From 00b09924a6b085e62a8ed1dc70b819e5b4639b4b Mon Sep 17 00:00:00 2001
From: anatawa12 <anatawa12@icloud.com>
Date: Mon, 14 Apr 2025 00:00:07 +0900
Subject: [PATCH] chore: extend for deleting notes
---
.../src/queue/processors/DeleteAccountProcessorService.ts | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts b/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts
index a6440b5c74..55aaff8cf9 100644
--- a/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts
@@ -11,7 +11,7 @@ import { MiUser } from '@/models/User.js';
import type Logger from '@/logger.js';
import { DriveService } from '@/core/DriveService.js';
import type { MiDriveFile } from '@/models/DriveFile.js';
-import type { MiNote } from '@/models/Note.js';
+import { MiNote } from '@/models/Note.js';
import { EmailService } from '@/core/EmailService.js';
import { bindThis } from '@/decorators.js';
import { SearchService } from '@/core/SearchService.js';
@@ -78,7 +78,9 @@ export class DeleteAccountProcessorService {
cursor = notes.at(-1)?.id ?? null;
- await this.notesRepository.delete(notes.map(note => note.id));
+ await extendTimeoutQuery(this.db, async (manager) => {
+ await manager.delete(MiNote, notes.map(note => note.id));
+ });
for (const note of notes) {
await this.searchService.unindexNote(note);