Test Title

 [public]` — Retrieve a paste (role/user-gated; ephemeral by\n  default, `public: true` to show the channel)\n- `list` — Show all pastes with code, content preview, and permission info\n- `delete ` — Remove a paste (creator or admin)\n- `allow-role  ` — Grant a role view permission (admin)\n- `deny-role  ` — Revoke a role's view permission (admin)\n- `allow-user  ` — Grant a user view permission (admin)\n- `deny-user  ` — Revoke a user's view permission (admin)\n\nMax 50 pastes per guild. Autocomplete on paste codes. Pastes are unrestricted by\ndefault; once any role or user is added, only those roles/users (and admins) can\nview.\n\n#### `/pick `\n\nPick a random item from a comma-separated list (min 2 choices).\n\n#### `/poll` (admin-only)\n\nOne active poll per guild.\n\n- `create    [duration]` — Post a poll with one\n  button per option (2–10 options, up to 5 per row). Default duration 7 days,\n  max 30 days. Omit duration for no time limit.\n- `end` — End the poll, show final results with vote bars and percentages\n\nVote behavior: click to vote, click same to remove, click different to switch.\nMax 10,000 voters. Panel updates throttled to 5-second intervals. Auto-ended by\n`polls.cron.ts`.\n\n#### `/roll  [secret] [announce]`\n\nRoll dice using TTRPG notation. Supports `XdN`, `XdN+M`, `XdN-M`. 1–20 dice,\nd2–d100. Shows individual rolls and total.\n\n- **secret** — Roll is ephemeral (only you see it). Includes a **Reveal Roll**\n  button to post the result publicly.\n- **announce** — When rolling secretly, posts a public notice\n  (\"🎲 @user rolled some dice...\") so the table knows something happened.\n\nExamples: `/roll dice:1d20`, `/roll dice:4d6`, `/roll dice:2d20+5`,\n`/roll dice:1d20 secret:True announce:True`\n\n#### `/react-roles` (admin-only)\n\nSelf-assignable role panels.\n\n- `add   ` — Add a role (max 25, supports custom and unicode\n  emoji)\n- `remove ` — Remove a role from the panel\n- `list` — Show current configuration\n- `send ` — Post or update the role panel (patches existing message if\n  present)\n- `clear` — Delete all config\n\nUsers click buttons to toggle roles on/off.\n\n#### `/remind  `\n\nPersonal reminders. Duration supports `s`, `m`, `h`, `d` and combinations like\n`1d12h`. Max 10 active per user, max 30 days, max 500 chars. Delivered by\n`reminders.cron.ts`.\n\n#### `/schedule` (admin-only)\n\nTime-delayed message delivery.\n\n- `send   ` — Schedule a message (max 2000 chars, max 30\n  days)\n- `list` — Show pending messages with channel, preview, and relative time\n- `cancel ` — Cancel a pending message (autocomplete shows pending)\n\nMax 25 per guild. Delivered by `scheduled-messages.cron.ts`.\n\n#### `/slow-echo  [delay]`\n\nDeferred command demo. Waits 1–10 seconds (default 3) then echoes. 10-second\ncooldown.\n\n#### `/stash`\n\nPersonal clipboard — snippets persist across all servers.\n\n- `save  ` — Save or overwrite a named snippet (max 4000 chars)\n- `get ` — Recall a snippet\n- `list` — Show all entries with previews\n- `delete ` — Remove a snippet\n\nMax 25 entries per user. Names sanitized to lowercase alphanumeric + hyphens (max\n32 chars). Always ephemeral. Autocomplete on names.\n\n#### `/ticket`\n\nPrivate support ticket channels. Requires **Manage Channels** permission.\n\n- `new` — Opens a modal to create a new ticket. Creates a private channel under\n  the configured category with permission overwrites so only the creator and bot\n  can see it. Posts a staff control panel (Join/Close buttons) in the staff\n  channel. Max 3 open tickets per user.\n- `close [reason]` — Close the current ticket channel. Locks the channel, renames\n  it, posts a close notice, and schedules auto-deletion after 24 hours.\n- `setup  ` — Admin-only. Configure which channel\n  receives staff control panels and which category new tickets are created under.\n\nClosed tickets are auto-deleted by `tickets.cron.ts` after 24 hours.\n\n#### `/livestream` (admin-only)\n\nTrack streamers across Twitch, YouTube, and Kick. Notifications are posted\nautomatically when tracked streamers go live.\n\n- `add    [display-name]` — Track a streamer in the\n  specified channel. Supports Twitch, YouTube (channel ID), and Kick.\n- `remove  ` — Stop tracking a streamer\n- `list` — Show all tracked streamers grouped by platform\n\nMax 25 trackers per guild. Requires `TWITCH_CLIENT_ID` + `TWITCH_CLIENT_SECRET`\nfor Twitch, `YOUTUBE_API_KEY` for YouTube. Kick works without credentials.\nDelivered by `livestreams.cron.ts` with a 5-minute renotification cooldown.\n\n#### `/tag`\n\nPer-guild text snippets with optional role/user-gated viewing.\n\n- `view ` — Display a tag (role/user-gated, autocomplete on name)\n- `add  ` — Create a tag (admin-only, max 50 per guild)\n- `edit  ` — Update a tag (admin-only)\n- `remove ` — Delete a tag (admin-only)\n- `allow-role  ` — Grant a role view permission (admin)\n- `deny-role  ` — Revoke a role's view permission (admin)\n- `allow-user  ` — Grant a user view permission (admin)\n- `deny-user  ` — Revoke a user's view permission (admin)\n- `list` — Show all tag names with permission info\n\nTags are unrestricted by default; once any role or user is added, only those\nroles/users (and admins) can view.\n\n#### `/template`\n\nReusable embed builder with role/user-based send permissions. Lets authorized\nusers post rich embeds — something normally impossible without a bot or webhook.\n\n- `create ` — Open a modal to build an embed (admin)\n- `edit ` — Open a pre-filled modal to modify an embed (admin)\n- `add-field    [inline]` — Add a field (admin)\n- `remove-field  ` — Remove a field (admin)\n- `allow-role  ` — Grant a role permission to send (admin)\n- `deny-role  ` — Revoke a role's send permission (admin)\n- `allow-user  ` — Grant a user permission to send (admin)\n- `deny-user  ` — Revoke a user's send permission (admin)\n- `preview ` — Preview the embed privately (anyone)\n- `send  [channel]` — Post the embed (role/user-gated, see below)\n- `list` — Show all templates with permission info (anyone)\n- `delete ` — Remove a template (admin)\n\n**Role/user-based send access:** Each template has `allowedRoles` and\n`allowedUsers` lists. If both are empty, only admins can send. If roles or users\nare listed, users with at least one matching role or user ID (or admins) can\nsend. Non-admins always post to the current channel; admins can specify a\ndifferent channel.\n\n**Modal fields:** Title (required), Description (required), Color (hex, e.g.\n`#5865f2`), Footer, Image URL.\n\nMax 25 templates per guild, up to 25 fields per embed. Autocomplete on names.\n\n#### `/user-info` (context menu)\n\nRight-click a user to see their display name, username, ID, account creation\ndate, and avatar.\n\n#### `/color-picker`\n\nSelect menu demo. Choose a color from a dropdown to see a colored embed.\n\n## Component Handlers\n\nLocated in `discord/interactions/components/`. Auto-discovered and matched by\n`custom_id`.\n\n| File                | custom_id         | Match  | Type   | Description                            |\n| ------------------- | ----------------- | ------ | ------ | -------------------------------------- |\n| `color-select.ts`   | `color-select`    | exact  | select | Color picker dropdown handler          |\n| `example-button.ts` | `example-button`  | exact  | button | Demo button                            |\n| `facts-page.ts`     | `facts-page:`     | prefix | button | Fact pagination                        |\n| `feedback-modal.ts` | `feedback-modal`  | exact  | modal  | Feedback form → webhook                |\n| `giveaway-enter.ts` | `giveaway-enter:` | prefix | button | Giveaway entry (atomic dedup, 10k cap) |\n| `poll-vote.ts`      | `poll-vote:`      | prefix | button | Poll voting (toggle/switch, 10k cap)   |\n| `react-role.ts`     | `react-role:`     | prefix | button | Role toggle via Discord API            |\n| `roll-reveal.ts`    | `roll-reveal:`    | prefix | button | Reveal a secret dice roll publicly     |\n| `template-modal.ts` | `template-modal:` | prefix | modal  | Template create/edit modal submission   |\n| `ticket-modal.ts`   | `ticket-modal:`   | prefix | modal  | Ticket creation (channel + staff panel) |\n| `ticket-join.ts`    | `ticket-join:`    | prefix | button | Staff joins ticket channel              |\n| `ticket-close.ts`   | `ticket-close:`   | prefix | button | Opens close-reason modal                |\n| `ticket-close-modal.ts` | `ticket-close-modal:` | prefix | modal | Processes close reason, closes ticket |\n\n## Cron Jobs\n\nAll cron vals run every 1–5 minutes. Each uses the `listDue()` + `claimDelete()`\npattern for exactly-once delivery.\n\n### `giveaways.cron.ts`\n\nFinds expired giveaways, atomically ends them, picks winners, updates panel,\nposts announcement. Cleans up ended giveaways after a delay.\n\n### `polls.cron.ts`\n\nFinds expired polls, atomically ends them, patches panel with final vote bars\nand percentages.\n\n### `reminders.cron.ts`\n\nDelivers due reminders in batches of 5. Sends `⏰ <@user>, reminder: {message}`\nto the original channel. Retries up to 5 times with exponential backoff (1m, 2m,\n4m, 8m, 16m). Permanent failures (403/404) drop immediately.\n\n### `scheduled-messages.cron.ts`\n\nDelivers due messages in batches of 5. Same retry and permanent-failure logic as\nreminders.\n\n### `tickets.cron.ts`\n\nDeletes closed ticket channels after their 24-hour grace period. Uses\n`claimDelete()` for atomic dedup. Treats 404 (already deleted) as success.\nOn failure, re-inserts with a 1-hour retry delay.\n\n### `livestreams.cron.ts`\n\nPolls streaming platforms and posts Discord embeds when tracked streamers go\nlive. Groups trackers by platform — Twitch is batched (up to 100 per API call),\nYouTube and Kick are checked in parallel (concurrency limit of 5). Uses atomic\n`kv.update()` to prevent duplicate notifications and a 5-minute cooldown to\navoid spam on rapid online/offline cycles. Skips platforms whose credentials are\nnot configured.\n\n### `example.cron.ts`\n\nTemplate showing webhook usage from a cron job.\n\n## KV Store\n\n`discord/persistence/kv.ts` — SQLite-backed key-value store. Table:\n`kv_store (key TEXT PRIMARY KEY, value TEXT NOT NULL, due_at INTEGER)` with an\nindex on `due_at`. The table must be created before first use via\n`bootstrapKvTable()` (exposed as `GET /?bootstrap=true`).\n\n### Methods\n\n| Method                                            | Description                                                                                                                 |\n| ------------------------------------------------- | --------------------------------------------------------------------------------------------------------------------------- |\n| `bootstrapKvTable()`                              | Creates the KV table and indexes (idempotent). Called via `?bootstrap=true` admin endpoint.                                 |\n| `get(key)`                                     | Read a value by key                                                                                                         |\n| `set(key, value, dueAt?)`                         | Upsert. Optional `dueAt` (epoch ms) for time-based queries.                                                                 |\n| `delete(key)`                                     | Delete by key                                                                                                               |\n| `claimDelete(key)`                                | Atomically delete and return `true` if existed. For exactly-once delivery.                                                  |\n| `list(prefix?, limit?)`                           | List entries by prefix. Limit enforced in TypeScript (Val Town SQLite has no `LIMIT`).                                      |\n| `listDue(now, prefix?, limit?)`                   | List entries where `due_at <= now`.                                                                                         |\n| `listDueWithConfig(configKey, now, prefix?, limit?)` | Fetch a config row and due items in a single UNION ALL query. Used by cron jobs to reduce SQLite calls.               |\n| `update(key, fn, retries?)`                    | Atomic read-modify-write with optimistic concurrency (CAS). Falls back to unconditional write.                              |\n| `claimUpdate(key, fn, retries?)`               | Like `update()` but strict claim semantics — returns `null` on missing key, null return, or exhausted retries. No fallback. |\n\n### Usage\n\n```typescript\nimport { kv } from \"../../persistence/kv.ts\";\n\nawait kv.set(\"user:123\", { score: 42 });\nconst data = await kv.get<{ score: number }>(\"user:123\");\nawait kv.delete(\"user:123\");\nconst all = await kv.list(\"user:\");\n```\n\n### Key Namespaces\n\n| Prefix                                   | Description                                |\n| ---------------------------------------- | ------------------------------------------ |\n| `cooldown:{command}:{userId}`            | Per-user command cooldown expiry            |\n| `cooldown:games:daily:{userId}`          | Daily reward 24h cooldown                   |\n| `counter:{guildId}`                      | Guild counter value                        |\n| `giveaway:{guildId}`                     | Active/ended giveaway state                |\n| `guild_config:{guildId}`                 | Admin roles, enabled commands              |\n| `logging:muted_paths`                    | Muted webhook log paths (global)           |\n| `manifest`                               | Command/component file manifest            |\n| `patreon:discord:{discordId}`            | Patreon patron record                      |\n| `poll:{guildId}`                         | Active/ended poll state                    |\n| `ratelimit:patreon`                      | Patreon webhook rate limit                 |\n| `react-roles:{guildId}`                  | Role panel config                          |\n| `reminder:{userId}:{guildId}:{ts}-{rnd}` | Individual reminder with `due_at`          |\n| `scheduled-msg:{guildId}:{ts}-{rnd}`     | Individual scheduled message with `due_at` |\n| `tags:{guildId}`                         | All tags for a guild                       |\n| `ticket:{guildId}:{channelId}`           | Ticket state                               |\n\n## Blob Storage\n\n`discord/persistence/blob.ts` — Re-exports Val Town's blob storage (Cloudflare\nR2-backed). Better suited for larger, opaque data that doesn't need indexed\nqueries.\n\n### Usage\n\n```typescript\nimport { blob } from \"../../persistence/blob.ts\";\n\nawait blob.setJSON(\"paste:g1:abc123\", { content: \"hello\" });\nconst data = await blob.getJSON(\"paste:g1:abc123\");\nawait blob.delete(\"paste:g1:abc123\");\nconst items = await blob.list(\"paste:g1:\");\n```\n\n### Key Namespaces\n\n| Prefix                          | Description                          |\n| ------------------------------- | ------------------------------------ |\n| `backup:{guildId}:{id}`        | Guild data backup snapshots          |\n| `paste:{guildId}:{code}`       | Server pastebin entries              |\n| `stash:{userId}:{name}`        | Personal clipboard snippets          |\n| `template:{guildId}:{name}`    | Reusable embed templates             |\n\n## Guild Configuration\n\n`discord/persistence/guild-config.ts` — Stored at `guild_config:{guildId}`.\n\n```typescript\ninterface GuildConfig {\n  guildId: string;\n  adminRoleIds: string[]; // up to 25\n  enabledCommands: string[]; // up to 50\n  createdAt: string;\n  updatedAt: string;\n}\n```\n\nMethods: `get()`, `getAdminRoleIds()`, `getEnabledCommands()`,\n`setAdminRoles()`, `addAdminRole()`, `removeAdminRole()`, `enableCommand()`,\n`disableCommand()`, `listGuilds()`.\n\n## Admin System\n\n`isGuildAdmin(guildId, userId, memberRoles, memberPermissions?)` in\n`discord/constants.ts` uses a three-tier check:\n\n1. **Bot owner** — User ID matches `CONFIG.appOwnerId` (global bypass)\n2. **Server administrator** — Member permissions bitfield has the\n   `ADMINISTRATOR` bit\n3. **Configured admin role** — Member has any role in the guild's `adminRoleIds`\n   from KV\n\nCommands with `adminOnly: true` are gated by this check before execution.\n\n### Embed Colors\n\n```typescript\nSUCCESS: 0x57f287; // green\nERROR: 0xed4245; // red\nINFO: 0x5865f2; // blurple\nWARNING: 0xfee75c; // yellow\n```\n\n## Linked Roles\n\nDiscord's\n[Linked Roles](https://discord.com/developers/docs/tutorials/configuring-app-metadata-for-linked-roles)\nfeature lets server admins gate roles behind external account verification.\n\n### Setup\n\n1. Set `DISCORD_CLIENT_SECRET` environment variable\n2. In the Discord Developer Portal under **General Information**, set **Linked\n   Roles Verification URL** to `https://YOUR_ENDPOINT/linked-roles`\n3. Under **OAuth2**, add `https://YOUR_ENDPOINT/linked-roles/callback` as a\n   redirect URI\n4. Register the metadata schema: `GET ?register-metadata=true`\n   (password-protected)\n\n### Flow\n\n1. User clicks a linked role in the server → redirected to `/linked-roles`\n2. Bot generates CSRF state token, redirects to Discord OAuth2 (scopes:\n   `role_connections.write identify` + verifier extras)\n3. Discord redirects to `/linked-roles/callback` with code and state\n4. Bot validates CSRF state (HMAC-SHA256, 10-minute expiry), exchanges code for\n   tokens, fetches user, runs verifier, pushes metadata\n5. User sees success page\n\n### Built-in Verifiers\n\n| Verifier        | File                 | Metadata                           | Description                                         |\n| --------------- | -------------------- | ---------------------------------- | --------------------------------------------------- |\n| Always Verified | `always-verified.ts` | `verified` (boolean)               | Always passes. Default.                             |\n| Account Age     | `account-age.ts`     | `account_age_days` (integer)       | Extracts creation date from Discord snowflake       |\n| GitHub          | `github.ts`          | `public_repos`, `account_age_days` | Reads Discord-linked GitHub, fetches public profile |\n| Patreon         | `patreon.ts`         | `is_patron` (boolean)              | Reads KV record populated by Patreon webhook        |\n| Steam           | `steam.ts`           | `games_owned`, `account_age_days`  | Reads Discord-linked Steam, fetches via Steam API   |\n\n### Creating a Custom Verifier\n\n```typescript\nimport { defineVerifier, MetadataType } from \"../define-verifier.ts\";\nimport { setVerifier } from \"../routes.ts\";\n\nconst myVerifier = defineVerifier({\n  name: \"My Verifier\",\n  metadata: [\n    {\n      key: \"level\",\n      name: \"Level\",\n      description: \"User level must be at least this value\",\n      type: MetadataType.INTEGER_GREATER_THAN_OR_EQUAL,\n    },\n  ],\n  async verify(user) {\n    const level = await fetchLevelFromMyAPI(user.id);\n    return {\n      platformName: \"My Platform\",\n      platformUsername: user.username,\n      metadata: { level },\n    };\n  },\n});\n\nsetVerifier(myVerifier);\n```\n\nUpdate the import in `services/interactions.http.ts` to point to your verifier.\n\n### Patreon Webhook\n\n`POST /patreon/webhook` — HMAC-MD5 signature verification via\n`X-Patreon-Signature` header. Rate-limited to 30 requests per 60 seconds via KV.\nHandles `members:create`, `members:update` (writes patron record to KV), and\n`members:delete` (deletes record). Extracts Discord user ID from Patreon's\nsocial connections data.\n\n## Webhook Logging\n\n`discord/webhook/logger.ts` — Batched Discord webhook logger.\n\n```typescript\nimport { createLogger } from \"../webhook/logger.ts\";\n\nconst log = createLogger(\"my-module\");\nlog.info(\"Server started\");\nlog.warn(\"Rate limited\");\nlog.error(\"Connection failed\", error);\nlog.debug(\"Verbose detail\");\n```\n\n**Configuration:** `webhookUrl`, `context` (module name), `minLevel` (default\n`\"info\"`), `batchIntervalMs` (default 2000), `maxBatchSize` (default 15),\n`fallbackToConsole` (default `true`).\n\n**Behavior:** Errors flush immediately. Other levels schedule a flush after\n`batchIntervalMs`. On flush failure, entries are restored to the buffer (capped\nat 100). `finalizeAllLoggers()` flushes all registered loggers before the\nisolate terminates.\n\n**Muting:** Each logger instance has a `muted` flag. When `muted = true`,\ninfo/debug entries are still emitted to console but suppressed from the webhook.\nWarnings and errors always get through. The interaction handler and cron helper\nset this flag automatically based on paths configured via\n`/server logging mute`. Path format: `cmd:` or `cron:` with prefix\nmatching (muting `cmd:games` also mutes `cmd:games:coinflip`). Configuration is\nstored in KV at `logging:muted_paths` (max 100 paths).\n\n**Format:** `**[context]** - N log(s)` followed by `{emoji} HH:MM:SS message`\n\n## Webhook Sending\n\n`discord/webhook/send.ts` — Send messages and embeds to Discord webhooks.\n\n```typescript\nimport { send } from \"../webhook/send.ts\";\n\nawait send(\"Hello world\", webhookUrl);\nawait send([embed1, embed2], webhookUrl);\n```\n\n**Chunking:** Strings split at 2000 chars (breaking at newlines/spaces). Embeds\nbatched into groups of 10 staying under 6000 total characters.\n\n**Discord limits enforced:** Content 2000, embed title 256, description 4096,\nfields 25, field name 256, field value 1024, footer 2048, author name 256, total\nembed chars 6000, embeds per message 10.\n\n**Rate limiting:** On 429, waits `Retry-After` (capped 10s), retries once. On\n401/403/404, retries with `DISCORD_CONSOLE` fallback webhook if different.\n\n## Command Registration\n\n`discord/interactions/registration.ts` handles registering commands with\nDiscord's API.\n\n- **Global commands** — Bulk overwrite via `PUT /applications/{appId}/commands`\n- **Guild commands** — Per-guild overwrite via\n  `PUT /applications/{appId}/guilds/{guildId}/commands`\n\nFunctions: `registerGlobalCommands()`, `syncAllGuilds()`,\n`registerCommand(name, guildId)`, `registerCommandsToGuild(guildId)`,\n`deregisterCommandFromGuild(name, guildId)`, `deregisterAllFromGuild(guildId)`,\n`fetchRegisteredCommands(guildId?)`.\n\n`registerCommandsToGuild()` always bulk PUTs from guild config — reads enabled\ncommands from KV and overwrites the guild's registered commands to match.\n`registerCommand()` requires a guild ID and validates the command is enabled\nbefore registering. `syncAllGuilds()` is the only function that touches all\nguilds.\n\n### Discovery\n\n`GET /?discover=true` scans the project using Val Town's `listFiles()`, finds\n`.ts` files in `commands/` and `components/`, and saves the manifest to KV. The\nregistry loads this manifest on cold start to dynamically import all command and\ncomponent files. Falls back to a static manifest if KV is empty.\n\n## Helpers\n\n### Duration Parser (`discord/helpers/duration.ts`)\n\n```typescript\nimport { parseDuration } from \"../../helpers/duration.ts\";\nparseDuration(\"1h30m\"); // 5400000 (ms)\nparseDuration(\"2d\"); // 172800000\n```\n\nSupports `s` (seconds), `m` (minutes), `h` (hours), `d` (days), combinable.\nReturns `null` if invalid or exceeds 30 days.\n\n### Embed Builder (`discord/helpers/embed-builder.ts`)\n\n```typescript\nimport { embed } from \"../../helpers/embed-builder.ts\";\n\nconst e = embed()\n  .title(\"Hello\")\n  .description(\"World\")\n  .color(0x5865f2)\n  .field(\"Name\", \"Value\", true)\n  .footer(\"Footer text\")\n  .timestamp()\n  .build();\n```\n\nPresets: `.success(desc)`, `.error(desc)`, `.info(desc)`, `.warning(desc)`.\n\n### Crypto (`discord/helpers/crypto.ts`)\n\n- `timingSafeEqual(a, b)` — Constant-time string comparison via HMAC to prevent\n  timing attacks\n- `secureRandomIndex(max)` — Cryptographically secure random integer in\n  `[0, max)` using rejection sampling (no modulo bias)\n\n### TTL Cache (`discord/helpers/cache.ts`)\n\n```typescript\nimport { ExpiringCache } from \"../../helpers/cache.ts\";\n\nconst cache = new ExpiringCache(30_000, 500);\nconst items = await cache.getOrFetch(key, () => fetchItems());\ncache.delete(key); // invalidate\n```\n\nGeneric cache with TTL expiry and max-entry eviction. Used by paste, template,\ntag, stash, backup, and schedule commands for autocomplete caching.\n\n### Permissions (`discord/helpers/permissions.ts`)\n\n```typescript\nimport { checkEntityAccess, blobAllow, blobDeny, kvAllow, kvDeny } from \"../../helpers/permissions.ts\";\n\n// Check if user can access an entity (open by default)\nawait checkEntityAccess(entry, guildId, userId, roles, perms);\n// Check with closed default (admin-only when no restrictions)\nawait checkEntityAccess(entry, guildId, userId, roles, perms, { defaultOpen: false });\n```\n\nShared permission checking and role/user CRUD for blob-stored and KV-stored\nentities. Used by paste, template, and tag commands.\n\n### Format (`discord/helpers/format.ts`)\n\n```typescript\nimport { formatPermissionInfo, discordTimestamp } from \"../../helpers/format.ts\";\n\nformatPermissionInfo(entry);                // \" (roles: <@&r1>; users: <@u1>)\"\nformatPermissionInfo(entry, \"admin-only\");  // \" (admin-only)\" when no restrictions\ndiscordTimestamp(Date.now());               // \"\"\n```\n\n### Cron (`discord/helpers/cron.ts`)\n\n```typescript\nimport { runCron, deliverWithRetry } from \"../../helpers/cron.ts\";\n\nawait runCron({\n  name: \"MyCron\",\n  prefix: \"myprefix:\",\n  process: async (entry, logger) => {\n    await deliverWithRetry({ entry, deliver: ..., logger, entityLabel: \"item\" });\n  },\n});\n```\n\nShared cron lifecycle (logger, listDue, allSettled, finalize) and\nclaim-delete + delivery + backoff retry pattern.\n\n### Errors (`discord/interactions/errors.ts`)\n\n`UserFacingError` — Custom error class with a `userMessage` shown to Discord\nusers and an optional `internalMessage` for logs. All other errors show a\ngeneric message with an 8-char interaction ID reference.\n\n## Adding a New Command\n\nCreate a file in `discord/interactions/commands/`:\n\n```typescript\nimport { defineCommand } from \"../define-command.ts\";\n\nexport default defineCommand({\n  name: \"hello\",\n  description: \"Say hello\",\n  registration: { type: \"guild\", servers: [\"MAIN\"] },\n  deferred: false,\n  ephemeral: false,\n  async execute({ userId }) {\n    return { success: true, message: `Hello <@${userId}>!` };\n  },\n});\n```\n\nThen enable it with `/server commands enable command:hello` and it will be\nregistered automatically. Or use `/commands register hello` to register it\nmanually.\n\n### Command Options\n\n| Property       | Default          | Description                                                   |\n| -------------- | ---------------- | ------------------------------------------------------------- |\n| `name`         | —                | Command name                                                  |\n| `description`  | —                | Command description                                           |\n| `type`         | `1` (CHAT_INPUT) | `2` for USER context menu, `3` for MESSAGE context menu       |\n| `registration` | —                | `{ type: \"global\" }` or `{ type: \"guild\" }`                   |\n| `deferred`     | `true`           | `false` for instant response, `true` for background execution |\n| `ephemeral`    | `true`           | `false` to make responses visible to the whole channel        |\n| `adminOnly`    | `false`          | Restrict to admins (via `isGuildAdmin`)                       |\n| `cooldown`     | `3`              | Seconds between uses per user                                 |\n| `options`      | `[]`             | Discord command options array                                 |\n\n### Execution Context\n\nThe `execute` function receives:\n\n```typescript\n{\n  userId, guildId, channelId, interactionId, interactionToken,\n  options,       // parsed options (flat or subcommand-prefixed)\n  targetId,      // for context menu commands\n  resolved,      // resolved users/members/channels/roles\n  memberRoles,   // array of role IDs\n  subcommand,    // parsed subcommand name (e.g. \"admin:add\")\n}\n```\n\n### Response Shape\n\n```typescript\n{\n  success: boolean;\n  message?: string;        // text content\n  embeds?: Embed[];        // Discord embeds\n  components?: Component[];// action rows\n  modal?: ModalData;       // open a modal (non-deferred only)\n  updateMessage?: boolean; // update the original message (components only)\n}\n```\n\n## Adding a Component Handler\n\nCreate a file in `discord/interactions/components/`:\n\n```typescript\nimport { defineComponent } from \"../define-component.ts\";\n\nexport default defineComponent({\n  customId: \"my-button\",\n  match: \"exact\",\n  type: \"button\",\n  async execute({ userId }) {\n    return { success: true, message: `Clicked by <@${userId}>!` };\n  },\n});\n```\n\nMatch modes: `\"exact\"` for full `custom_id` match, `\"prefix\"` for prefix match\n(useful for dynamic IDs like `delete:123`).\n\n## Modal Dialogs\n\nReturn a `modal` from a non-deferred command, then handle the submission with a\ncomponent handler:\n\n```typescript\n// Command returns a modal\nasync execute() {\n  return {\n    success: true,\n    modal: {\n      title: \"Feedback\",\n      custom_id: \"feedback-modal\",\n      components: [\n        { type: 1, components: [{ type: 4, custom_id: \"topic\", label: \"Topic\", style: 1, required: true }] },\n      ],\n    },\n  };\n}\n```\n\n```typescript\n// components/feedback-modal.ts — sends submission to FEEDBACK_WEBHOOK\nexport default defineComponent({\n  customId: \"feedback-modal\",\n  match: \"exact\",\n  type: \"modal\",\n  async execute({ fields, userId }) {\n    if (CONFIG.feedbackWebhook) {\n      await send({ title: \"New Feedback\", fields: [...] }, CONFIG.feedbackWebhook);\n    }\n    return { success: true, message: \"\", embed: { title: \"Feedback Received\", ... } };\n  },\n});\n```\n\n## Select Menus\n\nReturn `components` with a select menu, then handle the selection:\n\n```typescript\n// Command returns a select menu\nasync execute() {\n  return {\n    success: true,\n    message: \"Choose:\",\n    components: [{\n      type: 1,\n      components: [{ type: 3, custom_id: \"my-select\", options: [{ label: \"A\", value: \"a\" }] }],\n    }],\n  };\n}\n```\n\n```typescript\n// components/my-select.ts\nexport default defineComponent({\n  customId: \"my-select\",\n  match: \"exact\",\n  type: \"select\",\n  async execute({ values }) {\n    return {\n      success: true,\n      updateMessage: true,\n      message: `You picked: ${values?.[0]}`,\n    };\n  },\n});\n```\n\n## Pagination with Buttons\n\nReturn buttons with encoded state in the `custom_id`, then use a prefix-match\nhandler:\n\n```typescript\n// components/my-page.ts\nexport default defineComponent({\n  customId: \"my-page:\",\n  match: \"prefix\",\n  type: \"button\",\n  async execute({ customId }) {\n    const page = parseInt(customId.split(\":\")[1], 10);\n    return { success: true, updateMessage: true, message: `Page ${page}`, components: [...] };\n  },\n});\n```\n\n## Testing\n\nCatnip has a comprehensive test suite — **126 test files** with **1621 tests** and\na **100% pass rate**. Tests run on Deno's built-in test runner with no external\ntest dependencies.\n\n```bash\ndeno test --allow-env --allow-net --no-check\n```\n\n### Coverage by Layer\n\n| Layer | Files | Tests | What's Covered |\n|---|---|---|---|\n| **Core infrastructure** | 6 | 61 | Config loading, API retry logic, crypto helpers, duration parsing, embed builder, timeouts |\n| **Interaction framework** | 7 | 55 | Handler dispatch, auto-discovery, command factory, component factory, error handling, patterns, registration |\n| **Commands** | 14 | 193 | backup, facts, giveaway, paste, poll, roll, remind, schedule, server, stash, tag, template, ticket |\n| **Components** | 9 | 66 | giveaway-enter, poll-vote, react-role, roll-reveal, template-modal, ticket-close, ticket-close-modal, ticket-join, ticket-modal |\n| **Persistence** | 2 | 43 | KV store CRUD, atomic operations, optimistic concurrency, time-based queries, guild config |\n| **Linked roles** | 5 | 34 | OAuth2 flow, verifier factory, Patreon webhook, routes, CSRF state tokens |\n| **Webhooks** | 2 | 36 | Batched logger (flush, levels, truncation), message sending (chunking, embeds, rate limits) |\n| **Cron jobs** | 6 | 35 | Giveaway auto-end, poll auto-end, reminder delivery, scheduled messages, ticket expiry, livestream notifications |\n| **HTTP endpoint** | 1 | 12 | Signature verification, routing, health check, admin auth |\n| **HTML pages** | 1 | 6 | Legal pages rendering, security headers |\n\n### Test Infrastructure\n\nAll external dependencies are mocked so tests run offline and in isolation:\n\n- **`test/_mocks/sqlite.ts`** — In-memory SQLite mock with full query support\n- **`test/_mocks/blob.ts`** — In-memory blob storage mock (getJSON, setJSON,\n  delete, list, copy, move)\n- **`test/_mocks/fetch.ts`** — Configurable HTTP fetch mock for Discord API calls\n- **`test/_mocks/env.ts`** — Environment variable mock for config testing\n- **`test/_mocks/sign.ts`** — Ed25519 request signing for interaction tests\n- **`test/_mocks/val-utils.ts`** — Val Town runtime utilities mock\n\n## Project Structure\n\n```\n├── discord/\n│   ├── constants.ts              # CONFIG, isGuildAdmin, EmbedColors\n│   ├── discord-api.ts            # Discord API client with retry logic\n│   ├── pages.ts                  # HTML pages (legal, linked roles)\n│   ├── helpers/\n│   │   ├── cache.ts              # ExpiringCache with TTL + max entries\n│   │   ├── cron.ts               # runCron() + deliverWithRetry() helpers\n│   │   ├── crypto.ts             # timingSafeEqual, secureRandomIndex\n│   │   ├── duration.ts           # Human-readable duration parser\n│   │   ├── embed-builder.ts      # Fluent embed builder\n│   │   ├── format.ts             # formatPermissionInfo, discordTimestamp\n│   │   ├── permissions.ts        # checkEntityAccess, blob/KV perm CRUD\n│   │   └── timeout.ts            # withTimeout() utility\n│   ├── linked-roles/\n│   │   ├── define-verifier.ts    # defineVerifier() helper and types\n│   │   ├── oauth.ts              # Discord OAuth2 token exchange\n│   │   ├── patreon-webhook.ts    # Patreon webhook handler\n│   │   ├── register-metadata.ts  # Push metadata schema to Discord\n│   │   ├── routes.ts             # HTTP route handlers + verifier registry\n│   │   ├── state.ts              # HMAC-SHA256 CSRF state tokens\n│   │   └── verifiers/\n│   │       ├── account-age.ts    # Discord account age verifier\n│   │       ├── always-verified.ts# Always-true verifier (default)\n│   │       ├── github.ts         # GitHub profile verifier\n│   │       ├── patreon.ts        # Patreon patron verifier\n│   │       └── steam.ts          # Steam profile verifier\n│   ├── persistence/\n│   │   ├── blob.ts               # Blob storage (Val Town / Cloudflare R2)\n│   │   ├── guild-config.ts       # Per-guild config (admin roles, commands)\n│   │   ├── kv.ts                 # Key-value store (Val Town SQLite)\n│   │   └── log-config.ts         # Webhook log muting config (KV-backed)\n│   ├── interactions/\n│   │   ├── auto-discover.ts      # File discovery, saves manifest to KV\n│   │   ├── define-command.ts     # defineCommand() factory\n│   │   ├── define-component.ts   # defineComponent() factory\n│   │   ├── errors.ts             # UserFacingError class\n│   │   ├── handler.ts            # Main interaction dispatcher\n│   │   ├── manifest.ts           # Static fallback manifest\n│   │   ├── patterns.ts           # Discord API constants & autocomplete\n│   │   ├── registration.ts       # Command registration logic\n│   │   ├── registry.ts           # Command & component registry (KV-backed)\n│   │   ├── commands/\n│   │   │   ├── about.ts          # Bot info\n│   │   │   ├── backup.ts         # Guild data export/import\n│   │   │   ├── coin-flip.ts      # Coin flip\n│   │   │   ├── color-picker.ts   # Select menu demo\n│   │   │   ├── commands.ts       # Admin: manage registration\n│   │   │   ├── counter.ts        # Persistent counter\n│   │   │   ├── echo.ts           # Echo input\n│   │   │   ├── facts.ts          # Paginated facts\n│   │   │   ├── feedback.ts       # Modal demo\n│   │   │   ├── giveaway.ts       # Giveaway system\n│   │   │   ├── help.ts           # List commands\n│   │   │   ├── paste.ts          # Server pastebin\n│   │   │   ├── pick.ts           # Random picker\n│   │   │   ├── ping.ts           # Health check\n│   │   │   ├── poll.ts           # Poll system\n│   │   │   ├── roll.ts            # Dice roller\n│   │   │   ├── react-roles.ts    # Self-assign role panels\n│   │   │   ├── remind.ts         # Personal reminders\n│   │   │   ├── schedule.ts       # Scheduled messages\n│   │   │   ├── server.ts         # Guild configuration\n│   │   │   ├── slow-echo.ts      # Deferred command demo\n│   │   │   ├── stash.ts          # Personal clipboard\n│   │   │   ├── tag.ts            # Custom text tags\n│   │   │   ├── template.ts       # Embed builder & poster\n│   │   │   ├── ticket.ts         # Ticket system\n│   │   │   └── user-info.ts      # User context menu\n│   │   └── components/\n│   │       ├── color-select.ts   # Color picker handler\n│   │       ├── example-button.ts # Button demo handler\n│   │       ├── facts-page.ts     # Fact pagination handler\n│   │       ├── feedback-modal.ts # Feedback modal handler\n│   │       ├── giveaway-enter.ts # Giveaway entry handler\n│   │       ├── poll-vote.ts      # Poll vote handler\n│   │       ├── react-role.ts     # Role toggle handler\n│   │       ├── roll-reveal.ts    # Dice roll reveal handler\n│   │       ├── template-modal.ts # Template create/edit modal handler\n│   │       ├── ticket-close.ts   # Ticket close handler\n│   │       ├── ticket-close-modal.ts # Close reason modal handler\n│   │       ├── ticket-join.ts    # Ticket join handler\n│   │       └── ticket-modal.ts   # Ticket creation modal handler\n│   └── webhook/\n│       ├── logger.ts             # Batched Discord webhook logger\n│       └── send.ts               # Webhook message sending\n├── services/\n│   ├── interactions.http.ts      # HTTP endpoint (all routes)\n│   ├── example.cron.ts           # Cron job template\n│   ├── giveaways.cron.ts         # Auto-end expired giveaways\n│   ├── polls.cron.ts             # Auto-end expired polls\n│   ├── reminders.cron.ts         # Deliver due reminders\n│   ├── scheduled-messages.cron.ts# Deliver due scheduled messages\n│   ├── tickets.cron.ts           # Expire inactive tickets\n│   └── livestreams.cron.ts       # Post go-live notifications\n└── test/\n    └── _mocks/                   # Test infrastructure mocks\n```\n\n## License\n\nThis project is licensed under the [MIT License](LICENSE).",[],[667],"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",[],[676],"22f42bee-1e3b-11f1-9847-42dde27851f2","CONTRIBUTING.md","9d263f8a-1d6c-11f1-9ac8-42dde27851f2",345,["D",1773337476304],"# Contributing to Catnip\n\nThanks for your interest in contributing! Catnip is a Discord bot template built for Val Town's serverless Deno runtime.\n\n## Getting Started\n\n1. Fork and clone the repository\n2. Copy `.env.example` to `.env` and fill in your Discord application credentials\n3. Install [Deno](https://deno.land) if you don't have it\n\n## Running Tests\n\n```bash\ndeno test --allow-env --allow-net --no-check\n```\n\nAll 1621 tests across 126 files should pass. Tests use mock modules for SQLite, blob storage, and Val Town utilities (see `test/_mocks/`). See the [README](README.md#testing) for a full coverage breakdown.\n\n## Adding a Command\n\n1. Create a new file in `discord/interactions/commands/`\n2. Use `defineCommand()` to declare the command and its handler\n3. Register the component handler if needed in `discord/interactions/components/`\n4. Run discover + register via the admin endpoints\n\nSee the [README](README.md#adding-a-new-command) for a full walkthrough with examples.\n\n## Code Style\n\n- TypeScript with Deno conventions\n- No external dependencies beyond Val Town standard libraries and Deno std\n- Use `UserFacingError` for errors shown to Discord users\n- Use `createLogger()` instead of `console.log` for production logging\n- Parameterize all SQL queries — never interpolate user input\n- Use `kv.update()` or `kv.claimUpdate()` for atomic mutations\n\n## Pull Requests\n\n- Keep changes focused — one feature or fix per PR\n- Include tests for new commands or behavior changes\n- Make sure all existing tests still pass\n- Update the README if you add commands, env vars, or endpoints\n\n## Reporting Issues\n\nOpen an issue on GitHub with:\n- What you expected to happen\n- What actually happened\n- Steps to reproduce (if applicable)\n\nFor security vulnerabilities, see [SECURITY.md](SECURITY.md).\n",[],[684],"230716c8-1e3b-11f1-855d-42dde27851f2","CHANGELOG.md","9d303986-1d6c-11f1-aa5a-42dde27851f2",347,["D",1773337476382],2,"# Changelog\n\n## 1.0.2 — Webhook Log Muting, Command Rename & Daily Rewards\n\n### Features\n- Webhook log muting — `/server logging mute ` suppresses routine (info/debug) webhook logs for noisy commands or cron jobs while still forwarding warnings and errors. Supports prefix matching (e.g. muting `cmd:games` also mutes `cmd:games:coinflip`). Manage with `mute`, `unmute`, and `list` subcommands.\n- `/server info` now shows muted log paths alongside admin roles and enabled commands\n- Per-game toggles — admins can enable/disable individual games via `/games-config toggle --game  --enabled ` (all 20 games supported)\n- Daily reward command — `/games daily` grants a random coin amount (default 50–150) with a 24-hour cooldown\n- Daily reward configuration — `/games-config daily` lets admins set `--enabled`, `--min`, `--max` reward range\n- `games-config info` now shows disabled games list and daily reward settings\n- Added `GameName` type and `ALL_GAME_NAMES` constant for type-safe game references\n\n### Changes\n- Renamed `/r` to `/roll` for clarity\n- Moved `/daily` into `/games daily` subcommand — consolidates all game interactions under one command\n- Logger `muted` flag integrated into interaction handler (commands) and `runCron()` helper (cron jobs)\n\n### Testing\n- New tests for `log-config.ts`, server logging subcommands, toggle, daily config, daily command, and per-game disable enforcement\n\n## 1.0.1 — Extract Reusable Patterns\n\n### Refactoring\n- Extract `ExpiringCache` class (`discord/helpers/cache.ts`) — replaces 6 identical cache implementations across paste, template, tag, stash, backup, and schedule commands\n- Extract permission helpers (`discord/helpers/permissions.ts`) — `checkEntityAccess()` replaces `canGet`/`canSend`/`canView`, blob/KV CRUD helpers replace 12 duplicated allow/deny handlers\n- Extract format helpers (`discord/helpers/format.ts`) — `formatPermissionInfo()` and `discordTimestamp()` replace duplicated formatting blocks\n- Extract cron helpers (`discord/helpers/cron.ts`) — `runCron()` wraps common cron lifecycle, `deliverWithRetry()` wraps claim-delete + retry pattern\n- Refactor paste, template, tag, stash, backup, schedule commands to use shared helpers\n- Refactor reminders, scheduled-messages, giveaways, polls, tickets cron jobs to use shared helpers\n- Add 45 new tests for helper modules; all 672 tests pass\n\n## 1.0.0 — Initial Public Release\n\n### Features\n- Slash command framework with `defineCommand()`, auto-registration, subcommands, autocomplete, and cooldowns\n- Component handling for buttons, select menus, and modals via `defineComponent()`\n- Context menu commands (user and message right-click)\n- Per-guild configuration — admin roles, command enable/disable, persisted in KV\n- Giveaway system — button entry, auto-end via cron, winner picking, reroll\n- Poll system — button voting with live counts, auto-end, vote switching\n- Reminders — personal time-delayed reminders with exactly-once cron delivery\n- Scheduled messages — admin-only delayed message posting\n- Ticket system — thread-based support tickets with close reasons, join requests, modal creation, and auto-expiry via cron\n- React-roles — self-assignable role panels with button toggling\n- Tags — per-guild text snippets with role/user-gated viewing\n- Templates — reusable embed builder with modal editing, role/user-based send permissions, and channel posting\n- Paste — server pastebin with short codes, public/private retrieval, role/user-gated access, and creator/admin delete\n- Stash — personal cross-server clipboard with named snippets\n- Backup — admin-only guild data export/import for tags, templates, and counters\n- Dice roller — standard TTRPG notation (`2d20+5`) with secret rolls, announce, and reveal\n- Linked roles — Discord OAuth2 verification with pluggable verifiers (Steam, GitHub, Patreon, account age)\n- Webhook logging — batched Discord webhook logger with log levels and auto-flush\n- Webhook sending — message chunking, embed batching, rate-limit handling, fallback support\n- KV persistence — SQLite-backed key-value store with atomic operations, optimistic concurrency, and time-based queries\n- Blob persistence — Cloudflare R2-backed storage for larger data (pastes, templates, backups, stash)\n- Guild allowlist via `ALLOWED_GUILD_IDS`\n- Built-in Terms of Service and Privacy Policy pages\n- Health check endpoint\n\n### Testing\n- **529 tests** across **51 files** with 100% pass rate\n- Full coverage across commands, components, persistence, crons, linked roles, and webhooks\n- Offline test infrastructure with mocks for SQLite, blob storage, fetch, env, signing, and Val Town utilities\n\n### Security\n- Ed25519 signature verification on all interactions\n- HMAC-SHA256 CSRF tokens for OAuth2 flow\n- Timing-safe comparisons for all secret validation\n- Parameterized SQL queries throughout\n- Explicit null defaults for optional secrets\n- Rate limiting and per-user command cooldowns\n- Exactly-once cron delivery via atomic `claimDelete()`\n- Retry with exponential backoff respecting Discord rate limits\n",[],[692],"9d1c23ce-1d6c-11f1-bd35-42dde27851f2","AGENTS.md","9d1c246e-1d6c-11f1-bd35-42dde27851f2",279,["D",1773248775433],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious operations)\n- Follow modern ES6+ conventions and functional programming practices if possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n  return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n  // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n**Warning:** Val Town auto-detects any file with `cron` in the name as a cron val. Never use `cron` in test file names — use `-job` instead (e.g. `reminders-job_test.ts`, not `reminders.cron_test.ts`).\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n  // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst TABLE_NAME = 'todo_app_users_2';\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n  id INTEGER PRIMARY KEY AUTOINCREMENT,\n  name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(`SELECT * FROM ${TABLE_NAME} WHERE id = ?`, [1]);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n  messages: [\n    { role: \"user\", content: \"Say hello in a creative way\" },\n  ],\n  model: \"gpt-4o-mini\",\n  max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({ \n  subject: \"Hi\",  \n  text: \"Hi\", \n  html: \"Hi
