varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-11 07:30:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: eliminate self.protocol_id attribute \w in PeerRouting

Browse Source
This commit is contained in:
Luca Vivona
2025-06-22 00:25:48 -04:00
parent feb8db6655
commit 3a4338e1df
2 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
libp2p/kad_dht/peer_routing.py
View File

@ -60,7 +60,6 @@ class PeerRouting(IPeerRouting):
""" """
self.host = host self.host = host
self.routing_table = routing_table self.routing_table = routing_table
self.protocol_id = PROTOCOL_ID
async def find_peer(self, peer_id: ID) -> PeerInfo | None: async def find_peer(self, peer_id: ID) -> PeerInfo | None:
""" """
@ -245,7 +244,7 @@ class PeerRouting(IPeerRouting):
# Open a stream to the peer using the Kademlia protocol # Open a stream to the peer using the Kademlia protocol
logger.debug(f"Opening stream to {peer} for closest peers query") logger.debug(f"Opening stream to {peer} for closest peers query")
try: try:
stream = await self.host.new_stream(peer, [self.protocol_id]) stream = await self.host.new_stream(peer, [PROTOCOL_ID])
logger.debug(f"Stream opened to {peer}") logger.debug(f"Stream opened to {peer}")
except Exception as e: except Exception as e:
logger.warning(f"Failed to open stream to {peer}: {e}") logger.warning(f"Failed to open stream to {peer}: {e}")

1
tests/core/kad_dht/test_unit_peer_routing.py
View File

@ -89,7 +89,6 @@ class TestPeerRouting:
assert peer_routing.host == mock_host assert peer_routing.host == mock_host
assert peer_routing.routing_table == mock_routing_table assert peer_routing.routing_table == mock_routing_table
assert peer_routing.protocol_id == PROTOCOL_ID
@pytest.mark.trio @pytest.mark.trio
async def test_find_peer_local_host(self, peer_routing, mock_host): async def test_find_peer_local_host(self, peer_routing, mock_host):