feat: add redis support in shopify pixel for id stitching

src/v0/sources/shopify/util.js

@@ -272,6 +272,7 @@ module.exports = {
   createPropertiesForEcomEvent,
   extractEmailFromPayload,
   getAnonymousIdAndSessionId,
+  getCartToken,
   checkAndUpdateCartItems,
   getHashLineItems,
   getDataFromRedis,

src/v1/sources/shopify/transform.js

@@ -4,10 +4,30 @@
 const {
   process: processPixelWebhookEvents,
 } = require('./webhookTransformations/serverSideTransform');
+const { RedisDB } = require('../../../util/redis/redisConnector');
+
+const NO_OPERATION_SUCCESS = {
+  outputToSource: {
+    body: Buffer.from('OK').toString('base64'),
+    contentType: 'text/plain',
+  },
+  statusCode: 200,
+};
+
+const isIdentifierEvent = (event) => ['rudderIdentifier'].includes(event?.event);
+
+const processIdentifierEvent = async (event) => {
+  const { cartToken, anonymousId } = event;
+  await RedisDB.setVal(`${cartToken}`, anonymousId);
+  return NO_OPERATION_SUCCESS;
+};
 
 const process = async (inputEvent) => {
   const { event } = inputEvent;
   const { query_parameters } = event;
+  if (isIdentifierEvent(event)) {
+    return processIdentifierEvent(event);
+  }
   // check identify the event is from the web pixel based on the pixelEventLabel property.
   const { pixelEventLabel: pixelClientEventLabel } = event;
   if (pixelClientEventLabel) {

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

@@ -4,6 +4,7 @@
 const stats = require('../../../../util/stats');
 const { getShopifyTopic, extractEmailFromPayload } = require('../../../../v0/sources/shopify/util');
 const { removeUndefinedAndNullValues, isDefinedAndNotNull } = require('../../../../v0/util');
+const { RedisDB } = require('../../../../util/redis/redisConnector');
 const Message = require('../../../../v0/sources/message');
 const { EventType } = require('../../../../constants');
 const {
@@ -21,6 +22,7 @@
   getProductsFromLineItems,
   getAnonymousIdFromAttributes,
 } = require('./serverSideUtlis');
+const { getCartToken } = require('../../../../v0/sources/shopify/util');
 
 const NO_OPERATION_SUCCESS = {
   outputToSource: {
@@ -125,6 +127,13 @@
     const anonymousId = getAnonymousIdFromAttributes(event);
     if (isDefinedAndNotNull(anonymousId)) {
       message.setProperty('anonymousId', anonymousId);
+    } else {
+      // if anonymousId is not present in note_attributes or note_attributes is not present, query redis for anonymousId
+      const cartToken = getCartToken(message);
+      const redisData = await RedisDB.getVal(cartToken);
+      if (redisData?.anonymousId) {
+        message.setProperty('anonymousId', redisData.anonymousId);
+      }
     }
   }
   message.setProperty(`integrations.${INTEGERATION}`, true);