[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_110":111,"_112":113},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","project-brain-branch-archive-v1","path","instance-affinity-z7p3/hash_branch_artifacts.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":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/project-brain-branch-archive-v1/code/instance-affinity-z7p3/hash_branch_artifacts.ts","extension","id","2cb4fbcc-d1f7-4a29-aafb-f2510010cd0d","hash_branch_artifacts.ts","fileId","01a07b80-b4d6-73c0-ae85-3ffa216e5437","parentId","01a07b80-b4d5-7124-b029-2e1fbc8ad6a4","branchId","dfaa6cf0-d6c1-4d1d-bddb-0d8f8a62293a","branchVersion",4,"latest",true,"createdAt",["D",1788791971867],"version",1,"fileType","script","content","const files={\"brain_bridge_worker.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\n\\nconst WORKER_TOKEN = Deno.env.get(\\\"BRAIN_BRIDGE_WORKER_TOKEN\\\") || \\\"\\\";\\nconst JOB_TABLE = \\\"brain_bridge_jobs\\\";\\nconst WORKER_TABLE = \\\"brain_bridge_workers_v6\\\";\\nconst EXPECTED_WORKER_ID = \\\"project-brain-live-v1-worker-v2\\\";\\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,legacyUnattestedActiveLeases=0,recentInstanceCount=1){\\n return workerState===\\\"HEALTHY\\\" && duplicateActiveLeases===0 && expiredLeases===0 && legacyUnattestedActiveLeases===0 && recentInstanceCount===1 ? 200 : 503;\\n}\\nexport function legacyLeaseRiskLeases(leasedCount:number,legacyRiskCount:number){\\n return legacyRiskCount>0 && leasedCount>0 ? leasedCount : 0;\\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 isAttestedInstance(instance:string){return !!instance && instance!==\\\"LEGACY_UNATTESTED_INSTANCE\\\";}\\nfunction exactRecoverPredicate(alias=\\\"j\\\"){\\n return `(${alias}.op='brain' AND json_valid(${alias}.payload_json)=1\\n AND json_type(${alias}.payload_json,'$.args')='array'\\n AND json_array_length(json_extract(${alias}.payload_json,'$.args'))=1\\n AND json_extract(${alias}.payload_json,'$.args[0]')='recover-stale'\\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\\n}\\nexport function leaseOneSql(table=JOB_TABLE,allowRecovery=true){\\n table=tableName(table);\\n const recover=exactRecoverPredicate(\\\"j\\\");\\n const recoveryEligibility=allowRecovery ? \\\"1=1\\\" : `NOT ${recover}`;\\n const recoveryOrder=allowRecovery ? `CASE WHEN ${recover} THEN 0 ELSE 1 END` : \\\"1\\\";\\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 (${recoveryEligibility})\\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 ${recoveryOrder} ASC,\\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE j.priority END DESC,\\n j.created_at,j.id\\n LIMIT 1\\n )\\n RETURNING id,op,payload_json,priority,lease_expires_at`;\\n}\\nexport function resultSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\\n RETURNING id,state`;\\n}\\n\\nexport type DispatchResult=\\n | {ok:true;payload_json:string}\\n | {ok:false;error:string};\\n\\nfunction exactKeys(q:any, expected:string[]){\\n const got=Object.keys(q).sort();\\n const want=[...expected].sort();\\n return got.length===want.length && got.every((k,i)=>k===want[i]);\\n}\\n\\nexport function normalizeDispatch(op:string,payloadJson:string):DispatchResult{\\n let q:any;try{q=JSON.parse(payloadJson)}catch{return {ok:false,error:\\\"PAYLOAD_JSON_INVALID\\\"}}\\n if(!q || typeof q!==\\\"object\\\" || Array.isArray(q))return {ok:false,error:\\\"PAYLOAD_OBJECT_REQUIRED\\\"};\\n\\n if(op===\\\"brain\\\"){\\n if(!exactKeys(q,[\\\"args\\\",\\\"timeout\\\"]))return {ok:false,error:\\\"BRAIN_PAYLOAD_SCHEMA_NOT_CLOSED\\\"};\\n if(!Array.isArray(q.args) || q.args.length<1 || q.args.some((x:any)=>typeof x!==\\\"string\\\"))return {ok:false,error:\\\"BRAIN_ARGS_INVALID\\\"};\\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>MAX_JOB_TIMEOUT)return {ok:false,error:\\\"BRAIN_TIMEOUT_INVALID\\\"};\\n const cmd=q.args[0];\\n if(cmd===\\\"boot\\\")return {ok:false,error:\\\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\\\"};\\n if(cmd===\\\"boot-agent\\\")return {ok:false,error:\\\"RAW_BOOT_AGENT_NOT_BRIDGE_COMMAND\\\"};\\n if(cmd===\\\"recover-leases\\\")return {ok:false,error:\\\"RECOVER_LEASE_ALIAS_NOT_AVAILABLE_ON_CURRENT_EXECUTOR\\\"};\\n if(!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 ${WORKER_TABLE} (\\n endpoint_host TEXT NOT NULL,\\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(endpoint_host,worker_id,instance_id)\\n )`);\\n}\\nfunction instanceOf(q:any){const v=String(q?.instance_id||\\\"\\\").trim();return v||\\\"LEGACY_UNATTESTED_INSTANCE\\\";}\\nexport function endpointScope(req:Request){return new URL(req.url).host.toLowerCase();}\\n\\nasync function workerHealth(endpointHost:string){\\n await ensureTables();\\n const wr:any=await sqlite.execute({\\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 ${WORKER_TABLE}\\n WHERE endpoint_host=? AND worker_id=?\\n ORDER BY last_poll_at DESC LIMIT 1`,\\n args:[endpointHost,EXPECTED_WORKER_ID]\\n });\\n const w=wr.rows?.[0]||null;\\n const ri:any=await sqlite.execute({\\n sql:`SELECT COUNT(*) AS recent_instance_count\\n FROM ${WORKER_TABLE}\\n WHERE endpoint_host=? AND worker_id=?\\n AND last_poll_at IS NOT NULL\\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\\n args:[endpointHost,EXPECTED_WORKER_ID,STALE_SECONDS]\\n });\\n const recentInstanceCount=Number(ri.rows?.[0]?.recent_instance_count||0);\\n const legacyRisk:any=await sqlite.execute({\\n sql:`SELECT COUNT(*) AS legacy_risk_count\\n FROM ${WORKER_TABLE}\\n WHERE endpoint_host=? AND worker_id=?\\n AND instance_id='LEGACY_UNATTESTED_INSTANCE'\\n AND last_poll_at IS NOT NULL\\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\\n args:[endpointHost,EXPECTED_WORKER_ID,LEASE_SECONDS]\\n });\\n const legacyRiskCount=Number(legacyRisk.rows?.[0]?.legacy_risk_count||0);\\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 leasedCount=Number(q.leased_count||0);\\n // A legacy process can own a still-live 180s queue lease after its heartbeat has aged\\n // beyond the 90s recent-instance window. Conservatively hold health closed for the\\n // full lease horizon whenever any legacy heartbeat in this endpoint scope could still\\n // be the origin of an active lease.\\n const legacyUnattestedActiveLeases=legacyLeaseRiskLeases(leasedCount,legacyRiskCount);\\n const status=healthHttpStatus(cls.state,duplicateActiveLeases,expiredLeases,legacyUnattestedActiveLeases,recentInstanceCount);\\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 legacy_unattested_active_leases:legacyUnattestedActiveLeases,\\n expected_worker_id:EXPECTED_WORKER_ID,\\n recent_expected_worker_instances:recentInstanceCount,\\n queue:q,\\n transport_priority_cap:PRIORITY_CAP,\\n max_brain_timeout_seconds:MAX_JOB_TIMEOUT,\\n queue_lease_seconds:LEASE_SECONDS,\\n selection_policy:\\\"RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT\\\",\\n atomic_single_flight:true,\\n fail_closed_http_status:status\\n }};\\n}\\n\\nasync function rejectInvalidLease(worker:string,id:string,error:string){\\n await sqlite.execute({\\n sql:`UPDATE ${JOB_TABLE}\\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\\n args:[JSON.stringify({classification:\\\"BRIDGE_DISPATCH_REJECTED\\\",error}),id,worker]\\n });\\n}\\n\\nexport default async function(req:Request):Promise{\\n const u=new URL(req.url);\\n const endpointHost=endpointScope(req);\\n if(req.method===\\\"GET\\\" && u.pathname.endsWith(\\\"/health\\\")){\\n const h=await workerHealth(endpointHost);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 if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\\\"WORKER_ID_MISMATCH\\\"},403);\\n const instance=instanceOf(q);\\n await sqlite.execute({\\n sql:`INSERT INTO ${WORKER_TABLE}(endpoint_host,worker_id,instance_id,first_seen_at,last_poll_at,updated_at)\\n VALUES(?,?,?,datetime('now'),datetime('now'),datetime('now'))\\n ON CONFLICT(endpoint_host,worker_id,instance_id) DO UPDATE SET last_poll_at=datetime('now'),updated_at=datetime('now')`,\\n args:[endpointHost,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(JOB_TABLE,isAttestedInstance(instance)),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 ${WORKER_TABLE} SET lease_count=lease_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\\n args:[endpointHost,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 if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\\\"WORKER_ID_MISMATCH\\\"},403);\\n const r:any=await sqlite.execute({\\n sql:resultSql(),\\n args:[success?\\\"COMPLETE\\\":\\\"FAILED\\\",success?JSON.stringify(q.result??null):null,success?null:JSON.stringify(q.error??null),id,worker]\\n });\\n if(!r.rows?.length)return json({ok:false,error:\\\"LEASE_MISMATCH_OR_EXPIRED\\\"},409);\\n await sqlite.execute({\\n sql:`UPDATE ${WORKER_TABLE} SET last_result_at=datetime('now'),result_count=result_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\\n args:[endpointHost,worker,instance]\\n });\\n return json({ok:true,id,state:r.rows[0].state,worker_id:worker,instance_id:instance});\\n }\\n return json({ok:false,error:\\\"NOT_FOUND\\\"},404);\\n}\\n\",\"legacy_lease_horizon_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { LEASE_SECONDS, healthHttpStatus, legacyLeaseRiskLeases } from \\\"./brain_bridge_worker.ts\\\";\\n\\nconst T=\\\"legacy_lease_horizon_z7p3_\\\"+crypto.randomUUID().replaceAll(\\\"-\\\",\\\"\\\");\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\n\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n endpoint_host TEXT NOT NULL,worker_id TEXT NOT NULL,instance_id TEXT NOT NULL,last_poll_at TEXT\\n)`);\\ntry{\\n const worker=\\\"project-brain-live-v1-worker-v2\\\";\\n await sqlite.execute({sql:`INSERT INTO ${T} VALUES\\n ('main.example',?,'LEGACY_UNATTESTED_INSTANCE',datetime('now','-100 seconds')),\\n ('main.example',?,'attested-new',datetime('now'))`,args:[worker,worker]});\\n const recent:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id=? AND last_poll_at>=datetime('now','-90 seconds')`,args:[worker]});\\n const risk:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id=? AND instance_id='LEGACY_UNATTESTED_INSTANCE'\\n AND last_poll_at>=datetime('now','-' || ? || ' seconds')`,args:[worker,LEASE_SECONDS]});\\n const recentCount=Number(recent.rows?.[0]?.n||0);\\n const riskCount=Number(risk.rows?.[0]?.n||0);\\n const legacyActive=legacyLeaseRiskLeases(1,riskCount);\\n ok(\\\"legacy_100s_not_recent_but_within_180s_lease_horizon\\\",recentCount===1 && riskCount===1,{recentCount,riskCount});\\n ok(\\\"live_legacy_origin_risk_fails_health_closed\\\",healthHttpStatus(\\\"HEALTHY\\\",0,0,legacyActive,recentCount)===503,{legacyActive,recentCount});\\n\\n ok(\\\"legacy_risk_without_active_lease_does_not_false_fail\\\",legacyLeaseRiskLeases(0,riskCount)===0);\\n ok(\\\"no_legacy_risk_with_active_attested_lease_can_be_healthy\\\",\\n healthHttpStatus(\\\"HEALTHY\\\",0,0,legacyLeaseRiskLeases(1,0),1)===200);\\n\\n await sqlite.execute({sql:`UPDATE ${T} SET last_poll_at=datetime('now','-181 seconds')\\n WHERE endpoint_host='main.example' AND instance_id='LEGACY_UNATTESTED_INSTANCE'`});\\n const past:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id=? AND instance_id='LEGACY_UNATTESTED_INSTANCE'\\n AND last_poll_at>=datetime('now','-' || ? || ' seconds')`,args:[worker,LEASE_SECONDS]});\\n ok(\\\"legacy_older_than_max_lease_horizon_no_longer_counts\\\",Number(past.rows?.[0]?.n||0)===0,{row:past.rows?.[0]});\\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 sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\n}\\nif(out.failures.length)throw new Error(\\\"LEGACY_LEASE_HORIZON_TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"instance_affinity_gap_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { healthHttpStatus, resultSql } from \\\"./brain_bridge_worker.ts\\\";\\n\\nconst JOBS=\\\"instance_affinity_gap_jobs_z7p3\\\";\\nconst WORKERS=\\\"instance_affinity_gap_workers_z7p3\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${JOBS}`);\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${WORKERS}`);\\nawait sqlite.execute(`CREATE TABLE ${JOBS}(\\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\\n)`);\\nawait sqlite.execute(`CREATE TABLE ${WORKERS}(\\n endpoint_host TEXT NOT NULL, worker_id TEXT NOT NULL, instance_id TEXT NOT NULL,\\n last_poll_at TEXT,last_result_at TEXT,lease_count INTEGER NOT NULL DEFAULT 0,result_count INTEGER NOT NULL DEFAULT 0,\\n PRIMARY KEY(endpoint_host,worker_id,instance_id)\\n)`);\\ntry{\\n const worker=\\\"project-brain-live-v1-worker-v2\\\";\\n await sqlite.execute({sql:`INSERT INTO ${WORKERS} VALUES\\n ('main.example',?,'LEGACY_UNATTESTED_INSTANCE',datetime('now','-100 seconds'),datetime('now','-100 seconds'),1,0),\\n ('main.example',?,'attested-new',datetime('now'),NULL,0,0)`,args:[worker,worker]});\\n await sqlite.execute({sql:`INSERT INTO ${JOBS}\\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\\n VALUES('legacy-origin',1,'brain','{\\\"args\\\":[\\\"verify-chain\\\"],\\\"timeout\\\":60}','LEASED',?,datetime('now','+80 seconds'),datetime('now','-100 seconds'),datetime('now','-100 seconds'))`,args:[worker]});\\n\\n const latest:any=await sqlite.execute({sql:`SELECT instance_id FROM ${WORKERS}\\n WHERE endpoint_host='main.example' AND worker_id=? ORDER BY last_poll_at DESC LIMIT 1`,args:[worker]});\\n const recent:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${WORKERS}\\n WHERE endpoint_host='main.example' AND worker_id=? AND last_poll_at>=datetime('now','-90 seconds')`,args:[worker]});\\n const leased:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${JOBS} WHERE state='LEASED' AND lease_expires_at>datetime('now')`);\\n const selected=String(latest.rows?.[0]?.instance_id||\\\"\\\");\\n const recentCount=Number(recent.rows?.[0]?.n||0);\\n const leasedCount=Number(leased.rows?.[0]?.n||0);\\n const currentLegacyActive=(selected===\\\"LEGACY_UNATTESTED_INSTANCE\\\")?leasedCount:0;\\n const currentStatus=healthHttpStatus(\\\"HEALTHY\\\",0,0,currentLegacyActive,recentCount);\\n ok(\\\"pre_repair_legacy_origin_false_green_reproduced\\\",currentStatus===200,{\\n selected,recentCount,leasedCount,currentLegacyActive,currentStatus,\\n explanation:\\\"legacy heartbeat is older than STALE_SECONDS but its 180s lease is still live\\\"\\n });\\n\\n // Current result predicate has no instance identity. A different instance sharing the logical worker id\\n // can complete the live lease. This is recorded as a bounded affinity counterexample, not yet a required\\n // production repair in this test.\\n const cross:any=await sqlite.execute({sql:resultSql(JOBS),args:[\\n \\\"COMPLETE\\\",JSON.stringify({from_instance:\\\"attested-new\\\"}),null,\\\"legacy-origin\\\",worker\\n ]});\\n const crossAccepted=(cross.rows?.length||0)===1;\\n ok(\\\"result_path_logical_worker_only_cross_instance_acceptance_reproduced\\\",crossAccepted,{crossAccepted,rows:cross.rows});\\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 sqlite.execute(`DROP TABLE IF EXISTS ${JOBS}`);\\n await sqlite.execute(`DROP TABLE IF EXISTS ${WORKERS}`);\\n}\\nif(out.failures.length)throw new Error(\\\"COUNTEREXAMPLE_REPRODUCTION_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"instance_affinity_pure_runner.ts\":\"import legacyHealth from \\\"./legacy_active_health_test.ts\\\";\\nimport heartbeatScope from \\\"./heartbeat_scope_test.ts\\\";\\n\\nconst results:any[]=[];\\nfor(const [name,fn] of [[\\\"legacy_active_health_test\\\",legacyHealth],[\\\"heartbeat_scope_test\\\",heartbeatScope]] as const){\\n try{\\n const r=fn();\\n results.push({name,ok:true,result:r});\\n }catch(e){\\n results.push({name,ok:false,error:String(e)});\\n }\\n}\\nconsole.log(JSON.stringify(results,null,2));\\nif(results.some(x=>!x.ok))throw new Error(\\\"PURE_REGRESSION_FAILURE\\\");\",\"instance_affinity_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { isAttestedInstance, leaseOneSql } from \\\"./brain_bridge_worker.ts\\\";\\nconst T=\\\"bridge_instance_affinity_test_0140\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\nconst ex=(sql:string,args:any[]=[])=>sqlite.execute({sql,args});\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`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\\n)`);\\ntry{\\n ok(\\\"legacy_not_attested\\\",!isAttestedInstance(\\\"LEGACY_UNATTESTED_INSTANCE\\\"));\\n ok(\\\"uuid_attested\\\",isAttestedInstance(\\\"c7d7f290-2f43-4fda-a997-e2133962ac83\\\"));\\n const ordinary=JSON.stringify({args:[\\\"verify-chain\\\"],timeout:60});\\n const recover=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:60});\\n\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('recover',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('ordinary',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01')`,[recover,ordinary]);\\n let r:any=await ex(leaseOneSql(T,false),[\\\"worker\\\",\\\"worker\\\"]);\\n ok(\\\"legacy_skips_recovery_and_leases_ordinary\\\",r.rows?.[0]?.id===\\\"ordinary\\\",{row:r.rows?.[0]});\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES('recover',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00')`,[recover]);\\n r=await ex(leaseOneSql(T,false),[\\\"worker\\\",\\\"worker\\\"]);\\n ok(\\\"legacy_with_only_recovery_gets_no_job\\\",(r.rows?.length||0)===0,{rows:r.rows});\\n\\n r=await ex(leaseOneSql(T,true),[\\\"worker\\\",\\\"worker\\\"]);\\n ok(\\\"attested_instance_can_lease_recovery\\\",r.rows?.[0]?.id===\\\"recover\\\",{row:r.rows?.[0]});\\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(\\\"TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"heartbeat_scope_integration.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { healthHttpStatus } from \\\"./brain_bridge_worker.ts\\\";\\nconst T=\\\"heartbeat_scope_integration_0144\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n endpoint_host TEXT NOT NULL,worker_id TEXT NOT NULL,instance_id TEXT NOT NULL,\\n last_poll_at TEXT,last_result_at TEXT,lease_count INTEGER NOT NULL DEFAULT 0,\\n result_count INTEGER NOT NULL DEFAULT 0,PRIMARY KEY(endpoint_host,worker_id,instance_id)\\n)`);\\ntry{\\n await sqlite.execute(`INSERT INTO ${T} VALUES\\n ('main.example','project-brain-live-v1-worker-v2','LEGACY_UNATTESTED_INSTANCE',datetime('now','-1 second'),datetime('now','-1 second'),110,106),\\n ('main.example','project-brain-live-v1-worker-v2','c7d7f290-2f43-4fda-a997-e2133962ac83',datetime('now','-2 seconds'),datetime('now','-190 seconds'),12,11),\\n ('main.example','project-brain-live-v1-worker-v2','70d03cb9-a66b-4bfd-8186-070849e9fc09',datetime('now','-3 seconds'),NULL,0,0),\\n ('candidate.example','project-brain-live-v1-worker-v2','candidate-only',datetime('now'),datetime('now'),1,1)`);\\n const main:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id='project-brain-live-v1-worker-v2'\\n AND last_poll_at>=datetime('now','-90 seconds')`);\\n const candidate:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='candidate.example' AND worker_id='project-brain-live-v1-worker-v2'\\n AND last_poll_at>=datetime('now','-90 seconds')`);\\n ok(\\\"three_recent_main_instances_detected\\\",Number(main.rows?.[0]?.n)===3,{row:main.rows?.[0]});\\n ok(\\\"candidate_endpoint_isolated\\\",Number(candidate.rows?.[0]?.n)===1,{row:candidate.rows?.[0]});\\n ok(\\\"main_three_instances_health_503\\\",healthHttpStatus(\\\"HEALTHY\\\",0,0,0,Number(main.rows?.[0]?.n))===503);\\n ok(\\\"candidate_single_instance_can_be_200\\\",healthHttpStatus(\\\"HEALTHY\\\",0,0,0,Number(candidate.rows?.[0]?.n))===200);\\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(\\\"TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"brain_bridge_recovery_first_test_0120.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { leaseOneSql } from \\\"./brain_bridge_worker.ts\\\";\\n\\nconst T=\\\"brain_bridge_recovery_first_test_0120\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\nconst ex=(sql:string,args:any[]=[])=>sqlite.execute({sql,args});\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n id TEXT PRIMARY KEY,\\n priority REAL NOT NULL DEFAULT 0,\\n op TEXT NOT NULL,\\n payload_json TEXT NOT NULL,\\n state TEXT NOT NULL DEFAULT 'READY',\\n lease_owner TEXT,\\n lease_expires_at TEXT,\\n result_json TEXT,\\n error_json TEXT,\\n created_at TEXT NOT NULL,\\n updated_at TEXT NOT NULL\\n)`);\\n\\ntry{\\n const ordinary=JSON.stringify({args:[\\\"status\\\"],timeout:60});\\n const recover=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:60});\\n const recoverExtraArg=JSON.stringify({args:[\\\"recover-stale\\\",\\\"oops\\\"],timeout:60});\\n const recoverExtraKey=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:60,extra:true});\\n const recoverBadTimeout=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:121});\\n const oldAlias=JSON.stringify({args:[\\\"recover-leases\\\"],timeout:60});\\n\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('ordinary-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('recover-valid',1e300,'brain',?,'READY','2026-01-01 00:00:10','2026-01-01 00:00:10')`,[ordinary,recover]);\\n let r:any=await ex(leaseOneSql(T),[\\\"w\\\",\\\"w\\\"]);\\n ok(\\\"valid_recover_preempts_older_overcap_ordinary\\\",r.rows?.[0]?.id===\\\"recover-valid\\\",{row:r.rows?.[0]});\\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL WHERE id='recover-valid'`);\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('ordinary-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('recover-extra-arg',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01'),\\n ('recover-extra-key',1e300,'brain',?,'READY','2026-01-01 00:00:02','2026-01-01 00:00:02'),\\n ('recover-bad-timeout',1e300,'brain',?,'READY','2026-01-01 00:00:03','2026-01-01 00:00:03'),\\n ('recover-old-alias',1e300,'brain',?,'READY','2026-01-01 00:00:04','2026-01-01 00:00:04')`,\\n [ordinary,recoverExtraArg,recoverExtraKey,recoverBadTimeout,oldAlias]);\\n r=await ex(leaseOneSql(T),[\\\"w2\\\",\\\"w2\\\"]);\\n ok(\\\"invalid_recovery_shapes_do_not_preempt\\\",r.rows?.[0]?.id===\\\"ordinary-old\\\",{row:r.rows?.[0]});\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('fifo-a',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('fifo-b',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01')`,[ordinary,ordinary]);\\n r=await ex(leaseOneSql(T),[\\\"w3\\\",\\\"w3\\\"]);\\n ok(\\\"ordinary_overcap_fifo_preserved\\\",r.rows?.[0]?.id===\\\"fifo-a\\\",{row:r.rows?.[0]});\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at,lease_owner,lease_expires_at) VALUES\\n ('active',1,'brain',?,'LEASED','2026-01-01 00:00:00','2026-01-01 00:00:00','w4',datetime('now','+60 seconds')),\\n ('recover-valid',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01',NULL,NULL)`,[ordinary,recover]);\\n r=await ex(leaseOneSql(T),[\\\"w4\\\",\\\"w4\\\"]);\\n ok(\\\"single_flight_still_blocks_recovery_for_busy_same_worker\\\",(r.rows?.length||0)===0,{rows:r.rows});\\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 sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\n}\\nif(out.failures.length) throw new Error(\\\"TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"brain_bridge_worker_v5_rebased_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport {\\n activeLeaseDecision,activeLeaseSql,LEASE_SECONDS,leaseOneSql,MAX_JOB_TIMEOUT,\\n normalizeDispatch,PRIORITY_CAP,recoverExpiredSql,resultSql,SUPPORTED_BRAIN_COMMANDS\\n} from \\\"./brain_bridge_worker_v5_rebased_candidate.ts\\\";\\n\\nconst T=\\\"brain_bridge_jobs_v5_test_\\\"+crypto.randomUUID().replaceAll(\\\"-\\\",\\\"\\\");\\nconst out:any={tests:[],failures:[]};\\nfunction ok(name:string,cond:boolean,detail:any={}){out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name);}\\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\\nconst oldV4Sql=(table:string)=>`UPDATE ${table}\\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+90 seconds'),updated_at=datetime('now')\\n WHERE id=(SELECT id FROM ${table} WHERE state='READY'\\n ORDER BY CASE WHEN priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE priority END DESC,created_at,id LIMIT 1)\\n RETURNING id`;\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`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)`);\\ntry{\\n const p=JSON.stringify({args:[\\\"status\\\"],timeout:60});\\n for(let i=0;i<64;i++){\\n const id=\\\"job-\\\"+String(i).padStart(3,\\\"0\\\");\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES(?,?, 'brain',?,'READY',?,?)`,\\n [id,64-i,p,\\\"2026-01-01 00:00:\\\"+String(i%60).padStart(2,\\\"0\\\"),\\\"2026-01-01 00:00:00\\\"]);\\n }\\n\\n const old:any[]=await Promise.all(Array.from({length:16},()=>ex(oldV4Sql(T),[\\\"dup-worker\\\"])));\\n const oldIds=old.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const oldActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"live_v4_toctou_reproduced\\\",oldIds.length>1 && oldActive.rows.length>1,{leased_count:oldIds.length,active_count:oldActive.rows.length});\\n\\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL,result_json=NULL,error_json=NULL`);\\n const fresh:any[]=await Promise.all(Array.from({length:32},()=>ex(leaseOneSql(T),[\\\"dup-worker\\\",\\\"dup-worker\\\"])));\\n const freshIds=fresh.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const freshActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"rebased_atomic_single_flight\\\",freshIds.length===1 && freshActive.rows.length===1,{leased_count:freshIds.length,active_count:freshActive.rows.length,id:freshIds[0]});\\n ok(\\\"active_lease_busy_not_redeliver\\\",activeLeaseDecision(freshActive.rows).kind===\\\"busy\\\",activeLeaseDecision(freshActive.rows));\\n\\n const workers=Array.from({length:16},(_,i)=>\\\"independent-\\\"+i);\\n const indep:any[]=await Promise.all(workers.map(w=>ex(leaseOneSql(T),[w,w])));\\n const indepIds=indep.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n ok(\\\"distinct_workers_progress\\\",indepIds.length===16 && new Set(indepIds).size===16,{count:indepIds.length});\\n\\n // Command surface.\\n for(const cmd of SUPPORTED_BRAIN_COMMANDS){\\n ok(\\\"command_allowed:\\\"+cmd,normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[cmd],timeout:60})).ok);\\n }\\n for(const cmd of [\\\"boot\\\",\\\"boot-agent\\\",\\\"recover-leases\\\",\\\"recover-stale\\\",\\\"record-external-artifact\\\",\\\"init\\\",\\\"nonsense\\\"]){\\n ok(\\\"command_rejected:\\\"+cmd,!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[cmd],timeout:60})).ok);\\n }\\n ok(\\\"boot_error_precise\\\",(normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"boot\\\"],timeout:60})) as any).error===\\\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\\\");\\n ok(\\\"timeout_1_allowed\\\",normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:1})).ok);\\n ok(\\\"timeout_120_allowed\\\",normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:120})).ok);\\n for(const timeout of [0,-1,121,999999,\\\"60\\\",null]){\\n ok(\\\"timeout_rejected:\\\"+String(timeout),!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout})).ok);\\n }\\n ok(\\\"brain_schema_closed\\\",!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:60,evil:true})).ok);\\n\\n ok(\\\"read_join_allowed\\\",normalizeDispatch(\\\"read_text\\\",JSON.stringify({path:\\\"/brain/JOIN_PROTOCOL.md\\\",max_bytes:200000})).ok);\\n ok(\\\"read_artifact_allowed\\\",normalizeDispatch(\\\"read_text\\\",JSON.stringify({path:\\\"/brain/artifacts/x.json\\\",max_bytes:1})).ok);\\n for(const q of [\\n {path:\\\"/brain/artifacts/../brain.db\\\",max_bytes:10},\\n {path:\\\"/brain/artifacts/\\\",max_bytes:10},\\n {path:\\\"/etc/passwd\\\",max_bytes:10},\\n {path:\\\"/brain/artifacts/x\\\",max_bytes:200001},\\n {path:\\\"/brain/artifacts/x\\\",max_bytes:10,extra:true}\\n ]) ok(\\\"read_rejected:\\\"+JSON.stringify(q),!normalizeDispatch(\\\"read_text\\\",JSON.stringify(q)).ok);\\n\\n // Priority cap means over-cap jobs are FIFO instead of escalating an arms race.\\n await ex(`UPDATE ${T} SET state='COMPLETE',lease_owner=NULL,lease_expires_at=NULL`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('overcap-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('overcap-new',1e301,'brain',?,'READY','2026-01-02 00:00:00','2026-01-02 00:00:00')`,[p,p]);\\n const cap:any=await ex(leaseOneSql(T),[\\\"cap-worker\\\",\\\"cap-worker\\\"]);\\n ok(\\\"priority_cap_fifo_over_cap\\\",cap.rows?.[0]?.id===\\\"overcap-old\\\",{row:cap.rows?.[0]});\\n\\n // Known late-result failure happened ~123 s after poll. New lease is 180 s and max command timeout is 120 s.\\n ok(\\\"lease_exceeds_known_late_result_window\\\",LEASE_SECONDS>123,{LEASE_SECONDS});\\n ok(\\\"lease_exceeds_max_command_timeout\\\",LEASE_SECONDS>MAX_JOB_TIMEOUT,{LEASE_SECONDS,MAX_JOB_TIMEOUT});\\n const capId=cap.rows?.[0]?.id;\\n const accepted:any=await ex(resultSql(T),[\\\"COMPLETE\\\",\\\"{}\\\",\\\"\\\",capId,\\\"cap-worker\\\"]);\\n ok(\\\"in_envelope_result_accepted\\\",(accepted.rows?.length||0)===1,{rows:accepted.rows});\\n\\n // Expired result fails closed and the lease remains recoverable.\\n await ex(`UPDATE ${T} SET state='LEASED',lease_owner='late-worker',lease_expires_at=datetime('now','-1 second') WHERE id='overcap-new'`);\\n const late:any=await ex(resultSql(T),[\\\"COMPLETE\\\",\\\"{}\\\",\\\"\\\", \\\"overcap-new\\\",\\\"late-worker\\\"]);\\n ok(\\\"truly_expired_result_rejected\\\",(late.rows?.length||0)===0);\\n await sqlite.execute(recoverExpiredSql(T));\\n const recovered:any=await ex(`SELECT state,lease_owner FROM ${T} WHERE id='overcap-new'`);\\n ok(\\\"expired_lease_recovered\\\",recovered.rows?.[0]?.state===\\\"READY\\\" && recovered.rows[0].lease_owner===null,{row:recovered.rows?.[0]});\\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(\\\"V5_REBASE_TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\\n\",\"brain_bridge_worker_v3_stress_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { activeLeaseSql, leaseOneSql, recoverExpiredSql } from \\\"./brain_bridge_worker_v3_candidate.ts\\\";\\n\\nconst T=\\\"brain_bridge_jobs_v3_stress_4d71\\\";\\nconst out:any={tests:[],failures:[]};\\nfunction ok(name:string,cond:boolean,detail:any={}){out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name);}\\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\\nconst oldSql=(table:string)=>`UPDATE ${table}\\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+90 seconds'),updated_at=datetime('now')\\n WHERE id=(SELECT id FROM ${table} WHERE state='READY' ORDER BY priority DESC,created_at,id LIMIT 1)\\n RETURNING id`;\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`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,\\n result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\\ntry{\\n const p=JSON.stringify({args:[\\\"status\\\"],timeout:60});\\n for(let i=0;i<64;i++){\\n const id=\\\"job-\\\"+String(i).padStart(3,\\\"0\\\");\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES(?,?, 'brain',?,'READY',?,?)`,\\n [id,64-i,p,\\\"2026-01-01 00:00:\\\"+String(i%60).padStart(2,\\\"0\\\"),\\\"2026-01-01 00:00:00\\\"]);\\n }\\n\\n const old:any[]=await Promise.all(Array.from({length:16},()=>ex(oldSql(T),[\\\"dup-worker\\\"])));\\n const oldIds=old.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const oldActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"baseline_old_sql_reproduces_multi_lease\\\",oldIds.length>1 && oldActive.rows.length>1,{leased_count:oldIds.length,active_count:oldActive.rows.length,first:oldIds.slice(0,5)});\\n\\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL,result_json=NULL,error_json=NULL`);\\n\\n const fresh:any[]=await Promise.all(Array.from({length:32},()=>ex(leaseOneSql(T),[\\\"dup-worker\\\",\\\"dup-worker\\\"])));\\n const freshIds=fresh.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const freshActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"candidate_32_duplicate_polls_single_lease\\\",freshIds.length===1 && freshActive.rows.length===1,{leased_count:freshIds.length,active_count:freshActive.rows.length,id:freshIds[0]});\\n\\n const workers=Array.from({length:16},(_,i)=>\\\"independent-\\\"+String(i).padStart(2,\\\"0\\\"));\\n const independent:any[]=await Promise.all(workers.map(w=>ex(leaseOneSql(T),[w,w])));\\n const independentIds=independent.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n ok(\\\"candidate_independent_workers_progress\\\",independentIds.length===16 && new Set(independentIds).size===16,{leased_count:independentIds.length,unique:new Set(independentIds).size});\\n\\n const all:any=await ex(`SELECT id,priority,lease_owner FROM ${T} WHERE state='LEASED' ORDER BY priority DESC,created_at,id`);\\n ok(\\\"candidate_deterministic_topology\\\",all.rows[0]?.id===\\\"job-000\\\" && all.rows[0]?.lease_owner===\\\"dup-worker\\\",{first:all.rows[0]});\\n\\n // Expire only dup-worker lease, recover, and ensure exactly that row returns to READY.\\n await ex(`UPDATE ${T} SET lease_expires_at=datetime('now','-1 second') WHERE lease_owner='dup-worker'`);\\n await sqlite.execute(recoverExpiredSql(T));\\n const recovered:any=await ex(`SELECT id,state,lease_owner FROM ${T} WHERE id='job-000'`);\\n ok(\\\"candidate_expired_recovery_preserved\\\",recovered.rows[0]?.state===\\\"READY\\\" && recovered.rows[0]?.lease_owner===null,{row:recovered.rows[0]});\\n\\n const independentStill:any=await ex(`SELECT count(*) AS n FROM ${T} WHERE state='LEASED' AND lease_owner LIKE 'independent-%'`);\\n ok(\\\"recovery_does_not_clear_live_other_workers\\\",Number(independentStill.rows[0]?.n)===16,{count:independentStill.rows[0]?.n});\\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 sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\n}\\nif(out.failures.length)throw new Error(\\\"STRESS_FAILURE:\\\"+out.failures.join(\\\",\\\"));\\n\"};\nconst enc=new TextEncoder();\nconst hex=(b:Uint8Array)=>[...b].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nconst out:any[]=[];\nfor(const [path,content] of Object.entries(files)){\n const bytes=enc.encode(content as string);\n const digest=new Uint8Array(await crypto.subtle.digest(\"SHA-256\",bytes));\n out.push({path,bytes:bytes.length,sha256:hex(digest)});\n}\nconsole.log(JSON.stringify(out,null,2));","deleted",false,"label",[47,24],"instance-affinity-z7p3","b26db1a4-9886-4203-a62c-fa490e51e9b5",["D",1788778403598],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Exact frozen Brain branch archive for bounded GC","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a07b80-917a-70c9-9bdd-76c8831d420a","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","b26db1a498864203a62cfa490e51e9b5","tursoHostname","b26db1a498864203a62cfa490e51e9b5-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789477862254],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_109":105},"org",{"_9":10,"_102":103,"_104":105,"_58":59,"_106":107,"_108":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",23,"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",{"_85":-5,"_143":144,"_145":146,"_147":148,"_149":44,"_150":44,"_151":44,"_152":34,"_153":-5,"_154":-7,"_155":-7,"_156":66,"_157":44,"_158":44,"_159":-5,"_160":44,"_161":44,"_162":44,"_163":-5},"ENV",{"_114":115,"_116":117,"_118":93,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140,"_141":142},"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"]