wip
This commit is contained in:
@@ -40,13 +40,13 @@ export class EventBuffer extends RedisBuffer<IClickhouseEvent> {
|
|||||||
'event:received',
|
'event:received',
|
||||||
SuperJSON.stringify(transformEvent(event))
|
SuperJSON.stringify(transformEvent(event))
|
||||||
);
|
);
|
||||||
if (event.profile_id) {
|
// if (event.profile_id) {
|
||||||
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 = (
|
||||||
|
|||||||
Reference in New Issue
Block a user