Method putFile

Libraries/Http/HttpAsyncFileServer.cpp:335–370

}

Result HttpAsyncFileServer::putFile(HttpAsyncFileServer::Stream& stream, HttpConnection& connection,
                                    StringSpan filePath)
{
    StringPath path;
    SC_TRY(path.assign(directory.view()));
    SC_TRY(path.append("/"));
    SC_TRY(path.append(filePath));
    const size_t   totalFileUploadBytes = static_cast<size_t>(connection.request.getBodyBytesRemaining());
    FileDescriptor fd;
    SC_TRY(fd.open(path.view(), FileOpen::Write));
    if (totalFileUploadBytes == 0)
    {
        SC_TRY(fd.close());
        return connection.response.sendEmpty(201);
    }

    SC_TRY(stream.writableFileStream.init(connection.buffersPool, *eventLoop, fd));
    SC_TRY(stream.writableFileStream.request.executeOn(stream.writableFileStreamTask, *threadPool));
    fd.detach();
    stream.writableFileStream.setAutoCloseDescriptor(true);

    HttpConnection& asyncConnection = static_cast<HttpConnection&>(connection);

    stream.putFileListener.connection = &asyncConnection;
    const bool addedFinishListener =
        stream.writableFileStream.eventFinish.addListener<HttpAsyncFileServer::Stream::PutFileListener,
                                                          &HttpAsyncFileServer::Stream::PutFileListener::onFinish>(
            stream.putFileListener);
    SC_HTTP_ASSERT_RELEASE(addedFinishListener);

    connection.pipeline.source   = &connection.request.getReadableStream();
    connection.pipeline.sinks[0] = &stream.writableFileStream;
    SC_TRY(connection.pipeline.pipe());
    SC_TRY(connection.pipeline.start());
    return Result(true);
}

void HttpAsyncFileServer::Stream::PutFileListener::onFinish()
{