[SchemaRegistry] generate GA SR from swagger (#21570)

fixes: #20661

Author: swathipil

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_common/_response_handlers.py

@@ -28,21 +28,25 @@
 
 def _parse_schema_properties_dict(response):
     return {
-        'id': response.headers.get('schema-id'),
-        'format': response.headers.get('serialization-type')
+        'id': response.headers.get('schema-id')
     }
 
 
-def _parse_response_schema_properties(response):
+def _parse_response_schema_properties(response, format):
+    # pylint:disable=redefined-builtin
     properties_dict = _parse_schema_properties_dict(response)
-    properties_dict['id'] = response.json()["id"]
+    properties_dict['format'] = format
     return SchemaProperties(
         **properties_dict
     )
 
 
 def _parse_response_schema(response):
+    # pylint:disable=redefined-builtin
+    schema_props_dict = _parse_schema_properties_dict(response)
+    format = response.headers.get('content-type').split('serialization=')[1]
+    schema_props_dict['format'] = format
     return Schema(
         definition=response.text(),
-        properties=SchemaProperties(**_parse_schema_properties_dict(response))
+        properties=SchemaProperties(**schema_props_dict)
     )

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/_azure_schema_registry.py

@@ -16,35 +16,37 @@
 
 if TYPE_CHECKING:
     # pylint: disable=unused-import,ungrouped-imports
-    from typing import Any, Dict
+    from typing import Any, Dict, Optional
 
     from azure.core.credentials import TokenCredential
     from azure.core.rest import HttpRequest, HttpResponse
 
 class AzureSchemaRegistry(object):
-    """Azure Schema Registry is as a central schema repository, complete with support for versioning, management, compatibility checking, and RBAC.
+    """Azure Schema Registry is as a central schema repository, with support for versioning, management, compatibility checking, and RBAC.
 
-    :param credential: Credential needed for the client to connect to Azure.
-    :type credential: ~azure.core.credentials.TokenCredential
     :param endpoint: The Schema Registry service endpoint, for example
-         my-namespace.servicebus.windows.net.
+     my-namespace.servicebus.windows.net.
     :type endpoint: str
+    :param credential: Credential needed for the client to connect to Azure.
+    :type credential: ~azure.core.credentials.TokenCredential
+    :keyword api_version: Api Version. The default value is "2021-10". Note that overriding this
+     default value may result in unsupported behavior.
+    :paramtype api_version: str
     """
 
     def __init__(
         self,
-        credential,  # type: "TokenCredential"
         endpoint,  # type: str
+        credential,  # type: "TokenCredential"
         **kwargs  # type: Any
     ):
         # type: (...) -> None
-        base_url = 'https://{endpoint}'
-        self._config = AzureSchemaRegistryConfiguration(credential, endpoint, **kwargs)
-        self._client = PipelineClient(base_url=base_url, config=self._config, **kwargs)
+        _endpoint = 'https://{endpoint}'
+        self._config = AzureSchemaRegistryConfiguration(endpoint=endpoint, credential=credential, **kwargs)
+        self._client = PipelineClient(base_url=_endpoint, config=self._config, **kwargs)
 
-        client_models = {}  # type: Dict[str, Any]
-        self._serialize = Serializer(client_models)
-        self._deserialize = Deserializer(client_models)
+        self._serialize = Serializer()
+        self._deserialize = Deserializer()
         self._serialize.client_side_validation = False
 
 
@@ -59,17 +61,14 @@ def send_request(
         We have helper methods to create requests specific to this service in `azure.schemaregistry._generated.rest`.
         Use these helper methods to create the request you pass to this method.
 
-        >>> from azure.schemaregistry._generated.rest import schema
-        >>> request = schema.build_get_by_id_request(schema_id, **kwargs)
-        <HttpRequest [GET], url: '/$schemagroups/getSchemaById/{schema-id}'>
+        >>> from azure.schemaregistry._generated.rest import schema_groups
+        >>> request = schema_groups.build_list_request(**kwargs)
+        <HttpRequest [GET], url: '/$schemaGroups'>
         >>> response = client.send_request(request)
         <HttpResponse: 200 OK>
 
         For more information on this code flow, see https://aka.ms/azsdk/python/protocol/quickstart
 
-        For advanced cases, you can also create your own :class:`~azure.core.rest.HttpRequest`
-        and pass it in.
-
         :param request: The network request you want to make. Required.
         :type request: ~azure.core.rest.HttpRequest
         :keyword bool stream: Whether the response payload will be streamed. Defaults to False.
@@ -79,8 +78,9 @@ 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)
         return self._client.send_request(request_copy, **kwargs)
 

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/_configuration.py

@@ -26,28 +26,32 @@ class AzureSchemaRegistryConfiguration(Configuration):
     Note that all parameters used to create this instance are saved as instance
     attributes.
 
-    :param credential: Credential needed for the client to connect to Azure.
-    :type credential: ~azure.core.credentials.TokenCredential
     :param endpoint: The Schema Registry service endpoint, for example my-namespace.servicebus.windows.net.
     :type endpoint: str
+    :param credential: Credential needed for the client to connect to Azure.
+    :type credential: ~azure.core.credentials.TokenCredential
+    :keyword api_version: Api Version. The default value is "2021-10". Note that overriding this default value may result in unsupported behavior.
+    :paramtype api_version: str
     """
 
     def __init__(
         self,
-        credential,  # type: "TokenCredential"
         endpoint,  # type: str
+        credential,  # type: "TokenCredential"
         **kwargs  # type: Any
     ):
         # type: (...) -> None
-        if credential is None:
-            raise ValueError("Parameter 'credential' must not be None.")
+        super(AzureSchemaRegistryConfiguration, self).__init__(**kwargs)
+        api_version = kwargs.pop('api_version', "2021-10")  # type: str
+
         if endpoint is None:
             raise ValueError("Parameter 'endpoint' must not be None.")
-        super(AzureSchemaRegistryConfiguration, self).__init__(**kwargs)
+        if credential is None:
+            raise ValueError("Parameter 'credential' must not be None.")
 
-        self.credential = credential
         self.endpoint = endpoint
-        self.api_version = "2020-09-01-preview"
+        self.credential = credential
+        self.api_version = api_version
         self.credential_scopes = kwargs.pop('credential_scopes', ['https://eventhubs.azure.net/.default'])
         kwargs.setdefault('sdk_moniker', 'azureschemaregistry/{}'.format(VERSION))
         self._configure(**kwargs)

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/_vendor.py

@@ -0,0 +1,21 @@
+# --------------------------------------------------------------------------
+# 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.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
+# --------------------------------------------------------------------------
+
+
+
+
+def _format_url_section(template, **kwargs):
+    components = template.split("/")
+    while components:
+        try:
+            return template.format(**kwargs)
+        except KeyError as key:
+            formatted_components = template.split("/")
+            components = [
+                c for c in formatted_components if "{}".format(key.args[0]) not in c
+            ]
+            template = "/".join(components)

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/_version.py

@@ -6,4 +6,4 @@
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 
-VERSION = "1.0.0b3"
+VERSION = "1.0.0"

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/aio/__init__.py

@@ -8,3 +8,9 @@
 
 from ._azure_schema_registry import AzureSchemaRegistry
 __all__ = ['AzureSchemaRegistry']
+
+try:
+    from ._patch import patch_sdk  # type: ignore
+    patch_sdk()
+except ImportError:
+    pass

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/aio/_azure_schema_registry.py

@@ -7,7 +7,7 @@
 # --------------------------------------------------------------------------
 
 from copy import deepcopy
-from typing import Any, Awaitable, TYPE_CHECKING
+from typing import Any, Awaitable, Optional, TYPE_CHECKING
 
 from azure.core import AsyncPipelineClient
 from azure.core.rest import AsyncHttpResponse, HttpRequest
@@ -22,28 +22,30 @@
     from azure.core.credentials_async import AsyncTokenCredential
 
 class AzureSchemaRegistry:
-    """Azure Schema Registry is as a central schema repository, complete with support for versioning, management, compatibility checking, and RBAC.
+    """Azure Schema Registry is as a central schema repository, with support for versioning, management, compatibility checking, and RBAC.
 
-    :param credential: Credential needed for the client to connect to Azure.
-    :type credential: ~azure.core.credentials_async.AsyncTokenCredential
     :param endpoint: The Schema Registry service endpoint, for example
-         my-namespace.servicebus.windows.net.
+     my-namespace.servicebus.windows.net.
     :type endpoint: str
+    :param credential: Credential needed for the client to connect to Azure.
+    :type credential: ~azure.core.credentials_async.AsyncTokenCredential
+    :keyword api_version: Api Version. The default value is "2021-10". Note that overriding this
+     default value may result in unsupported behavior.
+    :paramtype api_version: str
     """
 
     def __init__(
         self,
-        credential: "AsyncTokenCredential",
         endpoint: str,
+        credential: "AsyncTokenCredential",
         **kwargs: Any
     ) -> None:
-        base_url = 'https://{endpoint}'
-        self._config = AzureSchemaRegistryConfiguration(credential, endpoint, **kwargs)
-        self._client = AsyncPipelineClient(base_url=base_url, config=self._config, **kwargs)
+        _endpoint = 'https://{endpoint}'
+        self._config = AzureSchemaRegistryConfiguration(endpoint=endpoint, credential=credential, **kwargs)
+        self._client = AsyncPipelineClient(base_url=_endpoint, config=self._config, **kwargs)
 
-        client_models = {}  # type: Dict[str, Any]
-        self._serialize = Serializer(client_models)
-        self._deserialize = Deserializer(client_models)
+        self._serialize = Serializer()
+        self._deserialize = Deserializer()
         self._serialize.client_side_validation = False
 
 
@@ -57,17 +59,14 @@ def send_request(
         We have helper methods to create requests specific to this service in `azure.schemaregistry._generated.rest`.
         Use these helper methods to create the request you pass to this method.
 
-        >>> from azure.schemaregistry._generated.rest import schema
-        >>> request = schema.build_get_by_id_request(schema_id, **kwargs)
-        <HttpRequest [GET], url: '/$schemagroups/getSchemaById/{schema-id}'>
+        >>> from azure.schemaregistry._generated.rest import schema_groups
+        >>> request = schema_groups.build_list_request(**kwargs)
+        <HttpRequest [GET], url: '/$schemaGroups'>
         >>> response = await client.send_request(request)
         <AsyncHttpResponse: 200 OK>
 
         For more information on this code flow, see https://aka.ms/azsdk/python/protocol/quickstart
 
-        For advanced cases, you can also create your own :class:`~azure.core.rest.HttpRequest`
-        and pass it in.
-
         :param request: The network request you want to make. Required.
         :type request: ~azure.core.rest.HttpRequest
         :keyword bool stream: Whether the response payload will be streamed. Defaults to False.
@@ -77,8 +76,9 @@ 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)
         return self._client.send_request(request_copy, **kwargs)
 

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/aio/_configuration.py

@@ -24,27 +24,31 @@ class AzureSchemaRegistryConfiguration(Configuration):
     Note that all parameters used to create this instance are saved as instance
     attributes.
 
-    :param credential: Credential needed for the client to connect to Azure.
-    :type credential: ~azure.core.credentials_async.AsyncTokenCredential
     :param endpoint: The Schema Registry service endpoint, for example my-namespace.servicebus.windows.net.
     :type endpoint: str
+    :param credential: Credential needed for the client to connect to Azure.
+    :type credential: ~azure.core.credentials_async.AsyncTokenCredential
+    :keyword api_version: Api Version. The default value is "2021-10". Note that overriding this default value may result in unsupported behavior.
+    :paramtype api_version: str
     """
 
     def __init__(
         self,
-        credential: "AsyncTokenCredential",
         endpoint: str,
+        credential: "AsyncTokenCredential",
         **kwargs: Any
     ) -> None:
-        if credential is None:
-            raise ValueError("Parameter 'credential' must not be None.")
+        super(AzureSchemaRegistryConfiguration, self).__init__(**kwargs)
+        api_version = kwargs.pop('api_version', "2021-10")  # type: str
+
         if endpoint is None:
             raise ValueError("Parameter 'endpoint' must not be None.")
-        super(AzureSchemaRegistryConfiguration, self).__init__(**kwargs)
+        if credential is None:
+            raise ValueError("Parameter 'credential' must not be None.")
 
-        self.credential = credential
         self.endpoint = endpoint
-        self.api_version = "2020-09-01-preview"
+        self.credential = credential
+        self.api_version = api_version
         self.credential_scopes = kwargs.pop('credential_scopes', ['https://eventhubs.azure.net/.default'])
         kwargs.setdefault('sdk_moniker', 'azureschemaregistry/{}'.format(VERSION))
         self._configure(**kwargs)

sdk/schemaregistry/azure-schemaregistry/azure/schemaregistry/_generated/rest/schema/__init__.py

@@ -8,15 +8,18 @@
 
 try:
     from ._request_builders_py3 import build_get_by_id_request
+    from ._request_builders_py3 import build_get_versions_request
     from ._request_builders_py3 import build_query_id_by_content_request
     from ._request_builders_py3 import build_register_request
 except (SyntaxError, ImportError):
     from ._request_builders import build_get_by_id_request  # type: ignore
+    from ._request_builders import build_get_versions_request  # type: ignore
     from ._request_builders import build_query_id_by_content_request  # type: ignore
     from ._request_builders import build_register_request  # type: ignore
 
 __all__ = [
     'build_get_by_id_request',
+    'build_get_versions_request',
     'build_query_id_by_content_request',
     'build_register_request',
 ]