varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-12 16:10:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename InsecureSession initiator flag

Browse Source
This commit is contained in:
Dominik Muhs
2019-10-24 19:18:29 +02:00
parent 18783b82a2
commit 7ad96d167c
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
libp2p/security/insecure/transport.py
View File

@ -29,10 +29,10 @@ class InsecureSession(BaseSession):
local_peer: ID, local_peer: ID,
local_private_key: PrivateKey, local_private_key: PrivateKey,
conn: ReadWriteCloser, conn: ReadWriteCloser,
initiator: bool, is_initiator: bool,
peer_id: Optional[ID] = None, peer_id: Optional[ID] = None,
) -> None: ) -> None:
super().__init__(local_peer, local_private_key, initiator, peer_id) super().__init__(local_peer, local_private_key, is_initiator, peer_id)
self.conn = conn self.conn = conn
async def write(self, data: bytes) -> int: async def write(self, data: bytes) -> int:
@ -68,7 +68,7 @@ class InsecureSession(BaseSession):
# Verify if the receive `ID` matches the one we originally initialize the session. # Verify if the receive `ID` matches the one we originally initialize the session.
# We only need to check it when we are the initiator, because only in that condition # We only need to check it when we are the initiator, because only in that condition
# we possibly knows the `ID` of the remote. # we possibly knows the `ID` of the remote.
if self.initiator and self.remote_peer_id != received_peer_id: if self.is_initiator and self.remote_peer_id != received_peer_id:
raise HandshakeFailure( raise HandshakeFailure(
"remote peer sent unexpected peer ID. " "remote peer sent unexpected peer ID. "
f"expected={self.remote_peer_id} received={received_peer_id}" f"expected={self.remote_peer_id} received={received_peer_id}"
@ -97,7 +97,7 @@ class InsecureSession(BaseSession):
self.remote_permanent_pubkey = received_pubkey self.remote_permanent_pubkey = received_pubkey
# Only need to set peer's id when we don't know it before, # Only need to set peer's id when we don't know it before,
# i.e. we are not the connection initiator. # i.e. we are not the connection initiator.
if not self.initiator: if not self.is_initiator:
self.remote_peer_id = received_peer_id self.remote_peer_id = received_peer_id
# TODO: Store `pubkey` and `peer_id` to `PeerStore` # TODO: Store `pubkey` and `peer_id` to `PeerStore`