infra: first stab at postgres stuff

Author: domdomegg

deploy/README.md

@@ -103,7 +103,7 @@ Pre-requisites:
     │   ├── cert_manager.go    # SSL certificate management
     │   ├── deploy.go          # Deployment orchestration
     │   ├── ingress.go         # Ingress controller setup
-    │   ├── mongodb.go         # MongoDB deployment
+    │   ├── postgres.go        # PostgreSQL database deployment
     │   └── registry.go        # MCP Registry deployment
     └── providers/       # Kubernetes cluster providers
         ├── types.go           # Provider interface definitions
@@ -122,7 +122,7 @@ Pre-requisites:
 5. `k8s.DeployAll()` orchestrates complete deployment:
    - Certificate manager for SSL/TLS
    - Ingress controller for external access
-   - MongoDB for data persistence
+   - Database for data persistence
    - MCP Registry application
 
 ## Configuration
@@ -152,5 +152,5 @@ kubectl get svc -n ingress-nginx
 
 ```bash
 kubectl logs -l app=mcp-registry
-kubectl logs -l app=mongodb
+kubectl logs -l app=postgres
 ```

deploy/pkg/k8s/deploy.go

@@ -21,14 +21,14 @@ func DeployAll(ctx *pulumi.Context, cluster *providers.ProviderInfo, environment
 		return nil, err
 	}
 
-	// Deploy MongoDB
-	err = DeployMongoDB(ctx, cluster, environment)
+	// Deploy PostgreSQL databases
+	pgCluster, err := DeployPostgresDatabases(ctx, cluster, environment)
 	if err != nil {
 		return nil, err
 	}
 
 	// Deploy MCP Registry
-	service, err = DeployMCPRegistry(ctx, cluster, environment)
+	service, err = DeployMCPRegistry(ctx, cluster, environment, pgCluster)
 	if err != nil {
 		return nil, err
 	}

deploy/pkg/k8s/mongodb.go

@@ -0,0 +1,53 @@
+package k8s
+
+import (
+	"github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/apiextensions"
+	"github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/helm/v3"
+	metav1 "github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/meta/v1"
+	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
+
+	"github.com/modelcontextprotocol/registry/deploy/infra/pkg/providers"
+)
+
+// DeployPostgresDatabases deploys the CloudNative PostgreSQL operator and PostgreSQL cluster
+func DeployPostgresDatabases(ctx *pulumi.Context, cluster *providers.ProviderInfo, environment string) (*apiextensions.CustomResource, error) {
+	// Install cloudnative-pg Helm chart
+	cloudNativePG, err := helm.NewChart(ctx, "cloudnative-pg", helm.ChartArgs{
+		Chart:   pulumi.String("cloudnative-pg"),
+		Version: pulumi.String("v0.26.0"),
+		FetchArgs: helm.FetchArgs{
+			Repo: pulumi.String("https://cloudnative-pg.github.io/charts"),
+		},
+		Namespace: pulumi.String("cnpg-system"),
+	}, pulumi.Provider(cluster.Provider))
+	if err != nil {
+		return nil, err
+	}
+
+	// Create PostgreSQL cluster
+	pgCluster, err := apiextensions.NewCustomResource(ctx, "registry-pg", &apiextensions.CustomResourceArgs{
+		ApiVersion: pulumi.String("postgresql.cnpg.io/v1"),
+		Kind:       pulumi.String("Cluster"),
+		Metadata: &metav1.ObjectMetaArgs{
+			Name:      pulumi.String("registry-pg"),
+			Namespace: pulumi.String("default"),
+			Labels: pulumi.StringMap{
+				"app":         pulumi.String("registry-pg"),
+				"environment": pulumi.String(environment),
+			},
+		},
+		OtherFields: map[string]interface{}{
+			"spec": map[string]interface{}{
+				"instances": 1,
+				"storage": map[string]interface{}{
+					"size": "50Gi",
+				},
+			},
+		},
+	}, pulumi.Provider(cluster.Provider), pulumi.DependsOn([]pulumi.Resource{cloudNativePG}))
+	if err != nil {
+		return nil, err
+	}
+
+	return pgCluster, nil
+}

deploy/pkg/k8s/postgres.go

@@ -5,6 +5,7 @@ import (
 	"strings"
 
 	v1 "github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/apps/v1"
+	"github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/apiextensions"
 	corev1 "github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/core/v1"
 	metav1 "github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/meta/v1"
 	networkingv1 "github.com/pulumi/pulumi-kubernetes/sdk/v4/go/kubernetes/networking/v1"
@@ -26,7 +27,7 @@ func getGitCommitHash() string {
 }
 
 // DeployMCPRegistry deploys the MCP Registry to the Kubernetes cluster
-func DeployMCPRegistry(ctx *pulumi.Context, cluster *providers.ProviderInfo, environment string) (*corev1.Service, error) {
+func DeployMCPRegistry(ctx *pulumi.Context, cluster *providers.ProviderInfo, environment string, pgCluster *apiextensions.CustomResource) (*corev1.Service, error) {
 	conf := config.New(ctx, "mcp-registry")
 	githubClientId := conf.Require("githubClientId")
 
@@ -91,8 +92,15 @@ func DeployMCPRegistry(ctx *pulumi.Context, cluster *providers.ProviderInfo, env
 							},
 							Env: corev1.EnvVarArray{
 								&corev1.EnvVarArgs{
-									Name:  pulumi.String("MCP_REGISTRY_DATABASE_URL"),
-									Value: pulumi.String("mongodb://mongodb.default.svc.cluster.local:27017"),
+									Name: pulumi.String("MCP_REGISTRY_DATABASE_URL"),
+									ValueFrom: &corev1.EnvVarSourceArgs{
+										SecretKeyRef: &corev1.SecretKeySelectorArgs{
+											Name: pgCluster.Metadata.Name().ApplyT(func(name string) string {
+												return name + "-app"
+											}).(pulumi.StringOutput),
+											Key: pulumi.String("uri"),
+										},
+									},
 								},
 								&corev1.EnvVarArgs{
 									Name:  pulumi.String("MCP_REGISTRY_GITHUB_CLIENT_ID"),

deploy/pkg/k8s/registry.go

@@ -56,19 +56,3 @@ CREATE TRIGGER update_servers_updated_at
     BEFORE UPDATE ON servers 
     FOR EACH ROW 
     EXECUTE FUNCTION update_updated_at_column();
-
--- View for listing servers (similar to current MongoDB List behavior)
-CREATE VIEW server_list AS
-SELECT 
-    id,
-    name,
-    description,
-    status,
-    repository,
-    jsonb_build_object(
-        'version', version,
-        'release_date', release_date,
-        'is_latest', is_latest
-    ) as version_detail
-FROM servers
-WHERE is_latest = true;