varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-12 16:10:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

recompile protobuf schema and remove typos

Browse Source
This commit is contained in:
lla-dane
2025-08-11 09:48:45 +05:30
parent 5ab68026d6
commit a21d9e878b
3 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/kad_dht/kad_dht.py
View File

@ -364,7 +364,7 @@ class KadDHT(Service):
envelope, _ = consume_envelope( envelope, _ = consume_envelope(
message.senderRecord, "libp2p-peer-record" message.senderRecord, "libp2p-peer-record"
) )
# Use the default TTL of 2 hours (72000 seconds) # Use the default TTL of 2 hours (7200 seconds)
if not self.host.get_peerstore().consume_peer_record( if not self.host.get_peerstore().consume_peer_record(
envelope, 7200 envelope, 7200
): ):

1
libp2p/kad_dht/peer_routing.py
View File

@ -361,7 +361,6 @@ class PeerRouting(IPeerRouting):
) )
except Exception as e: except Exception as e:
print("EXCEPTION CAME")
logger.debug(f"Error querying peer {peer} for closest: {e}") logger.debug(f"Error querying peer {peer} for closest: {e}")
finally: finally:

2
tests/core/kad_dht/test_kad_dht.py
View File

@ -86,7 +86,7 @@ async def test_find_node(dht_pair: tuple[KadDHT, KadDHT]):
dht_b.host.get_peerstore().get_peer_record(dht_a.host.get_id()), Envelope dht_b.host.get_peerstore().get_peer_record(dht_a.host.get_id()), Envelope
) )
# Verifies if the senderRecord in the FIND_NODE response is correctly proccessed # Verifies if the senderRecord in the FIND_NODE response is correctly processed
assert isinstance( assert isinstance(
dht_a.host.get_peerstore().get_peer_record(dht_b.host.get_id()), Envelope dht_a.host.get_peerstore().get_peer_record(dht_b.host.get_id()), Envelope
) )