bidirectional python zerorpc client

1 files changed, 25 insertions, 0 deletions

diff --git a/python/relay.py b/python/relay.py
new file mode 100644
index 0000000..68741d5
--- /dev/null
+++ b/python/relay.py
@@ -0,0 +1,25 @@
+from dotenv import load_dotenv, find_dotenv
+import os
+import zerorpc
+import gevent
+
+load_dotenv(find_dotenv())
+
+class RelayRPC(object):
+  def start(self):
+    print("Relay running on port {}".format(os.getenv('RELAY_PORT')))
+
+  def connected(self, msg):
+    print("got connect, trying to call back.")
+    print("Connecting to RPC on port {}".format(os.getenv('RPC_PORT')))
+    client = zerorpc.Client()
+    client.connect("tcp://127.0.0.1:" + os.getenv('RPC_PORT'))
+    client.send_param("key", "value")
+
+  def send_file(self, fn):
+    print("got file: {} bytes".format(len(fn)))
+
+rpc = RelayRPC()
+server = zerorpc.Server(rpc)
+server.bind("tcp://127.0.0.1:" + os.getenv('RELAY_PORT'))
+server.run()