Swap to concat for events

PostHog · Sep 5, 2024 · d5bcbe2 · d5bcbe2
1 parent 70c6ce8
commit d5bcbe2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugin-server/src/main/ingestion-queues/session-recording/utils.ts b/plugin-server/src/main/ingestion-queues/session-recording/utils.ts
@@ -337,13 +337,13 @@ export const parseKafkaBatch = async (
         const newEventsByWindowId: IncomingRecordingMessage['eventsByWindowId'] = Object.entries(
             existingMessage.eventsByWindowId
         ).reduce((acc, [windowId, events]) => {
-            acc[windowId] = [...events]
+            acc[windowId] = ([] as RRWebEvent[]).concat(events)
             return acc
         }, {} as IncomingRecordingMessage['eventsByWindowId'])
 
         for (const [windowId, events] of Object.entries(parsedMessage.eventsByWindowId)) {
             newEventsByWindowId[windowId] = newEventsByWindowId[windowId] || []
-            newEventsByWindowId[windowId].push(...events)
+            newEventsByWindowId[windowId].concat(events)
         }
 
         existingMessage.eventsByWindowId = newEventsByWindowId