Function TestFileDBPoolRefCounting

server/server_test.go:753–812

(t *testing.T)

		{"present bare", []string{"ducklake", "cache_httpfs"}, true},
		{"present with source", []string{"ducklake", "cache_httpfs FROM community"}, true},
		{"absent", []string{"ducklake", "httpfs"}, false},
		{"empty list", []string{}, false},
		{"nil list", nil, false},
		{"similar name", []string{"not_cache_httpfs"}, false},
		{"substring match", []string{"cache_httpfs_v2 FROM community"}, false},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			got := hasCacheHTTPFS(tt.extensions)
			if got != tt.want {
				t.Errorf("hasCacheHTTPFS(%v) = %v, want %v", tt.extensions, got, tt.want)
			}
		})
	}
}

func TestOpenBaseDBFilePersistenceRejectsPathTraversal(t *testing.T) {
	dataDir := t.TempDir()
	cfg := Config{
		FilePersistence: true,
		DataDir:         dataDir,
	}

	cases := []struct {
		name     string
		username string
	}{
		{"parent directory", "../etc/evil"},
		{"slash in name", "foo/bar"},
		{"backslash dot-dot", "..\\windows"},
		{"dot-dot between names", "alice/../bob"},
	}

	for _, tc := range cases {
		t.Run(tc.name, func(t *testing.T) {
			db, err := openBaseDB(cfg, tc.username)
			if err == nil {
				_ = db.Close()
				t.Fatalf("expected error for username %q, got nil", tc.username)
			}
			if !strings.Contains(err.Error(), "invalid username for file persistence") {
				t.Fatalf("unexpected error: %v", err)
			}
		})
	}
}

func TestOpenBaseDBCreatesDataDir(t *testing.T) {
	base := t.TempDir()
	nested := filepath.Join(base, "deep", "nested", "dir")

	cfg := Config{
		FilePersistence: true,
		DataDir:         nested,
	}
	db, err := openBaseDB(cfg, "testuser")
	if err != nil {