Added record files

Author: jorge-beauregard

sdk/communication/azure-communication-sms/azure/communication/sms/_shared/user_credential.py

@@ -11,7 +11,7 @@
 )
 import six
 from msrest.serialization import TZ_UTC
-from .utils import create_access_token, get_authentication_policy
+from .utils import create_access_token
 
 class CommunicationUserCredential(object):
     """Credential type used for authenticating to an Azure Communication service.

sdk/communication/azure-communication-sms/azure/communication/sms/_shared/utils.py

@@ -69,30 +69,35 @@ def create_access_token(token):
     except ValueError:
         raise ValueError(token_parse_err_msg)
 
-    def get_authentication_policy(
-            endpoint, # type: str
-            credential # type: TokenCredential or str
-    ):
-        # type: (...) -> BearerTokenCredentialPolicy or HMACCredentialPolicy
-        """Returns the correct authentication policy based
-        on which credential is being passed.
-        :param endpoint: The endpoint to which we are authenticating to.
-        :type endpoint: str
-        :param credential: The credential we use to authenticate to the service
-        :type credential: TokenCredential or str
-        :rtype: ~azure.core.pipeline.policies.BearerTokenCredentialPolicy
-        ~HMACCredentialsPolicy
-        """
+def get_authentication_policy(
+        endpoint, # type: str
+        credential, # type: TokenCredential or str
+        is_async=False, # type: bool
+):
+    # type: (...) -> BearerTokenCredentialPolicy or HMACCredentialPolicy
+    """Returns the correct authentication policy based
+    on which credential is being passed.
 
-        if credential is None:
-            raise ValueError("Parameter 'credential' must not be None.")
-        if hasattr(credential, "get_token"):
-            from azure.core.pipeline.policies import BearerTokenCredentialPolicy
-            return BearerTokenCredentialPolicy(
-                credential, "https://communication.azure.com//.default")
-        if isinstance(credential, str):
-            from .._shared.policy import HMACCredentialsPolicy
-            return HMACCredentialsPolicy(endpoint, credential)
+    :param endpoint: The endpoint to which we are authenticating to.
+    :type endpoint: str
+    :param credential: The credential we use to authenticate to the service
+    :type credential: TokenCredential or str
+    :param isAsync: For async clients there is a need to decode the url
+    :type bool: isAsync or str
 
