From 83e20713c1c3b55532f6f022eaaf290471d3b5c5 Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Sun, 20 May 2018 14:45:16 +0200 Subject: rename rpc --- rpc/relay.py | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 rpc/relay.py (limited to 'rpc/relay.py') diff --git a/rpc/relay.py b/rpc/relay.py new file mode 100644 index 0000000..9e56001 --- /dev/null +++ b/rpc/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_frame(self, frame): + print("got frame: {} bytes".format(len(frame))) + +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