tests

pkg/operator/controller/gatewayclass/controller.go

@@ -3,7 +3,9 @@ package gatewayclass
 import (
 	"context"
 	logf "github.com/openshift/cluster-ingress-operator/pkg/log"
+	operatorsv1alpha1 "github.com/operator-framework/api/pkg/operators/v1alpha1"
 	"k8s.io/client-go/tools/record"
+	"sigs.k8s.io/controller-runtime/pkg/event"
 
 	gatewayapiv1beta1 "sigs.k8s.io/gateway-api/apis/v1beta1"
 
@@ -79,17 +81,17 @@ func NewUnmanaged(mgr manager.Manager, config Config) (controller.Controller, er
 	//	}}
 	//}
 
-	//isServiceMeshSubscription := predicate.NewPredicateFuncs(func(o client.Object) bool {
-	//	return o.GetName() == "servicemeshoperator" && o.GetNamespace() == "openshift-operators"
-	//})
-	//if err := c.Watch(source.Kind(operatorCache, &operatorsv1alpha1.Subscription{}), &handler.EnqueueRequestForObject{}, predicate.Funcs{
-	//	CreateFunc:  func(e event.CreateEvent) bool { return false },
-	//	DeleteFunc:  func(e event.DeleteEvent) bool { return true },
-	//	UpdateFunc:  func(e event.UpdateEvent) bool { return false },
-	//	GenericFunc: func(e event.GenericEvent) bool { return false },
-	//}); err != nil {
-	//	return nil, err
-	//}
+	isServiceMeshSubscription := predicate.NewPredicateFuncs(func(o client.Object) bool {
+		return o.GetName() == "servicemeshoperator" && o.GetNamespace() == "openshift-operators"
+	})
+	if err = c.Watch(source.Kind[client.Object](operatorCache, &operatorsv1alpha1.Subscription{}, &handler.EnqueueRequestForObject{}, isServiceMeshSubscription, predicate.Funcs{
+		CreateFunc:  func(e event.CreateEvent) bool { return false },
+		DeleteFunc:  func(e event.DeleteEvent) bool { return true },
+		UpdateFunc:  func(e event.UpdateEvent) bool { return false },
+		GenericFunc: func(e event.GenericEvent) bool { return false },
+	})); err != nil {
+		return nil, err
+	}
 
 	return c, nil
 }