Method executeBlocking

Libraries/HttpClient/HttpClient.cpp:1702–1772

}

SC::Result SC::HttpClient::executeBlocking(const HttpClientRequest& request, HttpClientResponse& response,
                                           Span<char> bodyBuffer, size_t& bodyLength,
                                           const HttpClientOperationMemory& memory)
{
    bodyLength = 0;

    HttpClient client;
    SC_TRY(client.init());

    struct BlockingListener final : public HttpClientOperationListener
    {
        Span<char>           bodyBuffer;
        size_t*              bodyLength = nullptr;
        bool*                completed  = nullptr;
        Result*              finalRes   = nullptr;
        HttpClientOperation* operation  = nullptr;

        virtual void onResponseBody(Span<const char> data) override
        {
            const size_t remaining = bodyBuffer.sizeInBytes() - *bodyLength;
            const size_t toCopy    = data.sizeInBytes() < remaining ? data.sizeInBytes() : remaining;
            if (toCopy > 0)
            {
                memcpy(bodyBuffer.data() + *bodyLength, data.data(), toCopy);
                *bodyLength += toCopy;
            }
            if (toCopy != data.sizeInBytes())
            {
                *finalRes  = Result::Error("HttpClient: blocking response body buffer too small");
                *completed = true;
                (void)operation->cancel();
            }
        }

        virtual void onResponseComplete() override { *completed = true; }

        virtual void onError(Result error) override
        {
            *completed = true;
            if (*finalRes)
            {
                *finalRes = error;
            }
        }
    };

    HttpClientOperation operation;
    SC_TRY(operation.init(client, memory));

    bool   completed = false;
    Result finalRes(true);

    BlockingListener listener;
    listener.bodyBuffer = bodyBuffer;
    listener.bodyLength = &bodyLength;
    listener.completed  = &completed;
    listener.finalRes   = &finalRes;
    listener.operation  = &operation;