[Storage Queue] Migrating to TypeSpec

sdk/storage/azure-storage-queue/MANIFEST.in

@@ -1,7 +1,7 @@
 include *.md
-include azure/__init__.py
-include azure/storage/__init__.py
 include LICENSE
+include azure/storage/queue/py.typed
 recursive-include tests *.py
 recursive-include samples *.py *.md
-include azure/storage/queue/py.typed
+include azure/__init__.py
+include azure/storage/__init__.py

sdk/storage/azure-storage-queue/_metadata.json

@@ -0,0 +1,6 @@
+{
+  "apiVersion": "2026-04-06",
+  "apiVersions": {
+    "Storage.Queues": "2026-04-06"
+  }
+}

sdk/storage/azure-storage-queue/apiview-properties.json

@@ -0,0 +1,65 @@
+{
+    "CrossLanguagePackageId": "Storage.Queues",
+    "CrossLanguageDefinitionId": {
+        "azure.storage.queue.models.AccessPolicy": "Storage.Queues.AccessPolicy",
+        "azure.storage.queue.models.CorsRule": "Storage.Queues.CorsRule",
+        "azure.storage.queue.models.Error": "Storage.Queues.Error",
+        "azure.storage.queue.models.GeoReplication": "Storage.Queues.GeoReplication",
+        "azure.storage.queue.models.KeyInfo": "Storage.Queues.KeyInfo",
+        "azure.storage.queue.models.ListOfSentMessage": "Storage.Queues.ListOfSentMessage",
+        "azure.storage.queue.models.ListQueuesResponse": "Storage.Queues.ListQueuesResponse",
+        "azure.storage.queue.models.Logging": "Storage.Queues.Logging",
+        "azure.storage.queue.models.Metrics": "Storage.Queues.Metrics",
+        "azure.storage.queue.models.PeekedMessage": "Storage.Queues.PeekedMessage",
+        "azure.storage.queue.models.PeekedMessages": "Storage.Queues.PeekedMessages",
+        "azure.storage.queue.models.QueueItem": "Storage.Queues.QueueItem",
+        "azure.storage.queue.models.QueueMessage": "Storage.Queues.QueueMessage",
+        "azure.storage.queue.models.QueueServiceProperties": "Storage.Queues.QueueServiceProperties",
+        "azure.storage.queue.models.QueueServiceStats": "Storage.Queues.QueueServiceStats",
+        "azure.storage.queue.models.ReceivedMessage": "Storage.Queues.ReceivedMessage",
+        "azure.storage.queue.models.ReceivedMessages": "Storage.Queues.ReceivedMessages",
+        "azure.storage.queue.models.RetentionPolicy": "Storage.Queues.RetentionPolicy",
+        "azure.storage.queue.models.SentMessage": "Storage.Queues.SentMessage",
+        "azure.storage.queue.models.SignedIdentifier": "Storage.Queues.SignedIdentifier",
+        "azure.storage.queue.models.SignedIdentifiers": "Storage.Queues.SignedIdentifiers",
+        "azure.storage.queue.models.UserDelegationKey": "Storage.Queues.UserDelegationKey",
+        "azure.storage.queue.models.StorageErrorCode": "Storage.Queues.StorageErrorCode",
+        "azure.storage.queue.models.GeoReplicationStatus": "Storage.Queues.GeoReplicationStatus",
+        "azure.storage.queue.models.ListQueuesIncludeType": "Storage.Queues.ListQueuesIncludeType",
+        "azure.storage.queue.operations.ServiceOperations.set_properties": "Storage.Queues.Service.setProperties",
+        "azure.storage.queue.aio.operations.ServiceOperations.set_properties": "Storage.Queues.Service.setProperties",
+        "azure.storage.queue.operations.ServiceOperations.get_properties": "Storage.Queues.Service.getProperties",
+        "azure.storage.queue.aio.operations.ServiceOperations.get_properties": "Storage.Queues.Service.getProperties",
+        "azure.storage.queue.operations.ServiceOperations.get_statistics": "Storage.Queues.Service.getStatistics",
+        "azure.storage.queue.aio.operations.ServiceOperations.get_statistics": "Storage.Queues.Service.getStatistics",
+        "azure.storage.queue.operations.ServiceOperations.get_user_delegation_key": "Storage.Queues.Service.getUserDelegationKey",
+        "azure.storage.queue.aio.operations.ServiceOperations.get_user_delegation_key": "Storage.Queues.Service.getUserDelegationKey",
+        "azure.storage.queue.operations.ServiceOperations.get_queues": "Storage.Queues.Service.getQueues",
+        "azure.storage.queue.aio.operations.ServiceOperations.get_queues": "Storage.Queues.Service.getQueues",
+        "azure.storage.queue.operations.QueueOperations.create": "Storage.Queues.Queue.create",
+        "azure.storage.queue.aio.operations.QueueOperations.create": "Storage.Queues.Queue.create",
+        "azure.storage.queue.operations.QueueOperations.get_properties": "Storage.Queues.Queue.getProperties",
+        "azure.storage.queue.aio.operations.QueueOperations.get_properties": "Storage.Queues.Queue.getProperties",
+        "azure.storage.queue.operations.QueueOperations.delete": "Storage.Queues.Queue.delete",
+        "azure.storage.queue.aio.operations.QueueOperations.delete": "Storage.Queues.Queue.delete",
+        "azure.storage.queue.operations.QueueOperations.set_metadata": "Storage.Queues.Queue.setMetadata",
+        "azure.storage.queue.aio.operations.QueueOperations.set_metadata": "Storage.Queues.Queue.setMetadata",
+        "azure.storage.queue.operations.QueueOperations.get_access_policy": "Storage.Queues.Queue.getAccessPolicy",
+        "azure.storage.queue.aio.operations.QueueOperations.get_access_policy": "Storage.Queues.Queue.getAccessPolicy",
+        "azure.storage.queue.operations.QueueOperations.set_access_policy": "Storage.Queues.Queue.setAccessPolicy",
+        "azure.storage.queue.aio.operations.QueueOperations.set_access_policy": "Storage.Queues.Queue.setAccessPolicy",
+        "azure.storage.queue.operations.QueueOperations.receive_messages": "Storage.Queues.Queue.receiveMessages",
+        "azure.storage.queue.aio.operations.QueueOperations.receive_messages": "Storage.Queues.Queue.receiveMessages",
+        "azure.storage.queue.operations.QueueOperations.clear": "Storage.Queues.Queue.clear",
+        "azure.storage.queue.aio.operations.QueueOperations.clear": "Storage.Queues.Queue.clear",
+        "azure.storage.queue.operations.QueueOperations.send_message": "Storage.Queues.Queue.sendMessage",
+        "azure.storage.queue.aio.operations.QueueOperations.send_message": "Storage.Queues.Queue.sendMessage",
+        "azure.storage.queue.operations.QueueOperations.peek_messages": "Storage.Queues.Queue.peekMessages",
+        "azure.storage.queue.aio.operations.QueueOperations.peek_messages": "Storage.Queues.Queue.peekMessages",
+        "azure.storage.queue.operations.QueueOperations.update_message": "Storage.Queues.Queue.updateMessage",
+        "azure.storage.queue.aio.operations.QueueOperations.update_message": "Storage.Queues.Queue.updateMessage",
+        "azure.storage.queue.operations.QueueOperations.delete_message": "Storage.Queues.Queue.deleteMessage",
+        "azure.storage.queue.aio.operations.QueueOperations.delete_message": "Storage.Queues.Queue.deleteMessage"
+    },
+    "CrossLanguageVersion": "93cf2ffb7d42"
+}

