dispatch fixed and priority added

1 files changed, 26 insertions, 47 deletions

diff --git a/src/crepe/api/EventManager.cpp b/src/crepe/api/EventManager.cpp
index 27a304f..4f88e97 100644
--- a/src/crepe/api/EventManager.cpp
+++ b/src/crepe/api/EventManager.cpp
@@ -8,58 +8,37 @@ EventManager & EventManager::get_instance() {
 }
 
 void EventManager::dispatch_events() {
-	using HandlersMap
-		= std::unordered_map<int, std::vector<std::unique_ptr<IEventHandlerWrapper>>>;
-	using HandlersVec = std::vector<std::unique_ptr<IEventHandlerWrapper>>;
+    for (auto event_it = this->events_queue.begin(); event_it != this->events_queue.end();) {
+        std::unique_ptr<Event>& event = (*event_it).event;
+        int channel = (*event_it).channel;
+        std::type_index event_type = (*event_it).type;
 
-	for (auto event_it = this->events_queue.begin(); event_it != this->events_queue.end();) {
-		std::unique_ptr<Event> & event = (*event_it).event;
-		int channel = (*event_it).channel;
-		std::type_index event_type = (*event_it).type;
+        bool event_handled = false;
+        auto handlers_it = this->subscribers.find(event_type);
+        if (handlers_it != this->subscribers.end()) {
+            std::vector<CallbackEntry>& handlers = handlers_it->second;
+            
+            std::sort(handlers.begin(), handlers.end(), [](const CallbackEntry& a, const CallbackEntry& b) {
+                return a.priority > b.priority;
+            });
 
-		bool event_handled = false;
+            for (auto handler_it = handlers.begin(); handler_it != handlers.end(); ++handler_it) {
+                // If callback is executed and returns true, remove the event from the queue
+                if ((*handler_it).callback->exec(*event)) {
+                    event_it = this->events_queue.erase(event_it);
+                    event_handled = true;
+                    break;
+                }
+            }
+        }
 
-		if (channel) {
-			auto handlers_it = subscribers_by_event_id.find(event_type);
-			if (handlers_it != subscribers_by_event_id.end()) {
-				HandlersMap & handlers_map = handlers_it->second;
-				auto handlers = handlers_map.find(channel);
-				if (handlers != handlers_map.end()) {
-					HandlersVec & callbacks = handlers->second;
-					for (auto handler_it = callbacks.begin(); handler_it != callbacks.end();
-						 ++handler_it) {
-						if ((*handler_it)->exec(*event)) {
-							event_it = events_queue.erase(event_it);
-							event_handled = true;
-							break;
-						}
-					}
-				}
-			}
-		} else {
-			// Handle event for all channels
-			auto handlers_it = this->subscribers.find(event_type);
-			if (handlers_it != this->subscribers.end()) {
-				HandlersVec & handlers = handlers_it->second;
-				for (auto handler_it = handlers.begin(); handler_it != handlers.end();
-					 ++handler_it) {
-					// remove event from queue since and continue when callback returns true
-					if ((*handler_it)->exec(*event)) {
-						event_it = this->events_queue.erase(event_it);
-						event_handled = true;
-						break;
-					}
-				}
-			}
-		}
-
-		if (!event_handled) {
-			++event_it;
-		}
-	}
+        if (!event_handled) {
+            ++event_it;
+        }
+    }
 }
+
 void EventManager::clear(){
 	this->subscribers.clear();
 	this->events_queue.clear();
-	this->subscribers_by_event_id.clear();
 }