Method prepareBodyStream

Libraries/Http/HttpConnection.cpp:487–532

bool HttpIncomingMessage::pushBodyData(AsyncBufferView::ID bufferID, size_t sizeInBytes)
{
    return bodyStream.pushBodyData(bufferID, sizeInBytes);
}

void HttpIncomingMessage::finishBodyStream()
{
    bodyComplete = true;
    bodyStream.finishBody();
}

void HttpIncomingMessage::failBodyStream(Result result)
{
    bodyComplete = false;
    bodyStream.failBody(result);
}

void HttpIncomingMessage::abortBodyStream() { bodyStream.destroy(); }

Result HttpIncomingMessage::prepareBodyStream(AsyncBuffersPool& buffersPool, Function<Result()>&& onReadRequest,
                                              bool allowCloseDelimited)
{
    StringSpan transferEncoding;
    StringSpan contentLengthValue;
    const bool hasTransferEncoding = getHeader("Transfer-Encoding", transferEncoding);
    if (hasTransferEncoding and getHeader("Content-Length", contentLengthValue))
    {
        return Result::Error(HttpResultCategory, HttpError::BodyFramingHeadersConflict);
    }

    if (hasTransferEncoding)
    {
        if (not scHttpTransferEncodingIsChunked(transferEncoding))
        {
            return Result::Error(HttpResultCategory, HttpError::TransferEncodingUnsupported);
        }
        bodyFramingKind       = HttpBodyFramingKind::Chunked;
        bodyBytesRemaining    = 0;
        bodyComplete          = false;
        chunkedState          = ChunkedState::Size;
        chunkedChunkSize      = 0;
        chunkedBytesRemaining = 0;
        chunkedSizeHasDigits  = false;
    }
    else if (getHeader("Content-Length", contentLengthValue))
    {
        bodyFramingKind    = HttpBodyFramingKind::ContentLength;
        bodyBytesRemaining = getParser().contentLength;
        bodyComplete       = (bodyBytesRemaining == 0);
    }