add mocks

Signed-off-by: Alexy Mantha <alexy@mantha.dev>

server/application/application_test.go

@@ -47,12 +47,12 @@ import (
 	appinformer "github.com/argoproj/argo-cd/v2/pkg/client/informers/externalversions"
 	"github.com/argoproj/argo-cd/v2/reposerver/apiclient"
 	"github.com/argoproj/argo-cd/v2/reposerver/apiclient/mocks"
-	appmocks "github.com/argoproj/argo-cd/v2/server/application/mocks"
 	servercache "github.com/argoproj/argo-cd/v2/server/cache"
 	"github.com/argoproj/argo-cd/v2/server/rbacpolicy"
 	"github.com/argoproj/argo-cd/v2/test"
 	"github.com/argoproj/argo-cd/v2/util/argo"
 	"github.com/argoproj/argo-cd/v2/util/assets"
+	broadcastermocks "github.com/argoproj/argo-cd/v2/util/broadcast/mocks"
 	"github.com/argoproj/argo-cd/v2/util/cache"
 	cacheutil "github.com/argoproj/argo-cd/v2/util/cache"
 	"github.com/argoproj/argo-cd/v2/util/cache/appstate"
@@ -221,7 +221,7 @@ func newTestAppServerWithEnforcerConfigure(f func(*rbac.Enforcer), t *testing.T,
 		panic("Timed out waiting for caches to sync")
 	}
 
-	broadcaster := new(appmocks.Broadcaster)
+	broadcaster := new(broadcastermocks.Broadcaster[appsv1.ApplicationWatchEvent])
 	broadcaster.On("Subscribe", mock.Anything, mock.Anything).Return(func() {}).Run(func(args mock.Arguments) {
 		// Simulate the broadcaster notifying the subscriber of an application update.
 		// The second parameter to Subscribe is filters. For the purposes of tests, we ignore the filters. Future tests
@@ -401,7 +401,7 @@ func newTestAppServerWithEnforcerConfigureWithBenchmark(f func(*rbac.Enforcer),
 		panic("Timed out waiting for caches to sync")
 	}
 
-	broadcaster := new(appmocks.Broadcaster)
+	broadcaster := new(broadcastermocks.Broadcaster[appsv1.ApplicationWatchEvent])
 	broadcaster.On("Subscribe", mock.Anything, mock.Anything).Return(func() {}).Run(func(args mock.Arguments) {
 		// Simulate the broadcaster notifying the subscriber of an application update.
 		// The second parameter to Subscribe is filters. For the purposes of tests, we ignore the filters. Future tests

server/applicationset/applicationset_test.go

@@ -7,7 +7,7 @@ import (
 	"testing"
 	"time"
 
-	appsetmocks "github.com/argoproj/argo-cd/v2/server/applicationset/mocks"
+	broadcastermocks "github.com/argoproj/argo-cd/v2/util/broadcast/mocks"
 	"github.com/argoproj/pkg/sync"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
@@ -150,7 +150,7 @@ func newTestAppSetServerWithEnforcerConfigure(f func(*rbac.Enforcer), namespace
 		panic("Timed out waiting for caches to sync")
 	}
 
-	broadcaster := new(appsetmocks.Broadcaster)
+	broadcaster := new(broadcastermocks.Broadcaster[appsv1.ApplicationSetWatchEvent])
 	broadcaster.On("Subscribe", mock.Anything, mock.Anything).Return(func() {}).Run(func(args mock.Arguments) {
 		// Simulate the broadcaster notifying the subscriber of an applicationset update.
 		// The second parameter to Subscribe is filters. For the purposes of tests, we ignore the filters. Future tests