diff --git a/plugin-server/src/ingestion/ingestion-e2e.test.ts b/plugin-server/src/ingestion/ingestion-e2e.test.ts index 92d42b6c39..d677ef449a 100644 --- a/plugin-server/src/ingestion/ingestion-e2e.test.ts +++ b/plugin-server/src/ingestion/ingestion-e2e.test.ts @@ -242,7 +242,7 @@ describe('Event Pipeline E2E tests', () => { expect(warnings).toEqual([ expect.objectContaining({ type: 'client_ingestion_warning', - team_id: team.id.toString(), + team_id: team.id, details: expect.objectContaining({ message: 'test message' }), }), ]) @@ -259,7 +259,7 @@ describe('Event Pipeline E2E tests', () => { await waitForExpect(async () => { const events = await fetchEvents(hub, team.id) expect(events.length).toBe(1) - expect(events[0].team_id).toBe(team.id.toString()) + expect(events[0].team_id).toBe(team.id) }) }) diff --git a/plugin-server/tests/worker/ingestion/person-state-batch.test.ts b/plugin-server/tests/worker/ingestion/person-state-batch.test.ts index 2b356cc935..ec5cd1e2fe 100644 --- a/plugin-server/tests/worker/ingestion/person-state-batch.test.ts +++ b/plugin-server/tests/worker/ingestion/person-state-batch.test.ts @@ -396,7 +396,7 @@ describe('PersonState.processEvent()', () => { expect.objectContaining({ distinct_id: 'new2', person_id: newUserUuid, - version: '1', + version: 1, }), ]) ) @@ -1465,13 +1465,13 @@ describe('PersonState.processEvent()', () => { id: expect.any(String), properties: '{}', created_at: timestampch, - version: '1', + version: 1, is_identified: 1, }), expect.objectContaining({ id: expect.any(String), is_deleted: 1, - version: '100', + version: 100, }), ]) ) @@ -1665,13 +1665,13 @@ describe('PersonState.processEvent()', () => { id: expect.any(String), properties: JSON.stringify({ a: 1, b: 3, c: 4, d: 6, e: 7, f: 9 }), created_at: timestampch, - version: '1', + version: 1, is_identified: 1, }), expect.objectContaining({ id: expect.any(String), is_deleted: 1, - version: '100', + version: 100, }), ]) ) @@ -1890,13 +1890,13 @@ describe('PersonState.processEvent()', () => { id: expect.any(String), properties: '{}', created_at: timestampch, - version: '1', + version: 1, is_identified: 1, }), expect.objectContaining({ id: expect.any(String), is_deleted: 1, - version: '100', + version: 100, }), ]) ) @@ -2383,13 +2383,13 @@ describe('PersonState.processEvent()', () => { id: firstUserUuid, properties: '{}', created_at: timestampch, - version: '1', + version: 1, is_identified: 1, }), expect.objectContaining({ id: secondUserUuid, is_deleted: 1, - version: '100', + version: 100, }), ]) ) diff --git a/plugin-server/tests/worker/ingestion/postgres-parity.test.ts b/plugin-server/tests/worker/ingestion/postgres-parity.test.ts index 1a225f4979..3d33f7f477 100644 --- a/plugin-server/tests/worker/ingestion/postgres-parity.test.ts +++ b/plugin-server/tests/worker/ingestion/postgres-parity.test.ts @@ -117,7 +117,7 @@ describe('postgres parity', () => { { id: uuid, created_at: expect.any(String), // '2021-02-04 00:18:26.472', - team_id: teamId.toString(), + team_id: teamId, properties: { userPropOnce: 'propOnceValue', userProp: 'propValue' }, is_identified: 1, is_deleted: 0, @@ -160,15 +160,15 @@ describe('postgres parity', () => { { distinct_id: 'distinct1', person_id: person.uuid, - team_id: teamId.toString(), - version: '0', + team_id: teamId, + version: 0, is_deleted: 0, }, { distinct_id: 'distinct2', person_id: person.uuid, - team_id: teamId.toString(), - version: '0', + team_id: teamId, + version: 0, is_deleted: 0, }, ]) @@ -332,8 +332,8 @@ describe('postgres parity', () => { { distinct_id: 'distinct1', person_id: person.uuid, - team_id: teamId.toString(), - version: '0', + team_id: teamId, + version: 0, is_deleted: 0, }, ]) @@ -431,15 +431,15 @@ describe('postgres parity', () => { { distinct_id: 'another_distinct_id', person_id: anotherPerson.uuid, - team_id: teamId.toString(), - version: '0', + team_id: teamId, + version: 0, is_deleted: 0, }, { distinct_id: 'distinct1', person_id: anotherPerson.uuid, - team_id: teamId.toString(), - version: '1', + team_id: teamId, + version: 1, is_deleted: 0, }, ]) diff --git a/plugin-server/tests/worker/ingestion/utils.test.ts b/plugin-server/tests/worker/ingestion/utils.test.ts index ce017d671a..df8bb9fb64 100644 --- a/plugin-server/tests/worker/ingestion/utils.test.ts +++ b/plugin-server/tests/worker/ingestion/utils.test.ts @@ -29,7 +29,7 @@ describe('captureIngestionWarning()', () => { expect(warnings).toEqual([ expect.objectContaining({ - team_id: '2', + team_id: 2, source: 'plugin-server', type: 'some_type', details: '{"foo":"bar"}',