logs

Author: haljac

src/ExpressBridge.ts

@@ -42,7 +42,7 @@ export class ExpressBridge {
       if (process.env.EB_TELEMETRY && this.options.telemetry) {
         console.log('Telemetry enabled, setting trace tag on event.');
         this.telemetry = new Telemetry(this.options.telemetry);
-        const tag = this.telemetry.tagEvent(incomingEvent);
+        this.telemetry.tagEvent(incomingEvent);
       }
 
       await this.telemetry?.beacon('EB-PROCESS', {
@@ -54,6 +54,8 @@ export class ExpressBridge {
 
       const matchedPatterns = this.match(incomingEvent);
 
+      console.log('Patterns matched: ', matchedPatterns);
+
       if (matchedPatterns.length > 0) {
         await this.telemetry?.beacon('EB-MATCH', {
           description: 'Patterns matched for event. Calling assigned handlers.',

src/Telemetry.ts

@@ -42,11 +42,11 @@ export class Telemetry {
       for (const record of payload) {
         record.eb_event_id = record.eb_event_id || tag;
       }
-    } else if (!payload) {
-      event.eb_event_id = event.eb_event_id || tag;
-    } else {
+    } else if (payload) {
       payload = typeof payload === 'string' ? JSON.parse(payload) : payload;
       payload.eb_event_id = payload.eb_event_id || tag;
+    } else {
+      event.eb_event_id = event.eb_event_id || tag;
     }
 
     this.eb_event_id = tag;