NotificationDispatcher.h

// SPDX-License-Identifier: MIT
#pragma once
 
#include "AdsNotification.h"
#include "AmsHeader.h"
#include "Semaphore.h"
 
#include <atomic>
#include <functional>
#include <map>
#include <thread>
 
using DeleteNotificationCallback = std::function<long (uint32_t hNotify, uint32_t tmms)>;
 
struct NotificationDispatcher {
    NotificationDispatcher(DeleteNotificationCallback callback);
    ~NotificationDispatcher();
    void Emplace(uint32_t hNotify, std::shared_ptr<Notification> notification);
    long Erase(uint32_t hNotify, uint32_t tmms);
    void Notify();
    void Run();
 
    const DeleteNotificationCallback deleteNotification;
    RingBuffer ring;
private:
    std::map<uint32_t, std::shared_ptr<Notification> > notifications;
    std::recursive_mutex mutex;
    Semaphore sem;
    std::atomic<bool> stopExecution;
    std::thread thread;
 
    std::shared_ptr<Notification> Find(uint32_t hNotify);
};
using SharedDispatcher = std::shared_ptr<NotificationDispatcher>;