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

avoid extra join in BackgroundTaskProcessorService.processPostNote

Browse source
This commit is contained in:
Hazelnoot 2025-10-23 11:30:10 -04:00
parent b89cbe8a43
commit 893b4ae260
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
packages/backend/src/queue/processors/BackgroundTaskProcessorService.ts
View file

@ -253,11 +253,12 @@ export class BackgroundTaskProcessorService {
private async processPostNote(task: PostNoteBackgroundTask): Promise<string> { private async processPostNote(task: PostNoteBackgroundTask): Promise<string> {
const note = await this.notesRepository.findOne({ const note = await this.notesRepository.findOne({
where: { id: task.noteId }, where: { id: task.noteId },
relations: { user: true, renote: true, reply: true, channel: true }, relations: { renote: true, reply: true, channel: true },
}); });
if (!note) return `Skipping post-note task: note ${task.noteId} has been deleted`; if (!note) return `Skipping post-note task: note ${task.noteId} has been deleted`;
const user = await this.cacheService.findUserById(note.userId); const user = await this.cacheService.findUserById(note.userId);
if (user.isSuspended) return `Skipping post-note task: note ${task.noteId}'s user ${note.userId} is suspended`; if (user.isSuspended) return `Skipping post-note task: note ${task.noteId}'s user ${note.userId} is suspended`;
note.user = user;
const mentionedUsers = await this.cacheService.getUsers(note.mentions); const mentionedUsers = await this.cacheService.getUsers(note.mentions);
const poll = await this.pollsRepository.findOneBy({ noteId: note.id }); const poll = await this.pollsRepository.findOneBy({ noteId: note.id });