\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name);     // Project name\nconsole.log(projectVal.version);  // Version number\nconsole.log(projectVal.branch);   // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: ``\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│   ├── database/\n│   │   ├── migrations.ts    # Schema definitions\n│   │   ├── queries.ts       # DB query functions\n│   │   └── README.md\n│   └── routes/              # Route modules\n│       ├── [route].ts\n│       └── static.ts        # Static file serving\n│   ├── index.ts             # Main entry point\n│   └── README.md\n├── frontend/\n│   ├── components/\n│   │   ├── App.tsx\n│   │   └── [Component].tsx\n│   ├── favicon.svg\n│   ├── index.html           # Main HTML template\n│   ├── index.tsx            # Frontend JS entry point\n│   ├── README.md\n│   └── style.css\n├── README.md\n└── shared/\n    ├── README.md\n    └── utils.ts             # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n  ```ts\n  import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n  \n  // serve all files in frontend/ and shared/\n  app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n  app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n  \n  // For index.html, often you'll want to bootstrap with initial data\n  app.get(\"/\", async c => {\n    let html = await readFile(\"/frontend/index.html\", import.meta.url);\n    \n    // Inject data to avoid extra round-trips\n    const initialData = await fetchInitialData();\n    const dataScript = ``;\n    \n    html = html.replace(\"\", `${dataScript}`);\n    return c.html(html);\n  });\n  ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n  ```ts\n  // Unwrap Hono errors to see original error details\n  app.onError((err, c) => {\n    throw err;\n  });\n  ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n   - Val Town runs on Deno in a serverless context, not Node.js\n   - Code in `shared/` must work in both frontend and backend environments\n   - Cannot use `Deno` keyword in shared code\n   - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n   - Limited support for ALTER TABLE operations\n   - Create new tables with updated schemas and copy data when needed\n   - Always run table creation before querying\n\n3. **React Configuration:**\n   - All React dependencies must be pinned to 18.2.0\n   - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n   - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n   - Val Town only supports text files, not binary\n   - Use the provided utilities to read files across branches and forks\n   - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n   - `fetch` handler is the entry point for HTTP vals\n   - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[],[701],"9d719796-1d6c-11f1-be21-42dde27851f2",".vtignore","9d71985e-1d6c-11f1-be21-42dde27851f2",292,["D",1773248775944],".git\n.vscode\n.cursorrules\n.claude\n.vt\n.DS_Store\n*:Zone.Identifier\nnode_modules\nvendor",[],[709],"9d2065a6-1d6c-11f1-b767-42dde27851f2",".gitignore","9d20666e-1d6c-11f1-b767-42dde27851f2",280,["D",1773248775478],"# Environment variables\n.env\n.env.*\n!.env.example\n\n# OS files\n.DS_Store\nThumbs.db\n*:Zone.Identifier\n\n# Editor directories\n.idea/\n*.swp\n*.swo\n*~\n\n# Claude Code\n.claude/\n\n# Val Town\n.vt/\n\n# Deno\n.deno/\n\n# Node (in case of compatibility layers)\nnode_modules/\n",[],[717],"9d696ff8-1d6c-11f1-87f5-42dde27851f2",".env.example","9d6970b6-1d6c-11f1-87f5-42dde27851f2",291,["D",1773248775961],"# Required — bot will not start without these\nDISCORD_APP_ID=\nDISCORD_PUBLIC_KEY=\nDISCORD_BOT_TOKEN=\n\n# Optional — global bot owner (bypasses all admin checks)\nDISCORD_APP_OWNER_ID=\n\n# Optional — webhook URL for centralized logging\nDISCORD_CONSOLE=\n\n# Optional — required for Linked Roles OAuth2 flow\nDISCORD_CLIENT_SECRET=\n\n# Optional — protects admin endpoints (register, discover, invite)\nADMIN_PASSWORD=\n\n# Optional — required for Steam linked-role verifier\nSTEAM_API_KEY=\n\n# Optional — required for Patreon webhook signature verification\nPATREON_WEBHOOK_SECRET=\n\n# Optional — comma-separated guild IDs to restrict the bot to\nALLOWED_GUILD_IDS=\n",[],[725],"9d364e7a-1d6c-11f1-91ad-42dde27851f2","assert.ts","9d364f4c-1d6c-11f1-91ad-42dde27851f2","94226a9e-1d6c-11f1-9109-42dde27851f2",284,["D",1773248775638],"/**\n * Lightweight assert helpers that work in both local Deno and Val Town production.\n *\n * Val Town's runtime doesn't include `@std/assert` in its import map, so test\n * files that use a bare `\"@std/assert\"` specifier crash at import time. This\n * module provides the subset of assertion functions the test suite uses,\n * removing the external dependency entirely.\n */\n\nfunction deepEqual(a: unknown, b: unknown): boolean {\n  if (Object.is(a, b)) return true;\n  if (a === null || b === null) return false;\n  if (typeof a !== typeof b) return false;\n  if (typeof a !== \"object\") return false;\n\n  if (Array.isArray(a)) {\n    if (!Array.isArray(b) || a.length !== b.length) return false;\n    return a.every((v, i) => deepEqual(v, (b as unknown[])[i]));\n  }\n\n  if (Array.isArray(b)) return false;\n\n  const aObj = a as Record;\n  const bObj = b as Record;\n  const keys = Object.keys(aObj);\n  if (keys.length !== Object.keys(bObj).length) return false;\n  return keys.every((k) => deepEqual(aObj[k], bObj[k]));\n}\n\nfunction inspect(value: unknown): string {\n  try {\n    return typeof Deno !== \"undefined\"\n      ? Deno.inspect(value, { depth: 8 })\n      : JSON.stringify(value, null, 2);\n  } catch {\n    return String(value);\n  }\n}\n\nexport function assert(value: unknown, msg?: string): asserts value {\n  if (!value) {\n    throw new Error(msg ?? `Expected truthy value, got ${inspect(value)}`);\n  }\n}\n\nexport function assertEquals(actual: T, expected: T, msg?: string): void {\n  if (!deepEqual(actual, expected)) {\n    throw new Error(\n      msg ??\n        `Values are not equal:\\n  actual:   ${inspect(actual)}\\n  expected: ${inspect(expected)}`,\n    );\n  }\n}\n\nexport function assertNotStrictEquals(\n  actual: T,\n  expected: T,\n  msg?: string,\n): void {\n  if (actual === expected) {\n    throw new Error(\n      msg ?? `Expected values to NOT be strictly equal: ${inspect(actual)}`,\n    );\n  }\n}\n\nexport function assertStringIncludes(\n  actual: string,\n  expected: string,\n  msg?: string,\n): void {\n  if (!actual.includes(expected)) {\n    throw new Error(\n      msg ??\n        `Expected string to include \"${expected}\", got: \"${actual}\"`,\n    );\n  }\n}\n\n// deno-lint-ignore no-explicit-any\nexport function assertInstanceOf any>(\n  value: unknown,\n  expectedType: T,\n  msg?: string,\n): asserts value is InstanceType {\n  if (!(value instanceof expectedType)) {\n    throw new Error(\n      msg ??\n        `Expected instance of ${expectedType.name}, got ${typeof value}`,\n    );\n  }\n}\n\nexport async function assertRejects(\n  fn: () => PromiseLike,\n  // deno-lint-ignore no-explicit-any\n  errorClass?: new (...args: any[]) => Error,\n  msgIncludes?: string,\n  msg?: string,\n): Promise {\n  let threw = false;\n  let error: unknown;\n  try {\n    await fn();\n  } catch (e) {\n    threw = true;\n    error = e;\n  }\n  if (!threw) {\n    throw new Error(msg ?? \"Expected function to throw\");\n  }\n  if (errorClass && !(error instanceof errorClass)) {\n    throw new Error(\n      msg ??\n        `Expected error to be instance of ${errorClass.name}, got ${error}`,\n    );\n  }\n  if (msgIncludes && error instanceof Error && !error.message.includes(msgIncludes)) {\n    throw new Error(\n      msg ??\n        `Expected error message to include \"${msgIncludes}\", got \"${error.message}\"`,\n    );\n  }\n  return error as Error;\n}\n",[],[741,733],"test","9d63dc6e-1d6c-11f1-8936-42dde27851f2","val-utils.ts","9d63dd72-1d6c-11f1-8936-42dde27851f2","9492226c-1d6c-11f1-9109-42dde27851f2",290,["D",1773248775853],"/**\n * test/_mocks/val-utils.ts\n *\n * Stub for Val Town's listFiles() utility used by auto-discover.\n */\n\nexport function listFiles(_callerUrl?: string): Promise> {\n  return Promise.resolve([]);\n}\n",[],[741,751,743],"_mocks","c475f4fe-1fc4-11f1-ab0d-42dde27851f2","sqlite.ts","9d52b8b2-1d6c-11f1-87f5-42dde27851f2",355,["D",1773506539484],"/**\n * test/_mocks/sqlite.ts\n *\n * In-memory SQLite mock matching Val Town's API shape.\n * Call sqlite._reset() between tests for isolation.\n */\n\nconst store = new Map();\nconst dueAtStore = new Map();\n\nfunction parseQuery(input: string | { sql: string; args?: any[] }) {\n  const sql = typeof input === \"string\" ? input : input.sql;\n  const args = typeof input === \"string\" ? [] : (input.args ?? []);\n  return { sql: sql.trim(), args };\n}\n\n/** Unescape SQL LIKE backslash-escaped chars to get a literal prefix. */\nfunction unescapeLikePrefix(pattern: string): string {\n  return pattern.replace(/%$/, \"\").replace(/\\\\(.)/g, \"$1\");\n}\n\nexport const sqlite = {\n  async execute(input: string | { sql: string; args?: any[] }) {\n    const { sql, args } = parseQuery(input);\n\n    // CREATE TABLE / CREATE INDEX\n    if (sql.toUpperCase().startsWith(\"CREATE TABLE\") || sql.toUpperCase().startsWith(\"CREATE INDEX\")) {\n      return { rows: [], rowsAffected: 0, columns: [] };\n    }\n\n    // UNION ALL: combined config + due items query\n    if (sql.includes(\"UNION ALL\")) {\n      const configKey = args[0] as string;\n      const now = args[1] as number;\n      const pattern = args[2] as string;\n      const prefix = unescapeLikePrefix(pattern);\n      const rows: any[][] = [];\n\n      // Config row (tag \"C\")\n      const configValue = store.get(configKey);\n      if (configValue !== undefined) {\n        rows.push([\"C\", configKey, configValue]);\n      }\n\n      // Due items (tag \"D\")\n      for (const [k, v] of store.entries()) {\n        if (!k.startsWith(prefix)) continue;\n        const dueAt = dueAtStore.get(k);\n        if (dueAt !== null && dueAt !== undefined && dueAt <= now) {\n          rows.push([\"D\", k, v]);\n        }\n      }\n\n      return { rows, rowsAffected: 0, columns: [\"tag\", \"key\", \"value\"] };\n    }\n\n    // SELECT value FROM ... WHERE key = ?\n    if (/SELECT\\s+value\\s+FROM/i.test(sql) && sql.includes(\"key = ?\")) {\n      const key = args[0] as string;\n      const value = store.get(key);\n      return {\n        rows: value !== undefined ? [[value]] : [],\n        rowsAffected: 0,\n        columns: [\"value\"],\n      };\n    }\n\n    // SELECT key, value FROM ... WHERE due_at IS NOT NULL AND due_at <= ? AND key LIKE ?\n    if (/SELECT\\s+key,\\s*value\\s+FROM/i.test(sql) && sql.includes(\"due_at\") && sql.includes(\"LIKE ?\")) {\n      const now = args[0] as number;\n      const pattern = args[1] as string;\n      const prefix = unescapeLikePrefix(pattern);\n      const rows = [...store.entries()]\n        .filter(([k]) => k.startsWith(prefix))\n        .filter(([k]) => {\n          const dueAt = dueAtStore.get(k);\n          return dueAt !== null && dueAt !== undefined && dueAt <= now;\n        })\n        .map(([k, v]) => [k, v]);\n      return { rows, rowsAffected: 0, columns: [\"key\", \"value\"] };\n    }\n\n    // SELECT key, value FROM ... WHERE due_at IS NOT NULL AND due_at <= ?\n    if (/SELECT\\s+key,\\s*value\\s+FROM/i.test(sql) && sql.includes(\"due_at\") && !sql.includes(\"LIKE\")) {\n      const now = args[0] as number;\n      const rows = [...store.entries()]\n        .filter(([k]) => {\n          const dueAt = dueAtStore.get(k);\n          return dueAt !== null && dueAt !== undefined && dueAt <= now;\n        })\n        .map(([k, v]) => [k, v]);\n      return { rows, rowsAffected: 0, columns: [\"key\", \"value\"] };\n    }\n\n    // SELECT key, value FROM ... WHERE key LIKE ?\n    if (/SELECT\\s+key,\\s*value\\s+FROM/i.test(sql) && sql.includes(\"LIKE ?\")) {\n      const pattern = args[0] as string;\n      const prefix = unescapeLikePrefix(pattern);\n      const rows = [...store.entries()]\n        .filter(([k]) => k.startsWith(prefix))\n        .map(([k, v]) => [k, v]);\n      return { rows, rowsAffected: 0, columns: [\"key\", \"value\"] };\n    }\n\n    // SELECT key, value FROM ... (no WHERE)\n    if (/SELECT\\s+key,\\s*value\\s+FROM/i.test(sql) && !sql.includes(\"WHERE\")) {\n      const rows = [...store.entries()].map(([k, v]) => [k, v]);\n      return { rows, rowsAffected: 0, columns: [\"key\", \"value\"] };\n    }\n\n    // INSERT OR REPLACE\n    if (/INSERT\\s+OR\\s+REPLACE/i.test(sql)) {\n      const key = args[0] as string;\n      const value = args[1] as string;\n      store.set(key, value);\n      dueAtStore.set(key, args.length > 2 ? (args[2] as number | null) : null);\n      return { rows: [], rowsAffected: 1, columns: [] };\n    }\n\n    // INSERT OR IGNORE\n    if (/INSERT\\s+OR\\s+IGNORE/i.test(sql)) {\n      const key = args[0] as string;\n      const value = args[1] as string;\n      if (!store.has(key)) {\n        store.set(key, value);\n        dueAtStore.set(key, args.length > 2 ? (args[2] as number | null) : null);\n        return { rows: [], rowsAffected: 1, columns: [] };\n      }\n      return { rows: [], rowsAffected: 0, columns: [] };\n    }\n\n    // UPDATE ... SET value = ? WHERE key = ? AND value = ?\n    if (sql.toUpperCase().startsWith(\"UPDATE\")) {\n      const newValue = args[0] as string;\n      const key = args[1] as string;\n      const oldValue = args[2] as string;\n      if (store.get(key) === oldValue) {\n        store.set(key, newValue);\n        return { rows: [], rowsAffected: 1, columns: [] };\n      }\n      return { rows: [], rowsAffected: 0, columns: [] };\n    }\n\n    // DELETE FROM ... WHERE key = ?\n    if (sql.toUpperCase().startsWith(\"DELETE\")) {\n      const key = args[0] as string;\n      const had = store.has(key);\n      store.delete(key);\n      dueAtStore.delete(key);\n      return { rows: [], rowsAffected: had ? 1 : 0, columns: [] };\n    }\n\n    return { rows: [], rowsAffected: 0, columns: [] };\n  },\n\n  _reset() {\n    store.clear();\n    dueAtStore.clear();\n  },\n};\n",[],[741,751,753],"9d5951b8-1d6c-11f1-b1ab-42dde27851f2","sign.ts","9d59528a-1d6c-11f1-b1ab-42dde27851f2",289,["D",1773248775855],"/**\n * test/_mocks/sign.ts\n *\n * Ed25519 signing helper for testing Discord signature verification.\n * The private key here matches the public key in env.ts.\n */\n\nconst PKCS8_HEX = \"302e020100300506032b6570042204202197bb0a1f75ba922bb1fa1fcb5e28668bb7ebbccc30566b1f1837984bf65bf5\";\n\nfunction hexToBytes(hex: string): Uint8Array {\n  const bytes = new Uint8Array(hex.length / 2);\n  for (let i = 0; i < bytes.length; i++) {\n    bytes[i] = parseInt(hex.substring(i * 2, i * 2 + 2), 16);\n  }\n  return bytes;\n}\n\nfunction bytesToHex(bytes: Uint8Array): string {\n  return [...bytes].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nlet cachedPrivateKey: CryptoKey | null = null;\n\nasync function getPrivateKey(): Promise {\n  if (!cachedPrivateKey) {\n    cachedPrivateKey = await crypto.subtle.importKey(\n      \"pkcs8\",\n      hexToBytes(PKCS8_HEX),\n      { name: \"Ed25519\" },\n      false,\n      [\"sign\"],\n    );\n  }\n  return cachedPrivateKey;\n}\n\n/**\n * Sign a request body for Discord interaction verification.\n * Returns the signature hex and a fresh timestamp.\n */\nexport async function signBody(body: string): Promise<{ signature: string; timestamp: string }> {\n  const timestamp = String(Math.floor(Date.now() / 1000));\n  const key = await getPrivateKey();\n  const message = new TextEncoder().encode(timestamp + body);\n  const sigBuf = await crypto.subtle.sign(\"Ed25519\", key, message);\n  return { signature: bytesToHex(new Uint8Array(sigBuf)), timestamp };\n}\n\n/**\n * Build a signed Request for handleInteraction.\n */\nexport async function signedRequest(body: string): Promise {\n  const { signature, timestamp } = await signBody(body);\n  return new Request(\"https://example.com/\", {\n    method: \"POST\",\n    body,\n    headers: {\n      \"X-Signature-Ed25519\": signature,\n      \"X-Signature-Timestamp\": timestamp,\n    },\n  });\n}\n",[],[741,751,761],"9d477966-1d6c-11f1-aa5a-42dde27851f2","fetch.ts","9d477a42-1d6c-11f1-aa5a-42dde27851f2",286,["D",1773248775703],"/**\n * test/_mocks/fetch.ts\n *\n * Reusable fetch mock for testing. Records all calls and returns\n * configurable responses. Install/uninstall around tests.\n */\n\nexport interface MockResponse {\n  status?: number;\n  body?: unknown;\n  headers?: Record;\n}\n\nexport interface RecordedCall {\n  url: string;\n  init?: RequestInit;\n}\n\nlet responses: MockResponse[] = [];\nlet defaultResponse: MockResponse = { status: 200, body: {} };\nlet calls: RecordedCall[] = [];\nlet originalFetch: typeof globalThis.fetch | null = null;\nlet shouldThrow: Error | null = null;\n\nexport function mockFetch(opts?: {\n  responses?: MockResponse[];\n  default?: MockResponse;\n}) {\n  calls = [];\n  responses = opts?.responses ? [...opts.responses] : [];\n  defaultResponse = opts?.default ?? { status: 200, body: {} };\n  shouldThrow = null;\n  originalFetch = globalThis.fetch;\n\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    calls.push({ url, init });\n\n    if (shouldThrow) {\n      const err = shouldThrow;\n      shouldThrow = null;\n      throw err;\n    }\n\n    const mock = responses.shift() ?? defaultResponse;\n\n    const headers = new Headers(mock.headers);\n    if (!headers.has(\"Content-Type\")) {\n      headers.set(\"Content-Type\", \"application/json\");\n    }\n\n    const body = mock.body !== undefined ? JSON.stringify(mock.body) : null;\n\n    return new Response(body, {\n      status: mock.status ?? 200,\n      headers,\n    });\n  }) as typeof globalThis.fetch;\n}\n\nexport function setNextThrow(error: Error) {\n  shouldThrow = error;\n}\n\nexport function getCalls(): RecordedCall[] {\n  return calls;\n}\n\nexport function restoreFetch() {\n  if (originalFetch) {\n    globalThis.fetch = originalFetch;\n    originalFetch = null;\n  }\n  calls = [];\n  responses = [];\n  shouldThrow = null;\n}\n",[],[741,751,769],"9d439314-1d6c-11f1-85a6-42dde27851f2","env.ts","9d439422-1d6c-11f1-85a6-42dde27851f2",285,["D",1773248775683],"/**\n * test/_mocks/env.ts\n *\n * Side-effect module: sets required env vars for testing.\n * Import this BEFORE any source modules that depend on discord/constants.ts.\n */\n\nconst testEnv: Record = {\n  DISCORD_APP_ID: \"11111111111111111\",\n  DISCORD_PUBLIC_KEY: \"e9ed0f268572a36c4dbf24af61334541c051ebdf2b5b44fc32ae071b21186d48\",\n  DISCORD_BOT_TOKEN: \"test_bot_token\",\n  DISCORD_CLIENT_SECRET: \"test_client_secret\",\n  ADMIN_PASSWORD: \"test_admin_password\",\n};\n\nfor (const [key, value] of Object.entries(testEnv)) {\n  if (!Deno.env.get(key)) {\n    Deno.env.set(key, value);\n  }\n}\n",[],[741,751,777],"9d563ec4-1d6c-11f1-85c7-42dde27851f2","blob.ts","9d563fb4-1d6c-11f1-85c7-42dde27851f2",288,["D",1773248775681],"/**\n * test/_mocks/blob.ts\n *\n * In-memory blob storage mock matching Val Town's blob API shape.\n * Call blob._reset() between tests for isolation.\n */\n\nconst store = new Map();\n\nexport const blob = {\n  async getJSON(key: string): Promise {\n    const raw = store.get(key);\n    if (raw === undefined) return undefined;\n    return JSON.parse(raw) as T;\n  },\n\n  async setJSON(key: string, value: unknown): Promise {\n    store.set(key, JSON.stringify(value));\n  },\n\n  async delete(key: string): Promise {\n    store.delete(key);\n  },\n\n  async list(prefix?: string): Promise> {\n    const results: Array<{ key: string; size: number; lastModified: string }> = [];\n    for (const [key, value] of store.entries()) {\n      if (prefix && !key.startsWith(prefix)) continue;\n      results.push({\n        key,\n        size: new Blob([value]).size,\n        lastModified: new Date().toISOString(),\n      });\n    }\n    return results;\n  },\n\n  async copy(from: string, to: string): Promise {\n    const value = store.get(from);\n    if (value !== undefined) {\n      store.set(to, value);\n    }\n  },\n\n  async move(from: string, to: string): Promise {\n    const value = store.get(from);\n    if (value !== undefined) {\n      store.set(to, value);\n      store.delete(from);\n    }\n  },\n\n  _reset(): void {\n    store.clear();\n  },\n};\n",[],[741,751,785],"94922168-1d6c-11f1-9109-42dde27851f2",13,["D",1773248761136],[632,633,634,635,636,637],[741,751],"942269cc-1d6c-11f1-9109-42dde27851f2",5,["D",1773248760409],[631,638],[741],"5d134d92-1d77-11f1-bc9c-42dde27851f2","tickets.cron_test.ts","3b1e9296-1d77-11f1-a67b-42dde27851f2","940748e0-1d6c-11f1-9109-42dde27851f2",313,["D",1773253392463],"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",[],[811,803],"services","5a2816b8-5caf-11f1-bcf4-1607ee4eb77e","tickets.cron.ts","94fc763a-1d6c-11f1-95a1-42dde27851f2",366,["D",1780204362663],"/**\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    mutePath: \"cron:tickets\",\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",[],[811,813],"5b42b2fa-1d77-11f1-8c19-42dde27851f2","scheduled-messages.cron_test.ts","3afa4c10-1d77-11f1-852c-42dde27851f2",312,["D",1773253389444],"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",[],[811,821],"571eedb6-5caf-11f1-a63f-1607ee4eb77e","scheduled-messages.cron.ts","95405670-1d6c-11f1-a9cb-42dde27851f2",365,["D",1780204357554],"/**\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    mutePath: \"cron:scheduled-messages\",\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",[],[811,829],"56a63eb0-1d77-11f1-b8b5-42dde27851f2","reminders.cron_test.ts","3af2468c-1d77-11f1-96ec-42dde27851f2",310,["D",1773253381711],"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",[],[811,837],"544f404a-5caf-11f1-bae0-1607ee4eb77e","reminders.cron.ts","96ebb366-1d6c-11f1-a405-42dde27851f2",364,["D",1780204352740],"/**\n * services/reminders.cron.ts\n *\n * Cron job that delivers due reminders 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 { Reminder } from \"../discord/interactions/commands/remind.ts\";\nimport { runCron, deliverWithRetry } from \"../discord/helpers/cron.ts\";\n\nconst CONCURRENCY = 5;\n\nexport default async function () {\n  await runCron({\n    name: \"ReminderCron\",\n    mutePath: \"cron:reminders\",\n    prefix: \"reminder:\",\n    maxDue: 100,\n    async process(entry, logger) {\n      const reminder = entry.value as Reminder;\n\n      await deliverWithRetry({\n        entry,\n        validate: (v) => !!(v as Reminder)?.channelId && !!(v as Reminder)?.userId && !!(v as Reminder)?.message,\n        deliver: (v) => {\n          const r = v as Reminder;\n          return discordBotFetch(\"POST\", `channels/${r.channelId}/messages`, {\n            content: `\\u23F0 <@${r.userId}>, reminder: ${r.message}`,\n          });\n        },\n        logger,\n        entityLabel: \"reminder\",\n      });\n    },\n  });\n}\n",[],[811,845],"5907d86c-1d77-11f1-bc9c-42dde27851f2","polls.cron_test.ts","3b04299c-1d77-11f1-9a9b-42dde27851f2",311,["D",1773253385704],"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",[],[811,853],"4ccdd08c-5aef-11f1-90cf-ee650bb23af1","polls.cron.ts","9539049c-1d6c-11f1-95a1-42dde27851f2",363,["D",1780011925721],"/**\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    mutePath: \"cron:polls\",\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",[],[811,861],"357e3de0-1d6e-11f1-beb3-42dde27851f2","livestreams.cron_test.ts","94f85398-1d6c-11f1-9ac8-42dde27851f2",294,["D",1773249460612],"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",[],[811,869],"420f38ca-5aef-11f1-aa97-ee650bb23af1","livestreams.cron.ts","9508cc6e-1d6c-11f1-95a1-42dde27851f2",362,["D",1780011907695],"/**\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 { logConfig, isPathMuted } from \"../discord/persistence/log-config.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  // Check if this cron path is muted\n  try {\n    const mutedPaths = await logConfig.getMutedPaths();\n    logger.muted = isPathMuted(\"cron:livestreams\", mutedPaths);\n  } catch { /* proceed unmuted */ }\n\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",[],[811,877],"c494b0f6-1fc4-11f1-a3c4-42dde27851f2","interactions.http_test.ts","95048c26-1d6c-11f1-b767-42dde27851f2",357,["D",1773506539378],"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\n// --- Bootstrap endpoint ---\n\nDeno.test(\"http: GET ?bootstrap=true without auth returns 401\", async () => {\n  const req = new Request(\"https://example.com/?bootstrap=true\");\n  const res = await handler(req);\n  assertEquals(res.status, 401);\n});\n\nDeno.test(\"http: GET ?bootstrap=true with correct auth returns success\", async () => {\n  const req = new Request(\"https://example.com/?bootstrap=true\", {\n    headers: { Authorization: \"Bearer test_admin_password\" },\n  });\n  const res = await handler(req);\n  assertEquals(res.status, 200);\n  const body = await res.json();\n  assertEquals(body.ok, true);\n  assert(body.message.includes(\"KV table\"), \"Should mention KV table in message\");\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",[],[811,885],"5daeddc6-5caf-11f1-be77-1607ee4eb77e","interactions.http.ts","94eda2f4-1d6c-11f1-9ac8-42dde27851f2",["D",1780204368587],"/**\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 *   ?bootstrap=true          — create KV table and indexes (idempotent)\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 { bootstrapKvTable } from \"../discord/persistence/kv.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      if (url.searchParams.get(\"bootstrap\") === \"true\") {\n        const authError = await checkPassword(req);\n        if (authError) return authError;\n        try {\n          await bootstrapKvTable();\n          return Response.json({ ok: true, message: \"KV table and indexes created\" });\n        } catch (err) {\n          logger.error(\"Bootstrap failed:\", err);\n          return Response.json({ error: \"Bootstrap 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",[],[811,893],"3aeb744c-1d77-11f1-bc02-42dde27851f2","giveaways.cron_test.ts","9516cf08-1d6c-11f1-b767-42dde27851f2",301,["D",1773253335188],"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    createdBy: \"admin1\",\n    createdAt: Date.now() - 3600000,\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",[],[811,900],"34b77fac-5aef-11f1-90cf-ee650bb23af1","giveaways.cron.ts","9527cf60-1d6c-11f1-ac6f-42dde27851f2",361,["D",1780011885313],4,"/**\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    mutePath: \"cron:giveaways\",\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",[],[811,908],"eaf9558c-1d79-11f1-aa61-42dde27851f2","example.cron.ts","950ff656-1d6c-11f1-95a1-42dde27851f2",314,["D",1773254489552],"/**\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",[],[811,917],"94074818-1d6c-11f1-9109-42dde27851f2",["D",1773248760230],[615,616,617,618,619,620,621,622,623,624,625,626,627,628,629],[811],"99630a86-1d6c-11f1-bd27-42dde27851f2","pages_test.ts","99630b3a-1d6c-11f1-bd27-42dde27851f2",166,["D",1773248769138],"import { assert, assertEquals } from \"../test/assert.ts\";\nimport {\n  page,\n  htmlResponse,\n  termsPage,\n  privacyPage,\n  linkedRolesSuccessPage,\n  linkedRolesErrorPage,\n} from \"./pages.ts\";\n\nDeno.test(\"page: returns valid HTML structure\", () => {\n  const html = page(\"Test Title\", \"Hello
\");\n  assert(html.includes(\"\"));\n  assert(html.includes(\"Test Title\"));\n  assert(html.includes(\"Hello
\"));\n});\n\nDeno.test(\"htmlResponse: sets content-type header\", () => {\n  const res = htmlResponse(\"test
\");\n  assertEquals(res.headers.get(\"Content-Type\"), \"text/html; charset=utf-8\");\n});\n\nDeno.test(\"termsPage: contains terms content\", async () => {\n  const res = termsPage();\n  const html = await res.text();\n  assert(html.includes(\"Terms of Service\"));\n  assert(html.includes(\"Acceptance of Terms\"));\n});\n\nDeno.test(\"privacyPage: contains privacy content\", async () => {\n  const res = privacyPage();\n  const html = await res.text();\n  assert(html.includes(\"Privacy Policy\"));\n  assert(html.includes(\"Information We Collect\"));\n});\n\nDeno.test(\"linkedRolesSuccessPage: escapes XSS in username\", async () => {\n  const res = linkedRolesSuccessPage('');\n  const html = await res.text();\n  assert(!html.includes(\"\", \"body
\");\n  assert(!html.includes(\"
History · linked-roles
