[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","677e8c58-6cb2-11f1-9245-1607ee4eb77e","name","fileType","http","content","// ─────────────────────────────────────────────────────────────────────────────\n// Life co-pilot — backend v2 (Val Town HTTP val)\n//\n// What's new in v2: it reads Notion.\n// /priority → reads your Substack pipeline + both \"Priorities Right Now\"\n// notes + the Writing-Time Balance page, works out what you\n// should do now and how urgent it is.\n// /published → marks a pipeline row Published (a narrow, safe write).\n// /log-words → records novel words done today on the balance page.\n//\n// Still here from v1: /meal, /summary, /fridge.\n//\n// SETUP — three environment variables in the val's sidebar:\n// ANTHROPIC_API_KEY your sk-ant-... key\n// NOTION_READ_TOKEN the `reset-app-read` secret (novel hub — read only)\n// NOTION_WRITE_TOKEN the `reset-app-write` secret (Substack hub + balance)\n//\n// SAFETY: this code can only perform the specific operations below. It cannot\n// rewrite prose. The bible and manuscript sit behind the read-only token.\n// ─────────────────────────────────────────────────────────────────────────────\n\nconst MODEL = \"claude-haiku-4-5\";\nconst API = \"https://api.anthropic.com/v1/messages\";\nconst NOTION = \"https://api.notion.com/v1\";\nconst NOTION_VERSION = \"2022-06-28\";\n\n// --- your Notion IDs ---------------------------------------------------------\nconst IDS = {\n pipelineDb: \"e96c14b1-5f5d-4f8f-bfb0-b3b7f9711a2b\", // Content Pipeline\n substackPriority: \"39d0c767-03a9-8187-b38d-ca8d754645aa\", // Joy of Old Books — Priorities Right Now\n novelPriority: \"39d0c767-03a9-8154-99b0-c67a6b7d0112\", // Oxford Beneath — Priorities Right Now\n balance: \"39d0c767-03a9-814c-a353-ce9e3135b6db\", // Writing-Time Balance\n tasksDb: \"f87f0d48-95b9-4f69-acd8-f2410a59b033\", // The Long Game — Tasks\n};\n\nconst HEALTH_POOL =\n `water (anytime), green tea (max 3/day, not evening), hibiscus tea (evening only, 1/day), ` +\n `B12 / vitamin D / algae omega-3 / turmeric capsule (once daily each), handful of nuts, ` +\n `kettlebell deadlifts, squats, calf raises, glute bridges, brisk 2-min walk, posture reset, ` +\n `pelvic floor squeezes, 5 slow breaths, 30-sec neck & shoulder stretch. ` +\n `Toddler-hours rule: standing exercises only — no floor work. Wiped = gentle only (water, breaths, stretch).`;\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n};\n\nfunction json(body: unknown, status = 200): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\n// --- Notion helpers ----------------------------------------------------------\nfunction notionHeaders(write = false) {\n const key = write\n ? Deno.env.get(\"NOTION_WRITE_TOKEN\")\n : Deno.env.get(\"NOTION_READ_TOKEN\");\n if (!key) {\n throw new Error(\n `Missing ${write ? \"NOTION_WRITE_TOKEN\" : \"NOTION_READ_TOKEN\"}`,\n );\n }\n return {\n \"Authorization\": `Bearer ${key}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n };\n}\n\nasync function notion(path: string, init: RequestInit = {}, write = false) {\n const r = await fetch(NOTION + path, {\n ...init,\n headers: notionHeaders(write),\n });\n if (!r.ok) {\n throw new Error(\n `Notion ${r.status} on ${path}: ${(await r.text()).slice(0, 300)}`,\n );\n }\n return await r.json();\n}\n\n// Flatten a page's blocks into plain text (headings, paragraphs, bullets).\nasync function pageText(\n pageId: string,\n write = false,\n max = 6000,\n): Promise {\n const data = await notion(\n `/blocks/${pageId}/children?page_size=100`,\n {},\n write,\n );\n const lines: string[] = [];\n for (const b of data.results ?? []) {\n const t = b.type;\n const rich = b[t]?.rich_text;\n if (!Array.isArray(rich) || !rich.length) continue;\n const text = rich.map((r: any) => r.plain_text).join(\"\");\n if (t.startsWith(\"heading\")) lines.push(`\\n## ${text}`);\n else if (t === \"bulleted_list_item\" || t === \"numbered_list_item\") {\n lines.push(`- ${text}`);\n } else lines.push(text);\n }\n return lines.join(\"\\n\").slice(0, max);\n}\n\n// Read a property value into something plain.\nfunction propValue(p: any): string {\n if (!p) return \"\";\n switch (p.type) {\n case \"title\":\n case \"rich_text\":\n return (p[p.type] ?? []).map((r: any) => r.plain_text).join(\"\");\n case \"select\":\n return p.select?.name ?? \"\";\n case \"multi_select\":\n return (p.multi_select ?? []).map((s: any) => s.name).join(\", \");\n case \"status\":\n return p.status?.name ?? \"\";\n case \"date\":\n return p.date?.start ?? \"\";\n case \"checkbox\":\n return p.checkbox ? \"yes\" : \"no\";\n case \"number\":\n return p.number != null ? String(p.number) : \"\";\n default:\n return \"\";\n }\n}\n\n// Everything in the pipeline that isn't finished yet.\nasync function pipelineRows(): Promise {\n const data = await notion(`/databases/${IDS.pipelineDb}/query`, {\n method: \"POST\",\n body: JSON.stringify({ page_size: 50 }),\n }, true);\n return (data.results ?? []).map((row: any) => {\n const out: Record = { id: row.id };\n for (const [name, p] of Object.entries(row.properties ?? {})) {\n const v = propValue(p);\n if (v) out[name] = v;\n if ((p as any).type === \"title\" && v) out.title = v;\n }\n return out;\n }).filter((r: any) => (r.Status ?? \"\").toLowerCase() !== \"published\");\n}\n\n// Open tasks from The Long Game — Tasks.\nasync function tasksRows(): Promise {\n const data = await notion(`/databases/${IDS.tasksDb}/query`, {\n method: \"POST\",\n body: JSON.stringify({ page_size: 100 }),\n }, true);\n return (data.results ?? []).map((row: any) => {\n const out: Record = { id: row.id };\n for (const [name, p] of Object.entries(row.properties ?? {})) {\n const v = propValue(p as any);\n if (v) out[name] = v;\n if ((p as any).type === \"title\" && v) out.title = v;\n if ((p as any).type === \"date\" && v && name === \"Due\") out.due = v;\n }\n return out;\n }).filter((r: any) => (r.Status ?? \"\") !== \"Done\");\n}\n\n// --- Claude ------------------------------------------------------------------\nasync function askClaude(\n system: string,\n user: string,\n maxTokens = 700,\n): Promise {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) throw new Error(\"Missing ANTHROPIC_API_KEY\");\n const r = await fetch(API, {\n method: \"POST\",\n headers: {\n \"x-api-key\": key,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: maxTokens,\n system,\n messages: [{ role: \"user\", content: user }],\n }),\n });\n if (!r.ok) {\n throw new Error(`Anthropic ${r.status}: ${(await r.text()).slice(0, 300)}`);\n }\n const data = await r.json();\n return (data.content ?? []).filter((b: any) => b.type === \"text\").map((\n b: any,\n ) => b.text).join(\"\").trim();\n}\n\n// --- /priority ---------------------------------------------------------------\nasync function handlePriority(body: any) {\n const today = new Date().toISOString().slice(0, 10);\n const energy = String(body?.energy ?? \"unknown\");\n const minutes = String(body?.minutes ?? \"unknown\");\n const extra = String(body?.context ?? \"\").slice(0, 600);\n\n const [subPriority, novelPriority, balance, rows, tasks] = await Promise.all([\n pageText(IDS.substackPriority, true).catch(() => \"\"),\n pageText(IDS.novelPriority, false).catch(() => \"\"),\n pageText(IDS.balance, true).catch(() => \"\"),\n pipelineRows().catch(() => []),\n tasksRows().catch(() => []),\n ]);\n\n const system =\n `You work out what one thing this person should do next, and how urgent it is. ` +\n `You are given her own written priorities for each area, her live Substack pipeline, ` +\n `and her writing-time balance targets. Apply HER rules — don't invent your own.\\n\\n` +\n `Reply with ONLY a JSON object, no prose, no code fences:\\n` +\n `{\"headline\":\"\",` +\n `\"urgency\":\"red|amber|green\",\"why\":\"\",` +\n `\"next\":[\"\",\"\"],` +\n `\"balance\":\"\",` +\n `\"health\":\"\"}\\n\\n` +\n `Rules: compute urgency from dates against today. An imminent deadline beats everything. ` +\n `Something untouched for days earns urgency through neglect. Size the suggestion to her ` +\n `stated energy and minutes. Be specific and small — a single concrete step, never \"work on X\". ` +\n `Weigh the life TASKS list alongside the writing: an overdue or imminent task can outrank writing; ` +\n `otherwise protect the writing targets. Always include one \"health\" micro-action from this pool, ` +\n `sized to energy/time: ${HEALTH_POOL}`;\n\n const user =\n `Today is ${today}. Energy: ${energy}. Minutes available: ${minutes}.` +\n (extra ? ` Also: ${extra}` : \"\") +\n `\\n\\n=== SUBSTACK PRIORITIES ===\\n${subPriority}` +\n `\\n\\n=== NOVEL PRIORITIES ===\\n${novelPriority}` +\n `\\n\\n=== WRITING-TIME BALANCE ===\\n${balance}` +\n `\\n\\n=== LIVE PIPELINE (unpublished) ===\\n${\n JSON.stringify(rows, null, 1).slice(0, 3000)\n }` +\n `\\n\\n=== LIFE TASKS (open; id omitted) ===\\n${\n JSON.stringify(\n tasks.map((t) => ({\n task: t.title,\n area: t.Area,\n due: t.due || \"\",\n flags: t.Flags || \"\",\n notes: t.Notes || \"\",\n })),\n null,\n 1,\n ).slice(0, 4000)\n }`;\n\n const raw = await askClaude(system, user, 700);\n try {\n const cleaned = raw.replace(/```json/gi, \"\").replace(/```/g, \"\").trim();\n const s = cleaned.indexOf(\"{\"), e = cleaned.lastIndexOf(\"}\");\n return json(JSON.parse(cleaned.slice(s, e + 1)));\n } catch {\n return json({\n headline: raw.slice(0, 200),\n urgency: \"green\",\n why: \"\",\n next: [],\n balance: \"\",\n health: \"\",\n });\n }\n}\n\n// --- /published : narrow write ----------------------------------------------\n// Body: { pageId: \"\" } → sets Status to Published.\nasync function handlePublished(body: any) {\n const pageId = String(body?.pageId ?? \"\");\n if (!pageId) return json({ error: \"pageId required\" }, 400);\n // Find whether Status is a status or select property, then set it.\n const page = await notion(`/pages/${pageId}`, {}, true);\n const statusProp = page.properties?.Status;\n const value = statusProp?.type === \"status\"\n ? { Status: { status: { name: \"Published\" } } }\n : { Status: { select: { name: \"Published\" } } };\n await notion(`/pages/${pageId}`, {\n method: \"PATCH\",\n body: JSON.stringify({ properties: value }),\n }, true);\n return json({ ok: true, marked: \"Published\" });\n}\n\n// --- /log-words : narrow write ----------------------------------------------\n// Body: { words: 600, note?: \"...\" } → appends a dated line to the balance page.\nasync function handleLogWords(body: any) {\n const words = parseInt(body?.words, 10);\n if (!Number.isFinite(words)) {\n return json({ error: \"words must be a number\" }, 400);\n }\n const note = String(body?.note ?? \"\").slice(0, 200);\n const line = `${\n new Date().toISOString().slice(0, 10)\n } — novel: ${words} words${note ? ` (${note})` : \"\"}`;\n await notion(`/blocks/${IDS.balance}/children`, {\n method: \"PATCH\",\n body: JSON.stringify({\n children: [{\n object: \"block\",\n type: \"bulleted_list_item\",\n bulleted_list_item: {\n rich_text: [{ type: \"text\", text: { content: line } }],\n },\n }],\n }),\n }, true);\n return json({ ok: true, logged: line });\n}\n\n// --- /task-done : narrow write --------------------------------------------\nasync function handleTaskDone(body: any) {\n const pageId = String(body?.pageId ?? \"\");\n if (!pageId) return json({ error: \"pageId required\" }, 400);\n await notion(`/pages/${pageId}`, {\n method: \"PATCH\",\n body: JSON.stringify({\n properties: { Status: { select: { name: \"Done\" } } },\n }),\n }, true);\n return json({ ok: true });\n}\n\n// --- /task-add : narrow write ---------------------------------------------\nasync function handleTaskAdd(body: any) {\n const task = String(body?.task ?? \"\").slice(0, 200);\n if (!task) return json({ error: \"task required\" }, 400);\n const area =\n [\"House\", \"Family\", \"Admin\", \"People\", \"Self\"].includes(body?.area)\n ? body.area\n : \"House\";\n const props: any = {\n Task: { title: [{ text: { content: task } }] },\n Area: { select: { name: area } },\n Status: { select: { name: \"To do\" } },\n };\n if (body?.due && /^\\d{4}-\\d{2}-\\d{2}$/.test(body.due)) {\n props.Due = { date: { start: body.due } };\n }\n if (body?.notes) {\n props.Notes = {\n rich_text: [{ text: { content: String(body.notes).slice(0, 300) } }],\n };\n }\n await notion(`/pages`, {\n method: \"POST\",\n body: JSON.stringify({\n parent: { database_id: IDS.tasksDb },\n properties: props,\n }),\n }, true);\n return json({ ok: true, added: task });\n}\n\n// --- /daily-update : voice update -> list changes ---------------------------\nasync function handleDailyUpdate(body: any) {\n const text = String(body?.text ?? \"\").slice(0, 1200);\n if (!text) return json({ error: \"text required\" }, 400);\n const tasks = await tasksRows().catch(() => []);\n const listing = tasks.map((t) =>\n `${t.id} :: ${t.title} [${t.Area || \"?\"}${t.due ? \", due \" + t.due : \"\"}]`\n ).join(\"\\n\");\n const today = new Date().toISOString().slice(0, 10);\n const system =\n `You maintain a to-do list. Given the open tasks (each line: id :: title [area, due]) and the person's ` +\n `spoken update, work out which existing tasks are DONE, which NEW tasks to add, and any due-date changes. ` +\n `Voice transcription may garble words — match on meaning. Today is ${today}. ` +\n `Her update may also mention FOOD she ate and NOVEL WRITING done — extract those too. ` +\n `Reply ONLY JSON: {\"done\":[\"\"],\"add\":[{\"task\":\"...\",\"area\":\"House|Family|Admin|People|Self\",\"due\":\"YYYY-MM-DD or empty\",\"notes\":\"\"}],` +\n `\"redate\":[{\"id\":\"\",\"due\":\"YYYY-MM-DD\"}],` +\n `\"dozen\":{:} using only keys ${\n DOZEN_KEYS.join(\"/\")\n } for food actually eaten,` +\n `\"novelWords\":,` +\n `\"reply\":\"\"}. ` +\n `Only mark done what she clearly says is done. Only add clear new tasks.`;\n const raw = await askClaude(\n system,\n `OPEN TASKS:\\n${listing}\\n\\nHER UPDATE:\\n${text}`,\n 800,\n );\n let plan: any = {};\n try {\n const c = raw.replace(/\\u0060\\u0060\\u0060json/gi, \"\").replace(\n /\\u0060\\u0060\\u0060/g,\n \"\",\n ).trim();\n plan = JSON.parse(c.slice(c.indexOf(\"{\"), c.lastIndexOf(\"}\") + 1));\n } catch {\n return json({\n reply: \"I couldn't parse that — try rephrasing?\",\n done: 0,\n added: 0,\n });\n }\n const ids = new Set(tasks.map((t: any) => t.id));\n let doneN = 0, addN = 0;\n for (const id of (plan.done ?? [])) {\n if (ids.has(id)) {\n try {\n await handleTaskDone({ pageId: id });\n doneN++;\n } catch {}\n }\n }\n for (const a of (plan.add ?? []).slice(0, 10)) {\n try {\n await handleTaskAdd(a);\n addN++;\n } catch {}\n }\n for (const r of (plan.redate ?? [])) {\n if (ids.has(r.id) && /^\\d{4}-\\d{2}-\\d{2}$/.test(r.due ?? \"\")) {\n try {\n await notion(`/pages/${r.id}`, {\n method: \"PATCH\",\n body: JSON.stringify({\n properties: { Due: { date: { start: r.due } } },\n }),\n }, true);\n } catch {}\n }\n }\n // dozen: validate and pass back for the app to apply locally\n const dozen: Record = {};\n if (plan.dozen && typeof plan.dozen === \"object\") {\n for (const k of Object.keys(plan.dozen)) {\n if (DOZEN_KEYS.includes(k)) {\n const n = parseInt(plan.dozen[k], 10);\n if (n > 0) dozen[k] = Math.min(n, 3);\n }\n }\n }\n // novel words: log to the balance page\n const words = parseInt(plan.novelWords, 10);\n if (Number.isFinite(words) && words > 0) {\n try {\n await handleLogWords({ words });\n } catch {}\n }\n return json({\n reply: plan.reply || `Done — ticked ${doneN}, added ${addN}.`,\n done: doneN,\n added: addN,\n dozen,\n });\n}\n\n// --- v1 endpoints, unchanged -------------------------------------------------\nconst DOZEN_KEYS = [\n \"beans\",\n \"berries\",\n \"fruit\",\n \"cruc\",\n \"greens\",\n \"veg\",\n \"flax\",\n \"nuts\",\n \"spices\",\n \"grains\",\n \"drinks\",\n \"exercise\",\n];\nconst SATISFIABLE = [\n \"nuts\",\n \"brazil\",\n \"turmeric\",\n \"garlic\",\n \"amla\",\n \"blackcumin\",\n \"cumin\",\n \"ginger\",\n];\n\nasync function handleMeal(body: any) {\n const text = String(body?.text ?? \"\").slice(0, 800);\n const system =\n `You read a meal description and map it onto Dr. Greger's Daily Dozen. Reply with ONLY JSON:\\n` +\n `{\"dozen\":{:},\"satisfied\":[],\"note\":\"\"}\\n` +\n `Valid keys: ${DOZEN_KEYS.join(\", \")}. Valid ids: ${\n SATISFIABLE.join(\", \")\n }. Note under 15 words.`;\n const raw = await askClaude(system, `Meal: ${text}`, 400);\n let parsed: any = {};\n try {\n const c = raw.replace(/```json/gi, \"\").replace(/```/g, \"\").trim();\n parsed = JSON.parse(c.slice(c.indexOf(\"{\"), c.lastIndexOf(\"}\") + 1));\n } catch {\n parsed = {};\n }\n const dozen: Record = {};\n for (const k of Object.keys(parsed.dozen ?? {})) {\n if (DOZEN_KEYS.includes(k)) {\n const n = parseInt(parsed.dozen[k], 10);\n if (n > 0) dozen[k] = Math.min(n, 3);\n }\n }\n return json({\n dozen,\n satisfied: Array.isArray(parsed.satisfied)\n ? parsed.satisfied.filter((x: any) => SATISFIABLE.includes(x))\n : [],\n note: typeof parsed.note === \"string\" ? parsed.note : \"Logged your meal.\",\n });\n}\n\nasync function handleSummary(body: any) {\n const counts = body?.counts ?? {};\n const done = Array.isArray(body?.done) ? body.done : [];\n const lines = DOZEN_KEYS.filter((k) => counts[k]).map((k) =>\n `${k}: ${counts[k].got}/${counts[k].goal}`\n ).join(\", \");\n const system =\n `You are a warm, encouraging coach. Write 2-4 short sentences, no lists, no markdown. ` +\n `Name what she nailed, flag one or two gaps as easy wins, end kindly. Never mention calories or restriction.`;\n const text = await askClaude(\n system,\n `Daily Dozen today — ${\n lines || \"nothing logged\"\n }. Reminders completed: ${done.length} (${\n done.slice(0, 12).join(\"; \") || \"none\"\n }).`,\n 350,\n );\n return json({ text });\n}\n\nasync function handleFridge(body: any) {\n const ingredients = String(body?.ingredients ?? \"\").slice(0, 600);\n const gaps = Array.isArray(body?.gaps) ? body.gaps.join(\", \") : \"\";\n const system =\n `Suggest ONE simple plant-forward meal from what's on hand. 3-5 short sentences, no lists or markdown: ` +\n `name it, quick how-to, which Daily Dozen boxes it ticks. Lean toward what she's short of. Quick and realistic. No alcohol.`;\n const text = await askClaude(\n system,\n `Have: ${ingredients}.` + (gaps ? ` Short on: ${gaps}.` : \"\"),\n 400,\n );\n return json({ text });\n}\n\n// --- /area : detail data for a section's page --------------------------------\n// Body: { area: \"substack\" | \"novel\" }\nasync function handleArea(body: any) {\n const area = String(body?.area ?? \"\");\n if (area === \"substack\") {\n const [rows, priorities] = await Promise.all([\n pipelineRows().catch(() => []),\n pageText(IDS.substackPriority, true).catch(() => \"\"),\n ]);\n return json({ rows, priorities });\n }\n if (area === \"tasks\") {\n const rows = await tasksRows().catch(() => []);\n return json({ rows });\n }\n if (area === \"novel\") {\n const [text, balance] = await Promise.all([\n pageText(IDS.novelPriority, false).catch(() => \"\"),\n pageText(IDS.balance, true).catch(() => \"\"),\n ]);\n return json({ text, balance });\n }\n return json({ error: \"area must be substack, novel or tasks\" }, 400);\n}\n\n// --- router ------------------------------------------------------------------\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS });\n }\n const path = new URL(req.url).pathname.replace(/\\/+$/, \"\");\n\n if (req.method === \"GET\" && (path === \"\" || path === \"/\")) {\n return new Response(\n \"Co-pilot backend v2 running. POST to /priority, /area, /task-done, /task-add, /daily-update, /published, /log-words, /meal, /summary, /fridge.\",\n { headers: { \"Content-Type\": \"text/plain\", ...CORS } },\n );\n }\n if (req.method !== \"POST\") return json({ error: \"Use POST.\" }, 405);\n\n let body: any = {};\n try {\n body = await req.json();\n } catch {\n return json({ error: \"Invalid JSON body.\" }, 400);\n }\n\n try {\n if (path.endsWith(\"/priority\")) return await handlePriority(body);\n if (path.endsWith(\"/area\")) return await handleArea(body);\n if (path.endsWith(\"/task-done\")) return await handleTaskDone(body);\n if (path.endsWith(\"/task-add\")) return await handleTaskAdd(body);\n if (path.endsWith(\"/daily-update\")) return await handleDailyUpdate(body);\n if (path.endsWith(\"/published\")) return await handlePublished(body);\n if (path.endsWith(\"/log-words\")) return await handleLogWords(body);\n if (path.endsWith(\"/meal\")) return await handleMeal(body);\n if (path.endsWith(\"/summary\")) return await handleSummary(body);\n if (path.endsWith(\"/fridge\")) return await handleFridge(body);\n return json({ error: \"Unknown endpoint.\" }, 404);\n } catch (err: any) {\n return json({ error: String(err?.message ?? err) }, 500);\n }\n}","// ─────────────────────────────────────────────────────────────────────────────\n// Life co-pilot — backend v2 (Val Town HTTP val)\n//\n// What's new in v2: it reads Notion.\n// /priority → reads your Substack pipeline + both \"Priorities Right Now\"\n// notes + the Writing-Time Balance page, works out what you\n// should do now and how urgent it is.\n// /published → marks a pipeline row Published (a narrow, safe write).\n// /log-words → records novel words done today on the balance page.\n//\n// Still here from v1: /meal, /summary, /fridge.\n//\n// SETUP — three environment variables in the val's sidebar:\n// ANTHROPIC_API_KEY your sk-ant-... key\n// NOTION_READ_TOKEN the `reset-app-read` secret (novel hub — read only)\n// NOTION_WRITE_TOKEN the `reset-app-write` secret (Substack hub + balance)\n//\n// SAFETY: this code can only perform the specific operations below. It cannot\n// rewrite prose. The bible and manuscript sit behind the read-only token.\n// ─────────────────────────────────────────────────────────────────────────────\n\nconst MODEL = \"claude-haiku-4-5\";\nconst API = \"https://api.anthropic.com/v1/messages\";\nconst NOTION = \"https://api.notion.com/v1\";\nconst NOTION_VERSION = \"2022-06-28\";\n\n// --- your Notion IDs ---------------------------------------------------------\nconst IDS = {\n pipelineDb: \"e96c14b1-5f5d-4f8f-bfb0-b3b7f9711a2b\", // Content Pipeline\n substackPriority: \"39d0c767-03a9-8187-b38d-ca8d754645aa\", // Joy of Old Books — Priorities Right Now\n novelPriority: \"39d0c767-03a9-8154-99b0-c67a6b7d0112\", // Oxford Beneath — Priorities Right Now\n balance: \"39d0c767-03a9-814c-a353-ce9e3135b6db\", // Writing-Time Balance\n tasksDb: \"f87f0d48-95b9-4f69-acd8-f2410a59b033\", // The Long Game — Tasks\n hq: \"3a90c767-03a9-8126-97ad-eec810ca7660\", // The Long Game — HQ (life priorities; Daily Log lives inside)\n};\n// Also set env var GOOGLE_ICS_URL to your calendar's secret iCal address.\n\nconst HEALTH_POOL =\n `water (anytime), green tea (max 3/day, not evening), hibiscus tea (evening only, 1/day), ` +\n `B12 / vitamin D / algae omega-3 / turmeric capsule (once daily each), handful of nuts, ` +\n `kettlebell deadlifts, squats, calf raises, glute bridges, brisk 2-min walk, posture reset, ` +\n `pelvic floor squeezes, 5 slow breaths, 30-sec neck & shoulder stretch. ` +\n `Toddler-hours rule: standing exercises only — no floor work. Wiped = gentle only (water, breaths, stretch).`;\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n};\n\nfunction json(body: unknown, status = 200): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\n// --- Notion helpers ----------------------------------------------------------\nfunction notionHeaders(write = false) {\n const key = write\n ? Deno.env.get(\"NOTION_WRITE_TOKEN\")\n : Deno.env.get(\"NOTION_READ_TOKEN\");\n if (!key) {\n throw new Error(\n `Missing ${write ? \"NOTION_WRITE_TOKEN\" : \"NOTION_READ_TOKEN\"}`,\n );\n }\n return {\n \"Authorization\": `Bearer ${key}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n };\n}\n\nasync function notion(path: string, init: RequestInit = {}, write = false) {\n const r = await fetch(NOTION + path, {\n ...init,\n headers: notionHeaders(write),\n });\n if (!r.ok) {\n throw new Error(\n `Notion ${r.status} on ${path}: ${(await r.text()).slice(0, 300)}`,\n );\n }\n return await r.json();\n}\n\n// Flatten a page's blocks into plain text (headings, paragraphs, bullets).\nasync function pageText(\n pageId: string,\n write = false,\n max = 6000,\n): Promise {\n const data = await notion(\n `/blocks/${pageId}/children?page_size=100`,\n {},\n write,\n );\n const lines: string[] = [];\n for (const b of data.results ?? []) {\n const t = b.type;\n const rich = b[t]?.rich_text;\n if (!Array.isArray(rich) || !rich.length) continue;\n const text = rich.map((r: any) => r.plain_text).join(\"\");\n if (t.startsWith(\"heading\")) lines.push(`\\n## ${text}`);\n else if (t === \"bulleted_list_item\" || t === \"numbered_list_item\") {\n lines.push(`- ${text}`);\n } else lines.push(text);\n }\n return lines.join(\"\\n\").slice(0, max);\n}\n\n// Read a property value into something plain.\nfunction propValue(p: any): string {\n if (!p) return \"\";\n switch (p.type) {\n case \"title\":\n case \"rich_text\":\n return (p[p.type] ?? []).map((r: any) => r.plain_text).join(\"\");\n case \"select\":\n return p.select?.name ?? \"\";\n case \"multi_select\":\n return (p.multi_select ?? []).map((s: any) => s.name).join(\", \");\n case \"status\":\n return p.status?.name ?? \"\";\n case \"date\":\n return p.date?.start ?? \"\";\n case \"checkbox\":\n return p.checkbox ? \"yes\" : \"no\";\n case \"number\":\n return p.number != null ? String(p.number) : \"\";\n default:\n return \"\";\n }\n}\n\n// Everything in the pipeline that isn't finished yet.\nasync function pipelineRows(): Promise {\n const data = await notion(`/databases/${IDS.pipelineDb}/query`, {\n method: \"POST\",\n body: JSON.stringify({ page_size: 50 }),\n }, true);\n return (data.results ?? []).map((row: any) => {\n const out: Record = { id: row.id };\n for (const [name, p] of Object.entries(row.properties ?? {})) {\n const v = propValue(p);\n if (v) out[name] = v;\n if ((p as any).type === \"title\" && v) out.title = v;\n }\n return out;\n }).filter((r: any) => (r.Status ?? \"\").toLowerCase() !== \"published\");\n}\n\n// Open tasks from The Long Game — Tasks.\nasync function tasksRows(): Promise {\n const data = await notion(`/databases/${IDS.tasksDb}/query`, {\n method: \"POST\",\n body: JSON.stringify({ page_size: 100 }),\n }, true);\n return (data.results ?? []).map((row: any) => {\n const out: Record = { id: row.id };\n for (const [name, p] of Object.entries(row.properties ?? {})) {\n const v = propValue(p as any);\n if (v) out[name] = v;\n if ((p as any).type === \"title\" && v) out.title = v;\n if ((p as any).type === \"date\" && v && name === \"Due\") out.due = v;\n }\n return out;\n }).filter((r: any) => (r.Status ?? \"\") !== \"Done\");\n}\n\nlet dailyLogDbId: string | null = null;\nasync function findDailyLogDb(): Promise {\n if (dailyLogDbId) return dailyLogDbId;\n const data = await notion(\n `/blocks/${IDS.hq}/children?page_size=50`,\n {},\n true,\n );\n for (const blk of data.results ?? []) {\n if (\n blk.type === \"child_database\" &&\n /daily log/i.test(blk.child_database?.title ?? \"\")\n ) {\n dailyLogDbId = blk.id;\n return blk.id;\n }\n }\n throw new Error(\"Daily Log database not found under HQ\");\n}\n\nasync function todaysLogRow(): Promise {\n const db = await findDailyLogDb();\n const today = new Date().toISOString().slice(0, 10);\n const data = await notion(`/databases/${db}/query`, {\n method: \"POST\",\n body: JSON.stringify({\n filter: { property: \"Date\", date: { equals: today } },\n page_size: 1,\n }),\n }, true);\n return (data.results ?? [])[0] ?? null;\n}\n\n// --- calendar (Google secret ICS) -------------------------------------------\nfunction icsUnfold(text: string): string[] {\n return text.replace(/\\r\\n[ \\t]/g, \"\").replace(/\\r/g, \"\").split(\"\\n\");\n}\nasync function todaysEvents(): Promise<{ time: string; title: string }[]> {\n const url = Deno.env.get(\"GOOGLE_ICS_URL\");\n if (!url) return [];\n const r = await fetch(url);\n if (!r.ok) return [];\n const lines = icsUnfold(await r.text());\n const today = new Date();\n const y = today.getFullYear(),\n mo = today.getMonth() + 1,\n da = today.getDate();\n const todayStr = `${y}${String(mo).padStart(2, \"0\")}${\n String(da).padStart(2, \"0\")\n }`;\n const dow = [\"SU\", \"MO\", \"TU\", \"WE\", \"TH\", \"FR\", \"SA\"][today.getDay()];\n const out: { time: string; title: string; sort: string }[] = [];\n let ev: any = null;\n for (const ln of lines) {\n if (ln === \"BEGIN:VEVENT\") {\n ev = {};\n continue;\n }\n if (ln === \"END:VEVENT\") {\n if (ev) {\n const ds = ev.DTSTART ?? \"\";\n const dateBit = (ds.match(/(\\d{8})/) ?? [])[1] ?? \"\";\n const timeBit = (ds.match(/T(\\d{4})/) ?? [])[1] ?? \"\";\n const rr = ev.RRULE ?? \"\";\n let today_ = dateBit === todayStr;\n if (!today_ && rr) {\n if (/FREQ=DAILY/.test(rr)) today_ = dateBit <= todayStr;\n else if (/FREQ=WEEKLY/.test(rr)) {\n const byday = (rr.match(/BYDAY=([^;]+)/) ?? [])[1] ?? \"\";\n const startDow = dateBit\n ? [\n \"SU\",\n \"MO\",\n \"TU\",\n \"WE\",\n \"TH\",\n \"FR\",\n \"SA\",\n ][\n new Date(\n `${dateBit.slice(0, 4)}-${dateBit.slice(4, 6)}-${\n dateBit.slice(6, 8)\n }T00:00:00`,\n ).getDay()\n ]\n : \"\";\n today_ = dateBit <= todayStr &&\n (byday ? byday.includes(dow) : startDow === dow);\n }\n }\n const until = (rr.match(/UNTIL=(\\d{8})/) ?? [])[1];\n if (until && until < todayStr) today_ = false;\n if (today_ && ev.SUMMARY) {\n const time = timeBit\n ? `${timeBit.slice(0, 2)}:${timeBit.slice(2, 4)}`\n : \"\";\n out.push({ time, title: ev.SUMMARY, sort: timeBit || \"0000\" });\n }\n }\n ev = null;\n continue;\n }\n if (!ev) continue;\n const key = ln.split(/[;:]/)[0];\n const val = ln.slice(ln.indexOf(\":\") + 1);\n if ([\"DTSTART\", \"SUMMARY\", \"RRULE\"].includes(key)) ev[key] = val;\n }\n out.sort((a, b) => a.sort.localeCompare(b.sort));\n return out.slice(0, 10).map(({ time, title }) => ({ time, title }));\n}\n\n// --- Claude ------------------------------------------------------------------\nasync function askClaude(\n system: string,\n user: string,\n maxTokens = 700,\n): Promise {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) throw new Error(\"Missing ANTHROPIC_API_KEY\");\n const r = await fetch(API, {\n method: \"POST\",\n headers: {\n \"x-api-key\": key,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: maxTokens,\n system,\n messages: [{ role: \"user\", content: user }],\n }),\n });\n if (!r.ok) {\n throw new Error(`Anthropic ${r.status}: ${(await r.text()).slice(0, 300)}`);\n }\n const data = await r.json();\n return (data.content ?? []).filter((b: any) => b.type === \"text\").map((\n b: any,\n ) => b.text).join(\"\").trim();\n}\n\n// --- /priority ---------------------------------------------------------------\nasync function handlePriority(body: any) {\n const today = new Date().toISOString().slice(0, 10);\n const energy = String(body?.energy ?? \"unknown\");\n const minutes = String(body?.minutes ?? \"unknown\");\n const extra = String(body?.context ?? \"\").slice(0, 600);\n\n const [hq, subPriority, novelPriority, balance, rows, tasks] = await Promise\n .all([\n pageText(IDS.hq, true, 3500).catch(() => \"\"),\n pageText(IDS.substackPriority, true).catch(() => \"\"),\n pageText(IDS.novelPriority, false).catch(() => \"\"),\n pageText(IDS.balance, true).catch(() => \"\"),\n pipelineRows().catch(() => []),\n tasksRows().catch(() => []),\n ]);\n\n const system =\n `You work out what one thing this person should do next, and how urgent it is. ` +\n `You are given her own written priorities for each area, her live Substack pipeline, ` +\n `and her writing-time balance targets. Apply HER rules — don't invent your own.\\n\\n` +\n `Reply with ONLY a JSON object, no prose, no code fences:\\n` +\n `{\"headline\":\"\",` +\n `\"urgency\":\"red|amber|green\",\"why\":\"\",` +\n `\"next\":[\"\",\"\"],` +\n `\"balance\":\"\",` +\n `\"health\":\"\"}\\n\\n` +\n `Rules: compute urgency from dates against today. An imminent deadline beats everything. ` +\n `Something untouched for days earns urgency through neglect. Size the suggestion to her ` +\n `stated energy and minutes. Be specific and small — a single concrete step, never \"work on X\". ` +\n `Weigh the life TASKS list alongside the writing: an overdue or imminent task can outrank writing; ` +\n `otherwise protect the writing targets. Always include one \"health\" micro-action from this pool, ` +\n `sized to energy/time: ${HEALTH_POOL}`;\n\n const user =\n `Today is ${today}. Energy: ${energy}. Minutes available: ${minutes}.` +\n (extra ? ` Also: ${extra}` : \"\") +\n `\\n\\n=== LIFE PRIORITIES (HQ — the top layer) ===\\n${hq}` +\n `\\n\\n=== SUBSTACK PRIORITIES ===\\n${subPriority}` +\n `\\n\\n=== NOVEL PRIORITIES ===\\n${novelPriority}` +\n `\\n\\n=== WRITING-TIME BALANCE ===\\n${balance}` +\n `\\n\\n=== LIVE PIPELINE (unpublished) ===\\n${\n JSON.stringify(rows, null, 1).slice(0, 3000)\n }` +\n `\\n\\n=== LIFE TASKS (open; id omitted) ===\\n${\n JSON.stringify(\n tasks.map((t) => ({\n task: t.title,\n area: t.Area,\n due: t.due || \"\",\n flags: t.Flags || \"\",\n notes: t.Notes || \"\",\n })),\n null,\n 1,\n ).slice(0, 4000)\n }`;\n\n const raw = await askClaude(system, user, 700);\n try {\n const cleaned = raw.replace(/```json/gi, \"\").replace(/```/g, \"\").trim();\n const s = cleaned.indexOf(\"{\"), e = cleaned.lastIndexOf(\"}\");\n return json(JSON.parse(cleaned.slice(s, e + 1)));\n } catch {\n return json({\n headline: raw.slice(0, 200),\n urgency: \"green\",\n why: \"\",\n next: [],\n balance: \"\",\n health: \"\",\n });\n }\n}\n\n// --- /published : narrow write ----------------------------------------------\n// Body: { pageId: \"\" } → sets Status to Published.\nasync function handlePublished(body: any) {\n const pageId = String(body?.pageId ?? \"\");\n if (!pageId) return json({ error: \"pageId required\" }, 400);\n // Find whether Status is a status or select property, then set it.\n const page = await notion(`/pages/${pageId}`, {}, true);\n const statusProp = page.properties?.Status;\n const value = statusProp?.type === \"status\"\n ? { Status: { status: { name: \"Published\" } } }\n : { Status: { select: { name: \"Published\" } } };\n await notion(`/pages/${pageId}`, {\n method: \"PATCH\",\n body: JSON.stringify({ properties: value }),\n }, true);\n return json({ ok: true, marked: \"Published\" });\n}\n\n// --- /log-words : narrow write ----------------------------------------------\n// Body: { words: 600, note?: \"...\" } → appends a dated line to the balance page.\nasync function handleLogWords(body: any) {\n const words = parseInt(body?.words, 10);\n if (!Number.isFinite(words)) {\n return json({ error: \"words must be a number\" }, 400);\n }\n const note = String(body?.note ?? \"\").slice(0, 200);\n const line = `${\n new Date().toISOString().slice(0, 10)\n } — novel: ${words} words${note ? ` (${note})` : \"\"}`;\n await notion(`/blocks/${IDS.balance}/children`, {\n method: \"PATCH\",\n body: JSON.stringify({\n children: [{\n object: \"block\",\n type: \"bulleted_list_item\",\n bulleted_list_item: {\n rich_text: [{ type: \"text\", text: { content: line } }],\n },\n }],\n }),\n }, true);\n return json({ ok: true, logged: line });\n}\n\n// --- /dashboard : the glance ------------------------------------------------\nasync function handleDashboard(_body: any) {\n const [calendar, tasks, pipeline, novelText] = await Promise.all([\n todaysEvents().catch(() => []),\n tasksRows().catch(() => []),\n pipelineRows().catch(() => []),\n pageText(IDS.novelPriority, false, 3000).catch(() => \"\"),\n ]);\n // urgent: due within 2 days or overdue\n const today = new Date().toISOString().slice(0, 10);\n const soon = (d: string) => {\n if (!d) return false;\n const gap =\n (new Date(d + \"T00:00:00\").getTime() -\n new Date(today + \"T00:00:00\").getTime()) / 86400000;\n return gap <= 2;\n };\n const urgent = tasks.filter((t: any) => soon(t.due)).sort((a: any, b: any) =>\n (a.due || \"\").localeCompare(b.due || \"\")\n )\n .map((t: any) => ({ id: t.id, title: t.title, due: t.due }));\n // snapshots\n const snapshots: any[] = [];\n // substack: earliest unpublished by publish date\n const dateOf = (r: any) => {\n for (const k in r) {\n if (/publish/i.test(k) && /\\d{4}-/.test(r[k])) return r[k];\n }\n return \"\";\n };\n const sorted = pipeline.slice().sort((a: any, b: any) =>\n (dateOf(a) || \"9999\").localeCompare(dateOf(b) || \"9999\")\n );\n if (sorted.length) {\n const nx = sorted[0];\n snapshots.push({\n area: \"Substack\",\n what: nx.title || \"(untitled)\",\n due: dateOf(nx),\n meta: nx.Status ? (\"Status: \" + nx.Status) : \"\",\n });\n } else {snapshots.push({\n area: \"Substack\",\n what: \"Pipeline empty — nothing queued\",\n meta: \"\",\n });}\n // novel: pull the \"Next scene / chapter\" line if present\n const m = novelText.match(/Next scene[^:]*:\\s*([^\\n]+)/i);\n snapshots.push({\n area: \"Novel\",\n what: m\n ? m[1].replace(/^_|_$/g, \"\").trim()\n : \"Default: draft the next scene of Book 1\",\n meta: \"500 words/day is the floor\",\n });\n // house: nearest-due or first House task not already in urgent\n const urgentIds = new Set(urgent.map((u: any) => u.id));\n const house =\n tasks.filter((t: any) => t.Area === \"House\" && !urgentIds.has(t.id))\n .sort((a: any, b: any) =>\n (a.due || \"9999\").localeCompare(b.due || \"9999\")\n )[0];\n if (house) {\n snapshots.push({\n area: \"House\",\n what: house.title,\n due: house.due || \"\",\n meta: \"\",\n });\n }\n // health: from today's Daily Log row if it exists\n try {\n const row = await todaysLogRow();\n if (row) {\n const mv = propValue(row.properties?.[\"Movement\"]);\n const eat = propValue(row.properties?.[\"Eating\"]);\n snapshots.push({\n area: \"Health\",\n what: mv ? (\"Moved: \" + mv) : \"No movement logged yet today\",\n meta: eat || \"\",\n });\n } else {\n snapshots.push({\n area: \"Health\",\n what: \"No log yet today — tell me about your morning\",\n meta: \"\",\n });\n }\n } catch { /* daily log optional */ }\n return json({ calendar, urgent, snapshots });\n}\n\n// --- /task-done : narrow write --------------------------------------------\nasync function handleTaskDone(body: any) {\n const pageId = String(body?.pageId ?? \"\");\n if (!pageId) return json({ error: \"pageId required\" }, 400);\n await notion(`/pages/${pageId}`, {\n method: \"PATCH\",\n body: JSON.stringify({\n properties: { Status: { select: { name: \"Done\" } } },\n }),\n }, true);\n return json({ ok: true });\n}\n\n// --- /task-add : narrow write ---------------------------------------------\nasync function handleTaskAdd(body: any) {\n const task = String(body?.task ?? \"\").slice(0, 200);\n if (!task) return json({ error: \"task required\" }, 400);\n const area =\n [\"House\", \"Family\", \"Admin\", \"People\", \"Self\"].includes(body?.area)\n ? body.area\n : \"House\";\n const props: any = {\n Task: { title: [{ text: { content: task } }] },\n Area: { select: { name: area } },\n Status: { select: { name: \"To do\" } },\n };\n if (body?.due && /^\\d{4}-\\d{2}-\\d{2}$/.test(body.due)) {\n props.Due = { date: { start: body.due } };\n }\n if (body?.notes) {\n props.Notes = {\n rich_text: [{ text: { content: String(body.notes).slice(0, 300) } }],\n };\n }\n await notion(`/pages`, {\n method: \"POST\",\n body: JSON.stringify({\n parent: { database_id: IDS.tasksDb },\n properties: props,\n }),\n }, true);\n return json({ ok: true, added: task });\n}\n\n// --- /daily-update : voice update -> list changes ---------------------------\nasync function handleDailyUpdate(body: any) {\n const text = String(body?.text ?? \"\").slice(0, 1200);\n if (!text) return json({ error: \"text required\" }, 400);\n const tasks = await tasksRows().catch(() => []);\n const listing = tasks.map((t) =>\n `${t.id} :: ${t.title} [${t.Area || \"?\"}${t.due ? \", due \" + t.due : \"\"}]`\n ).join(\"\\n\");\n const today = new Date().toISOString().slice(0, 10);\n const system =\n `You maintain a to-do list. Given the open tasks (each line: id :: title [area, due]) and the person's ` +\n `spoken update, work out which existing tasks are DONE, which NEW tasks to add, and any due-date changes. ` +\n `Voice transcription may garble words — match on meaning. Today is ${today}. ` +\n `Her update may also mention FOOD she ate and NOVEL WRITING done — extract those too. ` +\n `Reply ONLY JSON: {\"done\":[\"\"],\"add\":[{\"task\":\"...\",\"area\":\"House|Family|Admin|People|Self\",\"due\":\"YYYY-MM-DD or empty\",\"notes\":\"\"}],` +\n `\"redate\":[{\"id\":\"\",\"due\":\"YYYY-MM-DD\"}],` +\n `\"dozen\":{:} using only keys ${\n DOZEN_KEYS.join(\"/\")\n } for food actually eaten,` +\n `\"novelWords\":,` +\n `\"log\":{\"entry\":\"\",` +\n `\"energy\":\"\",\"mood\":\"\",\"eating\":\"\",` +\n `\"movement\":[\"Morning\"|\"Afternoon\"|\"Evening\"],\"sleep\":{\"bedtime\":\"\",\"up\":\"\",\"wakes\":,\"approx\":\"\"},` +\n `\"cycleDay\":},` +\n `\"reply\":\"\"}. ` +\n `Only mark done what she clearly says is done. Only add clear new tasks.`;\n const raw = await askClaude(\n system,\n `OPEN TASKS:\\n${listing}\\n\\nHER UPDATE:\\n${text}`,\n 800,\n );\n let plan: any = {};\n try {\n const c = raw.replace(/\\u0060\\u0060\\u0060json/gi, \"\").replace(\n /\\u0060\\u0060\\u0060/g,\n \"\",\n ).trim();\n plan = JSON.parse(c.slice(c.indexOf(\"{\"), c.lastIndexOf(\"}\") + 1));\n } catch {\n return json({\n reply: \"I couldn't parse that — try rephrasing?\",\n done: 0,\n added: 0,\n });\n }\n const ids = new Set(tasks.map((t: any) => t.id));\n let doneN = 0, addN = 0;\n for (const id of (plan.done ?? [])) {\n if (ids.has(id)) {\n try {\n await handleTaskDone({ pageId: id });\n doneN++;\n } catch {}\n }\n }\n for (const a of (plan.add ?? []).slice(0, 10)) {\n try {\n await handleTaskAdd(a);\n addN++;\n } catch {}\n }\n for (const r of (plan.redate ?? [])) {\n if (ids.has(r.id) && /^\\d{4}-\\d{2}-\\d{2}$/.test(r.due ?? \"\")) {\n try {\n await notion(`/pages/${r.id}`, {\n method: \"PATCH\",\n body: JSON.stringify({\n properties: { Due: { date: { start: r.due } } },\n }),\n }, true);\n } catch {}\n }\n }\n // dozen: validate and pass back for the app to apply locally\n const dozen: Record = {};\n if (plan.dozen && typeof plan.dozen === \"object\") {\n for (const k of Object.keys(plan.dozen)) {\n if (DOZEN_KEYS.includes(k)) {\n const n = parseInt(plan.dozen[k], 10);\n if (n > 0) dozen[k] = Math.min(n, 3);\n }\n }\n }\n // novel words: log to the balance page\n const words = parseInt(plan.novelWords, 10);\n if (Number.isFinite(words) && words > 0) {\n try {\n await handleLogWords({ words });\n } catch {}\n }\n // daily log: upsert today's row\n try {\n const L = plan.log ?? {};\n if (\n L.entry || L.energy || L.mood || L.eating || (L.movement ?? []).length ||\n L.sleep\n ) {\n const db = await findDailyLogDb();\n let row = await todaysLogRow();\n const today = new Date();\n const dayName = today.toLocaleDateString(\"en-GB\", {\n weekday: \"short\",\n day: \"numeric\",\n month: \"short\",\n });\n const props: any = {};\n const setText = (name: string, v: string) => {\n if (v) {\n props[name] = {\n rich_text: [{ text: { content: String(v).slice(0, 300) } }],\n };\n }\n };\n setText(\"Energy (words)\", L.energy);\n setText(\"Mood (words)\", L.mood);\n setText(\"Eating\", L.eating);\n if (L.sleep) {\n setText(\"Bedtime\", L.sleep.bedtime);\n setText(\"Up for the day\", L.sleep.up);\n setText(\"Approx sleep\", L.sleep.approx);\n const w = parseInt(L.sleep.wakes, 10);\n if (Number.isFinite(w) && w >= 0) props[\"Night wakes\"] = { number: w };\n }\n const cd = parseInt(L.cycleDay, 10);\n if (Number.isFinite(cd) && cd > 0) props[\"Cycle day\"] = { number: cd };\n if ((L.movement ?? []).length) {\n props[\"Movement\"] = {\n multi_select: L.movement.filter((x: string) =>\n [\"Morning\", \"Afternoon\", \"Evening\", \"None\"].includes(x)\n ).map((x: string) => ({ name: x })),\n };\n }\n if (!row) {\n props[\"Day\"] = { title: [{ text: { content: dayName } }] };\n props[\"Date\"] = {\n date: { start: new Date().toISOString().slice(0, 10) },\n };\n const created = await notion(`/pages`, {\n method: \"POST\",\n body: JSON.stringify({\n parent: { database_id: db },\n properties: props,\n }),\n }, true);\n row = created;\n } else if (Object.keys(props).length) {\n await notion(`/pages/${row.id}`, {\n method: \"PATCH\",\n body: JSON.stringify({ properties: props }),\n }, true);\n }\n if (L.entry && row?.id) {\n const stamp = new Date().toLocaleTimeString(\"en-GB\", {\n hour: \"2-digit\",\n minute: \"2-digit\",\n });\n await notion(`/blocks/${row.id}/children`, {\n method: \"PATCH\",\n body: JSON.stringify({\n children: [{\n object: \"block\",\n type: \"bulleted_list_item\",\n bulleted_list_item: {\n rich_text: [{\n type: \"text\",\n text: {\n content: `${stamp} — ${String(L.entry).slice(0, 500)}`,\n },\n }],\n },\n }],\n }),\n }, true);\n }\n }\n } catch { /* log write is best-effort */ }\n return json({\n reply: plan.reply || `Done — ticked ${doneN}, added ${addN}.`,\n done: doneN,\n added: addN,\n dozen,\n });\n}\n\n// --- v1 endpoints, unchanged -------------------------------------------------\nconst DOZEN_KEYS = [\n \"beans\",\n \"berries\",\n \"fruit\",\n \"cruc\",\n \"greens\",\n \"veg\",\n \"flax\",\n \"nuts\",\n \"spices\",\n \"grains\",\n \"drinks\",\n \"exercise\",\n];\nconst SATISFIABLE = [\n \"nuts\",\n \"brazil\",\n \"turmeric\",\n \"garlic\",\n \"amla\",\n \"blackcumin\",\n \"cumin\",\n \"ginger\",\n];\n\nasync function handleMeal(body: any) {\n const text = String(body?.text ?? \"\").slice(0, 800);\n const system =\n `You read a meal description and map it onto Dr. Greger's Daily Dozen. Reply with ONLY JSON:\\n` +\n `{\"dozen\":{:},\"satisfied\":[],\"note\":\"\"}\\n` +\n `Valid keys: ${DOZEN_KEYS.join(\", \")}. Valid ids: ${\n SATISFIABLE.join(\", \")\n }. Note under 15 words.`;\n const raw = await askClaude(system, `Meal: ${text}`, 400);\n let parsed: any = {};\n try {\n const c = raw.replace(/```json/gi, \"\").replace(/```/g, \"\").trim();\n parsed = JSON.parse(c.slice(c.indexOf(\"{\"), c.lastIndexOf(\"}\") + 1));\n } catch {\n parsed = {};\n }\n const dozen: Record = {};\n for (const k of Object.keys(parsed.dozen ?? {})) {\n if (DOZEN_KEYS.includes(k)) {\n const n = parseInt(parsed.dozen[k], 10);\n if (n > 0) dozen[k] = Math.min(n, 3);\n }\n }\n return json({\n dozen,\n satisfied: Array.isArray(parsed.satisfied)\n ? parsed.satisfied.filter((x: any) => SATISFIABLE.includes(x))\n : [],\n note: typeof parsed.note === \"string\" ? parsed.note : \"Logged your meal.\",\n });\n}\n\nasync function handleSummary(body: any) {\n const counts = body?.counts ?? {};\n const done = Array.isArray(body?.done) ? body.done : [];\n const lines = DOZEN_KEYS.filter((k) => counts[k]).map((k) =>\n `${k}: ${counts[k].got}/${counts[k].goal}`\n ).join(\", \");\n const system =\n `You are a warm, encouraging coach. Write 2-4 short sentences, no lists, no markdown. ` +\n `Name what she nailed, flag one or two gaps as easy wins, end kindly. Never mention calories or restriction.`;\n const text = await askClaude(\n system,\n `Daily Dozen today — ${\n lines || \"nothing logged\"\n }. Reminders completed: ${done.length} (${\n done.slice(0, 12).join(\"; \") || \"none\"\n }).`,\n 350,\n );\n return json({ text });\n}\n\nasync function handleFridge(body: any) {\n const ingredients = String(body?.ingredients ?? \"\").slice(0, 600);\n const gaps = Array.isArray(body?.gaps) ? body.gaps.join(\", \") : \"\";\n const system =\n `Suggest ONE simple plant-forward meal from what's on hand. 3-5 short sentences, no lists or markdown: ` +\n `name it, quick how-to, which Daily Dozen boxes it ticks. Lean toward what she's short of. Quick and realistic. No alcohol.`;\n const text = await askClaude(\n system,\n `Have: ${ingredients}.` + (gaps ? ` Short on: ${gaps}.` : \"\"),\n 400,\n );\n return json({ text });\n}\n\n// --- /area : detail data for a section's page --------------------------------\n// Body: { area: \"substack\" | \"novel\" }\nasync function handleArea(body: any) {\n const area = String(body?.area ?? \"\");\n if (area === \"substack\") {\n const [rows, priorities] = await Promise.all([\n pipelineRows().catch(() => []),\n pageText(IDS.substackPriority, true).catch(() => \"\"),\n ]);\n return json({ rows, priorities });\n }\n if (area === \"tasks\") {\n const rows = await tasksRows().catch(() => []);\n return json({ rows });\n }\n if (area === \"novel\") {\n const [text, balance] = await Promise.all([\n pageText(IDS.novelPriority, false).catch(() => \"\"),\n pageText(IDS.balance, true).catch(() => \"\"),\n ]);\n return json({ text, balance });\n }\n return json({ error: \"area must be substack, novel or tasks\" }, 400);\n}\n\n// --- router ------------------------------------------------------------------\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS });\n }\n const path = new URL(req.url).pathname.replace(/\\/+$/, \"\");\n\n if (req.method === \"GET\" && (path === \"\" || path === \"/\")) {\n return new Response(\n \"Co-pilot backend v2 running. POST to /priority, /dashboard, /area, /task-done, /task-add, /daily-update, /published, /log-words, /meal, /summary, /fridge.\",\n { headers: { \"Content-Type\": \"text/plain\", ...CORS } },\n );\n }\n if (req.method !== \"POST\") return json({ error: \"Use POST.\" }, 405);\n\n let body: any = {};\n try {\n body = await req.json();\n } catch {\n return json({ error: \"Invalid JSON body.\" }, 400);\n }\n\n try {\n if (path.endsWith(\"/priority\")) return await handlePriority(body);\n if (path.endsWith(\"/dashboard\")) return await handleDashboard(body);\n if (path.endsWith(\"/area\")) return await handleArea(body);\n if (path.endsWith(\"/task-done\")) return await handleTaskDone(body);\n if (path.endsWith(\"/task-add\")) return await handleTaskAdd(body);\n if (path.endsWith(\"/daily-update\")) return await handleDailyUpdate(body);\n if (path.endsWith(\"/published\")) return await handlePublished(body);\n if (path.endsWith(\"/log-words\")) return await handleLogWords(body);\n if (path.endsWith(\"/meal\")) return await handleMeal(body);\n if (path.endsWith(\"/summary\")) return await handleSummary(body);\n if (path.endsWith(\"/fridge\")) return await handleFridge(body);\n return json({ error: \"Unknown endpoint.\" }, 404);\n } catch (err: any) {\n return json({ error: String(err?.message ?? err) }, 500);\n }\n}","createdAt",["D",1785677971784],"branchVersion","branchId","9b33e21a-d22d-4dd7-a09a-78b0a0326802","id","6fe4e55b-4304-43ef-88ce-d1e1f6bd6dab","main-http-ts",["D",1781964892100],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","my app","imageUrl","bbb5f228-9df2-49bd-bfe4-73bf5b53ee7a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ee535-cdc5-745a-99b6-c69e7f17c1cd","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","harrietbrown","handle","displayName","Harriet Brown","avatar","https://lh3.googleusercontent.com/a/ACg8ocIHMQtDEx9WfQtjRIQ_PQMehw2VfBYXt-Zz855UGV23pl-4W7MO=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":152,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":153,"_79":154,"_81":155,"_83":25},"tree",[147],"files",[147],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"a3eaac1a-01d5-40de-b5e5-5a6c332abf00","parentId","latest",["D",1785677971784],7,"label",[28],"pulls","branches",1,"forks","envVars",{"_143":145,"_146":61},"connections",{"_143":61,"_144":61},"count","unfilledCount",5,"emptyCount",{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":148,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_149":150,"_27":151},["D",1785677971784],"children",[],[28],["D",1781964892100],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_124":189,"_190":191,"_192":193,"_194":25,"_195":25,"_196":25,"_197":122,"_198":-5,"_199":-7,"_200":-7,"_201":61,"_202":25,"_203":25,"_204":-5,"_205":25,"_206":25,"_207":25,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":85,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8