[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_210":211,"_212":213},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":125,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_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":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",25,"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","bot-webhook.ts","latestPath","fileId","6922aaa6-7e8e-11f1-a591-1607ee4eb77e","name","fileType","http","content","// Palantír Herald — Telegram bot webhook (Val Town HTTP val)\n// Routes: POST /webhook (Telegram), GET /pull + POST /ack (Claude sessions), POST /send (outbound pings)\nimport { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst BOT = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\nconst WEBHOOK_SECRET = Deno.env.get(\"WEBHOOK_SECRET\")!;\nconst PULL_SECRET = Deno.env.get(\"PULL_SECRET\")!;\nconst API = `https://api.telegram.org/bot${BOT}`;\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS inbox (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT DEFAULT (datetime('now')),\n chat_id INTEGER, kind TEXT, text TEXT, file_id TEXT, processed INTEGER DEFAULT 0)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL, note TEXT DEFAULT '', tier TEXT DEFAULT 'fellowship',\n area TEXT DEFAULT '', ord REAL DEFAULT 0, status TEXT DEFAULT 'open',\n comments TEXT DEFAULT '[]',\n created TEXT DEFAULT (datetime('now')), done_at TEXT)`);\n// AXIOMA team tasks live in the SAME table (one source of truth) but carry an owner.\n// The dashboard Quest Log shows only Alexandr's; the AXIOMA board shows the team's.\n// Without this separation, logging a task for Danny would pollute his personal day.\ntry { await sqlite.execute(\"ALTER TABLE tasks ADD COLUMN owner TEXT DEFAULT 'alexandr'\"); } catch (_) { /* already there */ }\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS group_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT DEFAULT (datetime('now')),\n chat_id INTEGER, chat_title TEXT, from_name TEXT, kind TEXT, text TEXT, file_id TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS agent_jobs (\n id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT DEFAULT (datetime('now')),\n agent TEXT, brief TEXT, packs TEXT, status TEXT DEFAULT 'queued',\n result TEXT, done_at TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS news_feedback (\n id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT DEFAULT (datetime('now')),\n item_key TEXT, title TEXT, source TEXT, topic TEXT, verdict TEXT, applied INTEGER DEFAULT 0)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS news_items (\n key TEXT PRIMARY KEY, title TEXT, source TEXT, topic TEXT, ts TEXT DEFAULT (datetime('now')))`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS journal (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT DEFAULT (datetime('now')),\n source TEXT, summary TEXT, details TEXT, filed INTEGER DEFAULT 0)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY, value TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS day_plan (\n date TEXT, task_id INTEGER, state TEXT DEFAULT 'none', PRIMARY KEY (date, task_id))`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS day_plan_text (\n date TEXT PRIMARY KEY, plan TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS chats (\n chat_id INTEGER PRIMARY KEY, username TEXT, first_seen TEXT DEFAULT (datetime('now')))`);\n\nasync function tg(method: string, params: any) {\n const r = await fetch(`${API}/${method}`, { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify(params) });\n if (!r.ok) console.error(method, r.status, await r.text());\n return r.ok ? (await r.json()).result : null;\n}\n\nasync function send(chatId: number, text: string) {\n const r = await fetch(`${API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"Markdown\" }),\n });\n if (!r.ok) console.error(\"sendMessage failed\", r.status, await r.text());\n}\n\n\n// ---------- the Brain (active only when ANTHROPIC_API_KEY is set) ----------\nconst BRAIN_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n\nasync function proActive(): Promise {\n const r = await sqlite.execute(\"SELECT value FROM settings WHERE key='pro_until'\");\n return !!r.rows[0] && new Date(r.rows[0].value as string) > new Date();\n}\nconst API_MARK = \"\\n\\n\\u26a1api\";\n\n// A plain text capture becomes a real quest IMMEDIATELY — no LLM, just an insert,\n// so it is free. Before 2026-07-25 this only wrote to the inbox and the quest was\n// created hours later by the Morning Herald, while the bot already claimed\n// \"Taken to the Quest Log\" — so Alexandr looked at the dashboard and found nothing.\n// The inbox row is still written (marked processed) as an audit trail; the Herald\n// enriches tier/area/note on its next run rather than creating a duplicate.\nasync function captureFallback(chatId: number, text: string) {\n const raw = text.trim();\n const title = raw\n .replace(/^(please\\s+)?(add|put|log|save)\\s+(this\\s+)?(to\\s+)?(the\\s+)?(tasks?|quests?|list)?\\s*(to\\s+)?/i, \"\")\n .replace(/^(todo|task|напомни|добавь(\\s+задачу)?|запиши)[:,\\s-]*/i, \"\")\n .trim() || raw;\n const clean = title.charAt(0).toUpperCase() + title.slice(1);\n await sqlite.execute({\n sql: \"INSERT INTO inbox (chat_id, kind, text, processed) VALUES (?,?,?,1)\",\n args: [chatId, \"text\", raw],\n });\n const mx = await sqlite.execute({\n sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier=?\", args: [\"fellowship\"],\n });\n await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord) VALUES (?,?,?,?,?)\",\n args: [clean.slice(0, 160), \"captured from Telegram \" + new Date().toISOString().slice(0, 10),\n \"fellowship\", \"\", mx.rows[0].o],\n });\n await send(chatId, \"⚔️ Added to the Quest Log:\\n\" + clean.slice(0, 90) +\n \"\\n\\nIt is on the dashboard now.\");\n}\n\nasync function brain(chatId: number, text: string) {\n const open = await sqlite.execute(\"SELECT id,title,tier,area,note FROM tasks WHERE status='open' ORDER BY tier,ord\");\n const grp = await sqlite.execute(\"SELECT ts,from_name,text FROM group_log WHERE kind='text' ORDER BY id DESC LIMIT 60\");\n const sys = `You are the Palantír Herald — Alexandr's personal assistant bot on Telegram. Concise, warm, light Lord-of-the-Rings flavor (never overdone). Answer in the user's language.\nFacts: Maraletto = family e-commerce business (Shopify; legal entity COTTONPASSION LDA; formerly named Artograph; run with father Sergey). AXIOMA = the work project and its team group chat, which you silently scribe.\nSelf-knowledge: you (this same bot) DO post to the AXIOMA group in exactly two cases — the Monday open-tasks report and the Friday clean-week toast (plus rare messages Alexandr explicitly requests). On 24 Jul a scheduling bug caused duplicated posts; it was fixed with once-per-day guards. If Alexandr reports bot misbehavior, acknowledge honestly and suggest he tell desktop Claude to investigate — never deny actions your other components may have taken.\nClassify the user's message and respond ONLY with JSON, no fences:\n- a task/thought to capture -> {\"action\":\"task\",\"title\":\"...\",\"tier\":\"balrog|nazgul|fellowship|shire\",\"area\":\"Maraletto|Finance|Family|Consulting|Other\",\"reply\":\"one-line confirmation\"}\n- anything else (question, status check, completing tasks, chat) -> {\"action\":\"answer\",\"reply\":\"markdown answer, <=200 words\",\"complete_task_ids\":[ids to mark done, optional]}\nTier guide: balrog=urgent/overdue, nazgul=has deadline, fellowship=this week, shire=someday.\nOPEN QUESTS: ${JSON.stringify(open.rows)}\nRECENT AXIOMA GROUP LOG (newest first): ${JSON.stringify(grp.rows)}`;\n const pro = await proActive();\n const model = pro ? (Deno.env.get(\"BRAIN_MODEL_PRO\") ?? \"claude-sonnet-4-5\") : (Deno.env.get(\"BRAIN_MODEL\") ?? \"claude-haiku-4-5\");\n const sysFinal = sys + (pro ? \"\" : \"\\nECONOMY MODE: keep answers brief (<=100 words) — API credits are precious. Depth only when truly needed.\");\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: { \"x-api-key\": BRAIN_KEY!, \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model, max_tokens: pro ? 2000 : 500,\n system: sysFinal, messages: [{ role: \"user\", content: text }] }),\n });\n if (!r.ok) { console.error(\"anthropic\", r.status, await r.text()); await captureFallback(chatId, text); return; }\n const out = ((await r.json()).content?.[0]?.text ?? \"\").replace(/^```json\\s*|^```\\s*|```\\s*$/g, \"\").trim();\n let j: any;\n try { j = JSON.parse(out); } catch { await send(chatId, out.slice(0, 3900) || \"🌫 The stone is clouded.\"); return; }\n if (j.action === \"task\" && j.title) {\n const mx = await sqlite.execute({ sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier=?\", args: [j.tier ?? \"fellowship\"] });\n await sqlite.execute({ sql: \"INSERT INTO tasks (title, note, tier, area, ord) VALUES (?,?,?,?,?)\",\n args: [j.title, \"via bot \" + new Date().toISOString().slice(0,10), j.tier ?? \"fellowship\", j.area ?? \"\", mx.rows[0].o] });\n await send(chatId, (j.reply || \"⚔️ Taken to the Quest Log.\") + API_MARK);\n } else {\n for (const id of j.complete_task_ids ?? []) {\n await sqlite.execute({ sql: \"UPDATE tasks SET status='done', done_at=datetime('now') WHERE id=?\", args: [Number(id)] });\n }\n await send(chatId, ((j.reply || \"…\") + API_MARK).slice(0, 3900));\n }\n}\n\n\n// ---------- interactive morning form ----------\nconst STATES = [\"none\", \"today\", \"done\"];\nconst ICON: Record = { none: \"⬜\", today: \"📅\", done: \"✅\" };\n\n// Normalised title used for duplicate detection. The Herald re-imported five\n// already-completed tasks on 2026-07-26 because nothing checked whether an\n// equivalent task existed. Titles drift slightly (\"Review Palantir dashboard\n// preview\" -> \"... v4\"), so compare on significant words, not exact strings.\nfunction titleKey(t: string): string {\n return String(t || \"\").toLowerCase()\n .replace(/[^a-z0-9\\u0400-\\u04ff ]+/g, \" \")\n .split(/\\s+/)\n .map((w) => w.replace(/s$/, \"\")) // crude stem: \"lists\" == \"list\", \"forms\" == \"form\"\n .filter((w) => w.length > 3 && ![\"from\",\"with\",\"that\",\"this\",\"your\",\"the\",\"and\",\"for\",\"new\",\"page\",\"fro\"].includes(w))\n .sort().slice(0, 6).join(\" \");\n}\nasync function findTwin(title: string): Promise {\n const key = titleKey(title);\n if (!key) return null;\n const r = await sqlite.execute(\n \"SELECT id,title,status,done_at FROM tasks WHERE done_at IS NULL OR done_at > datetime('now','-21 days')\");\n for (const row of r.rows as any[]) {\n const k2 = titleKey(row.title as string);\n if (!k2) continue;\n const a = new Set(key.split(\" \")), b = new Set(k2.split(\" \"));\n let hit = 0; a.forEach((w) => { if (b.has(w)) hit++; });\n const overlap = hit / Math.max(a.size, b.size);\n if (overlap >= 0.6) return row;\n }\n return null;\n}\n\nasync function buildKeyboard(date: string) {\n const tasks = await sqlite.execute(\"SELECT id,title 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 LIMIT 10\");\n const st = await sqlite.execute({ sql: \"SELECT task_id, state FROM day_plan WHERE date=?\", args: [date] });\n const map: Record = {};\n for (const r of st.rows) map[r.task_id as number] = r.state as string;\n // Anything he picked yesterday and did not finish is already marked 'today'\n // by the rollover, so it sorts to the top and arrives pre-selected. Before\n // this, unfinished picks simply vanished at midnight.\n const carried = new Set();\n const y = await sqlite.execute({\n sql: `SELECT dp.task_id FROM day_plan dp JOIN tasks t ON t.id = dp.task_id\n WHERE dp.date = date(?, '-1 day') AND dp.state = 'today' AND t.status = 'open'`,\n args: [date] });\n for (const r of y.rows as any[]) carried.add(r.task_id as number);\n const sorted = (tasks.rows as any[]).slice().sort(\n (a, b) => (carried.has(b.id) ? 1 : 0) - (carried.has(a.id) ? 1 : 0));\n const rows = sorted.map((tk: any) => [{\n text: `${ICON[map[tk.id] ?? \"none\"]}${carried.has(tk.id) ? \" ↻\" : \"\"} ${String(tk.title).slice(0, 40)}`,\n callback_data: `t:${tk.id}`,\n }]);\n rows.push([{ text: \"🏁 Forge the plan\", callback_data: \"forge\" }]);\n return { inline_keyboard: rows };\n}\n\nasync function forgePlanBrain(chatId: number, date: string) {\n const forceBrain = true;\n return forgePlanInner(chatId, date, forceBrain);\n}\n\nasync function forgePlan(chatId: number, date: string) {\n return forgePlanInner(chatId, date, false);\n}\n\nasync function forgePlanInner(chatId: number, date: string, forceBrain: boolean) {\n const st = await sqlite.execute({ sql: \"SELECT task_id, state FROM day_plan WHERE date=?\", args: [date] });\n const doneIds = st.rows.filter((r: any) => r.state === \"done\").map((r: any) => r.task_id);\n const todayIds = st.rows.filter((r: any) => r.state === \"today\").map((r: any) => r.task_id);\n for (const id of doneIds) {\n await sqlite.execute({ sql: \"UPDATE tasks SET status='done', done_at=datetime('now') WHERE id=?\", args: [id] });\n }\n if (!todayIds.length) { await send(chatId, doneIds.length ? \"✅ Marked done. No battles chosen for today — a quiet day, then.\" : \"No battles chosen. The stone rests.\"); return; }\n const q = await sqlite.execute({ sql: `SELECT id,title,tier,area,note FROM tasks WHERE id IN (${todayIds.map(() => \"?\").join(\",\")})`, args: todayIds });\n\n // FREE PATH (default): record the choice, tell desktop Claude to forge the plan and start working.\n if (!forceBrain && Deno.env.get(\"FORGE_MODE\") !== \"brain\") {\n const titles = q.rows.map((r: any) => \"• \" + r.title).join(\"\\n\");\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO day_plan_text (date, plan) VALUES (?,?)\",\n args: [date, \"AWAITING_DESKTOP_FORGE\\n\" + titles],\n });\n await sqlite.execute({\n sql: \"INSERT INTO journal (source, summary, details) VALUES (?,?,?)\",\n args: [\"morning form\", `Alexandr chose ${todayIds.length} quest(s) for ${date}`,\n \"CHOSEN:\\n\" + q.rows.map((r: any) => `#${r.id} ${r.title} [${r.tier}/${r.area}] ${r.note ?? \"\"}`).join(\"\\n\") +\n (doneIds.length ? `\\nMARKED DONE: ${doneIds.join(\", \")}` : \"\") +\n \"\\nACTION: forge the day plan (order, time slots, 🤝 what Claude takes vs 🗡 yours alone), send it via /send, and START the items Claude can take.\"],\n });\n await send(chatId, \"🗺 *Chosen for today:*\\n\" + titles +\n \"\\n\\nDesktop Claude will forge the plan and begin what it can take — free of API credits. (Need it forged right now in the cloud? send `/forge` ⚡)\");\n return;\n }\n if (!BRAIN_KEY) { await send(chatId, \"Plan chosen: \" + q.rows.map((r: any) => r.title).join(\" · \")); return; }\n const sys = `You are the Palantír Herald, planning Alexandr's day. Light LOTR flavor, concise. He runs Maraletto (family e-commerce, Shopify, with father Sergey) and works as an AI consultant.\nGiven his chosen tasks for today, produce a short battle plan (<=180 words):\n1) sensible order with rough time slots (morning/midday/evening),\n2) \"🤝 I can take:\" — parts Claude/the Herald can do autonomously or draft (research, analysis, documents, reconciliation, outreach drafts),\n3) \"🗡 Yours alone:\" — payments, calls, physical-world, decisions.\nEnd with one short encouraging line.`;\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\", headers: { \"x-api-key\": BRAIN_KEY!, \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model: Deno.env.get(\"BRAIN_MODEL\") ?? \"claude-haiku-4-5\", max_tokens: 700, system: sys,\n messages: [{ role: \"user\", content: \"Today's chosen tasks: \" + JSON.stringify(q.rows) }] }),\n });\n let plan = \"Plan for today: \" + q.rows.map((r: any) => r.title).join(\" · \");\n if (r.ok) plan = ((await r.json()).content?.[0]?.text ?? plan).trim();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO day_plan_text (date, plan) VALUES (?,?)\", args: [date, plan] });\n await send(chatId, \"🗺 *The day's battle plan*\\n\\n\" + plan.slice(0, 3700) + API_MARK);\n}\n\nasync function handleCallback(cb: any) {\n const date = new Date().toISOString().slice(0, 10);\n const chatId = cb.message?.chat?.id;\n try {\n if (String(cb.data).startsWith(\"n:\")) {\n const [, verdict, key] = String(cb.data).split(\":\");\n const it = await sqlite.execute({ sql: \"SELECT * FROM news_items WHERE key=?\", args: [key] });\n const row: any = it.rows[0] ?? {};\n await sqlite.execute({\n sql: \"INSERT INTO news_feedback (item_key,title,source,topic,verdict) VALUES (?,?,?,?,?)\",\n args: [key, row.title ?? \"\", row.source ?? \"\", row.topic ?? \"\", verdict] });\n const label: Record = { up:\"👍 more like this\", down:\"👎 less of this\", star:\"⭐ important\", block:\"🚫 never again\" };\n await tg(\"answerCallbackQuery\", { callback_query_id: cb.id, text: label[verdict] ?? \"noted\" });\n return;\n }\n if (cb.data === \"forge\") {\n await tg(\"answerCallbackQuery\", { callback_query_id: cb.id, text: \"Forging…\" });\n await forgePlan(chatId, date);\n return;\n }\n if (String(cb.data).startsWith(\"t:\")) {\n const id = Number(String(cb.data).slice(2));\n const cur = await sqlite.execute({ sql: \"SELECT state FROM day_plan WHERE date=? AND task_id=?\", args: [date, id] });\n const next = STATES[(STATES.indexOf((cur.rows[0]?.state as string) ?? \"none\") + 1) % STATES.length];\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO day_plan (date, task_id, state) VALUES (?,?,?)\", args: [date, id, next] });\n await tg(\"editMessageReplyMarkup\", { chat_id: chatId, message_id: cb.message.message_id, reply_markup: await buildKeyboard(date) });\n await tg(\"answerCallbackQuery\", { callback_query_id: cb.id });\n }\n } catch (e) { console.error(\"callback\", e); await tg(\"answerCallbackQuery\", { callback_query_id: cb.id, text: \"hiccup — try again\" }); }\n}\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\napp.post(\"/webhook\", async (c) => {\n if (c.req.header(\"X-Telegram-Bot-Api-Secret-Token\") !== WEBHOOK_SECRET) return c.text(\"forbidden\", 401);\n const u = await c.req.json();\n if (u.callback_query) { await handleCallback(u.callback_query); return c.text(\"ok\"); }\n const m = u.message;\n if (!m) return c.text(\"ok\");\n const chatId = m.chat.id;\n\n // ---- group chats: listen silently, never reply ----\n if (m.chat.type === \"group\" || m.chat.type === \"supergroup\") {\n const from = [m.from?.first_name, m.from?.last_name].filter(Boolean).join(\" \") || m.from?.username || \"?\";\n const kind = m.voice || m.audio ? \"voice\" : (m.text ? \"text\" : \"other\");\n const fid = (m.voice ?? m.audio)?.file_id ?? null;\n await sqlite.execute({\n sql: \"INSERT INTO group_log (chat_id, chat_title, from_name, kind, text, file_id) VALUES (?,?,?,?,?,?)\",\n args: [chatId, m.chat.title ?? \"\", from, kind, m.text ?? m.caption ?? \"\", fid],\n });\n await sqlite.execute(\"DELETE FROM group_log WHERE ts < datetime('now','-45 days')\");\n\n // Law 3 says never speak in AXIOMA UNASKED. An explicit @mention is being asked.\n // Approved by Alexandr 2026-07-31 (quest #33). Free: no LLM, plain parsing.\n const txt = (m.text ?? m.caption ?? \"\").trim();\n const MENTION = /@calude_assistant_bot|@claude_assistant_bot/i;\n const WANTS_TASK = /\\b(log|add|record|note|запиши|залогируй|добавь)\\b.{0,20}\\b(task|todo|задач)/i;\n if (MENTION.test(txt) && WANTS_TASK.test(txt)) {\n // The task text is either after the verb, or — the common case — the message\n // being replied to (\"Need to be filled by Danny\" ← \"@bot log this task for Danny\").\n const replied = (m.reply_to_message?.text ?? m.reply_to_message?.caption ?? \"\").trim();\n let body = txt.replace(MENTION, \"\")\n .replace(/\\b(please\\s+)?(log|add|record|note|запиши|залогируй|добавь)\\b\\s*(this\\s+)?(task|todo|задачу|задача)?\\s*/i, \"\")\n .trim();\n // \"for Danny\" / \"для Дэнни\" → owner, and strip it from the title\n let owner = \"unassigned\";\n const who = body.match(/\\b(?:for|для)\\s+([A-Za-z\\u0400-\\u04ff]+)/i);\n if (who) { owner = who[1].toLowerCase(); body = body.replace(who[0], \"\").trim(); }\n const ROSTER: Record = { danny: \"danny\", дэнни: \"danny\", дени: \"danny\",\n sergey: \"sergey\", sergio: \"sergey\", сергей: \"sergey\", серхио: \"sergey\",\n alex: \"alexandr\", alexandr: \"alexandr\", саша: \"alexandr\", алексадр: \"alexandr\" };\n owner = ROSTER[owner] ?? owner;\n const title = (body && body.length > 3) ? body : replied;\n if (!title) {\n await send(chatId, \"I can log it — reply to the message that describes the task, or write it after the mention.\");\n return c.text(\"ok\");\n }\n const twin = await findTwin(title);\n if (twin) {\n await send(chatId, `Already on the board: “${String(twin.title).slice(0, 70)}”.`);\n return c.text(\"ok\");\n }\n const mx = await sqlite.execute({ sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier='fellowship'\" });\n const r = await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord, owner) VALUES (?,?,?,?,?,?) RETURNING id\",\n args: [title.slice(0, 160), `AXIOMA group · asked by ${from} · ${new Date().toISOString().slice(0, 10)}`,\n \"fellowship\", \"axioma\", mx.rows[0].o, owner] });\n await send(chatId, `📋 Logged for *${owner === \"unassigned\" ? \"the team\" : owner}*: ${title.slice(0, 90)}\\n_#${r.rows[0].id} · it will appear in Monday's report._`);\n return c.text(\"ok\");\n }\n return c.text(\"ok\"); // otherwise: listen silently, never reply\n }\n\n // ---- private chats: only the owner (first registered) is served ----\n const own = await sqlite.execute(\"SELECT chat_id FROM chats ORDER BY first_seen LIMIT 1\");\n const ownerId = own.rows[0]?.chat_id;\n if (ownerId && chatId !== ownerId) return c.text(\"ok\"); // strangers: silent ignore\n await sqlite.execute({ sql: \"INSERT OR IGNORE INTO chats (chat_id, username) VALUES (?,?)\", args: [chatId, m.from?.username ?? \"\"] });\n\n if (m.text === \"/start\") {\n await send(chatId, \"🔮 *The Palantír hears you.*\\nSpeak a task, a thought, or a voice note — it shall be carried to the Quest Log and sorted by the scribes.\");\n return c.text(\"ok\");\n }\n if (m.voice || m.audio) {\n const f = m.voice ?? m.audio;\n await sqlite.execute({ sql: \"INSERT INTO inbox (chat_id, kind, text, file_id) VALUES (?,?,?,?)\", args: [chatId, \"voice\", m.caption ?? \"\", f.file_id] });\n await send(chatId, \"🎙 Heard. The scribes will transcribe it at the next watch.\");\n return c.text(\"ok\");\n }\n if (m.text === \"/pro\") {\n const until = new Date(Date.now() + 2 * 3600e3).toISOString();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO settings (key, value) VALUES ('pro_until', ?)\", args: [until] });\n await send(chatId, \"🔥 Pro mode for 2 hours — deeper counsel, higher cost. /eco to end early.\");\n return c.text(\"ok\");\n }\n if (m.text === \"/forge\") {\n const date = new Date().toISOString().slice(0, 10);\n await send(chatId, \"⚡ Forging in the cloud…\");\n const prev = Deno.env.get(\"FORGE_MODE\");\n await forgePlanBrain(chatId, date);\n return c.text(\"ok\");\n }\n if (m.text === \"/eco\") {\n await sqlite.execute(\"DELETE FROM settings WHERE key='pro_until'\");\n await send(chatId, \"🌿 Economy mode — brief and thrifty.\");\n return c.text(\"ok\");\n }\n if (m.text) {\n // API COST POLICY: brain only when clearly addressed — question mark, /ask, or \"bot ...\" prefix.\n // Everything else = free capture; the desktop Herald processes it on subscription.\n const txt = m.text.trim();\n // COST POLICY: the cloud brain costs API credits (no subscription exists outside the desktop app).\n // It wakes ONLY on an explicit /ask (or \"bot:\" prefix). Everything else is captured for FREE\n // and answered later by desktop Claude on the subscription.\n const explicit = /^\\/ask\\b/i.test(txt) || /^(bot|бот)[,:]/i.test(txt);\n if (BRAIN_KEY && explicit) {\n await brain(chatId, txt.replace(/^(\\/ask|bot|бот)[,:]?\\s*/i, \"\"));\n } else if (/\\?\\s*$/.test(txt)) {\n await sqlite.execute({ sql: \"INSERT INTO inbox (chat_id, kind, text) VALUES (?,?,?)\", args: [chatId, \"text\", txt] });\n await send(chatId, \"📜 Noted — desktop Claude will answer this for free at the next watch.\\nNeed it *now*? Resend with `/ask` in front (uses API credits ⚡).\");\n } else {\n await captureFallback(chatId, txt);\n }\n return c.text(\"ok\");\n }\n await send(chatId, \"The stone does not yet understand this kind of message — send text or a voice note.\");\n return c.text(\"ok\");\n});\n\n// Morning Herald: deliver brief + interactive task picker to the owner\napp.post(\"/morning-form\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { brief } = await c.req.json();\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\" });\n if (brief) await send(chatId, brief.slice(0, 3900));\n const date = new Date().toISOString().slice(0, 10);\n await tg(\"sendMessage\", { chat_id: chatId, text: \"🗡 Choose today's battles — tap to cycle: ⬜ skip · 📅 today · ✅ already done. Then forge the plan.\",\n reply_markup: await buildKeyboard(date) });\n return c.json({ ok: true });\n});\napp.get(\"/dayplan\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM day_plan_text ORDER BY date DESC LIMIT 1\");\n return c.json(r.rows[0] ?? {});\n});\n\n// Today's choices from the morning form — any session can read what Alexandr picked\napp.get(\"/dayselection\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const date = c.req.query(\"date\") ?? new Date().toISOString().slice(0, 10);\n const r = await sqlite.execute({\n sql: `SELECT dp.task_id, dp.state, t.title, t.tier, t.area, t.note\n FROM day_plan dp LEFT JOIN tasks t ON t.id = dp.task_id\n 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 return c.json({ date, picks: r.rows, plan: plan.rows[0]?.plan ?? null });\n});\n// Desktop session stores the forged plan (free) so it shows on the dashboard\napp.post(\"/dayplan\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { date, plan } = await c.req.json();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO day_plan_text (date, plan) VALUES (?,?)\",\n args: [date ?? new Date().toISOString().slice(0, 10), plan] });\n return c.json({ ok: true });\n});\n\n// AGENT BUS — HQ dispatches jobs, specialists claim and answer them\napp.post(\"/agent/job\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { agent, brief, packs } = await c.req.json();\n if (!agent || !brief) return c.json({ ok: false, error: \"agent and brief required\" });\n const r = await sqlite.execute({ sql: \"INSERT INTO agent_jobs (agent, brief, packs) VALUES (?,?,?) RETURNING id\",\n args: [agent, brief, JSON.stringify(packs ?? [])] });\n return c.json({ ok: true, id: r.rows[0].id });\n});\napp.get(\"/agent/jobs\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const agent = c.req.query(\"agent\");\n const r = agent\n ? await sqlite.execute({ sql: \"SELECT * FROM agent_jobs WHERE status='queued' AND agent=? ORDER BY id\", args: [agent] })\n : await sqlite.execute(\"SELECT * FROM agent_jobs WHERE status='queued' ORDER BY id\");\n return c.json(r.rows);\n});\napp.post(\"/agent/result\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { id, result, ok } = await c.req.json();\n await sqlite.execute({ sql: \"UPDATE agent_jobs SET status=?, result=?, done_at=datetime('now') WHERE id=?\",\n args: [ok === false ? \"failed\" : \"done\", result ?? \"\", Number(id)] });\n return c.json({ ok: true });\n});\napp.get(\"/agent/results\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM agent_jobs WHERE status IN ('done','failed') ORDER BY id DESC LIMIT 30\");\n return c.json(r.rows);\n});\n\n// NEWS FEEDBACK — the Scribe registers items, Alexandr taps verdicts, HQ/Scribe learn from them\napp.post(\"/news/register\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { items } = await c.req.json(); // [{key,title,source,topic}]\n for (const i of items ?? []) {\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO news_items (key,title,source,topic) VALUES (?,?,?,?)\",\n args: [i.key, i.title ?? \"\", i.source ?? \"\", i.topic ?? \"\"] });\n }\n return c.json({ ok: true, n: (items ?? []).length });\n});\napp.get(\"/news/feedback\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const all = c.req.query(\"all\") === \"1\";\n const r = await sqlite.execute(all\n ? \"SELECT * FROM news_feedback ORDER BY id DESC LIMIT 200\"\n : \"SELECT * FROM news_feedback WHERE applied = 0 ORDER BY id\");\n return c.json(r.rows);\n});\napp.post(\"/news/feedback/applied\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { ids } = await c.req.json();\n for (const id of ids ?? []) await sqlite.execute({ sql: \"UPDATE news_feedback SET applied=1 WHERE id=?\", args: [Number(id)] });\n return c.json({ ok: true });\n});\n// Send one digest item with feedback buttons (called by the Scribe)\napp.post(\"/news/send\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { text, key } = await c.req.json();\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\" });\n await tg(\"sendMessage\", { chat_id: chatId, text, parse_mode: \"Markdown\",\n disable_web_page_preview: true,\n reply_markup: key ? { inline_keyboard: [[\n { text: \"👍\", callback_data: `n:up:${key}` },\n { text: \"👎\", callback_data: `n:down:${key}` },\n { text: \"⭐\", callback_data: `n:star:${key}` },\n { text: \"🚫\", callback_data: `n:block:${key}` },\n ]] } : undefined });\n return c.json({ ok: true });\n});\n\n// SHARED JOURNAL — every session logs what it did here; the main HQ session files it into JOURNAL/\napp.post(\"/journal\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { source, summary, details } = await c.req.json();\n if (!summary) return c.json({ ok: false, error: \"summary required\" });\n await sqlite.execute({\n sql: \"INSERT INTO journal (source, summary, details) VALUES (?,?,?)\",\n args: [source ?? \"unknown session\", summary, details ?? \"\"],\n });\n return c.json({ ok: true });\n});\napp.get(\"/journal\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const all = c.req.query(\"all\") === \"1\";\n const r = await sqlite.execute(all\n ? \"SELECT * FROM journal ORDER BY id DESC LIMIT 100\"\n : \"SELECT * FROM journal WHERE filed = 0 ORDER BY id\");\n return c.json(r.rows);\n});\napp.post(\"/journal/filed\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { ids } = await c.req.json();\n for (const id of ids ?? []) {\n await sqlite.execute({ sql: \"UPDATE journal SET filed = 1 WHERE id = ?\", args: [Number(id)] });\n }\n return c.json({ ok: true });\n});\n\n// Claude sessions: read the work-group scribe log (owner's eyes only)\napp.get(\"/group\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const since = c.req.query(\"since\") ?? \"1970-01-01\";\n const limit = Math.min(Number(c.req.query(\"limit\") ?? 200), 500);\n const r = await sqlite.execute({\n sql: \"SELECT * FROM group_log WHERE ts >= ? ORDER BY id DESC LIMIT ?\",\n args: [since, limit],\n });\n return c.json(r.rows);\n});\n\n// Claude sessions: fetch unprocessed captures\napp.get(\"/pull\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM inbox WHERE processed = 0 ORDER BY id\");\n return c.json(r.rows);\n});\n// Claude sessions: mark processed\napp.post(\"/ack\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { ids } = await c.req.json();\n for (const id of ids ?? []) {\n await sqlite.execute({ sql: \"UPDATE inbox SET processed = 1 WHERE id = ?\", args: [id] });\n }\n return c.json({ ok: true });\n});\n// Outbound ping from Claude (desktop sessions, Herald, crons)\napp.post(\"/send\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { text, chat_id } = await c.req.json();\n let target = chat_id;\n if (!target) {\n const r = await sqlite.execute(\"SELECT chat_id FROM chats ORDER BY first_seen LIMIT 1\");\n target = r.rows[0]?.chat_id;\n }\n if (!target) return c.json({ ok: false, error: \"no chat registered — /start the bot first\" });\n await send(target as number, text);\n return c.json({ ok: true });\n});\n\n\n// ---------- Quest Log CRUD (dashboard + Claude sessions) ----------\nconst auth = (c: any) => c.req.query(\"secret\") === PULL_SECRET;\n\napp.get(\"/tasks\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n // Default = Alexandr's own quests only. The dashboard Quest Log calls this bare,\n // so team tasks can never crowd his personal day. ?owner=all|danny|sergey for the board.\n const who = c.req.query(\"owner\") ?? \"alexandr\";\n const sqlOwner = who === \"all\" ? \"\" : \" AND COALESCE(owner,'alexandr') = ?\";\n const r = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE status='open'\" + sqlOwner +\n \" ORDER BY CASE tier WHEN 'balrog' THEN 0 WHEN 'nazgul' THEN 1 WHEN 'fellowship' THEN 2 ELSE 3 END, ord, id\",\n args: who === \"all\" ? [] : [who] });\n return c.json(r.rows);\n});\napp.get(\"/tasks/all\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM tasks ORDER BY status, tier, ord LIMIT 300\");\n return c.json(r.rows);\n});\napp.post(\"/tasks\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const b = await c.req.json();\n if (!b.force) {\n const twin = await findTwin(b.title);\n if (twin) return c.json({ ok: false, duplicate: true, existing: twin,\n hint: \"An equivalent task already exists. Reopen or comment on it, or resend with force:true.\" }, 409);\n }\n const mx = await sqlite.execute({ sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier=?\", args: [b.tier ?? \"fellowship\"] });\n const r = await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord, owner) VALUES (?,?,?,?,?,?) RETURNING *\",\n args: [b.title, b.note ?? \"\", b.tier ?? \"fellowship\", b.area ?? \"\", b.ord ?? mx.rows[0].o,\n b.owner ?? \"alexandr\"],\n });\n return c.json(r.rows[0]);\n});\napp.post(\"/tasks/bulk\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const items = await c.req.json();\n let n = 0;\n const skipped: any[] = [];\n for (const b of items) {\n if (!b.force) {\n const twin = await findTwin(b.title);\n if (twin) { skipped.push({ title: b.title, existing: twin }); continue; }\n }\n await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord) VALUES (?,?,?,?,?)\",\n args: [b.title, b.note ?? \"\", b.tier ?? \"fellowship\", b.area ?? \"\", (n + 1) * 10],\n });\n n++;\n }\n return c.json({ ok: true, inserted: n, skippedAsDuplicate: skipped });\n});\napp.patch(\"/tasks/:id\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json();\n const allowed = [\"title\", \"note\", \"tier\", \"area\", \"ord\", \"status\", \"owner\"];\n for (const k of allowed) {\n if (k in b) {\n await sqlite.execute({ sql: `UPDATE tasks SET ${k}=? WHERE id=?`, args: [b[k], id] });\n }\n }\n if (b.status === \"done\") {\n await sqlite.execute({ sql: \"UPDATE tasks SET done_at=datetime('now') WHERE id=?\", args: [id] });\n }\n const r = await sqlite.execute({ sql: \"SELECT * FROM tasks WHERE id=?\", args: [id] });\n return c.json(r.rows[0] ?? { ok: false });\n});\napp.post(\"/tasks/:id/comment\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const id = Number(c.req.param(\"id\"));\n const { text } = await c.req.json();\n const r = await sqlite.execute({ sql: \"SELECT comments FROM tasks WHERE id=?\", args: [id] });\n const comments = JSON.parse((r.rows[0]?.comments as string) ?? \"[]\");\n comments.push({ text, ts: new Date().toISOString().slice(0, 16).replace(\"T\", \" \") });\n await sqlite.execute({ sql: \"UPDATE tasks SET comments=? WHERE id=?\", args: [JSON.stringify(comments), id] });\n return c.json({ ok: true, count: comments.length });\n});\n\n// Warden triggers — called by the desktop scheduler (or manually); in-code window guards still apply\napp.get(\"/warden/:mode\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const mode = c.req.param(\"mode\");\n if (mode !== \"monday\" && mode !== \"friday\") return c.text(\"unknown mode\", 400);\n const { runWarden } = await import(\"./warden-shared.ts\");\n await runWarden(mode as \"monday\" | \"friday\");\n return c.json({ ok: true, note: \"ran with window guards — check logs for skip/post\" });\n});\n\n// Roll yesterday's unfinished picks into today. Without this, choosing eight\n// battles and finishing three left the other five stranded — off the plan, off\n// the dashboard, remembered only by Alexandr.\napp.post(\"/day/rollover\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const date = (await c.req.json().catch(() => ({}))).date ?? new Date().toISOString().slice(0, 10);\n const y = await sqlite.execute({\n sql: `SELECT dp.task_id, t.title FROM day_plan dp JOIN tasks t ON t.id = dp.task_id\n WHERE dp.date = date(?, '-1 day') AND dp.state = 'today' AND t.status = 'open'`,\n args: [date] });\n const carried: string[] = [];\n for (const r of y.rows as any[]) {\n const has = await sqlite.execute({\n sql: \"SELECT 1 FROM day_plan WHERE date=? AND task_id=?\", args: [date, r.task_id] });\n if (has.rows.length) continue;\n await sqlite.execute({\n sql: \"INSERT INTO day_plan (date, task_id, state) VALUES (?,?,'today')\",\n args: [date, r.task_id] });\n carried.push(r.title as string);\n }\n return c.json({ ok: true, date, carried: carried.length, titles: carried });\n});\n\napp.get(\"/\", (c) => c.text(\"🔮 Palantír Herald stands watch.\"));\nexport default app.fetch;\n","// Palantír Herald — Telegram bot webhook (Val Town HTTP val)\n// Routes: POST /webhook (Telegram), GET /pull + POST /ack (Claude sessions), POST /send (outbound pings)\nimport { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst BOT = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\nconst WEBHOOK_SECRET = Deno.env.get(\"WEBHOOK_SECRET\")!;\nconst PULL_SECRET = Deno.env.get(\"PULL_SECRET\")!;\nconst API = `https://api.telegram.org/bot${BOT}`;\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS inbox (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT DEFAULT (datetime('now')),\n chat_id INTEGER, kind TEXT, text TEXT, file_id TEXT, processed INTEGER DEFAULT 0)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS tasks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL, note TEXT DEFAULT '', tier TEXT DEFAULT 'fellowship',\n area TEXT DEFAULT '', ord REAL DEFAULT 0, status TEXT DEFAULT 'open',\n comments TEXT DEFAULT '[]',\n created TEXT DEFAULT (datetime('now')), done_at TEXT)`);\n// AXIOMA team tasks live in the SAME table (one source of truth) but carry an owner.\n// The dashboard Quest Log shows only Alexandr's; the AXIOMA board shows the team's.\n// Without this separation, logging a task for Danny would pollute his personal day.\ntry { await sqlite.execute(\"ALTER TABLE tasks ADD COLUMN owner TEXT DEFAULT 'alexandr'\"); } catch (_) { /* already there */ }\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS group_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT DEFAULT (datetime('now')),\n chat_id INTEGER, chat_title TEXT, from_name TEXT, kind TEXT, text TEXT, file_id TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS agent_jobs (\n id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT DEFAULT (datetime('now')),\n agent TEXT, brief TEXT, packs TEXT, status TEXT DEFAULT 'queued',\n result TEXT, done_at TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS news_feedback (\n id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT DEFAULT (datetime('now')),\n item_key TEXT, title TEXT, source TEXT, topic TEXT, verdict TEXT, applied INTEGER DEFAULT 0)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS news_items (\n key TEXT PRIMARY KEY, title TEXT, source TEXT, topic TEXT, ts TEXT DEFAULT (datetime('now')))`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS journal (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT DEFAULT (datetime('now')),\n source TEXT, summary TEXT, details TEXT, filed INTEGER DEFAULT 0)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS settings (\n key TEXT PRIMARY KEY, value TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS day_plan (\n date TEXT, task_id INTEGER, state TEXT DEFAULT 'none', PRIMARY KEY (date, task_id))`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS day_plan_text (\n date TEXT PRIMARY KEY, plan TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS chats (\n chat_id INTEGER PRIMARY KEY, username TEXT, first_seen TEXT DEFAULT (datetime('now')))`);\n\nasync function tg(method: string, params: any) {\n const r = await fetch(`${API}/${method}`, { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify(params) });\n if (!r.ok) console.error(method, r.status, await r.text());\n return r.ok ? (await r.json()).result : null;\n}\n\nasync function send(chatId: number, text: string) {\n const r = await fetch(`${API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"Markdown\" }),\n });\n if (!r.ok) console.error(\"sendMessage failed\", r.status, await r.text());\n}\n\n\n// ---------- the Brain (active only when ANTHROPIC_API_KEY is set) ----------\nconst BRAIN_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n\nasync function proActive(): Promise {\n const r = await sqlite.execute(\"SELECT value FROM settings WHERE key='pro_until'\");\n return !!r.rows[0] && new Date(r.rows[0].value as string) > new Date();\n}\nconst API_MARK = \"\\n\\n\\u26a1api\";\n\n// A plain text capture becomes a real quest IMMEDIATELY — no LLM, just an insert,\n// so it is free. Before 2026-07-25 this only wrote to the inbox and the quest was\n// created hours later by the Morning Herald, while the bot already claimed\n// \"Taken to the Quest Log\" — so Alexandr looked at the dashboard and found nothing.\n// The inbox row is still written (marked processed) as an audit trail; the Herald\n// enriches tier/area/note on its next run rather than creating a duplicate.\nasync function captureFallback(chatId: number, text: string) {\n const raw = text.trim();\n const title = raw\n .replace(/^(please\\s+)?(add|put|log|save)\\s+(this\\s+)?(to\\s+)?(the\\s+)?(tasks?|quests?|list)?\\s*(to\\s+)?/i, \"\")\n .replace(/^(todo|task|напомни|добавь(\\s+задачу)?|запиши)[:,\\s-]*/i, \"\")\n .trim() || raw;\n const clean = title.charAt(0).toUpperCase() + title.slice(1);\n await sqlite.execute({\n sql: \"INSERT INTO inbox (chat_id, kind, text, processed) VALUES (?,?,?,1)\",\n args: [chatId, \"text\", raw],\n });\n const mx = await sqlite.execute({\n sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier=?\", args: [\"fellowship\"],\n });\n await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord) VALUES (?,?,?,?,?)\",\n args: [clean.slice(0, 160), \"captured from Telegram \" + new Date().toISOString().slice(0, 10),\n \"fellowship\", \"\", mx.rows[0].o],\n });\n await send(chatId, \"⚔️ Added to the Quest Log:\\n\" + clean.slice(0, 90) +\n \"\\n\\nIt is on the dashboard now.\");\n}\n\nasync function brain(chatId: number, text: string) {\n const open = await sqlite.execute(\"SELECT id,title,tier,area,note FROM tasks WHERE status='open' ORDER BY tier,ord\");\n const grp = await sqlite.execute(\"SELECT ts,from_name,text FROM group_log WHERE kind='text' ORDER BY id DESC LIMIT 60\");\n const sys = `You are the Palantír Herald — Alexandr's personal assistant bot on Telegram. Concise, warm, light Lord-of-the-Rings flavor (never overdone). Answer in the user's language.\nFacts: Maraletto = family e-commerce business (Shopify; legal entity COTTONPASSION LDA; formerly named Artograph; run with father Sergey). AXIOMA = the work project and its team group chat, which you silently scribe.\nSelf-knowledge: you (this same bot) DO post to the AXIOMA group in exactly two cases — the Monday open-tasks report and the Friday clean-week toast (plus rare messages Alexandr explicitly requests). On 24 Jul a scheduling bug caused duplicated posts; it was fixed with once-per-day guards. If Alexandr reports bot misbehavior, acknowledge honestly and suggest he tell desktop Claude to investigate — never deny actions your other components may have taken.\nClassify the user's message and respond ONLY with JSON, no fences:\n- a task/thought to capture -> {\"action\":\"task\",\"title\":\"...\",\"tier\":\"balrog|nazgul|fellowship|shire\",\"area\":\"Maraletto|Finance|Family|Consulting|Other\",\"reply\":\"one-line confirmation\"}\n- anything else (question, status check, completing tasks, chat) -> {\"action\":\"answer\",\"reply\":\"markdown answer, <=200 words\",\"complete_task_ids\":[ids to mark done, optional]}\nTier guide: balrog=urgent/overdue, nazgul=has deadline, fellowship=this week, shire=someday.\nOPEN QUESTS: ${JSON.stringify(open.rows)}\nRECENT AXIOMA GROUP LOG (newest first): ${JSON.stringify(grp.rows)}`;\n const pro = await proActive();\n const model = pro ? (Deno.env.get(\"BRAIN_MODEL_PRO\") ?? \"claude-sonnet-4-5\") : (Deno.env.get(\"BRAIN_MODEL\") ?? \"claude-haiku-4-5\");\n const sysFinal = sys + (pro ? \"\" : \"\\nECONOMY MODE: keep answers brief (<=100 words) — API credits are precious. Depth only when truly needed.\");\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: { \"x-api-key\": BRAIN_KEY!, \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model, max_tokens: pro ? 2000 : 500,\n system: sysFinal, messages: [{ role: \"user\", content: text }] }),\n });\n if (!r.ok) { console.error(\"anthropic\", r.status, await r.text()); await captureFallback(chatId, text); return; }\n const out = ((await r.json()).content?.[0]?.text ?? \"\").replace(/^```json\\s*|^```\\s*|```\\s*$/g, \"\").trim();\n let j: any;\n try { j = JSON.parse(out); } catch { await send(chatId, out.slice(0, 3900) || \"🌫 The stone is clouded.\"); return; }\n if (j.action === \"task\" && j.title) {\n const mx = await sqlite.execute({ sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier=?\", args: [j.tier ?? \"fellowship\"] });\n await sqlite.execute({ sql: \"INSERT INTO tasks (title, note, tier, area, ord) VALUES (?,?,?,?,?)\",\n args: [j.title, \"via bot \" + new Date().toISOString().slice(0,10), j.tier ?? \"fellowship\", j.area ?? \"\", mx.rows[0].o] });\n await send(chatId, (j.reply || \"⚔️ Taken to the Quest Log.\") + API_MARK);\n } else {\n for (const id of j.complete_task_ids ?? []) {\n await sqlite.execute({ sql: \"UPDATE tasks SET status='done', done_at=datetime('now') WHERE id=?\", args: [Number(id)] });\n }\n await send(chatId, ((j.reply || \"…\") + API_MARK).slice(0, 3900));\n }\n}\n\n\n// ---------- interactive morning form ----------\nconst STATES = [\"none\", \"today\", \"done\"];\nconst ICON: Record = { none: \"⬜\", today: \"📅\", done: \"✅\" };\n\n// Normalised title used for duplicate detection. The Herald re-imported five\n// already-completed tasks on 2026-07-26 because nothing checked whether an\n// equivalent task existed. Titles drift slightly (\"Review Palantir dashboard\n// preview\" -> \"... v4\"), so compare on significant words, not exact strings.\nfunction titleKey(t: string): string {\n return String(t || \"\").toLowerCase()\n .replace(/[^a-z0-9\\u0400-\\u04ff ]+/g, \" \")\n .split(/\\s+/)\n .map((w) => w.replace(/s$/, \"\")) // crude stem: \"lists\" == \"list\", \"forms\" == \"form\"\n .filter((w) => w.length > 3 && ![\"from\",\"with\",\"that\",\"this\",\"your\",\"the\",\"and\",\"for\",\"new\",\"page\",\"fro\"].includes(w))\n .sort().slice(0, 6).join(\" \");\n}\nasync function findTwin(title: string): Promise {\n const key = titleKey(title);\n if (!key) return null;\n const r = await sqlite.execute(\n \"SELECT id,title,status,done_at FROM tasks WHERE done_at IS NULL OR done_at > datetime('now','-21 days')\");\n for (const row of r.rows as any[]) {\n const k2 = titleKey(row.title as string);\n if (!k2) continue;\n const a = new Set(key.split(\" \")), b = new Set(k2.split(\" \"));\n let hit = 0; a.forEach((w) => { if (b.has(w)) hit++; });\n const overlap = hit / Math.max(a.size, b.size);\n if (overlap >= 0.6) return row;\n }\n return null;\n}\n\nasync function buildKeyboard(date: string) {\n const tasks = await sqlite.execute(\"SELECT id,title 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 LIMIT 10\");\n const st = await sqlite.execute({ sql: \"SELECT task_id, state FROM day_plan WHERE date=?\", args: [date] });\n const map: Record = {};\n for (const r of st.rows) map[r.task_id as number] = r.state as string;\n // Anything he picked yesterday and did not finish is already marked 'today'\n // by the rollover, so it sorts to the top and arrives pre-selected. Before\n // this, unfinished picks simply vanished at midnight.\n const carried = new Set();\n const y = await sqlite.execute({\n sql: `SELECT dp.task_id FROM day_plan dp JOIN tasks t ON t.id = dp.task_id\n WHERE dp.date = date(?, '-1 day') AND dp.state = 'today' AND t.status = 'open'`,\n args: [date] });\n for (const r of y.rows as any[]) carried.add(r.task_id as number);\n const sorted = (tasks.rows as any[]).slice().sort(\n (a, b) => (carried.has(b.id) ? 1 : 0) - (carried.has(a.id) ? 1 : 0));\n const rows = sorted.map((tk: any) => [{\n text: `${ICON[map[tk.id] ?? \"none\"]}${carried.has(tk.id) ? \" ↻\" : \"\"} ${String(tk.title).slice(0, 40)}`,\n callback_data: `t:${tk.id}`,\n }]);\n rows.push([{ text: \"🏁 Forge the plan\", callback_data: \"forge\" }]);\n return { inline_keyboard: rows };\n}\n\nasync function forgePlanBrain(chatId: number, date: string) {\n const forceBrain = true;\n return forgePlanInner(chatId, date, forceBrain);\n}\n\nasync function forgePlan(chatId: number, date: string) {\n return forgePlanInner(chatId, date, false);\n}\n\nasync function forgePlanInner(chatId: number, date: string, forceBrain: boolean) {\n const st = await sqlite.execute({ sql: \"SELECT task_id, state FROM day_plan WHERE date=?\", args: [date] });\n const doneIds = st.rows.filter((r: any) => r.state === \"done\").map((r: any) => r.task_id);\n const todayIds = st.rows.filter((r: any) => r.state === \"today\").map((r: any) => r.task_id);\n for (const id of doneIds) {\n await sqlite.execute({ sql: \"UPDATE tasks SET status='done', done_at=datetime('now') WHERE id=?\", args: [id] });\n }\n if (!todayIds.length) { await send(chatId, doneIds.length ? \"✅ Marked done. No battles chosen for today — a quiet day, then.\" : \"No battles chosen. The stone rests.\"); return; }\n const q = await sqlite.execute({ sql: `SELECT id,title,tier,area,note FROM tasks WHERE id IN (${todayIds.map(() => \"?\").join(\",\")})`, args: todayIds });\n\n // FREE PATH (default): record the choice, tell desktop Claude to forge the plan and start working.\n if (!forceBrain && Deno.env.get(\"FORGE_MODE\") !== \"brain\") {\n const titles = q.rows.map((r: any) => \"• \" + r.title).join(\"\\n\");\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO day_plan_text (date, plan) VALUES (?,?)\",\n args: [date, \"AWAITING_DESKTOP_FORGE\\n\" + titles],\n });\n await sqlite.execute({\n sql: \"INSERT INTO journal (source, summary, details) VALUES (?,?,?)\",\n args: [\"morning form\", `Alexandr chose ${todayIds.length} quest(s) for ${date}`,\n \"CHOSEN:\\n\" + q.rows.map((r: any) => `#${r.id} ${r.title} [${r.tier}/${r.area}] ${r.note ?? \"\"}`).join(\"\\n\") +\n (doneIds.length ? `\\nMARKED DONE: ${doneIds.join(\", \")}` : \"\") +\n \"\\nACTION: forge the day plan (order, time slots, 🤝 what Claude takes vs 🗡 yours alone), send it via /send, and START the items Claude can take.\"],\n });\n await send(chatId, \"🗺 *Chosen for today:*\\n\" + titles +\n \"\\n\\nDesktop Claude will forge the plan and begin what it can take — free of API credits. (Need it forged right now in the cloud? send `/forge` ⚡)\");\n return;\n }\n if (!BRAIN_KEY) { await send(chatId, \"Plan chosen: \" + q.rows.map((r: any) => r.title).join(\" · \")); return; }\n const sys = `You are the Palantír Herald, planning Alexandr's day. Light LOTR flavor, concise. He runs Maraletto (family e-commerce, Shopify, with father Sergey) and works as an AI consultant.\nGiven his chosen tasks for today, produce a short battle plan (<=180 words):\n1) sensible order with rough time slots (morning/midday/evening),\n2) \"🤝 I can take:\" — parts Claude/the Herald can do autonomously or draft (research, analysis, documents, reconciliation, outreach drafts),\n3) \"🗡 Yours alone:\" — payments, calls, physical-world, decisions.\nEnd with one short encouraging line.`;\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\", headers: { \"x-api-key\": BRAIN_KEY!, \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model: Deno.env.get(\"BRAIN_MODEL\") ?? \"claude-haiku-4-5\", max_tokens: 700, system: sys,\n messages: [{ role: \"user\", content: \"Today's chosen tasks: \" + JSON.stringify(q.rows) }] }),\n });\n let plan = \"Plan for today: \" + q.rows.map((r: any) => r.title).join(\" · \");\n if (r.ok) plan = ((await r.json()).content?.[0]?.text ?? plan).trim();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO day_plan_text (date, plan) VALUES (?,?)\", args: [date, plan] });\n await send(chatId, \"🗺 *The day's battle plan*\\n\\n\" + plan.slice(0, 3700) + API_MARK);\n}\n\nasync function handleCallback(cb: any) {\n const date = new Date().toISOString().slice(0, 10);\n const chatId = cb.message?.chat?.id;\n try {\n if (String(cb.data).startsWith(\"n:\")) {\n const [, verdict, key] = String(cb.data).split(\":\");\n const it = await sqlite.execute({ sql: \"SELECT * FROM news_items WHERE key=?\", args: [key] });\n const row: any = it.rows[0] ?? {};\n await sqlite.execute({\n sql: \"INSERT INTO news_feedback (item_key,title,source,topic,verdict) VALUES (?,?,?,?,?)\",\n args: [key, row.title ?? \"\", row.source ?? \"\", row.topic ?? \"\", verdict] });\n const label: Record = { up:\"👍 more like this\", down:\"👎 less of this\", star:\"⭐ important\", block:\"🚫 never again\" };\n await tg(\"answerCallbackQuery\", { callback_query_id: cb.id, text: label[verdict] ?? \"noted\" });\n return;\n }\n if (cb.data === \"forge\") {\n await tg(\"answerCallbackQuery\", { callback_query_id: cb.id, text: \"Forging…\" });\n await forgePlan(chatId, date);\n return;\n }\n if (String(cb.data).startsWith(\"t:\")) {\n const id = Number(String(cb.data).slice(2));\n const cur = await sqlite.execute({ sql: \"SELECT state FROM day_plan WHERE date=? AND task_id=?\", args: [date, id] });\n const next = STATES[(STATES.indexOf((cur.rows[0]?.state as string) ?? \"none\") + 1) % STATES.length];\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO day_plan (date, task_id, state) VALUES (?,?,?)\", args: [date, id, next] });\n await tg(\"editMessageReplyMarkup\", { chat_id: chatId, message_id: cb.message.message_id, reply_markup: await buildKeyboard(date) });\n await tg(\"answerCallbackQuery\", { callback_query_id: cb.id });\n }\n } catch (e) { console.error(\"callback\", e); await tg(\"answerCallbackQuery\", { callback_query_id: cb.id, text: \"hiccup — try again\" }); }\n}\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\napp.post(\"/webhook\", async (c) => {\n if (c.req.header(\"X-Telegram-Bot-Api-Secret-Token\") !== WEBHOOK_SECRET) return c.text(\"forbidden\", 401);\n const u = await c.req.json();\n if (u.callback_query) { await handleCallback(u.callback_query); return c.text(\"ok\"); }\n const m = u.message;\n if (!m) return c.text(\"ok\");\n const chatId = m.chat.id;\n\n // ---- group chats: listen silently, never reply ----\n if (m.chat.type === \"group\" || m.chat.type === \"supergroup\") {\n const from = [m.from?.first_name, m.from?.last_name].filter(Boolean).join(\" \") || m.from?.username || \"?\";\n const kind = m.voice || m.audio ? \"voice\" : (m.text ? \"text\" : \"other\");\n const fid = (m.voice ?? m.audio)?.file_id ?? null;\n await sqlite.execute({\n sql: \"INSERT INTO group_log (chat_id, chat_title, from_name, kind, text, file_id) VALUES (?,?,?,?,?,?)\",\n args: [chatId, m.chat.title ?? \"\", from, kind, m.text ?? m.caption ?? \"\", fid],\n });\n await sqlite.execute(\"DELETE FROM group_log WHERE ts < datetime('now','-45 days')\");\n\n // Law 3 says never speak in AXIOMA UNASKED. An explicit @mention is being asked.\n // Approved by Alexandr 2026-07-31 (quest #33). Free: no LLM, plain parsing.\n const txt = (m.text ?? m.caption ?? \"\").trim();\n const MENTION = /@calude_assistant_bot|@claude_assistant_bot/i;\n const WANTS_TASK = /\\b(log|add|record|note|запиши|залогируй|добавь)\\b.{0,20}\\b(task|todo|задач)/i;\n if (MENTION.test(txt) && WANTS_TASK.test(txt)) {\n // The task text is either after the verb, or — the common case — the message\n // being replied to (\"Need to be filled by Danny\" ← \"@bot log this task for Danny\").\n const replied = (m.reply_to_message?.text ?? m.reply_to_message?.caption ?? \"\").trim();\n let body = txt.replace(MENTION, \"\")\n .replace(/\\b(please\\s+)?(log|add|record|note|запиши|залогируй|добавь)\\b\\s*(this\\s+)?(task|todo|задачу|задача)?\\s*/i, \"\")\n .trim();\n // \"for Danny\" / \"для Дэнни\" → owner, and strip it from the title\n let owner = \"unassigned\";\n const who = body.match(/\\b(?:for|для)\\s+([A-Za-z\\u0400-\\u04ff]+)/i);\n if (who) { owner = who[1].toLowerCase(); body = body.replace(who[0], \"\").trim(); }\n const ROSTER: Record = { danny: \"danny\", дэнни: \"danny\", дени: \"danny\",\n sergey: \"sergey\", sergio: \"sergey\", сергей: \"sergey\", серхио: \"sergey\",\n alex: \"alexandr\", alexandr: \"alexandr\", саша: \"alexandr\", алексадр: \"alexandr\" };\n owner = ROSTER[owner] ?? owner;\n const title = (body && body.length > 3) ? body : replied;\n if (!title) {\n await send(chatId, \"I can log it — reply to the message that describes the task, or write it after the mention.\");\n return c.text(\"ok\");\n }\n const twin = await findTwin(title);\n if (twin) {\n await send(chatId, `Already on the board: “${String(twin.title).slice(0, 70)}”.`);\n return c.text(\"ok\");\n }\n const mx = await sqlite.execute({ sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier='fellowship'\" });\n const r = await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord, owner) VALUES (?,?,?,?,?,?) RETURNING id\",\n args: [title.slice(0, 160), `AXIOMA group · asked by ${from} · ${new Date().toISOString().slice(0, 10)}`,\n \"fellowship\", \"axioma\", mx.rows[0].o, owner] });\n await send(chatId, `📋 Logged for *${owner === \"unassigned\" ? \"the team\" : owner}*: ${title.slice(0, 90)}\\n_#${r.rows[0].id} · it will appear in Monday's report._`);\n return c.text(\"ok\");\n }\n return c.text(\"ok\"); // otherwise: listen silently, never reply\n }\n\n // ---- private chats: only the owner (first registered) is served ----\n const own = await sqlite.execute(\"SELECT chat_id FROM chats ORDER BY first_seen LIMIT 1\");\n const ownerId = own.rows[0]?.chat_id;\n if (ownerId && chatId !== ownerId) return c.text(\"ok\"); // strangers: silent ignore\n await sqlite.execute({ sql: \"INSERT OR IGNORE INTO chats (chat_id, username) VALUES (?,?)\", args: [chatId, m.from?.username ?? \"\"] });\n\n if (m.text === \"/start\") {\n await send(chatId, \"🔮 *The Palantír hears you.*\\nSpeak a task, a thought, or a voice note — it shall be carried to the Quest Log and sorted by the scribes.\");\n return c.text(\"ok\");\n }\n if (m.voice || m.audio) {\n const f = m.voice ?? m.audio;\n await sqlite.execute({ sql: \"INSERT INTO inbox (chat_id, kind, text, file_id) VALUES (?,?,?,?)\", args: [chatId, \"voice\", m.caption ?? \"\", f.file_id] });\n await send(chatId, \"🎙 Heard. The scribes will transcribe it at the next watch.\");\n return c.text(\"ok\");\n }\n if (m.text === \"/pro\") {\n const until = new Date(Date.now() + 2 * 3600e3).toISOString();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO settings (key, value) VALUES ('pro_until', ?)\", args: [until] });\n await send(chatId, \"🔥 Pro mode for 2 hours — deeper counsel, higher cost. /eco to end early.\");\n return c.text(\"ok\");\n }\n if (m.text === \"/forge\") {\n const date = new Date().toISOString().slice(0, 10);\n await send(chatId, \"⚡ Forging in the cloud…\");\n const prev = Deno.env.get(\"FORGE_MODE\");\n await forgePlanBrain(chatId, date);\n return c.text(\"ok\");\n }\n if (m.text === \"/eco\") {\n await sqlite.execute(\"DELETE FROM settings WHERE key='pro_until'\");\n await send(chatId, \"🌿 Economy mode — brief and thrifty.\");\n return c.text(\"ok\");\n }\n if (m.text) {\n // API COST POLICY: brain only when clearly addressed — question mark, /ask, or \"bot ...\" prefix.\n // Everything else = free capture; the desktop Herald processes it on subscription.\n const txt = m.text.trim();\n // COST POLICY: the cloud brain costs API credits (no subscription exists outside the desktop app).\n // It wakes ONLY on an explicit /ask (or \"bot:\" prefix). Everything else is captured for FREE\n // and answered later by desktop Claude on the subscription.\n const explicit = /^\\/ask\\b/i.test(txt) || /^(bot|бот)[,:]/i.test(txt);\n if (BRAIN_KEY && explicit) {\n await brain(chatId, txt.replace(/^(\\/ask|bot|бот)[,:]?\\s*/i, \"\"));\n } else if (/\\?\\s*$/.test(txt)) {\n await sqlite.execute({ sql: \"INSERT INTO inbox (chat_id, kind, text) VALUES (?,?,?)\", args: [chatId, \"text\", txt] });\n await send(chatId, \"📜 Noted — desktop Claude will answer this for free at the next watch.\\nNeed it *now*? Resend with `/ask` in front (uses API credits ⚡).\");\n } else {\n await captureFallback(chatId, txt);\n }\n return c.text(\"ok\");\n }\n await send(chatId, \"The stone does not yet understand this kind of message — send text or a voice note.\");\n return c.text(\"ok\");\n});\n\n// Morning Herald: deliver brief + interactive task picker to the owner\napp.post(\"/morning-form\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { brief } = await c.req.json();\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\" });\n if (brief) await send(chatId, brief.slice(0, 3900));\n const date = new Date().toISOString().slice(0, 10);\n await tg(\"sendMessage\", { chat_id: chatId, text: \"🗡 Choose today's battles — tap to cycle: ⬜ skip · 📅 today · ✅ already done. Then forge the plan.\",\n reply_markup: await buildKeyboard(date) });\n return c.json({ ok: true });\n});\napp.get(\"/dayplan\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM day_plan_text ORDER BY date DESC LIMIT 1\");\n return c.json(r.rows[0] ?? {});\n});\n\n// Today's choices from the morning form — any session can read what Alexandr picked\napp.get(\"/dayselection\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const date = c.req.query(\"date\") ?? new Date().toISOString().slice(0, 10);\n const r = await sqlite.execute({\n sql: `SELECT dp.task_id, dp.state, t.title, t.tier, t.area, t.note\n FROM day_plan dp LEFT JOIN tasks t ON t.id = dp.task_id\n 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 return c.json({ date, picks: r.rows, plan: plan.rows[0]?.plan ?? null });\n});\n// Desktop session stores the forged plan (free) so it shows on the dashboard\napp.post(\"/dayplan\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { date, plan } = await c.req.json();\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO day_plan_text (date, plan) VALUES (?,?)\",\n args: [date ?? new Date().toISOString().slice(0, 10), plan] });\n return c.json({ ok: true });\n});\n\n// AGENT BUS — HQ dispatches jobs, specialists claim and answer them\napp.post(\"/agent/job\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { agent, brief, packs } = await c.req.json();\n if (!agent || !brief) return c.json({ ok: false, error: \"agent and brief required\" });\n const r = await sqlite.execute({ sql: \"INSERT INTO agent_jobs (agent, brief, packs) VALUES (?,?,?) RETURNING id\",\n args: [agent, brief, JSON.stringify(packs ?? [])] });\n return c.json({ ok: true, id: r.rows[0].id });\n});\napp.get(\"/agent/jobs\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const agent = c.req.query(\"agent\");\n const r = agent\n ? await sqlite.execute({ sql: \"SELECT * FROM agent_jobs WHERE status='queued' AND agent=? ORDER BY id\", args: [agent] })\n : await sqlite.execute(\"SELECT * FROM agent_jobs WHERE status='queued' ORDER BY id\");\n return c.json(r.rows);\n});\napp.post(\"/agent/result\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { id, result, ok } = await c.req.json();\n await sqlite.execute({ sql: \"UPDATE agent_jobs SET status=?, result=?, done_at=datetime('now') WHERE id=?\",\n args: [ok === false ? \"failed\" : \"done\", result ?? \"\", Number(id)] });\n return c.json({ ok: true });\n});\napp.get(\"/agent/results\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM agent_jobs WHERE status IN ('done','failed') ORDER BY id DESC LIMIT 30\");\n return c.json(r.rows);\n});\n\n// NEWS FEEDBACK — the Scribe registers items, Alexandr taps verdicts, HQ/Scribe learn from them\napp.post(\"/news/register\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { items } = await c.req.json(); // [{key,title,source,topic}]\n for (const i of items ?? []) {\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO news_items (key,title,source,topic) VALUES (?,?,?,?)\",\n args: [i.key, i.title ?? \"\", i.source ?? \"\", i.topic ?? \"\"] });\n }\n return c.json({ ok: true, n: (items ?? []).length });\n});\napp.get(\"/news/feedback\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const all = c.req.query(\"all\") === \"1\";\n const r = await sqlite.execute(all\n ? \"SELECT * FROM news_feedback ORDER BY id DESC LIMIT 200\"\n : \"SELECT * FROM news_feedback WHERE applied = 0 ORDER BY id\");\n return c.json(r.rows);\n});\napp.post(\"/news/feedback/applied\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { ids } = await c.req.json();\n for (const id of ids ?? []) await sqlite.execute({ sql: \"UPDATE news_feedback SET applied=1 WHERE id=?\", args: [Number(id)] });\n return c.json({ ok: true });\n});\n// Send one digest item with feedback buttons (called by the Scribe)\napp.post(\"/news/send\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { text, key } = await c.req.json();\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\" });\n await tg(\"sendMessage\", { chat_id: chatId, text, parse_mode: \"Markdown\",\n disable_web_page_preview: true,\n reply_markup: key ? { inline_keyboard: [[\n { text: \"👍\", callback_data: `n:up:${key}` },\n { text: \"👎\", callback_data: `n:down:${key}` },\n { text: \"⭐\", callback_data: `n:star:${key}` },\n { text: \"🚫\", callback_data: `n:block:${key}` },\n ]] } : undefined });\n return c.json({ ok: true });\n});\n\n// IN-ARTICLE REACTIONS — the Morning Edition (telegra.ph) ends every story with 👍👎⭐🚫 links.\n// The article is public, so links carry an HMAC token derived from PULL_SECRET instead of any\n// secret itself. Recording happens via a JS POST from the confirmation page, never on GET —\n// crawlers and link-prefetchers that fetch a URL must not be able to write feedback\n// (robots.txt below is the first fence, no-JS-no-write is the second, the HMAC is the third).\n// Tokens never expire by design: Alexandr reads old editions days later and reactions still count.\nasync function newsToken(key: string, v: string): Promise {\n const enc = new TextEncoder();\n const k = await crypto.subtle.importKey(\"raw\", enc.encode(PULL_SECRET),\n { name: \"HMAC\", hash: \"SHA-256\" }, false, [\"sign\"]);\n const sig = await crypto.subtle.sign(\"HMAC\", k, enc.encode(`${key}:${v}`));\n return Array.from(new Uint8Array(sig)).map((b) => b.toString(16).padStart(2, \"0\")).join(\"\").slice(0, 20);\n}\nconst V_EMOJI: Record = { up: \"👍\", down: \"👎\", star: \"⭐\", block: \"🚫\" };\nconst V_LABEL: Record = {\n up: \"More like this — noted\", down: \"Less of this — noted\",\n star: \"Marked important\", block: \"Never again — banished\",\n};\nconst esc = (s: string) => s.replace(/&/g, \"&\").replace(//g, \">\").replace(/\"/g, \""\");\n\nfunction reactShell(inner: string): string {\n return `\n\nPalantír

${inner}

`;\n}\n\napp.get(\"/robots.txt\", (c) => c.text(\"User-agent: *\\nDisallow: /\\n\"));\n\napp.get(\"/news/react\", async (c) => {\n const key = c.req.query(\"key\") ?? \"\", v = c.req.query(\"v\") ?? \"\", t = c.req.query(\"t\") ?? \"\";\n if (!key || !V_EMOJI[v] || t !== await newsToken(key, v)) {\n return c.html(reactShell(`

🌫

The stone does not know this sign

Stale or invalid reaction link.

`), 403);\n }\n const it = await sqlite.execute({ sql: \"SELECT title FROM news_items WHERE key=?\", args: [key] });\n const title = esc((it.rows[0]?.title as string) || key);\n const others = (await Promise.all(Object.keys(V_EMOJI).filter((x) => x !== v).map(async (x) =>\n `${V_EMOJI[x]}`,\n ))).join(\"\");\n return c.html(reactShell(`

${V_EMOJI[v]}

Recording…

“${title}”

${others}

\nChanged your mind? Tap another sign above.
Otherwise just close this page and return to the article.\n\n`));\n});\n\napp.post(\"/news/react\", async (c) => {\n const key = c.req.query(\"key\") ?? \"\", v = c.req.query(\"v\") ?? \"\", t = c.req.query(\"t\") ?? \"\";\n if (!key || !V_EMOJI[v] || t !== await newsToken(key, v)) return c.json({ ok: false }, 403);\n // Reloading the page re-POSTs; don't let one opinion count twice while unapplied.\n const dup = await sqlite.execute({\n sql: \"SELECT id FROM news_feedback WHERE item_key=? AND verdict=? AND applied=0\", args: [key, v] });\n if (dup.rows.length) return c.json({ ok: true, dup: true });\n const it = await sqlite.execute({ sql: \"SELECT * FROM news_items WHERE key=?\", args: [key] });\n const row: any = it.rows[0] ?? {};\n await sqlite.execute({\n sql: \"INSERT INTO news_feedback (item_key,title,source,topic,verdict) VALUES (?,?,?,?,?)\",\n args: [key, row.title ?? \"\", row.source ?? \"\", row.topic ?? \"\", v] });\n return c.json({ ok: true });\n});\n\n// SHARED JOURNAL — every session logs what it did here; the main HQ session files it into JOURNAL/\napp.post(\"/journal\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { source, summary, details } = await c.req.json();\n if (!summary) return c.json({ ok: false, error: \"summary required\" });\n await sqlite.execute({\n sql: \"INSERT INTO journal (source, summary, details) VALUES (?,?,?)\",\n args: [source ?? \"unknown session\", summary, details ?? \"\"],\n });\n return c.json({ ok: true });\n});\napp.get(\"/journal\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const all = c.req.query(\"all\") === \"1\";\n const r = await sqlite.execute(all\n ? \"SELECT * FROM journal ORDER BY id DESC LIMIT 100\"\n : \"SELECT * FROM journal WHERE filed = 0 ORDER BY id\");\n return c.json(r.rows);\n});\napp.post(\"/journal/filed\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { ids } = await c.req.json();\n for (const id of ids ?? []) {\n await sqlite.execute({ sql: \"UPDATE journal SET filed = 1 WHERE id = ?\", args: [Number(id)] });\n }\n return c.json({ ok: true });\n});\n\n// Claude sessions: read the work-group scribe log (owner's eyes only)\napp.get(\"/group\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const since = c.req.query(\"since\") ?? \"1970-01-01\";\n const limit = Math.min(Number(c.req.query(\"limit\") ?? 200), 500);\n const r = await sqlite.execute({\n sql: \"SELECT * FROM group_log WHERE ts >= ? ORDER BY id DESC LIMIT ?\",\n args: [since, limit],\n });\n return c.json(r.rows);\n});\n\n// Claude sessions: fetch unprocessed captures\napp.get(\"/pull\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM inbox WHERE processed = 0 ORDER BY id\");\n return c.json(r.rows);\n});\n// Claude sessions: mark processed\napp.post(\"/ack\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { ids } = await c.req.json();\n for (const id of ids ?? []) {\n await sqlite.execute({ sql: \"UPDATE inbox SET processed = 1 WHERE id = ?\", args: [id] });\n }\n return c.json({ ok: true });\n});\n// Outbound ping from Claude (desktop sessions, Herald, crons)\napp.post(\"/send\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const { text, chat_id } = await c.req.json();\n let target = chat_id;\n if (!target) {\n const r = await sqlite.execute(\"SELECT chat_id FROM chats ORDER BY first_seen LIMIT 1\");\n target = r.rows[0]?.chat_id;\n }\n if (!target) return c.json({ ok: false, error: \"no chat registered — /start the bot first\" });\n await send(target as number, text);\n return c.json({ ok: true });\n});\n\n\n// ---------- Quest Log CRUD (dashboard + Claude sessions) ----------\nconst auth = (c: any) => c.req.query(\"secret\") === PULL_SECRET;\n\napp.get(\"/tasks\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n // Default = Alexandr's own quests only. The dashboard Quest Log calls this bare,\n // so team tasks can never crowd his personal day. ?owner=all|danny|sergey for the board.\n const who = c.req.query(\"owner\") ?? \"alexandr\";\n const sqlOwner = who === \"all\" ? \"\" : \" AND COALESCE(owner,'alexandr') = ?\";\n const r = await sqlite.execute({\n sql: \"SELECT * FROM tasks WHERE status='open'\" + sqlOwner +\n \" ORDER BY CASE tier WHEN 'balrog' THEN 0 WHEN 'nazgul' THEN 1 WHEN 'fellowship' THEN 2 ELSE 3 END, ord, id\",\n args: who === \"all\" ? [] : [who] });\n return c.json(r.rows);\n});\napp.get(\"/tasks/all\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const r = await sqlite.execute(\"SELECT * FROM tasks ORDER BY status, tier, ord LIMIT 300\");\n return c.json(r.rows);\n});\napp.post(\"/tasks\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const b = await c.req.json();\n if (!b.force) {\n const twin = await findTwin(b.title);\n if (twin) return c.json({ ok: false, duplicate: true, existing: twin,\n hint: \"An equivalent task already exists. Reopen or comment on it, or resend with force:true.\" }, 409);\n }\n const mx = await sqlite.execute({ sql: \"SELECT COALESCE(MAX(ord),0)+10 AS o FROM tasks WHERE tier=?\", args: [b.tier ?? \"fellowship\"] });\n const r = await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord, owner) VALUES (?,?,?,?,?,?) RETURNING *\",\n args: [b.title, b.note ?? \"\", b.tier ?? \"fellowship\", b.area ?? \"\", b.ord ?? mx.rows[0].o,\n b.owner ?? \"alexandr\"],\n });\n return c.json(r.rows[0]);\n});\napp.post(\"/tasks/bulk\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const items = await c.req.json();\n let n = 0;\n const skipped: any[] = [];\n for (const b of items) {\n if (!b.force) {\n const twin = await findTwin(b.title);\n if (twin) { skipped.push({ title: b.title, existing: twin }); continue; }\n }\n await sqlite.execute({\n sql: \"INSERT INTO tasks (title, note, tier, area, ord) VALUES (?,?,?,?,?)\",\n args: [b.title, b.note ?? \"\", b.tier ?? \"fellowship\", b.area ?? \"\", (n + 1) * 10],\n });\n n++;\n }\n return c.json({ ok: true, inserted: n, skippedAsDuplicate: skipped });\n});\napp.patch(\"/tasks/:id\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json();\n const allowed = [\"title\", \"note\", \"tier\", \"area\", \"ord\", \"status\", \"owner\"];\n for (const k of allowed) {\n if (k in b) {\n await sqlite.execute({ sql: `UPDATE tasks SET ${k}=? WHERE id=?`, args: [b[k], id] });\n }\n }\n if (b.status === \"done\") {\n await sqlite.execute({ sql: \"UPDATE tasks SET done_at=datetime('now') WHERE id=?\", args: [id] });\n }\n const r = await sqlite.execute({ sql: \"SELECT * FROM tasks WHERE id=?\", args: [id] });\n return c.json(r.rows[0] ?? { ok: false });\n});\napp.post(\"/tasks/:id/comment\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const id = Number(c.req.param(\"id\"));\n const { text } = await c.req.json();\n const r = await sqlite.execute({ sql: \"SELECT comments FROM tasks WHERE id=?\", args: [id] });\n const comments = JSON.parse((r.rows[0]?.comments as string) ?? \"[]\");\n comments.push({ text, ts: new Date().toISOString().slice(0, 16).replace(\"T\", \" \") });\n await sqlite.execute({ sql: \"UPDATE tasks SET comments=? WHERE id=?\", args: [JSON.stringify(comments), id] });\n return c.json({ ok: true, count: comments.length });\n});\n\n// Warden triggers — called by the desktop scheduler (or manually); in-code window guards still apply\napp.get(\"/warden/:mode\", async (c) => {\n if (c.req.query(\"secret\") !== PULL_SECRET) return c.text(\"forbidden\", 401);\n const mode = c.req.param(\"mode\");\n if (mode !== \"monday\" && mode !== \"friday\") return c.text(\"unknown mode\", 400);\n const { runWarden } = await import(\"./warden-shared.ts\");\n await runWarden(mode as \"monday\" | \"friday\");\n return c.json({ ok: true, note: \"ran with window guards — check logs for skip/post\" });\n});\n\n// Roll yesterday's unfinished picks into today. Without this, choosing eight\n// battles and finishing three left the other five stranded — off the plan, off\n// the dashboard, remembered only by Alexandr.\napp.post(\"/day/rollover\", async (c) => {\n if (!auth(c)) return c.text(\"forbidden\", 401);\n const date = (await c.req.json().catch(() => ({}))).date ?? new Date().toISOString().slice(0, 10);\n const y = await sqlite.execute({\n sql: `SELECT dp.task_id, t.title FROM day_plan dp JOIN tasks t ON t.id = dp.task_id\n WHERE dp.date = date(?, '-1 day') AND dp.state = 'today' AND t.status = 'open'`,\n args: [date] });\n const carried: string[] = [];\n for (const r of y.rows as any[]) {\n const has = await sqlite.execute({\n sql: \"SELECT 1 FROM day_plan WHERE date=? AND task_id=?\", args: [date, r.task_id] });\n if (has.rows.length) continue;\n await sqlite.execute({\n sql: \"INSERT INTO day_plan (date, task_id, state) VALUES (?,?,'today')\",\n args: [date, r.task_id] });\n carried.push(r.title as string);\n }\n return c.json({ ok: true, date, carried: carried.length, titles: carried });\n});\n\napp.get(\"/\", (c) => c.text(\"🔮 Palantír Herald stands watch.\"));\nexport default app.fetch;\n","createdAt",["D",1786479627429],"branchVersion","branchId","cc31caf5-d2e1-4af9-b0dd-bd82fa3e53fe","id","8754a5f7-f359-4e36-abb1-c12689a1658c","palantir-herald",["D",1783928553221],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Palantír Herald — Telegram capture + pings","imageUrl","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",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",100,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ClaudeAssistant","handle","displayName","Alexandr Stakhov","avatar","https://lh3.googleusercontent.com/a/ACg8ocKCA_6NlmBdn2fDI25kVPZAGM3tPMEmD7U1Na63L8rtZj8kBQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":205,"_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":65,"_66":67,"_68":206,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":207,"_82":208,"_84":209,"_86":25},"tree",[184,185,186,187,188],"files",[184,185,186,187,188],"counts",{"_173":61,"_174":142,"_175":61,"_176":177,"_178":179},"contents",[130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":169,"_32":28,"_30":31,"_138":-5,"_41":42,"_40":14,"_140":25,"_38":170,"_13":171,"_33":34,"_35":37,"_24":25,"_145":-5,"_27":172},{"_43":161,"_32":162,"_30":163,"_138":-5,"_41":42,"_40":164,"_140":25,"_38":165,"_13":61,"_33":166,"_35":167,"_24":25,"_145":-5,"_27":168},{"_43":154,"_32":155,"_30":156,"_138":-5,"_41":42,"_40":157,"_140":25,"_38":158,"_13":142,"_33":143,"_35":159,"_24":25,"_145":-5,"_27":160},{"_43":147,"_32":148,"_30":149,"_138":-5,"_41":42,"_40":150,"_140":25,"_38":151,"_13":142,"_33":143,"_35":152,"_24":25,"_145":-5,"_27":153},{"_43":135,"_32":136,"_30":137,"_138":-5,"_41":42,"_40":139,"_140":25,"_38":141,"_13":142,"_33":143,"_35":144,"_24":25,"_145":-5,"_27":146},"6bbf5c09-77bd-492f-9104-18efee6ce78c","warden-shared.ts","96d7544c-8749-11f1-a009-1607ee4eb77e","parentId",10,"latest",["D",1784899694120],1,"script","// Shared logic for the cloud wardens (Monday scroll / Friday toast).\n// Runs only when ANTHROPIC_API_KEY is set. Ledger lives in sqlite (team_ledger).\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function runWarden(mode: \"monday\" | \"friday\", lastRunAt?: Date) {\n const KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n const BOT = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\n if (!KEY) { console.log(\"brain not armed — warden idle\"); return; }\n\n // ---- HARD GUARDS: correct weekday+hour window (UTC), and never twice per day ----\n const now = new Date();\n const day = now.getUTCDay(), hour = now.getUTCHours();\n const inWindow = mode === \"monday\" ? (day === 1 && hour >= 5 && hour <= 8)\n : (day === 5 && hour >= 14 && hour <= 17);\n if (!inWindow && Deno.env.get(\"WARDEN_FORCE\") !== \"1\") { console.log(`outside ${mode} window (utc day ${day} hour ${hour}) — skip`); return; }\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS warden_log (date TEXT, mode TEXT, PRIMARY KEY (date, mode))`);\n const today = now.toISOString().slice(0, 10);\n const ran = await sqlite.execute({ sql: \"SELECT 1 FROM warden_log WHERE date=? AND mode=?\", args: [today, mode] });\n if (ran.rows.length) { console.log(\"already ran today — skip\"); return; }\n await sqlite.execute({ sql: \"INSERT INTO warden_log (date, mode) VALUES (?,?)\", args: [today, mode] });\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS team_ledger (\n id INTEGER PRIMARY KEY AUTOINCREMENT, person TEXT, task TEXT,\n promised_on TEXT, status TEXT DEFAULT 'open', done_on TEXT)`);\n\n const since = new Date(Date.now() - 8 * 86400e3).toISOString().slice(0, 19).replace(\"T\", \" \");\n const msgs = await sqlite.execute({\n sql: \"SELECT ts,from_name,text FROM group_log WHERE kind='text' AND ts >= ? ORDER BY id\",\n args: [since] });\n const ledger = await sqlite.execute(\"SELECT * FROM team_ledger WHERE status='open'\");\n const groupRow = await sqlite.execute(\"SELECT chat_id FROM group_log ORDER BY id DESC LIMIT 1\");\n const groupChat = groupRow.rows[0]?.chat_id;\n if (!groupChat) { console.log(\"no group known\"); return; }\n\n const sys = `You are the AXIOMA Warden — commitment tracker for a small friendly team (Alexandr, his father Sergey, colleagues; the Maraletto e-commerce team). Chat may be Russian and/or English.\nFrom the week's messages: extract NEW promises (\"I'll do X\", \"that's on me\", \"беру на себя\", \"сделаю\", \"отправлю\" — real commitments only, be conservative, dedupe against the existing ledger), and detect completions (\"done\",\"готово\",\"отправил\" or clearly fulfilled).\nThen write the ${mode === \"monday\" ? \"Monday-morning report: per person, open items (oldest first, mark items open >1 week). If nothing open: a short varied celebration line.\" : \"Friday-evening check: if NOTHING is open for anyone, write a short (<=50 words) warm beer-toast celebrating the clean week. If anything IS open, the post must be EMPTY (silent Friday).\"}\nTone: warm, relaxed, one small joke max, never at anyone's expense, <=120 words, in the chat's dominant language.\nRespond ONLY with JSON, no fences:\n{\"new_open\":[{\"person\":\"...\",\"task\":\"...\",\"promised_on\":\"YYYY-MM-DD\"}],\"completed_ids\":[ledger ids now done],\"post\":\"group message or empty string\"}\nEXISTING OPEN LEDGER: ${JSON.stringify(ledger.rows)}\nWEEK'S MESSAGES: ${JSON.stringify(msgs.rows)}`;\n\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: { \"x-api-key\": KEY, \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model: Deno.env.get(\"BRAIN_MODEL\") ?? \"claude-haiku-4-5\", max_tokens: 1200,\n system: sys, messages: [{ role: \"user\", content: `Run the ${mode} warden now.` }] }),\n });\n if (!r.ok) { console.error(\"anthropic\", r.status, await r.text()); return; }\n const out = ((await r.json()).content?.[0]?.text ?? \"\").replace(/^```json\\s*|^```\\s*|```\\s*$/g, \"\").trim();\n let j: any;\n try { j = JSON.parse(out); } catch (e) { console.error(\"bad json\", out.slice(0, 200)); return; }\n\n for (const n of j.new_open ?? []) {\n await sqlite.execute({ sql: \"INSERT INTO team_ledger (person, task, promised_on) VALUES (?,?,?)\",\n args: [n.person, n.task, n.promised_on ?? new Date().toISOString().slice(0, 10)] });\n }\n for (const id of j.completed_ids ?? []) {\n await sqlite.execute({ sql: \"UPDATE team_ledger SET status='done', done_on=date('now') WHERE id=?\", args: [Number(id)] });\n }\n const post = (j.post ?? \"\").trim();\n if (post) {\n await fetch(`https://api.telegram.org/bot${BOT}/sendMessage`, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ chat_id: groupChat, text: post }),\n });\n console.log(\"posted to group\");\n } else {\n console.log(\"nothing to post (silent by design)\");\n }\n}\n","label",[136],"adb75a53-713a-450c-9387-7f68c81baa71","monday-scroll.ts","97465266-8749-11f1-89d0-1607ee4eb77e",12,["D",1784899862476],"// Cloud warden — Monday scroll. Cron (UTC): 30 6 * * 1 (~08:30 Amsterdam in summer)\nimport { runWarden } from \"./warden-shared.ts\";\nexport default async function (interval: Interval) {\n await runWarden(\"monday\", interval.lastRunAt);\n}\n",[148],"192cb76d-ad0e-4395-b073-6d375a501181","friday-toast.ts","97bde344-8749-11f1-b372-1607ee4eb77e",13,["D",1784899862794],"// Cloud warden — Friday toast. Cron (UTC): 30 15 * * 5 (~17:30 Amsterdam in summer)\nimport { runWarden } from \"./warden-shared.ts\";\nexport default async function (interval: Interval) {\n await runWarden(\"friday\", interval.lastRunAt);\n}\n",[155],"818e21c7-9c1a-4081-84c8-102861e10523","coin-watcher.ts","69902324-7e8e-11f1-90d7-1607ee4eb77e",2,["D",1783928554662],"interval","// Coin Watcher — pings Telegram when new Wise transactions complete (Val Town interval val)\n// Cron: */15 * * * * (UTC). Same val as bot-webhook.ts -> shares its sqlite (chats table).\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst WISE = Deno.env.get(\"WISE_TOKEN\");\nconst BOT = Deno.env.get(\"TELEGRAM_BOT_TOKEN\")!;\nconst PROFILE = Deno.env.get(\"WISE_PROFILE\") ?? \"\"; // Maraletto business profile id (env)\nconst strip = (s: string) => (s || \"\").replace(/<[^>]+>/g, \"\");\n\nexport default async function (interval: Interval) {\n if (!WISE) { console.log(\"WISE_TOKEN not set — watcher idle\"); return; }\n const r = await sqlite.execute(\"SELECT chat_id FROM chats ORDER BY first_seen LIMIT 1\").catch(() => null);\n const chat = r?.rows?.[0]?.chat_id;\n if (!chat) { console.log(\"no chat registered yet\"); return; }\n const since = interval.lastRunAt ?? new Date(Date.now() - 6 * 3600e3);\n\n const res = await fetch(`https://api.wise.com/v1/profiles/${PROFILE}/activities?size=10`,\n { headers: { Authorization: `Bearer ${WISE}` } });\n if (!res.ok) { console.error(\"wise\", res.status); return; }\n const acts = (await res.json()).activities ?? [];\n for (const a of acts.reverse()) {\n if (a.status !== \"COMPLETED\" || a.type === \"CARD_CHECK\") continue;\n if (new Date(a.createdOn) <= since) continue;\n const text = `🪙 *Coin moves in Erebor*\\n${strip(a.title)} — *${strip(a.primaryAmount)}*\\n_${(a.type || \"\").toLowerCase().replace(/_/g, \" \")} · Maraletto (Wise)_`;\n await fetch(`https://api.telegram.org/bot${BOT}/sendMessage`, {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chat, text, parse_mode: \"Markdown\" }),\n });\n }\n}\n",[162],"02524101-0ef4-47a3-9de6-23428f349581",["D",1786479627429],17,[28],"pulls","branches","forks","envVars",{"_180":182,"_183":61},"connections",{"_180":61,"_181":61},"count","unfilledCount",8,"emptyCount",{"_43":169,"_32":28,"_30":31,"_138":-5,"_41":42,"_40":14,"_140":25,"_38":202,"_13":171,"_33":34,"_35":37,"_24":25,"_145":-5,"_190":203,"_27":204},{"_43":161,"_32":162,"_30":163,"_138":-5,"_41":42,"_40":164,"_140":25,"_38":199,"_13":61,"_33":166,"_35":167,"_24":25,"_145":-5,"_190":200,"_27":201},{"_43":154,"_32":155,"_30":156,"_138":-5,"_41":42,"_40":157,"_140":25,"_38":196,"_13":142,"_33":143,"_35":159,"_24":25,"_145":-5,"_190":197,"_27":198},{"_43":147,"_32":148,"_30":149,"_138":-5,"_41":42,"_40":150,"_140":25,"_38":193,"_13":142,"_33":143,"_35":152,"_24":25,"_145":-5,"_190":194,"_27":195},{"_43":135,"_32":136,"_30":137,"_138":-5,"_41":42,"_40":139,"_140":25,"_38":189,"_13":142,"_33":143,"_35":144,"_24":25,"_145":-5,"_190":191,"_27":192},["D",1784899694120],"children",[],[136],["D",1784899862476],[],[148],["D",1784899862794],[],[155],["D",1783928554662],[],[162],["D",1786479627429],[],[28],["D",1783928553221],["D",1789525245864],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_127":243,"_244":245,"_246":247,"_248":25,"_249":25,"_250":25,"_251":125,"_252":-5,"_253":-7,"_254":-7,"_255":61,"_256":25,"_257":25,"_258":-5,"_259":25,"_260":25,"_261":25,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":88,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v25