[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_220":221,"_222":223},"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",6,"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/rest.ts","latestPath","fileId","5a2e66ac-aac6-11f1-9772-1607ee4eb77e","name","rest.ts","fileType","script","content","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","createdAt",["D",1788790431810],"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":216,"_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":217,"_80":218,"_82":219,"_84":24},"tree",[165,171,172],"files",[165,166,167,168,169,170,171,172],"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":14,"_164":62},"connections",{"_162":62,"_163":62},"count","unfilledCount","emptyCount",{"_42":148,"_31":149,"_29":150,"_132":-5,"_40":41,"_39":151,"_134":58,"_37":213,"_13":62,"_33":153,"_35":-5,"_23":24,"_138":-5,"_174":214,"_26":215},{"_42":209,"_31":193,"_29":187,"_132":150,"_40":41,"_39":151,"_134":58,"_37":210,"_13":62,"_33":153,"_35":-5,"_23":24,"_138":-5,"_174":211,"_26":212},{"_42":202,"_31":203,"_29":204,"_132":187,"_40":41,"_39":151,"_134":24,"_37":205,"_13":62,"_33":34,"_35":206,"_23":24,"_138":-5,"_174":207,"_26":208},{"_42":194,"_31":195,"_29":196,"_132":187,"_40":41,"_39":197,"_134":24,"_37":198,"_13":62,"_33":34,"_35":199,"_23":24,"_138":-5,"_174":200,"_26":201},{"_42":184,"_31":185,"_29":186,"_132":187,"_40":41,"_39":188,"_134":24,"_37":189,"_13":62,"_33":34,"_35":190,"_23":24,"_138":-5,"_174":191,"_26":192},{"_42":180,"_31":32,"_29":30,"_132":150,"_40":41,"_39":14,"_134":58,"_37":181,"_13":62,"_33":34,"_35":36,"_23":24,"_138":-5,"_174":182,"_26":183},{"_42":141,"_31":142,"_29":143,"_132":-5,"_40":41,"_39":144,"_134":24,"_37":177,"_13":62,"_33":20,"_35":146,"_23":24,"_138":-5,"_174":178,"_26":179},{"_42":130,"_31":131,"_29":56,"_132":-5,"_40":41,"_39":133,"_134":24,"_37":173,"_13":62,"_33":136,"_35":137,"_23":24,"_138":139,"_174":175,"_26":176},["D",1788790391961],"children",[],[131],["D",1788790280169],[],[142],"65241ea7-2439-4cb9-87d4-5e1b995df305",["D",1788790431810],[],[149,32],"c5940555-4a75-4267-843f-3cf9e0fda18f","snapshot.ts","4a5f7e00-aac6-11f1-ba03-1607ee4eb77e","ea2bc655-318f-4a1f-8393-ec5c5fa3f307",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,193,185],"dash","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,193,195],"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 · v6