Bj44 dZddlmZmZddlmZmZddlmZddl m Z m Z m Z ddl mZddlmZddlmZdd lmZGd d eZGd d eZGddeZGddeZGddeZGddeZGddeeeeeeZy)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 jeZdZdZedededefdZededededdfdZ ededdfd Z y) IAsyncPeerMetadataz-Async interface for peer metadata operations.peer_idkeyreturnc Kyw)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)selfrrs 3/Users/sumanjeet/code/py-libp2p/libp2p/abc_async.py get_asynczIAsyncPeerMetadata.get_asyncvalNc Kyw)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)rrrrs r put_asynczIAsyncPeerMetadata.put_async0rrc Kyw)z Clear metadata for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer whose metadata is to be cleared. Nrrrs rclear_metadata_asyncz'IAsyncPeerMetadata.clear_metadata_async@rr) __name__ __module__ __qualname____doc__rr strr rrr rrrrs~7 r    .  r    -  D      "      r&rc eZdZdZededededdfdZedede ededdfd Z edede efd Z ededdfd Z ede efd Zededeefd Zy)IAsyncAddrBookz,Async interface for address book operations.raddrttlrNc Kyw)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*s radd_addr_asynczIAsyncAddrBook.add_addr_asyncPrraddrsc Kyw)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*s radd_addrs_asynczIAsyncAddrBook.add_addrs_async`rrc Kyw)a Retrieve the addresses for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- list[Multiaddr] A list of multiaddresses. Nrrs r addrs_asynczIAsyncAddrBook.addrs_asyncrrrc Kyw)z Clear all addresses for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrs rclear_addrs_asyncz IAsyncAddrBook.clear_addrs_asyncrrc Kyw)z Retrieve all peer IDs that have addresses stored. Returns ------- list[ID] A list of peer IDs with stored addresses. Nrrs rpeers_with_addrs_asyncz%IAsyncAddrBook.peers_with_addrs_asyncrrc Kyw)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. Nrrs raddr_stream_asyncz IAsyncAddrBook.addr_stream_asyncrr)r!r"r#r$rr rintr,rr/listr1r3r6rr8rr&rr(r(Ms6  B  i  c  d      "*9"5 rAr9boolrCr rErGrr&rr<r<s@>ho>>>X>$>>    s  t      2  (T/      B  4    r&r<ceZdZdZededefdZedededdfdZedede fdZ eded e ddfd Z eded e ddfd Z edeefd ZededdfdZy) IAsyncKeyBookz(Async interface for key book operations.rrc Kyw)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. Nrrs r pubkey_asynczIAsyncKeyBook.pubkey_asyncrrpubkeyNc Kyw)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)rrrMs radd_pubkey_asynczIAsyncKeyBook.add_pubkey_asyncrrc Kyw)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. Nrrs r privkey_asynczIAsyncKeyBook.privkey_asyncrrprivkeyc Kyw)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)rrrRs radd_privkey_asynczIAsyncKeyBook.add_privkey_asyncrrkey_pairc Kyw)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)rrrUs radd_key_pair_asyncz IAsyncKeyBook.add_key_pair_async"rrc Kyw)z Retrieve all peer IDs that have keys stored. Returns ------- list[ID] A list of peer IDs with stored keys. Nrr5s rpeer_with_keys_asyncz"IAsyncKeyBook.peer_with_keys_async0rrc Kyw)z Clear key data for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrs rclear_keydata_asyncz!IAsyncKeyBook.clear_keydata_async<rr)r!r"r#r$rr r rLrOr rQrTrrWr:rYr[rr&rrJrJs2 "     b  )       2 *    r  J  4        g  $      DH            r&rJcbeZdZdZedededdfdZededefdZededdfdZ y) IAsyncMetricsz'Async interface for metrics operations.rRTTrNc Kyw)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)rrr^s rrecord_latency_asyncz"IAsyncMetrics.record_latency_asyncLrrc Kyw)z Retrieve the latency EWMA for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- float The latency EWMA value. Nrrs rlatency_EWMA_asyncz IAsyncMetrics.latency_EWMA_asyncZrrc Kyw)z Clear metrics for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrs rclear_metrics_asyncz!IAsyncMetrics.clear_metrics_asynckrr) r!r"r#r$rr floatr`rbrdrr&rr]r]Isp1  "  5  T      u          r&r]ceZdZdZededeefdZedede eddfdZ edede eddfdZ edede eddfd Z edede edeefd Z edede edefd Zededdfd Zy) IAsyncProtoBookz-Async interface for protocol book operations.rrc Kyw)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. Nrrs rget_protocols_asyncz#IAsyncProtoBook.get_protocols_async{rr protocolsNc Kyw)z Add protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to add. Nrrrrjs radd_protocols_asyncz#IAsyncProtoBook.add_protocols_asyncrrc Kyw)z Set protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to set. Nrrls rset_protocols_asyncz#IAsyncProtoBook.set_protocols_asyncrrc Kyw)z Remove protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to remove. Nrrls rremove_protocols_asyncz&IAsyncProtoBook.remove_protocols_asyncrrc Kyw)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. Nrrls rsupports_protocols_asyncz(IAsyncProtoBook.supports_protocols_asyncrrc Kyw)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. Nrrls rfirst_supported_protocol_asyncz.IAsyncProtoBook.first_supported_protocol_asyncrrc Kyw)z Clear protocol data for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nrrs rclear_protocol_data_asyncz)IAsyncProtoBook.clear_protocol_data_asyncrr)r!r"r#r$rr r:r%rirrmrorqrsrurwrr&rrgrgxs;7  S         RV          RV        &.sm        &.sm c  (  &.sm   (  r  d    r&rgceZdZdZededefdZedeefdZ ededdfdZ edeefdZ ed d e ddfd Z ed d Zy)IAsyncPeerStorez Async interface for a peer store. Provides async methods for managing peer information including address management, protocol handling, and key storage. rrc Kyw)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. Nrrs rpeer_info_asynczIAsyncPeerStore.peer_info_asyncrrc Kyw)z Retrieve all peer identifiers stored in the peer store. Returns ------- list[ID] A list of all peer IDs in the store. Nrr5s rpeer_ids_asynczIAsyncPeerStore.peer_ids_asyncrrNc Kyw)z&Clear all data for the specified peer.Nrrs rclear_peerdata_asyncz$IAsyncPeerStore.clear_peerdata_asyncrrc Kyw)z Retrieve all valid (non-expired) peer identifiers. Returns ------- list[ID] A list of valid peer IDs in the store. Nrr5s rvalid_peer_ids_asyncz$IAsyncPeerStore.valid_peer_ids_asyncrrcleanup_intervalc Kyw)z=Start periodic cleanup of expired peer records and addresses.Nr)rrs rstart_cleanup_taskz"IAsyncPeerStore.start_cleanup_task+rrc Kyw)z+Close the peerstore and clean up resources.Nrr5s r close_asynczIAsyncPeerStore.close_async/rr)i)rN)r!r"r#r$rr rr{r:r}rrr9rrrr&rryrys R H    d2h    5"555  DH    LLLL::r&ryN)r$abcrrcollections.abcrr multiaddrrlibp2p.crypto.keysrr r libp2p.custom_typesr libp2p.peer.enveloper libp2p.peer.idr libp2p.peer.peerinforrr(r<rJr]rgryrr&rrs$3==-))5 5 p] S] @1 c1 he Ce P, C, ^t ct nB: B:r&