open-telemetry · mayurkale22 · Dec 19, 2019 · Dec 5, 2019 · Dec 5, 2019 · Dec 5, 2019
diff --git a/examples/tracer-web/README.md b/examples/tracer-web/README.md
@@ -1,7 +1,6 @@
 # Overview
 
-This example shows how to use [@opentelemetry/web](https://github.com/open-telemetry/opentelemetry-js/tree/master/packages/opentelemetry-web) to instrument your JavaScript code running in the browser.
-This example uses the `ConsoleSpanExporter()` to export spans to the browser console output.
+This example shows how to use [@opentelemetry/web](https://github.com/open-telemetry/opentelemetry-js/tree/master/packages/opentelemetry-web) with different plugins and setup to instrument your JavaScript code running in the browser.
 
 ## Installation
 

diff --git a/examples/tracer-web/index.html → ...cer-web/examples/document-load/index.html b/examples/tracer-web/index.html → ...cer-web/examples/document-load/index.html
@@ -22,7 +22,7 @@
 
 <body>
   Example of using Web Tracer with document load plugin with console exporter and collector exporter
-  <script type="text/javascript" src="/bundle.js"></script>
+  <script type="text/javascript" src="document-load.js"></script>
   <br/>
   <button id="button1">Test WebTracer with ZoneScopeManager - async</button>
 

diff --git a/examples/tracer-web/index.js → ...racer-web/examples/document-load/index.js b/examples/tracer-web/index.js → ...racer-web/examples/document-load/index.js
diff --git a/examples/tracer-web/examples/xml-http-request/index.html b/examples/tracer-web/examples/xml-http-request/index.html
@@ -0,0 +1,31 @@
+<!DOCTYPE html>
+<html lang="en">
+
+<head>
+  <meta charset="utf-8">
+  <title>Web Tracer Example</title>
+  <base href="/">
+
+  <!--
+    https://www.w3.org/TR/trace-context/
+    Set the `traceparent` in the server's HTML template code. It should be
+    dynamically generated server side to have the server's request trace Id,
+    a parent span Id that was set on the server's request span, and the trace
+    flags to indicate the server's sampling decision
+    (01 = sampled, 00 = notsampled).
+    '{version}-{traceId}-{spanId}-{sampleDecision}'
+  -->
+  <meta name="traceparent" content="00-ab42124a3c573678d4d8b21ba52df3bf-d21f7bc17caa5aba-01">
+
+  <meta name="viewport" content="width=device-width, initial-scale=1">
+</head>
+
+<body>
+  Example of using Web Tracer with XMLHttpRequest plugin with console exporter and collector exporter
+  <script type="text/javascript" src="xml-http-request.js"></script>
+  <br/>
+  <button id="button1">Test</button>
+
+</body>
+
+</html>
diff --git a/examples/tracer-web/examples/xml-http-request/index.js b/examples/tracer-web/examples/xml-http-request/index.js
@@ -0,0 +1,60 @@
+import { ConsoleSpanExporter, SimpleSpanProcessor } from '@opentelemetry/tracing';
+import { WebTracer } from '@opentelemetry/web';
+import { XMLHttpRequestPlugin } from '@opentelemetry/plugin-xml-http-request';
+import { ZoneScopeManager } from '@opentelemetry/scope-zone';
+import { CollectorExporter } from '@opentelemetry/exporter-collector';
+
+const webTracerWithZone = new WebTracer({
+  scopeManager: new ZoneScopeManager(),
+  plugins: [
+    new XMLHttpRequestPlugin({
+      ignoreUrls: ['http://localhost:8090/sockjs-node/info'],
+      propagateTraceHeaderUrls: [
+        'http://localhost:8090'
+      ]
+    })
+  ]
+});
+
+webTracerWithZone.addSpanProcessor(new SimpleSpanProcessor(new ConsoleSpanExporter()));
+webTracerWithZone.addSpanProcessor(new SimpleSpanProcessor(new CollectorExporter()));
+
+// example of keeping track of scope between async operations
+const prepareClickEvent = () => {
+  const url1 = 'http://localhost:8090/xml-http-request.js';
+
+  const element = document.getElementById('button1');
+  let mainSpan = webTracerWithZone.startSpan('main-span');
+  webTracerWithZone.bind(element, mainSpan);
+
+  const onClick = () => {
+    const span1 = webTracerWithZone.startSpan(`files-series-info-1`, {
+      parent: webTracerWithZone.getCurrentSpan()
+    });
+
+    webTracerWithZone.withSpan(span1, () => {
+      getData(url1).then((data) => {
+        webTracerWithZone.getCurrentSpan().addEvent('fetching-span1-completed');
+        span1.end();
+      });
+    });
+
+  };
+  element.addEventListener('click', onClick);
+};
+
+const getData = (url) => {
+  return new Promise(async (resolve, reject) => {
+    const req = new XMLHttpRequest();
+    req.open('GET', url, true);
+    req.withCredentials = true;
+    req.send();
+    req.onload = function () {
+      resolve();
+    };
+  });
+};
+
+window.addEventListener('load', () => {
+  prepareClickEvent();
+});
diff --git a/examples/tracer-web/package.json b/examples/tracer-web/package.json
@@ -5,7 +5,7 @@
   "description": "Example of using @opentelemetry/web in browser",
   "main": "index.js",
   "scripts": {
-    "start": "webpack-dev-server -d --progress --colors --port 8090 --config webpack.config.js --hot --inline --host 0.0.0.0"
+    "start": "webpack-dev-server -d --progress --colors --port 8090 --config webpack.config.js --hot --inline --host 0.0.0.0 --content-base examples"
   },
   "repository": {
     "type": "git",
@@ -38,7 +38,8 @@
     "@opentelemetry/plugin-document-load": "^0.2.0",
     "@opentelemetry/scope-zone": "^0.2.0",
     "@opentelemetry/tracing": "^0.2.0",
-    "@opentelemetry/web": "^0.2.0"
+    "@opentelemetry/web": "^0.2.0",
+    "@opentelemetry/plugin-xml-http-request": "^0.3.0"
   },
   "homepage": "https://github.com/open-telemetry/opentelemetry-js#readme"
 }
diff --git a/examples/tracer-web/webpack.config.js b/examples/tracer-web/webpack.config.js
@@ -1,12 +1,19 @@
 const webpack = require('webpack');
 const webpackMerge = require('webpack-merge');
 const path = require('path');
-const mainPath = path.resolve('');
 const directory = path.resolve(__dirname);
 
 const common = {
   mode: 'development',
-  entry: 'index.js',
+  entry: {
+    'document-load': 'examples/document-load/index.js',
+    'xml-http-request': 'examples/xml-http-request/index.js'
+  },
+  output: {
+    path: path.resolve(__dirname, 'dist'),
+    filename: '[name].js',
+    sourceMapFilename: '[file].map'
+  },
   target: 'web',
   module: {
     rules: [
@@ -28,7 +35,6 @@ const common = {
   },
   resolve: {
     modules: [
-      path.resolve(mainPath, 'src'),
       path.resolve(directory),
       'node_modules'
     ],
@@ -38,12 +44,8 @@ const common = {
 
 module.exports = webpackMerge(common, {
   devtool: 'eval-source-map',
-  output: {
-    filename: 'bundle.js',
-    sourceMapFilename: '[file].map'
-  },
   devServer: {
-    contentBase: path.resolve(__dirname),
+    contentBase: path.resolve(__dirname)
   },
   plugins: [
     new webpack.DefinePlugin({

diff --git a/packages/opentelemetry-core/src/common/time.ts b/packages/opentelemetry-core/src/common/time.ts
@@ -19,7 +19,7 @@ import { otperformance as performance } from '../platform';
 import { TimeOriginLegacy } from './types';
 
 const NANOSECOND_DIGITS = 9;
-const SECOND_TO_NANOSECONDS = Math.pow(10, NANOSECOND_DIGITS);
+export const SECOND_TO_NANOSECONDS = Math.pow(10, NANOSECOND_DIGITS);
 
 /**
  * Converts a number to HrTime

diff --git a/packages/opentelemetry-core/src/common/types.ts b/packages/opentelemetry-core/src/common/types.ts
@@ -32,3 +32,13 @@ export interface TimeOriginLegacy {
     fetchStart: number;
   };
 }
+
+/**
+ * This interface defines the params that are be added to the wrapped function
+ * using the "shimmer.wrap"
+ */
+export interface ShimWrapped {
+  __wrapped: boolean;
+  __unwrap: Function;
+  __original: Function;
+}
diff --git a/packages/opentelemetry-core/src/index.ts b/packages/opentelemetry-core/src/index.ts
@@ -25,6 +25,7 @@ export * from './context/propagation/HttpTraceContext';
 export * from './platform';
 export * from './trace/globaltracer-utils';
 export * from './trace/instrumentation/BasePlugin';
+export * from './trace/instrumentation/basePluginUtils';
 export * from './trace/NoopSpan';
 export * from './trace/NoopTracer';
 export * from './trace/NoRecordingSpan';
@@ -33,3 +34,4 @@ export * from './trace/spancontext-utils';
 export * from './trace/TracerDelegate';
 export * from './trace/TraceState';
 export * from './metrics/NoopMeter';
+export * from './utils/wrap';
diff --git a/packages/opentelemetry-core/src/trace/instrumentation/basePluginUtils.ts b/packages/opentelemetry-core/src/trace/instrumentation/basePluginUtils.ts
@@ -0,0 +1,48 @@
+/*!
+ * Copyright 2019, OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * Check if {@param url} matches {@param urlToMatch}
+ * @param url
+ * @param urlToMatch
+ */
+export function urlMatches(url: string, urlToMatch: string | RegExp): boolean {
+  if (typeof urlToMatch === 'string') {
+    return url === urlToMatch;
+  } else {
+    return !!url.match(urlToMatch);
+  }
+}
+/**
+ * Check if {@param url} should be ignored when comparing against {@param ignoredUrls}
+ * @param url
+ * @param ignoredUrls
+ */
+export function isUrlIgnored(
+  url: string,
+  ignoredUrls?: Array<string | RegExp>
+): boolean {
+  if (!ignoredUrls) {
+    return false;
+  }
+
+  for (const ignoreUrl of ignoredUrls) {
+    if (urlMatches(url, ignoreUrl)) {
+      return true;
+    }
+  }
+  return false;
+}
diff --git a/packages/opentelemetry-core/src/utils/wrap.ts b/packages/opentelemetry-core/src/utils/wrap.ts
@@ -0,0 +1,30 @@
+/*!
+ * Copyright 2019, OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { ShimWrapped } from '../common/types';
+
+/**
+ * Checks if certain function has been already wrapped
+ * @param func
+ */
+export function isWrapped(func: any) {
+  return (
+    typeof func === 'function' &&
+    typeof (func as ShimWrapped).__original === 'function' &&
+    typeof (func as ShimWrapped).__unwrap === 'function' &&
+    (func as ShimWrapped).__wrapped === true
+  );
+}
diff --git a/packages/opentelemetry-core/test/trace/basePluginUtils.test.ts b/packages/opentelemetry-core/test/trace/basePluginUtils.test.ts
@@ -0,0 +1,75 @@
+/**
+ * Copyright 2019, OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import * as assert from 'assert';
+
+import { isUrlIgnored } from '../../src';
+
+const urlIgnored = 'url should be ignored';
+const urlNotIgnored = 'url should NOT be ignored';
+
+const urlToTest = 'http://myaddress.com/somepath';
+
+describe('BasePlugin - Utils', () => {
+  describe('isUrlIgnored', () => {
+    describe('when ignored urls are undefined', () => {
+      it('should return false', () => {
+        assert.strictEqual(isUrlIgnored(urlToTest), false, urlNotIgnored);
+      });
+    });
+    describe('when ignored urls are empty', () => {
+      it('should return false', () => {
+        assert.strictEqual(isUrlIgnored(urlToTest, []), false, urlNotIgnored);
+      });
+    });
+    describe('when ignored urls is the same as url', () => {
+      it('should return true', () => {
+        assert.strictEqual(
+          isUrlIgnored(urlToTest, ['http://myaddress.com/somepath']),
+          true,
+          urlIgnored
+        );
+      });
+    });
+    describe('when url is part of ignored urls', () => {
+      it('should return false', () => {
+        assert.strictEqual(
+          isUrlIgnored(urlToTest, ['http://myaddress.com/some']),
+          false,
+          urlNotIgnored
+        );
+      });
+    });
+    describe('when ignored urls is part of url - REGEXP', () => {
+      it('should return true', () => {
+        assert.strictEqual(
+          isUrlIgnored(urlToTest, [/.+?myaddress\.com/]),
+          true,
+          urlIgnored
+        );
+      });
+    });
+    describe('when url is part of ignored urls - REGEXP', () => {
+      it('should return false', () => {
+        assert.strictEqual(
+          isUrlIgnored(urlToTest, [/http:\/\/myaddress\.com\/somepath2/]),
+          false,
+          urlNotIgnored
+        );
+      });
+    });
+  });
+});