Add MKS kubeconfig data source (#178)

* Add MKS kubeconfig data source

For #145

* Fix due to recommendations

* Use sensitive fields in mks kubeconfig data source

go.mod

@@ -9,6 +9,6 @@ require (
 	github.com/selectel/dbaas-go v0.4.0
 	github.com/selectel/domains-go v0.3.0
 	github.com/selectel/go-selvpcclient v1.12.0
-	github.com/selectel/mks-go v0.8.0
+	github.com/selectel/mks-go v0.9.0
 	github.com/stretchr/testify v1.7.0
 )

go.sum

@@ -289,8 +289,10 @@ github.com/selectel/domains-go v0.3.0 h1:0shjqQmpkWc6eM1SwgKqbTTNiT5G2BOEnvS7Jvu
 github.com/selectel/domains-go v0.3.0/go.mod h1:AhXhwyMSTkpEWFiBLUvzFP76W+WN+ZblwmjLJLt7y58=
 github.com/selectel/go-selvpcclient v1.12.0 h1:LsT074HOVF1dWYapsAWjaaJDQhmDPpcsVjSwQ1r1fj0=
 github.com/selectel/go-selvpcclient v1.12.0/go.mod h1:HNteVXevZMjUCRR6lImTsGZZSTeKu89S/qbEDWDqmgc=
-github.com/selectel/mks-go v0.8.0 h1:tZJ248zZmJEGYZaygqLzboTFml0qxKkRjEAPzVAN0Ro=
-github.com/selectel/mks-go v0.8.0/go.mod h1:OrlLnGes+HK7HNxUab/8Rll5iT0XQQnx4+dW1Ysph2o=
+github.com/selectel/mks-go v0.6.0 h1:5ZlqvwlVrjrrbNygsiFfUGZTyTPzPGGo8aYJkbtrYV0=
+github.com/selectel/mks-go v0.6.0/go.mod h1:OrlLnGes+HK7HNxUab/8Rll5iT0XQQnx4+dW1Ysph2o=
+github.com/selectel/mks-go v0.9.0 h1:j0uvdUkbKtQmNWU5cjadsplPbCggWvTETAUHJQMWawU=
+github.com/selectel/mks-go v0.9.0/go.mod h1:FcFqF3WvZIhztyAt1+ZySKf0zWmCEvg9e2gRwxVyQOw=
 github.com/sergi/go-diff v1.0.0/go.mod h1:0CfEIISq7TuYL3j771MWULgwwjU+GofnZX9QAmXWZgo=
 github.com/sergi/go-diff v1.1.0/go.mod h1:STckp+ISIX8hZLjrqAeVduY0gWCT9IjLuqbuNXdaHfM=
 github.com/sergi/go-diff v1.2.0 h1:XU+rvMAioB0UC3q1MFrIQy4Vo5/4VsRDQQXHsEya6xQ=

selectel/data_source_selectel_mks_kubeconfig_v1.go

@@ -0,0 +1,107 @@
+package selectel
+
+import (
+	"context"
+	"log"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/validation"
+	"github.com/selectel/go-selvpcclient/selvpcclient/resell/v2/tokens"
+	v1 "github.com/selectel/mks-go/pkg/v1"
+	"github.com/selectel/mks-go/pkg/v1/cluster"
+)
+
+func dataSourceMKSKubeconfigV1() *schema.Resource {
+	return &schema.Resource{
+		ReadContext: dataSourceMKSKubeconfigV1Read,
+		Schema: map[string]*schema.Schema{
+			"project_id": {
+				Type:     schema.TypeString,
+				Required: true,
+				ForceNew: true,
+			},
+			"cluster_id": {
+				Type:     schema.TypeString,
+				Required: true,
+				ForceNew: true,
+			},
+			"region": {
+				Type:     schema.TypeString,
+				Required: true,
+				ValidateFunc: validation.StringInSlice([]string{
+					ru1Region,
+					ru2Region,
+					ru3Region,
+					ru7Region,
+					ru8Region,
+					ru9Region,
+				}, false),
+			},
+			"raw_config": {
+				Type:      schema.TypeString,
+				Computed:  true,
+				Sensitive: true,
+			},
+			"server": {
+				Type:      schema.TypeString,
+				Computed:  true,
+				Sensitive: true,
+			},
+			"cluster_ca_cert": {
+				Type:      schema.TypeString,
+				Computed:  true,
+				Sensitive: true,
+			},
+			"client_cert": {
+				Type:      schema.TypeString,
+				Computed:  true,
+				Sensitive: true,
+			},
+			"client_key": {
+				Type:      schema.TypeString,
+				Computed:  true,
+				Sensitive: true,
+			},
+		},
+	}
+}
+
+func dataSourceMKSKubeconfigV1Read(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
+	config := meta.(*Config)
+	resellV2Client := config.resellV2Client()
+	tokenOpts := tokens.TokenOpts{
+		ProjectID: d.Get("project_id").(string),
+	}
+
+	log.Print(msgCreate(objectToken, tokenOpts))
+	token, _, err := tokens.Create(ctx, resellV2Client, tokenOpts)
+	if err != nil {
+		return diag.FromErr(errCreatingObject(objectToken, err))
+	}
+
+	region := d.Get("region").(string)
+	endpoint := getMKSClusterV1Endpoint(region)
+	mksClient := v1.NewMKSClientV1(token.ID, endpoint)
+
+	clusterID := d.Get("cluster_id").(string)
+
+	mksCluster, _, err := cluster.Get(ctx, mksClient, clusterID)
+	if err != nil {
+		return diag.FromErr(errGettingObject(objectCluster, clusterID, err))
+	}
+
+	parsedKubeconfig, _, err := cluster.GetParsedKubeconfig(ctx, mksClient, mksCluster.ID)
+	if err != nil {
+		return diag.FromErr(errGettingObject(objectKubeConfig, clusterID, err))
+	}
+
+	d.SetId(clusterID)
+	d.Set("raw_config", parsedKubeconfig.KubeconfigRaw)
+	d.Set("server", parsedKubeconfig.Server)
+	d.Set("cluster_ca_cert", parsedKubeconfig.ClusterCA)
+	d.Set("client_cert", parsedKubeconfig.ClientCert)
+	d.Set("client_key", parsedKubeconfig.ClientKey)
+
+	return nil
+}

selectel/data_source_selectel_mks_kubeconfig_v1_test.go

@@ -0,0 +1,72 @@
+package selectel
+
+import (
+	"errors"
+	"fmt"
+	"testing"
+	"time"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/acctest"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/terraform"
+)
+
+func TestAccMKSKubeconfigV1DataSourceBasic(t *testing.T) {
+	projectName := acctest.RandomWithPrefix("tf-acc")
+	clusterName := acctest.RandomWithPrefix("tf-acc-cl")
+	kubeVersion := testAccMKSClusterV1GetDefaultKubeVersion(t)
+	maintenanceWindowStart := testAccMKSClusterV1GetMaintenanceWindowStart(12 * time.Hour)
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { testAccSelectelPreCheck(t) },
+		ProviderFactories: testAccProviders,
+		CheckDestroy:      testAccCheckVPCV2ProjectDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccMKSKubeconfigV1Basic(projectName, clusterName, kubeVersion, maintenanceWindowStart),
+				Check: resource.ComposeTestCheckFunc(
+					testAccCheckMKSKubeconfigV1("data.selectel_mks_kubeconfig_v1.kubeconfig_tf_acc_test_1"),
+				),
+			},
+		},
+	})
+}
+
+func testAccCheckMKSKubeconfigV1(name string) resource.TestCheckFunc {
+	return func(s *terraform.State) error {
+		rs, ok := s.RootModule().Resources[name]
+		if !ok {
+			return fmt.Errorf("can't find kubeconfig data source: %s", name)
+		}
+
+		if _, ok = rs.Primary.Attributes["raw_config"]; !ok {
+			return errors.New("empty 'raw_config' field in kubeconfigs data source")
+		}
+		if _, ok = rs.Primary.Attributes["server"]; !ok {
+			return errors.New("empty 'server' field in kubeconfigs data source")
+		}
+		if _, ok = rs.Primary.Attributes["cluster_ca_cert"]; !ok {
+			return errors.New("empty 'cluster_ca_cert' field in kubeconfigs data source")
+		}
+		if _, ok = rs.Primary.Attributes["client_cert"]; !ok {
+			return errors.New("empty 'client_cert' field in kubeconfigs data source")
+		}
+		if _, ok = rs.Primary.Attributes["client_key"]; !ok {
+			return errors.New("empty 'client_key' field in kubeconfigs data source")
+		}
+
+		return nil
+	}
+}
+
+func testAccMKSKubeconfigV1Basic(projectName, clusterName, kubeVersion, maintenanceWindowStart string) string {
+	return fmt.Sprintf(`
+%s
+
+data "selectel_mks_kubeconfig_v1" "kubeconfig_tf_acc_test_1" {
+  cluster_id    = "${selectel_mks_cluster_v1.cluster_tf_acc_test_1.id}"
+  project_id    = "${selectel_vpc_project_v2.project_tf_acc_test_1.id}"
+  region        = "ru-3"
+}
+`, testAccMKSClusterV1Basic(projectName, clusterName, kubeVersion, maintenanceWindowStart))
+}

selectel/provider.go

@@ -20,6 +20,7 @@ const (
 	objectUser                    = "user"
 	objectVRRPSubnet              = "VRRP subnet"
 	objectCluster                 = "cluster"
+	objectKubeConfig              = "kubeconfig"
 	objectNodegroup               = "nodegroup"
 	objectDomain                  = "domain"
 	objectRecord                  = "record"
@@ -75,6 +76,7 @@ func Provider() *schema.Provider {
 			"selectel_dbaas_flavor_v1":                  dataSourceDBaaSFlavorV1(),
 			"selectel_dbaas_configuration_parameter_v1": dataSourceDBaaSConfigurationParameterV1(),
 			"selectel_dbaas_prometheus_metric_token_v1": dataSourceDBaaSPrometheusMetricTokenV1(),
+			"selectel_mks_kubeconfig_v1":                dataSourceMKSKubeconfigV1(),
 			"selectel_mks_feature_gates_v1":             dataSourceMKSFeatureGatesV1(),
 			"selectel_mks_admission_controllers_v1":     dataSourceMKSAdmissionControllersV1(),
 		},