GuanM/certimate
1
0
Fork 0
mirror of https://github.com/usual2970/certimate.git synced 2025-06-08 05:29:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge branch 'main' of github.com:usual2970/certimate

Browse Source
This commit is contained in:
Yoan.liu 2025-05-23 16:48:54 +08:00
commit bff8add010
1 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
internal/pkg/core/applicant/acme-dns-01/lego-providers/aliyun-esa/internal/lego.go
View File

@ -89,6 +89,8 @@ func NewDNSProviderConfig(config *Config) (*DNSProvider, error) {
return &DNSProvider{ return &DNSProvider{
client: client, client: client,
config: config, config: config,
siteIDs: make(map[string]int64),
}, nil }, nil
} }
@ -100,7 +102,7 @@ func (d *DNSProvider) Present(domain, token, keyAuth string) error {
return fmt.Errorf("alicloud-esa: could not find zone for domain %q: %w", domain, err) return fmt.Errorf("alicloud-esa: could not find zone for domain %q: %w", domain, err)
} }
siteId, err := d.getSiteId(authZone) siteId, err := d.getSiteId(strings.TrimRight(authZone, "."))
if err != nil { if err != nil {
return fmt.Errorf("alicloud-esa: could not find site for zone %q: %w", authZone, err) return fmt.Errorf("alicloud-esa: could not find site for zone %q: %w", authZone, err)
} }
@ -120,7 +122,7 @@ func (d *DNSProvider) CleanUp(domain, token, keyAuth string) error {
return fmt.Errorf("alicloud-esa: could not find zone for domain %q: %w", domain, err) return fmt.Errorf("alicloud-esa: could not find zone for domain %q: %w", domain, err)
} }
siteId, err := d.getSiteId(authZone) siteId, err := d.getSiteId(strings.TrimRight(authZone, "."))
if err != nil { if err != nil {
return fmt.Errorf("alicloud-esa: could not find site for zone %q: %w", authZone, err) return fmt.Errorf("alicloud-esa: could not find site for zone %q: %w", authZone, err)
} }
@ -148,10 +150,11 @@ func (d *DNSProvider) getSiteId(siteName string) (int64, error) {
pageSize := 500 pageSize := 500
for { for {
request := &aliesa.ListSitesRequest{ request := &aliesa.ListSitesRequest{
SiteName: tea.String(siteName), SiteName: tea.String(siteName),
PageNumber: tea.Int32(int32(pageNumber)), SiteSearchType: tea.String("exact"),
PageSize: tea.Int32(int32(pageNumber)), PageNumber: tea.Int32(int32(pageNumber)),
AccessType: tea.String("NS"), PageSize: tea.Int32(int32(pageSize)),
AccessType: tea.String("NS"),
} }
response, err := d.client.ListSites(request) response, err := d.client.ListSites(request)
if err != nil { if err != nil {
@ -178,7 +181,7 @@ func (d *DNSProvider) getSiteId(siteName string) (int64, error) {
} }
} }
return 0, errors.New("failed to get site id") return 0, errors.New("site not found")
} }
func (d *DNSProvider) findDNSRecord(siteId int64, effectiveFQDN string) (*aliesa.ListRecordsResponseBodyRecords, error) { func (d *DNSProvider) findDNSRecord(siteId int64, effectiveFQDN string) (*aliesa.ListRecordsResponseBodyRecords, error) {
@ -186,11 +189,12 @@ func (d *DNSProvider) findDNSRecord(siteId int64, effectiveFQDN string) (*aliesa
pageSize := 500 pageSize := 500
for { for {
request := &aliesa.ListRecordsRequest{ request := &aliesa.ListRecordsRequest{
SiteId: tea.Int64(siteId), SiteId: tea.Int64(siteId),
Type: tea.String("TXT"), Type: tea.String("TXT"),
RecordName: tea.String(effectiveFQDN), RecordName: tea.String(effectiveFQDN),
PageNumber: tea.Int32(int32(pageNumber)), RecordMatchType: tea.String("exact"),
PageSize: tea.Int32(int32(pageNumber)), PageNumber: tea.Int32(int32(pageNumber)),
PageSize: tea.Int32(int32(pageSize)),
} }
response, err := d.client.ListRecords(request) response, err := d.client.ListRecords(request)
if err != nil { if err != nil {