sdk/storage/azure-storage-queue/azure/storage/queue/_generated/__init__.py

@@ -2,7 +2,7 @@
 # --------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
-# Code generated by Microsoft (R) AutoRest Code Generator.
+# Code generated by Microsoft (R) Python Code Generator.
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 # pylint: disable=wrong-import-position
@@ -12,7 +12,10 @@
 if TYPE_CHECKING:
     from ._patch import *  # pylint: disable=unused-wildcard-import
 
-from ._azure_queue_storage import AzureQueueStorage  # type: ignore
+from ._client import QueuesClient  # type: ignore
+from ._version import VERSION
+
+__version__ = VERSION
 
 try:
     from ._patch import __all__ as _patch_all
@@ -22,7 +25,7 @@
 from ._patch import patch_sdk as _patch_sdk
 
 __all__ = [
-    "AzureQueueStorage",
+    "QueuesClient",
 ]
 __all__.extend([p for p in _patch_all if p not in __all__])  # pyright: ignore
 

sdk/storage/azure-storage-queue/azure/storage/queue/_generated/_azure_queue_storage.py → sdk/storage/azure-storage-queue/azure/storage/queue/_generated/_client.py

@@ -2,53 +2,53 @@
 # --------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
-# Code generated by Microsoft (R) AutoRest Code Generator.
+# Code generated by Microsoft (R) Python Code Generator.
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 
 from copy import deepcopy
