[{"_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","bridge_cp_rb_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/bridge_cp_rb_v8m3.ts","extension","id","56c89f07-e158-4cf9-be07-31ba040db306","fileId","01a07cbd-7cd7-7031-8858-e053d464ef66","parentId","branchId","b0991504-8a60-44de-bc55-794f567855ab","branchVersion",1,"latest",true,"createdAt",["D",1788799187967],"version",0,"fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { normalizeBootAgentPayload } from \"./boot_gate_m8c2.ts\";\nimport { prepareAtomicCoalescePlan } from \"./brain_bridge_readonly_coalesce_v4.ts\";\n\n// Inlined control-plane CLI guard; preserves current boot-agent and readonly-coalesce paths.\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 normalizeBootAgentPayload(q,MAX_JOB_TIMEOUT);\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\n const resultJson=success?JSON.stringify(q.result??null):null;\n const plan=success&&resultJson ? prepareAtomicCoalescePlan(resultJson,id,worker,true) : null;\n let state:string;\n let coalescedIds:string[]=[];\n\n if(plan){\n const cr:any=await sqlite.execute({sql:plan.sql,args:plan.args});\n const ids=(cr.rows||[]).map((x:any)=>String(x.id));\n if(!ids.includes(id))return json({ok:false,error:\"LEASE_MISMATCH_OR_EXPIRED\"},409);\n state=\"COMPLETE\";\n coalescedIds=ids.filter((x:string)=>x!==id);\n }else{\n const r:any=await sqlite.execute({\n sql:resultSql(),\n args:[success?\"COMPLETE\":\"FAILED\",resultJson,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 state=String(r.rows[0].state);\n }\n\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,worker_id:worker,instance_id:instance,\n coalesced_count:coalescedIds.length,coalesced_ids:coalescedIds});\n }\n return json({ok:false,error:\"NOT_FOUND\"},404);\n}\n","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"]