fix test

Signed-off-by: Huabing Zhao <[email protected]>

internal/provider/kubernetes/predicates.go

@@ -294,10 +294,7 @@ func (r *gatewayAPIReconciler) validateServiceForReconcile(obj client.Object) bo
 	// Check if the Service belongs to a Gateway, if so, update the Gateway status.
 	gtw := r.findOwningGateway(ctx, labels)
 	if gtw != nil {
-		// Trigger a status update for the Gateway.
-		// The status updater will check the service to get the addresses of the Gateway,
-		// and check the Deployment/DaemonSet to get the status of the Gateway workload.
-		r.resources.GatewayStatuses.Store(utils.NamespacedName(gtw), &gtw.Status)
+		r.updateGatewayStatus(gtw)
 		return false
 	}
 
@@ -531,10 +528,7 @@ func (r *gatewayAPIReconciler) validateObjectForReconcile(obj client.Object) boo
 		// Check if the obj belongs to a Gateway, if so, update the Gateway status.
 		gtw := r.findOwningGateway(ctx, labels)
 		if gtw != nil {
-			// Trigger a status update for the Gateway.
-			// The status updater will check the service to get the addresses of the Gateway,
-			// and check the Deployment/DaemonSet to get the status of the Gateway workload.
-			r.resources.GatewayStatuses.Store(utils.NamespacedName(gtw), &gtw.Status)
+			r.updateGatewayStatus(gtw)
 			return false
 		}
 	}
@@ -642,12 +636,26 @@ func (r *gatewayAPIReconciler) updateStatusForGatewaysUnderGatewayClass(ctx cont
 	}
 
 	for _, gateway := range gateways.Items {
-		r.resources.GatewayStatuses.Store(utils.NamespacedName(&gateway), &gateway.Status)
+		r.updateGatewayStatus(&gateway)
 	}
 
 	return nil
 }
 
+// updateGatewayStatus triggers a status update for the Gateway.
+func (r *gatewayAPIReconciler) updateGatewayStatus(gateway *gwapiv1.Gateway) {
+	// The status added to GatewayStatuses is solely used to trigger the status updater
+	// and does not reflect the real changed status.
+	//
+	// The status updater will check the Envoy Proxy service to get the addresses of the Gateway,
+	// and check the Envoy Proxy Deployment/DaemonSet to get the status of the Gateway workload.
+	//
+	// Since the status does not reflect the actual changed status, we need to delete it first
+	// to prevent it from being considered unchanged. This ensures that subscribers receive the update event.
+	r.resources.GatewayStatuses.Delete(utils.NamespacedName(gateway))
+	r.resources.GatewayStatuses.Store(utils.NamespacedName(gateway), &gateway.Status)
+}
+
 func (r *gatewayAPIReconciler) handleNode(obj client.Object) bool {
 	ctx := context.Background()
 	node, ok := obj.(*corev1.Node)