Method dialUpstreamAndBridge

proxy/client.go:220–264

(downstreamConn net.Conn, host string, resp []byte, extra, dialStyle byte)

}

func (proxy *ProxyClient) dialUpstreamAndBridge(downstreamConn net.Conn, host string, resp []byte, extra, dialStyle byte) net.Conn {
	upstreamConn, err := proxy.dialUpstream(0)
	if err != nil {
		proxy.Logger.E("Dial", "Error", err)
		downstreamConn.Close()
		return nil
	}

	r := proxy.Cipher.newRequest()
	r.Opt = Options(doConnect | extra)
	r.Auth = proxy.UserAuth
	if proxy.Partial {
		r.Opt.Set(doPartial)
	}

	var pl buffer
	pl.Writes("GET /", proxy.encryptHost(host, r), " HTTP/1.1\r\nHost: ", proxy.genHost(), "\r\n")

	for _, h := range dummyHeaders {
		if v, ok := proxy.dummies.Get(h); ok && v.(string) != "" {
			pl.Writes(h, ": ", v.(string), "\r\n")
		}
	}

	upstreamConn.Write(pl.Writes("\r\n").Bytes())
	buf, err := readUntil(upstreamConn, "\r\n\r\n")
	// the first 15 bytes MUST be "HTTP/1.1 200 OK"
	if err != nil || len(buf) < 15 || !bytes.Equal(buf[:15], []byte("HTTP/1.1 200 OK")) {
		if err != nil {
			proxy.Logger.E("Client", "Invalid response", host, err)
		}

		upstreamConn.Close()
		downstreamConn.Close()
		return nil
	}

	if resp != nil {
		downstreamConn.Write(resp)
	}

	go proxy.Cipher.IO.Bridge(downstreamConn, upstreamConn, &r.iv, IOConfig{Partial: proxy.Partial})

	return upstreamConn
}

func (proxy *ProxyClient) dialUpstreamAndBridgeWS(downstreamConn net.Conn, host string, resp []byte, extra, dialStyle byte) net.Conn {
	upstreamConn, err := proxy.dialUpstream(dialStyle)