Fix Openshift version check to work on ROSA

Signed-off-by: Mohamed Mahmoud <mmahmoud@redhat.com>

Author: msherif1234

config/rbac/role.yaml

@@ -108,6 +108,18 @@ rules:
   - patch
   - update
   - watch
+- apiGroups:
+  - config.openshift.io
+  resources:
+  - clusteroperators
+  verbs:
+  - create
+  - delete
+  - get
+  - list
+  - patch
+  - update
+  - watch
 - apiGroups:
   - config.openshift.io
   resources:

pkg/cluster/cluster.go

@@ -11,6 +11,7 @@ import (
 	operatorv1 "github.com/openshift/api/operator/v1"
 	securityv1 "github.com/openshift/api/security/v1"
 	monv1 "github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring/v1"
+	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/discovery"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
@@ -75,17 +76,18 @@ func (c *Info) fetchAvailableAPIs(client *discovery.DiscoveryClient) error {
 }
 
 func (c *Info) fetchOpenShiftClusterVersion(ctx context.Context, cl client.Client) error {
-	key := client.ObjectKey{Name: "version"}
-	cversion := &configv1.ClusterVersion{}
-	if err := cl.Get(ctx, key, cversion); err != nil {
-		return fmt.Errorf("could not fetch ClusterVersion: %w", err)
+	cno := &configv1.ClusterOperator{}
+	err := cl.Get(ctx, types.NamespacedName{Name: "network"}, cno)
+	if err != nil {
+		return fmt.Errorf("error fetching OpenShift Cluster Network Operator: %w", err)
 	}
-	c.ID = string(cversion.Spec.ClusterID)
-	// Get version; use the same method as via `oc get clusterversion`, where printed column uses jsonPath:
-	// .status.history[?(@.state=="Completed")].version
-	for _, history := range cversion.Status.History {
-		if history.State == "Completed" {
-			c.openShiftVersion = semver.New(history.Version)
+	for _, v := range cno.Status.Versions {
+		if v.Name == "operator" {
+			ver, err := semver.NewVersion(v.Version)
+			if err != nil {
+				return fmt.Errorf("error parsing OpenShift Cluster Network Operator version: %w", err)
+			}
+			c.openShiftVersion = ver
 			break
 		}
 	}

pkg/manager/manager.go

@@ -38,6 +38,7 @@ import (
 //+kubebuilder:rbac:urls="/metrics",verbs=get
 //+kubebuilder:rbac:groups=apiextensions.k8s.io,resources=customresourcedefinitions,verbs=get;list;watch
 //+kubebuilder:rbac:groups=apiextensions.k8s.io,resources=customresourcedefinitions/status,verbs=update;patch
+//+kubebuilder:rbac:groups=config.openshift.io,resources=clusteroperators,verbs=get;create;delete;update;patch;list;watch
 
 type Registerer func(context.Context, *Manager) error
 

pkg/test/envtest.go

@@ -132,6 +132,10 @@ func PrepareEnvTest(controllers []manager.Registerer, namespaces []string, baseP
 	})
 	Expect(err).NotTo(HaveOccurred())
 
+	err = k8sClient.Create(ctx, &configv1.ClusterOperator{
+		ObjectMeta: metav1.ObjectMeta{Name: "network"},
+	})
+	Expect(err).NotTo(HaveOccurred())
 	k8sManager, err := manager.NewManager(
 		context.Background(),
 		cfg,