This commit override security context in system tests for openshift.

The env variable ENVIRONMENT is checked to see if we are running agaist an openshift K8S.
This is due to run our system-tests in a pipeline against openshift.
RABBITMQ_IMAGE env variable is introduced like the cluster-operator in order to override the image of the rabbitmq cluster created by the system-tests
Also RABBITMQ_IMAGE_PULL_SECRET is introduced like the cluster-operator to override the image pull secret and allow us to run the system-tests on a commercial version

Author: [email protected]

system_tests/utils.go

@@ -174,7 +174,7 @@ func kubernetesNodeIp(ctx context.Context, clientSet *kubernetes.Clientset) stri
 }
 
 func basicTestRabbitmqCluster(name, namespace string) *rabbitmqv1beta1.RabbitmqCluster {
-	return &rabbitmqv1beta1.RabbitmqCluster{
+	cluster := &rabbitmqv1beta1.RabbitmqCluster{
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      name,
 			Namespace: namespace,
@@ -195,6 +195,43 @@ func basicTestRabbitmqCluster(name, namespace string) *rabbitmqv1beta1.RabbitmqC
 			},
 		},
 	}
+
+	if os.Getenv("ENVIRONMENT") == "openshift" {
+		cluster = overrideSecurityContextForOpenshift(cluster)
+	}
+
+	if image := os.Getenv("RABBITMQ_IMAGE"); image != "" {
+		cluster.Spec.Image = image
+	}
+	if secret := os.Getenv("RABBITMQ_IMAGE_PULL_SECRET"); secret != "" {
+		cluster.Spec.ImagePullSecrets = []corev1.LocalObjectReference{
+			{Name: secret},
+		}
+	}
+
+	return cluster
+}
+
+func overrideSecurityContextForOpenshift(cluster *rabbitmqv1beta1.RabbitmqCluster) *rabbitmqv1beta1.RabbitmqCluster {
+
+	cluster.Spec.Override = rabbitmqv1beta1.RabbitmqClusterOverrideSpec{
+		StatefulSet: &rabbitmqv1beta1.StatefulSet{
+			Spec: &rabbitmqv1beta1.StatefulSetSpec{
+				Template: &rabbitmqv1beta1.PodTemplateSpec{
+					Spec: &corev1.PodSpec{
+						SecurityContext: &corev1.PodSecurityContext{},
+						Containers: []corev1.Container{
+							{
+								Name: "rabbitmq",
+							},
+						},
+					},
+				},
+			},
+		},
+	}
+
+	return cluster
 }
 
 func setupTestRabbitmqCluster(k8sClient client.Client, rabbitmqCluster *rabbitmqv1beta1.RabbitmqCluster) {