mirror of
https://github.com/m13253/dns-over-https.git
synced 2026-08-28 08:44:07 +00:00
Update to IETF draft-07
This commit is contained in:
@@ -182,21 +182,21 @@ func (c *Client) handlerFunc(w dns.ResponseWriter, r *dns.Msg, isTCP bool) {
|
|||||||
if len(c.conf.UpstreamIETF) == 0 {
|
if len(c.conf.UpstreamIETF) == 0 {
|
||||||
requestType = "application/dns-json"
|
requestType = "application/dns-json"
|
||||||
} else if len(c.conf.UpstreamGoogle) == 0 {
|
} else if len(c.conf.UpstreamGoogle) == 0 {
|
||||||
requestType = "message/dns"
|
requestType = "application/dns-message"
|
||||||
} else {
|
} else {
|
||||||
numServers := len(c.conf.UpstreamGoogle) + len(c.conf.UpstreamIETF)
|
numServers := len(c.conf.UpstreamGoogle) + len(c.conf.UpstreamIETF)
|
||||||
random := rand.Intn(numServers)
|
random := rand.Intn(numServers)
|
||||||
if random < len(c.conf.UpstreamGoogle) {
|
if random < len(c.conf.UpstreamGoogle) {
|
||||||
requestType = "application/dns-json"
|
requestType = "application/dns-json"
|
||||||
} else {
|
} else {
|
||||||
requestType = "message/dns"
|
requestType = "application/dns-message"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
var req *DNSRequest
|
var req *DNSRequest
|
||||||
if requestType == "application/dns-json" {
|
if requestType == "application/dns-json" {
|
||||||
req = c.generateRequestGoogle(w, r, isTCP)
|
req = c.generateRequestGoogle(w, r, isTCP)
|
||||||
} else if requestType == "message/dns" {
|
} else if requestType == "application/dns-message" {
|
||||||
req = c.generateRequestIETF(w, r, isTCP)
|
req = c.generateRequestIETF(w, r, isTCP)
|
||||||
} else {
|
} else {
|
||||||
panic("Unknown request Content-Type")
|
panic("Unknown request Content-Type")
|
||||||
@@ -210,21 +210,21 @@ func (c *Client) handlerFunc(w dns.ResponseWriter, r *dns.Msg, isTCP bool) {
|
|||||||
candidateType := strings.SplitN(req.response.Header.Get("Content-Type"), ";", 2)[0]
|
candidateType := strings.SplitN(req.response.Header.Get("Content-Type"), ";", 2)[0]
|
||||||
if candidateType == "application/json" {
|
if candidateType == "application/json" {
|
||||||
contentType = "application/json"
|
contentType = "application/json"
|
||||||
} else if candidateType == "message/dns" {
|
} else if candidateType == "application/dns-message" {
|
||||||
contentType = "message/dns"
|
contentType = "application/dns-message"
|
||||||
} else if candidateType == "application/dns-udpwireformat" {
|
} else if candidateType == "application/dns-udpwireformat" {
|
||||||
contentType = "message/dns"
|
contentType = "application/dns-message"
|
||||||
} else {
|
} else {
|
||||||
if requestType == "application/dns-json" {
|
if requestType == "application/dns-json" {
|
||||||
contentType = "application/json"
|
contentType = "application/json"
|
||||||
} else if requestType == "message/dns" {
|
} else if requestType == "application/dns-message" {
|
||||||
contentType = "message/dns"
|
contentType = "application/dns-message"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if contentType == "application/json" {
|
if contentType == "application/json" {
|
||||||
c.parseResponseGoogle(w, r, isTCP, req)
|
c.parseResponseGoogle(w, r, isTCP, req)
|
||||||
} else if contentType == "message/dns" {
|
} else if contentType == "application/dns-message" {
|
||||||
c.parseResponseIETF(w, r, isTCP, req)
|
c.parseResponseIETF(w, r, isTCP, req)
|
||||||
} else {
|
} else {
|
||||||
panic("Unknown response Content-Type")
|
panic("Unknown response Content-Type")
|
||||||
|
|||||||
@@ -91,7 +91,7 @@ func (c *Client) generateRequestGoogle(w dns.ResponseWriter, r *dns.Msg, isTCP b
|
|||||||
err: err,
|
err: err,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
req.Header.Set("Accept", "application/json, message/dns, application/dns-udpwireformat")
|
req.Header.Set("Accept", "application/json, application/dns-message, application/dns-udpwireformat")
|
||||||
req.Header.Set("User-Agent", "DNS-over-HTTPS/1.1 (+https://github.com/m13253/dns-over-https)")
|
req.Header.Set("User-Agent", "DNS-over-HTTPS/1.1 (+https://github.com/m13253/dns-over-https)")
|
||||||
c.httpClientMux.RLock()
|
c.httpClientMux.RLock()
|
||||||
resp, err := c.httpClient.Do(req)
|
resp, err := c.httpClient.Do(req)
|
||||||
|
|||||||
+4
-4
@@ -128,7 +128,7 @@ func (c *Client) generateRequestIETF(w dns.ResponseWriter, r *dns.Msg, isTCP boo
|
|||||||
numServers := len(c.conf.UpstreamIETF)
|
numServers := len(c.conf.UpstreamIETF)
|
||||||
upstream := c.conf.UpstreamIETF[rand.Intn(numServers)]
|
upstream := c.conf.UpstreamIETF[rand.Intn(numServers)]
|
||||||
requestURL := fmt.Sprintf("%s?ct=application/dns-udpwireformat&dns=%s", upstream, requestBase64)
|
requestURL := fmt.Sprintf("%s?ct=application/dns-udpwireformat&dns=%s", upstream, requestBase64)
|
||||||
//requestURL := fmt.Sprintf("%s?ct=message/dns&dns=%s", upstream, requestBase64)
|
//requestURL := fmt.Sprintf("%s?ct=application/dns-message&dns=%s", upstream, requestBase64)
|
||||||
|
|
||||||
var req *http.Request
|
var req *http.Request
|
||||||
if len(requestURL) < 2048 {
|
if len(requestURL) < 2048 {
|
||||||
@@ -151,9 +151,9 @@ func (c *Client) generateRequestIETF(w dns.ResponseWriter, r *dns.Msg, isTCP boo
|
|||||||
err: err,
|
err: err,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
req.Header.Set("Content-Type", "message/dns")
|
req.Header.Set("Content-Type", "application/dns-message")
|
||||||
}
|
}
|
||||||
req.Header.Set("Accept", "message/dns, application/dns-udpwireformat, application/json")
|
req.Header.Set("Accept", "application/dns-message, application/dns-udpwireformat, application/json")
|
||||||
req.Header.Set("User-Agent", "DNS-over-HTTPS/1.1 (+https://github.com/m13253/dns-over-https)")
|
req.Header.Set("User-Agent", "DNS-over-HTTPS/1.1 (+https://github.com/m13253/dns-over-https)")
|
||||||
c.httpClientMux.RLock()
|
c.httpClientMux.RLock()
|
||||||
resp, err := c.httpClient.Do(req)
|
resp, err := c.httpClient.Do(req)
|
||||||
@@ -185,7 +185,7 @@ func (c *Client) parseResponseIETF(w dns.ResponseWriter, r *dns.Msg, isTCP bool,
|
|||||||
log.Printf("HTTP error: %s\n", req.response.Status)
|
log.Printf("HTTP error: %s\n", req.response.Status)
|
||||||
req.reply.Rcode = dns.RcodeServerFailure
|
req.reply.Rcode = dns.RcodeServerFailure
|
||||||
contentType := req.response.Header.Get("Content-Type")
|
contentType := req.response.Header.Get("Content-Type")
|
||||||
if contentType != "message/dns" && !strings.HasPrefix(contentType, "message/dns;") {
|
if contentType != "application/dns-message" && !strings.HasPrefix(contentType, "application/dns-message;") {
|
||||||
w.WriteMsg(req.reply)
|
w.WriteMsg(req.reply)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-2
@@ -45,7 +45,7 @@ func (s *Server) parseRequestIETF(w http.ResponseWriter, r *http.Request) *DNSRe
|
|||||||
errtext: fmt.Sprintf("Invalid argument value: \"dns\" = %q", requestBase64),
|
errtext: fmt.Sprintf("Invalid argument value: \"dns\" = %q", requestBase64),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if len(requestBinary) == 0 && (r.Header.Get("Content-Type") == "message/dns" || r.Header.Get("Content-Type") == "application/dns-udpwireformat") {
|
if len(requestBinary) == 0 && (r.Header.Get("Content-Type") == "application/dns-message" || r.Header.Get("Content-Type") == "application/dns-udpwireformat") {
|
||||||
requestBinary, err = ioutil.ReadAll(r.Body)
|
requestBinary, err = ioutil.ReadAll(r.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return &DNSRequest{
|
return &DNSRequest{
|
||||||
@@ -144,7 +144,7 @@ func (s *Server) generateResponseIETF(w http.ResponseWriter, r *http.Request, re
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
w.Header().Set("Content-Type", "message/dns")
|
w.Header().Set("Content-Type", "application/dns-message")
|
||||||
now := time.Now().UTC().Format(http.TimeFormat)
|
now := time.Now().UTC().Format(http.TimeFormat)
|
||||||
w.Header().Set("Date", now)
|
w.Header().Set("Date", now)
|
||||||
w.Header().Set("Last-Modified", now)
|
w.Header().Set("Last-Modified", now)
|
||||||
|
|||||||
@@ -98,7 +98,7 @@ func (s *Server) handlerFunc(w http.ResponseWriter, r *http.Request) {
|
|||||||
if r.FormValue("name") != "" {
|
if r.FormValue("name") != "" {
|
||||||
contentType = "application/dns-json"
|
contentType = "application/dns-json"
|
||||||
} else if r.FormValue("dns") != "" {
|
} else if r.FormValue("dns") != "" {
|
||||||
contentType = "message/dns"
|
contentType = "application/dns-message"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
var responseType string
|
var responseType string
|
||||||
@@ -108,10 +108,10 @@ func (s *Server) handlerFunc(w http.ResponseWriter, r *http.Request) {
|
|||||||
responseType = "application/json"
|
responseType = "application/json"
|
||||||
break
|
break
|
||||||
} else if responseCandidate == "application/dns-udpwireformat" {
|
} else if responseCandidate == "application/dns-udpwireformat" {
|
||||||
responseType = "message/dns"
|
responseType = "application/dns-message"
|
||||||
break
|
break
|
||||||
} else if responseCandidate == "message/dns" {
|
} else if responseCandidate == "application/dns-message" {
|
||||||
responseType = "message/dns"
|
responseType = "application/dns-message"
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -119,17 +119,17 @@ func (s *Server) handlerFunc(w http.ResponseWriter, r *http.Request) {
|
|||||||
// Guess response Content-Type based on request Content-Type
|
// Guess response Content-Type based on request Content-Type
|
||||||
if contentType == "application/dns-json" {
|
if contentType == "application/dns-json" {
|
||||||
responseType = "application/json"
|
responseType = "application/json"
|
||||||
} else if contentType == "message/dns" {
|
} else if contentType == "application/dns-message" {
|
||||||
responseType = "message/dns"
|
responseType = "application/dns-message"
|
||||||
} else if contentType == "application/dns-udpwireformat" {
|
} else if contentType == "application/dns-udpwireformat" {
|
||||||
responseType = "message/dns"
|
responseType = "application/dns-message"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
var req *DNSRequest
|
var req *DNSRequest
|
||||||
if contentType == "application/dns-json" {
|
if contentType == "application/dns-json" {
|
||||||
req = s.parseRequestGoogle(w, r)
|
req = s.parseRequestGoogle(w, r)
|
||||||
} else if contentType == "message/dns" {
|
} else if contentType == "application/dns-message" {
|
||||||
req = s.parseRequestIETF(w, r)
|
req = s.parseRequestIETF(w, r)
|
||||||
} else if contentType == "application/dns-udpwireformat" {
|
} else if contentType == "application/dns-udpwireformat" {
|
||||||
req = s.parseRequestIETF(w, r)
|
req = s.parseRequestIETF(w, r)
|
||||||
@@ -151,7 +151,7 @@ func (s *Server) handlerFunc(w http.ResponseWriter, r *http.Request) {
|
|||||||
|
|
||||||
if responseType == "application/json" {
|
if responseType == "application/json" {
|
||||||
s.generateResponseGoogle(w, r, req)
|
s.generateResponseGoogle(w, r, req)
|
||||||
} else if responseType == "message/dns" {
|
} else if responseType == "application/dns-message" {
|
||||||
s.generateResponseIETF(w, r, req)
|
s.generateResponseIETF(w, r, req)
|
||||||
} else {
|
} else {
|
||||||
panic("Unknown response Content-Type")
|
panic("Unknown response Content-Type")
|
||||||
|
|||||||
Reference in New Issue
Block a user