Method tryParseResponse

Tests/Libraries/Http/HttpTestClient.cpp:367–423

}

void SC::HttpTestClient::tryParseResponse(AsyncSocketReceive::Result& result)
{
    receivedBytes += result.completionData.numBytes;
    SC_ASSERT_RELEASE(content.resize(receivedBytes));
    Span<const char> readData;
    SC_ASSERT_RELEASE(content.toSpanConst().sliceStart(parsedBytes, readData));
    bool parsedSuccessfully = true;
    if (not headersReceived)
    {
        size_t readBytes;
        while (parsedSuccessfully and not readData.empty())
        {
            Span<const char> parsedData;
            parsedSuccessfully &= parser.parse(readData, readBytes, parsedData);
            parsedSuccessfully &= readData.sliceStart(readBytes, readData);
            parsedBytes += readBytes;
            if (parser.state == HttpParser::State::Result and parser.token == HttpParser::Token::HeaderValue)
            {
                if (parser.matchesHeader(HttpParser::HeaderType::ContentLength))
                {
                    contentLen = static_cast<size_t>(parser.contentLength);
                }
            }
            if (parser.token == HttpParser::Token::HeadersEnd)
            {
                headersReceived = true;
                break;
            }
        }
    }
    const size_t expectedContentLen = responseHasNoBody and headersReceived ? 0 : contentLen;
    if (content.size() == parsedBytes + expectedContentLen)
    {
        // If we're not keeping the connection open, or if the server closed the connection, close it
        if (not keepConnectionOpen or result.completionData.disconnected)
        {
            SC_ASSERT_RELEASE(clientSocket.close());
            hasActiveConnection = false;
        }
        // Call the callback regardless
        callback(*this);
    }
    else
    {
        SC_ASSERT_RELEASE(content.reserve(receivedBytes + 1024));
        SC_ASSERT_RELEASE(content.resize(content.capacity()));
        SC_ASSERT_RELEASE(content.toSpan().sliceStart(receivedBytes, receiveAsync.buffer));
        if (parsedSuccessfully)
        {
            result.reactivateRequest(true);
        }
        else
        {
            // TODO: raise error
        }
    }
}