zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(buffer): unpack error

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2025-02-09 07:21:17 +01:00
parent 0dfa77957c
commit b1a66199a3
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/db/src/buffers/event-buffer-redis.ts
View File

@@ -90,7 +90,12 @@ for i, sessionId in ipairs(sessionIds) do
if #events == 0 then if #events == 0 then
table.insert(sessionsToRemove, sessionId) table.insert(sessionsToRemove, sessionId)
elseif #events >= minEvents then -- Use the parameter instead of hardcoded value -- If we have collected 100 sessions to remove, remove them now
if #sessionsToRemove >= 100 then
redis.call('ZREM', sessionSortedKey, unpack(sessionsToRemove))
sessionsToRemove = {}
end
elseif #events >= minEvents then
result[resultIndex] = { sessionId = sessionId, events = events } result[resultIndex] = { sessionId = sessionId, events = events }
resultIndex = resultIndex + 1 resultIndex = resultIndex + 1
totalEvents = totalEvents + #events totalEvents = totalEvents + #events
@@ -100,6 +105,7 @@ for i, sessionId in ipairs(sessionIds) do
end end
end end
-- Remove any remaining sessions
if #sessionsToRemove > 0 then if #sessionsToRemove > 0 then
redis.call('ZREM', sessionSortedKey, unpack(sessionsToRemove)) redis.call('ZREM', sessionSortedKey, unpack(sessionsToRemove))
end end