[{"_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","r3a3-m6q9-shadow2","path","hash_boot_fair_evidence_sol2014.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/r3a3-m6q9-shadow2/code/hash_boot_fair_evidence_sol2014.ts","extension","id","1ee2fb14-473e-4fa1-bebe-9f5523c2b56c","fileId","01a092e7-153b-76b2-ac43-d23adc98ca28","parentId","branchId","1da4df5d-ade5-4da9-8efa-00b2d8f1294a","branchVersion",1,"latest",true,"createdAt",["D",1789171012789],"version",0,"fileType","script","content","const sources={\"worker_boot_cohort_fair_v1.ts\":\"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 { prepareAdmissionAwareCoalescePlan as prepareAtomicCoalescePlan } from \\\"./brain_bridge_readonly_coalesce_admission_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};\\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\\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 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(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}\\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-admission-a7k3-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_BOOT_ADMISSION_THEN_CLAMPED_PRIORITY_INSERTION_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 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},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 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,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\",\"brain_bridge_readonly_coalesce_admission_v1.ts\":\"import {\\n classifyValidCoalesceResult,\\n MAX_JOB_TIMEOUT,\\n TRANSPORT_PRIORITY_CAP,\\n} from \\\"./brain_bridge_readonly_coalesce_v4.ts\\\";\\n\\nexport type AdmissionAtomicPlan={sql:string;args:unknown[];command:\\\"verify-chain\\\"|\\\"verify-claim-graph\\\"};\\n\\nfunction tableName(t:string){\\n if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(t))throw new Error(\\\"BAD_TABLE\\\");\\n return t;\\n}\\nfunction closedReadonlySql(a:string){\\n return `(${a}.op='brain'\\n AND json_valid(${a}.payload_json)=1\\n AND json_type(${a}.payload_json,'$.args')='array'\\n AND json_array_length(json_extract(${a}.payload_json,'$.args'))=1\\n AND json_extract(${a}.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\\n AND json_type(${a}.payload_json,'$.timeout')='integer'\\n AND json_extract(${a}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\\n AND (SELECT COUNT(*) FROM json_each(${a}.payload_json))=2)`;\\n}\\nfunction validRecoverStaleSql(a:string){\\n return `(${a}.op='brain'\\n AND json_valid(${a}.payload_json)=1\\n AND json_type(${a}.payload_json,'$.args')='array'\\n AND json_array_length(json_extract(${a}.payload_json,'$.args'))=1\\n AND json_extract(${a}.payload_json,'$.args[0]')='recover-stale'\\n AND json_type(${a}.payload_json,'$.timeout')='integer'\\n AND json_extract(${a}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\\n AND (SELECT COUNT(*) FROM json_each(${a}.payload_json))=2)`;\\n}\\nfunction canonicalMutationSql(a:string){\\n return `(${a}.op='brain' AND NOT ${closedReadonlySql(a)})`;\\n}\\n/* Mirrors the admission class in the candidate scheduler exactly.\\n Keeping this expression byte-local to the candidate is deliberate: if the\\n scheduler class changes, parity tests must fail before cutover. */\\nfunction admissionMutationSql(a:string){\\n return `(${a}.op='brain'\\n AND json_valid(${a}.payload_json)=1\\n AND json_type(${a}.payload_json,'$.args')='array'\\n AND json_extract(${a}.payload_json,'$.args[0]') IN ('register-agent','claim'))`;\\n}\\nfunction effectivePrioritySql(a:string){\\n return `(CASE WHEN ${a}.priority > ${TRANSPORT_PRIORITY_CAP} THEN ${TRANSPORT_PRIORITY_CAP} ELSE ${a}.priority END)`;\\n}\\n/* For a read follower f, every READY admission mutation precedes f under the\\n candidate scheduler regardless of insertion time/priority. Other mutations\\n retain the legacy recovery+priority+FIFO ordering. */\\nfunction mutatingReadyPrecedesSql(b:string,f:string){\\n const br=validRecoverStaleSql(b);\\n const ba=admissionMutationSql(b);\\n const bp=effectivePrioritySql(b),fp=effectivePrioritySql(f);\\n return `(${canonicalMutationSql(b)} AND (\\n ${br}\\n OR ${ba}\\n OR (\\n NOT ${br}\\n AND NOT ${ba}\\n AND (\\n ${bp} > ${fp}\\n OR (${bp}=${fp} AND (\\n ${b}.created_at < ${f}.created_at\\n OR (${b}.created_at=${f}.created_at AND ${b}.id<${f}.id)\\n ))\\n )\\n )\\n ))`;\\n}\\nfunction leaderValidSql(a:string){\\n return `(${a}.id=?\\n AND ${a}.state='LEASED'\\n AND ${a}.lease_owner=?\\n AND ${a}.lease_expires_at IS NOT NULL\\n AND ${a}.lease_expires_at > datetime('now')\\n AND ${a}.op='brain'\\n AND json_valid(${a}.payload_json)=1\\n AND json_type(${a}.payload_json,'$.args')='array'\\n AND json_array_length(json_extract(${a}.payload_json,'$.args'))=1\\n AND json_extract(${a}.payload_json,'$.args[0]')=?\\n AND json_type(${a}.payload_json,'$.timeout')='integer'\\n AND json_extract(${a}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\\n AND (SELECT COUNT(*) FROM json_each(${a}.payload_json))=2)`;\\n}\\n\\nexport function atomicSuccessfulAdmissionAwareCoalesceSql(table=\\\"brain_bridge_jobs\\\"){\\n table=tableName(table);\\n const leaderL=leaderValidSql(\\\"l\\\");\\n return `WITH leader AS MATERIALIZED (\\n SELECT l.id,l.op,l.payload_json,l.priority,l.updated_at AS leased_at\\n FROM ${table} AS l\\n WHERE ${leaderL}\\n )\\n UPDATE ${table} AS j\\n SET state='COMPLETE',\\n result_json=?,\\n error_json=NULL,\\n lease_owner=NULL,\\n lease_expires_at=NULL,\\n updated_at=datetime('now')\\n WHERE\\n j.id IN (SELECT id FROM leader)\\n OR (\\n j.state='READY'\\n AND EXISTS(\\n SELECT 1 FROM leader AS l\\n WHERE j.op=l.op\\n AND j.payload_json=l.payload_json\\n AND j.priority=l.priority\\n AND j.created_at < l.leased_at\\n AND NOT EXISTS(\\n SELECT 1 FROM ${table} AS b\\n WHERE b.id<>j.id AND b.id<>l.id\\n AND b.state='READY'\\n AND ${mutatingReadyPrecedesSql(\\\"b\\\",\\\"j\\\")}\\n )\\n AND NOT EXISTS(\\n SELECT 1 FROM ${table} AS m\\n WHERE m.id<>j.id AND m.id<>l.id\\n AND m.state='LEASED'\\n AND ${canonicalMutationSql(\\\"m\\\")}\\n )\\n AND NOT EXISTS(\\n SELECT 1 FROM ${table} AS t\\n WHERE t.id<>j.id AND t.id<>l.id\\n AND t.state IN ('COMPLETE','FAILED')\\n AND t.updated_at >= l.leased_at\\n AND ${canonicalMutationSql(\\\"t\\\")}\\n )\\n )\\n )\\n RETURNING id`;\\n}\\n\\nexport function prepareAdmissionAwareCoalescePlan(\\n resultJson:string,id:string,worker:string,success:boolean,table=\\\"brain_bridge_jobs\\\",\\n):AdmissionAtomicPlan|null{\\n if(success!==true||!id||!worker)return null;\\n const command=classifyValidCoalesceResult(resultJson);\\n if(command===null)return null;\\n return {\\n command,\\n sql:atomicSuccessfulAdmissionAwareCoalesceSql(table),\\n args:[id,worker,command,resultJson],\\n };\\n}\",\"boot_cohort_pure_sol2014_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nconst JOB_TABLE = \\\"brain_bridge_jobs\\\";\\nexport const PRIORITY_CAP = 1_000_000_000;\\nexport const MAX_JOB_TIMEOUT = 120;\\nexport const LEASE_SECONDS = 180;\\nfunction tableName(table:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table))throw new Error(\\\"BAD_TABLE\\\");return table;}\\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 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]')='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}\\n\\nconst T=\\\"boot_cohort_pure_\\\"+crypto.randomUUID().replaceAll(\\\"-\\\",\\\"\\\");\\nconst out:any={schema:\\\"BOOT_COHORT_FAIR_EXACT_EXTRACT_TEST\\\",tests:[],failures:[]};\\nconst check=(n:string,c:boolean,d:any={})=>{out.tests.push({name:n,ok:!!c,detail:d});if(!c)out.failures.push(n);};\\nconst ex=async(sql:string,args:any[]=[])=>await sqlite.execute({sql,args});\\nconst p=(args:string[],extra:any=null)=>JSON.stringify(Object.assign({args,timeout:60},extra||{}));\\nasync function add(id:string,args:string[],created:string,priority=PRIORITY_CAP,extra:any=null){\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES(?,?,'brain',?,'READY',?,?)`,[id,priority,p(args,extra),created,created]);\\n}\\nasync function lease(w:string){const r:any=await ex(leaseOneSql(T),[w,w]);return String(r.rows?.[0]?.id||\\\"\\\");}\\nasync function done(id:string){await ex(`UPDATE ${T} SET state='COMPLETE',lease_owner=NULL,lease_expires_at=NULL WHERE id=?`,[id]);}\\nasync function clear(){await ex(`DELETE FROM ${T}`);}\\nawait sqlite.execute(`CREATE TABLE ${T}(id TEXT PRIMARY KEY,priority REAL NOT NULL DEFAULT 0,op TEXT NOT NULL,payload_json TEXT NOT NULL,state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\\ntry{\\n await add(\\\"ordinary-old\\\",[\\\"ensure-task\\\",\\\"x\\\"],\\\"2026-01-01 00:00:00\\\");\\n await add(\\\"status-new\\\",[\\\"status\\\"],\\\"2026-01-01 00:00:10\\\");\\n check(\\\"boot_cohort_bypasses_ordinary\\\",(await lease(\\\"w1\\\"))===\\\"status-new\\\"); await clear();\\n\\n await add(\\\"register-old\\\",[\\\"register-agent\\\",\\\"a\\\"],\\\"2026-01-01 00:01:00\\\");\\n await add(\\\"status-new\\\",[\\\"status\\\"],\\\"2026-01-01 00:01:10\\\");\\n check(\\\"older_registration_beats_newer_preflight\\\",(await lease(\\\"w2\\\"))===\\\"register-old\\\"); await clear();\\n\\n await add(\\\"status-old\\\",[\\\"status\\\"],\\\"2026-01-01 00:02:00\\\");\\n await add(\\\"register-new\\\",[\\\"register-agent\\\",\\\"a\\\"],\\\"2026-01-01 00:02:10\\\");\\n check(\\\"older_preflight_beats_newer_registration\\\",(await lease(\\\"w3\\\"))===\\\"status-old\\\"); await clear();\\n\\n const ts=\\\"2026-01-01 00:03:00\\\";\\n for(const [id,args] of [[\\\"claim\\\",[\\\"claim\\\",\\\"--agent\\\",\\\"a\\\"]],[\\\"register\\\",[\\\"register-agent\\\",\\\"a\\\"]],[\\\"vcg\\\",[\\\"verify-claim-graph\\\"]],[\\\"vc\\\",[\\\"verify-chain\\\"]],[\\\"status\\\",[\\\"status\\\"]]] as any[]) await add(id,args,ts);\\n const seq:string[]=[]; for(let i=0;i<5;i++){const id=await lease(\\\"seq\\\"+i);seq.push(id);await done(id);}\\n check(\\\"exact_tie_stage_order\\\",JSON.stringify(seq)===JSON.stringify([\\\"status\\\",\\\"vc\\\",\\\"vcg\\\",\\\"register\\\",\\\"claim\\\"]),{seq}); await clear();\\n\\n await add(\\\"register-old\\\",[\\\"register-agent\\\",\\\"a\\\"],\\\"2026-01-01 00:04:00\\\");\\n const leased:string[]=[]; for(let i=0;i<8;i++){await add(\\\"status-\\\"+i,[\\\"status\\\"],\\\"2026-01-01 00:05:\\\"+String(i).padStart(2,\\\"0\\\"));const id=await lease(\\\"sa\\\"+i);leased.push(id);await done(id);}\\n check(\\\"continuous_preflight_cannot_starve_old_registration\\\",leased[0]===\\\"register-old\\\",{leased}); await clear();\\n\\n await add(\\\"status-old\\\",[\\\"status\\\"],\\\"2026-01-01 00:06:00\\\");\\n const leased2:string[]=[]; for(let i=0;i<8;i++){await add(\\\"register-\\\"+i,[\\\"register-agent\\\",\\\"a\\\"+i],\\\"2026-01-01 00:07:\\\"+String(i).padStart(2,\\\"0\\\"));const id=await lease(\\\"sb\\\"+i);leased2.push(id);await done(id);}\\n check(\\\"continuous_admission_cannot_starve_old_preflight\\\",leased2[0]===\\\"status-old\\\",{leased2}); await clear();\\n\\n await add(\\\"fake-status-old\\\",[\\\"status\\\"],\\\"2026-01-01 00:08:00\\\",PRIORITY_CAP,{evil:true});\\n await add(\\\"register-valid\\\",[\\\"register-agent\\\",\\\"a\\\"],\\\"2026-01-01 00:08:10\\\");\\n check(\\\"malformed_preflight_not_in_boot_cohort\\\",(await lease(\\\"w4\\\"))===\\\"register-valid\\\"); await clear();\\n\\n await add(\\\"recover-low\\\",[\\\"recover-stale\\\"],\\\"2026-01-01 00:09:10\\\",0);\\n await add(\\\"status-high\\\",[\\\"status\\\"],\\\"2026-01-01 00:09:00\\\");\\n check(\\\"recover_stale_absolute_first\\\",(await lease(\\\"w5\\\"))===\\\"recover-low\\\"); await clear();\\n\\n await add(\\\"status-overcap-old\\\",[\\\"status\\\"],\\\"2026-01-01 00:10:00\\\",1e300);\\n await add(\\\"status-overcap-new\\\",[\\\"status\\\"],\\\"2026-01-01 00:10:10\\\",1e301);\\n check(\\\"priority_cap_fifo_inside_boot_cohort\\\",(await lease(\\\"w6\\\"))===\\\"status-overcap-old\\\"); await clear();\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);}\\nif(out.failures.length)throw new Error(\\\"BOOT_COHORT_FAIR_EXACT_EXTRACT_FAIL:\\\"+out.failures.join(\\\",\\\"));\\n\",\"coalesce_admission_sol2014_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { prepareAdmissionAwareCoalescePlan } from \\\"./brain_bridge_readonly_coalesce_admission_v1.ts\\\";\\n\\nconst T=\\\"coalesce_admission_test_\\\"+crypto.randomUUID().replaceAll(\\\"-\\\",\\\"\\\");\\nconst out:any={schema:\\\"ADMISSION_AWARE_COALESCE_FOCUSED_V1\\\",tests:[],failures:[]};\\nconst check=(n:string,c:boolean,d:any={})=>{out.tests.push({name:n,ok:!!c,detail:d});if(!c)out.failures.push(n);};\\nconst ex=async(sql:string,args:any[]=[])=>await sqlite.execute({sql,args});\\nconst chainPayload=JSON.stringify({args:[\\\"verify-chain\\\"],timeout:60});\\nconst regPayload=JSON.stringify({args:[\\\"register-agent\\\",\\\"agent-x\\\",\\\"--workstream\\\",\\\"global\\\",\\\"--role\\\",\\\"worker\\\",\\\"--type\\\",\\\"CHAT\\\",\\\"--capabilities\\\",\\\"[]\\\"],timeout:60});\\nconst goodResult=JSON.stringify({\\n returncode:0,\\n stdout:JSON.stringify({computed_head:\\\"a\\\".repeat(64),events:7,ok:true,stored_head:\\\"a\\\".repeat(64)})+\\\"\\\\n\\\",\\n stderr:\\\"\\\",\\n stdout_truncated:false,\\n stderr_truncated:false\\n});\\nconst statusResult=JSON.stringify({\\n returncode:0,\\n stdout:JSON.stringify({generation:1,ok:true})+\\\"\\\\n\\\",\\n stderr:\\\"\\\",\\n stdout_truncated:false,\\n stderr_truncated:false\\n});\\n\\nawait ex(`CREATE TABLE ${T}(\\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT NOT NULL, payload_json TEXT NOT NULL,\\n state TEXT NOT NULL DEFAULT 'READY', lease_owner TEXT, lease_expires_at TEXT, result_json TEXT, error_json TEXT,\\n created_at TEXT NOT NULL, updated_at TEXT NOT NULL)`);\\nasync function clear(){await ex(`DELETE FROM ${T}`);}\\nasync function seedBase(){\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\\n VALUES\\n ('leader',1000000000,'brain',?,'LEASED','worker-1',datetime('now','+120 seconds'),'2026-01-01 00:00:10',datetime('now','-2 seconds')),\\n ('follower',1000000000,'brain',?,'READY',NULL,NULL,'2026-01-01 00:00:00','2026-01-01 00:00:00')`,[chainPayload,chainPayload]);\\n}\\nasync function execPlan(){\\n const plan=prepareAdmissionAwareCoalescePlan(goodResult,\\\"leader\\\",\\\"worker-1\\\",true,T as any);\\n check(\\\"valid_verify_chain_plan_created\\\",!!plan);\\n if(!plan)return [];\\n const r:any=await ex(plan.sql,plan.args as any[]);\\n return (r.rows||[]).map((x:any)=>String(x.id)).sort();\\n}\\ntry{\\n await seedBase();\\n let ids=await execPlan();\\n check(\\\"clean_duplicate_coalesces_leader_and_follower\\\",JSON.stringify(ids)===JSON.stringify([\\\"follower\\\",\\\"leader\\\"]),{ids});\\n await clear();\\n\\n await seedBase();\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES('register-ready',1000000000,'brain',?,'READY','2026-01-01 00:00:05','2026-01-01 00:00:05')`,[regPayload]);\\n ids=await execPlan();\\n const rr:any=await ex(`SELECT id,state FROM ${T} WHERE id IN ('leader','follower') ORDER BY id`);\\n check(\\\"ready_registration_blocks_follower\\\",ids.length===1&&ids[0]===\\\"leader\\\"&&rr.rows?.find((x:any)=>x.id===\\\"follower\\\")?.state===\\\"READY\\\",{ids,rows:rr.rows});\\n await clear();\\n\\n await seedBase();\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\\n VALUES('mutation-leased',1000000000,'brain',?,'LEASED','other-worker',datetime('now','+120 seconds'),'2026-01-01 00:00:05',datetime('now','-1 second'))`,[regPayload]);\\n ids=await execPlan();\\n check(\\\"leased_canonical_mutation_blocks_follower\\\",ids.length===1&&ids[0]===\\\"leader\\\",{ids});\\n await clear();\\n\\n await seedBase();\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES('mutation-terminal',1000000000,'brain',?,'COMPLETE','2026-01-01 00:00:05',datetime('now'))`,[regPayload]);\\n ids=await execPlan();\\n check(\\\"terminal_mutation_after_leader_lease_blocks_follower\\\",ids.length===1&&ids[0]===\\\"leader\\\",{ids});\\n await clear();\\n\\n const badPlan=prepareAdmissionAwareCoalescePlan(\\\"{}\\\", \\\"leader\\\",\\\"worker-1\\\",true,T as any);\\n check(\\\"malformed_success_result_not_coalescible\\\",badPlan===null);\\n const statusPlan=prepareAdmissionAwareCoalescePlan(statusResult,\\\"leader\\\",\\\"worker-1\\\",true,T as any);\\n check(\\\"status_result_not_coalescible\\\",statusPlan===null);\\n const failedPlan=prepareAdmissionAwareCoalescePlan(goodResult,\\\"leader\\\",\\\"worker-1\\\",false,T as any);\\n check(\\\"failed_worker_result_not_coalescible\\\",failedPlan===null);\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{\\n await ex(`DROP TABLE IF EXISTS ${T}`);\\n}\\nif(out.failures.length)throw new Error(\\\"ADMISSION_COALESCE_TEST_FAIL:\\\"+out.failures.join(\\\",\\\"));\\n\",\"brain_bridge_worker.ts\":\"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 { prepareAtomicCoalescePlan } from \\\"./brain_bridge_readonly_coalesce_v4.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};\\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\\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\\n AND 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]') 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 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 json_extract(j.payload_json,'$.args[0]') IN ('register-agent','claim')\\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]')='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(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}\\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_BOOT_PREFLIGHT_THEN_BOOT_ADMISSION_THEN_CLAMPED_PRIORITY_INSERTION_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 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},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 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,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\"};\nconst evidence={\"schema\":\"BRAIN_BOOT_COHORT_FAIRNESS_INDEPENDENT_VALIDATION_V1\",\"classification\":\"VERIFIED_NONAUTHORITY_CANDIDATE_EVIDENCE\",\"production_mutation\":false,\"canonical_brain_mutation\":false,\"direct_sprites_calls\":0,\"human_authority_approval\":false,\"finding\":{\"live_problem\":\"current scheduler ranks all valid boot preflight reads ahead of register-agent/claim, creating admission starvation under sustained preflight load\",\"observed_queue\":{\"ready\":435,\"preflight_ready\":200,\"admission_ready\":187,\"leased\":1},\"registration_job\":\"chat-sol-20260906-2029-register-if1\",\"registration_state\":\"READY\",\"candidate_policy\":\"recover-stale absolute first; valid boot preflight plus register/claim form one priority-capped FIFO boot cohort; exact timestamp tie breaks status, verify-chain, verify-claim-graph, register-agent, claim\",\"separate_unresolved_boundary\":\"attempt/incarnation result fencing remains separate and is not claimed repaired by this fairness candidate\"},\"tests\":{\"exact_extracted_scheduler\":\"9/9 PASS\",\"admission_aware_coalescer\":\"11/11 PASS\",\"invalid_infrastructure_runs\":[\"candidate HTTP-import test: libSQL resp.body?.cancel failure before assertions\"]}};\nasync function id(s:string){const b=new TextEncoder().encode(s);const h=await crypto.subtle.digest(\"SHA-256\",b);return {bytes:b.length,sha256:Array.from(new Uint8Array(h)).map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")};}\nconst identities:any={};for(const [k,v] of Object.entries(sources))identities[k]=await id(v as string);\nconst content=JSON.stringify({...evidence,identities},null,2);\nconsole.log(JSON.stringify({identities,evidence_content:content,evidence_identity:await id(content)}));","deleted",false,"label",[14],"04900e5a-0cc1-401b-9ed8-b0fe6196756a",["D",1789171012789],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable R3A3 exact cohort falsifier","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a092e7-1539-7581-b5ef-8e522619d4aa","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","04900e5a0cc1401b9ed8b0fe6196756a","tursoHostname","04900e5a0cc1401b9ed8b0fe6196756a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"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",2,"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"]