[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",14,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","e38ac600-6734-11f1-bbbb-1607ee4eb77e","name","fileType","http","content","// ============================================================================\n// Kling (fal.ai) MCP connector — v2.8 (duration 5/10/15s + multi_prompt obiekty)\n// upload | from_gemini | generate | status | result | generate_wait\n// + video_concat | video_compose | lipsync | balance | models\n// GET /play?u= + GET /raw?u=. SEKRET: FAL_KEY\n// ============================================================================\nconst KEY = Deno.env.get(\"FAL_KEY\") ?? \"\";\nconst FAL = \"https://queue.fal.run\";\nconst REST = \"https://rest.alpha.fal.ai\";\nconst GEMINI_MCP =\n \"https://rafalwiktorowicz--824b5460548611f1ae1eee650bb23af1.web.val.run/mcp\";\nconst H = () => ({\n \"Authorization\": `Key ${KEY}`,\n \"Content-Type\": \"application/json\",\n});\n\nconst MODELS: Record = {\n \"v3-pro\": \"fal-ai/kling-video/v3/pro/image-to-video\",\n \"v3-std\": \"fal-ai/kling-video/v3/standard/image-to-video\",\n \"o3-pro\": \"fal-ai/kling-video/o3/pro/image-to-video\",\n \"o3-std\": \"fal-ai/kling-video/o3/standard/image-to-video\",\n};\n\nconst TOOLS = [\n {\n name: \"kling_upload\",\n description:\n \"Wgrywa zdjęcie do fal i zwraca PUBLICZNY link (public_url). base64 (data URI lub czysty) ALBO source_url.\",\n inputSchema: {\n type: \"object\",\n properties: {\n base64: { type: \"string\" },\n source_url: { type: \"string\" },\n content_type: { type: \"string\", default: \"image/png\" },\n file_name: { type: \"string\", default: \"upload.png\" },\n },\n },\n },\n {\n name: \"kling_from_gemini\",\n description:\n \"Pobiera obraz z Gemini (image_id) SERWEROWO i wrzuca na fal -> public_url. Bez base64 w czacie.\",\n inputSchema: {\n type: \"object\",\n properties: { image_id: { type: \"string\" } },\n required: [\"image_id\"],\n },\n },\n {\n name: \"kling_generate\",\n description:\n \"Zleca scenę wideo Klinga. Zwraca request_id + status_url + response_url.\",\n inputSchema: {\n type: \"object\",\n properties: {\n model: {\n type: \"string\",\n enum: [\"v3-pro\", \"v3-std\", \"o3-pro\", \"o3-std\"],\n default: \"o3-std\",\n },\n image_url: {\n type: \"string\",\n description: \"Publiczny URL klatki startowej\",\n },\n prompt: { type: \"string\" },\n duration: { type: \"string\", enum: [\"5\", \"10\", \"15\"], default: \"5\" },\n negative_prompt: { type: \"string\", default: \"\" },\n cfg_scale: { type: \"number\", default: 0.5 },\n generate_audio: { type: \"boolean\", default: false },\n end_image_url: { type: \"string\" },\n elements: { type: \"array\", items: { type: \"object\" } },\n multi_prompt: { type: \"array\", items: {} },\n },\n required: [\"model\", \"image_url\", \"prompt\"],\n },\n },\n {\n name: \"kling_status\",\n description: \"Status joba (podaj status_url).\",\n inputSchema: {\n type: \"object\",\n properties: { status_url: { type: \"string\" } },\n required: [\"status_url\"],\n },\n },\n {\n name: \"kling_result\",\n description:\n \"Gotowy film po COMPLETED (podaj response_url). Działa też dla video_concat/compose/lipsync.\",\n inputSchema: {\n type: \"object\",\n properties: { response_url: { type: \"string\" } },\n required: [\"response_url\"],\n },\n },\n {\n name: \"kling_generate_wait\",\n description: \"Zleca scenę I czeka do max_wait_s.\",\n inputSchema: {\n type: \"object\",\n properties: {\n model: {\n type: \"string\",\n enum: [\"v3-pro\", \"v3-std\", \"o3-pro\", \"o3-std\"],\n default: \"o3-std\",\n },\n image_url: { type: \"string\" },\n prompt: { type: \"string\" },\n duration: { type: \"string\", enum: [\"5\", \"10\", \"15\"], default: \"5\" },\n negative_prompt: { type: \"string\", default: \"\" },\n cfg_scale: { type: \"number\", default: 0.5 },\n generate_audio: { type: \"boolean\", default: false },\n end_image_url: { type: \"string\" },\n elements: { type: \"array\", items: { type: \"object\" } },\n max_wait_s: { type: \"number\", default: 45 },\n },\n required: [\"model\", \"image_url\", \"prompt\"],\n },\n },\n {\n name: \"video_concat\",\n description:\n \"Skleja klipy PO KOLEI (+ opc. 1 audio) przez fal compose. Zwraca response_url -> kling_result.\",\n inputSchema: {\n type: \"object\",\n properties: {\n clips: {\n type: \"array\",\n items: {},\n description: \"URL-e klipów po kolei LUB {url,duration}\",\n },\n audio_url: { type: \"string\" },\n clip_seconds: { type: \"number\", default: 5 },\n },\n required: [\"clips\"],\n },\n },\n {\n name: \"video_compose\",\n description:\n \"Zaawansowane: surowe tracks wg fal-ai/ffmpeg-api/compose. Zwraca response_url -> kling_result.\",\n inputSchema: {\n type: \"object\",\n properties: { tracks: { type: \"array\", items: { type: \"object\" } } },\n required: [\"tracks\"],\n },\n },\n {\n name: \"lipsync\",\n description:\n \"Lip-sync: wideo + audio (np. nasze ElevenLabs PL) -> usta zgrane. PEWNY sposób na polski. model: 'fal-ai/sync-lipsync/v2' (domyślnie) lub 'fal-ai/kling-video/lipsync/audio-to-video'. Zwraca response_url -> kling_result.\",\n inputSchema: {\n type: \"object\",\n properties: {\n video_url: { type: \"string\" },\n audio_url: { type: \"string\" },\n sync_mode: {\n type: \"string\",\n enum: [\"cut_off\", \"loop\", \"bounce\", \"silence\", \"remap\"],\n default: \"cut_off\",\n },\n model: { type: \"string\", default: \"fal-ai/sync-lipsync/v2\" },\n },\n required: [\"video_url\", \"audio_url\"],\n },\n },\n {\n name: \"kling_balance\",\n description: \"Saldo fal (best-effort).\",\n inputSchema: { type: \"object\", properties: {} },\n },\n {\n name: \"kling_models\",\n description: \"Lista modeli i aliasów.\",\n inputSchema: { type: \"object\", properties: {} },\n },\n];\n\nfunction b64ToBytes(b64: string): { bytes: Uint8Array; ct: string } {\n let ct = \"image/png\", data = b64;\n const m = b64.match(/^data:([^;]+);base64,(.*)$/s);\n if (m) {\n ct = m[1];\n data = m[2];\n }\n const bin = atob(data.replace(/\\s/g, \"\"));\n const out = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) out[i] = bin.charCodeAt(i);\n return { bytes: out, ct };\n}\n\nasync function doUpload(a: Record) {\n let bytes: Uint8Array, ct = String(a.content_type ?? \"image/png\");\n const fn = String(a.file_name ?? \"upload.png\");\n if (a.source_url) {\n const r = await fetch(String(a.source_url));\n if (!r.ok) throw new Error(`pobieranie source_url ${r.status}`);\n ct = r.headers.get(\"content-type\") ?? ct;\n bytes = new Uint8Array(await r.arrayBuffer());\n } else if (a.base64) {\n const p = b64ToBytes(String(a.base64));\n bytes = p.bytes;\n ct = p.ct || ct;\n } else throw new Error(\"Podaj base64 albo source_url.\");\n const init = await fetch(\n `${REST}/storage/upload/initiate?storage_type=fal-cdn-v3`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Key ${KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ content_type: ct, file_name: fn }),\n },\n );\n const itxt = await init.text();\n if (!init.ok) {\n throw new Error(`initiate ${init.status}: ${itxt.slice(0, 200)}`);\n }\n const { file_url, upload_url } = JSON.parse(itxt);\n const put = await fetch(upload_url, {\n method: \"PUT\",\n headers: { \"Content-Type\": ct },\n body: bytes,\n });\n if (!put.ok) {\n throw new Error(`put ${put.status}: ${(await put.text()).slice(0, 150)}`);\n }\n return { public_url: file_url, bytes: bytes.length, content_type: ct };\n}\n\nasync function doFromGemini(a: Record) {\n const gid = String(a.image_id || \"\");\n if (!gid) throw new Error(\"Podaj image_id.\");\n const r = await fetch(GEMINI_MCP, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n jsonrpc: \"2.0\",\n id: 1,\n method: \"tools/call\",\n params: { name: \"get_gemini_images\", arguments: { ids: [gid] } },\n }),\n });\n const txt = await r.text();\n if (!r.ok) throw new Error(`gemini ${r.status}: ${txt.slice(0, 200)}`);\n const inner = JSON.parse(txt)?.result?.content?.[0]?.text;\n if (!inner) throw new Error(\"brak content z Gemini\");\n const img = (JSON.parse(inner).images || [])[0];\n if (!img?.b64) throw new Error(\"brak b64 z Gemini\");\n return await doUpload({\n base64: img.b64,\n content_type: img.mime || \"image/jpeg\",\n file_name: \"gemini.jpg\",\n });\n}\n\nasync function doLipsync(a: Record) {\n if (!a.video_url || !a.audio_url) {\n throw new Error(\"Podaj video_url i audio_url.\");\n }\n const model = String(a.model || \"fal-ai/sync-lipsync/v2\");\n const input: Record = {\n video_url: String(a.video_url),\n audio_url: String(a.audio_url),\n sync_mode: String(a.sync_mode || \"cut_off\"),\n };\n const s = await submitRaw(model, input);\n return {\n ...s,\n hint: \"Po chwili: kling_result(response_url) -> video_url + play_url.\",\n };\n}\n\nfunction buildInput(a: Record, alias: string) {\n const isO3 = alias.startsWith(\"o3\");\n const input: Record = {\n prompt: String(a.prompt ?? \"\"),\n duration: String(a.duration ?? \"5\"),\n generate_audio: a.generate_audio === true,\n negative_prompt: String(a.negative_prompt ?? \"\"),\n cfg_scale: Number(a.cfg_scale ?? 0.5),\n };\n input[isO3 ? \"image_url\" : \"start_image_url\"] = String(a.image_url ?? \"\");\n if (a.end_image_url) input[\"end_image_url\"] = String(a.end_image_url);\n if (Array.isArray(a.elements) && a.elements.length) {\n input[\"elements\"] = a.elements;\n }\n if (Array.isArray(a.multi_prompt) && a.multi_prompt.length) {\n const totalDur = Number(a.duration ?? \"5\");\n const per = Math.max(1, Math.round(totalDur / a.multi_prompt.length));\n input[\"multi_prompt\"] = (a.multi_prompt as any[]).map((p) =>\n typeof p === \"string\" ? { prompt: p, duration: String(per) } : p\n );\n delete input[\"prompt\"];\n }\n return input;\n}\nasync function submit(a: Record) {\n const alias = String(a.model ?? \"o3-std\");\n const model = MODELS[alias];\n if (!model) throw new Error(`Nieznany model: ${alias}`);\n const r = await fetch(`${FAL}/${model}`, {\n method: \"POST\",\n headers: H(),\n body: JSON.stringify(buildInput(a, alias)),\n });\n const txt = await r.text();\n if (!r.ok) throw new Error(`fal submit ${r.status}: ${txt.slice(0, 300)}`);\n const j = JSON.parse(txt);\n return {\n request_id: j.request_id,\n status_url: j.status_url,\n response_url: j.response_url,\n model: alias,\n };\n}\nasync function submitRaw(modelPath: string, input: Record) {\n const r = await fetch(`${FAL}/${modelPath}`, {\n method: \"POST\",\n headers: H(),\n body: JSON.stringify(input),\n });\n const txt = await r.text();\n if (!r.ok) {\n throw new Error(`fal ${modelPath} ${r.status}: ${txt.slice(0, 300)}`);\n }\n const j = JSON.parse(txt);\n return {\n request_id: j.request_id,\n status_url: j.status_url,\n response_url: j.response_url,\n };\n}\nasync function doGenerate(a: Record) {\n const s = await submit(a);\n return {\n ...s,\n hint:\n \"Odpytuj kling_status(status_url); po COMPLETED -> kling_result(response_url).\",\n };\n}\nasync function getJson(u: string, label: string) {\n const r = await fetch(u, { headers: H() });\n const txt = await r.text();\n if (!r.ok) throw new Error(`fal ${label} ${r.status}: ${txt.slice(0, 300)}`);\n return JSON.parse(txt);\n}\nasync function doStatus(a: Record) {\n if (!a.status_url) throw new Error(\"Brak status_url.\");\n return await getJson(String(a.status_url), \"status\");\n}\nasync function doResult(a: Record) {\n if (!a.response_url) throw new Error(\"Brak response_url.\");\n const j = await getJson(String(a.response_url), \"result\");\n return {\n video_url: j.video?.url ?? j.video_url ?? null,\n duration: j.duration,\n raw: j,\n };\n}\nasync function doGenerateWait(a: Record) {\n const s = await submit(a);\n const maxWait = Number(a.max_wait_s ?? 45) * 1000;\n const t0 = Date.now();\n while (Date.now() - t0 < maxWait) {\n await new Promise((z) => setTimeout(z, 6000));\n let st: any;\n try {\n st = await getJson(s.status_url, \"status\");\n } catch {\n continue;\n }\n if (st.status === \"COMPLETED\") {\n const j = await getJson(s.response_url, \"result\");\n return {\n status: \"COMPLETED\",\n video_url: j.video?.url ?? null,\n model: s.model,\n request_id: s.request_id,\n };\n }\n }\n return {\n status: \"PENDING\",\n note: \"Jeszcze się generuje — kling_result(response_url) za chwilę.\",\n ...s,\n };\n}\nasync function doCompose(a: Record) {\n if (!Array.isArray(a.tracks)) throw new Error(\"Podaj tracks (tablica).\");\n const s = await submitRaw(\"fal-ai/ffmpeg-api/compose\", { tracks: a.tracks });\n return {\n ...s,\n hint: \"Po chwili: kling_result(response_url) -> video_url + play_url.\",\n };\n}\nasync function doConcat(a: Record) {\n const clips = a.clips as Array;\n if (!Array.isArray(clips) || !clips.length) throw new Error(\"Podaj clips.\");\n const def = Number(a.clip_seconds ?? 5);\n let t = 0;\n const kf = clips.map((c) => {\n const url = typeof c === \"string\" ? c : c.url;\n const dur = (typeof c === \"object\" && c.duration)\n ? Number(c.duration)\n : def;\n const k = { url, timestamp: t, duration: dur };\n t += dur;\n return k;\n });\n const tracks: any[] = [{ id: \"video\", type: \"video\", keyframes: kf }];\n if (a.audio_url) {\n tracks.push({\n id: \"audio\",\n type: \"audio\",\n keyframes: [{ url: String(a.audio_url), timestamp: 0, duration: t }],\n });\n }\n return await doCompose({ tracks });\n}\nasync function doBalance() {\n for (\n const path of [\"/billing/user/balance\", \"/billing/balance\", \"/users/me\"]\n ) {\n try {\n const r = await fetch(`${REST}${path}`, {\n headers: { \"Authorization\": `Key ${KEY}` },\n });\n if (r.ok) return { source: path, data: JSON.parse(await r.text()) };\n } catch (_e) { /* dalej */ }\n }\n return {\n balance: \"niedostępne przez API\",\n hint: \"Sprawdź w panelu fal.ai → Billing.\",\n };\n}\nfunction doModels() {\n return Object.entries(MODELS).map(([alias, id]) => ({ alias, model_id: id }));\n}\n\nasync function callTool(name: string, args: Record) {\n if (name === \"kling_upload\") return await doUpload(args);\n if (name === \"kling_from_gemini\") return await doFromGemini(args);\n if (name === \"kling_generate\") return await doGenerate(args);\n if (name === \"kling_status\") return await doStatus(args);\n if (name === \"kling_result\") return await doResult(args);\n if (name === \"kling_generate_wait\") return await doGenerateWait(args);\n if (name === \"video_concat\") return await doConcat(args);\n if (name === \"video_compose\") return await doCompose(args);\n if (name === \"lipsync\") return await doLipsync(args);\n if (name === \"kling_balance\") return await doBalance();\n if (name === \"kling_models\") return doModels();\n throw new Error(`Unknown tool: ${name}`);\n}\nfunction rpc(id: unknown, result?: unknown, error?: unknown) {\n const body: Record = { jsonrpc: \"2.0\", id };\n if (error) body.error = error;\n else body.result = result;\n return new Response(JSON.stringify(body), {\n headers: { \"content-type\": \"application/json\" },\n });\n}\nfunction playerPage(rawUrl: string, dlUrl: string) {\n return new Response(\n `\n\n

\n ⬇︎ Pobierz / Zapisz wideo\n`,\n { headers: { \"content-type\": \"text/html; charset=utf-8\" } },\n );\n}\nasync function rawProxy(u: string, dl: boolean, range: string | null) {\n const upstream = await fetch(u, range ? { headers: { range } } : {});\n const h = new Headers();\n h.set(\"content-type\", \"video/mp4\");\n h.set(\"accept-ranges\", \"bytes\");\n const cl = upstream.headers.get(\"content-length\");\n const cr = upstream.headers.get(\"content-range\");\n if (cl) h.set(\"content-length\", cl);\n if (cr) h.set(\"content-range\", cr);\n if (dl) h.set(\"content-disposition\", 'attachment; filename=\"wideo.mp4\"');\n return new Response(upstream.body, { status: upstream.status, headers: h });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n if (\n req.method === \"GET\" &&\n (url.pathname === \"/play\" || url.pathname === \"/raw\")\n ) {\n const u = url.searchParams.get(\"u\");\n if (!u) return new Response(\"podaj ?u=\", { status: 400 });\n if (url.pathname === \"/raw\") {\n return await rawProxy(\n u,\n url.searchParams.has(\"dl\"),\n req.headers.get(\"range\"),\n );\n }\n const raw = `${url.origin}/raw?u=${encodeURIComponent(u)}`;\n return playerPage(raw, `${raw}&dl=1`);\n }\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return new Response(\"Kling MCP v2.8. POST /mcp | GET /play?u=\");\n }\n if (\n req.method === \"POST\" && (url.pathname === \"/mcp\" || url.pathname === \"/\")\n ) {\n let msg: any;\n try {\n msg = await req.json();\n } catch {\n return rpc(null, undefined, { code: -32700, message: \"Parse error\" });\n }\n const { id, method, params } = msg ?? {};\n if (method === \"initialize\") {\n return rpc(id, {\n protocolVersion: \"2024-11-05\",\n capabilities: { tools: {} },\n serverInfo: { name: \"kling-mcp\", version: \"2.8.0\" },\n });\n }\n if (method === \"notifications/initialized\") {\n return new Response(null, { status: 204 });\n }\n if (method === \"tools/list\") return rpc(id, { tools: TOOLS });\n if (method === \"tools/call\") {\n try {\n const out = await callTool(params?.name, params?.arguments ?? {});\n if (out && typeof (out as any).video_url === \"string\") {\n (out as any).play_url = `${url.origin}/play?u=${\n encodeURIComponent((out as any).video_url)\n }`;\n }\n return rpc(id, {\n content: [{ type: \"text\", text: JSON.stringify(out, null, 2) }],\n });\n } catch (e) {\n return rpc(id, {\n content: [{ type: \"text\", text: `BŁĄD: ${(e as Error).message}` }],\n isError: true,\n });\n }\n }\n return rpc(id, undefined, {\n code: -32601,\n message: `Method not found: ${method}`,\n });\n }\n return new Response(\"Method not allowed\", { status: 405 });\n}","// ============================================================================\n// Kling (fal.ai) MCP connector — v2.9 (+ shot_type customize/intelligent dla multi_prompt; elements @Element1)\n// upload | from_gemini | generate | status | result | generate_wait\n// + video_concat | video_compose | lipsync | balance | models\n// GET /play?u= + GET /raw?u=. SEKRET: FAL_KEY\n// ============================================================================\nconst KEY = Deno.env.get(\"FAL_KEY\") ?? \"\";\nconst FAL = \"https://queue.fal.run\";\nconst REST = \"https://rest.alpha.fal.ai\";\nconst GEMINI_MCP = \"https://rafalwiktorowicz--824b5460548611f1ae1eee650bb23af1.web.val.run/mcp\";\nconst H = () => ({ \"Authorization\": `Key ${KEY}`, \"Content-Type\": \"application/json\" });\n\nconst MODELS: Record = {\n \"v3-pro\": \"fal-ai/kling-video/v3/pro/image-to-video\",\n \"v3-std\": \"fal-ai/kling-video/v3/standard/image-to-video\",\n \"o3-pro\": \"fal-ai/kling-video/o3/pro/image-to-video\",\n \"o3-std\": \"fal-ai/kling-video/o3/standard/image-to-video\",\n};\n\nconst TOOLS = [\n {\n name: \"kling_upload\",\n description: \"Wgrywa zdjęcie do fal i zwraca PUBLICZNY link (public_url). base64 (data URI lub czysty) ALBO source_url.\",\n inputSchema: {\n type: \"object\",\n properties: {\n base64: { type: \"string\" },\n source_url: { type: \"string\" },\n content_type: { type: \"string\", default: \"image/png\" },\n file_name: { type: \"string\", default: \"upload.png\" },\n },\n },\n },\n {\n name: \"kling_from_gemini\",\n description: \"Pobiera obraz z Gemini (image_id) SERWEROWO i wrzuca na fal -> public_url. Bez base64 w czacie.\",\n inputSchema: { type: \"object\", properties: { image_id: { type: \"string\" } }, required: [\"image_id\"] },\n },\n {\n name: \"kling_generate\",\n description: \"Zleca scenę wideo Klinga. Zwraca request_id + status_url + response_url.\",\n inputSchema: {\n type: \"object\",\n properties: {\n model: { type: \"string\", enum: [\"v3-pro\", \"v3-std\", \"o3-pro\", \"o3-std\"], default: \"o3-std\" },\n image_url: { type: \"string\", description: \"Publiczny URL klatki startowej\" },\n prompt: { type: \"string\" },\n duration: { type: \"string\", enum: [\"5\", \"10\", \"15\"], default: \"5\" },\n negative_prompt: { type: \"string\", default: \"\" },\n cfg_scale: { type: \"number\", default: 0.5 },\n generate_audio: { type: \"boolean\", default: false },\n end_image_url: { type: \"string\" },\n elements: { type: \"array\", items: { type: \"object\" }, description: \"Postacie/obiekty: [{frontal_image_url, reference_image_urls:[...]}]. W prompcie @Element1, @Element2.\" },\n multi_prompt: { type: \"array\", items: {}, description: \"Multi-shot: ['opis ujęcia 1','opis 2'] lub [{prompt,duration}].\" },\n shot_type: { type: \"string\", enum: [\"customize\", \"intelligent\"], default: \"customize\", description: \"Tylko przy multi_prompt. customize=my dzielimy ujęcia, intelligent=model planuje.\" },\n },\n required: [\"model\", \"image_url\", \"prompt\"],\n },\n },\n {\n name: \"kling_status\",\n description: \"Status joba (podaj status_url).\",\n inputSchema: { type: \"object\", properties: { status_url: { type: \"string\" } }, required: [\"status_url\"] },\n },\n {\n name: \"kling_result\",\n description: \"Gotowy film po COMPLETED (podaj response_url). Działa też dla video_concat/compose/lipsync.\",\n inputSchema: { type: \"object\", properties: { response_url: { type: \"string\" } }, required: [\"response_url\"] },\n },\n {\n name: \"kling_generate_wait\",\n description: \"Zleca scenę I czeka do max_wait_s.\",\n inputSchema: {\n type: \"object\",\n properties: {\n model: { type: \"string\", enum: [\"v3-pro\", \"v3-std\", \"o3-pro\", \"o3-std\"], default: \"o3-std\" },\n image_url: { type: \"string\" },\n prompt: { type: \"string\" },\n duration: { type: \"string\", enum: [\"5\", \"10\", \"15\"], default: \"5\" },\n negative_prompt: { type: \"string\", default: \"\" },\n cfg_scale: { type: \"number\", default: 0.5 },\n generate_audio: { type: \"boolean\", default: false },\n end_image_url: { type: \"string\" },\n elements: { type: \"array\", items: { type: \"object\" } },\n multi_prompt: { type: \"array\", items: {} },\n shot_type: { type: \"string\", enum: [\"customize\", \"intelligent\"], default: \"customize\" },\n max_wait_s: { type: \"number\", default: 45 },\n },\n required: [\"model\", \"image_url\", \"prompt\"],\n },\n },\n {\n name: \"video_concat\",\n description: \"Skleja klipy PO KOLEI (+ opc. 1 audio) przez fal compose. Zwraca response_url -> kling_result.\",\n inputSchema: {\n type: \"object\",\n properties: {\n clips: { type: \"array\", items: {}, description: \"URL-e klipów po kolei LUB {url,duration}\" },\n audio_url: { type: \"string\" },\n clip_seconds: { type: \"number\", default: 5 },\n },\n required: [\"clips\"],\n },\n },\n {\n name: \"video_compose\",\n description: \"Zaawansowane: surowe tracks wg fal-ai/ffmpeg-api/compose. Zwraca response_url -> kling_result.\",\n inputSchema: { type: \"object\", properties: { tracks: { type: \"array\", items: { type: \"object\" } } }, required: [\"tracks\"] },\n },\n {\n name: \"lipsync\",\n description: \"Lip-sync: wideo + audio (np. nasze ElevenLabs PL) -> usta zgrane. PEWNY sposób na polski. model: 'fal-ai/sync-lipsync/v2' (domyślnie) lub 'fal-ai/kling-video/lipsync/audio-to-video'. Zwraca response_url -> kling_result.\",\n inputSchema: {\n type: \"object\",\n properties: {\n video_url: { type: \"string\" },\n audio_url: { type: \"string\" },\n sync_mode: { type: \"string\", enum: [\"cut_off\", \"loop\", \"bounce\", \"silence\", \"remap\"], default: \"cut_off\" },\n model: { type: \"string\", default: \"fal-ai/sync-lipsync/v2\" },\n },\n required: [\"video_url\", \"audio_url\"],\n },\n },\n { name: \"kling_balance\", description: \"Saldo fal (best-effort).\", inputSchema: { type: \"object\", properties: {} } },\n { name: \"kling_models\", description: \"Lista modeli i aliasów.\", inputSchema: { type: \"object\", properties: {} } },\n];\n\nfunction b64ToBytes(b64: string): { bytes: Uint8Array; ct: string } {\n let ct = \"image/png\", data = b64;\n const m = b64.match(/^data:([^;]+);base64,(.*)$/s);\n if (m) { ct = m[1]; data = m[2]; }\n const bin = atob(data.replace(/\\s/g, \"\"));\n const out = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) out[i] = bin.charCodeAt(i);\n return { bytes: out, ct };\n}\n\nasync function doUpload(a: Record) {\n let bytes: Uint8Array, ct = String(a.content_type ?? \"image/png\");\n const fn = String(a.file_name ?? \"upload.png\");\n if (a.source_url) {\n const r = await fetch(String(a.source_url));\n if (!r.ok) throw new Error(`pobieranie source_url ${r.status}`);\n ct = r.headers.get(\"content-type\") ?? ct;\n bytes = new Uint8Array(await r.arrayBuffer());\n } else if (a.base64) {\n const p = b64ToBytes(String(a.base64));\n bytes = p.bytes; ct = p.ct || ct;\n } else throw new Error(\"Podaj base64 albo source_url.\");\n const init = await fetch(`${REST}/storage/upload/initiate?storage_type=fal-cdn-v3`, {\n method: \"POST\",\n headers: { \"Authorization\": `Key ${KEY}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ content_type: ct, file_name: fn }),\n });\n const itxt = await init.text();\n if (!init.ok) throw new Error(`initiate ${init.status}: ${itxt.slice(0, 200)}`);\n const { file_url, upload_url } = JSON.parse(itxt);\n const put = await fetch(upload_url, { method: \"PUT\", headers: { \"Content-Type\": ct }, body: bytes });\n if (!put.ok) throw new Error(`put ${put.status}: ${(await put.text()).slice(0, 150)}`);\n return { public_url: file_url, bytes: bytes.length, content_type: ct };\n}\n\nasync function doFromGemini(a: Record) {\n const gid = String(a.image_id || \"\");\n if (!gid) throw new Error(\"Podaj image_id.\");\n const r = await fetch(GEMINI_MCP, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ jsonrpc: \"2.0\", id: 1, method: \"tools/call\",\n params: { name: \"get_gemini_images\", arguments: { ids: [gid] } } }),\n });\n const txt = await r.text();\n if (!r.ok) throw new Error(`gemini ${r.status}: ${txt.slice(0, 200)}`);\n const inner = JSON.parse(txt)?.result?.content?.[0]?.text;\n if (!inner) throw new Error(\"brak content z Gemini\");\n const img = (JSON.parse(inner).images || [])[0];\n if (!img?.b64) throw new Error(\"brak b64 z Gemini\");\n return await doUpload({ base64: img.b64, content_type: img.mime || \"image/jpeg\", file_name: \"gemini.jpg\" });\n}\n\nasync function doLipsync(a: Record) {\n if (!a.video_url || !a.audio_url) throw new Error(\"Podaj video_url i audio_url.\");\n const model = String(a.model || \"fal-ai/sync-lipsync/v2\");\n const input: Record = {\n video_url: String(a.video_url),\n audio_url: String(a.audio_url),\n sync_mode: String(a.sync_mode || \"cut_off\"),\n };\n const s = await submitRaw(model, input);\n return { ...s, hint: \"Po chwili: kling_result(response_url) -> video_url + play_url.\" };\n}\n\nfunction buildInput(a: Record, alias: string) {\n const isO3 = alias.startsWith(\"o3\");\n const input: Record = {\n prompt: String(a.prompt ?? \"\"),\n duration: String(a.duration ?? \"5\"),\n generate_audio: a.generate_audio === true,\n negative_prompt: String(a.negative_prompt ?? \"\"),\n cfg_scale: Number(a.cfg_scale ?? 0.5),\n };\n input[isO3 ? \"image_url\" : \"start_image_url\"] = String(a.image_url ?? \"\");\n if (a.end_image_url) input[\"end_image_url\"] = String(a.end_image_url);\n if (Array.isArray(a.elements) && a.elements.length) input[\"elements\"] = a.elements;\n if (Array.isArray(a.multi_prompt) && a.multi_prompt.length) {\n const totalDur = Number(a.duration ?? \"5\");\n const per = Math.max(1, Math.round(totalDur / a.multi_prompt.length));\n input[\"multi_prompt\"] = (a.multi_prompt as any[]).map((p) =>\n typeof p === \"string\" ? { prompt: p, duration: String(per) } : p\n );\n input[\"shot_type\"] = String(a.shot_type ?? \"customize\");\n delete input[\"prompt\"];\n }\n return input;\n}\nasync function submit(a: Record) {\n const alias = String(a.model ?? \"o3-std\");\n const model = MODELS[alias];\n if (!model) throw new Error(`Nieznany model: ${alias}`);\n const r = await fetch(`${FAL}/${model}`, { method: \"POST\", headers: H(), body: JSON.stringify(buildInput(a, alias)) });\n const txt = await r.text();\n if (!r.ok) throw new Error(`fal submit ${r.status}: ${txt.slice(0, 300)}`);\n const j = JSON.parse(txt);\n return { request_id: j.request_id, status_url: j.status_url, response_url: j.response_url, model: alias };\n}\nasync function submitRaw(modelPath: string, input: Record) {\n const r = await fetch(`${FAL}/${modelPath}`, { method: \"POST\", headers: H(), body: JSON.stringify(input) });\n const txt = await r.text();\n if (!r.ok) throw new Error(`fal ${modelPath} ${r.status}: ${txt.slice(0, 300)}`);\n const j = JSON.parse(txt);\n return { request_id: j.request_id, status_url: j.status_url, response_url: j.response_url };\n}\nasync function doGenerate(a: Record) {\n const s = await submit(a);\n return { ...s, hint: \"Odpytuj kling_status(status_url); po COMPLETED -> kling_result(response_url).\" };\n}\nasync function getJson(u: string, label: string) {\n const r = await fetch(u, { headers: H() });\n const txt = await r.text();\n if (!r.ok) throw new Error(`fal ${label} ${r.status}: ${txt.slice(0, 300)}`);\n return JSON.parse(txt);\n}\nasync function doStatus(a: Record) {\n if (!a.status_url) throw new Error(\"Brak status_url.\");\n return await getJson(String(a.status_url), \"status\");\n}\nasync function doResult(a: Record) {\n if (!a.response_url) throw new Error(\"Brak response_url.\");\n const j = await getJson(String(a.response_url), \"result\");\n return { video_url: j.video?.url ?? j.video_url ?? null, duration: j.duration, raw: j };\n}\nasync function doGenerateWait(a: Record) {\n const s = await submit(a);\n const maxWait = Number(a.max_wait_s ?? 45) * 1000;\n const t0 = Date.now();\n while (Date.now() - t0 < maxWait) {\n await new Promise((z) => setTimeout(z, 6000));\n let st: any;\n try { st = await getJson(s.status_url, \"status\"); } catch { continue; }\n if (st.status === \"COMPLETED\") {\n const j = await getJson(s.response_url, \"result\");\n return { status: \"COMPLETED\", video_url: j.video?.url ?? null, model: s.model, request_id: s.request_id };\n }\n }\n return { status: \"PENDING\", note: \"Jeszcze się generuje — kling_result(response_url) za chwilę.\", ...s };\n}\nasync function doCompose(a: Record) {\n if (!Array.isArray(a.tracks)) throw new Error(\"Podaj tracks (tablica).\");\n const s = await submitRaw(\"fal-ai/ffmpeg-api/compose\", { tracks: a.tracks });\n return { ...s, hint: \"Po chwili: kling_result(response_url) -> video_url + play_url.\" };\n}\nasync function doConcat(a: Record) {\n const clips = a.clips as Array;\n if (!Array.isArray(clips) || !clips.length) throw new Error(\"Podaj clips.\");\n const def = Number(a.clip_seconds ?? 5);\n let t = 0;\n const kf = clips.map((c) => {\n const url = typeof c === \"string\" ? c : c.url;\n const dur = (typeof c === \"object\" && c.duration) ? Number(c.duration) : def;\n const k = { url, timestamp: t, duration: dur };\n t += dur;\n return k;\n });\n const tracks: any[] = [{ id: \"video\", type: \"video\", keyframes: kf }];\n if (a.audio_url) tracks.push({ id: \"audio\", type: \"audio\", keyframes: [{ url: String(a.audio_url), timestamp: 0, duration: t }] });\n return await doCompose({ tracks });\n}\nasync function doBalance() {\n for (const path of [\"/billing/user/balance\", \"/billing/balance\", \"/users/me\"]) {\n try {\n const r = await fetch(`${REST}${path}`, { headers: { \"Authorization\": `Key ${KEY}` } });\n if (r.ok) return { source: path, data: JSON.parse(await r.text()) };\n } catch (_e) { /* dalej */ }\n }\n return { balance: \"niedostępne przez API\", hint: \"Sprawdź w panelu fal.ai → Billing.\" };\n}\nfunction doModels() { return Object.entries(MODELS).map(([alias, id]) => ({ alias, model_id: id })); }\n\nasync function callTool(name: string, args: Record) {\n if (name === \"kling_upload\") return await doUpload(args);\n if (name === \"kling_from_gemini\") return await doFromGemini(args);\n if (name === \"kling_generate\") return await doGenerate(args);\n if (name === \"kling_status\") return await doStatus(args);\n if (name === \"kling_result\") return await doResult(args);\n if (name === \"kling_generate_wait\") return await doGenerateWait(args);\n if (name === \"video_concat\") return await doConcat(args);\n if (name === \"video_compose\") return await doCompose(args);\n if (name === \"lipsync\") return await doLipsync(args);\n if (name === \"kling_balance\") return await doBalance();\n if (name === \"kling_models\") return doModels();\n throw new Error(`Unknown tool: ${name}`);\n}\nfunction rpc(id: unknown, result?: unknown, error?: unknown) {\n const body: Record = { jsonrpc: \"2.0\", id };\n if (error) body.error = error; else body.result = result;\n return new Response(JSON.stringify(body), { headers: { \"content-type\": \"application/json\" } });\n}\nfunction playerPage(rawUrl: string, dlUrl: string) {\n return new Response(\n `\n\n

\n ⬇︎ Pobierz / Zapisz wideo\n`, { headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n}\nasync function rawProxy(u: string, dl: boolean, range: string | null) {\n const upstream = await fetch(u, range ? { headers: { range } } : {});\n const h = new Headers();\n h.set(\"content-type\", \"video/mp4\");\n h.set(\"accept-ranges\", \"bytes\");\n const cl = upstream.headers.get(\"content-length\");\n const cr = upstream.headers.get(\"content-range\");\n if (cl) h.set(\"content-length\", cl);\n if (cr) h.set(\"content-range\", cr);\n if (dl) h.set(\"content-disposition\", 'attachment; filename=\"wideo.mp4\"');\n return new Response(upstream.body, { status: upstream.status, headers: h });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n if (req.method === \"GET\" && (url.pathname === \"/play\" || url.pathname === \"/raw\")) {\n const u = url.searchParams.get(\"u\");\n if (!u) return new Response(\"podaj ?u=\", { status: 400 });\n if (url.pathname === \"/raw\") return await rawProxy(u, url.searchParams.has(\"dl\"), req.headers.get(\"range\"));\n const raw = `${url.origin}/raw?u=${encodeURIComponent(u)}`;\n return playerPage(raw, `${raw}&dl=1`);\n }\n if (req.method === \"GET\" && url.pathname === \"/\") return new Response(\"Kling MCP v2.9. POST /mcp | GET /play?u=\");\n if (req.method === \"POST\" && (url.pathname === \"/mcp\" || url.pathname === \"/\")) {\n let msg: any;\n try { msg = await req.json(); } catch { return rpc(null, undefined, { code: -32700, message: \"Parse error\" }); }\n const { id, method, params } = msg ?? {};\n if (method === \"initialize\") return rpc(id, { protocolVersion: \"2024-11-05\", capabilities: { tools: {} }, serverInfo: { name: \"kling-mcp\", version: \"2.9.0\" } });\n if (method === \"notifications/initialized\") return new Response(null, { status: 204 });\n if (method === \"tools/list\") return rpc(id, { tools: TOOLS });\n if (method === \"tools/call\") {\n try {\n const out = await callTool(params?.name, params?.arguments ?? {});\n if (out && typeof (out as any).video_url === \"string\") {\n (out as any).play_url = `${url.origin}/play?u=${encodeURIComponent((out as any).video_url)}`;\n }\n return rpc(id, { content: [{ type: \"text\", text: JSON.stringify(out, null, 2) }] });\n } catch (e) {\n return rpc(id, { content: [{ type: \"text\", text: `BŁĄD: ${(e as Error).message}` }], isError: true });\n }\n }\n return rpc(id, undefined, { code: -32601, message: `Method not found: ${method}` });\n }\n return new Response(\"Method not allowed\", { status: 405 });\n}","createdAt",["D",1781395669983],"branchVersion","branchId","7d540fb1-6309-41b6-9e3a-d71c4c965f9e","id","41c67c22-ed04-4711-b6b4-0e90d25ff121","Kling",["D",1781361227849],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Kling ","imageUrl","52376bcb-d641-4952-81c2-24aad07615a6","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e5fc1-0ea2-72fa-904c-6707220b8246","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",17,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","rafawiktorowicz","handle","displayName","Rafał Wiktorowicz","avatar","https://lh3.googleusercontent.com/a/ACg8ocKbp75cCjXsr6hEF5LeT4ePV1zdflGOWHOIG9GAIuLH5-GNTg=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":152,"_79":153,"_81":154,"_83":25},"tree",[146],"files",[146],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"6393054e-8ef2-42f8-8342-1da94a7a28ff","parentId","latest",["D",1781395669983],13,"label",[28],"pulls","branches",1,"forks","envVars",{"_143":137,"_145":61},"connections",{"_143":61,"_144":61},"count","unfilledCount","emptyCount",{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":147,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_148":149,"_27":150},["D",1781395669983],"children",[],[28],["D",1781361227849],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_124":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":122,"_197":-5,"_198":-7,"_199":-7,"_200":61,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":85,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v14