${msg}

`,\n 500\n );\n }\n\n return c.json(\n { error: \"Internal Server Error\", details: err?.message ?? String(err) },\n 500\n );\n});\n\n// --- Helpers (Blob reading + content types) ---\n\nasync function blobToBytes(data) {\n // Val Town blob.get can return a Response (stream). If so, read it directly.\n if (data instanceof Response) {\n return new Uint8Array(await data.arrayBuffer());\n }\n // Otherwise treat as BodyInit-ish.\n return new Uint8Array(await new Response(data).arrayBuffer());\n}\n\nfunction contentTypeFor(filename) {\n const lower = String(filename).toLowerCase();\n if (lower.endsWith(\".png\")) return \"image/png\";\n if (lower.endsWith(\".jpg\") || lower.endsWith(\".jpeg\")) return \"image/jpeg\";\n if (lower.endsWith(\".gif\")) return \"image/gif\";\n if (lower.endsWith(\".svg\")) return \"image/svg+xml\";\n if (lower.endsWith(\".webp\")) return \"image/webp\";\n return \"application/octet-stream\";\n}\n\n// --- API Routes for Memories ---\n\napp.get(\"/api/memories\", async (c) => {\n const memories = await getAllMemories();\n return c.json(memories);\n});\n\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\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 await updateMemory(id, body);\n return c.json({ success: true });\n});\n\napp.delete(\"/api/memories/:id\", async (c) => {\n const id = c.req.param(\"id\");\n\n await deleteMemory(id);\n return c.json({ success: true });\n});\n\n// --- Blob Image Serving Routes ---\n\n// --- TEMP: upload a background image into THIS backend's blob store ---\napp.get(\"/api/upload_bg\", (c) =>\n c.html(`\n

