CodeGen from PR 30346 in Azure/azure-rest-api-specs

Merge 2a4eabf40cb0613e3c17fecc7227ad29bb03a47b into dcceabad7ae50b3faecf1dee49339d639cd11a2c

sdk/communication/azure-communication-messages/_meta.json

@@ -0,0 +1,6 @@
+{
+  "commit": "5c2d8f3740040f3601c3d6e4eb3773b4373e3cb2",
+  "repository_url": "https://github.com/Azure/azure-rest-api-specs",
+  "typespec_src": "specification/communication/Communication.Messages",
+  "@azure-tools/typespec-python": "0.33.0"
+}

sdk/communication/azure-communication-messages/azure/__init__.py

@@ -1 +1 @@
-__path__ = __import__('pkgutil').extend_path(__path__, __name__)  # type: ignore
+__path__ = __import__("pkgutil").extend_path(__path__, __name__)  # type: ignore

sdk/communication/azure-communication-messages/azure/communication/__init__.py

@@ -1 +1 @@
-__path__ = __import__('pkgutil').extend_path(__path__, __name__)  # type: ignore
+__path__ = __import__("pkgutil").extend_path(__path__, __name__)  # type: ignore

sdk/communication/azure-communication-messages/azure/communication/messages/__init__.py

@@ -18,9 +18,10 @@
 except ImportError:
     _patch_all = []
 from ._patch import patch_sdk as _patch_sdk
+
 __all__ = [
-    'NotificationMessagesClient',
-    'MessageTemplateClient',
+    "NotificationMessagesClient",
+    "MessageTemplateClient",
 ]
 __all__.extend([p for p in _patch_all if p not in __all__])
 

sdk/communication/azure-communication-messages/azure/communication/messages/_client.py

@@ -8,6 +8,7 @@
 
 from copy import deepcopy
 from typing import Any, TYPE_CHECKING, Union
+from typing_extensions import Self
 
 from azure.core import PipelineClient
 from azure.core.credentials import AzureKeyCredential
@@ -22,53 +23,51 @@
     # pylint: disable=unused-import,ungrouped-imports
     from azure.core.credentials import TokenCredential
 
-class NotificationMessagesClient(NotificationMessagesClientOperationsMixin):  # pylint: disable=client-accepts-api-version-keyword
+
+class NotificationMessagesClient(
+    NotificationMessagesClientOperationsMixin
+):  # pylint: disable=client-accepts-api-version-keyword
     """NotificationMessagesClient.
 
     :param endpoint: The communication resource, for example
      https://my-resource.communication.azure.com. Required.
     :type endpoint: str
-    :param credential: Credential needed for the client to connect to Azure. Is either a
+    :param credential: Credential used to authenticate requests to the service. Is either a
      TokenCredential type or a AzureKeyCredential type. Required.
     :type credential: ~azure.core.credentials.TokenCredential or
      ~azure.core.credentials.AzureKeyCredential
-    :keyword api_version: The API version to use for this operation. Default value is "2024-02-01".
+    :keyword api_version: The API version to use for this operation. Default value is "2024-08-30".
      Note that overriding this default value may result in unsupported behavior.
     :paramtype api_version: str
     """
 
-    def __init__(
-        self,
-        endpoint: str,
-        credential: Union["TokenCredential", AzureKeyCredential],
-        **kwargs: Any
-    ) -> None:
-        _endpoint = '{endpoint}'
+    def __init__(self, endpoint: str, credential: Union["TokenCredential", AzureKeyCredential], **kwargs: Any) -> None:
+        _endpoint = "{endpoint}"
         self._config = NotificationMessagesClientConfiguration(endpoint=endpoint, credential=credential, **kwargs)
-        _policies = kwargs.pop('policies', None)
+        _policies = kwargs.pop("policies", None)
         if _policies is None:
-            _policies = [policies.RequestIdPolicy(**kwargs),self._config.headers_policy,
-                         self._config.user_agent_policy,self._config.proxy_policy,
-                         policies.ContentDecodePolicy(**kwargs),
-                         self._config.redirect_policy,self._config.retry_policy,
-                         self._config.authentication_policy,
-                         self._config.custom_hook_policy,self._config.logging_policy,
-                         policies.DistributedTracingPolicy(**kwargs),
-                         policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None,
-                         self._config.http_logging_policy]
+            _policies = [
+                policies.RequestIdPolicy(**kwargs),
+                self._config.headers_policy,
+                self._config.user_agent_policy,
+                self._config.proxy_policy,
+                policies.ContentDecodePolicy(**kwargs),
+                self._config.redirect_policy,
+                self._config.retry_policy,
+                self._config.authentication_policy,
+                self._config.custom_hook_policy,
+                self._config.logging_policy,
+                policies.DistributedTracingPolicy(**kwargs),
+                policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None,
+                self._config.http_logging_policy,
+            ]
         self._client: PipelineClient = PipelineClient(base_url=_endpoint, policies=_policies, **kwargs)
 
