jh ddlmZmZddlmZmZmZmZmZddl m Z ddl m Z ddl mZddlmZmZmZmZddlmZddlZdd lmZdd lmZmZmZdd lmZmZm Z m!Z!m"Z"dd l#m$Z$dd l%m&Z&m'Z'ddl(m)Z)ddl*m+cm,cm-Z,ddl.m/Z/erddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddl GddeZ?Gdde?e>Z@GddeZAGdd e'ed ZBGd!d"e'ZCGd#d$e&ZDGd%d&eZEGd'd(eZFGd)d*eZGGd+d,eZHGd-d.eZIGd/d0eZJGd1d2eEeFeGeHeIeJZKGd3d4eZLGd5d6eZMe Gd7d8ZNGd9d:eMe=ZOGd;deZQGd?d@eZRGdAdBeZSGdCdDeZTGdEdFeZUGdGdHeZVGdIdJeZWGdKdLeZXGdMdNeZYGdOdPeZZGdQdReZ[GdSdTedTee;jZ]GdUdVeZ^GdWdXe=Z_GdYdZeZ`y)[)ABCabstractmethod) AsyncIterable AsyncIteratorIterableKeysViewSequence)AbstractAsyncContextManager) dataclass) TracebackType) TYPE_CHECKINGAnyAsyncContextManagerOptional) MultiaddrN)ConnectionType)KeyPair PrivateKey PublicKey) MetadataValueStreamHandlerFnTHandler TProtocol ValidatorFn)EventBus)CloserReadWriteCloser)ID)PeerInfo)TagStore)Envelope) PeerRecord) Multiselect)Pubsub)rpc_pb2) ServiceAPIcNeZdZUdZeed<edeefdZ ede fdZ y)IRawConnectionz Interface for a raw connection. This interface provides a basic reader/writer connection abstraction. Attributes ---------- is_initiator (bool): True if the local endpoint initiated the connection. is_initiatorreturncy)z Get the actual transport addresses used by this connection. Returns the real IP/port addresses, not peerstore addresses. For relayed connections, should include /p2p-circuit in the path. Nselfs -/Users/sumanjeet/code/py-libp2p/libp2p/abc.pyget_transport_addressesz&IRawConnection.get_transport_addressesZs cyzD Get the type of connection (direct, relayed, etc.) Nr,r-s r/get_connection_typez"IRawConnection.get_connection_typed r1N) __name__ __module__ __qualname____doc__bool__annotations__rlistrr0rr4r,r1r/r(r(JsG  i   ^  r1r(cheZdZdZedefdZedefdZedefdZ ede fdZ y)AbstractSecureConnz Abstract interface for secure connections. Represents a secured connection object, including details about the security involved in the connection. r*cy)z\ Retrieve the local peer's identifier. :return: The local peer ID. Nr,r-s r/get_local_peerz!AbstractSecureConn.get_local_peer}r1cy)zm Retrieve the local peer's private key. :return: The private key of the local peer. Nr,r-s r/get_local_private_keyz(AbstractSecureConn.get_local_private_keyrAr1cy)z^ Retrieve the remote peer's identifier. :return: The remote peer ID. Nr,r-s r/get_remote_peerz"AbstractSecureConn.get_remote_peerrAr1cy)zm Retrieve the remote peer's public key. :return: The public key of the remote peer. Nr,r-s r/get_remote_public_keyz(AbstractSecureConn.get_remote_public_keyrAr1N) r6r7r8r9rrr@rrCrErrGr,r1r/r>r>tss    z      y  r1r>ceZdZdZy) ISecureConnzv Interface for a secure connection. Combines secure connection functionalities with raw I/O operations. N)r6r7r8r9r,r1r/rIrIsr1rIc2eZdZUdZeed<ejed<ede deddfdZ e ede fdZ edd Zedd Ze ede fd Ze ede fd Zedd ZeddZedeefdZedefdZy) IMuxedConnaS Interface for a multiplexed connection. References ---------- https://github.com/libp2p/go-stream-muxer/blob/master/muxer.go Attributes ---------- peer_id (ID): The identifier of the connected peer. event_started (trio.Event): An event that signals when the multiplexer has started. peer_id event_startedconnr*Ncy)z Initialize a new multiplexed connection. :param conn: An instance of a secure connection used for new multiplexed streams. :param peer_id: The peer ID associated with the connection. Nr,r.rNrLs r/__init__zIMuxedConn.__init__rAr1cy)z Determine if this connection is the initiator. :return: True if this connection initiated the connection, otherwise False. Nr,r-s r/r)zIMuxedConn.is_initiatorrAr1c Kyw)z) Start the multiplexer. Nr,r-s r/startzIMuxedConn.startc Kyw)z4 Close the multiplexed connection. Nr,r-s r/closezIMuxedConn.closerUrVcy)z Check if the connection is fully established and ready for streams. :return: True if the connection is established, otherwise False. Nr,r-s r/is_establishedzIMuxedConn.is_establishedrAr1cyz Check if the connection is fully closed. :return: True if the connection is closed, otherwise False. Nr,r-s r/ is_closedzIMuxedConn.is_closedrAr1c Kyw)zm Create and open a new multiplexed stream. :return: A new instance of IMuxedStream. Nr,r-s r/ open_streamzIMuxedConn.open_streamrUrVc Kyw)z Accept a new multiplexed stream initiated by the remote peer. :return: A new instance of IMuxedStream. Nr,r-s r/ accept_streamzIMuxedConn.accept_streamrUrVcy)zH Get transport addresses by delegating to secured_conn. Nr,r-s r/r0z"IMuxedConn.get_transport_addressesr5r1cy)zD Get connection type by delegating to secured_conn. Nr,r-s r/r4zIMuxedConn.get_connection_type r5r1r*Nr* IMuxedStream)r6r7r8r9rr;trioEventrrIrQpropertyr:r)rTrXrZr]r_rar<rr0rr4r,r1r/rKrKs9 K::            d          4       i   ^  r1rKceZdZUdZeed<ed dZededdfdZ eddZ d e e dzd e dzd e dzddfd Zy)rfz Interface for a multiplexed stream. Represents a stream multiplexed over a single connection. Attributes ---------- muxed_conn (IMuxedConn): The underlying multiplexed connection. muxed_connr*Nc Kyw)z Reset the stream. This method closes both ends of the stream, instructing the remote side to hang up. Nr,r-s r/resetzIMuxedStream.reset$rUrVttlcy)z Set a deadline for the stream. :param ttl: Time-to-live for the stream in seconds. :raises ValueError: if ttl is invalid (e.g. negative). Nr,r.rns r/ set_deadlinezIMuxedStream.set_deadline-rAr1cK|Sw)z Enter the async context manager.r,r-s r/ __aenter__zIMuxedStream.__aenter__6s  sexc_typeexc_valexc_tbc@K|jd{y7w)z4Exit the async context manager and close the stream.N)rX)r.rtrurvs r/ __aexit__zIMuxedStream.__aexit__;sjjls rdre)r6r7r8r9rKr;rrmintrqrstype BaseExceptionr rxr,r1r/rfrfs       }%,%$   r1rfceZdZUdZeed<ejedzed<e de dzfdZ e de ddfdZ e d d Z y) INetStreamz Interface for a network stream. Represents a network stream operating over a multiplexed connection. Attributes ---------- muxed_conn (IMuxedConn): The multiplexed connection that this stream belongs to. rkNmetric_send_channelr*cy)z Retrieve the protocol identifier for the stream. :return: The protocol ID associated with the stream. Nr,r-s r/ get_protocolzINetStream.get_protocolXrAr1 protocol_idcy)z Set the protocol identifier for the stream. :param protocol_id: The protocol ID to assign to the stream. Nr,r.rs r/ set_protocolzINetStream.set_protocol`rAr1c Kyw)z` Reset the network stream. This method closes both ends of the stream. Nr,r-s r/rmzINetStream.resethrUrVrd)r6r7r8r9rKr;rgMemorySendChannelrrrrrrmr,r1r/r}r}Hsy //4t;; i$.    d    r1r}ceZdZUdZeed<ejed<ee de fdZ e de fdZ e dee dffdZe deefd Ze defd Zy ) INetConna> Interface for a network connection. Defines a network connection capable of creating and managing streams. Attributes ---------- muxed_conn (IMuxedConn): The underlying multiplexed connection. event_started (trio.Event): Event signaling when the connection has started. rkrMr*cyr\r,r-s r/r]zINetConn.is_closedrAr1c Kyw)zr Create a new network stream over the connection. :return: A new instance of INetStream. Nr,r-s r/ new_streamzINetConn.new_streamrUrV.cy)z Retrieve all active streams associated with this connection. :return: A tuple containing instances of INetStream. Nr,r-s r/ get_streamszINetConn.get_streamsrAr1cy)a$ Retrieve the actual transport addresses used by this connection. Returns the real IP/port addresses, not peerstore addresses. For relayed connections, should include /p2p-circuit in the path. :return: A list of multiaddresses used by the transport. Nr,r-s r/r0z INetConn.get_transport_addressesrAr1cyr3r,r-s r/r4zINetConn.get_connection_typer5r1N)r6r7r8r9rKr;rgrhrirr:r]r}rtuplerr<rr0rr4r,r1r/rrts ::  4   *   U:s?3   i   ^  r1rc jeZdZdZedededefdZededededdfdZ ededdfd Z y) IPeerMetadataz Interface for managing peer metadata. Provides methods for storing and retrieving metadata associated with peers. rLkeyr*cy)a Retrieve metadata for a specified peer. :param peer_id: The ID of the peer. :param key: The key for the metadata to retrieve. :return: The metadata value associated with the key. :raises Exception: If the peer ID is not found. Nr,r.rLrs r/getzIPeerMetadata.getrAr1valNcy)z Store metadata for a specified peer. :param peer_id: The ID of the peer. :param key: The key for the metadata. :param val: The value to store. :raises Exception: If the operation is unsuccessful. Nr,r.rLrrs r/putzIPeerMetadata.putrAr1cy)z Remove all stored metadata for the specified peer. Parameters ---------- peer_id : ID The peer identifier whose metadata are to be removed. Nr,r.rLs r/clear_metadatazIPeerMetadata.clear_metadatarAr1) r6r7r8r9rrstrrrrrr,r1r/rrs  2 C M   2 C m     b  T    r1rc eZdZdZededededdfdZedede ededdfd Z edede efd Z ededdfd Z ede efd Zy) IAddrBookz[ Interface for an address book. Provides methods for managing peer addresses. rLaddrrnr*Ncy)a Add a single address for a given peer. This method calls ``add_addrs(peer_id, [addr], ttl)``. Parameters ---------- peer_id : ID The peer identifier for which to add the address. addr : Multiaddr The multiaddress of the peer. ttl : int The time-to-live for the address, after which it is no longer valid. Nr,r.rLrrns r/add_addrzIAddrBook.add_addrrAr1addrscy)aE Add multiple addresses for a given peer, all with the same TTL. If an address already exists with a longer TTL, no action should be taken. If an address exists with a shorter TTL, its TTL should be extended to match the provided TTL. Parameters ---------- peer_id : ID The peer identifier for which to add addresses. addrs : Sequence[Multiaddr] A sequence of multiaddresses to add. ttl : int The time-to-live for the addresses, after which they become invalid. Nr,r.rLrrns r/ add_addrszIAddrBook.add_addrsrAr1cy)aD Retrieve all known and valid addresses for the specified peer. Parameters ---------- peer_id : ID The peer identifier whose addresses are requested. Returns ------- list[Multiaddr] A list of valid multiaddresses for the given peer. Nr,rs r/rzIAddrBook.addrsrAr1cy)z Remove all stored addresses for the specified peer. Parameters ---------- peer_id : ID The peer identifier whose addresses are to be removed. Nr,rs r/ clear_addrszIAddrBook.clear_addrs rAr1cy)z Retrieve all peer identifiers that have stored addresses. Returns ------- list[ID] A list of peer IDs with stored addresses. Nr,r-s r/peers_with_addrszIAddrBook.peers_with_addrs,rAr1)r6r7r8r9rrrryrr rr<rrrr,r1r/rrs   ) # $  "  HY,? c d  & R DO    2  $      $r(    r1rcheZdZdZedddedefdZedede dfdZ ededd fd Z y ) ICertifiedAddrBookzh Interface for a certified address book. Provides methods for managing signed peer records enveloper!rnr*cy)a! Accept and store a signed PeerRecord, unless it's older than the one already stored. This function: - Extracts the peer ID and sequence number from the envelope - Rejects the record if it's older (lower seq) - Updates the stored peer record and replaces associated addresses if accepted Parameters ---------- envelope: Signed envelope containing a PeerRecord. ttl: Time-to-live for the included multiaddrs (in seconds). Nr,r.rrns r/consume_peer_recordz&ICertifiedAddrBook.consume_peer_recordArAr1rLcya Retrieve the most recent signed PeerRecord `Envelope` for a peer, if it exists and is still relevant. First, it runs cleanup via `maybe_delete_peer_record` to purge stale data. Then it checks whether the peer has valid, unexpired addresses before returning the associated envelope. Parameters ---------- peer_id : ID The peer to look up. Nr,rs r/get_peer_recordz"ICertifiedAddrBook.get_peer_recordWrAr1Ncy)a Delete the signed peer record for a peer if it has no know (non-expired) addresses. This is a garbage collection mechanism: if all addresses for a peer have expired or been cleared, there's no point holding onto its signed `Envelope` Parameters ---------- peer_id : ID The peer whose record we may delete. Nr,rs r/maybe_delete_peer_recordz+ICertifiedAddrBook.maybe_delete_peer_recordirAr1) r6r7r8r9rryr:rrrrrr,r1r/rr:sy  J S T  * r hz.B  "    t    r1rceZdZdZededefdZededefdZ edededdfdZ eded eddfd Z eded e ddfd Z edeefd ZededdfdZy)IKeyBookz[ Interface for an key book. Provides methods for managing cryptographic keys. rLr*cy)z Returns the public key of the specified peer Parameters ---------- peer_id : ID The peer identifier whose public key is to be returned. Nr,rs r/pubkeyzIKeyBook.pubkeyrAr1cy)z Returns the private key of the specified peer Parameters ---------- peer_id : ID The peer identifier whose private key is to be returned. Nr,rs r/privkeyzIKeyBook.privkeyrAr1rNcy)z Adds the public key for a specified peer Parameters ---------- peer_id : ID The peer identifier whose public key is to be added pubkey: PublicKey The public key of the peer Nr,r.rLrs r/ add_pubkeyzIKeyBook.add_pubkeyrAr1rcy)z Adds the private key for a specified peer Parameters ---------- peer_id : ID The peer identifier whose private key is to be added privkey: PrivateKey The private key of the peer Nr,r.rLrs r/ add_privkeyzIKeyBook.add_privkeyrAr1key_paircy)z Adds the key pair for a specified peer Parameters ---------- peer_id : ID The peer identifier whose key pair is to be added key_pair: KeyPair The key pair of the peer Nr,r.rLrs r/ add_key_pairzIKeyBook.add_key_pairrAr1cyz/Returns all the peer IDs stored in the AddrBookNr,r-s r/peer_with_keyszIKeyBook.peer_with_keysrAr1cyz Remove all stored keydata for the specified peer. Parameters ---------- peer_id : ID The peer identifier whose keys are to be removed. Nr,rs r/ clear_keydatazIKeyBook.clear_keydatarAr1)r6r7r8r9rrrrrrrrrrr<rrr,r1r/rr}s   b  Y      r  j      "  i  D      2   t      B  '  d    >R>>  R  D    r1rcbeZdZdZedededdfdZededefdZededdfdZ y) IMetricszd Interface for metrics of peer interaction. Provides methods for managing the metrics. rLRTTr*Ncyam Records a new round-trip time (RTT) latency value for the specified peer using Exponentially Weighted Moving Average (EWMA). Parameters ---------- peer_id : ID The identifier of the peer for which latency is being recorded. RTT : float The round-trip time latency value to record. Nr,r.rLrs r/record_latencyzIMetrics.record_latencyrAr1cya Returns the current latency value for the specified peer using Exponentially Weighted Moving Average (EWMA). Parameters ---------- peer_id : ID The identifier of the peer whose latency EWMA is to be returned. Nr,rs r/ latency_EWMAzIMetrics.latency_EWMArAr1cyz Clears the stored latency metrics for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer whose latency metrics are to be cleared. Nr,rs r/ clear_metricszIMetrics.clear_metricsrAr1) r6r7r8r9rrfloatrrrr,r1r/rrst   b  u        B  5      R  D    r1rceZdZdZededeefdZedede eddfdZ edede eddfdZ edede eddfd Z edede edeefd Z edede edefd Zededdfd Zy) IProtoBookzl Interface for a protocol book. Provides methods for managing the list of supported protocols. rLr*cy)z Returns the list of protocols associated with the specified peer. Parameters ---------- peer_id : ID The identifier of the peer whose supported protocols are to be returned. Nr,rs r/ get_protocolszIProtoBook.get_protocolsrAr1 protocolsNcy)a- Adds the given protocols to the specified peer's protocol list. Parameters ---------- peer_id : ID The identifier of the peer to which protocols will be added. protocols : Sequence[str] A sequence of protocol strings to add. Nr,r.rLrs r/ add_protocolszIProtoBook.add_protocols!rAr1cy)a8 Replaces the existing protocols of the specified peer with the given list. Parameters ---------- peer_id : ID The identifier of the peer whose protocols are to be set. protocols : Sequence[str] A sequence of protocol strings to assign. Nr,rs r/ set_protocolszIProtoBook.set_protocols0rAr1cya3 Removes the specified protocols from the peer's protocol list. Parameters ---------- peer_id : ID The identifier of the peer from which protocols will be removed. protocols : Sequence[str] A sequence of protocol strings to remove. Nr,rs r/remove_protocolszIProtoBook.remove_protocols?rAr1cyam Returns the list of protocols from the input sequence that the peer supports. Parameters ---------- peer_id : ID The identifier of the peer to check for protocol support. protocols : Sequence[str] A sequence of protocol strings to check against the peer's supported protocols. Nr,rs r/supports_protocolszIProtoBook.supports_protocolsNrAr1cya Returns the first protocol from the input list that the peer supports. Parameters ---------- peer_id : ID The identifier of the peer to check for supported protocols. protocols : Sequence[str] A sequence of protocol strings to check. Returns ------- str The first matching protocol string, or an empty string if none are supported. Nr,rs r/first_supported_protocolz#IProtoBook.first_supported_protocol^rAr1cyz Clears all protocol data associated with the specified peer. Parameters ---------- peer_id : ID The identifier of the peer whose protocol data will be cleared. Nr,rs r/clear_protocol_datazIProtoBook.clear_protocol_datasrAr1)r6r7r8r9rrr<rrr rrrrrrr,r1r/rrs6   R  DI      R  HSM  d      R  HSM  d        x}        "  #  4PS9      x} QT  (  2  $    r1rc eZdZdZedededefdZededededdfdZ ededdfd Z eded e d e ddfd Z eded ee d e ddfdZededee fdZededdfdZedeefdZededfdZed5dZeddd e defdZedededfdZededdfdZededefdZededefdZedededdfdZedededdfdZ edede!ddfd Z"edeefd!Z#ededdfd"Z$eded#e%ddfd$Z&edede%fd%Z'ededdfd&Z(ededeefd'Z)eded(eeddfd)Z*eded(eeddfd*Z+eded(eeddfd+Z,eded(eedeefd,Z-eded(eedefd-Z.ededdfd.Z/edede0fd/Z1edeefd0Z2ededefd1Z3ededdfd2Z4ed6d3e ddfd4Z5y)7 IPeerStorez Interface for a peer store. Provides methods for managing peer information including address management, protocol handling, and key storage. rLrr*cy)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. Nr,rs r/rzIPeerStore.getrAr1rNcy)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,rs r/rzIPeerStore.putrAr1cyrr,rs r/rzIPeerStore.clear_metadatarAr1rrncy)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,rs r/rzIPeerStore.add_addrrAr1rcy)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,rs r/rzIPeerStore.add_addrsrAr1cy)a Retrieve the addresses for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- list[Multiaddr] A list of multiaddresses. Nr,rs r/rzIPeerStore.addrsrAr1cy)z Clear all addresses for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Nr,rs r/rzIPeerStore.clear_addrsrAr1cy)z Retrieve all peer identifiers with stored addresses. Returns ------- list[ID] A list of peer IDs. Nr,r-s r/rzIPeerStore.peers_with_addrsrAr1r!cy)z-Get the local-peer-record wrapped in EnvelopeNr,r-s r/get_local_recordzIPeerStore.get_local_recordrAr1rcy)z-Set the local-peer-record wrapped in EnvelopeNr,)r.rs r/set_local_recordzIPeerStore.set_local_recordrAr1cy)a Accept and store a signed PeerRecord, unless it's older than the one already stored. This function: - Extracts the peer ID and sequence number from the envelope - Rejects the record if it's older (lower seq) - Updates the stored peer record and replaces associated addresses if accepted Parameters ---------- envelope: Signed envelope containing a PeerRecord. ttl: Time-to-live for the included multiaddrs (in seconds). Nr,rs r/rzIPeerStore.consume_peer_recordrAr1cyrr,rs r/rzIPeerStore.get_peer_record+rAr1cy)a Delete the signed peer record for a peer if it has no know (non-expired) addresses. This is a garbage collection mechanism: if all addresses for a peer have expired or been cleared, there's no point holding onto its signed `Envelope` Parameters ---------- peer_id : ID The peer whose record we may delete. Nr,rs r/rz#IPeerStore.maybe_delete_peer_record=rAr1cy)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. Raises ------ PeerStoreError If the peer ID is not found. Nr,rs r/rzIPeerStore.pubkeyOrAr1cy)ac 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. Raises ------ PeerStoreError If the peer ID is not found. Nr,rs r/rzIPeerStore.privkeyerAr1rcy)aI Add a public key for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. pubkey : PublicKey The public key to add. Raises ------ PeerStoreError If the peer already has a public key set. Nr,rs r/rzIPeerStore.add_pubkey{rAr1rcy)aN Add a private key for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. privkey : PrivateKey The private key to add. Raises ------ PeerStoreError If the peer already has a private key set. Nr,rs r/rzIPeerStore.add_privkeyrAr1rcy)aP 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. Raises ------ PeerStoreError If the peer already has a public or private key set. Nr,rs r/rzIPeerStore.add_key_pairrAr1cyrr,r-s r/rzIPeerStore.peer_with_keysrAr1cyrr,rs r/rzIPeerStore.clear_keydatarAr1rcyrr,rs r/rzIPeerStore.record_latencyrAr1cyrr,rs r/rzIPeerStore.latency_EWMArAr1cyrr,rs r/rzIPeerStore.clear_metricsrAr1cy)ao Retrieve the protocols associated with the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. Returns ------- list[str] A list of protocol identifiers. Raises ------ PeerStoreError If the peer ID is not found. Nr,rs r/rzIPeerStore.get_protocolsrAr1rcy)z Add additional protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to add. Nr,rs r/rzIPeerStore.add_protocolsrAr1cy)z Set the protocols for the specified peer. Parameters ---------- peer_id : ID The identifier of the peer. protocols : Sequence[str] The protocols to set. Nr,rs r/rzIPeerStore.set_protocolsrAr1cyrr,rs r/rzIPeerStore.remove_protocols!rAr1cyrr,rs r/rzIPeerStore.supports_protocols0rAr1cyrr,rs r/rz#IPeerStore.first_supported_protocol@rAr1cyrr,rs r/rzIPeerStore.clear_protocol_dataUrAr1cy)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. Nr,rs r/ peer_infozIPeerStore.peer_infobrAr1cy)z Retrieve all peer identifiers stored in the peer store. Returns ------- list[ID] A list of all peer IDs in the store. Nr,r-s r/peer_idszIPeerStore.peer_idssrAr1cy)a Return True if ``peer_id`` is known to this store. This MUST be O(1)-ish (in-memory map / single key lookup) and MUST NOT materialize the full peer list: ``peer_ids()`` on persistent stores reconstructs and hashes every peer, which is far too expensive for hot paths (e.g. per-connection checks). Parameters ---------- peer_id : ID The peer ID to check. Returns ------- bool True if the peer is known to the store. Nr,rs r/has_peerzIPeerStore.has_peerrAr1cy)clear_peerdataNr,rs r/rzIPeerStore.clear_peerdatarAr1cleanup_intervalc Kyw)z=Start periodic cleanup of expired peer records and addresses.Nr,)r.rs r/start_cleanup_taskzIPeerStore.start_cleanup_taskrUrV)rr!r*N)i)6r6r7r8r9rrrrrrrrryrr rr<rrrrrrr:rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr,r1r/rrs; 2 C M  .  2  C  m        b  T        )  #  $        HY,?  c  d     R DO    2  $      $r(    <(:"6<<<< J S T  ( r hz.B  "    t    " b Y  * r j  * " i D  $ 2  t  $ B ' d  $>R>>  R  D      b  u        B  5      R  D     R DI  *  R  HSM  d      R  HSM  d        x}        "  #  4PS9      x} QT  (  2  $          $r(      t  *bTLLLLr1rc\eZdZdZededdfdZedeedffdZed dZ y) IListenerz Interface for a network listener. Provides methods for starting a listener, retrieving its addresses, and closing it. maddrr*Nc Kyw)an Start listening on the specified multiaddress. The listener manages its own background tasks internally and keeps them alive until :meth:`close` is called. Callers do not need to supply a nursery. Parameters ---------- maddr : Multiaddr The multiaddress on which to listen. Raises ------ Exception Transport-specific listener exception, such as ``OpenConnectionError`` (TCP/WebSocket) or ``QUICListenError`` (QUIC), if listening fails (e.g. missing/invalid port or failed start). Nr,r.r"s r/listenzIListener.listenrUrV.cy)z Retrieve the list of addresses on which the listener is active. Returns ------- tuple[Multiaddr, ...] A tuple of multiaddresses. Nr,r-s r/ get_addrszIListener.get_addrsrAr1c Kyw)z& Close the listener. Nr,r-s r/rXzIListener.close rVrd) r6r7r8r9rrr%rr'rXr,r1r/r!r!sa )   ,  5C0      r1r!ceZdZUdZeed<eeee fed<ee e fed<e defdZ e ddedzdee fd Ze deeee ffd Ze dede dzfd Ze dedee fd Ze dedefd Ze dedede fdZe dededefdZe deddfdZe dedefdZe ddZe ddZe ddZe deddfdZ y)INetworka Interface for the network. Provides methods for managing connections, streams, and listeners. Attributes ---------- peerstore : IPeerStore The peer store for managing peer information. connections : dict[ID, list[INetConn]] A mapping of peer IDs to lists of network connections (multiple connections per peer). listeners : dict[str, IListener] A mapping of listener identifiers to listener instances. peerstore connections listenersr*cy)z Retrieve the peer identifier for this network. Returns ------- ID The identifier of this peer. Nr,r-s r/ get_peer_idzINetwork.get_peer_idrAr1NrLcy)a Get connections for peer (like JS getConnections, Go ConnsToPeer). Parameters ---------- peer_id : ID | None The peer ID to get connections for. If None, returns all connections. Returns ------- list[INetConn] List of connections to the specified peer, or all connections if peer_id is None. Nr,rs r/get_connectionszINetwork.get_connectionsrAr1cy)z Get all connections map (like JS getConnectionsMap). Returns ------- dict[ID, list[INetConn]] The complete mapping of peer IDs to their connection lists. Nr,r-s r/get_connections_mapzINetwork.get_connections_map rAr1cy)a7 Get single connection for backward compatibility. Parameters ---------- peer_id : ID The peer ID to get a connection for. Returns ------- INetConn | None The first available connection, or None if no connections exist. Nr,rs r/get_connectionzINetwork.get_connectionrAr1c Kyw)a Create connections to the specified peer with load balancing. Parameters ---------- peer_id : ID The identifier of the peer to dial. Returns ------- list[INetConn] List of established connections to the peer. Raises ------ SwarmException If an error occurs during dialing. Nr,rs r/ dial_peerzINetwork.dial_peer)rUrVc Kyw)a Create a new network stream to the specified peer. Parameters ---------- peer_id : ID The identifier of the destination peer. Returns ------- INetStream The newly created network stream. Nr,rs r/rzINetwork.new_stream?rUrVraw_connc Kyw)a  Secure and upgrade a raw outbound connection to a multiplexed network connection Parameters ---------- raw_conn : IRawConnection The raw connection to upgrade. peer_id : ID The peer to which this connection is established. Returns ------- INetConn The upgraded, secure, and multiplexed network connection. Raises ------ SwarmException If upgrading security or multiplexing the connection fails. Nr,r.r:rLs r/upgrade_outbound_raw_connz"INetwork.upgrade_outbound_raw_connPrUrVr"c Kyw)a4 Secure and upgrade a raw inbound connection to a multiplexed network connection Parameters ---------- raw_conn : IRawConnection The incoming raw connection to upgrade. maddr : Multiaddr The multiaddress on which the connection was received. Returns ------- IMuxedConn The upgraded, secure, and multiplexed network connection. Raises ------ SwarmException If upgrading security or multiplexing the connection fails. Nr,r.r:r"s r/upgrade_inbound_raw_connz!INetwork.upgrade_inbound_raw_connjrUrVstream_handlercy)z Set the stream handler for incoming streams. Parameters ---------- stream_handler : StreamHandlerFn The handler function to process incoming streams. Nr,)r.rAs r/set_stream_handlerzINetwork.set_stream_handlerrAr1 multiaddrsc Kyw)aT Start listening on one or more multiaddresses. Parameters ---------- multiaddrs : Sequence[Multiaddr] One or more multiaddresses on which to start listening. Returns ------- bool True if at least one listener started successfully, otherwise False. Nr,)r.rDs r/r%zINetwork.listenrUrVcy)z Register a notifee instance to receive network events. Parameters ---------- notifee : INotifee An object implementing the INotifee interface. Nr,r.notifees r/register_notifeezINetwork.register_notifeerAr1cy)z Unregister a notifee instance so it stops receiving network events. Parameters ---------- notifee : INotifee The notifee previously passed to ``register_notifee``. Nr,rGs r/remove_notifeezINetwork.remove_notifeerAr1c Kyw)zQ Close the network and all associated connections and listeners. Nr,r-s r/rXzINetwork.closerUrVc Kyw)z Close the connection to the specified peer. Parameters ---------- peer_id : ID The identifier of the peer whose connection should be closed. Nr,rs r/ close_peerzINetwork.close_peerrUrVN)rHINotifeer*Nrd)!r6r7r8r9rr;dictrr<rrr!rr0r2r4r6r8r}rr(r=rrKr@rrCr:r%rIrKrXrNr,r1r/r+r+s"b$x.())CN##  R     rDy DN  "  T"d8n*<%=     b X_   r d8n  *  z   & 13   2 & /8   2    T      d                t    r1r+cJeZdZUdZeed<eed<eed<eed<edzed<y)CMInfou  Unified snapshot of connection manager state. Equivalent to go-libp2p's connmgr.CMInfo snapshot returned by BasicConnMgr.GetInfo() — providing a single call-site for all watermark / live-count / grace / last-trim data needed by operators and metrics exporters. Attributes ---------- low_watermark : int Target connection count after pruning. high_watermark : int Connection count that triggers pruning. connected_count : int Current number of live connections. grace_period : float Seconds a new connection is exempt from pruning. last_trim : float | None Unix timestamp of the most recent prune cycle, or None if the connection count has never exceeded the high watermark. low_watermarkhigh_watermarkconnected_count grace_periodN last_trim)r6r7r8r9ryr;rr,r1r/rSrSs+0t|r1rSc eZdZUdZeed<edefdZede e effdZ ede de dedd fd Z ede de dd fd Zede defd Zede de dd fd Zede de defdZedde de defdZedefdZy )INetworkServicez Interface for a network service with connection management capabilities. Extends INetwork with go-libp2p style connection manager methods. connection_gater*cy)z Get total number of connections (inbound + outbound). Returns ------- int Total number of active connections. Nr,r-s r/get_total_connectionsz%INetworkService.get_total_connectionsrAr1cy)z Get connection metrics (go-libp2p style). Returns ------- dict[str, int] Connection metrics including total, inbound, and outbound counts. Nr,r-s r/ get_metricszINetworkService.get_metricsrAr1rLtagvalueNcy)a Tag a peer with a string, associating a weight with the tag. Parameters ---------- peer_id : ID The peer to tag. tag : str The tag name. value : int The weight/value associated with the tag. Nr,)r.rLr`ras r/tag_peerzINetworkService.tag_peerrAr1cy)z Remove the tagged value from the peer. Parameters ---------- peer_id : ID The peer to untag. tag : str The tag name to remove. Nr,r.rLr`s r/ untag_peerzINetworkService.untag_peerrAr1cy)a Get the metadata associated with a peer. Parameters ---------- peer_id : ID The peer to get info for. Returns ------- Any The tag info for the peer, or None if no tags recorded. Nr,rs r/ get_tag_infozINetworkService.get_tag_info,rAr1cy)z Protect a peer from having its connection(s) pruned. Parameters ---------- peer_id : ID The peer to protect. tag : str Protection tag. Nr,res r/protectzINetworkService.protect=rAr1cy)aS Remove a protection that may have been placed on a peer. Parameters ---------- peer_id : ID The peer to unprotect. tag : str The protection tag to remove. Returns ------- bool True if the peer is still protected by other tags. Nr,res r/ unprotectzINetworkService.unprotectKrAr1cy)a8 Check if a peer is protected. Parameters ---------- peer_id : ID The peer to check. tag : str If provided, check if protected by this specific tag. Returns ------- bool True if the peer is protected. Nr,res r/ is_protectedzINetworkService.is_protected^rAr1cy)ur Return a unified snapshot of connection manager state. Provides a single call-site for watermarks, live connection count, grace period, and the timestamp of the last prune — matching go-libp2p's BasicConnMgr.GetInfo(). Returns ------- CMInfo Snapshot of current connection manager state. Nr,r-s r/get_conn_mgr_infoz!INetworkService.get_conn_mgr_infoqrAr1))r6r7r8r9rr;rryr]rQrr_rrcrfrhrjr:rlrnrSrpr,r1r/rZrZs\   s      T#s(^          S  T      "  3  4     B 3    r          # $  $ B S $  $  6    r1rZceZdZdZedddeddfdZedddeddfdZeddd eddfd Z eddd eddfd Z eddd e ddfd Z eddd e ddfdZ y)rPz Interface for a network service. Extends the INetwork interface with additional service management capabilities. networkr+streamr*Nc Kyw)z Called when a new stream is opened. Parameters ---------- network : INetwork The network instance on which the stream was opened. stream : INetStream The stream that was opened. Nr,r.rsrts r/ opened_streamzINotifee.opened_streamrUrVc Kyw)z Called when a stream is closed. Parameters ---------- network : INetwork The network instance on which the stream was closed. stream : INetStream The stream that was closed. Nr,rvs r/ closed_streamzINotifee.closed_streamrUrVrNc Kyw)a  Called when a new connection is established. Parameters ---------- network : INetwork The network instance where the connection was established. conn : INetConn The connection that was opened. Nr,r.rsrNs r/ connectedzINotifee.connectedrUrVc Kyw)z Called when a connection is closed. Parameters ---------- network : INetwork The network instance where the connection was closed. conn : INetConn The connection that was closed. Nr,r{s r/ disconnectedzINotifee.disconnectedrUrV multiaddrc Kyw)a# Called when a listener starts on a multiaddress. Parameters ---------- network : INetwork The network instance where the listener is active. multiaddr : Multiaddr The multiaddress on which the listener is listening. Nr,r.rsrs r/r%zINotifee.listenrUrVc Kyw)a. Called when a listener stops listening on a multiaddress. Parameters ---------- network : INetwork The network instance where the listener was active. multiaddr : Multiaddr The multiaddress that is no longer being listened on. Nr,rs r/ listen_closezINotifee.listen_closerUrV)r6r7r8r9rr}rwryrr|r~rr%rr,r1r/rPrPs  :  z  d      :  z  d      z    d      *  H        J  9        *    t    r1rPc eZdZdZedefdZedefdZede fdZ ede fdZ ed&dZ edeefdZedeefd Zedefd Zeed'd Zedeefd Zedeefd Zeej2ddeedededfdZedededdfdZ ededdfdZ!edejDedzfdZ#ed(dZ$ed)de%dzddfdZ&ededeede'fdZ(ede)ddfdZ*ededdfd Z+ed*d!Z,ed"e-dede.fd#Z/ed"e-d$ede0fd%Z1y)+IHostz Interface for the host. Provides methods for retrieving host information, managing connections and streams, and running the host. r*cy)z Retrieve the host's peer identifier. Returns ------- ID The host's peer identifier. Nr,r-s r/get_idz IHost.get_idrAr1cy)z Retrieve the public key of the host. Returns ------- PublicKey The public key belonging to the host. Nr,r-s r/get_public_keyzIHost.get_public_keyrAr1cy)z Retrieve the private key of the host. Returns ------- PrivateKey The private key belonging to the host. Nr,r-s r/get_private_keyzIHost.get_private_keyrAr1cy)z Retrieve the network service instance associated with the host. Returns ------- INetworkService The network instance of the host. Nr,r-s r/ get_networkzIHost.get_networkrAr1cy)z Retrieve the muxer instance for the host. Returns ------- Any The muxer instance of the host. Nr,r-s r/get_muxz IHost.get_muxrAr1cy)a Return the addresses this host advertises to other peers. These may differ from the actual listen addresses when ``announce_addrs`` is configured. Each address includes a ``/p2p/{peer_id}`` suffix. Returns ------- list[Multiaddr] A list of advertised multiaddresses, each with a ``/p2p/{peer_id}`` suffix. Nr,r-s r/r'zIHost.get_addrs+rAr1cy)z Retrieve the raw multiaddr addresses this host is listening to, without the /p2p/{peer_id} suffix. Returns ------- list[Multiaddr] A list of raw multiaddresses. Nr,r-s r/get_transport_addrszIHost.get_transport_addrs;rAr1cy)z4 :return: the peerstore of the host Nr,r-s r/ get_peerstorezIHost.get_peerstoreHrAr1cy)u Return the connection manager (TagStore) for this host. Provides access to tag_peer, untag_peer, upsert_tag, protect, unprotect, and is_protected without going through the network layer — matching go-libp2p's h.ConnManager(). Returns ------- TagStore The tag store managing peer priorities and protections. Nr,r-s r/ conn_managerzIHost.conn_managerNrAr1cy)z Retrieve the identifiers of peers currently connected to the host. Returns ------- list[ID] A list of peer identifiers. Nr,r-s r/get_connected_peerszIHost.get_connected_peers_rAr1cy)zH :return: List of peer IDs that have active connections Nr,r-s r/get_live_peerszIHost.get_live_peerskrAr1) task_status listen_addrsrNcy)aL Run the host and start listening on the specified multiaddresses. Parameters ---------- listen_addrs : Sequence[Multiaddr] A sequence of multiaddresses on which the host should listen. task_status : Any Task status for trio nursery compatibility (ignored). Nr,)r.rrs r/runz IHost.runqrAr1rrAcy)a  Set the stream handler for the specified protocol. Parameters ---------- protocol_id : TProtocol The protocol identifier used on the stream. stream_handler : StreamHandlerFn The stream handler function to be set. Nr,)r.rrAs r/rCzIHost.set_stream_handlerrAr1cy)z Remove the stream handler for the specified protocol. Parameters ---------- protocol_id : TProtocol The protocol identifier to remove the handler for. Nr,rs r/remove_stream_handlerzIHost.remove_stream_handlerrAr1cy)zP Returns the recving end of the channel, used for metric events Nr,r-s r/get_metrics_recv_channelzIHost.get_metrics_recv_channelrAr1cy)ai Return the host's event bus (INotifee-style listener fan-out). Modules emit typed events on the bus whenever something happens; any number of listeners can register to be notified (the Prometheus metrics exporter being one). Returns ------- EventBus The host's event bus instance. Nr,r-s r/ get_event_buszIHost.get_event_busrAr1 public_ipc Kyw)zS Initiate the ACME-AUTO-TLS-BROKER negotiation for TLS certificate Nr,)r.rs r/initiate_autotls_procedurez IHost.initiate_autotls_procedurerUrVrL protocol_idsc Kyw)a Create a new stream to the specified peer. Parameters ---------- peer_id : ID The identifier of the peer to connect. protocol_ids : Sequence[TProtocol] A sequence of available protocol identifiers to use for the stream. Returns ------- INetStream The newly created network stream. Nr,)r.rLrs r/rzIHost.new_streamrUrVrc Kyw)a0 Establish a connection to the specified peer. This method ensures there is a connection between the host and the peer represented by the provided peer information. It also absorbs the addresses from ``peer_info`` into the host's internal peerstore. If no active connection exists, the host will dial the peer and block until a connection is established or an error occurs. Parameters ---------- peer_info : PeerInfo The peer information of the peer to connect to. Nr,)r.rs r/connectz IHost.connectrUrVc Kyw)z Disconnect from the specified peer. Parameters ---------- peer_id : ID The identifier of the peer to disconnect from. Nr,rs r/ disconnectzIHost.disconnectrUrVc Kyw)zN Close the host and all underlying connections and services. Nr,r-s r/rXz IHost.closerUrVr:c Kyw)a Upgrade a raw outbound connection to a fully secure and multiplexed network connection for the specified peer. Parameters ---------- raw_conn : IRawConnection The raw (unencrypted/unmultiplexed) connection to upgrade. peer_id : ID The ID of the peer this connection is being established to. Returns ------- INetConn The upgraded and authenticated network connection with security and multiplexing. Raises ------ SwarmException If the upgrade process (security handshake or multiplexer negotiation) fails Nr,r<s r/upgrade_outbound_connectionz!IHost.upgrade_outbound_connectionrUrVr"c Kyw)ac Upgrade a raw inbound connection to a fully secure and multiplexed network connection for the given multiaddress. Parameters ---------- raw_conn : IRawConnection The inbound raw connection to upgrade. maddr : Multiaddr The multiaddress this connection arrived on. Returns ------- IMuxedConn The upgraded and authenticated inbound muxed connection. Raises ------ SwarmException If the upgrade process (security handshake or multiplexer negotiation) fails Nr,r?s r/upgrade_inbound_connectionz IHost.upgrade_inbound_connection rUrV)r*r#)r*r )r*rrOrd)2r6r7r8r9rrrrrrrrZrrr<rr'rrrrirrrrgTASK_STATUS_IGNOREDr rr rrrrCrMemoryReceiveChannelrrrrr}rrrrrXr(rrrKrr,r1r/rrs                   _          4 ?      T)_     z        T"X     R    33  y)   %T *   $  $  6E          t     $*C*CC*H4*O       #* PT    )1))<   ( x D  "    t       & 13   6 & /8   r1rceZdZdZedefdZedefdZede jfdZ edefdZ ede defdZy ) IPeerRecorda Interface for a libp2p PeerRecord object. A PeerRecord contains metadata about a peer such as its ID, public addresses, and a strictly increasing sequence number for versioning. PeerRecords are used in signed routing Envelopes for secure peer data propagation. r*cy)z Return the domain string for this record type. Used in envelope validation to distinguish different record types. Nr,r-s r/domainzIPeerRecord.domain; rAr1cy)z Return a binary codec prefix that identifies the PeerRecord type. This is prepended in signed envelopes to allow type-safe decoding. Nr,r-s r/codeczIPeerRecord.codecC rAr1cy)z Convert this PeerRecord into its Protobuf representation. :raises ValueError: if serialization fails (e.g., invalid peer ID). :return: A populated protobuf `PeerRecord` message. Nr,r-s r/ to_protobufzIPeerRecord.to_protobufK rAr1cy)z Serialize this PeerRecord into a byte string. Used when signing or sealing the record in an envelope. :raises ValueError: if protobuf serialization fails. :return: Byte-encoded PeerRecord. Nr,r-s r/marshal_recordzIPeerRecord.marshal_recordT rAr1othercy)aY Compare this PeerRecord with another for equality. Two PeerRecords are considered equal if: - They have the same `peer_id` - Their `seq` numbers match - Their address lists are identical and ordered :param other: Object to compare with. :return: True if equal, False otherwise. Nr,r.rs r/equalzIPeerRecord.equal_ rAr1N)r6r7r8r9rrrbytesrpbr"rrobjectr:rr,r1r/rr1 s    u   R]]       6  d    r1rcheZdZedefdZededdfdZed dZede de fdZ y) IEnveloper*cy)z Serialize this Envelope into its protobuf wire format. Converts all envelope fields into a `pb.Envelope` protobuf message and returns the serialized bytes. :return: Serialized envelope as bytes. Nr,r-s r/marshal_envelopezIEnvelope.marshal_envelopep rAr1rNcy)aM Verify the envelope's signature within the given domain scope. This ensures that the envelope has not been tampered with and was signed under the correct usage context. :param domain: Domain string that contextualizes the signature. :raises ValueError: If the signature is invalid. Nr,)r.rs r/validatezIEnvelope.validate{ rAr1cy)a{ Lazily decode and return the embedded PeerRecord. This method unmarshals the payload bytes into a `PeerRecord` instance, using the registered codec to identify the type. The decoded result is cached for future use. :return: Decoded PeerRecord object. :raises Exception: If decoding fails or payload type is unsupported. Nr,r-s r/recordzIEnvelope.record rAr1rcy)ad Compare this Envelope with another for structural equality. Two envelopes are considered equal if: - They have the same public key - The payload type and payload bytes match - Their signatures are identical :param other: Another object to compare. :return: True if equal, False otherwise. Nr,rs r/rzIEnvelope.equal rAr1)r*r") r6r7r8rrrrrrrr:rr,r1r/rro ss %    s  t          3  4    r1rceZdZdZedeefdZedeeddfdZ edeeddfdZ edeeddfdZ edeedeefd Z edeedefd Z ed&d Zed eeddfd ZedeefdZed&dZedededdfdZededefdZed&dZededdfdZedefdZededdfdZedefdZed&dZededdfdZedefdZ ed&dZ!ed&d Z"ede#fd!Z$ede#fd"Z%ed#e#ddfd$Z&ede'fd%Z(y)' IPeerDataz Interface for managing peer data. Provides methods for handling protocols, addresses, metadata, and keys associated with a peer. r*cy)z Retrieve all protocols associated with the peer. Returns ------- list[str] A list of protocols associated with the peer. Nr,r-s r/rzIPeerData.get_protocols rAr1rNcy)z Add one or more protocols to the peer's data. Parameters ---------- protocols : Sequence[str] A sequence of protocols to add. Nr,r.rs r/rzIPeerData.add_protocols rAr1cy)z Set the protocols for the peer. Parameters ---------- protocols : Sequence[str] A sequence of protocols to set. Nr,rs r/rzIPeerData.set_protocols rAr1cy)z Removes the specified protocols from this peer's list of supported protocols. Parameters ---------- protocols : Sequence[str] A sequence of protocol strings to be removed. Nr,rs r/rzIPeerData.remove_protocols rAr1cy)a Returns the list of protocols from the input sequence that are supported by this peer. Parameters ---------- protocols : Sequence[str] A sequence of protocol strings to check against this peer's supported protocols. Returns ------- list[str] A list of protocol strings that are supported. Nr,rs r/rzIPeerData.supports_protocols rAr1cy)ad Returns the first protocol from the input list that this peer supports. Parameters ---------- protocols : Sequence[str] A sequence of protocol strings to check for support. Returns ------- str The first matching protocol, or an empty string if none are supported. Nr,rs r/rz"IPeerData.first_supported_protocol rAr1cy)zE Clears all protocol data associated with this peer. Nr,r-s r/rzIPeerData.clear_protocol_data rAr1rcy)z Add multiple multiaddresses to the peer's data. Parameters ---------- addrs : Sequence[Multiaddr] A sequence of multiaddresses to add. ttl: inr Time to live for the peer record Nr,)r.rs r/rzIPeerData.add_addrs rAr1cy)z Retrieve all multiaddresses associated with the peer. Returns ------- list[Multiaddr] A list of multiaddresses. Nr,r-s r/r'zIPeerData.get_addrs rAr1cy)z@ Clear all addresses associated with the peer. Nr,r-s r/rzIPeerData.clear_addrs" rAr1rrcy)z Store a metadata key-value pair for the peer. Parameters ---------- key : str The metadata key. val : MetadataValue The value to associate with the key. Nr,)r.rrs r/ put_metadatazIPeerData.put_metadata) rAr1cy)aO Retrieve metadata for a given key. Parameters ---------- key : str The metadata key. Returns ------- MetadataValue The metadata value for the given key. Raises ------ PeerDataError If the key is not found. Nr,)r.rs r/ get_metadatazIPeerData.get_metadata7 rAr1cy)zH Clears all metadata entries associated with this peer. Nr,r-s r/rzIPeerData.clear_metadataM rAr1rcy)z Add a public key to the peer's data. Parameters ---------- pubkey : PublicKey The public key to add. Nr,)r.rs r/rzIPeerData.add_pubkeyS rAr1cy)z Retrieve the public key for the peer. Returns ------- PublicKey The public key of the peer. Raises ------ PeerDataError If the public key is not found. Nr,r-s r/ get_pubkeyzIPeerData.get_pubkey_ rAr1rcy)z Add a private key to the peer's data. Parameters ---------- privkey : PrivateKey The private key to add. Nr,)r.rs r/rzIPeerData.add_privkeyp rAr1cy)z Retrieve the private key for the peer. Returns ------- PrivateKey The private key of the peer. Raises ------ PeerDataError If the private key is not found. Nr,r-s r/ get_privkeyzIPeerData.get_privkey| rAr1cy)z~ Clears all cryptographic key data associated with this peer, including both public and private keys. Nr,r-s r/rzIPeerData.clear_keydata rAr1 new_latencycy)a! Records a new latency measurement using Exponentially Weighted Moving Average (EWMA). Parameters ---------- new_latency : float The new round-trip time (RTT) latency value to incorporate into the EWMA calculation. Nr,)r.rs r/rzIPeerData.record_latency rAr1cy)z Returns the current EWMA value of the recorded latency. Returns ------- float The current latency estimate based on EWMA. Nr,r-s r/rzIPeerData.latency_EWMA rAr1cy)zS Clears all latency-related metrics and resets the internal state. Nr,r-s r/rzIPeerData.clear_metrics rAr1cy)z4 Updates timestamp to current time. Nr,r-s r/update_last_identifiedz IPeerData.update_last_identified rAr1cy)z Fetch the last identified timestamp Returns ------- last_identified_timestamp The lastIdentified time of peer. Nr,r-s r/get_last_identifiedzIPeerData.get_last_identified rAr1cy)z Get ttl value for the peer for validity check Returns ------- int The ttl of the peer. Nr,r-s r/get_ttlzIPeerData.get_ttl rAr1rncy)z Set ttl value for the peer for validity check Parameters ---------- ttl : int The ttl for the peer. Nr,rps r/set_ttlzIPeerData.set_ttl rAr1cy)z Check if the peer is expired based on last_identified and ttl Returns ------- bool True, if last_identified + ttl > current_time Nr,r-s r/ is_expiredzIPeerData.is_expired rAr1rd))r6r7r8r9rr<rrr rrrrrrrrr'rrrrrrrrrrrrrrrrrryrrrr:rr,r1r/rr s  tCy      x}        x}        (3-  D     HSM d3i  $ (3- C      x 2  t      4 ?          -  D        *      t     I    :  $     Z      %  D      e          S            3  4      D    r1rc@eZdZdZededdfdZedefdZy)IMultiselectCommunicatorz Communicator helper for multiselect. Ensures that both the client and multistream module follow the same multistream protocol. msg_strr*Nc Kyw)z Write a message to the stream. Parameters ---------- msg_str : str The message string to write. Nr,)r.rs r/writezIMultiselectCommunicator.write rUrVc Kyw)z Read a message from the stream until EOF. Returns ------- str The message read from the stream. Nr,r-s r/readzIMultiselectCommunicator.read rUrV)r6r7r8r9rrrrr,r1r/rr sD  3  4      C    r1rcleZdZdZededdfdZedeededefdZ edededefd Z y) IMultiselectClientz Client for multiselect negotiation. Communicates with the receiver's multiselect module to select a protocol for communication. communicatorr*Nc Kyw)a Ensure that the client and multiselect module are using the same multiselect protocol. Parameters ---------- communicator : IMultiselectCommunicator The communicator used for negotiating the multiselect protocol. Raises ------ Exception If there is a multiselect protocol ID mismatch. Nr,r.rs r/ handshakezIMultiselectClient.handshake rUrVrc Kyw)a Select one protocol from a sequence by communicating with the multiselect module. For each protocol in the provided sequence, the client sends a selection message and expects the multiselect module to confirm the protocol. The first confirmed protocol is returned. Parameters ---------- protocols : Sequence[TProtocol] The protocols to attempt selection. communicator : IMultiselectCommunicator The communicator used for negotiating the protocol. Returns ------- TProtocol The protocol selected by the multiselect module. Nr,)r.rrs r/ select_one_ofz IMultiselectClient.select_one_of, rUrVprotocolc Kyw)a Attempt to select the given protocol. Parameters ---------- communicator : IMultiselectCommunicator The communicator used to interact with the counterparty. protocol : TProtocol The protocol to select. Returns ------- TProtocol The protocol if successfully selected. Raises ------ Exception If protocol selection fails. Nr,)r.rrs r/ try_selectzIMultiselectClient.try_selectF rUrV) r6r7r8r9rrrr rrrr,r1r/rr s ,D   " !), rVc Kyw)a Wait until a specific peer has subscribed to a topic. This method blocks until the given peer appears in the peer_topics map for the specified topic, indicating that they have sent a subscription message. Use this instead of arbitrary trio.sleep() calls to avoid race conditions. The implementation uses an event-based approach with :class:`trio.Event` so the task consumes zero CPU while waiting. Parameters ---------- peer_id : ID The identifier of the peer to wait for. topic_id : str The topic to check subscription for. timeout : float Maximum time to wait in seconds. Defaults to 5.0. Raises ------ trio.TooSlowError If the peer does not subscribe within the timeout period. Example:: await connect(host1, host2) await pubsub1.wait_for_subscription(host2.get_id(), "my-topic") # Now safe to assert subscription state Nr,)r.rLrmrts r/wait_for_subscriptionzIPubsub.wait_for_subscriptions H rVrd)g@)r6r7r8r9rirrr`rrrrrrdrr:rhrjrlr5rpr7r<rrPrrvrxr,r1r/r^r^\ s  r      5C0      8C=      %0 FJ   $  C  D        0@  "  #  $      cDIo  U  t     2    @;># # %(# 38# # # r1r^c reZdZdZed dZed dZedefdZede de d e de e fd Z y) IPerfzv Interface for the perf protocol service. Spec: https://github.com/libp2p/specs/blob/master/perf/perf.md r*Nc Kyw)z9Start the perf service and register the protocol handler.Nr,r-s r/rTz IPerf.start6  rVc Kyw)z:Stop the perf service and unregister the protocol handler.Nr,r-s r/stopz IPerf.stop;r|rVcy)z*Check if the service is currently running.Nr,r-s r/ is_startedzIPerf.is_started@s r1r send_bytes recv_bytescy)a Measure transfer performance to a remote peer. Parameters ---------- multiaddr : Multiaddr The address of the remote peer to test against. send_bytes : int Number of bytes to upload to the remote peer. recv_bytes : int Number of bytes to request the remote peer to send back. Yields ------ PerfOutput Progress reports during the transfer, with a final summary at the end. Nr,)r.rrrs r/measure_performancezIPerf.measure_performanceEs2 r1rd)r6r7r8r9rrTr~r:rrryrrrr,r1r/rzrz/s      D       s    r1rz)aabcrrcollections.abcrrrrr contextlibr dataclassesr typesr typingr rrrrrrglibp2p.connection_typesrlibp2p.crypto.keysrrrlibp2p.custom_typesrrrrrlibp2p.events.busr libp2p.io.abcrrlibp2p.peer.idrlibp2p.peer.pb.peer_record_pb2peerrpeer_record_pb2libp2p.peer.peerinforlibp2p.network.tag_storer libp2p.peer.enveloper!libp2p.peer.peer_recordr"!libp2p.protocol_muxer.multiselectr#libp2p.pubsub.pubsubr$libp2p.pubsub.pbr%libp2p.tools.anyio_service.apir&r(r>rIrKrfr}rrrrrrrrr!r+rSrZrPrrrrrrr rrr"r(r:r5r<r^rzr,r1r/rs3!  ',+1-2=6  _ J ' ' T$nh h V-?$7$G-f& & X; v; B' C' ZT T p= = FW sW z. s. ho o jXL90(HjXL|1 1 nq sq h  @R h R p[ s[ BG CG V : #: |1 1 nB B P  s HL L dF F X) c) X 3 85 s5 vo o j *+]7??-K @Q CQ hM jM f/ C/ r1