feat: Add current connection list

src/client.rs

@@ -1,3 +1,5 @@
+use bitcoin::p2p::address::AddrV2;
+use bitcoin::p2p::ServiceFlags;
 use bitcoin::{Amount, Transaction, Wtxid};
 use bitcoin::{BlockHash, FeeRate};
 use tokio::sync::mpsc;
@@ -166,6 +168,20 @@ impl Requester {
         Ok(FeeRate::from_sat_per_kwu(fee_rate))
     }
 
+    /// Get the current peer connections.
+    ///
+    /// # Errors
+    ///
+    /// If the node has stopped running.
+    pub async fn peer_info(&self) -> Result<Vec<(AddrV2, ServiceFlags)>, ClientError> {
+        let (tx, rx) = tokio::sync::oneshot::channel::<Vec<(AddrV2, ServiceFlags)>>();
+        let request = ClientRequest::new((), tx);
+        self.ntx
+            .send(ClientMessage::GetPeerInfo(request))
+            .map_err(|_| ClientError::SendError)?;
+        rx.await.map_err(|_| ClientError::RecvError)
+    }
+
     /// Starting after the configured checkpoint, re-emit all block filters.
     ///
     /// # Errors

src/messages.rs

@@ -1,6 +1,8 @@
 use std::collections::BTreeMap;
 use std::ops::Div;
 
+use bitcoin::p2p::address::AddrV2;
+use bitcoin::p2p::ServiceFlags;
 use bitcoin::{
     block::Header, p2p::message_network::RejectReason, BlockHash, FeeRate, Transaction, Wtxid,
 };
@@ -151,6 +153,8 @@ pub(crate) enum ClientMessage {
     AddPeer(TrustedPeer),
     /// Request the broadcast minimum fee rate.
     GetBroadcastMinFeeRate(ClientRequest<(), FeeRate>),
+    /// Get info on connections
+    GetPeerInfo(ClientRequest<(), Vec<(AddrV2, ServiceFlags)>>),
     /// Send an empty message to see if the node is running.
     NoOp,
 }

src/network/peer_map.rs

@@ -190,6 +190,13 @@ impl PeerMap {
             .unwrap_or(FeeRate::BROADCAST_MIN)
     }
 
+    pub fn peer_info(&self) -> Vec<(AddrV2, ServiceFlags)> {
+        self.map
+            .values()
+            .map(|peer| (peer.record.network_addr().0, peer.record.service_flags()))
+            .collect()
+    }
+
     // Send a message to the specified peer
     pub async fn send_message(&self, nonce: PeerId, message: MainThreadMessage) {
         if let Some(peer) = self.map.get(&nonce) {

src/node.rs

@@ -258,6 +258,14 @@ impl Node {
                                     self.dialog.send_warning(Warning::ChannelDropped);
                                 };
                             }
+                            ClientMessage::GetPeerInfo(request) => {
+                                let (_, oneshot) = request.into_values();
+                                let peers = self.peer_map.peer_info();
+                                let send_result = oneshot.send(peers);
+                                if send_result.is_err() {
+                                    self.dialog.send_warning(Warning::ChannelDropped);
+                                };
+                            }
                             ClientMessage::NoOp => (),
                         }
                     }

tests/core.rs

@@ -250,6 +250,8 @@ async fn various_client_methods() {
     let _ = requester.broadcast_min_feerate().await.unwrap();
     let cp = requester.chain_tip().await.unwrap();
     assert_eq!(cp.hash, best);
+    let peers = requester.peer_info().await.unwrap();
+    assert_eq!(peers.len(), 1);
     assert!(requester.is_running());
     requester.shutdown().unwrap();
     rpc.stop().unwrap();