feat(p2p): add wait() to Node and runtime

Author: GaspardKirira

include/vix/p2p/Node.hpp

@@ -58,6 +58,7 @@ namespace vix::p2p
     virtual void start() = 0;
     virtual void stop() = 0;
     virtual bool running() const = 0;
+    virtual void wait() = 0;
 
     virtual bool connect(const PeerEndpoint &ep) = 0;
     virtual void disconnect(const PeerId &peer_id) = 0;

include/vix/p2p/P2P.hpp

@@ -33,9 +33,8 @@ namespace vix::p2p
 
     virtual void start() = 0;
     virtual void stop() = 0;
-
+    virtual void wait() = 0;
     virtual bool connect(const PeerEndpoint &ep) = 0;
-
     virtual NodeStats stats() const = 0;
   };
 
@@ -74,6 +73,12 @@ namespace vix::p2p
         node_->stop();
     }
 
+    void wait() override
+    {
+      if (node_)
+        node_->wait();
+    }
+
     // Default: manual connect (same spirit as CLI --connect)
     bool connect(const PeerEndpoint &ep) override
     {

src/Node.cpp

@@ -22,6 +22,8 @@
 #include <random>
 #include <deque>
 #include <span>
+#include <atomic>
+#include <future>
 
 #include <vix/p2p/Node.hpp>
 #include <vix/p2p/Peer.hpp>
@@ -176,6 +178,18 @@ namespace vix::p2p
 
     bool running() const override { return running_; }
 
+    void wait() override
+    {
+      if (!running_)
+        start();
+
+      if (io_thread_.joinable() && std::this_thread::get_id() == io_thread_.get_id())
+        return;
+
+      if (io_thread_.joinable())
+        io_thread_.join();
+    }
+
     bool connect(const PeerEndpoint &ep) override
     {
       if (!running_)