support mps schedule resource (#2179)

* support schedule resource

* add e2e case

* adjust e2e case

* add doc

.changelog/2179.txt

@@ -0,0 +1,7 @@
+```release-note:new-resource
+tencentcloud_mps_schedule
+```
+
+```release-note:new-resource
+tencentcloud_mps_enable_schedule_config
+```

tencentcloud/provider.go

@@ -1583,6 +1583,8 @@ Media Processing Service(MPS)
 	tencentcloud_mps_person_sample
 	tencentcloud_mps_withdraws_watermark_operation
 	tencentcloud_mps_word_sample
+	tencentcloud_mps_schedule
+	tencentcloud_mps_enable_schedule_config
 
 Cloud HDFS(CHDFS)
   Data Source
@@ -3097,6 +3099,8 @@ func Provider() *schema.Provider {
 			"tencentcloud_mps_person_sample":                                   resourceTencentCloudMpsPersonSample(),
 			"tencentcloud_mps_withdraws_watermark_operation":                   resourceTencentCloudMpsWithdrawsWatermarkOperation(),
 			"tencentcloud_mps_word_sample":                                     resourceTencentCloudMpsWordSample(),
+			"tencentcloud_mps_schedule":                                        resourceTencentCloudMpsSchedule(),
+			"tencentcloud_mps_enable_schedule_config":                          resourceTencentCloudMpsEnableScheduleConfig(),
 			"tencentcloud_cbs_disk_backup":                                     resourceTencentCloudCbsDiskBackup(),
 			"tencentcloud_cbs_snapshot_share_permission":                       resourceTencentCloudCbsSnapshotSharePermission(),
 			"tencentcloud_cbs_disk_backup_rollback_operation":                  resourceTencentCloudCbsDiskBackupRollbackOperation(),

tencentcloud/resource_tc_mps_enable_schedule_config.go

@@ -0,0 +1,317 @@
+/*
+Provides a resource to create a mps enable_schedule_config
+
+Example Usage
+
+Enable the mps schedule
+
+```hcl
+data "tencentcloud_cos_bucket_object" "object" {
+  bucket = "keep-bucket-${local.app_id}"
+  key    = "/mps-test/test.mov"
+}
+
+resource "tencentcloud_cos_bucket" "output" {
+  bucket      = "tf-bucket-mps-schedule-config-output1-${local.app_id}"
+  force_clean = true
+  acl         = "public-read"
+}
+
+resource "tencentcloud_mps_schedule" "example" {
+  schedule_name = "tf_test_mps_schedule_config"
+
+  trigger {
+    type = "CosFileUpload"
+    cos_file_upload_trigger {
+      bucket  = data.tencentcloud_cos_bucket_object.object.bucket
+      region  = "%s"
+      dir     = "/upload/"
+      formats = ["flv", "mov"]
+    }
+  }
+
+  activities {
+    activity_type   = "input"
+    reardrive_index = [1, 2]
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [3]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [6, 7]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [4, 5]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [10]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [10]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [10]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [8]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [9]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type   = "action-trans"
+    reardrive_index = [10]
+    activity_para {
+      transcode_task {
+        definition = 10
+      }
+    }
+  }
+
+  activities {
+    activity_type = "output"
+  }
+
+  output_storage {
+    type = "COS"
+    cos_output_storage {
+      bucket = tencentcloud_cos_bucket.output.bucket
+      region = "%s"
+    }
+  }
+
+  output_dir = "output/"
+}
+
+resource "tencentcloud_mps_enable_schedule_config" "config" {
+  schedule_id = tencentcloud_mps_schedule.example.id
+  enabled = true
+}
+```
+
+Disable the mps schedule
+
+```hcl
+resource "tencentcloud_mps_enable_schedule_config" "config" {
+  schedule_id = tencentcloud_mps_schedule.example.id
+  enabled = false
+}
+
+```
+
+Import
+
+mps enable_schedule_config can be imported using the id, e.g.
+
+```
+terraform import tencentcloud_mps_enable_schedule_config.enable_schedule_config enable_schedule_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 resourceTencentCloudMpsEnableScheduleConfig() *schema.Resource {
+	return &schema.Resource{
+		Create: resourceTencentCloudMpsEnableScheduleConfigCreate,
+		Read:   resourceTencentCloudMpsEnableScheduleConfigRead,
+		Update: resourceTencentCloudMpsEnableScheduleConfigUpdate,
+		Delete: resourceTencentCloudMpsEnableScheduleConfigDelete,
+		Importer: &schema.ResourceImporter{
+			State: schema.ImportStatePassthrough,
+		},
+		Schema: map[string]*schema.Schema{
+			"schedule_id": {
+				Required:    true,
+				Type:        schema.TypeInt,
+				Description: "The scheme ID.",
+			},
+
+			"enabled": {
+				Required:    true,
+				Type:        schema.TypeBool,
+				Description: "true: enable; false: disable.",
+			},
+		},
+	}
+}
+
+func resourceTencentCloudMpsEnableScheduleConfigCreate(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_schedule_config.create")()
+	defer inconsistentCheck(d, meta)()
+
+	var scheduleId int
+	if v, ok := d.GetOkExists("schedule_id"); ok {
+		scheduleId = v.(int)
+	}
+	d.SetId(helper.IntToStr(scheduleId))
+
+	return resourceTencentCloudMpsEnableScheduleConfigUpdate(d, meta)
+}
+
+func resourceTencentCloudMpsEnableScheduleConfigRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_schedule_config.read")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	service := MpsService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+	scheduleId := d.Id()
+
+	schedules, err := service.DescribeMpsScheduleById(ctx, &scheduleId)
+	if err != nil {
+		return err
+	}
+
+	if len(schedules) == 0 {
+		d.SetId("")
+		log.Printf("[WARN]%s resource `MpsEnableScheduleConfig` [%s] not found, please check if it has been deleted.\n", logId, d.Id())
+		return nil
+	}
+
+	enableScheduleConfig := schedules[0]
+
+	if enableScheduleConfig.ScheduleId != nil {
+		_ = d.Set("schedule_id", enableScheduleConfig.ScheduleId)
+	}
+
+	status := enableScheduleConfig.Status
+	if status != nil {
+		if *status == "Enabled" {
+			_ = d.Set("enabled", true)
+		} else {
+			_ = d.Set("enabled", false)
+		}
+	}
+
+	return nil
+}
+
+func resourceTencentCloudMpsEnableScheduleConfigUpdate(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_schedule_config.update")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	var (
+		enableRequest  = mps.NewEnableScheduleRequest()
+		disableRequest = mps.NewDisableScheduleRequest()
+		scheduleId     *int64
+		enabled        bool
+	)
+
+	scheduleId = helper.StrToInt64Point(d.Id())
+
+	if v, ok := d.GetOkExists("enabled"); ok && v != nil {
+		enabled = v.(bool)
+
+		if enabled {
+			enableRequest.ScheduleId = scheduleId
+			err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+				result, e := meta.(*TencentCloudClient).apiV3Conn.UseMpsClient().EnableSchedule(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 enableScheduleConfig failed, reason:%+v", logId, err)
+				return err
+			}
+		} else {
+			disableRequest.ScheduleId = scheduleId
+			err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+				result, e := meta.(*TencentCloudClient).apiV3Conn.UseMpsClient().DisableSchedule(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 disableScheduleConfig failed, reason:%+v", logId, err)
+				return err
+			}
+		}
+
+	}
+	return resourceTencentCloudMpsEnableScheduleConfigRead(d, meta)
+}
+
+func resourceTencentCloudMpsEnableScheduleConfigDelete(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_mps_enable_schedule_config.delete")()
+	defer inconsistentCheck(d, meta)()
+
+	return nil
+}