fix: stitched events through redis in pixel

Author: yashasvibajpai

src/v1/sources/shopify/config.js

@@ -42,6 +42,8 @@ const RUDDER_ECOM_MAP = {
   orders_create: 'Order Created',
 };
 
+const SERVERSIDE_STITCHED_EVENTS = Object.keys(RUDDER_ECOM_MAP);
+
 const contextualFieldMappingJSON = JSON.parse(
   fs.readFileSync(path.resolve(__dirname, 'pixelEventsMappings', 'contextualFieldMapping.json')),
 );
@@ -95,6 +97,7 @@ module.exports = {
   PIXEL_EVENT_TOPICS,
   PIXEL_EVENT_MAPPING,
   RUDDER_ECOM_MAP,
+  SERVERSIDE_STITCHED_EVENTS,
   contextualFieldMappingJSON,
   cartViewedEventMappingJSON,
   productListViewedEventMappingJSON,

src/v1/sources/shopify/webhookTransformations/serverSideTransform.js

@@ -22,7 +22,7 @@ const {
   getProductsFromLineItems,
   getAnonymousIdFromAttributes,
 } = require('./serverSideUtlis');
-const { getCartToken } = require('../../../../v0/sources/shopify/util');
+const { getCartToken } = require('./serverSideUtlis');
 
 const NO_OPERATION_SUCCESS = {
   outputToSource: {

src/v1/sources/shopify/webhookTransformations/serverSideUtlis.js

@@ -1,6 +1,10 @@
 const { isDefinedAndNotNull } = require('@rudderstack/integrations-lib');
 const { constructPayload } = require('../../../../v0/util');
-const { lineItemsMappingJSON, productMappingJSON } = require('../config');
+const {
+  lineItemsMappingJSON,
+  productMappingJSON,
+  SERVERSIDE_STITCHED_EVENTS,
+} = require('../config');
 
 /**
  * Returns an array of products from the lineItems array received from the webhook event
@@ -54,8 +58,22 @@ const getAnonymousIdFromAttributes = (event) => {
   return rudderAnonymousIdObject ? rudderAnonymousIdObject.value : null;
 };
 
+/**
+ * Returns the cart_token from the event message
+ * @param {Object} message
+ * @returns {String} cart_token
+ */
+const getCartToken = (message) => {
+  const { event, properties, context } = message;
+  if (SERVERSIDE_STITCHED_EVENTS.includes(event)) {
+    return context?.cart_token || properties?.cart_token || null;
+  }
+  return null;
+};
+
 module.exports = {
   createPropertiesForEcomEventFromWebhook,
   getProductsFromLineItems,
   getAnonymousIdFromAttributes,
+  getCartToken,
 };