/
upstream.go
39 lines (29 loc) · 1.06 KB
/
upstream.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
// Package upstream abstracts a upstream lookups so that plugins can handle them in an unified way.
package upstream
import (
"context"
"fmt"
"github.com/inverse-inc/wireguard-go/dns/core/dnsserver"
"github.com/inverse-inc/wireguard-go/dns/plugin/pkg/nonwriter"
"github.com/inverse-inc/wireguard-go/dns/request"
"github.com/miekg/dns"
)
// Upstream is used to resolve CNAME or other external targets via CoreDNS itself.
type Upstream struct{}
// New creates a new Upstream to resolve names using the coredns process.
func New() *Upstream { return &Upstream{} }
// Lookup routes lookups to our selves or forward to a remote.
func (u *Upstream) Lookup(ctx context.Context, state request.Request, name string, typ uint16) (*dns.Msg, error) {
server, ok := ctx.Value(dnsserver.Key{}).(*dnsserver.Server)
if !ok {
return nil, fmt.Errorf("no full server is running")
}
size := state.Size()
do := state.Do()
req := new(dns.Msg)
req.SetQuestion(name, typ)
req.SetEdns0(uint16(size), do)
nw := nonwriter.New(state.W)
server.ServeDNS(ctx, nw, req)
return nw.Msg, nil
}