[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_93":92,"_32":45,"_102":83,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"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":45,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",7,"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","981e6f76-5e7b-11f1-8619-1607ee4eb77e","name","fileType","http","content","// ============================================================\n// KDP BUILDER — MCP serwer (Val Town / Deno) v1.0\n// CEL: składanie gotowego PDF z obrazów (URL -> wielostronicowy PDF KDP)\n// + generacja Recraft (recraftv4_1) na Twoim kluczu 5000.\n// Serwer MA internet, więc robi to, czego Claude w czacie nie może:\n// 1) pobiera obrazy po URL, 2) skleja PDF (pdf-lib), 3) hostuje go pod /pdf/.\n// Obrazy z Recrafta są re-hostowane w blob (trwałe) pod /img/.\n// ENV (SEKRET): RECRAFT_API_KEY\n// ============================================================\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { PDFDocument, rgb, StandardFonts } from \"https://esm.sh/pdf-lib@1.17.1\";\n\nconst RECRAFT_GEN = \"https://external.api.recraft.ai/v1/images/generations\";\nconst RECRAFT_ME = \"https://external.api.recraft.ai/v1/users/me\";\nconst MODEL_DEFAULT = \"recraftv4_1\";\n\nconst RETRY = {\n maxAttempts: 6,\n baseMs: 800,\n factor: 1.8,\n capMs: 20_000,\n retryStatuses: new Set([408, 409, 425, 429, 500, 502, 503, 504]),\n};\nconst TIMEOUT_MS = 180_000;\nconst DEFAULT_CONCURRENCY = 4, MAX_CONCURRENCY = 8;\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst jitter = (ms: number) => Math.round(ms * (0.7 + Math.random() * 0.6));\n\nclass RErr extends Error {\n status: number;\n retryable: boolean;\n constructor(m: string, s: number, r: boolean) {\n super(m);\n this.status = s;\n this.retryable = r;\n }\n}\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 withRetry(fn: () => Promise): Promise {\n let a = 0, wait = RETRY.baseMs, last: unknown;\n while (a < RETRY.maxAttempts) {\n try {\n return await fn();\n } catch (e) {\n const o = e as RErr;\n if (!o.retryable) throw e;\n if (++a >= RETRY.maxAttempts) break;\n await sleep(jitter(Math.min(wait, RETRY.capMs)));\n wait *= RETRY.factor;\n last = e;\n }\n }\n throw last;\n}\nconst KEY = () => {\n const k = Deno.env.get(\"RECRAFT_API_KEY\");\n if (!k) {\n throw new RErr(\n \"brak RECRAFT_API_KEY w ENV (dodaj sekret w valu)\",\n 500,\n false,\n );\n }\n return k;\n};\n\nlet SELF_ORIGIN = \"\";\n\n// base64 bezpieczny dla dużych Uint8Array\nfunction u8ToB64(u8: Uint8Array): string {\n let s = \"\";\n const CH = 0x8000;\n for (let i = 0; i < u8.length; i += CH) {\n s += String.fromCharCode.apply(null, u8.subarray(i, i + CH) as any);\n }\n return btoa(s);\n}\nconst b64ToU8 = (b: string) => Uint8Array.from(atob(b), (c) => c.charCodeAt(0));\n\nasync function storeBlob(prefix: string, bytes: Uint8Array, mime: string) {\n const id = crypto.randomUUID().replace(/-/g, \"\");\n await blob.setJSON(`${prefix}:${id}`, { b64: u8ToB64(bytes), mime });\n return {\n id,\n url: `${SELF_ORIGIN}/${prefix === \"img\" ? \"img\" : \"pdf\"}/${id}`,\n };\n}\n// image = http(s) URL | data-URL | blob id (img:) | surowy base64\nasync function loadBytes(\n image: string,\n): Promise<{ bytes: Uint8Array; mime: string }> {\n if (/^https?:/i.test(image)) {\n return await withRetry(async () => {\n const r = await fetch(image, {\n headers: { Accept: \"image/png,image/jpeg;q=0.9,*/*;q=0.5\" },\n });\n if (!r.ok) {\n throw new RErr(\n `pobranie obrazu HTTP ${r.status}`,\n r.status,\n RETRY.retryStatuses.has(r.status),\n );\n }\n return {\n bytes: new Uint8Array(await r.arrayBuffer()),\n mime: r.headers.get(\"content-type\") || \"image/png\",\n };\n });\n }\n if (image.startsWith(\"data:\")) {\n const mime = image.slice(5, image.indexOf(\";\")) || \"image/png\";\n const b = image.replace(/^data:[^,]+,/, \"\");\n return { bytes: b64ToU8(b), mime };\n }\n const o = await blob.getJSON(`img:${image}`);\n if (o) return { bytes: b64ToU8(o.b64), mime: o.mime || \"image/png\" };\n return { bytes: b64ToU8(image), mime: \"image/png\" };\n}\n\n// konwersja do formatu osadzalnego przez pdf-lib (png/jpg). WEBP itp. -> PNG przez proxy weserv (bez wasm).\nasync function toPngIfNeeded(\n bytes: Uint8Array,\n mime: string,\n srcUrl?: string,\n): Promise<{ bytes: Uint8Array; kind: \"png\" | \"jpg\" }> {\n const m = (mime || \"\").toLowerCase();\n if (m.includes(\"png\") || (bytes[0] === 0x89 && bytes[1] === 0x50)) {\n return { bytes, kind: \"png\" };\n }\n if (\n m.includes(\"jpeg\") || m.includes(\"jpg\") ||\n (bytes[0] === 0xFF && bytes[1] === 0xD8)\n ) return { bytes, kind: \"jpg\" };\n if (srcUrl && /^https?:/i.test(srcUrl)) {\n const prox = `https://images.weserv.nl/?url=${\n encodeURIComponent(srcUrl.replace(/^https?:\\/\\//i, \"\"))\n }&output=png`;\n const r = await fetch(prox);\n if (!r.ok) {\n throw new RErr(\n `konwersja PNG (weserv) HTTP ${r.status}`,\n r.status,\n false,\n );\n }\n return { bytes: new Uint8Array(await r.arrayBuffer()), kind: \"png\" };\n }\n throw new RErr(\n \"nieobsługiwany format obrazu (nie PNG/JPG i brak URL do konwersji)\",\n 415,\n false,\n );\n}\n\n// === RECRAFT: generacja ===\nasync function recraftGen(\n o: { prompt: string; model?: string; size?: string; style?: string },\n) {\n return await withRetry(async () => {\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), TIMEOUT_MS);\n let res: Response;\n try {\n res = await fetch(RECRAFT_GEN, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${KEY()}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n prompt: o.prompt,\n model: o.model || MODEL_DEFAULT,\n size: o.size || \"1024x1024\",\n n: 1,\n ...(o.style ? { style: o.style } : {}),\n }),\n signal: ctrl.signal,\n });\n } catch (e) {\n throw new RErr(`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 RErr(\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 rurl = data?.data?.[0]?.url;\n if (!rurl) throw new RErr(\"brak url w odpowiedzi Recraft\", 200, false);\n const r2 = await fetch(rurl);\n const buf = new Uint8Array(await r2.arrayBuffer());\n const stored = await storeBlob(\n \"img\",\n buf,\n r2.headers.get(\"content-type\") || \"image/png\",\n );\n return { id: stored.id, url: stored.url, recraft_url: rurl };\n });\n}\n\n// === SKŁADANIE PDF ===\nasync function composePdf(\n o: {\n items: { title?: string; image_url: string }[];\n book_title?: string;\n subtitle?: string;\n cover?: boolean;\n page_size?: string;\n },\n) {\n const items = o.items || [];\n if (!items.length) {\n throw new RErr(\"compose_pdf: pusta lista items\", 400, false);\n }\n const [PW, PH] = (o.page_size === \"a4\") ? [595.28, 841.89] : [612, 792]; // letter domyślnie (8.5x11)\n const M = 48;\n const pdf = await PDFDocument.create();\n const fontB = await pdf.embedFont(StandardFonts.HelveticaBold);\n const fontR = await pdf.embedFont(StandardFonts.Helvetica);\n const hasCover = o.cover !== false && !!o.book_title;\n\n if (hasCover) {\n const p = pdf.addPage([PW, PH]);\n let s = 42;\n const t = o.book_title!;\n while (fontB.widthOfTextAtSize(t, s) > PW - 2 * M && s > 16) s -= 2;\n const tw = fontB.widthOfTextAtSize(t, s);\n p.drawText(t, {\n x: (PW - tw) / 2,\n y: PH * 0.56,\n size: s,\n font: fontB,\n color: rgb(0.12, 0.12, 0.12),\n });\n if (o.subtitle) {\n const ss = 16;\n const sw = fontR.widthOfTextAtSize(o.subtitle, ss);\n p.drawText(o.subtitle, {\n x: (PW - sw) / 2,\n y: PH * 0.56 - 34,\n size: ss,\n font: fontR,\n color: rgb(0.45, 0.45, 0.45),\n });\n }\n }\n\n let pageNo = hasCover ? 1 : 0;\n for (const it of items) {\n const p = pdf.addPage([PW, PH]);\n pageNo++;\n if (it.title) {\n const s = 26;\n const tw = fontB.widthOfTextAtSize(it.title, s);\n p.drawText(it.title, {\n x: (PW - tw) / 2,\n y: PH - M - 16,\n size: s,\n font: fontB,\n color: rgb(0.12, 0.12, 0.12),\n });\n }\n const raw = await loadBytes(it.image_url);\n const emb = await toPngIfNeeded(raw.bytes, raw.mime, it.image_url);\n const img = emb.kind === \"png\"\n ? await pdf.embedPng(emb.bytes)\n : await pdf.embedJpg(emb.bytes);\n const topY = it.title ? (PH - M - 44) : (PH - M);\n const botY = M + 22;\n const boxW = PW - 2 * M, boxH = topY - botY;\n const sc = Math.min(boxW / img.width, boxH / img.height);\n const w = img.width * sc, h = img.height * sc;\n p.drawImage(img, {\n x: (PW - w) / 2,\n y: botY + (boxH - h) / 2,\n width: w,\n height: h,\n });\n const pn = String(pageNo);\n const pnw = fontR.widthOfTextAtSize(pn, 11);\n p.drawText(pn, {\n x: (PW - pnw) / 2,\n y: 22,\n size: 11,\n font: fontR,\n color: rgb(0.6, 0.6, 0.6),\n });\n }\n const out = await pdf.save();\n const stored = await storeBlob(\"pdf\", out, \"application/pdf\");\n return { id: stored.id, url: stored.url, pages: pdf.getPageCount() };\n}\n\nasync function getUser() {\n const res = await fetch(RECRAFT_ME, {\n headers: { Authorization: `Bearer ${KEY()}` },\n });\n const txt = await res.text();\n if (!res.ok) {\n throw new RErr(\n `HTTP ${res.status}: ${txt.slice(0, 300)}`,\n res.status,\n false,\n );\n }\n try {\n return JSON.parse(txt);\n } catch {\n return { raw: txt };\n }\n}\n\nasync function batch(\n items: any[],\n conc: number,\n fn: (it: any, i: number) => Promise,\n) {\n const lim = pLimit(Math.max(1, Math.min(MAX_CONCURRENCY, conc)));\n const out = await Promise.all(items.map((it, index) =>\n lim(async () => {\n try {\n return { index, ok: true, ...(await fn(it, index) as any) };\n } catch (e) {\n return { index, ok: false, error: (e as Error).message };\n }\n })\n ));\n out.sort((a: any, b: any) => a.index - b.index);\n return out;\n}\n\nconst TOOLS = [\n {\n name: \"compose_pdf\",\n description:\n \"★ Składa wielostronicowy PDF (KDP). items=[{title,image_url}]. Pobiera obrazy po URL i robi: 1 rysunek + tytuł na stronę. Opcje: book_title, subtitle, cover(bool), page_size(letter|a4). Zwraca {id,url,pages}.\",\n inputSchema: {\n type: \"object\",\n properties: {\n items: {\n type: \"array\",\n items: {\n type: \"object\",\n properties: {\n title: { type: \"string\" },\n image_url: { type: \"string\" },\n },\n required: [\"image_url\"],\n },\n },\n book_title: { type: \"string\" },\n subtitle: { type: \"string\" },\n cover: { type: \"boolean\" },\n page_size: { type: \"string\" },\n },\n required: [\"items\"],\n },\n },\n {\n name: \"recraft_generate\",\n description:\n \"Generuje obraz w Recraft (recraftv4_1) na kluczu 5000. Zwraca {id,url,recraft_url}. url jest trwały (re-host w blob).\",\n inputSchema: {\n type: \"object\",\n properties: {\n prompt: { type: \"string\" },\n model: { type: \"string\" },\n size: { type: \"string\" },\n style: { type: \"string\" },\n },\n required: [\"prompt\"],\n },\n },\n {\n name: \"recraft_generate_batch\",\n description:\n \"★ WIELOWĄTKOWO generuje LISTĘ promptów (pLimit). prompts=[...]. Zwraca [{index,id,url,recraft_url}].\",\n inputSchema: {\n type: \"object\",\n properties: {\n prompts: { type: \"array\", items: { type: \"string\" } },\n model: { type: \"string\" },\n size: { type: \"string\" },\n style: { type: \"string\" },\n max_concurrent: { type: \"number\" },\n },\n required: [\"prompts\"],\n },\n },\n {\n name: \"get_user\",\n description: \"Stan konta Recraft (m.in. kredyty).\",\n inputSchema: { type: \"object\", properties: {} },\n },\n {\n name: \"get_image\",\n description: \"Zwraca base64 obrazu zapisanego w blob wg id.\",\n inputSchema: {\n type: \"object\",\n properties: { id: { type: \"string\" } },\n required: [\"id\"],\n },\n },\n];\n\nasync function dispatch(name: string, a: any): Promise {\n if (name === \"compose_pdf\") {\n return JSON.stringify(\n await composePdf({\n items: a?.items ?? [],\n book_title: a?.book_title,\n subtitle: a?.subtitle,\n cover: a?.cover,\n page_size: a?.page_size,\n }),\n );\n }\n if (name === \"recraft_generate\") {\n return JSON.stringify(\n await recraftGen({\n prompt: String(a?.prompt ?? \"\"),\n model: a?.model,\n size: a?.size,\n style: a?.style,\n }),\n );\n }\n if (name === \"recraft_generate_batch\") {\n const r = await batch(\n (a?.prompts ?? []).map((p: string) => ({ prompt: p })),\n Number(a?.max_concurrent) || DEFAULT_CONCURRENCY,\n (it) =>\n recraftGen({\n prompt: String(it.prompt),\n model: a?.model,\n size: a?.size,\n style: a?.style,\n }),\n );\n return JSON.stringify(r);\n }\n if (name === \"get_user\") return JSON.stringify(await getUser());\n if (name === \"get_image\") {\n const o = await blob.getJSON(`img:${a.id}`);\n if (!o) throw new RErr(`brak obrazu ${a.id}`, 404, false);\n return JSON.stringify({ id: a.id, b64: o.b64, mime: o.mime });\n }\n throw new RErr(`Nieznane narzędzie: ${name}`, 400, false);\n}\n\n// --- TRANSPORT (MCP JSON-RPC + serwowanie /img/ i /pdf/) ---\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 SELF_ORIGIN = url.origin;\n if (req.method === \"GET\" && url.pathname.startsWith(\"/img/\")) {\n const o = await blob.getJSON(`img:${url.pathname.slice(5)}`);\n if (!o) return new Response(\"not found\", { status: 404 });\n return new Response(b64ToU8(o.b64), {\n headers: {\n \"Content-Type\": o.mime || \"image/png\",\n \"Cache-Control\": \"public, max-age=31536000\",\n },\n });\n }\n if (req.method === \"GET\" && url.pathname.startsWith(\"/pdf/\")) {\n const o = await blob.getJSON(`pdf:${url.pathname.slice(5)}`);\n if (!o) return new Response(\"not found\", { status: 404 });\n return new Response(b64ToU8(o.b64), {\n headers: {\n \"Content-Type\": \"application/pdf\",\n \"Content-Disposition\": `inline; filename=\"kdp.pdf\"`,\n \"Cache-Control\": \"public, max-age=31536000\",\n },\n });\n }\n if (req.method === \"GET\") {\n return new Response(\n `KDP BUILDER MCP v1.0 — działa. Tooly: compose_pdf, recraft_generate, recraft_generate_batch, get_user, get_image. PDF pod /pdf/, obrazy 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: \"kdpbuilder\", version: \"1.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 ?? {}),\n }],\n });\n } catch (e) {\n return ok(id, {\n content: [{ type: \"text\", text: `BŁĄD KDP: ${(e as Error).message}` }],\n isError: true,\n });\n }\n }\n return er(id, -32601, \"Method not found\");\n}","// ============================================================\n// KDP BUILDER — MCP serwer (Val Town / Deno) v1.0\n// CEL: składanie gotowego PDF z obrazów (URL -> wielostronicowy PDF KDP)\n// + generacja Recraft (recraftv4_1) na Twoim kluczu 5000.\n// Serwer MA internet, więc robi to, czego Claude w czacie nie może:\n// 1) pobiera obrazy po URL, 2) skleja PDF (pdf-lib), 3) hostuje go pod /pdf/.\n// Obrazy z Recrafta są re-hostowane w blob (trwałe) pod /img/.\n// ENV (SEKRET): RECRAFT_API_KEY\n// ============================================================\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { PDFDocument, rgb, StandardFonts } from \"https://esm.sh/pdf-lib@1.17.1\";\n\nconst RECRAFT_GEN = \"https://external.api.recraft.ai/v1/images/generations\";\nconst RECRAFT_ME = \"https://external.api.recraft.ai/v1/users/me\";\nconst MODEL_DEFAULT = \"recraftv4_1\";\n\nconst RETRY = {\n maxAttempts: 6,\n baseMs: 800,\n factor: 1.8,\n capMs: 20_000,\n retryStatuses: new Set([408, 409, 425, 429, 500, 502, 503, 504]),\n};\nconst TIMEOUT_MS = 180_000;\nconst DEFAULT_CONCURRENCY = 4, MAX_CONCURRENCY = 8;\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst jitter = (ms: number) => Math.round(ms * (0.7 + Math.random() * 0.6));\n\nclass RErr extends Error {\n status: number;\n retryable: boolean;\n constructor(m: string, s: number, r: boolean) {\n super(m);\n this.status = s;\n this.retryable = r;\n }\n}\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 withRetry(fn: () => Promise): Promise {\n let a = 0, wait = RETRY.baseMs, last: unknown;\n while (a < RETRY.maxAttempts) {\n try {\n return await fn();\n } catch (e) {\n const o = e as RErr;\n if (!o.retryable) throw e;\n if (++a >= RETRY.maxAttempts) break;\n await sleep(jitter(Math.min(wait, RETRY.capMs)));\n wait *= RETRY.factor;\n last = e;\n }\n }\n throw last;\n}\nconst KEY = () => {\n const k = Deno.env.get(\"RECRAFT_API_KEY\");\n if (!k) {\n throw new RErr(\n \"brak RECRAFT_API_KEY w ENV (dodaj sekret w valu)\",\n 500,\n false,\n );\n }\n return k;\n};\n\nlet SELF_ORIGIN = \"\";\n\n// base64 bezpieczny dla dużych Uint8Array\nfunction u8ToB64(u8: Uint8Array): string {\n let s = \"\";\n const CH = 0x8000;\n for (let i = 0; i < u8.length; i += CH) {\n s += String.fromCharCode.apply(null, u8.subarray(i, i + CH) as any);\n }\n return btoa(s);\n}\nconst b64ToU8 = (b: string) => Uint8Array.from(atob(b), (c) => c.charCodeAt(0));\n\nasync function storeBlob(prefix: string, bytes: Uint8Array, mime: string) {\n const id = crypto.randomUUID().replace(/-/g, \"\");\n await blob.setJSON(`${prefix}:${id}`, { b64: u8ToB64(bytes), mime });\n return {\n id,\n url: `${SELF_ORIGIN}/${prefix === \"img\" ? \"img\" : \"pdf\"}/${id}`,\n };\n}\n// image = http(s) URL | data-URL | blob id (img:) | surowy base64\nasync function loadBytes(\n image: string,\n): Promise<{ bytes: Uint8Array; mime: string }> {\n if (/^https?:/i.test(image)) {\n return await withRetry(async () => {\n const r = await fetch(image, {\n headers: { Accept: \"image/png,image/jpeg;q=0.9,*/*;q=0.5\" },\n });\n if (!r.ok) {\n throw new RErr(\n `pobranie obrazu HTTP ${r.status}`,\n r.status,\n RETRY.retryStatuses.has(r.status),\n );\n }\n return {\n bytes: new Uint8Array(await r.arrayBuffer()),\n mime: r.headers.get(\"content-type\") || \"image/png\",\n };\n });\n }\n if (image.startsWith(\"data:\")) {\n const mime = image.slice(5, image.indexOf(\";\")) || \"image/png\";\n const b = image.replace(/^data:[^,]+,/, \"\");\n return { bytes: b64ToU8(b), mime };\n }\n const o = await blob.getJSON(`img:${image}`);\n if (o) return { bytes: b64ToU8(o.b64), mime: o.mime || \"image/png\" };\n return { bytes: b64ToU8(image), mime: \"image/png\" };\n}\n\n// konwersja do formatu osadzalnego przez pdf-lib (png/jpg). WEBP itp. -> PNG przez proxy weserv (bez wasm).\nasync function toPngIfNeeded(\n bytes: Uint8Array,\n mime: string,\n srcUrl?: string,\n): Promise<{ bytes: Uint8Array; kind: \"png\" | \"jpg\" }> {\n const m = (mime || \"\").toLowerCase();\n if (m.includes(\"png\") || (bytes[0] === 0x89 && bytes[1] === 0x50)) {\n return { bytes, kind: \"png\" };\n }\n if (\n m.includes(\"jpeg\") || m.includes(\"jpg\") ||\n (bytes[0] === 0xFF && bytes[1] === 0xD8)\n ) return { bytes, kind: \"jpg\" };\n if (srcUrl && /^https?:/i.test(srcUrl)) {\n const prox = `https://images.weserv.nl/?url=${\n encodeURIComponent(srcUrl.replace(/^https?:\\/\\//i, \"\"))\n }&output=png`;\n const r = await fetch(prox);\n if (!r.ok) {\n throw new RErr(\n `konwersja PNG (weserv) HTTP ${r.status}`,\n r.status,\n false,\n );\n }\n return { bytes: new Uint8Array(await r.arrayBuffer()), kind: \"png\" };\n }\n throw new RErr(\n \"nieobsługiwany format obrazu (nie PNG/JPG i brak URL do konwersji)\",\n 415,\n false,\n );\n}\n\n// === RECRAFT: generacja ===\nasync function recraftGen(\n o: { prompt: string; model?: string; size?: string; style?: string },\n) {\n return await withRetry(async () => {\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), TIMEOUT_MS);\n let res: Response;\n try {\n res = await fetch(RECRAFT_GEN, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${KEY()}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n prompt: o.prompt,\n model: o.model || MODEL_DEFAULT,\n size: o.size || \"1024x1024\",\n n: 1,\n ...(o.style ? { style: o.style } : {}),\n }),\n signal: ctrl.signal,\n });\n } catch (e) {\n throw new RErr(`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 RErr(\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 rurl = data?.data?.[0]?.url;\n if (!rurl) throw new RErr(\"brak url w odpowiedzi Recraft\", 200, false);\n const r2 = await fetch(rurl);\n const buf = new Uint8Array(await r2.arrayBuffer());\n const stored = await storeBlob(\n \"img\",\n buf,\n r2.headers.get(\"content-type\") || \"image/png\",\n );\n return { id: stored.id, url: stored.url, recraft_url: rurl };\n });\n}\n\n// === SKŁADANIE PDF ===\nasync function composePdf(\n o: {\n items: { title?: string; image_url: string }[];\n book_title?: string;\n subtitle?: string;\n cover?: boolean;\n page_size?: string;\n },\n) {\n const items = o.items || [];\n if (!items.length) {\n throw new RErr(\"compose_pdf: pusta lista items\", 400, false);\n }\n const [PW, PH] = (o.page_size === \"a4\") ? [595.28, 841.89] : [612, 792]; // letter domyślnie (8.5x11)\n const M = 48;\n const pdf = await PDFDocument.create();\n const fontB = await pdf.embedFont(StandardFonts.HelveticaBold);\n const fontR = await pdf.embedFont(StandardFonts.Helvetica);\n const hasCover = o.cover !== false && !!o.book_title;\n\n if (hasCover) {\n const p = pdf.addPage([PW, PH]);\n let s = 42;\n const t = o.book_title!;\n while (fontB.widthOfTextAtSize(t, s) > PW - 2 * M && s > 16) s -= 2;\n const tw = fontB.widthOfTextAtSize(t, s);\n p.drawText(t, {\n x: (PW - tw) / 2,\n y: PH * 0.56,\n size: s,\n font: fontB,\n color: rgb(0.12, 0.12, 0.12),\n });\n if (o.subtitle) {\n const ss = 16;\n const sw = fontR.widthOfTextAtSize(o.subtitle, ss);\n p.drawText(o.subtitle, {\n x: (PW - sw) / 2,\n y: PH * 0.56 - 34,\n size: ss,\n font: fontR,\n color: rgb(0.45, 0.45, 0.45),\n });\n }\n }\n\n let pageNo = hasCover ? 1 : 0;\n for (const it of items) {\n const p = pdf.addPage([PW, PH]);\n pageNo++;\n if (it.title) {\n const s = 26;\n const tw = fontB.widthOfTextAtSize(it.title, s);\n p.drawText(it.title, {\n x: (PW - tw) / 2,\n y: PH - M - 16,\n size: s,\n font: fontB,\n color: rgb(0.12, 0.12, 0.12),\n });\n }\n const raw = await loadBytes(it.image_url);\n const emb = await toPngIfNeeded(raw.bytes, raw.mime, it.image_url);\n const img = emb.kind === \"png\"\n ? await pdf.embedPng(emb.bytes)\n : await pdf.embedJpg(emb.bytes);\n const topY = it.title ? (PH - M - 44) : (PH - M);\n const botY = M + 22;\n const boxW = PW - 2 * M, boxH = topY - botY;\n const sc = Math.min(boxW / img.width, boxH / img.height);\n const w = img.width * sc, h = img.height * sc;\n p.drawImage(img, {\n x: (PW - w) / 2,\n y: botY + (boxH - h) / 2,\n width: w,\n height: h,\n });\n const pn = String(pageNo);\n const pnw = fontR.widthOfTextAtSize(pn, 11);\n p.drawText(pn, {\n x: (PW - pnw) / 2,\n y: 22,\n size: 11,\n font: fontR,\n color: rgb(0.6, 0.6, 0.6),\n });\n }\n const out = await pdf.save();\n const stored = await storeBlob(\"pdf\", out, \"application/pdf\");\n return { id: stored.id, url: stored.url, pages: pdf.getPageCount() };\n}\n\nasync function getUser() {\n const res = await fetch(RECRAFT_ME, {\n headers: { Authorization: `Bearer ${KEY()}` },\n });\n const txt = await res.text();\n if (!res.ok) {\n throw new RErr(\n `HTTP ${res.status}: ${txt.slice(0, 300)}`,\n res.status,\n false,\n );\n }\n try {\n return JSON.parse(txt);\n } catch {\n return { raw: txt };\n }\n}\n\nasync function batch(\n items: any[],\n conc: number,\n fn: (it: any, i: number) => Promise,\n) {\n const lim = pLimit(Math.max(1, Math.min(MAX_CONCURRENCY, conc)));\n const out = await Promise.all(items.map((it, index) =>\n lim(async () => {\n try {\n return { index, ok: true, ...(await fn(it, index) as any) };\n } catch (e) {\n return { index, ok: false, error: (e as Error).message };\n }\n })\n ));\n out.sort((a: any, b: any) => a.index - b.index);\n return out;\n}\n\nconst TOOLS = [\n {\n name: \"compose_pdf\",\n description:\n \"★ Składa wielostronicowy PDF (KDP). items=[{title,image_url}]. Pobiera obrazy po URL i robi: 1 rysunek + tytuł na stronę. Opcje: book_title, subtitle, cover(bool), page_size(letter|a4). Zwraca {id,url,pages}.\",\n inputSchema: {\n type: \"object\",\n properties: {\n items: {\n type: \"array\",\n items: {\n type: \"object\",\n properties: {\n title: { type: \"string\" },\n image_url: { type: \"string\" },\n },\n required: [\"image_url\"],\n },\n },\n book_title: { type: \"string\" },\n subtitle: { type: \"string\" },\n cover: { type: \"boolean\" },\n page_size: { type: \"string\" },\n },\n required: [\"items\"],\n },\n },\n {\n name: \"recraft_generate\",\n description:\n \"Generuje obraz w Recraft (recraftv4_1) na kluczu 5000. Zwraca {id,url,recraft_url}. url jest trwały (re-host w blob).\",\n inputSchema: {\n type: \"object\",\n properties: {\n prompt: { type: \"string\" },\n model: { type: \"string\" },\n size: { type: \"string\" },\n style: { type: \"string\" },\n },\n required: [\"prompt\"],\n },\n },\n {\n name: \"recraft_generate_batch\",\n description:\n \"★ WIELOWĄTKOWO generuje LISTĘ promptów (pLimit). prompts=[...]. Zwraca [{index,id,url,recraft_url}].\",\n inputSchema: {\n type: \"object\",\n properties: {\n prompts: { type: \"array\", items: { type: \"string\" } },\n model: { type: \"string\" },\n size: { type: \"string\" },\n style: { type: \"string\" },\n max_concurrent: { type: \"number\" },\n },\n required: [\"prompts\"],\n },\n },\n {\n name: \"get_user\",\n description: \"Stan konta Recraft (m.in. kredyty).\",\n inputSchema: { type: \"object\", properties: {} },\n },\n {\n name: \"get_image\",\n description: \"Zwraca base64 obrazu zapisanego w blob wg id.\",\n inputSchema: {\n type: \"object\",\n properties: { id: { type: \"string\" } },\n required: [\"id\"],\n },\n },\n {\n name: \"fetch_b64_batch\",\n description:\n \"★ Pobiera obrazy po URL i zwraca base64 (PNG, konwersja jeśli webp). DUŻY payload (zrzut na dysk).\",\n inputSchema: {\n type: \"object\",\n properties: { urls: { type: \"array\", items: { type: \"string\" } } },\n required: [\"urls\"],\n },\n },\n];\n\nasync function dispatch(name: string, a: any): Promise {\n if (name === \"compose_pdf\") {\n return JSON.stringify(\n await composePdf({\n items: a?.items ?? [],\n book_title: a?.book_title,\n subtitle: a?.subtitle,\n cover: a?.cover,\n page_size: a?.page_size,\n }),\n );\n }\n if (name === \"recraft_generate\") {\n return JSON.stringify(\n await recraftGen({\n prompt: String(a?.prompt ?? \"\"),\n model: a?.model,\n size: a?.size,\n style: a?.style,\n }),\n );\n }\n if (name === \"recraft_generate_batch\") {\n const r = await batch(\n (a?.prompts ?? []).map((p: string) => ({ prompt: p })),\n Number(a?.max_concurrent) || DEFAULT_CONCURRENCY,\n (it) =>\n recraftGen({\n prompt: String(it.prompt),\n model: a?.model,\n size: a?.size,\n style: a?.style,\n }),\n );\n return JSON.stringify(r);\n }\n if (name === \"get_user\") return JSON.stringify(await getUser());\n if (name === \"get_image\") {\n const o = await blob.getJSON(`img:${a.id}`);\n if (!o) throw new RErr(`brak obrazu ${a.id}`, 404, false);\n return JSON.stringify({ id: a.id, b64: o.b64, mime: o.mime });\n }\n if (name === \"fetch_b64_batch\") {\n const urls: string[] = a?.urls ?? [];\n const images: any[] = [];\n for (const u of urls) {\n try {\n const r = await loadBytes(u);\n const e = await toPngIfNeeded(r.bytes, r.mime, u);\n images.push({ url: u, b64: u8ToB64(e.bytes), mime: \"image/png\" });\n } catch (err) {\n images.push({ url: u, error: (err as Error).message });\n }\n }\n let payload = JSON.stringify({ images });\n const TARGET = 1150000;\n if (payload.length < TARGET) {\n payload = JSON.stringify({\n images,\n _pad: \" \".repeat(TARGET - payload.length),\n });\n }\n return payload;\n }\n throw new RErr(`Nieznane narzędzie: ${name}`, 400, false);\n}\n\n// --- TRANSPORT (MCP JSON-RPC + serwowanie /img/ i /pdf/) ---\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 SELF_ORIGIN = url.origin;\n if (req.method === \"GET\" && url.pathname.startsWith(\"/img/\")) {\n const o = await blob.getJSON(`img:${url.pathname.slice(5)}`);\n if (!o) return new Response(\"not found\", { status: 404 });\n return new Response(b64ToU8(o.b64), {\n headers: {\n \"Content-Type\": o.mime || \"image/png\",\n \"Cache-Control\": \"public, max-age=31536000\",\n },\n });\n }\n if (req.method === \"GET\" && url.pathname.startsWith(\"/pdf/\")) {\n const o = await blob.getJSON(`pdf:${url.pathname.slice(5)}`);\n if (!o) return new Response(\"not found\", { status: 404 });\n return new Response(b64ToU8(o.b64), {\n headers: {\n \"Content-Type\": \"application/pdf\",\n \"Content-Disposition\": `inline; filename=\"kdp.pdf\"`,\n \"Cache-Control\": \"public, max-age=31536000\",\n },\n });\n }\n if (req.method === \"GET\") {\n return new Response(\n `KDP BUILDER MCP v1.0 — działa. Tooly: compose_pdf, recraft_generate, recraft_generate_batch, get_user, get_image. PDF pod /pdf/, obrazy 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: \"kdpbuilder\", version: \"1.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 ?? {}),\n }],\n });\n } catch (e) {\n return ok(id, {\n content: [{ type: \"text\", text: `BŁĄD KDP: ${(e as Error).message}` }],\n isError: true,\n });\n }\n }\n return er(id, -32601, \"Method not found\");\n}","createdAt",["D",1780503995366],"branchVersion","branchId","981c2ee6-5e7b-11f1-8619-1607ee4eb77e","id","981b75fa-5e7b-11f1-8619-1607ee4eb77e","recraft",["D",1780402035111],"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","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_93":92,"_101":97},"org",{"_93":92,"_94":95,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":14,"_32":83,"_43":42,"_84":44,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":45,"_91":92},"isOwned","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":149,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":45,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":150,"_78":151,"_80":152,"_82":25},"tree",[144],"files",[144],"counts",{"_133":60,"_134":135,"_136":60,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":120,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"fd29b2d4-5f68-11f1-a3cc-1607ee4eb77e","parentId","latest",["D",1780503995366],6,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":135,"_143":60},"connections",{"_141":60,"_142":60},"count","unfilledCount","emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":120,"_38":145,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_146":147,"_27":148},["D",1780503995366],"children",[],[28],["D",1780402035111],{"_93":92,"_101":97},{"_93":92,"_94":95,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":14,"_32":83,"_43":42,"_84":44,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":45,"_91":92},"ctx",{"_76":-5,"_122":186,"_187":188,"_189":190,"_191":25,"_192":25,"_193":25,"_194":120,"_195":-5,"_196":-7,"_197":-7,"_198":60,"_199":25,"_200":25,"_201":-5,"_202":25,"_203":25,"_204":25,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":83,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v7