From 14468a10048864031b541b2493a08fcb11ce2084 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Mon, 17 Feb 2025 06:01:56 +0100
Subject: [PATCH] fix(buffer): avoid stalled session events

---
 packages/db/src/buffers/event-buffer-redis.ts | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/packages/db/src/buffers/event-buffer-redis.ts b/packages/db/src/buffers/event-buffer-redis.ts
index 590c352e..6fb72c44 100644
--- a/packages/db/src/buffers/event-buffer-redis.ts
+++ b/packages/db/src/buffers/event-buffer-redis.ts
@@ -101,9 +101,11 @@ for i, sessionId in ipairs(sessionIds) do
     result[resultIndex] = { sessionId = sessionId, events = events }
     resultIndex = resultIndex + 1
     totalEvents = totalEvents + #events
-    if totalEvents >= batchSize then
-      break
-    end
+  end
+  
+  -- Only check if we should break AFTER processing the entire session
+  if totalEvents >= batchSize then
+    break
   end
 end