[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_183":184,"_185":186},"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",13,"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","portal.js","latestPath","fileId","b51c99aa-ac54-11f1-9375-1607ee4eb77e","name","fileType","content","// Логика входов восстановления, один раз на веб-стандартах (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

Log viewer

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

\nMaintenance key\n\n\n\n

nginx

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// Сравнение без ранней остановки: время не зависит от места расхождения.\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","createdAt",["D",1789027729691],"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",1789483278662],"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":178,"_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":179,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":180,"_83":181,"_85":182,"_87":25},"tree",[165,166,167],"files",[165,166,167],"counts",{"_155":62,"_156":152,"_157":62,"_158":159,"_160":161},"contents",[129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":147,"_32":148,"_30":149,"_133":-5,"_40":41,"_39":150,"_134":25,"_37":151,"_13":152,"_33":20,"_34":153,"_24":25,"_137":-5,"_27":154},{"_42":139,"_32":140,"_30":56,"_133":-5,"_40":41,"_39":141,"_134":25,"_37":142,"_13":143,"_33":144,"_34":145,"_24":25,"_137":-5,"_27":146},{"_42":132,"_32":28,"_30":31,"_133":-5,"_40":41,"_39":14,"_134":25,"_37":135,"_13":136,"_33":20,"_34":36,"_24":25,"_137":-5,"_27":138},"8f767562-a45e-49bb-9f19-d64f2e0b42b7","parentId","latest",["D",1789027729691],6,"label",[28],"41ec0850-7306-4345-a92b-c636d416d235","main.js",12,["D",1789027728671],3,"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, secretHash, bucketTake, NOT_FOUND_PAGE } from \"./portal.js\";\nimport { b2Authenticator, newestObjectNative } from \"./b2.js\";\n\n// Авторизация B2 с кешированием живёт на уровне модуля: площадка держит\n// модуль между запросами, и токен на 24 часа не приходится получать заново\n// на каждую выдачу капсулы. Кеш хранит и keyId, на котором токен получен:\n// после перевыпуска или разделения ключа B2 новый запрос приходит с другим\n// ключом, и замыкать прежний — значит авторизовываться старым ключом, пока\n// площадка не пересоздаст модуль.\nlet b2Authorize = null;\nlet b2KeyCached = null;\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// Счётчик попыток: токен-бакет, строка на маршрут (арифметика общая,\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 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; 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 if (b2Authorize === null || b2KeyCached !== env(\"B2_KEY_ID\")) {\n b2Authorize = b2Authenticator((url, init) => fetch(url, init), {\n keyId: env(\"B2_KEY_ID\"),\n applicationKey: env(\"B2_APPLICATION_KEY\"),\n });\n b2KeyCached = env(\"B2_KEY_ID\");\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",[140],"8b97c931-02fe-4719-ae7e-b82f4ac46a76","b2.js","b5b1c2f0-ac54-11f1-a82c-1607ee4eb77e",11,["D",1789021064444],1,"// Чтение свежайшей капсулы из 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",[148],"pulls","branches","forks","envVars",{"_162":141,"_164":62},"connections",{"_162":62,"_163":62},"count","unfilledCount","emptyCount",{"_42":147,"_32":148,"_30":149,"_133":-5,"_40":41,"_39":150,"_134":25,"_37":175,"_13":152,"_33":20,"_34":153,"_24":25,"_137":-5,"_169":176,"_27":177},{"_42":139,"_32":140,"_30":56,"_133":-5,"_40":41,"_39":141,"_134":25,"_37":172,"_13":143,"_33":144,"_34":145,"_24":25,"_137":-5,"_169":173,"_27":174},{"_42":132,"_32":28,"_30":31,"_133":-5,"_40":41,"_39":14,"_134":25,"_37":168,"_13":136,"_33":20,"_34":36,"_24":25,"_137":-5,"_169":170,"_27":171},["D",1789027729691],"children",[],[28],["D",1789027728671],[],[140],["D",1789021064444],[],[148],["D",1788961523162],["D",1789483278662],{"_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":216,"_217":218,"_219":220,"_221":25,"_222":25,"_223":25,"_224":58,"_225":-5,"_226":-7,"_227":-7,"_228":62,"_229":25,"_230":25,"_231":-5,"_232":25,"_233":25,"_234":25,"_235":-5},"ENV",{"_187":188,"_189":190,"_191":89,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v13