[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_310":311,"_312":313},"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",21,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","services/livestreams.cron_test.ts","latestPath","fileId","94f85398-1d6c-11f1-9ac8-42dde27851f2","name","livestreams.cron_test.ts","fileType","interval","content","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","createdAt",["D",1773248761810],"branchVersion","branchId","4db1f610-1d6c-11f1-9a9a-42dde27851f2","id","4db147e2-1d6c-11f1-9a9a-42dde27851f2","catnip",["D",1773248642232],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Open source Discord bot template built for Val Town","imageUrl","d06b6c80-f3a1-11ef-89a3-8735e07158f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","e03963fb-ecc4-48fb-bc25-0173a8b9a8c8","tursoName","4db147e21d6c11f19a9a42dde27851f2","tursoHostname","4db147e21d6c11f19a9a42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789520505489],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":24},"branch",{"_13":86,"_31":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned",367,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","catalloc","handle","displayName","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0478d851-5bca-4d5e-6593-fb952af01c00/square512?exp=1789577999&sig=dd4f84669405a2b44de8df5c2d916f7dbec2110ea5df568b407fe28ffb9967e0","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":305,"_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":306,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":307,"_81":308,"_83":309,"_85":24},"tree",[165,177,182],"files",[165,166,167,168,169,170,171,172,173,174,175,176,177,178,179,180,181,182,183],"counts",{"_153":60,"_154":155,"_156":60,"_157":158,"_159":160},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":147,"_31":148,"_29":149,"_134":-5,"_40":41,"_39":150,"_136":123,"_37":151,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":152},{"_42":141,"_31":142,"_29":143,"_134":-5,"_40":41,"_39":144,"_136":123,"_37":145,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":146},{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":123,"_37":137,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":140},"942269cc-1d6c-11f1-9109-42dde27851f2","test","94226a9e-1d6c-11f1-9109-42dde27851f2","parentId",5,"latest",["D",1773248760409],"directory","label",[132],"94074818-1d6c-11f1-9109-42dde27851f2","services","940748e0-1d6c-11f1-9109-42dde27851f2",3,["D",1773248760230],[142],"9414ade6-1d6c-11f1-9109-42dde27851f2","discord","9414aeb8-1d6c-11f1-9109-42dde27851f2",4,["D",1773248760319],[148],"pulls","branches",1,"forks","envVars",{"_161":163,"_164":60},"connections",{"_161":60,"_162":60},"count","unfilledCount",8,"emptyCount",{"_42":147,"_31":148,"_29":149,"_134":-5,"_40":41,"_39":150,"_136":123,"_37":302,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":303,"_26":304},{"_42":297,"_31":296,"_29":291,"_134":149,"_40":41,"_39":298,"_136":123,"_37":299,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":300,"_26":301},{"_42":288,"_31":289,"_29":290,"_134":291,"_40":41,"_39":292,"_136":123,"_37":293,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":294,"_26":295},{"_42":281,"_31":282,"_29":283,"_134":149,"_40":41,"_39":284,"_136":123,"_37":285,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":286,"_26":287},{"_42":276,"_31":268,"_29":263,"_134":149,"_40":41,"_39":277,"_136":123,"_37":278,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":279,"_26":280},{"_42":269,"_31":270,"_29":271,"_134":263,"_40":41,"_39":272,"_136":123,"_37":273,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":274,"_26":275},{"_42":260,"_31":261,"_29":262,"_134":263,"_40":41,"_39":264,"_136":123,"_37":265,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":266,"_26":267},{"_42":256,"_31":255,"_29":250,"_134":149,"_40":41,"_39":163,"_136":123,"_37":257,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":258,"_26":259},{"_42":247,"_31":248,"_29":249,"_134":250,"_40":41,"_39":251,"_136":123,"_37":252,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":253,"_26":254},{"_42":240,"_31":241,"_29":242,"_134":149,"_40":41,"_39":243,"_136":123,"_37":244,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":245,"_26":246},{"_42":234,"_31":142,"_29":235,"_134":149,"_40":41,"_39":236,"_136":123,"_37":237,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":238,"_26":239},{"_42":227,"_31":228,"_29":229,"_134":149,"_40":41,"_39":230,"_136":123,"_37":231,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":232,"_26":233},{"_42":141,"_31":142,"_29":143,"_134":-5,"_40":41,"_39":144,"_136":123,"_37":224,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":225,"_26":226},{"_42":215,"_31":216,"_29":217,"_134":143,"_40":41,"_39":218,"_136":24,"_37":219,"_13":60,"_33":220,"_35":221,"_23":24,"_139":44,"_189":222,"_26":223},{"_42":211,"_31":32,"_29":30,"_134":143,"_40":41,"_39":14,"_136":24,"_37":212,"_13":60,"_33":34,"_35":36,"_23":24,"_139":-5,"_189":213,"_26":214},{"_42":203,"_31":204,"_29":205,"_134":143,"_40":41,"_39":206,"_136":24,"_37":207,"_13":60,"_33":34,"_35":208,"_23":24,"_139":-5,"_189":209,"_26":210},{"_42":195,"_31":196,"_29":197,"_134":143,"_40":41,"_39":198,"_136":24,"_37":199,"_13":60,"_33":34,"_35":200,"_23":24,"_139":-5,"_189":201,"_26":202},{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":123,"_37":192,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":193,"_26":194},{"_42":184,"_31":185,"_29":186,"_134":133,"_40":41,"_39":187,"_136":123,"_37":188,"_13":60,"_33":138,"_35":-5,"_23":24,"_139":-5,"_189":190,"_26":191},"94922168-1d6c-11f1-9109-42dde27851f2","_mocks","9492226c-1d6c-11f1-9109-42dde27851f2",13,["D",1773248761136],"children",[],[132,185],["D",1773248760409],[183],[132],"94e801dc-1d6c-11f1-9ac8-42dde27851f2","scheduled-messages.cron_test.ts","94e80448-1d6c-11f1-9ac8-42dde27851f2",18,["D",1773248761703],"import \"../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, getCalls, restoreFetch } from \"../test/_mocks/fetch.ts\";\nimport type { ScheduledMessage } from \"../discord/interactions/commands/schedule.ts\";\nimport { KV_PREFIX } from \"../discord/interactions/commands/schedule.ts\";\nimport runCron from \"./scheduled-messages.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makeMessage(overrides?: Partial): ScheduledMessage {\n return {\n guildId: \"g1\",\n channelId: \"c1\",\n content: \"hello\",\n sendAt: Date.now() - 1000,\n createdBy: \"u1\",\n createdAt: Date.now() - 60000,\n ...overrides,\n };\n}\n\nDeno.test(\"scheduled-messages cron: successful delivery cleans up KV\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:1`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 403 drops item permanently\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:2`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 403, body: \"Forbidden\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 404 drops item permanently\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:3`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 404, body: \"Not Found\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: transient failure re-inserts with retryCount\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:4`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on transient failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: drops after MAX_RETRIES\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:5`;\n await kv.set(key, makeMessage({ retryCount: 4 }), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: empty list is no-op\", async () => {\n resetStore();\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: malformed entry (missing channelId) is deleted\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:6`;\n await kv.set(\n key,\n { guildId: \"g1\", content: \"hello\", sendAt: Date.now() - 1000, createdBy: \"u1\", createdAt: Date.now() - 60000 },\n Date.now() - 1000,\n );\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 500 error re-inserts with retryCount\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:7`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 500, body: \"Internal Server Error\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 500 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: 503 error re-inserts\", async () => {\n resetStore();\n const key = `${KV_PREFIX}g1:8`;\n await kv.set(key, makeMessage(), Date.now() - 1000);\n mockFetch({ default: { status: 503, body: \"Service Unavailable\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 503 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"scheduled-messages cron: multiple due messages all processed\", async () => {\n resetStore();\n const keys = [`${KV_PREFIX}g1:9`, `${KV_PREFIX}g1:10`, `${KV_PREFIX}g1:11`];\n for (const key of keys) {\n await kv.set(key, makeMessage(), Date.now() - 1000);\n }\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n for (const key of keys) {\n const remaining = await kv.get(key);\n assertEquals(remaining, null, `${key} should be cleaned up`);\n }\n assert(getCalls().length >= 3, `Expected at least 3 fetch calls, got ${getCalls().length}`);\n } finally {\n restoreFetch();\n }\n});\n",[],[142,196],"94f0ff8a-1d6c-11f1-b767-42dde27851f2","reminders.cron_test.ts","94f10066-1d6c-11f1-b767-42dde27851f2",20,["D",1773248761747],"import \"../test/_mocks/env.ts\";\nimport { assertEquals, assert } from \"../test/assert.ts\";\nimport { sqlite } from \"../test/_mocks/sqlite.ts\";\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport { mockFetch, getCalls, restoreFetch } from \"../test/_mocks/fetch.ts\";\nimport type { Reminder } from \"../discord/interactions/commands/remind.ts\";\nimport runCron from \"./reminders.cron.ts\";\n\nfunction resetStore() {\n (sqlite as any)._reset();\n}\n\nfunction makeReminder(overrides?: Partial): Reminder {\n return {\n userId: \"u1\",\n guildId: \"g1\",\n channelId: \"c1\",\n message: \"test\",\n dueAt: Date.now() - 1000,\n createdAt: Date.now() - 60000,\n ...overrides,\n };\n}\n\nDeno.test(\"reminders cron: successful delivery cleans up KV\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:1\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 403 drops item permanently\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:2\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 403, body: \"Forbidden\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 404 drops item permanently\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:3\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 404, body: \"Not Found\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: transient failure re-inserts with retryCount\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:4\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n // After 5xx, discordBotFetch retries internally (2 attempts), then returns error\n // Cron should re-insert with retryCount\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on transient failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: drops after MAX_RETRIES\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:5\";\n await kv.set(key, makeReminder({ retryCount: 4 }), Date.now() - 1000);\n mockFetch({ default: { status: 502, body: \"Bad Gateway\" } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: empty list is no-op\", async () => {\n resetStore();\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: malformed reminder (missing channelId) is deleted\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:6\";\n await kv.set(\n key,\n { userId: \"u1\", guildId: \"g1\", message: \"test\", dueAt: Date.now() - 1000, createdAt: Date.now() - 60000 },\n Date.now() - 1000,\n );\n mockFetch({ default: { status: 200, body: {} } });\n try {\n await runCron();\n const remaining = await kv.get(key);\n assertEquals(remaining, null);\n assertEquals(getCalls().length, 0);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 500 error re-inserts with retryCount\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:7\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 500, body: \"Internal Server Error\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 500 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: 503 error re-inserts\", async () => {\n resetStore();\n const key = \"reminder:u1:g1:8\";\n await kv.set(key, makeReminder(), Date.now() - 1000);\n mockFetch({ default: { status: 503, body: \"Service Unavailable\" } });\n try {\n await runCron();\n const entry = await kv.get(key);\n assert(entry !== null, \"Should re-insert on 503 failure\");\n assertEquals(entry!.retryCount, 1);\n } finally {\n restoreFetch();\n }\n});\n\nDeno.test(\"reminders cron: multiple due reminders all processed\", async () => {\n resetStore();\n const keys = [\"reminder:u1:g1:9\", \"reminder:u1:g1:10\", \"reminder:u1:g1:11\"];\n for (const key of keys) {\n await kv.set(key, makeReminder(), Date.now() - 1000);\n }\n mockFetch({ default: { status: 200, body: { id: \"msg1\" } } });\n try {\n await runCron();\n for (const key of keys) {\n const remaining = await kv.get(key);\n assertEquals(remaining, null, `${key} should be cleaned up`);\n }\n assert(getCalls().length >= 3, `Expected at least 3 fetch calls, got ${getCalls().length}`);\n } finally {\n restoreFetch();\n }\n});\n",[],[142,204],"94f852da-1d6c-11f1-9ac8-42dde27851f2",["D",1773248761810],[],[142,32],"94eda22c-1d6c-11f1-9ac8-42dde27851f2","interactions.http.ts","94eda2f4-1d6c-11f1-9ac8-42dde27851f2",19,["D",1773248761741],"http","/**\n * services/interactions.http.ts\n *\n * Discord interactions HTTP endpoint.\n *\n * GET paths:\n * /terms — Terms of Service page\n * /privacy — Privacy Policy page\n * /invite — Auth-gated invite page (Bearer token required)\n * /linked-roles — Linked Roles OAuth2 redirect\n * /linked-roles/callback — Linked Roles OAuth2 callback\n *\n * GET params (root):\n * ?discover=true — scan project files, save manifest to KV\n * ?register=true — bulk-register all commands with Discord\n * ?register-metadata=true — push linked roles metadata schema to Discord\n * (none) — health check (status, command count, interaction count)\n *\n * POST paths:\n * /patreon/webhook — Patreon webhook handler (signature-verified)\n * (default) — Discord interaction handler (signature-verified)\n */\n\nimport { handleInteraction } from \"../discord/interactions/handler.ts\";\nimport { getFailedImports } from \"../discord/interactions/registry.ts\";\nimport { syncAllGuilds } from \"../discord/interactions/registration.ts\";\nimport { discover } from \"../discord/interactions/auto-discover.ts\";\nimport { CONFIG } from \"../discord/constants.ts\";\nimport { termsPage, privacyPage, invitePage } from \"../discord/pages.ts\";\nimport { handleLinkedRolesRedirect, handleLinkedRolesCallback } from \"../discord/linked-roles/routes.ts\";\nimport { registerMetadataSchema } from \"../discord/linked-roles/register-metadata.ts\";\nimport { handlePatreonWebhook } from \"../discord/linked-roles/patreon-webhook.ts\";\nimport { timingSafeEqual } from \"../discord/helpers/crypto.ts\";\nimport { createLogger, finalizeAllLoggers } from \"../discord/webhook/logger.ts\";\nimport \"../discord/linked-roles/verifiers/always-verified.ts\"; // side-effect: registers verifier\n\nconst logger = createLogger(\"HTTP\");\n\nasync function checkPassword(req: Request): Promise {\n const password = CONFIG.adminPassword;\n if (!password) {\n return Response.json({ error: \"Forbidden: admin password not configured\" }, { status: 403 });\n }\n const header = req.headers.get(\"Authorization\");\n const token = header?.startsWith(\"Bearer \") ? header.slice(7) : null;\n if (!token || !(await timingSafeEqual(token, password))) {\n return Response.json({ error: \"Unauthorized\" }, { status: 401 });\n }\n return null;\n}\n\nexport default async function(req: Request): Promise {\n try {\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\"); // strip trailing slashes\n\n if (path === \"/terms\") return termsPage();\n if (path === \"/privacy\") return privacyPage();\n if (path === \"/invite\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n return invitePage(CONFIG.appId);\n }\n if (path === \"/linked-roles\") return handleLinkedRolesRedirect(req);\n if (path === \"/linked-roles/callback\") return handleLinkedRolesCallback(req);\n\n if (url.searchParams.get(\"register\") === \"true\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n try {\n const results = await syncAllGuilds();\n const ok = results.filter((r) => r.success);\n const fail = results.filter((r) => !r.success);\n return Response.json({ registered: ok.length, failed: fail.length, results });\n } catch (err) {\n logger.error(\"Registration failed:\", err);\n return Response.json({ error: \"Registration failed\" }, { status: 500 });\n }\n }\n\n if (url.searchParams.get(\"register-metadata\") === \"true\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n try {\n const result = await registerMetadataSchema();\n return Response.json(result, { status: result.ok ? 200 : 500 });\n } catch (err) {\n logger.error(\"Metadata registration failed:\", err);\n return Response.json({ error: \"Metadata registration failed\" }, { status: 500 });\n }\n }\n\n if (url.searchParams.get(\"discover\") === \"true\") {\n const authError = await checkPassword(req);\n if (authError) return authError;\n try {\n const manifest = await discover(import.meta.url);\n return Response.json({\n commands: manifest.commands.length,\n components: manifest.components.length,\n manifest,\n });\n } catch (err) {\n logger.error(\"Discovery failed:\", err);\n return Response.json({ error: \"Discovery failed\" }, { status: 500 });\n }\n }\n\n const failedImports = getFailedImports();\n return Response.json({\n status: failedImports.length > 0 ? \"degraded\" : \"ok\",\n });\n }\n\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\");\n\n if (path === \"/patreon/webhook\") {\n return handlePatreonWebhook(req);\n }\n\n return handleInteraction(req);\n } catch (err) {\n logger.error(\"Unhandled request error:\", err);\n return Response.json({ error: \"Internal server error\" }, { status: 500 });\n } finally {\n // Flush any buffered logs before the isolate terminates\n await finalizeAllLoggers();\n }\n}\n",[],[142,216],["D",1773248760230],[178,179,180,181],[142],"9468c8d6-1d6c-11f1-8f18-42dde27851f2","webhook","9468c9b2-1d6c-11f1-8f18-42dde27851f2",10,["D",1773248760870],[],[148,228],"94357d96-1d6c-11f1-ac6f-42dde27851f2","94357e68-1d6c-11f1-ac6f-42dde27851f2",6,["D",1773248760493],[],[148,142],"94832ec4-1d6c-11f1-9109-42dde27851f2","persistence","94832fe6-1d6c-11f1-9109-42dde27851f2",12,["D",1773248761042],[],[148,241],"94c4b97a-1d6c-11f1-9ac8-42dde27851f2","verifiers","94c4ba6a-1d6c-11f1-9ac8-42dde27851f2","944e9be6-1d6c-11f1-8f18-42dde27851f2",16,["D",1773248761471],[],[148,255,248],"linked-roles","944e9b32-1d6c-11f1-8f18-42dde27851f2",["D",1773248760699],[173],[148,255],"94b4abde-1d6c-11f1-9109-42dde27851f2","components","94b4acba-1d6c-11f1-9109-42dde27851f2","9442037c-1d6c-11f1-8f18-42dde27851f2",15,["D",1773248761361],[],[148,268,261],"interactions","94a2fe16-1d6c-11f1-9109-42dde27851f2","commands","94a2fed4-1d6c-11f1-9109-42dde27851f2",14,["D",1773248761250],[],[148,268,270],"944202a0-1d6c-11f1-8f18-42dde27851f2",7,["D",1773248760616],[170,171],[148,268],"9475e9bc-1d6c-11f1-ac6f-42dde27851f2","helpers","9475eb06-1d6c-11f1-ac6f-42dde27851f2",11,["D",1773248760955],[],[148,282],"94dac09e-1d6c-11f1-9ac8-42dde27851f2","casino","94dac184-1d6c-11f1-9ac8-42dde27851f2","945b77c6-1d6c-11f1-8f18-42dde27851f2",17,["D",1773248761616],[],[148,296,289],"games","945b76fe-1d6c-11f1-8f18-42dde27851f2",9,["D",1773248760783],[167],[148,296],["D",1773248760319],[166,168,169,172,174,175,176],[148],["D",1773248642232],["D",1789520505489],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":24},{"_13":86,"_31":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_79":-5,"_125":343,"_344":345,"_346":347,"_348":24,"_349":24,"_350":24,"_351":123,"_352":-5,"_353":-7,"_354":-7,"_355":60,"_356":24,"_357":24,"_358":-5,"_359":24,"_360":24,"_361":24,"_362":-5},"ENV",{"_314":315,"_316":317,"_318":87,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338,"_339":340,"_341":342},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v21