[{"_1":2,"_173":-5,"_174":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":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","notificationCount",0,"flagDenols","ENV",{"_36":37,"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","2f607f7b74b4e52529fb75176d403d8b5b284eb1","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":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",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_149":150,"_170":171,"_172":-5},"handle","boucher","name","vt-discord","path","backend/webhooks.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":72,"_110":-5,"_12":111,"_112":113,"_114":115,"_116":-5,"_117":118,"_14":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":129,"_132":133,"_135":136,"_148":20},"id","2e9210fa-2711-11f0-a12e-569c3dd06744","createdAt",["D",1746161519737],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","f48e9547-27bd-4117-9554-682f2eb67a4b","pinnedFileId","751ff414-2884-11f0-b137-569c3dd06744","pinPreview",true,"screenshotVersion","likeCount",2,"4f5bd3a8-17ca-44d2-b569-1c9fcdb094b9","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_130":131},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXh1eU1FSEZMMTNaWFM1Rm5rYXBrd0pBRyIsImluaXRpYWxzIjoiUkIifQ","org",{"_93":94,"_134":131},"avatar","branch",{"_137":138,"_95":43,"_101":139,"_140":102,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":96,"_147":94},"version",34,"2e944ece-2711-11f0-a12e-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":151,"_95":152,"_153":154,"_155":156,"_157":139,"_158":159,"_160":115,"_103":161,"_137":118,"_162":163,"_164":165,"_166":20,"_167":-5,"_97":168},"2124b5aa-2886-11f0-8f9b-569c3dd06744","webhooks.ts","fileId","e8e6fb3e-2859-11f0-8c0e-569c3dd06744","parentId","e89244b8-2859-11f0-b4f5-569c3dd06744","branchId","branchVersion",25,"latest",["D",1746321699516],"fileType","script","content","// Webhook handlers for Discord events\nimport { processMessage } from \"./bot.ts\";\nimport * as discord from \"./discord.ts\";\nimport * as db from \"./database.ts\";\nimport * as importer from \"./importer.ts\";\n\n// Process Discord interactions\nexport async function handleInteraction(request: Request): Promise {\n try {\n console.log(\"Received Discord interaction request\");\n \n // Log headers for debugging\n const headers = {};\n for (const [key, value] of request.headers.entries()) {\n headers[key] = value;\n }\n console.log(\"Request headers:\", JSON.stringify(headers));\n \n const bodyText = await request.text();\n console.log(\"Request body:\", bodyText);\n \n // Parse the body as JSON\n const body = JSON.parse(bodyText);\n \n // Handle Discord interaction types\n if (body.type === 1) {\n // Respond to Discord PING for endpoint verification\n console.log(\"Responding to Discord PING verification\");\n return new Response(JSON.stringify({ type: 1 }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n } else if (body.type === 2) {\n // Handle commands\n console.log(\"Handling command:\", body.data?.name);\n return handleCommand(body);\n } else if (body.type === 3) {\n // Handle message components interactions\n console.log(\"Handling component interaction\");\n return handleComponentInteraction(body);\n }\n \n console.log(\"Invalid interaction type:\", body.type);\n return new Response(\"Invalid interaction type\", { status: 400 });\n } catch (error) {\n console.error(\"Error in handleInteraction:\", error);\n console.log(\"Error stack:\", error.stack);\n return new Response(\"Internal server error\", { status: 500 });\n }\n}\n\n// Process Discord messages from webhooks\nexport async function handleMessageCreate(request: Request): Promise {\n try {\n const body = await request.json();\n \n // Process the message\n await processMessage(body);\n \n return new Response(\"Message processed\", { status: 200 });\n } catch (error) {\n console.error(\"Error handling message create webhook:\", error);\n return new Response(\"Error processing message\", { status: 500 });\n }\n}\n\n// Handle Discord slash commands\nasync function handleCommand(interaction: any): Promise {\n const { name } = interaction.data;\n \n switch (name) {\n case 'query':\n return handleQueryCommand(interaction);\n case 'project':\n return handleProjectCommand(interaction);\n case 'links':\n return handleLinksCommand(interaction);\n case 'import':\n return handleImportCommand(interaction);\n default:\n return respondToInteraction(\"Unknown command\");\n }\n}\n\n// Handle message component interactions (buttons, select menus)\nasync function handleComponentInteraction(interaction: any): Promise {\n const customId = interaction.data.custom_id;\n \n // Handle different component interactions based on customId\n if (customId.startsWith(\"link_\")) {\n return handleLinkInteraction(interaction, customId);\n } else if (customId.startsWith(\"project_\")) {\n return handleProjectInteraction(interaction, customId);\n }\n \n return respondToInteraction(\"Unknown interaction\");\n}\n\n// Handle AI query command\nasync function handleQueryCommand(interaction: any): Promise {\n const query = interaction.data.options.find((o: any) => o.name === 'question')?.value;\n \n if (!query) {\n return respondToInteraction(\"Please provide a question to ask\");\n }\n \n // Send an initial response so Discord knows we're processing\n await deferReply(interaction.id, interaction.token);\n \n try {\n // Get the user and their partner's ID\n // For now we'll assume the command is always run by the couple\n // In a production version, you'd want to configure this\n const userId = interaction.member.user.id;\n \n // TODO: Replace this with a proper lookup of the partner\n // This could be from a configuration setting in your database\n const partnerUserId = \"PARTNER_USER_ID\"; // Replace with actual lookup\n \n // Get relevant messages based on the query\n const relevantMessages = await db.getRelevantMessagesForQuery(\n query, \n [userId, partnerUserId], \n 100\n );\n \n if (!relevantMessages.length) {\n return editReply(\n interaction.token, \n \"I couldn't find any relevant messages in your history\"\n );\n }\n \n // Create a user map for formatting\n const userMap = new Map();\n userMap.set(userId, interaction.member.user.username);\n userMap.set(partnerUserId, \"Partner\"); // Replace with actual lookup\n \n // Ask Claude for analysis\n const claudeResponse = await db.analyzeMessagesWithClaude(\n relevantMessages,\n userMap,\n query\n );\n \n return editReply(interaction.token, claudeResponse);\n } catch (error) {\n console.error(\"Error handling query command:\", error);\n return editReply(\n interaction.token, \n \"Sorry, I encountered an error processing your query\"\n );\n }\n}\n\n// Handle project management command\nasync function handleProjectCommand(interaction: any): Promise {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'create':\n return handleCreateProject(interaction);\n case 'list':\n return handleListProjects(interaction);\n case 'view':\n return handleViewProject(interaction);\n default:\n return respondToInteraction(\"Unknown project subcommand\");\n }\n}\n\n// Handle links command\nasync function handleLinksCommand(interaction: any): Promise {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'list':\n return handleListLinks(interaction);\n case 'categorize':\n return handleCategorizeLink(interaction);\n case 'search':\n return handleSearchLinks(interaction);\n default:\n return respondToInteraction(\"Unknown links subcommand\");\n }\n}\n\n// Handle creating a new project\nasync function handleCreateProject(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const name = options.find((o: any) => o.name === 'name')?.value;\n const description = options.find((o: any) => o.name === 'description')?.value;\n \n if (!name) {\n return respondToInteraction(\"Please provide a project name\");\n }\n \n try {\n const projectId = await db.createProject({\n name,\n description,\n created_at: Date.now(),\n is_active: true\n });\n \n if (projectId) {\n return respondToInteraction(`Project \"${name}\" created successfully! ID: ${projectId}`);\n } else {\n return respondToInteraction(\"Failed to create project\");\n }\n } catch (error) {\n console.error(\"Error creating project:\", error);\n return respondToInteraction(\"Error creating project\");\n }\n}\n\n// Handle listing projects\nasync function handleListProjects(interaction: any): Promise {\n try {\n const projects = await db.getProjects();\n \n if (projects.length === 0) {\n return respondToInteraction(\"No projects found\");\n }\n \n let response = \"**Your Projects:**\\n\";\n \n for (const project of projects) {\n const date = new Date(project.created_at).toISOString().split('T')[0];\n response += `**${project.id}**: ${project.name} (${date})\\n`;\n \n if (project.description) {\n response += ` *${project.description}*\\n`;\n }\n }\n \n return respondToInteraction(response);\n } catch (error) {\n console.error(\"Error listing projects:\", error);\n return respondToInteraction(\"Error listing projects\");\n }\n}\n\n// Handle viewing a project\nasync function handleViewProject(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const projectId = options.find((o: any) => o.name === 'id')?.value;\n \n if (!projectId) {\n return respondToInteraction(\"Please provide a project ID\");\n }\n \n try {\n // Get project details\n const project = await db.getProject(projectId);\n \n if (!project) {\n return respondToInteraction(\"Project not found\");\n }\n \n // Get project messages\n const messages = await db.getProjectMessages(projectId, 10);\n \n let response = `**Project: ${project.name}**\\n`;\n \n if (project.description) {\n response += `*${project.description}*\\n\\n`;\n }\n \n if (messages.length === 0) {\n response += \"No messages in this project yet.\";\n } else {\n response += \"**Recent messages:**\\n\";\n \n for (const message of messages) {\n const date = new Date(message.timestamp).toISOString().split('T')[0];\n const preview = message.content.length > 100 \n ? message.content.substring(0, 97) + \"...\" \n : message.content;\n \n response += `[${date}] ${preview}\\n`;\n }\n }\n \n // Add a button to view more\n const components = [\n {\n type: 1,\n components: [\n {\n type: 2,\n style: 1,\n label: \"View More Messages\",\n custom_id: `project_view_more:${projectId}:10`\n }\n ]\n }\n ];\n \n return respondToInteraction(response, false, components);\n } catch (error) {\n console.error(\"Error viewing project:\", error);\n return respondToInteraction(\"Error viewing project\");\n }\n}\n\n// Handle listing links\nasync function handleListLinks(interaction: any): Promise {\n try {\n const options = interaction.data.options[0].options;\n const limit = options.find((o: any) => o.name === 'limit')?.value || 10;\n \n const links = await db.getLinks(limit);\n \n if (links.length === 0) {\n return respondToInteraction(\"No links found\");\n }\n \n let response = \"**Recently Shared Links:**\\n\";\n \n for (const link of links) {\n const date = new Date(link.timestamp).toISOString().split('T')[0];\n const category = link.category ? `[${link.category}] ` : '';\n \n response += `**${link.id}**: ${category}${link.url} (${date})\\n`;\n }\n \n return respondToInteraction(response);\n } catch (error) {\n console.error(\"Error listing links:\", error);\n return respondToInteraction(\"Error listing links\");\n }\n}\n\n// Handle categorizing a link\nasync function handleCategorizeLink(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const linkId = options.find((o: any) => o.name === 'id')?.value;\n const category = options.find((o: any) => o.name === 'category')?.value;\n \n if (!linkId || !category) {\n return respondToInteraction(\"Please provide a link ID and category\");\n }\n \n try {\n const success = await db.updateLinkCategory(linkId, category);\n \n if (success) {\n return respondToInteraction(`Link categorized as \"${category}\"`);\n } else {\n return respondToInteraction(\"Failed to categorize link\");\n }\n } catch (error) {\n console.error(\"Error categorizing link:\", error);\n return respondToInteraction(\"Error categorizing link\");\n }\n}\n\n// Handle searching links\nasync function handleSearchLinks(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const query = options.find((o: any) => o.name === 'query')?.value;\n \n if (!query) {\n return respondToInteraction(\"Please provide a search query\");\n }\n \n try {\n const links = await db.searchLinks(query);\n \n if (links.length === 0) {\n return respondToInteraction(`No links found matching \"${query}\"`);\n }\n \n let response = `**Links matching \"${query}\":**\\n`;\n \n for (const link of links) {\n const date = new Date(link.timestamp).toISOString().split('T')[0];\n const category = link.category ? `[${link.category}] ` : '';\n \n response += `**${link.id}**: ${category}${link.url} (${date})\\n`;\n }\n \n return respondToInteraction(response);\n } catch (error) {\n console.error(\"Error searching links:\", error);\n return respondToInteraction(\"Error searching links\");\n }\n}\n\n// Handle import command\nasync function handleImportCommand(interaction: any): Promise {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'channel':\n return handleImportChannel(interaction);\n case 'dm':\n return handleInitiateDmImport(interaction);\n default:\n return respondToInteraction(\"Unknown import subcommand\");\n }\n}\n\n// Handle importing from a channel\nasync function handleImportChannel(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const channelId = options.find((o: any) => o.name === 'channel_id')?.value;\n const limit = options.find((o: any) => o.name === 'limit')?.value || 100;\n const before = options.find((o: any) => o.name === 'before')?.value;\n \n if (!channelId) {\n return respondToInteraction(\"Please provide a channel ID\");\n }\n \n // Send an initial response so Discord knows we're processing\n await deferReply(interaction.id, interaction.token);\n \n try {\n // Import messages from the channel\n const result = await importer.importChannelHistory(channelId, limit, before);\n \n let response = `✅ Import completed!\\n\\n**Results:**\\n`;\n response += `- Messages imported: ${result.messagesImported}\\n`;\n response += `- Links extracted: ${result.linksImported}\\n`;\n \n // Check for errors\n if (result.errors.length > 0) {\n // Find the oldest_id error message for pagination\n const oldestIdMessage = result.errors.find(err => err.startsWith('oldest_id:'));\n if (oldestIdMessage) {\n const oldestId = oldestIdMessage.split(':')[1];\n response += `\\nTo import more messages, use this command again with the \\`before\\` parameter set to: \\`${oldestId}\\``;\n }\n \n // Filter out the oldest_id message and report other errors\n const actualErrors = result.errors.filter(err => !err.startsWith('oldest_id:'));\n if (actualErrors.length > 0) {\n response += `\\n\\n**Errors:**\\n`;\n for (const error of actualErrors) {\n response += `- ${error}\\n`;\n }\n }\n }\n \n return editReply(interaction.token, response);\n } catch (error) {\n console.error(\"Error importing channel history:\", error);\n return editReply(interaction.token, \"Error importing channel history\");\n }\n}\n\n// Handle initiating a DM import\nasync function handleInitiateDmImport(interaction: any): Promise {\n // Create a unique identifier for this upload\n const uploadId = crypto.randomUUID();\n \n console.log(\"DM import initiated by user:\", interaction.member?.user?.id);\n \n // Get the VAL_TOWN_URL from env\n const valTownUrl = Deno.env.get(\"VAL_TOWN_URL\") || \"your-val-town-url\";\n \n // Create a message with instructions for uploading DM history\n let response = `**Discord DM History Import**\\n\\n`;\n response += `To import your Discord DM history:\\n\\n`;\n response += `1. Follow the steps in the Discord app to download your data:\\n`;\n response += ` - Go to User Settings → Privacy & Safety\\n`;\n response += ` - Scroll down to \"Request all of my Data\"\\n`;\n response += ` - Click the request button and wait for Discord to email you\\n\\n`;\n response += `2. Once you receive your data, extract the package\\n\\n`;\n response += `3. Find the JSON file with your DM history (usually in messages/ folder)\\n\\n`;\n response += `4. Go to this special upload URL to send the file to this bot:\\n`;\n response += ` ${valTownUrl}/upload/${uploadId}\\n\\n`;\n response += `This URL will be valid for 24 hours. Your data will be processed securely and only stored in this bot's database.`;\n \n console.log(\"Generated upload URL:\", `${valTownUrl}/upload/${uploadId}`);\n \n // TODO: Store the uploadId in your database with an expiration time\n // This would allow you to validate it when the upload arrives\n \n return respondToInteraction(response);\n}\n\n// Handle link interactions (from buttons, etc.)\nasync function handleLinkInteraction(interaction: any, customId: string): Promise {\n // Parse the custom ID\n const [prefix, action, linkId] = customId.split(':');\n \n if (action === 'view') {\n // TODO: Implement link viewing\n return respondToInteraction(\"Link view not yet implemented\");\n }\n \n return respondToInteraction(\"Unknown link interaction\");\n}\n\n// Handle project interactions (from buttons, etc.)\nasync function handleProjectInteraction(interaction: any, customId: string): Promise {\n // Parse the custom ID\n const [prefix, action, projectId, offset] = customId.split(':');\n \n if (action === 'view_more') {\n // TODO: Implement pagination for project messages\n return respondToInteraction(\"Pagination not yet implemented\");\n }\n \n return respondToInteraction(\"Unknown project interaction\");\n}\n\n// Helper function to respond to Discord interactions\nfunction respondToInteraction(content: string, ephemeral = false, components?: any[]): Response {\n const response: any = {\n type: 4,\n data: {\n content,\n flags: ephemeral ? 64 : 0\n }\n };\n \n if (components) {\n response.data.components = components;\n }\n \n return new Response(\n JSON.stringify(response),\n { headers: { \"Content-Type\": \"application/json\" } }\n );\n}\n\n// Helper function to send a deferred response (for long-running commands)\nasync function deferReply(interactionId: string, interactionToken: string): Promise {\n try {\n await discord.discordRequest(\n `/interactions/${interactionId}/${interactionToken}/callback`,\n \"POST\",\n {\n type: 5, // DEFERRED_CHANNEL_MESSAGE_WITH_SOURCE\n data: {}\n }\n );\n } catch (error) {\n console.error(\"Error deferring reply:\", error);\n }\n}\n\n// Helper function to edit a deferred response\nasync function editReply(interactionToken: string, content: string): Promise {\n try {\n await discord.discordRequest(\n `/webhooks/${Deno.env.get(\"DISCORD_APPLICATION_ID\")}/${interactionToken}/messages/@original`,\n \"PATCH\",\n {\n content\n }\n );\n \n // Return an empty 200 response since we've already responded via the webhook\n return new Response(\"\", { status: 200 });\n } catch (error) {\n console.error(\"Error editing reply:\", error);\n return new Response(\"Error editing reply\", { status: 500 });\n }\n}","deleted","label",[169,152],"backend","permalink","https://www.val.town/x/boucher/vt-discord/code/backend/webhooks.ts","extension","actionData","errors"]