@edirect/audit-instrumentation-express - npm Package Compare versions

Comparing version 1.5.15 to 1.5.16

CHANGELOG.md

@@ -5,2 +5,4 @@ # Changelog
 
+## [1.5.16](https://bitbucket.org/gofrank/audit-service-nodejs/compare/v1.5.15...v1.5.16) (2023-09-19)
+
 ## [1.5.15](https://bitbucket.org/gofrank/audit-service-nodejs/compare/v1.5.14...v1.5.15) (2023-09-19)
@@ -7,0 +9,0 @@

package.json

 {
   "name": "@edirect/audit-instrumentation-express",
-  "version": "1.5.15",
+  "version": "1.5.16",
   "private": false,
@@ -5,0 +5,0 @@ "dependencies": {

src/index.js

@@ -15,17 +15,29 @@ "use strict";
     static middleware = (options) => (req, res, next) => {
-        const data = {};
-        const { sessionId } = options || {};
-        if (sessionId) {
-            data.sessionId = sessionId(req);
-        }
-        const originIpAddress = (0, request_ip_1.getClientIp)(req);
-        if (originIpAddress) {
-            data.originIpAddress = originIpAddress;
-        }
-        data.originUrl = req.protocol + '://' + req.get('host') + req.originalUrl;
-        audit_domain_1.Context.set('instrumentation-express', data);
-        next();
+        audit_domain_1.Context.start((ns) => {
+            try {
+                const data = {};
+                const { sessionId } = options || {};
+                if (sessionId) {
+                    data.sessionId = sessionId(req);
+                }
+                const originIpAddress = (0, request_ip_1.getClientIp)(req);
+                if (originIpAddress) {
+                    data.originIpAddress = originIpAddress;
+                }
+                data.originUrl = req.protocol + '://' + req.get('host') + req.originalUrl;
+                ns.set('instrumentation-express', data);
+            }
+            catch (err) {
+                console.error("@edirect/audit-instrumentation-express: Error setting middleware context", err);
+            }
+            finally {
+                next();
+            }
+        });
     };
     execute(data) {
-        const { sessionId, originIpAddress, originUrl } = audit_domain_1.Context.get('instrumentation-express');
+        const ctx = audit_domain_1.Context.get('instrumentation-express');
+        if (!ctx)
+            return Promise.resolve(data);
+        const { sessionId, originIpAddress, originUrl } = { sessionId: null, originIpAddress: null, originUrl: null, ...ctx };
         return Promise.resolve({
@@ -32,0 +44,0 @@ ...data,

No alert changes

Improved metrics

Total package byte prevSize

7333

increased by15.14%

Lines of code

61

increased by24.49%

No dependency changes