diff --git a/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts b/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts index 58e70c5bfb..1607334efe 100644 --- a/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts +++ b/packages/backend/src/queue/processors/CleanRemoteNotesProcessorService.ts @@ -58,6 +58,7 @@ export class CleanRemoteNotesProcessorService { }, take: 50, order: { + // 古い順 id: 1, }, }); @@ -70,6 +71,10 @@ export class CleanRemoteNotesProcessorService { await this.notesRepository.delete(notes.map(note => note.id)); for (const note of notes) { + if (cursor === null || note.id > cursor) { + cursor = note.id; + } + const t = this.idService.parse(note.id).date.getTime(); if (stats.oldest === null || t < stats.oldest) { stats.oldest = t; @@ -79,8 +84,6 @@ export class CleanRemoteNotesProcessorService { } } - cursor = notes.at(-1)?.id ?? null; - stats.deletedCount += notes.length; const elapsed = Date.now() - startAt;