${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 if (job.state === \"pending\") {\n body = `\n

⏳ Generating…

Model: ${MODEL_LABEL}

Usually takes 1–3 minutes. Auto-refreshes every 10 s.

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

✅ Video Ready

Model: ${MODEL_LABEL}

Prompt: ${\n escHtml(job.prompt)\n }

⬇️ Download Video 🔗 Direct Link

Raw URL

${\n      escHtml(job.videoUrl)\n    }

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

❌ Generation Failed

${\n escHtml(job.message)\n }

Return to Poe and try a different prompt or image.

`;\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(\n /\"/g,\n \""\",\n );\n}\n\nfunction renderHtml(title: string, body: string): string {\n return `${title} – AI Video Generator${body}`;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const baseUrl = `${url.protocol}//${url.host}`;\n\n const statusMatch = url.pathname.match(/^\\/status\\/([a-f0-9]{16})$/i);\n if (req.method === \"GET\" && statusMatch) return handleStatusPage(statusMatch[1]);\n\n if (req.method === \"GET\") {\n return new Response(\n JSON.stringify({ status: \"ok\", bot: \"AI Video Generator\", model: MODEL_LABEL }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\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({\n error: \"Unauthorized\",\n message: \"Valid BOT_ACCESS_KEY required\",\n }),\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 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 {\n controller.enqueue(encodeEvent(event, data));\n } catch {}\n };\n\n const enqueueKeepalive = () => {\n if (closed) return;\n try {\n controller.enqueue(encodeKeepalive());\n } catch {}\n };\n\n const close = () => {\n if (closed) return;\n closed = true;\n enqueue(\"done\", {});\n try {\n controller.close();\n } catch {}\n };\n\n const send: SendEventFn = (event, data) => enqueue(event, data);\n const sendKeepalive = () => enqueueKeepalive();\n\n getResponse(reqBody, send, sendKeepalive, baseUrl)\n .catch((e) => {\n console.error(\"Top-level error:\", e);\n enqueue(\"error\", {\n text: \"Unexpected error processing request.\",\n allow_retry: true,\n });\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/vidu-q2-turbo/code/main.tsx","extension","actionData","errors"]