misty.cafe/mistykey
1
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

remove onUserUpdated listener from CollapsedQueueService

Browse source
This commit is contained in:
Hazelnoot 2025-06-25 14:06:18 -04:00
parent 1d44a27505
commit f01d51981b
1 changed files with 0 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

11
packages/backend/src/core/CollapsedQueueService.ts
View file

@ -132,9 +132,6 @@ export class CollapsedQueueService implements OnApplicationShutdown {
concurrency: 4, // High concurrency - this queue gets a lot of activity
},
);
this.internalEventService.on('localUserUpdated', this.onUserUpdated);
this.internalEventService.on('remoteUserUpdated', this.onUserUpdated);
}
@bindThis
@ -169,16 +166,8 @@ export class CollapsedQueueService implements OnApplicationShutdown {
this.logger.error(`Error persisting ${queue.name}: ${renderInlineError(error)}`);
}
@bindThis
private onUserUpdated(data: { id: string }) {
this.updateUserQueue.enqueue(data.id, { updatedAt: new Date() });
}
async onApplicationShutdown() {
// TODO note/user delete events
// TODO remove updated events
this.internalEventService.off('localUserUpdated', this.onUserUpdated);
this.internalEventService.off('remoteUserUpdated', this.onUserUpdated);
await this.performAllNow();
}