varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-09 22:50:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename secio initiator flags

Browse Source
This commit is contained in:
Dominik Muhs
2019-10-24 19:22:24 +02:00
parent 7ad96d167c
commit 021c92ea25
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
libp2p/security/secio/transport.py
View File

@ -61,9 +61,9 @@ class SecureSession(BaseSession):
remote_peer: PeerID, remote_peer: PeerID,
remote_encryption_parameters: AuthenticatedEncryptionParameters, remote_encryption_parameters: AuthenticatedEncryptionParameters,
conn: MsgIOReadWriter, conn: MsgIOReadWriter,
initiator: bool, is_initiator: bool,
) -> None: ) -> None:
super().__init__(local_peer, local_private_key, initiator, remote_peer) super().__init__(local_peer, local_private_key, is_initiator, remote_peer)
self.conn = conn self.conn = conn
self.local_encryption_parameters = local_encryption_parameters self.local_encryption_parameters = local_encryption_parameters
@ -371,7 +371,7 @@ def _mk_session_from(
local_private_key: PrivateKey, local_private_key: PrivateKey,
session_parameters: SessionParameters, session_parameters: SessionParameters,
conn: MsgIOReadWriter, conn: MsgIOReadWriter,
initiator: bool, is_initiator: bool,
) -> SecureSession: ) -> SecureSession:
key_set1, key_set2 = initialize_pair_for_encryption( key_set1, key_set2 = initialize_pair_for_encryption(
session_parameters.local_encryption_parameters.cipher_type, session_parameters.local_encryption_parameters.cipher_type,
@ -389,7 +389,7 @@ def _mk_session_from(
session_parameters.remote_peer, session_parameters.remote_peer,
key_set2, key_set2,
conn, conn,
initiator, is_initiator,
) )
return session return session
@ -425,8 +425,8 @@ async def create_secure_session(
except IOException: except IOException:
raise SecioException("connection closed") raise SecioException("connection closed")
initiator = remote_peer is not None is_initiator = remote_peer is not None
session = _mk_session_from(local_private_key, session_parameters, msg_io, initiator) session = _mk_session_from(local_private_key, session_parameters, msg_io, is_initiator)
try: try:
received_nonce = await _finish_handshake(session, remote_nonce) received_nonce = await _finish_handshake(session, remote_nonce)