add support for RabbitMQ operator backed-services

Signed-off-by: Predrag Knezevic <[email protected]>

Author: pedjak

config/rbac/kustomization.yaml

@@ -15,6 +15,7 @@ resources:
 - crunchy_postgres_clusterrole.yaml
 - percona_mysql_clusterrole.yaml
 - cloud_native_postgres_clusterrole.yaml
+- rabbitmq_operator_clusterrole.yaml
 # Comment the following 4 lines if you want to disable
 # the auth proxy (https://github.com/brancz/kube-rbac-proxy)
 # which protects your /metrics endpoint.

config/rbac/rabbitmq_operator_clusterrole.yaml

@@ -0,0 +1,14 @@
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRole
+metadata:
+  name: rabbitmq-operator-viewer-role
+  labels:
+    servicebinding.io/controller: "true"
+rules:
+  - apiGroups:
+      - rabbitmq.com
+    resources:
+      - rabbitmqclusters
+    verbs:
+      - get
+      - list

controllers/crd/crd_controller.go

@@ -69,6 +69,9 @@ var bindingAnnotations = map[schema.GroupVersionKind]map[string]string{
 		"service.binding":          "path={.metadata.name}-{.spec.bootstrap.initdb.owner},objectType=Secret",
 		"service.binding/database": "path={.spec.bootstrap.initdb.database}",
 	},
+	schema.GroupVersionKind{Group: "rabbitmq.com", Version: "v1beta1", Kind: "RabbitmqCluster"}: {
+		"servicebinding.io/provisioned-service": "true",
+	},
 }
 
 // CrdReconciler reconciles a CustomResourceDefinition resources

pkg/util/util_test.go

@@ -15,10 +15,10 @@ func TestService(t *testing.T) {
 var _ = Describe("Merge Map", func() {
 
 	It("should merge two maps", func() {
-		m1 := map[string]string {
+		m1 := map[string]string{
 			"foo": "bar",
 		}
-		m2 := map[string]string {
+		m2 := map[string]string{
 			"bar": "foo",
 		}
 		m3 := MergeMaps(m1, m2)
@@ -30,15 +30,15 @@ var _ = Describe("Merge Map", func() {
 
 	It("should return src map if dst is uninitialized", func() {
 		var m1 map[string]string
-		m2 := map[string]string {
+		m2 := map[string]string{
 			"bar": "foo",
 		}
 		m3 := MergeMaps(m1, m2)
 		Expect(m3).To(Equal(m2))
 	})
 	It("should return dst map if src is uninitialized", func() {
 		var m1 map[string]string
-		m2 := map[string]string {
+		m2 := map[string]string{
 			"bar": "foo",
 		}
 		m3 := MergeMaps(m2, m1)

test/acceptance/features/steps/rabbitmq_operator.py

@@ -0,0 +1,18 @@
+from olm import Operator
+from behave import given
+
+
+class RabbitMqOperator(Operator):
+
+    def __init__(self, name="rabbitmq-cluster-operator"):
+        self.name = name
+
+
+@given(u'RabbitMQ operator is running')
+def install(_context):
+    operator = RabbitMqOperator()
+    operator.openshift.operators_namespace = "rabbitmq-system"
+    if not operator.is_running():
+        operator.openshift.apply_yaml_file("https://github.com/rabbitmq/cluster-operator/releases/download/v1.9.0/cluster-operator.yml")
+        operator.is_running(wait=True)
+    print("RabbitMQ operator is running")

test/acceptance/features/supportExistingOperatorBackedServices.feature

@@ -290,3 +290,51 @@ Feature: Support a number of existing operator-backed services out of the box
            app
            """
     And File "/bindings/$scenario_id/password" exists in application pod
+
+  Scenario: Bind test application to RabbitMQ instance provisioned by RabbitMq operator
+    Given RabbitMQ operator is running
+    * Generic test application is running
+    * The Custom Resource is present
+          """
+          apiVersion: rabbitmq.com/v1beta1
+          kind: RabbitmqCluster
+          metadata:
+            name: hello-world
+          """
+    When Service Binding is applied
+          """
+          apiVersion: binding.operators.coreos.com/v1alpha1
+          kind: ServiceBinding
+          metadata:
+              name: $scenario_id
+          spec:
+              services:
+              - group: rabbitmq.com
+                version: v1beta1
+                kind: RabbitmqCluster
+                name: hello-world
+              application:
+                name: $scenario_id
+                group: apps
+                version: v1
+                resource: deployments
+          """
+    Then Service Binding is ready
+    And Kind RabbitmqCluster with apiVersion rabbitmq.com/v1beta1 is listed in bindable kinds
+    And Content of file "/bindings/$scenario_id/type" in application pod is
+           """
+           rabbitmq
+           """
+    And Content of file "/bindings/$scenario_id/host" in application pod is
+           """
+           hello-world.$NAMESPACE.svc
+           """
+    And Content of file "/bindings/$scenario_id/port" in application pod is
+           """
+           5672
+           """
+    And File "/bindings/$scenario_id/username" exists in application pod
+           """
+           root
+           """
+    And File "/bindings/$scenario_id/password" exists in application pod