Feat/support css watermark rule

.changelog/2156.txt

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

go.mod

@@ -60,7 +60,7 @@ require (
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/gaap v1.0.514
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/kms v1.0.563
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse v1.0.729
-	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live v1.0.535
+	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live v1.0.756
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mariadb v1.0.672
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.651
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/monitor v1.0.734

go.sum

@@ -902,6 +902,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse v1.0.729 h1:
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse v1.0.729/go.mod h1:lLoyD7Z6OQQDFxDGGTe8wmirhUFZ36l5OaxzP75853Y=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live v1.0.535 h1:hSwG4ZbcP2Ht+AWHI81EMCvJdDTyTT7zP/qjOe/VcZg=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live v1.0.535/go.mod h1:mYKqy56uKaI0aPySeUByymvwDerPTmdMJQPQKC/NU1s=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live v1.0.756 h1:uwlWCqnsEXlafj/SixOJyyJojgEsjxkGtVOFGRhKk5I=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live v1.0.756/go.mod h1:MWQuFxqztpy6xLJ/XXuAxjBXcjpCLbyN42P3eub1yEs=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mariadb v1.0.672 h1:sR3MyM9RBw1PNRdWoBrtK+2M9Qbb0i6DfQSrvZ4/4os=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mariadb v1.0.672/go.mod h1:o3rBKhtfIJfw4BG22M0CQVLQAc0WqIsbyRI/EW52Ka0=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.651 h1:Ohb58H6gIlTcd73CF+goUlEdNJ2CYkYUHTYxV/M4UL4=

tencentcloud/provider.go

@@ -1322,6 +1322,7 @@ Real User Monitoring(RUM)
 Cloud Streaming Services(CSS)
   Resource
     tencentcloud_css_watermark
+	tencentcloud_css_watermark_rule_attachment
 	tencentcloud_css_pull_stream_task
 	tencentcloud_css_live_transcode_template
 	tencentcloud_css_live_transcode_rule_attachment
@@ -2893,6 +2894,7 @@ func Provider() *schema.Provider {
 			"tencentcloud_tdcpg_cluster":                                       resourceTencentCloudTdcpgCluster(),
 			"tencentcloud_tdcpg_instance":                                      resourceTencentCloudTdcpgInstance(),
 			"tencentcloud_css_watermark":                                       resourceTencentCloudCssWatermark(),
+			"tencentcloud_css_watermark_rule_attachment":                       resourceTencentCloudCssWatermarkRuleAttachment(),
 			"tencentcloud_css_pull_stream_task":                                resourceTencentCloudCssPullStreamTask(),
 			"tencentcloud_css_live_transcode_template":                         resourceTencentCloudCssLiveTranscodeTemplate(),
 			"tencentcloud_css_live_transcode_rule_attachment":                  resourceTencentCloudCssLiveTranscodeRuleAttachment(),

tencentcloud/resource_tc_css_watermark_rule_attachment.go

@@ -0,0 +1,242 @@
+/*
+Provides a resource to create a css watermark_rule
+
+Example Usage
+
+Binding watermark rule with a css stream
+
+```hcl
+resource "tencentcloud_css_pull_stream_task" "example" {
+  stream_name = "tf_example_stream_name"
+  source_type = "PullLivePushLive"
+  source_urls = ["rtmp://xxx.com/live/stream"]
+  domain_name = "test.domain.com"
+  app_name    = "live"
+  start_time  = "2023-09-27T10:28:21Z"
+  end_time    = "2023-09-27T17:28:21Z"
+  operator    = "tf_admin"
+  comment     = "This is a e2e test case."
+}
+
+resource "tencentcloud_css_watermark" "example" {
+  picture_url    = "picture_url"
+  watermark_name = "watermark_name"
+  x_position     = 0
+  y_position     = 0
+  width          = 0
+  height         = 0
+}
+
+resource "tencentcloud_css_watermark_rule_attachment" "watermark_rule_attachment" {
+  domain_name = tencentcloud_css_pull_stream_task.example.domain_name
+  app_name    = tencentcloud_css_pull_stream_task.example.app_name
+  stream_name = tencentcloud_css_pull_stream_task.example.stream_name
+  template_id = tencentcloud_css_watermark.example.id
+}
+```
+
+Import
+
+css watermark_rule_attachment can be imported using the id, e.g.
+
+```
+terraform import tencentcloud_css_watermark_rule_attachment.watermark_rule domain_name#app_name#stream_name#template_id
+```
+*/
+package tencentcloud
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"strings"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	css "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live/v20180801"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func resourceTencentCloudCssWatermarkRuleAttachment() *schema.Resource {
+	return &schema.Resource{
+		Create: resourceTencentCloudCssWatermarkRuleAttachmentCreate,
+		Read:   resourceTencentCloudCssWatermarkRuleAttachmentRead,
+		Delete: resourceTencentCloudCssWatermarkRuleAttachmentDelete,
+		Importer: &schema.ResourceImporter{
+			State: schema.ImportStatePassthrough,
+		},
+		Schema: map[string]*schema.Schema{
+			"domain_name": {
+				Required:    true,
+				ForceNew:    true,
+				Type:        schema.TypeString,
+				Description: "rule domain name.",
+			},
+
+			"app_name": {
+				Required:    true,
+				ForceNew:    true,
+				Type:        schema.TypeString,
+				Description: "rule app name.",
+			},
+
+			"stream_name": {
+				Required:    true,
+				ForceNew:    true,
+				Type:        schema.TypeString,
+				Description: "rule stream name.",
+			},
+
+			"template_id": {
+				Required:    true,
+				ForceNew:    true,
+				Type:        schema.TypeInt,
+				Description: "The template Id can be acquired by the Id of `tencentcloud_css_watermark`.",
+			},
+
+			"create_time": {
+				Computed:    true,
+				Type:        schema.TypeString,
+				Description: "create time.",
+			},
+
+			"update_time": {
+				Computed:    true,
+				Type:        schema.TypeString,
+				Description: "update time.",
+			},
+		},
+	}
+}
+
+func resourceTencentCloudCssWatermarkRuleAttachmentCreate(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_css_watermark_rule_attachment.create")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	var (
+		request    = css.NewCreateLiveWatermarkRuleRequest()
+		domainName string
+		appName    string
+		streamName string
+		templateId int
+	)
+	if v, ok := d.GetOk("domain_name"); ok {
+		domainName = v.(string)
+		request.DomainName = helper.String(domainName)
+	}
+
+	if v, ok := d.GetOk("app_name"); ok {
+		appName = v.(string)
+		request.AppName = helper.String(appName)
+	}
+
+	if v, ok := d.GetOk("stream_name"); ok {
+		streamName = v.(string)
+		request.StreamName = helper.String(streamName)
+	}
+
+	if v, ok := d.GetOkExists("template_id"); ok {
+		templateId = v.(int)
+		request.TemplateId = helper.IntInt64(templateId)
+	}
+
+	err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+		result, e := meta.(*TencentCloudClient).apiV3Conn.UseCssClient().CreateLiveWatermarkRule(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 {
+		log.Printf("[CRITAL]%s create css watermarkRule failed, reason:%+v", logId, err)
+		return err
+	}
+
+	d.SetId(strings.Join([]string{domainName, appName, streamName, helper.IntToStr(templateId)}, FILED_SP))
+
+	return resourceTencentCloudCssWatermarkRuleAttachmentRead(d, meta)
+}
+
+func resourceTencentCloudCssWatermarkRuleAttachmentRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_css_watermark_rule_attachment.read")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	service := CssService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+	idSplit := strings.Split(d.Id(), FILED_SP)
+	if len(idSplit) != 4 {
+		return fmt.Errorf("id is broken,%s", d.Id())
+	}
+	domainName := idSplit[0]
+	appName := idSplit[1]
+	streamName := idSplit[2]
+	templateId := idSplit[3]
+
+	watermarkRule, err := service.DescribeCssWatermarkRuleAttachment(ctx, domainName, appName, streamName, templateId)
+	if err != nil {
+		return err
+	}
+
+	if watermarkRule == nil {
+		d.SetId("")
+		log.Printf("[WARN]%s resource `CssWatermarkRule` [%s] not found, please check if it has been deleted.\n", logId, d.Id())
+		return nil
+	}
+
+	if watermarkRule.DomainName != nil {
+		_ = d.Set("domain_name", watermarkRule.DomainName)
+	}
+
+	if watermarkRule.AppName != nil {
+		_ = d.Set("app_name", watermarkRule.AppName)
+	}
+
+	if watermarkRule.StreamName != nil {
+		_ = d.Set("stream_name", watermarkRule.StreamName)
+	}
+
+	if watermarkRule.TemplateId != nil {
+		_ = d.Set("template_id", watermarkRule.TemplateId)
+	}
+
+	if watermarkRule.CreateTime != nil {
+		_ = d.Set("create_time", watermarkRule.CreateTime)
+	}
+
+	if watermarkRule.UpdateTime != nil {
+		_ = d.Set("update_time", watermarkRule.UpdateTime)
+	}
+
+	return nil
+}
+
+func resourceTencentCloudCssWatermarkRuleAttachmentDelete(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("resource.tencentcloud_css_watermark_rule_attachment.delete")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	service := CssService{client: meta.(*TencentCloudClient).apiV3Conn}
+	idSplit := strings.Split(d.Id(), FILED_SP)
+	if len(idSplit) != 4 {
+		return fmt.Errorf("id is broken,%s", d.Id())
+	}
+	domainName := idSplit[0]
+	appName := idSplit[1]
+	streamName := idSplit[2]
+
+	if err := service.DetachCssWatermarkRuleAttachment(ctx, domainName, appName, streamName); err != nil {
+		return err
+	}
+
+	return nil
+}