✨ extension: use union discriminator pattern in source specification

api/v1alpha1/extension_types.go

@@ -30,6 +30,10 @@ const (
 	ManagedStatePaused ExtensionManagedState = "Paused"
 )
 
+const (
+	SourceTypePackage = "package"
+)
+
 type ExtensionSourcePackage struct {
 	//+kubebuilder:validation:MaxLength:=48
 	//+kubebuilder:validation:Pattern:=^[a-z0-9]+(-[a-z0-9]+)*$
@@ -60,11 +64,17 @@ type ExtensionSourcePackage struct {
 	UpgradeConstraintPolicy UpgradeConstraintPolicy `json:"upgradeConstraintPolicy,omitempty"`
 }
 
+// +kubebuilder:validation:XValidation:rule="self.sourceType=='package' && has(self.__package__)",message="sourceType must match populated union field"
+//
 // ExtensionSource defines the source for this Extension, right now, only a package is supported.
 type ExtensionSource struct {
-	// A source package defined by a name, version and/or channel
+	//+kubebuilder:validation:Enum:=package
 	//+kubebuilder:validation:Required
-	Package *ExtensionSourcePackage `json:"package"`
+	// sourceType is the discriminator for the source type
+	SourceType string `json:"sourceType"`
+
+	// package defines a reference for a bundle in a catalog defined by a name and a version and/or channel
+	Package *ExtensionSourcePackage `json:"package,omitempty"`
 }
 
 // ExtensionSpec defines the desired state of Extension

config/crd/bases/olm.operatorframework.io_extensions.yaml

@@ -59,8 +59,8 @@ spec:
                 description: source of Extension to be installed
                 properties:
                   package:
-                    description: A source package defined by a name, version and/or
-                      channel
+                    description: package defines a reference for a bundle in a catalog
+                      defined by a name and a version and/or channel
                     properties:
                       channel:
                         description: channel constraint definition
@@ -95,9 +95,17 @@ spec:
                     required:
                     - name
                     type: object
+                  sourceType:
+                    description: sourceType is the discriminator for the source type
+                    enum:
+                    - package
+                    type: string
                 required:
-                - package
+                - sourceType
                 type: object
+                x-kubernetes-validations:
+                - message: sourceType must match populated union field
+                  rule: self.sourceType=='package' && has(self.__package__)
             required:
             - serviceAccountName
             - source

internal/controllers/extension_admission_test.go

@@ -44,6 +44,7 @@ func TestExtensionAdmissionServiceAccount(t *testing.T) {
 			err := cl.Create(context.Background(), buildExtension(ocv1alpha1.ExtensionSpec{
 				ServiceAccountName: tc.saName,
 				Source: ocv1alpha1.ExtensionSource{
+					SourceType: ocv1alpha1.SourceTypePackage,
 					Package: &ocv1alpha1.ExtensionSourcePackage{
 						Name: "package",
 					},
@@ -65,9 +66,11 @@ func TestExtensionAdmissionSource(t *testing.T) {
 		source ocv1alpha1.ExtensionSource
 		err    string
 	}{
-		{"empty source", ocv1alpha1.ExtensionSource{}, "spec.source.package: Required value"},
-		{"source with empty package", ocv1alpha1.ExtensionSource{Package: &ocv1alpha1.ExtensionSourcePackage{}}, "spec.source.package.name in body should match"},
-		{"source with minimal valid package", ocv1alpha1.ExtensionSource{Package: &ocv1alpha1.ExtensionSourcePackage{Name: "package"}}, ""},
+		{"empty source", ocv1alpha1.ExtensionSource{}, `spec.source.sourceType: Unsupported value: "": supported values: "package"`},
+		{"invalid sourceType", ocv1alpha1.ExtensionSource{SourceType: "invalid"}, `spec.source.sourceType: Unsupported value: "invalid": supported values: "package"`},
+		{"source with unset package", ocv1alpha1.ExtensionSource{SourceType: ocv1alpha1.SourceTypePackage}, `spec.source: Invalid value: "object": sourceType must match populated union field`},
+		{"source with empty package", ocv1alpha1.ExtensionSource{SourceType: ocv1alpha1.SourceTypePackage, Package: &ocv1alpha1.ExtensionSourcePackage{}}, "spec.source.package.name in body should match"},
+		{"source with minimal valid package", ocv1alpha1.ExtensionSource{SourceType: ocv1alpha1.SourceTypePackage, Package: &ocv1alpha1.ExtensionSourcePackage{Name: "package"}}, ""},
 	}
 
 	t.Parallel()
@@ -124,6 +127,7 @@ func TestExtensionAdmissionSourcePackageName(t *testing.T) {
 			err := cl.Create(context.Background(), buildExtension(ocv1alpha1.ExtensionSpec{
 				ServiceAccountName: "serviceaccount",
 				Source: ocv1alpha1.ExtensionSource{
+					SourceType: ocv1alpha1.SourceTypePackage,
 					Package: &ocv1alpha1.ExtensionSourcePackage{
 						Name: tc.pkgName,
 					},
@@ -216,6 +220,7 @@ func TestExtensionAdmissionSourcePackageVersion(t *testing.T) {
 			err := cl.Create(context.Background(), buildExtension(ocv1alpha1.ExtensionSpec{
 				ServiceAccountName: "serviceaccount",
 				Source: ocv1alpha1.ExtensionSource{
+					SourceType: ocv1alpha1.SourceTypePackage,
 					Package: &ocv1alpha1.ExtensionSourcePackage{
 						Name:    "package",
 						Version: tc.version,
@@ -265,6 +270,7 @@ func TestExtensionAdmissionSourcePackageChannel(t *testing.T) {
 			err := cl.Create(context.Background(), buildExtension(ocv1alpha1.ExtensionSpec{
 				ServiceAccountName: "serviceaccount",
 				Source: ocv1alpha1.ExtensionSource{
+					SourceType: ocv1alpha1.SourceTypePackage,
 					Package: &ocv1alpha1.ExtensionSourcePackage{
 						Name:    "package",
 						Channel: tc.channelName,

internal/controllers/extension_controller_test.go

@@ -75,7 +75,7 @@ func TestExtensionReconcile(t *testing.T) {
 				ObjectMeta: metav1.ObjectMeta{Name: extKey.Name, Namespace: extKey.Namespace},
 				Spec: ocv1alpha1.ExtensionSpec{
 					ServiceAccountName: "test-service-account",
-					Source:             ocv1alpha1.ExtensionSource{Package: &ocv1alpha1.ExtensionSourcePackage{Name: "test-package"}},
+					Source:             ocv1alpha1.ExtensionSource{SourceType: ocv1alpha1.SourceTypePackage, Package: &ocv1alpha1.ExtensionSourcePackage{Name: "test-package"}},
 				},
 			}
 			if tc.paused {