Ссылка панели изменилась

` +\n `

Старый адрес содержал главный токен шлюза, и держать его в закладке опасно. ` +\n `Новый адрес открывает панель только на чтение:

` +\n `

${url.origin}${fresh}

` +\n `

Сохраните его в закладки вместо этой страницы. Сейчас перейдём сами.

`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\", \"Cache-Control\": \"no-store\" } },\n );\n }\n\n if (given !== (await panelToken(token))) {\n return new Response(\"Неверный токен\", { status: 401 });\n }\n\n if (m[2]) {\n const hours = Math.min(\n 720,\n Math.max(1, Number(url.searchParams.get(\"hours\") ?? 24)),\n );\n const data = await collect(hours);\n return new Response(JSON.stringify(data), {\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n \"Cache-Control\": \"no-store\",\n },\n });\n }\n\n return new Response(PANEL_PAGE, {\n headers: {\n \"Content-Type\": \"text/html; charset=utf-8\",\n \"Cache-Control\": \"no-store\",\n },\n });\n}\n",[193],"beba0773-67c1-4cc5-b677-27a4bdf27205","panel-page.ts","88584514-8db3-11f1-a6cc-1607ee4eb77e",100,["D",1785755714688],"// Разметка панели вынесена отдельным файлом: страница разрослась до пяти видов,\n// а main.tsx и без неё упирается в предел Val Town в 80 000 символов.\n//\n// Пять видов отвечают на пять разных вопросов, и смешивать их в один экран нельзя:\n// «нужно ли вмешаться» (пульт), «кто чем занят прямо сейчас» (бригада), «что у меня\n// есть» (схема), «как идут проекты» (проекты), «почему это заняло столько» (разбор\n// задачи). Пульт стоит первым намеренно: внимание дорого, и когда всё хорошо, экран\n// пуст. Бригада — наоборот, экран для наблюдения за идущей работой, и смотреть в неё\n// имеет смысл только пока работа идёт.\n\nexport const PANEL_PAGE = String.raw`\n\n\n\nАгентская сеть\n

Агентская сеть

Загружаю…

\n\n

Пульт

Бригада

Исполнители

Проекты

Схема

Лента

\n\n

\n \n \n

\n\n

Идёт сейчас

\n\n

Данные из журнала шлюза: инструмент, исполнитель, длительность, токены, стоимость\nи пометка «зачем». Тексты запросов и ответов не хранятся намеренно — в них рабочие данные клиентов.

