Mempool syncer: check peer for necessary service flag when adding it …

…dynamically
nimiq · Nov 7, 2024 · 95e9128 · 95e9128
1 parent 918a0a3
commit 95e9128
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/mempool/src/sync/mod.rs b/mempool/src/sync/mod.rs
@@ -22,6 +22,7 @@ use nimiq_consensus::{sync::syncer::SyncEvent, ConsensusProxy};
 use nimiq_hash::{Blake2bHash, Hash};
 use nimiq_network_interface::{
     network::Network,
+    peer_info::Services,
     request::{request_handler, RequestError},
 };
 use nimiq_time::sleep_until;
@@ -193,7 +194,11 @@ impl<N: Network> MempoolSyncer<N> {
 
     /// Add peer to discover its mempool
     fn add_peer(&mut self, peer_id: N::PeerId) {
-        if self.peers.contains(&peer_id) {
+        if self.peers.contains(&peer_id)
+            || !self
+                .network
+                .peer_provides_services(peer_id.clone(), Services::MEMPOOL)
+        {
             return;
         }