hypertrace-publisher

@hypertrace/nodejsagent

Object.defineProperty(exports, "__esModule", { value: true });

    'propagation_formats': ['TRACECONTEXT'],

        'endpoint': 'http://localhost:4317',

            'endpoint': 'http://opa.traceableai:8181/',

        'body_max_processing_size_bytes': 131072

    return JSON.parse(JSON.stringify(DEFAULT_AGENT_CONFIG));

exports.getDefaultConfigValues = getDefaultConfigValues;

const envSettings_1 = require("./envSettings");

    let enabled = (0, envSettings_1.getEnvValue)('ENABLED');

        envConfig['enabled'] = isTrue(enabled);

    let serviceName = (0, envSettings_1.getEnvValue)('SERVICE_NAME');

        envConfig['service_name'] = serviceName;

    let reportingEndpoint = (0, envSettings_1.getEnvValue)('REPORTING_ENDPOINT');

        reporting['endpoint'] = reportingEndpoint;

    let traceReporterType = (0, envSettings_1.getEnvValue)('REPORTING_TRACE_REPORTER_TYPE');

        reporting['trace_reporter_type'] = traceReporterType;

    let reportingSecure = (0, envSettings_1.getEnvValue)('REPORTING_SECURE');

        reporting['secure'] = isTrue(reportingSecure);

    let reportingCertFile = (0, envSettings_1.getEnvValue)("REPORTING_CERT_FILE");

        reporting["cert_file"] = reportingCertFile;

    let reportingToken = (0, envSettings_1.getEnvValue)('REPORTING_TOKEN');

        reporting['token'] = reportingToken;

    if (Object.keys(reporting).length > 0) {

        envConfig['reporting'] = reporting;

    let httpHeadersRequest = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_HTTP_HEADERS_REQUEST');

        dataCapture['http_headers'] = {};

        dataCapture['http_headers']['request'] = isTrue(httpHeadersRequest);

    let httpHeadersResponse = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_HTTP_HEADERS_RESPONSE');

        dataCapture['http_headers'] || (dataCapture['http_headers'] = {});

        dataCapture['http_headers']['response'] = isTrue(httpHeadersResponse);

    let httpBodyRequest = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_HTTP_BODY_REQUEST');

        dataCapture['http_body']['request'] = isTrue(httpBodyRequest);

    let httpBodyResponse = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_HTTP_BODY_RESPONSE');

        dataCapture['http_body'] || (dataCapture['http_body'] = {});

        dataCapture['http_body']['response'] = isTrue(httpBodyResponse);

    let rpcMetadataRequest = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_RPC_METADATA_REQUEST');

        dataCapture['rpc_metadata'] = {};

        dataCapture['rpc_metadata']['request'] = isTrue(rpcMetadataRequest);

    let rpcMetadataResponse = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_RPC_METADATA_RESPONSE');

        dataCapture['rpc_metadata'] || (dataCapture['rpc_metadata'] = {});

        dataCapture['rpc_metadata']['response'] = isTrue(rpcMetadataResponse);

    let rpcBodyRequest = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_RPC_BODY_REQUEST');

        dataCapture['rpc_body']['request'] = isTrue(rpcBodyRequest);

    let rpcBodyResponse = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_RPC_BODY_RESPONSE');

        dataCapture['rpc_body'] || (dataCapture['rpc_body'] = {});

        dataCapture['rpc_body']['response'] = isTrue(rpcBodyResponse);

    let bodyMaxSizeBytes = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_BODY_MAX_SIZE_BYTES');

        dataCapture['body_max_size_bytes'] = parseInt(bodyMaxSizeBytes);

    let bodyMaxProcessingSizeBytes = (0, envSettings_1.getEnvValue)('DATA_CAPTURE_BODY_MAX_PROCESSING_SIZE_BYTES');

        dataCapture['body_max_processing_size_bytes'] = parseInt(bodyMaxProcessingSizeBytes);

    if (Object.keys(dataCapture).length > 0) {

        envConfig['data_capture'] = dataCapture;

    let propagationFormats = (0, envSettings_1.getEnvValue)('PROPAGATION_FORMATS');

        envConfig['propagation_formats'] = propagationFormats.split(',');

    return value.toUpperCase() == 'TRUE';

exports.HypertraceAgent = exports.hypertraceDomain = void 0;

// need to load patch first to load patch to support import and require

const InstrumentationCompat_1 = require("./instrumentation/InstrumentationCompat");

require('./instrumentation/instrumentation-patch');

const instrumentation_aws_lambda_1 = require("@opentelemetry/instrumentation-aws-lambda");

const sdk_trace_node_1 = require("@opentelemetry/sdk-trace-node");

const sdk_trace_base_1 = require("@opentelemetry/sdk-trace-base");

const exporter_zipkin_1 = require("@opentelemetry/exporter-zipkin");

const config_1 = require("./config/config");

const instrumentation_express_1 = require("@opentelemetry/instrumentation-express");

const ExpressLayerType_1 = require("@opentelemetry/instrumentation-express/build/src/enums/ExpressLayerType");

const core_1 = require("@opentelemetry/core");

const propagator_b3_1 = require("@opentelemetry/propagator-b3");

const HttpInstrumentationWrapper_1 = require("./instrumentation/HttpInstrumentationWrapper");

const ExpressWrapper_1 = require("./instrumentation/wrapper/ExpressWrapper");

const instrumentation_mysql_1 = require("@opentelemetry/instrumentation-mysql");

const instrumentation_mysql2_1 = require("@opentelemetry/instrumentation-mysql2");

const instrumentation_pg_1 = require("@opentelemetry/instrumentation-pg");

const instrumentation_mongodb_1 = require("@opentelemetry/instrumentation-mongodb");

const KoaHypertraceInstrumentation_1 = require("./instrumentation/KoaHypertraceInstrumentation");

const types_1 = require("@opentelemetry/instrumentation-koa/build/src/types");

const KoaWrapper_1 = require("./instrumentation/wrapper/KoaWrapper");

const instrumentation_graphql_1 = require("@opentelemetry/instrumentation-graphql");

const exporter_trace_otlp_grpc_1 = require("@opentelemetry/exporter-trace-otlp-grpc");

const opentelemetry_instrumentation_mongoose_1 = require("opentelemetry-instrumentation-mongoose");

const GrpcJsHypertraceInstrumentation_1 = require("./instrumentation/GrpcJsHypertraceInstrumentation");

const OutgoingRequestWrapper_1 = require("./instrumentation/wrapper/OutgoingRequestWrapper");

const HttpHypertraceInstrumentation_1 = require("./instrumentation/HttpHypertraceInstrumentation");

const SailsWrapper_1 = require("./instrumentation/wrapper/SailsWrapper");

const Framework_1 = require("./instrumentation/Framework");

const LambdaInstrumentationWrapper_1 = require("./instrumentation/LambdaInstrumentationWrapper");

const HapiWrapper_1 = require("./instrumentation/wrapper/HapiWrapper");

const api = require("@opentelemetry/api");

const { Resource } = require('@opentelemetry/resources');

const { registerInstrumentations } = require('@opentelemetry/instrumentation');

exports.hypertraceDomain = require('domain').create();

        Logging_1.logger.info("Initializing Hypertrace Agent");

        Logging_1.logger.info(`Hypertrace Version: ${Version_1.version}`);

        Logging_1.logger.info(`Node version: ${process.version}`);

        this.config = config_1.Config.getInstance();

        this._provider = this.setupTracingProvider(overrideVersion);

        Logging_1.logger.info("Successfully initialized Hypertrace Agent");

        exports.hypertraceDomain.on('error', (er) => {

            // these should only be forbidden errors unless something is going wrong with our body capture

            // in either case, we don't want those exceptions to bubble outside of the agent

            Logging_1.logger.debug('Error caught within hypertrace domain');

            Logging_1.logger.debug(`error ${er.stack}`);

        if (!config_1.Config.getInstance().config.enabled) {

            Logging_1.logger.info('Hypertrace disabled - not instrumenting');

        Logging_1.logger.info('Hypertrace enabled - instrumenting');

        let httpWrapper = new HttpInstrumentationWrapper_1.HttpInstrumentationWrapper(this.config.config);

        (0, OutgoingRequestWrapper_1.patchClientRequest)();

        (0, ExpressWrapper_1.patchExpress)();

        (0, SailsWrapper_1.patchSails)();

        if (Framework_1.Framework.getInstance().available('@grpc/grpc-js')) {

            // we need to check for grpc a level up before trying to patch since we cant "require" in the

            // specific class we need to instead it has to be imported,

            // but imports cant occur within conditionals

            const grpcWrapper = require('./instrumentation/wrapper/GrpcJsWrapper');

            new instrumentation_aws_lambda_1.AwsLambdaInstrumentation({

                requestHook: LambdaInstrumentationWrapper_1.LambdaRequestHook,

                responseHook: LambdaInstrumentationWrapper_1.LambdaResponseHook,

                disableAwsContextPropagation: true

            new HttpHypertraceInstrumentation_1.HttpHypertraceInstrumentation({

                requestHook: httpWrapper.IncomingRequestHook,

                startOutgoingSpanHook: httpWrapper.OutgoingRequestHook,

                applyCustomAttributesOnSpan: httpWrapper.CustomAttrs,

                responseHook: httpWrapper.RespHook

            new instrumentation_express_1.ExpressInstrumentation({ ignoreLayersType: [ExpressLayerType_1.ExpressLayerType.MIDDLEWARE, ExpressLayerType_1.ExpressLayerType.REQUEST_HANDLER] }),

            new KoaHypertraceInstrumentation_1.KoaHypertraceInstrumentation({

                ignoreLayersType: [types_1.KoaLayerType.MIDDLEWARE],

                requestCallback: KoaWrapper_1.koaRequestCallback,

                responseCallback: KoaWrapper_1.koaResponseCallback

            new GrpcJsHypertraceInstrumentation_1.GrpcJsHypertraceInstrumentation(),

            new instrumentation_graphql_1.GraphQLInstrumentation(),

            new instrumentation_mysql_1.MySQLInstrumentation(),

            new instrumentation_mysql2_1.MySQL2Instrumentation(),

            new instrumentation_pg_1.PgInstrumentation(),

            new instrumentation_mongodb_1.MongoDBInstrumentation(),

            new opentelemetry_instrumentation_mongoose_1.MongooseInstrumentation()

        if ((0, InstrumentationCompat_1.isCompatible)("12.0.0")) {

            // Imports are only allowed at top level

            // so instead we need to require it if the node version is modern enough

            (0, HapiWrapper_1.patchHapi)();

            const hapiHypertraceInstrumentation = require("./instrumentation/HapiHypertraceInstrumentation");

            instrumentations.push(new hapiHypertraceInstrumentation.HapiHypertraceInstrumentation({}));

            tracerProvider: this._provider,

            instrumentations: instrumentations

        // if using express under es6 syntax http/https loading isnt captured

        // this ensures they are loaded immediately following instrumentation init

        this.exporter = this.setupExporter();

        Logging_1.logger.debug('Provider registered');

    setupTracingProvider(overrideVersion) {

        let reportedVersion = overrideVersion ? overrideVersion : Version_1.version;

            'service.name': this.config.config.service_name,

            'service.instance.id': process.pid,

            'telemetry.sdk.version': reportedVersion,

            'telemetry.sdk.name': 'hypertrace',

            'telemetry.sdk.language': 'nodejs'

        let extraConfigAttributes = config_1.Config.getInstance().config.resource_attributes;

            Object.assign(resourceAttributes, extraConfigAttributes);

        return new sdk_trace_node_1.NodeTracerProvider({

            resource: new Resource(resourceAttributes)

            Logging_1.logger.info(`Creating OTLP exporter reporting to: ${this.config.config.reporting.endpoint}`);

            const credentials = this.config.config.reporting.cert_file.length > 0

                ? grpc.credentials.createSsl(fs.readFileSync(this.config.config.reporting.cert_file))

                : grpc.credentials.createInsecure();

            return new exporter_trace_otlp_grpc_1.OTLPTraceExporter({

                url: this.config.config.reporting.endpoint

                url: this.config.config.reporting.endpoint,

exports.HypertraceAgent = HypertraceAgent;

  "description": "Hypertrace Node.js Agent",

    "url": "git://github.com/hypertrace/nodejsagent"

    "@opentelemetry/exporter-trace-otlp-grpc": "0.27.0",

    "@opentelemetry/exporter-trace-otlp-http": "^0.27.0",

    "@opentelemetry/exporter-zipkin": "1.0.1",

    "@opentelemetry/instrumentation-aws-lambda": "^0.28.1",

    "@opentelemetry/instrumentation-express": "0.26.0",

    "@opentelemetry/instrumentation-graphql": "^0.26.0",

    "@opentelemetry/instrumentation-grpc": "0.27.0",

    "@opentelemetry/instrumentation-hapi": "0.27.0",

    "@opentelemetry/instrumentation-http": "0.27.0",

    "@opentelemetry/instrumentation-koa": "^0.27.0",

    "@opentelemetry/instrumentation-mongodb": "^0.26.0",

    "@opentelemetry/instrumentation-mysql": "^0.26.0",

    "@opentelemetry/instrumentation-mysql2": "^0.26.0",

    "@opentelemetry/instrumentation-pg": "^0.26.0",

    "@opentelemetry/propagator-b3": "1.0.1",

    "@opentelemetry/sdk-trace-node": "1.0.1",

    "opentelemetry-instrumentation-mongoose": "^0.26.1",

    "@nestjs/platform-express": "^8.1.1",

    "@semantic-release/github": "^8.0.1",

    "next-version": "semantic-release --dry-run | grep 'The next release version is' | grep -oEi \"\\s([0-9].*)$\" | xargs",

    "test": "env TS_NODE_COMPILER_OPTIONS='{\"module\": \"commonjs\" }' HT_LOG_LEVEL=DEBUG mocha -r ts-node/register 'test/**/*.ts' --exclude 'test/integration/**/*.*'",

    "coverage": "nyc --reporter=lcov npm run test",

    "generate_pb": "pbjs --keep-case -t static-module -w default -o src/config/generated.js agent-config/proto/hypertrace/agent/config/v1/config.proto && pbts --keep-case -o ./src/config/generated.d.ts ./src/config/generated.js"

		@@ -11,2 +11,3 @@ "use strict";
		'secure': false,
		'cert_file': "",
		'trace_reporter_type': 'OTLP',
		@@ -13,0 +14,0 @@ 'token': '',

		{
		"name": "@hypertrace/nodejsagent",
		"version": "1.5.2",
		"version": "1.6.0",
		"description": "Hypertrace Node.js Agent",
		@@ -5,0 +5,0 @@ "author": "Traceable Inc.",

New alerts

Improved metrics

Worsened metrics

		@@ -29,2 +29,6 @@ "use strict";
		}
		let reportingCertFile = (0, envSettings_1.getEnvValue)("REPORTING_CERT_FILE");
		if (reportingCertFile) {
		reporting["cert_file"] = reportingCertFile;
		}
		let reportingToken = (0, envSettings_1.getEnvValue)('REPORTING_TOKEN');
		@@ -31,0 +35,0 @@ if (reportingToken) {

		@@ -38,2 +38,4 @@ "use strict";
		const api = require("@opentelemetry/api");
		const grpc = require('@grpc/grpc-js');
		const fs = require('fs');
		const { Resource } = require('@opentelemetry/resources');
		@@ -176,4 +178,8 @@ const { registerInstrumentations } = require('@opentelemetry/instrumentation');
		Logging_1.logger.info(`Creating OTLP exporter reporting to: ${this.config.config.reporting.endpoint}`);
		const credentials = this.config.config.reporting.cert_file.length > 0
		? grpc.credentials.createSsl(fs.readFileSync(this.config.config.reporting.cert_file))
		: grpc.credentials.createInsecure();
		return new exporter_trace_otlp_grpc_1.OTLPTraceExporter({
		url: this.config.config.reporting.endpoint
		url: this.config.config.reporting.endpoint,
		credentials,
		});
		@@ -180,0 +186,0 @@ }