add list_peer_channels to cln

stakwork · Oct 15, 2024 · 18fd227 · 18fd227
1 parent 1539cca
commit 18fd227
Show file tree

Hide file tree

Showing 7 changed files with 22 additions and 10 deletions.
diff --git a/app/src/api/cln.ts b/app/src/api/cln.ts
@@ -23,6 +23,10 @@ export async function list_peers(tag: string) {
   return await clnCmd("ListPeers", tag);
 }
 
+export async function list_peer_channels(tag: string) {
+  return await clnCmd("ListPeerChannels", tag);
+}
+
 export async function list_funds(tag: string) {
   return await clnCmd("ListFunds", tag);
 }

diff --git a/app/src/api/cmd.ts b/app/src/api/cmd.ts
@@ -6,6 +6,7 @@ export let root = "/api";
 if (IS_DEV) {
   root = "http://localhost:8000/api";
   // root = "https://app.v2.sphinx.chat/api";
+  // root = "https://app.router1.sphinx.chat/api";
 }
 
 const mode = import.meta.env.MODE;
@@ -34,6 +35,7 @@ export type Cmd =
   | "ListChannels"
   | "AddPeer"
   | "ListPeers"
+  | "ListPeerChannels"
   | "AddChannel"
   | "GetBalance"
   | "NewAddress"

diff --git a/app/src/helpers/cln.ts b/app/src/helpers/cln.ts
@@ -149,6 +149,7 @@ function getChannelStatus(status) {
 }
 
 function convertChannelArrayToObj(peerObj) {
+  console.log("=>", peerObj);
   const peers = peerObj.peers;
   const obj = {};
   for (let i = 0; i < peers.length; i++) {

diff --git a/src/cmd.rs b/src/cmd.rs
@@ -151,7 +151,7 @@ pub enum SwarmCmd {
     UpdateUser(UpdateUserDetails),
     GetApiToken,
     SetGlobalMemLimit(u64),
-    GetSignedInUserDetails
+    GetSignedInUserDetails,
 }
 
 #[derive(Serialize, Deserialize, Debug, Clone)]
@@ -251,6 +251,7 @@ pub enum LndCmd {
 pub enum ClnCmd {
     GetInfo,
     ListPeers,
+    ListPeerChannels,
     ListFunds,
     NewAddress,
     AddPeer(AddPeer),

diff --git a/src/conn/cln/mod.rs b/src/conn/cln/mod.rs
@@ -116,15 +116,13 @@ impl ClnRPC {
 
     pub async fn list_peer_channels(
         &mut self,
-        peer_id: Vec<u8>,
+        peer_id: Option<Vec<u8>>,
     ) -> Result<pb::ListpeerchannelsResponse> {
-        let response = self
-            .client
-            .list_peer_channels(pb::ListpeerchannelsRequest {
-                id: Some(peer_id),
-                ..Default::default()
-            })
-            .await?;
+        let mut req = pb::ListpeerchannelsRequest::default();
+        if let Some(peer_id) = peer_id {
+            req.id = Some(peer_id);
+        }
+        let response = self.client.list_peer_channels(req).await?;
         Ok(response.into_inner())
     }
 

diff --git a/src/handler.rs b/src/handler.rs
@@ -536,6 +536,10 @@ pub async fn handle(
                     let info = client.list_peers().await?;
                     Some(serde_json::to_string(&info)?)
                 }
+                ClnCmd::ListPeerChannels => {
+                    let info = client.list_peer_channels(None).await?;
+                    Some(serde_json::to_string(&info)?)
+                }
                 ClnCmd::ListFunds => {
                     let funds = client.list_funds().await?;
                     Some(serde_json::to_string(&funds)?)

diff --git a/src/setup/mod.rs b/src/setup/mod.rs
@@ -120,7 +120,9 @@ pub async fn new_chan_from_cln1(
     let mut ok = false;
     log::info!("wait for channel to confirm...");
     while !ok {
-        let pc = cln1.list_peer_channels(hex::decode(peer_pubkey)?).await?;
+        let pc = cln1
+            .list_peer_channels(Some(hex::decode(peer_pubkey)?))
+            .await?;
         for c in pc.channels {
             // println!("{:?}", c.status);
             if let Some(status) = c.status.get(0) {