feat:support mps workflow config (#2159)

* feat:support mps workflow config

* add changelog

Author: lyu571

.changelog/2159.txt

@@ -0,0 +1,3 @@
+```release-note:new-resource
+tencentcloud_mps_enable_workflow_config
+```

tencentcloud/provider.go

@@ -1556,6 +1556,7 @@ Tencent Service Framework(TSF)
 Media Processing Service(MPS)
   Resource
 	tencentcloud_mps_workflow
+	tencentcloud_mps_enable_workflow_config
 	tencentcloud_mps_transcode_template
 	tencentcloud_mps_watermark_template
 	tencentcloud_mps_image_sprite_template
@@ -3017,6 +3018,7 @@ func Provider() *schema.Provider {
 			"tencentcloud_tsf_operate_group":                                   resourceTencentCloudTsfOperateGroup(),
 			"tencentcloud_tsf_unit_namespace":                                  resourceTencentCloudTsfUnitNamespace(),
 			"tencentcloud_mps_workflow":                                        resourceTencentCloudMpsWorkflow(),
+			"tencentcloud_mps_enable_workflow_config":                          resourceTencentCloudMpsEnableWorkflowConfig(),
 			"tencentcloud_mps_transcode_template":                              resourceTencentCloudMpsTranscodeTemplate(),
 			"tencentcloud_mps_watermark_template":                              resourceTencentCloudMpsWatermarkTemplate(),
 			"tencentcloud_mps_image_sprite_template":                           resourceTencentCloudMpsImageSpriteTemplate(),

tencentcloud/resource_tc_mps_enable_workflow_config.go

@@ -0,0 +1,271 @@
+/*
+Provides a resource to create a mps enable_workflow_config
+
+Example Usage
+
+Enable the mps workflow
+
+```hcl
+resource "tencentcloud_mps_workflow" "example" {
+  output_dir    = "/"
+  task_priority = 0
+  workflow_name = "tf-workflow-enable-config"
+
+  media_process_task {
+    adaptive_dynamic_streaming_task_set {
+      definition             = 12
+      output_object_path     = "/out"
+      segment_object_name    = "/out"
+      sub_stream_object_name = "/out/out/"
+
+      output_storage {
+        type = "COS"
+
+        cos_output_storage {
+          bucket = "cos-lock-1308919341"
+          region = "ap-guangzhou"
+        }
+      }
+    }
+
+    snapshot_by_time_offset_task_set {
+      definition          = 10
+      ext_time_offset_set = [
+        "1s",
+      ]
+      output_object_path  = "/snapshot/"
+      time_offset_set     = []
+
+      output_storage {
+        type = "COS"
+
+        cos_output_storage {
+          bucket = "cos-lock-1308919341"
+          region = "ap-guangzhou"
+        }
+      }
+    }
+
+    animated_graphic_task_set {
+      definition         = 20000
+      end_time_offset    = 0
+      output_object_path = "/test/"
+      start_time_offset  = 0
+
+      output_storage {
+        type = "COS"
+
+        cos_output_storage {
+          bucket = "cos-lock-1308919341"
+          region = "ap-guangzhou"
+        }
+      }
+    }
+  }
+
+  ai_analysis_task {
+    definition = 20
+  }
+
+  ai_content_review_task {
+    definition = 20
+  }
+
+  ai_recognition_task {
+    definition = 20
+  }
+
+  output_storage {
+    type = "COS"
+
+    cos_output_storage {
+      bucket = "cos-lock-1308919341"
+      region = "ap-guangzhou"
+    }
+  }
+
+  trigger {
+    type = "CosFileUpload"
+
+    cos_file_upload_trigger {
+      bucket = "cos-lock-1308919341"
+      dir    = "/"
+      region = "ap-guangzhou"
+    }
+  }
+}
+
+resource "tencentcloud_mps_enable_workflow_config" "config" {
+  workflow_id = tencentcloud_mps_workflow.example.id
+  enabled = true
+}
+
+```
+
+Disable the mps workflow
+
+```hcl
+resource "tencentcloud_mps_enable_workflow_config" "config" {
+  workflow_id = tencentcloud_mps_workflow.example.id
+  enabled = false
+}
+
+```
+
+Import
+
+mps enable_workflow_config can be imported using the id, e.g.
+
+```
+terraform import tencentcloud_mps_enable_workflow_config.enable_workflow_config enable_workflow_config_id
+```
+*/
+package tencentcloud
+
+import (
+	"context"
+	"log"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	mps "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mps/v20190612"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func resourceTencentCloudMpsEnableWorkflowConfig() *schema.Resource {
+	return &schema.Resource{
+		Create: resourceTencentCloudMpsEnableWorkflowConfigCreate,
+		Read:   resourceTencentCloudMpsEnableWorkflowConfigRead,
+		Update: resourceTencentCloudMpsEnableWorkflowConfigUpdate,
+		Delete: resourceTencentCloudMpsEnableWorkflowConfigDelete,
+		Importer: &schema.ResourceImporter{
+			State: schema.ImportStatePassthrough,
+		},
+		Schema: map[string]*schema.Schema{
+			"workflow_id": {
+				Required:    true,
+				Type:        schema.TypeInt,
+				Description: "Workflow ID.",
+			},
+
+			"enabled": {
+				Required:    true,
+				Type:        schema.TypeBool,
+				Description: "true: enable; false: disable.",
+			},
+		},
+	}
+}
+
+func resourceTencentCloudMpsEnableWorkflowConfigCreate(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_workflow_config.create")()
+	defer inconsistentCheck(d, meta)()
+
+	var workflowId int
+	if v, ok := d.GetOkExists("workflow_id"); ok {
+		workflowId = v.(int)
+	}
+	d.SetId(helper.IntToStr(workflowId))
+
+	return resourceTencentCloudMpsEnableWorkflowConfigUpdate(d, meta)
+}
+
+func resourceTencentCloudMpsEnableWorkflowConfigRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_workflow_config.read")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	service := MpsService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+	workflowId := d.Id()
+
+	enableWorkflowConfig, err := service.DescribeMpsWorkflowById(ctx, workflowId)
+	if err != nil {
+		return err
+	}
+
+	if enableWorkflowConfig == nil {
+		d.SetId("")
+		log.Printf("[WARN]%s resource `MpsEnableWorkflowConfig` [%s] not found, please check if it has been deleted.\n", logId, d.Id())
+		return nil
+	}
+
+	if enableWorkflowConfig.WorkflowId != nil {
+		_ = d.Set("workflow_id", enableWorkflowConfig.WorkflowId)
+	}
+
+	status := enableWorkflowConfig.Status
+	if status != nil {
+		if *status == "Enabled" {
+			_ = d.Set("enabled", true)
+		} else {
+			_ = d.Set("enabled", false)
+		}
+	}
+
+	return nil
+}
+
+func resourceTencentCloudMpsEnableWorkflowConfigUpdate(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_workflow_config.update")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	var (
+		enableRequest  = mps.NewEnableWorkflowRequest()
+		disableRequest = mps.NewDisableWorkflowRequest()
+		workflowId     *int64
+		enabled        bool
+	)
+
+	workflowId = helper.StrToInt64Point(d.Id())
+
+	if v, ok := d.GetOkExists("enabled"); ok && v != nil {
+		enabled = v.(bool)
+
+		if enabled {
+			enableRequest.WorkflowId = workflowId
+			err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+				result, e := meta.(*TencentCloudClient).apiV3Conn.UseMpsClient().EnableWorkflow(enableRequest)
+				if e != nil {
+					return retryError(e)
+				} else {
+					log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, enableRequest.GetAction(), enableRequest.ToJsonString(), result.ToJsonString())
+				}
+				return nil
+			})
+			if err != nil {
+				log.Printf("[CRITAL]%s operate mps enableWorkflowConfig failed, reason:%+v", logId, err)
+				return err
+			}
+		} else {
+			disableRequest.WorkflowId = workflowId
+			err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+				result, e := meta.(*TencentCloudClient).apiV3Conn.UseMpsClient().DisableWorkflow(disableRequest)
+				if e != nil {
+					return retryError(e)
+				} else {
+					log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, disableRequest.GetAction(), disableRequest.ToJsonString(), result.ToJsonString())
+				}
+				return nil
+			})
+			if err != nil {
+				log.Printf("[CRITAL]%s operate mps disableWorkflowConfig failed, reason:%+v", logId, err)
+				return err
+			}
+		}
+	}
+
+	return resourceTencentCloudMpsEnableWorkflowConfigRead(d, meta)
+}
+
+func resourceTencentCloudMpsEnableWorkflowConfigDelete(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_workflow_config.delete")()
+	defer inconsistentCheck(d, meta)()
+
+	return nil
+}