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

added getter for connected peers

Browse Source
This commit is contained in:
mystical-prog
2024-11-04 21:54:10 +05:30
committed by Paul Robinson
parent a10b8fdb91
commit 847dfa6577
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
libp2p/host/basic_host.py
View File

@ -145,6 +145,9 @@ class BasicHost(IHost):
addrs.append(addr.encapsulate(p2p_part)) addrs.append(addr.encapsulate(p2p_part))
return addrs return addrs
def get_connected_peers(self) -> List[ID]:
return list(self.get_network().connections.keys())
@asynccontextmanager @asynccontextmanager
async def run( async def run(
self, listen_addrs: Sequence[multiaddr.Multiaddr] self, listen_addrs: Sequence[multiaddr.Multiaddr]

6
libp2p/host/host_interface.py
View File

@ -71,6 +71,12 @@ class IHost(ABC):
:return: all the multiaddr addresses this host is listening to :return: all the multiaddr addresses this host is listening to
""" """
@abstractmethod
def get_connected_peers(self) -> List[ID]:
"""
:return: all the ids of peers this host is currently connected to
"""
@abstractmethod @abstractmethod
def run( def run(
self, listen_addrs: Sequence[multiaddr.Multiaddr] self, listen_addrs: Sequence[multiaddr.Multiaddr]