V0.1.35

.github/workflows/test_and_release.yml

@@ -21,7 +21,7 @@ jobs:
     runs-on: ${{ matrix.os }}
     steps:
       - name: Set up Go 1.22
-        uses: actions/setup-go@v1
+        uses: actions/setup-go@v6
         with:
           go-version: 1.22
 

AGENTS.md

@@ -24,9 +24,13 @@ AGENTS.md
 
 - ユーザー向け挙動、CLI オプション、設定方法、インストール手順を変えた場合は、対応する README / docs も更新してください。
 
+---
+
 ## 補足
 
-### NFS / lsshfs compatibility patch
+### 注意事項
+
+#### NFS / lsshfs compatibility patch
 
 このリポジトリでは、`lsshfs` を macOS 上で NFS backend として利用した際に発生する以下の問題を回避するため、`go-nfs` と `go-billy` を `internal/third_party` 配下でローカル管理している。
 
@@ -36,7 +40,7 @@ AGENTS.md
 - `Error applying attributes: Operation not supported: permission denied`
 - mount 先に不要な一時ファイルや 0 byte ファイルが残ることがある
 
-#### 現在の依存構成
+##### 現在の依存構成
 
 `go.mod` では以下の `replace` を使っている。
 
@@ -45,9 +49,10 @@ AGENTS.md
 
 この構成は意図的なものであり、安易に upstream 版へ戻してはいけない。
 
-#### 具体的な修正内容
+##### 具体的な修正内容
+
+###### 1. `nfs_sftpfs.go`
 
-##### 1. `nfs_sftpfs.go`
 `NewChangeSFTPFS()` の返り値を、単純な `temporal.New(chroot.New(...))` ではなく、`billy.Change` を維持する wrapper に変更している。
 
 変更意図:
@@ -65,7 +70,8 @@ AGENTS.md
 
 これらは `sftp.Client` へ forward する。
 
-##### 2. `internal/third_party/github.com/willscott/go-nfs/nfs_oncreate.go`
+###### 2. `internal/third_party/github.com/willscott/go-nfs/nfs_oncreate.go`
+
 `CREATE_EXCLUSIVE` を即 `NFSStatusNotSupp` で失敗させないようにしている。
 
 変更意図:
@@ -76,19 +82,20 @@ AGENTS.md
 
 さらに、attribute apply に失敗した場合は、作りかけファイルを `Remove()` して cleanup するようにしている。
 
-##### 3. `internal/third_party/github.com/go-git/go-billy/v5`
+###### 3. `internal/third_party/github.com/go-git/go-billy/v5`
+
 このディレクトリは `replace` 先として内部保持している。
 現時点では `go-sshlib` 側の wrapper で `Change` 問題を吸収しているが、依存整合性と将来の patch 管理のため、`go-billy` も `internal/third_party` 側で固定している。
 
-#### 重要な注意
+##### 重要な注意
 
 以下は勝手に変更しないこと。
 
 - `go.mod` の `replace` の削除
 - `internal/third_party` 配下の削除
 - upstream 版への安易な差し戻し
 - `nfs_sftpfs.go` の `changeChrootFS` wrapper の除去
-- `nfs_oncreate.go` の `exclusive create` 回避処理の除去
+- `internal/third_party/github.com/willscott/go-nfs/nfs_oncreate.go` の `exclusive create` 回避処理の除去
 
 これらを戻すと、`lsshfs` で以下の不具合が再発する可能性が高い。
 
@@ -97,7 +104,7 @@ AGENTS.md
 - attribute apply エラー
 - macOS 上での不安定な file operation
 
-#### 変更時のルール
+##### 変更時のルール
 
 この周辺を変更する場合は、少なくとも以下を確認すること。
 

auth_test.go

@@ -132,6 +132,70 @@ func TestCreateControlPersistAuthMethodsRemovesTransientKeyFile(t *testing.T) {
 	}
 }
 
