warnings + relay connected_peers fn

src/p2p/behaviour/mod.rs

@@ -37,7 +37,7 @@ where
     autonat: AutoNat,
 }
 
-async fn poll_swarm<KS>(mut swarm: Swarm<Behaviour<KS>>) -> Result<(), ()>
+async fn poll_swarm<KS>(_swarm: Swarm<Behaviour<KS>>) -> Result<(), ()>
 where
     KS: RecordStore + Send + 'static,
 {

src/p2p/relay.rs

@@ -54,6 +54,7 @@ enum Message {
     GetAddresses(oneshot::Sender<Vec<Multiaddr>>),
     ListenOn(Vec<Multiaddr>, oneshot::Sender<Result<(), Error>>),
     Dial(Multiaddr, oneshot::Sender<Result<(), Error>>),
+    GetConnectedPeers(oneshot::Sender<Vec<PeerId>>),
 }
 
 impl RelayNode {
@@ -82,6 +83,12 @@ impl RelayNode {
         self.sender.send(Message::Dial(addr, s)).await?;
         r.await?
     }
+
+    pub async fn connected_peers(&mut self) -> Result<Vec<PeerId>, Error> {
+        let (s, r) = oneshot::channel();
+        self.sender.send(Message::GetConnectedPeers(s)).await?;
+        Ok(r.await?)
+    }
 }
 
 #[derive(Debug)]
@@ -235,6 +242,9 @@ async fn poll_swarm(
                     swarm.dial(addr)?;
                     s.send(Ok(())).map_err(|_| SwarmError::SendError)?
                 }
+                Message::GetConnectedPeers(s) => s
+                    .send(swarm.connected_peers().map(|p| p.to_owned()).collect())
+                    .map_err(|_| SwarmError::SendError)?,
             },
             Either::Right((Some(_), _)) => {
                 // process swarm event