From 4e4b8f6eac119ac6592aed8c5b67678d229e778f Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Wed, 18 Dec 2019 21:13:26 +0100 Subject: inversion --- inversion/listener.py | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 inversion/listener.py (limited to 'inversion/listener.py') diff --git a/inversion/listener.py b/inversion/listener.py new file mode 100644 index 0000000..a43c33c --- /dev/null +++ b/inversion/listener.py @@ -0,0 +1,25 @@ +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): + 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)) + if cmd == '': + pass + else: + pass + 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) -- cgit v1.2.3-70-g09d2