jianl - First e2e test

Author: JianLi-RH

.gitignore

@@ -2,3 +2,4 @@
 bin/
 .DS_Store
 _output
+.openshift-tests-extension

.openshift-tests-extension/openshift_payload_cluster-version-operator.json

@@ -4,6 +4,16 @@ It integrates [openshift-tests-extension](https://github.com/openshift-eng/opens
 cluster-version-operator which allows openshift components to contribute tests to openshift-tests' suites with
 extension binaries.
 
+## Prerequisites
+- Install golang, the version number must be greater than or equal to the version number in go.mod. Here is the how-to doc https://go.dev/doc/install
+- Have the environment variable `KUBECONFIG` set pointing to your cluster.
+
+## Build the executable binary
+In root folder, run below command to build executable binary:
+```console
+$ make build
+```
+The executable binary can be found in ${BIN_PATH} folder, BIN_PATH is set in hack/build-info.sh, in linux it is _output/linux/amd64/ folder.
 
 ## Run the tests locally
 
@@ -21,4 +31,10 @@ After [installing-ginkgo](https://onsi.github.io/ginkgo/#installing-ginkgo):
 $ ginkgo ./test/...
 ```
 
+## Using binary 
+```console
+$ _output/linux/amd64/cluster-version-operator-tests run-test <test case name>
+```
+Note: `test case name` can be found in .openshift-tests-extension/openshift_payload_cluster-version-operator.json
+
 The output looks nicer this way.

cmd/cluster-version-operator-tests/README.md

@@ -1,12 +1,37 @@
 package cvo
 
 import (
-	. "github.com/onsi/ginkgo/v2"
-	. "github.com/onsi/gomega"
+	"context"
+
+	g "github.com/onsi/ginkgo/v2"
+	o "github.com/onsi/gomega"
+	kerrors "k8s.io/apimachinery/pkg/api/errors"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+
+	"github.com/openshift/cluster-version-operator/test/utilities"
 )
 
-var _ = Describe("[Jira:Cluster Version Operator] cluster-version-operator-tests", func() {
-	It("should support passing tests", func() {
-		Expect(true).To(BeTrue())
+var _ = g.Describe("[Jira:Cluster Version Operator] The cluster version operator", g.Ordered, g.Label("cvo"), func() {
+	defer g.GinkgoRecover()
+	var client *kubernetes.Clientset
+
+	g.BeforeAll(func() {
+		client = utilities.MustGetKubeClient()
+	})
+
+	//author: [email protected]
+	g.It("the removed resources are not created in a fresh installed cluster", g.Label("High", "42543"), func() {
+		g.By("Service controller-manager-service should not be installed")
+		_, err := client.CoreV1().Services("openshift-cloud-credential-operator").Get(context.TODO(), "controller-manager-service", metav1.GetOptions{})
+		o.Expect(kerrors.IsNotFound(err)).To(o.BeTrue(), "Service controller-manager-service was accidentally installed")
+
+		g.By("ClusterRoleBindings default-account-openshift-machine-config-operator should not be installed")
+		_, err = client.RbacV1().ClusterRoleBindings().Get(context.TODO(), "default-account-openshift-machine-config-operator", metav1.GetOptions{})
+		o.Expect(kerrors.IsNotFound(err)).To(o.BeTrue(), "ClusterRoleBinding default-account-openshift-machine-config-operator was accidentally installed")
+
+		g.By("CronJobs machine-config-nodes-crd-cleanup should not be installed")
+		_, err = client.BatchV1().CronJobs("openshift-machine-config-operator").Get(context.TODO(), "machine-config-nodes-crd-cleanup", metav1.GetOptions{})
+		o.Expect(kerrors.IsNotFound(err)).To(o.BeTrue(), "CronJob machine-config-nodes-crd-cleanup was accidentally installed")
 	})
 })

test/cvo/cvo.go

@@ -0,0 +1,29 @@
+package utilities
+
+import (
+	"os"
+
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/tools/clientcmd"
+)
+
+// MustGetKubeClient will create a kubernetes.Clientset object instance.
+//
+// The function returns an instance of kubernetes.Clientset when it success
+func MustGetKubeClient() *kubernetes.Clientset {
+	configPath, present := os.LookupEnv("KUBECONFIG")
+	if present {
+		config, err := clientcmd.BuildConfigFromFlags("", configPath)
+		if err != nil {
+			panic("Unable not load KUBECONFIG: " + err.Error())
+		}
+		// Create the Clientset
+		clientset, err := kubernetes.NewForConfig(config)
+		if err != nil {
+			panic("Create kubernetes.Clientset failed: " + err.Error())
+		}
+		return clientset
+	} else {
+		panic("Environment variable KUBECONFIG must be set")
+	}
+}