aboutsummaryrefslogtreecommitdiff
path: root/jsonrpc
diff options
context:
space:
mode:
authorhozan23 <hozan23@karyontech.net>2024-06-14 02:04:43 +0200
committerhozan23 <hozan23@karyontech.net>2024-06-14 02:04:43 +0200
commit0c0699c0460c1b149915729223eec701bde481df (patch)
treeb9ada7e1bd288684eb8fdf690ea1034520ab9f16 /jsonrpc
parent60a947f6e857f0aa5ae5e8c3b0a183577f74a9f4 (diff)
p2p: WIP implement rpc server for the p2p monitor
Diffstat (limited to 'jsonrpc')
-rw-r--r--jsonrpc/src/client/mod.rs2
-rw-r--r--jsonrpc/src/server/channel.rs1
2 files changed, 2 insertions, 1 deletions
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>,