[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","panelprophet","name","manhwa-recap-robot","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":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":-5,"_13":44},"permalink","https://www.val.town/x/panelprophet/manhwa-recap-robot/code/main.ts","extension","id","d9922a90-d824-4153-b815-490474917248","fileId","01a016ca-0ae9-7248-a934-69c7bf7a7460","parentId","branchId","509528af-ae61-4cab-8ee7-107219bf189e","branchVersion",24,"latest",true,"createdAt",["D",1787321023712],"version",14,"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 (only used on the Horde fallback path).\nconst NEGATIVE_PROMPT =\n \"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, comic grid, storyboard, collage, multiple panels in one image, single panel layout, distorted, ugly, mismatched face, different person\";\n\n// ============================================================================\n// IMAGE ENGINES\n// \"No low-end models\": the primary generators are current top-tier image models.\n// gemini — Google Nano Banana (gemini-3.1-flash-image). Free API key,\n// state-of-the-art, and it accepts a character-reference image\n// so the SAME protagonist is reused across every panel. PRIMARY.\n// pollinations— flux-anime checkpoint (needs a (free-tier) Pollinations key\n// for the premium model + no-logo). Secondary.\n// horde — AI Horde Stable Diffusion (anonymous). LAST-RESORT fallback\n// so the app keeps working with zero keys (add a registered key\n// for better SD checkpoints).\n// The active engine is auto-picked by whichever key you've set, or forced via\n// the IMG_ENGINE env var (\"gemini\" | \"pollinations\" | \"horde\").\n// ============================================================================\nconst GEMINI_KEY = Deno.env.get(\"GEMINI_API_KEY\") || Deno.env.get(\"GEMINI_KEY2\") || \"\";\nconst GEMINI_MODEL = Deno.env.get(\"GEMINI_IMG_MODEL\") || \"gemini-2.5-flash-image\";\nconst POLL_KEY = Deno.env.get(\"POLLINATIONS_KEY\") || \"\";\nconst OPENAI_KEY = Deno.env.get(\"OPENAI_API_KEY\") || Deno.env.get(\"OPENAI_API_KEY2\") || \"\";\nconst OPENAI_IMG_MODEL = Deno.env.get(\"OPENAI_IMG_MODEL\") || \"gpt-image-1\";\n\nfunction hordeKey() {\n return Deno.env.get(\"AI_HORDE_KEY\") || \"0000000000\";\n}\n\nfunction pickEngine(): string {\n // Paid top-tier (OpenAI gpt-image-1) wins whenever a key is present.\n if (OPENAI_KEY) return \"openai\";\n const forced = Deno.env.get(\"IMG_ENGINE\");\n if (forced) return [\"gemini\", \"openai\", \"pollinations\", \"horde\"].includes(forced) ? forced : \"gemini\";\n if (GEMINI_KEY) return \"gemini\";\n if (POLL_KEY) return \"pollinations\";\n return \"horde\";\n}\n\n// Fixed SEED keeps the same character consistent per target-panel across the\n// fixed-seed engines (Horde). Gemini instead uses reference-image chaining.\nconst SEED = 42;\n\n// ---- Horde helpers (fallback path) ---------------------------------------\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\n// ---- Lookup handler -------------------------------------------------------\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// ============================================================================\n// ASYNC JOB FLOW (works within the free-tier 1-minute request timeout)\n// startJob stores the job + engine. The client polls /api/status, which churns\n// out a few panels per poll (each a single fast generation call). No one server\n// request blocks for the whole batch.\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 const engine = pickEngine();\n\n const jobId = crypto.randomUUID();\n const items = prompts.map((p, i) => ({\n hordeId: null as string | null,\n done: false,\n failed: false,\n url: null as string | null,\n prompt: p,\n retried: false,\n attempt: 0,\n idx: i,\n }));\n await blob.setJSON(\"job:\" + jobId, { id: jobId, items, createdAt: Date.now(), width, height, model: String(body.model || \"\"), engine });\n cleanup();\n return Response.json({ jobId, count: prompts.length, engine });\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 let lastErr: unknown = null;\n try {\n if (job.engine === \"gemini\") await churnGemini(job);\n else if (job.engine === \"openai\") await churnOpenai(job);\n else if (job.engine === \"pollinations\") await churnPollinations(job);\n else await churnHorde(job);\n } catch (e) {\n // A single poll hiccup must never 500 the job: stay pending and retry next poll.\n lastErr = e;\n console.error(\"Poll engine error:\", (e && (e as any).message) || e);\n }\n\n // If a paid engine (Gemini / OpenAI) is unavailable (bad/out-of-quota key),\n // downgrade the job to the Horde fallback so panels still get produced\n // instead of hanging forever.\n if ((job.engine === \"gemini\" || job.engine === \"openai\") && lastErr) {\n const msg = String((lastErr && (lastErr as any).message) || \"\");\n if (/(quota|billing|credits|429|403|401|api ?key|invalid|insufficient)/i.test(msg)) {\n job.engine = \"horde\";\n console.warn(\"Engine unavailable (\" + msg.slice(0, 80) + \") — job downgraded to Horde fallback.\");\n }\n }\n\n await blob.setJSON(\"job:\" + jobId, job);\n const pending = job.items.filter((i: any) => !i.done && !i.failed).length;\n const errors = job.items.filter((i: any) => i.failed).length;\n return Response.json({\n done: pending === 0,\n engine: job.engine,\n urls: job.items.map((i: any) => i.url),\n total: job.items.length,\n pending,\n errors,\n });\n}\n\n// ---- Gemini churn ----------------------------------------------------------\n// Panels are generated 0,1,2,... so that every panel AFTER the first reuses the\n// first panel's image as a CHARACTER-REFERENCE — the same face, outfit and style\n// in every panel. Batches a few per poll to stay inside the 1-minute budget.\nconst GEMINI_BATCH = 3; // panels attempted per poll (each call ~10-20s, parallel)\nconst GEMINI_TIMEOUT_MS = 90000;\n\nasync function churnGemini(job: any) {\n const same = job.items.filter((i: any) => !i.done && !i.failed);\n if (!same.length) return;\n\n // First panel must exist before the rest can reference it.\n const first = job.items[0];\n if (!first.done && !(first.failed && first.attempt > 0)) {\n await genGeminiItem(first, null, job);\n if (!first.done) return; // poll budget spent, continue next poll\n }\n\n const refUrl = (first && first.url) || \"\";\n const batch = same.filter((i: any) => i.idx !== 0).slice(0, GEMINI_BATCH);\n const results = await Promise.allSettled(\n batch.map((it: any) => genGeminiItem(it, refUrl, job)),\n );\n results.forEach((r, i) => {\n if (r.status === \"rejected\") {\n const it = batch[i];\n it.attempt += 1;\n if (it.attempt >= 2) it.failed = true; // give each panel two shots\n else it.failed = false;\n console.error(\"Gemini panel fail:\", (r.reason && r.reason.message) || r.reason);\n }\n });\n}\n\nasync function genGeminiItem(item: any, refUrl: string | null, job: any) {\n const asp = geminiAspect(job.width || 720, job.height || 1280);\n // Trim the prompt so the anti-distortion tail isn't sent twice, keep it as one line.\n const prompt = String(item.prompt || \"\").substring(0, 1800);\n item.url = await geminiImage(prompt, asp, refUrl, Number(SEED) + item.idx);\n item.done = !!(item.url);\n item.failed = !item.url;\n}\n\nfunction geminiAspect(w: number, h: number): string {\n if (h > w) return \"9:16\";\n if (w > h) return \"16:9\";\n return \"1:1\";\n}\n\ninterface GeminiPart {\n type: \"text\" | \"image\";\n text?: string;\n data?: string;\n mime_type?: string;\n}\n\nasync function geminiImage(prompt: string, aspect: string, refDataUrl: string | null, seed: number): Promise {\n const parts: GeminiPart[] = [{ type: \"text\", text: prompt }];\n if (refDataUrl) {\n const i = refDataUrl.indexOf(\",\");\n parts.push({\n type: \"image\",\n mime_type: (refDataUrl.match(/^data:([^;]+)/) || [\"\", \"image/png\"])[1],\n data: i >= 0 ? refDataUrl.slice(i + 1) : refDataUrl,\n });\n }\n const res = await fetch(\"https://generativelanguage.googleapis.com/v1beta/interactions\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", \"x-goog-api-key\": GEMINI_KEY },\n body: JSON.stringify({\n model: GEMINI_MODEL,\n input: parts,\n response_format: { type: \"image\", aspect_ratio: aspect, image_size: \"1K\" },\n }),\n signal: AbortSignal.timeout(GEMINI_TIMEOUT_MS),\n });\n if (!res.ok) {\n const txt = await res.text().catch(() => \"\");\n throw new Error(\"Gemini HTTP \" + res.status + (txt ? \" \" + txt.slice(0, 160) : \"\"));\n }\n const data = await res.json();\n const img = data?.output_image || data?.interaction?.output_image;\n if (!img || !img.data) throw new Error(\"Gemini returned no image: \" + JSON.stringify(data).slice(0, 200));\n return \"data:\" + (img.mime_type || \"image/png\") + \";base64,\" + img.data;\n}\n\n// ---- Pollinations churn (flux-anime) --------------------------------------\n// Each panel is a single GET that returns image bytes; Pollinations caches by\n// URL so re-polling a done panel is free. Fixed per-panel seed keeps identity.\nasync function churnPollinations(job: any) {\n const same = job.items.filter((i: any) => !i.done && !i.failed);\n for (const it of same.slice(0, 3)) {\n try {\n it.url = await pollImage(it.prompt, job.width || 720, job.height || 1280, Number(SEED) + it.idx);\n it.done = !!it.url;\n it.failed = !it.url;\n } catch (e) {\n it.attempt += 1;\n if (it.attempt >= 3) it.failed = true;\n console.error(\"Pollinations panel fail:\", (e && e.message) || e);\n }\n }\n}\n\nasync function pollImage(prompt: string, width: number, height: number, seed: number): Promise {\n const url = new URL(\"https://image.pollinations.ai/prompt/\" + encodeURIComponent(String(prompt).substring(0, 1800)));\n url.searchParams.set(\"width\", String(width));\n url.searchParams.set(\"height\", String(height));\n url.searchParams.set(\"seed\", String(seed));\n const model = POLL_KEY ? \"flux-anime\" : \"sana\";\n url.searchParams.set(\"model\", model);\n url.searchParams.set(\"safe\", \"true\");\n if (POLL_KEY) {\n url.searchParams.set(\"key\", POLL_KEY);\n url.searchParams.set(\"nologo\", \"true\");\n }\n const res = await fetch(url.toString(), { signal: AbortSignal.timeout(45000) });\n if (!res.ok) throw new Error(\"Pollinations HTTP \" + res.status);\n const mime = res.headers.get(\"content-type\") || \"image/jpeg\";\n return \"data:\" + mime + \";base64,\" + await toB64(res);\n}\n\n// ---- Horde churn (last-resort fallback) -----------------------------------\nasync function churnHorde(job: any) {\n const apikey = hordeKey();\n const { items } = job;\n for (const it of items) {\n if (it.done) continue;\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) { it.failed = true; console.error(\"Horde panel retry failed:\", (e && e.message) || e); }\n }\n continue;\n }\n if (!it.hordeId) {\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; console.error(\"Horde submit failed:\", (e && e.message) || e);\n }\n continue;\n }\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 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;\n }\n } catch { /* keep pending */ }\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: prompt.substring(0, 1800),\n params: { width, height, n: 1, steps: 30, cfg_scale: 6, sampler_name: \"k_euler_a\", 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\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 if (msg.includes(\"429\")) {\n await new Promise((r) => setTimeout(r, 800));\n continue;\n }\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\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// ---- shared helpers --------------------------------------------------------\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 return \"data:\" + mime + \";base64,\" + await toB64(res);\n}\n\nasync function toB64(res: Response): Promise {\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 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 { /* best effort */ }\n}\n// ---- OpenAI churn (gpt-image-1) -------------------------------------------\n// Top-tier image model via your OpenAI/ChatGPT API key. Sends the panel prompt\n// to /v1/images/generations and returns b64. Batches a few per poll.\nasync function churnOpenai(job: any) {\n const same = job.items.filter((i: any) => !i.done && !i.failed);\n const batch = same.slice(0, 3);\n const results = await Promise.allSettled(batch.map((it: any) => genOpenaiItem(it, job)));\n results.forEach((r, i) => {\n if (r.status === \"rejected\") {\n const it = batch[i];\n it.attempt += 1;\n if (it.attempt >= 2) it.failed = true; // two shots per panel\n else it.failed = false;\n console.error(\"OpenAI panel fail:\", (r.reason && (r.reason as any).message) || r.reason);\n }\n });\n}\n\nasync function genOpenaiItem(item: any, job: any) {\n const size = openaiSize(job.width || 720, job.height || 1280);\n const prompt = String(item.prompt || \"\").substring(0, 2000);\n item.url = await openaiImage(prompt, size);\n item.done = !!item.url;\n item.failed = !item.url;\n}\n\nfunction openaiSize(w: number, h: number): string {\n if (h > w) return \"1024x1536\"; // portrait 2:3 (~9:16-ish)\n if (w > h) return \"1536x1024\"; // landscape 3:2 (~16:9-ish)\n return \"1024x1024\";\n}\n\nasync function openaiImage(prompt: string, size: string): Promise {\n const res = await fetch(\"https://api.openai.com/v1/images/generations\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\", \"authorization\": \"Bearer \" + OPENAI_KEY },\n body: JSON.stringify({\n model: OPENAI_IMG_MODEL,\n prompt,\n n: 1,\n size,\n quality: \"high\",\n }),\n signal: AbortSignal.timeout(90000),\n });\n if (!res.ok) {\n const txt = await res.text().catch(() => \"\");\n throw new Error(\"OpenAI HTTP \" + res.status + (txt ? \" \" + txt.slice(0, 160) : \"\"));\n }\n const data = await res.json();\n const b64 = data && data.data && data.data[0] && data.data[0].b64_json;\n if (!b64) throw new Error(\"OpenAI returned no image: \" + JSON.stringify(data).slice(0, 160));\n return \"data:image/png;base64,\" + b64;\n}\n","deleted",false,"label",[14],"d3a39fb3-6dbd-4b71-bbd8-e49f2e0417c4",["D",1787088734583],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Manhwa recap robot (remix) for bug fixes","imageUrl","userId","e4f22b5e-fcbc-4270-a27f-698d49c236dc","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a016ab-f805-7648-8129-cf1e2d52f80a","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_104":100},"org",{"_9":10,"_97":98,"_99":100,"_55":56,"_101":102,"_103":42},"branch",{"_35":30,"_11":85,"_22":28,"_86":45,"_87":88,"_89":36,"_90":50,"_91":92,"_93":94,"_95":12,"_96":10},"isOwned","main","projectId","forkedBranchId","b7bb689b-5e7c-4f5e-963c-f1f776d3b468","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","24b55c76-4552-4d57-b7f1-c9aa4895b4f9","forkedProjectOrgId","01a01650-da55-76b8-afca-abcee983d985","projectName","userHandle","displayName","Panel Prophet","avatar","https://lh3.googleusercontent.com/a/ACg8ocIJ2ctzaPnZwmY060GbVZc0tlpTkp38RCfcsg7ipx-W6IOB2A=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":62,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":85,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"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"]