Method HandleRequest

handler/handler.go:168–200

(wr http.ResponseWriter, req *http.Request, username string)

}

func (s *ProxyHandler) HandleRequest(wr http.ResponseWriter, req *http.Request, username string) {
	req.RequestURI = ""
	forwardReqBody := newH1ReqBodyPipe()
	origBody := req.Body
	req.Body = forwardReqBody.Body()
	address := addressFromURL(req.URL)
	go func() {
		s.forward(req.Context(), username, wrapH1ReqBody(origBody), forwardReqBody, "tcp", address)
	}()
	if req.ProtoMajor == 2 {
		req.URL.Scheme = "http" // We can't access :scheme pseudo-header, so assume http
		req.URL.Host = req.Host
	}
	resp, err := s.httptransport.RoundTrip(req)
	if err != nil {
		var accessErr derrors.ErrAccessDenied
		if errors.As(err, &accessErr) {
			s.logger.Warning("Access denied: %v", err)
			s.rejectAccess(wr, req)
			return
		}
		s.logger.Error("HTTP fetch error: %v", err)
		http.Error(wr, "Server Error", http.StatusInternalServerError)
		return
	}
	defer resp.Body.Close()
	s.logger.Info("%v %v %v %v", req.RemoteAddr, req.Method, req.URL, resp.Status)
	delHopHeaders(resp.Header)
	copyHeader(wr.Header(), resp.Header)
	wr.WriteHeader(resp.StatusCode)
	flush(wr)
	s.forward(req.Context(), username, wrapH1RespWriter(wr), wrapH1ReqBody(resp.Body), "tcp", address)
}

func (s *ProxyHandler) HandleGetRandom(wr http.ResponseWriter, req *http.Request, username string) {
	if len(req.URL.Path) <= 1 || req.URL.Path[0] != '/' {