From f0a2cafa741e9b63d53d7a8b197c05477da13eb6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Wed, 17 Jul 2024 23:28:59 +0200
Subject: [PATCH] enable publish on event

---
 packages/db/src/buffers/event-buffer.ts | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)

diff --git a/packages/db/src/buffers/event-buffer.ts b/packages/db/src/buffers/event-buffer.ts
index 0650b5ce..ebc0f502 100644
--- a/packages/db/src/buffers/event-buffer.ts
+++ b/packages/db/src/buffers/event-buffer.ts
@@ -36,15 +36,17 @@ export class EventBuffer extends RedisBuffer<IClickhouseEvent> {
   }
 
   public onInsert?: OnInsert<IClickhouseEvent> | undefined = (event) => {
-    // redisPub.publish(
-    //   'event:received',
-    //   SuperJSON.stringify(transformEvent(event))
-    // );
-    // this.redis.setex(
-    //   `live:event:${event.project_id}:${event.profile_id}`,
-    //   '',
-    //   60 * 5
-    // );
+    redisPub.publish(
+      'event:received',
+      SuperJSON.stringify(transformEvent(event))
+    );
+    if (event.profile_id) {
+      this.redis.setex(
+        `live:event:${event.project_id}:${event.profile_id}`,
+        '',
+        60 * 5
+      );
+    }
   };
 
   public onCompleted?: OnCompleted<IClickhouseEvent> | undefined = (