-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathquery.go
96 lines (78 loc) · 1.99 KB
/
query.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
package main
import (
"net"
"strings"
"github.com/miekg/dns"
)
var client dns.Client
func init() {
client.Timeout = globalTimeout
client.Dialer = &net.Dialer{
Timeout: globalTimeout,
}
}
// NOTE: these query functions are not fully recursive
// they are meant to be used with a fully recursive resolver like unbound/bind/named
func queryNS(server, domain string) ([]string, error) {
domain = dns.Fqdn(domain)
v("dns query: @%s NS %s", server, domain)
m := new(dns.Msg)
m.SetQuestion(domain, dns.TypeNS)
in, _, err := client.Exchange(m, server)
if err != nil {
return nil, err
}
out := make([]string, 0, 2)
for i := range in.Answer {
if t, ok := in.Answer[i].(*dns.NS); ok {
v("dns answer NS @%s\t%s:\t%s\n", server, domain, t.Ns)
t.Ns = strings.ToLower(t.Ns)
out = append(out, t.Ns)
}
}
return out, nil
}
func queryA(server, domain string) ([]net.IP, error) {
domain = dns.Fqdn(domain)
v("dns query: @%s A %s", server, domain)
m := new(dns.Msg)
m.SetQuestion(domain, dns.TypeA)
in, _, err := client.Exchange(m, server)
if err != nil {
return nil, err
}
out := make([]net.IP, 0, 1)
for i := range in.Answer {
if t, ok := in.Answer[i].(*dns.A); ok {
v("dns answer A @%s\t%s:\t%s\n", server, domain, t.A.String())
out = append(out, t.A)
}
}
return out, nil
}
func queryAAAA(server, domain string) ([]net.IP, error) {
domain = dns.Fqdn(domain)
v("dns query: @%s AAAA %s", server, domain)
m := new(dns.Msg)
m.SetQuestion(domain, dns.TypeAAAA)
in, _, err := client.Exchange(m, server)
if err != nil {
return nil, err
}
out := make([]net.IP, 0, 1)
for i := range in.Answer {
if t, ok := in.Answer[i].(*dns.AAAA); ok {
v("dns answer AAAA @%s\t%s:\t%s\n", server, domain, t.AAAA.String())
out = append(out, t.AAAA)
}
}
return out, nil
}
func queryIP(server, domain string) ([]net.IP, error) {
aIPs, err := queryA(server, domain)
if err != nil {
return aIPs, err
}
aaaaIPs, err := queryAAAA(server, domain)
return append(aIPs, aaaaIPs...), err
}