feat: add stats for bad events in fb_custom_audience

src/util/prometheus.js

@@ -707,6 +707,18 @@ class Prometheus {
           500, 600, 700, 800, 900, 1000,
         ],
       },
+      {
+        name: 'fb_custom_audience_event_having_all_null_field_values_for_a_user',
+        help: 'fbcustomaudience event having all null field values for a user',
+        type: 'counter',
+        labelNames: ['destinationId'],
+      },
+      {
+        name: 'fb_custom_audience_event_having_all_null_field_values_for_all_users',
+        help: 'fbcustomaudience event having all null field values for all users',
+        type: 'counter',
+        labelNames: ['destinationId'],
+      },
       {
         name: 'http_request_size',
         help: 'http_request_size',

src/v0/destinations/fb_custom_audience/transform.js

@@ -60,6 +60,7 @@ const preparePayload = (
   paramsPayload,
   isHashRequired,
   disableFormat,
+  destinationId,
 ) => {
   const prepareFinalPayload = _.cloneDeep(paramsPayload);
   if (Array.isArray(userSchema)) {
@@ -73,6 +74,7 @@ const preparePayload = (
     userUpdateList,
     isHashRequired,
     disableFormat,
+    destinationId,
   );
   return batchingWithPayloadSize(prepareFinalPayload);
 };
@@ -125,6 +127,7 @@ const prepareResponse = (
     paramsPayload,
     isHashRequired,
     disableFormat,
+    destination.ID,
   );
   // paramsPayload.schema = userSchema;
   const respList = [];

src/v0/destinations/fb_custom_audience/util.js

@@ -2,6 +2,7 @@ const _ = require('lodash');
 const sha256 = require('sha256');
 const get = require('get-value');
 const jsonSize = require('json-size');
+const stats = require('../../../util/stats');
 
 const { isDefinedAndNotNull } = require('../../util');
 const { maxPayloadSize } = require('./config');
@@ -128,11 +129,19 @@ const ensureApplicableFormat = (userProperty, userInformation) => {
 
 // Function responsible for making the data field without payload object
 // Based on the "isHashRequired" value hashing is explicitly enabled or disabled
-const prepareDataField = (userSchema, userUpdateList, isHashRequired, disableFormat) => {
+const prepareDataField = (
+  userSchema,
+  userUpdateList,
+  isHashRequired,
+  disableFormat,
+  destinationId,
+) => {
   const data = [];
   let updatedProperty;
   let dataElement;
+  let nullEvent = true; // flag to check for bad events (all user properties are null)
   userUpdateList.forEach((eachUser) => {
+    let nullUserData = true; // flag to check for bad event (all properties are null for a user)
     dataElement = [];
     userSchema.forEach((eachProperty) => {
       const userProperty = eachUser[eachProperty];
@@ -160,9 +169,24 @@ const prepareDataField = (userSchema, userUpdateList, isHashRequired, disableFor
         dataElement.push(updatedProperty);
       }
     });
+    dataElement.forEach((property) => {
+      if (property) {
+        nullUserData = false;
+        nullEvent = false;
+      }
+    });
+    if (nullUserData) {
+      stats.increment('fb_custom_audience_event_having_all_null_field_values_for_a_user', {
+        destinationId,
+      });
+    }
     data.push(dataElement);
   });
-
+  if (nullEvent) {
+    stats.increment('fb_custom_audience_event_having_all_null_field_values_for_all_users', {
+      destinationId,
+    });
+  }
   return data;
 };
 module.exports = { prepareDataField, getSchemaForEventMappedToDest, batchingWithPayloadSize };