${title} – AI Video + Music

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 video & music…

Running ${POE_VIDEO_MODELS[0]} and ${MUSIC_MODEL} in parallel.

Usually takes 2–4 minutes. This page auto-refreshes every 10 seconds.

\n \n `;\n } else if (job.state === \"done\") {\n const proxyVideo = `${baseUrl}/proxy?url=${encodeURIComponent(job.videoUrl)}`;\n const proxyMusic = job.musicUrl\n ? `${baseUrl}/proxy?url=${encodeURIComponent(job.musicUrl)}`\n : null;\n\n const musicSection = proxyMusic\n ? `\n

🎵 Music

🎬 Merge Video + Music

Click below to merge locally in your browser using FFmpeg WASM — nothing is uploaded.

\n \n

`\n : `

⚠️ Music generation did not return a URL — video only.

`;\n\n body = `\n

✅ Ready!

Prompt: ${escHtml(job.prompt)}

Model: ${escHtml(job.model)}

\n\n

🎥 Video

\n ⬇️ Download Video\n

\n\n ${musicSection}\n

\n\n ${proxyMusic ? `\n ` : ''}\n `;\n } else if (job.state === \"raw\") {\n body = `\n

🎬 Generation Response

Prompt: ${escHtml(job.prompt)}

Model: ${escHtml(job.model)}

\n ${job.musicUrl ? `

Music: ${escHtml(job.musicUrl)}

` : \"\"}\n

${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 + Music\", body), {\n status: 200,\n headers: { \"Content-Type\": \"text/html\" },\n });\n}\n\nfunction escHtml(s: string): string {\n return s\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\");\n}\n\nfunction renderHtml(title: string, body: string): string {\n return `\n\n\n \n \n ${title} – AI Video + Music\n \n\n\n ${body}\n\n`;\n}\n\n/* ------------------------------------------------------------------ */\n/* 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 // GET /status/:jobId\n const statusMatch = url.pathname.match(/^\\/status\\/([a-f0-9]{16})$/i);\n if (req.method === \"GET\" && statusMatch) {\n return handleStatusPage(statusMatch[1], baseUrl);\n }\n\n // GET /proxy?url=... — CORS proxy for FFmpeg WASM downloads\n if (req.method === \"GET\" && url.pathname === \"/proxy\") {\n return handleProxy(req);\n }\n\n // Health check\n if (req.method === \"GET\") {\n return new Response(\n JSON.stringify({\n status: \"ok\",\n bot: \"AI Video + Music Generator\",\n videoModels: POE_VIDEO_MODELS,\n musicModel: MUSIC_MODEL,\n }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // CORS pre-flight\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 // Stream SSE, kick off background generation\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-01/code/main.tsx","extension","actionData","errors"]