feat: add userId to web pixel events from redis if available

src/v1/sources/shopify/transformV1.js

@@ -17,7 +17,7 @@ const processV1Events = async (event) => {
       return processIdentifierEvent(event);
     }
     // handle events from the app pixel.
-    const pixelWebEventResponse = processPixelWebEvents(event);
+    const pixelWebEventResponse = await processPixelWebEvents(event);
     return pixelWebEventResponse;
   }
   if (isServerSideEvent) {

src/v1/sources/shopify/utils.js

@@ -11,8 +11,9 @@ const NO_OPERATION_SUCCESS = {
 const isIdentifierEvent = (payload) => ['rudderIdentifier'].includes(payload?.event);
 
 const processIdentifierEvent = async (event) => {
-  const { cartToken, anonymousId } = event;
+  const { cartToken, anonymousId, userId } = event;
   await RedisDB.setVal(`pixel:${cartToken}`, ['anonymousId', anonymousId]);
+  await RedisDB.setVal(`pixel:${anonymousId}`, ['userId', userId]);
   return NO_OPERATION_SUCCESS;
 };
 

src/v1/sources/shopify/webpixelTransformations/pixelTransform.js

@@ -85,7 +85,7 @@ const handleCartTokenRedisOperations = async (inputEvent, clientId) => {
   }
 };
 
-function processPixelEvent(inputEvent) {
+async function processPixelEvent(inputEvent) {
   // eslint-disable-next-line @typescript-eslint/naming-convention
   const { name, query_parameters, context, clientId, data, id } = inputEvent;
   const shopifyDetails = { ...inputEvent };
@@ -161,12 +161,19 @@ function processPixelEvent(inputEvent) {
     message.context.campaign = campaignParams;
   }
   message.messageId = id;
+
+  // attach userId to the message if anonymousId is present in Redis
+  // this allows stitching of events from the same user across multiple checkouts
+  const redisData = await RedisDB.getVal(`pixel:${message.anonymousId}`);
+  if (isDefinedNotNullNotEmpty(redisData)) {
+    message.userId = redisData.userId;
+  }
   message = removeUndefinedAndNullValues(message);
   return message;
 }
 
-const processPixelWebEvents = (event) => {
-  const pixelEvent = processPixelEvent(event);
+const processPixelWebEvents = async (event) => {
+  const pixelEvent = await processPixelEvent(event);
   return removeUndefinedAndNullValues(pixelEvent);
 };
 

test/integrations/sources/shopify/mocks.ts

@@ -1,5 +1,12 @@
 import utils from '../../../../src/v0/util';
+import { RedisDB } from '../../../../src/util/redis/redisConnector';
 
 export const mockFns = (_) => {
   jest.spyOn(utils, 'generateUUID').mockReturnValue('5d3e2cb6-4011-5c9c-b7ee-11bc1e905097');
+  jest.spyOn(RedisDB, 'getVal').mockImplementation((key) => {
+    if (key === 'pixel:c7b3f99b-4d34-463b-835f-c879482a7750') {
+      return Promise.resolve({ userId: 'test-user-id' });
+    }
+    return Promise.resolve({});
+  });
 };