StarMirror/py-libp2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Opt-out of linting on the special cases we have, given new ignore rules

Browse Source
This commit is contained in:
Alex Stokes 2019-08-03 12:45:55 -07:00 committed by Kevin Mai-Husan Chia
parent 03b1304fe7
commit cb301fcc51
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
examples/chat/chat.py
View File

@ -53,9 +53,10 @@ async def run(port, destination, localhost):
print( print(
f"Run 'python ./examples/chat/chat.py" f"Run 'python ./examples/chat/chat.py"
+ localhost_opt + localhost_opt
+ f" -p {int(port) + 1} -d /ip4/{ip}/tcp/{port}/p2p/{host.get_id().pretty()}' on another console.\n" + f" -p {int(port) + 1} -d /ip4/{ip}/tcp/{port}/p2p/{host.get_id().pretty()}'"
+ " on another console."
) )
print("\nWaiting for incoming connection\n\n") print("Waiting for incoming connection...")
else: # its the client else: # its the client
maddr = multiaddr.Multiaddr(destination) maddr = multiaddr.Multiaddr(destination)

2
libp2p/pubsub/pubsub.py
View File

@ -143,7 +143,7 @@ class Pubsub:
# NOTE: Check if `rpc_incoming.control` is set through `HasField`. # NOTE: Check if `rpc_incoming.control` is set through `HasField`.
# This is necessary because `control` is an optional field in pb2. # This is necessary because `control` is an optional field in pb2.
# Ref: https://developers.google.com/protocol-buffers/docs/reference/python-generated#singular-fields-proto2 # Ref: https://developers.google.com/protocol-buffers/docs/reference/python-generated#singular-fields-proto2 # noqa: E501
if rpc_incoming.HasField("control"): if rpc_incoming.HasField("control"):
# Pass rpc to router so router could perform custom logic # Pass rpc to router so router could perform custom logic
await self.router.handle_rpc(rpc_incoming, peer_id) await self.router.handle_rpc(rpc_incoming, peer_id)

5
tests/peer/test_peerinfo.py
View File

@ -8,6 +8,7 @@ from libp2p.peer.peerdata import PeerData
from libp2p.peer.peerinfo import InvalidAddrError, PeerInfo, info_from_p2p_addr from libp2p.peer.peerinfo import InvalidAddrError, PeerInfo, info_from_p2p_addr
ALPHABETS = "123456789ABCDEFGHJKLMNPQRSTUVWXYZabcdefghijkmnopqrstuvwxyz" ALPHABETS = "123456789ABCDEFGHJKLMNPQRSTUVWXYZabcdefghijkmnopqrstuvwxyz"
VALID_MULTI_ADDR_STR = "/ip4/127.0.0.1/tcp/8000/p2p/3YgLAeMKSAPcGqZkAt8mREqhQXmJT8SN8VCMN4T6ih4GNX9wvK8mWJnWZ1qA2mLdCQ" # noqa: E501
def test_init_(): def test_init_():
@ -47,9 +48,7 @@ def test_info_from_p2p_addr_invalid(addr):
def test_info_from_p2p_addr_valid(): def test_info_from_p2p_addr_valid():
m_addr = multiaddr.Multiaddr( m_addr = multiaddr.Multiaddr(VALID_MULTI_ADDR_STR)
"/ip4/127.0.0.1/tcp/8000/p2p/3YgLAeMKSAPcGqZkAt8mREqhQXmJT8SN8VCMN4T6ih4GNX9wvK8mWJnWZ1qA2mLdCQ"
)
info = info_from_p2p_addr(m_addr) info = info_from_p2p_addr(m_addr)
assert ( assert (
info.peer_id.pretty() info.peer_id.pretty()