[{"_1":2,"_179":-5,"_180":-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","7d418bcdbd95115abef88d28c51e56db78c20f78","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,"_153":154,"_176":177,"_178":-5},"handle","catalloc","name","vt-discord-bot","path","discord/interactions/handler.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":74,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":-5,"_121":-5,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_139":140,"_152":20},"id","602f274c-11cb-11f1-8956-42dde27851f2","createdAt",["D",1771970061440],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","d06b6c80-f3a1-11ef-89a3-8735e07158f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","e03963fb-ecc4-48fb-bc25-0173a8b9a8c8","tursoName","tursoHostname","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_132":133},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0478d851-5bca-4d5e-6593-fb952af01c00/square512","org",{"_95":96,"_136":133,"_12":113,"_137":138},"avatar","tier","pro","branch",{"_141":142,"_97":45,"_103":143,"_144":104,"_145":-5,"_146":-5,"_147":-5,"_148":-5,"_149":-5,"_150":98,"_151":96},"version",68,"6030c714-11cb-11f1-8956-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":155,"_97":156,"_157":158,"_159":160,"_161":143,"_162":163,"_164":165,"_105":166,"_141":33,"_167":168,"_169":170,"_171":20,"_172":-5,"_99":173},"a0171ae0-11cb-11f1-abca-42dde27851f2","handler.ts","fileId","a0171b94-11cb-11f1-abca-42dde27851f2","parentId","9f83eb44-11cb-11f1-aa56-42dde27851f2","branchId","branchVersion",20,"latest",true,["D",1771970168541],"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 } 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: \"error\",\n});\n\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): Record {\n const data: Record = { content: message, 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 // Permission guard\n if (command.permissions) {\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 isAuthorizedUser =\n command.permissions.users?.includes(userId) ?? false;\n const isAuthorizedRole =\n command.permissions.roles?.some((r) => memberRoles.includes(r)) ?? false;\n if (!isAuthorizedUser && !isAuthorizedRole) {\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)\n if (++interactionCount % 100 === 0) {\n const now = Date.now();\n for (const [key, expiry] of cooldowns) {\n if (now >= expiry) cooldowns.delete(key);\n }\n }\n\n if (command.cooldown && command.cooldown > 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() + command.cooldown * 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\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 });\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),\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 result = await command.execute({\n guildId,\n userId,\n options,\n config: command.config,\n targetId,\n resolved,\n memberRoles,\n });\n const message = formatResultMessage(result);\n logger.info(`${logCtx} Sending followup`);\n await sendFollowup(body.application_id, body.token, message, result);\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 return Response.json({\n type: InteractionResponseType.DEFERRED_CHANNEL_MESSAGE_WITH_SOURCE,\n data: { flags: 64 },\n });\n}\n\nasync function sendFollowup(\n applicationId: string,\n interactionToken: string,\n content: string,\n result?: { embed?: any; components?: any[] },\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)),\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 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","deleted","label",[174,175,156],"discord","interactions","permalink","https://www.val.town/x/catalloc/vt-discord-bot/code/discord/interactions/handler.ts","extension","actionData","errors"]