Remove reflect middleware - it was only a toy

This commit is contained in:
Miek Gieben
2016-03-23 10:54:50 +00:00
parent 15518b5b6f
commit 7d834ce037
4 changed files with 2 additions and 118 deletions

View File

@@ -51,12 +51,11 @@ var directiveOrder = []directive{
{"shutdown", setup.Shutdown}, {"shutdown", setup.Shutdown},
// Directives that inject handlers (middleware) // Directives that inject handlers (middleware)
{"log", setup.Log},
{"errors", setup.Errors},
{"prometheus", setup.Prometheus}, {"prometheus", setup.Prometheus},
{"rewrite", setup.Rewrite}, {"rewrite", setup.Rewrite},
{"file", setup.File}, {"file", setup.File},
{"reflect", setup.Reflect},
{"log", setup.Log},
{"errors", setup.Errors},
{"proxy", setup.Proxy}, {"proxy", setup.Proxy},
} }

View File

@@ -1,28 +0,0 @@
package setup
import (
"github.com/miekg/coredns/middleware"
"github.com/miekg/coredns/middleware/reflect"
)
// Reflect sets up the reflect middleware.
func Reflect(c *Controller) (middleware.Middleware, error) {
if err := reflectParse(c); err != nil {
return nil, err
}
return func(next middleware.Handler) middleware.Handler {
return reflect.Reflect{Next: next}
}, nil
}
func reflectParse(c *Controller) error {
for c.Next() {
if c.Val() == "reflect" {
if c.NextArg() {
return c.ArgErr()
}
}
}
return nil
}

View File

@@ -1,86 +0,0 @@
// Reflect provides middleware that reflects back some client properties.
// This is the default middleware when Caddy is run without configuration.
//
// The left-most label must be `who`.
// When queried for type A (resp. AAAA), it sends back the IPv4 (resp. v6) address.
// In the additional section the port number and transport are shown.
// Basic use pattern:
//
// dig @localhost -p 1053 who.miek.nl A
//
// ;; ANSWER SECTION:
// who.miek.nl. 0 IN A 127.0.0.1
//
// ;; ADDITIONAL SECTION:
// who.miek.nl. 0 IN TXT "Port: 56195 (udp)"
package reflect
import (
"errors"
"net"
"strings"
"golang.org/x/net/context"
"github.com/miekg/coredns/middleware"
"github.com/miekg/dns"
)
type Reflect struct {
Next middleware.Handler
}
func (rl Reflect) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error) {
state := middleware.State{Req: r, W: w}
class := r.Question[0].Qclass
qname := r.Question[0].Name
i, ok := dns.NextLabel(qname, 0)
if strings.ToLower(qname[:i]) != who || ok {
err := state.ErrorMessage(dns.RcodeFormatError)
w.WriteMsg(err)
return dns.RcodeFormatError, errors.New(dns.RcodeToString[dns.RcodeFormatError])
}
answer := new(dns.Msg)
answer.SetReply(r)
answer.Compress = true
answer.Authoritative = true
ip := state.IP()
proto := state.Proto()
port, _ := state.Port()
family := state.Family()
var rr dns.RR
switch family {
case 1:
rr = new(dns.A)
rr.(*dns.A).Hdr = dns.RR_Header{Name: qname, Rrtype: dns.TypeA, Class: class, Ttl: 0}
rr.(*dns.A).A = net.ParseIP(ip).To4()
case 2:
rr = new(dns.AAAA)
rr.(*dns.AAAA).Hdr = dns.RR_Header{Name: qname, Rrtype: dns.TypeAAAA, Class: class, Ttl: 0}
rr.(*dns.AAAA).AAAA = net.ParseIP(ip)
}
t := new(dns.TXT)
t.Hdr = dns.RR_Header{Name: qname, Rrtype: dns.TypeTXT, Class: class, Ttl: 0}
t.Txt = []string{"Port: " + port + " (" + proto + ")"}
switch state.Type() {
case "TXT":
answer.Answer = append(answer.Answer, t)
answer.Extra = append(answer.Extra, rr)
default:
fallthrough
case "AAAA", "A":
answer.Answer = append(answer.Answer, rr)
answer.Extra = append(answer.Extra, t)
}
w.WriteMsg(answer)
return 0, nil
}
const who = "who."

View File

@@ -1 +0,0 @@
package reflect