add test case

Author: AlinsRan

internal/controller/consumer_controller.go

@@ -100,12 +100,10 @@ func (r *ConsumerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 			}
 
 			if err := r.Provider.Delete(ctx, consumer); err != nil {
-				r.Log.Error(err, "failed to delete consumer", "consumer", consumer)
 				return ctrl.Result{}, err
 			}
 			return ctrl.Result{}, nil
 		}
-		r.Log.Error(err, "failed to get consumer", "consumer", consumer)
 		return ctrl.Result{}, err
 	}
 
@@ -123,16 +121,13 @@ func (r *ConsumerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 	}
 
 	if err := r.updateStatus(ctx, consumer, statusErr); err != nil {
-		r.Log.Error(err, "failed to update consumer status", "consumer", consumer)
 		return ctrl.Result{}, err
 	}
 
 	return ctrl.Result{}, nil
 }
 
 func (r *ConsumerReconciler) processSepc(ctx context.Context, tctx *provider.TranslateContext, consumer *v1alpha1.Consumer) error {
-	r.Log.Info("Processing consumer", "name", consumer.Name, "namespace", consumer.Namespace)
-
 	for _, credential := range consumer.Spec.Credentials {
 		if credential.SecretRef == nil {
 			continue
@@ -204,5 +199,10 @@ func (r *ConsumerReconciler) checkGatewayRef(object client.Object) bool {
 		r.Log.Error(err, "failed to get gateway", "gateway", consumer.Spec.GatewayRef.Name)
 		return false
 	}
-	return true
+	gatewayClass := &gatewayv1.GatewayClass{}
+	if err := r.Client.Get(context.Background(), client.ObjectKey{Name: string(gateway.Spec.GatewayClassName)}, gatewayClass); err != nil {
+		r.Log.Error(err, "failed to get gateway class", "gateway", gateway.GetName(), "gatewayclass", gateway.Spec.GatewayClassName)
+		return false
+	}
+	return matchesController(string(gatewayClass.Spec.ControllerName))
 }

internal/controller/status.go

@@ -10,17 +10,20 @@ const (
 	ConditionTypeProgressing string = "Progressing"
 	ConditionTypeDegraded    string = "Degraded"
 
-	ConditionReasonSynced string = "ResourceSynced"
+	ConditionReasonSynced    string = "ResourceSynced"
+	ConditionReasonSyncAbort string = "ResourceSyncAbort"
 )
 
 func NewCondition(observedGeneration int64, status bool, message string) metav1.Condition {
 	condition := metav1.ConditionTrue
+	reason := ConditionReasonSynced
 	if !status {
 		condition = metav1.ConditionFalse
+		reason = ConditionReasonSyncAbort
 	}
 	return metav1.Condition{
 		Type:               ConditionTypeAvailable,
-		Reason:             ConditionReasonSynced,
+		Reason:             reason,
 		Status:             condition,
 		Message:            message,
 		ObservedGeneration: observedGeneration,