wip

Author: dak1n1

kubernetes/provider_test.go

@@ -450,65 +450,109 @@ var testAccProviderFactoriesInternal = map[string]func() (*schema.Provider, erro
 	},
 }
 
-func TestAccAKubernetesProvider_config_path(t *testing.T) {
+func TestAccKubernetesProvider_config_path(t *testing.T) {
 
-	resource.ParallelTest(t, resource.TestCase{
-		PreCheck: func() { testAccPreCheck(t); skipIfNotRunningInMinikube(t) },
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t); skipIfNotRunningInMinikube(t); unsetEnv(t) },
 		ProviderFactories: testAccProviderFactoriesInternal,
 		Steps: []resource.TestStep{
 			{
-				Config: testAccKubernetesProvider_config_path(),
-				Check: resource.ComposeTestCheckFunc(
-					resource.TestCheckResourceAttr("data.kubernetes_namespace.test", "metadata.0.name", "default"),
+				Config: testAccKubernetesProviderConfig(
+					providerConfig_config_path("~/.kube/config"),
 				),
+				Check: resource.TestCheckResourceAttr("data.kubernetes_namespace.test", "metadata.0.name", "default"),
 			},
 		},
 	})
 }
 
-func TestAccAKubernetesProvider_config_paths(t *testing.T) {
+func TestAccKubernetesProvider_config_paths(t *testing.T) {
 	wantError := `"config_path": conflicts with config_paths`
 
-	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:          func() { testAccPreCheck(t); skipIfNotRunningInMinikube(t) },
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { skipIfNotRunningInMinikube(t); unsetEnv(t) },
 		ProviderFactories: testAccProviderFactoriesInternal,
 		Steps: []resource.TestStep{
 			{
-				Config:      testAccKubernetesProvider_config_paths(),
+				Config: testAccKubernetesProviderConfig(
+					providerConfig_config_paths([]string{"~/.kube/config", "~/.kube/config2"}),
+				),
+				Check: resource.TestCheckResourceAttr("data.kubernetes_namespace.test", "metadata.0.name", "default"),
+			},
+			{
+				Config: testAccKubernetesProviderConfig(
+					providerConfig_config_path("~/.kube/config") +
+						providerConfig_config_paths([]string{"~/.kube/config", "~/.kube/config2"}),
+				),
 				ExpectError: regexp.MustCompile(wantError),
 			},
 		},
 	})
 }
 
-func testAccKubernetesProvider_config_path() string {
+// testAccKubernetesProviderConfig is used together with the providerConfig_* functions
+// to assemble a Kubernetes provider configuration with interchangeable options.
+func testAccKubernetesProviderConfig(providerConfig string) string {
 	return fmt.Sprintf(`provider "kubernetes" {
-  config_path = "~/.kube/config"
+  %s
 }
 
-# Required to initialize the provider.
 data kubernetes_namespace "test" {
   metadata {
     name = "default"
   }
 }
-`)
+`, providerConfig)
 }
 
-func testAccKubernetesProvider_config_paths() string {
-	return fmt.Sprintf(`provider "kubernetes" {
-  config_path = "~/.kube/config"
-  config_paths = ["~/.kube/config"]
-#  host = "https://192.168.39.129:8443"
-#  cluster_ca_certificate = file("~/.minikube/profiles/minikube/apiserver.crt")
-#  token = base64decode(file("~/.minikube/profiles/minikube/token"))
+func providerConfig_config_path(path string) string {
+	return fmt.Sprintf(`
+  config_path = "%s"
+`, path)
 }
 
-# Required to initialize the provider.
-data kubernetes_namespace "test" {
-  metadata {
-    name = "default"
-  }
+func providerConfig_config_paths(paths []string) string {
+	return fmt.Sprintf(`
+  config_paths = [%q]
+`, strings.Join(paths, ", "))
 }
-`)
+
+func testAccKubernetesProviderConfig_token(token string) string {
+	return fmt.Sprintf(`
+  token = %s
+`, token)
+}
+
+func testAccKubernetesProviderConfig_ca_cert(ca_cert string) string {
+	return fmt.Sprintf(`
+  cluster_ca_certificate = %s
+`, ca_cert)
+}
+
+func testAccKubernetesProviderConfig_client_cert(client_cert string) string {
+	return fmt.Sprintf(`
+  client_certificate = %s
+`, client_cert)
+}
+
+func testAccKubernetesProviderConfig_client_key(client_key string) string {
+	return fmt.Sprintf(`
+  client_key = %s
+`, client_key)
+}
+
+func testAccKubernetesProviderConfig_host(host string) string {
+	return fmt.Sprintf(`
+  host = %s
+`, host)
+}
+
+func testAccKubernetesProvider_exec(clusterName string) string {
+	return fmt.Sprintf(`
+  exec {
+    api_version = "client.authentication.k8s.io/v1alpha1"
+    args        = ["eks", "get-token", "--cluster-name", "%s"]
+    command     = "aws"
+  }
+`, clusterName)
 }