[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","brain-cellf3u1-z4n7-scratch","path","candidate.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_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":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mosadek/brain-cellf3u1-z4n7-scratch/code/candidate.ts","extension","id","490c0dc3-0be3-4b04-9048-5092cb2b51f1","fileId","575b6c44-ae37-11f1-9416-1607ee4eb77e","parentId","branchId","2e151913-c997-462d-8d38-657782b03e25","branchVersion",7,"latest",true,"createdAt",["D",1789168937611],"version",5,"fileType","http","content","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'}})}}","deleted",false,"label",[14],"90c66d70-3ece-4bcd-b79a-a491b559279c",["D",1789168706324],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Ephemeral candidate rebasing scratchpad","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","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",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":62,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]