[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","umgroupkzcommits","name","uls-radar-reklamy","path","src/rest.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":38,"_66":67,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/umgroupkzcommits/uls-radar-reklamy/code/src/rest.ts","extension","id","65241ea7-2439-4cb9-87d4-5e1b995df305","rest.ts","fileId","5a2e66ac-aac6-11f1-9772-1607ee4eb77e","parentId","fce2ee45-dde0-44d8-a8ff-19af836c83de","branchId","bfd39142-8f6a-4087-8abb-f6da5f96742a","branchVersion",6,"latest",true,"createdAt",["D",1788790431810],"version",0,"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","deleted",false,"label",[47,24],"src","0d66920f-8240-4395-a231-63f86e6c3888",["D",1788790280130],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Радар рекламных лидов ULS: живая страница из Битрикс24","imageUrl","userId","ce244983-5dfc-4662-ad1a-ca34d2e798a0","pinnedFileId","426b02f0-aac6-11f1-9f81-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019fa853-4d22-71bf-b5fe-af55df9678e6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_58":59,"_102":103,"_104":44},"branch",{"_37":88,"_11":89,"_22":30,"_90":48,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",54,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","umgroupkz-commits","avatar","https://avatars.githubusercontent.com/u/279207781?v=4","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":44,"_146":44,"_147":44,"_148":34,"_149":-5,"_150":-7,"_151":-7,"_152":38,"_153":44,"_154":44,"_155":-5,"_156":44,"_157":44,"_158":44,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]