summaryrefslogtreecommitdiff
path: root/events.py
diff options
context:
space:
mode:
authorJon Bergli Heier <snakebite@jvnv.net>2011-08-16 14:49:40 +0200
committerJon Bergli Heier <snakebite@jvnv.net>2011-08-16 14:49:40 +0200
commita3e86f3be768c8fa1fc2af12d5e5d66d9d9b82e8 (patch)
treeb7ff0104001b62709e22cdaefa0adc23ea07b919 /events.py
parent74ad26edc2cf0d8aa8d5d485d708de1a34aa75c0 (diff)
Implemented basic cuesheet support, some playlist fixes.
Diffstat (limited to 'events.py')
-rw-r--r--events.py17
1 files changed, 12 insertions, 5 deletions
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))