2018-08-29 12:26:22 +01:00
|
|
|
package request
|
|
|
|
|
|
|
|
|
|
import "github.com/miekg/dns"
|
|
|
|
|
|
|
|
|
|
// ScrubWriter will, when writing the message, call scrub to make it fit the client's buffer.
|
|
|
|
|
type ScrubWriter struct {
|
|
|
|
|
dns.ResponseWriter
|
|
|
|
|
req *dns.Msg // original request
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// NewScrubWriter returns a new and initialized ScrubWriter.
|
|
|
|
|
func NewScrubWriter(req *dns.Msg, w dns.ResponseWriter) *ScrubWriter { return &ScrubWriter{w, req} }
|
|
|
|
|
|
2019-02-17 15:31:12 +07:00
|
|
|
// WriteMsg overrides the default implementation of the underlying dns.ResponseWriter and calls
|
2018-08-29 12:26:22 +01:00
|
|
|
// scrub on the message m and will then write it to the client.
|
|
|
|
|
func (s *ScrubWriter) WriteMsg(m *dns.Msg) error {
|
|
|
|
|
state := Request{Req: s.req, W: s.ResponseWriter}
|
2019-07-11 12:54:47 +00:00
|
|
|
state.SizeAndDo(m)
|
|
|
|
|
state.Scrub(m)
|
|
|
|
|
return s.ResponseWriter.WriteMsg(m)
|
2018-08-29 12:26:22 +01:00
|
|
|
}
|