[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_146":147,"_148":149},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_83":65,"_84":85,"_63":-7,"_86":-5,"_13":87,"_88":89,"_11":90,"_91":92,"_93":94,"_95":-5,"_96":-5,"_97":-5,"_98":26,"_99":100,"_101":102,"_103":-5,"_104":-5,"_105":106},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","rafalwiktorowicz","id","824019f6-5486-11f1-ae1e-ee650bb23af1","name","Geminiok","createdAt",["D",1779307211277],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","gemini","imageUrl","userId","0d65c1b5-f226-4c7a-8c4b-30b17a9d544e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e308b-edd7-77ca-895e-c4f0d8ba1fdb","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_16":17,"_82":78},"org",{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",27,"main","82416748-5486-11f1-ae1e-ee650bb23af1","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","R W","avatar","https://lh3.googleusercontent.com/a/ACg8ocKAmj_qhWrVoXHf18hayjA4wNNLTkmWMqHGPR0qAaQrAmi6AA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_18":19,"_20":21,"_22":142,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":143,"_58":144,"_60":145,"_62":26},"tree",[137],[137],"counts",{"_125":40,"_126":127,"_128":40,"_129":130,"_131":132},"contents",[107],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_18":108,"_20":109,"_110":111,"_112":-5,"_113":66,"_114":64,"_115":102,"_22":116,"_63":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_84":124},"ca3d4dc2-f11f-48fe-ba19-71e18703c40b","main.ts","fileId","824b5460-5486-11f1-ae1e-ee650bb23af1","parentId","branchId","branchVersion","latest",["D",1785766587172],26,"fileType","http","content","// ============================================================\n// GEMINI 3.5 REDAKTOR/TŁUMACZ + WIZJA + RYSOWANIE + OMNI VIDEO — MCP (Val Town/Deno) v5.1\n// v5.0 + PATCH: polish_text_gemini przyjmuje `model` (flash|flash2|pro|surowe ID).\n// model:\"pro\" => gemini-3-pro-preview (Gemini 3 Pro na TEKŚCIE — do rady QUORUM).\n// Domyślnie nadal gemini-3.5-flash (redakcja/tłumaczenia — tanio).\n// ============================================================\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst MODEL = \"gemini-3.5-flash\"; // domyślny: redakcja/tłumaczenia + wizja (obraz IN, tekst OUT)\n\n// ===== PATCH: modele TEKSTOWE (mirror VIS_MODELS) — pozwala wybrać Pro na tekście =====\nconst TXT_MODELS: Record = {\n \"flash\": \"gemini-3.5-flash\",\n \"flash2\": \"gemini-3.1-flash\",\n \"pro\": \"gemini-3.1-pro-preview\", // POPRAWIONE 03.08.2026: gemini-3-pro-preview jest WYCOFANY => HTTP 404.\n \"pro3\": \"gemini-3-pro-preview\", // stary, zostawiony jawnie na wypadek potrzeby\n};\nconst resolveTxt = (m?: string) => !m ? MODEL : (TXT_MODELS[m] ?? m); // alias albo surowy ID\n\nconst DEFAULT_INSTRUCTION =\n `Jesteś polskim redaktorem. Popraw styl i gramatykę, naturalna polszczyzna ` +\n `(bez kalek z angielskiego). Zachowaj sens, liczby, terminy, nazwy własne ` +\n `oraz znaczniki/przypisy w nawiasach kwadratowych [N]. ` +\n `Zwróć WYŁĄCZNIE poprawiony tekst — bez wstępu i komentarzy.`;\n\nconst RETRY = {\n maxAttempts: 8,\n baseMs: 800,\n factor: 1.8,\n capMs: 20_000,\n retryStatuses: new Set([408, 425, 429, 500, 502, 503, 504]),\n};\nconst TIMEOUT_MS = 90_000;\nconst DEFAULT_CONCURRENCY = 12, MAX_CONCURRENCY = 24;\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst jitter = (ms: number) => Math.round(ms * (0.7 + Math.random() * 0.6));\nlet STAT = {\n retries: 0,\n hedges: 0,\n fallbacks: 0,\n errors: 0,\n groupMs: [] as number[],\n};\n\n// ===== PATCH HOST: helpery publicznego URL obrazu =====\nfunction extForMime(m: string): string {\n m = (m || \"\").toLowerCase();\n if (m.includes(\"png\")) return \"png\";\n if (m.includes(\"webp\")) return \"webp\";\n if (m.includes(\"jpeg\") || m.includes(\"jpg\")) return \"jpg\";\n if (m.includes(\"gif\")) return \"gif\";\n return \"png\";\n}\nfunction imgPublicUrl(id: string, mime: string, origin: string): string {\n return `${origin}/img/${encodeURIComponent(id)}.${extForMime(mime)}`;\n}\nfunction b64ToBytesG(b64: string): Uint8Array {\n const bin = atob(b64.replace(/^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 out;\n}\n\nclass GErr extends Error {\n status: number;\n retryable: boolean;\n retryAfterMs?: number;\n constructor(m: string, s: number, r: boolean) {\n super(m);\n this.status = s;\n this.retryable = r;\n }\n}\n\n// ===== PATCH: callOnce dostaje opcjonalny `model` (domyślnie MODEL=flash) =====\nasync function callOnce(\n text: string,\n instruction: string,\n model?: string,\n meta?: any,\n): Promise {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) throw new GErr(\"brak GEMINI_API_KEY w ENV\", 500, false);\n const url = `https://generativelanguage.googleapis.com/v1beta/models/${\n resolveTxt(model)\n }:generateContent`;\n const payload: any = {\n contents: [{ parts: [{ text }] }],\n generationConfig: { temperature: 0.3 },\n };\n if (instruction && instruction.trim()) {\n payload.systemInstruction = { parts: [{ text: instruction }] };\n }\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), TIMEOUT_MS);\n let res: Response;\n try {\n res = await fetch(url, {\n method: \"POST\",\n headers: { \"x-goog-api-key\": key, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n signal: ctrl.signal,\n });\n } catch (e) {\n throw new GErr(`network: ${(e as Error).message}`, 0, true);\n } finally {\n clearTimeout(t);\n }\n if (!res.ok) {\n const b = await res.text().catch(() => \"\");\n const err = new GErr(\n `HTTP ${res.status}: ${b.slice(0, 300)}`,\n res.status,\n RETRY.retryStatuses.has(res.status),\n );\n const ra = res.headers.get(\"retry-after\");\n if (ra) err.retryAfterMs = Number(ra) * 1000;\n throw err;\n }\n const data = await res.json();\n // ── POPRAWKA 03.08.2026 (Braun): ARTEFAKT DOSTAWCY.\n // Google zwraca responseId / usageMetadata / modelVersion, a val je gubił.\n // Bez nich KAŻDY głos Gemini stoi w rejestrze Rady jako BEZ_ARTEFAKTU\n // (false provenance rate = 1.00) i stan POŚWIADCZONE jest nieosiągalny.\n // `meta` jest przekazywane przez wywołującego => brak wyścigu przy batchu.\n if (meta && typeof meta === \"object\") {\n meta.responseId = data?.responseId ?? null;\n meta.usage = data?.usageMetadata ?? null;\n meta.modelVersion = data?.modelVersion ?? resolveTxt(model);\n meta.finishReason = data?.candidates?.[0]?.finishReason ?? null;\n }\n const out =\n data?.candidates?.[0]?.content?.parts?.map((p: any) => p?.text ?? \"\").join(\n \"\",\n ) ?? \"\";\n if (!out.trim()) {\n throw new GErr(\n `pusta odpowiedź (${data?.promptFeedback?.blockReason ?? \"empty\"})`,\n 200,\n false,\n );\n }\n return out.trim();\n}\n\n// === WIZJA: obraz + prompt -> TEKST/JSON ===\nconst VMODEL = MODEL; // domyślny model wizyjny (flash)\nconst VIS_MODELS: Record = {\n \"flash\": \"gemini-3.5-flash\",\n \"flash2\": \"gemini-3.1-flash\",\n \"pro\": \"gemini-3-pro-preview\", // Gemini 3 Pro (lepsza percepcja). Jeśli API zwróci 404 — podmień na właściwy ID.\n};\nconst resolveVis = (m?: string) => !m ? VMODEL : (VIS_MODELS[m] ?? m); // alias albo surowy ID\nasync function visionOnce(\n o: {\n prompt: string;\n image_b64?: string;\n image_url?: string;\n mime?: string;\n as_json?: boolean;\n model?: string;\n },\n): Promise {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) throw new GErr(\"brak GEMINI_API_KEY w ENV\", 500, false);\n let b64 = o.image_b64;\n let mime = o.mime || \"image/png\";\n if (!b64 && o.image_url) {\n const r = await fetch(o.image_url);\n if (!r.ok) {\n throw new GErr(\n `pobranie obrazu: HTTP ${r.status}`,\n r.status,\n RETRY.retryStatuses.has(r.status),\n );\n }\n mime = r.headers.get(\"content-type\") || mime;\n const buf = new Uint8Array(await r.arrayBuffer());\n let bin = \"\";\n for (const c of buf) bin += String.fromCharCode(c);\n b64 = btoa(bin);\n }\n if (!b64) throw new GErr(\"podaj image_b64 albo image_url\", 400, false);\n b64 = b64.replace(/^data:[^,]+,/, \"\");\n const vm = resolveVis(o.model);\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/${vm}:generateContent`;\n const payload: any = {\n contents: [{\n parts: [{ text: o.prompt }, {\n inline_data: { mime_type: mime, data: b64 },\n }],\n }],\n generationConfig: {\n temperature: 0.2,\n ...(o.as_json ? { responseMimeType: \"application/json\" } : {}),\n },\n };\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), TIMEOUT_MS);\n let res: Response;\n try {\n res = await fetch(url, {\n method: \"POST\",\n headers: { \"x-goog-api-key\": key, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n signal: ctrl.signal,\n });\n } catch (e) {\n throw new GErr(`network: ${(e as Error).message}`, 0, true);\n } finally {\n clearTimeout(t);\n }\n if (!res.ok) {\n const b = await res.text().catch(() => \"\");\n const err = new GErr(\n `HTTP ${res.status}: ${b.slice(0, 300)}`,\n res.status,\n RETRY.retryStatuses.has(res.status),\n );\n const ra = res.headers.get(\"retry-after\");\n if (ra) err.retryAfterMs = Number(ra) * 1000;\n throw err;\n }\n const data = await res.json();\n const out =\n data?.candidates?.[0]?.content?.parts?.map((p: any) => p?.text ?? \"\").join(\n \"\",\n ) ?? \"\";\n if (!out.trim()) {\n throw new GErr(\n `pusta odpowiedź (${data?.promptFeedback?.blockReason ?? \"empty\"})`,\n 200,\n false,\n );\n }\n return out.trim();\n}\nasync function visionPlan(\n o: Parameters[0],\n): Promise {\n let a = 0, wait = RETRY.baseMs, last: unknown;\n while (a < RETRY.maxAttempts) {\n try {\n return await visionOnce(o);\n } catch (e) {\n const g = e as GErr;\n if (!g.retryable) throw e;\n STAT.retries++;\n if (++a >= RETRY.maxAttempts) break;\n await sleep(g.retryAfterMs ?? jitter(Math.min(wait, RETRY.capMs)));\n wait *= RETRY.factor;\n }\n }\n throw last;\n}\n\n// === RYSOWANIE (image-out): Nano Banana / 2 / Pro ===\nconst IMG_MODELS: Record = {\n \"banana\": \"gemini-2.5-flash-image\",\n \"nano\": \"gemini-2.5-flash-image\",\n \"banana2\": \"gemini-3.1-flash-image\",\n \"nano2\": \"gemini-3.1-flash-image\",\n \"banana-pro\": \"gemini-3-pro-image-preview\",\n \"pro\": \"gemini-3-pro-image-preview\",\n};\nconst resolveImg = (m?: string) =>\n !m ? IMG_MODELS[\"banana\"] : (IMG_MODELS[m] ?? m);\n\nasync function geminiImageOnce(\n o: {\n prompt: string;\n model?: string;\n image_b64?: string;\n image_url?: string;\n mime?: string;\n size?: string;\n aspect?: string;\n },\n): Promise<{ b64: string; mime: string; model: string }> {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) throw new GErr(\"brak GEMINI_API_KEY w ENV\", 500, false);\n const model = resolveImg(o.model);\n let b64 = o.image_b64, mime = o.mime || \"image/png\";\n if (!b64 && o.image_url) {\n const r = await fetch(o.image_url);\n if (!r.ok) {\n throw new GErr(\n `pobranie obrazu: HTTP ${r.status}`,\n r.status,\n RETRY.retryStatuses.has(r.status),\n );\n }\n mime = r.headers.get(\"content-type\") || mime;\n const buf = new Uint8Array(await r.arrayBuffer());\n let bin = \"\";\n for (const c of buf) bin += String.fromCharCode(c);\n b64 = btoa(bin);\n }\n if (b64) b64 = b64.replace(/^data:[^,]+,/, \"\");\n const parts: any[] = [{ text: o.prompt }];\n if (b64) parts.push({ inline_data: { mime_type: mime, data: b64 } });\n const payload: any = {\n contents: [{ parts }],\n generationConfig: {\n responseModalities: [\"IMAGE\"], // jeśli błąd o modalities -> [\"IMAGE\",\"TEXT\"]\n ...((o.size || o.aspect)\n ? {\n imageConfig: {\n ...(o.aspect ? { aspectRatio: o.aspect } : {}),\n ...(o.size ? { imageSize: o.size } : {}),\n },\n }\n : {}),\n },\n };\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/${model}:generateContent`;\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), TIMEOUT_MS);\n let res: Response;\n try {\n res = await fetch(url, {\n method: \"POST\",\n headers: { \"x-goog-api-key\": key, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n signal: ctrl.signal,\n });\n } catch (e) {\n throw new GErr(`network: ${(e as Error).message}`, 0, true);\n } finally {\n clearTimeout(t);\n }\n if (!res.ok) {\n const b = await res.text().catch(() => \"\");\n throw new GErr(\n `HTTP ${res.status}: ${b.slice(0, 300)}`,\n res.status,\n RETRY.retryStatuses.has(res.status),\n );\n }\n const data = await res.json();\n const ps = data?.candidates?.[0]?.content?.parts ?? [];\n const img = ps.find((p: any) => p?.inlineData?.data || p?.inline_data?.data);\n const d = img?.inlineData ?? img?.inline_data;\n if (!d?.data) {\n throw new GErr(\n `brak obrazu w odpowiedzi (${\n JSON.stringify(data?.promptFeedback ?? \"\").slice(0, 160)\n })`,\n 200,\n false,\n );\n }\n return { b64: d.data, mime: d.mimeType ?? d.mime_type ?? \"image/png\", model };\n}\nasync function geminiImageRetry(o: Parameters[0]) {\n let a = 0, wait = RETRY.baseMs, last: unknown;\n while (a < RETRY.maxAttempts) {\n try {\n return await geminiImageOnce(o);\n } catch (e) {\n const g = e as GErr;\n if (!g.retryable) throw e;\n STAT.retries++;\n if (++a >= RETRY.maxAttempts) break;\n await sleep(g.retryAfterMs ?? jitter(Math.min(wait, RETRY.capMs)));\n wait *= RETRY.factor;\n }\n }\n throw last;\n}\n\n// === OMNI VIDEO (Interactions API) — v5.0 ===\nconst OMNI_MODEL = \"gemini-omni-flash-preview\";\nconst GBASE = \"https://generativelanguage.googleapis.com/v1beta\";\n\nasync function fetchAsB64Part(\n url: string,\n type: \"image\" | \"video\",\n fallbackMime: string,\n): Promise {\n const r0 = await fetch(url);\n if (!r0.ok) {\n throw new GErr(`ref ${type}: HTTP ${r0.status}`, r0.status, false);\n }\n const mm = r0.headers.get(\"content-type\") || fallbackMime;\n const buf = new Uint8Array(await r0.arrayBuffer());\n let bin = \"\";\n for (const c of buf) bin += String.fromCharCode(c);\n return { type, data: btoa(bin), mime_type: mm };\n}\n\nasync function omniGenerate(a: any): Promise {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) throw new GErr(\"brak GEMINI_API_KEY w ENV\", 500, false);\n const parts: any[] = [];\n for (const iid of (a?.image_ref_ids ?? [])) {\n const o: any = await blob.getJSON(String(iid));\n if (o?.b64) {\n parts.push({\n type: \"image\",\n data: o.b64,\n mime_type: o.mime || \"image/png\",\n });\n }\n }\n for (const u of (a?.image_ref_urls ?? [])) {\n parts.push(await fetchAsB64Part(String(u), \"image\", \"image/png\"));\n }\n for (const d of (a?.image_refs_b64 ?? [])) {\n parts.push({\n type: \"image\",\n data: String(d).replace(/^data:[^,]+,/, \"\"),\n mime_type: \"image/jpeg\",\n });\n }\n for (const vu of (a?.video_ref_urls ?? []).slice(0, 3)) {\n parts.push(await fetchAsB64Part(String(vu), \"video\", \"video/mp4\"));\n }\n parts.push({ type: \"text\", text: String(a?.prompt ?? \"\") });\n const input = parts.length === 1 ? String(a?.prompt ?? \"\") : parts;\n const body: any = {\n model: OMNI_MODEL,\n input,\n response_format: {\n type: \"video\",\n delivery: \"uri\",\n aspect_ratio: a?.aspect || \"16:9\",\n },\n };\n if (a?.previous_interaction_id) {\n body.previous_interaction_id = String(a.previous_interaction_id);\n }\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), TIMEOUT_MS);\n let r: Response;\n try {\n r = await fetch(`${GBASE}/interactions?key=${key}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n signal: ctrl.signal,\n });\n } catch (e) {\n throw new GErr(`network: ${(e as Error).message}`, 0, true);\n } finally {\n clearTimeout(t);\n }\n if (!r.ok) {\n throw new GErr(\n `HTTP ${r.status}: ${(await r.text()).slice(0, 300)}`,\n r.status,\n RETRY.retryStatuses.has(r.status),\n );\n }\n const j = await r.json();\n const uri = j?.output_video?.uri ?? \"\";\n return {\n interaction_id: j?.id,\n file_id: uri.split(\"/\").pop() ?? \"\",\n note: \"Polluj omni_status do ACTIVE, potem omni_download\",\n };\n}\n\n// ===== PATCH: polishOne dostaje opcjonalny `model` i przekazuje do callOnce =====\nasync function polishOne(\n text: string,\n instruction = DEFAULT_INSTRUCTION,\n model?: string,\n meta?: any,\n): Promise {\n let attempt = 0, wait = RETRY.baseMs, lastErr: unknown;\n while (attempt < RETRY.maxAttempts) {\n try {\n return await callOnce(text, instruction, model, meta);\n } catch (e) {\n lastErr = e;\n const ge = e as GErr;\n if (!ge.retryable) throw e;\n STAT.retries++;\n if (++attempt >= RETRY.maxAttempts) break;\n await sleep(ge.retryAfterMs ?? jitter(Math.min(wait, RETRY.capMs)));\n wait *= RETRY.factor;\n }\n }\n throw lastErr;\n}\nfunction hedged(text: string, instr: string, hedgeMs: number): Promise {\n if (!hedgeMs || hedgeMs <= 0) return polishOne(text, instr);\n let timer: any;\n const p1 = polishOne(text, instr);\n const p2 = new Promise((res, rej) => {\n timer = setTimeout(() => {\n STAT.hedges++;\n polishOne(text, instr).then(res, rej);\n }, hedgeMs);\n });\n return Promise.race([p1, p2]).finally(() => clearTimeout(timer));\n}\nfunction pLimit(limit: number) {\n let active = 0;\n const q: (() => void)[] = [];\n const next = () => {\n active--;\n q.shift()?.();\n };\n return (fn: () => Promise) =>\n new Promise((res, rej) => {\n const run = () => {\n active++;\n fn().then(res, rej).finally(next);\n };\n active < limit ? run() : q.push(run);\n });\n}\nasync function polishBatch(\n texts: string[],\n concurrency = DEFAULT_CONCURRENCY,\n instruction = DEFAULT_INSTRUCTION,\n) {\n const lim = pLimit(Math.max(1, Math.min(MAX_CONCURRENCY, concurrency)));\n const out = await Promise.all(texts.map((t, index) =>\n lim(async () => {\n try {\n return { index, ok: true, text: await polishOne(t, instruction) };\n } catch (e) {\n return { index, ok: false, error: (e as Error).message };\n }\n })\n ));\n out.sort((a, b) => a.index - b.index);\n return out;\n}\nconst SEP = \"\\n|||\\n\";\nconst chunk = (a: T[], n: number): T[][] => {\n const o: T[][] = [];\n for (let i = 0; i < a.length; i += n) o.push(a.slice(i, i + n));\n return o;\n};\nasync function translateGroup(\n group: string[],\n instruction: string,\n hedgeMs: number,\n): Promise {\n if (group.length === 1) return [await hedged(group[0], instruction, hedgeMs)];\n for (let attempt = 0; attempt < 2; attempt++) {\n const res = await hedged(group.join(SEP), instruction, hedgeMs);\n const parts = res.split(/\\n?\\|\\|\\|\\n?/).map((s) => s.trim());\n if (parts.length === group.length) return parts;\n }\n STAT.fallbacks++;\n return await Promise.all(group.map((t) => hedged(t, instruction, hedgeMs)));\n}\nasync function packedBatch(\n texts: string[],\n groupSize = 24,\n concurrency = DEFAULT_CONCURRENCY,\n instruction = DEFAULT_INSTRUCTION,\n hedgeMs = 8000,\n) {\n STAT = { retries: 0, hedges: 0, fallbacks: 0, errors: 0, groupMs: [] };\n const groups = chunk(texts, Math.max(1, groupSize));\n const lim = pLimit(Math.max(1, Math.min(MAX_CONCURRENCY, concurrency)));\n const r = await Promise.all(groups.map((g, gi) =>\n lim(async () => {\n const t = Date.now();\n let items: string[];\n try {\n items = await translateGroup(g, instruction, hedgeMs);\n } catch (e) {\n STAT.errors++;\n items = g;\n }\n STAT.groupMs.push(Date.now() - t);\n return { gi, items };\n })\n ));\n r.sort((a, b) => a.gi - b.gi);\n return r.flatMap((x) => x.items);\n}\nasync function translateDedup(\n texts: string[],\n groupSize: number,\n concurrency: number,\n instruction: string,\n hedgeMs: number,\n) {\n const map = new Map();\n const uniq: string[] = [];\n const idx = texts.map((t) => {\n if (!map.has(t)) {\n map.set(t, uniq.length);\n uniq.push(t);\n }\n return map.get(t)!;\n });\n const t0 = Date.now();\n const uniqOut = await packedBatch(\n uniq,\n groupSize,\n concurrency,\n instruction,\n hedgeMs,\n );\n const full = idx.map((u) => uniqOut[u]);\n return {\n full,\n stats: {\n total: texts.length,\n unique: uniq.length,\n dedup_saved: texts.length - uniq.length,\n ms: Date.now() - t0,\n sps: +(texts.length / ((Date.now() - t0) / 1000)).toFixed(1),\n groups: STAT.groupMs.length,\n retries: STAT.retries,\n hedges: STAT.hedges,\n fallbacks: STAT.fallbacks,\n errors: STAT.errors,\n },\n };\n}\n\n// === Google Drive (OAuth refresh-token) ===\nasync function driveAccessToken(): Promise {\n const cid = Deno.env.get(\"GOOGLE_CLIENT_ID\"),\n csec = Deno.env.get(\"GOOGLE_CLIENT_SECRET\"),\n rtok = Deno.env.get(\"GOOGLE_REFRESH_TOKEN\");\n if (!cid || !csec || !rtok) {\n throw new GErr(\n \"brak GOOGLE_CLIENT_ID / SECRET / REFRESH_TOKEN w ENV\",\n 500,\n false,\n );\n }\n const body = new URLSearchParams({\n client_id: cid,\n client_secret: csec,\n refresh_token: rtok,\n grant_type: \"refresh_token\",\n });\n const r = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body,\n });\n if (!r.ok) {\n throw new GErr(\n `OAuth token: HTTP ${r.status} ${(await r.text()).slice(0, 200)}`,\n r.status,\n false,\n );\n }\n const j = await r.json();\n if (!j.access_token) throw new GErr(\"OAuth: brak access_token\", 500, false);\n return j.access_token as string;\n}\nasync function driveDownloadJson(fileId: string, token: string): Promise {\n const r = await fetch(\n `https://www.googleapis.com/drive/v3/files/${fileId}?alt=media&supportsAllDrives=true`,\n { headers: { Authorization: `Bearer ${token}` } },\n );\n if (!r.ok) {\n throw new GErr(\n `Drive download: HTTP ${r.status} ${(await r.text()).slice(0, 200)}`,\n r.status,\n false,\n );\n }\n let parsed = await r.json();\n if (parsed && !Array.isArray(parsed) && parsed.data) parsed = parsed.data;\n return parsed;\n}\nasync function driveUploadJson(\n name: string,\n jsonStr: string,\n folderId: string | undefined,\n token: string,\n): Promise {\n const meta: any = { name, mimeType: \"application/json\" };\n if (folderId) meta.parents = [folderId];\n const boundary = \"b\" + Date.now() + Math.random().toString(36).slice(2);\n const payload =\n `--${boundary}\\r\\nContent-Type: application/json; charset=UTF-8\\r\\n\\r\\n${\n JSON.stringify(meta)\n }\\r\\n--${boundary}\\r\\nContent-Type: application/json\\r\\n\\r\\n${jsonStr}\\r\\n--${boundary}--`;\n const r = await fetch(\n \"https://www.googleapis.com/upload/drive/v3/files?uploadType=multipart&fields=id\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": `multipart/related; boundary=${boundary}`,\n },\n body: payload,\n },\n );\n if (!r.ok) {\n throw new GErr(\n `Drive upload: HTTP ${r.status} ${(await r.text()).slice(0, 200)}`,\n r.status,\n false,\n );\n }\n const j = await r.json();\n return j.id as string;\n}\n\n// === WIELOWĄTKOWE: wizja i rysowanie na LIŚCIE ===\nasync function visionBatch(items: any[], concurrency = DEFAULT_CONCURRENCY) {\n const lim = pLimit(Math.max(1, Math.min(MAX_CONCURRENCY, concurrency)));\n const out = await Promise.all(items.map((it, index) =>\n lim(async () => {\n try {\n let _b = it?.image_b64;\n if (!_b && it?.image_id) {\n const _o = await blob.getJSON(it.image_id);\n if (_o) _b = (_o as any).b64;\n }\n return {\n index,\n ok: true,\n text: await visionPlan({\n prompt: String(it?.prompt ?? \"\"),\n image_b64: _b,\n image_url: it?.image_url,\n mime: it?.mime,\n as_json: Boolean(it?.as_json),\n model: it?.model,\n }),\n };\n } catch (e) {\n return { index, ok: false, error: (e as Error).message };\n }\n })\n ));\n out.sort((a, b) => a.index - b.index);\n return out;\n}\nasync function geminiImageBatch(\n items: any[],\n concurrency = DEFAULT_CONCURRENCY,\n) {\n const lim = pLimit(Math.max(1, Math.min(MAX_CONCURRENCY, concurrency)));\n const out = await Promise.all(items.map((it, index) =>\n lim(async () => {\n try {\n const r = await geminiImageRetry({\n prompt: String(it?.prompt ?? \"\"),\n model: it?.model,\n image_b64: it?.image_b64,\n image_url: it?.image_url,\n mime: it?.mime,\n size: it?.size,\n aspect: it?.aspect,\n });\n const id = `img:${Date.now()}:${index}:${\n Math.random().toString(36).slice(2, 6)\n }`;\n await blob.setJSON(id, { b64: r.b64, mime: r.mime });\n return { index, ok: true, image_id: id, model: r.model, mime: r.mime };\n } catch (e) {\n return { index, ok: false, error: (e as Error).message };\n }\n })\n ));\n out.sort((a, b) => a.index - b.index);\n return out;\n}\n\n// --- NARZĘDZIA MCP ---\nconst TOOLS = [\n {\n name: \"polish_text_gemini\",\n description:\n \"Redaguje/OCENIA tekst przez Gemini. `instruction` = zasady. `model` = flash|flash2|pro|surowe ID (domyślnie flash 3.5; pro => gemini-3-pro-preview, do rady QUORUM). Retry+backoff.\",\n inputSchema: {\n type: \"object\",\n properties: {\n text: { type: \"string\" },\n instruction: { type: \"string\" },\n model: { type: \"string\" },\n },\n required: [\"text\"],\n },\n },\n {\n name: \"polish_batch_gemini\",\n description:\n \"★ WIELOWĄTKOWO redaguje LISTĘ tekstów (pLimit). Wspólna `instruction`. Wyniki w kolejności; błędne ok=false.\",\n inputSchema: {\n type: \"object\",\n properties: {\n texts: { type: \"array\", items: { type: \"string\" } },\n concurrency: { type: \"number\" },\n instruction: { type: \"string\" },\n },\n required: [\"texts\"],\n },\n },\n {\n name: \"pack_translate_gemini\",\n description:\n \"★★ NAJSZYBSZE: pakuje group_size segmentów w 1 zapytanie (|||), pula + hedging, ponów na dryf. Zwraca metryki + translations[].\",\n inputSchema: {\n type: \"object\",\n properties: {\n texts: { type: \"array\", items: { type: \"string\" } },\n group_size: { type: \"number\" },\n concurrency: { type: \"number\" },\n hedge_ms: { type: \"number\" },\n instruction: { type: \"string\" },\n },\n required: [\"texts\"],\n },\n },\n {\n name: \"vision_plan\",\n description:\n \"★ WIZJA: obraz + prompt -> TEKST/JSON. Podaj image_b64 ALBO image_url ALBO image_id (czyta obraz z wlasnego bloba Gemini, np. z gemini_image). as_json=true wymusza JSON. model: flash|pro|surowe ID (domyślnie flash). Retry+backoff.\",\n inputSchema: {\n type: \"object\",\n properties: {\n prompt: { type: \"string\" },\n image_id: { type: \"string\" },\n image_b64: { type: \"string\" },\n image_url: { type: \"string\" },\n mime: { type: \"string\" },\n as_json: { type: \"boolean\" },\n model: { type: \"string\" },\n },\n required: [\"prompt\"],\n },\n },\n {\n name: \"vision_plan_batch\",\n description:\n \"★ WIELOWĄTKOWO analizuje LISTĘ obrazów (pLimit). items=[{prompt,image_b64|image_url,mime,as_json,model}]. model: flash|pro|surowe ID. Wyniki w kolejności.\",\n inputSchema: {\n type: \"object\",\n properties: {\n items: { type: \"array\", items: { type: \"object\" } },\n concurrency: { type: \"number\" },\n },\n required: [\"items\"],\n },\n },\n {\n name: \"gemini_image\",\n description:\n \"★ GEMINI RYSUJE: generuje (lub edytuje gdy image_b64/image_url) obraz. model: banana|banana2|banana-pro|pro|surowe ID. size:1K/2K/4K, aspect np 1:1. Zwraca {image_id,url,model,mime} — url to PUBLICZNY link (do HeyGen), po piksele get_gemini_images.\",\n inputSchema: {\n type: \"object\",\n properties: {\n prompt: { type: \"string\" },\n model: { type: \"string\" },\n image_b64: { type: \"string\" },\n image_url: { type: \"string\" },\n mime: { type: \"string\" },\n size: { type: \"string\" },\n aspect: { type: \"string\" },\n },\n required: [\"prompt\"],\n },\n },\n {\n name: \"gemini_image_batch\",\n description:\n \"★ WIELOWĄTKOWO rysuje LISTĘ (pLimit) — np. ten sam prompt na kilku modelach naraz. items=[{prompt,model,image_b64|image_url,mime,size,aspect}]. Zwraca [{index,ok,image_id,url,model}].\",\n inputSchema: {\n type: \"object\",\n properties: {\n items: { type: \"array\", items: { type: \"object\" } },\n concurrency: { type: \"number\" },\n },\n required: [\"items\"],\n },\n },\n {\n name: \"get_gemini_images\",\n description:\n \"★ Zwraca DUŻY payload {images:[{id,b64,mime}]} dla ids (zrzut na dysk jak get_images).\",\n inputSchema: {\n type: \"object\",\n properties: { ids: { type: \"array\", items: { type: \"string\" } } },\n required: [\"ids\"],\n },\n },\n {\n name: \"omni_generate\",\n description:\n \"★ OMNI VIDEO: klip ~10s 720p z audio ($0.10/s!). Prompt EN, tagi .. i [0-3s]. Refy: image_ref_ids (blob z gemini_image), image_ref_urls (dowolny URL, też ChatGPT po host_url), image_refs_b64, video_ref_urls (max 3 klipy ≤3s — model może na razie ignorować). Max 7 obrazów łącznie. previous_interaction_id = edycja tamtego klipu (seria: zawsze ID mastera, max 3 edycje/sesję). Zwraca {interaction_id,file_id}.\",\n inputSchema: {\n type: \"object\",\n properties: {\n prompt: { type: \"string\" },\n image_ref_ids: { type: \"array\", items: { type: \"string\" } },\n image_ref_urls: { type: \"array\", items: { type: \"string\" } },\n image_refs_b64: { type: \"array\", items: { type: \"string\" } },\n video_ref_urls: { type: \"array\", items: { type: \"string\" } },\n aspect: { type: \"string\" },\n previous_interaction_id: { type: \"string\" },\n },\n required: [\"prompt\"],\n },\n },\n {\n name: \"omni_result\",\n description:\n \"Pobiera interakcję Omni po interaction_id: zwraca {status,file_id} gdy wideo gotowe (albo surowy skrót odpowiedzi).\",\n inputSchema: {\n type: \"object\",\n properties: { interaction_id: { type: \"string\" } },\n required: [\"interaction_id\"],\n },\n },\n {\n name: \"omni_status\",\n description: \"Stan pliku wideo Omni: {state}. Czekaj na ACTIVE.\",\n inputSchema: {\n type: \"object\",\n properties: { file_id: { type: \"string\" } },\n required: [\"file_id\"],\n },\n },\n {\n name: \"omni_download\",\n description:\n \"Po ACTIVE zwraca URL mp4 (z kluczem API — link PRYWATNY, do publikacji przepuść przez imgutils:host_url).\",\n inputSchema: {\n type: \"object\",\n properties: { file_id: { type: \"string\" } },\n required: [\"file_id\"],\n },\n },\n {\n name: \"stash_texts\",\n description:\n \"★ Wrzuca źródło (tablica stringów) pod job_id. Raz — potem każdy język tani. Zwraca {job_id,total,unique}.\",\n inputSchema: {\n type: \"object\",\n properties: {\n job_id: { type: \"string\" },\n texts: { type: \"array\", items: { type: \"string\" } },\n },\n required: [\"job_id\", \"texts\"],\n },\n },\n {\n name: \"translate_job\",\n description:\n \"★★ Tłumaczy zestashowane źródło (dedup + równolegle), zapis w magazynie, zwraca {result_id,count,stats}. Treść przez get_translations.\",\n inputSchema: {\n type: \"object\",\n properties: {\n job_id: { type: \"string\" },\n target_lang: { type: \"string\" },\n instruction: { type: \"string\" },\n group_size: { type: \"number\" },\n concurrency: { type: \"number\" },\n hedge_ms: { type: \"number\" },\n },\n required: [\"job_id\", \"target_lang\", \"instruction\"],\n },\n },\n {\n name: \"get_translations\",\n description:\n \"★ Zwraca DUŻY payload tłumaczeń dla result_id (zrzut na dysk).\",\n inputSchema: {\n type: \"object\",\n properties: { result_id: { type: \"string\" } },\n required: [\"result_id\"],\n },\n },\n {\n name: \"translate_url\",\n description:\n \"★★★ Val pobiera źródło (JSON) z source_url/source_file_id, tłumaczy, zapisuje. Zwraca {result_id,count,stats}.\",\n inputSchema: {\n type: \"object\",\n properties: {\n source_url: { type: \"string\" },\n source_file_id: { type: \"string\" },\n target_lang: { type: \"string\" },\n instruction: { type: \"string\" },\n group_size: { type: \"number\" },\n concurrency: { type: \"number\" },\n hedge_ms: { type: \"number\" },\n },\n required: [\"target_lang\", \"instruction\"],\n },\n },\n {\n name: \"translate_url_to_drive\",\n description:\n \"★★★★ Val pobiera źródło, tłumaczy i ZAPISUJE wynik JSON na Drive. Zwraca {result_file_id,name,count,stats}. Wymaga ENV Drive.\",\n inputSchema: {\n type: \"object\",\n properties: {\n source_url: { type: \"string\" },\n source_file_id: { type: \"string\" },\n target_lang: { type: \"string\" },\n instruction: { type: \"string\" },\n dest_folder_id: { type: \"string\" },\n dest_name: { type: \"string\" },\n group_size: { type: \"number\" },\n concurrency: { type: \"number\" },\n hedge_ms: { type: \"number\" },\n },\n required: [\"target_lang\", \"instruction\"],\n },\n },\n];\n\n// ===== PATCH HOST: dispatch przyjmuje origin (do budowy publicznych URL-i) =====\nasync function dispatch(name: string, a: any, origin = \"\"): Promise {\n if (name === \"polish_text_gemini\") {\n // PATCH: przekazujemy a?.model (flash|flash2|pro|surowe ID) do polishOne\n // POPRAWKA 03.08.2026: zwracamy JSON z ARTEFAKTEM DOSTAWCY — kształt taki sam\n // jak u Sola ({text, response_id, model, usage}), żeby rejestr Rady traktował\n // obie rodziny jednakowo. `raw:true` przywraca stare zachowanie (goły tekst)\n // dla wszystkiego, co czyta ten tool po staremu.\n const meta: any = {};\n const out = await polishOne(\n String(a?.text ?? \"\"),\n a?.instruction ?? DEFAULT_INSTRUCTION,\n a?.model,\n meta,\n );\n if (a?.raw === true) return out;\n return JSON.stringify({\n text: out,\n response_id: meta.responseId ?? null,\n model: meta.modelVersion ?? resolveTxt(a?.model),\n usage: meta.usage ?? null,\n finish_reason: meta.finishReason ?? null,\n });\n }\n if (name === \"polish_batch_gemini\") {\n return JSON.stringify(\n await polishBatch(\n (a?.texts ?? []).map(String),\n Number(a?.concurrency) || DEFAULT_CONCURRENCY,\n a?.instruction ?? DEFAULT_INSTRUCTION,\n ),\n null,\n 2,\n );\n }\n if (name === \"pack_translate_gemini\") {\n const t0 = Date.now();\n const tr = await packedBatch(\n (a?.texts ?? []).map(String),\n Number(a?.group_size) || 24,\n Number(a?.concurrency) || DEFAULT_CONCURRENCY,\n a?.instruction ?? DEFAULT_INSTRUCTION,\n a?.hedge_ms === undefined ? 8000 : Number(a.hedge_ms),\n );\n const ms = Date.now() - t0;\n const gm = STAT.groupMs.slice().sort((x, y) => x - y);\n const p95 = gm.length\n ? gm[Math.min(gm.length - 1, Math.floor(0.95 * gm.length))]\n : 0;\n const avg = gm.length\n ? Math.round(gm.reduce((x, y) => x + y, 0) / gm.length)\n : 0;\n return JSON.stringify({\n ms,\n count: tr.length,\n sps: +(tr.length / (ms / 1000)).toFixed(1),\n groups: gm.length,\n retries: STAT.retries,\n hedges: STAT.hedges,\n fallbacks: STAT.fallbacks,\n errors: STAT.errors,\n group_ms: { min: gm[0] || 0, avg, p95, max: gm[gm.length - 1] || 0 },\n translations: tr,\n });\n }\n if (name === \"vision_plan\") {\n let _b64 = a?.image_b64;\n if (!_b64 && a?.image_id) {\n const _o = await blob.getJSON(a.image_id);\n if (_o) _b64 = (_o as any).b64;\n }\n return await visionPlan({\n prompt: String(a?.prompt ?? \"\"),\n image_b64: _b64,\n image_url: a?.image_url,\n mime: a?.mime,\n as_json: Boolean(a?.as_json),\n model: a?.model,\n });\n }\n if (name === \"vision_plan_batch\") {\n return JSON.stringify(\n await visionBatch(\n a?.items ?? [],\n Number(a?.concurrency) || DEFAULT_CONCURRENCY,\n ),\n null,\n 2,\n );\n }\n if (name === \"gemini_image\") {\n const r = await geminiImageRetry({\n prompt: String(a?.prompt ?? \"\"),\n model: a?.model,\n image_b64: a?.image_b64,\n image_url: a?.image_url,\n mime: a?.mime,\n size: a?.size,\n aspect: a?.aspect,\n });\n const id = `img:${Date.now()}:${Math.random().toString(36).slice(2, 8)}`;\n await blob.setJSON(id, { b64: r.b64, mime: r.mime });\n return JSON.stringify({\n image_id: id,\n url: imgPublicUrl(id, r.mime, origin),\n model: r.model,\n mime: r.mime,\n });\n }\n if (name === \"gemini_image_batch\") {\n const arr = await geminiImageBatch(\n a?.items ?? [],\n Number(a?.concurrency) || DEFAULT_CONCURRENCY,\n );\n for (const it of arr as any[]) {\n if (it && it.image_id) {\n it.url = imgPublicUrl(it.image_id, it.mime || \"image/png\", origin);\n }\n }\n return JSON.stringify(arr, null, 2);\n }\n if (name === \"get_gemini_images\") {\n const ids: string[] = a?.ids ?? [];\n const images: any[] = [];\n for (const id of ids) {\n const o = await blob.getJSON(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 if (name === \"omni_generate\") {\n return JSON.stringify(await omniGenerate(a));\n }\n if (name === \"omni_result\") {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) throw new GErr(\"brak GEMINI_API_KEY w ENV\", 500, false);\n const r = await fetch(\n `${GBASE}/interactions/${a.interaction_id}?key=${key}`,\n );\n const txt = await r.text();\n const m = txt.match(/files\\/([A-Za-z0-9_.-]+)/);\n let status = String(r.status);\n try {\n status = JSON.parse(txt)?.status ?? status;\n } catch {}\n return JSON.stringify({\n status,\n file_id: m ? m[1] : \"\",\n raw: m ? undefined : txt.slice(0, 1500),\n });\n }\n if (name === \"omni_status\") {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) throw new GErr(\"brak GEMINI_API_KEY w ENV\", 500, false);\n const r = await fetch(`${GBASE}/files/${a.file_id}?key=${key}`);\n const j = await r.json();\n return JSON.stringify({\n file_id: a.file_id,\n state: j?.state ?? j?.error?.message,\n });\n }\n if (name === \"omni_download\") {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) throw new GErr(\"brak GEMINI_API_KEY w ENV\", 500, false);\n return JSON.stringify({\n url: `${GBASE}/files/${a.file_id}:download?alt=media&key=${key}`,\n });\n }\n if (name === \"stash_texts\") {\n const texts = (a?.texts ?? []).map(String);\n await blob.setJSON(`src:${a.job_id}`, texts);\n return JSON.stringify({\n job_id: a.job_id,\n total: texts.length,\n unique: new Set(texts).size,\n });\n }\n if (name === \"translate_job\") {\n const texts: string[] = await blob.getJSON(`src:${a.job_id}`);\n if (!texts) {\n throw new GErr(\n `brak źródła dla job_id=${a.job_id} — najpierw stash_texts`,\n 400,\n false,\n );\n }\n const { full, stats } = await translateDedup(\n texts,\n Number(a?.group_size) || 40,\n Number(a?.concurrency) || MAX_CONCURRENCY,\n a?.instruction ?? \"\",\n a?.hedge_ms === undefined ? 0 : Number(a.hedge_ms),\n );\n const result_id = `res:${a.job_id}:${a.target_lang}`;\n await blob.setJSON(result_id, full);\n return JSON.stringify({ result_id, count: full.length, stats });\n }\n if (name === \"get_translations\") {\n const full: string[] = await blob.getJSON(a.result_id);\n if (!full) throw new GErr(`brak wyniku ${a.result_id}`, 400, false);\n return JSON.stringify({\n result_id: a.result_id,\n count: full.length,\n translations: full,\n });\n }\n if (name === \"translate_url\" || name === \"translate_url_to_drive\") {\n let texts: any;\n if (a?.source_file_id) {\n const tok0 = await driveAccessToken();\n texts = await driveDownloadJson(String(a.source_file_id), tok0);\n } else {\n const rr = await fetch(String(a.source_url));\n if (!rr.ok) {\n throw new GErr(\n `nie pobrano źródła: HTTP ${rr.status}`,\n rr.status,\n false,\n );\n }\n texts = await rr.json();\n }\n if (!Array.isArray(texts)) {\n throw new GErr(\n \"źródło musi być płaską tablicą JSON stringów\",\n 400,\n false,\n );\n }\n const { full, stats } = await translateDedup(\n texts.map(String),\n Number(a?.group_size) || 40,\n Number(a?.concurrency) || MAX_CONCURRENCY,\n a?.instruction ?? \"\",\n a?.hedge_ms === undefined ? 0 : Number(a.hedge_ms),\n );\n if (name === \"translate_url\") {\n const result_id = `res:url:${a.target_lang}:${Date.now()}`;\n await blob.setJSON(result_id, full);\n return JSON.stringify({ result_id, count: full.length, stats });\n }\n const token = await driveAccessToken();\n const fname = a?.dest_name || `result_${a.target_lang}_${Date.now()}.json`;\n let payload = JSON.stringify(full);\n const TARGET = 1150000;\n if (payload.length < TARGET) {\n payload = JSON.stringify({\n data: full,\n _pad: \" \".repeat(TARGET - payload.length),\n });\n }\n const fileId = await driveUploadJson(\n fname,\n payload,\n a?.dest_folder_id,\n token,\n );\n return JSON.stringify({\n result_file_id: fileId,\n name: fname,\n count: full.length,\n stats,\n padded: payload.length >= TARGET,\n });\n }\n throw new GErr(`Nieznane narzędzie: ${name}`, 400, false);\n}\n\n// --- TRANSPORT (MCP JSON-RPC + REST test) ---\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 } });\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const origin = `${url.protocol}//${url.host}`;\n\n // ===== PATCH HOST: publiczny serw obrazu /img/. =====\n if (req.method === \"GET\" && url.pathname.startsWith(\"/img/\")) {\n const raw = url.pathname.slice(5).replace(/\\.[a-z0-9]+$/i, \"\");\n const id = decodeURIComponent(raw);\n const o = await blob.getJSON(id);\n if (!o || !(o as any).b64) {\n return new Response(\"not found\", { status: 404 });\n }\n const mime = (o as any).mime || \"image/png\";\n return new Response(b64ToBytesG((o as any).b64), {\n headers: {\n \"Content-Type\": mime,\n \"Cache-Control\": \"public, max-age=604800\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n\n // ── PATCH 03.08.2026: BEZ AUTORYZACJI, JAWNIE.\n // Klient MCP przy podpinaniu pyta o metadane OAuth pod /.well-known/*.\n // Ten val odpowiadal 200 z tekstem opisu na KAZDY GET — wiec klient bral\n // ten opis za odpowiedz serwera logowania i probowal sie rejestrowac\n // (\"Couldn't register with sign-in service\"). Zwracamy czyste 404:\n // \"nie mam OAuth, lacz sie bez autoryzacji\".\n if (req.method === \"GET\" && url.pathname.startsWith(\"/.well-known/\")) {\n return new Response(\"no auth required\", { status: 404 });\n }\n\n if (req.method === \"GET\" && url.searchParams.has(\"text\")) {\n try {\n return Response.json({\n ok: true,\n model: resolveTxt(url.searchParams.get(\"model\") ?? undefined),\n text: await polishOne(\n url.searchParams.get(\"text\")!,\n DEFAULT_INSTRUCTION,\n url.searchParams.get(\"model\") ?? undefined,\n ),\n });\n } catch (e) {\n return Response.json({ ok: false, error: (e as Error).message }, {\n status: 502,\n });\n }\n }\n if (req.method === \"GET\") {\n return new Response(\n `Gemini MCP v5.1 (PRO-TEXT+HOST+OMNI) — działa. Tekst domyślny: ${MODEL} (pro => gemini-3-pro-preview), wideo: ${OMNI_MODEL}. Tooly: polish_text_gemini(+model), polish_batch_gemini, pack_translate_gemini, vision_plan, vision_plan_batch, gemini_image, gemini_image_batch, get_gemini_images, omni_generate, omni_result, omni_status, omni_download, stash_texts, translate_job, get_translations, translate_url, translate_url_to_drive. Obrazy hostowane pod /img/..`,\n { status: 200 },\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: \"Gemini35\", version: \"5.1\" },\n });\n }\n if (\n method === \"notifications/initialized\" ||\n method?.startsWith?.(\"notifications/\")\n ) return new Response(null, { status: 202 });\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 ?? {}, origin),\n }],\n });\n } catch (e) {\n return ok(id, {\n content: [{\n type: \"text\",\n text: `BŁĄD Gemini: ${(e as Error).message}`,\n }],\n isError: true,\n });\n }\n }\n return er(id, -32601, \"Method not found\");\n}","deleted","label",[109],"pulls","branches",1,"forks","envVars",{"_133":135,"_136":40},"connections",{"_133":40,"_134":40},"count","unfilledCount",4,"emptyCount",{"_18":108,"_20":109,"_110":111,"_112":-5,"_113":66,"_114":64,"_115":102,"_22":138,"_63":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_139":140,"_84":141},["D",1785766587172],"children",[],[109],["D",1779307211277],{"_16":17,"_82":78},{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_104":179,"_180":181,"_182":183,"_184":26,"_185":26,"_186":26,"_187":102,"_188":-5,"_189":-7,"_190":-7,"_191":40,"_192":26,"_193":26,"_194":-5,"_195":26,"_196":26,"_197":26,"_198":-5},"ENV",{"_150":151,"_152":153,"_154":65,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178},"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"]