package dns // A concurrent client implementation. // Client sends query to a channel which // will then handle the query. Returned replys // are return on another channel. Ready for handling --- same // setup for server - a HANDLER function that gets run // when the query returns. import ( "io" "net" "time" ) // Incoming (just as in os.Signal) type QueryHandler interface { QueryDNS(w RequestWriter, q *Msg) } // The RequestWriter interface is used by a DNS query handler to // construct a DNS request. type RequestWriter interface { Write(*Msg) Send(*Msg) error Receive() (*Msg, error) Close() error Dial() error } // hijacked connections...? type reply struct { client *Client addr string req *Msg conn net.Conn tsigRequestMAC string tsigTimersOnly bool } // A Request is a incoming message from a Client type Request struct { Request *Msg Addr string Client *Client } // QueryMux is an DNS request multiplexer. It matches the // zone name of each incoming request against a list of // registered patterns add calls the handler for the pattern // that most closely matches the zone name. type QueryMux struct { m map[string]QueryHandler } // NewQueryMux allocates and returns a new QueryMux. func NewQueryMux() *QueryMux { return &QueryMux{make(map[string]QueryHandler)} } // DefaultQueryMux is the default QueryMux used by Query. var DefaultQueryMux = NewQueryMux() func newQueryChanSlice() chan *Exchange { return make(chan *Exchange) } func newQueryChan() chan *Request { return make(chan *Request) } // Default channels to use for the resolver var ( // DefaultReplyChan is the channel on which the replies are // coming back. Is it a channel of *Exchange, so that the original // question is included with the answer. DefaultReplyChan = newQueryChanSlice() // DefaultQueryChan is the channel were you can send the questions to. DefaultQueryChan = newQueryChan() ) // The HandlerQueryFunc type is an adapter to allow the use of // ordinary functions as DNS query handlers. If f is a function // with the appropriate signature, HandlerQueryFunc(f) is a // QueryHandler object that calls f. type HandlerQueryFunc func(RequestWriter, *Msg) // QueryDNS calls f(w, reg) func (f HandlerQueryFunc) QueryDNS(w RequestWriter, r *Msg) { go f(w, r) } func HandleQueryFunc(pattern string, handler func(RequestWriter, *Msg)) { DefaultQueryMux.HandleQueryFunc(pattern, handler) } // reusing zoneMatch from server.go func (mux *QueryMux) match(zone string) QueryHandler { var h QueryHandler var n = 0 for k, v := range mux.m { if !zoneMatch(k, zone) { continue } if h == nil || len(k) > n { n = len(k) h = v } } return h } func (mux *QueryMux) Handle(pattern string, handler QueryHandler) { if pattern == "" { panic("dns: invalid pattern " + pattern) } mux.m[pattern] = handler } func (mux *QueryMux) HandleQueryFunc(pattern string, handler func(RequestWriter, *Msg)) { mux.Handle(pattern, HandlerQueryFunc(handler)) } func (mux *QueryMux) QueryDNS(w RequestWriter, r *Msg) { h := mux.match(r.Question[0].Name) if h == nil { panic("dns: no handler found for " + r.Question[0].Name) } h.QueryDNS(w, r) } type Client struct { Net string // if "tcp" a TCP query will be initiated, otherwise an UDP one Attempts int // number of attempts Retry bool // retry with TCP QueryChan chan *Request // read DNS request from this channel ReplyChan chan *Exchange // write the reply (together with the DNS request) to this channel ReadTimeout time.Duration // the net.Conn.SetReadTimeout value for new connections (ns) WriteTimeout time.Duration // the net.Conn.SetWriteTimeout value for new connections (ns) TsigSecret map[string]string // secret(s) for Tsig map[] Hijacked net.Conn // if set the calling code takes care of the connection // LocalAddr string // Local address to use } // NewClient creates a new client, with Net set to "udp" and Attempts to 1. // The client's ReplyChan is set to DefaultReplyChan and QueryChan // to DefaultQueryChan. func NewClient() *Client { c := new(Client) c.Net = "udp" c.Attempts = 1 c.ReplyChan = DefaultReplyChan c.QueryChan = DefaultQueryChan c.ReadTimeout = 2 * 1e9 c.WriteTimeout = 2 * 1e9 return c } type Query struct { QueryChan chan *Request // read DNS request from this channel Handler QueryHandler // handler to invoke, dns.DefaultQueryMux if nil } func (q *Query) Query() error { handler := q.Handler if handler == nil { handler = DefaultQueryMux } //forever: for { select { case in := <-q.QueryChan: w := new(reply) w.req = in.Request w.addr = in.Addr w.client = in.Client handler.QueryDNS(w, in.Request) } } return nil } func (q *Query) ListenAndQuery() error { if q.QueryChan == nil { q.QueryChan = DefaultQueryChan } return q.Query() } // ListenAndQuery starts the listener for firing off the queries. If // c is nil DefaultQueryChan is used. If handler is nil // DefaultQueryMux is used. func ListenAndQuery(request chan *Request, handler QueryHandler) { q := &Query{QueryChan: request, Handler: handler} go q.ListenAndQuery() } // Write returns the original question and the answer on the // reply channel of the client. func (w *reply) Write(m *Msg) { w.Client().ReplyChan <- &Exchange{Request: w.req, Reply: m} } // Do performs an asynchronous query. The result is returned on the // QueryChan channel set in the Client c. func (c *Client) Do(m *Msg, a string) { c.QueryChan <- &Request{Client: c, Addr: a, Request: m} } // ExchangeBuffer performs a synchronous query. It sends the buffer m to the // address contained in a. func (c *Client) ExchangeBuffer(inbuf []byte, a string, outbuf []byte) (n int, err error) { w := new(reply) w.client = c w.addr = a if c.Hijacked == nil { if err = w.Dial(); err != nil { return 0, err } defer w.Close() } if c.Hijacked != nil { w.conn = c.Hijacked } if n, err = w.writeClient(inbuf); err != nil { return 0, err } if n, err = w.readClient(outbuf); err != nil { return n, err } return n, nil } // Exchange performs an synchronous query. It sends the message m to the address // contained in a and waits for an reply. func (c *Client) Exchange(m *Msg, a string) (r *Msg, err error) { var n int out, ok := m.Pack() if !ok { return nil, ErrPack } var in []byte switch c.Net { case "tcp": in = make([]byte, MaxMsgSize) case "udp": size := UDPMsgSize for _, r := range m.Extra { if r.Header().Rrtype == TypeOPT { size = int(r.(*RR_OPT).UDPSize()) } } in = make([]byte, size) } if n, err = c.ExchangeBuffer(out, a, in); err != nil { return nil, err } r = new(Msg) if ok := r.Unpack(in[:n]); !ok { return nil, ErrUnpack } return r, nil } // Dial connects to the address addr for the network set in c.Net func (w *reply) Dial() error { conn, err := net.Dial(w.Client().Net, w.addr) if err != nil { return err } w.conn = conn return nil } // UDP/TCP stuff big TODO // Close/noclose func (w *reply) Close() (err error) { return w.conn.Close() } func (w *reply) Client() *Client { return w.client } func (w *reply) Request() *Msg { return w.req } func (w *reply) Receive() (*Msg, error) { var p []byte m := new(Msg) switch w.Client().Net { case "tcp", "tcp4", "tcp6": p = make([]byte, MaxMsgSize) case "udp", "udp4", "udp6": p = make([]byte, DefaultMsgSize) } n, err := w.readClient(p) if err != nil { return nil, err } p = p[:n] if ok := m.Unpack(p); !ok { return nil, ErrUnpack } // Tsig if m.IsTsig() { secret := m.Extra[len(m.Extra)-1].(*RR_TSIG).Hdr.Name _, ok := w.Client().TsigSecret[secret] if !ok { return m, ErrSecret } // Need to work on the original message p, as that was used // to calculate the tsig. err := TsigVerify(p, w.Client().TsigSecret[secret], w.tsigRequestMAC, w.tsigTimersOnly) if err != nil { return m, err } } return m, nil } func (w *reply) readClient(p []byte) (n int, err error) { if w.conn == nil { return 0, ErrConnEmpty //panic("no connection") } switch w.Client().Net { case "tcp", "tcp4", "tcp6": if len(p) < 1 { return 0, io.ErrShortBuffer } for a := 0; a < w.Client().Attempts; a++ { w.conn.SetReadDeadline(time.Now().Add(w.Client().ReadTimeout)) w.conn.SetWriteDeadline(time.Now().Add(w.Client().WriteTimeout)) n, err = w.conn.(*net.TCPConn).Read(p[0:2]) if err != nil || n != 2 { if e, ok := err.(net.Error); ok && e.Timeout() { continue } return n, err } l, _ := unpackUint16(p[0:2], 0) if l == 0 { return 0, ErrShortRead } if int(l) > len(p) { return int(l), io.ErrShortBuffer } n, err = w.conn.(*net.TCPConn).Read(p[:l]) if err != nil { if e, ok := err.(net.Error); ok && e.Timeout() { continue } return n, err } i := n for i < int(l) { j, err := w.conn.(*net.TCPConn).Read(p[i:int(l)]) if err != nil { if e, ok := err.(net.Error); ok && e.Timeout() { // We are half way in our read... continue } return i, err } i += j } n = i } case "udp", "udp4", "udp6": for a := 0; a < w.Client().Attempts; a++ { w.conn.SetReadDeadline(time.Now().Add(w.Client().ReadTimeout)) w.conn.SetWriteDeadline(time.Now().Add(w.Client().ReadTimeout)) n, _, err = w.conn.(*net.UDPConn).ReadFromUDP(p) if err != nil { if e, ok := err.(net.Error); ok && e.Timeout() { continue } return n, err } } } return } // Send sends a dns msg to the address specified in w. // If the message m contains a TSIG record the transaction // signature is calculated. func (w *reply) Send(m *Msg) error { if m.IsTsig() { secret := m.Extra[len(m.Extra)-1].(*RR_TSIG).Hdr.Name _, ok := w.Client().TsigSecret[secret] if !ok { return ErrSecret } // Compressie maakt dit stuk if err := TsigGenerate(m, w.Client().TsigSecret[secret], w.tsigRequestMAC, w.tsigTimersOnly); err != nil { return err } w.tsigRequestMAC = m.Extra[len(m.Extra)-1].(*RR_TSIG).MAC // Save the requestMAC for the next packet } out, ok := m.Pack() if !ok { return ErrPack } _, err := w.writeClient(out) if err != nil { return err } return nil } func (w *reply) writeClient(p []byte) (n int, err error) { if w.Client().Attempts == 0 { panic("c.Attempts 0") } if w.Client().Net == "" { panic("c.Net empty") } if w.Client().Hijacked == nil { if err = w.Dial(); err != nil { return 0, err } } switch w.Client().Net { case "tcp", "tcp4", "tcp6": if len(p) < 2 { return 0, io.ErrShortBuffer } for a := 0; a < w.Client().Attempts; a++ { w.conn.SetWriteDeadline(time.Now().Add(w.Client().WriteTimeout)) w.conn.SetReadDeadline(time.Now().Add(w.Client().ReadTimeout)) a, b := packUint16(uint16(len(p))) n, err = w.conn.Write([]byte{a, b}) if err != nil { if e, ok := err.(net.Error); ok && e.Timeout() { continue } return n, err } if n != 2 { return n, io.ErrShortWrite } n, err = w.conn.Write(p) if err != nil { if e, ok := err.(net.Error); ok && e.Timeout() { continue } return n, err } i := n if i < len(p) { j, err := w.conn.Write(p[i:len(p)]) if err != nil { if e, ok := err.(net.Error); ok && e.Timeout() { // We are half way in our write... continue } return i, err } i += j } n = i } case "udp", "udp4", "udp6": for a := 0; a < w.Client().Attempts; a++ { w.conn.SetWriteDeadline(time.Now().Add(w.Client().WriteTimeout)) w.conn.SetReadDeadline(time.Now().Add(w.Client().ReadTimeout)) n, err = w.conn.(*net.UDPConn).Write(p) if err != nil { if e, ok := err.(net.Error); ok && e.Timeout() { continue } return n, err } } } return }