Initial Prototype Code - Do NOT Merge

rush.json

@@ -389,6 +389,10 @@
     {
       "packageName": "@azure/template",
       "projectFolder": "sdk/template/template"
+    },
+    {
+      "packageName": "@azure/core-tracing",
+      "projectFolder": "sdk/core/core-tracing"
     }
   ]
 }

sdk/core/core-http/lib/webResource.ts

@@ -9,8 +9,21 @@ import { HttpOperationResponse } from "./httpOperationResponse";
 import { OperationResponse } from "./operationResponse";
 import { ProxySettings } from "./serviceClient";
 
-export type HttpMethods = "GET" | "PUT" | "POST" | "DELETE" | "PATCH" | "HEAD" | "OPTIONS" | "TRACE";
-export type HttpRequestBody = Blob | string | ArrayBuffer | ArrayBufferView | (() => NodeJS.ReadableStream);
+export type HttpMethods =
+  | "GET"
+  | "PUT"
+  | "POST"
+  | "DELETE"
+  | "PATCH"
+  | "HEAD"
+  | "OPTIONS"
+  | "TRACE";
+export type HttpRequestBody =
+  | Blob
+  | string
+  | ArrayBuffer
+  | ArrayBufferView
+  | (() => NodeJS.ReadableStream);
 
 /**
  * Fired in response to upload or download progress.
@@ -19,7 +32,7 @@ export type TransferProgressEvent = {
   /**
    * The number of bytes loaded so far.
    */
-  loadedBytes: number
+  loadedBytes: number;
 };
 
 /**
@@ -28,8 +41,16 @@ export type TransferProgressEvent = {
  */
 export interface AbortSignalLike {
   readonly aborted: boolean;
-  addEventListener(type: "abort", listener: (this: AbortSignalLike, ev: any) => any, options?: any): void;
-  removeEventListener(type: "abort", listener: (this: AbortSignalLike, ev: any) => any, options?: any): void;
+  addEventListener(
+    type: "abort",
+    listener: (this: AbortSignalLike, ev: any) => any,
+    options?: any
+  ): void;
+  removeEventListener(
+    type: "abort",
+    listener: (this: AbortSignalLike, ev: any) => any,
+    options?: any
+  ): void;
 }
 
 /**
@@ -59,9 +80,12 @@ export class WebResource {
    * HttpOperationResponse combination. If this is undefined, then a simple status code lookup will
    * be used.
    */
-  operationResponseGetter?: (operationSpec: OperationSpec, response: HttpOperationResponse) => (undefined | OperationResponse);
+  operationResponseGetter?: (
+    operationSpec: OperationSpec,
+    response: HttpOperationResponse
+  ) => undefined | OperationResponse;
   formData?: any;
-  query?: { [key: string]: any; };
+  query?: { [key: string]: any };
   operationSpec?: OperationSpec;
   withCredentials: boolean;
   timeout: number;
