aboutsummaryrefslogtreecommitdiffstats
path: root/gui
diff options
context:
space:
mode:
Diffstat (limited to 'gui')
-rw-r--r--gui/muxrc.py92
-rwxr-xr-xgui/odr-dabmux-gui.py12
-rw-r--r--gui/views/index.tpl15
3 files changed, 116 insertions, 3 deletions
diff --git a/gui/muxrc.py b/gui/muxrc.py
new file mode 100644
index 0000000..7644ae4
--- /dev/null
+++ b/gui/muxrc.py
@@ -0,0 +1,92 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+#
+# Copyright (C) 2016
+# Matthias P. Braendli, matthias.braendli@mpb.li
+#
+# http://www.opendigitalradio.org
+#
+# This file is part of ODR-DabMux.
+#
+# ODR-DabMux is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as
+# published by the Free Software Foundation, either version 3 of the
+# License, or (at your option) any later version.
+#
+# ODR-DabMux is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with ODR-DabMux. If not, see <http://www.gnu.org/licenses/>.
+import zmq
+import json
+
+class RCParameter(object):
+ def __init__(self, param, value):
+ self.param = param
+ self.value = value
+
+class RCModule(object):
+ """Container object for RC module"""
+ def __init__(self, name):
+ self.name = name
+ self.parameters = []
+
+class MuxRemoteControl(object):
+ """Interact with ODR-DabMux using the ZMQ RC"""
+
+ def __init__(self, mux_host, mux_port=12722):
+ self._host = mux_host
+ self._port = mux_port
+ self._ctx = zmq.Context()
+
+ self.module_list = []
+
+ def zRead(self, message_parts):
+ sock = zmq.Socket(self._ctx, zmq.REQ)
+ sock.setsockopt(zmq.LINGER, 0)
+ sock.connect("tcp://{}:{}".format(self._host, self._port))
+
+ for i, part in enumerate(message_parts):
+ if i == len(message_parts) - 1:
+ f = 0
+ else:
+ f = zmq.SNDMORE
+
+ print("Send {} {}".format(i, part))
+ sock.send(part, flags=f)
+
+ print("Poll")
+
+ # use poll for timeouts:
+ poller = zmq.Poller()
+ poller.register(sock, zmq.POLLIN)
+ if poller.poll(5*1000): # 5s timeout in milliseconds
+ recv = sock.recv_multipart()
+ print("RX {}".format(recv))
+ sock.close()
+ return recv
+ else:
+ raise IOError("Timeout processing ZMQ request")
+
+ def load(self):
+ """Load the list of RC modules"""
+ module_names = self.zRead([b'list'])
+
+ self.module_list = []
+
+ for name in module_names:
+ mod = RCModule(name)
+ module_params = self.zRead([b'show', name])
+
+ for param in module_params:
+ p, v = param.split(': ')
+ mod.parameters.append(RCParameter(p, v))
+
+ self.module_list.append(mod)
+
+ def get_modules(self):
+ return self.module_list
+
diff --git a/gui/odr-dabmux-gui.py b/gui/odr-dabmux-gui.py
index 85098f8..7e3cb3e 100755
--- a/gui/odr-dabmux-gui.py
+++ b/gui/odr-dabmux-gui.py
@@ -1,7 +1,7 @@
#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
-# Copyright (C) 2015
+# Copyright (C) 2016
# Matthias P. Braendli, matthias.braendli@mpb.li
#
# http://www.opendigitalradio.org
@@ -28,6 +28,7 @@
# along with ODR-DabMux. If not, see <http://www.gnu.org/licenses/>.
from muxconfig import *
+from muxrc import *
from bottle import route, run, template, static_file, request
import json
@@ -80,13 +81,15 @@ def config_json_get():
@route('/')
def index():
conf.load()
+ rc.load()
return template('index',
version = conf.get_mux_version(),
g = conf.get_general_options(),
services = conf.get_services(),
subchannels = conf.get_subchannels(),
- components = conf.get_components())
+ components = conf.get_components(),
+ rcmodules = rc.get_modules())
@route('/services')
def index():
@@ -119,10 +122,13 @@ if __name__ == '__main__':
parser.add_argument('--host', default='127.0.0.1', help='socket host (default: 127.0.0.1)',required=False)
parser.add_argument('--port', default='8000', help='socket port (default: 8000)',required=False)
parser.add_argument('--mhost', default='127.0.0.1', help='mux host (default: 127.0.0.1)',required=False)
- parser.add_argument('--mport', default='12720', help='mux port (default: 12720)',required=False)
+ parser.add_argument('--mport', default='12720', help='mux management server port (default: 12720)',required=False)
+ parser.add_argument('--rcport', default='12722', help='mux zmq rc port (default: 12722)',required=False)
cli_args = parser.parse_args()
conf = ConfigurationHandler(cli_args.mhost, cli_args.mport)
+ rc = MuxRemoteControl(cli_args.mhost, cli_args.rcport)
+
run(host=cli_args.host, port=int(cli_args.port), debug=True, reloader=False)
diff --git a/gui/views/index.tpl b/gui/views/index.tpl
index c38d827..5c44c61 100644
--- a/gui/views/index.tpl
+++ b/gui/views/index.tpl
@@ -14,6 +14,7 @@
<li><a href="#servicelist">Services</a></li>
<li><a href="#subchannels">Subchannels</a></li>
<li><a href="#components">Components</a></li>
+ <li><a href="#rcmodules">RC Modules</a></li>
</ul>
<div id="info">
@@ -52,6 +53,20 @@
% end
</ul>
</div>
+ <div id="rcmodules">
+ <p>RC Modules</p>
+ <ul>
+ % for m in rcmodules:
+ <li>{{m.name}}
+ <ul>
+ % for p in m.parameters:
+ <li>{{p.param}} : {{p.value}}</li>
+ % end
+ </ul>
+ </li>
+ % end
+ </ul>
+ </div>
</div>
</body>
</html>