diff --git a/packages/backend/src/queue/processors/RelationshipProcessorService.ts b/packages/backend/src/queue/processors/RelationshipProcessorService.ts index 3964fa7952..99a88a93d8 100644 --- a/packages/backend/src/queue/processors/RelationshipProcessorService.ts +++ b/packages/backend/src/queue/processors/RelationshipProcessorService.ts @@ -51,8 +51,8 @@ export class RelationshipProcessorService { public async processUnfollow(job: Bull.Job): Promise { this.logger.info(`${job.data.from.id} is trying to unfollow ${job.data.to.id}`); const [follower, followee] = await Promise.all([ - this.usersRepository.findOneByOrFail({ id: job.data.from.id }), - this.usersRepository.findOneByOrFail({ id: job.data.to.id }), + this.cacheService.findUserById(job.data.from.id), + this.cacheService.findUserById(job.data.to.id), ]) as [MiLocalUser | MiRemoteUser, MiLocalUser | MiRemoteUser]; await this.userFollowingService.unfollow(follower, followee, job.data.silent); return 'ok'; @@ -62,8 +62,8 @@ export class RelationshipProcessorService { public async processBlock(job: Bull.Job): Promise { this.logger.info(`${job.data.from.id} is trying to block ${job.data.to.id}`); const [blockee, blocker] = await Promise.all([ - this.usersRepository.findOneByOrFail({ id: job.data.from.id }), - this.usersRepository.findOneByOrFail({ id: job.data.to.id }), + this.cacheService.findUserById(job.data.from.id), + this.cacheService.findUserById(job.data.to.id), ]); await this.userBlockingService.block(blockee, blocker, job.data.silent); return 'ok'; @@ -73,8 +73,8 @@ export class RelationshipProcessorService { public async processUnblock(job: Bull.Job): Promise { this.logger.info(`${job.data.from.id} is trying to unblock ${job.data.to.id}`); const [blockee, blocker] = await Promise.all([ - this.usersRepository.findOneByOrFail({ id: job.data.from.id }), - this.usersRepository.findOneByOrFail({ id: job.data.to.id }), + this.cacheService.findUserById(job.data.from.id), + this.cacheService.findUserById(job.data.to.id), ]); await this.userBlockingService.unblock(blockee, blocker); return 'ok';