blob: 9e56001c34081978ace6887ebf29511efca29e56 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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()
|
