diff options
| author | Max Resnick <max@ofmax.li> | 2025-09-20 23:59:46 -0700 |
|---|---|---|
| committer | Max Resnick <max@ofmax.li> | 2025-09-20 23:59:46 -0700 |
| commit | de0e66a14419b608f6d81ebd12598fceb07a91ea (patch) | |
| tree | 9d59c9b889c9384d7a02cf358d9d1d4efb950e7a /internal | |
| parent | e81cbe44ae496f32c98011c739718d4df7570f73 (diff) | |
| download | go-git-server-de0e66a14419b608f6d81ebd12598fceb07a91ea.tar.gz | |
fix: some things
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/admin/model_test.go | 4 | ||||
| -rw-r--r-- | internal/modules/handler.go | 107 | ||||
| -rw-r--r-- | internal/modules/handler_test.go | 316 |
3 files changed, 398 insertions, 29 deletions
diff --git a/internal/admin/model_test.go b/internal/admin/model_test.go index 082b3f0..d36c9d0 100644 --- a/internal/admin/model_test.go +++ b/internal/admin/model_test.go @@ -146,8 +146,8 @@ func TestLoadServerConfig(t *testing.T) { if err != nil { t.Fatal(err) } - if len(loadedFile.Repos) != 2 { - t.Fatalf("expected to find 2 repos found %d", len(loadedFile.Repos)) + if len(loadedFile.Repos) != 3 { + t.Fatalf("expected to find 3 repos found %d", len(loadedFile.Repos)) } }) diff --git a/internal/modules/handler.go b/internal/modules/handler.go index 9fa1094..c01f716 100644 --- a/internal/modules/handler.go +++ b/internal/modules/handler.go @@ -5,6 +5,7 @@ import ( "fmt" "log/slog" "net/http" + "net/url" "path/filepath" "strings" @@ -18,6 +19,74 @@ type ModuleHandler struct { serverHost string } +// normalizeImportPath creates a properly formatted full import path +func (h *ModuleHandler) normalizeImportPath(modulePath string) (string, error) { + if h.serverHost == "" { + return "", fmt.Errorf("serverHost cannot be empty") + } + if modulePath == "" { + return "", fmt.Errorf("modulePath cannot be empty") + } + if strings.Contains(modulePath, "..") { + return "", fmt.Errorf("modulePath cannot contain '..'") + } + + // Clean the inputs + host := strings.TrimRight(h.serverHost, "/") + module := strings.Trim(modulePath, "/") + + // Validate that module path doesn't contain invalid characters + if strings.ContainsAny(module, " \t\n\r") { + return "", fmt.Errorf("modulePath cannot contain whitespace characters") + } + + return host + "/" + module, nil +} + +// buildRepoURL creates a proper repository URL +func (h *ModuleHandler) buildRepoURL(modulePath string) (string, error) { + _, err := h.normalizeImportPath(modulePath) + if err != nil { + return "", err + } + + // Use proper URL building to ensure valid URLs + repoURL := &url.URL{ + Scheme: "https", + Host: h.serverHost, + Path: "/" + strings.Trim(modulePath, "/"), + } + + return repoURL.String(), nil +} + +// generateGoImportHTML creates the HTML response for go-import requests +func (h *ModuleHandler) generateGoImportHTML(modulePath string) (string, error) { + fullImportPath, err := h.normalizeImportPath(modulePath) + if err != nil { + return "", fmt.Errorf("failed to normalize import path: %w", err) + } + + repoURL, err := h.buildRepoURL(modulePath) + if err != nil { + return "", fmt.Errorf("failed to build repository URL: %w", err) + } + + return fmt.Sprintf(`<!DOCTYPE html> +<html> +<head> + <meta name="go-import" content="%s git %s"> + <meta name="go-source" content="%s %s %s/tree/{/dir} %s/blob/{/dir}/{file}#L{line}"> +</head> +<body> + go get %s +</body> +</html>`, + fullImportPath, repoURL, + fullImportPath, repoURL, repoURL, repoURL, + fullImportPath), nil +} + // NewModuleHandler creates a new module handler with explicit routes for known repos func NewModuleHandler(reposDir, serverHost string, config *admin.ServerRepos) http.Handler { handler := &ModuleHandler{ @@ -266,19 +335,12 @@ func (h *ModuleHandler) handleGoImportForModule(w http.ResponseWriter, r *http.R } // Generate HTML with go-import meta tag - html := fmt.Sprintf(`<!DOCTYPE html> -<html> -<head> - <meta name="go-import" content="%s git https://%s/%s"> - <meta name="go-source" content="%s https://%s/%s https://%s/%s/tree/{/dir} https://%s/%s/blob/{/dir}/{file}#L{line}"> -</head> -<body> - go get %s -</body> -</html>`, - modulePath, h.serverHost, modulePath, - modulePath, h.serverHost, modulePath, h.serverHost, modulePath, h.serverHost, modulePath, - modulePath) + html, err := h.generateGoImportHTML(modulePath) + if err != nil { + slog.Error("failed to generate go-import HTML", "module", modulePath, "error", err) + http.Error(w, "Internal Server Error", http.StatusInternalServerError) + return + } w.Header().Set("Content-Type", "text/html; charset=utf-8") w.WriteHeader(http.StatusOK) @@ -300,19 +362,12 @@ func (h *ModuleHandler) handleGoImport(w http.ResponseWriter, r *http.Request) { modulePath := ExtractModulePath(r.URL.Path) // Generate HTML with go-import meta tag - html := fmt.Sprintf(`<!DOCTYPE html> -<html> -<head> - <meta name="go-import" content="%s git https://%s/%s"> - <meta name="go-source" content="%s https://%s/%s https://%s/%s/tree/{/dir} https://%s/%s/blob/{/dir}/{file}#L{line}"> -</head> -<body> - go get %s -</body> -</html>`, - modulePath, h.serverHost, modulePath, - modulePath, h.serverHost, modulePath, h.serverHost, modulePath, h.serverHost, modulePath, - modulePath) + html, err := h.generateGoImportHTML(modulePath) + if err != nil { + slog.Error("failed to generate go-import HTML", "module", modulePath, "error", err) + http.Error(w, "Internal Server Error", http.StatusInternalServerError) + return + } w.Header().Set("Content-Type", "text/html; charset=utf-8") w.WriteHeader(http.StatusOK) diff --git a/internal/modules/handler_test.go b/internal/modules/handler_test.go index b173f98..943c74c 100644 --- a/internal/modules/handler_test.go +++ b/internal/modules/handler_test.go @@ -65,7 +65,7 @@ func TestHandleGoImport_ConfiguredModule(t *testing.T) { } // Check for correct module path and VCS info - expectedContent := `content="mymodule git https://git.example.com/mymodule"` + expectedContent := `content="git.example.com/mymodule git https://git.example.com/mymodule"` if !strings.Contains(body, expectedContent) { t.Errorf("response should contain %s", expectedContent) } @@ -548,3 +548,317 @@ func TestModuleMiddleware(t *testing.T) { } }) } + +// Tests for new helper functions +func TestNormalizeImportPath(t *testing.T) { + handler := &ModuleHandler{ + reposDir: "/tmp/repos", + serverHost: "git.example.com", + } + + tests := []struct { + name string + serverHost string + modulePath string + expected string + shouldErr bool + }{ + { + name: "valid_simple_path", + serverHost: "git.example.com", + modulePath: "mymodule", + expected: "git.example.com/mymodule", + shouldErr: false, + }, + { + name: "trailing_slash_on_host", + serverHost: "git.example.com/", + modulePath: "mymodule", + expected: "git.example.com/mymodule", + shouldErr: false, + }, + { + name: "leading_slash_on_module", + serverHost: "git.example.com", + modulePath: "/mymodule", + expected: "git.example.com/mymodule", + shouldErr: false, + }, + { + name: "nested_module_path", + serverHost: "git.example.com", + modulePath: "company/mymodule", + expected: "git.example.com/company/mymodule", + shouldErr: false, + }, + { + name: "empty_server_host", + serverHost: "", + modulePath: "mymodule", + expected: "", + shouldErr: true, + }, + { + name: "empty_module_path", + serverHost: "git.example.com", + modulePath: "", + expected: "", + shouldErr: true, + }, + { + name: "path_traversal_attempt", + serverHost: "git.example.com", + modulePath: "../../../etc/passwd", + expected: "", + shouldErr: true, + }, + { + name: "whitespace_in_module_path", + serverHost: "git.example.com", + modulePath: "my module", + expected: "", + shouldErr: true, + }, + { + name: "tab_in_module_path", + serverHost: "git.example.com", + modulePath: "my\tmodule", + expected: "", + shouldErr: true, + }, + } + + for _, tt := range tests { + t.Run(tt.name, func(t *testing.T) { + // Update handler for this test + handler.serverHost = tt.serverHost + + result, err := handler.normalizeImportPath(tt.modulePath) + + if tt.shouldErr { + if err == nil { + t.Errorf("expected error but got none") + } + } else { + if err != nil { + t.Errorf("unexpected error: %v", err) + } + if result != tt.expected { + t.Errorf("expected %q, got %q", tt.expected, result) + } + } + }) + } +} + +func TestBuildRepoURL(t *testing.T) { + handler := &ModuleHandler{ + reposDir: "/tmp/repos", + serverHost: "git.example.com", + } + + tests := []struct { + name string + modulePath string + expected string + shouldErr bool + }{ + { + name: "simple_module", + modulePath: "mymodule", + expected: "https://git.example.com/mymodule", + shouldErr: false, + }, + { + name: "nested_module", + modulePath: "company/mymodule", + expected: "https://git.example.com/company/mymodule", + shouldErr: false, + }, + { + name: "invalid_module_path", + modulePath: "", + expected: "", + shouldErr: true, + }, + } + + for _, tt := range tests { + t.Run(tt.name, func(t *testing.T) { + result, err := handler.buildRepoURL(tt.modulePath) + + if tt.shouldErr { + if err == nil { + t.Errorf("expected error but got none") + } + } else { + if err != nil { + t.Errorf("unexpected error: %v", err) + } + if result != tt.expected { + t.Errorf("expected %q, got %q", tt.expected, result) + } + } + }) + } +} + +func TestGenerateGoImportHTML(t *testing.T) { + handler := &ModuleHandler{ + reposDir: "/tmp/repos", + serverHost: "git.example.com", + } + + tests := []struct { + name string + modulePath string + shouldErr bool + expectedHTML []string // Strings that should be present in the HTML + }{ + { + name: "valid_module", + modulePath: "mymodule", + shouldErr: false, + expectedHTML: []string{ + `<meta name="go-import" content="git.example.com/mymodule git https://git.example.com/mymodule">`, + `<meta name="go-source" content="git.example.com/mymodule https://git.example.com/mymodule`, + `go get git.example.com/mymodule`, + }, + }, + { + name: "invalid_module", + modulePath: "", + shouldErr: true, + expectedHTML: nil, + }, + { + name: "module_with_path_traversal", + modulePath: "../../../etc/passwd", + shouldErr: true, + expectedHTML: nil, + }, + } + + for _, tt := range tests { + t.Run(tt.name, func(t *testing.T) { + result, err := handler.generateGoImportHTML(tt.modulePath) + + if tt.shouldErr { + if err == nil { + t.Errorf("expected error but got none") + } + } else { + if err != nil { + t.Errorf("unexpected error: %v", err) + } + + for _, expected := range tt.expectedHTML { + if !strings.Contains(result, expected) { + t.Errorf("HTML should contain %q, got:\n%s", expected, result) + } + } + } + }) + } +} + +// Integration test that simulates the full go-get flow +func TestGoGetIntegration(t *testing.T) { + config := &admin.ServerRepos{ + Repos: []*admin.GitRepo{ + { + Name: "mymodule", + GoModule: true, + }, + }, + } + + handler := NewModuleHandler("/tmp/repos", "git.example.com", config) + + // Test the complete go-get flow: + // 1. Initial request with go-get=1 + // 2. Verify correct meta tags are returned + // 3. Verify import path format is correct + + req := httptest.NewRequest("GET", "/mymodule?go-get=1", nil) + w := httptest.NewRecorder() + + handler.ServeHTTP(w, req) + + if w.Code != http.StatusOK { + t.Fatalf("expected status 200, got %d", w.Code) + } + + body := w.Body.String() + + // Verify the response contains proper go-import directive + expectedImport := `content="git.example.com/mymodule git https://git.example.com/mymodule"` + if !strings.Contains(body, expectedImport) { + t.Errorf("response should contain correct go-import directive: %s\nGot: %s", expectedImport, body) + } + + // Verify the response contains proper go-source directive + expectedSource := `content="git.example.com/mymodule https://git.example.com/mymodule` + if !strings.Contains(body, expectedSource) { + t.Errorf("response should contain correct go-source directive: %s\nGot: %s", expectedSource, body) + } + + // Verify the response contains proper body content + expectedBody := `go get git.example.com/mymodule` + if !strings.Contains(body, expectedBody) { + t.Errorf("response should contain correct body content: %s\nGot: %s", expectedBody, body) + } + + // Verify content type + contentType := w.Header().Get("Content-Type") + if contentType != "text/html; charset=utf-8" { + t.Errorf("expected content type text/html; charset=utf-8, got %s", contentType) + } + + // Test that the import path format matches Go's expectations: + // - Should be domain/path format + // - Should not have protocol prefix in the import path + // - Should use HTTPS for the repository URL + if strings.Contains(body, `content="mymodule git`) { + t.Error("import path should include domain, not just module name") + } + + if strings.Contains(body, `content="https://git.example.com/mymodule git`) { + t.Error("import path should not include protocol") + } +} + +// Test error handling in go-import generation +func TestGoImportErrorHandling(t *testing.T) { + // Test with invalid server configuration + handler := &ModuleHandler{ + reposDir: "/tmp/repos", + serverHost: "", // Invalid empty host + } + + req := httptest.NewRequest("GET", "/mymodule?go-get=1", nil) + w := httptest.NewRecorder() + + handler.handleGoImport(w, req) + + if w.Code != http.StatusInternalServerError { + t.Errorf("expected status 500 for invalid server config, got %d", w.Code) + } + + // Test with invalid module path characters + handler.serverHost = "git.example.com" + + req = httptest.NewRequest("GET", "/my%20module?go-get=1", nil) + w = httptest.NewRecorder() + + handler.handleGoImport(w, req) + + // Should handle URL-encoded paths gracefully or return appropriate error + if w.Code == http.StatusOK { + body := w.Body.String() + // Verify it doesn't contain malformed content + if strings.Contains(body, "%20") { + t.Error("response should not contain URL-encoded characters in meta tags") + } + } +} |