Method onData

Libraries/Http/HttpAsyncFileServer.cpp:910–1009

}

void HttpAsyncFileServer::Stream::MultipartListener::onData(AsyncBufferView::ID bufferID)
{
    AsyncReadableStream& readable = connection->request.getReadableStream();
    AsyncBuffersPool&    buffers  = readable.getBuffersPool();

    Span<const char> data;
    SC_HTTP_ASSERT_RELEASE(buffers.getReadableData(bufferID, data));

    size_t           readBytes;
    Span<const char> parsedData;

    while (not data.empty() and stream->multipartParser.state != HttpMultipartParser::State::Finished)
    {
        SC_HTTP_ASSERT_RELEASE(stream->multipartParser.parse(data, readBytes, parsedData));

        const bool streamedBody =
            stream->multipartParser.token == HttpMultipartParser::Token::PartBody and parsedData.sizeInBytes() > 0;
        if (streamedBody and currentFd.isValid())
        {
            SC_HTTP_ASSERT_RELEASE(currentFd.write(parsedData));
        }

        bool tokenProcessed = false;
        if (stream->multipartParser.state != HttpMultipartParser::State::Parsing)
        {
            tokenProcessed = true;
            switch (stream->multipartParser.token)
            {
            case HttpMultipartParser::Token::Boundary: {
                if (currentFd.isValid())
                {
                    (void)currentFd.close();
                }
                currentHeaderName = {};
                partHeaders.reset();
            }
            break;

            case HttpMultipartParser::Token::HeaderName: {
                currentHeaderName = {parsedData, false, StringEncoding::Ascii};
            }
            break;

            case HttpMultipartParser::Token::HeaderValue: {
                SC_HTTP_ASSERT_RELEASE(
                    partHeaders.addHeader(currentHeaderName, {parsedData, false, StringEncoding::Ascii}));
                if (partHeaders.isFile() and not partHeaders.hasSafeFileName())
                {
                    rejectedFileName = true;
                }
            }
            break;

            case HttpMultipartParser::Token::PartHeaderEnd: {
                if (partHeaders.isSafeFile())
                {
                    (void)currentFilePath.assign(server->directory.view());
                    (void)currentFilePath.append("/");