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

enable publish on event

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2024-07-17 23:28:59 +02:00
parent d2a5a5792f
commit f0a2cafa74
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -36,15 +36,17 @@ export class EventBuffer extends RedisBuffer<IClickhouseEvent> {
} }
public onInsert?: OnInsert<IClickhouseEvent> | undefined = (event) => { public onInsert?: OnInsert<IClickhouseEvent> | undefined = (event) => {
// redisPub.publish( redisPub.publish(
// 'event:received', 'event:received',
// SuperJSON.stringify(transformEvent(event)) SuperJSON.stringify(transformEvent(event))
// ); );
// this.redis.setex( if (event.profile_id) {
// `live:event:${event.project_id}:${event.profile_id}`, this.redis.setex(
// '', `live:event:${event.project_id}:${event.profile_id}`,
// 60 * 5 '',
// ); 60 * 5
);
}
}; };
public onCompleted?: OnCompleted<IClickhouseEvent> | undefined = ( public onCompleted?: OnCompleted<IClickhouseEvent> | undefined = (