[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_412":413,"_414":415},"routes/_app.x.$handle.$name",{"_97":96,"_31":44,"_105":87,"_26":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":24,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":24,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":24},"version",32,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","services/scheduled-messages.cron.ts","latestPath","fileId","95405670-1d6c-11f1-a9cb-42dde27851f2","name","scheduled-messages.cron.ts","fileType","interval","content","/**\n * services/scheduled-messages.cron.ts\n *\n * Cron job that delivers due scheduled messages and cleans up KV.\n * Schedule in Val Town to run every 1-5 minutes.\n */\n\nimport { discordBotFetch } from \"../discord/discord-api.ts\";\nimport type { ScheduledMessage } from \"../discord/interactions/commands/schedule.ts\";\nimport { KV_PREFIX } from \"../discord/interactions/commands/schedule.ts\";\nimport { runCron, deliverWithRetry } from \"../discord/helpers/cron.ts\";\n\nconst CONCURRENCY = 5;\n\nexport default async function () {\n await runCron({\n name: \"ScheduledMsgCron\",\n prefix: KV_PREFIX,\n maxDue: 100,\n async process(entry, logger) {\n await deliverWithRetry({\n entry,\n validate: (v) => !!(v as ScheduledMessage)?.channelId && !!(v as ScheduledMessage)?.content,\n deliver: (v) => {\n const msg = v as ScheduledMessage;\n return discordBotFetch(\"POST\", `channels/${msg.channelId}/messages`, {\n content: msg.content,\n });\n },\n logger,\n entityLabel: \"scheduled message\",\n });\n },\n });\n}\n","createdAt",["D",1773248762243],"branchVersion","branchId","4db1f610-1d6c-11f1-9a9a-42dde27851f2","id","4db147e2-1d6c-11f1-9a9a-42dde27851f2","catnip",["D",1773248642232],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Open source Discord bot template built for Val Town","imageUrl","d06b6c80-f3a1-11ef-89a3-8735e07158f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","e03963fb-ecc4-48fb-bc25-0173a8b9a8c8","tursoName","4db147e21d6c11f19a9a42dde27851f2","tursoHostname","4db147e21d6c11f19a9a42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789520505489],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":24},"branch",{"_13":86,"_31":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned",367,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","catalloc","handle","displayName","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0478d851-5bca-4d5e-6593-fb952af01c00/square512?exp=1789574399&sig=a9ef0704cdeece2faded611a27124cd8449ad633644a735efe39174587de46e5","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":407,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":24,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":408,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":409,"_81":410,"_83":411,"_85":24},"tree",[173,185,200,202],"files",[173,174,175,176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200,201,202],"counts",{"_161":60,"_162":163,"_164":60,"_165":166,"_167":168},"contents",[128,129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":155,"_31":156,"_29":157,"_135":-5,"_40":41,"_39":158,"_137":123,"_37":159,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_26":160},{"_42":149,"_31":150,"_29":151,"_135":-5,"_40":41,"_39":152,"_137":123,"_37":153,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_26":154},{"_42":142,"_31":143,"_29":144,"_135":-5,"_40":41,"_39":145,"_137":123,"_37":146,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_26":148},{"_42":132,"_31":133,"_29":134,"_135":-5,"_40":41,"_39":136,"_137":123,"_37":138,"_13":60,"_33":20,"_35":139,"_23":24,"_140":-5,"_26":141},"953cdb4e-1d6c-11f1-9ac8-42dde27851f2","SECURITY.md","953cdbee-1d6c-11f1-9ac8-42dde27851f2","parentId",31,"latest",["D",1773248762247],"# Security Policy\n\n## Reporting a Vulnerability\n\nIf you discover a security vulnerability in Catnip, please report it responsibly:\n\n1. **Do not** open a public GitHub issue\n2. Email **catalloc** (see GitHub profile) with a description of the vulnerability\n3. Include steps to reproduce if possible\n\nYou should receive an acknowledgment within 48 hours. Fixes for confirmed vulnerabilities will be released as soon as practical.\n\n## Security Practices\n\nCatnip implements the following security measures:\n\n- **Ed25519 signature verification** on all Discord interactions\n- **HMAC-SHA256 state tokens** with 10-minute expiry for OAuth2 CSRF protection\n- **Timing-safe comparisons** for all secret/token validation (prevents timing attacks)\n- **Parameterized SQL queries** throughout the KV layer (prevents injection)\n- **Mention sanitization** to prevent `@everyone`/`@here` abuse\n- **Content-Security-Policy**, **X-Frame-Options**, and **X-Content-Type-Options** headers on HTML pages\n- **Explicit null defaults** for optional secrets — features fail loudly instead of operating with empty credentials\n- **Rate limiting** on Patreon webhooks and per-user command cooldowns\n- **Exactly-once delivery** for cron jobs via atomic `claimDelete()` operations\n- **Retry with exponential backoff** for Discord API calls, respecting `429 Retry-After`\n- **30-second request timeouts** on all outbound HTTP calls\n- **Guild allowlist** support via `ALLOWED_GUILD_IDS`\n\n## Environment Variables\n\nAll secrets are read from environment variables at runtime — nothing is hardcoded. See `.env.example` for the full list. Required variables cause the bot to fail at startup if missing.\n","label",[133],"942269cc-1d6c-11f1-9109-42dde27851f2","test","94226a9e-1d6c-11f1-9109-42dde27851f2",5,["D",1773248760409],"directory",[143],"94074818-1d6c-11f1-9109-42dde27851f2","services","940748e0-1d6c-11f1-9109-42dde27851f2",3,["D",1773248760230],[150],"9414ade6-1d6c-11f1-9109-42dde27851f2","discord","9414aeb8-1d6c-11f1-9109-42dde27851f2",4,["D",1773248760319],[156],"pulls","branches",1,"forks","envVars",{"_169":171,"_172":60},"connections",{"_169":60,"_170":60},"count","unfilledCount",8,"emptyCount",{"_42":155,"_31":156,"_29":157,"_135":-5,"_40":41,"_39":158,"_137":123,"_37":404,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":405,"_26":406},{"_42":399,"_31":398,"_29":393,"_135":157,"_40":41,"_39":400,"_137":123,"_37":401,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":402,"_26":403},{"_42":390,"_31":391,"_29":392,"_135":393,"_40":41,"_39":394,"_137":123,"_37":395,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":396,"_26":397},{"_42":383,"_31":384,"_29":385,"_135":157,"_40":41,"_39":386,"_137":123,"_37":387,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":388,"_26":389},{"_42":378,"_31":370,"_29":365,"_135":157,"_40":41,"_39":379,"_137":123,"_37":380,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":381,"_26":382},{"_42":371,"_31":372,"_29":373,"_135":365,"_40":41,"_39":374,"_137":123,"_37":375,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":376,"_26":377},{"_42":362,"_31":363,"_29":364,"_135":365,"_40":41,"_39":366,"_137":123,"_37":367,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":368,"_26":369},{"_42":358,"_31":357,"_29":352,"_135":157,"_40":41,"_39":171,"_137":123,"_37":359,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":360,"_26":361},{"_42":349,"_31":350,"_29":351,"_135":352,"_40":41,"_39":353,"_137":123,"_37":354,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":355,"_26":356},{"_42":342,"_31":343,"_29":344,"_135":157,"_40":41,"_39":345,"_137":123,"_37":346,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":347,"_26":348},{"_42":336,"_31":150,"_29":337,"_135":157,"_40":41,"_39":338,"_137":123,"_37":339,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":340,"_26":341},{"_42":329,"_31":330,"_29":331,"_135":157,"_40":41,"_39":332,"_137":123,"_37":333,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":334,"_26":335},{"_42":149,"_31":150,"_29":151,"_135":-5,"_40":41,"_39":152,"_137":123,"_37":326,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":327,"_26":328},{"_42":318,"_31":319,"_29":320,"_135":151,"_40":41,"_39":321,"_137":24,"_37":322,"_13":60,"_33":34,"_35":323,"_23":24,"_140":-5,"_204":324,"_26":325},{"_42":310,"_31":311,"_29":312,"_135":151,"_40":41,"_39":313,"_137":24,"_37":314,"_13":60,"_33":34,"_35":315,"_23":24,"_140":-5,"_204":316,"_26":317},{"_42":302,"_31":303,"_29":304,"_135":151,"_40":41,"_39":305,"_137":24,"_37":306,"_13":60,"_33":34,"_35":307,"_23":24,"_140":-5,"_204":308,"_26":309},{"_42":294,"_31":295,"_29":296,"_135":151,"_40":41,"_39":297,"_137":24,"_37":298,"_13":60,"_33":290,"_35":299,"_23":24,"_140":44,"_204":300,"_26":301},{"_42":285,"_31":286,"_29":287,"_135":151,"_40":41,"_39":288,"_137":24,"_37":289,"_13":60,"_33":290,"_35":291,"_23":24,"_140":-5,"_204":292,"_26":293},{"_42":277,"_31":278,"_29":279,"_135":151,"_40":41,"_39":280,"_137":24,"_37":281,"_13":60,"_33":34,"_35":282,"_23":24,"_140":-5,"_204":283,"_26":284},{"_42":269,"_31":270,"_29":271,"_135":151,"_40":41,"_39":272,"_137":24,"_37":273,"_13":60,"_33":34,"_35":274,"_23":24,"_140":-5,"_204":275,"_26":276},{"_42":261,"_31":262,"_29":263,"_135":151,"_40":41,"_39":264,"_137":24,"_37":265,"_13":60,"_33":34,"_35":266,"_23":24,"_140":-5,"_204":267,"_26":268},{"_42":253,"_31":254,"_29":255,"_135":151,"_40":41,"_39":256,"_137":24,"_37":257,"_13":60,"_33":34,"_35":258,"_23":24,"_140":-5,"_204":259,"_26":260},{"_42":245,"_31":246,"_29":247,"_135":151,"_40":41,"_39":248,"_137":24,"_37":249,"_13":60,"_33":34,"_35":250,"_23":24,"_140":-5,"_204":251,"_26":252},{"_42":241,"_31":32,"_29":30,"_135":151,"_40":41,"_39":14,"_137":24,"_37":242,"_13":60,"_33":34,"_35":36,"_23":24,"_140":-5,"_204":243,"_26":244},{"_42":233,"_31":234,"_29":235,"_135":151,"_40":41,"_39":236,"_137":24,"_37":237,"_13":60,"_33":34,"_35":238,"_23":24,"_140":-5,"_204":239,"_26":240},{"_42":225,"_31":226,"_29":227,"_135":151,"_40":41,"_39":228,"_137":24,"_37":229,"_13":60,"_33":34,"_35":230,"_23":24,"_140":-5,"_204":231,"_26":232},{"_42":217,"_31":218,"_29":219,"_135":151,"_40":41,"_39":220,"_137":24,"_37":221,"_13":60,"_33":34,"_35":222,"_23":24,"_140":-5,"_204":223,"_26":224},{"_42":142,"_31":143,"_29":144,"_135":-5,"_40":41,"_39":145,"_137":123,"_37":214,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":215,"_26":216},{"_42":207,"_31":208,"_29":209,"_135":144,"_40":41,"_39":210,"_137":123,"_37":211,"_13":60,"_33":147,"_35":-5,"_23":24,"_140":-5,"_204":212,"_26":213},{"_42":132,"_31":133,"_29":134,"_135":-5,"_40":41,"_39":136,"_137":123,"_37":203,"_13":60,"_33":20,"_35":139,"_23":24,"_140":-5,"_204":205,"_26":206},["D",1773248762247],"children",[],[133],"94922168-1d6c-11f1-9109-42dde27851f2","_mocks","9492226c-1d6c-11f1-9109-42dde27851f2",13,["D",1773248761136],[],[143,208],["D",1773248760409],[201],[143],"95224f4a-1d6c-11f1-bb31-42dde27851f2","tickets.cron_test.ts","95224ffe-1d6c-11f1-bb31-42dde27851f2",27,["D",1773248761748],"import \"../test/_mocks/env.ts\";\nimport \"../test/_mocks/sqlite.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, getCalls, restoreFetch, setNextThrow } from \"../test/_mocks/fetch.ts\";\nimport type { TicketData } from \"../discord/interactions/commands/ticket.ts\";\nimport runCron from \"./tickets.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makeTicket(overrides?: Partial): TicketData {\n return {\n guildId: \"g1\",\n channelId: \"ch1\",\n userId: \"u1\",\n title: \"Test Ticket\",\n staffMessageId: \"smsg1\",\n staffChannelId: \"staff_ch\",\n joinedStaff: [],\n status: \"closed\",\n closedBy: \"staff1\",\n createdAt: Date.now() - 86400000,\n ...overrides,\n };\n}\n\nDeno.test(\"tickets cron: deletes closed ticket channel and removes KV entry\", async () => {\n resetStore();\n const key = \"ticket:g1:ch1\";\n await kv.set(key, makeTicket(), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n\n // Verify DELETE call to Discord API\n const calls = getCalls();\n const deleteCall = calls.find((c) =>\n c.url.includes(\"channels/ch1\") && c.init?.method === \"DELETE\"\n );\n assert(deleteCall !== undefined);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: treats 404 as success\", async () => {\n resetStore();\n const key = \"ticket:g1:ch_gone\";\n await kv.set(key, makeTicket({ channelId: \"ch_gone\" }), Date.now() - 1000);\n mockFetch({ default: { status: 404, body: { message: \"Unknown Channel\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: skips open tickets\", async () => {\n resetStore();\n const key = \"ticket:g1:ch_open\";\n await kv.set(key, makeTicket({ channelId: \"ch_open\", status: \"open\" }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n // Open ticket should still exist (not claimed)\n const remaining = await kv.get(key);\n assert(remaining !== null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: re-inserts on failure with retry delay\", async () => {\n resetStore();\n const key = \"ticket:g1:ch_fail\";\n const ticket = makeTicket({ channelId: \"ch_fail\" });\n await kv.set(key, ticket, Date.now() - 1000);\n mockFetch({ default: { status: 500, body: { message: \"Internal Server Error\" } } });\n try {\n await runCron();\n // Should be re-inserted for retry\n const remaining = await kv.get(key);\n assert(remaining !== null);\n assertEquals(remaining?.channelId, \"ch_fail\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: no-op when no due entries\", async () => {\n resetStore();\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n const calls = getCalls();\n // No Discord API calls should be made\n assertEquals(calls.length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: timeout error re-inserts with retry delay\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n const key = \"ticket:g1:ch_timeout\";\n const ticket = makeTicket({ channelId: \"ch_timeout\" });\n await kv.set(key, ticket, Date.now() - 1000);\n // Mock fetch to always throw so discordBotFetch fails on all retries\n mockFetch();\n const origFetch = globalThis.fetch;\n globalThis.fetch = (() => { throw new Error(\"Timed out\"); }) as any;\n try {\n await runCron();\n // Should be re-inserted for retry\n const remaining = await kv.get(key);\n assert(remaining !== null, \"Ticket should be re-inserted after timeout\");\n assertEquals(remaining?.channelId, \"ch_timeout\");\n } finally {\n globalThis.fetch = origFetch;\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: 403 error re-inserts (non-404 non-200)\", async () => {\n resetStore();\n const key = \"ticket:g1:ch_403\";\n const ticket = makeTicket({ channelId: \"ch_403\" });\n await kv.set(key, ticket, Date.now() - 1000);\n mockFetch({ default: { status: 403, body: { message: \"Missing Permissions\" } } });\n try {\n await runCron();\n // 403 is not ok and not 404, so should be re-inserted\n const remaining = await kv.get(key);\n assert(remaining !== null, \"Ticket should be re-inserted after 403 error\");\n assertEquals(remaining?.channelId, \"ch_403\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: claimDelete returns false silently skips\", async () => {\n resetStore();\n const key = \"ticket:g1:ch_claimed\";\n const ticket = makeTicket({ channelId: \"ch_claimed\" });\n await kv.set(key, ticket, Date.now() - 1000);\n\n const origClaimDelete = kv.claimDelete.bind(kv);\n (kv as any).claimDelete = async (k: string) => {\n if (k === key) return false;\n return origClaimDelete(k);\n };\n\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n // claimDelete returned false — no Discord API call should be made\n const calls = getCalls();\n const deleteCall = calls.find((c) =>\n c.url.includes(\"channels/ch_claimed\") && c.init?.method === \"DELETE\"\n );\n assertEquals(deleteCall, undefined, \"Should not call Discord API when claimDelete returns false\");\n } finally {\n (kv as any).claimDelete = origClaimDelete;\n restoreFetch();\n }\n});\n\nDeno.test(\"tickets cron: KV.set failure on re-insert does not crash\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n const key = \"ticket:g1:ch_reinsert_fail\";\n const ticket = makeTicket({ channelId: \"ch_reinsert_fail\" });\n await kv.set(key, ticket, Date.now() - 1000);\n // Return 500 to trigger the catch block (re-insert path)\n mockFetch({ default: { status: 500, body: { message: \"Internal Server Error\" } } });\n\n // Monkey-patch kv.set to throw on re-insert\n const origSet = kv.set.bind(kv);\n let setCallCount = 0;\n (kv as any).set = async (...args: unknown[]) => {\n setCallCount++;\n // The re-insert kv.set is called after the catch block\n if (setCallCount > 0 && args[0] === key) {\n throw new Error(\"KV set failure\");\n }\n return origSet(...(args as Parameters));\n };\n\n try {\n // Should not throw even though kv.set fails on re-insert\n await runCron();\n } finally {\n (kv as any).set = origSet;\n restoreFetch();\n }\n});\n",[],[150,218],"94fc7554-1d6c-11f1-95a1-42dde27851f2","tickets.cron.ts","94fc763a-1d6c-11f1-95a1-42dde27851f2",22,["D",1773248761838],"/**\n * services/tickets.cron.ts\n *\n * Cron job that deletes closed ticket channels after their 24h grace period.\n * Schedule in Val Town to run every 1-5 minutes.\n */\n\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { type TicketData, KV_PREFIX } from \"../discord/interactions/commands/ticket.ts\";\nimport { discordBotFetch } from \"../discord/discord-api.ts\";\nimport { withTimeout } from \"../discord/helpers/timeout.ts\";\nimport { runCron } from \"../discord/helpers/cron.ts\";\n\nconst ITEM_TIMEOUT_MS = 30_000;\nconst RETRY_DELAY_MS = 60 * 60 * 1000; // 1 hour\n\nexport default async function () {\n let deleted = 0, failed = 0;\n\n await runCron({\n name: \"TicketCron\",\n prefix: KV_PREFIX,\n maxDue: 50,\n async process(entry, logger) {\n const ticket = entry.value as TicketData;\n\n // Only process closed tickets\n if (ticket.status !== \"closed\") return;\n\n const claimed = await kv.claimDelete(entry.key);\n if (!claimed) return;\n\n try {\n const result = await withTimeout(\n discordBotFetch(\"DELETE\", `channels/${ticket.channelId}`),\n ITEM_TIMEOUT_MS,\n );\n\n // Treat 404 as success (channel already deleted)\n if (result.ok || result.status === 404) {\n deleted++;\n } else {\n throw new Error(`HTTP ${result.status}: ${result.error}`);\n }\n } catch (err) {\n failed++;\n logger.error(`Failed to delete ticket channel ${ticket.channelId}:`, err);\n // Re-insert with retry delay\n try {\n await kv.set(entry.key, ticket, Date.now() + RETRY_DELAY_MS);\n } catch (reinsertErr) {\n logger.error(`Failed to re-insert ticket ${entry.key} for retry:`, reinsertErr);\n }\n }\n },\n });\n}\n",[],[150,226],"94e801dc-1d6c-11f1-9ac8-42dde27851f2","scheduled-messages.cron_test.ts","94e80448-1d6c-11f1-9ac8-42dde27851f2",18,["D",1773248761703],"import \"../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, getCalls, restoreFetch } from \"../test/_mocks/fetch.ts\";\nimport type { ScheduledMessage } from \"../discord/interactions/commands/schedule.ts\";\nimport { KV_PREFIX } from \"../discord/interactions/commands/schedule.ts\";\nimport runCron from \"./scheduled-messages.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makeMessage(overrides?: Partial): ScheduledMessage {\n return {\n guildId: \"g1\",\n channelId: \"c1\",\n content: \"hello\",\n sendAt: Date.now() - 1000,\n createdBy: \"u1\",\n createdAt: Date.now() - 60000,\n ...overrides,\n };\n}\n\nDeno.test(\"scheduled-messages cron: successful delivery cleans up KV\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:1`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 403 drops item permanently\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:2`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 403, body: \"Forbidden\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 404 drops item permanently\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:3`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 404, body: \"Not Found\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: transient failure re-inserts with retryCount\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:4`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on transient failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: drops after MAX_RETRIES\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:5`;\n await kv.set(key, makeMessage({ retryCount: 4 }), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: empty list is no-op\", async () => {\n resetStore();\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: malformed entry (missing channelId) is deleted\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:6`;\n await kv.set(\n key,\n { guildId: \"g1\", content: \"hello\", sendAt: Date.now() - 1000, createdBy: \"u1\", createdAt: Date.now() - 60000 },\n Date.now() - 1000,\n );\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 500 error re-inserts with retryCount\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:7`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 500, body: \"Internal Server Error\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 500 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 503 error re-inserts\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:8`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 503, body: \"Service Unavailable\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 503 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: multiple due messages all processed\", async () => {\n resetStore();\n const keys = [`${KV_PREFIX}g1:9`, `${KV_PREFIX}g1:10`, `${KV_PREFIX}g1:11`];\n for (const key of keys) {\n await kv.set(key, makeMessage(), Date.now() - 1000);\n }\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n for (const key of keys) {\n const remaining = await kv.get(key);\n assertEquals(remaining, null, `${key} should be cleaned up`);\n }\n assert(getCalls().length >= 3, `Expected at least 3 fetch calls, got ${getCalls().length}`);\n } finally {\n restoreFetch();\n }\n});\n",[],[150,234],"954055da-1d6c-11f1-a9cb-42dde27851f2",["D",1773248762243],[],[150,32],"94f0ff8a-1d6c-11f1-b767-42dde27851f2","reminders.cron_test.ts","94f10066-1d6c-11f1-b767-42dde27851f2",20,["D",1773248761747],"import \"../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, getCalls, restoreFetch } from \"../test/_mocks/fetch.ts\";\nimport type { Reminder } from \"../discord/interactions/commands/remind.ts\";\nimport runCron from \"./reminders.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makeReminder(overrides?: Partial): Reminder {\n return {\n userId: \"u1\",\n guildId: \"g1\",\n channelId: \"c1\",\n message: \"test\",\n dueAt: Date.now() - 1000,\n createdAt: Date.now() - 60000,\n ...overrides,\n };\n}\n\nDeno.test(\"reminders cron: successful delivery cleans up KV\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:1\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 403 drops item permanently\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:2\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 403, body: \"Forbidden\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 404 drops item permanently\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:3\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 404, body: \"Not Found\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: transient failure re-inserts with retryCount\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:4\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n // After 5xx, discordBotFetch retries internally (2 attempts), then returns error\n // Cron should re-insert with retryCount\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on transient failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: drops after MAX_RETRIES\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:5\";\n await kv.set(key, makeReminder({ retryCount: 4 }), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: empty list is no-op\", async () => {\n resetStore();\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: malformed reminder (missing channelId) is deleted\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:6\";\n await kv.set(\n key,\n { userId: \"u1\", guildId: \"g1\", message: \"test\", dueAt: Date.now() - 1000, createdAt: Date.now() - 60000 },\n Date.now() - 1000,\n );\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 500 error re-inserts with retryCount\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:7\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 500, body: \"Internal Server Error\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 500 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 503 error re-inserts\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:8\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 503, body: \"Service Unavailable\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 503 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: multiple due reminders all processed\", async () => {\n resetStore();\n const keys = [\"reminder:u1:g1:9\", \"reminder:u1:g1:10\", \"reminder:u1:g1:11\"];\n for (const key of keys) {\n await kv.set(key, makeReminder(), Date.now() - 1000);\n }\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n for (const key of keys) {\n const remaining = await kv.get(key);\n assertEquals(remaining, null, `${key} should be cleaned up`);\n }\n assert(getCalls().length >= 3, `Expected at least 3 fetch calls, got ${getCalls().length}`);\n } finally {\n restoreFetch();\n }\n});\n",[],[150,246],"952c3a64-1d6c-11f1-bd27-42dde27851f2","polls.cron_test.ts","952c3b4a-1d6c-11f1-bd27-42dde27851f2",29,["D",1773248762135],"import \"../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, restoreFetch, setNextThrow } from \"../test/_mocks/fetch.ts\";\nimport type { PollConfig } from \"../discord/interactions/commands/poll.ts\";\nimport { MAX_ANNOUNCE_RETRIES } from \"../discord/interactions/commands/poll.ts\";\nimport runCron from \"./polls.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makePoll(overrides?: Partial): PollConfig {\n return {\n question: \"Test?\",\n options: [\"Yes\", \"No\"],\n votes: {},\n channelId: \"c1\",\n messageId: \"m1\",\n createdBy: \"u1\",\n endsAt: Date.now() - 1000,\n ended: false,\n ...overrides,\n };\n}\n\nDeno.test(\"polls cron: ended poll is cleaned up\", async () => {\n resetStore();\n const key = \"poll:g1\";\n await kv.set(key, makePoll({ ended: true }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: active poll gets ended\", async () => {\n resetStore();\n const key = \"poll:g1\";\n await kv.set(key, makePoll({ ended: false }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // endPoll atomically claims and sets ended=true\n const updated = await kv.get(key);\n assertEquals(updated?.ended, true);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: API failure does not delete poll (retried next run)\", async () => {\n resetStore();\n const key = \"poll:g1\";\n await kv.set(key, makePoll({ ended: false }), Date.now() - 1000);\n // All API calls fail — endPoll's claimUpdate succeeds but panel update fails\n // The poll should still be marked ended (claimUpdate is first) but remain in KV\n mockFetch({ default: { status: 500, body: \"Internal Server Error\" } });\n try {\n await runCron();\n const updated = await kv.get(key);\n // claimUpdate transitions ended: false → true before any API calls\n // so even on API failure, the poll state reflects the claim\n assert(updated !== null, \"Poll should still be in KV\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: deletes malformed entries\", async () => {\n resetStore();\n const key = \"poll:g1\";\n // Missing channelId and messageId\n await kv.set(key, { question: \"Bad\", options: [], votes: {}, ended: false, endsAt: 0, createdBy: \"u\" }, Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // Malformed entry is cleaned up\n const remaining = await kv.get(key);\n assert(remaining === null, \"Malformed poll should be deleted\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: timeout error on active poll retries next run\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n const key = \"poll:g_timeout\";\n await kv.set(key, makePoll({ ended: false }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n setNextThrow(new Error(\"Timed out\"));\n try {\n await runCron();\n const remaining = await kv.get(key);\n assert(remaining !== null, \"Poll should still be in KV after timeout\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: announce retry success removes announceFailed flag\", async () => {\n resetStore();\n const key = \"poll:g_retry_ok\";\n await kv.set(key, makePoll({\n ended: true,\n announceFailed: true,\n announceRetries: 0,\n }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const updated = await kv.get(key);\n assert(updated !== null, \"Poll should still exist (scheduled for cleanup)\");\n assertEquals(updated?.announceFailed, undefined, \"announceFailed should be cleared\");\n assertEquals(updated?.announceRetries, undefined, \"announceRetries should be cleared\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: announce retry intermediate uses exponential backoff\", async () => {\n resetStore();\n const key = \"poll:g_backoff\";\n await kv.set(key, makePoll({\n ended: true,\n announceFailed: true,\n announceRetries: 0,\n }), Date.now() - 1000);\n // announcePoll returns false when PATCH fails\n mockFetch({\n responses: [\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n ],\n });\n try {\n await runCron();\n const updated = await kv.get(key);\n assert(updated !== null, \"Poll should still exist\");\n assertEquals(updated?.announceFailed, true, \"announceFailed should remain true\");\n assertEquals(updated?.announceRetries, 1, \"announceRetries should increment to 1\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: MAX_ANNOUNCE_RETRIES exhaustion gives up\", async () => {\n resetStore();\n const key = \"poll:g_maxretry\";\n await kv.set(key, makePoll({\n ended: true,\n announceFailed: true,\n announceRetries: MAX_ANNOUNCE_RETRIES - 1,\n }), Date.now() - 1000);\n // announcePoll returns false (PATCH fails)\n mockFetch({\n responses: [\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n ],\n });\n try {\n await runCron();\n const updated = await kv.get(key);\n assert(updated !== null, \"Poll should exist (saved for cleanup)\");\n assertEquals(updated?.announceFailed, undefined, \"announceFailed should be cleared after giving up\");\n assertEquals(updated?.announceRetries, undefined, \"announceRetries should be cleared after giving up\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: announce retry error increments failed counter\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n const key = \"poll:g_retry_err\";\n await kv.set(key, makePoll({\n ended: true,\n announceFailed: true,\n announceRetries: 0,\n }), Date.now() - 1000);\n mockFetch();\n setNextThrow(new Error(\"Network failure\"));\n try {\n await runCron();\n const remaining = await kv.get(key);\n assert(remaining !== null, \"Poll should still be in KV after announce error\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: empty poll list is no-op\", async () => {\n resetStore();\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // No errors, no exceptions — just a no-op\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: claimDelete returns false skips cleanup\", async () => {\n resetStore();\n const key = \"poll:g_nodupe\";\n await kv.set(key, makePoll({ ended: true }), Date.now() - 1000);\n\n const origClaimDelete = kv.claimDelete.bind(kv);\n (kv as any).claimDelete = async (k: string) => {\n if (k === key) return false;\n return origClaimDelete(k);\n };\n\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // claimDelete returned false — no error\n } finally {\n (kv as any).claimDelete = origClaimDelete;\n restoreFetch();\n }\n});\n\nDeno.test(\"polls cron: partial malformation (channelId but no messageId) deleted\", async () => {\n resetStore();\n const key = \"poll:g_partial\";\n await kv.set(key, {\n question: \"Partial\",\n options: [\"A\", \"B\"],\n votes: {},\n channelId: \"c1\",\n ended: false,\n endsAt: 0,\n createdBy: \"u1\",\n }, Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assert(remaining === null, \"Partially malformed poll should be deleted\");\n } finally {\n restoreFetch();\n }\n});\n",[],[150,254],"953903b6-1d6c-11f1-95a1-42dde27851f2","polls.cron.ts","9539049c-1d6c-11f1-95a1-42dde27851f2",30,["D",1773248762019],"/**\n * services/polls.cron.ts\n *\n * Cron job that checks for expired polls and ends them.\n * Schedule in Val Town to run every 1-5 minutes.\n */\n\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { type PollConfig, endPoll, announcePoll, MAX_ANNOUNCE_RETRIES } from \"../discord/interactions/commands/poll.ts\";\nimport { withTimeout } from \"../discord/helpers/timeout.ts\";\nimport { runCron } from \"../discord/helpers/cron.ts\";\n\nconst ITEM_TIMEOUT_MS = 30_000;\nconst ANNOUNCE_RETRY_DELAY_MS = 15 * 60 * 1000;\nconst CLEANUP_DELAY_MS = 24 * 60 * 60 * 1000;\n\nexport default async function () {\n let ended = 0, cleaned = 0, retried = 0, failed = 0;\n\n await runCron({\n name: \"PollCron\",\n prefix: \"poll:\",\n maxDue: 100,\n async process(entry, logger) {\n const config = entry.value as PollConfig;\n if (!config?.channelId || !config?.messageId) {\n logger.warn(`Deleting malformed poll: ${entry.key}`);\n await kv.claimDelete(entry.key).catch((e) =>\n logger.warn(`Failed to delete malformed entry ${entry.key}: ${e instanceof Error ? e.message : String(e)}`)\n );\n return;\n }\n\n // Ended polls — retry announcement or clean up\n if (config.ended) {\n if (config.announceFailed) {\n const guildId = entry.key.slice(\"poll:\".length);\n const retries = (config.announceRetries ?? 0) + 1;\n try {\n const success = await withTimeout(announcePoll(guildId, config), ITEM_TIMEOUT_MS);\n if (success) {\n const { announceFailed: _, announceRetries: __, ...clean } = config;\n await kv.set(entry.key, clean, Date.now() + CLEANUP_DELAY_MS);\n retried++;\n } else if (retries >= MAX_ANNOUNCE_RETRIES) {\n const { announceFailed: _, announceRetries: __, ...clean } = config;\n await kv.set(entry.key, clean, Date.now() + CLEANUP_DELAY_MS);\n logger.warn(`Giving up on poll announce for ${entry.key} after ${retries} retries`);\n } else {\n await kv.set(\n entry.key,\n { ...config, announceRetries: retries },\n Date.now() + ANNOUNCE_RETRY_DELAY_MS * Math.pow(2, retries - 1),\n );\n }\n } catch (err) {\n failed++;\n logger.error(`Failed to retry poll announce ${entry.key}:`, err);\n }\n return;\n }\n\n // Normal cleanup — delete the KV row\n try {\n const deleted = await kv.claimDelete(entry.key);\n if (deleted) cleaned++;\n } catch (err) {\n failed++;\n logger.error(`Failed to clean up ended poll ${entry.key}:`, err);\n }\n return;\n }\n\n // Active poll whose due_at has arrived — endPoll handles atomicity\n try {\n const guildId = entry.key.slice(\"poll:\".length);\n await withTimeout(endPoll(guildId), ITEM_TIMEOUT_MS);\n ended++;\n } catch (err) {\n failed++;\n const isTimeout = err instanceof Error && err.message === \"Timed out\";\n if (isTimeout) {\n logger.warn(`Timed out ending poll ${entry.key} — will retry next run`);\n } else {\n logger.error(`Failed to end poll ${entry.key}:`, err);\n }\n }\n },\n });\n}\n",[],[150,262],"94f852da-1d6c-11f1-9ac8-42dde27851f2","livestreams.cron_test.ts","94f85398-1d6c-11f1-9ac8-42dde27851f2",21,["D",1773248761810],"import \"../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, getCalls, restoreFetch } from \"../test/_mocks/fetch.ts\";\nimport type { StreamTracker } from \"../discord/interactions/commands/livestream.ts\";\nimport { streamLiveKey } from \"../discord/interactions/commands/livestream.ts\";\nimport runCron from \"./livestreams.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makeTracker(overrides?: Partial): StreamTracker {\n return {\n guildId: \"g1\",\n platform: \"kick\",\n username: \"streamer1\",\n displayName: \"Streamer1\",\n channelId: \"c1\",\n addedBy: \"u1\",\n addedAt: new Date().toISOString(),\n ...overrides,\n };\n}\n\n// --- No trackers ---\n\nDeno.test(\"livestreams cron: no-op when no trackers exist\", async () => {\n resetStore();\n mockFetch();\n try {\n await runCron();\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\n// --- Kick (no API key needed) ---\n\nDeno.test(\"livestreams cron: Kick live stream sends notification\", async () => {\n resetStore();\n const key = \"stream:g1:kick:streamer1\";\n await kv.set(key, makeTracker());\n\n mockFetch({\n responses: [\n // Kick API response — live\n {\n status: 200,\n body: {\n livestream: {\n is_live: true,\n session_title: \"Playing Games\",\n viewer_count: 42,\n thumbnail: { url: \"https://example.com/thumb.jpg\" },\n },\n },\n },\n // Discord message post — success\n { status: 200, body: { id: \"msg1\" } },\n ],\n });\n\n try {\n await runCron();\n\n // Should have called Kick API + Discord API\n const calls = getCalls();\n assertEquals(calls.length, 2);\n assert(calls[0].url.includes(\"kick.com/api/v2/channels/streamer1\"));\n assert(calls[1].url.includes(\"channels/c1/messages\"));\n\n // Live state should be stored\n const liveState = await kv.get(streamLiveKey(\"g1\", \"kick\", \"streamer1\"));\n assert(liveState !== null, \"Should store live state\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: Kick offline clears live state\", async () => {\n resetStore();\n const key = \"stream:g1:kick:streamer1\";\n await kv.set(key, makeTracker());\n\n // Pre-set live state\n const liveKey = streamLiveKey(\"g1\", \"kick\", \"streamer1\");\n await kv.set(liveKey, { title: \"Old Stream\", url: \"https://kick.com/streamer1\", notifiedAt: new Date().toISOString() });\n\n mockFetch({\n responses: [\n // Kick API — offline\n { status: 200, body: { livestream: null } },\n ],\n });\n\n try {\n await runCron();\n const liveState = await kv.get(liveKey);\n assertEquals(liveState, null, \"Live state should be cleared when offline\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: does not re-notify for already-live stream\", async () => {\n resetStore();\n const key = \"stream:g1:kick:streamer1\";\n await kv.set(key, makeTracker());\n\n // Pre-set live state (already notified)\n const liveKey = streamLiveKey(\"g1\", \"kick\", \"streamer1\");\n await kv.set(liveKey, { title: \"Existing\", url: \"https://kick.com/streamer1\", notifiedAt: new Date().toISOString() });\n\n mockFetch({\n responses: [\n // Kick API — still live\n {\n status: 200,\n body: {\n livestream: {\n is_live: true,\n session_title: \"Still Playing\",\n viewer_count: 100,\n },\n },\n },\n ],\n });\n\n try {\n await runCron();\n const calls = getCalls();\n // Should call Kick API but NOT Discord (already notified)\n assertEquals(calls.length, 1);\n assert(calls[0].url.includes(\"kick.com\"));\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: Discord failure cleans up live state\", async () => {\n resetStore();\n const key = \"stream:g1:kick:streamer1\";\n await kv.set(key, makeTracker());\n\n mockFetch({\n responses: [\n // Kick API — live\n {\n status: 200,\n body: {\n livestream: {\n is_live: true,\n session_title: \"Stream\",\n viewer_count: 10,\n },\n },\n },\n // Discord post fails (discordBotFetch retries internally, mock returns same for all)\n { status: 500, body: \"Internal Server Error\" },\n { status: 500, body: \"Internal Server Error\" },\n { status: 500, body: \"Internal Server Error\" },\n ],\n });\n\n try {\n await runCron();\n // Live state should be cleaned up on notification failure\n const liveKey = streamLiveKey(\"g1\", \"kick\", \"streamer1\");\n const liveState = await kv.get(liveKey);\n assertEquals(liveState, null, \"Live state should be cleaned up on Discord failure\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: skips trackers with missing fields\", async () => {\n resetStore();\n // Invalid tracker — missing channelId\n await kv.set(\"stream:g1:kick:bad\", { guildId: \"g1\", platform: \"kick\", username: \"bad\" });\n\n mockFetch();\n try {\n await runCron();\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: cooldown prevents re-notification after offline/online cycle\", async () => {\n resetStore();\n const key = \"stream:g1:kick:streamer1\";\n await kv.set(key, makeTracker());\n\n // Set a recent cooldown (just went offline)\n const cooldownKey = \"stream_cooldown:g1:kick:streamer1\";\n await kv.set(cooldownKey, { clearedAt: Date.now() }, Date.now() + 5 * 60 * 1000);\n\n mockFetch({\n responses: [\n // Kick API — live again\n {\n status: 200,\n body: {\n livestream: {\n is_live: true,\n session_title: \"Back!\",\n viewer_count: 5,\n },\n },\n },\n ],\n });\n\n try {\n await runCron();\n const calls = getCalls();\n // Should call Kick API but NOT Discord (cooldown active)\n assertEquals(calls.length, 1);\n assert(calls[0].url.includes(\"kick.com\"));\n } finally {\n restoreFetch();\n }\n});\n\n// --- Twitch (requires env vars) ---\n\nDeno.test(\"livestreams cron: Twitch batch check sends notification\", async () => {\n resetStore();\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_twitch_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_twitch_secret\");\n\n const key = \"stream:g1:twitch:twitchuser\";\n await kv.set(key, makeTracker({ platform: \"twitch\", username: \"twitchuser\", displayName: \"TwitchUser\" }));\n\n mockFetch({\n responses: [\n // Twitch token request\n { status: 200, body: { access_token: \"tok123\", expires_in: 3600 } },\n // Twitch streams API — live\n {\n status: 200,\n body: {\n data: [\n {\n user_login: \"twitchuser\",\n title: \"Twitch Stream!\",\n viewer_count: 200,\n thumbnail_url: \"https://example.com/{width}x{height}.jpg\",\n },\n ],\n },\n },\n // Discord message post\n { status: 200, body: { id: \"msg2\" } },\n ],\n });\n\n try {\n await runCron();\n const calls = getCalls();\n assert(calls.length >= 2, \"Should call Twitch API and Discord\");\n assert(calls.some((c) => c.url.includes(\"twitch.tv\")), \"Should call Twitch API\");\n assert(calls.some((c) => c.url.includes(\"channels/c1/messages\")), \"Should post to Discord\");\n\n const liveState = await kv.get(streamLiveKey(\"g1\", \"twitch\", \"twitchuser\"));\n assert(liveState !== null, \"Should store live state\");\n } finally {\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: Twitch skipped when credentials missing\", async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n\n const key = \"stream:g1:twitch:twitchuser\";\n await kv.set(key, makeTracker({ platform: \"twitch\", username: \"twitchuser\" }));\n\n mockFetch();\n try {\n await runCron();\n assertEquals(getCalls().length, 0, \"Should not call any API when Twitch creds missing\");\n } finally {\n restoreFetch();\n }\n});\n\n// --- YouTube (requires env var) ---\n\nDeno.test(\"livestreams cron: YouTube live sends notification\", async () => {\n resetStore();\n Deno.env.set(\"YOUTUBE_API_KEY\", \"test_yt_key\");\n\n const key = \"stream:g1:youtube:UCxyz\";\n await kv.set(key, makeTracker({ platform: \"youtube\", username: \"UCxyz\", displayName: \"YouTuber\" }));\n\n mockFetch({\n responses: [\n // YouTube API — live\n {\n status: 200,\n body: {\n items: [\n {\n id: { videoId: \"vid123\" },\n snippet: {\n title: \"YouTube Live!\",\n thumbnails: { high: { url: \"https://example.com/yt-thumb.jpg\" } },\n },\n },\n ],\n },\n },\n // Discord message post\n { status: 200, body: { id: \"msg3\" } },\n ],\n });\n\n try {\n await runCron();\n const calls = getCalls();\n assert(calls.some((c) => c.url.includes(\"googleapis.com\")), \"Should call YouTube API\");\n assert(calls.some((c) => c.url.includes(\"channels/c1/messages\")), \"Should post to Discord\");\n } finally {\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: YouTube skipped when API key missing\", async () => {\n resetStore();\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n const key = \"stream:g1:youtube:UCxyz\";\n await kv.set(key, makeTracker({ platform: \"youtube\", username: \"UCxyz\" }));\n\n mockFetch();\n try {\n await runCron();\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\n// --- Multiple platforms ---\n\nDeno.test(\"livestreams cron: processes multiple platforms in one run\", async () => {\n resetStore();\n\n // Only Kick (no twitch/youtube creds)\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:kick:streamer1\", makeTracker({ username: \"streamer1\" }));\n await kv.set(\"stream:g1:kick:streamer2\", makeTracker({ username: \"streamer2\", displayName: \"Streamer2\", channelId: \"c2\" }));\n\n mockFetch({\n responses: [\n // Kick API — streamer1 live\n {\n status: 200,\n body: {\n livestream: { is_live: true, session_title: \"S1 Live\", viewer_count: 10 },\n },\n },\n // Kick API — streamer2 offline\n { status: 200, body: { livestream: null } },\n // Discord notification for streamer1\n { status: 200, body: { id: \"msg4\" } },\n ],\n });\n\n try {\n await runCron();\n const calls = getCalls();\n // 2 Kick API calls + 1 Discord notification\n // Order may vary due to parallelMap, but we should have exactly 3 calls\n assertEquals(calls.length, 3);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: CAS update failure on live state returns noop\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n const key = \"stream:g1:kick:streamer_cas\";\n await kv.set(key, makeTracker({ username: \"streamer_cas\" }));\n\n // Monkey-patch kv.update to throw a CAS error when setting live state\n const origUpdate = kv.update.bind(kv);\n (kv as any).update = async (...args: unknown[]) => {\n const k = args[0] as string;\n if (k.startsWith(\"stream_live:\")) {\n throw new Error(\"CAS exhaustion\");\n }\n return origUpdate(...(args as Parameters));\n };\n\n mockFetch({\n responses: [\n // Kick API — live\n {\n status: 200,\n body: {\n livestream: { is_live: true, session_title: \"CAS Test\", viewer_count: 5 },\n },\n },\n ],\n });\n\n try {\n await runCron();\n // Should not crash; no Discord notification sent\n const calls = getCalls();\n const discordCalls = calls.filter((c) => c.url.includes(\"channels/c1/messages\"));\n assertEquals(discordCalls.length, 0, \"No Discord notification on CAS failure\");\n } finally {\n (kv as any).update = origUpdate;\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: Twitch token fetch failure (non-200)\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_twitch_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_twitch_secret\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:twitch:twitchfail\", makeTracker({ platform: \"twitch\", username: \"twitchfail\" }));\n\n mockFetch({\n responses: [\n // Twitch token request fails\n { status: 401, body: { message: \"Invalid client\" } },\n ],\n });\n\n try {\n await runCron();\n // Should not crash — Twitch batch check catches the error\n } finally {\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: YouTube API error returns noop\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n Deno.env.set(\"YOUTUBE_API_KEY\", \"test_yt_key\");\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n\n await kv.set(\"stream:g1:youtube:UCfail\", makeTracker({ platform: \"youtube\", username: \"UCfail\" }));\n\n mockFetch({\n responses: [\n // YouTube API returns 500\n { status: 500, body: \"Internal Server Error\" },\n ],\n });\n\n try {\n await runCron();\n // Should not crash\n } finally {\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: Kick API 404 treats as offline\", async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:kick:streamer404\", makeTracker({ username: \"streamer404\" }));\n\n mockFetch({\n responses: [\n // Kick API returns 404\n { status: 404, body: { message: \"Not Found\" } },\n ],\n });\n\n try {\n await runCron();\n // 404 is treated as offline — no Discord notification\n const calls = getCalls();\n const discordCalls = calls.filter((c) => c.url.includes(\"channels/c1/messages\"));\n assertEquals(discordCalls.length, 0, \"No Discord notification for 404\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: Kick non-200 non-404 logs error\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:kick:streamer500\", makeTracker({ username: \"streamer500\" }));\n\n mockFetch({\n responses: [\n // Kick API returns 500\n { status: 500, body: \"Server Error\" },\n ],\n });\n\n try {\n await runCron();\n // Should not crash — error is caught by parallelMap\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: KV.delete failure on notification rollback logs error\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:kick:streamer_rollback\", makeTracker({ username: \"streamer_rollback\" }));\n\n // Monkey-patch kv.delete to throw for live state cleanup\n const origDelete = kv.delete.bind(kv);\n (kv as any).delete = async (k: string) => {\n if (k.startsWith(\"stream_live:\")) {\n throw new Error(\"Delete failed\");\n }\n return origDelete(k);\n };\n\n mockFetch({\n responses: [\n // Kick API — live\n {\n status: 200,\n body: {\n livestream: { is_live: true, session_title: \"Rollback Test\", viewer_count: 5 },\n },\n },\n // Discord notification fails\n { status: 500, body: \"Internal Server Error\" },\n { status: 500, body: \"Internal Server Error\" },\n { status: 500, body: \"Internal Server Error\" },\n ],\n });\n\n try {\n await runCron();\n // Should not crash even though both Discord notification and live state cleanup fail\n } finally {\n (kv as any).delete = origDelete;\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: mixed platform - one fails, others succeed\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:kick:fail_streamer\", makeTracker({ username: \"fail_streamer\", channelId: \"c_fail\" }));\n await kv.set(\"stream:g1:kick:ok_streamer\", makeTracker({ username: \"ok_streamer\", channelId: \"c_ok\" }));\n\n mockFetch({\n responses: [\n // Kick API — fail_streamer 500\n { status: 500, body: \"Server Error\" },\n // Kick API — ok_streamer live\n {\n status: 200,\n body: {\n livestream: { is_live: true, session_title: \"OK Stream\", viewer_count: 10 },\n },\n },\n // Discord notification for ok_streamer\n { status: 200, body: { id: \"msg_ok\" } },\n ],\n });\n\n try {\n await runCron();\n // One fails, one succeeds — cron should not crash\n const liveState = await kv.get(streamLiveKey(\"g1\", \"kick\", \"ok_streamer\"));\n assert(liveState !== null, \"Successful streamer should have live state\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: two Twitch trackers both get checked\", async () => {\n resetStore();\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_twitch_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_twitch_secret\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:twitch:user1\", makeTracker({ platform: \"twitch\", username: \"user1\", channelId: \"c1\" }));\n await kv.set(\"stream:g1:twitch:user2\", makeTracker({ platform: \"twitch\", username: \"user2\", channelId: \"c2\" }));\n\n // Use a URL-matching mock approach: token may be cached from prior test.\n // Use default for Discord notifications. The responses list covers all possible calls in order:\n // If token cached: [streams API, Discord msg1, Discord msg2]\n // If token not cached: [token, streams API, Discord msg1, Discord msg2]\n // Either way, we use a smart default that works for Discord calls.\n const origFetch = globalThis.fetch;\n mockFetch();\n const twitchStreamsResponse = {\n data: [\n { user_login: \"user1\", title: \"Stream 1\", viewer_count: 50, thumbnail_url: \"\" },\n { user_login: \"user2\", title: \"Stream 2\", viewer_count: 30, thumbnail_url: \"\" },\n ],\n };\n // Override fetch to return context-appropriate responses\n globalThis.fetch = (async (input: string | URL | Request, init?: RequestInit) => {\n const url = typeof input === \"string\" ? input : input instanceof URL ? input.toString() : input.url;\n getCalls().push({ url, init });\n if (url.includes(\"twitch.tv/oauth2/token\")) {\n return new Response(JSON.stringify({ access_token: \"tok_batch\", expires_in: 3600 }), { status: 200 });\n }\n if (url.includes(\"twitch.tv/helix/streams\")) {\n return new Response(JSON.stringify(twitchStreamsResponse), { status: 200 });\n }\n // Discord API\n return new Response(JSON.stringify({ id: \"msg_twitch\" }), { status: 200 });\n }) as typeof globalThis.fetch;\n\n try {\n await runCron();\n const live1 = await kv.get(streamLiveKey(\"g1\", \"twitch\", \"user1\"));\n const live2 = await kv.get(streamLiveKey(\"g1\", \"twitch\", \"user2\"));\n assert(live1 !== null, \"user1 should have live state\");\n assert(live2 !== null, \"user2 should have live state\");\n } finally {\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n globalThis.fetch = origFetch;\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: multiple guilds tracking same streamer both notified\", async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n await kv.set(\"stream:g1:kick:shared_streamer\", makeTracker({ guildId: \"g1\", username: \"shared_streamer\", channelId: \"c1\" }));\n await kv.set(\"stream:g2:kick:shared_streamer\", makeTracker({ guildId: \"g2\", username: \"shared_streamer\", channelId: \"c2\" }));\n\n mockFetch({\n responses: [\n // Kick API for g1's check\n {\n status: 200,\n body: {\n livestream: { is_live: true, session_title: \"Shared Stream\", viewer_count: 100 },\n },\n },\n // Kick API for g2's check\n {\n status: 200,\n body: {\n livestream: { is_live: true, session_title: \"Shared Stream\", viewer_count: 100 },\n },\n },\n // Discord notification for g1\n { status: 200, body: { id: \"msg_g1\" } },\n // Discord notification for g2\n { status: 200, body: { id: \"msg_g2\" } },\n ],\n });\n\n try {\n await runCron();\n const live1 = await kv.get(streamLiveKey(\"g1\", \"kick\", \"shared_streamer\"));\n const live2 = await kv.get(streamLiveKey(\"g2\", \"kick\", \"shared_streamer\"));\n assert(live1 !== null, \"Guild 1 should have live state\");\n assert(live2 !== null, \"Guild 2 should have live state\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: notification failure cleans up live state key\", async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n const key = \"stream:g1:kick:streamer_cleanup\";\n await kv.set(key, makeTracker({ username: \"streamer_cleanup\" }));\n\n mockFetch({\n responses: [\n // Kick API — live\n {\n status: 200,\n body: {\n livestream: { is_live: true, session_title: \"Cleanup Test\", viewer_count: 10 },\n },\n },\n // Discord notification fails\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n ],\n });\n\n try {\n await runCron();\n // Live state should be cleaned up on notification failure\n const liveKey = streamLiveKey(\"g1\", \"kick\", \"streamer_cleanup\");\n const liveState = await kv.get(liveKey);\n assertEquals(liveState, null, \"Live state key should be deleted after notification failure\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"livestreams cron: offline cycle sets cooldown key\", async () => {\n resetStore();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n\n const key = \"stream:g1:kick:streamer_cooldown\";\n await kv.set(key, makeTracker({ username: \"streamer_cooldown\" }));\n\n // Pre-set live state (was previously live)\n const liveKey = streamLiveKey(\"g1\", \"kick\", \"streamer_cooldown\");\n await kv.set(liveKey, { title: \"Was Live\", url: \"https://kick.com/streamer_cooldown\", notifiedAt: new Date().toISOString() });\n\n mockFetch({\n responses: [\n // Kick API — now offline\n { status: 200, body: { livestream: null } },\n ],\n });\n\n try {\n await runCron();\n // Live state should be cleared\n const liveState = await kv.get(liveKey);\n assertEquals(liveState, null, \"Live state should be cleared when offline\");\n\n // Cooldown key should be set\n const cooldownKey = \"stream_cooldown:g1:kick:streamer_cooldown\";\n const cooldown = await kv.get(cooldownKey);\n assert(cooldown !== null, \"Cooldown key should be set after going offline\");\n } finally {\n restoreFetch();\n }\n});\n",[],[150,270],"9508cb74-1d6c-11f1-95a1-42dde27851f2","livestreams.cron.ts","9508cc6e-1d6c-11f1-95a1-42dde27851f2",24,["D",1773248761919],"/**\n * services/livestreams.cron.ts\n *\n * Cron job that polls streaming platforms and posts Discord embeds\n * when tracked streamers go live. Schedule in Val Town to run every 2-5 minutes.\n *\n * Algorithm:\n * 1. Load all stream trackers from KV\n * 2. Group by platform, check each (Twitch batched, YouTube/Kick parallel)\n * 3. Compare against stored live state — post notification on new live, clear on offline\n */\n\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport {\n type StreamTracker,\n streamLiveKey,\n} from \"../discord/interactions/commands/livestream.ts\";\nimport {\n type Platform,\n type StreamStatus,\n checkTwitchStreams,\n checkYouTubeStream,\n checkKickStream,\n} from \"../discord/services/stream-platforms.ts\";\nimport { discordBotFetch } from \"../discord/discord-api.ts\";\nimport { createLogger, finalizeAllLoggers } from \"../discord/webhook/logger.ts\";\nimport { CONFIG } from \"../discord/constants.ts\";\n\nconst logger = createLogger(\"LivestreamCron\");\n\nconst MAX_TRACKERS_PER_RUN = 200;\nconst CONCURRENCY = 5;\n\ninterface StreamLiveState {\n title: string;\n url: string;\n notifiedAt: string;\n}\n\nconst PLATFORM_COLORS: Record = {\n twitch: 0x9146ff,\n youtube: 0xff0000,\n kick: 0x53fc18,\n};\n\nconst PLATFORM_LABELS: Record = {\n twitch: \"Twitch\",\n youtube: \"YouTube\",\n kick: \"Kick\",\n};\n\n/** Run up to `limit` async tasks at a time. */\nasync function parallelMap(\n items: T[],\n fn: (item: T) => Promise,\n limit: number,\n): Promise[]> {\n const results: PromiseSettledResult[] = [];\n let index = 0;\n\n async function worker() {\n while (index < items.length) {\n const i = index++;\n try {\n const value = await fn(items[i]);\n results[i] = { status: \"fulfilled\", value };\n } catch (reason) {\n results[i] = { status: \"rejected\", reason };\n }\n }\n }\n\n const workers = Array.from({ length: Math.min(limit, items.length) }, () => worker());\n await Promise.all(workers);\n return results;\n}\n\nconst COOLDOWN_MS = 5 * 60 * 1000; // 5-minute renotification cooldown\n\nasync function processTracker(\n tracker: StreamTracker,\n status: StreamStatus,\n): Promise<\"notified\" | \"cleared\" | \"noop\"> {\n const liveKey = streamLiveKey(tracker.guildId, tracker.platform, tracker.username);\n const cooldownKey = `stream_cooldown:${tracker.guildId}:${tracker.platform}:${tracker.username.toLowerCase()}`;\n\n if (status.isLive) {\n // Attempt atomic claim: only write if no live state exists yet\n let wonClaim = false;\n const liveState: StreamLiveState = {\n title: status.title || \"\",\n url: status.streamUrl,\n notifiedAt: new Date().toISOString(),\n };\n try {\n await kv.update(liveKey, (current) => {\n if (current) return current; // already live — no-op\n wonClaim = true;\n return liveState;\n });\n } catch {\n // CAS exhaustion — another cron instance is racing; skip this cycle\n return \"noop\";\n }\n\n if (!wonClaim) return \"noop\"; // already had live state\n\n // Check renotification cooldown\n const cooldown = await kv.get<{ clearedAt: number }>(cooldownKey);\n if (cooldown && Date.now() - cooldown.clearedAt < COOLDOWN_MS) {\n return \"noop\"; // within cooldown window — skip notification\n }\n\n // Post notification\n const embed = {\n author: {\n name: `${tracker.displayName} is now live!`,\n url: status.streamUrl,\n },\n title: status.title || \"Live Stream\",\n url: status.streamUrl,\n color: PLATFORM_COLORS[tracker.platform],\n footer: { text: PLATFORM_LABELS[tracker.platform] },\n timestamp: new Date().toISOString(),\n ...(status.thumbnailUrl ? { image: { url: status.thumbnailUrl } } : {}),\n };\n\n const result = await discordBotFetch(\"POST\", `channels/${tracker.channelId}/messages`, {\n embeds: [embed],\n });\n\n if (!result.ok) {\n logger.error(`Failed to notify ${tracker.displayName} (${tracker.platform}) in guild ${tracker.guildId}: ${result.error}`);\n // Clean up the live state we just wrote since notification failed\n try {\n await kv.delete(liveKey);\n } catch (deleteErr) {\n logger.error(`Failed to clean up live state ${liveKey}:`, deleteErr);\n }\n return \"noop\";\n }\n\n return \"notified\";\n } else {\n // Offline — clear live state if it existed\n const claimed = await kv.claimDelete(liveKey);\n if (claimed) {\n // Set cooldown so rapid online/offline cycles don't spam\n await kv.set(cooldownKey, { clearedAt: Date.now() }, Date.now() + COOLDOWN_MS);\n return \"cleared\";\n }\n return \"noop\";\n }\n}\n\nexport default async function () {\n try {\n const entries = await kv.list(\"stream:\", MAX_TRACKERS_PER_RUN);\n if (entries.length === 0) return;\n\n // Group trackers by platform\n const byPlatform: Record = {\n twitch: [],\n youtube: [],\n kick: [],\n };\n\n for (const entry of entries) {\n const tracker = entry.value as StreamTracker;\n if (!tracker?.platform || !tracker?.username || !tracker?.channelId) continue;\n if (byPlatform[tracker.platform]) {\n byPlatform[tracker.platform].push(tracker);\n }\n }\n\n let notified = 0;\n let cleared = 0;\n let errors = 0;\n\n // --- Twitch (batched) ---\n if (byPlatform.twitch.length > 0 && CONFIG.twitchClientId && CONFIG.twitchClientSecret) {\n try {\n const usernames = byPlatform.twitch.map((t) => t.username);\n const statuses = await checkTwitchStreams(usernames);\n\n const results = await parallelMap(\n byPlatform.twitch,\n async (tracker) => {\n const status = statuses.get(tracker.username.toLowerCase());\n if (!status) return \"noop\" as const;\n return await processTracker(tracker, status);\n },\n CONCURRENCY,\n );\n for (const r of results) {\n if (r.status === \"fulfilled\") {\n if (r.value === \"notified\") notified++;\n else if (r.value === \"cleared\") cleared++;\n } else {\n errors++;\n logger.error(\"Twitch check failed:\", r.reason);\n }\n }\n } catch (err) {\n errors++;\n logger.error(\"Twitch batch check failed:\", err);\n }\n }\n\n // --- YouTube (per-channel, parallel) ---\n if (byPlatform.youtube.length > 0 && CONFIG.youtubeApiKey) {\n const results = await parallelMap(\n byPlatform.youtube,\n async (tracker) => {\n const status = await checkYouTubeStream(tracker.username);\n return await processTracker(tracker, status);\n },\n CONCURRENCY,\n );\n for (const r of results) {\n if (r.status === \"fulfilled\") {\n if (r.value === \"notified\") notified++;\n else if (r.value === \"cleared\") cleared++;\n } else {\n errors++;\n logger.error(\"YouTube check failed:\", r.reason);\n }\n }\n }\n\n // --- Kick (per-user, parallel) ---\n if (byPlatform.kick.length > 0) {\n const results = await parallelMap(\n byPlatform.kick,\n async (tracker) => {\n const status = await checkKickStream(tracker.username);\n return await processTracker(tracker, status);\n },\n CONCURRENCY,\n );\n for (const r of results) {\n if (r.status === \"fulfilled\") {\n if (r.value === \"notified\") notified++;\n else if (r.value === \"cleared\") cleared++;\n } else {\n errors++;\n logger.error(\"Kick check failed:\", r.reason);\n }\n }\n }\n\n const total = byPlatform.twitch.length + byPlatform.youtube.length + byPlatform.kick.length;\n logger.info(\n `Run complete: ${total} tracker(s) — ${notified} notified, ${cleared} cleared, ${errors} error(s)`,\n );\n } finally {\n await finalizeAllLoggers();\n }\n}\n",[],[150,278],"95048b54-1d6c-11f1-b767-42dde27851f2","interactions.http_test.ts","95048c26-1d6c-11f1-b767-42dde27851f2",23,["D",1773248761887],"http","import \"../test/_mocks/env.ts\";\nimport \"../test/_mocks/sqlite.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { mockFetch, getCalls, restoreFetch } from \"../test/_mocks/fetch.ts\";\nimport { signedRequest } from \"../test/_mocks/sign.ts\";\nimport handler from \"./interactions.http.ts\";\n\n// --- GET routes ---\n\nDeno.test(\"http: GET /terms returns HTML page\", async () => {\n const req = new Request(\"https://example.com/terms\");\n const res = await handler(req);\n assertEquals(res.status, 200);\n const text = await res.text();\n assert(text.includes(\"Terms\") || text.includes(\"html\"));\n});\n\nDeno.test(\"http: GET /privacy returns HTML page\", async () => {\n const req = new Request(\"https://example.com/privacy\");\n const res = await handler(req);\n assertEquals(res.status, 200);\n const text = await res.text();\n assert(text.includes(\"Privacy\") || text.includes(\"html\"));\n});\n\nDeno.test(\"http: GET /invite without auth returns 401\", async () => {\n const req = new Request(\"https://example.com/invite\");\n const res = await handler(req);\n assertEquals(res.status, 401);\n});\n\nDeno.test(\"http: GET /invite with wrong token returns 401\", async () => {\n const req = new Request(\"https://example.com/invite\", {\n headers: { Authorization: \"Bearer wrong_password\" },\n });\n const res = await handler(req);\n assertEquals(res.status, 401);\n});\n\n// --- Admin endpoints ---\n\nDeno.test(\"http: GET ?register=true without auth returns 401\", async () => {\n const req = new Request(\"https://example.com/?register=true\");\n const res = await handler(req);\n assertEquals(res.status, 401);\n});\n\nDeno.test(\"http: GET ?discover=true without auth returns 401\", async () => {\n const req = new Request(\"https://example.com/?discover=true\");\n const res = await handler(req);\n assertEquals(res.status, 401);\n});\n\nDeno.test(\"http: GET ?register-metadata=true without auth returns 401\", async () => {\n const req = new Request(\"https://example.com/?register-metadata=true\");\n const res = await handler(req);\n assertEquals(res.status, 401);\n});\n\n// --- Health check ---\n\nDeno.test(\"http: GET root returns health check JSON\", async () => {\n const req = new Request(\"https://example.com/\");\n const res = await handler(req);\n assertEquals(res.status, 200);\n const body = await res.json();\n assertEquals(body.status, \"ok\");\n assertEquals(body.commands, undefined);\n});\n\n// --- Trailing slash normalization ---\n\nDeno.test(\"http: GET /terms/ (trailing slash) still works\", async () => {\n const req = new Request(\"https://example.com/terms/\");\n const res = await handler(req);\n assertEquals(res.status, 200);\n});\n\nDeno.test(\"http: GET /privacy/ (trailing slash) still works\", async () => {\n const req = new Request(\"https://example.com/privacy/\");\n const res = await handler(req);\n assertEquals(res.status, 200);\n});\n\n// --- POST routing ---\n\nDeno.test(\"http: POST without signature returns 401\", async () => {\n const req = new Request(\"https://example.com/\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ type: 1 }),\n });\n const res = await handler(req);\n // Should fail signature verification\n assertEquals(res.status, 401);\n});\n\nDeno.test(\"http: POST /patreon/webhook routes to patreon handler (not 404)\", async () => {\n // The patreon webhook handler uses MD5-HMAC which may not be supported\n // in all Deno versions. This test verifies routing works (not 404).\n const req = new Request(\"https://example.com/patreon/webhook\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Patreon-Event\": \"members:create\",\n },\n body: JSON.stringify({ data: {} }),\n });\n const res = await handler(req);\n // Without signature header, should return 401 or 503 (missing config), not 404\n assert(res.status === 401 || res.status === 503 || res.status === 429);\n});\n\nDeno.test(\"http: GET /invite with correct auth returns HTML\", async () => {\n const req = new Request(\"https://example.com/invite\", {\n headers: { Authorization: \"Bearer test_admin_password\" },\n });\n const res = await handler(req);\n assertEquals(res.status, 200);\n const text = await res.text();\n assert(text.includes(\"html\") || text.includes(\"invite\") || text.includes(\"Invite\"), \"Should return HTML invite page\");\n});\n\nDeno.test(\"http: GET ?register=true with correct auth returns JSON\", async () => {\n const req = new Request(\"https://example.com/?register=true\", {\n headers: { Authorization: \"Bearer test_admin_password\" },\n });\n mockFetch({ default: { status: 200, body: { id: \"1\" } } });\n try {\n const res = await handler(req);\n const body = await res.json();\n // syncAllGuilds returns an array of results\n assert(res.status === 200, \"Should return 200 on success\");\n assert(\"registered\" in body || \"results\" in body, \"Should contain registration results\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"http: GET ?register=true error returns 500\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n const req = new Request(\"https://example.com/?register=true\", {\n headers: { Authorization: \"Bearer test_admin_password\" },\n });\n // Mock fetch to throw so syncAllGuilds fails\n mockFetch();\n // Make all fetches fail to trigger the catch block\n mockFetch({ default: { status: 200, body: null } });\n // Actually we need syncAllGuilds to throw. The simplest way is to not mock fetch at all\n // and let it fail, but we need mockFetch for cleanup. Let's use setNextThrow approach:\n // syncAllGuilds will try to fetch guilds list first.\n restoreFetch();\n mockFetch({ default: { status: 500, body: \"fail\" } });\n try {\n const res = await handler(req);\n // syncAllGuilds may fail or return error results\n // If it throws, we get 500; if it returns failed results, we get 200 with failed count\n assert(res.status === 200 || res.status === 500, \"Should return 200 or 500\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"http: GET ?register-metadata=true with correct auth returns JSON\", async () => {\n const req = new Request(\"https://example.com/?register-metadata=true\", {\n headers: { Authorization: \"Bearer test_admin_password\" },\n });\n mockFetch({ default: { status: 200, body: {} } });\n try {\n const res = await handler(req);\n // registerMetadataSchema returns { ok: true/false }\n const body = await res.json();\n assert(res.status === 200 || res.status === 500, \"Should return 200 or 500\");\n assert(\"ok\" in body || \"error\" in body, \"Should contain ok or error field\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"http: GET ?register-metadata=true error returns 500\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n const req = new Request(\"https://example.com/?register-metadata=true\", {\n headers: { Authorization: \"Bearer test_admin_password\" },\n });\n mockFetch({ default: { status: 500, body: \"fail\" } });\n try {\n const res = await handler(req);\n const body = await res.json();\n // registerMetadataSchema may return {ok:false} or the handler may catch and return 500\n assert(res.status === 200 || res.status === 500, \"Should return result or error\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"http: GET ?discover=true with correct auth returns JSON\", async () => {\n const req = new Request(\"https://example.com/?discover=true\", {\n headers: { Authorization: \"Bearer test_admin_password\" },\n });\n mockFetch({ default: { status: 200, body: {} } });\n try {\n const res = await handler(req);\n const body = await res.json();\n // discover() either succeeds with manifest or handler catches error and returns 500\n assert(res.status === 200 || res.status === 500, \"Should return result or error\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"http: GET ?discover=true error returns 500\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n const req = new Request(\"https://example.com/?discover=true\", {\n headers: { Authorization: \"Bearer test_admin_password\" },\n });\n // Don't mock fetch so discover might fail with network errors\n mockFetch();\n // Restore and immediately mock with failing responses\n restoreFetch();\n mockFetch({ default: { status: 500, body: \"fail\" } });\n try {\n const res = await handler(req);\n // If discover throws, returns 500; if it handles gracefully, may return 200\n assert(res.status === 200 || res.status === 500, \"Should return result or error\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"http: GET / returns JSON with status field\", async () => {\n const req = new Request(\"https://example.com/\");\n const res = await handler(req);\n assertEquals(res.status, 200);\n const body = await res.json();\n assert(\"status\" in body, \"Health check should contain status field\");\n assert(body.status === \"ok\" || body.status === \"degraded\", \"Status should be ok or degraded\");\n});\n\nDeno.test(\"http: unknown GET path falls through to health check\", async () => {\n const req = new Request(\"https://example.com/unknown-path\");\n const res = await handler(req);\n // Unknown paths fall through to the health check at the end of GET handling\n assertEquals(res.status, 200);\n const body = await res.json();\n assert(\"status\" in body, \"Should return health check JSON for unknown paths\");\n});\n\nDeno.test(\"http: POST interaction with valid signature routes correctly\", async () => {\n // Type 1 = PING, which should get PONG response (type 1)\n const body = JSON.stringify({ type: 1 });\n const req = await signedRequest(body);\n const res = await handler(req);\n assertEquals(res.status, 200);\n const data = await res.json();\n assertEquals(data.type, 1, \"PING should receive PONG response\");\n});\n",[],[150,286],"94eda22c-1d6c-11f1-9ac8-42dde27851f2","interactions.http.ts","94eda2f4-1d6c-11f1-9ac8-42dde27851f2",19,["D",1773248761741],"/**\n * services/interactions.http.ts\n *\n * Discord interactions HTTP endpoint.\n *\n * GET paths:\n * /terms — Terms of Service page\n * /privacy — Privacy Policy page\n * /invite — Auth-gated invite page (Bearer token required)\n * /linked-roles — Linked Roles OAuth2 redirect\n * /linked-roles/callback — Linked Roles OAuth2 callback\n *\n * GET params (root):\n * ?discover=true — scan project files, save manifest to KV\n * ?register=true — bulk-register all commands with Discord\n * ?register-metadata=true — push linked roles metadata schema to Discord\n * (none) — health check (status, command count, interaction count)\n *\n * POST paths:\n * /patreon/webhook — Patreon webhook handler (signature-verified)\n * (default) — Discord interaction handler (signature-verified)\n */\n\nimport { handleInteraction } from \"../discord/interactions/handler.ts\";\nimport { getFailedImports } from \"../discord/interactions/registry.ts\";\nimport { syncAllGuilds } from \"../discord/interactions/registration.ts\";\nimport { discover } from \"../discord/interactions/auto-discover.ts\";\nimport { CONFIG } from \"../discord/constants.ts\";\nimport { termsPage, privacyPage, invitePage } from \"../discord/pages.ts\";\nimport { handleLinkedRolesRedirect, handleLinkedRolesCallback } from \"../discord/linked-roles/routes.ts\";\nimport { registerMetadataSchema } from \"../discord/linked-roles/register-metadata.ts\";\nimport { handlePatreonWebhook } from \"../discord/linked-roles/patreon-webhook.ts\";\nimport { timingSafeEqual } from \"../discord/helpers/crypto.ts\";\nimport { createLogger, finalizeAllLoggers } from \"../discord/webhook/logger.ts\";\nimport \"../discord/linked-roles/verifiers/always-verified.ts\"; // side-effect: registers verifier\n\nconst logger = createLogger(\"HTTP\");\n\nasync function checkPassword(req: Request): Promise {\n const password = CONFIG.adminPassword;\n if (!password) {\n return Response.json({ error: \"Forbidden: admin password not configured\" }, { status: 403 });\n }\n const header = req.headers.get(\"Authorization\");\n const token = header?.startsWith(\"Bearer \") ? header.slice(7) : null;\n if (!token || !(await timingSafeEqual(token, password))) {\n return Response.json({ error: \"Unauthorized\" }, { status: 401 });\n }\n return null;\n}\n\nexport default async function(req: Request): Promise {\n try {\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\"); // strip trailing slashes\n\n if (path === \"/terms\") return termsPage();\n if (path === \"/privacy\") return privacyPage();\n if (path === \"/invite\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n return invitePage(CONFIG.appId);\n }\n if (path === \"/linked-roles\") return handleLinkedRolesRedirect(req);\n if (path === \"/linked-roles/callback\") return handleLinkedRolesCallback(req);\n\n if (url.searchParams.get(\"register\") === \"true\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n try {\n const results = await syncAllGuilds();\n const ok = results.filter((r) => r.success);\n const fail = results.filter((r) => !r.success);\n return Response.json({ registered: ok.length, failed: fail.length, results });\n } catch (err) {\n logger.error(\"Registration failed:\", err);\n return Response.json({ error: \"Registration failed\" }, { status: 500 });\n }\n }\n\n if (url.searchParams.get(\"register-metadata\") === \"true\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n try {\n const result = await registerMetadataSchema();\n return Response.json(result, { status: result.ok ? 200 : 500 });\n } catch (err) {\n logger.error(\"Metadata registration failed:\", err);\n return Response.json({ error: \"Metadata registration failed\" }, { status: 500 });\n }\n }\n\n if (url.searchParams.get(\"discover\") === \"true\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n try {\n const manifest = await discover(import.meta.url);\n return Response.json({\n commands: manifest.commands.length,\n components: manifest.components.length,\n manifest,\n });\n } catch (err) {\n logger.error(\"Discovery failed:\", err);\n return Response.json({ error: \"Discovery failed\" }, { status: 500 });\n }\n }\n\n const failedImports = getFailedImports();\n return Response.json({\n status: failedImports.length > 0 ? \"degraded\" : \"ok\",\n });\n }\n\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\");\n\n if (path === \"/patreon/webhook\") {\n return handlePatreonWebhook(req);\n }\n\n return handleInteraction(req);\n } catch (err) {\n logger.error(\"Unhandled request error:\", err);\n return Response.json({ error: \"Internal server error\" }, { status: 500 });\n } finally {\n // Flush any buffered logs before the isolate terminates\n await finalizeAllLoggers();\n }\n}\n",[],[150,295],"9516ce54-1d6c-11f1-b767-42dde27851f2","giveaways.cron_test.ts","9516cf08-1d6c-11f1-b767-42dde27851f2",26,["D",1773248762005],"import \"../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, restoreFetch, setNextThrow } from \"../test/_mocks/fetch.ts\";\nimport type { GiveawayConfig } from \"../discord/interactions/commands/giveaway.ts\";\nimport { MAX_ANNOUNCE_RETRIES } from \"../discord/interactions/commands/giveaway.ts\";\nimport runCron from \"./giveaways.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makeGiveaway(overrides?: Partial): GiveawayConfig {\n return {\n prize: \"Test Prize\",\n channelId: \"c1\",\n messageId: \"m1\",\n endsAt: Date.now() - 1000,\n winnersCount: 1,\n entrants: [\"u1\", \"u2\"],\n ended: false,\n ...overrides,\n };\n}\n\nDeno.test(\"giveaways cron: ended giveaway is cleaned up\", async () => {\n resetStore();\n const key = \"giveaway:g1\";\n await kv.set(key, makeGiveaway({ ended: true, winners: [\"u1\"] }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: active giveaway gets ended\", async () => {\n resetStore();\n const key = \"giveaway:g1\";\n await kv.set(key, makeGiveaway({ ended: false }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // endGiveaway atomically claims and sets ended=true, then re-saves with cleanup delay\n const updated = await kv.get(key);\n assertEquals(updated?.ended, true);\n assertEquals(Array.isArray(updated?.winners), true);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: API failure does not delete giveaway (retried next run)\", async () => {\n resetStore();\n const key = \"giveaway:g1\";\n await kv.set(key, makeGiveaway({ ended: false }), Date.now() - 1000);\n // All API calls fail — endGiveaway's claimUpdate succeeds but panel update fails\n mockFetch({ default: { status: 500, body: \"Internal Server Error\" } });\n try {\n await runCron();\n const updated = await kv.get(key);\n assert(updated !== null, \"Giveaway should still be in KV\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: deletes malformed entries\", async () => {\n resetStore();\n const key = \"giveaway:g1\";\n // Missing channelId and messageId\n await kv.set(key, { prize: \"Bad\", ended: false, endsAt: 0, winnersCount: 1, entrants: [] }, Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // Malformed entry is cleaned up\n const remaining = await kv.get(key);\n assert(remaining === null, \"Malformed giveaway should be deleted\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: timeout error on active giveaway retries next run\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n const key = \"giveaway:g_timeout\";\n await kv.set(key, makeGiveaway({ ended: false }), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n // Make the first fetch throw a timeout error (endGiveaway's claimUpdate calls fetch internally)\n setNextThrow(new Error(\"Timed out\"));\n try {\n await runCron();\n // The giveaway should remain in KV since the cron catches timeout errors\n const remaining = await kv.get(key);\n assert(remaining !== null, \"Giveaway should still be in KV after timeout\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: announce retry success removes announceFailed flag\", async () => {\n resetStore();\n const key = \"giveaway:g_retry_ok\";\n await kv.set(key, makeGiveaway({\n ended: true,\n winners: [\"u1\"],\n announceFailed: true,\n announceRetries: 0,\n }), Date.now() - 1000);\n // announceGiveaway calls PATCH + POST to Discord\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const updated = await kv.get(key);\n assert(updated !== null, \"Giveaway should still exist (scheduled for cleanup)\");\n assertEquals(updated?.announceFailed, undefined, \"announceFailed should be cleared\");\n assertEquals(updated?.announceRetries, undefined, \"announceRetries should be cleared\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: announce retry intermediate uses exponential backoff\", async () => {\n resetStore();\n const key = \"giveaway:g_backoff\";\n await kv.set(key, makeGiveaway({\n ended: true,\n winners: [\"u1\"],\n announceFailed: true,\n announceRetries: 0,\n }), Date.now() - 1000);\n // announceGiveaway returns false when PATCH fails (non-ok response)\n // First call is PATCH (fail), second is POST (doesn't matter)\n mockFetch({\n responses: [\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n ],\n });\n try {\n await runCron();\n const updated = await kv.get(key);\n assert(updated !== null, \"Giveaway should still exist\");\n assertEquals(updated?.announceFailed, true, \"announceFailed should remain true\");\n assertEquals(updated?.announceRetries, 1, \"announceRetries should increment to 1\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: MAX_ANNOUNCE_RETRIES exhaustion gives up\", async () => {\n resetStore();\n const key = \"giveaway:g_maxretry\";\n await kv.set(key, makeGiveaway({\n ended: true,\n winners: [\"u1\"],\n announceFailed: true,\n announceRetries: MAX_ANNOUNCE_RETRIES - 1,\n }), Date.now() - 1000);\n // announceGiveaway returns false (PATCH fails)\n mockFetch({\n responses: [\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n { status: 500, body: \"fail\" },\n ],\n });\n try {\n await runCron();\n const updated = await kv.get(key);\n assert(updated !== null, \"Giveaway should exist (saved for cleanup)\");\n assertEquals(updated?.announceFailed, undefined, \"announceFailed should be cleared after giving up\");\n assertEquals(updated?.announceRetries, undefined, \"announceRetries should be cleared after giving up\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: announce retry error increments failed counter\", { sanitizeOps: false, sanitizeResources: false }, async () => {\n resetStore();\n const key = \"giveaway:g_retry_err\";\n await kv.set(key, makeGiveaway({\n ended: true,\n winners: [\"u1\"],\n announceFailed: true,\n announceRetries: 0,\n }), Date.now() - 1000);\n // Make fetch throw so announceGiveaway throws instead of returning false\n mockFetch();\n setNextThrow(new Error(\"Network failure\"));\n try {\n await runCron();\n // The entry should still be in KV (catch block doesn't modify it)\n const remaining = await kv.get(key);\n assert(remaining !== null, \"Giveaway should still be in KV after announce error\");\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: empty giveaway list is no-op\", async () => {\n resetStore();\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // No errors, no exceptions — just a no-op\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: claimDelete returns false skips cleanup\", async () => {\n resetStore();\n const key = \"giveaway:g_nodupe\";\n await kv.set(key, makeGiveaway({ ended: true, winners: [\"u1\"] }), Date.now() - 1000);\n\n // Monkey-patch claimDelete to return false for this key\n const origClaimDelete = kv.claimDelete.bind(kv);\n (kv as any).claimDelete = async (k: string) => {\n if (k === key) return false;\n return origClaimDelete(k);\n };\n\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n // claimDelete returned false, so no cleanup was done — no error\n } finally {\n (kv as any).claimDelete = origClaimDelete;\n restoreFetch();\n }\n});\n\nDeno.test(\"giveaways cron: partial malformation (channelId but no messageId) deleted\", async () => {\n resetStore();\n const key = \"giveaway:g_partial\";\n // Has channelId but missing messageId\n await kv.set(key, {\n prize: \"Partial\",\n channelId: \"c1\",\n ended: false,\n endsAt: 0,\n winnersCount: 1,\n entrants: [],\n }, Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assert(remaining === null, \"Partially malformed giveaway should be deleted\");\n } finally {\n restoreFetch();\n }\n});\n",[],[150,303],"9527cec0-1d6c-11f1-ac6f-42dde27851f2","giveaways.cron.ts","9527cf60-1d6c-11f1-ac6f-42dde27851f2",28,["D",1773248762110],"/**\n * services/giveaways.cron.ts\n *\n * Cron job that checks for expired giveaways and ends them.\n * Schedule in Val Town to run every 1-5 minutes.\n */\n\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { type GiveawayConfig, endGiveaway, announceGiveaway, MAX_ANNOUNCE_RETRIES } from \"../discord/interactions/commands/giveaway.ts\";\nimport { withTimeout } from \"../discord/helpers/timeout.ts\";\nimport { runCron } from \"../discord/helpers/cron.ts\";\n\nconst ITEM_TIMEOUT_MS = 30_000;\nconst ANNOUNCE_RETRY_DELAY_MS = 15 * 60 * 1000;\nconst CLEANUP_DELAY_MS = 24 * 60 * 60 * 1000;\n\nexport default async function () {\n let ended = 0, cleaned = 0, retried = 0, failed = 0;\n\n await runCron({\n name: \"GiveawayCron\",\n prefix: \"giveaway:\",\n maxDue: 100,\n async process(entry, logger) {\n const config = entry.value as GiveawayConfig;\n if (!config?.channelId || !config?.messageId) {\n logger.warn(`Deleting malformed giveaway: ${entry.key}`);\n await kv.claimDelete(entry.key).catch((e) =>\n logger.warn(`Failed to delete malformed entry ${entry.key}: ${e instanceof Error ? e.message : String(e)}`)\n );\n return;\n }\n\n // Ended giveaways — retry announcement or clean up\n if (config.ended) {\n if (config.announceFailed) {\n const guildId = entry.key.slice(\"giveaway:\".length);\n const retries = (config.announceRetries ?? 0) + 1;\n try {\n const success = await withTimeout(announceGiveaway(guildId, config), ITEM_TIMEOUT_MS);\n if (success) {\n const { announceFailed: _, announceRetries: __, ...clean } = config;\n await kv.set(entry.key, clean, Date.now() + CLEANUP_DELAY_MS);\n retried++;\n } else if (retries >= MAX_ANNOUNCE_RETRIES) {\n const { announceFailed: _, announceRetries: __, ...clean } = config;\n await kv.set(entry.key, clean, Date.now() + CLEANUP_DELAY_MS);\n logger.warn(`Giving up on giveaway announce for ${entry.key} after ${retries} retries`);\n } else {\n await kv.set(\n entry.key,\n { ...config, announceRetries: retries },\n Date.now() + ANNOUNCE_RETRY_DELAY_MS * Math.pow(2, retries - 1),\n );\n }\n } catch (err) {\n failed++;\n logger.error(`Failed to retry giveaway announce ${entry.key}:`, err);\n }\n return;\n }\n\n // Normal cleanup — delete the KV row\n try {\n const deleted = await kv.claimDelete(entry.key);\n if (deleted) cleaned++;\n } catch (err) {\n failed++;\n logger.error(`Failed to clean up ended giveaway ${entry.key}:`, err);\n }\n return;\n }\n\n // Active giveaway whose due_at has arrived — endGiveaway handles atomicity\n try {\n const guildId = entry.key.slice(\"giveaway:\".length);\n await withTimeout(endGiveaway(guildId), ITEM_TIMEOUT_MS);\n ended++;\n } catch (err) {\n failed++;\n const isTimeout = err instanceof Error && err.message === \"Timed out\";\n if (isTimeout) {\n logger.warn(`Timed out ending giveaway ${entry.key} — will retry next run`);\n } else {\n logger.error(`Failed to end giveaway ${entry.key}:`, err);\n }\n }\n },\n });\n}\n",[],[150,311],"950ff44e-1d6c-11f1-95a1-42dde27851f2","example.cron.ts","950ff656-1d6c-11f1-95a1-42dde27851f2",25,["D",1773248761966],"/**\n * services/example.cron.ts\n *\n * Example cron job demonstrating webhook messaging from a scheduled task.\n * Schedule this in Val Town's cron configuration to run periodically.\n */\n\nimport { send } from \"../discord/webhook/send.ts\";\nimport { embed } from \"../discord/helpers/embed-builder.ts\";\n\nexport default async function () {\n await send(\n embed().info(\"Cron job executed successfully.\").timestamp().build(),\n );\n}\n",[],[150,319],["D",1773248760230],[186,187,188,189,190,191,192,193,194,195,196,197,198,199],[150],"9468c8d6-1d6c-11f1-8f18-42dde27851f2","webhook","9468c9b2-1d6c-11f1-8f18-42dde27851f2",10,["D",1773248760870],[],[156,330],"94357d96-1d6c-11f1-ac6f-42dde27851f2","94357e68-1d6c-11f1-ac6f-42dde27851f2",6,["D",1773248760493],[],[156,150],"94832ec4-1d6c-11f1-9109-42dde27851f2","persistence","94832fe6-1d6c-11f1-9109-42dde27851f2",12,["D",1773248761042],[],[156,343],"94c4b97a-1d6c-11f1-9ac8-42dde27851f2","verifiers","94c4ba6a-1d6c-11f1-9ac8-42dde27851f2","944e9be6-1d6c-11f1-8f18-42dde27851f2",16,["D",1773248761471],[],[156,357,350],"linked-roles","944e9b32-1d6c-11f1-8f18-42dde27851f2",["D",1773248760699],[181],[156,357],"94b4abde-1d6c-11f1-9109-42dde27851f2","components","94b4acba-1d6c-11f1-9109-42dde27851f2","9442037c-1d6c-11f1-8f18-42dde27851f2",15,["D",1773248761361],[],[156,370,363],"interactions","94a2fe16-1d6c-11f1-9109-42dde27851f2","commands","94a2fed4-1d6c-11f1-9109-42dde27851f2",14,["D",1773248761250],[],[156,370,372],"944202a0-1d6c-11f1-8f18-42dde27851f2",7,["D",1773248760616],[178,179],[156,370],"9475e9bc-1d6c-11f1-ac6f-42dde27851f2","helpers","9475eb06-1d6c-11f1-ac6f-42dde27851f2",11,["D",1773248760955],[],[156,384],"94dac09e-1d6c-11f1-9ac8-42dde27851f2","casino","94dac184-1d6c-11f1-9ac8-42dde27851f2","945b77c6-1d6c-11f1-8f18-42dde27851f2",17,["D",1773248761616],[],[156,398,391],"games","945b76fe-1d6c-11f1-8f18-42dde27851f2",9,["D",1773248760783],[175],[156,398],["D",1773248760319],[174,176,177,180,182,183,184],[156],["D",1773248642232],["D",1789520505489],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":24},{"_13":86,"_31":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_79":-5,"_125":445,"_446":447,"_448":449,"_450":24,"_451":24,"_452":24,"_453":123,"_454":-5,"_455":-7,"_456":-7,"_457":60,"_458":24,"_459":24,"_460":-5,"_461":24,"_462":24,"_463":24,"_464":-5},"ENV",{"_416":417,"_418":419,"_420":87,"_421":422,"_423":424,"_425":426,"_427":428,"_429":430,"_431":432,"_433":434,"_435":436,"_437":438,"_439":440,"_441":442,"_443":444},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v32