mirror of
https://github.com/varun-r-mallya/py-libp2p.git
synced 2026-02-12 16:10:57 +00:00
Clean up old comments, print stmts, formatting, etc.
This commit is contained in:
@ -17,8 +17,6 @@ async def test_example():
|
|||||||
await node_b.provide("hello")
|
await node_b.provide("hello")
|
||||||
|
|
||||||
providers = await node_b.get_providers("hello")
|
providers = await node_b.get_providers("hello")
|
||||||
# print ("providers")
|
|
||||||
# print (providers)
|
|
||||||
|
|
||||||
# bmuller's handle_call_response wraps
|
# bmuller's handle_call_response wraps
|
||||||
# every rpc call result in a list of tuples
|
# every rpc call result in a list of tuples
|
||||||
|
|||||||
@ -12,7 +12,6 @@ features are implemented in swarm
|
|||||||
import pytest
|
import pytest
|
||||||
import multiaddr
|
import multiaddr
|
||||||
|
|
||||||
|
|
||||||
from tests.utils import (
|
from tests.utils import (
|
||||||
cleanup,
|
cleanup,
|
||||||
echo_stream_handler,
|
echo_stream_handler,
|
||||||
|
|||||||
@ -21,10 +21,7 @@ async def perform_simple_test(
|
|||||||
async def stream_handler(stream):
|
async def stream_handler(stream):
|
||||||
while True:
|
while True:
|
||||||
read_string = (await stream.read()).decode()
|
read_string = (await stream.read()).decode()
|
||||||
print("host B received:" + read_string)
|
|
||||||
|
|
||||||
response = "ack:" + read_string
|
response = "ack:" + read_string
|
||||||
print("sending response:" + response)
|
|
||||||
await stream.write(response.encode())
|
await stream.write(response.encode())
|
||||||
|
|
||||||
for protocol in protocols_with_handlers:
|
for protocol in protocols_with_handlers:
|
||||||
@ -40,7 +37,6 @@ async def perform_simple_test(
|
|||||||
|
|
||||||
response = (await stream.read()).decode()
|
response = (await stream.read()).decode()
|
||||||
|
|
||||||
print("res: " + response)
|
|
||||||
assert response == ("ack:" + message)
|
assert response == ("ack:" + message)
|
||||||
|
|
||||||
assert expected_selected_protocol == stream.get_protocol()
|
assert expected_selected_protocol == stream.get_protocol()
|
||||||
|
|||||||
@ -19,8 +19,6 @@ async def test_simple_two_nodes():
|
|||||||
|
|
||||||
router = KadmeliaPeerRouter(node_b)
|
router = KadmeliaPeerRouter(node_b)
|
||||||
returned_info = await router.find_peer(ID(node_a_kad_peerinfo.peer_id_bytes))
|
returned_info = await router.find_peer(ID(node_a_kad_peerinfo.peer_id_bytes))
|
||||||
print(repr(returned_info))
|
|
||||||
print(repr(node_a_kad_peerinfo))
|
|
||||||
assert repr(returned_info) == repr(node_a_kad_peerinfo)
|
assert repr(returned_info) == repr(node_a_kad_peerinfo)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user