ksEvent.h

/*
 *  Copyright (c) 2020-2026, Krzysztof Strehlau
 *
 *  This file is a part of the ksIotFrameworkLib IoT library.
 *  All licensing information can be found inside LICENSE.md file.
 *
 *  https://github.com/cziter15/ksIotFrameworkLib/blob/master/LICENSE
 */
 
#pragma once
 
#include <vector>
#include <memory>
#include <functional>
 
#include "ksEventInterface.h"
#include "ksEventHandle.h"
 
#define DECLARE_KS_EVENT(evtName, ...) \
    std::shared_ptr<ksf::evt::ksEvent<__VA_ARGS__>> evtName {std::make_shared<ksf::evt::ksEvent<__VA_ARGS__>>()};
 
namespace ksf::evt
{
    template <typename... Params>
    class ksEvent : public evt::ksEventInterface
    {
        protected:
            std::vector<std::pair<std::size_t, std::function<void(Params...)>>> callbacks;  
            std::size_t lastCallbackUID{0};                                                 
 
        public:
            bool isBound() const
            {
                return !callbacks.empty();
            }
 
            void registerEvent(std::unique_ptr<ksf::evt::ksEventHandle>& outHandle, std::function<void(Params...)>&& function)
            {
                ++lastCallbackUID;
                outHandle = std::make_unique<ksf::evt::ksEventHandle>(weak_from_this(), lastCallbackUID);
                callbacks.emplace_back(lastCallbackUID, std::move(function));
            }
 
            void unbind(std::size_t callbackUID) override
            {
                auto predicate = [callbackUID](const auto& cb) {
                    auto& [uid, function] = cb;
                    return uid == callbackUID; 
                };
 
                callbacks.erase(std::remove_if(callbacks.begin(), callbacks.end(), predicate), callbacks.end());
            }
 
            void broadcast(Params... params) const
            {
                for (const auto& [uid, function] : callbacks)
                    function(params...);
            }
    };
}