blob: 68741d5e6f858d30ddf26d33447d8ed44dcbc93d (
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_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()
|
