diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py index d5d4b52..d8fb3c0 100644 --- a/libp2p/pubsub/pubsub.py +++ b/libp2p/pubsub/pubsub.py @@ -87,9 +87,10 @@ class Pubsub(): if rpc_incoming.publish: # deal with RPC.publish for message in rpc_incoming.publish: - if message.seqno not in self.seen_messages: + id_in_seen_msgs = (message.seqno, message.from_id) + if id_in_seen_msgs not in self.seen_messages: should_publish = True - self.seen_messages.append((message.seqno, message.from_id)) + self.seen_messages.append(id_in_seen_msgs) await self.handle_talk(message) if rpc_incoming.subscriptions: