MGMT-18437: Add consumer label when creating ACI

To identify this cluster is being used by the CAPI Openshift
Assisted controllers, we'll add the consumer label on
the AgentClusterInstall with the value set to this controller's name.

Author: CrystalChun

controlplane/internal/controller/clusterdeployment_controller.go

@@ -247,6 +247,7 @@ func (r *ClusterDeploymentReconciler) computeAgentClusterInstall(
 			ManifestsConfigMapRefs: additionalManifests,
 		},
 	}
+	aci.Labels[hiveext.ClusterConsumerLabel] = openshiftAssistedControlPlaneKind
 
 	if len(acp.Spec.Config.APIVIPs) > 0 && len(acp.Spec.Config.IngressVIPs) > 0 {
 		aci.Spec.APIVIPs = acp.Spec.Config.APIVIPs

controlplane/internal/controller/clusterdeployment_controller_test.go

@@ -104,7 +104,7 @@ var _ = Describe("ClusterDeployment Controller", func() {
 			cluster := utils.NewCluster(clusterName, namespace)
 			Expect(k8sClient.Create(ctx, cluster)).To(Succeed())
 
-			cd := utils.NewClusterDeployment(namespace, clusterDeploymentName)
+			cd := utils.NewClusterDeploymentWithOwnerCluster(namespace, clusterDeploymentName, clusterName)
 			Expect(k8sClient.Create(ctx, cd)).To(Succeed())
 
 			enableOn := models.DiskEncryptionEnableOnAll
@@ -156,6 +156,16 @@ var _ = Describe("ClusterDeployment Controller", func() {
 			Expect(aci.Spec.MastersSchedulable).To(Equal(oacp.Spec.Config.MastersSchedulable))
 			Expect(aci.Spec.SSHPublicKey).To(Equal(oacp.Spec.Config.SSHAuthorizedKey))
 
+			// Assert ACI has correct labels
+			Expect(aci.Labels).NotTo(BeEmpty())
+			Expect(aci.Labels).To(HaveKey(clusterv1.ClusterNameLabel))
+			Expect(aci.Labels[clusterv1.ClusterNameLabel]).To(Equal(clusterName))
+			Expect(aci.Labels).To(HaveKey(clusterv1.MachineControlPlaneLabel))
+			Expect(aci.Labels).To(HaveKey(clusterv1.MachineControlPlaneNameLabel))
+			Expect(aci.Labels[clusterv1.MachineControlPlaneNameLabel]).To(Equal(oacp.Name))
+			Expect(aci.Labels).To(HaveKey(hiveext.ClusterConsumerLabel))
+			Expect(aci.Labels[hiveext.ClusterConsumerLabel]).To(Equal(openshiftAssistedControlPlaneKind))
+
 			clusterImageSet := &hivev1.ClusterImageSet{}
 			Expect(k8sClient.Get(ctx, types.NamespacedName{Name: cd.Name}, clusterImageSet)).To(Succeed())
 			Expect(clusterImageSet.Spec.ReleaseImage).To(Equal("quay.io/openshift-release-dev/ocp-release:4.16.0-multi"))