Add an e2e to the Proposal controller

Author: hongkailiu

test/cvo/accept_risks.go

@@ -8,6 +8,8 @@ import (
 	o "github.com/onsi/gomega"
 	monitoringv1 "github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring/v1"
 	prometheusoperatorv1client "github.com/prometheus-operator/prometheus-operator/pkg/client/versioned/typed/monitoring/v1"
+	runtimeclient "sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/client/config"
 
 	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/api/meta"
@@ -22,6 +24,7 @@ import (
 	configv1client "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1"
 
 	"github.com/openshift/cluster-version-operator/pkg/external"
+	proposalv1alpha1 "github.com/openshift/cluster-version-operator/pkg/proposal/api/v1alpha1"
 	"github.com/openshift/cluster-version-operator/test/util"
 )
 
@@ -31,6 +34,7 @@ var _ = g.Describe(`[Jira:"Cluster Version Operator"] cluster-version-operator`,
 		c                *rest.Config
 		configClient     *configv1client.ConfigV1Client
 		monitoringClient *prometheusoperatorv1client.MonitoringV1Client
+		rtClient         runtimeclient.Client
 		err              error
 
 		ctx         = context.TODO()
@@ -46,6 +50,9 @@ var _ = g.Describe(`[Jira:"Cluster Version Operator"] cluster-version-operator`,
 		monitoringClient, err = prometheusoperatorv1client.NewForConfig(c)
 		o.Expect(err).To(o.BeNil())
 
+		rtClient, err = runtimeclient.New(config.GetConfigOrDie(), runtimeclient.Options{})
+		o.Expect(err).To(o.BeNil())
+
 		util.SkipIfNotTechPreviewNoUpgrade(ctx, c)
 		o.Expect(util.SkipIfHypershift(ctx, c)).To(o.BeNil())
 		o.Expect(util.SkipIfMicroshift(ctx, c)).To(o.BeNil())
@@ -238,4 +245,31 @@ var _ = g.Describe(`[Jira:"Cluster Version Operator"] cluster-version-operator`,
 			o.Expect(err).NotTo(o.HaveOccurred())
 		}
 	})
+
+	g.It("should create proposals", g.Label("Serial"), oteginkgo.Informing(), func() {
+		o.Expect(util.SkipIfNetworkRestricted(ctx, c, util.FauxinnatiAPIURL)).To(o.BeNil())
+
+		cv, err := configClient.ClusterVersions().Get(ctx, external.DefaultClusterVersionName, metav1.GetOptions{})
+		o.Expect(err).NotTo(o.HaveOccurred())
+
+		g.By("Using fauxinnati as the upstream and its simple channel")
+		cv.Spec.Upstream = util.FauxinnatiAPIURL
+		cv.Spec.Channel = "simple"
+
+		_, err = configClient.ClusterVersions().Update(ctx, cv, metav1.UpdateOptions{})
+		o.Expect(err).NotTo(o.HaveOccurred())
+		needRecover = true
+
+		// TODO: move to its own file
+		g.By("Checking if the proposal are created")
+		o.Expect(wait.PollUntilContextTimeout(ctx, 30*time.Second, 5*time.Minute, true, func(ctx context.Context) (done bool, err error) {
+			proposals := proposalv1alpha1.ProposalList{}
+			err = rtClient.List(ctx, &proposals, runtimeclient.InNamespace(external.DefaultCVONamespace))
+			o.Expect(err).NotTo(o.HaveOccurred())
+			if len(proposals.Items) == 0 {
+				return false, nil
+			}
+			return true, nil
+		})).NotTo(o.HaveOccurred(), "no conditional update risk from alert found in ClusterVersion's status")
+	})
 })