ls-standard-library/source/ls-std/event/EventManager.cpp

/*
* Author:          Patrick-Christopher Mattulat
* Company:         Lynar Studios
* E-Mail:          webmaster@lynarstudios.com
* Created:         2024-05-16
* Changed:         2024-05-17
*
* */

#include <ls-std/core/exception/EventNotHandledException.hpp>
#include <ls-std/event/EventListener.hpp>
#include <ls-std/event/EventManager.hpp>
#include <utility>

using ls::std::core::Class;
using ls::std::core::EventNotHandledException;
using ls::std::event::Event;
using ls::std::event::EventListener;
using ls::std::event::EventManager;
using ls::std::event::type::event_action;
using ls::std::event::type::event_listeners;
using ls::std::event::type::listener_id;
using ::std::make_pair;
using ::std::move;
using ::std::shared_ptr;

EventManager::EventManager() : Class("EventManager")
{}

EventManager::~EventManager() noexcept = default;

listener_id EventManager::getNextProvisionId() const
{
  return this->provisionId;
}

bool EventManager::holdsListenerForEvent(listener_id _id, const Event &_event)
{
  bool holdsListener{};

  if (this->_observesEvent(_event))
  {
    for (const auto &[listener, eventAction] : this->inventory[_event.getClassName()])
    {
      holdsListener = listener->getId() == _id;

      if (holdsListener)
      {
        break;
      }
    }
  }

  return holdsListener;
}

void EventManager::invoke(const Event &_event) const
{
  if (!this->_observesEvent(_event))
  {
    throw EventNotHandledException("event " + _event.getClassName() + " is not known by event manager");
  }
  else
  {
    for (const auto &[eventName, listeners] : this->inventory)
    {
      EventManager::_notifyListeners(listeners);
    }
  }
}

listener_id EventManager::requestListenerId()
{
  listener_id providedId = this->provisionId;
  ++this->provisionId;

  return providedId;
}

void EventManager::subscribeListenerForEvent(shared_ptr<EventListener> _listener, const Event &_event, event_action _action)
{
  if (!this->_observesEvent(_event))
  {
    this->inventory[_event.getClassName()] = {};
  }

  auto inventoryEntry = make_pair<shared_ptr<EventListener>, event_action>(::move(_listener), ::move(_action));
  this->inventory[_event.getClassName()].push_back(inventoryEntry);
}

void EventManager::unsubscribeListenerForEvent(const shared_ptr<EventListener> &_listener, const Event &_event)
{
  if (this->_observesEvent(_event))
  {
    for (auto iterator = this->inventory[_event.getClassName()].begin(); iterator != this->inventory[_event.getClassName()].end(); iterator++)
    {
      if (iterator->first->getId() == _listener->getId())
      {
        this->inventory[_event.getClassName()].erase(iterator);
        break;
      }
    }
  }
}

void EventManager::_notifyListeners(const event_listeners &_listeners)
{
  for (const auto &[listener, eventAction] : _listeners)
  {
    eventAction();
  }
}

bool EventManager::_observesEvent(const Event &_event) const
{
  return this->inventory.find(_event.getClassName()) != this->inventory.end();
}