From 2f922b3ac504a5450132447630c6100c7424e16e Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Sun, 20 May 2018 11:30:48 +0200 Subject: bidirectional python zerorpc client --- python/relay.py | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 python/relay.py (limited to 'python/relay.py') 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() -- cgit v1.2.3-70-g09d2