import os
import sys
sys.path.append(os.path.join(os.path.dirname(os.path.realpath(__file__)), '../../live-cortex/rpc/'))
from rpc import CortexRPC

class Listener:
  def __init__(self, opt, run_live, run_cmd):
    self.opt = opt
    self.run_live = run_live
  def _set_fn(self, key, value):
    self.opt[key] = value
  def _get_fn(self):
    return self.opt
  def _cmd_fn(self, cmd, payload):
    print("got command {}".format(cmd))
    run_cmd(cmd, payload)
  def _ready_fn(self, rpc_client):
    print("Ready!")
    self.rpc_client = rpc_client
    self.run_live(self.opt, rpc_client)
  def connect(self):
    self.rpc_client = CortexRPC(self._get_fn, self._set_fn, self._ready_fn, self._cmd_fn)