diff --git a/packages/db/src/buffers/event-buffer-psql.ts b/packages/db/src/buffers/event-buffer-psql.ts index d1afe2ec..292292ae 100644 --- a/packages/db/src/buffers/event-buffer-psql.ts +++ b/packages/db/src/buffers/event-buffer-psql.ts @@ -245,13 +245,16 @@ export class EventBuffer extends BaseBuffer { projectId: string; profileId: string; }): Promise { - const event = await db.eventBuffer.findFirst({ + const event = await db.$primary().eventBuffer.findFirst({ where: { projectId, profileId, name: 'screen_view', }, orderBy: { createdAt: 'desc' }, + select: { + payload: true, + }, }); if (event) { diff --git a/packages/db/src/buffers/profile-buffer-psql.ts b/packages/db/src/buffers/profile-buffer-psql.ts index 0f7649d0..1ab4c575 100644 --- a/packages/db/src/buffers/profile-buffer-psql.ts +++ b/packages/db/src/buffers/profile-buffer-psql.ts @@ -122,6 +122,11 @@ export class ProfileBuffer extends BaseBuffer { orderBy: { createdAt: 'desc', }, + select: { + checksum: true, + payload: true, + id: true, + }, }); // Last item in buffer is the same as the new profile