[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_180":181,"_182":183},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":24,"_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",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_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":24},"version",3,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","check_connection.ts","latestPath","fileId","f777b384-b23f-11f1-99fc-1607ee4eb77e","name","fileType","script","content","import { checkConnection } from \"./core.ts\";\ntry { console.log(JSON.stringify(await checkConnection())); } catch(e) { console.log(JSON.stringify({ok:false,message:e instanceof Error?e.message:\"Connection failed\"})); }\n","createdAt",["D",1789612322955],"branchVersion","branchId","1ee7eb37-0bf1-49fe-9423-2f1df9595d8f","id","0e357033-e80a-474f-9460-c64b53ec6cf0","seedance",["D",1789612203305],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","BytePlus video adapter with live model announcements","imageUrl","0d65c1b5-f226-4c7a-8c4b-30b17a9d544e","pinnedFileId","0f61c8fc-b25b-11f1-a03f-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e308b-edd7-77ca-895e-c4f0d8ba1fdb","tursoName","0e357033e80a474f9460c64b53ec6cf0","tursoHostname","0e357033e80a474f9460c64b53ec6cf0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789706445022],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",16,"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",{"_41":42,"_31":43,"_36":175,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":176,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":177,"_82":178,"_84":179,"_86":24},"tree",[162,163,164],"files",[162,163,164],"counts",{"_152":61,"_153":145,"_154":61,"_155":156,"_157":158},"contents",[129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":149,"_31":27,"_29":30,"_135":-5,"_39":40,"_38":14,"_137":57,"_36":150,"_13":61,"_32":33,"_34":35,"_23":24,"_140":-5,"_26":151},{"_41":142,"_31":143,"_29":144,"_135":-5,"_39":40,"_38":145,"_137":24,"_36":146,"_13":61,"_32":33,"_34":147,"_23":24,"_140":-5,"_26":148},{"_41":132,"_31":133,"_29":134,"_135":-5,"_39":40,"_38":136,"_137":57,"_36":138,"_13":61,"_32":33,"_34":139,"_23":24,"_140":-5,"_26":141},"313ab981-6a0c-448e-9923-140958084e96","main.ts","f2f8638a-b23f-11f1-9b1d-1607ee4eb77e","parentId",2,"latest",["D",1789612315413],"import { refreshModels } from \"./core.ts\";\nconsole.log(JSON.stringify(await refreshModels()));\n","label",[133],"ea9aa4f0-f44f-44d2-9809-39d3f2e78beb","core.ts","e5ee599c-b23f-11f1-b340-1607ee4eb77e",1,["D",1789612293535],"// Version-independent BytePlus adapter. No HTTP entrypoint; execute through authenticated Val Town MCP.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nexport const BASE = \"https://ark.ap-southeast.bytepluses.com/api/v3\";\nconst TASKS = \"/contents/generations/tasks\";\nconst DOCS = [\"https://www.byteplus.com/en\", \"https://docs.byteplus.com/en/docs/ModelArk\"];\ntype Obj = Record;\nexport async function init() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS models(id TEXT PRIMARY KEY, label TEXT NOT NULL, enabled INTEGER NOT NULL DEFAULT 0, source TEXT NOT NULL, updated_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS discoveries(name TEXT NOT NULL, source TEXT NOT NULL, first_seen TEXT NOT NULL, last_seen TEXT NOT NULL, PRIMARY KEY(name,source))`,\n `CREATE TABLE IF NOT EXISTS jobs(request_id TEXT PRIMARY KEY, payload TEXT NOT NULL, authorized INTEGER NOT NULL DEFAULT 0, state TEXT NOT NULL DEFAULT 'draft', task_id TEXT, result TEXT, created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP, submitted_at TEXT)`\n ], \"write\");\n}\nexport function validId(id: unknown): id is string {\n return typeof id === \"string\" && /^[a-zA-Z0-9_-]{1,160}$/.test(id) && !id.startsWith(\"apikey-\");\n}\nexport function validatePayload(body: Obj) {\n if (!body || typeof body !== \"object\" || Array.isArray(body) || !validId(body.model)) throw Error(\"Valid model/endpoint ID required; Resource ID apikey-... is not a model.\");\n if (!Array.isArray(body.content) || !body.content.length) throw Error(\"content array required.\");\n if (JSON.stringify(body).length > 150000) throw Error(\"Payload too large; use HTTPS reference URLs.\");\n const cap = Number(Deno.env.get(\"MAX_VIDEO_SECONDS\") || \"30\");\n if (!Number.isFinite(cap) || cap < 1) throw Error(\"Invalid MAX_VIDEO_SECONDS configuration.\");\n if (!Number.isInteger(body.duration) || body.duration < 1 || body.duration > cap) throw Error(`Explicit duration 1-${cap}s required. Model limits may be lower.`);\n for (const c of body.content) {\n if (c.type === \"text\") { if (typeof c.text !== \"string\" || !c.text.trim()) throw Error(\"Text is empty.\"); }\n else if ([\"image_url\", \"video_url\", \"audio_url\"].includes(c.type)) {\n const u = new URL(c[c.type]?.url);\n if (u.protocol !== \"https:\" || u.username || u.password) throw Error(\"Reference must be HTTPS without embedded credentials.\");\n } else throw Error(\"Unsupported content type; review adapter for a new API schema.\");\n }\n // New provider parameters are passed through, not silently discarded. Routing and credentials are never caller-controlled.\n for (const key of [\"api_key\", \"authorization\", \"base_url\", \"url\", \"headers\", \"callback_url\"]) {\n if (key in body) throw Error(\"Credentials, routing and callbacks are not accepted in job payloads.\");\n }\n return body;\n}\nexport function discoverNames(html: string): string[] {\n // Names are announcements only, never inferred API model IDs or entitlement.\n const text = html.replace(/]*>[\\s\\S]*?<\\/script>/gi, \" \").replace(/]*>[\\s\\S]*?<\\/style>/gi, \" \").replace(/<[^>]+>/g, \" \").replace(/ | /gi,\" \");\n return [...new Set(Array.from(text.matchAll(/\\bSeedance\\s*(\\d+(?:[.\\s]\\d+)?)(?:\\s+(fast|pro|lite|mini))?\\b/gi), m => `Seedance ${m[1].replace(/\\s+/,'.')}${m[2] ? ' '+m[2].toLowerCase() : ''}`))].sort();\n}\nclass ApiError extends Error { constructor(message: string, public uncertain=false) { super(message); } }\nfunction secret() {\n const key = Deno.env.get(\"ARK_API_KEY\")?.trim();\n if (!key || key.startsWith(\"apikey-\")) throw Error(\"Set secret ARK_API_KEY in this val's Environment Variables (not Resource ID).\");\n return key;\n}\nexport async function api(method: \"GET\"|\"POST\", path: string, body?: Obj, transport: typeof fetch = fetch) {\n const key=secret();\n let response: Response;\n try {\n response = await transport(BASE+path,{method,redirect:\"error\",signal:AbortSignal.timeout(20000),headers:{\"Authorization\":`Bearer ${key}`,\"Content-Type\":\"application/json\"},body: body ? JSON.stringify(body) : undefined});\n } catch { throw new ApiError(\"Network/timeout error. Check BytePlus tasks before resubmitting.\",method===\"POST\"); }\n if (!response.ok) throw new ApiError(`BytePlus HTTP ${response.status}. Check access, billing and parameters in console.`,method===\"POST\" && response.status>=500);\n try { return await response.json(); } catch { throw new ApiError(\"Invalid provider JSON; check console.\",method===\"POST\"); }\n}\nexport async function refreshModels() {\n await init();\n const reports=[];\n for(const source of DOCS){\n try {\n const r=await fetch(source,{signal:AbortSignal.timeout(10000),redirect:\"error\"});\n if(!r.ok) throw Error(`HTTP ${r.status}`);\n const html=await r.text();\n if(html.length>4000000) throw Error(\"Source exceeds parser limit\");\n const names=discoverNames(html), now=new Date().toISOString(), newlySeen=[];\n for(const name of names){\n const prior=await sqlite.execute({sql:\"SELECT name FROM discoveries WHERE name=? AND source=?\",args:[name,source]});\n if(!prior.rows.length) newlySeen.push(name);\n await sqlite.execute({sql:\"INSERT INTO discoveries VALUES(?,?,?,?) ON CONFLICT(name,source) DO UPDATE SET last_seen=excluded.last_seen\",args:[name,source,now,now]});\n }\n reports.push({source,checked_at:now,names,newly_seen:newlySeen,status:names.length?\"announcements_only\":\"incomplete_no_names_extracted\"});\n } catch { reports.push({source,status:\"unavailable\",checked_at:new Date().toISOString()}); }\n }\n return {reports, ...await configuration(), note:\"Live public-source discovery, not a complete account model list. No automatic model switch. New API formats require adapter review.\"};\n}\nexport async function configuration() {\n await init();\n const rows=await sqlite.execute(\"SELECT id,label,enabled,source,updated_at FROM models ORDER BY updated_at DESC\");\n const discovered=await sqlite.execute(\"SELECT name,source,first_seen,last_seen FROM discoveries ORDER BY last_seen DESC\");\n return {key_configured:!!Deno.env.get(\"ARK_API_KEY\"),default_model:Deno.env.get(\"ARK_MODEL\")||null,account_access_verified:false,registered_models:rows.rows,announcements:discovered.rows};\n}\nexport async function checkConnection(){\n await api(\"GET\",TASKS+\"?page_num=1&page_size=1\");\n return {authentication:\"accepted\",generation_tested:false,model_entitlement:\"not_verified\"};\n}\nexport function sanitizeTask(t:Obj){\n const result:Obj={};\n for(const k of [\"id\",\"model\",\"status\",\"duration\",\"resolution\",\"ratio\",\"created_at\"]) if(k in t) result[k]=t[k];\n result.content={};\n for(const k of [\"video_url\",\"file_url\",\"last_frame_url\"]){ const v=t.content?.[k]; if(typeof v===\"string\" && v.startsWith(\"https://\")) result.content[k]=v; }\n if(t.error) result.error={message:\"See BytePlus console for failure details.\"};\n return result;\n}\nexport async function recentVideos(){\n const r=await api(\"GET\",TASKS+\"?page_num=1&page_size=10\");\n return {items:(r.items||[]).map(sanitizeTask)};\n}\nexport async function pollJobs(){\n await init();\n const rows=await sqlite.execute(\"SELECT request_id,task_id FROM jobs WHERE state IN ('submitted','queued','running') AND task_id IS NOT NULL ORDER BY submitted_at DESC LIMIT 10\");\n const results=[];\n for(const row of rows.rows){\n if(!validId(row.task_id)) continue;\n try{\n const data=sanitizeTask(await api(\"GET\",TASKS+\"/\"+row.task_id));\n await sqlite.execute({sql:\"UPDATE jobs SET state=?,result=? WHERE request_id=?\",args:[data.status||\"submitted\",JSON.stringify(data),row.request_id]});\n results.push({request_id:row.request_id,...data});\n }catch(e){results.push({request_id:row.request_id,error: e instanceof ApiError?e.message:\"Configuration or local error\"});}\n }\n return results;\n}\nexport async function submitNext(transport: typeof fetch=fetch){\n await init(); secret();\n // Atomic single claim and daily budget check. A crash leaves 'submitting', never auto-retried.\n const limit=Number(Deno.env.get(\"MAX_DAILY_JOBS\")||\"10\");\n if(!Number.isInteger(limit)||limit<1||limit>1000) throw Error(\"Invalid MAX_DAILY_JOBS.\");\n const claim=await sqlite.execute({sql:`UPDATE jobs SET state='submitting',submitted_at=CURRENT_TIMESTAMP WHERE request_id=(SELECT request_id FROM jobs WHERE state='draft' AND authorized=1 ORDER BY created_at,request_id LIMIT 1) AND (SELECT count(*) FROM jobs WHERE submitted_at>=datetime('now','-1 day')) < ? RETURNING request_id,payload`,args:[limit]});\n if(!claim.rows.length) return {state:\"no_submission\",note:\"No authorized draft, or daily job count reached.\"};\n const row=claim.rows[0];\n let state=\"rejected\", taskId:string|null=null, result:Obj;\n try{\n const body=validatePayload(JSON.parse(String(row.payload)));\n const allowed=await sqlite.execute({sql:\"SELECT id FROM models WHERE id=? AND enabled=1\",args:[body.model]});\n if(!allowed.rows.length && body.model !== Deno.env.get(\"ARK_MODEL\")) throw Error(\"Model not explicitly enabled in registry or ARK_MODEL.\");\n const data=await api(\"POST\",TASKS,body,transport);\n if(!validId(data.id)) throw new ApiError(\"No valid task ID returned. Inspect BytePlus console.\",true);\n taskId=data.id;state=\"submitted\";result={id:taskId};\n }catch(e){\n state=e instanceof ApiError && e.uncertain?\"uncertain\":\"rejected\";\n result={error:e instanceof ApiError?e.message:\"Local validation failed. Check model registry, duration, references and payload schema.\"};\n }\n await sqlite.execute({sql:\"UPDATE jobs SET state=?,task_id=?,result=? WHERE request_id=?\",args:[state,taskId,JSON.stringify(result),row.request_id]});\n return {request_id:row.request_id,state,...result!};\n}\n",[143],"cc2be9cf-1ac6-4258-bd92-8828d56e869d",["D",1789612322955],[27],"pulls","branches","forks","envVars",{"_159":136,"_161":61},"connections",{"_159":61,"_160":61},"count","unfilledCount","emptyCount",{"_41":149,"_31":27,"_29":30,"_135":-5,"_39":40,"_38":14,"_137":57,"_36":172,"_13":61,"_32":33,"_34":35,"_23":24,"_140":-5,"_166":173,"_26":174},{"_41":142,"_31":143,"_29":144,"_135":-5,"_39":40,"_38":145,"_137":24,"_36":169,"_13":61,"_32":33,"_34":147,"_23":24,"_140":-5,"_166":170,"_26":171},{"_41":132,"_31":133,"_29":134,"_135":-5,"_39":40,"_38":136,"_137":57,"_36":165,"_13":61,"_32":33,"_34":139,"_23":24,"_140":-5,"_166":167,"_26":168},["D",1789612315413],"children",[],[133],["D",1789612293535],[],[143],["D",1789612322955],[],[27],["D",1789612203305],["D",1789706445022],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":213,"_214":215,"_216":217,"_218":24,"_219":24,"_220":24,"_221":57,"_222":-5,"_223":-7,"_224":-7,"_225":61,"_226":24,"_227":24,"_228":-5,"_229":24,"_230":24,"_231":24,"_232":-5},"ENV",{"_184":185,"_186":187,"_188":88,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","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 · v3