Added clientset tests

pkg/driver/provisioner_server_impl.go

@@ -59,12 +59,12 @@ var FetchSecretInformation = fetchObjectStorageProviderSecretInfo
 var FetchParameters = fetchS3Parameters
 
 func InitProvisionerServer(provisioner string) (cosiapi.ProvisionerServer, error) {
-	klog.V(3).InfoS("Initializing ProvisionerServer", "provisioner", provisioner)
 	if provisioner == "" {
 		err := errors.New("provisioner name cannot be empty")
 		klog.ErrorS(err, "Failed to initialize ProvisionerServer: empty provisioner name")
 		return nil, err
 	}
+	klog.V(3).InfoS("Initializing ProvisionerServer", "provisioner", provisioner)
 
 	kubeConfig, err := InClusterConfig()
 	if err != nil {

pkg/driver/provisioner_server_impl_test.go

@@ -28,6 +28,39 @@ import (
 	cosiapi "sigs.k8s.io/container-object-storage-interface-spec"
 )
 
+var _ = Describe("ProvisionerServer Global Kubernetes and Bucket Client", func() {
+	var (
+		kubeConfig *rest.Config
+	)
+
+	BeforeEach(func() {
+		// Initialize a mock kubeConfig for tests
+		kubeConfig = &rest.Config{
+			Host: "https://mock-server",
+		}
+	})
+
+	Describe("NewKubernetesClient", func() {
+		It("should return a Kubernetes client interface when called with a valid config", func() {
+			client, err := driver.NewKubernetesClient(kubeConfig)
+			Expect(err).To(BeNil())
+			Expect(client).NotTo(BeNil())
+			_, ok := client.(*kubernetes.Clientset)
+			Expect(ok).To(BeTrue())
+		})
+	})
+
+	Describe("NewBucketClient", func() {
+		It("should return a Bucket client interface when called with a valid config", func() {
+			client, err := driver.NewBucketClient(kubeConfig)
+			Expect(err).To(BeNil())
+			Expect(client).NotTo(BeNil())
+			_, ok := client.(*bucketclientset.Clientset)
+			Expect(ok).To(BeTrue())
+		})
+	})
+})
+
 var _ = Describe("ProvisionerServer InitProvisionerServer", func() {
 	var (
 		provisioner string