add vpc resource (#1880)

* add vpc resource

* add changelog

Author: hellertang

.changelog/1880.txt

@@ -0,0 +1,7 @@
+```release-note:new-data-source
+tencentcloud_vpn_default_health_check_ip
+```
+
+```release-note:new-resource
+tencentcloud_ccn_instances_reject_attach
+```

tencentcloud/data_source_tc_vpn_default_health_check_ip.go

@@ -0,0 +1,105 @@
+/*
+Use this data source to query detailed information of vpn default_health_check_ip
+
+Example Usage
+
+```hcl
+data "tencentcloud_vpn_default_health_check_ip" "default_health_check_ip" {
+  vpn_gateway_id = "vpngw-gt8bianl"
+}
+```
+*/
+package tencentcloud
+
+import (
+	"context"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	vpc "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/vpc/v20170312"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func dataSourceTencentCloudVpnDefaultHealthCheckIp() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceTencentCloudVpnDefaultHealthCheckIpRead,
+		Schema: map[string]*schema.Schema{
+			"vpn_gateway_id": {
+				Required:    true,
+				Type:        schema.TypeString,
+				Description: "vpn gateway id.",
+			},
+
+			"health_check_local_ip": {
+				Computed:    true,
+				Type:        schema.TypeString,
+				Description: "local ip of health check.",
+			},
+
+			"health_check_remote_ip": {
+				Computed:    true,
+				Type:        schema.TypeString,
+				Description: "remote ip for health check.",
+			},
+
+			"result_output_file": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Used to save results.",
+			},
+		},
+	}
+}
+
+func dataSourceTencentCloudVpnDefaultHealthCheckIpRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("data_source.tencentcloud_vpn_default_health_check_ip.read")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	var vpnGwId string
+	res := make(map[string]interface{})
+
+	paramMap := make(map[string]interface{})
+	if v, ok := d.GetOk("vpn_gateway_id"); ok {
+		vpnGwId = v.(string)
+		paramMap["VpnGatewayId"] = helper.String(v.(string))
+	}
+
+	service := VpcService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+	var defaultHealthCheck *vpc.GenerateVpnConnectionDefaultHealthCheckIpResponseParams
+
+	err := resource.Retry(readRetryTimeout, func() *resource.RetryError {
+		result, e := service.DescribeVpnDefaultHealthCheckIp(ctx, paramMap)
+		if e != nil {
+			return retryError(e)
+		}
+		defaultHealthCheck = result
+		return nil
+	})
+	if err != nil {
+		return err
+	}
+
+	if defaultHealthCheck.HealthCheckLocalIp != nil {
+		_ = d.Set("health_check_local_ip", defaultHealthCheck.HealthCheckLocalIp)
+		res["health_check_local_ip"] = defaultHealthCheck.HealthCheckLocalIp
+	}
+
+	if defaultHealthCheck.HealthCheckRemoteIp != nil {
+		_ = d.Set("health_check_remote_ip", defaultHealthCheck.HealthCheckRemoteIp)
+		res["health_check_remote_ip"] = defaultHealthCheck.HealthCheckRemoteIp
+	}
+
+	d.SetId(vpnGwId)
+	output, ok := d.GetOk("result_output_file")
+	if ok && output.(string) != "" {
+		if e := writeToFile(output.(string), res); e != nil {
+			return e
+		}
+	}
+	return nil
+}

tencentcloud/data_source_tc_vpn_default_health_check_ip_test.go

@@ -0,0 +1,31 @@
+package tencentcloud
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+func TestAccTencentCloudVpnDefaultHealthCheckIpDataSource_basic(t *testing.T) {
+	t.Parallel()
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			testAccPreCheck(t)
+		},
+		Providers: testAccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccVpnDefaultHealthCheckIpDataSource,
+				Check:  resource.ComposeTestCheckFunc(testAccCheckTencentCloudDataSourceID("data.tencentcloud_vpn_default_health_check_ip.default_health_check_ip")),
+			},
+		},
+	})
+}
+
+const testAccVpnDefaultHealthCheckIpDataSource = `
+
+data "tencentcloud_vpn_default_health_check_ip" "default_health_check_ip" {
+  vpn_gateway_id = "vpngw-gt8bianl"
+}
+
+`

tencentcloud/provider.go

@@ -247,6 +247,7 @@ Cloud Connect Network(CCN)
     tencentcloud_ccn_bandwidth_limit
 	tencentcloud_ccn_routes
 	tencentcloud_ccn_instances_accept_attach
