fix ssl tests (#987)

Author: hellertang

tencentcloud/resource_tc_ssl_certificate_test.go

@@ -4,7 +4,10 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"log"
+	"strings"
 	"testing"
+	"time"
 
 	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
 
@@ -15,6 +18,58 @@ import (
 	ssl "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ssl/v20191205"
 )
 
+func init() {
+	resource.AddTestSweepers("tencentcloud_ssl_certificate", &resource.Sweeper{
+		Name: "tencentcloud_ssl_certificate",
+		F:    testSweepSslCertificate,
+	})
+}
+
+func testSweepSslCertificate(region string) error {
+	logId := getLogId(contextNil)
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	sharedClient, err := sharedClientForRegion(region)
+	if err != nil {
+		return fmt.Errorf("getting tencentcloud client error: %s", err.Error())
+	}
+	client := sharedClient.(*TencentCloudClient)
+
+	sslService := SSLService{
+		client: client.apiV3Conn,
+	}
+	describeRequest := ssl.NewDescribeCertificatesRequest()
+	instances, err := sslService.DescribeCertificates(ctx, describeRequest)
+	if err != nil {
+		return fmt.Errorf("get instance list error: %s", err.Error())
+	}
+
+	for _, v := range instances {
+
+		instanceId := *v.CertificateId
+		instanceName := *v.Alias
+		now := time.Now()
+		createTime := stringTotime(*v.CertBeginTime)
+		interval := now.Sub(createTime).Minutes()
+
+		if strings.HasPrefix(instanceName, keepResource) || strings.HasPrefix(instanceName, defaultResource) {
+			continue
+		}
+
+		if needProtect == 1 && int64(interval) < 30 {
+			continue
+		}
+
+		request := ssl.NewDeleteCertificateRequest()
+		request.CertificateId = helper.String(instanceId)
+		if _, err = sslService.DeleteCertificate(ctx, request); err != nil {
+			log.Printf("[ERROR] sweep instance %s error: %s", instanceId, err.Error())
+		}
+	}
+
+	return nil
+}
+
 func TestAccTencentCloudSslCertificate_basic(t *testing.T) {
 	t.Parallel()
 	resource.Test(t, resource.TestCase{

tencentcloud/resource_tc_vpn_customer_gateway_test.go

@@ -4,7 +4,9 @@ import (
 	"context"
 	"fmt"
 	"log"
+	"strings"
 	"testing"
+	"time"
 
 	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
 	"github.com/hashicorp/terraform-plugin-sdk/terraform"
@@ -40,10 +42,17 @@ func testSweepVpnCustomerGateway(region string) error {
 
 	for _, v := range instances {
 		customerGwId := *v.CustomerGatewayId
+		customerName := *v.CustomerGatewayName
 
-		//if !strings.HasPrefix(instanceName, defaultInsName) {
-		//	continue
-		//}
+		now := time.Now()
+		createTime := stringTotime(*v.CreatedTime)
+		interval := now.Sub(createTime).Minutes()
+		if strings.HasPrefix(customerName, keepResource) || strings.HasPrefix(customerName, defaultResource) {
+			continue
+		}
+		if needProtect == 1 && int64(interval) < 30 {
+			continue
+		}
 
 		if err = vpcService.DeleteCustomerGateway(ctx, customerGwId); err != nil {
 			log.Printf("[ERROR] sweep instance %s error: %s", customerGwId, err.Error())

tencentcloud/resource_tc_vpn_gateway_test.go

@@ -4,7 +4,9 @@ import (
 	"context"
 	"fmt"
 	"log"
+	"strings"
 	"testing"
+	"time"
 
 	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
 	"github.com/hashicorp/terraform-plugin-sdk/terraform"
@@ -39,13 +41,21 @@ func testSweepVpnGateway(region string) error {
 	}
 
 	for _, v := range instances {
-		//vpnGwName := *v.VpnGatewayName
-
-		//if !strings.HasPrefix(vpnGwName, defaultInsName) {
-		//	continue
-		//}
 
 		vpnGwId := *v.VpnGatewayId
+		vpnName := *v.VpnGatewayName
+		now := time.Now()
+		createTime := stringTotime(*v.CreatedTime)
+		interval := now.Sub(createTime).Minutes()
+
+		if strings.HasPrefix(vpnName, keepResource) || strings.HasPrefix(vpnName, defaultResource) {
+			continue
+		}
+
+		if needProtect == 1 && int64(interval) < 30 {
+			continue
+		}
+
 		if err = vpcService.DeleteVpnGateway(ctx, vpnGwId); err != nil {
 			log.Printf("[ERROR] sweep instance %s error: %s", vpnGwId, err.Error())
 		}