代码拉取完成,页面将自动刷新
同步操作将从 wl4g/dopaas-coredns 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
package xcloud_dopaas_coredns
import (
"fmt"
"github.com/coredns/coredns/plugin"
"github.com/coredns/coredns/request"
"github.com/miekg/dns"
"golang.org/x/net/context"
)
// ServeDNS implements the plugin.Handler interface.
func (redis *Redis) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error) {
state := request.Request{W: w, Req: r}
qname := state.Name()
qtype := state.Type()
zone := Qname2Zone(qname)
//Blacklist use this way
access := redis.filter(qname)
if !access {
return dns.RcodeRefused, nil
}
if zone == "" {
return plugin.NextOrFailure(qname, redis.Next, ctx, w, r)
}
z := redis.load(zone)
if z == nil {
return plugin.NextOrFailure(qname, redis.Next, ctx, w, r)
}
if qtype == "AXFR" {
records := redis.AXFR(z)
ch := make(chan *dns.Envelope)
tr := new(dns.Transfer)
tr.TsigSecret = nil
go func(ch chan *dns.Envelope) {
j, l := 0, 0
for i, r := range records {
l += dns.Len(r)
if l > transferLength {
ch <- &dns.Envelope{RR: records[j:i]}
l = 0
j = i
}
}
if j < len(records) {
ch <- &dns.Envelope{RR: records[j:]}
}
close(ch)
}(ch)
err := tr.Out(w, r, ch)
if err != nil {
fmt.Println(err)
}
w.Hijack()
return dns.RcodeSuccess, nil
}
location := redis.findLocation(qname, z)
if len(location) == 0 { // empty, no results
//return redis.errorResponse(state, zone, dns.RcodeNameError, nil)
return plugin.NextOrFailure(qname, redis.Next, ctx, w, r)
}
answers := make([]dns.RR, 0, 10)
extras := make([]dns.RR, 0, 10)
record := redis.get(location, z)
if record == nil {
return plugin.NextOrFailure(qname, redis.Next, ctx, w, r)
}
switch qtype {
case "A":
answers, extras = redis.A(qname, z, record)
case "AAAA":
answers, extras = redis.AAAA(qname, z, record)
case "CNAME":
answers, extras = redis.CNAME(qname, z, record)
case "TXT":
answers, extras = redis.TXT(qname, z, record)
case "NS":
answers, extras = redis.NS(qname, z, record)
case "MX":
answers, extras = redis.MX(qname, z, record)
case "SRV":
answers, extras = redis.SRV(qname, z, record)
case "SOA":
answers, extras = redis.SOA(qname, z, record)
case "CAA":
answers, extras = redis.CAA(qname, z, record)
default:
return redis.errorResponse(state, zone, dns.RcodeNotImplemented, nil)
}
m := new(dns.Msg)
m.SetReply(r)
m.Authoritative, m.RecursionAvailable, m.Compress = true, false, true
m.Answer = append(m.Answer, answers...)
m.Extra = append(m.Extra, extras...)
state.SizeAndDo(m)
m = state.Scrub(m)
_ = w.WriteMsg(m)
return dns.RcodeSuccess, nil
}
// Name implements the Handler interface.
func (redis *Redis) Name() string { return PluginName }
func (redis *Redis) errorResponse(state request.Request, zone string, rcode int, err error) (int, error) {
m := new(dns.Msg)
m.SetRcode(state.Req, rcode)
m.Authoritative, m.RecursionAvailable, m.Compress = true, false, true
state.SizeAndDo(m)
_ = state.W.WriteMsg(m)
// Return success as the rcode to signal we have written to the client.
return dns.RcodeSuccess, err
}
// blacklist and whitelist
func (redis *Redis) filter(qname string) bool {
if len(qname) <= 0 {
return false
}
qname = qname[0 : len(qname)-1]
whitelistExp := redis.GetWhitelist()
blacklistExp := redis.GetBlacklist()
for _, expression := range whitelistExp {
match := ExpressionMatch(qname, expression)
if match {
return true
}
}
for _, expression := range blacklistExp {
match := ExpressionMatch(qname, expression)
if match {
return false
}
}
return true
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。