Error loading page

Please try again later.

\", 500);\n }\n});\n\n// Serve all static 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// API endpoints\n\n// Health check endpoint\napp.get(\"/health\", c => {\n return c.json({ \n status: \"ok\",\n timestamp: new Date().toISOString(),\n version: projectInfo.version\n });\n});\n\n// Discord interactions endpoint\napp.post(\"/api/interactions\", async c => {\n return await handleDiscordInteractionRequest(c.req.raw);\n});\n\n// Manual trigger for fetching DMs\napp.post(\"/api/fetch-dms\", async c => {\n try {\n log(\"Manually triggering DM fetch...\", \"info\");\n const messages = await fetchAndStoreDMs();\n return c.json({ \n success: true, \n message: \"DM fetch completed successfully\", \n count: messages.length,\n timestamp: new Date().toISOString()\n });\n } catch (error) {\n log(`Error fetching DMs: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return c.json({ \n success: false, \n error: error instanceof Error ? error.message : String(error) \n }, 500);\n }\n});\n\n// Manual trigger for processing links\napp.post(\"/api/process-links\", async c => {\n try {\n log(\"Manually triggering link processing...\", \"info\");\n const result = await batchProcessLinks();\n return c.json({\n ...result,\n timestamp: new Date().toISOString()\n });\n } catch (error) {\n log(`Error processing links: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return c.json({ \n success: false, \n error: error instanceof Error ? error.message : String(error) \n }, 500);\n }\n});\n\n// Query endpoint\napp.post(\"/api/query\", async c => {\n try {\n const body = await c.req.json();\n const { query, filters } = body;\n \n if (!query) {\n return c.json({ success: false, error: \"Missing query parameter\" }, 400);\n }\n \n log(`Processing query: \"${query}\"`, \"info\");\n const result = await processQuery(query, filters);\n \n return c.json({ \n success: true, \n data: result,\n timestamp: new Date().toISOString()\n });\n } catch (error) {\n log(`Error processing query: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return c.json({ \n success: false, \n error: error instanceof Error ? error.message : String(error) \n }, 500);\n }\n});\n\n// Discord command endpoints\napp.post(\"/api/commands/search\", async c => {\n try {\n const body = await c.req.json();\n const { query } = body;\n \n if (!query) {\n return c.json({ success: false, error: \"Missing query parameter\" }, 400);\n }\n \n log(`Processing Discord search command: \"${query}\"`, \"info\");\n \n // Process query with focus on recent messages\n const result = await processQuery(query, { limit: 100 });\n \n // Format response for Discord based on result type\n let response;\n \n switch (result.type) {\n case \"links\":\n if (result.links && result.links.length > 0) {\n response = `Found ${result.links.length} links related to \"${query}\":\\n` +\n result.links.slice(0, 5).map(link => `- ${link.url}`).join(\"\\n\");\n } else {\n response = `No links found related to \"${query}\".`;\n }\n break;\n \n case \"furniture\":\n response = `Furniture Analysis: ${result.analysis || \"No analysis available\"}\\n\\n`;\n if (result.preferences && result.preferences.length > 0) {\n response += `Preferences: ${result.preferences.join(\", \")}\\n\\n`;\n }\n if (result.relevantLinks && result.relevantLinks.length > 0) {\n response += `Relevant Links: ${result.relevantLinks.slice(0, 3).map(link => link.url).join(\", \")}`;\n }\n break;\n \n case \"summary\":\n response = `Summary: ${result.summary || \"No summary available\"}\\n\\n`;\n if (result.keyPoints && result.keyPoints.length > 0) {\n response += `Key Points: ${result.keyPoints.join(\", \")}`;\n }\n break;\n \n default:\n response = result.answer || \"No specific answer found for your query.\";\n }\n \n return c.json({ \n success: true, \n response,\n timestamp: new Date().toISOString()\n });\n } catch (error) {\n log(`Error processing Discord command: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return c.json({ \n success: false, \n response: \"Sorry, I encountered an error processing your request.\" \n }, 500);\n }\n});\n\n// Register commands endpoint\napp.post(\"/api/register-commands\", async c => {\n try {\n const applicationId = getEnv(\"DISCORD_CLIENT_ID\");\n const token = getEnv(\"DISCORD_TOKEN\");\n \n if (!applicationId || !token) {\n return c.json({ \n success: false, \n error: \"Missing Discord credentials in environment variables\" \n }, 400);\n }\n \n log(\"Registering Discord commands...\", \"info\");\n const result = await registerCommands(applicationId, token);\n \n return c.json({ \n success: true, \n message: \"Commands registered successfully\", \n data: result,\n timestamp: new Date().toISOString()\n });\n } catch (error) {\n log(`Error registering commands: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return c.json({ \n success: false, \n error: error instanceof Error ? error.message : String(error) \n }, 500);\n }\n});\n\n// Cron job endpoints for Val.town scheduled execution\n\n/**\n * Handles the scheduled DM fetch cron job\n */\nexport async function cronFetchDMs() {\n try {\n log(\"Running scheduled DM fetch...\", \"info\");\n await initializeServices(); // Ensure services are initialized\n const messages = await fetchAndStoreDMs();\n \n log(`Scheduled DM fetch completed successfully. Fetched ${messages.length} messages.`, \"info\");\n return { \n success: true, \n message: \"Scheduled DM fetch completed successfully\", \n count: messages.length,\n timestamp: new Date().toISOString()\n };\n } catch (error) {\n log(`Error in DM fetch cron job: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return { \n success: false, \n error: error instanceof Error ? error.message : String(error),\n timestamp: new Date().toISOString()\n };\n }\n}\n\n/**\n * Handles the scheduled link processing cron job\n */\nexport async function cronProcessLinks() {\n try {\n log(\"Running scheduled link processing...\", \"info\");\n await initializeServices(); // Ensure services are initialized\n const result = await batchProcessLinks();\n \n log(`Scheduled link processing completed. Processed ${result.processed || 0} links.`, \"info\");\n return {\n ...result,\n timestamp: new Date().toISOString()\n };\n } catch (error) {\n log(`Error in link processing cron job: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return { \n success: false, \n error: error instanceof Error ? error.message : String(error),\n timestamp: new Date().toISOString()\n };\n }\n}\n\n// Expose cron endpoints via HTTP as well\napp.get(\"/api/cron/fetch-dms\", async c => {\n const result = await cronFetchDMs();\n return c.json(result, result.success ? 200 : 500);\n});\n\napp.get(\"/api/cron/process-links\", async c => {\n const result = await cronProcessLinks();\n return c.json(result, result.success ? 200 : 500);\n});\n\n// Error handler - Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n log(`Unhandled server error: ${err.message}`, \"error\");\n throw err;\n});\n\n// Export the fetch handler for Val.town HTTP vals\nexport default app.fetch;",[],[152,170,223],{"_103":231,"_95":232,"_153":233,"_155":171,"_156":138,"_157":234,"_159":116,"_105":235,"_99":32,"_161":181,"_163":236,"_164":22,"_165":-5,"_166":237,"_98":238},"7cf17d22-2710-11f0-818e-569c3dd06744","link-analyzer.ts","7cf17de0-2710-11f0-818e-569c3dd06744",25,["D",1746161221514],"// Link analyzer for Val.town\nimport { getMessages, updateLinkCategory } from \"./database.ts\";\nimport { categorizeContent } from \"./anthropic-service.ts\";\nimport { extractUrls, log } from \"../shared/utils.ts\";\nimport type { MessageRecord, LinkRecord } from \"../shared/types.ts\";\n\ninterface LinkToProcess {\n url: string;\n messageId: string;\n authorId: string;\n timestamp: number;\n messageContent: string;\n id?: number;\n}\n\ninterface CategoryResult {\n category: string;\n confidence: 'high' | 'medium' | 'low';\n isValidCategory: boolean;\n suggestedCategory?: string;\n error?: string;\n}\n\ninterface MetadataResult {\n title: string;\n description: string;\n}\n\n/**\n * Extract and process links from messages\n * @param messages - Array of message objects\n * @returns Array of processed link objects\n */\nexport function extractLinks(messages: MessageRecord[]): LinkToProcess[] {\n const extractedLinks: LinkToProcess[] = [];\n \n for (const message of messages) {\n if (!message.content) continue;\n \n const urls = extractUrls(message.content);\n if (!urls) continue;\n \n for (const url of urls) {\n extractedLinks.push({\n url,\n messageId: message.id,\n authorId: message.author_id,\n timestamp: typeof message.timestamp === 'string' \n ? parseInt(message.timestamp) \n : message.timestamp,\n messageContent: message.content,\n id: message.id ? parseInt(message.id) : undefined\n });\n }\n }\n \n return extractedLinks;\n}\n\n/**\n * Categorize a link using AI\n * @param link - Link object to categorize\n * @returns Categorization result\n */\nexport async function categorizeLink(link: LinkToProcess): Promise {\n try {\n // For furniture-specific project, check for furniture-related terms\n const furnitureTerms = [\n 'sofa', 'couch', 'chair', 'table', 'bed', 'dresser', 'nightstand',\n 'desk', 'shelf', 'bookcase', 'cabinet', 'wardrobe', 'ottoman',\n 'bench', 'stool', 'lamp', 'lighting', 'decor', 'furniture'\n ];\n \n // Check if URL or message context contains furniture terms\n const urlLower = link.url.toLowerCase();\n const messageLower = link.messageContent ? link.messageContent.toLowerCase() : '';\n \n let isFurnitureRelated = false;\n const detectedTerms: string[] = [];\n \n for (const term of furnitureTerms) {\n if (urlLower.includes(term) || messageLower.includes(term)) {\n isFurnitureRelated = true;\n detectedTerms.push(term);\n }\n }\n \n if (isFurnitureRelated) {\n // Use Anthropic to determine specific furniture category\n const validCategories = [\n 'sofa', 'chair', 'table', 'bed', 'dresser', 'desk', \n 'lamp', 'shelf', 'bookcase', 'rug', 'curtain', 'other'\n ];\n \n const contentToAnalyze = `\nURL: ${link.url}\nMessage context: ${link.messageContent}\nDetected furniture terms: ${detectedTerms.join(', ')}\n `;\n \n const category = await categorizeContent(contentToAnalyze, validCategories);\n \n // Validate returned category\n if (validCategories.includes(category)) {\n return {\n category,\n confidence: 'high',\n isValidCategory: true\n };\n } else {\n return {\n category: 'other',\n confidence: 'low',\n isValidCategory: false,\n suggestedCategory: category\n };\n }\n } else {\n // Not furniture-related\n return {\n category: 'other',\n confidence: 'high',\n isValidCategory: true\n };\n }\n } catch (error) {\n log(`Error categorizing link: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return {\n category: 'other',\n confidence: 'low',\n isValidCategory: true,\n error: error instanceof Error ? error.message : String(error)\n };\n }\n}\n\n/**\n * Extract metadata for a link (title, description)\n * @param url - URL to extract metadata for\n * @returns Metadata object\n */\nexport async function extractLinkMetadata(url: string): Promise {\n try {\n // In a production system, you'd want to actually fetch the page content\n // For simplicity, we'll make an educated guess based on the URL\n \n // Parse the URL\n const urlObj = new URL(url);\n const hostname = urlObj.hostname;\n const pathname = urlObj.pathname;\n \n // Extract potential title from pathname\n let title = '';\n if (pathname && pathname !== '/') {\n // Remove extensions and convert to title case\n const parts = pathname.split('/').filter(p => p && !p.startsWith('?'));\n if (parts.length > 0) {\n // Get the last part of the path, which often contains the title\n const lastPart = parts[parts.length - 1]\n .replace(/\\.html|\\.php|\\.asp|\\.aspx|\\.jsp/gi, '')\n .replace(/-|_/g, ' ');\n \n // Convert to title case\n title = lastPart\n .split(' ')\n .map(word => word.charAt(0).toUpperCase() + word.slice(1).toLowerCase())\n .join(' ');\n }\n }\n \n // If we couldn't extract a title, use the domain name\n if (!title) {\n // Remove www. and .com, .org, etc.\n title = hostname\n .replace(/^www\\./i, '')\n .replace(/\\.(com|org|net|io|gov|edu|co|uk|us|ca|au|de|fr|jp|cn|ru|br|in)$/i, '')\n .split('.')\n .map(part => part.charAt(0).toUpperCase() + part.slice(1))\n .join(' ');\n }\n \n // Create a simple description\n const description = `Content from ${hostname}${pathname}`;\n \n return {\n title: title || hostname,\n description: description\n };\n } catch (error) {\n log(`Error extracting link metadata: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n try {\n return {\n title: new URL(url).hostname,\n description: 'No description available'\n };\n } catch {\n return {\n title: \"Unknown domain\",\n description: \"Invalid URL format\"\n };\n }\n }\n}\n\n/**\n * Batch process all links in the database\n * - Categorizes uncategorized links\n * - Updates link metadata\n */\nexport async function batchProcessLinks(): Promise<{success: boolean, processed?: number, error?: string}> {\n try {\n // Get messages with links that haven't been processed\n const messages = await getMessages({ limit: 100 });\n \n // Extract links\n const links = extractLinks(messages);\n \n let processedCount = 0;\n \n // Process each link\n for (const link of links) {\n try {\n // Skip links without ID\n if (!link.id) continue;\n \n // Categorize the link\n const categorization = await categorizeLink(link);\n \n // Extract metadata\n const metadata = await extractLinkMetadata(link.url);\n \n // Update link in database\n await updateLinkCategory(link.id, categorization.category);\n \n log(`Processed link: ${link.url}`, \"info\");\n log(`Category: ${categorization.category}`, \"info\");\n log(`Title: ${metadata.title}`, \"info\");\n \n processedCount++;\n } catch (linkError) {\n log(`Error processing link ${link.url}: ${linkError instanceof Error ? linkError.message : String(linkError)}`, \"error\");\n // Continue with next link\n }\n }\n \n return {\n success: true,\n processed: processedCount\n };\n } catch (error) {\n log(`Error in batch processing links: ${error instanceof Error ? error.message : String(error)}`, \"error\");\n return {\n success: false,\n error: error instanceof Error ? error.message : String(error)\n };\n }\n}",[],[152,170,232],{"_103":240,"_95":241,"_153":242,"_155":171,"_156":138,"_157":243,"_159":116,"_105":244,"_99":32,"_161":181,"_163":245,"_164":22,"_165":-5,"_166":246,"_98":247},"7ccc0736-2710-11f0-89d1-569c3dd06744","query-service.ts","7ccc07d6-2710-11f0-89d1-569c3dd06744",15,["D",1746161221452],"// Query service for Val.town\nimport { getMessages, getLinks } from \"./database.ts\";\nimport { analyzeConversation, summarizeConversation } from \"./anthropic-service.ts\";\n\n/**\n * Process a user query about messages and links\n * @param {string} query - The user's query\n * @param {Object} filters - Optional filters for message retrieval\n * @returns {Object} - The query response\n */\nexport async function processQuery(query: string, filters: any = {}) {\n try {\n // Analyze the query to determine intent\n const queryIntent = await analyzeQueryIntent(query);\n \n // Handle different types of queries based on intent\n switch (queryIntent.type) {\n case 'link_search':\n return await handleLinkSearch(query, queryIntent.categories);\n \n case 'conversation_search':\n return await handleConversationSearch(query, filters);\n \n case 'summary_request':\n return await handleSummaryRequest(query, filters);\n \n case 'furniture_specific':\n return await handleFurnitureQuery(query);\n \n default:\n // General query - use AI to analyze messages\n return await handleGeneralQuery(query, filters);\n }\n } catch (error) {\n console.error('Error processing query:', error);\n throw error;\n }\n}\n\n/**\n * Analyze the intent of a user query\n * @param {string} query - The user's query\n * @returns {Object} - The query intent\n */\nasync function analyzeQueryIntent(query: string) {\n try {\n const prompt = `\nDetermine the intent of this query about Discord messages between two people:\n\"${query}\"\n\nClassify it as one of these types:\n1. link_search - looking for shared links\n2. conversation_search - looking for specific conversation topics\n3. summary_request - wanting summaries of conversations\n4. furniture_specific - specifically about furniture\n5. general_query - any other type of question\n\nIf it's link_search or furniture_specific, also identify relevant categories.\n\nResponse format:\n{\n \"type\": \"intent_type\",\n \"categories\": [\"category1\", \"category2\"] // Only for link_search or furniture_specific\n}\n `;\n \n const response = await analyzeConversation([], prompt);\n \n // Try to extract JSON from the response\n const jsonMatch = response.match(/\\{[\\s\\S]*\\}/);\n if (jsonMatch) {\n try {\n return JSON.parse(jsonMatch[0]);\n } catch (e) {\n console.error('Error parsing intent JSON:', e);\n }\n }\n \n // Simple heuristic fallback\n const lowerQuery = query.toLowerCase();\n if (lowerQuery.includes('link') || lowerQuery.includes('url') || lowerQuery.includes('website')) {\n return { type: 'link_search', categories: [] };\n } else if (lowerQuery.includes('sofa') || lowerQuery.includes('chair') || \n lowerQuery.includes('table') || lowerQuery.includes('furniture')) {\n return { type: 'furniture_specific', categories: ['sofa', 'chair', 'table'] };\n } else if (lowerQuery.includes('summary') || lowerQuery.includes('summarize')) {\n return { type: 'summary_request', categories: [] };\n } else {\n return { type: 'general_query', categories: [] };\n }\n } catch (error) {\n console.error('Error analyzing query intent:', error);\n return { \n type: 'general_query',\n categories: []\n };\n }\n}\n\n/**\n * Handle a link search query\n * @param {string} query - The user's query\n * @param {Array} categories - Categories to search in\n * @returns {Object} - The query response\n */\nasync function handleLinkSearch(query: string, categories: string[] = []) {\n let linkFilters: any = {};\n \n // If categories are provided, use them\n if (categories && categories.length > 0) {\n linkFilters.category = categories;\n }\n \n // Get links based on filters\n const links = getLinks(linkFilters);\n \n // If no specific categories, use Anthropic to help filter relevant links\n if ((!categories || categories.length === 0) && links.length > 0) {\n const relevantLinks = await filterRelevantLinks(links, query);\n return {\n type: 'links',\n links: relevantLinks,\n message: `Found ${relevantLinks.length} links that might be relevant to your query.`\n };\n }\n \n return {\n type: 'links',\n links: links,\n message: `Found ${links.length} links in the specified categories.`\n };\n}\n\n/**\n * Filter links for relevance to a query\n * @param {Array} links - Array of link objects\n * @param {string} query - The user's query\n * @returns {Array} - Filtered array of relevant links\n */\nasync function filterRelevantLinks(links: any[], query: string) {\n if (links.length === 0) return [];\n \n try {\n // Prepare a sample of links (limit to avoid token limits)\n const linkSample = links.slice(0, 50).map(link => ({\n url: link.url,\n content: link.content,\n id: link.id\n }));\n \n const prompt = `\nI have a list of links shared in Discord messages. Based on this query: \"${query}\"\nPlease determine which of these links are most relevant:\n\n${JSON.stringify(linkSample, null, 2)}\n\nReturn only the IDs of relevant links in a JSON array format like:\n[\"1\", \"5\", \"10\"]\n `;\n \n const response = await analyzeConversation([], prompt);\n \n // Try to extract JSON array from the response\n const jsonMatch = response.match(/\\[([\\s\\S]*?)\\]/);\n if (jsonMatch) {\n try {\n const relevantIds = JSON.parse(jsonMatch[0]);\n return links.filter(link => relevantIds.includes(link.id.toString()));\n } catch (e) {\n console.error('Error parsing relevant link IDs:', e);\n }\n }\n \n // Simple keyword matching fallback\n return links.filter(link => {\n const lowerUrl = link.url.toLowerCase();\n const lowerContent = (link.content || '').toLowerCase();\n const lowerQuery = query.toLowerCase();\n \n const queryKeywords = lowerQuery.split(/\\s+/).filter((word: string) => word.length > 3);\n \n return queryKeywords.some(keyword => \n lowerUrl.includes(keyword) || lowerContent.includes(keyword)\n );\n });\n } catch (error) {\n console.error('Error filtering relevant links:', error);\n return links;\n }\n}\n\n/**\n * Handle a conversation search query\n * @param {string} query - The user's query\n * @param {Object} filters - Message filters\n * @returns {Object} - The query response\n */\nasync function handleConversationSearch(query: string, filters: any = {}) {\n // Get messages based on filters\n const messages = getMessages(filters);\n \n try {\n // Use Anthropic to analyze the conversation\n const result = await analyzeConversation(messages.slice(0, 50), query);\n \n // Extract relevant messages if possible\n const relevantMessageIds: string[] = [];\n const relevantMessages: any[] = [];\n \n // Try to find message IDs in the response\n const messageIdRegex = /message\\s+(?:ID|id|Id):\\s*([a-zA-Z0-9]+)/g;\n let match;\n while ((match = messageIdRegex.exec(result)) !== null) {\n relevantMessageIds.push(match[1]);\n }\n \n // If we found message IDs, look them up\n if (relevantMessageIds.length > 0) {\n for (const id of relevantMessageIds) {\n const message = messages.find(m => m.id === id);\n if (message) {\n relevantMessages.push({\n id: message.id,\n content: message.content,\n timestamp: message.timestamp,\n context: \"Relevant message from conversation\"\n });\n }\n }\n }\n \n return {\n type: 'conversation',\n relevantMessages: relevantMessages,\n summary: result\n };\n } catch (error) {\n console.error('Error in conversation search:', error);\n return {\n type: 'error',\n message: 'Error processing conversation search.'\n };\n }\n}\n\n/**\n * Handle a summary request\n * @param {string} query - The user's query\n * @param {Object} filters - Message filters\n * @returns {Object} - The query response\n */\nasync function handleSummaryRequest(query: string, filters: any = {}) {\n // Get messages based on filters\n const messages = getMessages(filters);\n \n // Use Anthropic to generate a summary\n try {\n const summaryResult = await summarizeConversation(messages.slice(0, 100), query);\n \n // Extract key points if possible\n const keyPointsRegex = /Key points:([\\s\\S]*?)(?:\\n\\n|$)/i;\n const keyPointsMatch = summaryResult.summary.match(keyPointsRegex);\n \n let keyPoints: string[] = [];\n if (keyPointsMatch) {\n // Extract bullet points\n const bulletPointRegex = /[-*]\\s*(.+?)(?=\\n[-*]|\\n\\n|$)/g;\n let bulletMatch;\n while ((bulletMatch = bulletPointRegex.exec(keyPointsMatch[1])) !== null) {\n keyPoints.push(bulletMatch[1].trim());\n }\n }\n \n // If no key points were extracted using regex, try to infer some\n if (keyPoints.length === 0) {\n const sentences = summaryResult.summary.split(/[.!?]+/).filter((s: string) => s.trim().length > 20);\n keyPoints = sentences.slice(0, 3).map((s: string) => s.trim());\n }\n \n return {\n type: 'summary',\n summary: summaryResult.summary,\n keyPoints: keyPoints,\n messageCount: messages.length\n };\n } catch (error) {\n console.error('Error generating summary:', error);\n return {\n type: 'error',\n message: 'Error generating summary.'\n };\n }\n}\n\n/**\n * Handle a furniture-specific query\n * @param {string} query - The user's query\n * @returns {Object} - The query response\n */\nasync function handleFurnitureQuery(query: string) {\n // Get furniture-related links\n const furnitureCategories = ['sofa', 'chair', 'table', 'bed', 'dresser', 'desk', 'lamp'];\n const furnitureLinks = getLinks({ category: furnitureCategories });\n \n // Get messages that mention furniture\n const furnitureKeywords = ['sofa', 'chair', 'table', 'bed', 'dresser', 'desk', 'lamp', 'couch', 'furniture'];\n \n let messagesWithFurniture: any[] = [];\n for (const keyword of furnitureKeywords) {\n const messages = getMessages({ search: keyword });\n messagesWithFurniture = [...messagesWithFurniture, ...messages];\n }\n \n // Remove duplicates\n const uniqueMessageIds = new Set();\n messagesWithFurniture = messagesWithFurniture.filter(msg => {\n if (uniqueMessageIds.has(msg.id)) {\n return false;\n }\n uniqueMessageIds.add(msg.id);\n return true;\n });\n \n // Use Anthropic to analyze furniture-related content\n try {\n // Create prompt for furniture analysis\n const prompt = `\nI have a set of Discord messages and links related to furniture. The user wants to know about: \"${query}\"\n\nPlease analyze what the two people have discussed about furniture,\nespecially anything related to the user's query. Include any preferences, opinions,\nor decisions they've made about furniture items.\n\nFocus on:\n1. Overall furniture preferences and tastes\n2. Specific opinions about furniture items they've shared\n3. Any decisions they've made about furniture purchases\n4. Finding relevant furniture links that address the query\n `;\n \n const analysis = await analyzeConversation(messagesWithFurniture.slice(0, 50), prompt);\n \n // Extract preferences if possible\n const preferencesRegex = /preferences:?([\\s\\S]*?)(?:\\n\\n|$)/i;\n const preferencesMatch = analysis.match(preferencesRegex);\n \n let preferences: string[] = [];\n if (preferencesMatch) {\n // Extract bullet points\n const bulletPointRegex = /[-*]\\s*(.+?)(?=\\n[-*]|\\n\\n|$)/g;\n let bulletMatch;\n while ((bulletMatch = bulletPointRegex.exec(preferencesMatch[1])) !== null) {\n preferences.push(bulletMatch[1].trim());\n }\n }\n \n // If no preferences were extracted, try to infer some\n if (preferences.length === 0) {\n // Look for phrases like \"prefers\", \"likes\", \"wants\", etc.\n const preferenceRegex = /(?:prefer|like|want|look for|interested in)s?\\s+([^.!?]+)/gi;\n let prefMatch;\n while ((prefMatch = preferenceRegex.exec(analysis)) !== null) {\n preferences.push(prefMatch[1].trim());\n }\n }\n \n // Find relevant links\n const relevantLinks = furnitureLinks.slice(0, 10).map(link => ({\n url: link.url,\n context: `Shared furniture link related to ${link.category || 'furniture'}`\n }));\n \n return {\n type: 'furniture',\n analysis: analysis,\n preferences: preferences.slice(0, 5), // Limit to 5 preferences\n relevantLinks: relevantLinks,\n messageCount: messagesWithFurniture.length,\n linkCount: furnitureLinks.length\n };\n } catch (error) {\n console.error('Error analyzing furniture data:', error);\n return {\n type: 'error',\n message: 'Error analyzing furniture-related data.'\n };\n }\n}\n\n/**\n * Handle a general query\n * @param {string} query - The user's query\n * @param {Object} filters - Message filters\n * @returns {Object} - The query response\n */\nasync function handleGeneralQuery(query: string, filters: any = {}) {\n // Get messages based on filters\n const messages = getMessages(filters);\n \n // Use Anthropic to analyze messages\n try {\n // Direct analysis of messages with Claude\n const answer = await analyzeConversation(messages.slice(0, 50), query);\n \n // Extract evidence if possible\n const evidenceRegex = /evidence:?([\\s\\S]*?)(?:\\n\\n|$)/i;\n const evidenceMatch = answer.match(evidenceRegex);\n \n let evidence: string[] = [];\n if (evidenceMatch) {\n // Extract bullet points\n const bulletPointRegex = /[-*]\\s*(.+?)(?=\\n[-*]|\\n\\n|$)/g;\n let bulletMatch;\n while ((bulletMatch = bulletPointRegex.exec(evidenceMatch[1])) !== null) {\n evidence.push(bulletMatch[1].trim());\n }\n }\n \n // Determine confidence based on answer content\n let confidence = 'medium';\n if (answer.toLowerCase().includes('not enough information') || \n answer.toLowerCase().includes('cannot determine') ||\n answer.toLowerCase().includes('no evidence')) {\n confidence = 'low';\n } else if (answer.toLowerCase().includes('clearly') || \n answer.toLowerCase().includes('definitely') ||\n answer.toLowerCase().includes('conclusively')) {\n confidence = 'high';\n }\n \n return {\n type: 'general',\n answer: answer,\n evidence: evidence,\n confidence: confidence,\n messageCount: messages.length\n };\n } catch (error) {\n console.error('Error processing general query:', error);\n return {\n type: 'error',\n message: 'Error processing your query.'\n };\n }\n}",[],[152,170,241],[152,170],{"_103":250,"_95":251,"_153":252,"_155":154,"_156":138,"_157":253,"_159":116,"_105":254,"_99":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_166":255,"_98":292},"7c532f96-2710-11f0-8393-569c3dd06744","frontend","7c533040-2710-11f0-8393-569c3dd06744",2,["D",1746161220722],[256,273,283],{"_103":257,"_95":258,"_153":259,"_155":252,"_156":138,"_157":260,"_159":116,"_105":261,"_99":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_166":262,"_98":272},"7c86d184-2710-11f0-9826-569c3dd06744","components","7c86d210-2710-11f0-9826-569c3dd06744",5,["D",1746161221058],[263],{"_103":264,"_95":265,"_153":266,"_155":259,"_156":138,"_157":267,"_159":116,"_105":268,"_99":32,"_161":181,"_163":269,"_164":22,"_165":-5,"_166":270,"_98":271},"7cc7fefc-2710-11f0-9826-569c3dd06744","App.tsx","7cc7ffba-2710-11f0-9826-569c3dd06744",14,["D",1746161221385],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState, useEffect } from \"https://esm.sh/react@18.2.0\";\n\ninterface ProjectInfo {\n name: string;\n username: string;\n version: string;\n viewSourceUrl: string;\n}\n\n// Access the project info injected by the server\ndeclare global {\n interface Window {\n __PROJECT_INFO__?: ProjectInfo;\n }\n}\n\nexport function App() {\n const [status, setStatus] = useState<'idle' | 'loading' | 'success' | 'error'>('idle');\n const [serverInfo, setServerInfo] = useState(null);\n const [error, setError] = useState(null);\n \n // Fetch server health status on component mount\n useEffect(() => {\n async function checkHealth() {\n try {\n setStatus('loading');\n const response = await fetch('/health');\n if (!response.ok) {\n throw new Error(`Health check failed: ${response.status}`);\n }\n const data = await response.json();\n setServerInfo(data);\n setStatus('success');\n } catch (err) {\n console.error('Health check error:', err);\n setError(err instanceof Error ? err.message : String(err));\n setStatus('error');\n }\n }\n \n checkHealth();\n }, []);\n \n // Get project info from window object\n const projectInfo = window.__PROJECT_INFO__;\n \n return (\n

