[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_116":-5,"_20":117,"_22":118,"_119":120,"_121":122,"_25":123,"_24":-5,"_124":-5,"_125":-5,"_126":53,"_127":128,"_129":44,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","rafawiktorowicz","name","flux","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":14,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","b6f08482-f773-4701-be8f-df83d31b7f25","main.ts","fileId","51aa89c2-64d3-11f1-aae4-1607ee4eb77e","parentId","branchId","bcc146d3-5c1d-4f8b-96a8-b5e98e0d9233","branchVersion",5,"latest",true,"createdAt",["D",1781104455626],4,"fileType","http","content","// ============================================================================\n// FLUX FILL — MCP serwer (Val Town / Deno) v1.0\n// Inpainting z PIXEL-LOCK: obszar POZA maską zostaje NIETKNIĘTY (1:1).\n// Model: BFL flux-pro-1.0-fill (Black Forest Labs)\n// Hosting wyników w blob, serwowane pod /img/ (jak val ChatGPT).\n//\n// WDROŻENIE:\n// 1. Nowy val na val.town → wklej całość → Save/Deploy.\n// 2. Ustaw sekret: FLUX_API_KEY = Twój klucz z https://dashboard.bfl.ai\n// (val przyjmie też BFL_API_KEY, gdyby tak był nazwany).\n// 3. URL vala dodaj jako connector MCP (jak chatgpt).\n//\n// MASKA (ważne):\n// - BIAŁE = obszar do WYPEŁNIENIA (inpaint / wymazania)\n// - CZARNE = ZACHOWAJ piksel w piksel\n// - PNG/JPEG, dokładnie te same wymiary co obraz.\n// Dla kart how-to-draw: maluj na biało obszar elementu do usunięcia,\n// prompt np. \"plain solid white background, nothing here\".\n// ============================================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst KEY = () =>\n Deno.env.get(\"FLUX_API_KEY\") || Deno.env.get(\"BFL_API_KEY\") || \"\";\nlet SELF_ORIGIN = \"\";\n\n// --- ładowanie obrazu/maski: url | data-url | id (blob) | surowy base64 -----\nasync function loadBytes(\n image: string,\n): Promise<{ bytes: Uint8Array; mime: string }> {\n if (/^https?:/i.test(image)) {\n const r = await fetch(image);\n if (!r.ok) throw new Error(`pobranie obrazu HTTP ${r.status}`);\n return {\n bytes: new Uint8Array(await r.arrayBuffer()),\n mime: r.headers.get(\"content-type\") || \"image/png\",\n };\n }\n if (image.startsWith(\"data:\")) {\n const mime = image.slice(5, image.indexOf(\";\")) || \"image/png\";\n const b = image.replace(/^data:[^,]+,/, \"\");\n return { bytes: Uint8Array.from(atob(b), (c) => c.charCodeAt(0)), mime };\n }\n const o = await blob.getJSON(`img:${image}`);\n if (o) {\n return {\n bytes: Uint8Array.from(atob(o.b64), (c) => c.charCodeAt(0)),\n mime: o.mime || \"image/png\",\n };\n }\n return {\n bytes: Uint8Array.from(atob(image), (c) => c.charCodeAt(0)),\n mime: \"image/png\",\n };\n}\n\nfunction toB64(bytes: Uint8Array): string {\n let s = \"\";\n const CH = 0x8000;\n for (let i = 0; i < bytes.length; i += CH) {\n s += String.fromCharCode(...bytes.subarray(i, i + CH));\n }\n return btoa(s);\n}\n\nasync function storeImage(\n b64: string,\n mime: string,\n): Promise<{ id: string; url: string }> {\n const id = crypto.randomUUID().replace(/-/g, \"\");\n await blob.setJSON(`img:${id}`, { b64, mime });\n return { id, url: `${SELF_ORIGIN}/img/${id}` };\n}\n\n// --- FLUX FILL: submit + polling ------------------------------------------\nasync function fluxFill(o: {\n image: string;\n mask: string;\n prompt: string;\n steps?: number;\n guidance?: number;\n output_format?: string;\n safety_tolerance?: number;\n}) {\n if (!KEY()) throw new Error(\"brak FLUX_API_KEY (ustaw sekret w valu)\");\n const img = await loadBytes(o.image);\n const msk = await loadBytes(o.mask);\n\n const body = {\n prompt: o.prompt ?? \"\",\n image: toB64(img.bytes),\n mask: toB64(msk.bytes),\n steps: o.steps ?? 50,\n guidance: o.guidance ?? 30,\n output_format: o.output_format ?? \"png\",\n safety_tolerance: o.safety_tolerance ?? 2,\n };\n\n const sub = await fetch(\"https://api.bfl.ai/v1/flux-pro-1.0-fill\", {\n method: \"POST\",\n headers: {\n \"x-key\": KEY(),\n \"Content-Type\": \"application/json\",\n \"accept\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n if (!sub.ok) {\n throw new Error(\n `BFL submit HTTP ${sub.status}: ${(await sub.text()).slice(0, 300)}`,\n );\n }\n const j = await sub.json();\n const pollUrl = j.polling_url ||\n `https://api.bfl.ai/v1/get_result?id=${j.id}`;\n\n // polling (do ~90 s)\n for (let i = 0; i < 60; i++) {\n await new Promise((r) => setTimeout(r, 1500));\n const pr = await fetch(pollUrl, {\n headers: { \"x-key\": KEY(), \"accept\": \"application/json\" },\n });\n if (!pr.ok) continue;\n const pj = await pr.json();\n const st = pj.status;\n if (st === \"Ready\") {\n const sample = pj.result?.sample;\n if (!sample) throw new Error(\"brak result.sample w odpowiedzi BFL\");\n const ir = await fetch(sample);\n const bytes = new Uint8Array(await ir.arrayBuffer());\n return await storeImage(toB64(bytes), \"image/png\");\n }\n if (\n st === \"Error\" || st === \"Failed\" ||\n st === \"Content Moderated\" || st === \"Request Moderated\"\n ) {\n throw new Error(`BFL status: ${st} ${JSON.stringify(pj.details || {})}`);\n }\n // \"Pending\" / \"Processing\" -> czekaj dalej\n }\n throw new Error(\"BFL timeout (polling > 90s)\");\n}\n\n// --- TOOLS ------------------------------------------------------------------\nconst TOOLS = [\n {\n name: \"flux_fill\",\n description:\n \"★ FLUX.1 Fill [pro] — inpainting z PIXEL-LOCK. Obszar POZA maską zostaje NIETKNIĘTY 1:1. \" +\n \"image = url | data-url | id | base64. mask = j.w. (BIAŁE=wypełnij/inpaint, CZARNE=zachowaj). \" +\n \"prompt opisuje co wstawić w białym obszarze (np. 'plain solid white background'). \" +\n \"steps(50), guidance(30). Zwraca {id,url}. Piksele przez get_image(id).\",\n inputSchema: {\n type: \"object\",\n properties: {\n image: { type: \"string\" },\n mask: { type: \"string\" },\n prompt: { type: \"string\" },\n steps: { type: \"number\" },\n guidance: { type: \"number\" },\n output_format: { type: \"string\" },\n safety_tolerance: { type: \"number\" },\n },\n required: [\"image\", \"mask\", \"prompt\"],\n },\n },\n {\n name: \"flux_kontext\",\n description:\n \"★ FLUX.1 Kontext [pro] — edycja INSTRUKCJĄ, bez maski. Usuwa/zmienia element komendą, \" +\n \"zachowując resztę (np. 'remove the body and legs, keep only the head, pure white background'). \" +\n \"image = url | data-url | id | base64. prompt = instrukcja po angielsku. Zwraca {id,url}.\",\n inputSchema: {\n type: \"object\",\n properties: {\n image: { type: \"string\" },\n prompt: { type: \"string\" },\n guidance: { type: \"number\" },\n output_format: { type: \"string\" },\n safety_tolerance: { type: \"number\" },\n },\n required: [\"image\", \"prompt\"],\n },\n },\n {\n name: \"flux_kontext_batch\",\n description:\n \"★ WIELOWĄTKOWO (pLimit) edycja instrukcją listy obrazów. edits=[{image,prompt,guidance?,output_format?,safety_tolerance?}], max_concurrent(4). Zwraca [{index,id,url}].\",\n inputSchema: {\n type: \"object\",\n properties: {\n edits: { type: \"array\", items: { type: \"object\" } },\n max_concurrent: { type: \"number\" },\n },\n required: [\"edits\"],\n },\n },\n {\n name: \"flux_fill_batch\",\n description:\n \"★ WIELOWĄTKOWO (pLimit) inpainting listy. edits=[{image,mask,prompt,steps?,guidance?,output_format?,safety_tolerance?}], max_concurrent(4). Zwraca [{index,id,url}].\",\n inputSchema: {\n type: \"object\",\n properties: {\n edits: { type: \"array\", items: { type: \"object\" } },\n max_concurrent: { type: \"number\" },\n },\n required: [\"edits\"],\n },\n },\n {\n name: \"get_images\",\n description:\n \"Hurtowo zwraca base64 wielu obrazów. ids=[...]. Duży payload → trafia do tool_results.\",\n inputSchema: {\n type: \"object\",\n properties: { ids: { type: \"array\", items: { type: \"string\" } } },\n required: [\"ids\"],\n },\n },\n {\n name: \"get_image\",\n description: \"Zwraca base64 obrazu wg id.\",\n inputSchema: {\n type: \"object\",\n properties: { id: { type: \"string\" } },\n required: [\"id\"],\n },\n },\n];\n\nasync function fluxKontext(o: {\n image: string;\n prompt: string;\n guidance?: number;\n output_format?: string;\n safety_tolerance?: number;\n}) {\n if (!KEY()) throw new Error(\"brak FLUX_API_KEY (ustaw sekret w valu)\");\n const img = await loadBytes(o.image);\n const body: any = {\n prompt: o.prompt ?? \"\",\n input_image: toB64(img.bytes),\n output_format: o.output_format ?? \"png\",\n safety_tolerance: o.safety_tolerance ?? 2,\n };\n if (o.guidance != null) body.guidance = o.guidance;\n const sub = await fetch(\"https://api.bfl.ai/v1/flux-kontext-pro\", {\n method: \"POST\",\n headers: {\n \"x-key\": KEY(),\n \"Content-Type\": \"application/json\",\n \"accept\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n if (!sub.ok) {\n throw new Error(\n `BFL kontext HTTP ${sub.status}: ${(await sub.text()).slice(0, 300)}`,\n );\n }\n const j = await sub.json();\n const pollUrl = j.polling_url ||\n `https://api.bfl.ai/v1/get_result?id=${j.id}`;\n for (let i = 0; i < 60; i++) {\n await new Promise((r) => setTimeout(r, 1500));\n const pr = await fetch(pollUrl, {\n headers: { \"x-key\": KEY(), \"accept\": \"application/json\" },\n });\n if (!pr.ok) continue;\n const pj = await pr.json();\n const st = pj.status;\n if (st === \"Ready\") {\n const sample = pj.result?.sample;\n if (!sample) throw new Error(\"brak result.sample (kontext)\");\n const ir = await fetch(sample);\n return await storeImage(\n toB64(new Uint8Array(await ir.arrayBuffer())),\n \"image/png\",\n );\n }\n if (\n st === \"Error\" || st === \"Failed\" ||\n (typeof st === \"string\" && st.includes(\"Moderated\"))\n ) {\n throw new Error(\n `BFL kontext status: ${st} ${JSON.stringify(pj.details || {})}`,\n );\n }\n }\n throw new Error(\"BFL kontext timeout (polling > 90s)\");\n}\n\n// pula współbieżności (pLimit) — przetwarza listę równolegle z limitem\nasync function pool(\n items: T[],\n limit: number,\n fn: (it: T, i: number) => Promise,\n): Promise {\n const res: any[] = new Array(items.length);\n let idx = 0;\n const n = Math.max(1, Math.min(limit || 4, items.length));\n const workers = Array.from({ length: n }, async () => {\n while (idx < items.length) {\n const i = idx++;\n try {\n res[i] = await fn(items[i], i);\n } catch (e) {\n res[i] = { index: i, error: (e as Error).message };\n }\n }\n });\n await Promise.all(workers);\n return res;\n}\n\nasync function dispatch(name: string, a: any): Promise {\n if (name === \"flux_kontext_batch\") {\n const r = await pool(\n a.edits ?? [],\n Number(a.max_concurrent) || 4,\n async (it: any, i) => ({\n index: i,\n ...(await fluxKontext({\n image: String(it.image),\n prompt: String(it.prompt ?? \"\"),\n guidance: it.guidance,\n output_format: it.output_format,\n safety_tolerance: it.safety_tolerance,\n })),\n }),\n );\n return JSON.stringify(r);\n }\n if (name === \"flux_fill_batch\") {\n const r = await pool(\n a.edits ?? [],\n Number(a.max_concurrent) || 4,\n async (it: any, i) => ({\n index: i,\n ...(await fluxFill({\n image: String(it.image),\n mask: String(it.mask),\n prompt: String(it.prompt ?? \"\"),\n steps: it.steps,\n guidance: it.guidance,\n output_format: it.output_format,\n safety_tolerance: it.safety_tolerance,\n })),\n }),\n );\n return JSON.stringify(r);\n }\n if (name === \"flux_kontext\") {\n return JSON.stringify(\n await fluxKontext({\n image: String(a.image),\n prompt: String(a.prompt ?? \"\"),\n guidance: a.guidance,\n output_format: a.output_format,\n safety_tolerance: a.safety_tolerance,\n }),\n );\n }\n if (name === \"flux_fill\") {\n return JSON.stringify(\n await fluxFill({\n image: String(a.image),\n mask: String(a.mask),\n prompt: String(a.prompt ?? \"\"),\n steps: a.steps,\n guidance: a.guidance,\n output_format: a.output_format,\n safety_tolerance: a.safety_tolerance,\n }),\n );\n }\n if (name === \"get_image\") {\n const o = await blob.getJSON(`img:${a.id}`);\n if (!o) throw new Error(`brak obrazu ${a.id}`);\n return JSON.stringify({ id: a.id, b64: o.b64, mime: o.mime });\n }\n if (name === \"get_images\") {\n const ids: string[] = a?.ids ?? [];\n const images: any[] = [];\n for (const id of ids) {\n const o = await blob.getJSON(`img:${id}`);\n if (o) images.push({ id, b64: o.b64, mime: o.mime });\n }\n let payload = JSON.stringify({ images });\n const TARGET = 1150000;\n if (payload.length < TARGET) {\n payload = JSON.stringify({\n images,\n _pad: \" \".repeat(TARGET - payload.length),\n });\n }\n return payload;\n }\n throw new Error(`Nieznane narzędzie: ${name}`);\n}\n\nconst ok = (id: any, result: any) =>\n Response.json({ jsonrpc: \"2.0\", id, result });\nconst er = (id: any, code: number, message: string) =>\n Response.json({ jsonrpc: \"2.0\", id, error: { code, message } });\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n SELF_ORIGIN = url.origin;\n\n if (req.method === \"GET\" && url.pathname.startsWith(\"/img/\")) {\n const id = url.pathname.slice(5);\n const o = await blob.getJSON(`img:${id}`);\n if (!o) return new Response(\"not found\", { status: 404 });\n const bin = Uint8Array.from(atob(o.b64), (c) => c.charCodeAt(0));\n return new Response(bin, {\n headers: {\n \"Content-Type\": o.mime || \"image/png\",\n \"Cache-Control\": \"public, max-age=31536000\",\n },\n });\n }\n if (req.method === \"GET\") {\n return new Response(\n \"FLUX Fill MCP v1.0 — działa. Narzędzie: flux_fill (inpainting pixel-lock). \" +\n (KEY() ? \"Klucz: OK.\" : \"UWAGA: brak FLUX_API_KEY.\"),\n { status: 200 },\n );\n }\n\n let body: any = {};\n try {\n body = await req.json();\n } catch {\n return er(null, -32700, \"Parse error\");\n }\n const { id, method, params } = body;\n if (method === \"initialize\") {\n return ok(id, {\n protocolVersion: \"2024-11-05\",\n capabilities: { tools: {} },\n serverInfo: { name: \"flux-fill\", version: \"1.0\" },\n });\n }\n if (method?.startsWith?.(\"notifications/\")) {\n return new Response(null, { status: 202 });\n }\n if (method === \"tools/list\") return ok(id, { tools: TOOLS });\n if (method === \"tools/call\") {\n try {\n return ok(id, {\n content: [{\n type: \"text\",\n text: await dispatch(params?.name, params?.arguments ?? {}),\n }],\n });\n } catch (e) {\n return ok(id, {\n content: [{ type: \"text\", text: `BŁĄD FLUX: ${(e as Error).message}` }],\n isError: true,\n });\n }\n }\n return er(id, -32601, \"Method not found\");\n}","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1781104455626],"children",[],[35],"9523a9bd-20c4-4456-8b6e-c7c4f0152596",["D",1781099419354],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","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",{"_11":12,"_115":111},"org",{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},"branch",{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"isOwned","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",{"_33":61,"_13":14,"_45":149,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":14,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":150,"_95":151,"_97":152,"_99":53},[146],"files",[146],"counts",{"_136":77,"_137":138,"_139":77,"_31":140,"_141":142},[134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":135},[35],"pulls","branches",1,"forks",{"_143":138,"_145":77},"connections",{"_143":77,"_144":77},"count","unfilledCount","emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":147,"_18":148},[],[35],["D",1781099419354],{"_11":12,"_115":111},{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"ctx",{"_93":-5,"_131":186,"_187":188,"_189":190,"_191":53,"_192":53,"_193":53,"_194":44,"_195":-5,"_196":-7,"_197":-7,"_198":77,"_199":53,"_200":53,"_201":-5,"_202":53,"_203":53,"_204":53,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":16,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"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"]