Revert "Revert "Feature: Support Event Filtering for Device Mode Dest…

…inations (#358)""

This reverts commit bbc1ace.

.gitignore

@@ -17,5 +17,6 @@ build.sh
 publish.sh
 dist/*
 !dist/rudder-sdk-js/*
+dist/rudder-sdk-js/index.js
 coverage/**
 __tests__/prodsdk.js

analytics.js

@@ -29,6 +29,7 @@ import {
   removeTrailingSlashes,
   getConfigUrl,
   checkSDKUrl,
+  commonNames,
 } from "./utils/utils";
 import {
   MAX_WAIT_FOR_INTEGRATION_LOAD,
@@ -340,10 +341,18 @@ class Analytics {
             if (
               succesfulLoadedIntersectClientSuppliedIntegrations[i][methodName]
             ) {
-              const clonedBufferEvent = cloneDeep(event);
-              succesfulLoadedIntersectClientSuppliedIntegrations[i][methodName](
-                ...clonedBufferEvent
+              const sendEvent = !object.IsEventBlackListed(
+                event[0].message.event,
+                succesfulLoadedIntersectClientSuppliedIntegrations[i].name
               );
+
+              // Block the event if it is blacklisted for the device-mode destination
+              if (sendEvent) {
+                const clonedBufferEvent = cloneDeep(event);
+                succesfulLoadedIntersectClientSuppliedIntegrations[i][
+                  methodName
+                ](...clonedBufferEvent);
+              }
             }
           }
         } catch (error) {
@@ -569,6 +578,66 @@ class Analytics {
     );
   }
 
+  IsEventBlackListed(eventName, intgName) {
+    if (!eventName || !(typeof eventName === "string")) {
+      return false;
+    }
+    const sdkIntgName = commonNames[intgName];
+    const intg = this.clientIntegrations.find(
+      (intg) => intg.name === sdkIntgName
+    );
+
+    const { blacklistedEvents, whitelistedEvents, eventFilteringOption } =
+      intg.config;
+
+    if (!eventFilteringOption) {
+      return false;
+    }
+
+    switch (eventFilteringOption) {
+      // disabled filtering
+      case "disable":
+        return false;
+      // Blacklist is choosen for filtering events
+      case "blacklistedEvents":
+        const isValidBlackList =
+          blacklistedEvents &&
+          Array.isArray(blacklistedEvents) &&
+          blacklistedEvents.every((x) => x.eventName !== "");
+
+        if (isValidBlackList) {
+          return blacklistedEvents.find(
+            (eventObj) =>
+              eventObj.eventName.trim().toUpperCase() ===
+              eventName.trim().toUpperCase()
+          ) === undefined
+            ? false
+            : true;
+        } else {
+          return false;
+        }
+      // Whitelist is choosen for filtering events
+      case "whitelistedEvents":
+        const isValidWhiteList =
+          whitelistedEvents &&
+          Array.isArray(whitelistedEvents) &&
+          whitelistedEvents.some((x) => x.eventName !== "");
+        if (isValidWhiteList) {
+          return whitelistedEvents.find(
+            (eventObj) =>
+              eventObj.eventName.trim().toUpperCase() ===
+              eventName.trim().toUpperCase()
+          ) === undefined
+            ? true
+            : false;
+        } else {
+          return true;
+        }
+      default:
+        return false;
+    }
+  }
+
   /**
    * Process and send data to destinations along with rudder BE
    *
@@ -639,8 +708,16 @@ class Analytics {
           succesfulLoadedIntersectClientSuppliedIntegrations.forEach((obj) => {
             if (!obj.isFailed || !obj.isFailed()) {
               if (obj[type]) {
-                const clonedRudderElement = cloneDeep(rudderElement);
-                obj[type](clonedRudderElement);
+                let sendEvent = !this.IsEventBlackListed(
+                  rudderElement.message.event,
+                  obj.name
+                );
+
+                // Block the event if it is blacklisted for the device-mode destination
+                if (sendEvent) {
+                  const clonedRudderElement = cloneDeep(rudderElement);
+                  obj[type](clonedRudderElement);
+                }
               }
             }
           });

utils/utils.js

@@ -684,6 +684,7 @@ export {
   isArray,
   isDefinedAndNotNull,
   getDataFromSource,
+  commonNames,
   removeTrailingSlashes,
   getConfigUrl,
   checkSDKUrl,