chore: updated files

src/v0/destinations/snapchat_conversion/config.js

@@ -116,6 +116,7 @@ const mappingConfigV3 = getMappingConfig(ConfigCategoryV3, __dirname);
 module.exports = {
   ENDPOINT,
   ConfigCategory,
+  ConfigCategoryV3,
   eventNameMapping,
   mappingConfig,
   mappingConfigV3,

src/v0/destinations/snapchat_conversion/transformV3.js

@@ -19,9 +19,9 @@ const {
   ENDPOINT,
   eventNameMapping,
   mappingConfigV3,
-  ConfigCategoryV3,
   MAX_BATCH_SIZE,
   pageTypeToTrackEvent,
+  ConfigCategoryV3,
 } = require('./config');
 const {
   msUnixTimestamp,
@@ -50,6 +50,7 @@ function buildResponse(apiKey, payload, message) {
 const populateHashedTraitsValues = (payload, message) => {
   const firstName = getFieldValueFromMessage(message, 'firstName');
   const lastName = getFieldValueFromMessage(message, 'lastName');
+  const middleName = getFieldValueFromMessage(message, 'middleName');
   const city = getFieldValueFromMessage(message, 'city');
   const state = getFieldValueFromMessage(message, 'state');
   const zip = getFieldValueFromMessage(message, 'zipcode');
@@ -59,6 +60,7 @@ const populateHashedTraitsValues = (payload, message) => {
       {
         user_data: {
           fn: firstName ? getHashedValue(firstName.toString().toLowerCase().trim()) : undefined,
+          mn: middleName ? getHashedValue(middleName.toString().toLowerCase().trim()) : undefined,
           ln: lastName ? getHashedValue(lastName.toString().toLowerCase().trim()) : undefined,
           ct: city ? getHashedValue(city.toString().toLowerCase().trim()) : undefined,
           zp: zip ? getHashedValue(zip.toString().toLowerCase().trim()) : undefined,
@@ -85,13 +87,13 @@ const populateHashedValues = (payload, message) => {
 
   const updatedPayload = populateHashedTraitsValues(payload, message);
   if (email) {
-    updatedPayload.data.user_data.em = getHashedValue(email.toString().toLowerCase().trim());
+    updatedPayload.data[0].user_data.em = getHashedValue(email.toString().toLowerCase().trim());
   }
   if (phone) {
-    updatedPayload.data.user_data.ph = getHashedValue(phone.toString().toLowerCase().trim());
+    updatedPayload.data[0].user_data.ph = getHashedValue(phone.toString().toLowerCase().trim());
   }
   if (ip) {
-    updatedPayload.data.user_data.client_ip_address = getHashedValue(
+    updatedPayload.data[0].user_data.client_ip_address = getHashedValue(
       ip.toString().toLowerCase().trim(),
     );
   }
@@ -100,13 +102,13 @@ const populateHashedValues = (payload, message) => {
     isAppleFamily(message.context?.device?.type) &&
     (message.properties?.idfv || message.context?.device?.id)
   ) {
-    updatedPayload.data.user_data.idfv = getHashedValue(
+    updatedPayload.data[0].user_data.idfv = getHashedValue(
       message.properties?.idfv || message.context?.device?.id,
     );
   }
 
   if (message.properties?.adId || message.context?.device?.advertisingId) {
-    updatedPayload.data.user_data.madid = getHashedValue(
+    updatedPayload.data[0].user_data.madid = getHashedValue(
       message.properties?.adId || message.context?.device?.advertisingId,
     );
   }
@@ -129,10 +131,10 @@ const validateEventConfiguration = (actionSource, pixelId, snapAppId, appId) =>
 };
 const validateRequiredFields = (payload) => {
   if (
-    !payload.data.user_data.em &&
-    !payload.data.user_data.ph &&
-    !payload.data.user_data.madid &&
-    !(payload.data.user_data.client_ip_address && payload.data.user_data.client_user_agent)
+    !payload.data[0].user_data.em &&
+    !payload.data[0].user_data.ph &&
+    !payload.data[0].user_data.madid &&
+    !(payload.data[0].user_data.client_ip_address && payload.data[0].user_data.client_user_agent)
   ) {
     throw new InstrumentationError(
       'At least one of email or phone or advertisingId or ip and clientUserAgent is required',
@@ -158,7 +160,7 @@ const addSpecificEventDetails = (message, payload, actionSource, pixelId, snapAp
 };
 const getEventConversionType = (message) => {
   const channel = get(message, 'channel');
-  let actionSource = message?.properties?.actionSource;
+  let actionSource = message?.properties?.action_source;
   if (channelMapping[actionSource?.toLowerCase()] || channelMapping[channel?.toLowerCase()]) {
     actionSource = actionSource
       ? channelMapping[actionSource?.toLowerCase()]
@@ -183,22 +185,35 @@ const trackResponseBuilder = (message, { Config }, mappedEvent) => {
     switch (event.toLowerCase()) {
       /* Browsing Section */
       case 'products_searched':
-        payload = constructPayload(message, mappingConfigV3[ConfigCategoryV3.PRODUCTS_SEARCHED.name]);
+        payload = constructPayload(
+          message,
+          mappingConfigV3[ConfigCategoryV3.PRODUCTS_SEARCHED.name],
+        );
         payload.data.event_name = eventNameMapping[event.toLowerCase()];
         break;
       case 'product_list_viewed':
-        payload = constructPayload(message, mappingConfigV3[ConfigCategoryV3.PRODUCT_LIST_VIEWED.name]);
+        payload = constructPayload(
+          message,
+          mappingConfigV3[ConfigCategoryV3.PRODUCT_LIST_VIEWED.name],
+        );
         payload.data.event_name = eventNameMapping[event.toLowerCase()];
         payload.data.custom_data.content_ids = getItemIds(message);
-        payload.data.custom_data.contents.price = payload.data.custom_data.contents.price || getPriceSum(message);
+        payload.data.custom_data.contents.price =
+        payload.data.custom_data.contents.price || getPriceSum(message);
         break;
       /* Promotions Section */
       case 'promotion_viewed':
-        payload = constructPayload(message, mappingConfigV3[ConfigCategoryV3.PROMOTION_VIEWED.name]);
+        payload = constructPayload(
+          message,
+          mappingConfigV3[ConfigCategoryV3.PROMOTION_VIEWED.name],
+        );
         payload.data.event_name = eventNameMapping[event.toLowerCase()];
         break;
       case 'promotion_clicked':
-        payload = constructPayload(message, mappingConfigV3[ConfigCategoryV3.PROMOTION_CLICKED.name]);
+        payload = constructPayload(
+          message,
+          mappingConfigV3[ConfigCategoryV3.PROMOTION_CLICKED.name],
+        );
         payload.data.event_name = eventNameMapping[event.toLowerCase()];
         break;
       /* Ordering Section */
@@ -207,10 +222,14 @@ const trackResponseBuilder = (message, { Config }, mappedEvent) => {
         payload.data.event_name = eventNameMapping[event.toLowerCase()];
         break;
       case 'checkout_started':
-        payload = constructPayload(message, mappingConfigV3[ConfigCategoryV3.CHECKOUT_STARTED.name]);
+        payload = constructPayload(
+          message,
+          mappingConfigV3[ConfigCategoryV3.CHECKOUT_STARTED.name],
+        );
         payload.data.event_name = eventNameMapping[event.toLowerCase()];
         payload.data.custom_data.content_ids = getItemIds(message);
-        payload.data.custom_data.contents.price = payload.data.custom_data.contents.price || getPriceSum(message);
+        payload.data.custom_data.contents.price =
+          payload.data.custom_data.contents.price || getPriceSum(message);
         break;
       case 'payment_info_entered':
         payload = constructPayload(
@@ -223,7 +242,8 @@ const trackResponseBuilder = (message, { Config }, mappedEvent) => {
         payload = constructPayload(message, mappingConfigV3[ConfigCategoryV3.ORDER_COMPLETED.name]);
         payload.data.event_name = eventNameMapping[event.toLowerCase()];
         payload.data.custom_data.content_ids = getItemIds(message);
-        payload.data.custom_data.contents.price = payload.data.custom_data.contents.price || getPriceSum(message);
+        payload.data.custom_data.contents.price =
+          payload.data.custom_data.contents.price || getPriceSum(message);
         break;
       case 'product_added':
         payload = constructPayload(message, mappingConfigV3[ConfigCategoryV3.PRODUCT_ADDED.name]);
@@ -254,7 +274,7 @@ const trackResponseBuilder = (message, { Config }, mappedEvent) => {
   payload = { ...payload, ...getEventCommonProperties(message) };
   payload = populateHashedValues(payload, message);
   validateRequiredFields(payload);
-  payload.data.event_time = getFieldValueFromMessage(message, 'eventTime');
+  payload.data.event_time = getFieldValueFromMessage(message, 'timestamp');
   const eventTime = payload.data.event_time;
   if (eventTime) {
     const start = moment.unix(moment(eventTime).format('X'));
@@ -270,7 +290,7 @@ const trackResponseBuilder = (message, { Config }, mappedEvent) => {
     payload.data.event_time = msUnixTimestamp(payload.data.event_time)?.toString()?.slice(0, 10);
   }
 
-  payload.action_source = actionSource;
+  payload.data.action_source = actionSource;
   payload = addSpecificEventDetails(message, payload, actionSource, pixelId, snapAppId, appId);
   // adding for deduplication for more than one source
   if (enableDeduplication) {

src/v0/destinations/snapchat_conversion/utilsV3.js

@@ -1,34 +1,25 @@
-const { getFieldValueFromMessage } = require('../../util');
-
-// Utility function to extract the click_id from the event_source_url
-const extractClickIdFromUrl = (message) => {
+/// Utility function to extract the click_id (ScCid) from the event_source_url
+const extractClickIdFromUrl = (url) => {
   try {
-    const eventSourceUrl = getFieldValueFromMessage(message, 'pageUrl');
-
-    if (!eventSourceUrl) {
-      throw new Error('URL not found in message');
-    }
-
-    const urlObj = new URL(eventSourceUrl);
+    const urlObj = new URL(url);
     const clickId = urlObj.searchParams.get('ScCid'); // 'ScCid' is the query parameter for click_id
-
-    return clickId;
+    return clickId || null; // Return null if not found
   } catch (error) {
-    return null; 
+    return null;
   }
 };
 
 function getEndpointWithClickId(endpoint, message) {
   let clickId;
 
-  const scClickId = getFieldValueFromMessage(message, 'scClickId');
-
-  if (scClickId) {
-    clickId = scClickId;
+  // Check if scClickId is provided directly in the message
+  if (message.properties.sc_click_id) {
+    clickId = message.properties.sc_click_id;
   } else {
-    const eventSourceUrl = getFieldValueFromMessage(message, 'eventSourceUrl');
+    // Check if the eventSourceUrl is provided in message properties or directly
+    const eventSourceUrl = message.event_source_url || message.properties?.event_source_url;
     if (eventSourceUrl) {
-      clickId = extractClickIdFromUrl(eventSourceUrl);
+      clickId = extractClickIdFromUrl(eventSourceUrl); // Extract from URL if present
     }
   }
 
@@ -38,15 +29,12 @@ function getEndpointWithClickId(endpoint, message) {
   }
 
   // Replace {ID} in the endpoint with the found Click ID
-  const urlObj = new URL(endpoint);
-  if (urlObj.pathname.includes('{ID}')) {
-    urlObj.pathname = urlObj.pathname.replace('{ID}', clickId);
-  } else {
-    throw new Error('Endpoint URL does not contain {ID} placeholder');
-  }
+  let urlObj = decodeURIComponent(endpoint);
+
+  urlObj = urlObj.replace('{ID}', clickId);
 
   // Return the updated endpoint URL with the scClickId replaced
-  return urlObj.toString();
+  return urlObj;
 }
 
 module.exports = { getEndpointWithClickId, extractClickIdFromUrl };