911891f485
* write failures with ResponseReverter instead of letting server write them Signed-off-by: Chris O'Haver <cohaver@infoblox.com> * fix comment Signed-off-by: Chris O'Haver <cohaver@infoblox.com>
114 lines
2.8 KiB
Go
114 lines
2.8 KiB
Go
package test
|
|
|
|
import (
|
|
"bytes"
|
|
"testing"
|
|
|
|
"github.com/miekg/dns"
|
|
)
|
|
|
|
func TestRewriteFailure(t *testing.T) {
|
|
t.Parallel()
|
|
i, udp, _, err := CoreDNSServerAndPorts(`.:0 {
|
|
rewrite name regex (.*)\.test\.$ {1}. answer auto
|
|
# no next plugin to induce SERVFAIL
|
|
}`)
|
|
if err != nil {
|
|
t.Fatalf("Could not get CoreDNS serving instance: %s", err)
|
|
}
|
|
|
|
defer i.Stop()
|
|
|
|
m := new(dns.Msg)
|
|
m.SetQuestion("example.test.", dns.TypeMX)
|
|
|
|
r, err := dns.Exchange(m, udp)
|
|
if err != nil {
|
|
t.Fatalf("Expected to receive reply, but didn't: %s", err)
|
|
}
|
|
|
|
if len(r.Question) == 0 {
|
|
t.Error("Invalid empty question section")
|
|
}
|
|
if r.Question[0].Name != "example.test." {
|
|
t.Errorf("Question section mismatch. expected \"example.test.\" got %q", r.Question[0].Name)
|
|
}
|
|
}
|
|
|
|
func TestRewrite(t *testing.T) {
|
|
t.Parallel()
|
|
corefile := `.:0 {
|
|
rewrite type MX a
|
|
rewrite edns0 local set 0xffee hello-world
|
|
erratic . {
|
|
drop 0
|
|
}
|
|
}`
|
|
|
|
i, udp, _, err := CoreDNSServerAndPorts(corefile)
|
|
if err != nil {
|
|
t.Fatalf("Could not get CoreDNS serving instance: %s", err)
|
|
}
|
|
|
|
defer i.Stop()
|
|
|
|
testMX(t, udp)
|
|
testEdns0(t, udp)
|
|
}
|
|
|
|
func testMX(t *testing.T, server string) {
|
|
m := new(dns.Msg)
|
|
m.SetQuestion("example.com.", dns.TypeMX)
|
|
|
|
r, err := dns.Exchange(m, server)
|
|
if err != nil {
|
|
t.Fatalf("Expected to receive reply, but didn't: %s", err)
|
|
}
|
|
|
|
// expect answer section with A record in it
|
|
if len(r.Answer) == 0 {
|
|
t.Error("Expected to at least one RR in the answer section, got none")
|
|
}
|
|
if r.Answer[0].Header().Rrtype != dns.TypeA {
|
|
t.Errorf("Expected RR to A, got: %d", r.Answer[0].Header().Rrtype)
|
|
}
|
|
if r.Answer[0].(*dns.A).A.String() != "192.0.2.53" {
|
|
t.Errorf("Expected 192.0.2.53, got: %s", r.Answer[0].(*dns.A).A.String())
|
|
}
|
|
}
|
|
|
|
func testEdns0(t *testing.T, server string) {
|
|
m := new(dns.Msg)
|
|
m.SetQuestion("example.com.", dns.TypeA)
|
|
|
|
r, err := dns.Exchange(m, server)
|
|
if err != nil {
|
|
t.Fatalf("Expected to receive reply, but didn't: %s", err)
|
|
}
|
|
|
|
// expect answer section with A record in it
|
|
if len(r.Answer) == 0 {
|
|
t.Error("Expected to at least one RR in the answer section, got none")
|
|
}
|
|
if r.Answer[0].Header().Rrtype != dns.TypeA {
|
|
t.Errorf("Expected RR to A, got: %d", r.Answer[0].Header().Rrtype)
|
|
}
|
|
if r.Answer[0].(*dns.A).A.String() != "192.0.2.53" {
|
|
t.Errorf("Expected 192.0.2.53, got: %s", r.Answer[0].(*dns.A).A.String())
|
|
}
|
|
o := r.IsEdns0()
|
|
if o == nil || len(o.Option) == 0 {
|
|
t.Error("Expected EDNS0 options but got none")
|
|
} else {
|
|
if e, ok := o.Option[0].(*dns.EDNS0_LOCAL); ok {
|
|
if e.Code != 0xffee {
|
|
t.Errorf("Expected EDNS_LOCAL code 0xffee but got %x", e.Code)
|
|
}
|
|
if !bytes.Equal(e.Data, []byte("hello-world")) {
|
|
t.Errorf("Expected EDNS_LOCAL data 'hello-world' but got %q", e.Data)
|
|
}
|
|
} else {
|
|
t.Errorf("Expected EDNS0_LOCAL but got %v", o.Option[0])
|
|
}
|
|
}
|
|
}
|