From 3df1a6bbfb66aac4bd18c042929a7ba845e0b9f1 Mon Sep 17 00:00:00 2001 From: Arjen Hiemstra Date: Mon, 20 Jan 2025 14:41:03 +0100 Subject: [PATCH] Fix: Deezer tracks that have been replaced with a newer version fail to play Some tracks have been replaced by a newer version. When this happens, the old track information stays available but it will fail to play because the stream has become invalid. Fortunately, the playback API provides the track replacement in a "FALLBACK" entry. So when we encounter a track that has a "FALLBACK" entry, use the information from that entry rather than the main track entry for the stream. Fixes music-assistant/support#3466 --- music_assistant/providers/deezer/__init__.py | 10 +++++++--- music_assistant/providers/deezer/gw_client.py | 16 +++++++++++++--- 2 files changed, 20 insertions(+), 6 deletions(-) diff --git a/music_assistant/providers/deezer/__init__.py b/music_assistant/providers/deezer/__init__.py index 994c14b8f..be29c8b05 100644 --- a/music_assistant/providers/deezer/__init__.py +++ b/music_assistant/providers/deezer/__init__.py @@ -441,7 +441,10 @@ async def get_stream_details( ), stream_type=StreamType.CUSTOM, duration=int(song_data["DURATION"]), - data={"url": url, "format": url_details["format"]}, + # Due to track replacement, the track ID of the stream may be different from the ID + # that is stored. We need the proper track ID to decrypt the stream, so store it + # separately so we can use it later on. + data={"url": url, "format": url_details["format"], "track_id": song_data["SNG_ID"]}, size=int(song_data[f"FILESIZE_{url_details['format']}"]), ) @@ -449,7 +452,7 @@ async def get_audio_stream( self, streamdetails: StreamDetails, seek_position: int = 0 ) -> AsyncGenerator[bytes, None]: """Return the audio stream for the provider item.""" - blowfish_key = self.get_blowfish_key(streamdetails.item_id) + blowfish_key = self.get_blowfish_key(streamdetails.data["track_id"]) chunk_index = 0 timeout = ClientTimeout(total=0, connect=30, sock_read=600) headers = {} @@ -671,7 +674,8 @@ def parse_track(self, track: deezer.Track, user_country: str, position: int = 0) ) }, metadata=self.parse_metadata_track(track=track), - track_number=position, + track_number=track.track_position, + disc_number=track.disk_number, position=position, disc_number=getattr(track, "disk_number", 0), ) diff --git a/music_assistant/providers/deezer/gw_client.py b/music_assistant/providers/deezer/gw_client.py index e0e83f753..f5dda1eba 100644 --- a/music_assistant/providers/deezer/gw_client.py +++ b/music_assistant/providers/deezer/gw_client.py @@ -128,8 +128,18 @@ async def get_song_data(self, track_id): async def get_deezer_track_urls(self, track_id): """Get the URL for a given track id.""" dz_license = await self._get_license() - song_data = await self.get_song_data(track_id) - track_token = song_data["results"]["TRACK_TOKEN"] + + song_results = await self.get_song_data(track_id) + + song_data = song_results["results"] + # If the song has been replaced by a newer version, the old track will + # not play anymore. The data for the newer song is contained in a + # "FALLBACK" entry in the song data. So if that is available, use that + # instead so we get the right track token. + if "FALLBACK" in song_data: + song_data = song_data["FALLBACK"] + + track_token = song_data["TRACK_TOKEN"] url_data = { "license_token": dz_license, "media": [ @@ -151,7 +161,7 @@ async def get_deezer_track_urls(self, track_id): msg = "Received an error from API" raise DeezerGWError(msg, error) - return result_json["data"][0]["media"][0], song_data["results"] + return result_json["data"][0]["media"][0], song_data async def log_listen( self, next_track: str | None = None, last_track: StreamDetails | None = None