Method createUpdateDomain

ddns/porkbun.go:61–88

(recordType, ipAddr string, domain *ddnscore.Domain)

}

func (pb *Porkbun) createUpdateDomain(recordType, ipAddr string, domain *ddnscore.Domain) {

	var record PorkbunDomainQueryResponse
	// 获取当前域名信息
	err := pb.request(
		porkbunEndpoint+fmt.Sprintf("/retrieveByNameType/%s/%s/%s", domain.DomainName, recordType, domain.SubDomain),
		&PorkbunApiKey{
			AccessKey: pb.task.DNS.ID,
			SecretKey: pb.task.DNS.Secret,
		},
		&record,
	)

	if err != nil {
		return
	}
	if record.Status == "SUCCESS" {
		if len(record.Records) > 0 {
			// 存在，更新
			pb.modify(&record, domain, recordType, ipAddr)
		} else {
			// 不存在，创建
			pb.create(domain, recordType, ipAddr)
		}
	} else {
		domain.SetDomainUpdateStatus(ddnscore.UpdatedFailed, "查询现有域名记录失败")
	}
}

// 创建
func (pb *Porkbun) create(domain *ddnscore.Domain, recordType string, ipAddr string) {