libp2p.security.insecure package

Subpackages

• libp2p.security.insecure.pb package
  • Submodules
  • libp2p.security.insecure.pb.plaintext_pb2 module
  • Module contents

Submodules

libp2p.security.insecure.transport module

class libp2p.security.insecure.transport.InsecureSession(*, local_peer: libp2p.peer.id.ID, local_private_key: libp2p.crypto.keys.PrivateKey, remote_peer: libp2p.peer.id.ID, remote_permanent_pubkey: libp2p.crypto.keys.PublicKey, is_initiator: bool, conn: libp2p.io.abc.ReadWriteCloser)

Bases: libp2p.security.base_session.BaseSession

async close() → None

local_peer = None

local_private_key = None

async read(n: int = None) → bytes

remote_peer = None

remote_permanent_pubkey = None

async write(data: bytes) → None

class libp2p.security.insecure.transport.InsecureTransport(local_key_pair: libp2p.crypto.keys.KeyPair, secure_bytes_provider: Callable[[int], bytes] = <function default_secure_bytes_provider>)

Bases: libp2p.security.base_transport.BaseSecureTransport

InsecureTransport provides the “identity” upgrader for a IRawConnection, i.e. the upgraded transport does not add any additional security.

async secure_inbound(conn: libp2p.network.connection.raw_connection_interface.IRawConnection) → libp2p.security.secure_conn_interface.ISecureConn

Secure the connection, either locally or by communicating with opposing node via conn, for an inbound connection (i.e. we are not the initiator)

Returns

secure connection object (that implements secure_conn_interface)

async secure_outbound(conn: libp2p.network.connection.raw_connection_interface.IRawConnection, peer_id: libp2p.peer.id.ID) → libp2p.security.secure_conn_interface.ISecureConn

Secure the connection, either locally or by communicating with opposing node via conn, for an inbound connection (i.e. we are the initiator)

Returns

secure connection object (that implements secure_conn_interface)

class libp2p.security.insecure.transport.PlaintextHandshakeReadWriter(read_write_closer: libp2p.io.abc.ReadWriteCloser)

Bases: libp2p.io.msgio.VarIntLengthMsgReadWriter

max_msg_size: int = 65536

libp2p.security.insecure.transport.make_exchange_message(pubkey: libp2p.crypto.keys.PublicKey) → libp2p.security.insecure.pb.plaintext_pb2.Exchange

async libp2p.security.insecure.transport.run_handshake(local_peer: libp2p.peer.id.ID, local_private_key: libp2p.crypto.keys.PrivateKey, conn: libp2p.network.connection.raw_connection_interface.IRawConnection, is_initiator: bool, remote_peer_id: libp2p.peer.id.ID) → libp2p.security.secure_conn_interface.ISecureConn

Raise HandshakeFailure when handshake failed.

Module contents