blob: fc04586aa33f94262385a87bd177dda59b9f64b9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
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)
|