+func TestCleanupControlPersistTransientFilesRemovesDuplicates(t *testing.T) {
+	dir := t.TempDir()
+	path := filepath.Join(dir, "transient-key")
+	if err := os.WriteFile(path, []byte("secret"), 0o600); err != nil {
+		t.Fatalf("os.WriteFile() error = %v", err)
+	}
+
+	cleanupControlPersistTransientFiles([]string{path, path, ""})
+
+	if _, err := os.Stat(path); !os.IsNotExist(err) {
+		t.Fatalf("transient file still exists: stat err = %v", err)
+	}
+}
+
+func TestControlPersistAuthMethodKeyNil(t *testing.T) {
+	key, ok := controlPersistAuthMethodKey(nil)
+	if ok {
+		t.Fatalf("controlPersistAuthMethodKey(nil) = %#v, true; want false", key)
+	}
+}
+
+func TestLookupControlPersistAuthMethodUnknown(t *testing.T) {
+	auth := ssh.Password("secret")
+	if _, ok := lookupControlPersistAuthMethod(auth); ok {
+		t.Fatal("lookupControlPersistAuthMethod() unexpectedly found unregistered auth method")
+	}
+}
+
+func TestValidateControlPersistAuthDefinitionsMissingFields(t *testing.T) {
+	tests := []struct {
+		name string
+		defs []controlPersistAuthMethodDefinition
+		want string
+	}{
+		{
+			name: "password requires value",
+			defs: []controlPersistAuthMethodDefinition{{Type: "password"}},
+			want: "password auth requires Password",
+		},
+		{
+			name: "publickey requires key path",
+			defs: []controlPersistAuthMethodDefinition{{Type: "publickey"}},
+			want: "publickey auth requires KeyPath",
+		},
+		{
+			name: "pkcs11 requires provider",
+			defs: []controlPersistAuthMethodDefinition{{Type: "pkcs11"}},
+			want: "pkcs11 auth requires PKCS11Provider",
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			err := validateControlPersistAuthDefinitions(tt.defs)
+			if err == nil {
+				t.Fatal("validateControlPersistAuthDefinitions() error = nil, want non-nil")
+			}
+			if !strings.Contains(err.Error(), tt.want) {
+				t.Fatalf("validateControlPersistAuthDefinitions() error = %v, want %q", err, tt.want)
+			}
+		})
+	}
+}
+
 func writeTempPrivateKey(t *testing.T) string {
 	t.Helper()
 

common_proxy_test.go

@@ -0,0 +1,93 @@
+package sshlib
+
+import (
+	"os/user"
+	"path/filepath"
+	"testing"
+
+	"golang.org/x/net/proxy"
+)
+
+func TestGetAbsPathExpandsHomePrefix(t *testing.T) {
+	usr, err := user.Current()
+	if err != nil || usr == nil || usr.HomeDir == "" {
+		t.Skip("current user home directory is unavailable")
+	}
+
+	got := getAbsPath("~/sshlib-test")
+	want := filepath.Join(usr.HomeDir, "sshlib-test")
+	if got != want {
+		t.Fatalf("getAbsPath(%q) = %q, want %q", "~/sshlib-test", got, want)
+	}
+}
+
+func TestGetAbsPathPreservesTildeInsideWindowsShortNameStylePath(t *testing.T) {
+	input := filepath.Join("tmp", "RUNNERC~1", "sshlib")
+	got := getAbsPath(input)
+	want, err := filepath.Abs(input)
+	if err != nil {
+		t.Fatalf("filepath.Abs() error = %v", err)
+	}
+	if got != want {
+		t.Fatalf("getAbsPath(%q) = %q, want %q", input, got, want)
+	}
+}
+
+func TestCreateHttpProxyDialerIncludesAddressPortAndAuth(t *testing.T) {
+	p := &Proxy{
+		Type:      "http",
+		Addr:      "proxy.example.com",
+		Port:      "8080",
+		User:      "alice",
+		Password:  "secret",
+		Forwarder: &stubContextDialer{},
+	}
+
+	dialer, err := p.CreateHttpProxyDialer()
+	if err != nil {
+		t.Fatalf("CreateHttpProxyDialer() error = %v", err)
+	}
+
+	httpDialer, ok := dialer.(*httpProxy)
+	if !ok {
+		t.Fatalf("CreateHttpProxyDialer() type = %T, want *httpProxy", dialer)
+	}
+	if httpDialer.host != "proxy.example.com:8080" {
+		t.Fatalf("CreateHttpProxyDialer() host = %q, want %q", httpDialer.host, "proxy.example.com:8080")
+	}
+	if !httpDialer.haveAuth || httpDialer.username != "alice" || httpDialer.password != "secret" {
+		t.Fatalf("CreateHttpProxyDialer() auth = have:%t user:%q pass:%q", httpDialer.haveAuth, httpDialer.username, httpDialer.password)
+	}
+	if httpDialer.forward != p.Forwarder {
+		t.Fatal("CreateHttpProxyDialer() did not preserve custom forwarder")
+	}
+}
+
+func TestCreateHttpProxyDialerDefaultsToDirectForwarder(t *testing.T) {
+	p := &Proxy{
+		Type: "http",
+		Addr: "proxy.example.com",
+	}
+
+	dialer, err := p.CreateHttpProxyDialer()
+	if err != nil {
+		t.Fatalf("CreateHttpProxyDialer() error = %v", err)
+	}
+
+	httpDialer, ok := dialer.(*httpProxy)
+	if !ok {
+		t.Fatalf("CreateHttpProxyDialer() type = %T, want *httpProxy", dialer)
+	}
+	if httpDialer.forward != proxy.Direct {
+		t.Fatal("CreateHttpProxyDialer() should default to proxy.Direct forwarder")
+	}
+}
+
+func TestProxyRoutePortOrDefault(t *testing.T) {
+	if got := (ProxyRoute{Type: "ssh"}).portOrDefault(); got != "22" {
+		t.Fatalf("portOrDefault() = %q, want %q", got, "22")
+	}
+	if got := (ProxyRoute{Type: "http", Port: "8080"}).portOrDefault(); got != "8080" {
+		t.Fatalf("portOrDefault() = %q, want %q", got, "8080")
+	}
+}