[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22},"handle","umgroupkzcommits","name","aiGateway","path","telegram.ts","project",{"_23":45,"_11":12,"_34":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":33,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":42},"file",{"_23":24,"_11":14,"_25":26,"_27":-5,"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":17,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/umgroupkzcommits/aiGateway/code/telegram.ts","extension","ts","id","bd04ee52-bc5d-491d-83bb-7b65bdc1b677","fileId","00b0705a-a2da-11f1-ac42-1607ee4eb77e","parentId","branchId","25b8e3e2-628a-4eb6-9af2-0242162621ad","branchVersion",263,"latest",true,"createdAt",["D",1788981176562],"version",24,"fileType","content","// Вход в сеть через Telegram.\n//\n// Зачем. Половина рабочих просьб рождается не за компьютером: голосовая заметка\n// из машины, вопрос между объектами. Приложение Claude закрывает это лишь отчасти,\n// а чужой агентский каркас ради одного входа тащил бы вторую вселенную правил\n// (разбор Hermes, 23 августа). Здесь вход живёт прямо в шлюзе: те же исполнители,\n// тот же журнал, та же панель, ноль новых серверов.\n//\n// Устройство. Telegram шлёт каждое сообщение вебхуком на /tg/hook. Подлинность\n// проверяется секретом в заголовке (Telegram повторяет его в каждом запросе;\n// секрет выводится из токена бота, отдельной переменной не нужно). Отвечаем\n// только владельцу: TG_OWNER_CHAT_ID.\n//\n// Бот у входа СВОЙ, отдельный: TG_AI_BOT_TOKEN. Бот из TELEGRAM_BOT_TOKEN\n// обслуживает клиента (мост отчётов Битрикса) и трогать его нельзя — вебхук\n// на нём отключил бы getUpdates, которым мост привязывает сотрудников.\n// Разные боты — разные вебхуки, никто никому не мешает.\n//\n// Чужим бот не отвечает вовсе: молчание дешевле, чем объяснять незнакомцам,\n// что здесь закрыто.\n//\n// Токен бота в журнал и в ответы не попадает. Ссылки на файлы Telegram содержат\n// токен в пути — поэтому файл скачивается здесь и уходит в расшифровку байтами,\n// а не ссылкой.\n\nimport { ask, env } from \"./main.tsx\";\nimport { transcribe } from \"./modal.ts\";\nimport { handleHqHttp, handleHqTools, hqCommand, hqDialog, HQ_TOOLS, feedNotify, feedTalk } from \"./hq.ts\";\nimport { handleMemory } from \"./memory.ts\";\nimport { logCall, newTrace } from \"./log.ts\";\nimport { chatEnabled, chatTurn } from \"./tgchat.ts\";\n\n/**\n * Свой адрес — нужен живому разговору: Claude подключается к этому же шлюзу как\n * MCP-клиент. Берётся из последнего запроса к /tg/; на холодном старте (вызов\n * tg_probe до первого вебхука) — известный адрес вала.\n */\nlet lastOrigin = \"https://umgroupkzcommits--bfdf35328cce11f180cf1607ee4eb77e.web.val.run\";\n\nconst API = \"https://api.telegram.org\";\n/** Предел скачивания файлов у Bot API — 20 МБ; оставляем запас. */\nconst MAX_FILE = 19 * 1024 * 1024;\n\nfunction json(body: unknown, status = 200) {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\n/** Секрет вебхука: производная от токена бота, наружу не показывается. */\nasync function hookSecret(botToken: string): Promise {\n const d = await crypto.subtle.digest(\n \"SHA-256\",\n new TextEncoder().encode(\"tg-hook:\" + botToken),\n );\n return [...new Uint8Array(d)].slice(0, 16)\n .map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function tgApi(botToken: string, method: string, body: unknown) {\n const r = await fetch(`${API}/bot${botToken}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const j: any = await r.json().catch(() => ({}));\n if (!j.ok) {\n throw new Error(`Telegram ${method}: ${String(j.description ?? r.status).slice(0, 200)}`);\n }\n return j.result;\n}\n\n/** Ответ владельцу, длинное — частями: предел Telegram 4096 знаков. */\nconst VOICE_TERMS = \"Клод, Claude Code, Cowork, Битрикс24, Supabase, Val Town, Google Ads, Telegram, WhatsApp, \" +\n \"Крокус, Тандем, Lalaser, FBSM, Узел, Ассистент открытых линий, шлюз, сторож, очередь, обходчик, свод правил, деплой, тесты.\";\nfunction voiceTerms(): string {\n const extra = env(\"TG_VOICE_TERMS\") ?? \"\";\n return (extra ? extra + \" \" : \"\") + VOICE_TERMS;\n}\n\nasync function say(botToken: string, chatId: string, text: string) {\n // Предел Telegram — 4096 знаков; длинное режем по границам строк, чтобы\n // абзацы и списки не рвались посреди слова (замер 6 сентября: итог сессии\n // Claude Code на 3–5 тыс. знаков приходил разорванным).\n let rest = text.trim() || \"(пусто)\";\n while (rest.length) {\n let cut = rest.length;\n if (cut > 3800) {\n const nl = rest.lastIndexOf(\"\\n\", 3800);\n cut = nl > 1500 ? nl : 3800;\n }\n await tgApi(botToken, \"sendMessage\", { chat_id: chatId, text: rest.slice(0, cut) });\n rest = rest.slice(cut).replace(/^\\s+/, \"\");\n }\n}\n\n/** Сообщение владельцу от штаба (hq.ts): тем же ботом, тому же chat id. */\nasync function tgNotify(text: string) {\n const owner = env(\"TG_OWNER_CHAT_ID\");\n if (!owner) throw new Error(\"не задан TG_OWNER_CHAT_ID\");\n await say(cleanBotToken(), String(owner), text);\n}\n// Всё, что штаб говорит владельцу, ложится и в ленту штаба (страница «Лента штаба»).\nasync function ownerNotify(text: string) { await feedNotify(tgNotify, \"tg\")(text); }\n\nfunction b64(bytes: Uint8Array): string {\n let s = \"\";\n for (let i = 0; i < bytes.length; i += 0x8000) {\n s += String.fromCharCode(...bytes.subarray(i, i + 0x8000));\n }\n return btoa(s);\n}\n\n/**\n * Токен бота, очищенный от типичного мусора вставки: пробелы и переводы строк,\n * кавычки и обратные кавычки по краям, случайная приставка bot. Замер\n * 23 августа: живой токен, скопированный из BotFather, не принимался —\n * Telegram отвечает «Not Found» на любой лишний символ в токене.\n */\nfunction cleanBotToken(): string {\n return String(env(\"TG_AI_BOT_TOKEN\") ?? \"\").trim()\n .replace(/^['\"`]+|['\"`]+$/g, \"\").replace(/^bot(?=\\d)/i, \"\");\n}\n\n// ---------------------------------------------------------------------------\n// Поручения и входящие файлы.\n//\n// Смысл: бот — приёмная, а не исполнитель. Всё, что требует настоящей работы,\n// складывается в таблицу tg_inbox (файлы — в закрытую корзину tg-inbox), и\n// сессии Claude разбирают это инструментом tg_inbox по расписанию или по\n// просьбе, отвечая владельцу инструментом tg_answer. Так поручение, данное\n// с телефона в дороге, не требует ни включённого компьютера, ни открытого чата.\n// ---------------------------------------------------------------------------\n\nconst INBOX_TABLE = \"tg_inbox\";\nconst INBOX_BUCKET = \"tg-inbox\";\n\nfunction sb() {\n const url = env(\"SUPABASE_URL\");\n const key = env(\"SUPABASE_SERVICE_KEY\");\n if (!url || !key) throw new Error(\"нет SUPABASE_URL или SUPABASE_SERVICE_KEY\");\n return { url: url.replace(/\\/+$/, \"\"), key };\n}\n\nfunction sbHeaders(key: string, extra: Record = {}) {\n return { apikey: key, Authorization: `Bearer ${key}`, \"Content-Type\": \"application/json\", ...extra };\n}\n\nasync function inboxAdd(row: { kind: string; text?: string; file_path?: string; mime?: string }): Promise {\n const { url, key } = sb();\n const r = await fetch(`${url}/rest/v1/${INBOX_TABLE}`, {\n method: \"POST\",\n headers: sbHeaders(key, { Prefer: \"return=representation\" }),\n body: JSON.stringify(row),\n });\n if (!r.ok) throw new Error(`очередь поручений: ${r.status} ${(await r.text()).slice(0, 200)}`);\n return (await r.json())[0]?.id;\n}\n\nasync function storagePut(path: string, bytes: Uint8Array, mime: string) {\n const { url, key } = sb();\n const r = await fetch(`${url}/storage/v1/object/${INBOX_BUCKET}/${path}`, {\n method: \"POST\",\n // apikey обязателен: ключ нового образца (sb_secret_…) — не JWT, и без этого\n // заголовка хранилище отвечает 403 «Invalid Compact JWS». Замер 5 сентября:\n // девять файлов подряд отскочили с этой ошибкой, владелец решил, что бот мёртв.\n headers: { apikey: key, Authorization: `Bearer ${key}`, \"Content-Type\": mime || \"application/octet-stream\", \"x-upsert\": \"true\" },\n body: bytes,\n });\n if (!r.ok) throw new Error(`хранилище: ${r.status} ${(await r.text()).slice(0, 200)}`);\n}\n\nasync function signedUrl(path: string, seconds = 3600): Promise {\n const { url, key } = sb();\n const r = await fetch(`${url}/storage/v1/object/sign/${INBOX_BUCKET}/${path}`, {\n method: \"POST\",\n headers: sbHeaders(key),\n body: JSON.stringify({ expiresIn: seconds }),\n });\n if (!r.ok) throw new Error(`подпись ссылки: ${r.status}`);\n return url + \"/storage/v1\" + (await r.json()).signedURL;\n}\n\n/**\n * Слова, с которых начинается поручение для Claude, а не вопрос дежурной\n * модели. «Передай Клоду …» добавлено 1 сентября: владелец формулирует\n * поручения именно так, а бот их не узнавал — и очередь оставалась пустой.\n * Формы «клоду/клода/клот» — потому что Whisper склоняет и коверкает имя.\n */\nconst TASK_RE = /^((передай|скажи)[:,]?\\s+)?(задача|поручение|сделай|кл[аоу]{1,2}[дт][ауеы]?|claude)[:,\\s]/i;\n\nconst QUEUED_REPLY = (id: number) =>\n `Принял, поручение №${id}. Разберу в ближайший обход — отвечу сюда же.`;\n\n// «продолжи в [Крокус портал]: добавь выгрузку» — поручение-продолжение: сторож\n// найдёт последнюю сессию Claude Code владельца в папке проекта и продолжит её\n// (--resume), а не начнёт с нуля. Голосом двоеточие не произносят — запятая тоже\n// годится. С «план …» впереди это шаг плана — его разбирает hqCommand.\nconst CONTINUE_RE = /^продолжи(?:ть)?\\s*(?:сессию|чат|работу)?\\s*(?:в|по)?\\s*\\[?([^\\]:\\-—,]{2,60}?)\\]?\\s*[:\\-—,]\\s*([\\s\\S]{3,})$/i;\nasync function continueCmd(text: string, kind: string): Promise {\n const m = text.trim().match(CONTINUE_RE);\n if (!m) return null;\n const id = await inboxAdd({ kind, text: text.trim() });\n return `Принял, поручение №${id}: продолжу последнюю вашу сессию Claude Code в папке «${m[1].trim()}» — ` +\n `сторож заберёт в течение минуты и напишет, какую сессию продолжает. Итог придёт сюда же.`;\n}\n\n/**\n * Список открытого в очереди — ответ на «очередь»/«статус». Появился после\n * жалобы 1 сентября «не обнаруживает заданий»: владельцу нужен способ увидеть\n * своими глазами, что бот записал, не дожидаясь обхода.\n */\nasync function inboxList(): Promise {\n const { url, key } = sb();\n const r = await fetch(`${url}/rest/v1/${INBOX_TABLE}?status=in.(new,taken)&order=at.asc&limit=30`, { headers: sbHeaders(key) });\n if (!r.ok) throw new Error(`очередь поручений: ${r.status}`);\n const rows: any[] = await r.json();\n if (!rows.length) return \"Очередь пуста: открытых поручений и материалов нет.\";\n const lines = rows.map((row) =>\n `№${row.id} · ${row.kind}${row.status === \"taken\" ? \" · В РАБОТЕ\" : \"\"} · ${String(row.text ?? row.file_path ?? \"\").replace(/\\s+/g, \" \").slice(0, 90)}`\n );\n return `Открыто: ${rows.length}. Поручения Claude выполнит в ближайший обход; материалы и файлы он просто видит.\\n\\n` +\n lines.join(\"\\n\");\n}\n\n/** «отмени №12» — снять поручение с очереди, не выполняя. null — не про отмену. */\nasync function cancelCmd(text: string): Promise {\n const m = text.match(/^отмен[иа](?:ть)?\\s*(?:№|номер)?\\s*(\\d+)/i);\n if (!m) return null;\n const { url, key } = sb();\n const r = await fetch(`${url}/rest/v1/${INBOX_TABLE}?id=eq.${m[1]}&status=eq.new`, {\n method: \"PATCH\",\n headers: sbHeaders(key, { Prefer: \"return=representation\" }),\n body: JSON.stringify({ status: \"done\", reply: \"отменено владельцем\", done_at: new Date().toISOString() }),\n });\n const rows: any[] = r.ok ? await r.json() : [];\n return rows.length ? `Поручение №${m[1]} снято с очереди.` : `Открытого поручения №${m[1]} нет.`;\n}\n\n// ---------------------------------------------------------------------------\n// Сторож на компьютере владельца (tg-watch.ps1): раз в 20 секунд спрашивает\n// /tg/next, забирает поручение (status → taken), запускает Claude Code без окна\n// в папке проекта и закрывает поручение через tg_answer. Так поручение из\n// Telegram выполняется через секунды, а не через час, платит подписка, и у\n// исполнителя есть папки, venv и тесты — то, чего нет у облачного обходчика.\n// Обходчик остаётся запасным: он видит только new, а взятое и не закрытое за\n// два часа возвращается в new само.\n// ---------------------------------------------------------------------------\n\nconst TAKEN_STALE_MS = 2 * 3600 * 1000;\n\nasync function claimNext(): Promise {\n const { url, key } = sb();\n const stale = new Date(Date.now() - TAKEN_STALE_MS).toISOString();\n await fetch(`${url}/rest/v1/${INBOX_TABLE}?status=eq.taken&taken_at=lt.${encodeURIComponent(stale)}`, {\n method: \"PATCH\", headers: sbHeaders(key), body: JSON.stringify({ status: \"new\", taken_at: null }),\n }).catch(() => {});\n const kinds = `(${encodeURIComponent(\"задача\")},${encodeURIComponent(\"голос-задача\")})`;\n const r = await fetch(`${url}/rest/v1/${INBOX_TABLE}?status=eq.new&kind=in.${kinds}&order=at.asc&limit=1`, { headers: sbHeaders(key) });\n if (!r.ok) throw new Error(`очередь поручений: ${r.status}`);\n const rows: any[] = await r.json();\n if (!rows.length) return null;\n // Берём с условием status=eq.new: если опередил обходчик, строк не вернётся.\n const p = await fetch(`${url}/rest/v1/${INBOX_TABLE}?id=eq.${rows[0].id}&status=eq.new`, {\n method: \"PATCH\",\n headers: sbHeaders(key, { Prefer: \"return=representation\" }),\n body: JSON.stringify({ status: \"taken\", taken_at: new Date().toISOString() }),\n });\n const took: any[] = p.ok ? await p.json() : [];\n return took.length ? took[0] : null;\n}\n\nasync function inboxRow(id: string): Promise {\n const { url, key } = sb();\n const r = await fetch(`${url}/rest/v1/${INBOX_TABLE}?id=eq.${encodeURIComponent(id)}&select=id,at,kind,text,status,reply,done_at,taken_at`, { headers: sbHeaders(key) });\n const rows: any[] = r.ok ? await r.json() : [];\n return rows[0] ?? null;\n}\n\nasync function releaseTask(id: string): Promise {\n const { url, key } = sb();\n const r = await fetch(`${url}/rest/v1/${INBOX_TABLE}?id=eq.${encodeURIComponent(id)}&status=eq.taken`, {\n method: \"PATCH\", headers: sbHeaders(key, { Prefer: \"return=representation\" }),\n body: JSON.stringify({ status: \"new\", taken_at: null }),\n });\n const rows: any[] = r.ok ? await r.json() : [];\n return rows.length > 0;\n}\n\nexport const TG_TOOLS = [\n {\n name: \"tg_inbox\",\n description:\n \"Входящие из Telegram: поручения и файлы, которые владелец прислал боту сети. \" +\n \"Вызывайте в начале обхода и когда владелец говорит «посмотри, что я кидал в телеграм». \" +\n \"Возвращает записи со статусом new: текст поручения, для файлов — подписанную ссылку \" +\n \"на час (её можно отдать read_document для распознавания) и картинки прямо в ответе. \" +\n \"Виды записей: «задача» и «голос-задача» — явные поручения, их надо выполнить и закрыть \" +\n \"через tg_answer с номером. «файл» и «материал» (пересланные сообщения и голосовые) — \" +\n \"хранилище и контекст: без явного поручения их НЕ выполнять и не отвечать по каждому; \" +\n \"используйте как материал к задачам и закрывайте вместе с задачей, к которой они \" +\n \"относятся, иначе оставляйте открытыми.\",\n inputSchema: {\n type: \"object\",\n properties: {\n status: { type: \"string\", enum: [\"new\", \"done\"], description: \"По умолчанию new.\" },\n limit: { type: \"number\", description: \"Сколько записей вернуть. По умолчанию 20.\" },\n },\n },\n },\n {\n name: \"tg_answer\",\n description:\n \"Ответить владельцу в Telegram от имени бота сети и, если указан id, закрыть \" +\n \"поручение из tg_inbox. Пишите по-русски и по делу: это личный чат владельца. \" +\n \"Для поручений с необратимыми последствиями (деньги, удаление, отправка клиентам) \" +\n \"не выполняйте молча — ответьте вопросом и оставьте поручение открытым.\",\n inputSchema: {\n type: \"object\",\n properties: {\n reply: { type: \"string\", description: \"Текст ответа владельцу.\" },\n id: { type: \"number\", description: \"Номер поручения, которое этот ответ закрывает.\" },\n },\n required: [\"reply\"],\n },\n },\n {\n name: \"tg_task\",\n description:\n \"Поставить поручение в очередь tg_inbox — так же, как это делает владелец из Telegram. \" +\n \"Для задач по расписанию (ревизия, проверка бюджетов): нашли конкретную починяемую поломку \" +\n \"шлюза — не описывайте её в отчёте, а положите поручением с точной инструкцией, обходчик \" +\n \"выполнит в ближайший час. Владелец получает уведомление в Telegram.\",\n inputSchema: {\n type: \"object\",\n properties: {\n text: { type: \"string\", description: \"Что сделать — точно и самодостаточно: файл, строка, чем заменить, как проверить.\" },\n source: { type: \"string\", description: \"Кто ставит: «ревизия», «проверка бюджетов», имя сессии. Попадёт в текст поручения.\" },\n },\n required: [\"text\"],\n },\n },\n {\n name: \"tg_probe\",\n description:\n \"Проверить живой разговор бота: прогнать сообщение через Claude с инструментами сети так, \" +\n \"как это делает Telegram, и вернуть ответ, НЕ отправляя его владельцу. Для отладки и самопроверки.\",\n inputSchema: {\n type: \"object\",\n properties: { text: { type: \"string\", description: \"Сообщение от имени владельца.\" } },\n required: [\"text\"],\n },\n },\n {\n name: \"tg_status\",\n description:\n \"Самопроверка телеграм-входа. Вызывайте при жалобе «бот не отвечает» или \" +\n \"«Клод не видит, что я пишу в телеграм»: покажет, прописан ли вебхук, копятся ли \" +\n \"у Telegram недоставленные обновления, какая ошибка вебхука была последней, \" +\n \"задан ли владелец и что лежит в очереди последним. Токенов не раскрывает.\",\n inputSchema: { type: \"object\", properties: {} },\n },\n ...HQ_TOOLS,\n];\n\nexport async function handleTgTools(name: string, args: any, text: (s: string) => any) {\n const hq = await handleHqTools(name, args ?? {}, text, ownerNotify);\n if (hq) return hq;\n if (name === \"tg_inbox\") {\n const { url, key } = sb();\n const status = args?.status === \"done\" ? \"done\" : \"new\";\n const limit = Math.min(Number(args?.limit ?? 20), 50);\n const r = await fetch(\n `${url}/rest/v1/${INBOX_TABLE}?status=eq.${status}&order=at.asc&limit=${limit}`,\n { headers: sbHeaders(key) },\n );\n if (!r.ok) throw new Error(`очередь поручений: ${r.status}`);\n const rows: any[] = await r.json();\n if (!rows.length) return text(`Входящих со статусом «${status}» нет.`);\n\n const parts: any[] = [];\n const lines: string[] = [];\n for (const row of rows) {\n let line = `№${row.id} · ${String(row.at).slice(0, 16).replace(\"T\", \" \")} · ${row.kind}`;\n if (row.text) line += `\\n${row.text}`;\n if (row.file_path) {\n const u = await signedUrl(row.file_path);\n line += `\\nфайл (${row.mime ?? \"?\"}), ссылка на час: ${u}`;\n if (/^image\\//.test(row.mime ?? \"\")) {\n try {\n const img = await fetch(u);\n const bytes = new Uint8Array(await img.arrayBuffer());\n if (bytes.length <= 3 * 1024 * 1024) {\n parts.push({ type: \"image\", data: b64(bytes), mimeType: row.mime });\n }\n } catch { /* картинка не открылась — останется ссылка */ }\n }\n }\n lines.push(line);\n }\n return {\n content: [\n {\n type: \"text\",\n text: `Входящих: ${rows.length}. Разобранное закрывайте через tg_answer с номером.\\n\\n` +\n lines.join(\"\\n\\n\"),\n },\n ...parts,\n ],\n };\n }\n\n if (name === \"tg_task\") {\n if (!args?.text) throw new Error(\"Обязательный параметр: text\");\n const source = String(args.source ?? \"сеть\").trim();\n const body = `[${source}] ${String(args.text).trim()}`;\n const id = await inboxAdd({ kind: \"задача\", text: body });\n // Владельцу — коротко: он должен знать, что сеть сама поставила себе работу.\n const botToken = cleanBotToken();\n const owner = env(\"TG_OWNER_CHAT_ID\");\n if (botToken && owner) {\n await say(botToken, String(owner), `Сеть поставила поручение №${id} (${source}): ${String(args.text).trim().slice(0, 300)}\\n\\nОбходчик выполнит в ближайший час; чтобы отменить — напишите «отмени №${id}».`).catch(() => {});\n }\n return text(`Поручение №${id} поставлено в очередь (${source}).`);\n }\n\n if (name === \"tg_probe\") {\n if (!args?.text) throw new Error(\"Обязательный параметр: text\");\n if (!chatEnabled()) return text(\"Живой разговор выключен: нет ANTHROPIC_API_KEY или TG_CHAT=off.\");\n const started = Date.now();\n const reply = await chatTurn({ text: String(args.text), origin: lastOrigin, trace: newTrace() });\n return text(`[${Date.now() - started} мс]\\n${reply}`);\n }\n\n if (name === \"tg_status\") {\n const botToken = cleanBotToken();\n if (!botToken) return text(\"Не задан TG_AI_BOT_TOKEN — вход выключен.\");\n const wh: any = await tgApi(botToken, \"getWebhookInfo\", {});\n const { url, key } = sb();\n const q = await fetch(`${url}/rest/v1/${INBOX_TABLE}?select=id,kind,status,at&order=at.desc&limit=10`, { headers: sbHeaders(key) });\n const rows: any[] = q.ok ? await q.json() : [];\n const owner = env(\"TG_OWNER_CHAT_ID\");\n const lines = [\n `вебхук: ${wh.url ? wh.url : \"НЕ ПРОПИСАН — сообщения никуда не приходят, нужен повторный /tg/setup\"}`,\n `недоставленных обновлений у Telegram: ${wh.pending_update_count ?? 0}`,\n wh.last_error_date\n ? `последняя ошибка вебхука: ${new Date(wh.last_error_date * 1000).toISOString().slice(0, 16).replace(\"T\", \" \")} UTC — ${String(wh.last_error_message ?? \"\").slice(0, 300)}`\n : \"ошибок вебхука Telegram не помнит\",\n `владелец TG_OWNER_CHAT_ID: ${owner ? \"задан\" : \"НЕ задан — бот никому не отвечает\"}`,\n `очередь (свежие): ${rows.length ? rows.map((row) => `№${row.id} ${row.kind}/${row.status}`).join(\", \") : \"пуста\"}`,\n ];\n return text(\"Самопроверка телеграм-входа:\\n\" + lines.join(\"\\n\"));\n }\n\n if (name !== \"tg_answer\") return null;\n if (!args?.reply) throw new Error(\"Обязательный параметр: reply\");\n const botToken = cleanBotToken();\n const owner = env(\"TG_OWNER_CHAT_ID\");\n if (!botToken || !owner) throw new Error(\"Не заданы TG_AI_BOT_TOKEN или TG_OWNER_CHAT_ID\");\n await say(botToken, String(owner), String(args.reply));\n if (args.id != null) {\n const { url, key } = sb();\n await fetch(`${url}/rest/v1/${INBOX_TABLE}?id=eq.${encodeURIComponent(String(args.id))}`, {\n method: \"PATCH\",\n headers: sbHeaders(key),\n body: JSON.stringify({ status: \"done\", reply: String(args.reply).slice(0, 2000), done_at: new Date().toISOString() }),\n });\n }\n return text(\n args.id != null\n ? `Отправлено владельцу, поручение №${args.id} закрыто.`\n : \"Отправлено владельцу.\",\n );\n}\n\nconst HELP = `Это вход в агентскую сеть UM Group.\n\nПишите или говорите как человеку — отвечает Claude сразу, с памятью\nсети и её инструментами. Что нельзя сделать с телефона (компьютер,\nпапки проектов, долгая работа) — он сам ставит поручением и называет\nномер; выполнит обходчик в ближайший час. Слово «очередь» — что\nзаписано и ещё не разобрано; «отмени №N» — снимет.\n\nВсё остальное — хранилище для Claude: пересланные сообщения\nи голосовые, документы и фото сохраняю во входящие, он видит их\nиз любой сессии. Сам с ними ничего не делаю, пока не поручите.\n\n«запомни: …» / «вспомни …» — долговременная память сети.\nСвой вопрос текстом или голосом — быстрый ответ дежурной бесплатной\nмодели. Аудиофайл — верну расшифровку (для казахского — слово\n«казахский» в подписи).\n\nШтаб — план дня по проектам: «план: …» — штаб предложит шаги;\n«план ок» — запуск, «план правка: …» — перепланировать; шаги с 🔎\nпридут на проверку: «шаг N ок» / «шаг N: что исправить»; «штаб» —\nсостояние, «стоп план» — отмена. Выполняет Claude Code на компьютере.\n«продолжи в [Папка проекта]: что сделать» — продолжить вашу последнюю\nсессию Claude Code в этой папке (доработка программы, правки), сразу.`;\n\n/** «запомни …» / «вспомни …» — обращение к памяти сети. null — не про память. */\nasync function memoryCmd(text: string, trace: string, started: number): Promise {\n const mem = text.match(/^(запомни|вспомни)[:,]?\\s+(.+)/is);\n if (!mem) return null;\n const kind = mem[1].toLowerCase();\n const wrap = (s: string) => ({ content: [{ type: \"text\", text: s }] });\n const res: any = kind === \"запомни\"\n ? await handleMemory(\"remember\", { text: mem[2] }, wrap)\n : await handleMemory(\"recall\", { query: mem[2], top: 5 }, wrap);\n void logCall({ trace, tool: \"tg:\" + (kind === \"запомни\" ? \"remember\" : \"recall\"), ms: Date.now() - started, note: text.slice(0, 80), project: \"Телеграм\" });\n // Подпись про инструмент rules в чужом интерфейсе только путает — срезаем.\n return String(res.content[0].text).split(\"\\n\\n—\\n\")[0];\n}\n\n/**\n * Предел ожидания исполнителя. Замер 3 сентября: голосовое расшифровалось,\n * а дальше — тишина: ни ответа, ни ошибки, ни строки в журнале. Похоже на\n * зависший вызов, убитый средой по лимиту времени. С пределом зависание\n * превращается в честную ошибку, которая доходит и до журнала, и до владельца.\n */\nfunction withDeadline(p: Promise, ms: number): Promise {\n return Promise.race([\n p,\n new Promise((_, rej) =>\n setTimeout(() =>\n rej(new Error(`исполнители не ответили за ${Math.round(ms / 1000)} секунд — попробуйте ещё раз`)), ms)\n ),\n ]);\n}\n\n// Намерение своего сообщения: поручение, вопрос или заметка.\n//\n// Замер 6 сентября: владелец наговорил «Сообщи мне, когда будут закончены текущие\n// задачи…» — это поручение, но без слов «передай Клоду/сделай» бот отдал его\n// дежурной модели как вопрос, и оно пропало. Ключевые слова — слишком узкое сито.\n// Теперь: повелительное наклонение → поручение; вопросительное слово или «?» →\n// вопрос; остальное решает быстрый классификатор (groq, ~60 мс), а при его отказе\n// считаем поручением — поручение видно в очереди и снимается словом «отмени»,\n// а проглоченное поручение не видно нигде.\n// \\b с кириллицей в JS не работает (замер 1 сентября), поэтому границы — явные.\n// Замер 6 сентября (вечер): «Ну давай протестируем задание, посмотреть статус\n// проекта…?» ушло вопросом — «ну» перед «давай» ломало якорь ^, а «?» в конце\n// (Whisper ставит его сам) добил. Теперь вводные слова срезаются, форма «давай\n// сделаем/проверим» — поручение, и повелительное сильнее знака вопроса.\nconst FILLER_RE = /^(ну|так|слушай|слушайте|окей|ок|ладно|значит|вот|и|а|короче|итак|привет|здравствуй|здравствуйте|клод|claude|пожалуйста)[,!.\\s]+/i;\nconst IMPERATIVE_RE =\n /^(сообщи|сделай|проверь|собери|напиши|отправь|посчитай|подготовь|найди|составь|обнови|запусти|посмотри|разбери|создай|исправь|почини|переведи|расшифруй|напомни|сравни|выясни|узнай|организуй|добавь|удали|перенеси|подготовьте|дай знать|держи в курсе|нужно|надо|необходимо|прошу|давай|давайте|протестируй|протестируем|проверим|посмотрим|соберём|соберем|сделаем|подготовим|напишем|выполни|скинь|пришли|запиши|поставь|настрой|включи|выключи|подключи|прогони|выложи|опубликуй|разберись|подумай|предложи)(?=[\\s,:!.-]|$)/i;\nconst QUESTION_RE =\n /^(что|как|сколько|почему|зачем|где|когда|кто|кого|кому|какой|какая|какие|каков|есть ли|можно ли|а )(?=[\\s,?]|$)/i;\n\nfunction stripFillers(text: string): string {\n let t = text.trim();\n for (let i = 0; i < 4; i++) {\n const n = t.replace(FILLER_RE, \"\");\n if (n === t) break;\n t = n;\n }\n return t;\n}\n\nasync function intentOf(raw: string, trace: string): Promise<\"task\" | \"question\" | \"note\"> {\n const text = stripFillers(raw);\n if (TASK_RE.test(raw) || TASK_RE.test(text) || IMPERATIVE_RE.test(text)) return \"task\";\n if (QUESTION_RE.test(text) || /\\?\\s*$/.test(text)) return \"question\";\n try {\n const r = await withDeadline(ask({\n provider: \"groq\",\n tier: \"fast\",\n max_tokens: 40,\n temperature: 0,\n system: \"Владелец пишет своему ассистенту. Ответь ОДНИМ словом: ПОРУЧЕНИЕ — просит что-то сделать, проверить, собрать, напомнить, сообщить позже; ВОПРОС — хочет получить ответ прямо сейчас; ЗАМЕТКА — просто делится информацией без просьбы.\",\n prompt: text.slice(0, 500),\n note: \"намерение: \" + text.slice(0, 40),\n project: \"Телеграм\",\n trace,\n } as any), 6000);\n const v = String(r.text).toLowerCase();\n if (/вопрос/.test(v)) return \"question\";\n if (/заметк/.test(v)) return \"note\";\n return \"task\";\n } catch {\n return \"task\";\n }\n}\n\n/**\n * Живой ответ Claude (tgchat.ts). null — не получилось: ключа нет, потолок,\n * отказ API или не уложились в предел вебхука; тогда работает прежняя схема\n * (вопрос → бесплатная модель, поручение → очередь). Сбой — в журнал с await.\n */\nasync function liveReply(text: string, trace: string): Promise {\n try {\n return await withDeadline(chatTurn({ text, origin: lastOrigin, trace }), 50000);\n } catch (e: any) {\n const masked = String(e?.message || e).replace(/sk-ant-[\\w-]+/g, \"<скрыто>\").slice(0, 300);\n await logCall({ trace, tool: \"tg:чат-сбой\", status: \"error\", error: masked, project: \"Телеграм\" }).catch(() => {});\n return null;\n }\n}\n\n/** Разбор одного сообщения. Ошибки уходят владельцу текстом, не в пустоту. */\nasync function handleMessage(botToken: string, msg: any) {\n const chatId = String(msg.chat.id);\n const trace = newTrace();\n const started = Date.now();\n\n const media = msg.voice ?? msg.audio ?? msg.video_note ??\n (msg.document && /^audio\\//.test(msg.document.mime_type ?? \"\") ? msg.document : null);\n\n try {\n if (media) {\n if ((media.file_size ?? 0) > MAX_FILE) {\n await say(botToken, chatId, `Файл ${(media.file_size / 1048576).toFixed(1)} МБ, а Telegram отдаёт ботам до 20. Положите запись в папку «Записи на расшифровку» на Диске.`);\n return;\n }\n const info = await tgApi(botToken, \"getFile\", { file_id: media.file_id });\n const raw = await fetch(`${API}/file/bot${botToken}/${info.file_path}`);\n if (!raw.ok) throw new Error(`не скачался файл: ${raw.status}`);\n const bytes = new Uint8Array(await raw.arrayBuffer());\n const kk = /казах/i.test(msg.caption ?? \"\");\n // Словарь для Whisper: имена проектов и терминов, иначе «Битрикс24» приходит\n // как «ВАЗАП-24» (замер 6 сентября). Дополняется переменной TG_VOICE_TERMS.\n const r = await transcribe({ base64: b64(bytes), language: kk ? \"kk\" : \"ru\", prompt: voiceTerms() });\n void logCall({ trace, tool: \"tg:расшифровка\", provider: r.provider, ms: Date.now() - started, note: \"голосовое из Telegram\", project: \"Телеграм\" });\n const spoken = r.text.trim();\n\n // Пересланное чужое голосовое — материал для Claude, а не разговор с ботом:\n // владелец скидывает переписку, чтобы Claude её видел (замер 1 сентября —\n // бот вместо этого возвращал транскрипты и болтал, очередь оставалась\n // пустой). Расшифровка кладётся в очередь, в ответ — короткое подтверждение.\n const forwarded = !!(msg.forward_origin || msg.forward_from || msg.forward_sender_name || msg.forward_date);\n if (forwarded) {\n const id = await inboxAdd({ kind: \"материал\", text: \"Пересланное голосовое, расшифровка:\\n\" + spoken });\n await say(botToken, chatId, `Сохранил, №${id}. Расшифровка: «${spoken.slice(0, 400)}${spoken.length > 400 ? \"…\" : \"\"}»`);\n return;\n }\n\n // Своё голосовое — сказанная вслух команда, а не заказ на транскрипт.\n // Транскрипт как ответ остаётся аудиофайлам — их присылают ради текста.\n const isOwnSpeech = !!(msg.voice || msg.video_note);\n\n if (isOwnSpeech) {\n const cont = await continueCmd(spoken, \"голос-продолжение\");\n if (cont !== null) {\n await say(botToken, chatId, `Понял так: «${spoken.slice(0, 3000)}»\\n\\n` + cont);\n return;\n }\n const hqAns = await hqCommand(spoken, ownerNotify);\n if (hqAns !== null) {\n await feedTalk(spoken, hqAns, \"tg-voice\");\n await say(botToken, chatId, hqAns);\n return;\n }\n }\n const memAns = await memoryCmd(spoken, trace, started);\n if (memAns !== null) {\n await say(botToken, chatId, memAns);\n return;\n }\n if (/^(очередь|статус)\\s*[?.!]*$/i.test(spoken)) {\n await say(botToken, chatId, await inboxList());\n return;\n }\n // Разговор со штабом: пока есть активный план, своё сообщение читает штаб\n // (бесплатная модель со состоянием планов) — отвечает и выполняет решения.\n if (isOwnSpeech) {\n const dlg = await withDeadline(hqDialog(spoken, ownerNotify, trace), 40000).catch(() => null);\n if (dlg !== null) {\n void logCall({ trace, tool: \"tg:штаб-диалог\", ms: Date.now() - started, note: spoken.slice(0, 80), project: \"Штаб\" });\n await feedTalk(spoken, dlg, \"tg-voice\");\n await say(botToken, chatId, dlg);\n return;\n }\n }\n if (isOwnSpeech && chatEnabled()) {\n const live = await liveReply(spoken, trace);\n if (live !== null) {\n await say(botToken, chatId, live);\n return;\n }\n }\n const spokenIntent = isOwnSpeech ? await intentOf(spoken, trace) : \"question\";\n if (spokenIntent === \"task\") {\n const id = await inboxAdd({ kind: \"голос-задача\", text: spoken });\n // Показываем расшифровку целиком: обрезка до 300 знаков читалась как\n // «бот не всё расшифровал» (жалоба 8 сентября).\n await say(botToken, chatId, `Понял так: «${spoken.slice(0, 3000)}»\\n\\n` + QUEUED_REPLY(id));\n return;\n }\n if (spokenIntent === \"note\") {\n const id = await inboxAdd({ kind: \"материал\", text: spoken });\n // Та же обрезка, что у поручения, и та же жалоба: надиктованная заметка\n // длиннее 200 знаков возвращалась куском, будто расшифровалась не вся.\n await say(botToken, chatId, `Записал как заметку, №${id}: «${spoken.slice(0, 3000)}»`);\n return;\n }\n if (isOwnSpeech) {\n const ans = await withDeadline(ask({\n // gemini названо явно: автоподбор уводил живой чат на qwen (p50 22 с,\n // ревизия 6 сентября), а у gemini ~1,5 с; при 429 шлюз сам подменит.\n provider: \"gemini\",\n tier: \"fast\",\n prompt: spoken,\n system: \"Ты — вход в рабочую сеть UM Group (Караганда). Вопрос надиктован голосом, в расшифровке возможны огрехи — понимай по смыслу. Отвечай по-русски, коротко и по делу: ответ уходит в Telegram.\",\n max_tokens: 1200,\n note: \"голосовой вопрос из Telegram: \" + spoken.slice(0, 60),\n project: \"Телеграм\",\n trace,\n } as any), 45000);\n await say(botToken, chatId, ans.text);\n return;\n }\n await say(botToken, chatId, r.text);\n return;\n }\n\n // Документ или фото — во входящие: закрытая корзина + строка в очереди.\n const doc = msg.document && !/^audio\\//.test(msg.document.mime_type ?? \"\") ? msg.document : null;\n const photo = Array.isArray(msg.photo) && msg.photo.length ? msg.photo[msg.photo.length - 1] : null;\n const incoming = doc ?? photo;\n if (incoming) {\n if ((incoming.file_size ?? 0) > MAX_FILE) {\n await say(botToken, chatId, \"Файл больше 20 МБ — Telegram не отдаёт такие ботам. Положите его в папку на Диске.\");\n return;\n }\n const info = await tgApi(botToken, \"getFile\", { file_id: incoming.file_id });\n const raw = await fetch(`${API}/file/bot${botToken}/${info.file_path}`);\n if (!raw.ok) throw new Error(`не скачался файл: ${raw.status}`);\n const bytes = new Uint8Array(await raw.arrayBuffer());\n const mime = doc?.mime_type ?? \"image/jpeg\";\n const orig = String(doc?.file_name ?? \"photo.jpg\").replace(/[^A-Za-z0-9а-яА-ЯёЁ._-]/g, \"_\").slice(-60);\n const path = `${Date.now()}-${orig}`;\n await storagePut(path, bytes, mime);\n const id = await inboxAdd({ kind: \"файл\", text: (msg.caption ?? \"\").trim() || undefined, file_path: path, mime });\n void logCall({ trace, tool: \"tg:файл\", ms: Date.now() - started, note: orig, project: \"Телеграм\" });\n await say(botToken, chatId, `Файл принял, №${id}` + (msg.caption ? \" (подпись сохранил)\" : \"\") + \". Посмотрю в ближайший обход.\");\n return;\n }\n\n const text = String(msg.text ?? \"\").trim();\n if (!text) return;\n\n // Пересланный чужой текст — материал для Claude, не вопрос боту: отвечать\n // моделью на реплики из чужой переписки бессмысленно (замер 1 сентября).\n const fwd = !!(msg.forward_origin || msg.forward_from || msg.forward_sender_name || msg.forward_date);\n if (fwd) {\n const id = await inboxAdd({ kind: \"материал\", text });\n void logCall({ trace, tool: \"tg:материал\", ms: Date.now() - started, note: text.slice(0, 80), project: \"Телеграм\" });\n await say(botToken, chatId, `Сохранил, №${id}.`);\n return;\n }\n\n if (/^\\/(start|help)/.test(text) || /^помощь$/i.test(text)) {\n await say(botToken, chatId, HELP);\n return;\n }\n\n if (/^(очередь|статус)\\s*[?.!]*$/i.test(text)) {\n await say(botToken, chatId, await inboxList());\n return;\n }\n const cancelled = await cancelCmd(text);\n if (cancelled !== null) {\n await say(botToken, chatId, cancelled);\n return;\n }\n\n const cont = await continueCmd(text, \"продолжение\");\n if (cont !== null) {\n void logCall({ trace, tool: \"tg:продолжение\", ms: Date.now() - started, note: text.slice(0, 80), project: \"Телеграм\" });\n await say(botToken, chatId, cont);\n return;\n }\n\n const hqAnswer = await hqCommand(text, ownerNotify);\n if (hqAnswer !== null) {\n void logCall({ trace, tool: \"tg:штаб\", ms: Date.now() - started, note: text.slice(0, 80), project: \"Телеграм\" });\n await feedTalk(text, hqAnswer, \"tg\");\n await say(botToken, chatId, hqAnswer);\n return;\n }\n\n const memAnswer = await memoryCmd(text, trace, started);\n if (memAnswer !== null) {\n await say(botToken, chatId, memAnswer);\n return;\n }\n\n const dlg = await withDeadline(hqDialog(text, ownerNotify, trace), 40000).catch(() => null);\n if (dlg !== null) {\n void logCall({ trace, tool: \"tg:штаб-диалог\", ms: Date.now() - started, note: text.slice(0, 80), project: \"Штаб\" });\n await feedTalk(text, dlg, \"tg\");\n await say(botToken, chatId, dlg);\n return;\n }\n\n if (chatEnabled()) {\n const live = await liveReply(text, trace);\n if (live !== null) {\n await say(botToken, chatId, live);\n return;\n }\n }\n const intent = await intentOf(text, trace);\n if (intent === \"task\") {\n const id = await inboxAdd({ kind: \"задача\", text });\n void logCall({ trace, tool: \"tg:задача\", ms: Date.now() - started, note: text.slice(0, 80), project: \"Телеграм\" });\n await say(botToken, chatId, QUEUED_REPLY(id));\n return;\n }\n if (intent === \"note\") {\n const id = await inboxAdd({ kind: \"материал\", text });\n await say(botToken, chatId, `Записал как заметку, №${id}.`);\n return;\n }\n\n const r = await withDeadline(ask({\n provider: \"gemini\",\n tier: \"fast\",\n prompt: text,\n system: \"Ты — вход в рабочую сеть UM Group (Караганда). Отвечай по-русски, коротко и по делу: ответ уходит в Telegram.\",\n max_tokens: 1200,\n note: \"вопрос из Telegram: \" + text.slice(0, 60),\n project: \"Телеграм\",\n trace,\n } as any), 45000);\n await say(botToken, chatId, r.text);\n } catch (e: any) {\n const masked = String(e?.message || e).replace(/bot\\d+:[\\w-]+/g, \"bot<скрыто>\");\n // Журнал — с ожиданием: брошенная без await запись теряется, когда среда\n // закрывает вызов сразу после ответа (пропавший сбой 3 сентября).\n await logCall({ trace, tool: \"tg:сбой\", status: \"error\", ms: Date.now() - started, error: masked.slice(0, 300), project: \"Телеграм\" }).catch(() => {});\n await say(botToken, chatId, \"Не получилось: \" + masked.slice(0, 500)).catch(() => {});\n }\n}\n\nexport async function handleTelegram(req: Request, url: URL): Promise {\n if (url.pathname.startsWith(\"/hq/\")) return await handleHqHttp(req, url, ownerNotify);\n if (!url.pathname.startsWith(\"/tg/\")) return null;\n lastOrigin = url.origin;\n const botToken = cleanBotToken();\n if (!botToken) {\n return json({ error: \"Не задана переменная TG_AI_BOT_TOKEN в вале — нужен отдельный бот для сети, клиентского из TELEGRAM_BOT_TOKEN не трогаем\" }, 503);\n }\n\n // Разовая настройка: прописать вебхук у Telegram. Защищено токеном шлюза —\n // тем же способом, каким защищена панель.\n if (url.pathname === \"/tg/setup\") {\n if (url.searchParams.get(\"key\") !== env(\"GATEWAY_TOKEN\")) {\n return json({ error: \"нужен ?key=GATEWAY_TOKEN\" }, 403);\n }\n // Если Telegram не признал токен, отдать диагностику ФОРМЫ значения,\n // не показывая само значение: этого хватает, чтобы найти мусор вставки.\n let me: any;\n try {\n me = await tgApi(botToken, \"getMe\", {});\n } catch (e: any) {\n return json({\n error: \"Telegram не принял токен: \" + String(e?.message || e),\n shape: {\n length: botToken.length,\n colon: botToken.includes(\":\"),\n starts_with_digits: /^\\d+:/.test(botToken),\n has_whitespace_inside: /\\s/.test(botToken),\n looks_like_token: /^\\d{5,}:[A-Za-z0-9_-]{25,}$/.test(botToken),\n },\n hint: \"Сотрите значение TG_AI_BOT_TOKEN в вале и впечатайте заново: только цифры, двоеточие и хвост, без кавычек, пробелов и приставки bot.\",\n }, 502);\n }\n await tgApi(botToken, \"setWebhook\", {\n url: `${url.origin}/tg/hook`,\n secret_token: await hookSecret(botToken),\n allowed_updates: [\"message\"],\n drop_pending_updates: true,\n });\n const owner = env(\"TG_OWNER_CHAT_ID\");\n return json({\n ok: true,\n bot: \"@\" + me.username,\n webhook: `${url.origin}/tg/hook`,\n owner: owner ? \"задан\" : \"НЕ задан: напишите боту, он сообщит ваш chat id (переменная TG_OWNER_CHAT_ID)\",\n });\n }\n\n // Сторож на компьютере: /tg/next — взять следующее поручение, /tg/row — его\n // состояние, /tg/release — вернуть в очередь. Под токеном шлюза, как панель.\n if (url.pathname === \"/tg/next\" || url.pathname === \"/tg/row\" || url.pathname === \"/tg/release\") {\n if (url.searchParams.get(\"key\") !== env(\"GATEWAY_TOKEN\")) return json({ error: \"нужен ?key=GATEWAY_TOKEN\" }, 403);\n if (url.pathname === \"/tg/next\") {\n const row = await claimNext();\n return row ? json({ id: row.id, kind: row.kind, text: row.text, at: row.at }) : new Response(null, { status: 204 });\n }\n const id = url.searchParams.get(\"id\") ?? \"\";\n if (!/^\\d+$/.test(id)) return json({ error: \"нужен id\" }, 400);\n if (url.pathname === \"/tg/row\") {\n const row = await inboxRow(id);\n return row ? json(row) : json({ error: \"нет такого поручения\" }, 404);\n }\n return json({ released: await releaseTask(id) });\n }\n\n if (url.pathname === \"/tg/hook\" && req.method === \"POST\") {\n const got = req.headers.get(\"X-Telegram-Bot-Api-Secret-Token\") ?? \"\";\n if (got !== await hookSecret(botToken)) return json({ error: \"чужой\" }, 403);\n\n const update: any = await req.json().catch(() => null);\n const msg = update?.message;\n // Всегда 200: иначе Telegram будет бесконечно повторять то, что нам не нужно.\n if (!msg?.chat) return json({ ok: true });\n\n const chatId = String(msg.chat.id);\n // Группы не обслуживаем: бот сидит в группе отчётов Битрикса, и каждое\n // сообщение там долетает сюда. Молча пропускаем, в журнал не пишем —\n // иначе журнал утонет в чужих репликах.\n if (msg.chat.type !== \"private\") return json({ ok: true });\n\n const owner = env(\"TG_OWNER_CHAT_ID\");\n if (!owner) {\n await say(botToken, chatId, `Ваш chat id: ${chatId}\\nДобавьте его в переменные вала как TG_OWNER_CHAT_ID — после этого бот будет отвечать только вам.`);\n return json({ ok: true });\n }\n if (chatId !== String(owner)) {\n void logCall({ trace: \"tg\", tool: \"tg:чужой\", status: \"error\", error: \"личное сообщение с чужого chat id\", project: \"Телеграм\" });\n return json({ ok: true });\n }\n await handleMessage(botToken, msg);\n return json({ ok: true });\n }\n\n return json({ error: \"нет такого адреса\" }, 404);\n}\n","deleted",false,"label",[14],"f04cc041-3bf4-4db7-a7ca-6638165c8d3d",["D",1785495035570],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","MCP gateway to external LLM providers","imageUrl","userId","ce244983-5dfc-4662-ad1a-ca34d2e798a0","pinnedFileId","bfdf3532-8cce-11f1-80cf-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa853-4d22-71bf-b5fe-af55df9678e6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_103":99},"org",{"_9":10,"_96":97,"_98":99,"_55":56,"_100":101,"_102":42},"branch",{"_36":86,"_11":87,"_23":29,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":12,"_95":10},"isOwned",293,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","umgroupkz-commits","avatar","https://avatars.githubusercontent.com/u/279207781?v=4","tier","free","canRestrictVals","profileImageUrl","ctx",{"_79":-5,"_137":138,"_139":140,"_141":142,"_143":42,"_144":42,"_145":42,"_146":33,"_147":-5,"_148":-7,"_149":-7,"_150":63,"_151":42,"_152":42,"_153":-5,"_154":42,"_155":42,"_156":42,"_157":-5},"ENV",{"_108":109,"_110":111,"_112":87,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]