[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_184":185,"_186":187},"routes/_app.x.$handle.$name",{"_98":97,"_32":44,"_107":88,"_27":102,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":58,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",16,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":20,"_34":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":20,"_34":35},"deleted",false,"deletedHere","path","b2.js","latestPath","fileId","b5b1c2f0-ac54-11f1-a82c-1607ee4eb77e","name","fileType","content","// Чтение свежайшей капсулы из B2 нативным API, без зависимостей от площадки:\n// fetchImpl приходит снаружи, поэтому обход страниц проверяется тестами в\n// Node. S3-совместимый путь здесь жил до 2026-09-10 и требовал подписывающего\n// клиента; оба входа (Cloudflare Worker и Val Town) обходятся обычным fetch\n// по токену авторизации, поэтому S3-вариант удалён вместе со своими тестами.\n// Шиппер ноутбука ходит в B2 через rclone и этот файл не использует.\n\n// Токен авторизации B2 живёт 24 часа, а запрос капсулы случается несколько\n// раз в сутки: без кеширования каждый запрос платил бы лишним round trip на\n// b2_authorize_account. Запас в час — потому что точный срок B2 не\n// объявляет, а 401 по протухшему токену newestObjectNative переживает\n// повторной авторизацией.\nconst AUTH_TTL_MS = 23 * 60 * 60 * 1000;\n\n// Авторизация с кешированием. Возвращает функцию: account = await authorize()\n// — обычные запросы, authorize(true) — принудительная переавторизация после\n// 401. Держится в модуле обёртки (Val Town и Workers сохраняют состояние\n// модуля между запросами), поэтому токен один на серию запросов.\nexport function b2Authenticator(\n fetchImpl,\n { keyId, applicationKey },\n authUrl = \"https://api.backblazeb2.com\",\n) {\n let cached = null;\n let expiresAt = 0;\n return async (force = false) => {\n if (!force && cached !== null && Date.now() < expiresAt) return cached;\n const auth = await fetchImpl(`${authUrl}/b2api/v3/b2_authorize_account`, {\n headers: { authorization: `Basic ${btoa(`${keyId}:${applicationKey}`)}` },\n });\n if (!auth.ok) throw new Error(`B2 authorize: HTTP ${auth.status}`);\n const account = await auth.json();\n const api = account.apiInfo.storageApi;\n cached = {\n token: account.authorizationToken,\n apiUrl: api.apiUrl,\n downloadUrl: api.downloadUrl,\n // Ключ, привязанный к одному бакету, получает его идентификатор уже в\n // ответе авторизации; ключ пошире спрашивает его по имени.\n bucketId: api.bucketId ?? null,\n accountId: account.accountId,\n };\n expiresAt = Date.now() + AUTH_TTL_MS;\n return cached;\n };\n}\n\n// Имена объектов начинаются с даты, список приходит по возрастанию, поэтому\n// свежайший — лексикографический максимум. 401 на любом запросе означает\n// протухший кешированный токен и возвращается как признак повтора.\nasync function fetchNewest(fetchImpl, account, bucket, prefix) {\n const headers = { authorization: account.token, \"content-type\": \"application/json\" };\n\n let bucketId = account.bucketId;\n if (bucketId === null) {\n const list = await fetchImpl(`${account.apiUrl}/b2api/v3/b2_list_buckets`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ accountId: account.accountId, bucketName: bucket }),\n });\n if (list.status === 401) return { retry: true };\n if (!list.ok) throw new Error(`B2 list buckets: HTTP ${list.status}`);\n const buckets = await list.json();\n bucketId = buckets.buckets.find((one) => one.bucketName === bucket)?.bucketId ?? null;\n if (bucketId === null) throw new Error(`B2: бакет ${bucket} недоступен ключу`);\n }\n\n let newest = null;\n let startFileName = null;\n do {\n const page = await fetchImpl(`${account.apiUrl}/b2api/v3/b2_list_file_names`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ bucketId, prefix, maxFileCount: 1000, startFileName }),\n });\n if (page.status === 401) return { retry: true };\n if (!page.ok) throw new Error(`B2 list files: HTTP ${page.status}`);\n const body = await page.json();\n for (const file of body.files) {\n if (newest === null || file.fileName > newest) newest = file.fileName;\n }\n startFileName = body.nextFileName ?? null;\n } while (startFileName !== null);\n if (newest === null) return { value: null };\n\n const object = await fetchImpl(`${account.downloadUrl}/file/${bucket}/${newest}`, {\n headers: { authorization: account.token },\n });\n if (object.status === 401) return { retry: true };\n if (!object.ok) return { value: null };\n return {\n value: {\n body: object.body,\n contentType: \"application/octet-stream\",\n filename: newest.slice(newest.lastIndexOf(\"/\") + 1),\n },\n };\n}\n\nexport async function newestObjectNative(fetchImpl, { authorize, bucket, prefix }) {\n const first = await fetchNewest(fetchImpl, await authorize(), bucket, prefix);\n if (!first.retry) return first.value;\n const second = await fetchNewest(fetchImpl, await authorize(true), bucket, prefix);\n if (second.retry) throw new Error(\"B2: авторизация отклонена дважды\");\n return second.value;\n}\n","// Чтение свежайшей капсулы из B2 нативным API, без зависимостей от площадки:\n// fetchImpl приходит снаружи, поэтому обход страниц проверяется тестами в\n// Node. S3-совместимый путь здесь жил до 2026-09-10 и требовал подписывающего\n// клиента; оба входа (Cloudflare Worker и Val Town) обходятся обычным fetch\n// по токену авторизации, поэтому S3-вариант удалён вместе со своими тестами.\n// Шиппер ноутбука ходит в B2 через rclone и этот файл не использует.\n\n// Токен авторизации B2 живёт 24 часа, а запрос капсулы случается несколько\n// раз в сутки: без кеширования каждый запрос платил бы лишним round trip на\n// b2_authorize_account. Запас в час — потому что точный срок B2 не\n// объявляет, а 401 по протухшему токену newestObjectNative переживает\n// повторной авторизацией.\nconst AUTH_TTL_MS = 23 * 60 * 60 * 1000;\n\n// Авторизация с кешированием. Возвращает функцию: account = await authorize()\n// — обычные запросы, authorize(true) — принудительная переавторизация после\n// 401. Держится в модуле обёртки (Val Town и Workers сохраняют состояние\n// модуля между запросами), поэтому токен один на серию запросов.\nexport function b2Authenticator(\n fetchImpl,\n { keyId, applicationKey },\n authUrl = \"https://api.backblazeb2.com\",\n) {\n let cached = null;\n let expiresAt = 0;\n return async (force = false) => {\n if (!force && cached !== null && Date.now() < expiresAt) return cached;\n const auth = await fetchImpl(`${authUrl}/b2api/v3/b2_authorize_account`, {\n headers: { authorization: `Basic ${btoa(`${keyId}:${applicationKey}`)}` },\n });\n if (!auth.ok) throw new Error(`B2 authorize: HTTP ${auth.status}`);\n const account = await auth.json();\n const api = account.apiInfo.storageApi;\n cached = {\n token: account.authorizationToken,\n apiUrl: api.apiUrl,\n downloadUrl: api.downloadUrl,\n // Ключ, привязанный к одному бакету, получает его идентификатор уже в\n // ответе авторизации; ключ пошире спрашивает его по имени.\n bucketId: api.bucketId ?? null,\n accountId: account.accountId,\n };\n expiresAt = Date.now() + AUTH_TTL_MS;\n return cached;\n };\n}\n\n// Кеш authenticator'а, ключеванный keyId: один экземпляр на модуль обёртки\n// (Val Town и Workers сохраняют состояние модуля между запросами). После\n// перевыпуска или разделения ключа B2 следующий запрос приходит с другим\n// keyId, и authenticator пересоздаётся — иначе isolate продолжал бы\n// авторизовываться прежним ключом, пока площадка не пересоздаст модуль.\n// Ключом выбран только keyId намеренно: B2 при перевыпуске меняет его всегда,\n// а applicationKey без keyId не ходит, так что отдельная проверка второй\n// половины секрета ничего бы не добавила. getCredentials зовётся лениво, на\n// каждый запрос: секреты площадки в обёртках доступны только внутри\n// обработчика.\nexport function b2AuthenticatorCache(fetchImpl) {\n let cached = null;\n let keyCached = null;\n return (getCredentials) => {\n const { keyId, applicationKey } = getCredentials();\n if (cached === null || keyCached !== keyId) {\n cached = b2Authenticator(fetchImpl, { keyId, applicationKey });\n keyCached = keyId;\n }\n return cached;\n };\n}\n\n// Имена объектов начинаются с даты, список приходит по возрастанию, поэтому\n// свежайший — лексикографический максимум. 401 на любом запросе означает\n// протухший кешированный токен и возвращается как признак повтора.\nasync function fetchNewest(fetchImpl, account, bucket, prefix) {\n const headers = { authorization: account.token, \"content-type\": \"application/json\" };\n\n let bucketId = account.bucketId;\n if (bucketId === null) {\n const list = await fetchImpl(`${account.apiUrl}/b2api/v3/b2_list_buckets`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ accountId: account.accountId, bucketName: bucket }),\n });\n if (list.status === 401) return { retry: true };\n if (!list.ok) throw new Error(`B2 list buckets: HTTP ${list.status}`);\n const buckets = await list.json();\n bucketId = buckets.buckets.find((one) => one.bucketName === bucket)?.bucketId ?? null;\n if (bucketId === null) throw new Error(`B2: бакет ${bucket} недоступен ключу`);\n }\n\n let newest = null;\n let startFileName = null;\n do {\n const page = await fetchImpl(`${account.apiUrl}/b2api/v3/b2_list_file_names`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ bucketId, prefix, maxFileCount: 1000, startFileName }),\n });\n if (page.status === 401) return { retry: true };\n if (!page.ok) throw new Error(`B2 list files: HTTP ${page.status}`);\n const body = await page.json();\n for (const file of body.files) {\n if (newest === null || file.fileName > newest) newest = file.fileName;\n }\n startFileName = body.nextFileName ?? null;\n } while (startFileName !== null);\n if (newest === null) return { value: null };\n\n const object = await fetchImpl(`${account.downloadUrl}/file/${bucket}/${newest}`, {\n headers: { authorization: account.token },\n });\n if (object.status === 401) return { retry: true };\n if (!object.ok) return { value: null };\n return {\n value: {\n body: object.body,\n contentType: \"application/octet-stream\",\n filename: newest.slice(newest.lastIndexOf(\"/\") + 1),\n },\n };\n}\n\nexport async function newestObjectNative(fetchImpl, { authorize, bucket, prefix }) {\n const first = await fetchNewest(fetchImpl, await authorize(), bucket, prefix);\n if (!first.retry) return first.value;\n const second = await fetchNewest(fetchImpl, await authorize(true), bucket, prefix);\n if (second.retry) throw new Error(\"B2: авторизация отклонена дважды\");\n return second.value;\n}\n","createdAt",["D",1789041587918],"branchVersion","branchId","d6b13203-4fda-4a27-83f2-b458520d1b3a","id","7d69cc3c-d57f-45f6-ac4b-008f68039ca0","recovery-portal",["D",1788961523162],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Вход восстановления: первый лист и капсула по паролю","imageUrl","f4386386-2ee1-4a4a-baf7-4faa1548d197","pinnedFileId","b4dcdb44-ac54-11f1-894a-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a08663-da63-77c9-9747-c38e37bdf83f","tursoName","7d69cc3cd57f45f6ac4b008f68039ca0","tursoHostname","7d69cc3cd57f45f6ac4b008f68039ca0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789570231850],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":54,"_103":104,"_105":25},"branch",{"_13":14,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","iqidi","handle","displayName","I Q","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":179,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":180,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":181,"_83":182,"_85":183,"_87":25},"tree",[166,167,168],"files",[166,167,168],"counts",{"_154":62,"_155":156,"_157":62,"_158":159,"_160":161},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":150,"_32":28,"_30":31,"_134":-5,"_40":41,"_39":14,"_136":58,"_37":151,"_13":152,"_33":20,"_34":36,"_24":25,"_140":-5,"_27":153},{"_42":142,"_32":143,"_30":56,"_134":-5,"_40":41,"_39":144,"_136":58,"_37":145,"_13":146,"_33":147,"_34":148,"_24":25,"_140":-5,"_27":149},{"_42":131,"_32":132,"_30":133,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":137,"_13":138,"_33":20,"_34":139,"_24":25,"_140":-5,"_27":141},"afe60930-71b1-4b66-8299-25e1e2bba913","portal.js","b51c99aa-ac54-11f1-9375-1607ee4eb77e","parentId",15,"latest",["D",1789041587407],7,"// Логика входов восстановления, один раз на веб-стандартах (fetch, WebCrypto).\n// Площадка (Cloudflare Worker, Val Town) даёт обёртку из двух интерфейсов:\n// attempts.take(route) -> Promise<{ allowed, justExhausted }> — взять\n// попытку из счётчика маршрута; allowed ложно при исчерпанном лимите,\n// justExhausted истинно только у первого запроса сверх предела (по нему\n// шлётся единственное уведомление об упоре — дальше 429 молча, чтобы\n// поток запросов не топил канал уведомлений). У каждого маршрута свой\n// счётчик, поэтому тестовый путь не тратит бюджет настоящих паролей.\n// objects.get(name) -> Promise<{ body, contentType?, filename? } | null>\n// — выдаваемое содержимое: name \"sheet\" (первый лист) или \"capsule\"\n// (свежайшая капсула восстановления). null или пустое body — объекта\n// нет; пропавший секрет не должен выдаваться как пустой файл.\n// На сервере нет паролей — только проверочные строки (см. parseVerifier),\n// по одной на маршрут, из секретов площадки. Разбирает их сам portal.js и\n// только для того маршрута, который запрошен: обёртка, разбиравшая обе\n// строки на входе в обработчик, от одного неположенного секрета отвечала\n// пятисоткой на всё, включая страницу и первый лист.\n//\n// Маршруты: GET / — страница с формой; POST /access.log, /error.log,\n// /debug.log с JSON {key}.\n// Ответы: 200 с содержимым, 401 отказ, 429 исчерпан лимит, 503 у входа\n// не разобралась своя проверочная строка.\n// /debug.log всегда отказывает: живость проверяется заведомо неверным\n// паролем, и выдача на этом пути была бы дефектом, а не удачей. При этом он\n// выполняет настоящий вывод хеша параметрами sheet: проверка живости\n// должна мерить тот же дорогой путь, что настоящие маршруты (на Workers\n// у PBKDF2 есть предел итераций и бюджет CPU — обрыв там иначе невидим).\n//\n// Страница и пути притворяются просмотром логов веб-сервера: всё на\n// английском, без слов про восстановление, ключи и деньги. Случайный\n// прохожий, сканер или чужой агент не должны видеть повода тратить время\n// на подбор. Внутренние имена (sheet, capsule, test) остаются прежними: их\n// видит только владелец в журнале попыток и в секретах площадки.\n\n// Страница входа: единственный GET, который вход отвечает. Без неё маршруты\n// POST с JSON недостижимы из обычного браузера, а весь смысл входа — человек\n// без инструментов. Секретов на странице нет, пароль уходит только в POST\n// на этот же адрес.\n// Шрифт и ширина взяты со стандартной страницы nginx: она узнаваема, и вход\n// не должен выделяться ничем, включая вёрстку. Внутри шаблона нет ни\n// комментариев, ни кириллицы: всё, что там написано, читает посторонний.\nconst PAGE = `\n\n\n\n\nLog viewer\n\n

Log viewer

Read-only access to server logs. Enter the maintenance key and pick a file.

\nMaintenance key\n\n\n\n

nginx

\n\n`;\n\n// Страница 404 в точности той формы, какую печатает nginx с server_tokens off:\n// сканер сравнивает не только тело главной страницы, но и вид ошибок, а\n// самодельная строка «not found» выдала бы, что за адресом не веб-сервер.\nexport const NOT_FOUND_PAGE = `\n404 Not Found\n\n

404 Not Found

nginx\n\n\n`;\n\n// Путь маршрута и его внутреннее имя разведены: путь выглядит файлом лога и\n// виден постороннему, имя ведёт счётчик и журнал и видно только владельцу.\nconst ROUTES = {\n \"access.log\": { id: \"sheet\", passwordKey: \"sheet\", objectName: \"sheet\", alwaysDeny: false },\n \"error.log\": { id: \"capsule\", passwordKey: \"capsule\", objectName: \"capsule\", alwaysDeny: false },\n \"debug.log\": { id: \"test\", passwordKey: \"sheet\", objectName: null, alwaysDeny: true },\n};\n\nfunction hexToBytes(hex) {\n const bytes = new Uint8Array(hex.length / 2);\n for (let i = 0; i < bytes.length; i++) {\n bytes[i] = parseInt(hex.slice(i * 2, i * 2 + 2), 16);\n }\n return bytes;\n}\n\nfunction bytesToHex(bytes) {\n return Array.from(new Uint8Array(bytes), (b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\n// SHA-256 текста в hex. Им вход отвечает машине на запрос журнала: по хешу\n// первого листа публикация сверяет, что секрет площадки действительно\n// обновился, а не принял старое значение молча.\nexport async function sha256Hex(text) {\n const digest = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(text));\n return bytesToHex(digest);\n}\n\n// Хеш секрета площадки для сверки публикации: null, когда секрет не поставлен.\n// Хеш пустой строки был бы неотличим от чужого пустого значения, а null\n// говорит точно: на входе этого секрета нет вовсе.\nexport async function secretHash(value) {\n return value ? sha256Hex(value) : null;\n}\n\n// Бюджет попыток: токен-бакет, одна строка на маршрут в хранилище площадки.\n// Строка на попытку (схема 2026-09-10) делала таблицу безграничной: посторонний\n// поток запросов оставлял в окне N строк, и каждый следующий запрос сканировал\n// их все — порядка N² тарифицируемых чтений. Скользящее окно к тому же\n// превращало суточную блокировку в бессрочную: несколько запросов в сутки не\n// давали окну опустеть. Бакет даёт то же поведение при постоянном размере\n// таблицы, и доля бюджета (limit за windowMs) возвращается непрерывно, поэтому\n// владелец не заперт до конца потока.\n//\n// state: { tokens, at, exhausted } из хранилища или null у нового маршрута.\n// Возвращает решение take из контракта выше и next — состояние для записи.\n// justExhausted истинно только у первого отказа после исчерпания: уведомление\n// об упоре приходит один раз, а не на каждый запрос потока.\nexport const ATTEMPT_WINDOW_MS = 24 * 60 * 60 * 1000;\n\nexport function bucketTake(state, { limit, now, windowMs = ATTEMPT_WINDOW_MS }) {\n const tokens =\n state === null\n ? limit\n : Math.min(limit, state.tokens + Math.max(0, now - state.at) * (limit / windowMs));\n if (tokens >= 1) {\n return {\n allowed: true,\n justExhausted: false,\n next: { tokens: tokens - 1, at: now, exhausted: false },\n };\n }\n return {\n allowed: false,\n justExhausted: !(state !== null && state.exhausted),\n next: { tokens, at: now, exhausted: true },\n };\n}\n\n// PBKDF2-SHA256 -> hex. Этим же вызовом владелец готовит хеш для секрета\n// площадки: node -e 'import(\"./portal.js\").then(...)'.\nexport async function derivePasswordHash(password, saltHex, iterations) {\n const key = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(password),\n \"PBKDF2\",\n false,\n [\"deriveBits\"],\n );\n const bits = await crypto.subtle.deriveBits(\n { name: \"PBKDF2\", hash: \"SHA-256\", salt: hexToBytes(saltHex), iterations },\n key,\n 256,\n );\n return bytesToHex(bits);\n}\n\n// Проверочная строка пароля: \"<итерации>:<соль hex>:<хеш hex>\". Соль, число\n// итераций и хеш ходят одним секретом площадки, потому что порознь они молча\n// разъезжаются: хеш, посчитанный с одним числом итераций, и площадка,\n// настроенная на другое, дают вечный отказ без единой ошибки. Строку собирает\n// scripts/first-sheet-render.sh из пароля в sops.\n// Регистр hex приводится здесь и только здесь: строку может выставить и\n// человек руками, а сравнение хешей идёт побайтно.\nexport function parseVerifier(text) {\n const match = /^([0-9]+):([0-9a-fA-F]+):([0-9a-fA-F]+)$/.exec(String(text ?? \"\").trim());\n if (match === null) throw new Error(\"проверочная строка пароля неразборчива\");\n return {\n iterations: Number(match[1]),\n salt: match[2].toLowerCase(),\n hash: match[3].toLowerCase(),\n };\n}\n\n// Сравнение без ранней остановки: время не зависит от места расхождения.\n// Им сравниваются и хеши паролей, и токен журнала /events в обёртках:\n// принцип один — время ответа не подсказывает, насколько секрет совпал.\nexport function equalSecret(a, b) {\n if (typeof a !== \"string\" || typeof b !== \"string\") return false;\n let diff = a.length ^ b.length;\n for (let i = 0; i < a.length && i < b.length; i++) {\n diff |= a.charCodeAt(i) ^ b.charCodeAt(i);\n }\n return diff === 0;\n}\n\n// Уведомление владельцу по webhook: одна реализация на обе обёртки.\n// Адрес приходит из секрета площадки; fetchImpl подменяется в тестах.\n// Срок жизни запроса ограничен: канал уведомлений бывает не столько недоступен,\n// сколько молчалив (ntfy.sh 8 сентября 2026 принял одно сообщение из десятка),\n// а без предела молчание тянуло бы ответ владельцу до предела площадки.\nexport function webhookNotify(url, fetchImpl = fetch, timeoutMs = 2000) {\n return async (event) => {\n await fetchImpl(url, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ ...event, time: new Date().toISOString() }),\n signal: AbortSignal.timeout(timeoutMs),\n });\n };\n}\n\n// verifiers: { sheet, capsule } — проверочные строки как есть, из секретов\n// площадки; разбираются по одной, в момент запроса своего маршрута.\nexport function createPortal({ verifiers, attempts, objects, notify }) {\n async function tell(event) {\n // Недоступный webhook не должен превращать верный пароль в отказ:\n // человек в аварии важнее уведомления.\n try {\n await notify(event);\n } catch {\n /* канал уведомлений лежит; ответ уже решён */\n }\n }\n\n async function handle(request) {\n const { pathname } = new URL(request.url);\n if (request.method === \"GET\" && pathname === \"/\") {\n return new Response(PAGE, {\n status: 200,\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n }\n const path = pathname.slice(1);\n // hasOwn, не `in`: /toString и прочая цепочка прототипов — не маршруты.\n if (request.method !== \"POST\" || !Object.hasOwn(ROUTES, path)) {\n return new Response(NOT_FOUND_PAGE, {\n status: 404,\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n }\n const { id: route, passwordKey, objectName, alwaysDeny } = ROUTES[path];\n\n let password;\n try {\n ({ key: password } = await request.json());\n } catch {\n password = undefined;\n }\n if (typeof password !== \"string\" || password === \"\") {\n // Пароль не предъявлен — это не попытка подбора: бюджет не тратится,\n // уведомление не шлётся.\n return new Response(\"no entries\", { status: 401 });\n }\n\n const { allowed, justExhausted } = await attempts.take(route);\n if (!allowed) {\n if (justExhausted) await tell({ route, outcome: \"limit\" });\n return new Response(\"rate limited\", { status: 429 });\n }\n\n // Разбирается только строка запрошенного маршрута, и её негодность —\n // ответ 503 этому маршруту, а не пятисотка всему входу: иначе один\n // неположенный секрет закрывал бы и страницу, и первый лист.\n let salt, hash, iterations;\n try {\n ({ salt, hash, iterations } = parseVerifier(verifiers[passwordKey]));\n } catch {\n await tell({ route, outcome: \"verifier-broken\" });\n return new Response(\"unavailable\", { status: 503 });\n }\n\n const matches = equalSecret(await derivePasswordHash(password, salt, iterations), hash);\n if (alwaysDeny || !matches) {\n await tell({ route, outcome: \"denied\" });\n return new Response(\"no entries\", { status: 401 });\n }\n\n const object = await objects.get(objectName);\n if (!object || object.body == null || object.body === \"\") {\n await tell({ route, outcome: \"object-missing\" });\n return new Response(\"unavailable\", { status: 500 });\n }\n await tell({ route, outcome: \"issued\" });\n const headers = {\n \"content-type\": object.contentType ?? \"application/octet-stream\",\n };\n if (object.filename) {\n const safe = object.filename.replace(/[\"\\\\\\r\\n]/g, \"_\");\n headers[\"content-disposition\"] = `attachment; filename=\"${safe}\"`;\n }\n return new Response(object.body, { status: 200, headers });\n }\n\n return { fetch: handle };\n}\n","label",[132],"80cf2826-bb59-4b34-90b8-8798e64e60cb","main.js",14,["D",1789041586222],4,"http","// Обёртка второго входа (Val Town, HTTP val): счётчик попыток и журнал в\n// SQLite площадки, капсула из B2 (свежайший объект под RECOVERY_PREFIX — его\n// кладёт scripts/cloud-backup-ship.sh), первый лист из переменной окружения.\n// Логика паролей и маршрутов целиком в portal.js, работа с B2 — в b2.js:\n// вал состоит из этого файла и их обоих рядом.\n//\n// Второй вход стоит у другой компании намеренно: беда у одной площадки не\n// должна отрезать оба пути к капсуле. Хранилище у него тоже своё — B2 против\n// R2 у первого.\n//\n// Free-план Val Town проверен 2026-09-09 (https://www.val.town/limits):\n// таймаут запуска 1 мин, SQLite, переменные окружения и исходящий fetch есть —\n// хватает с запасом, капсула весит около двух килобайт. Приватных валов на\n// free-плане нет, поэтому секретов в коде не бывает: все они в переменных.\n//\n// Переменные окружения площадки: SHEET_VERIFIER, CAPSULE_VERIFIER,\n// RECOVERY_PREFIX, EVENTS_TOKEN и FIRST_SHEET кладёт ночной\n// scripts/first-sheet-render.sh; руками один раз ставятся NOTIFY_WEBHOOK,\n// B2_KEY_ID, B2_APPLICATION_KEY, B2_BUCKET, LIMIT_SHEET, LIMIT_CAPSULE,\n// LIMIT_TEST. B2 опрашивается парой b2-restore-* (ключ у бакета пока один,\n// docs/deploy.md, раздел «Ключ B2»).\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport {\n createPortal,\n webhookNotify,\n secretHash,\n bucketTake,\n equalSecret,\n NOT_FOUND_PAGE,\n} from \"./portal.js\";\nimport { b2AuthenticatorCache, newestObjectNative } from \"./b2.js\";\n\n// Авторизация B2 с кешированием живёт на уровне модуля: площадка держит\n// модуль между запросами, и токен на 24 часа не приходится получать заново\n// на каждую выдачу капсулы. Кеш пересоздаётся при смене keyId — после\n// перевыпуска ключа модуль не авторизовывался бы прежним (общая реализация\n// и её обоснование — b2AuthenticatorCache в b2.js).\nconst b2Cached = b2AuthenticatorCache((url, init) => fetch(url, init));\n\nconst env = (name) => Deno.env.get(name);\n\n// Сколько событий вход помнит: машина забирает их раз в час, запас на\n// несколько суток молчания.\nconst EVENTS_KEPT = 200;\n\nasync function ensureTables() {\n await sqlite.execute({\n sql: \"CREATE TABLE IF NOT EXISTS recovery_portal_attempt_bucket (route TEXT PRIMARY KEY, tokens REAL, at INTEGER, exhausted INTEGER)\",\n args: [],\n });\n await sqlite.execute({\n sql: \"CREATE TABLE IF NOT EXISTS recovery_portal_events (id INTEGER PRIMARY KEY AUTOINCREMENT, at TEXT, route TEXT, outcome TEXT)\",\n args: [],\n });\n // Таблицы прошлых схем удалены однократно при переходе на бакет\n // 2026-09-10: DROP на каждый запрос гонял бы мусор в удалённый SQLite вечно.\n for (const legacy of [\"recovery_portal_attempts\", \"recovery_portal_attempt_window\"]) {\n const found = await sqlite.execute({\n sql: \"SELECT name FROM sqlite_master WHERE type='table' AND name = ?\",\n args: [legacy],\n });\n if (found.rows.length > 0) {\n await sqlite.execute({ sql: `DROP TABLE ${legacy}`, args: [] });\n }\n }\n}\n\n// SQLite площадки удалённый, и ensureTables стоила четыре round trip на\n// каждый запрос. Модуль площадки переживает запросы (на этом же держится\n// кеш B2), поэтому подготовка таблиц идёт один раз на время жизни модуля.\n// После пересоздания модуля она повторится — таблицы к тому времени уже\n// стоят, и CREATE IF NOT EXISTS ничего не меняет.\nlet tablesReady = null;\n\n// Счётчик попыток: токен-бакет, строка на маршрут (арифметика общая,\n// bucketTake в portal.js). Имя таблицы с префиксом, потому что SQLite\n// площадки общий на весь аккаунт. Контракт take описан в portal.js:\n// justExhausted — только у первого запроса сверх предела.\nasync function takeAttempt(route, limit) {\n const now = Date.now();\n const result = await sqlite.execute({\n sql: \"SELECT tokens, at, exhausted FROM recovery_portal_attempt_bucket WHERE route = ?\",\n args: [route],\n });\n const state =\n result.rows.length === 0\n ? null\n : {\n tokens: Number(result.rows[0][0]),\n at: Number(result.rows[0][1]),\n exhausted: Boolean(result.rows[0][2]),\n };\n const { allowed, justExhausted, next } = bucketTake(state, { limit, now });\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO recovery_portal_attempt_bucket (route, tokens, at, exhausted) VALUES (?, ?, ?, ?)\",\n args: [route, next.tokens, next.at, next.exhausted ? 1 : 0],\n });\n return { allowed, justExhausted };\n}\n\n// Журнал попыток: webhook доходит не всегда, поэтому машина забирает события\n// сама (scripts/portal-attempts.sh). Хранится последние EVENTS_KEPT штук.\nasync function recordEvent(event) {\n await sqlite.execute({\n sql: \"INSERT INTO recovery_portal_events (at, route, outcome) VALUES (?, ?, ?)\",\n args: [event.time, event.route, event.outcome],\n });\n await sqlite.execute({\n sql: \"DELETE FROM recovery_portal_events WHERE id <= (SELECT MAX(id) FROM recovery_portal_events) - ?\",\n args: [EVENTS_KEPT],\n });\n}\n\nasync function eventsSince(id) {\n const result = await sqlite.execute({\n sql: \"SELECT id, at, route, outcome FROM recovery_portal_events WHERE id > ? ORDER BY id\",\n args: [id],\n });\n return result.rows.map(([eventId, at, route, outcome]) => ({\n id: Number(eventId),\n at,\n route,\n outcome,\n }));\n}\n\n// Самый старый id в журнале. Машина держит отметку о прочитанном, и если\n// отметка меньше minId - 1, события между ними стёрты ротацией: без этого\n// признака «журнал обрезан» неотличим от «событий не было».\nasync function eventsMinId() {\n const result = await sqlite.execute({\n sql: \"SELECT MIN(id) FROM recovery_portal_events\",\n args: [],\n });\n const min = result.rows[0][0];\n return min === null ? null : Number(min);\n}\n\nexport default async function (request) {\n tablesReady ??= ensureTables();\n await tablesReady;\n const limits = {\n sheet: Number(env(\"LIMIT_SHEET\") ?? 100),\n capsule: Number(env(\"LIMIT_CAPSULE\") ?? 100),\n test: Number(env(\"LIMIT_TEST\") ?? 1000),\n };\n\n // Журнал отдаётся по токену и не входит в portal.js: там логика паролей,\n // общая для площадок, а хранилище журнала у каждой своё. Несовпавший или\n // непоставленный токен отвечает так же, как несуществующий путь.\n const { pathname } = new URL(request.url);\n if (request.method === \"POST\" && pathname === \"/events\") {\n const body = await request.json().catch(() => ({}));\n // Токен сравнивается тем же сравнением без ранней остановки, что и\n // хеши паролей: время ответа не подсказывает, насколько секрет совпал.\n if (!env(\"EVENTS_TOKEN\") || !equalSecret(String(body.token ?? \"\"), env(\"EVENTS_TOKEN\"))) {\n return new Response(NOT_FOUND_PAGE, {\n status: 404,\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n }\n // minId — признак обрезки журнала для portal-attempts.sh; hashes —\n // сверка ночной публикации: first-sheet-render.sh сравнивает хеши всех\n // значений, которые только что отправил переменными. Один лист сверялся\n // до 2026-09-10, и смена пароля без смены текста листа оставалась\n // невидимой: площадка могла принять PUT проверочной строки с 200, но\n // оставить старое значение.\n return Response.json({\n events: await eventsSince(Number(body.since ?? 0)),\n minId: await eventsMinId(),\n hashes: {\n firstSheet: await secretHash(env(\"FIRST_SHEET\")),\n sheetVerifier: await secretHash(env(\"SHEET_VERIFIER\")),\n capsuleVerifier: await secretHash(env(\"CAPSULE_VERIFIER\")),\n prefix: await secretHash(env(\"RECOVERY_PREFIX\")),\n },\n });\n }\n\n const webhook = webhookNotify(env(\"NOTIFY_WEBHOOK\"));\n const portal = createPortal({\n verifiers: { sheet: env(\"SHEET_VERIFIER\"), capsule: env(\"CAPSULE_VERIFIER\") },\n attempts: { take: (route) => takeAttempt(route, limits[route]) },\n objects: {\n get: async (name) => {\n if (name === \"sheet\") {\n // Непоставленный секрет — это отсутствующий объект, а не\n // успешная выдача пустого файла.\n if (!env(\"FIRST_SHEET\")) return null;\n return { body: env(\"FIRST_SHEET\"), contentType: \"text/plain; charset=utf-8\" };\n }\n // Нативный API B2, а не S3: та же работа без пакета для подписи\n // запросов, и код совпадает с первым входом.\n return newestObjectNative((url, init) => fetch(url, init), {\n authorize: b2Cached(() => ({\n keyId: env(\"B2_KEY_ID\"),\n applicationKey: env(\"B2_APPLICATION_KEY\"),\n })),\n bucket: env(\"B2_BUCKET\"),\n prefix: env(\"RECOVERY_PREFIX\"),\n });\n },\n },\n // Запись в журнал идёт до ответа: у площадки нет waitUntil, а событие,\n // потерянное ради скорости, — это как раз то, чего журнал не должен\n // допускать. Webhook ответа не ждёт вовсе: он лишь быстрый путь, надёжный\n // путь уже записан, а молчащий канал иначе задерживал бы выдачу капсулы\n // на всё время своего молчания.\n notify: async (event) => {\n const stamped = { ...event, time: new Date().toISOString() };\n await recordEvent(stamped).catch(() => {});\n void webhook(event).catch(() => {});\n },\n });\n return portal.fetch(request);\n}\n",[143],"ff6e0184-e670-4f25-b44c-631c83ebf11f",["D",1789041587918],2,[28],"pulls","branches",1,"forks","envVars",{"_162":164,"_165":62},"connections",{"_162":62,"_163":62},"count","unfilledCount",12,"emptyCount",{"_42":150,"_32":28,"_30":31,"_134":-5,"_40":41,"_39":14,"_136":58,"_37":176,"_13":152,"_33":20,"_34":36,"_24":25,"_140":-5,"_170":177,"_27":178},{"_42":142,"_32":143,"_30":56,"_134":-5,"_40":41,"_39":144,"_136":58,"_37":173,"_13":146,"_33":147,"_34":148,"_24":25,"_140":-5,"_170":174,"_27":175},{"_42":131,"_32":132,"_30":133,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":169,"_13":138,"_33":20,"_34":139,"_24":25,"_140":-5,"_170":171,"_27":172},["D",1789041587407],"children",[],[132],["D",1789041586222],[],[143],["D",1789041587918],[],[28],["D",1788961523162],["D",1789570231850],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":54,"_103":104,"_105":25},{"_13":14,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_81":-5,"_125":217,"_218":219,"_220":221,"_222":25,"_223":25,"_224":25,"_225":58,"_226":-5,"_227":-7,"_228":-7,"_229":62,"_230":25,"_231":25,"_232":-5,"_233":25,"_234":25,"_235":25,"_236":-5},"ENV",{"_188":189,"_190":191,"_192":88,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v16