Implement version-specific endpoints for /servers/{id}

- Update /servers/{id} endpoint to return latest version by default
- Add /servers/{id}?version={version} endpoint for specific versions
- Add /servers/{id}/versions endpoint to list all versions
- Enhance database layer with ServerID filter support
- Update service layer with new methods: GetByIDAndVersion, GetVersionsByID
- Update API documentation and OpenAPI specification
- Refactor PostgreSQL filter logic to reduce complexity
- All tests pass and endpoints tested locally

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>

Author: tadasant

cmd/publisher/commands/init.go

@@ -309,7 +309,7 @@ func createServerJSON(
 			URL:    repoURL,
 			Source: repoSource,
 		},
-		Version: version,
+		Version:  version,
 		Packages: []model.Package{pkg},
 	}
 }

cmd/publisher/commands/logout.go

@@ -13,7 +13,7 @@ func LogoutCommand() error {
 	}
 
 	tokenPath := filepath.Join(homeDir, TokenFileName)
-	
+
 	// Check if token file exists
 	if _, err := os.Stat(tokenPath); os.IsNotExist(err) {
 		_, _ = fmt.Fprintln(os.Stdout, "Not logged in")
@@ -30,7 +30,7 @@ func LogoutCommand() error {
 		".mcpregistry_github_token",
 		".mcpregistry_registry_token",
 	}
-	
+
 	for _, file := range legacyFiles {
 		path := filepath.Join(homeDir, file)
 		if _, err := os.Stat(path); err == nil {
@@ -40,4 +40,4 @@ func LogoutCommand() error {
 
 	_, _ = fmt.Fprintln(os.Stdout, "✓ Successfully logged out")
 	return nil
-}
+}

cmd/publisher/main.go

@@ -67,4 +67,4 @@ func printUsage() {
 	_, _ = fmt.Fprintln(os.Stdout, "  publish       Publish server.json to the registry")
 	_, _ = fmt.Fprintln(os.Stdout)
 	_, _ = fmt.Fprintln(os.Stdout, "Use 'mcp-publisher <command> --help' for more information about a command.")
-}
+}

deploy/pkg/k8s/ingress.go

@@ -51,7 +51,7 @@ func SetupIngressController(ctx *pulumi.Context, cluster *providers.ProviderInfo
 		Values: pulumi.Map{
 			"controller": pulumi.Map{
 				"service": pulumi.Map{
-					"type": serviceType,
+					"type":        serviceType,
 					"annotations": pulumi.Map{},
 				},
 				"config": pulumi.Map{

deploy/pkg/providers/gcp/provider.go

@@ -22,19 +22,19 @@ type Provider struct{}
 // createGCPProvider creates a GCP provider with explicit credentials if configured
 func createGCPProvider(ctx *pulumi.Context, name string) (*gcp.Provider, error) {
 	gcpConf := config.New(ctx, "gcp")
-	
+
 	// Get project ID from config
 	projectID := gcpConf.Get("project")
 	if projectID == "" {
 		return nil, fmt.Errorf("GCP project ID not configured. Set gcp:project")
 	}
-	
+
 	// Get region from config or use default
 	region := gcpConf.Get("region")
 	if region == "" {
 		region = "us-central1"
 	}
-	
+
 	// Get credentials from config (base64 encoded service account JSON)
 	credentials := gcpConf.Get("credentials")
 	if credentials != "" {
@@ -45,7 +45,7 @@ func createGCPProvider(ctx *pulumi.Context, name string) (*gcp.Provider, error)
 		}
 		credentials = string(decodedCreds)
 	}
-	
+
 	// Create a GCP provider with explicit credentials if provided
 	if credentials != "" {
 		return gcp.NewProvider(ctx, name, &gcp.ProviderArgs{
@@ -54,7 +54,7 @@ func createGCPProvider(ctx *pulumi.Context, name string) (*gcp.Provider, error)
 			Credentials: pulumi.String(credentials),
 		})
 	}
-	
+
 	return nil, nil
 }
 

docs/reference/api/openapi.yaml

@@ -39,7 +39,7 @@ paths:
   /v0/servers/{id}:
     get:
       summary: Get MCP server details
-      description: Returns detailed information about a specific MCP server
+      description: Returns detailed information about a specific MCP server. By default, returns the latest version. Use the 'version' query parameter to retrieve a specific version.
       parameters:
         - name: id
           in: path
@@ -50,9 +50,10 @@ paths:
             format: uuid
         - name: version
           in: query
-          description: Desired MCP server version
+          description: Specific version to retrieve (optional). If not provided, returns the latest version.
           schema:
             type: string
+          example: "1.0.2"
       responses:
         '200':
           description: Detailed server information
@@ -70,6 +71,40 @@ paths:
                   error:
                     type: string
                     example: "Server not found"
+  /v0/servers/{id}/versions:
+    get:
+      summary: Get all versions of an MCP server
+      description: Returns a list of all versions for a specific MCP server
+      parameters:
+        - name: id
+          in: path
+          required: true
+          description: Unique ID of the server
+          schema:
+            type: string
+            format: uuid
+      responses:
+        '200':
+          description: List of all server versions
+          content:
+            application/json:
+              schema:
+                type: object
+                properties:
+                  versions:
+                    type: array
+                    items:
+                      $ref: '#/components/schemas/ServerDetail'
+        '404':
+          description: Server not found
+          content:
+            application/json:
+              schema:
+                type: object
+                properties:
+                  error:
+                    type: string
+                    example: "Server not found"
   /v0/publish:
     post:
       summary: Publish MCP server (Optional)

internal/api/handlers/v0/publish_integration_test.go

@@ -160,9 +160,9 @@ func TestPublishIntegration(t *testing.T) {
 
 	t.Run("publish fails with invalid token", func(t *testing.T) {
 		publishReq := apiv0.ServerJSON{
-			Name:          "io.github.domdomegg/test-server",
-			Description:   "Test server",
-			Version: "1.0.0",
+			Name:        "io.github.domdomegg/test-server",
+			Description: "Test server",
+			Version:     "1.0.0",
 		}
 
 		body, err := json.Marshal(publishReq)
@@ -183,7 +183,7 @@ func TestPublishIntegration(t *testing.T) {
 		publishReq := apiv0.ServerJSON{
 			Name:        "io.github.other/test-server",
 			Description: "A test server",
-			Version: "1.0.0",
+			Version:     "1.0.0",
 			Repository: model.Repository{
 				URL:    "https://github.com/example/test-server",
 				Source: "github",
@@ -219,8 +219,8 @@ func TestPublishIntegration(t *testing.T) {
 		publishReq := apiv0.ServerJSON{
 			Name:        "io.github.domdomegg/airtable-mcp-server",
 			Description: "A test server with MCPB package",
-			Version: "1.7.2",
-			Status: model.StatusActive,
+			Version:     "1.7.2",
+			Status:      model.StatusActive,
 			Packages: []model.Package{
 				{
 					RegistryType: model.RegistryTypeMCPB,

internal/api/handlers/v0/publish_registry_validation_test.go

@@ -47,7 +47,7 @@ func TestPublishRegistryValidation(t *testing.T) {
 		publishReq := apiv0.ServerJSON{
 			Name:        "com.example/test-server-with-npm",
 			Description: "A test server with invalid npm package reference",
-			Version: "1.0.0",
+			Version:     "1.0.0",
 			Packages: []model.Package{
 				{
 					RegistryType: model.RegistryTypeNPM,
@@ -88,7 +88,7 @@ func TestPublishRegistryValidation(t *testing.T) {
 		publishReq := apiv0.ServerJSON{
 			Name:        "com.example/test-server-mcpb-validation",
 			Description: "A test server with MCPB package and registry validation enabled",
-			Version: "0.0.36",
+			Version:     "0.0.36",
 			Packages: []model.Package{
 				{
 					RegistryType: model.RegistryTypeMCPB,
@@ -138,7 +138,7 @@ func TestPublishRegistryValidation(t *testing.T) {
 		publishReq := apiv0.ServerJSON{
 			Name:        "com.example/test-server-multiple-packages",
 			Description: "A test server with multiple packages where second fails",
-			Version: "1.0.0",
+			Version:     "1.0.0",
 			Packages: []model.Package{
 				{
 					RegistryType: model.RegistryTypeMCPB,
@@ -189,7 +189,7 @@ func TestPublishRegistryValidation(t *testing.T) {
 		publishReq := apiv0.ServerJSON{
 			Name:        "com.example/test-server-first-package-fails",
 			Description: "A test server where first package fails",
-			Version: "1.0.0",
+			Version:     "1.0.0",
 			Packages: []model.Package{
 				{
 					RegistryType: model.RegistryTypeNPM,

internal/api/handlers/v0/publish_test.go

@@ -113,9 +113,9 @@ func TestPublishEndpoint(t *testing.T) {
 		{
 			name: "invalid authorization header format",
 			requestBody: apiv0.ServerJSON{
-				Name:          "io.github.domdomegg/test-server",
-				Description:   "Test server",
-				Version: "1.0.0",
+				Name:        "io.github.domdomegg/test-server",
+				Description: "Test server",
+				Version:     "1.0.0",
 			},
 			authHeader: "InvalidFormat",
 			setupRegistryService: func(_ service.RegistryService) {
@@ -129,7 +129,7 @@ func TestPublishEndpoint(t *testing.T) {
 			requestBody: apiv0.ServerJSON{
 				Name:        "test-server",
 				Description: "A test server",
-				Version: "1.0.0",
+				Version:     "1.0.0",
 			},
 			authHeader: "Bearer invalidToken",
 			setupRegistryService: func(_ service.RegistryService) {
@@ -143,7 +143,7 @@ func TestPublishEndpoint(t *testing.T) {
 			requestBody: apiv0.ServerJSON{
 				Name:        "io.github.other/test-server",
 				Description: "A test server",
-				Version: "1.0.0",
+				Version:     "1.0.0",
 				Repository: model.Repository{
 					URL:    "https://github.com/example/test-server",
 					Source: "github",
@@ -167,7 +167,7 @@ func TestPublishEndpoint(t *testing.T) {
 			requestBody: apiv0.ServerJSON{
 				Name:        "example/test-server",
 				Description: "A test server",
-				Version: "1.0.0",
+				Version:     "1.0.0",
 				Repository: model.Repository{
 					URL:    "https://github.com/example/test-server",
 					Source: "github",
@@ -185,7 +185,7 @@ func TestPublishEndpoint(t *testing.T) {
 				existingServer := apiv0.ServerJSON{
 					Name:        "example/test-server",
 					Description: "Existing test server",
-					Version: "1.0.0",
+					Version:     "1.0.0",
 					Repository: model.Repository{
 						URL:    "https://github.com/example/test-server-existing",
 						Source: "github",
@@ -202,7 +202,7 @@ func TestPublishEndpoint(t *testing.T) {
 			requestBody: apiv0.ServerJSON{
 				Name:        "com.example/test-server-mcpb",
 				Description: "A test server with MCPB package",
-				Version: "1.0.0",
+				Version:     "1.0.0",
 				Packages: []model.Package{
 					{
 						RegistryType: model.RegistryTypeMCPB,

internal/api/handlers/v0/servers.go

@@ -36,9 +36,20 @@ type ListServersBody struct {
 
 // ServerDetailInput represents the input for getting server details
 type ServerDetailInput struct {
+	ID      string `path:"id" doc:"Server ID (UUID)" format:"uuid"`
+	Version string `query:"version" doc:"Specific version to retrieve (optional)" required:"false" example:"1.0.0"`
+}
+
+// ServerVersionsInput represents the input for getting server versions
+type ServerVersionsInput struct {
 	ID string `path:"id" doc:"Server ID (UUID)" format:"uuid"`
 }
 
+// ServerVersionsBody represents the response body for server versions
+type ServerVersionsBody struct {
+	Versions []apiv0.ServerJSON `json:"versions" doc:"List of all versions for the server"`
+}
+
 // RegisterServersEndpoints registers all server-related endpoints
 func RegisterServersEndpoints(api huma.API, registry service.RegistryService) {
 	// List servers endpoint
@@ -118,11 +129,21 @@ func RegisterServersEndpoints(api huma.API, registry service.RegistryService) {
 		Method:      http.MethodGet,
 		Path:        "/v0/servers/{id}",
 		Summary:     "Get MCP server details",
-		Description: "Get detailed information about a specific MCP server",
+		Description: "Get detailed information about a specific MCP server. Returns the latest version by default, or a specific version if the 'version' query parameter is provided.",
 		Tags:        []string{"servers"},
 	}, func(_ context.Context, input *ServerDetailInput) (*Response[apiv0.ServerJSON], error) {
-		// Get the server details from the registry service
-		serverDetail, err := registry.GetByID(input.ID)
+		var serverDetail *apiv0.ServerJSON
+		var err error
+
+		// Check if a specific version is requested
+		if input.Version != "" {
+			// Get specific version
+			serverDetail, err = registry.GetByIDAndVersion(input.ID, input.Version)
+		} else {
+			// Get latest version
+			serverDetail, err = registry.GetByID(input.ID)
+		}
+
 		if err != nil {
 			if err.Error() == "record not found" {
 				return nil, huma.Error404NotFound("Server not found")
@@ -134,4 +155,29 @@ func RegisterServersEndpoints(api huma.API, registry service.RegistryService) {
 			Body: *serverDetail,
 		}, nil
 	})
+
+	// Get server versions endpoint
+	huma.Register(api, huma.Operation{
+		OperationID: "get-server-versions",
+		Method:      http.MethodGet,
+		Path:        "/v0/servers/{id}/versions",
+		Summary:     "Get all versions of an MCP server",
+		Description: "Get a list of all versions for a specific MCP server",
+		Tags:        []string{"servers"},
+	}, func(_ context.Context, input *ServerVersionsInput) (*Response[ServerVersionsBody], error) {
+		// Get all versions from the registry service
+		versions, err := registry.GetVersionsByID(input.ID)
+		if err != nil {
+			if err.Error() == "record not found" {
+				return nil, huma.Error404NotFound("Server not found")
+			}
+			return nil, huma.Error500InternalServerError("Failed to get server versions", err)
+		}
+
+		return &Response[ServerVersionsBody]{
+			Body: ServerVersionsBody{
+				Versions: versions,
+			},
+		}, nil
+	})
 }