Method AsyncRequest

src/plugin/net/src/AFCHttpClient.cpp:43–118

}

ananas::Future<std::pair<bool, std::string>> AFCHttpClient::AsyncRequest(
    brynet::net::http::HttpRequest::HTTP_METHOD http_method, const std::string& ip, const uint16_t port,
    const std::string& url, std::map<std::string, std::string>& params, const std::vector<std::string>& cookies,
    const std::string& http_body)
{
    using namespace brynet::net;
    using namespace brynet::net::http;

    http::HttpRequest request;
    request.setMethod(http_method);
    request.setUrl(url);
    request.addHeadValue("Host", std::string(ip) + std::string(":") + ARK_TO_STRING(port));

    for (auto cookie : cookies)
    {
        request.setCookie(cookie);
    }

    request.setContentType("application/json");

    switch (http_method)
    {
        case brynet::net::http::HttpRequest::HTTP_METHOD::HTTP_METHOD_POST:
        case brynet::net::http::HttpRequest::HTTP_METHOD::HTTP_METHOD_PUT:
            if (!http_body.empty())
            {
                request.setBody(http_body);
            }
            break;
        default:
            break;
    }

    HttpQueryParameter query_params;
    for (auto iter : params)
    {
        query_params.add(iter.first, iter.second);
    }

    request.setQuery(query_params.getResult());
    std::string req_url = request.getResult();

    // promise
    ananas::Promise<std::pair<bool, std::string>> promise;

    // start to connect
    connection_builder_.configureConnector(connector_)
        .configureService(tcp_service_)
        .configureConnectOptions({AsyncConnector::ConnectOptions::WithAddr(ip, port),
            AsyncConnector::ConnectOptions::WithTimeout(ARK_CONNECT_TIMEOUT),
            AsyncConnector::ConnectOptions::WithFailedCallback(
                [=]() mutable { promise.SetValue(std::make_pair(false, std::string())); })})
        .configureConnectionOptions({TcpService::AddSocketOption::WithMaxRecvBufferSize(ARK_HTTP_RECV_BUFFER_SIZE),
            TcpService::AddSocketOption::AddEnterCallback([](const TcpConnection::Ptr& session) {
#ifdef ARK_RUN_MODE_DEBUG
                CONSOLE_INFO_LOG << "http client connected!" << std::endl;
#endif
            })})