Introduce system/phase timers

Close: #181

src/ecstasy/registry/Registry.cpp

@@ -83,7 +83,10 @@ namespace ecstasy
 
     void Registry::runSystem(const std::type_index &systemId)
     {
-        _systems.get(systemId).run(*this);
+        ISystem &system = _systems.get(systemId);
+
+        if (system.getTimer().trigger())
+            system.run(*this);
     }
 
     void Registry::runSystems()

src/ecstasy/system/CMakeLists.txt

@@ -6,5 +6,7 @@ set(SRC
     ${INCROOT}/Pipeline.hpp
     ${SRCROOT}/Pipeline.cpp
     ${INCROOT}/ISystem.hpp
+    ${INCROOT}/Timer.hpp
+    ${SRCROOT}/Timer.cpp
     PARENT_SCOPE
 )

src/ecstasy/system/ISystem.hpp

@@ -12,6 +12,8 @@
 #ifndef ECSTASY_SYSTEM_ISYSTEM_HPP_
 #define ECSTASY_SYSTEM_ISYSTEM_HPP_
 
+#include "ecstasy/system/Timer.hpp"
+
 namespace ecstasy
 {
     /// @brief Forward declaration of Registry class.
@@ -37,6 +39,42 @@ namespace ecstasy
         /// @since 1.0.0 (2022-10-17)
         ///
         virtual void run(Registry &registry) = 0;
+
+        ///
+        /// @brief Get the system timer.
+        ///
+        /// @note The timer is used to control the execution of the system. You can also use
+        /// @ref ecstasy::Pipeline::Phase "Phase" scale timers.
+        ///
+        /// @return Timer& Reference to the system timer.
+        ///
+        /// @author Andréas Leroux ([email protected])
+        /// @since 1.0.0 (2024-11-22)
+        ///
+        [[nodiscard]] constexpr Timer &getTimer() noexcept
+        {
+            return _timer;
+        }
+
+        ///
+        /// @brief Get the system timer.
+        ///
+        /// @note The timer is used to control the execution of the system. You can also use
+        /// @ref ecstasy::Pipeline::Phase "Phase" scale timers.
+        ///
+        /// @return const Timer& Reference to the system timer.
+        ///
+        /// @author Andréas Leroux ([email protected])
+        /// @since 1.0.0 (2024-11-22)
+        ///
+        [[nodiscard]] constexpr const Timer &getTimer() const noexcept
+        {
+            return _timer;
+        }
+
+      private:
+        /// @brief Timer to control the execution of the system.
+        Timer _timer;
     };
 } // namespace ecstasy
 

src/ecstasy/system/Pipeline.cpp

@@ -25,8 +25,10 @@ namespace ecstasy
         return _pipeline._systemsIds.begin() + static_cast<long>(end_idx());
     }
 
-    void Pipeline::Phase::run() const
+    void Pipeline::Phase::run()
     {
+        if (!_timer.trigger())
+            return;
         for (auto it = begin(); it < end(); ++it) {
             _pipeline._registry.runSystem(*it);
         }
@@ -54,14 +56,14 @@ namespace ecstasy
         }
     }
 
-    void Pipeline::run() const
+    void Pipeline::run()
     {
         for (auto &phase : _phases) {
             phase.second.run();
         }
     }
 
