\n \n

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

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

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

\n\n \n \n

\n \n\n","label",[18],"pulls","branches",1,"forks","envVars",{"_177":171,"_179":26},"connections",{"_177":26,"_178":26},"count","unfilledCount","emptyCount",{"_32":270,"_13":261,"_62":256,"_42":-5,"_34":35,"_162":196,"_163":84,"_36":271,"_38":26,"_64":272,"_165":-5,"_65":24,"_167":-5,"_198":273,"_17":274},{"_32":262,"_13":263,"_62":264,"_42":256,"_34":35,"_162":265,"_163":84,"_36":266,"_38":171,"_64":230,"_165":267,"_65":24,"_167":-5,"_198":268,"_17":269},{"_32":253,"_13":254,"_62":255,"_42":256,"_34":35,"_162":239,"_163":84,"_36":257,"_38":26,"_64":230,"_165":258,"_65":24,"_167":-5,"_198":259,"_17":260},{"_32":246,"_13":247,"_62":248,"_42":-5,"_34":35,"_162":110,"_163":84,"_36":249,"_38":171,"_64":21,"_165":250,"_65":24,"_167":-5,"_198":251,"_17":252},{"_32":161,"_13":18,"_62":63,"_42":-5,"_34":35,"_162":39,"_163":84,"_36":243,"_38":26,"_64":21,"_165":166,"_65":24,"_167":-5,"_198":244,"_17":245},{"_32":234,"_13":235,"_62":236,"_42":-5,"_34":35,"_162":237,"_163":84,"_36":238,"_38":239,"_64":230,"_165":240,"_65":24,"_167":-5,"_198":241,"_17":242},{"_32":225,"_13":226,"_62":227,"_42":-5,"_34":35,"_162":228,"_163":84,"_36":229,"_38":26,"_64":230,"_165":231,"_65":24,"_167":-5,"_198":232,"_17":233},{"_32":218,"_13":219,"_62":220,"_42":-5,"_34":35,"_162":171,"_163":84,"_36":221,"_38":26,"_64":21,"_165":222,"_65":24,"_167":-5,"_198":223,"_17":224},{"_32":210,"_13":211,"_62":212,"_42":-5,"_34":35,"_162":213,"_163":84,"_36":214,"_38":171,"_64":21,"_165":215,"_65":24,"_167":-5,"_198":216,"_17":217},{"_32":201,"_13":202,"_62":82,"_42":-5,"_34":35,"_162":203,"_163":84,"_36":204,"_38":196,"_64":205,"_165":206,"_65":24,"_167":207,"_198":208,"_17":209},{"_32":191,"_13":192,"_62":193,"_42":-5,"_34":35,"_162":194,"_163":84,"_36":195,"_38":196,"_64":21,"_165":197,"_65":24,"_167":-5,"_198":199,"_17":200},"5853322a-05a5-45ca-b09c-de86b95076ff","style.css","019fb5b3-559b-704e-aa6d-336401c00e72",8,["D",1785460224036],2,":root {\n --bg: #06070c;\n --bg-2: #0b0d16;\n --panel: rgba(255, 255, 255, .045);\n --border: rgba(255, 255, 255, .09);\n --text: #eef1f7;\n --muted: #8b93a7;\n --accent: #6d8bff;\n --accent-2: #b364ff;\n --accent-3: #35e0d0;\n --ok: #35d69a;\n --warn: #ffb64d;\n --err: #ff5f6d;\n --radius: 18px;\n}\n\n* { box-sizing: border-box; }\n\nhtml, body { height: 100%; }\n\nbody {\n margin: 0;\n background: var(--bg);\n color: var(--text);\n font: 15px/1.55 ui-sans-serif, system-ui, -apple-system, \"Segoe UI\", Roboto, sans-serif;\n -webkit-font-smoothing: antialiased;\n overflow-x: hidden;\n}\n\n/* ── фон: медленно дышащие градиентные пятна ── */\nbody::before,\nbody::after {\n content: \"\";\n position: fixed;\n inset: -30vh -30vw;\n z-index: -1;\n pointer-events: none;\n background:\n radial-gradient(38vw 38vw at 18% 12%, rgba(109, 139, 255, .17), transparent 65%),\n radial-gradient(34vw 34vw at 82% 22%, rgba(179, 100, 255, .15), transparent 62%),\n radial-gradient(40vw 40vw at 50% 96%, rgba(53, 224, 208, .10), transparent 62%);\n animation: drift 26s ease-in-out infinite alternate;\n}\n\nbody::after {\n animation-duration: 34s;\n animation-direction: alternate-reverse;\n opacity: .65;\n}\n\n@keyframes drift {\n from { transform: translate3d(-2%, -1%, 0) scale(1); }\n to { transform: translate3d(3%, 2%, 0) scale(1.12); }\n}\n\n/* ── каркас ── */\n.wrap {\n max-width: 1080px;\n margin: 0 auto;\n padding: 28px 20px 80px;\n}\n\nheader.top {\n display: flex;\n align-items: center;\n justify-content: space-between;\n gap: 16px;\n margin-bottom: 40px;\n}\n\n.brand {\n display: flex;\n align-items: center;\n gap: 11px;\n font-weight: 700;\n letter-spacing: -.02em;\n font-size: 17px;\n}\n\n.brand .dot {\n width: 26px;\n height: 26px;\n border-radius: 8px;\n background: linear-gradient(135deg, var(--accent), var(--accent-2));\n box-shadow: 0 0 22px rgba(109, 139, 255, .55);\n animation: pulse 3.4s ease-in-out infinite;\n}\n\n@keyframes pulse {\n 50% { box-shadow: 0 0 34px rgba(179, 100, 255, .7); }\n}\n\nnav { display: flex; gap: 8px; align-items: center; }\n\nnav a {\n color: var(--muted);\n text-decoration: none;\n font-size: 13.5px;\n padding: 7px 13px;\n border-radius: 10px;\n border: 1px solid transparent;\n transition: .2s;\n}\n\nnav a:hover {\n color: var(--text);\n background: var(--panel);\n border-color: var(--border);\n}\n\n/* ── герой ── */\n.hero { text-align: center; margin-bottom: 42px; }\n\n.hero h1 {\n margin: 0 0 14px;\n font-size: clamp(30px, 6.2vw, 54px);\n line-height: 1.05;\n letter-spacing: -.035em;\n font-weight: 800;\n background: linear-gradient(100deg, #fff 12%, var(--accent) 48%, var(--accent-2) 82%);\n -webkit-background-clip: text;\n background-clip: text;\n color: transparent;\n}\n\n.hero p {\n margin: 0 auto;\n max-width: 560px;\n color: var(--muted);\n font-size: 16px;\n}\n\n/* ── стеклянные карточки ── */\n.card {\n background: var(--panel);\n border: 1px solid var(--border);\n border-radius: var(--radius);\n backdrop-filter: blur(18px) saturate(140%);\n -webkit-backdrop-filter: blur(18px) saturate(140%);\n padding: 22px;\n box-shadow: 0 18px 50px rgba(0, 0, 0, .42);\n}\n\n.card + .card { margin-top: 18px; }\n\n.card h2 {\n margin: 0 0 4px;\n font-size: 15px;\n letter-spacing: .01em;\n}\n\n.card .hint {\n margin: 0 0 16px;\n color: var(--muted);\n font-size: 13px;\n}\n\n/* ── зона перетаскивания ── */\n.drop {\n position: relative;\n border: 1.5px dashed rgba(255, 255, 255, .17);\n border-radius: 15px;\n padding: 40px 20px;\n text-align: center;\n cursor: pointer;\n transition: .22s;\n background: rgba(255, 255, 255, .015);\n}\n\n.drop:hover { border-color: rgba(109, 139, 255, .55); background: rgba(109, 139, 255, .05); }\n\n.drop.over {\n border-color: var(--accent-3);\n background: rgba(53, 224, 208, .09);\n transform: scale(1.012);\n}\n\n.drop .ico { font-size: 34px; display: block; margin-bottom: 10px; opacity: .85; }\n\n.drop .big { font-weight: 600; margin-bottom: 5px; }\n\n.drop .small { color: var(--muted); font-size: 12.5px; }\n\n.drop input[type=file] { display: none; }\n\n.or {\n display: flex;\n align-items: center;\n gap: 12px;\n margin: 16px 0;\n color: var(--muted);\n font-size: 12px;\n text-transform: uppercase;\n letter-spacing: .12em;\n}\n\n.or::before, .or::after {\n content: \"\";\n flex: 1;\n height: 1px;\n background: var(--border);\n}\n\n/* ── поля ── */\ninput[type=text], input[type=url], input[type=password], select {\n width: 100%;\n padding: 12px 14px;\n border-radius: 11px;\n border: 1px solid var(--border);\n background: rgba(0, 0, 0, .32);\n color: var(--text);\n font: inherit;\n font-size: 14px;\n transition: .18s;\n}\n\ninput:focus, select:focus {\n outline: none;\n border-color: var(--accent);\n box-shadow: 0 0 0 3.5px rgba(109, 139, 255, .17);\n}\n\nlabel.fld { display: block; margin-bottom: 14px; }\n\nlabel.fld > span {\n display: block;\n margin-bottom: 7px;\n font-size: 12.5px;\n color: var(--muted);\n}\n\n/* ── выбор масштаба ── */\n.scales { display: grid; grid-template-columns: 1fr 1fr; gap: 12px; margin-bottom: 16px; }\n\n.scale {\n border: 1px solid var(--border);\n background: rgba(255, 255, 255, .02);\n border-radius: 14px;\n padding: 16px;\n cursor: pointer;\n transition: .2s;\n text-align: left;\n color: var(--text);\n font: inherit;\n}\n\n.scale:hover { border-color: rgba(109, 139, 255, .45); transform: translateY(-2px); }\n\n.scale.on {\n border-color: var(--accent);\n background: linear-gradient(135deg, rgba(109, 139, 255, .16), rgba(179, 100, 255, .1));\n box-shadow: 0 0 0 1px rgba(109, 139, 255, .35), 0 10px 30px rgba(109, 139, 255, .18);\n}\n\n.scale b { display: block; font-size: 19px; letter-spacing: -.02em; margin-bottom: 3px; }\n\n.scale i { font-style: normal; color: var(--muted); font-size: 12.5px; }\n\n/* ── кнопки ── */\n.btn {\n display: inline-flex;\n align-items: center;\n justify-content: center;\n gap: 8px;\n width: 100%;\n padding: 14px 20px;\n border: none;\n border-radius: 13px;\n font: inherit;\n font-weight: 650;\n font-size: 14.5px;\n color: #fff;\n cursor: pointer;\n background: linear-gradient(100deg, var(--accent), var(--accent-2));\n background-size: 180% 100%;\n transition: .25s;\n box-shadow: 0 12px 32px rgba(109, 139, 255, .3);\n}\n\n.btn:hover:not(:disabled) { background-position: 100% 0; transform: translateY(-1.5px); }\n\n.btn:disabled { opacity: .45; cursor: not-allowed; box-shadow: none; }\n\n.btn.ghost {\n background: var(--panel);\n border: 1px solid var(--border);\n box-shadow: none;\n color: var(--text);\n width: auto;\n padding: 9px 15px;\n font-size: 13px;\n font-weight: 500;\n}\n\n.btn.ghost:hover { background: rgba(255, 255, 255, .09); }\n\n.btn.tiny { width: auto; padding: 6px 11px; font-size: 12px; border-radius: 9px; }\n\n.btn.danger { background: linear-gradient(100deg, #ff4d6d, #ff7a45); box-shadow: none; }\n\n/* ── прогресс ── */\n.prog { margin-top: 18px; display: none; }\n\n.prog.on { display: block; animation: fade .35s ease; }\n\n@keyframes fade { from { opacity: 0; transform: translateY(6px); } }\n\n.bar {\n height: 8px;\n border-radius: 99px;\n background: rgba(255, 255, 255, .07);\n overflow: hidden;\n position: relative;\n}\n\n.bar > i {\n position: absolute;\n inset: 0 auto 0 0;\n width: 0%;\n border-radius: 99px;\n background: linear-gradient(90deg, var(--accent), var(--accent-2), var(--accent-3));\n background-size: 200% 100%;\n transition: width .6s ease;\n animation: slide 2.2s linear infinite;\n}\n\n@keyframes slide { to { background-position: 200% 0; } }\n\n.prog .row {\n display: flex;\n justify-content: space-between;\n align-items: center;\n margin-bottom: 9px;\n font-size: 13px;\n}\n\n.prog .pct { color: var(--muted); font-variant-numeric: tabular-nums; }\n\n.spin {\n width: 13px;\n height: 13px;\n border: 2px solid rgba(255, 255, 255, .2);\n border-top-color: var(--accent);\n border-radius: 50%;\n display: inline-block;\n animation: spin .8s linear infinite;\n vertical-align: -2px;\n margin-right: 7px;\n}\n\n@keyframes spin { to { transform: rotate(360deg); } }\n\n/* ── сообщения ── */\n.msg {\n margin-top: 14px;\n padding: 12px 14px;\n border-radius: 11px;\n font-size: 13.5px;\n display: none;\n border: 1px solid;\n}\n\n.msg.on { display: block; animation: fade .3s ease; }\n\n.msg.err { background: rgba(255, 95, 109, .1); border-color: rgba(255, 95, 109, .35); color: #ffb3b9; }\n\n.msg.ok { background: rgba(53, 214, 154, .1); border-color: rgba(53, 214, 154, .32); color: #97e9c6; }\n\n.msg.info { background: rgba(109, 139, 255, .1); border-color: rgba(109, 139, 255, .3); color: #c2cdff; }\n\n/* ── результат ── */\n.result { margin-top: 18px; display: none; }\n\n.result.on { display: block; animation: fade .4s ease; }\n\n.result video {\n width: 100%;\n border-radius: 13px;\n border: 1px solid var(--border);\n background: #000;\n display: block;\n margin-bottom: 12px;\n}\n\n/* ── история ── */\n.jobs { display: flex; flex-direction: column; gap: 10px; }\n\n.job {\n display: flex;\n align-items: center;\n gap: 13px;\n padding: 13px 15px;\n border-radius: 13px;\n border: 1px solid var(--border);\n background: rgba(255, 255, 255, .02);\n transition: .2s;\n flex-wrap: wrap;\n}\n\n.job:hover { background: rgba(255, 255, 255, .045); }\n\n.job .meta { flex: 1; min-width: 180px; }\n\n.job .name {\n font-size: 13.5px;\n word-break: break-all;\n margin-bottom: 3px;\n font-weight: 500;\n}\n\n.job .sub { color: var(--muted); font-size: 11.5px; }\n\n.pill {\n font-size: 11px;\n padding: 4px 10px;\n border-radius: 99px;\n font-weight: 600;\n letter-spacing: .02em;\n white-space: nowrap;\n border: 1px solid;\n}\n\n.pill.queued { color: var(--muted); background: rgba(255, 255, 255, .05); border-color: var(--border); }\n.pill.processing { color: #c2cdff; background: rgba(109, 139, 255, .14); border-color: rgba(109, 139, 255, .35); }\n.pill.succeeded { color: #97e9c6; background: rgba(53, 214, 154, .13); border-color: rgba(53, 214, 154, .32); }\n.pill.failed { color: #ffb3b9; background: rgba(255, 95, 109, .13); border-color: rgba(255, 95, 109, .32); }\n.pill.canceled { color: var(--warn); background: rgba(255, 182, 77, .12); border-color: rgba(255, 182, 77, .3); }\n\n.empty { color: var(--muted); font-size: 13.5px; text-align: center; padding: 26px 0; }\n\n/* ── статистика админки ── */\n.grid4 { display: grid; grid-template-columns: repeat(4, 1fr); gap: 13px; margin-bottom: 18px; }\n\n.stat {\n background: var(--panel);\n border: 1px solid var(--border);\n border-radius: 15px;\n padding: 17px;\n backdrop-filter: blur(14px);\n}\n\n.stat .n {\n font-size: 27px;\n font-weight: 750;\n letter-spacing: -.03em;\n background: linear-gradient(120deg, #fff, var(--accent));\n -webkit-background-clip: text;\n background-clip: text;\n color: transparent;\n font-variant-numeric: tabular-nums;\n}\n\n.stat .k { color: var(--muted); font-size: 11.5px; margin-top: 3px; letter-spacing: .02em; }\n\npre.dump {\n background: rgba(0, 0, 0, .45);\n border: 1px solid var(--border);\n border-radius: 12px;\n padding: 14px;\n overflow: auto;\n font-size: 12px;\n max-height: 340px;\n color: #b8c1d9;\n margin: 0;\n}\n\n.gate { max-width: 380px; margin: 14vh auto 0; }\n\nfooter.foot {\n margin-top: 42px;\n text-align: center;\n color: var(--muted);\n font-size: 12px;\n}\n\nfooter.foot a { color: var(--muted); }\n\n/* ── мобильные ── */\n@media (max-width: 720px) {\n .wrap { padding: 20px 15px 60px; }\n .grid4 { grid-template-columns: 1fr 1fr; }\n header.top { flex-direction: column; align-items: flex-start; gap: 12px; }\n .drop { padding: 30px 14px; }\n .job { gap: 9px; }\n}\n\n@media (max-width: 420px) {\n .scales { grid-template-columns: 1fr; }\n}\n\n@media (prefers-reduced-motion: reduce) {\n * { animation: none !important; transition: none !important; }\n}\n","children",[],[192],"422af693-06f8-4dab-a2d6-de0248312798","main.tsx",6,["D",1785460160688],"http","import { Hono } from \"npm:hono\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport * as db from \"./lib/db.ts\";\nimport * as rep from \"./lib/replicate.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst MAX_UPLOAD = 8 * 1024 * 1024; // 8 МБ — предел для загрузки через запрос\nconst FREE_PER_HOUR = 2; // без пароля: столько задач в час\n\n/* ─────────── пользователь и авторизация ─────────── */\n\nfunction cookies(req: Request): Record {\n const raw = req.headers.get(\"cookie\") ?? \"\";\n const out: Record = {};\n for (const part of raw.split(\";\")) {\n const [k, ...v] = part.trim().split(\"=\");\n if (k) out[k] = decodeURIComponent(v.join(\"=\"));\n }\n return out;\n}\n\nfunction userKey(c: any): string {\n const existing = cookies(c.req.raw).uid;\n if (existing) return existing;\n const fresh = crypto.randomUUID();\n c.header(\"Set-Cookie\", `uid=${fresh}; Path=/; Max-Age=31536000; SameSite=Lax`);\n return fresh;\n}\n\nfunction adminPassword(): string | null {\n return Deno.env.get(\"ADMIN_PASSWORD\") ?? null;\n}\n\nfunction isAdmin(c: any): boolean {\n const pw = adminPassword();\n if (!pw) return false;\n const supplied = c.req.header(\"x-admin-password\") ?? cookies(c.req.raw).admin ?? \"\";\n return supplied.length > 0 && supplied === pw;\n}\n\nfunction requireAdmin(c: any): Response | null {\n if (!adminPassword()) {\n return c.json({ error: \"ADMIN_PASSWORD не задан в переменных окружения вала\" }, 500);\n }\n if (!isAdmin(c)) return c.json({ error: \"Неверный пароль\" }, 401);\n return null;\n}\n\n/* ─────────── статика ─────────── */\n\napp.get(\"/\", (c) => serveFile(\"./index.html\", import.meta.url));\napp.get(\"/admin\", (c) => serveFile(\"./admin.html\", import.meta.url));\napp.get(\"/style.css\", (c) => serveFile(\"./style.css\", import.meta.url));\napp.get(\"/app.js\", (c) => serveFile(\"./app.js\", import.meta.url));\napp.get(\"/admin.js\", (c) => serveFile(\"./admin.js\", import.meta.url));\napp.get(\"/favicon.svg\", (c) => serveFile(\"./favicon.svg\", import.meta.url));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n/* ─────────── загрузка файла в blob ─────────── */\n\napp.post(\"/api/upload\", async (c) => {\n const form = await c.req.formData();\n const file = form.get(\"file\");\n if (!(file instanceof File)) return c.json({ error: \"Файл не передан\" }, 400);\n if (file.size > MAX_UPLOAD) {\n return c.json({\n error:\n `Файл ${(file.size / 1048576).toFixed(1)} МБ — больше лимита ${MAX_UPLOAD / 1048576} МБ. `\n + `Загрузи видео куда-нибудь и вставь прямую ссылку.`,\n }, 413);\n }\n const ext = (file.name.split(\".\").pop() ?? \"mp4\").toLowerCase().replace(/[^a-z0-9]/g, \"\");\n const key = `upload/${crypto.randomUUID()}.${ext}`;\n await blob.set(key, await file.arrayBuffer());\n const url = new URL(c.req.url).origin + \"/f/\" + key.slice(\"upload/\".length);\n return c.json({ url, key, size: file.size });\n});\n\n// Публичная отдача загруженного файла — Replicate забирает видео по этой ссылке.\napp.get(\"/f/:name\", async (c) => {\n const name = c.req.param(\"name\");\n if (!/^[a-z0-9-]+\\.[a-z0-9]+$/i.test(name)) return c.text(\"Плохое имя файла\", 400);\n try {\n const res = await blob.get(`upload/${name}`);\n const bytes = await res.arrayBuffer();\n const ext = name.split(\".\").pop()!.toLowerCase();\n const type = ext === \"webm\" ? \"video/webm\" : ext === \"mov\" ? \"video/quicktime\" : \"video/mp4\";\n return new Response(bytes, {\n headers: { \"Content-Type\": type, \"Cache-Control\": \"public, max-age=3600\" },\n });\n } catch {\n return c.text(\"Не найдено\", 404);\n }\n});\n\n/* ─────────── задачи ─────────── */\n\napp.post(\"/api/jobs\", async (c) => {\n const uid = userKey(c);\n const body = await c.req.json().catch(() => ({}));\n const sourceUrl = String(body.sourceUrl ?? \"\").trim();\n const scale = body.scale === 4 ? 4 : 2;\n const model = String(body.model ?? \"RealESRGAN_x4plus\");\n\n if (!/^https?:\\/\\/.+/i.test(sourceUrl)) {\n return c.json({ error: \"Нужна прямая ссылка на видео (http/https)\" }, 400);\n }\n\n // Защита кошелька: без пароля админа — лимит задач в час.\n if (!isAdmin(c)) {\n const used = await db.recentJobCount(uid);\n if (used >= FREE_PER_HOUR) {\n return c.json({\n error:\n `Лимит ${FREE_PER_HOUR} задач в час без пароля. Введи пароль админа, чтобы снять лимит.`,\n }, 429);\n }\n }\n\n const id = crypto.randomUUID();\n await db.createJob({ id, source_url: sourceUrl, scale, model, user_key: uid });\n\n try {\n const origin = new URL(c.req.url).origin;\n const pred = await rep.createPrediction({\n videoUrl: sourceUrl,\n scale,\n model,\n webhookUrl: `${origin}/api/webhook/replicate`,\n });\n await db.attachPrediction(id, pred.id);\n return c.json({ id, predictionId: pred.id, status: \"processing\" });\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n await db.markFailedById(id, msg);\n return c.json({ id, error: msg }, 502);\n }\n});\n\napp.get(\"/api/jobs\", async (c) => {\n const uid = userKey(c);\n const jobs = await db.listJobs({ userKey: uid, limit: 30 });\n return c.json({ jobs });\n});\n\napp.get(\"/api/jobs/:id\", async (c) => {\n const job = await db.getJob(c.req.param(\"id\"));\n if (!job) return c.json({ error: \"Задача не найдена\" }, 404);\n\n // Вебхук мог не дойти — подтягиваем состояние напрямую.\n if (job.prediction_id && (job.status === \"processing\" || job.status === \"queued\")) {\n try {\n const pred = await rep.getPrediction(job.prediction_id);\n if (pred.status === \"succeeded\") {\n const out = Array.isArray(pred.output) ? pred.output[0] : pred.output;\n await db.finishJob({\n predictionId: job.prediction_id,\n status: \"succeeded\",\n outputUrl: typeof out === \"string\" ? out : null,\n });\n } else if (pred.status === \"failed\" || pred.status === \"canceled\") {\n await db.finishJob({\n predictionId: job.prediction_id,\n status: pred.status,\n error: pred.error ? String(pred.error) : null,\n });\n }\n const fresh = await db.getJob(job.id);\n return c.json({ job: fresh, replicate: { status: pred.status, logs: pred.logs ?? null } });\n } catch (err) {\n return c.json({ job, warning: err instanceof Error ? err.message : String(err) });\n }\n }\n return c.json({ job });\n});\n\n/* ─────────── вебхук Replicate ─────────── */\n\napp.post(\"/api/webhook/replicate\", async (c) => {\n const pred = await c.req.json().catch(() => null);\n if (!pred?.id) return c.json({ ok: false }, 400);\n const out = Array.isArray(pred.output) ? pred.output[0] : pred.output;\n if (pred.status === \"succeeded\") {\n await db.finishJob({\n predictionId: pred.id,\n status: \"succeeded\",\n outputUrl: typeof out === \"string\" ? out : null,\n });\n } else if (pred.status === \"failed\" || pred.status === \"canceled\") {\n await db.finishJob({\n predictionId: pred.id,\n status: pred.status,\n error: pred.error ? String(pred.error) : null,\n });\n }\n return c.json({ ok: true });\n});\n\n/* ─────────── админка ─────────── */\n\napp.post(\"/api/admin/login\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const pw = adminPassword();\n if (!pw) return c.json({ error: \"ADMIN_PASSWORD не задан\" }, 500);\n if (String(body.password ?? \"\") !== pw) return c.json({ error: \"Неверный пароль\" }, 401);\n c.header(\"Set-Cookie\", `admin=${encodeURIComponent(pw)}; Path=/; Max-Age=86400; SameSite=Lax`);\n return c.json({ ok: true });\n});\n\napp.get(\"/api/admin/stats\", async (c) => {\n const deny = requireAdmin(c);\n if (deny) return deny;\n const s = await db.stats();\n let tokenOk = false;\n let tokenError: string | null = null;\n try {\n await rep.account();\n tokenOk = true;\n } catch (err) {\n tokenError = err instanceof Error ? err.message : String(err);\n }\n return c.json({\n ...s,\n replicate: { model: rep.MODEL, tokenOk, tokenError },\n env: {\n REPLICATE_API_TOKEN: Boolean(Deno.env.get(\"REPLICATE_API_TOKEN\")),\n ADMIN_PASSWORD: Boolean(adminPassword()),\n },\n });\n});\n\napp.get(\"/api/admin/jobs\", async (c) => {\n const deny = requireAdmin(c);\n if (deny) return deny;\n const jobs = await db.listJobs({ limit: 100 });\n return c.json({ jobs });\n});\n\napp.post(\"/api/admin/jobs/:id/cancel\", async (c) => {\n const deny = requireAdmin(c);\n if (deny) return deny;\n const job = await db.getJob(c.req.param(\"id\"));\n if (!job) return c.json({ error: \"Задача не найдена\" }, 404);\n if (job.prediction_id) {\n try {\n await rep.cancelPrediction(job.prediction_id);\n } catch { /* уже завершена — не мешает локальной отметке */ }\n }\n await db.markCanceled(job.id);\n return c.json({ ok: true });\n});\n\napp.get(\"/api/admin/model-schema\", async (c) => {\n const deny = requireAdmin(c);\n if (deny) return deny;\n try {\n return c.json(await rep.inputSchema());\n } catch (err) {\n return c.json({ error: err instanceof Error ? err.message : String(err) }, 502);\n }\n});\n\nexport default app.fetch;\n","video-ai-upscaler-nh",[],[202],"3397147a-068b-4fee-bcdb-62443d230fe1","index.html","019fb5b3-559b-704e-aa6d-2784520c6915",9,["D",1785460240087],"\n\n \n \n \n Video AI — апскейл видео нейросетью\n \n \n \n \n \n \n

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",[],[211],"f26319f4-281a-4935-bf3b-ac09d0611334","favicon.svg","019fb5b3-559b-704e-aa6d-22dea24d265f",["D",1785459856696],"",[],[219],"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",[],[226],"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",[],[235],["D",1785460287890],[],[18],"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",[],[247],"70148414-f5b4-44ad-84d8-e54bcddd1666","replicate.ts","29fa989c-8c7c-11f1-b632-1607ee4eb77e","cb0621bd-1bcc-4b7b-9f38-03a948f49a11",["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",[],[261,254],"lib","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",[],[261,263],"7cac6248-79f6-4d2e-a0f6-a6da1dc0d48a",["D",1785460007594],"directory",[181,182],[261],["D",1785459856696],["D",1789474853273],{"_11":12,"_127":68},{"_11":12,"_123":68,"_67":68,"_30":66,"_124":125,"_126":24},{"_38":110,"_13":16,"_32":35,"_111":70,"_112":113,"_114":115,"_116":75,"_117":118,"_119":120,"_121":14,"_122":12},"ctx",{"_52":-5,"_148":313,"_314":315,"_316":317,"_318":24,"_319":24,"_320":24,"_321":84,"_322":-5,"_323":-7,"_324":-7,"_325":26,"_326":24,"_327":24,"_328":-5,"_329":24,"_330":24,"_331":24,"_332":-5},"ENV",{"_284":285,"_286":287,"_288":16,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312},"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. Модель улучшения

История

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

History · admin.html