From a7e221ba2593b2b1d2c075f6eb313b59e49f5194 Mon Sep 17 00:00:00 2001
From: syuilo <4439005+syuilo@users.noreply.github.com>
Date: Thu, 17 Jul 2025 09:52:44 +0900
Subject: [PATCH] Update CleanRemoteNotesProcessorService.ts

---
 .../queue/processors/CleanRemoteNotesProcessorService.ts   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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;