${title} – AI Video Generator

Job not found or expired.

\"), {\n status: 404,\n headers: { \"Content-Type\": \"text/html\" },\n });\n }\n\n let body = \"\";\n\n if (job.state === \"pending\") {\n body = `\n

⏳ Generating your video…

This usually takes 1–3 minutes. This page will auto-refresh every 10 seconds.

\n \n `;\n } else if (job.state === \"done\") {\n body = `\n

✅ Video Ready!

Prompt: ${escHtml(job.prompt)}

Model: ${escHtml(job.model)}

\n ⬇️ Download Video\n 🔗 Open Direct Link\n

Direct URL

${escHtml(job.videoUrl)}

\n `;\n } else if (job.state === \"raw\") {\n body = `\n

🎬 Generation Response

Prompt: ${escHtml(job.prompt)}

Model: ${escHtml(job.model)}

${escHtml(job.content)}

\n `;\n } else if (job.state === \"error\") {\n body = `\n

❌ Generation Failed

${escHtml(job.message)}

Please go back to Poe and try again with a different prompt.

\n `;\n }\n\n return new Response(renderHtml(\"Video Status\", body), {\n status: 200,\n headers: { \"Content-Type\": \"text/html\" },\n });\n}\n\nfunction escHtml(s: string): string {\n return s.replace(/&/g, \"&\").replace(//g, \">\").replace(/\"/g, \""\");\n}\n\nfunction renderHtml(title: string, body: string): string {\n return `\n\n\n \n \n ${title} – AI Video Generator\n \n\n\n ${body}\n\n`;\n}\n\n/* ------------------------------------------------------------------ */\n/* Exported HTTP entry‑point */\n/* ------------------------------------------------------------------ */\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const baseUrl = `${url.protocol}//${url.host}`;\n\n // ----------------------------------------------------------------\n // Status page: GET /status/:jobId\n // ----------------------------------------------------------------\n const statusMatch = url.pathname.match(/^\\/status\\/([a-f0-9]{16})$/i);\n if (req.method === \"GET\" && statusMatch) {\n return handleStatusPage(statusMatch[1]);\n }\n\n // ----------------------------------------------------------------\n // Health‑check / root GET\n // ----------------------------------------------------------------\n if (req.method === \"GET\") {\n return new Response(\n JSON.stringify({ status: \"ok\", bot: \"AI Video Generator\", models: POE_VIDEO_MODELS }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // ----------------------------------------------------------------\n // CORS pre‑flight\n // ----------------------------------------------------------------\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Authorization, Content-Type, X-API-Key\",\n },\n });\n }\n\n if (req.method !== \"POST\") {\n return new Response(JSON.stringify({ error: \"Method not allowed\" }), {\n status: 405,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n if (!authenticateRequest(req)) {\n return new Response(\n JSON.stringify({ error: \"Unauthorized\", message: \"Valid BOT_ACCESS_KEY required\" }),\n { status: 401, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n const reqBody = await req.json().catch(() => ({}));\n\n if (reqBody.type === \"settings\") {\n return new Response(JSON.stringify(await getBotSettings()), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n if (reqBody.type !== \"query\") {\n return new Response(JSON.stringify({ status: \"ok\" }), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // ----------------------------------------------------------------\n // Query — stream SSE, kick off background generation, return fast\n // ----------------------------------------------------------------\n const stream = new ReadableStream({\n start(controller) {\n let closed = false;\n\n const enqueue = (event: string, data: any) => {\n if (closed) return;\n try { controller.enqueue(encodeEvent(event, data)); } catch {}\n };\n\n const close = () => {\n if (closed) return;\n closed = true;\n enqueue(\"done\", {});\n try { controller.close(); } catch {}\n };\n\n const send: SendEventFn = (event, data) => enqueue(event, data);\n\n getResponse(reqBody, send, baseUrl)\n .catch((e) => {\n console.error(\"Top‑level request error:\", e);\n enqueue(\"error\", { text: \"Error processing request.\", allow_retry: true });\n })\n .finally(close);\n },\n });\n\n return new Response(stream, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n}","deleted","label",[102],"permalink","https://www.val.town/x/OpenSourceLab/LTX-2-Audio/code/main.tsx","extension","actionData","errors"]