[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_536":537,"_538":539},"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",45,"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","discord/services/stream-platforms_test.ts","latestPath","fileId","95b9eaee-1d6c-11f1-9ac8-42dde27851f2","name","stream-platforms_test.ts","fileType","script","content","import \"../../test/_mocks/env.ts\";\nimport { assertEquals, assert, assertRejects } from \"../../test/assert.ts\";\nimport { mockFetch, getCalls, restoreFetch } from \"../../test/_mocks/fetch.ts\";\nimport { checkTwitchStreams, checkYouTubeStream, checkKickStream, _internals } from \"./stream-platforms.ts\";\n\n// --- Twitch ---\n\nDeno.test(\"twitch: empty array returns empty map\", async () => {\n const result = await checkTwitchStreams([]);\n assertEquals(result.size, 0);\n});\n\nDeno.test(\"twitch: single live user\", async () => {\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_secret\");\n mockFetch({\n responses: [\n // Token request\n { status: 200, body: { access_token: \"tok\", expires_in: 3600 } },\n // Streams API\n {\n status: 200,\n body: {\n data: [{\n user_login: \"ninja\",\n title: \"Playing Fortnite\",\n viewer_count: 50000,\n thumbnail_url: \"https://img.twitch.tv/{width}x{height}.jpg\",\n }],\n },\n },\n ],\n });\n try {\n const result = await checkTwitchStreams([\"ninja\"]);\n assertEquals(result.size, 1);\n const ninja = result.get(\"ninja\")!;\n assertEquals(ninja.isLive, true);\n assertEquals(ninja.title, \"Playing Fortnite\");\n assertEquals(ninja.viewerCount, 50000);\n assert(ninja.streamUrl.includes(\"twitch.tv/ninja\"));\n } finally {\n restoreFetch();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n }\n});\n\nDeno.test(\"twitch: mixed live/offline\", async () => {\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_secret\");\n // Token is cached from prior test, so only need streams response\n mockFetch({\n default: {\n status: 200,\n body: {\n data: [{ user_login: \"live_user\", title: \"Live!\", viewer_count: 100, thumbnail_url: \"\" }],\n },\n },\n });\n try {\n const result = await checkTwitchStreams([\"live_user\", \"offline_user\"]);\n assertEquals(result.get(\"live_user\")!.isLive, true);\n assertEquals(result.get(\"offline_user\")!.isLive, false);\n } finally {\n restoreFetch();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n }\n});\n\nDeno.test(\"twitch: streams API error throws\", async () => {\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_secret\");\n // Token is cached, so the 401 hits the streams endpoint\n mockFetch({ default: { status: 401, body: \"Unauthorized\" } });\n try {\n await assertRejects(\n () => checkTwitchStreams([\"user\"]),\n Error,\n \"Twitch streams API failed\",\n );\n } finally {\n restoreFetch();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n }\n});\n\n// --- YouTube ---\n\nDeno.test(\"youtube: live returns isLive true with video URL\", async () => {\n Deno.env.set(\"YOUTUBE_API_KEY\", \"test_key\");\n mockFetch({\n default: {\n status: 200,\n body: {\n items: [{\n id: { videoId: \"abc123\" },\n snippet: { title: \"Live Stream\", thumbnails: { high: { url: \"https://thumb.jpg\" } } },\n }],\n },\n },\n });\n try {\n const result = await checkYouTubeStream(\"UCtest\");\n assertEquals(result.isLive, true);\n assertEquals(result.title, \"Live Stream\");\n assert(result.streamUrl.includes(\"abc123\"));\n } finally {\n restoreFetch();\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n }\n});\n\nDeno.test(\"youtube: not live returns isLive false\", async () => {\n Deno.env.set(\"YOUTUBE_API_KEY\", \"test_key\");\n mockFetch({ default: { status: 200, body: { items: [] } } });\n try {\n const result = await checkYouTubeStream(\"UCtest\");\n assertEquals(result.isLive, false);\n assert(result.streamUrl.includes(\"UCtest\"));\n } finally {\n restoreFetch();\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n }\n});\n\nDeno.test(\"youtube: missing API key throws\", async () => {\n Deno.env.delete(\"YOUTUBE_API_KEY\");\n await assertRejects(\n () => checkYouTubeStream(\"UCtest\"),\n Error,\n \"YOUTUBE_API_KEY\",\n );\n});\n\n// --- Kick ---\n\nDeno.test(\"kick: live stream returns data\", async () => {\n mockFetch({\n default: {\n status: 200,\n body: {\n livestream: {\n is_live: true,\n session_title: \"Gaming Live\",\n viewer_count: 500,\n thumbnail: { url: \"https://thumb.jpg\" },\n },\n },\n },\n });\n try {\n const result = await checkKickStream(\"testuser\");\n assertEquals(result.isLive, true);\n assertEquals(result.title, \"Gaming Live\");\n assertEquals(result.viewerCount, 500);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"kick: 404 returns offline\", async () => {\n mockFetch({ default: { status: 404, body: \"Not Found\" } });\n try {\n const result = await checkKickStream(\"nonexistent\");\n assertEquals(result.isLive, false);\n assert(result.streamUrl.includes(\"nonexistent\"));\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"kick: API error throws\", async () => {\n mockFetch({ default: { status: 500, body: \"Server Error\" } });\n try {\n await assertRejects(\n () => checkKickStream(\"user\"),\n Error,\n \"Kick API failed\",\n );\n } finally {\n restoreFetch();\n }\n});\n\n// --- Token cache isolation tests ---\n\nDeno.test(\"twitch: resetTokenCache clears cache forcing new token fetch\", async () => {\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_secret\");\n _internals.resetTokenCache();\n mockFetch({\n responses: [\n // Token request\n { status: 200, body: { access_token: \"fresh_tok\", expires_in: 3600 } },\n // Streams API\n { status: 200, body: { data: [] } },\n ],\n });\n try {\n await checkTwitchStreams([\"anyuser\"]);\n const calls = getCalls();\n assertEquals(calls.length, 2);\n assert(calls[0].url.includes(\"oauth2/token\"));\n assert(calls[1].url.includes(\"helix/streams\"));\n } finally {\n restoreFetch();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n }\n});\n\nDeno.test(\"twitch: expired token cache triggers new fetch\", async () => {\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_secret\");\n _internals.resetTokenCache();\n // First call: get a token with a very short expiry\n mockFetch({\n responses: [\n // Token with 0s expiry (already expired by the time we use it again)\n { status: 200, body: { access_token: \"short_tok\", expires_in: 0 } },\n { status: 200, body: { data: [] } },\n ],\n });\n try {\n await checkTwitchStreams([\"user1\"]);\n } finally {\n restoreFetch();\n }\n // Second call: should fetch a new token since the old one is expired\n mockFetch({\n responses: [\n { status: 200, body: { access_token: \"new_tok\", expires_in: 3600 } },\n { status: 200, body: { data: [] } },\n ],\n });\n try {\n await checkTwitchStreams([\"user2\"]);\n const calls = getCalls();\n assertEquals(calls.length, 2);\n assert(calls[0].url.includes(\"oauth2/token\"));\n } finally {\n restoreFetch();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n }\n});\n\nDeno.test(\"twitch: token request failure throws\", async () => {\n Deno.env.set(\"TWITCH_CLIENT_ID\", \"test_id\");\n Deno.env.set(\"TWITCH_CLIENT_SECRET\", \"test_secret\");\n _internals.resetTokenCache();\n mockFetch({\n default: { status: 401, body: \"Unauthorized\" },\n });\n try {\n await assertRejects(\n () => checkTwitchStreams([\"user\"]),\n Error,\n \"Twitch token request failed\",\n );\n } finally {\n restoreFetch();\n Deno.env.delete(\"TWITCH_CLIENT_ID\");\n Deno.env.delete(\"TWITCH_CLIENT_SECRET\");\n }\n});\n","createdAt",["D",1773248762362],"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=1789590611&sig=3d5cfd566f03bd7ef54032465bfae9f4533f6ef5afe318a739689e9d03f72173","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":531,"_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":532,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":533,"_81":534,"_83":535,"_85":24},"tree",[189,212,227,229,230,231],"files",[189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231],"counts",{"_177":60,"_178":179,"_180":60,"_181":182,"_183":184},"contents",[128,129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":171,"_31":172,"_29":173,"_137":-5,"_40":41,"_39":174,"_139":123,"_37":175,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_26":176},{"_42":165,"_31":166,"_29":167,"_137":-5,"_40":41,"_39":168,"_139":123,"_37":169,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_26":170},{"_42":158,"_31":159,"_29":160,"_137":-5,"_40":41,"_39":161,"_139":123,"_37":162,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_26":164},{"_42":151,"_31":152,"_29":153,"_137":-5,"_40":41,"_39":154,"_139":123,"_37":155,"_13":60,"_33":20,"_35":156,"_23":24,"_142":-5,"_26":157},{"_42":144,"_31":145,"_29":146,"_137":-5,"_40":41,"_39":147,"_139":123,"_37":148,"_13":60,"_33":20,"_35":149,"_23":24,"_142":-5,"_26":150},{"_42":134,"_31":135,"_29":136,"_137":-5,"_40":41,"_39":138,"_139":123,"_37":140,"_13":60,"_33":20,"_35":141,"_23":24,"_142":-5,"_26":143},"9552335e-1d6c-11f1-95a1-42dde27851f2","deno.json","95523408-1d6c-11f1-95a1-42dde27851f2","parentId",34,"latest",["D",1773248762361],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"imports\": {\n \"https://esm.town/v/std/sqlite/main.ts\": \"./test/_mocks/sqlite.ts\",\n \"https://esm.town/v/std/utils@85-main/index.ts\": \"./test/_mocks/val-utils.ts\",\n \"https://esm.town/v/std/blob\": \"./test/_mocks/blob.ts\"\n },\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\",\n \"no-unresolved\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}\n","label",[135],"953cdb4e-1d6c-11f1-9ac8-42dde27851f2","SECURITY.md","953cdbee-1d6c-11f1-9ac8-42dde27851f2",31,["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",[145],"954b31f8-1d6c-11f1-b767-42dde27851f2","LICENSE","954b32d4-1d6c-11f1-b767-42dde27851f2",33,["D",1773248762268],"MIT License\n\nCopyright (c) 2026 catalloc\n\nPermission is hereby granted, free of charge, to any person obtaining a copy\nof this software and associated documentation files (the \"Software\"), to deal\nin the Software without restriction, including without limitation the rights\nto use, copy, modify, merge, publish, distribute, sublicense, and/or sell\ncopies of the Software, and to permit persons to whom the Software is\nfurnished to do so, subject to the following conditions:\n\nThe above copyright notice and this permission notice shall be included in all\ncopies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR\nIMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,\nFITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE\nAUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER\nLIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,\nOUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE\nSOFTWARE.\n",[152],"942269cc-1d6c-11f1-9109-42dde27851f2","test","94226a9e-1d6c-11f1-9109-42dde27851f2",5,["D",1773248760409],"directory",[159],"94074818-1d6c-11f1-9109-42dde27851f2","services","940748e0-1d6c-11f1-9109-42dde27851f2",3,["D",1773248760230],[166],"9414ade6-1d6c-11f1-9109-42dde27851f2","discord","9414aeb8-1d6c-11f1-9109-42dde27851f2",4,["D",1773248760319],[172],"pulls","branches",1,"forks","envVars",{"_185":187,"_188":60},"connections",{"_185":60,"_186":60},"count","unfilledCount",8,"emptyCount",{"_42":171,"_31":172,"_29":173,"_137":-5,"_40":41,"_39":174,"_139":123,"_37":528,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":529,"_26":530},{"_42":523,"_31":522,"_29":517,"_137":173,"_40":41,"_39":524,"_139":123,"_37":525,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":526,"_26":527},{"_42":514,"_31":515,"_29":516,"_137":517,"_40":41,"_39":518,"_139":123,"_37":519,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":520,"_26":521},{"_42":507,"_31":508,"_29":509,"_137":173,"_40":41,"_39":510,"_139":123,"_37":511,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":512,"_26":513},{"_42":502,"_31":423,"_29":417,"_137":173,"_40":41,"_39":503,"_139":123,"_37":504,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":505,"_26":506},{"_42":497,"_31":448,"_29":442,"_137":417,"_40":41,"_39":498,"_139":123,"_37":499,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":500,"_26":501},{"_42":489,"_31":490,"_29":491,"_137":442,"_40":41,"_39":492,"_139":123,"_37":493,"_13":60,"_33":34,"_35":494,"_23":24,"_142":-5,"_233":495,"_26":496},{"_42":481,"_31":482,"_29":483,"_137":442,"_40":41,"_39":484,"_139":123,"_37":485,"_13":60,"_33":34,"_35":486,"_23":24,"_142":-5,"_233":487,"_26":488},{"_42":473,"_31":474,"_29":475,"_137":442,"_40":41,"_39":476,"_139":123,"_37":477,"_13":60,"_33":34,"_35":478,"_23":24,"_142":-5,"_233":479,"_26":480},{"_42":465,"_31":466,"_29":467,"_137":442,"_40":41,"_39":468,"_139":123,"_37":469,"_13":60,"_33":34,"_35":470,"_23":24,"_142":-5,"_233":471,"_26":472},{"_42":457,"_31":458,"_29":459,"_137":442,"_40":41,"_39":460,"_139":123,"_37":461,"_13":60,"_33":34,"_35":462,"_23":24,"_142":-5,"_233":463,"_26":464},{"_42":449,"_31":450,"_29":451,"_137":442,"_40":41,"_39":452,"_139":123,"_37":453,"_13":60,"_33":34,"_35":454,"_23":24,"_142":-5,"_233":455,"_26":456},{"_42":439,"_31":440,"_29":441,"_137":442,"_40":41,"_39":443,"_139":123,"_37":444,"_13":60,"_33":34,"_35":445,"_23":24,"_142":-5,"_233":446,"_26":447},{"_42":432,"_31":433,"_29":434,"_137":417,"_40":41,"_39":435,"_139":123,"_37":436,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":437,"_26":438},{"_42":424,"_31":425,"_29":426,"_137":417,"_40":41,"_39":427,"_139":24,"_37":428,"_13":60,"_33":34,"_35":429,"_23":24,"_142":-5,"_233":430,"_26":431},{"_42":414,"_31":415,"_29":416,"_137":417,"_40":41,"_39":418,"_139":123,"_37":419,"_13":60,"_33":34,"_35":420,"_23":24,"_142":-5,"_233":421,"_26":422},{"_42":410,"_31":409,"_29":404,"_137":173,"_40":41,"_39":187,"_139":123,"_37":411,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":412,"_26":413},{"_42":401,"_31":402,"_29":403,"_137":404,"_40":41,"_39":405,"_139":123,"_37":406,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":407,"_26":408},{"_42":394,"_31":395,"_29":396,"_137":173,"_40":41,"_39":397,"_139":123,"_37":398,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":399,"_26":400},{"_42":389,"_31":166,"_29":377,"_137":173,"_40":41,"_39":390,"_139":123,"_37":391,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":392,"_26":393},{"_42":381,"_31":382,"_29":383,"_137":377,"_40":41,"_39":384,"_139":123,"_37":385,"_13":60,"_33":34,"_35":386,"_23":24,"_142":-5,"_233":387,"_26":388},{"_42":376,"_31":32,"_29":30,"_137":377,"_40":41,"_39":14,"_139":123,"_37":378,"_13":60,"_33":34,"_35":36,"_23":24,"_142":-5,"_233":379,"_26":380},{"_42":369,"_31":370,"_29":371,"_137":173,"_40":41,"_39":372,"_139":123,"_37":373,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":374,"_26":375},{"_42":165,"_31":166,"_29":167,"_137":-5,"_40":41,"_39":168,"_139":123,"_37":366,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":367,"_26":368},{"_42":358,"_31":359,"_29":360,"_137":167,"_40":41,"_39":361,"_139":24,"_37":362,"_13":60,"_33":257,"_35":363,"_23":24,"_142":-5,"_233":364,"_26":365},{"_42":350,"_31":351,"_29":352,"_137":167,"_40":41,"_39":353,"_139":24,"_37":354,"_13":60,"_33":257,"_35":355,"_23":24,"_142":-5,"_233":356,"_26":357},{"_42":342,"_31":343,"_29":344,"_137":167,"_40":41,"_39":345,"_139":24,"_37":346,"_13":60,"_33":257,"_35":347,"_23":24,"_142":-5,"_233":348,"_26":349},{"_42":334,"_31":335,"_29":336,"_137":167,"_40":41,"_39":337,"_139":24,"_37":338,"_13":60,"_33":330,"_35":339,"_23":24,"_142":44,"_233":340,"_26":341},{"_42":325,"_31":326,"_29":327,"_137":167,"_40":41,"_39":328,"_139":24,"_37":329,"_13":60,"_33":330,"_35":331,"_23":24,"_142":-5,"_233":332,"_26":333},{"_42":317,"_31":318,"_29":319,"_137":167,"_40":41,"_39":320,"_139":24,"_37":321,"_13":60,"_33":257,"_35":322,"_23":24,"_142":-5,"_233":323,"_26":324},{"_42":309,"_31":310,"_29":311,"_137":167,"_40":41,"_39":312,"_139":24,"_37":313,"_13":60,"_33":257,"_35":314,"_23":24,"_142":-5,"_233":315,"_26":316},{"_42":301,"_31":302,"_29":303,"_137":167,"_40":41,"_39":304,"_139":24,"_37":305,"_13":60,"_33":257,"_35":306,"_23":24,"_142":-5,"_233":307,"_26":308},{"_42":293,"_31":294,"_29":295,"_137":167,"_40":41,"_39":296,"_139":24,"_37":297,"_13":60,"_33":257,"_35":298,"_23":24,"_142":-5,"_233":299,"_26":300},{"_42":285,"_31":286,"_29":287,"_137":167,"_40":41,"_39":288,"_139":24,"_37":289,"_13":60,"_33":257,"_35":290,"_23":24,"_142":-5,"_233":291,"_26":292},{"_42":277,"_31":278,"_29":279,"_137":167,"_40":41,"_39":280,"_139":24,"_37":281,"_13":60,"_33":257,"_35":282,"_23":24,"_142":-5,"_233":283,"_26":284},{"_42":269,"_31":270,"_29":271,"_137":167,"_40":41,"_39":272,"_139":24,"_37":273,"_13":60,"_33":257,"_35":274,"_23":24,"_142":-5,"_233":275,"_26":276},{"_42":261,"_31":262,"_29":263,"_137":167,"_40":41,"_39":264,"_139":24,"_37":265,"_13":60,"_33":257,"_35":266,"_23":24,"_142":-5,"_233":267,"_26":268},{"_42":252,"_31":253,"_29":254,"_137":167,"_40":41,"_39":255,"_139":24,"_37":256,"_13":60,"_33":257,"_35":258,"_23":24,"_142":-5,"_233":259,"_26":260},{"_42":158,"_31":159,"_29":160,"_137":-5,"_40":41,"_39":161,"_139":123,"_37":249,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":250,"_26":251},{"_42":242,"_31":243,"_29":244,"_137":160,"_40":41,"_39":245,"_139":123,"_37":246,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_233":247,"_26":248},{"_42":151,"_31":152,"_29":153,"_137":-5,"_40":41,"_39":154,"_139":123,"_37":239,"_13":60,"_33":20,"_35":156,"_23":24,"_142":-5,"_233":240,"_26":241},{"_42":144,"_31":145,"_29":146,"_137":-5,"_40":41,"_39":147,"_139":123,"_37":236,"_13":60,"_33":20,"_35":149,"_23":24,"_142":-5,"_233":237,"_26":238},{"_42":134,"_31":135,"_29":136,"_137":-5,"_40":41,"_39":138,"_139":123,"_37":232,"_13":60,"_33":20,"_35":141,"_23":24,"_142":-5,"_233":234,"_26":235},["D",1773248762361],"children",[],[135],["D",1773248762247],[],[145],["D",1773248762268],[],[152],"94922168-1d6c-11f1-9109-42dde27851f2","_mocks","9492226c-1d6c-11f1-9109-42dde27851f2",13,["D",1773248761136],[],[159,243],["D",1773248760409],[228],[159],"95224f4a-1d6c-11f1-bb31-42dde27851f2","tickets.cron_test.ts","95224ffe-1d6c-11f1-bb31-42dde27851f2",27,["D",1773248761748],"interval","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",[],[166,253],"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",[],[166,262],"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",[],[166,270],"954055da-1d6c-11f1-a9cb-42dde27851f2","scheduled-messages.cron.ts","95405670-1d6c-11f1-a9cb-42dde27851f2",32,["D",1773248762243],"/**\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",[],[166,278],"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",[],[166,286],"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",[],[166,294],"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",[],[166,302],"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",[],[166,310],"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",[],[166,318],"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",[],[166,326],"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",[],[166,335],"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",[],[166,343],"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",[],[166,351],"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",[],[166,359],["D",1773248760230],[213,214,215,216,217,218,219,220,221,222,223,224,225,226],[166],"9468c8d6-1d6c-11f1-8f18-42dde27851f2","webhook","9468c9b2-1d6c-11f1-8f18-42dde27851f2",10,["D",1773248760870],[],[172,370],"95b9ea1c-1d6c-11f1-9ac8-42dde27851f2","94357e68-1d6c-11f1-ac6f-42dde27851f2",["D",1773248762362],[],[172,166,32],"9555651a-1d6c-11f1-a9cb-42dde27851f2","stream-platforms.ts","955565c4-1d6c-11f1-a9cb-42dde27851f2",35,["D",1773248762421],"/**\n * discord/services/stream-platforms.ts\n *\n * Platform adapters for checking live stream status on Twitch, YouTube, and Kick.\n * Twitch uses batched Helix API calls with in-memory token caching.\n * YouTube uses the Data API v3 search endpoint.\n * Kick uses the unofficial public API (best-effort).\n */\n\nimport { CONFIG } from \"../constants.ts\";\n\nexport type Platform = \"twitch\" | \"youtube\" | \"kick\";\n\nexport interface StreamStatus {\n isLive: boolean;\n title?: string;\n viewerCount?: number;\n thumbnailUrl?: string;\n streamUrl: string;\n}\n\n// --- Twitch ---\n\ninterface TwitchTokenCache {\n accessToken: string;\n expiresAt: number; // epoch ms\n}\n\nlet memoryTokenCache: TwitchTokenCache | null = null;\n\nasync function getTwitchToken(): Promise {\n const clientId = CONFIG.twitchClientId;\n const clientSecret = CONFIG.twitchClientSecret;\n if (!clientId || !clientSecret) {\n throw new Error(\"TWITCH_CLIENT_ID and TWITCH_CLIENT_SECRET are required for Twitch streams\");\n }\n\n if (memoryTokenCache && memoryTokenCache.expiresAt > Date.now() + 60_000) {\n return memoryTokenCache.accessToken;\n }\n\n const resp = await fetch(\"https://id.twitch.tv/oauth2/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: clientId,\n client_secret: clientSecret,\n grant_type: \"client_credentials\",\n }),\n signal: AbortSignal.timeout(10_000),\n });\n\n if (!resp.ok) {\n const text = await resp.text();\n throw new Error(`Twitch token request failed (${resp.status}): ${text}`);\n }\n\n const data = await resp.json();\n memoryTokenCache = {\n accessToken: data.access_token,\n expiresAt: Date.now() + data.expires_in * 1000,\n };\n return memoryTokenCache.accessToken;\n}\n\n/**\n * Check live status for up to 100 Twitch usernames in one API call.\n * Returns a map of lowercase username -> StreamStatus.\n */\nexport async function checkTwitchStreams(usernames: string[]): Promise> {\n const results = new Map();\n if (usernames.length === 0) return results;\n\n const clientId = CONFIG.twitchClientId;\n if (!clientId) throw new Error(\"TWITCH_CLIENT_ID is required for Twitch streams\");\n\n const token = await getTwitchToken();\n\n // Batch up to 100 per request\n const batches: string[][] = [];\n for (let i = 0; i < usernames.length; i += 100) {\n batches.push(usernames.slice(i, i + 100));\n }\n\n for (const batch of batches) {\n const params = new URLSearchParams();\n for (const u of batch) params.append(\"user_login\", u.toLowerCase());\n\n const resp = await fetch(`https://api.twitch.tv/helix/streams?${params}`, {\n headers: {\n \"Client-ID\": clientId,\n Authorization: `Bearer ${token}`,\n },\n signal: AbortSignal.timeout(10_000),\n });\n\n if (!resp.ok) {\n const text = await resp.text();\n throw new Error(`Twitch streams API failed (${resp.status}): ${text}`);\n }\n\n const data = await resp.json();\n const liveSet = new Set();\n\n for (const stream of data.data ?? []) {\n const login = (stream.user_login as string).toLowerCase();\n liveSet.add(login);\n results.set(login, {\n isLive: true,\n title: stream.title,\n viewerCount: stream.viewer_count,\n thumbnailUrl: (stream.thumbnail_url as string)\n ?.replace(\"{width}\", \"440\")\n .replace(\"{height}\", \"248\"),\n streamUrl: `https://twitch.tv/${login}`,\n });\n }\n\n // Mark non-live usernames as offline\n for (const u of batch) {\n const lower = u.toLowerCase();\n if (!liveSet.has(lower)) {\n results.set(lower, { isLive: false, streamUrl: `https://twitch.tv/${lower}` });\n }\n }\n }\n\n return results;\n}\n\n// --- YouTube ---\n\n/**\n * Check if a YouTube channel is currently live streaming.\n * Uses 100 quota units per call.\n */\nexport async function checkYouTubeStream(channelId: string): Promise {\n const apiKey = CONFIG.youtubeApiKey;\n if (!apiKey) throw new Error(\"YOUTUBE_API_KEY is required for YouTube streams\");\n\n const params = new URLSearchParams({\n part: \"snippet\",\n channelId,\n eventType: \"live\",\n type: \"video\",\n maxResults: \"1\",\n key: apiKey,\n });\n\n const resp = await fetch(`https://www.googleapis.com/youtube/v3/search?${params}`, {\n signal: AbortSignal.timeout(10_000),\n });\n\n if (!resp.ok) {\n const text = await resp.text();\n throw new Error(`YouTube API failed (${resp.status}): ${text}`);\n }\n\n const data = await resp.json();\n const items = data.items ?? [];\n\n if (items.length === 0) {\n return { isLive: false, streamUrl: `https://youtube.com/channel/${channelId}` };\n }\n\n const item = items[0];\n const videoId = item.id?.videoId;\n return {\n isLive: true,\n title: item.snippet?.title,\n thumbnailUrl: item.snippet?.thumbnails?.high?.url,\n streamUrl: videoId\n ? `https://youtube.com/watch?v=${videoId}`\n : `https://youtube.com/channel/${channelId}`,\n };\n}\n\n// --- Kick ---\n\n/**\n * Check if a Kick streamer is live using the unofficial public API.\n * No API key required. Best-effort — may break if Kick changes their API.\n */\nexport async function checkKickStream(username: string): Promise {\n const resp = await fetch(`https://kick.com/api/v2/channels/${encodeURIComponent(username)}`, {\n headers: { Accept: \"application/json\" },\n signal: AbortSignal.timeout(10_000),\n });\n\n if (!resp.ok) {\n if (resp.status === 404) {\n return { isLive: false, streamUrl: `https://kick.com/${username}` };\n }\n const text = await resp.text();\n throw new Error(`Kick API failed (${resp.status}): ${text}`);\n }\n\n const data = await resp.json();\n const livestream = data.livestream;\n\n if (!livestream || !livestream.is_live) {\n return { isLive: false, streamUrl: `https://kick.com/${username}` };\n }\n\n return {\n isLive: true,\n title: livestream.session_title ?? livestream.slug,\n viewerCount: livestream.viewer_count,\n thumbnailUrl: livestream.thumbnail?.url,\n streamUrl: `https://kick.com/${username}`,\n };\n}\n\nexport const _internals = {\n resetTokenCache() { memoryTokenCache = null; },\n};\n",[],[172,166,382],"94357d96-1d6c-11f1-ac6f-42dde27851f2",6,["D",1773248760493],[209,210],[172,166],"94832ec4-1d6c-11f1-9109-42dde27851f2","persistence","94832fe6-1d6c-11f1-9109-42dde27851f2",12,["D",1773248761042],[],[172,395],"94c4b97a-1d6c-11f1-9ac8-42dde27851f2","verifiers","94c4ba6a-1d6c-11f1-9ac8-42dde27851f2","944e9be6-1d6c-11f1-8f18-42dde27851f2",16,["D",1773248761471],[],[172,409,402],"linked-roles","944e9b32-1d6c-11f1-8f18-42dde27851f2",["D",1773248760699],[206],[172,409],"9568e658-1d6c-11f1-95a1-42dde27851f2","handler_integration_test.ts","9568e734-1d6c-11f1-95a1-42dde27851f2","9442037c-1d6c-11f1-8f18-42dde27851f2",37,["D",1773248762506],"import \"../../test/_mocks/env.ts\";\nimport { assertEquals } from \"../../test/assert.ts\";\nimport { handleInteraction } from \"./handler.ts\";\nimport { signedRequest } from \"../../test/_mocks/sign.ts\";\n\n// --- JSON.parse guard ---\n\nDeno.test(\"handleInteraction: malformed JSON returns 400\", async () => {\n const req = await signedRequest(\"{not valid json\");\n const res = await handleInteraction(req);\n assertEquals(res.status, 400);\n assertEquals(await res.text(), \"Invalid JSON\");\n});\n\nDeno.test(\"handleInteraction: valid PING returns pong\", async () => {\n const req = await signedRequest(JSON.stringify({ type: 1 }));\n const res = await handleInteraction(req);\n assertEquals(res.status, 200);\n const body = await res.json();\n assertEquals(body.type, 1); // PONG\n});\n\n// --- Request ID in error responses ---\n\nDeno.test(\"handleInteraction: unsupported type returns ephemeral response\", async () => {\n const req = await signedRequest(JSON.stringify({ type: 999 }));\n const res = await handleInteraction(req);\n assertEquals(res.status, 200);\n const body = await res.json();\n assertEquals(body.data.content, \"Unsupported interaction type\");\n assertEquals(body.data.flags, 64);\n});\n",[],[172,423,415],"interactions","955ab1a0-1d6c-11f1-a490-42dde27851f2","handler.ts","955ab268-1d6c-11f1-a490-42dde27851f2",36,["D",1773248762453],"/**\n * discord/interactions/handler.ts\n *\n * Single source of truth for Discord interaction handling.\n * All HTTP endpoints should import from this module.\n */\n\nimport { getCommand, getComponentHandler } from \"./registry.ts\";\nimport type { Command, CommandResult } from \"./define-command.ts\";\nimport {\n InteractionResponseType,\n OptionTypes,\n createAutocompleteResponse,\n} from \"./patterns.ts\";\nimport { createLogger } from \"../webhook/logger.ts\";\nimport { CONFIG, isGuildAdmin } from \"../constants.ts\";\nimport { UserFacingError } from \"./errors.ts\";\nimport type { ComponentContext } from \"./define-component.ts\";\nimport { kv } from \"../persistence/kv.ts\";\nimport { remainingMs } from \"../discord-api.ts\";\nimport { cryptoJitter } from \"../helpers/crypto.ts\";\n\nconst INTERACTION_TYPES = {\n PING: 1,\n APPLICATION_COMMAND: 2,\n MESSAGE_COMPONENT: 3,\n APPLICATION_COMMAND_AUTOCOMPLETE: 4,\n MODAL_SUBMIT: 5,\n} as const;\n\nconst logger = createLogger(\"InteractionHandler\", {\n minLevel: \"info\",\n});\n\nconst DEFERRED_TIMEOUT_MS = 9 * 60 * 1000; // 9 minutes (pro account 10-min limit, 1-min buffer)\n\nlet cachedKey: CryptoKey | null = null;\n\nasync function getPublicKey(): Promise {\n if (!cachedKey) {\n cachedKey = await crypto.subtle.importKey(\n \"raw\",\n hexToUint8Array(CONFIG.publicKey),\n { name: \"Ed25519\" },\n false,\n [\"verify\"],\n );\n }\n return cachedKey;\n}\n\nfunction hexToUint8Array(hex: string): Uint8Array {\n if (hex.length % 2 !== 0 || !/^[0-9a-f]*$/i.test(hex)) {\n throw new Error(\"Invalid hex string\");\n }\n const bytes = new Uint8Array(hex.length / 2);\n for (let i = 0; i < bytes.length; i++) {\n bytes[i] = parseInt(hex.substring(i * 2, i * 2 + 2), 16);\n }\n return bytes;\n}\n\nasync function verifyDiscordRequest(\n body: string,\n signature: string,\n timestamp: string,\n): Promise {\n try {\n const age = Math.abs(Date.now() / 1000 - parseInt(timestamp, 10));\n if (isNaN(age) || age > 5) return false;\n const key = await getPublicKey();\n const message = new TextEncoder().encode(timestamp + body);\n return await crypto.subtle.verify(\"Ed25519\", key, hexToUint8Array(signature), message);\n } catch {\n return false;\n }\n}\n\nfunction ephemeralResponse(content: string): Response {\n return Response.json({\n type: InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE,\n data: { content, flags: 64 },\n });\n}\n\nfunction buildPayload(\n message: string,\n result?: { embed?: any; components?: any[] },\n ephemeral = true,\n): Record {\n const data: Record = { content: message };\n if (ephemeral) data.flags = 64;\n if (result?.embed) data.embeds = [result.embed];\n if (result?.components) data.components = result.components;\n return data;\n}\n\n/**\n * Extract subcommand name and nested options from Discord interaction data.\n */\nfunction parseSubcommandOptions(\n dataOptions: any[] | undefined,\n): { subcommand: string | null; options: Record } {\n const options: Record = {};\n let subcommand: string | null = null;\n\n if (!dataOptions || !Array.isArray(dataOptions)) {\n return { subcommand, options };\n }\n\n for (const opt of dataOptions) {\n if (\n opt.type === OptionTypes.SUB_COMMAND ||\n opt.type === OptionTypes.SUB_COMMAND_GROUP\n ) {\n subcommand = opt.name;\n if (opt.options && Array.isArray(opt.options)) {\n for (const nestedOpt of opt.options) {\n if (nestedOpt.type === OptionTypes.SUB_COMMAND) {\n subcommand = `${opt.name}:${nestedOpt.name}`;\n if (nestedOpt.options) {\n for (const innerOpt of nestedOpt.options) {\n options[innerOpt.name] = innerOpt.value;\n }\n }\n } else {\n options[nestedOpt.name] = nestedOpt.value;\n }\n }\n }\n } else {\n options[opt.name] = opt.value;\n }\n }\n\n return { subcommand, options };\n}\n\nfunction formatResultMessage(result: CommandResult): string {\n if (result.message) return result.message;\n if (result.error) return `Error: ${result.error}`;\n return result.success ? \"Command completed\" : \"Command failed\";\n}\n\nasync function handleAutocompleteInteraction(body: any): Promise {\n const commandName = body.data.name;\n try {\n const cmd = getCommand(commandName);\n if (!cmd?.autocomplete) return createAutocompleteResponse([]);\n return await cmd.autocomplete(body, cmd.config);\n } catch (error) {\n logger.error(`Autocomplete error for ${commandName}:`, error);\n return createAutocompleteResponse([\n { name: \"Error fetching options\", value: \"_error\" },\n ]);\n }\n}\n\nasync function handleSlashCommandInteraction(body: any): Promise {\n const commandName = body.data.name;\n const command = getCommand(commandName);\n\n if (!command) {\n return ephemeralResponse(\"Error: Unknown command\");\n }\n\n const guildId = body.guild_id;\n const userId = body.member?.user?.id || body.user?.id;\n const ref = body.id?.slice(0, 8) ?? crypto.randomUUID().slice(0, 8);\n\n // Guild-only guard — guild-scoped commands cannot be used in DMs\n if (command.registration.type === \"guild\" && !body.guild_id) {\n return ephemeralResponse(\"This command can only be used in a server.\");\n }\n\n // Admin-only guard\n if (command.adminOnly) {\n if (!body.guild_id) {\n return ephemeralResponse(\"This command can only be used in a server.\");\n }\n const memberRoles: string[] = body.member?.roles || [];\n const authorized = await isGuildAdmin(guildId, userId, memberRoles, body.member?.permissions);\n if (!authorized) {\n return ephemeralResponse(\n \"You are not authorized to use this command.\",\n );\n }\n }\n\n // KV-backed cooldown — atomic check-and-set to prevent burst bypass\n if (command.cooldown && command.cooldown > 0) {\n const cooldownKey = `cooldown:${commandName}:${userId}`;\n let onCooldown = false;\n let remaining = 0;\n try {\n await kv.update(cooldownKey, (expiry) => {\n const now = Date.now();\n if (expiry !== null && now < expiry) {\n onCooldown = true;\n remaining = Math.ceil((expiry - now) / 1000);\n return expiry; // no-op, keep existing cooldown\n }\n return now + command.cooldown! * 1000;\n });\n } catch {\n // CAS exhaustion — allow through rather than block\n }\n if (onCooldown) {\n return ephemeralResponse(\n `Please wait ${remaining} second${remaining !== 1 ? \"s\" : \"\"} before using this command again.`,\n );\n }\n }\n\n // Extract command options with subcommand support\n const { subcommand, options: parsedOptions } = parseSubcommandOptions(\n body.data.options,\n );\n\n const options: Record = {\n ...parsedOptions,\n channelId: body.channel_id,\n interactionToken: body.token,\n interactionId: body.id,\n };\n\n if (subcommand) {\n options.subcommand = subcommand;\n }\n\n const logCtx = `[${ref}] [cmd:${commandName} guild:${guildId} user:${userId}]`;\n\n logger.info(\n `${logCtx} Processing${subcommand ? `:${subcommand}` : \"\"} inline`,\n );\n\n // Context menu data\n const targetId = body.data.target_id;\n const resolved = body.data.resolved;\n\n const memberRoles: string[] = body.member?.roles ?? [];\n const memberPermissions: string | undefined = body.member?.permissions;\n\n // Fast-command path — respond immediately without deferring\n if (command.deferred === false) {\n try {\n const result = await command.execute({\n guildId,\n userId,\n options,\n config: command.config,\n targetId,\n resolved,\n memberRoles,\n memberPermissions,\n });\n\n // Modal response (only valid for non-deferred commands)\n if (result.modal) {\n return Response.json({\n type: InteractionResponseType.MODAL,\n data: {\n title: result.modal.title,\n custom_id: result.modal.custom_id,\n components: result.modal.components,\n },\n });\n }\n\n const message = formatResultMessage(result);\n const isEphemeral = result.ephemeral ?? (command.ephemeral !== false);\n return Response.json({\n type: InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE,\n data: buildPayload(message, result, isEphemeral),\n });\n } catch (error) {\n logger.error(`${logCtx} Error executing fast command:`, error);\n const msg = error instanceof UserFacingError\n ? error.userMessage\n : `Something went wrong with /${commandName} (ref: ${ref})`;\n return ephemeralResponse(`Error: ${msg}`);\n }\n }\n\n // Deferred path — return ACK directly, execute + followup in background\n\n (async () => {\n const ac = new AbortController();\n const timer = setTimeout(() => ac.abort(), DEFERRED_TIMEOUT_MS);\n try {\n const timeout = new Promise((_, reject) => {\n ac.signal.addEventListener(\"abort\", () => reject(new Error(\"Command execution timed out\")), { once: true });\n });\n // Race covers both execute and followup so the combined time is bounded\n await Promise.race([\n (async () => {\n logger.info(`${logCtx} Executing...`);\n const result = await command.execute({\n guildId,\n userId,\n options,\n config: command.config,\n targetId,\n resolved,\n memberRoles,\n memberPermissions,\n signal: ac.signal,\n });\n const message = formatResultMessage(result);\n logger.info(`${logCtx} Sending followup`);\n await sendFollowup(body.application_id, body.token, message, result, command.ephemeral !== false);\n logger.info(`${logCtx} Completed successfully`);\n })(),\n timeout,\n ]);\n } catch (error) {\n logger.error(`${logCtx} Error executing:`, error);\n const userMsg = error instanceof UserFacingError\n ? error.userMessage\n : `Something went wrong with /${commandName} (ref: ${ref})`;\n try {\n await sendFollowup(body.application_id, body.token, `Error: ${userMsg}`);\n } catch (followupError) {\n logger.error(`${logCtx} Failed to send error followup:`, followupError);\n }\n } finally {\n clearTimeout(timer);\n }\n })().catch((error) => {\n logger.error(`${logCtx} Unhandled error in deferred execution:`, error);\n });\n\n const deferData: Record = {};\n if (command.ephemeral !== false) deferData.flags = 64;\n return Response.json({\n type: InteractionResponseType.DEFERRED_CHANNEL_MESSAGE_WITH_SOURCE,\n data: deferData,\n });\n}\n\nasync function sendFollowup(\n applicationId: string,\n interactionToken: string,\n content: string,\n result?: { embed?: any; components?: any[] },\n ephemeral = true,\n): Promise {\n const url = `https://discord.com/api/v10/webhooks/${applicationId}/${interactionToken}`;\n const body = JSON.stringify(buildPayload(content, result, ephemeral));\n\n for (let attempt = 0; attempt < 2; attempt++) {\n try {\n const response = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body,\n signal: AbortSignal.timeout(30_000),\n });\n\n if (response.ok) return;\n\n const errorBody = await response.text().catch(() => \"\");\n if (response.status === 429 && attempt === 0) {\n const retryAfter = parseFloat(response.headers.get(\"Retry-After\") || \"1\") * 1000;\n const jitter = cryptoJitter(Math.min(retryAfter * 0.2, 2000));\n const totalWait = Math.min(retryAfter + jitter, 60_000);\n if (totalWait + 30_000 > remainingMs()) {\n logger.error(`Failed to send followup: 429 rate limited, insufficient time budget (${Math.round(remainingMs() / 1000)}s left)`);\n return;\n }\n await new Promise((r) => setTimeout(r, totalWait));\n continue;\n }\n if (response.status >= 500 && attempt === 0 && remainingMs() > 32_000) {\n await new Promise((r) => setTimeout(r, 1000 + cryptoJitter(1000)));\n continue;\n }\n logger.error(\n `Failed to send followup: ${response.status} ${errorBody}`,\n );\n return;\n } catch (error) {\n if (attempt === 0 && remainingMs() > 32_000) {\n await new Promise((r) => setTimeout(r, 1000));\n continue;\n }\n logger.error(\n `Failed to send followup (network): ${error instanceof Error ? error.message : String(error)}`,\n );\n }\n }\n}\n\nfunction parseComponentType(discordType: number): \"button\" | \"select\" | undefined {\n if (discordType === 2) return \"button\";\n if (discordType >= 3 && discordType <= 8) return \"select\";\n return undefined;\n}\n\nasync function handleInteractiveComponent(body: any, isModal: boolean): Promise {\n const customId: string = body.data.custom_id;\n const ref = body.id?.slice(0, 8);\n\n let handlerType: \"button\" | \"select\" | \"modal\";\n if (isModal) {\n handlerType = \"modal\";\n } else {\n const componentType = parseComponentType(body.data.component_type);\n if (!componentType) {\n return ephemeralResponse(\"Unsupported component type\");\n }\n handlerType = componentType;\n }\n\n const handler = getComponentHandler(customId, handlerType);\n if (!handler) {\n return ephemeralResponse(`No handler for this ${isModal ? \"modal\" : \"component\"}`);\n }\n\n if (handler.adminOnly) {\n const userId = body.member?.user?.id || body.user?.id;\n if (!body.guild_id) {\n return ephemeralResponse(\"This action can only be used in a server.\");\n }\n const memberRoles: string[] = body.member?.roles || [];\n const authorized = await isGuildAdmin(body.guild_id, userId, memberRoles, body.member?.permissions);\n if (!authorized) {\n return ephemeralResponse(\"You are not authorized to use this action.\");\n }\n }\n\n try {\n const ctx: ComponentContext = {\n customId,\n guildId: body.guild_id,\n userId: body.member?.user?.id || body.user?.id,\n interaction: body,\n values: isModal ? undefined : body.data.values,\n };\n\n if (isModal) {\n const MAX_MODAL_FIELD_LENGTH = 4000;\n const fields: Record = {};\n for (const row of body.data.components ?? []) {\n for (const component of row.components ?? []) {\n if (component.custom_id && component.value !== undefined) {\n fields[component.custom_id] = String(component.value).slice(0, MAX_MODAL_FIELD_LENGTH);\n }\n }\n }\n ctx.fields = fields;\n }\n\n const result = await handler.execute(ctx);\n\n // Return a modal dialog (only valid for non-modal component handlers)\n if (!isModal && result.modal) {\n return Response.json({\n type: InteractionResponseType.MODAL,\n data: {\n title: result.modal.title,\n custom_id: result.modal.custom_id,\n components: result.modal.components,\n },\n });\n }\n\n const responseType = !isModal && result.updateMessage\n ? InteractionResponseType.UPDATE_MESSAGE\n : InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE;\n const message = result.message || (result.error ? `Error: ${result.error}` : \"Done\");\n\n return Response.json({ type: responseType, data: buildPayload(message, result) });\n } catch (error) {\n logger.error(`[${ref}] ${isModal ? \"Modal\" : \"Component\"} error [${customId}]:`, error);\n const userMsg = error instanceof UserFacingError\n ? error.userMessage\n : `Something went wrong (ref: ${ref})`;\n return ephemeralResponse(`Error: ${userMsg}`);\n }\n}\n\n/**\n * Main entry point for handling Discord interactions.\n * Import and use this in your HTTP endpoint.\n *\n * @example\n * ```typescript\n * import { handleInteraction } from \"../discord/interactions/handler.ts\";\n *\n * export default async function(req: Request): Promise {\n * return handleInteraction(req);\n * }\n * ```\n */\nexport async function handleInteraction(req: Request): Promise {\n try {\n const signature = req.headers.get(\"X-Signature-Ed25519\");\n const timestamp = req.headers.get(\"X-Signature-Timestamp\");\n\n if (!signature || !timestamp) {\n return new Response(\"Missing signature or timestamp\", { status: 401 });\n }\n\n const bodyText = await req.text();\n const isValid = await verifyDiscordRequest(bodyText, signature, timestamp);\n\n if (!isValid) {\n return new Response(\"Invalid signature\", { status: 401 });\n }\n\n let body: any;\n try {\n body = JSON.parse(bodyText);\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n // Guild allowlist check — cache once per request to avoid re-parsing\n const allowedIds = CONFIG.allowedGuildIds;\n if (\n allowedIds.length > 0 &&\n body.type !== INTERACTION_TYPES.PING &&\n (!body.guild_id || !allowedIds.includes(body.guild_id))\n ) {\n return ephemeralResponse(\"This bot is not authorized for this server.\");\n }\n\n switch (body.type) {\n case INTERACTION_TYPES.PING:\n return Response.json({ type: InteractionResponseType.PONG });\n\n case INTERACTION_TYPES.APPLICATION_COMMAND_AUTOCOMPLETE:\n return handleAutocompleteInteraction(body);\n\n case INTERACTION_TYPES.APPLICATION_COMMAND:\n return handleSlashCommandInteraction(body);\n\n case INTERACTION_TYPES.MESSAGE_COMPONENT:\n return handleInteractiveComponent(body, false);\n\n case INTERACTION_TYPES.MODAL_SUBMIT:\n return handleInteractiveComponent(body, true);\n\n default:\n return ephemeralResponse(\"Unsupported interaction type\");\n }\n } catch (error) {\n logger.error(\"Interaction handler error:\", error);\n return Response.json(\n {\n type: InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE,\n data: {\n content: \"An error occurred while processing the interaction\",\n flags: 64,\n },\n },\n { status: 500 },\n );\n }\n}\n\nexport default handleInteraction;\n\nexport const _internals = {\n hexToUint8Array,\n parseSubcommandOptions,\n formatResultMessage,\n buildPayload,\n parseComponentType,\n ephemeralResponse,\n sendFollowup,\n verifyDiscordRequest,\n};\n",[],[172,423,425],"94b4abde-1d6c-11f1-9109-42dde27851f2","components","94b4acba-1d6c-11f1-9109-42dde27851f2",15,["D",1773248761361],[],[172,423,433],"95a98992-1d6c-11f1-87f5-42dde27851f2","schedule_test.ts","95a98a46-1d6c-11f1-87f5-42dde27851f2","94a2fed4-1d6c-11f1-9109-42dde27851f2",43,["D",1773248762958],"import \"../../../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../../../test/assert.ts\";\nimport { sqlite } from \"../../../test/_mocks/sqlite.ts\";\nimport { kv } from \"../../persistence/kv.ts\";\nimport type { ScheduledMessage } from \"./schedule.ts\";\nimport { KV_PREFIX } from \"./schedule.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nconst ADMIN_PERMISSIONS = \"8\"; // ADMINISTRATOR bit\n\nDeno.test(\"schedule send: invalid time returns error\", async () => {\n resetStore();\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g1\",\n userId: \"u1\",\n options: { subcommand: \"send\", channel: \"c1\", time: \"nope\", message: \"hi\" },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, false);\n assert(result.error?.includes(\"Invalid time\"));\n});\n\nDeno.test(\"schedule send: creates entry\", async () => {\n resetStore();\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g1\",\n userId: \"u1\",\n options: { subcommand: \"send\", channel: \"c1\", time: \"1h\", message: \"hello world\" },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, true);\n\n const entries = await kv.list(`${KV_PREFIX}g1:`);\n assertEquals(entries.length, 1);\n const msg = entries[0].value as ScheduledMessage;\n assertEquals(msg.content, \"hello world\");\n assertEquals(msg.channelId, \"c1\");\n});\n\nDeno.test(\"schedule list: shows entries\", async () => {\n resetStore();\n const prefix = `${KV_PREFIX}g1:`;\n await kv.set(`${prefix}1234`, {\n guildId: \"g1\",\n channelId: \"c1\",\n content: \"test msg\",\n sendAt: Date.now() + 3600000,\n createdBy: \"u1\",\n createdAt: Date.now(),\n }, Date.now() + 3600000);\n\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g1\",\n userId: \"u1\",\n options: { subcommand: \"list\" },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, true);\n assert(result.message?.includes(\"test msg\"));\n});\n\nDeno.test(\"schedule cancel: removes entry\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:12345`;\n await kv.set(key, {\n guildId: \"g1\",\n channelId: \"c1\",\n content: \"to cancel\",\n sendAt: Date.now() + 3600000,\n createdBy: \"u1\",\n createdAt: Date.now(),\n });\n\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g1\",\n userId: \"u1\",\n options: { subcommand: \"cancel\", id: key },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, true);\n assert(result.message?.includes(\"cancelled\"));\n\n const gone = await kv.get(key);\n assertEquals(gone, null);\n});\n\nDeno.test(\"schedule send: 25-per-guild limit enforced\", async () => {\n resetStore();\n const prefix = `${KV_PREFIX}g1:`;\n for (let i = 0; i < 25; i++) {\n await kv.set(`${prefix}${i}`, {\n guildId: \"g1\",\n channelId: \"c1\",\n content: `msg${i}`,\n sendAt: Date.now() + 3600000,\n createdBy: \"u1\",\n createdAt: Date.now(),\n });\n }\n\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g1\",\n userId: \"u1\",\n options: { subcommand: \"send\", channel: \"c1\", time: \"1h\", message: \"overflow\" },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, false);\n assert(result.error?.includes(\"Maximum 25\"));\n});\n\n// ── Batch 4e tests ──\n\nDeno.test(\"schedule: MAX_SCHEDULED=25 limit enforced with 26th entry\", async () => {\n resetStore();\n const prefix = `${KV_PREFIX}g_lim:`;\n for (let i = 0; i < 25; i++) {\n await kv.set(`${prefix}${i}`, {\n guildId: \"g_lim\",\n channelId: \"c1\",\n content: `msg${i}`,\n sendAt: Date.now() + 3600000,\n createdBy: \"u1\",\n createdAt: Date.now(),\n });\n }\n\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g_lim\",\n userId: \"u1\",\n options: { subcommand: \"send\", channel: \"c1\", time: \"2h\", message: \"26th message\" },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, false);\n assert(result.error?.includes(\"Maximum 25\"));\n // Verify no new entry was created\n const entries = await kv.list(`${prefix}`);\n assertEquals(entries.length, 25);\n});\n\nDeno.test(\"schedule: cancel with invalid key returns error\", async () => {\n resetStore();\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g1\",\n userId: \"u1\",\n options: { subcommand: \"cancel\", id: `${KV_PREFIX}g1:nonexistent-key` },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, false);\n assert(result.error?.includes(\"not found\"));\n});\n\nDeno.test(\"schedule: empty list shows appropriate message\", async () => {\n resetStore();\n const mod = (await import(\"./schedule.ts\")).default;\n const result = await mod.execute({\n guildId: \"g_empty_list\",\n userId: \"u1\",\n options: { subcommand: \"list\" },\n memberRoles: [],\n memberPermissions: ADMIN_PERMISSIONS,\n } as any);\n assertEquals(result.success, true);\n assert(result.message?.includes(\"No scheduled messages\"));\n});\n\nDeno.test(\"schedule: no focused field returns empty autocomplete\", async () => {\n resetStore();\n const mod = (await import(\"./schedule.ts\")).default;\n const resp = await mod.autocomplete!({\n guild_id: \"g1\",\n data: {\n options: [{\n options: [{ name: \"id\", value: \"something\", focused: false }],\n }],\n },\n }, {});\n const data = await resp.json();\n assertEquals(data.data.choices.length, 0);\n});\n",[],[172,423,448,440],"commands","95a189cc-1d6c-11f1-9109-42dde27851f2","remind.ts","95a18a6c-1d6c-11f1-9109-42dde27851f2",42,["D",1773248762842],"/**\n * Remind - Set personal reminders delivered via channel message\n *\n * Usage: /remind duration:1h message:Check the oven\n *\n * File: discord/interactions/commands/remind.ts\n */\n\nimport { defineCommand, OptionTypes } from \"../define-command.ts\";\nimport { kv } from \"../../persistence/kv.ts\";\nimport { parseDuration } from \"../../helpers/duration.ts\";\n\nexport interface Reminder {\n userId: string;\n guildId: string;\n channelId: string;\n message: string;\n dueAt: number;\n createdAt: number;\n retryCount?: number;\n}\n\nconst MAX_REMINDERS_PER_USER = 10;\n\nexport default defineCommand({\n name: \"remind\",\n description: \"Set a personal reminder\",\n\n options: [\n {\n name: \"duration\",\n description: \"When to remind you (e.g. 10m, 1h, 2d)\",\n type: OptionTypes.STRING,\n required: true,\n },\n {\n name: \"message\",\n description: \"What to remind you about\",\n type: OptionTypes.STRING,\n required: true,\n max_length: 500,\n },\n ],\n\n registration: { type: \"guild\" },\n deferred: false,\n\n async execute({ guildId, userId, options }) {\n const durationStr = options.duration as string;\n const message = options.message as string;\n const channelId = options.channelId as string;\n\n const ms = parseDuration(durationStr);\n if (!ms) {\n return { success: false, error: \"Invalid duration. Use formats like `10m`, `1h`, `2d`, `1d12h`. Max 30 days.\" };\n }\n\n // Check user's active reminder count (scoped prefix avoids scanning all reminders)\n const userReminders = await kv.list(`reminder:${userId}:`);\n if (userReminders.length >= MAX_REMINDERS_PER_USER) {\n return { success: false, error: `You can have at most ${MAX_REMINDERS_PER_USER} active reminders.` };\n }\n\n const now = Date.now();\n const dueAt = now + ms;\n const randomSuffix = crypto.randomUUID().slice(0, 8);\n\n const reminder: Reminder = {\n userId,\n guildId,\n channelId,\n message,\n dueAt,\n createdAt: now,\n };\n\n await kv.set(`reminder:${userId}:${guildId}:${now}-${randomSuffix}`, reminder, dueAt);\n\n const unixSeconds = Math.floor(dueAt / 1000);\n return { success: true, message: `Reminder set! I'll remind you .` };\n },\n});\n",[],[172,423,448,450],"959522fe-1d6c-11f1-b8a3-42dde27851f2","poll.ts","959523a8-1d6c-11f1-b8a3-42dde27851f2",41,["D",1773248762806],"/**\n * Polls - Admin command for running button-based polls\n *\n * Subcommands:\n * /poll create [duration]\n * /poll end\n *\n * File: discord/interactions/commands/poll.ts\n */\n\nimport { defineCommand, OptionTypes } from \"../define-command.ts\";\nimport { EmbedColors } from \"../../constants.ts\";\nimport { kv } from \"../../persistence/kv.ts\";\nimport { discordBotFetch } from \"../../discord-api.ts\";\nimport { parseDuration } from \"../../helpers/duration.ts\";\nimport { createLogger } from \"../../webhook/logger.ts\";\n\nconst logger = createLogger(\"Poll\");\n\nexport interface PollConfig {\n question: string;\n options: string[];\n votes: Record; // { odUserId: optionIndex }\n channelId: string;\n messageId: string;\n createdBy: string;\n endsAt: number;\n ended: boolean;\n lastPanelUpdate?: number;\n announceFailed?: boolean;\n announceRetries?: number;\n}\n\nconst DEFAULT_POLL_DURATION_MS = 7 * 24 * 60 * 60 * 1000; // 7 days\nconst MAX_POLL_DURATION_MS = 30 * 24 * 60 * 60 * 1000; // 30 days\nconst MAX_OPTION_LENGTH = 80;\nconst CLEANUP_DELAY_MS = 24 * 60 * 60 * 1000; // 24 hours\nconst ANNOUNCE_RETRY_DELAY_MS = 15 * 60 * 1000; // 15 minutes\nexport const MAX_ANNOUNCE_RETRIES = 3;\n\nexport function pollKey(guildId: string): string {\n return `poll:${guildId}`;\n}\n\nfunction countVotes(votes: Record, optionCount: number): number[] {\n const counts = new Array(optionCount).fill(0);\n for (const idx of Object.values(votes)) {\n if (idx >= 0 && idx < optionCount) counts[idx]++;\n }\n return counts;\n}\n\nfunction buildPollEmbed(config: PollConfig, ended = false) {\n const counts = countVotes(config.votes, config.options.length);\n const totalVotes = Object.keys(config.votes).length;\n\n const optionLines = config.options.map((opt, i) => {\n if (ended && totalVotes > 0) {\n const pct = Math.round((counts[i] / totalVotes) * 100);\n const barLen = Math.round(pct / 10);\n const bar = \"█\".repeat(barLen) + \"░\".repeat(10 - barLen);\n return `${bar} **${opt}** — ${counts[i]} vote${counts[i] !== 1 ? \"s\" : \"\"} (${pct}%)`;\n }\n return `🔵 **${opt}** — ${counts[i]} vote${counts[i] !== 1 ? \"s\" : \"\"}`;\n });\n\n const timeText = `Ends `;\n\n const description = [\n ...optionLines,\n \"\",\n `Total votes: ${totalVotes}`,\n ended ? \"\" : timeText,\n ].filter((line) => line !== \"\" || !ended).join(\"\\n\");\n\n return {\n title: ended ? \"📊 Poll Results\" : `📊 ${config.question}`,\n description: ended ? `**${config.question}**\\n\\n${description}` : description,\n color: ended ? EmbedColors.WARNING : EmbedColors.INFO,\n footer: { text: ended ? \"Poll ended\" : \"Click a button to vote\" },\n };\n}\n\nexport function buildPollComponents(guildId: string, options: string[], ended = false) {\n if (ended) return [];\n\n const buttons = options.map((opt, i) => ({\n type: 2,\n style: 1, // PRIMARY\n label: opt.length > 80 ? opt.slice(0, 77) + \"...\" : opt,\n custom_id: `poll-vote:${guildId}:${i}`,\n }));\n\n // Split into action rows of max 5 buttons each\n const rows = [];\n for (let i = 0; i < buttons.length; i += 5) {\n rows.push({ type: 1, components: buttons.slice(i, i + 5) });\n }\n return rows;\n}\n\n/**\n * Attempt to send the poll results announcement (embed update).\n * Returns true if the Discord API call succeeded.\n */\nexport async function announcePoll(guildId: string, config: PollConfig): Promise {\n const patchResult = await discordBotFetch(\"PATCH\", `channels/${config.channelId}/messages/${config.messageId}`, {\n embeds: [buildPollEmbed(config, true)],\n components: buildPollComponents(guildId, config.options, true),\n });\n if (!patchResult.ok) {\n logger.error(`Failed to update panel for ${guildId}: ${patchResult.error}`);\n return false;\n }\n return true;\n}\n\nexport async function endPoll(guildId: string): Promise {\n const key = pollKey(guildId);\n\n // Atomically claim the poll — only one caller can transition ended to true\n // Set announceFailed:true as a fail-safe so crash between claim and announce is retried by cron\n const config = await kv.claimUpdate(key, (current) => {\n if (current.ended) return null; // already ended, don't claim\n return { ...current, ended: true, announceFailed: true, announceRetries: 0 };\n });\n\n if (!config) return; // no poll, already ended, or lost race\n\n const announced = await announcePoll(guildId, config);\n if (announced) {\n // Success — clear fail-safe flag and schedule cleanup\n const { announceFailed: _, announceRetries: __, ...clean } = config;\n try {\n await kv.set(key, clean, Date.now() + CLEANUP_DELAY_MS);\n } catch {\n logger.error(`Failed to clear announceFailed flag for poll ${guildId}`);\n }\n } else {\n // Override with retry schedule so the cron re-attempts the announcement\n // announceFailed is already set from claimUpdate\n try {\n await kv.set(key, config, Date.now() + ANNOUNCE_RETRY_DELAY_MS);\n } catch {\n logger.error(`Failed to schedule announce retry for poll ${guildId}`);\n }\n }\n}\n\nexport { buildPollEmbed };\n\nexport default defineCommand({\n name: \"poll\",\n description: \"Admin: Run polls with button voting\",\n\n options: [\n {\n name: \"create\",\n description: \"Start a new poll\",\n type: OptionTypes.SUB_COMMAND,\n required: false,\n options: [\n {\n name: \"question\",\n description: \"The poll question\",\n type: OptionTypes.STRING,\n required: true,\n max_length: 256,\n },\n {\n name: \"options\",\n description: \"Comma-separated choices (2–10)\",\n type: OptionTypes.STRING,\n required: true,\n },\n {\n name: \"channel\",\n description: \"Channel to post the poll in\",\n type: OptionTypes.CHANNEL,\n required: true,\n },\n {\n name: \"duration\",\n description: \"Auto-end time (e.g. 1h, 2d). Default: 7 days, max: 30 days.\",\n type: OptionTypes.STRING,\n required: false,\n },\n ],\n },\n {\n name: \"end\",\n description: \"End the active poll and show results\",\n type: OptionTypes.SUB_COMMAND,\n required: false,\n },\n ],\n\n registration: { type: \"guild\" },\n adminOnly: true,\n ephemeral: false,\n\n async execute({ guildId, userId, options }) {\n const sub = options?.subcommand as string | undefined;\n\n if (sub === \"create\") {\n const question = options.question as string;\n const optionsStr = options.options as string;\n const channelId = options.channel as string;\n const durationStr = options.duration as string | undefined;\n\n // Parse and validate options\n const choices = optionsStr.split(\",\").map((s) => {\n const trimmed = s.trim();\n return trimmed.length > MAX_OPTION_LENGTH\n ? trimmed.slice(0, MAX_OPTION_LENGTH - 3) + \"...\"\n : trimmed;\n }).filter(Boolean);\n if (choices.length < 2) {\n return { success: false, error: \"Provide at least 2 comma-separated options.\" };\n }\n if (choices.length > 10) {\n return { success: false, error: \"Maximum 10 options allowed.\" };\n }\n const uniqueChoices = new Set(choices.map((c) => c.toLowerCase()));\n if (uniqueChoices.size !== choices.length) {\n return { success: false, error: \"Duplicate options are not allowed.\" };\n }\n\n // Parse optional duration (default 7 days, max 30 days)\n let durationMs = DEFAULT_POLL_DURATION_MS;\n if (durationStr) {\n const ms = parseDuration(durationStr);\n if (!ms || ms > MAX_POLL_DURATION_MS) {\n return { success: false, error: \"Invalid duration. Use formats like `1h`, `30m`, `2d`, `1d12h`. Max 30 days.\" };\n }\n durationMs = ms;\n }\n const endsAt = Date.now() + durationMs;\n\n // Check for existing active poll\n const existing = await kv.get(pollKey(guildId));\n if (existing && !existing.ended) {\n return { success: false, error: \"There's already an active poll. Use `/poll end` first.\" };\n }\n\n const config: PollConfig = {\n question,\n options: choices,\n votes: {},\n channelId,\n messageId: \"\",\n createdBy: userId,\n endsAt,\n ended: false,\n };\n\n // Post poll panel\n const post = await discordBotFetch(\"POST\", `channels/${channelId}/messages`, {\n embeds: [buildPollEmbed(config)],\n components: buildPollComponents(guildId, choices),\n });\n\n if (!post.ok) {\n logger.error(`[guild:${guildId} channel:${channelId}] Failed to post: ${post.error}`);\n return { success: false, error: \"Failed to post poll. The bot may lack permissions in that channel.\" };\n }\n\n config.messageId = post.data.id;\n\n // Race guard: re-check after posting (narrows TOCTOU to microseconds)\n const raceCheck = await kv.get(pollKey(guildId));\n if (raceCheck && !raceCheck.ended) {\n // Another admin created one while we were posting — clean up orphaned message\n await discordBotFetch(\"DELETE\", `channels/${channelId}/messages/${config.messageId}`).catch((err) => logger.warn(\"Failed to clean up orphaned poll message:\", err));\n return { success: false, error: \"A poll was just created by another admin. Please try again.\" };\n }\n\n await kv.set(pollKey(guildId), config, config.endsAt);\n\n return { success: true, message: `Poll started in <#${channelId}>! Ends .` };\n }\n\n if (sub === \"end\") {\n const config = await kv.get(pollKey(guildId));\n if (!config || config.ended) {\n return { success: false, error: \"No active poll to end.\" };\n }\n\n await endPoll(guildId);\n const totalVotes = Object.keys(config.votes).length;\n return { success: true, message: `Poll ended! ${totalVotes} total vote${totalVotes !== 1 ? \"s\" : \"\"}.` };\n }\n\n return { success: false, error: \"Please use a subcommand: create or end.\" };\n },\n});\n",[],[172,423,448,458],"95b0b5aa-1d6c-11f1-b12b-42dde27851f2","leaderboard.ts","95b0b668-1d6c-11f1-b12b-42dde27851f2",44,["D",1773248762910],"/**\n * Leaderboard Command — Top coin holders in the server\n *\n * File: discord/interactions/commands/leaderboard.ts\n */\n\nimport { defineCommand, OptionTypes } from \"../define-command.ts\";\nimport { accounts } from \"../../games/accounts.ts\";\nimport { gamesConfig } from \"../../games/games-config.ts\";\nimport { xp } from \"../../games/xp.ts\";\nimport { embed } from \"../../helpers/embed-builder.ts\";\nimport { EmbedColors } from \"../../constants.ts\";\n\nconst PAGE_SIZE = 10;\n\nexport default defineCommand({\n name: \"leaderboard\",\n description: \"View the top coin holders\",\n\n options: [\n {\n name: \"page\",\n description: \"Page number (default: 1)\",\n type: OptionTypes.INTEGER,\n required: false,\n },\n ],\n\n registration: { type: \"guild\" },\n deferred: true,\n ephemeral: false,\n\n async execute({ guildId, options }) {\n const page = Math.max(1, (options?.page as number) ?? 1);\n const config = await gamesConfig.get(guildId);\n const allAccounts = await accounts.listAccounts(guildId);\n\n if (allAccounts.length === 0) {\n return { success: true, message: \"No one has any coins yet!\" };\n }\n\n const totalPages = Math.ceil(allAccounts.length / PAGE_SIZE);\n const safePage = Math.min(page, totalPages);\n const start = (safePage - 1) * PAGE_SIZE;\n const pageAccounts = allAccounts.slice(start, start + PAGE_SIZE);\n\n // Batch-fetch levels for users on this page (avoids N+1 queries)\n const levelMap = await xp.getLevels(guildId, pageAccounts.map((a) => a.userId));\n\n const lines = pageAccounts.map((a, i) => {\n const rank = start + i + 1;\n const medal = rank === 1 ? \" :first_place:\" : rank === 2 ? \" :second_place:\" : rank === 3 ? \" :third_place:\" : \"\";\n const lvl = levelMap.get(a.userId) ?? 0;\n return `**${rank}.** <@${a.userId}> Lv.${lvl} — **${a.balance.toLocaleString()}** ${config.currencyName}${medal}`;\n });\n\n const e = embed()\n .title(`${config.currencyEmoji} Leaderboard`)\n .description(lines.join(\"\\n\"))\n .color(EmbedColors.INFO)\n .footer(`Page ${safePage}/${totalPages} • ${allAccounts.length} total users`)\n .build();\n\n return { success: true, embed: e };\n },\n});\n\nexport const _internals = { PAGE_SIZE };\n",[],[172,423,448,466],"958d3404-1d6c-11f1-bd35-42dde27851f2","help_test.ts","958d34d6-1d6c-11f1-bd35-42dde27851f2",40,["D",1773248762567],"import \"../../../test/_mocks/env.ts\";\nimport \"../../../test/_mocks/sqlite.ts\";\nimport { assertEquals, assert, assertStringIncludes } from \"../../../test/assert.ts\";\nimport { EmbedColors } from \"../../../discord/constants.ts\";\nimport help from \"./help.ts\";\n\nDeno.test(\"help: returns embed with Available Commands title\", async () => {\n const result = await help.execute({\n guildId: \"123\",\n userId: \"456\",\n options: {},\n config: {},\n });\n assertEquals(result.success, true);\n assert(result.embed);\n assertEquals(result.embed!.title, \"Available Commands\");\n});\n\nDeno.test(\"help: filters out adminOnly commands\", async () => {\n const result = await help.execute({\n guildId: \"123\",\n userId: \"456\",\n options: {},\n config: {},\n });\n const desc = result.embed!.description!;\n // \"server\" is adminOnly, should not appear\n assert(!desc.includes(\"/server\"), \"adminOnly commands should be filtered out\");\n});\n\nDeno.test(\"help: commands are sorted alphabetically\", async () => {\n const result = await help.execute({\n guildId: \"123\",\n userId: \"456\",\n options: {},\n config: {},\n });\n const desc = result.embed!.description!;\n const names = desc.split(\"\\n\").map((line: string) => {\n const match = line.match(/\\*\\*\\/(.+?)\\*\\*/);\n return match ? match[1] : \"\";\n }).filter(Boolean);\n const sorted = [...names].sort((a, b) => a.localeCompare(b));\n assertEquals(names, sorted);\n});\n\nDeno.test(\"help: embed uses INFO color\", async () => {\n const result = await help.execute({\n guildId: \"123\",\n userId: \"456\",\n options: {},\n config: {},\n });\n assertEquals(result.embed!.color, EmbedColors.INFO);\n});\n",[],[172,423,448,474],"9576a860-1d6c-11f1-a490-42dde27851f2","color-picker.ts","9576a932-1d6c-11f1-a490-42dde27851f2",38,["D",1773248762558],"/**\n * Color Picker Command - Demonstrates select menu components\n *\n * File: discord/interactions/commands/color-picker.ts\n */\n\nimport { defineCommand } from \"../define-command.ts\";\n\nexport default defineCommand({\n name: \"color-picker\",\n description: \"Pick a color from a dropdown menu\",\n\n registration: { type: \"guild\" },\n deferred: false,\n ephemeral: false,\n\n async execute() {\n return {\n success: true,\n message: \"Choose a color:\",\n components: [\n {\n type: 1, // Action Row\n components: [\n {\n type: 3, // String Select\n custom_id: \"color-select\",\n placeholder: \"Select a color...\",\n options: [\n { label: \"Red\", value: \"red\", emoji: { name: \"\\uD83D\\uDD34\" } },\n { label: \"Green\", value: \"green\", emoji: { name: \"\\uD83D\\uDFE2\" } },\n { label: \"Blue\", value: \"blue\", emoji: { name: \"\\uD83D\\uDD35\" } },\n { label: \"Yellow\", value: \"yellow\", emoji: { name: \"\\uD83D\\uDFE1\" } },\n ],\n },\n ],\n },\n ],\n };\n },\n});\n",[],[172,423,448,482],"9587274e-1d6c-11f1-ac6f-42dde27851f2","balance.ts","9587280c-1d6c-11f1-ac6f-42dde27851f2",39,["D",1773248762696],"/**\n * Balance Command — Check your coins or another user's balance\n *\n * File: discord/interactions/commands/balance.ts\n */\n\nimport { defineCommand, OptionTypes } from \"../define-command.ts\";\nimport { accounts } from \"../../games/accounts.ts\";\nimport { gamesConfig } from \"../../games/games-config.ts\";\nimport { embed } from \"../../helpers/embed-builder.ts\";\nimport { EmbedColors } from \"../../constants.ts\";\n\nexport default defineCommand({\n name: \"balance\",\n description: \"Check your coin balance\",\n\n options: [\n {\n name: \"user\",\n description: \"User to check (default: yourself)\",\n type: OptionTypes.USER,\n required: false,\n },\n ],\n\n registration: { type: \"guild\" },\n deferred: false,\n ephemeral: true,\n\n async execute({ guildId, userId, options }) {\n const targetId = (options?.user as string) ?? userId;\n const isSelf = targetId === userId;\n const config = await gamesConfig.get(guildId);\n const account = await accounts.getOrCreate(guildId, targetId, config.startingBalance);\n\n const e = embed()\n .title(`${config.currencyEmoji} Balance`)\n .color(EmbedColors.INFO)\n .field(\"Balance\", `${account.balance.toLocaleString()} ${config.currencyName}`, true)\n .field(\"Lifetime Earned\", `${account.lifetimeEarned.toLocaleString()} ${config.currencyName}`, true)\n .footer(isSelf ? \"Your balance\" : `Balance for <@${targetId}>`)\n .build();\n\n return { success: true, embed: e };\n },\n});\n",[],[172,423,448,490],"94a2fe16-1d6c-11f1-9109-42dde27851f2",14,["D",1773248761250],[195,196,197,198,199,200,201],[172,423,448],"944202a0-1d6c-11f1-8f18-42dde27851f2",7,["D",1773248760616],[194,202,203,204],[172,423],"9475e9bc-1d6c-11f1-ac6f-42dde27851f2","helpers","9475eb06-1d6c-11f1-ac6f-42dde27851f2",11,["D",1773248760955],[],[172,508],"94dac09e-1d6c-11f1-9ac8-42dde27851f2","casino","94dac184-1d6c-11f1-9ac8-42dde27851f2","945b77c6-1d6c-11f1-8f18-42dde27851f2",17,["D",1773248761616],[],[172,522,515],"games","945b76fe-1d6c-11f1-8f18-42dde27851f2",9,["D",1773248760783],[191],[172,522],["D",1773248760319],[190,192,193,205,207,208,211],[172],["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":569,"_570":571,"_572":573,"_574":24,"_575":24,"_576":24,"_577":123,"_578":-5,"_579":-7,"_580":-7,"_581":60,"_582":24,"_583":24,"_584":-5,"_585":24,"_586":24,"_587":24,"_588":-5},"ENV",{"_540":541,"_542":543,"_544":87,"_545":546,"_547":548,"_549":550,"_551":552,"_553":554,"_555":556,"_557":558,"_559":560,"_561":562,"_563":564,"_565":566,"_567":568},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v45