Function NewProxy

core/proxy.go:30–122

Creates goproxy.ProxyHttpServer and configures it to be used as a proxy for Hoverfly goproxy is given handlers that use the Hoverfly request processing

(hoverfly *Hoverfly)

// Creates goproxy.ProxyHttpServer and configures it to be used as a proxy for Hoverfly
// goproxy is given handlers that use the Hoverfly request processing
func NewProxy(hoverfly *Hoverfly) *goproxy.ProxyHttpServer {
	ProxyAuthorizationHeader = hoverfly.Cfg.ProxyAuthorizationHeader

	// creating proxy
	proxy := goproxy.NewProxyHttpServer()

	// Fix #774: HTTP/1.1 clients may send requests with a relative URL (path only) and a Host header.
	// goproxy's default NonproxyHandler returns 500 for these. Reconstruct the absolute URL from the
	// Host header so the request is processed normally, matching the behaviour of NewWebserverProxy.
	//
	// Guard: if the Host header targets the proxy's own port the client is connecting directly to
	// Hoverfly (not using it as a proxy). In that case keep the original 500 "is a proxy server"
	// response — forwarding to ourselves would cause infinite recursion or a panic.
	proxy.NonproxyHandler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if r.Host == "" {
			http.Error(w, "Cannot handle requests without Host header, e.g., HTTP 1.0", http.StatusBadRequest)
			return
		}
		if _, port, err := net.SplitHostPort(r.Host); err == nil && port == hoverfly.Cfg.ProxyPort {
			http.Error(w, "This is a proxy server. Does not respond to non-proxy requests.", http.StatusInternalServerError)
			return
		}
		r.URL.Scheme = "http"
		r.URL.Host = r.Host
		proxy.ServeHTTP(w, r)
	})

	if hoverfly.Cfg.AuthEnabled {
		log.Info("Enabling proxy authentication")
		proxyBasicAndBearer(proxy, "hoverfly", func(user, password string) bool {

			proxyUser := &backends.User{
				Username: user,
				Password: password,
			}

			responseStatus, _ := authentication.Login(proxyUser, hoverfly.Authentication, nil, 0)

			return responseStatus == http.StatusOK
		}, func(headerToken string) bool {
			return authentication.IsJwtTokenValid(headerToken, hoverfly.Authentication, hoverfly.Cfg.SecretKey, hoverfly.Cfg.JWTExpirationDelta)
		})
	}

	proxy.OnRequest(matchesFilter(hoverfly.Cfg.Destination)).
		HandleConnect(goproxy.FuncHttpsHandler(func(host string, ctx *goproxy.ProxyCtx) (*goproxy.ConnectAction, string) {
			if hoverfly.Cfg.PlainHttpTunneling && !strings.HasSuffix(host, ":443") {
				return goproxy.HTTPMitmConnect, host
			}
			return goproxy.MitmConnect, host
		}))

	// processing connections
	proxy.OnRequest(matchesFilter(hoverfly.Cfg.Destination)).DoFunc(
		func(r *http.Request, ctx *goproxy.ProxyCtx) (*http.Request, *http.Response) {
			startTime := time.Now()
			resp, journalIDChannel := hoverfly.processRequest(r)
			id, _ := hoverfly.Journal.NewEntry(r, resp, hoverfly.Cfg.Mode, startTime)