From 0c0699c0460c1b149915729223eec701bde481df Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@karyontech.net>
Date: Fri, 14 Jun 2024 02:04:43 +0200
Subject: p2p: WIP implement rpc server for the p2p monitor

---
 jsonrpc/src/client/mod.rs     | 2 +-
 jsonrpc/src/server/channel.rs | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

(limited to 'jsonrpc')

diff --git a/jsonrpc/src/client/mod.rs b/jsonrpc/src/client/mod.rs
index 95354d3..1225f13 100644
--- a/jsonrpc/src/client/mod.rs
+++ b/jsonrpc/src/client/mod.rs
@@ -97,6 +97,7 @@ impl Client {
 
         // Send the json request
         self.conn.send(req_json).await?;
+        debug!("--> {request}");
 
         // Register a new request
         let rx = self.message_dispatcher.register(id).await;
@@ -126,7 +127,6 @@ impl Client {
             return Err(Error::InvalidMsg("Invalid response id"));
         }
 
-        debug!("--> {request}");
         Ok(response)
     }
 
diff --git a/jsonrpc/src/server/channel.rs b/jsonrpc/src/server/channel.rs
index bb62b9f..9278c8c 100644
--- a/jsonrpc/src/server/channel.rs
+++ b/jsonrpc/src/server/channel.rs
@@ -11,6 +11,7 @@ pub(crate) struct NewNotification {
 }
 
 /// Represents a new subscription
+#[derive(Clone)]
 pub struct Subscription {
     pub id: SubscriptionID,
     parent: Arc<Channel>,
-- 
cgit v1.2.3