实现域名、记录同步等API

Author: iwind

go.mod

@@ -3,6 +3,7 @@ module github.com/TeaOSLab/EdgeCommon
 go 1.15
 
 require (
+	github.com/cespare/xxhash/v2 v2.1.1
 	github.com/go-yaml/yaml v2.1.0+incompatible
 	github.com/golang/protobuf v1.4.2
 	github.com/iwind/TeaGo v0.0.0-20210411134150-ddf57e240c2f

go.sum

@@ -5,6 +5,7 @@ github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym
 github.com/DataDog/sketches-go v0.0.0-20190923095040-43f19ad77ff7/go.mod h1:Q5DbzQ+3AkgGwymQO7aZFNP7ns2lZKGtvRBzRXfdi60=
 github.com/benbjohnson/clock v1.0.3/go.mod h1:bGMdMPoPVvcYyt1gHDf4J2KE153Yf9BuiUKYMaxlTDM=
 github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
+github.com/cespare/xxhash/v2 v2.1.1 h1:6MnRN8NT7+YBpUIWxHtefFZOKTAPgGjpQSxqLNn0+qY=
 github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
 github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=

pkg/configutils/ip.go

@@ -0,0 +1,26 @@
+package configutils
+
+import (
+	"encoding/binary"
+	"github.com/cespare/xxhash/v2"
+	"math"
+	"net"
+	"strings"
+)
+
+// IP2Long 将IP转换为整型
+// 注意IPv6没有顺序
+func IP2Long(ip string) uint64 {
+	if len(ip) == 0 {
+		return 0
+	}
+	s := net.ParseIP(ip)
+	if len(s) == 0 {
+		return 0
+	}
+
+	if strings.Contains(ip, ":") {
+		return math.MaxUint32 + xxhash.Sum64(s)
+	}
+	return uint64(binary.BigEndian.Uint32(s.To4()))
+}

pkg/dnsconfigs/record_types.go

@@ -48,7 +48,7 @@ func FindAllRecordTypeDefinitions() []*RecordTypeDefinition {
 		},
 		{
 			Type:        RecordTypeTXT,
-			Description: "文本长度限制512，通常做SPF记录（反垃圾邮件）",
+			Description: "文本长度限制512，通常做SPF记录或者校验域名所有者",
 		},
 		{
 			Type:        RecordTypeCAA,

pkg/dnsconfigs/route_ranges.go

@@ -2,14 +2,39 @@
 
 package dnsconfigs
 
+import "github.com/TeaOSLab/EdgeCommon/pkg/configutils"
+
 type RouteRangeType = string
 
 const (
 	RouteRangeTypeIP RouteRangeType = "ipRange"
 )
 
+type RouteRangeInterface interface {
+	Init() error
+	Contains(ip uint64) bool
+}
+
 // RouteRangeIPRange IP范围配置
 type RouteRangeIPRange struct {
 	IPFrom string `json:"ipFrom"`
 	IPTo   string `json:"ipTo"`
+
+	ipFromLong uint64
+	ipToLong   uint64
+}
+
+func (this *RouteRangeIPRange) Init() error {
+	this.ipFromLong = configutils.IP2Long(this.IPFrom)
+	this.ipToLong = configutils.IP2Long(this.IPTo)
+
+	if this.ipFromLong > this.ipToLong {
+		this.ipFromLong, this.ipToLong = this.ipToLong, this.ipFromLong
+	}
+
+	return nil
+}
+
+func (this *RouteRangeIPRange) Contains(ip uint64) bool {
+	return this.ipFromLong <= ip && this.ipToLong >= ip
 }