[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","ClaudeAssistant","name","palantir-herald","path","palantir-routes.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":-5,"_58":42,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/ClaudeAssistant/palantir-herald/code/palantir-routes.ts","extension","id","75fdd5fe-5e3c-47db-9b42-8ff22effa87b","fileId","61b2d050-a64f-11f1-86de-1607ee4eb77e","parentId","branchId","cc31caf5-d2e1-4af9-b0dd-bd82fa3e53fe","branchVersion",90,"latest",true,"createdAt",["D",1789004711694],"version",15,"fileType","script","content","// Palantír routes (HQ, 1–2 Sep 2026) — the dashboard's data in the val, the bot as a citizen.\n// Split into its own file: bot-webhook.ts sits at Val Town's 80k limit.\n//\n// /snapshot POST (bus auth) the PC pushes a SECRET-FREE copy of dashboard/data.js after every\n// regeneration; GET returns it. Quest #110: every fact the dashboard shows, askable.\n// /dayselection POST {date?, picks:[{task_id,state}]} — the battle picker on the page (quest #98).\n// /forge POST {mode:\"desktop\"|\"cloud\"} — same two paths the Telegram keyboard offers.\n// /presence POST {session, minutes, note} heartbeat of the desktop Gatekeeper; GET who is awake.\n// /gate/pull GET queued private messages, claimed for the caller (quest #112).\n// /gate/answer POST {id, text} → Telegram reply + row answered. /gate/release POST {id}.\n// handleCommand /money /fleet /tasks (alias /quests) /today /road /news /shelf /deeds /journal /who /help — free, no LLM.\n// gateRoute present → queue for the Gatekeeper; absent → \"the stone is dark\" (+ /ask to push credits).\n// snapshotContext what the cloud brain (/ask) gets to see beyond open quests.\n// applyBrainActions structured actions the brain may return: create_tasks, note, dispatch.\n// Mounted by bot-webhook.ts: mountPalantir(app, sqlite, PULL_SECRET, busAuth, { send, tg, forgePlan, forgePlanBrain }).\n// /mirror/* the Mirror tab's answers (task #232, 9 Sep 2026) — lives in mirror-routes.ts, mounted from here.\n// /coldpath/* the missed-slot reconciler's status and switches (task #220, 10 Sep 2026) — lives in reconciler.ts,\n// mounted from here; /coldpath in the bot is coldPathCommand from the same file.\n\nimport { mountMirror } from \"./mirror-routes.ts\";\n// Static on purpose: mountColdPath must register its routes while the app is being built, and\n// coldPathCommand sits in the webhook's request path. herald-fallback.ts imports the same file lazily\n// instead, inside a try — the rescue brief must never fail to load because of this module.\nimport { mountColdPath, coldPathCommand } from \"./reconciler.ts\";\n\nconst STAMP = () => new Date().toISOString().slice(0, 19).replace(\"T\", \" \");\nconst esc = (s: any) => String(s ?? \"\").replace(/[_*`\\[]/g, (m) => \"\\\\\" + m); // Telegram Markdown v1 escapes\nconst eur = (v: any) => (v == null || isNaN(Number(v))) ? \"—\" : \"€\" + Number(v).toFixed(2).replace(/\\B(?=(\\d{3})+(?!\\d))/g, \" \").replace(\".\", \",\");\nconst eur0 = (v: any) => (v == null || isNaN(Number(v))) ? \"—\" : \"€\" + Math.round(Number(v)).toLocaleString(\"en\").replace(/,/g, \" \");\n\nlet deps: any = {};\nlet db: any = null;\n\nasync function init(sqlite: any) {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS snapshot (\n key TEXT PRIMARY KEY, data TEXT, stamp TEXT, ts TEXT DEFAULT (datetime('now')))`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS presence (\n session TEXT PRIMARY KEY, until TEXT, note TEXT, ts TEXT DEFAULT (datetime('now')))`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS gate_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT DEFAULT (datetime('now')),\n chat_id INTEGER, text TEXT, status TEXT DEFAULT 'queued',\n claimed_by TEXT, claimed_at TEXT, answered_at TEXT, answer_chars INTEGER)`);\n // Quest #98: deadlines were free text (\"due Mon 31 Aug\") — a column the page, the herald and the\n // beacons can read. ISO date, nullable.\n try { await sqlite.execute(\"ALTER TABLE tasks ADD COLUMN due TEXT\"); } catch (_) { /* already there */ }\n // The night watch's tables are declared here too, identically to night-watch.ts.\n // Whichever of the two runs first wins, and the reader never 500s on a table the\n // writer has not created yet — the interval may not have fired since deploy.\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS balance_history (\n day TEXT PRIMARY KEY, business_eur REAL, currency TEXT, source TEXT, ts TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS nightwatch_runs (\n ts TEXT PRIMARY KEY, job TEXT, status TEXT, detail TEXT)`);\n}\n\n// ---------- snapshot ----------\nasync function getSnapshot(sqlite: any): Promise<{ data: any, stamp: string } | null> {\n const r = await sqlite.execute(\"SELECT data, stamp FROM snapshot WHERE key='dashboard'\");\n if (!r.rows.length) return null;\n try { return { data: JSON.parse(r.rows[0].data as string), stamp: String(r.rows[0].stamp ?? \"\") }; }\n catch { return null; }\n}\n\nfunction stripSecrets(d: any): any {\n if (!d || typeof d !== \"object\") return d;\n const out: any = Array.isArray(d) ? [] : {};\n for (const k of Object.keys(d)) {\n if (k === \"api\" || k === \"secret\" || /token|secret|password/i.test(k)) continue;\n const v = d[k];\n out[k] = (v && typeof v === \"object\") ? stripSecrets(v) : v;\n }\n return out;\n}\n\n// ---------- presence + gate ----------\nasync function whoIsAwake(sqlite: any): Promise {\n const r = await sqlite.execute(\"SELECT session, until, note, ts FROM presence WHERE until > datetime('now') ORDER BY until DESC\");\n return r.rows as any[];\n}\n\nfunction ageOf(stamp: string): string {\n if (!stamp) return \"no stamp\";\n const d = new Date(stamp.replace(\" \", \"T\") + (/[zZ]|[+-]\\d\\d:?\\d\\d$/.test(stamp) ? \"\" : \"+02:00\"));\n if (isNaN(d.getTime())) return stamp;\n const m = Math.round((Date.now() - d.getTime()) / 60000);\n if (m < 1) return \"just now\";\n if (m < 60) return `${m} min ago`;\n if (m < 48 * 60) return `${Math.round(m / 60)} h ago`;\n return `${Math.round(m / 1440)} d ago`;\n}\n\nfunction localHHMM(d: Date): string {\n return d.toLocaleTimeString(\"en-GB\", { hour: \"2-digit\", minute: \"2-digit\", timeZone: \"Europe/Amsterdam\" });\n}\n\n// ---------- the free commands ----------\nconst HELP = `🔮 *Palantír in the pocket* — no credits, straight from the dashboard's last refresh:\n/money — the pot, Wise, this month, standing orders\n/fleet — who reported, who is silent, the bus\n/quests — open quests by tier (with #ids)\n/today — calendar + the battle plan\n/road — the next 14 days\n/news — today's heat map\n/shelf — Rivendell today\n/deeds — closed this week\n/journal — the last 10 lines\n/who — is a session awake?\n/coldpath — what did not run while the PC was off, and the two switches\n/ask — wake the cloud brain ⚡ (credits)`;\n\nasync function renderCommand(sqlite: any, cmd: string): Promise {\n const snap = await getSnapshot(sqlite);\n const D = snap?.data ?? {};\n const age = snap ? `_as of ${esc(snap.stamp)} · ${ageOf(snap.stamp)}_` : \"_no snapshot yet — the PC has not pushed one_\";\n const list = (arr: any[], f: (x: any) => string, max = 12) => arr.slice(0, max).map(f).join(\"\\n\") || \"—\";\n\n if (cmd === \"help\" || cmd === \"start\") return HELP;\n\n if (cmd === \"money\") {\n const ML = D?.money?.live ?? {}, MS = D?.money?.spend ?? {}, B = D?.business ?? {};\n // #159 (4 Sep 2026) — the name comes from ACCOUNT_LABELS in update_dashboard_data.py, the same\n // map the console reads. bank + last four stays as provenance and fallback, never as the headline.\n const accts = (ML.accounts ?? []).map((a: any) =>\n `• *${esc(a.label ?? `${a.bank} …${a.tail}`)}* (${esc(a.bank)} …${esc(a.tail)}): *${eur(a.balance)}* — as of ${esc(a.as_of ?? \"?\")}`).join(\"\\n\");\n const cats = (MS.monthCategories ?? []).slice(0, 6).map((c: any) => `• ${esc(c.cat)} ${eur0(c.eur)}`).join(\"\\n\");\n const bk = MS.book?.totals ?? {};\n const bop = MS.businessOnPersonal ?? {};\n const PM = MS.previousMonth ?? null;\n const moved = [MS.monthMovedAssets ? `${eur0(MS.monthMovedAssets)} into crypto/investing` : \"\", MS.monthMovedInternal ? `${eur0(MS.monthMovedInternal)} between own accounts` : \"\"].filter(Boolean).join(\", \");\n return `💰 *Money*\\n*Personal pot: ${eur(ML.personalTotal)}* (ABN + Revolut, one pot)\\n${accts || \"• no live balances\"}\\n` +\n `*Business (Wise): ${eur0(B.coffersEUR)}* ${B.coffersSource ? \"· \" + esc(B.coffersSource) : \"\"}\\n\\n` +\n `*This month so far* (${esc(MS.monthLabel ?? \"?\")}): *${eur(MS.monthTotalOut)} consumed*${moved ? ` — not counted: ${moved}` : \"\"}\\n${cats}\\n` +\n (PM && PM.out != null ? `\\n*${esc(PM.label)}:* ${eur(PM.out)} consumed · ${eur0(PM.assets)} into crypto/investing · ${eur0(PM.internal)} moved between own accounts · ${eur0(PM.income)} came in${PM.family ? ` (${eur0(PM.family)} of it from Sergey — yours)` : \"\"}\\n` +\n (PM.categories ?? []).slice(0, 6).map((c: any) => `• ${esc(c.cat)} ${eur0(c.eur)}`).join(\"\\n\") + \"\\n\" : \"\") + \"\\n\" +\n `*Standing orders:* ${eur(bk.liveMonthly)}/month · ${bk.liveCount ?? \"?\"} live · ${eur(bk.byDuty?.free)} your choice · ${bk.checkCount ?? 0} need a check\\n` +\n (bop.core_maraletto != null ? `*Maraletto owes you:* ${eur(bop.core_maraletto)}\\n` : \"\") +\n `\\n${age}`;\n }\n\n if (cmd === \"fleet\") {\n const FL = D?.fleet ?? {}, W = FL.watch ?? {};\n const awake = await whoIsAwake(sqlite);\n const st = await sqlite.execute(\"SELECT status, COUNT(*) AS n FROM agent_jobs GROUP BY status\");\n const counts: Record = {}; for (const r of st.rows as any[]) counts[String(r.status)] = Number(r.n);\n const stranded = await sqlite.execute(\"SELECT id, agent FROM agent_jobs WHERE status='running' AND COALESCE(claimed_at, ts) < datetime('now','-2 hours')\");\n const blocked = await sqlite.execute(\"SELECT COUNT(*) AS n FROM agent_blocked WHERE resolved=0\");\n const ok = (W.ok ?? []).map((a: any) => esc(a.agent)).join(\", \") || \"—\";\n const silent = (W.silent ?? []).map((a: any) => `${esc(a.agent)} (${esc(a.why ?? \"\")})`).join(\", \");\n const waiting = (W.waiting ?? []).map((a: any) => esc(a.agent)).join(\", \");\n const last = await sqlite.execute(\"SELECT ts, source, summary FROM journal ORDER BY id DESC LIMIT 3\");\n return `🏰 *The Citadel*\\n` +\n `*Reporting:* ${ok}\\n` + (silent ? `*SILENT:* ${silent}\\n` : `*Silent:* none\\n`) + (waiting ? `*Waiting/outside window:* ${waiting}\\n` : \"\") +\n `*Bus:* ${counts.queued ?? 0} queued · ${counts.running ?? 0} running · ${stranded.rows.length} stranded\\n` +\n `*Blocked runs open:* ${Number((blocked.rows[0] as any)?.n ?? 0)}\\n` +\n `*Awake now:* ${awake.length ? awake.map((a) => esc(a.session)).join(\", \") : \"no session — the stone is dark\"}\\n\\n` +\n `*Last journal:*\\n${list(last.rows as any[], (r: any) => `• ${esc(String(r.ts).slice(11, 16))} ${esc(r.source)}: ${esc(String(r.summary).slice(0, 110))}`)}\\n\\n${age}`;\n }\n\n if (cmd === \"quests\" || cmd === \"tasks\") { // \"tasks\" is the plain-English name (3 Sep 2026); \"quests\" kept so old muscle memory still works\n const r = await sqlite.execute(\"SELECT id, title, tier, due FROM tasks WHERE status='open' AND COALESCE(owner,'alexandr')='alexandr' ORDER BY CASE tier WHEN 'balrog' THEN 0 WHEN 'nazgul' THEN 1 WHEN 'fellowship' THEN 2 ELSE 3 END, ord, id\");\n const byTier: Record = {};\n for (const t of r.rows as any[]) (byTier[String(t.tier)] = byTier[String(t.tier)] ?? []).push(t);\n const names: Record = { balrog: \"🔥 Urgent\", nazgul: \"⚔️ Due soon\", fellowship: \"🧭 Active\", shire: \"🌿 Someday\" };\n let out = `📜 *Quest Log — ${r.rows.length} open*\\n`;\n for (const k of [\"balrog\", \"nazgul\", \"fellowship\", \"shire\"]) {\n const items = byTier[k] ?? []; if (!items.length) continue;\n out += `\\n*${names[k]}* (${items.length})\\n` + items.slice(0, 15).map((t: any) => `#${t.id} ${esc(String(t.title).slice(0, 80))}${t.due ? ` · due ${esc(t.due)}` : \"\"}`).join(\"\\n\") + (items.length > 15 ? `\\n… ${items.length - 15} more` : \"\") + \"\\n\";\n }\n return out + \"\\n_live from the val_\";\n }\n\n if (cmd === \"today\") {\n const dl = D?.daily ?? {};\n const date = new Date().toISOString().slice(0, 10);\n const picks = await sqlite.execute({ sql: \"SELECT dp.task_id, dp.state, t.title FROM day_plan dp LEFT JOIN tasks t ON t.id=dp.task_id WHERE dp.date=? AND dp.state!='none'\", args: [date] });\n const plan = await sqlite.execute({ sql: \"SELECT plan FROM day_plan_text WHERE date=?\", args: [date] });\n const cal = list(dl.calendar ?? [], (c: any) => `• ${esc(c.when || \"\")} ${esc(c.title)}${c.cal && c.cal !== \"own\" ? ` (${esc(c.cal)})` : \"\"}`);\n const pk = list(picks.rows as any[], (p: any) => `• ${p.state === \"done\" ? \"✅\" : \"📅\"} #${p.task_id} ${esc(String(p.title ?? \"\").slice(0, 70))}`);\n const pl = String(plan.rows[0]?.plan ?? \"\");\n return `☀️ *Today*\\n*Calendar:*\\n${cal}\\n\\n*Battles chosen:*\\n${picks.rows.length ? pk : \"none yet — pick on the dashboard or in the morning form\"}\\n\\n*Plan:* ${pl ? (pl.startsWith(\"AWAITING\") ? \"chosen, forge pending\" : esc(pl.slice(0, 900))) : \"not forged\"}\\n\\n${age}`;\n }\n\n if (cmd === \"road\") {\n const up = D?.daily?.upcoming ?? [];\n const dues = await sqlite.execute(\"SELECT id, title, due FROM tasks WHERE status='open' AND due IS NOT NULL AND due != '' ORDER BY due LIMIT 15\");\n const days: Record = {};\n for (const e of up) (days[e.day ?? \"?\"] = days[e.day ?? \"?\"] ?? []).push(`• ${esc(e.time || \"\")} ${esc(e.title)}${e.cal && e.cal !== \"own\" ? ` (${esc(e.cal)})` : \"\"}`);\n let out = \"🛤 *The Road Ahead — 14 days*\\n\";\n for (const d of Object.keys(days).slice(0, 14)) out += `\\n*${esc(d)}*\\n${days[d].join(\"\\n\")}\\n`;\n if (dues.rows.length) out += `\\n*Quest deadlines:*\\n` + list(dues.rows as any[], (t: any) => `• ${esc(t.due)} — #${t.id} ${esc(String(t.title).slice(0, 60))}`);\n return out + `\\n\\n${age}`;\n }\n\n if (cmd === \"news\") {\n const K = D?.knowledge ?? {}, dd = K.daily ?? {};\n const blocks: [string, string][] = [[\"trending\", \"🔥 Trending\"], [\"react\", \"🎯 Might need your reaction\"], [\"tech\", \"⚗️ Tech & science\"], [\"know\", \"📖 Good to know\"], [\"curious\", \"✨ Curious\"]];\n let out = `📰 *Heat Map* ${K.generatedAt ? \"· \" + esc(K.generatedAt) : \"\"}\\n`;\n for (const [k, name] of blocks) {\n const items = dd[k] ?? []; if (!items.length) continue;\n out += `\\n*${name}*\\n` + items.slice(0, 4).map((t: any) => `• ${t.url ? `[${esc(String(t.title).slice(0, 80))}](${t.url})` : esc(String(t.title).slice(0, 80))}`).join(\"\\n\") + \"\\n\";\n }\n return out + `\\n${age}`;\n }\n\n if (cmd === \"shelf\") {\n const RV = D?.rivendell ?? {};\n const item = (t: any) => `• ${t.url ? `[${esc(String(t.title).slice(0, 70))}](${t.url})` : esc(String(t.title).slice(0, 70))} _(${esc(t.source ?? \"\")}, ~${t.readMinutes ?? \"?\"} min)_`;\n return `🏛 *Rivendell today*\\n*The Athenaeum*\\n${list(RV.athenaeum ?? [], item)}\\n\\n*The Frontier*\\n${list(RV.frontier ?? [], item)}\\n\\n_archive: ${RV.archiveCount ?? \"?\"} pieces_\\n${age}`;\n }\n\n if (cmd === \"deeds\") {\n const r = await sqlite.execute(\"SELECT id, title, done_at FROM tasks WHERE status='done' AND done_at > datetime('now','-7 days') AND COALESCE(owner,'alexandr')='alexandr' ORDER BY done_at DESC LIMIT 20\");\n const jobs = await sqlite.execute(\"SELECT id, agent, done_at, substr(brief,1,70) AS brief FROM agent_jobs WHERE status='done' AND done_at > datetime('now','-7 days') ORDER BY id DESC LIMIT 8\");\n return `✅ *Deeds — last 7 days*\\n*Quests closed (${r.rows.length}):*\\n${list(r.rows as any[], (t: any) => `• ${esc(String(t.done_at).slice(5, 10))} #${t.id} ${esc(String(t.title).slice(0, 70))}`, 20)}\\n\\n*Errands delivered (${jobs.rows.length}):*\\n${list(jobs.rows as any[], (j: any) => `• #${j.id} ${esc(j.agent)}: ${esc(j.brief)}…`)}\\n\\n_live from the val_`;\n }\n\n if (cmd === \"journal\") {\n const r = await sqlite.execute(\"SELECT ts, source, summary FROM journal ORDER BY id DESC LIMIT 10\");\n return `📓 *The Chronicle — last 10*\\n` + list(r.rows as any[], (x: any) => `• ${esc(String(x.ts).slice(5, 16))} *${esc(x.source)}* — ${esc(String(x.summary).slice(0, 140))}`, 10) + \"\\n\\n_live from the val (UTC stamps)_\";\n }\n\n if (cmd === \"who\") {\n const awake = await whoIsAwake(sqlite);\n const q = await sqlite.execute(\"SELECT COUNT(*) AS n FROM gate_queue WHERE status IN ('queued','claimed')\");\n return awake.length\n ? `🟢 *Awake:* ${awake.map((a) => `${esc(a.session)} (until ${esc(String(a.until).slice(11, 16))} UTC${a.note ? \", \" + esc(a.note) : \"\"})`).join(\"; \")}\\n_${Number((q.rows[0] as any)?.n ?? 0)} message(s) waiting at the gate_`\n : `🌑 *The stone is dark* — no desktop session is awake. Captures still work; questions wait, or /ask wakes the cloud brain ⚡ (credits).`;\n }\n return null;\n}\n\n// ---------- brain context (for /ask) ----------\nasync function snapshotContext(sqlite: any): Promise {\n const snap = await getSnapshot(sqlite);\n if (!snap) return \"DASHBOARD SNAPSHOT: none pushed yet.\";\n const D = snap.data ?? {};\n const ML = D.money?.live ?? {}, MS = D.money?.spend ?? {}, B = D.business ?? {}, dl = D.daily ?? {}, W = D.fleet?.watch ?? {};\n const short = (arr: any[], f: (x: any) => string, n = 8) => (arr ?? []).slice(0, n).map(f).join(\"; \");\n return `DASHBOARD SNAPSHOT (as of ${snap.stamp}, ${ageOf(snap.stamp)}):\nMONEY personal pot ${ML.personalTotal ?? \"?\"} EUR = ${short(ML.accounts ?? [], (a: any) => `${a.label ?? `${a.bank} …${a.tail}`} (${a.bank} …${a.tail}) ${a.balance} as of ${a.as_of}`)}; business Wise ${B.coffersEUR ?? \"?\"} EUR; month ${MS.monthLabel ?? \"?\"} out ${MS.monthTotalOut ?? \"?\"}: ${short(MS.monthCategories ?? [], (c: any) => `${c.cat} ${c.eur}`)}; standing orders ${MS.book?.totals?.liveMonthly ?? \"?\"}/mo (${MS.book?.totals?.liveCount ?? \"?\"} live); Maraletto owes ${MS.businessOnPersonal?.core_maraletto ?? \"?\"}.\nCALENDAR today: ${short(dl.calendar ?? [], (c: any) => `${c.when} ${c.title}`)}. NEXT DAYS: ${short(dl.upcoming ?? [], (e: any) => `${e.day} ${e.time} ${e.title}`, 14)}.\nAGENTS ok: ${(W.ok ?? []).map((a: any) => a.agent).join(\",\")}; silent: ${(W.silent ?? []).map((a: any) => a.agent).join(\",\") || \"none\"}; waiting: ${(W.waiting ?? []).map((a: any) => a.agent).join(\",\") || \"none\"}.\nNEWS today: ${short(Object.values(dl ? (D.knowledge?.daily ?? {}) : {}).flat() as any[], (t: any) => t.title, 10)}.\nRIVENDELL: ${short([...(D.rivendell?.athenaeum ?? []), ...(D.rivendell?.frontier ?? [])], (t: any) => t.title, 9)}.\nDECISIONS pending: ${short(D.vault?.decisions ?? [], (d: any) => d.title)}.`;\n}\n\n// ---------- structured actions the brain may return ----------\nasync function applyBrainActions(sqlite: any, j: any, chatId: number): Promise {\n const did: string[] = [];\n for (const t of (Array.isArray(j.create_tasks) ? j.create_tasks : []).slice(0, 5)) {\n const title = String(t?.title ?? t ?? \"\").slice(0, 160); if (title.length < 3) continue;\n const mx = await sqlite.execute({ sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier=?\", args: [t?.tier ?? \"fellowship\"] });\n await sqlite.execute({ sql: \"INSERT INTO tasks (title, note, tier, area, ord, owner, due) VALUES (?,?,?,?,?,?,?)\",\n args: [title, \"via /ask \" + new Date().toISOString().slice(0, 10), t?.tier ?? \"fellowship\", t?.area ?? \"\", mx.rows[0].o,\n /^\\s*(HQ[:\\/]|RUMO-ORCH|\\[CHANGE REQUEST\\]|Wright[:\\/ ]|Bolt[:\\/ ]|Palantir defect|Build:)/i.test(title) ? \"system\" : \"alexandr\",\n t?.due ?? null] });\n did.push(`quest: ${title.slice(0, 50)}`);\n }\n if (j.note && String(j.note).trim().length > 3) {\n await sqlite.execute({ sql: \"INSERT INTO inbox (chat_id, kind, text, processed) VALUES (?,?,?,0)\",\n args: [chatId, \"note\", String(j.note).slice(0, 1500) + \"\\n[via: /ask cloud brain]\"] });\n did.push(\"note → vault\");\n }\n if (j.dispatch && j.dispatch.brief) {\n await sqlite.execute({ sql: \"INSERT INTO agent_jobs (agent, brief, packs) VALUES (?,?,?)\",\n args: [String(j.dispatch.agent ?? \"rex-runner\"), String(j.dispatch.brief).slice(0, 1500) + \"\\n\\n(dispatched by the cloud brain on Alexandr's /ask)\", \"[]\"] });\n did.push(`errand → ${j.dispatch.agent ?? \"rex-runner\"}`);\n }\n if (did.length) await sqlite.execute({ sql: \"INSERT INTO journal (source, summary, details) VALUES (?,?,?)\",\n args: [\"cloud brain (/ask)\", \"acted on /ask: \" + did.join(\", \"), JSON.stringify(j).slice(0, 1500)] });\n return did;\n}\n\n// ---------- routing when a human writes ----------\n// Returns true when the message was handled here (command, or queued for the gate, or dark-stone answer).\nasync function gateRoute(sqlite: any, chatId: number, text: string, isChatIntent: boolean): Promise {\n const awake = await whoIsAwake(sqlite);\n if (awake.length) {\n await sqlite.execute({ sql: \"INSERT INTO gate_queue (chat_id, text) VALUES (?,?)\", args: [chatId, text.slice(0, 4000)] });\n await deps.tg(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n // stale rows from a session that died mid-way: say so once, then let the gatekeeper's next pull handle them\n const stale = await sqlite.execute(\"SELECT COUNT(*) AS n FROM gate_queue WHERE status IN ('queued','claimed') AND ts < datetime('now','-6 minutes')\");\n if (Number((stale.rows[0] as any)?.n ?? 0) > 0) {\n await deps.send(chatId, `⏳ ${(stale.rows[0] as any).n} earlier message(s) are still waiting at the gate — the session may have gone quiet. /who to check, /ask to push the cloud brain ⚡.`);\n }\n return true;\n }\n if (!isChatIntent) return false; // captures (task / note / directive / hq) keep their free path when nobody is awake\n await deps.send(chatId, \"🌑 *The stone is dark* — no desktop session is awake, so this waits for the next watch. Urgent? Reply `/ask` + your question to wake the cloud brain ⚡ (credits).\");\n return true;\n}\n\nexport function mountPalantir(app: any, sqlite: any, PULL_SECRET: string, busAuth: any, d: any) {\n deps = d; db = sqlite;\n const ready = init(sqlite);\n const auth = (c: any) => c.req.query(\"secret\") === PULL_SECRET;\n mountMirror(app, sqlite, PULL_SECRET, busAuth); // HQ 9 Sep 2026 (#232): /mirror/answer, /mirror/answers, /mirror/applied\n mountColdPath(app, sqlite, PULL_SECRET, busAuth); // Ada 10 Sep 2026 (#220): GET /coldpath, POST /coldpath/{flag,run,forget}\n\n app.post(\"/snapshot\", async (c: any) => {\n await ready;\n const body = await c.req.json().catch(() => ({}));\n if (!(await busAuth(c, body))) return c.text(\"forbidden\", 401);\n const data = stripSecrets(body.data ?? body);\n delete data.secret;\n const txt = JSON.stringify(data);\n if (txt.indexOf(PULL_SECRET) >= 0) return c.json({ ok: false, error: \"the payload contains the write secret — refused\" }, 400);\n if (txt.length > 900_000) return c.json({ ok: false, error: \"snapshot too large\" }, 413);\n const stamp = String(data.generatedAt ?? STAMP());\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO snapshot (key, data, stamp, ts) VALUES ('dashboard', ?, ?, datetime('now'))\", args: [txt, stamp] });\n const back = await sqlite.execute(\"SELECT length(data) AS n, stamp FROM snapshot WHERE key='dashboard'\");\n return c.json({ ok: true, bytes: Number((back.rows[0] as any)?.n ?? 0), stamp: (back.rows[0] as any)?.stamp });\n });\n app.get(\"/snapshot\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const s = await getSnapshot(sqlite);\n return c.json(s ? { ok: true, stamp: s.stamp, age: ageOf(s.stamp), data: s.data } : { ok: false, error: \"no snapshot yet\" });\n });\n\n // #134 (5 Sep 2026) — undo for an accidentally closed task, as its own verb so callers cannot get it\n // half right: status back to open AND done_at forgotten, or the console keeps counting it as closed.\n // Lives here because bot-webhook.ts sits at Val Town's 80k limit.\n app.post(\"/tasks/:id/reopen\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const id = Number(c.req.param(\"id\"));\n const row = await sqlite.execute({ sql: \"SELECT id, status FROM tasks WHERE id=?\", args: [id] });\n if (!row.rows.length) return c.json({ ok: false, error: `no task ${id}` }, 404);\n await sqlite.execute({ sql: \"UPDATE tasks SET status='open', done_at=NULL WHERE id=?\", args: [id] });\n const back = await sqlite.execute({ sql: \"SELECT * FROM tasks WHERE id=?\", args: [id] });\n return c.json({ ok: true, task: back.rows[0] ?? null });\n });\n\n // the battle picker on the page — same table the Telegram keyboard writes\n app.post(\"/dayselection\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const b = await c.req.json().catch(() => ({}));\n const date = String(b.date ?? new Date().toISOString().slice(0, 10)).slice(0, 10);\n const picks = Array.isArray(b.picks) ? b.picks : [];\n let n = 0;\n for (const p of picks) {\n const id = Number(p.task_id), state = String(p.state ?? \"none\");\n if (!id || ![\"none\", \"today\", \"done\"].includes(state)) continue;\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO day_plan (date, task_id, state) VALUES (?,?,?)\", args: [date, id, state] });\n n++;\n }\n const r = await sqlite.execute({ sql: \"SELECT dp.task_id, dp.state, t.title FROM day_plan dp LEFT JOIN tasks t ON t.id=dp.task_id WHERE dp.date=? AND dp.state!='none'\", args: [date] });\n return c.json({ ok: true, date, written: n, picks: r.rows });\n });\n\n // forge from the page: \"desktop\" = the free path (journal + AWAITING mark, the forger picks it up),\n // \"cloud\" = the ⚡ brain now. Both send the same Telegram messages the keyboard would.\n app.post(\"/forge\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const b = await c.req.json().catch(() => ({}));\n const date = String(b.date ?? new Date().toISOString().slice(0, 10)).slice(0, 10);\n const own = await sqlite.execute(\"SELECT chat_id FROM chats ORDER BY first_seen LIMIT 1\");\n const chatId = own.rows[0]?.chat_id as number;\n if (!chatId) return c.json({ ok: false, error: \"no owner chat\" }, 400);\n if (b.mode === \"cloud\") await deps.forgePlanBrain(chatId, date); else await deps.forgePlan(chatId, date);\n const plan = await sqlite.execute({ sql: \"SELECT plan FROM day_plan_text WHERE date=?\", args: [date] });\n return c.json({ ok: true, date, mode: b.mode === \"cloud\" ? \"cloud\" : \"desktop\", plan: plan.rows[0]?.plan ?? null });\n });\n\n // ---- presence + the gate (quest #112) ----\n app.post(\"/presence\", async (c: any) => {\n await ready;\n const body = await c.req.json().catch(() => ({}));\n if (!(await busAuth(c, body))) return c.text(\"forbidden\", 401);\n const session = String(body.session ?? \"gatekeeper\").slice(0, 60);\n const minutes = Math.min(Math.max(Number(body.minutes ?? 5), 1), 120);\n if (body.off) { await sqlite.execute({ sql: \"DELETE FROM presence WHERE session=?\", args: [session] }); return c.json({ ok: true, session, off: true }); }\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO presence (session, until, note, ts) VALUES (?, datetime('now', ?), ?, datetime('now'))\",\n args: [session, `+${minutes} minutes`, String(body.note ?? \"\").slice(0, 120)] });\n const q = await sqlite.execute(\"SELECT COUNT(*) AS n FROM gate_queue WHERE status='queued'\");\n return c.json({ ok: true, session, minutes, waiting: Number((q.rows[0] as any)?.n ?? 0) });\n });\n app.get(\"/presence\", async (c: any) => { await ready; if (!auth(c)) return c.text(\"forbidden\", 401); return c.json({ ok: true, awake: await whoIsAwake(sqlite) }); });\n\n app.get(\"/gate/pull\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const who = String(c.req.query(\"session\") ?? \"gatekeeper\").slice(0, 60);\n const r = await sqlite.execute(\"SELECT * FROM gate_queue WHERE status='queued' OR (status='claimed' AND claimed_at < datetime('now','-10 minutes')) ORDER BY id LIMIT 10\");\n for (const row of r.rows as any[]) {\n await sqlite.execute({ sql: \"UPDATE gate_queue SET status='claimed', claimed_by=?, claimed_at=datetime('now') WHERE id=?\", args: [who, row.id] });\n }\n return c.json({ ok: true, messages: r.rows });\n });\n app.post(\"/gate/answer\", async (c: any) => {\n await ready;\n const body = await c.req.json().catch(() => ({}));\n if (!(await busAuth(c, body))) return c.text(\"forbidden\", 401);\n const row = await sqlite.execute({ sql: \"SELECT * FROM gate_queue WHERE id=?\", args: [Number(body.id)] });\n if (!row.rows.length) return c.json({ ok: false, error: `no message ${body.id}` }, 404);\n const chatId = Number((row.rows[0] as any).chat_id);\n const text = String(body.text ?? \"\").slice(0, 3900);\n if (!text.trim()) return c.json({ ok: false, error: \"text required\" }, 400);\n const res = await deps.send(chatId, text, \"gate\");\n if (res.ok) await sqlite.execute({ sql: \"UPDATE gate_queue SET status='answered', answered_at=datetime('now'), answer_chars=? WHERE id=?\", args: [text.length, Number(body.id)] });\n return c.json({ ok: res.ok, message_id: res.message_id, error: res.error }, res.ok ? 200 : 502);\n });\n app.post(\"/gate/release\", async (c: any) => {\n await ready;\n const body = await c.req.json().catch(() => ({}));\n if (!(await busAuth(c, body))) return c.text(\"forbidden\", 401);\n await sqlite.execute({ sql: \"UPDATE gate_queue SET status='queued', claimed_by=NULL, claimed_at=NULL WHERE id=? AND status='claimed'\", args: [Number(body.id)] });\n return c.json({ ok: true });\n });\n app.get(\"/gate/status\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT status, COUNT(*) AS n FROM gate_queue GROUP BY status\");\n const recent = await sqlite.execute(\"SELECT id, ts, status, claimed_by, answered_at, substr(text,1,80) AS text FROM gate_queue ORDER BY id DESC LIMIT 20\");\n return c.json({ ok: true, counts: r.rows, recent: recent.rows, awake: await whoIsAwake(sqlite) });\n });\n\n // --- the night watch's record, read back by the desktop (task #179) ----------\n // telegram/night-watch.ts captures the Wise business balance on an interval so a\n // sleeping PC does not put a hole in the money history. These two routes are how\n // update_dashboard_data.py collects what was captured while the machine was off.\n // Read-only: the val captures, the desktop reconciles. Nothing here interprets.\n app.get(\"/nightwatch/balances\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const since = String(c.req.query(\"since\") ?? \"\").slice(0, 10);\n const r = since\n ? await sqlite.execute({\n sql: \"SELECT day, business_eur, currency, source, ts FROM balance_history WHERE day >= ? ORDER BY day\",\n args: [since],\n })\n : await sqlite.execute(\"SELECT day, business_eur, currency, source, ts FROM balance_history ORDER BY day\");\n return c.json({ ok: true, days: r.rows });\n });\n\n // Force one pass of the watch. Same code path the interval runs, and idempotent,\n // so this can never disagree with the scheduled run about the same day.\n app.post(\"/nightwatch/run\", async (c: any) => {\n await ready;\n const body = await c.req.json().catch(() => ({}));\n if (!(await busAuth(c, body))) return c.text(\"forbidden\", 401);\n const { captureAll } = await import(\"./night-watch.ts\");\n return c.json({ ok: true, result: await captureAll() });\n });\n\n // The receipts. A gap here is the evidence that the watch itself was down —\n // which is the whole reason it writes a heartbeat even when there is nothing to do.\n app.get(\"/nightwatch/runs\", async (c: any) => {\n await ready;\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT ts, job, status, detail FROM nightwatch_runs ORDER BY ts DESC LIMIT 50\");\n return c.json({ ok: true, runs: r.rows });\n });\n\n // register the command menu with Telegram (the deploy script calls this once after each deploy)\n app.post(\"/bot/menu\", async (c: any) => {\n await ready;\n const body = await c.req.json().catch(() => ({}));\n if (!(await busAuth(c, body))) return c.text(\"forbidden\", 401);\n const r = await deps.tg(\"setMyCommands\", { commands: MENU });\n return c.json({ ok: !!r, commands: MENU.length });\n });\n\n return {\n ready,\n handleCommand: async (chatId: number, text: string): Promise => {\n await ready;\n // /coldpath takes arguments, which the match below rejects, so it is asked first (#220).\n if (await coldPathCommand(sqlite, chatId, text, deps.send)) return true;\n const m = String(text ?? \"\").trim().match(/^\\/(money|fleet|quests|today|road|news|shelf|deeds|journal|who|help|start)(?:@\\w+)?\\s*$/i);\n if (!m) return false;\n const out = await renderCommand(sqlite, m[1].toLowerCase());\n if (out == null) return false;\n await deps.send(chatId, out.slice(0, 3900), \"command\");\n return true;\n },\n gateRoute: async (chatId: number, text: string, isChatIntent: boolean) => { await ready; return gateRoute(sqlite, chatId, text, isChatIntent); },\n isAwake: async () => { await ready; return (await whoIsAwake(sqlite)).length > 0; },\n snapshotContext: async () => { await ready; return snapshotContext(sqlite); },\n applyBrainActions: async (j: any, chatId: number) => { await ready; return applyBrainActions(sqlite, j, chatId); },\n commandMenu: MENU,\n };\n}\nconst MENU = [\n { command: \"money\", description: \"The pot, Wise, this month, standing orders\" },\n { command: \"fleet\", description: \"Agents: who reported, who is silent, the bus\" },\n { command: \"tasks\", description: \"Open tasks by urgency, with #ids\" },\n { command: \"today\", description: \"Calendar + today's plan\" },\n { command: \"road\", description: \"The next 14 days\" },\n { command: \"news\", description: \"Today's news edition\" },\n { command: \"shelf\", description: \"Today's reading shelves\" },\n { command: \"deeds\", description: \"Closed this week\" },\n { command: \"journal\", description: \"The last 10 journal lines\" },\n { command: \"who\", description: \"Is a session awake?\" },\n { command: \"ask\", description: \"Wake the cloud brain ⚡ (credits)\" },\n { command: \"forge\", description: \"Forge today's plan in the cloud ⚡\" },\n { command: \"pro\", description: \"2 h of deeper counsel (Sonnet)\" },\n { command: \"eco\", description: \"Back to economy mode\" },\n { command: \"coldpath\", description: \"The cold path: what did not run, and the two switches\" },\n { command: \"help\", description: \"What the assistant can do\" },\n];\n","deleted",false,"label",[14],"8754a5f7-f359-4e36-abb1-c12689a1658c",["D",1783928553221],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Palantír Herald — Telegram capture + pings","imageUrl","userId","3ed96798-6351-4c0c-a152-1db6ab7640c9","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f5a68-d0b6-75de-80af-2b23ea5ed456","tursoName","8754a5f7f3594e36abb1c12689a1658c","tursoHostname","8754a5f7f3594e36abb1c12689a1658c-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",100,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Alexandr Stakhov","avatar","https://lh3.googleusercontent.com/a/ACg8ocKCA_6NlmBdn2fDI25kVPZAGM3tPMEmD7U1Na63L8rtZj8kBQ=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":62,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]