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",[214],"e8accde2-2859-11f0-96d8-569c3dd06744","shared","e8acce8c-2859-11f0-96d8-569c3dd06744",4,["D",1746302706924],[221],"e8634406-2859-11f0-a8a7-569c3dd06744",["D",1746302706440],[58],"e892442c-2859-11f0-b4f5-569c3dd06744","backend","e89244b8-2859-11f0-b4f5-569c3dd06744",3,["D",1746302706739],[230],"e87e1e20-2859-11f0-a8a7-569c3dd06744",["D",1746302706620],[73],"pulls","branches","forks","envVars",{"_245":247,"_248":173},"connections",{"_245":173,"_246":173},"count","unfilledCount",7,"emptyCount",{"_28":235,"_13":73,"_56":72,"_37":-5,"_30":31,"_160":67,"_162":87,"_32":357,"_34":173,"_59":60,"_165":-5,"_61":24,"_167":-5,"_269":358,"_124":359},{"_28":350,"_13":351,"_56":352,"_37":72,"_30":31,"_160":247,"_162":87,"_32":353,"_34":173,"_59":47,"_165":354,"_61":24,"_167":-5,"_269":355,"_124":356},{"_28":229,"_13":230,"_56":231,"_37":-5,"_30":31,"_160":232,"_162":87,"_32":347,"_34":173,"_59":60,"_165":-5,"_61":24,"_167":-5,"_269":348,"_124":349},{"_28":339,"_13":340,"_56":341,"_37":231,"_30":31,"_160":342,"_162":87,"_32":343,"_34":20,"_59":164,"_165":344,"_61":24,"_167":-5,"_269":345,"_124":346},{"_28":331,"_13":332,"_56":333,"_37":231,"_30":31,"_160":334,"_162":87,"_32":335,"_34":20,"_59":164,"_165":336,"_61":24,"_167":-5,"_269":337,"_124":338},{"_28":323,"_13":324,"_56":325,"_37":231,"_30":31,"_160":326,"_162":87,"_32":327,"_34":173,"_59":164,"_165":328,"_61":24,"_167":-5,"_269":329,"_124":330},{"_28":315,"_13":316,"_56":317,"_37":231,"_30":31,"_160":318,"_162":87,"_32":319,"_34":173,"_59":164,"_165":320,"_61":24,"_167":-5,"_269":321,"_124":322},{"_28":307,"_13":308,"_56":309,"_37":231,"_30":31,"_160":110,"_162":87,"_32":310,"_34":311,"_59":164,"_165":312,"_61":24,"_167":-5,"_269":313,"_124":314},{"_28":299,"_13":300,"_56":301,"_37":231,"_30":31,"_160":302,"_162":87,"_32":303,"_34":67,"_59":164,"_165":304,"_61":24,"_167":-5,"_269":305,"_124":306},{"_28":226,"_13":58,"_56":57,"_37":-5,"_30":31,"_160":20,"_162":87,"_32":296,"_34":173,"_59":60,"_165":-5,"_61":24,"_167":-5,"_269":297,"_124":298},{"_28":220,"_13":221,"_56":222,"_37":-5,"_30":31,"_160":223,"_162":87,"_32":293,"_34":173,"_59":60,"_165":-5,"_61":24,"_167":-5,"_269":294,"_124":295},{"_28":213,"_13":214,"_56":215,"_37":-5,"_30":31,"_160":216,"_162":87,"_32":290,"_34":173,"_59":47,"_165":218,"_61":24,"_167":-5,"_269":291,"_124":292},{"_28":206,"_13":207,"_56":208,"_37":-5,"_30":31,"_160":209,"_162":87,"_32":287,"_34":173,"_59":47,"_165":211,"_61":24,"_167":-5,"_269":288,"_124":289},{"_28":199,"_13":200,"_56":201,"_37":-5,"_30":31,"_160":202,"_162":87,"_32":284,"_34":173,"_59":47,"_165":204,"_61":24,"_167":-5,"_269":285,"_124":286},{"_28":192,"_13":193,"_56":194,"_37":-5,"_30":31,"_160":195,"_162":87,"_32":281,"_34":173,"_59":47,"_165":197,"_61":24,"_167":-5,"_269":282,"_124":283},{"_28":184,"_13":185,"_56":186,"_37":-5,"_30":31,"_160":187,"_162":87,"_32":278,"_34":173,"_59":189,"_165":190,"_61":24,"_167":-5,"_269":279,"_124":280},{"_28":177,"_13":178,"_56":179,"_37":-5,"_30":31,"_160":180,"_162":87,"_32":275,"_34":173,"_59":47,"_165":182,"_61":24,"_167":-5,"_269":276,"_124":277},{"_28":169,"_13":170,"_56":85,"_37":-5,"_30":31,"_160":171,"_162":87,"_32":272,"_34":173,"_59":174,"_165":175,"_61":24,"_167":-5,"_269":273,"_124":274},{"_28":157,"_13":158,"_56":159,"_37":-5,"_30":31,"_160":161,"_162":87,"_32":268,"_34":67,"_59":164,"_165":166,"_61":24,"_167":-5,"_269":270,"_124":271},["D",1746321983950],"children",[],[158],["D",1746320981424],[],[170],["D",1746302707144],[],[178],["D",1746321983952],[],[185],["D",1746302707305],[],[193],["D",1746302707414],[],[200],["D",1746302707350],[],[207],["D",1746302707301],[],[214],["D",1746302706924],[],[221],["D",1746302706440],[],[58],"2124b5aa-2886-11f0-8f9b-569c3dd06744","webhooks.ts","e8e6fb3e-2859-11f0-8c0e-569c3dd06744",25,["D",1746321699516],"// 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}",[],[230,300],"e97cdd40-28f7-11f0-b7bc-569c3dd06744","main.ts","e8d9a5e2-2859-11f0-acf0-569c3dd06744",["D",1746370568766],6,"// Main entry point for the Discord bot\nimport { registerCommands, discordRequest } from \"./discord.ts\";\nimport { commands } from \"./bot.ts\";\nimport { handleInteraction, handleMessageCreate } from \"./webhooks.ts\";\nimport { importDiscordDataExport } from \"./importer.ts\";\nimport { initDatabase } from \"./database.ts\";\n// Using the official Anthropic JS SDK\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.10.0\";\n\n// This is critical for Discord verification - DO NOT REMOVE\nconst DISCORD_PUBLIC_KEY = Deno.env.get(\"DISCORD_PUBLIC_KEY\");\n\n// Environment variables\nconst DISCORD_TOKEN = Deno.env.get(\"DISCORD_TOKEN\");\nconst DISCORD_APPLICATION_ID = Deno.env.get(\"DISCORD_APPLICATION_ID\");\nconst ANTHROPIC_API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n\nif (!DISCORD_TOKEN || !DISCORD_APPLICATION_ID) {\n throw new Error(\"Missing required environment variables\");\n}\n\n// Initialize Claude API client\nconst anthropic = ANTHROPIC_API_KEY ? new Anthropic({\n apiKey: ANTHROPIC_API_KEY,\n}) : null;\n\n// Initialize database on startup\nawait initDatabase();\n\n// Convert hex string to Uint8Array\nfunction hexToUint8Array(hex: string): Uint8Array {\n // Remove '0x' prefix if present\n const normalizedHex = hex.startsWith('0x') ? hex.substring(2) : hex;\n \n // Ensure even number of characters\n if (normalizedHex.length % 2 !== 0) {\n throw new Error('Hex string must have an even number of characters');\n }\n \n // Create result array\n const result = new Uint8Array(normalizedHex.length / 2);\n \n // Process each byte (2 hex chars)\n for (let i = 0; i < normalizedHex.length; i += 2) {\n result[i / 2] = parseInt(normalizedHex.substring(i, i + 2), 16);\n }\n \n return result;\n}\n\n// Function to validate Discord interaction request signature\n// Discord uses Ed25519 to sign requests, and the signature is provided in the headers\nasync function validateDiscordRequest(request: Request, bodyText: string): Promise {\n // Get signature and timestamp from the request headers\n const signature = request.headers.get(\"x-signature-ed25519\");\n const timestamp = request.headers.get(\"x-signature-timestamp\");\n \n console.log(\"Validating Discord request with signature:\", signature?.substring(0, 20) + \"...\");\n console.log(\"Timestamp:\", timestamp);\n console.log(\"Public key available:\", !!DISCORD_PUBLIC_KEY);\n \n if (DISCORD_PUBLIC_KEY) {\n console.log(\"Public key length:\", DISCORD_PUBLIC_KEY.length);\n console.log(\"Public key prefix:\", DISCORD_PUBLIC_KEY.substring(0, 10) + \"...\");\n }\n \n // If we're missing either of these headers, the request is not valid\n if (!signature || !timestamp || !DISCORD_PUBLIC_KEY) {\n console.error(\"Missing signature, timestamp, or public key\");\n return false;\n }\n \n try {\n // Convert hex strings to Uint8Arrays\n const signatureUint8Array = hexToUint8Array(signature);\n const messageUint8Array = new TextEncoder().encode(timestamp + bodyText);\n const publicKeyUint8Array = hexToUint8Array(DISCORD_PUBLIC_KEY);\n \n console.log(\"Signature length:\", signatureUint8Array.length);\n console.log(\"Public key length:\", publicKeyUint8Array.length);\n console.log(\"Message length:\", messageUint8Array.length);\n\n // Import the public key\n const cryptoKey = await crypto.subtle.importKey(\n 'raw',\n publicKeyUint8Array,\n { name: 'Ed25519', namedCurve: 'Ed25519' },\n false,\n ['verify']\n );\n \n // Verify the signature\n const isValid = await crypto.subtle.verify(\n 'Ed25519',\n cryptoKey,\n signatureUint8Array,\n messageUint8Array\n );\n \n if (isValid) {\n console.log(\"Discord signature verification SUCCESSFUL\");\n } else {\n console.error(\"Discord signature verification FAILED\");\n }\n \n return isValid;\n } catch (error) {\n console.error(\"Error validating request:\", error);\n console.error(\"Error details:\", error.message);\n console.error(\"Error stack:\", error.stack);\n return false;\n }\n}\n\n// Function to handle incoming requests\nexport default async function(req: Request) {\n try {\n console.log(`Request received: ${req.method} ${new URL(req.url).pathname}`);\n const url = new URL(req.url);\n \n // Special handling for Discord interaction requests\n if (req.headers.has(\"x-signature-ed25519\") && req.headers.has(\"x-signature-timestamp\")) {\n \n console.log(\"Discord interaction request received, validating...\");\n \n // Clone the request since we need to read the body for validation\n // but also need to pass it to the handler later\n const clonedReq = req.clone();\n \n // Read the body for verification\n const bodyText = await clonedReq.text();\n \n // Validate the request signature\n const isValid = await validateDiscordRequest(clonedReq, bodyText);\n \n if (!isValid) {\n console.error(\"Invalid Discord request signature\");\n return new Response(\"Invalid request signature\", { status: 401 });\n }\n \n console.log(\"Discord request validation successful\");\n \n // Parse the JSON for Discord-specific handling\n try {\n const body = JSON.parse(bodyText);\n \n // Check if this is a Discord PING (type 1 interaction)\n if (body && body.type === 1) {\n console.log(\"Received Discord PING verification\");\n // Respond to Discord PING\n return new Response(JSON.stringify({ type: 1 }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n \n // Handle different interaction types\n if (body.type === 2) {\n // It's a command interaction\n console.log(\"Handling command interaction:\", body.data?.name);\n return await handleCommand(body);\n } else if (body.type === 3) {\n // It's a component interaction\n console.log(\"Handling component interaction\");\n return await handleComponentInteraction(body);\n } else {\n // For other interaction types, use the standard handler\n console.log(\"Using standard interaction handler for type:\", body.type);\n // Create a new request with the same body for the handler\n const newReq = new Request(req.url, {\n method: req.method,\n headers: req.headers,\n body: bodyText\n });\n return await handleInteraction(newReq);\n }\n } catch (e) {\n console.error(\"Error parsing Discord interaction as JSON:\", e);\n return new Response(\"Invalid interaction format\", { status: 400 });\n }\n }\n \n // Normal route handling for non-Discord interaction requests\n if (url.pathname === \"/interactions\") {\n console.log(\"Routing to interactions handler\");\n return await handleInteraction(req);\n }\n \n // Handle Discord message create webhook\n if (url.pathname === \"/webhooks/messages\") {\n console.log(\"Routing to message webhook handler\");\n return await handleMessageCreate(req);\n }\n \n // Handle Discord API webhook verification\n if (url.pathname === \"/register\") {\n console.log(\"Routing to command registration handler\");\n return await registerCommandsHandler(req);\n }\n \n // Handle DM history file upload\n if (url.pathname.startsWith(\"/upload/\")) {\n console.log(\"Routing to DM upload handler\");\n return await handleDmUpload(req);\n }\n \n // For the root path\n if (url.pathname === \"/\") {\n // Return basic info\n return new Response(\"Discord Bot API - Status: Online\", {\n headers: { \"Content-Type\": \"text/plain\" }\n });\n }\n \n // Log unknown routes\n console.log(`Unknown route requested: ${url.pathname}`);\n \n // Default response\n return new Response(\"Discord Bot API - Route not found\", {\n status: 404,\n headers: { \"Content-Type\": \"text/plain\" }\n });\n } catch (error) {\n console.error(\"Error handling request:\", error);\n console.log(\"Error stack:\", error.stack);\n return new Response(\"Internal server error\", { status: 500 });\n }\n}\n\n// Handler for registering commands\nasync function registerCommandsHandler(req: Request): Promise {\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n \n try {\n // Register commands with Discord\n const success = await registerCommands(commands);\n \n if (success) {\n return new Response(\"Commands registered successfully\");\n } else {\n return new Response(\"Failed to register commands\", { status: 500 });\n }\n } catch (error) {\n console.error(\"Error registering commands:\", error);\n return new Response(\"Error registering commands\", { status: 500 });\n }\n}\n\n// Cron job to sync recent messages (runs every hour)\nexport async function syncRecentMessages() {\n try {\n // Get configured channel IDs for message syncing\n // In a production version, you'd want to store this in your database\n // For now, we'll hardcode it\n const channelIds = [\"1367934092594643088\"]; // general\n \n for (const channelId of channelIds) {\n // Fetch recent messages from the channel\n const messages = await discordRequest(`/channels/${channelId}/messages?limit=100`);\n \n if (Array.isArray(messages)) {\n // Process each message\n for (const message of messages) {\n await processMessage(message);\n }\n }\n }\n \n console.log(\"Message sync completed successfully\");\n } catch (error) {\n console.error(\"Error syncing messages:\", error);\n }\n}\n\n// Function to process a new message\nasync function processMessage(message: any) {\n try {\n // Skip bot messages\n if (message.author.bot) {\n return;\n }\n \n // Make a POST request to the message webhook\n await fetch(`${Deno.env.get(\"VAL_TOWN_URL\")}/webhooks/messages`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify(message)\n });\n } catch (error) {\n console.error(\"Error processing message:\", error);\n }\n}\n\n// Function to handle Discord slash commands\nasync function handleCommand(interaction: any) {\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 default:\n return respondToInteraction(\"Unknown command\");\n }\n}\n\n// Function to handle message component interactions (buttons, select menus)\nasync function handleComponentInteraction(interaction: any) {\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 }\n \n return respondToInteraction(\"Unknown interaction\");\n}\n\n// Handle AI query command\nasync function handleQueryCommand(interaction: any) {\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 try {\n // Get relevant messages based on the query\n const relevantMessages = await getRelevantMessages(query);\n \n if (!relevantMessages.length) {\n return respondToInteraction(\"I couldn't find any relevant messages in your history\");\n }\n \n if (!anthropic) {\n return respondToInteraction(\"Claude API is not configured\");\n }\n \n // Format the context for Claude\n const context = formatMessagesForClaude(relevantMessages);\n \n // Ask Claude for analysis\n const claudeResponse = await anthropic.messages.create({\n model: \"claude-3-opus-20240229\",\n max_tokens: 1000,\n messages: [\n {\n role: \"user\",\n content: `You are analyzing conversations between a couple. Based on these message excerpts, please answer their question in a helpful way.\n \nMessage history:\n${context}\n\nQuestion: ${query}\n\nPlease be concise but thorough in your answer, providing specific references to what they discussed when relevant.`\n }\n ],\n });\n \n return respondToInteraction(claudeResponse.content[0].text);\n } catch (error) {\n console.error(\"Error handling query command:\", error);\n return respondToInteraction(\"Sorry, I encountered an error processing your query\");\n }\n}\n\n// Handle project management command\nasync function handleProjectCommand(interaction: any) {\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) {\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// Helper function to respond to Discord interactions\nfunction respondToInteraction(content: string, ephemeral = false) {\n return new Response(\n JSON.stringify({\n type: 4,\n data: {\n content,\n flags: ephemeral ? 64 : 0\n }\n }),\n { headers: { \"Content-Type\": \"application/json\" } }\n );\n}\n\n// Placeholder functions to be implemented\nasync function getRelevantMessages(query: string) {\n // TODO: implement retrieval logic based on query\n return [];\n}\n\nfunction formatMessagesForClaude(messages: any[]) {\n // TODO: implement message formatting for Claude\n return \"\";\n}\n\nasync function handleCreateProject(interaction: any) {\n // TODO: implement project creation\n return respondToInteraction(\"Project creation not yet implemented\");\n}\n\nasync function handleListProjects(interaction: any) {\n // TODO: implement project listing\n return respondToInteraction(\"Project listing not yet implemented\");\n}\n\nasync function handleViewProject(interaction: any) {\n // TODO: implement project viewing\n return respondToInteraction(\"Project viewing not yet implemented\");\n}\n\nasync function handleListLinks(interaction: any) {\n // TODO: implement link listing\n return respondToInteraction(\"Link listing not yet implemented\");\n}\n\nasync function handleCategorizeLink(interaction: any) {\n // TODO: implement link categorization\n return respondToInteraction(\"Link categorization not yet implemented\");\n}\n\nasync function handleSearchLinks(interaction: any) {\n // TODO: implement link searching\n return respondToInteraction(\"Link searching not yet implemented\");\n}\n\nasync function handleLinkInteraction(interaction: any, customId: string) {\n // TODO: implement link interaction handling\n return respondToInteraction(\"Link interaction not yet implemented\");\n}\n\n// Handle DM history file upload\nasync function handleDmUpload(req: Request): Promise {\n if (req.method !== \"POST\") {\n // Return a simple HTML form for GET requests\n if (req.method === \"GET\") {\n return new Response(`\n \n \n \n Discord DM History Upload\n \n \n \n

