Merge pull request #2742 from sayam93/sayam93-patch-1

closes #2739
alandtse · Dec 11, 2024 · 904aef9 · 904aef9
2 parents 2f0f525 + 2cd3b5f
commit 904aef9
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 20 deletions.
diff --git a/custom_components/alexa_media/const.py b/custom_components/alexa_media/const.py
@@ -111,13 +111,12 @@
 ATTR_EMAIL = "email"
 ATTR_NUM_ENTRIES = "entries"
 STREAMING_ERROR_MESSAGE = (
-    "Sorry folks! Amazon doesn't allow streaming music like this. "
-    "Please take it up with them!"
+    "Sorry, direct music streaming isn't supported. "
+    "This limitation is set by Amazon, and not by Alexa-Media-Player, Music-Assistant, nor Home-Assistant."
 )
 PUBLIC_URL_ERROR_MESSAGE = (
     "To send TTS, please set the public URL in integration configuration."
 )
-ANNOUNCE_ERROR_MESSAGE = "To send TTS, please set Announce=true."
 STARTUP = f"""
 -------------------------------------------------------------------
 {DOMAIN}

diff --git a/custom_components/alexa_media/media_player.py b/custom_components/alexa_media/media_player.py
@@ -41,7 +41,6 @@
 )
 from .alexa_media import AlexaMedia
 from .const import (
-    ANNOUNCE_ERROR_MESSAGE,
     DEPENDENT_ALEXA_COMPONENTS,
     MIN_TIME_BETWEEN_FORCED_SCANS,
     MIN_TIME_BETWEEN_SCANS,
@@ -1378,9 +1377,7 @@ async def async_send_dropin_notification(self, message, **kwargs):
             )
 
     @_catch_login_errors
-    async def async_play_tts_cloud_say(
-        self, media_type, public_url, media_id, **kwargs
-    ):
+    async def async_play_tts_cloud_say(self, public_url, media_id, **kwargs):
         file_name = media_id
         if media_source.is_media_source_id(media_id):
             media = await media_source.async_resolve_media(
@@ -1389,12 +1386,6 @@ async def async_play_tts_cloud_say(
             file_name = media.url[media.url.rindex("/") : media.url.rindex(".")]
             media_id = async_process_play_media_url(self.hass, media.url)
 
-        if media_type == "music":
-            # Log and notify for Amazon restriction on streaming music
-            _LOGGER.warning(STREAMING_ERROR_MESSAGE)
-            await self.async_send_tts(STREAMING_ERROR_MESSAGE)
-            return
-
         if kwargs.get(ATTR_MEDIA_ANNOUNCE):
             input_file_path = self.hass.config.path(
                 f"{UPLOAD_PATH}{file_name}_input.mp3"
@@ -1441,8 +1432,8 @@ async def async_play_tts_cloud_say(
                 f"<audio src='{public_url}local/alexa_tts{output_file_name}' />"
             )
         else:
-            await self.async_send_tts(ANNOUNCE_ERROR_MESSAGE)
-            _LOGGER.warning(ANNOUNCE_ERROR_MESSAGE)
+            await self.async_send_tts(STREAMING_ERROR_MESSAGE)
+            _LOGGER.warning(STREAMING_ERROR_MESSAGE)
 
     @_catch_login_errors
     async def async_play_media(self, media_type, media_id, enqueue=None, **kwargs):
@@ -1455,14 +1446,13 @@ async def async_play_media(self, media_type, media_id, enqueue=None, **kwargs):
             "options"
         ].get(CONF_PUBLIC_URL, DEFAULT_PUBLIC_URL)
         if media_type == "music":
-            if not public_url:
+            if public_url:
+                # Handle TTS playback
+                await self.async_play_tts_cloud_say(public_url, media_id, **kwargs)
+            else:
                 # Log and notify for missing public URL
                 _LOGGER.warning(PUBLIC_URL_ERROR_MESSAGE)
                 await self.async_send_tts(PUBLIC_URL_ERROR_MESSAGE)
-            else:
-                # Log and notify for Amazon restriction on streaming music
-                _LOGGER.warning(STREAMING_ERROR_MESSAGE)
-                await self.async_send_tts(STREAMING_ERROR_MESSAGE)
         elif media_type == "sequence":
             _LOGGER.debug(
                 "%s: %s:Running sequence %s with queue_delay %s",