[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_108":109,"_110":111},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","Numbmanhwa","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/Numbmanhwa/manhwa-recap-robot/code/main.ts","extension","id","f2f3c437-8b28-4f2a-899c-8b4ea3dd3c35","fileId","01a015c7-94b8-743d-8139-0b0ba40e75ef","parentId","branchId","3e31b6b1-7079-4f5e-88ba-802389deccd8","branchVersion",25,"latest",true,"createdAt",["D",1787075167558],"version",4,"fileType","http","content","import { staticHTTPServer } 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, extra fingers, extra limbs, bad anatomy, distorted face, 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\";\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 return null;\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 = apikey === \"0000000000\" ? 832 : 2048;\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, sampler_name: \"k_euler_a\", 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-robot-42",[14],"22105ad8-254f-4b2b-bf0e-07393d6a9260",["D",1787071796347],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","AI manhwa recap video generator with thumbnail micro analysis","imageUrl","userId","00de319e-99a2-4563-81e5-21dd97a2afa3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a015c1-67bd-766b-b976-2a6534c126ed","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_107":103},"org",{"_9":10,"_100":101,"_102":103,"_56":57,"_104":105,"_106":42},"branch",{"_35":86,"_11":87,"_22":28,"_88":46,"_89":90,"_91":92,"_93":51,"_94":95,"_96":97,"_98":12,"_99":10},"isOwned",26,"main","projectId","forkedBranchId","c57926c8-7beb-40b3-8ba7-ec90b7b687c6","forkedBranchVersion",41,"forkedProjectPrivacy","forkedProjectId","4dee7cf8-684b-4c18-acea-6c23e5c8235c","forkedProjectOrgId","01a01566-4382-718a-880f-71ab27c0faa9","projectName","userHandle","displayName","Numb Manhwa","avatar","https://lh3.googleusercontent.com/a/ACg8ocJaQh5Nww6BPtFHhJC2hQOo3Crkrd2fw_vns5kbdqQKEyWYug=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_79":-5,"_141":142,"_143":144,"_145":146,"_147":42,"_148":42,"_149":42,"_150":32,"_151":-5,"_152":-7,"_153":-7,"_154":63,"_155":42,"_156":42,"_157":-5,"_158":42,"_159":42,"_160":42,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":87,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"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"]