test: add informer start

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

Author: juanxiu

internal/manager/application/application_test.go

@@ -58,6 +58,19 @@ func fakeInformer(t *testing.T, namespace string, objects ...runtime.Object) (*f
 		informer.WithNamespaceScope[*v1alpha1.Application](namespace),
 	)
 	require.NoError(t, err)
+
+	go func() {
+		err = informer.Start(context.Background())
+		if err != nil {
+			t.Fatalf("failed to start informer: %v", err)
+		}
+	}()
+
+	// cache.WaitForCacheSync(context.Background().Done(), informer.HasSynced)
+	if err = informer.WaitForSync(context.Background()); err != nil {
+		t.Fatalf("failed to wait for informer sync: %v", err)
+	}
+
 	return appC, informer
 }
 
@@ -69,6 +82,7 @@ func fakeAppManager(t *testing.T, objects ...runtime.Object) (*fakeappclient.Cli
 	am, err := NewApplicationManager(be, "argocd")
 	assert.NoError(t, err)
 
+	// go am.StartBackend(context.Background())
 	return appC, am
 }
 
@@ -209,7 +223,13 @@ func Test_ManagerUpdateManaged(t *testing.T) {
 		mgr, err := NewApplicationManager(be, "argocd", WithMode(manager.ManagerModeManaged), WithRole(manager.ManagerRoleAgent))
 		require.NoError(t, err)
 
+		// ctx, cancel := context.WithCancel(context.Background())
+		// defer cancel()
+		// go mgr.StartBackend(ctx)
+		// cache.WaitForCacheSync(ctx.Done(), ai.HasSynced)
+
 		updated, err := mgr.UpdateManagedApp(context.Background(), incoming)
+
 		require.NoError(t, err)
 		require.NotNil(t, updated)
 

principal/event_test.go

@@ -128,6 +128,7 @@ func Test_CreateEvents(t *testing.T) {
 		wq.On("Get").Return(&ev, false)
 		wq.On("Done", &ev)
 		s, err := NewServer(context.Background(), fac, "argocd", WithGeneratedTokenSigningKey(), WithAutoNamespaceCreate(true, "", nil))
+		s.Start(context.Background(), make(chan error))
 		s.clusterMgr.MapCluster("argocd", &v1alpha1.Cluster{Name: "argocd", Server: "https://argocd.com"})
 		require.NoError(t, err)
 		s.setAgentMode("argocd", types.AgentModeAutonomous)
@@ -247,6 +248,7 @@ func Test_CreateEvents(t *testing.T) {
 		wq.On("Get").Return(&ev, false)
 		wq.On("Done", &ev)
 		s, err := NewServer(context.Background(), fac, "argocd", WithGeneratedTokenSigningKey())
+		s.Start(context.Background(), make(chan error))
 		require.NoError(t, err)
 		s.clusterMgr.MapCluster("foo", &v1alpha1.Cluster{Name: "foo", Server: "https://foo.com"})
 		s.setAgentMode("foo", types.AgentModeAutonomous)
@@ -327,6 +329,7 @@ func Test_UpdateEvents(t *testing.T) {
 		wq.On("Done", &ev)
 		s, err := NewServer(context.Background(), fac, "argocd", WithGeneratedTokenSigningKey())
 		require.NoError(t, err)
+		s.Start(context.Background(), make(chan error))
 		s.setAgentMode("foo", types.AgentModeAutonomous)
 		s.clusterMgr.MapCluster("foo", &v1alpha1.Cluster{Name: "foo", Server: "https://foo.com"})
 		got, err := s.processRecvQueue(context.Background(), "foo", wq)
@@ -446,6 +449,7 @@ func Test_DeleteEvents_ManagedMode(t *testing.T) {
 			wq.On("Done", &ev)
 			s, err := NewServer(context.Background(), fac, "argocd", WithGeneratedTokenSigningKey())
 			require.NoError(t, err)
+
 			s.setAgentMode("foo", types.AgentModeManaged)
 
 			_, err = fac.ApplicationsClientset.ArgoprojV1alpha1().Applications(delApp.Namespace).Create(context.Background(), delApp, v1.CreateOptions{})