mirror of
				https://github.com/coredns/coredns.git
				synced 2025-10-30 09:43:17 -04:00 
			
		
		
		
	
		
			
	
	
		
			95 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
		
		
			
		
	
	
			95 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
|  | package test
 | ||
|  | 
 | ||
|  | import (
 | ||
|  | 	"bytes"
 | ||
|  | 	"io/ioutil"
 | ||
|  | 	"log"
 | ||
|  | 	"testing"
 | ||
|  | 
 | ||
|  | 	"github.com/miekg/dns"
 | ||
|  | )
 | ||
|  | 
 | ||
|  | func TestRewrite(t *testing.T) {
 | ||
|  | 	t.Parallel()
 | ||
|  | 	corefile := `.:0 {
 | ||
|  |        rewrite type MX a
 | ||
|  |        rewrite edns0 local set 0xffee hello-world
 | ||
|  |        erratic . {
 | ||
|  | 	drop 0
 | ||
|  | 	}
 | ||
|  | }`
 | ||
|  | 
 | ||
|  | 	i, err := CoreDNSServer(corefile)
 | ||
|  | 	if err != nil {
 | ||
|  | 		t.Fatalf("Could not get CoreDNS serving instance: %s", err)
 | ||
|  | 	}
 | ||
|  | 
 | ||
|  | 	udp, _ := CoreDNSServerPorts(i, 0)
 | ||
|  | 	if udp == "" {
 | ||
|  | 		t.Fatalf("Could not get UDP listening port")
 | ||
|  | 	}
 | ||
|  | 	defer i.Stop()
 | ||
|  | 
 | ||
|  | 	log.SetOutput(ioutil.Discard)
 | ||
|  | 
 | ||
|  | 	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])
 | ||
|  | 		}
 | ||
|  | 	}
 | ||
|  | }
 |