modify mongodb force_delete

CHANGELOG.md

@@ -1,4 +1,11 @@
 ## 1.42.1 (Unreleased)
+
+ENHANCEMENTS:
+
+* Resource: `tencentcloud_mongodb_instance` support mongodb postpaid force_delete.
+* Resource: `tencentcloud_mongodb_sharding_instance` support mongodb sharding postpaid force_delete.
+* Resource: `tencentcloud_mongodb_standby_instance` support mongodb standby postpaid force_delete.
+
 ## 1.42.0 (September 8, 2020)
 
 FEATURES:

tencentcloud/resource_tc_mongodb_instance.go

@@ -511,6 +511,24 @@ func resourceTencentCloudMongodbInstanceDelete(d *schema.ResourceData, meta inte
 	if err != nil {
 		return err
 	}
-
+	err = mongodbService.OfflineIsolatedDBInstance(ctx, instanceId)
+	if err != nil {
+		log.Printf("[CRITAL]%s mongodb %s fail, reason:%s\n", logId, "OfflineIsolatedDBInstance", err.Error())
+		return err
+	}
+	//describe and check not exist
+	err = resource.Retry(5*readRetryTimeout, func() *resource.RetryError {
+		instance, _, errRet := mongodbService.DescribeInstanceById(ctx, instanceId)
+		if errRet != nil {
+			return retryError(errRet, InternalError)
+		}
+		if instance == nil {
+			return nil
+		}
+		return resource.NonRetryableError(fmt.Errorf("after OfflineIsolatedDBInstance mongodb Status is %d", *instance.Status))
+	})
+	if err != nil {
+		return err
+	}
 	return nil
 }

tencentcloud/resource_tc_mongodb_sharding_instance.go

@@ -506,6 +506,24 @@ func resourceMongodbShardingInstanceDelete(d *schema.ResourceData, meta interfac
 	if err != nil {
 		return err
 	}
-
+	err = mongodbService.OfflineIsolatedDBInstance(ctx, instanceId)
+	if err != nil {
+		log.Printf("[CRITAL]%s mongodb %s fail, reason:%s\n", logId, "OfflineIsolatedDBInstance", err.Error())
+		return err
+	}
+	//describe and check not exist
+	err = resource.Retry(5*readRetryTimeout, func() *resource.RetryError {
+		instance, _, errRet := mongodbService.DescribeInstanceById(ctx, instanceId)
+		if errRet != nil {
+			return retryError(errRet, InternalError)
+		}
+		if instance == nil {
+			return nil
+		}
+		return resource.NonRetryableError(fmt.Errorf("after OfflineIsolatedDBInstance mongodb Status is %d", *instance.Status))
+	})
+	if err != nil {
+		return err
+	}
 	return nil
 }

tencentcloud/resource_tc_mongodb_standby_instance.go

@@ -556,6 +556,25 @@ func resourceTencentCloudMongodbStandbyInstanceDelete(d *schema.ResourceData, me
 	if err != nil {
 		return err
 	}
+	err = mongodbService.OfflineIsolatedDBInstance(ctx, instanceId)
+	if err != nil {
+		log.Printf("[CRITAL]%s mongodb %s fail, reason:%s\n", logId, "OfflineIsolatedDBInstance", err.Error())
+		return err
+	}
+	//describe and check not exist
+	err = resource.Retry(5*readRetryTimeout, func() *resource.RetryError {
+		instance, _, errRet := mongodbService.DescribeInstanceById(ctx, instanceId)
+		if errRet != nil {
+			return retryError(errRet, InternalError)
+		}
+		if instance == nil {
+			return nil
+		}
+		return resource.NonRetryableError(fmt.Errorf("after OfflineIsolatedDBInstance mongodb Status is %d", *instance.Status))
+	})
+	if err != nil {
+		return err
+	}
 
 	return nil
 }

tencentcloud/service_tencentcloud_mongodb.go

@@ -313,3 +313,43 @@ func (me *MongodbService) DescribeAsyncRequestInfo(ctx context.Context, asyncId
 
 	return nil
 }
+
+func (me *MongodbService) OfflineIsolatedDBInstance(ctx context.Context, instanceId string) (errRet error) {
+	logId := getLogId(ctx)
+	request := mongodb.NewOfflineIsolatedDBInstanceRequest()
+	request.InstanceId = &instanceId
+	defer func() {
+		if errRet != nil {
+			log.Printf("[CRITAL]%s api[%s] fail,reason[%s]", logId, request.GetAction(), errRet.Error())
+		}
+	}()
+	var response *mongodb.OfflineIsolatedDBInstanceResponse
+	err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+		ratelimit.Check(request.GetAction())
+		result, e := me.client.UseMongodbClient().OfflineIsolatedDBInstance(request)
+		if e != nil {
+			if ee, ok := e.(*sdkErrors.TencentCloudSDKError); ok {
+				if ee.Code == "InvalidParameterValue.LockFailed" {
+					return resource.RetryableError(e)
+				} else {
+					return resource.NonRetryableError(e)
+				}
+			}
+			log.Printf("[CRITAL]%s api[%s] fail, reason:%s", logId, request.GetAction(), e.Error())
+			return resource.NonRetryableError(e)
+		}
+		response = result
+		return nil
+	})
+	if err != nil {
+		return err
+	}
+	if response != nil && response.Response != nil {
+		if err = me.DescribeAsyncRequestInfo(ctx, *response.Response.AsyncRequestId); err != nil {
+			return err
+		}
+	}
+	log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]",
+		logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
+	return nil
+}