Mercurial > libervia-backend
annotate src/plugins/plugin_misc_radiocol.py @ 1198:16ce9a6580a3
misc (install): Lower default setuptools version
From 0d607b6ed49eab758fd9b272e148f032e65fb2e2 Mon Sep 17 00:00:00 2001
python-setuptools 5.7 is not yet in Debian, so we need to set the
default version to 5.5 (the current version in sid) to avoid the newer
version to be downloaded from pypi.
author | Matteo Cypriani <mcy@lm7.fr> |
---|---|
date | Tue, 09 Sep 2014 22:09:51 -0400 |
parents | 301b342c697a |
children | 83ed877541e3 |
rev | line source |
---|---|
450 | 1 #!/usr/bin/python |
2 # -*- coding: utf-8 -*- | |
3 | |
609
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
4 # SAT plugin for managing Radiocol |
811 | 5 # Copyright (C) 2009, 2010, 2011, 2012, 2013, 2014 Jérôme Poisson (goffi@goffi.org) |
450 | 6 |
609
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
7 # This program is free software: you can redistribute it and/or modify |
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
8 # it under the terms of the GNU Affero General Public License as published by |
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
9 # the Free Software Foundation, either version 3 of the License, or |
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
10 # (at your option) any later version. |
450 | 11 |
609
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
12 # This program is distributed in the hope that it will be useful, |
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of |
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
15 # GNU Affero General Public License for more details. |
450 | 16 |
609
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
17 # You should have received a copy of the GNU Affero General Public License |
84a6e83157c2
fixed licences in docstrings (they are now in comments)
Goffi <goffi@goffi.org>
parents:
594
diff
changeset
|
18 # along with this program. If not, see <http://www.gnu.org/licenses/>. |
450 | 19 |
901
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
20 from sat.core.i18n import _, D_ |
993
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
941
diff
changeset
|
21 from sat.core.log import getLogger |
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
941
diff
changeset
|
22 log = getLogger(__name__) |
450 | 23 from twisted.words.xish import domish |
577
593331663b80
plugin radiocol: songs are deleted once played (Q&D need to be reworked once file are properly transfered to server)
Goffi <goffi@goffi.org>
parents:
572
diff
changeset
|
24 from twisted.internet import reactor |
593331663b80
plugin radiocol: songs are deleted once played (Q&D need to be reworked once file are properly transfered to server)
Goffi <goffi@goffi.org>
parents:
572
diff
changeset
|
25 from twisted.words.protocols.jabber import jid |
849
c5a8f602662b
plugin room_game, radiocol: RoomGame.send returns a Deferred.
souliane <souliane@mailoo.org>
parents:
828
diff
changeset
|
26 from twisted.internet import defer |
765
787ee59dba9c
plugins radiocol, xep-0054: better handling of upload errors:
souliane <souliane@mailoo.org>
parents:
764
diff
changeset
|
27 from sat.core import exceptions |
455
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
28 import os.path |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
29 import copy |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
30 import time |
577
593331663b80
plugin radiocol: songs are deleted once played (Q&D need to be reworked once file are properly transfered to server)
Goffi <goffi@goffi.org>
parents:
572
diff
changeset
|
31 from os import unlink |
464
794f60e2da27
plugin radiocol: fixed missing import
Goffi <goffi@goffi.org>
parents:
459
diff
changeset
|
32 from mutagen.oggvorbis import OggVorbis, OggVorbisHeaderError |
901
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
33 from mutagen.mp3 import MP3, HeaderNotFoundError |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
34 from mutagen.easyid3 import EasyID3 |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
35 from mutagen.id3 import ID3NoHeaderError |
450 | 36 |
717
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
37 |
450 | 38 NC_RADIOCOL = 'http://www.goffi.org/protocol/radiocol' |
39 RADIOC_TAG = 'radiocol' | |
40 | |
41 PLUGIN_INFO = { | |
594
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
42 "name": "Radio collective plugin", |
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
43 "import_name": "Radiocol", |
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
44 "type": "Exp", |
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
45 "protocols": [], |
718
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
46 "dependencies": ["XEP-0045", "XEP-0249", "ROOM-GAME"], |
594
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
47 "main": "Radiocol", |
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
48 "handler": "yes", |
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
49 "description": _("""Implementation of radio collective""") |
450 | 50 } |
51 | |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
52 |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
53 # Number of songs needed in the queue before we start playing |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
54 QUEUE_TO_START = 2 |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
55 # Maximum number of songs in the queue (the song being currently played doesn't count) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
56 QUEUE_LIMIT = 2 |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
57 |
450 | 58 |
718
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
59 class Radiocol(object): |
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
60 |
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
61 def inheritFromRoomGame(self, host): |
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
62 global RoomGame |
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
63 RoomGame = host.plugins["ROOM-GAME"].__class__ |
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
64 self.__class__ = type(self.__class__.__name__, (self.__class__, RoomGame, object), {}) |
450 | 65 |
66 def __init__(self, host): | |
993
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
941
diff
changeset
|
67 log.info(_("Radio collective initialization")) |
718
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
68 self.inheritFromRoomGame(host) |
074970227bc0
plugin tools: turn src/plugin/games.py into a plugin and move it to src/plugins/plugin_misc_room_game.py
souliane <souliane@mailoo.org>
parents:
717
diff
changeset
|
69 RoomGame._init_(self, host, PLUGIN_INFO, (NC_RADIOCOL, RADIOC_TAG), |
827
215a2cb15e2d
plugin radiocol: sync data includes a "jump to time" info
souliane <souliane@mailoo.org>
parents:
826
diff
changeset
|
70 game_init={'queue': [], 'upload': True, 'playing': None, 'playing_time': 0, 'to_delete': {}}) |
450 | 71 self.host = host |
712
f610864eb7a5
plugins (MUC, tools, games): generalize the generation of a unique room name when joining a MUC and no room is specified:
souliane <souliane@mailoo.org>
parents:
683
diff
changeset
|
72 host.bridge.addMethod("radiocolLaunch", ".plugin", in_sign='asss', out_sign='', method=self.prepareRoom) |
717
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
73 host.bridge.addMethod("radiocolCreate", ".plugin", in_sign='sass', out_sign='', method=self.createGame) |
765
787ee59dba9c
plugins radiocol, xep-0054: better handling of upload errors:
souliane <souliane@mailoo.org>
parents:
764
diff
changeset
|
74 host.bridge.addMethod("radiocolSongAdded", ".plugin", in_sign='sss', out_sign='', method=self.radiocolSongAdded, async=True) |
717
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
75 host.bridge.addSignal("radiocolPlayers", ".plugin", signature='ssass') # room_jid, referee, players, profile |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
76 host.bridge.addSignal("radiocolStarted", ".plugin", signature='ssasais') # room_jid, referee, players, [QUEUE_TO_START, QUEUE_LIMIT], profile |
594
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
77 host.bridge.addSignal("radiocolSongRejected", ".plugin", signature='sss') # room_jid, reason, profile |
903
c3fdf187a73a
plugin radiocol: preload signal also contains the uploader nickname
souliane <souliane@mailoo.org>
parents:
901
diff
changeset
|
78 host.bridge.addSignal("radiocolPreload", ".plugin", signature='ssssssss') # room_jid, timestamp, filename, title, artist, album, profile |
594
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
79 host.bridge.addSignal("radiocolPlay", ".plugin", signature='sss') # room_jid, filename, profile |
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
80 host.bridge.addSignal("radiocolNoUpload", ".plugin", signature='ss') # room_jid, profile |
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
81 host.bridge.addSignal("radiocolUploadOk", ".plugin", signature='ss') # room_jid, profile |
450 | 82 |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
83 def __create_preload_elt(self, sender, song_added_elt): |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
84 preload_elt = copy.deepcopy(song_added_elt) |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
85 preload_elt.name = 'preload' |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
86 preload_elt['sender'] = sender |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
87 preload_elt['timestamp'] = str(time.time()) |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
88 # attributes filename, title, artist, album, length have been copied |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
89 # XXX: the frontend should know the temporary directory where file is put |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
90 return preload_elt |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
91 |
455
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
92 def radiocolSongAdded(self, referee, song_path, profile): |
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
93 """This method is called by libervia when a song has been uploaded |
790
19262fb77230
plugin room game: improved docstrings, added '_' as prefix for internal methods names
souliane <souliane@mailoo.org>
parents:
771
diff
changeset
|
94 @param referee: JID of the referee in the room (room userhost + '/' + nick) |
455
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
95 @song_path: absolute path of the song added |
849
c5a8f602662b
plugin room_game, radiocol: RoomGame.send returns a Deferred.
souliane <souliane@mailoo.org>
parents:
828
diff
changeset
|
96 @param profile_key: %(doc_profile_key)s |
c5a8f602662b
plugin room_game, radiocol: RoomGame.send returns a Deferred.
souliane <souliane@mailoo.org>
parents:
828
diff
changeset
|
97 @return: a Deferred instance |
c5a8f602662b
plugin room_game, radiocol: RoomGame.send returns a Deferred.
souliane <souliane@mailoo.org>
parents:
828
diff
changeset
|
98 """ |
455
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
99 #XXX: this is a Q&D way for the proof of concept. In the future, the song should |
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
100 # be streamed to the backend using XMPP file copy |
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
101 # Here we cheat because we know we are on the same host, and we don't |
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
102 # check data. Referee will have to parse the song himself to check it |
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
103 try: |
901
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
104 if song_path.lower().endswith('.mp3'): |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
105 actual_song = MP3(song_path) |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
106 try: |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
107 song = EasyID3(song_path) |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
108 |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
109 class Info(object): |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
110 def __init__(self, length): |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
111 self.length = length |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
112 song.info = Info(actual_song.info.length) |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
113 except ID3NoHeaderError: |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
114 song = actual_song |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
115 else: |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
116 song = OggVorbis(song_path) |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
117 except (OggVorbisHeaderError, HeaderNotFoundError): |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
118 #this file is not ogg vorbis nor mp3, we reject it |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
119 self.deleteFile(song_path) # FIXME: same host trick (see note above) |
901
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
120 return defer.fail(exceptions.DataError(D_("The uploaded file has been rejected, only Ogg Vorbis and MP3 songs are accepted."))) |
c238d2c02237
plugin radiocol: add MP3 support
souliane <souliane@mailoo.org>
parents:
849
diff
changeset
|
121 |
714
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
122 attrs = {'filename': os.path.basename(song_path), |
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
123 'title': song.get("title", ["Unknown"])[0], |
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
124 'artist': song.get("artist", ["Unknown"])[0], |
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
125 'album': song.get("album", ["Unknown"])[0], |
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
126 'length': str(song.info.length) |
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
127 } |
683
75e4f5e2cc65
plugins radiocol, card_game, quiz: code factorization
souliane <souliane@mailoo.org>
parents:
609
diff
changeset
|
128 radio_data = self.games[jid.JID(referee).userhost()] # FIXME: referee comes from Libervia's client side, it's unsecure |
714
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
129 radio_data['to_delete'][attrs['filename']] = song_path # FIXME: works only because of the same host trick, see the note under the docstring |
849
c5a8f602662b
plugin room_game, radiocol: RoomGame.send returns a Deferred.
souliane <souliane@mailoo.org>
parents:
828
diff
changeset
|
130 return self.send(jid.JID(referee), ('', 'song_added'), attrs, profile=profile) |
455
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
131 |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
132 def playNext(self, room_jid, profile): |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
133 """"Play next song in queue if exists, and put a timer |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
134 which trigger after the song has been played to play next one""" |
464
794f60e2da27
plugin radiocol: fixed missing import
Goffi <goffi@goffi.org>
parents:
459
diff
changeset
|
135 #TODO: songs need to be erased once played or found invalids |
577
593331663b80
plugin radiocol: songs are deleted once played (Q&D need to be reworked once file are properly transfered to server)
Goffi <goffi@goffi.org>
parents:
572
diff
changeset
|
136 # ==> unlink done the Q&D way with the same host trick (see above) |
683
75e4f5e2cc65
plugins radiocol, card_game, quiz: code factorization
souliane <souliane@mailoo.org>
parents:
609
diff
changeset
|
137 radio_data = self.games[room_jid.userhost()] |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
138 if len(radio_data['players']) == 0: |
993
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
941
diff
changeset
|
139 log.debug(_('No more participants in the radiocol: cleaning data')) |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
140 radio_data['queue'] = [] |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
141 for filename in radio_data['to_delete']: |
764
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
142 self.deleteFile(filename, radio_data) |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
143 radio_data['to_delete'] = {} |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
144 queue = radio_data['queue'] |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
145 if not queue: |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
146 #nothing left to play, we need to wait for uploads |
827
215a2cb15e2d
plugin radiocol: sync data includes a "jump to time" info
souliane <souliane@mailoo.org>
parents:
826
diff
changeset
|
147 radio_data['playing'] = None |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
148 return |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
149 song = queue.pop(0) |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
150 filename, length = song['filename'], float(song['length']) |
714
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
151 self.send(room_jid, ('', 'play'), {'filename': filename}, profile=profile) |
827
215a2cb15e2d
plugin radiocol: sync data includes a "jump to time" info
souliane <souliane@mailoo.org>
parents:
826
diff
changeset
|
152 radio_data['playing'] = song |
215a2cb15e2d
plugin radiocol: sync data includes a "jump to time" info
souliane <souliane@mailoo.org>
parents:
826
diff
changeset
|
153 radio_data['playing_time'] = time.time() |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
154 |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
155 if not radio_data['upload'] and len(queue) < QUEUE_LIMIT: |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
156 #upload is blocked and we now have resources to get more, we reactivate it |
714
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
157 self.send(room_jid, ('', 'upload_ok'), profile=profile) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
158 radio_data['upload'] = True |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
159 |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
160 reactor.callLater(length, self.playNext, room_jid, profile) |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
161 #we wait more than the song length to delete the file, to manage poorly reactive networks/clients |
764
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
162 reactor.callLater(length + 90, self.deleteFile, filename, radio_data) # FIXME: same host trick (see above) |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
163 |
764
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
164 def deleteFile(self, filename, radio_data=None): |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
165 """ |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
166 Delete a previously uploaded file. |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
167 @param filename: filename to delete, or full filepath if radio_data is None |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
168 @param radio_data: current game data |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
169 @return: True if the file has been deleted |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
170 """ |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
171 if radio_data: |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
172 try: |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
173 file_to_delete = radio_data['to_delete'][filename] |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
174 except KeyError: |
993
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
941
diff
changeset
|
175 log.error(_("INTERNAL ERROR: can't find full path of the song to delete")) |
764
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
176 return False |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
177 else: |
d0e809014ea2
plugin radiocol: fix wrong call of deleteFile
souliane <souliane@mailoo.org>
parents:
746
diff
changeset
|
178 file_to_delete = filename |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
179 try: |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
180 unlink(file_to_delete) |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
181 except OSError: |
993
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
941
diff
changeset
|
182 log.error(_("INTERNAL ERROR: can't find %s on the file system" % file_to_delete)) |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
183 return False |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
184 return True |
455
72522263cbc9
plugin RadioCol: basic functionnality working approximately
Goffi <goffi@goffi.org>
parents:
453
diff
changeset
|
185 |
717
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
186 def room_game_cmd(self, mess_elt, profile): |
587
952322b1d490
Remove trailing whitespaces.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
577
diff
changeset
|
187 from_jid = jid.JID(mess_elt['from']) |
450 | 188 room_jid = jid.JID(from_jid.userhost()) |
826
71f8e996f765
plugins radiocol_tarot: do not process received messages for MUC users that are actually not playing the game + fix for testing purpose
souliane <souliane@mailoo.org>
parents:
825
diff
changeset
|
189 nick = self.host.plugins["XEP-0045"].getRoomNick(room_jid.userhost(), profile) |
71f8e996f765
plugins radiocol_tarot: do not process received messages for MUC users that are actually not playing the game + fix for testing purpose
souliane <souliane@mailoo.org>
parents:
825
diff
changeset
|
190 |
450 | 191 radio_elt = mess_elt.firstChildElement() |
683
75e4f5e2cc65
plugins radiocol, card_game, quiz: code factorization
souliane <souliane@mailoo.org>
parents:
609
diff
changeset
|
192 radio_data = self.games[room_jid.userhost()] |
717
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
193 if 'queue' in radio_data: |
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
194 queue = radio_data['queue'] |
587
952322b1d490
Remove trailing whitespaces.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
577
diff
changeset
|
195 |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
196 from_referee = self.isReferee(room_jid.userhost(), from_jid.resource) |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
197 to_referee = self.isReferee(room_jid.userhost(), jid.JID(mess_elt['to']).user) |
826
71f8e996f765
plugins radiocol_tarot: do not process received messages for MUC users that are actually not playing the game + fix for testing purpose
souliane <souliane@mailoo.org>
parents:
825
diff
changeset
|
198 is_player = self.isPlayer(room_jid.userhost(), nick) |
450 | 199 for elt in radio_elt.elements(): |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
200 if not from_referee and not (to_referee and elt.name == 'song_added'): |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
201 continue # sender must be referee, expect when a song is submitted |
826
71f8e996f765
plugins radiocol_tarot: do not process received messages for MUC users that are actually not playing the game + fix for testing purpose
souliane <souliane@mailoo.org>
parents:
825
diff
changeset
|
202 if not is_player and (elt.name not in ('started', 'players')): |
71f8e996f765
plugins radiocol_tarot: do not process received messages for MUC users that are actually not playing the game + fix for testing purpose
souliane <souliane@mailoo.org>
parents:
825
diff
changeset
|
203 continue # user is in the room but not playing |
587
952322b1d490
Remove trailing whitespaces.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
577
diff
changeset
|
204 |
826
71f8e996f765
plugins radiocol_tarot: do not process received messages for MUC users that are actually not playing the game + fix for testing purpose
souliane <souliane@mailoo.org>
parents:
825
diff
changeset
|
205 if elt.name in ('started', 'players'): # new game created and/or players list updated |
717
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
206 players = [] |
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
207 for player in elt.elements(): |
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
208 players.append(unicode(player)) |
358018c5c398
plugins (games): more factorization and flexibility for launching and joining games:
souliane <souliane@mailoo.org>
parents:
714
diff
changeset
|
209 signal = self.host.bridge.radiocolStarted if elt.name == 'started' else self.host.bridge.radiocolPlayers |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
210 signal(room_jid.userhost(), from_jid.full(), players, [QUEUE_TO_START, QUEUE_LIMIT], profile) |
594
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
211 elif elt.name == 'preload': # a song is in queue and must be preloaded |
903
c3fdf187a73a
plugin radiocol: preload signal also contains the uploader nickname
souliane <souliane@mailoo.org>
parents:
901
diff
changeset
|
212 self.host.bridge.radiocolPreload(room_jid.userhost(), elt['timestamp'], elt['filename'], elt['title'], elt['artist'], elt['album'], elt['sender'], profile) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
213 elif elt.name == 'play': |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
214 self.host.bridge.radiocolPlay(room_jid.userhost(), elt['filename'], profile) |
594
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
215 elif elt.name == 'song_rejected': # a song has been refused |
577
593331663b80
plugin radiocol: songs are deleted once played (Q&D need to be reworked once file are properly transfered to server)
Goffi <goffi@goffi.org>
parents:
572
diff
changeset
|
216 self.host.bridge.radiocolSongRejected(room_jid.userhost(), elt['reason'], profile) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
217 elif elt.name == 'no_upload': |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
218 self.host.bridge.radiocolNoUpload(room_jid.userhost(), profile) |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
219 elif elt.name == 'upload_ok': |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
220 self.host.bridge.radiocolUploadOk(room_jid.userhost(), profile) |
594
e629371a28d3
Fix pep8 support in src/plugins.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
588
diff
changeset
|
221 elif elt.name == 'song_added': # a song has been added |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
222 #FIXME: we are KISS for the proof of concept: every song is added, to a limit of 3 in queue. |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
223 # Need to manage some sort of rules to allow peoples to send songs |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
224 if len(queue) >= QUEUE_LIMIT: |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
225 #there are already too many songs in queue, we reject this one |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
226 #FIXME: add an error code |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
227 self.send(from_jid, ('', 'song_rejected'), {'reason': "Too many songs in queue"}, profile=profile) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
228 return |
587
952322b1d490
Remove trailing whitespaces.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
577
diff
changeset
|
229 |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
230 #The song is accepted and added in queue |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
231 preload_elt = self.__create_preload_elt(from_jid.resource, elt) |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
232 queue.append(preload_elt) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
233 |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
234 if len(queue) >= QUEUE_LIMIT: |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
235 #We are at the limit, we refuse new upload until next play |
714
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
236 self.send(room_jid, ('', 'no_upload'), profile=profile) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
237 radio_data['upload'] = False |
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
238 |
714
ecc5a5b34ee1
plugins (games): add a method to send messages more easily
souliane <souliane@mailoo.org>
parents:
712
diff
changeset
|
239 self.send(room_jid, preload_elt, profile=profile) |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
240 if not radio_data['playing'] and len(queue) == QUEUE_TO_START: |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
241 # We have not started playing yet, and we have QUEUE_TO_START |
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
242 # songs in queue. We can now start the party :) |
457
fbe7c9118ce4
plugin radiocol: working Radio Collective \o/
Goffi <goffi@goffi.org>
parents:
456
diff
changeset
|
243 self.playNext(room_jid, profile) |
450 | 244 else: |
993
301b342c697a
core: use of the new core.log module:
Goffi <goffi@goffi.org>
parents:
941
diff
changeset
|
245 log.error(_('Unmanaged game element: %s') % elt.name) |
746
539f278bc265
plugin room_games, radiocol: send the current queue to new players
souliane <souliane@mailoo.org>
parents:
718
diff
changeset
|
246 |
828
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
247 def getSyncDataForPlayer(self, room_jid_s, nick): |
827
215a2cb15e2d
plugin radiocol: sync data includes a "jump to time" info
souliane <souliane@mailoo.org>
parents:
826
diff
changeset
|
248 game_data = self.games[room_jid_s] |
828
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
249 elements = [] |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
250 if game_data['playing']: |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
251 preload = copy.deepcopy(game_data['playing']) |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
252 current_time = game_data['playing_time'] + 1 if self.testing else time.time() |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
253 preload['filename'] += '#t=%.2f' % (current_time - game_data['playing_time']) |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
254 elements.append(preload) |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
255 play = domish.Element(('', 'play')) |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
256 play['filename'] = preload['filename'] |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
257 elements.append(play) |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
258 if len(game_data['queue']) > 0: |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
259 elements.extend(copy.deepcopy(game_data['queue'])) |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
260 if len(game_data['queue']) == QUEUE_LIMIT: |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
261 elements.append(domish.Element(('', 'no_upload'))) |
8f335c03eebb
plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance
souliane <souliane@mailoo.org>
parents:
827
diff
changeset
|
262 return elements |