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..330a1aa 100644 --- a/src/libs/anilist/anilist-do.ts +++ b/src/libs/anilist/anilist-do.ts @@ -291,11 +291,13 @@ export class AnilistDurableObject extends DurableObject { async alarm() { const now = Date.now(); const alarms = await this.state.storage.list({ prefix: "alarm:" }); + console.debug(`Retrieved alarms from cache:`, Object.entries(alarms)); for (const [key, ttl] of Object.entries(alarms)) { if (now >= ttl) { // The key in alarms is `alarm:${storageKey}` // We want to delete the storageKey const storageKey = key.replace("alarm:", ""); + console.debug(`Deleting storage key ${storageKey} & alarm ${key}`); await this.state.storage.delete(storageKey); await this.state.storage.delete(key); }