fix: install VPA CRD directly on clusterfor bundle e2e test.

Author: exdx

test/e2e/bundle_e2e_test.go

@@ -2,6 +2,10 @@ package e2e
 
 import (
 	"context"
+	"encoding/json"
+	"github.com/ghodss/yaml"
+	apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
+	k8serrors "k8s.io/apimachinery/pkg/api/errors"
 
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
@@ -16,6 +20,73 @@ import (
 	"github.com/operator-framework/operator-lifecycle-manager/test/e2e/ctx"
 )
 
+const vpaCRDManifest = `
+apiVersion: apiextensions.k8s.io/v1beta1
+kind: CustomResourceDefinition
+metadata:
+  name: verticalpodautoscalers.autoscaling.k8s.io
+  annotations:
+    "api-approved.kubernetes.io": "https://github.com/kubernetes/kubernetes/pull/63797"
+spec:
+  group: autoscaling.k8s.io
+  scope: Namespaced
+  names:
+    plural: verticalpodautoscalers
+    singular: verticalpodautoscaler
+    kind: VerticalPodAutoscaler
+    shortNames:
+      - vpa
+  version: v1beta1
+  versions:
+    - name: v1beta1
+      served: false
+      storage: false
+    - name: v1beta2
+      served: true
+      storage: true
+    - name: v1
+      served: true
+      storage: false
+  validation:
+    # openAPIV3Schema is the schema for validating custom objects.
+    openAPIV3Schema:
+      type: object
+      properties:
+        spec:
+          type: object
+          required: []
+          properties:
+            targetRef:
+              type: object
+            updatePolicy:
+              type: object
+              properties:
+                updateMode:
+                  type: string
+            resourcePolicy:
+              type: object
+              properties:
+                containerPolicies:
+                  type: array
+                  items:
+                    type: object
+                    properties:
+                      containerName:
+                        type: string
+                      mode:
+                        type: string
+                        enum: ["Auto", "Off"]
+                      minAllowed:
+                        type: object
+                      maxAllowed:
+                        type: object
+                      controlledResources:
+                        type: array
+                        items:
+                          type: string
+                          enum: ["cpu", "memory"]
+`
+
 var _ = Describe("Installing bundles with new object types", func() {
 	var (
 		kubeClient     operatorclient.ClientInterface
@@ -34,7 +105,7 @@ var _ = Describe("Installing bundles with new object types", func() {
 	})
 
 	When("a bundle with a pdb, priorityclass, and VPA object is installed", func() {
-		By("including the VPA CRD in the CSV")
+		By("first installing the VPA CRD on cluster")
 		const (
 			packageName = "busybox"
 			channelName = "alpha"
@@ -47,6 +118,30 @@ var _ = Describe("Installing bundles with new object types", func() {
 				imageName  = "quay.io/olmtest/single-bundle-index:pdb"
 			)
 
+			// create VPA CRD on cluster
+			data, err := yaml.YAMLToJSON([]byte(vpaCRDManifest))
+			Expect(err).ToNot(HaveOccurred(), "could not convert vpa crd to json")
+
+			crd := &apiextensionsv1beta1.CustomResourceDefinition{}
+			err = json.Unmarshal(data, crd)
+			Expect(err).ToNot(HaveOccurred(), "could not convert vpa crd to unstructured")
+
+			_, err = kubeClient.ApiextensionsInterface().ApiextensionsV1beta1().CustomResourceDefinitions().Create(context.TODO(), crd, metav1.CreateOptions{})
+			if err != nil {
+				if !k8serrors.IsAlreadyExists(err) {
+					Expect(err).ToNot(HaveOccurred(), "could not create vpa crd to on cluster")
+				}
+			}
+
+			// ensure vpa crd is established and accepted on the cluster before continuing
+			Eventually(func () bool {
+				crd, err := kubeClient.ApiextensionsInterface().ApiextensionsV1beta1().CustomResourceDefinitions().Get(context.TODO(), crd.GetName(), metav1.GetOptions{})
+				if err != nil {
+					return false
+				}
+				return crdReady(&crd.Status)
+			}).Should(BeTrue())
+
 			var installPlanRef string
 			// create catalog source
 			source := &v1alpha1.CatalogSource{
@@ -65,7 +160,7 @@ var _ = Describe("Installing bundles with new object types", func() {
 				},
 			}
 
-			source, err := operatorClient.OperatorsV1alpha1().CatalogSources(source.GetNamespace()).Create(context.TODO(), source, metav1.CreateOptions{})
+			source, err = operatorClient.OperatorsV1alpha1().CatalogSources(source.GetNamespace()).Create(context.TODO(), source, metav1.CreateOptions{})
 			Expect(err).ToNot(HaveOccurred(), "could not create catalog source")
 
 			// Create a Subscription for package
@@ -118,3 +213,23 @@ var _ = Describe("Installing bundles with new object types", func() {
 		})
 	})
 })
+
+func crdReady(status *apiextensionsv1beta1.CustomResourceDefinitionStatus) bool {
+	if status == nil {
+		return false
+	}
+	established, namesAccepted := false, false
+	for _, cdt := range status.Conditions{
+		switch cdt.Type {
+		case apiextensionsv1beta1.Established:
+			if cdt.Status == apiextensionsv1beta1.ConditionTrue {
+				established = true
+			}
+		case apiextensionsv1beta1.NamesAccepted:
+			if cdt.Status == apiextensionsv1beta1.ConditionTrue {
+				namesAccepted = true
+			}
+		}
+	}
+	return established && namesAccepted
+}