[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_164":165,"_166":167},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_61":134,"_16":-7,"_135":-5,"_17":136,"_137":138,"_28":139,"_21":140,"_23":141,"_142":-5,"_143":-5,"_144":-5,"_145":36,"_146":147,"_148":34,"_149":-5,"_150":-5,"_151":152},"routes/_app.x.$handle.$name._index",{"_11":12,"_13":14,"_15":-7,"_16":-7,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-7,"_26":-5,"_27":-5,"_28":29,"_30":-5,"_31":-5,"_32":-5,"_33":34,"_35":36,"_37":34},"handle","rafawiktorowicz","name","Kling","branchName","version","project",{"_39":78,"_13":14,"_50":79,"_80":-5,"_81":36,"_82":83,"_84":83,"_85":86,"_87":-5,"_88":89,"_90":-5,"_91":36,"_92":-5,"_93":-5,"_94":67,"_95":96,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":111,"_112":113,"_114":115,"_116":36},"tags",[],"counts",{"_66":67,"_68":69,"_70":67,"_71":72,"_73":74},"contents",[63],"readme","upstream","pull","files",[38],"preview","ahead","behind","showHomeCustomizationHint",true,"showHTTPPreviewSettingsHint",false,"hasHTTPFiles",{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":51,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_59":60,"_61":62},"id","e45a62e5-1b82-4205-979b-0b26ffa542d8","main.ts","fileId","e38ac600-6734-11f1-bbbb-1607ee4eb77e","parentId","branchId","7d540fb1-6309-41b6-9e3a-d71c4c965f9e","branchVersion",17,"latest","createdAt",["D",1783145728646],16,"fileType","http","content","// ============================================================================\n// Kling (fal.ai) MCP connector — v3.2 (v3.1 + video_last_frame: klatka z wideo -> public URL)\n// upload | from_gemini | generate | status | result | generate_wait\n// + video_concat | video_compose | lipsync | balance | models | video_to_audio | video_last_frame\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: {\n type: \"array\",\n items: { type: \"object\" },\n description:\n \"Postacie/obiekty: [{frontal_image_url, reference_image_urls:[...]}]. W prompcie @Element1, @Element2.\",\n },\n multi_prompt: {\n type: \"array\",\n items: {},\n description:\n \"Multi-shot: ['opis ujęcia 1','opis 2'] lub [{prompt,duration}].\",\n },\n shot_type: {\n type: \"string\",\n enum: [\"customize\", \"intelligent\"],\n default: \"customize\",\n description:\n \"Tylko przy multi_prompt. customize=my dzielimy ujęcia, intelligent=model planuje.\",\n },\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 multi_prompt: { type: \"array\", items: {} },\n shot_type: {\n type: \"string\",\n enum: [\"customize\", \"intelligent\"],\n default: \"customize\",\n },\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. NAJLEPSZY na polski. model domyślnie 'fal-ai/sync-lipsync/v3' (Sync Labs, native 4K). Alt: 'fal-ai/sync-lipsync/v2/pro', 'veed/lipsync', 'fal-ai/tavus/hummingbird'. Zwraca response_url -> kling_result. UWAGA: polskiego nikt nie benchmarkuje -> najpierw test 5s.\",\n inputSchema: {\n type: \"object\",\n properties: {\n video_url: { type: \"string\" },\n audio_url: { type: \"string\" },\n sync_mode: { type: \"string\", default: \"cut_off\" },\n model: { type: \"string\", default: \"fal-ai/sync-lipsync/v3\" },\n },\n required: [\"video_url\", \"audio_url\"],\n },\n },\n {\n name: \"video_to_audio\",\n description:\n \"SFX/dźwięki otoczenia zsynchronizowane z gotowym CICHYM klipem (Hunyuan-Video-Foley, 48kHz SOTA). Podaj video_url + prompt opisujący dźwięki (EN, np. 'old telephone ringing, quiet room ambience'). Zwraca response_url -> kling_result (wideo z dogranym dźwiękiem). Stosuj na ujęciach BEZ mówienia.\",\n inputSchema: {\n type: \"object\",\n properties: {\n video_url: { type: \"string\" },\n prompt: { type: \"string\", description: \"Opis dźwięków po angielsku.\" },\n guidance_scale: { type: \"number\", default: 4.5 },\n num_inference_steps: { type: \"number\", default: 50 },\n },\n required: [\"video_url\"],\n },\n },\n {\n name: \"video_last_frame\",\n description:\n \"Wycina klatkę z wideo (fal ffmpeg, sync) i zwraca PUBLICZNY image_url — do w Omni. frame_type: last|first|middle (domyślnie last). video_url musi być publiczny (bez kluczy w URL!).\",\n inputSchema: {\n type: \"object\",\n properties: {\n video_url: { type: \"string\" },\n frame_type: { type: \"string\", default: \"last\" },\n },\n required: [\"video_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/v3\");\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\nasync function doFoley(a: Record) {\n if (!a.video_url) throw new Error(\"Podaj video_url (cichy klip).\");\n const input: Record = {\n video_url: String(a.video_url),\n guidance_scale: Number(a.guidance_scale ?? 4.5),\n num_inference_steps: Number(a.num_inference_steps ?? 50),\n };\n // FIX v3.1: Hunyuan-Foley oczekuje pola text_prompt (nie prompt)\n if (a.prompt) input[\"text_prompt\"] = String(a.prompt);\n const s = await submitRaw(\"fal-ai/hunyuan-video-foley\", input);\n return {\n ...s,\n hint:\n \"Po chwili: kling_result(response_url) -> wideo z dźwiękiem + play_url.\",\n };\n}\n\n// NOWE v3.2: klatka z wideo (sync przez fal.run — szybka operacja)\nasync function doLastFrame(a: Record) {\n if (!a.video_url) throw new Error(\"Podaj video_url (publiczny).\");\n const input = {\n video_url: String(a.video_url),\n frame_type: String(a.frame_type ?? \"last\"),\n };\n const r = await fetch(\"https://fal.run/fal-ai/ffmpeg-api/extract-frame\", {\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 extract-frame ${r.status}: ${txt.slice(0, 250)}`);\n }\n const j = JSON.parse(txt);\n const u = j?.image?.url ?? j?.images?.[0]?.url ?? j?.url ?? \"\";\n if (!u) throw new Error(`brak obrazu w odpowiedzi: ${txt.slice(0, 250)}`);\n return { image_url: u, frame_type: input.frame_type };\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 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}`, {\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 === \"video_to_audio\") return await doFoley(args);\n if (name === \"video_last_frame\") return await doLastFrame(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 v3.2. 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: \"3.2.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}","deleted","label","children",[],"path",[41],{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":64,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_61":65},["D",1783145728646],[41],"pulls",0,"branches",1,"forks","envVars",{"_75":69,"_77":67},"connections",{"_75":67,"_76":67},"count","unfilledCount","emptyCount","41c67c22-ed04-4711-b6b4-0e90d25ff121",["D",1781361227849],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Kling ","imageUrl","userId","52376bcb-d641-4952-81c2-24aad07615a6","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019e5fc1-0ea2-72fa-904c-6707220b8246","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_133":129},"org",{"_11":12,"_126":127,"_128":129,"_88":89,"_130":131,"_132":36},"branch",{"_16":48,"_13":117,"_39":46,"_118":78,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":-5,"_124":14,"_125":12},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Rafał Wiktorowicz","avatar","https://lh3.googleusercontent.com/a/ACg8ocKbp75cCjXsr6hEF5LeT4ePV1zdflGOWHOIG9GAIuLH5-GNTg=s96-c","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_39":78,"_13":14,"_50":160,"_80":-5,"_81":36,"_82":83,"_84":83,"_85":86,"_87":-5,"_88":89,"_90":-5,"_91":36,"_92":-5,"_93":-5,"_94":67,"_95":96,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":161,"_112":162,"_114":163,"_116":36},"tree",[157],[157],{"_66":67,"_68":69,"_70":67,"_71":155,"_73":156},[153],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":64,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_61":154},[41],{"_75":69,"_77":67},{"_75":67,"_76":67},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":51,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_59":158,"_61":159},[],[41],["D",1781361227849],{"_11":12,"_133":129},{"_11":12,"_126":127,"_128":129,"_88":89,"_130":131,"_132":36},{"_16":48,"_13":117,"_39":46,"_118":78,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":-5,"_124":14,"_125":12},"ctx",{"_110":-5,"_150":197,"_198":199,"_200":201,"_202":36,"_203":36,"_204":36,"_205":34,"_206":-5,"_207":-7,"_208":-7,"_209":67,"_210":36,"_211":36,"_212":-5,"_213":36,"_214":36,"_215":36,"_216":-5},"ENV",{"_168":169,"_170":171,"_172":117,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196},"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"]