[{"_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-cohort-v3-p0-test-m1","path","tmp_hash_control_plane_v8m3.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":36,"_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-cohort-v3-p0-test-m1/code/tmp_hash_control_plane_v8m3.ts","extension","id","61e75404-0123-4921-b67a-37918b43990f","fileId","01a07cbd-7cd9-720b-89cd-f30935cd8a2a","parentId","branchId","b0991504-8a60-44de-bc55-794f567855ab","branchVersion",1,"latest",true,"createdAt",["D",1788799187967],"version",0,"fileType","script","content","const files={\"worker_sc\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\n\\n// Inlined control-plane CLI guard; no production dependency outside this worker.\\nexport type GuardResult = {ok:true}|{ok:false,error:string};\\ntype OptSpec = {required?:boolean,type?:\\\"string\\\"|\\\"int\\\"|\\\"float\\\"|\\\"json\\\",choices?:string[]};\\ntype CmdSpec = {positionals:number,opts:Record};\\n\\nconst S:Record={\\n \\\"status\\\":{positionals:0,opts:{}},\\n \\\"verify-chain\\\":{positionals:0,opts:{}},\\n \\\"verify-claim-graph\\\":{positionals:0,opts:{}},\\n \\\"recover-stale\\\":{positionals:0,opts:{}},\\n \\\"register-agent\\\":{positionals:1,opts:{\\n \\\"--workstream\\\":{required:true},\\\"--role\\\":{},\\\"--type\\\":{},\\n \\\"--parent\\\":{},\\\"--capabilities\\\":{type:\\\"json\\\"}\\n }},\\n \\\"ensure-task\\\":{positionals:1,opts:{\\n \\\"--workstream\\\":{required:true},\\\"--priority\\\":{type:\\\"float\\\"},\\\"--depends\\\":{type:\\\"json\\\"},\\n \\\"--requires\\\":{type:\\\"json\\\"},\\\"--writes\\\":{type:\\\"json\\\"},\\\"--guards\\\":{type:\\\"json\\\"},\\n \\\"--dedupe-key\\\":{required:true},\\\"--success\\\":{required:true},\\\"--value\\\":{required:true},\\n \\\"--context\\\":{type:\\\"json\\\"},\\\"--agent\\\":{}\\n }},\\n \\\"delegate-task\\\":{positionals:1,opts:{\\n \\\"--workstream\\\":{required:true},\\\"--parent-agent\\\":{required:true},\\\"--child-agent\\\":{required:true},\\n \\\"--priority\\\":{type:\\\"float\\\"},\\\"--depends\\\":{type:\\\"json\\\"},\\\"--requires\\\":{type:\\\"json\\\"},\\n \\\"--writes\\\":{type:\\\"json\\\"},\\\"--guards\\\":{type:\\\"json\\\"},\\\"--dedupe-key\\\":{required:true},\\n \\\"--success\\\":{required:true},\\\"--value\\\":{required:true},\\\"--context\\\":{type:\\\"json\\\"}\\n }},\\n \\\"claim\\\":{positionals:0,opts:{\\n \\\"--agent\\\":{required:true},\\\"--mode\\\":{choices:[\\\"INTERACTIVE\\\",\\\"PROCESS\\\"]},\\\"--lease-seconds\\\":{type:\\\"int\\\"}\\n }},\\n \\\"renew-lease\\\":{positionals:0,opts:{\\n \\\"--agent\\\":{required:true},\\\"--task\\\":{required:true},\\\"--seconds\\\":{type:\\\"int\\\"}\\n }},\\n \\\"commit\\\":{positionals:0,opts:{\\n \\\"--agent\\\":{required:true},\\\"--task\\\":{required:true},\\\"--expected-generation\\\":{type:\\\"int\\\"},\\n \\\"--expected-workstream-generation\\\":{type:\\\"int\\\"},\\\"--state\\\":{choices:[\\\"COMPLETE\\\",\\\"INVALID\\\",\\\"BLOCKED\\\"]},\\n \\\"--payload\\\":{required:true,type:\\\"json\\\"}\\n }},\\n \\\"checkpoint\\\":{positionals:0,opts:{\\n \\\"--config\\\":{},\\\"--attempts\\\":{type:\\\"int\\\"},\\\"--timeout\\\":{type:\\\"int\\\"}\\n }},\\n \\\"add-claim\\\":{positionals:1,opts:{\\n \\\"--workstream\\\":{required:true},\\\"--status\\\":{choices:[\\\"VERIFIED\\\",\\\"CANDIDATE\\\",\\\"HYPOTHESIS\\\"]},\\n \\\"--statement\\\":{required:true,type:\\\"json\\\"},\\\"--evidence\\\":{type:\\\"json\\\"},\\\"--depends\\\":{type:\\\"json\\\"},\\\"--agent\\\":{}\\n }},\\n \\\"invalidate-claim\\\":{positionals:1,opts:{\\n \\\"--reason\\\":{required:true},\\\"--agent\\\":{}\\n }},\\n \\\"supersede-task-context\\\":{positionals:0,opts:{\\n \\\"--task\\\":{required:true},\\\"--agent\\\":{required:true},\\\"--expected-workstream-generation\\\":{required:true,type:\\\"int\\\"},\\n \\\"--new-context\\\":{required:true,type:\\\"json\\\"},\\\"--reason\\\":{required:true},\\\"--evidence\\\":{type:\\\"json\\\"}\\n }},\\n \\\"migrate-task-invariants\\\":{positionals:0,opts:{\\n \\\"--task\\\":{required:true},\\\"--agent\\\":{required:true},\\\"--expected-workstream-generation\\\":{required:true,type:\\\"int\\\"},\\n \\\"--dedupe-key\\\":{required:true},\\\"--writes\\\":{type:\\\"json\\\"},\\\"--guards\\\":{type:\\\"json\\\"},\\n \\\"--reason\\\":{required:true},\\\"--evidence\\\":{type:\\\"json\\\"}\\n }},\\n \\\"reconcile-causal-blocks\\\":{positionals:0,opts:{\\n \\\"--workstream\\\":{required:true},\\\"--agent\\\":{required:true},\\\"--expected-workstream-generation\\\":{required:true,type:\\\"int\\\"}\\n }}\\n};\\n\\nfunction validValue(spec:OptSpec,v:string):boolean{\\n if(spec.choices && !spec.choices.includes(v)) return false;\\n if(spec.type===\\\"int\\\") return /^-?\\\\d+$/.test(v);\\n if(spec.type===\\\"float\\\") return v.trim()!==\\\"\\\" && Number.isFinite(Number(v));\\n if(spec.type===\\\"json\\\"){ try{JSON.parse(v);return true}catch{return false} }\\n return true;\\n}\\n\\nexport function validateBrainArgs(args:string[]):GuardResult{\\n if(!Array.isArray(args)||args.length<1||args.some(x=>typeof x!==\\\"string\\\")) return {ok:false,error:\\\"ARGS_INVALID\\\"};\\n const cmd=args[0],spec=S[cmd];\\n if(!spec) return {ok:false,error:\\\"SUBCOMMAND_NOT_ALLOWED\\\"};\\n // Canonical argparse treats an exclusive --help request as a successful diagnostic exit.\\n // Preserve that observed compatibility without allowing --help to mask extra arguments.\\n if(args.length===2 && args[1]===\\\"--help\\\") return {ok:true};\\n const rest=args.slice(1);\\n const pos:string[]=[]; const seen=new Map();\\n for(let i=0;i=rest.length || rest[i+1].startsWith(\\\"--\\\")) return {ok:false,error:\\\"OPTION_VALUE_MISSING:\\\"+t};\\n const v=rest[i+1];\\n if(!validValue(os,v)) return {ok:false,error:\\\"OPTION_VALUE_INVALID:\\\"+t};\\n seen.set(t,v); i+=2;\\n }else{ pos.push(t); i++; }\\n }\\n if(pos.length!==spec.positionals) return {ok:false,error:\\\"POSITIONAL_COUNT_INVALID\\\"};\\n for(const [k,v] of Object.entries(spec.opts)) if(v.required && !seen.has(k)) return {ok:false,error:\\\"REQUIRED_OPTION_MISSING:\\\"+k};\\n return {ok:true};\\n}\\n\\n\\nconst WORKER_TOKEN = Deno.env.get(\\\"BRAIN_BRIDGE_WORKER_TOKEN\\\") || \\\"\\\";\\nconst JOB_TABLE = \\\"brain_bridge_jobs\\\";\\nexport const STALE_SECONDS = 90;\\nexport const DEAD_SECONDS = 180;\\nexport const PRIORITY_CAP = 1_000_000_000;\\nexport const MAX_JOB_TIMEOUT = 120;\\nexport const LEASE_SECONDS = 180;\\nexport const MAX_READ_BYTES = 200_000;\\n\\nexport const SUPPORTED_BRAIN_COMMANDS = [\\n \\\"status\\\",\\n \\\"verify-chain\\\",\\n \\\"verify-claim-graph\\\",\\n \\\"register-agent\\\",\\n \\\"ensure-task\\\",\\n \\\"delegate-task\\\",\\n \\\"claim\\\",\\n \\\"renew-lease\\\",\\n \\\"commit\\\",\\n \\\"checkpoint\\\",\\n \\\"add-claim\\\",\\n \\\"invalidate-claim\\\",\\n \\\"supersede-task-context\\\",\\n \\\"migrate-task-invariants\\\",\\n \\\"reconcile-causal-blocks\\\",\\n \\\"recover-stale\\\"\\n] as const;\\nconst SUPPORTED = new Set(SUPPORTED_BRAIN_COMMANDS);\\n\\nfunction json(v:unknown,status=200){return Response.json(v,{status});}\\nfunction tableName(table:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table))throw new Error(\\\"BAD_TABLE\\\");return table;}\\n\\nexport function classifyWorkerAge(ageSeconds:number|null){\\n if(ageSeconds===null || !Number.isFinite(ageSeconds)) return {state:\\\"UNKNOWN\\\",reason:\\\"NO_WORKER_HEARTBEAT\\\"};\\n if(ageSeconds<=STALE_SECONDS) return {state:\\\"HEALTHY\\\",reason:\\\"RECENT_WORKER_POLL\\\"};\\n if(ageSeconds<=DEAD_SECONDS) return {state:\\\"DEGRADED\\\",reason:\\\"WORKER_POLL_STALE\\\"};\\n return {state:\\\"DOWN\\\",reason:\\\"WORKER_POLL_DEAD\\\"};\\n}\\nexport function effectivePriority(x:number){if(!Number.isFinite(x))return 0;return Math.min(x,PRIORITY_CAP);}\\nexport function healthHttpStatus(workerState:string,duplicateActiveLeases:number,expiredLeases:number){\\n return workerState===\\\"HEALTHY\\\" && duplicateActiveLeases===0 && expiredLeases===0 ? 200 : 503;\\n}\\nexport function activeLeaseDecision(rows:any[]){\\n if(rows.length>1)return {kind:\\\"conflict\\\" as const,count:rows.length};\\n if(rows[0])return {kind:\\\"busy\\\" as const,active_job_id:String(rows[0].id),lease_expires_at:rows[0].lease_expires_at};\\n return {kind:\\\"free\\\" as const};\\n}\\n\\nexport function recoverExpiredSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state='READY',lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at <= datetime('now')`;\\n}\\nexport function activeLeaseSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `SELECT id,op,payload_json,priority,lease_expires_at\\n FROM ${table}\\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\\n ORDER BY lease_expires_at,id LIMIT 2`;\\n}\\nexport function leaseOneSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),updated_at=datetime('now')\\n WHERE id=(\\n SELECT j.id FROM ${table} j\\n WHERE j.state='READY'\\n AND NOT EXISTS(\\n SELECT 1 FROM ${table} x\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\n )\\n ORDER BY\\n CASE\\n WHEN j.op='brain' AND json_valid(j.payload_json)=1 THEN\\n CASE\\n WHEN json_type(j.payload_json,'$.args')='array'\\n AND json_array_length(json_extract(j.payload_json,'$.args'))=1\\n AND json_extract(j.payload_json,'$.args[0]')='recover-stale'\\n AND json_type(j.payload_json,'$.timeout')='integer'\\n AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2\\n THEN 0 ELSE 1\\n END\\n ELSE 1\\n END ASC,\\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE j.priority END DESC,\\n j.created_at,j.id\\n LIMIT 1\\n )\\n RETURNING id,op,payload_json,priority,lease_expires_at`;\\n}\\nexport function resultSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\\n RETURNING id,state`;\\n}\\n\\nexport type DispatchResult=\\n | {ok:true;payload_json:string}\\n | {ok:false;error:string};\\n\\nfunction exactKeys(q:any, expected:string[]){\\n const got=Object.keys(q).sort();\\n const want=[...expected].sort();\\n return got.length===want.length && got.every((k,i)=>k===want[i]);\\n}\\n\\nexport function normalizeDispatch(op:string,payloadJson:string):DispatchResult{\\n let q:any;try{q=JSON.parse(payloadJson)}catch{return {ok:false,error:\\\"PAYLOAD_JSON_INVALID\\\"}}\\n if(!q || typeof q!==\\\"object\\\" || Array.isArray(q))return {ok:false,error:\\\"PAYLOAD_OBJECT_REQUIRED\\\"};\\n\\n if(op===\\\"brain\\\"){\\n if(!exactKeys(q,[\\\"args\\\",\\\"timeout\\\"]))return {ok:false,error:\\\"BRAIN_PAYLOAD_SCHEMA_NOT_CLOSED\\\"};\\n if(!Array.isArray(q.args) || q.args.length<1 || q.args.some((x:any)=>typeof x!==\\\"string\\\"))return {ok:false,error:\\\"BRAIN_ARGS_INVALID\\\"};\\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>MAX_JOB_TIMEOUT)return {ok:false,error:\\\"BRAIN_TIMEOUT_INVALID\\\"};\\n const cmd=q.args[0];\\n if(cmd===\\\"boot\\\")return {ok:false,error:\\\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\\\"};\\n if(cmd===\\\"boot-agent\\\")return {ok:false,error:\\\"RAW_BOOT_AGENT_NOT_BRIDGE_COMMAND\\\"};\\n if(cmd===\\\"recover-leases\\\")return {ok:false,error:\\\"RECOVER_LEASE_ALIAS_NOT_AVAILABLE_ON_CURRENT_EXECUTOR\\\"};\\n if(cmd===\\\"recover-stale\\\" && q.args.length!==1)return {ok:false,error:\\\"RECOVER_STALE_ARGS_INVALID\\\"};\\n if(!SUPPORTED.has(cmd))return {ok:false,error:\\\"BRAIN_SUBCOMMAND_NOT_ALLOWED\\\"};\\n const syntax=validateBrainArgs(q.args);\\n if(!syntax.ok)return {ok:false,error:\\\"BRAIN_CLI_SCHEMA_REJECTED:\\\"+syntax.error};\\n return {ok:true,payload_json:JSON.stringify({args:q.args,timeout:q.timeout})};\\n }\\n\\n if(op===\\\"read_text\\\"){\\n if(!exactKeys(q,[\\\"path\\\",\\\"max_bytes\\\"]))return {ok:false,error:\\\"READ_TEXT_SCHEMA_NOT_CLOSED\\\"};\\n if(typeof q.path!==\\\"string\\\")return {ok:false,error:\\\"READ_TEXT_PATH_REQUIRED\\\"};\\n if(q.path.includes(\\\"\\\\0\\\") || q.path.includes(\\\"\\\\\\\\\\\") || q.path.split(\\\"/\\\").some((s:string)=>s===\\\".\\\" || s===\\\"..\\\")){\\n return {ok:false,error:\\\"READ_TEXT_TRAVERSAL_REJECTED\\\"};\\n }\\n const artifactFile=q.path.startsWith(\\\"/brain/artifacts/\\\") && q.path.length>\\\"/brain/artifacts/\\\".length && !q.path.endsWith(\\\"/\\\");\\n if(!(q.path===\\\"/brain/JOIN_PROTOCOL.md\\\" || artifactFile))return {ok:false,error:\\\"READ_TEXT_PATH_FORBIDDEN\\\"};\\n if(!Number.isInteger(q.max_bytes) || q.max_bytes<1 || q.max_bytes>MAX_READ_BYTES)return {ok:false,error:\\\"READ_TEXT_MAX_BYTES_INVALID\\\"};\\n return {ok:true,payload_json:JSON.stringify({path:q.path,max_bytes:q.max_bytes})};\\n }\\n return {ok:false,error:\\\"OP_UNSUPPORTED\\\"};\\n}\\n\\nasync function ensureTables(){\\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS brain_bridge_workers_v4 (\\n worker_id TEXT NOT NULL,\\n instance_id TEXT NOT NULL,\\n first_seen_at TEXT NOT NULL,\\n last_poll_at TEXT,\\n last_result_at TEXT,\\n lease_count INTEGER NOT NULL DEFAULT 0,\\n result_count INTEGER NOT NULL DEFAULT 0,\\n updated_at TEXT NOT NULL,\\n PRIMARY KEY(worker_id,instance_id)\\n )`);\\n}\\nfunction instanceOf(q:any){const v=String(q?.instance_id||\\\"\\\").trim();return v||\\\"LEGACY_UNATTESTED_INSTANCE\\\";}\\n\\nasync function workerHealth(){\\n await ensureTables();\\n const wr:any=await sqlite.execute(`\\n SELECT worker_id,instance_id,last_poll_at,last_result_at,lease_count,result_count,\\n CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) AS poll_age_seconds\\n FROM brain_bridge_workers_v4\\n ORDER BY last_poll_at DESC LIMIT 1`);\\n const w=wr.rows?.[0]||null;\\n const qc:any=await sqlite.execute({\\n sql:`SELECT\\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\\n SUM(CASE WHEN state='LEASED' THEN 1 ELSE 0 END) AS leased_count,\\n SUM(CASE WHEN state='LEASED' AND lease_expires_at <= datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\\n SUM(CASE WHEN state='READY' AND priority > ? THEN 1 ELSE 0 END) AS overcap_ready_count,\\n MIN(CASE WHEN state='READY' THEN created_at END) AS oldest_ready_at,\\n MIN(CASE WHEN state='LEASED' THEN lease_expires_at END) AS earliest_lease_expiry\\n FROM brain_bridge_jobs`,\\n args:[PRIORITY_CAP]\\n });\\n const dup:any=await sqlite.execute(`\\n SELECT COUNT(*) AS duplicate_worker_count FROM (\\n SELECT lease_owner FROM brain_bridge_jobs\\n WHERE state='LEASED' AND lease_expires_at > datetime('now') AND lease_owner IS NOT NULL\\n GROUP BY lease_owner HAVING COUNT(*) > 1\\n )`);\\n const q=qc.rows?.[0]||{};\\n const duplicateActiveLeases=Number(dup.rows?.[0]?.duplicate_worker_count||0);\\n const cls=classifyWorkerAge(w?Number(w.poll_age_seconds):null);\\n const expiredLeases=Number(q.expired_lease_count||0);\\n const status=healthHttpStatus(cls.state,duplicateActiveLeases,expiredLeases);\\n return {status,body:{\\n endpoint_ok:true,\\n service:\\\"brain-bridge-worker-v5-rebased-candidate\\\",\\n worker:w,\\n worker_state:cls.state,\\n worker_reason:cls.reason,\\n instance_identity_available:w ? w.instance_id!==\\\"LEGACY_UNATTESTED_INSTANCE\\\" : false,\\n duplicate_active_worker_leases:duplicateActiveLeases,\\n queue:q,\\n transport_priority_cap:PRIORITY_CAP,\\n max_brain_timeout_seconds:MAX_JOB_TIMEOUT,\\n queue_lease_seconds:LEASE_SECONDS,\\n selection_policy:\\\"RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT\\\",\\n atomic_single_flight:true,\\n fail_closed_http_status:status\\n }};\\n}\\n\\nasync function rejectInvalidLease(worker:string,id:string,error:string){\\n await sqlite.execute({\\n sql:`UPDATE ${JOB_TABLE}\\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\\n args:[JSON.stringify({classification:\\\"BRIDGE_DISPATCH_REJECTED\\\",error}),id,worker]\\n });\\n}\\n\\nexport default async function(req:Request):Promise{\\n const u=new URL(req.url);\\n if(req.method===\\\"GET\\\" && u.pathname.endsWith(\\\"/health\\\")){\\n const h=await workerHealth();return json(h.body,h.status);\\n }\\n if(req.method!==\\\"POST\\\")return json({ok:false,error:\\\"METHOD\\\"},405);\\n const supplied=req.headers.get(\\\"x-brain-worker-token\\\")||\\\"\\\";\\n if(!WORKER_TOKEN || supplied!==WORKER_TOKEN)return json({ok:false,error:\\\"UNAUTHORIZED\\\"},401);\\n let q:any;try{q=await req.json()}catch{return json({ok:false,error:\\\"BAD_JSON\\\"},400)}\\n await ensureTables();\\n\\n if(u.pathname.endsWith(\\\"/poll\\\")){\\n const worker=String(q.worker_id||\\\"\\\").trim();\\n if(!worker || worker.length>128)return json({ok:false,error:\\\"WORKER_REQUIRED\\\"},400);\\n const instance=instanceOf(q);\\n await sqlite.execute({\\n sql:`INSERT INTO brain_bridge_workers_v4(worker_id,instance_id,first_seen_at,last_poll_at,updated_at)\\n VALUES(?,?,datetime('now'),datetime('now'),datetime('now'))\\n ON CONFLICT(worker_id,instance_id) DO UPDATE SET last_poll_at=datetime('now'),updated_at=datetime('now')`,\\n args:[worker,instance]\\n });\\n\\n await sqlite.execute(recoverExpiredSql());\\n const ar:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\\n const before=activeLeaseDecision(ar.rows||[]);\\n if(before.kind===\\\"conflict\\\")return json({ok:false,error:\\\"MULTIPLE_ACTIVE_LEASES\\\",worker_id:worker,count:before.count},409);\\n if(before.kind===\\\"busy\\\")return json({ok:true,job:null,reason:\\\"ACTIVE_LEASE_EXISTS\\\",active_lease:{id:before.active_job_id,lease_expires_at:before.lease_expires_at},worker_id:worker,instance_id:instance});\\n\\n const r:any=await sqlite.execute({sql:leaseOneSql(),args:[worker,worker]});\\n if(!r.rows?.[0]){\\n return json({ok:true,job:null,reason:\\\"NO_READY_JOB_OR_RACED_ACTIVE_LEASE\\\",worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP});\\n }\\n\\n const row=r.rows[0];\\n const normalized=normalizeDispatch(String(row.op),String(row.payload_json));\\n if(!normalized.ok){\\n await rejectInvalidLease(worker,String(row.id),normalized.error);\\n return json({ok:true,job:null,reason:\\\"DISPATCH_REJECTED\\\",rejected_job:String(row.id),dispatch_error:normalized.error,worker_id:worker,instance_id:instance});\\n }\\n\\n await sqlite.execute({\\n sql:\\\"UPDATE brain_bridge_workers_v4 SET lease_count=lease_count+1,updated_at=datetime('now') WHERE worker_id=? AND instance_id=?\\\",\\n args:[worker,instance]\\n });\\n return json({ok:true,job:{...row,payload_json:normalized.payload_json},worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP,lease_seconds:LEASE_SECONDS});\\n }\\n\\n if(u.pathname.endsWith(\\\"/result\\\")){\\n const worker=String(q.worker_id||\\\"\\\").trim(),id=String(q.id||\\\"\\\").trim(),success=q.success===true;\\n const instance=instanceOf(q);\\n if(!worker||!id)return json({ok:false,error:\\\"BAD_RESULT_ID\\\"},400);\\n const r:any=await sqlite.execute({\\n sql:resultSql(),\\n args:[success?\\\"COMPLETE\\\":\\\"FAILED\\\",success?JSON.stringify(q.result??null):null,success?null:JSON.stringify(q.error??null),id,worker]\\n });\\n if(!r.rows?.length)return json({ok:false,error:\\\"LEASE_MISMATCH_OR_EXPIRED\\\"},409);\\n await sqlite.execute({\\n sql:\\\"UPDATE brain_bridge_workers_v4 SET last_result_at=datetime('now'),result_count=result_count+1,updated_at=datetime('now') WHERE worker_id=? AND instance_id=?\\\",\\n args:[worker,instance]\\n });\\n return json({ok:true,id,state:r.rows[0].state,worker_id:worker,instance_id:instance});\\n }\\n return json({ok:false,error:\\\"NOT_FOUND\\\"},404);\\n}\\n\",\"replay_sc\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { normalizeDispatch,SUPPORTED_BRAIN_COMMANDS } from \\\"./bridge_cp_sc_v8m3.ts\\\";\\nconst supported=new Set(SUPPORTED_BRAIN_COMMANDS as readonly string[]);\\nfunction cmdOf(p:string){try{const q=JSON.parse(p);return Array.isArray(q?.args)?String(q.args[0]??\\\"\\\"):null}catch{return null}}\\n\\nconst goodQ:any=await sqlite.execute(`\\n SELECT id,op,payload_json,updated_at FROM brain_bridge_jobs\\n WHERE state='COMPLETE' AND op='brain'\\n ORDER BY updated_at DESC LIMIT 800`);\\nconst good=(goodQ.rows||[]).filter((x:any)=>supported.has(cmdOf(String(x.payload_json))||\\\"\\\"));\\nconst goodRejected=good.map((x:any)=>({id:x.id,cmd:cmdOf(String(x.payload_json)),d:normalizeDispatch(String(x.op),String(x.payload_json))}))\\n .filter((x:any)=>!x.d.ok);\\n\\nconst badQ:any=await sqlite.execute(`\\n SELECT id,op,payload_json,error_json,updated_at FROM brain_bridge_jobs\\n WHERE state='FAILED' AND op='brain'\\n ORDER BY updated_at DESC LIMIT 600`);\\nfunction isCliOrDispatchFailure(x:any){\\n let e:any;try{e=JSON.parse(String(x.error_json||\\\"{}\\\"))}catch{return false}\\n if(e?.classification===\\\"BRIDGE_DISPATCH_REJECTED\\\") return true;\\n if(e?.classification===\\\"TRANSPORT_QUEUE_QUARANTINE\\\"){\\n return !!e.invalid_argument || /syntactically invalid|parser|argument/i.test(String(e.reason||\\\"\\\"));\\n }\\n const s=String(e?.stderr||\\\"\\\");\\n return Number(e?.returncode)===2 && /brain\\\\.py/.test(s) &&\\n /(unrecognized arguments|following arguments are required|argument cmd: invalid choice)/.test(s);\\n}\\nconst bad=(badQ.rows||[]).filter(isCliOrDispatchFailure);\\nconst badAccepted=bad.map((x:any)=>({id:x.id,cmd:cmdOf(String(x.payload_json)),d:normalizeDispatch(String(x.op),String(x.payload_json))}))\\n .filter((x:any)=>x.d.ok);\\n\\nconsole.log(JSON.stringify({\\n schema:\\\"BRAIN_CP_TWO_SIDED_QUEUE_REPLAY_V8M3\\\",\\n successful_supported_sample:good.length,\\n successful_rejected:goodRejected.length,\\n successful_rejected_examples:goodRejected.slice(0,20),\\n failed_sample:bad.length,\\n failed_would_prehost_accept:badAccepted.length,\\n failed_accepted_examples:badAccepted.slice(0,20),\\n pass:good.length>0&&bad.length>0&&goodRejected.length===0&&badAccepted.length===0,\\n production_mutation:false,direct_sprites:false,human_authority_approval:false\\n},null,2));\\nif(!good.length||!bad.length||goodRejected.length||badAccepted.length)throw new Error(\\\"TWO_SIDED_QUEUE_REPLAY_FAIL\\\");\\n\"};const e=new TextEncoder();const out:any={};for(const [k,v] of Object.entries(files)){const b=e.encode(v as string);const h=await crypto.subtle.digest(\"SHA-256\",b);out[k]={bytes:b.length,sha256:[...new Uint8Array(h)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")};}console.log(JSON.stringify(out,null,2));","deleted",false,"label",[14],"d9af2f28-3492-4111-98aa-ad7443cd8663",["D",1788799187967],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Isolated V3 cohort P0 repair test","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a07cbd-7cda-7441-ac3e-cf192087c1d5","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","d9af2f283492411198aaad7443cd8663","tursoHostname","d9af2f283492411198aaad7443cd8663-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494036282],"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",37,"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":36,"_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"]