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