[{"_1":2,"_183":-5,"_184":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e9e636d7b466d0cb012ac9b89f74068c1d9c5525","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_156":157,"_180":181,"_182":-5},"handle","catalloc","name","catnip","path","discord/interactions/handler.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":-5,"_12":114,"_115":-5,"_116":20,"_117":-5,"_118":-5,"_119":33,"_14":120,"_121":122,"_123":124,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":134,"_137":138,"_142":143,"_155":20},"id","f89e4358-134e-11f1-911b-42dde27851f2","createdAt",["D",1772136532467],"deletedAt","legacyEnvVars","privacy","public","description","Open source Discord bot template built for Val Town","imageUrl","d06b6c80-f3a1-11ef-89a3-8735e07158f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","e03963fb-ecc4-48fb-bc25-0173a8b9a8c8","tursoName","f89e4358134e11f1911b42dde27851f2","tursoHostname","f89e4358134e11f1911b42dde27851f2-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_135":136},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0478d851-5bca-4d5e-6593-fb952af01c00/square512","org",{"_95":96,"_139":136,"_12":114,"_140":141},"avatar","tier","pro","branch",{"_144":145,"_97":45,"_103":146,"_147":104,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":98,"_154":96},"version",233,"f89e7d78-134e-11f1-911b-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":158,"_97":159,"_160":161,"_162":163,"_164":146,"_165":166,"_167":168,"_105":169,"_144":170,"_171":172,"_173":174,"_175":20,"_176":-5,"_99":177},"5d5e3d0c-1520-11f1-8911-42dde27851f2","handler.ts","fileId","f9e43b3c-134e-11f1-abb8-42dde27851f2","parentId","f8fe798a-134e-11f1-911b-42dde27851f2","branchId","branchVersion",185,"latest",true,["D",1772336417465],6,"fileType","script","content","/**\n * discord/interactions/handler.ts\n *\n * Single source of truth for Discord interaction handling.\n * All HTTP endpoints should import from this module.\n */\n\nimport { getCommand, getComponentHandler } from \"./registry.ts\";\nimport type { Command, CommandResult } from \"./define-command.ts\";\nimport {\n InteractionResponseType,\n OptionTypes,\n createAutocompleteResponse,\n} from \"./patterns.ts\";\nimport { createLogger } from \"../webhook/logger.ts\";\nimport { CONFIG, isGuildAdmin } from \"../constants.ts\";\nimport { UserFacingError } from \"./errors.ts\";\nimport type { ComponentContext } from \"./define-component.ts\";\n\nconst INTERACTION_TYPES = {\n PING: 1,\n APPLICATION_COMMAND: 2,\n MESSAGE_COMPONENT: 3,\n APPLICATION_COMMAND_AUTOCOMPLETE: 4,\n MODAL_SUBMIT: 5,\n} as const;\n\nconst logger = createLogger(\"InteractionHandler\", {\n minLevel: \"info\",\n});\n\nconst DEFERRED_TIMEOUT_MS = 9 * 60 * 1000; // 9 minutes (pro account 10-min limit, 1-min buffer)\nconst MAX_COOLDOWN_ENTRIES = 10_000;\nconst cooldowns = new Map();\nlet interactionCount = 0;\n\nexport function getInteractionCount(): number {\n return interactionCount;\n}\n\nlet cachedKey: CryptoKey | null = null;\n\nasync function getPublicKey(): Promise {\n if (!cachedKey) {\n cachedKey = await crypto.subtle.importKey(\n \"raw\",\n hexToUint8Array(CONFIG.publicKey),\n { name: \"Ed25519\" },\n false,\n [\"verify\"],\n );\n }\n return cachedKey;\n}\n\nfunction hexToUint8Array(hex: string): Uint8Array {\n const bytes = new Uint8Array(hex.length / 2);\n for (let i = 0; i < bytes.length; i++) {\n bytes[i] = parseInt(hex.substring(i * 2, i * 2 + 2), 16);\n }\n return bytes;\n}\n\nasync function verifyDiscordRequest(\n body: string,\n signature: string,\n timestamp: string,\n): Promise {\n try {\n const key = await getPublicKey();\n const message = new TextEncoder().encode(timestamp + body);\n return await crypto.subtle.verify(\"Ed25519\", key, hexToUint8Array(signature), message);\n } catch {\n return false;\n }\n}\n\nfunction ephemeralResponse(content: string): Response {\n return Response.json({\n type: InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE,\n data: { content, flags: 64 },\n });\n}\n\nfunction buildPayload(\n message: string,\n result?: { embed?: any; components?: any[] },\n ephemeral = true,\n): Record {\n const data: Record = { content: message };\n if (ephemeral) data.flags = 64;\n if (result?.embed) data.embeds = [result.embed];\n if (result?.components) data.components = result.components;\n return data;\n}\n\n/**\n * Extract subcommand name and nested options from Discord interaction data.\n */\nfunction parseSubcommandOptions(\n dataOptions: any[] | undefined,\n): { subcommand: string | null; options: Record } {\n const options: Record = {};\n let subcommand: string | null = null;\n\n if (!dataOptions || !Array.isArray(dataOptions)) {\n return { subcommand, options };\n }\n\n for (const opt of dataOptions) {\n if (\n opt.type === OptionTypes.SUB_COMMAND ||\n opt.type === OptionTypes.SUB_COMMAND_GROUP\n ) {\n subcommand = opt.name;\n if (opt.options && Array.isArray(opt.options)) {\n for (const nestedOpt of opt.options) {\n if (nestedOpt.type === OptionTypes.SUB_COMMAND) {\n subcommand = `${opt.name}:${nestedOpt.name}`;\n if (nestedOpt.options) {\n for (const innerOpt of nestedOpt.options) {\n options[innerOpt.name] = innerOpt.value;\n }\n }\n } else {\n options[nestedOpt.name] = nestedOpt.value;\n }\n }\n }\n } else {\n options[opt.name] = opt.value;\n }\n }\n\n return { subcommand, options };\n}\n\nfunction formatResultMessage(result: CommandResult): string {\n if (result.message) return result.message;\n if (result.error) return `Error: ${result.error}`;\n return result.success ? \"Command completed\" : \"Command failed\";\n}\n\nasync function handleAutocompleteInteraction(body: any): Promise {\n const commandName = body.data.name;\n try {\n const cmd = getCommand(commandName);\n if (!cmd?.autocomplete) return createAutocompleteResponse([]);\n return await cmd.autocomplete(body, cmd.config);\n } catch (error) {\n logger.error(`Autocomplete error for ${commandName}:`, error);\n return createAutocompleteResponse([\n { name: \"Error fetching options\", value: \"_error\" },\n ]);\n }\n}\n\nasync function handleSlashCommandInteraction(body: any): Promise {\n const commandName = body.data.name;\n const command = getCommand(commandName);\n\n if (!command) {\n return ephemeralResponse(\"Error: Unknown command\");\n }\n\n const guildId = body.guild_id;\n const userId = body.member?.user?.id || body.user?.id;\n\n // Guild-only guard — guild-scoped commands cannot be used in DMs\n if (command.registration.type === \"guild\" && !body.guild_id) {\n return ephemeralResponse(\"This command can only be used in a server.\");\n }\n\n // Admin-only guard\n if (command.adminOnly) {\n if (!body.guild_id) {\n return ephemeralResponse(\"This command can only be used in a server.\");\n }\n const memberRoles: string[] = body.member?.roles || [];\n const authorized = await isGuildAdmin(guildId, userId, memberRoles, body.member?.permissions);\n if (!authorized) {\n return ephemeralResponse(\n \"You are not authorized to use this command.\",\n );\n }\n }\n\n // Cooldown check (with periodic eviction of expired entries, hard cap on size)\n interactionCount++;\n if (interactionCount % 100 === 0 || cooldowns.size > MAX_COOLDOWN_ENTRIES) {\n const now = Date.now();\n for (const [key, expiry] of cooldowns) {\n if (now >= expiry) cooldowns.delete(key);\n }\n }\n\n const DEFAULT_COOLDOWN = 3;\n const cooldownSeconds = command.cooldown ?? DEFAULT_COOLDOWN;\n if (cooldownSeconds > 0) {\n const cooldownKey = `${commandName}:${userId}`;\n const expiry = cooldowns.get(cooldownKey);\n if (expiry) {\n if (Date.now() < expiry) {\n const remaining = Math.ceil((expiry - Date.now()) / 1000);\n return ephemeralResponse(\n `Please wait ${remaining} second${remaining !== 1 ? \"s\" : \"\"} before using this command again.`,\n );\n }\n cooldowns.delete(cooldownKey);\n }\n cooldowns.set(cooldownKey, Date.now() + cooldownSeconds * 1000);\n }\n\n // Extract command options with subcommand support\n const { subcommand, options: parsedOptions } = parseSubcommandOptions(\n body.data.options,\n );\n\n const options: Record = {\n ...parsedOptions,\n channelId: body.channel_id,\n interactionToken: body.token,\n interactionId: body.id,\n };\n\n if (subcommand) {\n options.subcommand = subcommand;\n }\n\n const logCtx = `[cmd:${commandName} guild:${guildId} user:${userId}]`;\n\n logger.info(\n `${logCtx} Processing${subcommand ? `:${subcommand}` : \"\"} inline`,\n );\n\n // Context menu data\n const targetId = body.data.target_id;\n const resolved = body.data.resolved;\n\n const memberRoles: string[] = body.member?.roles ?? [];\n const memberPermissions: string | undefined = body.member?.permissions;\n\n // Fast-command path — respond immediately without deferring\n if (command.deferred === false) {\n try {\n const result = await command.execute({\n guildId,\n userId,\n options,\n config: command.config,\n targetId,\n resolved,\n memberRoles,\n memberPermissions,\n });\n\n // Modal response (only valid for non-deferred commands)\n if (result.modal) {\n return Response.json({\n type: InteractionResponseType.MODAL,\n data: {\n title: result.modal.title,\n custom_id: result.modal.custom_id,\n components: result.modal.components,\n },\n });\n }\n\n const message = formatResultMessage(result);\n return Response.json({\n type: InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE,\n data: buildPayload(message, result, command.ephemeral !== false),\n });\n } catch (error) {\n const ref = body.id?.slice(0, 8);\n logger.error(`${logCtx} Error executing fast command:`, error);\n const msg = error instanceof UserFacingError\n ? error.userMessage\n : \"Something went wrong\";\n return ephemeralResponse(`Error: ${msg}${ref ? ` (ref: ${ref})` : \"\"}`);\n }\n }\n\n // Deferred path — return ACK directly, execute + followup in background\n const ref = body.id?.slice(0, 8);\n\n (async () => {\n try {\n logger.info(`${logCtx} Executing...`);\n const timeout = new Promise((_, reject) =>\n setTimeout(() => reject(new Error(\"Command execution timed out\")), DEFERRED_TIMEOUT_MS),\n );\n const result = await Promise.race([\n command.execute({\n guildId,\n userId,\n options,\n config: command.config,\n targetId,\n resolved,\n memberRoles,\n memberPermissions,\n }),\n timeout,\n ]);\n const message = formatResultMessage(result);\n logger.info(`${logCtx} Sending followup`);\n await sendFollowup(body.application_id, body.token, message, result, command.ephemeral !== false);\n logger.info(`${logCtx} Completed successfully`);\n } catch (error) {\n logger.error(`${logCtx} Error executing:`, error);\n const userMsg = error instanceof UserFacingError\n ? error.userMessage\n : `Something went wrong (ref: ${ref})`;\n try {\n await sendFollowup(body.application_id, body.token, `Error: ${userMsg}`);\n } catch (followupError) {\n logger.error(`${logCtx} Failed to send error followup:`, followupError);\n }\n }\n })();\n\n const deferData: Record = {};\n if (command.ephemeral !== false) deferData.flags = 64;\n return Response.json({\n type: InteractionResponseType.DEFERRED_CHANNEL_MESSAGE_WITH_SOURCE,\n data: deferData,\n });\n}\n\nasync function sendFollowup(\n applicationId: string,\n interactionToken: string,\n content: string,\n result?: { embed?: any; components?: any[] },\n ephemeral = true,\n): Promise {\n const response = await fetch(\n `https://discord.com/api/v10/webhooks/${applicationId}/${interactionToken}`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(buildPayload(content, result, ephemeral)),\n signal: AbortSignal.timeout(30_000),\n },\n );\n\n if (!response.ok) {\n logger.error(\n `Failed to send followup: ${response.status} ${response.statusText}`,\n );\n }\n}\n\nfunction parseComponentType(discordType: number): \"button\" | \"select\" | undefined {\n if (discordType === 2) return \"button\";\n if (discordType >= 3 && discordType <= 8) return \"select\";\n return undefined;\n}\n\nasync function handleInteractiveComponent(body: any, isModal: boolean): Promise {\n const customId: string = body.data.custom_id;\n const ref = body.id?.slice(0, 8);\n\n let handlerType: \"button\" | \"select\" | \"modal\";\n if (isModal) {\n handlerType = \"modal\";\n } else {\n const componentType = parseComponentType(body.data.component_type);\n if (!componentType) {\n return ephemeralResponse(\"Unsupported component type\");\n }\n handlerType = componentType;\n }\n\n const handler = getComponentHandler(customId, handlerType);\n if (!handler) {\n return ephemeralResponse(`No handler for this ${isModal ? \"modal\" : \"component\"}`);\n }\n\n if (handler.adminOnly) {\n const userId = body.member?.user?.id || body.user?.id;\n if (!body.guild_id) {\n return ephemeralResponse(\"This action can only be used in a server.\");\n }\n const memberRoles: string[] = body.member?.roles || [];\n const authorized = await isGuildAdmin(body.guild_id, userId, memberRoles, body.member?.permissions);\n if (!authorized) {\n return ephemeralResponse(\"You are not authorized to use this action.\");\n }\n }\n\n try {\n const ctx: ComponentContext = {\n customId,\n guildId: body.guild_id,\n userId: body.member?.user?.id || body.user?.id,\n interaction: body,\n values: isModal ? undefined : body.data.values,\n };\n\n if (isModal) {\n const fields: Record = {};\n for (const row of body.data.components ?? []) {\n for (const component of row.components ?? []) {\n if (component.custom_id && component.value !== undefined) {\n fields[component.custom_id] = component.value;\n }\n }\n }\n ctx.fields = fields;\n }\n\n const result = await handler.execute(ctx);\n const responseType = !isModal && result.updateMessage\n ? InteractionResponseType.UPDATE_MESSAGE\n : InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE;\n const message = result.message || (result.error ? `Error: ${result.error}` : \"Done\");\n\n return Response.json({ type: responseType, data: buildPayload(message, result) });\n } catch (error) {\n logger.error(`${isModal ? \"Modal\" : \"Component\"} error [${customId}]:`, error);\n return ephemeralResponse(`Error: Something went wrong${ref ? ` (ref: ${ref})` : \"\"}`);\n }\n}\n\n/**\n * Main entry point for handling Discord interactions.\n * Import and use this in your HTTP endpoint.\n *\n * @example\n * ```typescript\n * import { handleInteraction } from \"../discord/interactions/handler.ts\";\n *\n * export default async function(req: Request): Promise {\n * return handleInteraction(req);\n * }\n * ```\n */\nexport async function handleInteraction(req: Request): Promise {\n try {\n const signature = req.headers.get(\"X-Signature-Ed25519\");\n const timestamp = req.headers.get(\"X-Signature-Timestamp\");\n\n if (!signature || !timestamp) {\n return new Response(\"Missing signature or timestamp\", { status: 401 });\n }\n\n const bodyText = await req.text();\n const isValid = await verifyDiscordRequest(bodyText, signature, timestamp);\n\n if (!isValid) {\n return new Response(\"Invalid signature\", { status: 401 });\n }\n\n const body = JSON.parse(bodyText);\n\n switch (body.type) {\n case INTERACTION_TYPES.PING:\n return Response.json({ type: InteractionResponseType.PONG });\n\n case INTERACTION_TYPES.APPLICATION_COMMAND_AUTOCOMPLETE:\n return handleAutocompleteInteraction(body);\n\n case INTERACTION_TYPES.APPLICATION_COMMAND:\n return handleSlashCommandInteraction(body);\n\n case INTERACTION_TYPES.MESSAGE_COMPONENT:\n return handleInteractiveComponent(body, false);\n\n case INTERACTION_TYPES.MODAL_SUBMIT:\n return handleInteractiveComponent(body, true);\n\n default:\n return ephemeralResponse(\"Unsupported interaction type\");\n }\n } catch (error) {\n logger.error(\"Interaction handler error:\", error);\n return Response.json(\n {\n type: InteractionResponseType.CHANNEL_MESSAGE_WITH_SOURCE,\n data: {\n content: \"An error occurred while processing the interaction\",\n flags: 64,\n },\n },\n { status: 500 },\n );\n }\n}\n\nexport default handleInteraction;\n\nexport const _internals = {\n hexToUint8Array,\n parseSubcommandOptions,\n formatResultMessage,\n buildPayload,\n parseComponentType,\n ephemeralResponse,\n};\n","deleted","label",[178,179,159],"discord","interactions","permalink","https://www.val.town/x/catalloc/catnip/code/discord/interactions/handler.ts","extension","actionData","errors"]