Feat/tcm support (#1328)

* feat: support tcm

* feat: support tcm

* feat: add tcm unit

* fix: update unit

* fix: update unit

* fix: support tcm

* feat: add changelog

* fix: update basic test

* fix: query empty handling

Co-authored-by: arunma <arunma@tencent.com>

Author: gitmkn

.changelog/1328.txt

@@ -0,0 +1,4 @@
+```release-note:enhancement
+resource/tencentcloud_tcm_mesh: support service mash creating/updating
+resource/tencentcloud_tcm_cluster_attachment: support for service mesh binding/unbinding of clusters
+```

go.mod

@@ -58,6 +58,7 @@ require (
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/sts v1.0.199
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tag v1.0.199
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tcaplusdb v1.0.199
+	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tcm v1.0.519
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tcr v1.0.503
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tdmq v1.0.268
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tem v1.0.472

go.sum

@@ -744,3 +744,14 @@ const (
 )
 
 // End of TEO
+
+// TCM
+
+const (
+	defaultMeshClusterId = "cls-9ae9qo9k"
+	defaultMeshId        = "mesh-rofjmux7"
+	defaultMeshVpcId     = "vpc-pyyv5k3v"
+	defaultMeshSubnetId  = "subnet-06i8auk6"
+)
+
+// End of TCM

tencentcloud/basic_test.go

@@ -8,6 +8,8 @@ import (
 	"strconv"
 	"time"
 
+	tcm "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tcm/v20210413"
+
 	"github.com/tencentyun/cos-go-sdk-v5"
 
 	"github.com/aws/aws-sdk-go/aws"
@@ -121,6 +123,7 @@ type TencentCloudClient struct {
 	lighthouseConn     *lighthouse.Client
 	temConn            *tem.Client
 	teoConn            *teo.Client
+	tcmConn            *tcm.Client
 }
 
 // NewClientProfile returns a new ClientProfile
@@ -761,6 +764,19 @@ func (me *TencentCloudClient) UseTeoClient() *teo.Client {
 	return me.teoConn
 }
 
+// UseTcmClient returns teo client for service
+func (me *TencentCloudClient) UseTcmClient() *tcm.Client {
+	if me.tcmConn != nil {
+		return me.tcmConn
+	}
+
+	cpf := me.NewClientProfile(300)
+	me.tcmConn, _ = tcm.NewClient(me.Credential, me.Region, cpf)
+	me.tcmConn.WithHttpTransport(&LogRoundTripper{})
+
+	return me.tcmConn
+}
+
 func getEnvDefault(key string, defVal int) int {
 	val, ex := os.LookupEnv(key)
 	if !ex {

tencentcloud/connectivity/client.go

@@ -693,6 +693,12 @@ TencentCloud EdgeOne(TEO)
 	tencentcloud_teo_ddos_policy
 	tencentcloud_teo_security_policy
 	tencentcloud_teo_custom_error_page
+
+TencentCloud ServiceMesh(TCM)
+  Resource
+	tencentcloud_tcm_mesh
+	tencentcloud_tcm_cluster_attachment
+
 */
 package tencentcloud
 
@@ -1251,6 +1257,8 @@ func Provider() terraform.ResourceProvider {
 			"tencentcloud_teo_custom_error_page":                    resourceTencentCloudTeoCustomErrorPage(),
 			// "tencentcloud_teo_host_certificate":                     resourceTencentCloudTeoHostCertificate(),
 			// "tencentcloud_teo_default_certificate":                  resourceTencentCloudTeoDefaultCertificate(),
+			"tencentcloud_tcm_mesh":               resourceTencentCloudTcmMesh(),
+			"tencentcloud_tcm_cluster_attachment": resourceTencentCloudTcmClusterAttachment(),
 		},
 
 		ConfigureFunc: providerConfigure,

tencentcloud/provider.go

@@ -0,0 +1,307 @@
+/*
+Provides a resource to create a tcm cluster_attachment
+
+Example Usage
+
+```hcl
+resource "tencentcloud_tcm_cluster_attachment" "cluster_attachment" {
+  mesh_id = "mesh-b9q6vf9l"
+  cluster_list {
+    cluster_id = "cls-rc5uy6dy"
+    region = "ap-guangzhou"
+    role = "REMOTE"
+    vpc_id = "vpc-a1jycmbx"
+    subnet_id = "subnet-lkyb3ayc"
+    type = "TKE"
+  }
+}
+
+```
+Import
+
+tcm cluster_attachment can be imported using the mesh_id#cluster_id, e.g.
+```
+$ terraform import tencentcloud_tcm_cluster_attachment.cluster_attachment mesh-b9q6vf9l#cls-rc5uy6dy
+```
+*/
+package tencentcloud
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"strings"
+
+	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
+	tcm "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tcm/v20210413"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func resourceTencentCloudTcmClusterAttachment() *schema.Resource {
+	return &schema.Resource{
+		Read:   resourceTencentCloudTcmClusterAttachmentRead,
+		Create: resourceTencentCloudTcmClusterAttachmentCreate,
+		Delete: resourceTencentCloudTcmClusterAttachmentDelete,
+		Importer: &schema.ResourceImporter{
+			State: schema.ImportStatePassthrough,
+		},
+		Schema: map[string]*schema.Schema{
+			"mesh_id": {
+				Type:        schema.TypeString,
+				Required:    true,
+				ForceNew:    true,
+				Description: "Mesh ID.",
+			},
+
+			"cluster_list": {
+				Type:        schema.TypeList,
+				Optional:    true,
+				ForceNew:    true,
+				Description: "Cluster list.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"cluster_id": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "TKE Cluster id.",
+						},
+						"region": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "TKE cluster region.",
+						},
+						"role": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Cluster role in mesh, REMOTE or MASTER.",
+						},
+						"vpc_id": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Cluster's VpcId.",
+						},
+						"subnet_id": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Subnet id, only needed if it's standalone mesh.",
+						},
+						"type": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Cluster type.",
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
+func resourceTencentCloudTcmClusterAttachmentCreate(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_tcm_cluster_attachment.create")()
+	defer inconsistentCheck(d, meta)()
+
+	var (
+		logId     = getLogId(contextNil)
+		ctx       = context.WithValue(context.TODO(), logIdKey, logId)
+		request   = tcm.NewLinkClusterListRequest()
+		meshId    string
+		clusterId string
+	)
+
+	if v, ok := d.GetOk("mesh_id"); ok {
+		meshId = v.(string)
+		request.MeshId = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("cluster_list"); ok {
+		for _, item := range v.([]interface{}) {
+			dMap := item.(map[string]interface{})
+			cluster := tcm.Cluster{}
+			if v, ok := dMap["cluster_id"]; ok {
+				clusterId = v.(string)
+				cluster.ClusterId = helper.String(v.(string))
+			}
+			if v, ok := dMap["region"]; ok {
+				cluster.Region = helper.String(v.(string))
+			}
+			if v, ok := dMap["role"]; ok {
+				cluster.Role = helper.String(v.(string))
+			}
+			if v, ok := dMap["vpc_id"]; ok {
+				cluster.VpcId = helper.String(v.(string))
+			}
+			if v, ok := dMap["subnet_id"]; ok {
+				cluster.SubnetId = helper.String(v.(string))
+			}
+			if v, ok := dMap["type"]; ok {
+				cluster.Type = helper.String(v.(string))
+			}
+
+			request.ClusterList = append(request.ClusterList, &cluster)
+		}
+	}
+
+	err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+		result, e := meta.(*TencentCloudClient).apiV3Conn.UseTcmClient().LinkClusterList(request)
+		if e != nil {
+			return retryError(e)
+		} else {
+			log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n",
+				logId, request.GetAction(), request.ToJsonString(), result.ToJsonString())
+		}
+		return nil
+	})
+
+	if err != nil {
+		log.Printf("[CRITAL]%s create tcm clusterAttachment failed, reason:%+v", logId, err)
+		return err
+	}
+
+	service := TcmService{client: meta.(*TencentCloudClient).apiV3Conn}
+	err = resource.Retry(3*readRetryTimeout, func() *resource.RetryError {
+		mesh, errRet := service.DescribeTcmMesh(ctx, meshId)
+		if errRet != nil {
+			return retryError(errRet, InternalError)
+		}
+		clusterList := mesh.Mesh.ClusterList
+		if len(clusterList) < 1 {
+			return resource.RetryableError(fmt.Errorf("link is being created, retry..."))
+		}
+		var linkState string
+		for _, v := range clusterList {
+			if *v.ClusterId != clusterId {
+				continue
+			}
+			linkState = *v.Status.LinkState
+			if linkState == "LINKED" {
+				return nil
+			}
+			if linkState == "LINK_FAILED" {
+				return resource.NonRetryableError(fmt.Errorf("link status is %v, operate failed.", linkState))
+			}
+		}
+		return resource.RetryableError(fmt.Errorf("link status is %v, retry...", linkState))
+	})
+	if err != nil {
+		return err
+	}
+
+	d.SetId(strings.Join([]string{meshId, clusterId}, FILED_SP))
+	return resourceTencentCloudTcmClusterAttachmentRead(d, meta)
+}
+
+func resourceTencentCloudTcmClusterAttachmentRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_tcm_cluster_attachment.read")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	service := TcmService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+	ids := strings.Split(d.Id(), FILED_SP)
+	if len(ids) != 2 {
+		return fmt.Errorf("id is broken, id is %s", d.Id())
+	}
+
+	meshId := ids[0]
+	clusterId := ids[1]
+
+	mesh, err := service.DescribeTcmMesh(ctx, meshId)
+
+	if err != nil {
+		return err
+	}
+
+	if mesh == nil || mesh.Mesh == nil || len(mesh.Mesh.ClusterList) < 1 {
+		d.SetId("")
+		return fmt.Errorf("resource `clusterAttachment` %s does not exist", meshId)
+	}
+
+	_ = d.Set("mesh_id", meshId)
+
+	if len(mesh.Mesh.ClusterList) > 0 {
+		clusterAttachment := mesh.Mesh
+		clusterListList := []interface{}{}
+		for _, clusterList := range clusterAttachment.ClusterList {
+			if *clusterList.ClusterId != clusterId {
+				continue
+			}
+			clusterListMap := map[string]interface{}{}
+			if clusterList.ClusterId != nil {
+				clusterListMap["cluster_id"] = clusterList.ClusterId
+			}
+			if clusterList.Region != nil {
+				clusterListMap["region"] = clusterList.Region
+			}
+			if clusterList.Role != nil {
+				clusterListMap["role"] = clusterList.Role
+			}
+			if clusterList.VpcId != nil {
+				clusterListMap["vpc_id"] = clusterList.VpcId
+			}
+			if clusterList.SubnetId != nil {
+				clusterListMap["subnet_id"] = clusterList.SubnetId
+			}
+			if clusterList.Type != nil {
+				clusterListMap["type"] = clusterList.Type
+			}
+
+			clusterListList = append(clusterListList, clusterListMap)
+		}
+		_ = d.Set("cluster_list", clusterListList)
+	}
+
+	return nil
+}
+
+func resourceTencentCloudTcmClusterAttachmentDelete(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_tcm_cluster_attachment.delete")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	service := TcmService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+	ids := strings.Split(d.Id(), FILED_SP)
+	if len(ids) != 2 {
+		return fmt.Errorf("id is broken, id is %s", d.Id())
+	}
+
+	meshId := ids[0]
+	clusterId := ids[1]
+
+	if err := service.DeleteTcmClusterAttachmentById(ctx, meshId, clusterId); err != nil {
+		return err
+	}
+
+	err := resource.Retry(3*readRetryTimeout, func() *resource.RetryError {
+		mesh, errRet := service.DescribeTcmMesh(ctx, meshId)
+		if errRet != nil {
+			return retryError(errRet, InternalError)
+		}
+		clusterList := mesh.Mesh.ClusterList
+		if len(clusterList) < 1 {
+			return nil
+		}
+		var linkState string
+		for _, v := range clusterList {
+			if *v.ClusterId != clusterId {
+				continue
+			}
+			linkState = *v.Status.LinkState
+			if linkState == "UNLINK_FAILED" {
+				return resource.NonRetryableError(fmt.Errorf("link status is %v, operate failed.", linkState))
+			}
+		}
+		return resource.RetryableError(fmt.Errorf("link status is %v, retry...", linkState))
+	})
+	if err != nil {
+		return err
+	}
+
+	return nil
+}