blob: 57670d516c17aa79253ee2e76b22eb8f4ec26798 (
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()
|
