HttpAsyncFileServer.h

// Copyright (c) Stefano Cristiano
// SPDX-License-Identifier: MIT
#pragma once
#include "../AsyncStreams/AsyncRequestStreams.h"
#include "HttpAsyncServer.h"
 
namespace SC
{
struct SC_COMPILER_EXPORT HttpAsyncFileServer
{
    struct SC_COMPILER_EXPORT Stream
    {
        ReadableFileStream readableFileStream;
        WritableFileStream writableFileStream;
        AsyncTaskSequence  readableFileStreamTask;
    };
 
    template <int RequestsSize>
    struct SC_COMPILER_EXPORT StreamQueue : public Stream
    {
        StreamQueue()
        {
            readableFileStream.setReadQueue(readQueue);
            writableFileStream.setWriteQueue(writeQueue);
        }
        AsyncReadableStream::Request readQueue[RequestsSize];
        AsyncWritableStream::Request writeQueue[RequestsSize];
    };
 
    Result init(ThreadPool& threadPool, AsyncEventLoop& loop, StringSpan directoryToServe);
 
    Result close();
 
    Result handleRequest(HttpAsyncFileServer::Stream& stream, HttpConnection& connection);
 
  private:
    Result putFile(HttpAsyncFileServer::Stream& stream, HttpConnection& connection, StringSpan filePath);
    Result getFile(HttpAsyncFileServer::Stream& stream, HttpConnection& connection, StringSpan filePath);
 
    StringPath directory;
 
    AsyncEventLoop* eventLoop  = nullptr;
    ThreadPool*     threadPool = nullptr;
    struct Internal;
};
 
} // namespace SC