[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_328":329,"_330":331},"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",23,"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/interactions.http_test.ts","latestPath","fileId","95048c26-1d6c-11f1-b767-42dde27851f2","name","interactions.http_test.ts","fileType","http","content","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","createdAt",["D",1773248761887],"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=1789577999&sig=dd4f84669405a2b44de8df5c2d916f7dbec2110ea5df568b407fe28ffb9967e0","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":323,"_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":324,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":325,"_81":326,"_83":327,"_85":24},"tree",[165,177,184],"files",[165,166,167,168,169,170,171,172,173,174,175,176,177,178,179,180,181,182,183,184,185],"counts",{"_153":60,"_154":155,"_156":60,"_157":158,"_159":160},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":147,"_31":148,"_29":149,"_134":-5,"_40":41,"_39":150,"_136":123,"_37":151,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":152},{"_42":141,"_31":142,"_29":143,"_134":-5,"_40":41,"_39":144,"_136":123,"_37":145,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":146},{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":123,"_37":137,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":140},"942269cc-1d6c-11f1-9109-42dde27851f2","test","94226a9e-1d6c-11f1-9109-42dde27851f2","parentId",5,"latest",["D",1773248760409],"directory","label",[132],"94074818-1d6c-11f1-9109-42dde27851f2","services","940748e0-1d6c-11f1-9109-42dde27851f2",3,["D",1773248760230],[142],"9414ade6-1d6c-11f1-9109-42dde27851f2","discord","9414aeb8-1d6c-11f1-9109-42dde27851f2",4,["D",1773248760319],[148],"pulls","branches",1,"forks","envVars",{"_161":163,"_164":60},"connections",{"_161":60,"_162":60},"count","unfilledCount",8,"emptyCount",{"_42":147,"_31":148,"_29":149,"_134":-5,"_40":41,"_39":150,"_136":123,"_37":320,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":321,"_26":322},{"_42":315,"_31":314,"_29":309,"_134":149,"_40":41,"_39":316,"_136":123,"_37":317,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":318,"_26":319},{"_42":306,"_31":307,"_29":308,"_134":309,"_40":41,"_39":310,"_136":123,"_37":311,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":312,"_26":313},{"_42":299,"_31":300,"_29":301,"_134":149,"_40":41,"_39":302,"_136":123,"_37":303,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":304,"_26":305},{"_42":294,"_31":286,"_29":281,"_134":149,"_40":41,"_39":295,"_136":123,"_37":296,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":297,"_26":298},{"_42":287,"_31":288,"_29":289,"_134":281,"_40":41,"_39":290,"_136":123,"_37":291,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":292,"_26":293},{"_42":278,"_31":279,"_29":280,"_134":281,"_40":41,"_39":282,"_136":123,"_37":283,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":284,"_26":285},{"_42":274,"_31":273,"_29":268,"_134":149,"_40":41,"_39":163,"_136":123,"_37":275,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":276,"_26":277},{"_42":265,"_31":266,"_29":267,"_134":268,"_40":41,"_39":269,"_136":123,"_37":270,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":271,"_26":272},{"_42":258,"_31":259,"_29":260,"_134":149,"_40":41,"_39":261,"_136":123,"_37":262,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":263,"_26":264},{"_42":252,"_31":142,"_29":253,"_134":149,"_40":41,"_39":254,"_136":123,"_37":255,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":256,"_26":257},{"_42":245,"_31":246,"_29":247,"_134":149,"_40":41,"_39":248,"_136":123,"_37":249,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":250,"_26":251},{"_42":141,"_31":142,"_29":143,"_134":-5,"_40":41,"_39":144,"_136":123,"_37":242,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":243,"_26":244},{"_42":234,"_31":235,"_29":236,"_134":143,"_40":41,"_39":237,"_136":24,"_37":238,"_13":60,"_33":34,"_35":239,"_23":24,"_139":44,"_191":240,"_26":241},{"_42":230,"_31":32,"_29":30,"_134":143,"_40":41,"_39":14,"_136":24,"_37":231,"_13":60,"_33":34,"_35":36,"_23":24,"_139":-5,"_191":232,"_26":233},{"_42":222,"_31":223,"_29":224,"_134":143,"_40":41,"_39":225,"_136":24,"_37":226,"_13":60,"_33":202,"_35":227,"_23":24,"_139":-5,"_191":228,"_26":229},{"_42":214,"_31":215,"_29":216,"_134":143,"_40":41,"_39":217,"_136":24,"_37":218,"_13":60,"_33":202,"_35":219,"_23":24,"_139":-5,"_191":220,"_26":221},{"_42":206,"_31":207,"_29":208,"_134":143,"_40":41,"_39":209,"_136":24,"_37":210,"_13":60,"_33":202,"_35":211,"_23":24,"_139":-5,"_191":212,"_26":213},{"_42":197,"_31":198,"_29":199,"_134":143,"_40":41,"_39":200,"_136":24,"_37":201,"_13":60,"_33":202,"_35":203,"_23":24,"_139":-5,"_191":204,"_26":205},{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":123,"_37":194,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":195,"_26":196},{"_42":186,"_31":187,"_29":188,"_134":133,"_40":41,"_39":189,"_136":123,"_37":190,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_191":192,"_26":193},"94922168-1d6c-11f1-9109-42dde27851f2","_mocks","9492226c-1d6c-11f1-9109-42dde27851f2",13,["D",1773248761136],"children",[],[132,187],["D",1773248760409],[185],[132],"94fc7554-1d6c-11f1-95a1-42dde27851f2","tickets.cron.ts","94fc763a-1d6c-11f1-95a1-42dde27851f2",22,["D",1773248761838],"interval","/**\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",[],[142,198],"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",[],[142,207],"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",[],[142,215],"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",[],[142,223],"95048b54-1d6c-11f1-b767-42dde27851f2",["D",1773248761887],[],[142,32],"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",[],[142,235],["D",1773248760230],[178,179,180,181,182,183],[142],"9468c8d6-1d6c-11f1-8f18-42dde27851f2","webhook","9468c9b2-1d6c-11f1-8f18-42dde27851f2",10,["D",1773248760870],[],[148,246],"94357d96-1d6c-11f1-ac6f-42dde27851f2","94357e68-1d6c-11f1-ac6f-42dde27851f2",6,["D",1773248760493],[],[148,142],"94832ec4-1d6c-11f1-9109-42dde27851f2","persistence","94832fe6-1d6c-11f1-9109-42dde27851f2",12,["D",1773248761042],[],[148,259],"94c4b97a-1d6c-11f1-9ac8-42dde27851f2","verifiers","94c4ba6a-1d6c-11f1-9ac8-42dde27851f2","944e9be6-1d6c-11f1-8f18-42dde27851f2",16,["D",1773248761471],[],[148,273,266],"linked-roles","944e9b32-1d6c-11f1-8f18-42dde27851f2",["D",1773248760699],[173],[148,273],"94b4abde-1d6c-11f1-9109-42dde27851f2","components","94b4acba-1d6c-11f1-9109-42dde27851f2","9442037c-1d6c-11f1-8f18-42dde27851f2",15,["D",1773248761361],[],[148,286,279],"interactions","94a2fe16-1d6c-11f1-9109-42dde27851f2","commands","94a2fed4-1d6c-11f1-9109-42dde27851f2",14,["D",1773248761250],[],[148,286,288],"944202a0-1d6c-11f1-8f18-42dde27851f2",7,["D",1773248760616],[170,171],[148,286],"9475e9bc-1d6c-11f1-ac6f-42dde27851f2","helpers","9475eb06-1d6c-11f1-ac6f-42dde27851f2",11,["D",1773248760955],[],[148,300],"94dac09e-1d6c-11f1-9ac8-42dde27851f2","casino","94dac184-1d6c-11f1-9ac8-42dde27851f2","945b77c6-1d6c-11f1-8f18-42dde27851f2",17,["D",1773248761616],[],[148,314,307],"games","945b76fe-1d6c-11f1-8f18-42dde27851f2",9,["D",1773248760783],[167],[148,314],["D",1773248760319],[166,168,169,172,174,175,176],[148],["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":361,"_362":363,"_364":365,"_366":24,"_367":24,"_368":24,"_369":123,"_370":-5,"_371":-7,"_372":-7,"_373":60,"_374":24,"_375":24,"_376":-5,"_377":24,"_378":24,"_379":24,"_380":-5},"ENV",{"_332":333,"_334":335,"_336":87,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360},"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 · v23