[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_108":109,"_110":111},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","pb-r3r1-readcoalesce-20260912","path","current/brain_bridge_worker.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":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":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/pb-r3r1-readcoalesce-20260912/code/current/brain_bridge_worker.ts","extension","id","1116f680-6b7b-4358-abe8-12c9a72f00db","brain_bridge_worker.ts","fileId","01a0928e-9e37-702a-9dd5-eff9bd500039","parentId","f3fb2318-ae2e-11f1-b054-1607ee4eb77e","branchId","a9932cbe-2418-481b-981e-aabcc7561c6a","branchVersion",3,"latest",true,"createdAt",["D",1789165215291],"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 { prepareAdmissionAwareCoalescePlan as prepareAtomicCoalescePlan } from \"./brain_bridge_readonly_coalesce_admission_v1.ts\";\nimport { AUTHORITY_TABLE, ensureAuthorityTable } 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 MISSION_FAIRNESS_AGE_SECONDS = 15;\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;\nexport const VAL_NATIVE_ATOMICALLY_QUALIFIED_COMMANDS = [\n \"status\",\n \"verify-chain\",\n \"verify-claim-graph\",\n \"register-agent\",\n \"ensure-task\",\n \"claim\",\n \"renew-lease\",\n \"commit\",\n \"recover-stale\",\n \"supersede-task-context\"\n] as const;\nconst SUPPORTED = new Set(SUPPORTED_BRAIN_COMMANDS);\n\nexport function commandSurfaceForAuthority(writer:string|null|undefined){\n const recognized=[...SUPPORTED_BRAIN_COMMANDS];\n if(writer===\"val_native\") return {\n writer,\n recognized,\n currently_executable:[...VAL_NATIVE_ATOMICALLY_QUALIFIED_COMMANDS],\n fence:\"OTHER_RECOGNIZED_MUTATORS_REQUIRE_INDEPENDENT_ATOMIC_REACTIVATION\"\n };\n if(writer===\"host_bridge\") return {\n writer,\n recognized,\n currently_executable:[...SUPPORTED_BRAIN_COMMANDS],\n fence:\"HOST_BRIDGE_COMPATIBILITY_SURFACE_ONLY_WHILE_AUTHORITY_SELECTED\"\n };\n return {writer:writer??null,recognized,currently_executable:[],fence:\"NO_AUTHORITY_SELECTED_EXECUTION_SURFACE\"};\n}\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='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_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_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\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 )\n AND EXISTS(\n SELECT 1 FROM ${table} c\n WHERE c.state='READY'\n AND c.op='brain'\n AND json_valid(c.payload_json)=1\n AND json_type(c.payload_json,'$.args')='array'\n AND json_extract(c.payload_json,'$.args[0]')='commit'\n AND json_type(c.payload_json,'$.timeout')='integer'\n AND json_extract(c.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(c.payload_json))=2\n AND (\n c.created_at < j.created_at\n OR (c.created_at=j.created_at AND c.rowid < j.rowid)\n )\n )\n THEN 1 ELSE 0\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 json_extract(j.payload_json,'$.args[0]') IN ('ensure-task','renew-lease','supersede-task-context','migrate-task-invariants')\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 AND (julianday('now') - julianday(j.created_at))*86400.0 >= ${MISSION_FAIRNESS_AGE_SECONDS}\n THEN 0 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 )\n THEN 0 ELSE 1\n END ASC,\n CASE\n WHEN j.op='brain'\n AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='claim'\n AND json_extract(j.payload_json,'$.args[1]')='--agent'\n AND EXISTS(\n SELECT 1 FROM ${table} r\n WHERE r.state='READY'\n AND r.op='brain'\n AND json_valid(r.payload_json)=1\n AND json_extract(r.payload_json,'$.args[0]')='register-agent'\n AND json_extract(r.payload_json,'$.args[1]')=json_extract(j.payload_json,'$.args[2]')\n AND r.created_at=j.created_at\n )\n THEN 1 ELSE 0\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]')='register-agent' THEN 3\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='claim' THEN 4\n ELSE 5\n END ASC,\n j.rowid,\n 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([\"status\",\"verify-chain\",\"verify-claim-graph\"].includes(cmd) && q.args.length!==1){\n return {ok:false,error:\"READ_ONLY_COMMAND_ARGS_FORBIDDEN\"};\n }\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:\"BOOT_AGENT_NOT_END_TO_END_USE_REGISTER_AGENT_THEN_CLAIM\"};\n if(cmd===\"renew-lease\" && q.args.includes(\"--lease-seconds\")){\n return {ok:false,error:\"RENEW_LEASE_USE_SECONDS_NOT_LEASE_SECONDS\"};\n }\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\nlet schemaReady:Promise|null=null;\nasync function ensureTables(){\n if(!schemaReady){\n schemaReady=(async()=>{\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 await ensureAuthorityTable(sqlite);\n })();\n }\n try{await schemaReady}catch(e){schemaReady=null;throw e}\n}\nasync function admitHostWriter(){\n await ensureTables();\n const r:any=await sqlite.execute(`SELECT epoch,writer,source_generation,source_head,mode,prepared_at,updated_at FROM ${AUTHORITY_TABLE} WHERE id=1`);\n const a:any=r.rows?.[0]||null;\n if(!a)return {ok:false,reason:\"AUTHORITY_UNINITIALIZED\"};\n if(String(a.mode)!==\"ACTIVE\")return {ok:false,reason:\"AUTHORITY_PREPARED_NO_WRITER\",authority:a};\n if(String(a.writer)!==\"host_bridge\")return {ok:false,reason:\"WRITER_NOT_CANONICAL\",authority:a};\n return {ok:true,epoch:Number(a.epoch),authority:a};\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,qc,dup,auth,dur]:any[]=await sqlite.batch([\n {sql:`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 {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`,args:[PRIORITY_CAP]},\n {sql:`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 {sql:`SELECT epoch,writer,source_generation,source_head,mode,prepared_at,updated_at\n FROM ${AUTHORITY_TABLE} WHERE id=1`},\n {sql:`SELECT\n (SELECT generation FROM brainvn_epoch_meta WHERE id=1) AS canonical_generation,\n (SELECT MAX(generation) FROM brainvn_replicas WHERE verified=1) AS max_verified_replica_generation,\n (SELECT COUNT(*) FROM brainvn_replicas WHERE verified=1) AS verified_replica_count`}\n ],\"read\");\n const w=wr.rows?.[0]||null;\n const q=qc.rows?.[0]||{};\n const a=auth.rows?.[0]||null;\n const d=dur.rows?.[0]||{};\n const canonicalGeneration=d.canonical_generation==null?null:Number(d.canonical_generation);\n const maxVerifiedReplicaGeneration=d.max_verified_replica_generation==null?null:Number(d.max_verified_replica_generation);\n const durabilityLagGenerations=\n canonicalGeneration==null||maxVerifiedReplicaGeneration==null\n ? null\n : Math.max(0,canonicalGeneration-maxVerifiedReplicaGeneration);\n const durabilityState=\n durabilityLagGenerations==null ? \"UNKNOWN\" :\n durabilityLagGenerations===0 ? \"CURRENT\" : \"LAGGING\";\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-boot-cohort-fair-v1\",\n control_plane_authority:a,\n brain_command_surface:commandSurfaceForAuthority(a?.writer==null?null:String(a.writer)),\n worker:w,\n worker_state:cls.state,\n worker_reason:cls.reason,\n worker_health_scope:\"HOST_BRIDGE_WORKER_ONLY\",\n instance_identity_available:w ? w.instance_id!==\"LEGACY_UNATTESTED_INSTANCE\" : false,\n duplicate_active_worker_leases:duplicateActiveLeases,\n queue:q,\n durability:{\n canonical_generation:canonicalGeneration,\n max_verified_replica_generation:maxVerifiedReplicaGeneration,\n verified_replica_count:Number(d.verified_replica_count||0),\n lag_generations:durabilityLagGenerations,\n state:durabilityState\n },\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_OLDER_READY_COMMIT_BARRIER_THEN_AGED_NONBOOT_MISSION_15S_ESCAPE_THEN_BOOT_COHORT_PAIRED_REGISTER_BEFORE_CLAIM_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 authority=await admitHostWriter();\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 const pollBatch:any[]=await sqlite.batch([\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')`,args:[worker,instance]},\n {sql:recoverExpiredSql()},\n {sql:activeLeaseSql(),args:[worker]},\n {sql:leaseOneSql(),args:[worker,worker]}\n ],\"write\");\n const ar:any=pollBatch[2];\n const r:any=pollBatch[3];\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 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 authority=await admitHostWriter();\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,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",[47,24],"current","4d625a42-bd31-472a-9c2e-3fa3d1061da9",["D",1789165205903],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Rev3 read-only coalescer rebind qualification","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_107":103},"org",{"_9":10,"_100":101,"_102":103,"_58":59,"_104":105,"_106":44},"branch",{"_37":87,"_11":88,"_22":30,"_89":48,"_90":91,"_92":93,"_94":53,"_95":96,"_97":66,"_98":12,"_99":10},"isOwned",11,"main","projectId","forkedBranchId","135bdb83-a5ef-4663-8e8c-8e5cf123ceb2","forkedBranchVersion",20,"forkedProjectPrivacy","forkedProjectId","ef2de6a5-356a-4dd1-b3f2-03ea3ef80bac","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_80":-5,"_141":142,"_143":144,"_145":146,"_147":44,"_148":44,"_149":44,"_150":34,"_151":-5,"_152":-7,"_153":-7,"_154":38,"_155":44,"_156":44,"_157":-5,"_158":44,"_159":44,"_160":44,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":88,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"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"]