Радар рекламных лидов

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_265":266,"_267":268},"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",11,"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/write.ts","latestPath","fileId","808ede94-aac6-11f1-beac-1607ee4eb77e","name","write.ts","fileType","script","content","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","createdAt",["D",1788790496203],"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":261,"_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":262,"_80":263,"_82":264,"_84":24},"tree",[166,177,178],"files",[166,167,168,169,170,171,172,173,174,175,176,177,178],"counts",{"_155":62,"_156":144,"_157":62,"_158":159,"_160":161},"contents",[127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":148,"_31":149,"_29":150,"_132":-5,"_40":41,"_39":151,"_134":58,"_37":152,"_13":62,"_33":153,"_35":-5,"_23":24,"_138":-5,"_26":154},{"_42":141,"_31":142,"_29":143,"_132":-5,"_40":41,"_39":144,"_134":24,"_37":145,"_13":62,"_33":20,"_35":146,"_23":24,"_138":-5,"_26":147},{"_42":130,"_31":131,"_29":56,"_132":-5,"_40":41,"_39":133,"_134":24,"_37":135,"_13":62,"_33":136,"_35":137,"_23":24,"_138":139,"_26":140},"be5fcdad-5b3b-4454-aecb-074a9737acc5","dash.ts","parentId",2,"latest",["D",1788790391961],"http","import { envOpt } from \"./src/env.ts\";\nimport { getPortal } from \"./src/portals.ts\";\nimport { ответСКукой, пропущен, сравнитьУстойчиво, страницаВхода } from \"./src/dash/auth.ts\";\nimport { дляСтраницы, type Снимок, собратьСнимок } from \"./src/dash/snapshot.ts\";\nimport { страница } from \"./src/dash/page.ts\";\nimport { СТИЛИ, СЦЕНАРИЙ } from \"./src/dash/assets.ts\";\nimport { Кэш } from \"./src/dash/cache.ts\";\nimport { вCsv } from \"./src/dash/csv.ts\";\nimport { лента } from \"./src/dash/card.ts\";\nimport {\n написатьКомментарий,\n ОшибкаПроверки,\n причиныОтказа,\n проставитьПричину,\n} from \"./src/dash/write.ts\";\n\nconst КЭШ = new Кэш<Снимок>(5 * 60 * 1000);\n\n/** Пока по одному ключу снимка уже идёт сборка, второй одновременный запрос\n * ждёт тот же промис вместо новой сборки (находка 8 ревью задачи 11): иначе\n * несколько параллельных открытий страницы с холодным кэшем запускают по\n * четыре тяжёлых обращения к порталу каждое. */\nconst ВЫПОЛНЯЕТСЯ = new Map>();\n\n/** Статика отдаётся из строковых констант в памяти (src/dash/assets.ts), а не\n * читается с диска (находка C1, Critical): на Val Town нет файловой системы —\n * там нет `Deno.readFile`/`readTextFile`, а `import.meta.url` там https-адрес,\n * а не `file://`, так что `new URL(...)` даже не собрал бы валидный путь для\n * чтения. Раздача из памяти работает одинаково локально и на Val Town. */\nconst СТАТИКА: Record = {\n \"/dash.css\": { тело: СТИЛИ, тип: \"text/css; charset=utf-8\" },\n \"/dash.js\": { тело: СЦЕНАРИЙ, тип: \"text/javascript; charset=utf-8\" },\n};\n\n/** Читает JSON тела запроса, не бросая исключение наружу (находка 4): битое\n * или пустое тело — это ошибка клиента (400), а не необработанное падение. */\nasync function прочестьJson(req: Request): Promise<{ ok: true; тело: unknown } | { ok: false }> {\n try {\n return { ok: true, тело: await req.json() };\n } catch {\n return { ok: false };\n }\n}\n\nfunction объект(v: unknown): v is Record {\n return typeof v === \"object\" && v !== null && !Array.isArray(v);\n}\n\n/** Заголовок Origin у обычного запроса со страницы дашборда есть всегда и\n * совпадает с адресом самого дашборда. Отсутствие или расхождение — признак\n * запроса с чужого сайта (находка 1, Critical): SameSite=Strict у куки этот\n * сценарий уже закрывает для большинства браузеров, но для маршрутов, которые\n * пишут в боевую CRM клиента, полагаться на одну лишь настройку куки нельзя.\n *\n * Сравниваются ИМЕНА ХОСТОВ, а не адреса целиком (переревью, находка про\n * прод): вал разворачивается за обратным прокси-терминатором TLS — снаружи\n * браузер обращается по https и присылает Origin со схемой https, а внутрь\n * приложения запрос приходит по http. Сравнение полных origin никогда бы не\n * сошлось и валило бы 403 у всех пользователей в проде, хотя запрос идёт со\n * своей же страницы. Схема здесь никакой защиты не даёт: чужой сайт не может\n * подделать имя хоста в заголовке Origin — его ставит браузер, а не код\n * страницы; значение заголовка полностью вне контроля JS с чужого домена.\n * Ожидаемый хост берётся из заголовка Host запроса (это и есть то, к чему\n * реально обратился браузер, прокси его не переписывает), а если заголовка\n * нет — из адреса самого запроса, как раньше.\n *\n * Отсутствие заголовка Origin — тоже отказ, и это осознанное решение, а не\n * недосмотр: у дашборда один пользователь, работает из обычного браузера,\n * а браузер всегда шлёт Origin у запроса, отправленного со страницы (fetch/\n * XHR/form). Часть нестандартных клиентов (curl, некоторые расширения) его\n * не пришлют и потеряют возможность записи — это принято сознательно: для\n * операции, меняющей боевую CRM клиента, строгий отказ правильнее, чем\n * смягчение проверки ради клиента, который здесь никогда и не появится.\n * Следующему читателю: не убирать эту строгость, увидев жалобу «Origin не\n * пришёл» — обычный браузер эту жалобу никогда не produces. */\nfunction источникВерен(req: Request, url: URL): boolean {\n const origin = req.headers.get(\"origin\");\n if (origin === null) return false;\n\n let хостОригина: string;\n try {\n // Значение может быть строкой \"null\" (так браузер помечает запросы из\n // песочницы) или произвольным мусором — в обоих случаях new URL бросает,\n // и это тоже отказ, а не повод разбирать вручную.\n хостОригина = new URL(origin).host;\n } catch {\n return false;\n }\n\n const хостОжидаемый = req.headers.get(\"host\") ?? url.host;\n return хостОригина === хостОжидаемый;\n}\n\n/** Наружу — короткий безопасный текст; полный текст исключения (адрес\n * вебхука, внутренние поля, данные клиента) — только в консоль сервера\n * (находка 6). Исключение — ОшибкаПроверки: её текст мы писали сами в\n * write.ts, он безопасен и полезен пользователю. */\nfunction ответНаОшибкуПортала(е: unknown): Response {\n if (е instanceof ОшибкаПроверки) {\n return Response.json({ error: е.message }, { status: 400 });\n }\n console.error(е);\n return Response.json(\n { error: \"Портал отклонил запрос, подробности в журнале сервера\" },\n { status: 400 },\n );\n}\n\n/** Строгая проверка параметра from (находка 7): только вид ГГГГ-ММ-ДД, и дата\n * обязана существовать по-настоящему — иначе мусор уходит в фильтр запроса\n * к порталу и раздувает кэш случайными ключами. */\nfunction разобранаДата(s: string): boolean {\n const m = /^(\\d{4})-(\\d{2})-(\\d{2})$/.exec(s);\n if (!m) return false;\n const год = Number(m[1]);\n const месяц = Number(m[2]);\n const день = Number(m[3]);\n const d = new Date(Date.UTC(год, месяц - 1, день));\n return (\n d.getUTCFullYear() === год &&\n d.getUTCMonth() === месяц - 1 &&\n d.getUTCDate() === день\n );\n}\n\nexport default async function (req: Request): Promise {\n const пароль = envOpt(\"DASH_PASSWORD\");\n const слаг = envOpt(\"DASH_PORTAL\") ?? \"uls\";\n if (!пароль) {\n return Response.json({ error: \"DASH_PASSWORD не задан в переменных окружения\" }, {\n status: 500,\n });\n }\n const url = new URL(req.url);\n\n if (url.pathname === \"/login\" && req.method === \"POST\") {\n const форма = await req.formData();\n // Устойчивое ко времени сравнение (находка 2): обычное === раскрывает\n // совпавший префикс пароля через время ответа.\n return сравнитьУстойчиво(String(форма.get(\"p\") ?? \"\"), пароль)\n ? await ответСКукой(пароль, \"/\")\n : страницаВхода(\"Пароль не подошёл\");\n }\n // Все пути, кроме /login, закрыты проверкой пропущен() — включая статику:\n // дашборд с телефонами клиентов не должен отдавать даже вёрстку и скрипт\n // тому, кто не вошёл.\n if (!(await пропущен(req, пароль))) return страницаВхода();\n\n const статика = СТАТИКА[url.pathname];\n if (статика) {\n return new Response(статика.тело, { headers: { \"content-type\": статика.тип } });\n }\n\n const портал = getPortal(слаг);\n\n // Причина отказа: имя поля берётся только из переменной окружения, никогда\n // из запроса браузера — иначе испорченный или подделанный запрос мог бы\n // записать значение в произвольное поле лида на боевом портале.\n const полеПричины = envOpt(\"REFUSAL_FIELD\");\n\n if (url.pathname === \"/reasons\" && req.method === \"GET\") {\n if (!полеПричины) {\n return Response.json(\n { error: \"REFUSAL_FIELD не задан — причины отказа отключены\" },\n { status: 404 },\n );\n }\n try {\n const список = await причиныОтказа(портал, полеПричины);\n return Response.json(список);\n } catch (е) {\n return ответНаОшибкуПортала(е);\n }\n }\n\n if (url.pathname === \"/refusal\" && req.method === \"POST\") {\n if (!источникВерен(req, url)) {\n return Response.json({ error: \"Запрос не с этой страницы (Origin не совпадает)\" }, {\n status: 403,\n });\n }\n if (!полеПричины) {\n return Response.json(\n { error: \"REFUSAL_FIELD не задан — запись причины отказа отключена\" },\n { status: 500 },\n );\n }\n const разбор = await прочестьJson(req);\n if (!разбор.ok || !объект(разбор.тело)) {\n return Response.json({ error: \"Тело запроса не является JSON-объектом\" }, { status: 400 });\n }\n const { лид, значение } = разбор.тело as Record;\n if (typeof лид !== \"string\" || лид.trim().length === 0) {\n return Response.json({ error: \"Поле «лид» обязано быть непустой строкой\" }, {\n status: 400,\n });\n }\n if (typeof значение !== \"string\" || значение.trim().length === 0) {\n return Response.json({ error: \"Поле «значение» обязано быть непустой строкой\" }, {\n status: 400,\n });\n }\n try {\n await проставитьПричину(портал, лид, полеПричины, значение);\n КЭШ.сбросить();\n return Response.json({ ok: true });\n } catch (е) {\n return ответНаОшибкуПортала(е);\n }\n }\n\n if (url.pathname === \"/card\") {\n const лид = url.searchParams.get(\"lead\");\n const сделка = url.searchParams.get(\"deal\");\n return Response.json(await лента(портал, лид, сделка));\n }\n\n if (url.pathname === \"/comment\" && req.method === \"POST\") {\n if (!источникВерен(req, url)) {\n return Response.json({ error: \"Запрос не с этой страницы (Origin не совпадает)\" }, {\n status: 403,\n });\n }\n const разбор = await прочестьJson(req);\n if (!разбор.ok || !объект(разбор.тело)) {\n return Response.json({ error: \"Тело запроса не является JSON-объектом\" }, { status: 400 });\n }\n const { тип, id, текст } = разбор.тело as Record;\n if (тип !== \"lead\" && тип !== \"deal\") {\n return Response.json({ error: \"Поле «тип» обязано быть lead или deal\" }, { status: 400 });\n }\n if (typeof id !== \"string\" || id.trim().length === 0) {\n return Response.json({ error: \"Поле «id» обязано быть непустой строкой\" }, {\n status: 400,\n });\n }\n if (typeof текст !== \"string\") {\n return Response.json({ error: \"Поле «текст» обязано быть строкой\" }, { status: 400 });\n }\n if (текст.length > 10_000) {\n return Response.json({ error: \"Комментарий длиннее 10000 символов\" }, { status: 400 });\n }\n try {\n const id_ = await написатьКомментарий(портал, тип, id, текст);\n КЭШ.сбросить();\n return Response.json({ ok: true, id: id_ });\n } catch (е) {\n return ответНаОшибкуПортала(е);\n }\n }\n\n // Снимок собирается только для двух вещей ниже — главной страницы и\n // выгрузки CSV (находка 3): /card и /comment его не используют и не должны\n // ждать выкачивание восьми сотен лидов и сотни сделок ради ленты событий\n // или одного комментария.\n if (url.pathname !== \"/\" && url.pathname !== \"/csv\") {\n return Response.json({ error: \"Неизвестный путь\" }, { status: 404 });\n }\n\n const сегодня = new Date();\n const отДатыRaw = url.searchParams.get(\"from\");\n let отДаты: string;\n if (отДатыRaw === null) {\n отДаты = `${сегодня.getUTCFullYear()}-01-01`;\n } else if (разобранаДата(отДатыRaw)) {\n отДаты = отДатыRaw;\n } else {\n return Response.json(\n { error: \"Параметр from обязан быть настоящей датой в виде ГГГГ-ММ-ДД\" },\n { status: 400 },\n );\n }\n const ключ = `снимок:${отДаты}`;\n if (url.searchParams.has(\"refresh\")) КЭШ.сбросить();\n let снимок = КЭШ.взять(ключ);\n if (!снимок) {\n let промис = ВЫПОЛНЯЕТСЯ.get(ключ);\n if (!промис) {\n промис = собратьСнимок(портал, отДаты, сегодня).finally(() => {\n ВЫПОЛНЯЕТСЯ.delete(ключ);\n });\n ВЫПОЛНЯЕТСЯ.set(ключ, промис);\n }\n снимок = await промис;\n КЭШ.положить(ключ, снимок);\n }\n\n if (url.pathname === \"/csv\") {\n return new Response(вCsv(снимок.обращения, снимок.справочники, снимок.люди), {\n headers: {\n \"content-type\": \"text/csv; charset=utf-8\",\n \"content-disposition\": 'attachment; filename=\"obrashcheniya.csv\"',\n },\n });\n }\n\n return new Response(страница(дляСтраницы(снимок, сегодня), портал.domain), {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n}\n","label","uls-radar",[131],"b4891b78-0353-442c-a6ee-e1f7754f33d4","README.md","ffcaa978-aac5-11f1-9a31-1607ee4eb77e",1,["D",1788790280169],"# Радар рекламных лидов ULS\n\nЖивая страница по воронке «ОП ГПМ» портала uls.bitrix24.kz: что происходит\nс обращениями, пришедшими с рекламы, и во что они превращаются.\n\nВход — `dash.ts` (HTTP). Данные берутся у портала при запросе, свой базы нет,\nответ кэшируется на пять минут.\n\n## Переменные окружения\n\n| Переменная | Что | Секрет |\n|---|---|---|\n| `B24_PORTALS` | `uls` | нет |\n| `B24_HOOK_ULS` | входящий вебхук портала целиком, со слэшем на конце | **да** |\n| `B24_TITLE_ULS` | как называть портал на странице | нет |\n| `DASH_PORTAL` | `uls` | нет |\n| `DASH_PASSWORD` | пароль входа на страницу | **да** |\n| `AD_SOURCES` | коды рекламных источников через запятую | нет |\n| `REFUSAL_FIELD` | имя списочного поля лида с причиной отказа (`UF_CRM_…`) | нет |\n\nСекреты живут только здесь, в переменных окружения вала: ни в коде, ни в\nрепозитории, ни в переписке.\n\nИсходник: ветка `claude/uls-portal-access-1bb082` репозитория коннектора\nБитрикс24. Правки вносить там и переносить сюда, а не наоборот.\n",[142],"2d62502a-f613-43bf-a173-f1e13318c5f3","src","fce2ee45-dde0-44d8-a8ff-19af836c83de",3,["D",1788790396829],"directory",[149],"pulls","branches","forks","envVars",{"_162":164,"_165":62},"connections",{"_162":62,"_163":62},"count","unfilledCount",6,"emptyCount",{"_42":148,"_31":149,"_29":150,"_132":-5,"_40":41,"_39":151,"_134":58,"_37":258,"_13":62,"_33":153,"_35":-5,"_23":24,"_138":-5,"_180":259,"_26":260},{"_42":254,"_31":222,"_29":218,"_132":150,"_40":41,"_39":151,"_134":58,"_37":255,"_13":62,"_33":153,"_35":-5,"_23":24,"_138":-5,"_180":256,"_26":257},{"_42":247,"_31":248,"_29":249,"_132":218,"_40":41,"_39":151,"_134":24,"_37":250,"_13":62,"_33":34,"_35":251,"_23":24,"_138":-5,"_180":252,"_26":253},{"_42":239,"_31":240,"_29":241,"_132":218,"_40":41,"_39":242,"_134":58,"_37":243,"_13":62,"_33":34,"_35":244,"_23":24,"_138":-5,"_180":245,"_26":246},{"_42":231,"_31":232,"_29":233,"_132":218,"_40":41,"_39":234,"_134":24,"_37":235,"_13":62,"_33":34,"_35":236,"_23":24,"_138":-5,"_180":237,"_26":238},{"_42":223,"_31":224,"_29":225,"_132":218,"_40":41,"_39":226,"_134":24,"_37":227,"_13":62,"_33":34,"_35":228,"_23":24,"_138":-5,"_180":229,"_26":230},{"_42":217,"_31":32,"_29":30,"_132":218,"_40":41,"_39":14,"_134":58,"_37":219,"_13":62,"_33":34,"_35":36,"_23":24,"_138":-5,"_180":220,"_26":221},{"_42":209,"_31":210,"_29":211,"_132":150,"_40":41,"_39":212,"_134":58,"_37":213,"_13":62,"_33":34,"_35":214,"_23":24,"_138":-5,"_180":215,"_26":216},{"_42":201,"_31":202,"_29":203,"_132":150,"_40":41,"_39":204,"_134":58,"_37":205,"_13":62,"_33":34,"_35":206,"_23":24,"_138":-5,"_180":207,"_26":208},{"_42":193,"_31":194,"_29":195,"_132":150,"_40":41,"_39":196,"_134":58,"_37":197,"_13":62,"_33":34,"_35":198,"_23":24,"_138":-5,"_180":199,"_26":200},{"_42":186,"_31":187,"_29":188,"_132":150,"_40":41,"_39":164,"_134":58,"_37":189,"_13":62,"_33":34,"_35":190,"_23":24,"_138":-5,"_180":191,"_26":192},{"_42":141,"_31":142,"_29":143,"_132":-5,"_40":41,"_39":144,"_134":24,"_37":183,"_13":62,"_33":20,"_35":146,"_23":24,"_138":-5,"_180":184,"_26":185},{"_42":130,"_31":131,"_29":56,"_132":-5,"_40":41,"_39":133,"_134":24,"_37":179,"_13":62,"_33":136,"_35":137,"_23":24,"_138":139,"_180":181,"_26":182},["D",1788790391961],"children",[],[131],["D",1788790280169],[],[142],"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",[],[149,187],"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",[],[149,194],"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",[],[149,202],"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",[],[149,210],"a3732ce4-ad59-4f7d-b1eb-2440d784172f","ea2bc655-318f-4a1f-8393-ec5c5fa3f307",["D",1788790496203],[],[149,222,32],"dash","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",[],[149,222,224],"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",[],[149,222,232],"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",[],[149,222,240],"386e5c2d-2817-4bec-a2ed-058fcc6238bd","assets.ts","4551f028-aac6-11f1-a1b6-1607ee4eb77e",["D",1788790396829],"// Сгенерировано из public/dash.css и public/dash.js (находка C1 финального\n// ревью): на Val Town нет файловой системы, поэтому статика раздаётся из\n// строковых констант в памяти, а не читается с диска через Deno.readTextFile.\n// Содержимое — дословная копия исходных файлов, перенесённая как есть.\n\n/** Содержимое /dash.css, дословно. */\nexport const СТИЛИ: string =\n '@import url(\"https://fonts.googleapis.com/css2?family=Barlow+Condensed:wght@500;600;700&family=IBM+Plex+Sans:wght@400;500;600&family=IBM+Plex+Mono:wght@400;500&display=swap\");\\n:root{\\n --bg:#EDF1F5; --surface:#FFFFFF; --sunk:#F5F8FA; --ink:#111A23; --muted:#5C6E7E; --line:#D6DEE6;\\n --accent:#0F5C8C; --accent-ink:#0B4A72; --signal:#C2410C;\\n --ok-bg:#DCEEE3; --ok-ink:#1E5C3C; --bad-bg:#F6E2DF; --bad-ink:#8E3227;\\n --warn-bg:#F7EAD2; --warn-ink:#7A551A; --chip:#E6ECF2;\\n --bar:#0F5C8C; --bar2:#7FA9C6;\\n}\\n@media (prefers-color-scheme:dark){:root:not([data-theme=\"light\"]){\\n --bg:#101519; --surface:#181F26; --sunk:#141A20; --ink:#E3E9EF; --muted:#93A3B2; --line:#28323C;\\n --accent:#4E9CD0; --accent-ink:#7DBBE4; --signal:#E8763F;\\n --ok-bg:#17311F; --ok-ink:#79C393; --bad-bg:#361F1B; --bad-ink:#DE9384;\\n --warn-bg:#33290F; --warn-ink:#D6B366; --chip:#212A33;\\n --bar:#4E9CD0; --bar2:#2C5E80;\\n}}\\n:root[data-theme=\"dark\"]{\\n --bg:#101519; --surface:#181F26; --sunk:#141A20; --ink:#E3E9EF; --muted:#93A3B2; --line:#28323C;\\n --accent:#4E9CD0; --accent-ink:#7DBBE4; --signal:#E8763F;\\n --ok-bg:#17311F; --ok-ink:#79C393; --bad-bg:#361F1B; --bad-ink:#DE9384;\\n --warn-bg:#33290F; --warn-ink:#D6B366; --chip:#212A33;\\n --bar:#4E9CD0; --bar2:#2C5E80;\\n}\\n*{box-sizing:border-box}\\nbody{margin:0;background:var(--bg);color:var(--ink);\\n font:14px/1.5 \"IBM Plex Sans\",\"Segoe UI\",system-ui,sans-serif;}\\n.wrap{max-width:1240px;margin:0 auto;padding:22px 18px 60px}\\nh1{font-family:\"Barlow Condensed\",sans-serif;font-size:34px;font-weight:700;letter-spacing:.01em;\\n margin:0 0 3px;text-transform:uppercase}\\n.sub{color:var(--muted);font-size:13px;margin-bottom:18px}\\n.panel{background:var(--surface);border:1px solid var(--line);border-radius:7px}\\n.filters{display:flex;gap:8px;flex-wrap:wrap;padding:11px 13px;margin-bottom:14px;align-items:center}\\n.filters .btn{margin-top:0;text-decoration:none;display:inline-block}\\n.filters label{font-size:11px;text-transform:uppercase;letter-spacing:.07em;color:var(--muted);\\n font-weight:600;margin-right:3px}\\nselect,input[type=search]{font:inherit;font-size:13px;padding:5px 8px;border:1px solid var(--line);\\n border-radius:4px;background:var(--sunk);color:var(--ink)}\\ninput[type=search]{min-width:180px}\\n.kpis{display:grid;grid-template-columns:repeat(auto-fit,minmax(132px,1fr));gap:9px;margin-bottom:16px}\\n.kpi{background:var(--surface);border:1px solid var(--line);border-radius:7px;padding:11px 13px}\\n.kpi b{display:block;font-family:\"Barlow Condensed\",sans-serif;font-size:30px;font-weight:600;\\n line-height:1.05;font-variant-numeric:tabular-nums}\\n.kpi span{font-size:11.5px;color:var(--muted);display:block;margin-top:1px}\\n.kpi.sig b{color:var(--signal)} .kpi.ok b{color:var(--ok-ink)} .kpi.acc b{color:var(--accent)}\\n.grid2{display:grid;grid-template-columns:1fr 1fr;gap:14px;margin-bottom:14px}\\n@media(max-width:860px){.grid2{grid-template-columns:1fr}}\\nh2{font-family:\"Barlow Condensed\",sans-serif;font-size:17px;text-transform:uppercase;\\n letter-spacing:.05em;margin:0 0 9px;font-weight:600}\\n.box{padding:13px}\\n.funnel div{display:flex;align-items:center;gap:9px;margin:5px 0;font-size:13px}\\n.funnel .bar{height:19px;background:var(--bar);border-radius:3px;min-width:2px}\\n.funnel .lbl{width:132px;flex:none;color:var(--muted);font-size:12.5px}\\n.funnel .val{font-family:\"IBM Plex Mono\",monospace;font-size:12.5px;font-variant-numeric:tabular-nums}\\ntable{width:100%;border-collapse:collapse;font-size:13px}\\nth{font-size:10.5px;text-transform:uppercase;letter-spacing:.06em;color:var(--muted);font-weight:600;\\n text-align:left;padding:7px 9px;border-bottom:1px solid var(--line);white-space:nowrap}\\ntd{padding:6px 9px;border-bottom:1px solid var(--line);vertical-align:top}\\ntr:last-child td{border-bottom:none}\\ntd.n,th.n{text-align:right;font-family:\"IBM Plex Mono\",monospace;font-variant-numeric:tabular-nums;\\n font-size:12.5px;white-space:nowrap}\\n.months{display:flex;gap:5px;align-items:flex-end;height:110px;padding:4px 0}\\n.months .col{flex:1;display:flex;flex-direction:column;justify-content:flex-end;gap:2px;align-items:center}\\n.months .b1{width:100%;background:var(--bar2);border-radius:2px 2px 0 0}\\n.months .b2{width:100%;background:var(--signal);border-radius:2px 2px 0 0}\\n.months .mm{font-size:10.5px;color:var(--muted);margin-top:3px}\\n.legend{font-size:11.5px;color:var(--muted);display:flex;gap:12px;margin-top:5px}\\n.legend i{display:inline-block;width:9px;height:9px;border-radius:2px;margin-right:4px}\\n.tblwrap{overflow-x:auto}\\n.rowlink{cursor:pointer}\\n.rowlink:hover{background:var(--sunk)}\\nth.sortable{cursor:pointer;user-select:none}\\nth.sortable:hover{color:var(--ink)}\\n.issues{display:grid;grid-template-columns:repeat(auto-fit,minmax(230px,1fr));gap:10px}\\n.issue{background:var(--sunk);border:1px solid var(--line);border-radius:6px;padding:9px 11px}\\n.issue .ihead{display:flex;justify-content:space-between;align-items:baseline;gap:8px;margin-bottom:4px}\\n.issue .ihead b{font-size:12.5px;font-weight:600}\\n.issue .ihead .count{color:var(--muted);font-family:\"IBM Plex Mono\",monospace;font-size:12px;flex:none}\\n.issue .ilist{font-size:12.5px;line-height:1.7;color:var(--ink);word-break:break-word}\\n.issue .iempty{font-size:12.5px;color:var(--muted)}\\n.chip{display:inline-block;padding:1px 7px;border-radius:9px;font-size:11.5px;font-weight:600;white-space:nowrap}\\n.c-ok{background:var(--ok-bg);color:var(--ok-ink)}\\n.c-bad{background:var(--bad-bg);color:var(--bad-ink)}\\n.c-warn{background:var(--warn-bg);color:var(--warn-ink)}\\n.c-mut{background:var(--chip);color:var(--muted)}\\na{color:var(--accent-ink)}\\n.mono{font-family:\"IBM Plex Mono\",monospace;font-size:12.5px}\\n.count{color:var(--muted);font-weight:400;font-size:13px;font-family:\"IBM Plex Sans\",sans-serif;\\n text-transform:none;letter-spacing:0}\\n/* панель детали */\\n.scrim{position:fixed;inset:0;background:rgba(8,14,20,.5);opacity:0;pointer-events:none;\\n transition:opacity .18s;z-index:40}\\n.scrim.on{opacity:1;pointer-events:auto}\\n.drawer{position:fixed;top:0;right:0;height:100%;width:min(560px,100%);background:var(--surface);\\n border-left:1px solid var(--line);transform:translateX(100%);transition:transform .22s;z-index:50;\\n overflow-y:auto;padding:18px 20px 40px}\\n.drawer.on{transform:none}\\n.dclose{position:absolute;top:12px;right:14px;background:var(--chip);border:none;color:var(--ink);\\n border-radius:4px;padding:4px 9px;cursor:pointer;font:inherit;font-size:13px}\\n.dh{font-family:\"Barlow Condensed\",sans-serif;font-size:23px;font-weight:600;margin:0 34px 2px 0}\\n.meta{display:grid;grid-template-columns:auto 1fr;gap:4px 14px;font-size:13px;margin:12px 0 16px}\\n.meta dt{color:var(--muted)} .meta dd{margin:0}\\n.tl{border-left:2px solid var(--line);margin-left:6px;padding-left:14px}\\n.tl .ev{position:relative;padding:0 0 14px}\\n.tl .ev::before{content:\"\";position:absolute;left:-20px;top:5px;width:8px;height:8px;border-radius:50%;\\n background:var(--accent);border:2px solid var(--surface)}\\n.tl .ev.sig::before{background:var(--signal)}\\n.tl .when{font-family:\"IBM Plex Mono\",monospace;font-size:11.5px;color:var(--muted)}\\n.tl .what{font-size:13px;margin-top:1px;white-space:pre-wrap}\\n.tl .who{font-size:11.5px;color:var(--muted)}\\n.files{margin-top:4px;display:flex;flex-direction:column;gap:2px}\\n.files span{font-size:12px;color:var(--accent-ink)}\\n.cbox{margin-top:14px}\\n.cbox textarea{width:100%;font:inherit;font-size:13px;padding:8px;border:1px solid var(--line);\\n border-radius:5px;background:var(--sunk);color:var(--ink);resize:vertical;min-height:64px}\\n.btn{margin-top:7px;background:var(--accent);color:#fff;border:none;border-radius:5px;padding:7px 14px;\\n font:inherit;font-size:13px;font-weight:600;cursor:pointer}\\n.btn.ghost{background:var(--chip);color:var(--ink)}\\n.btn:disabled{opacity:.55;cursor:default}\\n.note{font-size:11.5px;color:var(--muted);margin-top:6px}\\n.reason{margin-top:14px}\\n.reason select{width:100%;margin-bottom:7px}\\n.err{color:var(--bad-ink);font-size:12.5px;margin-top:6px}\\nfooter{margin-top:26px;padding-top:13px;border-top:1px solid var(--line);color:var(--muted);font-size:12px}\\n';\n\n/** Содержимое /dash.js, дословно. */\nexport const СЦЕНАРИЙ: string =\n '// Клиентский сценарий дашборда. Перенесён из согласованного макета\\n// (.superpowers/sdd/2026-08-31-dashboard-reklamnyh-lidov/soglasovannyy-maket.html):\\n// состав экранов, вёрстка и порядок блоков сохранены. Отличия от макета:\\n// - данные читаются из

Diff · v11