-        raise TypeError("Unsupported credential: {}. Use an access token string to use HMACCredentialsPolicy"
-                        "or a token credential from azure.identity".format(type(credential)))
+    :rtype: ~azure.core.pipeline.policies.BearerTokenCredentialPolicy
+    ~HMACCredentialsPolicy
+    """
+
+    if credential is None:
+        raise ValueError("Parameter 'credential' must not be None.")
+    if hasattr(credential, "get_token"):
+        from azure.core.pipeline.policies import BearerTokenCredentialPolicy
+        return BearerTokenCredentialPolicy(
+            credential, "https://communication.azure.com//.default")
+    if isinstance(credential, str):
+        from .._shared.policy import HMACCredentialsPolicy
+        return HMACCredentialsPolicy(endpoint, credential, decode_url=is_async)
+
+    raise TypeError("Unsupported credential: {}. Use an access token string to use HMACCredentialsPolicy"
+                    "or a token credential from azure.identity".format(type(credential)))

sdk/communication/azure-communication-sms/dev_requirements.txt

@@ -1,5 +1,6 @@
 -e ../../../tools/azure-sdk-tools
 -e ../../../tools/azure-devtools
+-e ../../identity/azure-identity
 ../../core/azure-core
 ../azure-communication-nspkg
 aiohttp>=3.0; python_version >= '3.5'

sdk/communication/azure-communication-sms/tests/recordings/test_sms_client_e2e.test_send_sms.yaml

@@ -14,9 +14,9 @@ interactions:
       Content-Type:
       - application/json
       Date:
-      - Fri, 09 Oct 2020 23:20:19 GMT
+      - Wed, 20 Jan 2021 18:11:23 GMT
       User-Agent:
-      - azsdk-python-communication-sms/1.0.0b3 Python/3.8.6 (Windows-10-10.0.19041-SP0)
+      - azsdk-python-communication-sms/1.0.0b5 Python/3.8.5 (Windows-10-10.0.19041-SP0)
       x-ms-return-client-request-id:
       - 'true'
     method: POST
@@ -27,13 +27,15 @@ interactions:
       content-type:
       - application/json; charset=utf-8
       date:
-      - Fri, 09 Oct 2020 23:20:19 GMT
+      - Wed, 20 Jan 2021 18:11:24 GMT
       ms-cv:
-      - JCf4xQXQEkS2Tix1X3WyhA.0
+      - 1y4+o6OmR0ulV50uPXHoEw.0
+      request-context:
+      - appId=
       transfer-encoding:
       - chunked
       x-processing-time:
-      - 1071ms
+      - 484ms
     status:
       code: 200
       message: OK

sdk/communication/azure-communication-sms/tests/recordings/test_sms_client_e2e_async.test_send_sms_async.yaml

@@ -10,9 +10,9 @@ interactions:
       Content-Type:
       - application/json
       Date:
-      - Fri, 09 Oct 2020 23:20:20 GMT
+      - Wed, 20 Jan 2021 18:11:24 GMT
       User-Agent:
-      - azsdk-python-communication-sms/1.0.0b3 Python/3.8.6 (Windows-10-10.0.19041-SP0)
+      - azsdk-python-communication-sms/1.0.0b5 Python/3.8.5 (Windows-10-10.0.19041-SP0)
       x-ms-return-client-request-id:
       - 'true'
     method: POST
@@ -21,10 +21,11 @@ interactions:
     body: '{"messageId": "sanitized"}'
     headers:
       content-type: application/json; charset=utf-8
-      date: Fri, 09 Oct 2020 23:20:20 GMT
-      ms-cv: Fh5qIzKnFUaqzbz+3C3fKQ.0
+      date: Wed, 20 Jan 2021 18:11:24 GMT
+      ms-cv: x7uY4q7a+EmmyTMUW8my+A.0
+      request-context: appId=
       transfer-encoding: chunked
-      x-processing-time: 815ms
+      x-processing-time: 468ms
     status:
       code: 200
       message: OK

sdk/communication/azure-communication-sms/tests/recordings/test_sms_client_e2e_async.test_send_sms_async_from_managed_identity.yaml

@@ -0,0 +1,29 @@
+interactions:
+- request:
+    body: '{"from": "sanitized", "to": "sanitized", "message": "Hello World via SMS",
+      "sendSmsOptions": {"enableDeliveryReport": true}}'
+    headers:
+      Accept:
+      - application/json
+      Content-Length:
+      - '132'
+      Content-Type:
+      - application/json
+      User-Agent:
+      - azsdk-python-communication-sms/1.0.0b5 Python/3.8.5 (Windows-10-10.0.19041-SP0)
+    method: POST
+    uri: https://sanitized.communication.azure.com/sms?api-version=2020-07-20-preview1
+  response:
+    body: '{"messageId": "sanitized"}'
+    headers:
+      content-type: application/json; charset=utf-8
+      date: Wed, 20 Jan 2021 18:11:27 GMT
+      ms-cv: 2alAVqPXy0O98kSmG+jzFA.0
+      request-context: appId=
+      transfer-encoding: chunked
+      x-processing-time: 827ms
+    status:
+      code: 200
+      message: OK
+    url: https://sanitized.communication.azure.com/sms?api-version=2020-07-20-preview1
+version: 1

sdk/communication/azure-communication-sms/tests/test_sms_client_e2e_async.py

@@ -6,15 +6,25 @@
 
 import os
 import pytest
+from azure.core.credentials import AccessToken
 from azure.communication.sms.aio import SmsClient
 from azure.communication.sms import (
     PhoneNumber, SendSmsOptions
 )
+from azure.communication.sms._shared.utils import parse_connection_str
 from _shared.asynctestcase import AsyncCommunicationTestCase
 from _shared.testcase import (
     BodyReplacerProcessor, ResponseReplacerProcessor
 )
+from azure.identity import DefaultAzureCredential
 
+
+class FakeTokenCredential(object):
+    def __init__(self):
+        self.token = AccessToken("Fake Token", 0)
+
+    def get_token(self, *args):
+        return self.token
 class SMSClientTestAsync(AsyncCommunicationTestCase):
     def __init__(self, method_name):
         super(SMSClientTestAsync, self).__init__(method_name)
@@ -46,3 +56,24 @@ async def test_send_sms_async(self):
                 send_sms_options=SendSmsOptions(enable_delivery_report=True))  # optional property
 
             assert sms_response.message_id is not None
+
+    @AsyncCommunicationTestCase.await_prepared_test
+    @pytest.mark.live_test_only
+    async def test_send_sms_async_from_managed_identity(self):
+        endpoint, access_key = parse_connection_str(self.connection_str)
+        from devtools_testutils import is_live
+        if not is_live():
+            credential = FakeTokenCredential()
+        else:
+            credential = DefaultAzureCredential()
+        sms_client = SmsClient(endpoint, credential)
+        print(sms_client)
+        async with sms_client:
+            # calling send() with sms values
+            sms_response = await sms_client.send(
+                from_phone_number=PhoneNumber(self.phone_number),
+                to_phone_numbers=[PhoneNumber(self.phone_number)],
+                message="Hello World via SMS",
+                send_sms_options=SendSmsOptions(enable_delivery_report=True))  # optional property
+
+            assert sms_response.message_id is not None