fix: update the return data-structure

rudderlabs · May 2, 2024 · 8dd90fc · 8dd90fc
1 parent db3205d
commit 8dd90fc
Showing 1 changed file with 11 additions and 5 deletions.
diff --git a/src/v0/destinations/redis/transform.js b/src/v0/destinations/redis/transform.js
@@ -69,10 +69,13 @@ const process = (event) => {
     }
     // JSON.SET <key> . <value>
     return {
-      key: `${workspaceId}:${destinationId}:${message.context.sources.profiles_entity}:${message.context.sources.profiles_id_type}:${message.userId}`,
-      value: {
-        [message.context.sources.profiles_model]: message.traits,
+      message: {
+        key: `${workspaceId}:${destinationId}:${message.context.sources.profiles_entity}:${message.context.sources.profiles_id_type}:${message.userId}`,
+        value: {
+          [message.context.sources.profiles_model]: message.traits,
+        },
       },
+      userId: message.userId,
     };
   }
 
@@ -81,8 +84,11 @@ const process = (event) => {
     // If redis should store information as JSON type
     // JSON.SET <key> . <value>
     return {
-      key: `${keyPrefix}user:${lodash.toString(message.userId)}`,
-      value: message.traits || message.context.traits,
+      message: {
+        key: `${keyPrefix}user:${lodash.toString(message.userId)}`,
+        value: message.traits || message.context.traits,
+      },
+      userId: message.userId,
     };
   }