diff --git a/packages/db/src/buffers/event-buffer.ts b/packages/db/src/buffers/event-buffer.ts index 32be5212..c902cf47 100644 --- a/packages/db/src/buffers/event-buffer.ts +++ b/packages/db/src/buffers/event-buffer.ts @@ -40,13 +40,14 @@ export class EventBuffer extends RedisBuffer { 'event:received', SuperJSON.stringify(transformEvent(event)) ); - // if (event.profile_id) { - // this.redis.setex( - // `live:event:${event.project_id}:${event.profile_id}`, - // '', - // 60 * 5 - // ); - // } + if (event.profile_id) { + this.redis.set( + `live:event:${event.project_id}:${event.profile_id}`, + '', + 'EX', + 60 * 5 + ); + } }; public onCompleted?: OnCompleted | undefined = (