removing the converting url string to URL (#41435)

* removing the converting url string to URL

* fixing the live test

* fxing reference error

Author: v-dharmarajv

sdk/communication/azure-communication-callautomation/azure/communication/callautomation/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)
 

sdk/communication/azure-communication-callautomation/tests/test_call_media_client.py

@@ -30,8 +30,7 @@
     HoldRequest,
     UnholdRequest,
     StartMediaStreamingRequest,
-    StopMediaStreamingRequest,
-    InterruptAudioAndAnnounceRequest
+    StopMediaStreamingRequest
 )
 from azure.communication.callautomation._generated.models._enums import RecognizeInputType, DtmfTone
 from unittest.mock import Mock

sdk/communication/azure-communication-callautomation/tests/test_e2e_media_client.py

@@ -15,10 +15,8 @@
     PhoneNumberIdentifier,
     MediaStreamingOptions,
     MediaStreamingContentType,
-    MediaStreamingTransportType,
     MediaStreamingAudioChannelType,
     TranscriptionOptions,
-    TranscriptionTransportType,
     TextSource,
     RecognizeInputType,
     RecognitionChoice
@@ -215,7 +213,6 @@ def test_start_stop_media_streaming_in_a_call(self):
 
         media_streaming_options=MediaStreamingOptions(
             transport_url=self.transport_url,
-            transport_type=MediaStreamingTransportType.WEBSOCKET,
             content_type=MediaStreamingContentType.AUDIO,
             audio_channel_type=MediaStreamingAudioChannelType.MIXED,
             start_media_streaming=False)
@@ -277,7 +274,6 @@ def test_start_stop_transcription_in_call(self):
 
         transcription_options=TranscriptionOptions(
             transport_url=self.transport_url,
-            transport_type=TranscriptionTransportType.WEBSOCKET,
             locale="en-US",
             start_transcription=False)
 

sdk/communication/azure-communication-chat/azure/communication/chat/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)
 

sdk/communication/azure-communication-email/azure/communication/email/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)
 

sdk/communication/azure-communication-identity/azure/communication/identity/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)
 

sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)
 

sdk/communication/azure-communication-messages/azure/communication/messages/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)
 

sdk/communication/azure-communication-phonenumbers/azure/communication/phonenumbers/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)
 

sdk/communication/azure-communication-rooms/azure/communication/rooms/_shared/policy.py

@@ -63,33 +63,6 @@ def _sign_request(self, request):
         if parsed_url.query:
             query_url += "?" + parsed_url.query
 
-        # Need URL() to get a correct encoded key value, from "%3A" to ":", when transport is in type AioHttpTransport.
-        # There's a similar scenario in azure-storage-blob and azure-appconfiguration, the check logic is from there.
-        try:
-            from yarl import URL
-            from azure.core.pipeline.transport import (  # pylint:disable=non-abstract-transport-import
-                AioHttpTransport,
-            )
-
-            if (
-                isinstance(request.context.transport, AioHttpTransport)
-                or isinstance(
-                    getattr(request.context.transport, "_transport", None),
-                    AioHttpTransport,
-                )
-                or isinstance(
-                    getattr(
-                        getattr(request.context.transport, "_transport", None),
-                        "_transport",
-                        None,
-                    ),
-                    AioHttpTransport,
-                )
-            ):
-                query_url = str(URL(query_url))
-        except (ImportError, TypeError):
-            pass
-
         if self._decode_url:
             query_url = urllib.parse.unquote(query_url)