From f9ca949d8e6f41f538c469f7d067ec832aaff223 Mon Sep 17 00:00:00 2001 From: Rushil Perera Date: Thu, 18 Dec 2025 08:50:53 -0500 Subject: [PATCH] chore: add debug logging to help understand why episode updates won't run --- src/index.ts | 1 + src/libs/anilist/anilist-do.ts | 2 ++ 2 files changed, 3 insertions(+) diff --git a/src/index.ts b/src/index.ts index ff869f1..ae887c9 100644 --- a/src/index.ts +++ b/src/index.ts @@ -82,6 +82,7 @@ export default { case "ANILIST_UPDATES": const anilistUpdateBody = message.body as QueueBody["ANILIST_UPDATES"]; + console.log("queue run", message.body); switch (anilistUpdateBody.updateType) { case AnilistUpdateType.UpdateWatchStatus: if (!anilistUpdateBody[AnilistUpdateType.UpdateWatchStatus]) { diff --git a/src/libs/anilist/anilist-do.ts b/src/libs/anilist/anilist-do.ts index 18995e6..aa55a6b 100644 --- a/src/libs/anilist/anilist-do.ts +++ b/src/libs/anilist/anilist-do.ts @@ -276,12 +276,14 @@ export class AnilistDurableObject extends DurableObject { const result = await fetcher(); await this.state.storage.put(key, result); + console.debug(`Retrieved alarms from cache:`, Object.entries(alarms)); const calculatedTtl = typeof ttl === "function" ? ttl(result) : ttl; if (calculatedTtl && calculatedTtl > 0) { const alarmTime = Date.now() + calculatedTtl; await this.state.storage.setAlarm(alarmTime); + console.debug(`Deleting storage key ${storageKey} & alarm ${key}`); await this.state.storage.put(`alarm:${key}`, alarmTime); }