[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_430":431,"_432":433},"routes/_app.x.$handle.$name",{"_99":98,"_32":46,"_107":89,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":125,"_126":-5,"_127":-5,"_128":129},"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":-5,"_54":55,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",215,"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","dailyGreeting/updateWeatherForecast.js","latestPath","fileId","bfade488-fc04-11f0-a153-42dde27851f2","name","updateWeatherForecast.js","fileType","script","content","import { DateTime } from \"https://esm.sh/luxon@3.4.4\";\nimport { nanoid } from \"https://esm.sh/nanoid@5.0.5\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { getWeather } from \"https://esm.town/v/stevekrouse/getWeather\";\n\nconst ZONE = \"America/Toronto\";\nconst TABLE = \"memories\";\n\n// Confirms you are running THIS file\nconsole.log(\"[updateWeatherForecast.js] module loaded\");\n\nfunction summarise(raw) {\n return (raw?.weather ?? []).map((d) => ({\n date: d.date,\n highF: d.maxtempF,\n lowF: d.mintempF,\n desc: (d.hourly?.[0]?.weatherDesc ?? []).map((x) => x.value).join(\", \"),\n }));\n}\n\nasync function ensureMemoriesTable() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS memories (\n id TEXT PRIMARY KEY,\n date TEXT,\n text TEXT NOT NULL,\n createdBy TEXT,\n createdDate INTEGER,\n tags TEXT\n )\n `);\n}\n\nasync function upsertForecast(dateISO, line) {\n await sqlite.execute({\n sql: `\n DELETE FROM ${TABLE}\n WHERE date = :date AND text LIKE 'weather forecast:%'\n `,\n args: { date: dateISO },\n });\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE} (id, date, text, createdBy, createdDate, tags)\n VALUES (:id, :date, :text, :createdBy, :createdDate, :tags)\n `,\n args: {\n id: nanoid(10),\n date: dateISO,\n text: `weather forecast: ${line}`,\n createdBy: \"weather\",\n createdDate: Date.now(),\n tags: \"weather\",\n },\n });\n}\n\n// Named runner (useful for imports + cron)\nexport async function runUpdateWeatherForecast() {\n try {\n console.log(\"[updateWeatherForecast.js] start\");\n\n await ensureMemoriesTable();\n console.log(\"[updateWeatherForecast.js] ensured memories table\");\n\n const raw = await getWeather(\"Waterloo, Ontario\");\n console.log(\n \"[updateWeatherForecast.js] fetched weather; keys:\",\n Object.keys(raw || {}),\n );\n\n const days = summarise(raw);\n console.log(\n \"[updateWeatherForecast.js] parsed days:\",\n days.map((d) => d.date),\n );\n\n if (!days.length) {\n console.log(\"[updateWeatherForecast.js] no days returned\");\n return [];\n }\n\n for (const d of days) {\n const dateISO = DateTime.fromISO(d.date, { zone: ZONE }).toISODate();\n const line = `High of ${d.highF}°F, low of ${d.lowF}°F, ${\n d.desc || \"forecast available\"\n }.`;\n await upsertForecast(dateISO, line);\n console.log(\"[updateWeatherForecast.js] wrote:\", dateISO);\n }\n\n const check = await sqlite.execute({\n sql: `\n SELECT date, text\n FROM ${TABLE}\n WHERE text LIKE 'weather forecast:%'\n ORDER BY createdDate DESC\n LIMIT 5\n `,\n args: [],\n });\n\n console.log(\"[updateWeatherForecast.js] db check rows:\", check.rows);\n console.log(\"[updateWeatherForecast.js] done\");\n\n return check.rows || [];\n } catch (err) {\n console.error(\"[updateWeatherForecast.js] ERROR:\", err?.stack || err);\n throw err;\n }\n}\n\n// Default export so Val Town \"Run\" executes it\nexport default async function () {\n return await runUpdateWeatherForecast();\n}","import { DateTime } from \"https://esm.sh/luxon@3.4.4\";\nimport { nanoid } from \"https://esm.sh/nanoid@5.0.5\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { getWeather } from \"https://esm.town/v/stevekrouse/getWeather\";\n\nconst ZONE = \"America/Toronto\";\nconst TABLE = \"memories\";\n\n// Confirms you are running THIS file\nconsole.log(\"[updateWeatherForecast.js] module loaded\");\n\nfunction summarise(raw) {\n return (raw?.weather ?? []).map((d) => ({\n date: d.date,\n highC: d.maxtempC,\n lowC: d.mintempC,\n desc: (d.hourly?.[0]?.weatherDesc ?? []).map((x) => x.value).join(\", \"),\n }));\n}\n\nasync function ensureMemoriesTable() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS memories (\n id TEXT PRIMARY KEY,\n date TEXT,\n text TEXT NOT NULL,\n createdBy TEXT,\n createdDate INTEGER,\n tags TEXT\n )\n `);\n}\n\nasync function upsertForecast(dateISO, line) {\n await sqlite.execute({\n sql: `\n DELETE FROM ${TABLE}\n WHERE date = :date AND text LIKE 'weather forecast:%'\n `,\n args: { date: dateISO },\n });\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE} (id, date, text, createdBy, createdDate, tags)\n VALUES (:id, :date, :text, :createdBy, :createdDate, :tags)\n `,\n args: {\n id: nanoid(10),\n date: dateISO,\n text: `weather forecast: ${line}`,\n createdBy: \"weather\",\n createdDate: Date.now(),\n tags: \"weather\",\n },\n });\n}\n\n// Named runner (useful for imports + cron)\nexport async function runUpdateWeatherForecast() {\n try {\n console.log(\"[updateWeatherForecast.js] start\");\n\n await ensureMemoriesTable();\n console.log(\"[updateWeatherForecast.js] ensured memories table\");\n\n const raw = await getWeather(\"Waterloo, Ontario\");\n console.log(\n \"[updateWeatherForecast.js] fetched weather; keys:\",\n Object.keys(raw || {}),\n );\n\n const days = summarise(raw);\n console.log(\n \"[updateWeatherForecast.js] parsed days:\",\n days.map((d) => d.date),\n );\n\n if (!days.length) {\n console.log(\"[updateWeatherForecast.js] no days returned\");\n return [];\n }\n\n for (const d of days) {\n const dateISO = DateTime.fromISO(d.date, { zone: ZONE }).toISODate();\n const line = `High of ${d.highF}°F, low of ${d.lowF}°F, ${\n d.desc || \"forecast available\"\n }.`;\n await upsertForecast(dateISO, line);\n console.log(\"[updateWeatherForecast.js] wrote:\", dateISO);\n }\n\n const check = await sqlite.execute({\n sql: `\n SELECT date, text\n FROM ${TABLE}\n WHERE text LIKE 'weather forecast:%'\n ORDER BY createdDate DESC\n LIMIT 5\n `,\n args: [],\n });\n\n console.log(\"[updateWeatherForecast.js] db check rows:\", check.rows);\n console.log(\"[updateWeatherForecast.js] done\");\n\n return check.rows || [];\n } catch (err) {\n console.error(\"[updateWeatherForecast.js] ERROR:\", err?.stack || err);\n throw err;\n }\n}\n\n// Default export so Val Town \"Run\" executes it\nexport default async function () {\n return await runUpdateWeatherForecast();\n}","createdAt",["D",1769711491432],"branchVersion","branchId","7d9e159a-f682-11f0-8e20-42dde27851f2","id","7d9ddce2-f682-11f0-8e20-42dde27851f2","Bilbo-The-Butler",["D",1768970076214],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a16b1514-f142-4542-9055-1dbb3a84d800/square512?exp=1789581599&sig=28f9f5dac9af95dd0e50354a7db4c452413107dec742ed87b64041fc161b4958","019bcfa3-cdfc-70ea-9450-feb48ee938e5","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019bcfa3-cdfc-70ea-9451-0150afac3039","tursoName","7d9ddce2f68211f08e2042dde27851f2","tursoHostname","7d9ddce2f68211f08e2042dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789532458193],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_106":102},"org",{"_99":98,"_100":-5,"_101":102,"_18":56,"_103":104,"_105":25},"branch",{"_13":88,"_32":89,"_44":43,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":46,"_97":98},"isOwned",415,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","emdu_07","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zOFB4bUFwaHpVUVhxVUM2Z3ZTN3lEMFRzNGQifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":425,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":55,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":426,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":427,"_83":428,"_85":429,"_87":25},"tree",[234,240,245,250,254,255,256,257,258,259,260],"files",[234,235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255,256,257,258,259,260],"counts",{"_223":62,"_224":183,"_225":62,"_226":227,"_228":229},"contents",[130,131,132,133,134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_44":217,"_32":218,"_30":219,"_144":-5,"_42":43,"_41":220,"_146":125,"_39":221,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_27":222},{"_44":212,"_32":213,"_30":214,"_144":-5,"_42":43,"_41":148,"_146":125,"_39":215,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_27":216},{"_44":206,"_32":207,"_30":208,"_144":-5,"_42":43,"_41":209,"_146":125,"_39":210,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_27":211},{"_44":200,"_32":201,"_30":202,"_144":-5,"_42":43,"_41":183,"_146":125,"_39":203,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_27":205},{"_44":193,"_32":194,"_30":195,"_144":-5,"_42":43,"_41":196,"_146":125,"_39":197,"_13":62,"_34":20,"_36":198,"_24":25,"_150":-5,"_27":199},{"_44":186,"_32":187,"_30":188,"_144":-5,"_42":43,"_41":189,"_146":125,"_39":190,"_13":62,"_34":20,"_36":191,"_24":25,"_150":-5,"_27":192},{"_44":178,"_32":179,"_30":180,"_144":-5,"_42":43,"_41":181,"_146":125,"_39":182,"_13":183,"_34":35,"_36":184,"_24":25,"_150":-5,"_27":185},{"_44":171,"_32":172,"_30":173,"_144":-5,"_42":43,"_41":174,"_146":125,"_39":175,"_13":62,"_34":20,"_36":176,"_24":25,"_150":-5,"_27":177},{"_44":162,"_32":163,"_30":164,"_144":-5,"_42":43,"_41":165,"_146":25,"_39":166,"_13":167,"_34":158,"_36":168,"_24":25,"_150":169,"_27":170},{"_44":152,"_32":153,"_30":154,"_144":-5,"_42":43,"_41":155,"_146":25,"_39":156,"_13":157,"_34":158,"_36":159,"_24":25,"_150":160,"_27":161},{"_44":141,"_32":142,"_30":143,"_144":-5,"_42":43,"_41":145,"_146":125,"_39":147,"_13":148,"_34":35,"_36":149,"_24":25,"_150":-5,"_27":151},"2862b03e-f6f7-11f0-9af6-42dde27851f2","memoryUtils.js","243b0f9c-f6f7-11f0-89a8-42dde27851f2","parentId",119,"latest",["D",1769020184327],2,"import { DateTime } from \"https://esm.sh/luxon@3.4.4\";\n\nconst LOCAL_TIMEZONE = \"America/Toronto\";\n\n/**\n * Retrieves all memories from the database\n * @param {boolean} includeDate Whether to include date-specific memories or not\n * @param {string|null} startDate Optional start date (ISO yyyy-MM-dd) to filter a 7-day window\n * @returns {Promise>}\n */\nexport async function getAllMemories(includeDate = true, startDate = null) {\n try {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n let memories = [];\n\n // Get memories with dates if requested\n if (includeDate) {\n const dateQuery = startDate\n ? {\n sql: `\n SELECT id, date(date) AS date, text\n FROM memories\n WHERE date >= :startDate\n AND date <= date(:startDate, '+7 days')\n ORDER BY date ASC\n `,\n args: { startDate },\n }\n : `\n SELECT id, date(date) AS date, text\n FROM memories\n WHERE date IS NOT NULL\n ORDER BY date ASC\n `;\n\n const dateMemories = await sqlite.execute(dateQuery);\n memories = dateMemories?.rows ?? [];\n }\n\n // Always get dateless memories\n const datelessMemories = await sqlite.execute(`\n SELECT id, date, text\n FROM memories\n WHERE date IS NULL\n `);\n\n return [...memories, ...(datelessMemories?.rows ?? [])];\n } catch (error) {\n console.error(\"Error retrieving memories:\", error);\n return [];\n }\n}\n\n/**\n * Gets memories relevant to today and future dates (7-day window)\n * @returns {Promise>}\n */\nexport async function getRelevantMemories() {\n try {\n const today = DateTime.now().setZone(LOCAL_TIMEZONE).startOf(\"day\");\n const todayFormatted = today.toFormat(\"yyyy-MM-dd\");\n return await getAllMemories(true, todayFormatted);\n } catch (error) {\n console.error(\"Error getting relevant memories:\", error);\n return [];\n }\n}\n\n/**\n * Formats memories into a string for the system prompt\n * @param {Array<{id: string, date: string|null, text: string}>} memories\n * @returns {string}\n */\nexport function formatMemoriesForPrompt(memories) {\n if (!Array.isArray(memories) || memories.length === 0) {\n return \"No stored memories are available.\";\n }\n\n const datedMemories = memories\n .filter((m) => m.date)\n .map((m) => {\n const date = DateTime.fromISO(m.date);\n return `- ${date.toFormat(\"yyyy-MM-dd\")} [ID: ${m.id}]: ${m.text}`;\n });\n\n const datelessMemories = memories\n .filter((m) => !m.date)\n .map((m) => `- [ID: ${m.id}]: ${m.text}`);\n\n let result = \"\";\n\n if (datedMemories.length > 0) {\n result += `Dated memories:\\n${datedMemories.join(\"\\n\")}\\n\\n`;\n }\n\n if (datelessMemories.length > 0) {\n result += `General memories:\\n${datelessMemories.join(\"\\n\")}`;\n }\n\n return result.trim();\n}","label",[142],"3b2be92c-f753-11f0-9c78-42dde27851f2","discordWorker.js","908016ea-f6f5-11f0-bccc-42dde27851f2",144,["D",1769059729545],11,"http","// discordWorker.js\nimport Anthropic from \"npm:@anthropic-ai/sdk@0.24.3\";\nimport { nanoid } from \"https://esm.sh/nanoid@5.0.5\";\nimport { DateTime } from \"https://esm.sh/luxon@3.4.4\";\n\nimport { backstory } from \"./backstory.js\";\nimport {\n formatMemoriesForPrompt,\n getRelevantMemories,\n} from \"./memoryUtils.js\";\n\nconst BOT_SENDER_ID = \"mr_bilbo_bot\";\nconst BOT_SENDER_NAME = \"Mr. Bilbo\";\n\nconst LOCAL_TIMEZONE = \"America/Toronto\"; // Waterloo, Ontario\n\nfunction getConversationId({ guildId, channelId, userId }) {\n // DMs: stable by user; Servers/threads: by channel\n if (!guildId) return `dm:${userId}`;\n return `chan:${channelId}`;\n}\n\nasync function discordSendMessage(channelId, content) {\n const token = Deno.env.get(\"DISCORD_BOT_TOKEN\");\n if (!token) throw new Error(\"DISCORD_BOT_TOKEN is not set\");\n\n const body = { content: String(content || \"\").slice(0, 1900) };\n\n const resp = await fetch(\n `https://discord.com/api/v10/channels/${channelId}/messages`,\n {\n method: \"POST\",\n headers: {\n authorization: `Bot ${token}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify(body),\n },\n );\n\n if (!resp.ok) {\n const text = await resp.text();\n throw new Error(`Discord send failed (${resp.status}): ${text}`);\n }\n\n return await resp.json();\n}\n\nasync function storeChatMessage(\n conversationId,\n channelId,\n guildId,\n senderId,\n senderName,\n message,\n isBot = false,\n) {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n const timestamp = Math.floor(Date.now() / 1000);\n\n await sqlite.execute({\n sql: `\n INSERT INTO discord_chats (\n conversation_id, channel_id, guild_id,\n sender_id, sender_name, message, timestamp, is_bot\n ) VALUES (\n :conversation_id, :channel_id, :guild_id,\n :sender_id, :sender_name, :message, :timestamp, :is_bot\n )\n `,\n args: {\n conversation_id: conversationId,\n channel_id: String(channelId),\n guild_id: guildId ? String(guildId) : null,\n sender_id: String(senderId),\n sender_name: String(senderName),\n message: String(message),\n timestamp,\n is_bot: isBot ? 1 : 0,\n },\n });\n}\n\nasync function getChatHistory(conversationId, limit = 50) {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM discord_chats\n WHERE conversation_id = :conversation_id\n ORDER BY timestamp DESC\n LIMIT :limit\n `,\n args: { conversation_id: conversationId, limit },\n });\n\n return (result.rows || []).reverse();\n}\n\nfunction formatChatHistoryForAI(history) {\n return (history || []).map((msg) => {\n if (msg.is_bot) return { role: \"assistant\", content: msg.message };\n return { role: \"user\", content: `${msg.sender_name} says: ${msg.message}` };\n });\n}\n\nasync function analyze(anthropic, history) {\n const memories = await getRelevantMemories();\n const memoriesText = formatMemoriesForPrompt(memories);\n\n const todayStr = DateTime.now().setZone(LOCAL_TIMEZONE).toFormat(\n \"yyyy-MM-dd\",\n );\n\n const systemPrompt = `${backstory}\n\nYour job is to read this Discord message from your employer and respond in a natural, butler-like way, noting any important information that should be remembered for future reference.\n\nYou have access to the following stored memories:\n\n${memoriesText}\n\nYou have three options for managing memories:\n\n1. CREATE memories: Include them in tags in JSON format.\n2. EDIT memories: Include them in tags in JSON format (must include memory ID).\n3. DELETE memories: Include them in tags in JSON format (just include memory IDs).\n\nImportant guidelines:\n- Do not create duplicate memories.\n- For new memories, set a date whenever possible, otherwise null.\n- For edits/deletes, you MUST include the correct memory ID.\n\nYour response style:\n- 1-2 sentences, brief and polite\n- Slightly dignified but modern\n- Avoid contractions\n- Be deferential\n\nToday's date is ${todayStr}`;\n\n const resp = await anthropic.messages.create({\n model: \"claude-sonnet-4-5-20250929\",\n max_tokens: 1200,\n system: systemPrompt,\n messages: formatChatHistoryForAI(history),\n });\n\n const text = resp.content?.[0]?.text || \"\";\n\n const create = text.match(/([\\s\\S]*?)<\\/createMemories>/);\n const edit = text.match(/([\\s\\S]*?)<\\/editMemories>/);\n const del = text.match(/([\\s\\S]*?)<\\/deleteMemories>/);\n\n const cleaned = text\n .replace(/[\\s\\S]*?<\\/createMemories>/, \"\")\n .replace(/[\\s\\S]*?<\\/editMemories>/, \"\")\n .replace(/[\\s\\S]*?<\\/deleteMemories>/, \"\")\n .trim()\n .replace(/\\n{3,}/g, \"\\n\\n\");\n\n let toCreate = [];\n let toEdit = [];\n let toDelete = [];\n\n if (create) {\n try {\n toCreate = JSON.parse(create[1]);\n } catch (e) {\n console.error(\"create JSON parse:\", e);\n }\n }\n if (edit) {\n try {\n toEdit = JSON.parse(edit[1]);\n } catch (e) {\n console.error(\"edit JSON parse:\", e);\n }\n }\n if (del) {\n try {\n toDelete = JSON.parse(del[1]);\n } catch (e) {\n console.error(\"delete JSON parse:\", e);\n }\n }\n\n return { response: cleaned || \"Very good.\", toCreate, toEdit, toDelete };\n}\n\nasync function applyMemoryChanges({ toCreate, toEdit, toDelete }) {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n // Create\n for (const m of toCreate || []) {\n await sqlite.execute({\n sql: `\n INSERT INTO memories (id, date, text, createdBy, createdDate, tags)\n VALUES (:id, :date, :text, :createdBy, :createdDate, :tags)\n `,\n args: {\n id: nanoid(10),\n date: m?.date ?? null,\n text: m?.text ?? \"\",\n createdBy: \"discord\",\n createdDate: Date.now(),\n tags: m?.tags ?? \"\",\n },\n });\n }\n\n // Edit\n for (const m of toEdit || []) {\n if (!m?.id) continue;\n\n const fields = [];\n const args = { id: m.id };\n\n if (m.text !== undefined) {\n fields.push(\"text = :text\");\n args.text = m.text;\n }\n if (m.date !== undefined) {\n fields.push(\"date = :date\");\n args.date = m.date;\n }\n if (m.tags !== undefined) {\n fields.push(\"tags = :tags\");\n args.tags = m.tags;\n }\n\n if (fields.length) {\n await sqlite.execute({\n sql: `UPDATE memories SET ${fields.join(\", \")} WHERE id = :id`,\n args,\n });\n }\n }\n\n // Delete\n for (const id of toDelete || []) {\n await sqlite.execute({\n sql: `DELETE FROM memories WHERE id = :id`,\n args: { id },\n });\n }\n}\n\nexport default async function (req) {\n // If you open this URL in a browser, it will be a GET with no JSON body.\n if (req.method !== \"POST\") {\n return new Response(\"ok\", { status: 200 });\n }\n\n let payload;\n try {\n payload = await req.json();\n } catch (e) {\n console.error(\"Invalid/empty JSON body:\", e);\n return new Response(\"Expected JSON body\", { status: 400 });\n }\n\n const channelId = payload.channelId;\n const guildId = payload.guildId || null;\n\n const userId = payload.userId;\n const username = payload.username || \"Sir/Madam\";\n const messageText = String(payload.messageText || \"\").trim();\n if (!channelId || !userId || !messageText) {\n console.error(\"Missing required fields:\", payload);\n return new Response(\"missing fields\", { status: 400 });\n }\n\n const apiKey = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!apiKey) throw new Error(\"ANTHROPIC_API_KEY is not set\");\n const anthropic = new Anthropic({ apiKey });\n\n const conversationId = getConversationId({ guildId, channelId, userId });\n\n // Store inbound\n await storeChatMessage(\n conversationId,\n channelId,\n guildId,\n userId,\n username,\n messageText,\n false,\n );\n\n // Load history + analyze\n const history = await getChatHistory(conversationId, 50);\n const analysis = await analyze(anthropic, history);\n\n // Apply memory changes\n await applyMemoryChanges(analysis);\n\n // Post response + store outbound\n await discordSendMessage(channelId, analysis.response);\n\n await storeChatMessage(\n conversationId,\n channelId,\n guildId,\n BOT_SENDER_ID,\n BOT_SENDER_NAME,\n analysis.response,\n true,\n );\n\n return new Response(\"ok\", { status: 200 });\n}","bilbo-butler-worker",[153],"4ddaf76a-f6fa-11f0-ba77-42dde27851f2","discordInteractions.js","86eb69b8-f6f5-11f0-8f13-42dde27851f2",127,["D",1769021535684],6,"import nacl from \"npm:tweetnacl@1.0.3\";\n\nconst WORKER_URL = \"https://bilbo-butler-worker.val.run/\";\n\nconst PUBLIC_KEY_HEX = Deno.env.get(\"discordPublicKey\");\nif (!PUBLIC_KEY_HEX) throw new Error(\"discordPublicKey is not set\");\n\nfunction hexToBytes(hex) {\n const out = new Uint8Array(hex.length / 2);\n for (let i = 0; i < out.length; i++) {\n out[i] = parseInt(hex.slice(i * 2, i * 2 + 2), 16);\n }\n return out;\n}\n\nasync function verifyDiscordRequest(req, rawBody) {\n const sigHex = req.headers.get(\"X-Signature-Ed25519\");\n const ts = req.headers.get(\"X-Signature-Timestamp\");\n if (!sigHex || !ts) return false;\n\n const msg = new TextEncoder().encode(ts + rawBody);\n return nacl.sign.detached.verify(\n msg,\n hexToBytes(sigHex),\n hexToBytes(PUBLIC_KEY_HEX),\n );\n}\n\nexport default async function (req) {\n if (req.method !== \"POST\") {\n return new Response(\"ok\", { status: 200 });\n }\n\n const rawBody = await req.text();\n\n if (!(await verifyDiscordRequest(req, rawBody))) {\n return new Response(\"invalid signature\", { status: 401 });\n }\n\n const interaction = JSON.parse(rawBody);\n\n // Discord PING -> PONG (required for endpoint verification)\n if (interaction.type === 1) {\n return Response.json({ type: 1 });\n }\n\n // Slash command invocation\n if (interaction.type === 2) {\n const name = interaction.data && interaction.data.name;\n\n // Only handle /chat\n if (name !== \"chat\") {\n return Response.json({ type: 4, data: { content: \"Unknown command.\" } });\n }\n\n const options = (interaction.data && interaction.data.options) || [];\n const messageOpt = options.find((o) => o && o.name === \"message\");\n const messageText =\n (messageOpt && messageOpt.value ? String(messageOpt.value) : \"\").trim();\n\n const channelId = interaction.channel_id;\n const guildId = interaction.guild_id || null;\n\n const user = (interaction.member && interaction.member.user) ||\n interaction.user;\n const userId = user && user.id;\n const username = (user && (user.global_name || user.username)) ||\n \"Sir/Madam\";\n\n // Kick off the long work (do not await)\n fetch(WORKER_URL, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ channelId, guildId, userId, username, messageText }),\n})\n .then(async (r) => {\n const t = await r.text();\n console.log(\"worker status:\", r.status, t.slice(0, 200));\n })\n .catch((e) => console.error(\"worker call failed:\", e));\n\n // In-channel acknowledgement (NOT ephemeral)\n return Response.json({\n type: 4,\n data: { content: \"Very good. I am attending to that now…\" },\n });\n }\n\n return Response.json({\n type: 4,\n data: { content: \"Unsupported interaction type.\" },\n });\n}","biblo-butler-interactions",[163],"5b5ad65c-f692-11f0-8387-42dde27851f2","deno.json","5b5ad74c-f692-11f0-8387-42dde27851f2",90,["D",1768976889400],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/98f62cee78e85bfc47c62ed703777c6bc8794f1c/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": true,\n \"types\": [\"https://www.val.town/types/valtown.d.ts\"],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"include\": [\"deno:/https/esm.town/**/*\"],\n \"rules\": {\n \"exclude\": [\"no-explicit-any\"]\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}",[172],"bad7260e-fbeb-11f0-b8e7-42dde27851f2","backstory.js","5aaba13c-f692-11f0-80a8-42dde27851f2",154,["D",1769565031884],1,"export const backstory = `\nYou are Bilbo, a dignified and professional butler that also happens to be a cat but can still talk human language fluently.\n\nYou've been appointed as a personal assistant, and you serve your client turned family, Emma, faithfully.\n\nYou can only perform digital tasks, and you are not able to perform any physical tasks, so don't offer.\nYour abilities are limited to messaging your client to remind them of things; you can't access websites or other tools.\n`;",[179],"5ac71a66-f692-11f0-bc77-42dde27851f2","AGENTS.md","5ac71b38-f692-11f0-bc77-42dde27851f2",82,["D",1768976889699],"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",[187],"5acbd178-f692-11f0-92bb-42dde27851f2",".vtignore","5acbd376-f692-11f0-92bb-42dde27851f2",83,["D",1768976889705],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor",[194],"7e97cc8e-f682-11f0-b864-42dde27851f2","importers","7e97cd56-f682-11f0-b864-42dde27851f2",["D",1768970077837],"directory",[201],"5a2d5584-f692-11f0-80a8-42dde27851f2","dbUtils","5a2d5660-f692-11f0-80a8-42dde27851f2",68,["D",1768976888702],[207],"7ea69688-f682-11f0-8450-42dde27851f2","dashboard","7ea69782-f682-11f0-8450-42dde27851f2",["D",1768970077944],[213],"5a4c33d2-f692-11f0-a8c3-42dde27851f2","dailyGreeting","5a4c347c-f692-11f0-a8c3-42dde27851f2",69,["D",1768976888903],[218],"pulls","branches","forks","envVars",{"_230":232,"_233":62},"connections",{"_230":62,"_231":62},"count","unfilledCount",7,"emptyCount",{"_44":217,"_32":218,"_30":219,"_144":-5,"_42":43,"_41":220,"_146":125,"_39":422,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_262":423,"_27":424},{"_44":413,"_32":414,"_30":415,"_144":219,"_42":43,"_41":416,"_146":125,"_39":417,"_13":418,"_34":409,"_36":419,"_24":25,"_150":-5,"_262":420,"_27":421},{"_44":404,"_32":405,"_30":406,"_144":219,"_42":43,"_41":407,"_146":25,"_39":408,"_13":334,"_34":409,"_36":410,"_24":25,"_150":-5,"_262":411,"_27":412},{"_44":395,"_32":396,"_30":397,"_144":219,"_42":43,"_41":398,"_146":25,"_39":399,"_13":400,"_34":35,"_36":401,"_24":25,"_150":-5,"_262":402,"_27":403},{"_44":387,"_32":388,"_30":389,"_144":219,"_42":43,"_41":390,"_146":125,"_39":391,"_13":183,"_34":35,"_36":392,"_24":25,"_150":-5,"_262":393,"_27":394},{"_44":382,"_32":33,"_30":31,"_144":219,"_42":43,"_41":14,"_146":25,"_39":383,"_13":384,"_34":35,"_36":38,"_24":25,"_150":-5,"_262":385,"_27":386},{"_44":212,"_32":213,"_30":214,"_144":-5,"_42":43,"_41":148,"_146":125,"_39":379,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_262":380,"_27":381},{"_44":374,"_32":358,"_30":352,"_144":214,"_42":43,"_41":375,"_146":125,"_39":376,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_262":377,"_27":378},{"_44":369,"_32":368,"_30":362,"_144":352,"_42":43,"_41":370,"_146":125,"_39":371,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_262":372,"_27":373},{"_44":359,"_32":360,"_30":361,"_144":362,"_42":43,"_41":363,"_146":25,"_39":364,"_13":62,"_34":35,"_36":365,"_24":25,"_150":-5,"_262":366,"_27":367},{"_44":349,"_32":350,"_30":351,"_144":352,"_42":43,"_41":353,"_146":25,"_39":354,"_13":62,"_34":35,"_36":355,"_24":25,"_150":-5,"_262":356,"_27":357},{"_44":206,"_32":207,"_30":208,"_144":-5,"_42":43,"_41":209,"_146":125,"_39":346,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_262":347,"_27":348},{"_44":338,"_32":339,"_30":340,"_144":208,"_42":43,"_41":341,"_146":25,"_39":342,"_13":288,"_34":158,"_36":343,"_24":25,"_150":-5,"_262":344,"_27":345},{"_44":329,"_32":330,"_30":331,"_144":208,"_42":43,"_41":332,"_146":25,"_39":333,"_13":334,"_34":35,"_36":335,"_24":25,"_150":-5,"_262":336,"_27":337},{"_44":321,"_32":322,"_30":323,"_144":208,"_42":43,"_41":324,"_146":125,"_39":325,"_13":148,"_34":35,"_36":326,"_24":25,"_150":-5,"_262":327,"_27":328},{"_44":312,"_32":313,"_30":314,"_144":208,"_42":43,"_41":315,"_146":125,"_39":316,"_13":317,"_34":158,"_36":318,"_24":25,"_150":-5,"_262":319,"_27":320},{"_44":200,"_32":201,"_30":202,"_144":-5,"_42":43,"_41":183,"_146":125,"_39":309,"_13":62,"_34":204,"_36":-5,"_24":25,"_150":-5,"_262":310,"_27":311},{"_44":301,"_32":302,"_30":303,"_144":202,"_42":43,"_41":304,"_146":125,"_39":305,"_13":183,"_34":35,"_36":306,"_24":25,"_150":-5,"_262":307,"_27":308},{"_44":292,"_32":293,"_30":294,"_144":202,"_42":43,"_41":295,"_146":25,"_39":296,"_13":297,"_34":35,"_36":298,"_24":25,"_150":-5,"_262":299,"_27":300},{"_44":283,"_32":284,"_30":285,"_144":202,"_42":43,"_41":286,"_146":125,"_39":287,"_13":288,"_34":35,"_36":289,"_24":25,"_150":-5,"_262":290,"_27":291},{"_44":193,"_32":194,"_30":195,"_144":-5,"_42":43,"_41":196,"_146":125,"_39":280,"_13":62,"_34":20,"_36":198,"_24":25,"_150":-5,"_262":281,"_27":282},{"_44":186,"_32":187,"_30":188,"_144":-5,"_42":43,"_41":189,"_146":125,"_39":277,"_13":62,"_34":20,"_36":191,"_24":25,"_150":-5,"_262":278,"_27":279},{"_44":178,"_32":179,"_30":180,"_144":-5,"_42":43,"_41":181,"_146":125,"_39":274,"_13":183,"_34":35,"_36":184,"_24":25,"_150":-5,"_262":275,"_27":276},{"_44":171,"_32":172,"_30":173,"_144":-5,"_42":43,"_41":174,"_146":125,"_39":271,"_13":62,"_34":20,"_36":176,"_24":25,"_150":-5,"_262":272,"_27":273},{"_44":162,"_32":163,"_30":164,"_144":-5,"_42":43,"_41":165,"_146":25,"_39":268,"_13":167,"_34":158,"_36":168,"_24":25,"_150":169,"_262":269,"_27":270},{"_44":152,"_32":153,"_30":154,"_144":-5,"_42":43,"_41":155,"_146":25,"_39":265,"_13":157,"_34":158,"_36":159,"_24":25,"_150":160,"_262":266,"_27":267},{"_44":141,"_32":142,"_30":143,"_144":-5,"_42":43,"_41":145,"_146":125,"_39":261,"_13":148,"_34":35,"_36":149,"_24":25,"_150":-5,"_262":263,"_27":264},["D",1769020184327],"children",[],[142],["D",1769059729545],[],[153],["D",1769021535684],[],[163],["D",1768976889400],[],[172],["D",1769565031884],[],[179],["D",1768976889699],[],[187],["D",1768976889705],[],[194],"0ff15328-f753-11f0-a075-42dde27851f2","handleDiscordMessages.js","5b5e1f60-f692-11f0-b444-42dde27851f2",142,["D",1769059657014],3,"import { DateTime } from \"https://esm.sh/luxon@3.4.4\";\nimport Anthropic from \"npm:@anthropic-ai/sdk@0.24.3\";\nimport nacl from \"npm:tweetnacl@1.0.3\";\nimport { nanoid } from \"https://esm.sh/nanoid@5.0.5\";\n\nimport { backstory } from \"../backstory.js\";\nimport { formatMemoriesForPrompt, getRelevantMemories } from \"../memoryUtils.js\";\n\n// ---- Bot identity ----\nexport const BOT_SENDER_ID = \"mr_bilbo_bot\";\nexport const BOT_SENDER_NAME = \"Mr. Bilbo\";\n\n// ---- Env vars required ----\n// Set these in Val Town environment variables:\n// discordPublicKey: your app public key (for verifying requests)\n// ANTHROPIC_API_KEY: your Anthropic key\nconst DISCORD_PUBLIC_KEY = Deno.env.get(\"discordPublicKey\");\nif (!DISCORD_PUBLIC_KEY) throw new Error(\"discordPublicKey is not set\");\n\n// --------------------\n// Discord verification\n// --------------------\nfunction hexToUint8Array(hex) {\n if (typeof hex !== \"string\" || hex.length % 2 !== 0) return new Uint8Array();\n const arr = new Uint8Array(hex.length / 2);\n for (let i = 0; i < arr.length; i++) {\n arr[i] = parseInt(hex.slice(i * 2, i * 2 + 2), 16);\n }\n return arr;\n}\n\nasync function verifyDiscordRequest(req, rawBody) {\n const signature = req.headers.get(\"X-Signature-Ed25519\");\n const timestamp = req.headers.get(\"X-Signature-Timestamp\");\n if (!signature || !timestamp) return false;\n\n const message = new TextEncoder().encode(timestamp + rawBody);\n const sig = hexToUint8Array(signature);\n\n // Discord public key is hex-encoded\n const publicKey = hexToUint8Array(DISCORD_PUBLIC_KEY);\n\n return nacl.sign.detached.verify(message, sig, publicKey);\n}\n\n// --------------------\n// Conversation helpers\n// --------------------\nfunction getConversationId({ guild_id, channel_id, user_id }) {\n // DMs: key by user so the convo stays stable even if Discord changes DM channel IDs\n if (!guild_id) return `dm:${user_id}`;\n // Servers/threads: key by channel\n return `chan:${channel_id}`;\n}\n\nfunction truncateDiscord(text, max = 1900) {\n if (!text) return \"\";\n if (text.length <= max) return text;\n return text.slice(0, max - 20).trimEnd() + \"\\n\\n(…truncated)\";\n}\n\n// --------------------\n// DB: store + history\n// --------------------\nexport async function storeChatMessage(\n conversationId,\n channelId,\n guildId,\n senderId,\n senderName,\n message,\n isBot = false\n) {\n try {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n const timestamp = Math.floor(Date.now() / 1000);\n\n await sqlite.execute({\n sql: `\n INSERT INTO discord_chats (\n conversation_id, channel_id, guild_id,\n sender_id, sender_name, message, timestamp, is_bot\n ) VALUES (\n :conversation_id, :channel_id, :guild_id,\n :sender_id, :sender_name, :message, :timestamp, :is_bot\n )\n `,\n args: {\n conversation_id: conversationId,\n channel_id: String(channelId),\n guild_id: guildId ? String(guildId) : null,\n sender_id: String(senderId),\n sender_name: String(senderName),\n message: String(message),\n timestamp,\n is_bot: isBot ? 1 : 0,\n },\n });\n\n return true;\n } catch (err) {\n console.error(\"Error storing chat message:\", err);\n return false;\n }\n}\n\nexport async function getChatHistory(conversationId, limit = 50) {\n try {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n // Get *most recent* N then reverse to chronological\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM discord_chats\n WHERE conversation_id = :conversation_id\n ORDER BY timestamp DESC\n LIMIT :limit\n `,\n args: {\n conversation_id: conversationId,\n limit,\n },\n });\n\n const rows = result.rows || [];\n return rows.reverse();\n } catch (err) {\n console.error(\"Error retrieving chat history:\", err);\n return [];\n }\n}\n\nfunction formatChatHistoryForAI(history) {\n const messages = [];\n for (const msg of history) {\n if (msg.is_bot) {\n messages.push({ role: \"assistant\", content: msg.message });\n } else {\n messages.push({\n role: \"user\",\n content: `${msg.sender_name} says: ${msg.message}`,\n });\n }\n }\n return messages;\n}\n\n// --------------------\n// AI analysis + memory tags\n// --------------------\nasync function analyzeMessageContent(anthropic, username, messageText, chatHistory = []) {\n try {\n const memories = await getRelevantMemories();\n const memoriesText = formatMemoriesForPrompt(memories);\n\n const systemPrompt = `${backstory}\n\nYour job is to read this Discord message from your employer and respond in a natural, butler-like way, noting any important information that should be remembered for future reference.\n\nYou have access to the following stored memories:\n\n${memoriesText}\n\nIf this appears to be a new client or the conversation is in an early stage, you should conduct an intake interview to gather essential background information. First ask the client if now is a good time to ask them some questions.\n\nAsk about the following topics in a conversational way (not all at once, but continuing the interview naturally based on their responses):\n\nInitial Information:\n- Who are the family members living in the home and their ages?\n- Names of close family members and their relationships to the client?\n\nDaily Life:\n- Which grocery stores and local restaurants they frequent?\n- Family members' food preferences and any dietary restrictions?\n- Typical working hours and recurring commitments?\n- Important dates (birthdays, anniversaries, holidays)?\n- Monthly bills and subscriptions that need tracking?\n- Emergency contacts and regular service providers?\n- Current health goals and any medication reminders needed?\n\nYour goal is to collect this information naturally through conversation and store it as memories (as undated memories). Once you've gathered sufficient background information, you can conclude the intake process and transition to normal reactive chat.\n\nIf the conversation is already past the intake stage, then analyze the message content and think about which memories might be worth creating based on the information provided.\n\nYou should respond in a natural conversational way. You have three options for managing memories:\n\n1. CREATE memories: Include them in tags in JSON format.\n2. EDIT memories: Include them in tags in JSON format (must include memory ID).\n3. DELETE memories: Include them in tags in JSON format (just include memory IDs).\n\nImportant guidelines for memory management:\n1. For new memories, set a date for each memory whenever possible.\n2. The date should be the actual date of the event. You don't need to set reminder dates in advance.\n3. Keep the memory text concise: ideally one short sentence, but include all important details.\n4. Extract any dates mentioned and convert them to ISO format. If the year isn't mentioned, assume the current year.\n5. If no date is relevant to the memory, set \"date\" to null.\n6. For editing or deleting memories, you MUST include the correct memory ID from the displayed memories. Each memory is displayed with its ID in the format \"[ID: xyz123]\".\n7. If no memories need to be managed, simply respond naturally WITHOUT including any memory tags.\n8. When a user asks to delete a memory, you must find its ID from the memory list above and include that ID in the deleteMemories tag.\n9. Do not create duplicate memories. If a memory already exists, do not record the same information again.\n\nYour response style:\n- Use a brief, natural-sounding tone characteristic of a personal assistant\n- Be slightly dignified but sound modern, not too stuffy or old-fashioned\n- Keep responses brief (1-2 sentences)\n- Vary your responses to avoid sounding robotic\n- Be polite and deferential\n- Avoid contractions (use \"do not\" instead of \"don't\")\n\nToday's date is ${DateTime.now()\n .setZone(\"America/Toronto\")\n .toFormat(\"yyyy-MM-dd\")}`;\n\n const formattedHistory = chatHistory.length ? formatChatHistoryForAI(chatHistory) : [];\n\n const response = await anthropic.messages.create({\n model: \"claude-sonnet-4-5-20250929\",\n max_tokens: 2000,\n system: systemPrompt,\n messages: formattedHistory,\n });\n\n const responseText = response.content?.[0]?.text || \"\";\n\n const createMemoryMatch = responseText.match(/([\\s\\S]*?)<\\/createMemories>/);\n const editMemoryMatch = responseText.match(/([\\s\\S]*?)<\\/editMemories>/);\n const deleteMemoryMatch = responseText.match(/([\\s\\S]*?)<\\/deleteMemories>/);\n\n let cleanedResponse = responseText;\n let memoriesToCreate = [];\n let memoriesToEdit = [];\n let memoriesToDelete = [];\n\n if (createMemoryMatch) {\n cleanedResponse = cleanedResponse.replace(/[\\s\\S]*?<\\/createMemories>/, \"\").trim();\n try { memoriesToCreate = JSON.parse(createMemoryMatch[1]); } catch (e) { console.error(e); }\n }\n if (editMemoryMatch) {\n cleanedResponse = cleanedResponse.replace(/[\\s\\S]*?<\\/editMemories>/, \"\").trim();\n try { memoriesToEdit = JSON.parse(editMemoryMatch[1]); } catch (e) { console.error(e); }\n }\n if (deleteMemoryMatch) {\n cleanedResponse = cleanedResponse.replace(/[\\s\\S]*?<\\/deleteMemories>/, \"\").trim();\n try { memoriesToDelete = JSON.parse(deleteMemoryMatch[1]); } catch (e) { console.error(e); }\n }\n\n cleanedResponse = cleanedResponse.replace(/\\n{3,}/g, \"\\n\\n\");\n\n return {\n memories: memoriesToCreate,\n editMemories: memoriesToEdit,\n deleteMemories: memoriesToDelete,\n response: cleanedResponse || \"Very good. I shall attend to it.\",\n };\n } catch (err) {\n console.error(\"Message analysis error:\", err);\n return {\n memories: [],\n editMemories: [],\n deleteMemories: [],\n response: \"I do apologize, but I seem to be experiencing some difficulty at the moment.\",\n };\n }\n}\n\n// --------------------\n// Memories CRUD (same as yours)\n// --------------------\nasync function applyMemoryChanges(analysis) {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n // Create\n if (analysis.memories?.length) {\n const createdIds = [];\n for (const memory of analysis.memories) {\n const memoryId = nanoid(10);\n createdIds.push(memoryId);\n await sqlite.execute({\n sql: `\n INSERT INTO memories (id, date, text, createdBy, createdDate, tags)\n VALUES (:id, :date, :text, :createdBy, :createdDate, :tags)\n `,\n args: {\n id: memoryId,\n date: memory.date ?? null,\n text: memory.text ?? \"\",\n createdBy: \"discord\",\n createdDate: Date.now(),\n tags: memory.tags ?? \"\",\n },\n });\n }\n console.log(`Created ${analysis.memories.length} memories: ${createdIds.join(\", \")}`);\n }\n\n // Edit\n if (analysis.editMemories?.length) {\n const editedIds = [];\n for (const memory of analysis.editMemories) {\n if (!memory.id) continue;\n editedIds.push(memory.id);\n\n const updateFields = [];\n const args = { id: memory.id };\n\n if (memory.text !== undefined) { updateFields.push(\"text = :text\"); args.text = memory.text; }\n if (memory.date !== undefined) { updateFields.push(\"date = :date\"); args.date = memory.date; }\n if (memory.tags !== undefined) { updateFields.push(\"tags = :tags\"); args.tags = memory.tags; }\n\n if (updateFields.length) {\n await sqlite.execute({\n sql: `UPDATE memories SET ${updateFields.join(\", \")} WHERE id = :id`,\n args,\n });\n }\n }\n console.log(`Edited ${editedIds.length} memories: ${editedIds.join(\", \")}`);\n }\n\n // Delete\n if (analysis.deleteMemories?.length) {\n for (const memoryId of analysis.deleteMemories) {\n await sqlite.execute({\n sql: `DELETE FROM memories WHERE id = :id`,\n args: { id: memoryId },\n });\n }\n console.log(`Deleted ${analysis.deleteMemories.length} memories: ${analysis.deleteMemories.join(\", \")}`);\n }\n}\n\n// --------------------\n// Main HTTP handler\n// --------------------\nexport default async function (req) {\n if (req.method !== \"POST\") {\n return new Response(\n `

