From 0dfa77957c8b079faa4cd59c2e483e6626a4fa9f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Sun, 9 Feb 2025 06:49:07 +0100
Subject: [PATCH] tmp(buffer): get all sessions instead

---
 packages/db/src/buffers/event-buffer-redis.ts | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/packages/db/src/buffers/event-buffer-redis.ts b/packages/db/src/buffers/event-buffer-redis.ts
index 1bbfc168..30b9c559 100644
--- a/packages/db/src/buffers/event-buffer-redis.ts
+++ b/packages/db/src/buffers/event-buffer-redis.ts
@@ -283,12 +283,9 @@ return "OK"
     }
 
     for (const session of parsed) {
-      // Might be redundant check
-      if (session.events.length > 1) {
-        sessions[session.sessionId] = session.events
-          .map((e) => getSafeJson<IClickhouseEvent>(e))
-          .filter((e): e is IClickhouseEvent => e !== null);
-      }
+      sessions[session.sessionId] = session.events
+        .map((e) => getSafeJson<IClickhouseEvent>(e))
+        .filter((e): e is IClickhouseEvent => e !== null);
     }
 
     return sessions;
@@ -336,7 +333,7 @@ return "OK"
       let now = performance.now();
       const [sessions, regularQueueEvents] = await Promise.all([
         // (A) Fetch session events
-        this.getEligableSessions({ minEventsInSession: 2 }),
+        this.getEligableSessions({ minEventsInSession: 1 }),
         // (B) Fetch no-session events
         redis.lrange(this.regularQueueKey, 0, this.batchSize / 2 - 1),
       ]);