Feat: Adding work subject executor feature related api (#152)

* [generated] go mod vendor

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

* adding work executor subject field

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

Author: yue9944882

test/integration/manifestwork_test.go

@@ -0,0 +1,75 @@
+package integration
+
+import (
+	"context"
+	"fmt"
+
+	workv1 "open-cluster-management.io/api/work/v1"
+
+	"github.com/onsi/ginkgo"
+	"github.com/onsi/gomega"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/rand"
+)
+
+var _ = ginkgo.Describe("ManifestWork API test", func() {
+	var manifestWorkName string
+
+	ginkgo.BeforeEach(func() {
+		suffix := rand.String(5)
+		manifestWorkName = fmt.Sprintf("manifestwork-%s", suffix)
+	})
+
+	ginkgo.It("Create a ManifestWork with empty executor identity", func() {
+		work := &workv1.ManifestWork{
+			ObjectMeta: metav1.ObjectMeta{
+				Name: manifestWorkName,
+			},
+		}
+		_, err := hubWorkClient.WorkV1().ManifestWorks(testNamespace).
+			Create(context.TODO(), work, metav1.CreateOptions{})
+		gomega.Expect(err).ToNot(gomega.HaveOccurred())
+	})
+
+	invalidSubjectType := "my-invalid-service-account-name"
+	ginkgo.It("Create a ManifestWork with an non-empty identity", func() {
+		work := &workv1.ManifestWork{
+			ObjectMeta: metav1.ObjectMeta{
+				Name: manifestWorkName,
+			},
+			Spec: workv1.ManifestWorkSpec{
+				Executor: &workv1.ManifestWorkExecutor{
+					Subject: workv1.ManifestWorkExecutorSubject{
+						Type: workv1.ManifestWorkExecutorSubjectType(invalidSubjectType),
+					},
+				},
+			},
+		}
+		_, err := hubWorkClient.WorkV1().ManifestWorks(testNamespace).
+			Create(context.TODO(), work, metav1.CreateOptions{})
+		gomega.Expect(err).To(gomega.HaveOccurred())
+	})
+
+	ginkgo.It("Create a ManifestWork with an non-empty identity", func() {
+		work := &workv1.ManifestWork{
+			ObjectMeta: metav1.ObjectMeta{
+				Name: manifestWorkName,
+			},
+			Spec: workv1.ManifestWorkSpec{
+				Executor: &workv1.ManifestWorkExecutor{
+					Subject: workv1.ManifestWorkExecutorSubject{
+						Type: workv1.ExecutorSubjectTypeServiceAccount,
+						ServiceAccount: &workv1.ManifestWorkSubjectServiceAccount{
+							Namespace: "default",
+							Name:      "----",
+						},
+					},
+				},
+			},
+		}
+		_, err := hubWorkClient.WorkV1().ManifestWorks(testNamespace).
+			Create(context.TODO(), work, metav1.CreateOptions{})
+		gomega.Expect(err).To(gomega.HaveOccurred())
+	})
+
+})

test/integration/suite_test.go

@@ -1,12 +1,17 @@
 package integration
 
 import (
+	"context"
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/rand"
 	"path/filepath"
 	"testing"
 
 	"github.com/onsi/ginkgo"
 	"github.com/onsi/gomega"
 
+	"k8s.io/client-go/kubernetes"
 	"sigs.k8s.io/controller-runtime/pkg/envtest"
 
 	addonv1alpha1client "open-cluster-management.io/api/client/addon/clientset/versioned"
@@ -16,6 +21,8 @@ import (
 )
 
 var testEnv *envtest.Environment
+var testNamespace string
+var kubernetesClient kubernetes.Interface
 var hubWorkClient workclientset.Interface
 var hubClusterClient clusterv1client.Interface
 var hubAddonClient addonv1alpha1client.Interface
@@ -57,13 +64,28 @@ var _ = ginkgo.BeforeSuite(func(done ginkgo.Done) {
 	gomega.Expect(err).NotTo(gomega.HaveOccurred())
 	operatorClient, err = operatorclientset.NewForConfig(cfg)
 	gomega.Expect(err).NotTo(gomega.HaveOccurred())
+	kubernetesClient, err = kubernetes.NewForConfig(cfg)
+	gomega.Expect(err).NotTo(gomega.HaveOccurred())
+
+	testNamespace = "open-cluster-management-api-test-" + rand.String(5)
+	_, err = kubernetesClient.CoreV1().Namespaces().
+		Create(context.TODO(), &corev1.Namespace{
+			ObjectMeta: metav1.ObjectMeta{
+				Name: testNamespace,
+			},
+		}, metav1.CreateOptions{})
+	gomega.Expect(err).ToNot(gomega.HaveOccurred())
 
 	close(done)
 }, 300)
 
 var _ = ginkgo.AfterSuite(func() {
 	ginkgo.By("tearing down the test environment")
 
-	err := testEnv.Stop()
+	err := kubernetesClient.CoreV1().Namespaces().
+		Delete(context.TODO(), testNamespace, metav1.DeleteOptions{})
+	gomega.Expect(err).ToNot(gomega.HaveOccurred())
+
+	err = testEnv.Stop()
 	gomega.Expect(err).ToNot(gomega.HaveOccurred())
 })