Upload logbook_bg.png (to this app's blob store)

\n \n

Then check /api/blob_keys

\n `)\n);\n\napp.post(\"/api/upload_bg\", async (c) => {\n const form = await c.req.formData();\n const file = form.get(\"file\");\n if (!(file instanceof File)) return c.text(\"Missing file\", 400);\n\n const bytes = new Uint8Array(await file.arrayBuffer());\n await blob.set(\"logbook_bg.png\", bytes);\n\n return c.html(`\n

Uploaded logbook_bg.png (${bytes.byteLength} bytes)

\n `);\n});\n\napp.get(\"/api/blob_keys\", async (c) => {\n const keys = await blob.list();\n return c.json({ keys });\n});\n\napp.get(\"/api/images/:filename\", async (c) => {\n const filename = c.req.param(\"filename\");\n console.log(\"images route filename =\", filename);\n\n let data;\n try {\n data = await blob.get(filename);\n } catch (e) {\n console.log(\"blob.get threw for\", filename, e?.name, e?.message);\n return c.json({ error: \"Image not found\", filename, threw: String(e?.name ?? e) }, 404);\n }\n\n if (!data) {\n return c.json({ error: \"Image not found\", filename, got: null }, 404);\n }\n\n const bytes = await blobToBytes(data);\n return new Response(bytes, {\n headers: { \"Content-Type\": contentTypeFor(filename), \"Cache-Control\": \"no-store\" },\n });\n});\n\napp.get(\"/api/images_debug/:filename\", async (c) => {\n const filename = c.req.param(\"filename\");\n\n let data;\n try {\n data = await blob.get(filename);\n } catch {\n return c.json({ ok: false, error: \"not found\" }, 404);\n }\n if (!data) return c.json({ ok: false, error: \"not found\" }, 404);\n\n const bytes = await blobToBytes(data);\n\n // Magic bytes checks (no string formatting edge cases)\n const isPng =\n bytes.length >= 8 &&\n bytes[0] === 0x89 &&\n bytes[1] === 0x50 &&\n bytes[2] === 0x4e &&\n bytes[3] === 0x47 &&\n bytes[4] === 0x0d &&\n bytes[5] === 0x0a &&\n bytes[6] === 0x1a &&\n bytes[7] === 0x0a;\n\n const isJpeg = bytes.length >= 3 && bytes[0] === 0xff && bytes[1] === 0xd8 && bytes[2] === 0xff;\n\n // WEBP starts with \"RIFF....WEBP\"\n const isWebp =\n bytes.length >= 12 &&\n bytes[0] === 0x52 &&\n bytes[1] === 0x49 &&\n bytes[2] === 0x46 &&\n bytes[3] === 0x46 &&\n bytes[8] === 0x57 &&\n bytes[9] === 0x45 &&\n bytes[10] === 0x42 &&\n bytes[11] === 0x50;\n\n let detected = \"unknown\";\n if (isPng) detected = \"png\";\n else if (isJpeg) detected = \"jpeg\";\n else if (isWebp) detected = \"webp\";\n\n const first16 = Array.from(bytes.slice(0, 16))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\" \");\n\n return c.json({\n ok: true,\n filename,\n byteLength: bytes.byteLength,\n first16,\n detected,\n looksLikePng: isPng,\n contentType: contentTypeFor(filename),\n });\n});\n\n// --- (Optional) Debug route ---\n// Handy to confirm you’re hitting the correct HTTP val.\napp.get(\"/__debug\", (c) => {\n return c.json({\n ok: true,\n hint: \"Try /, /public/index.tsx, /public/components/App.tsx, /public/style.css\",\n url: c.req.url,\n });\n});\n\n// --- Static File Serving (Frontend) ---\n\napp.get(\"/\", async (c) => {\n let html = await readFile(\"/dashboard/frontend/index.html\", import.meta.url);\n\n // OPTIONAL: bootstrap initial data like the Stevens demo template.\n // If your memories table is large, you might want to remove this and let the\n // frontend fetch instead.\n try {\n const memories = await getAllMemories();\n const initial = ``;\n html = html.replace(\"\", `${initial}`);\n } catch (e) {\n console.warn(\"Failed to bootstrap __INITIAL_DATA:\", e);\n }\n\n // Inject view source link\n const viewSourceLink = import.meta.url.replace(\"esm.town\", \"val.town\");\n const viewSourceTag =\n `View Source`;\n html = html.replace(\"\", `${viewSourceTag}`);\n\n return c.html(html);\n});\n\n// Serve all frontend files under /public/*\n// Maps /public/whatever -> /dashboard/frontend/whatever\napp.get(\"/public/*\", (c) => {\n const filePath = c.req.path.replace(/^\\/public/, \"/dashboard/frontend\");\n return serveFile(filePath, import.meta.url);\n});\n\n// HTTP vals expect an exported \"fetch handler\"\nexport default app.fetch;",[293,210,96],"5a7b6af8-f692-11f0-b45d-42dde27851f2",["D",1768976889213],[293,210,80],"pulls","branches",1,"forks","envVars",{"_312":314,"_315":26},"connections",{"_312":26,"_313":26},"count","unfilledCount",7,"emptyCount",{"_49":715,"_13":656,"_78":649,"_59":-5,"_51":52,"_286":716,"_288":24,"_53":717,"_55":26,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":718,"_17":719},{"_49":706,"_13":707,"_78":708,"_59":649,"_51":52,"_286":709,"_288":24,"_53":710,"_55":711,"_81":694,"_290":712,"_83":30,"_291":-5,"_369":713,"_17":714},{"_49":698,"_13":699,"_78":700,"_59":649,"_51":52,"_286":701,"_288":24,"_53":702,"_55":440,"_81":694,"_290":703,"_83":30,"_291":-5,"_369":704,"_17":705},{"_49":689,"_13":690,"_78":691,"_59":649,"_51":52,"_286":692,"_288":24,"_53":693,"_55":505,"_81":694,"_290":695,"_83":30,"_291":-5,"_369":696,"_17":697},{"_49":681,"_13":682,"_78":683,"_59":649,"_51":52,"_286":684,"_288":24,"_53":685,"_55":563,"_81":114,"_290":686,"_83":30,"_291":-5,"_369":687,"_17":688},{"_49":673,"_13":674,"_78":675,"_59":649,"_51":52,"_286":676,"_288":24,"_53":677,"_55":449,"_81":97,"_290":678,"_83":30,"_291":-5,"_369":679,"_17":680},{"_49":665,"_13":666,"_78":667,"_59":649,"_51":52,"_286":668,"_288":24,"_53":669,"_55":306,"_81":97,"_290":670,"_83":30,"_291":-5,"_369":671,"_17":672},{"_49":657,"_13":658,"_78":659,"_59":649,"_51":52,"_286":660,"_288":24,"_53":661,"_55":514,"_81":97,"_290":662,"_83":30,"_291":-5,"_369":663,"_17":664},{"_49":646,"_13":647,"_78":648,"_59":649,"_51":52,"_286":650,"_288":24,"_53":651,"_55":652,"_81":97,"_290":653,"_83":30,"_291":-5,"_369":654,"_17":655},{"_49":642,"_13":293,"_78":285,"_59":-5,"_51":52,"_286":367,"_288":24,"_53":643,"_55":26,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":644,"_17":645},{"_49":284,"_13":210,"_78":209,"_59":285,"_51":52,"_286":287,"_288":24,"_53":639,"_55":26,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":640,"_17":641},{"_49":301,"_13":80,"_78":79,"_59":209,"_51":52,"_286":56,"_288":24,"_53":636,"_55":26,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":637,"_17":638},{"_49":628,"_13":629,"_78":630,"_59":79,"_51":52,"_286":631,"_288":24,"_53":632,"_55":367,"_81":97,"_290":633,"_83":30,"_291":-5,"_369":634,"_17":635},{"_49":296,"_13":96,"_78":95,"_59":209,"_51":52,"_286":203,"_288":24,"_53":625,"_55":298,"_81":114,"_290":299,"_83":30,"_291":-5,"_369":626,"_17":627},{"_49":620,"_13":549,"_78":542,"_59":285,"_51":52,"_286":621,"_288":24,"_53":622,"_55":306,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":623,"_17":624},{"_49":613,"_13":614,"_78":615,"_59":542,"_51":52,"_286":616,"_288":24,"_53":617,"_55":306,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":618,"_17":619},{"_49":608,"_13":599,"_78":593,"_59":542,"_51":52,"_286":609,"_288":24,"_53":610,"_55":306,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":611,"_17":612},{"_49":600,"_13":601,"_78":602,"_59":593,"_51":52,"_286":603,"_288":24,"_53":604,"_55":505,"_81":97,"_290":605,"_83":30,"_291":-5,"_369":606,"_17":607},{"_49":590,"_13":591,"_78":592,"_59":593,"_51":52,"_286":249,"_288":24,"_53":594,"_55":595,"_81":97,"_290":596,"_83":30,"_291":-5,"_369":597,"_17":598},{"_49":585,"_13":584,"_78":578,"_59":542,"_51":52,"_286":586,"_288":24,"_53":587,"_55":306,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":588,"_17":589},{"_49":575,"_13":576,"_78":577,"_59":578,"_51":52,"_286":579,"_288":24,"_53":580,"_55":440,"_81":97,"_290":581,"_83":30,"_291":-5,"_369":582,"_17":583},{"_49":567,"_13":568,"_78":569,"_59":542,"_51":52,"_286":570,"_288":24,"_53":571,"_55":514,"_81":21,"_290":572,"_83":30,"_291":-5,"_369":573,"_17":574},{"_49":558,"_13":559,"_78":560,"_59":542,"_51":52,"_286":561,"_288":24,"_53":562,"_55":563,"_81":21,"_290":564,"_83":30,"_291":-5,"_369":565,"_17":566},{"_49":550,"_13":551,"_78":552,"_59":542,"_51":52,"_286":553,"_288":24,"_53":554,"_55":367,"_81":97,"_290":555,"_83":30,"_291":-5,"_369":556,"_17":557},{"_49":539,"_13":540,"_78":541,"_59":542,"_51":52,"_286":543,"_288":24,"_53":544,"_55":545,"_81":21,"_290":546,"_83":30,"_291":-5,"_369":547,"_17":548},{"_49":534,"_13":491,"_78":485,"_59":-5,"_51":52,"_286":535,"_288":24,"_53":536,"_55":26,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":537,"_17":538},{"_49":526,"_13":527,"_78":528,"_59":485,"_51":52,"_286":529,"_288":24,"_53":530,"_55":440,"_81":114,"_290":531,"_83":30,"_291":-5,"_369":532,"_17":533},{"_49":518,"_13":519,"_78":520,"_59":485,"_51":52,"_286":521,"_288":24,"_53":522,"_55":430,"_81":114,"_290":523,"_83":30,"_291":-5,"_369":524,"_17":525},{"_49":509,"_13":510,"_78":511,"_59":485,"_51":52,"_286":512,"_288":24,"_53":513,"_55":514,"_81":114,"_290":515,"_83":30,"_291":-5,"_369":516,"_17":517},{"_49":500,"_13":501,"_78":502,"_59":485,"_51":52,"_286":503,"_288":24,"_53":504,"_55":505,"_81":97,"_290":506,"_83":30,"_291":-5,"_369":507,"_17":508},{"_49":492,"_13":493,"_78":494,"_59":485,"_51":52,"_286":495,"_288":24,"_53":496,"_55":367,"_81":97,"_290":497,"_83":30,"_291":-5,"_369":498,"_17":499},{"_49":482,"_13":483,"_78":484,"_59":485,"_51":52,"_286":486,"_288":24,"_53":487,"_55":387,"_81":114,"_290":488,"_83":30,"_291":-5,"_369":489,"_17":490},{"_49":478,"_13":434,"_78":427,"_59":-5,"_51":52,"_286":306,"_288":24,"_53":479,"_55":26,"_81":82,"_290":-5,"_83":30,"_291":-5,"_369":480,"_17":481},{"_49":470,"_13":471,"_78":472,"_59":427,"_51":52,"_286":473,"_288":24,"_53":474,"_55":440,"_81":97,"_290":475,"_83":30,"_291":-5,"_369":476,"_17":477},{"_49":461,"_13":462,"_78":463,"_59":427,"_51":52,"_286":464,"_288":24,"_53":465,"_55":466,"_81":97,"_290":467,"_83":30,"_291":-5,"_369":468,"_17":469},{"_49":453,"_13":454,"_78":455,"_59":427,"_51":52,"_286":456,"_288":24,"_53":457,"_55":306,"_81":97,"_290":458,"_83":30,"_291":-5,"_369":459,"_17":460},{"_49":444,"_13":445,"_78":446,"_59":427,"_51":52,"_286":447,"_288":24,"_53":448,"_55":449,"_81":97,"_290":450,"_83":30,"_291":-5,"_369":451,"_17":452},{"_49":435,"_13":436,"_78":437,"_59":427,"_51":52,"_286":438,"_288":24,"_53":439,"_55":440,"_81":97,"_290":441,"_83":30,"_291":-5,"_369":442,"_17":443},{"_49":424,"_13":425,"_78":426,"_59":427,"_51":52,"_286":428,"_288":24,"_53":429,"_55":430,"_81":114,"_290":431,"_83":30,"_291":-5,"_369":432,"_17":433},{"_49":416,"_13":417,"_78":418,"_59":-5,"_51":52,"_286":419,"_288":24,"_53":420,"_55":26,"_81":21,"_290":421,"_83":30,"_291":-5,"_369":422,"_17":423},{"_49":408,"_13":409,"_78":410,"_59":-5,"_51":52,"_286":411,"_288":24,"_53":412,"_55":26,"_81":21,"_290":413,"_83":30,"_291":-5,"_369":414,"_17":415},{"_49":400,"_13":401,"_78":402,"_59":-5,"_51":52,"_286":403,"_288":24,"_53":404,"_55":306,"_81":97,"_290":405,"_83":30,"_291":-5,"_369":406,"_17":407},{"_49":392,"_13":393,"_78":394,"_59":-5,"_51":52,"_286":395,"_288":24,"_53":396,"_55":26,"_81":21,"_290":397,"_83":30,"_291":-5,"_369":398,"_17":399},{"_49":382,"_13":383,"_78":384,"_59":-5,"_51":52,"_286":385,"_288":24,"_53":386,"_55":387,"_81":114,"_290":388,"_83":30,"_291":389,"_369":390,"_17":391},{"_49":372,"_13":373,"_78":374,"_59":-5,"_51":52,"_286":375,"_288":24,"_53":376,"_55":377,"_81":114,"_290":378,"_83":30,"_291":379,"_369":380,"_17":381},{"_49":362,"_13":363,"_78":364,"_59":-5,"_51":52,"_286":365,"_288":24,"_53":366,"_55":367,"_81":97,"_290":368,"_83":30,"_291":-5,"_369":370,"_17":371},"2862b03e-f6f7-11f0-9af6-42dde27851f2","memoryUtils.js","243b0f9c-f6f7-11f0-89a8-42dde27851f2",119,["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}","children",[],[363],"1c492daa-0b97-11f1-b89f-42dde27851f2","discordWorker.js","908016ea-f6f5-11f0-bccc-42dde27851f2",375,["D",1771287906472],16,"// 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 if (!guildId) return `dm:${userId}`;\n return `chan:${channelId}`;\n}\n\n/** normalize tags like \"discord,art,friends\" -> \"discord, art, friends\" */\nfunction normalizeTags(tags) {\n return String(tags ?? \"\")\n .split(\",\")\n .map((t) => t.trim())\n .filter(Boolean)\n .join(\", \");\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\n/** Deduplicate interactions so Discord retries do not re-run side effects. */\nasync function ensureNotDuplicate(interactionId) {\n if (!interactionId) return false;\n\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n\n await sqlite.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS processed_interactions (\n id TEXT PRIMARY KEY,\n createdDate INTEGER\n )\n `,\n });\n\n const existing = await sqlite.execute({\n sql: `SELECT id FROM processed_interactions WHERE id = :id LIMIT 1`,\n args: { id: String(interactionId) },\n });\n\n if ((existing.rows ?? []).length) return true;\n\n await sqlite.execute({\n sql: `INSERT INTO processed_interactions (id, createdDate) VALUES (:id, :t)`,\n args: { id: String(interactionId), t: Date.now() },\n });\n\n return false;\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(\"yyyy-MM-dd\");\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- NEVER create a memory with empty text.\n- Only create/edit/delete memories based on the MOST RECENT user message in the chat history.\n\nFor CREATE memories JSON, use an array of objects with:\n{ \"date\": \"YYYY-MM-DD\" | null, \"text\": \"string\", \"tags\": \"comma,separated\" | \"\" }\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 const stats = {\n created: 0,\n edited: 0,\n deleted: 0,\n skippedEmptyCreates: 0,\n skippedDuplicateCreates: 0, // NEW\n };\n\n // Create (skip blank text + skip duplicates)\n for (const m of toCreate || []) {\n const text = String(m?.text ?? \"\").trim();\n const tags = normalizeTags(m?.tags ?? \"\");\n const date = m?.date ?? null;\n\n if (!text) {\n stats.skippedEmptyCreates++;\n console.warn(\"Skipping CREATE memory with empty text:\", m);\n continue;\n }\n\n // NEW: prevent re-creating deleted/old items (idempotent insert)\n const existing = await sqlite.execute({\n sql: `\n SELECT id FROM memories\n WHERE createdBy = 'discord'\n AND date IS :date\n AND text = :text\n LIMIT 1\n `,\n args: { date, text },\n });\n\n if ((existing.rows ?? []).length) {\n stats.skippedDuplicateCreates++;\n continue;\n }\n\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,\n text,\n createdBy: \"discord\",\n createdDate: Date.now(),\n tags,\n },\n });\n\n stats.created++;\n }\n\n // Edit (normalize tags if present)\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 = normalizeTags(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 stats.edited++;\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 stats.deleted++;\n }\n\n return stats;\n}\n\nexport default async function (req) {\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 interactionId = payload.interactionId || null;\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\n if (!channelId || !userId || !messageText) {\n console.error(\"Missing required fields:\", payload);\n return new Response(\"missing fields\", { status: 400 });\n }\n\n // Deduplicate\n try {\n const isDup = await ensureNotDuplicate(interactionId);\n if (isDup) {\n console.warn(\"Duplicate interaction ignored:\", interactionId);\n return new Response(\"ok\", { status: 200 });\n }\n } catch (e) {\n console.warn(\"Dedupe check failed (continuing):\", e);\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 + get stats\n const stats = await applyMemoryChanges(analysis);\n\n // If Claude tried to create memories but none were valid, apologize.\n let reply = analysis.response;\n\n const requestedCreates = Array.isArray(analysis.toCreate)\n ? analysis.toCreate.length\n : 0;\n\n if (requestedCreates > 0 && stats.created === 0 && stats.skippedEmptyCreates > 0) {\n reply =\n \"I am sorry—something went wrong while I was saving that note, and nothing was recorded. Would you please try again, perhaps rephrasing it as a single clear sentence?\";\n }\n\n // Post response + store outbound\n await discordSendMessage(channelId, reply);\n\n await storeChatMessage(\n conversationId,\n channelId,\n guildId,\n BOT_SENDER_ID,\n BOT_SENDER_NAME,\n reply,\n true,\n );\n\n return new Response(\"ok\", { status: 200 });\n}","bilbo-butler-worker",[],[373],"5101d95a-0b94-11f1-ac96-42dde27851f2","discordInteractions.js","86eb69b8-f6f5-11f0-8f13-42dde27851f2",374,["D",1771286706722],8,"import nacl from \"npm:tweetnacl@1.0.3\";\n\nconst WORKER_URL = \"https://bilbo-butler-worker.val.run/\";\nconst ACKS = [\n \"Very well, just one moment…\",\n \"Certainly. Allow me a moment…\",\n \"Right away. I shall see to it…\",\n \"Of course. I will handle that presently…\",\n \"Understood. One moment, please…\",\n];\n\nfunction pick(arr) {\n return arr[Math.floor(Math.random() * arr.length)];\n}\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 // NEW: pass interactionId through for dedupe\n const interactionId = interaction.id;\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({\n interactionId,\n channelId,\n guildId,\n userId,\n username,\n messageText,\n }),\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 return Response.json({\n type: 4,\n data: { content: pick(ACKS) },\n });\n }\n\n return Response.json({\n type: 4,\n data: { content: \"Unsupported interaction type.\" },\n });\n}","biblo-butler-interactions",[],[383],"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}",[],[393],"bad7260e-fbeb-11f0-b8e7-42dde27851f2","backstory.js","5aaba13c-f692-11f0-80a8-42dde27851f2",154,["D",1769565031884],"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`;",[],[401],"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",[],[409],"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",[],[417],"8c35ca92-0b74-11f1-bc71-42dde27851f2","usecleanup.ts","428fb376-0b74-11f1-bc9d-42dde27851f2","7e97cd56-f682-11f0-b864-42dde27851f2",347,["D",1771273062148],4,"import cleanupFunFacts from \"./cleanupFunFacts.js\";\nexport default async () => await cleanupFunFacts();",[],[434,425],"importers","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}",[],[434,436],"cc5439ac-0b5f-11f1-895c-42dde27851f2","getWeather.js","5a97cc98-f692-11f0-b45d-42dde27851f2",315,["D",1771264150290],19,"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 normalizePunctuation(s) {\n return (s ?? \"\")\n .replace(/\\s+/g, \" \")\n .replace(/\\s+([.,!?;:])/g, \"$1\") // remove space before punctuation\n .replace(/[.]+$/g, \"\") // strip trailing periods (we add our own)\n .trim();\n}\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: normalizePunctuation((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 const dateISO = DateTime.fromISO(day.date, { zone: ZONE }).toISODate();\n\n const firstDesc = normalizePunctuation(day.hourly?.[0]?.desc || \"forecast available\");\n const forecastText = `High of ${day.highTemp}°C, low of ${day.lowTemp}°C, ${firstDesc}.`;\n\n await deleteExistingForecast(dateISO);\n await insertForecast(dateISO, forecastText);\n }\n\n console.log(\"Weather forecast updated in memories.\");\n return days;\n}",[],[434,445],"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",[],[434,454],"3619d680-1b3c-11f1-bfc0-42dde27851f2","generateFunFacts.js","13efeb4a-0b6e-11f1-832c-42dde27851f2",408,["D",1773008084474],11,"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 Anthropic from \"https://esm.sh/@anthropic-ai/sdk@0.24.3\";\n\nconst TABLE_NAME = \"memories\";\nconst ZONE = \"America/Toronto\";\nconst DAYS_TO_FILL = 7;\nconst FACTS_PER_ATTEMPT = 15;\nconst MAX_GENERATION_ATTEMPTS = 3;\n\nfunction normalizePunctuation(s) {\n return (s ?? \"\")\n .replace(/\\s+/g, \" \")\n .replace(/\\s+([.,!?;:])/g, \"$1\")\n .replace(/[.]+$/g, \"\")\n .trim();\n}\n\nfunction toStoredFunFactText(factText) {\n return `Fun fact: ${normalizePunctuation(factText)}.`;\n}\n\nasync function deleteExistingFunFact(dateISO) {\n await sqlite.execute({\n sql: `\n DELETE FROM ${TABLE_NAME}\n WHERE date = :date AND createdBy = 'fun_fact'\n `,\n args: { date: dateISO },\n });\n}\n\nasync function insertFunFact(dateISO, factText) {\n const text = toStoredFunFactText(factText);\n\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,\n createdBy: \"fun_fact\",\n createdDate: Date.now(),\n tags: \"fun_fact\",\n },\n });\n}\n\nasync function getExistingFunFactTexts() {\n const cutoffDate = DateTime.now()\n .setZone(ZONE)\n .startOf(\"day\")\n .minus({ days: 70 })\n .toISODate();\n\n const result = await sqlite.execute({\n sql: `\n SELECT text\n FROM ${TABLE_NAME}\n WHERE createdBy = 'fun_fact'\n AND date >= :cutoffDate\n `,\n args: { cutoffDate },\n });\n\n return new Set(\n (result.rows ?? [])\n .map((row) => row.text)\n .filter(Boolean),\n );\n}\n\nfunction extractTextFromAnthropic(resp) {\n const blocks = resp?.content ?? [];\n return blocks.map((b) => (b?.type === \"text\" ? b.text : \"\")).join(\"\").trim();\n}\n\nasync function generateFactsAnthropicOnce(client, count, bannedFacts = []) {\n const bannedBlock = bannedFacts.length\n ? `\nDo NOT repeat or closely paraphrase any of these previously used facts:\n${bannedFacts.map((f) => `- ${f}`).join(\"\\n\")}\n`\n : \"\";\n\n const prompt = `\nGenerate ${count} unique, family-friendly fun facts (1–2 sentences each).\n\nConstraints:\n- Not about current events, politics, or celebrities\n- No medical advice\n- Avoid controversial topics\n- Each fact must be meaningfully different from the others\n${bannedBlock}\nReturn ONLY valid JSON: an array of exactly ${count} strings.\nDo not include any extra text, code fences, or commentary.\n`.trim();\n\n const resp = await client.messages.create({\n model: \"claude-sonnet-4-5-20250929\",\n max_tokens: 1400,\n temperature: 0.85,\n messages: [{ role: \"user\", content: prompt }],\n });\n\n const text = extractTextFromAnthropic(resp);\n const arr = JSON.parse(text);\n\n if (!Array.isArray(arr)) {\n throw new Error(\"Anthropic response JSON was not an array.\");\n }\n\n const facts = arr.slice(0, count).map((s) => String(s));\n if (facts.length < count) {\n throw new Error(`Got ${facts.length} facts; expected ${count}.`);\n }\n\n return facts;\n}\n\nasync function generateFactsAnthropic(existingFactTexts) {\n const apiKey = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!apiKey) {\n throw new Error(\"Missing ANTHROPIC_API_KEY (set it in Val Town environment variables).\");\n }\n\n const client = new Anthropic({ apiKey });\n\n const bannedFacts = Array.from(existingFactTexts)\n .slice(-50)\n .map((text) => text.replace(/^Fun fact:\\s*/i, \"\").replace(/\\.$/, \"\"));\n\n try {\n return await generateFactsAnthropicOnce(client, FACTS_PER_ATTEMPT, bannedFacts);\n } catch (_e) {\n const resp = await client.messages.create({\n model: \"claude-sonnet-4-5-20250929\",\n max_tokens: 1600,\n temperature: 0.2,\n messages: [\n {\n role: \"user\",\n content: `\nReturn ONLY valid JSON: an array of exactly ${FACTS_PER_ATTEMPT} strings. No other text.\n\nGenerate ${FACTS_PER_ATTEMPT} family-friendly fun facts.\nDo not repeat or closely paraphrase previously used facts.\nKeep every fact distinct from the others.\n`.trim(),\n },\n ],\n });\n\n const text = extractTextFromAnthropic(resp);\n const arr = JSON.parse(text);\n\n if (!Array.isArray(arr)) {\n throw new Error(\"Retry response JSON was not an array.\");\n }\n\n const facts = arr.slice(0, FACTS_PER_ATTEMPT).map((s) => String(s));\n if (facts.length < FACTS_PER_ATTEMPT) {\n throw new Error(`Retry got ${facts.length} facts; expected ${FACTS_PER_ATTEMPT}.`);\n }\n\n return facts;\n }\n}\n\nfunction filterFreshFacts(candidateFacts, existingFactTexts, newlyAcceptedTexts) {\n const accepted = [];\n\n for (const fact of candidateFacts) {\n const normalized = toStoredFunFactText(fact);\n\n if (existingFactTexts.has(normalized)) continue;\n if (newlyAcceptedTexts.has(normalized)) continue;\n\n newlyAcceptedTexts.add(normalized);\n accepted.push(fact);\n }\n\n return accepted;\n}\n\nexport default async function generateFunFacts() {\n const today = DateTime.now().setZone(ZONE).startOf(\"day\");\n const existingFactTexts = await getExistingFunFactTexts();\n const newlyAcceptedTexts = new Set();\n const freshFacts = [];\n\n for (let attempt = 1; attempt <= MAX_GENERATION_ATTEMPTS; attempt++) {\n if (freshFacts.length >= DAYS_TO_FILL) break;\n\n const candidates = await generateFactsAnthropic(existingFactTexts);\n const filtered = filterFreshFacts(candidates, existingFactTexts, newlyAcceptedTexts);\n freshFacts.push(...filtered);\n\n console.log(`Fun fact generation attempt ${attempt}: got ${filtered.length} fresh facts.`);\n }\n\n let updatedCount = 0;\n let skippedCount = 0;\n\n for (let i = 0; i < DAYS_TO_FILL; i++) {\n const dateISO = today.plus({ days: i }).toISODate();\n const fact = freshFacts[i];\n\n if (!fact) {\n console.log(`No fresh fun fact available for ${dateISO}; keeping existing fact.`);\n skippedCount++;\n continue;\n }\n\n await deleteExistingFunFact(dateISO);\n await insertFunFact(dateISO, fact);\n updatedCount++;\n }\n\n console.log(\"Fun facts updated in memories.\", {\n updatedCount,\n skippedCount,\n });\n\n return {\n ok: true,\n updatedCount,\n skippedCount,\n };\n}",[],[434,462],"185a5ca0-0b74-11f1-ad2f-42dde27851f2","cleanupFunFacts.js","ad87dec0-0b73-11f1-a6f8-42dde27851f2",339,["D",1771272867579],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE_NAME = \"memories\";\n\nexport default async function cleanupFunFacts() {\n const res = await sqlite.execute({\n sql: `\n UPDATE ${TABLE_NAME}\n SET text = REPLACE(text, ' .', '.')\n WHERE createdBy = 'fun_fact' AND text LIKE '% .%'\n `,\n });\n\n console.log(\"cleanupFunFacts done:\", res);\n return res;\n}",[],[434,471],"7e97cc8e-f682-11f0-b864-42dde27851f2",["D",1768970077837],[349,350,351,352,353,354],[434],"cc7d3ee6-f751-11f0-871b-42dde27851f2","setupDiscordDb.js","5ab9c000-f692-11f0-9451-42dde27851f2","5a2d5660-f692-11f0-80a8-42dde27851f2",137,["D",1769059114355],"// 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}",[],[491,483],"dbUtils","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}",[],[491,493],"2c7b45f6-0b5f-11f1-9e5c-42dde27851f2","populateCreatedBys.js","5aae2d94-f692-11f0-85b0-42dde27851f2",312,["D",1771263882099],6,"// 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 }\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 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}",[],[491,501],"cd71d7fe-0b91-11f1-b076-42dde27851f2","new-file-1054.ts","d821bbf0-0b79-11f1-8af2-42dde27851f2",373,["D",1771285626997],5,"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport default async function debugDate(_req: Request) {\n const res = await sqlite.execute({\n sql: `\n SELECT id, date, createdBy, createdDate, tags, text\n FROM memories\n WHERE date = '2026-02-17'\n ORDER BY createdDate DESC\n LIMIT 20\n `,\n });\n\n return Response.json(res, { status: 200 });\n}",[],[491,510],"40bf5ade-ffa7-11f0-84f7-42dde27851f2","migrateDb.js","5ac21822-f692-11f0-9437-42dde27851f2",256,["D",1769975425929],"// dbUtils/migrateDb.js\n// HTTP init endpoint: ensures memories table + columns + indexes exist,\n// and returns a table list + column list for verification.\n\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE = \"memories\";\n\nexport default async function migrateDb(_req) {\n await sqlite.execute({\n sql: `\n CREATE TABLE IF NOT EXISTS ${TABLE} (\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 args: [],\n });\n\n const info = await sqlite.execute({ sql: `PRAGMA table_info(${TABLE})`, args: [] });\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({\n sql: `ALTER TABLE ${TABLE} ADD COLUMN ${name} ${typeSql}`,\n args: [],\n });\n existingCols.add(name);\n }\n };\n\n // Keep compatibility if schema evolves\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 // Indexes to match common queries / sorting\n await sqlite.execute({\n sql: `CREATE INDEX IF NOT EXISTS idx_memories_date ON ${TABLE}(date)`,\n args: [],\n });\n\n await sqlite.execute({\n sql: `CREATE INDEX IF NOT EXISTS idx_memories_createdBy ON ${TABLE}(createdBy)`,\n args: [],\n });\n\n // Helps ORDER BY createdDate DESC\n await sqlite.execute({\n sql: `CREATE INDEX IF NOT EXISTS idx_memories_createdDate ON ${TABLE}(createdDate)`,\n args: [],\n });\n\n const tables = await sqlite.execute({\n sql: `\n SELECT name FROM sqlite_master\n WHERE type='table'\n ORDER BY name\n `,\n args: [],\n });\n\n const cols = await sqlite.execute({ sql: `PRAGMA table_info(${TABLE})`, args: [] });\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}",[],[491,519],"a2af2510-0b75-11f1-abbe-42dde27851f2","createFunFacts.ts","8dbca42a-0b75-11f1-bf0c-42dde27851f2",357,["D",1771273529356],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nexport default async function checkFunFacts() {\n const rows = await sqlite.execute({\n sql: `\n SELECT date, createdBy, tags, text\n FROM memories\n WHERE createdBy = 'fun_fact' OR tags LIKE '%fun_fact%'\n ORDER BY date DESC\n LIMIT 20\n `,\n });\n\n console.log(rows);\n return rows;\n}",[],[491,527],"5a2d5584-f692-11f0-80a8-42dde27851f2",68,["D",1768976888702],[342,343,344,345,346,347],[491],"59b3ae0e-0b60-11f1-bb7c-42dde27851f2","style.css","01696212-ff02-11f0-a182-42dde27851f2","f3a401a0-ff01-11f0-9c9d-42dde27851f2",323,["D",1771264387474],18,":root {\n --bg: #0b0d12;\n --panel: #121621;\n --panel2: #0f131c;\n --text: #e9eefc;\n --muted: #9fb0d0;\n --border: rgba(255, 255, 255, 0.08);\n --accent: #7aa7ff;\n --danger: #ff6b6b;\n}\n\n* { box-sizing: border-box; }\nhtml, body { height: 100%; }\nbody {\n min-height: 100vh;\n background: #0b0d12; /* fallback */\n margin: 0;\n font-family: \"Kulim Park\", system-ui, -apple-system, Segoe UI, Roboto, Arial, sans-serif;\n}\n\n/* Background image layer */\nbody::before {\n content: \"\";\n position: fixed;\n inset: 0;\n z-index: -1;\n background-image:\n linear-gradient(rgba(0,0,0,0), rgba(0,0,0,0)),\n url(\"/api/images/logbook_bg.png\");\n background-size: cover;\n background-position: center;\n}\n\na { color: var(--accent); text-decoration: none; }\na:hover { text-decoration: underline; }\n\n.shell {\n max-width: 1100px;\n margin: 0 auto;\n padding: 22px 16px 48px;\n\n /* The rectangle */\n background: rgba(255, 255, 255, 0.10);\n border: 1px solid rgba(255,255,255,0.14);\n border-radius: 18px;\n backdrop-filter: blur(8px);\n}\n\n\n.topbar {\n display: flex;\n align-items: baseline;\n justify-content: space-between;\n gap: 12px;\n margin-bottom: 14px;\n}\n\nh1 {\n font-size: 18px;\n margin: 0;\n letter-spacing: 0.2px;\n}\n\n.sub {\n color: var(--muted);\n font-size: 12px;\n margin-top: 4px;\n}\n\n.pill {\n display: inline-flex;\n align-items: center;\n gap: 8px;\n padding: 6px 10px;\n border: 1px solid var(--border);\n border-radius: 999px;\n background: rgba(255,255,255,0.03);\n color: var(--muted);\n font-size: 12px;\n}\n\n.layout {\n display: grid;\n grid-template-columns: 360px 1fr;\n gap: 12px;\n}\n\n@media (max-width: 920px) {\n .layout { grid-template-columns: 1fr; }\n}\n\n.card {\n border: 1px solid var(--border);\n background: rgba(18, 22, 33, 0.72);\n border-radius: 14px;\n box-shadow: 0 10px 28px rgba(0,0,0,0.25);\n overflow: hidden;\n}\n\n.cardHeader {\n padding: 12px 12px 10px;\n border-bottom: 1px solid var(--border);\n background: rgba(15,19,28,0.55);\n}\n\n.cardBody { padding: 12px; }\n\n.row { display: flex; gap: 10px; align-items: center; flex-wrap: wrap; }\n.spread { justify-content: space-between; }\n\n.input, .textarea {\n width: 100%;\n padding: 10px 11px;\n border-radius: 12px;\n border: 1px solid var(--border);\n background: rgba(255,255,255,0.04);\n color: var(--text);\n outline: none;\n}\n\n.textarea { min-height: 140px; resize: vertical; }\n\n.input:focus, .textarea:focus {\n border-color: rgba(122,167,255,0.55);\n box-shadow: 0 0 0 3px rgba(122,167,255,0.14);\n}\n\n.btn {\n padding: 9px 11px;\n border-radius: 12px;\n border: 1px solid var(--border);\n background: rgba(255,255,255,0.06);\n color: var(--text);\n cursor: pointer;\n user-select: none;\n}\n.btn:hover { background: rgba(255,255,255,0.09); }\n.btn.primary {\n border-color: rgba(122,167,255,0.35);\n background: rgba(122,167,255,0.14);\n}\n.btn.danger {\n border-color: rgba(255,107,107,0.35);\n background: rgba(255,107,107,0.12);\n}\n\n.list {\n display: flex;\n flex-direction: column;\n gap: 8px;\n}\n\n.item {\n border: 1px solid var(--border);\n background: rgba(255,255,255,0.03);\n border-radius: 12px;\n padding: 10px;\n cursor: pointer;\n}\n.item:hover { background: rgba(255,255,255,0.05); }\n\n.itemActive {\n border-color: rgba(122,167,255,0.5);\n background: rgba(122,167,255,0.10);\n}\n\n.itemTitle {\n font-size: 13px;\n margin: 0 0 6px;\n color: var(--text);\n}\n.itemMeta {\n font-size: 11px;\n color: var(--muted);\n display: flex;\n gap: 8px;\n flex-wrap: wrap;\n}\n\n.hr { border: none; border-top: 1px solid var(--border); margin: 12px 0; }\n\n.kbd {\n font-family: \"Kulim Park\", system-ui, -apple-system, Segoe UI, Roboto, Arial, sans-serif;\n font-size: 12px;\n color: var(--muted);\n border: 1px solid var(--border);\n background: rgba(255,255,255,0.03);\n padding: 2px 6px;\n border-radius: 8px;\n}\n\n/* ---- Notebook horizontal layout overrides ---- */\n\n/* make the app container feel like a page */\n.shell{\n max-width: 1250px;\n margin: 24px auto;\n padding: 18px;\n border-radius: 18px;\n background: rgba(10, 14, 22, 0.35);\n border: 1px solid rgba(255,255,255,0.12);\n backdrop-filter: blur(6px);\n}\n\n/* wider, horizontal split */\n.layout{\n display: grid;\n grid-template-columns: 520px 1fr; /* entries left, editor right */\n gap: 14px;\n}\n\n@media (max-width: 980px){\n .layout{ grid-template-columns: 1fr; }\n}\n\n/* blue frame around the whole notebook area */\n.layoutWrap{\n border: 2px solid rgba(122,167,255,0.80);\n border-radius: 16px;\n padding: 10px;\n box-shadow: 0 0 0 6px rgba(122,167,255,0.12);\n}\n\n/* slightly more “notebook” feel */\n.card{\n background: rgba(14, 18, 26, 0.70);\n border: 1px solid rgba(255,255,255,0.10);\n}\n\n.list{\n gap: 0;\n border: 1px solid rgba(255,255,255,0.10);\n border-radius: 12px;\n overflow: hidden;\n}\n\n.item{\n border: none;\n border-bottom: 1px solid rgba(255,255,255,0.08);\n border-radius: 0;\n background: rgba(255,255,255,0.03);\n}\n\n.item:last-child{ border-bottom: none; }\n\n.itemRow{\n display: grid;\n grid-template-columns: 120px 1fr 160px;\n gap: 10px;\n align-items: start;\n}\n\n.itemDate{\n font-size: 12px;\n opacity: 0.9;\n white-space: nowrap;\n overflow: hidden;\n text-overflow: ellipsis;\n}\n\n.itemNote{\n font-size: 13px;\n line-height: 1.25;\n}\n\n.itemTags{\n font-size: 12px;\n text-align: right;\n opacity: 0.85;\n white-space: nowrap;\n overflow: hidden;\n text-overflow: ellipsis;\n}\n/* hide old meta line (since we’ve moved it into columns) */\n.itemMeta{ display: none; }",[],[293,549,540],"frontend","2462542c-ff02-11f0-9c9d-42dde27851f2","index.tsx","20a3a17e-ff02-11f0-9019-42dde27851f2",235,["D",1769904511371],"/**\n * @jsxImportSource https://esm.sh/react@18.2.0\n */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"/public/components/App.tsx\";\n\ndeclare global {\n interface Window {\n __INITIAL_DATA?: unknown;\n }\n}\n\nconst rootEl = document.getElementById(\"root\");\nif (!rootEl) throw new Error(\"Missing #root element\");\n\nconst initialData = window.__INITIAL_DATA ?? null;\n\ncreateRoot(rootEl).render(\n \n \n \n);",[],[293,549,551],"be81e706-0b06-11f1-bac6-42dde27851f2","index.html","f6ad82ea-ff01-11f0-bf3a-42dde27851f2",302,["D",1771225901891],9,"\n\n \n \n \n \n \n \n Logbook\n\n \n \n\n \n \n\n \n \n \n \n

\n\n \n \n \n",[],[293,549,559],"2ae8eca6-0ade-11f1-a341-42dde27851f2","favicon.svg","13aab03e-ff02-11f0-a8bb-42dde27851f2",283,["D",1771208474401],"",[],[293,549,568],"6e7e760e-0b5e-11f1-be9c-42dde27851f2","types.ts","540df174-ff32-11f0-ab2f-42dde27851f2","5196b21e-ff32-11f0-87f4-42dde27851f2",308,["D",1771263563357],"export type Memory = {\n id: string;\n date: string | null;\n text: string;\n createdBy: string | null;\n createdDate: number | null;\n tags: string | null;\n};",[],[293,549,584,576],"shared","52ded71e-ff32-11f0-ab2f-42dde27851f2",248,["D",1769925205212],[336],[293,549,584],"39b50d16-1b5d-11f1-b6a4-42dde27851f2","NotebookView.tsx","13c900cc-ff1e-11f0-b4a8-42dde27851f2","2bb364f0-ff02-11f0-919e-42dde27851f2",["D",1773022263911],33,"/**\n * @jsxImportSource https://esm.sh/react@18.2.0\n */\nimport React, {\n useEffect,\n useMemo,\n useRef,\n useState,\n} from \"https://esm.sh/react@18.2.0\";\nimport type { Memory } from \"/public/shared/types.ts\";\n\ntype CreateBody = Partial<\n Pick\n>;\ntype Patch = Partial>;\n\ntype Props = {\n loading: boolean;\n memories: Memory[];\n onRefresh: () => Promise;\n onCreate: (body: CreateBody) => Promise;\n onUpdate: (id: string, patch: Patch) => Promise;\n onDelete: (id: string) => Promise;\n};\n\nfunction preview(text: string, max = 180) {\n const t = (text ?? \"\").trim().replace(/\\s+/g, \" \");\n return t.length > max ? t.slice(0, max - 1) + \"…\" : (t || \"(empty)\");\n}\n\nfunction normalizeTags(tags: string) {\n return tags\n .split(/[,]+/)\n .map((t) => t.trim())\n .filter(Boolean)\n .join(\", \");\n}\n\nexport function NotebookView({\n loading,\n memories,\n onRefresh,\n onCreate,\n onUpdate,\n onDelete,\n}: Props) {\n const [selectedId, setSelectedId] = useState(\n memories[0]?.id ?? null,\n );\n\n // Pagination like the demo (“Page 1 of 2”)\n const PAGE_SIZE = 10;\n const [page, setPage] = useState(0);\n\n // Create form\n const [newText, setNewText] = useState(\"\");\n const [newDate, setNewDate] = useState(\"\");\n const [newTags, setNewTags] = useState(\"\");\n const newTextareaRef = useRef(null);\n\n // Edit overlay\n const [editOpen, setEditOpen] = useState(false);\n const [editText, setEditText] = useState(\"\");\n const [editDate, setEditDate] = useState(\"\");\n const [editTags, setEditTags] = useState(\"\");\n\n const selected = useMemo(\n () => memories.find((m) => m.id === selectedId) ?? null,\n [memories, selectedId],\n );\n\n const pageCount = Math.max(1, Math.ceil(memories.length / PAGE_SIZE));\n const pagedMemories = useMemo(() => {\n const start = page * PAGE_SIZE;\n return memories.slice(start, start + PAGE_SIZE);\n }, [memories, page]);\n\n // keep selection valid\n useEffect(() => {\n if (selectedId && !memories.some((m) => m.id === selectedId)) {\n setSelectedId(memories[0]?.id ?? null);\n }\n if (!selectedId && memories[0]?.id) {\n setSelectedId(memories[0].id);\n }\n }, [memories]);\n\n // keep page in range\n useEffect(() => {\n if (page > pageCount - 1) setPage(Math.max(0, pageCount - 1));\n }, [pageCount]);\n\n // load selected into editor\n useEffect(() => {\n if (!selected) return;\n setEditText(selected.text ?? \"\");\n setEditDate(selected.date ?? \"\");\n setEditTags(selected.tags ?? \"\");\n }, [selectedId]);\n\n // Ctrl/Cmd+Enter create or save (matches your old behavior)\n useEffect(() => {\n const onKeyDown = (e: KeyboardEvent) => {\n const isAction = (e.ctrlKey || e.metaKey) && e.key === \"Enter\";\n if (!isAction) return;\n\n if (document.activeElement === newTextareaRef.current) {\n void create();\n } else if (editOpen && selected) {\n void save();\n }\n };\n window.addEventListener(\"keydown\", onKeyDown);\n return () => window.removeEventListener(\"keydown\", onKeyDown);\n }, [\n editOpen,\n selected,\n editText,\n editDate,\n editTags,\n newText,\n newDate,\n newTags,\n ]);\n\n async function create() {\n const text = newText.trim();\n if (!text) return;\n\n const body: CreateBody = {\n text,\n date: newDate.trim() ? newDate.trim() : null,\n tags: newTags.trim() ? normalizeTags(newTags) : null,\n createdDate: Date.now(),\n };\n\n const created = await onCreate(body);\n\n setNewText(\"\");\n setNewDate(\"\");\n setNewTags(\"\");\n\n // Assume appended -> jump to last page\n const newIndex = memories.length;\n setPage(Math.floor(newIndex / PAGE_SIZE));\n\n setSelectedId(created.id);\n setEditOpen(true);\n }\n\n async function save() {\n if (!selected) return;\n\n const patch: Patch = {\n text: editText,\n date: editDate.trim() ? editDate.trim() : null,\n tags: editTags.trim() ? normalizeTags(editTags) : null,\n };\n\n await onUpdate(selected.id, patch);\n setEditOpen(false);\n }\n\n async function del() {\n if (!selected) return;\n const ok = confirm(\"Delete this entry?\");\n if (!ok) return;\n await onDelete(selected.id);\n setEditOpen(false);\n }\n\n function openEditor(id: string) {\n setSelectedId(id);\n setEditOpen(true);\n }\n\n return (\n

\n \n\n

Notebook

\n\n

\n \n \n

\n\n

\n {/* Left: Create */}\n

New Entry

\n {loading\n ? \"Loading…\"\n : \"Write something, then click NEW ENTRY.\"}\n

\n\n \n New entry\n \n\n

\n setNewDate(e.target.value)}\n />\n

\n setNewTags(e.target.value)}\n />\n

\n setNewText(e.target.value)}\n />\n\n

