[{"_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",8,"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 — serwer MCP (Val Town / Deno) v3.7\n// • Model na stałe. Instrukcję podaje wywołujący (`instruction`).\n// • SZYBKO: pakowanie K segmentów/zapytanie + pula równoległa + hedging.\n// • MIERZY SIĘ SAM: zwraca ms, sps, retries, hedges, fallbacks, p95.\n// ENV: GEMINI_API_KEY\n// ============================================================\nconst MODEL = \"gemini-3.5-flash\";\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// --- STROJENIE ---\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));\n// Liczniki diagnostyczne (resetowane na starcie packedBatch).\nlet STAT = {\n retries: 0,\n hedges: 0,\n fallbacks: 0,\n errors: 0,\n groupMs: [] as number[],\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// Jedno żądanie (bez retry). System-instruction TYLKO jeśli podane.\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// Cierpliwy retry z backoffem na TYM SAMYM modelu.\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}\n// HEDGING: jeśli pierwsze żądanie maruderzy > hedgeMs, odpal duplikat; bierz pierwszego.\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}\n// SEMAFOR — pula równoległa.\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}\n// --- PAKOWANY BATCH: K segmentów/zapytanie, pula + hedging, z pomiarem ---\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 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 STAT.fallbacks++; // dryf liczby segmentów → bezpieczny fallback per-segment\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; // zachowaj liczbę segmentów (apply się nie wywróci)\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}\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: {\n text: { type: \"string\", description: \"Tekst po polsku do redakcji\" },\n instruction: {\n type: \"string\",\n description: \"Opcjonalna instrukcja (system prompt).\",\n },\n },\n required: [\"text\"],\n },\n },\n {\n name: \"polish_batch_gemini\",\n description:\n \"★ WIELOWĄTKOWO redaguje LISTĘ tekstów (semafor). 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: {\n type: \"number\",\n description:\n `1..${MAX_CONCURRENCY} (domyślnie ${DEFAULT_CONCURRENCY})`,\n },\n instruction: { type: \"string\" },\n },\n required: [\"texts\"],\n },\n },\n {\n name: \"pack_translate_gemini\",\n description:\n \"★★ NAJSZYBSZE + POMIAR: pakuje group_size segmentów w 1 zapytanie (delimiter |||), pula równoległa + hedging. Zwraca JSON {ms, count, sps, groups, retries, hedges, fallbacks, errors, group_ms{min,avg,p95,max}, translations[]}. W `instruction` podaj polecenie (np. tłumaczenie DE) + zasadę: zachowaj separatory ||| i tę samą liczbę segmentów.\",\n inputSchema: {\n type: \"object\",\n properties: {\n texts: { type: \"array\", items: { type: \"string\" } },\n group_size: {\n type: \"number\",\n description: \"segmentów na zapytanie (domyślnie 24)\",\n },\n concurrency: {\n type: \"number\",\n description:\n `1..${MAX_CONCURRENCY} (domyślnie ${DEFAULT_CONCURRENCY})`,\n },\n hedge_ms: {\n type: \"number\",\n description:\n \"po ilu ms odpalić duplikat marudera (0 = bez hedgingu; domyślnie 8000)\",\n },\n instruction: { type: \"string\" },\n },\n required: [\"texts\"],\n },\n },\n];\nasync function dispatch(name: string, a: any): 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 throw new GErr(`Nieznane narzędzie: ${name}`, 400, false);\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 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 v3.7 — działa. Model: ${MODEL}. Narzędzia: polish_text_gemini, polish_batch_gemini, pack_translate_gemini.`,\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: \"3.7.0\" },\n });\n }\n if (\n method === \"notifications/initialized\" ||\n method?.startsWith?.(\"notifications/\")\n ) {\n return new Response(null, { status: 202 });\n }\n if (method === \"tools/list\") return ok(id, { tools: TOOLS });\n if (method === \"tools/call\") {\n try {\n return ok(id, {\n content: [{\n type: \"text\",\n text: await dispatch(params?.name, params?.arguments ?? {}),\n }],\n });\n } catch (e) {\n return ok(id, {\n content: [{\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 — serwer MCP (Val Town / Deno) v3.7.1\n// • Model na stałe. Instrukcję podaje wywołujący (`instruction`).\n// • SZYBKO: pakowanie K segmentów/zapytanie + pula równoległa + hedging.\n// • translateGroup: pakiet + 1 ponów na dryf, dopiero potem per-segment.\n// • MIERZY SIĘ SAM: ms, sps, retries, hedges, fallbacks, p95.\n// ENV: GEMINI_API_KEY\n// ============================================================\nconst MODEL = \"gemini-3.5-flash\";\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// --- STROJENIE ---\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));\n// Liczniki diagnostyczne (resetowane na starcie packedBatch).\nlet STAT = {\n retries: 0,\n hedges: 0,\n fallbacks: 0,\n errors: 0,\n groupMs: [] as number[],\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// Jedno żądanie (bez retry). System-instruction TYLKO jeśli podane.\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// Cierpliwy retry z backoffem na TYM SAMYM modelu.\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}\n// HEDGING: jeśli pierwsze żądanie maruderzy > hedgeMs, odpal duplikat; bierz pierwszego.\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}\n// SEMAFOR — pula równoległa.\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}\n// --- PAKOWANY BATCH: K segmentów/zapytanie, pula + hedging, z pomiarem ---\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++) { // pakiet + 1 ponów na dryf\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++; // dopiero teraz drogi fallback per-segment\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; // zachowaj liczbę segmentów (apply się nie wywróci)\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}\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: {\n text: { type: \"string\", description: \"Tekst po polsku do redakcji\" },\n instruction: {\n type: \"string\",\n description: \"Opcjonalna instrukcja (system prompt).\",\n },\n },\n required: [\"text\"],\n },\n },\n {\n name: \"polish_batch_gemini\",\n description:\n \"★ WIELOWĄTKOWO redaguje LISTĘ tekstów (semafor). 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: {\n type: \"number\",\n description:\n `1..${MAX_CONCURRENCY} (domyślnie ${DEFAULT_CONCURRENCY})`,\n },\n instruction: { type: \"string\" },\n },\n required: [\"texts\"],\n },\n },\n {\n name: \"pack_translate_gemini\",\n description:\n \"★★ NAJSZYBSZE + POMIAR: pakuje group_size segmentów w 1 zapytanie (delimiter |||), pula równoległa + hedging, ponów pakiet na dryf. Zwraca JSON {ms, count, sps, groups, retries, hedges, fallbacks, errors, group_ms{min,avg,p95,max}, translations[]}. W `instruction` podaj polecenie (np. tłumaczenie DE) + zasadę: zachowaj separatory ||| i tę samą liczbę segmentów.\",\n inputSchema: {\n type: \"object\",\n properties: {\n texts: { type: \"array\", items: { type: \"string\" } },\n group_size: {\n type: \"number\",\n description: \"segmentów na zapytanie (domyślnie 24)\",\n },\n concurrency: {\n type: \"number\",\n description:\n `1..${MAX_CONCURRENCY} (domyślnie ${DEFAULT_CONCURRENCY})`,\n },\n hedge_ms: {\n type: \"number\",\n description:\n \"po ilu ms odpalić duplikat marudera (0 = bez hedgingu; domyślnie 8000)\",\n },\n instruction: { type: \"string\" },\n },\n required: [\"texts\"],\n },\n },\n];\nasync function dispatch(name: string, a: any): 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 throw new GErr(`Nieznane narzędzie: ${name}`, 400, false);\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 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 v3.7.1 — działa. Model: ${MODEL}. Narzędzia: polish_text_gemini, polish_batch_gemini, pack_translate_gemini.`,\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: \"3.7.1\" },\n });\n }\n if (\n method === \"notifications/initialized\" ||\n method?.startsWith?.(\"notifications/\")\n ) {\n return new Response(null, { status: 202 });\n }\n if (method === \"tools/list\") return ok(id, { tools: TOOLS });\n if (method === \"tools/call\") {\n try {\n return ok(id, {\n content: [{\n type: \"text\",\n text: await dispatch(params?.name, params?.arguments ?? {}),\n }],\n });\n } catch (e) {\n return ok(id, {\n content: [{\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",1780066110922],"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},"75b2bd5e-5b6d-11f1-af28-ee650bb23af1","parentId","latest",["D",1780066110922],7,"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",1780066110922],"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 · v8