fix(gossipsub): forward to floodsub peers

messages weren't forwarded to floodsub peers Pull-Request: #5908.
libp2p · Mar 7, 2025 · 9caa7f5 · 9caa7f5
1 parent 29efd0d
commit 9caa7f5
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 5 deletions.
diff --git a/protocols/gossipsub/CHANGELOG.md b/protocols/gossipsub/CHANGELOG.md
@@ -8,6 +8,9 @@
 - Respect already received IDONTWANT messages when handling IWANT.
   See [PR 5901](https://github.com/libp2p/rust-libp2p/pull/5901)
 
+- Fix messages were not forwarded to floodsub peers.
+  See [PR 5908](https://github.com/libp2p/rust-libp2p/pull/5908)
+
 ## 0.48.0
 
 - Allow broadcasting `IDONTWANT` messages when publishing to avoid downloading data that is already available.

diff --git a/protocols/gossipsub/src/behaviour.rs b/protocols/gossipsub/src/behaviour.rs
@@ -2673,15 +2673,17 @@ where
 
         // Populate the recipient peers mapping
 
-        // Add explicit peers
-        for peer_id in &self.explicit_peers {
-            let Some(peer) = self.connected_peers.get(peer_id) else {
-                continue;
-            };
+        // Add explicit peers and floodsub peers
+        for (peer_id, peer) in &self.connected_peers {
             if Some(peer_id) != propagation_source
                 && !originating_peers.contains(peer_id)
                 && Some(peer_id) != message.source.as_ref()
                 && peer.topics.contains(&message.topic)
+                && (self.explicit_peers.contains(peer_id)
+                    || (peer.kind == PeerKind::Floodsub
+                        && !self
+                            .score_below_threshold(peer_id, |ts| ts.publish_threshold)
+                            .0))
             {
                 recipient_peers.insert(*peer_id);
             }