EventBus.hpp

Go to the documentation of this file.

/*
 * Copyright (C) 2025  Tetex7
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */
 
//
// Created by tete on 05/30/2025.
//
#pragma once
#ifndef L61_EVENT_SYSTEM_EVENTBUS_HPP
#define L61_EVENT_SYSTEM_EVENTBUS_HPP
#include <cstdint>
#include <map>
#include <variant>
#include <string>
#include <queue>
#include <memory>
#include <set>
#include <format>
 
#include "l61/EventSystem/Event.hpp"
#include "l61/EventSystem/types.hpp"
#include "l61/meta.hpp"
#include "l61/ScriptEngine/IBasicScriptEngine.hpp"
#include "l61/baseTypes.hpp"
#include "l61/EventSystem/IEventBusContainer.hpp"
 
 
 
 
namespace l61::EventSystem
{
    class EventBus final : public IEventBusContainer
    {
    private:
        std::unordered_map<bus_frequency_t, std::unordered_map<bus_frequency_t, std::unique_ptr<Event>>> _map;
        std::queue<bus_frequency_t> _freq_stack;
    public:
 
        bool addEvent(const bus_frequency_t& freq, const bus_frequency_t& sub_freq, const Event& event) override;
        void removeEvent(const bus_frequency_t& freq, const bus_frequency_t& sub_freq) override;
 
        void removeFrequency(const bus_frequency_t& freq) override;
 
        void pumpIt();
 
        void push(const bus_frequency_t& freq);
        void pushBand(const std::set<bus_frequency_t>& freqBand);
 
        template<meta::eventBusFrequencyCompatible... Ty>
        void pushBand(Ty&&... vals)
        {
            this->pushBand({std::forward<Ty>(vals)...});
        }
 
        void addEventBand(const std::set<std::tuple<const bus_frequency_t&, const bus_frequency_t&, const Event&>>& eventBand);
 
        explicit EventBus() = default;
        ~EventBus() override = default;
 
        void operator[](const bus_frequency_t &frequency);
 
        EventBus(EventBus&&) = delete;
        EventBus(EventBus&) = delete;
        EventBus(const EventBus&) = delete;
        EventBus& operator=(const EventBus&) = delete;
    };
 
 
    void runEventBus(EventBus& bus, SignalQueue_t& signals);
}
 
 
 
#endif //L61_EVENT_SYSTEM_EVENTBUS_HPP