[{"_1":2,"_174":-5,"_175":-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,"_171":172,"_173":-5},"handle","boucher","name","vt-discord","path","backend/bot.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":162,"_163":164,"_165":166,"_167":20,"_168":-5,"_97":169},"9454d5d8-285d-11f0-86d2-569c3dd06744","bot.ts","fileId","e8e0331c-2859-11f0-97af-569c3dd06744","parentId","e89244b8-2859-11f0-b4f5-569c3dd06744","branchId","branchVersion",19,"latest",["D",1746304283402],1,"fileType","script","content","// 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}","deleted","label",[170,152],"backend","permalink","https://www.val.town/x/boucher/vt-discord/code/backend/bot.ts","extension","actionData","errors"]