From 3fd4382c76aafbe6ee9a1adf67a9d22c57c2f673 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= Date: Tue, 18 Feb 2025 21:17:02 +0100 Subject: [PATCH] debug(buffer): log more and disable deletion of cache --- apps/worker/src/jobs/events.create-session-end.ts | 1 + packages/db/src/buffers/event-buffer-redis.ts | 14 +++++++------- 2 files changed, 8 insertions(+), 7 deletions(-) diff --git a/apps/worker/src/jobs/events.create-session-end.ts b/apps/worker/src/jobs/events.create-session-end.ts index c133ed19..bc544c93 100644 --- a/apps/worker/src/jobs/events.create-session-end.ts +++ b/apps/worker/src/jobs/events.create-session-end.ts @@ -134,6 +134,7 @@ export async function createSessionEnd( screenViews, sessionDuration, events, + lastScreenView: lastScreenView ? lastScreenView : 'none', }); return createEvent({ diff --git a/packages/db/src/buffers/event-buffer-redis.ts b/packages/db/src/buffers/event-buffer-redis.ts index 1219a15d..4496cdad 100644 --- a/packages/db/src/buffers/event-buffer-redis.ts +++ b/packages/db/src/buffers/event-buffer-redis.ts @@ -225,13 +225,13 @@ return "OK" addEventToSession(); } else if (event.name === 'session_end') { - // Delete last screen view - multi.del( - this.getLastEventKey({ - projectId: event.project_id, - profileId: event.profile_id, - }), - ); + // // Delete last screen view + // multi.del( + // this.getLastEventKey({ + // projectId: event.project_id, + // profileId: event.profile_id, + // }), + // ); // Check if session has any events const eventCount = await redis.llen(sessionKey);