chore(e2e): fix and enable e2e tests

.github/workflows/ci.yml

@@ -28,6 +28,41 @@ jobs:
 
       - run: make test
 
+  e2e:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: "1.20"
+
+      - name: Install Go dependencies
+        run: |
+          go install github.com/onsi/ginkgo/v2/ginkgo
+          go install sigs.k8s.io/kwok/cmd/{kwok,kwokctl}@v0.3.0
+
+      - name: Build cluster
+        run: CLUSTER_PROVIDER=kwok make dev-up
+
+      - name: Build images
+        run: make images
+
+      - name: Run Kubeadmiral
+        run: |
+          kwokctl get kubeconfig --name kubeadmiral-host > $HOME/.kube/kubeadmiral/kubeadmiral-host.yaml
+          docker create \
+            --network host \
+            --name kubeadmiral-controller-manager \
+            ghcr.io/kubewharf/kubeadmiral-controller-manager:latest \
+            /kubeadmiral-controller-manager --kubeconfig=/etc/kubeconfig --klog-v=4 --cluster-join-timeout=1m
+          docker cp $HOME/.kube/kubeadmiral/kubeadmiral-host.yaml kubeadmiral-controller-manager:/etc/kubeconfig
+          docker start kubeadmiral-controller-manager
+
+      - name: Run tests
+        run: KUBECONFIG=$HOME/.kube/kubeadmiral/kubeadmiral-host.yaml EXTRA_GINKGO_FLAGS="-v" make e2e
+
   lint:
     runs-on: ubuntu-latest
     steps:

test/e2e/automigration/automigration.go

@@ -52,7 +52,7 @@ var (
 	assertNoAutoMigrationDuration = 20 * time.Second
 )
 
