diagnostic-channel-publishers
Advanced tools
Comparing version 1.0.0 to 1.0.1
"use strict"; | ||
var __assign = (this && this.__assign) || function () { | ||
__assign = Object.assign || function(t) { | ||
for (var s, i = 1, n = arguments.length; i < n; i++) { | ||
s = arguments[i]; | ||
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p)) | ||
t[p] = s[p]; | ||
} | ||
return t; | ||
}; | ||
return __assign.apply(this, arguments); | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
@@ -34,35 +23,26 @@ exports.enable = exports.azureCoreTracing = exports.AzureMonitorSymbol = void 0; | ||
var tracing = require("@opentelemetry/tracing"); | ||
var api_1 = require("@opentelemetry/api"); | ||
var tracerConfig = diagnostic_channel_1.channel.spanContextPropagator | ||
? { contextManager: diagnostic_channel_1.channel.spanContextPropagator } | ||
: undefined; | ||
new tracing.BasicTracerProvider().register(tracerConfig); | ||
var tracer = api_1.trace.getTracer("applicationinsights tracer"); | ||
// Patch startSpan instead of using spanProcessor.onStart because parentSpan must be | ||
// set while the span is constructed | ||
var startSpanOriginal_1 = tracer.startSpan; | ||
tracer.startSpan = function (name, options) { | ||
// if no parent span was provided, apply the current context | ||
if (!options || !options.parent) { | ||
var parentOperation = api_1.getSpan(api_1.context.active()); | ||
if (parentOperation && parentOperation.operation && parentOperation.operation.traceparent) { | ||
options = __assign(__assign({}, options), { parent: { | ||
traceId: parentOperation.operation.traceparent.traceId, | ||
spanId: parentOperation.operation.traceparent.spanId, | ||
traceFlags: 1, | ||
} }); | ||
} | ||
} | ||
var span = startSpanOriginal_1.call(this, name, options); | ||
var originalEnd = span.end; | ||
span.end = function () { | ||
var result = originalEnd.apply(this, arguments); | ||
diagnostic_channel_1.channel.publish("azure-coretracing", span); | ||
return result; | ||
var api = require("@opentelemetry/api"); | ||
var provider = new tracing.BasicTracerProvider(); | ||
var defaultTracer = provider.getTracer("applicationinsights tracer"); | ||
// Patch Azure SDK setTracer | ||
var setTracerOriginal_1 = coreTracing.setTracer; | ||
coreTracing.setTracer = function (tracer) { | ||
// Patch startSpan instead of using spanProcessor.onStart because parentSpan must be | ||
// set while the span is constructed | ||
var startSpanOriginal = tracer.startSpan; | ||
tracer.startSpan = function (name, options, context) { | ||
var span = startSpanOriginal.call(this, name, options, context); | ||
var originalEnd = span.end; | ||
span.end = function () { | ||
var result = originalEnd.apply(this, arguments); | ||
diagnostic_channel_1.channel.publish("azure-coretracing", span); | ||
return result; | ||
}; | ||
return span; | ||
}; | ||
return span; | ||
tracer[exports.AzureMonitorSymbol] = true; | ||
setTracerOriginal_1.call(this, tracer); | ||
}; | ||
api_1.getSpan(api_1.context.active()); // seed OpenTelemetryScopeManagerWrapper with "active" symbol | ||
tracer[exports.AzureMonitorSymbol] = true; | ||
coreTracing.setTracer(tracer); // recordSpanData is not present on BasicTracer - cast to any | ||
api.trace.getSpan(api.context.active()); // seed OpenTelemetryScopeManagerWrapper with "active" symbol | ||
coreTracing.setTracer(defaultTracer); | ||
isPatched = true; | ||
@@ -69,0 +49,0 @@ } |
{ | ||
"name": "diagnostic-channel-publishers", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"main": "dist/src/index.js", | ||
@@ -23,7 +23,7 @@ "types": "dist/src/index.d.ts", | ||
"devDependencies": { | ||
"@azure/core-tracing": "^1.0.0-preview.11", | ||
"@opentelemetry/api": "^0.18.1", | ||
"@opentelemetry/tracing": "^0.19.0", | ||
"@azure/core-tracing": "^1.0.0-preview.12", | ||
"@opentelemetry/api": "^1.0.0", | ||
"@opentelemetry/tracing": "^0.23.0", | ||
"@types/mocha": "^8.2.2", | ||
"@types/node": "~8.0.0", | ||
"@types/node": "^8.5.0", | ||
"@types/pg": "7.4.11", | ||
@@ -30,0 +30,0 @@ "@types/tedious": "^4.0.3", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
56589
1207