refactor tagging

Author: haljac

src/ExpressBridge.ts

@@ -68,17 +68,7 @@ export class ExpressBridge {
         },
       });
 
-      const matchedPatterns = this.comparableCollection.filter(
-        (eventPattern: EventPattern<Partial<typeof incomingEvent>>) => {
-          console.log('testing pattern: ', eventPattern);
-          console.log('against... ', incomingEvent);
-          return eventPattern.test(incomingEvent);
-        }
-      );
-
-      console.log('Matched patterns: ', matchedPatterns);
-      console.log('Did we match patterns?: ', matchedPatterns.length > 0);
-      console.log('patterns to match against: ', this.comparableCollection);
+      const matchedPatterns = this.match(incomingEvent);
 
       if (matchedPatterns.length > 0) {
         await this.telemetry?.beacon('EB-MATCH', {
@@ -147,6 +137,16 @@ export class ExpressBridge {
   public getTelemetryId() {
     return this.telemetry.eb_event_id;
   }
+
+  private match(
+    incomingEvent: Record<string, any>
+  ): EventPattern<typeof incomingEvent>[] {
+    return this.comparableCollection.filter(
+      (eventPattern: EventPattern<Partial<typeof incomingEvent>>) => {
+        return eventPattern.test(incomingEvent as any);
+      }
+    );
+  }
 }
 
 function pipeline(message: EventType, ...functions: handlerType[]): EventType {

src/Telemetry.ts

@@ -1,4 +1,5 @@
 import axios from 'axios';
+import { v4 } from 'uuid';
 import { AxiosRequestConfig } from 'axios';
 
 export type TelemetryConfig = Partial<AxiosRequestConfig> & {
@@ -30,4 +31,20 @@ export class Telemetry {
       console.log('Error calling telemetry beacon', err);
     }
   }
+
+  public tagEvent(event: Record<string, any>): Record<string, any> {
+    const { body, detail, Records } = event;
+    let payload = body ?? detail ?? Records;
+
+    const tag = v4();
+    if (Array.isArray(payload)) {
+      for (const record of payload) {
+        record.eb_event_id = record.eb_event_id || tag;
+      }
+    } else {
+      payload = typeof payload === 'string' ? JSON.parse(payload) : payload;
+      payload.eb_event_id = payload.eb_event_id || tag;
+    }
+    return event;
+  }
 }