From 92e24125db5bc48cb7f1ff9f356c77dc41124086 Mon Sep 17 00:00:00 2001 From: syuilo <4439005+syuilo@users.noreply.github.com> Date: Wed, 24 Sep 2025 09:39:53 +0900 Subject: [PATCH] Update PostScheduledNoteProcessorService.ts --- .../queue/processors/PostScheduledNoteProcessorService.ts | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/packages/backend/src/queue/processors/PostScheduledNoteProcessorService.ts b/packages/backend/src/queue/processors/PostScheduledNoteProcessorService.ts index f29ddd7161..e203189f0d 100644 --- a/packages/backend/src/queue/processors/PostScheduledNoteProcessorService.ts +++ b/packages/backend/src/queue/processors/PostScheduledNoteProcessorService.ts @@ -9,6 +9,7 @@ import type { NoteDraftsRepository } from '@/models/_.js'; import type Logger from '@/logger.js'; import { NotificationService } from '@/core/NotificationService.js'; import { bindThis } from '@/decorators.js'; +import { NoteCreateService } from '@/core/NoteCreateService.js'; import { QueueLoggerService } from '../QueueLoggerService.js'; import type * as Bull from 'bullmq'; import type { PostScheduledNoteJobData } from '../types.js'; @@ -21,6 +22,7 @@ export class PostScheduledNoteProcessorService { @Inject(DI.noteDraftsRepository) private noteDraftsRepository: NoteDraftsRepository, + private noteCreateService: NoteCreateService, private notificationService: NotificationService, private queueLoggerService: QueueLoggerService, ) { @@ -34,6 +36,10 @@ export class PostScheduledNoteProcessorService { return; } + const note = await this.noteCreateService.create(draft.user, draft); + + this.noteDraftsRepository.remove(draft); + this.notificationService.createNotification(draft.userId, 'scheduledNotePosted', { noteId: note.id, });