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

use immediate delete options in DeleteAccountProcessorService

Browse source
This commit is contained in:
Hazelnoot 2025-09-18 19:51:21 -04:00
parent 87212185b2
commit 3aa302ff15
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
packages/backend/src/queue/processors/DeleteAccountProcessorService.ts
View file

@ -328,7 +328,7 @@ export class DeleteAccountProcessorService {
// Delete replies through the usual service to ensure we get all "cascading notes" logic. // Delete replies through the usual service to ensure we get all "cascading notes" logic.
for (const reply of replies) { for (const reply of replies) {
await this.noteDeleteService.delete(reply.user as MiUser, reply); await this.noteDeleteService.delete(reply.user as MiUser, reply, undefined, true);
} }
await this.noteEditsRepository.delete({ await this.noteEditsRepository.delete({
@ -345,7 +345,7 @@ export class DeleteAccountProcessorService {
// Delete note AP logs // Delete note AP logs
const noteUris = notes.map(n => n.uri).filter(u => !!u) as string[]; const noteUris = notes.map(n => n.uri).filter(u => !!u) as string[];
if (noteUris.length > 0) { if (noteUris.length > 0) {
await this.apLogService.deleteObjectLogsDeferred(noteUris); await this.apLogService.deleteObjectLogs(noteUris);
} }
} }
@ -383,10 +383,10 @@ export class DeleteAccountProcessorService {
{ // Delete actor logs { // Delete actor logs
if (user.uri) { if (user.uri) {
await this.apLogService.deleteObjectLogsDeferred(user.uri); await this.apLogService.deleteObjectLogs(user.uri);
} }
await this.apLogService.deleteInboxLogsDeferred(user.id); await this.apLogService.deleteInboxLogs(user.id);
this.logger.info('All AP logs deleted'); this.logger.info('All AP logs deleted');
} }