wip

2024-07-17 23:50:59 +02:00
parent 4893a42b26
commit ba1bd0e035
1 changed files with 8 additions and 7 deletions
--- 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<IClickhouseEvent> {
      '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<IClickhouseEvent> | undefined = (