[SC2] Enhancement on EnsureLabels function

bundle/manifests/ibm-common-service-operator.clusterserviceversion.yaml

@@ -460,6 +460,7 @@ spec:
                 - get
                 - list
                 - watch
+                - update
             - apiGroups:
                 - apps
               resources:

config/rbac/role.yaml

@@ -106,6 +106,7 @@ rules:
   - get
   - list
   - watch
+  - update
 - apiGroups:
   - apps
   resources:

internal/controller/bootstrap/init.go

@@ -20,6 +20,7 @@ import (
 	"bytes"
 	"context"
 	"fmt"
+	"maps"
 	"reflect"
 	"strconv"
 	"strings"
@@ -1901,9 +1902,7 @@ func (b *Bootstrap) UpdateResourceLabel(instance *apiv3.CommonService) error {
 	// get spec.labels in the spec
 	for _, cs := range csObjectList.Items {
 		labels := cs.Spec.Labels
-		for key, val := range labels {
-			(labelsMap)[key] = val
-		}
+		maps.Copy(labelsMap, labels)
 	}
 
 	if len(labelsMap) == 0 {
@@ -1921,15 +1920,14 @@ func (b *Bootstrap) UpdateResourceLabel(instance *apiv3.CommonService) error {
 	}
 
 	// update labels in the configmap
-	cmNames := []string{"common-services-maps", "namespace-scope"}
+	nsscmName := "namespace-scope"
 	cmList := &corev1.ConfigMapList{}
-	for _, cmName := range cmNames {
-		cm := &corev1.ConfigMap{}
-		if err := b.Client.Get(context.TODO(), types.NamespacedName{Name: cmName, Namespace: b.CSData.ServicesNs}, cm); err != nil && !errors.IsNotFound(err) {
-			return err
-		} else if errors.IsNotFound(err) {
-			klog.V(3).Infof("configmap %s is not found in namespace: %s", cmName, b.CSData.ServicesNs)
-		}
+	cm := &corev1.ConfigMap{}
+	if err := b.Client.Get(context.TODO(), types.NamespacedName{Name: nsscmName, Namespace: b.CSData.OperatorNs}, cm); err != nil && !errors.IsNotFound(err) {
+		return err
+	} else if errors.IsNotFound(err) {
+		klog.V(3).Infof("configmap %s is not found in namespace: %s", nsscmName, b.CSData.OperatorNs)
+	} else {
 		cmList.Items = append(cmList.Items, *cm)
 	}
 	cmUnstructedList, err := util.ObjectListToNewUnstructuredList(cmList)
@@ -1962,8 +1960,9 @@ func (b *Bootstrap) UpdateResourceLabel(instance *apiv3.CommonService) error {
 		return err
 	} else if errors.IsNotFound(err) {
 		klog.V(3).Infof("OperandRegistry common-service is not found in namespace: %s", b.CSData.ServicesNs)
+	} else {
+		opregList.Items = append(opregList.Items, *opreg)
 	}
-	opregList.Items = append(opregList.Items, *opreg)
 	opregUnstructedList, err := util.ObjectListToNewUnstructuredList(opregList)
 	if err != nil {
 		return err
@@ -1981,9 +1980,11 @@ func (b *Bootstrap) UpdateResourceLabel(instance *apiv3.CommonService) error {
 			return err
 		} else if errors.IsNotFound(err) {
 			klog.V(3).Infof("Issuer %s is not found in namespace: %s", issuerName, b.CSData.ServicesNs)
+		} else {
+			issuerList.Items = append(issuerList.Items, *issuer)
 		}
-		issuerList.Items = append(issuerList.Items, *issuer)
 	}
+
 	issuerUnstructedList, err := util.ObjectListToNewUnstructuredList(issuerList)
 	if err != nil {
 		return err
@@ -2000,21 +2001,24 @@ func (b *Bootstrap) UpdateResourceLabel(instance *apiv3.CommonService) error {
 		return err
 	} else if errors.IsNotFound(err) {
 		klog.V(3).Infof("certificate cs-ca-certificate is not found in namespace: %s", b.CSData.ServicesNs)
+	} else {
+		certList.Items = append(certList.Items, *cert)
 	}
-	certList.Items = append(certList.Items, *cert)
 	certUnstructedList, err := util.ObjectListToNewUnstructuredList(certList)
 	if err != nil {
 		return err
 	}
 	if err := b.UpdateResourceWithLabel(certUnstructedList, labelsMap); err != nil {
 		return err
 	}
-
 	return nil
 }
 
 func (b *Bootstrap) UpdateResourceWithLabel(resources *unstructured.UnstructuredList, labels map[string]string) error {
 	for _, resource := range resources.Items {
+		if resource.GetName() == "" {
+			continue
+		}
 		util.EnsureLabels(&resource, labels)
 		klog.Infof("Updating labels in %s %s/%s", resource.GetKind(), resource.GetNamespace(), resource.GetName())
 		if err := b.UpdateObject(&resource); err != nil {

internal/controller/common/util.go

@@ -22,6 +22,7 @@ import (
 	"encoding/base64"
 	"fmt"
 	"io"
+	"maps"
 	"os"
 	"reflect"
 	"strconv"
@@ -686,12 +687,13 @@ func EnsureLabelsForConfigMap(cm *corev1.ConfigMap, labels map[string]string) {
 
 // EnsureLabels ensures that the specifc resource has the certain labels
 func EnsureLabels(resource *unstructured.Unstructured, labels map[string]string) {
-	if resource.Object["metadata"].(map[string]interface{})["labels"] == nil {
-		resource.Object["metadata"].(map[string]interface{})["labels"] = make(map[string]string)
-	}
-	for k, v := range labels {
-		resource.Object["metadata"].(map[string]interface{})["labels"].(map[string]string)[k] = v
+	if resource.GetLabels() == nil {
+		resource.SetLabels(labels)
+		return
 	}
+	newLabels := resource.GetLabels()
+	maps.Copy(newLabels, labels)
+	resource.SetLabels(newLabels)
 }
 
 // GetRequestNs gets requested-from-namespace of map-to-common-service-namespace