\n Create: Ctrl+Enter\n

\n\n {/* Right: Table */}\n

DATE

NOTE

SOURCE

EDIT

\n\n

\n {pagedMemories.map((m) => (\n openEditor(m.id)}\n role=\"row\"\n >\n

{m.date ?? \"—\"}

{preview(m.text, 220)}

\n {m.tags?.trim() ? m.tags : \"—\"}\n

\n openEditor(m.id)}\n title=\"Edit\"\n >\n ✎\n \n

\n ))}\n\n {!loading && memories.length === 0\n ? (\n

\n \n No entries yet.\n

\n )\n : null}\n

\n\n

\n setPage((p) => Math.max(0, p - 1))}\n disabled={page === 0}\n >\n Prev\n \n \n setPage((p) => Math.min(pageCount - 1, p + 1))}\n disabled={page >= pageCount - 1}\n >\n Next\n \n

\n\n

\n Page {page + 1} of {pageCount}\n

\n\n {/* Edit overlay */}\n {editOpen\n ? (\n

setEditOpen(false)}>\n

e.stopPropagation()}>\n

Edit Note

\n {selected ? `Editing ${selected.id}` : \"No selection\"}\n

\n \n \n \n

\n\n

\n {!selected\n ? (\n

\n Pick an entry to edit.\n

\n )\n : (\n <>\n setEditDate(e.target.value)}\n />\n

\n setEditTags(e.target.value)}\n />\n

\n setEditText(e.target.value)}\n style={{ minHeight: 180 }}\n />\n \n Save: Ctrl+Enter\n

