TimerService.h

Go to the documentation of this file.

 
#pragma once
 
#include <cstdint>
#include <ctime>
#include <string>
#include <unordered_map>
#include <functional>
#include <FreeRTOS.h>
#include <semphr.h>
#include <timers.h>
 
#include "events/Event.h"
#include "time/TimeOfDay.h"
#include "time/DaysOfWeek.h"
 
 
struct TimerJob
{
    TimeOfDay startTime;     
    DaysOfWeek repeatDays;   
    uint32_t durationMs = 0; 
    Event startEvent;        
    Event stopEvent;         
    bool recurring = true;   
};
 
class TimerService
{
public:
 
 
    TimerService();
    ~TimerService() = default;
 
    void withLock(const std::function<void()>& fn);
 
 
    static TimerService &instance();
 
    void scheduleAt(time_t unixTime, const Event &event);
    void scheduleAt(time_t unixTime, const Event &event, const std::string &jobId);
 
    void scheduleEvery(uint32_t intervalMs, const Event &event);
    void scheduleEvery(uint32_t intervalMs, const Event &event, const std::string &jobId);
 
    void scheduleDailyAt(TimeOfDay time, DaysOfWeek days, const Event &event);
    void scheduleDailyAt(TimeOfDay time, DaysOfWeek days, const Event &event, const std::string &jobId);
 
    void scheduleDuration(TimeOfDay start, DaysOfWeek days, uint32_t durationMs,
                          const Event &startEvent, const Event &stopEvent);
    void scheduleDuration(TimeOfDay start, DaysOfWeek days, uint32_t durationMs,
                          const Event &startEvent, const Event &stopEvent, const std::string &baseJobId);
 
    void checkMissedEvents(time_t now);
 
    bool cancel(const std::string &jobId);
 
    void scheduleCallbackAt(time_t unixTime, std::function<void()> callback);
 
 
private:
 
    SemaphoreHandle_t lock_;
    static StaticSemaphore_t lockBuffer_;
 
    std::unordered_map<std::string, TimerHandle_t> scheduledJobs; 
    // Note: TimerHandles are created and managed by FreeRTOS.
    // They will automatically clean up after firing if pdFALSE is passed to xTimerDelete.
    // If pdTRUE is passed, the timer will be deleted immediately after firing.
    // This is useful for one-shot timers.
 
    void rescheduleDailyJob(const TimerJob &job);
};