chore: address commentsx1

rudderlabs · Feb 28, 2024 · b064d9f · b064d9f
1 parent a0fb0b4
commit b064d9f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/v0/destinations/redis/transform.js b/src/v0/destinations/redis/transform.js
@@ -4,7 +4,7 @@ const flatten = require('flat');
 const { InstrumentationError } = require('@rudderstack/integrations-lib');
 const { isEmpty, isObject } = require('../../util');
 const { EventType } = require('../../../constants');
-const { handleRecordEventsForRedis } = require('./transformV2');
+const { handleRecordEvents } = require('./utils');
 
 // processValues:
 // 1. removes keys with empty values or still an object(empty) after flattening
@@ -64,7 +64,7 @@ const process = (event) => {
   const { message, destination, metadata } = event;
   // seperate record events
   if (message.type === EventType.RECORD) {
-    return handleRecordEventsForRedis(message, destination, metadata);
+    return handleRecordEvents(message, destination, metadata);
   }
 
   const messageType = message && message.type && message.type.toLowerCase();

diff --git a/src/v0/destinations/redis/transformV2.js → src/v0/destinations/redis/utils.js b/src/v0/destinations/redis/transformV2.js → src/v0/destinations/redis/utils.js
@@ -32,7 +32,7 @@ const { transformSubEventTypeProfiles } = require('./transform');
 //     },
 // }
 
-function handleRecordEventsForRedis(message, destination, metadata) {
+function handleRecordEvents(message, destination, metadata) {
   // fields -> traits
   // metadata -> metadata
   // context.sources.profiles_<$$$> -> context.sources.profiles_<$$$>
@@ -42,4 +42,4 @@ function handleRecordEventsForRedis(message, destination, metadata) {
   return transformSubEventTypeProfiles(message, workspaceId, destinationId);
 }
 
-module.exports = { handleRecordEventsForRedis };
+module.exports = { handleRecordEvents };