datadog-lambda-js - npm Package Compare versions

Comparing version 3.27.0 to 3.28.0

dist/handler.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.handler = void 0;
 var index_1 = require("./index");
@@ -5,0 +4,0 @@ // We reuse the function loading logic already inside the lambda runtime.

dist/index.js

@@ -81,3 +81,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getEnvValue = exports.getTraceHeaders = exports.sendDistributionMetric = exports.sendDistributionMetricWithDate = exports.datadog = exports.defaultConfig = exports.defaultSiteURL = exports.mergeXrayTracesEnvVar = exports.lambdaTaskRootEnvVar = exports.datadogHandlerEnvVar = exports.enhancedMetricsEnvVar = exports.logInjectionEnvVar = exports.logForwardingEnvVar = exports.logLevelEnvVar = exports.siteURLEnvVar = exports.apiKeyKMSEnvVar = exports.apiKeyEnvVar = void 0;
 var metrics_1 = require("./metrics");
@@ -84,0 +83,0 @@ var trace_1 = require("./trace");

dist/metrics/api.js

@@ -6,3 +6,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.APIClient = void 0;
 var https_1 = __importDefault(require("https"));
@@ -9,0 +8,0 @@ var querystring_1 = __importDefault(require("querystring"));

dist/metrics/batcher.js

