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

test: fix the tests

Browse source
This commit is contained in:
souliane 2015-04-17 19:06:39 +02:00
commit f34a5b8aaf
1 changed files with 206 additions and 211 deletions
Download patch file Download diff file Expand all files Collapse all files

72
src/test/test_plugin_misc_radiocol.py
View file

@ -42,12 +42,12 @@ import copy
import shutil
from logging import WARNING
ROOM_JID_S = Const.MUC_STR[0]
ROOM_JID = JID(Const.MUC_STR[0])
PROFILE = Const.PROFILE[0]
REFEREE_FULL = ROOM_JID_S + '/' + Const.JID[0].user
REFEREE_FULL = JID(ROOM_JID.userhost() + '/' + Const.JID[0].user)
PLAYERS_INDICES = [0, 1, 3] # referee included
OTHER_PROFILES = [Const.PROFILE[1], Const.PROFILE[3]]
OTHER_PLAYERS = [Const.JID_STR[1], Const.JID_STR[3]]
OTHER_PLAYERS = [Const.JID[1], Const.JID[3]]
class RadiocolTest(helpers.SatTestCase):
@ -62,12 +62,8 @@ class RadiocolTest(helpers.SatTestCase):
self.plugin.testing = True
self.plugin_0045 = self.host.plugins['XEP-0045'] = helpers_plugins.FakeXEP_0045(self.host)
self.plugin_0249 = self.host.plugins['XEP-0249'] = helpers_plugins.FakeXEP_0249(self.host)
logger = getLogger()
level = logger.getEffectiveLevel()
logger.setLevel(WARNING) # remove log.info pollution
for profile in Const.PROFILE:
self.host.getClient(profile) # init self.host.profiles[profile]
logger.setLevel(level)
self.songs = []
self.playlist = []
self.sound_dir = self.host.memory.getConfig('', 'media_dir') + '/test/sound/'
@ -90,9 +86,9 @@ class RadiocolTest(helpers.SatTestCase):
content += "</started>"
return content
def _expectedMessage(self, to_s, type_, content):
def _expectedMessage(self, to_jid, type_, content):
"""
@param to_s: recipient full jid as unicode
@param to_jid: recipient full jid
@param type_: message type ('normal' or 'groupchat')
@param content: content as unicode or list of domish elements
@return: the message XML built from the given recipient, message type and content
@ -103,7 +99,7 @@ class RadiocolTest(helpers.SatTestCase):
if not element.hasAttribute('xmlns'):
element['xmlns'] = ''
content = "".join([element.toXml() for element in new_content])
return "<message to='%s' type='%s'><%s xmlns='%s'>%s</%s></message>" % (to_s, type_, plugin.RADIOC_TAG, plugin.NC_RADIOCOL, content, plugin.RADIOC_TAG)
return "<message to='%s' type='%s'><%s xmlns='%s'>%s</%s></message>" % (to_jid.full(), type_, plugin.RADIOC_TAG, plugin.NC_RADIOCOL, content, plugin.RADIOC_TAG)
def _rejectSongCb(self, profile_index):
"""Check if the message "song_rejected" has been sent by the referee
@ -111,24 +107,24 @@ class RadiocolTest(helpers.SatTestCase):
@param profile_index: uploader's profile"""
sent = self.host.getSentMessage(0)
content = "<song_rejected xmlns='' reason='Too many songs in queue'/>"
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID_S + '/' + self.plugin_0045.getNick(0, profile_index), 'normal', content))
self._roomGameCmd(sent, ['radiocolSongRejected', ROOM_JID_S, 'Too many songs in queue'])
self.assertEqualXML(sent.toXml(), self._expectedMessage(JID(ROOM_JID.userhost() + '/' + self.plugin_0045.getNick(0, profile_index), 'normal', content)))
self._roomGameCmd(sent, ['radiocolSongRejected', ROOM_JID.full(), 'Too many songs in queue'])
def _noUploadCb(self):
"""Check if the message "no_upload" has been sent by the referee
and process the command with the profiles of each room users"""
sent = self.host.getSentMessage(0)
content = "<no_upload xmlns=''/>"
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID_S, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolNoUpload', ROOM_JID_S])
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolNoUpload', ROOM_JID.full()])
def _uploadOkCb(self):
"""Check if the message "upload_ok" has been sent by the referee
and process the command with the profiles of each room users"""
sent = self.host.getSentMessage(0)
content = "<upload_ok xmlns=''/>"
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID_S, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolUploadOk', ROOM_JID_S])
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolUploadOk', ROOM_JID.full()])
def _preloadCb(self, attrs, profile_index):
"""Check if the message "preload" has been sent by the referee
@ -144,8 +140,8 @@ class RadiocolTest(helpers.SatTestCase):
content = "<preload xmlns='' %s/>" % " ".join(["%s='%s'" % (attr, attrs[attr]) for attr in attrs])
if sent.hasAttribute('from'):
del sent['from']
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID_S, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolPreload', ROOM_JID_S, attrs['timestamp'], attrs['filename'], attrs['title'], attrs['artist'], attrs['album'], attrs['sender']])
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolPreload', ROOM_JID.full(), attrs['timestamp'], attrs['filename'], attrs['title'], attrs['artist'], attrs['album'], attrs['sender']])
def _playNextSongCb(self):
"""Check if the message "play" has been sent by the referee
@ -153,10 +149,10 @@ class RadiocolTest(helpers.SatTestCase):
sent = self.host.getSentMessage(0)
filename = self.playlist.pop(0)
content = "<play xmlns='' filename='%s' />" % filename
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID_S, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolPlay', ROOM_JID_S, filename])
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID, 'groupchat', content))
self._roomGameCmd(sent, ['radiocolPlay', ROOM_JID.full(), filename])
game_data = self.plugin.games[ROOM_JID_S]
game_data = self.plugin.games[ROOM_JID]
if len(game_data['queue']) == plugin.QUEUE_LIMIT - 1:
self._uploadOkCb()
@ -170,7 +166,7 @@ class RadiocolTest(helpers.SatTestCase):
if isinstance(d, Failure):
self.fail("OGG song could not be added!")
game_data = self.plugin.games[ROOM_JID_S]
game_data = self.plugin.games[ROOM_JID]
song = OggVorbis(filepath)
attrs = {'filename': os.path.basename(filepath),
'title': song.get("title", ["Unknown"])[0],
@ -213,7 +209,7 @@ class RadiocolTest(helpers.SatTestCase):
call = from_index
from_index = 0
sent['from'] = ROOM_JID_S + '/' + self.plugin_0045.getNick(0, from_index)
sent['from'] = ROOM_JID.full() + '/' + self.plugin_0045.getNick(0, from_index)
recipient = JID(sent['to']).resource
# The message could have been sent to a room user (room_jid + '/' + nick),
@ -227,7 +223,7 @@ class RadiocolTest(helpers.SatTestCase):
nick = self.plugin_0045.getNick(0, index)
if nick:
if not recipient or nick == recipient:
if call and (self.plugin.isPlayer(ROOM_JID_S, nick) or call[0] == 'radiocolStarted'):
if call and (self.plugin.isPlayer(ROOM_JID, nick) or call[0] == 'radiocolStarted'):
args = copy.deepcopy(call)
args.append(Const.PROFILE[index])
self.host.bridge.expectCall(*args)
@ -239,16 +235,16 @@ class RadiocolTest(helpers.SatTestCase):
@param profile_index: index of the profile to be synchronized
"""
for nick in sync_data:
expected = self._expectedMessage(ROOM_JID_S + '/' + nick, 'normal', sync_data[nick])
expected = self._expectedMessage(JID(ROOM_JID.userhost() + '/' + nick), 'normal', sync_data[nick])
sent = self.host.getSentMessage(0)
self.assertEqualXML(sent.toXml(), expected)
for elt in sync_data[nick]:
if elt.name == 'preload':
self.host.bridge.expectCall('radiocolPreload', ROOM_JID_S, elt['timestamp'], elt['filename'], elt['title'], elt['artist'], elt['album'], elt['sender'], Const.PROFILE[profile_index])
self.host.bridge.expectCall('radiocolPreload', ROOM_JID.full(), elt['timestamp'], elt['filename'], elt['title'], elt['artist'], elt['album'], elt['sender'], Const.PROFILE[profile_index])
elif elt.name == 'play':
self.host.bridge.expectCall('radiocolPlay', ROOM_JID_S, elt['filename'], Const.PROFILE[profile_index])
self.host.bridge.expectCall('radiocolPlay', ROOM_JID.full(), elt['filename'], Const.PROFILE[profile_index])
elif elt.name == 'no_upload':
self.host.bridge.expectCall('radiocolNoUpload', ROOM_JID_S, Const.PROFILE[profile_index])
self.host.bridge.expectCall('radiocolNoUpload', ROOM_JID.full(), Const.PROFILE[profile_index])
sync_data[nick]
self._roomGameCmd(sent, [])
@ -263,13 +259,13 @@ class RadiocolTest(helpers.SatTestCase):
self.plugin.userJoinedTrigger(room, room.roster[user_nick], PROFILE)
if player_index not in PLAYERS_INDICES:
# this user is actually not a player
self.assertFalse(self.plugin.isPlayer(ROOM_JID_S, user_nick))
to_jid, type_ = (ROOM_JID_S + '/' + user_nick, 'normal')
self.assertFalse(self.plugin.isPlayer(ROOM_JID, user_nick))
to_jid, type_ = (JID(ROOM_JID.userhost() + '/' + user_nick), 'normal')
else:
# this user is a player
self.assertTrue(self.plugin.isPlayer(ROOM_JID_S, user_nick))
self.assertTrue(self.plugin.isPlayer(ROOM_JID, user_nick))
nicks.append(user_nick)
to_jid, type_ = (ROOM_JID_S, 'groupchat')
to_jid, type_ = (ROOM_JID, 'groupchat')
# Check that the message "players" has been sent by the referee
expected = self._expectedMessage(to_jid, type_, self._buildPlayers(nicks))
@ -277,10 +273,10 @@ class RadiocolTest(helpers.SatTestCase):
self.assertEqualXML(sent.toXml(), expected)
# Process the command with the profiles of each room users
self._roomGameCmd(sent, ['radiocolStarted', ROOM_JID_S, REFEREE_FULL, nicks, [plugin.QUEUE_TO_START, plugin.QUEUE_LIMIT]])
self._roomGameCmd(sent, ['radiocolStarted', ROOM_JID.full(), REFEREE_FULL.full(), nicks, [plugin.QUEUE_TO_START, plugin.QUEUE_LIMIT]])
if sync:
self._syncCb(self.plugin._getSyncData(ROOM_JID_S, [user_nick]), player_index)
self._syncCb(self.plugin._getSyncData(ROOM_JID, [user_nick]), player_index)
def _leaveRoom(self, room, nicks, player_index):
"""Make a player leave a room and update the list of nicks
@ -342,14 +338,14 @@ class RadiocolTest(helpers.SatTestCase):
self.reinit()
# create game
self.plugin.prepareRoom(OTHER_PLAYERS, ROOM_JID_S, PROFILE)
self.assertTrue(self.plugin._gameExists(ROOM_JID_S, True))
self.plugin.prepareRoom(OTHER_PLAYERS, ROOM_JID, PROFILE)
self.assertTrue(self.plugin._gameExists(ROOM_JID, True))
room = self.plugin_0045.getRoom(0, 0)
nicks = [self.plugin_0045.getNick(0, 0)]
sent = self.host.getSentMessage(0)
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID_S, 'groupchat', self._buildPlayers(nicks)))
self._roomGameCmd(sent, ['radiocolStarted', ROOM_JID_S, REFEREE_FULL, nicks, [plugin.QUEUE_TO_START, plugin.QUEUE_LIMIT]])
self.assertEqualXML(sent.toXml(), self._expectedMessage(ROOM_JID, 'groupchat', self._buildPlayers(nicks)))
self._roomGameCmd(sent, ['radiocolStarted', ROOM_JID.full(), REFEREE_FULL.full(), nicks, [plugin.QUEUE_TO_START, plugin.QUEUE_LIMIT]])
self._joinRoom(room, nicks, 1) # player joins
self._joinRoom(room, nicks, 4) # user not playing joins