varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2025-12-31 20:36:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

WIP CI Build Errors (#76)

Browse Source 
* ignore TODO and kademlia

* remove unnecessary pass

* fixed swarm warnings

* fixed peerdata_interface warnings

* fixed peer warnings

* fixed rest of linting errors

* trying to fix last error

* fixed dup errors
This commit is contained in:
ZX
2018-11-26 18:24:29 -05:00
committed by Alex Haynes
parent 8326f87835
commit 8bcffb67cb
30 changed files with 39 additions and 96 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
tests/libp2p/test_libp2p.py
View File

@ -1,11 +1,11 @@
import pytest
from libp2p.libp2p import *
from libp2p.libp2p import new_node
@pytest.mark.asyncio
async def test_simple_messages():
hostA = await new_node(transport_opt=["/ip4/127.0.0.1/tcp/8001/ipfs/hostA"])
hostB = await new_node(transport_opt=["/ip4/127.0.0.1/tcp/8000/ipfs/hostB"])
node_a = await new_node(transport_opt=["/ip4/127.0.0.1/tcp/8001/ipfs/node_a"])
node_b = await new_node(transport_opt=["/ip4/127.0.0.1/tcp/8000/ipfs/node_b"])
async def stream_handler(stream):
while True:
@ -16,12 +16,12 @@ async def test_simple_messages():
print("sending response:" + response)
await stream.write(response.encode())
hostB.set_stream_handler("/echo/1.0.0", stream_handler)
node_b.set_stream_handler("/echo/1.0.0", stream_handler)
# Associate the peer with local ip address (see default parameters of Libp2p())
hostA.get_peerstore().add_addr("hostB", "/ip4/127.0.0.1/tcp/8000", 10)
node_a.get_peerstore().add_addr("node_b", "/ip4/127.0.0.1/tcp/8000", 10)
stream = await hostA.new_stream("hostB", "/echo/1.0.0")
stream = await node_a.new_stream("node_b", "/echo/1.0.0")
messages = ["hello" + str(x) for x in range(10)]
for message in messages: