From 8b8b0518856cbaaad4d8f8a25f0bb38686d5e153 Mon Sep 17 00:00:00 2001 From: lla-dane Date: Fri, 18 Jul 2025 12:08:50 +0530 Subject: [PATCH] batch operations for consume_peer_record --- libp2p/peer/peerstore.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/libp2p/peer/peerstore.py b/libp2p/peer/peerstore.py index 8a01c8ec..454b0d1b 100644 --- a/libp2p/peer/peerstore.py +++ b/libp2p/peer/peerstore.py @@ -270,6 +270,13 @@ class PeerStore(IPeerStore): return True + def consume_peer_records(self, envelopes: list[Envelope], ttl: int) -> list[bool]: + """Consume multiple peer records in a single operation.""" + results = [] + for envelope in envelopes: + results.append(self.consume_peer_record(envelope, ttl)) + return results + def get_peer_record(self, peer_id: ID) -> Envelope | None: """ Retrieve the most recent signed PeerRecord `Envelope` for a peer, if it exists