mirror of
https://github.com/usual2970/certimate.git
synced 2025-06-08 13:39:53 +00:00
592 lines
29 KiB
Go
592 lines
29 KiB
Go
package deployer
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/usual2970/certimate/internal/domain"
|
|
"github.com/usual2970/certimate/internal/pkg/core/deployer"
|
|
providerAliyunALB "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-alb"
|
|
providerAliyunCASDeploy "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-cas-deploy"
|
|
providerAliyunCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-cdn"
|
|
providerAliyunCLB "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-clb"
|
|
providerAliyunDCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-dcdn"
|
|
providerAliyunESA "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-esa"
|
|
providerAliyunLive "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-live"
|
|
providerAliyunNLB "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-nlb"
|
|
providerAliyunOSS "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-oss"
|
|
providerAliyunWAF "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aliyun-waf"
|
|
providerAWSCloudFront "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/aws-cloudfront"
|
|
providerBaiduCloudCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/baiducloud-cdn"
|
|
providerBaotaPanelSite "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/baotapanel-site"
|
|
providerBytePlusCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/byteplus-cdn"
|
|
providerDogeCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/dogecloud-cdn"
|
|
providerEdgioApplications "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/edgio-applications"
|
|
providerHuaweiCloudCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/huaweicloud-cdn"
|
|
providerHuaweiCloudELB "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/huaweicloud-elb"
|
|
providerK8sSecret "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/k8s-secret"
|
|
providerLocal "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/local"
|
|
providerQiniuCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/qiniu-cdn"
|
|
providerQiniuPili "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/qiniu-pili"
|
|
providerSSH "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/ssh"
|
|
providerTencentCloudCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/tencentcloud-cdn"
|
|
providerTencentCloudCLB "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/tencentcloud-clb"
|
|
providerTencentCloudCOS "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/tencentcloud-cos"
|
|
providerTencentCloudCSS "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/tencentcloud-css"
|
|
providerTencentCloudECDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/tencentcloud-ecdn"
|
|
providerTencentCloudEO "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/tencentcloud-eo"
|
|
providerTencentCloudSSLDeploy "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/tencentcloud-ssl-deploy"
|
|
providerUCloudUCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/ucloud-ucdn"
|
|
providerUCloudUS3 "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/ucloud-us3"
|
|
providerVolcEngineCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/volcengine-cdn"
|
|
providerVolcEngineCLB "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/volcengine-clb"
|
|
providerVolcEngineDCDN "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/volcengine-dcdn"
|
|
providerVolcEngineLive "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/volcengine-live"
|
|
providerVolcEngineTOS "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/volcengine-tos"
|
|
providerWebhook "github.com/usual2970/certimate/internal/pkg/core/deployer/providers/webhook"
|
|
"github.com/usual2970/certimate/internal/pkg/core/logger"
|
|
"github.com/usual2970/certimate/internal/pkg/utils/maps"
|
|
"github.com/usual2970/certimate/internal/pkg/utils/slices"
|
|
)
|
|
|
|
func createDeployer(options *deployerOptions) (deployer.Deployer, logger.Logger, error) {
|
|
logger := logger.NewDefaultLogger()
|
|
|
|
/*
|
|
注意：如果追加新的常量值，请保持以 ASCII 排序。
|
|
NOTICE: If you add new constant, please keep ASCII order.
|
|
*/
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeAliyunALB, domain.DeployProviderTypeAliyunCASDeploy, domain.DeployProviderTypeAliyunCDN, domain.DeployProviderTypeAliyunCLB, domain.DeployProviderTypeAliyunDCDN, domain.DeployProviderTypeAliyunESA, domain.DeployProviderTypeAliyunLive, domain.DeployProviderTypeAliyunNLB, domain.DeployProviderTypeAliyunOSS, domain.DeployProviderTypeAliyunWAF:
|
|
{
|
|
access := domain.AccessConfigForAliyun{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeAliyunALB:
|
|
deployer, err := providerAliyunALB.NewWithLogger(&providerAliyunALB.AliyunALBDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceType: providerAliyunALB.DeployResourceType(maps.GetValueAsString(options.ProviderDeployConfig, "resourceType")),
|
|
LoadbalancerId: maps.GetValueAsString(options.ProviderDeployConfig, "loadbalancerId"),
|
|
ListenerId: maps.GetValueAsString(options.ProviderDeployConfig, "listenerId"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunCASDeploy:
|
|
deployer, err := providerAliyunCASDeploy.NewWithLogger(&providerAliyunCASDeploy.AliyunCASDeployDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceIds: slices.Filter(strings.Split(maps.GetValueAsString(options.ProviderDeployConfig, "resourceIds"), ";"), func(s string) bool { return s != "" }),
|
|
ContactIds: slices.Filter(strings.Split(maps.GetValueAsString(options.ProviderDeployConfig, "contactIds"), ";"), func(s string) bool { return s != "" }),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunCDN:
|
|
deployer, err := providerAliyunCDN.NewWithLogger(&providerAliyunCDN.AliyunCDNDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunCLB:
|
|
deployer, err := providerAliyunCLB.NewWithLogger(&providerAliyunCLB.AliyunCLBDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceType: providerAliyunCLB.DeployResourceType(maps.GetValueAsString(options.ProviderDeployConfig, "resourceType")),
|
|
LoadbalancerId: maps.GetValueAsString(options.ProviderDeployConfig, "loadbalancerId"),
|
|
ListenerPort: maps.GetValueOrDefaultAsInt32(options.ProviderDeployConfig, "listenerPort", 443),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunDCDN:
|
|
deployer, err := providerAliyunDCDN.NewWithLogger(&providerAliyunDCDN.AliyunDCDNDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunESA:
|
|
deployer, err := providerAliyunESA.NewWithLogger(&providerAliyunESA.AliyunESADeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
SiteId: maps.GetValueAsInt64(options.ProviderDeployConfig, "siteId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunLive:
|
|
deployer, err := providerAliyunLive.NewWithLogger(&providerAliyunLive.AliyunLiveDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunNLB:
|
|
deployer, err := providerAliyunNLB.NewWithLogger(&providerAliyunNLB.AliyunNLBDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceType: providerAliyunNLB.DeployResourceType(maps.GetValueAsString(options.ProviderDeployConfig, "resourceType")),
|
|
LoadbalancerId: maps.GetValueAsString(options.ProviderDeployConfig, "loadbalancerId"),
|
|
ListenerId: maps.GetValueAsString(options.ProviderDeployConfig, "listenerId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunOSS:
|
|
deployer, err := providerAliyunOSS.NewWithLogger(&providerAliyunOSS.AliyunOSSDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
Bucket: maps.GetValueAsString(options.ProviderDeployConfig, "bucket"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeAliyunWAF:
|
|
deployer, err := providerAliyunWAF.NewWithLogger(&providerAliyunWAF.AliyunWAFDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.AccessKeySecret,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
InstanceId: maps.GetValueAsString(options.ProviderDeployConfig, "instanceId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeAWSCloudFront:
|
|
{
|
|
access := domain.AccessConfigForAWS{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeAWSCloudFront:
|
|
deployer, err := providerAWSCloudFront.NewWithLogger(&providerAWSCloudFront.AWSCloudFrontDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
SecretAccessKey: access.SecretAccessKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
DistributionId: maps.GetValueAsString(options.ProviderDeployConfig, "distributionId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeBaiduCloudCDN:
|
|
{
|
|
access := domain.AccessConfigForBaiduCloud{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeBaiduCloudCDN:
|
|
deployer, err := providerBaiduCloudCDN.NewWithLogger(&providerBaiduCloudCDN.BaiduCloudCDNDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
SecretAccessKey: access.SecretAccessKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeBaotaPanelSite:
|
|
{
|
|
access := domain.AccessConfigForBaotaPanel{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
deployer, err := providerBaotaPanelSite.NewWithLogger(&providerBaotaPanelSite.BaotaPanelSiteDeployerConfig{
|
|
ApiUrl: access.ApiUrl,
|
|
ApiKey: access.ApiKey,
|
|
SiteName: maps.GetValueAsString(options.ProviderDeployConfig, "siteName"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
}
|
|
|
|
case domain.DeployProviderTypeBytePlusCDN:
|
|
{
|
|
access := domain.AccessConfigForBytePlus{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeBytePlusCDN:
|
|
deployer, err := providerBytePlusCDN.NewWithLogger(&providerBytePlusCDN.BytePlusCDNDeployerConfig{
|
|
AccessKey: access.AccessKey,
|
|
SecretKey: access.SecretKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeDogeCloudCDN:
|
|
{
|
|
access := domain.AccessConfigForDogeCloud{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
deployer, err := providerDogeCDN.NewWithLogger(&providerDogeCDN.DogeCloudCDNDeployerConfig{
|
|
AccessKey: access.AccessKey,
|
|
SecretKey: access.SecretKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
}
|
|
|
|
case domain.DeployProviderTypeEdgioApplications:
|
|
{
|
|
access := domain.AccessConfigForEdgio{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
deployer, err := providerEdgioApplications.NewWithLogger(&providerEdgioApplications.EdgioApplicationsDeployerConfig{
|
|
ClientId: access.ClientId,
|
|
ClientSecret: access.ClientSecret,
|
|
EnvironmentId: maps.GetValueAsString(options.ProviderDeployConfig, "environmentId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
}
|
|
|
|
case domain.DeployProviderTypeHuaweiCloudCDN, domain.DeployProviderTypeHuaweiCloudELB:
|
|
{
|
|
access := domain.AccessConfigForHuaweiCloud{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeHuaweiCloudCDN:
|
|
deployer, err := providerHuaweiCloudCDN.NewWithLogger(&providerHuaweiCloudCDN.HuaweiCloudCDNDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
SecretAccessKey: access.SecretAccessKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeHuaweiCloudELB:
|
|
deployer, err := providerHuaweiCloudELB.NewWithLogger(&providerHuaweiCloudELB.HuaweiCloudELBDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
SecretAccessKey: access.SecretAccessKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceType: providerHuaweiCloudELB.DeployResourceType(maps.GetValueAsString(options.ProviderDeployConfig, "resourceType")),
|
|
CertificateId: maps.GetValueAsString(options.ProviderDeployConfig, "certificateId"),
|
|
LoadbalancerId: maps.GetValueAsString(options.ProviderDeployConfig, "loadbalancerId"),
|
|
ListenerId: maps.GetValueAsString(options.ProviderDeployConfig, "listenerId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeLocal:
|
|
{
|
|
deployer, err := providerLocal.NewWithLogger(&providerLocal.LocalDeployerConfig{
|
|
ShellEnv: providerLocal.ShellEnvType(maps.GetValueAsString(options.ProviderDeployConfig, "shellEnv")),
|
|
PreCommand: maps.GetValueAsString(options.ProviderDeployConfig, "preCommand"),
|
|
PostCommand: maps.GetValueAsString(options.ProviderDeployConfig, "postCommand"),
|
|
OutputFormat: providerLocal.OutputFormatType(maps.GetValueOrDefaultAsString(options.ProviderDeployConfig, "format", string(providerLocal.OUTPUT_FORMAT_PEM))),
|
|
OutputCertPath: maps.GetValueAsString(options.ProviderDeployConfig, "certPath"),
|
|
OutputKeyPath: maps.GetValueAsString(options.ProviderDeployConfig, "keyPath"),
|
|
PfxPassword: maps.GetValueAsString(options.ProviderDeployConfig, "pfxPassword"),
|
|
JksAlias: maps.GetValueAsString(options.ProviderDeployConfig, "jksAlias"),
|
|
JksKeypass: maps.GetValueAsString(options.ProviderDeployConfig, "jksKeypass"),
|
|
JksStorepass: maps.GetValueAsString(options.ProviderDeployConfig, "jksStorepass"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
}
|
|
|
|
case domain.DeployProviderTypeKubernetesSecret:
|
|
{
|
|
access := domain.AccessConfigForKubernetes{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
deployer, err := providerK8sSecret.NewWithLogger(&providerK8sSecret.K8sSecretDeployerConfig{
|
|
KubeConfig: access.KubeConfig,
|
|
Namespace: maps.GetValueOrDefaultAsString(options.ProviderDeployConfig, "namespace", "default"),
|
|
SecretName: maps.GetValueAsString(options.ProviderDeployConfig, "secretName"),
|
|
SecretType: maps.GetValueOrDefaultAsString(options.ProviderDeployConfig, "secretType", "kubernetes.io/tls"),
|
|
SecretDataKeyForCrt: maps.GetValueOrDefaultAsString(options.ProviderDeployConfig, "secretDataKeyForCrt", "tls.crt"),
|
|
SecretDataKeyForKey: maps.GetValueOrDefaultAsString(options.ProviderDeployConfig, "secretDataKeyForKey", "tls.key"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
}
|
|
|
|
case domain.DeployProviderTypeQiniuCDN, domain.DeployProviderTypeQiniuPili:
|
|
{
|
|
access := domain.AccessConfigForQiniu{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeQiniuCDN:
|
|
deployer, err := providerQiniuCDN.NewWithLogger(&providerQiniuCDN.QiniuCDNDeployerConfig{
|
|
AccessKey: access.AccessKey,
|
|
SecretKey: access.SecretKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeQiniuPili:
|
|
deployer, err := providerQiniuPili.NewWithLogger(&providerQiniuPili.QiniuPiliDeployerConfig{
|
|
AccessKey: access.AccessKey,
|
|
SecretKey: access.SecretKey,
|
|
Hub: maps.GetValueAsString(options.ProviderDeployConfig, "hub"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeSSH:
|
|
{
|
|
access := domain.AccessConfigForSSH{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
deployer, err := providerSSH.NewWithLogger(&providerSSH.SshDeployerConfig{
|
|
SshHost: access.Host,
|
|
SshPort: access.Port,
|
|
SshUsername: access.Username,
|
|
SshPassword: access.Password,
|
|
SshKey: access.Key,
|
|
SshKeyPassphrase: access.KeyPassphrase,
|
|
UseSCP: maps.GetValueAsBool(options.ProviderDeployConfig, "useSCP"),
|
|
PreCommand: maps.GetValueAsString(options.ProviderDeployConfig, "preCommand"),
|
|
PostCommand: maps.GetValueAsString(options.ProviderDeployConfig, "postCommand"),
|
|
OutputFormat: providerSSH.OutputFormatType(maps.GetValueOrDefaultAsString(options.ProviderDeployConfig, "format", string(providerSSH.OUTPUT_FORMAT_PEM))),
|
|
OutputCertPath: maps.GetValueAsString(options.ProviderDeployConfig, "certPath"),
|
|
OutputKeyPath: maps.GetValueAsString(options.ProviderDeployConfig, "keyPath"),
|
|
PfxPassword: maps.GetValueAsString(options.ProviderDeployConfig, "pfxPassword"),
|
|
JksAlias: maps.GetValueAsString(options.ProviderDeployConfig, "jksAlias"),
|
|
JksKeypass: maps.GetValueAsString(options.ProviderDeployConfig, "jksKeypass"),
|
|
JksStorepass: maps.GetValueAsString(options.ProviderDeployConfig, "jksStorepass"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
}
|
|
|
|
case domain.DeployProviderTypeTencentCloudCDN, domain.DeployProviderTypeTencentCloudCLB, domain.DeployProviderTypeTencentCloudCOS, domain.DeployProviderTypeTencentCloudCSS, domain.DeployProviderTypeTencentCloudECDN, domain.DeployProviderTypeTencentCloudEO, domain.DeployProviderTypeTencentCloudSSLDeploy:
|
|
{
|
|
access := domain.AccessConfigForTencentCloud{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeTencentCloudCDN:
|
|
deployer, err := providerTencentCloudCDN.NewWithLogger(&providerTencentCloudCDN.TencentCloudCDNDeployerConfig{
|
|
SecretId: access.SecretId,
|
|
SecretKey: access.SecretKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeTencentCloudCLB:
|
|
deployer, err := providerTencentCloudCLB.NewWithLogger(&providerTencentCloudCLB.TencentCloudCLBDeployerConfig{
|
|
SecretId: access.SecretId,
|
|
SecretKey: access.SecretKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceType: providerTencentCloudCLB.DeployResourceType(maps.GetValueAsString(options.ProviderDeployConfig, "resourceType")),
|
|
LoadbalancerId: maps.GetValueAsString(options.ProviderDeployConfig, "loadbalancerId"),
|
|
ListenerId: maps.GetValueAsString(options.ProviderDeployConfig, "listenerId"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeTencentCloudCOS:
|
|
deployer, err := providerTencentCloudCOS.NewWithLogger(&providerTencentCloudCOS.TencentCloudCOSDeployerConfig{
|
|
SecretId: access.SecretId,
|
|
SecretKey: access.SecretKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
Bucket: maps.GetValueAsString(options.ProviderDeployConfig, "bucket"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeTencentCloudCSS:
|
|
deployer, err := providerTencentCloudCSS.NewWithLogger(&providerTencentCloudCSS.TencentCloudCSSDeployerConfig{
|
|
SecretId: access.SecretId,
|
|
SecretKey: access.SecretKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeTencentCloudECDN:
|
|
deployer, err := providerTencentCloudECDN.NewWithLogger(&providerTencentCloudECDN.TencentCloudECDNDeployerConfig{
|
|
SecretId: access.SecretId,
|
|
SecretKey: access.SecretKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeTencentCloudEO:
|
|
deployer, err := providerTencentCloudEO.NewWithLogger(&providerTencentCloudEO.TencentCloudEODeployerConfig{
|
|
SecretId: access.SecretId,
|
|
SecretKey: access.SecretKey,
|
|
ZoneId: maps.GetValueAsString(options.ProviderDeployConfig, "zoneId"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeTencentCloudSSLDeploy:
|
|
deployer, err := providerTencentCloudSSLDeploy.NewWithLogger(&providerTencentCloudSSLDeploy.TencentCloudSSLDeployDeployerConfig{
|
|
SecretId: access.SecretId,
|
|
SecretKey: access.SecretKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceType: maps.GetValueAsString(options.ProviderDeployConfig, "resourceType"),
|
|
ResourceIds: slices.Filter(strings.Split(maps.GetValueAsString(options.ProviderDeployConfig, "resourceIds"), ";"), func(s string) bool { return s != "" }),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeUCloudUCDN, domain.DeployProviderTypeUCloudUS3:
|
|
{
|
|
access := domain.AccessConfigForUCloud{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeUCloudUCDN:
|
|
deployer, err := providerUCloudUCDN.NewWithLogger(&providerUCloudUCDN.UCloudUCDNDeployerConfig{
|
|
PrivateKey: access.PrivateKey,
|
|
PublicKey: access.PublicKey,
|
|
ProjectId: access.ProjectId,
|
|
DomainId: maps.GetValueAsString(options.ProviderDeployConfig, "domainId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeUCloudUS3:
|
|
deployer, err := providerUCloudUS3.NewWithLogger(&providerUCloudUS3.UCloudUS3DeployerConfig{
|
|
PrivateKey: access.PrivateKey,
|
|
PublicKey: access.PublicKey,
|
|
ProjectId: access.ProjectId,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
Bucket: maps.GetValueAsString(options.ProviderDeployConfig, "bucket"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeVolcEngineCDN, domain.DeployProviderTypeVolcEngineCLB, domain.DeployProviderTypeVolcEngineDCDN, domain.DeployProviderTypeVolcEngineLive, domain.DeployProviderTypeVolcEngineTOS:
|
|
{
|
|
access := domain.AccessConfigForVolcEngine{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
switch options.Provider {
|
|
case domain.DeployProviderTypeVolcEngineCDN:
|
|
deployer, err := providerVolcEngineCDN.NewWithLogger(&providerVolcEngineCDN.VolcEngineCDNDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.SecretAccessKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeVolcEngineCLB:
|
|
deployer, err := providerVolcEngineCLB.NewWithLogger(&providerVolcEngineCLB.VolcEngineCLBDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.SecretAccessKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
ResourceType: providerVolcEngineCLB.DeployResourceType(maps.GetValueAsString(options.ProviderDeployConfig, "resourceType")),
|
|
ListenerId: maps.GetValueAsString(options.ProviderDeployConfig, "listenerId"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeVolcEngineDCDN:
|
|
deployer, err := providerVolcEngineDCDN.NewWithLogger(&providerVolcEngineDCDN.VolcEngineDCDNDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.SecretAccessKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeVolcEngineLive:
|
|
deployer, err := providerVolcEngineLive.NewWithLogger(&providerVolcEngineLive.VolcEngineLiveDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.SecretAccessKey,
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
case domain.DeployProviderTypeVolcEngineTOS:
|
|
deployer, err := providerVolcEngineTOS.NewWithLogger(&providerVolcEngineTOS.VolcEngineTOSDeployerConfig{
|
|
AccessKeyId: access.AccessKeyId,
|
|
AccessKeySecret: access.SecretAccessKey,
|
|
Region: maps.GetValueAsString(options.ProviderDeployConfig, "region"),
|
|
Bucket: maps.GetValueAsString(options.ProviderDeployConfig, "bucket"),
|
|
Domain: maps.GetValueAsString(options.ProviderDeployConfig, "domain"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
|
|
default:
|
|
break
|
|
}
|
|
}
|
|
|
|
case domain.DeployProviderTypeWebhook:
|
|
{
|
|
access := domain.AccessConfigForWebhook{}
|
|
if err := maps.Decode(options.ProviderAccessConfig, &access); err != nil {
|
|
return nil, nil, fmt.Errorf("failed to decode provider access config: %w", err)
|
|
}
|
|
|
|
deployer, err := providerWebhook.NewWithLogger(&providerWebhook.WebhookDeployerConfig{
|
|
WebhookUrl: access.Url,
|
|
WebhookData: maps.GetValueAsString(options.ProviderDeployConfig, "webhookData"),
|
|
}, logger)
|
|
return deployer, logger, err
|
|
}
|
|
}
|
|
|
|
return nil, nil, fmt.Errorf("unsupported deployer provider: %s", string(options.Provider))
|
|
}
|