stream_client.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_client.h"  // IWYU pragma: keep
#include "fl/stl/string.h"
#include "fl/stl/unique_ptr.h"
#include "fl/stl/noexcept.h"
 
namespace fl {
namespace net {
namespace http {

class HttpStreamClient : public HttpStreamTransport {
public:
    HttpStreamClient(const fl::string& host, u16 port = 8080, u32 heartbeatIntervalMs = 30000);

    ~HttpStreamClient() FL_NOEXCEPT override;
 
    // Connection Management (override from HttpStreamTransport)

    bool connect() override;

    void disconnect() override;

    bool isConnected() const override;
 
protected:
    // Abstract methods implementation (from HttpStreamTransport)

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

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

    void triggerReconnect() override;
 
private:
    bool sendHttpRequestHeader();

    bool readHttpResponseHeader();

    fl::unique_ptr<NativeHttpClient> mNativeClient;

    bool mHttpHeaderSent;
    bool mHttpHeaderReceived;

    fl::string mHost;
    u16 mPort;
};
 
}  // namespace http
}  // namespace net
}  // namespace fl
 
#endif // FASTLED_HAS_NETWORKING