From 7d64a8234f49a4d6cf88b19956a8f1f4a4aae945 Mon Sep 17 00:00:00 2001
From: Brian O'Connor <btoconnor@users.noreply.github.com>
Date: Wed, 23 Oct 2024 04:17:22 -0400
Subject: [PATCH] SiriusXM: live radio data in the stream title (#1739)

---
 .../server/providers/siriusxm/__init__.py     | 34 +++++++++++++++++--
 1 file changed, 31 insertions(+), 3 deletions(-)

diff --git a/music_assistant/server/providers/siriusxm/__init__.py b/music_assistant/server/providers/siriusxm/__init__.py
index fab10ffd5..b4c04f00f 100644
--- a/music_assistant/server/providers/siriusxm/__init__.py
+++ b/music_assistant/server/providers/siriusxm/__init__.py
@@ -42,7 +42,7 @@
 
 import sxm.http
 from sxm import SXMClientAsync
-from sxm.models import QualitySize, RegionChoice, XMChannel
+from sxm.models import QualitySize, RegionChoice, XMChannel, XMLiveChannel
 
 CONF_SXM_USERNAME = "sxm_email_address"
 CONF_SXM_PASSWORD = "sxm_password"
@@ -110,6 +110,8 @@ class SiriusXMProvider(MusicProvider):
     _sxm_server: Webserver
     _base_url: str
 
+    _current_stream_details: StreamDetails | None = None
+
     @property
     def supported_features(self) -> tuple[ProviderFeature, ...]:
         """Return the features supported by this Provider."""
@@ -203,7 +205,11 @@ async def get_stream_details(self, item_id: str) -> StreamDetails:
         """Get streamdetails for a track/radio."""
         hls_path = f"http://{self._base_url}/{item_id}.m3u8"
 
-        return StreamDetails(
+        # Keep a reference to the current `StreamDetails` object so that we can
+        # update the `stream_title` attribute as callbacks come in from the
+        # sxm-client with the channel's live data.
+        # See `_channel_updated` for where this is handled.
+        self._current_stream_details = StreamDetails(
             item_id=item_id,
             provider=self.instance_id,
             audio_format=AudioFormat(
@@ -215,6 +221,8 @@ async def get_stream_details(self, item_id: str) -> StreamDetails:
             can_seek=False,
         )
 
+        return self._current_stream_details
+
     async def browse(self, path: str) -> Sequence[MediaItemType | ItemMapping]:
         """Browse this provider's items.
 
@@ -223,7 +231,27 @@ async def browse(self, path: str) -> Sequence[MediaItemType | ItemMapping]:
         return [self._parse_radio(channel) for channel in self._channels]
 
     def _channel_updated(self, live_channel_raw: dict[str, Any]) -> None:
-        self.logger.debug(f"channel updated {live_channel_raw}")
+        """Handle a channel update event."""
+        live_data = XMLiveChannel.from_dict(live_channel_raw)
+
+        self.logger.debug(f"Got update for SiriusXM channel {live_data.id}")
+        current_channel = self._current_stream_details.item_id
+
+        if live_data.id != current_channel:
+            # This can happen when changing channels
+            self.logger.debug(
+                f"Received update for channel {live_data.id}, current channel is {current_channel}"
+            )
+            return
+
+        latest_cut_marker = live_data.get_latest_cut()
+
+        if latest_cut_marker:
+            latest_cut = latest_cut_marker.cut
+            title = latest_cut.title
+            artists = ", ".join([a.name for a in latest_cut.artists])
+
+            self._current_stream_details.stream_title = f"{title} - {artists}"
 
     async def _refresh_channels(self) -> bool:
         self._channels = await self._client.channels