From a3e86f3be768c8fa1fc2af12d5e5d66d9d9b82e8 Mon Sep 17 00:00:00 2001 From: Jon Bergli Heier Date: Tue, 16 Aug 2011 14:49:40 +0200 Subject: Implemented basic cuesheet support, some playlist fixes. --- events.py | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) (limited to 'events.py') diff --git a/events.py b/events.py index 451e6f0..0d0360d 100644 --- a/events.py +++ b/events.py @@ -25,8 +25,15 @@ def EventSubscriber(app, environ, start_response, path): if address == session: address, message = message.split(None, 1) - if address in ('cached', 'recoding', 'play'): + data = None + if address in ('cached', 'recoding'): + track, path = message.split(None, 1) + data = json.dumps({'type': address, 'path': path, 'track': track}) + yield 'data: {0}\n\n'.format(data) + elif address in ('play',): data = json.dumps({'type': address, 'path': message}) + + if data: yield 'data: {0}\n\n'.format(data) socket.close() @@ -37,11 +44,11 @@ class EventPublisher(object): self.socket = self.context.socket(zmq.PUB) self.socket.bind(config.get('event_publisher')) - def recoding(self, path): - self.socket.send('recoding {0}'.format(path)) + def recoding(self, path, track): + self.socket.send('recoding {0} {1}'.format(track or '_', path)) - def cached(self, path): - self.socket.send('cached {0}'.format(path)) + def cached(self, path, track): + self.socket.send('cached {0} {1}'.format(track or '_', path)) def play(self, session, path): self.socket.send('session-{0} play {1}'.format(session, path)) -- cgit v1.2.3