Method handleRequest

bcos-boostssl/bcos-boostssl/httpserver/HttpSession.cpp:122–181

    }
}
void bcos::boostssl::http::HttpSession::handleRequest(const HttpRequest& _httpRequest)
{
    HTTP_SESSION(DEBUG) << LOG_BADGE("handleRequest") << LOG_DESC("request")
                        << LOG_KV("method", _httpRequest.method_string())
                        << LOG_KV("target", _httpRequest.target())
                        << LOG_KV("body", _httpRequest.body())
                        << LOG_KV("keep_alive", _httpRequest.keep_alive())
                        << LOG_KV("need_eof", _httpRequest.need_eof());

    auto startT = utcTime();
    unsigned version = _httpRequest.version();

    // handle options request for CORS preflight
    if (_httpRequest.method() == boost::beast::http::verb::options)
    {
        // The standard response status code for preflight requests is 204(No Content)
        auto resp = buildHttpResp(boost::beast::http::status::no_content, _httpRequest.keep_alive(),
            version, {}, m_corsConfig);

        BCOS_LOG(TRACE) << LOG_BADGE("handleRequest") << LOG_DESC("options response")
                        << LOG_KV("body", std::string_view((const char*)resp->body().data(),
                                              resp->body().size()))
                        << LOG_KV("keep_alive", resp->keep_alive())
                        << LOG_KV("need_eof", resp->need_eof())
                        << LOG_KV("timecost", (utcTime() - startT));

        queue().enqueue(std::move(resp));
        return;
    }

    // handle http request
    if (m_httpReqHandler)
    {
        const std::string& request = _httpRequest.body();
        m_httpReqHandler(request, [session = shared_from_this(), version, startT,
                                      keepAlive = _httpRequest.keep_alive()](bcos::bytes _content) {
            auto resp = session->buildHttpResp(boost::beast::http::status::ok, keepAlive, version,
                std::move(_content), session->corsConfig());
            // put the response into the queue and waiting to be send
            BCOS_LOG(TRACE) << LOG_BADGE("handleRequest") << LOG_DESC("response")
                            << LOG_KV("body", std::string_view((const char*)resp->body().data(),
                                                  resp->body().size()))
                            << LOG_KV("keep_alive", resp->keep_alive())
                            << LOG_KV("need_eof", resp->need_eof())
                            << LOG_KV("timecost", (utcTime() - startT));
            session->queue().enqueue(std::move(resp));
        });
    }
    else
    {
        // unsupported http service
        auto resp = buildHttpResp(boost::beast::http::status::http_version_not_supported,
            _httpRequest.keep_alive(), version, {}, m_corsConfig);
        // put the response into the queue and waiting to be send
        HTTP_SESSION(WARNING) << LOG_BADGE("handleRequest") << LOG_DESC("unsupported http service")
                              << LOG_KV("body", std::string_view((const char*)resp->body().data(),
                                                    resp->body().size()));
        queue().enqueue(std::move(resp));