[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_185":186,"_187":188},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":58,"_126":-5,"_127":-5,"_128":129},"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":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",8,"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","1b903a12-ae48-11f1-861e-1607ee4eb77e","name","fileType","http","content","const PROTOCOLS = new Set(['2025-06-18', '2025-03-26', '2024-11-05']);\nconst WEB_ENTRY = 'https://app-cl8wbg.v2.appdeploy.ai/';\nconst SERVER = { name: 'Infinite Canvas · 无限画布', version: '0.2.0-remote.20260912' };\n\nconst tools = [\n {\n name: 'canvas_probe',\n description: 'Check the Infinite Canvas remote MCP gateway and return the browser canvas entry.',\n inputSchema: { type: 'object', properties: {}, additionalProperties: false },\n annotations: { readOnlyHint: true, destructiveHint: false, openWorldHint: false }\n },\n {\n name: 'canvas_get_template',\n description: 'Return the canonical version-1 starter board used by Infinite Canvas.',\n inputSchema: { type: 'object', properties: {}, additionalProperties: false },\n annotations: { readOnlyHint: true, destructiveHint: false, openWorldHint: false }\n },\n {\n name: 'canvas_validate',\n description: 'Validate a portable Infinite Canvas version-1 board without saving or changing it.',\n inputSchema: {\n type: 'object',\n properties: { board: { type: 'object', description: 'Portable Infinite Canvas JSON object.' } },\n required: ['board'],\n additionalProperties: false\n },\n annotations: { readOnlyHint: true, destructiveHint: false, openWorldHint: false }\n },\n {\n name: 'canvas_open_web',\n description: 'Return the live web entry for the editable Infinite Canvas interface.',\n inputSchema: { type: 'object', properties: {}, additionalProperties: false },\n annotations: { readOnlyHint: true, destructiveHint: false, openWorldHint: true }\n }\n];\n\nfunction starterBoard() {\n return {\n version: 1,\n id: 'video-workspace',\n title: '视频制作工作台',\n revision: 0,\n view: { x: 30, y: 35, scale: 1 },\n nodes: [\n { id: 'reference', type: 'character', title: '角色与参考素材', body: '导入角色图、动作参考视频或音频。', x: 0, y: 0, w: 288, h: 184, color: 'blue', status: '待处理' },\n { id: 'shot-1', type: 'shot', title: 'S1 · 身份与微表演', body: '记录构图、呼吸、眼神和细微动作。', x: 358, y: 0, w: 288, h: 184, color: 'blue', status: '待处理', duration_s: 4 },\n { id: 'shot-2', type: 'shot', title: 'S2 · 主体动作', body: '记录动作参考、身体运动与节奏。', x: 716, y: 0, w: 288, h: 184, color: 'blue', status: '待处理', duration_s: 6 },\n { id: 'brief', type: 'note', title: '先让一个镜头成立', body: '这是可编辑的工作模板，不是已生成成片。', x: 0, y: 245, w: 288, h: 184, color: 'gold', status: '待处理' },\n { id: 'shot-3', type: 'shot', title: 'S3 · 姿态承接', body: '保持角色身份、衣服、空间方向和动作连续。', x: 358, y: 245, w: 288, h: 184, color: 'blue', status: '待处理', duration_s: 5 },\n { id: 'shot-4', type: 'review', title: 'S4 · 表演与验收', body: '人工检查自然度、角色一致性、身体接触和声音。', x: 716, y: 245, w: 288, h: 184, color: 'green', status: '待处理', duration_s: 5 }\n ],\n edges: [\n { id: 'e1', from: 'reference', to: 'shot-1' },\n { id: 'e2', from: 'shot-1', to: 'shot-2' },\n { id: 'e3', from: 'brief', to: 'shot-3' },\n { id: 'e4', from: 'shot-3', to: 'shot-4' }\n ]\n };\n}\n\nfunction validateBoard(board: unknown) {\n if (!board || typeof board !== 'object' || Array.isArray(board)) return { valid: false, error: 'Board must be an object.' };\n const b = board as Record;\n if (b.version !== 1) return { valid: false, error: 'Only version 1 is supported.' };\n if (typeof b.id !== 'string' || !/^[A-Za-z0-9][A-Za-z0-9_-]{0,95}$/.test(b.id)) return { valid: false, error: 'Invalid board id.' };\n if (typeof b.title !== 'string' || b.title.length > 200) return { valid: false, error: 'Invalid board title.' };\n if (!Array.isArray(b.nodes) || b.nodes.length > 2000) return { valid: false, error: 'Invalid nodes collection.' };\n if (!Array.isArray(b.edges) || b.edges.length > 5000) return { valid: false, error: 'Invalid edges collection.' };\n const ids = new Set();\n for (const node of b.nodes) {\n if (!node || typeof node !== 'object' || Array.isArray(node)) return { valid: false, error: 'Invalid node.' };\n const n = node as Record;\n if (typeof n.id !== 'string' || !/^[A-Za-z0-9][A-Za-z0-9_-]{0,95}$/.test(n.id) || ids.has(n.id)) return { valid: false, error: 'Invalid or duplicate node id.' };\n ids.add(n.id);\n }\n for (const edge of b.edges) {\n if (!edge || typeof edge !== 'object' || Array.isArray(edge)) return { valid: false, error: 'Invalid edge.' };\n const e = edge as Record;\n if (typeof e.from !== 'string' || typeof e.to !== 'string' || !ids.has(e.from) || !ids.has(e.to) || e.from === e.to) return { valid: false, error: 'Invalid edge reference.' };\n }\n return { valid: true, nodes: b.nodes.length, edges: b.edges.length };\n}\n\nfunction jsonRpc(id: unknown, result: unknown, status = 200) {\n return new Response(JSON.stringify({ jsonrpc: '2.0', id, result }), {\n status,\n headers: {\n 'content-type': 'application/json; charset=utf-8',\n 'access-control-allow-origin': '*',\n 'cache-control': 'no-store'\n }\n });\n}\n\nfunction rpcError(id: unknown, code: number, message: string, status = 200) {\n return new Response(JSON.stringify({ jsonrpc: '2.0', id, error: { code, message } }), {\n status,\n headers: { 'content-type': 'application/json; charset=utf-8', 'access-control-allow-origin': '*', 'cache-control': 'no-store' }\n });\n}\n\nfunction toolResult(data: unknown) {\n return {\n content: [{ type: 'text', text: JSON.stringify(data, null, 2) }],\n structuredContent: data,\n isError: false\n };\n}\n\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n if (req.method === 'OPTIONS') {\n return new Response(null, { status: 204, headers: { 'access-control-allow-origin': '*', 'access-control-allow-methods': 'POST, GET, OPTIONS', 'access-control-allow-headers': 'content-type, accept, mcp-protocol-version, mcp-session-id' } });\n }\n if (req.method === 'GET') {\n if (url.searchParams.get('health') === '1') return Response.json({ ok: true, server: SERVER, tools: tools.length, endpoint: url.origin + url.pathname, web: WEB_ENTRY });\n return new Response('Infinite Canvas MCP — POST JSON-RPC 2.0 requests to this endpoint.', { status: 200, headers: { 'content-type': 'text/plain; charset=utf-8' } });\n }\n if (req.method !== 'POST') return new Response('Method not allowed', { status: 405, headers: { allow: 'GET, POST, OPTIONS' } });\n\n let message: Record;\n try {\n const parsed = await req.json();\n if (!parsed || typeof parsed !== 'object' || Array.isArray(parsed)) return rpcError(null, -32600, 'Invalid Request', 400);\n message = parsed as Record;\n } catch {\n return rpcError(null, -32700, 'Parse error', 400);\n }\n\n const method = message.method;\n const id = Object.prototype.hasOwnProperty.call(message, 'id') ? message.id : null;\n const params = message.params && typeof message.params === 'object' && !Array.isArray(message.params) ? message.params as Record : {};\n\n if (method === 'notifications/initialized' || method === 'notifications/cancelled') return new Response(null, { status: 202 });\n if (method === 'ping') return jsonRpc(id, {});\n if (method === 'initialize') {\n const requested = typeof params.protocolVersion === 'string' ? params.protocolVersion : '2025-06-18';\n const protocolVersion = PROTOCOLS.has(requested) ? requested : '2025-06-18';\n return jsonRpc(id, { protocolVersion, capabilities: { tools: { listChanged: false } }, serverInfo: SERVER, instructions: 'Infinite Canvas remote gateway. Current tools are read-only; use canvas_open_web for the editable browser canvas.' });\n }\n if (method === 'tools/list') return jsonRpc(id, { tools });\n if (method === 'tools/call') {\n const name = params.name;\n const args = params.arguments && typeof params.arguments === 'object' && !Array.isArray(params.arguments) ? params.arguments as Record : {};\n if (name === 'canvas_probe') return jsonRpc(id, toolResult({ ok: true, server: SERVER, transport: 'streamable-http-json', readOnly: true, webEntry: WEB_ENTRY, toolCount: tools.length }));\n if (name === 'canvas_get_template') return jsonRpc(id, toolResult(starterBoard()));\n if (name === 'canvas_validate') return jsonRpc(id, toolResult(validateBoard(args.board)));\n if (name === 'canvas_open_web') return jsonRpc(id, toolResult({ url: WEB_ENTRY, note: 'Editable browser canvas. This remote MCP gateway is currently read-only.' }));\n return rpcError(id, -32602, 'Unknown tool');\n }\n return rpcError(id, -32601, 'Method not found');\n}\n","import { VERSION, NODE_TYPES, TEMPLATES, SOURCES, ADAPTERS, template, compile } from './workflow-core.js';\nimport { createRun, readRun, nextTasks, claimTask, recordTask, reviewTask, cancelRun } from './run-store.js';\nconst WEB_ENTRY = 'https://app-cl8wbg.v2.appdeploy.ai/';\nconst PROTOCOLS = new Set(['2025-06-18','2025-03-26','2024-11-05']);\nconst SERVER = {name:'Infinite Canvas · 无限画布',version:VERSION};\nconst string = {type:'string'};\nconst object = {type:'object'};\nconst access = {run_id:string,run_key:{type:'string',minLength:64,maxLength:64,description:'Private per-run access key, returned only by canvas_create_run. Never put provider credentials here.'}};\nconst revision = {expected_revision:{type:'integer',minimum:0}};\nconst tool = (name:string,description:string,properties:object={},required:string[]=[],read=true) => ({name,description,inputSchema:{type:'object',properties,required,additionalProperties:false},annotations:{readOnlyHint:read,destructiveHint:name==='canvas_cancel_run',idempotentHint:read,openWorldHint:false}});\nconst tools = [\n tool('canvas_probe','Check real service capabilities. Does not imply that a video provider is funded or available.'),\n tool('canvas_get_template','Return a usable version-1 workflow; choose template_id from canvas_list_templates.',{template_id:string}),\n tool('canvas_validate','Validate the portable board and its execution graph; reports cycle, binding and missing-input errors.',{board:object},['board']),\n tool('canvas_open_web','Return the editable browser canvas entry. This does not read the user browser storage.'),\n tool('canvas_list_templates','List six manga, art and motion workflow recipes and their reference sources.'),\n tool('canvas_list_nodes','List typed input, generation, media-processing and human-review nodes.'),\n tool('canvas_compile_workflow','Compile a board into ordered executable tasks without submitting or charging.',{board:object},['board']),\n tool('canvas_get_adapter_guides','Read executor contracts, provider preflight requirements and quality boundaries.'),\n tool('canvas_create_run','With user consent, persist a workflow snapshot and private run key. Creation does NOT submit model jobs.',{board:object,consent:{type:'boolean'},billing:{type:'string',enum:['free_only']}},['board','consent'],false),\n tool('canvas_read_run','Read one private run, actual recorded receipts and freshness timestamps.',access,['run_id','run_key']),\n tool('canvas_next_tasks','Return ready connector or media-worker tasks. The ChatGPT executor must perform them and record real receipts.',access,['run_id','run_key']),\n tool('canvas_claim_task','Reserve a ready task before external execution. Never blindly re-submit an existing or uncertain provider request.',{...access,...revision,node_id:string,request_id:string},['run_id','run_key','expected_revision','node_id','request_id'],false),\n tool('canvas_record_task','Record a real provider/worker receipt using the private run and task keys. Model outputs enter review, never automatic approval.',{...access,...revision,node_id:string,lease_token:string,state:{type:'string',enum:['submitted','queued','in_progress','review','completed','failed','blocked']},provider_job_id:string,output:object,qa:object,note:string},['run_id','run_key','expected_revision','node_id','lease_token','state','note'],false),\n tool('canvas_review_task','Record explicit USER visual approval or rejection. Do not call approval merely because metadata or pixel tests pass.',{...access,...revision,node_id:string,user_confirmed:{type:'boolean'},decision:{type:'string',enum:['approved','rejected']},note:string},['run_id','run_key','expected_revision','node_id','user_confirmed','decision','note'],false),\n tool('canvas_cancel_run','Stop downstream execution of one private run. Does not cancel already submitted provider jobs or promise a refund.',{...access,...revision},['run_id','run_key','expected_revision'],false)\n];\nconst handlers:Recordany> = {\n canvas_probe:()=>({ok:true,server:SERVER,toolCount:tools.length,templateCount:TEMPLATES.length,nodeTypeCount:NODE_TYPES.length,webEntry:WEB_ENTRY,transport:'streamable-http-json',execution_mode:'chatgpt_connector_assisted',provider_credentials_stored:false,unattended_worker:false,privacy:'Public recipes; per-run 256-bit capability keys and revision-guarded private state.'}),\n canvas_get_template:a=>template(a.template_id),\n canvas_validate:a=>compile(a.board),\n canvas_open_web:()=>({url:WEB_ENTRY,note:'Browser editor and execution console; model calls are performed by the connected ChatGPT executor.'}),\n canvas_list_templates:()=>({templates:TEMPLATES.map(({build,...t})=>({...t,node_count:build()[0].length})),sources:SOURCES}),\n canvas_list_nodes:()=>({nodes:NODE_TYPES}),\n canvas_compile_workflow:a=>compile(a.board),\n canvas_get_adapter_guides:()=>ADAPTERS,\n canvas_create_run:createRun,canvas_read_run:readRun,canvas_next_tasks:nextTasks,canvas_claim_task:claimTask,canvas_record_task:recordTask,canvas_review_task:reviewTask,canvas_cancel_run:cancelRun\n};\nconst headers = {'content-type':'application/json; charset=utf-8','access-control-allow-origin':'*','cache-control':'no-store','x-content-type-options':'nosniff'};\nfunction json(value:unknown,status=200) {return new Response(JSON.stringify(value),{status,headers});}\nfunction error(id:unknown,code:number,message:string,status=200) {return json({jsonrpc:'2.0',id,error:{code,message}},status);}\nasync function body(req:Request) {\n if (Number(req.headers.get('content-length') || 0)>262144) throw Error('REQUEST_TOO_LARGE');\n const reader=req.body?.getReader(); if(!reader) return '';\n const chunks:Uint8Array[]=[]; let total=0;\n while(true) {const {done,value}=await reader.read(); if(done) break; total+=value.byteLength; if(total>262144){await reader.cancel();throw Error('REQUEST_TOO_LARGE');} chunks.push(value);}\n const data=new Uint8Array(total); let at=0; for(const part of chunks){data.set(part,at);at+=part.length;} return new TextDecoder().decode(data);\n}\nexport default async function(req:Request):Promise {\n const url=new URL(req.url);\n if(req.method==='OPTIONS') return new Response(null,{status:204,headers:{...headers,'access-control-allow-methods':'POST,GET,OPTIONS','access-control-allow-headers':'content-type,accept,mcp-protocol-version,mcp-session-id'}});\n if(req.method==='GET') {\n if(url.searchParams.get('health')==='1') return json(handlers.canvas_probe({}));\n if(req.headers.get('accept')?.includes('text/event-stream')) return new Response(null,{status:405,headers:{allow:'POST'}});\n return json({service:SERVER,mcp:'POST JSON-RPC to this URL',web:WEB_ENTRY,mode:'connector-assisted, not an unattended renderer'});\n }\n if(req.method!=='POST') return new Response(null,{status:405,headers:{allow:'POST,GET,OPTIONS'}});\n if(!req.headers.get('content-type')?.includes('application/json')) return error(null,-32600,'Content-Type must be application/json',415);\n let m:any;\n try {m=JSON.parse(await body(req));} catch(e) {return error(null,-32700,(e as Error).message==='REQUEST_TOO_LARGE'?'REQUEST_TOO_LARGE':'Parse error',(e as Error).message==='REQUEST_TOO_LARGE'?413:400);}\n if(!m||Array.isArray(m)||m.jsonrpc!=='2.0'||typeof m.method!=='string'||(m.id!==undefined&&m.id!==null&&typeof m.id!=='string'&&typeof m.id!=='number')) return error(null,-32600,'Invalid Request',400);\n if(m.id===undefined) return new Response(null,{status:202,headers});\n const params=m.params||{}; if(typeof params!=='object'||Array.isArray(params)) return error(m.id,-32602,'Invalid params');\n if(m.method==='initialize') return json({jsonrpc:'2.0',id:m.id,result:{protocolVersion:PROTOCOLS.has(params.protocolVersion)?params.protocolVersion:'2025-06-18',capabilities:{tools:{listChanged:true}},serverInfo:SERVER,instructions:'Video workflow orchestration, not an autonomous generator. Read canvas_get_adapter_guides. Use run keys for private state. Claim before provider submission; record genuine job IDs and output URLs. Never confuse queued jobs, technical QA, or proxy clips with visually approved video.'}});\n if(m.method==='ping') return json({jsonrpc:'2.0',id:m.id,result:{}});\n if(m.method==='tools/list') return json({jsonrpc:'2.0',id:m.id,result:{tools}});\n if(m.method!=='tools/call') return error(m.id,-32601,'Method not found');\n const entry=tools.find(t=>t.name===params.name); if(!entry) return error(m.id,-32602,'Unknown tool');\n const args=params.arguments||{}; if(typeof args!=='object'||Array.isArray(args)) return error(m.id,-32602,'Invalid arguments');\n if(entry.inputSchema.required.some(k=>!Object.hasOwn(args,k))||Object.keys(args).some(k=>!Object.hasOwn(entry.inputSchema.properties,k))) return error(m.id,-32602,'Missing or unknown arguments');\n try {\n const data=await handlers[params.name](args);\n return json({jsonrpc:'2.0',id:m.id,result:{content:[{type:'text',text:JSON.stringify(data)}],structuredContent:data,isError:false}});\n } catch(e) {\n const message=(e as Error).message.slice(0,600);\n return json({jsonrpc:'2.0',id:m.id,result:{content:[{type:'text',text:message}],isError:true}});\n }\n}\n","createdAt",["D",1789180479903],"branchVersion","branchId","f7be5dbc-27c0-4d47-9c6a-f53b6506d92b","id","5f2940b9-497a-4c0e-b48a-7471214abdbb","infinite-canvas-mcp",["D",1789176014798],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Infinite Canvas remote MCP for ChatGPT","imageUrl","aa4fc0c7-9a5e-471f-80f7-c417d4e86485","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0795e-e242-722a-a25b-204f9da61ffe","tursoName","5f2940b9497a4c0eb48a7471214abdbb","tursoHostname","5f2940b9497a4c0eb48a7471214abdbb-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789532458193],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","xuhuanzhi32svg","handle","displayName","xuhuanzhi32-svg","avatar","https://avatars.githubusercontent.com/u/322119312?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":180,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":181,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":182,"_83":183,"_85":184,"_87":25},"tree",[167,168,169],"files",[167,168,169],"counts",{"_157":62,"_158":154,"_159":62,"_160":161,"_162":163},"contents",[130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":152,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":153,"_13":154,"_33":34,"_35":37,"_24":25,"_143":155,"_27":156},{"_43":145,"_32":146,"_30":147,"_136":-5,"_41":42,"_40":148,"_138":25,"_38":149,"_13":62,"_33":141,"_35":150,"_24":25,"_143":-5,"_27":151},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":25,"_38":139,"_13":140,"_33":141,"_35":142,"_24":25,"_143":-5,"_27":144},"792b742a-e57b-4969-a8f0-060c98bf5d77","workflow-core.js","1361f45c-ae52-11f1-a766-1607ee4eb77e","parentId",6,"latest",["D",1789180354677],3,"script","// Shared pure workflow contracts: imported by the MCP service and web canvas.\n// Provider calls are dispatched by the connected ChatGPT executor, not by this module.\nexport const VERSION = '0.3.0';\nexport const SOURCES = [\n {name: 'Weave · reusable I2V workflows', url: 'https://www.figma.com/solutions/ai-image-to-video-generator-weave/', lesson: 'Separate references, generation, edits and sequencing.'},\n {name: 'Weave · iterators', url: 'https://help.weavy.ai/en/articles/12343281-iterators', lesson: 'Keep batch inputs independent; review candidates before downstream use.'},\n {name: 'ComfyUI · Wan 2.2', url: 'https://docs.comfy.org/tutorials/video/wan/wan2_2', lesson: 'First/last frames are generation conditions, not optical-flow substitutes.'},\n {name: 'LTX · consistent characters', url: 'https://ltx.io/blog/how-to-create-a-consistent-character', lesson: 'Reuse an explicit character asset; treat wardrobe variants separately.'},\n {name: 'Weave · compositing', url: 'https://www.figma.com/solutions/ai-video-compositing/', lesson: 'Keep masks, color matching and compositing as inspectable stages.'}\n];\nconst spec = (id, name, output, inputs, executor, description) => ({id, name, output, inputs, executor, description});\nexport const NODE_TYPES = [\n spec('text', '创意 / 剧本', 'text', {}, 'input', '填写故事目标、受众和具体动作；空文本不会通过检查。'),\n spec('image', '角色 / 风格参考图', 'image', {}, 'input', '使用经过确认的参考图。身份、服装与风格分别记录。'),\n spec('video', '动作 / 实拍参考', 'video', {}, 'input', '提供真实视频，不用低帧率技术代理冒充参考表演。'),\n spec('audio', '对白 / 音乐参考', 'audio', {}, 'input', '提供拥有使用权限的对白、音乐或声音素材。'),\n spec('style', '美术设定锁定', 'text', {}, 'input', '锁定线条、材质、色彩、光线、服装和禁止变化项。'),\n spec('prompt', '提示词组装', 'text', {text: 'text'}, 'local', '合并上游文字与镜头描述，不声称经过大模型润色。'),\n spec('image_generate', '关键帧生成', 'image', {text: 'text'}, 'connector', '生成可独立审看的单张关键帧；计费前核对模型契约与余额。'),\n spec('image_edit', '参考图局部修改', 'image', {image: 'image'}, 'connector', '修改明确区域或服装，不静默更换角色身份。'),\n spec('text_to_video', '文生视频', 'video', {text: 'text'}, 'connector', '从文字生成真实连续视频，不降级为静帧拼接。'),\n spec('image_to_video', '图生视频', 'video', {start_image: 'image'}, 'connector', '首帧驱动主体表演；输出必须另外完成视觉审查。'),\n spec('first_last_video', '首尾帧艺术转场', 'video', {start_image: 'image', end_image: 'image'}, 'connector', '由支持首尾帧的模型生成过渡，不用交叉淡化代替。'),\n spec('motion_transfer', '视频动作迁移', 'video', {image: 'image', video: 'video'}, 'connector', '动作参考与角色参考独立；保留来源和实际任务 ID。'),\n spec('video_edit', '视频艺术重绘', 'video', {video: 'video', image: 'image'}, 'connector', '在保留时序和镜头运动的前提下重绘；先检查输入时长限制。'),\n spec('last_frame', '提取真实末帧', 'image', {video: 'video'}, 'media_worker', '从实际解码末帧提取，不用原参考图冒充上一镜末帧。'),\n spec('trim', '视频裁剪', 'video', {video: 'video'}, 'media_worker', '按真实时间区间裁剪已有视频，不生成缺失内容。'),\n spec('grade', '视频调色', 'video', {video: 'video'}, 'media_worker', '对已有视频调整曝光、对比和饱和度，不增加动作或细节。'),\n spec('speech', '对白配音', 'audio', {text: 'text'}, 'connector', '选定声音后生成对白；配音不等于口型同步。'),\n spec('sound', '环境 / 音效', 'audio', {text: 'text'}, 'connector', '生成独立环境声或音效，不替代人物表演。'),\n spec('technical_qc', '技术检测', 'video', {video: 'video'}, 'media_worker', '检查解码、尺寸、帧率、重复帧；不能据此自动判定美术合格。'),\n spec('review', '视觉验收关卡', 'video', {video: 'video'}, 'human', '检查自然度、身份、肢体、接触和连续性；未批准不得合成。'),\n spec('assemble', '批准镜头合成', 'video', {video: 'video'}, 'media_worker', '只合成已批准的视频，音频可选；禁止塞入静帧代替失败镜头。'),\n spec('mix', '对白 / 音效混音', 'video', {video: 'video', audio: 'audio'}, 'media_worker', '将真实音频按指定延迟混入视频，保留完整视频时长。')\n];\nconst BY_TYPE = new Map(NODE_TYPES.map(n => [n.id, n]));\nconst safeText = (x, max = 20000) => typeof x === 'string' && x.length <= max;\nconst ID = /^[A-Za-z0-9][A-Za-z0-9_-]{0,95}$/;\nexport function safeUrl(value) {\n if (typeof value !== 'string' || value.length > 8192) return false;\n try {\n const u = new URL(value);\n return u.protocol === 'https:' && !u.username && !u.password && !u.hash && u.hostname.includes('.') && !/^(localhost|127\\.|10\\.|192\\.168\\.|169\\.254\\.|0\\.|\\[)/.test(u.hostname) && !/\\.(local|internal)$/.test(u.hostname);\n } catch { return false; }\n}\nexport function operation(node) {\n return node.render?.operation || ({character: 'image', clip: 'video', audio: 'audio', review: 'review'}[node.type]) || 'text';\n}\nexport function mediaFor(node, jobs = {}) {\n const job = jobs[node.id];\n if (job && ['review', 'approved', 'completed'].includes(job.state) && job.output) return job.output;\n const type = BY_TYPE.get(operation(node))?.output;\n if (node.render?.source?.url && safeUrl(node.render.source.url)) return {kind: type, url: node.render.source.url, ...(node.render.source.media_id ? {media_id: node.render.source.media_id, provider: node.render.source.provider} : {})};\n if (node.render?.source?.media_id && /^[0-9a-f-]{36}$/i.test(node.render.source.media_id)) return {kind: type, media_id: node.render.source.media_id, provider: node.render.source.provider};\n if (type === 'text' && (node.prompt?.trim() || node.body?.trim())) return {kind: 'text', text: node.prompt || node.body};\n for (const kind of ['image', 'video', 'audio']) if (node[kind]) return {kind, url: safeUrl(node[kind]) ? node[kind] : undefined, local: !safeUrl(node[kind])};\n return null;\n}\nexport function compile(board, jobs = {}) {\n const errors = [], warnings = [], steps = [];\n if (!board || board.version !== 1 || !Array.isArray(board.nodes) || !Array.isArray(board.edges) || board.nodes.length > 2000 || board.edges.length > 5000) return {valid: false, errors: ['无效 v1 工程或超出节点上限'], warnings, steps};\n const map = new Map(), incoming = new Map(), outgoing = new Map();\n for (const n of board.nodes) {\n if (!n || !ID.test(n.id) || ['constructor','prototype','__proto__'].includes(n.id) || map.has(n.id) || !safeText(n.title, 200) || !safeText(n.body) || (n.prompt !== undefined && !safeText(n.prompt)) || !Number.isFinite(n.x) || !Number.isFinite(n.y)) {errors.push('节点 ID、文字或坐标无效'); continue;}\n map.set(n.id, n); incoming.set(n.id, []); outgoing.set(n.id, []);\n if (!BY_TYPE.has(operation(n))) errors.push(`${n.title}: 未知执行类型`);\n }\n const edgeIds = new Set();\n for (const e of board.edges) {\n if (!e || !ID.test(e.id) || edgeIds.has(e.id) || !map.has(e.from) || !map.has(e.to) || e.from === e.to) {errors.push('连线引用无效或重复'); continue;}\n edgeIds.add(e.id); incoming.get(e.to).push(e.from); outgoing.get(e.from).push(e.to);\n }\n const indegree = new Map([...incoming].map(([k,v]) => [k,v.length]));\n const queue = [...map.keys()].filter(id => indegree.get(id) === 0), order = [];\n for (let i = 0; i < queue.length; i++) {const id = queue[i]; order.push(id); for (const next of outgoing.get(id)) {indegree.set(next, indegree.get(next) - 1); if (indegree.get(next) === 0) queue.push(next);}}\n if (order.length !== map.size) errors.push('检测到循环依赖：工作流必须是无环图');\n for (const id of order) {\n const n = map.get(id), kind = operation(n), s = BY_TYPE.get(kind); if (!s) continue;\n const parents = incoming.get(id), bindings = {}, issues = [];\n const declared = n.render?.bindings || {};\n for (const [role, output] of Object.entries(s.inputs)) {\n const explicit = declared[role];\n const matches = explicit ? parents.filter(p => p === explicit) : parents.filter(p => BY_TYPE.get(operation(map.get(p)))?.output === output);\n if (matches.length === 0) issues.push(`缺少 ${role} 输入`);\n else if (matches.length > 1 && kind !== 'assemble' && role !== 'text') issues.push(`${role} 有多个来源，请明确绑定`);\n else if (matches.some(p => BY_TYPE.get(operation(map.get(p)))?.output !== output)) issues.push(`${role} 输入类型不匹配`);\n else bindings[role] = matches;\n }\n if (kind === 'first_last_video' && bindings.start_image?.[0] === bindings.end_image?.[0]) warnings.push(`${n.title}: 首尾引用相同，仅适用于明确设计的循环`);\n if (s.executor === 'input' && !mediaFor(n, jobs)) issues.push(s.output === 'text' ? '未填写内容' : '未绑定素材');\n if (s.executor === 'connector' && !n.prompt?.trim()) issues.push('未填写镜头提示词');\n if (n.duration_s !== undefined && (!Number.isFinite(n.duration_s) || n.duration_s <= 0 || n.duration_s > 3600)) issues.push('时长无效');\n const job = jobs[id];\n const waiting = parents.filter(p => {\n const ps = BY_TYPE.get(operation(map.get(p))); if (!ps) return true;\n if (kind === 'assemble') return jobs[p]?.state !== 'approved';\n if (ps.executor === 'input') return !mediaFor(map.get(p), jobs);\n const accepted = ['technical_qc','review'].includes(kind) ? ['review','approved','completed'] : ['approved','completed'];\n return !accepted.includes(jobs[p]?.state);\n });\n let state = job?.state || (issues.length ? 'needs_input' : waiting.length ? 'waiting_dependency' : s.executor === 'input' ? 'completed' : s.executor === 'human' ? 'needs_review' : 'ready');\n if (job?.state === 'review') state = 'review';\n steps.push({id, title: n.title, operation: kind, executor: s.executor, output: s.output, dependencies: parents, bindings, state, issues, waiting});\n }\n return {valid: errors.length === 0, ready: steps.filter(s => s.state === 'ready').map(s => s.id), errors, warnings, steps, execution_mode: 'chatgpt_connector_assisted', visual_quality_verified: false};\n}\nexport function connectorRequest(board, step, jobs = {}, billing = 'free_only') {\n const n = board.nodes.find(n => n.id === step.id);\n if (!n || step.executor !== 'connector') throw Error('不是模型生成节点');\n if (step.issues.length || step.waiting.length) throw Error('输入或依赖未就绪');\n const media = {};\n for (const [role, ids] of Object.entries(step.bindings)) {\n media[role] = ids.map(id => mediaFor(board.nodes.find(n => n.id === id), jobs));\n if (media[role].some(m => !m || m.local)) throw Error('本机素材尚未上传；先通过已连接素材工具上传，不能将本机路径作为模型输入');\n }\n const first = role => media[role]?.[0];\n const prompt = [n.prompt, ...(media.text || []).map(x => x.text || '')].filter(Boolean).join('\\n\\n');\n if (step.operation === 'motion_transfer') {\n const value = role => first(role)?.media_id || first(role)?.url;\n if (!first('video')?.media_id) throw Error('Higgsfield 动作视频必须使用确认上传后的 media_id');\n const params = {model: 'hf_mult_motion_control', count: 1, resolution: n.render?.resolution || '720p', medias: [{role:'image', value:value('image')},{role:'video',value:value('video')}], prompt};\n if (billing === 'free_only') params.use_free_gens = true;\n return {provider: 'Higgsfield', tool: 'generate_video', arguments: {params}, preflight: ['balance', 'estimate_video_cost'], billing, duration_semantics: 'source_video_controlled', warning: '先核对真实余额与免费额度；绝不将免费失败改成付费重试'};\n }\n const args = {prompt, duration: n.duration_s || 5, aspect_ratio: n.render?.aspect_ratio || '16:9', resolution: n.render?.resolution || '720p', agentic_prompting: false};\n let tool = 'generate_video', model = 'video/seedance-2.0-mini';\n if (step.operation === 'image_to_video') args.image_url = first('start_image')?.url;\n if (step.operation === 'first_last_video') {model = 'video/minimax-h3-max'; args.resolution = '768P'; args.image_url = first('start_image')?.url; args.last_frame_url = first('end_image')?.url;}\n if (step.operation === 'video_edit') {model = 'video/gemini-omni-flash'; args.video_urls = [first('video')?.url]; args.image_urls = [first('image')?.url];}\n if (['image_generate','image_edit'].includes(step.operation)) {tool = 'generate_image'; model = 'image/nano-banana-2'; delete args.duration; delete args.resolution; delete args.aspect_ratio; args.size = '16:9'; if (step.operation === 'image_edit') args.image_url = first('image')?.url;}\n if (step.operation === 'speech') {tool = 'generate_speech'; model = 'speech/elevenlabs-v3'; for (const k of Object.keys(args)) delete args[k]; args.text = prompt; if (!n.render?.voice_id) throw Error('未选择并试听配音 voice_id'); args.voice_id = n.render.voice_id;}\n if (step.operation === 'sound') {tool = 'generate_audio'; model = 'sfx/elevenlabs-sound-v2'; for (const k of Object.keys(args)) delete args[k]; args.prompt = prompt; args.duration_seconds = n.duration_s || 5;}\n args.model = model;\n if (Object.values(args).some(x => x === undefined) || Object.values(args).some(x => Array.isArray(x) && x.includes(undefined))) throw Error('该后端需要永久 HTTPS 素材地址，不能混用另一后端的 media_id');\n return {provider:'Creative_Claw',tool,arguments:args,preflight:['get_model_params','credit_preflight'],billing,blocked: billing === 'free_only' ? 'NO_CONFIRMED_FREE_ALLOWANCE' : null, warning:'参数草案必须用当前 get_model_params 核对；不得静默替换模型、时长或参考图'};\n}\nfunction node(id, op, title, body, col, row, prompt = '') {\n const s = BY_TYPE.get(op);\n return {id, type: op === 'review' ? 'review' : s.output === 'image' && s.executor === 'input' ? 'character' : s.output === 'audio' ? 'audio' : s.output === 'text' ? 'note' : 'shot', title, body, prompt, x: col * 350, y: row * 240, w: 296, h: 188, color: s.executor === 'human' ? 'green' : s.executor === 'input' ? 'gold' : 'blue', status:'待处理', ...(s.output === 'video' && s.executor === 'connector' ? {duration_s:5} : {}), render:{operation:op,bindings:{}}};\n}\nexport const TEMPLATES = [\n {id:'single-shot',name:'单镜头角色表演',category:'先跑通一镜',description:'角色图 → 真实 I2V → 技术检测 → 视觉验收',build:()=>[\n [node('identity','image','角色身份锚点','确认脸、毛色/肤色、服装和身体比例。',0,0),node('shot','image_to_video','自然表演镜头','先做单角色、固定机位与一个明确动作。',1,0,'Same character and clothing as the first frame. Natural breathing, one gentle blink, a small head turn and believable hair or ear secondary motion. Stable camera, continuous real subject motion, no slideshow.'),node('qc','technical_qc','检测实际视频','全量解码与帧率检查不等于美术合格。',2,0),node('review','review','自然度人工验收','通过标准：没有畸形、滑步、换脸与僵硬表情。',3,0)], [['identity','shot'],['shot','qc'],['qc','review']]\n ]},\n {id:'manga-drama',name:'AI 漫剧 · 连续两镜',category:'叙事',description:'人物 / 美术锁定 → 第一镜 → 验收 → 真实末帧 → 第二镜 → 合成',build:()=>[\n [node('identity','image','人物与服装锁定','同一份批准的角色参考；不用无服装转面图替代。',0,0),node('style','style','美术设定','清晰线条、克制高光、统一光线和色彩；禁止中途换装。',0,1),node('s1','image_to_video','S1 · 动作建立','固定镜头，让角色完成一个清楚的动作意图。',1,0,'Cinematic anime, preserve identity and outfit. The character notices something offscreen and turns their head with natural anticipation. Continuous acting, no text.'),node('r1','review','S1 验收','批准后才提取末帧。',2,0),node('last','last_frame','S1 实际末帧','从通过的输出视频最后一个可解码帧提取。',3,0),node('s2','image_to_video','S2 · 动作承接','接续姿态，不能重置角色身体。',4,0,'Continue the action from the supplied first frame. Same identity, clothing, scene direction and lighting. Settle naturally and respond with a subtle expression.'),node('r2','review','S2 验收','核对动作承接和空间方向。',5,0),node('final','assemble','批准镜头成片','只接纳批准的真实视频。',6,0)], [['identity','s1'],['style','s1'],['s1','r1'],['r1','last'],['last','s2'],['style','s2'],['s2','r2'],['r1','final'],['r2','final']]\n ]},\n {id:'motion-transfer',name:'动作迁移 · 角色替换',category:'表演',description:'正式角色图 + 真实动作视频 → Genjutsu → 对照检测 → 人工验收',build:()=>[\n [node('identity','image','正式角色图','只使用一个确定的身份和服装版本。',0,0),node('driver','video','真实动作参考','输入时长就是动作迁移基准，不虚设输出长度。',0,1),node('motion','motion_transfer','角色动作迁移','严格免费模式；免费不适用时停止，不改成扣费。',1,0,'Transfer the source choreography to the exact reference character. Preserve appearance, clothing, source timing, formation, contact and camera. Natural articulated motion, no geometry proxy or slideshow.'),node('qc','technical_qc','技术 / 时序检查','来源和输出分别检查；全局帧差不能证明迁移正确。',2,0),node('review','review','表演与身份验收','核对动作节奏、重心、脚底接触、服装和面部。',3,0)], [['identity','motion'],['driver','motion'],['motion','qc'],['qc','review']]\n ]},\n {id:'art-transition',name:'艺术短片 · 首尾变形',category:'艺术',description:'首帧 + 目标尾帧 → 生成式过渡 → 调色 → 审看',build:()=>[\n [node('start','image','起始艺术画面','明确材质、主体和视觉中心。',0,0),node('end','image','目标尾帧','保持构图可衔接；不是交叉淡化素材。',0,1),node('transform','first_last_video','生成式材质转场','使用支持首尾帧的模型；不使用补帧伪造。',1,0,'A controlled material transformation from the first image into the last. Continuous physical unfolding and coherent silhouettes, deliberate motion and stable framing. No dissolve or slide transition.'),node('grade','grade','统一色彩','调色只改变色彩，不增加主体动作。',2,0),node('review','review','形变美术验收','拒绝脸部融化、纹理爬动和无动机闪烁。',3,0)], [['start','transform'],['end','transform'],['transform','grade'],['grade','review']]\n ]},\n {id:'music-visual',name:'音乐视觉 · 双段节奏',category:'艺术 / MV',description:'分段提示词 → 独立视频 → 候选审看 → 合成 → 音乐混音',build:()=>[\n [node('brief','text','节奏与视觉意图','第一段缓慢聚拢，第二段开放；时长与已获授权音乐匹配。',0,0),node('music','audio','已授权音乐','导入真实音频，禁止把声音模板当已生成音轨。',0,1),node('a','text_to_video','A · 蓄势','一个明确运动中心，不堆满噪声和特效。',1,0,'Abstract sculptural paper forms slowly gather under soft directional light. Genuine continuous deformation, tactile material and deliberate pacing, no slideshow.'),node('b','text_to_video','B · 释放','与 A 保持材质和色彩一致。',1,1,'The same abstract sculptural paper forms unfold outward gracefully. Cohesive tactile material, restrained palette and real continuous motion.'),node('ra','review','A 审看','单段先通过审美验收。',2,0),node('rb','review','B 审看','单段先通过审美验收。',2,1),node('cut','assemble','两段合成','连接批准视频，不自动添加未授权素材。',3,0),node('mix','mix','音乐混音','按时长保留视频；这一步不是口型同步。',4,0)], [['brief','a'],['brief','b'],['a','ra'],['b','rb'],['ra','cut'],['rb','cut'],['cut','mix'],['music','mix']]\n ]},\n {id:'art-restyle',name:'实拍转艺术 · 保留时序',category:'风格迁移',description:'真实视频 + 风格图 → 视频重绘 → 技术检测 → 视觉验收',build:()=>[\n [node('footage','video','原始视频','保留原片时序，确认人物与素材使用权限。',0,0),node('look','image','艺术风格参考','用线条、笔触和材质引导，不篡改动作。',0,1),node('restyle','video_edit','视频艺术重绘','先校验模型允许的输入长度与参考组合。',1,0,'Restyle the source video using the visual language of the reference image. Preserve source action timing, camera movement, geometry and subject identity. Stable temporal brushwork, no flicker.'),node('qc','technical_qc','时序与重复帧筛查','检测只作为筛查；需进一步审看片。',2,0),node('review','review','风格稳定验收','笔触稳定，动作节奏不失真，主体不融化。',3,0)], [['footage','restyle'],['look','restyle'],['restyle','qc'],['qc','review']]\n ]}\n];\nexport function template(id = 'single-shot') {\n const t = TEMPLATES.find(t => t.id === id); if (!t) throw Error('未知工作流模板');\n const [nodes, links] = t.build();\n if (id === 'art-transition') {nodes.find(n=>n.id==='transform').render.bindings={start_image:'start',end_image:'end'};}\n return {version:1,id:`workflow-${id}`,title:t.name,revision:0,view:{x:30,y:30,scale:1},nodes,edges:links.map(([from,to],i)=>({id:`e-${i}`,from,to}))};\n}\nexport const ADAPTERS = {\n mode:'connector-assisted',\n paid_submissions:'require a fresh provider estimate and explicit budget; no silent paid fallback',\n generation:['Higgsfield.generate_video', 'Creative_Claw.generate_video', 'Creative_Claw.generate_image', 'Creative_Claw.generate_speech', 'Creative_Claw.generate_audio'],\n media_worker:['last_frame','trim','grade','technical_qc','assemble','mix'],\n restrictions:['A provider job ID is not a playable video.', 'Do not retry a submitted or uncertain request blindly.', 'No automatic visual approval.', 'No frame-sequence or low-fps proxy fallback.', 'No independent background generator is deployed in this gateway.'],\n schema_rule:'Read the selected provider model schema before submission; preserve reference order and literal-frame semantics.'\n};\n","label",[134],"5701560d-7f3c-462f-b2e7-2658e2dbfca5","run-store.js","5d6e656c-ae52-11f1-930a-1607ee4eb77e",7,["D",1789180420310],"import { sqlite } from 'https://esm.town/v/std/sqlite/main.ts';\nimport { compile, connectorRequest, mediaFor, operation, safeUrl, NODE_TYPES } from './workflow-core.js';\nconst MAX_BYTES = 192 * 1024;\nconst digest = async text => [...new Uint8Array(await crypto.subtle.digest('SHA-256', new TextEncoder().encode(text)))].map(x => x.toString(16).padStart(2, '0')).join('');\nconst token = () => [...crypto.getRandomValues(new Uint8Array(32))].map(x => x.toString(16).padStart(2, '0')).join('');\nlet initialized;\nasync function init() {\n if (!initialized) initialized = sqlite.execute('CREATE TABLE IF NOT EXISTS canvas_runs_v3 (id TEXT PRIMARY KEY, key_hash TEXT NOT NULL, revision INTEGER NOT NULL, document TEXT NOT NULL, created_at TEXT NOT NULL)');\n try { await initialized; } catch (e) { initialized = null; throw e; }\n}\nfunction bytes(value) { return new TextEncoder().encode(JSON.stringify(value)).length; }\nfunction clean(run) {\n const value = JSON.parse(JSON.stringify(run));\n for (const j of Object.values(value.jobs)) delete j.lease_token;\n value.plan = compile(value.board, value.jobs);\n return value;\n}\nasync function load(args) {\n if (!/^[0-9a-f-]{36}$/i.test(args.run_id || '') || !/^[0-9a-f]{64}$/.test(args.run_key || '')) throw Error('RUN_ACCESS_DENIED');\n await init();\n const result = await sqlite.execute({sql:'SELECT document, revision FROM canvas_runs_v3 WHERE id = ? AND key_hash = ?', args:[args.run_id, await digest(args.run_key)]});\n if (!result.rows.length) throw Error('RUN_ACCESS_DENIED');\n const run = JSON.parse(result.rows[0].document); run.revision = Number(result.rows[0].revision); return run;\n}\nasync function save(args, run) {\n if (!Number.isInteger(args.expected_revision) || args.expected_revision !== run.revision) throw Error('REVISION_CONFLICT: read run and retry');\n const expected = run.revision; run.revision++; run.updated_at = new Date().toISOString();\n if (bytes(run) > MAX_BYTES) throw Error('RUN_SIZE_LIMIT');\n const result = await sqlite.execute({sql:'UPDATE canvas_runs_v3 SET document = ?, revision = ? WHERE id = ? AND key_hash = ? AND revision = ?',args:[JSON.stringify(run),run.revision,run.id,await digest(args.run_key),expected]});\n if (result.rowsAffected !== 1) throw Error('REVISION_CONFLICT: concurrent update rejected');\n return clean(run);\n}\nexport async function createRun(args) {\n const plan = compile(args.board);\n if (!plan.valid || args.board.nodes.length > 128) throw Error(plan.errors.join('; ') || 'A run supports at most 128 nodes');\n if (args.consent !== true) throw Error('CONSENT_REQUIRED: workflow text and source URLs will be stored remotely');\n if (bytes(args.board) > 120 * 1024) throw Error('BOARD_TOO_LARGE: keep media at its provider and store HTTPS references, not base64');\n if (args.billing !== undefined && args.billing !== 'free_only') throw Error('This release only dispatches confirmed free model requests. Paid generation requires a separate reviewed adapter.');\n const id = crypto.randomUUID(), key = token(), now = new Date().toISOString();\n const run = {id,revision:0,created_at:now,updated_at:now,state:'active',mode:'chatgpt_connector_assisted',billing:'free_only',board:args.board,jobs:{},events:[{at:now,event:'run_created',note:'No provider job submitted by creation.'}]};\n await init();\n // Bound storage use on the public gateway; writes never overwrite another run.\n const inserted = await sqlite.execute({sql:'INSERT INTO canvas_runs_v3 (id,key_hash,revision,document,created_at) SELECT ?,?,?,?,? WHERE (SELECT COUNT(*) FROM canvas_runs_v3) < 40',args:[id,await digest(key),0,JSON.stringify(run),now]});\n if (inserted.rowsAffected !== 1) throw Error('RUN_CAPACITY_LIMIT: export existing runs before creating more');\n return {...clean(run),run_key:key,privacy:'Run key grants access. Keep it private; it is not a provider API key.'};\n}\nexport async function readRun(args) { return clean(await load(args)); }\nexport async function nextTasks(args) {\n const run = await load(args); if (run.state !== 'active') return {run_id:run.id,state:run.state,tasks:[]};\n const plan = compile(run.board, run.jobs), tasks = [];\n for (const step of plan.steps.filter(s => ['ready','needs_review','review','submitted','queued','in_progress','leased'].includes(s.state))) {\n let request = null, blocked = null;\n if (step.state === 'ready') {\n try {\n if (step.executor === 'connector') request = connectorRequest(run.board,step,run.jobs,run.billing);\n else if (step.executor === 'media_worker') request = {executor:'canvas_media_worker.py',operation:step.operation,inputs:Object.fromEntries(Object.entries(step.bindings).map(([k,ids]) => [k,ids.map(id => mediaFor(run.board.nodes.find(n=>n.id===id),run.jobs))])),config:run.board.nodes.find(n=>n.id===step.id).render || {}};\n } catch(e) { blocked = e.message; }\n }\n tasks.push({...step,request,blocked,receipt:run.jobs[step.id]?.provider_job_id || null});\n }\n return {run_id:run.id,revision:run.revision,mode:run.mode,tasks,notice:'The ChatGPT executor must perform provider/worker calls and record actual receipts; this endpoint does not launch a background worker.'};\n}\nexport async function claimTask(args) {\n const run = await load(args); if (run.state !== 'active') throw Error('RUN_NOT_ACTIVE');\n if (!/^[A-Za-z0-9_-]{8,96}$/.test(args.request_id || '')) throw Error('REQUEST_ID_REQUIRED');\n const previous = run.jobs[args.node_id];\n if (previous) {\n if (previous.request_id === args.request_id && previous.state === 'leased') return {run_id:run.id,revision:run.revision,node_id:args.node_id,lease_token:previous.lease_token,idempotent:true};\n throw Error('TASK_ALREADY_CLAIMED_OR_SUBMITTED: inspect its receipt; no blind retry');\n }\n const plan = compile(run.board,run.jobs), step = plan.steps.find(s=>s.id===args.node_id);\n if (!plan.valid || !step || step.state !== 'ready' || step.executor === 'human') throw Error('TASK_NOT_READY');\n let request;\n if (step.executor === 'connector') {request=connectorRequest(run.board,step,run.jobs,run.billing); if (request.blocked) throw Error(request.blocked);}\n const lease = token();\n run.jobs[args.node_id] = {state:'leased',request_id:args.request_id,lease_token:lease,claimed_at:new Date().toISOString(),request:request || null};\n run.events.push({at:new Date().toISOString(),event:'task_claimed',node_id:args.node_id});\n const saved = await save(args,run);\n return {run_id:run.id,revision:saved.revision,node_id:args.node_id,lease_token:lease,request:request || {executor:step.executor,operation:step.operation,bindings:step.bindings},notice:'Lease persisted before provider submission. A lost/unknown submission must be reconciled, never repeated automatically.'};\n}\nexport async function recordTask(args) {\n const run = await load(args), job = run.jobs[args.node_id];\n if (!job || !args.lease_token || job.lease_token !== args.lease_token) throw Error('LEASE_ACCESS_DENIED');\n if (run.state !== 'active') throw Error('RUN_NOT_ACTIVE: provider receipt remains external; no downstream execution');\n const states = ['submitted','queued','in_progress','review','completed','failed','blocked'];\n if (!states.includes(args.state)) throw Error('INVALID_TASK_STATE');\n const op = operation(run.board.nodes.find(n=>n.id===args.node_id)), spec = NODE_TYPES.find(s=>s.id===op);\n if (['approved','rejected','completed','failed'].includes(job.state)) throw Error('TERMINAL_TASK: create a new run for a deliberate retry');\n if (spec.executor === 'connector' && args.state === 'completed') throw Error('VISUAL_REVIEW_REQUIRED: model output must enter review, never auto-complete');\n if (spec.executor === 'connector' && ['submitted','queued','in_progress','review'].includes(args.state) && (!args.provider_job_id || typeof args.provider_job_id !== 'string' || args.provider_job_id.length > 200)) throw Error('REAL_PROVIDER_JOB_ID_REQUIRED');\n if (job.provider_job_id && args.provider_job_id && job.provider_job_id !== args.provider_job_id) throw Error('PROVIDER_JOB_ID_MISMATCH');\n if (['review','completed'].includes(args.state)) {\n if (!args.output || args.output.kind !== spec.output || !(safeUrl(args.output.url) || spec.output === 'text' && typeof args.output.text === 'string')) throw Error('VALID_OUTPUT_REQUIRED');\n }\n if (args.output?.url && !safeUrl(args.output.url)) throw Error('UNSAFE_OUTPUT_URL');\n if (typeof args.note !== 'string' || args.note.length > 4000) throw Error('EVIDENCE_NOTE_REQUIRED');\n Object.assign(job,{state:args.state,checked_at:new Date().toISOString(),note:args.note,evidence_source:'executor_report'});\n if (args.provider_job_id) job.provider_job_id=args.provider_job_id;\n if (args.output) job.output=args.output;\n if (args.qa) {if (bytes(args.qa)>16000) throw Error('QA_TOO_LARGE'); job.qa=args.qa;}\n run.events.push({at:job.checked_at,event:'provider_or_worker_receipt',node_id:args.node_id,state:args.state});\n if (run.events.length > 100) run.events=run.events.slice(-100);\n return save(args,run);\n}\nexport async function reviewTask(args) {\n const run=await load(args); if (run.state!=='active') throw Error('RUN_NOT_ACTIVE');\n if (args.user_confirmed!==true || !['approved','rejected'].includes(args.decision) || typeof args.note!=='string' || args.note.trim().length<4) throw Error('EXPLICIT_USER_VISUAL_REVIEW_REQUIRED');\n const n=run.board.nodes.find(n=>n.id===args.node_id); if(!n) throw Error('NODE_NOT_FOUND');\n let job=run.jobs[n.id];\n if (operation(n)==='review' && !job) {\n const step=compile(run.board,run.jobs).steps.find(s=>s.id===n.id);\n if(step.waiting.length || step.issues.length) throw Error('REVIEW_INPUT_NOT_READY');\n const inputId=step.bindings.video?.[0], output=mediaFor(run.board.nodes.find(x=>x.id===inputId),run.jobs);\n if(!output?.url || !safeUrl(output.url)) throw Error('NO_PLAYABLE_VIDEO');\n job={state:'review',output}; run.jobs[n.id]=job;\n }\n if(!job || job.state!=='review') throw Error('TASK_NOT_AWAITING_REVIEW');\n job.state=args.decision; job.review={by:'user',note:args.note,at:new Date().toISOString()};\n run.events.push({at:job.review.at,event:'visual_review',node_id:n.id,decision:args.decision});\n return save(args,run);\n}\nexport async function cancelRun(args) {\n const run=await load(args); run.state='cancelled';\n const external=Object.values(run.jobs).filter(j=>j.provider_job_id&&!['approved','rejected','failed','completed'].includes(j.state)).map(j=>j.provider_job_id);\n run.events.push({at:new Date().toISOString(),event:'run_cancelled',note:'Does not cancel provider jobs or guarantee refunds.'});\n return {...await save(args,run),provider_jobs_not_cancelled:external};\n}\n",[146],"492b448c-f5e6-4df4-9702-5dec7d382cc2",["D",1789180479903],2,"infinite-canvas-mcp-xh32",[28],"pulls","branches","forks","envVars",{"_164":62,"_166":62},"connections",{"_164":62,"_165":62},"count","unfilledCount","emptyCount",{"_43":152,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":177,"_13":154,"_33":34,"_35":37,"_24":25,"_143":155,"_171":178,"_27":179},{"_43":145,"_32":146,"_30":147,"_136":-5,"_41":42,"_40":148,"_138":25,"_38":174,"_13":62,"_33":141,"_35":150,"_24":25,"_143":-5,"_171":175,"_27":176},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":25,"_38":170,"_13":140,"_33":141,"_35":142,"_24":25,"_143":-5,"_171":172,"_27":173},["D",1789180354677],"children",[],[134],["D",1789180420310],[],[146],["D",1789180479903],[],[28],["D",1789176014798],["D",1789532458193],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_127":218,"_219":220,"_221":222,"_223":25,"_224":25,"_225":25,"_226":58,"_227":-5,"_228":-7,"_229":-7,"_230":62,"_231":25,"_232":25,"_233":-5,"_234":25,"_235":25,"_236":25,"_237":-5},"ENV",{"_189":190,"_191":192,"_193":89,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v8