CCM-10258 adding plane prop path selector

Author: aidenvaines-cgi

infrastructure/modules/eventpub/lambda/eventpub/src/index.js

@@ -18,6 +18,7 @@ function validateEvent(event) {
         'source',
         'specversion',
         'type',
+        'plane',
         'subject',
         'time',
         'datacontenttype',
@@ -49,7 +50,7 @@ function validateEvent(event) {
 }
 
 async function sendToEventBridge(events, eventBusArn) {
-    // console.info(`Sending ${events.length} events to EventBridge: ${eventBusArn}`);
+    console.debug(`Sending ${events.length} events to EventBridge: ${eventBusArn}`);
 
     const failedEvents = [];
     for (let i = 0; i < events.length; i += EVENTBRIDGE_MAX_BATCH_SIZE) {
@@ -64,7 +65,7 @@ async function sendToEventBridge(events, eventBusArn) {
         let attempts = 0;
         while (attempts < MAX_RETRIES) {
             try {
-                // console.info(`Attempt ${attempts + 1}: Sending batch of ${entries.length} events.`);
+                console.debug(`Attempt ${attempts + 1}: Sending batch of ${entries.length} events.`);
 
                 const response = await eventBridge.send(new PutEventsCommand({ Entries: entries }));
                 response.FailedEntryCount && response.Entries.forEach((entry, idx) => {
@@ -100,7 +101,7 @@ async function sendToDLQ(events) {
 }
 
 exports.handler = async (snsEvent) => {
-    // console.info(`Received SNS event with ${snsEvent.Records.length} records.`);
+    console.debug(`Received SNS event with ${snsEvent.Records.length} records.`);
 
     if (THROTTLE_DELAY_MS > 0) {
         console.info(`Throttling enabled. Delaying processing by ${THROTTLE_DELAY_MS}ms`);
@@ -111,14 +112,14 @@ exports.handler = async (snsEvent) => {
     const validEvents = records.filter(validateEvent);
     const invalidEvents = records.filter(event => !validateEvent(event));
 
-    // console.info(`Valid events: ${validEvents.length}, Invalid events: ${invalidEvents.length}`);
+    console.debug(`Valid events: ${validEvents.length}, Invalid events: ${invalidEvents.length}`);
 
     if (invalidEvents.length) await sendToDLQ(invalidEvents);
 
-    const dataEvents = validEvents.filter(event => event.type === 'data');
-    const controlEvents = validEvents.filter(event => event.type === 'control');
+    const dataEvents = validEvents.filter(event => event.plane === 'data');
+    const controlEvents = validEvents.filter(event => event.plane === 'control');
 
-    // console.info(`Data events: ${dataEvents.length}, Control events: ${controlEvents.length}`);
+    console.debug(`Data events: ${dataEvents.length}, Control events: ${controlEvents.length}`);
 
     const failedDataEvents = await sendToEventBridge(dataEvents, DATA_PLANE_EVENT_BUS_ARN);
     const failedControlEvents = await sendToEventBridge(controlEvents, CONTROL_PLANE_EVENT_BUS_ARN);