Skip to content

Commit

Permalink
Fix: Deezer tracks that have been replaced with a newer version fail …
Browse files Browse the repository at this point in the history
…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
  • Loading branch information
awhiemstra committed Jan 20, 2025
1 parent 49aa75c commit 3df1a6b
Show file tree
Hide file tree
Showing 2 changed files with 20 additions and 6 deletions.
10 changes: 7 additions & 3 deletions music_assistant/providers/deezer/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -441,15 +441,18 @@ 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']}"]),
)

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 = {}
Expand Down Expand Up @@ -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),
)
Expand Down
16 changes: 13 additions & 3 deletions music_assistant/providers/deezer/gw_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -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": [
Expand All @@ -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
Expand Down

0 comments on commit 3df1a6b

Please sign in to comment.