[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_181":182,"_183":184},"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":57,"_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",8,"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","verify.ts","latestPath","fileId","b4e1e5dc-ae37-11f1-9f94-1607ee4eb77e","name","fileType","script","content","import ts from \"npm:typescript@5.9.2\";\nconst CANDIDATE=\"https://mosadek--575b6c44ae3711f194161607ee4eb77e.web.val.run/\";\nconst EXPECTED_SHA=\"151f4ab4f63f2e07db9563854f9eb3587ee477220c489da7f6e2d272ed35af29\";\nconst enc=new TextEncoder();\nconst sha=async(s:string)=>[...new Uint8Array(await crypto.subtle.digest(\"SHA-256\",enc.encode(s)))].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nconst r=await fetch(CANDIDATE);if(!r.ok)throw new Error(`candidate_fetch_${r.status}`);const s=await r.text();const actual=await sha(s);\nconst tests:any[]=[];const t=(name:string,ok:boolean,detail:any=null)=>tests.push({name,ok,detail});\nt(\"exact_sha\",actual===EXPECTED_SHA,{actual,bytes:enc.encode(s).length});\nconst tr=ts.transpileModule(s,{compilerOptions:{target:ts.ScriptTarget.ES2022,module:ts.ModuleKind.ESNext},reportDiagnostics:true,fileName:\"candidate.ts\"});const diagnostics=(tr.diagnostics||[]).filter(d=>d.category===ts.DiagnosticCategory.Error).map(d=>ts.flattenDiagnosticMessageText(d.messageText,\"\\n\"));t(\"typescript_parse\",diagnostics.length===0,diagnostics.slice(0,10));\nconst required=[\n [\"resolver\",\"async function taskResolution(id:string)\"],\n [\"ambiguous_failclosed\",\"throw new Error(\\\"TASK_ID_AMBIGUOUS:\\\"+id)\"],\n [\"exact_definition_replay\",\"TASK_ID_DEFINITION_CONFLICT\"],\n [\"dedupe_id_collision\",\"TASK_ID_DEDUPE_IDENTITY_COLLISION\"],\n [\"claim_rowid\",\"WHERE rowid=? AND id=? AND state='READY' RETURNING id\"],\n [\"commit_rowid\",\"TASK_IDENTITY_LOST_DURING_COMMIT\"],\n [\"renew_rowid\",\"TASK_IDENTITY_LOST_DURING_RENEW\"],\n [\"recover_ambiguous\",\"ambiguous_task_ids:[...ambiguous].sort()\"],\n [\"context_rowid\",\"TASK_IDENTITY_LOST_DURING_CONTEXT_SUPERSESSION\"],\n [\"invariant_rowid\",\"TASK_IDENTITY_LOST_DURING_INVARIANT_MIGRATION\"],\n [\"focus_carrier\",\"RUNTIME_FOCUS_POLICY_CARRIER_TASK\"],\n [\"focus_snapshot\",\"buildFocusSnapshot\"],\n [\"focus_decision\",\"focusTaskDecision\"],\n [\"chat_unproven\",\"CHAT_UNPROVEN\"],\n [\"non_agent\",\"human_authority_approval\"],\n [\"assignment_gate\",\"ASSIGNED_OTHER\"],\n [\"dependency_gate\",\"DEPENDENCY_UNSATISFIED\"],\n [\"guard_gate\",\"GUARD_UNSATISFIED\"],\n [\"write_conflict\",\"WRITE_CONFLICT\"],\n [\"lease_generation\",\"expected-lease-generation\"],\n [\"workstream_cas\",\"STALE_WORKSTREAM_WRITE\"],\n [\"transport_guard\",\"boundTransportGuard\"],\n [\"attempt_fence\",\"VAL_NATIVE_TRANSPORT_ATTEMPT_FENCED\"],\n [\"mutation_receipts\",\"brainvn_mutation_receipts\"],\n [\"stable_retry\",\"STABLE_RETRY_AUTHORIZATION_FENCED\"],\n [\"trust_metadata\",\"p_real_eligible:false\"],\n [\"focus_rev3_binding_field\",\"temporary_focus_policy_revision\"],\n];\nfor(const [name,needle] of required)t(`anchor_${name}`,s.includes(needle),needle);\nconst forbidden=[\n [\"id_only_complete_update\",/UPDATE \\$\\{P\\}tasks SET state='COMPLETE'[^`]*WHERE id=\\?/g],\n [\"id_only_full_commit_update\",/UPDATE \\$\\{P\\}tasks SET state=\\?[^`]*WHERE id=\\?/g],\n [\"id_only_context_update\",/UPDATE \\$\\{P\\}tasks SET context_manifest=\\?[^`]*WHERE id=\\?/g],\n [\"id_only_invariant_update\",/UPDATE \\$\\{P\\}tasks SET dedupe_key=\\?[^`]*WHERE id=\\?/g],\n [\"task_delete\",/DELETE\\s+FROM\\s+\\$\\{P\\}tasks/gi]\n];\nfor(const [name,re] of forbidden as any)t(`forbidden_${name}`,!(re as RegExp).test(s));\n// Pure semantic counterexample model for the exact identity rules transplanted into the kernel.\ntype Row={rowid:number,id:string,ws:string,dedupe:string,priority:number,definition:string,state:string,lease_owner?:string|null};\nfunction rowsById(rows:Row[],id:string){return rows.filter(x=>x.id===id)}\nfunction rowsByDedupe(rows:Row[],ws:string,d:string){return rows.filter(x=>x.ws===ws&&x.dedupe===d)}\nfunction unique(rows:Row[],id:string){const xs=rowsById(rows,id);if(xs.length>1)throw new Error(\"TASK_ID_AMBIGUOUS\");return xs[0]??null}\nfunction existing(rows:Row[],e:Row){const a=rowsById(rows,e.id),b=rowsByDedupe(rows,e.ws,e.dedupe);if(a.length>1)throw new Error(\"TASK_ID_AMBIGUOUS\");if(b.length>1)throw new Error(\"TASK_DEDUPE_AMBIGUOUS\");if(a[0]&&b[0]&&a[0].rowid!==b[0].rowid)throw new Error(\"TASK_ID_DEDUPE_IDENTITY_COLLISION\");const x=a[0]??b[0];if(!x)return null;if(x.id!==e.id)throw new Error(\"DEDUPE_KEY_TASK_ID_CONFLICT\");if(x.definition!==e.definition||x.priority!==e.priority)throw new Error(\"TASK_ID_DEFINITION_CONFLICT\");return x}\nconst base:Row={rowid:1,id:\"T\",ws:\"global\",dedupe:\"D1\",priority:7,definition:\"A\",state:\"READY\"};let rows=[base];\nt(\"semantic_exact_replay\",existing(rows,{...base})?.rowid===1);\nlet threw=false;try{existing(rows,{...base,dedupe:\"D2\",definition:\"B\"})}catch{threw=true}t(\"semantic_same_id_different_definition_or_dedupe_rejected\",threw);\nthrew=false;try{existing(rows,{...base,rowid:2,id:\"U\",dedupe:\"D1\"})}catch{threw=true}t(\"semantic_same_dedupe_different_id_rejected\",threw);\nrows=[{...base,state:\"LEASED\",lease_owner:\"A\"},{...base,rowid:2,dedupe:\"D2\",definition:\"B\",state:\"READY\"}];threw=false;try{unique(rows,\"T\")}catch{threw=true}t(\"semantic_postlease_duplicate_commit_fails_closed\",threw&&rows.filter(x=>x.state===\"COMPLETE\").length===0);\nfor(const pair of [[\"READY\",\"LEASED\"],[\"READY\",\"COMPLETE\"]]){rows=[{...base,state:pair[0]},{...base,rowid:2,dedupe:\"D2\",definition:\"B\",state:pair[1]}];threw=false;try{unique(rows,\"T\")}catch{threw=true}t(`semantic_twin_${pair[0]}_${pair[1]}_reject`,threw)}\nrows=[{...base,definition:\"weak\",state:\"READY\"},{...base,rowid:2,dedupe:\"D2\",definition:\"strong\",state:\"READY\"}];t(\"semantic_weaker_twin_cannot_be_selected\",rowsById(rows,\"T\").length!==1);\nconst directTaskIdLookups=(s.match(/one\\(`SELECT [^`]*FROM \\$\\{P\\}tasks WHERE id=\\?/g)||[]).length;t(\"no_direct_one_task_id_lookup\",directTaskIdLookups===0,directTaskIdLookups);\nconst writeTx=s.includes('return await withTransaction(\"write\",async()=>{');t(\"mutators_still_transactional\",writeTx);\nconst failed=tests.filter(x=>!x.ok);console.log(JSON.stringify({schema:\"CELLF3U1_CANDIDATE_VERIFY_V1\",candidate_sha256:actual,candidate_bytes:enc.encode(s).length,pass:failed.length===0,total:tests.length,failed,tests},null,2));if(failed.length)Deno.exit(1);","createdAt",["D",1789168970617],"branchVersion","branchId","2e151913-c997-462d-8d38-657782b03e25","id","90c66d70-3ece-4bcd-b79a-a491b559279c","brain-cellf3u1-z4n7-scratch",["D",1789168706324],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Ephemeral candidate rebasing scratchpad","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","575b6c44-ae37-11f1-9416-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","90c66d703ece4bcdb79aa491b559279c","tursoHostname","90c66d703ece4bcdb79aa491b559279c-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"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","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":176,"_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":177,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":178,"_82":179,"_84":180,"_86":24},"tree",[163,164,165],"files",[163,164,165],"counts",{"_153":61,"_154":141,"_155":61,"_156":157,"_158":159},"contents",[129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":145,"_31":146,"_29":55,"_133":-5,"_39":40,"_38":147,"_134":57,"_36":148,"_13":149,"_32":150,"_34":151,"_23":24,"_136":-5,"_26":152},{"_41":138,"_31":139,"_29":140,"_133":-5,"_39":40,"_38":141,"_134":57,"_36":142,"_13":61,"_32":33,"_34":143,"_23":24,"_136":-5,"_26":144},{"_41":132,"_31":27,"_29":30,"_133":-5,"_39":40,"_38":14,"_134":57,"_36":135,"_13":61,"_32":33,"_34":35,"_23":24,"_136":-5,"_26":137},"26e48734-1bab-4cbf-afab-90502a3c9bb1","parentId","latest",["D",1789168970617],"label",[27],"edd912d4-70e0-4d26-8deb-3e9894e7ef07","probe.ts","176251a2-ae37-11f1-a9a0-1607ee4eb77e",1,["D",1789168706369],"const enc=new TextEncoder();\nconst hex=async(s:string)=>[...new Uint8Array(await crypto.subtle.digest('SHA-256',enc.encode(s)))].map(x=>x.toString(16).padStart(2,'0')).join('');\nconst urls=[\n 'https://esm.town/v/mosadek/project-brain-live-v1-durable/val_native_kernel_v1.ts',\n 'https://esm.town/v/mosadek/project-brain-live-v1-durable@main/val_native_kernel_v1.ts'\n];\nfor(const url of urls){try{const r=await fetch(url);const t=await r.text();console.log(JSON.stringify({url,status:r.status,final:r.url,bytes:enc.encode(t).length,sha256:await hex(t),prefix:t.slice(0,80)}));}catch(e){console.log(JSON.stringify({url,error:String(e)}));}}\n",[139],"490c0dc3-0be3-4b04-9048-5092cb2b51f1","candidate.ts",7,["D",1789168937611],5,"http","const enc=new TextEncoder();\nconst BASE='https://esm.town/v/mosadek/project-brain-live-v1-durable@3233-main/val_native_kernel_v1.ts';\nconst BASE_SHA='9d4e0612857a5b0f4de62144232fca6f46210a9aea7c93e8cef20b1df50ab789';\nconst hex=async(s:string)=>[...new Uint8Array(await crypto.subtle.digest('SHA-256',enc.encode(s)))].map(x=>x.toString(16).padStart(2,'0')).join('');\nfunction once(src:string,oldS:string,newS:string,label:string){const i=src.indexOf(oldS);if(i<0)throw new Error('PATCH_MISS:'+label);if(src.indexOf(oldS,i+oldS.length)>=0)throw new Error('PATCH_MULTI:'+label);return src.slice(0,i)+newS+src.slice(i+oldS.length)}\nfunction inFn(src:string,startMark:string,endMark:string,oldS:string,newS:string,label:string){const a=src.indexOf(startMark),b=src.indexOf(endMark,a+startMark.length);if(a<0||b<0)throw new Error('PATCH_RANGE:'+label);const seg=src.slice(a,b);const i=seg.indexOf(oldS);if(i<0)throw new Error('PATCH_MISS:'+label);if(seg.indexOf(oldS,i+oldS.length)>=0)throw new Error('PATCH_MULTI:'+label);return src.slice(0,a)+seg.slice(0,i)+newS+seg.slice(i+oldS.length)+src.slice(b)}\nfunction patch(base:string){let s=base;\nconst one=`async function one(sql:string,args:any[]=[]){const r:any=await sqlite.execute({sql,args});return r.rows?.[0]??null}\\n`;\nconst helpers=`async function one(sql:string,args:any[]=[]){const r:any=await sqlite.execute({sql,args});return r.rows?.[0]??null}\\nasync function taskRowsById(id:string){const r:any=await sqlite.execute({sql:\\`SELECT rowid AS __task_rowid,* FROM \\${P}tasks WHERE id=? ORDER BY rowid\\`,args:[id]});return (r.rows||[]) as any[]}\\nasync function taskResolution(id:string){const rows=await taskRowsById(id);return rows.length===0?{kind:\\\"MISSING\\\" as const,row:null,count:0}:rows.length===1?{kind:\\\"UNIQUE\\\" as const,row:rows[0],count:1}:{kind:\\\"AMBIGUOUS\\\" as const,row:null,count:rows.length}}\\nasync function taskMultiplicity(id:string){return (await taskResolution(id)).count}\\nasync function uniqueTaskById(id:string){const x=await taskResolution(id);if(x.kind===\\\"AMBIGUOUS\\\")throw new Error(\\\"TASK_ID_AMBIGUOUS:\\\"+id);return x.kind===\\\"UNIQUE\\\"?x.row:null}\\nasync function taskRowsByDedupe(ws:string,dedupe:string){const r:any=await sqlite.execute({sql:\\`SELECT rowid AS __task_rowid,* FROM \\${P}tasks WHERE workstream=? AND dedupe_key=? ORDER BY rowid\\`,args:[ws,dedupe]});return (r.rows||[]) as any[]}\\nfunction taskDefinitionMatches(r:any,e:any){return String(r.id)===e.id&&String(r.workstream)===e.ws&&Number(r.priority)===e.priority&&canon(parseJson(r.depends_json||\\\"[]\\\",\\\"EXISTING_DEPS\\\"))===canon(e.deps)&&String(r.success_condition||\\\"\\\")===e.success&&String(r.decision_value||\\\"\\\")===e.value&&canon(parseJson(r.context_manifest||\\\"{}\\\",\\\"EXISTING_CTX\\\"))===canon(e.ctx)&&canon(parseJson(r.requires_json||\\\"[]\\\",\\\"EXISTING_REQ\\\"))===canon(e.req)&&String(r.dedupe_key||\\\"\\\")===e.dedupe&&(r.assigned_agent??null)===(e.assigned??null)&&(r.delegated_by??null)===(e.delegated??null)&&canon(parseJson(r.writes_json||\\\"[]\\\",\\\"EXISTING_WRITES\\\"))===canon(e.writes)&&canon(parseJson(r.guards_json||\\\"[]\\\",\\\"EXISTING_GUARDS\\\"))===canon(e.guards)}\\nasync function existingTaskForCreation(e:any){const byId=await taskRowsById(e.id),byDedupe=await taskRowsByDedupe(e.ws,e.dedupe);if(byId.length>1)throw new Error(\\\"TASK_ID_AMBIGUOUS:\\\"+e.id);if(byDedupe.length>1)throw new Error(\\\"TASK_DEDUPE_AMBIGUOUS:\\\"+e.dedupe);const a=byId[0]??null,b=byDedupe[0]??null;if(a&&b&&Number(a.__task_rowid)!==Number(b.__task_rowid))throw new Error(\\\"TASK_ID_DEDUPE_IDENTITY_COLLISION\\\");const r=a??b;if(!r)return null;if(String(r.id)!==e.id)throw new Error(\\\"DEDUPE_KEY_TASK_ID_CONFLICT\\\");if(!taskDefinitionMatches(r,e))throw new Error(\\\"TASK_ID_DEFINITION_CONFLICT\\\");return r}\\n`;\ns=once(s,one,helpers,'helpers');\ns=once(s,'const t:any=await one(`SELECT state,result_event_id FROM ${P}tasks WHERE id=?`,[CHAT_UNPROVEN_ACTIVATION_TASK]);','const t:any=await uniqueTaskById(CHAT_UNPROVEN_ACTIVATION_TASK);','chat-activation');\ns=once(s,'if(a.task_id){const t:any=await one(`SELECT workstream FROM ${P}tasks WHERE id=?`,[a.task_id]);if(t&&String(t.workstream)===ws)return true}','if(a.task_id){const t:any=await uniqueTaskById(String(a.task_id));if(t&&String(t.workstream)===ws)return true}','artifact-task');\ns=once(s,'async function depsSatisfied(r:any){for(const d of parseJson(r.depends_json||\"[]\",\"DEPS\")){const x:any=await one(`SELECT state FROM ${P}tasks WHERE id=?`,[d]);if(!x||String(x.state)!==\"COMPLETE\")return false}return true}','async function depsSatisfied(r:any){for(const d of parseJson(r.depends_json||\"[]\",\"DEPS\")){const x:any=await uniqueTaskById(String(d));if(!x||String(x.state)!==\"COMPLETE\")return false}return true}','deps');\ns=once(s,'const row:any=await one(`SELECT state,context_manifest FROM ${P}tasks WHERE id=?`,[RUNTIME_FOCUS_POLICY_CARRIER_TASK]);','const row:any=await uniqueTaskById(RUNTIME_FOCUS_POLICY_CARRIER_TASK);','focus-carrier');\ns=once(s,'if(g.type===\"task_complete\"){const x:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!x||String(x.workstream)!==String(r.workstream)||String(x.state)!==\"COMPLETE\")return false}','if(g.type===\"task_complete\"){const x:any=await uniqueTaskById(String(g.id));if(!x||String(x.workstream)!==String(r.workstream)||String(x.state)!==\"COMPLETE\")return false}','guard-satisfied-task');\ns=once(s,'if(g.type===\"task_complete\"){if(typeof g.id!==\"string\"||!g.id)throw new Error(\"BAD_TASK_GUARD\");const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!r)throw new Error(\"UNKNOWN_GUARD_TASK\");','if(g.type===\"task_complete\"){if(typeof g.id!==\"string\"||!g.id)throw new Error(\"BAD_TASK_GUARD\");const r:any=await uniqueTaskById(String(g.id));if(!r)throw new Error(\"UNKNOWN_GUARD_TASK\");','normalize-guard-task');\ns=once(s,'type NoReadyReason=\"MISSING_DEDUPE\"|\"ASSIGNED_OTHER\"|','type NoReadyReason=\"TASK_ID_AMBIGUOUS\"|\"MISSING_DEDUPE\"|\"ASSIGNED_OTHER\"|','no-ready-type');\ns=once(s,'const NO_READY_REASONS:NoReadyReason[]=[\"MISSING_DEDUPE\",','const NO_READY_REASONS:NoReadyReason[]=[\"TASK_ID_AMBIGUOUS\",\"MISSING_DEDUPE\",','no-ready-list');\ns=once(s,'const q:any=await sqlite.execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state=\\'READY\\' ORDER BY priority DESC,id`,args:[ws]});const C=new Set(caps);','const q:any=await sqlite.execute({sql:`SELECT rowid AS __task_rowid,* FROM ${P}tasks WHERE workstream=? AND state=\\'READY\\' ORDER BY priority DESC,id,rowid`,args:[ws]});const C=new Set(caps);','bestready-select');\ns=once(s,'readyRowsSeen++;\\n if(!r.dedupe_key){','readyRowsSeen++;\\n if(await taskMultiplicity(String(r.id))!==1){reject(r,\"TASK_ID_AMBIGUOUS\");continue}\\n if(!r.dedupe_key){','bestready-multiplicity');\nconst ensureStart=s.indexOf('async function ensureTask(args:string[]){');const ensureEnd=s.indexOf('\\nasync function claim(args:string[]){',ensureStart);if(ensureStart<0||ensureEnd<0)throw new Error('PATCH_RANGE:ensure');\nconst ensureNew=`async function ensureTask(args:string[]){\\n if(args.length<2)throw new Error(\"TASK_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),dedupe=String(f[\"dedupe-key\"]||\"\");if(!ws||!dedupe)throw new Error(\"ENSURE_FIELDS_REQUIRED\");\\n const deps=parseJson(f.depends||\"[]\",\"DEPS\"),ctx=parseJson(f.context||\"{}\",\"CTX\"),req=parseJson(f.requires||\"[]\",\"REQ\"),writes=cleanWrites(parseJson(f.writes||\"[]\",\"WRITES\")),guards=await normalizeGuards(ws,parseJson(f.guards||\"[]\",\"GUARDS\"));\\n if(!Array.isArray(deps)||!ctx||Array.isArray(ctx)||!Array.isArray(req))throw new Error(\"BAD_JSON_SHAPE\");\\n const priority=Number(f.priority);if(!Number.isFinite(priority))throw new Error(\"BAD_PRIORITY\");const expectedDef={id,ws,priority,deps,success:String(f.success||\"\"),value:String(f.value||\"\"),ctx,req,dedupe,assigned:null,delegated:null,writes,guards};const existing:any=await existingTaskForCreation(expectedDef);if(existing)return{ok:true,created:false,task_id:existing.id,state:existing.state,lease_owner:existing.lease_owner,generation:await generation(),dedupe_key:dedupe};\\n if(!await one(\\`SELECT id FROM \\${P}workstreams WHERE id=?\\`,[ws]))throw new Error(\"UNKNOWN_WORKSTREAM\");\\n for(const d of deps){const r:any=await uniqueTaskById(String(d));if(!r)throw new Error(\"UNKNOWN_DEP\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_DEP\");if([\"INVALID\",\"BLOCKED\"].includes(String(r.state)))throw new Error(\"TERMINAL_DEPENDENCY\")}\\n const t=now();await sqlite.execute({sql:\\`INSERT INTO \\${P}tasks(id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json) VALUES(?,?,'READY',?,?,?,?,?,NULL,NULL,NULL,NULL,?,?,NULL,?,?,NULL,NULL,?,?)\\`,args:[id,ws,priority,canon(deps),String(f.success||\"\"),String(f.value||\"\"),canon(ctx),t,t,canon(req),dedupe,canon(writes),canon(guards)]});\\n await appendEvent(ws,f.agent??null,id,\"TASK_CREATED\",{priority,depends:deps,requires:req,writes,guards,dedupe_key:dedupe,success_condition:String(f.success||\"\"),decision_value:String(f.value||\"\")});const ng=await bump();await sqlite.execute({sql:\\`UPDATE \\${P}workstreams SET head_generation=?,updated_at=? WHERE id=?\\`,args:[ng,now(),ws]});return{ok:true,created:true,task_id:id,state:\"READY\",generation:ng,dedupe_key:dedupe}\\n}`;\ns=s.slice(0,ensureStart)+ensureNew+s.slice(ensureEnd);\nconst claimStart=s.indexOf('async function claim(args:string[]){');const claimEnd=s.indexOf('\\nasync function renew(args:string[]){',claimStart);if(claimStart<0||claimEnd<0)throw new Error('PATCH_RANGE:claim');\nconst claimOld=s.slice(claimStart,claimEnd);\nlet claimNew=claimOld;\nclaimNew=claimNew.replace('const ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[id]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");if(String(ag.type)===\"CHAT_UNPROVEN\"){const blocked:any=await requireChatUnprovenActivation();if(blocked)return blocked}const held:any=await one(`SELECT id,lease_expires_at FROM ${P}tasks WHERE state=\\'LEASED\\' AND lease_owner=? ORDER BY updated_at DESC LIMIT 1`,[id]);const g0=await generation();','const ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[id]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");if(String(ag.type)===\"CHAT_UNPROVEN\"){const blocked:any=await requireChatUnprovenActivation();if(blocked)return blocked}const heldQ:any=await sqlite.execute({sql:`SELECT rowid AS __task_rowid,id,lease_expires_at FROM ${P}tasks WHERE state=\\'LEASED\\' AND lease_owner=? ORDER BY updated_at DESC,rowid`,args:[id]});const heldRows:any[]=heldQ.rows||[];const g0=await generation();if(heldRows.length>1)return{ok:false,reason:\"AGENT_LEASE_MULTIPLICITY_AMBIGUOUS\",task_ids:[...new Set(heldRows.map((x:any)=>String(x.id)))].sort(),generation:g0};const held:any=heldRows[0]??null;');\nclaimNew=claimNew.replace('if(held){if(held.lease_expires_at&&String(held.lease_expires_at)();\\n for(const r of stale){if(await taskMultiplicity(String(r.id))!==1){ambiguous.add(String(r.id));continue}const old=r.lease_owner??null;const u:any=await sqlite.execute({sql:\\`UPDATE \\${P}tasks SET state='READY',lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL,updated_at=? WHERE rowid=? AND id=? RETURNING id\\`,args:[now(),r.__task_rowid,r.id]});if((u.rows||[]).length!==1)throw new Error(\"TASK_IDENTITY_LOST_DURING_RECOVERY\");if(old&&!await one(\\`SELECT id FROM \\${P}tasks WHERE state='LEASED' AND lease_owner=? LIMIT 1\\`,[old]))await sqlite.execute({sql:\\`UPDATE \\${P}agents SET status='READY',last_seen=? WHERE id=?\\`,args:[now(),old]});await appendEvent(String(r.workstream),null,String(r.id),\"TASK_LEASE_RECOVERED\",{previous_owner:old});recovered.push(String(r.id))}\\n let g=await generation();if(recovered.length){g=await bump();const wss=[...new Set(stale.filter(r=>!ambiguous.has(String(r.id))).map(r=>String(r.workstream)))].sort();for(const ws of wss)await sqlite.execute({sql:\\`UPDATE \\${P}workstreams SET head_generation=?,updated_at=? WHERE id=?\\`,args:[g,now(),ws]})}return{ok:true,recovered,ambiguous_task_ids:[...ambiguous].sort(),generation:g}\\n}`;\ns=s.slice(0,recoverStart)+recoverNew+s.slice(recoverEnd);\ns=inFn(s,'async function commit(args:string[]){','\\nasync function validateEvidenceRefs(','const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','const task:any=await uniqueTaskById(taskId),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','commit-select-first');\ns=once(s,'await sqlite.execute({sql:`UPDATE ${P}tasks SET state=\\'COMPLETE\\',result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE id=?`,args:[eid,now(),taskId]});','const u:any=await sqlite.execute({sql:`UPDATE ${P}tasks SET state=\\'COMPLETE\\',result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE rowid=? AND id=? RETURNING id`,args:[eid,now(),task.__task_rowid,taskId]});if((u.rows||[]).length!==1)throw new Error(\"TASK_IDENTITY_LOST_DURING_COMMIT\");','commit-update-first');\ns=once(s,'else if(ref.startsWith(\"task:\")){const id=ref.slice(5),r:any=await one(`SELECT state,result_event_id FROM ${P}tasks WHERE id=?`,[id]);if(!r||String(r.state)!==\"COMPLETE\"||r.result_event_id===null)throw new Error(\"UNVERIFIED_TASK_EVIDENCE\")}','else if(ref.startsWith(\"task:\")){const id=ref.slice(5),r:any=await uniqueTaskById(id);if(!r||String(r.state)!==\"COMPLETE\"||r.result_event_id===null)throw new Error(\"UNVERIFIED_TASK_EVIDENCE\")}','evidence-task');\ns=once(s,'const out:any[]=[];for(const d of parseJson(r.depends_json||\"[]\",\"DEPS\")){const x:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[d]);','const out:any[]=[];for(const d of parseJson(r.depends_json||\"[]\",\"DEPS\")){const x:any=await uniqueTaskById(String(d));','terminal-dep');\ns=once(s,'if(g.type===\"task_complete\"){const x:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);','if(g.type===\"task_complete\"){const x:any=await uniqueTaskById(String(g.id));','terminal-guard');\ns=once(s,'const changed:any[]=[];while(true){const rows:any[]=(await sqlite.execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state=\\'READY\\' ORDER BY id`,args:[ws]})).rows as any[];const round:any[]=[];\\n for(const r of rows){const deps=await terminalDepFailures(r),guards=await terminalGuardFailures(r);','const changed:any[]=[];while(true){const rows:any[]=(await sqlite.execute({sql:`SELECT rowid AS __task_rowid,* FROM ${P}tasks WHERE workstream=? AND state=\\'READY\\' ORDER BY id,rowid`,args:[ws]})).rows as any[];const round:any[]=[];\\n for(const r of rows){if(await taskMultiplicity(String(r.id))!==1)continue;const deps=await terminalDepFailures(r),guards=await terminalGuardFailures(r);','propagate-select');\ns=once(s,'WHERE id=? AND state=\\'READY\\' RETURNING id`,args:[eid,now(),r.id]});\\n if((u.rows||[]).length){','WHERE rowid=? AND id=? AND state=\\'READY\\' RETURNING id`,args:[eid,now(),r.__task_rowid,r.id]});\\n if((u.rows||[]).length){','propagate-update');\nconst delStart=s.indexOf('async function delegateTask(args:string[]){');const delEnd=s.indexOf('\\nasync function supersedeContext(args:string[]){',delStart);if(delStart<0||delEnd<0)throw new Error('PATCH_RANGE:delegate');\nlet del=s.slice(delStart,delEnd);\ndel=del.replace('const existing:any=await one(`SELECT * FROM ${P}tasks WHERE workstream=? AND dedupe_key=? ORDER BY created_at DESC LIMIT 1`,[ws,dedupe]);if(existing){if(String(existing.assigned_agent)!==child||String(existing.delegated_by)!==parent)throw new Error(\"DEDUPE_KEY_DELEGATION_MISMATCH\");return{ok:true,created:false,task_id:existing.id,state:existing.state,assigned_agent:existing.assigned_agent,delegated_by:existing.delegated_by,lease_owner:existing.lease_owner,generation:await generation(),dedupe_key:dedupe}}','const priority=Number(f.priority??0);if(!Number.isFinite(priority))throw new Error(\"BAD_PRIORITY\");const expectedDef={id,ws,priority,deps,success:String(f.success||\"\"),value:String(f.value||\"\"),ctx,req,dedupe,assigned:child,delegated:parent,writes,guards};const existing:any=await existingTaskForCreation(expectedDef);if(existing)return{ok:true,created:false,task_id:existing.id,state:existing.state,assigned_agent:existing.assigned_agent,delegated_by:existing.delegated_by,lease_owner:existing.lease_owner,generation:await generation(),dedupe_key:dedupe}');\ndel=del.replace('for(const d of deps){const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[d]);','for(const d of deps){const r:any=await uniqueTaskById(String(d));');\ndel=del.replace('const t=now(),priority=Number(f.priority??0);await sqlite.execute','const t=now();await sqlite.execute');\nif(del===s.slice(delStart,delEnd))throw new Error('PATCH_NOCHANGE:delegate');s=s.slice(0,delStart)+del+s.slice(delEnd);\ns=inFn(s,'async function supersedeContext(args:string[]){','\\nasync function ensureTaskInvariantRequiresColumns(','const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','const task:any=await uniqueTaskById(taskId),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','supersede-select');\ns=once(s,'await sqlite.execute({sql:`UPDATE ${P}tasks SET context_manifest=?,updated_at=? WHERE id=?`,args:[canon(newCtx),now(),taskId]});const ng=await bump();','const u:any=await sqlite.execute({sql:`UPDATE ${P}tasks SET context_manifest=?,updated_at=? WHERE rowid=? AND id=? RETURNING id`,args:[canon(newCtx),now(),task.__task_rowid,taskId]});if((u.rows||[]).length!==1)throw new Error(\"TASK_IDENTITY_LOST_DURING_CONTEXT_SUPERSESSION\");const ng=await bump();','supersede-update');\ns=inFn(s,'async function migrateInvariants(args:string[]){','\\nasync function reconcileCausal(','const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','const task:any=await uniqueTaskById(taskId),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','migrate-select');\ns=once(s,'await sqlite.execute({sql:`UPDATE ${P}tasks SET dedupe_key=?,writes_json=?,guards_json=?,requires_json=?,updated_at=? WHERE id=?`,args:[dedupe,canon(writes),canon(guards),newR,now(),taskId]});const ng=await bump();','const u:any=await sqlite.execute({sql:`UPDATE ${P}tasks SET dedupe_key=?,writes_json=?,guards_json=?,requires_json=?,updated_at=? WHERE rowid=? AND id=? RETURNING id`,args:[dedupe,canon(writes),canon(guards),newR,now(),task.__task_rowid,taskId]});if((u.rows||[]).length!==1)throw new Error(\"TASK_IDENTITY_LOST_DURING_INVARIANT_MIGRATION\");const ng=await bump();','migrate-update');\ns=once(s,'if(spec.task!==null){const t:any=await one(`SELECT workstream FROM ${P}tasks WHERE id=?`,[spec.task]);if(!t)throw new Error(\"UNKNOWN_ARTIFACT_TASK\");','if(spec.task!==null){const t:any=await uniqueTaskById(spec.task);if(!t)throw new Error(\"UNKNOWN_ARTIFACT_TASK\");','external-art-task');\ns=inFn(s,'async function commitFull(args:string[]){','\\nconst CHECKPOINT_STATE_TABLES=','const f=flags(args,1),agent=String(f.agent||\"\"),taskId=String(f.task||\"\"),state=String(f.state||\"COMPLETE\");if(!agent||!taskId||![\"COMPLETE\",\"INVALID\",\"BLOCKED\"].includes(state))throw new Error(\"BAD_COMMIT\");const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','const f=flags(args,1),agent=String(f.agent||\"\"),taskId=String(f.task||\"\"),state=String(f.state||\"COMPLETE\");if(!agent||!taskId||![\"COMPLETE\",\"INVALID\",\"BLOCKED\"].includes(state))throw new Error(\"BAD_COMMIT\");const task:any=await uniqueTaskById(taskId),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);','commitfull-select');\ns=once(s,'await sqlite.execute({sql:`UPDATE ${P}tasks SET state=?,result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE id=?`,args:[state,eid,now(),taskId]});let propagated:any[]=[];','const u:any=await sqlite.execute({sql:`UPDATE ${P}tasks SET state=?,result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE rowid=? AND id=? RETURNING id`,args:[state,eid,now(),task.__task_rowid,taskId]});if((u.rows||[]).length!==1)throw new Error(\"TASK_IDENTITY_LOST_DURING_COMMIT\");let propagated:any[]=[];','commitfull-update');\nreturn s}\nexport default async function(req:Request){try{const r=await fetch(BASE);if(!r.ok)return new Response('base fetch '+r.status,{status:500});const b=await r.text();const bh=await hex(b);if(bh!==BASE_SHA)return new Response('base hash mismatch '+bh,{status:500});const c=patch(b);const ch=await hex(c);return new Response(c,{headers:{'content-type':'text/plain; charset=utf-8','x-base-sha256':bh,'x-candidate-sha256':ch,'x-candidate-bytes':String(enc.encode(c).length)}})}catch(e){return new Response(String(e?.stack||e),{status:500,headers:{'content-type':'text/plain'}})}}",[146],"pulls","branches","forks","envVars",{"_160":61,"_162":61},"connections",{"_160":61,"_161":61},"count","unfilledCount","emptyCount",{"_41":145,"_31":146,"_29":55,"_133":-5,"_39":40,"_38":147,"_134":57,"_36":173,"_13":149,"_32":150,"_34":151,"_23":24,"_136":-5,"_167":174,"_26":175},{"_41":138,"_31":139,"_29":140,"_133":-5,"_39":40,"_38":141,"_134":57,"_36":170,"_13":61,"_32":33,"_34":143,"_23":24,"_136":-5,"_167":171,"_26":172},{"_41":132,"_31":27,"_29":30,"_133":-5,"_39":40,"_38":14,"_134":57,"_36":166,"_13":61,"_32":33,"_34":35,"_23":24,"_136":-5,"_167":168,"_26":169},["D",1789168970617],"children",[],[27],["D",1789168706369],[],[139],["D",1789168937611],[],[146],["D",1789168706324],["D",1789522836959],{"_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":214,"_215":216,"_217":218,"_219":24,"_220":24,"_221":24,"_222":57,"_223":-5,"_224":-7,"_225":-7,"_226":61,"_227":24,"_228":24,"_229":-5,"_230":24,"_231":24,"_232":24,"_233":-5},"ENV",{"_185":186,"_187":188,"_189":88,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8