@@ -23,3 +23,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.Batcher = void 0;
 /**
@@ -26,0 +25,0 @@ * Batcher joins metrics with matching properties.

dist/metrics/enhanced-metrics.js

@@ -23,3 +23,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.incrementErrorsMetric = exports.incrementInvocationsMetric = exports.getEnhancedMetricTags = exports.getRuntimeTag = void 0;
 var arn_1 = require("../utils/arn");
@@ -62,8 +61,5 @@ var cold_start_1 = require("../utils/cold-start");
     var arnTags = ["functionname:" + context.functionName];
-    if (context.functionVersion) {
+    if (context.invokedFunctionArn) {
         arnTags = arn_1.parseTagsFromARN(context.invokedFunctionArn, context.functionVersion);
     }
-    else if (context.invokedFunctionArn) {
-        arnTags = arn_1.parseTagsFromARN(context.invokedFunctionArn);
-    }
     var tags = __spread(arnTags, [cold_start_1.getColdStartTag(), "memorysize:" + context.memoryLimitInMB]);
@@ -70,0 +66,0 @@ var runtimeTag = getRuntimeTag();

dist/metrics/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 var listener_1 = require("./listener");
-Object.defineProperty(exports, "MetricsListener", { enumerable: true, get: function () { return listener_1.MetricsListener; } });
+exports.MetricsListener = listener_1.MetricsListener;
 var kms_service_1 = require("./kms-service");
-Object.defineProperty(exports, "KMSService", { enumerable: true, get: function () { return kms_service_1.KMSService; } });
+exports.KMSService = kms_service_1.KMSService;
 var enhanced_metrics_1 = require("./enhanced-metrics");
-Object.defineProperty(exports, "incrementErrorsMetric", { enumerable: true, get: function () { return enhanced_metrics_1.incrementErrorsMetric; } });
-Object.defineProperty(exports, "incrementInvocationsMetric", { enumerable: true, get: function () { return enhanced_metrics_1.incrementInvocationsMetric; } });
+exports.incrementErrorsMetric = enhanced_metrics_1.incrementErrorsMetric;
+exports.incrementInvocationsMetric = enhanced_metrics_1.incrementInvocationsMetric;
 //# sourceMappingURL=index.js.map

dist/metrics/kms-service.js

@@ -39,3 +39,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.KMSService = void 0;
 var utils_1 = require("../utils");
@@ -42,0 +41,0 @@ // In order to avoid the layer adding the 40mb aws-sdk to a deployment, (which is always available

dist/metrics/listener.js

@@ -59,3 +59,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.MetricsListener = void 0;
 var util_1 = require("util");
@@ -62,0 +61,0 @@ var utils_1 = require("../utils");

dist/metrics/metric-log.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.writeMetricToStdout = exports.buildMetricLog = void 0;
 // Builds the string representation of the metric that will be written to logs
@@ -5,0 +4,0 @@ function buildMetricLog(name, value, metricTime, tags) {

dist/metrics/model.js

@@ -34,3 +34,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isDistribution = exports.Distribution = void 0;
 var Distribution = /** @class */ (function () {
@@ -37,0 +36,0 @@ function Distribution(name, points) {

dist/metrics/processor.js

@@ -42,3 +42,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.Processor = void 0;
 var promise_retry_1 = __importDefault(require("promise-retry"));
@@ -45,0 +44,0 @@ var utils_1 = require("../utils");

dist/trace/constants.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.awsXrayDaemonAddressEnvVar = exports.xrayTraceEnvVar = exports.xraySubsegmentNamespace = exports.xrayBaggageSubsegmentKey = exports.xraySubsegmentKey = exports.xraySubsegmentName = exports.samplingPriorityHeader = exports.parentIDHeader = exports.traceIDHeader = exports.Source = exports.SampleMode = void 0;
 var SampleMode;
@@ -5,0 +4,0 @@ (function (SampleMode) {

dist/trace/context.js

@@ -30,3 +30,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.convertToAPMParentID = exports.convertToAPMTraceID = exports.convertToSampleMode = exports.convertTraceContext = exports.readStepFunctionContextFromEvent = exports.parseXrayTraceContextHeader = exports.readTraceContextFromXray = exports.readTraceFromEvent = exports.sendXraySubsegment = exports.generateXraySubsegment = exports.addXrayMetadata = exports.addStepFunctionContextToXray = exports.addTraceContextToXray = exports.extractTraceContext = void 0;
 var bignumber_js_1 = require("bignumber.js");
@@ -147,3 +146,4 @@ var crypto_1 = require("crypto");
     var headers = event.headers;
-    if (typeof headers !== "object") {
+    // e.g. When lambda is invoked synchronously, headers can be set to null by the caller
+    if (!headers || typeof headers !== "object") {
         return;
@@ -150,0 +150,0 @@ }

dist/trace/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 var listener_1 = require("./listener");
-Object.defineProperty(exports, "TraceListener", { enumerable: true, get: function () { return listener_1.TraceListener; } });
+exports.TraceListener = listener_1.TraceListener;
 //# sourceMappingURL=index.js.map

dist/trace/listener.js

@@ -50,3 +50,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.TraceListener = void 0;
 var context_1 = require("./context");
@@ -71,3 +70,3 @@ var patch_http_1 = require("./patch-http");
         },
-        enumerable: false,
+        enumerable: true,
         configurable: true
@@ -74,0 +73,0 @@ });

dist/trace/patch-console.js

 "use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
 var __importStar = (this && this.__importStar) || function (mod) {
     if (mod && mod.__esModule) return mod;
     var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
+    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
+    result["default"] = mod;
     return result;
 };
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.unpatchConsole = exports.patchConsole = void 0;
 var shimmer = __importStar(require("shimmer"));
@@ -24,0 +11,0 @@ var log_1 = require("../utils/log");

dist/trace/patch-http.js

@@ -13,21 +13,2 @@ "use strict";
 };
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
 var __read = (this && this.__read) || function (o, n) {
@@ -52,4 +33,10 @@ var m = typeof Symbol === "function" && o[Symbol.iterator];
 };
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k];
+    result["default"] = mod;
+    return result;
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.unpatchHttp = exports.patchHttp = void 0;
 var http_1 = __importDefault(require("http"));
@@ -56,0 +43,0 @@ var https_1 = __importDefault(require("https"));

dist/trace/trace-context-service.js

@@ -14,3 +14,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.TraceContextService = void 0;
 var aws_xray_sdk_core_1 = require("aws-xray-sdk-core");
@@ -57,3 +56,3 @@ var utils_1 = require("../utils");
         },
-        enumerable: false,
+        enumerable: true,
         configurable: true
@@ -73,3 +72,3 @@ });
         },
-        enumerable: false,
+        enumerable: true,
         configurable: true
@@ -81,3 +80,3 @@ });
         },
-        enumerable: false,
+        enumerable: true,
         configurable: true
