Properly handle upgrade scenario with extra metadata

If extra metadata has not changed, still set HelmReleaseSummaries MetadataHash.
projectsveltos · Feb 15, 2024 · 373733a · 373733a
1 parent 98685bd
commit 373733a
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 5 deletions.
diff --git a/controllers/handlers_helm.go b/controllers/handlers_helm.go
@@ -1681,7 +1681,7 @@ func addExtraMetadata(ctx context.Context, requestedChart *configv1alpha1.HelmCh
 	lastDeployedMetadataHash := getMetadataHashFromHelmChartSummary(requestedChart, clusterSummary)
 
 	if reflect.DeepEqual(metadataHash, lastDeployedMetadataHash) {
-		return nil
+		return updateMetadataHashOnHelmChartSummary(ctx, requestedChart, metadataHash, clusterSummary)
 	}
 
 	actionConfig, err := actionConfigInit(requestedChart.ReleaseNamespace, kubeconfig)

diff --git a/test/fv/helm_test.go b/test/fv/helm_test.go
@@ -129,7 +129,7 @@ var _ = Describe("Helm", func() {
 
 		Byf("Verifying wildfly deployment is created in the workload cluster")
 		Eventually(func() error {
-			depl := &appsv1.Deployment{}
+			depl = &appsv1.Deployment{}
 			return workloadClient.Get(context.TODO(),
 				types.NamespacedName{Namespace: "wildfly", Name: "wildfly"}, depl)
 		}, timeout, pollingInterval).Should(BeNil())
@@ -146,7 +146,7 @@ var _ = Describe("Helm", func() {
 			clusterSummary.Spec.ClusterNamespace, clusterSummary.Spec.ClusterName, configv1alpha1.FeatureHelm,
 			nil, charts)
 
-		Byf("Changing ClusterProfile requiring different chart version for kyverno")
+		Byf("Changing ClusterProfile requiring different chart version for kyverno and update extra labels")
 		Expect(k8sClient.Get(context.TODO(), types.NamespacedName{Name: clusterProfile.Name}, currentClusterProfile)).To(Succeed())
 		currentClusterProfile.Spec.HelmCharts = []configv1alpha1.HelmChart{
 			{
@@ -168,6 +168,12 @@ var _ = Describe("Helm", func() {
 				HelmChartAction:  configv1alpha1.HelmChartActionInstall,
 			},
 		}
+		currentClusterProfile.Spec.ExtraLabels = map[string]string{
+			randomString(): randomString(),
+			randomString(): randomString(),
+			randomString(): randomString(),
+		}
+		currentClusterProfile.Spec.ExtraAnnotations = nil
 		Expect(k8sClient.Update(context.TODO(), currentClusterProfile)).To(Succeed())
 
 		verifyClusterSummary(controllers.ClusterProfileLabelName,
@@ -176,14 +182,14 @@ var _ = Describe("Helm", func() {
 
 		Byf("Verifying kyverno deployment is still present in the workload cluster")
 		Eventually(func() error {
-			depl := &appsv1.Deployment{}
+			depl = &appsv1.Deployment{}
 			return workloadClient.Get(context.TODO(),
 				types.NamespacedName{Namespace: "kyverno", Name: "kyverno-admission-controller"}, depl)
 		}, timeout, pollingInterval).Should(BeNil())
 
 		Byf("Verifying wildfly deployment is still in the workload cluster")
 		Eventually(func() error {
-			depl := &appsv1.Deployment{}
+			depl = &appsv1.Deployment{}
 			return workloadClient.Get(context.TODO(),
 				types.NamespacedName{Namespace: "wildfly", Name: "wildfly"}, depl)
 		}, timeout, pollingInterval).Should(BeNil())
@@ -200,6 +206,15 @@ var _ = Describe("Helm", func() {
 			clusterSummary.Spec.ClusterNamespace, clusterSummary.Spec.ClusterName, configv1alpha1.FeatureHelm,
 			nil, charts)
 
+		Byf("Verifying kyverno deployment has proper labels/annotations")
+		Expect(workloadClient.Get(context.TODO(),
+			types.NamespacedName{Namespace: "kyverno", Name: "kyverno-admission-controller"}, depl))
+		content, err = runtime.DefaultUnstructuredConverter.ToUnstructured(depl)
+		Expect(err).To(BeNil())
+		u.SetUnstructuredContent(content)
+		verifyExtraLabels(&u, currentClusterProfile.Spec.ExtraLabels)
+		verifyExtraAnnotations(&u, currentClusterProfile.Spec.ExtraAnnotations)
+
 		Byf("Changing ClusterProfile to not require wildfly anymore")
 		Expect(k8sClient.Get(context.TODO(), types.NamespacedName{Name: clusterProfile.Name}, currentClusterProfile)).To(Succeed())
 		currentClusterProfile.Spec.HelmCharts = []configv1alpha1.HelmChart{