Discord DM History Upload

Use this form to upload your Discord data export JSON file.

\n \n \n \n

Privacy Note: Your data will only be stored in the bot's database and used for the conversation analysis features you've requested. It will not be shared with third parties.

\n \n \n `, {\n headers: { \"Content-Type\": \"text/html\" }\n });\n }\n \n return new Response(\"Method not allowed\", { status: 405 });\n }\n \n try {\n // Check if this is a multipart form data request\n const contentType = req.headers.get(\"content-type\") || \"\";\n \n if (contentType.includes(\"multipart/form-data\")) {\n // Parse the form data\n const formData = await req.formData();\n const file = formData.get(\"file\");\n \n if (!file || !(file instanceof File)) {\n return new Response(\"No file uploaded\", { status: 400 });\n }\n \n // Read the file as JSON\n const fileContent = await file.text();\n let jsonData;\n try {\n jsonData = JSON.parse(fileContent);\n } catch (_error) {\n return new Response(\"Invalid JSON file\", { status: 400 });\n }\n \n // Process the data\n const result = await importDiscordDataExport(jsonData);\n \n // Return a success response with HTML\n return new Response(`\n \n \n \n Upload Complete\n \n \n \n

Upload Complete

\n \n

Import Results:

Messages imported: ${result.messagesImported}

