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

use CacheService in all relationship jobs

Browse source
This commit is contained in:
Hazelnoot 2025-09-14 09:53:41 -04:00
parent 3fb2b38c92
commit 41d8c04097
1 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

12
packages/backend/src/queue/processors/RelationshipProcessorService.ts
View file

@ -51,8 +51,8 @@ export class RelationshipProcessorService {
public async processUnfollow(job: Bull.Job<RelationshipJobData>): Promise<string> { public async processUnfollow(job: Bull.Job<RelationshipJobData>): Promise<string> {
this.logger.info(`${job.data.from.id} is trying to unfollow ${job.data.to.id}`); this.logger.info(`${job.data.from.id} is trying to unfollow ${job.data.to.id}`);
const [follower, followee] = await Promise.all([ const [follower, followee] = await Promise.all([
this.usersRepository.findOneByOrFail({ id: job.data.from.id }), this.cacheService.findUserById(job.data.from.id),
this.usersRepository.findOneByOrFail({ id: job.data.to.id }), this.cacheService.findUserById(job.data.to.id),
]) as [MiLocalUser | MiRemoteUser, MiLocalUser | MiRemoteUser]; ]) as [MiLocalUser | MiRemoteUser, MiLocalUser | MiRemoteUser];
await this.userFollowingService.unfollow(follower, followee, job.data.silent); await this.userFollowingService.unfollow(follower, followee, job.data.silent);
return 'ok'; return 'ok';
@ -62,8 +62,8 @@ export class RelationshipProcessorService {
public async processBlock(job: Bull.Job<RelationshipJobData>): Promise<string> { public async processBlock(job: Bull.Job<RelationshipJobData>): Promise<string> {
this.logger.info(`${job.data.from.id} is trying to block ${job.data.to.id}`); this.logger.info(`${job.data.from.id} is trying to block ${job.data.to.id}`);
const [blockee, blocker] = await Promise.all([ const [blockee, blocker] = await Promise.all([
this.usersRepository.findOneByOrFail({ id: job.data.from.id }), this.cacheService.findUserById(job.data.from.id),
this.usersRepository.findOneByOrFail({ id: job.data.to.id }), this.cacheService.findUserById(job.data.to.id),
]); ]);
await this.userBlockingService.block(blockee, blocker, job.data.silent); await this.userBlockingService.block(blockee, blocker, job.data.silent);
return 'ok'; return 'ok';
@ -73,8 +73,8 @@ export class RelationshipProcessorService {
public async processUnblock(job: Bull.Job<RelationshipJobData>): Promise<string> { public async processUnblock(job: Bull.Job<RelationshipJobData>): Promise<string> {
this.logger.info(`${job.data.from.id} is trying to unblock ${job.data.to.id}`); this.logger.info(`${job.data.from.id} is trying to unblock ${job.data.to.id}`);
const [blockee, blocker] = await Promise.all([ const [blockee, blocker] = await Promise.all([
this.usersRepository.findOneByOrFail({ id: job.data.from.id }), this.cacheService.findUserById(job.data.from.id),
this.usersRepository.findOneByOrFail({ id: job.data.to.id }), this.cacheService.findUserById(job.data.to.id),
]); ]);
await this.userBlockingService.unblock(blockee, blocker); await this.userBlockingService.unblock(blockee, blocker);
return 'ok'; return 'ok';