Method handleHTTP

pkg/http/server.go:134–181

(conn net.Conn, req *http.Request, isConnectMethod bool)

}

func (s *Server) handleHTTP(conn net.Conn, req *http.Request, isConnectMethod bool) error {
	if s.UserConnectHandle == nil {
		return s.embedHandleHTTP(conn, req, isConnectMethod)
	}

	if isConnectMethod {
		_, err := conn.Write([]byte("HTTP/1.1 200 Connection Established\r\n\r\n"))
		if err != nil {
			return err
		}
	} else {
		cConn := &customConn{
			Conn: conn,
			req:  req,
		}
		conn = cConn
	}

	targetAddr := req.URL.Host
	host, portStr, err := net.SplitHostPort(targetAddr)
	if err != nil {
		host = targetAddr
		if req.URL.Scheme == "https" || isConnectMethod {
			portStr = "443"
		} else {
			portStr = "80"
		}
		targetAddr = net.JoinHostPort(host, portStr)
	}

	portInt, err := strconv.Atoi(portStr)
	if err != nil {
		return err // Handle the error if the port string is not a valid integer.
	}
	port := int32(portInt)

	proxyReq := &statute.ProxyRequest{
		Conn:        conn,
		Reader:      io.Reader(conn),
		Writer:      io.Writer(conn),
		Network:     "tcp",
		Destination: targetAddr,
		DestHost:    host,
		DestPort:    port,
	}

	return s.UserConnectHandle(proxyReq)
}

func (s *Server) embedHandleHTTP(conn net.Conn, req *http.Request, isConnectMethod bool) error {
	defer func() {