[MASTER] ONCEHUB-98709 Removed event filtering from rudder-transformer

src/services/destination/preTransformation.ts

@@ -1,6 +1,6 @@
 import { Context } from 'koa';
 import { ProcessorTransformationRequest, RouterTransformationRequestData } from '../../types/index';
 import { DynamicConfigParser } from '../../util/dynamicConfigParser';
 import { oncehubTransformer } from '../../util/oncehub-custom-transformer';
 
 export class DestinationPreTransformationService {
@@ -21,10 +21,7 @@
         return parsedEvent;
       },
     );
-    // Filter out any undefined or null events after processing
-    // This is important to ensure that we only return valid events to the next step in the pipeline
-    const filteredEvents = eventsProcessed.filter((event: any) => !!event);
 
-    return filteredEvents;
+    return eventsProcessed;
   }
 }

src/util/oncehub-custom-transformer.js

@@ -9,18 +9,14 @@
 };
 
 const doesEventContainContextTraits = (event) => {
   return event && event.message && event.message.context && event.message.context.traits;
 };
 
-const getPageEventBlockedDestinationsList = () => {
-  return (process.env.BLOCKED_PAGE_DESTINATIONS || '').trim().split(',');
-};
-
 const handleFirstLoginGA4Property = (destination, event, traits) => {
   // delete firstLoginGA4 property from traits when destination is not GA4
   if (destination !== 'ga4') {
     delete traits.firstLoginGA4;
     return;
   }
 
   // add firstLoginGA4 property in traits when Identify call is for GA4 destination
@@ -47,7 +43,7 @@
       // eslint-disable-next-line no-param-reassign
       event.message.traits.accountCreatedDate = Math.floor(
         Date.parse(event.message.traits.accountCreatedDate) / 1000,
       );
     }
   }
 };
@@ -57,13 +53,6 @@
   const contextTraitsPresent = doesEventContainContextTraits(event);
   const eventTraitsPresent = doesEventContainsTraits(event);
   const checkDestinationList = getPIIDestinationList().includes(destination);
-  const checkPageEventBlockedDestination =
-    getPageEventBlockedDestinationsList().includes(destination);
-  if (event.message.type === EventType.PAGE && checkPageEventBlockedDestination) {
-    // eslint-disable-next-line no-param-reassign
-    return null;
-  }
-
   changeDateFormatForCustomerio(
     contextTraitsPresent,
     eventTraitsPresent,
@@ -100,7 +89,6 @@
 
   // eslint-disable-next-line no-console
   // if(doesEventContainsTraits(event)) console.log("event log=>destination : ", JSON.stringify(destination), " , ==> event traits : ", JSON.stringify(event.message.traits), " , ==> event here : ",JSON.stringify(event));
-
   return event;
 };