chore: rename acc to collection for clarity

Enterprise-CMCS · Nov 28, 2024 · 10a729f · 10a729f
1 parent 290bd49
commit 10a729f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/lib/lambda/sinkMainProcessors.ts b/lib/lambda/sinkMainProcessors.ts
@@ -56,20 +56,20 @@ const getTransformedEventFromRecord = (
 };
 
 export const processAndIndex = async (kafkaRecords: KafkaRecord[], topicPartition: string) => {
-  const recordsToUpdate = kafkaRecords.reduce<TransformedEvent[]>((acc, kafkaRecord) => {
+  const recordsToUpdate = kafkaRecords.reduce<TransformedEvent[]>((collection, kafkaRecord) => {
     console.log(`record: ${JSON.stringify(kafkaRecord, null, 2)}`);
 
     try {
       const { value } = kafkaRecord;
 
       if (!value) {
-        return acc;
+        return collection;
       }
 
       const transformedEvent = getTransformedEventFromRecord(value, topicPartition, kafkaRecord);
 
       if (transformedEvent) {
-        return acc.concat(transformedEvent);
+        return collection.concat(transformedEvent);
       }
     } catch (error) {
       logError({
@@ -79,7 +79,7 @@ export const processAndIndex = async (kafkaRecords: KafkaRecord[], topicPartitio
       });
     }
 
-    return acc;
+    return collection;
   }, []);
 
   await bulkUpdateDataWrapper(recordsToUpdate, "main");