Core/Utilities: Added timer series queuing to EventMap (TrinityCore#29420)

(cherry picked from commit c5735ed)

# Conflicts:
#	src/common/Utilities/EventMap.cpp
#	src/common/Utilities/EventMap.h

Author: mdX7

src/common/Utilities/EventMap.cpp

@@ -85,6 +85,7 @@ EventMap::EventId EventMap::ExecuteEvent()
             auto eventId = itr->second._id;
             _lastEvent = itr->second;
             _eventMap.erase(itr);
+            ScheduleNextFromSeries(_lastEvent);
             return eventId;
         }
     }
@@ -160,6 +161,14 @@ void EventMap::CancelEvent(EventId eventId)
         else
             ++itr;
     }
+
+    for (EventSeriesStore::iterator itr = _timerSeries.begin(); itr != _timerSeries.end();)
+    {
+        if (eventId == (itr->first & 0x0000FFFF))
+            _timerSeries.erase(itr++);
+        else
+            ++itr;
+    }
 }
 
 void EventMap::CancelEventGroup(GroupIndex group)
@@ -174,6 +183,14 @@ void EventMap::CancelEventGroup(GroupIndex group)
         else
             ++itr;
     }
+
+    for (EventSeriesStore::iterator itr = _timerSeries.begin(); itr != _timerSeries.end();)
+    {
+        if (itr->first & (1 << (group + 15)))
+            _timerSeries.erase(itr++);
+        else
+            ++itr;
+    }
 }
 
 Milliseconds EventMap::GetTimeUntilEvent(EventId eventId) const
@@ -189,3 +206,40 @@ bool EventMap::HasEventScheduled(EventId eventId) const
 {
     return GetTimeUntilEvent(eventId) != Milliseconds::max();
 }
+
+void EventMap::ScheduleNextFromSeries(uint32 eventData)
+{
+    EventSeriesStore::iterator itr = _timerSeries.find(eventData);
+    if (itr == _timerSeries.end())
+        return;
+
+    if (itr->first != eventData)
+        return;
+
+    if (itr->second.size() == 0)
+        return;
+
+    Milliseconds time = itr->second.front();
+    itr->second.pop();
+
+    ScheduleEvent(eventData, time);
+}
+
+void EventMap::ScheduleEventSeries(uint32 eventId, uint8 group, uint8 phase, std::initializer_list<Milliseconds> const& timeSeries)
+{
+    if (group && group <= 8)
+        eventId |= (1 << (group + 15));
+
+    if (phase && phase <= 8)
+        eventId |= (1 << (phase + 23));
+
+    for (Milliseconds const& time : timeSeries)
+        _timerSeries[eventId].push(time);
+
+    ScheduleNextFromSeries(eventId);
+}
+
+void EventMap::ScheduleEventSeries(uint32 eventId, std::initializer_list<Milliseconds> const& timeSeries)
+{
+    ScheduleEventSeries(eventId, 0, 0, timeSeries);
+}

src/common/Utilities/EventMap.h

@@ -21,6 +21,7 @@
 #include "Define.h"
 #include "Duration.h"
 #include <map>
+#include <queue>
 
 class TC_COMMON_API EventMap
 {
@@ -49,6 +50,7 @@ class TC_COMMON_API EventMap
      * Key: Time as TimePoint when the event should occur.
      */
     using EventStore = std::multimap<TimePoint, Event>;
+    typedef std::map<uint32 /*event data*/, std::queue<Milliseconds>> EventSeriesStore;
 
 public:
     EventMap() : _time(TimePoint::min()), _phaseMask(0) { }
@@ -255,6 +257,31 @@ class TC_COMMON_API EventMap
      */
     bool HasEventScheduled(EventId eventId) const;
 
+    /**
+    * @name ScheduleNextFromSeries
+    * @brief Schedules specified event with next timer from series
+    * @param full event data, including group and phase
+    */
+    void ScheduleNextFromSeries(uint32 eventData);
+
+    /**
+    * @name ScheduleEventSeries
+    * @brief Schedules specified event with first value of the series and then requeues with the next
+    * @param eventId of the event.
+    * @param group of the event.
+    * @param phase of the event.
+    * @param timeSeries specifying the times the event should be automatically scheduled after each trigger (first value is initial schedule)
+    */
+    void ScheduleEventSeries(uint32 eventId, uint8 group, uint8 phase, std::initializer_list<Milliseconds> const& timeSeries);
+
+    /**
+    * @name ScheduleEventSeries
+    * @brief Schedules specified event with first value of the series and then requeues with the next
+    * @param eventId of the event.
+    * @param timeSeries specifying the times the event should be automatically scheduled after each trigger (first value is initial schedule)
+    */
+    void ScheduleEventSeries(uint32 eventId, std::initializer_list<Milliseconds> const& series);
+
 private:
     /**
     * @name _time
@@ -292,6 +319,12 @@ class TC_COMMON_API EventMap
     * @brief Stores information on the most recently executed event
     */
     Event _lastEvent;
+
+    /**
+    * @name _timerSeries
+    * @brief Stores information about time series which requeue itself until series is empty
+    */
+    EventSeriesStore _timerSeries;
 };
 
 #endif // TRINITYCORE_EVENT_MAP_H