From c2187ca6b61c701c281cc528db43f6b97c50f3d8 Mon Sep 17 00:00:00 2001
From: dec05eba <dec05eba@protonmail.com>
Date: Thu, 7 Jun 2018 22:00:42 +0200
Subject: Add bootstrap node, listen method

---
 include/sibs/BootstrapConnection.hpp | 33 +++++++++++++++++++++++++++++++++
 1 file changed, 33 insertions(+)
 create mode 100644 include/sibs/BootstrapConnection.hpp

(limited to 'include/sibs/BootstrapConnection.hpp')

diff --git a/include/sibs/BootstrapConnection.hpp b/include/sibs/BootstrapConnection.hpp
new file mode 100644
index 0000000..964d777
--- /dev/null
+++ b/include/sibs/BootstrapConnection.hpp
@@ -0,0 +1,33 @@
+#pragma once
+
+#include "../utils.hpp"
+#include "DirectConnection.hpp"
+#include "PubsubKey.hpp"
+
+namespace sibs
+{
+    class PubsubKeyAlreadyListeningException : public std::runtime_error
+    {
+    public:
+        PubsubKeyAlreadyListeningException(const std::string &errMsg) : std::runtime_error(errMsg) {}
+    };
+    
+    using BoostrapConnectionListenCallbackFunc = std::function<void(const void *data, const usize size)>;
+    
+    class BootstrapConnection
+    {
+        DISABLE_COPY(BootstrapConnection)
+    public:
+        BootstrapConnection(const Ipv4 &bootstrapAddress);
+        
+        // Throws PubsubKeyAlreadyListeningException if we are already listening on the key @pubsubKey
+        void listen(const PubsubKey &pubsubKey, BoostrapConnectionListenCallbackFunc callbackFunc);
+    private:
+        void receiveDataFromServer(std::shared_ptr<DirectConnectionPeer> peer, const void *data, const usize size);
+        void receiveDataFromPeer(BoostrapConnectionListenCallbackFunc listenCallbackFunc, std::shared_ptr<DirectConnectionPeer> peer, const void *data, const usize size);
+    private:
+        DirectConnections connections;
+        std::shared_ptr<DirectConnectionPeer> serverPeer;
+        PubsubKeyMap<BoostrapConnectionListenCallbackFunc> listenCallbackFuncs;
+    };
+}
-- 
cgit v1.2.3