fix: fix find record bug

Author: gitsang

pkg/api/api.go

@@ -1,8 +1,6 @@
 package api
 
 import (
-	"ddns/pkg/utils"
-
 	alidns20150109 "github.com/alibabacloud-go/alidns-20150109/v2/client"
 	openapi "github.com/alibabacloud-go/darabonba-openapi/client"
 	"github.com/alibabacloud-go/tea/tea"
@@ -24,32 +22,28 @@ func CreateClient(accessKeyId string, accessKeySecret string) (_result *alidns20
 	return _result, _err
 }
 
-func DescribeDomainRecords(client *alidns20150109.Client, domainName string) (
-	[]*alidns20150109.DescribeDomainRecordsResponseBodyDomainRecordsRecord, error) {
+func FindRecordByRR(client *alidns20150109.Client, domainName, rr string) (
+	*alidns20150109.DescribeDomainRecordsResponseBodyDomainRecordsRecord, error) {
 
 	describeDomainRecordsRequest := &alidns20150109.DescribeDomainRecordsRequest{
 		DomainName: tea.String(domainName),
+		KeyWord:    tea.String(rr),
+		SearchMode: tea.String("EXACT"),
 	}
 	resp, err := client.DescribeDomainRecords(describeDomainRecordsRequest)
 	if err != nil {
 		return nil, err
 	}
 	records := resp.Body.DomainRecords.Record
-
-	log.Debug(utils.FUNCTION()+"success", zap.Reflect("records", records))
-	return records, nil
-}
-
-func FindRecordByRR(
-	records []*alidns20150109.DescribeDomainRecordsResponseBodyDomainRecordsRecord,
-	rr string) *alidns20150109.DescribeDomainRecordsResponseBodyDomainRecordsRecord {
+	log.Debug("describe domain records success", zap.Reflect("records", records))
 
 	for _, rec := range records {
 		if *rec.RR == rr {
-			return rec
+			return rec, nil
 		}
 	}
-	return nil
+
+	return nil, nil
 }
 
 func UpdateRecord(client *alidns20150109.Client, id, rr, typ, value string) error {

pkg/service/service.go

@@ -21,31 +21,29 @@ func UpdateDns() {
 		return
 	}
 
-	records, err := api.DescribeDomainRecords(client, config.Cfg.Domain)
-	if err != nil {
-		log.Error("list record failed", zap.Error(err))
-		return
-	}
-	if len(records) == 0 {
-		log.Error("record not found")
-		return
-	}
-	log.Info("describe domain records", zap.Reflect("records", records))
-
 	for _, ddns := range config.Cfg.DDNSs {
 		if !ddns.Enable {
-			continue
+			return
 		}
 		logFields := []zap.Field{zap.Reflect("ddns", ddns)}
 
+		// get ip
 		ip, err := utils.GetIpWithPrefix(ddns.Interface, ddns.Prefix)
 		if err != nil {
 			log.Error("get interface ip failed", append(logFields, zap.Error(err))...)
 			continue
 		}
 		logFields = append(logFields, zap.String("ip", ip))
 
-		record := api.FindRecordByRR(records, ddns.RR)
+		// find record
+		record, err := api.FindRecordByRR(client, config.Cfg.Domain, ddns.RR)
+		if err != nil {
+			log.Error("find record by rr failed", append(logFields, zap.Error(err))...)
+			continue
+		}
+		logFields = append(logFields, zap.Reflect("record", record))
+
+		// create or update
 		if record == nil { // create
 			err = api.CreateRecord(client, config.Cfg.Domain, ddns.RR, ddns.Type, ip)
 			if err != nil {