Method handleNetworkEvent

core/network/HttpClient.cpp:248–403

}

void HttpClient::handleNetworkEvent(yasio::io_event* event)
{
    int channelIndex       = event->cindex();
    auto channel           = _service->channel_at(event->cindex());
    HttpResponse* response = (HttpResponse*)channel->ud_.ptr;
    assert(response);

    bool responseFinished = response->isFinished();
    switch (event->kind())
    {
    case YEK_ON_PACKET:
        if (!responseFinished)
        {
            auto&& pkt = event->packet_view();
            auto err = response->input(pkt.data(), pkt.size());
            if (err != HPE_OK)
            {
                response->updateInternalCode(err);
                _service->close(event->cindex());
                break;
            }
        }
        if (response->isFinished())
        {
            response->updateInternalCode(yasio::errc::eof);
            _service->close(event->cindex());
        }
        break;
    case YEK_ON_OPEN:
        if (event->status() == 0)
        {
            obstream obs;
            bool usePostData = false;
            auto request     = response->getHttpRequest();
            switch (request->getRequestType())
            {
            case HttpRequest::Type::GET:
                obs.write_bytes("GET");
                break;
            case HttpRequest::Type::PATCH:
                obs.write_bytes("PATCH");
                usePostData = true;
                break;
            case HttpRequest::Type::POST:
                obs.write_bytes("POST");
                usePostData = true;
                break;
            case HttpRequest::Type::DELETE:
                obs.write_bytes("DELETE");
                break;
            case HttpRequest::Type::PUT:
                obs.write_bytes("PUT");
                usePostData = true;
                break;
            default:
                obs.write_bytes("GET");
                break;
            }