-from typing import Any
-from typing_extensions import Self
+import sys
+from typing import Any, TYPE_CHECKING
 
 from azure.core import PipelineClient
 from azure.core.pipeline import policies
 from azure.core.rest import HttpRequest, HttpResponse
 
-from . import models as _models
-from ._configuration import AzureQueueStorageConfiguration
+from ._configuration import QueuesClientConfiguration
 from ._utils.serialization import Deserializer, Serializer
-from .operations import (
-    MessageIdOperations,
-    MessagesOperations,
-    QueueOperations,
-    ServiceOperations,
-)
+from .operations import QueueOperations, ServiceOperations
 
+if sys.version_info >= (3, 11):
+    from typing import Self
+else:
+    from typing_extensions import Self  # type: ignore
 
-class AzureQueueStorage:  # pylint: disable=client-accepts-api-version-keyword
-    """AzureQueueStorage.
+if TYPE_CHECKING:
+    from azure.core.credentials import TokenCredential
+
+
+class QueuesClient:  # pylint: disable=client-accepts-api-version-keyword
+    """QueuesClient.
 
     :ivar service: ServiceOperations operations
     :vartype service: azure.storage.queue.operations.ServiceOperations
     :ivar queue: QueueOperations operations
     :vartype queue: azure.storage.queue.operations.QueueOperations
-    :ivar messages: MessagesOperations operations
-    :vartype messages: azure.storage.queue.operations.MessagesOperations
-    :ivar message_id: MessageIdOperations operations
-    :vartype message_id: azure.storage.queue.operations.MessageIdOperations
-    :param url: The URL of the service account, queue or message that is the target of the desired
-     operation. Required.
+    :param url: The host name of the queue storage account, e.g.
+     accountName.queue.core.windows.net. Required.
     :type url: str
-    :param version: Specifies the version of the operation to use for this request. Required.
-    :type version: str
-    :param base_url: Service URL. Required. Default value is "".
-    :type base_url: str
+    :param credential: Credential used to authenticate requests to the service. Required.
+    :type credential: ~azure.core.credentials.TokenCredential
+    :keyword version: Specifies the version of the operation to use for this request. Known values
+     are "2026-04-06" and None. Default value is None. If not set, the operation's default API
+     version will be used. Note that overriding this default value may result in unsupported
+     behavior.
+    :paramtype version: str
     """
 
-    def __init__(  # pylint: disable=missing-client-constructor-parameter-credential
-        self, url: str, version: str, base_url: str = "", **kwargs: Any
-    ) -> None:
-        self._config = AzureQueueStorageConfiguration(url=url, version=version, **kwargs)
+    def __init__(self, url: str, credential: "TokenCredential", **kwargs: Any) -> None:
+        _endpoint = "{url}"
+        self._config = QueuesClientConfiguration(url=url, credential=credential, **kwargs)
 
         _policies = kwargs.pop("policies", None)
         if _policies is None:
@@ -64,27 +64,24 @@ def __init__(  # pylint: disable=missing-client-constructor-parameter-credential
                 self._config.custom_hook_policy,
                 self._config.logging_policy,
                 policies.DistributedTracingPolicy(**kwargs),
-                (policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None),
+                policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None,
                 self._config.http_logging_policy,
             ]
-        self._client: PipelineClient = PipelineClient(base_url=base_url, policies=_policies, **kwargs)
+        self._client: PipelineClient = PipelineClient(base_url=_endpoint, policies=_policies, **kwargs)
 
-        client_models = {k: v for k, v in _models.__dict__.items() if isinstance(v, type)}
-        self._serialize = Serializer(client_models)
-        self._deserialize = Deserializer(client_models)
+        self._serialize = Serializer()
+        self._deserialize = Deserializer()
         self._serialize.client_side_validation = False
         self.service = ServiceOperations(self._client, self._config, self._serialize, self._deserialize)
         self.queue = QueueOperations(self._client, self._config, self._serialize, self._deserialize)
-        self.messages = MessagesOperations(self._client, self._config, self._serialize, self._deserialize)
-        self.message_id = MessageIdOperations(self._client, self._config, self._serialize, self._deserialize)
 
-    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
         >>> request = HttpRequest("GET", "https://www.example.org/")
         <HttpRequest [GET], url: 'https://www.example.org/'>
-        >>> response = client._send_request(request)
+        >>> response = client.send_request(request)
         <HttpResponse: 200 OK>
 
         For more information on this code flow, see https://aka.ms/azsdk/dpcodegen/python/send_request
@@ -97,7 +94,11 @@ def _send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs:
         """
 
         request_copy = deepcopy(request)
