fix: linter errors

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

Author: fullykubed

pkg/reconciler/cmd/start.go

@@ -163,26 +163,26 @@ func Start(eventsOpts ArgoEventsControllerOpts) {
 	// by the EventSource. This controller provides the EventBus config via an env var which is why we need
 	// to reconcile the EventSource when the EventBus status.config updates.
 	if err := eventSourceController.Watch(
-		source.Kind(mgr.GetCache(), &aev1.EventBus{},			
-		handler.TypedEnqueueRequestsFromMapFunc[*aev1.EventBus](func(ctx context.Context, eventBus *aev1.EventBus) []reconcile.Request {
-			var eventSourceList aev1.EventSourceList
-			if err := mgr.GetClient().List(ctx, &eventSourceList, client.InNamespace(eventBus.Namespace)); err != nil {
-				logger.Errorw("Failed to list EventSources", zap.Error(err))
-				return nil
-			}
-			var requests []reconcile.Request
-			for _, es := range eventSourceList.Items {
-				requests = append(requests, reconcile.Request{
-					NamespacedName: types.NamespacedName{
-						Name:      es.Name,
-						Namespace: es.Namespace,
-					},
-				})
-			}
-			return requests
-		}),
-		common.EventBusConfigStatusChangedPredicate{},
-	)); err != nil {
+		source.Kind(mgr.GetCache(), &aev1.EventBus{},
+			handler.TypedEnqueueRequestsFromMapFunc[*aev1.EventBus](func(ctx context.Context, eventBus *aev1.EventBus) []reconcile.Request {
+				var eventSourceList aev1.EventSourceList
+				if err := mgr.GetClient().List(ctx, &eventSourceList, client.InNamespace(eventBus.Namespace)); err != nil {
+					logger.Errorw("Failed to list EventSources", zap.Error(err))
+					return nil
+				}
+				var requests []reconcile.Request
+				for _, es := range eventSourceList.Items {
+					requests = append(requests, reconcile.Request{
+						NamespacedName: types.NamespacedName{
+							Name:      es.Name,
+							Namespace: es.Namespace,
+						},
+					})
+				}
+				return requests
+			}),
+			common.EventBusConfigStatusChangedPredicate{},
+		)); err != nil {
 		logger.Fatalw("Unable to watch EventBus for EventSource updates", zap.Error(err))
 	}
 

pkg/reconciler/eventsource/resource.go

@@ -171,12 +171,12 @@ func getDeployment(ctx context.Context, cl client.Client, args *AdaptorArgs) (*a
 	return nil, apierrors.NewNotFound(schema.GroupResource{}, "")
 }
 
-func buildDeployment(args *AdaptorArgs, eventBus *aev1.EventBus) (*appv1.Deployment, error) {
+func buildDeployment(args *AdaptorArgs, eventBus *v1alpha1.EventBus) (*appv1.Deployment, error) {
 	deploymentSpec, err := buildDeploymentSpec(args)
 	if err != nil {
 		return nil, err
 	}
-	eventSourceCopy := &aev1.EventSource{
+	eventSourceCopy := &v1alpha1.EventSource{
 		ObjectMeta: metav1.ObjectMeta{
 			Namespace: args.EventSource.Namespace,
 			Name:      args.EventSource.Name,