From 28dc8421030d4cb34aa8dd44ee1ec5e4bfd5383d Mon Sep 17 00:00:00 2001 From: Stuckinaboot Date: Wed, 10 Apr 2019 20:01:53 -0400 Subject: [PATCH] Save working code --- examples/chat/chat.py | 3 +-- examples/sharding/most_basic_connect/driver.py | 12 +++++++++--- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/examples/chat/chat.py b/examples/chat/chat.py index 9543174..49cdd29 100755 --- a/examples/chat/chat.py +++ b/examples/chat/chat.py @@ -31,8 +31,7 @@ async def write_data(stream): async def run(port, destination): - external_ip = urllib.request.urlopen( - 'https://v4.ident.me/').read().decode('utf8') + external_ip = "192.168.1.39" transport_opt_str = "/ip4/%s/tcp/%s" % (external_ip, port) host = await new_node( transport_opt=[transport_opt_str]) diff --git a/examples/sharding/most_basic_connect/driver.py b/examples/sharding/most_basic_connect/driver.py index 9ddb05a..f464110 100644 --- a/examples/sharding/most_basic_connect/driver.py +++ b/examples/sharding/most_basic_connect/driver.py @@ -41,10 +41,16 @@ async def main(): # Convert neighbor_addr_str to multiaddr neighbor_addr = multiaddr.Multiaddr(neighbor_addr_str) + print("Connecting") await connect(node.libp2p_node, neighbor_addr) - await asyncio.sleep(5) + print("Creating new stream") + s = await node.libp2p_node.new_stream(id_opt, ["/foo/1"]) + await s.write("foo".encode()) + await asyncio.sleep(15) if __name__ == "__main__": loop = asyncio.get_event_loop() - loop.run_until_complete(main()) - loop.close() \ No newline at end of file + # loop.run_until_complete(main()) + asyncio.ensure_future(main()) + loop.run_forever() + # loop.close()