FrameworkController.cpp

Go to the documentation of this file.

 
#include "framework/FrameworkController.h"
#include "framework/AppContext.h"
#include "framework/FrameworkTask.h"
#include "events/EventManager.h"
#include "events/Event.h"
#include "http/Router.h"
 
FrameworkController::FrameworkController(const char *name, Router &sharedRouter, uint16_t stackSize, UBaseType_t priority)
    : FrameworkTask(name, stackSize, priority),
      router(sharedRouter) {}
 
void FrameworkController::run()
{
    enableEventQueue();  // MUST be here to initialize queue before use
    initRoutes();        // Call initRoutes() to set up routes
    onStart();           // Call onStart() to initialize controller state
    while (true)
    {
        waitAndDispatch(getPollIntervalTicks()); // Wait for notifications or timeout
        poll();               // Call user logic
    }
}
 
void FrameworkController::onStart()
{
    // can safely be overridden in derived classes
    // Default implementation does nothing
}
 
void FrameworkController::initRoutes()
{
    // Default implementation does nothing
    // Override in derived classes to set up routes
}
 
void FrameworkController::onEvent(const Event &event)
{
    // Default: do nothing
}
 
void FrameworkController::poll()
{
    // Default no-op
}
 
void FrameworkController::waitAndDispatch(uint32_t timeoutMs)
{
    Event event;
    if (getNextEvent(event, timeoutMs))
    {
        onEvent(event);
    }
}
 
void FrameworkController::runEvery(uint32_t intervalMs, const std::function<void()> &fn, const char *id)
{
    TickType_t now = xTaskGetTickCount();
    TickType_t &last = _timers[std::string(id)];
 
    if ((now - last) >= pdMS_TO_TICKS(intervalMs))
    {
        fn();
        last = now;
    }
}