HttpAsyncServer.h

// Copyright (c) Stefano Cristiano
// SPDX-License-Identifier: MIT
#pragma once
#include "HttpServer.h"
namespace SC
{
#if SC_COMPILER_MSVC
#pragma warning(push)
#pragma warning(disable : 4251)
#endif
struct SC_COMPILER_EXPORT HttpAsyncServer
{
    Result start(AsyncEventLoop& loop, StringSpan address, uint16_t port, HttpServer::Memory& memory);
 
    Result stopAsync();
 
    Result stopSync();
 
    [[nodiscard]] bool isStarted() const { return started; }
 
    void setupStreamsMemory(Span<AsyncReadableStream::Request> readQueue, Span<AsyncWritableStream::Request> writeQueue,
                            Span<AsyncBufferView> buffers);
 
    HttpServer httpServer;
 
  private:
    AsyncBuffersPool buffersPool;
 
    Span<AsyncReadableStream::Request> readQueues;
    Span<AsyncWritableStream::Request> writeQueues;
 
    bool started  = false;
    bool stopping = false;
 
    void onNewClient(AsyncSocketAccept::Result& result);
    void closeAsync(HttpServerClient& requestClient);
 
    void onStreamReceive(HttpServerClient& client, AsyncBufferView::ID bufferID);
 
    AsyncEventLoop*   eventLoop = nullptr;
    SocketDescriptor  serverSocket;
    AsyncSocketAccept asyncServerAccept;
};
#if SC_COMPILER_MSVC
#pragma warning(pop)
#endif
} // namespace SC