From 13fc699b360f56153822dd81221e284965eace8a Mon Sep 17 00:00:00 2001
From: Stuckinaboot <aspyn@seas.upenn.edu>
Date: Wed, 10 Apr 2019 17:56:10 -0400
Subject: [PATCH] Add driver that launches both nodes together

---
 .../most_basic_connect/driver_single.py       | 50 +++++++++++++++++++
 1 file changed, 50 insertions(+)
 create mode 100644 examples/sharding/most_basic_connect/driver_single.py

diff --git a/examples/sharding/most_basic_connect/driver_single.py b/examples/sharding/most_basic_connect/driver_single.py
new file mode 100644
index 0000000..262fab0
--- /dev/null
+++ b/examples/sharding/most_basic_connect/driver_single.py
@@ -0,0 +1,50 @@
+import asyncio
+import json 
+import multiaddr
+import sys
+import time
+from libp2p.peer.id import ID
+from node import Node
+from libp2p.peer.peerinfo import info_from_p2p_addr
+from tests.utils import cleanup
+from Crypto.PublicKey import RSA
+from libp2p.peer.id import id_from_public_key
+
+"""
+Driver is called in the following way
+python receiver_driver.py topology_config.json "my_node_id"
+"""
+
+SLEEP_TIME = 5
+
+async def connect(node1, node2_addr):
+    # node1 connects to node2
+    info = info_from_p2p_addr(node2_addr)
+    await node1.connect(info)
+
+async def main():
+    # Create Node
+    my_transport_opt_str = sys.argv[1]
+    node1 = await Node.create(my_transport_opt_str)
+
+    # Allow for all nodes to start up
+    # await asyncio.sleep(SLEEP_TIME)
+
+    neighbor_addr_str = sys.argv[2]
+    node2 = await Node.create(neighbor_addr_str)
+
+    new_key = RSA.generate(2048, e=65537)
+    id_opt = id_from_public_key(new_key.publickey())
+
+    # Add p2p part
+    neighbor_addr_str += "/p2p/" + id_opt.pretty()
+
+    # Convert neighbor_addr_str to multiaddr
+    neighbor_addr = multiaddr.Multiaddr(neighbor_addr_str)
+    await connect(node1.libp2p_node, neighbor_addr)
+    await asyncio.sleep(5)
+
+if __name__ == "__main__":
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(main())
+    loop.close()
\ No newline at end of file