andpp/mopidy
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Renable some output tests

Browse Source
This commit is contained in:
Thomas Adamcik 2010-08-19 00:52:42 +02:00
parent a20251daac
commit cf24089137
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tests/outputs/gstreamer_test.py
View File

@ -1,6 +1,7 @@
import multiprocessing import multiprocessing
import unittest import unittest
from mopidy import settings
from mopidy.outputs.gstreamer import GStreamerOutput from mopidy.outputs.gstreamer import GStreamerOutput
from mopidy.process import pickle_connection from mopidy.process import pickle_connection
from mopidy.utils.path import path_to_uri from mopidy.utils.path import path_to_uri
@ -9,6 +10,8 @@ from tests import data_folder, SkipTest
class GStreamerOutputTest(unittest.TestCase): class GStreamerOutputTest(unittest.TestCase):
def setUp(self): def setUp(self):
self.original_backends = settings.BACKENDS
settings.BACKENDS = ('mopidy.backends.local.LocalBackend',)
self.song_uri = path_to_uri(data_folder('song1.wav')) self.song_uri = path_to_uri(data_folder('song1.wav'))
self.output_queue = multiprocessing.Queue() self.output_queue = multiprocessing.Queue()
self.core_queue = multiprocessing.Queue() self.core_queue = multiprocessing.Queue()
@ -16,6 +19,7 @@ class GStreamerOutputTest(unittest.TestCase):
def tearDown(self): def tearDown(self):
self.output.destroy() self.output.destroy()
settings.BACKENDS = settings.original_backends
def send_recv(self, message): def send_recv(self, message):
(my_end, other_end) = multiprocessing.Pipe() (my_end, other_end) = multiprocessing.Pipe()
@ -24,35 +28,30 @@ class GStreamerOutputTest(unittest.TestCase):
my_end.poll(None) my_end.poll(None)
return my_end.recv() return my_end.recv()
def send(self, message): def send(self, message):
self.output_queue.put(message) self.output_queue.put(message)
@SkipTest
def test_play_uri_existing_file(self): def test_play_uri_existing_file(self):
message = {'command': 'play_uri', 'uri': self.song_uri} message = {'command': 'play_uri', 'uri': self.song_uri}
self.assertEqual(True, self.send_recv(message)) self.assertEqual(True, self.send_recv(message))
@SkipTest
def test_play_uri_non_existing_file(self): def test_play_uri_non_existing_file(self):
message = {'command': 'play_uri', 'uri': self.song_uri + 'bogus'} message = {'command': 'play_uri', 'uri': self.song_uri + 'bogus'}
self.assertEqual(False, self.send_recv(message)) self.assertEqual(False, self.send_recv(message))
@SkipTest
def test_default_get_volume_result(self): def test_default_get_volume_result(self):
message = {'command': 'get_volume'} message = {'command': 'get_volume'}
self.assertEqual(100, self.send_recv(message)) self.assertEqual(100, self.send_recv(message))
@SkipTest
def test_set_volume(self): def test_set_volume(self):
self.send({'command': 'set_volume', 'volume': 50}) self.send({'command': 'set_volume', 'volume': 50})
self.assertEqual(50, self.send_recv({'command': 'get_volume'})) self.assertEqual(50, self.send_recv({'command': 'get_volume'}))
@SkipTest
def test_set_volume_to_zero(self): def test_set_volume_to_zero(self):
self.send({'command': 'set_volume', 'volume': 0}) self.send({'command': 'set_volume', 'volume': 0})
self.assertEqual(0, self.send_recv({'command': 'get_volume'})) self.assertEqual(0, self.send_recv({'command': 'get_volume'}))
@SkipTest
def test_set_volume_to_one_hundred(self): def test_set_volume_to_one_hundred(self):
self.send({'command': 'set_volume', 'volume': 100}) self.send({'command': 'set_volume', 'volume': 100})
self.assertEqual(100, self.send_recv({'command': 'get_volume'})) self.assertEqual(100, self.send_recv({'command': 'get_volume'}))