[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_144":145,"_146":147},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_82":64,"_83":84,"_62":-7,"_85":-5,"_13":86,"_87":88,"_11":89,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":-5,"_97":26,"_98":99,"_100":101,"_102":-5,"_103":-5,"_104":105},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":21,"_31":-5,"_32":33,"_34":-5,"_35":26,"_36":-5,"_37":-5,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":47,"_48":47,"_49":50,"_51":50,"_52":50,"_53":47,"_54":47,"_55":56,"_57":58,"_59":60,"_61":26},"query","handle","rafawiktorowicz","id","aac63886-5e0d-46f0-9f1d-ff3a0f81fe1b","name","Audiofon","createdAt",["D",1781280753109],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","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",{"_16":17,"_81":77},"org",{"_16":17,"_74":75,"_76":77,"_32":33,"_78":79,"_80":26},"branch",{"_62":63,"_20":64,"_18":65,"_66":19,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":21,"_73":17},"isOwned","version",7,"main","869f9fa2-82c9-43af-a25e-fc310ca370e2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Rafał Wiktorowicz","avatar","https://lh3.googleusercontent.com/a/ACg8ocKbp75cCjXsr6hEF5LeT4ePV1zdflGOWHOIG9GAIuLH5-GNTg=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_18":19,"_20":21,"_22":140,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":21,"_31":-5,"_32":33,"_34":-5,"_35":26,"_36":-5,"_37":-5,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":47,"_48":47,"_49":50,"_51":50,"_52":50,"_53":47,"_54":47,"_55":141,"_57":142,"_59":143,"_61":26},"tree",[135],[135],"counts",{"_124":39,"_125":126,"_127":39,"_128":129,"_130":131},"contents",[106],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_18":107,"_20":108,"_109":110,"_111":-5,"_112":65,"_113":63,"_114":101,"_22":115,"_62":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_83":123},"430357c7-a275-475a-9d93-7fcab4194730","main.ts","fileId","84dd0908-6679-11f1-9158-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1781281923456],6,"fileType","http","content","// ============================================================================\n// Auphonic MCP connector — v5\n// De-esser / mastering audiobooka przez Auphonic API.\n// v4: upload bajtów (omija walidację URL).\n// v5: wynik POBIERANY z Auphonic (z tokenem) i zapisywany w valu ->\n// zwraca PUBLICZNY link …val.run/audio/ (otwieralny wszędzie, do Excela/montażu).\n//\n// ENV (Settings vala):\n// AUPHONIC_TOKEN = API key (Bearer token) [WYMAGANE]\n// AUPHONIC_PRESET = domyślny UUID presetu [OPCJONALNE]\n//\n// Narzędzia:\n// list_presets() -> presety + UUID\n// deess_start(url, preset?) -> 1 plik: zwraca {uuid} OD RAZU\n// deess_get(uuid) -> status; gdy done -> mirroruje wynik i zwraca public_url\n// deess(url, preset?) -> 1 plik wszystko-w-jednym (krótkie, czeka ~80s)\n// deess_batch(urls[], preset?) -> ★ N plików RÓWNOLEGLE, zwraca listę {uuid}\n// deess_batch_get(uuids[]) -> ★ statusy naraz; gotowe -> public_urls\n// ============================================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst TOKEN = Deno.env.get(\"AUPHONIC_TOKEN\") ?? \"\";\nconst DEFAULT_PRESET = Deno.env.get(\"AUPHONIC_PRESET\") ?? \"\";\nconst API = \"https://auphonic.com/api\";\nlet SELF_ORIGIN = \"\";\n\nfunction authHeaders(extra: Record = {}): Record {\n return { \"Authorization\": `Bearer ${TOKEN}`, ...extra };\n}\n\nasync function apiGET(path: string): Promise {\n const r = await fetch(`${API}${path}`, { headers: authHeaders() });\n const txt = await r.text();\n if (!r.ok) throw new Error(`GET ${path} -> ${r.status}: ${txt.slice(0, 300)}`);\n return JSON.parse(txt);\n}\n\n// ---- list_presets --------------------------------------------------------\nasync function doListPresets() {\n const j = await apiGET(\"/presets.json\");\n const items = (j.data ?? []).map((p: any) => ({\n uuid: p.uuid,\n preset_name: p.preset_name ?? p.metadata?.title ?? \"(bez nazwy)\",\n }));\n return { count: items.length, presets: items };\n}\n\n// ---- tworzenie + start: POBIERZ bajty i wyślij jako UPLOAD (omija walidację URL) ----\nasync function createAndStart(url: string, preset: string): Promise {\n if (!preset) {\n throw new Error(\"Brak presetu. Podaj preset (UUID) lub ustaw ENV AUPHONIC_PRESET. UUID: list_presets().\");\n }\n const fr = await fetch(url);\n if (!fr.ok) throw new Error(`Nie pobrałem pliku źródłowego: ${fr.status}`);\n const bytes = new Uint8Array(await fr.arrayBuffer());\n const fname = (url.split(\"/\").pop() || \"audio\") + \".mp3\";\n\n const fd = new FormData();\n fd.append(\"preset\", preset);\n fd.append(\"action\", \"start\");\n fd.append(\"input_file\", new Blob([bytes], { type: \"audio/mpeg\" }), fname);\n\n const r = await fetch(`${API}/simple/productions.json`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${TOKEN}` },\n body: fd,\n });\n const txt = await r.text();\n if (!r.ok) throw new Error(`POST /simple/productions.json (upload) -> ${r.status}: ${txt.slice(0, 300)}`);\n const j = JSON.parse(txt);\n const uuid = j?.data?.uuid;\n if (!uuid) throw new Error(`Brak uuid: ${txt.slice(0, 200)}`);\n return uuid as string;\n}\n\nfunction pickAuphonicDownload(data: any): string | null {\n const outs = data?.output_files ?? [];\n if (outs.length && outs[0].download_url) return outs[0].download_url;\n return null;\n}\n\n// pobiera gotowy plik z Auphonic (z tokenem) i zapisuje w valu -> public_url\nasync function mirrorResult(uuid: string, auphonicUrl: string): Promise {\n const r = await fetch(auphonicUrl, { headers: authHeaders(), redirect: \"follow\" });\n if (!r.ok) throw new Error(`Pobieranie wyniku Auphonic -> ${r.status}`);\n const bytes = new Uint8Array(await r.arrayBuffer());\n await blob.set(`out_${uuid}`, new Blob([bytes], { type: \"audio/mpeg\" }));\n return `${SELF_ORIGIN}/audio/${uuid}`;\n}\n\nasync function getStatus(uuid: string) {\n const j = await apiGET(`/production/${uuid}.json`);\n const d = j.data ?? {};\n const status = String(d.status_string ?? d.status ?? \"\");\n const done = /done/i.test(status);\n const error = /error|fail/i.test(status);\n let public_url: string | null = null;\n let auphonic_url: string | null = null;\n if (done) {\n auphonic_url = pickAuphonicDownload(d);\n if (auphonic_url) {\n // jeśli już zmirrorowane, nie pobieraj ponownie\n let exists = false;\n try { exists = !!(await blob.get(`out_${uuid}`)); } catch { exists = false; }\n public_url = exists ? `${SELF_ORIGIN}/audio/${uuid}` : await mirrorResult(uuid, auphonic_url);\n }\n }\n return {\n uuid,\n status,\n done,\n error,\n public_url, // <- TEN link otwierasz wszędzie\n auphonic_url, // <- oryginalny (za logowaniem), informacyjnie\n error_message: d.error_message || undefined,\n };\n}\n\n// ---- pojedyncze -----------------------------------------------------------\nasync function doDeessStart(a: Record) {\n const url = String(a.url ?? \"\");\n if (!url) throw new Error(\"Brak url.\");\n const preset = String(a.preset ?? DEFAULT_PRESET);\n const uuid = await createAndStart(url, preset);\n return { uuid, status: \"processing\", preset_used: preset, hint: \"Odpytuj deess_get(uuid).\" };\n}\n\nasync function doDeessGet(a: Record) {\n const uuid = String(a.uuid ?? \"\");\n if (!uuid) throw new Error(\"Brak uuid.\");\n return await getStatus(uuid);\n}\n\nasync function doDeess(a: Record) {\n const start = await doDeessStart(a);\n for (let i = 0; i < 16; i++) {\n await new Promise((z) => setTimeout(z, 5000));\n const st = await getStatus(start.uuid);\n if (st.done || st.error) return { ...st, preset_used: start.preset_used };\n }\n return { uuid: start.uuid, status: \"processing\", done: false, note: \"Dokończ przez deess_get(uuid).\", preset_used: start.preset_used };\n}\n\n// ---- WSADOWE (równolegle) -------------------------------------------------\nasync function doDeessBatch(a: Record) {\n const urls = (a.urls as string[]) ?? [];\n if (!urls.length) throw new Error(\"Brak urls.\");\n const preset = String(a.preset ?? DEFAULT_PRESET);\n const maxC = Math.min(Number(a.max_concurrent ?? 5), urls.length);\n\n const results: Array<{ url: string; uuid?: string; error?: string }> = new Array(urls.length);\n const queue = urls.map((url, idx) => ({ url, idx }));\n const worker = async () => {\n while (queue.length) {\n const item = queue.shift();\n if (!item) break;\n try {\n const uuid = await createAndStart(item.url, preset);\n results[item.idx] = { url: item.url, uuid };\n } catch (e) {\n results[item.idx] = { url: item.url, error: (e as Error).message };\n }\n }\n };\n await Promise.all(Array(maxC).fill(null).map(() => worker()));\n\n const uuids = results.filter((r) => r.uuid).map((r) => r.uuid as string);\n const failed = results.filter((r) => r.error);\n return {\n count: urls.length,\n started: uuids.length,\n uuids,\n items: results,\n failed_count: failed.length,\n preset_used: preset,\n hint: \"Odpytuj deess_batch_get(uuids) aż all_done -> public_urls.\",\n };\n}\n\nasync function doDeessBatchGet(a: Record) {\n const uuids = (a.uuids as string[]) ?? [];\n if (!uuids.length) throw new Error(\"Brak uuids.\");\n const statuses = await Promise.all(uuids.map((u) => getStatus(String(u)).catch((e) => ({\n uuid: String(u), status: \"error\", done: false, error: true, public_url: null, auphonic_url: null, error_message: (e as Error).message,\n }))));\n const done = statuses.filter((s) => s.done);\n return {\n total: uuids.length,\n done_count: done.length,\n processing_count: statuses.filter((s) => !s.done && !s.error).length,\n error_count: statuses.filter((s) => s.error).length,\n all_done: done.length === uuids.length,\n public_urls: done.map((s) => s.public_url),\n statuses,\n };\n}\n\n// ---- MCP boilerplate ------------------------------------------------------\nconst TOOLS = [\n { name: \"list_presets\", description: \"Lista presetów Auphonic (uuid + nazwa).\", inputSchema: { type: \"object\", properties: {} } },\n {\n name: \"deess_start\",\n description: \"★ 1 plik: startuje de-essing, zwraca {uuid} OD RAZU. Potem deess_get.\",\n inputSchema: { type: \"object\", properties: { url: { type: \"string\" }, preset: { type: \"string\", description: \"UUID presetu; pusty = ENV.\" } }, required: [\"url\"] },\n },\n {\n name: \"deess_get\",\n description: \"Status 1 produkcji. done=true -> public_url (otwieralny wszędzie).\",\n inputSchema: { type: \"object\", properties: { uuid: { type: \"string\" } }, required: [\"uuid\"] },\n },\n {\n name: \"deess\",\n description: \"1 plik wszystko-w-jednym (krótkie; czeka ~80s). Zwraca public_url.\",\n inputSchema: { type: \"object\", properties: { url: { type: \"string\" }, preset: { type: \"string\" } }, required: [\"url\"] },\n },\n {\n name: \"deess_batch\",\n description: \"★ N plików RÓWNOLEGLE: tworzy i startuje wszystkie, zwraca listę {uuid} jednym wywołaniem. Do 10+ na raz.\",\n inputSchema: {\n type: \"object\",\n properties: {\n urls: { type: \"array\", items: { type: \"string\" }, description: \"Lista publicznych linków MP3.\" },\n preset: { type: \"string\", description: \"UUID presetu; pusty = ENV.\" },\n max_concurrent: { type: \"number\", default: 5 },\n },\n required: [\"urls\"],\n },\n },\n {\n name: \"deess_batch_get\",\n description: \"★ Statusy naraz. all_done=true -> public_urls gotowe.\",\n inputSchema: { type: \"object\", properties: { uuids: { type: \"array\", items: { type: \"string\" } } }, required: [\"uuids\"] },\n },\n];\n\nasync function callTool(name: string, args: Record) {\n if (name === \"list_presets\") return await doListPresets();\n if (name === \"deess_start\") return await doDeessStart(args);\n if (name === \"deess_get\") return await doDeessGet(args);\n if (name === \"deess\") return await doDeess(args);\n if (name === \"deess_batch\") return await doDeessBatch(args);\n if (name === \"deess_batch_get\") return await doDeessBatchGet(args);\n throw new Error(`Unknown tool: ${name}`);\n}\n\nfunction rpc(id: unknown, result?: unknown, error?: unknown) {\n const body: Record = { jsonrpc: \"2.0\", id };\n if (error) body.error = error;\n else body.result = result;\n return new Response(JSON.stringify(body), { headers: { \"content-type\": \"application/json\" } });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n SELF_ORIGIN = url.origin;\n\n // serwowanie zmirrorowanych wyników\n if (req.method === \"GET\" && url.pathname.startsWith(\"/audio/\")) {\n const id = url.pathname.slice(\"/audio/\".length);\n try {\n const b = await blob.get(`out_${id}`);\n return new Response(await b.arrayBuffer(), { headers: { \"content-type\": \"audio/mpeg\" } });\n } catch {\n return new Response(\"not found\", { status: 404 });\n }\n }\n\n if (req.method === \"GET\" && url.pathname === \"/\") return new Response(\"Auphonic MCP v5. POST /mcp\");\n if (req.method === \"POST\" && (url.pathname === \"/mcp\" || url.pathname === \"/\")) {\n let msg: any;\n try { msg = await req.json(); } catch { return rpc(null, undefined, { code: -32700, message: \"Parse error\" }); }\n const { id, method, params } = msg ?? {};\n if (method === \"initialize\") {\n return rpc(id, { protocolVersion: \"2024-11-05\", capabilities: { tools: {} }, serverInfo: { name: \"auphonic-mcp\", version: \"5.0.0\" } });\n }\n if (method === \"notifications/initialized\") return new Response(null, { status: 204 });\n if (method === \"tools/list\") return rpc(id, { tools: TOOLS });\n if (method === \"tools/call\") {\n try {\n const out = await callTool(params?.name, params?.arguments ?? {});\n return rpc(id, { content: [{ type: \"text\", text: JSON.stringify(out, null, 2) }] });\n } catch (e) {\n return rpc(id, { content: [{ type: \"text\", text: `BŁĄD: ${(e as Error).message}` }], isError: true });\n }\n }\n return rpc(id, undefined, { code: -32601, message: `Method not found: ${method}` });\n }\n return new Response(\"Method not allowed\", { status: 405 });\n}","deleted","label",[108],"pulls","branches",1,"forks","envVars",{"_132":126,"_134":39},"connections",{"_132":39,"_133":39},"count","unfilledCount","emptyCount",{"_18":107,"_20":108,"_109":110,"_111":-5,"_112":65,"_113":63,"_114":101,"_22":136,"_62":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_137":138,"_83":139},["D",1781281923456],"children",[],[108],["D",1781280753109],{"_16":17,"_81":77},{"_16":17,"_74":75,"_76":77,"_32":33,"_78":79,"_80":26},{"_62":63,"_20":64,"_18":65,"_66":19,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":21,"_73":17},"ctx",{"_55":-5,"_103":177,"_178":179,"_180":181,"_182":26,"_183":26,"_184":26,"_185":101,"_186":-5,"_187":-7,"_188":-7,"_189":39,"_190":26,"_191":26,"_192":-5,"_193":26,"_194":26,"_195":26,"_196":-5},"ENV",{"_148":149,"_150":151,"_152":64,"_153":154,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176},"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"]

Search