summaryrefslogtreecommitdiff
path: root/include
diff options
context:
space:
mode:
authorRoman Smrž <roman.smrz@seznam.cz>2021-01-06 21:52:53 +0100
committerRoman Smrž <roman.smrz@seznam.cz>2021-01-06 21:52:53 +0100
commit381b6505b5afaacc9194168697f6bc93c43d2775 (patch)
tree1190917b6ee40d6f4a74bf724466b3062ab86f4f /include
parent96eb8471d11667a56466a6f701d1d23fa64c2225 (diff)
Access services via Server object
Diffstat (limited to 'include')
-rw-r--r--include/erebos/message.h10
-rw-r--r--include/erebos/network.h11
2 files changed, 18 insertions, 3 deletions
diff --git a/include/erebos/message.h b/include/erebos/message.h
index c94e8c3..66d221c 100644
--- a/include/erebos/message.h
+++ b/include/erebos/message.h
@@ -4,11 +4,14 @@
#include <chrono>
#include <functional>
+#include <memory>
#include <optional>
#include <string>
namespace erebos {
+using std::unique_ptr;
+
class Identity;
class DirectMessage
@@ -78,13 +81,14 @@ public:
void handle(Context &) const override;
typedef std::function<void(const DirectMessageThread &, ssize_t, ssize_t)> ThreadWatcher;
- static void onUpdate(ThreadWatcher);
- static DirectMessageThread thread(const Identity &);
+ void onUpdate(ThreadWatcher);
+ DirectMessageThread thread(const Identity &);
- static DirectMessage send(const Identity &, const Peer &, const std::string &);
+ DirectMessage send(const Identity &, const Peer &, const std::string &);
private:
struct Priv;
+ unique_ptr<Priv> p;
};
}
diff --git a/include/erebos/network.h b/include/erebos/network.h
index d730fb5..a2f989e 100644
--- a/include/erebos/network.h
+++ b/include/erebos/network.h
@@ -4,6 +4,7 @@
#include <erebos/service.h>
#include <functional>
+#include <typeinfo>
namespace erebos {
@@ -13,14 +14,24 @@ public:
Server(const Identity &, std::vector<std::unique_ptr<Service>> &&);
~Server();
+ template<class S> S & svc();
+
class PeerList & peerList() const;
struct Peer;
private:
+ Service & svcHelper(const std::type_info &);
+
struct Priv;
const std::shared_ptr<Priv> p;
};
+template<class S>
+S & Server::svc()
+{
+ return dynamic_cast<S&>(svcHelper(typeid(S)));
+}
+
class Peer
{
public: