[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",24,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","824b5460-5486-11f1-ae1e-ee650bb23af1","name","fileType","http","content","// ============================================================\n// GEMINI 3.5 REDAKTOR/TŁUMACZ + WIZJA + RYSOWANIE + OMNI VIDEO — MCP (Val Town/Deno) v5.0\n// v4.7 + OMNI: omni_generate / omni_status / omni_download (Interactions API,\n// gemini-omni-flash-preview). Referencje: image_ref_ids (blob z gemini_image),\n// image_ref_urls (dowolny URL), image_refs_b64, video_ref_urls (max 3 klipy ≤3s —\n// model może na razie ignorować). previous_interaction_id = edycja klipu.\n// ENV: GEMINI_API_KEY (+ Drive: GOOGLE_CLIENT_ID / SECRET / REFRESH_TOKEN)\n// ============================================================\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst MODEL = \"gemini-3.5-flash\"; // redakcja/tłumaczenia + wizja (obraz IN, tekst OUT)\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\nasync function callOnce(text: string, instruction: string): 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 =\n `https://generativelanguage.googleapis.com/v1beta/models/${MODEL}: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 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) — NOWE w 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 // a) referencje z własnego bloba (image_id z gemini_image)\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 // b) referencje z URL (np. url z gemini_image, imgutils, ChatGPT po host_url)\n for (const u of (a?.image_ref_urls ?? [])) {\n parts.push(await fetchAsB64Part(String(u), \"image\", \"image/png\"));\n }\n // c) referencje base64 wprost\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 // d) referencje WIDEO (max 3, klipy ≤3s) — UWAGA: model na razie może je ignorować\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\nasync function polishOne(\n text: string,\n instruction = DEFAULT_INSTRUCTION,\n): Promise {\n let attempt = 0, wait = RETRY.baseMs, lastErr: unknown;\n while (attempt < RETRY.maxAttempts) {\n try {\n return await callOnce(text, instruction);\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 polski tekst przez Gemini 3.5. Zasady w `instruction` (opcjonalnie). Retry+backoff.\",\n inputSchema: {\n type: \"object\",\n properties: { text: { type: \"string\" }, instruction: { type: \"string\" } },\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\\u0119 Omni po interaction_id: zwraca {status,file_id} gdy wideo gotowe (albo surowy skr\\u00f3t 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 return await polishOne(\n String(a?.text ?? \"\"),\n a?.instruction ?? DEFAULT_INSTRUCTION,\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 // PATCH HOST: dorzucamy publiczny url\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 // PATCH HOST: dorzucamy publiczny url do każdego udanego elementu\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 // deep-scan: dowolne \"files/\" w calej odpowiedzi\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 if (req.method === \"GET\" && url.searchParams.has(\"text\")) {\n try {\n return Response.json({\n ok: true,\n model: MODEL,\n text: await polishOne(url.searchParams.get(\"text\")!),\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 3.5 MCP v5.0 (HOST+OMNI+RESULT) — działa. Model: ${MODEL}, wideo: ${OMNI_MODEL}. Tooly: polish_text_gemini, 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.0\" },\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}","// ============================================================\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-pro-preview\", // Gemini 3 Pro (tekst). Jeśli API zwróci 404 — podmień na właściwy ID.\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(text: string, instruction: string, model?: string): 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 =\n `https://generativelanguage.googleapis.com/v1beta/models/${resolveTxt(model)}: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 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): Promise {\n let attempt = 0, wait = RETRY.baseMs, lastErr: unknown;\n while (attempt < RETRY.maxAttempts) {\n try {\n return await callOnce(text, instruction, model);\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 return await polishOne(\n String(a?.text ?? \"\"),\n a?.instruction ?? DEFAULT_INSTRUCTION,\n a?.model,\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 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}","createdAt",["D",1783526551696],"branchVersion","branchId","82416748-5486-11f1-ae1e-ee650bb23af1","id","824019f6-5486-11f1-ae1e-ee650bb23af1","Geminiok",["D",1779307211277],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","gemini","imageUrl","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",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",27,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","rafalwiktorowicz","handle","displayName","R W","avatar","https://lh3.googleusercontent.com/a/ACg8ocKAmj_qhWrVoXHf18hayjA4wNNLTkmWMqHGPR0qAaQrAmi6AA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":152,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":153,"_79":154,"_81":155,"_83":25},"tree",[147],"files",[147],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"b2492860-9d41-42cd-97a3-ee09cfcf6170","parentId","latest",["D",1783526551696],23,"label",[28],"pulls","branches",1,"forks","envVars",{"_143":145,"_146":61},"connections",{"_143":61,"_144":61},"count","unfilledCount",4,"emptyCount",{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":148,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_149":150,"_27":151},["D",1783526551696],"children",[],[28],["D",1779307211277],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_124":189,"_190":191,"_192":193,"_194":25,"_195":25,"_196":25,"_197":122,"_198":-5,"_199":-7,"_200":-7,"_201":61,"_202":25,"_203":25,"_204":-5,"_205":25,"_206":25,"_207":25,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":85,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v24