make the tests pass

PostHog · Mar 24, 2024 · a307efe · a307efe
1 parent 46b81c0
commit a307efe
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugin-server/src/main/ingestion-queues/session-recording/utils.ts b/plugin-server/src/main/ingestion-queues/session-recording/utils.ts
@@ -6,6 +6,7 @@ import path from 'path'
 import { KAFKA_SESSION_RECORDING_SNAPSHOT_ITEM_EVENTS } from '../../../config/kafka-topics'
 import { PipelineEvent, RawEventMessage, RRWebEvent } from '../../../types'
 import { status } from '../../../utils/status'
+import { cloneObject } from '../../../utils/utils'
 import { eventDroppedCounter } from '../metrics'
 import { TeamIDWithConfig } from './session-recordings-consumer'
 import { IncomingRecordingMessage, PersistedRecordingMessage } from './types'
@@ -256,7 +257,7 @@ export const reduceRecordingMessages = (messages: IncomingRecordingMessage[]): I
     for (const message of messages) {
         const key = `${message.team_id}-${message.session_id}`
         if (!reducedMessages[key]) {
-            reducedMessages[key] = message
+            reducedMessages[key] = cloneObject(message)
         } else {
             const existingMessage = reducedMessages[key]
             for (const [windowId, events] of Object.entries(message.eventsByWindowId)) {