feat: changes for supporting record event in FB audience

src/v0/destinations/fb_custom_audience/transform.js

@@ -1,14 +1,7 @@
 const lodash = require('lodash');
 const get = require('get-value');
+const { InstrumentationError, ConfigurationError } = require('@rudderstack/integrations-lib');
 const {
-  InstrumentationError,
-  TransformationError,
-  ConfigurationError,
-} = require('@rudderstack/integrations-lib');
-const {
-  defaultRequestConfig,
-  defaultPostRequestConfig,
-  defaultDeleteRequestConfig,
   checkSubsetOfArray,
   isDefinedAndNotNullAndNotEmpty,
   returnArrayOfSubarrays,
@@ -22,36 +15,20 @@
   batchingWithPayloadSize,
   generateAppSecretProof,
 } = require('./util');
-const {
-  getEndPoint,
-  schemaFields,
-  USER_ADD,
-  USER_DELETE,
-  typeFields,
-  subTypeFields,
-} = require('./config');
+const { schemaFields, USER_ADD, USER_DELETE } = require('./config');
 
 const { MappedToDestinationKey } = require('../../../constants');
+const { processRecordInputs, responseBuilderSimple, getDataSource } = require('./transformV2');
 
-const responseBuilderSimple = (payload, audienceId) => {
-  if (payload) {
-    const responseParams = payload.responseField;
-    const response = defaultRequestConfig();
-    response.endpoint = getEndPoint(audienceId);
-
-    if (payload.operationCategory === 'add') {
-      response.method = defaultPostRequestConfig.requestMethod;
+function extraKeysPresent(dictionary, keyList) {
+  // eslint-disable-next-line no-restricted-syntax
+  for (const key in dictionary) {
+    if (!keyList.includes(key)) {
+      return true;
     }
-    if (payload.operationCategory === 'remove') {
-      response.method = defaultDeleteRequestConfig.requestMethod;
-    }
-
-    response.params = responseParams;
-    return response;
   }
-  // fail-safety for developer error
-  throw new TransformationError(`Payload could not be constructed`);
-};
+  return false;
+}
 
 // Function responsible prepare the payload field of every event parameter
 
@@ -102,7 +79,6 @@
   const prepareParams = {};
   // creating the parameters field
   const paramsPayload = {};
-  const dataSource = {};
 
   prepareParams.access_token = accessToken;
 
@@ -118,13 +94,7 @@
   }
   // creating the data_source block
 
-  if (type && type !== 'NA' && typeFields.includes(type)) {
-    dataSource.type = type;
-  }
-
-  if (subType && subType !== 'NA' && subTypeFields.includes(subType)) {
-    dataSource.sub_type = subType;
-  }
+  const dataSource = getDataSource(type, subType);
   if (Object.keys(dataSource).length > 0) {
     paramsPayload.data_source = dataSource;
   }
@@ -250,6 +220,7 @@
       ),
     );
   }
+
   toSendEvents.forEach((sendEvent) => {
     respList.push(responseBuilderSimple(sendEvent, operationAudienceId));
   });
@@ -265,7 +236,29 @@
 const process = (event) => processEvent(event.message, event.destination);
 
 const processRouterDest = async (inputs, reqMetadata) => {
-  const respList = await simpleProcessRouterDest(inputs, process, reqMetadata);
+  const respList = [];
+  const groupedInputs = lodash.groupBy(inputs, (input) => input.message.type?.toLowerCase());
+  let transformedRecordEvent = [];
+  let transformedAudienceEvent = [];
+
+  const eventTypes = ['record', 'audiencelist'];
+  if (extraKeysPresent(groupedInputs, eventTypes)) {
+    throw new ConfigurationError('unsupported events present in the event');
+  }
+
+  if (groupedInputs.record) {
+    transformedRecordEvent = await processRecordInputs(groupedInputs.record, reqMetadata);
+  }
+
+  if (groupedInputs.audiencelist) {
+    transformedAudienceEvent = await simpleProcessRouterDest(
+      groupedInputs.audiencelist,
+      process,
+      reqMetadata,
+    );
+  }
+
+  respList.push(...transformedRecordEvent, ...transformedAudienceEvent);
   return flattenMap(respList);
 };