update gateways from k8s client for services/deployments predicates

Signed-off-by: shawnh2 <shawnhxh@outlook.com>

internal/gatewayapi/validate.go

@@ -207,8 +207,8 @@ func (t *Translator) validateListenerConditions(listener *ListenerContext) (isRe
 		listener.SetCondition(gwapiv1.ListenerConditionResolvedRefs, metav1.ConditionTrue, gwapiv1.ListenerReasonResolvedRefs,
 			"Listener references have been resolved")
 		return true
-
 	}
+
 	// Any condition on the listener apart from Programmed=true indicates an error.
 	if !(lConditions[0].Type == string(gwapiv1.ListenerConditionProgrammed) && lConditions[0].Status == metav1.ConditionTrue) {
 		hasProgrammedCond := false

internal/provider/kubernetes/predicates.go

@@ -213,11 +213,14 @@ func (r *gatewayAPIReconciler) validateServiceForReconcile(obj client.Object) bo
 	}
 	labels := svc.GetLabels()
 
-	// Check if the Service belongs to a Gateway, if so, update the Gateway status.
-	gtw := r.findOwningGateway(ctx, labels)
-	if gtw != nil {
-		r.updateStatusForGateway(ctx, gtw)
-		return false
+	// Only services in the configured namespace should be reconciled.
+	if svc.Namespace == r.namespace {
+		// Check if the Service belongs to a Gateway, if so, update the Gateway status.
+		gtw := r.findOwningGateway(ctx, labels)
+		if gtw != nil {
+			r.updateStatusForGateway(ctx, gtw)
+			return false
+		}
 	}
 
 	// Merged gateways will have only this label, update status of all Gateways under found GatewayClass.
@@ -226,9 +229,15 @@ func (r *gatewayAPIReconciler) validateServiceForReconcile(obj client.Object) bo
 		res, _ := r.resources.GatewayAPIResources.Load(string(r.classController))
 		if res != nil {
 			if (*res)[gclass] != nil && len((*res)[gclass].Gateways) > 0 {
-				for _, gw := range (*res)[gclass].Gateways {
-					gw := gw
-					r.updateStatusForGateway(ctx, gw)
+				for _, gtw := range (*res)[gclass].Gateways {
+					curGtw := new(gwapiv1.Gateway)
+					key := types.NamespacedName{Namespace: gtw.Namespace, Name: gtw.Name}
+					if err := r.client.Get(ctx, key, curGtw); err != nil {
+						r.log.Info("gateway not found", "gatewayclass", gclass, "name", key.String())
+						return false
+					}
+
+					r.updateStatusForGateway(ctx, curGtw)
 				}
 			}
 		}
@@ -383,9 +392,15 @@ func (r *gatewayAPIReconciler) validateDeploymentForReconcile(obj client.Object)
 		res, _ := r.resources.GatewayAPIResources.Load(string(r.classController))
 		if res != nil {
 			if (*res)[gclass] != nil && len((*res)[gclass].Gateways) > 0 {
-				for _, gw := range (*res)[gclass].Gateways {
-					gw := gw
-					r.updateStatusForGateway(ctx, gw)
+				for _, gtw := range (*res)[gclass].Gateways {
+					curGtw := new(gwapiv1.Gateway)
+					key := types.NamespacedName{Namespace: gtw.Namespace, Name: gtw.Name}
+					if err := r.client.Get(ctx, key, curGtw); err != nil {
+						r.log.Info("gateway not found", "gatewayclass", gclass, "name", key.String())
+						return false
+					}
+
+					r.updateStatusForGateway(ctx, curGtw)
 				}
 			}
 		}