add POSTGRES_HOST_RO to core host if using cnpg cluster

Signed-off-by: Amit Prinz Setter <alphaprinz@gmail.com>

Author: alphaprinz

deploy/internal/statefulset-core.yaml

@@ -119,6 +119,7 @@ spec:
                   key: NOOBAA_VERSION_AUTH_ENABLED
             - name: POSTGRES_HOST
               value: "noobaa-db-pg-0.noobaa-db-pg"
+            - name: POSTGRES_HOST_RO
             - name: POSTGRES_PORT
             - name: POSTGRES_DBNAME
             - name: POSTGRES_USER

pkg/bundle/deploy.go

@@ -5293,7 +5293,7 @@ spec:
       noobaa-s3-svc: "true"
 `
 
-const Sha256_deploy_internal_statefulset_core_yaml = "34da89373b8398adb670d779a35f5c5a94365da99b5a2db65715fd62a7638d5c"
+const Sha256_deploy_internal_statefulset_core_yaml = "3dba40ad6babb033832e999680f333849bf3f194a24aa1163587529315ebe8da"
 
 const File_deploy_internal_statefulset_core_yaml = `apiVersion: apps/v1
 kind: StatefulSet
@@ -5416,6 +5416,7 @@ spec:
                   key: NOOBAA_VERSION_AUTH_ENABLED
             - name: POSTGRES_HOST
               value: "noobaa-db-pg-0.noobaa-db-pg"
+            - name: POSTGRES_HOST_RO
             - name: POSTGRES_PORT
             - name: POSTGRES_DBNAME
             - name: POSTGRES_USER

pkg/system/phase2_creating.go

@@ -452,6 +452,20 @@ func (r *Reconciler) setDesiredCoreEnv(c *corev1.Container) {
 				c.Env[j].ValueFrom = nil
 			}
 
+		case "POSTGRES_HOST_RO":
+			if r.shouldReconcileCNPGCluster() {
+				//RO host is not part of the cnpg app secret, so we're getting it here from the service
+				services := &corev1.ServiceList{}
+				cnpg_label, _ := labels.Parse("app=noobaa,cnpg.io/cluster=noobaa-db-pg-cluster")
+				util.KubeList(services, &client.ListOptions{Namespace: r.NooBaaPostgresDB.Namespace, LabelSelector: cnpg_label})
+				for _, service := range services.Items {
+					if (service.Spec.Selector["cnpg.io/instanceRole"] == "replica") {
+						c.Env[j].Value = service.Name
+						break
+					}
+				}
+			}
+
 		case "DB_TYPE":
 			c.Env[j].Value = "postgres"