libervia-backend: sat/plugins/plugin_misc

annotate sat/plugins/plugin_misc_radiocol.py @ 2646:712cb4ff3e13

core: new EncryptionHandler class which manage encrypted session as a core feature: Plugin handling encryption can now register using host.registerEncryptionPlugin, and an encryption session can now be started using messageEncryptionStart bridge method. This will make encryption handling more easy, as we now know if a session is clear or e2e encrypted, and which plugin handle it.

author	Goffi <goffi@goffi.org>
date	Sun, 29 Jul 2018 19:22:56 +0200
parents	56f94936df1e
children	003b8b4b56a7

rev	line source
1934 2daf7b4c6756 use of /usr/bin/env instead of /usr/bin/python in shebang Goffi <goffi@goffi.org> parents: 1766 diff changeset	1 #!/usr/bin/env python2
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	2 # -- coding: utf-8 --
afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	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
2483 0046283a285d dates update Goffi <goffi@goffi.org> parents: 2414 diff changeset	5 # Copyright (C) 2009-2018 Jérôme Poisson (goffi@goffi.org)
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	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 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	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 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	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 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	19
901 c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	20 from sat.core.i18n import _, D_
2145 33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	21 from sat.core.constants import Const as C
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	22 from sat.core.log import getLogger
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	23
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	24 log = getLogger(__name__)
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	25 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	26 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	27 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	28 from twisted.internet import defer
765 787ee59dba9c plugins radiocol, xep-0054: better handling of upload errors: souliane <souliane@mailoo.org> parents: 764 diff changeset	29 from sat.core import exceptions
455 72522263cbc9 plugin RadioCol: basic functionnality working approximately Goffi <goffi@goffi.org> parents: 453 diff changeset	30 import os.path
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	31 import copy
539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	32 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	33 from os import unlink
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	34
1542 94901070478e plugins: added new MissingModule exceptions to plugins using third party modules Goffi <goffi@goffi.org> parents: 1411 diff changeset	35 try:
94901070478e plugins: added new MissingModule exceptions to plugins using third party modules Goffi <goffi@goffi.org> parents: 1411 diff changeset	36 from mutagen.oggvorbis import OggVorbis, OggVorbisHeaderError
94901070478e plugins: added new MissingModule exceptions to plugins using third party modules Goffi <goffi@goffi.org> parents: 1411 diff changeset	37 from mutagen.mp3 import MP3, HeaderNotFoundError
94901070478e plugins: added new MissingModule exceptions to plugins using third party modules Goffi <goffi@goffi.org> parents: 1411 diff changeset	38 from mutagen.easyid3 import EasyID3
94901070478e plugins: added new MissingModule exceptions to plugins using third party modules Goffi <goffi@goffi.org> parents: 1411 diff changeset	39 from mutagen.id3 import ID3NoHeaderError
94901070478e plugins: added new MissingModule exceptions to plugins using third party modules Goffi <goffi@goffi.org> parents: 1411 diff changeset	40 except ImportError:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	41 raise exceptions.MissingModule(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	42 u"Missing module Mutagen, please download/install from https://bitbucket.org/lazka/mutagen"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	43 )
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	44
717 358018c5c398 plugins (games): more factorization and flexibility for launching and joining games: souliane <souliane@mailoo.org> parents: 714 diff changeset	45
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	46 NC_RADIOCOL = "http://www.goffi.org/protocol/radiocol"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	47 RADIOC_TAG = "radiocol"
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	48
afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	49 PLUGIN_INFO = {
2145 33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	50 C.PI_NAME: "Radio collective plugin",
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	51 C.PI_IMPORT_NAME: "Radiocol",
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	52 C.PI_TYPE: "Exp",
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	53 C.PI_PROTOCOLS: [],
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	54 C.PI_DEPENDENCIES: ["XEP-0045", "XEP-0249", "ROOM-GAME"],
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	55 C.PI_MAIN: "Radiocol",
33c8c4973743 core (plugins): added missing contants + use of new constants in PLUGIN_INFO Goffi <goffi@goffi.org> parents: 1934 diff changeset	56 C.PI_HANDLER: "yes",
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	57 C.PI_DESCRIPTION: _("""Implementation of radio collective"""),
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	58 }
afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	59
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	60
539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	61 # 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	62 QUEUE_TO_START = 2
539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	63 # 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	64 QUEUE_LIMIT = 2
fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	65
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	66
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	67 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	68 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	69 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	70 RoomGame = host.plugins["ROOM-GAME"].__class__
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	71 self.__class__ = type(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	72 self.__class__.__name__, (self.__class__, RoomGame, object), {}
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	73 )
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	74
afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	75 def __init__(self, host):
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	76 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	77 self.inheritFromRoomGame(host)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	78 RoomGame._init_(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	79 self,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	80 host,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	81 PLUGIN_INFO,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	82 (NC_RADIOCOL, RADIOC_TAG),
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	83 game_init={
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	84 "queue": [],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	85 "upload": True,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	86 "playing": None,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	87 "playing_time": 0,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	88 "to_delete": {},
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	89 },
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	90 )
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	91 self.host = host
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	92 host.bridge.addMethod(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	93 "radiocolLaunch",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	94 ".plugin",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	95 in_sign="asss",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	96 out_sign="",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	97 method=self._prepareRoom,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	98 async=True,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	99 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	100 host.bridge.addMethod(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	101 "radiocolCreate",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	102 ".plugin",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	103 in_sign="sass",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	104 out_sign="",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	105 method=self._createGame,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	106 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	107 host.bridge.addMethod(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	108 "radiocolSongAdded",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	109 ".plugin",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	110 in_sign="sss",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	111 out_sign="",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	112 method=self._radiocolSongAdded,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	113 async=True,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	114 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	115 host.bridge.addSignal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	116 "radiocolPlayers", ".plugin", signature="ssass"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	117 ) # room_jid, referee, players, profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	118 host.bridge.addSignal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	119 "radiocolStarted", ".plugin", signature="ssasais"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	120 ) # room_jid, referee, players, [QUEUE_TO_START, QUEUE_LIMIT], profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	121 host.bridge.addSignal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	122 "radiocolSongRejected", ".plugin", signature="sss"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	123 ) # room_jid, reason, profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	124 host.bridge.addSignal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	125 "radiocolPreload", ".plugin", signature="ssssssss"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	126 ) # room_jid, timestamp, filename, title, artist, album, profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	127 host.bridge.addSignal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	128 "radiocolPlay", ".plugin", signature="sss"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	129 ) # room_jid, filename, profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	130 host.bridge.addSignal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	131 "radiocolNoUpload", ".plugin", signature="ss"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	132 ) # room_jid, profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	133 host.bridge.addSignal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	134 "radiocolUploadOk", ".plugin", signature="ss"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	135 ) # room_jid, profile
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	136
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	137 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	138 preload_elt = copy.deepcopy(song_added_elt)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	139 preload_elt.name = "preload"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	140 preload_elt["sender"] = sender
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	141 preload_elt["timestamp"] = str(time.time())
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	142 # 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	143 # 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	144 return preload_elt
fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	145
1411 8767c0bb7d48 plugin radiocol: radiocolSongAdded now gets a JID as argument, add _radiocolSongAdded working with unicode for bridge calls souliane <souliane@mailoo.org> parents: 1409 diff changeset	146 def _radiocolSongAdded(self, referee_s, song_path, profile):
8767c0bb7d48 plugin radiocol: radiocolSongAdded now gets a JID as argument, add _radiocolSongAdded working with unicode for bridge calls souliane <souliane@mailoo.org> parents: 1409 diff changeset	147 return self.radiocolSongAdded(jid.JID(referee_s), song_path, profile)
8767c0bb7d48 plugin radiocol: radiocolSongAdded now gets a JID as argument, add _radiocolSongAdded working with unicode for bridge calls souliane <souliane@mailoo.org> parents: 1409 diff changeset	148
455 72522263cbc9 plugin RadioCol: basic functionnality working approximately Goffi <goffi@goffi.org> parents: 453 diff changeset	149 def radiocolSongAdded(self, referee, song_path, profile):
72522263cbc9 plugin RadioCol: basic functionnality working approximately Goffi <goffi@goffi.org> parents: 453 diff changeset	150 """This method is called by libervia when a song has been uploaded
1411 8767c0bb7d48 plugin radiocol: radiocolSongAdded now gets a JID as argument, add _radiocolSongAdded working with unicode for bridge calls souliane <souliane@mailoo.org> parents: 1409 diff changeset	151 @param referee (jid.JID): JID of the referee in the room (room userhost + '/' + nick)
8767c0bb7d48 plugin radiocol: radiocolSongAdded now gets a JID as argument, add _radiocolSongAdded working with unicode for bridge calls souliane <souliane@mailoo.org> parents: 1409 diff changeset	152 @param song_path (unicode): absolute path of the song added
8767c0bb7d48 plugin radiocol: radiocolSongAdded now gets a JID as argument, add _radiocolSongAdded working with unicode for bridge calls souliane <souliane@mailoo.org> parents: 1409 diff changeset	153 @param profile_key (unicode): %(doc_profile_key)s
849 c5a8f602662b plugin room_game, radiocol: RoomGame.send returns a Deferred. souliane <souliane@mailoo.org> parents: 828 diff changeset	154 @return: a Deferred instance
c5a8f602662b plugin room_game, radiocol: RoomGame.send returns a Deferred. souliane <souliane@mailoo.org> parents: 828 diff changeset	155 """
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	156 # XXX: this is a Q&D way for the proof of concept. In the future, the song should
455 72522263cbc9 plugin RadioCol: basic functionnality working approximately Goffi <goffi@goffi.org> parents: 453 diff changeset	157 # be streamed to the backend using XMPP file copy
72522263cbc9 plugin RadioCol: basic functionnality working approximately Goffi <goffi@goffi.org> parents: 453 diff changeset	158 # 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	159 # 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	160 try:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	161 if song_path.lower().endswith(".mp3"):
901 c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	162 actual_song = MP3(song_path)
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	163 try:
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	164 song = EasyID3(song_path)
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	165
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	166 class Info(object):
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	167 def __init__(self, length):
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	168 self.length = length
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	169
901 c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	170 song.info = Info(actual_song.info.length)
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	171 except ID3NoHeaderError:
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	172 song = actual_song
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	173 else:
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	174 song = OggVorbis(song_path)
c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	175 except (OggVorbisHeaderError, HeaderNotFoundError):
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	176 # 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	177 self.deleteFile(song_path) # FIXME: same host trick (see note above)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	178 return defer.fail(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	179 exceptions.DataError(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	180 D_(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	181 "The uploaded file has been rejected, only Ogg Vorbis and MP3 songs are accepted."
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	182 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	183 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	184 )
901 c238d2c02237 plugin radiocol: add MP3 support souliane <souliane@mailoo.org> parents: 849 diff changeset	185
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	186 attrs = {
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	187 "filename": os.path.basename(song_path),
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	188 "title": song.get("title", ["Unknown"])[0],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	189 "artist": song.get("artist", ["Unknown"])[0],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	190 "album": song.get("album", ["Unknown"])[0],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	191 "length": str(song.info.length),
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	192 }
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	193 radio_data = self.games[
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	194 referee.userhostJID()
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	195 ] # FIXME: referee comes from Libervia's client side, it's unsecure
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	196 radio_data["to_delete"][
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	197 attrs["filename"]
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	198 ] = (
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	199 song_path
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	200 ) # FIXME: works only because of the same host trick, see the note under the docstring
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	201 return self.send(referee, ("", "song_added"), attrs, profile=profile)
455 72522263cbc9 plugin RadioCol: basic functionnality working approximately Goffi <goffi@goffi.org> parents: 453 diff changeset	202
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	203 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	204 """"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	205 which trigger after the song has been played to play next one"""
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	206 # 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	207 # ==> unlink done the Q&D way with the same host trick (see above)
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	208 radio_data = self.games[room_jid]
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	209 if len(radio_data["players"]) == 0:
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	210 log.debug(_(u"No more participants in the radiocol: cleaning data"))
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	211 radio_data["queue"] = []
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	212 for filename in radio_data["to_delete"]:
764 d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	213 self.deleteFile(filename, radio_data)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	214 radio_data["to_delete"] = {}
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	215 queue = radio_data["queue"]
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	216 if not queue:
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	217 # nothing left to play, we need to wait for uploads
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	218 radio_data["playing"] = None
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	219 return
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	220 song = queue.pop(0)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	221 filename, length = song["filename"], float(song["length"])
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	222 self.send(room_jid, ("", "play"), {"filename": filename}, profile=profile)
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	223 radio_data["playing"] = song
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	224 radio_data["playing_time"] = time.time()
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	225
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	226 if not radio_data["upload"] and len(queue) < QUEUE_LIMIT:
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	227 # upload is blocked and we now have resources to get more, we reactivate it
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	228 self.send(room_jid, ("", "upload_ok"), profile=profile)
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	229 radio_data["upload"] = True
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	230
fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	231 reactor.callLater(length, self.playNext, room_jid, profile)
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	232 # we wait more than the song length to delete the file, to manage poorly reactive networks/clients
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	233 reactor.callLater(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	234 length + 90, self.deleteFile, filename, radio_data
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	235 ) # 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	236
764 d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	237 def deleteFile(self, filename, radio_data=None):
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	238 """
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	239 Delete a previously uploaded file.
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	240 @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	241 @param radio_data: current game data
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	242 @return: True if the file has been deleted
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	243 """
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	244 if radio_data:
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	245 try:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	246 file_to_delete = radio_data["to_delete"][filename]
764 d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	247 except KeyError:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	248 log.error(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	249 _(u"INTERNAL ERROR: can't find full path of the song to delete")
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	250 )
764 d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	251 return False
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	252 else:
d0e809014ea2 plugin radiocol: fix wrong call of deleteFile souliane <souliane@mailoo.org> parents: 746 diff changeset	253 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	254 try:
539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	255 unlink(file_to_delete)
539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	256 except OSError:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	257 log.error(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	258 _(u"INTERNAL ERROR: can't find %s on the file system" % file_to_delete)
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	259 )
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	260 return False
539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	261 return True
455 72522263cbc9 plugin RadioCol: basic functionnality working approximately Goffi <goffi@goffi.org> parents: 453 diff changeset	262
717 358018c5c398 plugins (games): more factorization and flexibility for launching and joining games: souliane <souliane@mailoo.org> parents: 714 diff changeset	263 def room_game_cmd(self, mess_elt, profile):
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	264 from_jid = jid.JID(mess_elt["from"])
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	265 room_jid = from_jid.userhostJID()
83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	266 nick = self.host.plugins["XEP-0045"].getRoomNick(room_jid, profile)
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	267
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	268 radio_elt = mess_elt.firstChildElement()
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	269 radio_data = self.games[room_jid]
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	270 if "queue" in radio_data:
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	271 queue = radio_data["queue"]
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 577 diff changeset	272
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	273 from_referee = self.isReferee(room_jid, from_jid.resource)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	274 to_referee = self.isReferee(room_jid, jid.JID(mess_elt["to"]).user)
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	275 is_player = self.isPlayer(room_jid, nick)
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	276 for elt in radio_elt.elements():
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	277 if not from_referee and not (to_referee and elt.name == "song_added"):
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	278 continue # sender must be referee, expect when a song is submitted
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	279 if not is_player and (elt.name not in ("started", "players")):
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	280 continue # user is in the room but not playing
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 577 diff changeset	281
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	282 if elt.name in (
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	283 "started",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	284 "players",
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	285 ): # 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	286 players = []
358018c5c398 plugins (games): more factorization and flexibility for launching and joining games: souliane <souliane@mailoo.org> parents: 714 diff changeset	287 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	288 players.append(unicode(player))
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	289 signal = (
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	290 self.host.bridge.radiocolStarted
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	291 if elt.name == "started"
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	292 else self.host.bridge.radiocolPlayers
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	293 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	294 signal(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	295 room_jid.userhost(),
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	296 from_jid.full(),
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	297 players,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	298 [QUEUE_TO_START, QUEUE_LIMIT],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	299 profile,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	300 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	301 elif elt.name == "preload": # a song is in queue and must be preloaded
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	302 self.host.bridge.radiocolPreload(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	303 room_jid.userhost(),
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	304 elt["timestamp"],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	305 elt["filename"],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	306 elt["title"],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	307 elt["artist"],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	308 elt["album"],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	309 elt["sender"],
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	310 profile,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	311 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	312 elif elt.name == "play":
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	313 self.host.bridge.radiocolPlay(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	314 room_jid.userhost(), elt["filename"], profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	315 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	316 elif elt.name == "song_rejected": # a song has been refused
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	317 self.host.bridge.radiocolSongRejected(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	318 room_jid.userhost(), elt["reason"], profile
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	319 )
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	320 elif elt.name == "no_upload":
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	321 self.host.bridge.radiocolNoUpload(room_jid.userhost(), profile)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	322 elif elt.name == "upload_ok":
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	323 self.host.bridge.radiocolUploadOk(room_jid.userhost(), profile)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	324 elif elt.name == "song_added": # a song has been added
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	325 # FIXME: we are KISS for the proof of concept: every song is added, to a limit of 3 in queue.
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	326 # 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	327 if len(queue) >= QUEUE_LIMIT:
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	328 # there are already too many songs in queue, we reject this one
83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	329 # FIXME: add an error code
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	330 self.send(
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	331 from_jid,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	332 ("", "song_rejected"),
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	333 {"reason": "Too many songs in queue"},
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	334 profile=profile,
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	335 )
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	336 return
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 577 diff changeset	337
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	338 # 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	339 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	340 queue.append(preload_elt)
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	341
fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	342 if len(queue) >= QUEUE_LIMIT:
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	343 # We are at the limit, we refuse new upload until next play
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	344 self.send(room_jid, ("", "no_upload"), profile=profile)
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	345 radio_data["upload"] = False
457 fbe7c9118ce4 plugin radiocol: working Radio Collective \o/ Goffi <goffi@goffi.org> parents: 456 diff changeset	346
714 ecc5a5b34ee1 plugins (games): add a method to send messages more easily souliane <souliane@mailoo.org> parents: 712 diff changeset	347 self.send(room_jid, preload_elt, profile=profile)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	348 if not radio_data["playing"] and len(queue) == QUEUE_TO_START:
746 539f278bc265 plugin room_games, radiocol: send the current queue to new players souliane <souliane@mailoo.org> parents: 718 diff changeset	349 # 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	350 # 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	351 self.playNext(room_jid, profile)
450 afe9cfd2ddbb plugins: radio collective first draft Goffi <goffi@goffi.org> parents: diff changeset	352 else:
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	353 log.error(_(u"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	354
1359 83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	355 def getSyncDataForPlayer(self, room_jid, nick):
83127a4c89ce plugins room_game, quiz, radiocol, tarot: use JID instead of unicode in many methods + class attributes souliane <souliane@mailoo.org> parents: 1257 diff changeset	356 game_data = self.games[room_jid]
828 8f335c03eebb plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance souliane <souliane@mailoo.org> parents: 827 diff changeset	357 elements = []
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	358 if game_data["playing"]:
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	359 preload = copy.deepcopy(game_data["playing"])
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	360 current_time = game_data["playing_time"] + 1 if self.testing else time.time()
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	361 preload["filename"] += "#t=%.2f" % (current_time - game_data["playing_time"])
828 8f335c03eebb plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance souliane <souliane@mailoo.org> parents: 827 diff changeset	362 elements.append(preload)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	363 play = domish.Element(("", "play"))
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	364 play["filename"] = preload["filename"]
828 8f335c03eebb plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance souliane <souliane@mailoo.org> parents: 827 diff changeset	365 elements.append(play)
2624 56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	366 if len(game_data["queue"]) > 0:
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	367 elements.extend(copy.deepcopy(game_data["queue"]))
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	368 if len(game_data["queue"]) == QUEUE_LIMIT:
56f94936df1e code style reformatting using black Goffi <goffi@goffi.org> parents: 2562 diff changeset	369 elements.append(domish.Element(("", "no_upload")))
828 8f335c03eebb plugins room_games, radiocol, libervia: small changes like refactorization to ease the maintenance souliane <souliane@mailoo.org> parents: 827 diff changeset	370 return elements

Mercurial > libervia-backend

annotate sat/plugins/plugin_misc_radiocol.py @ 2646:712cb4ff3e13