From f01d51981b97646dd6175268738a6cc0fb30ddf5 Mon Sep 17 00:00:00 2001 From: Hazelnoot Date: Wed, 25 Jun 2025 14:06:18 -0400 Subject: [PATCH] remove onUserUpdated listener from CollapsedQueueService --- packages/backend/src/core/CollapsedQueueService.ts | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/packages/backend/src/core/CollapsedQueueService.ts b/packages/backend/src/core/CollapsedQueueService.ts index 22a56a2346..9c01f434a2 100644 --- a/packages/backend/src/core/CollapsedQueueService.ts +++ b/packages/backend/src/core/CollapsedQueueService.ts @@ -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(); }