EventManager.h

Go to the documentation of this file.

 
#ifndef EVENT_MANAGER_H
#define EVENT_MANAGER_H
#pragma once
 
#include <vector>
#include <type_traits>
#include <FreeRTOS.h>
#include <task.h>
#include <semphr.h>
#include <queue.h>
#include "events/Event.h"
#include "framework/FrameworkController.h"
 
// Forward declaration
class FrameworkTask;
 
class EventManager
{
public:
    static EventManager &getInstance()
    {
        static EventManager instance;
        return instance;
    }
 
    explicit EventManager(size_t queueSize = 0); // Optional override
 
    void subscribe(uint32_t eventMask, FrameworkController *controller);
 
    void postEvent(const Event &e);
 
    void postNotification(const Notification &n, FrameworkTask *target);
 
    void enqueue(const Event &event);
 
    bool hasPendingEvents(FrameworkController *controller) const;
 
    template<typename Enum, typename... Rest>
    inline void subscribeTo(FrameworkController* ctrl, Enum first, Rest... rest) {
        static_assert(
            (std::is_same_v<Enum, Rest> && ...),
            "All event types must be of the same enum class (UserNotification or SystemNotification)"
        );
    
        subscribe(eventMask(first, rest...), ctrl);
    }
 
private:
    struct Subscriber
    {
        uint32_t eventMask;              
        FrameworkController *controller; 
    };
 
    SemaphoreHandle_t lock;
    static StaticSemaphore_t lockBuffer_;
 
    std::vector<Subscriber> subscribers_;
 
    void withSubscribers(const std::function<void(std::vector<Subscriber> &)> &fn);
    void withSubscribersFromISR(const std::function<void(std::vector<Subscriber> &)> &fn);
};
 
#endif // EVENT_MANAGER_H