+	tencentcloud_ccn_instances_reject_attach
 	tencentcloud_ccn_instances_reset_attach
 
 CVM Dedicated Host(CDH)
@@ -955,6 +956,7 @@ VPN Connections(VPN)
     tencentcloud_vpn_gateways
     tencentcloud_vpn_gateway_routes
 	tencentcloud_vpn_customer_gateway_vendors
+	tencentcloud_vpn_default_health_check_ip
 
   Resource
     tencentcloud_vpn_customer_gateway
@@ -1617,6 +1619,7 @@ func Provider() *schema.Provider {
 			"tencentcloud_vpn_gateway_routes":                        dataSourceTencentCloudVpnGatewayRoutes(),
 			"tencentcloud_vpn_connections":                           dataSourceTencentCloudVpnConnections(),
 			"tencentcloud_vpn_customer_gateway_vendors":              dataSourceTencentCloudVpnCustomerGatewayVendors(),
+			"tencentcloud_vpn_default_health_check_ip":               dataSourceTencentCloudVpnDefaultHealthCheckIp(),
 			"tencentcloud_ha_vips":                                   dataSourceTencentCloudHaVips(),
 			"tencentcloud_ha_vip_eip_attachments":                    dataSourceTencentCloudHaVipEipAttachments(),
 			"tencentcloud_ccn_instances":                             dataSourceTencentCloudCcnInstances(),
@@ -2080,6 +2083,7 @@ func Provider() *schema.Provider {
 			"tencentcloud_ccn_bandwidth_limit":                            resourceTencentCloudCcnBandwidthLimit(),
 			"tencentcloud_ccn_routes":                                     resourceTencentCloudCcnRoutes(),
 			"tencentcloud_ccn_instances_accept_attach":                    resourceTencentCloudCcnInstancesAcceptAttach(),
+			"tencentcloud_ccn_instances_reject_attach":                    resourceTencentCloudCcnInstancesRejectAttach(),
 			"tencentcloud_ccn_instances_reset_attach":                     resourceTencentCloudCcnInstancesResetAttach(),
 			"tencentcloud_dc_instance":                                    resourceTencentCloudDcInstance(),
 			"tencentcloud_dcx":                                            resourceTencentCloudDcxInstance(),

tencentcloud/resource_tc_ccn_instances_reject_attach.go

@@ -0,0 +1,155 @@
+/*
+Provides a resource to create a vpc ccn_instances_reject_attach, you can use this resource to approve cross-region attachment.
+
+Example Usage
+
+```hcl
+resource "tencentcloud_ccn_instances_reject_attach" "ccn_instances_reject_attach" {
+  ccn_id = "ccn-39lqkygf"
+  instances {
+    instance_id     = "vpc-j9yhbzpn"
+    instance_region = "ap-guangzhou"
+    instance_type   = "VPC"
+  }
+}
+```
+*/
+package tencentcloud
+
+import (
+	"fmt"
+	"log"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	vpc "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/vpc/v20170312"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func resourceTencentCloudCcnInstancesRejectAttach() *schema.Resource {
+	return &schema.Resource{
+		Create: resourceTencentCloudCcnInstancesRejectAttachCreate,
+		Read:   resourceTencentCloudCcnInstancesRejectAttachRead,
+		Delete: resourceTencentCloudCcnInstancesRejectAttachDelete,
+		Importer: &schema.ResourceImporter{
+			State: schema.ImportStatePassthrough,
+		},
+		Schema: map[string]*schema.Schema{
+			"ccn_id": {
+				Required:    true,
+				ForceNew:    true,
+				Type:        schema.TypeString,
+				Description: "CCN Instance ID.",
+			},
+
+			"instances": {
+				Required:    true,
+				ForceNew:    true,
+				Type:        schema.TypeList,
+				Description: "Reject List Of Attachment Instances.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"instance_id": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Attachment Instance ID.",
+						},
+						"instance_region": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Instance Region.",
+						},
+						"instance_type": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "InstanceType: `VPC`, `DIRECTCONNECT`, `BMVPC`, `VPNGW`.",
+						},
+						"description": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Description.",
+						},
+						"route_table_id": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "ID of the routing table associated with the instance. Note: This field may return null, indicating that no valid value can be obtained.",
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
+func resourceTencentCloudCcnInstancesRejectAttachCreate(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_ccn_instances_reject_attach.read")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	var (
+		request = vpc.NewRejectAttachCcnInstancesRequest()
+		ccnId   string
+	)
+	if v, ok := d.GetOk("ccn_id"); ok {
+		ccnId = v.(string)
+		request.CcnId = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("instances"); ok {
+		for _, item := range v.([]interface{}) {
+			dMap := item.(map[string]interface{})
+			ccnInstance := vpc.CcnInstance{}
+			if v, ok := dMap["instance_id"]; ok {
+				ccnInstance.InstanceId = helper.String(v.(string))
+			}
+			if v, ok := dMap["instance_region"]; ok {
+				ccnInstance.InstanceRegion = helper.String(v.(string))
+			}
+			if v, ok := dMap["instance_type"]; ok {
+				ccnInstance.InstanceType = helper.String(v.(string))
+			}
+			if v, ok := dMap["description"]; ok {
+				ccnInstance.Description = helper.String(v.(string))
+			}
+			if v, ok := dMap["route_table_id"]; ok {
+				routeTableId := v.(string)
+				if routeTableId != "" {
+					ccnInstance.RouteTableId = helper.String(v.(string))
+				}
+			}
+			request.Instances = append(request.Instances, &ccnInstance)
+		}
+	}
+
+	err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+		result, e := meta.(*TencentCloudClient).apiV3Conn.UseVpcClient().RejectAttachCcnInstances(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 {
+		return fmt.Errorf("[CRITAL]%s operate vpc ccnInstancesRejectAttach failed, reason:%+v", logId, err)
+	}
+
+	d.SetId(ccnId)
+
+	return resourceTencentCloudCcnInstancesRejectAttachRead(d, meta)
+}
+
+func resourceTencentCloudCcnInstancesRejectAttachRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_ccn_instances_reject_attach.read")()
+	defer inconsistentCheck(d, meta)()
+
+	return nil
+}
+
+func resourceTencentCloudCcnInstancesRejectAttachDelete(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_ccn_instances_reject_attach.delete")()
+	defer inconsistentCheck(d, meta)()
+
+	return nil
+}

tencentcloud/service_tencentcloud_dcg.go

@@ -471,6 +471,61 @@ func (me *VpcService) CreateDirectConnectGatewayCcnRoute(ctx context.Context, dc
 	return
 }
 
+// not used, because if support, it will cause resource destroyed
+func (me *VpcService) ReplaceDirectConnectGatewayCcnRoute(ctx context.Context, dcgId, cidr string, asPaths []string) (routeId string, errRet error) {
+
+	logId := getLogId(ctx)
+
+	request := vpc.NewReplaceDirectConnectGatewayCcnRoutesRequest()
+	request.DirectConnectGatewayId = &dcgId
+
+	var ccnRoute vpc.DirectConnectGatewayCcnRoute
+	ccnRoute.DestinationCidrBlock = &cidr
+	ccnRoute.ASPath = make([]*string, 0, len(asPaths))
+
+	for index := range asPaths {
+		ccnRoute.ASPath = append(ccnRoute.ASPath, &asPaths[index])
+	}
+	request.Routes = []*vpc.DirectConnectGatewayCcnRoute{&ccnRoute}
+	ratelimit.Check(request.GetAction())
+	response, err := me.client.UseVpcClient().ReplaceDirectConnectGatewayCcnRoutes(request)
+
+	defer func() {
+		if errRet != nil {
+			responseStr := ""
+			if response != nil {
+				responseStr = response.ToJsonString()
+			}
+			log.Printf("[CRITAL]%s api[%s] fail, request body [%s],response body [%s], reason[%s]\n",
+				logId,
+				request.GetAction(),
+				request.ToJsonString(),
+				responseStr,
+				errRet.Error())
+		}
+	}()
+
+	if err != nil {
+		errRet = err
+		return
+	}
+
+	routeIdTemp, has, err := me.GetCcnRouteId(ctx, dcgId, cidr, asPaths)
+
+	if err != nil {
+		errRet = err
+		return
+	}
+
+	if has == 1 {
+		routeId = routeIdTemp
+		return
+	} else {
+		errRet = fmt.Errorf("after api `ReplaceDirectConnectGatewayCcnRoutes`, api `DescribeDirectConnectGatewayCcnRoutes` return null route info")
+	}
+	return
+}
+
 func (me *VpcService) DeleteDirectConnectGatewayCcnRoute(ctx context.Context, dcgId, routeId string) (errRet error) {
 
 	logId := getLogId(ctx)