Class HttpConnection

src/fl/stl/asio/http/connection.h:35–92

HttpConnection: Manages connection lifecycle and state transitions

// HttpConnection: Manages connection lifecycle and state transitions
class HttpConnection {
public:
    explicit HttpConnection(const ConnectionConfig& config = ConnectionConfig());

    // State management
    ConnectionState getState() const;
    bool isConnected() const;
    bool isDisconnected() const;
    bool shouldReconnect() const;

    // Connection control
    void connect();          // Initiate connection
    void disconnect();       // Graceful disconnect
    void close();           // Permanent close (no reconnect)

    // Connection events (call these from transport layer)
    void onConnected(u32 currentTimeMs = 0);  // Connection established
    void onDisconnected();  // Connection lost
    void onError();         // Connection error

    // Asio-compatible: handle connection event from error_code
    void onEvent(const asio::error_code& ec, u32 currentTimeMs = 0);

    // Heartbeat management
    void onHeartbeatSent();      // Called when heartbeat sent
    void onHeartbeatReceived();  // Called when heartbeat/data received
    bool shouldSendHeartbeat(u32 currentTimeMs) const;

    // Update loop (call regularly)
    void update(u32 currentTimeMs);

    // Reconnection state
    u32 getReconnectDelayMs() const;
    u32 getReconnectAttempts() const;

    // Timeout detection
    bool isTimedOut(u32 currentTimeMs) const;

private:
    ConnectionConfig mConfig;
    ConnectionState mState;

    // Reconnection state
    u32 mReconnectAttempts;
    u32 mReconnectDelayMs;
    u32 mNextReconnectTimeMs;
    bool mWasReconnecting;  // Track if we were in RECONNECTING before CONNECTING

    // Heartbeat state
    u32 mLastHeartbeatSentMs;
    u32 mLastDataReceivedMs;

    // State transition helpers
    void transitionTo(ConnectionState newState, u32 currentTimeMs);
    void resetReconnectState();
    void resetReconnectAttempts();
    u32 calculateBackoffDelay() const;
};