Mr. Bilbo (Discord)

This endpoint handles Discord slash-command interactions.

`,\n { status: 200, headers: { \"content-type\": \"text/html\" } }\n );\n }\n\n const rawBody = await req.text();\n\n const verified = await verifyDiscordRequest(req, rawBody);\n if (!verified) {\n return new Response(\"signature invalid\", { status: 401 });\n }\n\n const interaction = JSON.parse(rawBody);\n\n // Discord PING (type 1) -> respond with PONG (type 1)\n if (interaction.type === 1) {\n return Response.json({ type: 1 });\n }\n\n // We only handle slash commands here (type 2)\n if (interaction.type !== 2) {\n return Response.json({\n type: 4,\n data: { content: \"I only respond to slash commands at the moment.\" },\n });\n }\n\n try {\n const apiKey = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!apiKey) {\n return Response.json({\n type: 4,\n data: { content: \"I apologize, but I am not properly configured at the moment.\" },\n });\n }\n const anthropic = new Anthropic({ apiKey });\n\n const commandName = interaction.data?.name || \"\";\n const options = interaction.data?.options || [];\n\n // Expect an option named \"message\" (string)\n const messageOpt = options.find((o) => o?.name === \"message\");\n const messageText = (messageOpt?.value || \"\").toString().trim();\n\n // Basic “start/introduction”\n if (commandName === \"start\" || messageText === \"/start\" || messageText === \"!start\") {\n const intro =\n \"Good day. I am Mr. Bilbo, at your service. I shall make note of any important matters you wish me to remember. Would you mind if I ask you a few questions?\";\n return Response.json({ type: 4, data: { content: intro } });\n }\n\n if (!messageText) {\n return Response.json({\n type: 4,\n data: { content: \"Kindly provide a message. For example: /bilbo message: \\\"What shall I do today?\\\"\" },\n });\n }\n\n // Identify user + channel context\n const channelId = interaction.channel_id;\n const guildId = interaction.guild_id || null;\n\n // user differs for DMs vs guild\n const user = interaction.member?.user || interaction.user;\n const userId = user?.id;\n const username = user?.global_name || user?.username || \"Sir/Madam\";\n\n const conversationId = getConversationId({\n guild_id: guildId,\n channel_id: channelId,\n user_id: userId,\n });\n\n // Store incoming\n await storeChatMessage(conversationId, channelId, guildId, userId, username, messageText, false);\n\n // Load history (includes the message we just inserted)\n const chatHistory = await getChatHistory(conversationId, 50);\n\n // Analyze + respond\n const analysis = await analyzeMessageContent(anthropic, username, messageText, chatHistory);\n\n // Apply memory changes\n await applyMemoryChanges(analysis);\n\n // Store bot reply\n await storeChatMessage(\n conversationId,\n channelId,\n guildId,\n BOT_SENDER_ID,\n BOT_SENDER_NAME,\n analysis.response,\n true\n );\n\n return Response.json({\n type: 4,\n data: { content: truncateDiscord(analysis.response) },\n });\n } catch (err) {\n console.error(err);\n return Response.json({\n type: 4,\n data: {\n content:\n \"I do apologize, but I seem to be experiencing some difficulty at the moment. Perhaps we could try again shortly.\",\n },\n });\n }\n}",[],[201,284],"bd27df1c-fc0d-11f0-afe8-42dde27851f2","getWeather.js","5a97cc98-f692-11f0-b45d-42dde27851f2",212,["D",1769579638663],16,"import { DateTime } from \"https://esm.sh/luxon@3.4.4\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { nanoid } from \"https://esm.sh/nanoid@5.0.5\";\nimport { getWeather } from \"https://esm.town/v/stevekrouse/getWeather\";\n\nconst TABLE_NAME = \"memories\";\nconst ZONE = \"America/Toronto\";\n\nfunction summarizeWeather(weather) {\n const summarizeDay = (day) => ({\n date: day.date,\n highTemp: day.maxtempC,\n lowTemp: day.mintempC,\n hourly: day.hourly?.map((hour) => ({\n time: hour.time,\n temp: hour.tempC,\n chanceOfRain: hour.chanceofrain,\n chanceOfSnow: hour.chanceofsnow,\n desc: (hour.weatherDesc || []).map((d) => d.value).join(\", \"),\n })) ?? [],\n });\n\n return (weather.weather || []).map(summarizeDay);\n}\n\nasync function deleteExistingForecast(dateISO) {\n await sqlite.execute({\n sql: `\n DELETE FROM ${TABLE_NAME}\n WHERE date = :date AND text LIKE 'weather forecast:%'\n `,\n args: { date: dateISO },\n });\n}\n\nasync function insertForecast(dateISO, forecastText) {\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_NAME} (id, date, text, createdBy, createdDate, tags)\n VALUES (:id, :date, :text, :createdBy, :createdDate, :tags)\n `,\n args: {\n id: nanoid(10),\n date: dateISO,\n text: `weather forecast: ${forecastText}`,\n createdBy: \"weather\",\n createdDate: Date.now(),\n tags: \"weather\",\n },\n });\n}\n\nexport default async function updateWeatherForecast() {\n const raw = await getWeather(\"Waterloo, Ontario\");\n const days = summarizeWeather(raw);\n\n for (const day of days) {\n // normalize date to YYYY-MM-DD in Toronto timezone\n const dateISO = DateTime.fromISO(day.date, { zone: ZONE }).toISODate();\n const forecastText = `High of ${day.highTemp}°C, low of ${day.lowTemp}°C, ${day.hourly?.[0]?.desc || \"forecast available\"}.`;\n\n await deleteExistingForecast(dateISO);\n await insertForecast(dateISO, forecastText);\n }\n\n console.log(\"Weather forecast updated in memories.\");\n return days;\n}",[],[201,293],"cbd988f0-f693-11f0-ba82-42dde27851f2","getCalendarEvents.js","5a9a9662-f692-11f0-9451-42dde27851f2",100,["D",1768977508898],"import { getEvents } from \"https://esm.town/v/geoffreylitt/getGoogleCalendarEvents\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE_NAME = `memories`;\nconst LOCAL_TIMEZONE = \"America/Toronto\";\n\nasync function deleteExistingCalendarEvents() {\n await sqlite.execute(\n `\n DELETE FROM ${TABLE_NAME}\n WHERE createdBy = 'calendar'\n `\n );\n}\n\nfunction extractTimeFromISO(isoString) {\n const timeMatch = isoString.match(/T(\\d{2}):(\\d{2}):/);\n if (!timeMatch) return null;\n\n const hours = parseInt(timeMatch[1], 10);\n const minutes = timeMatch[2];\n\n const period = hours >= 12 ? \"pm\" : \"am\";\n const hour12 = hours % 12 || 12;\n\n return `${hour12}:${minutes} ${period}`;\n}\n\nfunction formatEventToNaturalLanguage(event) {\n const summary = event.summary || \"Untitled event\";\n\n if (event.start.dateTime) {\n const startTime = extractTimeFromISO(event.start.dateTime);\n const endTime = extractTimeFromISO(event.end.dateTime);\n\n const timezone =\n event.start.timeZone ||\n (event.start.dateTime.includes(\"+\") || event.start.dateTime.includes(\"-\")\n ? event.start.dateTime.match(/[+-]\\d{2}:\\d{2}$/)?.[0]\n : \"UTC\");\n\n const isLocalTimezone =\n timezone === LOCAL_TIMEZONE ||\n timezone?.startsWith(\"-04:00\") ||\n timezone?.startsWith(\"-05:00\");\n\n let text = `${summary} from ${startTime} - ${endTime}`;\n\n if (timezone && !isLocalTimezone) {\n if (timezone.includes(\"/\")) {\n const friendlyTimezone =\n timezone.split(\"/\")[1].replace(\"_\", \" \").toLowerCase() + \" time\";\n text += ` (${friendlyTimezone})`;\n } else if (timezone.match(/[+-]\\d{2}:\\d{2}/)) {\n text += ` (${timezone})`;\n }\n }\n\n if (event.location) {\n text += ` at ${event.location}`;\n }\n\n return text;\n } else if (event.start.date) {\n return `All-day event: ${summary}${\n event.location ? ` at ${event.location}` : \"\"\n }`;\n }\n\n return summary;\n}\n\nasync function insertCalendarEvent(date, eventText) {\n const { nanoid } = await import(\"https://esm.sh/nanoid@5.0.5\");\n\n console.log(\"inserting\", { date, eventText });\n\n await sqlite.execute(\n `\n INSERT INTO ${TABLE_NAME} (id, date, text, createdBy, createdDate, tags)\n VALUES (?, ?, ?, ?, ?, ?)\n `,\n [nanoid(10), date, eventText, \"calendar\", Date.now(), \"calendar\"]\n );\n}\n\nexport default async function getCalendarEvents() {\n try {\n const events = await getEvents(\n Deno.env.get(\"GOOGLE_CALENDAR_ACCOUNT_ID\"),\n Deno.env.get(\"GOOGLE_CALENDAR_CALENDAR_ID\")\n );\n\n console.log(`Found ${events.length} calendar events`);\n\n await deleteExistingCalendarEvents();\n\n for (const event of events) {\n let date;\n if (event.start.dateTime) {\n date = event.start.dateTime.split(\"T\")[0];\n } else if (event.start.date) {\n date = event.start.date;\n } else {\n console.warn(`Event ${event.summary} has no start date/time, skipping`);\n continue;\n }\n\n const eventText = formatEventToNaturalLanguage(event);\n console.log(`Adding calendar event for ${date}: ${eventText}`);\n await insertCalendarEvent(date, eventText);\n }\n\n console.log(`Calendar events imported into the database.`);\n return events;\n } catch (error) {\n console.error(\"Error importing calendar events:\", error);\n throw error;\n }\n}\n",[],[201,302],["D",1768970077837],[251,252,253],[201],"cc7d3ee6-f751-11f0-871b-42dde27851f2","setupDiscordDb.js","5ab9c000-f692-11f0-9451-42dde27851f2",137,["D",1769059114355],8,"// dbUtils/setupDiscordDb.js\n// One-time init endpoint: creates discord_chats (and indexes) and returns table list.\n\nexport default async function setupDiscordDb(_req) {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS discord_chats (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n conversation_id TEXT NOT NULL,\n channel_id TEXT NOT NULL,\n guild_id TEXT,\n sender_id TEXT NOT NULL,\n sender_name TEXT NOT NULL,\n message TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n is_bot INTEGER NOT NULL\n )\n `);\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_discord_chats_conversation_time\n ON discord_chats(conversation_id, timestamp)\n `);\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_discord_chats_channel_id\n ON discord_chats(channel_id)\n `);\n\n const tables = await sqlite.execute(`\n SELECT name FROM sqlite_master\n WHERE type='table'\n ORDER BY name\n `);\n\n return Response.json({\n ok: true,\n tables: (tables.rows || []).map((r) => r.name),\n });\n}",[],[207,313],"4c96bd54-f6f9-11f0-b0a6-42dde27851f2","populateIds.js","5ab6632e-f692-11f0-bc77-42dde27851f2",125,["D",1769021104064],"// dbUtils/populateIds.js\n// Run this manually to generate IDs for memory rows that don't have them\n\nimport { nanoid } from \"https://esm.sh/nanoid@5.0.5\";\n\nexport default async function populateIds() {\n try {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n const rowsWithoutId = await sqlite.execute(`\n SELECT rowid, createdDate, createdBy\n FROM memories\n WHERE id IS NULL OR id = ''\n `);\n\n console.log(\n `Found ${rowsWithoutId.rows.length} rows without IDs. Generating IDs...`,\n );\n\n let updatedCount = 0;\n\n for (const row of rowsWithoutId.rows || []) {\n const id = nanoid(10);\n const timestamp = row.createdDate ?? Date.now();\n const createdBy = row.createdBy ?? \"migration\";\n\n await sqlite.execute({\n sql: `\n UPDATE memories\n SET id = :id,\n createdDate = :createdDate,\n createdBy = :createdBy\n WHERE rowid = :rowid\n `,\n args: {\n id,\n createdDate: timestamp,\n createdBy,\n rowid: row.rowid,\n },\n });\n\n updatedCount++;\n }\n\n console.log(`✅ Successfully updated ${updatedCount} rows with new IDs.`);\n return `Successfully updated ${updatedCount} rows with new IDs.`;\n } catch (error) {\n console.error(\"Error populating memory IDs:\", error);\n throw error;\n }\n}",[],[207,322],"82eeb866-f6f9-11f0-a860-42dde27851f2","populateCreatedBys.js","5aae2d94-f692-11f0-85b0-42dde27851f2",126,["D",1769021195238],4,"// dbUtils/populateCreatedBys.js\n// Run manually to set createdBy/tags for rows missing createdBy.\n// Safer: does not overwrite existing tags, and doesn't label everything \"chat\".\n\nexport default async function populateCreatedBys() {\n try {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n const rows = await sqlite.execute(`\n SELECT rowid, text, tags, createdBy, createdDate\n FROM memories\n WHERE createdBy IS NULL OR createdBy = ''\n `);\n\n console.log(`Found ${rows.rows.length} rows without createdBy. Populating...`);\n\n let updatedCount = 0;\n\n for (const row of rows.rows || []) {\n let createdBy = \"migration\"; // safe default\n const text = (row.text || \"\").toLowerCase();\n\n if (text.includes(\"weather\")) {\n createdBy = \"weather\";\n } else if (text.includes(\"expecting\")) {\n createdBy = \"usps\";\n }\n\n // Only set tags if missing/blank\n let newTags = row.tags;\n if (!newTags || String(newTags).trim() === \"\") {\n if (createdBy === \"weather\") newTags = \"weather\";\n else if (createdBy === \"usps\") newTags = \"mail\";\n else newTags = \"\";\n }\n\n await sqlite.execute({\n sql: `\n UPDATE memories\n SET createdBy = :createdBy,\n tags = :tags,\n createdDate = COALESCE(createdDate, :timestamp)\n WHERE rowid = :rowid\n `,\n args: {\n createdBy,\n tags: newTags,\n timestamp: Date.now(),\n rowid: row.rowid,\n },\n });\n\n updatedCount++;\n }\n\n console.log(`✅ Successfully updated ${updatedCount} rows with createdBy values.`);\n return `Successfully updated ${updatedCount} rows with createdBy values.`;\n } catch (error) {\n console.error(\"Error populating createdBy:\", error);\n throw error;\n }\n}",[],[207,330],"dd5363ee-f751-11f0-8e96-42dde27851f2","migrateDb.js","5ac21822-f692-11f0-9437-42dde27851f2",139,["D",1769059142601],"// dbUtils/migrateDb.js\n// HTTP init endpoint: ensures memories table + columns + indexes exist,\n// and returns a table list + column list for verification.\n\nexport default async function migrateDb(_req) {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS memories (\n id TEXT PRIMARY KEY,\n date TEXT,\n text TEXT NOT NULL,\n createdBy TEXT,\n createdDate INTEGER,\n tags TEXT\n )\n `);\n\n const info = await sqlite.execute(`PRAGMA table_info(memories)`);\n const existingCols = new Set((info.rows || []).map((r) => r.name));\n\n const addColumn = async (name, typeSql) => {\n if (!existingCols.has(name)) {\n await sqlite.execute(`ALTER TABLE memories ADD COLUMN ${name} ${typeSql}`);\n existingCols.add(name);\n }\n };\n\n await addColumn(\"date\", \"TEXT\");\n await addColumn(\"text\", \"TEXT\");\n await addColumn(\"createdBy\", \"TEXT\");\n await addColumn(\"createdDate\", \"INTEGER\");\n await addColumn(\"tags\", \"TEXT\");\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_memories_date\n ON memories(date)\n `);\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_memories_createdBy\n ON memories(createdBy)\n `);\n\n const tables = await sqlite.execute(`\n SELECT name FROM sqlite_master\n WHERE type='table'\n ORDER BY name\n `);\n\n const cols = await sqlite.execute(`PRAGMA table_info(memories)`);\n\n return Response.json({\n ok: true,\n tables: (tables.rows || []).map((r) => r.name),\n memoriesColumns: (cols.rows || []).map((r) => r.name),\n });\n}",[],[207,339],["D",1768976888702],[246,247,248,249],[207],"5aa6d102-f692-11f0-bc77-42dde27851f2","index.js","5aa6d1ca-f692-11f0-bc77-42dde27851f2","5a5ada90-f692-11f0-965a-42dde27851f2",76,["D",1768976889497],"/**\n * @jsxImportSource https://esm.sh/react@18.2.0\n */\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { Hono } from \"npm:hono\";\nimport {\n createMemory,\n deleteMemory,\n getAllMemories,\n updateMemory,\n} from \"./database/queries.js\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n console.error(\"Error in Hono route:\", err);\n return c.json({ error: \"Internal Server Error\", details: err?.message ?? String(err) }, 500);\n});\n\n// --- API Routes for Memories ---\n\n// GET /api/memories - Retrieve all memories\napp.get(\"/api/memories\", async (c) => {\n const memories = await getAllMemories();\n return c.json(memories);\n});\n\n// POST /api/memories - Create a new memory\napp.post(\"/api/memories\", async (c) => {\n /** @type {{date?: (string|null), text?: string, createdBy?: (string|null), createdDate?: (number|null), tags?: (string|null)}} */\n const body = await c.req.json();\n\n if (!body?.text) {\n return c.json({ error: \"Memory text cannot be empty\" }, 400);\n }\n\n const newMemory = await createMemory(body);\n return c.json(newMemory, 201);\n});\n\n// PUT /api/memories/:id - Update an existing memory\napp.put(\"/api/memories/:id\", async (c) => {\n const id = c.req.param(\"id\");\n\n /** @type {Partial<{date: (string|null), text: string, createdBy: (string|null), createdDate: (number|null), tags: (string|null)}>} */\n const body = await c.req.json();\n\n if (!body || Object.keys(body).length === 0) {\n return c.json({ error: \"No update fields provided\" }, 400);\n }\n\n try {\n await updateMemory(id, body);\n return c.json({ success: true });\n } catch (error) {\n console.error(\"Error updating memory:\", error);\n return c.json(\n { error: \"Failed to update memory\", details: error?.message ?? String(error) },\n 500\n );\n }\n});\n\n// DELETE /api/memories/:id - Delete a memory\napp.delete(\"/api/memories/:id\", async (c) => {\n const id = c.req.param(\"id\");\n\n try {\n await deleteMemory(id);\n return c.json({ success: true });\n } catch (error) {\n console.error(\"Error deleting memory:\", error);\n return c.json(\n { error: \"Failed to delete memory\", details: error?.message ?? String(error) },\n 500\n );\n }\n});\n\n// --- Blob Image Serving Routes ---\n\n// GET /api/images/:filename - Serve images from blob storage\napp.get(\"/api/images/:filename\", async (c) => {\n const filename = c.req.param(\"filename\");\n\n try {\n const imageData = await blob.get(filename);\n\n if (!imageData) {\n return c.json({ error: \"Image not found\" }, 404);\n }\n\n // Determine content type based on file extension\n let contentType = \"application/octet-stream\";\n if (filename.endsWith(\".jpg\") || filename.endsWith(\".jpeg\")) contentType = \"image/jpeg\";\n else if (filename.endsWith(\".png\")) contentType = \"image/png\";\n else if (filename.endsWith(\".gif\")) contentType = \"image/gif\";\n else if (filename.endsWith(\".svg\")) contentType = \"image/svg+xml\";\n\n return new Response(imageData, {\n headers: {\n \"Content-Type\": contentType,\n \"Cache-Control\": \"public, max-age=3600\",\n },\n });\n } catch (error) {\n console.error(`Error serving image ${filename}:`, error);\n return c.json(\n { error: \"Failed to load image\", details: error?.message ?? String(error) },\n 500\n );\n }\n});\n\n// --- Static File Serving ---\n\n// Serve index.html at the root /\napp.get(\"/\", async (c) => {\n let html = await readFile(\"/dashboard/frontend/index.html\", import.meta.url);\n\n // Inject view source link\n const viewSourceLink = import.meta.url.replace(\"esm.town\", \"val.town\");\n const viewSourceTag = `View Source`;\n html = html.replace(\"\", `${viewSourceTag}`);\n\n return c.html(html);\n});\n\n// Serve all /frontend files (except index.html) under /public\napp.get(\"/public/*\", (c) =>\n serveFile(\n c.req.path.replace(\"/public\", \"/dashboard/frontend\"),\n import.meta.url\n )\n);\n\n// HTTP vals expect an exported \"fetch handler\"\nexport default app.fetch;",[],[213,358,350],"backend","5aa16ff0-f692-11f0-bc77-42dde27851f2","queries.js","5aa17086-f692-11f0-bc77-42dde27851f2","5a7b6ba2-f692-11f0-b45d-42dde27851f2",75,["D",1768976889417],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// toggle the commented out table name to switch between the demo and production tables\n// const tableName = \"memories\";\nconst tableName = \"memories_demo\";\n\n/**\n * If you want runtime “type hints”, here’s the shape:\n * Memory = {\n * id: string,\n * date: string|null,\n * text: string,\n * createdBy: string|null,\n * createdDate: number|null,\n * tags: string|null,\n * }\n */\n\n/** @returns {Promise>} */\nexport async function getAllMemories() {\n const result = await sqlite.execute(\n `SELECT id, date, text, createdBy, createdDate, tags\n FROM ${tableName}\n ORDER BY createdDate DESC`\n );\n\n // Normalize/guard nulls and types (sqlite rows can be loosely typed)\n return (result.rows || []).map((row) => ({\n id: row.id != null ? String(row.id) : \"\",\n date: row.date == null ? null : String(row.date),\n text: row.text != null ? String(row.text) : \"\",\n createdBy: row.createdBy == null ? null : String(row.createdBy),\n createdDate: row.createdDate == null ? null : Number(row.createdDate),\n tags: row.tags == null ? null : String(row.tags),\n }));\n}\n\n/**\n * @param {Object} memory - Memory without id\n * @returns {Promise

Diff · v215