-    void Pipeline::run(Pipeline::PhaseId phase) const
+    void Pipeline::run(Pipeline::PhaseId phase)
     {
         auto phaseIt = _phases.find(phase);
 

src/ecstasy/system/Pipeline.hpp

@@ -16,6 +16,7 @@
 #include <typeindex>
 #include <vector>
 #include "ecstasy/system/ISystem.hpp"
+#include "ecstasy/system/Timer.hpp"
 
 namespace ecstasy
 {
@@ -72,7 +73,7 @@ namespace ecstasy
             /// @author Andréas Leroux ([email protected])
             /// @since 1.0.0 (2024-11-21)
             ///
-            constexpr Phase(Pipeline &pipeline, PhaseId id) : _pipeline(pipeline), _begin(), _size(0), _id(id)
+            Phase(Pipeline &pipeline, PhaseId id) : _pipeline(pipeline), _begin(), _size(0), _id(id)
             {
             }
 
@@ -83,7 +84,7 @@ namespace ecstasy
             /// @author Andréas Leroux ([email protected])
             /// @since 1.0.0 (2024-11-21)
             ///
-            void run() const;
+            void run();
 
             ///
             /// @brief Get the number of systems in this phase.
@@ -132,6 +133,44 @@ namespace ecstasy
             ///
             [[nodiscard]] SystemIterator end() const noexcept;
 
+            ///
+            /// @brief Get the phase timer.
+            ///
+            /// @note The timer is used to control the execution of the phase. You can also use
+            /// @ref ecstasy::ISystem "ISystem" scale timers.
+            ///
+            /// @warning Rate limiting both the phase and the systems will result in multiplied timers (not added).
+            /// However interval timers will be cumulative.
+            ///
+            /// @return Timer& Reference to the system timer.
+            ///
+            /// @author Andréas Leroux ([email protected])
+            /// @since 1.0.0 (2024-11-22)
+            ///
+            [[nodiscard]] constexpr Timer &getTimer() noexcept
+            {
+                return _timer;
+            }
+
+            ///
+            /// @brief Get the phase timer.
+            ///
+            /// @note The timer is used to control the execution of the phase. You can also use
+            /// @ref ecstasy::ISystem "ISystem" scale timers.
+            ///
+            /// @warning Rate limiting both the phase and the systems will result in multiplied timers (not added).
+            /// However interval timers will be cumulative.
+            ///
+            /// @return const Timer& Reference to the system timer.
+            ///
+            /// @author Andréas Leroux ([email protected])
+            /// @since 1.0.0 (2024-11-22)
+            ///
+            [[nodiscard]] constexpr const Timer &getTimer() const noexcept
+            {
+                return _timer;
+            }
+
           private:
             /// @brief Owning pipeline.
             Pipeline &_pipeline;
@@ -141,6 +180,8 @@ namespace ecstasy
             std::size_t _size;
             /// @brief Identifier of the phase.
             PhaseId _id;
+            /// @brief Timer to control the execution of the phase.
+            Timer _timer;
 
             ///
             /// @brief Get the index of the first system in this phase.
@@ -266,7 +307,7 @@ namespace ecstasy
         /// @author Andréas Leroux ([email protected])
         /// @since 1.0.0 (2024-11-21)
         ///
-        void run() const;
+        void run();
 
         ///
         /// @brief Run a specific phase of the pipeline.
@@ -276,7 +317,7 @@ namespace ecstasy
         /// @author Andréas Leroux ([email protected])
         /// @since 1.0.0 (2024-11-21)
         ///
-        void run(PhaseId phase) const;
+        void run(PhaseId phase);
 
       private:
         /// @brief Ordered list of systems.

src/ecstasy/system/Timer.cpp

@@ -0,0 +1,88 @@
+///
+/// @file Timer.cpp
+/// @author Andréas Leroux ([email protected])
+/// @brief
+/// @version 1.0.0
+/// @date 2024-11-21
+///
+/// @copyright Copyright (c) ECSTASY 2022 - 2024
+///
+///
+
+#include "Timer.hpp"
+#include <stdexcept>
+
+namespace ecstasy
+{
+    Timer::Timer()
+    {
+        _lastTrigger = TimePoint::min();
+        setRate(0);
+    }
+
+    Timer::Timer(Timer::Interval interval) : Timer()
+    {
+        setInterval(interval);
+    }
+
+    Timer::Timer(std::uint32_t rate) : Timer()
+    {
+        setRate(rate);
+    }
+
+    void Timer::setRate(std::uint32_t rate) noexcept
+    {
+        _type = Type::Rate;
+        if (rate == 0) {
+            rate = 1;
+        }
+        _rate.rate = rate;
+        // Reset the countdown to trigger to run the first time
+        _rate.triggerCountdown = 0;
+    }
+
+    std::uint32_t Timer::getRate() const
+    {
+        if (_type != Type::Rate)
+            throw std::runtime_error("Timer is not of type Rate");
+        return _rate.rate;
+    }
+
+    void Timer::setInterval(Timer::Interval interval) noexcept
+    {
+        _type = Type::TimeInterval;
+        _timer.interval = interval;
+    }
+
+    Timer::Interval Timer::getInterval() const
+    {
+        if (_type != Type::TimeInterval)
+            throw std::runtime_error("Timer is not of type Rate");
+        return _timer.interval;
+    }
+
+    bool Timer::trigger() noexcept
+    {
+        switch (_type) {
+            case Type::TimeInterval: {
+                auto tp = std::chrono::system_clock::now();
+
+                if (tp - _timer.interval >= _lastTrigger) {
+                    _lastTrigger = tp;
+                    return true;
+                }
+                return false;
+            }
+            case Type::Rate: {
+                if (_rate.triggerCountdown == 0) {
+                    _rate.triggerCountdown = _rate.rate - 1;
+                    _lastTrigger = std::chrono::system_clock::now();
+                    return true;
+                }
+                --_rate.triggerCountdown;
+                return false;
+            }
+        }
+        return false;
+    }
+} // namespace ecstasy