updating the play prompts

Author: Vinothini Dharmaraj

sdk/communication/azure-communication-callautomation/azure/communication/callautomation/_call_connection_client.py

@@ -4,7 +4,7 @@
 # Licensed under the MIT License. See License.txt in the project root for
 # license information.
 # --------------------------------------------------------------------------
-from typing import TYPE_CHECKING, Optional, List, Union, Dict,  overload
+from typing import TYPE_CHECKING, Optional, List, Union, Dict
 from urllib.parse import urlparse
 import warnings
 
@@ -411,10 +411,11 @@ def remove_participant(
 
         return RemoveParticipantResult._from_generated(response) # pylint:disable=protected-access
 
-    @overload
+    @distributed_trace
     def play_media(
         self,
-        play_source: Union['FileSource', 'TextSource', 'SsmlSource'],
+        play_source: Union[Union['FileSource', 'TextSource', 'SsmlSource'],
+                           List[Union['FileSource', 'TextSource', 'SsmlSource']]],
         play_to: Union[Literal["all"], List['CommunicationIdentifier']] = 'all',
         *,
         loop: bool = False,
@@ -427,39 +428,8 @@ def play_media(
         :param play_source: A PlaySource representing the source to play.
         :type play_source: ~azure.communication.callautomation.FileSource or
          ~azure.communication.callautomation.TextSource or
-         ~azure.communication.callautomation.SsmlSource
-        :param play_to: The targets to play media to. Default value is 'all', to play media
-         to all participants in the call.
-        :type play_to: list[~azure.communication.callautomation.CommunicationIdentifier]
-        :keyword loop: Whether the media should be repeated until cancelled.
-        :paramtype loop: bool
-        :keyword operation_context: Value that can be used to track this call and its associated events.
-        :paramtype operation_context: str or None
-        :keyword operation_callback_url: Set a callback URL that overrides the default callback URL set
-         by CreateCall/AnswerCall for this operation.
-         This setup is per-action. If this is not set, the default callback URL set by
-         CreateCall/AnswerCall will be used.
-        :paramtype operation_callback_url: str or None
-        :return: None
-        :rtype: None
-        :raises ~azure.core.exceptions.HttpResponseError:
-        """
-
-    @overload
-    def play_media(
-        self,
-        play_sources: List[Union['FileSource', 'TextSource', 'SsmlSource']],
-        play_to: Union[Literal["all"], List['CommunicationIdentifier']] = 'all',
-        *,
-        loop: bool = False,
-        operation_context: Optional[str] = None,
-        operation_callback_url: Optional[str] = None,
-        **kwargs
-    ) -> None:
-        """Play media to specific participant(s) in this call.
-
-        :param play_sources: A PlaySource representing the source to play.
-        :type play_sources: list[~azure.communication.callautomation.FileSource] or
+         ~azure.communication.callautomation.SsmlSource or
+         list[~azure.communication.callautomation.FileSource] or
          list[~azure.communication.callautomation.TextSource] or
          list[~azure.communication.callautomation.SsmlSource]
         :param play_to: The targets to play media to. Default value is 'all', to play media
@@ -478,27 +448,19 @@ def play_media(
         :rtype: None
         :raises ~azure.core.exceptions.HttpResponseError:
         """
-
-    @distributed_trace
-    def play_media(
-        self,
-        **kwargs
-    ) -> None:
-
         self._play_media(
-            play_source=kwargs.pop("play_source", None),
-            play_sources=kwargs.pop("play_sources", None),
-            play_to=kwargs.pop("play_to", 'all'),
-            loop=kwargs.pop("loop", False),
-            operation_context=kwargs.pop("operation_context", None),
-            operation_callback_url=kwargs.pop("operation_callback_url", None),
+            play_source=play_source,
+            play_to=play_to,
+            loop=loop,
+            operation_context=operation_context,
+            operation_callback_url=operation_callback_url,
             **kwargs
         )
 
     def _play_media(
         self,
-        play_source: Union['FileSource', 'TextSource', 'SsmlSource'],
-        play_sources: Optional[ List[Union['FileSource', 'TextSource', 'SsmlSource']]],
+        play_source: Union[Union['FileSource', 'TextSource', 'SsmlSource'],
+                           List[Union['FileSource', 'TextSource', 'SsmlSource']]],
         play_to: Union[Literal["all"], List['CommunicationIdentifier']] = 'all',
         *,
         loop: bool = False,
@@ -512,9 +474,8 @@ def _play_media(
         :param play_source: A PlaySource representing the source to play.
         :type play_source: ~azure.communication.callautomation.FileSource or
          ~azure.communication.callautomation.TextSource or
-         ~azure.communication.callautomation.SsmlSource
-        :param play_sources: A PlaySource representing the source to play.
-        :type play_sources: list[~azure.communication.callautomation.FileSource] or
+         ~azure.communication.callautomation.SsmlSource or
+         list[~azure.communication.callautomation.FileSource] or
          list[~azure.communication.callautomation.TextSource] or
          list[~azure.communication.callautomation.SsmlSource]
         :param play_to: The targets to play media to. Default value is 'all', to play media
@@ -536,7 +497,9 @@ def _play_media(
         :rtype: None
         :raises ~azure.core.exceptions.HttpResponseError:
         """
+
         play_source_single: Optional[Union['FileSource', 'TextSource', 'SsmlSource']] = None
+        play_sources: Optional[List[Union['FileSource', 'TextSource', 'SsmlSource']]] = None
         if isinstance(play_source, list):
             if play_source:  # Check if the list is not empty
                 play_sources = play_source
@@ -556,10 +519,11 @@ def _play_media(
         )
         self._call_media_client.play(self._call_connection_id, play_request)
 
-    @overload
+    @distributed_trace
     def play_media_to_all(
         self,
-        play_source: Union['FileSource', 'TextSource', 'SsmlSource'],
+        play_source: Union[Union['FileSource', 'TextSource', 'SsmlSource'],
+                           List[Union['FileSource', 'TextSource', 'SsmlSource']]],
         *,
         loop: bool = False,
         operation_context: Optional[str] = None,
@@ -572,43 +536,8 @@ def play_media_to_all(
         :param play_source: A PlaySource representing the source to play.
         :type play_source: ~azure.communication.callautomation.FileSource or
          ~azure.communication.callautomation.TextSource or
-         ~azure.communication.callautomation.SsmlSource
-        :keyword loop: Whether the media should be repeated until cancelled.
-        :paramtype loop: bool
-        :keyword operation_context: Value that can be used to track this call and its associated events.
-        :paramtype operation_context: str or None
-        :keyword operation_callback_url: Set a callback URL that overrides the default callback URL set
-         by CreateCall/AnswerCall for this operation.
-         This setup is per-action. If this is not set, the default callback URL set by
-         CreateCall/AnswerCall will be used.
-        :paramtype operation_callback_url: str or None
-        :keyword interrupt_call_media_operation: If set play can barge into other existing
-         queued-up/currently-processing requests.
-        :paramtype interrupt_call_media_operation: bool
-        :return: None
-        :rtype: None
-        :raises ~azure.core.exceptions.HttpResponseError:
-        """
-        warnings.warn(
-            "The method 'play_media_to_all' is deprecated. Please use 'play_media' instead.",
-            DeprecationWarning
-        )
-
-    @overload
-    def play_media_to_all(
-        self,
-        play_sources: Optional[List[Union['FileSource', 'TextSource', 'SsmlSource']]],
-        *,
-        loop: bool = False,
-        operation_context: Optional[str] = None,
-        operation_callback_url: Optional[str] = None,
-        interrupt_call_media_operation: bool = False,
-        **kwargs
-    ) -> None:
-        """Play media to all participants in this call.
-
-        :param play_sources: A list of PlaySource representing the sources to play.
-        :type play_sources: list[~azure.communication.callautomation.FileSource] or
+         ~azure.communication.callautomation.SsmlSource or         
+         list[~azure.communication.callautomation.FileSource] or
          list[~azure.communication.callautomation.TextSource] or
          list[~azure.communication.callautomation.SsmlSource]
         :keyword loop: Whether the media should be repeated until cancelled.
@@ -632,30 +561,24 @@ def play_media_to_all(
             DeprecationWarning
         )
 
-    @distributed_trace
-    def play_media_to_all(
-        self,
-        **kwargs
-    ) -> None:
-
         self._play_media(
-            play_source=kwargs.pop("play_source", None),
-            play_sources=kwargs.pop("play_sources", None),
-            loop=kwargs.pop("loop", False),
-            operation_context=kwargs.pop("operation_context", None),
-            operation_callback_url=kwargs.pop("operation_callback_url", None),
-            interrupt_call_media_operation=kwargs.pop("interrupt_call_media_operation", False),
+            play_source=play_source,
+            loop=loop,
+            operation_context=operation_context,
+            operation_callback_url=operation_callback_url,
+            interrupt_call_media_operation=interrupt_call_media_operation,
             **kwargs
         )
 
-    @overload
+    @distributed_trace
     def start_recognizing_media(
         self,
         input_type: Union[str, 'RecognizeInputType'],
         target_participant: 'CommunicationIdentifier',
         *,
         initial_silence_timeout: Optional[int] = None,
-        play_prompt: Optional[Union['FileSource', 'TextSource', 'SsmlSource']] = None,
+        play_prompt: Optional[Union[Union['FileSource', 'TextSource', 'SsmlSource'],
+                           List[Union['FileSource', 'TextSource', 'SsmlSource']]]] = None,
         interrupt_call_media_operation: bool = False,
         operation_context: Optional[str] = None,
         interrupt_prompt: bool = False,
@@ -716,96 +639,14 @@ def start_recognizing_media(
         :raises ~azure.core.exceptions.HttpResponseError:
         """
 
-    @overload
-    def start_recognizing_media(
-        self,
-        input_type: Union[str, 'RecognizeInputType'],
-        target_participant: 'CommunicationIdentifier',
-        *,
-        initial_silence_timeout: Optional[int] = None,
-        play_prompts: Optional[List[Union['FileSource', 'TextSource', 'SsmlSource']]] = None,
-        interrupt_call_media_operation: bool = False,
-        operation_context: Optional[str] = None,
-        interrupt_prompt: bool = False,
-        dtmf_inter_tone_timeout: Optional[int] = None,
-        dtmf_max_tones_to_collect: Optional[int] = None,
-        dtmf_stop_tones: Optional[List[str or 'DtmfTone']] = None,
-        speech_language: Optional[str] = None,
-        choices: Optional[List['RecognitionChoice']] = None,
-        end_silence_timeout: Optional[int] = None,
-        speech_recognition_model_endpoint_id: Optional[str] = None,
-        operation_callback_url: Optional[str] = None,
-        **kwargs
-    ) -> None:
-        """Recognize inputs from specific participant in this call.
-
-        :param input_type: Determines the type of the recognition.
-        :type input_type: str or ~azure.communication.callautomation.RecognizeInputType
-        :param target_participant: Target participant of DTMF tone recognition.
-        :type target_participant: ~azure.communication.callautomation.CommunicationIdentifier
-        :keyword initial_silence_timeout: Time to wait for first input after prompt in seconds (if any).
-        :paramtype initial_silence_timeout: int
-        :keyword play_prompts: The source of the audio to be played for recognition.
-        :paramtype play_prompts: ~azure.communication.callautomation.FileSource or
-         ~azure.communication.callautomation.TextSource or
-         ~azure.communication.callautomation.SsmlSource
-        :keyword interrupt_call_media_operation:
-         If set recognize can barge into other existing queued-up/currently-processing requests.
-        :paramtype interrupt_call_media_operation: bool
-        :keyword operation_context: Value that can be used to track this call and its associated events.
-        :paramtype operation_context: str
-        :keyword interrupt_prompt: Determines if we interrupt the prompt and start recognizing.
-        :paramtype interrupt_prompt: bool
-        :keyword dtmf_inter_tone_timeout: Time to wait between DTMF inputs to stop recognizing. Will be ignored
-         unless input_type is 'dtmf' or 'speechOrDtmf'.
-        :paramtype dtmf_inter_tone_timeout: int
-        :keyword dtmf_max_tones_to_collect: Maximum number of DTMF tones to be collected. Will be ignored
-         unless input_type is 'dtmf' or 'speechOrDtmf'.
-        :paramtype dtmf_max_tones_to_collect: int
-        :keyword dtmf_stop_tones: List of tones that will stop recognizing. Will be ignored
-         unless input_type is 'dtmf' or 'speechOrDtmf'.
-        :paramtype dtmf_stop_tones: list[str or ~azure.communication.callautomation.DtmfTone]
-        :keyword speech_language: Speech language to be recognized, If not set default is en-US.
-        :paramtype speech_language: str
-        :keyword choices: Defines Ivr choices for recognize. Will be ignored unless input_type is 'choices'.
-        :paramtype choices: list[~azure.communication.callautomation.RecognitionChoice]
-        :keyword end_silence_timeout: The length of end silence when user stops speaking and cogservice
-         send response. Will be ingored unless input_type is 'speech' or 'speechOrDtmf'.
-        :paramtype end_silence_timeout: int
-        :keyword speech_recognition_model_endpoint_id: Endpoint where the custom model was deployed.
-        :paramtype speech_recognition_model_endpoint_id: str
-        :keyword operation_callback_url: Set a callback URL that overrides the default callback URL set
-         by CreateCall/AnswerCall for this operation.
-         This setup is per-action. If this is not set, the default callback URL set by
-         CreateCall/AnswerCall will be used.
-        :paramtype operation_callback_url: str or None
-        :return: None
-        :rtype: None
-        :raises ~azure.core.exceptions.HttpResponseError:
-        """
-
-    @distributed_trace
-    def start_recognizing_media(
-        self,
-        **kwargs
-    ) -> None:
+        play_prompt_single: Optional[Union['FileSource', 'TextSource', 'SsmlSource']] = None
+        play_prompts: Optional[List[Union['FileSource', 'TextSource', 'SsmlSource']]] = None
+        if isinstance(play_prompt, list):
+            if play_prompt:  # Check if the list is not empty
+                play_prompts = play_prompt
+        else:
+            play_prompt_single = play_prompt
 
-        play_prompt = kwargs.pop("play_prompt", None)
-        input_type=kwargs.pop("input_type")
-        target_participant=kwargs.pop("target_participant")
-        initial_silence_timeout=kwargs.pop("initial_silence_timeout", None)
-        speech_language=kwargs.pop("speech_language", None)
-        speech_recognition_model_endpoint_id=kwargs.pop("speech_recognition_model_endpoint_id", None)
-        play_prompts=kwargs.pop("play_prompts", None)
-        interrupt_call_media_operation=kwargs.pop("interrupt_call_media_operation", False)
-        operation_context=kwargs.pop("operation_context", None)
-        interrupt_prompt=kwargs.pop("interrupt_prompt", False)
-        dtmf_inter_tone_timeout=kwargs.pop("dtmf_inter_tone_timeout", None)
-        dtmf_max_tones_to_collect=kwargs.pop("dtmf_max_tones_to_collect", None)
-        dtmf_stop_tones=kwargs.pop("dtmf_stop_tones", None)
-        choices=kwargs.pop("choices", None)
-        end_silence_timeout=kwargs.pop("end_silence_timeout", None)
-        operation_callback_url=kwargs.pop("operation_callback_url", None)
         options = RecognizeOptions(
             interrupt_prompt=interrupt_prompt,
             initial_silence_timeout_in_seconds=initial_silence_timeout,
@@ -814,13 +655,6 @@ def start_recognizing_media(
             speech_recognition_model_endpoint_id=speech_recognition_model_endpoint_id
         )
 
-        play_source_single: Optional[Union['FileSource', 'TextSource', 'SsmlSource']] = None
-        if isinstance(play_prompt, list):
-            if play_prompt:  # Check if the list is not empty
-                play_source_single = play_prompt[0]
-        else:
-            play_source_single = play_prompt
-
         if input_type == RecognizeInputType.DTMF:
             dtmf_options=DtmfOptions(
                 inter_tone_timeout_in_seconds=dtmf_inter_tone_timeout,
@@ -849,7 +683,7 @@ def start_recognizing_media(
 
         recognize_request = RecognizeRequest(
             recognize_input_type=input_type,
-            play_prompt=play_source_single._to_generated() if play_source_single else None,  # pylint:disable=protected-access
+            play_prompt=play_prompt_single._to_generated() if play_prompt_single else None,  # pylint:disable=protected-access
             play_prompts=[prompt._to_generated() for prompt in play_prompts] if play_prompts else None, # pylint:disable=protected-access
             interrupt_call_media_operation=interrupt_call_media_operation,
             operation_context=operation_context,