Links extracted: ${result.linksImported}

\n \n ${result.errors.length > 0 ? `\n

Errors:

${err}

\n ` : ''}\n \n

Success!

\n \n \n `, {\n headers: { \"Content-Type\": \"text/html\" }\n });\n } else {\n // Handle regular JSON payload\n const jsonData = await req.json();\n const result = await importDiscordDataExport(jsonData);\n \n return new Response(JSON.stringify(result), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n } catch (error) {\n console.error(\"Error handling DM upload:\", error);\n return new Response(`Error processing upload: ${error.message}`, { status: 500 });\n }\n}",[],[230,308],"e8ea56a8-2859-11f0-b4f5-569c3dd06744","importer.ts","e8ea575c-2859-11f0-b4f5-569c3dd06744",10,["D",1746302707298],"// Data importer for Discord message history\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport * as db from \"./database.ts\";\n\n// Type definitions for Discord data export\ninterface DiscordExportMessage {\n id: string;\n type: number;\n timestamp: string;\n content: string;\n author: {\n id: string;\n name: string;\n discriminator: string;\n nickname: string;\n avatar?: string;\n };\n attachments: any[];\n embeds: any[];\n mentions: any[];\n reactions?: {\n emoji: {\n id: string | null;\n name: string;\n };\n count: number;\n }[];\n}\n\ninterface DiscordExportChannel {\n id: string;\n type: number;\n name: string;\n recipients: {\n id: string;\n name: string;\n discriminator: string;\n nickname?: string;\n }[];\n messages: DiscordExportMessage[];\n}\n\n// Function to process Discord data export file\nexport async function importDiscordDataExport(data: any): Promise<{\n messagesImported: number;\n linksImported: number;\n errors: string[];\n}> {\n const result = {\n messagesImported: 0,\n linksImported: 0,\n errors: [] as string[],\n };\n\n try {\n // Begin transaction\n await sqlite.execute(\"BEGIN TRANSACTION\");\n\n // Process the data\n if (Array.isArray(data.messages)) {\n // Direct format - array of messages\n await processMessages(data.messages, result);\n } else if (data.channel && Array.isArray(data.channel.messages)) {\n // Channel format\n await processMessages(data.channel.messages, result);\n } else if (Array.isArray(data)) {\n // Array of channels or messages\n for (const item of data) {\n if (item.messages) {\n // It's a channel\n await processMessages(item.messages, result);\n } else if (item.id && item.content) {\n // It's a message\n await processMessage(item, result);\n }\n }\n } else {\n throw new Error(\"Unsupported data format\");\n }\n\n // Commit the transaction\n await sqlite.execute(\"COMMIT\");\n } catch (error) {\n // Rollback on error\n await sqlite.execute(\"ROLLBACK\");\n result.errors.push(`Import failed: ${error.message}`);\n console.error(\"Import error:\", error);\n }\n\n return result;\n}\n\n// Process an array of messages\nasync function processMessages(\n messages: DiscordExportMessage[],\n result: { messagesImported: number; linksImported: number; errors: string[] }\n): Promise {\n for (const message of messages) {\n await processMessage(message, result);\n }\n}\n\n// Process a single message\nasync function processMessage(\n message: DiscordExportMessage,\n result: { messagesImported: number; linksImported: number; errors: string[] }\n): Promise {\n try {\n // Skip system messages\n if (message.type !== 0 && message.type !== 19) {\n return;\n }\n\n // Skip empty messages\n if (!message.content && (!message.attachments || message.attachments.length === 0)) {\n return;\n }\n\n // Extract relevant data\n const { urls, domains } = db.extractLinks(message.content || \"\");\n const hasLinks = urls.length > 0;\n const isCommand = (message.content || \"\").startsWith(\"/\");\n \n // Default channel ID for DM imports\n const channelId = \"imported_dm\";\n\n // Create database message object\n const dbMessage: db.Message = {\n id: message.id,\n channel_id: channelId,\n user_id: message.author.id,\n content: message.content || \"\",\n timestamp: new Date(message.timestamp).getTime(),\n has_links: hasLinks,\n is_command: isCommand\n };\n\n // Save the message\n const success = await db.saveMessage(dbMessage);\n \n if (success) {\n result.messagesImported++;\n \n // Process links if any\n if (hasLinks) {\n for (let i = 0; i < urls.length; i++) {\n const link: db.Link = {\n message_id: message.id,\n url: urls[i],\n domain: domains[i] || extractDomain(urls[i]),\n timestamp: new Date(message.timestamp).getTime()\n };\n \n const linkId = await db.saveLink(link);\n if (linkId) {\n result.linksImported++;\n }\n }\n }\n }\n } catch (error) {\n result.errors.push(`Error processing message ${message.id}: ${error.message}`);\n console.error(\"Error processing message:\", error);\n }\n}\n\n// Helper function to extract domain from URL\nfunction extractDomain(url: string): string {\n try {\n const domain = new URL(url).hostname;\n return domain;\n } catch (error) {\n return \"unknown\";\n }\n}\n\n// Function to import messages from a specific Discord channel\nexport async function importChannelHistory(\n channelId: string,\n limit = 100,\n before?: string\n): Promise<{\n messagesImported: number;\n linksImported: number;\n errors: string[];\n}> {\n const result = {\n messagesImported: 0,\n linksImported: 0,\n errors: [] as string[],\n };\n\n try {\n const DISCORD_TOKEN = Deno.env.get(\"DISCORD_TOKEN\");\n \n if (!DISCORD_TOKEN) {\n throw new Error(\"Missing Discord token\");\n }\n \n // Fetch messages from Discord API\n let url = `https://discord.com/api/v10/channels/${channelId}/messages?limit=${limit}`;\n if (before) {\n url += `&before=${before}`;\n }\n \n const response = await fetch(url, {\n headers: {\n Authorization: `Bot ${DISCORD_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n });\n \n if (!response.ok) {\n throw new Error(`Discord API error: ${response.status} ${response.statusText}`);\n }\n \n const messages = await response.json();\n \n // Begin transaction\n await sqlite.execute(\"BEGIN TRANSACTION\");\n \n // Process messages\n for (const message of messages) {\n // Skip bot messages\n if (message.author.bot) {\n continue;\n }\n \n const { urls, domains } = db.extractLinks(message.content || \"\");\n const hasLinks = urls.length > 0;\n const isCommand = (message.content || \"\").startsWith(\"/\");\n \n // Create database message object\n const dbMessage: db.Message = {\n id: message.id,\n channel_id: message.channel_id,\n user_id: message.author.id,\n content: message.content || \"\",\n timestamp: new Date(message.timestamp).getTime(),\n has_links: hasLinks,\n is_command: isCommand\n };\n \n // Save the message\n const success = await db.saveMessage(dbMessage);\n \n if (success) {\n result.messagesImported++;\n \n // Process links if any\n if (hasLinks) {\n for (let i = 0; i < urls.length; i++) {\n const link: db.Link = {\n message_id: message.id,\n url: urls[i],\n domain: domains[i] || extractDomain(urls[i]),\n timestamp: new Date(message.timestamp).getTime()\n };\n \n const linkId = await db.saveLink(link);\n if (linkId) {\n result.linksImported++;\n }\n }\n }\n }\n }\n \n // Commit the transaction\n await sqlite.execute(\"COMMIT\");\n \n // Return the oldest message ID for pagination\n if (messages.length > 0) {\n result.errors.push(`oldest_id:${messages[messages.length - 1].id}`);\n }\n } catch (error) {\n // Rollback on error\n await sqlite.execute(\"ROLLBACK\");\n result.errors.push(`Import failed: ${error.message}`);\n console.error(\"Import error:\", error);\n }\n \n return result;\n}",[],[230,316],"e8ee0438-2859-11f0-ab88-569c3dd06744","discord.ts","e8ee04ec-2859-11f0-ab88-569c3dd06744",11,["D",1746302707299],"// Discord API integration\n\n// Discord API base URL\nconst DISCORD_API_URL = \"https://discord.com/api/v10\";\n\n// Environment variables\nconst DISCORD_TOKEN = Deno.env.get(\"DISCORD_TOKEN\");\nconst DISCORD_APPLICATION_ID = Deno.env.get(\"DISCORD_APPLICATION_ID\");\n\n// Type definitions\nexport interface DiscordMessage {\n id: string;\n channel_id: string;\n author: {\n id: string;\n username: string;\n global_name?: string;\n };\n content: string;\n timestamp: string;\n attachments: any[];\n embeds: any[];\n mentions: any[];\n}\n\nexport interface DiscordChannel {\n id: string;\n name: string;\n type: number;\n guild_id: string;\n}\n\nexport interface DiscordUser {\n id: string;\n username: string;\n global_name?: string;\n}\n\n// Helper function for Discord API requests\nexport async function discordRequest(endpoint: string, method = \"GET\", body?: any) {\n const url = `${DISCORD_API_URL}${endpoint}`;\n \n const headers = {\n \"Authorization\": `Bot ${DISCORD_TOKEN}`,\n \"Content-Type\": \"application/json\",\n \"User-Agent\": \"ValTownDiscordBot/1.0\"\n };\n \n const options: RequestInit = { method, headers };\n \n if (body) {\n options.body = JSON.stringify(body);\n }\n \n try {\n const response = await fetch(url, options);\n \n if (!response.ok) {\n const errorData = await response.json().catch(() => null);\n console.error(`Discord API error: ${response.status} ${response.statusText}`, errorData);\n throw new Error(`Discord API request failed: ${response.status} ${response.statusText}`);\n }\n \n // Check if there's content before parsing as JSON\n const text = await response.text();\n return text ? JSON.parse(text) : null;\n } catch (error) {\n console.error(\"Discord request error:\", error);\n throw error;\n }\n}\n\n// Function to register slash commands with Discord\nexport async function registerCommands(commands: any[]) {\n try {\n await discordRequest(\n `/applications/${DISCORD_APPLICATION_ID}/commands`, \n \"PUT\", \n commands\n );\n console.log(\"Commands registered successfully\");\n return true;\n } catch (error) {\n console.error(\"Error registering commands:\", error);\n return false;\n }\n}\n\n// Function to fetch channel messages\nexport async function fetchChannelMessages(channelId: string, limit = 100, before?: string) {\n let endpoint = `/channels/${channelId}/messages?limit=${limit}`;\n if (before) {\n endpoint += `&before=${before}`;\n }\n \n return await discordRequest(endpoint);\n}\n\n// Function to fetch a specific message\nexport async function fetchMessage(channelId: string, messageId: string) {\n return await discordRequest(`/channels/${channelId}/messages/${messageId}`);\n}\n\n// Function to fetch channel details\nexport async function fetchChannel(channelId: string) {\n return await discordRequest(`/channels/${channelId}`);\n}\n\n// Function to fetch user details\nexport async function fetchUser(userId: string) {\n return await discordRequest(`/users/${userId}`);\n}\n\n// Function to send a message to a channel\nexport async function sendMessage(channelId: string, content: string) {\n return await discordRequest(`/channels/${channelId}/messages`, \"POST\", { content });\n}\n\n// Function to reply to a message\nexport async function replyToMessage(channelId: string, messageId: string, content: string) {\n return await discordRequest(`/channels/${channelId}/messages`, \"POST\", {\n content,\n message_reference: {\n message_id: messageId\n }\n });\n}\n\n// Function to verify Discord interaction signature\nexport async function verifyInteraction(signature: string, timestamp: string, body: string) {\n // TODO: Implement proper signature verification using public key\n // This is a critical security step for a production bot\n \n // For now, we'll return true to allow development\n return true;\n}",[],[230,324],"053d6176-288a-11f0-84dc-569c3dd06744","database.ts","e8fa4766-2859-11f0-96d8-569c3dd06744",31,["D",1746323370671],"// Database operations for the Discord bot\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// Database initialization function - call this when the application starts\nexport async function initDatabase() {\n try {\n // Messages table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS messages (\n id TEXT PRIMARY KEY,\n channel_id TEXT NOT NULL,\n user_id TEXT NOT NULL,\n content TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n has_links BOOLEAN DEFAULT FALSE,\n is_command BOOLEAN DEFAULT FALSE\n )\n `);\n \n // Links table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS links (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message_id TEXT NOT NULL,\n url TEXT NOT NULL,\n domain TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n category TEXT,\n FOREIGN KEY(message_id) REFERENCES messages(id)\n )\n `);\n \n // Projects table (for explicit grouping)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS projects (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n description TEXT,\n created_at INTEGER NOT NULL,\n is_active BOOLEAN DEFAULT TRUE\n )\n `);\n \n // Project messages mapping\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS project_messages (\n project_id INTEGER NOT NULL,\n message_id TEXT NOT NULL,\n PRIMARY KEY(project_id, message_id),\n FOREIGN KEY(project_id) REFERENCES projects(id),\n FOREIGN KEY(message_id) REFERENCES messages(id)\n )\n `);\n \n // Topics table (for AI-categorized grouping)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS topics (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n description TEXT,\n created_at INTEGER NOT NULL\n )\n `);\n \n // Topic messages mapping\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS topic_messages (\n topic_id INTEGER NOT NULL,\n message_id TEXT NOT NULL,\n PRIMARY KEY(topic_id, message_id),\n FOREIGN KEY(topic_id) REFERENCES topics(id),\n FOREIGN KEY(message_id) REFERENCES messages(id)\n )\n `);\n \n console.log(\"Database initialized successfully\");\n return true;\n } catch (error) {\n console.error(\"Database initialization error:\", error);\n return false;\n }\n}\n\n// Types\nexport interface Message {\n id: string;\n channel_id: string;\n user_id: string;\n content: string;\n timestamp: number;\n has_links: boolean;\n is_command: boolean;\n}\n\nexport interface Link {\n id?: number;\n message_id: string;\n url: string;\n domain: string;\n timestamp: number;\n category?: string;\n}\n\nexport interface Project {\n id?: number;\n name: string;\n description?: string;\n created_at: number;\n is_active: boolean;\n}\n\nexport interface Topic {\n id?: number;\n name: string;\n description?: string;\n created_at: number;\n}\n\n// URL regex pattern for link extraction\nconst URL_REGEX = /(https?:\\/\\/[^\\s]+)/g;\nconst DOMAIN_REGEX = /^(?:https?:\\/\\/)?(?:[^@\\n]+@)?(?:www\\.)?([^:/\\n?]+)/i;\n\n// Message operations\nexport async function saveMessage(message: Message): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO messages (id, channel_id, user_id, content, timestamp, has_links, is_command)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n content = excluded.content,\n has_links = excluded.has_links,\n is_command = excluded.is_command`,\n [\n message.id,\n message.channel_id,\n message.user_id,\n message.content,\n message.timestamp,\n message.has_links ? 1 : 0,\n message.is_command ? 1 : 0\n ]\n );\n return true;\n } catch (error) {\n console.error(\"Error saving message:\", error);\n return false;\n }\n}\n\nexport async function getMessage(messageId: string): Promise {\n try {\n const result = await sqlite.execute(\n \"SELECT * FROM messages WHERE id = ?\",\n [messageId]\n );\n \n if (result.rows.length === 0) {\n return null;\n }\n \n const row = result.rows[0];\n return {\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n };\n } catch (error) {\n console.error(\"Error getting message:\", error);\n return null;\n }\n}\n\nexport async function getMessagesByUserIds(userIds: string[], limit = 1000, offset = 0): Promise {\n try {\n // Create placeholders for the SQL IN clause\n const placeholders = userIds.map(() => '?').join(',');\n \n const result = await sqlite.execute(\n `SELECT * FROM messages\n WHERE user_id IN (${placeholders})\n ORDER BY timestamp DESC\n LIMIT ? OFFSET ?`,\n [...userIds, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting messages by user ids:\", error);\n return [];\n }\n}\n\nexport async function searchMessages(query: string, limit = 100): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM messages\n WHERE content LIKE ?\n ORDER BY timestamp DESC\n LIMIT ?`,\n [`%${query}%`, limit]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error searching messages:\", error);\n return [];\n }\n}\n\n// Link operations\nexport function extractLinks(content: string): { urls: string[], domains: string[] } {\n const urls: string[] = [];\n const domains: string[] = [];\n \n const matches = content.match(URL_REGEX);\n \n if (matches) {\n matches.forEach(url => {\n urls.push(url);\n \n const domainMatch = url.match(DOMAIN_REGEX);\n if (domainMatch && domainMatch[1]) {\n domains.push(domainMatch[1]);\n }\n });\n }\n \n return { urls, domains };\n}\n\nexport async function saveLink(link: Link): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO links (message_id, url, domain, timestamp, category)\n VALUES (?, ?, ?, ?, ?)\n RETURNING id`,\n [\n link.message_id,\n link.url,\n link.domain,\n link.timestamp,\n link.category || null\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error saving link:\", error);\n return null;\n }\n}\n\nexport async function getLinks(limit = 50, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM links\n ORDER BY timestamp DESC\n LIMIT ? OFFSET ?`,\n [limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n message_id: row.message_id,\n url: row.url,\n domain: row.domain,\n timestamp: row.timestamp,\n category: row.category\n }));\n } catch (error) {\n console.error(\"Error getting links:\", error);\n return [];\n }\n}\n\nexport async function searchLinks(query: string, limit = 50): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM links\n WHERE url LIKE ? OR domain LIKE ? OR category LIKE ?\n ORDER BY timestamp DESC\n LIMIT ?`,\n [`%${query}%`, `%${query}%`, `%${query}%`, limit]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n message_id: row.message_id,\n url: row.url,\n domain: row.domain,\n timestamp: row.timestamp,\n category: row.category\n }));\n } catch (error) {\n console.error(\"Error searching links:\", error);\n return [];\n }\n}\n\nexport async function updateLinkCategory(linkId: number, category: string): Promise {\n try {\n await sqlite.execute(\n `UPDATE links\n SET category = ?\n WHERE id = ?`,\n [category, linkId]\n );\n return true;\n } catch (error) {\n console.error(\"Error updating link category:\", error);\n return false;\n }\n}\n\n// Project operations\nexport async function createProject(project: Project): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO projects (name, description, created_at, is_active)\n VALUES (?, ?, ?, ?)\n RETURNING id`,\n [\n project.name,\n project.description || null,\n project.created_at,\n project.is_active ? 1 : 0\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error creating project:\", error);\n return null;\n }\n}\n\nexport async function getProjects(includeInactive = false): Promise {\n try {\n let query = `SELECT * FROM projects`;\n const params = [];\n \n if (!includeInactive) {\n query += ` WHERE is_active = 1`;\n }\n \n query += ` ORDER BY created_at DESC`;\n \n const result = await sqlite.execute(query, params);\n \n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at,\n is_active: Boolean(row.is_active)\n }));\n } catch (error) {\n console.error(\"Error getting projects:\", error);\n return [];\n }\n}\n\nexport async function getProject(projectId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM projects WHERE id = ?`,\n [projectId]\n );\n \n if (result.rows.length === 0) {\n return null;\n }\n \n const row = result.rows[0];\n return {\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at,\n is_active: Boolean(row.is_active)\n };\n } catch (error) {\n console.error(\"Error getting project:\", error);\n return null;\n }\n}\n\nexport async function addMessageToProject(projectId: number, messageId: string): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO project_messages (project_id, message_id)\n VALUES (?, ?)\n ON CONFLICT DO NOTHING`,\n [projectId, messageId]\n );\n return true;\n } catch (error) {\n console.error(\"Error adding message to project:\", error);\n return false;\n }\n}\n\nexport async function getProjectMessages(projectId: number, limit = 100, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT m.*\n FROM messages m\n JOIN project_messages pm ON m.id = pm.message_id\n WHERE pm.project_id = ?\n ORDER BY m.timestamp DESC\n LIMIT ? OFFSET ?`,\n [projectId, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting project messages:\", error);\n return [];\n }\n}\n\n// Topic operations\nexport async function createTopic(topic: Topic): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO topics (name, description, created_at)\n VALUES (?, ?, ?)\n RETURNING id`,\n [\n topic.name,\n topic.description || null,\n topic.created_at\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error creating topic:\", error);\n return null;\n }\n}\n\nexport async function getTopics(): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM topics ORDER BY name ASC`\n );\n \n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at\n }));\n } catch (error) {\n console.error(\"Error getting topics:\", error);\n return [];\n }\n}\n\nexport async function addMessageToTopic(topicId: number, messageId: string): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO topic_messages (topic_id, message_id)\n VALUES (?, ?)\n ON CONFLICT DO NOTHING`,\n [topicId, messageId]\n );\n return true;\n } catch (error) {\n console.error(\"Error adding message to topic:\", error);\n return false;\n }\n}\n\nexport async function getTopicMessages(topicId: number, limit = 100, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT m.*\n FROM messages m\n JOIN topic_messages tm ON m.id = tm.message_id\n WHERE tm.topic_id = ?\n ORDER BY m.timestamp DESC\n LIMIT ? OFFSET ?`,\n [topicId, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting topic messages:\", error);\n return [];\n }\n}",[],[230,332],"9454d5d8-285d-11f0-86d2-569c3dd06744","bot.ts","e8e0331c-2859-11f0-97af-569c3dd06744",19,["D",1746304283402],"// Bot logic and message processing\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.10.0\";\nimport * as db from \"./database.ts\";\nimport * as discord from \"./discord.ts\";\n\n// Initialize Claude API client\nconst ANTHROPIC_API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\nconst anthropic = new Anthropic({\n apiKey: ANTHROPIC_API_KEY || \"\",\n});\n\n// Command definitions\nexport const commands = [\n {\n name: \"query\",\n description: \"Ask a question about your past conversations\",\n options: [\n {\n name: \"question\",\n description: \"What would you like to know about your past conversations?\",\n type: 3, // STRING\n required: true\n }\n ]\n },\n {\n name: \"project\",\n description: \"Manage conversation projects\",\n options: [\n {\n name: \"create\",\n description: \"Create a new project\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"name\",\n description: \"Project name\",\n type: 3, // STRING\n required: true\n },\n {\n name: \"description\",\n description: \"Project description\",\n type: 3, // STRING\n required: false\n }\n ]\n },\n {\n name: \"list\",\n description: \"List all projects\",\n type: 1 // SUB_COMMAND\n },\n {\n name: \"view\",\n description: \"View a project's messages\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"id\",\n description: \"Project ID\",\n type: 4, // INTEGER\n required: true\n }\n ]\n }\n ]\n },\n {\n name: \"links\",\n description: \"Manage shared links\",\n options: [\n {\n name: \"list\",\n description: \"List recently shared links\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"limit\",\n description: \"Number of links to show (default: 10)\",\n type: 4, // INTEGER\n required: false\n }\n ]\n },\n {\n name: \"categorize\",\n description: \"Categorize a link\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"id\",\n description: \"Link ID\",\n type: 4, // INTEGER\n required: true\n },\n {\n name: \"category\",\n description: \"Category name\",\n type: 3, // STRING\n required: true\n }\n ]\n },\n {\n name: \"search\",\n description: \"Search for links\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"query\",\n description: \"Search query\",\n type: 3, // STRING\n required: true\n }\n ]\n }\n ]\n },\n {\n name: \"import\",\n description: \"Import conversation history\",\n options: [\n {\n name: \"channel\",\n description: \"Import message history from a Discord channel\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"channel_id\",\n description: \"Discord channel ID to import from\",\n type: 3, // STRING\n required: true\n },\n {\n name: \"limit\",\n description: \"Number of messages to import (default: 100, max: 100)\",\n type: 4, // INTEGER\n required: false\n },\n {\n name: \"before\",\n description: \"Import messages before this message ID (for pagination)\",\n type: 3, // STRING\n required: false\n }\n ]\n },\n {\n name: \"dm\",\n description: \"Initialize an imported DM history upload\",\n type: 1 // SUB_COMMAND\n }\n ]\n }\n];\n\n// Process a new Discord message\nexport async function processMessage(message: discord.DiscordMessage): Promise {\n try {\n // Skip processing bot messages\n if (message.author.bot) {\n return;\n }\n \n // Extract relevant information\n const { urls, domains } = db.extractLinks(message.content);\n const hasLinks = urls.length > 0;\n const isCommand = message.content.startsWith(\"/\");\n \n // Save the message\n const dbMessage: db.Message = {\n id: message.id,\n channel_id: message.channel_id,\n user_id: message.author.id,\n content: message.content,\n timestamp: new Date(message.timestamp).getTime(),\n has_links: hasLinks,\n is_command: isCommand\n };\n \n await db.saveMessage(dbMessage);\n \n // If the message contains links, process them\n if (hasLinks) {\n for (let i = 0; i < urls.length; i++) {\n const link: db.Link = {\n message_id: message.id,\n url: urls[i],\n domain: domains[i] || extractDomain(urls[i]),\n timestamp: new Date(message.timestamp).getTime()\n };\n \n await db.saveLink(link);\n }\n \n // Analyze and categorize links (optional step)\n await categorizeLinksByContent(message.id, message.content);\n }\n \n // Check if the message is in a project context\n const activeProject = await findActiveProject(message.channel_id);\n if (activeProject) {\n await db.addMessageToProject(activeProject.id!, message.id);\n }\n \n // Classify message into topics (can be run asynchronously)\n setTimeout(() => {\n classifyMessageIntoTopics(message.id, message.content).catch(err => {\n console.error(\"Error classifying message:\", err);\n });\n }, 0);\n } catch (error) {\n console.error(\"Error processing message:\", error);\n }\n}\n\n// Helper function to extract domain from URL\nfunction extractDomain(url: string): string {\n try {\n const domain = new URL(url).hostname;\n return domain;\n } catch (error) {\n return \"unknown\";\n }\n}\n\n// Find active project in a channel\nasync function findActiveProject(channelId: string): Promise {\n // This is a placeholder implementation\n // In a real system, you might store active projects per channel\n // or use message content to determine the project context\n return null;\n}\n\n// Use Claude to categorize links based on message content\nasync function categorizeLinksByContent(messageId: string, content: string): Promise {\n try {\n // Get the message that contains the links\n const message = await db.getMessage(messageId);\n if (!message || !message.has_links) {\n return;\n }\n \n // Use Claude to analyze the content and suggest categories\n const response = await anthropic.messages.create({\n model: \"claude-3-haiku-20240307\",\n max_tokens: 100,\n messages: [\n {\n role: \"user\",\n content: `This message contains one or more links. Based on the message content, what category would you assign to these links? Choose a single word or short phrase that best describes what these links are about. Only respond with the category name, nothing else.\n\nMessage content: \"${content}\"`\n }\n ],\n });\n \n const category = response.content[0].text.trim();\n \n // Update all links in this message with the suggested category\n const result = await sqlite.execute(\n `UPDATE links SET category = ? WHERE message_id = ?`,\n [category, messageId]\n );\n } catch (error) {\n console.error(\"Error categorizing links:\", error);\n }\n}\n\n// Use Claude to classify a message into topics\nasync function classifyMessageIntoTopics(messageId: string, content: string): Promise {\n try {\n // Skip short messages\n if (content.length < 20) {\n return;\n }\n \n // Get existing topics\n const topics = await db.getTopics();\n \n // Format topics for Claude\n const topicsText = topics.map(t => `${t.id}: ${t.name}`).join(\"\\n\");\n \n // Use Claude to classify the message\n const response = await anthropic.messages.create({\n model: \"claude-3-haiku-20240307\",\n max_tokens: 200,\n messages: [\n {\n role: \"user\",\n content: `You are classifying conversation messages into topics. I'll provide a message and a list of existing topics. Your task is to:\n\n1. Determine if the message fits into any of the existing topics\n2. If it does, return the topic IDs that match (can be multiple)\n3. If it doesn't fit any existing topic, suggest a new topic name\n\nExisting topics:\n${topicsText || \"No existing topics yet.\"}\n\nMessage: \"${content}\"\n\nReturn your answer in this exact format:\nEXISTING_TOPICS: [list of topic IDs, or \"none\"]\nNEW_TOPIC: [suggest a new topic name, or \"none\"]`\n }\n ],\n });\n \n const analysis = response.content[0].text;\n \n // Extract existing topics\n const existingTopicsMatch = analysis.match(/EXISTING_TOPICS:\\s*(.+)/i);\n const existingTopics = existingTopicsMatch ? existingTopicsMatch[1].trim() : \"none\";\n \n // Extract new topic suggestion\n const newTopicMatch = analysis.match(/NEW_TOPIC:\\s*(.+)/i);\n const newTopic = newTopicMatch ? newTopicMatch[1].trim() : \"none\";\n \n // Process existing topic assignments\n if (existingTopics !== \"none\") {\n const topicIds = existingTopics\n .replace(/[\\[\\]]/g, \"\")\n .split(\",\")\n .map(id => parseInt(id.trim(), 10))\n .filter(id => !isNaN(id));\n \n for (const topicId of topicIds) {\n await db.addMessageToTopic(topicId, messageId);\n }\n }\n \n // Create new topic if suggested\n if (newTopic !== \"none\") {\n const topicId = await db.createTopic({\n name: newTopic,\n created_at: Date.now()\n });\n \n if (topicId) {\n await db.addMessageToTopic(topicId, messageId);\n }\n }\n } catch (error) {\n console.error(\"Error classifying message:\", error);\n }\n}\n\n// Function to get relevant messages for answering a query\nexport async function getRelevantMessagesForQuery(query: string, userIds: string[], limit = 100): Promise {\n try {\n // First, search messages directly containing terms in the query\n let messages = await db.searchMessages(query, limit);\n \n // If we didn't find enough messages, expand the search\n if (messages.length < 10) {\n // Use Claude to extract key search terms\n const response = await anthropic.messages.create({\n model: \"claude-3-haiku-20240307\",\n max_tokens: 100,\n messages: [\n {\n role: \"user\",\n content: `Extract 3-5 key search terms from this query to help find relevant messages in a conversation database. Return ONLY the terms separated by commas, nothing else.\n\nQuery: \"${query}\"`\n }\n ],\n });\n \n const searchTerms = response.content[0].text.split(\",\").map(term => term.trim());\n \n // Search for each term and collect results\n for (const term of searchTerms) {\n if (term) {\n const termResults = await db.searchMessages(term, Math.round(limit / searchTerms.length));\n \n // Add unique messages\n for (const result of termResults) {\n if (!messages.some(m => m.id === result.id)) {\n messages.push(result);\n }\n \n // Stop if we've reached the limit\n if (messages.length >= limit) {\n break;\n }\n }\n }\n }\n }\n \n // If we still don't have enough results, add recent messages from these users\n if (messages.length < limit) {\n const recentMessages = await db.getMessagesByUserIds(userIds, limit - messages.length);\n \n // Add unique messages\n for (const result of recentMessages) {\n if (!messages.some(m => m.id === result.id)) {\n messages.push(result);\n }\n }\n }\n \n // Sort messages by timestamp (oldest first for conversation continuity)\n messages.sort((a, b) => a.timestamp - b.timestamp);\n \n return messages;\n } catch (error) {\n console.error(\"Error getting relevant messages:\", error);\n return [];\n }\n}\n\n// Function to format messages for Claude analysis\nexport function formatMessagesForClaudeAnalysis(messages: db.Message[], userMap: Map): string {\n let formattedMessages = \"\";\n \n for (const message of messages) {\n const username = userMap.get(message.user_id) || \"Unknown User\";\n const date = new Date(message.timestamp).toISOString().split(\"T\")[0];\n \n formattedMessages += `[${date}] ${username}: ${message.content}\\n\\n`;\n }\n \n return formattedMessages;\n}\n\n// Function to analyze messages with Claude\nexport async function analyzeMessagesWithClaude(messages: db.Message[], userMap: Map, query: string): Promise {\n try {\n const formattedMessages = formatMessagesForClaudeAnalysis(messages, userMap);\n \n const response = await anthropic.messages.create({\n model: \"claude-3-opus-20240229\", // Using our most capable model for deep analysis\n max_tokens: 1000,\n messages: [\n {\n role: \"user\",\n content: `You are analyzing conversations between a couple. Based on these message excerpts, please answer their question in a helpful way.\n \nMessage history:\n${formattedMessages}\n\nQuestion: ${query}\n\nPlease be concise but thorough in your answer, providing specific references to what they discussed when relevant.\nIf they're asking about items they've discussed (like furniture, products, etc.), try to include:\n1. Names/descriptions of items they mentioned\n2. Any opinions or preferences they expressed\n3. Links they shared if available\n4. A summary of their overall feelings on the topic`\n }\n ],\n });\n \n return response.content[0].text;\n } catch (error) {\n console.error(\"Error analyzing messages with Claude:\", error);\n return \"I'm sorry, I encountered an error while analyzing your conversations. Please try again with a different question.\";\n }\n}",[],[230,340],["D",1746302706739],[252,253,254,255,256,257],[230],"e8dd05b6-2859-11f0-8fb6-569c3dd06744","settings.local.json","e8dd064c-2859-11f0-8fb6-569c3dd06744",["D",1746302707146],"{\n \"permissions\": {\n \"allow\": [\n \"Bash(mkdir:*)\",\n \"Bash(mkdir:*)\"\n ],\n \"deny\": []\n }\n}",[],[73,351],["D",1746302706620],[250],[73],["D",1746161519737],{"_11":12,"_123":64},{"_11":12,"_119":-5,"_63":64,"_25":62,"_120":121,"_122":24},{"_34":110,"_13":16,"_28":31,"_111":74,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":14,"_118":12},"ctx",{"_45":-5,"_142":397,"_398":399,"_400":401,"_402":24,"_403":24,"_404":24,"_405":87,"_406":-5,"_407":-7,"_408":-7,"_409":173,"_410":24,"_411":24,"_412":-5,"_413":24,"_414":24,"_415":24,"_416":-5},"ENV",{"_368":369,"_370":371,"_372":16,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392,"_393":394,"_395":396},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]