Support deployment to Alibaba Cloud CDN.

internal/deployer/aliyun_cdn.go

@@ -0,0 +1,68 @@
+package deployer
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+
+	cdn20180510 "github.com/alibabacloud-go/cdn-20180510/v5/client"
+	openapi "github.com/alibabacloud-go/darabonba-openapi/v2/client"
+	util "github.com/alibabacloud-go/tea-utils/v2/service"
+	"github.com/alibabacloud-go/tea/tea"
+)
+
+type AliyunCdn struct {
+	client *cdn20180510.Client
+	option *DeployerOption
+}
+
+func NewAliyunCdn(option *DeployerOption) (*AliyunCdn, error) {
+	access := &aliyunAccess{}
+	json.Unmarshal([]byte(option.Access), access)
+	a := &AliyunCdn{
+		option: option,
+	}
+	client, err := a.createClient(access.AccessKeyId, access.AccessKeySecret)
+	if err != nil {
+		return nil, err
+	}
+
+	return &AliyunCdn{
+		client: client,
+		option: option,
+	}, nil
+}
+
+func (a *AliyunCdn) Deploy(ctx context.Context) error {
+
+	certName := fmt.Sprintf("%s-%s", a.option.Domain, a.option.DomainId)
+	setCdnDomainSSLCertificateRequest := &cdn20180510.SetCdnDomainSSLCertificateRequest{
+		DomainName:  tea.String(a.option.Domain),
+		CertName:    tea.String(certName),
+		CertType:    tea.String("upload"),
+		SSLProtocol: tea.String("on"),
+		SSLPub:      tea.String(a.option.Certificate.Certificate),
+		SSLPri:      tea.String(a.option.Certificate.PrivateKey),
+		CertRegion:  tea.String("cn-hangzhou"),
+	}
+
+	runtime := &util.RuntimeOptions{}
+
+	_, err := a.client.SetCdnDomainSSLCertificateWithOptions(setCdnDomainSSLCertificateRequest, runtime)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (a *AliyunCdn) createClient(accessKeyId, accessKeySecret string) (_result *cdn20180510.Client, _err error) {
+	config := &openapi.Config{
+		AccessKeyId:     tea.String(accessKeyId),
+		AccessKeySecret: tea.String(accessKeySecret),
+	}
+	config.Endpoint = tea.String("cdn.aliyuncs.com")
+	_result = &cdn20180510.Client{}
+	_result, _err = cdn20180510.NewClient(config)
+	return _result, _err
+}

internal/deployer/deployer.go

@@ -13,7 +13,13 @@ const (
 	configTypeAliyun = "aliyun"
 )
 
+const (
+	targetAliyunOss = "aliyun-oss"
+	targetAliyunCdn = "aliyun-cdn"
+)
+
 type DeployerOption struct {
+	DomainId    string                `json:"domainId"`
 	Domain      string                `json:"domain"`
 	Product     string                `json:"product"`
 	Access      string                `json:"access"`
@@ -26,18 +32,21 @@ type Deployer interface {
 
 func Get(record *models.Record) (Deployer, error) {
 	access := record.ExpandedOne("targetAccess")
-	switch access.GetString("configType") {
-	case configTypeAliyun:
-		option := &DeployerOption{
-			Domain:  record.GetString("domain"),
-			Product: getProduct(record),
-			Access:  access.GetString("config"),
-			Certificate: applicant.Certificate{
-				Certificate: record.GetString("certificate"),
-				PrivateKey:  record.GetString("privateKey"),
-			},
-		}
+	option := &DeployerOption{
+		DomainId: record.Id,
+		Domain:   record.GetString("domain"),
+		Product:  getProduct(record),
+		Access:   access.GetString("config"),
+		Certificate: applicant.Certificate{
+			Certificate: record.GetString("certificate"),
+			PrivateKey:  record.GetString("privateKey"),
+		},
+	}
+	switch record.GetString("targetType") {
+	case targetAliyunOss:
 		return NewAliyun(option)
+	case targetAliyunCdn:
+		return NewAliyunCdn(option)
 	}
 	return nil, errors.New("not implemented")
 }