[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","brain-cohort-v3-p0-test-m1","path","seal4d71.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":36,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mosadek/brain-cohort-v3-p0-test-m1/code/seal4d71.ts","extension","id","59620158-7d55-4183-974a-d9573c2bd51f","fileId","01a07cbd-7cd8-7171-85aa-a6ca9d77715f","parentId","branchId","b0991504-8a60-44de-bc55-794f567855ab","branchVersion",1,"latest",true,"createdAt",["D",1788799187967],"version",0,"fileType","script","content","const files={\"worker\":\"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\\\";\\nexport const STALE_SECONDS = 90;\\nexport const DEAD_SECONDS = 180;\\nexport const PRIORITY_CAP = 1_000_000_000;\\nexport const MAX_JOB_TIMEOUT = 120;\\nexport const LEASE_SECONDS = 180;\\nexport const MAX_READ_BYTES = 200_000;\\n\\nexport const SUPPORTED_BRAIN_COMMANDS = [\\n \\\"status\\\",\\n \\\"verify-chain\\\",\\n \\\"verify-claim-graph\\\",\\n \\\"register-agent\\\",\\n \\\"ensure-task\\\",\\n \\\"delegate-task\\\",\\n \\\"claim\\\",\\n \\\"renew-lease\\\",\\n \\\"commit\\\",\\n \\\"checkpoint\\\",\\n \\\"add-claim\\\",\\n \\\"invalidate-claim\\\",\\n \\\"supersede-task-context\\\",\\n \\\"migrate-task-invariants\\\",\\n \\\"reconcile-causal-blocks\\\",\\n \\\"recover-stale\\\"\\n] as const;\\nconst SUPPORTED = new Set(SUPPORTED_BRAIN_COMMANDS);\\n\\nfunction json(v:unknown,status=200){return Response.json(v,{status});}\\nfunction tableName(table:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table))throw new Error(\\\"BAD_TABLE\\\");return table;}\\n\\nexport function classifyWorkerAge(ageSeconds:number|null){\\n if(ageSeconds===null || !Number.isFinite(ageSeconds)) return {state:\\\"UNKNOWN\\\",reason:\\\"NO_WORKER_HEARTBEAT\\\"};\\n if(ageSeconds<=STALE_SECONDS) return {state:\\\"HEALTHY\\\",reason:\\\"RECENT_WORKER_POLL\\\"};\\n if(ageSeconds<=DEAD_SECONDS) return {state:\\\"DEGRADED\\\",reason:\\\"WORKER_POLL_STALE\\\"};\\n return {state:\\\"DOWN\\\",reason:\\\"WORKER_POLL_DEAD\\\"};\\n}\\nexport function effectivePriority(x:number){if(!Number.isFinite(x))return 0;return Math.min(x,PRIORITY_CAP);}\\nexport function healthHttpStatus(workerState:string,duplicateActiveLeases:number,expiredLeases:number){\\n return workerState===\\\"HEALTHY\\\" && duplicateActiveLeases===0 && expiredLeases===0 ? 200 : 503;\\n}\\nexport function activeLeaseDecision(rows:any[]){\\n if(rows.length>1)return {kind:\\\"conflict\\\" as const,count:rows.length};\\n if(rows[0])return {kind:\\\"busy\\\" as const,active_job_id:String(rows[0].id),lease_expires_at:rows[0].lease_expires_at};\\n return {kind:\\\"free\\\" as const};\\n}\\n\\nexport function recoverExpiredSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state='READY',lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at <= datetime('now')`;\\n}\\nexport function activeLeaseSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `SELECT id,op,payload_json,priority,lease_expires_at\\n FROM ${table}\\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\\n ORDER BY lease_expires_at,id LIMIT 2`;\\n}\\nexport function leaseOneSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),updated_at=datetime('now')\\n WHERE id=(\\n SELECT j.id FROM ${table} j\\n WHERE j.state='READY'\\n AND NOT EXISTS(\\n SELECT 1 FROM ${table} x\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\n )\\n ORDER BY\\n CASE\\n WHEN j.op='brain' AND json_valid(j.payload_json)=1 THEN\\n CASE\\n WHEN json_type(j.payload_json,'$.args')='array'\\n AND json_array_length(json_extract(j.payload_json,'$.args'))=1\\n AND json_extract(j.payload_json,'$.args[0]')='recover-stale'\\n AND json_type(j.payload_json,'$.timeout')='integer'\\n AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2\\n THEN 0 ELSE 1\\n END\\n ELSE 1\\n END ASC,\\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE j.priority END DESC,\\n j.created_at,j.id\\n LIMIT 1\\n )\\n RETURNING id,op,payload_json,priority,lease_expires_at`;\\n}\\nexport function resultSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\\n RETURNING id,state`;\\n}\\n\\nexport type DispatchResult=\\n | {ok:true;payload_json:string}\\n | {ok:false;error:string};\\n\\nfunction exactKeys(q:any, expected:string[]){\\n const got=Object.keys(q).sort();\\n const want=[...expected].sort();\\n return got.length===want.length && got.every((k,i)=>k===want[i]);\\n}\\n\\nexport function normalizeDispatch(op:string,payloadJson:string):DispatchResult{\\n let q:any;try{q=JSON.parse(payloadJson)}catch{return {ok:false,error:\\\"PAYLOAD_JSON_INVALID\\\"}}\\n if(!q || typeof q!==\\\"object\\\" || Array.isArray(q))return {ok:false,error:\\\"PAYLOAD_OBJECT_REQUIRED\\\"};\\n\\n if(op===\\\"brain\\\"){\\n if(!exactKeys(q,[\\\"args\\\",\\\"timeout\\\"]))return {ok:false,error:\\\"BRAIN_PAYLOAD_SCHEMA_NOT_CLOSED\\\"};\\n if(!Array.isArray(q.args) || q.args.length<1 || q.args.some((x:any)=>typeof x!==\\\"string\\\"))return {ok:false,error:\\\"BRAIN_ARGS_INVALID\\\"};\\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>MAX_JOB_TIMEOUT)return {ok:false,error:\\\"BRAIN_TIMEOUT_INVALID\\\"};\\n const cmd=q.args[0];\\n if(cmd===\\\"boot\\\")return {ok:false,error:\\\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\\\"};\\n if(cmd===\\\"boot-agent\\\")return {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 brain_bridge_workers_v4 (\\n worker_id TEXT NOT NULL,\\n instance_id TEXT NOT NULL,\\n first_seen_at TEXT NOT NULL,\\n last_poll_at TEXT,\\n last_result_at TEXT,\\n lease_count INTEGER NOT NULL DEFAULT 0,\\n result_count INTEGER NOT NULL DEFAULT 0,\\n updated_at TEXT NOT NULL,\\n PRIMARY KEY(worker_id,instance_id)\\n )`);\\n}\\nfunction instanceOf(q:any){const v=String(q?.instance_id||\\\"\\\").trim();return v||\\\"LEGACY_UNATTESTED_INSTANCE\\\";}\\n\\nasync function workerHealth(){\\n await ensureTables();\\n const wr:any=await sqlite.execute(`\\n SELECT worker_id,instance_id,last_poll_at,last_result_at,lease_count,result_count,\\n CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) AS poll_age_seconds\\n FROM brain_bridge_workers_v4\\n ORDER BY last_poll_at DESC LIMIT 1`);\\n const w=wr.rows?.[0]||null;\\n const qc:any=await sqlite.execute({\\n sql:`SELECT\\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\\n SUM(CASE WHEN state='LEASED' THEN 1 ELSE 0 END) AS leased_count,\\n SUM(CASE WHEN state='LEASED' AND lease_expires_at <= datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\\n SUM(CASE WHEN state='READY' AND priority > ? THEN 1 ELSE 0 END) AS overcap_ready_count,\\n MIN(CASE WHEN state='READY' THEN created_at END) AS oldest_ready_at,\\n MIN(CASE WHEN state='LEASED' THEN lease_expires_at END) AS earliest_lease_expiry\\n FROM brain_bridge_jobs`,\\n args:[PRIORITY_CAP]\\n });\\n const dup:any=await sqlite.execute(`\\n SELECT COUNT(*) AS duplicate_worker_count FROM (\\n SELECT lease_owner FROM brain_bridge_jobs\\n WHERE state='LEASED' AND lease_expires_at > datetime('now') AND lease_owner IS NOT NULL\\n GROUP BY lease_owner HAVING COUNT(*) > 1\\n )`);\\n const q=qc.rows?.[0]||{};\\n const duplicateActiveLeases=Number(dup.rows?.[0]?.duplicate_worker_count||0);\\n const cls=classifyWorkerAge(w?Number(w.poll_age_seconds):null);\\n const expiredLeases=Number(q.expired_lease_count||0);\\n const status=healthHttpStatus(cls.state,duplicateActiveLeases,expiredLeases);\\n return {status,body:{\\n endpoint_ok:true,\\n service:\\\"brain-bridge-worker-v5-rebased-candidate\\\",\\n worker:w,\\n worker_state:cls.state,\\n worker_reason:cls.reason,\\n instance_identity_available:w ? w.instance_id!==\\\"LEGACY_UNATTESTED_INSTANCE\\\" : false,\\n duplicate_active_worker_leases:duplicateActiveLeases,\\n queue:q,\\n transport_priority_cap:PRIORITY_CAP,\\n max_brain_timeout_seconds:MAX_JOB_TIMEOUT,\\n queue_lease_seconds:LEASE_SECONDS,\\n selection_policy:\\\"RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT\\\",\\n atomic_single_flight:true,\\n fail_closed_http_status:status\\n }};\\n}\\n\\nasync function rejectInvalidLease(worker:string,id:string,error:string){\\n await sqlite.execute({\\n sql:`UPDATE ${JOB_TABLE}\\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\\n args:[JSON.stringify({classification:\\\"BRIDGE_DISPATCH_REJECTED\\\",error}),id,worker]\\n });\\n}\\n\\nexport default async function(req:Request):Promise{\\n const u=new URL(req.url);\\n if(req.method===\\\"GET\\\" && u.pathname.endsWith(\\\"/health\\\")){\\n const h=await workerHealth();return json(h.body,h.status);\\n }\\n if(req.method!==\\\"POST\\\")return json({ok:false,error:\\\"METHOD\\\"},405);\\n const supplied=req.headers.get(\\\"x-brain-worker-token\\\")||\\\"\\\";\\n if(!WORKER_TOKEN || supplied!==WORKER_TOKEN)return json({ok:false,error:\\\"UNAUTHORIZED\\\"},401);\\n let q:any;try{q=await req.json()}catch{return json({ok:false,error:\\\"BAD_JSON\\\"},400)}\\n await ensureTables();\\n\\n if(u.pathname.endsWith(\\\"/poll\\\")){\\n const worker=String(q.worker_id||\\\"\\\").trim();\\n if(!worker || worker.length>128)return json({ok:false,error:\\\"WORKER_REQUIRED\\\"},400);\\n const instance=instanceOf(q);\\n await sqlite.execute({\\n sql:`INSERT INTO brain_bridge_workers_v4(worker_id,instance_id,first_seen_at,last_poll_at,updated_at)\\n VALUES(?,?,datetime('now'),datetime('now'),datetime('now'))\\n ON CONFLICT(worker_id,instance_id) DO UPDATE SET last_poll_at=datetime('now'),updated_at=datetime('now')`,\\n args:[worker,instance]\\n });\\n\\n await sqlite.execute(recoverExpiredSql());\\n const ar:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\\n const before=activeLeaseDecision(ar.rows||[]);\\n if(before.kind===\\\"conflict\\\")return json({ok:false,error:\\\"MULTIPLE_ACTIVE_LEASES\\\",worker_id:worker,count:before.count},409);\\n if(before.kind===\\\"busy\\\")return json({ok:true,job:null,reason:\\\"ACTIVE_LEASE_EXISTS\\\",active_lease:{id:before.active_job_id,lease_expires_at:before.lease_expires_at},worker_id:worker,instance_id:instance});\\n\\n const r:any=await sqlite.execute({sql:leaseOneSql(),args:[worker,worker]});\\n if(!r.rows?.[0]){\\n return json({ok:true,job:null,reason:\\\"NO_READY_JOB_OR_RACED_ACTIVE_LEASE\\\",worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP});\\n }\\n\\n const row=r.rows[0];\\n const normalized=normalizeDispatch(String(row.op),String(row.payload_json));\\n if(!normalized.ok){\\n await rejectInvalidLease(worker,String(row.id),normalized.error);\\n return json({ok:true,job:null,reason:\\\"DISPATCH_REJECTED\\\",rejected_job:String(row.id),dispatch_error:normalized.error,worker_id:worker,instance_id:instance});\\n }\\n\\n await sqlite.execute({\\n sql:\\\"UPDATE brain_bridge_workers_v4 SET lease_count=lease_count+1,updated_at=datetime('now') WHERE worker_id=? AND instance_id=?\\\",\\n args:[worker,instance]\\n });\\n return json({ok:true,job:{...row,payload_json:normalized.payload_json},worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP,lease_seconds:LEASE_SECONDS});\\n }\\n\\n if(u.pathname.endsWith(\\\"/result\\\")){\\n const worker=String(q.worker_id||\\\"\\\").trim(),id=String(q.id||\\\"\\\").trim(),success=q.success===true;\\n const instance=instanceOf(q);\\n if(!worker||!id)return json({ok:false,error:\\\"BAD_RESULT_ID\\\"},400);\\n 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 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:r.rows[0].state,worker_id:worker,instance_id:instance});\\n }\\n return json({ok:false,error:\\\"NOT_FOUND\\\"},404);\\n}\\n\",\"protocol\":\"# PROJECT BRAIN VAL BRIDGE PROTOCOL V2\\n\\n## Purpose\\n\\nNormal ChatGPT project work uses Val Town as the only ChatGPT-facing transport to the canonical Project Brain. Direct Sprites connector calls are maintenance-only because they can trigger separate file-materialization approval prompts.\\n\\nNormal path:\\n\\n`ChatGPT → Val Town → brain_bridge_jobs → persistent Brain worker → canonical Brain`\\n\\nVal/project: `mosadek/project-brain-live-v1-durable` \\nQueue: `brain_bridge_jobs` \\nWorker identity: `project-brain-live-v1-worker-v2`\\n\\n## Mandatory health interpretation\\n\\nThe HTTP endpoint being reachable is NOT proof that the persistent Brain worker is alive.\\n\\nRead `brain_bridge_worker.ts /health`.\\n\\n- HTTP 200 means the most recent worker poll is fresh and the queue has no expired lease or duplicate active lease for one worker ID.\\n- HTTP 503 means fail closed. Inspect `worker_state`, `worker_reason`, queue counts, and endpoint traces.\\n- `endpoint_ok:true` only proves the Val endpoint itself is executing.\\n- `instance_identity_available:false` means the persistent worker has not yet supplied a distinct process instance ID. Do not overclaim process identity.\\n\\nCurrent Val-side invariants:\\n- priority cap: `1_000_000_000`;\\n- selection above the cap: FIFO by `created_at,id`;\\n- maximum Brain command timeout: `120 seconds`;\\n- queue lease: `180 seconds`;\\n- atomic single-flight per `worker_id`;\\n- an active unexpired lease is not redelivered to another poll sharing that worker ID;\\n- a pre-existing duplicate active lease for one worker ID fails closed;\\n- expired queue leases are returned to READY on a worker poll;\\n- results are accepted only for the current unexpired lease owner.\\n\\nThese are transport invariants, not Brain authority.\\n\\n## Submit a Brain command\\n\\nInsert a unique job:\\n\\n```sql\\nINSERT INTO brain_bridge_jobs\\n(id, priority, op, payload_json, state, lease_owner, lease_expires_at,\\n result_json, error_json, created_at, updated_at)\\nVALUES (?, ?, 'brain', ?, 'READY', NULL, NULL, NULL, NULL,\\n datetime('now'), datetime('now'))\\n```\\n\\nBrain payload is closed-schema:\\n\\n```json\\n{\\\"args\\\":[\\\"status\\\"],\\\"timeout\\\":60}\\n```\\n\\nRequirements:\\n- exact top-level keys: `args`, `timeout`;\\n- `args` is a non-empty string array;\\n- `timeout` is an integer from 1 through 120.\\n\\nCurrently allowed Brain subcommands:\\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\\nAnything else fails at Val-side dispatch rather than being sent onward.\\n\\n## Boot semantics\\n\\nThere is currently NO valid atomic `boot` bridge command.\\n\\nThe public bridge previously advertised `boot`, but the live kernel accepts `boot-agent` while the persistent executor rejects raw `boot-agent`. Therefore neither spelling is a valid end-to-end bridge operation.\\n\\nUse the proven equivalent sequence:\\n\\n1. `register-agent`\\n2. `claim`\\n\\nRegister only capabilities actually present in the current chat. Never claim `human_authority_approval`.\\n\\nExample conceptual sequence:\\n\\n```text\\nregister-agent --workstream --role \\n --type CHAT --capabilities \\n\\nclaim --agent --mode INTERACTIVE --lease-seconds 1800\\n```\\n\\nDo not submit `boot` or `boot-agent` until a later verified bridge/executor revision explicitly restores an atomic wrapper.\\n\\n## Lease recovery semantics\\n\\nDo not submit `recover-leases` or `recover-stale` through this bridge revision.\\n\\n- Val transport queue lease expiry is recovered automatically by the worker on poll.\\n- Canonical Brain task-lease recovery is a separate operation and is not currently exposed end-to-end by the persistent executor.\\n- If canonical stale-lease recovery becomes necessary, create/route a bridge-extension task or use another verified non-Sprites route. Do not guess an alias.\\n\\n## Poll a job result\\n\\n```sql\\nSELECT id,state,lease_owner,lease_expires_at,result_json,error_json,updated_at\\nFROM brain_bridge_jobs\\nWHERE id=?\\n```\\n\\nTerminal states:\\n- COMPLETE\\n- FAILED\\n\\nA READY job means it has not been executed. A LEASED job is not complete. Do not infer canonical mutation from queue state alone.\\n\\n## Read Brain text without Sprites\\n\\nUse `op='read_text'` with exact closed-schema payload:\\n\\n```json\\n{\\\"path\\\":\\\"/brain/JOIN_PROTOCOL.md\\\",\\\"max_bytes\\\":200000}\\n```\\n\\nAllowed paths:\\n- exactly `/brain/JOIN_PROTOCOL.md`;\\n- a non-directory file strictly below `/brain/artifacts/`.\\n\\nConstraints:\\n- `max_bytes`: integer 1..200000;\\n- no `.` or `..` path segments;\\n- no backslash or NUL;\\n- no extra payload fields.\\n\\nEarlier worker stalls coincided with read jobs, but later bounded artifact reads completed successfully. Therefore do not claim that `read_text` itself caused the historical stall. Keep the bounded allowlist and use current worker health as the liveness signal.\\n\\n## Hard transport rule\\n\\nRoutine ChatGPT work:\\n- DO NOT call Sprites;\\n- DO NOT call Sprites.exec;\\n- DO NOT call Sprites.file_read/file_write/file_copy/file_delete;\\n- DO NOT call Sprites service/checkpoint/file/blob operations.\\n\\nIf a required operation is missing:\\n1. use an existing valid non-Sprites substrate when possible;\\n2. route or build a bridge extension;\\n3. fail closed if the missing operation is necessary;\\n4. direct Sprites remains an explicit maintenance emergency, not an automatic fallback.\\n\\n## Failure behavior\\n\\nIf jobs stay READY:\\n1. inspect `/health`;\\n2. inspect worker endpoint traces;\\n3. inspect the current active/expired queue leases;\\n4. do not raise transport priorities above the cap to win a queue arms race;\\n5. do not interpret the Val endpoint being online as the Brain worker being online.\\n\\nIf worker health is DOWN:\\n- queued commands remain pending;\\n- no live Brain registration, claim, commit, status, or verification should be invented;\\n- Val-side code/evidence work may continue when it does not pretend to mutate canonical Brain;\\n- repair/restore the persistent executor through an authorized route, then resume queue processing.\\n\\n## Proven facts and bounded claims\\n\\nThe reverse bridge has successfully:\\n- read Brain status;\\n- created canonical Brain tasks;\\n- registered CHAT agents;\\n- claimed tasks;\\n- committed task results;\\n- run verify-chain and verify-claim-graph.\\n\\nThe Val-side worker has independently reproduced and repaired the same-worker concurrent lease race in isolated queue tests. This does NOT prove the persistent Sprite-side executor is permanently supervised or continuously alive.\\n\\n## Goal\\n\\nNormal project work must stay materialization-free from ChatGPT while remaining fail-closed:\\n\\n`ChatGPT agent → Val Town → durable queue → live worker → verified Brain`\\n\\nIf the live worker disappears, the system must say so rather than smiling with HTTP 200 like a malfunctioning status page.\\n\",\"bootstrap\":\"# PROJECT BRAIN CHAT BOOTSTRAP V3 — VAL-ONLY / NO SPRITES\\n\\n## Non-negotiable transport rule\\n\\nFor normal ChatGPT project work, do not invoke the Sprites ChatGPT connector.\\n\\nUse:\\n`ChatGPT → Val Town → brain_bridge_jobs → persistent worker → canonical Brain`\\n\\nVal/project: `mosadek/project-brain-live-v1-durable` \\nProtocol: `BRAIN_VAL_BRIDGE_PROTOCOL.md`\\n\\nThe first external project call in a new chat is Val Town, not Sprites.\\n\\n## Fail-closed boot sequence\\n\\n1. Read this bootstrap and the current `BRAIN_VAL_BRIDGE_PROTOCOL.md` through Val Town.\\n2. Read `brain_bridge_worker.ts /health`.\\n3. If health is not HTTP 200 with a fresh worker heartbeat, fail closed for live Brain operations. Do not confuse `endpoint_ok` with a live executor.\\n4. Submit a unique `status` Brain job with an integer timeout ≤120.\\n5. Wait for that exact job to become COMPLETE or FAILED.\\n6. Run `verify-chain` and `verify-claim-graph`.\\n7. Determine the correct workstream from verified live state.\\n8. Register a unique CHAT agent with `register-agent`, declaring only capabilities actually present.\\n9. Never claim `human_authority_approval`.\\n10. Claim a causally ready task with `claim`.\\n11. Continue through the Val queue.\\n\\n## Important: no atomic boot alias\\n\\nDo NOT submit `boot` or raw `boot-agent`.\\n\\nThe old bridge documentation was wrong end-to-end:\\n- live Brain kernel command: `boot-agent`;\\n- persistent executor currently rejects raw `boot-agent`;\\n- old public bridge alias `boot` reached Brain literally and failed argparse.\\n\\nCurrent proven boot equivalent:\\n\\n`register-agent → claim`\\n\\nThis preserves the kernel’s registration and scheduler semantics without inventing an unavailable wrapper.\\n\\n## Queue contract\\n\\nBrain payload:\\n\\n```json\\n{\\\"args\\\":[\\\"status\\\"],\\\"timeout\\\":60}\\n```\\n\\nCurrent transport limits:\\n- priority cap: 1,000,000,000;\\n- all over-cap priorities tie and use FIFO;\\n- Brain timeout: 1..120 seconds;\\n- queue lease: 180 seconds;\\n- atomic single-flight per worker ID;\\n- no redelivery while a worker has an unexpired active lease.\\n\\nDo not try to defeat queue fairness by using huge floating-point priorities. Humanity already ran that experiment.\\n\\n## Supported Brain commands\\n\\nCurrently allowed:\\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\\nCurrently unavailable end-to-end:\\n- boot\\n- boot-agent\\n- recover-leases\\n- recover-stale\\n- arbitrary/unlisted brain.py subcommands\\n\\nIf an unavailable operation is required, route a bridge-extension task. Do not guess aliases.\\n\\n## Read-only Brain text\\n\\nUse `op='read_text'` only for:\\n- `/brain/JOIN_PROTOCOL.md`;\\n- non-directory files below `/brain/artifacts/`.\\n\\nMaximum 200,000 bytes. Closed payload schema. No traversal segments.\\n\\n## Worker health\\n\\nThe Val endpoint can be alive while the persistent worker is dead.\\n\\nTreat:\\n- HTTP 200 = transport worker heartbeat currently healthy;\\n- HTTP 503 = degraded/down/inconsistent transport. Inspect the response and traces.\\n\\nWhen health is 503, queued jobs may remain READY. Do not invent their results.\\n\\n## Direct Sprites emergency boundary\\n\\nDirect Sprites is not an automatic fallback.\\n\\nUse a non-Sprites route or extend the bridge first. Direct Sprites is reserved for an explicitly authorized maintenance emergency after acknowledging it can trigger the platform materialization approval.\\n\\n## After every task\\n\\n1. preserve consequential evidence and hashes;\\n2. reconcile current workstream generation;\\n3. commit through the Brain;\\n4. verify chain/claim graph when consequential;\\n5. claim the next eligible task;\\n6. continue unless mission complete or a genuine external boundary remains.\\n\\n## Goal\\n\\nA new chat must be able to join the same canonical Brain without recurring Sprites connector approvals, while failures remain visible instead of being laundered into fake liveness.\\n\",\"regression\":\"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\\n} from \\\"./brain_bridge_worker.ts\\\";\\n\\nconst T=\\\"brain_bridge_live_reg_\\\"+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 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'\\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(`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 await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES(?,?, 'brain',?,'READY',?,?)`,\\n [\\\"job-\\\"+String(i).padStart(3,\\\"0\\\"),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 ok(\\\"baseline_old_sql_multi_lease\\\",oldIds.length>1,{leased:oldIds.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 active:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"live_atomic_single_flight\\\",freshIds.length===1 && active.rows.length===1,{leased:freshIds.length,active:active.rows.length,id:freshIds[0]});\\n ok(\\\"live_active_not_redelivered\\\",activeLeaseDecision(active.rows).kind===\\\"busy\\\",activeLeaseDecision(active.rows));\\n\\n const workers=Array.from({length:16},(_,i)=>\\\"worker-\\\"+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(\\\"live_distinct_workers_progress\\\",indepIds.length===16 && new Set(indepIds).size===16,{count:indepIds.length});\\n\\n for(const cmd of [\\\"status\\\",\\\"verify-chain\\\",\\\"verify-claim-graph\\\",\\\"register-agent\\\",\\\"claim\\\",\\\"renew-lease\\\",\\\"commit\\\",\\\"checkpoint\\\"]){\\n ok(\\\"allowed_\\\"+cmd,normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[cmd],timeout:60})).ok);\\n }\\n ok(\\\"boot_rejected\\\",!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"boot\\\"],timeout:60})).ok);\\n ok(\\\"raw_boot_agent_rejected\\\",!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"boot-agent\\\"],timeout:60})).ok);\\n ok(\\\"recover_leases_rejected\\\",!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"recover-leases\\\"],timeout:60})).ok);\\n ok(\\\"timeout_120_allowed\\\",normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:120})).ok);\\n ok(\\\"timeout_121_rejected\\\",!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:121})).ok);\\n ok(\\\"open_brain_schema_rejected\\\",!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:60,extra: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 ok(\\\"read_traversal_rejected\\\",!normalizeDispatch(\\\"read_text\\\",JSON.stringify({path:\\\"/brain/artifacts/../brain.db\\\",max_bytes:10})).ok);\\n ok(\\\"read_directory_rejected\\\",!normalizeDispatch(\\\"read_text\\\",JSON.stringify({path:\\\"/brain/artifacts/\\\",max_bytes:10})).ok);\\n ok(\\\"read_oversize_rejected\\\",!normalizeDispatch(\\\"read_text\\\",JSON.stringify({path:\\\"/brain/artifacts/x\\\",max_bytes:200001})).ok);\\n\\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(\\\"live_priority_cap_fifo\\\",cap.rows?.[0]?.id===\\\"overcap-old\\\",{row:cap.rows?.[0]});\\n ok(\\\"lease_exceeds_max_timeout\\\",LEASE_SECONDS>MAX_JOB_TIMEOUT,{LEASE_SECONDS,MAX_JOB_TIMEOUT});\\n\\n const capId=cap.rows?.[0]?.id;\\n const accepted:any=await ex(resultSql(T),[\\\"COMPLETE\\\",\\\"{}\\\",\\\"\\\",capId,\\\"cap-worker\\\"]);\\n ok(\\\"valid_result_accepted\\\",(accepted.rows?.length||0)===1);\\n\\n await ex(`UPDATE ${T} SET state='LEASED',lease_owner='late',lease_expires_at=datetime('now','-1 second') WHERE id='overcap-new'`);\\n const late:any=await ex(resultSql(T),[\\\"COMPLETE\\\",\\\"{}\\\",\\\"\\\", \\\"overcap-new\\\",\\\"late\\\"]);\\n ok(\\\"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 const rs=normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"recover-stale\\\"],timeout:60}));\\n out.observation={recover_stale_val_dispatch_allowed:rs.ok,separate_global_alias_task_required:true};\\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(\\\"LIVE_SINGLEFLIGHT_REGRESSION_FAILURE:\\\"+out.failures.join(\\\",\\\"));\\n\"};\nasync function h(s:string){\n const b=new TextEncoder().encode(s);\n const d=await crypto.subtle.digest(\"SHA-256\",b);\n return {bytes:b.length,sha256:[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")};\n}\nconst out:any={};\nfor(const [k,v] of Object.entries(files)) out[k]=await h(v as string);\nconsole.log(JSON.stringify(out));\n","deleted",false,"label",[14],"d9af2f28-3492-4111-98aa-ad7443cd8663",["D",1788799187967],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Isolated V3 cohort P0 repair test","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a07cbd-7cda-7441-ac3e-cf192087c1d5","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","d9af2f283492411198aaad7443cd8663","tursoHostname","d9af2f283492411198aaad7443cd8663-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494036282],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",37,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":36,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]