Ensure correlationId is used in filtering observability

Author: mjewildnhs

lambdas/client-transform-filter-lambda/src/handler.ts

@@ -215,13 +215,15 @@ async function filterBatch(
 
   for (const event of transformedEvents) {
     const { clientId } = event.data;
+    const correlationId = extractCorrelationId(event);
     const config = configByClientId.get(clientId);
     const filterResult = evaluateSubscriptionFilters(event, config);
 
     if (filterResult.matched) {
       filtered.push(event);
       const targetIds = config?.targets?.map((t) => t.targetId);
       observability.recordFilteringMatched({
+        correlationId,
         clientId,
         eventType: event.type,
         subscriptionType: filterResult.subscriptionType,
@@ -232,6 +234,7 @@ async function filterBatch(
       observability
         .getLogger()
         .info("Event filtered out - no matching subscription", {
+          correlationId,
           clientId,
           eventType: event.type,
           subscriptionType: filterResult.subscriptionType,

lambdas/client-transform-filter-lambda/src/services/observability.ts

@@ -45,6 +45,7 @@ export class ObservabilityService {
   }
 
   recordFilteringMatched(context: {
+    correlationId?: string;
     clientId: string;
     eventType: string;
     subscriptionType: string;