[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_216":217,"_218":219},"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",6,"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","recent.ts","latestPath","fileId","05962f04-b240-11f1-8d94-1607ee4eb77e","name","fileType","script","content","import { recentVideos } from \"./core.ts\";\ntry { console.log(JSON.stringify(await recentVideos())); } catch { console.log(JSON.stringify({ok:false,message:\"Cannot read BytePlus tasks; verify credentials and connectivity.\"})); }\n","createdAt",["D",1789612346641],"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":211,"_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":212,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":213,"_82":214,"_84":215,"_86":24},"tree",[186,187,188,189,190,191],"files",[186,187,188,189,190,191],"counts",{"_176":61,"_177":165,"_178":61,"_179":180,"_181":182},"contents",[129,130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":169,"_31":170,"_29":171,"_138":-5,"_39":40,"_38":172,"_140":57,"_36":173,"_13":61,"_32":33,"_34":174,"_23":24,"_143":-5,"_26":175},{"_41":162,"_31":163,"_29":164,"_138":-5,"_39":40,"_38":165,"_140":24,"_36":166,"_13":61,"_32":33,"_34":167,"_23":24,"_143":-5,"_26":168},{"_41":155,"_31":156,"_29":157,"_138":-5,"_39":40,"_38":158,"_140":57,"_36":159,"_13":61,"_32":33,"_34":160,"_23":24,"_143":-5,"_26":161},{"_41":152,"_31":27,"_29":30,"_138":-5,"_39":40,"_38":14,"_140":57,"_36":153,"_13":61,"_32":33,"_34":35,"_23":24,"_143":-5,"_26":154},{"_41":145,"_31":146,"_29":147,"_138":-5,"_39":40,"_38":148,"_140":57,"_36":149,"_13":61,"_32":33,"_34":150,"_23":24,"_143":-5,"_26":151},{"_41":135,"_31":136,"_29":137,"_138":-5,"_39":40,"_38":139,"_140":57,"_36":141,"_13":61,"_32":33,"_34":142,"_23":24,"_143":-5,"_26":144},"38bf0b49-34eb-4ccd-8daa-19fe99a25ad5","submit.ts","fc2b63e4-b23f-11f1-b4ed-1607ee4eb77e","parentId",4,"latest",["D",1789612330847],"// PAID ACTION: only run after explicit user authorization of the queued job.\nimport { submitNext } from \"./core.ts\";\ntry { console.log(JSON.stringify(await submitNext())); } catch { console.log(JSON.stringify({ok:false,message:\"Configure ARK_API_KEY before submitting. No automatic retry.\"})); }\n","label",[136],"dbab1d6e-478e-4d0a-aec5-f81892296936","status.ts","007c6af6-b240-11f1-bfd8-1607ee4eb77e",5,["D",1789612338078],"import { pollJobs } from \"./core.ts\";\nconsole.log(JSON.stringify(await pollJobs()));\n",[146],"6537b8f5-c8f6-430b-b913-b4645ee569b2",["D",1789612346641],[27],"313ab981-6a0c-448e-9923-140958084e96","main.ts","f2f8638a-b23f-11f1-9b1d-1607ee4eb77e",2,["D",1789612315413],"import { refreshModels } from \"./core.ts\";\nconsole.log(JSON.stringify(await refreshModels()));\n",[156],"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",[163],"cc2be9cf-1ac6-4258-bd92-8828d56e869d","check_connection.ts","f777b384-b23f-11f1-99fc-1607ee4eb77e",3,["D",1789612322955],"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",[170],"pulls","branches","forks","envVars",{"_183":158,"_185":61},"connections",{"_183":61,"_184":61},"count","unfilledCount","emptyCount",{"_41":169,"_31":170,"_29":171,"_138":-5,"_39":40,"_38":172,"_140":57,"_36":208,"_13":61,"_32":33,"_34":174,"_23":24,"_143":-5,"_193":209,"_26":210},{"_41":162,"_31":163,"_29":164,"_138":-5,"_39":40,"_38":165,"_140":24,"_36":205,"_13":61,"_32":33,"_34":167,"_23":24,"_143":-5,"_193":206,"_26":207},{"_41":155,"_31":156,"_29":157,"_138":-5,"_39":40,"_38":158,"_140":57,"_36":202,"_13":61,"_32":33,"_34":160,"_23":24,"_143":-5,"_193":203,"_26":204},{"_41":152,"_31":27,"_29":30,"_138":-5,"_39":40,"_38":14,"_140":57,"_36":199,"_13":61,"_32":33,"_34":35,"_23":24,"_143":-5,"_193":200,"_26":201},{"_41":145,"_31":146,"_29":147,"_138":-5,"_39":40,"_38":148,"_140":57,"_36":196,"_13":61,"_32":33,"_34":150,"_23":24,"_143":-5,"_193":197,"_26":198},{"_41":135,"_31":136,"_29":137,"_138":-5,"_39":40,"_38":139,"_140":57,"_36":192,"_13":61,"_32":33,"_34":142,"_23":24,"_143":-5,"_193":194,"_26":195},["D",1789612330847],"children",[],[136],["D",1789612338078],[],[146],["D",1789612346641],[],[27],["D",1789612315413],[],[156],["D",1789612293535],[],[163],["D",1789612322955],[],[170],["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":249,"_250":251,"_252":253,"_254":24,"_255":24,"_256":24,"_257":57,"_258":-5,"_259":-7,"_260":-7,"_261":61,"_262":24,"_263":24,"_264":-5,"_265":24,"_266":24,"_267":24,"_268":-5},"ENV",{"_220":221,"_222":223,"_224":88,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248},"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 · v6