ONCEHUB-94733: Block PAGE calls for mixpanel destination

Author: SoniRani

src/services/destination/preTransformation.ts

@@ -15,10 +15,16 @@ export class DestinationPreTransformationService {
         // "traits": ["traits", "context.traits"]
         const destination = event?.destination?.DestinationDefinition?.Name;        
         let parsedEvent = oncehubTransformer(destination, event);
-        parsedEvent.request = { query: reqParams };
+        if (parsedEvent) {
+          parsedEvent.request = { query: reqParams };
+        }
         return parsedEvent;
       },
     );
-    return eventsProcessed;
+    // 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;
   }
 }

src/util/oncehub-custom-transformer.js

@@ -14,6 +14,12 @@ const getPIIDestinationList = () => {
     return event && event.message && event.message.context  && event.message.context.traits;
   };
 
+const getPageEventBlockedDestinationsList = () => {
+    return (process.env.BLOCKED_PAGE_DESTINATIONS || "mp")
+      .trim()
+      .split(",");
+  };
+
 const handleFirstLoginGA4Property = (destination, event, traits) => {
   // delete firstLoginGA4 property from traits when destination is not GA4
   if (destination !== 'ga4') {
@@ -27,7 +33,7 @@ const handleFirstLoginGA4Property = (destination, event, traits) => {
     traits.value = 0;
     }
 
-  };
+};
 
   const changeDateFormatForCustomerio = (contextTraitsPresent, eventTraitsPresent,checkDestinationList, event) => {
     if (checkDestinationList) {
@@ -51,6 +57,13 @@ const handleFirstLoginGA4Property = (destination, event, traits) => {
     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,checkDestinationList,event);
 
     if (!checkDestinationList && eventTraitsPresent) {
@@ -82,6 +95,7 @@ const handleFirstLoginGA4Property = (destination, event, traits) => {
 
     // 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;
   };