Function FL_TEST_FILE

tests/fl/net/http/stream_transport.cpp:7–362

#include <cstring>  // ok include

FL_TEST_FILE(FL_FILEPATH) {

using namespace fl;
using namespace fl::net::http;

// Mock implementation for testing
class MockStreamTransport : public HttpStreamTransport {
public:
    MockStreamTransport(const char* host, uint16_t port)
        : HttpStreamTransport(host, port, 1000)  // 1s heartbeat for testing
        , mConnected(false)
        , mCurrentTime(0) {
    }

    bool connect() override {
        mConnected = true;
        mConnection.onConnected(getCurrentTimeMs());
        return true;
    }

    void disconnect() override {
        mConnected = false;
        mConnection.onDisconnected();
    }

    bool isConnected() const override {
        return mConnected;
    }

    // Expose sendData for testing
    int sendData(fl::span<const uint8_t> data) override {
        mSentData.insert(mSentData.end(), data.begin(), data.end());
        return static_cast<int>(data.size());
    }

    // Expose recvData for testing
    int recvData(fl::span<uint8_t> buffer) override {
        if (mRecvData.empty()) {
            return 0;  // No data available
        }

        size_t toCopy = (mRecvData.size() < buffer.size()) ? mRecvData.size() : buffer.size();
        fl::memcpy(buffer.data(), mRecvData.data(), toCopy);
        mRecvData.erase_range(mRecvData.begin(), toCopy);
        return static_cast<int>(toCopy);
    }

    uint32_t getCurrentTimeMs() const override {
        return mCurrentTime;
    }

    void setCurrentTime(uint32_t time) {
        mCurrentTime = time;
    }

    void advanceTime(uint32_t delta) {
        mCurrentTime += delta;
    }