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

disabled

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2024-07-17 22:30:57 +02:00
parent 1db4ca2a7a
commit b782aafea6
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -36,15 +36,15 @@ 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( // this.redis.setex(
`live:event:${event.project_id}:${event.profile_id}`, // `live:event:${event.project_id}:${event.profile_id}`,
'', // '',
60 * 5 // 60 * 5
); // );
}; };
public onCompleted?: OnCompleted<IClickhouseEvent> | undefined = ( public onCompleted?: OnCompleted<IClickhouseEvent> | undefined = (