chore: Remove v2 suffix for replay consumer (#17938)

PostHog · Oct 12, 2023 · e47c2aa · e47c2aa
1 parent 00c18b6
commit e47c2aa
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/...cording/session-recordings-consumer-v2.ts → ...-recording/session-recordings-consumer.ts b/...cording/session-recordings-consumer-v2.ts → ...-recording/session-recordings-consumer.ts
@@ -95,7 +95,7 @@ type PartitionMetrics = {
     lastKnownCommit?: number
 }
 
-export class SessionRecordingIngesterV2 {
+export class SessionRecordingIngester {
     redisPool: RedisPool
     sessions: Record<string, SessionManager> = {}
     sessionHighWaterMarker: OffsetHighWaterMarker

diff --git a/plugin-server/src/main/pluginsServer.ts b/plugin-server/src/main/pluginsServer.ts
@@ -35,7 +35,7 @@ import {
     startAsyncWebhooksHandlerConsumer,
 } from './ingestion-queues/on-event-handler-consumer'
 import { startScheduledTasksConsumer } from './ingestion-queues/scheduled-tasks-consumer'
-import { SessionRecordingIngesterV2 } from './ingestion-queues/session-recording/session-recordings-consumer-v2'
+import { SessionRecordingIngester } from './ingestion-queues/session-recording/session-recordings-consumer'
 import { createHttpServer } from './services/http-server'
 import { getObjectStorage } from './services/object_storage'
 
@@ -411,7 +411,7 @@ export async function startPluginsServer(
                 throw new Error("Can't start session recording blob ingestion without object storage")
             }
             // NOTE: We intentionally pass in the original serverConfig as the ingester uses both kafkas
-            const ingester = new SessionRecordingIngesterV2(serverConfig, postgres, s3)
+            const ingester = new SessionRecordingIngester(serverConfig, postgres, s3)
             await ingester.start()
 
             const batchConsumer = ingester.batchConsumer

diff --git a/...ng/session-recordings-consumer-v2.test.ts → ...rding/session-recordings-consumer.test.ts b/...ng/session-recordings-consumer-v2.test.ts → ...rding/session-recordings-consumer.test.ts
@@ -5,7 +5,7 @@ import path from 'path'
 
 import { waitForExpect } from '../../../../functional_tests/expectations'
 import { defaultConfig } from '../../../../src/config/config'
-import { SessionRecordingIngesterV2 } from '../../../../src/main/ingestion-queues/session-recording/session-recordings-consumer-v2'
+import { SessionRecordingIngester } from '../../../../src/main/ingestion-queues/session-recording/session-recordings-consumer'
 import { Hub, PluginsServerConfig, Team } from '../../../../src/types'
 import { createHub } from '../../../../src/utils/db/hub'
 import { getFirstTeam, resetTestDatabase } from '../../../helpers/sql'
@@ -57,7 +57,7 @@ jest.mock('../../../../src/kafka/batch-consumer', () => {
 jest.setTimeout(1000)
 
 describe('ingester', () => {
-    let ingester: SessionRecordingIngesterV2
+    let ingester: SessionRecordingIngester
 
     let hub: Hub
     let closeHub: () => Promise<void>
@@ -76,7 +76,7 @@ describe('ingester', () => {
         teamToken = team.api_token
         await deleteKeysWithPrefix(hub)
 
-        ingester = new SessionRecordingIngesterV2(config, hub.postgres, hub.objectStorage)
+        ingester = new SessionRecordingIngester(config, hub.postgres, hub.objectStorage)
         await ingester.start()
         nextOffset = 1
 
@@ -522,11 +522,11 @@ describe('ingester', () => {
     })
 
     describe('simulated rebalancing', () => {
-        let otherIngester: SessionRecordingIngesterV2
+        let otherIngester: SessionRecordingIngester
         jest.setTimeout(5000) // Increased to cover lock delay
 
         beforeEach(async () => {
-            otherIngester = new SessionRecordingIngesterV2(config, hub.postgres, hub.objectStorage)
+            otherIngester = new SessionRecordingIngester(config, hub.postgres, hub.objectStorage)
             await otherIngester.start()
         })