Feat: add Support for K8s Credentials (#847)

* Feat: add Support for K8s Credentials

* add azure aks

* added gcp gke

* add update operation

client/api_client.go

@@ -151,6 +151,7 @@ type ApiClientInterface interface {
 	TeamRoleAssignmentDelete(payload *TeamRoleAssignmentDeletePayload) error
 	TeamRoleAssignments(payload *TeamRoleAssignmentListPayload) ([]TeamRoleAssignmentPayload, error)
 	KubernetesCredentialsCreate(payload *KubernetesCredentialsCreatePayload) (*Credentials, error)
+	KubernetesCredentialsUpdate(id string, payload *KubernetesCredentialsUpdatePayload) (*Credentials, error)
 }
 
 func NewApiClient(client http.HttpClientInterface, defaultOrganizationId string) ApiClientInterface {

client/kubernetes_credentials.go

@@ -15,6 +15,11 @@ type KubernetesCredentialsCreatePayload struct {
 	Value interface{}               `json:"value"`
 }
 
+type KubernetesCredentialsUpdatePayload struct {
+	Type  KubernetesCrednetialsType `json:"type"`
+	Value interface{}               `json:"value"`
+}
+
 // K8S_KUBECONFIG_FILE
 type KubeconfigFileValue struct {
 	KubeConfig string `json:"kubeConfig"`
@@ -63,3 +68,12 @@ func (client *ApiClient) KubernetesCredentialsCreate(payload *KubernetesCredenti
 
 	return &result, nil
 }
+
+func (client *ApiClient) KubernetesCredentialsUpdate(id string, payload *KubernetesCredentialsUpdatePayload) (*Credentials, error) {
+	var result Credentials
+	if err := client.http.Patch("/credentials/"+id, payload, &result); err != nil {
+		return nil, err
+	}
+
+	return &result, nil
+}

client/kubernetes_credentials_test.go

@@ -10,12 +10,16 @@ import (
 var _ = Describe("Kubernetes Credentials", func() {
 	var credentials *Credentials
 
-	Describe("KubernetesCredentialsCreate", func() {
-		value := AzureAksValue{
-			ClusterName:   "cc11",
-			ResourceGroup: "rg11",
-		}
+	mockCredentials := Credentials{
+		Id: "id111",
+	}
 
+	value := AzureAksValue{
+		ClusterName:   "cc11",
+		ResourceGroup: "rg11",
+	}
+
+	Describe("KubernetesCredentialsCreate", func() {
 		createPayload := KubernetesCredentialsCreatePayload{
 			Name:  "n1",
 			Type:  "K8S_AZURE_AKS_AUTH",
@@ -34,10 +38,6 @@ var _ = Describe("Kubernetes Credentials", func() {
 			Value:          createPayload.Value,
 		}
 
-		mockCredentials := Credentials{
-			Id: "id111",
-		}
-
 		BeforeEach(func() {
 			mockOrganizationIdCall(organizationId)
 
@@ -62,4 +62,29 @@ var _ = Describe("Kubernetes Credentials", func() {
 			Expect(credentials).To(Equal(&mockCredentials))
 		})
 	})
+
+	Describe("KubernetesCredentialsUpdate", func() {
+		updatePayload := KubernetesCredentialsUpdatePayload{
+			Type:  "K8S_AZURE_AKS_AUTH",
+			Value: value,
+		}
+
+		BeforeEach(func() {
+			httpCall = mockHttpClient.EXPECT().
+				Patch("/credentials/"+mockCredentials.Id, &updatePayload, gomock.Any()).
+				Do(func(path string, request interface{}, response *Credentials) {
+					*response = mockCredentials
+				})
+
+			credentials, _ = apiClient.KubernetesCredentialsUpdate(mockCredentials.Id, &updatePayload)
+		})
+
+		It("Should send PATCH request with params", func() {
+			httpCall.Times(1)
+		})
+
+		It("Should return key", func() {
+			Expect(credentials).To(Equal(&mockCredentials))
+		})
+	})
 })

env0/provider.go

@@ -149,6 +149,9 @@ func Provider(version string) plugin.ProviderFunc {
 				"env0_project_budget":                       resourceProjectBudget(),
 				"env0_environment_discovery_configuration":  resourceEnvironmentDiscoveryConfiguration(),
 				"env0_kubeconfig_credentials":               resourceKubeconfigCredentials(),
+				"env0_aws_eks_credentials":                  resourceAwsEksCredentials(),
+				"env0_azure_aks_credentials":                resourceAzureAksCredentials(),
+				"env0_gcp_gke_credentials":                  resourceGcpGkeCredentials(),
 			},
 		}
 

env0/resource_aws_eks_credentials.go

@@ -0,0 +1,83 @@
+package env0
+
+import (
+	"context"
+
+	"github.com/env0/terraform-provider-env0/client"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+)
+
+func resourceAwsEksCredentials() *schema.Resource {
+	return &schema.Resource{
+		CreateContext: resourceAwsEksCredentialsCreate,
+		UpdateContext: resourceAwsEksCredentialsUpdate,
+		ReadContext:   resourceCredentialsRead(AWS_EKS_TYPE),
+		DeleteContext: resourceCredentialsDelete,
+
+		Importer: &schema.ResourceImporter{StateContext: resourceCredentialsImport(AWS_EKS_TYPE)},
+
+		Schema: map[string]*schema.Schema{
+			"name": {
+				Type:        schema.TypeString,
+				Description: "name for the credentials",
+				Required:    true,
+				ForceNew:    true,
+			},
+			"cluster_name": {
+				Type:        schema.TypeString,
+				Description: "eks cluster name",
+				Required:    true,
+			},
+			"cluster_region": {
+				Type:        schema.TypeString,
+				Description: "the AWS region of the eks cluster",
+				Required:    true,
+			},
+		},
+	}
+}
+
+func resourceAwsEksCredentialsCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
+	value := client.AwsEksValue{}
+	if err := readResourceData(&value, d); err != nil {
+		return diag.Errorf("schema resource data deserialization failed: %v", err)
+	}
+
+	apiClient := meta.(client.ApiClientInterface)
+
+	request := client.KubernetesCredentialsCreatePayload{
+		Name:  d.Get("name").(string),
+		Value: value,
+		Type:  client.AwsEksCredentialsType,
+	}
+
+	credentials, err := apiClient.KubernetesCredentialsCreate(&request)
+	if err != nil {
+		return diag.Errorf("could not create credentials: %v", err)
+	}
+
+	d.SetId(credentials.Id)
+
+	return nil
+}
+
+func resourceAwsEksCredentialsUpdate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
+	value := client.AwsEksValue{}
+	if err := readResourceData(&value, d); err != nil {
+		return diag.Errorf("schema resource data deserialization failed: %v", err)
+	}
+
+	apiClient := meta.(client.ApiClientInterface)
+
+	request := client.KubernetesCredentialsUpdatePayload{
+		Value: value,
+		Type:  client.AwsEksCredentialsType,
+	}
+
+	if _, err := apiClient.KubernetesCredentialsUpdate(d.Id(), &request); err != nil {
+		return diag.Errorf("could not create credentials: %v", err)
+	}
+
+	return nil
+}