Woo

1 files changed, 112 insertions, 0 deletions

diff --git a/engine/include/signal.h b/engine/include/signal.h
new file mode 100644
index 0000000..db6638b
--- /dev/null
+++ b/engine/include/signal.h
@@ -0,0 +1,112 @@
+#pragma once
+
+#include <map>
+#include <list>
+#include <set>
+#include <initializer_list>
+#include "object.hpp"
+#include "task.hpp"
+#include "types.h"
+#include <functional>
+
+namespace flat
+{
+    namespace core
+    {
+        class signal;
+        class channel;
+    }
+}
+
+class flat::core::signal : virtual public flat::core::object
+{
+
+public:
+
+    flat::core::object * sender;
+    priority prior;
+
+    signal( flat::core::object * sender, 
+                const std::string& id = "", 
+                priority prior = 5);
+
+    /* Alias to flat::core::channel::emit() */
+    bool emit(const std::string& channel) const;
+
+    enum class priority : uint8_t
+    {
+        instant = 0, 
+        highest, 
+        high,
+        none, 
+        low, 
+        lowest
+    };
+};
+
+
+/* Channel class */
+class flat::core::channel : virtual public flat::core::object
+{
+    /* Post processing signal stacking */
+    stack_t stack;
+
+    /* Listeners list */
+    std::list<flat::core::listener> listeners;
+
+    /* Synchronous task checking for signals */
+    task_s * checker;
+
+    /* Channel mapping */
+    static std::map<std::string, channel*> channels;    
+ 
+public:
+
+    flat::core::channel(const std::string& id = "", flat::core::task::priority prior = flat::core::task::priority::none);
+    ~flat::core::channel();
+
+    void emit(const flat::core::signal&);
+
+    void connect(flat::core::listener_s*);
+    void disconnect(flat::core::listener_s*);
+   
+    static flat::core::channel * find_channel(const std::string&); 
+
+    void post_processing(void*);
+
+    /* Functor for order comparison */
+    struct sig_prior_cmp {
+    
+        bool operator()(const flat::core::signal&, const flat::core::signal&) const;
+    };
+
+    typedef std::set<flat::core::signal, sig_prior_cmp> stack_t;
+};
+
+/* Listener class */
+class flat::core::listener : virtual public flat::core::object
+{
+    std::list<std::string> filters;
+
+    bool check_in_filters(const std::string&) const;
+
+    std::function<void(const flat::core::object*)> m_callback;
+
+    flat::core::channel * parent = 0;
+
+public:
+
+    listener(   std::function<void()> m_callback,
+                const std::initializer_list<std::string>& filters = {});
+
+    ~listener();
+
+    void add_filter(const std::string&);
+    void remove_filter(const std::string&);
+
+    bool connect(const std::string&);
+    bool disconnect(const std::string&);
+
+    void invoke(const flat::core::signal&);
+};
+