FrameworkController.h

Go to the documentation of this file.

 
#pragma once
 
#include "FrameworkTask.h"
#include <unordered_map>
#include <functional>
#include <string>
#include <FreeRTOS.h>
#include <task.h>
#include "events/Event.h"
#include "http/Router.h"
 
class FrameworkController : public FrameworkTask
{
public:
    FrameworkController(const char* name, Router& sharedRouter, uint16_t stackSize = 1024, UBaseType_t priority = tskIDLE_PRIORITY + 1);
 
    void run() override final;
 
    const char *getName() const { return FrameworkTask::getName(); }
 
protected:
    virtual void onStart();
 
    virtual void initRoutes();
 
    virtual void onEvent(const Event &event);
 
 
    virtual TickType_t getPollIntervalTicks() {
        return pdMS_TO_TICKS(100); // Default: 100ms
    }
 
    virtual void poll();
 
    void runEvery(uint32_t intervalMs, const std::function<void()> &fn, const char *id);
 
    Router& router;    
 
public:
 
    // --- Event queue management ---
    void enableEventQueue(size_t depth = 8) {
        if (!eventQueue_) {
            eventQueue_ = xQueueCreate(depth, sizeof(Event));
        }
    }
    QueueHandle_t getEventQueue() const {
        return eventQueue_;
    }
 
    bool getNextEvent(Event& event, uint32_t timeoutMs) {
        return eventQueue_ && xQueueReceive(eventQueue_, &event, pdMS_TO_TICKS(timeoutMs)) == pdTRUE;
    }
 
 
private:
    std::unordered_map<std::string, TickType_t> _timers; 
    
    QueueHandle_t eventQueue_ = nullptr; // FreeRTOS queue for pending events
 
    void waitAndDispatch(uint32_t timeoutMs = portMAX_DELAY);
};
 
// --- Timing convenience macro ---
 
#define STRINGIFY_DETAIL(x) #x
#define STRINGIFY(x) STRINGIFY_DETAIL(x)
#define RUN_EVERY(ms, fn) runEvery(ms, fn, __FUNCTION__ ":" STRINGIFY(__LINE__))