chore: purchase event implementation

src/v0/destinations/topsort/config.js

@@ -2,13 +2,14 @@ const { getMappingConfig } = require('../../util');
 
 const BASE_URL = 'https://api.topsort.com/v2/events';
 
-const ConfigCategories = {
+const ConfigCategory = {
   TRACK: {
     type: 'track',
     name: 'TopsortTrackConfig',
   },
   PLACEMENT: { name: 'TopsortPlacementConfig' },
   ITEM: { name: 'TopsortItemConfig' },
+  PURCHASE_ITEM: { name: 'TopSortPurchaseProductConfig' },
 };
 
 const ECOMM_EVENTS_WITH_PRODUCT_ARRAY = [
@@ -20,11 +21,11 @@ const ECOMM_EVENTS_WITH_PRODUCT_ARRAY = [
   'Order Cancelled',
 ];
 
-const mappingConfig = getMappingConfig(ConfigCategories, __dirname);
+const mappingConfig = getMappingConfig(ConfigCategory, __dirname);
 
 module.exports = {
   mappingConfig,
-  ConfigCategories,
+  ConfigCategory,
   BASE_URL,
   ECOMM_EVENTS_WITH_PRODUCT_ARRAY,
 };

src/v0/destinations/topsort/data/TopSortPurchaseProductConfig.json

@@ -1,7 +1,7 @@
 [
   {
     "destKey": "productId",
-    "sourceKeys": ["productId", "properties.productId"]
+    "sourceKeys": ["product_id", "properties.product_id"]
   },
   {
     "destKey": "unitPrice",

src/v0/destinations/topsort/data/TopsortTrackConfig.json

@@ -8,8 +8,8 @@
     "required": true
   },
   {
-    "destKey": "anonymousId",
-    "sourceKeys": "opaqueUserId",
+    "destKey": "opaqueUserId",
+    "sourceKeys": "anonymousId",
     "required": true
   },
   {

src/v0/destinations/topsort/transform.js

@@ -3,58 +3,22 @@ const {
   ConfigurationError,
   getHashFromArray,
 } = require('@rudderstack/integrations-lib');
-const { ConfigCategory, mappingConfig, ECOMM_EVENTS_WITH_PRODUCT_ARRAY } = require('./config');
+const { mappingConfig, ECOMM_EVENTS_WITH_PRODUCT_ARRAY, ConfigCategory } = require('./config');
 const { constructPayload, simpleProcessRouterDest } = require('../../util');
 const {
-  constructItemPayloads,
-  createEventData,
   isProductArrayValid,
   getMappedEventName,
-  addFinalPayload,
+  processImpressionsAndClicksUtility,
+  processPurchaseEventUtility,
 } = require('./utils');
 
-// Function to process events with a product array
-const processProductArray = ({
-  products,
-  basePayload,
-  placementPayload,
-  topsortEvent,
-  finalPayloads,
-}) => {
-  const itemPayloads = constructItemPayloads(products, mappingConfig[ConfigCategory.ITEM.name]);
-  itemPayloads.forEach((itemPayload) => {
-    const eventData = createEventData(basePayload, placementPayload, itemPayload, topsortEvent);
-    addFinalPayload(eventData, finalPayloads);
-  });
-};
-
-// Function to process events with a single product or no product data
-const processSingleProduct = ({
-  basePayload,
-  placementPayload,
-  message,
-  topsortEvent,
-  finalPayloads,
-  messageId,
-}) => {
-  const itemPayload = constructPayload(message, mappingConfig[ConfigCategory.ITEM.name]);
-  const eventData = createEventData(basePayload, placementPayload, itemPayload, topsortEvent);
-
-  // Ensure messageId is used instead of generating a UUID for single product events
-  eventData.data.id = messageId;
-
-  // Add final payload with appropriate ID and other headers
-  addFinalPayload(eventData, finalPayloads);
-};
-
 const responseBuilder = (message, { Config }) => {
   const { topsortEvents } = Config;
   const { event, properties } = message;
-  const { products, messageId } = properties;
+  const { products } = properties;
 
   // Parse Topsort event mappings
-  const parsedTopsortEventMappings = getHashFromArray(topsortEvents);
-  const mappedEventName = getMappedEventName(parsedTopsortEventMappings, event);
+  const mappedEventName = getMappedEventName(getHashFromArray(topsortEvents), event);
 
   if (!mappedEventName) {
     throw new InstrumentationError("Event not mapped in 'topsortEvents'. Dropping the event.");
@@ -64,32 +28,44 @@ const responseBuilder = (message, { Config }) => {
 
   // Construct base and placement payloads
   const basePayload = constructPayload(message, mappingConfig[ConfigCategory.TRACK.name]);
-  const placementPayload = constructPayload(message, mappingConfig[ConfigCategory.PLACEMENT.name]);
-
-  // Check if the event involves a product array (using ECOMM_EVENTS_WITH_PRODUCT_ARRAY)
-  const isProductArrayAvailable =
-    ECOMM_EVENTS_WITH_PRODUCT_ARRAY.includes(event) && isProductArrayValid(event, properties);
 
-  const finalPayloads = [];
+  const finalPayloads = {
+    impressions: [],
+    clicks: [],
+    purchases: [],
+  };
 
   const commonArgs = {
     basePayload,
-    placementPayload,
     topsortEventName,
     finalPayloads,
+    products,
+    message,
+    isProductArrayAvailable:
+      ECOMM_EVENTS_WITH_PRODUCT_ARRAY.includes(event) && isProductArrayValid(event, properties),
   };
 
-  if (isProductArrayAvailable) {
-    processProductArray({
+  // Process events based on type and construct payload within each logic block
+  if (topsortEventName === 'impressions' || topsortEventName === 'clicks') {
+    const placementPayload = constructPayload(
+      message,
+      mappingConfig[ConfigCategory.PLACEMENT.name],
+    );
+    processImpressionsAndClicksUtility.processImpressionsAndClicks({
       ...commonArgs,
-      products, // Directly use destructured products
+      placementPayload, // Only pass placementPayload for impressions and clicks
     });
-  } else {
-    processSingleProduct({
-      ...commonArgs,
+  } else if (topsortEventName === 'purchases') {
+    const purchasePayload = constructPayload(
       message,
-      messageId, // Add 'messageId' for single product event
+      mappingConfig[ConfigCategory.PURCHASE_ITEM.name],
+    );
+    processPurchaseEventUtility.processPurchaseEvent({
+      ...commonArgs,
+      purchasePayload, // Only pass purchasePayload for purchase events
     });
+  } else {
+    throw new InstrumentationError(`Unknown event type: ${topsortEventName}`);
   }
 
   return finalPayloads;