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

Fix formatting and linting issues

Browse Source
This commit is contained in:
sumanjeet0012@gmail.com
2025-07-10 19:25:58 +05:30
parent 2dfee68f20
commit 9669a92976
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
libp2p/discovery/bootstrap/bootstrap.py
View File

@ -50,19 +50,19 @@ class BootstrapDiscovery:
except Exception as e: except Exception as e:
logger.debug(f"Invalid multiaddr format '{addr_str}': {e}") logger.debug(f"Invalid multiaddr format '{addr_str}': {e}")
return return
if (self.is_dns_addr(multiaddr)): if self.is_dns_addr(multiaddr):
resolved_addrs = await multiaddr.resolve() resolved_addrs = await multiaddr.resolve()
for resolved_addr in resolved_addrs: for resolved_addr in resolved_addrs:
if resolved_addr == multiaddr: if resolved_addr == multiaddr:
return return
self.add_addr(Multiaddr(resolved_addr)) self.add_addr(Multiaddr(resolved_addr))
self.add_addr(multiaddr) self.add_addr(multiaddr)
def is_dns_addr(self, addr: Multiaddr) -> bool: def is_dns_addr(self, addr: Multiaddr) -> bool:
"""Check if the address is a DNS address.""" """Check if the address is a DNS address."""
return any(protocol.name == "dnsaddr" for protocol in addr.protocols()) return any(protocol.name == "dnsaddr" for protocol in addr.protocols())
def add_addr(self, addr: Multiaddr) -> None: def add_addr(self, addr: Multiaddr) -> None:
"""Add a peer to the peerstore and emit discovery event.""" """Add a peer to the peerstore and emit discovery event."""
# Extract peer info from multiaddr # Extract peer info from multiaddr
@ -89,4 +89,4 @@ class BootstrapDiscovery:
self.discovered_peers.add(str(peer_info.peer_id)) self.discovered_peers.add(str(peer_info.peer_id))
# Emit peer discovery event # Emit peer discovery event
peerDiscovery.emit_peer_discovered(peer_info) peerDiscovery.emit_peer_discovered(peer_info)