lsps0: client implementation

libs/sdk-core/src/lsps0/client.rs

@@ -0,0 +1,67 @@
+use serde::{Deserialize, Serialize};
+use std::{sync::Arc, time::Duration};
+use tokio::sync::mpsc;
+
+use super::{error::Error, transport::Transport};
+
+#[derive(Debug, Serialize)]
+pub struct ListProtocolsRequest {}
+
+#[derive(Debug, Deserialize)]
+pub struct ListProtocolsResponse {
+    pub protocols: Vec<i32>,
+}
+
+pub struct Client {
+    transport: Arc<Transport>,
+    peer_id: Vec<u8>,
+    timeout: Duration,
+}
+
+impl Client {
+    #[allow(dead_code)]
+    pub fn new(transport: Arc<Transport>, peer_id: Vec<u8>, timeout: Duration) -> Self {
+        Self {
+            transport,
+            peer_id,
+            timeout,
+        }
+    }
+
+    #[allow(dead_code)]
+    pub async fn call<TRequest, TResponse>(
+        &self,
+        method: String,
+        req: TRequest,
+    ) -> Result<TResponse, Error>
+    where
+        TRequest: serde::Serialize,
+        TResponse: serde::de::DeserializeOwned,
+    {
+        self.transport
+            .request_response(method, self.peer_id.clone(), &req, self.timeout)
+            .await
+    }
+
+    #[allow(dead_code)]
+    pub async fn stream_notifications<TNotification>(
+        &self,
+        method: String,
+    ) -> Result<mpsc::Receiver<TNotification>, Error>
+    where
+        TNotification: serde::de::DeserializeOwned + std::marker::Send + 'static,
+    {
+        self.transport
+            .stream_notifications(method, self.peer_id.clone())
+            .await
+    }
+
+    #[allow(dead_code)]
+    pub async fn list_protocols(&self) -> Result<ListProtocolsResponse, Error> {
+        self.call(
+            String::from("lsps0.list_protocols"),
+            ListProtocolsRequest {},
+        )
+        .await
+    }
+}

libs/sdk-core/src/lsps0/mod.rs

@@ -1,7 +1,11 @@
+pub(crate) mod client;
 pub(crate) mod error;
 pub(crate) mod jsonrpc;
 pub(crate) mod transport;
 
+#[allow(unused_imports)]
+pub(crate) use client::Client;
+
 #[allow(unused_imports)]
 pub(crate) use transport::Transport;
 

libs/sdk-core/src/lsps0/transport.rs

@@ -222,7 +222,6 @@ impl Transport {
         }
     }
 
-    #[allow(dead_code)]
     pub async fn request_response<TRequest, TResponse>(
         &self,
         method: String,
@@ -271,7 +270,6 @@ impl Transport {
         }
     }
 
-    #[allow(dead_code)]
     pub async fn stream_notifications<TNotification>(
         &self,
         method: String,