Add v1 conversion test, runtime scheme

Author: benjaminjb

internal/controller/runtime/runtime.go

@@ -15,6 +15,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/manager"
 
 	"github.com/crunchydata/postgres-operator/internal/logging"
+	v1 "github.com/crunchydata/postgres-operator/pkg/apis/postgres-operator.crunchydata.com/v1"
 	"github.com/crunchydata/postgres-operator/pkg/apis/postgres-operator.crunchydata.com/v1beta1"
 )
 
@@ -34,6 +35,9 @@ func init() {
 	if err := v1beta1.AddToScheme(Scheme); err != nil {
 		panic(err)
 	}
+	if err := v1.AddToScheme(Scheme); err != nil {
+		panic(err)
+	}
 	if err := volumesnapshotv1.AddToScheme(Scheme); err != nil {
 		panic(err)
 	}

internal/testing/validation/postgrescluster_test.go

@@ -18,6 +18,7 @@ import (
 	"github.com/crunchydata/postgres-operator/internal/controller/runtime"
 	"github.com/crunchydata/postgres-operator/internal/testing/cmp"
 	"github.com/crunchydata/postgres-operator/internal/testing/require"
+	v1 "github.com/crunchydata/postgres-operator/pkg/apis/postgres-operator.crunchydata.com/v1"
 	"github.com/crunchydata/postgres-operator/pkg/apis/postgres-operator.crunchydata.com/v1beta1"
 )
 
@@ -519,3 +520,98 @@ func TestPostgresUserOptions(t *testing.T) {
 		assert.NilError(t, cc.Create(ctx, cluster, client.DryRunAll))
 	})
 }
+
+func TestPostgresUserInterfaceAcrossVersions(t *testing.T) {
+	ctx := context.Background()
+	cc := require.Kubernetes(t)
+	t.Parallel()
+
+	namespace := require.Namespace(t, cc)
+
+	base := v1beta1.NewPostgresCluster()
+	// Start with a bunch of required fields.
+	base.Namespace = namespace.Name
+	base.Name = "postgres-pgadmin"
+	require.UnmarshalInto(t, &base.Spec, `{
+		userInterface: {
+			pgAdmin: {
+				dataVolumeClaimSpec: {
+					accessModes: [ReadWriteOnce],
+					resources: { requests: { storage: 1Mi } },
+				},
+			},
+		},
+		postgresVersion: 16,
+		backups: {
+			pgbackrest: {
+				repos: [{ name: repo1 }],
+			},
+		},
+		instances: [{
+			dataVolumeClaimSpec: {
+				accessModes: [ReadWriteOnce],
+				resources: { requests: { storage: 1Mi } },
+			},
+		}],
+	}`)
+
+	v1base := v1.NewPostgresCluster()
+	// Start with a bunch of required fields.
+	v1base.Namespace = namespace.Name
+	v1base.Name = "postgres-pgadmin"
+	require.UnmarshalInto(t, &v1base.Spec, `{
+		userInterface: {
+			pgAdmin: {
+				dataVolumeClaimSpec: {
+					accessModes: [ReadWriteOnce],
+					resources: { requests: { storage: 1Mi } },
+				},
+			},
+		},
+		postgresVersion: 16,
+		backups: {
+			pgbackrest: {
+				repos: [{ name: repo1 }],
+			},
+		},
+		instances: [{
+			dataVolumeClaimSpec: {
+				accessModes: [ReadWriteOnce],
+				resources: { requests: { storage: 1Mi } },
+			},
+		}],
+	}`)
+
+	t.Run("v1beta1 is valid with pgadmin", func(t *testing.T) {
+		assert.NilError(t, cc.Create(ctx, base.DeepCopy(), client.DryRunAll),
+			"expected this base cluster to be valid")
+	})
+	t.Run("v1 is invalid with pgadmin", func(t *testing.T) {
+		assert.ErrorContains(t, cc.Create(ctx, v1base.DeepCopy(), client.DryRunAll),
+			"userInterface not available in v1")
+	})
+
+	t.Run("v1 is valid with pgadmin but only if unchanged from v1beta1", func(t *testing.T) {
+		// A v1 that has been updated from a v1beta1 with no change to the userInterface is valid
+		assert.NilError(t, cc.Create(ctx, base),
+			"expected this base cluster to be valid")
+		v1base.ResourceVersion = base.ResourceVersion
+		assert.NilError(t, cc.Update(ctx, v1base),
+			"expected this v1 cluster to be a valid update")
+
+		// But will not be valid if there's a change to the userInterface
+		require.UnmarshalInto(t, &v1base.Spec, `{
+			userInterface: {
+				pgAdmin: {
+					dataVolumeClaimSpec: {
+						accessModes: [ReadWriteOnce, ReadWriteMany],
+						resources: { requests: { storage: 2Mi } },
+					},
+				},
+			},
+		}`)
+
+		assert.ErrorContains(t, cc.Update(ctx, v1base),
+			"userInterface not available in v1")
+	})
+}