feat: add cdnfly deployer

README.md

@@ -137,6 +137,7 @@ make local.run
 | [AWS](https://aws.amazon.com/)          | 可部署到 AWS CloudFront                                                  |
 | [BytePlus](https://www.byteplus.com/)   | 可部署到 BytePlus CDN                                                    |
 | [CacheFly](https://www.cachefly.com/)   | 可部署到 CacheFly CDN                                                    |
+| [Cdnfly](https://www.cdnfly.cn/)        | 可部署到 Cdnfly CDN                                                      |
 | [Edgio](https://edg.io/)                | 可部署到 Edgio Applications                                              |
 | [Gcore](https://gcore.com/)             | 可部署到 Gcore CDN                                                       |
 

README_EN.md

@@ -136,6 +136,7 @@ The following hosting providers are supported:
 | [AWS](https://aws.amazon.com/)                  | Supports deployment to AWS CloudFront                                            |
 | [BytePlus](https://www.byteplus.com/)           | Supports deployment to BytePlus CDN                                              |
 | [CacheFly](https://www.cachefly.com/)           | Supports deployment to CacheFly CDN                                              |
+| [Cdnfly](https://www.cdnfly.cn/)                | Supports deployment to Cdnfly CDN                                                |
 | [Edgio](https://edg.io/)                        | Supports deployment to Edgio Applications                                        |
 | [Gcore](https://gcore.com/)                     | Supports deployment to Gcore CDN                                                 |
 

internal/deployer/providers.go

@@ -23,6 +23,7 @@ import (
 	pBaotaPanelSite "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/baotapanel-site"
 	pBytePlusCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/byteplus-cdn"
 	pCacheFly "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/cachefly"
+	pCdnfly "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/cdnfly"
 	pDogeCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/dogecloud-cdn"
 	pEdgioApplications "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/edgio-applications"
 	pGcoreCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/gcore-cdn"
@@ -302,6 +303,24 @@ func createDeployer(options *deployerOptions) (deployer.Deployer, logger.Logger,
 			return deployer, logger, err
 		}
 
+	case domain.DeployProviderTypeCdnfly:
+		{
+			access := domain.AccessConfigForCdnfly{}
+			if err := maps.Populate(options.ProviderAccessConfig, &access); err != nil {
+				return nil, nil, fmt.Errorf("failed to populate provider access config: %w", err)
+			}
+
+			deployer, err := pCdnfly.NewWithLogger(&pCdnfly.CdnflyDeployerConfig{
+				ApiUrl:        access.ApiUrl,
+				ApiKey:        access.ApiKey,
+				ApiSecret:     access.ApiSecret,
+				ResourceType:  pCdnfly.ResourceType(maps.GetValueAsString(options.ProviderDeployConfig, "resourceType")),
+				SiteId:        maps.GetValueAsString(options.ProviderDeployConfig, "siteId"),
+				CertificateId: maps.GetValueAsString(options.ProviderDeployConfig, "certificateId"),
+			}, logger)
+			return deployer, logger, err
+		}
+
 	case domain.DeployProviderTypeDogeCloudCDN:
 		{
 			access := domain.AccessConfigForDogeCloud{}

internal/domain/access.go

@@ -71,6 +71,12 @@ type AccessConfigForCacheFly struct {
 	ApiToken string `json:"apiToken"`
 }
 
+type AccessConfigForCdnfly struct {
+	ApiUrl    string `json:"apiUrl"`
+	ApiKey    string `json:"apiKey"`
+	ApiSecret string `json:"apiSecret"`
+}
+
 type AccessConfigForCloudflare struct {
 	DnsApiToken string `json:"dnsApiToken"`
 }

internal/domain/provider.go

@@ -20,7 +20,7 @@ const (
 	AccessProviderTypeBaotaPanel   = AccessProviderType("baotapanel")
 	AccessProviderTypeBytePlus     = AccessProviderType("byteplus")
 	AccessProviderTypeCacheFly     = AccessProviderType("cachefly")
-	AccessProviderTypeCdnfly       = AccessProviderType("cdnfly") // Cdnly（预留）
+	AccessProviderTypeCdnfly       = AccessProviderType("cdnfly")
 	AccessProviderTypeCloudflare   = AccessProviderType("cloudflare")
 	AccessProviderTypeClouDNS      = AccessProviderType("cloudns")
 	AccessProviderTypeCMCCCloud    = AccessProviderType("cmcccloud") // 移动云（预留）
@@ -113,6 +113,7 @@ const (
 	DeployProviderTypeBaotaPanelSite        = DeployProviderType("baotapanel-site")
 	DeployProviderTypeBytePlusCDN           = DeployProviderType("byteplus-cdn")
 	DeployProviderTypeCacheFly              = DeployProviderType("cachefly")
+	DeployProviderTypeCdnfly                = DeployProviderType("cdnfly")
 	DeployProviderTypeDogeCloudCDN          = DeployProviderType("dogecloud-cdn")
 	DeployProviderTypeEdgioApplications     = DeployProviderType("edgio-applications")
 	DeployProviderTypeGcoreCDN              = DeployProviderType("gcore-cdn")

internal/pkg/core/applicant/acme-dns-01/lego-providers/acmehttpreq/acmehttpreq.go

@@ -1,7 +1,6 @@
 package acmehttpreq
 
 import (
-	"errors"
 	"net/url"
 	"time"
 
@@ -19,7 +18,7 @@ type ACMEHttpReqApplicantConfig struct {
 
 func NewChallengeProvider(config *ACMEHttpReqApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	endpoint, _ := url.Parse(config.Endpoint)

internal/pkg/core/applicant/acme-dns-01/lego-providers/aliyun/aliyun.go

@@ -1,7 +1,6 @@
 package aliyun
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -17,7 +16,7 @@ type AliyunApplicantConfig struct {
 
 func NewChallengeProvider(config *AliyunApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := alidns.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/aws-route53/aws-route53.go

@@ -1,7 +1,6 @@
 package awsroute53
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -19,7 +18,7 @@ type AWSRoute53ApplicantConfig struct {
 
 func NewChallengeProvider(config *AWSRoute53ApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := route53.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/azure-dns/azure-dns.go

@@ -1,7 +1,6 @@
 package azuredns
 
 import (
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -22,7 +21,7 @@ type AzureDNSApplicantConfig struct {
 
 func NewChallengeProvider(config *AzureDNSApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := azuredns.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/cloudflare/cloudflare.go

@@ -1,7 +1,6 @@
 package cloudflare
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -16,7 +15,7 @@ type CloudflareApplicantConfig struct {
 
 func NewChallengeProvider(config *CloudflareApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := cloudflare.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/cloudns/cloudns.go

@@ -1,7 +1,6 @@
 package cloudns
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -17,7 +16,7 @@ type ClouDNSApplicantConfig struct {
 
 func NewChallengeProvider(config *ClouDNSApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := cloudns.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/gcore/gcore.go

@@ -1,7 +1,6 @@
 package gcore
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -16,7 +15,7 @@ type GcoreApplicantConfig struct {
 
 func NewChallengeProvider(config *GcoreApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := gcore.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/gname/gname.go

@@ -1,7 +1,6 @@
 package gname
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -18,7 +17,7 @@ type GnameApplicantConfig struct {
 
 func NewChallengeProvider(config *GnameApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := internal.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/godaddy/godaddy.go

@@ -1,7 +1,6 @@
 package godaddy
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -17,7 +16,7 @@ type GoDaddyApplicantConfig struct {
 
 func NewChallengeProvider(config *GoDaddyApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := godaddy.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/huaweicloud/huaweicloud.go

@@ -1,7 +1,6 @@
 package huaweicloud
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -18,7 +17,7 @@ type HuaweiCloudApplicantConfig struct {
 
 func NewChallengeProvider(config *HuaweiCloudApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	region := config.Region

internal/pkg/core/applicant/acme-dns-01/lego-providers/namedotcom/namedotcom.go

@@ -1,7 +1,6 @@
 package namedotcom
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -17,7 +16,7 @@ type NameDotComApplicantConfig struct {
 
 func NewChallengeProvider(config *NameDotComApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := namedotcom.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/namesilo/namesilo.go

@@ -1,7 +1,6 @@
 package namesilo
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -16,7 +15,7 @@ type NameSiloApplicantConfig struct {
 
 func NewChallengeProvider(config *NameSiloApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := namesilo.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/ns1/ns1.go

@@ -1,7 +1,6 @@
 package ns1
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -16,7 +15,7 @@ type NS1ApplicantConfig struct {
 
 func NewChallengeProvider(config *NS1ApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := ns1.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/powerdns/powerdns.go

@@ -1,7 +1,6 @@
 package namesilo
 
 import (
-	"errors"
 	"net/url"
 	"time"
 
@@ -18,7 +17,7 @@ type PowerDNSApplicantConfig struct {
 
 func NewChallengeProvider(config *PowerDNSApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	host, _ := url.Parse(config.ApiUrl)

internal/pkg/core/applicant/acme-dns-01/lego-providers/rainyun/rainyun.go

@@ -1,7 +1,6 @@
 package rainyun
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -16,7 +15,7 @@ type RainYunApplicantConfig struct {
 
 func NewChallengeProvider(config *RainYunApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := rainyun.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/tencentcloud/tencentcloud.go

@@ -1,7 +1,6 @@
 package tencentcloud
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -17,7 +16,7 @@ type TencentCloudApplicantConfig struct {
 
 func NewChallengeProvider(config *TencentCloudApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := tencentcloud.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/volcengine/volcengine.go

@@ -1,7 +1,6 @@
 package volcengine
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -17,7 +16,7 @@ type VolcEngineApplicantConfig struct {
 
 func NewChallengeProvider(config *VolcEngineApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := volcengine.NewDefaultConfig()

internal/pkg/core/applicant/acme-dns-01/lego-providers/westcn/westcn.go

@@ -1,7 +1,6 @@
 package westcn
 
 import (
-	"errors"
 	"time"
 
 	"github.com/go-acme/lego/v4/challenge"
@@ -17,7 +16,7 @@ type WestcnApplicantConfig struct {
 
 func NewChallengeProvider(config *WestcnApplicantConfig) (challenge.Provider, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	providerConfig := westcn.NewDefaultConfig()

internal/pkg/core/deployer/providers/aliyun-alb/aliyun_alb.go

@@ -61,11 +61,11 @@ func New(config *AliyunALBDeployerConfig) (*AliyunALBDeployer, error) {
 
 func NewWithLogger(config *AliyunALBDeployerConfig, logger logger.Logger) (*AliyunALBDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	clients, err := createSdkClients(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aliyun-cas-deploy/aliyun_cas_deploy.go

@@ -47,11 +47,11 @@ func New(config *AliyunCASDeployDeployerConfig) (*AliyunCASDeployDeployer, error
 
 func NewWithLogger(config *AliyunCASDeployDeployerConfig, logger logger.Logger) (*AliyunCASDeployDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aliyun-cdn/aliyun_cdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -39,11 +38,11 @@ func New(config *AliyunCDNDeployerConfig) (*AliyunCDNDeployer, error) {
 
 func NewWithLogger(config *AliyunCDNDeployerConfig, logger logger.Logger) (*AliyunCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret)

internal/pkg/core/deployer/providers/aliyun-clb/aliyun_clb.go

@@ -51,11 +51,11 @@ func New(config *AliyunCLBDeployerConfig) (*AliyunCLBDeployer, error) {
 
 func NewWithLogger(config *AliyunCLBDeployerConfig, logger logger.Logger) (*AliyunCLBDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aliyun-dcdn/aliyun_dcdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -39,11 +38,11 @@ func New(config *AliyunDCDNDeployerConfig) (*AliyunDCDNDeployer, error) {
 
 func NewWithLogger(config *AliyunDCDNDeployerConfig, logger logger.Logger) (*AliyunDCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret)

internal/pkg/core/deployer/providers/aliyun-esa/aliyun_esa.go

@@ -44,11 +44,11 @@ func New(config *AliyunESADeployerConfig) (*AliyunESADeployer, error) {
 
 func NewWithLogger(config *AliyunESADeployerConfig, logger logger.Logger) (*AliyunESADeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aliyun-live/aliyun_live.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -41,11 +40,11 @@ func New(config *AliyunLiveDeployerConfig) (*AliyunLiveDeployer, error) {
 
 func NewWithLogger(config *AliyunLiveDeployerConfig, logger logger.Logger) (*AliyunLiveDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aliyun-nlb/aliyun_nlb.go

@@ -49,11 +49,11 @@ func New(config *AliyunNLBDeployerConfig) (*AliyunNLBDeployer, error) {
 
 func NewWithLogger(config *AliyunNLBDeployerConfig, logger logger.Logger) (*AliyunNLBDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aliyun-oss/aliyun_oss.go

@@ -39,11 +39,11 @@ func New(config *AliyunOSSDeployerConfig) (*AliyunOSSDeployer, error) {
 
 func NewWithLogger(config *AliyunOSSDeployerConfig, logger logger.Logger) (*AliyunOSSDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aliyun-waf/aliyun_waf.go

@@ -43,11 +43,11 @@ func New(config *AliyunWAFDeployerConfig) (*AliyunWAFDeployer, error) {
 
 func NewWithLogger(config *AliyunWAFDeployerConfig, logger logger.Logger) (*AliyunWAFDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/aws-cloudfront/aws_cloudfront.go

@@ -43,11 +43,11 @@ func New(config *AWSCloudFrontDeployerConfig) (*AWSCloudFrontDeployer, error) {
 
 func NewWithLogger(config *AWSCloudFrontDeployerConfig, logger logger.Logger) (*AWSCloudFrontDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.SecretAccessKey, config.Region)

internal/pkg/core/deployer/providers/baiducloud-cdn/baiducloud_cdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"time"
 
@@ -37,11 +36,11 @@ func New(config *BaiduCloudCDNDeployerConfig) (*BaiduCloudCDNDeployer, error) {
 
 func NewWithLogger(config *BaiduCloudCDNDeployerConfig, logger logger.Logger) (*BaiduCloudCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.SecretAccessKey)

internal/pkg/core/deployer/providers/baishan-cdn/baishan_cdn.go

@@ -34,11 +34,11 @@ func New(config *BaishanCDNDeployerConfig) (*BaishanCDNDeployer, error) {
 
 func NewWithLogger(config *BaishanCDNDeployerConfig, logger logger.Logger) (*BaishanCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.ApiToken)
@@ -111,6 +111,10 @@ func (d *BaishanCDNDeployer) Deploy(ctx context.Context, certPem string, privkey
 }
 
 func createSdkClient(apiToken string) (*bssdk.Client, error) {
+	if apiToken == "" {
+		return nil, errors.New("invalid baishan api token")
+	}
+
 	client := bssdk.NewClient(apiToken)
 	return client, nil
 }

internal/pkg/core/deployer/providers/baotapanel-console/baotapanel_console.go

@@ -3,6 +3,7 @@
 import (
 	"context"
 	"errors"
+	"net/url"
 
 	xerrors "github.com/pkg/errors"
 
@@ -34,11 +35,11 @@ func New(config *BaotaPanelConsoleDeployerConfig) (*BaotaPanelConsoleDeployer, e
 
 func NewWithLogger(config *BaotaPanelConsoleDeployerConfig, logger logger.Logger) (*BaotaPanelConsoleDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.ApiUrl, config.ApiKey)
@@ -82,6 +83,14 @@ func (d *BaotaPanelConsoleDeployer) Deploy(ctx context.Context, certPem string,
 }
 
 func createSdkClient(apiUrl, apiKey string) (*btsdk.Client, error) {
+	if _, err := url.Parse(apiUrl); err != nil {
+		return nil, errors.New("invalid baota api url")
+	}
+
+	if apiKey == "" {
+		return nil, errors.New("invalid baota api key")
+	}
+
 	client := btsdk.NewClient(apiUrl, apiKey)
 	return client, nil
 }

internal/pkg/core/deployer/providers/baotapanel-console/baotapanel_console_test.go

@@ -33,8 +33,8 @@ Shell command to run this test:
 	go test -v ./baotapanel_console_test.go -args \
 	--CERTIMATE_DEPLOYER_BAOTAPANELCONSOLE_INPUTCERTPATH="/path/to/your-input-cert.pem" \
 	--CERTIMATE_DEPLOYER_BAOTAPANELCONSOLE_INPUTKEYPATH="/path/to/your-input-key.pem" \
-	--CERTIMATE_DEPLOYER_BAOTAPANELCONSOLE_APIURL="your-baota-panel-url" \
-	--CERTIMATE_DEPLOYER_BAOTAPANELCONSOLE_APIKEY="your-baota-panel-key"
+	--CERTIMATE_DEPLOYER_BAOTAPANELCONSOLE_APIURL="http://127.0.0.1:8888" \
+	--CERTIMATE_DEPLOYER_BAOTAPANELCONSOLE_APIKEY="your-api-key"
 */
 func TestDeploy(t *testing.T) {
 	flag.Parse()

internal/pkg/core/deployer/providers/baotapanel-site/baotapanel_site.go

@@ -3,6 +3,7 @@
 import (
 	"context"
 	"errors"
+	"net/url"
 
 	xerrors "github.com/pkg/errors"
 
@@ -34,11 +35,11 @@ func New(config *BaotaPanelSiteDeployerConfig) (*BaotaPanelSiteDeployer, error)
 
 func NewWithLogger(config *BaotaPanelSiteDeployerConfig, logger logger.Logger) (*BaotaPanelSiteDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.ApiUrl, config.ApiKey)
@@ -76,6 +77,14 @@ func (d *BaotaPanelSiteDeployer) Deploy(ctx context.Context, certPem string, pri
 }
 
 func createSdkClient(apiUrl, apiKey string) (*btsdk.Client, error) {
+	if _, err := url.Parse(apiUrl); err != nil {
+		return nil, errors.New("invalid baota api url")
+	}
+
+	if apiKey == "" {
+		return nil, errors.New("invalid baota api key")
+	}
+
 	client := btsdk.NewClient(apiUrl, apiKey)
 	return client, nil
 }

internal/pkg/core/deployer/providers/baotapanel-site/baotapanel_site_test.go

@@ -35,9 +35,9 @@ Shell command to run this test:
 	go test -v ./baotapanel_site_test.go -args \
 	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_INPUTCERTPATH="/path/to/your-input-cert.pem" \
 	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_INPUTKEYPATH="/path/to/your-input-key.pem" \
-	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_APIURL="your-baota-panel-url" \
-	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_APIKEY="your-baota-panel-key" \
-	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_SITENAME="your-baota-site-name"
+	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_APIURL="http://127.0.0.1:8888" \
+	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_APIKEY="your-api-key" \
+	--CERTIMATE_DEPLOYER_BAOTAPANELSITE_SITENAME="your-site-name"
 */
 func TestDeploy(t *testing.T) {
 	flag.Parse()

internal/pkg/core/deployer/providers/byteplus-cdn/byteplus_cdn.go

@@ -39,11 +39,11 @@ func New(config *BytePlusCDNDeployerConfig) (*BytePlusCDNDeployer, error) {
 
 func NewWithLogger(config *BytePlusCDNDeployerConfig, logger logger.Logger) (*BytePlusCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client := bpCdn.NewInstance()

internal/pkg/core/deployer/providers/cachefly/cachefly.go

@@ -30,11 +30,11 @@ func New(config *CacheFlyDeployerConfig) (*CacheFlyDeployer, error) {
 
 func NewWithLogger(config *CacheFlyDeployerConfig, logger logger.Logger) (*CacheFlyDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.ApiToken)
@@ -66,6 +66,10 @@ func (d *CacheFlyDeployer) Deploy(ctx context.Context, certPem string, privkeyPe
 }
 
 func createSdkClient(apiToken string) (*cfsdk.Client, error) {
+	if apiToken == "" {
+		return nil, errors.New("invalid cachefly api token")
+	}
+
 	client := cfsdk.NewClient(apiToken)
 	return client, nil
 }

internal/pkg/core/deployer/providers/cachefly/cachefly_test.go

@@ -31,7 +31,7 @@ Shell command to run this test:
 	go test -v ./cachefly_test.go -args \
 	--CERTIMATE_DEPLOYER_CACHEFLY_INPUTCERTPATH="/path/to/your-input-cert.pem" \
 	--CERTIMATE_DEPLOYER_CACHEFLY_INPUTKEYPATH="/path/to/your-input-key.pem" \
-	--CERTIMATE_DEPLOYER_CACHEFLY_APITOKEN="your-baota-panel-key"
+	--CERTIMATE_DEPLOYER_CACHEFLY_APITOKEN="your-api-token"
 */
 func TestDeploy(t *testing.T) {
 	flag.Parse()

internal/pkg/core/deployer/providers/cdnfly/cdnfly.go

@@ -0,0 +1,180 @@
+package cdnfly
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"net/url"
+	"time"
+
+	xerrors "github.com/pkg/errors"
+
+	"github.com/usual2970/certimate/internal/pkg/core/deployer"
+	"github.com/usual2970/certimate/internal/pkg/core/logger"
+	cfsdk "github.com/usual2970/certimate/internal/pkg/vendors/cdnfly-sdk"
+)
+
+type CdnflyDeployerConfig struct {
+	// Cdnfly 地址。
+	ApiUrl string `json:"apiUrl"`
+	// Cdnfly 用户端 API Key。
+	ApiKey string `json:"apiKey"`
+	// Cdnfly 用户端 API Secret。
+	ApiSecret string `json:"apiSecret"`
+	// 部署资源类型。
+	ResourceType ResourceType `json:"resourceType"`
+	// 网站 ID。
+	// 部署资源类型为 [RESOURCE_TYPE_SITE] 时必填。
+	SiteId string `json:"siteId,omitempty"`
+	// 证书 ID。
+	// 部署资源类型为 [RESOURCE_TYPE_CERTIFICATE] 时必填。
+	CertificateId string `json:"certificateId,omitempty"`
+}
+
+type CdnflyDeployer struct {
+	config    *CdnflyDeployerConfig
+	logger    logger.Logger
+	sdkClient *cfsdk.Client
+}
+
+var _ deployer.Deployer = (*CdnflyDeployer)(nil)
+
+func New(config *CdnflyDeployerConfig) (*CdnflyDeployer, error) {
+	return NewWithLogger(config, logger.NewNilLogger())
+}
+
+func NewWithLogger(config *CdnflyDeployerConfig, logger logger.Logger) (*CdnflyDeployer, error) {
+	if config == nil {
+		panic("config is nil")
+	}
+
+	if logger == nil {
+		panic("logger is nil")
+	}
+
+	client, err := createSdkClient(config.ApiUrl, config.ApiKey, config.ApiSecret)
+	if err != nil {
+		return nil, xerrors.Wrap(err, "failed to create sdk client")
+	}
+
+	return &CdnflyDeployer{
+		logger:    logger,
+		config:    config,
+		sdkClient: client,
+	}, nil
+}
+
+func (d *CdnflyDeployer) Deploy(ctx context.Context, certPem string, privkeyPem string) (*deployer.DeployResult, error) {
+	// 根据部署资源类型决定部署方式
+	switch d.config.ResourceType {
+	case RESOURCE_TYPE_SITE:
+		if err := d.deployToSite(ctx, certPem, privkeyPem); err != nil {
+			return nil, err
+		}
+
+	case RESOURCE_TYPE_CERTIFICATE:
+		if err := d.deployToCertificate(ctx, certPem, privkeyPem); err != nil {
+			return nil, err
+		}
+
+	default:
+		return nil, fmt.Errorf("unsupported resource type: %s", d.config.ResourceType)
+	}
+
+	return &deployer.DeployResult{}, nil
+}
+
+func (d *CdnflyDeployer) deployToSite(ctx context.Context, certPem string, privkeyPem string) error {
+	if d.config.SiteId == "" {
+		return errors.New("config `siteId` is required")
+	}
+
+	// 获取单个网站详情
+	// REF: https://doc.cdnfly.cn/wangzhanguanli-v1-sites.html#%E8%8E%B7%E5%8F%96%E5%8D%95%E4%B8%AA%E7%BD%91%E7%AB%99%E8%AF%A6%E6%83%85
+	getSiteReq := &cfsdk.GetSiteRequest{
+		Id: d.config.SiteId,
+	}
+	getSiteResp, err := d.sdkClient.GetSite(getSiteReq)
+	if err != nil {
+		return xerrors.Wrap(err, "failed to execute sdk request 'cdnfly.GetSite'")
+	} else {
+		d.logger.Logt("已获取网站详情", getSiteResp)
+	}
+
+	// 添加单个证书
+	// REF: https://doc.cdnfly.cn/wangzhanzhengshu-v1-certs.html#%E6%B7%BB%E5%8A%A0%E5%8D%95%E4%B8%AA%E6%88%96%E5%A4%9A%E4%B8%AA%E8%AF%81%E4%B9%A6-%E5%A4%9A%E4%B8%AA%E8%AF%81%E4%B9%A6%E6%97%B6%E6%95%B0%E6%8D%AE%E6%A0%BC%E5%BC%8F%E4%B8%BA%E6%95%B0%E7%BB%84
+	createCertificateReq := &cfsdk.CreateCertificateRequest{
+		Name: fmt.Sprintf("certimate-%d", time.Now().UnixMilli()),
+		Type: "custom",
+		Cert: certPem,
+		Key:  privkeyPem,
+	}
+	createCertificateResp, err := d.sdkClient.CreateCertificate(createCertificateReq)
+	if err != nil {
+		return xerrors.Wrap(err, "failed to execute sdk request 'cdnfly.CreateCertificate'")
+	} else {
+		d.logger.Logt("已添加证书", createCertificateResp)
+	}
+
+	// 修改单个网站
+	// REF: https://doc.cdnfly.cn/wangzhanguanli-v1-sites.html#%E4%BF%AE%E6%94%B9%E5%8D%95%E4%B8%AA%E7%BD%91%E7%AB%99
+	updateSiteHttpsListenMap := make(map[string]any)
+	_ = json.Unmarshal([]byte(getSiteResp.Data.HttpsListen), &updateSiteHttpsListenMap)
+	updateSiteHttpsListenMap["cert"] = createCertificateResp.Data
+	updateSiteHttpsListenData, _ := json.Marshal(updateSiteHttpsListenMap)
+	updateSiteHttpsListen := string(updateSiteHttpsListenData)
+	updateSiteReq := &cfsdk.UpdateSiteRequest{
+		Id:          d.config.SiteId,
+		HttpsListen: &updateSiteHttpsListen,
+	}
+	updateSiteResp, err := d.sdkClient.UpdateSite(updateSiteReq)
+	if err != nil {
+		return xerrors.Wrap(err, "failed to execute sdk request 'cdnfly.UpdateSite'")
+	} else {
+		d.logger.Logt("已修改网站", updateSiteResp)
+	}
+
+	return nil
+}
+
+func (d *CdnflyDeployer) deployToCertificate(ctx context.Context, certPem string, privkeyPem string) error {
+	if d.config.CertificateId == "" {
+		return errors.New("config `certificateId` is required")
+	}
+
+	// 修改单个证书
+	// REF: https://doc.cdnfly.cn/wangzhanzhengshu-v1-certs.html#%E4%BF%AE%E6%94%B9%E5%8D%95%E4%B8%AA%E8%AF%81%E4%B9%A6
+	updateCertificateType := "custom"
+	updateCertificateReq := &cfsdk.UpdateCertificateRequest{
+		Id:   d.config.CertificateId,
+		Type: &updateCertificateType,
+		Cert: &certPem,
+		Key:  &privkeyPem,
+	}
+	updateCertificateResp, err := d.sdkClient.UpdateCertificate(updateCertificateReq)
+	if err != nil {
+		return xerrors.Wrap(err, "failed to execute sdk request 'cdnfly.UpdateCertificate'")
+	} else {
+		d.logger.Logt("已修改证书", updateCertificateResp)
+	}
+
+	return nil
+}
+
+func createSdkClient(apiUrl, apiKey, apiSecret string) (*cfsdk.Client, error) {
+	if _, err := url.Parse(apiUrl); err != nil {
+		return nil, errors.New("invalid cachefly api url")
+	}
+
+	if apiKey == "" {
+		return nil, errors.New("invalid cachefly api key")
+	}
+
+	if apiSecret == "" {
+		return nil, errors.New("invalid cachefly api secret")
+	}
+
+	client := cfsdk.NewClient(apiUrl, apiKey, apiSecret)
+	return client, nil
+}

internal/pkg/core/deployer/providers/cdnfly/cdnfly_test.go

@@ -0,0 +1,81 @@
+package cdnfly_test
+
+import (
+	"context"
+	"flag"
+	"fmt"
+	"os"
+	"strings"
+	"testing"
+
+	provider "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/cdnfly"
+)
+
+var (
+	fInputCertPath string
+	fInputKeyPath  string
+	fApiUrl        string
+	fApiKey        string
+	fApiSecret     string
+	fCertificateId string
+)
+
+func init() {
+	argsPrefix := "CERTIMATE_DEPLOYER_CDNFLY_"
+
+	flag.StringVar(&fInputCertPath, argsPrefix+"INPUTCERTPATH", "", "")
+	flag.StringVar(&fInputKeyPath, argsPrefix+"INPUTKEYPATH", "", "")
+	flag.StringVar(&fApiUrl, argsPrefix+"APIURL", "", "")
+	flag.StringVar(&fApiKey, argsPrefix+"APIKEY", "", "")
+	flag.StringVar(&fApiSecret, argsPrefix+"APISECRET", "", "")
+	flag.StringVar(&fCertificateId, argsPrefix+"CERTIFICATEID", "", "")
+}
+
+/*
+Shell command to run this test:
+
+	go test -v ./cdnfly_test.go -args \
+	--CERTIMATE_DEPLOYER_CDNFLY_INPUTCERTPATH="/path/to/your-input-cert.pem" \
+	--CERTIMATE_DEPLOYER_CDNFLY_INPUTKEYPATH="/path/to/your-input-key.pem" \
+	--CERTIMATE_DEPLOYER_CDNFLY_APIURL="http://127.0.0.1:88" \
+	--CERTIMATE_DEPLOYER_CDNFLY_APIKEY="your-api-key" \
+	--CERTIMATE_DEPLOYER_CDNFLY_APISECRET="your-api-secret" \
+	--CERTIMATE_DEPLOYER_CDNFLY_CERTIFICATEID="your-cert-id"
+*/
+func TestDeploy(t *testing.T) {
+	flag.Parse()
+
+	t.Run("Deploy", func(t *testing.T) {
+		t.Log(strings.Join([]string{
+			"args:",
+			fmt.Sprintf("INPUTCERTPATH: %v", fInputCertPath),
+			fmt.Sprintf("INPUTKEYPATH: %v", fInputKeyPath),
+			fmt.Sprintf("APIURL: %v", fApiUrl),
+			fmt.Sprintf("APIKEY: %v", fApiKey),
+			fmt.Sprintf("APISECRET: %v", fApiSecret),
+			fmt.Sprintf("CERTIFICATEID: %v", fCertificateId),
+		}, "\n"))
+
+		deployer, err := provider.New(&provider.CdnflyDeployerConfig{
+			ApiUrl:        fApiUrl,
+			ApiKey:        fApiKey,
+			ApiSecret:     fApiSecret,
+			ResourceType:  provider.RESOURCE_TYPE_CERTIFICATE,
+			CertificateId: fCertificateId,
+		})
+		if err != nil {
+			t.Errorf("err: %+v", err)
+			return
+		}
+
+		fInputCertData, _ := os.ReadFile(fInputCertPath)
+		fInputKeyData, _ := os.ReadFile(fInputKeyPath)
+		res, err := deployer.Deploy(context.Background(), string(fInputCertData), string(fInputKeyData))
+		if err != nil {
+			t.Errorf("err: %+v", err)
+			return
+		}
+
+		t.Logf("ok: %v", res)
+	})
+}

internal/pkg/core/deployer/providers/cdnfly/consts.go

@@ -0,0 +1,10 @@
+package cdnfly
+
+type ResourceType string
+
+const (
+	// 资源类型：替换指定网站的证书。
+	RESOURCE_TYPE_SITE = ResourceType("site")
+	// 资源类型：替换指定证书。
+	RESOURCE_TYPE_CERTIFICATE = ResourceType("certificate")
+)

internal/pkg/core/deployer/providers/dogecloud-cdn/dogecloud_cdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"strconv"
 
 	xerrors "github.com/pkg/errors"
@@ -38,11 +37,11 @@ func New(config *DogeCloudCDNDeployerConfig) (*DogeCloudCDNDeployer, error) {
 
 func NewWithLogger(config *DogeCloudCDNDeployerConfig, logger logger.Logger) (*DogeCloudCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client := dogesdk.NewClient(config.AccessKey, config.SecretKey)

internal/pkg/core/deployer/providers/edgio-applications/edgio_applications.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	xerrors "github.com/pkg/errors"
 
@@ -36,11 +35,11 @@ func New(config *EdgioApplicationsDeployerConfig) (*EdgioApplicationsDeployer, e
 
 func NewWithLogger(config *EdgioApplicationsDeployerConfig, logger logger.Logger) (*EdgioApplicationsDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.ClientId, config.ClientSecret)

internal/pkg/core/deployer/providers/gcore-cdn/gcore_cdn.go

@@ -38,11 +38,11 @@ func New(config *GcoreCDNDeployerConfig) (*GcoreCDNDeployer, error) {
 
 func NewWithLogger(config *GcoreCDNDeployerConfig, logger logger.Logger) (*GcoreCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.ApiToken)
@@ -114,6 +114,10 @@ func (d *GcoreCDNDeployer) Deploy(ctx context.Context, certPem string, privkeyPe
 }
 
 func createSdkClient(apiToken string) (*gresources.Service, error) {
+	if apiToken == "" {
+		return nil, errors.New("invalid gcore api token")
+	}
+
 	requester := gprovider.NewClient(
 		gcoresdk.BASE_URL,
 		gprovider.WithSigner(gcoresdk.NewAuthRequestSigner(apiToken)),

internal/pkg/core/deployer/providers/huaweicloud-cdn/huaweicloud_cdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/global"
 	hcCdn "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/cdn/v2"
@@ -43,11 +42,11 @@ func New(config *HuaweiCloudCDNDeployerConfig) (*HuaweiCloudCDNDeployer, error)
 
 func NewWithLogger(config *HuaweiCloudCDNDeployerConfig, logger logger.Logger) (*HuaweiCloudCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/deployer/providers/huaweicloud-elb/huaweicloud_elb.go

@@ -58,11 +58,11 @@ func New(config *HuaweiCloudELBDeployerConfig) (*HuaweiCloudELBDeployer, error)
 
 func NewWithLogger(config *HuaweiCloudELBDeployerConfig, logger logger.Logger) (*HuaweiCloudELBDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.SecretAccessKey, config.Region)

internal/pkg/core/deployer/providers/huaweicloud-waf/huaweicloud_waf.go

@@ -55,11 +55,11 @@ func New(config *HuaweiCloudWAFDeployerConfig) (*HuaweiCloudWAFDeployer, error)
 
 func NewWithLogger(config *HuaweiCloudWAFDeployerConfig, logger logger.Logger) (*HuaweiCloudWAFDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.SecretAccessKey, config.Region)

internal/pkg/core/deployer/providers/k8s-secret/k8s_secret.go

@@ -45,11 +45,11 @@ func New(config *K8sSecretDeployerConfig) (*K8sSecretDeployer, error) {
 
 func NewWithLogger(config *K8sSecretDeployerConfig, logger logger.Logger) (*K8sSecretDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	return &K8sSecretDeployer{

internal/pkg/core/deployer/providers/local/local.go

@@ -3,7 +3,6 @@ package local
 import (
 	"bytes"
 	"context"
-	"errors"
 	"fmt"
 	"os/exec"
 	"runtime"
@@ -57,11 +56,11 @@ func New(config *LocalDeployerConfig) (*LocalDeployer, error) {
 
 func NewWithLogger(config *LocalDeployerConfig, logger logger.Logger) (*LocalDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	return &LocalDeployer{

internal/pkg/core/deployer/providers/qiniu-cdn/qiniu_cdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"strings"
 
 	xerrors "github.com/pkg/errors"
@@ -39,11 +38,11 @@ func New(config *QiniuCDNDeployerConfig) (*QiniuCDNDeployer, error) {
 
 func NewWithLogger(config *QiniuCDNDeployerConfig, logger logger.Logger) (*QiniuCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client := qiniusdk.NewClient(auth.New(config.AccessKey, config.SecretKey))

internal/pkg/core/deployer/providers/qiniu-pili/qiniu_pili.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	xerrors "github.com/pkg/errors"
 	"github.com/qiniu/go-sdk/v7/pili"
@@ -39,11 +38,11 @@ func New(config *QiniuPiliDeployerConfig) (*QiniuPiliDeployer, error) {
 
 func NewWithLogger(config *QiniuPiliDeployerConfig, logger logger.Logger) (*QiniuPiliDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	manager := pili.NewManager(pili.ManagerConfig{AccessKey: config.AccessKey, SecretKey: config.SecretKey})

internal/pkg/core/deployer/providers/safeline/safeline.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"net/url"
 
 	xerrors "github.com/pkg/errors"
 
@@ -38,11 +39,11 @@ func New(config *SafeLineDeployerConfig) (*SafeLineDeployer, error) {
 
 func NewWithLogger(config *SafeLineDeployerConfig, logger logger.Logger) (*SafeLineDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.ApiUrl, config.ApiToken)
@@ -97,6 +98,14 @@ func (d *SafeLineDeployer) deployToCertificate(ctx context.Context, certPem stri
 }
 
 func createSdkClient(apiUrl, apiToken string) (*safelinesdk.Client, error) {
+	if _, err := url.Parse(apiUrl); err != nil {
+		return nil, errors.New("invalid safeline api url")
+	}
+
+	if apiToken == "" {
+		return nil, errors.New("invalid safeline api token")
+	}
+
 	client := safelinesdk.NewClient(apiUrl, apiToken)
 	return client, nil
 }

internal/pkg/core/deployer/providers/safeline/safeline_test.go

@@ -35,8 +35,8 @@ Shell command to run this test:
 	go test -v ./safeline_test.go -args \
 	--CERTIMATE_DEPLOYER_SAFELINE_INPUTCERTPATH="/path/to/your-input-cert.pem" \
 	--CERTIMATE_DEPLOYER_SAFELINE_INPUTKEYPATH="/path/to/your-input-key.pem" \
-	--CERTIMATE_DEPLOYER_SAFELINE_APIURL="your-safeline-url" \
-	--CERTIMATE_DEPLOYER_SAFELINE_APITOKEN="your-safeline-api-token" \
+	--CERTIMATE_DEPLOYER_SAFELINE_APIURL="http://127.0.0.1:9443" \
+	--CERTIMATE_DEPLOYER_SAFELINE_APITOKEN="your-api-token" \
 	--CERTIMATE_DEPLOYER_SAFELINE_CERTIFICATEID="your-cerficiate-id"
 */
 func TestDeploy(t *testing.T) {

internal/pkg/core/deployer/providers/ssh/ssh.go

@@ -3,7 +3,6 @@ package ssh
 import (
 	"bytes"
 	"context"
-	"errors"
 	"fmt"
 	"os"
 	"path/filepath"
@@ -72,11 +71,11 @@ func New(config *SshDeployerConfig) (*SshDeployer, error) {
 
 func NewWithLogger(config *SshDeployerConfig, logger logger.Logger) (*SshDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	return &SshDeployer{

internal/pkg/core/deployer/providers/tencentcloud-cdn/tencentcloud_cdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"strings"
 
 	xerrors "github.com/pkg/errors"
@@ -47,11 +46,11 @@ func New(config *TencentCloudCDNDeployerConfig) (*TencentCloudCDNDeployer, error
 
 func NewWithLogger(config *TencentCloudCDNDeployerConfig, logger logger.Logger) (*TencentCloudCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	clients, err := createSdkClients(config.SecretId, config.SecretKey)

internal/pkg/core/deployer/providers/tencentcloud-clb/tencentcloud_clb.go

@@ -57,11 +57,11 @@ func New(config *TencentCloudCLBDeployerConfig) (*TencentCloudCLBDeployer, error
 
 func NewWithLogger(config *TencentCloudCLBDeployerConfig, logger logger.Logger) (*TencentCloudCLBDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	clients, err := createSdkClients(config.SecretId, config.SecretKey, config.Region)

internal/pkg/core/deployer/providers/tencentcloud-cos/tencentcloud_cos.go

@@ -44,11 +44,11 @@ func New(config *TencentCloudCOSDeployerConfig) (*TencentCloudCOSDeployer, error
 
 func NewWithLogger(config *TencentCloudCOSDeployerConfig, logger logger.Logger) (*TencentCloudCOSDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.SecretId, config.SecretKey, config.Region)

internal/pkg/core/deployer/providers/tencentcloud-css/tencentcloud_css.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	xerrors "github.com/pkg/errors"
 	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
@@ -39,11 +38,11 @@ func New(config *TencentCloudCSSDeployerConfig) (*TencentCloudCSSDeployer, error
 
 func NewWithLogger(config *TencentCloudCSSDeployerConfig, logger logger.Logger) (*TencentCloudCSSDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.SecretId, config.SecretKey)

internal/pkg/core/deployer/providers/tencentcloud-ecdn/tencentcloud_ecdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"strings"
 
 	xerrors "github.com/pkg/errors"
@@ -46,11 +45,11 @@ func New(config *TencentCloudECDNDeployerConfig) (*TencentCloudECDNDeployer, err
 
 func NewWithLogger(config *TencentCloudECDNDeployerConfig, logger logger.Logger) (*TencentCloudECDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	clients, err := createSdkClients(config.SecretId, config.SecretKey)

internal/pkg/core/deployer/providers/tencentcloud-eo/tencentcloud_eo.go

@@ -47,11 +47,11 @@ func New(config *TencentCloudEODeployerConfig) (*TencentCloudEODeployer, error)
 
 func NewWithLogger(config *TencentCloudEODeployerConfig, logger logger.Logger) (*TencentCloudEODeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	clients, err := createSdkClients(config.SecretId, config.SecretKey)

internal/pkg/core/deployer/providers/tencentcloud-ssl-deploy/tencentcloud_ssl_deploy.go

@@ -45,11 +45,11 @@ func New(config *TencentCloudSSLDeployDeployerConfig) (*TencentCloudSSLDeployDep
 
 func NewWithLogger(config *TencentCloudSSLDeployDeployerConfig, logger logger.Logger) (*TencentCloudSSLDeployDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.SecretId, config.SecretKey, config.Region)

internal/pkg/core/deployer/providers/tencentcloud-waf/tencentcloud_waf.go

@@ -45,11 +45,11 @@ func New(config *TencentCloudWAFDeployerConfig) (*TencentCloudWAFDeployer, error
 
 func NewWithLogger(config *TencentCloudWAFDeployerConfig, logger logger.Logger) (*TencentCloudWAFDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.SecretId, config.SecretKey, config.Region)

internal/pkg/core/deployer/providers/ucloud-ucdn/ucloud_ucdn.go

@@ -42,11 +42,11 @@ func New(config *UCloudUCDNDeployerConfig) (*UCloudUCDNDeployer, error) {
 
 func NewWithLogger(config *UCloudUCDNDeployerConfig, logger logger.Logger) (*UCloudUCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.PrivateKey, config.PublicKey)

internal/pkg/core/deployer/providers/ucloud-us3/ucloud_us3.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	xerrors "github.com/pkg/errors"
 	usdk "github.com/ucloud/ucloud-sdk-go/ucloud"
@@ -45,11 +44,11 @@ func New(config *UCloudUS3DeployerConfig) (*UCloudUS3Deployer, error) {
 
 func NewWithLogger(config *UCloudUS3DeployerConfig, logger logger.Logger) (*UCloudUS3Deployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.PrivateKey, config.PublicKey, config.Region)

internal/pkg/core/deployer/providers/volcengine-cdn/volcengine_cdn.go

@@ -39,11 +39,11 @@ func New(config *VolcEngineCDNDeployerConfig) (*VolcEngineCDNDeployer, error) {
 
 func NewWithLogger(config *VolcEngineCDNDeployerConfig, logger logger.Logger) (*VolcEngineCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client := veCdn.NewInstance()

internal/pkg/core/deployer/providers/volcengine-clb/volcengine_clb.go

@@ -45,11 +45,11 @@ func New(config *VolcEngineCLBDeployerConfig) (*VolcEngineCLBDeployer, error) {
 
 func NewWithLogger(config *VolcEngineCLBDeployerConfig, logger logger.Logger) (*VolcEngineCLBDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/volcengine-dcdn/volcengine_dcdn.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"strings"
 
 	xerrors "github.com/pkg/errors"
@@ -42,11 +41,11 @@ func New(config *VolcEngineDCDNDeployerConfig) (*VolcEngineDCDNDeployer, error)
 
 func NewWithLogger(config *VolcEngineDCDNDeployerConfig, logger logger.Logger) (*VolcEngineDCDNDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/volcengine-imagex/volcengine_imagex.go

@@ -42,11 +42,11 @@ func New(config *VolcEngineImageXDeployerConfig) (*VolcEngineImageXDeployer, err
 
 func NewWithLogger(config *VolcEngineImageXDeployerConfig, logger logger.Logger) (*VolcEngineImageXDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/volcengine-live/volcengine_live.go

@@ -40,11 +40,11 @@ func New(config *VolcEngineLiveDeployerConfig) (*VolcEngineLiveDeployer, error)
 
 func NewWithLogger(config *VolcEngineLiveDeployerConfig, logger logger.Logger) (*VolcEngineLiveDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client := veLive.NewInstance()

internal/pkg/core/deployer/providers/volcengine-tos/volcengine_tos.go

@@ -42,11 +42,11 @@ func New(config *VolcEngineTOSDeployerConfig) (*VolcEngineTOSDeployer, error) {
 
 func NewWithLogger(config *VolcEngineTOSDeployerConfig, logger logger.Logger) (*VolcEngineTOSDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/deployer/providers/webhook/webhook.go

@@ -3,7 +3,6 @@ package webhook
 import (
 	"context"
 	"encoding/json"
-	"errors"
 	"strings"
 	"time"
 
@@ -36,11 +35,11 @@ func New(config *WebhookDeployerConfig) (*WebhookDeployer, error) {
 
 func NewWithLogger(config *WebhookDeployerConfig, logger logger.Logger) (*WebhookDeployer, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	if logger == nil {
-		return nil, errors.New("logger is nil")
+		panic("logger is nil")
 	}
 
 	client := resty.New().

internal/pkg/core/notifier/providers/bark/bark.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	"github.com/nikoksr/notify"
 	"github.com/nikoksr/notify/service/bark"
@@ -26,7 +25,7 @@ var _ notifier.Notifier = (*BarkNotifier)(nil)
 
 func New(config *BarkNotifierConfig) (*BarkNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &BarkNotifier{

internal/pkg/core/notifier/providers/dingtalk/dingtalk.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	"github.com/nikoksr/notify/service/dingding"
 
@@ -24,7 +23,7 @@ var _ notifier.Notifier = (*DingTalkNotifier)(nil)
 
 func New(config *DingTalkNotifierConfig) (*DingTalkNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &DingTalkNotifier{

internal/pkg/core/notifier/providers/email/email.go

@@ -3,7 +3,6 @@
 import (
 	"context"
 	"crypto/tls"
-	"errors"
 	"fmt"
 	"net/smtp"
 
@@ -38,7 +37,7 @@ var _ notifier.Notifier = (*EmailNotifier)(nil)
 
 func New(config *EmailNotifierConfig) (*EmailNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &EmailNotifier{

internal/pkg/core/notifier/providers/lark/lark.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	"github.com/nikoksr/notify/service/lark"
 
@@ -22,7 +21,7 @@ var _ notifier.Notifier = (*LarkNotifier)(nil)
 
 func New(config *LarkNotifierConfig) (*LarkNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &LarkNotifier{

internal/pkg/core/notifier/providers/serverchan/serverchan.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"net/http"
 
 	notifyHttp "github.com/nikoksr/notify/service/http"
@@ -23,7 +22,7 @@ var _ notifier.Notifier = (*ServerChanNotifier)(nil)
 
 func New(config *ServerChanNotifierConfig) (*ServerChanNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &ServerChanNotifier{

internal/pkg/core/notifier/providers/telegram/telegram.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	"github.com/nikoksr/notify/service/telegram"
 
@@ -24,7 +23,7 @@ var _ notifier.Notifier = (*TelegramNotifier)(nil)
 
 func New(config *TelegramNotifierConfig) (*TelegramNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &TelegramNotifier{

internal/pkg/core/notifier/providers/webhook/webhook.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	"github.com/nikoksr/notify/service/http"
 
@@ -22,7 +21,7 @@ var _ notifier.Notifier = (*WebhookNotifier)(nil)
 
 func New(config *WebhookNotifierConfig) (*WebhookNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &WebhookNotifier{

internal/pkg/core/notifier/providers/wecom/wecom.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"net/http"
 
 	notifyHttp "github.com/nikoksr/notify/service/http"
@@ -23,7 +22,7 @@ var _ notifier.Notifier = (*WeComNotifier)(nil)
 
 func New(config *WeComNotifierConfig) (*WeComNotifier, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	return &WeComNotifier{

internal/pkg/core/uploader/providers/aliyun-cas/aliyun_cas.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -34,7 +33,7 @@ var _ uploader.Uploader = (*AliyunCASUploader)(nil)
 
 func New(config *AliyunCASUploaderConfig) (*AliyunCASUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/aliyun-slb/aliyun_slb.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"crypto/sha256"
 	"encoding/hex"
-	"errors"
 	"fmt"
 	"regexp"
 	"strings"
@@ -37,7 +36,7 @@ var _ uploader.Uploader = (*AliyunSLBUploader)(nil)
 
 func New(config *AliyunSLBUploaderConfig) (*AliyunSLBUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/aws-acm/aws_acm.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"time"
 
@@ -34,7 +33,7 @@ var _ uploader.Uploader = (*AWSCertificateManagerUploader)(nil)
 
 func New(config *AWSCertificateManagerUploaderConfig) (*AWSCertificateManagerUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.SecretAccessKey, config.Region)

internal/pkg/core/uploader/providers/byteplus-cdn/byteplus_cdn.go

@@ -5,7 +5,6 @@ import (
 	"crypto/sha1"
 	"crypto/sha256"
 	"encoding/hex"
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -33,7 +32,7 @@ var _ uploader.Uploader = (*ByteplusCDNUploader)(nil)
 
 func New(config *ByteplusCDNUploaderConfig) (*ByteplusCDNUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client := bpCdn.NewInstance()

internal/pkg/core/uploader/providers/dogecloud/dogecloud.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"time"
 
@@ -28,7 +27,7 @@ var _ uploader.Uploader = (*DogeCloudUploader)(nil)
 
 func New(config *DogeCloudUploaderConfig) (*DogeCloudUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/gcore-cdn/gcore_cdn.go

@@ -28,7 +28,7 @@ var _ uploader.Uploader = (*GcoreCDNUploader)(nil)
 
 func New(config *GcoreCDNUploaderConfig) (*GcoreCDNUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(config.ApiToken)
@@ -70,6 +70,10 @@ func (u *GcoreCDNUploader) Upload(ctx context.Context, certPem string, privkeyPe
 }
 
 func createSdkClient(apiToken string) (*gsslcerts.Service, error) {
+	if apiToken == "" {
+		return nil, errors.New("invalid gcore api token")
+	}
+
 	requester := gprovider.NewClient(
 		gcoresdk.BASE_URL,
 		gprovider.WithSigner(gcoresdk.NewAuthRequestSigner(apiToken)),

internal/pkg/core/uploader/providers/huaweicloud-elb/huaweicloud_elb.go

@@ -39,7 +39,7 @@ var _ uploader.Uploader = (*HuaweiCloudELBUploader)(nil)
 
 func New(config *HuaweiCloudELBUploaderConfig) (*HuaweiCloudELBUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/huaweicloud-scm/huaweicloud_scm.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"time"
 
@@ -35,7 +34,7 @@ var _ uploader.Uploader = (*HuaweiCloudSCMUploader)(nil)
 
 func New(config *HuaweiCloudSCMUploaderConfig) (*HuaweiCloudSCMUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/huaweicloud-waf/huaweicloud_waf.go

@@ -39,7 +39,7 @@ var _ uploader.Uploader = (*HuaweiCloudWAFUploader)(nil)
 
 func New(config *HuaweiCloudWAFUploaderConfig) (*HuaweiCloudWAFUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/qiniu-sslcert/qiniu_sslcert.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"time"
 
@@ -30,7 +29,7 @@ var _ uploader.Uploader = (*QiniuSSLCertUploader)(nil)
 
 func New(config *QiniuSSLCertUploaderConfig) (*QiniuSSLCertUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/tencentcloud-ssl/tencentcloud_ssl.go

@@ -2,7 +2,6 @@
 
 import (
 	"context"
-	"errors"
 
 	xerrors "github.com/pkg/errors"
 	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
@@ -28,7 +27,7 @@ var _ uploader.Uploader = (*TencentCloudSSLUploader)(nil)
 
 func New(config *TencentCloudSSLUploaderConfig) (*TencentCloudSSLUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(

internal/pkg/core/uploader/providers/ucloud-ussl/ucloud_ussl.go

@@ -38,7 +38,7 @@ var _ uploader.Uploader = (*UCloudUSSLUploader)(nil)
 
 func New(config *UCloudUSSLUploaderConfig) (*UCloudUSSLUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(config.PrivateKey, config.PublicKey)

internal/pkg/core/uploader/providers/volcengine-cdn/volcengine_cdn.go

@@ -5,7 +5,6 @@ import (
 	"crypto/sha1"
 	"crypto/sha256"
 	"encoding/hex"
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -34,7 +33,7 @@ var _ uploader.Uploader = (*VolcEngineCDNUploader)(nil)
 
 func New(config *VolcEngineCDNUploaderConfig) (*VolcEngineCDNUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client := veCdn.NewInstance()

internal/pkg/core/uploader/providers/volcengine-certcenter/volcengine_certcenter.go

@@ -2,7 +2,6 @@ package volcenginecertcenter
 
 import (
 	"context"
-	"errors"
 
 	xerrors "github.com/pkg/errors"
 	ve "github.com/volcengine/volcengine-go-sdk/volcengine"
@@ -30,7 +29,7 @@ var _ uploader.Uploader = (*VolcEngineCertCenterUploader)(nil)
 
 func New(config *VolcEngineCertCenterUploaderConfig) (*VolcEngineCertCenterUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client, err := createSdkClient(config.AccessKeyId, config.AccessKeySecret, config.Region)

internal/pkg/core/uploader/providers/volcengine-live/volcengine_live.go

@@ -2,7 +2,6 @@ package volcenginelive
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -31,7 +30,7 @@ var _ uploader.Uploader = (*VolcEngineLiveUploader)(nil)
 
 func New(config *VolcEngineLiveUploaderConfig) (*VolcEngineLiveUploader, error) {
 	if config == nil {
-		return nil, errors.New("config is nil")
+		panic("config is nil")
 	}
 
 	client := veLive.NewInstance()

internal/pkg/vendors/baishan-sdk/client.go

@@ -30,11 +30,9 @@ func (c *Client) WithTimeout(timeout time.Duration) *Client {
 }
 
 func (c *Client) sendRequest(method string, path string, params map[string]any) (*resty.Response, error) {
-	url := "https://cdn.api.baishan.com" + path
-
 	req := c.client.R()
 	req.Method = method
-	req.URL = url
+	req.URL = "https://cdn.api.baishan.com" + path
 	if strings.EqualFold(method, http.MethodGet) {
 		data := make(map[string]string)
 		for k, v := range params {
@@ -68,8 +66,8 @@ func (c *Client) sendRequestWithResult(method string, path string, params map[st
 
 	if err := json.Unmarshal(resp.Body(), &result); err != nil {
 		return fmt.Errorf("baishan api error: failed to parse response: %w", err)
-	} else if result.GetCode() != 0 {
-		return fmt.Errorf("baishan api error: %d - %s", result.GetCode(), result.GetMessage())
+	} else if errcode := result.GetCode(); errcode != 0 {
+		return fmt.Errorf("baishan api error: %d - %s", errcode, result.GetMessage())
 	}
 
 	return nil