summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors
diff options
context:
space:
mode:
authorCaipira <caipira@libnare.net>2023-07-08 21:31:38 +0900
committerGitHub <noreply@github.com>2023-07-08 21:31:38 +0900
commit60366a45585654115d5178486cc747cf0ee9450a (patch)
tree47cad89d513a3bae6459156125b1d6dd2a8c18eb /packages/backend/src/queue/processors
parentperf(backend): Reduce memory usage of MemoryKVCache (#11076) (diff)
downloadsharkey-60366a45585654115d5178486cc747cf0ee9450a.tar.gz
sharkey-60366a45585654115d5178486cc747cf0ee9450a.tar.bz2
sharkey-60366a45585654115d5178486cc747cf0ee9450a.zip
fix(backend): Remove Meilisearch index when notes are deleted (#10988)
* fix(backend): Include feature to delete Meilisearch index notes * Update variable name `cascadingNotesFilter` -> `federatedLocalCascadingNotes` * tweak --------- Co-authored-by: syuilo <Syuilotan@yahoo.co.jp>
Diffstat (limited to 'packages/backend/src/queue/processors')
-rw-r--r--packages/backend/src/queue/processors/DeleteAccountProcessorService.ts6
1 files changed, 6 insertions, 0 deletions
diff --git a/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts b/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts
index 39dd801af0..65ded170b7 100644
--- a/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeleteAccountProcessorService.ts
@@ -12,6 +12,7 @@ import { bindThis } from '@/decorators.js';
import { QueueLoggerService } from '../QueueLoggerService.js';
import type * as Bull from 'bullmq';
import type { DbUserDeleteJobData } from '../types.js';
+import { SearchService } from "@/core/SearchService.js";
@Injectable()
export class DeleteAccountProcessorService {
@@ -36,6 +37,7 @@ export class DeleteAccountProcessorService {
private driveService: DriveService,
private emailService: EmailService,
private queueLoggerService: QueueLoggerService,
+ private searchService: SearchService,
) {
this.logger = this.queueLoggerService.logger.createSubLogger('delete-account');
}
@@ -71,6 +73,10 @@ export class DeleteAccountProcessorService {
cursor = notes[notes.length - 1].id;
await this.notesRepository.delete(notes.map(note => note.id));
+
+ for (const note of notes) {
+ await this.searchService.unindexNote(note);
+ }
}
this.logger.succ('All of notes deleted');