@@ -84,0 +83,0 @@ });

dist/trace/tracer-wrapper.js

@@ -23,3 +23,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.TracerWrapper = void 0;
 var utils_1 = require("../utils");
@@ -47,3 +46,3 @@ var constants_1 = require("./constants");
         },
-        enumerable: false,
+        enumerable: true,
         configurable: true
@@ -50,0 +49,0 @@ });

dist/utils/arn.js

@@ -19,3 +19,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.parseTagsFromARN = exports.parseLambdaARN = void 0;
 function parseLambdaARN(arn, version) {
@@ -22,0 +21,0 @@ var _a;

dist/utils/cold-start.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports._resetColdStart = exports.getColdStartTag = exports.didFunctionColdStart = exports.setColdStart = void 0;
 var functionDidColdStart = true;
@@ -5,0 +4,0 @@ var isColdStartSet = false;

dist/utils/handler.js

@@ -39,3 +39,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.promisifiedHandler = exports.wrap = void 0;
 var log_1 = require("./log");
@@ -42,0 +41,0 @@ var serialize_error_1 = require("serialize-error");

dist/utils/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 var cold_start_1 = require("./cold-start");
-Object.defineProperty(exports, "didFunctionColdStart", { enumerable: true, get: function () { return cold_start_1.didFunctionColdStart; } });
-Object.defineProperty(exports, "getColdStartTag", { enumerable: true, get: function () { return cold_start_1.getColdStartTag; } });
-Object.defineProperty(exports, "setColdStart", { enumerable: true, get: function () { return cold_start_1.setColdStart; } });
+exports.didFunctionColdStart = cold_start_1.didFunctionColdStart;
+exports.getColdStartTag = cold_start_1.getColdStartTag;
+exports.setColdStart = cold_start_1.setColdStart;
 var handler_1 = require("./handler");
-Object.defineProperty(exports, "wrap", { enumerable: true, get: function () { return handler_1.wrap; } });
+exports.wrap = handler_1.wrap;
 var timer_1 = require("./timer");
-Object.defineProperty(exports, "Timer", { enumerable: true, get: function () { return timer_1.Timer; } });
+exports.Timer = timer_1.Timer;
 var log_1 = require("./log");
-Object.defineProperty(exports, "logError", { enumerable: true, get: function () { return log_1.logError; } });
-Object.defineProperty(exports, "logDebug", { enumerable: true, get: function () { return log_1.logDebug; } });
-Object.defineProperty(exports, "setLogLevel", { enumerable: true, get: function () { return log_1.setLogLevel; } });
-Object.defineProperty(exports, "setLogger", { enumerable: true, get: function () { return log_1.setLogger; } });
-Object.defineProperty(exports, "LogLevel", { enumerable: true, get: function () { return log_1.LogLevel; } });
+exports.logError = log_1.logError;
+exports.logDebug = log_1.logDebug;
+exports.setLogLevel = log_1.setLogLevel;
+exports.setLogger = log_1.setLogger;
+exports.LogLevel = log_1.LogLevel;
 //# sourceMappingURL=index.js.map

dist/utils/log.js

@@ -14,3 +14,2 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.logError = exports.logDebug = exports.getLogLevel = exports.setLogLevel = exports.setLogger = exports.LogLevel = void 0;
 var LogLevel;
@@ -17,0 +16,0 @@ (function (LogLevel) {

dist/utils/process-version.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getProcessVersion = void 0;
 function getProcessVersion() {
@@ -5,0 +4,0 @@ return process.version;

dist/utils/timer.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.Timer = void 0;
 /**
@@ -24,3 +23,3 @@ * Timer is used to get a promise that completes at a regular interval.
         },
-        enumerable: false,
+        enumerable: true,
         configurable: true
@@ -27,0 +26,0 @@ });

package.json

 {
   "name": "datadog-lambda-js",
-  "version": "3.27.0",
+  "version": "3.28.0",
   "description": "Lambda client library that supports hybrid tracing in node js",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

200302

decreased by-2.49%

Lines of code

2856

decreased by-1.79%

No dependency changes