Merge pull request #42 from mopidy/mopidy-4.0.0a8

Author: jodal

pyproject.toml

@@ -14,7 +14,7 @@ classifiers = [
 ]
 dynamic = ["version"]
 dependencies = [
-    "mopidy >= 4.0.0a7",
+    "mopidy >= 4.0.0a8",
     "pydbus >= 0.6.0",
     "pykka >= 4.1",
 ]

src/mopidy_mpris/player.py

@@ -6,7 +6,7 @@
 import logging
 
 from gi.repository.GLib import Variant
-from mopidy.core import PlaybackState
+from mopidy.types import PlaybackState
 from pydbus.generic import signal
 
 from mopidy_mpris.interface import Interface

tests/dummy_audio.py

@@ -4,21 +4,23 @@
 tests of the core and backends.
 """
 
+from typing import override
+
 import pykka
 from mopidy import audio
+from mopidy.types import DurationMs, PlaybackState
 
 
 def create_proxy(config=None, mixer=None):
     return DummyAudio.start(config, mixer).proxy()
 
 
 # TODO: reset position on track change?
-class DummyAudio(pykka.ThreadingActor):
+class DummyAudio(audio.Audio, pykka.ThreadingActor):
     def __init__(self, config=None, mixer=None):
         super().__init__()
-        self.state = audio.PlaybackState.STOPPED
-        self._volume = 0
-        self._position = 0
+        self.state = PlaybackState.STOPPED
+        self._position = DurationMs(0)
         self._source_setup_callback = None
         self._about_to_finish_callback = None
         self._uri = None
@@ -27,72 +29,60 @@ def __init__(self, config=None, mixer=None):
         self._tags = {}
         self._bad_uris = set()
 
-    def set_uri(self, uri, live_stream=False, download=False):  # noqa: FBT002
+    @override
+    def set_uri(self, uri, live_stream=False, download=False):
         assert self._uri is None, "prepare change not called before set"
-        self._position = 0
+        self._position = DurationMs(0)
         self._uri = uri
         self._stream_changed = True
         self._live_stream = live_stream
         self._tags = {}
 
-    def set_appsrc(self, *args, **kwargs):
-        pass
+    @override
+    def set_source_setup_callback(self, callback):
+        self._source_setup_callback = callback
 
-    def emit_data(self, buffer_):
-        pass
+    @override
+    def set_about_to_finish_callback(self, callback):
+        self._about_to_finish_callback = callback
 
+    @override
     def get_position(self):
         return self._position
 
+    @override
     def set_position(self, position):
         self._position = position
         audio.AudioListener.send("position_changed", position=position)
         return True
 
+    @override
     def start_playback(self):
-        return self._change_state(audio.PlaybackState.PLAYING)
+        return self._change_state(PlaybackState.PLAYING)
 
+    @override
     def pause_playback(self):
-        return self._change_state(audio.PlaybackState.PAUSED)
+        return self._change_state(PlaybackState.PAUSED)
 
+    @override
     def prepare_change(self):
         self._uri = None
         self._source_setup_callback = None
         return True
 
+    @override
     def stop_playback(self):
-        return self._change_state(audio.PlaybackState.STOPPED)
-
-    def get_volume(self):
-        return self._volume
-
-    def set_volume(self, volume):
-        self._volume = volume
-        return True
-
-    def set_metadata(self, track):
-        pass
+        return self._change_state(PlaybackState.STOPPED)
 
+    @override
     def get_current_tags(self):
         return self._tags
 
-    def set_source_setup_callback(self, callback):
-        self._source_setup_callback = callback
-
-    def set_about_to_finish_callback(self, callback):
-        self._about_to_finish_callback = callback
-
-    def enable_sync_handler(self):
-        pass
-
-    def wait_for_state_change(self):
-        pass
-
     def _change_state(self, new_state):
         if not self._uri:
             return False
 
-        if new_state == audio.PlaybackState.STOPPED and self._uri:
+        if new_state == PlaybackState.STOPPED and self._uri:
             self._stream_changed = True
             self._uri = None
 
@@ -111,39 +101,12 @@ def _change_state(self, new_state):
             target_state=None,
         )
 
-        if new_state == audio.PlaybackState.PLAYING:
+        if new_state == PlaybackState.PLAYING:
             self._tags["audio-codec"] = ["fake info..."]
             audio.AudioListener.send("tags_changed", tags=["audio-codec"])
 
         return self._uri not in self._bad_uris
 
-    def trigger_fake_playback_failure(self, uri):
-        self._bad_uris.add(uri)
-
     def trigger_fake_tags_changed(self, tags):
         self._tags.update(tags)
         audio.AudioListener.send("tags_changed", tags=self._tags.keys())
-
-    def get_source_setup_callback(self):
-        # This needs to be called from outside the actor or we lock up.
-        def wrapper():
-            if self._source_setup_callback:
-                self._source_setup_callback()
-
-        return wrapper
-
-    def get_about_to_finish_callback(self):
-        # This needs to be called from outside the actor or we lock up.
-        def wrapper():
-            if self._about_to_finish_callback:
-                self.prepare_change()
-                self._about_to_finish_callback()
-
-            if not self._uri or not self._about_to_finish_callback:
-                self._tags = {}
-                audio.AudioListener.send("reached_end_of_stream")
-            else:
-                audio.AudioListener.send("position_changed", position=0)
-                audio.AudioListener.send("stream_changed", uri=self._uri)
-
-        return wrapper

tests/test_player.py

@@ -1,7 +1,7 @@
 import pytest
 from gi.repository import GLib
-from mopidy.core import PlaybackState
 from mopidy.models import Album, Artist, Image, Track
+from mopidy.types import PlaybackState
 
 from mopidy_mpris.player import Player
 

tests/test_playlists.py

@@ -1,6 +1,6 @@
 import pytest
-from mopidy.audio import PlaybackState
 from mopidy.models import Track
+from mopidy.types import PlaybackState
 
 from mopidy_mpris.playlists import Playlists