域名解析增加CloudFlare DNS支持

Author: iwind

internal/dnsclients/cloudflare/response_base.go

@@ -0,0 +1,22 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package cloudflare
+
+type BaseResponse struct {
+	Success bool `json:"success"`
+	Errors  []struct {
+		Code    int    `json:"code"`
+		Message string `json:"message"`
+	} `json:"errors"`
+}
+
+func (this *BaseResponse) IsOk() bool {
+	return this.Success
+}
+
+func (this *BaseResponse) LastError() (code int, message string) {
+	if len(this.Errors) == 0 {
+		return 0, ""
+	}
+	return this.Errors[0].Code, this.Errors[0].Message
+}

internal/dnsclients/cloudflare/response_create_dns_record.go

@@ -0,0 +1,7 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package cloudflare
+
+type CreateDNSRecordResponse struct {
+	BaseResponse
+}

internal/dnsclients/cloudflare/response_delete_dns_record.go

@@ -0,0 +1,7 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package cloudflare
+
+type DeleteDNSRecordResponse struct {
+	BaseResponse
+}

internal/dnsclients/cloudflare/response_get_dns_records.go

@@ -0,0 +1,17 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package cloudflare
+
+type GetDNSRecordsResponse struct {
+	BaseResponse
+
+	Result []struct {
+		Id       string `json:"id"`
+		Type     string `json:"type"`
+		Name     string `json:"name"`
+		Content  string `json:"content"`
+		Ttl      int    `json:"ttl"`
+		ZoneId   string `json:"zoneId"`
+		ZoneName string `json:"zoneName"`
+	} `json:"result"`
+}

internal/dnsclients/cloudflare/response_interface.go

@@ -0,0 +1,8 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package cloudflare
+
+type ResponseInterface interface {
+	IsOk() bool
+	LastError() (code int, message string)
+}

internal/dnsclients/cloudflare/response_update_dns_record.go

@@ -0,0 +1,7 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package cloudflare
+
+type UpdateDNSRecordResponse struct {
+	BaseResponse
+}

internal/dnsclients/cloudflare/response_zones.go

@@ -0,0 +1,12 @@
+// Copyright 2021 Liuxiangchao iwind.liu@gmail.com. All rights reserved.
+
+package cloudflare
+
+type ZonesResponse struct {
+	BaseResponse
+
+	Result []struct {
+		Id   string `json:"id"`
+		Name string `json:"name"`
+	} `json:"result"`
+}

internal/dnsclients/provider_alidns.go

@@ -9,15 +9,15 @@ import (
 	"strings"
 )
 
-// 阿里云服务商
+// AliDNSProvider 阿里云服务商
 type AliDNSProvider struct {
 	BaseProvider
 
 	accessKeyId     string
 	accessKeySecret string
 }
 
-// 认证
+// Auth 认证
 func (this *AliDNSProvider) Auth(params maps.Map) error {
 	this.accessKeyId = params.GetString("accessKeyId")
 	this.accessKeySecret = params.GetString("accessKeySecret")
@@ -30,7 +30,7 @@ func (this *AliDNSProvider) Auth(params maps.Map) error {
 	return nil
 }
 
-// 获取域名列表
+// GetRecords 获取域名列表
 func (this *AliDNSProvider) GetRecords(domain string) (records []*Record, err error) {
 	pageNumber := 1
 	size := 100
@@ -70,7 +70,7 @@ func (this *AliDNSProvider) GetRecords(domain string) (records []*Record, err er
 	return
 }
 
-// 读取域名支持的线路数据
+// GetRoutes 读取域名支持的线路数据
 func (this *AliDNSProvider) GetRoutes(domain string) (routes []*Route, err error) {
 	req := alidns.CreateDescribeSupportLinesRequest()
 	req.DomainName = domain
@@ -89,7 +89,7 @@ func (this *AliDNSProvider) GetRoutes(domain string) (routes []*Route, err error
 	return
 }
 
-// 查询单个记录
+// QueryRecord 查询单个记录
 func (this *AliDNSProvider) QueryRecord(domain string, name string, recordType RecordType) (*Record, error) {
 	records, err := this.GetRecords(domain)
 	if err != nil {
@@ -103,7 +103,7 @@ func (this *AliDNSProvider) QueryRecord(domain string, name string, recordType R
 	return nil, err
 }
 
-// 设置记录
+// AddRecord 设置记录
 func (this *AliDNSProvider) AddRecord(domain string, newRecord *Record) error {
 	req := alidns.CreateAddDomainRecordRequest()
 	req.RR = newRecord.Name
@@ -124,7 +124,7 @@ func (this *AliDNSProvider) AddRecord(domain string, newRecord *Record) error {
 	return errors.New(resp.GetHttpContentString())
 }
 
-// 修改记录
+// UpdateRecord 修改记录
 func (this *AliDNSProvider) UpdateRecord(domain string, record *Record, newRecord *Record) error {
 	req := alidns.CreateUpdateDomainRecordRequest()
 	req.RecordId = record.Id
@@ -138,7 +138,7 @@ func (this *AliDNSProvider) UpdateRecord(domain string, record *Record, newRecor
 	return err
 }
 
-// 删除记录
+// DeleteRecord 删除记录
 func (this *AliDNSProvider) DeleteRecord(domain string, record *Record) error {
 	req := alidns.CreateDeleteDomainRecordRequest()
 	req.RecordId = record.Id
@@ -148,7 +148,7 @@ func (this *AliDNSProvider) DeleteRecord(domain string, record *Record) error {
 	return err
 }
 
-// 默认线路
+// DefaultRoute 默认线路
 func (this *AliDNSProvider) DefaultRoute() string {
 	return "default"
 }