Watch infrastructure and update AWS tags

Signed-off-by: chiragkyal <[email protected]>

pkg/operator/controller/ingress/controller.go

@@ -134,6 +134,10 @@ func New(mgr manager.Manager, config Config) (controller.Controller, error) {
 	if err := c.Watch(source.Kind[client.Object](operatorCache, &configv1.Proxy{}, handler.EnqueueRequestsFromMapFunc(reconciler.ingressConfigToIngressController))); err != nil {
 		return nil, err
 	}
+	// Watch for changes to infrastructure config to update user defined tags
+	if err := c.Watch(source.Kind[client.Object](operatorCache, &configv1.Infrastructure{}, handler.EnqueueRequestsFromMapFunc(reconciler.ingressConfigToIngressController))); err != nil {
+		return nil, err
+	}
 	return c, nil
 }
 

pkg/operator/controller/ingress/load_balancer_service.go

@@ -254,6 +254,8 @@ var (
 			//
 			// https://cloud.ibm.com/docs/containers?topic=containers-vpc-lbaas
 			iksLBEnableFeaturesAnnotation,
+			//TODO
+			// awsLBAdditionalResourceTags,
 		)
 
 		// Azure and GCP support switching between internal and external
@@ -280,6 +282,7 @@ var (
 // Always returns the current LB service if one exists (whether it already
 // existed or was created during the course of the function).
 func (r *reconciler) ensureLoadBalancerService(ci *operatorv1.IngressController, deploymentRef metav1.OwnerReference, platformStatus *configv1.PlatformStatus) (bool, *corev1.Service, error) {
+	log.Info("@chirag: Starting ensureLoadBalancerService()")
 	wantLBS, desiredLBService, err := desiredLoadBalancerService(ci, deploymentRef, platformStatus, r.config.IngressControllerLBSubnetsAWSEnabled, r.config.IngressControllerEIPAllocationsAWSEnabled)
 	if err != nil {
 		return false, nil, err
@@ -347,6 +350,7 @@ func isServiceOwnedByIngressController(service *corev1.Service, ic *operatorv1.I
 // desired if the high availability type is Cloud. An LB service will declare an
 // owner reference to the given deployment.
 func desiredLoadBalancerService(ci *operatorv1.IngressController, deploymentRef metav1.OwnerReference, platform *configv1.PlatformStatus, subnetsAWSEnabled bool, eipAllocationsAWSEnabled bool) (bool, *corev1.Service, error) {
+	log.Info("@chirag: Starting desiredLoadBalancerService()")
 	if ci.Status.EndpointPublishingStrategy.Type != operatorv1.LoadBalancerServiceStrategyType {
 		return false, nil, nil
 	}
@@ -446,6 +450,7 @@ func desiredLoadBalancerService(ci *operatorv1.IngressController, deploymentRef
 			}
 
 			if platform.AWS != nil && len(platform.AWS.ResourceTags) > 0 {
+				log.Info("@chirag: platform.AWS.ResourceTags", "tags", platform.AWS.ResourceTags)
 				var additionalTags []string
 				for _, userTag := range platform.AWS.ResourceTags {
 					if len(userTag.Key) > 0 {
@@ -454,6 +459,7 @@ func desiredLoadBalancerService(ci *operatorv1.IngressController, deploymentRef
 				}
 				if len(additionalTags) > 0 {
 					service.Annotations[awsLBAdditionalResourceTags] = strings.Join(additionalTags, ",")
+					log.Info("@chirag: service.Annotations", "tags", service.Annotations[awsLBAdditionalResourceTags])
 				}
 			}
 
@@ -751,10 +757,10 @@ func IsServiceInternal(service *corev1.Service) bool {
 	return false
 }
 
-// loadBalancerServiceTagsModified verifies that none of the managedAnnotations have been changed and also the AWS tags annotation
+// loadBalancerServiceTagsModified verifies that none of the managedAnnotations have been changed
 func loadBalancerServiceTagsModified(current, expected *corev1.Service) (bool, *corev1.Service) {
-	ignoredAnnotations := managedLoadBalancerServiceAnnotations.Union(sets.NewString(awsLBAdditionalResourceTags))
-	return loadBalancerServiceAnnotationsChanged(current, expected, ignoredAnnotations)
+	// ignoredAnnotations := managedLoadBalancerServiceAnnotations.Union(sets.NewString(awsLBAdditionalResourceTags))
+	return loadBalancerServiceAnnotationsChanged(current, expected, managedLoadBalancerServiceAnnotations)
 }
 
 // loadBalancerServiceIsUpgradeable returns an error value indicating if the