NE-2097: e2e - Add assertOSSMOperatorWithConfig helper

This commit introduces the `assertOSSMOperatorWithConfig` helper function,
which extends the existing `assertOSSMOperator` by allowing parameterization
of polling interval, timeout, and expected OSSM version (new check).

Author: alebedev87

test/e2e/util_gatewayapi_test.go

@@ -495,39 +495,45 @@ func deleteExistingSubscription(t *testing.T, namespace, subName string) error {
 
 }
 
-// assertOSSMOperator checks if the OSSM Istio operator gets successfully installed
-// and returns an error if not.
+// assertOSSMOperator checks if the OSSM operator gets successfully installed
+// and returns an error if not. It uses configurable parameters such as the expected OSSM version, polling interval, and timeout.
 func assertOSSMOperator(t *testing.T) error {
+	return assertOSSMOperatorWithConfig(t, "", 1*time.Second, 30*time.Second)
+}
+
+// assertOSSMOperatorWithConfig checks if the OSSM operator gets successfully installed
+// and returns an error if not. It uses configurable parameters such as
+// the expected OSSM version, polling interval, and timeout.
+func assertOSSMOperatorWithConfig(t *testing.T, ossmVersion string, interval, timeout time.Duration) error {
 	t.Helper()
 	dep := &appsv1.Deployment{}
 	ns := types.NamespacedName{Namespace: openshiftOperatorsNamespace, Name: openshiftIstioOperatorDeploymentName}
 
-	// Get the Istio operator deployment.
-	err := wait.PollUntilContextTimeout(context.Background(), 1*time.Second, 30*time.Second, false, func(context context.Context) (bool, error) {
+	// Get the OSSM operator deployment.
+	if err := wait.PollUntilContextTimeout(context.Background(), interval, timeout, false, func(context context.Context) (bool, error) {
 		if err := kclient.Get(context, ns, dep); err != nil {
 			t.Logf("failed to get deployment %v, retrying...", ns)
 			return false, nil
 		}
+		if len(ossmVersion) > 0 {
+			if csv, found := dep.Labels["olm.owner"]; found {
+				if csv == ossmVersion {
+					t.Logf("found OSSM deployment %q with expected version %q", ns, ossmVersion)
+				} else {
+					t.Logf("OSSM deployment %q expected to have version %q but got %q, retrying...", ns, ossmVersion, csv)
+					return false, nil
+				}
+			}
+		}
+		if dep.Status.AvailableReplicas < *dep.Spec.Replicas {
+			t.Logf("OSSM deployment %q expected to have %d available replica(s) but got %d, retrying...", ns, *dep.Spec.Replicas, dep.Status.AvailableReplicas)
+			return false, nil
+		}
+		t.Logf("found OSSM operator deployment %q with %d available replica(s)", ns, dep.Status.AvailableReplicas)
 		return true, nil
-	})
-	if err != nil {
+	}); err != nil {
 		return fmt.Errorf("error finding deployment %v: %v", ns, err)
 	}
-
-	// Get the istio-operator pod.
-	podlist, err := getPods(t, kclient, dep)
-	if err != nil {
-		return fmt.Errorf("error finding pod for deployment %v: %v", ns, err)
-	}
-	if len(podlist.Items) > 1 {
-		return fmt.Errorf("too many pods for deployment %v: %d", ns, len(podlist.Items))
-	}
-	pod := podlist.Items[0]
-	if pod.Status.Phase != corev1.PodRunning {
-		return fmt.Errorf("OSSM operator failure: pod %s is not running, it is %v", pod.Name, pod.Status.Phase)
-	}
-
-	t.Logf("found OSSM operator pod %s/%s to be %s", pod.Namespace, pod.Name, pod.Status.Phase)
 	return nil
 }