[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","r3a4-82c51675-shadow","path","admission_merge_n1/worker_fair_if_failclosed_a71_candidate.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":26,"_61":34,"_62":-5,"_63":-5,"_64":38,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/mosadek/r3a4-82c51675-shadow/code/admission_merge_n1/worker_fair_if_failclosed_a71_candidate.ts","extension","id","e48c99d2-ecc4-4570-b5ce-eb1a6c7e8e85","worker_fair_if_failclosed_a71_candidate.ts","fileId","01a09317-8b36-757f-b18a-5477cfa017af","parentId","01a09317-8b36-757f-b18a-5dbb66fe8af6","branchId","667edb8b-aaf6-4374-bf1c-2397f495e068","branchVersion",1,"latest",true,"createdAt",["D",1789174188714],"version",0,"fileType","http","content","import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\n\nconst scopedToken=Deno.env.get(\"VAL_TOWN_API_KEY\")||\"\";\nconst nativeFetch=async(input:any,init?:any):Promise=>{\n if(typeof input===\"string\" || input instanceof URL) return await globalThis.fetch(input,init);\n const method=String(input?.method||init?.method||\"GET\");\n const headers=new Headers();\n const src=input?.headers||init?.headers;\n if(src?.forEach) src.forEach((v:string,k:string)=>headers.set(k,v));\n else if(src) for(const [k,v] of Object.entries(src)) headers.set(k,String(v));\n let body:any=undefined;\n if(method!==\"GET\" && method!==\"HEAD\"){\n if(typeof input?.arrayBuffer===\"function\") body=new Uint8Array(await input.arrayBuffer());\n else body=input?.body??init?.body;\n }\n return await globalThis.fetch(String(input.url),{method,headers,body,redirect:\"manual\"});\n};\nconst sqlite:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:scopedToken,fetch:nativeFetch});\nimport { normalizeBootAgentPayload } from \"../boot_gate_m8c2.ts\";\nimport { prepareAdmissionAwareInstanceCoalescePlan as prepareAtomicCoalescePlan } from \"../brain_bridge_coalesce_admission_if_r4m8_v1.ts\";\nimport { admitWriter } from \"../brain_bridge_authority_epoch_v1.ts\";\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,lease_instance_id:String(rows[0].lease_instance_id||\"\")};\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='FAILED',\n result_json=NULL,\n error_json=json_object(\n 'classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN',\n 'retry_policy','RECONCILE_CANONICAL_STATE_THEN_NEW_JOB_ID'\n ),\n lease_owner=NULL,\n lease_instance_id=NULL,\n lease_expires_at=NULL,\n 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_instance_id,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_instance_id=?,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\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_type(j.payload_json,'$.args')='array'\n AND (\n (\n json_array_length(json_extract(j.payload_json,'$.args'))=1\n AND json_extract(j.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\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 )\n OR json_extract(j.payload_json,'$.args[0]') IN ('register-agent','claim')\n OR (\n json_array_length(json_extract(j.payload_json,'$.args'))=18\n AND json_extract(j.payload_json,'$.args[0]')='boot-agent'\n AND json_extract(j.payload_json,'$.args[1]')='--id'\n AND json_extract(j.payload_json,'$.args[3]')='--workstream'\n AND json_extract(j.payload_json,'$.args[5]')='--role'\n AND json_extract(j.payload_json,'$.args[6]')='independent-project-agent'\n AND json_extract(j.payload_json,'$.args[7]')='--type'\n AND json_extract(j.payload_json,'$.args[8]')='CHAT'\n AND json_extract(j.payload_json,'$.args[9]')='--capabilities'\n AND json_extract(j.payload_json,'$.args[11]')='--claim'\n AND json_extract(j.payload_json,'$.args[12]')='--mode'\n AND json_extract(j.payload_json,'$.args[13]')='INTERACTIVE'\n AND json_extract(j.payload_json,'$.args[14]')='--lease-seconds'\n AND json_extract(j.payload_json,'$.args[16]')='--recent-events'\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 )\n )\n THEN 0 ELSE 1\n END ASC,\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE j.priority END DESC,\n j.created_at,\n CASE\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='status' THEN 0\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='verify-chain' THEN 1\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='verify-claim-graph' THEN 2\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='boot-agent' THEN 3\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='register-agent' THEN 4\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='claim' THEN 5\n ELSE 6\n END ASC,\n j.rowid,\n j.id\n LIMIT 1\n )\n RETURNING id,op,payload_json,priority,lease_instance_id,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_instance_id=? 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 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 const cols:any=await sqlite.execute(`SELECT name FROM pragma_table_info('${JOB_TABLE}') WHERE name='lease_instance_id'`);\n if(!cols.rows?.length)throw new Error(\"LEASE_INSTANCE_COLUMN_REQUIRED\");\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-fair-instance-fence-atomic-boot-n1-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_FAIR_BOOT_COHORT_WITH_ATOMIC_BOOT_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT\",\n atomic_single_flight:true,\n instance_fenced_results:true,\n fail_closed_http_status:status\n }};\n}\n\nasync function rejectInvalidLease(worker:string,instance: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=? AND lease_instance_id=?`,\n args:[JSON.stringify({classification:\"BRIDGE_DISPATCH_REJECTED\",error}),id,worker,instance]\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 authority=await admitWriter(sqlite,\"host_bridge\");\n if(!authority.ok)return json({ok:false,error:\"CONTROL_PLANE_WRITER_FENCED\",reason:authority.reason,authority:authority.authority??null},409);\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,lease_instance_id:before.lease_instance_id},worker_id:worker,instance_id:instance});\n\n const r:any=await sqlite.execute({sql:leaseOneSql(),args:[worker,instance,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,instance,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 authority=await admitWriter(sqlite,\"host_bridge\");\n if(!authority.ok)return json({ok:false,error:\"CONTROL_PLANE_RESULT_FENCED\",reason:authority.reason,authority:authority.authority??null},409);\n\n const resultJson=success?JSON.stringify(q.result??null):null;\n const plan=success&&resultJson ? prepareAtomicCoalescePlan(resultJson,id,worker,instance,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,instance]\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",[47,24],"admission_merge_n1","29a70aaf-cb5b-45b6-9fd3-d04be7430cbd",["D",1789174188714],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","R3A4 cohort repair isolated qualification","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","29a70aafcb5b45b69fd3d04be7430cbd","tursoHostname","29a70aafcb5b45b69fd3d04be7430cbd-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_58":59,"_103":104,"_105":44},"branch",{"_37":32,"_11":90,"_22":30,"_91":48,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned","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",{"_83":-5,"_140":141,"_142":143,"_144":145,"_146":44,"_147":44,"_148":44,"_149":34,"_150":-5,"_151":-7,"_152":-7,"_153":38,"_154":44,"_155":44,"_156":-5,"_157":44,"_158":44,"_159":44,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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"]