diff --git a/libp2p/crypto/rsa.py b/libp2p/crypto/rsa.py index ec636cae..e40be45a 100644 --- a/libp2p/crypto/rsa.py +++ b/libp2p/crypto/rsa.py @@ -25,7 +25,7 @@ class RSAPublicKey(PublicKey): h = SHA256.new(data) try: # NOTE: the typing in ``pycryptodome`` is wrong on the arguments to ``verify``. - pkcs1_15.new(self.impl).verify(h, signature) # type: ignore + pkcs1_15.new(self.impl).verify(h, signature) except (ValueError, TypeError): return False return True @@ -49,7 +49,7 @@ class RSAPrivateKey(PrivateKey): def sign(self, data: bytes) -> bytes: h = SHA256.new(data) # NOTE: the typing in ``pycryptodome`` is wrong on the arguments to ``sign``. - return pkcs1_15.new(self.impl).sign(h) # type: ignore + return pkcs1_15.new(self.impl).sign(h) def get_public_key(self) -> PublicKey: return RSAPublicKey(self.impl.publickey()) diff --git a/libp2p/host/ping.py b/libp2p/host/ping.py index 01a34109..3144ef4d 100644 --- a/libp2p/host/ping.py +++ b/libp2p/host/ping.py @@ -25,18 +25,15 @@ async def _handle_ping(stream: INetStream, peer_id: PeerID) -> bool: logger.debug("Other side closed while waiting for ping from %s", peer_id) return False except StreamReset as error: - print("peer", peer_id, "ping reset") logger.debug( "Other side reset while waiting for ping from %s: %s", peer_id, error ) raise except Exception as error: - print("peer", peer_id, "ping", type(error)) logger.debug("Error while waiting to read ping for %s: %s", peer_id, error) raise logger.debug("Received ping from %s with data: 0x%s", peer_id, payload.hex()) - print("receive ping from", peer_id) try: await stream.write(payload) @@ -51,13 +48,11 @@ async def handle_ping(stream: INetStream) -> None: or closes the ``stream``.""" peer_id = stream.muxed_conn.peer_id - print("handling ping from", peer_id) while True: try: should_continue = await _handle_ping(stream, peer_id) if not should_continue: return except Exception: - print("error finish ping") await stream.reset() return