First pass on Schema Registry convenience layer

sdk/schemaregistry/schema-registry/package.json

@@ -62,6 +62,8 @@
   "prettier": "@azure/eslint-plugin-azure-sdk/prettier.json",
   "dependencies": {
     "@azure/core-http": "^1.1.6",
+    "@azure/logger": "^1.0.0",
+    "@opentelemetry/api": "^0.10.2",
     "tslib": "^2.0.0"
   },
   "devDependencies": {

sdk/schemaregistry/schema-registry/review/schema-registry.api.md

@@ -4,6 +4,73 @@
 
 ```ts
 
+import { HttpOperationResponse } from '@azure/core-http';
+import { OperationOptions } from '@azure/core-http';
+import { PipelineOptions } from '@azure/core-http';
+import { TokenCredential } from '@azure/core-http';
+
+// @public
+export interface GetSchemaByIdOptions extends OperationOptions {
+}
+
+// @public
+export interface GetSchemaIdOptions extends OperationOptions {
+}
+
+// @public
+export interface RegisterSchemaOptions extends OperationOptions {
+}
+
+// @public
+export interface Response {
+    _response: HttpOperationResponse;
+}
+
+// @public
+export interface Schema extends SchemaDefinition, SchemaId {
+}
+
+// @public
+export interface SchemaDefinition {
+    content: string;
+}
+
+// @public
+export interface SchemaDescription extends SchemaDefinition {
+    group: string;
+    name: string;
+    serializationType: string;
+}
+
+// @public
+export interface SchemaId {
+    id: string;
+    location: string;
+    locationById: string;
+    version: number;
+}
+
+// @public
+export interface SchemaIdResponse extends SchemaId, Response {
+}
+
+// @public
+export class SchemaRegistryClient {
+    constructor(endpoint: string, credential: TokenCredential, options?: SchemaRegistryClientOptions);
+    readonly endpoint: string;
+    getSchemaById(id: string, options?: GetSchemaByIdOptions): Promise<SchemaResponse>;
+    getSchemaId(schema: SchemaDescription, options?: GetSchemaIdOptions): Promise<SchemaIdResponse>;
+    registerSchema(schema: SchemaDescription, options?: RegisterSchemaOptions): Promise<SchemaIdResponse>;
+}
+
+// @public
+export interface SchemaRegistryClientOptions extends PipelineOptions {
+}
+
+// @public
+export interface SchemaResponse extends Schema, Response {
+}
+
 
 // (No @packageDocumentation comment for this package)
 

sdk/schemaregistry/schema-registry/src/constants.ts

@@ -0,0 +1,6 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT license.
+
+export const SDK_VERSION: string = "1.0.0-preview.1";
+export const DEFAULT_SCOPE = "https://eventhubs.azure.net/.default";
+export const LIB_INFO = `azsdk-js-schema-registry/${SDK_VERSION}`;

sdk/schemaregistry/schema-registry/src/generated/generatedSchemaRegistryClient.ts

@@ -0,0 +1,41 @@
+/*
+ * Copyright (c) Microsoft Corporation.
+ * Licensed under the MIT License.
+ *
+ * Code generated by Microsoft (R) AutoRest Code Generator.
+ * Changes may cause incorrect behavior and will be lost if the code is regenerated.
+ */
+
+import * as operations from "./operations";
+import * as Models from "./models";
+import * as Mappers from "./models/mappers";
+import { GeneratedSchemaRegistryClientContext } from "./generatedSchemaRegistryClientContext";
+import { GeneratedSchemaRegistryClientOptionalParams } from "./models";
+
+class GeneratedSchemaRegistryClient extends GeneratedSchemaRegistryClientContext {
+  /**
+   * Initializes a new instance of the GeneratedSchemaRegistryClient class.
+   * @param endpoint The Schema Registry service endpoint, for example
+   *                 my-namespace.servicebus.windows.net.
+   * @param options The parameter options
+   */
+  constructor(
+    endpoint: string,
+    options?: GeneratedSchemaRegistryClientOptionalParams
+  ) {
+    super(endpoint, options);
+    this.schema = new operations.Schema(this);
+  }
+
+  schema: operations.Schema;
+}
+
+// Operation Specifications
+
+export {
+  GeneratedSchemaRegistryClient,
+  GeneratedSchemaRegistryClientContext,
+  Models as GeneratedSchemaRegistryModels,
+  Mappers as GeneratedSchemaRegistryMappers
+};
+export * from "./operations";

sdk/schemaregistry/schema-registry/src/generated/schemaRegistryClientContext.ts → sdk/schemaregistry/schema-registry/src/generated/generatedSchemaRegistryClientContext.ts

@@ -7,29 +7,25 @@
  */
 
 import * as coreHttp from "@azure/core-http";
-import { SchemaRegistryClientOptionalParams } from "./models";
+import { GeneratedSchemaRegistryClientOptionalParams } from "./models";
 
 const packageName = "@azure/schema-registry";
 const packageVersion = "1.0.0-preview.1";
 
-export class SchemaRegistryClientContext extends coreHttp.ServiceClient {
+export class GeneratedSchemaRegistryClientContext extends coreHttp.ServiceClient {
   endpoint: string;
+  apiVersion: string;
 
   /**
-   * Initializes a new instance of the SchemaRegistryClientContext class.
-   * @param credentials Subscription credentials which uniquely identify client subscription.
+   * Initializes a new instance of the GeneratedSchemaRegistryClientContext class.
    * @param endpoint The Schema Registry service endpoint, for example
-   *                 https://mynamespace.servicebus.windows.net.
+   *                 my-namespace.servicebus.windows.net.
    * @param options The parameter options
    */
   constructor(
-    credentials: coreHttp.TokenCredential | coreHttp.ServiceClientCredentials,
     endpoint: string,
-    options?: SchemaRegistryClientOptionalParams
+    options?: GeneratedSchemaRegistryClientOptionalParams
   ) {
-    if (credentials === undefined) {
-      throw new Error("'credentials' cannot be null");
-    }
     if (endpoint === undefined) {
       throw new Error("'endpoint' cannot be null");
     }
@@ -44,13 +40,16 @@ export class SchemaRegistryClientContext extends coreHttp.ServiceClient {
       options.userAgent = `${packageName}/${packageVersion} ${defaultUserAgent}`;
     }
 
-    super(credentials, options);
+    super(undefined, options);
 
     this.requestContentType = "application/json; charset=utf-8";
 
-    this.baseUri = options.endpoint || "{endpoint}/$schemagroups";
+    this.baseUri = options.endpoint || "https://{endpoint}";
 
     // Parameter assignments
     this.endpoint = endpoint;
+
+    // Assigning values to Constant parameters
+    this.apiVersion = options.apiVersion || "2018-01-01-preview";
   }
 }

sdk/schemaregistry/schema-registry/src/generated/models/index.ts

@@ -29,7 +29,7 @@ export interface SchemaGetByIdHeaders {
   /**
    * Serialization type for the schema being stored.
    */
-  xSerialization?: string;
+  xSchemaType?: string;
   /**
    * References specific schema in registry namespace.
    */
@@ -45,17 +45,17 @@ export interface SchemaGetByIdHeaders {
 }
 
 /**
- * Defines headers for Schema_getIdByContent operation.
+ * Defines headers for Schema_queryIdByContent operation.
  */
-export interface SchemaGetIdByContentHeaders {
+export interface SchemaQueryIdByContentHeaders {
   /**
    * URL location of schema, identified by schema group, schema name, and version.
    */
   location?: string;
   /**
    * Serialization type for the schema being stored.
    */
-  xSerialization?: string;
+  xSchemaType?: string;
   /**
    * References specific schema in registry namespace.
    */
@@ -81,7 +81,7 @@ export interface SchemaRegisterHeaders {
   /**
    * Serialization type for the schema being registered.
    */
-  xSerialization?: string;
+  xSchemaType?: string;
   /**
    * References specific schema in registry namespace.
    */
@@ -96,6 +96,11 @@ export interface SchemaRegisterHeaders {
   xSchemaVersion?: number;
 }
 
+/**
+ * Defines values for SerializationType.
+ */
+export type SerializationType = "avro";
+
 /**
  * Contains response data for the getById operation.
  */
@@ -126,9 +131,9 @@ export type SchemaGetByIdResponse = SchemaGetByIdHeaders & {
 };
 
 /**
- * Contains response data for the getIdByContent operation.
+ * Contains response data for the queryIdByContent operation.
  */
-export type SchemaGetIdByContentResponse = SchemaGetIdByContentHeaders &
+export type SchemaQueryIdByContentResponse = SchemaQueryIdByContentHeaders &
   SchemaId & {
     /**
      * The underlying HTTP response.
@@ -146,7 +151,7 @@ export type SchemaGetIdByContentResponse = SchemaGetIdByContentHeaders &
       /**
        * The parsed HTTP response headers.
        */
-      parsedHeaders: SchemaGetIdByContentHeaders;
+      parsedHeaders: SchemaQueryIdByContentHeaders;
     };
   };
 
@@ -178,8 +183,12 @@ export type SchemaRegisterResponse = SchemaRegisterHeaders &
 /**
  * Optional parameters.
  */
-export interface SchemaRegistryClientOptionalParams
+export interface GeneratedSchemaRegistryClientOptionalParams
   extends coreHttp.ServiceClientOptions {
+  /**
+   * Api Version
+   */
+  apiVersion?: string;
   /**
    * Overrides client endpoint.
    */

sdk/schemaregistry/schema-registry/src/generated/models/mappers.ts

@@ -34,8 +34,8 @@ export const SchemaGetByIdHeaders: coreHttp.CompositeMapper = {
           name: "String"
         }
       },
-      xSerialization: {
-        serializedName: "x-serialization",
+      xSchemaType: {
+        serializedName: "x-schema-type",
         type: {
           name: "String"
         }
@@ -62,19 +62,19 @@ export const SchemaGetByIdHeaders: coreHttp.CompositeMapper = {
   }
 };
 
-export const SchemaGetIdByContentHeaders: coreHttp.CompositeMapper = {
+export const SchemaQueryIdByContentHeaders: coreHttp.CompositeMapper = {
   type: {
     name: "Composite",
-    className: "SchemaGetIdByContentHeaders",
+    className: "SchemaQueryIdByContentHeaders",
     modelProperties: {
       location: {
         serializedName: "location",
         type: {
           name: "String"
         }
       },
-      xSerialization: {
-        serializedName: "x-serialization",
+      xSchemaType: {
+        serializedName: "x-schema-type",
         type: {
           name: "String"
         }
@@ -112,8 +112,8 @@ export const SchemaRegisterHeaders: coreHttp.CompositeMapper = {
           name: "String"
         }
       },
-      xSerialization: {
-        serializedName: "x-serialization",
+      xSchemaType: {
+        serializedName: "x-schema-type",
         type: {
           name: "String"
         }

sdk/schemaregistry/schema-registry/src/generated/models/parameters.ts

@@ -6,7 +6,11 @@
  * Changes may cause incorrect behavior and will be lost if the code is regenerated.
  */
 
-import { OperationURLParameter, OperationParameter } from "@azure/core-http";
+import {
+  OperationURLParameter,
+  OperationQueryParameter,
+  OperationParameter
+} from "@azure/core-http";
 
 export const endpoint: OperationURLParameter = {
   parameterPath: "endpoint",
@@ -31,6 +35,20 @@ export const schemaId: OperationURLParameter = {
   }
 };
 
+export const apiVersion: OperationQueryParameter = {
+  parameterPath: "apiVersion",
+  mapper: {
+    // TODO: Manually patched for now due to https://github.com/Azure/azure-rest-api-specs/pull/10220#discussion_r469588293
+    // defaultValue: "2018-01-01-preview",
+    defaultValue: "2017-04",
+    isConstant: true,
+    serializedName: "api-version",
+    type: {
+      name: "String"
+    }
+  }
+};
+
 export const contentType: OperationParameter = {
   parameterPath: ["options", "contentType"],
   mapper: {
@@ -76,10 +94,10 @@ export const schemaName: OperationURLParameter = {
   }
 };
 
-export const serializationType: OperationParameter = {
-  parameterPath: "serializationType",
+export const xSchemaType: OperationParameter = {
+  parameterPath: "xSchemaType",
   mapper: {
-    serializedName: "serialization-type",
+    serializedName: "X-Schema-Type",
     required: true,
     type: {
       name: "String"