fix: tcaplus_table - add sweeper (#1072)

* fix: tcaplus_table - add sweeper

* fix: tcaplus_table - sweeper add offline recycle step

Author: Kagashino

tencentcloud/resource_tc_tcaplus_idl_test.go

@@ -36,7 +36,7 @@ func TestAccTencentCloudTcaplusIdlResource(t *testing.T) {
 					resource.TestCheckResourceAttrSet(testTcaplusIdlResourceNameResourceKey, "table_infos.0.value_fields"),
 					resource.TestCheckResourceAttrSet(testTcaplusIdlResourceNameResourceKey, "table_infos.0.sum_value_field_size"),
 					resource.TestCheckResourceAttrSet(testTcaplusIdlResourceNameResourceKey, "table_infos.0.index_key_set"),
-					resource.TestCheckResourceAttr(testTcaplusIdlResourceNameResourceKey, "table_infos.0.table_name", "tb_online_guagua"),
+					resource.TestCheckResourceAttr(testTcaplusIdlResourceNameResourceKey, "table_infos.0.table_name", "tb_idle_test"),
 					resource.TestCheckResourceAttr(testTcaplusIdlResourceNameResourceKey, "table_infos.0.error", ""),
 				),
 			},
@@ -112,7 +112,7 @@ resource "tencentcloud_tcaplus_idl" "test_idl" {
     syntax = "proto2";
     package myTcaplusTable;
     import "tcaplusservice.optionv1.proto";
-    message tb_online_guagua {
+    message tb_idle_test {
         option(tcaplusservice.tcaplus_primary_key) = "uin,name,region";
         required int64 uin = 1;
         required string name = 2;

tencentcloud/resource_tc_tcaplus_table_test.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"testing"
+	"time"
 
 	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
 	"github.com/hashicorp/terraform-plugin-sdk/terraform"
@@ -12,6 +13,76 @@ import (
 var testTcaplusTableResourceName = "tencentcloud_tcaplus_table"
 var testTcaplusTableResourceNameResourceKey = testTcaplusTableResourceName + ".test_table"
 
+func init() {
+	// go test -v ./tencentcloud -sweep=ap-guangzhou -sweep-run=tencentcloud_tcaplus_table
+	resource.AddTestSweepers("tencentcloud_tcaplus_table", &resource.Sweeper{
+		Name: "tencentcloud_tcaplus_table",
+		F: func(r string) error {
+			logId := getLogId(contextNil)
+			ctx := context.WithValue(context.TODO(), logIdKey, logId)
+			cli, _ := sharedClientForRegion(r)
+			client := cli.(*TencentCloudClient).apiV3Conn
+			service := TcaplusService{client}
+
+			clusters, err := service.DescribeClusters(ctx, "", defaultTcaPlusClusterName)
+
+			if err != nil {
+				return err
+			}
+
+			if len(clusters) == 0 {
+				return fmt.Errorf("no cluster named %s", defaultTcaPlusClusterName)
+			}
+
+			clusterId := *clusters[0].ClusterId
+
+			tables, err := service.DescribeTables(ctx, clusterId, "", "", "")
+
+			for _, table := range tables {
+				name := *table.TableName
+				// legacy bad argument
+				gId := clusterId + ":" + *table.TableGroupId
+				insId := *table.TableInstanceId
+				created := time.Time{}
+
+				if isResourcePersist(name, &created) {
+					continue
+				}
+
+				taskId, err := service.DeleteTable(ctx, clusterId, gId, insId, name)
+				if err != nil {
+					continue
+				}
+
+				err = resource.Retry(readRetryTimeout*3, func() *resource.RetryError {
+					info, has, err := service.DescribeTask(ctx, clusterId, taskId)
+					if err != nil {
+						return retryError(err)
+					}
+					if !has {
+						return nil
+					}
+					if *info.Progress < 100 {
+						return resource.RetryableError(fmt.Errorf("running delete task %s, table: %s -> %s", taskId, clusterId, name))
+					}
+					return nil
+				})
+
+				if err != nil {
+					continue
+				}
+
+				_, err = service.DeleteTable(ctx, clusterId, gId, insId, name)
+				if err != nil {
+					continue
+				}
+			}
+
+			return nil
+		},
+	})
+}
+
 func TestAccTencentCloudTcaplusTableResource(t *testing.T) {
 	t.Parallel()
 	resource.Test(t, resource.TestCase{