Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Socket
Sign inDemoInstall

diagnostic-channel-publishers

Package Overview
Dependencies
Maintainers
8
Versions
33
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

diagnostic-channel-publishers - npm Package Compare versions

Comparing version 1.0.0 to 1.0.1

64

dist/src/azure-coretracing.pub.js
"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",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc