issue-698, Save default user ref for zookeeper

Makefile

@@ -142,8 +142,8 @@ uninstall: manifests kustomize ## Uninstall CRDs from the K8s cluster specified
 deploy: manifests kustomize ## Deploy controller to the K8s cluster specified in ~/.kube/config.
 	cd scripts && ./make_creds_secret.sh
 	cd config/manager && $(KUSTOMIZE) edit set image controller=${IMG}
-	$(KUSTOMIZE) build config/default | kubectl apply -f -
 	kubectl apply -f ~/creds_secret.yaml
+	$(KUSTOMIZE) build config/default | kubectl apply -f -
 
 .PHONY: helm-deploy
 helm-deploy:

apis/clusters/v1beta1/zookeeper_types.go

@@ -45,7 +45,8 @@ type ZookeeperStatus struct {
 	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
 	// Important: Run "make" to regenerate code after modifying this file
 
-	ClusterStatus `json:",inline"`
+	ClusterStatus        `json:",inline"`
+	DefaultUserSecretRef *Reference `json:"DefaultRef,omitempty"`
 }
 
 //+kubebuilder:object:root=true

config/crd/bases/clusters.instaclustr.com_zookeepers.yaml

@@ -141,6 +141,17 @@ spec:
           status:
             description: ZookeeperStatus defines the observed state of Zookeeper
             properties:
+              DefaultRef:
+                description: ObjectReference is namespaced reference to an object
+                properties:
+                  name:
+                    type: string
+                  namespace:
+                    type: string
+                required:
+                - name
+                - namespace
+                type: object
               cdcid:
                 type: string
               currentClusterOperationStatus:

config/samples/clusters_v1beta1_zookeeper.yaml

@@ -3,7 +3,7 @@ kind: Zookeeper
 metadata:
   name: zookeeper-sample
 spec:
-  name: "username-zookeeper"
+  name: "mykyta-zookeeper-test"
 #  description: "some description"
   dataCentres:
     - clientToServerEncryption: false

controllers/clusters/zookeeper_controller.go

@@ -199,6 +199,7 @@ func (r *ZookeeperReconciler) handleCreateCluster(
 }
 
 func (r *ZookeeperReconciler) createDefaultSecret(ctx context.Context, zk *v1beta1.Zookeeper, l logr.Logger) error {
+	patch := zk.NewPatch()
 	username, password, err := r.API.GetDefaultCredentialsV1(zk.Status.ID)
 	if err != nil {
 		l.Error(err, "Cannot get default user creds for Zookeeper cluster from the Instaclustr API",
@@ -224,6 +225,24 @@ func (r *ZookeeperReconciler) createDefaultSecret(ctx context.Context, zk *v1bet
 		return err
 	}
 
+	zk.Status.DefaultUserSecretRef = &v1beta1.Reference{
+		Name:      secret.Name,
+		Namespace: secret.Namespace,
+	}
+
+	err = r.Status().Patch(ctx, zk, patch)
+	if err != nil {
+		l.Error(err, "Cannot patch Zookeeper resource",
+			"cluster name", zk.Spec.Name,
+			"status", zk.Status)
+
+		r.EventRecorder.Eventf(
+			zk, models.Warning, models.PatchFailed,
+			"Cluster resource patch is failed. Reason: %v", err)
+
+		return err
+	}
+
 	return nil
 }