-
         self._serialize = Serializer()
         self._deserialize = Deserializer()
         self._serialize.client_side_validation = False
 
-
-    def send_request(
-        self,
-        request: HttpRequest, *, stream: bool = False,
-        **kwargs: Any
-    ) -> HttpResponse:
+    def send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs: Any) -> HttpResponse:
         """Runs the network request through the client's chained policies.
 
         >>> from azure.core.rest import HttpRequest
@@ -88,7 +87,7 @@ def send_request(
 
         request_copy = deepcopy(request)
         path_format_arguments = {
-            "endpoint": self._serialize.url("self._config.endpoint", self._config.endpoint, 'str', skip_quote=True),
+            "endpoint": self._serialize.url("self._config.endpoint", self._config.endpoint, "str", skip_quote=True),
         }
 
         request_copy.url = self._client.format_url(request_copy.url, **path_format_arguments)
@@ -97,56 +96,56 @@ def send_request(
     def close(self) -> None:
         self._client.close()
 
-    def __enter__(self) -> "NotificationMessagesClient":
+    def __enter__(self) -> Self:
         self._client.__enter__()
         return self
 
     def __exit__(self, *exc_details: Any) -> None:
         self._client.__exit__(*exc_details)
+
+
 class MessageTemplateClient(MessageTemplateClientOperationsMixin):  # pylint: disable=client-accepts-api-version-keyword
     """MessageTemplateClient.
 
     :param endpoint: The communication resource, for example
      https://my-resource.communication.azure.com. Required.
     :type endpoint: str
-    :param credential: Credential needed for the client to connect to Azure. Is either a
+    :param credential: Credential used to authenticate requests to the service. Is either a
      TokenCredential type or a AzureKeyCredential type. Required.
     :type credential: ~azure.core.credentials.TokenCredential or
      ~azure.core.credentials.AzureKeyCredential
-    :keyword api_version: The API version to use for this operation. Default value is "2024-02-01".
+    :keyword api_version: The API version to use for this operation. Default value is "2024-08-30".
      Note that overriding this default value may result in unsupported behavior.
     :paramtype api_version: str
     """
 
-    def __init__(
-        self,
-        endpoint: str,
-        credential: Union["TokenCredential", AzureKeyCredential],
-        **kwargs: Any
-    ) -> None:
-        _endpoint = '{endpoint}'
+    def __init__(self, endpoint: str, credential: Union["TokenCredential", AzureKeyCredential], **kwargs: Any) -> None:
+        _endpoint = "{endpoint}"
         self._config = MessageTemplateClientConfiguration(endpoint=endpoint, credential=credential, **kwargs)
-        _policies = kwargs.pop('policies', None)
+        _policies = kwargs.pop("policies", None)
         if _policies is None:
-            _policies = [policies.RequestIdPolicy(**kwargs),self._config.headers_policy,self._config.user_agent_policy,
-                         self._config.proxy_policy,policies.ContentDecodePolicy(**kwargs),self._config.redirect_policy,
-                         self._config.retry_policy,self._config.authentication_policy,self._config.custom_hook_policy,
-                         self._config.logging_policy,policies.DistributedTracingPolicy(**kwargs),
-                         policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None,
-                         self._config.http_logging_policy]
+            _policies = [
+                policies.RequestIdPolicy(**kwargs),
+                self._config.headers_policy,
+                self._config.user_agent_policy,
+                self._config.proxy_policy,
+                policies.ContentDecodePolicy(**kwargs),
+                self._config.redirect_policy,
+                self._config.retry_policy,
+                self._config.authentication_policy,
+                self._config.custom_hook_policy,
+                self._config.logging_policy,
+                policies.DistributedTracingPolicy(**kwargs),
+                policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None,
+                self._config.http_logging_policy,
+            ]
         self._client: PipelineClient = PipelineClient(base_url=_endpoint, policies=_policies, **kwargs)
 
-
         self._serialize = Serializer()
         self._deserialize = Deserializer()
         self._serialize.client_side_validation = False
 
-
-    def send_request(
-        self,
-        request: HttpRequest, *, stream: bool = False,
-        **kwargs: Any
-    ) -> HttpResponse:
+    def send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs: Any) -> HttpResponse:
         """Runs the network request through the client's chained policies.
 
         >>> from azure.core.rest import HttpRequest
@@ -166,7 +165,7 @@ def send_request(
 
         request_copy = deepcopy(request)
         path_format_arguments = {
-            "endpoint": self._serialize.url("self._config.endpoint", self._config.endpoint, 'str', skip_quote=True),
+            "endpoint": self._serialize.url("self._config.endpoint", self._config.endpoint, "str", skip_quote=True),
         }
 
         request_copy.url = self._client.format_url(request_copy.url, **path_format_arguments)
@@ -175,7 +174,7 @@ def send_request(
     def close(self) -> None:
         self._client.close()
 
-    def __enter__(self) -> "MessageTemplateClient":
+    def __enter__(self) -> Self:
         self._client.__enter__()
         return self