[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22},"handle","umgroupkzcommits","name","aiGateway","path","hq.ts","project",{"_23":45,"_11":12,"_34":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":33,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":42},"file",{"_23":24,"_11":14,"_25":26,"_27":-5,"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":17,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/umgroupkzcommits/aiGateway/code/hq.ts","extension","ts","id","6bbb80ec-1983-48cb-bfcb-b155df5ca04f","fileId","5ef76614-ab4a-11f1-84b7-1607ee4eb77e","parentId","branchId","25b8e3e2-628a-4eb6-9af2-0242162621ad","branchVersion",289,"latest",true,"createdAt",["D",1789481763279],"version",51,"fileType","content","// Штаб: план дня → шаги по проектам → Claude Code на компьютере владельца →\n// проверка результата владельцем → готово.\n//\n// Зачем. Владелец 6 сентября: «описываю в единый центр весь план на день, он\n// предлагает шаги и работает по всем проектам; я только ставлю задачи и принимаю\n// работу». 9 сентября правило уточнено: день идёт этапами — рамка с вопросами,\n// ответы владельца, и лишь потом работа (см. README, «Как штаб строит день»).\n//\n// Кто что делает. Таблицы hq_plans / hq_steps (Supabase). Планирует и выполняет\n// Claude Code на компьютере владельца — его запускает сторож (tg-watch.ps1),\n// который спрашивает /hq/next: планировщик отдаёт шаги через hq_propose,\n// исполнитель отчитывается через hq_report. Владелец отвечает боту («план ок»,\n// «шаг 3 ок», «шаг 3: исправь …», «штаб», «стоп план») или жмёт кнопки на\n// странице штаба. Правки идут в ту же сессию Claude Code (--resume), контекст\n// не теряется.\n//\n// Параллельность: сколько шагов на одну папку — настройка; общий предел у сторожа.\n\nimport { ask, env } from \"./main.tsx\";\nimport { briefSystem, HQ_TOOLS } from \"./hq-text.ts\";\nimport { hqDigest, hqDialog, feedAdd, feedRecent, hqSay, planAnswer, HELD, openChat, nextOpen } from \"./hq-talk.ts\";\nexport { hqDigest, hqDialog, feedAdd, feedNotify, feedTalk, hqSay, planAnswer } from \"./hq-talk.ts\";\nexport { HQ_TOOLS };\n\ntype Notify = (text: string) => Promise;\n\nexport const PLANS = \"hq_plans\";\nexport const STEPS = \"hq_steps\";\n\nfunction json(body: unknown, status = 200) {\n return new Response(JSON.stringify(body), { status, headers: { \"Content-Type\": \"application/json; charset=utf-8\" } });\n}\n\nfunction sb() {\n const url = env(\"SUPABASE_URL\");\n const key = env(\"SUPABASE_SERVICE_KEY\");\n if (!url || !key) throw new Error(\"нет SUPABASE_URL или SUPABASE_SERVICE_KEY\");\n return { url: url.replace(/\\/+$/, \"\"), key };\n}\nfunction h(extra: Record = {}) {\n const { key } = sb();\n return { apikey: key, Authorization: `Bearer ${key}`, \"Content-Type\": \"application/json\", ...extra };\n}\nexport async function get(path: string): Promise {\n const { url } = sb();\n const r = await fetch(`${url}/rest/v1/${path}`, { headers: h() });\n if (!r.ok) throw new Error(`Supabase ${r.status}: ${(await r.text()).slice(0, 200)}`);\n return await r.json();\n}\nexport async function patch(path: string, body: unknown): Promise {\n const { url } = sb();\n const r = await fetch(`${url}/rest/v1/${path}`, { method: \"PATCH\", headers: h({ Prefer: \"return=representation\" }), body: JSON.stringify(body) });\n if (!r.ok) throw new Error(`Supabase ${r.status}: ${(await r.text()).slice(0, 200)}`);\n return await r.json();\n}\nexport async function insert(table: string, body: unknown): Promise {\n const { url } = sb();\n const r = await fetch(`${url}/rest/v1/${table}`, { method: \"POST\", headers: h({ Prefer: \"return=representation\" }), body: JSON.stringify(body) });\n if (!r.ok) throw new Error(`Supabase ${r.status}: ${(await r.text()).slice(0, 200)}`);\n return await r.json();\n}\nexport const now = () => new Date().toISOString();\nexport const short = (s: unknown, n: number) => String(s ?? \"\").replace(/\\s+/g, \" \").trim().slice(0, n);\n\n// ---------- настройки штаба ----------\n// Ключ-значение в hq_settings: автопилот, параллельность, модель исполнителя,\n// отметки последнего итога и пульса сторожа.\n\nconst SETTINGS = \"hq_settings\";\nexport async function getSetting(key: string): Promise {\n const rows = await get(`${SETTINGS}?key=eq.${encodeURIComponent(key)}&select=value`).catch(() => []);\n return rows[0]?.value ?? null;\n}\nexport async function setSetting(key: string, value: string): Promise {\n const rows = await patch(`${SETTINGS}?key=eq.${encodeURIComponent(key)}`, { value, at: now() }).catch(() => []);\n if (!rows.length) await insert(SETTINGS, { key, value, at: now() });\n}\nexport async function autopilot(): Promise {\n return (await getSetting(\"autopilot\")) !== \"off\";\n}\n/**\n * Какой моделью Claude Code выполнять шаги. Пусто — модель по умолчанию в Claude Code\n * владельца. Сторож подставляет её в `claude --model`. Владелец 9 сентября: «а на какой\n * модели всё это работает?» — чтобы менять её из штаба, а не правкой файла на компьютере.\n */\nexport async function setModel(name: string): Promise {\n const m = short(name, 60).toLowerCase();\n if (!m || /^(по умолчанию|сброс|как есть|default)$/.test(m)) {\n await setSetting(\"model\", \"\");\n return \"Шаги будут выполняться моделью по умолчанию вашего Claude Code (какая — покажет команда /model в Claude Code).\";\n }\n if (!/^[a-z0-9][a-z0-9.\\-]{2,59}$/.test(m)) return \"Название модели непонятно. Примеры: «штаб модель opus», «штаб модель sonnet», «штаб модель по умолчанию».\";\n await setSetting(\"model\", m);\n return `Шаги штаба пойдут на модели «${m}» (сторож запускает claude --model ${m}). Не подойдёт — «штаб модель по умолчанию».`;\n}\n\nexport async function setParallel(n: string | number): Promise {\n const k = Math.min(3, Math.max(1, Number(n) || 1));\n await setSetting(\"parallel_per_project\", String(k));\n return k === 1 ? \"В одной папке проекта — по одному шагу за раз (безопасно для кода).\" : `В одной папке проекта — до ${k} шагов одновременно (всего сторож ведёт не больше 3 сессий). Подходит для документных шагов; для правок кода в одной папке верните «штаб параллельно 1».`;\n}\nexport async function setAutopilot(on: boolean): Promise {\n await setSetting(\"autopilot\", on ? \"on\" : \"off\");\n return on\n ? \"Автопилот включён: планы стартуют сами, контрольные точки не останавливают работу, ждут вас только 🔒-шаги. Итог — «итог», по расписанию и по завершении плана.\"\n : \"Ручной режим: план ждёт «план ок», каждая контрольная точка — «шаг N ок».\";\n}\n\n// ---------- документы результата ----------\n//\n// Владелец 9 сентября: «а где результаты-то смотреть?». Исполнитель кладёт файлы\n// на компьютер; сторож после шага отправляет текстовые (.md/.txt) сюда, и страница\n// штаба показывает их прямо в приложении. Ключ — путь на компьютере.\n\nconst FILES = \"hq_files\";\nexport async function storeFile(a: { step_id?: number | string; path: string; content: string }): Promise {\n const path = String(a.path ?? \"\").trim();\n if (!path) throw new Error(\"нужен path\");\n const content = String(a.content ?? \"\").slice(0, 400_000);\n const name = path.split(/[\\\\/]/).pop() || path;\n const body = { step_id: a.step_id != null ? Number(a.step_id) : null, path, name, content, bytes: new TextEncoder().encode(content).length, at: now() };\n const upd = await patch(`${FILES}?path=eq.${encodeURIComponent(path)}`, body);\n const row = upd[0] ?? (await insert(FILES, body))[0];\n return { id: row.id, name, bytes: body.bytes };\n}\nexport async function listFiles(limit = 60): Promise {\n return await get(`${FILES}?select=id,step_id,path,name,bytes,at&order=at.desc&limit=${limit}`);\n}\nexport async function readFile(a: { id?: number | string; path?: string }): Promise {\n const rows = a.id != null\n ? await get(`${FILES}?id=eq.${a.id}`)\n : a.path ? await get(`${FILES}?path=eq.${encodeURIComponent(String(a.path))}`) : [];\n return rows[0] ?? null;\n}\n\n/** Всё состояние штаба одним JSON — для страницы в приложении (инструмент hq_data). */\nexport async function hqData(): Promise {\n // Архивные планы последних дней тоже отдаём: владелец 10 сентября случайно убрал план\n // в архив, и все его шаги «исчезли». Страница показывает их как скрытые, с возвратом.\n const week = new Date(Date.now() - 7 * 86400000).toISOString();\n const plans = await get(`${PLANS}?or=(archived.eq.false,at.gte.${encodeURIComponent(week)})&order=at.desc&limit=20`);\n const ids = plans.map((x) => x.id).join(\",\");\n const steps = ids ? await get(`${STEPS}?plan_id=in.(${ids})&order=plan_id.desc,ord.asc`) : [];\n const stored = await listFiles(120);\n const byPath = new Map(stored.map((f) => [f.path, f]));\n for (const s of steps) {\n s.files = filesOf(s.result).map((path) => {\n const f = byPath.get(path) ?? stored.find((x) => path.endsWith(x.name) || x.path.endsWith(path));\n return { path, name: path.split(/[\\\\/]/).pop(), id: f?.id ?? null, bytes: f?.bytes ?? null };\n });\n }\n return { now: now(), autopilot: await autopilot(), model: (await getSetting(\"model\")) || \"\", watcher_jobs: Number((await getSetting(\"watcher_jobs\")) ?? 0) || 0, parallel_per_project: Number((await getSetting(\"parallel_per_project\")) ?? 1) || 1, last_digest_at: await getSetting(\"last_digest_at\"), watcher_seen_at: await getSetting(\"watcher_seen_at\"), plans, steps, files: stored, feed: await feedRecent() };\n}\n\n// ---------- планы ----------\n\nexport const AUTO_PLAN = \"АВТОПЛАН\";\n\n// Пути к файлам из отчёта исполнителя — «где результаты смотреть» (владелец 9 сентября).\nconst FILE_RE = /[A-Za-z]:\\\$?:[^\\n\\\\«»\":;()]+\\\$*(?:«[^»\\n]+»|\"[^\"\\n]+\"|[^\\n\\\\«»\":;()]*?\\.(?:md|txt|docx?|xlsx?|pptx?|pdf|csv|json|py|ps1|ts|js|html?|png|jpe?g|zip|sql)\\b)/g;\nconst REL_FILE_RE = /(?:^|[\\s(«\"])((?:[\\p{L}\\p{N}_.-]+\\\\)+[\\p{L}\\p{N}_ .-]*?\\.(?:md|txt|docx?|xlsx?|pptx?|pdf|csv|json|py|ps1|ts|js|html?|png|jpe?g|zip|sql))\\b/gu;\nexport function filesOf(result: unknown): string[] {\n const t = String(result ?? \"\");\n const out = new Set();\n for (const m of t.matchAll(FILE_RE)) out.add(m[0].replace(/[«»\"]/g, \"\").trim());\n for (const m of t.matchAll(REL_FILE_RE)) if (![...out].some((x) => x.endsWith(m[1]))) out.add(m[1].trim());\n return [...out].slice(0, 12);\n}\n\n// Один и тот же план дважды (9 сентября: чат «Штаб» в Cowork создал план №5 рядом с\n// перепланированием №3 про того же Партнёра). Новый план на тему идущего — правка к\n// нему, а не второй план; «план новый: …» — принудительно отдельный.\nconst STOP = new Set([\"план\", \"плана\", \"сдела\", \"прове\", \"отчёт\", \"отчет\", \"клиен\", \"задач\", \"нужно\", \"потом\", \"снача\", \"после\", \"файл\", \"файлы\", \"докум\", \"подго\", \"сегод\", \"завтр\", \"проек\", \"работ\", \"чтобы\", \"котор\", \"через\", \"также\", \"можно\", \"нужны\", \"всего\", \"этого\", \"чтобы\"]);\nfunction stems(t: string): Set {\n const out = new Set();\n for (const w of String(t).toLowerCase().match(/[\\p{L}\\p{N}]{4,}/gu) ?? []) { const st = w.slice(0, 5); if (!STOP.has(st)) out.add(st); }\n return out;\n}\nfunction sameTopic(a: string, b: string): boolean {\n const A = stems(a), B = stems(b);\n if (A.size < 3 || B.size < 3) return false;\n let common = 0;\n for (const w of A) if (B.has(w)) common++;\n return common >= 3 && common / Math.min(A.size, B.size) >= 0.35;\n}\n\nexport async function createPlan(text: string, _notify: Notify, force = false): Promise {\n if (!text.trim()) throw new Error(\"пустой план\");\n const fm = text.trim().match(/^(?:новый|отдельный|отдельно)\\s*(?:план)?\\s*[:\\-—,]\\s*([\\s\\S]+)$/i);\n if (fm) { force = true; text = fm[1]; }\n const auto = text.trim().toUpperCase().startsWith(AUTO_PLAN);\n if (!auto && !force) {\n const active = await get(`${PLANS}?status=in.(draft,planning,discussing,proposed,approved,paused)&order=at.desc&limit=5`);\n const dup = active.find((p) => sameTopic(text, `${p.title} ${p.text}`));\n if (dup) {\n const r = await revisePlan(\"ДОПОЛНЕНИЕ: владелец прислал новый план на ту же тему — объединить с текущим, сделанное не повторять:\\n\" + text.trim(), _notify, dup.id);\n return `Это про то же, что идущий план №${dup.id} «${short(dup.title, 60)}» — второй план не завожу, записал как правку к нему. ${r} Нужен отдельный план — «план новый: …».`;\n }\n }\n const title = auto ? \"план дня — предложение штаба\" : short(text.split(/[\\n.!?]/)[0], 80) || \"план\";\n const [row] = await insert(PLANS, { text, title, status: \"draft\" });\n if (auto) return `План №${row.id}: штаб сам составит предложение на сегодня по вашим регулярным делам.`;\n return `План №${row.id} принят. Штаб на компьютере разберёт его и предложит шаги — обычно 3–10 минут. ` +\n `Потом ответьте «план ок» или «план правка: …».`;\n}\n\nasync function latestPlan(statuses: string[], id?: string | number): Promise {\n const rows = id\n ? await get(`${PLANS}?id=eq.${id}&status=in.(${statuses.join(\",\")})`)\n : await get(`${PLANS}?status=in.(${statuses.join(\",\")})&order=at.desc&limit=1`);\n return rows[0] ?? null;\n}\n\nexport async function stepsOf(planId: number | string): Promise {\n return await get(`${STEPS}?plan_id=eq.${planId}&order=ord.asc`);\n}\n\n/**\n * Шаг с replan закрыт: остальное штаб планирует заново по его результату\n * (владелец 8 сентября: «план предложи уже после расшифровки записи»).\n * Сделанные шаги остаются, ожидающие отменит новое предложение.\n */\nasync function replanAfter(s: any, notify: Notify): Promise {\n if (!s.replan) return false;\n const plan = (await get(`${PLANS}?id=eq.${s.plan_id}`))[0];\n if (!plan || ![\"approved\", \"done\"].includes(plan.status)) return false;\n const fb = `ПЕРЕПЛАНИРОВАНИЕ по результату шага №${s.id} «${short(s.title, 80)}»:\\n${String(s.result ?? \"\").slice(0, 4000)}`;\n // Шаг-рамка вернулся с вопросами: планировать остальной день без ответов владельца —\n // то самое «сделали кучу работы зря». Ставим план на паузу и спрашиваем.\n const asks: string[] = Array.isArray(s.asks) ? s.asks.map((x: any) => String(x)) : [];\n if (asks.length) {\n await patch(`${PLANS}?id=eq.${s.plan_id}`, { status: \"paused\", taken_at: null, feedback: fb.slice(0, 6000) });\n await notify(`⏸ План №${s.plan_id} ждёт ваших ответов — ${asks.length}:\\n` + asks.map((q, i) => `${i + 1}. ${q}`).join(\"\\n\") + `\\n\\nОтветьте «план ${s.plan_id} правка: …» (можно одним сообщением на все) — штаб соберёт остальные шаги по вашим ответам. Не важно — «план ${s.plan_id} продолжай».`);\n return true;\n }\n await patch(`${PLANS}?id=eq.${s.plan_id}`, { status: \"draft\", taken_at: null, done_at: null, feedback: fb.slice(0, 6000) });\n await notify(`🔁 Шаг №${s.id} закрыт — штаб перепланирует остальные шаги плана №${s.plan_id} по его результату и пришлёт новое предложение на утверждение.`);\n return true;\n}\n\n/** Шаги, у которых все зависимости закрыты, переводим waiting → queued. */\nasync function promote(planId: number | string): Promise {\n const steps = await stepsOf(planId);\n const done = new Set(steps.filter((s) => s.status === \"done\" || s.status === \"cancelled\").map((s) => Number(s.id)));\n let n = 0;\n for (const s of steps) {\n if (s.status !== \"waiting\") continue;\n const deps: number[] = (s.depends_on ?? []).map(Number);\n if (deps.every((d) => done.has(d))) {\n await patch(`${STEPS}?id=eq.${s.id}&status=eq.waiting`, { status: \"queued\" });\n n++;\n }\n }\n return n;\n}\n\nasync function planSummary(plan: any, steps: any[]): Promise {\n const mark: Record = {\n waiting: \"⏳ ждёт\", queued: \"▶ в очереди\", running: \"⚙ выполняется\", review: \"👀 на проверке\",\n // 🔒-шаг в работе только готовит: подменяем ниже, чтобы «выполняется» не пугало.\n done: \"✅ готово\", failed: \"✖ сбой\", cancelled: \"— отменён\",\n };\n const pmark: Record = { draft: \"черновик\", planning: \"планируется\", discussing: \"черновик словами — обсуждаем\", proposed: \"предложение\", approved: \"в работе\", paused: \"⏸ пауза\", done: \"выполнен\", cancelled: \"отменён\" };\n const live = steps.filter((s) => s.status !== \"cancelled\");\n const dropped = steps.length - live.length;\n const lines = live.map((s) => {\n const deps = (s.depends_on ?? []).length ? ` (после ${(s.depends_on as number[]).map((d) => \"№\" + d).join(\", \")})` : \"\";\n const state = s.approval && !s.permitted && [\"running\", \"queued\"].includes(s.status) ? (s.status === \"running\" ? \"⚙ готовит (не выполняет)\" : \"▶ в очереди на подготовку\") : mark[s.status] ?? s.status;\n return `${s.approval ? \"🔒 \" : s.checkpoint ? \"🔎 \" : \"\"}${s.replan ? \"🔁 \" : \"\"}${s.session_id && [\"waiting\", \"queued\"].includes(s.status) ? \"↪ \" : \"\"}Шаг №${s.id} · ${s.project || \"—\"} · ${state}${deps}\\n ${short(s.title, 120)}${s.session_note && [\"waiting\", \"queued\", \"running\"].includes(s.status) ? `\\n ↪ ${short(s.session_note, 160)}` : \"\"}`;\n });\n return `План №${plan.id} «${short(plan.title, 60)}» — ${pmark[plan.status] ?? plan.status}\\n` + lines.join(\"\\n\") +\n (dropped ? `\\n(ещё ${dropped} отменённых шагов не показаны — они не выполняются)` : \"\");\n}\n\n/**\n * Предварительный план словами. Владелец 9 сентября: «лучше, чтобы план сначала\n * предлагался общим текстовым списком, я бы читал, корректировал, отвечал на вопросы,\n * а уже потом это раскладывалось на шаги». Планировщик присылает сюда текст и вопросы;\n * шаги появятся только после «поехали».\n */\nexport async function planDraft(a: { plan_id: string | number; text: string; questions?: any[]; session_id?: string }, notify: Notify): Promise {\n const plan = (await get(`${PLANS}?id=eq.${a.plan_id}`))[0];\n if (!plan) throw new Error(`плана №${a.plan_id} нет`);\n if ([\"planning\", \"draft\", \"discussing\"].includes(plan.status) === false) throw new Error(`план №${plan.id} уже «${plan.status}» — черновик не принимается.`);\n const text = String(a.text ?? \"\").trim().slice(0, 6000);\n if (text.length < 40) throw new Error(\"text: нужен читаемый черновик плана словами\");\n const asks = (Array.isArray(a.questions) ? a.questions : []).map((q) => String(q).trim()).filter(Boolean).slice(0, 5);\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"discussing\", draft: text, asks, answers: null, taken_at: null, session_id: a.session_id ?? plan.session_id ?? null });\n await notify(`📝 План №${plan.id} — черновик, шагов ещё нет:\\n\\n${text}` +\n (asks.length ? `\\n\\nВопросы:\\n` + asks.map((q, i) => `${i + 1}. ${q}`).join(\"\\n\") : \"\") +\n `\\n\\n«план ${plan.id} поехали» — разложить на шаги; «план ${plan.id} правка: …» — поправить или ответить; «стоп план ${plan.id}» — отменить.`);\n return `план №${plan.id}: черновик отправлен владельцу, ждём «поехали»`;\n}\n\nexport async function approvePlan(notify: Notify, id?: string | number): Promise {\n const plan = await latestPlan([\"proposed\", \"discussing\"], id);\n if (!plan) return \"Нет плана, ожидающего утверждения. Сначала пришлите «план: …», штаб предложит шаги.\";\n // Утвердили черновик словами — теперь планировщик раскладывает его на шаги.\n if (plan.status === \"discussing\") {\n const answers = plan.answers && typeof plan.answers === \"object\" ? Object.entries(plan.answers).map(([k, v]) => `на вопрос ${Number(k) + 1}: ${v}`).join(\"; \") : \"\";\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"draft\", taken_at: null, feedback: (`ЧЕРНОВИК УТВЕРЖДЁН ВЛАДЕЛЬЦЕМ — разложи его на шаги.` + (answers ? ` Его ответы: ${answers}.` : \"\") + (plan.feedback ? `\\n${plan.feedback}` : \"\")).slice(0, 6000) });\n return `Черновик плана №${plan.id} принят — штаб раскладывает его на шаги, это 3–10 минут.`;\n }\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"approved\", approved_at: now() });\n const n = await promote(plan.id);\n const steps = await stepsOf(plan.id);\n const live = steps.filter((s) => s.status !== \"cancelled\").length;\n return `План №${plan.id} утверждён: шагов ${live}${steps.length > live ? ` (отменённые ${steps.length - live} не выполняются)` : \"\"}, в очередь ушло ${n}. Сторож на компьютере заберёт их в течение минуты. ` +\n `Шаги с 🔎 придут на проверку — отвечайте «шаг N ок» или «шаг N: что исправить». «штаб» — состояние.`;\n}\n\nexport async function revisePlan(feedback: string, notify: Notify, id?: string | number): Promise {\n const plan = await latestPlan([\"proposed\", \"discussing\", \"draft\", \"planning\", \"approved\", \"paused\", \"done\"], id);\n if (!plan) return \"Активного плана нет — пришлите новый: «план: …».\";\n const running = (await stepsOf(plan.id)).filter((s) => s.status === \"running\").length;\n await patch(`${STEPS}?plan_id=eq.${plan.id}&status=in.(waiting,queued)`, { status: \"cancelled\" });\n // Правка к плану — это и есть ответ на вопросы рамки: снимаем их с экрана.\n await patch(`${STEPS}?plan_id=eq.${plan.id}&asks=not.is.null`, { asks: null }).catch(() => []);\n await patch(`${PLANS}?id=eq.${plan.id}`, {\n status: \"draft\", session_id: plan.session_id,\n feedback: ((plan.feedback ? plan.feedback + \"\\n\" : \"\") + feedback).slice(0, 4000),\n });\n return `Правка к плану №${plan.id} записана, штаб перепланирует ещё не начатые шаги` + (running ? ` (${running} выполняющихся доработают)` : \"\") + (await autopilot() ? \" и продолжит сам.\" : \" и пришлёт новые шаги.\");\n}\n\nexport async function cancelPlan(id?: string | number): Promise {\n const plan = await latestPlan([\"draft\", \"planning\", \"discussing\", \"proposed\", \"approved\", \"paused\"], id);\n if (!plan) return \"Активного плана нет.\";\n await patch(`${STEPS}?plan_id=eq.${plan.id}&status=in.(waiting,queued,review)`, { status: \"cancelled\" });\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"cancelled\", done_at: now() });\n const running = (await stepsOf(plan.id)).filter((s) => s.status === \"running\").length;\n return `План №${plan.id} остановлен.` + (running ? ` ${running} шаг(а) уже выполняются — сторож закроет их по завершении, результат придёт, но дальше по плану не пойдёт.` : \"\");\n}\n\n/** Что сейчас требуется от владельца по плану — одной фразой на пункт. */\nfunction needsFromOwner(plan: any, steps: any[]): string[] {\n const out: string[] = [];\n if (plan.status === \"proposed\") out.push(`утвердить план №${plan.id} («план ${plan.id} ок») или поправить («план ${plan.id} правка: …»)`);\n if (plan.status === \"discussing\") { const asks = Array.isArray(plan.asks) ? plan.asks : []; const ans = plan.answers && typeof plan.answers === \"object\" ? plan.answers : {}; const left = asks.filter((_: any, i: number) => ans[String(i)] === undefined).length; out.push(left ? `ответить на ${left} вопрос(а) к черновику плана №${plan.id} (на странице — по одному кнопками, в Telegram — «план ${plan.id} правка: …»)` : `черновик плана №${plan.id} обсуждён — «план ${plan.id} поехали» или «план ${plan.id} правка: …»`); }\n if (plan.status === \"paused\") out.push(`план №${plan.id} на паузе — «план ${plan.id} продолжай»`);\n for (const s of steps) {\n if (s.status === \"review\" && s.approval && !s.permitted) out.push(`шаг №${s.id} подготовлен, нужно разрешение: «шаг ${s.id} делай» / «шаг ${s.id} ок» (закрыть без выполнения)`);\n else if (s.status === \"review\") out.push(`проверить результат шага №${s.id}: «шаг ${s.id} ок» или «шаг ${s.id}: что исправить»` + (s.replan ? \" — после «ок» штаб перепланирует остальное\" : \"\"));\n else if (s.status === \"failed\") out.push(`шаг №${s.id} упал — «шаг ${s.id}: как исправить» или «шаг ${s.id} отмени»`);\n }\n return out;\n}\n\n/** Строка о стороже: на связи ли компьютер владельца (пульс — опрос /hq/next раз в 20 с). */\nexport async function watcherLine(): Promise {\n const seen = await getSetting(\"watcher_seen_at\");\n if (!seen) return \"Сторож: ещё ни разу не выходил на связь — на компьютере запустите включить-сторожа.bat.\";\n const min = Math.round((Date.now() - new Date(seen).getTime()) / 60000);\n const jobs = Number((await getSetting(\"watcher_jobs\")) ?? 0) || 0;\n return min <= 2 ? (jobs >= 3 ? `Сторож на связи и занят: ${jobs} сессии Claude Code работают, следующий шаг возьмёт, как только освободится.` : \"Сторож на связи — шаги из очереди берутся в течение минуты.\") : `Сторож НЕ на связи ${min} мин (последний раз ${seen.slice(11, 16)} UTC): шаги в очереди не выполняются — запустите включить-сторожа.bat или включите компьютер.`;\n}\n\nexport async function hqStatus(): Promise {\n const mode = (await autopilot()) ? \"Режим: автопилот — планы стартуют сами, 🔎 не останавливают работу; ждут вас только 🔒 и сбои. «итог» — сводка.\" : \"Режим: ручной — «план ок», «шаг N ок».\";\n const plans = await get(`${PLANS}?status=in.(draft,planning,discussing,proposed,approved,paused)&order=at.desc&limit=3`);\n if (!plans.length) {\n const last = (await get(`${PLANS}?status=in.(done,cancelled)&archived=eq.false&order=at.desc&limit=1`))[0];\n return \"Активных планов нет.\" + (last ? ` Последний: №${last.id} «${short(last.title, 50)}» — ${last.status}.` : \"\") +\n \" Новый: «план: …». \" + mode + \"\\n\" + (await watcherLine());\n }\n const parts: string[] = [];\n for (const p of plans) {\n const steps = await stepsOf(p.id);\n const need = needsFromOwner(p, steps);\n parts.push((await planSummary(p, steps)) + (need.length ? \"\\n\\n⚠ Ждёт вас:\\n• \" + need.join(\"\\n• \") : \"\\n\\nОт вас сейчас ничего не нужно — работа идёт.\"));\n }\n return parts.join(\"\\n\\n\") + \"\\n\\n\" + mode + \"\\n\" + (await watcherLine());\n}\n\n// ---------- шаги ----------\n\nexport async function stepOk(id: string | number, notify: Notify): Promise {\n const [s] = await get(`${STEPS}?id=eq.${id}`);\n if (!s) return `Шага №${id} нет.`;\n if (s.status !== \"review\") return `Шаг №${id} сейчас «${s.status}», принимать нечего.`;\n await patch(`${STEPS}?id=eq.${id}`, { status: \"done\", seen: true });\n const skipped = s.approval && !s.permitted ? ` Действие НЕ выполнялось — закрыто без него (выполнить: «шаг ${id} делай»).` : \"\";\n if (await replanAfter(s, notify)) return `Шаг №${id} принят.${skipped} Штаб перепланирует остальное по его результату.`;\n const n = await promote(s.plan_id);\n const rest = (await stepsOf(s.plan_id)).filter((x) => ![\"done\", \"cancelled\"].includes(x.status));\n if (!rest.length) {\n await patch(`${PLANS}?id=eq.${s.plan_id}`, { status: \"done\", done_at: now() });\n return `Шаг №${id} принят.${skipped} План №${s.plan_id} выполнен целиком. 🎉`;\n }\n return `Шаг №${id} принят.${skipped}` + (n ? ` Дальше пошло ${n} шаг(а).` : \"\") + ` Осталось ${rest.length}.`;\n}\n\n/**\n * Ответ на ОДИН вопрос шага. Владелец 9 сентября: «ответил на один — второй улетел».\n * Вопросы жили одной пачкой, и любой ответ стирал всю; теперь ответы копятся по номерам,\n * а вопрос уходит с экрана только свой. Когда отвечены все — ответы уходят в дело:\n * у шага-рамки правкой в план (планировщик соберёт шаги по ним), у обычного шага —\n * доработкой в ту же сессию.\n */\nexport async function askAnswer(id: string | number, idx: any, text: string, notify: Notify): Promise {\n const [s] = await get(`${STEPS}?id=eq.${id}`);\n if (!s) return `Шага №${id} нет.`;\n const asks: string[] = Array.isArray(s.asks) ? s.asks.map((x: any) => String(x)) : [];\n if (!asks.length) return `У шага №${id} нет открытых вопросов.`;\n const i = Number(idx);\n if (!(i >= 0 && i < asks.length)) return `У шага №${id} нет вопроса №${Number(idx) + 1}.`;\n const answer = String(text ?? \"\").trim();\n if (!answer) return \"Пустой ответ — напишите, что ответить.\";\n const answers: Record = (s.answers && typeof s.answers === \"object\" && !Array.isArray(s.answers)) ? { ...s.answers } : {};\n answers[String(i)] = answer.slice(0, 2000);\n await feedAdd({ who: \"owner\", kind: \"answer\", step_id: s.id, plan_id: s.plan_id, text: answer, src: \"page\" });\n const left = asks.filter((_, k) => answers[String(k)] === undefined);\n if (left.length) {\n await patch(`${STEPS}?id=eq.${id}`, { answers });\n return `Ответ на вопрос ${i + 1} записан. Осталось вопросов: ${left.length} — штаб ждёт их, чтобы не гадать.`;\n }\n // Отвечено всё: собираем и пускаем в дело.\n await patch(`${STEPS}?id=eq.${id}`, { answers, asks: null });\n const pack = asks.map((q, k) => `В: ${q}\\nО: ${answers[String(k)] ?? \"—\"}`).join(\"\\n\\n\");\n if (s.replan) {\n const r = await revisePlan(`ОТВЕТЫ ВЛАДЕЛЬЦА на вопросы шага №${s.id}:\\n${pack}`, notify, s.plan_id);\n return `Ответ на вопрос ${i + 1} записан — отвечены все. ${r}`;\n }\n const r = await stepRework(s.id, `Ответы владельца:\\n${pack}`);\n return `Ответ на вопрос ${i + 1} записан — отвечены все. ${r}`;\n}\n\n/**\n * Задачи владельца на сегодня из Todoist — источник плана дня. Владелец 9 сентября:\n * «там я пишу задачи на день, заглядывай и предлагай план по ним, в моём порядке».\n * Токен — в переменной вала TODOIST_TOKEN, в коде и журнале его нет.\n */\nexport async function todoistToday(): Promise {\n const key = env(\"TODOIST_TOKEN\");\n if (!key) return \"Todoist не подключён: в переменных вала нет TODOIST_TOKEN.\";\n // Todoist закрыл REST v2 (отвечает 410) — ходим в текущий API v1, старый оставлен запасным.\n const urls = [\n \"https://api.todoist.com/api/v1/tasks/filter?query=\" + encodeURIComponent(\"today | overdue\"),\n \"https://api.todoist.com/rest/v2/tasks?filter=\" + encodeURIComponent(\"today | overdue\"),\n ];\n const codes: number[] = [];\n let rows: any[] = [];\n for (const u of urls) {\n const r = await fetch(u, { headers: { Authorization: `Bearer ${key}` } }).catch(() => null);\n if (!r) { codes.push(0); continue; }\n codes.push(r.status);\n if (!r.ok) continue;\n const j: any = await r.json().catch(() => null);\n rows = Array.isArray(j) ? j : Array.isArray(j?.results) ? j.results : [];\n break;\n }\n if (!rows.length && codes.every((c) => c !== 200)) {\n return `Todoist не ответил (коды ${codes.join(\", \")}). 401 — токен неверный, 410 — версия API закрыта; токен лежит в переменной вала TODOIST_TOKEN.`;\n }\n if (!rows.length) return \"На сегодня в Todoist задач нет.\";\n const line = (t: any) => `• ${String(t.content ?? \"\").slice(0, 200)}` +\n (t.due?.date ? ` (срок ${t.due.date}${t.due.is_recurring ? \", повторяется\" : \"\"})` : \"\") +\n (Number(t.priority) >= 3 ? \" [важно]\" : \"\") + (t.description ? ` — ${short(t.description, 200)}` : \"\");\n return `Задачи владельца на сегодня (Todoist, ${rows.length}):\\n` + rows.map(line).join(\"\\n\");\n}\n\n/** «шаг N делай» — разрешение владельца на запретное действие (деньги, сообщения другим людям). */\nexport async function stepGo(id: string | number): Promise {\n const [s] = await get(`${STEPS}?id=eq.${id}`);\n if (!s) return `Шага №${id} нет.`;\n if (!s.approval) return `Шаг №${id} не требует разрешения — для приёмки «шаг ${id} ок».`;\n if (s.permitted && s.status !== \"review\") return `Шаг №${id} уже разрешён, сейчас «${s.status}».`;\n if (![\"review\", \"failed\", \"done\"].includes(s.status)) return `Шаг №${id} сейчас «${s.status}» — дождитесь подготовки.`;\n await patch(`${STEPS}?id=eq.${id}`, { status: \"queued\", permitted: true, feedback: \"РАЗРЕШЕНО ВЛАДЕЛЬЦЕМ: выполни подготовленное действие ровно так, как показал в отчёте.\" });\n if (s.status === \"done\") await patch(`${PLANS}?id=eq.${s.plan_id}&status=eq.done`, { status: \"approved\", done_at: null });\n return `Шаг №${id}: разрешение записано, Claude Code выполнит подготовленное действие в той же сессии и отчитается.`;\n}\n\nexport async function stepRework(id: string | number, feedback: string): Promise {\n const [s] = await get(`${STEPS}?id=eq.${id}`);\n if (!s) return `Шага №${id} нет.`;\n if ([\"waiting\", \"queued\"].includes(s.status)) {\n await patch(`${STEPS}?id=eq.${id}`, { instruction: (String(s.instruction) + \"\\n\\nУточнение владельца: \" + feedback).slice(0, 8000) });\n return `Шаг №${id} ещё не начат — уточнение добавлено в поручение.`;\n }\n if (![\"review\", \"done\", \"failed\"].includes(s.status)) return `Шаг №${id} сейчас «${s.status}» — дождитесь результата, потом правьте.`;\n await patch(`${STEPS}?id=eq.${id}`, { status: \"queued\", feedback: feedback.slice(0, 4000) });\n if (s.status === \"done\") await patch(`${PLANS}?id=eq.${s.plan_id}&status=eq.done`, { status: \"approved\", done_at: null });\n // План на паузе после вопросов рамки: без снятия паузы доработанный шаг не запустится\n // никогда — сторож берёт шаги только из утверждённых планов (9 сентября штаб так завис).\n const rows = await patch(`${PLANS}?id=eq.${s.plan_id}&status=eq.paused`, { status: \"approved\" });\n const woke = rows.length ? \" План снят с паузы — шаг уйдёт в работу с вашими ответами.\" : \"\";\n return `Шаг №${id} отправлен на доработку в ту же сессию Claude Code: «${short(feedback, 100)}».` + woke;\n}\n\n/**\n * Отчёт исполнителя (инструмент hq_report или сторож). Контрольная точка →\n * на проверку владельцу, иначе → готово и следующие шаги в очередь.\n */\n/**\n * Короткая выжимка отчёта. Владелец 9 сентября: «везде полотно текста, читаешь —\n * не понимаешь, где внести корректировки, что важно, а что нет». Бесплатная\n * модель сжимает отчёт до 3–5 строк и отдельно вынимает вопросы к владельцу —\n * из них страница собирает «Вопросы дня».\n */\nconst MAX_ASKS = 2;\nasync function briefOf(s: any, result: string): Promise<{ brief: string; asks: string[] } | null> {\n if (result.length < 500) return null;\n try {\n const r: any = await ask({\n provider: \"gemini\", tier: \"smart\", max_tokens: 800, temperature: 0,\n note: \"выжимка отчёта шага для владельца\", project: \"Штаб\", trace: \"hq-brief\",\n system: briefSystem,\n prompt: `Шаг №${s.id}: ${s.title}\\nПроект: ${s.project || \"—\"}\\n\\nОтчёт:\\n${result.slice(0, 9000)}`,\n } as any);\n const t = String(r.text ?? \"\");\n const mm = t.match(/\\{[\\s\\S]*\\}/);\n const o = JSON.parse(mm ? mm[0] : t);\n const brief = (Array.isArray(o.brief) ? o.brief : []).map((x: any) => String(x).trim()).filter(Boolean).slice(0, 5);\n // Разбор 10 сентября: исполнители спрашивали по 3–4 раза о мелочах. Не больше двух вопросов на шаг.\n const allAsks = (Array.isArray(o.asks) ? o.asks : []).map((x: any) => String(x).trim()).filter(Boolean);\n const asks = allAsks.slice(0, MAX_ASKS);\n if (allAsks.length > MAX_ASKS) brief.push(\"ещё вопросы — в отчёте\");\n return brief.length ? { brief: brief.join(\"\\n\"), asks } : null;\n } catch { return null; }\n}\n\n/**\n * Выжимки задним числом: шаги, отчитавшиеся до появления briefOf, остались с\n * полотном и без «Вопросов дня». Владелец 9 сентября: «еще бы внутри каждого\n * шага чтобы был итог». Идём пачками, чтобы уложиться в предел вебхука.\n */\nexport async function backfillBriefs(limit = 5): Promise {\n // Отбираем в коде, а не фильтром: PostgREST-фильтр по пустому полю в этом\n // проекте молча ничего не возвращал, и уборка стояла.\n const all = await get(`${STEPS}?status=in.(done,review,failed)&order=id.desc&limit=200`);\n const need = all.filter((s: any) => !s.brief && String(s.result ?? \"\").length >= 500);\n let n = 0;\n for (const s of need.slice(0, limit)) {\n const b = await briefOf(s, String(s.result ?? \"\"));\n if (b) { await patch(`${STEPS}?id=eq.${s.id}`, { brief: b.brief, asks: b.asks }); n++; }\n }\n if (!need.length) return \"Все отчёты уже с выжимками.\";\n const left = need.length - n;\n return `Выжимок собрано: ${n}.` + (left ? ` Осталось без выжимки: ${left} — повторите «штаб выжимки».` : \" Больше нечего.\");\n}\n\nexport async function reportStep(a: { id: string | number; result: string; session_id?: string; failed?: boolean; needs_approval?: boolean }, notify: Notify): Promise {\n const [s] = await get(`${STEPS}?id=eq.${a.id}`);\n if (!s) throw new Error(`шага №${a.id} нет`);\n if (s.status === \"cancelled\") return `Шаг №${a.id} был отменён — результат записан, дальше по плану не идём.`;\n const result = String(a.result ?? \"\").slice(0, 12000);\n const upd: any = { result, result_at: now(), seen: false, attempts: Number(s.attempts ?? 0) + 1 };\n if (a.session_id) upd.session_id = a.session_id;\n if (a.needs_approval && !s.permitted) upd.approval = true;\n const plan = (await get(`${PLANS}?id=eq.${s.plan_id}`))[0];\n const lock = (s.approval || upd.approval) && !s.permitted;\n const sum = a.failed ? null : await briefOf(s, result);\n // Шаг вернулся после ответов владельца: новых вопросов из этого отчёта не вынимаем —\n // модель переспрашивала то же самое («он одни и те же вопросы по три раза спрашивал», 10 сентября).\n // Настоящий тупик исполнитель отдаёт сам: hq_report failed=true с одним вопросом.\n if (sum && (/^(Ответы владельца:|Доработка по словам владельца)/.test(String(s.feedback ?? \"\")) || (s.chat_at && Date.now() - new Date(s.chat_at).getTime() < 12 * 3600000))) sum.asks = [];\n if (sum) { upd.brief = sum.brief; upd.asks = sum.asks; upd.answers = null; }\n else if (!a.failed) { upd.asks = null; upd.answers = null; }\n const head = `Шаг №${s.id} · ${s.project || \"—\"} · ${short(s.title, 80)}`;\n const auto = await autopilot();\n const st = a.failed ? \"failed\" : lock ? \"locked\" : s.checkpoint && !s.permitted && !auto ? \"review\" : \"done\";\n await feedAdd({ who: \"claude\", kind: \"result\", step_id: s.id, plan_id: s.plan_id, src: st, text: sum?.brief || short(result, 1200) });\n // Владелец писал в ветку, пока шаг шёл: результат записан, шаг тут же уходит на доработку.\n if (!a.failed && String(s.feedback ?? \"\").startsWith(HELD)) {\n upd.status = \"queued\"; upd.taken_at = null; upd.feedback = \"Доработка по словам владельца, написанным пока шёл шаг:\\n\" + String(s.feedback).slice(HELD.length, 3800);\n await patch(`${STEPS}?id=eq.${s.id}`, upd);\n await notify(`↻ ${head}\\nГотово, но пока шаг шёл, вы писали в ветку — отправляю на доработку в ту же сессию.`);\n return `шаг №${s.id}: готово, уходит на доработку по словам владельца`;\n }\n if (lock && !a.failed) {\n // Запретное действие подготовлено, но не выполнено: ждём явного «делай».\n upd.status = \"review\";\n await patch(`${STEPS}?id=eq.${s.id}`, upd);\n await notify(`🔒 Нужно ваше разрешение. ${head}\\n\\n${result.slice(0, 3500)}\\n\\n«шаг ${s.id} делай» — выполнить ровно это; «шаг ${s.id}: правка» — изменить; «шаг ${s.id} ок» — закрыть, не выполняя.`);\n return `шаг №${s.id}: подготовлено, ждёт разрешения владельца`;\n }\n if (a.failed) {\n if (auto && Number(s.attempts ?? 0) < 1 && plan?.status === \"approved\") {\n // Автопилот: один повтор сам — в той же сессии, с хвостом ошибки.\n upd.status = \"queued\"; upd.taken_at = null;\n upd.feedback = (\"ПОВТОР ПОСЛЕ СБОЯ (сам, без владельца). Что было: \" + result.slice(-1500) + \"\\nРазберись в причине, обойди её и доведи шаг до конца; если это невозможно — hq_report failed=true с коротким объяснением, что нужно от владельца.\").slice(0, 4000);\n await patch(`${STEPS}?id=eq.${s.id}`, upd);\n await notify(`↻ ${head}\\nСбой, повторяю сам: ${short(result, 200)}`);\n return `шаг №${s.id}: сбой, повтор`;\n }\n upd.status = \"failed\";\n await patch(`${STEPS}?id=eq.${s.id}`, upd);\n await notify(`✖ ${head}\\nНе получилось:\\n${result.slice(0, 2500)}\\n\\nОтветьте «шаг ${s.id}: как исправить» — повторит в той же сессии, «шаг ${s.id} отмени» — идём дальше без него, или «стоп план».`);\n return `шаг №${s.id}: сбой записан`;\n }\n if (s.checkpoint && !s.permitted && !auto) {\n upd.status = \"review\";\n await patch(`${STEPS}?id=eq.${s.id}`, upd);\n await notify(`🔎 На проверку. ${head}\\n\\n${result.slice(0, 3500)}\\n\\nОтветьте «шаг ${s.id} ок» или «шаг ${s.id}: что исправить».`);\n return `шаг №${s.id}: на проверке у владельца`;\n }\n upd.status = \"done\";\n await patch(`${STEPS}?id=eq.${s.id}`, upd);\n if (await replanAfter({ ...s, result, asks: upd.asks ?? s.asks }, notify)) return `шаг №${s.id}: готово, дальше по вашим ответам`;\n const n = plan?.status === \"approved\" ? await promote(s.plan_id) : 0;\n const rest = (await stepsOf(s.plan_id)).filter((x) => ![\"done\", \"cancelled\"].includes(x.status));\n const okMark = s.permitted ? \"✅ Выполнено с вашего разрешения.\" : s.checkpoint && auto ? \"✅🔎\" : \"✅\";\n // Автопилот: коротко (подробности — в итоге), кроме шагов с разрешения владельца.\n const body = auto && !s.permitted ? short(result, 300) : result.slice(0, 1500);\n if (!rest.length && plan?.status === \"approved\") {\n await patch(`${PLANS}?id=eq.${s.plan_id}`, { status: \"done\", done_at: now() });\n await notify(`${okMark} ${head}\\n${body}\\n\\nПлан №${s.plan_id} выполнен целиком. 🎉`);\n if (auto) await hqDigest(notify, false);\n } else {\n await notify(`${okMark} ${head}\\n${body}` + (n ? `\\n\\nДальше пошло ${n} шаг(а).` : \"\"));\n }\n return `шаг №${s.id}: готово`;\n}\n\n/** Предложение шагов планировщиком (инструмент hq_propose). */\n/** Больше шести шагов на день владелец разобрать не может — режем и говорим об этом. */\nconst MAX_STEPS = 6;\n\nexport async function proposeSteps(a: { plan_id: string | number; steps: any[]; session_id?: string }, notify: Notify): Promise {\n const plan = (await get(`${PLANS}?id=eq.${a.plan_id}`))[0];\n if (!plan) throw new Error(`плана №${a.plan_id} нет`);\n if (!Array.isArray(a.steps) || !a.steps.length) throw new Error(\"steps: нужен непустой массив\");\n if (a.steps.length > 30) throw new Error(\"не больше 30 шагов в плане\");\n // Владелец 9 сентября: «31 шаг за день — каша, ключевое всё равно доуточняю руками».\n // Берём первые MAX_STEPS: остальное вернётся следующим планом, по результатам этих.\n const cut = Math.max(0, a.steps.length - MAX_STEPS);\n if (cut) a.steps = a.steps.slice(0, MAX_STEPS);\n // Принимаем шаги только от планировщика этого плана: 8 сентября сессия обычного\n // поручения вызвала hq_propose для двух чужих планов и снесла их предложения.\n if (![\"planning\", \"draft\"].includes(plan.status)) {\n throw new Error(`план №${plan.id} уже «${plan.status}» — предложение менять нельзя. Правки к плану делает владелец: «план правка: …»; ` +\n `новый план — «план: …». Если это обычное поручение, отвечайте через tg_answer.`);\n }\n // Старое предложение (если перепланируем) — отменяем.\n await patch(`${STEPS}?plan_id=eq.${plan.id}&status=in.(waiting,queued)`, { status: \"cancelled\" });\n const ids: number[] = [];\n for (let i = 0; i < a.steps.length; i++) {\n const st = a.steps[i] ?? {};\n if (!st.title || !st.instruction) throw new Error(`шаг ${i + 1}: нужны title и instruction`);\n const deps = (Array.isArray(st.depends_on) ? st.depends_on : [])\n .map((d: any) => Number(d))\n .filter((d: number) => d >= 1 && d <= i)\n .map((d: number) => ids[d - 1]);\n const [row] = await insert(STEPS, {\n plan_id: plan.id, ord: i + 1, project: short(st.project, 120) || null,\n title: short(st.title, 200), instruction: String(st.instruction).slice(0, 8000),\n checkpoint: !!st.checkpoint || !!st.approval, approval: !!st.approval, replan: !!st.replan, depends_on: deps, status: \"waiting\",\n session_id: st.resume_session ? short(st.resume_session, 80) : null,\n });\n ids.push(Number(row.id));\n }\n if (await autopilot()) {\n // Автопилот: не ждём «план ок» — стартуем сразу, владелец правит на ходу.\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"approved\", approved_at: now(), session_id: a.session_id ?? plan.session_id ?? null });\n const n = await promote(plan.id);\n const steps = await stepsOf(plan.id);\n await notify(\n `🚀 План №${plan.id} запущен (автопилот), в очередь ушло ${n}.` + (cut ? ` Планировщик предложил больше — ${cut} шаг(а) отложены до результатов этих.` : \"\") + `\\n` + (await planSummary({ ...plan, status: \"approved\" }, steps)) +\n `\\n\\n🔒 — подготовит и подождёт вашего «шаг N делай». Поправить на ходу: «план ${plan.id} правка: …», «шаг N отмени», «стоп план ${plan.id}». Итог — «итог».`,\n );\n return `план №${plan.id}: ${steps.length} шагов, запущен (автопилот)`;\n }\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"proposed\", session_id: a.session_id ?? plan.session_id ?? null });\n const steps = await stepsOf(plan.id);\n await notify(\n (await planSummary({ ...plan, status: \"предложение\" }, steps)) +\n `\\n\\n🔎 — контрольная точка: результат придёт вам на проверку. 🔒 — деньги или сообщения другим людям: подготовит, выполнит только после вашего «шаг N делай». 🔁 — после этого шага штаб перепланирует остальное по его результату.\\nОтветьте «план ок» — начну, или «план правка: …» — перепланирую. «стоп план» — отмена.`,\n );\n return `план №${plan.id}: ${steps.length} шагов предложено, ждём утверждения владельца`;\n}\n\n// ---------- управление планом на ходу ----------\n\n/** Последний активный план (для команд без номера). */\nasync function activePlan(id?: string | number): Promise {\n return await latestPlan([\"proposed\", \"approved\", \"paused\", \"draft\", \"planning\"], id);\n}\n\nexport async function stepCancel(id: string | number): Promise {\n const [s] = await get(`${STEPS}?id=eq.${id}`);\n if (!s) return `Шага №${id} нет.`;\n if (![\"waiting\", \"queued\", \"review\", \"failed\"].includes(s.status)) return `Шаг №${id} сейчас «${s.status}» — отменить можно только ожидающий или на проверке.`;\n await patch(`${STEPS}?id=eq.${id}`, { status: \"cancelled\" });\n const plan = (await get(`${PLANS}?id=eq.${s.plan_id}`))[0];\n const n = plan?.status === \"approved\" ? await promote(s.plan_id) : 0;\n return `Шаг №${id} отменён.` + (n ? ` Освободилось ${n} шаг(а), пошли дальше.` : \"\");\n}\n\n/** Поднять шаг в начало очереди (срочно) или опустить в конец. */\nexport async function stepMove(id: string | number, dir: \"up\" | \"down\"): Promise {\n const [s] = await get(`${STEPS}?id=eq.${id}`);\n if (!s) return `Шага №${id} нет.`;\n if (![\"waiting\", \"queued\"].includes(s.status)) return `Шаг №${id} сейчас «${s.status}» — двигать можно только ожидающие.`;\n const all = (await stepsOf(s.plan_id)).filter((x) => ![\"cancelled\", \"done\"].includes(x.status));\n const ords = all.map((x) => Number(x.ord));\n const ord = dir === \"up\" ? Math.min(...ords) - 1 : Math.max(...ords) + 1;\n const upd: any = { ord };\n if (dir === \"up\" && s.status === \"waiting\") upd.depends_on = [];\n await patch(`${STEPS}?id=eq.${id}`, upd);\n if (dir === \"up\") {\n const plan = (await get(`${PLANS}?id=eq.${s.plan_id}`))[0];\n if (plan?.status === \"approved\") await promote(s.plan_id);\n }\n return dir === \"up\" ? `Шаг №${id} — первым в очереди (зависимости сняты).` : `Шаг №${id} — в конец очереди.`;\n}\n\n/** Добавить шаг руками: текст — что сделать; проект угадает сторож по словам. */\nexport async function stepAdd(text: string, planId?: string | number, resume = false): Promise {\n const plan = await activePlan(planId);\n if (!plan) return \"Нет активного плана — сначала «план: …».\";\n if (!text.trim()) return \"Пустой шаг.\";\n const all = await stepsOf(plan.id);\n const ord = Math.max(0, ...all.map((x) => Number(x.ord))) + 1;\n const status = plan.status === \"approved\" ? \"queued\" : \"waiting\";\n const m = text.match(/^\\[([^\\]]{2,60})\\]\\s*/);\n const project = m ? m[1].trim() : null;\n const body = m ? text.slice(m[0].length) : text;\n if (/^продолж/i.test(body)) resume = true;\n const [row] = await insert(STEPS, {\n plan_id: plan.id, ord, project, title: short(body, 200), instruction: body.slice(0, 8000),\n checkpoint: true, status, depends_on: [], session_id: resume ? \"latest\" : null,\n });\n return `Шаг №${row.id} добавлен в план №${plan.id}` + (resume ? \" как продолжение последней сессии Claude Code в этой папке\" : \"\") + (status === \"queued\" ? \" и уже в очереди.\" : \" (пойдёт после «план ок»).\") +\n (project ? \"\" : \" Проект не указан — сторож угадает по словам; можно задать так: «план добавь: [Крокус] текст».\");\n}\n\n/** Сменить папку проекта у ещё не начатых шагов плана (владелец 9 сентября: «нужна новая папка для штаба»). */\nexport async function planProject(folder: string, id?: string | number): Promise {\n const plan = await activePlan(id);\n if (!plan) return \"Активного плана нет.\";\n const f = short(folder, 120);\n if (!f) return \"Назовите папку проекта (имя папки в C:\\\\Вайбкодинг).\";\n const rows = await patch(`${STEPS}?plan_id=eq.${plan.id}&status=in.(waiting,queued)`, { project: f });\n return `План №${plan.id}: папка проекта «${f}» у ${rows.length} не начатых шагов. Если папки на компьютере ещё нет — создайте её (или попросите Claude Code) до запуска: сторож работает в C:\\\\Вайбкодинг\\\\${f}.`;\n}\n\n/**\n * Исполнитель шага нашёл по ходу работы, что нужен ещё один шаг (инструмент hq_suggest).\n * Владелец 9 сентября: «он же может создавать новые шаги по результатам предыдущих».\n * Только добавление в свой план и только в конец: чужие шаги трогать нельзя (8 сентября\n * сессия поручения вызвала hq_propose и снесла два плана). Пределы — от бесконечной цепочки.\n */\nexport async function suggestStep(a: { step_id: string | number; title: string; instruction: string; project?: string; approval?: boolean; why?: string }, notify: Notify): Promise {\n const [from] = await get(`${STEPS}?id=eq.${a.step_id}`);\n if (!from) throw new Error(`шага №${a.step_id} нет`);\n if (!a.title || !a.instruction) throw new Error(\"нужны title и instruction\");\n const plan = (await get(`${PLANS}?id=eq.${from.plan_id}`))[0];\n if (!plan || ![\"approved\", \"paused\", \"proposed\"].includes(plan.status)) return `план №${from.plan_id} сейчас «${plan?.status}» — шаг не добавлен, расскажите о находке в hq_report.`;\n const all = await stepsOf(plan.id);\n if (all.filter((x) => x.suggested_by).length >= 6) return \"в этом плане уже 6 шагов, предложенных исполнителями, — больше не добавляю; напишите о находке в hq_report.\";\n if (all.filter((x) => Number(x.suggested_by) === Number(from.id)).length >= 2) return \"этот шаг уже предложил два новых — больше не добавляю; остальное в hq_report.\";\n const ord = Math.max(0, ...all.map((x) => Number(x.ord))) + 1;\n const status = plan.status === \"approved\" ? \"queued\" : \"waiting\";\n const [row] = await insert(STEPS, {\n plan_id: plan.id, ord, project: short(a.project, 120) || from.project,\n title: short(a.title, 200), instruction: (String(a.instruction).slice(0, 8000) + `\\n\\nШаг предложен исполнителем шага №${from.id} по ходу работы${a.why ? \": \" + short(a.why, 300) : \"\"}.`),\n checkpoint: true, approval: !!a.approval, replan: false, depends_on: [], status, suggested_by: Number(from.id),\n });\n await notify(`➕ Шаг №${row.id} добавлен исполнителем шага №${from.id}${a.why ? `: ${short(a.why, 200)}` : \"\"}\\n${short(a.title, 150)}\\nНе нужен — «шаг ${row.id} отмени».`);\n return `шаг №${row.id} добавлен в план №${plan.id} (${status === \"queued\" ? \"в очереди\" : \"ждёт утверждения плана\"}), владельцу отправлено уведомление`;\n}\n\n/** «План N перепланируй» — штаб пересобирает оставшиеся шаги по результатам сделанных. */\nexport async function planReplan(id?: string | number): Promise {\n const plan = await latestPlan([\"approved\", \"paused\", \"proposed\", \"done\"], id);\n if (!plan) return \"Активного плана нет.\";\n const steps = await stepsOf(plan.id);\n const done = steps.filter((s) => s.status === \"done\" && s.result);\n if (!done.length) return `По плану №${plan.id} ещё нет результатов — перепланировать не по чему.`;\n const running = steps.filter((s) => s.status === \"running\").length;\n const fb = \"ПЕРЕПЛАНИРОВАНИЕ по результатам уже сделанных шагов. Сделанное не повторять; ожидающие шаги будут заменены твоим новым списком — оставь в нём только то, что после этих результатов ещё нужно, и добавь то, что из них следует.\\n\\n\" +\n done.map((s) => `Шаг №${s.id} «${short(s.title, 80)}»:\\n${String(s.result).slice(0, 2500)}`).join(\"\\n\\n\");\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"draft\", taken_at: null, done_at: null, feedback: fb.slice(0, 12000) });\n return `План №${plan.id}: штаб пересоберёт оставшиеся шаги по результатам ${done.length} сделанных (3–10 минут)` + (running ? `; ${running} выполняющихся доработают` : \"\") + \".\";\n}\n\nexport async function planPause(id?: string | number): Promise {\n const plan = await latestPlan([\"approved\"], id);\n if (!plan) return \"Нет плана в работе, который можно приостановить.\";\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"paused\" });\n const running = (await stepsOf(plan.id)).filter((x) => x.status === \"running\").length;\n return `План №${plan.id} на паузе: новые шаги не запускаются.` + (running ? ` ${running} шаг(а) в работе доработают.` : \"\") + ` Продолжить: «план ${plan.id} продолжай».`;\n}\n\nexport async function planResume(id?: string | number): Promise {\n const plan = await latestPlan([\"paused\"], id);\n if (!plan) return \"Нет плана на паузе.\";\n // Пауза после шага-рамки: шагов ещё нет, продолжать нечего — отправляем на планирование.\n const rest = (await stepsOf(plan.id)).filter((x) => ![\"done\", \"cancelled\"].includes(x.status));\n if (!rest.length) {\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"draft\", taken_at: null });\n return `План №${plan.id} собирается дальше — штаб предложит шаги по тому, что уже выяснено.`;\n }\n await patch(`${PLANS}?id=eq.${plan.id}`, { status: \"approved\" });\n const n = await promote(plan.id);\n return `План №${plan.id} продолжается.` + (n ? ` В очередь ушло ${n}.` : \"\");\n}\n\n/** Убрать в архив отменённые и выполненные планы: с экрана и из «штаб». */\nexport async function archivePlans(id?: string | number): Promise {\n const rows = id\n ? await patch(`${PLANS}?id=eq.${id}&status=in.(cancelled,done)`, { archived: true })\n : await patch(`${PLANS}?status=in.(cancelled,done)&archived=eq.false`, { archived: true });\n return rows.length ? `В архив убрано планов: ${rows.length}.` : \"Нечего убирать: отменённых и выполненных планов вне архива нет.\";\n}\nexport async function unarchivePlan(id: string | number): Promise {\n const rows = await patch(`${PLANS}?id=eq.${id}&archived=eq.true`, { archived: false });\n return rows.length ? `План №${id} возвращён из архива — его шаги снова на виду.` : `План №${id} не в архиве.`;\n}\n\n/**\n * «Прочитано»: убрать карточку с глаз. Владелец 9 сентября: «нужна возможность\n * скрывать те, что я прочитал, а то они копятся и мешают». Шаг никуда не\n * девается — он остаётся в свёрнутом списке прочитанного и в отчётах.\n */\nexport async function stepSeen(id: string | number, on = true): Promise {\n const rows = await patch(`${STEPS}?id=eq.${id}`, { seen: on });\n if (!rows.length) return `Шага №${id} нет.`;\n return on ? `Шаг №${id} убран как прочитанный. Вернуть: «покажи скрытое».` : `Шаг №${id} снова на виду.`;\n}\n\n/** Скрыть всё сделанное разом; заодно закрытые планы — в архив. */\nexport async function seenAll(): Promise {\n const rows = await patch(`${STEPS}?status=eq.done&seen=eq.false`, { seen: true });\n const arch = await patch(`${PLANS}?status=in.(cancelled,done)&archived=eq.false`, { archived: true });\n if (!rows.length && !arch.length) return \"Скрывать нечего: всё сделанное уже убрано.\";\n return `Скрыто сделанных шагов: ${rows.length}.` + (arch.length ? ` Планов в архив: ${arch.length}.` : \"\") + \" Вернуть: «покажи скрытое».\";\n}\n\n/** Вернуть скрытое на экран. */\nexport async function unseenAll(): Promise {\n const rows = await patch(`${STEPS}?seen=eq.true`, { seen: false });\n return rows.length ? `Возвращено на экран шагов: ${rows.length}.` : \"Скрытых шагов нет.\";\n}\n\n// ---------- сторож: что делать дальше ----------\n\n/** Планы и шаги, зависшие в работе дольше двух часов, возвращаем в очередь. */\nasync function unstick() {\n const stale = new Date(Date.now() - 2 * 3600 * 1000).toISOString();\n await patch(`${STEPS}?status=eq.running&taken_at=lt.${encodeURIComponent(stale)}`, { status: \"queued\", taken_at: null }).catch(() => []);\n await patch(`${PLANS}?status=eq.planning&taken_at=lt.${encodeURIComponent(stale)}`, { status: \"draft\", taken_at: null }).catch(() => []);\n}\n\n/**\n * Следующая работа для сторожа: сначала планирование (draft), потом шаг из\n * очереди утверждённого плана, чей проект сейчас не занят. busy — папки, в\n * которых сторож уже ведёт сессии.\n */\nexport async function claimNextWork(busy: string[]): Promise {\n await unstick();\n const plans = await get(`${PLANS}?status=eq.draft&order=at.asc&limit=1`);\n if (plans[0]) {\n const p = plans[0];\n const got = await patch(`${PLANS}?id=eq.${p.id}&status=eq.draft`, { status: \"planning\", taken_at: now() });\n if (got.length) {\n // stage: draft — сначала черновик словами; steps — владелец его утвердил, режем на шаги.\n const stage = p.draft && /ЧЕРНОВИК УТВЕРЖДЁН/.test(String(p.feedback ?? \"\")) ? \"steps\" : \"draft\";\n return { kind: \"plan\", id: p.id, title: p.title, text: p.text, feedback: p.feedback, draft: p.draft ?? null, stage, session_id: p.session_id, model: (await getSetting(\"model\")) || null };\n }\n }\n // Сколько шагов одновременно в одной папке проекта. По умолчанию 1 (две сессии в одной\n // папке портят друг другу файлы); владелец 9 сентября: «один пункт за раз — надо побыстрее»,\n // документные шаги пишут в разные файлы — «штаб параллельно 3».\n const perProject = Math.max(1, Number((await getSetting(\"parallel_per_project\")) ?? 1) || 1);\n const busySet = new Set(perProject > 1 ? [] : busy.map((b) => b.toLowerCase()));\n const runningCount = new Map();\n for (const r of await get(`${STEPS}?status=eq.running&select=project`)) { const k = String(r.project ?? \"\").toLowerCase(); runningCount.set(k, (runningCount.get(k) ?? 0) + 1); }\n const runningProjects = new Set([...runningCount.entries()].filter(([, n]) => n >= perProject).map(([k]) => k));\n const queued = await get(`${STEPS}?status=eq.queued&order=plan_id.asc,ord.asc&limit=20`);\n for (const s of queued) {\n const plan = (await get(`${PLANS}?id=eq.${s.plan_id}&select=id,status,title`))[0];\n if (!plan || plan.status !== \"approved\") continue;\n const proj = String(s.project ?? \"\").toLowerCase();\n if (proj && (busySet.has(proj) || runningProjects.has(proj))) continue;\n const got = await patch(`${STEPS}?id=eq.${s.id}&status=eq.queued`, { status: \"running\", taken_at: now() });\n if (!got.length) continue;\n const all = await stepsOf(s.plan_id);\n // Одна тема — один чат Claude Code. Владелец 9 сентября: «если по вопросу уже есть чат,\n // пусть работает в нём». Берём сессию предыдущего шага этого же плана в той же папке,\n // если её сейчас никто не занял: контекст сохраняется, и чат можно продолжить руками.\n let resume = s.session_id;\n if (!resume) {\n const held = new Set(all.filter((x) => x.status === \"running\" && x.id !== s.id && x.session_id).map((x) => String(x.session_id)));\n const prev = all\n .filter((x) => x.session_id && !held.has(String(x.session_id)) && String(x.project ?? \"\").toLowerCase() === proj && [\"done\", \"review\"].includes(x.status))\n .sort((a, b) => Number(b.ord) - Number(a.ord))[0];\n if (prev) resume = prev.session_id;\n }\n const context = all\n .filter((x) => (s.depends_on ?? []).map(Number).includes(Number(x.id)) && x.result)\n .map((x) => `Результат шага №${x.id} «${short(x.title, 80)}»:\\n${String(x.result).slice(0, 3000)}`)\n .join(\"\\n\\n\");\n return {\n kind: \"step\", id: s.id, plan_id: s.plan_id, plan_title: plan.title, ord: s.ord, total: all.length,\n project: s.project, title: s.title, instruction: s.instruction, checkpoint: s.checkpoint,\n feedback: s.feedback, prev_result: s.result ?? null, approval: !!s.approval, permitted: !!s.permitted, replan: !!s.replan,\n session_id: resume, context, attempts: s.attempts, model: (await getSetting(\"model\")) || null,\n };\n }\n return null;\n}\n\nexport async function releaseWork(kind: string, id: string): Promise {\n if (kind === \"plan\") return (await patch(`${PLANS}?id=eq.${id}&status=eq.planning`, { status: \"draft\", taken_at: null })).length > 0;\n return (await patch(`${STEPS}?id=eq.${id}&status=eq.running`, { status: \"queued\", taken_at: null })).length > 0;\n}\n\n// ---------- Telegram: команды владельца ----------\n\n/** Возвращает ответ, если сообщение — команда штаба; иначе null. */\nexport async function hqCommand(raw: string, notify: Notify): Promise {\n const t = raw.trim();\n let m: RegExpMatchArray | null;\n // Голосом двоеточие не произносят — расшифровка ставит точку или запятую.\n if ((m = t.match(/^(план|план на день|план на сегодня|план на завтра|штаб|план дня|план новый|новый план|отдельный план)\\s*[:\\-—.,]\\s*([\\s\\S]{8,})$/i))) return await createPlan(m[2].trim(), notify, /нов|отдельн/i.test(m[1]));\n if (/^(план сам|составь план|предложи план|план дня сам|штаб, предложи план|штаб предложи план)\\s*[.!]*$/i.test(t)) return await createPlan(AUTO_PLAN + \": по регулярным делам владельца\", notify);\n // Длинное надиктованное поручение, где в начале упомянут штаб или план на\n // день/завтра, — это план, даже без «план:» (голосовое №8 от 8 сентября ушло\n // обычным поручением и планировщика не увидело).\n if (t.length >= 150 && /(через штаб|в штаб|штабу|штаб[,:]? |план(ируй|ируешь|ировать)? на (завтра|сегодня|день|неделю)|план действий)/i.test(t.slice(0, 160))) return await createPlan(t, notify);\n if ((m = t.match(/^план\\s*№?\\s*(\\d+)?\\s*(?:поехали|погнали|раскладывай|в работу)\\s*[.!]*$/i))) return await approvePlan(notify, m[1] || undefined);\n if (/^(задачи|задачи на сегодня|что на сегодня|todoist)\\s*[?.!]*$/i.test(t)) return await todoistToday();\n if ((m = t.match(/^(?:план\\s*№?\\s*(\\d+)\\s*ок|план\\s*ок\\s*№?\\s*(\\d+)|план\\s*ок|ок\\s*план|утверждаю|план утверждаю|утверждаю план|план принят|запускай план)\\s*[.!]*$/i))) return await approvePlan(notify, m[1] || m[2] || undefined);\n if ((m = t.match(/^план\\s*№?\\s*(\\d+)?\\s*(правка|правки|поправь|исправь)\\s*[:\\-—,]?\\s*([\\s\\S]+)$/i))) return await revisePlan(m[3].trim(), notify, m[1] || undefined);\n if ((m = t.match(/^(?:стоп план|отмени план|отменить план|останови план)\\s*№?\\s*(\\d+)?\\s*[.!]*$/i))) return await cancelPlan(m[1] || undefined);\n if (/^(штаб|план\\?|статус плана|как план)\\s*[?.!]*$/i.test(t)) return await hqStatus();\n if (/^(итог|итоги|штаб итог|сводка|что сделано|отчёт штаба|отчет штаба)\\s*[?.!]*$/i.test(t)) return `📋 Итог штаба\\n${await hqDigest(null, true)}`;\n if (/^(штаб авто|автопилот|автопилот вкл|штаб сам работай|штаб автопилот)\\s*[.!]*$/i.test(t)) return await setAutopilot(true);\n if (/^(штаб вручную|автопилот выкл|автопилот выключи|штаб спрашивай)\\s*[.!]*$/i.test(t)) return await setAutopilot(false);\n if ((m = t.match(/^штаб\\s*(?:параллельно|потоков|сессий)\\s*[:\\-—]?\\s*(\\d)\\s*[.!]*$/i))) return await setParallel(m[1]);\n if ((m = t.match(/^штаб\\s*модель\\s*[:\\-—]?\\s*([^\\n]{2,60})$/i))) return await setModel(m[1].trim());\n if ((m = t.match(/^шаг\\s*№?\\s*(\\d+)\\s*[:\\-—,]?\\s*(ок|окей|принято|принимаю|хорошо|годится|норм|да)\\s*[.!]*$/i))) return await stepOk(m[1], notify);\n if ((m = t.match(/^шаг\\s*№?\\s*(\\d+)\\s*[:\\-—,]?\\s*(делай|выполняй|выполни|отправляй|отправь|разрешаю|можно|запускай|плати|оплачивай)\\s*[.!]*$/i))) return await stepGo(m[1]);\n if ((m = t.match(/^(?:шаг\\s*№?\\s*(\\d+)\\s*[:\\-—,]?\\s*(?:отмени|отменить|убери|снять|сними)|(?:отмени|убери)\\s*шаг\\s*№?\\s*(\\d+))\\s*[.!]*$/i))) return await stepCancel(m[1] || m[2]);\n if ((m = t.match(/^шаг\\s*№?\\s*(\\d+)\\s*[:\\-—,]?\\s*(вверх|срочно|первым|наверх)\\s*[.!]*$/i))) return await stepMove(m[1], \"up\");\n if ((m = t.match(/^шаг\\s*№?\\s*(\\d+)\\s*[:\\-—,]?\\s*(вниз|в конец|потом|последним)\\s*[.!]*$/i))) return await stepMove(m[1], \"down\");\n if ((m = t.match(/^(?:план\\s*№?\\s*(\\d+)?\\s*)?(?:добавь|добавить|ещё шаг|еще шаг|новый шаг)\\s*(?:шаг)?\\s*[:\\-—,]\\s*([\\s\\S]+)$/i))) return await stepAdd(m[2].trim(), m[1] || undefined);\n // «план продолжи в [Проект]: что сделать» — шаг-продолжение последней сессии Claude Code в папке\n // проекта. Без слова «план» это поручение: уходит в очередь сразу (telegram.ts, CONTINUE_RE).\n if ((m = t.match(/^(?:план|шаг)\\s*[:,\\-—]?\\s*продолжи(?:ть)?\\s*(?:сессию|чат|работу)?\\s*(?:в|по)?\\s*\\[?([^\\]:\\-—]{2,60}?)\\]?\\s*[:\\-—]\\s*([\\s\\S]+)$/i))) return await stepAdd(`[${m[1].trim()}] ${m[2].trim()}`, undefined, true);\n if ((m = t.match(/^план\\s*№?\\s*(\\d+)?\\s*(?:перепланируй|перепланировать|пересобери|подумай заново)\\s*[.!]*$/i))) return await planReplan(m[1] || undefined);\n if ((m = t.match(/^план\\s*№?\\s*(\\d+)?\\s*(?:папка|проект)\\s*[:\\-—,]?\\s*([^\\n]{2,120})$/i))) return await planProject(m[2].trim(), m[1] || undefined);\n if ((m = t.match(/^план\\s*№?\\s*(\\d+)?\\s*(пауза|стой|подожди|приостанови)\\s*[.!]*$/i))) return await planPause(m[1] || undefined);\n if ((m = t.match(/^план\\s*№?\\s*(\\d+)?\\s*(продолжай|продолжить|дальше|возобнови)\\s*[.!]*$/i))) return await planResume(m[1] || undefined);\n if (/^(штаб\\s*(архив|чисто|очисти|уборка)|убери отменённые|убери отмененные|очисти штаб)\\s*[.!]*$/i.test(t)) return await archivePlans();\n if ((m = t.match(/^шаг\\s*№?\\s*(\\d+)\\s*[:\\-—,]?\\s*(прочитал|прочитано|прочёл|прочел|скрой|скрыть|убери с глаз)\\s*[.!]*$/i))) return await stepSeen(m[1]);\n if (/^(скрой прочитанное|скрыть прочитанное|прочитал всё|прочитал все|убери прочитанное|штаб чисти)\\s*[.!]*$/i.test(t)) return await seenAll();\n if (/^(покажи скрытое|верни скрытое|показать скрытое|покажи всё|покажи все)\\s*[.!]*$/i.test(t)) return await unseenAll();\n if (/^(штаб выжимки|выжимки|собери выжимки|итоги шагов)\\s*[.!]*$/i.test(t)) return await backfillBriefs();\n if ((m = t.match(/^шаг\\s*№?\\s*(\\d+)\\s*[:\\-—,]\\s*([\\s\\S]+)$/i))) return await stepRework(m[1], m[2].trim());\n return null;\n}\n\n// ---------- инструменты MCP ----------\n\n\nexport async function handleHqTools(name: string, args: any, text: (s: string) => any, notify: Notify) {\n if (name === \"hq_propose\") return text(await proposeSteps({ plan_id: args.plan_id, steps: args.steps, session_id: args.session_id }, notify));\n if (name === \"hq_report\") return text(await reportStep({ id: args.step_id, result: String(args.result ?? \"\"), session_id: args.session_id, failed: !!args.failed, needs_approval: !!args.needs_approval }, notify));\n if (name === \"hq_suggest\") return text(await suggestStep(args, notify));\n if (name === \"hq_status\") return text(await hqStatus());\n if (name === \"hq_today\") return text(await todoistToday());\n if (name === \"hq_draft\") return text(await planDraft({ plan_id: args.plan_id, text: String(args.text ?? \"\"), questions: args.questions, session_id: args.session_id }, notify));\n if (name === \"hq_data\") return text(JSON.stringify(await hqData()));\n if (name === \"hq_file\") {\n const f = await readFile({ id: args.id, path: args.path });\n return text(f ? JSON.stringify(f) : JSON.stringify({ error: \"документа нет: сторож ещё не отправил или файл не текстовый\" }));\n }\n if (name === \"hq_act\") {\n const id = args.id != null ? String(args.id) : undefined;\n const txt = String(args.text ?? \"\");\n switch (String(args.action)) {\n case \"approve\": return text(await approvePlan(notify, id));\n case \"revise\": return text(await revisePlan(txt, notify, id));\n case \"cancel\": return text(await cancelPlan(id));\n case \"pause\": return text(await planPause(id));\n case \"resume\": return text(await planResume(id));\n case \"step_ok\": return text(await stepOk(id ?? \"0\", notify));\n case \"step_go\": return text(await stepGo(id ?? \"0\"));\n case \"step_rework\": return text(await stepRework(id ?? \"0\", txt));\n case \"step_seen\": return text(await stepSeen(id ?? \"0\", args.on !== false));\n case \"seen_all\": return text(await seenAll());\n case \"unseen_all\": return text(await unseenAll());\n case \"briefs\": return text(await backfillBriefs(Number(args.id) || 5));\n case \"today\": return text(await todoistToday());\n case \"ask_answer\": return text(await askAnswer(id ?? \"0\", args.idx, txt, notify));\n case \"plan_answer\": return text(await planAnswer(id ?? \"0\", args.idx, txt));\n case \"say\": return text(await hqSay(txt, id, notify));\n case \"step_cancel\": return text(await stepCancel(id ?? \"0\"));\n case \"step_up\": return text(await stepMove(id ?? \"0\", \"up\"));\n case \"step_down\": return text(await stepMove(id ?? \"0\", \"down\"));\n case \"step_add\": return text(await stepAdd(txt, id, !!args.resume));\n case \"plan\": return text(await createPlan(txt, notify, !!args.force));\n case \"auto\": return text(await createPlan(AUTO_PLAN + \": по регулярным делам владельца\", notify));\n case \"archive\": return text(await archivePlans(id));\n case \"unarchive\": return text(await unarchivePlan(id ?? \"0\"));\n case \"open\": return text(await openChat(String(args.kind ?? \"step\"), id ?? \"0\", notify, args.path, txt));\n case \"digest\": return text(`📋 Итог штаба\\n${await hqDigest(null, true)}`);\n case \"autopilot_on\": return text(await setAutopilot(true));\n case \"autopilot_off\": return text(await setAutopilot(false));\n case \"project\": return text(await planProject(txt, id));\n case \"parallel\": return text(await setParallel(id ?? txt));\n case \"replan\": return text(await planReplan(id));\n case \"model\": return text(await setModel(txt));\n default: throw new Error(\"неизвестное действие\");\n }\n }\n return null;\n}\n\n// ---------- HTTP: сторож и страница ----------\n\nexport async function handleHqHttp(req: Request, url: URL, notify: Notify): Promise {\n if (!url.pathname.startsWith(\"/hq/\")) return null;\n if (url.searchParams.get(\"key\") !== env(\"GATEWAY_TOKEN\")) return json({ error: \"нужен ?key=GATEWAY_TOKEN\" }, 403);\n const p = url.pathname;\n if (p === \"/hq/ping\") {\n // Сторож бьётся сюда каждый круг (20 с) — даже когда все сессии заняты и работу он не просит.\n // Раньше пульс писал только /hq/next, и занятый тремя шагами сторож выглядел «не на связи».\n await setSetting(\"watcher_seen_at\", now());\n const jobs = Math.max(0, Number(url.searchParams.get(\"jobs\")) || 0);\n await setSetting(\"watcher_jobs\", String(jobs));\n // Штаб добирает выжимки к старым отчётам — по одной за круг сторожа, чтобы у\n // каждого шага был итог, а не полотно. Само иссякнет, когда доберёт все:\n // дальше это один быстрый запрос без обращения к модели.\n await backfillBriefs(3).catch(() => {});\n return json({ ok: true });\n }\n if (p === \"/hq/next\") {\n // Пульс сторожа: страница и «штаб» показывают, на связи ли компьютер.\n setSetting(\"watcher_seen_at\", now()).catch(() => {});\n const busy = (url.searchParams.get(\"busy\") ?? \"\").split(\"|\").filter(Boolean);\n const w = await claimNextWork(busy);\n // Владелец 9 сентября увидел 🔒-шаг в «выполняется» и испугался: «сейчас наделает».\n // Говорим сразу, что началась ПОДГОТОВКА, и чем она кончится.\n if (w && w.kind === \"step\" && w.approval && !w.permitted) {\n await notify(`🔒 Шаг №${w.id} · ${w.project || \"—\"} · ${short(w.title, 90)}\\nНачал ПОДГОТОВКУ: ничего не меняет и никому не пишет — соберёт точный список того, что предлагает сделать, и остановится. Когда закончит, пришлю список сюда, и только ваше «шаг ${w.id} делай» его запустит. Не нужно — «шаг ${w.id} отмени».`);\n }\n if (w) return json(w);\n // Сторожу работы нет — используем паузу: добираем выжимки к старым отчётам,\n // чтобы у каждого сделанного шага был итог, а не полотно. Иссякает само.\n await backfillBriefs(2).catch(() => {});\n return new Response(null, { status: 204 });\n }\n if (p === \"/hq/open\") { const o = await nextOpen(); return o ? json(o) : new Response(null, { status: 204 }); }\n if (p === \"/hq/release\") return json({ released: await releaseWork(url.searchParams.get(\"kind\") ?? \"step\", url.searchParams.get(\"id\") ?? \"0\") });\n if (p === \"/hq/report\" && req.method === \"POST\") {\n const b: any = await req.json().catch(() => ({}));\n if (b.kind === \"plan\") {\n // Планировщик не вызвал hq_propose. Первый раз — обратно в черновик (сторож\n // повторит), со второго — отменяем и говорим владельцу: крутить впустую нельзя.\n const plan = (await get(`${PLANS}?id=eq.${b.id}`))[0];\n if (!plan) return json({ error: \"нет такого плана\" }, 404);\n if (plan.status !== \"planning\") {\n // Сессия сама не знает своего id: сторож досылает его, чтобы правки шли в ту же сессию.\n if (b.session_id && plan.session_id !== b.session_id) await patch(`${PLANS}?id=eq.${b.id}`, { session_id: short(b.session_id, 80) });\n return json({ ok: true, note: `план уже «${plan.status}»` });\n }\n const attempts = Number(plan.attempts ?? 0) + 1;\n if (attempts >= 2) {\n await patch(`${PLANS}?id=eq.${b.id}`, { status: \"cancelled\", attempts, done_at: now() });\n await notify(`Штаб дважды не смог составить план №${b.id} — отменяю. Хвост вывода:\\n${short(b.result, 1500)}\\n\\nПопробуйте переформулировать: «план: …».`);\n return json({ ok: true, note: \"план отменён после двух неудач\" });\n }\n await patch(`${PLANS}?id=eq.${b.id}`, { status: \"draft\", taken_at: null, attempts });\n return json({ ok: true, note: \"план возвращён в черновик, будет вторая попытка\" });\n }\n if (b.kind === \"step\") {\n const st = (await get(`${STEPS}?id=eq.${b.id}&select=id,status,session_id`))[0];\n if (st && st.status !== \"running\") {\n if (b.session_id && st.session_id !== b.session_id) await patch(`${STEPS}?id=eq.${b.id}`, { session_id: short(b.session_id, 80) });\n return json({ ok: true, note: `шаг уже «${st.status}»` });\n }\n }\n return json({ ok: true, note: await reportStep({ id: b.id, result: String(b.result ?? \"\"), session_id: b.session_id, failed: !!b.failed, needs_approval: !!b.needs_approval }, notify) });\n }\n if (p === \"/hq/session-note\" && req.method === \"POST\") {\n // Сторож сообщает, какую сессию Claude Code продолжит (или почему не сможет):\n // заранее — в сводку (без уведомления), при запуске — владельцу в Telegram.\n const b: any = await req.json().catch(() => ({}));\n const note = short(String(b.note ?? \"\"), 300);\n if (!note) return json({ error: \"нужен note\" }, 400);\n // Сторож перед открытием чата владельцу ответвляет сессию (--fork-session): дальше шаг живёт в новой.\n const sid = b.session_id && /^[0-9a-f-]{20,60}$/i.test(String(b.session_id)) ? String(b.session_id) : null;\n if (b.kind === \"step\") await patch(`${STEPS}?id=eq.${b.id}`, sid ? { session_note: note, session_id: sid } : { session_note: note });\n else if (b.kind === \"plan\" && sid) await patch(`${PLANS}?id=eq.${b.id}`, { session_id: sid });\n if (b.notify) await notify(`↪ ${b.kind === \"step\" ? `Шаг №${b.id}` : `Поручение №${b.id}`}: ${note}`);\n return json({ ok: true });\n }\n if (p === \"/hq/pending-resume\") {\n // Шаги-продолжения, для которых сторож ещё не определил сессию.\n const rows = await get(`${STEPS}?session_id=not.is.null&session_note=is.null&status=in.(waiting,queued)&select=id,project,title,instruction,session_id&limit=20`);\n return json(rows);\n }\n if (p === \"/hq/item\") {\n const id = url.searchParams.get(\"id\") ?? \"0\";\n const rows = url.searchParams.get(\"kind\") === \"plan\"\n ? await get(`${PLANS}?id=eq.${id}&select=id,status,attempts,session_id`)\n : await get(`${STEPS}?id=eq.${id}&select=id,status,attempts,session_id,checkpoint,approval,permitted,result`);\n if (rows[0] && rows[0].result !== undefined) rows[0].files = filesOf(rows[0].result);\n return rows[0] ? json(rows[0]) : json({ error: \"нет\" }, 404);\n }\n if (p === \"/hq/file\" && req.method === \"POST\") {\n // Сторож отправляет текстовый документ результата (md/txt) — страница покажет его в приложении.\n const b: any = await req.json().catch(() => ({}));\n try { return json({ ok: true, ...(await storeFile({ step_id: b.step_id, path: String(b.path ?? \"\"), content: String(b.content ?? \"\") })) }); }\n catch (e) { return json({ error: String((e as Error).message ?? e) }, 400); }\n }\n if (p === \"/hq/files\") return json(await listFiles(120));\n if (p === \"/hq/pending-docs\") {\n // Текстовые файлы из отчётов закрытых шагов за 3 дня, которых ещё нет в хранилище, — сторож дошлёт.\n const since = new Date(Date.now() - 3 * 24 * 3600 * 1000).toISOString();\n const steps = await get(`${STEPS}?status=in.(done,review,failed)&result_at=gt.${encodeURIComponent(since)}&select=id,result&order=result_at.desc&limit=80`);\n const have = new Set((await listFiles(300)).map((f) => f.path));\n const out: any[] = [];\n for (const st of steps) for (const path of filesOf(st.result)) if (/\\.(md|txt|markdown|csv|json|py|ps1|ts|tsx|js|mjs|sql|html|yml|yaml|docx)$/i.test(path) && !have.has(path)) out.push({ step_id: st.id, path });\n return json(out.slice(0, 40));\n }\n if (p === \"/hq/data\") {\n const plans = url.searchParams.get(\"all\") === \"1\"\n ? await get(`${PLANS}?order=at.desc&limit=40`)\n : await get(`${PLANS}?archived=eq.false&order=at.desc&limit=15`);\n const ids = plans.map((x) => x.id).join(\",\");\n const steps = ids ? await get(`${STEPS}?plan_id=in.(${ids})&order=plan_id.desc,ord.asc`) : [];\n for (const s of steps) s.files = filesOf(s.result);\n return json({ plans, steps, now: now(), autopilot: await autopilot(), feed: await feedRecent() });\n }\n if (p === \"/hq/act\" && req.method === \"POST\") {\n const b: any = await req.json().catch(() => ({}));\n let msg = \"\";\n try {\n if (b.action === \"dialog\") msg = (await hqDialog(String(b.text ?? \"\").trim(), notify, \"hq-page\", true)) ?? \"Штаб не понял. Переформулируйте или нажмите кнопку.\";\n else if (b.action === \"plan\") msg = await createPlan(String(b.text ?? \"\").trim(), notify, !!b.force);\n else if (b.action === \"approve\") msg = await approvePlan(notify, b.id);\n else if (b.action === \"revise\") msg = await revisePlan(String(b.text ?? \"\"), notify, b.id);\n else if (b.action === \"cancel\") msg = await cancelPlan(b.id);\n else if (b.action === \"step_ok\") msg = await stepOk(b.id, notify);\n else if (b.action === \"step_rework\") msg = await stepRework(b.id, String(b.text ?? \"\"));\n else if (b.action === \"step_go\") msg = await stepGo(b.id);\n else if (b.action === \"step_cancel\") msg = await stepCancel(b.id);\n else if (b.action === \"step_up\") msg = await stepMove(b.id, \"up\");\n else if (b.action === \"step_down\") msg = await stepMove(b.id, \"down\");\n else if (b.action === \"step_add\") msg = await stepAdd(String(b.text ?? \"\"), b.id);\n else if (b.action === \"pause\") msg = await planPause(b.id);\n else if (b.action === \"resume\") msg = await planResume(b.id);\n else if (b.action === \"archive\") msg = await archivePlans(b.id);\n else if (b.action === \"unarchive\") msg = await unarchivePlan(b.id);\n else if (b.action === \"open\") msg = await openChat(String(b.kind ?? \"step\"), b.id, notify, b.path, b.text);\n else if (b.action === \"auto\") msg = await createPlan(AUTO_PLAN + \": по регулярным делам владельца\", notify);\n else if (b.action === \"digest\") msg = b.force ? `📋 Итог штаба\\n${await hqDigest(null, true)}` : ((await hqDigest(notify, false)) ? \"Итог отправлен в Telegram.\" : \"Нового с прошлого итога нет.\");\n else if (b.action === \"autopilot_on\") msg = await setAutopilot(true);\n else if (b.action === \"autopilot_off\") msg = await setAutopilot(false);\n else if (b.action === \"project\") msg = await planProject(String(b.text ?? \"\"), b.id);\n else if (b.action === \"parallel\") msg = await setParallel(b.id ?? b.text);\n else if (b.action === \"replan\") msg = await planReplan(b.id);\n else if (b.action === \"model\") msg = await setModel(String(b.text ?? \"\"));\n else if (b.action === \"step_seen\") msg = await stepSeen(b.id, b.on !== false);\n else if (b.action === \"seen_all\") msg = await seenAll();\n else if (b.action === \"unseen_all\") msg = await unseenAll();\n else if (b.action === \"briefs\") msg = await backfillBriefs(Number(b.id) || 5);\n else if (b.action === \"ask_answer\") msg = await askAnswer(b.id, b.idx, String(b.text ?? \"\"), notify);\n else if (b.action === \"plan_answer\") msg = await planAnswer(b.id, b.idx, String(b.text ?? \"\"));\n else if (b.action === \"say\") msg = await hqSay(String(b.text ?? \"\"), b.id, notify);\n else return json({ error: \"неизвестное действие\" }, 400);\n } catch (e) {\n return json({ error: String((e as Error).message ?? e) }, 500);\n }\n return json({ ok: true, message: msg });\n }\n return json({ error: \"нет такого пути\" }, 404);\n}\n","deleted",false,"label",[14],"f04cc041-3bf4-4db7-a7ca-6638165c8d3d",["D",1785495035570],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","MCP gateway to external LLM providers","imageUrl","userId","ce244983-5dfc-4662-ad1a-ca34d2e798a0","pinnedFileId","bfdf3532-8cce-11f1-80cf-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa853-4d22-71bf-b5fe-af55df9678e6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_103":99},"org",{"_9":10,"_96":97,"_98":99,"_55":56,"_100":101,"_102":42},"branch",{"_36":86,"_11":87,"_23":29,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":12,"_95":10},"isOwned",291,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","umgroupkz-commits","avatar","https://avatars.githubusercontent.com/u/279207781?v=4","tier","free","canRestrictVals","profileImageUrl","ctx",{"_79":-5,"_137":138,"_139":140,"_141":142,"_143":42,"_144":42,"_145":42,"_146":33,"_147":-5,"_148":-7,"_149":-7,"_150":63,"_151":42,"_152":42,"_153":-5,"_154":42,"_155":42,"_156":42,"_157":-5},"ENV",{"_108":109,"_110":111,"_112":87,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]