From acb20924f781d627c9bf8fd7a9cffedbea045834 Mon Sep 17 00:00:00 2001 From: Jayendra Parsai Date: Thu, 1 Oct 2026 21:25:13 +0530 Subject: [PATCH] test: update argocd-agent pricipal test Signed-off-by: Jayendra Parsai --- ...51_validate_argocd_agent_principal_test.go | 62 +++++++++++++++++++ 1 file changed, 62 insertions(+) diff --git a/test/openshift/e2e/ginkgo/sequential/1-051_validate_argocd_agent_principal_test.go b/test/openshift/e2e/ginkgo/sequential/1-051_validate_argocd_agent_principal_test.go index 10e37372bdf..07fd7786b39 100644 --- a/test/openshift/e2e/ginkgo/sequential/1-051_validate_argocd_agent_principal_test.go +++ b/test/openshift/e2e/ginkgo/sequential/1-051_validate_argocd_agent_principal_test.go @@ -642,6 +642,9 @@ var _ = Describe("GitOps Operator Sequential E2E Tests", func() { argoCD.Spec.ArgoCDAgent.Principal.Server.Service = argov1beta1api.ArgoCDAgentPrincipalServiceSpec{ Type: corev1.ServiceTypeLoadBalancer, + Annotations: map[string]string{ + "test.argocd.io/annotation": "test", + }, } Expect(k8sClient.Create(ctx, argoCD)).To(Succeed()) @@ -659,6 +662,65 @@ var _ = Describe("GitOps Operator Sequential E2E Tests", func() { } Eventually(principalService).Should(k8sFixture.ExistByName()) Expect(principalService.Spec.Type).To(Equal(corev1.ServiceTypeLoadBalancer)) + + By("Verify principal service has expected annotations") + Eventually(func() map[string]string { + err := k8sClient.Get(ctx, client.ObjectKey{Name: argoCDAgentPrincipalName, Namespace: ns.Name}, principalService) + if err != nil { + return nil + } + return principalService.Annotations + }, "30s", "2s").Should(HaveKeyWithValue("test.argocd.io/annotation", "test")) + + By("Update service annotations") + Expect(k8sClient.Get(ctx, client.ObjectKey{Name: argoCDName, Namespace: ns.Name}, argoCD)).To(Succeed()) + + argocdFixture.Update(argoCD, func(ac *argov1beta1api.ArgoCD) { + ac.Spec.ArgoCDAgent.Principal.Server.Service.Annotations = map[string]string{ + "test.argocd.io/annotation": "test2", + } + }) + + By("Verify principal service has updated annotations") + + principalService = &corev1.Service{ + ObjectMeta: metav1.ObjectMeta{ + Name: argoCDAgentPrincipalName, + Namespace: ns.Name, + }, + } + Eventually(principalService).Should(k8sFixture.ExistByName()) + Eventually(func() map[string]string { + err := k8sClient.Get(ctx, client.ObjectKey{Name: argoCDAgentPrincipalName, Namespace: ns.Name}, principalService) + if err != nil { + return nil + } + return principalService.Annotations + }, "30s", "2s").Should(HaveKeyWithValue("test.argocd.io/annotation", "test2")) + + By("Remove service annotations") + Expect(k8sClient.Get(ctx, client.ObjectKey{Name: argoCDName, Namespace: ns.Name}, argoCD)).To(Succeed()) + + argocdFixture.Update(argoCD, func(ac *argov1beta1api.ArgoCD) { + ac.Spec.ArgoCDAgent.Principal.Server.Service = argov1beta1api.ArgoCDAgentPrincipalServiceSpec{ + Type: corev1.ServiceTypeLoadBalancer, + } + }) + + By("Verify principal service annotation is removed") + + principalService = &corev1.Service{ + ObjectMeta: metav1.ObjectMeta{ + Name: argoCDAgentPrincipalName, + Namespace: ns.Name, + }, + } + + Eventually(principalService).Should(k8sFixture.ExistByName()) + Eventually(func() (map[string]string, error) { + err := k8sClient.Get(ctx, client.ObjectKey{Name: argoCDAgentPrincipalName, Namespace: ns.Name}, principalService) + return principalService.Annotations, err + }, "30s", "2s").ShouldNot(HaveKey("test.argocd.io/annotation")) }) It("should handle service type updates correctly", func() {