Discord DM Analyzer

\n AI-powered tool to analyze Discord DMs, track shared links, and provide insights about conversations.\n

\n \n

Server Status

\n {status === 'loading' && (\n

Checking server status...

\n )}\n \n {status === 'error' && (\n

Error connecting to server

\n {error &&

{error}

}\n

\n )}\n \n {status === 'success' && serverInfo && (\n

Status

\n \n {serverInfo.status}\n

\n {serverInfo.version && (\n

Version

{serverInfo.version}

\n )}\n {serverInfo.timestamp && (\n

Last Check

\n {new Date(serverInfo.timestamp).toLocaleString()}\n

\n )}\n

\n \n

Available Endpoints

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

Endpoint	Method	Description
/api/interactions	POST	Discord interactions endpoint
/api/fetch-dms	POST	Manually trigger DM fetching
/api/process-links	POST	Manually process links
/api/query	POST	Query your conversation data
/api/register-commands	POST	Register Discord slash commands

\n \n \n

\n );\n}",[],[152,251,258,265],[152,251,258],{"_103":274,"_95":275,"_153":276,"_155":252,"_156":138,"_157":277,"_159":116,"_105":278,"_99":32,"_161":279,"_163":280,"_164":22,"_165":-5,"_166":281,"_98":282},"7cbacb6a-2710-11f0-8393-569c3dd06744","index.html","7cbacc1e-2710-11f0-8393-569c3dd06744",10,["D",1746161221383],"file","\n\n \n \n \n Discord DM Analyzer\n \n \n \n \n \n \n

