chore: Adding support to ssh-agent on Windows using named pipes (#733)

go.mod

@@ -33,6 +33,7 @@ require (
 	golang.org/x/term v0.0.0-20210615171337-6886f2dfbf5b
 	golang.org/x/text v0.3.7 // indirect
 	golang.org/x/tools v0.1.7 // indirect
+	gopkg.in/natefinch/npipe.v2 v2.0.0-20160621034901-c1b8fa8bdcce
 	gopkg.in/yaml.v2 v2.4.0
 	k8s.io/api v0.21.4
 	k8s.io/apimachinery v0.21.4

go.sum

@@ -1780,6 +1780,8 @@ gopkg.in/ini.v1 v1.51.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
 gopkg.in/ini.v1 v1.62.0 h1:duBzk771uxoUuOlyRLkHsygud9+5lrlGjdFBb4mSKDU=
 gopkg.in/ini.v1 v1.62.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
 gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k=
+gopkg.in/natefinch/npipe.v2 v2.0.0-20160621034901-c1b8fa8bdcce h1:+JknDZhAj8YMt7GC73Ei8pv4MzjDUNPHgQWJdtMAaDU=
+gopkg.in/natefinch/npipe.v2 v2.0.0-20160621034901-c1b8fa8bdcce/go.mod h1:5AcXVHNjg+BDxry382+8OKon8SEWiKktQR07RKPsv1c=
 gopkg.in/resty.v1 v1.12.0/go.mod h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo=
 gopkg.in/square/go-jose.v2 v2.2.2/go.mod h1:M9dMgbHiYLoDGQrXy7OpJDJWiKiU//h+vD76mk0e1AI=
 gopkg.in/square/go-jose.v2 v2.3.1/go.mod h1:M9dMgbHiYLoDGQrXy7OpJDJWiKiU//h+vD76mk0e1AI=

ssh/ssh_agent_conf.go

@@ -0,0 +1,12 @@
+//go:build !windows
+// +build !windows
+
+package ssh
+
+import (
+	"net"
+)
+
+func dialSSHAgentConnection(sock string) (agentConn net.Conn, error error) {
+	return net.Dial("unix", sock)
+}

ssh/ssh_agent_conf_windows.go

@@ -0,0 +1,17 @@
+package ssh
+
+import (
+	"net"
+	"strings"
+
+	"gopkg.in/natefinch/npipe.v2"
+)
+
+func dialSSHAgentConnection(sock string) (agentConn net.Conn, error error) {
+	if strings.Contains(sock, "\\pipe\\") {
+		agentConn, error = npipe.Dial(sock)
+	} else {
+		agentConn, error = net.Dial("unix", sock)
+	}
+	return
+}

ssh/ssh_dialer.go

@@ -271,7 +271,7 @@ func NewSSHClientConfig(url *urlPkg.URL, credentialsConfig Config) (*ssh.ClientC
 	if sock, found := os.LookupEnv("SSH_AUTH_SOCK"); found && sock != "" {
 		var agentSigners []ssh.Signer
 		var agentConn net.Conn
-		agentConn, err = net.Dial("unix", sock)
+		agentConn, err = dialSSHAgentConnection(sock)
 		if err != nil {
 			return nil, fmt.Errorf("failed to connect to ssh-agent's socket: %w", err)
 		}