\n \n )}\n

\n )\n : null}\n

\n );\n}",[],[293,549,599,591],"components","234af14c-1b3c-11f1-a08d-42dde27851f2","App.tsx","2e7633d4-ff02-11f0-bf3a-42dde27851f2",406,["D",1773008052916],"/**\n * @jsxImportSource https://esm.sh/react@18.2.0\n */\nimport React, {\n useEffect,\n useMemo,\n useState,\n} from \"https://esm.sh/react@18.2.0\";\nimport { NotebookView } from \"/public/components/NotebookView.tsx\";\nimport type { Memory } from \"/public/shared/types.ts\";\n\ntype Props = {\n initialData: unknown;\n};\n\nasync function api(path: string, init?: RequestInit): Promise {\n const res = await fetch(path, {\n headers: { \"content-type\": \"application/json\", ...(init?.headers ?? {}) },\n ...init,\n });\n if (!res.ok) {\n const text = await res.text().catch(() => \"\");\n throw new Error(`HTTP ${res.status}: ${text || res.statusText}`);\n }\n return (await res.json()) as T;\n}\n\nfunction getMemoryTypePriority(memory: Memory): number {\n const createdBy = String(memory.createdBy ?? \"\").toLowerCase();\n const tags = String(memory.tags ?? \"\").toLowerCase();\n const text = String(memory.text ?? \"\").toLowerCase();\n\n const isFunFact = createdBy === \"fun_fact\" ||\n tags.includes(\"fun_fact\") ||\n text.startsWith(\"Fun fact:\");\n\n const isWeather = createdBy === \"weather\" ||\n tags.includes(\"weather\") ||\n text.startsWith(\"weather forecast:\");\n\n if (isWeather) return 2;\n if (isFunFact) return 3;\n return 1;\n}\n\nfunction sortMemoriesForLogbook(memories: Memory[]): Memory[] {\n return [...memories].sort((a, b) => {\n const dateA = String(a.date ?? \"\");\n const dateB = String(b.date ?? \"\");\n\n if (dateA !== dateB) {\n return dateB.localeCompare(dateA);\n }\n\n const priorityA = getMemoryTypePriority(a);\n const priorityB = getMemoryTypePriority(b);\n\n if (priorityA !== priorityB) {\n return priorityA - priorityB;\n }\n\n const createdA = Number(a.createdDate ?? 0);\n const createdB = Number(b.createdDate ?? 0);\n\n if (createdA !== createdB) {\n return createdB - createdA;\n }\n\n return String(a.id ?? \"\").localeCompare(String(b.id ?? \"\"));\n });\n}\n\nexport function App({ initialData }: Props) {\n const preloaded = initialData && typeof initialData === \"object\"\n ? (initialData as any).memories\n : null;\n\n const [memories, setMemories] = useState(\n Array.isArray(preloaded) ? preloaded : [],\n );\n const [loading, setLoading] = useState(!Array.isArray(preloaded));\n const [error, setError] = useState(null);\n\n async function refresh() {\n setError(null);\n setLoading(true);\n try {\n const rows = await api(\"/api/memories\");\n setMemories(rows ?? []);\n } catch (e: any) {\n setError(e?.message ?? String(e));\n } finally {\n setLoading(false);\n }\n }\n\n useEffect(() => {\n if (!Array.isArray(preloaded)) void refresh();\n // eslint-disable-next-line react-hooks/exhaustive-deps\n }, []);\n\n const stats = useMemo(() => {\n const count = memories.length;\n const withTags = memories.filter((m) =>\n (m.tags ?? \"\").trim().length > 0\n ).length;\n return { count, withTags };\n }, [memories]);\n\n const sortedMemories = useMemo(() => {\n return sortMemoriesForLogbook(memories);\n }, [memories]);\n\n return (\n

