[{"_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",{"_99":98,"_32":44,"_108":89,"_27":103,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":58,"_125":-5,"_126":-5,"_127":128},"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",11,"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 двумя способами, оба без зависимостей от\n// площадки: fetchImpl приходит снаружи, поэтому обход страниц проверяется\n// тестами в Node.\n//\n// S3-совместимый путь (newestObject) требует подписывающего клиента и живёт\n// ради Val Town, где такой клиент есть в npm. Нативный путь\n// (newestObjectNative) обходится обычным fetch и нужен второму входу на\n// Cloudflare: класть туда пакет ради подписи S3 — лишняя зависимость там, где\n// B2 отдаёт то же самое по токену.\n\n// Регион зашит в S3-адрес B2: s3.<регион>.backblazeb2.com.\nexport function regionFromEndpoint(endpoint) {\n return new URL(endpoint).hostname.split(\".\")[1];\n}\n\n// Свежайший объект под префиксом: имена начинаются с метки времени,\n// поэтому лексикографический максимум ключа — это самый новый объект.\nexport async function newestObject(fetchImpl, { endpoint, bucket, prefix }) {\n const base = `${endpoint}/${bucket}`;\n let newest = null;\n let token;\n do {\n const url = new URL(base);\n url.searchParams.set(\"list-type\", \"2\");\n url.searchParams.set(\"prefix\", prefix);\n if (token) url.searchParams.set(\"continuation-token\", token);\n const page = await fetchImpl(url.toString());\n if (!page.ok) throw new Error(`B2 list: HTTP ${page.status}`);\n const xml = await page.text();\n for (const [, key] of xml.matchAll(/([^<]+)<\\/Key>/g)) {\n if (newest === null || key > newest) newest = key;\n }\n token = /true<\\/IsTruncated>/.test(xml)\n ? xml.match(/([^<]+)<\\/NextContinuationToken>/)?.[1]\n : undefined;\n } while (token);\n if (newest === null) return null;\n const object = await fetchImpl(`${base}/${newest}`);\n if (!object.ok) return null;\n return {\n body: object.body,\n contentType: \"application/octet-stream\",\n filename: newest.slice(newest.lastIndexOf(\"/\") + 1),\n };\n}\n\n// Нативный API B2: пароль меняется на токен, дальше обычные запросы. Ключ,\n// привязанный к одному бакету, получает его идентификатор уже в ответе\n// авторизации; ключ пошире спрашивает его по имени. Имена объектов начинаются\n// с даты, список приходит по возрастанию, поэтому свежайший — последний.\nexport async function newestObjectNative(\n fetchImpl,\n { keyId, applicationKey, bucket, prefix },\n authUrl = \"https://api.backblazeb2.com\",\n) {\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 const token = account.authorizationToken;\n const headers = { authorization: token, \"content-type\": \"application/json\" };\n\n let bucketId = api.bucketId ?? null;\n if (bucketId === null) {\n const list = await fetchImpl(`${api.apiUrl}/b2api/v3/b2_list_buckets`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ accountId: account.accountId, bucketName: bucket }),\n });\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(`${api.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.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 null;\n\n const object = await fetchImpl(`${api.downloadUrl}/file/${bucket}/${newest}`, {\n headers: { authorization: token },\n });\n if (!object.ok) return null;\n return {\n body: object.body,\n contentType: \"application/octet-stream\",\n filename: newest.slice(newest.lastIndexOf(\"/\") + 1),\n };\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// Имена объектов начинаются с даты, список приходит по возрастанию, поэтому\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",1789021064444],"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",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"isOwned",16,"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",{"_155":62,"_156":153,"_157":62,"_158":159,"_160":161},"contents",[129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":151,"_32":28,"_30":31,"_135":-5,"_40":41,"_39":14,"_137":25,"_37":152,"_13":153,"_33":20,"_34":36,"_24":25,"_141":-5,"_27":154},{"_42":143,"_32":144,"_30":56,"_135":-5,"_40":41,"_39":145,"_137":25,"_37":146,"_13":147,"_33":148,"_34":149,"_24":25,"_141":-5,"_27":150},{"_42":132,"_32":133,"_30":134,"_135":-5,"_40":41,"_39":136,"_137":25,"_37":138,"_13":139,"_33":20,"_34":140,"_24":25,"_141":-5,"_27":142},"4870492a-e9f6-416c-a061-d28d00e71b50","portal.js","b51c99aa-ac54-11f1-9375-1607ee4eb77e","parentId",10,"latest",["D",1789021064002],5,"// Логика входов восстановления, один раз на веб-стандартах (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// 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// Сравнение без ранней остановки: время не зависит от места расхождения.\nfunction equalHex(a, b) {\n if (a.length !== b.length) return false;\n let diff = 0;\n for (let i = 0; i < a.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 = equalHex(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",[133],"8fd6c44a-ee17-4b98-aed0-60ae5ce59166","main.js",9,["D",1789021063562],2,"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 { createPortal, webhookNotify, sha256Hex, NOT_FOUND_PAGE } from \"./portal.js\";\nimport { b2Authenticator, newestObjectNative } from \"./b2.js\";\n\n// Авторизация B2 с кешированием живёт на уровне модуля: площадка держит\n// модуль между запросами, и токен на 24 часа не приходится получать заново\n// на каждую выдачу капсулы.\nlet b2Authorize = null;\n\nconst env = (name) => Deno.env.get(name);\n\n// Сколько событий вход помнит: машина забирает их раз в час, запас на\n// несколько суток молчания.\nconst EVENTS_KEPT = 200;\n\n// Окно подсчёта попыток: скользящие 24 часа вместо календарных суток UTC.\n// Суточный счётчик обнулялся в 00:00 UTC, и посторонний, знающий адрес, мог\n// выесть бюджет прямо перед полуночью и оставить владельца без входа на\n// считанные минуты до сброса, а заодно пройти две суточные нормы подряд.\nconst ATTEMPT_WINDOW_MS = 24 * 60 * 60 * 1000;\n\nasync function ensureTables() {\n // SQLite площадки переживает деплой вала, поэтому старая таблица суточных\n // счётчиков удаляется явно: схема сменилась 2026-09-10.\n await sqlite.execute({ sql: \"DROP TABLE IF EXISTS recovery_portal_attempts\", args: [] });\n await sqlite.execute({\n sql: \"CREATE TABLE IF NOT EXISTS recovery_portal_attempt_window (id INTEGER PRIMARY KEY AUTOINCREMENT, at INTEGER, route TEXT)\",\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\n// Счётчик попыток: строка на попытку, окно скользящее. Имя таблицы с\n// префиксом, потому что SQLite площадки общий на весь аккаунт. Контракт take\n// описан в portal.js: justExhausted — только у первого запроса сверх предела.\nasync function takeAttempt(route, limit) {\n const now = Date.now();\n await sqlite.execute({\n sql: \"DELETE FROM recovery_portal_attempt_window WHERE at <= ?\",\n args: [now - ATTEMPT_WINDOW_MS],\n });\n await sqlite.execute({\n sql: \"INSERT INTO recovery_portal_attempt_window (at, route) VALUES (?, ?)\",\n args: [now, route],\n });\n const result = await sqlite.execute({\n sql: \"SELECT COUNT(*) FROM recovery_portal_attempt_window WHERE route = ?\",\n args: [route],\n });\n const count = Number(result.rows[0][0]);\n return { allowed: count <= limit, justExhausted: count === limit + 1 };\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 await ensureTables();\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 if (!env(\"EVENTS_TOKEN\") || 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; sheetHash —\n // сверка ночной публикации: first-sheet-render.sh сравнивает его с\n // хешем листа, который только что отправил секретом.\n return Response.json({\n events: await eventsSince(Number(body.since ?? 0)),\n minId: await eventsMinId(),\n sheetHash: await sha256Hex(env(\"FIRST_SHEET\") ?? \"\"),\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 if (b2Authorize === null) {\n b2Authorize = b2Authenticator((url, init) => fetch(url, init), {\n keyId: env(\"B2_KEY_ID\"),\n applicationKey: env(\"B2_APPLICATION_KEY\"),\n });\n }\n return newestObjectNative((url, init) => fetch(url, init), {\n authorize: b2Authorize,\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",[144],"8b97c931-02fe-4719-ae7e-b82f4ac46a76",["D",1789021064444],1,[28],"pulls","branches","forks","envVars",{"_162":164,"_165":62},"connections",{"_162":62,"_163":62},"count","unfilledCount",12,"emptyCount",{"_42":151,"_32":28,"_30":31,"_135":-5,"_40":41,"_39":14,"_137":25,"_37":176,"_13":153,"_33":20,"_34":36,"_24":25,"_141":-5,"_170":177,"_27":178},{"_42":143,"_32":144,"_30":56,"_135":-5,"_40":41,"_39":145,"_137":25,"_37":173,"_13":147,"_33":148,"_34":149,"_24":25,"_141":-5,"_170":174,"_27":175},{"_42":132,"_32":133,"_30":134,"_135":-5,"_40":41,"_39":136,"_137":25,"_37":169,"_13":139,"_33":20,"_34":140,"_24":25,"_141":-5,"_170":171,"_27":172},["D",1789021064002],"children",[],[133],["D",1789021063562],[],[144],["D",1789021064444],[],[28],["D",1788961523162],["D",1789570231850],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":25},{"_13":88,"_32":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_126":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":89,"_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 · v11