summaryrefslogtreecommitdiff
path: root/inversion/listener.py
diff options
context:
space:
mode:
Diffstat (limited to 'inversion/listener.py')
-rw-r--r--inversion/listener.py25
1 files changed, 25 insertions, 0 deletions
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)