stream_server.h

Go to the documentation of this file.

#pragma once
 
#ifdef FASTLED_HAS_NETWORKING
 
#include "fl/net/http/stream_transport.h"
#include "fl/stl/asio/http/native_server.h"  // IWYU pragma: keep
#include "fl/stl/asio/http/http_parser.h"
#include "fl/stl/string.h"
#include "fl/stl/unique_ptr.h"
#include "fl/stl/flat_map.h"
#include "fl/stl/vector.h"
#include "fl/stl/noexcept.h"
 
namespace fl {
namespace net {
namespace http {

class HttpStreamServer : public HttpStreamTransport {
public:
    HttpStreamServer(u16 port = 8080, u32 heartbeatIntervalMs = 30000) FL_NO_EXCEPT;

    ~HttpStreamServer() FL_NO_EXCEPT override;
 
    // Connection Management (override from HttpStreamTransport)

    bool connect() FL_NO_EXCEPT override;

    void disconnect() FL_NO_EXCEPT override;

    bool isConnected() const FL_NO_EXCEPT override;
 
    // Server-specific methods

    u16 port() const FL_NO_EXCEPT;

    void acceptClients() FL_NO_EXCEPT;

    size_t getClientCount() const FL_NO_EXCEPT;

    void disconnectClient(u32 clientId) FL_NO_EXCEPT;

    fl::vector<u32> getClientIds() const FL_NO_EXCEPT;
 
protected:
    // Abstract methods implementation (from HttpStreamTransport)

    int sendData(fl::span<const u8> data) FL_NO_EXCEPT override;

    int recvData(fl::span<u8> buffer) FL_NO_EXCEPT override;

    void triggerReconnect() FL_NO_EXCEPT override;
 
private:
    struct ClientState {
        u32 clientId;
        bool httpHeaderReceived;
        bool httpHeaderSent;
        HttpRequestParser requestParser;
        fl::vector<u8> pendingData;  // Data waiting to be processed
        fl::string headerBuffer;     // Accumulates partial HTTP header reads
 
        // Default constructor (required for map operations)
        ClientState() FL_NO_EXCEPT
            : clientId(0)
            , httpHeaderReceived(false)
            , httpHeaderSent(false)
            , requestParser()
            , pendingData()
        {
        }
 
        ClientState(u32 id)
            FL_NO_EXCEPT : clientId(id)
            , httpHeaderReceived(false)
            , httpHeaderSent(false)
            , requestParser()
            , pendingData()
        {
        }
    };

    bool readHttpRequestHeader(u32 clientId) FL_NO_EXCEPT;

    bool sendHttpResponseHeader(u32 clientId) FL_NO_EXCEPT;

    bool processClientData(u32 clientId) FL_NO_EXCEPT;

    ClientState* getOrCreateClientState(u32 clientId) FL_NO_EXCEPT;

    void removeClientState(u32 clientId) FL_NO_EXCEPT;

    fl::unique_ptr<NativeHttpServer> mNativeServer;

    u16 mPort;

    fl::flat_map<u32, ClientState> mClientStates;

    fl::vector<u8> mRecvBuffer;

    u32 mLastProcessedClientId;
};
 
}  // namespace http
}  // namespace net
}  // namespace fl
 
#endif // FASTLED_HAS_NETWORKING