\n \n \n \n",[],[152,251,275],{"_103":284,"_95":285,"_153":286,"_155":252,"_156":138,"_157":287,"_159":116,"_105":288,"_99":32,"_161":181,"_163":289,"_164":22,"_165":-5,"_166":290,"_98":291},"7cb7fd86-2710-11f0-a1a2-569c3dd06744","index.tsx","7cb7fe1c-2710-11f0-a1a2-569c3dd06744",9,["D",1746161221382],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client?deps=react@18.2.0\";\nimport { App } from \"./components/App.tsx\";\n\n// Get root element\nconst root = document.getElementById(\"root\");\nif (!root) {\n throw new Error(\"Root element not found in document\");\n}\n\n// Render the App\ncreateRoot(root).render();",[],[152,251,285],[152,251],{"_103":294,"_95":295,"_153":296,"_155":154,"_156":138,"_157":297,"_159":116,"_105":298,"_99":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_166":299,"_98":318},"7c75e126-2710-11f0-8393-569c3dd06744","shared","7c75e1b2-2710-11f0-8393-569c3dd06744",4,["D",1746161220949],[300,309],{"_103":301,"_95":302,"_153":303,"_155":296,"_156":138,"_157":304,"_159":116,"_105":305,"_99":32,"_161":181,"_163":306,"_164":22,"_165":-5,"_166":307,"_98":308},"7ce652f8-2710-11f0-89d1-569c3dd06744","types.ts","7ce653ac-2710-11f0-89d1-569c3dd06744",22,["D",1746161221561],"/**\n * Shared types for Discord DM Analyzer\n */\n\n// Discord-related types\nexport interface DiscordMessage {\n id: string;\n content: string;\n authorId: string;\n timestamp: number;\n attachments?: string[];\n embeds?: string[];\n}\n\nexport interface DiscordChannel {\n id: string;\n type: number;\n name?: string;\n recipient_id?: string;\n}\n\nexport interface DiscordInteraction {\n id: string;\n type: number;\n data: {\n id?: string;\n name?: string;\n options?: DiscordInteractionOption[];\n };\n guild_id?: string;\n channel_id?: string;\n user?: {\n id: string;\n username: string;\n };\n token: string;\n version: number;\n}\n\nexport interface DiscordInteractionOption {\n name: string;\n type: number;\n value?: string;\n options?: DiscordInteractionOption[];\n}\n\nexport interface DiscordInteractionResponse {\n type: number;\n data?: {\n content?: string;\n embeds?: any[];\n components?: any[];\n flags?: number;\n };\n}\n\n// Database-related types\nexport interface MessageRecord {\n id: string;\n content: string;\n author_id: string;\n timestamp: number;\n processed: number;\n attachment_url?: string;\n}\n\nexport interface LinkRecord {\n id: number;\n message_id: string;\n url: string;\n category: string;\n title?: string;\n description?: string;\n content?: string;\n timestamp?: number;\n author_id?: string;\n}\n\nexport interface CategoryRecord {\n id: number;\n name: string;\n created_at: number;\n}\n\n// Query-related types\nexport interface QueryFilters {\n startDate?: string | number;\n endDate?: string | number;\n authorId?: string;\n search?: string;\n limit?: number;\n category?: string | string[];\n url?: string;\n}\n\nexport interface QueryResult {\n type: 'links' | 'conversation' | 'summary' | 'furniture' | 'general' | 'error';\n links?: LinkRecord[];\n message?: string;\n relevantMessages?: MessageRecord[];\n summary?: string;\n analysis?: string;\n preferences?: string[];\n relevantLinks?: { url: string; context: string }[];\n messageCount?: number;\n linkCount?: number;\n keyPoints?: string[];\n answer?: string;\n evidence?: string[];\n confidence?: 'low' | 'medium' | 'high';\n error?: string;\n}\n\n// Claude API types\nexport interface ClaudeOptions {\n model?: string;\n maxTokens?: number;\n temperature?: number;\n systemPrompt?: string;\n}\n\nexport interface SummaryResult {\n summary: string;\n messageCount: number;\n}",[],[152,295,302],{"_103":310,"_95":311,"_153":312,"_155":296,"_156":138,"_157":313,"_159":116,"_105":314,"_99":32,"_161":181,"_163":315,"_164":22,"_165":-5,"_166":316,"_98":317},"7cdea8f0-2710-11f0-a023-569c3dd06744","utils.ts","7cdea9ae-2710-11f0-a023-569c3dd06744",20,["D",1746161221555],"/**\n * Shared utility functions for Discord DM Analyzer\n */\n\n/**\n * Extract URLs from text content\n * @param content - The text content to extract URLs from\n * @returns Array of matched URLs or null if none found\n */\nexport function extractUrls(content: string): string[] | null {\n if (!content) return null;\n \n // Simple URL regex for extraction\n const urlRegex = /(https?:\\/\\/[^\\s]+)/g;\n const matches = content.match(urlRegex);\n \n return matches;\n}\n\n/**\n * Format timestamp to human-readable date string\n * @param timestamp - Unix timestamp in milliseconds\n * @returns Formatted date string\n */\nexport function formatTimestamp(timestamp: number): string {\n return new Date(timestamp).toLocaleString();\n}\n\n/**\n * Create a proper Discord command response\n * @param content - Response content\n * @param ephemeral - Whether the response should be ephemeral (only visible to command user)\n * @returns Discord interaction response object\n */\nexport function createCommandResponse(content: string, ephemeral: boolean = false): any {\n return {\n type: 4, // CHANNEL_MESSAGE_WITH_SOURCE\n data: {\n content,\n flags: ephemeral ? 64 : undefined // EPHEMERAL = 64\n }\n };\n}\n\n/**\n * Truncate text to specified length with ellipsis\n * @param text - Text to truncate\n * @param maxLength - Maximum length\n * @returns Truncated text\n */\nexport function truncateText(text: string, maxLength: number = 1000): string {\n if (!text || text.length <= maxLength) return text;\n return text.substring(0, maxLength - 3) + '...';\n}\n\n/**\n * Safely parse JSON with fallback\n * @param text - Text to parse as JSON\n * @param fallback - Fallback value if parsing fails\n * @returns Parsed JSON or fallback\n */\nexport function safeJsonParse(text: string, fallback: any = null): any {\n try {\n return JSON.parse(text);\n } catch (error) {\n return fallback;\n }\n}\n\n/**\n * Split array into chunks of specified size\n * @param array - Array to split\n * @param chunkSize - Size of each chunk\n * @returns Array of chunks\n */\nexport function chunkArray(array: T[], chunkSize: number): T[][] {\n const chunks = [];\n for (let i = 0; i < array.length; i += chunkSize) {\n chunks.push(array.slice(i, i + chunkSize));\n }\n return chunks;\n}\n\n/**\n * Get environment variable with validation\n * @param key - Environment variable key\n * @param required - Whether the variable is required\n * @returns Environment variable value or undefined\n */\nexport function getEnv(key: string, required: boolean = true): string | undefined {\n const value = Deno.env.get(key);\n if (required && !value) {\n console.error(`Required environment variable ${key} is missing`);\n }\n return value;\n}\n\n/**\n * Log message with timestamp\n * @param message - Message to log\n * @param level - Log level\n */\nexport function log(message: string, level: 'info' | 'error' | 'warn' | 'debug' = 'info'): void {\n const timestamp = new Date().toISOString();\n const formattedMessage = `[${timestamp}] [${level.toUpperCase()}] ${message}`;\n \n switch (level) {\n case 'error':\n console.error(formattedMessage);\n break;\n case 'warn':\n console.warn(formattedMessage);\n break;\n case 'debug':\n console.debug(formattedMessage);\n break;\n default:\n console.log(formattedMessage);\n }\n}",[],[152,295,311],[152,295],{"_103":320,"_95":321,"_153":322,"_155":154,"_156":138,"_157":323,"_159":116,"_105":324,"_99":32,"_161":279,"_163":325,"_164":22,"_165":-5,"_166":326,"_98":327},"7cdaa462-2710-11f0-9826-569c3dd06744","README.md","7cdaa4f8-2710-11f0-9826-569c3dd06744",19,["D",1746161221586],"# Discord DM Analyzer for Val.town\n\nThis project is a Discord bot that analyzes direct messages between two users (e.g., you and your partner), particularly focusing on:\n\n1. Tracking and categorizing shared links\n2. Searching conversation history\n3. Summarizing discussions on specific topics\n4. Analyzing furniture-related discussions\n\n## Architecture\n\nThe project is structured to work with Val.town and has the following components:\n\n- **Database Layer**: Uses Val.town's built-in SQLite database\n- **AI Integration**: Leverages Anthropic's Claude API for analysis\n- **Discord Integration**:\n - Bot token for fetching messages\n - Slash commands for user interactions\n - Webhook endpoint for Discord interactions\n- **API Endpoints**: Various endpoints for manual operations and automation\n\n## Setup\n\n### Environment Variables\n\nTo run this project on Val.town, you need to set up the following environment variables:\n\n- `DISCORD_TOKEN`: Your Discord bot token\n- `DISCORD_CLIENT_ID`: Your Discord application ID\n- `DISCORD_PUBLIC_KEY`: Public key for verifying Discord interactions\n- `DISCORD_USER_ID`: Your Discord user ID\n- `SPOUSE_USER_ID`: Your partner's Discord user ID\n- `ANTHROPIC_API_KEY`: Your Anthropic API key\n\n### Discord Bot Setup\n\n1. Create a Discord application: https://discord.com/developers/applications\n2. Add a bot to your application\n3. Set the required permissions:\n - Read Messages/View Channels\n - Read Message History\n - Send Messages\n4. Enable the Message Content Intent in the Bot section\n5. Use the `OAuth2 URL Generator` to create an invite link with the `bot` scope\n6. Add the bot to a server where both you and your partner are members\n\n### Val.town Deployment\n\n1. Create a new Val on Val.town\n2. Copy the contents of the backend directory\n3. Set up the required environment variables\n4. Create a cron schedule for periodically fetching messages and processing links\n\n## Usage\n\n### API Endpoints\n\n- `GET /health`: Check if the service is running\n- `POST /api/interactions`: Discord interactions endpoint\n- `POST /api/fetch-dms`: Manually trigger DM fetching\n- `POST /api/process-links`: Manually trigger link processing\n- `POST /api/query`: Process a query about your messages\n- `POST /api/commands/search`: Endpoint for search commands\n- `POST /api/register-commands`: Register Discord slash commands\n- `GET /api/cron/fetch-dms`: Cron endpoint for fetching DMs\n- `GET /api/cron/process-links`: Cron endpoint for processing links\n\n### Discord Commands\n\nThe bot provides several slash commands:\n\n- `/search [query]`: Search your conversation history\n- `/links [category]`: Find links shared in conversations, optionally filtered by category\n- `/categories`: List all available link categories\n- `/analyze [query]`: Perform a deeper analysis of your conversations\n\n## Development\n\n### Local Development\n\n1. Clone the repository\n2. Create a `.env` file with the required environment variables\n3. Install dependencies with `deno cache --reload index.ts`\n4. Run locally with `deno run --allow-net --allow-env index.ts`\n\n### Frontend\n\nA basic frontend is provided in the `frontend` directory. For now, we're focusing on the backend functionality, but the frontend can be extended to provide a web interface for searching and visualizing conversation data.\n\n## Val.town Specific Considerations\n\n- The database uses Val.town's built-in SQLite database\n- The code uses Deno and ESM modules compatible with Val.town\n- HTTP endpoints are designed to work with Val.town's serverless model\n- Discord verification is implemented according to Discord's security requirements\n\n## Credits\n\nThis project was ported from a Node.js implementation to work specifically with Val.town's environment.",[],[152,321],[152],{"_103":330,"_95":331,"_153":332,"_155":-5,"_156":138,"_157":333,"_159":116,"_105":334,"_99":32,"_161":279,"_163":335,"_164":22,"_165":-5,"_166":336,"_98":337},"7cb3e872-2710-11f0-bc07-569c3dd06744","DISCORD_BOT_SETUP.md","7cb3e930-2710-11f0-bc07-569c3dd06744",8,["D",1746161221312],"# Step-by-Step Discord Bot Setup Guide\n\nThis guide will walk you through creating a Discord bot and setting it up to work with the Discord DM Analyzer.\n\n## 1. Create a Discord Application\n\n1. Go to the [Discord Developer Portal](https://discord.com/developers/applications)\n2. Click the \"New Application\" button in the top-right corner\n3. Enter a name for your application (e.g., \"DM Analyzer\")\n4. Accept the terms and click \"Create\"\n\n## 2. Set Up the Bot\n\n1. In the left sidebar, click on \"Bot\"\n2. Click the \"Add Bot\" button on the right\n3. Confirm by clicking \"Yes, do it!\"\n4. Under the bot's username, you'll see a \"Reset Token\" button\n5. Click \"Reset Token\" and confirm\n6. Copy the token that appears - this is your `DISCORD_TOKEN`\n7. Under \"Privileged Gateway Intents\", enable:\n - MESSAGE CONTENT INTENT\n - SERVER MEMBERS INTENT\n8. Scroll down and click \"Save Changes\"\n\n## 3. Get Your Application ID\n\n1. In the left sidebar, click on \"General Information\"\n2. Under \"Application ID\", click the \"Copy\" button\n3. This is your `DISCORD_CLIENT_ID`\n\n## 4. Get Your User ID\n\n1. Open Discord\n2. Go to User Settings (gear icon next to your name)\n3. Select \"Advanced\" in the left sidebar\n4. Enable \"Developer Mode\"\n5. Close User Settings\n6. Right-click on your username anywhere in Discord\n7. Select \"Copy ID\"\n8. This is your `DISCORD_USER_ID`\n\n## 5. Get Your Spouse's User ID\n\n1. Right-click on your spouse's username in Discord\n2. Select \"Copy ID\"\n3. This is your `SPOUSE_USER_ID`\n\n## 6. Update Environment Variables\n\n1. In your project directory, create a `.env` file if you haven't already\n2. Add the following variables:\n ```\n DISCORD_TOKEN=your_discord_token_here\n DISCORD_CLIENT_ID=your_client_id_here\n DISCORD_USER_ID=your_user_id_here\n SPOUSE_USER_ID=spouse_user_id_here\n ```\n\n## 7. Get OpenAI API Key\n\n1. Go to [OpenAI's website](https://platform.openai.com/)\n2. Sign up or log in\n3. Navigate to the API keys section\n4. Create a new API key\n5. Copy the key\n6. Add it to your `.env` file:\n ```\n OPENAI_API_KEY=your_openai_api_key_here\n ```\n\n## 8. Register Bot Commands\n\n1. In your project directory, run:\n ```\n node discord-commands.js\n ```\n2. You should see \"Successfully registered application commands.\"\n\n## 9. Invite the Bot to Your Server\n\n1. In the Discord Developer Portal, click on \"OAuth2\" in the left sidebar\n2. Click on \"URL Generator\"\n3. Under \"Scopes\", select:\n - bot\n - applications.commands\n4. Under \"Bot Permissions\", select:\n - Read Messages/View Channels\n - Send Messages\n - Read Message History\n5. Copy the generated URL at the bottom\n6. Paste the URL in your browser\n7. Select a server where you want to add the bot\n8. Click \"Authorize\"\n9. Complete the CAPTCHA if prompted\n\n## 10. Deploy to Val.town (Optional)\n\n1. Install the Val.town CLI:\n ```\n npm install -g val-town-cli\n ```\n2. Authenticate with Val.town:\n ```\n vt login\n ```\n3. Deploy the application:\n ```\n node val-town-deploy.js\n ```\n4. Set up environment variables in Val.town:\n - Go to the Val.town dashboard\n - Find your deployed functions\n - Add the same environment variables from your `.env` file\n5. Set up a scheduled task for periodic DM fetching:\n - Create a new scheduled task in Val.town\n - Use the `discordDMBotCron` function\n - Choose a schedule (e.g., every 6 hours)\n\n## 11. Test Your Bot\n\n1. Start the local server:\n ```\n node index.js\n ```\n2. In Discord, use one of the slash commands:\n - `/search What did we say about the IKEA table?`\n - `/links sofa`\n - `/categories`\n - `/analyze Summarize our furniture discussions`\n\n3. You can also manually trigger a DM fetch:\n ```\n node val-town-cron.js\n ```\n\n## Troubleshooting\n\n### Bot not responding to commands\n- Make sure the bot is running (`node index.js`)\n- Check if commands were registered successfully\n- Verify that the bot has proper permissions\n\n### Cannot fetch DMs\n- Ensure both you and your spouse have DMed each other at least once\n- Verify that all tokens and IDs in the `.env` file are correct\n- Check Discord developer portal for any token or permission issues\n\n### Val.town deployment issues\n- Make sure you're logged in to Val.town CLI\n- Check for any errors in the deployment logs\n- Verify that environment variables are set correctly in Val.town\n\n## Next Steps\n\n1. Customize the bot's responses by editing the API endpoints in `api-server.js`\n2. Add more categories for link classification in `database.js`\n3. Enhance the AI queries by modifying prompts in `query-service.js`\n4. Create a web interface that connects to your API endpoints",[],[331],{"_103":339,"_95":321,"_153":340,"_155":-5,"_156":138,"_157":341,"_159":116,"_105":342,"_99":32,"_161":279,"_163":343,"_164":22,"_165":-5,"_166":344,"_98":345},"7cfa20da-2710-11f0-9826-569c3dd06744","7cfa2166-2710-11f0-9826-569c3dd06744",27,["D",1746161221708],"# Discord DM Analyzer\n\nA Discord bot that analyzes direct messages between you and your partner, allowing you to search and query conversation history, track shared links, and more. Perfect for finding those furniture links you shared months ago!\n\n## Features\n\n- **Message History Storage**: Securely stores your DM history in a SQLite database\n- **Link Detection & Categorization**: Automatically detects and categorizes links shared in conversations\n- **AI-Powered Querying**: Ask natural language questions about your conversation history\n- **Furniture Focus**: Special features for tracking furniture links and discussions\n- **Val.town Integration**: Runs on Val.town for easy deployment and scheduling\n- **Periodic Updates**: Automatically fetches new messages on a schedule\n\n## Use Cases\n\n- \"Show me all the sofas we discussed last month\"\n- \"What did we say about the IKEA table?\"\n- \"Find all the furniture links we shared since January\"\n- \"Summarize our discussion about the dining room\"\n\n## Setup Instructions\n\n### Prerequisites\n\n- Node.js 16+ and npm\n- Discord account with Bot token\n- OpenAI API key (for AI-powered queries)\n- Val.town account (for deployment)\n\n### Local Development Setup\n\n1. Clone this repository\n ```\n git clone \n cd discord-bot\n ```\n\n2. Install dependencies\n ```\n npm install\n ```\n\n3. Create a `.env` file based on `.env.example`\n ```\n cp .env.example .env\n ```\n\n4. Fill in the required environment variables in `.env`:\n - `DISCORD_TOKEN`: Your Discord bot token\n - `DISCORD_CLIENT_ID`: Your Discord application client ID\n - `DISCORD_USER_ID`: Your Discord user ID\n - `SPOUSE_USER_ID`: Your partner's Discord user ID\n - `OPENAI_API_KEY`: Your OpenAI API key\n\n5. Initialize the database\n ```\n node index.js\n ```\n\n6. Test the DM fetching process\n ```\n node val-town-cron.js\n ```\n\n### Val.town Deployment\n\n1. Install the Val.town CLI\n ```\n npm install -g val-town-cli\n ```\n\n2. Authenticate with Val.town\n ```\n vt login\n ```\n\n3. Deploy the application to Val.town\n ```\n node val-town-deploy.js\n ```\n\n4. Configure Val.town environment variables\n - Go to the Val.town dashboard\n - Add the same environment variables from your `.env` file\n\n5. Set up a scheduled task on Val.town for periodic DM fetching\n - Create a new scheduled task using the Val.town dashboard\n - Use the `discordDMBotCron` function\n - Set the schedule (e.g., every 6 hours)\n\n### Creating a Discord Bot\n\n1. Go to the [Discord Developer Portal](https://discord.com/developers/applications)\n2. Create a New Application\n3. Go to the \"Bot\" tab and create a bot\n4. Under \"Privileged Gateway Intents\", enable:\n - Message Content Intent\n - Server Members Intent\n5. Copy the bot token to your `.env` file\n6. Invite the bot to your server using the OAuth2 URL Generator\n - Select \"bot\" scope\n - Select permissions: Read Messages/View Channels, Read Message History\n7. Start a DM with your partner to create the DM channel the bot will monitor\n\n## API Endpoints\n\nThe application exposes the following HTTP endpoints:\n\n- `GET /health`: Health check endpoint\n- `POST /api/fetch-dms`: Manually trigger DM fetching\n- `POST /api/process-links`: Manually trigger link processing\n- `POST /api/query`: Submit a query about your message history\n - Body: `{ \"query\": \"your question here\", \"filters\": { optional filters } }`\n- `POST /api/commands/search`: Discord command endpoint for searching\n - Body: `{ \"query\": \"your search term\" }`\n\n## Discord Commands\n\nOnce set up, you can interact with the bot using the following commands:\n\n- `/search [query]`: Search your conversation history\n- `/links [category]`: Show links from a specific category\n- `/categories`: List all available link categories\n- `/analyze [query]`: Analyze your conversation with AI\n\n## Database Schema\n\nThe application uses a SQLite database with the following tables:\n\n- `messages`: Stores all DM messages\n- `attachments`: Stores message attachments\n- `embeds`: Stores message embeds\n- `links`: Stores extracted links with categories\n- `categories`: Stores link categories\n- `conversations`: Stores AI-generated conversation summaries\n\n## Contributing\n\nContributions are welcome! Please feel free to submit a Pull Request.\n\n## License\n\nThis project is licensed under the MIT License - see the LICENSE file for details.\n\n## Acknowledgements\n\n- Discord.js for Discord API integration\n- OpenAI for AI-powered querying\n- Val.town for hosting and scheduling\n- Better-SQLite3 for database management",[],[321],{"_103":347,"_95":348,"_153":349,"_155":-5,"_156":138,"_157":350,"_159":116,"_105":351,"_99":32,"_161":181,"_163":352,"_164":22,"_165":-5,"_166":353,"_98":354},"7cafebdc-2710-11f0-9826-569c3dd06744","database.js","7cafec68-2710-11f0-9826-569c3dd06744",7,["D",1746161221310],"import Database from 'better-sqlite3';\nimport linkify from 'linkify-it';\nimport 'dotenv/config';\n\n// For Val.town, we'll use the built-in SQLite functionality\n// In local dev, we'll use a file-based database\nconst DB_PATH = process.env.NODE_ENV === 'production' ? ':memory:' : './messages.db';\n\n// Initialize link parser\nconst linkParser = linkify();\n\n/**\n * Initialize the database schema\n */\nexport function initializeDatabase() {\n const db = new Database(DB_PATH);\n \n // Create messages table\n db.exec(`\n CREATE TABLE IF NOT EXISTS messages (\n id TEXT PRIMARY KEY,\n content TEXT,\n author_id TEXT,\n timestamp INTEGER,\n processed INTEGER DEFAULT 0\n )\n `);\n \n // Create attachments table\n db.exec(`\n CREATE TABLE IF NOT EXISTS attachments (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message_id TEXT,\n url TEXT,\n FOREIGN KEY (message_id) REFERENCES messages(id)\n )\n `);\n \n // Create embeds table\n db.exec(`\n CREATE TABLE IF NOT EXISTS embeds (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message_id TEXT,\n data TEXT,\n FOREIGN KEY (message_id) REFERENCES messages(id)\n )\n `);\n \n // Create links table\n db.exec(`\n CREATE TABLE IF NOT EXISTS links (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message_id TEXT,\n url TEXT,\n category TEXT,\n title TEXT,\n description TEXT,\n FOREIGN KEY (message_id) REFERENCES messages(id)\n )\n `);\n \n // Create categories table for organizing links\n db.exec(`\n CREATE TABLE IF NOT EXISTS categories (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT UNIQUE,\n created_at INTEGER\n )\n `);\n \n // Create table for AI-based message summaries\n db.exec(`\n CREATE TABLE IF NOT EXISTS conversations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n start_timestamp INTEGER,\n end_timestamp INTEGER,\n summary TEXT,\n topic TEXT\n )\n `);\n \n // Insert some default categories for furniture (per your example)\n const defaultCategories = [\n 'sofa', 'chair', 'table', 'bed', 'dresser', 'desk', \n 'lamp', 'shelf', 'bookcase', 'rug', 'curtain', 'other'\n ];\n \n const insertCategory = db.prepare('INSERT OR IGNORE INTO categories (name, created_at) VALUES (?, ?)');\n const now = Date.now();\n \n for (const category of defaultCategories) {\n insertCategory.run(category, now);\n }\n \n return db;\n}\n\n/**\n * Save messages to the database\n * @param {Array} messages - Array of message objects to save\n */\nexport async function saveDMMessages(messages) {\n const db = initializeDatabase();\n \n // Prepare statements\n const insertMessage = db.prepare(`\n INSERT OR IGNORE INTO messages (id, content, author_id, timestamp)\n VALUES (?, ?, ?, ?)\n `);\n \n const insertAttachment = db.prepare(`\n INSERT INTO attachments (message_id, url)\n VALUES (?, ?)\n `);\n \n const insertEmbed = db.prepare(`\n INSERT INTO embeds (message_id, data)\n VALUES (?, ?)\n `);\n \n const insertLink = db.prepare(`\n INSERT INTO links (message_id, url, category)\n VALUES (?, ?, ?)\n `);\n \n // Begin transaction\n const transaction = db.transaction((messages) => {\n for (const message of messages) {\n // Insert message\n insertMessage.run(\n message.id,\n message.content,\n message.authorId,\n message.timestamp\n );\n \n // Insert attachments\n if (message.attachments && message.attachments.length > 0) {\n for (const url of message.attachments) {\n insertAttachment.run(message.id, url);\n }\n }\n \n // Insert embeds\n if (message.embeds && message.embeds.length > 0) {\n for (const embed of message.embeds) {\n insertEmbed.run(message.id, embed);\n }\n }\n \n // Extract and insert links\n if (message.content) {\n const links = linkParser.match(message.content);\n if (links) {\n for (const link of links) {\n // Default to 'other' category, can be updated later\n insertLink.run(message.id, link.url, 'other');\n }\n }\n }\n }\n });\n \n // Execute transaction\n transaction(messages);\n \n console.log(`Saved ${messages.length} messages to database`);\n \n db.close();\n}\n\n/**\n * Get messages from the database, with optional filtering\n * @param {Object} filters - Optional filters for messages\n * @returns {Array} - Array of message objects\n */\nexport function getMessages(filters = {}) {\n const db = initializeDatabase();\n \n let query = `\n SELECT m.*, a.url as attachment_url\n FROM messages m\n LEFT JOIN attachments a ON m.id = a.message_id\n `;\n \n const queryParams = [];\n const whereClauses = [];\n \n // Apply filters\n if (filters.startDate) {\n whereClauses.push('m.timestamp >= ?');\n queryParams.push(new Date(filters.startDate).getTime());\n }\n \n if (filters.endDate) {\n whereClauses.push('m.timestamp <= ?');\n queryParams.push(new Date(filters.endDate).getTime());\n }\n \n if (filters.authorId) {\n whereClauses.push('m.author_id = ?');\n queryParams.push(filters.authorId);\n }\n \n if (filters.search) {\n whereClauses.push('m.content LIKE ?');\n queryParams.push(`%${filters.search}%`);\n }\n \n // Construct final query\n if (whereClauses.length > 0) {\n query += ' WHERE ' + whereClauses.join(' AND ');\n }\n \n query += ' ORDER BY m.timestamp DESC';\n \n // Add limit if specified\n if (filters.limit) {\n query += ' LIMIT ?';\n queryParams.push(filters.limit);\n }\n \n const results = db.prepare(query).all(...queryParams);\n \n db.close();\n \n return results;\n}\n\n/**\n * Get links from the database, with optional filtering\n * @param {Object} filters - Optional filters for links\n * @returns {Array} - Array of link objects\n */\nexport function getLinks(filters = {}) {\n const db = initializeDatabase();\n \n let query = `\n SELECT l.*, m.content, m.timestamp, m.author_id\n FROM links l\n JOIN messages m ON l.message_id = m.id\n `;\n \n const queryParams = [];\n const whereClauses = [];\n \n // Apply filters\n if (filters.category) {\n whereClauses.push('l.category = ?');\n queryParams.push(filters.category);\n }\n \n if (filters.url) {\n whereClauses.push('l.url LIKE ?');\n queryParams.push(`%${filters.url}%`);\n }\n \n if (filters.startDate) {\n whereClauses.push('m.timestamp >= ?');\n queryParams.push(new Date(filters.startDate).getTime());\n }\n \n if (filters.endDate) {\n whereClauses.push('m.timestamp <= ?');\n queryParams.push(new Date(filters.endDate).getTime());\n }\n \n // Construct final query\n if (whereClauses.length > 0) {\n query += ' WHERE ' + whereClauses.join(' AND ');\n }\n \n query += ' ORDER BY m.timestamp DESC';\n \n // Add limit if specified\n if (filters.limit) {\n query += ' LIMIT ?';\n queryParams.push(filters.limit);\n }\n \n const results = db.prepare(query).all(...queryParams);\n \n db.close();\n \n return results;\n}\n\n/**\n * Update link category\n * @param {number} linkId - ID of the link to update\n * @param {string} category - New category\n */\nexport function updateLinkCategory(linkId, category) {\n const db = initializeDatabase();\n \n db.prepare('UPDATE links SET category = ? WHERE id = ?').run(category, linkId);\n \n db.close();\n}\n\n/**\n * Get all available categories\n * @returns {Array} - Array of category objects\n */\nexport function getCategories() {\n const db = initializeDatabase();\n \n const categories = db.prepare('SELECT * FROM categories ORDER BY name').all();\n \n db.close();\n \n return categories;\n}\n\n/**\n * Add a new category\n * @param {string} name - Name of the new category\n */\nexport function addCategory(name) {\n const db = initializeDatabase();\n \n db.prepare('INSERT OR IGNORE INTO categories (name, created_at) VALUES (?, ?)').run(name, Date.now());\n \n db.close();\n}",[],[348],{"_103":356,"_95":357,"_153":358,"_155":-5,"_156":138,"_157":359,"_159":116,"_105":360,"_99":32,"_161":279,"_163":361,"_164":22,"_165":-5,"_166":362,"_98":363},"7cf563b0-2710-11f0-9860-569c3dd06744","deno.json","7cf56482-2710-11f0-9860-569c3dd06744",26,["D",1746161221677],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}",[],[357],{"_103":365,"_95":366,"_153":367,"_155":-5,"_156":138,"_157":368,"_159":116,"_105":369,"_99":32,"_161":181,"_163":370,"_164":22,"_165":-5,"_166":371,"_98":372},"7cac8bae-2710-11f0-99f2-569c3dd06744","discord-commands.js","7cac8c62-2710-11f0-99f2-569c3dd06744",6,["D",1746161221307],"import { REST, Routes, SlashCommandBuilder } from 'discord.js';\nimport 'dotenv/config';\n\nconst commands = [\n new SlashCommandBuilder()\n .setName('search')\n .setDescription('Search your conversation history')\n .addStringOption(option => \n option.setName('query')\n .setDescription('What would you like to search for?')\n .setRequired(true)),\n \n new SlashCommandBuilder()\n .setName('links')\n .setDescription('Find links shared in your conversations')\n .addStringOption(option => \n option.setName('category')\n .setDescription('Category of links to show (e.g., sofa, table)')\n .setRequired(false)),\n \n new SlashCommandBuilder()\n .setName('categories')\n .setDescription('List all available link categories'),\n \n new SlashCommandBuilder()\n .setName('analyze')\n .setDescription('Analyze your conversation with AI')\n .addStringOption(option => \n option.setName('query')\n .setDescription('What would you like to know about your conversations?')\n .setRequired(true)),\n];\n\nconst rest = new REST({ version: '10' }).setToken(process.env.DISCORD_TOKEN);\n\n/**\n * Register slash commands with Discord\n */\nexport async function registerCommands() {\n try {\n console.log('Registering slash commands...');\n \n await rest.put(\n Routes.applicationCommands(process.env.DISCORD_CLIENT_ID),\n { body: commands }\n );\n \n console.log('Successfully registered application commands.');\n } catch (error) {\n console.error('Error registering commands:', error);\n }\n}\n\n// If this script is being run directly, register commands\nif (process.argv[1] === new URL(import.meta.url).pathname) {\n registerCommands()\n .then(() => process.exit(0))\n .catch(error => {\n console.error('Error:', error);\n process.exit(1);\n });\n}",[],[366],{"_103":374,"_95":375,"_153":376,"_155":-5,"_156":138,"_157":377,"_159":116,"_105":378,"_99":32,"_161":181,"_163":379,"_164":22,"_165":-5,"_166":380,"_98":381},"7cee2d0c-2710-11f0-8393-569c3dd06744","index.js","7cee2dde-2710-11f0-8393-569c3dd06744",24,["D",1746161221674],"import { initializeDatabase } from './database.js';\nimport { fetchAndStoreDMs } from './discord-client.js';\nimport { batchProcessLinks } from './link-analyzer.js';\nimport express from 'express';\nimport { processQuery } from './query-service.js';\nimport 'dotenv/config';\n\n// Initialize Express app\nconst app = express();\napp.use(express.json());\n\n// Initialize database\ninitializeDatabase();\n\n// API routes\n\n// Health check endpoint\napp.get('/health', (req, res) => {\n res.json({ status: 'ok' });\n});\n\n// Manual trigger for fetching DMs\napp.post('/api/fetch-dms', async (req, res) => {\n try {\n console.log('Manually triggering DM fetch...');\n await fetchAndStoreDMs();\n res.json({ success: true, message: 'DM fetch completed successfully' });\n } catch (error) {\n console.error('Error fetching DMs:', error);\n res.status(500).json({ success: false, error: error.message });\n }\n});\n\n// Manual trigger for processing links\napp.post('/api/process-links', async (req, res) => {\n try {\n console.log('Manually triggering link processing...');\n const result = await batchProcessLinks();\n res.json(result);\n } catch (error) {\n console.error('Error processing links:', error);\n res.status(500).json({ success: false, error: error.message });\n }\n});\n\n// Query endpoint\napp.post('/api/query', async (req, res) => {\n try {\n const { query, filters } = req.body;\n \n if (!query) {\n return res.status(400).json({ success: false, error: 'Missing query' });\n }\n \n const result = await processQuery(query, filters);\n res.json({ success: true, data: result });\n } catch (error) {\n console.error('Error processing query:', error);\n res.status(500).json({ success: false, error: error.message });\n }\n});\n\n// Discord command endpoints\napp.post('/api/commands/search', async (req, res) => {\n try {\n const { query } = req.body;\n \n if (!query) {\n return res.status(400).json({ success: false, error: 'Missing query' });\n }\n \n // Process query with focus on recent messages\n const result = await processQuery(query, { limit: 100 });\n \n // Format response for Discord\n let response;\n \n switch (result.type) {\n case 'links':\n response = `Found ${result.links.length} links related to \"${query}\":\\n` +\n result.links.slice(0, 5).map(link => `- ${link.url}`).join('\\n');\n break;\n \n case 'furniture':\n response = `Furniture Analysis: ${result.analysis}\\n\\n` +\n `Preferences: ${result.preferences.join(', ')}\\n\\n` +\n `Relevant Links: ${result.relevantLinks.slice(0, 3).map(link => link.url).join(', ')}`;\n break;\n \n case 'summary':\n response = `Summary: ${result.summary}\\n\\n` +\n `Key Points: ${result.keyPoints.join(', ')}`;\n break;\n \n default:\n response = result.answer || 'No specific answer found for your query.';\n }\n \n res.json({ success: true, response });\n } catch (error) {\n console.error('Error processing Discord command:', error);\n res.status(500).json({ \n success: false, \n response: 'Sorry, I encountered an error processing your request.' \n });\n }\n});\n\n// Start the server\nconst PORT = process.env.PORT || 3000;\n\n// Only start the server if running locally (not on Val.town)\nif (process.argv[1] === new URL(import.meta.url).pathname) {\n app.listen(PORT, () => {\n console.log(`Server running on port ${PORT}`);\n });\n}\n\n// Export for Val.town\nexport default async function handler(req, res) {\n // Route the request through the Express app\n return new Promise((resolve, reject) => {\n app(req, res, (err) => {\n if (err) {\n return reject(err);\n }\n resolve();\n });\n });\n}\n\n// If this script is being run directly, run initial setup\nif (process.argv[1] === new URL(import.meta.url).pathname) {\n console.log('Initializing Discord DM Analyzer...');\n \n // Initialize database\n const db = initializeDatabase();\n console.log('Database initialized');\n \n // Additional setup if needed\n}",[],[375],{"_103":383,"_95":384,"_153":385,"_155":-5,"_156":138,"_157":386,"_159":116,"_105":387,"_99":32,"_161":181,"_163":388,"_164":22,"_165":-5,"_166":389,"_98":390},"7ce25d9c-2710-11f0-bc07-569c3dd06744","link-analyzer.js","7ce25e5a-2710-11f0-bc07-569c3dd06744",21,["D",1746161221606],"import linkify from 'linkify-it';\nimport { getMessages, updateLinkCategory } from './database.js';\nimport { categorizeContent } from './anthropic-service.js';\nimport 'dotenv/config';\n\n// Initialize link parser\nconst linkParser = linkify();\n\n/**\n * Extract and process links from messages\n * @param {Array} messages - Array of message objects\n * @returns {Array} - Array of processed link objects\n */\nexport function extractLinks(messages) {\n const extractedLinks = [];\n \n for (const message of messages) {\n if (!message.content) continue;\n \n const links = linkParser.match(message.content);\n if (!links) continue;\n \n for (const link of links) {\n extractedLinks.push({\n url: link.url,\n messageId: message.id,\n authorId: message.authorId,\n timestamp: message.timestamp,\n messageContent: message.content\n });\n }\n }\n \n return extractedLinks;\n}\n\n/**\n * Categorize a link using AI\n * @param {Object} link - Link object to categorize\n * @returns {Object} - Categorization result\n */\nexport async function categorizeLink(link) {\n try {\n // For furniture-specific project, check for furniture-related terms\n const furnitureTerms = [\n 'sofa', 'couch', 'chair', 'table', 'bed', 'dresser', 'nightstand',\n 'desk', 'shelf', 'bookcase', 'cabinet', 'wardrobe', 'ottoman',\n 'bench', 'stool', 'lamp', 'lighting', 'decor', 'furniture'\n ];\n \n // Check if URL or message context contains furniture terms\n const urlLower = link.url.toLowerCase();\n const messageLower = link.messageContent ? link.messageContent.toLowerCase() : '';\n \n let isFurnitureRelated = false;\n let detectedTerms = [];\n \n for (const term of furnitureTerms) {\n if (urlLower.includes(term) || messageLower.includes(term)) {\n isFurnitureRelated = true;\n detectedTerms.push(term);\n }\n }\n \n if (isFurnitureRelated) {\n // Use Anthropic to determine specific furniture category\n const validCategories = [\n 'sofa', 'chair', 'table', 'bed', 'dresser', 'desk', \n 'lamp', 'shelf', 'bookcase', 'rug', 'curtain', 'other'\n ];\n \n const contentToAnalyze = `\nURL: ${link.url}\nMessage context: ${link.messageContent}\nDetected furniture terms: ${detectedTerms.join(', ')}\n `;\n \n const category = await categorizeContent(contentToAnalyze, validCategories);\n \n // Validate returned category\n if (validCategories.includes(category)) {\n return {\n category,\n confidence: 'high',\n isValidCategory: true\n };\n } else {\n return {\n category: 'other',\n confidence: 'low',\n isValidCategory: false,\n suggestedCategory: category\n };\n }\n } else {\n // Not furniture-related\n return {\n category: 'other',\n confidence: 'high',\n isValidCategory: true\n };\n }\n } catch (error) {\n console.error('Error categorizing link:', error);\n return {\n category: 'other',\n confidence: 'low',\n isValidCategory: true,\n error: error.message\n };\n }\n}\n\n/**\n * Extract metadata for a link (title, description)\n * @param {string} url - URL to extract metadata for\n * @returns {Object} - Metadata object\n */\nexport async function extractLinkMetadata(url) {\n try {\n // In a production system, you'd want to actually fetch the page content\n // For simplicity, we'll make an educated guess based on the URL\n \n // Parse the URL\n const urlObj = new URL(url);\n const hostname = urlObj.hostname;\n const pathname = urlObj.pathname;\n \n // Extract potential title from pathname\n let title = '';\n if (pathname && pathname !== '/') {\n // Remove extensions and convert to title case\n const parts = pathname.split('/').filter(p => p && !p.startsWith('?'));\n if (parts.length > 0) {\n // Get the last part of the path, which often contains the title\n const lastPart = parts[parts.length - 1]\n .replace(/\\.html|\\.php|\\.asp|\\.aspx|\\.jsp/gi, '')\n .replace(/-|_/g, ' ');\n \n // Convert to title case\n title = lastPart\n .split(' ')\n .map(word => word.charAt(0).toUpperCase() + word.slice(1).toLowerCase())\n .join(' ');\n }\n }\n \n // If we couldn't extract a title, use the domain name\n if (!title) {\n // Remove www. and .com, .org, etc.\n title = hostname\n .replace(/^www\\./i, '')\n .replace(/\\.(com|org|net|io|gov|edu|co|uk|us|ca|au|de|fr|jp|cn|ru|br|in)$/i, '')\n .split('.')\n .map(part => part.charAt(0).toUpperCase() + part.slice(1))\n .join(' ');\n }\n \n // Create a simple description\n const description = `Content from ${hostname}${pathname}`;\n \n return {\n title: title || hostname,\n description: description\n };\n } catch (error) {\n console.error('Error extracting link metadata:', error);\n return {\n title: new URL(url).hostname,\n description: 'No description available'\n };\n }\n}\n\n/**\n * Batch process all links in the database\n * - Categorizes uncategorized links\n * - Updates link metadata\n */\nexport async function batchProcessLinks() {\n try {\n // Get messages with links that haven't been processed\n const messages = getMessages({ limit: 100 });\n \n // Extract links\n const links = extractLinks(messages);\n \n // Process each link\n for (const link of links) {\n // Categorize the link\n const categorization = await categorizeLink(link);\n \n // Extract metadata\n const metadata = await extractLinkMetadata(link.url);\n \n // Update link in database\n updateLinkCategory(link.id, categorization.category);\n \n console.log(`Processed link: ${link.url}`);\n console.log(`Category: ${categorization.category}`);\n console.log(`Title: ${metadata.title}`);\n }\n \n return {\n success: true,\n processed: links.length\n };\n } catch (error) {\n console.error('Error in batch processing links:', error);\n return {\n success: false,\n error: error.message\n };\n }\n}",[],[384],{"_103":392,"_95":393,"_153":394,"_155":-5,"_156":138,"_157":100,"_159":116,"_105":395,"_99":32,"_161":279,"_163":396,"_164":22,"_165":-5,"_166":397,"_98":398},"7cffec04-2710-11f0-b468-569c3dd06744","package.json","7cffecb8-2710-11f0-b468-569c3dd06744",["D",1746161221782],"{\n \"name\": \"discord-dm-analyzer\",\n \"version\": \"1.0.0\",\n \"description\": \"Discord bot that analyzes DMs between two users and provides query functionality\",\n \"main\": \"index.js\",\n \"type\": \"module\",\n \"scripts\": {\n \"start\": \"node index.js\",\n \"dev\": \"node index.js\",\n \"fetch\": \"node val-town-cron.js\",\n \"register\": \"node discord-commands.js\",\n \"interactions\": \"node interactions-endpoint.js\",\n \"deploy\": \"node val-town-deploy.js\",\n \"test\": \"echo \\\"Error: no test specified\\\" && exit 1\"\n },\n \"keywords\": [\n \"discord\",\n \"bot\",\n \"dm\",\n \"analyzer\",\n \"valtown\"\n ],\n \"author\": \"\",\n \"license\": \"MIT\",\n \"dependencies\": {\n \"discord.js\": \"^14.14.1\",\n \"discord-interactions\": \"^3.4.0\",\n \"better-sqlite3\": \"^9.2.2\",\n \"@anthropic-ai/sdk\": \"^0.16.1\",\n \"express\": \"^4.18.2\",\n \"linkify-it\": \"^4.0.1\",\n \"node-cron\": \"^3.0.3\",\n \"dotenv\": \"^16.3.1\"\n }\n}",[],[393],{"_103":400,"_95":401,"_153":402,"_155":-5,"_156":138,"_157":403,"_159":116,"_105":404,"_99":32,"_161":181,"_163":405,"_164":22,"_165":-5,"_166":406,"_98":407},"7cc17974-2710-11f0-9860-569c3dd06744","val-town-deploy.js","7cc17a28-2710-11f0-9860-569c3dd06744",12,["D",1746161221385],"/**\n * Script to deploy functions to Val.town\n * \n * Usage: \n * node val-town-deploy.js\n * \n * Requirements:\n * - You must have the Val.town CLI installed and authenticated\n * - You must have the necessary permissions to deploy to Val.town\n */\n\nimport { exec } from 'child_process';\nimport { readFileSync } from 'fs';\nimport { promisify } from 'util';\nimport 'dotenv/config';\n\nconst execAsync = promisify(exec);\n\n// Main functions to deploy\nconst deployTargets = [\n {\n file: 'val-town-cron.js',\n name: 'discordDMBotCron',\n isPublic: false,\n description: 'Cron job to fetch Discord DMs periodically'\n },\n {\n file: 'api-server.js',\n name: 'discordDMBotAPI',\n isPublic: true, \n description: 'HTTP API for Discord DM bot'\n }\n];\n\nasync function deployToValTown() {\n console.log('Starting deployment to Val.town...');\n \n for (const target of deployTargets) {\n try {\n console.log(`Deploying ${target.file} as ${target.name}...`);\n \n // Read the file content\n const fileContent = readFileSync(target.file, 'utf-8');\n \n // Create a temporary file with the Val.town metadata\n const tempFileName = `${target.file}.temp.js`;\n \n // Run vt deploy command\n const publicFlag = target.isPublic ? '--public' : '--private';\n const { stdout, stderr } = await execAsync(\n `vt deploy ${target.file} --name ${target.name} ${publicFlag} --description \"${target.description}\"`\n );\n \n if (stderr) {\n console.error(`Error deploying ${target.name}:`, stderr);\n } else {\n console.log(`Successfully deployed ${target.name}:`, stdout);\n }\n } catch (error) {\n console.error(`Failed to deploy ${target.name}:`, error);\n }\n }\n \n console.log('Deployment completed!');\n}\n\n// Run the deployment if this script is executed directly\nif (process.argv[1] === new URL(import.meta.url).pathname) {\n deployToValTown()\n .then(() => process.exit(0))\n .catch(error => {\n console.error('Deployment failed:', error);\n process.exit(1);\n });\n}",[],[401],"files",[150,168,175,185,194,203,212,221,230,239,249,256,263,273,283,293,300,309,319,329,338,346,355,364,373,382,391,399],"counts",{"_412":32,"_413":158,"_414":32,"_415":416},"pulls","branches","forks","envVars",{"_417":350,"_418":32},"count","emptyCount","contents",[421,424,427,430,433,436,439,442,445,448],{"_103":151,"_95":152,"_153":154,"_155":-5,"_156":138,"_157":158,"_159":116,"_105":422,"_99":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_98":423},["D",1746161220600],[152],{"_103":330,"_95":331,"_153":332,"_155":-5,"_156":138,"_157":333,"_159":116,"_105":425,"_99":32,"_161":279,"_163":335,"_164":22,"_165":-5,"_98":426},["D",1746161221312],[331],{"_103":339,"_95":321,"_153":340,"_155":-5,"_156":138,"_157":341,"_159":116,"_105":428,"_99":32,"_161":279,"_163":343,"_164":22,"_165":-5,"_98":429},["D",1746161221708],[321],{"_103":347,"_95":348,"_153":349,"_155":-5,"_156":138,"_157":350,"_159":116,"_105":431,"_99":32,"_161":181,"_163":352,"_164":22,"_165":-5,"_98":432},["D",1746161221310],[348],{"_103":356,"_95":357,"_153":358,"_155":-5,"_156":138,"_157":359,"_159":116,"_105":434,"_99":32,"_161":279,"_163":361,"_164":22,"_165":-5,"_98":435},["D",1746161221677],[357],{"_103":365,"_95":366,"_153":367,"_155":-5,"_156":138,"_157":368,"_159":116,"_105":437,"_99":32,"_161":181,"_163":370,"_164":22,"_165":-5,"_98":438},["D",1746161221307],[366],{"_103":374,"_95":375,"_153":376,"_155":-5,"_156":138,"_157":377,"_159":116,"_105":440,"_99":32,"_161":181,"_163":379,"_164":22,"_165":-5,"_98":441},["D",1746161221674],[375],{"_103":383,"_95":384,"_153":385,"_155":-5,"_156":138,"_157":386,"_159":116,"_105":443,"_99":32,"_161":181,"_163":388,"_164":22,"_165":-5,"_98":444},["D",1746161221606],[384],{"_103":392,"_95":393,"_153":394,"_155":-5,"_156":138,"_157":100,"_159":116,"_105":446,"_99":32,"_161":279,"_163":396,"_164":22,"_165":-5,"_98":447},["D",1746161221782],[393],{"_103":400,"_95":401,"_153":402,"_155":-5,"_156":138,"_157":403,"_159":116,"_105":449,"_99":32,"_161":181,"_163":405,"_164":22,"_165":-5,"_98":450},["D",1746161221385],[401],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_101":459,"_99":100,"_464":465},{"_103":104,"_95":96,"_105":460,"_107":-5,"_108":22,"_109":110,"_111":72,"_112":-5,"_14":113,"_114":-5,"_115":116,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":461,"_132":462,"_135":463,"_147":22},["D",1746146349872],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_99":137,"_95":43,"_103":138,"_139":104,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},"changes",[466],{"_279":467,"_469":-7,"_98":393},{"_153":394,"_95":393,"_161":279,"_163":396,"_105":468,"_157":100,"_156":138},["D",1746161221782],"previous","actionData","errors"]

boucher

discord-bot