Video AI Upscaler

\n \n

\n\n

Апскейл видео
нейросетью

Real-ESRGAN увеличивает разрешение и вытягивает детали. Загрузи короткий клип или дай\n прямую ссылку — обработка идёт на GPU в облаке.

\n\n

1. Источник видео

Файл до 8 МБ можно закинуть прямо здесь. Для больших видео используй ссылку.

\n\n

\n \n 🎬\n

Перетащи видео сюда

или нажми, чтобы выбрать файл · mp4, mov, webm · до 8 МБ

\n\n

или

\n\n \n Прямая ссылка на видео\n \n \n

\n\n

2. Модель улучшения

Чем выше масштаб, тем дольше и дороже рендер.

\n\n

\n \n \n

\n\n \n Вариант модели\n \n \n\n \n Пароль админа (снимает лимит 2 задачи в час, необязательно)\n \n \n\n \n\n

\n Отправка на обработку…\n 0%\n

\n\n

\n Скачать улучшенное видео\n

\n\n

История

Последние задачи с этого браузера.

Пока ничего не обработано.

\n\n \n

\n \n\n",[165],"f26319f4-281a-4935-bf3b-ac09d0611334","favicon.svg","019fb5b3-559b-704e-aa6d-22dea24d265f",["D",1785459856696],"",[173],"f6af11e2-6e78-4230-b469-780cb0167082","app.js","b8c2f38a-8c7c-11f1-a3f1-1607ee4eb77e",10,["D",1785460272868],"script","/* Клиент главной страницы. Чистый JS, без фреймворков. */\n\nconst $ = (id) => document.getElementById(id);\nconst drop = $(\"drop\"), file = $(\"file\"), url = $(\"url\"), model = $(\"model\"), pw = $(\"pw\");\nconst go = $(\"go\"), prog = $(\"prog\"), fill = $(\"fill\"), pct = $(\"pct\"), stage = $(\"stage\");\nconst msg = $(\"msg\"), result = $(\"result\"), video = $(\"video\"), dl = $(\"dl\"), jobsBox = $(\"jobs\");\n\nlet scale = 2;\nlet poll = null;\nlet fakeTimer = null;\n\n/* ── вспомогательное ── */\n\nfunction say(text, kind = \"info\") {\n msg.textContent = text;\n msg.className = \"msg on \" + kind;\n}\n\nfunction hideSay() {\n msg.className = \"msg\";\n}\n\nfunction setProgress(p, label) {\n fill.style.width = Math.min(100, Math.max(0, p)) + \"%\";\n pct.textContent = Math.round(p) + \"%\";\n if (label) stage.textContent = label;\n}\n\nfunction showProgress(on) {\n prog.className = on ? \"prog on\" : \"prog\";\n}\n\nfunction busy(on) {\n go.disabled = on;\n go.textContent = on ? \"Обрабатываю…\" : \"Улучшить видео\";\n}\n\n/**\n * Реального процента у Replicate нет, поэтому ползём к 90% по времени,\n * а до 100% доводим по факту готовности.\n */\nfunction startFakeProgress() {\n let p = 4;\n clearInterval(fakeTimer);\n fakeTimer = setInterval(() => {\n p += p < 45 ? 1.1 : p < 75 ? 0.5 : 0.16;\n if (p > 90) p = 90;\n setProgress(p);\n }, 900);\n}\n\nfunction stopFakeProgress() {\n clearInterval(fakeTimer);\n fakeTimer = null;\n}\n\n/* ── выбор масштаба ── */\n\ndocument.querySelectorAll(\".scale\").forEach((btn) => {\n btn.addEventListener(\"click\", () => {\n document.querySelectorAll(\".scale\").forEach((b) => b.classList.remove(\"on\"));\n btn.classList.add(\"on\");\n scale = Number(btn.dataset.scale);\n });\n});\n\n/* ── drag & drop и выбор файла ── */\n\ndrop.addEventListener(\"click\", () => file.click());\n\n[\"dragenter\", \"dragover\"].forEach((ev) =>\n drop.addEventListener(ev, (e) => {\n e.preventDefault();\n drop.classList.add(\"over\");\n })\n);\n\n[\"dragleave\", \"drop\"].forEach((ev) =>\n drop.addEventListener(ev, (e) => {\n e.preventDefault();\n drop.classList.remove(\"over\");\n })\n);\n\ndrop.addEventListener(\"drop\", (e) => {\n const f = e.dataTransfer?.files?.[0];\n if (f) upload(f);\n});\n\nfile.addEventListener(\"change\", () => {\n if (file.files?.[0]) upload(file.files[0]);\n});\n\nasync function upload(f) {\n if (!f.type.startsWith(\"video/\")) return say(\"Это не видеофайл.\", \"err\");\n hideSay();\n drop.querySelector(\".big\").textContent = \"Загружаю \" + f.name + \"…\";\n const fd = new FormData();\n fd.append(\"file\", f);\n try {\n const res = await fetch(\"/api/upload\", { method: \"POST\", body: fd });\n const data = await res.json();\n if (!res.ok) throw new Error(data.error || \"Не удалось загрузить файл\");\n url.value = data.url;\n drop.querySelector(\".big\").textContent = \"✓ \" + f.name;\n drop.querySelector(\".small\").textContent = (data.size / 1048576).toFixed(1)\n + \" МБ загружено — можно запускать обработку\";\n say(\"Файл загружен. Выбери масштаб и нажми «Улучшить видео».\", \"ok\");\n } catch (err) {\n drop.querySelector(\".big\").textContent = \"Перетащи видео сюда\";\n say(err.message, \"err\");\n }\n}\n\n/* ── запуск обработки ── */\n\ngo.addEventListener(\"click\", async () => {\n const src = url.value.trim();\n if (!src) return say(\"Сначала загрузи файл или вставь ссылку на видео.\", \"err\");\n\n hideSay();\n result.className = \"result\";\n busy(true);\n showProgress(true);\n setProgress(3, \"Отправка на обработку…\");\n\n try {\n const headers = { \"Content-Type\": \"application/json\" };\n if (pw.value) headers[\"x-admin-password\"] = pw.value;\n\n const res = await fetch(\"/api/jobs\", {\n method: \"POST\",\n headers,\n body: JSON.stringify({ sourceUrl: src, scale, model: model.value }),\n });\n const data = await res.json();\n if (!res.ok) throw new Error(data.error || \"Не удалось создать задачу\");\n\n setProgress(6, \"Модель загружается на GPU…\");\n startFakeProgress();\n watch(data.id);\n loadHistory();\n } catch (err) {\n stopFakeProgress();\n showProgress(false);\n busy(false);\n say(err.message, \"err\");\n }\n});\n\n/* ── отслеживание задачи ── */\n\nfunction watch(id) {\n clearInterval(poll);\n poll = setInterval(async () => {\n try {\n const res = await fetch(\"/api/jobs/\" + id);\n const data = await res.json();\n const job = data.job;\n if (!job) return;\n\n if (job.status === \"processing\") {\n stage.textContent = \"Апскейл кадров нейросетью…\";\n }\n\n if (job.status === \"succeeded\" && job.output_url) {\n clearInterval(poll);\n stopFakeProgress();\n setProgress(100, \"Готово\");\n busy(false);\n video.src = job.output_url;\n dl.href = job.output_url;\n result.className = \"result on\";\n say(\"Видео улучшено. Ссылка на файл живёт на серверах Replicate около часа — скачай сразу.\", \"ok\");\n loadHistory();\n setTimeout(() => showProgress(false), 1400);\n } else if (job.status === \"failed\" || job.status === \"canceled\") {\n clearInterval(poll);\n stopFakeProgress();\n showProgress(false);\n busy(false);\n say(job.error || \"Обработка не удалась.\", \"err\");\n loadHistory();\n }\n } catch (_) {\n /* сеть мигнула — следующая итерация повторит */\n }\n }, 4000);\n}\n\n/* ── история ── */\n\nfunction esc(s) {\n return String(s ?? \"\").replace(/[&<>\"]/g, (c) =>\n ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\" }[c]));\n}\n\nconst LABEL = {\n queued: \"в очереди\",\n processing: \"обработка\",\n succeeded: \"готово\",\n failed: \"ошибка\",\n canceled: \"отменено\",\n};\n\nasync function loadHistory() {\n try {\n const res = await fetch(\"/api/jobs\");\n const { jobs } = await res.json();\n if (!jobs?.length) {\n jobsBox.innerHTML = '

Пока ничего не обработано.

';\n return;\n }\n jobsBox.innerHTML = jobs.map((j) => {\n const when = new Date(j.created_at).toLocaleString(\"ru-RU\", {\n day: \"2-digit\",\n month: \"2-digit\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n });\n const name = j.source_url.split(\"/\").pop() || j.source_url;\n const link = j.output_url\n ? `Скачать`\n : \"\";\n return `

${esc(name)}

${j.scale}× · ${esc(j.model)} · ${when}

\n ${LABEL[j.status] ?? esc(j.status)}\n ${link}\n

`;\n }).join(\"\");\n } catch (_) {\n /* история не критична */\n }\n}\n\nloadHistory();\n",[179],"64d771d4-b8fa-4ab9-b23d-29683eeb51d9","admin.js","cdeaff82-8c7c-11f1-8dbc-1607ee4eb77e",16,["D",1785460331227],3,"/* Админка. Пароль держим только в памяти страницы + cookie, выставленной сервером. */\n\nconst $ = (id) => document.getElementById(id);\nlet pass = sessionStorage.getItem(\"adminPw\") || \"\";\n\nfunction headers() {\n return pass ? { \"x-admin-password\": pass } : {};\n}\n\nfunction esc(s) {\n return String(s ?? \"\").replace(/[&<>\"]/g, (c) =>\n ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\" }[c]));\n}\n\nconst LABEL = {\n queued: \"в очереди\",\n processing: \"обработка\",\n succeeded: \"готово\",\n failed: \"ошибка\",\n canceled: \"отменено\",\n};\n\n/* ── вход ── */\n\nasync function tryLogin(password) {\n const res = await fetch(\"/api/admin/login\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ password }),\n });\n const data = await res.json();\n if (!res.ok) throw new Error(data.error || \"Не удалось войти\");\n return true;\n}\n\n$(\"login\").addEventListener(\"click\", async () => {\n const value = $(\"pw\").value;\n if (!value) return;\n const box = $(\"gateMsg\");\n box.className = \"msg\";\n try {\n await tryLogin(value);\n pass = value;\n sessionStorage.setItem(\"adminPw\", value);\n openPanel();\n } catch (err) {\n box.textContent = err.message;\n box.className = \"msg on err\";\n }\n});\n\n$(\"pw\").addEventListener(\"keydown\", (e) => {\n if (e.key === \"Enter\") $(\"login\").click();\n});\n\n$(\"logout\").addEventListener(\"click\", (e) => {\n e.preventDefault();\n sessionStorage.removeItem(\"adminPw\");\n document.cookie = \"admin=; Path=/; Max-Age=0\";\n location.reload();\n});\n\nfunction openPanel() {\n $(\"gate\").style.display = \"none\";\n $(\"panel\").style.display = \"block\";\n refresh();\n}\n\n/* ── данные ── */\n\nasync function refresh() {\n await Promise.all([loadStats(), loadQueue()]);\n}\n\nasync function loadStats() {\n const res = await fetch(\"/api/admin/stats\", { headers: headers() });\n if (res.status === 401) {\n sessionStorage.removeItem(\"adminPw\");\n return location.reload();\n }\n const s = await res.json();\n $(\"sTotal\").textContent = s.total ?? 0;\n $(\"sOk\").textContent = s.byStatus?.succeeded ?? 0;\n $(\"sUsers\").textContent = s.users ?? 0;\n $(\"sDay\").textContent = s.last24h ?? 0;\n\n const rows = [\n row(\n \"REPLICATE_API_TOKEN\",\n s.env?.REPLICATE_API_TOKEN ? \"задан\" : \"не задан\",\n s.env?.REPLICATE_API_TOKEN ? \"succeeded\" : \"failed\",\n ),\n row(\n \"Связь с Replicate\",\n s.replicate?.tokenOk ? \"токен рабочий\" : (s.replicate?.tokenError ?? \"нет связи\"),\n s.replicate?.tokenOk ? \"succeeded\" : \"failed\",\n ),\n row(\"Модель\", s.replicate?.model ?? \"—\", \"processing\"),\n row(\"ADMIN_PASSWORD\", s.env?.ADMIN_PASSWORD ? \"задан\" : \"не задан\",\n s.env?.ADMIN_PASSWORD ? \"succeeded\" : \"failed\"),\n ];\n $(\"envBox\").innerHTML = rows.join(\"\");\n}\n\nfunction row(name, value, pill) {\n return `

${esc(name)}

${esc(value)}

\n ${pill === \"succeeded\" ? \"ок\" : pill === \"failed\" ? \"нет\" : \"инфо\"}\n

`;\n}\n\nasync function loadQueue() {\n const res = await fetch(\"/api/admin/jobs\", { headers: headers() });\n const { jobs } = await res.json();\n if (!jobs?.length) {\n $(\"queue\").innerHTML = '

Задач пока нет.

';\n return;\n }\n $(\"queue\").innerHTML = jobs.map((j) => {\n const when = new Date(j.created_at).toLocaleString(\"ru-RU\");\n const active = j.status === \"processing\" || j.status === \"queued\";\n const cancel = active\n ? ``\n : \"\";\n const link = j.output_url\n ? `Файл`\n : \"\";\n const err = j.error\n ? `

${esc(j.error).slice(0, 220)}

`\n : \"\";\n return `

${esc(j.source_url).slice(0, 90)}

${j.scale}× · ${esc(j.model)} · ${when} · ${esc(j.user_key).slice(0, 8)}

\n ${err}\n

\n ${LABEL[j.status] ?? esc(j.status)}\n ${link}${cancel}\n

`;\n }).join(\"\");\n\n document.querySelectorAll(\"[data-cancel]\").forEach((btn) => {\n btn.addEventListener(\"click\", async () => {\n btn.disabled = true;\n btn.textContent = \"Отменяю…\";\n await fetch(\"/api/admin/jobs/\" + btn.dataset.cancel + \"/cancel\", {\n method: \"POST\",\n headers: headers(),\n });\n refresh();\n });\n });\n}\n\n$(\"refresh\").addEventListener(\"click\", refresh);\n\n$(\"schema\").addEventListener(\"click\", async () => {\n $(\"schemaCard\").style.display = \"block\";\n $(\"schemaDump\").textContent = \"Загружаю…\";\n const res = await fetch(\"/api/admin/model-schema\", { headers: headers() });\n const data = await res.json();\n $(\"schemaDump\").textContent = JSON.stringify(data, null, 2);\n});\n\n/* Автовход, если пароль уже в сессии. */\nif (pass) {\n tryLogin(pass).then(openPanel).catch(() => sessionStorage.removeItem(\"adminPw\"));\n}\n\n/* Живое обновление панели. */\nsetInterval(() => {\n if ($(\"panel\").style.display === \"block\") refresh();\n}, 15000);\n",[187],"d990cdc1-9be9-45d6-963e-9a5fd3cb88b5","admin.html","c1b8ce06-8c7c-11f1-9b81-1607ee4eb77e",12,["D",1785460287890],"\n\n \n \n \n Админка — Video AI\n \n \n \n \n \n \n

\n \n

Вход в админку

Пароль лежит в переменной окружения ADMIN_PASSWORD.

\n \n Пароль\n \n \n \n

\n\n \n \n

\n \n\n",[195],"3f3d3276-f724-4cb8-aba9-505bbacce16a","README.md","019fb5b3-559b-704e-aa6d-1dd5aa0a7041",["D",1785460363154],"# Video AI Upscaler\n\nАпскейл видео нейросетью Real-ESRGAN. Тёмный интерфейс, drag & drop, прогресс, история,\nадминка с очередью и статистикой.\n\n**Сайт:** \n**Админка:** \n\n## Что нужно сделать перед запуском\n\n1. **Отзови старый ключ Replicate.** Тот, что был прислан в чате, скомпрометирован:\n \n2. Создай новый и добавь его как `REPLICATE_API_TOKEN` — до этого обработка не запустится.\n3. Поменяй `ADMIN_PASSWORD` (сейчас стоит заглушка `change-me-now-8f3kd9`).\n\nКлючи задаются только через переменные окружения вала, в коде их нет.\n\n## Структура\n\n| Файл | Назначение |\n| --- | --- |\n| `main.tsx` | HTTP-сервер: статика, API, вебхук, админ-роуты |\n| `lib/db.ts` | SQLite: задачи, история, статистика, рейт-лимит |\n| `lib/replicate.ts` | Replicate API: версия модели, схема входов, предсказания |\n| `index.html` / `app.js` | Главная страница |\n| `admin.html` / `admin.js` | Админка |\n| `style.css` | Тёмная тема, стекло, градиенты, адаптив |\n\n## Как идёт обработка\n\n```mermaid\nflowchart TD\n A[Пользователь] -->|файл до 8 МБ| B[POST /api/upload]\n A -->|или прямая ссылка| D\n B --> C[Blob storage]\n C -->|публичный URL /f/:name| D[POST /api/jobs]\n D --> E[SQLite: задача queued]\n D --> F[Replicate: создание prediction]\n F --> G[GPU: Real-ESRGAN]\n G -->|вебхук| H[POST /api/webhook/replicate]\n G -.->|если вебхук не дошёл| I[GET /api/jobs/:id опрашивает Replicate]\n H --> J[SQLite: succeeded + output_url]\n I --> J\n J --> K[Проигрывание и скачивание]\n```\n\n## Отличия от изначального ТЗ\n\n**Deno KV заменён на SQLite Val Town.** Deno KV на платформе недоступен. Задачи, история и\nстатистика лежат в `std/sqlite`, загруженные файлы — в `std/blob`. Оба хранилища бесплатны.\n\n**Загрузка файлов ограничена 8 МБ.** Replicate забирает видео по публичной ссылке, а гонять\nбольшие файлы через serverless-запрос нельзя. Мелкие клипы идут через blob, для остального есть\nполе с прямой ссылкой.\n\n**Прогресс-бар оценочный.** Replicate не отдаёт процент выполнения, поэтому полоса ползёт до 90%\nпо времени, а до 100% доходит по факту готовности.\n\n**Добавлена защита от расходов.** Без пароля админа — 2 задачи в час на браузер\n(`FREE_PER_HOUR` в `main.tsx`). С паролем лимита нет. Рендер видео на Replicate платный и\nмедленный, а сайт открыт всему интернету — без этого посторонние тратили бы твои деньги.\n\n## Проверка полей модели\n\n`lucataco/real-esrgan-video` менял имена входных полей между версиями, поэтому\n`lib/replicate.ts` читает схему последней версии и отправляет только те поля, которые модель\nреально принимает. Посмотреть живую схему: кнопка «Показать схему модели» в админке.\n\n## Стоимость\n\nVal Town — бесплатный тир. Платишь только Replicate за секунды GPU. 4x дороже и дольше 2x;\n30-секундный клип может рендериться несколько минут. Готовые файлы живут на серверах Replicate\nоколо часа — скачивай сразу.\n",[202],"7cac6248-79f6-4d2e-a0f6-a6da1dc0d48a","lib","cb0621bd-1bcc-4b7b-9f38-03a948f49a11",["D",1785460007594],"directory",[208],"pulls","forks","envVars",{"_219":169,"_221":57},"connections",{"_219":57,"_220":57},"count","unfilledCount","emptyCount",{"_20":207,"_13":208,"_141":209,"_143":-5,"_144":21,"_145":149,"_147":53,"_22":273,"_29":57,"_150":211,"_151":-5,"_153":40,"_154":-5,"_234":274,"_98":275},{"_20":265,"_13":266,"_141":267,"_143":209,"_144":21,"_145":268,"_147":53,"_22":269,"_29":169,"_150":183,"_151":270,"_153":40,"_154":-5,"_234":271,"_98":272},{"_20":258,"_13":259,"_141":260,"_143":209,"_144":21,"_145":191,"_147":53,"_22":261,"_29":57,"_150":183,"_151":262,"_153":40,"_154":-5,"_234":263,"_98":264},{"_20":201,"_13":202,"_141":203,"_143":-5,"_144":21,"_145":30,"_147":53,"_22":255,"_29":169,"_150":109,"_151":205,"_153":40,"_154":-5,"_234":256,"_98":257},{"_20":194,"_13":195,"_141":196,"_143":-5,"_144":21,"_145":197,"_147":53,"_22":252,"_29":57,"_150":109,"_151":199,"_153":40,"_154":-5,"_234":253,"_98":254},{"_20":186,"_13":187,"_141":188,"_143":-5,"_144":21,"_145":189,"_147":53,"_22":249,"_29":191,"_150":183,"_151":192,"_153":40,"_154":-5,"_234":250,"_98":251},{"_20":178,"_13":179,"_141":180,"_143":-5,"_144":21,"_145":181,"_147":53,"_22":246,"_29":57,"_150":183,"_151":184,"_153":40,"_154":-5,"_234":247,"_98":248},{"_20":172,"_13":173,"_141":174,"_143":-5,"_144":21,"_145":169,"_147":53,"_22":243,"_29":57,"_150":109,"_151":176,"_153":40,"_154":-5,"_234":244,"_98":245},{"_20":164,"_13":165,"_141":166,"_143":-5,"_144":21,"_145":167,"_147":53,"_22":240,"_29":169,"_150":109,"_151":170,"_153":40,"_154":-5,"_234":241,"_98":242},{"_20":156,"_13":157,"_141":51,"_143":-5,"_144":21,"_145":158,"_147":53,"_22":237,"_29":149,"_150":160,"_151":161,"_153":40,"_154":162,"_234":238,"_98":239},{"_20":139,"_13":140,"_141":142,"_143":-5,"_144":21,"_145":146,"_147":53,"_22":233,"_29":149,"_150":109,"_151":152,"_153":40,"_154":-5,"_234":235,"_98":236},["D",1785460224036],"children",[],[140],["D",1785460160688],[],[157],["D",1785460240087],[],[165],["D",1785459856696],[],[173],["D",1785460272868],[],[179],["D",1785460331227],[],[187],["D",1785460287890],[],[195],["D",1785460363154],[],[202],"70148414-f5b4-44ad-84d8-e54bcddd1666","replicate.ts","29fa989c-8c7c-11f1-b632-1607ee4eb77e",["D",1785460033321],"const API = \"https://api.replicate.com/v1\";\nexport const MODEL = \"lucataco/real-esrgan-video\";\n\nexport function token(): string {\n const t = Deno.env.get(\"REPLICATE_API_TOKEN\");\n if (!t) throw new Error(\"REPLICATE_API_TOKEN не задан в переменных окружения вала\");\n return t;\n}\n\nasync function rq(path: string, init: RequestInit = {}): Promise {\n const res = await fetch(`${API}${path}`, {\n ...init,\n headers: {\n \"Authorization\": `Bearer ${token()}`,\n \"Content-Type\": \"application/json\",\n ...(init.headers ?? {}),\n },\n });\n const text = await res.text();\n let body: any;\n try {\n body = JSON.parse(text);\n } catch {\n body = { raw: text };\n }\n if (!res.ok) {\n throw new Error(`Replicate ${res.status}: ${body?.detail ?? body?.raw ?? text}`);\n }\n return body;\n}\n\nlet cachedVersion: { id: string; inputs: Record } | null = null;\n\n/**\n * Тянет последнюю версию модели и её входную схему.\n * Схема нужна, чтобы отправлять только те поля, которые модель реально принимает —\n * у real-esrgan-video они менялись между версиями.\n */\nexport async function modelVersion(force = false) {\n if (cachedVersion && !force) return cachedVersion;\n const model = await rq(`/models/${MODEL}`);\n const version = model?.latest_version;\n if (!version?.id) throw new Error(\"Не удалось получить latest_version модели\");\n const props = version?.openapi_schema?.components?.schemas?.Input?.properties ?? {};\n cachedVersion = { id: version.id, inputs: props };\n return cachedVersion;\n}\n\n/** Отдаёт схему в сыром виде — используется в админке для проверки полей. */\nexport async function inputSchema() {\n const v = await modelVersion(true);\n return { version: v.id, inputs: v.inputs };\n}\n\n/**\n * Собирает input под конкретную версию модели.\n * scale 2 → FHD/x4plus, scale 4 → 4k/x4plus. Лишние поля отбрасываются по схеме.\n */\nexport function buildInput(\n videoUrl: string,\n scale: number,\n modelName: string,\n schema: Record,\n): Record {\n const candidate: Record = {\n video_path: videoUrl,\n video: videoUrl,\n model: modelName,\n model_name: modelName,\n resolution: scale >= 4 ? \"4k\" : \"FHD\",\n scale: scale,\n };\n const keys = Object.keys(schema);\n if (keys.length === 0) {\n // Схема недоступна — отправляем минимальный набор.\n return { video_path: videoUrl, model: modelName, resolution: scale >= 4 ? \"4k\" : \"FHD\" };\n }\n const input: Record = {};\n for (const [k, v] of Object.entries(candidate)) {\n if (!keys.includes(k)) continue;\n // Не подставляем значение, если модель ждёт enum и нашего значения там нет.\n const allowed = schema[k]?.enum ?? schema[k]?.allOf?.[0]?.enum;\n if (Array.isArray(allowed) && !allowed.includes(v)) continue;\n input[k] = v;\n }\n if (!input.video_path && !input.video) {\n const fileKey = keys.find((k) => /video|file|path|input/i.test(k));\n if (fileKey) input[fileKey] = videoUrl;\n }\n return input;\n}\n\nexport async function createPrediction(opts: {\n videoUrl: string;\n scale: number;\n model: string;\n webhookUrl?: string;\n}): Promise<{ id: string; status: string }> {\n const v = await modelVersion();\n const input = buildInput(opts.videoUrl, opts.scale, opts.model, v.inputs);\n const body: Record = { version: v.id, input };\n if (opts.webhookUrl) {\n body.webhook = opts.webhookUrl;\n body.webhook_events_filter = [\"completed\"];\n }\n const pred = await rq(\"/predictions\", { method: \"POST\", body: JSON.stringify(body) });\n return { id: pred.id, status: pred.status };\n}\n\nexport async function getPrediction(id: string): Promise {\n return await rq(`/predictions/${id}`);\n}\n\nexport async function cancelPrediction(id: string): Promise {\n await rq(`/predictions/${id}/cancel`, { method: \"POST\" });\n}\n\n/** Баланс/аккаунт — чтобы админка показывала, что токен живой. */\nexport async function account(): Promise {\n return await rq(\"/account\");\n}\n",[],[208,259],"1c765272-695f-45ab-be5d-03a80e860c35","db.ts","1aa50b70-8c7c-11f1-be91-1607ee4eb77e",5,["D",1785460156389],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type JobStatus = \"queued\" | \"processing\" | \"succeeded\" | \"failed\" | \"canceled\";\n\nexport interface Job {\n id: string;\n prediction_id: string | null;\n source_url: string;\n output_url: string | null;\n scale: number;\n model: string;\n status: JobStatus;\n error: string | null;\n user_key: string;\n created_at: string;\n finished_at: string | null;\n}\n\nlet ready: Promise | null = null;\n\n/** Создаёт схему один раз за жизнь изолята. */\nexport function initDb(): Promise {\n if (!ready) {\n ready = (async () => {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS jobs (\n id TEXT PRIMARY KEY,\n prediction_id TEXT,\n source_url TEXT NOT NULL,\n output_url TEXT,\n scale INTEGER NOT NULL DEFAULT 2,\n model TEXT NOT NULL DEFAULT 'RealESRGAN_x4plus',\n status TEXT NOT NULL DEFAULT 'queued',\n error TEXT,\n user_key TEXT NOT NULL DEFAULT 'anon',\n created_at TEXT NOT NULL,\n finished_at TEXT\n )`);\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS jobs_created_idx ON jobs (created_at DESC)`,\n );\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS jobs_prediction_idx ON jobs (prediction_id)`,\n );\n })();\n }\n return ready;\n}\n\nexport async function createJob(job: {\n id: string;\n source_url: string;\n scale: number;\n model: string;\n user_key: string;\n}): Promise {\n await initDb();\n await sqlite.execute({\n sql: `INSERT INTO jobs (id, source_url, scale, model, status, user_key, created_at)\n VALUES (?, ?, ?, ?, 'queued', ?, ?)`,\n args: [job.id, job.source_url, job.scale, job.model, job.user_key, new Date().toISOString()],\n });\n}\n\nexport async function attachPrediction(id: string, predictionId: string): Promise {\n await initDb();\n await sqlite.execute({\n sql: `UPDATE jobs SET prediction_id = ?, status = 'processing' WHERE id = ?`,\n args: [predictionId, id],\n });\n}\n\nexport async function finishJob(opts: {\n predictionId: string;\n status: JobStatus;\n outputUrl?: string | null;\n error?: string | null;\n}): Promise {\n await initDb();\n await sqlite.execute({\n sql: `UPDATE jobs\n SET status = ?, output_url = ?, error = ?, finished_at = ?\n WHERE prediction_id = ?`,\n args: [\n opts.status,\n opts.outputUrl ?? null,\n opts.error ?? null,\n new Date().toISOString(),\n opts.predictionId,\n ],\n });\n}\n\nexport async function getJob(id: string): Promise {\n await initDb();\n const res = await sqlite.execute({\n sql: `SELECT * FROM jobs WHERE id = ?`,\n args: [id],\n });\n return (res.rows[0] as unknown as Job) ?? null;\n}\n\nexport async function listJobs(opts: { userKey?: string; limit?: number } = {}): Promise {\n await initDb();\n const limit = Math.min(opts.limit ?? 50, 200);\n const res = opts.userKey\n ? await sqlite.execute({\n sql: `SELECT * FROM jobs WHERE user_key = ? ORDER BY created_at DESC LIMIT ?`,\n args: [opts.userKey, limit],\n })\n : await sqlite.execute({\n sql: `SELECT * FROM jobs ORDER BY created_at DESC LIMIT ?`,\n args: [limit],\n });\n return res.rows as unknown as Job[];\n}\n\nexport async function stats() {\n await initDb();\n const [totals, users, recent] = await Promise.all([\n sqlite.execute(`SELECT status, COUNT(*) AS n FROM jobs GROUP BY status`),\n sqlite.execute(`SELECT COUNT(DISTINCT user_key) AS n FROM jobs`),\n sqlite.execute(\n `SELECT COUNT(*) AS n FROM jobs WHERE created_at > datetime('now', '-1 day')`,\n ),\n ]);\n const byStatus: Record = {};\n for (const row of totals.rows as unknown as { status: string; n: number }[]) {\n byStatus[row.status] = Number(row.n);\n }\n const total = Object.values(byStatus).reduce((a, b) => a + b, 0);\n return {\n total,\n byStatus,\n users: Number((users.rows[0] as { n: number })?.n ?? 0),\n last24h: Number((recent.rows[0] as { n: number })?.n ?? 0),\n };\n}\n\n/** Отменяет задачу локально (Replicate отменяется отдельно). */\nexport async function markCanceled(id: string): Promise {\n await initDb();\n await sqlite.execute({\n sql: `UPDATE jobs SET status = 'canceled', finished_at = ? WHERE id = ?`,\n args: [new Date().toISOString(), id],\n });\n}\n\n/** Количество задач пользователя за последний час — для рейт-лимита. */\nexport async function recentJobCount(userKey: string): Promise {\n await initDb();\n const res = await sqlite.execute({\n sql: `SELECT COUNT(*) AS n FROM jobs\n WHERE user_key = ? AND created_at > datetime('now', '-1 hour')`,\n args: [userKey],\n });\n return Number((res.rows[0] as { n: number })?.n ?? 0);\n}\n\n/** Помечает задачу упавшей по её id (когда prediction ещё не создан). */\nexport async function markFailedById(id: string, error: string): Promise {\n await initDb();\n await sqlite.execute({\n sql: `UPDATE jobs SET status = 'failed', error = ?, finished_at = ? WHERE id = ?`,\n args: [error, new Date().toISOString(), id],\n });\n}\n",[],[208,266],["D",1785460007594],[223,224],[208],["D",1785459856696],["D",1789561879908],{"_11":12,"_96":91},{"_11":12,"_90":91,"_92":91,"_48":49,"_93":94,"_95":40},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":32,"_33":34,"_83":42,"_84":85,"_86":87,"_88":14,"_89":12},"ctx",{"_76":-5,"_119":314,"_315":316,"_317":318,"_319":40,"_320":40,"_321":40,"_322":53,"_323":-5,"_324":-7,"_325":-7,"_326":57,"_327":40,"_328":40,"_329":-5,"_330":40,"_331":40,"_332":40,"_333":-5},"ENV",{"_285":286,"_287":288,"_289":26,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313},"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"]

Апскейл видео
нейросетью

1. Источник видео

2. Модель улучшения

История

Вход в админку

Ключи и подключение

Очередь задач

Входные поля модели

Апскейл видеонейросетью

1. Источник видео

2. Модель улучшения

История

Вход в админку

Ключи и подключение

Очередь задач

Входные поля модели

Апскейл видео
нейросетью

Branches1

Branches
1