-        request_copy.url = self._client.format_url(request_copy.url)
+        path_format_arguments = {
+            "url": self._serialize.url("self._config.url", self._config.url, "str", skip_quote=True),
+        }
+
+        request_copy.url = self._client.format_url(request_copy.url, **path_format_arguments)
         return self._client.send_request(request_copy, stream=stream, **kwargs)  # type: ignore
 
     def close(self) -> None:

sdk/storage/azure-storage-queue/azure/storage/queue/_generated/_configuration.py

@@ -2,39 +2,51 @@
 # --------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
-# Code generated by Microsoft (R) AutoRest Code Generator.
+# Code generated by Microsoft (R) Python Code Generator.
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 
-from typing import Any
+from typing import Any, TYPE_CHECKING
 
 from azure.core.pipeline import policies
 
-VERSION = "unknown"
+from ._version import VERSION
 
+if TYPE_CHECKING:
+    from azure.core.credentials import TokenCredential
 
-class AzureQueueStorageConfiguration:  # pylint: disable=too-many-instance-attributes
-    """Configuration for AzureQueueStorage.
+
+class QueuesClientConfiguration:  # pylint: disable=too-many-instance-attributes
+    """Configuration for QueuesClient.
 
     Note that all parameters used to create this instance are saved as instance
     attributes.
 
-    :param url: The URL of the service account, queue or message that is the target of the desired
-     operation. Required.
+    :param url: The host name of the queue storage account, e.g.
+     accountName.queue.core.windows.net. Required.
     :type url: str
-    :param version: Specifies the version of the operation to use for this request. Required.
-    :type version: str
+    :param credential: Credential used to authenticate requests to the service. Required.
+    :type credential: ~azure.core.credentials.TokenCredential
+    :keyword version: Specifies the version of the operation to use for this request. Known values
+     are "2026-04-06" and None. Default value is None. If not set, the operation's default API
+     version will be used. Note that overriding this default value may result in unsupported
+     behavior.
+    :paramtype version: str
     """
 
-    def __init__(self, url: str, version: str, **kwargs: Any) -> None:
+    def __init__(self, url: str, credential: "TokenCredential", **kwargs: Any) -> None:
+        version: str = kwargs.pop("version", "2026-04-06")
+
         if url is None:
             raise ValueError("Parameter 'url' must not be None.")
-        if version is None:
-            raise ValueError("Parameter 'version' must not be None.")
+        if credential is None:
+            raise ValueError("Parameter 'credential' must not be None.")
 
         self.url = url
+        self.credential = credential
         self.version = version
-        kwargs.setdefault("sdk_moniker", "azurequeuestorage/{}".format(VERSION))
+        self.credential_scopes = kwargs.pop("credential_scopes", ["https://storage.azure.com/.default"])
+        kwargs.setdefault("sdk_moniker", "storage-queue/{}".format(VERSION))
         self.polling_interval = kwargs.get("polling_interval", 30)
         self._configure(**kwargs)
 
@@ -48,3 +60,7 @@ def _configure(self, **kwargs: Any) -> None:
         self.redirect_policy = kwargs.get("redirect_policy") or policies.RedirectPolicy(**kwargs)
         self.retry_policy = kwargs.get("retry_policy") or policies.RetryPolicy(**kwargs)
         self.authentication_policy = kwargs.get("authentication_policy")
+        if self.credential and not self.authentication_policy:
+            self.authentication_policy = policies.BearerTokenCredentialPolicy(
+                self.credential, *self.credential_scopes, **kwargs
+            )