o Bj44 @sdZddlmZmZddlmZmZddlmZddl m Z m Z m Z ddl mZddlmZddlmZdd lmZGd d d eZGd d d eZGdddeZGdddeZGdddeZGdddeZGdddeeeeeeZdS)z Asynchronous interfaces for py-libp2p components. This module defines async variants of the core libp2p interfaces, allowing for fully asynchronous implementations alongside the synchronous ones. )ABCabstractmethod) AsyncIterableSequence) Multiaddr)KeyPair PrivateKey PublicKey) MetadataValue)Envelope)ID)PeerInfoc @s^eZdZdZedededefddZededededdfd d Z ededdfd d Z dS) IAsyncPeerMetadataz-Async interface for peer metadata operations.peer_idkeyreturncdS)a Retrieve the value associated with a key for a specified peer. Parameters ---------- peer_id : ID The identifier of the peer. key : str The key to look up. Returns ------- MetadataValue The value corresponding to the specified key. Raises ------ PeerStoreError If the peer ID or value is not found. N)selfrrrr3/Users/sumanjeet/code/py-libp2p/libp2p/abc_async.py get_asynczIAsyncPeerMetadata.get_asyncvalNcr)a Store a key-value pair for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. key : str The key for the data. val : MetadataValue The value to store. Nr)rrrrrrr put_async0rzIAsyncPeerMetadata.put_asynccr)z Clear metadata for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer whose metadata is to be cleared. Nrrrrrrclear_metadata_async@rz'IAsyncPeerMetadata.clear_metadata_async) __name__ __module__ __qualname____doc__rr strr rrrrrrrrsrc @seZdZdZededededdfddZeded e ededdfd d Z edede efd d Z ededdfddZ ede efddZededeefddZdS)IAsyncAddrBookz,Async interface for address book operations.raddrttlrNcr)a Add an address for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. addr : Multiaddr The multiaddress to add. ttl : int The time-to-live for the record. Nr)rrr"r#rrradd_addr_asyncPrzIAsyncAddrBook.add_addr_asyncaddrscr)a9 Add multiple addresses for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. addrs : Sequence[Multiaddr] A sequence of multiaddresses to add. ttl : int The time-to-live for the record. Nr)rrr%r#rrradd_addrs_async`rzIAsyncAddrBook.add_addrs_asynccr)a Retrieve the addresses for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- list[Multiaddr] A list of multiaddresses. Nrrrrr addrs_asyncrrzIAsyncAddrBook.addrs_asynccr)z Clear all addresses for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrrrrclear_addrs_asyncrz IAsyncAddrBook.clear_addrs_asynccr)z Retrieve all peer IDs that have addresses stored. Returns ------- list[ID] A list of peer IDs with stored addresses. Nrrrrrpeers_with_addrs_asyncrz%IAsyncAddrBook.peers_with_addrs_asynccr)aU Returns an async stream of newly added addresses for the given peer. Parameters ---------- peer_id : ID The peer ID to monitor for address updates. Returns ------- AsyncIterable[Multiaddr] An async iterator yielding new addresses as they are added. Nrrrrraddr_stream_asyncrz IAsyncAddrBook.addr_stream_async)rrrrrr rintr$rr&listr'r(r*rr+rrrrr!Ms,   r!c@seZdZdZededBfddZededdfddZeded ede fd d Z ed e dedBfd dZ ed e ddfddZ dS)IAsyncCertifiedAddrBookz6Async interface for certified address book operations.rNcr)z/Get the local-signed-record wrapped in EnvelopeNrr)rrrget_local_record_asyncrz.IAsyncCertifiedAddrBook.get_local_record_asyncenvelopecr)z/Set the local-signed-record wrapped in EnvelopeNr)rr0rrrset_local_record_asyncrz.IAsyncCertifiedAddrBook.set_local_record_asyncr#cr)a- Accept and store a signed PeerRecord, unless it's older than the one already stored. Parameters ---------- envelope: Signed envelope containing a PeerRecord. ttl: Time-to-live for the included multiaddrs (in seconds). Nr)rr0r#rrrconsume_peer_record_asyncrz1IAsyncCertifiedAddrBook.consume_peer_record_asyncrcr)z Retrieve the most recent signed PeerRecord `Envelope` for a peer. Parameters ---------- peer_id : ID The peer to look up. Nrrrrrget_peer_record_asyncrz-IAsyncCertifiedAddrBook.get_peer_record_asynccr)z Delete the signed peer record for a peer if it has no known (non-expired) addresses. Parameters ---------- peer_id : ID The peer whose record we may delete. Nrrrrrmaybe_delete_peer_record_asyncrz6IAsyncCertifiedAddrBook.maybe_delete_peer_record_async)rrrrrr r/r1r,boolr2r r3r4rrrrr.s r.c@seZdZdZededefddZedededdfdd Zedede fd d Z eded e ddfd dZ edede ddfddZ edeefddZededdfddZdS) IAsyncKeyBookz(Async interface for key book operations.rrcr)a Retrieve the public key for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- PublicKey The public key of the peer. Nrrrrr pubkey_asyncrzIAsyncKeyBook.pubkey_asyncpubkeyNcr)z Add a public key for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. pubkey : PublicKey The public key to add. Nr)rrr8rrradd_pubkey_asyncrzIAsyncKeyBook.add_pubkey_asynccr)a Retrieve the private key for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- PrivateKey The private key of the peer. Nrrrrr privkey_asyncrzIAsyncKeyBook.privkey_asyncprivkeycr)z Add a private key for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. privkey : PrivateKey The private key to add. Nr)rrr;rrradd_privkey_asyncrzIAsyncKeyBook.add_privkey_asynckey_paircr)z Add a key pair for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. key_pair : KeyPair The key pair to add. Nr)rrr=rrradd_key_pair_async"rz IAsyncKeyBook.add_key_pair_asynccr)z Retrieve all peer IDs that have keys stored. Returns ------- list[ID] A list of peer IDs with stored keys. Nrr)rrrpeer_with_keys_async0rz"IAsyncKeyBook.peer_with_keys_asynccr)z Clear key data for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrrrrclear_keydata_async<rz!IAsyncKeyBook.clear_keydata_async)rrrrrr r r7r9rr:r<rr>r-r?r@rrrrr6s     r6c@sVeZdZdZedededdfddZededefdd Zededdfd d Z dS) IAsyncMetricsz'Async interface for metrics operations.rRTTrNcr)z Record a new latency measurement for the given peer. Parameters ---------- peer_id : ID The identifier of the peer. RTT : float The round-trip time measurement. Nr)rrrBrrrrecord_latency_asyncLrz"IAsyncMetrics.record_latency_asynccr)z Retrieve the latency EWMA for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- float The latency EWMA value. Nrrrrrlatency_EWMA_asyncZrz IAsyncMetrics.latency_EWMA_asynccr)z Clear metrics for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrrrrclear_metrics_asynckrz!IAsyncMetrics.clear_metrics_async) rrrrrr floatrCrDrErrrrrAIs rAc@seZdZdZededeefddZedede eddfdd Z edede eddfd d Z edede eddfd d Z edede edeefddZ edede edefddZededdfddZdS)IAsyncProtoBookz-Async interface for protocol book operations.rrcr)a  Retrieve the protocols supported by the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- list[str] A list of protocol strings. Nrrrrrget_protocols_async{rz#IAsyncProtoBook.get_protocols_async protocolsNcr)z Add protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to add. NrrrrIrrradd_protocols_asyncrz#IAsyncProtoBook.add_protocols_asynccr)z Set protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to set. NrrJrrrset_protocols_asyncrz#IAsyncProtoBook.set_protocols_asynccr)z Remove protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to remove. NrrJrrrremove_protocols_asyncrz&IAsyncProtoBook.remove_protocols_asynccr)aU Check which protocols are supported by the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to check. Returns ------- list[str] A list of supported protocols. NrrJrrrsupports_protocols_asyncrz(IAsyncProtoBook.supports_protocols_asynccr)aI Get the first supported protocol from the given list. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to check. Returns ------- str The first supported protocol. NrrJrrrfirst_supported_protocol_asyncrz.IAsyncProtoBook.first_supported_protocol_asynccr)z Clear protocol data for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrrrrclear_protocol_data_asyncrz)IAsyncProtoBook.clear_protocol_data_async)rrrrrr r-r rHrrKrLrMrNrOrPrrrrrGxsD     rGc@seZdZdZededefddZedeefddZ ededdfd d Z edeefd d Z edde ddfddZ edddZdS)IAsyncPeerStorez Async interface for a peer store. Provides async methods for managing peer information including address management, protocol handling, and key storage. rrcr)a Retrieve the peer information for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- PeerInfo The peer information object for the given peer. Nrrrrrpeer_info_asyncrzIAsyncPeerStore.peer_info_asynccr)z Retrieve all peer identifiers stored in the peer store. Returns ------- list[ID] A list of all peer IDs in the store. Nrr)rrrpeer_ids_asyncrzIAsyncPeerStore.peer_ids_asyncNcr)z&Clear all data for the specified peer.Nrrrrrclear_peerdata_asyncrz$IAsyncPeerStore.clear_peerdata_asynccr)z Retrieve all valid (non-expired) peer identifiers. Returns ------- list[ID] A list of valid peer IDs in the store. Nrr)rrrvalid_peer_ids_asyncrz$IAsyncPeerStore.valid_peer_ids_asynccleanup_intervalcr)z=Start periodic cleanup of expired peer records and addresses.Nr)rrWrrrstart_cleanup_task+rz"IAsyncPeerStore.start_cleanup_taskcr)z+Close the peerstore and clean up resources.Nrr)rrr close_async/rzIAsyncPeerStore.close_async)rV)rN)rrrrrr r rRr-rSrTrUr,rXrYrrrrrQs  rQN)rabcrrcollections.abcrr multiaddrrlibp2p.crypto.keysrrr libp2p.custom_typesr libp2p.peer.enveloper libp2p.peer.idr libp2p.peer.peerinfor rr!r.r6rArGrQrrrrs.     8`4h/ w