registry: add support for percona mongodb clusters

Percona is one of the better-used database providers in k8s.  Supporting
them as best as we can in SBO will be to our benefit.

Signed-off-by: Andy Sadler <[email protected]>

Author: sadlerap

config/rbac/kustomization.yaml

@@ -15,6 +15,7 @@ resources:
 - crunchy_postgres_clusterrole.yaml
 - percona_mysql_clusterrole.yaml
 - cloud_native_postgres_clusterrole.yaml
+- percona_mongodb_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/percona_mongodb_clusterrole.yaml

@@ -0,0 +1,14 @@
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRole
+metadata:
+  name: percona-mongodb-view
+  labels:
+    servicebinding.io/controller: "true"
+rules:
+  - apiGroups:
+      - psmdb.percona.com
+    resources:
+      - perconaservermongodbs
+    verbs:
+      - get
+      - list

controllers/crd/crd_controller.go

@@ -61,7 +61,23 @@ var bindingAnnotations = map[schema.GroupVersionKind]map[string]string{
 		"service.binding":          "path={.spec.secretsName},objectType=Secret",
 		"service.binding/host":     "path={.status.host}",
 		"service.binding/username": "root",
-		"service.binding/password": "path={.spec.secretsName},objectType=Secret,sourceKey=root",
+		"service.binding/password": "path={.spec.secretsName},objectTyp=Secret,sourceKey=root",
+	},
+	schema.GroupVersionKind{Group: "psmdb.percona.com", Version: "v1-9-0", Kind: "PerconaServerMongoDB"}: {
+		"service.binding/type":     "mongodb",
+		"service.binding/provider": "percona",
+		"service.binding":          "path={.spec.secrets.users},objectType=Secret",
+		"service.binding/username": "path={.spec.secrets.users},objectType=Secret,sourceKey=MONGODB_USER_ADMIN_USER",
+		"service.binding/password": "path={.spec.secrets.users},objectType=Secret,sourceKey=MONGODB_USER_ADMIN_PASSWORD",
+		"service.binding/host":     "path={.status.host}",
+	},
+	schema.GroupVersionKind{Group: "psmdb.percona.com", Version: "v1-10-0", Kind: "PerconaServerMongoDB"}: {
+		"service.binding/type":     "mongodb",
+		"service.binding/provider": "percona",
+		"service.binding":          "path={.spec.secrets.users},objectType=Secret",
+		"service.binding/username": "path={.spec.secrets.users},objectType=Secret,sourceKey=MONGODB_USER_ADMIN_USER",
+		"service.binding/password": "path={.spec.secrets.users},objectType=Secret,sourceKey=MONGODB_USER_ADMIN_PASSWORD",
+		"service.binding/host":     "path={.status.host}",
 	},
 	schema.GroupVersionKind{Group: "postgresql.k8s.enterprisedb.io", Version: "v1", Kind: "Cluster"}: {
 		"service.binding/type":     "postgresql",

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/perconamongodboperator.py

@@ -0,0 +1,49 @@
+from olm import Operator
+from environment import ctx
+from behave import given
+
+
+class PerconaMongoDBOperator(Operator):
+
+    def __init__(self, name="percona-server-mongodb-operator"):
+        self.name = name
+        if ctx.cli == "oc":
+            self.operator_catalog_source_name = "community-operators"
+        else:
+            self.operator_catalog_source_name = "operatorhubio-catalog"
+        self.operator_catalog_channel = "stable"
+        self.package_name = name
+
+
+@given(u'Percona MongoDB operator is running')
+def install_percona_mongodb_operator(context):
+    operator = PerconaMongoDBOperator()
+    operator.openshift.operators_namespace = context.namespace.name
+    if not operator.is_running():
+        subscription = f'''
+---
+apiVersion: operators.coreos.com/v1
+kind: OperatorGroup
+metadata:
+  name: operatorgroup
+  namespace: {operator.openshift.operators_namespace}
+spec:
+  targetNamespaces:
+  - {operator.openshift.operators_namespace}
+---
+apiVersion: operators.coreos.com/v1alpha1
+kind: Subscription
+metadata:
+  name: '{operator.name}'
+  namespace: {operator.openshift.operators_namespace}
+spec:
+  channel: '{operator.operator_catalog_channel}'
+  installPlanApproval: Automatic
+  name: '{operator.package_name}'
+  source: '{operator.operator_catalog_source_name}'
+  sourceNamespace: {operator.openshift.olm_namespace}
+        '''
+        print(subscription)
+        operator.openshift.apply(subscription)
+        operator.is_running(wait=True)
+    print("Percona MongoDB operator is running")

test/acceptance/features/supportExistingOperatorBackedServices.feature

@@ -290,3 +290,66 @@ 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 MongoDB provisioned by Percona's MongoDB operator
+    Given Percona MongoDB operator is running
+    * Generic test application is running
+    * The Custom Resource is present
+          """
+          apiVersion: psmdb.percona.com/v1-9-0
+          kind: PerconaServerMongoDB
+          metadata:
+              name: minimal-cluster
+          spec:
+              crVersion: 1.9.0
+              image: percona/percona-server-mongodb:4.4.8-9
+              allowUnsafeConfigurations: true
+              upgradeOptions:
+                  apply: 4.4-recommended
+                  schedule: "0 2 * * *"
+              secrets:
+                  users: minimal-cluster-secrets
+              replsets:
+                  - name: rs0
+                    size: 1
+                    volumeSpec:
+                        persistentVolumeClaim:
+                            resources:
+                                requests:
+                                    storage: 1Gi
+              sharding:
+                  enabled: false
+          """
+    When Service Binding is applied
+          """
+          apiVersion: binding.operators.coreos.com/v1alpha1
+          kind: ServiceBinding
+          metadata:
+              name: $scenario_id
+          spec:
+              services:
+              - group: psmdb.percona.com
+                version: v1-9-0
+                kind: PerconaServerMongoDB
+                name: minimal-cluster
+              application:
+                name: $scenario_id
+                group: apps
+                version: v1
+                resource: deployments
+          """
+    Then Service Binding is ready
+    And Kind PerconaServerMongoDB with apiVersion psmdb.percona.com/v1-9-0 is listed in bindable kinds
+    And Content of file "/bindings/$scenario_id/type" in application pod is
+           """
+           mongodb
+           """
+    And Content of file "/bindings/$scenario_id/username" in application pod is
+           """
+           userAdmin
+           """
+    And File "/bindings/$scenario_id/password" exists in application pod
+    And Content of file "/bindings/$scenario_id/host" in application pod is
+            """
+            minimal-cluster-rs0.$NAMESPACE.svc.cluster.local
+            """