Cleanup clusterOperatorInsights helper function

Author: valaparthvi

test/integration/basic_test.go

@@ -63,7 +63,7 @@ func TestArchiveUploadedAndResultReceived(t *testing.T) {
 func TestOptOutOptIn(t *testing.T) {
 	// initially IO should be running
 	errDisabled := wait.PollImmediate(1*time.Second, 30*time.Second, func() (bool, error) {
-		insightsNotDisabled := !operatorStatus(t, clusterOperatorInsights(), status.OperatorDisabled, configv1.ConditionTrue)
+		insightsNotDisabled := !operatorStatus(t, clusterOperator("insights", t), status.OperatorDisabled, configv1.ConditionTrue)
 		if insightsNotDisabled {
 			return true, nil
 		}
@@ -146,7 +146,7 @@ func TestOptOutOptIn(t *testing.T) {
 
 	// Wait for operator to become disabled because of removed pull-secret
 	errDisabled = wait.PollImmediate(1*time.Second, 30*time.Second, func() (bool, error) {
-		insightsDisabled := operatorConditionCheck(t, clusterOperatorInsights(), "Disabled")
+		insightsDisabled := operatorConditionCheck(t, clusterOperator("insights", t), "Disabled")
 		if insightsDisabled {
 			return true, nil
 		}
@@ -164,7 +164,7 @@ func TestOptOutOptIn(t *testing.T) {
 	// Check if reports are uploaded - Logs show that insights-operator is enabled and reports are uploaded
 	restartInsightsOperator(t)
 	errDisabled = wait.PollImmediate(1*time.Second, 3*time.Minute, func() (bool, error) {
-		insightsNotDisabled := !operatorStatus(t, clusterOperatorInsights(), status.OperatorDisabled, configv1.ConditionTrue)
+		insightsNotDisabled := !operatorStatus(t, clusterOperator("insights", t), status.OperatorDisabled, configv1.ConditionTrue)
 		if insightsNotDisabled {
 			return true, nil
 		}

test/integration/bugs_test.go

@@ -140,7 +140,7 @@ func TestUnreachableHost(t *testing.T) {
 	checkPodsLogs(t, "exceeded than threshold 5. Marking as degraded.")
 
 	// Check the operator is degraded
-	insightsDegraded := operatorConditionCheck(t, clusterOperatorInsights(), "Degraded")
+	insightsDegraded := operatorConditionCheck(t, clusterOperator("insights", t), "Degraded")
 	if !insightsDegraded {
 		t.Fatal("Insights is not degraded")
 	}
@@ -151,7 +151,7 @@ func TestUnreachableHost(t *testing.T) {
 	}
 	// Check the operator is not degraded anymore
 	errDegraded := wait.PollImmediate(3*time.Second, 3*time.Minute, func() (bool, error) {
-		insightsDegraded := operatorConditionCheck(t, clusterOperatorInsights(), "Degraded")
+		insightsDegraded := operatorConditionCheck(t, clusterOperator("insights", t), "Degraded")
 		if insightsDegraded {
 			return false, nil
 		}

test/integration/main_test.go

@@ -75,21 +75,15 @@ func configV1Client() (result *configv1client.ConfigV1Client) {
 	return client
 }
 
-func clusterOperator(clusterName string) *configv1.ClusterOperator {
+func clusterOperator(clusterName string, t *testing.T) *configv1.ClusterOperator {
 	// get info about given cluster operator
 	operator, err := configClient.ClusterOperators().Get(context.Background(), clusterName, metav1.GetOptions{})
 	if err != nil {
-		// TODO -> change to t.Fatal in follow-up PR
-		panic(err.Error())
+		t.Fatalf("Failed to get information about the operator: %s", err)
 	}
 	return operator
 }
 
-func clusterOperatorInsights() *configv1.ClusterOperator {
-	// TODO -> delete this function in follow-up PR
-	return clusterOperator("insights")
-}
-
 func operatorConditionCheck(t *testing.T, operator *configv1.ClusterOperator, conditionType configv1.ClusterStatusConditionType) bool {
 	statusConditions := operator.Status.Conditions
 
@@ -291,7 +285,7 @@ func degradeOperatorMonitoring(t *testing.T) func() {
 	// delete just in case it was already there, so we don't care about error
 	pod := findPod(t, clientset, "openshift-monitoring", "cluster-monitoring-operator")
 	clientset.CoreV1().ConfigMaps(pod.Namespace).Delete(context.Background(), "cluster-monitoring-config", metav1.DeleteOptions{})
-	operatorConditionCheck(t, clusterOperator("monitoring"), "Degraded")
+	operatorConditionCheck(t, clusterOperator("monitoring", t), "Degraded")
 	_, err := clientset.CoreV1().ConfigMaps(pod.Namespace).Create(context.Background(),
 		&corev1.ConfigMap{ObjectMeta: metav1.ObjectMeta{Name: "cluster-monitoring-config"}, Data: map[string]string{"config.yaml": "telemeterClient: enabled: NOT_BOOELAN"}},
 		metav1.CreateOptions{},
@@ -300,12 +294,12 @@ func degradeOperatorMonitoring(t *testing.T) func() {
 	err = clientset.CoreV1().Pods(pod.Namespace).Delete(context.Background(), pod.Name, metav1.DeleteOptions{})
 	e(t, err, "Failed to delete Pod")
 	wait.PollImmediate(1*time.Second, 5*time.Minute, func() (bool, error) {
-		return operatorConditionCheck(t, clusterOperator("monitoring"), "Degraded"), nil
+		return operatorConditionCheck(t, clusterOperator("monitoring", t), "Degraded"), nil
 	})
 	return func() {
 		clientset.CoreV1().ConfigMaps(pod.Namespace).Delete(context.Background(), "cluster-monitoring-config", metav1.DeleteOptions{})
 		wait.PollImmediate(3*time.Second, 3*time.Minute, func() (bool, error) {
-			insightsDegraded := operatorConditionCheck(t, clusterOperator("monitoring"), "Degraded")
+			insightsDegraded := operatorConditionCheck(t, clusterOperator("monitoring", t), "Degraded")
 			return !insightsDegraded, nil
 		})
 	}