@@ -79,20 +103,20 @@ export class WebResource {
     url?: string,
     method?: HttpMethods,
     body?: any,
-    query?: { [key: string]: any; },
-    headers?: { [key: string]: any; } | HttpHeaders,
+    query?: { [key: string]: any },
+    headers?: { [key: string]: any } | HttpHeaders,
     streamResponseBody?: boolean,
     withCredentials?: boolean,
     abortSignal?: AbortSignalLike,
     timeout?: number,
     onUploadProgress?: (progress: TransferProgressEvent) => void,
     onDownloadProgress?: (progress: TransferProgressEvent) => void,
-    proxySettings?: ProxySettings) {
-
+    proxySettings?: ProxySettings
+  ) {
     this.streamResponseBody = streamResponseBody;
     this.url = url || "";
     this.method = method || "GET";
-    this.headers = (headers instanceof HttpHeaders ? headers : new HttpHeaders(headers));
+    this.headers = headers instanceof HttpHeaders ? headers : new HttpHeaders(headers);
     this.body = body;
     this.query = query;
     this.formData = undefined;
@@ -133,18 +157,22 @@ export class WebResource {
     }
 
     if (options.url && options.pathTemplate) {
-      throw new Error("options.url and options.pathTemplate are mutually exclusive. Please provide exactly one of them.");
+      throw new Error(
+        "options.url and options.pathTemplate are mutually exclusive. Please provide exactly one of them."
+      );
     }
 
-
-    if ((options.pathTemplate == undefined || typeof options.pathTemplate.valueOf() !== "string") && (options.url == undefined || typeof options.url.valueOf() !== "string")) {
+    if (
+      (options.pathTemplate == undefined || typeof options.pathTemplate.valueOf() !== "string") &&
+      (options.url == undefined || typeof options.url.valueOf() !== "string")
+    ) {
       throw new Error("Please provide exactly one of options.pathTemplate or options.url.");
     }
 
     // set the url if it is provided.
     if (options.url) {
       if (typeof options.url !== "string") {
-        throw new Error("options.url must be of type \"string\".");
+        throw new Error('options.url must be of type "string".');
       }
       this.url = options.url;
     }
@@ -153,35 +181,55 @@ export class WebResource {
     if (options.method) {
       const validMethods = ["GET", "PUT", "HEAD", "DELETE", "OPTIONS", "POST", "PATCH", "TRACE"];
       if (validMethods.indexOf(options.method.toUpperCase()) === -1) {
-        throw new Error("The provided method \"" + options.method + "\" is invalid. Supported HTTP methods are: " + JSON.stringify(validMethods));
+        throw new Error(
+          'The provided method "' +
+            options.method +
+            '" is invalid. Supported HTTP methods are: ' +
+            JSON.stringify(validMethods)
+        );
       }
     }
-    this.method = (options.method.toUpperCase() as HttpMethods);
+    this.method = options.method.toUpperCase() as HttpMethods;
 
     // construct the url if path template is provided
     if (options.pathTemplate) {
       const { pathTemplate, pathParameters } = options;
       if (typeof pathTemplate !== "string") {
-        throw new Error("options.pathTemplate must be of type \"string\".");
+        throw new Error('options.pathTemplate must be of type "string".');
       }
       if (!options.baseUrl) {
         options.baseUrl = "https://management.azure.com";
       }
       const baseUrl = options.baseUrl;
-      let url = baseUrl + (baseUrl.endsWith("/") ? "" : "/") + (pathTemplate.startsWith("/") ? pathTemplate.slice(1) : pathTemplate);
-      const segments = url.match(/({\w*\s*\w*})/ig);
+      let url =
+        baseUrl +
+        (baseUrl.endsWith("/") ? "" : "/") +
+        (pathTemplate.startsWith("/") ? pathTemplate.slice(1) : pathTemplate);
+      const segments = url.match(/({\w*\s*\w*})/gi);
       if (segments && segments.length) {
         if (!pathParameters) {
-          throw new Error(`pathTemplate: ${pathTemplate} has been provided. Hence, options.pathParameters must also be provided.`);
+          throw new Error(
+            `pathTemplate: ${pathTemplate} has been provided. Hence, options.pathParameters must also be provided.`
+          );
         }
-        segments.forEach(function (item) {
+        segments.forEach(function(item) {
           const pathParamName = item.slice(1, -1);
           const pathParam = (pathParameters as { [key: string]: any })[pathParamName];
-          if (pathParam === null || pathParam === undefined || !(typeof pathParam === "string" || typeof pathParam === "object")) {
-            throw new Error(`pathTemplate: ${pathTemplate} contains the path parameter ${pathParamName}` +
-              ` however, it is not present in ${pathParameters} - ${JSON.stringify(pathParameters, undefined, 2)}.` +
-              `The value of the path parameter can either be a "string" of the form { ${pathParamName}: "some sample value" } or ` +
-              `it can be an "object" of the form { "${pathParamName}": { value: "some sample value", skipUrlEncoding: true } }.`);
+          if (
+            pathParam === null ||
+            pathParam === undefined ||
+            !(typeof pathParam === "string" || typeof pathParam === "object")
+          ) {
+            throw new Error(
+              `pathTemplate: ${pathTemplate} contains the path parameter ${pathParamName}` +
+                ` however, it is not present in ${pathParameters} - ${JSON.stringify(
+                  pathParameters,
+                  undefined,
+                  2
+                )}.` +
+                `The value of the path parameter can either be a "string" of the form { ${pathParamName}: "some sample value" } or ` +
+                `it can be an "object" of the form { "${pathParamName}": { value: "some sample value", skipUrlEncoding: true } }.`
+            );
           }
 
           if (typeof pathParam.valueOf() === "string") {
@@ -190,7 +238,9 @@ export class WebResource {
 
           if (typeof pathParam.valueOf() === "object") {
             if (!pathParam.value) {
-              throw new Error(`options.pathParameters[${pathParamName}] is of type "object" but it does not contain a "value" property.`);
+              throw new Error(
+                `options.pathParameters[${pathParamName}] is of type "object" but it does not contain a "value" property.`
+              );
             }
             if (pathParam.skipUrlEncoding) {
               url = url.replace(item, pathParam.value);
@@ -207,9 +257,11 @@ export class WebResource {
     if (options.queryParameters) {
       const queryParameters = options.queryParameters;
       if (typeof queryParameters !== "object") {
-        throw new Error(`options.queryParameters must be of type object. It should be a JSON object ` +
-          `of "query-parameter-name" as the key and the "query-parameter-value" as the value. ` +
-          `The "query-parameter-value" may be fo type "string" or an "object" of the form { value: "query-parameter-value", skipUrlEncoding: true }.`);
+        throw new Error(
+          `options.queryParameters must be of type object. It should be a JSON object ` +
+            `of "query-parameter-name" as the key and the "query-parameter-value" as the value. ` +
+            `The "query-parameter-value" may be fo type "string" or an "object" of the form { value: "query-parameter-value", skipUrlEncoding: true }.`
+        );
       }
       // append question mark if it is not present in the url
       if (this.url && this.url.indexOf("?") === -1) {
@@ -225,10 +277,11 @@ export class WebResource {
           if (typeof queryParam === "string") {
             queryParams.push(queryParamName + "=" + encodeURIComponent(queryParam));
             this.query[queryParamName] = encodeURIComponent(queryParam);
-          }
-          else if (typeof queryParam === "object") {
+          } else if (typeof queryParam === "object") {
             if (!queryParam.value) {
-              throw new Error(`options.queryParameters[${queryParamName}] is of type "object" but it does not contain a "value" property.`);
+              throw new Error(
+                `options.queryParameters[${queryParamName}] is of type "object" but it does not contain a "value" property.`
+              );
             }
             if (queryParam.skipUrlEncoding) {
               queryParams.push(queryParamName + "=" + queryParam.value);
@@ -239,7 +292,7 @@ export class WebResource {
             }
           }
         }
-      }// end-of-for
+      } // end-of-for
       // append the queryString
       this.url += queryParams.join("&");
     }
@@ -278,7 +331,11 @@ export class WebResource {
         }
       } else {
         if (options.serializationMapper) {
-          this.body = new Serializer(options.mappers).serialize(options.serializationMapper, options.body, "requestBody");
+          this.body = new Serializer(options.mappers).serialize(
+            options.serializationMapper,
+            options.body,
+            "requestBody"
+          );
         }
         if (!options.disableJsonStringifyOnBody) {
           this.body = JSON.stringify(options.body);
@@ -309,7 +366,8 @@ export class WebResource {
       this.abortSignal,
       this.timeout,
       this.onUploadProgress,
-      this.onDownloadProgress);
+      this.onDownloadProgress
+    );
 
     if (this.formData) {
       result.formData = this.formData;
@@ -460,5 +518,7 @@ export interface RequestOptionsBase {
    */
   onDownloadProgress?: (progress: TransferProgressEvent) => void;
 
+  spanOptions?: any;
+
   [key: string]: any;
 }

sdk/core/core-http/package.json

@@ -110,6 +110,7 @@
     "all": true
   },
   "dependencies": {
+    "@azure/core-tracing": "1.0.0-preview.1",
     "@azure/core-auth": "1.0.0-preview.1",
     "@types/tunnel": "^0.0.0",
     "axios": "^0.19.0",

sdk/core/core-tracing/.typings/karma.d.ts

@@ -0,0 +1,10 @@
+import * as karma from "karma";
+
+export type Config = karma.Config & {
+    rollupPreprocessor: any;
+    set: (config: ConfigOptions) => void;
+}
+
+export type ConfigOptions = karma.ConfigOptions & {
+    rollupPreprocessor: any;
+}

sdk/core/core-tracing/.typings/rollup-plugin-alias.d.ts

@@ -0,0 +1,4 @@
+declare module "rollup-plugin-alias" {
+    const alias(options: { [_: string]: string }) => void;
+    export default alias;
+}

sdk/core/core-tracing/.typings/rollup-plugin-commonjs.d.ts

@@ -0,0 +1,4 @@
+declare module "rollup-plugin-commonjs" {
+    const commonjs(options?: any) => void;
+    export default commonjs;
+}

sdk/core/core-tracing/.typings/rollup-plugin-json.d.ts

@@ -0,0 +1,4 @@
+declare module "rollup-plugin-json" {
+    const json() => void;
+    export default json;
+}

sdk/core/core-tracing/.typings/rollup-plugin-multi-entry.d.ts

@@ -0,0 +1,4 @@
+declare module 'rollup-plugin-multi-entry' {
+    const multiEntry: () => void;
+    export default multiEntry;
+}

sdk/core/core-tracing/.typings/rollup-plugin-node-resolve.d.ts

@@ -0,0 +1,4 @@
+declare module "rollup-plugin-node-resolve" {
+    const nodeResolve(options: { [_: string]: any }) => void;
+    export default nodeResolve;
+}

sdk/core/core-tracing/.typings/rollup-plugin-sourcemaps.d.ts

@@ -0,0 +1,4 @@
+declare module "rollup-plugin-sourcemaps" {
+    const sourcemaps() => void;
+    export default sourcemaps;
+}

sdk/core/core-tracing/.typings/rollup-plugin-visualizer.d.ts

@@ -0,0 +1,4 @@
+declare module "rollup-plugin-visualizer" {
+    const visualizer(options?: { [_: string]: any }) => void;
+    export default visualizer;
+}

sdk/core/core-tracing/Changelog.md

@@ -0,0 +1 @@
+# Changelog

sdk/core/core-tracing/LICENSE.txt

@@ -0,0 +1,21 @@
+    MIT License
+
+    Copyright (c) Microsoft Corporation. All rights reserved.
+
+    Permission is hereby granted, free of charge, to any person obtaining a copy
+    of this software and associated documentation files (the "Software"), to deal
+    in the Software without restriction, including without limitation the rights
+    to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+    copies of the Software, and to permit persons to whom the Software is
+    furnished to do so, subject to the following conditions:
+
+    The above copyright notice and this permission notice shall be included in all
+    copies or substantial portions of the Software.
+
+    THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+    IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+    FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+    AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+    LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+    OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+    SOFTWARE

sdk/core/core-tracing/README.md

@@ -0,0 +1,23 @@
+# Azure Core HTTP client library for JS
+
+This is the core HTTP pipeline for Azure SDK JavaScript libraries which work in the browser and Node.js. This library is primarily intended to be used in code generated by [AutoRest](https://github.com/Azure/Autorest).
+
+## Getting started
+
+Coming soon....
+
+## Contributing
+
+This project welcomes contributions and suggestions. Most contributions require you to agree to a
+Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us
+the rights to use your contribution. For details, visit https://cla.microsoft.com.
+
+When you submit a pull request, a CLA-bot will automatically determine whether you need to provide
+a CLA and decorate the PR appropriately (e.g., label, comment). Simply follow the instructions
+provided by the bot. You will only need to do this once across all repos using our CLA.
+
+If you'd like to contribute to this library, please read the [contributing guide](../../../CONTRIBUTING.md) to learn more about how to build and test the code.
+
+This project has adopted the [Microsoft Open Source Code of Conduct](https://opensource.microsoft.com/codeofconduct/).
+For more information see the [Code of Conduct FAQ](https://opensource.microsoft.com/codeofconduct/faq/) or
+contact [opencode@microsoft.com](mailto:opencode@microsoft.com) with any additional questions or comments.