-var _ = ginkgo.Describe("auto migration", autoMigrationTestLabel, func() {
+var _ = ginkgo.Describe("Auto Migration", autoMigrationTestLabel, func() {
 	f := framework.NewFramework("auto-migration", framework.FrameworkOptions{CreateNamespace: true})
 
 	var clusters []*fedcorev1a1.FederatedCluster

test/e2e/federatedcluster/clusterdelete.go

@@ -87,9 +87,8 @@ var _ = ginkgo.Describe("Cluster Delete", federatedClusterTestLabels, func() {
 		// 3. service account info deleted from secret
 		secret, err = f.HostKubeClient().CoreV1().Secrets(framework.FedSystemNamespace).Get(ctx, secret.Name, metav1.GetOptions{})
 		gomega.Expect(err).ToNot(gomega.HaveOccurred())
-		token, ca := getServiceAccountInfo(secret)
+		token, _ := getServiceAccountInfo(secret)
 		gomega.Expect(token).To(gomega.BeNil(), "Token data not removed from cluster secret")
-		gomega.Expect(ca).To(gomega.BeNil(), "Token data not removed from cluster secret")
 	}
 
 	ginkgo.Context("Without cascading delete", func() {

test/e2e/federatedcluster/clusterjoin.go

@@ -74,9 +74,8 @@ var _ = ginkgo.Describe("Cluster Join", federatedClusterTestLabels, func() {
 			ginkgo.By("Assert cluster secret not updated with service account information")
 			secret, err := f.HostKubeClient().CoreV1().Secrets(framework.FedSystemNamespace).Get(ctx, secret.Name, metav1.GetOptions{})
 			gomega.Expect(err).ToNot(gomega.HaveOccurred())
-			token, ca := getServiceAccountInfo(secret)
+			token, _ := getServiceAccountInfo(secret)
 			gomega.Expect(token).To(gomega.BeNil())
-			gomega.Expect(ca).To(gomega.BeNil())
 		})
 	})
 

test/e2e/framework/cluster.go

@@ -22,7 +22,7 @@ import (
 	corev1 "k8s.io/api/core/v1"
 
 	fedcorev1a1 "github.com/kubewharf/kubeadmiral/pkg/apis/core/v1alpha1"
-	"github.com/kubewharf/kubeadmiral/pkg/controllers/util"
+	"github.com/kubewharf/kubeadmiral/pkg/util/cascadingdeletion"
 )
 
 const (
@@ -51,7 +51,7 @@ func WithCascadingDelete(c *fedcorev1a1.FederatedCluster) {
 	if c.Annotations == nil {
 		c.Annotations = map[string]string{}
 	}
-	c.Annotations[util.AnnotationCascadingDelete] = "true"
+	c.Annotations[cascadingdeletion.AnnotationCascadingDelete] = "true"
 }
 
 func WithTaints(c *fedcorev1a1.FederatedCluster) {

test/e2e/framework/framework.go

@@ -38,11 +38,14 @@ import (
 	"k8s.io/client-go/dynamic"
 	kubeclient "k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/rest"
+	"k8s.io/client-go/tools/cache"
 	"k8s.io/client-go/tools/clientcmd"
 
 	fedcorev1a1 "github.com/kubewharf/kubeadmiral/pkg/apis/core/v1alpha1"
 	fedclient "github.com/kubewharf/kubeadmiral/pkg/client/clientset/versioned"
+	fedinformers "github.com/kubewharf/kubeadmiral/pkg/client/informers/externalversions"
 	"github.com/kubewharf/kubeadmiral/pkg/controllers/common"
+	"github.com/kubewharf/kubeadmiral/pkg/util/informermanager"
 	"github.com/kubewharf/kubeadmiral/test/e2e/framework/clusterprovider"
 )
 
@@ -83,6 +86,7 @@ var (
 	hostFedClient         fedclient.Interface
 	hostDynamicClient     dynamic.Interface
 	hostDiscoveryClient   discovery.DiscoveryInterface
+	ftcManager            informermanager.FederatedTypeConfigManager
 	clusterKubeClients    sync.Map
 	clusterFedClients     sync.Map
 	clusterDynamicClients sync.Map
@@ -93,7 +97,12 @@ func init() {
 	flag.StringVar(&master, "master", "", "The address of the host Kubernetes cluster.")
 	flag.StringVar(&kubeconfig, "kubeconfig", "", "The path of the kubeconfig for the host Kubernetes cluster.")
 	flag.Float64Var(&kubeAPIQPS, "kube-api-qps", 500, "The maximum QPS from each Kubernetes client.")
-	flag.IntVar(&kubeAPIBurst, "kube-api-burst", 1000, "The maximum burst for throttling requests from each Kubernetes client.")
+	flag.IntVar(
+		&kubeAPIBurst,
+		"kube-api-burst",
+		1000,
+		"The maximum burst for throttling requests from each Kubernetes client.",
+	)
 
 	flag.StringVar(&clusterProvider, "cluster-provider", "kwok", "The cluster provider [kwok,kind] to use.")
 	flag.StringVar(
@@ -102,11 +111,26 @@ func init() {
 		"kindest/node:v1.20.15@sha256:a32bf55309294120616886b5338f95dd98a2f7231519c7dedcec32ba29699394",
 		"The node image to use for creating kind test clusters, it should include the image digest.",
 	)
-	flag.StringVar(&kwokImagePrefix, "kwok-image-prefix", "registry.k8s.io", "The image prefix used by kwok to pull kubernetes images.")
-	flag.StringVar(&kwokKubeVersion, "kwok-kube-version", "v1.20.15", "The kubernetes version to be used for kwok member clusters")
+	flag.StringVar(
+		&kwokImagePrefix,
+		"kwok-image-prefix",
+		"registry.k8s.io",
+		"The image prefix used by kwok to pull kubernetes images.",
+	)
+	flag.StringVar(
+		&kwokKubeVersion,
+		"kwok-kube-version",
+		"v1.20.15",
+		"The kubernetes version to be used for kwok member clusters",
+	)
 
 	flag.BoolVar(&preserveClusters, "preserve-clusters", false, "If set, clusters created during testing are preserved")
-	flag.BoolVar(&preserveNamespace, "preserve-namespaces", false, "If set, namespaces created during testing are preserved")
+	flag.BoolVar(
+		&preserveNamespace,
+		"preserve-namespaces",
+		false,
+		"If set, namespaces created during testing are preserved",
+	)
 }
 
 var _ = ginkgo.SynchronizedBeforeSuite(
@@ -125,7 +149,7 @@ var _ = ginkgo.SynchronizedBeforeSuite(
 
 		return bytes
 	},
-	func(data []byte) {
+	func(ctx context.Context, data []byte) {
 		params := []string{}
 		err := json.Unmarshal(data, &params)
 		gomega.Expect(err).ToNot(gomega.HaveOccurred())
@@ -150,6 +174,21 @@ var _ = ginkgo.SynchronizedBeforeSuite(
 		hostDiscoveryClient, err = discovery.NewDiscoveryClientForConfig(restConfig)
 		gomega.Expect(err).ShouldNot(gomega.HaveOccurred())
 
+		fedInformerFactory := fedinformers.NewSharedInformerFactory(hostFedClient, 0)
+		manager := informermanager.NewInformerManager(
+			hostDynamicClient,
+			fedInformerFactory.Core().V1alpha1().FederatedTypeConfigs(),
+			nil,
+		)
+		ftcManager = manager
+
+		fedInformerFactory.Start(ctx.Done())
+		manager.Start(ctx)
+
+		if !cache.WaitForNamedCacheSync("host-informer-manager", ctx.Done(), ftcManager.HasSynced) {
+			ginkgo.Fail("failed to wait for host informer manager cache sync")
+		}
+
 		clusterKubeClients = sync.Map{}
 		clusterFedClients = sync.Map{}
 		clusterDynamicClients = sync.Map{}
@@ -170,7 +209,9 @@ var _ = ginkgo.SynchronizedBeforeSuite(
 				defaultClusterWaitTimeout,
 			)
 		default:
-			ginkgo.Fail(fmt.Sprintf("invalid cluster provider, %s or %s accepted", KwokClusterProvider, KindClusterProvider))
+			ginkgo.Fail(
+				fmt.Sprintf("invalid cluster provider, %s or %s accepted", KwokClusterProvider, KindClusterProvider),
+			)
 		}
 	},
 )
@@ -231,12 +272,19 @@ func (*framework) HostDiscoveryClient() discovery.DiscoveryInterface {
 	return hostDiscoveryClient
 }
 
+func (*framework) FTCManager() informermanager.FederatedTypeConfigManager {
+	return ftcManager
+}
+
 func (f *framework) TestNamespace() *corev1.Namespace {
 	gomega.Expect(f.namespace).ToNot(gomega.BeNil(), MessageUnexpectedError)
 	return f.namespace
 }
 
-func (f *framework) NewCluster(ctx context.Context, clusterModifiers ...ClusterModifier) (*fedcorev1a1.FederatedCluster, *corev1.Secret) {
+func (f *framework) NewCluster(
+	ctx context.Context,
+	clusterModifiers ...ClusterModifier,
+) (*fedcorev1a1.FederatedCluster, *corev1.Secret) {
 	clusterName := strings.ToLower(fmt.Sprintf("%s-%s", f.name, rand.String(12)))
 	cluster, secret := f.clusterProvider.NewCluster(ctx, clusterName)
 

test/e2e/framework/interface.go

@@ -26,6 +26,7 @@ import (
 
 	fedcorev1a1 "github.com/kubewharf/kubeadmiral/pkg/apis/core/v1alpha1"
 	fedclient "github.com/kubewharf/kubeadmiral/pkg/client/clientset/versioned"
+	"github.com/kubewharf/kubeadmiral/pkg/util/informermanager"
 )
 
 type FrameworkOptions struct {
@@ -37,6 +38,7 @@ type Framework interface {
 	HostFedClient() fedclient.Interface
 	HostDynamicClient() dynamic.Interface
 	HostDiscoveryClient() discovery.DiscoveryInterface
+	FTCManager() informermanager.FederatedTypeConfigManager
 
 	Name() string
 	TestNamespace() *corev1.Namespace

test/e2e/framework/policies/propagationpolicy.go

@@ -38,12 +38,12 @@ func PropagationPolicyForClustersWithPlacements(
 		},
 		Spec: fedcorev1a1.PropagationPolicySpec{
 			SchedulingMode: fedcorev1a1.SchedulingModeDuplicate,
-			Placements:     []fedcorev1a1.ClusterReference{},
+			Placements:     []fedcorev1a1.DesiredPlacement{},
 		},
 	}
 
 	for _, c := range clusters {
-		policy.Spec.Placements = append(policy.Spec.Placements, fedcorev1a1.ClusterReference{Cluster: c.Name})
+		policy.Spec.Placements = append(policy.Spec.Placements, fedcorev1a1.DesiredPlacement{Cluster: c.Name})
 	}
 
 	return policy

test/e2e/resourcepropagation/cronjobs.go

@@ -43,7 +43,8 @@ var _ = ginkgo.Describe("CronJob Propagation", func() {
 			resourcePropagationTest(
 				f,
 				&resourcePropagationTestConfig[*batchv1.CronJob]{
-					gvr:           batchv1.SchemeGroupVersion.WithResource("jobs"),
+					gvr:           batchv1.SchemeGroupVersion.WithResource("cronjobs"),
+					gvk:           batchv1.SchemeGroupVersion.WithKind("CronJob"),
 					objectFactory: resources.GetSimpleV1CronJob,
 					clientGetter: func(client kubernetes.Interface, namespace string) resourceClient[*batchv1.CronJob] {
 						return client.BatchV1().CronJobs(namespace)
@@ -56,7 +57,6 @@ var _ = ginkgo.Describe("CronJob Propagation", func() {
 						return resources.IsV1CronJobScheduledOnce(cronjob), nil
 					},
 					statusCollection: &resourceStatusCollectionTestConfig{
-						gvr:  fedtypesv1a1.SchemeGroupVersion.WithResource("federatedcronjobstatuses"),
 						path: "status",
 					},
 				},
@@ -66,7 +66,8 @@ var _ = ginkgo.Describe("CronJob Propagation", func() {
 			resourcePropagationTest(
 				f,
 				&resourcePropagationTestConfig[*batchv1b1.CronJob]{
-					gvr:           batchv1.SchemeGroupVersion.WithResource("jobs"),
+					gvr:           batchv1b1.SchemeGroupVersion.WithResource("cronjobs"),
+					gvk:           batchv1b1.SchemeGroupVersion.WithKind("CronJob"),
 					objectFactory: resources.GetSimpleV1Beta1CronJob,
 					clientGetter: func(client kubernetes.Interface, namespace string) resourceClient[*batchv1b1.CronJob] {
 						return client.BatchV1beta1().CronJobs(namespace)
@@ -79,7 +80,6 @@ var _ = ginkgo.Describe("CronJob Propagation", func() {
 						return resources.IsV1Beta1CronJobScheduledOnce(cronjob), nil
 					},
 					statusCollection: &resourceStatusCollectionTestConfig{
-						gvr:  fedtypesv1a1.SchemeGroupVersion.WithResource("federatedcronjobstatuses"),
 						path: "status",
 					},
 				},

test/e2e/resourcepropagation/deployments.go

@@ -34,6 +34,7 @@ var _ = ginkgo.Describe("Deployment Propagation", func() {
 			f,
 			&resourcePropagationTestConfig[*appsv1.Deployment]{
 				gvr:           appsv1.SchemeGroupVersion.WithResource("deployments"),
+				gvk:           appsv1.SchemeGroupVersion.WithKind("Deployment"),
 				objectFactory: resources.GetSimpleDeployment,
 				clientGetter: func(client kubernetes.Interface, namespace string) resourceClient[*appsv1.Deployment] {
 					return client.AppsV1().Deployments(namespace)
@@ -46,7 +47,6 @@ var _ = ginkgo.Describe("Deployment Propagation", func() {
 					return resources.IsDeploymentProgressing(deployment), nil
 				},
 				statusCollection: &resourceStatusCollectionTestConfig{
-					gvr:  fedtypesv1a1.SchemeGroupVersion.WithResource("federateddeploymentstatuses"),
 					path: "status",
 				},
 			},