This commit is contained in:
sumanjeet0012@gmail.com
2025-06-20 16:28:27 +05:30
parent e2f95f4df3
commit 387f4879d1
3 changed files with 8 additions and 19 deletions

View File

@ -6,18 +6,15 @@ import trio
from libp2p import ( from libp2p import (
new_host, new_host,
) )
from libp2p.abc import PeerInfo
from libp2p.crypto.secp256k1 import ( from libp2p.crypto.secp256k1 import (
create_new_key_pair, create_new_key_pair,
) )
from libp2p.discovery.events.peerDiscovery import ( from libp2p.discovery.events.peerDiscovery import peerDiscovery
peerDiscovery
)
from libp2p.abc import (
PeerInfo
)
def customFunctoion(peerinfo: PeerInfo): def customFunctoion(peerinfo: PeerInfo):
print("Printing peer info from demo file",repr(peerinfo)) print("Printing peer info from demo file", repr(peerinfo))
async def main(): async def main():

View File

@ -1,10 +1,7 @@
from collections.abc import ( from collections.abc import (
Awaitable,
Callable, Callable,
) )
import trio
from libp2p.abc import ( from libp2p.abc import (
PeerInfo, PeerInfo,
) )
@ -14,10 +11,10 @@ TTL: int = 60 * 60 # Time-to-live for discovered peers in seconds
class PeerDiscovery: class PeerDiscovery:
def __init__(self) -> None: def __init__(self) -> None:
self._peer_discovered_handlers: list[Callable[[PeerInfo], None]] = [] self._peer_discovered_handlers: list[Callable[[PeerInfo], None]] = []
def register_peer_discovered_handler( def register_peer_discovered_handler(
self, handler: Callable[[PeerInfo], Awaitable[None]] self, handler: Callable[[PeerInfo], None]
) -> None: ) -> None:
self._peer_discovered_handlers.append(handler) self._peer_discovered_handlers.append(handler)

View File

@ -7,15 +7,10 @@ from zeroconf import (
Zeroconf, Zeroconf,
) )
from libp2p.abc import ( from libp2p.abc import IPeerStore, Multiaddr
IPeerStore, from libp2p.discovery.events.peerDiscovery import peerDiscovery
Multiaddr
)
from libp2p.peer.id import ID from libp2p.peer.id import ID
from libp2p.peer.peerinfo import PeerInfo from libp2p.peer.peerinfo import PeerInfo
from libp2p.discovery.events.peerDiscovery import (
peerDiscovery
)
class PeerListener(ServiceListener): class PeerListener(ServiceListener):