Function FL_TEST_FILE

tests/fl/channels/manager.cpp:26–170

#include "test.h"

FL_TEST_FILE(FL_FILEPATH) {

namespace draining_state_test {

using namespace fl;
using DriverState = IChannelDriver::DriverState;

/// Mock driver that lets tests control what poll() returns.
class StatefulMockDriver : public IChannelDriver {
public:
    explicit StatefulMockDriver(const char* name) : mName(name) {}

    // Controllable state
    DriverState::Value mState = DriverState::READY;
    int showCount = 0;
    int enqueueCount = 0;
    int pollCount = 0;

    bool canHandle(const ChannelDataPtr&) const override { return true; }
    void enqueue(ChannelDataPtr) override { enqueueCount++; }
    void show() override { showCount++; }
    DriverState poll() override { pollCount++; return DriverState(mState); }
    fl::string getName() const override { return mName; }

    Capabilities getCapabilities() const override {
        return Capabilities(true, false);
    }

private:
    fl::string mName;
};

FL_TEST_CASE("ChannelManager::poll propagates each state correctly") {
    auto driver = fl::make_shared<StatefulMockDriver>("DRAIN_POLL");
    ChannelManager& mgr = ChannelManager::instance();
    mgr.addDriver(5000, driver);

    // Step through the full lifecycle: READY → BUSY → DRAINING → READY
    // Each mgr.poll() call is a single poll - no looping, no timeouts.

    driver->mState = DriverState::READY;
    FL_CHECK_EQ(static_cast<int>(mgr.poll().state),
                static_cast<int>(DriverState::READY));

    driver->mState = DriverState::BUSY;
    FL_CHECK_EQ(static_cast<int>(mgr.poll().state),
                static_cast<int>(DriverState::BUSY));

    driver->mState = DriverState::DRAINING;
    FL_CHECK_EQ(static_cast<int>(mgr.poll().state),
                static_cast<int>(DriverState::DRAINING));

    driver->mState = DriverState::READY;
    FL_CHECK_EQ(static_cast<int>(mgr.poll().state),
                static_cast<int>(DriverState::READY));

    // Verify poll was called exactly 4 times (once per mgr.poll())
    FL_CHECK_EQ(driver->pollCount, 4);