From c2d2f64fc3f2416848d0ef803f5f8d9725c2ad20 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Tue, 4 Feb 2025 16:51:18 +0100
Subject: [PATCH] use primary for reading eventbuffer

---
 packages/db/src/buffers/event-buffer-psql.ts   | 5 ++++-
 packages/db/src/buffers/profile-buffer-psql.ts | 5 +++++
 2 files changed, 9 insertions(+), 1 deletion(-)

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<IServiceEvent | null> {
-    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