[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":53,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"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":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",17,"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","81afddd2-5954-11f1-a20a-ee650bb23af1","name","fileType","http","content","// ============================================================================\n// ElevenLabs AUDIOBOOK Connector (val.run / Deno) — v1\n// Masowe, WIELOWĄTKOWE generowanie na GODZINY słuchania + sklejanie w 1 plik.\n//\n// Wzorce zapożyczone z Waszych innych konektorów:\n// • batch + get → jak generate_images_batch / get_images, get_translations\n// • job + uchwyt → jak stash_texts / translate_job (duże payloady zostają na serwerze,\n// agent dostaje mały {job_id} i odpytuje get)\n// • concurrency + hedge → jak pack_translate_gemini (pula + duplikat marudera)\n// • retry/backoff → 429/5xx z wykładniczym backoffem\n// • failed[] → lista indeksów do ponowienia bez przetwarzania całości\n//\n// TOOLS (manifest na końcu pliku):\n// tts — pojedynczy plik\n// tts_batch — N kawałków równolegle → {ids, audio_urls}\n// stitch_audio — skleja ID-ki w JEDEN plik (+ pauzy) ← brakujący element\n// tts_audiobook — chunk → batch → stitch w jednym wywołaniu (do ~kilkunastu min)\n// audiobook_start — JOB dla GODZIN: zwraca {job_id}, robi w tle partiami\n// audiobook_get — status/uchwyt: {status, done, total, audio_url?}\n// get_audio — pobierz/zweryfikuj kawałki po ID\n//\n// ENV: ELEVENLABS_API_KEY, SELF_URL (bazowy URL tego vala, np. https://...web.val.run)\n// ============================================================================\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst EL = \"https://api.elevenlabs.io/v1\";\nconst KEY = Deno.env.get(\"ELEVENLABS_API_KEY\")!;\nconst SELF = (Deno.env.get(\"SELF_URL\") || \"\").replace(/\\/$/, \"\");\nconst OUT_FMT = \"mp3_44100_128\"; // jednolity codec/bitrate => bezpieczny concat\n\nconst DEFAULTS = {\n model_id: \"eleven_v3\", // v3 = limit 5000 zn./generację → tniemy poniżej\n stability: 0.5,\n similarity_boost: 0.85,\n style: 0,\n use_speaker_boost: true,\n speed: 0.95,\n target_chars: 700, // długość kawałka (bezpiecznie < 5000 v3)\n max_concurrent: 8, // wątki (Creator ~5, Pro/Scale więcej)\n gap_text: \" … \", // pauza między kawałkami robiona TEKSTEM (bez hackowania ramek MP3)\n hedge_ms: 12000, // duplikat marudera po N ms (0 = off)\n retries: 5,\n};\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// ---------------------------------------------------------------- ElevenLabs call (retry+backoff)\nasync function elevenTTS(\n text: string,\n voice_id: string,\n o: any,\n): Promise {\n const body = JSON.stringify({\n text,\n model_id: o.model_id ?? DEFAULTS.model_id,\n voice_settings: {\n stability: o.stability ?? DEFAULTS.stability,\n similarity_boost: o.similarity_boost ?? DEFAULTS.similarity_boost,\n style: o.style ?? DEFAULTS.style,\n use_speaker_boost: o.use_speaker_boost ?? DEFAULTS.use_speaker_boost,\n speed: o.speed ?? DEFAULTS.speed,\n },\n });\n const max = o.retries ?? DEFAULTS.retries;\n for (let attempt = 0;; attempt++) {\n const r = await fetch(\n `${EL}/text-to-speech/${voice_id}?output_format=${OUT_FMT}`,\n {\n method: \"POST\",\n headers: { \"xi-api-key\": KEY, \"content-type\": \"application/json\" },\n body,\n },\n );\n if (r.ok) return new Uint8Array(await r.arrayBuffer());\n if ((r.status === 429 || r.status >= 500) && attempt < max) {\n await sleep(700 * 2 ** attempt + Math.random() * 400); // backoff + jitter\n continue;\n }\n throw new Error(`TTS ${r.status}: ${(await r.text()).slice(0, 200)}`);\n }\n}\n\n// ---------------------------------------------------------------- chunker (po zdaniach, bez cięcia w środku)\nfunction chunkText(text: string, target = DEFAULTS.target_chars): string[] {\n const sents =\n text.replace(/\\s+/g, \" \").trim().match(\n /[^.!?…]+[.!?…]+(\\s|$)|[^.!?…]+$/g,\n ) || [text];\n const out: string[] = [];\n let cur = \"\";\n for (const s of sents) {\n if ((cur + s).length > target && cur) {\n out.push(cur.trim());\n cur = \"\";\n }\n if (s.length > target) { // pojedyncze ultra-długie zdanie → tnij po przecinkach\n for (const part of s.split(/,\\s/)) {\n if ((cur + part).length > target && cur) {\n out.push(cur.trim());\n cur = \"\";\n }\n cur += part + \", \";\n }\n } else cur += s;\n }\n if (cur.trim()) out.push(cur.trim());\n return out;\n}\n\n// ---------------------------------------------------------------- pula wątków + hedging\nasync function pool(\n items: T[],\n worker: (x: T, i: number) => Promise,\n conc: number,\n hedge_ms = 0,\n) {\n const res:\n ({ ok: true; value: Uint8Array } | { ok: false; error: string })[] =\n new Array(items.length);\n let next = 0;\n async function runOne(i: number) {\n const main = worker(items[i], i);\n try {\n if (hedge_ms > 0) {\n // hedging: jeśli kawałek marudzi > hedge_ms, odpal duplikat i bierz pierwszy gotowy\n const hedged = (async () => {\n await sleep(hedge_ms);\n return worker(items[i], i);\n })();\n res[i] = { ok: true, value: await Promise.race([main, hedged]) };\n } else {\n res[i] = { ok: true, value: await main };\n }\n } catch (e) {\n res[i] = { ok: false, error: String(e).slice(0, 200) };\n }\n }\n const workers = Array.from(\n { length: Math.min(conc, items.length) },\n async () => {\n while (next < items.length) {\n const i = next++;\n await runOne(i);\n }\n },\n );\n await Promise.all(workers);\n return res;\n}\n\n// ---------------------------------------------------------------- store (val.run blob)\nfunction concatBytes(arrs: Uint8Array[]): Uint8Array {\n const total = arrs.reduce((n, a) => n + a.length, 0);\n const out = new Uint8Array(total);\n let off = 0;\n for (const a of arrs) {\n out.set(a, off);\n off += a.length;\n }\n return out;\n}\nasync function saveAudio(bytes: Uint8Array): Promise {\n const id = crypto.randomUUID();\n await blob.set(`audio:${id}`, bytes);\n return id;\n}\nasync function loadAudio(id: string): Promise {\n const b = await blob.get(`audio:${id}`);\n if (!b) throw new Error(`brak audio: ${id}`);\n return new Uint8Array(await b.arrayBuffer());\n}\nconst url = (id: string) => `${SELF}/audio/${id}`;\n\n// ============================================================================ TOOLS\nexport async function tts({ text, voice_id, ...o }: any) {\n const id = await saveAudio(await elevenTTS(text, voice_id, o));\n return { id, audio_url: url(id), model_id: o.model_id ?? DEFAULTS.model_id };\n}\n\nexport async function tts_batch(\n {\n texts,\n voice_id,\n max_concurrent = DEFAULTS.max_concurrent,\n hedge_ms = 0,\n ...o\n }: any,\n) {\n const r = await pool(\n texts,\n (t) => elevenTTS(t, voice_id, o),\n max_concurrent,\n hedge_ms,\n );\n const ids: string[] = [];\n const audio_urls: string[] = [];\n const failed: number[] = [];\n for (let i = 0; i < r.length; i++) {\n if (r[i].ok) {\n const id = await saveAudio((r[i] as any).value);\n ids.push(id);\n audio_urls.push(url(id));\n } else failed.push(i);\n }\n return { ids, audio_urls, count: ids.length, failed }; // failed[] → ponów tylko te indeksy\n}\n\n// ★ BRAKUJĄCY ELEMENT: sklej kawałki po ID w jeden plik (codec jednolity → concat bezpieczny)\nexport async function stitch_audio({ ids, gap_ms = 0 }: any) {\n const parts: Uint8Array[] = [];\n for (const id of ids) parts.push(await loadAudio(id));\n // pauzy robimy tekstem przy generowaniu (gap_text), więc tu czysty concat; gap_ms zostawione dla zgodności\n const out = concatBytes(parts);\n const id = await saveAudio(out);\n return { id, audio_url: url(id), bytes: out.length, parts: ids.length };\n}\n\n// jedno wywołanie: chunk → batch → stitch (do ~kilkunastu minut, w granicach timeoutu requestu)\nexport async function tts_audiobook(\n {\n text,\n voice_id,\n target_chars,\n gap_text = DEFAULTS.gap_text,\n max_concurrent = DEFAULTS.max_concurrent,\n hedge_ms = DEFAULTS.hedge_ms,\n ...o\n }: any,\n) {\n const chunks = chunkText(text, target_chars ?? DEFAULTS.target_chars)\n .map((c, i, arr) => i < arr.length - 1 ? c + gap_text : c); // pauza tekstem\n const r = await pool(\n chunks,\n (t) => elevenTTS(t, voice_id, o),\n max_concurrent,\n hedge_ms,\n );\n const ids: string[] = [];\n const failed: number[] = [];\n for (let i = 0; i < r.length; i++) {\n if (r[i].ok) ids.push(await saveAudio((r[i] as any).value));\n else failed.push(i);\n }\n if (failed.length) {\n return {\n error: \"część kawałków padła — ponów\",\n failed,\n ok_ids: ids,\n chunks: chunks.length,\n };\n }\n const s = await stitch_audio({ ids });\n return { ...s, chunks: chunks.length, failed: [] };\n}\n\n// ★ JOB dla GODZIN: start zwraca uchwyt natychmiast, przetwarzanie partiami w tle, get odpytuje\nexport async function audiobook_start(\n {\n text,\n voice_id,\n target_chars,\n gap_text = DEFAULTS.gap_text,\n batch_size = 24,\n max_concurrent = DEFAULTS.max_concurrent,\n hedge_ms = DEFAULTS.hedge_ms,\n ...o\n }: any,\n) {\n const chunks = chunkText(text, target_chars ?? DEFAULTS.target_chars)\n .map((c, i, arr) => i < arr.length - 1 ? c + gap_text : c);\n const job_id = crypto.randomUUID();\n await blob.setJSON(`job:${job_id}`, {\n status: \"running\",\n total: chunks.length,\n done: 0,\n ids: [],\n failed: [],\n });\n\n (async () => { // tło: partiami, żeby nie zabić pamięci/limitów\n const ids: (string | null)[] = new Array(chunks.length).fill(null);\n for (let start = 0; start < chunks.length; start += batch_size) {\n const slice = chunks.slice(start, start + batch_size);\n const r = await pool(\n slice,\n (t) => elevenTTS(t, voice_id, o),\n max_concurrent,\n hedge_ms,\n );\n const failed: number[] = [];\n for (let i = 0; i < r.length; i++) {\n if (r[i].ok) ids[start + i] = await saveAudio((r[i] as any).value);\n else failed.push(start + i);\n }\n const st = await blob.getJSON(`job:${job_id}`) as any;\n st.done = ids.filter(Boolean).length;\n st.failed = (st.failed || []).concat(failed);\n await blob.setJSON(`job:${job_id}`, st);\n }\n const okIds = ids.filter(Boolean) as string[];\n const out = concatBytes(await Promise.all(okIds.map(loadAudio)));\n const finalId = await saveAudio(out);\n const st = await blob.getJSON(`job:${job_id}`) as any;\n st.status = \"done\";\n st.audio_url = url(finalId);\n st.id = finalId;\n st.bytes = out.length;\n await blob.setJSON(`job:${job_id}`, st);\n })().catch(async (e) => {\n const st = await blob.getJSON(`job:${job_id}`) as any;\n st.status = \"error\";\n st.error = String(e).slice(0, 300);\n await blob.setJSON(`job:${job_id}`, st);\n });\n\n return { job_id, total: chunks.length }; // mały uchwyt, jak translate_job\n}\nexport async function audiobook_get({ job_id }: any) {\n return (await blob.getJSON(`job:${job_id}`)) ?? { status: \"not_found\" };\n}\nexport async function get_audio({ ids }: any) {\n return { audio_urls: ids.map((id: string) => url(id)), count: ids.length };\n}\n\n// ---------------------------------------------------------------- routing /audio/{id}\nexport default async function (req: Request): Promise {\n const u = new URL(req.url);\n const m = u.pathname.match(/^\\/audio\\/([0-9a-f-]+)$/i);\n if (m) {\n try {\n return new Response(await loadAudio(m[1]), {\n headers: { \"content-type\": \"audio/mpeg\" },\n });\n } catch {\n return new Response(\"not found\", { status: 404 });\n }\n }\n return new Response(\"ElevenLabs Audiobook Connector — patrz manifest tooli\", {\n status: 200,\n });\n}\n\n/* ============================ MCP TOOL MANIFEST (do rejestracji) ============================\ntts_audiobook {text, voice_id, target_chars?, gap_text?, max_concurrent?, hedge_ms?, model_id?, stability?, similarity_boost?, style?, speed?} -> {id, audio_url, bytes, chunks, failed}\naudiobook_start {text, voice_id, ...same, batch_size?} -> {job_id, total} // GODZINY: potem audiobook_get\naudiobook_get {job_id} -> {status:'running'|'done'|'error', done, total, failed, audio_url?}\ntts_batch {texts[], voice_id, max_concurrent?, hedge_ms?, ...} -> {ids, audio_urls, count, failed}\nstitch_audio {ids[], gap_ms?} -> {id, audio_url, bytes, parts}\ntts {text, voice_id, ...} -> {id, audio_url}\nget_audio {ids[]} -> {audio_urls, count}\n============================================================================================ */","// ============================================================================\n// ElevenLabs Connector — PEŁNY (do NADPISANIA) val.run / Deno v2\n// Serwer MCP (Streamable HTTP) + trasa /audio/{id}\n//\n// TOOLE (stare 1:1 + nowe):\n// tts tts_batch tts_longform voice_design remix_voice\n// stitch_audio tts_audiobook audiobook_start audiobook_get get_audio\n//\n// ENV: ELEVENLABS_API_KEY, SELF_URL (adres tego vala, BEZ końcowego /)\n//\n// UWAGA: voice_design i remix_voice używają standardowych endpointów\n// ElevenLabs (text-to-voice). Jeśli Twój stary konektor robił to inaczej i\n// działał — podmień TE DWIE funkcje na swoje. Reszta jest pewna i samowystarczalna.\n// ============================================================================\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst EL = \"https://api.elevenlabs.io/v1\";\nconst KEY = Deno.env.get(\"ELEVENLABS_API_KEY\")!;\nconst SELF = (Deno.env.get(\"SELF_URL\") || \"\").replace(/\\/$/, \"\");\nconst FMT = \"mp3_44100_128\"; // jednolity codec => bezpieczny concat\nconst sleep = (ms: number) => new Promise(r => setTimeout(r, ms));\nconst url = (id: string) => `${SELF}/audio/${id}`;\n\n// ----------------------------------------------------------------- ElevenLabs TTS (retry+backoff)\nasync function elevenTTS(text: string, voice_id: string, o: any): Promise {\n const body = JSON.stringify({\n text,\n model_id: o.model_id ?? \"eleven_multilingual_v2\",\n voice_settings: {\n stability: o.stability ?? 0.5,\n similarity_boost: o.similarity_boost ?? 0.8,\n style: o.style ?? 0,\n use_speaker_boost: o.use_speaker_boost ?? true,\n speed: o.speed ?? 1,\n },\n });\n for (let a = 0; ; a++) {\n const r = await fetch(`${EL}/text-to-speech/${voice_id}?output_format=${FMT}`, {\n method: \"POST\", headers: { \"xi-api-key\": KEY, \"content-type\": \"application/json\" }, body,\n });\n if (r.ok) return new Uint8Array(await r.arrayBuffer());\n if ((r.status === 429 || r.status >= 500) && a < 5) { await sleep(700 * 2 ** a + Math.random() * 400); continue; }\n throw new Error(`TTS ${r.status}: ${(await r.text()).slice(0, 200)}`);\n }\n}\n\n// ----------------------------------------------------------------- chunker + pula + concat + store\nfunction chunkText(text: string, target = 700): string[] {\n const sents = text.replace(/\\s+/g, \" \").trim().match(/[^.!?…]+[.!?…]+(\\s|$)|[^.!?…]+$/g) || [text];\n const out: string[] = []; let cur = \"\";\n for (const s of sents) {\n if ((cur + s).length > target && cur) { out.push(cur.trim()); cur = \"\"; }\n if (s.length > target) { for (const p of s.split(/,\\s/)) { if ((cur + p).length > target && cur) { out.push(cur.trim()); cur = \"\"; } cur += p + \", \"; } }\n else cur += s;\n }\n if (cur.trim()) out.push(cur.trim());\n return out;\n}\nasync function pool(items: string[], worker: (x: string) => Promise, conc: number, hedge_ms = 0) {\n const res: ({ ok: true; value: Uint8Array } | { ok: false; error: string })[] = new Array(items.length);\n let next = 0;\n async function run(i: number) {\n try {\n const main = worker(items[i]);\n if (hedge_ms > 0) { const h = (async () => { await sleep(hedge_ms); return worker(items[i]); })(); res[i] = { ok: true, value: await Promise.race([main, h]) }; }\n else res[i] = { ok: true, value: await main };\n } catch (e) { res[i] = { ok: false, error: String(e).slice(0, 200) }; }\n }\n await Promise.all(Array.from({ length: Math.min(conc, items.length) }, async () => { while (next < items.length) { const i = next++; await run(i); } }));\n return res;\n}\nfunction concatBytes(arr: Uint8Array[]): Uint8Array { const n = arr.reduce((s, a) => s + a.length, 0); const o = new Uint8Array(n); let k = 0; for (const a of arr) { o.set(a, k); k += a.length; } return o; }\nasync function saveAudio(b: Uint8Array): Promise { const id = crypto.randomUUID(); await blob.set(`audio:${id}`, b); return id; }\nasync function loadAudio(id: string): Promise { const b = await blob.get(`audio:${id}`); if (!b) throw new Error(`brak audio: ${id}`); return new Uint8Array(await b.arrayBuffer()); }\n\n// ============================================================================ HANDLERY TOOLI\nconst H: Record Promise> = {\n // ---- STARE (1:1) ----\n async tts(a) {\n const id = await saveAudio(await elevenTTS(a.text, a.voice_id, { model_id: a.model_id ?? \"eleven_multilingual_v2\", stability: a.stability ?? 0.5, similarity_boost: a.similarity_boost ?? 0.8, style: a.style ?? 0, use_speaker_boost: a.use_speaker_boost ?? true, speed: a.speed ?? 1 }));\n return { id, audio_url: url(id) };\n },\n async tts_batch(a) {\n const o = { model_id: a.model_id ?? \"eleven_v3\", stability: a.stability ?? 0.5, similarity_boost: a.similarity_boost ?? 0.85, style: a.style ?? 0, use_speaker_boost: a.use_speaker_boost ?? true, speed: a.speed ?? 0.9 };\n const r = await pool(a.texts, t => elevenTTS(t, a.voice_id, o), a.max_concurrent ?? 5, a.hedge_ms ?? 0);\n const ids: string[] = [], audio_urls: string[] = [], failed: number[] = [];\n for (let i = 0; i < r.length; i++) { if (r[i].ok) { const id = await saveAudio((r[i] as any).value); ids.push(id); audio_urls.push(url(id)); } else failed.push(i); }\n return { ids, audio_urls, count: ids.length, failed };\n },\n async tts_longform(a) {\n const o = { model_id: a.model_id ?? \"eleven_multilingual_v2\", stability: a.stability ?? 0.6, similarity_boost: a.similarity_boost ?? 0.85, style: a.style ?? 0, use_speaker_boost: a.use_speaker_boost ?? true, speed: a.speed ?? 1 };\n const chunks = chunkText(a.text, a.target_chars ?? 700);\n const r = await pool(chunks, t => elevenTTS(t, a.voice_id, o), a.max_concurrent ?? 5, 0);\n const parts: Uint8Array[] = []; const failed: number[] = [];\n for (let i = 0; i < r.length; i++) { if (r[i].ok) parts.push((r[i] as any).value); else failed.push(i); }\n if (failed.length) return { error: \"część kawałków padła\", failed, chunks: chunks.length };\n const id = await saveAudio(concatBytes(parts));\n return { id, audio_url: url(id), chunks: chunks.length };\n },\n async voice_design(a) { // ElevenLabs text-to-voice (zweryfikuj jeśli Twój stary inny)\n const prev = await fetch(`${EL}/text-to-voice/create-previews`, {\n method: \"POST\", headers: { \"xi-api-key\": KEY, \"content-type\": \"application/json\" },\n body: JSON.stringify({ voice_description: a.prompt, text: a.sample_text, model_id: a.model_id ?? \"eleven_multilingual_ttv_v2\", guidance_scale: a.guidance_scale ?? 30, loudness: a.loudness ?? 0.5 }),\n });\n if (!prev.ok) throw new Error(`voice_design previews ${prev.status}: ${(await prev.text()).slice(0, 200)}`);\n const pj = await prev.json(); const gv = pj.previews?.[0]?.generated_voice_id;\n if (a.auto_create !== false && gv) {\n const cr = await fetch(`${EL}/text-to-voice/create-voice-from-preview`, {\n method: \"POST\", headers: { \"xi-api-key\": KEY, \"content-type\": \"application/json\" },\n body: JSON.stringify({ voice_name: a.name ?? \"Starsza Polka (design)\", voice_description: a.prompt, generated_voice_id: gv }),\n });\n if (cr.ok) { const cj = await cr.json(); return { voice_id: cj.voice_id, generated_voice_id: gv }; }\n }\n return { generated_voice_id: gv, previews: pj.previews?.length ?? 0 };\n },\n async remix_voice(a) { // remix = nowy design z promptem + tekst referencyjny\n const prev = await fetch(`${EL}/text-to-voice/create-previews`, {\n method: \"POST\", headers: { \"xi-api-key\": KEY, \"content-type\": \"application/json\" },\n body: JSON.stringify({ voice_description: a.prompt, text: a.sample_text }),\n });\n if (!prev.ok) throw new Error(`remix ${prev.status}: ${(await prev.text()).slice(0, 200)}`);\n const pj = await prev.json();\n return { source_voice_id: a.voice_id, generated_voice_id: pj.previews?.[0]?.generated_voice_id, previews: pj.previews?.length ?? 0 };\n },\n\n // ---- NOWE (audiobook / masowo) ----\n async stitch_audio(a) { // sklej ID-ki w jeden plik\n const parts: Uint8Array[] = []; for (const id of a.ids) parts.push(await loadAudio(id));\n const out = concatBytes(parts); const id = await saveAudio(out);\n return { id, audio_url: url(id), bytes: out.length, parts: a.ids.length };\n },\n async tts_audiobook(a) { // chunk -> batch -> stitch (jeden plik)\n const o = { model_id: a.model_id ?? \"eleven_v3\", stability: a.stability ?? 0.5, similarity_boost: a.similarity_boost ?? 0.85, style: a.style ?? 0, use_speaker_boost: a.use_speaker_boost ?? true, speed: a.speed ?? 0.95 };\n const gap = a.gap_text ?? \" … \";\n const chunks = chunkText(a.text, a.target_chars ?? 700).map((c, i, arr) => i < arr.length - 1 ? c + gap : c);\n const r = await pool(chunks, t => elevenTTS(t, a.voice_id, o), a.max_concurrent ?? 8, a.hedge_ms ?? 12000);\n const parts: Uint8Array[] = []; const failed: number[] = [];\n for (let i = 0; i < r.length; i++) { if (r[i].ok) parts.push((r[i] as any).value); else failed.push(i); }\n if (failed.length) return { error: \"część kawałków padła — ponów\", failed, chunks: chunks.length };\n const id = await saveAudio(concatBytes(parts));\n return { id, audio_url: url(id), chunks: chunks.length, failed: [] };\n },\n async audiobook_start(a) { // JOB dla GODZIN — uchwyt + tło partiami\n const o = { model_id: a.model_id ?? \"eleven_v3\", stability: a.stability ?? 0.5, similarity_boost: a.similarity_boost ?? 0.85, style: a.style ?? 0, use_speaker_boost: a.use_speaker_boost ?? true, speed: a.speed ?? 0.95 };\n const gap = a.gap_text ?? \" … \"; const bs = a.batch_size ?? 24; const conc = a.max_concurrent ?? 8; const hedge = a.hedge_ms ?? 12000;\n const chunks = chunkText(a.text, a.target_chars ?? 700).map((c, i, arr) => i < arr.length - 1 ? c + gap : c);\n const job_id = crypto.randomUUID();\n await blob.setJSON(`job:${job_id}`, { status: \"running\", total: chunks.length, done: 0, failed: [] });\n (async () => {\n const ids: (string | null)[] = new Array(chunks.length).fill(null);\n for (let s = 0; s < chunks.length; s += bs) {\n const r = await pool(chunks.slice(s, s + bs), t => elevenTTS(t, a.voice_id, o), conc, hedge);\n const fail: number[] = [];\n for (let i = 0; i < r.length; i++) { if (r[i].ok) ids[s + i] = await saveAudio((r[i] as any).value); else fail.push(s + i); }\n const st: any = await blob.getJSON(`job:${job_id}`); st.done = ids.filter(Boolean).length; st.failed = (st.failed || []).concat(fail); await blob.setJSON(`job:${job_id}`, st);\n }\n const ok = ids.filter(Boolean) as string[];\n const out = concatBytes(await Promise.all(ok.map(loadAudio)));\n const fid = await saveAudio(out);\n const st: any = await blob.getJSON(`job:${job_id}`); st.status = \"done\"; st.id = fid; st.audio_url = url(fid); st.bytes = out.length; await blob.setJSON(`job:${job_id}`, st);\n })().catch(async e => { const st: any = await blob.getJSON(`job:${job_id}`); st.status = \"error\"; st.error = String(e).slice(0, 300); await blob.setJSON(`job:${job_id}`, st); });\n return { job_id, total: chunks.length };\n },\n async audiobook_get(a) { return (await blob.getJSON(`job:${a.job_id}`)) ?? { status: \"not_found\" }; },\n async get_audio(a) { return { audio_urls: a.ids.map((id: string) => url(id)), count: a.ids.length }; },\n};\n\n// ============================================================================ MCP TOOL SCHEMATY\nconst S = (props: any, req: string[] = []) => ({ type: \"object\", properties: props, required: req });\nconst str = { type: \"string\" }, num = { type: \"number\" }, bool = { type: \"boolean\" }, arr = { type: \"array\", items: { type: \"string\" } };\nconst VS = { model_id: str, stability: num, similarity_boost: num, style: num, use_speaker_boost: bool, speed: num };\nconst TOOLS = [\n { name: \"tts\", description: \"Pojedynczy plik MP3 (link).\", inputSchema: S({ text: str, voice_id: str, ...VS }, [\"text\", \"voice_id\"]) },\n { name: \"tts_batch\", description: \"WIELE kawałków równolegle → {ids, audio_urls, failed}.\", inputSchema: S({ texts: arr, voice_id: str, max_concurrent: num, hedge_ms: num, ...VS }, [\"texts\", \"voice_id\"]) },\n { name: \"tts_longform\", description: \"Długi tekst: dzieli, generuje równolegle i SKLEJA w jeden plik.\", inputSchema: S({ text: str, voice_id: str, target_chars: num, max_concurrent: num, ...VS }, [\"text\", \"voice_id\"]) },\n { name: \"voice_design\", description: \"Projektuje NOWY głos z opisu.\", inputSchema: S({ prompt: str, sample_text: str, name: str, auto_create: bool, guidance_scale: num, loudness: num, model_id: str }, [\"prompt\", \"sample_text\"]) },\n { name: \"remix_voice\", description: \"Remiks istniejącego głosu nowym promptem.\", inputSchema: S({ prompt: str, sample_text: str, voice_id: str }, [\"prompt\", \"sample_text\", \"voice_id\"]) },\n { name: \"stitch_audio\", description: \"Skleja ID-ki kawałków w JEDEN plik.\", inputSchema: S({ ids: arr, gap_ms: num }, [\"ids\"]) },\n { name: \"tts_audiobook\", description: \"Audiobook w jednym wywołaniu: chunk → batch → stitch.\", inputSchema: S({ text: str, voice_id: str, target_chars: num, gap_text: str, max_concurrent: num, hedge_ms: num, ...VS }, [\"text\", \"voice_id\"]) },\n { name: \"audiobook_start\", description: \"JOB dla GODZIN: zwraca {job_id}, robi w tle partiami.\", inputSchema: S({ text: str, voice_id: str, batch_size: num, target_chars: num, gap_text: str, max_concurrent: num, hedge_ms: num, ...VS }, [\"text\", \"voice_id\"]) },\n { name: \"audiobook_get\", description: \"Status joba: {status, done, total, audio_url?}.\", inputSchema: S({ job_id: str }, [\"job_id\"]) },\n { name: \"get_audio\", description: \"Linki do kawałków po ID.\", inputSchema: S({ ids: arr }, [\"ids\"]) },\n];\n\n// ============================================================================ MCP (Streamable HTTP) + /audio\nfunction rpc(id: any, result?: any, error?: any) { return { jsonrpc: \"2.0\", id, ...(error ? { error } : { result }) }; }\n\nexport default async function (req: Request): Promise {\n const u = new URL(req.url);\n // serwowanie audio\n const m = u.pathname.match(/^\\/audio\\/([0-9a-f-]+)$/i);\n if (m) { try { return new Response(await loadAudio(m[1]), { headers: { \"content-type\": \"audio/mpeg\", \"cache-control\": \"public, max-age=31536000\" } }); } catch { return new Response(\"not found\", { status: 404 }); } }\n\n if (req.method === \"GET\") return new Response(\"ElevenLabs MCP connector (audiobook). POST = JSON-RPC MCP.\", { status: 200 });\n\n // MCP JSON-RPC\n let body: any; try { body = await req.json(); } catch { return Response.json(rpc(null, undefined, { code: -32700, message: \"parse error\" })); }\n const { id, method, params } = body || {};\n try {\n if (method === \"initialize\")\n return Response.json(rpc(id, { protocolVersion: params?.protocolVersion ?? \"2025-06-18\", capabilities: { tools: {} }, serverInfo: { name: \"elevenlabs-audiobook\", version: \"2.0.0\" } }));\n if (method === \"notifications/initialized\") return new Response(null, { status: 202 });\n if (method === \"tools/list\") return Response.json(rpc(id, { tools: TOOLS }));\n if (method === \"tools/call\") {\n const fn = H[params?.name];\n if (!fn) return Response.json(rpc(id, undefined, { code: -32601, message: `nieznany tool: ${params?.name}` }));\n const out = await fn(params.arguments ?? {});\n return Response.json(rpc(id, { content: [{ type: \"text\", text: JSON.stringify(out) }] }));\n }\n return Response.json(rpc(id, undefined, { code: -32601, message: `nieznana metoda: ${method}` }));\n } catch (e) {\n return Response.json(rpc(id, { content: [{ type: \"text\", text: JSON.stringify({ error: String(e).slice(0, 300) }) }], isError: true }));\n }\n}","createdAt",["D",1780114192576],"branchVersion","branchId","81ac8dbc-5954-11f1-a20a-ee650bb23af1","id","81abf186-5954-11f1-a20a-ee650bb23af1","Elevenlabs",["D",1779835491284],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","52376bcb-d641-4952-81c2-24aad07615a6","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e5fc1-0ea2-72fa-904c-6707220b8246","tursoName","81abf186595411f1a20aee650bb23af1","tursoHostname","81abf186595411f1a20aee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789509672838],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",21,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","rafawiktorowicz","handle","displayName","Rafał Wiktorowicz","avatar","https://lh3.googleusercontent.com/a/ACg8ocKbp75cCjXsr6hEF5LeT4ePV1zdflGOWHOIG9GAIuLH5-GNTg=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":153,"_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":65,"_66":67,"_68":154,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":155,"_82":156,"_84":157,"_86":25},"tree",[148],"files",[148],"counts",{"_137":61,"_138":139,"_140":139,"_141":142,"_143":144},"contents",[129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":133,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":136},"68a24ea2-5bdd-11f1-98e4-ee650bb23af1","parentId","latest",["D",1780114192576],16,"label",[28],"pulls","branches",1,"forks","envVars",{"_145":139,"_147":61},"connections",{"_145":61,"_146":61},"count","unfilledCount","emptyCount",{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":149,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_150":151,"_27":152},["D",1780114192576],"children",[],[28],["D",1779835491284],["D",1789509672838],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":191,"_192":193,"_194":195,"_196":25,"_197":25,"_198":25,"_199":124,"_200":-5,"_201":-7,"_202":-7,"_203":61,"_204":25,"_205":25,"_206":-5,"_207":25,"_208":25,"_209":25,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":88,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"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 · v17