Logbook

\n {stats.count} entries\n •\n {stats.withTags} tagged\n •\n Ctrl+Enter\n

\n\n {error\n ? (\n \n

\n Load error: {error}\n

\n \n

\n )\n : null}\n\n {\n const created = await api(\"/api/memories\", {\n method: \"POST\",\n body: JSON.stringify(body),\n });\n setMemories((prev) => [created, ...prev]);\n return created;\n }}\n onUpdate={async (id, patch) => {\n await api<{ success: true }>(\n `/api/memories/${encodeURIComponent(id)}`,\n {\n method: \"PUT\",\n body: JSON.stringify(patch),\n },\n );\n setMemories((prev) =>\n prev.map((m) => (m.id === id ? ({ ...m, ...patch } as Memory) : m))\n );\n }}\n onDelete={async (id) => {\n await api<{ success: true }>(\n `/api/memories/${encodeURIComponent(id)}`,\n {\n method: \"DELETE\",\n },\n );\n setMemories((prev) => prev.filter((m) => m.id !== id));\n }}\n />\n

\n );\n}",[],[293,549,599,601],"2ce14004-ff02-11f0-9c3e-42dde27851f2",237,["D",1769904525637],[333,334],[293,549,599],"8b02706a-ffb4-11f0-9fb4-42dde27851f2","assets","89bd7a6a-ffb4-11f0-a17f-42dde27851f2",258,["D",1769981133977],[],[293,549,614],"f574417a-ff01-11f0-8913-42dde27851f2",220,["D",1769904432638],[331,332,335,337,338,339,340],[293,549],["D",1771195933349],[],[293,210,96],"39359de6-ffa7-11f0-9a7c-42dde27851f2","queries.js","5aa17086-f692-11f0-bc77-42dde27851f2",255,["D",1769975413280],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst TABLE = \"memories\";\n\n// Only allow updating these columns (prevents column-name injection)\nconst UPDATABLE_COLUMNS = new Set([\"date\", \"text\", \"createdBy\", \"createdDate\", \"tags\"]);\n\nfunction normalizeRow(row) {\n return {\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/** @returns {Promise>} */\nexport async function getAllMemories() {\n const result = await sqlite.execute({\n sql: `\n SELECT id, date, text, createdBy, createdDate, tags\n FROM ${TABLE}\n ORDER BY createdDate DESC\n `,\n args: [],\n });\n\n return (result.rows || []).map(normalizeRow);\n}\n\n/**\n * @param {Object} memory - Memory without id\n * @returns {Promise

History · backend