[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","Keanutd","name","manhwa-recap-robot","path","main.ts","project",{"_22":46,"_11":12,"_33":47,"_48":-5,"_49":42,"_50":51,"_52":51,"_53":54,"_55":-5,"_56":57,"_58":25,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_13":45},"permalink","https://www.val.town/x/Keanutd/manhwa-recap-robot/code/main.ts","extension","id","eac88574-4a21-45da-a2c6-0db90b4c65e6","fileId","01a01797-0364-7031-af7e-7f3839c7dfe4","parentId","branchId","831cf4fc-6538-44d9-be46-9729bd4f8228","branchVersion",19,"latest",true,"createdAt",["D",1787345495158],"version",8,"fileType","http","content","import { staticHTTPServer, readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst HORDE = \"https://aihorde.net/api/v2\";\nconst JOB_TTL_MS = 2 * 60 * 60 * 1000; // jobs expire after 2h\n// Always-available baseline model used if a pinned model is rejected.\nconst ANON_FALLBACK_MODEL = \"stable_diffusion\";\n// Reduces the classic Stable Diffusion artifacts (extra fingers, text, blur).\nconst NEGATIVE_PROMPT = \"text, watermark, signature, logo, blurry, low quality, deformed, ugly face, distorted face, poorly drawn face, asymmetric eyes, mismatched eyes, bad hands, mutated hands, extra fingers, extra digits, extra limbs, malformed limbs, missing limbs, bad anatomy, cropped, jpeg artifacts, nsfw, duplicate face, repeated character, clone, doppelganger, multiple identical people, twin, split screen, split panel, multiple copies of the same person, extra people, comic grid, storyboard, collage, multiple panels in one image, single panel layout, distorted, mismatched face, different person\";\n\n// FIXED SEED for character consistency: the same seed across every panel keeps\n// the protagonist's face/identity stable between shots (a known Stable Diffusion\n// technique for character consistency). Different prompts + same seed = same\n// character, different scene.\nconst SEED = 42;\n\n// AI Horde requires dimensions to be multiples of 64, and the anonymous key is\n// capped at 850x850 (a registered key can go much larger). Scale the requested\n// size down to fit `maxDim` while preserving aspect ratio, then snap to 64.\nfunction fitDims(w: number, h: number, maxDim: number): [number, number] {\n const scale = Math.min(1, maxDim / Math.max(w, h));\n let nw = Math.max(64, Math.round((w * scale) / 64) * 64);\n let nh = Math.max(64, Math.round((h * scale) / 64) * 64);\n while (nw > maxDim) nw -= 64;\n while (nh > maxDim) nh -= 64;\n return [nw, nh];\n}\n\nfunction hordeKey() {\n // `0000000000` is the shared anonymous key; a registered key gets higher priority.\n return Deno.env.get(\"AI_HORDE_KEY\") || \"0000000000\";\n}\n\n// Lookup handler: return a Response for API routes, else defer to the static server.\nasync function api(req: Request): Promise {\n const url = new URL(req.url);\n if (url.pathname === \"/api/generate\" && req.method === \"POST\") return startJob(req);\n if (url.pathname === \"/api/status\") return jobStatus(url.searchParams.get(\"job\") || \"\");\n if (url.pathname === \"/api/source\") return downloadSource(url.searchParams.get(\"pin\") || \"\");\n if (url.pathname === \"/api/img\") return proxyImg(url.searchParams.get(\"url\") || \"\");\n return null;\n}\n\n// ---- IMAGE PROXY: fetch any public image and return it as a same-origin\n// data URL, so panel images pasted into Manual mode never taint the canvas.\nasync function proxyImg(url: string): Promise {\n if (!url) return Response.json({ error: \"missing url\" }, { status: 400 });\n try {\n const res = await fetch(url);\n if (!res.ok) return Response.json({ error: \"http \" + res.status }, { status: 502 });\n const mime = res.headers.get(\"content-type\") || \"image/jpeg\";\n const bytes = new Uint8Array(await res.arrayBuffer());\n let bin = \"\";\n const CHUNK = 0x8000;\n for (let i = 0; i < bytes.length; i += CHUNK) bin += String.fromCharCode(...bytes.subarray(i, i + CHUNK));\n return Response.json({ dataUrl: `data:${mime};base64,${btoa(bin)}` });\n } catch (e) {\n return Response.json({ error: String((e && e.message) || e) }, { status: 500 });\n }\n}\n\n// ---- SOURCE EXPORT (for debugging / porting to another AI) ----\n// Bundles EVERY source file (server, scripting, thumbnail, image-gen, UI)\n// into a single self-contained text file so it can be pasted into another\n// AI to fix bugs, without loading the whole project.\n//\n// PRIVACY: gated by a PIN so random visitors to the public app can't grab\n// the source. Must match the SOURCE_PIN env var (see add_env_var on this val).\n\nconst SOURCE_FILES = [\"main.ts\", \"app.js\", \"index.html\", \"README.md\"];\n\nasync function downloadSource(pin: string): Promise {\n const expected = Deno.env.get(\"SOURCE_PIN\") || \"\";\n if (!expected || pin !== expected) {\n return Response.json(\n { error: \"Forbidden — a developer PIN is required to download the source code.\" },\n { status: 401 },\n );\n }\n try {\n let out =\n \"MANHWA RECAP ROBOT — FULL SOURCE EXPORT\\n\" +\n \"=========================================\\n\" +\n \"Generated: \" + new Date().toISOString() + \"\\n\" +\n \"Every file below is the live code, separated by FILE markers.\\n\" +\n \"Paste this whole file into another AI to review and fix bugs.\\n\\n\";\n for (const f of SOURCE_FILES) {\n try {\n const text = await readFile(f);\n out += \"\\n\" + \"=\".repeat(64) + \"\\n\";\n out += \"FILE: \" + f + \"\\n\";\n out += \"=\".repeat(64) + \"\\n\\n\";\n out += text + \"\\n\";\n } catch (e) {\n out += \"\\n\" + \"=\".repeat(64) + \"\\nFILE: \" + f + \"\\n\" + \"=\".repeat(64) + \"\\n\\n\";\n out += \"(could not read file: \" + String((e && e.message) || e) + \")\\n\";\n }\n }\n return new Response(out, {\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n \"content-disposition\": 'attachment; filename=\"manhwa-recap-robot-source.txt\"',\n },\n });\n } catch (e) {\n return Response.json({ error: String((e && e.message) || e) }, { status: 500 });\n }\n}\n\nexport default staticHTTPServer(import.meta.url, api);\n\n// ---- ASYNC JOB FLOW (works within the free-tier 1-minute request timeout) ----\n// startJob submits every panel to AI Horde (each submit is a fast HTTP POST)\n// and returns a jobId immediately. The client polls /api/status, which ticks\n// each Horde job forward. No single server request blocks for generation.\n\nasync function startJob(req: Request): Promise {\n try {\n const body = await req.json();\n const prompts: string[] = Array.isArray(body.prompts) ? body.prompts : [];\n const apikey = hordeKey();\n const maxDim = 832;\n const [width, height] = fitDims(Number(body.width) || 720, Number(body.height) || 1280, maxDim);\n\n const jobId = crypto.randomUUID();\n const items = [];\n const requestedModel = String(body.model || \"\").trim();\n for (const p of prompts) {\n try {\n const hordeId = await submitWithRetry(p, width, height, apikey, requestedModel || undefined);\n items.push({ hordeId, done: false, failed: false, url: null, prompt: p, retried: false });\n } catch (e) {\n console.error(\"Horde submit failed:\", (e && e.message) || e);\n items.push({ hordeId: null, done: false, failed: true, url: null, prompt: p, retried: false });\n }\n // Anonymous AI Horde rate-limits to ~2 submits/sec — pace the loop so\n // the later panels aren't rejected with 429.\n await new Promise((r) => setTimeout(r, 550));\n }\n await blob.setJSON(\"job:\" + jobId, { id: jobId, items, createdAt: Date.now(), width, height, model: requestedModel });\n cleanup(); // fire-and-forget old jobs\n return Response.json({ jobId, count: prompts.length });\n } catch (e) {\n return Response.json({ error: String((e && e.message) || e) }, { status: 500 });\n }\n}\n\nasync function jobStatus(jobId: string): Promise {\n if (!jobId) return Response.json({ error: \"missing job\" }, { status: 400 });\n const job = await blob.getJSON(\"job:\" + jobId).catch(() => null);\n if (!job) return Response.json({ error: \"not found\" }, { status: 404 });\n\n const apikey = hordeKey();\n for (const it of job.items) {\n if (it.done) continue;\n // AUTO-RETRY: a faulted/dropped panel (common on the anonymous tier) is\n // resubmitted once so it still reaches the target panel count.\n if (it.failed) {\n if (it.prompt && !it.retried) {\n it.retried = true; it.failed = false; it.hordeId = null;\n try {\n it.hordeId = await submitWithRetry(it.prompt, job.width || 720, job.height || 1280, apikey, job.model || undefined);\n } catch (e) {\n it.failed = true;\n console.error(\"Panel retry failed:\", (e && e.message) || e);\n }\n }\n continue;\n }\n if (!it.hordeId) continue;\n try {\n const data = await hordeStatus(it.hordeId, apikey);\n if (data && data.done) {\n const img = data.generations && data.generations[0] && data.generations[0].img;\n if (img) {\n // Horde returns raw base64, a data URL, or a signed R2 URL. Always\n // produce a same-origin data URL so the client canvas isn't tainted.\n it.url = img.startsWith(\"data:\") ? img\n : img.startsWith(\"http\") ? await toDataURL(img)\n : \"data:image/jpeg;base64,\" + img;\n }\n it.done = true;\n } else if (data && data.faulted) {\n it.failed = true; // picked up by next poll's auto-retry\n }\n } catch {\n // keep pending; we try again on the next poll\n }\n }\n await blob.setJSON(\"job:\" + jobId, job);\n\n const pending = job.items.filter((i) => !i.done && !i.failed).length;\n const errors = job.items.filter((i) => i.failed).length;\n return Response.json({\n done: pending === 0,\n urls: job.items.map((i) => i.url),\n total: job.items.length,\n pending,\n errors,\n });\n}\n\nasync function hordeSubmit(prompt: string, width: number, height: number, apikey: string, model?: string): Promise {\n const res = await fetch(HORDE + \"/generate/async\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", apikey },\n body: JSON.stringify({\n prompt,\n params: { width, height, n: 1, steps: 28, cfg_scale: 7.5, sampler_name: \"k_euler_a\", karras: true, seed: String(SEED), negative_prompt: NEGATIVE_PROMPT },\n ...(model ? { models: [model] } : {}),\n }),\n });\n if (!res.ok) {\n const txt = await res.text().catch(() => \"\");\n throw new Error(\"Horde async HTTP \" + res.status + (txt ? \" \" + txt.slice(0, 150) : \"\"));\n }\n const data = await res.json();\n if (!data.id) throw new Error(\"Horde returned no job id\");\n return data.id;\n}\n\n// Submit a prompt to AI Horde, handling the anonymous 429 rate limit\n// (retry with a short wait) and falling back to the baseline model if a\n// pinned model is rejected (e.g. needs more kudos than anonymous).\nasync function submitWithRetry(prompt: string, width: number, height: number, apikey: string, model?: string): Promise {\n const attempts = 3;\n for (let a = 0; a < attempts; a++) {\n try {\n return await hordeSubmit(prompt, width, height, apikey, model);\n } catch (e) {\n const msg = String((e && e.message) || e);\n // Rate limit -> wait and retry the same submission.\n if (msg.includes(\"429\")) {\n await new Promise((r) => setTimeout(r, 800));\n continue;\n }\n // Model rejected -> retry once on the always-available baseline.\n if (model && model !== ANON_FALLBACK_MODEL) {\n return await hordeSubmit(prompt, width, height, apikey, ANON_FALLBACK_MODEL);\n }\n throw e;\n }\n }\n throw new Error(\"Horde submit rate-limited after retries\");\n}\n\n// Single status check — called once per /api/status poll. (No blocking loop.)\nasync function hordeStatus(id: string, apikey: string): Promise {\n const res = await fetch(HORDE + \"/generate/status/\" + id, { headers: { apikey } });\n if (!res.ok) throw new Error(\"Horde status HTTP \" + res.status);\n return res.json();\n}\n\n// Fetch a remote image and re-serve it as a base64 data URL (canvas-safe).\nasync function toDataURL(url: string): Promise {\n const res = await fetch(url);\n if (!res.ok) throw new Error(\"image fetch HTTP \" + res.status);\n const mime = res.headers.get(\"content-type\") || \"image/jpeg\";\n const bytes = new Uint8Array(await res.arrayBuffer());\n let bin = \"\";\n const CHUNK = 0x8000;\n for (let i = 0; i < bytes.length; i += CHUNK) {\n bin += String.fromCharCode(...bytes.subarray(i, i + CHUNK));\n }\n return `data:${mime};base64,${btoa(bin)}`;\n}\n\nasync function cleanup() {\n try {\n const entries = await blob.list(\"job:\");\n const cutoff = Date.now() - JOB_TTL_MS;\n for (const e of entries) {\n const lm = new Date(e.lastModified as any).getTime();\n if (lm < cutoff) await blob.delete(e.key);\n }\n } catch {\n // best effort\n }\n}\n","deleted",false,"label","manhwa-recap-live",[14],"c02cf9a7-d554-42db-8234-6ca726631032",["D",1787101815947],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Manhwa recap video generator","imageUrl","userId","0fe8714d-3f7d-435b-b7a8-253e5c327592","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a01790-b58d-750c-b5be-2c254ae9f7d1","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_103":99},"org",{"_9":10,"_96":97,"_98":99,"_56":57,"_100":101,"_102":42},"branch",{"_35":86,"_11":87,"_22":28,"_88":46,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":12,"_95":10},"isOwned",39,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Inferno Stories","avatar","https://lh3.googleusercontent.com/a/ACg8ocKInAeuHKFSLtO4IJN4obpvxeSeLEmPulIGL2KF1xhfG8FS5JI=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_79":-5,"_137":138,"_139":140,"_141":142,"_143":42,"_144":42,"_145":42,"_146":32,"_147":-5,"_148":-7,"_149":-7,"_150":63,"_151":42,"_152":42,"_153":-5,"_154":42,"_155":42,"_156":42,"_157":-5},"ENV",{"_108":109,"_110":111,"_112":87,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]