Refine the Ready peers event

Author: lu-zero

dht-cache/src/cache.rs

@@ -2,6 +2,7 @@
 
 mod local;
 
+use std::collections::HashSet;
 use std::sync::Arc;
 use std::{collections::BTreeMap, time::Duration};
 
@@ -301,6 +302,7 @@ pub fn cache_channel(
         let peers_state = peers_state.clone();
         let peer_id = local_peer_id.clone();
         let cmd = cmd.clone();
+        let mut ready_peers = HashSet::new();
         async move {
             match ev {
                 DhtEvent::Config(cfg) => {
@@ -378,9 +380,10 @@ pub fn cache_channel(
                     }
                 }
                 DhtEvent::Ready(peers) => {
-                    if !peers.is_empty() {
+                    if !peers.is_empty() && peers != ready_peers {
+                        ready_peers = peers;
                         Some(Event::ReadyPeers(
-                            peers.into_iter().map(|p| p.to_string()).collect()))
+                            ready_peers.into_iter().map(|p| p.to_string()).collect()))
                     } else {
                         None
                     }

dht-cache/src/dht.rs

@@ -1,6 +1,7 @@
 //! DHT Abstraction
 //!
 
+use std::collections::HashSet;
 use std::time::Duration;
 
 use crate::domolibp2p::{DomoBehaviour, OutEvent};
@@ -28,7 +29,7 @@ pub enum Event {
     VolatileData(String),
     Config(String),
     Discovered(Vec<PeerId>),
-    Ready(Vec<PeerId>),
+    Ready(HashSet<PeerId>),
 }
 
 fn handle_command(swarm: &mut Swarm<DomoBehaviour>, cmd: Command) -> bool {
@@ -177,7 +178,7 @@ pub fn dht_channel(
                 .gossipsub
                 .all_peers()
                 .filter_map(|(p, topics)| {
-                    log::info!("{p}, {topics:?}");
+                    log::debug!("{p}, {topics:?}");
                     (topics.contains(&&volatile)
                         && topics.contains(&&persistent)
                         && topics.contains(&&config))
@@ -192,7 +193,7 @@ pub fn dht_channel(
                 // the mdns event is not enough to ensure we can send messages
                 _ = interval.tick() => {
                     log::debug!("{} Checking for peers", swarm.local_peer_id());
-                    let peers: Vec<_> = check_peers(&mut swarm);
+                    let peers: HashSet<_> = check_peers(&mut swarm);
                         if !peers.is_empty() &&
                         ev_send.send(Event::Ready(peers)).is_err() {
                             return swarm;