From 37652f70347607f183a1698c28d551cb9ace402e Mon Sep 17 00:00:00 2001 From: paschal533 Date: Tue, 2 Sep 2025 03:50:00 -0700 Subject: [PATCH 1/2] fix: GossipSub peer propagation to include FloodSub peers --- libp2p/pubsub/gossipsub.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libp2p/pubsub/gossipsub.py b/libp2p/pubsub/gossipsub.py index c345c138c..0e9bae26a 100644 --- a/libp2p/pubsub/gossipsub.py +++ b/libp2p/pubsub/gossipsub.py @@ -293,7 +293,7 @@ def _get_peers_to_send( floodsub_peers: set[ID] = { peer_id for peer_id in self.pubsub.peer_topics[topic] - if self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID + if peer_id in self.peer_protocol and self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID } send_to.update(floodsub_peers) From b367ff70c3db0b6c7362f850786698819eeb681e Mon Sep 17 00:00:00 2001 From: Paschal <58183764+paschal533@users.noreply.github.com> Date: Tue, 2 Sep 2025 04:31:35 -0700 Subject: [PATCH 2/2] Fix: lint error --- libp2p/pubsub/gossipsub.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/libp2p/pubsub/gossipsub.py b/libp2p/pubsub/gossipsub.py index 0291ce38b..06104957c 100644 --- a/libp2p/pubsub/gossipsub.py +++ b/libp2p/pubsub/gossipsub.py @@ -306,7 +306,8 @@ def _get_peers_to_send( floodsub_peers: set[ID] = { peer_id for peer_id in self.pubsub.peer_topics[topic] - if peer_id in self.peer_protocol and self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID + if peer_id in self.peer_protocol + and self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID } send_to.update(floodsub_peers)