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()