fix: add ckafka sweeper (#1049)

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

Author: tongyiming

tencentcloud/data_source_tc_ckafka_topics_test.go

@@ -31,7 +31,6 @@ func TestAccTencentCloudCkafkaTopicDataSource(t *testing.T) {
 					resource.TestCheckResourceAttrSet("data.tencentcloud_ckafka_topics.kafka_topics", "instance_list.0.unclean_leader_election_enable"),
 					resource.TestCheckResourceAttr("data.tencentcloud_ckafka_topics.kafka_topics", "instance_list.0.segment", "86400000"),
 					resource.TestCheckResourceAttr("data.tencentcloud_ckafka_topics.kafka_topics", "instance_list.0.retention", "60000"),
-					resource.TestCheckResourceAttr("data.tencentcloud_ckafka_topics.foo", "instance_list.#", "1"),
 					resource.TestCheckResourceAttrSet("data.tencentcloud_ckafka_topics.foo", "instance_list.0.partition_num"),
 					resource.TestCheckResourceAttrSet("data.tencentcloud_ckafka_topics.foo", "instance_list.0.replica_num"),
 					resource.TestCheckResourceAttrSet("data.tencentcloud_ckafka_topics.foo", "instance_list.0.create_time"),

tencentcloud/resource_tc_ckafka_user_test.go

@@ -3,12 +3,58 @@ package tencentcloud
 import (
 	"context"
 	"fmt"
+	"strings"
 	"testing"
+	"time"
 
 	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
 	"github.com/hashicorp/terraform-plugin-sdk/terraform"
 )
 
+func init() {
+	// go test -v ./tencentcloud -sweep=ap-guangzhou -sweep-run=tencentcloud_kafka
+	resource.AddTestSweepers("tencentcloud_kafka", &resource.Sweeper{
+		Name: "tencentcloud_kafka",
+		F: func(r string) error {
+			logId := getLogId(contextNil)
+			ctx := context.WithValue(context.TODO(), logIdKey, logId)
+			sharedClient, err := sharedClientForRegion(r)
+			if err != nil {
+				return fmt.Errorf("getting tencentcloud client error: %s", err.Error())
+			}
+			client := sharedClient.(*TencentCloudClient)
+
+			ckafkaService := CkafkaService{client: client.apiV3Conn}
+			params := make(map[string]interface{})
+			params["instance_id"] = defaultKafkaInstanceId
+			userInfos, err := ckafkaService.DescribeUserByFilter(ctx, params)
+			if err != nil {
+				return nil
+			}
+			for _, userInfo := range userInfos {
+				userName := *userInfo.Name
+				now := time.Now()
+				createTime := stringTotime(*userInfo.CreateTime)
+				interval := now.Sub(createTime).Minutes()
+				// less than 30 minute, not delete
+				if needProtect == 1 && int64(interval) < 30 {
+					continue
+				}
+
+				if strings.HasPrefix(userName, keepResource) || strings.HasPrefix(userName, defaultResource) {
+					continue
+				}
+				userIdStr := fmt.Sprintf("%v#%v", defaultKafkaInstanceId, userName)
+				err := ckafkaService.DeleteUser(ctx, userIdStr)
+				if err != nil {
+					return nil
+				}
+			}
+			return nil
+		},
+	})
+}
+
 func TestAccTencentCloudCkafkaUser(t *testing.T) {
 	t.Parallel()
 	resource.Test(t, resource.TestCase{