Function WrapJSFindProxyForURLFunc

dialer/jsrouter.go:24–56

(f JSFindProxyForURLFunc, logger *clog.CondLogger)

type JSFindProxyForURLFunc = func(url, host string) (string, error)

func WrapJSFindProxyForURLFunc(f JSFindProxyForURLFunc, logger *clog.CondLogger) JSRouterFunc {
	return func(req *jsext.JSRequestInfo, dst *jsext.JSDstInfo, _ string) (string, error) {
		h := dst.OriginalHost
		scheme := "https"
		if req != nil && req.Method != "CONNECT" {
			scheme = "http"
		}
		u := &url.URL{
			Scheme: scheme,
			Host:   net.JoinHostPort(dst.OriginalHost, strconv.Itoa(int(dst.Port))),
		}
		pSpec, err := f(u.String(), h)
		if err != nil {
			return "", err
		}
		logger.Debug("FindProxyForURL(%q, %q) -> %q", u, h, pSpec)
		pSpec, _, _ = strings.Cut(pSpec, ";")
		pSpec = strings.TrimSpace(pSpec)
		pType, pAddr, _ := strings.Cut(pSpec, " ")
		pAddr = strings.TrimSpace(pAddr)
		switch pType {
		case "", "DIRECT":
			return "", nil
		case "HTTP", "PROXY":
			return "http://" + pAddr, nil
		case "HTTPS":
			return "https://" + pAddr, nil
		case "SOCKS", "SOCKS5":
			return "socks5://" + pAddr, nil
		}
		return "", fmt.Errorf("FindProxyForURL returned unsupported proxy type: %q", pType)
	}
}

type JSRouter struct {
	funcPool     chan JSRouterFunc