[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_455":456,"_457":458},"routes/_app.x.$handle.$name",{"_96":95,"_31":44,"_105":86,"_26":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":24,"_120":121,"_122":58,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":24},"version",35,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","src/dash/assets/radar.ts","latestPath","fileId","48bbe6f2-ab4c-11f1-a3cd-1607ee4eb77e","name","radar.ts","fileType","script","content","/** Фильтры, сортировка, отрисовщики верхних панелей и таблицы, карточка обращения. */\nexport const ЧАСТЬ_РАДАР: string =\n `// Стадии, на которых сделка закрыта (совпадает с ЗАКРЫТЫЕ_СТАДИИ на сервере,\n// но клиенту известен только признак «закрыта», а не код стадии — победу от\n// проигрыша различить на этих данных нельзя, см. примечание у sc/dc ниже).\nconst CLOSED = (r) => r.закрыта;\n\nconst fm = document.getElementById(\"fm\"), fs = document.getElementById(\"fs\"),\n fg = document.getElementById(\"fg\"), ft = document.getElementById(\"ft\"),\n fq = document.getElementById(\"fq\");\n\n[...new Set(д.строки.map((r) => r.дата.slice(0, 7)))].sort().forEach((m) => fm.add(new Option(m, m)));\n[...new Set(д.строки.map((r) => r.источник))].sort().forEach((s) => fs.add(new Option(s, s)));\n[...new Set(д.строки.map((r) => r.менеджер))].sort().forEach((g) => fg.add(new Option(g, g)));\n\ndocument.getElementById(\"радар-sub\").textContent =\n \\`Воронка ОП ГПМ · источники, отмеченные как рекламные: \\${д.источники.map((s) => s.ключ).join(\", \") || \"—\"} · собрано \\${новаяДата(д.собран)}\\`;\n\nfunction новаяДата(iso) {\n const d = new Date(iso);\n return Number.isNaN(d.getTime()) ? iso : d.toLocaleDateString(\"ru-RU\");\n}\n\nfunction filteredRows() {\n const q = fq.value.trim().toLowerCase();\n return д.строки.filter((r) => {\n if (fm.value && r.дата.slice(0, 7) !== fm.value) return false;\n if (fs.value && r.источник !== fs.value) return false;\n if (fg.value && r.менеджер !== fg.value) return false;\n // «Дошёл до сделки» читает то же поле, что и шапка/воронка на сервере\n // (дошлоДоСделки), а не наличие сделки заново — иначе на CONVERTED-лиде\n // без связанной сделки число в шапке и число строк в таблице расходятся\n // (находка I1 финального ревью).\n if (ft.value === \"deal\" && !r.дошёл) return false;\n if (ft.value === \"nodeal\" && r.дошёл) return false;\n if (ft.value === \"live\" && (!r.сделка || CLOSED(r))) return false;\n if (ft.value === \"lost\" && (!r.сделка || !CLOSED(r))) return false;\n if (\n q &&\n !((r.название + \" \" + r.телефон + \" \" + r.лид + \" \" + (r.сделка || \"\")).toLowerCase().includes(q))\n ) return false;\n return true;\n });\n}\n\n// --- сортировка таблицы «Обращения»: по клику на заголовок «Дата», «Сумма»\n// или «Дней без движения» (Д9). sortKey === null — порядок как пришёл с\n// сервера (по возрастанию ID лида). ---\nlet sortKey = null;\nlet sortDir = 1;\n\nfunction sortedRows(rows) {\n if (!sortKey) return rows;\n const dir = sortDir;\n return [...rows].sort((a, b) => {\n const av = a[sortKey], bv = b[sortKey];\n if (typeof av === \"number\" || typeof bv === \"number\") {\n return dir * ((Number(av) || 0) - (Number(bv) || 0));\n }\n return dir * String(av).localeCompare(String(bv));\n });\n}\n\nfunction headCell(label, key, numeric) {\n const active = sortKey === key;\n const arrow = active ? (sortDir === 1 ? \" ▲\" : \" ▼\") : \"\";\n return \\`\\${esc(label)}\\${arrow}\\`;\n}\n\n// --- верхние панели: то, что посчитал сервер, целиком (Д1–Д10). Фильтры выше\n// на них не влияют — им нужны сырые коды статусов и стадий, которых сервер\n// клиенту не передаёт (см. примечание в шапке файла). ---\nfunction renderTop() {\n document.getElementById(\"kpis\").innerHTML = [\n [\"acc\", д.kpi.обращений, \"обращений с рекламы\"],\n [\n \"\",\n д.kpi.обращений\n ? \\`\\${д.kpi.конвертировано} · \\${Math.round(100 * д.kpi.конвертировано / д.kpi.обращений)}%\\`\n : д.kpi.конвертировано,\n \"дошли до сделки\",\n ],\n [\"\", д.kpi.вРаботе, \"сделок в работе\"],\n [\"acc\", money(д.kpi.пайплайн), \"пайплайн, ₸\"],\n [\"sig\", д.kpi.продано, \"продаж\"],\n [\"\", д.kpi.некачественных, \"закрыты как некачественные\"],\n ].map(([c, v, l]) => \\`

\\${v}\\${esc(l)}

\\`).join(\"\");\n\n const mx = д.воронка.length ? (д.воронка[0].сколько || 1) : 1;\n document.getElementById(\"funnel\").innerHTML = д.воронка.map(({ этап, сколько }) =>\n \\`

\\${esc(этап)}\\${сколько}

\\`\n ).join(\"\");\n\n const mmax = Math.max(1, ...д.когорты.map((к) => к.обращений));\n document.getElementById(\"months\").innerHTML = д.когорты.map((к) =>\n \\`

\\` +\n \\`

\\${esc(к.месяц.slice(5))}

\\`\n ).join(\"\");\n\n document.getElementById(\"tsrc\").innerHTML =\n 'ИсточникЛидовСделокКонв.Пайплайн' +\n д.источники.map((р) =>\n \\`\\${esc(р.ключ)}\\${р.лидов}\\${р.сделокСРекламы}\\${р.конверсия}%\\${\n money(р.пайплайн)\n }\\`\n ).join(\"\");\n\n document.getElementById(\"tmgr\").innerHTML =\n 'МенеджерЛидовСделокКонв.' +\n д.менеджеры.map((р) =>\n \\`\\${esc(р.ключ)}\\${р.лидов}\\${р.сделокСРекламы}\\${р.конверсия}%\\`\n ).join(\"\");\n\n // Стадии сделок, пришедших с рекламы: считаем по всем строкам со сделкой —\n // сервер такой готовый разрез не отдаёт, а название и сумма стадии в строке\n // уже есть, раскодировать ничего не нужно.\n const stg = {};\n for (const r of д.строки) {\n if (!r.сделка) continue;\n const k = r.стадияСделки ?? \"—\";\n (stg[k] = stg[k] || { n: 0, p: 0 });\n stg[k].n++;\n stg[k].p += r.сумма || 0;\n }\n document.getElementById(\"tstg\").innerHTML =\n 'СтадияСделокСумма' +\n Object.entries(stg).sort((a, b) => b[1].n - a[1].n).map(([k, v]) =>\n \\`\\${esc(k)}\\${v.n}\\${money(v.p)}\\`\n ).join(\"\");\n\n // Требует внимания (Д10): контроль качества, посчитанный сервером\n // (д.проблемы), просто не был выведен на экран — данные уже приходили в\n // каждой выдаче страницы (находка I3 финального ревью).\n const lead = (id) =>\n \\`#\\${esc(id)}\\`;\n const deal = (id) =>\n \\`#\\${esc(id)}\\`;\n const МАКС_ПОКАЗ = 8;\n function issueGroup(title, items, render) {\n const хвост = items.length > МАКС_ПОКАЗ\n ? \\` и ещё \\${items.length - МАКС_ПОКАЗ}\\`\n : \"\";\n return \\`

\\${esc(title)}\\${items.length}

\\` +\n (items.length === 0\n ? \\`

пусто

\\`\n : \\`

\\${items.slice(0, МАКС_ПОКАЗ).map(render).join(\", \")}\\${хвост}

\\`) +\n \\`

\\`;\n }\n document.getElementById(\"issues\").innerHTML =\n issueGroup(\n \"Дубли (лид с несколькими сделками)\",\n д.проблемы.дубли,\n (д_) => \\`\\${lead(д_.лид)} → \\${д_.сделки.map(deal).join(\", \")}\\`,\n ) +\n issueGroup(\"Живые сделки без суммы\", д.проблемы.безСуммы, deal) +\n issueGroup(\"Обращения без телефона\", д.проблемы.безТелефона, lead) +\n issueGroup(\"Необработанные обращения\", д.проблемы.неОбработаны, lead);\n}\n\n// --- таблица обращений: единственное, что реагирует на фильтры ---\nfunction renderRows() {\n const R = sortedRows(filteredRows());\n document.getElementById(\"cnt\").textContent = \"— \" + R.length + \" шт.\";\n const show = R.slice(0, 120);\n const head = \"Лид\" + headCell(\"Дата\", \"дата\", false) +\n \"НазваниеИсточникМенеджерСтатус лидаСделкаСтадия сделки\" +\n headCell(\"Сумма\", \"сумма\", true) + headCell(\"Дней без движения\", \"днейБезДвижения\", true) + \"\";\n document.getElementById(\"trows\").innerHTML =\n head +\n show.map((r) => {\n // Клиенту не передан код статуса/стадии (только переведённое название) —\n // «Некачественный» здесь совпадает с системным статусом Bitrix24 JUNK,\n // это единственный случай, где сопоставление по названию надёжно.\n // Для стадии сделки точно так же нельзя отличить «продано» от «провалено»\n // без кода, поэтому закрытая сделка всегда красная, включая гипотетическую\n // победу — сейчас продаж 0, так что расхождения нет.\n const sc = r.сделка ? \"c-ok\" : (r.статусЛида === \"Некачественный\" ? \"c-bad\" : \"c-warn\");\n const dc = !r.сделка ? \"\" : (CLOSED(r) ? \"c-bad\" : \"c-ok\");\n return \\`\\${esc(r.лид)}\\${\n esc(r.дата)\n }\\` +\n \\`\\${esc(r.название)}\\${esc(r.источник)}\\${esc(r.менеджер)}\\` +\n \\`\\${esc(r.статусЛида)}\\` +\n \\`\\${r.сделка ? esc(r.сделка) : \"—\"}\\` +\n \\`\\${r.стадияСделки ? \\`\\${esc(r.стадияСделки)}\\` : \"—\"}\\` +\n \\`\\${r.сумма ? money(r.сумма) : \"—\"}\\` +\n \\`\\${r.днейБезДвижения}\\`;\n }).join(\"\") +\n (R.length > show.length\n ? \\`показаны первые \\${show.length} из \\${R.length} — сузьте фильтры, чтобы увидеть остальные\\`\n : \"\");\n document.querySelectorAll(\".rowlink\").forEach((tr) => {\n tr.onclick = () => openCard(tr.dataset.id);\n });\n document.querySelectorAll(\"#trows th.sortable\").forEach((th) => {\n th.onclick = () => {\n const key = th.dataset.key;\n if (sortKey === key) sortDir = -sortDir;\n else {\n sortKey = key;\n sortDir = 1;\n }\n renderRows();\n };\n });\n}\n\n// --- карточка обращения ---\n\n// Причины отказа: список читается один раз при загрузке. Если REFUSAL_FIELD\n// не задан на сервере, /reasons отвечает ошибкой, и блок причин в карточке не\n// показывается вовсе (Д7).\nlet причины = [];\n// Список нужен только при открытии карточки — экран не должен ждать портал.\nfetch(\"/reasons\").then((r) => (r.ok ? r.json() : [])).then((с) => { причины = с; }).catch(() => {});\n\nfunction findRow(id) {\n return д.строки.find((r) => r.лид === id);\n}\n\nasync function openCard(id) {\n const r = findRow(id);\n if (!r) return;\n\n document.getElementById(\"drawer\").innerHTML =\n \\`\\` +\n \\`

\\${esc(r.название)}

\\` +\n \\`

Обращение с рекламы · \\${esc(r.источник)}

\\` +\n \\`

Лид: #\\${esc(r.лид)} — открыть в CRM ↗
Дата: \\${esc(r.дата)}
Телефон: \\${esc(r.телефон) || \"—\"}
Менеджер: \\${esc(r.менеджер)}
Статус лида: \\${esc(r.статусЛида)}
Сделка: #\\${esc(r.сделка)} — открыть в CRM ↗
Стадия: \\${esc(r.стадияСделки)}
Сумма: \\${\n r.сумма ? money(r.сумма) + \" ₸\" : \"не указана\"\n }
Сделка: не заводилась

\\` +\n \\`

Что происходило

Загрузка ленты…

\\` +\n \\`

Заметка собственника

\\` +\n \\`\\` +\n \\`\\` +\n \\`

Комментарий пишется прямо в таймлайн Битрикса по нажатию — автосохранения нет.

\\` +\n (причины.length > 0\n ? \\`

Причина отказа

\\` +\n \\`\\` +\n \\`\\` +\n \\`

\\`\n : \"\");\n\n document.getElementById(\"drawer\").classList.add(\"on\");\n document.getElementById(\"scrim\").classList.add(\"on\");\n document.getElementById(\"dc\").onclick = closeCard;\n\n // Заметка собственника: запись только по явному нажатию, без автосохранения.\n // Кнопка блокируется на время запроса — иначе двойной клик создаст в\n // карточке клиента два одинаковых комментария.\n const cBtn = document.getElementById(\"cBtn\");\n cBtn.onclick = async () => {\n const текст = document.getElementById(\"cText\").value.trim();\n const cNote = document.getElementById(\"cNote\");\n if (!текст) return;\n cBtn.disabled = true;\n try {\n const res = await fetch(\"/comment\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ тип: \"lead\", id: r.лид, текст }),\n });\n if (res.ok) {\n document.getElementById(\"cText\").value = \"\";\n cNote.textContent = \"Сохранено в CRM.\";\n cNote.classList.remove(\"err\");\n } else {\n const j = await res.json().catch(() => ({}));\n cNote.textContent = \"Ошибка: \" + (j.error || res.status);\n cNote.classList.add(\"err\");\n }\n } catch {\n cNote.textContent = \"Ошибка сети — комментарий не сохранён.\";\n cNote.classList.add(\"err\");\n } finally {\n cBtn.disabled = false;\n }\n };\n\n // Причина отказа: тот же принцип — только по нажатию, кнопка блокируется.\n const rBtn = document.getElementById(\"rBtn\");\n if (rBtn) {\n rBtn.onclick = async () => {\n const rSelect = document.getElementById(\"rSelect\");\n const rNote = document.getElementById(\"rNote\");\n const значение = rSelect.value;\n if (!значение) return;\n rBtn.disabled = true;\n try {\n const res = await fetch(\"/refusal\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ лид: r.лид, значение }),\n });\n if (res.ok) {\n rNote.textContent = \"Причина записана в CRM.\";\n rNote.classList.remove(\"err\");\n } else {\n const j = await res.json().catch(() => ({}));\n rNote.textContent = \"Ошибка: \" + (j.error || res.status);\n rNote.classList.add(\"err\");\n }\n } catch {\n rNote.textContent = \"Ошибка сети — причина не записана.\";\n rNote.classList.add(\"err\");\n } finally {\n rBtn.disabled = false;\n }\n };\n }\n\n // Лента событий грузится настоящим запросом к порталу, а не показывает\n // текст-заглушку, как в макете.\n const params = new URLSearchParams();\n if (r.лид) params.set(\"lead\", r.лид);\n if (r.сделка) params.set(\"deal\", r.сделка);\n const tl = document.getElementById(\"tl\");\n try {\n const res = await fetch(\"/card?\" + params.toString());\n const события = res.ok ? await res.json() : [];\n const ev = [{\n когда: r.дата + \" 00:00\",\n что: \\`Лид создан · источник «\\${r.источник}»\\`,\n кто: r.менеджер,\n сиг: true,\n файлы: [],\n }, ...события.map((с) => ({\n когда: с.когда,\n что: с.что,\n кто: с.кто,\n сиг: false,\n файлы: с.файлы,\n }))];\n ev.sort((a, b) => a.когда.localeCompare(b.когда));\n tl.innerHTML = ev.map((e) =>\n \\`

\\${esc(e.когда)}

\\` +\n \\`

\\${esc(e.что)}

\\${e.кто ? \\`

\\${esc(e.кто)}

\\` : \"\"}\\` +\n (e.файлы && e.файлы.length\n ? \\`

\\${\n e.файлы.map((ф) => \\`📎 \\${esc(ф.имя)}\\`)\n .join(\"\")\n }

\\`\n : \"\") + \\`

\\`\n ).join(\"\");\n } catch {\n tl.innerHTML = \\`

Не удалось загрузить ленту событий.

\\`;\n }\n}\n\nfunction closeCard() {\n document.getElementById(\"drawer\").classList.remove(\"on\");\n document.getElementById(\"scrim\").classList.remove(\"on\");\n}\ndocument.getElementById(\"scrim\").onclick = closeCard;\ndocument.addEventListener(\"keydown\", (e) => {\n if (e.key === \"Escape\") closeCard();\n});\n\n[fm, fs, fg, ft].forEach((el) => el.onchange = renderRows);\nfq.oninput = renderRows;\ndocument.getElementById(\"reset\").onclick = () => {\n fm.value = fs.value = fg.value = ft.value = \"\";\n fq.value = \"\";\n renderRows();\n};\n`;\n","createdAt",["D",1788847955114],"branchVersion","branchId","bfd39142-8f6a-4087-8abb-f6da5f96742a","id","0d66920f-8240-4395-a231-63f86e6c3888","uls-radar-reklamy",["D",1788790280130],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Радар рекламных лидов ULS: живая страница из Битрикс24","imageUrl","ce244983-5dfc-4662-ad1a-ca34d2e798a0","pinnedFileId","426b02f0-aac6-11f1-9f81-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa853-4d22-71bf-b5fe-af55df9678e6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":24},"branch",{"_13":85,"_31":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"isOwned",54,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","umgroupkzcommits","handle","displayName","umgroupkz-commits","avatar","https://avatars.githubusercontent.com/u/279207781?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":451,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":452,"_80":453,"_82":454,"_84":24},"tree",[167,199,200],"files",[167,168,169,170,171,172,173,174,175,176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200],"counts",{"_156":62,"_157":136,"_158":62,"_159":160,"_161":162},"contents",[127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":149,"_31":150,"_29":151,"_132":-5,"_40":41,"_39":152,"_134":58,"_37":153,"_13":62,"_33":154,"_35":-5,"_23":24,"_139":-5,"_26":155},{"_42":142,"_31":143,"_29":144,"_132":-5,"_40":41,"_39":145,"_134":24,"_37":146,"_13":136,"_33":20,"_35":147,"_23":24,"_139":-5,"_26":148},{"_42":130,"_31":131,"_29":56,"_132":-5,"_40":41,"_39":133,"_134":58,"_37":135,"_13":136,"_33":137,"_35":138,"_23":24,"_139":140,"_26":141},"bb923532-68a0-4daa-8e25-f5bcf685349c","dash.ts","parentId",28,"latest",["D",1788847925864],1,"http","import { envOpt } from \"./src/env.ts\";\r\nimport { getPortal } from \"./src/portals.ts\";\r\nimport { ответСКукой, пропущен, сравнитьУстойчиво, страницаВхода } from \"./src/dash/auth.ts\";\r\nimport {\r\n type СнимокРаботы,\r\n снимокРекламы,\r\n type СнимокСостояния,\r\n собратьРаботу,\r\n собратьСостояние,\r\n} from \"./src/dash/state.ts\";\r\nimport { дляЭкрана, параметрыЗапроса } from \"./src/dash/screen.ts\";\r\nimport { страница } from \"./src/dash/page.ts\";\r\nimport { СТИЛИ, СЦЕНАРИЙ } from \"./src/dash/assets.ts\";\r\nimport { Кэш } from \"./src/dash/cache.ts\";\r\nimport { вCsv, сделкиВCsv } from \"./src/dash/csv.ts\";\r\nimport { лента } from \"./src/dash/card.ts\";\r\nimport {\r\n написатьКомментарий,\r\n ОшибкаПроверки,\r\n причиныОтказа,\r\n проставитьПричину,\r\n} from \"./src/dash/write.ts\";\r\n\r\nconst ПЯТЬ_МИНУТ = 5 * 60 * 1000;\r\n/** Два снимка с разной жизнью (Р3): состояние одно на всех и переживает\r\n * смену периода, работа за период — своя на каждый диапазон. */\r\nconst КЭШ_СОСТОЯНИЯ = new Кэш<СнимокСостояния>(ПЯТЬ_МИНУТ);\r\nconst КЭШ_РАБОТЫ = new Кэш<СнимокРаботы>(ПЯТЬ_МИНУТ);\r\n\r\n/** Пока по ключу идёт сборка, второй одновременный запрос ждёт тот же промис\r\n * (находка 8 ревью задачи 11): холодный кэш и три вкладки не должны\r\n * запускать три выкачивания портала. */\r\nconst ВЫПОЛНЯЕТСЯ = new Map>();\r\n\r\nasync function однажды(ключ: string, сборка: () => Promise): Promise {\r\n let промис = ВЫПОЛНЯЕТСЯ.get(ключ) as Promise | undefined;\r\n if (!промис) {\r\n промис = сборка().finally(() => ВЫПОЛНЯЕТСЯ.delete(ключ));\r\n ВЫПОЛНЯЕТСЯ.set(ключ, промис);\r\n }\r\n return await промис;\r\n}\r\n\r\nfunction сброситьКэши(): void {\r\n КЭШ_СОСТОЯНИЯ.сбросить();\r\n КЭШ_РАБОТЫ.сбросить();\r\n // refresh обязан оборвать и сборку, идущую прямо сейчас (находка F9): иначе\r\n // однажды() отдаст всем ожидающим устаревший промис, запущенный до сброса.\r\n ВЫПОЛНЯЕТСЯ.clear();\r\n}\r\n\r\n/** Статика отдаётся из строковых констант в памяти (src/dash/assets.ts), а не\r\n * читается с диска (находка C1, Critical): на Val Town нет файловой системы —\r\n * там нет `Deno.readFile`/`readTextFile`, а `import.meta.url` там https-адрес,\r\n * а не `file://`, так что `new URL(...)` даже не собрал бы валидный путь для\r\n * чтения. Раздача из памяти работает одинаково локально и на Val Town. */\r\nconst СТАТИКА: Record = {\r\n \"/dash.css\": { тело: СТИЛИ, тип: \"text/css; charset=utf-8\" },\r\n \"/dash.js\": { тело: СЦЕНАРИЙ, тип: \"text/javascript; charset=utf-8\" },\r\n};\r\n\r\n/** Читает JSON тела запроса, не бросая исключение наружу (находка 4): битое\r\n * или пустое тело — это ошибка клиента (400), а не необработанное падение. */\r\nasync function прочестьJson(req: Request): Promise<{ ok: true; тело: unknown } | { ok: false }> {\r\n try {\r\n return { ok: true, тело: await req.json() };\r\n } catch {\r\n return { ok: false };\r\n }\r\n}\r\n\r\nfunction объект(v: unknown): v is Record {\r\n return typeof v === \"object\" && v !== null && !Array.isArray(v);\r\n}\r\n\r\n/** Заголовок Origin у обычного запроса со страницы дашборда есть всегда и\r\n * совпадает с адресом самого дашборда. Отсутствие или расхождение — признак\r\n * запроса с чужого сайта (находка 1, Critical): SameSite=Strict у куки этот\r\n * сценарий уже закрывает для большинства браузеров, но для маршрутов, которые\r\n * пишут в боевую CRM клиента, полагаться на одну лишь настройку куки нельзя.\r\n *\r\n * Сравниваются ИМЕНА ХОСТОВ, а не адреса целиком (переревью, находка про\r\n * прод): вал разворачивается за обратным прокси-терминатором TLS — снаружи\r\n * браузер обращается по https и присылает Origin со схемой https, а внутрь\r\n * приложения запрос приходит по http. Сравнение полных origin никогда бы не\r\n * сошлось и валило бы 403 у всех пользователей в проде, хотя запрос идёт со\r\n * своей же страницы. Схема здесь никакой защиты не даёт: чужой сайт не может\r\n * подделать имя хоста в заголовке Origin — его ставит браузер, а не код\r\n * страницы; значение заголовка полностью вне контроля JS с чужого домена.\r\n * Ожидаемый хост берётся из заголовка Host запроса (это и есть то, к чему\r\n * реально обратился браузер, прокси его не переписывает), а если заголовка\r\n * нет — из адреса самого запроса, как раньше.\r\n *\r\n * Отсутствие заголовка Origin — тоже отказ, и это осознанное решение, а не\r\n * недосмотр: у дашборда один пользователь, работает из обычного браузера,\r\n * а браузер всегда шлёт Origin у запроса, отправленного со страницы (fetch/\r\n * XHR/form). Часть нестандартных клиентов (curl, некоторые расширения) его\r\n * не пришлют и потеряют возможность записи — это принято сознательно: для\r\n * операции, меняющей боевую CRM клиента, строгий отказ правильнее, чем\r\n * смягчение проверки ради клиента, который здесь никогда и не появится.\r\n * Следующему читателю: не убирать эту строгость, увидев жалобу «Origin не\r\n * пришёл» — обычный браузер эту жалобу никогда не produces. */\r\nfunction источникВерен(req: Request, url: URL): boolean {\r\n const origin = req.headers.get(\"origin\");\r\n if (origin === null) return false;\r\n\r\n let хостОригина: string;\r\n try {\r\n // Значение может быть строкой \"null\" (так браузер помечает запросы из\r\n // песочницы) или произвольным мусором — в обоих случаях new URL бросает,\r\n // и это тоже отказ, а не повод разбирать вручную.\r\n хостОригина = new URL(origin).host;\r\n } catch {\r\n return false;\r\n }\r\n\r\n const хостОжидаемый = req.headers.get(\"host\") ?? url.host;\r\n return хостОригина === хостОжидаемый;\r\n}\r\n\r\n/** Наружу — короткий безопасный текст; полный текст исключения (адрес\r\n * вебхука, внутренние поля, данные клиента) — только в консоль сервера\r\n * (находка 6). Исключение — ОшибкаПроверки: её текст мы писали сами в\r\n * write.ts, он безопасен и полезен пользователю. */\r\nfunction ответНаОшибкуПортала(е: unknown): Response {\r\n if (е instanceof ОшибкаПроверки) {\r\n return Response.json({ error: е.message }, { status: 400 });\r\n }\r\n console.error(е);\r\n return Response.json(\r\n { error: \"Портал отклонил запрос, подробности в журнале сервера\" },\r\n { status: 400 },\r\n );\r\n}\r\n\r\n/** Имя метода из ошибки REST-слоя, без остального текста: в исключении\r\n * BitrixError лежит и адрес вебхука. rest.ts кладёт метод в поле `method`\r\n * (проверить в src/errors.ts; если поля нет — вернуть «портал»). */\r\nfunction названиеЗапроса(е: unknown): string {\r\n const m = (е as { method?: unknown })?.method;\r\n return typeof m === \"string\" && m ? m : \"портал\";\r\n}\r\n\r\nexport default async function (req: Request): Promise {\r\n const пароль = envOpt(\"DASH_PASSWORD\");\r\n const слаг = envOpt(\"DASH_PORTAL\") ?? \"uls\";\r\n if (!пароль) {\r\n return Response.json({ error: \"DASH_PASSWORD не задан в переменных окружения\" }, {\r\n status: 500,\r\n });\r\n }\r\n const url = new URL(req.url);\r\n\r\n if (url.pathname === \"/login\" && req.method === \"POST\") {\r\n const форма = await req.formData();\r\n // Устойчивое ко времени сравнение (находка 2): обычное === раскрывает\r\n // совпавший префикс пароля через время ответа.\r\n return сравнитьУстойчиво(String(форма.get(\"p\") ?? \"\"), пароль)\r\n ? await ответСКукой(пароль, \"/\")\r\n : страницаВхода(\"Пароль не подошёл\");\r\n }\r\n // Все пути, кроме /login, закрыты проверкой пропущен() — включая статику:\r\n // дашборд с телефонами клиентов не должен отдавать даже вёрстку и скрипт\r\n // тому, кто не вошёл.\r\n if (!(await пропущен(req, пароль))) return страницаВхода();\r\n\r\n const статика = СТАТИКА[url.pathname];\r\n if (статика) {\r\n return new Response(статика.тело, { headers: { \"content-type\": статика.тип } });\r\n }\r\n\r\n const портал = getPortal(слаг);\r\n\r\n // Причина отказа: имя поля берётся только из переменной окружения, никогда\r\n // из запроса браузера — иначе испорченный или подделанный запрос мог бы\r\n // записать значение в произвольное поле лида на боевом портале.\r\n const полеПричины = envOpt(\"REFUSAL_FIELD\");\r\n\r\n if (url.pathname === \"/reasons\" && req.method === \"GET\") {\r\n if (!полеПричины) {\r\n return Response.json(\r\n { error: \"REFUSAL_FIELD не задан — причины отказа отключены\" },\r\n { status: 404 },\r\n );\r\n }\r\n try {\r\n const список = await причиныОтказа(портал, полеПричины);\r\n return Response.json(список);\r\n } catch (е) {\r\n return ответНаОшибкуПортала(е);\r\n }\r\n }\r\n\r\n if (url.pathname === \"/refusal\" && req.method === \"POST\") {\r\n if (!источникВерен(req, url)) {\r\n return Response.json({ error: \"Запрос не с этой страницы (Origin не совпадает)\" }, {\r\n status: 403,\r\n });\r\n }\r\n if (!полеПричины) {\r\n return Response.json(\r\n { error: \"REFUSAL_FIELD не задан — запись причины отказа отключена\" },\r\n { status: 500 },\r\n );\r\n }\r\n const разбор = await прочестьJson(req);\r\n if (!разбор.ok || !объект(разбор.тело)) {\r\n return Response.json({ error: \"Тело запроса не является JSON-объектом\" }, { status: 400 });\r\n }\r\n const { лид, значение } = разбор.тело as Record;\r\n if (typeof лид !== \"string\" || лид.trim().length === 0) {\r\n return Response.json({ error: \"Поле «лид» обязано быть непустой строкой\" }, {\r\n status: 400,\r\n });\r\n }\r\n if (typeof значение !== \"string\" || значение.trim().length === 0) {\r\n return Response.json({ error: \"Поле «значение» обязано быть непустой строкой\" }, {\r\n status: 400,\r\n });\r\n }\r\n try {\r\n await проставитьПричину(портал, лид, полеПричины, значение);\r\n сброситьКэши();\r\n return Response.json({ ok: true });\r\n } catch (е) {\r\n return ответНаОшибкуПортала(е);\r\n }\r\n }\r\n\r\n if (url.pathname === \"/card\") {\r\n const лид = url.searchParams.get(\"lead\");\r\n const сделка = url.searchParams.get(\"deal\");\r\n return Response.json(await лента(портал, лид, сделка));\r\n }\r\n\r\n if (url.pathname === \"/comment\" && req.method === \"POST\") {\r\n if (!источникВерен(req, url)) {\r\n return Response.json({ error: \"Запрос не с этой страницы (Origin не совпадает)\" }, {\r\n status: 403,\r\n });\r\n }\r\n const разбор = await прочестьJson(req);\r\n if (!разбор.ok || !объект(разбор.тело)) {\r\n return Response.json({ error: \"Тело запроса не является JSON-объектом\" }, { status: 400 });\r\n }\r\n const { тип, id, текст } = разбор.тело as Record;\r\n if (тип !== \"lead\" && тип !== \"deal\") {\r\n return Response.json({ error: \"Поле «тип» обязано быть lead или deal\" }, { status: 400 });\r\n }\r\n if (typeof id !== \"string\" || id.trim().length === 0) {\r\n return Response.json({ error: \"Поле «id» обязано быть непустой строкой\" }, {\r\n status: 400,\r\n });\r\n }\r\n if (typeof текст !== \"string\") {\r\n return Response.json({ error: \"Поле «текст» обязано быть строкой\" }, { status: 400 });\r\n }\r\n if (текст.length > 10_000) {\r\n return Response.json({ error: \"Комментарий длиннее 10000 символов\" }, { status: 400 });\r\n }\r\n try {\r\n const id_ = await написатьКомментарий(портал, тип, id, текст);\r\n сброситьКэши();\r\n return Response.json({ ok: true, id: id_ });\r\n } catch (е) {\r\n return ответНаОшибкуПортала(е);\r\n }\r\n }\r\n\r\n // Снимок собирается только для двух вещей ниже — главной страницы и\r\n // выгрузки CSV (находка 3): /card и /comment его не используют и не должны\r\n // ждать выкачивание восьми сотен лидов и сотни сделок ради ленты событий\r\n // или одного комментария.\r\n if (url.pathname !== \"/\" && url.pathname !== \"/csv\") {\r\n return Response.json({ error: \"Неизвестный путь\" }, { status: 404 });\r\n }\r\n\r\n const сейчас = new Date();\r\n const разборП = параметрыЗапроса(url, сейчас);\r\n if (!разборП.ok) return Response.json({ error: разборП.ошибка }, { status: 400 });\r\n const п = разборП.п;\r\n if (url.searchParams.has(\"refresh\")) сброситьКэши();\r\n\r\n // Состояние без портала не строится вовсе: половинчатая воронка хуже\r\n // отсутствующей. Наружу — какой запрос упал, без текста исключения\r\n // (в нём адрес вебхука).\r\n let состояние = КЭШ_СОСТОЯНИЯ.взять(\"состояние\");\r\n if (!состояние) {\r\n try {\r\n состояние = await однажды(\"состояние\", () => собратьСостояние(портал, сейчас));\r\n КЭШ_СОСТОЯНИЯ.положить(\"состояние\", состояние);\r\n } catch (е) {\r\n console.error(е);\r\n return Response.json(\r\n { error: `Портал не ответил на запрос состояния: ${названиеЗапроса(е)}` },\r\n { status: 502 },\r\n );\r\n }\r\n }\r\n\r\n // Работа за период — с плашкой вместо отказа: воронку владелец должен\r\n // видеть, даже если история стадий сегодня не отвечает.\r\n const ключРаботы = `работа:${п.с}:${п.по}`;\r\n let работа: СнимокРаботы | null = КЭШ_РАБОТЫ.взять(ключРаботы) ?? null;\r\n const недоступно: string[] = [];\r\n if (!работа) {\r\n try {\r\n работа = await однажды(ключРаботы, () => собратьРаботу(портал, п.с, п.по, сейчас));\r\n КЭШ_РАБОТЫ.положить(ключРаботы, работа);\r\n } catch (е) {\r\n console.error(е);\r\n недоступно.push(названиеЗапроса(е));\r\n работа = null;\r\n }\r\n }\r\n\r\n const экран = дляЭкрана(состояние, работа, п, сейчас, недоступно);\r\n\r\n if (url.pathname === \"/csv\") {\r\n const сделки = п.вкладка === \"сделки\";\r\n const реклама = снимокРекламы(состояние, сейчас);\r\n const тело = сделки\r\n ? сделкиВCsv(экран.сделки, портал.domain)\r\n : вCsv(реклама.обращения, состояние.справочники, реклама.люди);\r\n return new Response(тело, {\r\n headers: {\r\n \"content-type\": \"text/csv; charset=utf-8\",\r\n \"content-disposition\": `attachment; filename=\"${сделки ? \"sdelki\" : \"obrashcheniya\"}.csv\"`,\r\n },\r\n });\r\n }\r\n\r\n return new Response(страница(экран, портал.domain), {\r\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\r\n });\r\n}\r\n","label","uls-radar",[131],"c95b6179-ee28-4758-a4dc-5276e9dda6ff","README.md","ffcaa978-aac5-11f1-9a31-1607ee4eb77e",26,["D",1788790705899],"# Радар рекламных лидов ULS\n\nЖивая страница по воронке «ОП ГПМ» портала uls.bitrix24.kz: что происходит\nс обращениями, пришедшими с рекламы, и во что они превращаются.\n\n**Адрес:** https://uls-radar.val.run/\n\nВход — `dash.ts` (HTTP). Данные берутся у портала в момент запроса, своей базы\nнет, ответ кэшируется на пять минут.\n\n## Что нужно, чтобы страница заработала\n\nРазвёрнута 7 сентября 2026. Код на месте, несекретные настройки заданы.\nОсталось добавить **две переменные** — без них страница отвечает отказом:\n\n| Переменная | Что | Задана |\n|---|---|---|\n| `B24_PORTALS` | `uls` | ✅ |\n| `DASH_PORTAL` | `uls` | ✅ |\n| `AD_SOURCES` | `STORE,CALL,CALLBACK` — Реклама, Сайт ULS-ASIA.KZ, Instagram | ✅ |\n| `B24_TITLE_ULS` | `ULS Asia` | ✅ |\n| `DASH_PASSWORD` | пароль входа на страницу | ❌ **нужно задать** |\n| `B24_HOOK_ULS` | входящий вебхук портала целиком, со слэшем на конце | ❌ **нужно задать** |\n| `REFUSAL_FIELD` | имя списочного поля лида с причиной отказа (`UF_CRM_…`) | не обязательна |\n\nПока `REFUSAL_FIELD` пуста, блок причин отказа на странице не показывается —\nэто не поломка, а сознательное поведение.\n\n## Секреты\n\nЖивут только здесь, в переменных окружения вала: ни в коде, ни в репозитории,\nни в переписке. В самом коде вебхуков и ключей нет — проверено перед\nразвёртыванием.\n\nАккаунт на бесплатном тарифе, поэтому **код вала виден публично**. Секретов\nв нём нет, а доступ к данным портала закрыт паролем `DASH_PASSWORD`.\n\n## Источник правды\n\nВетка `claude/uls-portal-access-1bb082` репозитория коннектора Битрикс24,\n858+ тестов. Правки вносить там и переносить сюда, а не наоборот: здесь лежит\nкопия, а не оригинал.\n\nПеренесено 24 файла — `dash.ts` и `src/`. Часть модулей (`journal.ts`,\n`entities.ts`, `appcall.ts` и соседние) тянется по цепочке импортов из\nобщего кода коннектора и на этой странице не используется: дашборд ходит\nна портал входящим вебхуком, путь приложения не задействован.\n",[143],"2d62502a-f613-43bf-a173-f1e13318c5f3","src","fce2ee45-dde0-44d8-a8ff-19af836c83de",3,["D",1788790396829],"directory",[150],"pulls","branches","forks","envVars",{"_163":165,"_166":62},"connections",{"_163":62,"_164":62},"count","unfilledCount",6,"emptyCount",{"_42":149,"_31":150,"_29":151,"_132":-5,"_40":41,"_39":152,"_134":58,"_37":448,"_13":62,"_33":154,"_35":-5,"_23":24,"_139":-5,"_202":449,"_26":450},{"_42":444,"_31":312,"_29":306,"_132":151,"_40":41,"_39":152,"_134":58,"_37":445,"_13":62,"_33":154,"_35":-5,"_23":24,"_139":-5,"_202":446,"_26":447},{"_42":439,"_31":398,"_29":394,"_132":306,"_40":41,"_39":440,"_134":58,"_37":441,"_13":62,"_33":154,"_35":-5,"_23":24,"_139":-5,"_202":442,"_26":443},{"_42":431,"_31":432,"_29":433,"_132":394,"_40":41,"_39":434,"_134":58,"_37":435,"_13":62,"_33":34,"_35":436,"_23":24,"_139":-5,"_202":437,"_26":438},{"_42":423,"_31":424,"_29":425,"_132":394,"_40":41,"_39":426,"_134":58,"_37":427,"_13":62,"_33":34,"_35":428,"_23":24,"_139":-5,"_202":429,"_26":430},{"_42":415,"_31":416,"_29":417,"_132":394,"_40":41,"_39":418,"_134":58,"_37":419,"_13":62,"_33":34,"_35":420,"_23":24,"_139":-5,"_202":421,"_26":422},{"_42":407,"_31":408,"_29":409,"_132":394,"_40":41,"_39":410,"_134":58,"_37":411,"_13":62,"_33":34,"_35":412,"_23":24,"_139":-5,"_202":413,"_26":414},{"_42":399,"_31":400,"_29":401,"_132":394,"_40":41,"_39":402,"_134":58,"_37":403,"_13":62,"_33":34,"_35":404,"_23":24,"_139":-5,"_202":405,"_26":406},{"_42":393,"_31":32,"_29":30,"_132":394,"_40":41,"_39":14,"_134":58,"_37":395,"_13":62,"_33":34,"_35":36,"_23":24,"_139":-5,"_202":396,"_26":397},{"_42":385,"_31":386,"_29":387,"_132":306,"_40":41,"_39":388,"_134":58,"_37":389,"_13":136,"_33":34,"_35":390,"_23":24,"_139":-5,"_202":391,"_26":392},{"_42":377,"_31":378,"_29":379,"_132":306,"_40":41,"_39":380,"_134":58,"_37":381,"_13":62,"_33":34,"_35":382,"_23":24,"_139":-5,"_202":383,"_26":384},{"_42":369,"_31":370,"_29":371,"_132":306,"_40":41,"_39":372,"_134":58,"_37":373,"_13":62,"_33":34,"_35":374,"_23":24,"_139":-5,"_202":375,"_26":376},{"_42":361,"_31":362,"_29":363,"_132":306,"_40":41,"_39":364,"_134":58,"_37":365,"_13":62,"_33":34,"_35":366,"_23":24,"_139":-5,"_202":367,"_26":368},{"_42":353,"_31":354,"_29":355,"_132":306,"_40":41,"_39":356,"_134":24,"_37":357,"_13":62,"_33":34,"_35":358,"_23":24,"_139":-5,"_202":359,"_26":360},{"_42":345,"_31":346,"_29":347,"_132":306,"_40":41,"_39":348,"_134":24,"_37":349,"_13":62,"_33":34,"_35":350,"_23":24,"_139":-5,"_202":351,"_26":352},{"_42":337,"_31":338,"_29":339,"_132":306,"_40":41,"_39":340,"_134":24,"_37":341,"_13":62,"_33":34,"_35":342,"_23":24,"_139":-5,"_202":343,"_26":344},{"_42":329,"_31":330,"_29":331,"_132":306,"_40":41,"_39":332,"_134":24,"_37":333,"_13":62,"_33":34,"_35":334,"_23":24,"_139":-5,"_202":335,"_26":336},{"_42":321,"_31":322,"_29":323,"_132":306,"_40":41,"_39":324,"_134":24,"_37":325,"_13":62,"_33":34,"_35":326,"_23":24,"_139":-5,"_202":327,"_26":328},{"_42":313,"_31":314,"_29":315,"_132":306,"_40":41,"_39":316,"_134":24,"_37":317,"_13":62,"_33":34,"_35":318,"_23":24,"_139":-5,"_202":319,"_26":320},{"_42":303,"_31":304,"_29":305,"_132":306,"_40":41,"_39":307,"_134":58,"_37":308,"_13":62,"_33":34,"_35":309,"_23":24,"_139":-5,"_202":310,"_26":311},{"_42":295,"_31":296,"_29":297,"_132":151,"_40":41,"_39":298,"_134":58,"_37":299,"_13":62,"_33":34,"_35":300,"_23":24,"_139":-5,"_202":301,"_26":302},{"_42":287,"_31":288,"_29":289,"_132":151,"_40":41,"_39":290,"_134":58,"_37":291,"_13":62,"_33":34,"_35":292,"_23":24,"_139":-5,"_202":293,"_26":294},{"_42":279,"_31":280,"_29":281,"_132":151,"_40":41,"_39":282,"_134":58,"_37":283,"_13":62,"_33":34,"_35":284,"_23":24,"_139":-5,"_202":285,"_26":286},{"_42":271,"_31":272,"_29":273,"_132":151,"_40":41,"_39":274,"_134":58,"_37":275,"_13":62,"_33":34,"_35":276,"_23":24,"_139":-5,"_202":277,"_26":278},{"_42":263,"_31":264,"_29":265,"_132":151,"_40":41,"_39":266,"_134":58,"_37":267,"_13":62,"_33":34,"_35":268,"_23":24,"_139":-5,"_202":269,"_26":270},{"_42":255,"_31":256,"_29":257,"_132":151,"_40":41,"_39":258,"_134":58,"_37":259,"_13":62,"_33":34,"_35":260,"_23":24,"_139":-5,"_202":261,"_26":262},{"_42":247,"_31":248,"_29":249,"_132":151,"_40":41,"_39":250,"_134":58,"_37":251,"_13":62,"_33":34,"_35":252,"_23":24,"_139":-5,"_202":253,"_26":254},{"_42":239,"_31":240,"_29":241,"_132":151,"_40":41,"_39":242,"_134":58,"_37":243,"_13":62,"_33":34,"_35":244,"_23":24,"_139":-5,"_202":245,"_26":246},{"_42":231,"_31":232,"_29":233,"_132":151,"_40":41,"_39":234,"_134":58,"_37":235,"_13":62,"_33":34,"_35":236,"_23":24,"_139":-5,"_202":237,"_26":238},{"_42":223,"_31":224,"_29":225,"_132":151,"_40":41,"_39":226,"_134":58,"_37":227,"_13":62,"_33":34,"_35":228,"_23":24,"_139":-5,"_202":229,"_26":230},{"_42":216,"_31":217,"_29":218,"_132":151,"_40":41,"_39":165,"_134":58,"_37":219,"_13":62,"_33":34,"_35":220,"_23":24,"_139":-5,"_202":221,"_26":222},{"_42":208,"_31":209,"_29":210,"_132":151,"_40":41,"_39":211,"_134":58,"_37":212,"_13":62,"_33":34,"_35":213,"_23":24,"_139":-5,"_202":214,"_26":215},{"_42":142,"_31":143,"_29":144,"_132":-5,"_40":41,"_39":145,"_134":24,"_37":205,"_13":136,"_33":20,"_35":147,"_23":24,"_139":-5,"_202":206,"_26":207},{"_42":130,"_31":131,"_29":56,"_132":-5,"_40":41,"_39":133,"_134":58,"_37":201,"_13":136,"_33":137,"_35":138,"_23":24,"_139":140,"_202":203,"_26":204},["D",1788847925864],"children",[],[131],["D",1788790705899],[],[143],"3a4c61e1-a4b2-42a8-a093-c913498d7e97","rpc.ts","bcb3e630-aac6-11f1-901c-1607ee4eb77e",22,["D",1788790597126],"import type { RestDeps } from \"./rest.ts\";\n\nexport interface ToolDef {\n name: string;\n description: string;\n inputSchema: unknown;\n}\n\nexport interface ToolResult {\n content: Array<{ type: \"text\"; text: string }>;\n isError?: boolean;\n}\n\n// Второй довод — необязательный: buildRpc ниже зовёт обработчики одним\n// доводом, и почти все обработчики его не несут вовсе. Он существует ради\n// процессной ветки b24_apply и b24_verify (src/apply.ts, src/verify.ts):\n// тесты процессной ветки подставляют его вторым доводом, тем же приёмом, что\n// применитьПроцесс/планПроцесса/проверитьЗапуском уже принимают его своим\n// последним доводом. Без этого поля в самом типе TypeScript видел бы у\n// `applyHandlers.b24_apply`/`verifyHandlers.b24_verify` тип поля Record (ровно\n// ToolHandler из одного довода), а не более широкую сигнатуру конкретной\n// функции, — и вызов с двумя доводами не проходил бы проверку типов.\n//\n// Тип — полный RestDeps (fetchImpl + sleep + now), а не только fetchImpl:\n// найдено ускорением тестов (задача про 13-минутный прогон) — узкий тип здесь\n// не пропускал `sleep` до rest.ts, и тесты процессной ветки честно ждали\n// боевой троттлинг rest.ts (500мс на вызов), которого фиктивный портал не\n// заслуживает.\nexport type ToolHandler = (\n args: Record,\n deps?: RestDeps,\n) => Promise;\n\nconst PROTOCOL_VERSION = \"2024-11-05\";\n\n/** Рабочее ядро правил. Клиент читает его при подключении — здесь только то,\n * что нужно знать до первого вызова. Подробности отдаёт инструмент b24_guide. */\nconst INSTRUCTIONS = [\n \"Коннектор к порталам Битрикс24 по входящему вебхуку.\",\n \"\",\n \"ПОРЯДОК. В начале работы с незнакомым порталом вызовите b24_snapshot — без снимка\",\n \"вы не знаете ни воронок, ни полей, ни идентификаторов и будете угадывать.\",\n \"Про повадки методов Битрикса спрашивайте b24_guide, а не память: она устаревает молча.\",\n \"\",\n \"БЕЗОПАСНОСТЬ. Уровень операции определяет сервер, не вы. Зелёный — чтение и создание\",\n \"нового — идёт сразу. Жёлтый — правка существующего и всё свыше 10 записей — требует\",\n \"подтверждения человека. Красный — удаление и изменение заполненного данными — требует\",\n \"подтверждения и записи обратной операции. Работа идёт на боевых порталах клиентов.\",\n \"\",\n \"ПРОВЕРКА. Созданное проверяется действием, а не перечитыванием. Всё, что заведено ради\",\n \"проверки, носит префикс ZZ_TEST_ и удаляется после. Отчёт обязан называть непроверенное.\",\n].join(\"\\n\");\n\nfunction result(id: unknown, value: unknown) {\n return { jsonrpc: \"2.0\", id, result: value };\n}\n\nexport function buildRpc(\n tools: ToolDef[],\n handlers: Record,\n): (msg: unknown) => Promise {\n return async (msg: unknown) => {\n const m = (msg ?? {}) as Record;\n const id = m.id;\n switch (m.method) {\n case \"initialize\":\n return result(id, {\n protocolVersion: typeof m.params?.protocolVersion === \"string\"\n ? m.params.protocolVersion\n : PROTOCOL_VERSION,\n capabilities: { tools: { listChanged: false } },\n serverInfo: { name: \"bitrix-connector\", version: \"0.1.0\" },\n instructions: INSTRUCTIONS,\n });\n\n case \"notifications/initialized\":\n case \"notifications/cancelled\":\n return null;\n\n case \"ping\":\n return result(id, {});\n\n case \"tools/list\":\n return result(id, { tools });\n\n case \"resources/list\":\n return result(id, { resources: [] });\n\n case \"prompts/list\":\n return result(id, { prompts: [] });\n\n case \"tools/call\": {\n const name = String(m.params?.name ?? \"\");\n const args = (m.params?.arguments ?? {}) as Record;\n const handler = handlers[name];\n if (!handler) {\n return result(id, {\n content: [{ type: \"text\", text: `Неизвестный инструмент: ${name}` }],\n isError: true,\n });\n }\n try {\n return result(id, await handler(args));\n } catch (e) {\n const text = e instanceof Error ? e.message : String(e);\n return result(id, {\n content: [{ type: \"text\", text: `Ошибка: ${text}` }],\n isError: true,\n });\n }\n }\n\n default:\n // Уведомление — это сообщение без id. По JSON-RPC на него не отвечают,\n // а stdio-транспорт записал бы ответ в поток как незапрошенное сообщение.\n if (m.id === undefined) return null;\n return result(id, {});\n }\n };\n}\n",[],[150,209],"65241ea7-2439-4cb9-87d4-5e1b995df305","rest.ts","5a2e66ac-aac6-11f1-9772-1607ee4eb77e",["D",1788790431810],"import type { Portal } from \"./portals.ts\";\r\nimport { BitrixError } from \"./errors.ts\";\r\nimport { appToken, forgetCachedToken, needsApp } from \"./appcall.ts\";\r\n\r\n// Цикл импортов rest.ts → appcall.ts → journal.ts → rest.ts (journal.ts зовёт call()\r\n// из rest.ts внутри b24_rollback) сегодня безопасен: ни один из трёх модулей не\r\n// читает импортированные привязки на верхнем уровне, только внутри функций, а к\r\n// моменту вызова любой функции все три модуля уже полностью проинициализированы.\r\n// Но это хрупкое свойство, а не гарантия: любой будущий top-level код в одном из\r\n// них (константа, вычисленная из импортированной функции, побочный эффект модуля)\r\n// может застать соседа неинициализированным и уронить старт с непонятной ошибкой\r\n// (находка 8 ревью задачи 2). Разрывать цикл не стали — три модуля тесно связаны\r\n// по смыслу (маршрутизация, хранилище, вызов), и вводить четвёртый файл ради\r\n// разрыва цикла усложнило бы код больше, чем экономит риск, который пока не\r\n// материализовался.\r\n\r\nexport interface RestDeps {\r\n fetchImpl?: typeof fetch;\r\n sleep?: (ms: number) => Promise;\r\n /** Часы для получения токена приложения на закрытых методах (см. needsApp).\r\n * Обычным вызовам, идущим вебхуком, не нужны вовсе. */\r\n now?: () => number;\r\n}\r\n\r\nconst MAX_RETRIES = 3;\r\nconst MAX_PAGES = 50;\r\n/** Битрикс допускает около двух запросов в секунду. Держим паузу между вызовами\r\n * к одному порталу, чтобы не ловить QUERY_LIMIT_EXCEEDED на ровном месте. */\r\nconst MIN_GAP_MS = 500;\r\n\r\nconst lastCallAt = new Map();\r\n\r\nconst realSleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\r\n\r\nasync function throttle(slug: string, sleep: (ms: number) => Promise) {\r\n const prev = lastCallAt.get(slug) ?? 0;\r\n const wait = prev + MIN_GAP_MS - Date.now();\r\n if (wait > 0) await sleep(wait);\r\n lastCallAt.set(slug, Date.now());\r\n}\r\n\r\ninterface Envelope {\r\n result?: unknown;\r\n error?: string;\r\n error_description?: string;\r\n next?: number;\r\n total?: number;\r\n}\r\n\r\nasync function once(\r\n portal: Portal,\r\n method: string,\r\n params: Record,\r\n deps: RestDeps,\r\n): Promise<{ env: Envelope; status: number }> {\r\n const doFetch = deps.fetchImpl ?? fetch;\r\n // Выбор пути решает таблица needsApp, а не вызывающий call()/callAll()/batch():\r\n // знание «что закрыто вебхуку» живёт в appcall.ts и не размазывается по коду\r\n // (этот проект уже четырежды платил за раздвоенное знание одного факта).\r\n //\r\n // appToken() зовётся ДО общего try/catch ниже: он бросает отказ по конфигурации\r\n // (нет приложения, нет пройденной авторизации) обычным Error, а не BitrixError, —\r\n // и такой отказ должен дойти до вызывающего как есть, с понятным текстом,\r\n // а не потеряться под общим \"портал недоступен\" сетевого catch.\r\n //\r\n // Обратная сторона этого решения (находка 9 ревью задачи 2): сетевой сбой ВНУТРИ\r\n // самого appToken() — например, oauth.bitrix24.tech не отвечает — тоже приходит\r\n // обычным Error и тоже не попадает под retry envelope() ниже, хотя по смыслу это\r\n // такой же временный сбой сети, как и падение самого REST-вызова (который retry\r\n // ловит). Цена той же развязки, что уже доказала себя на конфигурационных отказах:\r\n // разбираться, какой Error из appToken() временный, а какой окончательный, здесь не\r\n // входит в объём задачи — называем это ограничение, а не чиним молча.\r\n const useApp = needsApp(method);\r\n const token = useApp ? await appToken(portal.slug, { fetchImpl: doFetch, now: deps.now }) : undefined;\r\n const url = useApp ? `https://${portal.domain}/rest/${method}` : portal.base + method;\r\n const body = useApp ? { ...params, auth: token } : params;\r\n let status: number;\r\n let text: string;\r\n try {\r\n const res = await doFetch(url, {\r\n method: \"POST\",\r\n headers: { \"Content-Type\": \"application/json\" },\r\n body: JSON.stringify(body),\r\n });\r\n status = res.status;\r\n text = await res.text();\r\n } catch (e) {\r\n // Исключение сетевого слоя несёт полный адрес запроса в cause — вместе с токеном\r\n // вебхука. Наружу выпускаем только вымаранное сообщение BitrixError, исходное\r\n // исключение не пробрасываем и в cause не кладём.\r\n throw new BitrixError(\r\n \"NETWORK\",\r\n `портал недоступен (${e instanceof Error ? e.name : \"сбой сети\"})`,\r\n method,\r\n portal.domain,\r\n );\r\n }\r\n try {\r\n return { env: JSON.parse(text) as Envelope, status };\r\n } catch {\r\n throw new BitrixError(\r\n String(status),\r\n `Портал ответил не JSON: ${text.slice(0, 200)}`,\r\n method,\r\n portal.domain,\r\n );\r\n }\r\n}\r\n\r\nfunction retryable(code: string, description: string): boolean {\r\n const probe = `${code} ${description}`;\r\n return /QUERY_LIMIT_EXCEEDED|Too many requests|OPERATION_TIME_LIMIT|internal server error|NETWORK|expired_token/i\r\n .test(probe);\r\n}\r\n\r\n/** expired_token на самом REST-вызове (не на обмене токена в oauth.ts) значит, что\r\n * портал уже считает access_token просроченным, хотя кэш appcall.ts ещё думает\r\n * иначе — расхождение часов между процессами (находка 4 ревью задачи 2, смежная\r\n * часть). Голый повтор с тем же телом получил бы тот же отказ; забыть кэш перед\r\n * повтором обязан вызывающий (envelope() ниже), а не эта функция. */\r\nfunction tokenExpired(code: string, description: string): boolean {\r\n return /expired_token/i.test(`${code} ${description}`);\r\n}\r\n\r\n/** Битрикс умеет отвечать ошибкой с ПУСТЫМ полем error: {\"error\":\"\",\"error_description\":\"Not found\"}\r\n * с кодом 400. Проверка на непустоту error такой ответ приняла бы за успех с пустым\r\n * результатом — и вызывающий код пошёл бы дальше по несуществующим данным.\r\n * Найдено живым тестом на портале fbsm 11 августа 2026. */\r\nfunction isFailure(env: Envelope, status: number): boolean {\r\n if (status >= 400) return true;\r\n if (typeof env.error === \"string\" && env.error.length > 0) return true;\r\n if (typeof env.error_description === \"string\" && env.error_description.length > 0) return true;\r\n return false;\r\n}\r\n\r\nasync function envelope(\r\n portal: Portal,\r\n method: string,\r\n params: Record,\r\n deps: RestDeps,\r\n): Promise {\r\n const sleep = deps.sleep ?? realSleep;\r\n let last: Envelope | undefined;\r\n let lastStatus: number | undefined;\r\n for (let attempt = 0; attempt <= MAX_RETRIES; attempt++) {\r\n await throttle(portal.slug, sleep);\r\n try {\r\n const { env, status } = await once(portal, method, params, deps);\r\n last = env;\r\n lastStatus = status;\r\n if (!isFailure(env, status)) return env;\r\n if (!retryable(env.error || String(status), env.error_description ?? \"\")) break;\r\n } catch (e) {\r\n // Сетевой сбой или не-JSON ответ из once() приходит уже вымаранным BitrixError —\r\n // заворачиваем его в тот же конверт, что и ошибку протокола, чтобы повторы\r\n // работали одинаково.\r\n if (!(e instanceof BitrixError)) throw e;\r\n last = { error: e.code, error_description: e.description };\r\n lastStatus = undefined;\r\n if (!retryable(last.error ?? \"\", last.error_description ?? \"\")) break;\r\n }\r\n // Портал уже считает токен просроченным — сбрасываем кэш appcall.ts, чтобы\r\n // следующая попытка реально запросила новый токен через refresh(), а не\r\n // отправила тот же самый, ещё раз получив тот же самый отказ.\r\n if (needsApp(method) && tokenExpired(last?.error ?? \"\", last?.error_description ?? \"\")) {\r\n forgetCachedToken(portal.slug);\r\n }\r\n if (attempt < MAX_RETRIES) await sleep(500 * Math.pow(2, attempt));\r\n }\r\n throw new BitrixError(\r\n last?.error || String(lastStatus ?? \"\"),\r\n last?.error_description ?? \"\",\r\n method,\r\n portal.domain,\r\n );\r\n}\r\n\r\nexport async function call(\r\n portal: Portal,\r\n method: string,\r\n params: Record = {},\r\n deps: RestDeps = {},\r\n): Promise {\r\n const env = await envelope(portal, method, params, deps);\r\n return env.result as T;\r\n}\r\n\r\n/** Проходит все страницы выборки. Ограничение MAX_PAGES — защита от портала,\r\n * который повторяет один и тот же next и увёл бы нас в бесконечный цикл. */\r\nexport async function callAll(\r\n portal: Portal,\r\n method: string,\r\n params: Record = {},\r\n deps: RestDeps = {},\r\n): Promise {\r\n const out: T[] = [];\r\n let start: number | undefined;\r\n let seen = -1;\r\n for (let page = 0; page < MAX_PAGES; page++) {\r\n const body = start === undefined ? params : { ...params, start };\r\n const env = await envelope(portal, method, body, deps);\r\n const chunk = Array.isArray(env.result)\r\n ? env.result as T[]\r\n : (env.result as Record | undefined)\r\n ? Object.values(env.result as Record).flat()\r\n : [];\r\n out.push(...chunk);\r\n if (env.next === undefined || env.next === seen) break;\r\n seen = env.next;\r\n start = env.next;\r\n }\r\n return out;\r\n}\r\n\r\n/** Битрикс принимает команды пакета строками вида «метод?параметры»,\r\n * где вложенность кодируется квадратными скобками: filter[STAGE_ID]=NEW. */\r\nfunction toQuery(params: Record, prefix = \"\"): string[] {\r\n const parts: string[] = [];\r\n for (const [k, v] of Object.entries(params)) {\r\n const key = prefix ? `${prefix}[${k}]` : k;\r\n // undefined означает «поле не задано» — его в запросе быть не должно вовсе,\r\n // иначе портал отфильтрует по буквальной строке \"undefined\" и молча вернёт пустоту.\r\n if (v === undefined) continue;\r\n // null означает «очистить значение» — Битрикс ждёт для этого пустую строку.\r\n if (v === null) {\r\n parts.push(`${encodeURIComponent(key)}=`);\r\n continue;\r\n }\r\n if (typeof v === \"object\") {\r\n parts.push(...toQuery(v as Record, key));\r\n } else {\r\n parts.push(`${encodeURIComponent(key)}=${encodeURIComponent(String(v))}`);\r\n }\r\n }\r\n return parts;\r\n}\r\n\r\nexport interface BatchCmd {\r\n method: string;\r\n params?: Record;\r\n}\r\n\r\nconst BATCH_LIMIT = 50;\r\n\r\n/** Типизированный клиент пакета: проверяет лимит команд заранее и разбирает\r\n * result_error в понятную ошибку. Инструмент b24_call сейчас его не вызывает —\r\n * он идёт через универсальный call() и разбирает пакетный ответ сам (см. src/data.ts).\r\n * Нынешний потребитель этой функции — тесты (tests/rest_batch_test.ts); второй этап\r\n * (применение спецификаций пакетом) рассчитан на неё же. Не удалять и не упрощать. */\r\nexport async function batch(\r\n portal: Portal,\r\n cmds: Record,\r\n deps: RestDeps = {},\r\n): Promise> {\r\n const names = Object.keys(cmds);\r\n if (names.length > BATCH_LIMIT) {\r\n throw new Error(\r\n `В один пакет входит не больше ${BATCH_LIMIT} команд, передано ${names.length}. ` +\r\n \"Разбейте на несколько пакетов.\",\r\n );\r\n }\r\n const cmd: Record = {};\r\n for (const name of names) {\r\n const q = toQuery(cmds[name].params ?? {}).join(\"&\");\r\n cmd[name] = q ? `${cmds[name].method}?${q}` : cmds[name].method;\r\n }\r\n const env = await envelope(portal, \"batch\", { halt: 0, cmd }, deps);\r\n const box = env.result as {\r\n result?: Record;\r\n result_error?: Record;\r\n } | undefined;\r\n if (!box || typeof box !== \"object\") {\r\n throw new BitrixError(\r\n \"BATCH_SHAPE\",\r\n \"портал вернул пакет без поля result — разобрать состав ответа нечем\",\r\n \"batch\",\r\n portal.domain,\r\n );\r\n }\r\n const errors = Object.entries(box.result_error ?? {});\r\n if (errors.length > 0) {\r\n const [name, err] = errors[0];\r\n throw new BitrixError(\r\n err.error ?? \"\",\r\n err.error_description ?? \"\",\r\n `${cmds[name].method} (команда «${name}» в пакете)`,\r\n portal.domain,\r\n );\r\n }\r\n return box.result ?? {};\r\n}\r\n",[],[150,217],"8e73726a-d5d9-468f-b983-4281105a2ff8","redact.ts","c4160e26-aac6-11f1-8a4a-1607ee4eb77e",25,["D",1788790609470],"/** Токен вебхука — единственный секрет, который может случайно попасть в текст.\n * Домен и идентификатор пользователя оставляем: они не секретны, а без них\n * сообщение об ошибке перестаёт помогать. */\nconst WEBHOOK = /(\\/rest\\/\\d+\\/)[A-Za-z0-9]{8,}(\\/?)/g;\n\nexport function redact(text: string): string {\n return text.replace(WEBHOOK, \"$1***$2\");\n}\n",[],[150,224],"6e759420-c1bc-4abb-a3e4-4dd0d98be861","portals.ts","b5a7e12a-aac6-11f1-a221-1607ee4eb77e",19,["D",1788790585299],"import { env, envOpt } from \"./env.ts\";\r\nimport { appCreds, type AppCreds } from \"./oauth.ts\";\r\n\r\nexport interface Portal {\r\n slug: string;\r\n title: string;\r\n domain: string;\r\n userId: string;\r\n /** Полный адрес вебхука с завершающей косой чертой. Секрет: наружу не отдаётся. */\r\n base: string;\r\n /** Учётные данные локального приложения, если оно заведено на портале.\r\n * Отсутствие — не ошибка: приложение заведено не на каждом портале, и коннектор\r\n * обязан работать вебхуком там, где его нет. */\r\n appCreds?: AppCreds;\r\n}\r\n\r\nconst WEBHOOK = /^https:\\/\\/([^\\/]+)\\/rest\\/(\\d+)\\/([A-Za-z0-9]{8,})\\/?$/;\r\n\r\nexport function parseWebhook(url: string): { domain: string; userId: string; base: string } {\r\n const m = WEBHOOK.exec(url.trim());\r\n if (!m) {\r\n throw new Error(\r\n \"Адрес не похож на входящий вебхук Битрикс24. Ожидается вид \" +\r\n \"https://портал.bitrix24.kz/rest//<токен>/\",\r\n );\r\n }\r\n return { domain: m[1], userId: m[2], base: `https://${m[1]}/rest/${m[2]}/${m[3]}/` };\r\n}\r\n\r\nexport function listPortals(): Portal[] {\r\n const slugs = (envOpt(\"B24_PORTALS\") ?? \"\")\r\n .split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean);\r\n return slugs.map((slug) => {\r\n const hook = env(`B24_HOOK_${slug.toUpperCase()}`);\r\n const { domain, userId, base } = parseWebhook(hook);\r\n return {\r\n slug,\r\n title: envOpt(`B24_TITLE_${slug.toUpperCase()}`) ?? domain,\r\n domain,\r\n userId,\r\n base,\r\n appCreds: appCreds(slug),\r\n };\r\n });\r\n}\r\n\r\nexport function getPortal(slug: string): Portal {\r\n const all = listPortals();\r\n const found = all.find((p) => p.slug === slug.trim().toLowerCase());\r\n if (found) return found;\r\n const known = all.map((p) => p.slug).join(\", \") || \"ни одного\";\r\n throw new Error(`Портал «${slug}» не подключён. Подключены: ${known}`);\r\n}\r\n",[],[150,232],"6f4f96bb-2fcf-4cf4-b5fc-d46452863c1b","oauth.ts","b7ecd04e-aac6-11f1-a815-1607ee4eb77e",20,["D",1788790589102],"import { envOpt } from \"./env.ts\";\r\n\r\n/** Учётные данные локального приложения портала. Секрет: наружу не отдаются,\r\n * в вывод не печатаются. */\r\nexport interface AppCreds {\r\n clientId: string;\r\n clientSecret: string;\r\n}\r\n\r\n/** Живой токен приложения. expiresAt — момент истечения в миллисекундах. */\r\nexport interface AppToken {\r\n accessToken: string;\r\n refreshToken: string;\r\n expiresAt: number;\r\n}\r\n\r\nexport interface OauthDeps {\r\n fetchImpl?: typeof fetch;\r\n now?: () => number;\r\n}\r\n\r\n/** Проверено живьём 18 августа 2026 (Н41). */\r\nconst TOKEN_URL = \"https://oauth.bitrix24.tech/oauth/token/\";\r\n\r\n/** Учётные данные портала из окружения, либо undefined — приложение не заведено.\r\n *\r\n * По образцу listPortals в portals.ts: имя переменной строится из слага в\r\n * верхнем регистре. Отсутствие любой из двух переменных — не ошибка, а «приложения\r\n * тут нет»: приложение заведено не на каждом портале, и коннектор обязан работать\r\n * вебхуком там, где его нет. */\r\nexport function appCreds(slug: string): AppCreds | undefined {\r\n const upper = slug.trim().toUpperCase();\r\n const clientId = envOpt(`B24_APP_ID_${upper}`);\r\n const clientSecret = envOpt(`B24_APP_SECRET_${upper}`);\r\n if (!clientId || !clientSecret) return undefined;\r\n return { clientId, clientSecret };\r\n}\r\n\r\ninterface TokenResponse {\r\n access_token?: string;\r\n refresh_token?: string;\r\n expires_in?: number;\r\n error?: string;\r\n error_description?: string;\r\n}\r\n\r\n/** Один запрос к обмену, общий для кода и продления — разница между ними только\r\n * в наборе параметров grant и в том, есть ли прежний refresh_token на подмену.\r\n * Сообщение об ошибке собирается из error/error_description, а не из адреса\r\n * запроса: адрес несёт client_id и client_secret в строке запроса (так требует\r\n * обмен Битрикса), и текст, собранный из него, утёк бы секретом в журнал.\r\n *\r\n * fallbackRefreshToken — прежний refresh_token, если он есть (при продлении).\r\n * Не все реализации OAuth2 перевыпускают refresh_token при обновлении: прежний\r\n * остаётся действующим, и в ответе его просто нет. Разбор, требующий его\r\n * всегда, уронил бы каждое штатное продление обманчивым «без токена» — а доступ\r\n * при этом обновился нормально. При обмене кода fallback не передаётся: там\r\n * refresh_token обязан прийти, иначе продлевать будет нечем впоследствии. */\r\nasync function tokenRequest(\r\n grant: Record,\r\n fetchImpl: typeof fetch,\r\n now: () => number,\r\n fallbackRefreshToken?: string,\r\n): Promise {\r\n const url = `${TOKEN_URL}?${new URLSearchParams(grant)}`;\r\n let res: Response;\r\n try {\r\n res = await fetchImpl(url);\r\n } catch (e) {\r\n // Исключение сетевого слоя несёт полный адрес запроса в cause (проверено:\r\n // Deno заворачивает туда \"error sending request for url (...)\") — вместе\r\n // с client_secret в строке запроса. Пробрасывать исходное исключение или\r\n // класть его в cause нельзя: и то и другое напечатает секрет при первом же\r\n // console.error(e) вызывающей стороны. Тот же приём — в src/rest.ts, once().\r\n throw new Error(`портал обмена токена недоступен (${e instanceof Error ? e.name : \"сбой сети\"})`);\r\n }\r\n const text = await res.text();\r\n let body: TokenResponse;\r\n try {\r\n body = JSON.parse(text) as TokenResponse;\r\n } catch {\r\n // Заглушка хостинга на сбое вполне может ответить HTML вместо JSON (502\r\n // и подобное) — и пустое тело тоже не редкость. Без этой ветки человек\r\n // увидел бы сырой SyntaxError вместо понятной причины. Тот же приём — в\r\n // src/rest.ts, once(): текст ответа сервера в сообщение класть можно,\r\n // секретов в нём нет — секрет уходит в запрос, а не приходит в ответе.\r\n throw new Error(`Битрикс ответил не JSON на обмен токена: ${text.slice(0, 200)}`);\r\n }\r\n // Сперва error, потом access_token: Битрикс отвечает отказом в теле, а не только\r\n // кодом ответа, и проверка, смотрящая лишь на статус, приняла бы отказ за токен.\r\n if (body.error) {\r\n throw new Error(\r\n `Битрикс отказал в обмене токена (${body.error}): ${\r\n body.error_description || \"без пояснения\"\r\n }`,\r\n );\r\n }\r\n if (!body.access_token || typeof body.expires_in !== \"number\") {\r\n throw new Error(\"Битрикс ответил без токена — разобрать обмен нечем\");\r\n }\r\n const refreshToken = body.refresh_token || fallbackRefreshToken;\r\n if (!refreshToken) {\r\n throw new Error(\"Битрикс ответил без refresh_token, а прежнего нет — разобрать обмен нечем\");\r\n }\r\n return {\r\n accessToken: body.access_token,\r\n refreshToken,\r\n // Момент истечения, а не длительность: потребителю нужно знать, когда токен\r\n // истечёт, а не сколько секунд он должен был прожить.\r\n expiresAt: now() + body.expires_in * 1000,\r\n };\r\n}\r\n\r\n/** Обмен кода авторизации на токен. Код добывается разово через браузер и живёт секунды. */\r\nexport function exchangeCode(\r\n creds: AppCreds,\r\n code: string,\r\n deps: OauthDeps = {},\r\n): Promise {\r\n return tokenRequest(\r\n {\r\n grant_type: \"authorization_code\",\r\n client_id: creds.clientId,\r\n client_secret: creds.clientSecret,\r\n code,\r\n },\r\n deps.fetchImpl ?? fetch,\r\n deps.now ?? Date.now,\r\n );\r\n}\r\n\r\n/** Обновление истекающего токена по refresh_token. */\r\nexport function refresh(\r\n creds: AppCreds,\r\n refreshToken: string,\r\n deps: OauthDeps = {},\r\n): Promise {\r\n return tokenRequest(\r\n {\r\n grant_type: \"refresh_token\",\r\n client_id: creds.clientId,\r\n client_secret: creds.clientSecret,\r\n refresh_token: refreshToken,\r\n },\r\n deps.fetchImpl ?? fetch,\r\n deps.now ?? Date.now,\r\n refreshToken,\r\n );\r\n}\r\n",[],[150,240],"9b6e68e0-0145-429c-9e36-1a95a9acd86b","journal.ts","611b2d7e-aac6-11f1-b088-1607ee4eb77e",9,["D",1788790443437],"import { envOpt } from \"./env.ts\";\r\nimport { redact } from \"./redact.ts\";\r\nimport type { Level } from \"./guard.ts\";\r\nimport type { ToolDef, ToolHandler } from \"./rpc.ts\";\r\nimport { getPortal } from \"./portals.ts\";\r\nimport { call } from \"./rest.ts\";\r\nimport { type PortalId, usableId } from \"./ids.ts\";\r\nimport { labelByEntityTypeId } from \"./entities.ts\";\r\n\r\nexport interface Inverse {\r\n method: string;\r\n params: Record;\r\n /** Человеческое описание: что произойдёт при откате. Показывается перед откатом. */\r\n describe: string;\r\n}\r\n\r\nexport interface JournalRow {\r\n id?: string;\r\n portal: string;\r\n ts?: string;\r\n tool: string;\r\n method: string;\r\n params: unknown;\r\n result?: unknown;\r\n level: Level;\r\n inverse?: Inverse | null;\r\n undone_at?: string | null;\r\n note?: string;\r\n}\r\n\r\nconst TABLE = \"b24_journal\";\r\n\r\n/** Идентификатор созданной записи из ответа портала — или null, если портал его\r\n * не назвал ИЛИ назвал непригодным. Раньше проверка была `id === undefined`, и ноль,\r\n * минус единица, «», «0», «0123» и 1.5 давали обратную операцию с мусором: для трёх\r\n * поднадзорных методов её перехватила бы читающая защита, а для crm.item.delete\r\n * и обоих userfield.delete — нет (переревью задачи 8). Живьём портал так не отвечает,\r\n * но правило одно на проект, и исключений у него быть не должно. */\r\nfunction extractId(result: unknown): PortalId | null {\r\n if (typeof result === \"number\" || typeof result === \"string\") return usableId(result);\r\n const r = result as Record | undefined;\r\n return usableId(r?.item?.id ?? r?.ID ?? r?.id);\r\n}\r\n\r\n/** Поля, которые портал вычисляет сам. Возвращать их при воссоздании записи\r\n * бессмысленно, а иногда и вредно: идентификатор всё равно будет новым,\r\n * а даты и авторы создания исказят историю записи. */\r\nconst COMPUTED = new Set([\r\n \"ID\",\r\n \"id\",\r\n \"DATE_CREATE\",\r\n \"createdTime\",\r\n \"DATE_MODIFY\",\r\n \"updatedTime\",\r\n \"CREATED_BY_ID\",\r\n \"createdBy\",\r\n \"MODIFY_BY_ID\",\r\n \"updatedBy\",\r\n \"MOVED_BY_ID\",\r\n \"movedBy\",\r\n \"MOVED_TIME\",\r\n \"movedTime\",\r\n \"LAST_ACTIVITY_BY\",\r\n \"lastActivityBy\",\r\n \"LAST_ACTIVITY_TIME\",\r\n \"lastActivityTime\",\r\n]);\r\n\r\nfunction withoutComputed(snapshot: Record): Record {\r\n const out: Record = {};\r\n for (const [k, v] of Object.entries(snapshot)) {\r\n if (!COMPUTED.has(k)) out[k] = v;\r\n }\r\n return out;\r\n}\r\n\r\n/** Обратная операция строится только тогда, когда её можно построить честно.\r\n * null означает «откатить нельзя» — и это повод не выполнять красную операцию. */\r\nexport function inverseOf(\r\n method: string,\r\n params: Record,\r\n before: unknown,\r\n result: unknown,\r\n): Inverse | null {\r\n const m = method.toLowerCase();\r\n\r\n if (m === \"crm.item.add\") {\r\n const id = extractId(result);\r\n if (id === null) return null;\r\n // Сущность называется по entityTypeId через таблицу различий: с находки Н29\r\n // crm.item.* штатно ходит и по Сделкам, и запись «элемент смарт-процесса 2»\r\n // про обычную сделку человек читал бы как чужую (итоговое ревью, находка 7).\r\n return {\r\n method: \"crm.item.delete\",\r\n params: { entityTypeId: params.entityTypeId, id },\r\n describe: `удалить созданный элемент ${id} в сущности «${\r\n labelByEntityTypeId(params.entityTypeId)\r\n }» (entityTypeId ${params.entityTypeId})`,\r\n };\r\n }\r\n\r\n if (/\\.add$/.test(m)) {\r\n const id = extractId(result);\r\n if (id === null) return null;\r\n return {\r\n method: m.replace(/\\.add$/, \".delete\"),\r\n params: { id },\r\n describe: `удалить созданную запись ${id}`,\r\n };\r\n }\r\n\r\n if (/\\.update$/.test(m)) {\r\n if (!before || typeof before !== \"object\") return null;\r\n const touched = Object.keys((params.fields ?? {}) as Record);\r\n if (touched.length === 0) return null;\r\n const restore: Record = {};\r\n for (const k of touched) {\r\n // Поля, которых в снимке «до» не было вовсе (не заполнены), возвращаем как null —\r\n // явно, а не как undefined: JSON.stringify молча выбрасывает undefined-ключи,\r\n // и обратная операция незаметно забыла бы очистить поле, оставив чужое значение.\r\n const had = Object.prototype.hasOwnProperty.call(before as object, k);\r\n restore[k] = had ? (before as Record)[k] : null;\r\n }\r\n return {\r\n method: m,\r\n params: { ...params, fields: restore },\r\n describe: `вернуть прежние значения полей: ${touched.join(\", \")}`,\r\n };\r\n }\r\n\r\n if (m === \"crm.item.delete\") {\r\n if (!before || typeof before !== \"object\") return null;\r\n // Без entityTypeId вызов crm.item.add невыполним. Честнее вернуть null\r\n // и отказать в красной операции, чем обещать откат, которого не будет.\r\n if (params.entityTypeId === undefined) return null;\r\n const fields = withoutComputed(before as Record);\r\n // Снимок без единого содержательного поля — не снимок: восстанавливать нечего,\r\n // и обещать откат по нему нельзя.\r\n if (Object.keys(fields).length === 0) return null;\r\n return {\r\n method: \"crm.item.add\",\r\n params: { entityTypeId: params.entityTypeId, fields },\r\n describe: `воссоздать удалённый элемент из снимка в сущности «${\r\n labelByEntityTypeId(params.entityTypeId)\r\n }» (entityTypeId ${params.entityTypeId}). ` +\r\n \"Идентификатор будет новым, вычисляемые поля не восстанавливаются, \" +\r\n \"ссылки на прежний элемент останутся битыми\",\r\n };\r\n }\r\n\r\n if (/\\.delete$/.test(m)) {\r\n if (!before || typeof before !== \"object\") return null;\r\n const fields = withoutComputed(before as Record);\r\n // Снимок без единого содержательного поля — не снимок: восстанавливать нечего,\r\n // и обещать откат по нему нельзя.\r\n if (Object.keys(fields).length === 0) return null;\r\n return {\r\n method: m.replace(/\\.delete$/, \".add\"),\r\n params: { fields },\r\n describe: \"воссоздать удалённую запись из снимка. Идентификатор будет новым, \" +\r\n \"вычисляемые поля (даты и авторы создания) не восстанавливаются, \" +\r\n \"ссылки на прежнюю запись останутся битыми\",\r\n };\r\n }\r\n\r\n return null;\r\n}\r\n\r\n/** Записи журнала, сделанные ДО находки Н35, несут неисполнимую обратную операцию:\r\n * crm.status.delete с вычисленным STATUS_ID («C5:ZZNEW», «DT1074_41:INTAKE») вместо\r\n * числового id записи статуса. Портал на такой вызов отвечает «ID is not defined or\r\n * invalid» — то есть откат обещан, но состояться не может.\r\n *\r\n * Код починен (см. inverseOfAction в apply.ts), но ПРЕЖНИЕ записи в базе остались\r\n * и продолжают обещать: на портале fbsm их семь. Чинить их правкой базы мало —\r\n * такие же записи могут лежать на любом другом портале, куда коннектор ходил до\r\n * починки. Поэтому распознавание живёт здесь, в чтении: и b24_journal, и b24_rollback\r\n * обязаны называть такую запись неисполнимой ПРЯМО, а не показывать её доступной\r\n * и упираться в отказ портала (ревью задачи 8, находка 1).\r\n *\r\n * Возвращает причину невыполнимости или null, если с обратной операцией всё в порядке. */\r\nexport function inverseUnusable(inv: Inverse | null | undefined): string | null {\r\n if (!inv) return null;\r\n const m = inv.method.toLowerCase();\r\n // ПРАВИЛО, а не белый список. Здесь стоял перечень из трёх методов — и это было\r\n // то же раздвоение, что чинил весь круг, только мельче: пишущая половина применяла\r\n // мерку ко ВСЕМУ, что строит (inverseOf делает ещё crm.item.delete,\r\n // crm.deal.userfield.delete, userfieldconfig.delete и вообще любой <метод>.delete),\r\n // а читающая следила за тремя. Перечень пришлось бы вспоминать дополнять при каждом\r\n // новом методе — и однажды не вспомнить (переревью третьего круга).\r\n //\r\n // Условий два, и оба обязательны. Первое: метод удаляет. Второе: он адресует запись\r\n // ИМЕННО через id — есть методы удаления, работающие иначе (entity.delete берёт\r\n // ENTITY, lists.element.delete — IBLOCK_ID с ELEMENT_ID), и объявлять их записи\r\n // неисполнимыми значило бы запретить откат тому, о чём мерка ничего не знает.\r\n // Проверяется присутствие ключа, а не истинность значения: params.id === undefined\r\n // это не «идентификатора нет в замысле», а «идентификатор потерян», и молчать о таком\r\n // как раз нельзя.\r\n if (!m.endsWith(\".delete\")) return null;\r\n const params = inv.params ?? {};\r\n if (!Object.prototype.hasOwnProperty.call(params, \"id\")) return null;\r\n const id = params.id;\r\n // Мерку НЕ повторяем, а спрашиваем (ids.ts): именно здесь читающая половина\r\n // однажды разошлась с пишущей — там стояло Number.isFinite, тут isInteger,\r\n // и ответ портала 1.5 давал запись, которую отчёт числил откатываемой, а журнал\r\n // тут же объявлял неисполнимой. Пока правило записано дважды, оно разойдётся снова.\r\n // Проверяется не форма мусора («C5:ZZNEW» содержит двоеточие), а пригодность\r\n // самого идентификатора: так распознаётся и любая негодная запись, ещё не виденная.\r\n if (usableId(id) !== null) return null;\r\n // Объяснение своё там, где у метода есть своя история; для остальных — общее.\r\n // Общее не хуже: человеку важно, что откат не состоится и убирать придётся руками.\r\n const what = m === \"crm.status.delete\"\r\n ? \"это вычисленный STATUS_ID, а метод принимает только числовой id записи статуса; \" +\r\n \"портал ответит «ID is not defined or invalid». Удалите стадию вручную, если она ещё нужна\"\r\n : m === \"crm.category.delete\"\r\n // Ноль у воронки — не просто негодный идентификатор: это воронка по умолчанию\r\n // всей компании, и человек должен прочитать про неё прямо, а не догадаться.\r\n ? \"воронку с таким идентификатором удалить нельзя\" +\r\n (id === 0 ? \"; ноль — это ВОРОНКА ПО УМОЛЧАНИЮ всей компании, и целиться в неё откатом недопустимо\" : \"\") +\r\n \". Удалите воронку вручную, если она ещё нужна\"\r\n : m === \"crm.type.delete\"\r\n ? \"сущность с таким идентификатором удалить нельзя. Удалите её вручную, если она ещё нужна\"\r\n : \"запись с таким идентификатором удалить нельзя. Уберите её вручную, если она ещё нужна\";\r\n // Хвост про Н35 верен только для стадий и только для старых записей: у сущности\r\n // и воронки причина другая, а испорченная запись может появиться и сегодня — если\r\n // портал ответит непригодным идентификатором. Общая формулировка (переревью).\r\n return `ОТКАТ НЕИСПОЛНИМ: запись просит ${m} с идентификатором ${JSON.stringify(id)} — ` +\r\n `${what}. Идентификатором считается положительное целое число или строка цифр; ` +\r\n \"всё прочее портал отвергнет.\";\r\n}\r\n\r\nfunction db(): { url: string; key: string } | null {\r\n const url = envOpt(\"SUPABASE_URL\");\r\n const key = envOpt(\"SUPABASE_KEY\");\r\n return url && key ? { url, key } : null;\r\n}\r\n\r\n/** Подключён ли журнал. Без него обратные операции некуда сохранять,\r\n * а значит обещание отката ничем не обеспечено. */\r\nexport function journalReady(): boolean {\r\n return db() !== null;\r\n}\r\n\r\nexport async function record(row: JournalRow): Promise {\r\n const d = db();\r\n if (!d) return false; // без базы работаем, но молча: журнал не должен ронять операцию\r\n const safe = JSON.parse(redact(JSON.stringify(row)));\r\n try {\r\n const res = await fetch(`${d.url}/rest/v1/${TABLE}`, {\r\n method: \"POST\",\r\n headers: {\r\n apikey: d.key,\r\n Authorization: `Bearer ${d.key}`,\r\n \"Content-Type\": \"application/json\",\r\n Prefer: \"return=minimal\",\r\n },\r\n body: JSON.stringify(safe),\r\n });\r\n return res.ok;\r\n } catch {\r\n return false;\r\n }\r\n}\r\n\r\nexport async function history(portal: string, limit = 50): Promise {\r\n const d = db();\r\n if (!d) return [];\r\n const q = `${d.url}/rest/v1/${TABLE}?portal=eq.${encodeURIComponent(portal)}` +\r\n `&order=ts.desc&limit=${limit}`;\r\n const res = await fetch(q, {\r\n headers: { apikey: d.key, Authorization: `Bearer ${d.key}` },\r\n });\r\n if (!res.ok) return [];\r\n return await res.json() as JournalRow[];\r\n}\r\n\r\nconst APP_TOKEN_TABLE = \"b24_app_tokens\";\r\n\r\nexport interface TokenStoreDeps {\r\n fetchImpl?: typeof fetch;\r\n}\r\n\r\n/** Продление приложения по слагу портала. undefined означает ровно одно —\r\n * авторизация для этого портала ещё не пройдена (строки в таблице нет). Отказ\r\n * САМОГО хранилища (не отвечает, не тот статус) — другое дело и молчать о нём\r\n * нельзя: appToken() иначе примет недоступную базу за непройденную авторизацию\r\n * и отправит человека проходить её заново, хотя она уже пройдена (находка 2\r\n * ревью задачи 2 — record() выше молчит об этом на законных основаниях, журнал\r\n * необязателен; хранилище продления обязательно, и путать эти два случая здесь\r\n * нельзя). Поэтому — в отличие от record() — сбой хранилища бросается, а не\r\n * глотается. */\r\nexport async function loadRefreshToken(slug: string, deps: TokenStoreDeps = {}): Promise {\r\n const d = db();\r\n if (!d) return undefined;\r\n const doFetch = deps.fetchImpl ?? fetch;\r\n let res: Response;\r\n try {\r\n res = await doFetch(\r\n `${d.url}/rest/v1/${APP_TOKEN_TABLE}?portal=eq.${encodeURIComponent(slug)}&select=refresh_token&limit=1`,\r\n { headers: { apikey: d.key, Authorization: `Bearer ${d.key}` } },\r\n );\r\n } catch (e) {\r\n throw new Error(\r\n `Хранилище продления недоступно (${e instanceof Error ? e.name : \"сбой сети\"}) — это не то же ` +\r\n \"самое, что «авторизация не пройдена», и решать этот отказ повторной авторизацией не поможет.\",\r\n );\r\n }\r\n if (!res.ok) {\r\n throw new Error(\r\n `Хранилище продления ответило отказом (${res.status}) — это не то же самое, что «авторизация ` +\r\n \"не пройдена», и решать этот отказ повторной авторизацией не поможет.\",\r\n );\r\n }\r\n const rows = await res.json() as Array<{ refresh_token?: string }>;\r\n return rows[0]?.refresh_token || undefined;\r\n}\r\n\r\n/** Сохраняет продление, замещая прежнюю запись того же портала (upsert по portal).\r\n * Секрет: содержимое не годится ни в лог, ни в текст ошибки — здесь оно только\r\n * уходит в тело запроса к собственному хранилищу.\r\n *\r\n * Возвращает признак успеха, а не глотает неудачу молча (находка 1 ревью задачи 2):\r\n * инструмент b24_authorize обязан знать, сохранилось ли продление на самом деле,\r\n * прежде чем сказать человеку «Готово» — иначе тот пройдёт авторизацию заново,\r\n * получит подтверждение, и после следующего перезапуска коннектора она окажется\r\n * непройденной, без единого признака поломки на своей стороне. */\r\nexport async function storeRefreshToken(\r\n slug: string,\r\n refreshToken: string,\r\n deps: TokenStoreDeps = {},\r\n): Promise {\r\n const d = db();\r\n if (!d) return false;\r\n const doFetch = deps.fetchImpl ?? fetch;\r\n try {\r\n const res = await doFetch(`${d.url}/rest/v1/${APP_TOKEN_TABLE}`, {\r\n method: \"POST\",\r\n headers: {\r\n apikey: d.key,\r\n Authorization: `Bearer ${d.key}`,\r\n \"Content-Type\": \"application/json\",\r\n Prefer: \"resolution=merge-duplicates,return=minimal\",\r\n },\r\n body: JSON.stringify({ portal: slug, refresh_token: refreshToken, updated_at: new Date().toISOString() }),\r\n });\r\n return res.ok;\r\n } catch {\r\n return false;\r\n }\r\n}\r\n\r\nexport async function markUndone(id: string): Promise {\r\n const d = db();\r\n if (!d) return;\r\n await fetch(`${d.url}/rest/v1/${TABLE}?id=eq.${encodeURIComponent(id)}`, {\r\n method: \"PATCH\",\r\n headers: {\r\n apikey: d.key,\r\n Authorization: `Bearer ${d.key}`,\r\n \"Content-Type\": \"application/json\",\r\n Prefer: \"return=minimal\",\r\n },\r\n body: JSON.stringify({ undone_at: new Date().toISOString() }),\r\n });\r\n}\r\n\r\nexport const JOURNAL_TOOLS: ToolDef[] = [\r\n {\r\n name: \"b24_journal\",\r\n description:\r\n \"Что менялось на портале: время, инструмент, метод, уровень опасности и есть ли \" +\r\n \"обратная операция. Смотрите сюда перед откатом и когда надо понять, чьи это правки.\",\r\n inputSchema: {\r\n type: \"object\",\r\n properties: {\r\n portal: { type: \"string\" },\r\n limit: { type: \"number\", description: \"Сколько последних записей, по умолчанию 50\" },\r\n },\r\n required: [\"portal\"],\r\n },\r\n },\r\n {\r\n name: \"b24_rollback\",\r\n description:\r\n \"Откатить ранее выполненные изменения по идентификаторам записей журнала. \" +\r\n \"Откат сам является изменением портала, поэтому требует confirm: true. \" +\r\n \"Записи без обратной операции пропускаются с объяснением, а не молча.\",\r\n inputSchema: {\r\n type: \"object\",\r\n properties: {\r\n portal: { type: \"string\" },\r\n ids: { type: \"array\", items: { type: \"string\" }, description: \"Идентификаторы записей журнала\" },\r\n confirm: { type: \"boolean\" },\r\n },\r\n required: [\"portal\", \"ids\"],\r\n },\r\n },\r\n];\r\n\r\nexport const journalHandlers: Record = {\r\n b24_journal: async (args) => {\r\n const p = getPortal(String(args.portal ?? \"\"));\r\n const limit = typeof args.limit === \"number\" ? args.limit : 50;\r\n const rows = await history(p.slug, limit);\r\n if (rows.length === 0) {\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: \"Журнал пуст или база не подключена (SUPABASE_URL и SUPABASE_KEY).\",\r\n }],\r\n };\r\n }\r\n const brief = rows.map((r) => ({\r\n id: r.id, ts: r.ts, tool: r.tool, method: r.method, level: r.level,\r\n // Неисполнимая обратная операция называется прямо, а не показывается\r\n // доступной: молчание о неисправленном читается как «исправлено».\r\n откат: r.undone_at\r\n ? \"уже откачено\"\r\n : !r.inverse\r\n ? \"невозможен\"\r\n : inverseUnusable(r.inverse) ?? r.inverse.describe,\r\n }));\r\n return { content: [{ type: \"text\", text: JSON.stringify(brief, null, 2) }] };\r\n },\r\n\r\n b24_rollback: async (args) => {\r\n const p = getPortal(String(args.portal ?? \"\"));\r\n const ids = (args.ids ?? []) as string[];\r\n if (args.confirm !== true) {\r\n const rows = (await history(p.slug, 200)).filter((r) => ids.includes(String(r.id)));\r\n const found = new Set(rows.map((r) => String(r.id)));\r\n const missing = ids.filter((id) => !found.has(String(id)));\r\n const plan = rows.map((r) =>\r\n `${r.id}: ${\r\n !r.inverse\r\n ? \"ОТКАТ НЕВОЗМОЖЕН — обратной операции нет\"\r\n : inverseUnusable(r.inverse) ?? r.inverse.describe\r\n }`\r\n );\r\n if (missing.length > 0) plan.push(`не найдено в журнале: ${missing.join(\", \")}`);\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: \"Откат не выполнен: нужно подтверждение человека. Будет сделано:\\n\" +\r\n plan.join(\"\\n\") + \"\\nПовторите вызов с confirm: true.\",\r\n }],\r\n isError: true,\r\n };\r\n }\r\n\r\n const rows = (await history(p.slug, 200)).filter((r) => ids.includes(String(r.id)));\r\n const found = new Set(rows.map((r) => String(r.id)));\r\n const missing = ids.filter((id) => !found.has(String(id)));\r\n const done: string[] = [];\r\n const skipped: string[] = missing.map((id) => `${id}: записи нет среди последних 200 в журнале`);\r\n for (const r of rows) {\r\n if (!r.inverse) { skipped.push(`${r.id}: обратной операции нет`); continue; }\r\n if (r.undone_at) { skipped.push(`${r.id}: уже откачено ранее`); continue; }\r\n // Не отправляем порталу вызов, о котором заранее знаем, что он будет отвергнут:\r\n // человек должен прочитать причину, а не сообщение об ошибке от Битрикса.\r\n const unusable = inverseUnusable(r.inverse);\r\n if (unusable) { skipped.push(`${r.id}: ${unusable}`); continue; }\r\n try {\r\n await call(p, r.inverse.method, r.inverse.params);\r\n await markUndone(String(r.id));\r\n done.push(`${r.id}: ${r.inverse.describe}`);\r\n } catch (e) {\r\n skipped.push(`${r.id}: ${e instanceof Error ? e.message : String(e)}`);\r\n }\r\n }\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: `Откачено: ${done.length}\\n${done.join(\"\\n\")}\\n\\n` +\r\n `Пропущено: ${skipped.length}\\n${skipped.join(\"\\n\")}`,\r\n }],\r\n };\r\n },\r\n};\r\n",[],[150,248],"1be5ccef-882b-44de-bf6d-c6186f7cfec6","ids.ts","c14f11a6-aac6-11f1-9039-1607ee4eb77e",24,["D",1788790604829],"/** ЕДИНСТВЕННАЯ мерка идентификатора, пришедшего от портала.\n *\n * Зачем отдельный модуль. К переревью задачи 8 одно и то же решение — «годится ли\n * это, чтобы им что-то удалить» — было записано в проекте ПЯТЬЮ способами: requireId\n * в entities.ts (бросок), usableId в apply.ts (null), inverseUnusable в journal.ts\n * (чтение) и два разбора ответа портала, где стояло просто Number.isFinite. Половины\n * разошлись ровно там, где их писали в разное время: пишущая принимала 1.5,\n * а читающая тут же объявляла такую запись неисполнимой. Проект болел этим трижды,\n * и каждый раз лечилось одинаково — правило переносится в одно место, и все\n * начинают его СПРАШИВАТЬ, а не помнить.\n *\n * Модуль намеренно ни от чего не зависит: его волен звать любой слой, и цикла\n * импортов не возникнет ни при какой будущей правке.\n */\n\n/** Идентификатор в том виде, в каком его дал портал. Число у одних методов,\n * строка цифр у других (Н32 против Н34) — приводить одно к другому незачем:\n * удалять надо тем значением, которое портал сам и назвал. */\nexport type PortalId = number | string;\n\n/** Годится ли значение как идентификатор для правки или удаления записи.\n *\n * Годятся: положительное целое число и строка из одних цифр без ведущего нуля.\n * Не годятся — и каждый случай наблюдался или был предъявлен ревью:\n * undefined, null — портал не назвал идентификатора вовсе;\n * 0 — Number(null), Number(\"\") и Number(false) равны нулю, и ноль\n * выглядит как настоящий номер; у воронок это вдобавок воронка\n * по умолчанию всей компании;\n * отрицательное — идентификаторов таких не бывает;\n * дробное (1.5) — Number.isFinite его пропускал, а портал отвергнет;\n * Infinity, NaN — то же самое;\n * \"0\", \"0123\" — ведущий ноль означает, что это не номер, а строка;\n * \"\", \"нечисло\" — не номер;\n * true, {}, [] — портал ответил не тем, что мы умеем читать.\n */\nexport function usableId(raw: unknown): PortalId | null {\n if (typeof raw === \"number\") return Number.isInteger(raw) && raw > 0 ? raw : null;\n if (typeof raw === \"string\") return /^[1-9][0-9]*$/.test(raw) ? raw : null;\n return null;\n}\n\n/** То же решение, но при непригодном — отказ вместо null.\n *\n * Две обёртки нужны потому, что непригодность значит РАЗНОЕ в разных местах.\n * При чтении структуры портала она значит «портал ответил непонятным»: читать\n * дальше нельзя, потому что по выдуманному номеру переименование и удаление уйдут\n * на чужую запись, — здесь бросок. При разборе ответа на создание она значит\n * «откатить нечем»: действие уже выполнено, ронять применение поздно и незачем —\n * там usableId и честная строка человеку в отчёте.\n *\n * Возвращает число, а не PortalId: прочитанные структуры хранят id числом\n * (ActualField.id, ActualStage.id), и строка цифр приводится здесь один раз. */\nexport function requireId(raw: unknown, what: string): number {\n const ok = usableId(raw);\n if (ok === null) {\n throw new Error(\n `Портал вернул ${what} без пригодного идентификатора (получено ${\n raw === null ? \"null\" : raw === undefined ? \"ничего\" : JSON.stringify(raw)\n }). Читать такое я не умею и гадать не буду: по выдуманному номеру ` +\n \"переименование и удаление уйдут не на ту запись.\",\n );\n }\n return Number(ok);\n}\n\n/** Идентификатор воронки — единственное место, где НОЛЬ ЗАКОНЕН: у Сделок воронка\n * по умолчанию имеет id 0 (Н22, Р11), её читают всегда и не трогают никогда.\n * Отдельная функция, а не флаг у requireId: разница не в строгости, а в смысле,\n * и её нельзя терять при следующей правке.\n *\n * Обратите внимание на асимметрию, она намеренная: ПРОЧИТАТЬ воронку 0 можно,\n * а построить обратную операцию crm.category.delete с id 0 нельзя — это и была бы\n * попытка снести воронку всей компании. Второе решает usableId, и он ноль отвергает. */\nexport function requireCategoryId(raw: unknown): number {\n if (typeof raw === \"number\" && Number.isInteger(raw) && raw >= 0) return raw;\n if (typeof raw === \"string\" && /^(0|[1-9][0-9]*)$/.test(raw)) return Number(raw);\n throw new Error(\n `Портал вернул воронку без пригодного идентификатора (получено ${\n raw === null ? \"null\" : raw === undefined ? \"ничего\" : JSON.stringify(raw)\n }). Читать такое я не умею и гадать не буду: из этого номера строятся имена ` +\n \"стадий, и из непрочитанного они выйдут вида DEAL_STAGE_NaN.\",\n );\n}\n",[],[150,256],"f5fe0853-918a-47ec-8cc1-d9098d3802b5","guard.ts","becbe7f6-aac6-11f1-8a32-1607ee4eb77e",23,["D",1788790600636],"export type Level = \"green\" | \"yellow\" | \"red\";\n\nexport interface Verdict {\n level: Level;\n reason: string;\n}\n\n/** Свыше этого числа затрагиваемых записей операция перестаёт быть рутинной. */\nexport const BULK_THRESHOLD = 10;\n\nconst RED = /\\.[a-z0-9_]*(delete|remove|unbind|clear)[a-z0-9_]*$/i;\nconst YELLOW = /\\.(update|set|move|bind|import)$/i;\nconst GREEN_WRITE = /\\.(add|create)$/i;\nconst GREEN_READ = /\\.(list|get|fields|getbyentitytypeid|getlist|search|stat)$/i;\nconst GREEN_PLAIN = /^(profile|scope|methods|server\\.time|user\\.current|app\\.info)$/i;\n\n/** Порядок уровней по возрастанию опасности. Записан здесь один раз:\n * его копии в этом проекте расходились молча трижды. */\nexport const LEVEL_ORDER: Record = { green: 0, yellow: 1, red: 2 };\n\nfunction raise(a: Verdict, b: Verdict): Verdict {\n return LEVEL_ORDER[a.level] >= LEVEL_ORDER[b.level] ? a : b;\n}\n\n/** Команда пакета приходит в двух видах: сырой строкой «метод?параметры», как её\n * ждёт REST Битрикса, и объектом {method, params}, как её строит наш клиент.\n * Разбираем оба — через b24_call человек пришлёт первый вид, изнутри придёт второй. */\nfunction innerMethod(entry: unknown): string | undefined {\n if (typeof entry === \"string\") {\n const head = entry.split(\"?\")[0].trim();\n return head.length > 0 ? head : undefined;\n }\n if (entry && typeof entry === \"object\") {\n const m = (entry as { method?: unknown }).method;\n if (typeof m === \"string\" && m.trim().length > 0) return m.trim();\n }\n return undefined;\n}\n\n/** Неразобранный состав пакета считается красным: неизвестное содержимое\n * потенциально необратимой операции опаснее лишнего вопроса человеку. */\nfunction classifyBatch(params: Record, affected: number): Verdict {\n const cmd = params?.cmd;\n const entries = cmd && typeof cmd === \"object\"\n ? Object.values(cmd as Record)\n : [];\n if (entries.length === 0) {\n return { level: \"red\", reason: \"состав пакета не разобран, судить по нему нельзя\" };\n }\n\n let worst: Verdict = { level: \"green\", reason: \"все команды пакета безопасны\" };\n for (const entry of entries) {\n const inner = innerMethod(entry);\n if (inner === undefined) {\n return { level: \"red\", reason: \"в пакете есть команда, метод которой не распознан\" };\n }\n const v = classify(inner, {}, 1);\n worst = raise(worst, {\n level: v.level,\n reason: `самая опасная команда пакета — ${inner}: ${v.reason}`,\n });\n }\n\n const count = Math.max(affected, entries.length);\n if (count > BULK_THRESHOLD) {\n worst = raise(worst, {\n level: \"yellow\",\n reason: `команд в пакете: ${entries.length}, порог массовой операции ${BULK_THRESHOLD}`,\n });\n }\n return worst;\n}\n\nexport function classify(\n method: string,\n params: Record = {},\n affected = 1,\n): Verdict {\n const m = method.trim();\n\n // Пакет опасен ровно настолько, насколько опасна самая опасная команда внутри.\n // Судить его по имени нельзя: под именем batch проходит до 50 любых вызовов,\n // включая удаление.\n if (/^batch$/i.test(m)) return classifyBatch(params, affected);\n\n let base: Verdict;\n if (RED.test(m)) {\n base = { level: \"red\", reason: \"удаление: восстановить можно только обратной операцией\" };\n } else if (YELLOW.test(m)) {\n base = { level: \"yellow\", reason: \"правка существующей записи\" };\n } else if (GREEN_WRITE.test(m)) {\n base = { level: \"green\", reason: \"создание нового, существующее не затрагивается\" };\n } else if (GREEN_READ.test(m) || GREEN_PLAIN.test(m)) {\n base = { level: \"green\", reason: \"чтение, портал не изменяется\" };\n } else {\n // Незнакомый метод не может быть зелёным: неизвестное считаем опасным.\n base = { level: \"yellow\", reason: \"метод неизвестен классификатору, идём осторожно\" };\n }\n\n if (affected > BULK_THRESHOLD) {\n return raise(base, {\n level: \"yellow\",\n reason: `затрагивается записей: ${affected}, порог массовой операции ${BULK_THRESHOLD}`,\n });\n }\n return base;\n}\n",[],[150,264],"5d6458ad-214b-4314-bb38-dae904579512","errors.ts","ba91235e-aac6-11f1-8899-1607ee4eb77e",21,["D",1788790593515],"import { redact } from \"./redact.ts\";\r\n\r\n/** Подсказки собраны разведкой на живом портале 11 августа 2026.\r\n * Номера Н соответствуют находкам в спецификации решения. */\r\nconst HINTS: Array<{ match: RegExp; hint: string }> = [\r\n {\r\n match: /Application context required/i,\r\n hint:\r\n \"Метод требует контекста приложения OAuth и входящему вебхуку недоступен в принципе \" +\r\n \"(находка Н2). С задачи 2 этапа 3 выбор пути делает call() сам (needsApp в \" +\r\n \"src/appcall.ts) — если это сообщение всё же дошло сюда, значит на портале не \" +\r\n \"заведено локальное приложение (B24_APP_ID_<слаг>/B24_APP_SECRET_<слаг>) либо не \" +\r\n \"пройдена его разовая авторизация. Вызовите b24_authorize — он заведёт то, чего \" +\r\n \"не хватает, и объяснит, что делать дальше.\",\r\n },\r\n {\r\n match: /не можете просматривать настройки пользовательских полей/i,\r\n hint:\r\n \"Это сообщение не о правах, а о неверном entityId — ловушка Битрикса (Н3, Н5). \" +\r\n \"userfieldconfig.list с одним moduleId: 'crm' работает и отдаёт все поля. \" +\r\n \"В entityId нужен ВНУТРЕННИЙ id смарт-процесса в виде CRM_<внутренний id> \" +\r\n \"(например CRM_13), а не CRM_ (CRM_1054). Оба идентификатора \" +\r\n \"отдаёт b24_snapshot.\",\r\n },\r\n {\r\n match: /Смарт-процесс не найден|Smart process not found/i,\r\n hint:\r\n \"Частая причина — перепутаны идентификаторы (находка Н5). crm.type.get принимает \" +\r\n \"внутренний id, а привычный entityTypeId понимает только crm.type.getByEntityTypeId.\",\r\n },\r\n {\r\n match: /QUERY_LIMIT_EXCEEDED|Too many requests/i,\r\n hint:\r\n \"Превышена частота обращений: Битрикс допускает около двух запросов в секунду. \" +\r\n \"Клиент повторит сам; если повторяется устойчиво — сократите объём или примените пакеты.\",\r\n },\r\n {\r\n match: /must be array/i,\r\n hint:\r\n \"Параметр отправлен строкой там, где ждут массив или объект. Тело запроса надо слать \" +\r\n \"как JSON с заголовком Content-Type: application/json, а не формой.\",\r\n },\r\n {\r\n match: /INVALID_CREDENTIALS|WRONG_AUTH_TYPE|NO_AUTH_FOUND/i,\r\n hint:\r\n \"Вебхук недействителен: отозван, пересоздан или скопирован не полностью. \" +\r\n \"Нужен новый входящий вебхук из раздела «Разработчикам» портала.\",\r\n },\r\n];\r\n\r\nexport function explain(code: string, description: string): string | undefined {\r\n const probe = `${code} ${description}`;\r\n return HINTS.find((h) => h.match.test(probe))?.hint;\r\n}\r\n\r\nexport class BitrixError extends Error {\r\n readonly code: string;\r\n readonly description: string;\r\n readonly method: string;\r\n readonly hint?: string;\r\n\r\n constructor(code: string, description: string, method: string, context = \"\") {\r\n const hint = explain(code, description);\r\n const parts = [\r\n `Битрикс отказал на методе ${method}: ${description || code || \"без пояснения\"}`,\r\n ];\r\n if (hint) parts.push(`Подсказка: ${hint}`);\r\n if (context) parts.push(`Обращение: ${context}`);\r\n super(redact(parts.join(\"\\n\")));\r\n this.name = \"BitrixError\";\r\n this.code = code;\r\n this.description = description;\r\n this.method = method;\r\n this.hint = hint;\r\n }\r\n}\r\n",[],[150,272],"b458b8de-f7c0-40c7-af4c-85f54f399a74","env.ts","b34b9980-aac6-11f1-b49b-1607ee4eb77e",18,["D",1788790581323],"/** Единственная точка доступа к переменным окружения. Нигде больше Deno.env не трогаем. */\nexport function env(name: string): string {\n const v = Deno.env.get(name);\n if (!v) throw new Error(`Переменная окружения ${name} не задана`);\n return v;\n}\n\nexport function envOpt(name: string): string | undefined {\n const v = Deno.env.get(name);\n return v && v.length > 0 ? v : undefined;\n}\n",[],[150,280],"ec024e10-8c69-41b1-ba5f-10dedfaa8b55","entities.ts","5ea69984-aac6-11f1-b7dd-1607ee4eb77e",8,["D",1788790439315],"import type { Portal } from \"./portals.ts\";\nimport { call, type RestDeps } from \"./rest.ts\";\nimport type { Level } from \"./guard.ts\";\nimport { requireId, usableId } from \"./ids.ts\";\n\nexport type EntityKind = \"deal\" | \"smartProcess\";\n\n/** Идентификаторы сущности на конкретном портале. */\nexport interface Ids {\n entityTypeId: number;\n /** Внутренний id типа. Есть только у смарт-процессов. */\n typeId?: number;\n}\n\nexport interface RestCall {\n method: string;\n params: Record;\n}\n\nexport interface ActualField {\n id: number;\n fieldName: string;\n userTypeId: string;\n title: string;\n mandatory: boolean;\n multiple: boolean;\n /** Значения перечисления, как их отдаёт портал. Пустой список у полей любого\n * другого типа и у смарт-процессов (Н20: портал теряет значения, читать нечего).\n * Не опционально: обе реализации readFields обязаны сказать про состав прямо,\n * а не оставить его undefined — самопроверка иначе не отличит «значений нет»\n * от «читать не научились» (задача 8, сверка Н25 своим кодом). */\n items: string[];\n}\n\n/** То, что нужно таблице от поля спецификации, чтобы собрать вызов. */\nexport interface FieldWanted {\n key: string;\n type: string;\n title: string;\n required: boolean;\n multiple: boolean;\n items: string[];\n}\n\nexport interface EntityOps {\n kind: EntityKind;\n /** Как называть сущность человеку: «воронка сделок», «смарт-процесс». */\n label: string;\n /** Сущность ищется на портале по названию (смарт-процесс) или есть всегда (сделки). */\n discoverable: boolean;\n /** Известен заранее — только у сделок. */\n fixedEntityTypeId?: number;\n /** Ровно одна провальная стадия (смарт-процессы) или сколько угодно (сделки, Н24). */\n singleFailureStage: boolean;\n /** Значения перечисления задаются через вебхук (сделки, Н25) или теряются (Н20). */\n enumItemsSupported: boolean;\n /** Пространство имён пользовательских полей общее на весь портал (сделки) или своё\n * у каждой сущности (смарт-процессы, entityId CRM_). Это факт о портале,\n * а не настройка: у смарт-процесса readFields фильтрует список по своему entityId\n * и видит только свои поля, а у Сделок фильтровать не по чему — crm.deal.userfield.list\n * отдаёт ВСЕ поля сделок портала, заведённые всеми интеграциями и людьми.\n * Отсюда следствие, которым пользуется сличение: «лишним» у такой сущности считать\n * нечего, и prune её полей не удаляет (итоговое ревью ветки, находка 2). */\n sharedFieldNamespace: boolean;\n /** Почему у созданного поля не нашлось обратной операции. Метод создания у сущностей\n * разный, и назвать чужой значило бы соврать человеку про вызов, которого не было\n * (переревью задачи 7, находка 1). Текст живёт здесь, а не условием по имени сущности\n * в reasonNoRollback: разница сущностей — дело таблицы, и Р10 обещала, что условий\n * по имени сущности в apply.ts не останется (итоговое ревью ветки, находка 5). */\n noFieldIdReason: string;\n /** Стадии воронки по умолчанию не трогаются (сделки, Р11). */\n protectDefaultCategory: boolean;\n /** Уровень действия «создать воронку»: у смарт-процесса своя воронка не видна\n * никому, кроме процесса, а у Сделок новая воронка сразу заметна во всей CRM\n * компании — это правка рабочего процесса, а не создание своей структуры. */\n newCategoryLevel: Level;\n stageEntityId(ids: Ids, categoryId: number): string;\n stageStatusId(ids: Ids, categoryId: number, key: string): string;\n fieldName(ids: Ids, key: string): string;\n fieldAdd(ids: Ids, f: FieldWanted): RestCall;\n fieldRename(fieldId: number, fieldName: string, to: string): RestCall;\n /** Идентификатор приходит сюда из ДВУХ разных источников, и формы у них разные.\n * Из ответа на создание (fieldIdFromAddResult) — как есть: у сделок число (Н32),\n * у смарт-процессов строка цифр (Н34); сверить его там не с чем, и приводить\n * к другому типу значило бы удалять по значению, которого портал не называл.\n * Из readFields — числом: именно числовая форма проверена живьём на\n * userfieldconfig.update, и менять проверенное ради единообразия нельзя.\n * Отсюда `number | string`: это не «как дал портал» вообще, а честное признание,\n * что источников два и живьём подтверждены разные их формы (ревью задачи 8,\n * находка 2 — прежняя формулировка обещала больше, чем делал код). */\n fieldDelete(fieldId: number | string, fieldName: string): RestCall;\n /** Идентификатор созданного поля из ответа портала на fieldAdd — или null, если\n * ответ не той формы, которую этот метод действительно отдаёт. Формы у сущностей\n * РАЗНЫЕ и обе выяснены живьём, поэтому разбор живёт здесь, в таблице, а не\n * условием по сущности в inverseOfAction (Р10): условие посреди кода забывается\n * при следующей правке, а перепутанные формы означают удаление ЧУЖОГО поля\n * с тем же номером у другой сущности. null — законный ответ: он означает\n * «откатить нельзя честно», и applySpec скажет об этом человеку прямо. */\n fieldIdFromAddResult(result: unknown): number | string | null;\n readFields(portal: Portal, ids: Ids, deps: RestDeps): Promise;\n}\n\n/** Битрикс приводит UF_CRM_15_ADDRESS к ufCrm15Address в crm.item.* (Н12):\n * подчёркивания съедаются, каждый кусок с заглавной буквы, кроме первого.\n * ПЕРВЫЙ кусок (\"UF\") остаётся частью имени, просто в нижнем регистре —\n * его нельзя отбрасывать, иначе \"UF_CRM_15_ADDRESS\" превратится в\n * \"crm15Address\" вместо настоящего \"ufCrm15Address\", и поле в ответе портала\n * просто не найдётся: тихая ошибка, которую заметить труднее всего. */\nexport function camel(uf: string): string {\n const parts = uf.split(\"_\").filter(Boolean); // UF, CRM, 15, ADDRESS\n return parts\n .map((p, i) => {\n const low = p.toLowerCase();\n return i === 0 ? low : low.charAt(0).toUpperCase() + low.slice(1);\n })\n .join(\"\");\n}\n\nexport const yes = (v: unknown): boolean => v === \"Y\" || v === true;\n\n// Мерка идентификатора живёт в ids.ts — одна на весь проект (переревью задачи 8).\n// Реэкспорт держит прежние импорты `import { requireId } from \"./entities.ts\"`\n// рабочими и не заводит второй копии правила.\nexport { requireId, usableId } from \"./ids.ts\";\n\n/** Нормализация имени для сверки без учёта регистра и лишних пробелов: находка\n * ревью задачи 4 — сличение сверяло воронки только по .trim(), без регистра, и\n * «Общая воронка»/«общая воронка» читались как разные. Нужна и structure.ts\n * (поиск смарт-процесса и воронки по названию), и plan.ts (сличение воронок), и\n * spec.ts (задача 5, находка ревью: проверка коллизии имён воронок в\n * validateSpec) — живёт здесь, в нейтральном модуле без зависимости от них,\n * а не в structure.ts, откуда её пришлось бы импортировать в spec.ts и заводить\n * цикл spec → structure → spec (ревью задачи 5, находка 7). */\nexport const norm = (s: string) => s.trim().toLowerCase();\n\n/** Элементы списка, которые не являются объектами, — признак того, что портал\n * ответил не тем, что мы умеем читать. Молчать об этом нельзя: ложное «поля нет»\n * приведёт к созданию двойника на боевом портале.\n * Пустой список при этом законен: сущность без единого пользовательского поля —\n * нормальный случай. А вот null, число или строка вместо списка — нет.\n * Общая для structure.ts (чтение воронок) и здесь (чтение полей): два места\n * разбирали один и тот же ответ портала по одному и тому же правилу — второй\n * копии взяться было неоткуда. */\nexport function asObjects(v: unknown, what: string): Record[] {\n const raw = Array.isArray(v)\n ? v\n : v !== null && typeof v === \"object\"\n ? Object.values(v as Record).flat()\n : undefined;\n if (raw === undefined) {\n throw new Error(\n `Портал вернул ${what} в неожиданном виде: ${\n v === null ? \"null\" : v === undefined ? \"ничего\" : typeof v\n } вместо списка. Читать такое я не умею и гадать не буду: ` +\n \"принять это за пустоту значит решить, что процесса нет, и создать двойник.\",\n );\n }\n const out: Record[] = [];\n for (const item of raw) {\n if (!item || typeof item !== \"object\") {\n throw new Error(\n `Портал вернул ${what} в неожиданном виде: среди элементов есть ${\n item === null ? \"null\" : typeof item\n }. Читать такое я не умею и гадать не буду.`,\n );\n }\n out.push(item as Record);\n }\n return out;\n}\n\nconst DEAL: EntityOps = {\n kind: \"deal\",\n label: \"воронка сделок\",\n discoverable: false,\n fixedEntityTypeId: 2,\n // Н24: новая воронка получает ДВЕ провальных стадии — «Сделка провалена»\n // и «Анализ причины провала». Требовать ровно одну значит отвергать\n // то, что портал делает сам.\n singleFailureStage: false,\n // Н25: crm.deal.userfield.add возвращает значения списка с присвоенными id.\n // У смарт-процессов (Н20) те же значения теряются молча.\n enumItemsSupported: true,\n // Поля сделок общие на весь портал: crm.deal.userfield.list отдаёт все 37 полей\n // боевого портала fbsm — Wazzup, прежние интеграции, ручные поля отдела продаж.\n // Фильтра по воронке у них нет и быть не может: воронка сделки — это категория,\n // а поле принадлежит СДЕЛКЕ, а не категории.\n sharedFieldNamespace: true,\n noFieldIdReason: \"портал ответил на crm.deal.userfield.add не числом — идентификатор \" +\n \"созданного поля сделки из такого ответа не берётся (Н32: обычно приходит голое число)\",\n // Р11: в воронке по умолчанию лежат живые сделки всей компании.\n protectDefaultCategory: true,\n // Новая воронка появляется в CRM компании сразу и видна в каждой сделке —\n // без вопроса человеку это правка чужого рабочего процесса, а не своей структуры.\n newCategoryLevel: \"yellow\",\n // Н22 и Н23: воронка с id 0 адресуется особыми именами. Особый случай стоит\n // здесь, в таблице, а не условием посреди кода: спрятанный в ветке, он\n // забывается при следующей правке.\n stageEntityId: (_ids, categoryId) => categoryId === 0 ? \"DEAL_STAGE\" : `DEAL_STAGE_${categoryId}`,\n stageStatusId: (_ids, categoryId, key) =>\n categoryId === 0 ? key.toUpperCase() : `C${categoryId}:${key.toUpperCase()}`,\n fieldName: (_ids, key) => `UF_CRM_${key.toUpperCase()}`,\n fieldAdd: (_ids, f) => ({\n method: \"crm.deal.userfield.add\",\n params: {\n fields: {\n FIELD_NAME: `UF_CRM_${f.key.toUpperCase()}`,\n USER_TYPE_ID: f.type,\n MANDATORY: f.required ? \"Y\" : \"N\",\n MULTIPLE: f.multiple ? \"Y\" : \"N\",\n EDIT_FORM_LABEL: { ru: f.title },\n LIST_COLUMN_LABEL: { ru: f.title },\n // Значения списка передаются: Н25. Пустой список не передаём вовсе,\n // чтобы не отправлять порталу пустое поле там, где оно не нужно.\n ...(f.items.length > 0 ? { LIST: f.items.map((v) => ({ VALUE: v })) } : {}),\n },\n },\n }),\n // Оба ключа, как и при создании, — и это не симметрия ради красоты. Название поля\n // сделки коннектор ЧИТАЕТ из crm.deal.fields[ИМЯ].listLabel, то есть из колоночной\n // подписи (Н26). Прежнее переименование задавало только EDIT_FORM_LABEL: правка\n // проходила, следующее чтение возвращало прежнее название, переименование\n // планировалось снова — пять кругов и «НЕ ЗАВЕРШЕНО», при том что описание\n // b24_apply обещает идемпотентность (итоговое ревью ветки, находка 3). Живьём эта\n // ветка не проверялась ни разу, а заготовка теста выводила listLabel из\n // EDIT_FORM_LABEL — то есть повторяла допущение разбора и по построению не могла\n // поймать расхождение.\n fieldRename: (fieldId, _fieldName, to) => ({\n method: \"crm.deal.userfield.update\",\n params: { id: fieldId, fields: { EDIT_FORM_LABEL: { ru: to }, LIST_COLUMN_LABEL: { ru: to } } },\n }),\n fieldDelete: (fieldId) => ({ method: \"crm.deal.userfield.delete\", params: { id: fieldId } }),\n // Н32 (живая сборка задачи 8 на портале fbsm, записи журнала 7b747f38 и d3f0b2ee):\n // crm.deal.userfield.add отвечает ГОЛЫМ ЧИСЛОМ — идентификатором созданного поля\n // (617, 619). Ни обёртки {field: {id}}, как у userfieldconfig.add смарт-процессов,\n // ни {ID: …}, ни выдуманного планированием {: true}.\n // Строго число, и ничего кроме: любая другая форма означает, что портал ответил\n // не тем, чего мы ждём, — и тогда честнее отказаться от отката, чем вытащить\n // из чужой формы правдоподобное число и удалить им ЧУЖОЕ поле. Ровно этим кончилась\n // эвристика по выдуманному образцу, которую поймало ревью задачи 5: форма\n // {\"739\": {ID: \"739\", VALUE: \"Обычная\"}} из Н25 давала id 739.\n // Ответ читается КАК ЕСТЬ — голым значением с верхнего уровня. Внутрь обёрток\n // здесь не заглядывают НИКОГДА, и в этом вся разница со смарт-процессной веткой\n // (та берёт result.field.id): чужая обёртка {field:{id}} или {\"739\": {...}} из Н25\n // отвергается сама собой, потому что мерка объектов не принимает. Отдельной охраны\n // typeof тут прежде стояли зря — комментарий обещал проверку формы, которую на деле\n // делала мерка (переревью третьего круга). Ещё раньше здесь было своё\n // Number.isFinite: оно принимало дробное, и половины расходились.\n fieldIdFromAddResult: (result) => usableId(result),\n // Разведано разведочным скриптом (scripts/probe-deal-fields.ts) на портале fbsm\n // 12 августа 2026 — см. progress.md задачи 3, шаг 1. Ключи crm.deal.userfield.list\n // ПРОПИСНЫЕ (ID, ENTITY_ID, FIELD_NAME, USER_TYPE_ID, MANDATORY, MULTIPLE), в\n // отличие от userfieldconfig.list у смарт-процессов, где они camelCase.\n readFields: async (portal, ids, deps) => {\n const ufs = await call(portal, \"crm.deal.userfield.list\", {}, deps);\n // Н28: crm.deal.fields — не {fields: {...}}, как crm.item.fields у смарт-процессов,\n // а плоская карта FIELD_NAME -> описание ПРЯМО на верхнем уровне результата.\n // Читать здесь result.fields значило бы получать пустую карту на каждом поле —\n // без единой ошибки от портала, только пустые названия везде.\n const dealFields = await call>(portal, \"crm.deal.fields\", {}, deps)\n .catch(() => ({} as Record));\n return asObjects(ufs, \"список пользовательских полей сделки\").map((f) => {\n const fn = String(f.FIELD_NAME ?? \"\");\n // Отсутствующий ID — отказ, а не 0: 0 выглядит как настоящий идентификатор,\n // и переименование или удаление ушло бы на чужое поле вместо явного сбоя\n // (ревью задачи 3, находка 6). Проверка вынесена в requireId: прежняя,\n // здешняя, ловила только NaN и пропускала null и пустую строку — обе дают\n // ровно тот ноль, ради запрета которого её и писали (ревью задачи 8).\n const rawId = requireId(f.ID, `поле сделки (FIELD_NAME ${fn || \"неизвестно\"})`);\n // Н26: crm.deal.fields кладёт в title системное имя поля, а человеческое\n // название — в listLabel. Взять title значило бы показать человеку\n // «UF_CRM_ZZTEST» вместо «Приоритет» и запланировать переименование поля\n // в самого себя на каждом применении.\n const byPortal = dealFields[fn] as Record | undefined;\n const listLabel = typeof byPortal?.listLabel === \"string\" ? byPortal.listLabel : \"\";\n // Запасной путь на случай, если в crm.deal.fields записи нет: EDIT_FORM_LABEL.ru\n // из самого userfield.list. Не наблюдался живьём ни у одного из 37 полей на\n // fbsm (см. progress.md) — ни одно из них не заведено через наш код, а только\n // он передаёт этот ключ при создании (DEAL.fieldAdd). Регистр ключа выведен по\n // аналогии с остальными ключами userfield.list (все ПРОПИСНЫЕ), не проверен.\n const editFormLabel = (f.EDIT_FORM_LABEL as Record | undefined)?.ru;\n // Пустая строка не должна побеждать запасной путь — то же правило, что у\n // смарт-процессов (там в titleByCamel попадает только непустое title),\n // записанное здесь тем же способом, а не оператором ?? (находка 4).\n const title = listLabel.length > 0\n ? listLabel\n : typeof editFormLabel === \"string\" && editFormLabel.length > 0\n ? editFormLabel\n : \"\";\n return {\n id: rawId,\n fieldName: fn,\n userTypeId: String(f.USER_TYPE_ID ?? \"\"),\n title,\n mandatory: yes(f.MANDATORY),\n multiple: yes(f.MULTIPLE),\n items: enumValues(byPortal?.items, f.LIST),\n };\n });\n },\n};\n\n/** Значения перечисления из ответов портала. Оба источника наблюдались живьём на\n * поле, созданном нашим же кодом (задача 8, UF_CRM_ZZ_TEST_GRADE):\n * crm.deal.fields[FIELD_NAME].items — [{ID, VALUE}], по возрастанию ID;\n * crm.deal.userfield.list[].LIST — [{ID, SORT, VALUE, DEF, XML_ID}], порядок\n * ПРОИЗВОЛЬНЫЙ (пришло A, C, B при SORT 500\n * у всех трёх) — Н33.\n * Первый источник предпочтён вторым не порядком (сверка всё равно идёт множеством),\n * а тем же соображением, что и для названия: crm.deal.fields — то, что портал\n * показывает как поле сейчас. Второй — запасной, на случай отсутствия записи. */\nfunction enumValues(fromDealFields: unknown, fromUserfieldList: unknown): string[] {\n for (const src of [fromDealFields, fromUserfieldList]) {\n if (!Array.isArray(src)) continue;\n const out: string[] = [];\n for (const it of src) {\n const v = (it as Record | null)?.VALUE;\n // Пустое значение не пропускаем молча: список значений, где одно из них\n // прочиталось пустотой, — не тот список, с которым можно сверять состав.\n if (typeof v === \"string\" && v.length > 0) out.push(v);\n }\n if (out.length > 0) return out;\n }\n return [];\n}\n\nconst SMART: EntityOps = {\n kind: \"smartProcess\",\n label: \"смарт-процесс\",\n discoverable: true,\n singleFailureStage: true,\n enumItemsSupported: false,\n // Поля смарт-процесса живут под своим entityId (CRM_), и readFields\n // фильтрует по нему: всё, что видно сличению, заведено этой же сущностью.\n sharedFieldNamespace: false,\n noFieldIdReason: \"портал не вернул идентификатор созданного поля смарт-процесса\",\n protectDefaultCategory: false,\n // Своя воронка своего же смарт-процесса, никому больше не видна — как раньше.\n newCategoryLevel: \"green\",\n stageEntityId: (ids, categoryId) => `DYNAMIC_${ids.entityTypeId}_STAGE_${categoryId}`,\n stageStatusId: (ids, categoryId, key) =>\n `DT${ids.entityTypeId}_${categoryId}:${key.toUpperCase()}`,\n fieldName: (ids, key) => `UF_CRM_${ids.typeId}_${key.toUpperCase()}`,\n fieldAdd: (ids, f) => ({\n method: \"userfieldconfig.add\",\n params: {\n moduleId: \"crm\",\n field: {\n entityId: `CRM_${ids.typeId}`,\n fieldName: `UF_CRM_${ids.typeId}_${f.key.toUpperCase()}`,\n userTypeId: f.type,\n mandatory: f.required ? \"Y\" : \"N\",\n multiple: f.multiple ? \"Y\" : \"N\",\n editFormLabel: { ru: f.title },\n listColumnLabel: { ru: f.title },\n // Значения списка сюда намеренно не передаются: Н20, портал принимает\n // их без ошибки и молча теряет — проверено пятью способами.\n },\n },\n }),\n fieldRename: (fieldId, _fieldName, to) => ({\n method: \"userfieldconfig.update\",\n params: { moduleId: \"crm\", id: fieldId, field: { editFormLabel: { ru: to } } },\n }),\n fieldDelete: (fieldId) => ({\n method: \"userfieldconfig.delete\",\n params: { moduleId: \"crm\", id: fieldId },\n }),\n // Н34: userfieldconfig.add отвечает объектом, где field.id — СТРОКА цифр (\"615\"),\n // а не число. Проверено по 75 записям журнала портала fbsm (этап 2), не по памяти:\n // первая попытка задачи 8 потребовала здесь именно число — и сломала бы откат поля\n // смарт-процесса молча, потому что строка «615» числом не является. У Сделок форма\n // ответа ДРУГАЯ И ПО ОБЁРТКЕ, И ПО ТИПУ (Н32, голое число) — потому разбор и живёт\n // в таблице, по одному на сущность, а не общей функцией «достать id откуда-нибудь».\n fieldIdFromAddResult: (result) =>\n usableId((result as Record | null | undefined)?.field?.id),\n // Перенесено из readStructure дословно (задача 3, шаг 4): userfieldconfig.list\n // вызывается с одним moduleId, БЕЗ фильтра — с фильтром по несуществующему\n // entityId Битрикс отвечает про права и уводит в неверную сторону (Н3).\n readFields: async (portal, ids, deps) => {\n const ufs = await call(portal, \"userfieldconfig.list\", { moduleId: \"crm\" }, deps);\n const mine = `CRM_${ids.typeId}`;\n\n // Название поля берём из crm.item.fields: userfieldconfig.list его не отдаёт\n // ни для одного поля портала — проверено на всех полях боевых процессов (Task 8,\n // круг правок 2). Идентификатор и системное имя, наоборот, есть только в\n // userfieldconfig — отсюда два источника вместо одного.\n const itemFields = await call<{ fields?: Record> }>(\n portal,\n \"crm.item.fields\",\n { entityTypeId: ids.entityTypeId },\n deps,\n ).catch(() => ({ fields: {} }));\n const titleByCamel = new Map();\n for (const [k, v] of Object.entries(itemFields?.fields ?? {})) {\n const t = (v as Record)?.title;\n if (typeof t === \"string\" && t.length > 0) titleByCamel.set(k, t);\n }\n\n return asObjects(ufs, \"список пользовательских полей\")\n .filter((f) => String(f.entityId) === mine)\n .map((f) => {\n // Н34: userfieldconfig.list отдаёт id СТРОКОЙ («615»). Числовая форма для\n // правки поля проверена живьём (12 записей журнала userfieldconfig.update\n // по fbsm), поэтому здесь она и остаётся — менять проверенное ради\n // единообразия значило бы поставить непроверенное на живой путь.\n // Правило «передавать таким, каким дал портал» относится к идентификатору\n // из ОТВЕТА НА СОЗДАНИЕ (fieldIdFromAddResult): он ниоткуда больше не\n // читается и сверять его не с чем. Здесь источник другой — список полей.\n // Чего здесь быть не должно, так это молчаливого Number() без проверки:\n // отсутствующий id давал NaN, а NaN в теле запроса становится null —\n // и удаление поля при prune ушло бы в никуда, а переименование могло бы\n // уйти на чужое поле. У сделок этот случай закрыт броском (ревью задачи 3),\n // здесь он оставался открытым: мутация id -> 0 проходила весь набор.\n const rawId = requireId(\n f.id,\n `поле смарт-процесса (fieldName ${String(f.fieldName ?? \"неизвестно\")})`,\n );\n return {\n id: rawId,\n fieldName: String(f.fieldName ?? \"\"),\n userTypeId: String(f.userTypeId ?? \"\"),\n title: titleByCamel.get(camel(String(f.fieldName ?? \"\"))) ??\n String((f.editFormLabel as Record | undefined)?.ru ?? \"\"),\n mandatory: yes(f.mandatory),\n multiple: yes(f.multiple),\n // Н20: значения списка у смарт-процессов через вебхук не задаются — портал\n // принимает их и молча теряет (проверено пятью способами). Читать нечего,\n // и пустой список здесь — не заглушка, а факт. Сверка состава на него\n // не опирается: она включается только при enumItemsSupported (у сделок).\n items: [],\n };\n });\n },\n};\n\n/** Сама таблица: единственный список сущностей на весь проект. Map, а не объект:\n * у объекта BY_KIND[\"toString\"] отдал бы функцию с прототипа, и незнакомая сущность\n * прошла бы проверку. */\nconst BY_KIND = new Map([\n [\"deal\", DEAL],\n [\"smartProcess\", SMART],\n]);\n\n/** Какие сущности поддержаны. Спрашивается, а не переписывается: разбор спецификации\n * держал рядом свою копию списка (`new Set([\"deal\", \"smartProcess\"])`), и следующая\n * сущность появилась бы в таблице, но не в разборе — или наоборот\n * (итоговое ревью ветки, находка 6). */\nexport function entityKinds(): EntityKind[] {\n return [...BY_KIND.keys()];\n}\n\nexport function isEntityKind(v: string): v is EntityKind {\n return BY_KIND.has(v as EntityKind);\n}\n\nexport function entityOps(kind: EntityKind): EntityOps {\n const ops = BY_KIND.get(kind);\n if (!ops) {\n throw new Error(\n `Неизвестная сущность «${kind}». Поддерживаются ${entityKinds().join(\" и \")}. ` +\n \"Считать незнакомое смарт-процессом нельзя: применение уйдёт не в ту сущность.\",\n );\n }\n return ops;\n}\n\n/** Как назвать человеку сущность, известную ТОЛЬКО по entityTypeId. Журнал видит\n * лишь параметры вызова crm.item.* и спецификации не знает вовсе, а с находки Н29\n * crm.item.* штатно ходит и по Сделкам — до этой правки записи журнала называли\n * «элементом смарт-процесса 2» обычную сделку (итоговое ревью ветки, находка 7).\n * Признак берётся из таблицы: сущность с заранее известным номером — та, чей номер\n * совпал; всё прочее — сущность, которую ищут на портале по названию, у неё номер\n * свой на каждом портале и заранее неизвестен. В verify.ts то же решено через\n * ops.label, но там спецификация под рукой, а здесь её нет. */\nexport function labelByEntityTypeId(entityTypeId: unknown): string {\n const n = Number(entityTypeId);\n const all = [...BY_KIND.values()];\n const found = all.find((o) => o.fixedEntityTypeId === n) ?? all.find((o) => o.discoverable);\n return found?.label ?? \"сущность\";\n}\n",[],[150,288],"1a7eb924-878d-4b72-acc3-619e7cda4068","appcall.ts","5c8150cc-aac6-11f1-872a-1607ee4eb77e",7,["D",1788790435718],"import type { ToolDef, ToolHandler } from \"./rpc.ts\";\r\nimport { appCreds, exchangeCode, refresh, type AppToken, type OauthDeps } from \"./oauth.ts\";\r\nimport { journalReady, loadRefreshToken, record, storeRefreshToken } from \"./journal.ts\";\r\nimport { getPortal } from \"./portals.ts\";\r\n\r\nexport interface AppCallDeps {\r\n fetchImpl?: typeof fetch;\r\n now?: () => number;\r\n}\r\n\r\n/** Точные методы, закрытые входящему вебхуку (Н40): запись шаблона бизнес-процесса\r\n * требует контекста приложения. Читающий bizproc.workflow.template.list НЕ входит\r\n * сюда — он вебхуку доступен, и первым выводом «закрыто всё семейство» по одному\r\n * этому методу проект уже платил три этапа (см. src/guide.ts, тема «бизнес-процессы»). */\r\nconst CLOSED_EXACT = new Set([\r\n \"bizproc.workflow.template.add\",\r\n \"bizproc.workflow.template.update\",\r\n \"bizproc.workflow.template.delete\",\r\n]);\r\n\r\n/** Семейства, закрытые целиком (Н7, Н40) — проверяются префиксом С ТОЧКОЙ на конце.\r\n * Без точки \"bizproc.robot\" совпал бы и с методом другого семейства, начинающимся\r\n * теми же буквами; вместе с точкой \"crm.automation.trigger.\" не задевает соседний\r\n * \"crm.automation.triggerish.add\", а \"placement.\" не задевает \"myplacement.bind\". */\r\nconst CLOSED_PREFIXES = [\r\n \"bizproc.robot.\",\r\n \"bizproc.activity.\",\r\n \"bizproc.provider.\",\r\n \"crm.automation.trigger.\",\r\n \"placement.\",\r\n];\r\n\r\n/** Таблица различий, а не догадка вызывающего: знание о том, что закрыто вебхуку,\r\n * живёт в одном месте и не размазывается по коду call() — этот проект уже четырежды\r\n * платил за раздвоенное знание одного и того же факта.\r\n *\r\n * Регистр нормализуется: Битрикс принимает имена методов без учёта регистра\r\n * (см. b24_call, который лишь обрезает пробелы), и это единственная таблица\r\n * в проекте, которая раньше этого не делала (находка 3 ревью задачи 2) —\r\n * \"Bizproc.Robot.Add\" уходил бы вебхуком и получал в ответ то же самое\r\n * \"Application context required\", которое сам же и объясняет. */\r\nexport function needsApp(method: string): boolean {\r\n const m = method.toLowerCase();\r\n if (CLOSED_EXACT.has(m)) return true;\r\n return CLOSED_PREFIXES.some((p) => m.startsWith(p));\r\n}\r\n\r\n/** Живые токены приложения в памяти процесса, ключ — слаг портала. Обновление\r\n * не заглядывает в хранилище на каждый вызов: пока токен в памяти не истёк,\r\n * читать базу незачем. */\r\nconst live = new Map();\r\n\r\n/** Запас перед истечением: без него appToken мог бы отдать токен, который\r\n * протухнет на середине следующего запроса к порталу. */\r\nconst EXPIRY_SLACK_MS = 60_000;\r\n\r\n/** Живой токен портала для вызова закрытых методов. Обновляется не раньше, чем\r\n * понадобилось — за минуту до истечения, а не по расписанию: токен, полученный\r\n * и не использованный, тратит попытку продления зря.\r\n *\r\n * Отсутствие приложения или сохранённого продления — внятный отказ с объяснением,\r\n * что сделать человеку, а не молчаливое падение где-то глубже. */\r\nexport async function appToken(slug: string, deps: AppCallDeps = {}): Promise {\r\n const now = deps.now ?? Date.now;\r\n const creds = appCreds(slug);\r\n if (!creds) {\r\n const upper = slug.trim().toUpperCase();\r\n throw new Error(\r\n `Приложение портала «${slug}» не заведено: нет переменных окружения ` +\r\n `B24_APP_ID_${upper} и B24_APP_SECRET_${upper}. Без него методы, закрытые ` +\r\n \"входящему вебхуку, работать не будут.\",\r\n );\r\n }\r\n\r\n const cached = live.get(slug);\r\n if (cached && cached.expiresAt - EXPIRY_SLACK_MS > now()) return cached.accessToken;\r\n\r\n // Без хранилища продление негде держать между вызовами (и между перезапусками):\r\n // работать в таком виде нельзя, и это говорится прямо, а не молчанием.\r\n if (!journalReady()) {\r\n throw new Error(\r\n \"Хранилище продления не подключено (нет SUPABASE_URL и SUPABASE_KEY в окружении). \" +\r\n \"Приложение без него работать не может: продлевать токен будет нечем хранить.\",\r\n );\r\n }\r\n\r\n // Прежний refresh_token берём из памяти, если он уже был получен в этом процессе —\r\n // читать хранилище заново незачем. Иначе это первое обращение с рестарта, и его\r\n // остаётся искать в базе.\r\n const refreshToken = cached?.refreshToken ?? await loadRefreshToken(slug, { fetchImpl: deps.fetchImpl });\r\n if (!refreshToken) {\r\n throw new Error(\r\n `Для портала «${slug}» ещё не пройдена разовая авторизация приложения через браузер. ` +\r\n \"Вызовите инструмент b24_authorize: он даст ссылку для перехода и примет код, \" +\r\n \"который оттуда вернётся. Это делается один раз на портал — дальше коннектор \" +\r\n \"продлевает токен сам.\",\r\n );\r\n }\r\n\r\n const oauthDeps: OauthDeps = { fetchImpl: deps.fetchImpl, now: deps.now };\r\n let token: AppToken;\r\n try {\r\n token = await refresh(creds, refreshToken, oauthDeps);\r\n } catch (e) {\r\n const message = e instanceof Error ? e.message : String(e);\r\n // invalid_grant/expired_token/invalid_token — не временный сбой обмена, а протухшее\r\n // или отозванное продление (приложение пересоздали, доступ отозвали руками). Голый\r\n // текст Битрикса не называет выход, и коннектор упирался бы в него на каждом вызове,\r\n // не подсказав, что делать (находка 4 ревью задачи 2).\r\n if (/invalid_grant|expired_token|invalid_token/i.test(message)) {\r\n throw new Error(\r\n `Продление портала «${slug}» больше не действует: ${message}. Обычно это значит, ` +\r\n \"что приложение пересоздали или доступ отозвали. Пройдите разовую авторизацию \" +\r\n \"заново — вызовите b24_authorize.\",\r\n );\r\n }\r\n throw e; // сетевой или другой временный сбой обмена — это не про отозванный доступ\r\n }\r\n live.set(slug, token);\r\n const rotated = token.refreshToken !== refreshToken;\r\n const saved = await storeRefreshToken(slug, token.refreshToken, { fetchImpl: deps.fetchImpl });\r\n // Сохраняем и тогда, когда refresh_token не поменялся: дешевле перезаписать тем же\r\n // значением, чем городить сравнение ради пропуска записи. Провал сохранения здесь —\r\n // в отличие от b24_authorize — не роняет текущий вызов: токен уже в памяти и годен\r\n // прямо сейчас, обслужить вызывающего есть чем.\r\n //\r\n // Но провал — это не всегда потеря (уточнение к находке 1 после повторного ревью).\r\n // Портал не всегда переиздаёт refresh_token при обновлении (см. oauth.ts): если он\r\n // вернул тот же самый (rotated === false), прежнее значение и так уже в базе (или\r\n // его отсутствие там — отдельная, более ранняя история), и не сохранить то же самое\r\n // ещё раз — не вредно, молчание здесь осмысленно. А если портал выдал НОВОЕ продление,\r\n // а записать его не удалось — старое он мог уже отозвать при выдаче нового, и тогда\r\n // единственное действующее продление потеряно: при следующем перезапуске коннектора\r\n // авторизации не будет, и без записи в журнале эту потерю нечем будет объяснить\r\n // постфактум. Различаем это здесь и сообщаем только тогда, когда есть о чём.\r\n if (!saved && rotated) {\r\n // journal.ts уже устроен как место, где коннектор рассказывает человеку о\r\n // случившемся с порталом, и именно туда идёт b24_journal — тот же канал, тем же\r\n // best-effort (запись сама может не удаться, если база недоступна целиком, и это\r\n // тот же принятый компромисс, что и у всех остальных record() в проекте).\r\n await record({\r\n portal: slug,\r\n tool: \"appToken\",\r\n method: \"b24_app_token.refresh\",\r\n params: {},\r\n level: \"red\",\r\n inverse: null,\r\n note: \"Продление приложения обновилось (портал выдал новый refresh_token), но \" +\r\n \"сохранить его в хранилище не удалось. Прежнее продление могло быть уже отозвано \" +\r\n \"порталом при выдаче нового — авторизация рискует оказаться потеряна. Если после \" +\r\n \"перезапуска коннектора появится отказ «нужна разовая авторизация», это — причина; \" +\r\n \"пройдите b24_authorize заново.\",\r\n });\r\n }\r\n return token.accessToken;\r\n}\r\n\r\n/** Сбрасывает кэш живого токена для портала. Нужен, когда сам портал уже считает\r\n * access_token просроченным (расхождение часов между процессами), а наш кэш ещё\r\n * нет — голый повтор того же вызова получил бы тот же отказ; следующий appToken()\r\n * обязан пойти за настоящим обновлением, а не отдать то же самое из памяти. */\r\nexport function forgetCachedToken(slug: string): void {\r\n live.delete(slug);\r\n}\r\n\r\n/** Сохранить продление после разовой авторизации через браузер (b24_authorize).\r\n * Возвращает признак успеха (находка 1 ревью задачи 2): вызывающий обязан знать,\r\n * сохранилось ли продление на самом деле, а не считать сохранённым по факту вызова. */\r\nexport async function saveRefresh(slug: string, token: AppToken, deps: AppCallDeps = {}): Promise {\r\n live.set(slug, token);\r\n return await storeRefreshToken(slug, token.refreshToken, { fetchImpl: deps.fetchImpl });\r\n}\r\n\r\nexport const APPCALL_TOOLS: ToolDef[] = [\r\n {\r\n name: \"b24_authorize\",\r\n description:\r\n \"Разовая авторизация локального приложения портала. Нужна, чтобы заработали методы, \" +\r\n \"закрытые входящему вебхуку (запись шаблонов бизнес-процессов и похожие). Без \" +\r\n \"аргумента code печатает ссылку для перехода в браузере; вторым вызовом, с кодом \" +\r\n \"из этой ссылки, обменивает его на токен и сохраняет продление. Делается один раз \" +\r\n \"на портал — дальше коннектор продлевает токен сам.\",\r\n inputSchema: {\r\n type: \"object\",\r\n properties: {\r\n portal: { type: \"string\" },\r\n code: {\r\n type: \"string\",\r\n description:\r\n \"Значение параметра code из адреса, на который портал перебросил браузер \" +\r\n \"после подтверждения. Передаётся вторым вызовом, отдельно от первого.\",\r\n },\r\n },\r\n required: [\"portal\"],\r\n },\r\n },\r\n];\r\n\r\nexport const appcallHandlers: Record = {\r\n b24_authorize: async (args) => {\r\n const slug = String(args.portal ?? \"\");\r\n // getPortal — раньше appCreds: опечатка в слаге обязана называть «портал не\r\n // подключён», а не «нет переменных окружения» (находка 6 ревью задачи 2) — иначе\r\n // человек полезет чинить переменные там, где на самом деле опечатался в имени.\r\n const portal = getPortal(slug);\r\n const creds = portal.appCreds;\r\n if (!creds) {\r\n const upper = slug.trim().toUpperCase();\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: `Для портала «${slug}» не заведено локальное приложение: нет переменных ` +\r\n `окружения B24_APP_ID_${upper} и B24_APP_SECRET_${upper}. Заведите приложение в ` +\r\n \"разделе «Разработчикам» портала и добавьте эти переменные, прежде чем авторизовать.\",\r\n }],\r\n isError: true,\r\n };\r\n }\r\n if (!journalReady()) {\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: \"Хранилище продления не подключено (нет SUPABASE_URL и SUPABASE_KEY). Без \" +\r\n \"него сохранённая авторизация не переживёт следующий перезапуск коннектора. \" +\r\n \"Подключите хранилище и повторите.\",\r\n }],\r\n isError: true,\r\n };\r\n }\r\n const code = typeof args.code === \"string\" ? args.code.trim() : \"\";\r\n if (!code) {\r\n const url = `https://${portal.domain}/oauth/authorize/?client_id=${\r\n encodeURIComponent(creds.clientId)\r\n }&response_type=code`;\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: [\r\n \"Часть методов Битрикса (например, запись шаблонов бизнес-процессов) закрыта \" +\r\n \"входящему вебхуку и работает только через локальное приложение портала. Чтобы \" +\r\n \"включить их, нужно один раз подтвердить доступ приложению — так же, как обычно \" +\r\n \"подтверждают вход стороннего приложения в аккаунт.\",\r\n \"\",\r\n \"1. Откройте эту ссылку в браузере, где вы уже вошли на портале:\",\r\n url,\r\n \"2. Портал спросит подтверждение и перебросит на адрес вида .../?code=ЧТО-ТО.\",\r\n \"3. Сразу же (код живёт считаные СЕКУНДЫ — если отвлечься и вернуться позже, \" +\r\n \"портал его уже не примет, и придётся просто повторить переход по ссылке) \" +\r\n \"скопируйте значение code из адресной строки и вызовите этот же инструмент \" +\r\n \"ещё раз, передав portal и этот code.\",\r\n \"\",\r\n \"Это разовое действие. После него коннектор сохранит продление и дальше будет \" +\r\n \"обновлять токен сам, без участия человека.\",\r\n ].join(\"\\n\"),\r\n }],\r\n };\r\n }\r\n const token = await exchangeCode(creds, code);\r\n const saved = await saveRefresh(slug, token);\r\n if (!saved) {\r\n // Находка 1 ревью задачи 2: рецензент воспроизвёл именно это на боевом стенде —\r\n // Битрикс код принял, токен рабочий прямо сейчас, но сохранить его не удалось\r\n // (например, таблицы b24_app_tokens ещё нет). Сказать «Готово» здесь означало бы\r\n // соврать: после следующего перезапуска коннектора авторизации снова не будет,\r\n // без единого признака поломки на стороне человека.\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: `Битрикс принял код и выдал токен для портала «${slug}» — прямо сейчас он ` +\r\n \"рабочий, но сохранить продление в собственном хранилище не удалось. Проверьте \" +\r\n \"SUPABASE_URL, SUPABASE_KEY и саму таблицу b24_app_tokens (sql/002_app_tokens.sql). \" +\r\n \"Если коннектор перезапустится раньше, чем хранилище заработает, авторизацию \" +\r\n \"придётся проходить заново — код уже использован, потребуется новый переход \" +\r\n \"по ссылке (вызовите b24_authorize без code, чтобы получить её снова).\",\r\n }],\r\n isError: true,\r\n };\r\n }\r\n return {\r\n content: [{\r\n type: \"text\",\r\n text: `Готово: приложение портала «${slug}» авторизовано, продление сохранено. ` +\r\n \"Повторять эту процедуру больше не нужно — коннектор продлевает токен сам.\",\r\n }],\r\n };\r\n },\r\n};\r\n",[],[150,296],"a3732ce4-ad59-4f7d-b1eb-2440d784172f","write.ts","808ede94-aac6-11f1-beac-1607ee4eb77e","ea2bc655-318f-4a1f-8393-ec5c5fa3f307",11,["D",1788790496203],"import { call, type RestDeps } from \"../rest.ts\";\nimport type { Portal } from \"../portals.ts\";\n\n/** Ошибки наших собственных проверок до обращения к порталу: текст мы писали\n * сами, он безопасен и полезен пользователю. Отличается от ошибок портала\n * (адрес вебхука с токеном, внутренние поля, данные клиентов), которые наружу\n * отдавать нельзя (находка 6 ревью задачи 11) — dash.ts отдаёт клиенту текст\n * только этого подкласса, остальное маскирует и пишет в консоль сервера. */\nexport class ОшибкаПроверки extends Error {}\n\n/** Заметка собственника уходит в таймлайн карточки Битрикса, а не в своё\n * хранилище (Д6): иначе появится вторая переписка, невидимая менеджеру. */\nexport async function написатьКомментарий(\n portal: Portal,\n тип: \"lead\" | \"deal\",\n id: string,\n текст: string,\n deps: RestDeps = {},\n): Promise {\n const чистый = текст.trim();\n // Проверка до вызова, а не после: пустой комментарий не должен вообще\n // доходить до боевого портала.\n if (чистый.length === 0) {\n throw new ОшибкаПроверки(\"Пустой комментарий в CRM не отправляется\");\n }\n const ответ = await call(portal, \"crm.timeline.comment.add\", {\n fields: { ENTITY_ID: id, ENTITY_TYPE: тип, COMMENT: чистый },\n }, deps);\n return String(ответ);\n}\n\n/** Признак пользовательского поля Битрикса: системные поля лида (STATUS_ID, ASSIGNED_BY_ID\n * и т.п.) так не называются. Единственная пишущая точка дашборда в боевой CRM обязана\n * писать только в поле причины отказа, а не в произвольное поле лида (находка 1 ревью\n * задачи 7: опечатка в настройке или ошибка вызова иначе могла бы сбросить стадию сделки). */\nconst UF_PREFIX = \"UF_CRM_\";\n\nexport async function проставитьПричину(\n portal: Portal,\n лидId: string,\n полеCRM: string,\n значение: string,\n deps: RestDeps = {},\n): Promise {\n if (!полеCRM.startsWith(UF_PREFIX)) {\n throw new ОшибкаПроверки(\n `Поле «${полеCRM}» не похоже на пользовательское поле Битрикса (ожидается имя, ` +\n `начинающееся с ${UF_PREFIX}) — запись в системное поле лида здесь не делается.`,\n );\n }\n const чистое = значение.trim();\n // Проверка до вызова, а не после: пустая причина стёрла бы уже проставленное\n // значение в боевой карточке (находка 2 ревью задачи 7).\n if (чистое.length === 0) {\n throw new ОшибкаПроверки(\"Пустая причина отказа в CRM не отправляется\");\n }\n // Лишнее чтение здесь оправдано (находка 3 ревью задачи 7): запись происходит редко,\n // по нажатию кнопки, а цена мусора в боевой карточке — устаревшего или произвольного\n // значения, которого нет в справочнике поля, — выше стоимости одного лишнего вызова.\n //\n // Между этим чтением и записью ниже проходит время, и справочник теоретически может\n // измениться на портале за этот промежуток (переревью задачи 7, находка 3 второго\n // круга). Блокировка здесь неуместна: запись делает один человек нажатием кнопки\n // несколько раз в день, а худшее следствие гонки — в карточку попадёт значение,\n // ставшее недействительным секунду назад, что легко поправить повторной причиной.\n // Это осознанный выбор не городить синхронизацию ради такой цены ошибки, а не недосмотр.\n const справочник = await причиныОтказа(portal, полеCRM, deps);\n // Проверка «UF_CRM_» (находка 1, первый круг) отсекает системные поля, но пропускает\n // любое пользовательское — текстовое, числовое, «Регион» и т.п. Настоящую защиту от\n // записи не в ту колонку даёт именно этот пустой справочник: у несписочного поля\n // причиныОтказа() всегда вернёт [] (находка 1, переревью), и без явной проверки здесь\n // тот же случай уходил бы в общую ошибку «нет в справочнике» ниже — с текстом про\n // значение, а не про поле, и настройщик искал бы опечатку не там.\n if (справочник.length === 0) {\n throw new ОшибкаПроверки(\n `Поле «${полеCRM}» не является списком или не имеет значений на портале — ` +\n \"запись причины отказа отменена.\",\n );\n }\n if (!справочник.some((п) => п.id === чистое)) {\n throw new ОшибкаПроверки(\n `Значения «${чистое}» нет в справочнике поля ${полеCRM} — запись отменена, ` +\n \"чтобы в карточке не появился мусор.\",\n );\n }\n await call(portal, \"crm.lead.update\", {\n id: лидId,\n fields: { [полеCRM]: чистое },\n }, deps);\n}\n\ninterface ОписаниеПоля {\n FIELD_NAME?: string;\n LIST?: { ID?: string; VALUE?: string }[];\n}\n\n/** Значения списка берутся из справочника поля на портале. Пока заказчик поле не\n * завёл — список пуст, и интерфейс просто не покажет блок причин (Д7). Элементы\n * с пустым (в том числе из одних пробелов) идентификатором или названием\n * отфильтрованы (находка 4 ревью задачи 7, дополнено переревью): иначе интерфейс\n * мог бы предложить выбрать пустую строку. */\nexport async function причиныОтказа(\n portal: Portal,\n полеCRM: string,\n deps: RestDeps = {},\n): Promise<{ id: string; название: string }[]> {\n const поля = await call<ОписаниеПоля[]>(portal, \"crm.lead.userfield.list\", {\n filter: { FIELD_NAME: полеCRM },\n }, deps);\n const нужное = (поля ?? []).find((п) => п.FIELD_NAME === полеCRM);\n return (нужное?.LIST ?? [])\n .map((з) => ({ id: String(з.ID ?? \"\").trim(), название: String(з.VALUE ?? \"\").trim() }))\n .filter((з) => з.id.length > 0 && з.название.length > 0);\n}\n",[],[150,312,304],"dash","a19aaf32-1e03-4ae5-8618-e8e435495d59","sources.ts","8a4a81cc-aac6-11f1-aae1-1607ee4eb77e",15,["D",1788790512545],"import { envOpt } from \"../env.ts\";\nimport { callAll, type RestDeps } from \"../rest.ts\";\nimport type { Portal } from \"../portals.ts\";\n\n/** Коды источников, считающихся рекламными (Д2). Меняются переменной окружения,\n * а не правкой кода: заказчик наводит порядок в справочнике портала сам. */\nconst ПО_УМОЛЧАНИЮ = [\"STORE\", \"CALL\", \"CALLBACK\"];\n\nexport function рекламныеКоды(): string[] {\n const сырое = envOpt(\"AD_SOURCES\");\n if (!сырое) return [...ПО_УМОЛЧАНИЮ];\n const коды = сырое.split(\",\").map((s) => s.trim()).filter(Boolean);\n return коды.length > 0 ? коды : [...ПО_УМОЛЧАНИЮ];\n}\n\nexport interface Справочники {\n источники: Map;\n стадииЛида: Map;\n стадииСделки: Map;\n}\n\ninterface СтрокаСправочника {\n ENTITY_ID?: string;\n STATUS_ID?: string;\n NAME?: string;\n}\n\n/** Названия источников и стадий берём из портала в момент запроса и никогда не\n * храним: переименование в CRM должно подхватываться само (Д2). */\nexport async function загрузитьСправочники(\n portal: Portal,\n deps: RestDeps = {},\n): Promise<Справочники> {\n const строки = await callAll<СтрокаСправочника>(portal, \"crm.status.list\", {\n order: { SORT: \"ASC\" },\n }, deps);\n const с: Справочники = {\n источники: new Map(),\n стадииЛида: new Map(),\n стадииСделки: new Map(),\n };\n for (const с_ of строки) {\n const код = с_.STATUS_ID;\n const имя = с_.NAME;\n if (!код || !имя) continue;\n if (с_.ENTITY_ID === \"SOURCE\") с.источники.set(код, имя);\n else if (с_.ENTITY_ID === \"STATUS\") с.стадииЛида.set(код, имя);\n else if (с_.ENTITY_ID === \"DEAL_STAGE\") с.стадииСделки.set(код, имя);\n }\n return с;\n}\n",[],[150,312,314],"c5940555-4a75-4267-843f-3cf9e0fda18f","snapshot.ts","4a5f7e00-aac6-11f1-ba03-1607ee4eb77e",5,["D",1788790405283],"import type { RestDeps } from \"../rest.ts\";\nimport type { Portal } from \"../portals.ts\";\nimport { загрузитьЛиды, загрузитьСделки, загрузитьСотрудников, type Сделка } from \"./fetch.ts\";\nimport { загрузитьСправочники, рекламныеКоды, type Справочники } from \"./sources.ts\";\nimport {\n воронка,\n дошлоДоСделки,\n ЗАКРЫТЫЕ_СТАДИИ,\n каналСделки,\n type Когорта,\n когорты,\n контрольКачества,\n type Обращение,\n поКлючу,\n type Проблемы,\n type Разрез,\n свести,\n} from \"./metrics.ts\";\n\nconst ВОРОНКА_ОП = 0;\n\nexport interface Снимок {\n обращения: Обращение[];\n /** ВСЕ сделки воронки за период, не только рекламные: `обращения` уже\n * отфильтрованы по рекламным источникам (свести() отбирает лиды по\n * рекламныеКоды()), а здесь лежит целиком то, что вернул crm.deal.list.\n * Потребитель обязан фильтровать сам, если ему нужны только рекламные\n * сделки — см. контрольКачества() в дляСтраницы(). */\n всеСделки: Сделка[];\n /** id лида → его источник, по ВСЕМ загруженным лидам, а не только по\n * рекламным. Нерекламные здесь обязательны: именно они дают каналСделки()\n * основание НЕ засчитать сделку в рекламу, когда её собственное поле\n * «Источник» проставлено значением по умолчанию. Урезать карту до рекламных\n * лидов — значит вернуть перекос, ради устранения которого она заведена. */\n источникиЛидов: Map;\n справочники: Справочники;\n люди: Map;\n собран: string;\n}\n\nexport async function собратьСнимок(\n portal: Portal,\n отДаты: string,\n сегодня: Date,\n deps: RestDeps = {},\n): Promise<Снимок> {\n // Запросы идут строго последовательно, а не через Promise.all. rest.ts\n // держит паузу около полусекунды между обращениями к ОДНОМУ порталу\n // (throttle по portal.slug — см. MIN_GAP_MS в rest.ts), чтобы не поймать\n // отказ по частоте запросов. При параллельном запуске все четыре вызова\n // читают одну и ту же отметку времени последнего обращения и уходят\n // разом, обходя эту защиту. Последовательность здесь — требование, а не\n // недосмотр: не «оптимизировать» обратно в Promise.all.\n const справочники = await загрузитьСправочники(portal, deps);\n const лиды = await загрузитьЛиды(portal, отДаты, deps);\n const всеСделки = await загрузитьСделки(portal, отДаты, ВОРОНКА_ОП, deps);\n const люди = await загрузитьСотрудников(portal, deps);\n return {\n обращения: свести(лиды, всеСделки, рекламныеКоды(), сегодня),\n всеСделки,\n источникиЛидов: new Map(лиды.map((л) => [л.id, л.источник])),\n справочники,\n люди,\n собран: сегодня.toISOString(),\n };\n}\n\nexport interface СтрокаТаблицы {\n лид: string;\n дата: string;\n название: string;\n источник: string;\n менеджер: string;\n статусЛида: string;\n сделка: string | null;\n стадияСделки: string | null;\n закрыта: boolean;\n сумма: number;\n телефон: string;\n днейБезДвижения: number;\n /** Единое правило дошлоДоСделки(), то же самое, что даёт kpi.конвертировано\n * и воронка (находка I1 финального ревью): клиентский фильтр таблицы\n * «дошёл до сделки» раньше проверял только наличие сделки и расходился с\n * шапкой на лидах со статусом CONVERTED без связанной сделки. Теперь и\n * фильтр, и раскраска в браузере обязаны читать это поле, а не решать\n * заново по-своему. */\n дошёл: boolean;\n}\n\nexport interface ДляСтраницы {\n kpi: {\n обращений: number;\n конвертировано: number;\n вРаботе: number;\n пайплайн: number;\n продано: number;\n некачественных: number;\n };\n воронка: { этап: string; сколько: number }[];\n источники: Разрез[];\n менеджеры: Разрез[];\n когорты: Когорта[];\n проблемы: Проблемы;\n строки: СтрокаТаблицы[];\n собран: string;\n}\n\nexport function дляСтраницы(с: Снимок, сегодня: Date): ДляСтраницы {\n const о = с.обращения;\n\n // Два разных множества, и оба нужны (находка I2 финального ревью):\n //\n // ОБРАЩЕНИЕ — это лид с рекламного источника (о, уже отфильтровано\n // рекламныеКоды() внутри свести()). Показатели «обращений»,\n // «конвертировано», «некачественных» отвечают на вопрос про ЛИДЫ и\n // обязаны считаться по о — их трогать не нужно.\n //\n // РЕКЛАМНАЯ СДЕЛКА — это сделка, чей КАНАЛ рекламный, а канал определяет\n // каналСделки(): источник лида, если лид известен, иначе собственный\n // источник сделки. Второй случай обязателен: на боевом портале связка\n // LEAD_ID цела только у половины сделок, вторая половина заведена вручную\n // мимо лида — и это множество ШИРЕ, чем сделки одних лишь обращений.\n //\n // Отбор и группировка обязаны читать ОДНО правило. Раньше сделка попадала\n // сюда по собственному полю «Источник», даже когда её лид пришёл с другого\n // канала, — и разрез приписывал деньги каналу STORE, который их не приносил\n // (см. разбор в каналСделки()). Не разводить эти два места по разным\n // правилам: строка разреза обязана состоять ровно из тех сделок, которые\n // прошли отбор.\n //\n // Раньше «в работе»/«пайплайн»/«продано» считались по сделкам обращений\n // (о), то есть теряли ровно ту половину, которую рекламныеСделки ловит.\n // Показатели, отвечающие на вопрос про СДЕЛКИ («в работе», «пайплайн»,\n // «продано»), обязаны считаться по рекламныеСделки — иначе шапка занижает\n // пайплайн примерно вдвое на боевых данных портала. Следующему читателю:\n // не сводить эти два множества обратно в одно — они честно отвечают на\n // разные вопросы.\n const рекламныеИсточники = new Set(рекламныеКоды());\n const каналСд = (сд: Сделка) => каналСделки(сд, с.источникиЛидов);\n const рекламныеСделки = с.всеСделки.filter((сд) => рекламныеИсточники.has(каналСд(сд)));\n const рекламныеЖивые = рекламныеСделки.filter((сд) => !ЗАКРЫТЫЕ_СТАДИИ.has(сд.стадия));\n\n return {\n kpi: {\n обращений: о.length,\n // Единое правило «обращение дошло до сделки» (дошлоДоСделки), а не\n // сырой статус лида: иначе шапка и воронка/разрезы под ней показывают\n // разные числа на одних и тех же данных.\n конвертировано: о.filter((з) => дошлоДоСделки(з)).length,\n вРаботе: рекламныеЖивые.length,\n пайплайн: рекламныеЖивые.reduce((s, сд) => s + сд.сумма, 0),\n продано: рекламныеСделки.filter((сд) => сд.стадия === \"WON\").length,\n // JUNK И одновременно НЕ дошлоДоСделки: иначе брак со связанной сделкой\n // считался бы сразу и в «некачественных», и в «конвертировано» — шапка\n // противоречила бы сама себе.\n некачественных: о.filter((з) => з.лид.статус === \"JUNK\" && !дошлоДоСделки(з)).length,\n },\n // Оба разреза и воронка получают одно и то же рекламныеСделки — то самое\n // широкое множество, что уже питает kpi выше (находка I2 финального\n // ревью: раньше воронка()/поКлючу() принимали только о и не видели\n // сделки без лида, из-за чего шапка расходилась с воронкой и разрезами\n // на одном экране). ключСделки берёт группу из полей самой сделки\n // (источник/ответственный), а не через лид — у сделки без лида другого\n // пути нет.\n воронка: воронка(о, рекламныеСделки),\n источники: поКлючу(\n о,\n (з) => с.справочники.источники.get(з.лид.источник) ?? з.лид.источник,\n рекламныеСделки,\n // То же каналСделки(), что и в отборе выше: сделка обязана попасть в ту\n // строку разреза, по признаку которой её взяли в рекламные.\n (сд) => с.справочники.источники.get(каналСд(сд)) ?? каналСд(сд),\n ),\n менеджеры: поКлючу(\n о,\n (з) => с.люди.get(з.лид.ответственный) ?? з.лид.ответственный,\n рекламныеСделки,\n (сд) => с.люди.get(сд.ответственный) ?? сд.ответственный,\n ),\n когорты: когорты(о, сегодня),\n проблемы: контрольКачества(о, рекламныеСделки),\n строки: о.map((з) => ({\n лид: з.лид.id,\n дата: з.лид.создан,\n название: з.лид.название,\n источник: с.справочники.источники.get(з.лид.источник) ?? з.лид.источник,\n менеджер: с.люди.get(з.лид.ответственный) ?? з.лид.ответственный,\n статусЛида: с.справочники.стадииЛида.get(з.лид.статус) ?? з.лид.статус,\n сделка: з.сделка?.id ?? null,\n стадияСделки: з.сделка\n ? (с.справочники.стадииСделки.get(з.сделка.стадия) ?? з.сделка.стадия)\n : null,\n закрыта: з.сделка ? ЗАКРЫТЫЕ_СТАДИИ.has(з.сделка.стадия) : false,\n сумма: з.сделка?.сумма ?? 0,\n телефон: з.лид.телефон,\n днейБезДвижения: з.днейБезДвижения,\n дошёл: дошлоДоСделки(з),\n })),\n собран: с.собран,\n };\n}\n",[],[150,312,322],"71d1d2cc-8c8d-45f8-9ec4-f200dd7a8113","page.ts","b0f52dae-aac6-11f1-b36f-1607ee4eb77e",17,["D",1788790577405],"import type { ДляСтраницы } from \"./snapshot.ts\";\n\n/** Данные уходят в разметку как JSON внутри тега script. Символы, способные\n * закрыть тег или открыть новый, экранируются юникодными последовательностями:\n * названия клиентов приходят из CRM и содержат что угодно. */\nfunction безопасныйJson(v: unknown): string {\n return JSON.stringify(v)\n .replaceAll(\"<\", \"\\\\u003c\")\n .replaceAll(\">\", \"\\\\u003e\")\n .replaceAll(\"&\", \"\\\\u0026\")\n .replaceAll(\" \", \"\\\\u2028\")\n .replaceAll(\" \", \"\\\\u2029\");\n}\n\nexport function страница(д: ДляСтраницы, домен: string): string {\n return `\n\nРадар рекламных лидов\n\n\n

\n\n\n\n`;\n}\n",[],[150,312,330],"477ff0f3-186e-4a8d-8052-d08435066a10","metrics.ts","47c8b1fc-aac6-11f1-a0fa-1607ee4eb77e",4,["D",1788790400955],"import type { Лид, Сделка } from \"./fetch.ts\";\n\n/** Ключ группировки для сделки: то же самое человеческое имя (источник или\n * ответственный), что и для обращения, но взятое с собственных полей сделки —\n * нужно, чтобы отнести к разрезу сделку без привязанного лида. */\nexport type КлючСделки = (сд: Сделка) => string;\n\n/** Стадии, на которых сделка перестала быть живой. «Дубли» здесь же: это не\n * работа, а мусор учёта. */\nexport const ЗАКРЫТЫЕ_СТАДИИ: ReadonlySet = new Set([\n \"LOSE\",\n \"UC_YF6B6V\",\n \"UC_HOECEY\",\n \"APOLOGY\",\n \"WON\",\n]);\n\n/** Обращение дошло до сделки: портал сам пометил лид качественным, либо к лиду\n * привязана сделка. Оба признака равнозначны, потому что связка LEAD_ID на\n * боевом портале рвётся почти у половины сделок. */\nexport function дошлоДоСделки(з: Обращение): boolean {\n return з.лид.статус === \"CONVERTED\" || з.сделка !== null;\n}\n\n/** Канал, которому принадлежит сделка: источник ЛИДА, если лид известен, и\n * только при его отсутствии — собственный источник сделки.\n *\n * Почему не собственное поле сделки, хотя оно есть и заполнено у всех. Сверка\n * на боевом портале 7 сентября 2026 (71 сделка 2026 года с привязанным лидом):\n * у 18 из них источник сделки расходится с источником её лида, и расхождения\n * ВСЕ в одну сторону — сделка говорит STORE, а лид говорит другое (CALLBACK,\n * UC_M3Z0DY, WhatsApp). По полю сделки STORE выглядит лидером (18 сделок,\n * 766 млн ₸), по источнику лида в STORE остаётся одна сделка на 8 млн. То есть\n * «STORE» в карточке сделки — это значение по умолчанию, а не сведение о том,\n * откуда пришёл клиент; группировать деньги по нему значит приписывать выручку\n * каналу, который её не приносил.\n *\n * Откат на источник сделки нужен для двух случаев: сделка заведена мимо лида\n * (таких около половины) и лид старше загруженного периода — тогда его в карте\n * нет и собственное поле сделки остаётся единственным, что известно. */\nexport function каналСделки(сд: Сделка, источникиЛидов: Map): string {\n if (сд.лид !== null) {\n const источникЛида = источникиЛидов.get(сд.лид);\n if (источникЛида !== undefined) return источникЛида;\n }\n return сд.источник;\n}\n\nexport interface Обращение {\n лид: Лид;\n сделка: Сделка | null;\n днейБезДвижения: number;\n}\n\nconst СУТКИ = 86_400_000;\n\nfunction дней(от: string, до: Date): number {\n const дата = от.slice(0, 10);\n const t = Date.parse(дата + \"T00:00:00Z\");\n if (Number.isNaN(t)) return 0;\n return Math.max(0, Math.floor((до.getTime() - t) / СУТКИ));\n}\n\nexport function свести(\n лиды: Лид[],\n сделки: Сделка[],\n коды: string[],\n сегодня: Date,\n): Обращение[] {\n const набор = new Set(коды);\n const поЛиду = new Map();\n for (const с of сделки) {\n if (с.лид) {\n const существующая = поЛиду.get(с.лид);\n if (!существующая) {\n поЛиду.set(с.лид, с);\n } else {\n // Выбираем: сначала незакрытую, потом по дате (позже), потом по ID (больше)\n const сЗакрыта = ЗАКРЫТЫЕ_СТАДИИ.has(с.стадия);\n const сущЗакрыта = ЗАКРЫТЫЕ_СТАДИИ.has(существующая.стадия);\n if (сЗакрыта && !сущЗакрыта) {\n // Существующая незакрыта, а новая закрыта — оставляем существующую\n } else if (!сЗакрыта && сущЗакрыта) {\n // Новая незакрыта, а существующая закрыта — берём новую\n поЛиду.set(с.лид, с);\n } else if (с.изменена > существующая.изменена) {\n // Одинаковый статус закрытости, новая изменена позже\n поЛиду.set(с.лид, с);\n } else if (\n с.изменена === существующая.изменена &&\n Number(с.id) > Number(существующая.id)\n ) {\n // Изменены в один день, новая имеет больший ID\n поЛиду.set(с.лид, с);\n }\n }\n }\n }\n return лиды\n .filter((л) => набор.has(л.источник))\n .map((л) => {\n const с = поЛиду.get(л.id) ?? null;\n return {\n лид: л,\n сделка: с,\n днейБезДвижения: дней(с ? с.изменена : л.создан, сегодня),\n };\n });\n}\n\n/** Конверсия считается по статусу лида CONVERTED ИЛИ наличию связанной сделки:\n * оба признака доказывают, что обращение дошло до сделки.\n *\n * Воронка больше не вложена целиком (проектное решение по находке I2\n * финального ревью, «одна вселенная сделок на экране»): «Пришло обращений»,\n * «Взято в работу», «Стали сделкой» — про ЛИДЫ и считаются по о; «Сделка в\n * работе» и «Продано» — про СДЕЛКИ и считаются по рекламныеСделки, куда\n * входят и сделки без привязанного лида (на боевом портале это около\n * половины сделок). Поэтому «Сделка в работе» может оказаться БОЛЬШЕ, чем\n * «Стали сделкой»: часть сделок в работе никогда не была обращением. Это не\n * баг — это правда портала: связка LEAD_ID цела не у всех сделок. */\nexport function воронка(\n о: Обращение[],\n рекламныеСделки: Сделка[],\n): { этап: string; сколько: number }[] {\n const конв = о.filter((з) => дошлоДоСделки(з));\n const вРаботе = рекламныеСделки.filter((сд) => !ЗАКРЫТЫЕ_СТАДИИ.has(сд.стадия));\n const выиграно = рекламныеСделки.filter((сд) => сд.стадия === \"WON\");\n return [\n { этап: \"Пришло обращений\", сколько: о.length },\n { этап: \"Взято в работу\", сколько: о.filter((з) => з.лид.статус !== \"NEW\").length },\n { этап: \"Стали сделкой\", сколько: конв.length },\n { этап: \"Сделка в работе\", сколько: вРаботе.length },\n { этап: \"Продано\", сколько: выиграно.length },\n ];\n}\n\nexport interface Разрез {\n ключ: string;\n лидов: number;\n /** Сколько обращений (лидов) этой группы дошло до сделки — прежний смысл\n * поля «сделок» до находки I2 финального ревью. Отсюда же берётся\n * конверсия: доля ЛИДОВ, дошедших до сделки, а не отношение сделок к\n * лидам — так конверсия остаётся осмысленной (не превышает 100%) даже\n * когда сделок в группе больше, чем лидов. */\n дошлиДоСделки: number;\n /** Все рекламные сделки этой группы (по собственным полям сделки —\n * источник/ответственный), включая заведённые вручную мимо лида. Может\n * быть БОЛЬШЕ, чем лидов: это не ошибка, а следствие того, что связка\n * LEAD_ID цела не у всех сделок портала. Названо не «сделок», чтобы имя не\n * намекало на то же самое, что дошлиДоСделки. */\n сделокСРекламы: number;\n конверсия: number;\n пайплайн: number;\n}\n\n/** Разрез по источнику/менеджеру. Обходит обращения (о) для полей про ЛИДЫ\n * (лидов, дошлиДоСделки, конверсия) и рекламныеСделки для полей про СДЕЛКИ\n * (сделокСРекламы, пайплайн) — те же два множества и по тем же причинам, что\n * в воронке() (находка I2 финального ревью). ключСделки достаёт группу из\n * собственных полей сделки, потому что часть сделок не привязана к лиду и\n * не имеет обращения, из которого можно было бы взять группу иначе. */\nexport function поКлючу(\n о: Обращение[],\n ключ: (з: Обращение) => string,\n рекламныеСделки: Сделка[],\n ключСделки: КлючСделки,\n): Разрез[] {\n const свод = new Map();\n const строка = (к: string): Разрез => {\n const существующая = свод.get(к);\n if (существующая) return существующая;\n const новая: Разрез = {\n ключ: к,\n лидов: 0,\n дошлиДоСделки: 0,\n сделокСРекламы: 0,\n конверсия: 0,\n пайплайн: 0,\n };\n свод.set(к, новая);\n return новая;\n };\n for (const з of о) {\n const р = строка(ключ(з));\n р.лидов++;\n if (дошлоДоСделки(з)) р.дошлиДоСделки++;\n }\n for (const сд of рекламныеСделки) {\n const р = строка(ключСделки(сд));\n р.сделокСРекламы++;\n if (!ЗАКРЫТЫЕ_СТАДИИ.has(сд.стадия)) р.пайплайн += сд.сумма;\n }\n const строки = [...свод.values()];\n for (const р of строки) {\n р.конверсия = р.лидов > 0 ? Math.round((100 * р.дошлиДоСделки) / р.лидов) : 0;\n }\n return строки.sort((a, b) => b.лидов - a.лидов);\n}\n\nexport interface Когорта {\n месяц: string;\n обращений: number;\n сталиСделкой: number;\n доля: number;\n вРаботе: number;\n провалено: number;\n выиграно: number;\n возрастМесяцев: number;\n созрела: boolean;\n}\n\n/** Помесячная конверсия при цикле сделки в 5–11 месяцев всегда рисует провал:\n * обращения августа физически не могли стать продажей в августе. Поэтому итог\n * смотрится когортами, а незрелые когорты помечаются явно (Д4).\n *\n * Когорта созревает целиком с первого дня месяца-границы, хотя обращение конца\n * месяца может прожить меньше полного горизонта. Это осознанное упрощение для\n * месячной гранулярности анализа. */\nexport function когорты(\n о: Обращение[],\n сегодня: Date,\n горизонтМесяцев = 6,\n): Когорта[] {\n const свод = new Map();\n // Вычисляем год и месяц сегодня из ISO строки, чтобы обе стороны (дата лида\n // и сегодня) читались из одного соглашения. Обе трактуются как UTC; расхождение\n // с часовым поясом портала в пределах суток допустимо и не влияет на месячную\n // гранулярность.\n const сегодняИСО = сегодня.toISOString().slice(0, 7);\n const [годСегодня, месяцСегодня] = сегодняИСО.split(\"-\").map(Number);\n\n for (const з of о) {\n const м = з.лид.создан.slice(0, 7);\n // Строгая валидация: месяц должен совпадать с образцом YYYY-MM, где MM это\n // 01–12. Некорректные даты пропускаем.\n if (!/^\\d{4}-\\d{2}$/.test(м)) continue;\n const мнум = Number(м.split(\"-\")[1]);\n if (мнум < 1 || мнум > 12) continue;\n\n const к = свод.get(м) ?? {\n месяц: м,\n обращений: 0,\n сталиСделкой: 0,\n доля: 0,\n вРаботе: 0,\n провалено: 0,\n выиграно: 0,\n возрастМесяцев: 0,\n созрела: false,\n };\n к.обращений++;\n if (дошлоДоСделки(з)) к.сталиСделкой++;\n if (з.сделка) {\n if (з.сделка.стадия === \"WON\") к.выиграно++;\n else if (ЗАКРЫТЫЕ_СТАДИИ.has(з.сделка.стадия)) к.провалено++;\n else к.вРаботе++;\n }\n свод.set(м, к);\n }\n const итог = [...свод.values()].sort((a, b) => a.месяц.localeCompare(b.месяц));\n for (const к of итог) {\n к.доля = к.обращений > 0 ? Math.round((100 * к.сталиСделкой) / к.обращений) : 0;\n const [г, м] = к.месяц.split(\"-\").map(Number);\n // Возраст считается в месяцах: разница между годами, умноженная на 12, плюс\n // разница месяцев. Если результат отрицательный (когда месяц по UTC ещё не\n // наступил), приводим к нулю.\n к.возрастМесяцев = Math.max(\n 0,\n (годСегодня - г) * 12 + (месяцСегодня - м),\n );\n к.созрела = к.возрастМесяцев >= горизонтМесяцев;\n }\n return итог;\n}\n\nexport interface Проблемы {\n дубли: { лид: string; сделки: string[] }[];\n безСуммы: string[];\n безТелефона: string[];\n неОбработаны: string[];\n}\n\nexport function контрольКачества(о: Обращение[], сделки: Сделка[]): Проблемы {\n const поЛиду = new Map();\n for (const с of сделки) {\n if (!с.лид) continue;\n поЛиду.set(с.лид, [...(поЛиду.get(с.лид) ?? []), с.id]);\n }\n return {\n дубли: [...поЛиду.entries()]\n .filter(([, ids]) => ids.length > 1)\n .map(([лид, сделки]) => ({ лид, сделки })),\n безСуммы: сделки\n .filter((с) => !ЗАКРЫТЫЕ_СТАДИИ.has(с.стадия) && с.сумма === 0)\n .map((с) => с.id),\n безТелефона: о.filter((з) => з.лид.телефон.trim() === \"\")\n .map((з) => з.лид.id),\n неОбработаны: о.filter((з) => з.лид.статус === \"NEW\").map((з) => з.лид.id),\n };\n}\n",[],[150,312,338],"62d4d436-a2ad-48f6-9d68-6088cd0f5254","fetch.ts","87d203b6-aac6-11f1-93e9-1607ee4eb77e",14,["D",1788790508404],"import { callAll, type RestDeps } from \"../rest.ts\";\nimport type { Portal } from \"../portals.ts\";\n\nexport interface Лид {\n id: string;\n название: string;\n источник: string;\n статус: string;\n создан: string;\n ответственный: string;\n телефон: string;\n}\n\nexport interface Сделка {\n id: string;\n название: string;\n стадия: string;\n источник: string;\n создан: string;\n изменена: string;\n сумма: number;\n ответственный: string;\n лид: string | null;\n}\n\nconst день = (s: unknown) => String(s ?? \"\").slice(0, 10);\n\nfunction первыйТелефон(v: unknown): string {\n if (!Array.isArray(v) || v.length === 0) return \"\";\n const p = v[0] as { VALUE?: string };\n return String(p?.VALUE ?? \"\");\n}\n\nexport async function загрузитьЛиды(\n portal: Portal,\n отДаты: string,\n deps: RestDeps = {},\n): Promise<Лид[]> {\n const сырые = await callAll>(\n portal,\n \"crm.lead.list\",\n {\n filter: { \">=DATE_CREATE\": отДаты },\n select: [\n \"ID\",\n \"TITLE\",\n \"SOURCE_ID\",\n \"STATUS_ID\",\n \"DATE_CREATE\",\n \"ASSIGNED_BY_ID\",\n \"PHONE\",\n ],\n order: { ID: \"ASC\" },\n },\n deps,\n );\n return сырые.map((л) => ({\n id: String(л.ID ?? \"\"),\n название: String(л.TITLE ?? \"\"),\n источник: String(л.SOURCE_ID ?? \"\"),\n статус: String(л.STATUS_ID ?? \"\"),\n создан: день(л.DATE_CREATE),\n ответственный: String(л.ASSIGNED_BY_ID ?? \"\"),\n телефон: первыйТелефон(л.PHONE),\n }));\n}\n\nexport async function загрузитьСделки(\n portal: Portal,\n отДаты: string,\n категория: number,\n deps: RestDeps = {},\n): Promise<Сделка[]> {\n const сырые = await callAll>(\n portal,\n \"crm.deal.list\",\n {\n filter: { CATEGORY_ID: категория, \">=DATE_CREATE\": отДаты },\n select: [\n \"ID\",\n \"TITLE\",\n \"STAGE_ID\",\n \"SOURCE_ID\",\n \"DATE_CREATE\",\n \"DATE_MODIFY\",\n \"OPPORTUNITY\",\n \"ASSIGNED_BY_ID\",\n \"LEAD_ID\",\n ],\n order: { ID: \"ASC\" },\n },\n deps,\n );\n return сырые.map((с) => {\n // Портал отдаёт LEAD_ID тремя способами: числом-строкой, null и строкой \"0\".\n // Последнее встречается на живом портале (сделка 3563) и означает отсутствие\n // связки, а не лид номер ноль.\n const сырой = с.LEAD_ID == null ? \"\" : String(с.LEAD_ID);\n return {\n id: String(с.ID ?? \"\"),\n название: String(с.TITLE ?? \"\"),\n стадия: String(с.STAGE_ID ?? \"\"),\n источник: String(с.SOURCE_ID ?? \"\"),\n создан: день(с.DATE_CREATE),\n изменена: день(с.DATE_MODIFY),\n сумма: Number(с.OPPORTUNITY ?? 0) || 0,\n ответственный: String(с.ASSIGNED_BY_ID ?? \"\"),\n лид: сырой === \"\" || сырой === \"0\" ? null : сырой,\n };\n });\n}\n\nexport async function загрузитьСотрудников(\n portal: Portal,\n deps: RestDeps = {},\n): Promise> {\n const люди = await callAll>(\n portal,\n \"user.get\",\n {},\n deps,\n );\n const карта = new Map();\n for (const ч of люди) {\n const имя = [ч.NAME, ч.LAST_NAME].filter(Boolean).join(\" \").trim();\n карта.set(String(ч.ID ?? \"\"), имя || String(ч.ID ?? \"\"));\n }\n return карта;\n}\n",[],[150,312,346],"e45761fa-0afb-41db-8a18-57d2bce4e218","csv.ts","8537c8a2-aac6-11f1-bc5b-1607ee4eb77e",13,["D",1788790504033],"import type { Обращение } from \"./metrics.ts\";\nimport type { Справочники } from \"./sources.ts\";\n\nconst ШАПКА = [\n \"Лид\",\n \"Дата\",\n \"Название\",\n \"Источник\",\n \"Менеджер\",\n \"Статус лида\",\n \"Сделка\",\n \"Стадия сделки\",\n \"Сумма\",\n \"Телефон\",\n \"Дней без движения\",\n];\n\n/** Защита от инъекции формул в Excel: если значение начинается с =, +, -, @, табуляции,\n * перевода строки, возврата каретки или одинарной кавычки, ставим перед ним одинарную\n * кавычку. Затем экранируем кавычки и заворачиваем в кавычки при наличии спецсимволов.\n * Excel на русской раскладке ждёт точку с запятой и BOM — без них выгрузка открывается\n * одной колонкой и кракозябрами. */\nfunction поле(v: string | number): string {\n let s = String(v ?? \"\");\n\n // Одна проверка вместо двух: опасные для Excel первые символы и уже\n // имеющаяся одинарная кавычка требуют одного и того же — одной кавычки\n // впереди. Две подряд идущие проверки удваивали её на обычных значениях.\n if (/^[=+\\-@\\t\\r\\n']/.test(s)) {\n s = \"'\" + s;\n }\n\n // Экранирование кавычек и спецсимволы: если есть кавычки, точка с запятой,\n // перевод строки или возврат каретки, оборачиваем в двойные кавычки\n // и экранируем внутренние кавычки\n if (/[\";\\n\\r]/.test(s)) {\n s = `\"${s.replaceAll('\"', '\"\"')}\"`;\n }\n\n return s;\n}\n\nexport function вCsv(\n о: Обращение[],\n с: Справочники,\n люди: Map,\n): string {\n const строки = [ШАПКА.join(\";\")];\n for (const з of о) {\n строки.push(\n [\n з.лид.id,\n з.лид.создан,\n з.лид.название,\n с.источники.get(з.лид.источник) ?? з.лид.источник,\n люди.get(з.лид.ответственный) ?? з.лид.ответственный,\n с.стадииЛида.get(з.лид.статус) ?? з.лид.статус,\n з.сделка?.id ?? \"\",\n з.сделка ? (с.стадииСделки.get(з.сделка.стадия) ?? з.сделка.стадия) : \"\",\n з.сделка?.сумма ?? \"\",\n з.лид.телефон,\n з.днейБезДвижения,\n ].map(поле).join(\";\"),\n );\n }\n return \"\" + строки.join(\"\\r\\n\");\n}\n",[],[150,312,354],"05ff1b3c-8000-4d3b-94d3-0b4e3a321e21","card.ts","82e75360-aac6-11f1-b22f-1607ee4eb77e",12,["D",1788790500135],"import { call, callAll, type RestDeps } from \"../rest.ts\";\nimport type { Portal } from \"../portals.ts\";\n\nexport interface Событие {\n когда: string;\n что: string;\n кто: string;\n файлы: { имя: string; ссылка: string }[];\n вид: \"лид\" | \"стадия\" | \"звонок\" | \"задача\" | \"комментарий\";\n запись?: string;\n}\n\nconst ВЛАДЕЛЕЦ_ЛИД = 1;\nconst ВЛАДЕЛЕЦ_СДЕЛКА = 2;\n\nasync function активности(\n portal: Portal,\n типВладельца: number,\n id: string,\n deps: RestDeps,\n): Promise<Событие[]> {\n const список = await callAll>(\n portal,\n \"crm.activity.list\",\n {\n filter: { OWNER_TYPE_ID: типВладельца, OWNER_ID: id },\n select: [\n \"ID\",\n \"SUBJECT\",\n \"TYPE_ID\",\n \"CREATED\",\n \"DIRECTION\",\n \"RESPONSIBLE_ID\",\n \"PROVIDER_ID\",\n ],\n order: { CREATED: \"ASC\" },\n },\n deps,\n );\n return список.map((а) => {\n const телефония = String(а.PROVIDER_ID ?? \"\").includes(\"CALL\");\n return {\n когда: String(а.CREATED ?? \"\"),\n что: String(а.SUBJECT ?? \"\"),\n кто: String(а.RESPONSIBLE_ID ?? \"\"),\n файлы: [],\n вид: телефония ? (\"звонок\" as const) : (\"задача\" as const),\n запись: телефония ? String(а.ID ?? \"\") : undefined,\n };\n });\n}\n\nasync function комментарии(\n portal: Portal,\n тип: \"lead\" | \"deal\",\n id: string,\n deps: RestDeps,\n): Promise<Событие[]> {\n const список = await callAll>(\n portal,\n \"crm.timeline.comment.list\",\n {\n filter: { ENTITY_ID: id, ENTITY_TYPE: тип },\n order: { CREATED: \"ASC\" },\n },\n deps,\n );\n return список.map((к) => {\n const файлы = Object.values(\n (к.FILES ?? {}) as Record,\n ).map((ф) => ({ имя: ф.name ?? \"файл\", ссылка: ф.urlDownload ?? \"\" }));\n return {\n когда: String(к.CREATED ?? \"\"),\n что: String(к.COMMENT ?? \"\"),\n кто: String(к.AUTHOR_ID ?? \"\"),\n файлы,\n вид: \"комментарий\" as const,\n };\n });\n}\n\nasync function стадии(portal: Portal, id: string, deps: RestDeps): Promise<Событие[]> {\n const ответ = await call<{ items?: Record[] }>(\n portal,\n \"crm.stagehistory.list\",\n {\n entityTypeId: ВЛАДЕЛЕЦ_СДЕЛКА,\n filter: { OWNER_ID: id },\n order: { CREATED_TIME: \"ASC\" },\n },\n deps,\n );\n return (ответ?.items ?? []).map((ш) => ({\n когда: String(ш.CREATED_TIME ?? \"\"),\n что: String(ш.STAGE_ID ?? \"\"),\n кто: \"\",\n файлы: [],\n вид: \"стадия\" as const,\n }));\n}\n\n/** Сводит в одну ленту всё, что портал знает о судьбе обращения (Д5). Части,\n * которых нет (обращение без сделки), просто не дают событий — это нормальное\n * состояние, а не сбой. */\nexport async function лента(\n portal: Portal,\n лидId: string | null,\n сделкаId: string | null,\n deps: RestDeps = {},\n): Promise<Событие[]> {\n const части: Событие[][] = [];\n if (лидId) {\n части.push(await активности(portal, ВЛАДЕЛЕЦ_ЛИД, лидId, deps));\n части.push(await комментарии(portal, \"lead\", лидId, deps));\n }\n if (сделкаId) {\n части.push(await стадии(portal, сделкаId, deps));\n части.push(await активности(portal, ВЛАДЕЛЕЦ_СДЕЛКА, сделкаId, deps));\n части.push(await комментарии(portal, \"deal\", сделкаId, deps));\n }\n return части.flat().sort((a, b) => a.когда.localeCompare(b.когда));\n}\n",[],[150,312,362],"857f3e88-5a9f-4374-aa75-896813d0404c","cache.ts","ae90843c-aac6-11f1-98d6-1607ee4eb77e",16,["D",1788790573390],"/** Кэш ответов портала на короткий срок (Д1). Смысл — не ускорение, а защита\n * от лимита частоты Битрикса: перезагрузка страницы не должна каждый раз\n * заново выкачивать восемь сотен лидов. */\nexport class Кэш {\n #ttl: number;\n #now: () => number;\n #ящик = new Map();\n\n constructor(ttlMs: number, now: () => number = Date.now) {\n this.#ttl = ttlMs;\n this.#now = now;\n }\n\n взять(ключ: string): T | undefined {\n const я = this.#ящик.get(ключ);\n if (!я) return undefined;\n if (this.#now() > я.до) {\n this.#ящик.delete(ключ);\n return undefined;\n }\n return я.значение;\n }\n\n положить(ключ: string, значение: T): void {\n this.#ящик.set(ключ, { до: this.#now() + this.#ttl, значение });\n }\n\n сбросить(): void {\n this.#ящик.clear();\n }\n}\n",[],[150,312,370],"d121e752-e585-4a1f-a1b7-b94b65f9d6a9","auth.ts","7e4c5be8-aac6-11f1-b22f-1607ee4eb77e",10,["D",1788790492401],"/** На странице телефоны клиентов, поэтому вход закрыт паролем (Д11). Пароль\n * живёт в переменной окружения и в разметку никогда не попадает.\n * В куке хранится подписанный токен, не сам пароль (Critical). */\n\n/** Сравнивает две строки устойчиво ко времени (constant-time). Экспортирована\n * для входа по паролю в dash.ts: обычное === посимвольно раскрывает совпавший\n * префикс через время ответа (находка 2 ревью задачи 11). */\nexport function сравнитьУстойчиво(a: string, b: string): boolean {\n if (a.length !== b.length) return false;\n\n let разница = 0;\n for (let i = 0; i < a.length; i++) {\n разница |= a.charCodeAt(i) ^ b.charCodeAt(i);\n }\n return разница === 0;\n}\n\n/** Кодирует массив байт в base64url без выравнивающих знаков. */\nfunction base64url(bytes: Uint8Array): string {\n const binary = Array.from(bytes).map((b) => String.fromCharCode(b)).join(\"\");\n return btoa(binary).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=/g, \"\");\n}\n\n/** Подписывает срок для куки. Возвращает строку вида «срок.подпись». */\nexport async function подписать(пароль: string, срок: number): Promise {\n const сообщение = `dash-v1|${срок}`;\n const ключ = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(пароль),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const подпись_bytes = await crypto.subtle.sign(\n \"HMAC\",\n ключ,\n new TextEncoder().encode(сообщение),\n );\n const подпись = base64url(new Uint8Array(подпись_bytes));\n return `${срок}.${подпись}`;\n}\n\n/** Проверяет токен куки. Возвращает true если токен верен и не просрочен. */\nexport async function проверить(\n пароль: string,\n токен: string,\n сейчас: number,\n): Promise {\n const части = токен.split(\".\");\n if (части.length !== 2) return false;\n\n const [сроквтексте, подпись_полученная] = части;\n if (!/^\\d+$/.test(сроквтексте)) return false;\n\n const срок = Number(сроквтексте);\n if (!Number.isSafeInteger(срок)) return false;\n if (String(срок) !== сроквтексте) return false;\n if (срок <= сейчас) return false;\n\n const подпись_ожидаемая = await подписать(пароль, срок);\n return сравнитьУстойчиво(\n подпись_ожидаемая.split(\".\")[1]!,\n подпись_полученная,\n );\n}\n\nexport async function пропущен(\n req: Request,\n пароль: string,\n сейчас: number = Date.now(),\n): Promise {\n // Пустой пароль никогда не открывает вход\n if (пароль === \"\") return false;\n\n const cookie = req.headers.get(\"cookie\") ?? \"\";\n for (const кусок of cookie.split(\";\")) {\n const [имя, ...остальное] = кусок.trim().split(\"=\");\n if (имя === \"__Host-dash\") {\n const токен = остальное.join(\"=\");\n return await проверить(пароль, токен, сейчас);\n }\n }\n return false;\n}\n\nexport async function ответСКукой(\n пароль: string,\n куда: string,\n сейчас: number = Date.now(),\n): Promise {\n // Пустой пароль — это ошибка развёртывания (Important)\n if (пароль === \"\") {\n throw new Error(\"Пароль не должен быть пустым\");\n }\n\n // Только локальные пути: начинаться с одной /, не с двух, без обратных слэшей\n if (!куда.startsWith(\"/\") || куда.startsWith(\"//\") || куда.includes(\"\\\\\")) {\n throw new Error(\"Неверный путь редиректа\");\n }\n\n const срок = сейчас + 7 * 24 * 60 * 60 * 1000; // неделя в мс\n const токен = await подписать(пароль, срок);\n\n return new Response(null, {\n status: 302,\n headers: {\n \"location\": куда,\n \"set-cookie\":\n `__Host-dash=${токен}; Path=/; HttpOnly; Secure; SameSite=Strict; Max-Age=604800`,\n },\n });\n}\n\n/** Экранирует HTML символы в строке для безопасной вставки в разметку. */\nfunction экранировать(текст: string): string {\n return текст\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\n}\n\nexport function страницаВхода(ошибка?: string): Response {\n const ошибка_экранирована = ошибка ? экранировать(ошибка) : \"\";\n const html = `\nРадар рекламных лидов\n\n`;\n return new Response(html, {\n status: 401,\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n}\n",[],[150,312,378],"b46ff9b8-3f9e-4a28-ab75-074b59c61e09","assets.ts","4551f028-aac6-11f1-a1b6-1607ee4eb77e",29,["D",1788847927274],"// Клиентская часть живёт в строковых константах: на Val Town нет файловой\n// системы (находка C1 ревью части 1), поэтому статика раздаётся из памяти.\n// Разрезано по разделам экрана: одна константа на 500 строк не читается и\n// не правится точечно.\nimport { ЧАСТЬ_ОБЩЕЕ } from \"./assets/common.ts\";\nimport { ЧАСТЬ_КАРКАС } from \"./assets/frame.ts\";\nimport { ЧАСТЬ_СИГНАЛЫ } from \"./assets/signals.ts\";\nimport { ЧАСТЬ_РАБОТА } from \"./assets/work.ts\";\nimport { ЧАСТЬ_ВОРОНКА } from \"./assets/funnel.ts\";\nimport { ЧАСТЬ_СПИСОК } from \"./assets/list.ts\";\nimport { ЧАСТЬ_РАДАР } from \"./assets/radar.ts\";\nimport { ЧАСТЬ_ЗАПУСК } from \"./assets/boot.ts\";\n\nexport { СТИЛИ } from \"./assets/styles.ts\";\n\n/** Порядок частей — это порядок выполнения в браузере: сперва данные и\n * помощники, затем каркас (он создаёт узлы, на которые опираются остальные),\n * затем отрисовщики, и только в конце их вызовы. */\nexport function сценарий(): string {\n return [\n ЧАСТЬ_ОБЩЕЕ,\n ЧАСТЬ_КАРКАС,\n ЧАСТЬ_СИГНАЛЫ,\n ЧАСТЬ_РАБОТА,\n ЧАСТЬ_ВОРОНКА,\n ЧАСТЬ_СПИСОК,\n ЧАСТЬ_РАДАР,\n ЧАСТЬ_ЗАПУСК,\n ].join(\"\\n\");\n}\n\nexport const СЦЕНАРИЙ: string = сценарий();\n",[],[150,312,386],"2f40696a-4272-48b2-8ae6-9969c18b5c93","530ba280-ab49-11f1-9ae7-1607ee4eb77e",["D",1788847955114],[],[150,312,398,32],"assets","245da170-dd38-4670-a65b-1ab8770629bc","list.ts","47ffc3e6-ab4c-11f1-a71f-1607ee4eb77e",34,["D",1788847953889],"// src/dash/assets/list.ts\n/** Список сделок. Сортировка и отбор по сигналу — в браузере: строки уже\n * пришли целиком, ходить за ними на сервер незачем. По умолчанию порядок\n * тот, что задал сервер: тишина по убыванию, затем сумма. */\nexport const ЧАСТЬ_СПИСОК: string = `\nlet ключСортировки = null, порядокУбыв = true;\n\nfunction отобранныеСделки() {\n if (!выбранныйСигнал) return экран.сделки;\n const с = экран.сигналы.find((x) => x.код === выбранныйСигнал);\n if (!с) return экран.сделки;\n const нужные = new Set(с.сделки);\n return экран.сделки.filter((р) => нужные.has(р.id));\n}\n\nfunction отсортированные(строки) {\n if (!ключСортировки) return строки;\n const знак = порядокУбыв ? -1 : 1;\n return [...строки].sort((a, b) => {\n const x = a[ключСортировки], y = b[ключСортировки];\n if (typeof x === \"number\" && typeof y === \"number\") return знак * (x - y);\n return знак * String(x ?? \"\").localeCompare(String(y ?? \"\"), \"ru\");\n });\n}\n\nfunction заголовок(имя, ключ) {\n const стрелка = ключСортировки === ключ ? (порядокУбыв ? \" ↓\" : \" ↑\") : \"\";\n return \\`\\${имя}\\${стрелка}\\`;\n}\n\nfunction перерисоватьСписок() {\n const строки = отсортированные(отобранныеСделки());\n const счётчик = document.getElementById(\"счётчик-сделок\");\n const сброс = document.getElementById(\"сброс-сигнала\");\n const сигнал = выбранныйСигнал && экран.сигналы.find((x) => x.код === выбранныйСигнал);\n счётчик.textContent = сигнал\n ? \\`\\${строки.length} — \\${сигнал.заголовок}\\`\n : \\`\\${строки.length} шт.\\`;\n сброс.hidden = !выбранныйСигнал;\n\n const т = document.getElementById(\"сделки\");\n if (!строки.length) {\n т.innerHTML = 'Ни одной сделки под этот отбор.';\n return;\n }\n т.innerHTML =\n \"СделкаСтадияМенеджерКаналКомпанияЛид\" +\n заголовок(\"Сумма\", \"сумма\") + заголовок(\"Возраст\", \"возраст\") +\n заголовок(\"На стадии\", \"наСтадии\") + заголовок(\"Тишина\", \"тишина\") +\n \"Следующий шаг\" +\n строки.map((с) => {\n const цвет = с.тишина > 90 ? \" плохо\" : с.тишина > 30 ? \" тревожно\" : \"\";\n const шаг = с.следующийШаг\n ? esc(с.следующийШаг.тема) + (с.следующийШаг.срок ? \" · \" + esc(с.следующийШаг.срок.slice(0, 10)) : \"\")\n : 'нет';\n const закрыта = с.открыта ? \"\" : ' закрыта';\n const компания = с.компания != null ? esc(с.компания) : '—';\n const лид = с.лид != null\n ? \\`№\\${esc(с.лид)}\\`\n : '—';\n return \\`\n №\\${esc(с.id)} \\${esc(с.название)}\\${закрыта}\n \\${esc(с.стадия)}\n \\${esc(с.менеджер)}\\${с.уволен ? ' уволен' : \"\"}\n \\${esc(с.канал)}\n \\${компания}\n \\${лид}\n \\${money(с.сумма)}\n \\${с.возраст}\n \\${с.наСтадии}\n \\${с.тишина}\n \\${шаг}\\`;\n }).join(\"\");\n\n for (const th of т.querySelectorAll(\"[data-ключ]\")) {\n th.onclick = () => {\n const ключ = th.dataset.ключ;\n if (ключСортировки === ключ) порядокУбыв = !порядокУбыв;\n else { ключСортировки = ключ; порядокУбыв = true; }\n перерисоватьСписок();\n };\n }\n}\n\ndocument.getElementById(\"сброс-сигнала\").onclick = () => {\n выбранныйСигнал = null;\n const u = new URL(location.href);\n u.searchParams.delete(\"signal\");\n history.replaceState(null, \"\", u.toString());\n нарисоватьСигналы();\n перерисоватьСписок();\n};\n`;\n",[],[150,312,398,400],"3f7a5d35-09cb-41d3-84ae-7c9dbb78250a","funnel.ts","3ab88786-ab4c-11f1-8b7c-1607ee4eb77e",33,["D",1788847931603],"// src/dash/assets/funnel.ts\n/** Состояние воронки — все стадии, включая пустые: пустая вторая половина\n * воронки и есть главная находка по портфелю, её нельзя прятать. Разрез по\n * менеджерам показывает медианы, а не средние: одна сделка на 1,7 млрд не\n * должна двигать показатель. */\nexport const ЧАСТЬ_ВОРОНКА: string = `\nfunction нарисоватьВоронку() {\n const узел = document.getElementById(\"состояние\");\n if (!экран.воронка.length) {\n узел.innerHTML = '

Открытых сделок нет.

';\n return;\n }\n const макс = Math.max(1, ...экран.воронка.map((с) => с.штук));\n узел.innerHTML = экран.воронка.map((с) => {\n const пусто = с.штук === 0 ? \" пусто\" : \"\";\n return \\`

\n \\${esc(с.стадия)}\n \n \\${с.штук}\\${с.сумма ? \" · \" + money(с.сумма) : \"\"}

\\`;\n }).join(\"\");\n}\n\nfunction нарисоватьМенеджеров() {\n const узел = document.getElementById(\"менеджеры\");\n if (!экран.менеджеры.length) {\n узел.innerHTML = '

Открытых сделок нет.

';\n return;\n }\n узел.innerHTML = экран.менеджеры.map((м) => {\n const строки = м.стадии.map((с) => {\n const крупная = с.стадияКод === м.крупнейшая ? ' class=\"крупная\"' : \"\";\n return \\`\\${esc(с.стадия)}\\${с.штук}\n \\${money(с.сумма)}\\${с.медианаВозраста}\n \\${с.медианаТишины}\\`;\n }).join(\"\");\n return \\`

\\${esc(м.имя)}\\${м.уволен ? ' уволен' : \"\"}\n — \\${м.открытых} открытых на \\${money(м.сумма)} ₸

\n \n \n \\${строки}\n

Стадия	Шт	Сумма	Медиана возраста	Медиана тишины

Молчат больше месяца — \\${м.молчатМесяц} из \\${м.открытых}.\n Больше трёх месяцев — \\${м.молчатКвартал}. Без суммы — \\${м.безСуммы}.

\\`;\n }).join(\"\");\n}\n`;\n",[],[150,312,398,408],"d0d50cf7-5f54-4c4b-b9d5-e1ca22d5c523","frame.ts","3a139654-ab4c-11f1-99c7-1607ee4eb77e",32,["D",1788847930528],"/** Статическая разметка вокруг #app — создаёт узлы, на которые опираются отрисовщики. */\nexport const ЧАСТЬ_КАРКАС: string =\n `// --- каркас страницы (в макете это была статическая разметка вокруг #app) ---\ndocument.getElementById(\"app\").innerHTML = \\`\n

Отдел ГПМ

Воронка «ОП ГПМ» портала \\${esc(ПОРТАЛ)} · период\n \\${esc(экран.период.с)} — \\${esc(экран.период.по)} (\\${экран.период.дней} дн.)

\n \n —\n \n \n \n \n \n \n

\n только реклама\n \n Выгрузить весь период в CSV\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\n

По источникам

По менеджерам

\n\n

Стадии сделок, пришедших с рекламы

\n\n

Требует внимания

\n\n

Обращения

\n\n\n

\n\n

\n\n\\`;\n\n{\n // Показанный день — конец периода из адреса, а не сегодняшний; для кнопок\n // периода нужен день браузера (\"sv-SE\" даёт ровно ГГГГ-ММ-ДД по местному дню).\n const сегодня = new Date().toLocaleDateString(\"sv-SE\");\n const пресет = {\n \"сегодня\": [сегодня, сегодня],\n \"вчера\": [сдвинутьДень(сегодня, -1), сдвинутьДень(сегодня, -1)],\n \"7\": [сдвинутьДень(сегодня, -6), сегодня],\n \"30\": [сдвинутьДень(сегодня, -29), сегодня],\n \"месяц\": [сегодня.slice(0, 8) + \"01\", сегодня],\n };\n // Предел сервера — МАКС_ДНЕЙ в src/dash/screen.ts; длиннее сервер отдаёт голый JSON.\n const МАКС_ДНЕЙ = 92;\n for (const b of document.querySelectorAll(\"[data-период]\")) {\n b.onclick = () => { const [с, по] = пресет[b.dataset.период]; перейти({ from: с, to: по }); };\n }\n const дс = document.getElementById(\"дата-с\"), дпо = document.getElementById(\"дата-по\");\n const вДнях = (день) => {\n const [г, м, д] = день.split(\"-\").map(Number);\n return Date.UTC(г, м - 1, д);\n };\n const применить = () => {\n const разница = Math.round((вДнях(дпо.value) - вДнях(дс.value)) / 86400000);\n if (разница < 0 || разница + 1 > МАКС_ДНЕЙ) {\n const узел = document.getElementById(\"недоступно\");\n узел.textContent = \\`Период не длиннее \\${МАКС_ДНЕЙ} дней — выберите меньший отрезок\\`;\n узел.hidden = false;\n return;\n }\n перейти({ from: дс.value, to: дпо.value });\n };\n дс.onchange = применить; дпо.onchange = применить;\n document.getElementById(\"только-реклама\").onchange = (e) =>\n перейти({ ad: e.target.checked ? \"1\" : null });\n\n const выбор = document.getElementById(\"выбор-менеджера\");\n const люди = new Map();\n for (const в of экран.выработка) люди.set(в.id, в.имя + (в.уволен ? \" (уволен)\" : \"\"));\n for (const м of экран.менеджеры) люди.set(м.id, м.имя + (м.уволен ? \" (уволен)\" : \"\"));\n выбор.innerHTML = '' +\n [...люди].map(([id, имя]) => \\`\\`).join(\"\");\n // Менеджер из адреса может не иметь активности и открытых сделок в периоде —\n // тогда его не будет ни в выработке, ни в списке менеджеров. Без своего\n // \\`,\n );\n }\n выбор.value = экран.параметры.менеджер ?? \"\";\n выбор.onchange = (e) => перейти({ manager: e.target.value || null });\n\n // Свои id (шапка-csv/шапка-обновить) — у радара внизу те же кнопки под\n // старыми id csvLink/refreshBtn, два одинаковых id на странице недопустимы.\n // \"/csv\" + строка запроса, как в радаре: замена подстроки location.pathname\n // не привязана к началу и на корневом пути портит адрес.\n document.getElementById(\"шапка-csv\").href = \"/csv\" + location.search;\n document.getElementById(\"шапка-обновить\").onclick = () => перейти({ refresh: \"1\" });\n\n if (экран.недоступно.length || !экран.телефония) {\n const узел = document.getElementById(\"недоступно\");\n const части = [...экран.недоступно];\n if (!экран.телефония) части.push(\"телефония недоступна — звонки в выработке не учтены\");\n узел.textContent = \"Часть данных не получена: \" + части.join(\"; \");\n узел.hidden = false;\n }\n}\n`;\n",[],[150,312,398,416],"864b590d-72b9-4610-8ab1-6c439351e051","common.ts","39a78356-ab4c-11f1-9c9f-1607ee4eb77e",31,["D",1788847929826],"/** Заголовок сценария, чтение данных из #данные и общие помощники (money, esc). */\nexport const ЧАСТЬ_ОБЩЕЕ: string =\n `// Клиентский сценарий дашборда. Перенесён из согласованного макета\n// (.superpowers/sdd/2026-08-31-dashboard-reklamnyh-lidov/soglasovannyy-maket.html):\n// состав экранов, вёрстка и порядок блоков сохранены. Отличия от макета:\n// - данные читаются из

Что происходило

Заметка собственника

Причина отказа

Отдел ГПМ

Чем занят день за период

Где стоят открытые сделки

Портфель по менеджерам

Сделки \n показать все

Реклама: путь обращений

Путь обращения

По месяцам

По источникам

По менеджерам

Стадии сделок, пришедших с рекламы

Требует внимания

Обращения

Сделки \n

Diff · v35