[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_446":447,"_448":449},"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",35,"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.ts","latestPath","fileId","955565c4-1d6c-11f1-a9cb-42dde27851f2","name","stream-platforms.ts","fileType","script","content","/**\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","createdAt",["D",1773248762421],"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=1789590643&sig=2eec2c1e4d8af3bb54107963b801d9cde1228ff7911d3a88a275fe61cea87ee9","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":441,"_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":442,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":443,"_81":444,"_83":445,"_85":24},"tree",[189,202,217,219,220,221],"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],"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":438,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":439,"_26":440},{"_42":433,"_31":432,"_29":427,"_137":173,"_40":41,"_39":434,"_139":123,"_37":435,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":436,"_26":437},{"_42":424,"_31":425,"_29":426,"_137":427,"_40":41,"_39":428,"_139":123,"_37":429,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":430,"_26":431},{"_42":417,"_31":418,"_29":419,"_137":173,"_40":41,"_39":420,"_139":123,"_37":421,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":422,"_26":423},{"_42":412,"_31":404,"_29":399,"_137":173,"_40":41,"_39":413,"_139":123,"_37":414,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":415,"_26":416},{"_42":405,"_31":406,"_29":407,"_137":399,"_40":41,"_39":408,"_139":123,"_37":409,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":410,"_26":411},{"_42":396,"_31":397,"_29":398,"_137":399,"_40":41,"_39":400,"_139":123,"_37":401,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":402,"_26":403},{"_42":392,"_31":391,"_29":386,"_137":173,"_40":41,"_39":187,"_139":123,"_37":393,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":394,"_26":395},{"_42":383,"_31":384,"_29":385,"_137":386,"_40":41,"_39":387,"_139":123,"_37":388,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":389,"_26":390},{"_42":376,"_31":377,"_29":378,"_137":173,"_40":41,"_39":379,"_139":123,"_37":380,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":381,"_26":382},{"_42":371,"_31":166,"_29":367,"_137":173,"_40":41,"_39":372,"_139":123,"_37":373,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":374,"_26":375},{"_42":366,"_31":32,"_29":30,"_137":367,"_40":41,"_39":14,"_139":123,"_37":368,"_13":60,"_33":34,"_35":36,"_23":24,"_142":-5,"_223":369,"_26":370},{"_42":359,"_31":360,"_29":361,"_137":173,"_40":41,"_39":362,"_139":123,"_37":363,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":364,"_26":365},{"_42":165,"_31":166,"_29":167,"_137":-5,"_40":41,"_39":168,"_139":123,"_37":356,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":357,"_26":358},{"_42":348,"_31":349,"_29":350,"_137":167,"_40":41,"_39":351,"_139":24,"_37":352,"_13":60,"_33":247,"_35":353,"_23":24,"_142":-5,"_223":354,"_26":355},{"_42":340,"_31":341,"_29":342,"_137":167,"_40":41,"_39":343,"_139":24,"_37":344,"_13":60,"_33":247,"_35":345,"_23":24,"_142":-5,"_223":346,"_26":347},{"_42":332,"_31":333,"_29":334,"_137":167,"_40":41,"_39":335,"_139":24,"_37":336,"_13":60,"_33":247,"_35":337,"_23":24,"_142":-5,"_223":338,"_26":339},{"_42":324,"_31":325,"_29":326,"_137":167,"_40":41,"_39":327,"_139":24,"_37":328,"_13":60,"_33":320,"_35":329,"_23":24,"_142":44,"_223":330,"_26":331},{"_42":315,"_31":316,"_29":317,"_137":167,"_40":41,"_39":318,"_139":24,"_37":319,"_13":60,"_33":320,"_35":321,"_23":24,"_142":-5,"_223":322,"_26":323},{"_42":307,"_31":308,"_29":309,"_137":167,"_40":41,"_39":310,"_139":24,"_37":311,"_13":60,"_33":247,"_35":312,"_23":24,"_142":-5,"_223":313,"_26":314},{"_42":299,"_31":300,"_29":301,"_137":167,"_40":41,"_39":302,"_139":24,"_37":303,"_13":60,"_33":247,"_35":304,"_23":24,"_142":-5,"_223":305,"_26":306},{"_42":291,"_31":292,"_29":293,"_137":167,"_40":41,"_39":294,"_139":24,"_37":295,"_13":60,"_33":247,"_35":296,"_23":24,"_142":-5,"_223":297,"_26":298},{"_42":283,"_31":284,"_29":285,"_137":167,"_40":41,"_39":286,"_139":24,"_37":287,"_13":60,"_33":247,"_35":288,"_23":24,"_142":-5,"_223":289,"_26":290},{"_42":275,"_31":276,"_29":277,"_137":167,"_40":41,"_39":278,"_139":24,"_37":279,"_13":60,"_33":247,"_35":280,"_23":24,"_142":-5,"_223":281,"_26":282},{"_42":267,"_31":268,"_29":269,"_137":167,"_40":41,"_39":270,"_139":24,"_37":271,"_13":60,"_33":247,"_35":272,"_23":24,"_142":-5,"_223":273,"_26":274},{"_42":259,"_31":260,"_29":261,"_137":167,"_40":41,"_39":262,"_139":24,"_37":263,"_13":60,"_33":247,"_35":264,"_23":24,"_142":-5,"_223":265,"_26":266},{"_42":251,"_31":252,"_29":253,"_137":167,"_40":41,"_39":254,"_139":24,"_37":255,"_13":60,"_33":247,"_35":256,"_23":24,"_142":-5,"_223":257,"_26":258},{"_42":242,"_31":243,"_29":244,"_137":167,"_40":41,"_39":245,"_139":24,"_37":246,"_13":60,"_33":247,"_35":248,"_23":24,"_142":-5,"_223":249,"_26":250},{"_42":158,"_31":159,"_29":160,"_137":-5,"_40":41,"_39":161,"_139":123,"_37":239,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":240,"_26":241},{"_42":232,"_31":233,"_29":234,"_137":160,"_40":41,"_39":235,"_139":123,"_37":236,"_13":60,"_33":163,"_35":-5,"_23":24,"_142":-5,"_223":237,"_26":238},{"_42":151,"_31":152,"_29":153,"_137":-5,"_40":41,"_39":154,"_139":123,"_37":229,"_13":60,"_33":20,"_35":156,"_23":24,"_142":-5,"_223":230,"_26":231},{"_42":144,"_31":145,"_29":146,"_137":-5,"_40":41,"_39":147,"_139":123,"_37":226,"_13":60,"_33":20,"_35":149,"_23":24,"_142":-5,"_223":227,"_26":228},{"_42":134,"_31":135,"_29":136,"_137":-5,"_40":41,"_39":138,"_139":123,"_37":222,"_13":60,"_33":20,"_35":141,"_23":24,"_142":-5,"_223":224,"_26":225},["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,233],["D",1773248760409],[218],[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,243],"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,252],"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,260],"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,268],"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,276],"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,284],"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,292],"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,300],"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,308],"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,316],"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,325],"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,333],"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,341],"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,349],["D",1773248760230],[203,204,205,206,207,208,209,210,211,212,213,214,215,216],[166],"9468c8d6-1d6c-11f1-8f18-42dde27851f2","webhook","9468c9b2-1d6c-11f1-8f18-42dde27851f2",10,["D",1773248760870],[],[172,360],"9555651a-1d6c-11f1-a9cb-42dde27851f2","94357e68-1d6c-11f1-ac6f-42dde27851f2",["D",1773248762421],[],[172,166,32],"94357d96-1d6c-11f1-ac6f-42dde27851f2",6,["D",1773248760493],[200],[172,166],"94832ec4-1d6c-11f1-9109-42dde27851f2","persistence","94832fe6-1d6c-11f1-9109-42dde27851f2",12,["D",1773248761042],[],[172,377],"94c4b97a-1d6c-11f1-9ac8-42dde27851f2","verifiers","94c4ba6a-1d6c-11f1-9ac8-42dde27851f2","944e9be6-1d6c-11f1-8f18-42dde27851f2",16,["D",1773248761471],[],[172,391,384],"linked-roles","944e9b32-1d6c-11f1-8f18-42dde27851f2",["D",1773248760699],[197],[172,391],"94b4abde-1d6c-11f1-9109-42dde27851f2","components","94b4acba-1d6c-11f1-9109-42dde27851f2","9442037c-1d6c-11f1-8f18-42dde27851f2",15,["D",1773248761361],[],[172,404,397],"interactions","94a2fe16-1d6c-11f1-9109-42dde27851f2","commands","94a2fed4-1d6c-11f1-9109-42dde27851f2",14,["D",1773248761250],[],[172,404,406],"944202a0-1d6c-11f1-8f18-42dde27851f2",7,["D",1773248760616],[194,195],[172,404],"9475e9bc-1d6c-11f1-ac6f-42dde27851f2","helpers","9475eb06-1d6c-11f1-ac6f-42dde27851f2",11,["D",1773248760955],[],[172,418],"94dac09e-1d6c-11f1-9ac8-42dde27851f2","casino","94dac184-1d6c-11f1-9ac8-42dde27851f2","945b77c6-1d6c-11f1-8f18-42dde27851f2",17,["D",1773248761616],[],[172,432,425],"games","945b76fe-1d6c-11f1-8f18-42dde27851f2",9,["D",1773248760783],[191],[172,432],["D",1773248760319],[190,192,193,196,198,199,201],[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":479,"_480":481,"_482":483,"_484":24,"_485":24,"_486":24,"_487":123,"_488":-5,"_489":-7,"_490":-7,"_491":60,"_492":24,"_493":24,"_494":-5,"_495":24,"_496":24,"_497":24,"_498":-5},"ENV",{"_450":451,"_452":453,"_454":87,"_455":456,"_457":458,"_459":460,"_461":462,"_463":464,"_465":466,"_467":468,"_469":470,"_471":472,"_473":474,"_475":476,"_477":478},"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 · v35