1 files changed, 98 insertions, 0 deletions
diff --git a/mwe/events/src/eventManager.cpp b/mwe/events/src/eventManager.cpp
index 2aef89d..e022849 100644
--- a/mwe/events/src/eventManager.cpp
+++ b/mwe/events/src/eventManager.cpp
@@ -1,5 +1,102 @@
 #include "eventManager.h"
 
+<<<<<<< HEAD
+void EventManager::shutdown()
+{
+    subscribers.clear();
+}
+
+void EventManager::subscribe(int eventType, std::unique_ptr<IEventHandlerWrapper>&& handler, int eventId)
+{
+    if (eventId) {
+        std::unordered_map<int, std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>>::iterator subscribers = subscribersByEventId.find(eventType);
+
+        if (subscribers != subscribersByEventId.end()) {
+            std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>& handlersMap = subscribers->second;
+            std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>::iterator handlers = handlersMap.find(eventId);
+            if (handlers != handlersMap.end()) {
+                handlers->second.emplace_back(std::move(handler));
+                return;
+            }
+        }
+        subscribersByEventId[eventType][eventId].emplace_back(std::move(handler));
+
+    } else {
+        auto& handlers = subscribers[eventType];
+    	handlers.emplace_back(std::move(handler));
+    }
+}
+
+void EventManager::unsubscribe(int eventType, const std::string& handlerName, int eventId)
+{
+    if (eventId) {
+        std::unordered_map<int, std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>>::iterator subscriberList = subscribersByEventId.find(eventType);
+        if (subscriberList != subscribersByEventId.end()) {
+            std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>& handlersMap = subscriberList->second;
+            std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>::iterator handlers = handlersMap.find(eventId);
+            if (handlers != handlersMap.end()) {
+                std::vector<std::unique_ptr<IEventHandlerWrapper>>& callbacks = handlers->second;
+                for (std::vector<std::unique_ptr<IEventHandlerWrapper>>::iterator it = callbacks.begin(); it != callbacks.end(); ++it) {
+                    if (it->get()->getType() == handlerName) {
+                        it = callbacks.erase(it);
+                        return;
+                    }
+                }
+            }
+        }
+    } else {
+        std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>::iterator handlersIt = subscribers.find(eventType);
+        if (handlersIt != subscribers.end()) {
+            std::vector<std::unique_ptr<IEventHandlerWrapper>>& handlers = handlersIt->second;
+            for (std::vector<std::unique_ptr<IEventHandlerWrapper>>::iterator it = handlers.begin(); it != handlers.end(); ++it) {
+                if (it->get()->getType() == handlerName) {
+                    it = handlers.erase(it);
+                    return;
+                }
+            }
+        }
+    }
+}
+
+void EventManager::triggerEvent(const Event& event_, int eventId)
+{
+    if (eventId > 0) {
+        auto handlersIt = subscribersByEventId[event_.getEventType()].find(eventId);
+        if (handlersIt != subscribersByEventId[event_.getEventType()].end()) {
+            std::vector<std::unique_ptr<IEventHandlerWrapper>>& callbacks = handlersIt->second;
+            for (auto it = callbacks.begin(); it != callbacks.end();) {
+                (*it)->exec(event_);
+                if ((*it)->isDestroyOnSuccess()) {
+                    it = callbacks.erase(it);
+                } else {
+                    ++it;
+                }
+            }
+        }
+    } else {
+        auto& handlers = subscribers[event_.getEventType()];
+        for (std::unique_ptr<IEventHandlerWrapper>& handler : handlers) {
+            handler->exec(event_);
+        }
+    }
+}
+
+void EventManager::queueEvent(std::unique_ptr<Event>&& event_, int eventId)
+{
+    eventsQueue.emplace_back(std::move(event_), eventId);
+}
+
+void EventManager::dispatchEvents()
+{
+    for (std::vector<std::pair<std::unique_ptr<Event>, int>>::iterator eventIt = eventsQueue.begin(); eventIt != eventsQueue.end();) {
+        if (!eventIt->first.get()->getHandled()) {
+            triggerEvent(*eventIt->first.get(), eventIt->second);
+            eventIt = eventsQueue.erase(eventIt);
+        } else {
+            ++eventIt;
+        }
+    }
+=======
 void EventManager::shutdown() { m_subscribers.clear(); }
 
 void EventManager::subscribe(int eventType,
@@ -149,4 +246,5 @@ void EventManager::dispatchEvents() {
 			++eventIt;
 		}
 	}
+>>>>>>> b3b762a34e7ccb4a0dcd041a693ac7180af16002
 }