(res http.ResponseWriter, req *http.Request)
| 67 | } |
| 68 | |
| 69 | func (p *Proxy) defaultHandler(res http.ResponseWriter, req *http.Request) { |
| 70 | errors := p.builder.Errors() |
| 71 | if len(errors) > 0 { |
| 72 | res.Write([]byte(errors)) |
| 73 | } else { |
| 74 | p.runner.Run() |
| 75 | if strings.ToLower(req.Header.Get("Upgrade")) == "websocket" || strings.ToLower(req.Header.Get("Accept")) == "text/event-stream" { |
| 76 | proxyWebsocket(res, req, p.to) |
| 77 | } else { |
| 78 | p.proxy.ServeHTTP(res, req) |
| 79 | } |
| 80 | } |
| 81 | } |
| 82 | |
| 83 | func proxyWebsocket(w http.ResponseWriter, r *http.Request, host *url.URL) { |
| 84 | d, err := net.Dial("tcp", host.Host) |
nothing calls this directly
no test coverage detected