[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_346":347,"_348":349},"routes/_app.x.$handle.$name",{"_98":97,"_32":46,"_106":88,"_27":54,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":60,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",31,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","backend/database.ts","latestPath","fileId","e8fa4766-2859-11f0-96d8-569c3dd06744","name","database.ts","fileType","script","content","// Database operations for the Discord bot\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// Types\nexport interface Message {\n id: string;\n channel_id: string;\n user_id: string;\n content: string;\n timestamp: number;\n has_links: boolean;\n is_command: boolean;\n}\n\nexport interface Link {\n id?: number;\n message_id: string;\n url: string;\n domain: string;\n timestamp: number;\n category?: string;\n}\n\nexport interface Project {\n id?: number;\n name: string;\n description?: string;\n created_at: number;\n is_active: boolean;\n}\n\nexport interface Topic {\n id?: number;\n name: string;\n description?: string;\n created_at: number;\n}\n\n// URL regex pattern for link extraction\nconst URL_REGEX = /(https?:\\/\\/[^\\s]+)/g;\nconst DOMAIN_REGEX = /^(?:https?:\\/\\/)?(?:[^@\\n]+@)?(?:www\\.)?([^:/\\n?]+)/i;\n\n// Message operations\nexport async function saveMessage(message: Message): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO messages (id, channel_id, user_id, content, timestamp, has_links, is_command)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n content = excluded.content,\n has_links = excluded.has_links,\n is_command = excluded.is_command`,\n [\n message.id,\n message.channel_id,\n message.user_id,\n message.content,\n message.timestamp,\n message.has_links ? 1 : 0,\n message.is_command ? 1 : 0\n ]\n );\n return true;\n } catch (error) {\n console.error(\"Error saving message:\", error);\n return false;\n }\n}\n\nexport async function getMessage(messageId: string): Promise {\n try {\n const result = await sqlite.execute(\n \"SELECT * FROM messages WHERE id = ?\",\n [messageId]\n );\n \n if (result.rows.length === 0) {\n return null;\n }\n \n const row = result.rows[0];\n return {\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n };\n } catch (error) {\n console.error(\"Error getting message:\", error);\n return null;\n }\n}\n\nexport async function getMessagesByUserIds(userIds: string[], limit = 1000, offset = 0): Promise {\n try {\n // Create placeholders for the SQL IN clause\n const placeholders = userIds.map(() => '?').join(',');\n \n const result = await sqlite.execute(\n `SELECT * FROM messages\n WHERE user_id IN (${placeholders})\n ORDER BY timestamp DESC\n LIMIT ? OFFSET ?`,\n [...userIds, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting messages by user ids:\", error);\n return [];\n }\n}\n\nexport async function searchMessages(query: string, limit = 100): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM messages\n WHERE content LIKE ?\n ORDER BY timestamp DESC\n LIMIT ?`,\n [`%${query}%`, limit]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error searching messages:\", error);\n return [];\n }\n}\n\n// Link operations\nexport function extractLinks(content: string): { urls: string[], domains: string[] } {\n const urls: string[] = [];\n const domains: string[] = [];\n \n const matches = content.match(URL_REGEX);\n \n if (matches) {\n matches.forEach(url => {\n urls.push(url);\n \n const domainMatch = url.match(DOMAIN_REGEX);\n if (domainMatch && domainMatch[1]) {\n domains.push(domainMatch[1]);\n }\n });\n }\n \n return { urls, domains };\n}\n\nexport async function saveLink(link: Link): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO links (message_id, url, domain, timestamp, category)\n VALUES (?, ?, ?, ?, ?)\n RETURNING id`,\n [\n link.message_id,\n link.url,\n link.domain,\n link.timestamp,\n link.category || null\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error saving link:\", error);\n return null;\n }\n}\n\nexport async function getLinks(limit = 50, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM links\n ORDER BY timestamp DESC\n LIMIT ? OFFSET ?`,\n [limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n message_id: row.message_id,\n url: row.url,\n domain: row.domain,\n timestamp: row.timestamp,\n category: row.category\n }));\n } catch (error) {\n console.error(\"Error getting links:\", error);\n return [];\n }\n}\n\nexport async function searchLinks(query: string, limit = 50): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM links\n WHERE url LIKE ? OR domain LIKE ? OR category LIKE ?\n ORDER BY timestamp DESC\n LIMIT ?`,\n [`%${query}%`, `%${query}%`, `%${query}%`, limit]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n message_id: row.message_id,\n url: row.url,\n domain: row.domain,\n timestamp: row.timestamp,\n category: row.category\n }));\n } catch (error) {\n console.error(\"Error searching links:\", error);\n return [];\n }\n}\n\nexport async function updateLinkCategory(linkId: number, category: string): Promise {\n try {\n await sqlite.execute(\n `UPDATE links\n SET category = ?\n WHERE id = ?`,\n [category, linkId]\n );\n return true;\n } catch (error) {\n console.error(\"Error updating link category:\", error);\n return false;\n }\n}\n\n// Project operations\nexport async function createProject(project: Project): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO projects (name, description, created_at, is_active)\n VALUES (?, ?, ?, ?)\n RETURNING id`,\n [\n project.name,\n project.description || null,\n project.created_at,\n project.is_active ? 1 : 0\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error creating project:\", error);\n return null;\n }\n}\n\nexport async function getProjects(includeInactive = false): Promise {\n try {\n let query = `SELECT * FROM projects`;\n const params = [];\n \n if (!includeInactive) {\n query += ` WHERE is_active = 1`;\n }\n \n query += ` ORDER BY created_at DESC`;\n \n const result = await sqlite.execute(query, params);\n \n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at,\n is_active: Boolean(row.is_active)\n }));\n } catch (error) {\n console.error(\"Error getting projects:\", error);\n return [];\n }\n}\n\nexport async function getProject(projectId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM projects WHERE id = ?`,\n [projectId]\n );\n \n if (result.rows.length === 0) {\n return null;\n }\n \n const row = result.rows[0];\n return {\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at,\n is_active: Boolean(row.is_active)\n };\n } catch (error) {\n console.error(\"Error getting project:\", error);\n return null;\n }\n}\n\nexport async function addMessageToProject(projectId: number, messageId: string): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO project_messages (project_id, message_id)\n VALUES (?, ?)\n ON CONFLICT DO NOTHING`,\n [projectId, messageId]\n );\n return true;\n } catch (error) {\n console.error(\"Error adding message to project:\", error);\n return false;\n }\n}\n\nexport async function getProjectMessages(projectId: number, limit = 100, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT m.*\n FROM messages m\n JOIN project_messages pm ON m.id = pm.message_id\n WHERE pm.project_id = ?\n ORDER BY m.timestamp DESC\n LIMIT ? OFFSET ?`,\n [projectId, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting project messages:\", error);\n return [];\n }\n}\n\n// Topic operations\nexport async function createTopic(topic: Topic): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO topics (name, description, created_at)\n VALUES (?, ?, ?)\n RETURNING id`,\n [\n topic.name,\n topic.description || null,\n topic.created_at\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error creating topic:\", error);\n return null;\n }\n}\n\nexport async function getTopics(): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM topics ORDER BY name ASC`\n );\n \n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at\n }));\n } catch (error) {\n console.error(\"Error getting topics:\", error);\n return [];\n }\n}\n\nexport async function addMessageToTopic(topicId: number, messageId: string): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO topic_messages (topic_id, message_id)\n VALUES (?, ?)\n ON CONFLICT DO NOTHING`,\n [topicId, messageId]\n );\n return true;\n } catch (error) {\n console.error(\"Error adding message to topic:\", error);\n return false;\n }\n}\n\nexport async function getTopicMessages(topicId: number, limit = 100, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT m.*\n FROM messages m\n JOIN topic_messages tm ON m.id = tm.message_id\n WHERE tm.topic_id = ?\n ORDER BY m.timestamp DESC\n LIMIT ? OFFSET ?`,\n [topicId, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting topic messages:\", error);\n return [];\n }\n}","// Database operations for the Discord bot\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// Database initialization function - call this when the application starts\nexport async function initDatabase() {\n try {\n // Messages table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS messages (\n id TEXT PRIMARY KEY,\n channel_id TEXT NOT NULL,\n user_id TEXT NOT NULL,\n content TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n has_links BOOLEAN DEFAULT FALSE,\n is_command BOOLEAN DEFAULT FALSE\n )\n `);\n \n // Links table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS links (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message_id TEXT NOT NULL,\n url TEXT NOT NULL,\n domain TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n category TEXT,\n FOREIGN KEY(message_id) REFERENCES messages(id)\n )\n `);\n \n // Projects table (for explicit grouping)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS projects (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n description TEXT,\n created_at INTEGER NOT NULL,\n is_active BOOLEAN DEFAULT TRUE\n )\n `);\n \n // Project messages mapping\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS project_messages (\n project_id INTEGER NOT NULL,\n message_id TEXT NOT NULL,\n PRIMARY KEY(project_id, message_id),\n FOREIGN KEY(project_id) REFERENCES projects(id),\n FOREIGN KEY(message_id) REFERENCES messages(id)\n )\n `);\n \n // Topics table (for AI-categorized grouping)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS topics (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n description TEXT,\n created_at INTEGER NOT NULL\n )\n `);\n \n // Topic messages mapping\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS topic_messages (\n topic_id INTEGER NOT NULL,\n message_id TEXT NOT NULL,\n PRIMARY KEY(topic_id, message_id),\n FOREIGN KEY(topic_id) REFERENCES topics(id),\n FOREIGN KEY(message_id) REFERENCES messages(id)\n )\n `);\n \n console.log(\"Database initialized successfully\");\n return true;\n } catch (error) {\n console.error(\"Database initialization error:\", error);\n return false;\n }\n}\n\n// Types\nexport interface Message {\n id: string;\n channel_id: string;\n user_id: string;\n content: string;\n timestamp: number;\n has_links: boolean;\n is_command: boolean;\n}\n\nexport interface Link {\n id?: number;\n message_id: string;\n url: string;\n domain: string;\n timestamp: number;\n category?: string;\n}\n\nexport interface Project {\n id?: number;\n name: string;\n description?: string;\n created_at: number;\n is_active: boolean;\n}\n\nexport interface Topic {\n id?: number;\n name: string;\n description?: string;\n created_at: number;\n}\n\n// URL regex pattern for link extraction\nconst URL_REGEX = /(https?:\\/\\/[^\\s]+)/g;\nconst DOMAIN_REGEX = /^(?:https?:\\/\\/)?(?:[^@\\n]+@)?(?:www\\.)?([^:/\\n?]+)/i;\n\n// Message operations\nexport async function saveMessage(message: Message): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO messages (id, channel_id, user_id, content, timestamp, has_links, is_command)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET\n content = excluded.content,\n has_links = excluded.has_links,\n is_command = excluded.is_command`,\n [\n message.id,\n message.channel_id,\n message.user_id,\n message.content,\n message.timestamp,\n message.has_links ? 1 : 0,\n message.is_command ? 1 : 0\n ]\n );\n return true;\n } catch (error) {\n console.error(\"Error saving message:\", error);\n return false;\n }\n}\n\nexport async function getMessage(messageId: string): Promise {\n try {\n const result = await sqlite.execute(\n \"SELECT * FROM messages WHERE id = ?\",\n [messageId]\n );\n \n if (result.rows.length === 0) {\n return null;\n }\n \n const row = result.rows[0];\n return {\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n };\n } catch (error) {\n console.error(\"Error getting message:\", error);\n return null;\n }\n}\n\nexport async function getMessagesByUserIds(userIds: string[], limit = 1000, offset = 0): Promise {\n try {\n // Create placeholders for the SQL IN clause\n const placeholders = userIds.map(() => '?').join(',');\n \n const result = await sqlite.execute(\n `SELECT * FROM messages\n WHERE user_id IN (${placeholders})\n ORDER BY timestamp DESC\n LIMIT ? OFFSET ?`,\n [...userIds, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting messages by user ids:\", error);\n return [];\n }\n}\n\nexport async function searchMessages(query: string, limit = 100): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM messages\n WHERE content LIKE ?\n ORDER BY timestamp DESC\n LIMIT ?`,\n [`%${query}%`, limit]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error searching messages:\", error);\n return [];\n }\n}\n\n// Link operations\nexport function extractLinks(content: string): { urls: string[], domains: string[] } {\n const urls: string[] = [];\n const domains: string[] = [];\n \n const matches = content.match(URL_REGEX);\n \n if (matches) {\n matches.forEach(url => {\n urls.push(url);\n \n const domainMatch = url.match(DOMAIN_REGEX);\n if (domainMatch && domainMatch[1]) {\n domains.push(domainMatch[1]);\n }\n });\n }\n \n return { urls, domains };\n}\n\nexport async function saveLink(link: Link): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO links (message_id, url, domain, timestamp, category)\n VALUES (?, ?, ?, ?, ?)\n RETURNING id`,\n [\n link.message_id,\n link.url,\n link.domain,\n link.timestamp,\n link.category || null\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error saving link:\", error);\n return null;\n }\n}\n\nexport async function getLinks(limit = 50, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM links\n ORDER BY timestamp DESC\n LIMIT ? OFFSET ?`,\n [limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n message_id: row.message_id,\n url: row.url,\n domain: row.domain,\n timestamp: row.timestamp,\n category: row.category\n }));\n } catch (error) {\n console.error(\"Error getting links:\", error);\n return [];\n }\n}\n\nexport async function searchLinks(query: string, limit = 50): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM links\n WHERE url LIKE ? OR domain LIKE ? OR category LIKE ?\n ORDER BY timestamp DESC\n LIMIT ?`,\n [`%${query}%`, `%${query}%`, `%${query}%`, limit]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n message_id: row.message_id,\n url: row.url,\n domain: row.domain,\n timestamp: row.timestamp,\n category: row.category\n }));\n } catch (error) {\n console.error(\"Error searching links:\", error);\n return [];\n }\n}\n\nexport async function updateLinkCategory(linkId: number, category: string): Promise {\n try {\n await sqlite.execute(\n `UPDATE links\n SET category = ?\n WHERE id = ?`,\n [category, linkId]\n );\n return true;\n } catch (error) {\n console.error(\"Error updating link category:\", error);\n return false;\n }\n}\n\n// Project operations\nexport async function createProject(project: Project): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO projects (name, description, created_at, is_active)\n VALUES (?, ?, ?, ?)\n RETURNING id`,\n [\n project.name,\n project.description || null,\n project.created_at,\n project.is_active ? 1 : 0\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error creating project:\", error);\n return null;\n }\n}\n\nexport async function getProjects(includeInactive = false): Promise {\n try {\n let query = `SELECT * FROM projects`;\n const params = [];\n \n if (!includeInactive) {\n query += ` WHERE is_active = 1`;\n }\n \n query += ` ORDER BY created_at DESC`;\n \n const result = await sqlite.execute(query, params);\n \n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at,\n is_active: Boolean(row.is_active)\n }));\n } catch (error) {\n console.error(\"Error getting projects:\", error);\n return [];\n }\n}\n\nexport async function getProject(projectId: number): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM projects WHERE id = ?`,\n [projectId]\n );\n \n if (result.rows.length === 0) {\n return null;\n }\n \n const row = result.rows[0];\n return {\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at,\n is_active: Boolean(row.is_active)\n };\n } catch (error) {\n console.error(\"Error getting project:\", error);\n return null;\n }\n}\n\nexport async function addMessageToProject(projectId: number, messageId: string): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO project_messages (project_id, message_id)\n VALUES (?, ?)\n ON CONFLICT DO NOTHING`,\n [projectId, messageId]\n );\n return true;\n } catch (error) {\n console.error(\"Error adding message to project:\", error);\n return false;\n }\n}\n\nexport async function getProjectMessages(projectId: number, limit = 100, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT m.*\n FROM messages m\n JOIN project_messages pm ON m.id = pm.message_id\n WHERE pm.project_id = ?\n ORDER BY m.timestamp DESC\n LIMIT ? OFFSET ?`,\n [projectId, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting project messages:\", error);\n return [];\n }\n}\n\n// Topic operations\nexport async function createTopic(topic: Topic): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO topics (name, description, created_at)\n VALUES (?, ?, ?)\n RETURNING id`,\n [\n topic.name,\n topic.description || null,\n topic.created_at\n ]\n );\n \n if (result.rows.length > 0) {\n return result.rows[0].id;\n }\n return null;\n } catch (error) {\n console.error(\"Error creating topic:\", error);\n return null;\n }\n}\n\nexport async function getTopics(): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT * FROM topics ORDER BY name ASC`\n );\n \n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n created_at: row.created_at\n }));\n } catch (error) {\n console.error(\"Error getting topics:\", error);\n return [];\n }\n}\n\nexport async function addMessageToTopic(topicId: number, messageId: string): Promise {\n try {\n await sqlite.execute(\n `INSERT INTO topic_messages (topic_id, message_id)\n VALUES (?, ?)\n ON CONFLICT DO NOTHING`,\n [topicId, messageId]\n );\n return true;\n } catch (error) {\n console.error(\"Error adding message to topic:\", error);\n return false;\n }\n}\n\nexport async function getTopicMessages(topicId: number, limit = 100, offset = 0): Promise {\n try {\n const result = await sqlite.execute(\n `SELECT m.*\n FROM messages m\n JOIN topic_messages tm ON m.id = tm.message_id\n WHERE tm.topic_id = ?\n ORDER BY m.timestamp DESC\n LIMIT ? OFFSET ?`,\n [topicId, limit, offset]\n );\n \n return result.rows.map(row => ({\n id: row.id,\n channel_id: row.channel_id,\n user_id: row.user_id,\n content: row.content,\n timestamp: row.timestamp,\n has_links: Boolean(row.has_links),\n is_command: Boolean(row.is_command)\n }));\n } catch (error) {\n console.error(\"Error getting topic messages:\", error);\n return [];\n }\n}","createdAt",["D",1746323370671],"branchVersion","branchId","2e944ece-2711-11f0-a12e-569c3dd06744","id","2e9210fa-2711-11f0-a12e-569c3dd06744","vt-discord",["D",1746161519737],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","f48e9547-27bd-4117-9554-682f2eb67a4b","pinnedFileId","751ff414-2884-11f0-b137-569c3dd06744","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",2,"orgId","4f5bd3a8-17ca-44d2-b569-1c9fcdb094b9","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"isOwned",34,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","boucher","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXh1eU1FSEZMMTNaWFM1Rm5rYXBrd0pBRyIsImluaXRpYWxzIjoiUkIifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_44":45,"_32":46,"_39":342,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":343,"_82":344,"_84":345,"_86":25},"tree",[235,237,244,245,246,247,248,249,250,251,252,253],"files",[235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253],"counts",{"_224":153,"_225":210,"_226":153,"_227":228,"_229":230},"contents",[127,128,129,130,131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":219,"_32":220,"_30":221,"_142":-5,"_42":43,"_41":64,"_144":60,"_39":222,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_27":223},{"_44":213,"_32":214,"_30":215,"_142":-5,"_42":43,"_41":216,"_144":60,"_39":217,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_27":218},{"_44":207,"_32":208,"_30":209,"_142":-5,"_42":43,"_41":210,"_144":60,"_39":211,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_27":212},{"_44":200,"_32":201,"_30":202,"_142":-5,"_42":43,"_41":203,"_144":60,"_39":204,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_27":206},{"_44":193,"_32":194,"_30":195,"_142":-5,"_42":43,"_41":196,"_144":60,"_39":197,"_13":153,"_34":20,"_36":198,"_24":25,"_147":-5,"_27":199},{"_44":186,"_32":187,"_30":188,"_142":-5,"_42":43,"_41":189,"_144":60,"_39":190,"_13":153,"_34":20,"_36":191,"_24":25,"_147":-5,"_27":192},{"_44":179,"_32":180,"_30":181,"_142":-5,"_42":43,"_41":182,"_144":60,"_39":183,"_13":153,"_34":20,"_36":184,"_24":25,"_147":-5,"_27":185},{"_44":172,"_32":173,"_30":174,"_142":-5,"_42":43,"_41":175,"_144":60,"_39":176,"_13":153,"_34":20,"_36":177,"_24":25,"_147":-5,"_27":178},{"_44":164,"_32":165,"_30":166,"_142":-5,"_42":43,"_41":167,"_144":60,"_39":168,"_13":153,"_34":169,"_36":170,"_24":25,"_147":-5,"_27":171},{"_44":157,"_32":158,"_30":159,"_142":-5,"_42":43,"_41":160,"_144":60,"_39":161,"_13":153,"_34":20,"_36":162,"_24":25,"_147":-5,"_27":163},{"_44":149,"_32":150,"_30":58,"_142":-5,"_42":43,"_41":151,"_144":60,"_39":152,"_13":153,"_34":154,"_36":155,"_24":25,"_147":-5,"_27":156},{"_44":139,"_32":140,"_30":141,"_142":-5,"_42":43,"_41":143,"_144":60,"_39":145,"_13":64,"_34":35,"_36":146,"_24":25,"_147":-5,"_27":148},"cab1a68c-2886-11f0-a192-569c3dd06744","index.ts","e8f76ad2-2859-11f0-97af-569c3dd06744","parentId",27,"latest",["D",1746321983950],"// Main entry point for Val Town\nimport botHandler, { syncRecentMessages } from \"./backend/main.ts\";\n\n// HTTP handler for Discord interactions and webhooks\nexport default async function(req: Request) {\n // Special handling for Discord verification\n try {\n const bodyText = await req.text();\n let body;\n \n try {\n body = JSON.parse(bodyText);\n } catch (e) {\n // Not JSON, pass to regular handler\n const newReq = new Request(req.url, {\n method: req.method,\n headers: req.headers,\n body: bodyText\n });\n return botHandler(newReq);\n }\n \n // Check if this is a Discord ping\n if (body && body.type === 1) {\n console.log(\"Received Discord PING verification\");\n // Respond to Discord PING\n return new Response(JSON.stringify({ type: 1 }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n \n // For all other requests, pass to the regular handler\n const newReq = new Request(req.url, {\n method: req.method,\n headers: req.headers,\n body: JSON.stringify(body)\n });\n return botHandler(newReq);\n } catch (error) {\n console.error(\"Error in main handler:\", error);\n // If there's an error, still try the regular handler\n return botHandler(req);\n }\n}\n\n// Scheduled task to sync recent messages (runs hourly)\nexport async function hourlySync() {\n await syncRecentMessages();\n}","label",[140],"751ff324-2884-11f0-b137-569c3dd06744","httpHandler.ts",21,["D",1746320981424],0,"http","// Main entry point for Val Town\nimport botHandler from \"./backend/main.ts\";\n\n// HTTP handler for Discord interactions and webhooks\nexport default async function(req: Request) {\n return await botHandler(req);\n}\n",[150],"e8ce6664-2859-11f0-b4f5-569c3dd06744","deno.json","e8ce6754-2859-11f0-b4f5-569c3dd06744",5,["D",1746302707144],"{\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}",[158],"cab8d86c-2886-11f0-8039-569c3dd06744","cronHandler.ts","cab8d8f8-2886-11f0-8039-569c3dd06744",28,["D",1746321983952],"interval","// Main entry point for Val Town\nimport { syncRecentMessages } from \"./backend/main.ts\";\n\n// Scheduled task to sync recent messages (runs hourly)\nexport async function hourlySync() {\n await syncRecentMessages();\n}",[165],"e9049590-2859-11f0-a7a7-569c3dd06744","README.md","e904963a-2859-11f0-a7a7-569c3dd06744",18,["D",1746302707305],"# Discord Conversation Tracker & Analysis Bot\n\nA Discord bot that archives conversations between you and your partner in a private server, tracks shared links, and allows intelligent searching and analysis of past discussions using Claude AI. The bot can also import historical DM conversations from Discord's data export.\n\n## Features\n\n- **Message Archiving**: Records all messages exchanged in your private server\n- **Historical DM Import**: Import your conversation history from Discord data exports\n- **Link Tracking**: Automatically extracts and categorizes shared links\n- **AI-Powered Analysis**: Use Claude to query your conversation history\n- **Project Organization**: Group conversations by topics or projects\n- **Discord Command Interface**: Interact with your data directly through Discord\n\n## Requirements\n\n- Discord Bot Token\n- Discord Application ID\n- Anthropic API Key (for Claude)\n- A private Discord server with just you and your partner\n- Val Town account for hosting\n\n## Command Examples\n\n- `/query what tables did we like for the dining room?`\n- `/links list`\n- `/links search ikea`\n- `/project create name:Furniture description:Our furniture shopping journey`\n- `/project list`\n- `/import channel channel_id:123456789`\n- `/import dm` (generates upload link for DM history)\n\n## Setup Instructions\n\n1. Create a Discord application and bot at the [Discord Developer Portal](https://discord.com/developers/applications)\n2. Create a private server with just you and your partner\n3. Invite the bot to your server with the following permissions:\n - Read Messages/View Channels\n - Send Messages\n - Read Message History\n - Use Slash Commands\n4. Set up the environment variables in Val Town:\n - `DISCORD_TOKEN`: Your Discord bot token\n - `DISCORD_APPLICATION_ID`: Your Discord application ID\n - `ANTHROPIC_API_KEY`: Your Claude API key\n - `VAL_TOWN_URL`: The URL of your Val Town deployment\n\n5. Register the bot commands by making a POST request to the `/register` endpoint\n\n## Importing Historical DMs\n\nThere are two ways to import your conversation history:\n\n### Method 1: Discord Data Export (For Private DMs)\n1. Go to User Settings → Privacy & Safety in Discord\n2. Request your data export\n3. When you receive it, use the `/import dm` command to generate an upload link\n4. Upload your messages JSON file to the provided link\n\n### Method 2: Channel History Import (For Server Messages)\n1. Find the ID of the channel you want to import (enable Developer Mode in Discord)\n2. Use the command `/import channel channel_id:YOUR_CHANNEL_ID`\n3. If there are more than 100 messages, the command will tell you how to paginate for more\n\n## Database Schema\n\n### Messages\n- `id`: Unique message ID\n- `channel_id`: Discord channel ID\n- `user_id`: Discord user ID\n- `content`: Message text content\n- `timestamp`: Unix timestamp\n- `has_links`: Boolean indicating if message contains links\n- `is_command`: Boolean indicating if message is a command\n\n### Links\n- `id`: Auto-incrementing ID\n- `message_id`: Reference to message containing the link\n- `url`: Full URL\n- `domain`: Domain name\n- `timestamp`: Unix timestamp\n- `category`: Optional category tag\n\n### Projects\n- `id`: Auto-incrementing ID\n- `name`: Project name\n- `description`: Optional project description\n- `created_at`: Unix timestamp\n- `is_active`: Boolean status\n\n### Topics\n- `id`: Auto-incrementing ID\n- `name`: Topic name\n- `description`: Optional topic description\n- `created_at`: Unix timestamp\n\n## Implementation Details\n\nThis bot uses:\n- Discord API for bot functionality\n- SQLite for persistent storage\n- Claude API for natural language processing and conversation analysis\n- Val Town for serverless hosting\n\n## Privacy & Security\n\n- All data is stored within Val Town's secure environment\n- Only conversations in channels where the bot is invited are recorded\n- The bot does not share your conversation data with any third parties (except Claude for processing queries)\n\n## Limitations\n\n- The bot only processes messages after it has been added to a channel\n- Historical messages prior to bot installation need to be imported separately\n- Some advanced search capabilities require specific phrasing\n\n## Future Enhancements\n\n- Web interface for more detailed data exploration\n- Better automatic topic categorization\n- Image and attachment tracking\n- Sentiment analysis of conversations",[173],"e8fe0c3e-2859-11f0-ab88-569c3dd06744",".vtignore","e8fe0d06-2859-11f0-ab88-569c3dd06744",16,["D",1746302707414],".git\n.vscode\n.DS_Store\nnode_modules\nvendor",[180],"e8f1a142-2859-11f0-8c0e-569c3dd06744",".gitignore","e8f1a1ce-2859-11f0-8c0e-569c3dd06744",12,["D",1746302707350],"**/.claude/settings.local.json\n",[187],"e90197be-2859-11f0-a90e-569c3dd06744",".cursorrules","e9019868-2859-11f0-a90e-569c3dd06744",17,["D",1746302707301],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious operations)\n- Follow modern ES6+ conventions and functional programming practices if possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = 'todo_app_users_2';\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(`SELECT * FROM ${TABLE_NAME} WHERE id = ?`, [1]);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: \"Say hello in a creative way\" },\n ],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({ \n subject: \"Hi\", \n text: \"Hi\", \n html: \"

Hi

\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n \n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n \n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[194],"e8accde2-2859-11f0-96d8-569c3dd06744","shared","e8acce8c-2859-11f0-96d8-569c3dd06744",4,["D",1746302706924],"directory",[201],"e8634406-2859-11f0-a8a7-569c3dd06744","frontend","e86344b0-2859-11f0-a8a7-569c3dd06744",1,["D",1746302706440],[208],"e892442c-2859-11f0-b4f5-569c3dd06744","backend","e89244b8-2859-11f0-b4f5-569c3dd06744",3,["D",1746302706739],[214],"e87e1e20-2859-11f0-a8a7-569c3dd06744",".claude","e87e1ec0-2859-11f0-a8a7-569c3dd06744",["D",1746302706620],[220],"pulls","branches","forks","envVars",{"_231":233,"_234":153},"connections",{"_231":153,"_232":153},"count","unfilledCount",7,"emptyCount",{"_44":219,"_32":220,"_30":221,"_142":-5,"_42":43,"_41":64,"_144":60,"_39":339,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_255":340,"_27":341},{"_44":332,"_32":333,"_30":334,"_142":221,"_42":43,"_41":233,"_144":60,"_39":335,"_13":153,"_34":20,"_36":336,"_24":25,"_147":-5,"_255":337,"_27":338},{"_44":213,"_32":214,"_30":215,"_142":-5,"_42":43,"_41":216,"_144":60,"_39":329,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_255":330,"_27":331},{"_44":321,"_32":322,"_30":323,"_142":215,"_42":43,"_41":324,"_144":60,"_39":325,"_13":210,"_34":35,"_36":326,"_24":25,"_147":-5,"_255":327,"_27":328},{"_44":317,"_32":33,"_30":31,"_142":215,"_42":43,"_41":14,"_144":60,"_39":318,"_13":210,"_34":35,"_36":38,"_24":25,"_147":-5,"_255":319,"_27":320},{"_44":309,"_32":310,"_30":311,"_142":215,"_42":43,"_41":312,"_144":60,"_39":313,"_13":153,"_34":35,"_36":314,"_24":25,"_147":-5,"_255":315,"_27":316},{"_44":301,"_32":302,"_30":303,"_142":215,"_42":43,"_41":304,"_144":60,"_39":305,"_13":153,"_34":35,"_36":306,"_24":25,"_147":-5,"_255":307,"_27":308},{"_44":293,"_32":294,"_30":295,"_142":215,"_42":43,"_41":296,"_144":25,"_39":297,"_13":216,"_34":35,"_36":298,"_24":25,"_147":-5,"_255":299,"_27":300},{"_44":285,"_32":286,"_30":287,"_142":215,"_42":43,"_41":288,"_144":60,"_39":289,"_13":64,"_34":35,"_36":290,"_24":25,"_147":-5,"_255":291,"_27":292},{"_44":207,"_32":208,"_30":209,"_142":-5,"_42":43,"_41":210,"_144":60,"_39":282,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_255":283,"_27":284},{"_44":200,"_32":201,"_30":202,"_142":-5,"_42":43,"_41":203,"_144":60,"_39":279,"_13":153,"_34":205,"_36":-5,"_24":25,"_147":-5,"_255":280,"_27":281},{"_44":193,"_32":194,"_30":195,"_142":-5,"_42":43,"_41":196,"_144":60,"_39":276,"_13":153,"_34":20,"_36":198,"_24":25,"_147":-5,"_255":277,"_27":278},{"_44":186,"_32":187,"_30":188,"_142":-5,"_42":43,"_41":189,"_144":60,"_39":273,"_13":153,"_34":20,"_36":191,"_24":25,"_147":-5,"_255":274,"_27":275},{"_44":179,"_32":180,"_30":181,"_142":-5,"_42":43,"_41":182,"_144":60,"_39":270,"_13":153,"_34":20,"_36":184,"_24":25,"_147":-5,"_255":271,"_27":272},{"_44":172,"_32":173,"_30":174,"_142":-5,"_42":43,"_41":175,"_144":60,"_39":267,"_13":153,"_34":20,"_36":177,"_24":25,"_147":-5,"_255":268,"_27":269},{"_44":164,"_32":165,"_30":166,"_142":-5,"_42":43,"_41":167,"_144":60,"_39":264,"_13":153,"_34":169,"_36":170,"_24":25,"_147":-5,"_255":265,"_27":266},{"_44":157,"_32":158,"_30":159,"_142":-5,"_42":43,"_41":160,"_144":60,"_39":261,"_13":153,"_34":20,"_36":162,"_24":25,"_147":-5,"_255":262,"_27":263},{"_44":149,"_32":150,"_30":58,"_142":-5,"_42":43,"_41":151,"_144":60,"_39":258,"_13":153,"_34":154,"_36":155,"_24":25,"_147":-5,"_255":259,"_27":260},{"_44":139,"_32":140,"_30":141,"_142":-5,"_42":43,"_41":143,"_144":60,"_39":254,"_13":64,"_34":35,"_36":146,"_24":25,"_147":-5,"_255":256,"_27":257},["D",1746321983950],"children",[],[140],["D",1746320981424],[],[150],["D",1746302707144],[],[158],["D",1746321983952],[],[165],["D",1746302707305],[],[173],["D",1746302707414],[],[180],["D",1746302707350],[],[187],["D",1746302707301],[],[194],["D",1746302706924],[],[201],["D",1746302706440],[],[208],"2124b5aa-2886-11f0-8f9b-569c3dd06744","webhooks.ts","e8e6fb3e-2859-11f0-8c0e-569c3dd06744",25,["D",1746321699516],"// Webhook handlers for Discord events\nimport { processMessage } from \"./bot.ts\";\nimport * as discord from \"./discord.ts\";\nimport * as db from \"./database.ts\";\nimport * as importer from \"./importer.ts\";\n\n// Process Discord interactions\nexport async function handleInteraction(request: Request): Promise {\n try {\n console.log(\"Received Discord interaction request\");\n \n // Log headers for debugging\n const headers = {};\n for (const [key, value] of request.headers.entries()) {\n headers[key] = value;\n }\n console.log(\"Request headers:\", JSON.stringify(headers));\n \n const bodyText = await request.text();\n console.log(\"Request body:\", bodyText);\n \n // Parse the body as JSON\n const body = JSON.parse(bodyText);\n \n // Handle Discord interaction types\n if (body.type === 1) {\n // Respond to Discord PING for endpoint verification\n console.log(\"Responding to Discord PING verification\");\n return new Response(JSON.stringify({ type: 1 }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n } else if (body.type === 2) {\n // Handle commands\n console.log(\"Handling command:\", body.data?.name);\n return handleCommand(body);\n } else if (body.type === 3) {\n // Handle message components interactions\n console.log(\"Handling component interaction\");\n return handleComponentInteraction(body);\n }\n \n console.log(\"Invalid interaction type:\", body.type);\n return new Response(\"Invalid interaction type\", { status: 400 });\n } catch (error) {\n console.error(\"Error in handleInteraction:\", error);\n console.log(\"Error stack:\", error.stack);\n return new Response(\"Internal server error\", { status: 500 });\n }\n}\n\n// Process Discord messages from webhooks\nexport async function handleMessageCreate(request: Request): Promise {\n try {\n const body = await request.json();\n \n // Process the message\n await processMessage(body);\n \n return new Response(\"Message processed\", { status: 200 });\n } catch (error) {\n console.error(\"Error handling message create webhook:\", error);\n return new Response(\"Error processing message\", { status: 500 });\n }\n}\n\n// Handle Discord slash commands\nasync function handleCommand(interaction: any): Promise {\n const { name } = interaction.data;\n \n switch (name) {\n case 'query':\n return handleQueryCommand(interaction);\n case 'project':\n return handleProjectCommand(interaction);\n case 'links':\n return handleLinksCommand(interaction);\n case 'import':\n return handleImportCommand(interaction);\n default:\n return respondToInteraction(\"Unknown command\");\n }\n}\n\n// Handle message component interactions (buttons, select menus)\nasync function handleComponentInteraction(interaction: any): Promise {\n const customId = interaction.data.custom_id;\n \n // Handle different component interactions based on customId\n if (customId.startsWith(\"link_\")) {\n return handleLinkInteraction(interaction, customId);\n } else if (customId.startsWith(\"project_\")) {\n return handleProjectInteraction(interaction, customId);\n }\n \n return respondToInteraction(\"Unknown interaction\");\n}\n\n// Handle AI query command\nasync function handleQueryCommand(interaction: any): Promise {\n const query = interaction.data.options.find((o: any) => o.name === 'question')?.value;\n \n if (!query) {\n return respondToInteraction(\"Please provide a question to ask\");\n }\n \n // Send an initial response so Discord knows we're processing\n await deferReply(interaction.id, interaction.token);\n \n try {\n // Get the user and their partner's ID\n // For now we'll assume the command is always run by the couple\n // In a production version, you'd want to configure this\n const userId = interaction.member.user.id;\n \n // TODO: Replace this with a proper lookup of the partner\n // This could be from a configuration setting in your database\n const partnerUserId = \"PARTNER_USER_ID\"; // Replace with actual lookup\n \n // Get relevant messages based on the query\n const relevantMessages = await db.getRelevantMessagesForQuery(\n query, \n [userId, partnerUserId], \n 100\n );\n \n if (!relevantMessages.length) {\n return editReply(\n interaction.token, \n \"I couldn't find any relevant messages in your history\"\n );\n }\n \n // Create a user map for formatting\n const userMap = new Map();\n userMap.set(userId, interaction.member.user.username);\n userMap.set(partnerUserId, \"Partner\"); // Replace with actual lookup\n \n // Ask Claude for analysis\n const claudeResponse = await db.analyzeMessagesWithClaude(\n relevantMessages,\n userMap,\n query\n );\n \n return editReply(interaction.token, claudeResponse);\n } catch (error) {\n console.error(\"Error handling query command:\", error);\n return editReply(\n interaction.token, \n \"Sorry, I encountered an error processing your query\"\n );\n }\n}\n\n// Handle project management command\nasync function handleProjectCommand(interaction: any): Promise {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'create':\n return handleCreateProject(interaction);\n case 'list':\n return handleListProjects(interaction);\n case 'view':\n return handleViewProject(interaction);\n default:\n return respondToInteraction(\"Unknown project subcommand\");\n }\n}\n\n// Handle links command\nasync function handleLinksCommand(interaction: any): Promise {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'list':\n return handleListLinks(interaction);\n case 'categorize':\n return handleCategorizeLink(interaction);\n case 'search':\n return handleSearchLinks(interaction);\n default:\n return respondToInteraction(\"Unknown links subcommand\");\n }\n}\n\n// Handle creating a new project\nasync function handleCreateProject(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const name = options.find((o: any) => o.name === 'name')?.value;\n const description = options.find((o: any) => o.name === 'description')?.value;\n \n if (!name) {\n return respondToInteraction(\"Please provide a project name\");\n }\n \n try {\n const projectId = await db.createProject({\n name,\n description,\n created_at: Date.now(),\n is_active: true\n });\n \n if (projectId) {\n return respondToInteraction(`Project \"${name}\" created successfully! ID: ${projectId}`);\n } else {\n return respondToInteraction(\"Failed to create project\");\n }\n } catch (error) {\n console.error(\"Error creating project:\", error);\n return respondToInteraction(\"Error creating project\");\n }\n}\n\n// Handle listing projects\nasync function handleListProjects(interaction: any): Promise {\n try {\n const projects = await db.getProjects();\n \n if (projects.length === 0) {\n return respondToInteraction(\"No projects found\");\n }\n \n let response = \"**Your Projects:**\\n\";\n \n for (const project of projects) {\n const date = new Date(project.created_at).toISOString().split('T')[0];\n response += `**${project.id}**: ${project.name} (${date})\\n`;\n \n if (project.description) {\n response += ` *${project.description}*\\n`;\n }\n }\n \n return respondToInteraction(response);\n } catch (error) {\n console.error(\"Error listing projects:\", error);\n return respondToInteraction(\"Error listing projects\");\n }\n}\n\n// Handle viewing a project\nasync function handleViewProject(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const projectId = options.find((o: any) => o.name === 'id')?.value;\n \n if (!projectId) {\n return respondToInteraction(\"Please provide a project ID\");\n }\n \n try {\n // Get project details\n const project = await db.getProject(projectId);\n \n if (!project) {\n return respondToInteraction(\"Project not found\");\n }\n \n // Get project messages\n const messages = await db.getProjectMessages(projectId, 10);\n \n let response = `**Project: ${project.name}**\\n`;\n \n if (project.description) {\n response += `*${project.description}*\\n\\n`;\n }\n \n if (messages.length === 0) {\n response += \"No messages in this project yet.\";\n } else {\n response += \"**Recent messages:**\\n\";\n \n for (const message of messages) {\n const date = new Date(message.timestamp).toISOString().split('T')[0];\n const preview = message.content.length > 100 \n ? message.content.substring(0, 97) + \"...\" \n : message.content;\n \n response += `[${date}] ${preview}\\n`;\n }\n }\n \n // Add a button to view more\n const components = [\n {\n type: 1,\n components: [\n {\n type: 2,\n style: 1,\n label: \"View More Messages\",\n custom_id: `project_view_more:${projectId}:10`\n }\n ]\n }\n ];\n \n return respondToInteraction(response, false, components);\n } catch (error) {\n console.error(\"Error viewing project:\", error);\n return respondToInteraction(\"Error viewing project\");\n }\n}\n\n// Handle listing links\nasync function handleListLinks(interaction: any): Promise {\n try {\n const options = interaction.data.options[0].options;\n const limit = options.find((o: any) => o.name === 'limit')?.value || 10;\n \n const links = await db.getLinks(limit);\n \n if (links.length === 0) {\n return respondToInteraction(\"No links found\");\n }\n \n let response = \"**Recently Shared Links:**\\n\";\n \n for (const link of links) {\n const date = new Date(link.timestamp).toISOString().split('T')[0];\n const category = link.category ? `[${link.category}] ` : '';\n \n response += `**${link.id}**: ${category}${link.url} (${date})\\n`;\n }\n \n return respondToInteraction(response);\n } catch (error) {\n console.error(\"Error listing links:\", error);\n return respondToInteraction(\"Error listing links\");\n }\n}\n\n// Handle categorizing a link\nasync function handleCategorizeLink(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const linkId = options.find((o: any) => o.name === 'id')?.value;\n const category = options.find((o: any) => o.name === 'category')?.value;\n \n if (!linkId || !category) {\n return respondToInteraction(\"Please provide a link ID and category\");\n }\n \n try {\n const success = await db.updateLinkCategory(linkId, category);\n \n if (success) {\n return respondToInteraction(`Link categorized as \"${category}\"`);\n } else {\n return respondToInteraction(\"Failed to categorize link\");\n }\n } catch (error) {\n console.error(\"Error categorizing link:\", error);\n return respondToInteraction(\"Error categorizing link\");\n }\n}\n\n// Handle searching links\nasync function handleSearchLinks(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const query = options.find((o: any) => o.name === 'query')?.value;\n \n if (!query) {\n return respondToInteraction(\"Please provide a search query\");\n }\n \n try {\n const links = await db.searchLinks(query);\n \n if (links.length === 0) {\n return respondToInteraction(`No links found matching \"${query}\"`);\n }\n \n let response = `**Links matching \"${query}\":**\\n`;\n \n for (const link of links) {\n const date = new Date(link.timestamp).toISOString().split('T')[0];\n const category = link.category ? `[${link.category}] ` : '';\n \n response += `**${link.id}**: ${category}${link.url} (${date})\\n`;\n }\n \n return respondToInteraction(response);\n } catch (error) {\n console.error(\"Error searching links:\", error);\n return respondToInteraction(\"Error searching links\");\n }\n}\n\n// Handle import command\nasync function handleImportCommand(interaction: any): Promise {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'channel':\n return handleImportChannel(interaction);\n case 'dm':\n return handleInitiateDmImport(interaction);\n default:\n return respondToInteraction(\"Unknown import subcommand\");\n }\n}\n\n// Handle importing from a channel\nasync function handleImportChannel(interaction: any): Promise {\n const options = interaction.data.options[0].options;\n const channelId = options.find((o: any) => o.name === 'channel_id')?.value;\n const limit = options.find((o: any) => o.name === 'limit')?.value || 100;\n const before = options.find((o: any) => o.name === 'before')?.value;\n \n if (!channelId) {\n return respondToInteraction(\"Please provide a channel ID\");\n }\n \n // Send an initial response so Discord knows we're processing\n await deferReply(interaction.id, interaction.token);\n \n try {\n // Import messages from the channel\n const result = await importer.importChannelHistory(channelId, limit, before);\n \n let response = `✅ Import completed!\\n\\n**Results:**\\n`;\n response += `- Messages imported: ${result.messagesImported}\\n`;\n response += `- Links extracted: ${result.linksImported}\\n`;\n \n // Check for errors\n if (result.errors.length > 0) {\n // Find the oldest_id error message for pagination\n const oldestIdMessage = result.errors.find(err => err.startsWith('oldest_id:'));\n if (oldestIdMessage) {\n const oldestId = oldestIdMessage.split(':')[1];\n response += `\\nTo import more messages, use this command again with the \\`before\\` parameter set to: \\`${oldestId}\\``;\n }\n \n // Filter out the oldest_id message and report other errors\n const actualErrors = result.errors.filter(err => !err.startsWith('oldest_id:'));\n if (actualErrors.length > 0) {\n response += `\\n\\n**Errors:**\\n`;\n for (const error of actualErrors) {\n response += `- ${error}\\n`;\n }\n }\n }\n \n return editReply(interaction.token, response);\n } catch (error) {\n console.error(\"Error importing channel history:\", error);\n return editReply(interaction.token, \"Error importing channel history\");\n }\n}\n\n// Handle initiating a DM import\nasync function handleInitiateDmImport(interaction: any): Promise {\n // Create a unique identifier for this upload\n const uploadId = crypto.randomUUID();\n \n console.log(\"DM import initiated by user:\", interaction.member?.user?.id);\n \n // Get the VAL_TOWN_URL from env\n const valTownUrl = Deno.env.get(\"VAL_TOWN_URL\") || \"your-val-town-url\";\n \n // Create a message with instructions for uploading DM history\n let response = `**Discord DM History Import**\\n\\n`;\n response += `To import your Discord DM history:\\n\\n`;\n response += `1. Follow the steps in the Discord app to download your data:\\n`;\n response += ` - Go to User Settings → Privacy & Safety\\n`;\n response += ` - Scroll down to \"Request all of my Data\"\\n`;\n response += ` - Click the request button and wait for Discord to email you\\n\\n`;\n response += `2. Once you receive your data, extract the package\\n\\n`;\n response += `3. Find the JSON file with your DM history (usually in messages/ folder)\\n\\n`;\n response += `4. Go to this special upload URL to send the file to this bot:\\n`;\n response += ` ${valTownUrl}/upload/${uploadId}\\n\\n`;\n response += `This URL will be valid for 24 hours. Your data will be processed securely and only stored in this bot's database.`;\n \n console.log(\"Generated upload URL:\", `${valTownUrl}/upload/${uploadId}`);\n \n // TODO: Store the uploadId in your database with an expiration time\n // This would allow you to validate it when the upload arrives\n \n return respondToInteraction(response);\n}\n\n// Handle link interactions (from buttons, etc.)\nasync function handleLinkInteraction(interaction: any, customId: string): Promise {\n // Parse the custom ID\n const [prefix, action, linkId] = customId.split(':');\n \n if (action === 'view') {\n // TODO: Implement link viewing\n return respondToInteraction(\"Link view not yet implemented\");\n }\n \n return respondToInteraction(\"Unknown link interaction\");\n}\n\n// Handle project interactions (from buttons, etc.)\nasync function handleProjectInteraction(interaction: any, customId: string): Promise {\n // Parse the custom ID\n const [prefix, action, projectId, offset] = customId.split(':');\n \n if (action === 'view_more') {\n // TODO: Implement pagination for project messages\n return respondToInteraction(\"Pagination not yet implemented\");\n }\n \n return respondToInteraction(\"Unknown project interaction\");\n}\n\n// Helper function to respond to Discord interactions\nfunction respondToInteraction(content: string, ephemeral = false, components?: any[]): Response {\n const response: any = {\n type: 4,\n data: {\n content,\n flags: ephemeral ? 64 : 0\n }\n };\n \n if (components) {\n response.data.components = components;\n }\n \n return new Response(\n JSON.stringify(response),\n { headers: { \"Content-Type\": \"application/json\" } }\n );\n}\n\n// Helper function to send a deferred response (for long-running commands)\nasync function deferReply(interactionId: string, interactionToken: string): Promise {\n try {\n await discord.discordRequest(\n `/interactions/${interactionId}/${interactionToken}/callback`,\n \"POST\",\n {\n type: 5, // DEFERRED_CHANNEL_MESSAGE_WITH_SOURCE\n data: {}\n }\n );\n } catch (error) {\n console.error(\"Error deferring reply:\", error);\n }\n}\n\n// Helper function to edit a deferred response\nasync function editReply(interactionToken: string, content: string): Promise {\n try {\n await discord.discordRequest(\n `/webhooks/${Deno.env.get(\"DISCORD_APPLICATION_ID\")}/${interactionToken}/messages/@original`,\n \"PATCH\",\n {\n content\n }\n );\n \n // Return an empty 200 response since we've already responded via the webhook\n return new Response(\"\", { status: 200 });\n } catch (error) {\n console.error(\"Error editing reply:\", error);\n return new Response(\"Error editing reply\", { status: 500 });\n }\n}",[],[214,286],"053990c8-288a-11f0-b66d-569c3dd06744","main.ts","e8d9a5e2-2859-11f0-acf0-569c3dd06744",30,["D",1746323370665],"// Main entry point for the Discord bot\nimport { registerCommands, discordRequest } from \"./discord.ts\";\nimport { commands } from \"./bot.ts\";\nimport { handleInteraction, handleMessageCreate } from \"./webhooks.ts\";\nimport { importDiscordDataExport } from \"./importer.ts\";\nimport { initDatabase } from \"./database.ts\";\n// Using the official Anthropic JS SDK\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.10.0\";\n\n// This is critical for Discord verification - DO NOT REMOVE\nconst DISCORD_PUBLIC_KEY = Deno.env.get(\"DISCORD_PUBLIC_KEY\");\n\n// Environment variables\nconst DISCORD_TOKEN = Deno.env.get(\"DISCORD_TOKEN\");\nconst DISCORD_APPLICATION_ID = Deno.env.get(\"DISCORD_APPLICATION_ID\");\nconst ANTHROPIC_API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n\nif (!DISCORD_TOKEN || !DISCORD_APPLICATION_ID) {\n throw new Error(\"Missing required environment variables\");\n}\n\n// Initialize Claude API client\nconst anthropic = ANTHROPIC_API_KEY ? new Anthropic({\n apiKey: ANTHROPIC_API_KEY,\n}) : null;\n\n// Initialize database on startup\nawait initDatabase();\n\n// Function to handle incoming requests\nexport default async function(req: Request) {\n try {\n // Special handling for Discord verification\n // Simplest possible handling of Discord verification ping\n // To make this work, make sure to set the Interactions Endpoint URL \n // in Discord Developer Portal to your Val Town URL\n try {\n const bodyText = await req.text();\n let body;\n \n try {\n body = JSON.parse(bodyText);\n } catch (e) {\n // Not valid JSON, proceed with normal routing\n }\n \n // Check if this is a Discord ping (type 1 interaction)\n if (body && body.type === 1) {\n console.log(\"Received Discord PING verification\");\n // Respond to Discord PING\n return new Response(JSON.stringify({ type: 1 }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n \n // Recreate the request with the original body for further processing\n req = new Request(req.url, {\n method: req.method,\n headers: req.headers,\n body: bodyText\n });\n } catch (error) {\n console.error(\"Error processing body:\", error);\n // Continue with original request if there was an error\n }\n \n console.log(`Request received: ${req.method} ${new URL(req.url).pathname}`);\n \n const url = new URL(req.url);\n \n // Handle Discord interaction\n if (url.pathname === \"/interactions\") {\n console.log(\"Routing to interactions handler\");\n \n try {\n // Try to parse the body to determine if we should use direct command handling\n const bodyText = await req.text();\n const body = JSON.parse(bodyText);\n \n // Check if this is a command or component interaction\n if (body.type === 2) {\n // It's a command interaction\n return await handleCommand(body);\n } else if (body.type === 3) {\n // It's a component interaction\n return await handleComponentInteraction(body);\n } else {\n // For other interaction types, use the standard handler\n // Recreate the request with the original body\n const newReq = new Request(req.url, {\n method: req.method,\n headers: req.headers,\n body: bodyText\n });\n return await handleInteraction(newReq);\n }\n } catch (error) {\n console.error(\"Error in interaction routing:\", error);\n // If there's an error parsing, default to the standard handler\n return await handleInteraction(req);\n }\n }\n \n // Handle Discord message create webhook\n if (url.pathname === \"/webhooks/messages\") {\n console.log(\"Routing to message webhook handler\");\n return await handleMessageCreate(req);\n }\n \n // Handle Discord API webhook verification\n if (url.pathname === \"/register\") {\n console.log(\"Routing to command registration handler\");\n return await registerCommandsHandler(req);\n }\n \n // Handle DM history file upload\n if (url.pathname.startsWith(\"/upload/\")) {\n console.log(\"Routing to DM upload handler\");\n return await handleDmUpload(req);\n }\n \n // For the root path\n if (url.pathname === \"/\") {\n // Return basic info\n return new Response(\"Discord Bot API - Status: Online\", {\n headers: { \"Content-Type\": \"text/plain\" }\n });\n }\n \n // Log unknown routes\n console.log(`Unknown route requested: ${url.pathname}`);\n \n // Default response\n return new Response(\"Discord Bot API - Route not found\", {\n status: 404,\n headers: { \"Content-Type\": \"text/plain\" }\n });\n } catch (error) {\n console.error(\"Error handling request:\", error);\n console.log(\"Error stack:\", error.stack);\n return new Response(\"Internal server error\", { status: 500 });\n }\n}\n\n// Handler for registering commands\nasync function registerCommandsHandler(req: Request): Promise {\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n \n try {\n // Register commands with Discord\n const success = await registerCommands(commands);\n \n if (success) {\n return new Response(\"Commands registered successfully\");\n } else {\n return new Response(\"Failed to register commands\", { status: 500 });\n }\n } catch (error) {\n console.error(\"Error registering commands:\", error);\n return new Response(\"Error registering commands\", { status: 500 });\n }\n}\n\n// Cron job to sync recent messages (runs every hour)\nexport async function syncRecentMessages() {\n try {\n // Get configured channel IDs for message syncing\n // In a production version, you'd want to store this in your database\n // For now, we'll hardcode it\n const channelIds = [\"1367934092594643088\"]; // general\n \n for (const channelId of channelIds) {\n // Fetch recent messages from the channel\n const messages = await discordRequest(`/channels/${channelId}/messages?limit=100`);\n \n if (Array.isArray(messages)) {\n // Process each message\n for (const message of messages) {\n await processMessage(message);\n }\n }\n }\n \n console.log(\"Message sync completed successfully\");\n } catch (error) {\n console.error(\"Error syncing messages:\", error);\n }\n}\n\n// Function to process a new message\nasync function processMessage(message: any) {\n try {\n // Skip bot messages\n if (message.author.bot) {\n return;\n }\n \n // Make a POST request to the message webhook\n await fetch(`${Deno.env.get(\"VAL_TOWN_URL\")}/webhooks/messages`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify(message)\n });\n } catch (error) {\n console.error(\"Error processing message:\", error);\n }\n}\n\n// Function to handle Discord slash commands\nasync function handleCommand(interaction: any) {\n const { name } = interaction.data;\n \n switch (name) {\n case 'query':\n return handleQueryCommand(interaction);\n case 'project':\n return handleProjectCommand(interaction);\n case 'links':\n return handleLinksCommand(interaction);\n default:\n return respondToInteraction(\"Unknown command\");\n }\n}\n\n// Function to handle message component interactions (buttons, select menus)\nasync function handleComponentInteraction(interaction: any) {\n const customId = interaction.data.custom_id;\n \n // Handle different component interactions based on customId\n if (customId.startsWith(\"link_\")) {\n return handleLinkInteraction(interaction, customId);\n }\n \n return respondToInteraction(\"Unknown interaction\");\n}\n\n// Handle AI query command\nasync function handleQueryCommand(interaction: any) {\n const query = interaction.data.options.find((o: any) => o.name === 'question')?.value;\n \n if (!query) {\n return respondToInteraction(\"Please provide a question to ask\");\n }\n \n try {\n // Get relevant messages based on the query\n const relevantMessages = await getRelevantMessages(query);\n \n if (!relevantMessages.length) {\n return respondToInteraction(\"I couldn't find any relevant messages in your history\");\n }\n \n if (!anthropic) {\n return respondToInteraction(\"Claude API is not configured\");\n }\n \n // Format the context for Claude\n const context = formatMessagesForClaude(relevantMessages);\n \n // Ask Claude for analysis\n const claudeResponse = await anthropic.messages.create({\n model: \"claude-3-opus-20240229\",\n max_tokens: 1000,\n messages: [\n {\n role: \"user\",\n content: `You are analyzing conversations between a couple. Based on these message excerpts, please answer their question in a helpful way.\n \nMessage history:\n${context}\n\nQuestion: ${query}\n\nPlease be concise but thorough in your answer, providing specific references to what they discussed when relevant.`\n }\n ],\n });\n \n return respondToInteraction(claudeResponse.content[0].text);\n } catch (error) {\n console.error(\"Error handling query command:\", error);\n return respondToInteraction(\"Sorry, I encountered an error processing your query\");\n }\n}\n\n// Handle project management command\nasync function handleProjectCommand(interaction: any) {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'create':\n return handleCreateProject(interaction);\n case 'list':\n return handleListProjects(interaction);\n case 'view':\n return handleViewProject(interaction);\n default:\n return respondToInteraction(\"Unknown project subcommand\");\n }\n}\n\n// Handle links command\nasync function handleLinksCommand(interaction: any) {\n const subCommand = interaction.data.options[0].name;\n \n switch (subCommand) {\n case 'list':\n return handleListLinks(interaction);\n case 'categorize':\n return handleCategorizeLink(interaction);\n case 'search':\n return handleSearchLinks(interaction);\n default:\n return respondToInteraction(\"Unknown links subcommand\");\n }\n}\n\n// Helper function to respond to Discord interactions\nfunction respondToInteraction(content: string, ephemeral = false) {\n return new Response(\n JSON.stringify({\n type: 4,\n data: {\n content,\n flags: ephemeral ? 64 : 0\n }\n }),\n { headers: { \"Content-Type\": \"application/json\" } }\n );\n}\n\n// Placeholder functions to be implemented\nasync function getRelevantMessages(query: string) {\n // TODO: implement retrieval logic based on query\n return [];\n}\n\nfunction formatMessagesForClaude(messages: any[]) {\n // TODO: implement message formatting for Claude\n return \"\";\n}\n\nasync function handleCreateProject(interaction: any) {\n // TODO: implement project creation\n return respondToInteraction(\"Project creation not yet implemented\");\n}\n\nasync function handleListProjects(interaction: any) {\n // TODO: implement project listing\n return respondToInteraction(\"Project listing not yet implemented\");\n}\n\nasync function handleViewProject(interaction: any) {\n // TODO: implement project viewing\n return respondToInteraction(\"Project viewing not yet implemented\");\n}\n\nasync function handleListLinks(interaction: any) {\n // TODO: implement link listing\n return respondToInteraction(\"Link listing not yet implemented\");\n}\n\nasync function handleCategorizeLink(interaction: any) {\n // TODO: implement link categorization\n return respondToInteraction(\"Link categorization not yet implemented\");\n}\n\nasync function handleSearchLinks(interaction: any) {\n // TODO: implement link searching\n return respondToInteraction(\"Link searching not yet implemented\");\n}\n\nasync function handleLinkInteraction(interaction: any, customId: string) {\n // TODO: implement link interaction handling\n return respondToInteraction(\"Link interaction not yet implemented\");\n}\n\n// Handle DM history file upload\nasync function handleDmUpload(req: Request): Promise {\n if (req.method !== \"POST\") {\n // Return a simple HTML form for GET requests\n if (req.method === \"GET\") {\n return new Response(`\n \n \n \n Discord DM History Upload\n \n \n \n

Discord DM History Upload

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

\n \n \n \n

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

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

Upload Complete

\n \n

Import Results:

Messages imported: ${result.messagesImported}

Links extracted: ${result.linksImported}

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

Errors:

${err}

\n ` : ''}\n \n

Success!

\n \n \n `, {\n headers: { \"Content-Type\": \"text/html\" }\n });\n } else {\n // Handle regular JSON payload\n const jsonData = await req.json();\n const result = await importDiscordDataExport(jsonData);\n \n return new Response(JSON.stringify(result), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n } catch (error) {\n console.error(\"Error handling DM upload:\", error);\n return new Response(`Error processing upload: ${error.message}`, { status: 500 });\n }\n}",[],[214,294],"e8ea56a8-2859-11f0-b4f5-569c3dd06744","importer.ts","e8ea575c-2859-11f0-b4f5-569c3dd06744",10,["D",1746302707298],"// Data importer for Discord message history\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport * as db from \"./database.ts\";\n\n// Type definitions for Discord data export\ninterface DiscordExportMessage {\n id: string;\n type: number;\n timestamp: string;\n content: string;\n author: {\n id: string;\n name: string;\n discriminator: string;\n nickname: string;\n avatar?: string;\n };\n attachments: any[];\n embeds: any[];\n mentions: any[];\n reactions?: {\n emoji: {\n id: string | null;\n name: string;\n };\n count: number;\n }[];\n}\n\ninterface DiscordExportChannel {\n id: string;\n type: number;\n name: string;\n recipients: {\n id: string;\n name: string;\n discriminator: string;\n nickname?: string;\n }[];\n messages: DiscordExportMessage[];\n}\n\n// Function to process Discord data export file\nexport async function importDiscordDataExport(data: any): Promise<{\n messagesImported: number;\n linksImported: number;\n errors: string[];\n}> {\n const result = {\n messagesImported: 0,\n linksImported: 0,\n errors: [] as string[],\n };\n\n try {\n // Begin transaction\n await sqlite.execute(\"BEGIN TRANSACTION\");\n\n // Process the data\n if (Array.isArray(data.messages)) {\n // Direct format - array of messages\n await processMessages(data.messages, result);\n } else if (data.channel && Array.isArray(data.channel.messages)) {\n // Channel format\n await processMessages(data.channel.messages, result);\n } else if (Array.isArray(data)) {\n // Array of channels or messages\n for (const item of data) {\n if (item.messages) {\n // It's a channel\n await processMessages(item.messages, result);\n } else if (item.id && item.content) {\n // It's a message\n await processMessage(item, result);\n }\n }\n } else {\n throw new Error(\"Unsupported data format\");\n }\n\n // Commit the transaction\n await sqlite.execute(\"COMMIT\");\n } catch (error) {\n // Rollback on error\n await sqlite.execute(\"ROLLBACK\");\n result.errors.push(`Import failed: ${error.message}`);\n console.error(\"Import error:\", error);\n }\n\n return result;\n}\n\n// Process an array of messages\nasync function processMessages(\n messages: DiscordExportMessage[],\n result: { messagesImported: number; linksImported: number; errors: string[] }\n): Promise {\n for (const message of messages) {\n await processMessage(message, result);\n }\n}\n\n// Process a single message\nasync function processMessage(\n message: DiscordExportMessage,\n result: { messagesImported: number; linksImported: number; errors: string[] }\n): Promise {\n try {\n // Skip system messages\n if (message.type !== 0 && message.type !== 19) {\n return;\n }\n\n // Skip empty messages\n if (!message.content && (!message.attachments || message.attachments.length === 0)) {\n return;\n }\n\n // Extract relevant data\n const { urls, domains } = db.extractLinks(message.content || \"\");\n const hasLinks = urls.length > 0;\n const isCommand = (message.content || \"\").startsWith(\"/\");\n \n // Default channel ID for DM imports\n const channelId = \"imported_dm\";\n\n // Create database message object\n const dbMessage: db.Message = {\n id: message.id,\n channel_id: channelId,\n user_id: message.author.id,\n content: message.content || \"\",\n timestamp: new Date(message.timestamp).getTime(),\n has_links: hasLinks,\n is_command: isCommand\n };\n\n // Save the message\n const success = await db.saveMessage(dbMessage);\n \n if (success) {\n result.messagesImported++;\n \n // Process links if any\n if (hasLinks) {\n for (let i = 0; i < urls.length; i++) {\n const link: db.Link = {\n message_id: message.id,\n url: urls[i],\n domain: domains[i] || extractDomain(urls[i]),\n timestamp: new Date(message.timestamp).getTime()\n };\n \n const linkId = await db.saveLink(link);\n if (linkId) {\n result.linksImported++;\n }\n }\n }\n }\n } catch (error) {\n result.errors.push(`Error processing message ${message.id}: ${error.message}`);\n console.error(\"Error processing message:\", error);\n }\n}\n\n// Helper function to extract domain from URL\nfunction extractDomain(url: string): string {\n try {\n const domain = new URL(url).hostname;\n return domain;\n } catch (error) {\n return \"unknown\";\n }\n}\n\n// Function to import messages from a specific Discord channel\nexport async function importChannelHistory(\n channelId: string,\n limit = 100,\n before?: string\n): Promise<{\n messagesImported: number;\n linksImported: number;\n errors: string[];\n}> {\n const result = {\n messagesImported: 0,\n linksImported: 0,\n errors: [] as string[],\n };\n\n try {\n const DISCORD_TOKEN = Deno.env.get(\"DISCORD_TOKEN\");\n \n if (!DISCORD_TOKEN) {\n throw new Error(\"Missing Discord token\");\n }\n \n // Fetch messages from Discord API\n let url = `https://discord.com/api/v10/channels/${channelId}/messages?limit=${limit}`;\n if (before) {\n url += `&before=${before}`;\n }\n \n const response = await fetch(url, {\n headers: {\n Authorization: `Bot ${DISCORD_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n });\n \n if (!response.ok) {\n throw new Error(`Discord API error: ${response.status} ${response.statusText}`);\n }\n \n const messages = await response.json();\n \n // Begin transaction\n await sqlite.execute(\"BEGIN TRANSACTION\");\n \n // Process messages\n for (const message of messages) {\n // Skip bot messages\n if (message.author.bot) {\n continue;\n }\n \n const { urls, domains } = db.extractLinks(message.content || \"\");\n const hasLinks = urls.length > 0;\n const isCommand = (message.content || \"\").startsWith(\"/\");\n \n // Create database message object\n const dbMessage: db.Message = {\n id: message.id,\n channel_id: message.channel_id,\n user_id: message.author.id,\n content: message.content || \"\",\n timestamp: new Date(message.timestamp).getTime(),\n has_links: hasLinks,\n is_command: isCommand\n };\n \n // Save the message\n const success = await db.saveMessage(dbMessage);\n \n if (success) {\n result.messagesImported++;\n \n // Process links if any\n if (hasLinks) {\n for (let i = 0; i < urls.length; i++) {\n const link: db.Link = {\n message_id: message.id,\n url: urls[i],\n domain: domains[i] || extractDomain(urls[i]),\n timestamp: new Date(message.timestamp).getTime()\n };\n \n const linkId = await db.saveLink(link);\n if (linkId) {\n result.linksImported++;\n }\n }\n }\n }\n }\n \n // Commit the transaction\n await sqlite.execute(\"COMMIT\");\n \n // Return the oldest message ID for pagination\n if (messages.length > 0) {\n result.errors.push(`oldest_id:${messages[messages.length - 1].id}`);\n }\n } catch (error) {\n // Rollback on error\n await sqlite.execute(\"ROLLBACK\");\n result.errors.push(`Import failed: ${error.message}`);\n console.error(\"Import error:\", error);\n }\n \n return result;\n}",[],[214,302],"e8ee0438-2859-11f0-ab88-569c3dd06744","discord.ts","e8ee04ec-2859-11f0-ab88-569c3dd06744",11,["D",1746302707299],"// Discord API integration\n\n// Discord API base URL\nconst DISCORD_API_URL = \"https://discord.com/api/v10\";\n\n// Environment variables\nconst DISCORD_TOKEN = Deno.env.get(\"DISCORD_TOKEN\");\nconst DISCORD_APPLICATION_ID = Deno.env.get(\"DISCORD_APPLICATION_ID\");\n\n// Type definitions\nexport interface DiscordMessage {\n id: string;\n channel_id: string;\n author: {\n id: string;\n username: string;\n global_name?: string;\n };\n content: string;\n timestamp: string;\n attachments: any[];\n embeds: any[];\n mentions: any[];\n}\n\nexport interface DiscordChannel {\n id: string;\n name: string;\n type: number;\n guild_id: string;\n}\n\nexport interface DiscordUser {\n id: string;\n username: string;\n global_name?: string;\n}\n\n// Helper function for Discord API requests\nexport async function discordRequest(endpoint: string, method = \"GET\", body?: any) {\n const url = `${DISCORD_API_URL}${endpoint}`;\n \n const headers = {\n \"Authorization\": `Bot ${DISCORD_TOKEN}`,\n \"Content-Type\": \"application/json\",\n \"User-Agent\": \"ValTownDiscordBot/1.0\"\n };\n \n const options: RequestInit = { method, headers };\n \n if (body) {\n options.body = JSON.stringify(body);\n }\n \n try {\n const response = await fetch(url, options);\n \n if (!response.ok) {\n const errorData = await response.json().catch(() => null);\n console.error(`Discord API error: ${response.status} ${response.statusText}`, errorData);\n throw new Error(`Discord API request failed: ${response.status} ${response.statusText}`);\n }\n \n // Check if there's content before parsing as JSON\n const text = await response.text();\n return text ? JSON.parse(text) : null;\n } catch (error) {\n console.error(\"Discord request error:\", error);\n throw error;\n }\n}\n\n// Function to register slash commands with Discord\nexport async function registerCommands(commands: any[]) {\n try {\n await discordRequest(\n `/applications/${DISCORD_APPLICATION_ID}/commands`, \n \"PUT\", \n commands\n );\n console.log(\"Commands registered successfully\");\n return true;\n } catch (error) {\n console.error(\"Error registering commands:\", error);\n return false;\n }\n}\n\n// Function to fetch channel messages\nexport async function fetchChannelMessages(channelId: string, limit = 100, before?: string) {\n let endpoint = `/channels/${channelId}/messages?limit=${limit}`;\n if (before) {\n endpoint += `&before=${before}`;\n }\n \n return await discordRequest(endpoint);\n}\n\n// Function to fetch a specific message\nexport async function fetchMessage(channelId: string, messageId: string) {\n return await discordRequest(`/channels/${channelId}/messages/${messageId}`);\n}\n\n// Function to fetch channel details\nexport async function fetchChannel(channelId: string) {\n return await discordRequest(`/channels/${channelId}`);\n}\n\n// Function to fetch user details\nexport async function fetchUser(userId: string) {\n return await discordRequest(`/users/${userId}`);\n}\n\n// Function to send a message to a channel\nexport async function sendMessage(channelId: string, content: string) {\n return await discordRequest(`/channels/${channelId}/messages`, \"POST\", { content });\n}\n\n// Function to reply to a message\nexport async function replyToMessage(channelId: string, messageId: string, content: string) {\n return await discordRequest(`/channels/${channelId}/messages`, \"POST\", {\n content,\n message_reference: {\n message_id: messageId\n }\n });\n}\n\n// Function to verify Discord interaction signature\nexport async function verifyInteraction(signature: string, timestamp: string, body: string) {\n // TODO: Implement proper signature verification using public key\n // This is a critical security step for a production bot\n \n // For now, we'll return true to allow development\n return true;\n}",[],[214,310],"053d6176-288a-11f0-84dc-569c3dd06744",["D",1746323370671],[],[214,33],"9454d5d8-285d-11f0-86d2-569c3dd06744","bot.ts","e8e0331c-2859-11f0-97af-569c3dd06744",19,["D",1746304283402],"// Bot logic and message processing\nimport Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.10.0\";\nimport * as db from \"./database.ts\";\nimport * as discord from \"./discord.ts\";\n\n// Initialize Claude API client\nconst ANTHROPIC_API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\nconst anthropic = new Anthropic({\n apiKey: ANTHROPIC_API_KEY || \"\",\n});\n\n// Command definitions\nexport const commands = [\n {\n name: \"query\",\n description: \"Ask a question about your past conversations\",\n options: [\n {\n name: \"question\",\n description: \"What would you like to know about your past conversations?\",\n type: 3, // STRING\n required: true\n }\n ]\n },\n {\n name: \"project\",\n description: \"Manage conversation projects\",\n options: [\n {\n name: \"create\",\n description: \"Create a new project\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"name\",\n description: \"Project name\",\n type: 3, // STRING\n required: true\n },\n {\n name: \"description\",\n description: \"Project description\",\n type: 3, // STRING\n required: false\n }\n ]\n },\n {\n name: \"list\",\n description: \"List all projects\",\n type: 1 // SUB_COMMAND\n },\n {\n name: \"view\",\n description: \"View a project's messages\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"id\",\n description: \"Project ID\",\n type: 4, // INTEGER\n required: true\n }\n ]\n }\n ]\n },\n {\n name: \"links\",\n description: \"Manage shared links\",\n options: [\n {\n name: \"list\",\n description: \"List recently shared links\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"limit\",\n description: \"Number of links to show (default: 10)\",\n type: 4, // INTEGER\n required: false\n }\n ]\n },\n {\n name: \"categorize\",\n description: \"Categorize a link\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"id\",\n description: \"Link ID\",\n type: 4, // INTEGER\n required: true\n },\n {\n name: \"category\",\n description: \"Category name\",\n type: 3, // STRING\n required: true\n }\n ]\n },\n {\n name: \"search\",\n description: \"Search for links\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"query\",\n description: \"Search query\",\n type: 3, // STRING\n required: true\n }\n ]\n }\n ]\n },\n {\n name: \"import\",\n description: \"Import conversation history\",\n options: [\n {\n name: \"channel\",\n description: \"Import message history from a Discord channel\",\n type: 1, // SUB_COMMAND\n options: [\n {\n name: \"channel_id\",\n description: \"Discord channel ID to import from\",\n type: 3, // STRING\n required: true\n },\n {\n name: \"limit\",\n description: \"Number of messages to import (default: 100, max: 100)\",\n type: 4, // INTEGER\n required: false\n },\n {\n name: \"before\",\n description: \"Import messages before this message ID (for pagination)\",\n type: 3, // STRING\n required: false\n }\n ]\n },\n {\n name: \"dm\",\n description: \"Initialize an imported DM history upload\",\n type: 1 // SUB_COMMAND\n }\n ]\n }\n];\n\n// Process a new Discord message\nexport async function processMessage(message: discord.DiscordMessage): Promise {\n try {\n // Skip processing bot messages\n if (message.author.bot) {\n return;\n }\n \n // Extract relevant information\n const { urls, domains } = db.extractLinks(message.content);\n const hasLinks = urls.length > 0;\n const isCommand = message.content.startsWith(\"/\");\n \n // Save the message\n const dbMessage: db.Message = {\n id: message.id,\n channel_id: message.channel_id,\n user_id: message.author.id,\n content: message.content,\n timestamp: new Date(message.timestamp).getTime(),\n has_links: hasLinks,\n is_command: isCommand\n };\n \n await db.saveMessage(dbMessage);\n \n // If the message contains links, process them\n if (hasLinks) {\n for (let i = 0; i < urls.length; i++) {\n const link: db.Link = {\n message_id: message.id,\n url: urls[i],\n domain: domains[i] || extractDomain(urls[i]),\n timestamp: new Date(message.timestamp).getTime()\n };\n \n await db.saveLink(link);\n }\n \n // Analyze and categorize links (optional step)\n await categorizeLinksByContent(message.id, message.content);\n }\n \n // Check if the message is in a project context\n const activeProject = await findActiveProject(message.channel_id);\n if (activeProject) {\n await db.addMessageToProject(activeProject.id!, message.id);\n }\n \n // Classify message into topics (can be run asynchronously)\n setTimeout(() => {\n classifyMessageIntoTopics(message.id, message.content).catch(err => {\n console.error(\"Error classifying message:\", err);\n });\n }, 0);\n } catch (error) {\n console.error(\"Error processing message:\", error);\n }\n}\n\n// Helper function to extract domain from URL\nfunction extractDomain(url: string): string {\n try {\n const domain = new URL(url).hostname;\n return domain;\n } catch (error) {\n return \"unknown\";\n }\n}\n\n// Find active project in a channel\nasync function findActiveProject(channelId: string): Promise {\n // This is a placeholder implementation\n // In a real system, you might store active projects per channel\n // or use message content to determine the project context\n return null;\n}\n\n// Use Claude to categorize links based on message content\nasync function categorizeLinksByContent(messageId: string, content: string): Promise {\n try {\n // Get the message that contains the links\n const message = await db.getMessage(messageId);\n if (!message || !message.has_links) {\n return;\n }\n \n // Use Claude to analyze the content and suggest categories\n const response = await anthropic.messages.create({\n model: \"claude-3-haiku-20240307\",\n max_tokens: 100,\n messages: [\n {\n role: \"user\",\n content: `This message contains one or more links. Based on the message content, what category would you assign to these links? Choose a single word or short phrase that best describes what these links are about. Only respond with the category name, nothing else.\n\nMessage content: \"${content}\"`\n }\n ],\n });\n \n const category = response.content[0].text.trim();\n \n // Update all links in this message with the suggested category\n const result = await sqlite.execute(\n `UPDATE links SET category = ? WHERE message_id = ?`,\n [category, messageId]\n );\n } catch (error) {\n console.error(\"Error categorizing links:\", error);\n }\n}\n\n// Use Claude to classify a message into topics\nasync function classifyMessageIntoTopics(messageId: string, content: string): Promise {\n try {\n // Skip short messages\n if (content.length < 20) {\n return;\n }\n \n // Get existing topics\n const topics = await db.getTopics();\n \n // Format topics for Claude\n const topicsText = topics.map(t => `${t.id}: ${t.name}`).join(\"\\n\");\n \n // Use Claude to classify the message\n const response = await anthropic.messages.create({\n model: \"claude-3-haiku-20240307\",\n max_tokens: 200,\n messages: [\n {\n role: \"user\",\n content: `You are classifying conversation messages into topics. I'll provide a message and a list of existing topics. Your task is to:\n\n1. Determine if the message fits into any of the existing topics\n2. If it does, return the topic IDs that match (can be multiple)\n3. If it doesn't fit any existing topic, suggest a new topic name\n\nExisting topics:\n${topicsText || \"No existing topics yet.\"}\n\nMessage: \"${content}\"\n\nReturn your answer in this exact format:\nEXISTING_TOPICS: [list of topic IDs, or \"none\"]\nNEW_TOPIC: [suggest a new topic name, or \"none\"]`\n }\n ],\n });\n \n const analysis = response.content[0].text;\n \n // Extract existing topics\n const existingTopicsMatch = analysis.match(/EXISTING_TOPICS:\\s*(.+)/i);\n const existingTopics = existingTopicsMatch ? existingTopicsMatch[1].trim() : \"none\";\n \n // Extract new topic suggestion\n const newTopicMatch = analysis.match(/NEW_TOPIC:\\s*(.+)/i);\n const newTopic = newTopicMatch ? newTopicMatch[1].trim() : \"none\";\n \n // Process existing topic assignments\n if (existingTopics !== \"none\") {\n const topicIds = existingTopics\n .replace(/[\\[\\]]/g, \"\")\n .split(\",\")\n .map(id => parseInt(id.trim(), 10))\n .filter(id => !isNaN(id));\n \n for (const topicId of topicIds) {\n await db.addMessageToTopic(topicId, messageId);\n }\n }\n \n // Create new topic if suggested\n if (newTopic !== \"none\") {\n const topicId = await db.createTopic({\n name: newTopic,\n created_at: Date.now()\n });\n \n if (topicId) {\n await db.addMessageToTopic(topicId, messageId);\n }\n }\n } catch (error) {\n console.error(\"Error classifying message:\", error);\n }\n}\n\n// Function to get relevant messages for answering a query\nexport async function getRelevantMessagesForQuery(query: string, userIds: string[], limit = 100): Promise {\n try {\n // First, search messages directly containing terms in the query\n let messages = await db.searchMessages(query, limit);\n \n // If we didn't find enough messages, expand the search\n if (messages.length < 10) {\n // Use Claude to extract key search terms\n const response = await anthropic.messages.create({\n model: \"claude-3-haiku-20240307\",\n max_tokens: 100,\n messages: [\n {\n role: \"user\",\n content: `Extract 3-5 key search terms from this query to help find relevant messages in a conversation database. Return ONLY the terms separated by commas, nothing else.\n\nQuery: \"${query}\"`\n }\n ],\n });\n \n const searchTerms = response.content[0].text.split(\",\").map(term => term.trim());\n \n // Search for each term and collect results\n for (const term of searchTerms) {\n if (term) {\n const termResults = await db.searchMessages(term, Math.round(limit / searchTerms.length));\n \n // Add unique messages\n for (const result of termResults) {\n if (!messages.some(m => m.id === result.id)) {\n messages.push(result);\n }\n \n // Stop if we've reached the limit\n if (messages.length >= limit) {\n break;\n }\n }\n }\n }\n }\n \n // If we still don't have enough results, add recent messages from these users\n if (messages.length < limit) {\n const recentMessages = await db.getMessagesByUserIds(userIds, limit - messages.length);\n \n // Add unique messages\n for (const result of recentMessages) {\n if (!messages.some(m => m.id === result.id)) {\n messages.push(result);\n }\n }\n }\n \n // Sort messages by timestamp (oldest first for conversation continuity)\n messages.sort((a, b) => a.timestamp - b.timestamp);\n \n return messages;\n } catch (error) {\n console.error(\"Error getting relevant messages:\", error);\n return [];\n }\n}\n\n// Function to format messages for Claude analysis\nexport function formatMessagesForClaudeAnalysis(messages: db.Message[], userMap: Map): string {\n let formattedMessages = \"\";\n \n for (const message of messages) {\n const username = userMap.get(message.user_id) || \"Unknown User\";\n const date = new Date(message.timestamp).toISOString().split(\"T\")[0];\n \n formattedMessages += `[${date}] ${username}: ${message.content}\\n\\n`;\n }\n \n return formattedMessages;\n}\n\n// Function to analyze messages with Claude\nexport async function analyzeMessagesWithClaude(messages: db.Message[], userMap: Map, query: string): Promise {\n try {\n const formattedMessages = formatMessagesForClaudeAnalysis(messages, userMap);\n \n const response = await anthropic.messages.create({\n model: \"claude-3-opus-20240229\", // Using our most capable model for deep analysis\n max_tokens: 1000,\n messages: [\n {\n role: \"user\",\n content: `You are analyzing conversations between a couple. Based on these message excerpts, please answer their question in a helpful way.\n \nMessage history:\n${formattedMessages}\n\nQuestion: ${query}\n\nPlease be concise but thorough in your answer, providing specific references to what they discussed when relevant.\nIf they're asking about items they've discussed (like furniture, products, etc.), try to include:\n1. Names/descriptions of items they mentioned\n2. Any opinions or preferences they expressed\n3. Links they shared if available\n4. A summary of their overall feelings on the topic`\n }\n ],\n });\n \n return response.content[0].text;\n } catch (error) {\n console.error(\"Error analyzing messages with Claude:\", error);\n return \"I'm sorry, I encountered an error while analyzing your conversations. Please try again with a different question.\";\n }\n}",[],[214,322],["D",1746302706739],[238,239,240,241,242,243],[214],"e8dd05b6-2859-11f0-8fb6-569c3dd06744","settings.local.json","e8dd064c-2859-11f0-8fb6-569c3dd06744",["D",1746302707146],"{\n \"permissions\": {\n \"allow\": [\n \"Bash(mkdir:*)\",\n \"Bash(mkdir:*)\"\n ],\n \"deny\": []\n }\n}",[],[220,333],["D",1746302706620],[236],[220],["D",1746161519737],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},{"_13":87,"_32":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"ctx",{"_80":-5,"_124":379,"_380":381,"_382":383,"_384":25,"_385":25,"_386":25,"_387":60,"_388":-5,"_389":-7,"_390":-7,"_391":153,"_392":25,"_393":25,"_394":-5,"_395":25,"_396":25,"_397":25,"_398":-5},"ENV",{"_350":351,"_352":353,"_354":88,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v31