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

DNS resolution working

Browse Source
This commit is contained in:
sumanjeet0012@gmail.com
2025-07-09 01:45:15 +05:30
parent dcb199a6b7
commit 2965b4e364
2 changed files with 19 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
examples/bootstrap/bootstrap.py
View File

@ -29,11 +29,16 @@ def on_peer_discovery(peer_info: PeerInfo) -> None:
logger.info(f" Addresses: {[str(addr) for addr in peer_info.addrs]}") logger.info(f" Addresses: {[str(addr) for addr in peer_info.addrs]}")
# Example bootstrap peers (you can replace with real bootstrap nodes) # Example bootstrap peers ( valid IPFS bootstrap nodes)
BOOTSTRAP_PEERS = [ BOOTSTRAP_PEERS = [
# IPFS bootstrap nodes (examples - replace with actual working nodes) "/ip4/104.131.131.82/tcp/4001/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ",
"/ip4/104.131.131.82/tcp/4001/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SznbYGzPwp8qDrq",
"/ip6/2604:a880:1:20::203:d001/tcp/4001/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM", "/ip6/2604:a880:1:20::203:d001/tcp/4001/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM",
"/ip4/128.199.219.111/tcp/4001/p2p/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64",
"/ip4/104.236.76.40/tcp/4001/p2p/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64",
"/ip4/178.62.158.247/tcp/4001/p2p/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd",
"/ip6/2604:a880:1:20::203:d001/tcp/4001/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM",
"/ip6/2400:6180:0:d0::151:6001/tcp/4001/p2p/QmSoLSafTMBsPKadTEgaXctDQVcqN88CNLHXMkTNwMKPnu",
"/ip6/2a03:b0c0:0:1010::23:1001/tcp/4001/p2p/QmSoLueR4xBeUbY9WZ9xGUUxunbKWcrNFTDAadQJmocnWm",
] ]

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

@ -32,7 +32,7 @@ class BootstrapDiscovery:
try: try:
self._process_bootstrap_addr(addr_str) self._process_bootstrap_addr(addr_str)
except Exception as e: except Exception as e:
logger.warning(f"Failed to process bootstrap address {addr_str}: {e}") logger.debug(f"Failed to process bootstrap address {addr_str}: {e}")
def stop(self) -> None: def stop(self) -> None:
"""Clean up bootstrap discovery resources.""" """Clean up bootstrap discovery resources."""
@ -41,11 +41,18 @@ class BootstrapDiscovery:
def _process_bootstrap_addr(self, addr_str: str) -> None: def _process_bootstrap_addr(self, addr_str: str) -> None:
"""Convert string address to PeerInfo and add to peerstore.""" """Convert string address to PeerInfo and add to peerstore."""
# Convert string to Multiaddr try:
multiaddr = Multiaddr(addr_str) multiaddr = Multiaddr(addr_str)
except Exception as e:
logger.debug(f"Invalid multiaddr format '{addr_str}': {e}")
return
# Extract peer info from multiaddr # Extract peer info from multiaddr
peer_info = info_from_p2p_addr(multiaddr) try:
peer_info = info_from_p2p_addr(multiaddr)
except Exception as e:
logger.debug(f"Failed to extract peer info from '{addr_str}': {e}")
return
# Skip if it's our own peer # Skip if it's our own peer
if peer_info.peer_id == self.swarm.get_peer_id(): if peer_info.peer_id == self.swarm.get_peer_id():
@ -65,5 +72,3 @@ class BootstrapDiscovery:
# Emit peer discovery event # Emit peer discovery event
peerDiscovery.emit_peer_discovered(peer_info) peerDiscovery.emit_peer_discovered(peer_info)
logger.info(f"Discovered bootstrap peer: {peer_info.peer_id}")