[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_255":256,"_257":258},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_39":-7,"_134":-5,"_19":135,"_136":137,"_138":139,"_140":141,"_142":143,"_21":144,"_145":-5,"_146":-5,"_147":24,"_148":149,"_150":93,"_151":-5,"_152":-5,"_153":154},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","mosadek","name","brain-cellf3u1-z4n7-scratch","branchName","main","path","carrier.ts","project",{"_33":80,"_13":14,"_37":81,"_82":-5,"_83":24,"_84":85,"_86":85,"_87":88,"_89":-5,"_30":69,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":26,"_41":42,"_97":98,"_99":100,"_101":102,"_103":-5,"_104":105,"_106":105,"_107":108,"_109":108,"_110":108,"_111":105,"_112":105,"_54":113,"_114":115,"_116":117,"_118":24},"file",{"_64":65,"_13":18,"_66":67,"_68":24,"_79":-5},"isDirectory",false,"page",0,"history",[31,32],"hasNext","userId",{"_33":72,"_35":36,"_37":73,"_39":74,"_41":42,"_43":34,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":75,"_21":76,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":77},{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":62},"id","d1922ac3-39ee-4aa7-8fce-3a15ca3d751a","branchId","2e151913-c997-462d-8d38-657782b03e25","createdAt",["D",1789169023459],"version",9,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","parentId","782e62c0-d36b-45eb-a846-1629297c5b08","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","ChatGPT","user",{"_33":69,"_41":42,"_11":12,"_70":71},{"_64":65,"_13":18,"_66":67,"_68":24},"pull","merge","revert","multiple","commits",[63],{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":-5,"_59":-5},"fileId","d45fb0b0-ae37-11f1-bb10-1607ee4eb77e","fileType","http","deleted","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","8c9ef498-e906-436b-b559-17bad29b44aa",["D",1789169063757],10,{"_33":69,"_41":42,"_11":12,"_70":71},{"_64":65,"_13":18,"_66":67,"_68":24},[78],{"_33":72,"_35":36,"_37":73,"_39":74,"_41":42,"_43":34,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":75,"_21":76,"_57":-5,"_58":-5,"_59":-5},"deletedAtVersion","90c66d70-3ece-4bcd-b79a-a491b559279c",["D",1789168706324],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Ephemeral candidate rebasing scratchpad","imageUrl","pinnedFileId","575b6c44-ae37-11f1-9416-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_133":71},"org",{"_11":12,"_128":129,"_70":71,"_30":69,"_130":131,"_132":24},"branch",{"_39":119,"_13":16,"_33":36,"_120":80,"_121":-5,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":14,"_127":12},"isOwned",16,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":80,"_13":14,"_37":250,"_82":-5,"_83":24,"_84":85,"_86":85,"_87":88,"_89":-5,"_30":69,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":26,"_41":42,"_97":98,"_99":100,"_101":251,"_103":-5,"_104":105,"_106":105,"_107":108,"_109":108,"_110":108,"_111":105,"_112":105,"_54":252,"_114":253,"_116":254,"_118":24},"tree",[174,175,176,177,178,179,180,181,182],"files",[174,175,176,177,178,179,180,181,182],"counts",{"_164":26,"_165":159,"_166":26,"_167":168,"_169":170},"contents",[],{"_33":155,"_13":18,"_64":65,"_43":-5,"_35":36,"_156":74,"_157":93,"_37":158,"_39":159,"_66":67,"_160":161,"_68":24,"_162":-5,"_17":163},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"f14b2425-849c-4251-8dd2-495da0cfcadd","branchVersion","latest",["D",1789169063757],1,"content","const CANDIDATE=\"https://mosadek--575b6c44ae3711f194161607ee4eb77e.web.val.run/\";\nconst BASE_SHA=\"9d4e0612857a5b0f4de62144232fca6f46210a9aea7c93e8cef20b1df50ab789\";\nconst EXPECTED=\"151f4ab4f63f2e07db9563854f9eb3587ee477220c489da7f6e2d272ed35af29\";\nconst enc=new TextEncoder();\nconst hex=async(b:Uint8Array)=>[...new Uint8Array(await crypto.subtle.digest(\"SHA-256\",b))].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nconst b64=(b:Uint8Array)=>{let out=\"\";for(let i=0;i gunzip -> verify candidate_kernel_sha256\",gzip_base64:b64(gz)};return new Response(JSON.stringify(obj),{headers:{\"content-type\":\"application/json\"}})}","label",[18],"pulls","branches","forks","envVars",{"_171":26,"_173":26},"connections",{"_171":26,"_172":26},"count","unfilledCount","emptyCount",{"_33":242,"_13":243,"_64":91,"_43":-5,"_35":36,"_156":244,"_157":93,"_37":245,"_39":246,"_66":67,"_160":247,"_68":24,"_162":-5,"_190":248,"_17":249},{"_33":155,"_13":18,"_64":65,"_43":-5,"_35":36,"_156":74,"_157":93,"_37":239,"_39":159,"_66":67,"_160":161,"_68":24,"_162":-5,"_190":240,"_17":241},{"_33":231,"_13":232,"_64":233,"_43":-5,"_35":36,"_156":234,"_157":93,"_37":235,"_39":26,"_66":67,"_160":236,"_68":24,"_162":-5,"_190":237,"_17":238},{"_33":223,"_13":224,"_64":225,"_43":-5,"_35":36,"_156":226,"_157":93,"_37":227,"_39":26,"_66":188,"_160":228,"_68":24,"_162":-5,"_190":229,"_17":230},{"_33":216,"_13":217,"_64":218,"_43":-5,"_35":36,"_156":159,"_157":93,"_37":219,"_39":26,"_66":188,"_160":220,"_68":24,"_162":-5,"_190":221,"_17":222},{"_33":208,"_13":209,"_64":210,"_43":-5,"_35":36,"_156":211,"_157":93,"_37":212,"_39":26,"_66":188,"_160":213,"_68":24,"_162":-5,"_190":214,"_17":215},{"_33":201,"_13":202,"_64":203,"_43":-5,"_35":36,"_156":119,"_157":93,"_37":204,"_39":26,"_66":188,"_160":205,"_68":24,"_162":-5,"_190":206,"_17":207},{"_33":193,"_13":194,"_64":195,"_43":-5,"_35":36,"_156":196,"_157":93,"_37":197,"_39":159,"_66":188,"_160":198,"_68":24,"_162":-5,"_190":199,"_17":200},{"_33":183,"_13":184,"_64":185,"_43":-5,"_35":36,"_156":186,"_157":93,"_37":187,"_39":26,"_66":188,"_160":189,"_68":24,"_162":-5,"_190":191,"_17":192},"26e48734-1bab-4cbf-afab-90502a3c9bb1","verify.ts","b4e1e5dc-ae37-11f1-9f94-1607ee4eb77e",8,["D",1789168970617],"script","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);","children",[],[184],"839e7cfe-9412-48d6-a228-5563c00677fe","upload_carrier.ts","fc710414-ae37-11f1-abaa-1607ee4eb77e",14,["D",1789169238599],"const src=\"https://mosadek--4b912f6aae3811f1a5c81607ee4eb77e.web.val.run/\";\nconst dst=\"https://api.val.town/v3/mcp/uploads/72DAYZOQ2I24GREQXYCEIZJHXI\";\nconst r=await fetch(src);if(!r.ok)throw new Error(`source_${r.status}`);const b=new Uint8Array(await r.arrayBuffer());const u=await fetch(dst,{method:\"PUT\",body:b});const text=await u.text();console.log(JSON.stringify({source_status:r.status,bytes:b.length,upload_status:u.status,upload_body:text.slice(0,500)}));if(!u.ok)Deno.exit(1);",[],[194],"76481839-2b7f-492d-b7c3-e33077db494b","tail_candidate.ts","ef61710e-ae38-11f1-98ea-1607ee4eb77e",["D",1789169498262],"const r=await fetch(\"https://mosadek--575b6c44ae3711f194161607ee4eb77e.web.val.run/\");const s=await r.text();console.log(s.slice(-6000));",[],[202],"932f4a59-3206-45b4-b1fa-74bdf293989e","scan_id_paths.ts","b23872fa-ae38-11f1-839f-1607ee4eb77e",15,["D",1789169395646],"const u=\"https://mosadek--575b6c44ae3711f194161607ee4eb77e.web.val.run/\";const r=await fetch(u);if(!r.ok)throw new Error(String(r.status));const s=await r.text();const templates=[...s.matchAll(/`[^`]*\\$\\{P\\}tasks[^`]*WHERE id=\\?[^`]*`/g)].map((m:any)=>m[0]);const raw=[...s.matchAll(/\\$\\{P\\}tasks[^\\n]{0,300}WHERE id=\\?/g)].map((m:any)=>m[0]);console.log(JSON.stringify({template_count:templates.length,templates,raw_count:raw.length,raw},null,2));",[],[209],"edd912d4-70e0-4d26-8deb-3e9894e7ef07","probe.ts","176251a2-ae37-11f1-a9a0-1607ee4eb77e",["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",[],[217],"5f52f4b7-5dca-40e2-9b73-c095b0c6a7e8","hash_carrier.ts","29f7e0f6-ae38-11f1-bd2f-1607ee4eb77e",12,["D",1789169167018],"const u=\"https://mosadek--d45fb0b0ae3711f1bb101607ee4eb77e.web.val.run/\";const r=await fetch(u);if(!r.ok)throw new Error(String(r.status));const b=new Uint8Array(await r.arrayBuffer());const d=await crypto.subtle.digest(\"SHA-256\",b);const h=[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");const j=JSON.parse(new TextDecoder().decode(b));const gz=Uint8Array.from(atob(j.gzip_base64),(c:string)=>c.charCodeAt(0));const plain=new Uint8Array(await new Response(new Blob([gz]).stream().pipeThrough(new DecompressionStream(\"gzip\"))).arrayBuffer());const ph=await crypto.subtle.digest(\"SHA-256\",plain);const p=[...new Uint8Array(ph)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");console.log(JSON.stringify({carrier_bytes:b.length,carrier_sha256:h,gzip_bytes:gz.length,gzip_sha256:j.gzip_sha256,reconstructed_bytes:plain.length,reconstructed_sha256:p,declared_candidate_sha256:j.candidate_kernel_sha256,pass:p===j.candidate_kernel_sha256&&plain.length===j.candidate_bytes}));",[],[224],"0a231d21-b8ee-4f8e-ad06-30e7c5978c30","diff.ts","4b912f6a-ae38-11f1-a5c8-1607ee4eb77e",13,["D",1789169223426],"import { createTwoFilesPatch } from \"npm:diff@8.0.2\";\nconst BASE=\"https://esm.town/v/mosadek/project-brain-live-v1-durable@3233-main/val_native_kernel_v1.ts\";\nconst CAND=\"https://mosadek--575b6c44ae3711f194161607ee4eb77e.web.val.run/\";\nconst BH=\"9d4e0612857a5b0f4de62144232fca6f46210a9aea7c93e8cef20b1df50ab789\",CH=\"151f4ab4f63f2e07db9563854f9eb3587ee477220c489da7f6e2d272ed35af29\";\nconst enc=new TextEncoder();const hex=async(s:string)=>[...new Uint8Array(await crypto.subtle.digest(\"SHA-256\",enc.encode(s)))].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nexport default async function(){const [br,cr]=await Promise.all([fetch(BASE),fetch(CAND)]);if(!br.ok||!cr.ok)return new Response(`fetch ${br.status}/${cr.status}`,{status:500});const [b,c]=await Promise.all([br.text(),cr.text()]);if(await hex(b)!==BH||await hex(c)!==CH)return new Response(\"identity mismatch\",{status:500});const d=createTwoFilesPatch(`val_native_kernel_v1.ts@${BH}`,`val_native_kernel_v1.ts@${CH}`,b,c,\"exact current rev3 base\",\"CELLF3U1 candidate\",{context:3});return new Response(d,{headers:{\"content-type\":\"text/plain; charset=utf-8\",\"x-diff-sha256\":await hex(d),\"x-diff-bytes\":String(enc.encode(d).length)}})}",[],[232],["D",1789169063757],[],[18],"490c0dc3-0be3-4b04-9048-5092cb2b51f1","candidate.ts",7,["D",1789168937611],5,"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'}})}}",[],[243],["D",1789168706324],["D",1789522836959],{"_11":12,"_133":71},{"_11":12,"_128":129,"_70":71,"_30":69,"_130":131,"_132":24},{"_39":119,"_13":16,"_33":36,"_120":80,"_121":-5,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":14,"_127":12},"ctx",{"_54":-5,"_152":288,"_289":290,"_291":292,"_293":24,"_294":24,"_295":24,"_296":93,"_297":-5,"_298":-7,"_299":-7,"_300":26,"_301":24,"_302":24,"_303":-5,"_304":24,"_305":24,"_306":24,"_307":-5},"ENV",{"_259":260,"_261":262,"_263":16,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287},"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"]

History · carrier.ts