erebion/libervia-backend
Watch
1
0
Fork
You've already forked libervia-backend
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

plugin radiocol: working Radio Collective \o/

Browse source
This commit is contained in:
Goffi 2012-01-29 03:00:25 +01:00
commit 5c14137b98
1 changed files with 93 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

109
src/plugins/plugin_misc_radiocol.py
View file

@ -58,6 +58,8 @@ PLUGIN_INFO = {
"description": _("""Implementation of radio collective""")
}
QUEUE_LIMIT = 2
class Radiocol():
@ -71,6 +73,9 @@ class Radiocol():
host.bridge.addSignal("radiocolStarted", ".plugin", signature='sss') #room_jid, referee, profile
host.bridge.addSignal("radiocolSongRejected", ".plugin", signature='sss') #room_jid, reason, profile
host.bridge.addSignal("radiocolPreload", ".plugin", signature='ssssss') #room_jid, filename, title, artist, album, profile
host.bridge.addSignal("radiocolPlay", ".plugin", signature='sss') #room_jid, filename, profile
host.bridge.addSignal("radiocolNoUpload", ".plugin", signature='ss') #room_jid, profile
host.bridge.addSignal("radiocolUploadOk", ".plugin", signature='ss') #room_jid, profile
host.trigger.add("MUC user joined", self.userJoinedTrigger)
def createRadiocolElt(self, to_jid, type="normal"):
@ -86,6 +91,16 @@ class Radiocol():
started_elt = domish.Element(('','started'))
return started_elt
def __create_preload_elt(self, sender, filename, title, artist, album):
preload_elt = domish.Element(('','preload'))
preload_elt['sender'] = sender
preload_elt['filename'] = filename #XXX: the frontend should know the temporary directory where file is put
preload_elt['title'] = title
preload_elt['artist'] = artist
preload_elt['album'] = album
return preload_elt
def userJoinedTrigger(self, room, user, profile):
"""This trigger is used to check if we are waiting people in this room,
and to create a game if everybody is here"""
@ -159,7 +174,7 @@ class Radiocol():
referee = room_jid.userhost() + '/' + room_nick
status = {}
occupants_data = {}
self.radios[room_jid.userhost()] = {'referee':referee, 'occupants_data':occupants_data}
self.radios[room_jid.userhost()] = {'referee':referee, 'queue':[], 'upload':True, 'playing': False, 'occupants_data':occupants_data}
mess = self.createRadiocolElt(jid.JID(room_jid.userhost()))
mess.firstChildElement().addChild(self.__create_started_elt())
self.host.profiles[profile].xmlstream.send(mess)
@ -181,12 +196,12 @@ class Radiocol():
song = OggVorbis(song_path)
except OggVorbisHeaderError:
#this file is not ogg vorbis, we reject it
import pdb
pdb.set_trace()
self.host.bridge.radiocolSongRejected(jid.JID(referee).userhost(), \
"Uploaded file is not Ogg Vorbis song, only Ogg Vorbis songs are acceptable", profile)
"""mess = self.createRadiocolElt(jid.JID(referee))
reject_elt = mess.firstChildElement().addElement(('','song_rejected'))
reject_elt['sender'] = client.jid
reject_elt['reason'] = _("Uploaded file is not Ogg Vorbis song, only Ogg Vorbis songs are acceptable")
reject_elt['reason'] = "Uploaded file is not Ogg Vorbis song, only Ogg Vorbis songs are acceptable"
#FIXME: add an error code
self.host.profiles[profile].xmlstream.send(mess)"""
return
@ -204,14 +219,43 @@ class Radiocol():
self.host.profiles[profile].xmlstream.send(mess)
return
def playNext(self, room_jid, profile):
""""Play next sont in queue if exists, and put a timer
which trigger after the song has been played to play next one"""
#TODO: need to check that there are still peoples in the room
# and clean the datas/stop the playlist if it's not the case
radio_data = self.radios[room_jid.userhost()]
queue = radio_data['queue']
if not queue:
#nothing left to play, we need to wait for uploads
radio_data['playing'] = False
return
filename, length = queue.pop(0)
mess = self.createRadiocolElt(room_jid)
play_elt = mess.firstChildElement().addElement(('','play'))
play_elt['filename'] = filename
self.host.profiles[profile].xmlstream.send(mess)
if not radio_data['upload'] and len(queue) < QUEUE_LIMIT:
#upload is blocked and we now have resources to get more, we reactivate it
mess = self.createRadiocolElt(room_jid)
no_upload_elt = mess.firstChildElement().addElement(('','upload_ok'))
self.host.profiles[profile].xmlstream.send(mess)
radio_data['upload'] = True
print ("Playing next song in %s s" % length)
reactor.callLater(length, self.playNext, room_jid, profile)
def radiocol_game_cmd(self, mess_elt, profile):
#FIXME: we should check sender (is it referee ?) here before accepting commands
from_jid = jid.JID(mess_elt['from'])
room_jid = jid.JID(from_jid.userhost())
radio_elt = mess_elt.firstChildElement()
radio_data = self.radios[room_jid.userhost()]
occupants_data = radio_data['occupants_data']
queue = radio_data['queue']
for elt in radio_elt.elements():
@ -219,20 +263,53 @@ class Radiocol():
self.host.bridge.radiocolStarted(room_jid.userhost(), from_jid.full(), profile)
elif elt.name == 'preload': #a song is in queue and must be preloaded
self.host.bridge.radiocolPreload(room_jid.userhost(), elt['filename'], elt['title'], elt['artist'], elt['album'], profile)
elif elt.name == 'play':
self.host.bridge.radiocolPlay(room_jid.userhost(), elt['filename'], profile)
elif elt.name == 'song_rejected': #a song has been refused
import pdb
pdb.set_trace()
elif elt.name == 'song_added': #a song has been refused
#FIXME: we are KISS for the PoC: every song is added. Need to manage some sort of rules to allow peoples to send songs
self.host.bridge.radiocolSongRejected(jid.JID(referee).userhost(), elt['reason'], profile)
elif elt.name == 'no_upload':
self.host.bridge.radiocolNoUpload(room_jid.userhost(), profile)
elif elt.name == 'upload_ok':
self.host.bridge.radiocolUploadOk(room_jid.userhost(), profile)
elif elt.name == 'song_added': #a song has been added
#FIXME: we are KISS for the proof of concept: every song is added, to a limit of 3 in queue.
# Need to manage some sort of rules to allow peoples to send songs
if len(queue) >= QUEUE_LIMIT:
#there are already too many songs in queue, we reject this one
mess = self.createRadiocolElt(room_jid)
reject_elt = mess.firstChildElement().addElement(('','song_rejected'))
reject_elt['sender'] = from_jid.resource
reject_elt['reason'] = "Too many songs in queue"
#FIXME: add an error code
self.host.profiles[profile].xmlstream.send(mess)
return
#The song is accepted and added in queue
queue.append((elt['filename'], float(elt['length'])))
if len(queue) >= QUEUE_LIMIT:
#We are at the limit, we refuse new upload until next play
mess = self.createRadiocolElt(room_jid)
no_upload_elt = mess.firstChildElement().addElement(('','no_upload'))
#FIXME: add an error code
self.host.profiles[profile].xmlstream.send(mess)
radio_data['upload'] = False
mess = self.createRadiocolElt(room_jid)
preload_elt = mess.firstChildElement().addElement(('','preload'))
preload_elt['sender'] = from_jid.resource
preload_elt['filename'] = elt['filename'] #XXX: the frontend should know the temporary directory where file is put
preload_elt['title'] = elt['title']
preload_elt['artist'] = elt['artist']
preload_elt['album'] = elt['album']
preload_elt['length'] = elt['length']
preload_elt = self.__create_preload_elt(from_jid.resource,
elt['filename'],
elt['title'],
elt['artist'],
elt['album'])
mess.firstChildElement().addChild(preload_elt)
self.host.profiles[profile].xmlstream.send(mess)
if not radio_data['playing'] and len(queue) == 2:
#we have not started playing yet, and we have 2 songs in queue
#we can now start the party :)
radio_data['playing'] = True
self.playNext(room_jid, profile)
else:
error (_('Unmanaged game element: %s') % elt.name)