Method handle_request

net/http/server.cpp:325–365

    }

    int handle_request(Request &req, Response &resp, std::string_view prefix) override {
        if (req.verb() ==  Verb::CONNECT) {
            auto pos = req.target().find(":");
            estring_view host, port;
            if (pos != std::string_view::npos) {
                host = req.target().substr(0, pos);
                port = req.target().substr(pos + 1);
            } else {
                host = req.target();
                port = "443";
            }

            auto server_stream = m_client->native_connect(host, port.to_uint64());
            if (server_stream == nullptr) {
                resp.set_result(502);
                LOG_ERRNO_RETURN(0, 0, "failed to connect to host `", req.target());
            }
            DEFER(delete server_stream);

            auto client_stream = req.get_socket_stream();
            resp.set_result(200, "Connection Established");
            resp.send();
            bool stopped = false;

            auto th = photon::thread_enable_join(photon::thread_create11([&, other=photon::CURRENT]{
                tunnel_copy(server_stream, client_stream);
                if (!stopped)
                    photon::thread_interrupt(other, ECANCELED);
            }));

            tunnel_copy(client_stream, server_stream);
            stopped = true;

            photon::thread_interrupt((thread*)th, ECANCELED);
            photon::thread_join(th);
            LOG_DEBUG("tunnel exit");
            return 0;
        }

        return ProxyHandler::handle_request(req, resp, prefix);
    }

    static int default_forward_proxy_director(void*, Request &src, Request &dst) {
        LOG_DEBUG("request target = `", src.target());