\n`;\n",[201],"c5bba2aa-c8a9-4e26-90e4-4a98b0f29ee5",["D",1787240994007],[27],"c26141e6-57fd-4a77-a2e2-1f1574174834","modal.ts","6dcb7274-8d9b-11f1-bb02-1607ee4eb77e",119,["D",1786986739829],"// Не только текст: расшифровка речи, распознавание документов, поиск по смыслу.\n//\n// Всё это живёт на других эндпоинтах, а не в /chat/completions, поэтому через\n// callProvider не проходит. Ключи те же самые — доступ был всё время, просто\n// шлюз умел разговаривать только одним способом.\n//\n// Вынесено из main.tsx: Val Town не принимает файл длиннее 80 000 символов.\n\nimport { baseOf, env, providerById } from \"./main.tsx\";\n\n// Предел берём ровно такой, как у Groq на бесплатном тарифе — 25 МБ. Запас\n// «для надёжности» здесь вредит: 17 августа пятидесятиминутная запись на 24,5 МБ\n// получила отказ на нашей же проверке, хотя Groq её бы взял.\nconst MAX_FILE_BYTES = 25 * 1024 * 1024;\n\n/** Забирает файл по ссылке или из base64 и отдаёт байтами с ограничением размера. */\nasync function fetchBinary(a: { url?: string; base64?: string }): Promise<{ bytes: Uint8Array; name: string }> {\n if (a.base64) {\n const clean = a.base64.replace(/^data:[^;]+;base64,/, \"\");\n const bin = atob(clean);\n const u = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) u[i] = bin.charCodeAt(i);\n if (u.length > MAX_FILE_BYTES) throw new Error(`Файл больше ${MAX_FILE_BYTES / 1024 / 1024} МБ`);\n return { bytes: u, name: \"upload.bin\" };\n }\n if (!a.url) throw new Error(\"Нужен либо url, либо base64\");\n const r = await fetch(a.url);\n if (!r.ok) throw new Error(`Не удалось скачать файл: ${r.status}`);\n const buf = new Uint8Array(await r.arrayBuffer());\n if (buf.length > MAX_FILE_BYTES) {\n throw new Error(\n `Файл ${(buf.length / 1024 / 1024).toFixed(1)} МБ, а предел ${MAX_FILE_BYTES / 1024 / 1024} МБ. ` +\n \"Длинную запись нужно резать на части.\",\n );\n }\n const name = (a.url.split(\"?\")[0].split(\"/\").pop() || \"audio\").slice(0, 80);\n return { bytes: buf, name: name.includes(\".\") ? name : name + \".mp3\" };\n}\n\n// Вторая линия расшифровки должна быть НЕ realtime-моделью. Замер 17 августа:\n// все шесть попыток запаса за август упирались в один и тот же отказ Mistral —\n// «voxtral-mini-transcribe-realtime-2602 only supports realtime transcription».\n// То есть запаса не было вовсе: когда groq не брал файл, падало всё.\nconst TRANSCRIBE_MODELS: Record = {\n groq: \"whisper-large-v3-turbo\",\n mistral: \"voxtral-mini-latest\",\n};\n\nexport async function transcribe(a: {\n url?: string; base64?: string; provider?: string; model?: string; language?: string; prompt?: string;\n}): Promise<{ text: string; provider: string; model: string; bytes: number }> {\n const order = a.provider ? [a.provider] : [\"groq\", \"mistral\"];\n const errors: string[] = [];\n const file = await fetchBinary(a);\n\n for (const id of order) {\n const p = providerById(id);\n if (!p) { errors.push(`неизвестный провайдер ${id}`); continue; }\n const key = env(p.keyEnv);\n if (!key) { errors.push(`${id}: нет ключа ${p.keyEnv}`); continue; }\n const model = a.model || TRANSCRIBE_MODELS[id];\n if (!model) { errors.push(`${id}: не умеет расшифровку`); continue; }\n\n const form = new FormData();\n form.append(\"file\", new Blob([file.bytes]), file.name);\n form.append(\"model\", model);\n form.append(\"response_format\", \"json\");\n if (a.language) form.append(\"language\", a.language);\n if (a.prompt) form.append(\"prompt\", a.prompt);\n\n try {\n const res = await fetch(`${baseOf(p)}/audio/transcriptions`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${key}` },\n body: form,\n });\n if (!res.ok) throw new Error(`${id} вернул ${res.status}: ${(await res.text()).slice(0, 300)}`);\n const j: any = await res.json();\n const text = j?.text ?? \"\";\n if (!text) throw new Error(`${id} вернул пустую расшифровку`);\n return { text, provider: id, model, bytes: file.bytes.length };\n } catch (e: any) {\n errors.push(String(e?.message || e));\n }\n }\n throw new Error(`Расшифровка не удалась:\\n- ${errors.join(\"\\n- \")}`);\n}\n\nexport async function readDocument(a: { url: string; model?: string }): Promise<{ text: string; pages: number }> {\n const p = providerById(\"mistral\");\n const key = p && env(p.keyEnv);\n if (!p || !key) throw new Error(\"Распознавание документов идёт через Mistral: нет ключа MISTRAL_API_KEY\");\n\n const isImage = /\\.(png|jpe?g|webp|gif|bmp|tiff?)($|\\?)/i.test(a.url);\n const res = await fetch(`${baseOf(p)}/ocr`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${key}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n model: a.model || \"mistral-ocr-latest\",\n document: isImage\n ? { type: \"image_url\", image_url: a.url }\n : { type: \"document_url\", document_url: a.url },\n table_format: \"html\",\n }),\n });\n if (!res.ok) throw new Error(`mistral /ocr вернул ${res.status}: ${(await res.text()).slice(0, 400)}`);\n const j: any = await res.json();\n const pages = Array.isArray(j?.pages) ? j.pages : [];\n const text = pages.map((x: any) => x?.markdown ?? \"\").join(\"\\n\\n---\\n\\n\").trim();\n if (!text) throw new Error(`mistral вернул пустой текст: ${JSON.stringify(j).slice(0, 300)}`);\n return { text, pages: pages.length };\n}\n\nexport const EMBED_MODELS: Record = {\n gemini: \"gemini-embedding-2\",\n mistral: \"mistral-embed\",\n};\n\nexport async function embed(id: string, model: string, input: string[]): Promise {\n const p = providerById(id)!;\n const key = env(p.keyEnv)!;\n const res = await fetch(`${baseOf(p)}/embeddings`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${key}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ model, input }),\n });\n if (!res.ok) throw new Error(`${id} вернул ${res.status}: ${(await res.text()).slice(0, 300)}`);\n const j: any = await res.json();\n const rows = (j?.data ?? []).map((d: any) => d?.embedding).filter(Array.isArray);\n if (rows.length !== input.length) throw new Error(`${id} вернул ${rows.length} векторов вместо ${input.length}`);\n return rows;\n}\n\nfunction cosine(a: number[], b: number[]): number {\n let dot = 0, na = 0, nb = 0;\n for (let i = 0; i < a.length; i++) { dot += a[i] * b[i]; na += a[i] * a[i]; nb += b[i] * b[i]; }\n const d = Math.sqrt(na) * Math.sqrt(nb);\n return d === 0 ? 0 : dot / d;\n}\n\n/**\n * Векторы наружу не отдаём намеренно: сотня документов это сотни тысяч чисел,\n * они забьют контекст и не дадут ничего полезного. Сравнение делаем здесь,\n * возвращаем только порядок и близость.\n */\nexport async function rankByMeaning(a: {\n query: string; items: Array<{ id: string; text: string }>; provider?: string; model?: string; top?: number;\n}): Promise<{ provider: string; model: string; ranked: Array<{ id: string; score: number; preview: string }> }> {\n const order = a.provider ? [a.provider] : [\"gemini\", \"mistral\"];\n const errors: string[] = [];\n\n for (const id of order) {\n const p = providerById(id);\n if (!p || !env(p.keyEnv)) { errors.push(`${id}: не настроен`); continue; }\n const model = a.model || EMBED_MODELS[id];\n if (!model) { errors.push(`${id}: не умеет эмбеддинги`); continue; }\n try {\n const vecs = await embed(id, model, [a.query, ...a.items.map((x) => x.text)]);\n const q = vecs[0];\n const ranked = a.items\n .map((it, i) => ({\n id: it.id,\n score: Number(cosine(q, vecs[i + 1]).toFixed(4)),\n preview: it.text.replace(/\\s+/g, \" \").slice(0, 120),\n }))\n .sort((x, y) => y.score - x.score)\n .slice(0, a.top ?? 20);\n return { provider: id, model, ranked };\n } catch (e: any) {\n errors.push(String(e?.message || e));\n }\n }\n throw new Error(`Поиск по смыслу не удался:\\n- ${errors.join(\"\\n- \")}`);\n}\n",[211],"fd90d3ae-a804-43c7-99b1-b78307be7938","memory.ts","73c3f8f8-8dab-11f1-80bc-1607ee4eb77e",104,["D",1785770151730],"// Долговременная память: решения, факты, договорённости.\n//\n// Встроенная память Claude для этой организации отключена, поэтому знание о том,\n// что уже решено и почему, держалось в файлах и карточках вручную. Здесь оно\n// становится инструментом: записать и найти по смыслу с любого устройства.\n//\n// Два решения, принятых осознанно и отличающих это от готовых библиотек памяти.\n//\n// Первое: не пишем стенограмму. Дословная запись каждой реплики — это гора шума,\n// в которой тонет главное, и лишний риск с чувствительными данными. Пишем то,\n// к чему потом возвращаются: решения, проверенные факты, договорённости,\n// предпочтения. Отбор делает тот, кто записывает, и это правильное место для отбора.\n//\n// Второе: ничего не переводим. Эмбеддинги у нас многоязычные, русский и казахский\n// ложатся в тот же индекс, что английский. Перевод по дороге в память — потеря\n// смысла на каждом шаге, особенно на казахском.\n//\n// Сравнение векторов делает Postgres, а не шлюз: наружу уходит только результат,\n// а не сотни тысяч чисел, и не надо тянуть таблицу в память вала.\n\nimport { env } from \"./main.tsx\";\nimport { embed, EMBED_MODELS } from \"./modal.ts\";\nimport { CANON } from \"./canon.ts\";\n\n/** Подпись под ответом recall: дорога к своду правил из любой сессии. */\nconst CANON_HINT =\n \"\\n\\n—\\nДействующий свод правил сети: инструмент `rules`. Если его нет в списке\" +\n \" инструментов, значит сессия открыта раньше, чем он появился, — тогда вызовите\" +\n \" recall с запросом «правила сети», и свод придёт целиком.\";\n\nconst TABLE = \"gateway_memory\";\nconst KINDS = [\"решение\", \"факт\", \"договорённость\", \"предпочтение\", \"контакт\"];\n\nfunction db(): { url: string; key: string } {\n const url = env(\"SUPABASE_URL\");\n const key = env(\"SUPABASE_SERVICE_KEY\");\n if (!url || !key) {\n throw new Error(\n \"Память живёт в Supabase, а переменные SUPABASE_URL и SUPABASE_SERVICE_KEY не заданы.\",\n );\n }\n return { url: url.replace(/\\/+$/, \"\"), key };\n}\n\nfunction headers(key: string, extra: Record = {}) {\n return {\n apikey: key,\n Authorization: `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n ...extra,\n };\n}\n\n/**\n * Вектор для текста и модель, которой он посчитан. Порядок тот же, что у поиска\n * по смыслу: сначала Gemini, при отказе Mistral. Оба бесплатны и многоязычны.\n *\n * Модель возвращается вместе с вектором и хранится рядом с записью. Это не\n * формальность: у разных моделей разные пространства и разная длина вектора,\n * и сравнение записи от Gemini с запросом от Mistral даёт правдоподобный,\n * но бессмысленный результат. Поэтому поиск всегда идёт внутри одной модели.\n */\nasync function vectorFor(\n text: string,\n): Promise<{ vec: number[]; model: string }> {\n const errors: string[] = [];\n for (const id of [\"gemini\", \"mistral\"]) {\n const model = EMBED_MODELS[id];\n if (!model) continue;\n try {\n const [v] = await embed(id, model, [text]);\n if (!Array.isArray(v) || !v.length) throw new Error(\"пустой вектор\");\n return { vec: v, model: `${id}/${model}` };\n } catch (e: any) {\n errors.push(`${id}: ${String(e?.message || e).slice(0, 200)}`);\n }\n }\n throw new Error(`Не удалось получить вектор:\\n- ${errors.join(\"\\n- \")}`);\n}\n\nexport const MEMORY_TOOLS = [\n {\n name: \"remember\",\n description:\n \"Записать в долговременную память то, к чему потом возвращаются: принятое решение \" +\n \"и его причину, проверенный факт, договорённость с клиентом или подрядчиком, \" +\n \"предпочтение пользователя. Память общая для всех задач и доступна с любого устройства. \" +\n \"НЕ записывайте сюда стенограмму разговора, черновики и промежуточные рассуждения — \" +\n \"шум делает поиск бесполезным. Не записывайте пароли, ключи и токены. Формулируйте \" +\n \"так, чтобы через полгода было понятно без контекста: не «договорились как обсуждали», \" +\n \"а «клиент X платит помесячно, счёт выставляем пятого числа». Язык любой: русский, \" +\n \"казахский и английский ложатся в один индекс без перевода.\",\n inputSchema: {\n type: \"object\",\n properties: {\n text: {\n type: \"string\",\n description:\n \"Что запомнить. Одна мысль на запись, самодостаточная формулировка.\",\n },\n kind: {\n type: \"string\",\n enum: KINDS,\n description: \"Вид записи. По умолчанию «факт».\",\n },\n tags: {\n type: \"array\",\n items: { type: \"string\" },\n description:\n \"Метки для отбора: имя клиента, проект, услуга. По ним можно сузить поиск.\",\n },\n source: {\n type: \"string\",\n description: \"Откуда это известно: письмо, звонок, документ, замер.\",\n },\n project: {\n type: \"string\",\n description:\n \"Проект или клиент, к работе над которым относится вызов. Заполняйте: \" +\n \"по этому полю панель собирает карточку проекта, и без него работа \" +\n \"с памятью не видна в отчётах — выглядит так, будто сети не пользовались.\",\n },\n },\n required: [\"text\"],\n },\n },\n {\n name: \"recall\",\n description:\n \"Найти в долговременной памяти по смыслу, а не по точным словам: запрос «как платит \" +\n \"такой-то клиент» найдёт запись про помесячные счета, даже если слова другие. \" +\n \"Вызывайте в начале работы над темой, которая уже обсуждалась раньше, и всякий раз, \" +\n \"когда пользователь ссылается на прошлые договорённости. Возвращает записи с оценкой \" +\n \"близости: чем ближе к единице, тем вернее попадание. Если ничего похожего нет, \" +\n \"так и скажет — выдумывать содержимое памяти нельзя.\",\n inputSchema: {\n type: \"object\",\n properties: {\n query: { type: \"string\", description: \"О чём вспоминаем.\" },\n top: {\n type: \"number\",\n description: \"Сколько записей вернуть. По умолчанию 8.\",\n },\n kind: {\n type: \"string\",\n enum: KINDS,\n description: \"Ограничить видом записи.\",\n },\n tag: { type: \"string\", description: \"Ограничить одной меткой.\" },\n project: {\n type: \"string\",\n description:\n \"Проект или клиент, к работе над которым относится вызов. Заполняйте: \" +\n \"по этому полю панель собирает карточку проекта, и без него работа \" +\n \"с памятью не видна в отчётах — выглядит так, будто сети не пользовались.\",\n },\n },\n required: [\"query\"],\n },\n },\n {\n name: \"forget\",\n description:\n \"Удалить запись из памяти по её номеру. Нужно, когда договорённость отменена или \" +\n \"факт оказался неверным: устаревшая запись хуже отсутствующей, потому что ей верят. \" +\n \"Номер берётся из выдачи recall.\",\n inputSchema: {\n type: \"object\",\n properties: {\n id: { type: \"number\", description: \"Номер записи из recall.\" },\n },\n required: [\"id\"],\n },\n },\n];\n\nexport async function handleMemory(\n name: string,\n args: any,\n text: (s: string) => any,\n) {\n if (name === \"remember\") {\n if (!args?.text) throw new Error(\"Обязательный параметр: text\");\n const sb = db();\n const { vec, model } = await vectorFor(args.text);\n const row = {\n text: args.text,\n kind: args.kind && KINDS.includes(args.kind) ? args.kind : \"факт\",\n tags: Array.isArray(args.tags) ? args.tags : [],\n source: args.source ?? null,\n embed_model: model,\n embedding: vec,\n };\n const r = await fetch(`${sb.url}/rest/v1/${TABLE}`, {\n method: \"POST\",\n headers: headers(sb.key, { Prefer: \"return=representation\" }),\n body: JSON.stringify(row),\n });\n if (!r.ok) {\n throw new Error(\n `Supabase не принял запись, ${r.status}: ${(await r.text()).slice(0, 200)}`,\n );\n }\n const saved = (await r.json())[0];\n return text(\n `Запомнено под номером ${saved?.id}: «${row.text}»\\nВид: ${row.kind}` +\n (row.tags.length ? `, метки: ${row.tags.join(\", \")}` : \"\") +\n (row.source ? `\\nИсточник: ${row.source}` : \"\"),\n );\n }\n\n if (name === \"recall\") {\n if (!args?.query) throw new Error(\"Обязательный параметр: query\");\n\n // Свод правил достаётся и отсюда — намеренно, это запасной вход.\n // Новый инструмент в уже открытой сессии не появляется: список инструментов\n // клиент запрашивает один раз при подключении, поэтому `rules`, добавленный\n // позже, чужим и старым сессиям невиден. Recall же есть у всех давно, и свод\n // через него достижим везде. Отсюда же подпись в конце любого ответа: она\n // показывает дорогу к правилам тому, кто о них не знал.\n const wantsCanon = /правил|свод|канон|регламент|\\brules\\b/i.test(String(args.query));\n\n const sb = db();\n const { vec, model } = await vectorFor(args.query);\n const r = await fetch(`${sb.url}/rest/v1/rpc/recall_memory`, {\n method: \"POST\",\n headers: headers(sb.key),\n body: JSON.stringify({\n query_embedding: vec,\n query_model: model,\n match_count: Number(args.top ?? 8),\n filter_kind: args.kind ?? null,\n filter_tag: args.tag ?? null,\n }),\n });\n if (!r.ok) {\n throw new Error(\n `Supabase не выполнил поиск, ${r.status}: ${(await r.text()).slice(0, 200)}`,\n );\n }\n const rows: any[] = await r.json();\n if (!rows.length) {\n return text(\n (wantsCanon ? CANON + \"\\n\\n---\\n\\n\" : \"\") +\n \"В памяти ничего похожего нет.\" +\n \" Учтите: поиск идёт только по записям, посчитанным той же моделью эмбеддингов\" +\n ` (сейчас ${model}).` +\n (args.kind || args.tag\n ? \" Возможно, мешает ограничение по виду или метке.\"\n : \"\") +\n \" Не додумывайте содержимое памяти: пустой ответ означает именно пустоту.\" +\n CANON_HINT,\n );\n }\n const lines = rows.map(\n (m) =>\n `[${m.id}] ${Number(m.score).toFixed(3)} · ${m.kind}` +\n (m.tags?.length ? ` · ${m.tags.join(\", \")}` : \"\") +\n `\\n${m.text}` +\n (m.source ? `\\nисточник: ${m.source}` : \"\") +\n `\\nзаписано: ${String(m.at).slice(0, 10)}`,\n );\n return text(\n (wantsCanon ? CANON + \"\\n\\n---\\n\\n\" : \"\") +\n `Найдено записей: ${rows.length}. Чем ближе оценка к единице, тем вернее попадание.\\n\\n` +\n lines.join(\"\\n\\n\") +\n CANON_HINT,\n );\n }\n\n if (name !== \"forget\") return null;\n if (args?.id == null) throw new Error(\"Обязательный параметр: id\");\n const sb = db();\n const r = await fetch(\n `${sb.url}/rest/v1/${TABLE}?id=eq.${encodeURIComponent(String(args.id))}`,\n {\n method: \"DELETE\",\n headers: headers(sb.key, { Prefer: \"return=representation\" }),\n },\n );\n if (!r.ok) {\n throw new Error(\n `Supabase не удалил запись, ${r.status}: ${(await r.text()).slice(0, 200)}`,\n );\n }\n const gone = await r.json();\n if (!gone.length) {\n return text(`Записи с номером ${args.id} нет — возможно, её уже удалили.`);\n }\n return text(`Удалено: «${gone[0].text}»`);\n}\n",[218],"14ec798b-1a63-4d7b-95c1-865d0c1b3a32","main.tsx",123,["D",1787237457941],59,"http","/**\n * AI Gateway — удалённый MCP-сервер для делегирования задач внешним нейросетям.\n *\n * Деплой: Val Town (HTTP val). Работает на любом рантайме с fetch/Response.\n * Транспорт: MCP Streamable HTTP (JSON-RPC 2.0 поверх POST).\n *\n * Секреты (Val Town → Settings → Secrets):\n * GATEWAY_TOKEN — обязательный. Любая длинная случайная строка. Защищает эндпоинт.\n * OPENROUTER_API_KEY — опционально\n * GROQ_API_KEY — опционально\n * CEREBRAS_API_KEY — опционально\n * GEMINI_API_KEY — опционально\n * MISTRAL_API_KEY — опционально\n * Достаточно хотя бы одного ключа провайдера.\n *\n * Подключение в Claude: claude.ai → Settings → Connectors → Add custom connector\n * URL: https://<ваш-val>.val.run/mcp/\n */\n\nimport type { Provider } from \"./providers.ts\";\nimport {\n availableProviders,\n baseOf,\n env,\n FALLBACK_ORDER,\n PAID_ORDER,\n PREMIUM_ONLY,\n providerById,\n PROVIDERS,\n} from \"./providers.ts\";\nimport { CORE_TOOLS, TAIL_TOOLS } from \"./tools.ts\";\nexport { baseOf, env, providerById, PROVIDERS };\n\n// ---------------------------------------------------------------------------\n// Вызов модели\n// ---------------------------------------------------------------------------\n\ninterface AskArgs {\n prompt: string;\n system?: string;\n provider?: string;\n model?: string;\n tier?: \"fast\" | \"smart\" | \"long\";\n max_tokens?: number;\n temperature?: number;\n /** Разрешить платных провайдеров при автоподборе. По умолчанию false. */\n allow_paid?: boolean;\n /** Дополнительные поля тела запроса, специфичные для провайдера. */\n extra?: Record;\n}\n\ninterface AskResult {\n text: string;\n provider: string;\n model: string;\n usage?: Record;\n /** Заполнено, если названного провайдера подменили: текст для человека. */\n substituted?: string;\n}\n\nconst TIMEOUT_MS = 120_000;\nconst MAX_ATTEMPTS = 3;\n\n/** Ошибка, которую нельзя лечить повтором: тот же запрос даст тот же отказ. */\nfunction noRetry(msg: string): Error {\n const e: any = new Error(msg);\n e.noRetry = true;\n return e;\n}\n\n/**\n * Текст из ответа эндпоинта /responses. Берём ПОСЛЕДНЕЕ сообщение, а не склейку:\n * модель пишет промежуточные реплики, и склейка выдала бы пользователю ход\n * рассуждений вместо ответа.\n */\nfunction responsesText(json: any): string {\n let text = \"\";\n if (Array.isArray(json?.output)) {\n const said: string[] = [];\n for (const item of json.output) {\n if (item?.type && item.type !== \"message\") continue;\n const content = item?.content;\n if (!Array.isArray(content)) continue;\n const parts: string[] = [];\n for (const c of content) {\n if (typeof c?.text === \"string\" && c.text) parts.push(c.text);\n }\n if (parts.length) said.push(parts.join(\"\\n\"));\n }\n text = (said.at(-1) || \"\").trim();\n }\n if (!text && typeof json?.output_text === \"string\") {\n text = json.output_text.trim();\n }\n return text;\n}\n\n/**\n * Вызов модели на /responses с приведением ответа к форме /chat/completions.\n *\n * Линейка codex и часть новых моделей OpenAI на /chat/completions отвечают 404\n * и прямо пишут, куда идти. Приведение к привычной форме сделано намеренно:\n * так журнал, учёт расходов и разбор ответа выше по коду не знают о различии\n * протоколов и не обрастают ветвлениями.\n *\n * temperature сюда НЕ передаётся: рассуждающие модели принимают только значение\n * по умолчанию и на 0 отвечают отказом, а тише промолчать и выдать ответ здесь\n * полезнее, чем воспроизвести детерминизм ценой сбоя.\n */\nasync function viaResponses(\n p: Provider,\n model: string,\n a: AskArgs,\n key: string,\n): Promise {\n const input: Array<{ role: string; content: string }> = [];\n if (a.system) input.push({ role: \"system\", content: a.system });\n input.push({ role: \"user\", content: a.prompt });\n\n const body: Record = { model, input };\n if (a.max_tokens != null) body.max_output_tokens = a.max_tokens;\n if (a.extra && typeof a.extra === \"object\") Object.assign(body, a.extra);\n\n const r = await fetch(`${baseOf(p)}/responses`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${key}`,\n },\n body: JSON.stringify(body),\n });\n if (!r.ok) {\n throw noRetry(\n `${p.id}/${model} на /responses вернул ${r.status}: ${\n (await r.text()).slice(0, 400)\n }`,\n );\n }\n const j: any = await r.json();\n const u: any = j?.usage ?? {};\n return {\n choices: [{\n message: { content: responsesText(j) },\n finish_reason: j?.status,\n }],\n usage: {\n prompt_tokens: Number(u.input_tokens ?? 0),\n completion_tokens: Number(u.output_tokens ?? 0),\n },\n };\n}\n\nasync function callProvider(\n p: Provider,\n model: string,\n a: AskArgs,\n): Promise {\n const key = env(p.keyEnv);\n if (!key) throw new Error(`Нет ключа ${p.keyEnv} для провайдера ${p.id}`);\n\n const messages: Array<{ role: string; content: string }> = [];\n if (a.system) messages.push({ role: \"system\", content: a.system });\n messages.push({ role: \"user\", content: a.prompt });\n\n // Потолок проверяется до запроса: списание происходит у провайдера,\n // отменить его после ответа уже нельзя.\n if (p.cost !== \"free\") await guardBudget();\n\n const callStarted = Date.now();\n\n const body: Record = { model, messages };\n // OpenAI выбросил max_tokens из своего же API: новые модели принимают только\n // max_completion_tokens и на старое имя отвечают 400. У остальных провайдеров\n // совместимый слой понимает именно max_tokens, поэтому подменяем адресно.\n if (a.max_tokens != null) {\n if (p.id === \"openai\") body.max_completion_tokens = a.max_tokens;\n else body.max_tokens = a.max_tokens;\n }\n // temperature принимают не все. Рассуждающие модели отвечают на неё 400 и,\n // что хуже, ошибка выглядит как отказ провайдера целиком — на замере 3 августа\n // так молча выпал claude-opus-4-8 («`temperature` is deprecated for this model»).\n // Дешевле не отправлять её тем, кто заведомо откажет, чем ловить отказ.\n const noTemp = /opus|reasoner|thinking|^o[1-9]|gpt-5/i.test(String(model));\n if (a.temperature != null && !noTemp) body.temperature = a.temperature;\n // Провайдер-специфичные поля: translation_options у переводческих моделей Qwen,\n // enable_thinking для отключения рассуждений у гибридных моделей и подобное.\n if (a.extra && typeof a.extra === \"object\") Object.assign(body, a.extra);\n\n let lastErr = \"\";\n for (let attempt = 1; attempt <= MAX_ATTEMPTS; attempt++) {\n const ac = new AbortController();\n const timer = setTimeout(() => ac.abort(), TIMEOUT_MS);\n try {\n const res = await fetch(`${baseOf(p)}/chat/completions`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${key}`,\n // OpenRouter просит атрибуцию; для остальных заголовки безвредны.\n \"HTTP-Referer\": \"https://claude.ai\",\n \"X-Title\": \"Claude AI Gateway\",\n },\n body: JSON.stringify(body),\n signal: ac.signal,\n });\n\n if (res.status === 429 || res.status >= 500) {\n lastErr = `${p.id} вернул ${res.status}: ${\n (await res.text()).slice(0, 300)\n }`;\n if (attempt < MAX_ATTEMPTS) {\n await new Promise((r) => setTimeout(r, 800 * 2 ** (attempt - 1)));\n continue;\n }\n throw new Error(lastErr);\n }\n\n let json: any;\n if (!res.ok) {\n const errText = (await res.text()).slice(0, 500);\n // Модель обслуживается другим протоколом — это не ошибка запроса.\n // Повторяем на /responses и приводим ответ к общей форме.\n if (p.id === \"openai\" && errText.includes(\"v1/responses\")) {\n json = await viaResponses(p, model, a, key);\n } else {\n // 4xx повторять бессмысленно: неверное имя модели или параметра не\n // исправится само, а платный повтор оплачивается заново.\n throw noRetry(`${p.id} вернул ${res.status}: ${errText}`);\n }\n } else {\n json = await res.json();\n }\n const choice = json?.choices?.[0];\n const text = choice?.message?.content ?? \"\";\n if (!text) {\n // Рассуждающие модели DeepSeek кладут размышления в отдельное поле reasoning_content\n // и списывают их из того же max_tokens. Если лимит кончился раньше, чем модель перешла\n // к ответу, content приходит пустой — без этой ветки пользователь видел бы свалку JSON.\n const rc = choice?.message?.reasoning_content;\n if (typeof rc === \"string\" && rc.length > 0) {\n throw noRetry(\n `${p.id}/${model}: лимит max_tokens израсходован на размышления, до ответа модель не дошла ` +\n `(finish_reason=${choice?.finish_reason}, потрачено ${json?.usage?.completion_tokens} токенов). ` +\n `Поднимите max_tokens: коротким вопросам хватает 2500, разбору кода — от 8000 ` +\n `(на ревью 3 августа не хватило и 3000 — модель потратила весь лимит на размышления). ` +\n `Либо возьмите нерассуждающую deepseek-chat, либо разбейте текст на части: ` +\n `на длинном вводе рассуждения растут быстрее ответа.`,\n );\n }\n throw noRetry(\n `${p.id} вернул пустой ответ: ${JSON.stringify(json).slice(0, 300)}`,\n );\n }\n // В журнал пишем всех исполнителей, включая бесплатных: без них картина\n // работы неполная. В учёт расходов — только платных, там другой смысл.\n const usage: any = json?.usage ?? {};\n void logCall({\n trace: (a as any).trace,\n tool: \"chat\",\n provider: p.id,\n model,\n tier: a.tier,\n ms: Date.now() - callStarted,\n in_tokens: Number(usage.prompt_tokens ?? 0),\n out_tokens: Number(usage.completion_tokens ?? 0),\n usd:\n p.cost === \"free\"\n ? 0\n : estimateUsd(\n p.id,\n model,\n Number(usage.prompt_tokens ?? 0),\n Number(usage.completion_tokens ?? 0),\n ),\n note: (a as any).note,\n project: (a as any).project,\n });\n // Расход пишем здесь, а не у вызывающего: так учтётся любой путь —\n // одиночный запрос, пачка, сравнение моделей. Бесплатные отсеются по тарифу.\n if (p.cost !== \"free\") {\n const u: any = json?.usage ?? {};\n void logSpend({\n provider: p.id,\n model,\n kind: \"chat\",\n in_tokens: Number(u.prompt_tokens ?? 0),\n out_tokens: Number(u.completion_tokens ?? 0),\n }).then(forgetSpendCache);\n }\n return { text, provider: p.id, model, usage: json?.usage };\n } catch (e: any) {\n lastErr = e?.name === \"AbortError\"\n ? `${p.id}: таймаут ${TIMEOUT_MS} мс`\n : String(e?.message || e);\n // Повторяем только то, что могло пройти со второго раза: сеть, таймаут,\n // 429/5xx. Ошибки с признаком noRetry уходят наверх сразу — повтор платного\n // вызова с тем же исходом означал бы платить трижды за один отказ.\n if (e?.noRetry || attempt >= MAX_ATTEMPTS) throw new Error(lastErr);\n await new Promise((r) => setTimeout(r, 800 * 2 ** (attempt - 1)));\n } finally {\n clearTimeout(timer);\n }\n }\n throw new Error(lastErr || \"неизвестная ошибка\");\n}\n\n/**\n * Отказ по частоте запросов, а не по существу. Слова у провайдеров разные:\n * Google пишет RESOURCE_EXHAUSTED и «exceeded your current quota», остальные —\n * rate limit. Код 429 надёжнее слов, но в текст ошибки он попадает не всегда.\n */\nfunction isRateLimit(msg: string): boolean {\n return /\\b429\\b|rate.?limit|RESOURCE_EXHAUSTED|quota/i.test(msg);\n}\n\n/** Выбирает провайдера/модель и вызывает, при неудаче переходит к следующему провайдеру. */\nexport async function ask(a: AskArgs): Promise {\n const tier = a.tier || \"smart\";\n const errors: string[] = [];\n\n let candidates: Provider[];\n /** Названный бесплатный провайдер: подменяем только его и только на 429. */\n let pinnedFree: string | null = null;\n if (a.provider) {\n // Явное указание провайдера = осознанное согласие, в том числе на платного.\n const p = providerById(a.provider);\n if (!p) {\n throw new Error(\n `Неизвестный провайдер \"${a.provider}\". Доступны: ${\n PROVIDERS.map((x) => x.id).join(\", \")\n }`,\n );\n }\n if (!env(p.keyEnv)) {\n throw new Error(`Провайдер ${p.id} не настроен: нет секрета ${p.keyEnv}`);\n }\n candidates = [p];\n // Упор в лимит бесплатного провайдера — не повод возвращать отказ.\n // Замер 13 августа: восемь однотипных вызовов, все с явным provider \"gemini\",\n // ушли одновременно и все восемь получили 429 — не исчерпание квоты, а\n // минутный лимит. Повторы внутри callProvider занимают около 2,4 секунды\n // и в это окно не укладываются, а запасных кандидатов у названного\n // провайдера не было. Теперь есть: у бесплатного за спиной остальные\n // бесплатные, и подмена называется в ответе.\n //\n // Только для бесплатных и только на 429. Названный платный провайдер —\n // это решение человека о деньгах и качестве; молча увести работу другому\n // значит отменить его решение. И только на лимит: неверная модель или\n // неверный параметр у соседа дадут ту же ошибку, лишь позже.\n if (p.cost === \"free\") {\n pinnedFree = p.id;\n candidates = [\n p,\n ...FALLBACK_ORDER.map(providerById).filter((x): x is Provider =>\n !!x && x.id !== p.id && !!env(x.keyEnv)\n ),\n ];\n }\n } else {\n // CHEAP_AUTO=1 пускает дешёвых платных в автоподбор без флага allow_paid.\n // Согласие даётся конфигурацией и действует только при заданном дневном\n // потолке: разрешать неограниченный расход молча нельзя. Бесплатные всё\n // равно идут первыми — платные подхватывают, когда бесплатные отказали.\n const cheapAuto = env(\"CHEAP_AUTO\") === \"1\" &&\n !!Number(env(\"SPEND_LIMIT_USD\") ?? \"\");\n const order = a.allow_paid || cheapAuto\n ? [...FALLBACK_ORDER, ...PAID_ORDER]\n : FALLBACK_ORDER;\n candidates = order.map(providerById).filter((p): p is Provider =>\n !!p && !!env(p.keyEnv)\n );\n }\n\n if (candidates.length === 0) {\n const paidConfigured = [...PAID_ORDER, ...PREMIUM_ONLY]\n .map(providerById)\n .filter((p): p is Provider => !!p && !!env(p.keyEnv));\n if (paidConfigured.length > 0) {\n throw new Error(\n \"Ни один бесплатный провайдер не настроен. Настроены только платные (\" +\n paidConfigured.map((p) => `${p.id} — ${p.cost}`).join(\", \") +\n \"). Дешёвые платные включаются флагом allow_paid: true, премиальные — только явным указанием \" +\n \"provider. И то, и другое означает списание реальных денег, поэтому требует согласия пользователя.\",\n );\n }\n throw new Error(\n \"Не настроен ни один провайдер. Добавьте в секреты хотя бы один из: \" +\n PROVIDERS.map((p) => p.keyEnv).join(\", \"),\n );\n }\n\n for (const p of candidates) {\n const model = a.model || p.tiers[tier] || p.tiers.smart;\n // Через бесплатный Qwen доступны чужие модели — Kimi, GLM, DeepSeek.\n // Покрывает ли их разовый грант, Alibaba не документирует, а полная цена\n // Kimi около $0.57 вход и $3 выход за 1M. Пока не выяснено — считаем платным.\n if (\n p.id === \"qwen\" &&\n /^(kimi|moonshot|glm|deepseek|zhipu)/i.test(model) &&\n !a.allow_paid\n ) {\n errors.push(\n `${p.id}/${model}: чужая модель внутри аккаунта Qwen, бесплатность не подтверждена. ` +\n \"Нужен allow_paid и согласие пользователя.\",\n );\n continue;\n }\n try {\n const r = await callProvider(p, model, a);\n if (pinnedFree && p.id !== pinnedFree) {\n r.substituted = `Вы просили ${pinnedFree}, но он упёрся в лимит запросов ` +\n `(429). Ответ дал ${p.id}/${model} — бесплатный, как и запрошенный. ` +\n `Если ответ важно получить именно от ${pinnedFree}, повторите позже ` +\n `или разнесите вызовы во времени; десяток однотипных вопросов лучше ` +\n `отправлять одним ask_model_batch, а не веером параллельных вызовов.`;\n }\n return r;\n } catch (e: any) {\n const msg = String(e?.message || e);\n errors.push(msg);\n // Названный провайдер отказал не по лимиту — идти к соседям незачем:\n // человек выбрал исполнителя, а причина отказа у соседа повторится.\n if (pinnedFree && p.id === pinnedFree && !isRateLimit(msg)) break;\n }\n }\n throw new Error(`Все провайдеры отказали:\\n- ${errors.join(\"\\n- \")}`);\n}\n\n// ---------------------------------------------------------------------------\n// Веб-поиск через xAI. Отдельный эндпоинт /responses: у него другое тело\n// (input вместо messages) и серверные инструменты, поэтому в callProvider\n// он не укладывается.\n// ---------------------------------------------------------------------------\n\ninterface SearchArgs {\n query: string;\n model?: string;\n sources?: string[];\n system?: string;\n max_tokens?: number;\n}\n\ninterface SearchResult {\n text: string;\n model: string;\n citations: string[];\n usage?: Record;\n}\n\nasync function webSearch(a: SearchArgs): Promise {\n const p = providerById(\"xai\");\n if (!p) throw new Error(\"Провайдер xai не описан\");\n const key = env(p.keyEnv);\n if (!key) {\n throw new Error(\n \"Веб-поиск работает через xAI, но ключа XAI_API_KEY нет. Это платный провайдер: \" +\n p.price,\n );\n }\n\n const model = a.model || \"grok-4.5\";\n const srcs = Array.isArray(a.sources) && a.sources.length\n ? a.sources\n : [\"web\"];\n const tools = [...new Set(srcs)].map((s) => ({\n type: s === \"x\" ? \"x_search\" : \"web_search\",\n }));\n\n const input: Array<{ role: string; content: string }> = [];\n if (a.system) input.push({ role: \"system\", content: a.system });\n input.push({ role: \"user\", content: a.query });\n\n const body: Record = { model, input, tools };\n if (a.max_tokens != null) body.max_output_tokens = a.max_tokens;\n\n const ac = new AbortController();\n const timer = setTimeout(() => ac.abort(), TIMEOUT_MS);\n try {\n const res = await fetch(`${baseOf(p)}/responses`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${key}`,\n },\n body: JSON.stringify(body),\n signal: ac.signal,\n });\n if (!res.ok) {\n throw new Error(\n `xai /responses вернул ${res.status}: ${\n (await res.text()).slice(0, 500)\n }`,\n );\n }\n const json: any = await res.json();\n\n // Разбор общий с обычными вызовами на /responses: между поисками модель\n // пишет промежуточные реплики, поэтому берётся последнее сообщение.\n const text = responsesText(json);\n if (!text) {\n throw new Error(\n `xai вернул пустой ответ: ${JSON.stringify(json).slice(0, 400)}`,\n );\n }\n\n const raw = Array.isArray(json?.citations) ? json.citations : [];\n const citations = raw\n .map((c: any) => (typeof c === \"string\" ? c : c?.url))\n .filter((u: any): u is string => typeof u === \"string\");\n\n return { text, model, citations, usage: json?.usage };\n } catch (e: any) {\n if (e?.name === \"AbortError\") {\n throw new Error(`xai: таймаут ${TIMEOUT_MS} мс`);\n }\n throw e;\n } finally {\n clearTimeout(timer);\n }\n}\n\n// ---------------------------------------------------------------------------\n// Шлюз правит сам себя.\n//\n// У песочницы Claude нет выхода в сеть, и раньше каждая правка шла через браузер\n// пользователя — медленно и с риском попасть не туда. У самого вала сеть есть,\n// поэтому он может переписать себя через API Val Town.\n//\n// Опасность очевидна: сломанный код убьёт инструмент, которым его чинят. Поэтому\n// порядок такой — сверить хэш ДО записи, сохранить прежнюю версию, записать,\n// постучаться в собственный health, и при неудаче вернуть прежнюю. Дверь не должна\n// захлопываться изнутри.\n// ---------------------------------------------------------------------------\n\nconst VAL_ID_DEFAULT = \"f04cc041-3bf4-4db7-a7ca-6638165c8d3d\";\n\n/** Собственный адрес, взятый из входящего запроса: по нему проверяем себя после записи. */\nlet SELF_ORIGIN = \"\";\n\nasync function sha256(s: string): Promise {\n const buf = await crypto.subtle.digest(\n \"SHA-256\",\n new TextEncoder().encode(s),\n );\n return [...new Uint8Array(buf)].map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nfunction valApi(path: string): string {\n return \"https://api.val.town\" + path;\n}\n\nasync function readSource(path: string): Promise {\n const token = env(\"VALTOWN_TOKEN\");\n if (!token) throw new Error(\"Нет VALTOWN_TOKEN в переменных окружения вала\");\n const id = env(\"VALTOWN_VAL_ID\") || VAL_ID_DEFAULT;\n // Val Town отдаёт содержимое из кэша, поэтому обязателен меняющийся параметр.\n const r = await fetch(\n valApi(\n `/v2/vals/${id}/files/content?path=${\n encodeURIComponent(path)\n }&cb=${Date.now()}`,\n ),\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!r.ok) {\n throw new Error(\n `Не удалось прочитать исходник: ${r.status} ${\n (await r.text()).slice(0, 200)\n }`,\n );\n }\n return await r.text();\n}\n\nasync function writeSource(\n path: string,\n content: string,\n): Promise {\n const token = env(\"VALTOWN_TOKEN\")!;\n const id = env(\"VALTOWN_VAL_ID\") || VAL_ID_DEFAULT;\n const u = valApi(`/v2/vals/${id}/files?path=${encodeURIComponent(path)}`);\n const o = (m: string) => ({\n method: m,\n headers: { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ content }),\n });\n // Нового файла ещё нет — PUT отвечает 404, создаём его через POST.\n let r = await fetch(u, o(\"PUT\"));\n if (r.status === 404) {\n r = await fetch(u, { ...o(\"POST\"), body: JSON.stringify({ content, type: \"file\" }) });\n }\n const t = await r.text();\n if (!r.ok) {\n throw new Error(`Запись не прошла: ${r.status} ${t.slice(0, 200)}`);\n }\n const m = t.match(/\"version\":(\\d+)/);\n return m ? Number(m[1]) : null;\n}\n\n/** Стучится в собственный health. Живой шлюз обязан вернуть ok и своё имя. */\nasync function selfCheck(\n origin: string,\n): Promise<{ alive: boolean; detail: string }> {\n try {\n const r = await fetch(`${origin}/?deploycheck=${Date.now()}`);\n const t = await r.text();\n if (!r.ok) {\n return {\n alive: false,\n detail: `health вернул ${r.status}: ${t.slice(0, 200)}`,\n };\n }\n const j = JSON.parse(t);\n if (j?.ok !== true || j?.server !== \"ai-gateway\") {\n return { alive: false, detail: `неожиданный ответ: ${t.slice(0, 200)}` };\n }\n return {\n alive: true,\n detail: `провайдеров: ${(j.configured_providers ?? []).length}`,\n };\n } catch (e: any) {\n return {\n alive: false,\n detail: `health недоступен: ${String(e?.message || e).slice(0, 200)}`,\n };\n }\n}\n\ninterface DeployArgs {\n edits?: Array<{ find: string; replace: string }>;\n content?: string;\n expect_sha256?: string;\n path?: string;\n origin: string;\n}\n\nasync function deployGateway(a: DeployArgs) {\n const path = a.path || \"main.tsx\";\n let before = await readSource(path).catch((e) => { if (a.content == null) throw e; return \"\"; });\n\n let next: string;\n const applied: string[] = [];\n if (a.content != null) {\n next = a.content;\n applied.push(\"замена целиком\");\n } else {\n if (!Array.isArray(a.edits) || a.edits.length === 0) {\n throw new Error(\"Нужны либо edits, либо content\");\n }\n next = before;\n for (const [i, ed] of a.edits.entries()) {\n if (typeof ed?.find !== \"string\" || typeof ed?.replace !== \"string\") {\n throw new Error(`Правка ${i + 1}: нужны строки find и replace`);\n }\n const hits = next.split(ed.find).length - 1;\n if (hits !== 1) {\n throw new Error(\n `Правка ${\n i + 1\n } не применена: образец встречается ${hits} раз, а должен ровно один. ` +\n `Ничего не записано. Начало образца: ${ed.find.slice(0, 80)}`,\n );\n }\n const at = next.indexOf(ed.find);\n // Через slice, а не replace: в replace знак доллара имеет спецсмысл и молча съедает символы.\n next = next.slice(0, at) + ed.replace + next.slice(at + ed.find.length);\n applied.push(`правка ${i + 1}`);\n }\n }\n\n if (next === before) {\n throw new Error(\"После правок ничего не изменилось. Записывать нечего.\");\n }\n if (\n path === \"main.tsx\" &&\n (!next.includes('serverInfo: { name: \"ai-gateway\"') || next.length < 10000)\n ) {\n throw new Error(\n \"Результат не похож на исходник шлюза: нет опознавательных признаков или слишком короткий. Не записано.\",\n );\n }\n\n const got = await sha256(next);\n if (a.expect_sha256 && a.expect_sha256.toLowerCase() !== got) {\n throw new Error(\n `Хэш не совпал. Ожидался ${a.expect_sha256}, получился ${got}. Ничего не записано — ` +\n \"значит, ваш локальный файл и то, что на Val Town, разошлись.\",\n );\n }\n\n const version = await writeSource(path, next);\n // Небольшая пауза: свежий код должен успеть подхватиться.\n await new Promise((r) => setTimeout(r, 1500));\n const health = await selfCheck(a.origin);\n\n if (!health.alive) {\n let rolledBack = false;\n let rollbackNote = \"\";\n try {\n await writeSource(path, before);\n await new Promise((r) => setTimeout(r, 1500));\n const again = await selfCheck(a.origin);\n rolledBack = again.alive;\n rollbackNote = again.detail;\n } catch (e: any) {\n rollbackNote = String(e?.message || e);\n }\n throw new Error(\n `Новая версия не отвечает: ${health.detail}. ` +\n (rolledBack\n ? \"Прежняя версия возвращена, шлюз жив.\"\n : `ОТКАТ НЕ УДАЛСЯ: ${rollbackNote}. Чинить через браузер, страница api.val.town.`),\n );\n }\n\n return {\n path,\n version,\n bytes: new TextEncoder().encode(next).length,\n sha256: got,\n applied,\n health: health.detail,\n was_bytes: new TextEncoder().encode(before).length,\n };\n}\n\nimport { generateImage, IMG_KEEP, IMG_PREFIX, store } from \"./images.ts\";\nimport { handleVideo, VIDEO_TOOLS } from \"./video.ts\";\nimport { sourceFragment } from \"./source.ts\";\nimport { rankByMeaning, readDocument, transcribe } from \"./modal.ts\";\nimport { CATALOG_TOOLS, handleCatalog } from \"./catalog.ts\";\nimport { handleVerify, VERIFY_TOOLS } from \"./verify.ts\";\nimport { handleJobs, JOB_TOOLS } from \"./jobs.ts\";\nimport { handleMemory, MEMORY_TOOLS } from \"./memory.ts\";\nimport { handleLog, LOG_TOOLS, logCall, newTrace } from \"./log.ts\";\nimport { CANON_TOOLS, handleCanon, handleRulesHttp } from \"./canon.ts\";\nimport { handlePanel } from \"./panel.ts\";\nimport {\n estimateUsd,\n forgetSpendCache,\n guardBudget,\n handleSpend,\n logSpend,\n SPEND_TOOLS,\n} from \"./spend.ts\";\n\n// ---------------------------------------------------------------------------\n// Сигнализация: живы ли провайдеры и не кончились ли деньги.\n//\n// Остатка баланса почти никто не отдаёт — из наших только DeepSeek. У остальных\n// единственный честный способ узнать, что деньги кончились, — попробовать вызвать\n// и разобрать отказ. Поэтому проверка стоит несколько токенов на провайдера.\n// ---------------------------------------------------------------------------\n\ntype Verdict = \"ok\" | \"no_money\" | \"bad_key\" | \"rate_limited\" | \"unavailable\";\n\n/** Отличает «кончились деньги» от «слетел ключ» и от «частим». */\nfunction classify(status: number, body: string): Verdict {\n const b = body.toLowerCase();\n const moneyWords =\n /insufficient|credit|quota|billing|payment required|exceeded your current|balance|arrears|欠费|余额不足/;\n if (status === 402) return \"no_money\";\n if (moneyWords.test(b)) {\n // 429 с упоминанием квоты у бесплатных тарифов — это исчерпанный дневной лимит,\n // а не счёт. Для пользователя разница есть: одно чинится деньгами, другое ожиданием.\n if (status === 429 && /rate|per minute|per second|tpm|rpm/.test(b)) {\n return \"rate_limited\";\n }\n return \"no_money\";\n }\n if (status === 401 || status === 403) return \"bad_key\";\n if (status === 429) return \"rate_limited\";\n return \"unavailable\";\n}\n\nconst VERDICT_RU: Record = {\n ok: \"работает\",\n no_money: \"КОНЧИЛИСЬ ДЕНЬГИ\",\n bad_key: \"ключ не принят\",\n rate_limited: \"упёрлись в лимит частоты или суточную квоту\",\n unavailable: \"не отвечает\",\n};\n\n/** Реальный остаток там, где провайдер его отдаёт. Пока это только DeepSeek. */\nasync function balanceOf(\n p: Provider,\n key: string,\n): Promise<{ usd?: number; ok?: boolean } | null> {\n if (p.id !== \"deepseek\") return null;\n try {\n const r = await fetch(`${baseOf(p).replace(/\\/v1$/, \"\")}/user/balance`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!r.ok) return null;\n const j: any = await r.json();\n const usd = (j?.balance_infos ?? []).find((x: any) =>\n x?.currency === \"USD\"\n );\n return {\n usd: usd ? Number(usd.total_balance) : undefined,\n ok: j?.is_available,\n };\n } catch {\n return null;\n }\n}\n\ninterface ProviderStatus {\n provider: string;\n cost: string;\n verdict: Verdict;\n say: string;\n ms: number;\n balance_usd?: number;\n detail?: string;\n}\n\nasync function checkProviders(): Promise<{\n checked_at: string;\n alarm: boolean;\n problems: ProviderStatus[];\n all: ProviderStatus[];\n}> {\n const list = availableProviders();\n const all = await Promise.all(list.map(async (p): Promise => {\n const key = env(p.keyEnv)!;\n const t0 = Date.now();\n const bal = await balanceOf(p, key);\n\n let verdict: Verdict = \"ok\";\n let detail: string | undefined;\n try {\n // Дёшево, но не впритык: с max_tokens=1 рассуждающие модели упираются в лимит\n // раньше первого слова и отдают пустой ответ — проверка ловила бы саму себя.\n //\n // Шестнадцати хватает не всем. Рассуждающие модели тратят лимит на размышления\n // и возвращают 400 «max_tokens reached», не дойдя до ответа: еженедельная ревизия\n // 3 августа поймала на этом ложную тревогу по openai — монитор кричал об отказе,\n // хотя реальные задачи в тот же день проходили. Монитор, который врёт, хуже\n // отсутствующего: на третий раз его перестают читать и пропускают настоящий отказ.\n // Поэтому таким провайдерам пробник берёт запас, а не минимум.\n const reasoning = /opus|reasoner|thinking|^o[1-9]|gpt-5/i.test(String(p.tiers.fast));\n await callProvider(p, p.tiers.fast, {\n prompt: \"Ответь одним словом: да\",\n max_tokens: reasoning ? 2500 : 16,\n });\n } catch (e: any) {\n const msg = String(e?.message || e);\n const m = msg.match(/вернул (\\d{3}):?([\\s\\S]*)/);\n // Пустой текст при успешном HTTP — вопрос качества ответа, а не доступа и не денег.\n // Для сигнализации это «жив»: ключ приняли, счёт не пуст.\n verdict = msg.includes(\"пустой ответ\")\n ? \"ok\"\n : m\n ? classify(Number(m[1]), m[2] || \"\")\n : \"unavailable\";\n if (verdict !== \"ok\") detail = msg.slice(0, 200);\n }\n\n // Баланс может сказать о беде раньше, чем откажет вызов.\n if (bal && bal.ok === false) verdict = \"no_money\";\n\n return {\n provider: p.id,\n cost: p.cost,\n verdict,\n say: VERDICT_RU[verdict],\n ms: Date.now() - t0,\n ...(bal?.usd != null ? { balance_usd: bal.usd } : {}),\n ...(detail ? { detail } : {}),\n };\n }));\n\n const problems = all.filter((s) =>\n s.verdict !== \"ok\" || (s.balance_usd != null && s.balance_usd < 1)\n );\n return {\n checked_at: new Date().toISOString(),\n alarm: problems.length > 0,\n problems,\n all,\n };\n}\n\n/** Параллельная обработка пачки с ограничением конкурентности. */\nasync function askBatch(\n items: Array<{ id: string; prompt: string }>,\n common: Omit,\n concurrency: number,\n): Promise<\n Array<\n {\n id: string;\n text?: string;\n error?: string;\n provider?: string;\n model?: string;\n }\n >\n> {\n const out: Array<\n {\n id: string;\n text?: string;\n error?: string;\n provider?: string;\n model?: string;\n }\n > = new Array(items.length);\n let cursor = 0;\n\n async function worker() {\n while (true) {\n const i = cursor++;\n if (i >= items.length) return;\n const it = items[i];\n try {\n const r = await ask({ ...common, prompt: it.prompt });\n out[i] = {\n id: it.id,\n text: r.text,\n provider: r.provider,\n model: r.model,\n };\n } catch (e: any) {\n out[i] = { id: it.id, error: String(e?.message || e) };\n }\n }\n }\n\n const n = Math.max(1, Math.min(concurrency || 4, 16));\n await Promise.all(Array.from({ length: n }, worker));\n return out;\n}\n\n/**\n * Прогоняет один запрос через несколько моделей и возвращает ответы рядом.\n * Нужен для двух задач: выбрать лучшую модель под конкретный тип работы\n * и перекрёстно проверить ответ, когда цена ошибки высока.\n */\nasync function compare(\n prompt: string,\n targets: Array<\n { provider: string; model?: string; tier?: \"fast\" | \"smart\" | \"long\" }\n >,\n common: Omit,\n) {\n const started = targets.map(() => 0);\n const out = await Promise.all(targets.map(async (t, i) => {\n const p = providerById(t.provider);\n if (!p) return { provider: t.provider, error: \"неизвестный провайдер\" };\n const t0 = Date.now();\n started[i] = t0;\n try {\n const r = await ask({\n ...common,\n prompt,\n provider: t.provider,\n model: t.model,\n tier: t.tier,\n });\n return {\n provider: r.provider,\n model: r.model,\n cost: p.cost,\n ms: Date.now() - t0,\n out_tokens: (r.usage as any)?.completion_tokens ?? null,\n text: r.text,\n };\n } catch (e: any) {\n return {\n provider: t.provider,\n model: t.model,\n cost: p.cost,\n ms: Date.now() - t0,\n error: String(e?.message || e),\n };\n }\n }));\n return out;\n}\n\n/** Живой список моделей у провайдера (каталоги бесплатных тарифов меняются часто). */\nasync function listModels(providerId?: string, freeOnly = false) {\n const targets = providerId\n ? [providerById(providerId)].filter((p): p is Provider => !!p)\n : availableProviders();\n\n const result: any[] = [];\n for (const p of targets) {\n const key = env(p.keyEnv);\n if (!key) {\n result.push({\n provider: p.id,\n label: p.label,\n cost: p.cost,\n price: p.price,\n configured: false,\n note: `нет секрета ${p.keyEnv}`,\n });\n continue;\n }\n try {\n const res = await fetch(`${baseOf(p)}/models`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!res.ok) throw new Error(`${res.status}`);\n const json: any = await res.json();\n let models: any[] = json?.data ?? json?.models ?? [];\n let ids = models.map((m: any) => m?.id ?? m?.name).filter(Boolean);\n if (freeOnly && p.id === \"openrouter\") {\n const freeSet = new Set(\n models\n .filter((m: any) => {\n const pr = m?.pricing || {};\n return String(m?.id || \"\").endsWith(\":free\") ||\n (Number(pr.prompt) === 0 && Number(pr.completion) === 0);\n })\n .map((m: any) => m.id),\n );\n ids = ids.filter((id: string) => freeSet.has(id));\n }\n result.push({\n provider: p.id,\n label: p.label,\n cost: p.cost,\n price: p.price,\n configured: true,\n notes: p.notes,\n recommended: p.tiers,\n model_count: ids.length,\n models: ids.slice(0, 120),\n });\n } catch (e: any) {\n result.push({\n provider: p.id,\n label: p.label,\n cost: p.cost,\n price: p.price,\n configured: true,\n error: `не удалось получить список: ${String(e?.message || e)}`,\n recommended: p.tiers,\n });\n }\n }\n return result;\n}\n\n// ---------------------------------------------------------------------------\n// Описания инструментов MCP\n// ---------------------------------------------------------------------------\n\n/**\n * Инструменты, которым пометки не нужны: они про саму сеть, а не про чью-то\n * работу. Приписывать им клиента — засорять карточку проекта служебным шумом.\n */\nconst NO_MARKS = new Set([\n \"list_models\",\n \"check_catalog\",\n \"check_budgets\",\n \"spending\",\n \"activity\",\n \"get_gateway_source\",\n \"deploy_gateway\",\n \"rules\",\n]);\n\n/**\n * Пометки note и project приписываются к схемам централизованно, а не руками\n * в каждом файле. Причина в найденном: из двадцати четырёх инструментов поле\n * project было только у семи, поэтому работа, сделанная через verify_answer,\n * пачки, распознавание или картинки, попадала в журнал безымянной — и человек\n * видел в панели пустоту там, где сеть на самом деле работала. Ставить одно\n * и то же поле в дюжину схем вручную значит однажды забыть его в тринадцатой.\n */\nconst MARKS = {\n note: {\n type: \"string\",\n description:\n \"Зачем этот вызов, человеческими словами. Попадает в журнал и в панель: \" +\n \"без него запись читается как «что-то делали».\",\n },\n project: {\n type: \"string\",\n description:\n \"Проект, клиент или чат, к которому относится работа. Имя человеческое, \" +\n \"узнаваемое: «Битрикс Астана», а не «извлечение полей». По этому полю \" +\n \"панель собирает карточку проекта; без него работа не видна в отчётах.\",\n },\n} as const;\n\nfunction withMarks(t: any) {\n if (NO_MARKS.has(t.name)) return t;\n const props = t.inputSchema?.properties;\n if (!props) return t;\n return {\n ...t,\n inputSchema: {\n ...t.inputSchema,\n properties: { ...MARKS, ...props },\n },\n };\n}\n\nconst TOOLS = [\n ...CORE_TOOLS,\n ...VIDEO_TOOLS,\n ...SPEND_TOOLS,\n ...CATALOG_TOOLS,\n ...VERIFY_TOOLS,\n ...JOB_TOOLS,\n ...MEMORY_TOOLS,\n ...LOG_TOOLS,\n ...CANON_TOOLS,\n ...TAIL_TOOLS,\n].map(withMarks);\n\n// ---------------------------------------------------------------------------\n// Обработка вызова инструмента\n// ---------------------------------------------------------------------------\n\nfunction textContent(s: string) {\n return { content: [{ type: \"text\", text: s }] };\n}\n\nasync function handleToolCall(name: string, args: any) {\n if (name === \"ask_model\") {\n if (!args?.prompt) throw new Error(\"Обязательный параметр: prompt\");\n const r = await ask(args as AskArgs);\n const p = providerById(r.provider);\n const paidMark = p && p.cost !== \"free\"\n ? ` — ${p.cost === \"premium\" ? \"ПРЕМИАЛЬНЫЙ\" : \"ПЛАТНЫЙ\"}, ${p.price}`\n : \"\";\n return textContent(\n (r.substituted ? `⚠ Подмена исполнителя. ${r.substituted}\\n\\n` : \"\") +\n `[${r.provider} / ${r.model}${paidMark}]\\n\\n${r.text}` +\n (r.usage ? `\\n\\n---\\nusage: ${JSON.stringify(r.usage)}` : \"\"),\n );\n }\n\n if (name === \"ask_model_batch\") {\n const items = args?.items;\n if (!Array.isArray(items) || items.length === 0) {\n throw new Error(\"Обязательный параметр: items (непустой массив)\");\n }\n if (items.length > 500) throw new Error(\"Не более 500 элементов за вызов\");\n const { items: _drop, concurrency, ...common } = args;\n const results = await askBatch(items, common, concurrency ?? 4);\n const ok = results.filter((r) => r.text != null).length;\n const used = [\n ...new Set(results.map((r) => r.provider).filter(Boolean)),\n ] as string[];\n const paidUsed = used.filter((id) => providerById(id)?.cost !== \"free\");\n const costLine = paidUsed.length\n ? `\\nИспользованы ПЛАТНЫЕ провайдеры: ${\n paidUsed.map((id) => `${id} (${providerById(id)?.price})`).join(\", \")\n }. Сообщите пользователю о расходе.`\n : \"\";\n return textContent(\n `Обработано ${results.length}, успешно ${ok}, с ошибкой ${\n results.length - ok\n }.${costLine}\\n\\n` +\n JSON.stringify(results, null, 2),\n );\n }\n\n if (name === \"compare_models\") {\n const { prompt, targets, ...common } = args ?? {};\n if (!prompt) throw new Error(\"Обязательный параметр: prompt\");\n if (!Array.isArray(targets) || targets.length < 2) {\n throw new Error(\"targets: нужно минимум две позиции\");\n }\n if (targets.length > 6) throw new Error(\"targets: не больше шести за раз\");\n const res = await compare(prompt, targets, common);\n const paid = res.filter((r: any) => r.cost && r.cost !== \"free\")\n .map((r: any) =>\n r.provider + \" (\" + providerById(r.provider)?.price + \")\"\n );\n const head = \"Сравнение по \" + res.length + \" моделям.\" +\n (paid.length\n ? \"\\nЗАДЕЙСТВОВАНЫ ПЛАТНЫЕ: \" + [...new Set(paid)].join(\"; \") +\n \". Сообщите пользователю о расходе.\"\n : \"\");\n return textContent(head + \"\\n\\n\" + JSON.stringify(res, null, 2));\n }\n\n if (name === \"list_models\") {\n const r = await listModels(args?.provider, !!args?.free_only);\n return textContent(JSON.stringify(r, null, 2));\n }\n\n if (name === \"get_gateway_source\") {\n const path = args?.path || \"main.tsx\";\n const src = await readSource(path);\n const h = await sha256(src);\n const size = new TextEncoder().encode(src).length;\n if (args?.hash_only) {\n return textContent(\n JSON.stringify({ path, bytes: size, sha256: h }, null, 2),\n );\n }\n return textContent(\n sourceFragment(src, { path, size, sha: h, ...(args ?? {}) }),\n );\n }\n\n if (name === \"deploy_gateway\") {\n if (!SELF_ORIGIN) {\n throw new Error(\n \"Не удалось определить собственный адрес — деплой отменён\",\n );\n }\n const r = await deployGateway({ ...args, origin: SELF_ORIGIN });\n return textContent(\n `Развёрнуто. Версия ${r.version}, было ${r.was_bytes} байт, стало ${r.bytes}. ` +\n `Применено: ${\n r.applied.join(\", \")\n }. Проверка после записи: жив, ${r.health}.\\n` +\n `sha256 ${r.sha256}`,\n );\n }\n\n if (name === \"generate_image\") {\n if (!args?.prompt) throw new Error(\"Обязательный параметр: prompt\");\n if (!SELF_ORIGIN) throw new Error(\"Не удалось определить собственный адрес — некуда положить файл\");\n const r = await generateImage({ ...args, origin: SELF_ORIGIN });\n // Если корзина Supabase настроена, файл лежит там навсегда; иначе он во\n // временных блобах вала, откуда его вытеснит девятая картинка.\n const where = r.permanent\n ? \"Файл сохранён постоянно.\"\n : `Временное хранилище: остаются последние ${IMG_KEEP} картинок, нужное сохраните сразу.`;\n const paid = r.cost !== \"free\" ? ` — ПЛАТНЫЙ, ${r.price}. Сообщите пользователю о расходе.` : \" — бесплатно\";\n const head = `[${r.provider} / ${r.model}${paid}]\\n\\nСсылка на файл: ${r.url}\\nРазмер: ${\n (r.bytes / 1024).toFixed(0)\n } КБ. ${where}`;\n // Показываем картинку в ответе, чтобы оценить и переделать без лишнего\n // круга через пользователя. Отключается параметром preview.\n if (args?.preview === false) return textContent(head);\n return {\n content: [\n { type: \"text\", text: head },\n { type: \"image\", data: r.b64, mimeType: \"image/png\" },\n ],\n };\n }\n\n // Видео живёт в своём файле целиком — и объявления, и обработчики.\n const vid = await handleVideo(name, args ?? {}, textContent);\n if (vid) return vid;\n\n const sp = await handleSpend(name, args ?? {}, textContent);\n if (sp) return sp;\n\n const cat = await handleCatalog(name, args ?? {}, textContent);\n if (cat) return cat;\n\n const ver = await handleVerify(name, args ?? {}, textContent);\n if (ver) return ver;\n\n const job = await handleJobs(name, args ?? {}, textContent);\n if (job) return job;\n\n const mem = await handleMemory(name, args ?? {}, textContent);\n if (mem) return mem;\n\n const lg = await handleLog(name, args ?? {}, textContent);\n if (lg) return lg;\n\n const canon = await handleCanon(name, args ?? {}, textContent);\n if (canon) return canon;\n\n if (name === \"transcribe_audio\") {\n if (!args?.url && !args?.base64) {\n throw new Error(\"Нужен либо url, либо base64\");\n }\n const r = await transcribe(args);\n return textContent(\n `[расшифровка через ${r.provider} / ${r.model}, файл ${\n (r.bytes / 1024 / 1024).toFixed(1)\n } МБ — бесплатно]\\n\\n` +\n r.text,\n );\n }\n\n if (name === \"read_document\") {\n if (!args?.url) throw new Error(\"Обязательный параметр: url\");\n const r = await readDocument(args);\n return textContent(\n `[распознано через mistral, страниц: ${r.pages} — бесплатно]\\n\\n${r.text}`,\n );\n }\n\n if (name === \"rank_by_meaning\") {\n if (!args?.query) throw new Error(\"Обязательный параметр: query\");\n if (!Array.isArray(args?.items) || args.items.length === 0) {\n throw new Error(\"Обязательный параметр: items\");\n }\n if (args.items.length > 200) {\n throw new Error(\"Не более 200 позиций за вызов\");\n }\n const r = await rankByMeaning(args);\n return textContent(\n `[поиск по смыслу через ${r.provider} / ${r.model} — бесплатно]\\n\\n` +\n JSON.stringify(r.ranked, null, 2),\n );\n }\n\n if (name === \"check_budgets\") {\n const r = await checkProviders();\n const head = r.alarm\n ? `ТРЕВОГА. Проблемных провайдеров: ${r.problems.length}.\\n` +\n r.problems.map((s) =>\n `- ${s.provider} (${s.cost}): ${s.say}` +\n (s.balance_usd != null ? `, остаток $${s.balance_usd}` : \"\")\n ).join(\"\\n\")\n : \"Все провайдеры в порядке.\";\n return textContent(head + \"\\n\\n\" + JSON.stringify(r, null, 2));\n }\n\n if (name === \"web_search\") {\n if (!args?.query) throw new Error(\"Обязательный параметр: query\");\n // Самый дорогой инструмент шлюза обязан проходить потолок и учёт, как все.\n await guardBudget(0.05);\n const r = await webSearch(args as SearchArgs);\n const u: any = r.usage ?? {};\n void logSpend({\n provider: \"xai\",\n model: r.model,\n kind: \"search\",\n in_tokens: Number(u.input_tokens ?? u.prompt_tokens ?? 0),\n out_tokens: Number(u.output_tokens ?? u.completion_tokens ?? 0),\n }).then(forgetSpendCache);\n const p = providerById(\"xai\");\n const src = r.citations.length\n ? \"\\n\\nИсточники:\\n\" +\n r.citations.slice(0, 20).map((u, i) => `${i + 1}. ${u}`).join(\"\\n\")\n : \"\";\n return textContent(\n `[веб-поиск через xai / ${r.model} — ПЛАТНЫЙ, ${p?.price}. Сообщите пользователю о расходе.]\\n\\n` +\n r.text + src +\n (r.usage ? `\\n\\n---\\nusage: ${JSON.stringify(r.usage)}` : \"\"),\n );\n }\n\n throw new Error(`Неизвестный инструмент: ${name}`);\n}\n\n// ---------------------------------------------------------------------------\n// MCP: JSON-RPC поверх HTTP\n// ---------------------------------------------------------------------------\n\nconst PROTOCOL_VERSION = \"2025-06-18\";\n\nfunction rpcResult(id: any, result: any) {\n return { jsonrpc: \"2.0\", id, result };\n}\nfunction rpcError(id: any, code: number, message: string) {\n return { jsonrpc: \"2.0\", id, error: { code, message } };\n}\n\nasync function handleRpc(msg: any): Promise {\n const { id, method, params } = msg ?? {};\n\n switch (method) {\n case \"initialize\":\n return rpcResult(id, {\n protocolVersion: typeof params?.protocolVersion === \"string\"\n ? params.protocolVersion\n : PROTOCOL_VERSION,\n capabilities: { tools: { listChanged: false } },\n serverInfo: { name: \"ai-gateway\", version: \"1.1.0\" },\n // Единственный текст, который доходит до КАЖДОЙ среды сам, без установки:\n // клиент читает его при подключении коннектора. Поэтому здесь лежит\n // рабочее ядро правил, а не рекламное описание. Полный свод остаётся\n // в инструменте rules: держать его целиком тут — платить контекстом\n // в каждом чате, даже там, где нужен один перевод.\n instructions:\n \"Шлюз к внешним нейросетям и свод правил сети UM Group.\\n\\n\" +\n \"Прежде всего: в начале содержательной задачи вызовите инструмент `rules` — он отдаёт \" +\n \"действующий свод целиком (роли моделей по замерам, пороги, деньги, проверки). Ниже — \" +\n \"только то, что нужно знать до первого вызова.\\n\\n\" +\n \"ДЕЛЕГИРОВАНИЕ. Массовую механическую работу не делать собственным контекстом: от десяти \" +\n \"однотипных единиц — ask_model_batch, от сотни — start_batch и затем check_batch. \" +\n \"Повторяющееся выносить в system: у провайдеров с кэшем префикса это кратно дешевле.\\n\\n\" +\n \"ИСПОЛНИТЕЛИ по замерам: gemini — тексты, вычитка, казахский, быстрый первый проход по коду; \" +\n \"openai/gpt-5.3-codex — код, где нужна точность; groq — классификация и извлечение полей, \" +\n \"но код и русскую вычитку ему не давать; deepseek-reasoner — ревью и разбор багов, \" +\n \"обязательно max_tokens от 2500, иначе ответ придёт пустым; mistral — SQL и вторая линия.\\n\\n\" +\n \"ПОМЕТКИ. В каждом вызове заполнять note (зачем, человеческими словами) и project (имя \" +\n \"клиента или портала, узнаваемое человеком). Передавать на верхнем уровне аргументов, \" +\n \"НЕ через extra: оттуда они уходят провайдеру в тело запроса и роняют вызов с ошибкой 400. \" +\n \"Если переделываете чужой результат, note начинается с «переделка за ИМЯ:».\\n\\n\" +\n \"ДЕНЬГИ. Автовыбор ходит по бесплатным; дешёвые платные — флагом allow_paid; премиальные — \" +\n \"только явным указанием провайдера. Веб-поиск самый дорогой: по одному вопросу за раз.\\n\\n\" +\n \"ОТЧЁТ. Если в задаче участвовали внешние исполнители, ответ человеку заканчивается одной \" +\n \"строкой: кто, что сделал, сколько занял, сколько стоил.\",\n });\n\n case \"notifications/initialized\":\n case \"notifications/cancelled\":\n return null; // уведомления без ответа\n\n case \"ping\":\n return rpcResult(id, {});\n\n case \"tools/list\":\n return rpcResult(id, { tools: TOOLS });\n\n case \"tools/call\": {\n // Журналируем здесь, в одной точке: так в журнал попадает любой инструмент,\n // включая бесплатные и служебные, и ни один не забудется при добавлении нового.\n const callArgs = params?.arguments ?? {};\n const trace =\n typeof callArgs.trace === \"string\" && callArgs.trace\n ? callArgs.trace\n : newTrace();\n callArgs.trace = trace;\n const startedAt = Date.now();\n try {\n const out = await handleToolCall(params?.name, callArgs);\n void logCall({\n trace,\n tool: params?.name ?? \"?\",\n status: out?.isError ? \"error\" : \"ok\",\n ms: Date.now() - startedAt,\n note: typeof callArgs.note === \"string\" ? callArgs.note : undefined,\n project:\n typeof callArgs.project === \"string\" ? callArgs.project : undefined,\n });\n return rpcResult(id, out);\n } catch (e: any) {\n void logCall({\n trace,\n tool: params?.name ?? \"?\",\n status: \"error\",\n ms: Date.now() - startedAt,\n note: typeof callArgs.note === \"string\" ? callArgs.note : undefined,\n project:\n typeof callArgs.project === \"string\" ? callArgs.project : undefined,\n error: String(e?.message || e),\n });\n // Ошибки инструмента возвращаем как isError, а не как protocol error\n return rpcResult(id, {\n content: [{\n type: \"text\",\n text: `Ошибка: ${String(e?.message || e)}`,\n }],\n isError: true,\n });\n }\n }\n\n case \"resources/list\":\n return rpcResult(id, { resources: [] });\n case \"prompts/list\":\n return rpcResult(id, { prompts: [] });\n\n default:\n if (id === undefined) return null;\n return rpcError(id, -32601, `Метод не поддерживается: ${method}`);\n }\n}\n\nconst JSON_HEADERS = { \"Content-Type\": \"application/json; charset=utf-8\" };\n\n// ---------------------------------------------------------------------------\n// Мост Битрикс24 → Telegram: ежедневные отчёты сотрудников\n//\n// Робот «Исходящий Вебхук» в Битриксе умеет только дёрнуть адрес и подставляет\n// значения полей без кодирования: пробел в адресе Telegram молча отбивает.\n// Поэтому робот присылает сюда лишь числовой id карточки, а текст собираем мы,\n// прочитав карточку через входящий вебхук портала.\n//\n// Секреты (Val Town → Settings → Secrets):\n// TELEGRAM_BOT_TOKEN — токен бота от @BotFather\n// TELEGRAM_CHAT_ID — id группы, куда падают отчёты\n// B24_WEBHOOK — входящий вебхук портала: https://<портал>/rest//<код>/\n// TG_HOOK_KEY — произвольная строка, ею подписан адрес в роботе\n// ---------------------------------------------------------------------------\n\nconst B24_ENTITY_TYPE = 1054; // смарт-процесс «Ежедневный отчет»\nconst B24_CATEGORY = 21; // воронка внутри него\nconst B24_STAGE_DONE = \"DT1054_21:SUCCESS\"; // стадия «Заполнен»\nconst B24_F_DONE = \"ufCrm13_1784808565087\"; // Что сделано за день\nconst B24_F_PLANS = \"ufCrm13_1784808618697\"; // Планы на завтра\nconst B24_F_ISSUES = \"ufCrm13_1784808646329\"; // Проблемы / нужна помощь\n\n/** Портал живёт по Алматы: и «сегодня», и сводка считаются по местному дню. */\nfunction almatyToday(): string {\n return new Date(Date.now() + 5 * 60 * 60 * 1000).toISOString().slice(0, 10);\n}\n\nfunction ddmm(day: string): string {\n const [, m, d] = day.split(\"-\");\n return `${d}.${m}`;\n}\n\n// Вебхук портала мог быть заведён раньше и под другим именем — берём первое найденное,\n// чтобы не заставлять человека копировать одно и то же значение дважды.\nconst B24_HOOK_VARS = [\n \"B24_WEBHOOK\",\n \"B24_HOOK_FBSM\",\n \"B24_HOOK\",\n \"BITRIX_WEBHOOK\",\n \"B24_REST_HOOK\",\n];\n\nfunction b24HookVar(): string | null {\n for (const name of B24_HOOK_VARS) {\n if ((env(name) ?? \"\").trim()) return name;\n }\n return null;\n}\n\nasync function b24(\n method: string,\n params: Record = {},\n): Promise {\n const found = b24HookVar();\n const hook = found ? (env(found) ?? \"\").trim() : \"\";\n if (!hook) {\n throw new Error(\n `не задан вебхук портала ни в одной из переменных: ${B24_HOOK_VARS.join(\", \")}`,\n );\n }\n const base = hook.endsWith(\"/\") ? hook : hook + \"/\";\n const res = await fetch(base + method, {\n method: \"POST\",\n headers: JSON_HEADERS,\n body: JSON.stringify(params),\n });\n const data = await res.json().catch(() => ({} as any));\n if (data?.error) {\n throw new Error(\n `Битрикс ${method}: ${data.error_description ?? data.error}`,\n );\n }\n return data?.result;\n}\n\nasync function tgSend(text: string): Promise {\n const token = env(\"TELEGRAM_BOT_TOKEN\");\n const chatId = env(\"TELEGRAM_CHAT_ID\");\n if (!token || !chatId) {\n throw new Error(\"не заданы TELEGRAM_BOT_TOKEN и TELEGRAM_CHAT_ID\");\n }\n const res = await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: JSON_HEADERS,\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n const data = await res.json().catch(() => ({} as any));\n if (!data?.ok) throw new Error(`Telegram: ${data?.description ?? res.status}`);\n}\n\n/** В HTML-разметке Telegram опасны только эти три символа. */\nfunction tgEscape(v: unknown): string {\n return String(v ?? \"\").replace(/&/g, \"&\").replace(//g, \">\");\n}\n\nconst b24NameCache = new Map();\nasync function b24UserName(id: number): Promise {\n if (!id) return \"без ответственного\";\n const cached = b24NameCache.get(id);\n if (cached) return cached;\n const list = await b24(\"user.get\", { ID: id });\n const u = Array.isArray(list) ? list[0] : null;\n const name = [u?.NAME, u?.LAST_NAME].filter(Boolean).join(\" \").trim() ||\n `сотрудник #${id}`;\n b24NameCache.set(id, name);\n return name;\n}\n\n/** Одна карточка — сразу после того, как сотрудник её заполнил. */\nasync function tgReport(id: number): Promise> {\n if (!id) throw new Error(\"не передан id карточки\");\n const item = (await b24(\"crm.item.get\", {\n entityTypeId: B24_ENTITY_TYPE,\n id,\n }))?.item;\n if (!item) throw new Error(`карточка ${id} не найдена`);\n const who = await b24UserName(Number(item.assignedById));\n const done = String(item[B24_F_DONE] ?? \"\").trim();\n const plans = String(item[B24_F_PLANS] ?? \"\").trim();\n const issues = String(item[B24_F_ISSUES] ?? \"\").trim();\n const parts = [`📝 Отчёт за ${ddmm(almatyToday())} — ${tgEscape(who)}`];\n if (done) parts.push(`\\nСделано:\\n${tgEscape(done)}`);\n if (plans) parts.push(`\\nПланы на завтра:\\n${tgEscape(plans)}`);\n if (issues) parts.push(`\\nПроблемы:\\n${tgEscape(issues)}`);\n await tgSend(parts.join(\"\\n\"));\n return { sent: true, id, who };\n}\n\n/** Вечерняя сводка: кто сдал отчёт за сегодня, а кто нет. */\nasync function tgSummary(force: boolean): Promise> {\n const day = almatyToday();\n const mark = `tg-summary-${day}`;\n const s = await store();\n if (!force) {\n // Робот сработает у каждого сотрудника, а сводка нужна одна за день.\n try {\n await s.get(mark);\n return { skipped: `сводка за ${day} уже отправлена` };\n } catch { /* метки нет — значит сегодня ещё не отправляли */ }\n }\n const items: any[] = (await b24(\"crm.item.list\", {\n entityTypeId: B24_ENTITY_TYPE,\n filter: {\n categoryId: B24_CATEGORY,\n \">=createdTime\": `${day}T00:00:00+05:00`,\n },\n select: [\"id\", \"stageId\", \"assignedById\"],\n }))?.items ?? [];\n const done: string[] = [];\n const missing: string[] = [];\n for (const it of items) {\n const who = await b24UserName(Number(it.assignedById));\n (it.stageId === B24_STAGE_DONE ? done : missing).push(who);\n }\n const lines = [\n `📊 Отчёты за ${ddmm(day)}`,\n `\\n✅ Сдали (${done.length})`,\n done.length ? done.map((n) => `• ${tgEscape(n)}`).join(\"\\n\") : \"• никто\",\n `\\n❌ Не сдали (${missing.length})`,\n missing.length\n ? missing.map((n) => `• ${tgEscape(n)}`).join(\"\\n\")\n : \"• таких нет\",\n ];\n await tgSend(lines.join(\"\\n\"));\n await s.set(mark, new TextEncoder().encode(\"1\"));\n return { sent: true, done: done.length, missing: missing.length };\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n SELF_ORIGIN = url.origin;\n const token = env(\"GATEWAY_TOKEN\");\n\n // Health check без токена\n if (\n req.method === \"GET\" && (url.pathname === \"/\" || url.pathname === \"/health\")\n ) {\n return new Response(\n JSON.stringify(\n {\n ok: true,\n server: \"ai-gateway\",\n version: \"1.1.0\",\n deployed_at: \"2026-08-01\",\n configured_providers: availableProviders().map((p) => p.id),\n free: availableProviders().filter((p) => p.cost === \"free\").map((p) =>\n p.id\n ),\n cheap: availableProviders().filter((p) => p.cost === \"cheap\").map((\n p,\n ) => p.id),\n premium: availableProviders().filter((p) => p.cost === \"premium\").map(\n (p) => p.id\n ),\n token_set: !!token,\n mcp_path: \"/mcp/\",\n },\n null,\n 2,\n ),\n { headers: JSON_HEADERS },\n );\n }\n\n // Что из настроек моста уже на месте. Значений не показываем — только факт наличия.\n if (url.pathname === \"/tg/status\") {\n const gw = env(\"GATEWAY_TOKEN\");\n if (!gw || url.searchParams.get(\"token\") !== gw) {\n return new Response(JSON.stringify({ error: \"нет доступа\" }), {\n status: 403,\n headers: JSON_HEADERS,\n });\n }\n return new Response(\n JSON.stringify({\n telegram_bot_token: !!env(\"TELEGRAM_BOT_TOKEN\"),\n telegram_chat_id: !!env(\"TELEGRAM_CHAT_ID\"),\n tg_hook_key: !!env(\"TG_HOOK_KEY\"),\n bitrix_hook_var: b24HookVar(),\n }),\n { headers: JSON_HEADERS },\n );\n }\n\n // Отчёты из Битрикса. Робот портала о GATEWAY_TOKEN не знает, поэтому адрес\n // подписан отдельным ключом TG_HOOK_KEY.\n if (url.pathname === \"/tg/report\" || url.pathname === \"/tg/summary\") {\n const hookKey = env(\"TG_HOOK_KEY\");\n if (!hookKey || url.searchParams.get(\"key\") !== hookKey) {\n return new Response(JSON.stringify({ error: \"не тот ключ\" }), {\n status: 403,\n headers: JSON_HEADERS,\n });\n }\n try {\n const out = url.pathname === \"/tg/report\"\n ? await tgReport(Number(url.searchParams.get(\"id\") ?? 0))\n : await tgSummary(url.searchParams.get(\"force\") === \"1\");\n return new Response(JSON.stringify(out), { headers: JSON_HEADERS });\n } catch (e) {\n // Робот Битрикса ответа не читает — ошибку видно только отсюда.\n return new Response(JSON.stringify({ error: String(e) }), {\n status: 500,\n headers: JSON_HEADERS,\n });\n }\n }\n\n // Картинки отдаём без токена: ссылку открывает человек, а не программа.\n if (req.method === \"GET\" && url.pathname.startsWith(\"/f/\")) {\n // Битая %-кодировка в адресе — это 404, а не необработанное исключение.\n let name = url.pathname.slice(3);\n try {\n name = decodeURIComponent(name);\n } catch { /* оставляем как есть — регулярка ниже отбросит */ }\n if (!/^[a-f0-9]{32}\\.png$/.test(name)) {\n return new Response(JSON.stringify({ error: \"Не тот адрес\" }), { status: 404, headers: JSON_HEADERS });\n }\n try {\n const s = await store();\n const res = await s.get(IMG_PREFIX + name);\n return new Response(await res.arrayBuffer(), {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=86400\",\n // Чтобы ссылка сохраняла файл, а не открывала его во вкладке.\n \"Content-Disposition\": `attachment; filename=\"${name}\"`,\n },\n });\n } catch {\n return new Response(\n JSON.stringify({ error: \"Файла нет. Скорее всего, вытеснен новыми — храним последние \" + IMG_KEEP }),\n { status: 404, headers: JSON_HEADERS },\n );\n }\n }\n\n // Клиент MCP сначала щупает OAuth: /.well-known/... и /register. Раньше мы отвечали\n // на них 401 — а 401 для клиента означает «здесь нужен OAuth», и он уходит\n // регистрироваться в сервисе, которого у нас нет. Честный ответ — 404: OAuth тут не\n // поддерживается, авторизация идёт токеном в пути. Тогда клиент не пытается и подключается.\n if (\n url.pathname.startsWith(\"/.well-known/\") || url.pathname === \"/register\"\n ) {\n return new Response(\n JSON.stringify({\n error:\n \"OAuth не поддерживается. Токен передаётся в пути: /mcp/\",\n }),\n { status: 404, headers: JSON_HEADERS },\n );\n }\n\n // Авторизация: токен в пути или в заголовке Authorization\n if (!token) {\n return new Response(\n JSON.stringify({ error: \"GATEWAY_TOKEN не задан в секретах\" }),\n {\n status: 500,\n headers: JSON_HEADERS,\n },\n );\n }\n\n // Браузер просит значок на каждой странице панели. Без этого ответа он\n // получает 401 и сыплет ошибку в консоль на ровном месте.\n if (url.pathname === \"/favicon.ico\") return new Response(null, { status: 204 });\n\n // Свод правил по открытому адресу — до проверки токена намеренно: его читает\n // хук SessionStart в Claude Code, которому токен давать нельзя. Секретов в своде\n // нет, клиентских данных тоже.\n const rulesResponse = handleRulesHttp(url);\n if (rulesResponse) return rulesResponse;\n\n // Панель наблюдения разбирает адрес и проверяет токен сама: её ссылка выглядит\n // как /panel/ТОКЕН, а не как /mcp/ТОКЕН, и общий разбор её не узнаёт.\n const panelResponse = await handlePanel(url, token ?? \"\");\n if (panelResponse) return panelResponse;\n\n let pathToken: string | null = null;\n try {\n pathToken = url.pathname.startsWith(\"/mcp/\")\n ? decodeURIComponent(url.pathname.slice(5))\n : url.pathname.startsWith(\"/status/\")\n ? decodeURIComponent(url.pathname.slice(8))\n : null;\n } catch {\n // Битая кодировка совпасть с токеном не может — идём дальше как без токена.\n }\n const headerToken =\n (req.headers.get(\"authorization\") || \"\").replace(/^Bearer\\s+/i, \"\")\n .trim() || null;\n const authorized = (pathToken !== null && pathToken === token) ||\n (headerToken !== null && headerToken === token);\n\n if (!authorized) {\n return new Response(JSON.stringify({ error: \"Неверный токен\" }), {\n status: 401,\n headers: JSON_HEADERS,\n });\n }\n\n // Сигнализация. Стоит денег (дёргает всех живым вызовом), поэтому за токеном.\n if (url.pathname === \"/status\" || url.pathname.startsWith(\"/status/\")) {\n const r = await checkProviders();\n return new Response(JSON.stringify(r, null, 2), {\n status: r.alarm ? 503 : 200,\n headers: JSON_HEADERS,\n });\n }\n\n // Streamable HTTP: GET открывает SSE-поток. Серверных пушей у нас нет.\n if (req.method === \"GET\") {\n return new Response(null, { status: 405, headers: { Allow: \"POST\" } });\n }\n if (req.method === \"DELETE\") {\n return new Response(null, { status: 204 });\n }\n if (req.method !== \"POST\") {\n return new Response(null, { status: 405, headers: { Allow: \"POST\" } });\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return new Response(\n JSON.stringify(rpcError(null, -32700, \"Некорректный JSON\")),\n {\n status: 400,\n headers: JSON_HEADERS,\n },\n );\n }\n\n // Батч или одиночное сообщение\n if (Array.isArray(payload)) {\n const responses = (await Promise.all(payload.map(handleRpc))).filter((r) =>\n r !== null\n );\n if (responses.length === 0) return new Response(null, { status: 202 });\n return new Response(JSON.stringify(responses), { headers: JSON_HEADERS });\n }\n\n const response = await handleRpc(payload);\n if (response === null) return new Response(null, { status: 202 });\n return new Response(JSON.stringify(response), { headers: JSON_HEADERS });\n}",[225],"e251b244-282f-4eab-b36b-c38f52abaeda","log.ts","8a3e9c20-8dae-11f1-b6ca-1607ee4eb77e",67,["D",1785593843199],"// Журнал вызовов: кому что ушло, сколько заняло, чем кончилось.\n//\n// Расход мы уже видели, но по расходу не понять работу: бесплатные вызовы в нём\n// не видны вовсе, а серия связанных обращений выглядит россыпью строк. Здесь\n// пишется каждый вызов инструмента, а поле trace связывает их в одну задачу.\n//\n// Содержимое намеренно не пишется. Ни текст запроса, ни текст ответа: в них\n// рабочие данные клиентов, и превращать журнал в их хранилище — плохая сделка\n// ради удобства разбора. Пишется факт и обстоятельства: инструмент, исполнитель,\n// длительность, токены, статус и короткая пометка «зачем», которую задаёт\n// вызывающий. Пометка — единственное место, где смысл задачи попадает в журнал,\n// поэтому формулировать её надо человеческими словами.\n\nimport { env } from \"./main.tsx\";\n\nconst TABLE = \"gateway_log\";\n\nexport interface LogRow {\n trace?: string;\n project?: string;\n tool: string;\n provider?: string;\n model?: string;\n tier?: string;\n status?: string;\n ms?: number;\n in_tokens?: number;\n out_tokens?: number;\n usd?: number;\n note?: string;\n error?: string;\n}\n\nfunction db(): { url: string; key: string } | null {\n const url = env(\"SUPABASE_URL\");\n const key = env(\"SUPABASE_SERVICE_KEY\");\n if (!url || !key) return null;\n return { url: url.replace(/\\/+$/, \"\"), key };\n}\n\nfunction headers(key: string, extra: Record = {}) {\n return {\n apikey: key,\n Authorization: `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n ...extra,\n };\n}\n\n/**\n * Запись в журнал. Как и учёт расходов, не роняет работу: если журнал недоступен,\n * задача важнее записи о ней. Ошибку глотаем осознанно и молча — иначе сбой\n * наблюдения превратился бы в сбой работы, что ровно наоборот тому, зачем он нужен.\n */\nexport async function logCall(row: LogRow): Promise {\n const sb = db();\n if (!sb) return;\n try {\n await fetch(`${sb.url}/rest/v1/${TABLE}`, {\n method: \"POST\",\n headers: headers(sb.key, { Prefer: \"return=minimal\" }),\n body: JSON.stringify({\n ...row,\n status: row.status ?? \"ok\",\n error: row.error ? String(row.error).slice(0, 500) : null,\n note: row.note ? String(row.note).slice(0, 300) : null,\n project: row.project ? String(row.project).slice(0, 120) : null,\n }),\n });\n } catch {\n // Молчим намеренно, см. комментарий выше.\n }\n}\n\n/** Номер задачи. Один на серию вызовов, чтобы они читались вместе. */\nexport function newTrace(): string {\n const u = new Uint8Array(4);\n crypto.getRandomValues(u);\n return [...u].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nexport const LOG_TOOLS = [\n {\n name: \"activity\",\n description:\n \"Показать, что происходило в сети: какие инструменты вызывались, кто исполнял, \" +\n \"сколько заняло, чем кончилось. Записывается факт вызова, а не содержимое — \" +\n \"тексты запросов и ответов в журнал не попадают намеренно. Вызовы одной задачи \" +\n \"связаны общим номером, поэтому серия читается вместе, а не россыпью. \" +\n \"Полезно, когда нужно понять, куда ушло время и деньги, и почему что-то не сделалось.\",\n inputSchema: {\n type: \"object\",\n properties: {\n hours: {\n type: \"number\",\n description: \"За сколько последних часов смотреть. По умолчанию 24.\",\n },\n project: {\n type: \"string\",\n description: \"Показать только вызовы одного проекта.\",\n },\n task: {\n type: \"string\",\n description:\n \"Показать только вызовы одной задачи по её номеру. Параметр называется task, \" +\n \"а не trace, намеренно: trace шлюз подставляет в каждый вызов сам, и совпадение \" +\n \"имён превращало фильтр в вечно пустой.\",\n },\n only_errors: {\n type: \"boolean\",\n description: \"Только неудачные вызовы.\",\n },\n limit: {\n type: \"number\",\n description: \"Сколько строк вернуть. По умолчанию 50.\",\n },\n },\n },\n },\n];\n\nexport async function handleLog(\n name: string,\n args: any,\n text: (s: string) => any,\n) {\n if (name !== \"activity\") return null;\n const sb = db();\n if (!sb)\n throw new Error(\n \"Журнал живёт в Supabase: не заданы SUPABASE_URL и SUPABASE_SERVICE_KEY\",\n );\n\n const hours = Math.max(1, Number(args?.hours ?? 24));\n const since = new Date(Date.now() - hours * 3600 * 1000).toISOString();\n const limit = Math.min(500, Math.max(1, Number(args?.limit ?? 50)));\n\n let url =\n `${sb.url}/rest/v1/${TABLE}?select=*&order=at.desc&limit=${limit}` +\n `&at=gte.${since}`;\n if (args?.task) url += `&trace=eq.${encodeURIComponent(args.task)}`;\n if (args?.project) url += `&project=eq.${encodeURIComponent(args.project)}`;\n if (args?.only_errors) url += `&status=neq.ok`;\n\n const r = await fetch(url, { headers: headers(sb.key) });\n if (!r.ok) {\n throw new Error(\n `Supabase не отдал журнал, ${r.status}: ${(await r.text()).slice(0, 200)}`,\n );\n }\n const rows: any[] = await r.json();\n if (!rows.length) {\n return text(\n `За последние ${hours} ч. записей нет` +\n (args?.task ? ` для задачи ${args.task}` : \"\") +\n (args?.only_errors ? \" (искали только неудачные)\" : \"\") +\n \".\",\n );\n }\n\n // Группируем по задаче: серия вызовов должна читаться как работа, а не как лог.\n const byTrace = new Map();\n for (const row of rows) {\n const key = row.trace ?? \"—\";\n if (!byTrace.has(key)) byTrace.set(key, []);\n byTrace.get(key)!.push(row);\n }\n\n const blocks: string[] = [];\n for (const [trace, list] of byTrace) {\n const usd = list.reduce((s, x) => s + Number(x.usd ?? 0), 0);\n const bad = list.filter((x) => x.status !== \"ok\").length;\n const head =\n `Задача ${trace} · вызовов ${list.length}` +\n (usd > 0 ? ` · $${usd.toFixed(4)}` : \" · бесплатно\") +\n (bad ? ` · неудачных ${bad}` : \"\");\n const lines = list\n .slice()\n .reverse()\n .map((x) => {\n const who = [x.provider, x.model].filter(Boolean).join(\"/\");\n const time = String(x.at).slice(11, 19);\n const dur = x.ms != null ? `${x.ms} мс` : \"\";\n const toks =\n x.out_tokens != null\n ? `${x.in_tokens ?? 0}→${x.out_tokens} ток.`\n : \"\";\n const tail = [dur, toks].filter(Boolean).join(\", \");\n return (\n ` ${time} ${x.tool}${who ? ` → ${who}` : \"\"}` +\n (x.status !== \"ok\" ? ` [${x.status}]` : \"\") +\n (tail ? ` (${tail})` : \"\") +\n (x.note ? `\\n зачем: ${x.note}` : \"\") +\n (x.error ? `\\n ошибка: ${x.error}` : \"\")\n );\n });\n blocks.push(`${head}\\n${lines.join(\"\\n\")}`);\n }\n\n const total = rows.reduce((s, x) => s + Number(x.usd ?? 0), 0);\n return text(\n `За последние ${hours} ч.: вызовов ${rows.length}, задач ${byTrace.size}, ` +\n `расход примерно $${total.toFixed(4)}.\\n\\n${blocks.join(\"\\n\\n\")}`,\n );\n}\n",[233],"243bd258-e251-44b9-9888-1b32e2806f0e","jobs.ts","d34a5f4e-8da9-11f1-8d0a-1607ee4eb77e",90,["D",1785615234930],"// Фоновые пачки: работа порциями вместо одного долгого вызова.\n//\n// У обычного ask_model_batch есть потолок не по числу элементов, а по времени:\n// вал обрывает запрос, и пачка на тысячу документов до конца не доходит. Здесь\n// работа разложена во времени — состояние лежит в Supabase, а каждое обращение\n// check_batch обрабатывает очередную порцию и возвращает управление.\n//\n// Пачку двигают двое: тот, кто пришёл за результатом, и часовая задача по\n// расписанию, которая доталкивает незавершённые. Отсюда требование: два\n// одновременных обращения к одной пачке не должны взять одну порцию дважды —\n// этим занимается claim() ниже.\n\nimport { ask } from \"./main.tsx\";\nimport { env } from \"./main.tsx\";\n\nconst TABLE = \"gateway_jobs\";\n// Сколько работаем за один заход. Лимит по времени важнее лимита по числу:\n// один длинный документ может съесть всю порцию.\nconst CHUNK = 40;\nconst BUDGET_MS = 20_000;\nconst CONCURRENCY = 8;\nconst INLINE_LIMIT = 20_000;\n\nfunction db(): { url: string; key: string } | null {\n const url = env(\"SUPABASE_URL\");\n const key = env(\"SUPABASE_SERVICE_KEY\");\n if (!url || !key) return null;\n return { url: url.replace(/\\/+$/, \"\"), key };\n}\n\nfunction headers(key: string, extra: Record = {}) {\n return {\n apikey: key,\n Authorization: `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n ...extra,\n };\n}\n\nfunction need() {\n const sb = db();\n if (!sb) {\n throw new Error(\n \"Фоновые пачки хранят состояние в Supabase, а переменные SUPABASE_URL и \" +\n \"SUPABASE_SERVICE_KEY не заданы. Без них пачку негде держать между вызовами.\",\n );\n }\n return sb;\n}\n\nfunction jobId(): string {\n const u = new Uint8Array(8);\n crypto.getRandomValues(u);\n return \"batch_\" + [...u].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function loadJob(id: string): Promise {\n const sb = need();\n const r = await fetch(\n `${sb.url}/rest/v1/${TABLE}?id=eq.${encodeURIComponent(id)}&select=*`,\n {\n headers: headers(sb.key),\n },\n );\n if (!r.ok) throw new Error(`Supabase не отдал задачу, ${r.status}`);\n const rows = await r.json();\n return rows[0] ?? null;\n}\n\nasync function saveJob(\n id: string,\n patch: Record,\n): Promise {\n const sb = need();\n const r = await fetch(\n `${sb.url}/rest/v1/${TABLE}?id=eq.${encodeURIComponent(id)}`,\n {\n method: \"PATCH\",\n headers: headers(sb.key, { Prefer: \"return=minimal\" }),\n body: JSON.stringify({ ...patch, updated_at: new Date().toISOString() }),\n },\n );\n if (!r.ok)\n throw new Error(\n `Supabase не записал задачу, ${r.status}: ${(await r.text()).slice(0, 200)}`,\n );\n}\n\n/**\n * Захват пачки под себя перед обработкой. Два одновременных check_batch по одной\n * пачке брали одну и ту же порцию: платили провайдеру дважды и затирали результаты\n * друг друга — выигрывал тот, кто записал последним. Ролью версии строки работает\n * updated_at: обновляем строку только если она не изменилась с момента чтения.\n * Не изменилась — пачка наша; изменилась — её уже двигает кто-то другой.\n */\nasync function claim(id: string, seen: string | null): Promise {\n // У старых строк отметки времени может не быть — тогда захватывать нечем,\n // работаем как раньше: лучше обработать, чем встать намертво.\n if (!seen) return true;\n const sb = need();\n const r = await fetch(\n `${sb.url}/rest/v1/${TABLE}?id=eq.${encodeURIComponent(id)}` +\n `&updated_at=eq.${encodeURIComponent(seen)}`,\n {\n method: \"PATCH\",\n headers: headers(sb.key, { Prefer: \"return=representation\" }),\n body: JSON.stringify({\n status: \"running\",\n updated_at: new Date().toISOString(),\n }),\n },\n );\n if (!r.ok) return false;\n const rows = await r.json();\n return Array.isArray(rows) && rows.length === 1;\n}\n\nexport const JOB_TOOLS = [\n {\n name: \"start_batch\",\n description:\n \"Поставить большую пачку однотипных запросов в очередь. В отличие от ask_model_batch, \" +\n \"который выполняется целиком за один вызов и на тысячах элементов упирается в лимит \" +\n \"времени, здесь работа идёт порциями: инструмент возвращает номер задачи сразу, а сама \" +\n \"обработка происходит при каждом обращении check_batch. Пачку можно двигать вручную, \" +\n \"вызывая check_batch до конца, а можно оставить: раз в час её доталкивает задача \" +\n \"по расписанию. Годится для перевода, классификации, извлечения полей на сотнях \" +\n \"и тысячах элементов.\",\n inputSchema: {\n type: \"object\",\n properties: {\n items: {\n type: \"array\",\n description: \"Элементы работы. У каждого id и prompt.\",\n items: {\n type: \"object\",\n properties: {\n id: { type: \"string\" },\n prompt: { type: \"string\" },\n },\n required: [\"id\", \"prompt\"],\n },\n },\n system: {\n type: \"string\",\n description:\n \"Общая инструкция для всех элементов. Выносите сюда всё повторяющееся: \" +\n \"у провайдеров с кэшем префикса это резко удешевляет пачку.\",\n },\n tier: { type: \"string\", enum: [\"fast\", \"smart\", \"long\"] },\n provider: { type: \"string\" },\n model: { type: \"string\" },\n max_tokens: { type: \"number\" },\n temperature: { type: \"number\" },\n allow_paid: { type: \"boolean\" },\n },\n required: [\"items\"],\n },\n },\n {\n name: \"check_batch\",\n description:\n \"Продвинуть фоновую пачку и узнать её состояние. Каждый вызов обрабатывает очередную \" +\n \"порцию и возвращает, сколько сделано из скольких. Когда всё готово, отдаёт результат \" +\n \"страницами: если он не поместился, шлюз сам назовёт offset для следующей. Повторный \" +\n \"вызов после завершения ничего не пересчитывает и денег не стоит.\",\n inputSchema: {\n type: \"object\",\n properties: {\n job_id: { type: \"string\", description: \"Номер задачи из start_batch.\" },\n offset: {\n type: \"number\",\n description:\n \"С какого элемента показывать готовый результат. Нужен, когда результат \" +\n \"не поместился в один ответ: следующее значение шлюз называет сам.\",\n },\n },\n required: [\"job_id\"],\n },\n },\n];\n\nexport async function handleJobs(\n name: string,\n args: any,\n text: (s: string) => any,\n) {\n if (name === \"start_batch\") {\n const items = Array.isArray(args?.items) ? args.items : [];\n if (!items.length)\n throw new Error(\"Обязательный параметр: items (непустой массив)\");\n const bad = items.find((x: any) => !x?.id || !x?.prompt);\n if (bad) throw new Error(\"У каждого элемента должны быть id и prompt\");\n\n const sb = need();\n const id = jobId();\n const opts = {\n system: args.system,\n tier: args.tier,\n provider: args.provider,\n model: args.model,\n max_tokens: args.max_tokens,\n temperature: args.temperature,\n allow_paid: args.allow_paid === true,\n // Номер задачи запоминаем при постановке: обработка идёт в других вызовах,\n // а в журнале вся пачка должна читаться одной работой.\n trace: args.trace,\n };\n const r = await fetch(`${sb.url}/rest/v1/${TABLE}`, {\n method: \"POST\",\n headers: headers(sb.key, { Prefer: \"return=minimal\" }),\n body: JSON.stringify({\n id,\n status: \"queued\",\n total: items.length,\n done: 0,\n opts,\n items,\n results: [],\n // Отметку времени ставим сразу: она работает версией строки при захвате,\n // а без неё первая же проверка новой пачки шла бы без защиты от гонки.\n updated_at: new Date().toISOString(),\n }),\n });\n if (!r.ok)\n throw new Error(\n `Supabase не принял задачу, ${r.status}: ${(await r.text()).slice(0, 200)}`,\n );\n\n return text(\n `Пачка поставлена: ${id}\\nЭлементов: ${items.length}, обработано 0.\\n\\n` +\n `За один заход обрабатывается до ${CHUNK} элементов. Можно двигать вручную, ` +\n `вызывая check_batch с этим номером, а можно оставить: раз в час пачку ` +\n `доталкивает задача по расписанию.` +\n (opts.allow_paid\n ? \"\\n\\nРазрешены дешёвые платные провайдеры: пачка может стоить денег.\"\n : \"\"),\n );\n }\n\n if (name !== \"check_batch\") return null;\n if (!args?.job_id) throw new Error(\"Обязательный параметр: job_id\");\n\n const job = await loadJob(args.job_id);\n if (!job)\n throw new Error(\n `Задача ${args.job_id} не найдена. Номер выдаёт start_batch.`,\n );\n\n const items: any[] = job.items ?? [];\n const results: any[] = job.results ?? [];\n\n if (job.status === \"done\" || results.length >= items.length) {\n return await finish(job.id, items, results, text, Number(args.offset) || 0);\n }\n\n if (!(await claim(job.id, job.updated_at ?? null))) {\n return text(\n `Пачку ${job.id} прямо сейчас двигает другой вызов — обработано ${results.length} ` +\n `из ${items.length}. Это не ошибка: так две одновременные проверки не берут ` +\n `одну порцию дважды. Повторите через несколько секунд.`,\n );\n }\n\n // За один заход берём не больше порции и не дольше бюджета времени: что\n // успели — то записали. Остальное подхватит следующий вызов.\n const startCount = results.length;\n const started = Date.now();\n const opts = job.opts ?? {};\n\n while (\n results.length < items.length &&\n results.length - startCount < CHUNK &&\n Date.now() - started < BUDGET_MS\n ) {\n const slice = items.slice(\n results.length,\n Math.min(results.length + CONCURRENCY, items.length),\n );\n const done = await Promise.all(\n slice.map(async (it: any) => {\n try {\n const r = await ask({\n prompt: it.prompt,\n system: opts.system,\n tier: opts.tier,\n provider: opts.provider,\n model: opts.model,\n max_tokens: opts.max_tokens,\n temperature: opts.temperature,\n allow_paid: opts.allow_paid === true,\n trace: opts.trace,\n } as any);\n return {\n id: it.id,\n text: r.text,\n provider: r.provider,\n model: r.model,\n };\n } catch (e: any) {\n return { id: it.id, error: String(e?.message || e).slice(0, 300) };\n }\n }),\n );\n results.push(...done);\n }\n\n const finished = results.length >= items.length;\n await saveJob(job.id, {\n results,\n done: results.length,\n status: finished ? \"done\" : \"running\",\n });\n\n if (!finished) {\n const failed = results.filter((r) => r.error).length;\n return text(\n `Пачка ${job.id}: обработано ${results.length} из ${items.length}` +\n (failed ? `, из них с ошибкой ${failed}` : \"\") +\n `.\\n\\nВызовите check_batch ещё раз, чтобы продвинуть дальше.`,\n );\n }\n return await finish(job.id, items, results, text, Number(args.offset) || 0);\n}\n\n/**\n * Готовый результат отдаётся страницами. Раньше объёмный результат уезжал файлом\n * в публичную корзину — ссылка вечная и открыта любому, кто её знает, а внутри\n * рабочие данные клиентов. Журнал такие данные принципиально не хранит, и складывать\n * их в открытый доступ ради удобства выдачи — та же ошибка с другой стороны.\n */\nasync function finish(\n id: string,\n items: any[],\n results: any[],\n text: (s: string) => any,\n offset = 0,\n) {\n const okCount = results.filter((r) => !r.error).length;\n const head =\n `Пачка ${id} завершена. Элементов ${items.length}, успешно ${okCount}, ` +\n `с ошибкой ${results.length - okCount}.`;\n\n const from = Math.max(0, Math.min(offset, results.length));\n const page: any[] = [];\n let size = 0;\n let i = from;\n for (; i < results.length; i++) {\n const chunk = JSON.stringify(results[i], null, 2);\n // Хотя бы один элемент отдаём всегда, иначе гигантский элемент встал бы стеной.\n if (page.length && size + chunk.length > INLINE_LIMIT) break;\n page.push(results[i]);\n size += chunk.length;\n }\n\n const more = i < results.length;\n return text(\n `${head}\\n\\nПоказаны ${from + 1}–${i} из ${results.length}.` +\n (more ? ` Дальше — check_batch с тем же номером и offset: ${i}.` : \"\") +\n `\\n\\n${JSON.stringify(page, null, 2)}`,\n );\n}\n",[240],"3549fa2c-f84a-46d8-9009-195670b4f33a","images.ts","4911a186-8d89-11f1-90bb-1607ee4eb77e",69,["D",1785599108556],7,"// Картинки: генерация, хранение и выдача файла.\n// Вынесено из main.tsx: Val Town не принимает файл длиннее 80 000 символов,\n// и главный файл упёрся в этот предел.\n\nimport { baseOf, env, providerById } from \"./main.tsx\";\nimport { forgetSpendCache, guardBudget, logSpend } from \"./spend.ts\";\n\n// Места мало — 10 МБ на аккаунт при картинке около мегабайта, поэтому перед\n// записью вычищаем старое, оставляя последние KEEP.\nconst IMG_PREFIX = \"img:\";\nexport const IMG_KEEP = 8;\n\ninterface BlobStore {\n set(key: string, value: any): Promise;\n get(key: string): Promise;\n list(\n prefix?: string,\n ): Promise>;\n delete(key: string): Promise;\n}\n\n/** В тестах хранилища нет — подменяем памятью. */\nconst memoryBlobs = new Map();\nconst memoryStore: BlobStore = {\n async set(k, v) {\n memoryBlobs.set(k, v instanceof Uint8Array ? v : new Uint8Array(0));\n },\n async get(k) {\n const v = memoryBlobs.get(k);\n if (!v) throw new Error(\"ValTownBlobNotFoundError\");\n return new Response(v);\n },\n async list(prefix = \"\") {\n return [...memoryBlobs.keys()]\n .filter((k) => k.startsWith(prefix))\n .map((k) => ({\n key: k,\n size: memoryBlobs.get(k)!.length,\n lastModified: new Date().toISOString(),\n }));\n },\n async delete(k) {\n memoryBlobs.delete(k);\n },\n};\n\nlet blobCache: BlobStore | null = null;\nexport async function store(): Promise {\n if (blobCache) return blobCache;\n try {\n const mod: any = await import(\"https://esm.town/v/std/blob/main.ts\");\n blobCache = mod.blob as BlobStore;\n } catch {\n blobCache = memoryStore;\n }\n return blobCache;\n}\n\n/** Оставляет последние KEEP картинок: место кончается быстро. */\nasync function prune(s: BlobStore) {\n try {\n const all = await s.list(IMG_PREFIX);\n if (all.length <= IMG_KEEP) return;\n const old = all\n .sort((a, b) =>\n String(b.lastModified).localeCompare(String(a.lastModified)),\n )\n .slice(IMG_KEEP);\n for (const it of old) await s.delete(it.key);\n } catch {\n // Уборка второстепенна: не вышло — и ладно.\n }\n}\n\n// Постоянное хранилище: корзина в Supabase. Блобы Val Town остаются запасным\n// вариантом — 10 МБ на аккаунт, файлы вытесняются, поэтому там жить нельзя.\n// Ключ service_role лежит в переменных вала, в коде его нет.\nconst BUCKET = \"ai-gateway\";\n\nfunction supabase(): { url: string; key: string } | null {\n const url = env(\"SUPABASE_URL\");\n const key = env(\"SUPABASE_SERVICE_KEY\");\n if (!url || !key) return null;\n return { url: url.replace(/\\/+$/, \"\"), key };\n}\n\n/** Кладёт файл в Supabase. Возвращает публичную ссылку или null, если корзина не настроена. */\nexport async function putFile(\n name: string,\n bytes: Uint8Array,\n mime: string,\n): Promise {\n const sb = supabase();\n if (!sb) return null;\n // Ключ идёт в двух заголовках намеренно. Новые ключи вида sb_secret_ Supabase\n // принимает только в apikey (в Authorization он пытается разобрать их как JWT\n // и отвечает «Invalid Compact JWS»), а старые service_role — наоборот, в\n // Authorization. Одинаковое значение в обоих заголовках разрешено и покрывает оба.\n const r = await fetch(`${sb.url}/storage/v1/object/${BUCKET}/${name}`, {\n method: \"POST\",\n headers: {\n apikey: sb.key,\n Authorization: `Bearer ${sb.key}`,\n \"Content-Type\": mime,\n \"x-upsert\": \"true\",\n },\n body: bytes,\n });\n if (!r.ok) {\n throw new Error(\n `Supabase не принял файл, ${r.status}: ${(await r.text()).slice(0, 200)}`,\n );\n }\n return `${sb.url}/storage/v1/object/public/${BUCKET}/${name}`;\n}\n\nfunction randomId(): string {\n const u = new Uint8Array(16);\n crypto.getRandomValues(u);\n return [...u].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\n// Бесплатной генерации картинок нет ни у кого из наших. Проверено 01.08.2026:\n// у Google все модели Imagen закрыты для новых аккаунтов, а чат-модели с картинками\n// (gemini-3-pro-image, 2.5-flash-image, 3.1-flash-image) на бесплатном тарифе дают\n// 429 «quota exceeded» — квота там нулевая. В бесплатном каталоге OpenRouter моделей\n// для картинок нет вовсе. Поэтому единственный рабочий путь платный, и мы не тратим\n// вызов на заведомо мёртвого провайдера, а сразу говорим об этом.\nconst IMAGE_MODELS: Record = {\n gemini: \"gemini-3-pro-image\",\n xai: \"grok-imagine-image\",\n openai: \"gpt-image-2\",\n};\n\n// Картинки тарифицируются не по токенам чат-моделей, поэтому цену берём отдельно:\n// иначе в ответ уходила бы цена за миллион токенов и вводила в заблуждение.\nconst IMAGE_PRICE: Record = {\n xai: \"около $0.02 за картинку\",\n openai: \"около $0.03 за картинку среднего качества, до $0.12 за высокое\",\n};\n\n// Числовая оценка для учёта и дневного потолка. Для OpenAI берётся середина\n// вилки: точная цена зависит от качества, а занижать учёт хуже, чем завышать.\nconst IMAGE_USD: Record = { xai: 0.02, openai: 0.07 };\n\n// OpenAI свой же параметр response_format в картиночном API не принимает: gpt-image\n// всегда отдаёт base64 и на лишнее поле отвечает отказом. У остальных, наоборот,\n// без него приходит ссылка, которая через несколько минут протухает.\nfunction imageBody(id: string, model: string, prompt: string) {\n const body: Record = { model, prompt, n: 1 };\n if (id !== \"openai\") body.response_format = \"b64_json\";\n return body;\n}\n\ninterface ImageArgs {\n prompt: string;\n provider?: string;\n model?: string;\n allow_paid?: boolean;\n origin: string;\n}\n\nexport async function generateImage(a: ImageArgs) {\n if (!a.provider && !a.allow_paid) {\n throw new Error(\n \"Бесплатной генерации картинок сейчас нет: у Google квота на изображения нулевая, \" +\n \"в бесплатном каталоге OpenRouter таких моделей нет. Платных варианта два — xAI \" +\n \"(дешевле) и OpenAI (лучше держит надписи). Передайте allow_paid: true, \" +\n \"предварительно спросив пользователя.\",\n );\n }\n const order = a.provider ? [a.provider] : [\"xai\"];\n const errors: string[] = [];\n\n for (const id of order) {\n const p = providerById(id);\n if (!p) {\n errors.push(`неизвестный провайдер ${id}`);\n continue;\n }\n const key = env(p.keyEnv);\n if (!key) {\n errors.push(`${id}: нет ключа ${p.keyEnv}`);\n continue;\n }\n const model = a.model || IMAGE_MODELS[id];\n if (!model) {\n errors.push(`${id}: не умеет картинки`);\n continue;\n }\n\n // Потолок проверяется до запроса и вне try: отказ по бюджету — это ответ\n // пользователю, а не повод молча перебрать следующего платного провайдера.\n if (p.cost !== \"free\") await guardBudget(IMAGE_USD[id] ?? 0.02);\n\n try {\n const res = await fetch(`${baseOf(p)}/images/generations`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(imageBody(id, model, a.prompt)),\n });\n if (!res.ok)\n throw new Error(\n `${id} вернул ${res.status}: ${(await res.text()).slice(0, 300)}`,\n );\n const j: any = await res.json();\n const item = (j?.data ?? [])[0];\n let b64: string | undefined = item?.b64_json;\n\n // Часть провайдеров отдаёт ссылку вместо байтов. Забираем сами: чужая\n // ссылка протухнет раньше, чем пользователь успеет её открыть.\n if (!b64 && item?.url) {\n const im = await fetch(item.url);\n if (!im.ok)\n throw new Error(`${id}: картинка по ссылке недоступна, ${im.status}`);\n const buf = new Uint8Array(await im.arrayBuffer());\n let s = \"\";\n for (let i = 0; i < buf.length; i++) s += String.fromCharCode(buf[i]);\n b64 = btoa(s);\n }\n if (!b64)\n throw new Error(\n `${id} не вернул картинку: ${JSON.stringify(j).slice(0, 300)}`,\n );\n\n const bin = atob(b64);\n const bytes = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) bytes[i] = bin.charCodeAt(i);\n\n const name = `${randomId()}.png`;\n const remote = await putFile(name, bytes, \"image/png\");\n if (!remote) {\n const s = await store();\n await prune(s);\n await s.set(IMG_PREFIX + name, bytes);\n }\n\n // Картинки тарифицируются поштучно, токенов у них нет — пишем оценку сразу.\n if (p.cost !== \"free\") {\n void logSpend({\n provider: id,\n model,\n kind: \"image\",\n usd: IMAGE_USD[id] ?? 0.02,\n }).then(forgetSpendCache);\n }\n\n return {\n url: remote || `${a.origin}/f/${name}`,\n permanent: !!remote,\n provider: id,\n model,\n bytes: bytes.length,\n b64,\n cost: p.cost,\n price: IMAGE_PRICE[id] ?? p.price,\n };\n } catch (e: any) {\n errors.push(String(e?.message || e));\n }\n }\n throw new Error(`Картинка не получилась:\\n- ${errors.join(\"\\n- \")}`);\n}\n\nexport { IMG_PREFIX };\n",[247],"2a7d80dc-c986-4c8d-a8e9-31db6efb4021","cron.ts","d2b27478-9cad-11f1-a416-1607ee4eb77e",124,["D",1787240580317],"// Вечерняя сводка отчётов ФБСМ: дёргает /tg/summary этого же вала.\n// Расписание задаётся в Val Town → Triggers: 30 15 * * * (UTC) = 20:30 по Алматы.\n// Повторный вызов в тот же день безопасен: мост сам отсекает дубли.\n\nconst SELF = \"https://umgroupkzcommits--bfdf35328cce11f180cf1607ee4eb77e.web.val.run\";\n\nexport default async function dailySummary() {\n const key = Deno.env.get(\"TG_HOOK_KEY\") ?? \"\";\n if (!key) throw new Error(\"не задан TG_HOOK_KEY\");\n const res = await fetch(`${SELF}/tg/summary?key=${encodeURIComponent(key)}`);\n const text = await res.text();\n console.log(\"сводка:\", res.status, text);\n if (!res.ok) throw new Error(`сводка не ушла: ${res.status} ${text}`);\n}\n",[255],"064e972f-6d7f-40d4-a7ad-d64fdad05919","catalog.ts","b0fcb870-8da8-11f1-966d-1607ee4eb77e",52,["D",1785589108848],"// Слежение за каталогами моделей.\n//\n// Имена моделей у провайдеров живут своей жизнью: за один день выяснилось, что\n// у xAI прежние идентификаторы исчезли из каталога, у OpenRouter обновился весь\n// бесплатный список, а у DeepSeek удобные псевдонимы в каталоге не значатся вовсе.\n// Ломается это молча — очередной вызов просто отвечает «модель не найдена».\n//\n// Поэтому храним снимок каталога и сравниваем с ним. Снимок лежит в блобе вала,\n// а не в Supabase: это техническая мелочь на пару килобайт, ей там не место.\n\nimport { baseOf, env, providerById, PROVIDERS } from \"./main.tsx\";\nimport { store } from \"./images.ts\";\n\nconst KEY = \"catalog:snapshot\";\n\ntype Snapshot = { at: string; models: Record };\n\nasync function readSnapshot(): Promise {\n try {\n const s = await store();\n const txt = await (await s.get(KEY)).text();\n return JSON.parse(txt) as Snapshot;\n } catch {\n return null;\n }\n}\n\nasync function writeSnapshot(snap: Snapshot): Promise {\n const s = await store();\n await s.set(KEY, new TextEncoder().encode(JSON.stringify(snap)));\n}\n\n/** Живой список моделей у одного провайдера. Пустой массив означает «не отдал». */\nasync function listOf(id: string): Promise {\n const p = providerById(id);\n const key = p && env(p.keyEnv);\n if (!p || !key) return [];\n try {\n const r = await fetch(`${baseOf(p)}/models`, {\n headers: { Authorization: `Bearer ${key}` },\n });\n if (!r.ok) return [];\n const j: any = await r.json();\n const rows = j?.data ?? j?.models ?? [];\n return rows\n .map((m: any) => String(m?.id ?? m?.name ?? \"\"))\n .filter(Boolean)\n .sort();\n } catch {\n return [];\n }\n}\n\nexport const CATALOG_TOOLS = [\n {\n name: \"check_catalog\",\n description:\n \"Сверить живые каталоги моделей со снимком и показать, что появилось и что исчезло. \" +\n \"Нужно потому, что провайдеры меняют имена моделей молча, а узнаётся это в момент отказа \" +\n \"вызова. Запускать по расписанию раз в сутки и всякий раз, когда модель вдруг перестала \" +\n \"находиться. Первый запуск снимка не имеет и просто его создаёт. Провайдеры, которые не \" +\n \"отдают каталог по ключу, перечисляются отдельно — это не поломка, у Anthropic так и есть.\",\n inputSchema: {\n type: \"object\",\n properties: {\n save: {\n type: \"boolean\",\n description:\n \"Записать новый снимок после сверки. По умолчанию да. Передайте false, чтобы \" +\n \"посмотреть расхождения, не сбрасывая точку отсчёта.\",\n },\n },\n },\n },\n];\n\nexport async function handleCatalog(\n name: string,\n args: any,\n text: (s: string) => any,\n) {\n if (name !== \"check_catalog\") return null;\n\n const configured = PROVIDERS.filter((p: any) => !!env(p.keyEnv)).map(\n (p: any) => p.id,\n );\n const now: Record = {};\n const silent: string[] = [];\n for (const id of configured) {\n const models = await listOf(id);\n if (models.length) now[id] = models;\n else silent.push(id);\n }\n\n const prev = await readSnapshot();\n const save = args?.save !== false;\n const snap: Snapshot = { at: new Date().toISOString(), models: now };\n\n if (!prev) {\n if (save) await writeSnapshot(snap);\n const counts = Object.entries(now)\n .map(([id, m]) => `${id}: ${m.length}`)\n .join(\", \");\n return text(\n `Снимка не было — создан первый. Учтено провайдеров: ${Object.keys(now).length} (${counts}).` +\n (silent.length ? `\\nКаталог не отдают: ${silent.join(\", \")}.` : \"\") +\n \"\\n\\nСравнивать будет со следующего запуска.\",\n );\n }\n\n const lines: string[] = [];\n for (const id of Object.keys(now)) {\n const before = new Set(prev.models[id] ?? []);\n const after = new Set(now[id]);\n if (!prev.models[id]) {\n lines.push(\n `${id}: каталога в прошлом снимке не было, теперь ${after.size} моделей`,\n );\n continue;\n }\n const gone = [...before].filter((m) => !after.has(m));\n const added = [...after].filter((m) => !before.has(m));\n if (!gone.length && !added.length) continue;\n const parts: string[] = [];\n // Исчезнувшие важнее появившихся: именно они ломают то, что уже работает.\n if (gone.length)\n parts.push(`ИСЧЕЗЛИ (${gone.length}): ${gone.slice(0, 15).join(\", \")}`);\n if (added.length)\n parts.push(\n `появились (${added.length}): ${added.slice(0, 15).join(\", \")}`,\n );\n lines.push(`${id} — ${parts.join(\"; \")}`);\n }\n\n // Провайдер, который раньше отдавал каталог, а теперь молчит, — тоже событие:\n // так выглядит слетевший ключ или отозванный доступ.\n const wentSilent = silent.filter((id) => (prev.models[id] ?? []).length > 0);\n\n if (save) await writeSnapshot(snap);\n\n if (!lines.length && !wentSilent.length) {\n return text(\n `Каталоги не изменились с ${prev.at}. Проверено провайдеров: ${Object.keys(now).length}.` +\n (silent.length\n ? `\\nКаталог не отдают (как и раньше): ${silent.join(\", \")}.`\n : \"\"),\n );\n }\n\n return text(\n `Изменения в каталогах с ${prev.at}:\\n\\n${lines.join(\"\\n\")}` +\n (wentSilent.length\n ? `\\n\\nПерестали отдавать каталог: ${wentSilent.join(\", \")}. Проверьте ключ — так выглядит отозванный доступ.`\n : \"\") +\n \"\\n\\nЕсли исчезли модели, на которые шлюз ссылается по умолчанию, поправьте tiers в main.tsx.\",\n );\n}\n",[262],"40fa5f81-c69b-4826-b9ce-b6a1b2a2a0b1","canon.ts","a4a5c946-8de3-11f1-bdfb-1607ee4eb77e",121,["D",1786988286133],17,"// Свод правил сети — единственный источник истины, читаемый по требованию.\n//\n// Зачем отдельный инструмент, если правила уже лежат в плагине и в CLAUDE.md.\n// Те файлы читаются один раз при запуске сессии: правка доходит до уже открытых\n// чатов только после переустановки и перезапуска, а до чужих сред — никогда.\n// Здесь наоборот: текст живёт на шлюзе и отдаётся в момент вызова, поэтому\n// изменение правил доходит до всех сред сразу — до Cowork, до чатов claude.ai\n// и до Claude Code, — без переустановки и без перезапуска.\n//\n// Разделение обязанностей такое. Статические файлы держат ОДНУ строку: «в начале\n// задачи спроси правила у шлюза». Она почти не меняется, поэтому перезапуски\n// становятся редкими. Всё, что меняется часто — роли, пороги, договорённости, —\n// живёт здесь и правится одним развёртыванием.\n\nimport { logCall } from \"./log.ts\";\n\nexport const CANON_UPDATED = \"2 августа 2026\";\n\nexport const CANON = `# Правила агентской сети UM Group\n\nСвод от ${CANON_UPDATED}. Прочитан с шлюза, значит он актуален: файлы в плагине\nи в CLAUDE.md могли устареть, этот текст — нет.\n\n## 1. Делегирование\n\nМассовую механическую работу не делать собственным контекстом. От десяти\nоднотипных единиц — ask_model_batch, от сотни — start_batch и затем check_batch.\nВсё повторяющееся выносить в system: у провайдеров с кэшем префикса это кратно\nдешевле.\n\n### Как отдать наружу то, что лежит файлом\n\nask_model принимает строку, а не путь: чтобы передать документ, его надо сперва\nпрочитать, то есть занять им свой контекст — и экономия пропадает. read_document\nтут не помогает, он распознаёт по прямой ссылке, а не читает файл с диска.\n\nОбход есть, и он не хитрый: шлюз — обычный HTTP-эндпоинт с JSON-RPC. Скрипт\nчитает файл, режет на куски и отправляет их сам; модель при этом не видит ни\nодного абзаца, ей достаётся только сводка. Так и надо делать для вычитки,\nперевода и разметки больших текстов. Адрес и токен скрипт берёт из настройки\nMCP (claude mcp list), в код их не вписывать и на экран не печатать.\n\nПока такого скрипта нет — честнее сказать «иначе не умею», чем «не стоит того»:\nэто разные вещи, и человек по ответу должен понимать, какая именно.\n\n### Расшифровка записей: как файл попадает в шлюз\n\nШлюз берёт звук только по ссылке, а песочница Cowork наружу почти не ходит:\nзамер 17 августа — доступны pypi, npm и github, а Groq, Google и Supabase\nзакрыты. Значит файл, приложенный к чату, переслать шлюзу нельзя, и единственная\nплощадка, до которой достают обе стороны, — Google Drive владельца.\n\nПорядок: запись лежит в папке «Записи на расшифровку» (доступ по ссылке включён\nна папке один раз, файлы наследуют его). Ссылка для шлюза строится как\ndrive.usercontent.google.com/download?id=ИДЕНТИФИКАТОР&export=download — проверено\n17 августа на живой записи. После расшифровки текст кладётся в папку\n«Расшифровано», и туда же переносится сама запись: папка закрыта, и перенос\nснимает наследованный публичный доступ. Оставлять клиентские разговоры в открытой\nпапке после расшифровки нельзя.\n\nПредел одного вызова — 25 МБ, ровно как у Groq. Пятьдесят минут разговора в\n16 кГц моно — это около 12 МБ, то есть один вызов без нарезки; резать нужно\nтолько то, что не влезло и после сжатия.\n\n### Веер параллельных вызовов — не пачка\n\nЗамер 13 августа: восемь однотипных черновиков ушли восемью одновременными\nask_model, у каждого был явно указан provider gemini. Все восемь вернулись\nотказом 429. Квота при этом была цела — проверка провайдеров в тот же день\nпоказала gemini рабочим за 616 мс. Упор был в частоту, а не в исчерпание.\n\nОтсюда два правила. Однотипные единицы от десяти штук идут одним\nask_model_batch: он держит конкурентность сам, и минутный лимит бесплатного\nпровайдера не выбирается залпом. И провайдера в таких вызовах лучше не называть\nвовсе: автовыбор обойдёт бесплатных по кругу, а названный — это отказ от\nзапасных.\n\nСо стороны шлюза дыру закрыли 13 августа: названный БЕСПЛАТНЫЙ провайдер,\nупёршийся в 429, подменяется другим бесплатным, и подмена называется в ответе\nстрокой «Подмена исполнителя». Названного платного не подменяют — выбор платного\nисполнителя это решение человека о деньгах. Отказ не по лимиту (неверная модель,\nневерный параметр) к соседям тоже не уходит: у них будет та же ошибка, позже.\n\n## 2. Кто что делает (по замерам 1 августа, код проверялся запуском)\n\n- gemini — рабочая лошадь: тексты, вычитка, казахский, быстрый первый проход по\n коду. Бесплатно, около секунды.\n- openai/gpt-5.3-codex — код, где нужна точность. Около трёх секунд, порядка\n цента за задачу.\n- groq — конвейер структурного: классификация, извлечение полей, расчёты за\n полсекунды. Код, русскую вычитку и казахский ему не давать.\n- deepseek-reasoner — ревью и разбор багов. Обязательно max_tokens от 2500,\n а на разборе кода от 8000: замер 3 августа — на модуле объединения кампаний\n не хватило и 3000, весь лимит ушёл на размышления, ответ пришёл пустым.\n- mistral — вторая линия и чистый SQL.\n- qwen3-coder-next — бесплатный дублёр по коду.\n- openrouter — резерв, нестабилен.\n- Слабое место бесплатного контура — казахский язык: клиентский казахский\n контент сверять платной моделью.\n\n### Чего стоит внешнее ревью кода\n\nЗамер 3 августа, модуль объединения кампаний: из трёх находок внешней модели\nверной оказалась одна, а одна была прямо вредной — совет, который вернул бы\nкритический дефект. Причина простая и неустранимая: модель по ту сторону шлюза\nчитает код, но не может его запустить. Отсюда правило: находки внешнего ревью —\nэто гипотезы, а не вердикты. Каждую проверять запуском, прежде чем править.\nЦенность такого ревью в том, что оно дёшево порождает подозрения; цену находке\nзадаёт проверка, а не уверенность формулировки.\n\nИ отдельно: панель из нескольких моделей, которая не уложилась в время и свелась\nк одной модели, — это не панель. Весь её смысл в расхождении между участниками;\nодин участник расхождений не даёт. Если панель не отработала, честно сказать\n«сверка не состоялась», а не выдавать ответ единственной модели за сверку.\n\n## 3. Уровень модели по цене ошибки\n\nМеханика без суждения — младшая модель или наружу через шлюз. Обычное задание —\nсредняя. Неочевидный выбор и отладка — средняя с рассуждением. Архитектура,\nденьги, доступы, миграции — старшая, занижать нельзя. Модель текущей сессии\nClaude сменить не может: это делает человек. Модель субагентов и tier\nделегирования Claude выбирает сам и молча.\n\n## 4. Раздача задач плана\n\nУ каждой задачи плана сначала появляется исполнитель, и по умолчанию это не\nClaude-субагент. Критерий: поймает ли ошибку автоматическая проверка. Поймает —\nмеханика, в шлюз. Не поймает — суждение, оставить Claude: архитектура, схема\nданных, доступы и деньги, дизайн тестовых случаев, финальное ревью. Код из шлюза\nзапускается, а не читается: на замере модели уверенно возвращали функции,\nпроходившие два теста из шести.\n\nУстановленные плагины-специалисты подбираются автоматически, по их описанию: человек\nне обязан их помнить и не должен звать по имени. Когда задача отнесена к суждению,\nсначала проверьте, есть ли профильный агент — безопасность, TypeScript, схема данных, —\nи отдайте ему; общий субагент берётся, только если профильного нет. Слэш-команды таких\nплагинов — сокращение для человека, а не условие работы. Обратная сторона автоматики:\nсписок агентов сам занимает контекст и размывает выбор, поэтому плагинов держим единицы,\nа не десятки — см. раздел 11.\n\n### Как дать внешней модели то, чего она не видит\n\nВнешняя модель не видит репозиторий. Упаковщик repomix (npx repomix) сводит проект\nв один файл и считает токены заранее — это полезно для оценки стоимости и как карта\nструктуры. Но своду со сжатием (--compress) верить нельзя: он оставляет сигнатуры без\nтел, и модель начинает додумывать. Замер 1 августа на нашем же коде: по сжатому своду\nмодель не нашла ни одной из пяти известных проблем и выдала три несуществующих, прямо\nпротиворечащих комментариям в том же тексте. Для ревью отдавать полный текст нужных\nфайлов, а не свод; свод — для механики по всей базе и для оценки объёма.\n\n## 5. Пометки\n\nВ каждом вызове шлюза заполнять note (зачем, человеческими словами) и project\n(проект, клиент или чат). Передавать на верхнем уровне аргументов, НЕ через\nextra: оттуда они уходят провайдеру в тело запроса и роняют вызов с ошибкой 400.\n\n## 6. Деньги\n\nАвтовыбор ходит по бесплатным. Дешёвые платные — флагом allow_paid либо\nавтоматически, если задан CHEAP_AUTO=1 вместе с дневным потолком. Премиальные —\nтолько явным указанием провайдера, и это уже согласие на расход. Дневной потолок\nSPEND_LIMIT_USD проверяется до запроса и покрывает всё платное, включая картинки,\nвидео и веб-поиск. Веб-поиск — самый дорогой инструмент, только по одному вопросу\nза раз и никогда пачками.\n\n## 7. Проверка перед словом «готово»\n\nНе называть работу законченной, не выполнив действия, которое могло бы показать,\nчто она сломана. Перечитывание собственного результата таким действием не\nявляется. Изменив что-либо в системе — сразу обновить панель, схему архитектуры,\nREADME и инструкции: расхождение между работающим и нарисованным опаснее\nотсутствия схемы.\n\n### Правка живого кода: сначала карта влияния, потом правка\n\nДобавление функции в работающую программу ломает соседнее не случайно, а по\nодной и той же причине: правка делается в том месте, куда смотрят, а зависит от\nнего то, куда не смотрят. Поэтому порядок такой, и он не про аккуратность,\nа про действия.\n\nПервое. До правки — найти всех, кто пользуется тем, что меняется, и перечислить\nих в ответе списком. Поиском по имени функции, поля, ключа, эндпоинта, а не\nпо памяти. В список входят: вызывающие функции, тесты, схема данных и миграции,\nвнешний контракт (адреса API, формат ответа, имена полей в базе), обработчики\nошибок, и всё, что читает тот же файл или ту же настройку. Правка без такого\nсписка не начинается: «я посмотрел» — это не действие с независимым исходом.\n\nВторое. До правки — прогнать весь набор тестов и запомнить, что было зелёным.\nИначе после правки красный тест невозможно отнести: свой он или чужой. Замер\n17 августа в проекте автоматизации Google Ads: набор из 184 тестов, один тест\nуже красный. Без исходного замера он списывался бы на любую следующую правку —\nили, наоборот, прикрывал бы настоящую поломку.\n\nТретье. После правки — весь набор целиком, а не только новый тест. Новый тест\nпроверяет добавленное; ломается же соседнее.\n\nЧетвёртое. Красный тест — это не «готово». Если падение не связано с правкой,\nэто говорится человеку отдельной строкой, а не замалчивается. Заглушить тест,\nпометить пропуском или ослабить проверку вместо починки — запрещено: так теряется\nединственный сторож, который был.\n\nИ главное: правило само себя не выполняет. Решение «работа закончена» принимается\nчерез десятки ходов после того, как правило прочитано, и к этому моменту его\nв контексте уже нет. Поэтому там, где набор тестов запускается одной командой,\nставятся ворота на событие Stop: они прогоняют набор сами и возвращают ход\nобратно, если появились новые падения. В проекте автоматизации Google Ads такие\nворота стоят с 17 августа (scripts/hooks/tests-gate.ps1, журнал срабатываний\nрядом; ставятся одним запуском включить-ворота-тестов.bat). Заводится это в любом проекте, где есть чем проверять; если проверять\nнечем — это и есть первая задача, а не повод обойтись вниманием.\n\n## 8. Память\n\nВ начале темы вызывать recall, прежде чем спрашивать то, что уже обсуждали.\nИтог, к которому будут возвращаться, класть обратно через remember: одна\nсамодостаточная мысль на запись, без стенограмм и без секретов.\n\n## 9. Автономность\n\nДелать максимально всё самому. У человека просить только разрешение или то, что\nфизически недоступно. Не диктовать команды в консоль: если шаг всё же за ним,\nсвести его к одному клику — готовый скрипт, кнопка, файл. Называть границу\nдоступа прямо, а не изображать, что её нет.\n\n## 10. Сдержанность в коде\n\nПравила против переусложнения. Собраны по разбору типичных ошибок языковых моделей\nв коде и приведены к нашей практике.\n\n**Думать до кода.** Скрытое предположение опаснее неверного: неверное видно сразу,\nскрытое всплывает через неделю. Поэтому допущение проговаривается вслух — но именно\nпроговаривается, а не превращается в вопрос. Спрашивать человека только там, где\nошибка необратима: деньги, доступы, чужие системы, удаление. В остальном назвать\nдопущение и работать дальше.\n\n**Проще — лучше.** Минимум кода, решающий поставленную задачу. Никаких «на будущее»:\nабстракций под воображаемые случаи, настроек под один сценарий, обёрток ради одного\nвызова. Функция, вызываемая единожды, обычно не нужна.\n\n**Точечные правки.** Каждая изменённая строка должна относиться к запросу. Не\nпереписывать соседний код, не чинить попутно чужое, не удалять непонятный код на том\nосновании, что он выглядит мёртвым, не наводить порядок в стиле файла. Существующий\nстиль сохраняется, даже если он не нравится: правка, которую нельзя прочитать одним\nвзглядом, дороже той пользы, ради которой её сделали.\n\n**Критерий готовности — до начала.** Сформулировать, что именно будет считаться\nсделанным и чем это проверяется, прежде чем писать. Иначе «готово» превращается\nв мнение, а проверять становится нечего.\n\n## 11. Стоимость контекста\n\nКаждый подключённый инструмент занимает место в окне ещё до первого слова задачи.\nВ Cowork описания подтягиваются по требованию, поэтому десяток коннекторов там почти\nничего не стоит. В Claude Code иначе: серверы из .mcp.json читаются при старте целиком,\nи подключённое «на всякий случай» отнимает контекст всю сессию. Чужой замер, который мы\nне перепроверяли (авторы everything-claude-code): при включении всех серверов сразу\nрабочее окно сжимается примерно с 200k до 70k. Отсюда правило: в проекте держать только\nто, чем проект пользуется. Шлюз — везде, он один и заменяет набор. Остальное подключать\nв конкретном проекте, а не в общем файле. Если инструментов стало заметно больше, а\nзадачи прежние — это повод убрать, а не оставить.\n\n## 12. Секреты\n\nКлючи, GATEWAY_TOKEN, VALTOWN_TOKEN и ключ Supabase живут только в переменных\nокружения вала. Не в репозитории, не в чате, не в журнале, не в памяти. Любой\nскрипт, вывод которого пойдёт в переписку, обязан маскировать секреты до печати:\nclaude mcp list, например, печатает токен в составе адреса.\n\n## 13. Отчётность перед человеком\n\nОн не видит, кто делал работу, и не должен догадываться. Поэтому три правила.\n\n**Строка «кто делал».** Если в задаче участвовали внешние исполнители, ответ\nзаканчивается одной строкой: кто, что сделал, сколько занял, сколько стоил.\nПример: «gemini — черновик функции, 0,9 с, бесплатно; deepseek — ревью, 2,4 с,\n$0,0003; остальное я». Одна строка, без таблиц и без разделов. Всё сделано\nсамим — строки нет, тишина тоже информация.\n\n**Молчание не должно быть двусмысленным.** Если механическая работа в задаче была,\nа наружу не ушла, — скажите одной оговоркой почему: «двадцать однотипных правок делал\nсам, потому что каждая требовала знания соседнего кода». Без этого человек не отличает\n«делегировать было нечего» от «забыл делегировать», и оба случая выглядят одинаково.\nОбычный разговорный ответ оговорки не требует.\n\n**Строка описывает, а не управляет.** Она рассказывает о том, что уже произошло,\nи не участвует в выборе исполнителя. Делегировать, чтобы строка выглядела\nвнушительно, или наоборот — не делегировать, чтобы не отчитываться, — прямой\nвред. Решение принимается по цене ошибки, как в разделах 3 и 4, и только потом\nописывается.\n\n**Пометка переделки.** Если чужой результат приходится делать заново, note\nначинается с «переделка за ИМЯ:» и дальше — чем именно не подошёл. Пример:\n«переделка за groq: классификация промахнулась на трёх строках». Это\nединственный источник качества в панели: журнал видит, что вызов состоялся,\nно не видит, пригодился ли ответ. Без пометок вкладка «Исполнители» покажет\nскорость и цену, а про доверие соврёт нулём.\n\n**Имя проекта — человеческое.** В project идёт то, что человек узнает: имя\nклиента или портала, а не техническое описание работы. «Битрикс Астана», а не\n«извлечение полей».\n\n**Строка «чем работал».** Кроме внешних исполнителей называйте и своё оснащение:\nкакие навыки и плагины сработали, какие профильные агенты запускались. Человек\nустановил их и платит за них вниманием — он вправе знать, что они не лежат\nмёртвым грузом. Формат тот же: одна строка, человеческими словами.\nПример: «навыки: osint-kz (правовые основания и реестры), reviews-radar\n(отзывы 2ГИС); субагент по безопасности — проверка доступов».\n\nЕсли по теме навык есть, но не подошёл, — это тоже стоит одной оговорки: «скилл\nX не брал, он про SaaS-воронку, а тут портал Битрикса». Молчание здесь читается\nкак «навыки не работают», и человек начинает подозревать, что установка была\nнапрасной.`;\n\nexport const CANON_TOOLS = [\n {\n name: \"rules\",\n description:\n \"Получить действующий свод правил агентской сети: кто из моделей что делает по \" +\n \"результатам замеров, как выбирать уровень модели, как раздавать задачи плана, \" +\n \"как считаются деньги, что проверять перед словом «готово». Вызывайте в начале \" +\n \"работы — особенно если сессия открыта давно или это чужая среда: правила в \" +\n \"плагине и в CLAUDE.md читаются один раз при запуске и могли устареть, а этот \" +\n \"инструмент отдаёт текущую версию с шлюза. Ничего не стоит и не тратит токенов \" +\n \"провайдеров.\",\n inputSchema: {\n type: \"object\",\n properties: {\n project: {\n type: \"string\",\n description:\n \"Проект или клиент, в работе над которым читается свод. Заполняйте: \" +\n \"иначе чтение правил не попадёт в карточку проекта на панели.\",\n },\n },\n },\n },\n];\n\n/**\n * Свод по HTTP, без токена. Нужен для хука SessionStart в Claude Code: хук —\n * это команда в консоли, и класть в неё токен шлюза нельзя, а токен панели даёт\n * доступ к расходам и памяти, где лежат клиентские договорённости. Сам свод\n * секретов не содержит — это проверяется тестом, — поэтому открытый адрес здесь\n * дешевле любого из двух токенов.\n *\n * /rules — текст для человека и для curl.\n * /rules/hook — уже готовый ответ хука, чтобы в команде не было ни склейки,\n * ни jq, ни экранирования кавычек в cmd.exe.\n */\nexport function handleRulesHttp(url: URL): Response | null {\n const p = url.pathname.replace(/\\/+$/, \"\");\n\n // Срабатывания хуков пишем в журнал. Иначе проверить, что хук установился\n // и действительно работает, можно только заглянув в чужой settings.json —\n // а туда доступа нет. Теперь это видно в activity: «hook:свод» приходит раз\n // на сессию, «hook:субагент» — на каждый запуск субагента, и по их числу\n // сразу понятно, сколько работы ушло Claude-субагентам мимо шлюза.\n // Запись фоновая: хук не должен ждать базу, и её отказ не должен его ронять.\n const hookTool = p === \"/rules/hook\"\n ? \"hook:свод\"\n : p === \"/rules/agent-hook\"\n ? \"hook:субагент\"\n : null;\n if (hookTool) {\n void logCall({\n trace: \"hook\",\n tool: hookTool,\n status: \"ok\",\n note: hookTool === \"hook:свод\"\n ? \"старт сессии Claude Code — свод правил ушёл в контекст\"\n : \"Claude Code поднимает субагента — напоминание о раздаче задач\",\n }).catch(() => {});\n }\n if (p === \"/rules\") {\n return new Response(CANON, {\n headers: {\n \"Content-Type\": \"text/plain; charset=utf-8\",\n \"Cache-Control\": \"no-store\",\n },\n });\n }\n // Напоминание в момент, когда Claude Code собирается поднять субагента.\n // Свод, прочитанный на старте сессии, до этой точки не доживает: решение\n // «кому отдать задачу» принимается через десятки ходов, и рядом с ним\n // действует местный образец — «на следующую задачу поднимаем субагента».\n // Замер 3 августа: шестнадцать заходов исполнителей и семнадцать ревью, все\n // Claude-субагентами, из них около 300 тысяч токенов на чистой механике,\n // которую бесплатная модель сделала бы за секунду. Текст держать коротким:\n // он приходит на КАЖДЫЙ запуск субагента.\n if (p === \"/rules/agent-hook\") {\n return new Response(\n JSON.stringify({\n hookSpecificOutput: {\n hookEventName: \"PreToolUse\",\n permissionDecision: \"allow\",\n additionalContext:\n \"Раздача задач (свод, раздел 4). Прежде чем поднимать субагента, ответьте себе: \" +\n \"поймает ли ошибку этой задачи автоматическая проверка? Поймает — это механика \" +\n \"(перенос кода из плана, шаблонная правка, фикстуры, конвертация, разметка), \" +\n \"и она идёт в шлюз ai-gateway через ask_model или ask_model_batch, а не субагенту: \" +\n \"снаружи это доли цента, субагент тратит токены подписки. Не поймает — суждение, \" +\n \"субагент уместен: архитектура, схема данных, доступы и деньги, дизайн тестовых \" +\n \"случаев. Ревью кода — verify_answer с судьёй другого вендора и max_tokens от 8000, \" +\n \"а не рецензент того же вендора с тем же взглядом. В вызовах шлюза заполнять note \" +\n \"и project.\",\n },\n }),\n {\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n \"Cache-Control\": \"no-store\",\n },\n },\n );\n }\n\n if (p === \"/rules/hook\") {\n return new Response(\n JSON.stringify({\n hookSpecificOutput: {\n hookEventName: \"SessionStart\",\n additionalContext: CANON,\n },\n }),\n {\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n \"Cache-Control\": \"no-store\",\n },\n },\n );\n }\n return null;\n}\n\nexport async function handleCanon(\n name: string,\n _args: any,\n text: (s: string) => any,\n) {\n if (name !== \"rules\") return null;\n return text(CANON);\n}\n",[269],"pulls","branches","forks","envVars",{"_283":285,"_286":62},"connections",{"_283":62,"_284":62},"count","unfilledCount",24,"emptyCount",{"_42":268,"_32":269,"_30":270,"_147":-5,"_40":41,"_39":271,"_149":24,"_37":357,"_13":273,"_33":20,"_35":274,"_23":24,"_153":-5,"_306":358,"_26":359},{"_42":261,"_32":262,"_30":263,"_147":-5,"_40":41,"_39":264,"_149":24,"_37":354,"_13":62,"_33":20,"_35":266,"_23":24,"_153":-5,"_306":355,"_26":356},{"_42":254,"_32":255,"_30":256,"_147":-5,"_40":41,"_39":257,"_149":24,"_37":351,"_13":62,"_33":20,"_35":259,"_23":24,"_153":-5,"_306":352,"_26":353},{"_42":246,"_32":247,"_30":248,"_147":-5,"_40":41,"_39":249,"_149":58,"_37":348,"_13":251,"_33":20,"_35":252,"_23":24,"_153":-5,"_306":349,"_26":350},{"_42":239,"_32":240,"_30":241,"_147":-5,"_40":41,"_39":242,"_149":58,"_37":345,"_13":151,"_33":20,"_35":244,"_23":24,"_153":-5,"_306":346,"_26":347},{"_42":232,"_32":233,"_30":234,"_147":-5,"_40":41,"_39":235,"_149":58,"_37":342,"_13":168,"_33":20,"_35":237,"_23":24,"_153":-5,"_306":343,"_26":344},{"_42":224,"_32":225,"_30":56,"_147":-5,"_40":41,"_39":226,"_149":24,"_37":339,"_13":228,"_33":229,"_35":230,"_23":24,"_153":-5,"_306":340,"_26":341},{"_42":217,"_32":218,"_30":219,"_147":-5,"_40":41,"_39":220,"_149":58,"_37":336,"_13":151,"_33":20,"_35":222,"_23":24,"_153":-5,"_306":337,"_26":338},{"_42":210,"_32":211,"_30":212,"_147":-5,"_40":41,"_39":213,"_149":24,"_37":333,"_13":160,"_33":20,"_35":215,"_23":24,"_153":-5,"_306":334,"_26":335},{"_42":207,"_32":27,"_30":31,"_147":-5,"_40":41,"_39":14,"_149":24,"_37":330,"_13":62,"_33":34,"_35":36,"_23":24,"_153":-5,"_306":331,"_26":332},{"_42":200,"_32":201,"_30":202,"_147":-5,"_40":41,"_39":203,"_149":58,"_37":327,"_13":151,"_33":20,"_35":205,"_23":24,"_153":-5,"_306":328,"_26":329},{"_42":192,"_32":193,"_30":194,"_147":-5,"_40":41,"_39":195,"_149":58,"_37":324,"_13":197,"_33":20,"_35":198,"_23":24,"_153":-5,"_306":325,"_26":326},{"_42":185,"_32":186,"_30":187,"_147":-5,"_40":41,"_39":188,"_149":24,"_37":321,"_13":168,"_33":20,"_35":190,"_23":24,"_153":-5,"_306":322,"_26":323},{"_42":178,"_32":179,"_30":180,"_147":-5,"_40":41,"_39":181,"_149":58,"_37":318,"_13":62,"_33":20,"_35":183,"_23":24,"_153":-5,"_306":319,"_26":320},{"_42":171,"_32":172,"_30":173,"_147":-5,"_40":41,"_39":174,"_149":58,"_37":315,"_13":168,"_33":20,"_35":176,"_23":24,"_153":-5,"_306":316,"_26":317},{"_42":163,"_32":164,"_30":165,"_147":-5,"_40":41,"_39":166,"_149":24,"_37":312,"_13":168,"_33":20,"_35":169,"_23":24,"_153":-5,"_306":313,"_26":314},{"_42":155,"_32":156,"_30":157,"_147":-5,"_40":41,"_39":158,"_149":58,"_37":309,"_13":160,"_33":20,"_35":161,"_23":24,"_153":-5,"_306":310,"_26":311},{"_42":144,"_32":145,"_30":146,"_147":-5,"_40":41,"_39":148,"_149":58,"_37":305,"_13":151,"_33":20,"_35":152,"_23":24,"_153":-5,"_306":307,"_26":308},["D",1785599159836],"children",[],[145],["D",1785824288259],[],[156],["D",1785604086915],[],[164],["D",1785604867047],[],[172],["D",1785585372937],[],[179],["D",1785615018595],[],[186],["D",1785615037797],[],[193],["D",1785755714688],[],[201],["D",1787240994007],[],[27],["D",1786986739829],[],[211],["D",1785770151730],[],[218],["D",1787237457941],[],[225],["D",1785593843199],[],[233],["D",1785615234930],[],[240],["D",1785599108556],[],[247],["D",1787240580317],[],[255],["D",1785589108848],[],[262],["D",1786988286133],[],[269],["D",1785495035570],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":24},{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_123":397,"_398":399,"_400":401,"_402":24,"_403":24,"_404":24,"_405":58,"_406":-5,"_407":-7,"_408":-7,"_409":62,"_410":24,"_411":24,"_412":-5,"_413":24,"_414":24,"_415":24,"_416":-5},"ENV",{"_368":369,"_370":371,"_372":86,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392,"_393":394,"_395":396},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v125