[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_254":255,"_256":257},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":25,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",17,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","hash_evidence.ts","latestPath","fileId","e1d74662-a997-11f1-b89a-1607ee4eb77e","name","fileType","script","content","const files={\"candidate_v2r1.sql\":\"WITH\\ninput(raw) AS (VALUES (?)),\\nmeta AS (\\n SELECT raw,\\n json_valid(raw) AS is_json,\\n CASE WHEN json_valid(raw) THEN json_type(raw) ELSE NULL END AS root_type,\\n length(raw) AS raw_len\\n FROM input\\n),\\nsel AS (\\n SELECT CAST(je.key AS INTEGER) AS idx, je.value AS job_id, je.type AS value_type\\n FROM meta,\\n json_each(CASE WHEN is_json=1 AND root_type='array' THEN raw ELSE '[]' END) AS je\\n),\\nsel_stats AS (\\n SELECT\\n (SELECT is_json FROM meta) AS is_json,\\n (SELECT root_type FROM meta) AS root_type,\\n (SELECT raw_len FROM meta) AS raw_len,\\n COUNT(*) AS item_count,\\n SUM(CASE WHEN value_type!='text' THEN 1 ELSE 0 END) AS non_text_count,\\n SUM(CASE WHEN value_type='text' AND (length(job_id)<1 OR length(job_id)>256) THEN 1 ELSE 0 END) AS bad_length_count,\\n COUNT(DISTINCT CASE WHEN value_type='text' THEN job_id END) AS distinct_text_count\\n FROM sel\\n),\\nvalidation AS (\\n SELECT CASE\\n WHEN is_json!=1 THEN 'JOBS_JSON_INVALID'\\n WHEN root_type!='array' THEN 'JOBS_ARRAY_REQUIRED'\\n WHEN raw_len>4096 THEN 'JOBS_SELECTOR_TOO_LARGE'\\n WHEN item_count>16 THEN 'TOO_MANY_JOB_IDS'\\n WHEN COALESCE(non_text_count,0)>0 THEN 'JOB_ID_STRING_REQUIRED'\\n WHEN COALESCE(bad_length_count,0)>0 THEN 'JOB_ID_LENGTH_INVALID'\\n WHEN item_count!=distinct_text_count THEN 'DUPLICATE_JOB_ID'\\n ELSE NULL\\n END AS selector_error\\n FROM sel_stats\\n),\\nclock AS (SELECT datetime('now') AS now_ts),\\nworker_rows AS (\\n SELECT\\n instance_id,last_poll_at,last_result_at,lease_count,result_count,\\n ((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS poll_age_seconds_raw,\\n CAST(((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS INTEGER) AS poll_age_seconds\\n FROM brain_bridge_workers_v4\\n WHERE worker_id='project-brain-live-v1-worker-v2' AND last_poll_at IS NOT NULL\\n),\\nworker_agg AS (\\n SELECT\\n COUNT(*) AS total_instances,\\n SUM(CASE WHEN poll_age_seconds_raw<0 THEN 1 ELSE 0 END) AS future_instances,\\n SUM(CASE WHEN poll_age_seconds_raw>=0 AND poll_age_seconds_raw<=90 THEN 1 ELSE 0 END) AS fresh_instances,\\n SUM(CASE WHEN poll_age_seconds_raw>90 AND poll_age_seconds_raw<=180 THEN 1 ELSE 0 END) AS degraded_instances\\n FROM worker_rows\\n),\\nlatest_worker AS (\\n SELECT * FROM worker_rows ORDER BY last_poll_at DESC, instance_id DESC LIMIT 1\\n),\\nqueue_stats AS (\\n 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'\\n AND (lease_owner IS NULL OR trim(lease_owner)='' OR lease_expires_at IS NULL OR julianday(lease_expires_at) IS NULL)\\n THEN 1 ELSE 0 END) AS malformed_lease_count,\\n SUM(CASE WHEN state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\\n SUM(CASE WHEN state='READY' AND priority>1000000000 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),\\ndup_active AS (\\n SELECT COUNT(*) AS duplicate_worker_count FROM (\\n SELECT lease_owner\\n 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),\\nready_order AS (\\n SELECT\\n id,\\n CASE\\n WHEN op='brain' AND json_valid(payload_json)=1 THEN\\n CASE\\n WHEN json_type(payload_json,'$.args')='array'\\n AND json_array_length(json_extract(payload_json,'$.args'))=1\\n AND json_extract(payload_json,'$.args[0]')='recover-stale'\\n AND json_type(payload_json,'$.timeout')='integer'\\n AND json_extract(payload_json,'$.timeout') BETWEEN 1 AND 120\\n AND (SELECT COUNT(*) FROM json_each(payload_json))=2\\n THEN 0 ELSE 1\\n END\\n ELSE 1\\n END AS recovery_class,\\n CASE WHEN priority>1000000000 THEN 1000000000 ELSE priority END AS effective_priority,\\n created_at\\n FROM brain_bridge_jobs\\n WHERE state='READY'\\n),\\nranked_ready AS (\\n SELECT\\n id,\\n ROW_NUMBER() OVER (ORDER BY recovery_class ASC,effective_priority DESC,created_at ASC,id ASC)-1 AS transport_ready_ahead\\n FROM ready_order\\n),\\nselected AS (\\n SELECT\\n s.idx,s.job_id AS id,COALESCE(j.state,'MISSING') AS state,j.priority,\\n CASE WHEN j.priority>1000000000 THEN 1000000000 ELSE j.priority END AS effective_priority,\\n j.lease_owner,j.lease_expires_at,j.updated_at,\\n CASE WHEN j.result_json IS NOT NULL THEN 1 ELSE 0 END AS result_available,\\n CASE WHEN j.error_json IS NOT NULL THEN 1 ELSE 0 END AS error_available,\\n CASE WHEN j.id IS NOT NULL AND j.state IN ('COMPLETE','FAILED') THEN 1 ELSE 0 END AS terminal,\\n CASE WHEN j.state='READY' THEN rr.transport_ready_ahead ELSE NULL END AS transport_ready_ahead\\n FROM sel AS s\\n LEFT JOIN brain_bridge_jobs AS j ON j.id=s.job_id\\n LEFT JOIN ranked_ready AS rr ON rr.id=j.id\\n WHERE (SELECT selector_error FROM validation) IS NULL\\n ORDER BY s.idx\\n),\\njobs_agg AS (\\n SELECT json_group_array(json_object(\\n 'id',id,\\n 'state',state,\\n 'priority',priority,\\n 'effective_priority',effective_priority,\\n 'lease_owner',lease_owner,\\n 'lease_expires_at',lease_expires_at,\\n 'updated_at',updated_at,\\n 'result_available',result_available,\\n 'error_available',error_available,\\n 'terminal',terminal,\\n 'transport_ready_ahead',transport_ready_ahead\\n )) AS jobs_json\\n FROM selected\\n)\\nSELECT json_object(\\n 'schema','BRAIN_CONTROL_READMUX_V2',\\n 'observed_at',(SELECT now_ts FROM clock),\\n 'selector_error',(SELECT selector_error FROM validation),\\n 'worker',json_object(\\n 'worker_id','project-brain-live-v1-worker-v2',\\n 'state',(\\n SELECT CASE\\n WHEN future_instances>0 THEN 'FUTURE_HEARTBEAT_FAIL_CLOSED'\\n WHEN total_instances=0 THEN 'UNKNOWN'\\n WHEN fresh_instances=1 THEN 'HEALTHY'\\n WHEN fresh_instances>1 THEN 'AMBIGUOUS_FAIL_CLOSED'\\n WHEN degraded_instances>0 THEN 'DEGRADED'\\n ELSE 'DOWN'\\n END FROM worker_agg\\n ),\\n 'latest_instance_id',(SELECT instance_id FROM latest_worker),\\n 'latest_poll_age_seconds',(SELECT poll_age_seconds FROM latest_worker),\\n 'future_instance_count',COALESCE((SELECT future_instances FROM worker_agg),0),\\n 'fresh_instance_count',COALESCE((SELECT fresh_instances FROM worker_agg),0),\\n 'degraded_instance_count',COALESCE((SELECT degraded_instances FROM worker_agg),0),\\n 'endpoint_scope_attested',0\\n ),\\n 'queue',json_object(\\n 'ready_count',COALESCE((SELECT ready_count FROM queue_stats),0),\\n 'leased_count',COALESCE((SELECT leased_count FROM queue_stats),0),\\n 'malformed_lease_count',COALESCE((SELECT malformed_lease_count FROM queue_stats),0),\\n 'expired_lease_count',COALESCE((SELECT expired_lease_count FROM queue_stats),0),\\n 'duplicate_active_worker_leases',COALESCE((SELECT duplicate_worker_count FROM dup_active),0),\\n 'gate',CASE\\n WHEN COALESCE((SELECT malformed_lease_count FROM queue_stats),0)>0 THEN 'MALFORMED_LEASE_METADATA'\\n WHEN COALESCE((SELECT expired_lease_count FROM queue_stats),0)>0 THEN 'EXPIRED_LEASE_PRESENT'\\n WHEN COALESCE((SELECT duplicate_worker_count FROM dup_active),0)>0 THEN 'DUPLICATE_ACTIVE_WORKER_LEASE'\\n ELSE 'PASS'\\n END,\\n 'overcap_ready_count',COALESCE((SELECT overcap_ready_count FROM queue_stats),0),\\n 'oldest_ready_at',(SELECT oldest_ready_at FROM queue_stats),\\n 'earliest_lease_expiry',(SELECT earliest_lease_expiry FROM queue_stats),\\n 'transport_priority_cap',1000000000,\\n 'selection_policy','RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT'\\n ),\\n 'jobs',json(COALESCE((SELECT jobs_json FROM jobs_agg),'[]'))\\n) AS snapshot_json\",\"candidate_v2r1_poll.ts\":\"export type WorkerState=\\\"HEALTHY\\\"|\\\"DEGRADED\\\"|\\\"DOWN\\\"|\\\"UNKNOWN\\\"|\\\"AMBIGUOUS_FAIL_CLOSED\\\"|\\\"FUTURE_HEARTBEAT_FAIL_CLOSED\\\";\\nexport type QueueGate=\\\"PASS\\\"|\\\"MALFORMED_LEASE_METADATA\\\"|\\\"EXPIRED_LEASE_PRESENT\\\"|\\\"DUPLICATE_ACTIVE_WORKER_LEASE\\\";\\n\\nexport function stableStaggerMs(agentId:string){\\n let h=2166136261>>>0;\\n for(const ch of agentId){\\n h^=ch.codePointAt(0)??0;\\n h=Math.imul(h,16777619)>>>0;\\n }\\n return h%2000;\\n}\\n\\nexport function classifyWorker(total:number,fresh:number,degraded:number,future=0):WorkerState{\\n if(future>0)return \\\"FUTURE_HEARTBEAT_FAIL_CLOSED\\\";\\n if(total===0)return \\\"UNKNOWN\\\";\\n if(fresh===1)return \\\"HEALTHY\\\";\\n if(fresh>1)return \\\"AMBIGUOUS_FAIL_CLOSED\\\";\\n if(degraded>0)return \\\"DEGRADED\\\";\\n return \\\"DOWN\\\";\\n}\\n\\nexport function queueGate(expired:number,duplicates:number,malformed=0):QueueGate{\\n if(malformed>0)return \\\"MALFORMED_LEASE_METADATA\\\";\\n if(expired>0)return \\\"EXPIRED_LEASE_PRESENT\\\";\\n if(duplicates>0)return \\\"DUPLICATE_ACTIVE_WORKER_LEASE\\\";\\n return \\\"PASS\\\";\\n}\\n\\nexport type WatchedJobObservation={\\n id?:string,\\n state:string,\\n updated_at?:string|null,\\n transport_ready_ahead?:number|null\\n};\\n\\nexport function observationIdentity(input:{\\n rateLimited?:boolean,\\n workerState:WorkerState,\\n workerInstanceId?:string|null,\\n queueGate:QueueGate|string,\\n jobs:WatchedJobObservation[]\\n}):string{\\n return JSON.stringify({\\n rateLimited:input.rateLimited===true,\\n workerState:input.workerState,\\n workerInstanceId:input.workerInstanceId??null,\\n queueGate:input.queueGate,\\n jobs:input.jobs.map(j=>({\\n id:j.id??null,\\n state:j.state,\\n updated_at:j.updated_at??null,\\n transport_ready_ahead:Number.isInteger(j.transport_ready_ahead)?Number(j.transport_ready_ahead):null\\n }))\\n });\\n}\\n\\nexport function advanceObservationState(\\n previousIdentity:string|null,\\n currentIdentity:string,\\n previousUnchangedReads:number\\n){\\n const prev=Math.max(0,Math.min(4,Math.trunc(previousUnchangedReads||0)));\\n const same=previousIdentity!==null&&previousIdentity===currentIdentity;\\n return {\\n identity:currentIdentity,\\n unchangedReads:same?Math.min(4,prev+1):0,\\n changed:previousIdentity===null||!same\\n };\\n}\\n\\nexport function nextPollSeconds(input:{\\n rateLimited?:boolean,\\n workerState:WorkerState,\\n queueGate?:QueueGate|string,\\n jobs:Array<{state:string,transport_ready_ahead?:number|null}>,\\n unchangedReads:number\\n}):number|null{\\n const unchanged=Math.max(0,Math.min(4,Math.trunc(input.unchangedReads||0)));\\n if(input.jobs.length>0&&input.jobs.every(j=>j.state===\\\"COMPLETE\\\"||j.state===\\\"FAILED\\\"))return null;\\n if(input.rateLimited)return Math.min(60,30*(2**Math.min(unchanged,1)));\\n if(input.queueGate&&input.queueGate!==\\\"PASS\\\")return Math.min(60,15*(2**Math.min(unchanged,2)));\\n if(input.workerState!==\\\"HEALTHY\\\")return Math.min(60,15*(2**Math.min(unchanged,2)));\\n if(input.jobs.some(j=>j.state===\\\"LEASED\\\"))return Math.min(30,5*(2**Math.min(unchanged,2)));\\n const ahead=input.jobs\\n .filter(j=>j.state===\\\"READY\\\"&&Number.isInteger(j.transport_ready_ahead))\\n .map(j=>Number(j.transport_ready_ahead));\\n let base=15;\\n if(ahead.length){\\n const n=Math.min(...ahead);\\n base=n===0?3:n<=3?5:n<=10?10:20;\\n }\\n return Math.min(60,base*(2**Math.min(unchanged,2)));\\n}\\n\\nexport function nextPollDecision(input:{\\n previousIdentity:string|null,\\n previousUnchangedReads:number,\\n rateLimited?:boolean,\\n workerState:WorkerState,\\n workerInstanceId?:string|null,\\n queueGate:QueueGate|string,\\n jobs:WatchedJobObservation[]\\n}){\\n const identity=observationIdentity({\\n rateLimited:input.rateLimited,\\n workerState:input.workerState,\\n workerInstanceId:input.workerInstanceId,\\n queueGate:input.queueGate,\\n jobs:input.jobs\\n });\\n const state=advanceObservationState(input.previousIdentity,identity,input.previousUnchangedReads);\\n return {\\n ...state,\\n seconds:nextPollSeconds({\\n rateLimited:input.rateLimited,\\n workerState:input.workerState,\\n queueGate:input.queueGate,\\n jobs:input.jobs,\\n unchangedReads:state.unchangedReads\\n })\\n };\\n}\\n\",\"v2r1_rate_transition_test.ts\":\"import { observationIdentity, nextPollDecision } from \\\"./candidate_v2r1_poll.ts\\\";\\nconst obs={workerState:\\\"HEALTHY\\\" as const,workerInstanceId:\\\"i-rate\\\",queueGate:\\\"PASS\\\",jobs:[{id:\\\"j-rate\\\",state:\\\"READY\\\",updated_at:\\\"t\\\",transport_ready_ahead:0}]};\\nconst identityNormal=observationIdentity({...obs,rateLimited:false});\\nconst first429=nextPollDecision({previousIdentity:identityNormal,previousUnchangedReads:4,rateLimited:true,...obs});\\nconst identity429=first429.identity;\\nconst second429=nextPollDecision({previousIdentity:identity429,previousUnchangedReads:first429.unchangedReads,rateLimited:true,...obs});\\nconst recovered=nextPollDecision({previousIdentity:second429.identity,previousUnchangedReads:second429.unchangedReads,rateLimited:false,...obs});\\nconst cases=[\\n {name:\\\"enter 429 resets identity/backoff\\\",actual:[first429.changed,first429.unchangedReads,first429.seconds],expected:[true,0,30]},\\n {name:\\\"repeat 429 advances to 60\\\",actual:[second429.changed,second429.unchangedReads,second429.seconds],expected:[false,1,60]},\\n {name:\\\"clear 429 resets normal base\\\",actual:[recovered.changed,recovered.unchangedReads,recovered.seconds],expected:[true,0,3]}\\n].map(x=>({...x,pass:JSON.stringify(x.actual)===JSON.stringify(x.expected)}));\\nconsole.log(JSON.stringify({schema:\\\"READMUX_V2R1_RATE_LIMIT_TRANSITION_TEST_V1\\\",ok:cases.every(x=>x.pass),cases}));\"};\nfor(const [path,s] of Object.entries(files)){const b=new TextEncoder().encode(s);const h=await crypto.subtle.digest(\"SHA-256\",b);console.log(JSON.stringify({path,bytes:b.length,sha256:[...new Uint8Array(h)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}));}","const s=\"{\\n \\\"schema\\\": \\\"BRAIN_VAL_CONTROL_READMUX_V2R1_REPAIR_CANDIDATE_PROOF_V1\\\",\\n \\\"source_validation_task\\\": \\\"BRAIN-VAL-CONTROL-PLANE-READMUX-V2-INDEPENDENT-VALIDATION-20260906\\\",\\n \\\"agent_id\\\": \\\"chat-bbn-20260906-0353-sol-a7c94f\\\",\\n \\\"classification\\\": \\\"CANDIDATE_NONAUTHORITY_REPAIR_PASS_LOCAL_AND_LIVE_READ_ONLY\\\",\\n \\\"parent_falsification\\\": {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-v1.json\\\",\\n \\\"bytes\\\": 6756,\\n \\\"sha256\\\": \\\"bf98b3b5de13301318dd7ee4af80559f16c78f8cf2467a2a49a19fda3a13da0e\\\"\\n },\\n \\\"prior_repair_supplement\\\": {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-repair-proof-v1.json\\\",\\n \\\"bytes\\\": 2271,\\n \\\"sha256\\\": \\\"12507f14e8b5d466b0a84b70bddf67630736640ce78942d34b47faa762a71451\\\"\\n },\\n \\\"repair_val\\\": \\\"mosadek/brain-readmux-v2-review-a7c94f\\\",\\n \\\"candidate_artifacts\\\": [\\n {\\n \\\"path\\\": \\\"candidate_v2r1.sql\\\",\\n \\\"bytes\\\": 7835,\\n \\\"sha256\\\": \\\"c38cd379147874928fd796c959cfd3326b4c989e0c3489e3a930011737be5d3c\\\"\\n },\\n {\\n \\\"path\\\": \\\"candidate_v2r1_poll.ts\\\",\\n \\\"bytes\\\": 4049,\\n \\\"sha256\\\": \\\"ffb7bd495e82d9ec3cfb3fba0095d2b2336d4065c4ae5c8f6edc577f1614d850\\\"\\n },\\n {\\n \\\"path\\\": \\\"v2r1_sql_adv_test.ts\\\",\\n \\\"bytes\\\": 16701,\\n \\\"sha256\\\": \\\"adcbef7b20f12f7a1a30d01cca9c535441f343b249b0889acb52976b60efc6f0\\\"\\n },\\n {\\n \\\"path\\\": \\\"v2r1_rate_transition_test.ts\\\",\\n \\\"bytes\\\": 1349,\\n \\\"sha256\\\": \\\"a4851dbf0b9806fdfec30f962af703767a742d7f21e6e672cd98c45048d6874a\\\"\\n }\\n ],\\n \\\"repairs\\\": [\\n {\\n \\\"id\\\": \\\"D4_MISSING_WATCHED_ID_FALSE_TERMINAL_STOP\\\",\\n \\\"mechanism\\\": \\\"SQL preserves every requested selector ID via LEFT JOIN; unmatched IDs are explicit state=MISSING, terminal=0.\\\",\\n \\\"poller_change_required\\\": false\\n },\\n {\\n \\\"id\\\": \\\"D5_RATE_LIMIT_TRANSITION_NOT_IN_OBSERVATION_IDENTITY\\\",\\n \\\"mechanism\\\": \\\"rateLimited boolean is added to observationIdentity and nextPollDecision identity construction, resetting state on 429 enter/clear.\\\"\\n }\\n ],\\n \\\"verification\\\": {\\n \\\"patched_v2_unit\\\": \\\"36/36 PASS\\\",\\n \\\"patched_poller_adversarial\\\": \\\"21/21 PASS\\\",\\n \\\"patched_sql_adversarial\\\": \\\"26/26 PASS\\\",\\n \\\"patched_rate_limit_transition\\\": \\\"3/3 PASS\\\",\\n \\\"missing_id_composition_repair\\\": \\\"explicit MISSING row keeps polling active\\\",\\n \\\"one_bound_sql_parameter\\\": true,\\n \\\"static_sql_mutation_tokens\\\": 0,\\n \\\"sql_semicolons\\\": 0\\n },\\n \\\"live_repaired_read\\\": {\\n \\\"observed_at_utc\\\": \\\"2026-09-06T02:14:40Z\\\",\\n \\\"requested_count\\\": 3,\\n \\\"returned_count\\\": 3,\\n \\\"jobs\\\": [\\n {\\n \\\"id\\\": \\\"chat-sol-20260906-0353-a7c94f-status\\\",\\n \\\"state\\\": \\\"COMPLETE\\\",\\n \\\"terminal\\\": 1\\n },\\n {\\n \\\"id\\\": \\\"chat-sol-20260906-0353-a7c94f-claim\\\",\\n \\\"state\\\": \\\"COMPLETE\\\",\\n \\\"terminal\\\": 1\\n },\\n {\\n \\\"id\\\": \\\"__READMUX_A7C94F_MISSING_SENTINEL__\\\",\\n \\\"state\\\": \\\"MISSING\\\",\\n \\\"terminal\\\": 0\\n }\\n ],\\n \\\"worker_state\\\": \\\"AMBIGUOUS_FAIL_CLOSED\\\",\\n \\\"fresh_instance_count\\\": 2,\\n \\\"queue_gate\\\": \\\"PASS\\\",\\n \\\"rows_affected\\\": 0,\\n \\\"endpoint_scope_attested\\\": 0,\\n \\\"payload_result_error_bodies_returned\\\": false\\n },\\n \\\"promotion\\\": {\\n \\\"v2_unchanged\\\": \\\"REJECT\\\",\\n \\\"v2r1\\\": \\\"REQUIRES_DISTINCT_SECOND_PARTY_VALIDATION_BEFORE_PRODUCTION_ADOPTION\\\"\\n },\\n \\\"production_main_mutation\\\": false,\\n \\\"canonical_brain_py_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false\\n}\";\nconst b=new TextEncoder().encode(s);\nconst h=await crypto.subtle.digest(\"SHA-256\",b);\nconsole.log(JSON.stringify({bytes:b.length,sha256:[...new Uint8Array(h)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}));","createdAt",["D",1788661007901],"branchVersion","branchId","e3d1f5d9-3178-4f82-9d6d-189ec3fec4fb","id","5d733355-8adc-4afd-b8c8-ef4d9a2578ec","brain-readmux-v2-review-a7c94f",["D",1788660354429],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Independent readmux V2 review","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","5d7333558adc4afdb8c8ef4d9a2578ec","tursoHostname","5d7333558adc4afdb8c8ef4d9a2578ec-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789533091345],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",18,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":249,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":250,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":251,"_82":252,"_84":253,"_86":25},"tree",[212,213,214,215,216,217,218,219,220],"files",[212,213,214,215,216,217,218,219,220],"counts",{"_202":61,"_203":198,"_204":61,"_205":206,"_207":208},"contents",[129,130,131,132,133,134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":195,"_32":196,"_30":197,"_141":-5,"_41":42,"_40":198,"_143":144,"_38":199,"_13":61,"_33":34,"_35":200,"_24":25,"_147":-5,"_27":201},{"_43":188,"_32":189,"_30":190,"_141":-5,"_41":42,"_40":191,"_143":144,"_38":192,"_13":61,"_33":20,"_35":193,"_24":25,"_147":-5,"_27":194},{"_43":181,"_32":182,"_30":183,"_141":-5,"_41":42,"_40":184,"_143":144,"_38":185,"_13":61,"_33":34,"_35":186,"_24":25,"_147":-5,"_27":187},{"_43":174,"_32":175,"_30":176,"_141":-5,"_41":42,"_40":177,"_143":144,"_38":178,"_13":172,"_33":34,"_35":179,"_24":25,"_147":-5,"_27":180},{"_43":170,"_32":28,"_30":31,"_141":-5,"_41":42,"_40":14,"_143":25,"_38":171,"_13":172,"_33":34,"_35":37,"_24":25,"_147":-5,"_27":173},{"_43":163,"_32":164,"_30":165,"_141":-5,"_41":42,"_40":166,"_143":144,"_38":167,"_13":61,"_33":34,"_35":168,"_24":25,"_147":-5,"_27":169},{"_43":156,"_32":157,"_30":158,"_141":-5,"_41":42,"_40":159,"_143":144,"_38":160,"_13":61,"_33":34,"_35":161,"_24":25,"_147":-5,"_27":162},{"_43":149,"_32":150,"_30":151,"_141":-5,"_41":42,"_40":152,"_143":144,"_38":153,"_13":61,"_33":34,"_35":154,"_24":25,"_147":-5,"_27":155},{"_43":138,"_32":139,"_30":140,"_141":-5,"_41":42,"_40":142,"_143":144,"_38":145,"_13":61,"_33":34,"_35":146,"_24":25,"_147":-5,"_27":148},"2b22ab5e-b00b-4bf4-82f5-a36f14734b63","v2r1_sql_adv_test.ts","34595588-a998-11f1-8704-1607ee4eb77e","parentId",7,"latest",true,["D",1788660660293],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst SQL=\"WITH\\ninput(raw) AS (VALUES (?)),\\nmeta AS (\\n SELECT raw,\\n json_valid(raw) AS is_json,\\n CASE WHEN json_valid(raw) THEN json_type(raw) ELSE NULL END AS root_type,\\n length(raw) AS raw_len\\n FROM input\\n),\\nsel AS (\\n SELECT CAST(je.key AS INTEGER) AS idx, je.value AS job_id, je.type AS value_type\\n FROM meta,\\n json_each(CASE WHEN is_json=1 AND root_type='array' THEN raw ELSE '[]' END) AS je\\n),\\nsel_stats AS (\\n SELECT\\n (SELECT is_json FROM meta) AS is_json,\\n (SELECT root_type FROM meta) AS root_type,\\n (SELECT raw_len FROM meta) AS raw_len,\\n COUNT(*) AS item_count,\\n SUM(CASE WHEN value_type!='text' THEN 1 ELSE 0 END) AS non_text_count,\\n SUM(CASE WHEN value_type='text' AND (length(job_id)<1 OR length(job_id)>256) THEN 1 ELSE 0 END) AS bad_length_count,\\n COUNT(DISTINCT CASE WHEN value_type='text' THEN job_id END) AS distinct_text_count\\n FROM sel\\n),\\nvalidation AS (\\n SELECT CASE\\n WHEN is_json!=1 THEN 'JOBS_JSON_INVALID'\\n WHEN root_type!='array' THEN 'JOBS_ARRAY_REQUIRED'\\n WHEN raw_len>4096 THEN 'JOBS_SELECTOR_TOO_LARGE'\\n WHEN item_count>16 THEN 'TOO_MANY_JOB_IDS'\\n WHEN COALESCE(non_text_count,0)>0 THEN 'JOB_ID_STRING_REQUIRED'\\n WHEN COALESCE(bad_length_count,0)>0 THEN 'JOB_ID_LENGTH_INVALID'\\n WHEN item_count!=distinct_text_count THEN 'DUPLICATE_JOB_ID'\\n ELSE NULL\\n END AS selector_error\\n FROM sel_stats\\n),\\nclock AS (SELECT datetime('now') AS now_ts),\\nworker_rows AS (\\n SELECT\\n instance_id,last_poll_at,last_result_at,lease_count,result_count,\\n ((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS poll_age_seconds_raw,\\n CAST(((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS INTEGER) AS poll_age_seconds\\n FROM n4x7_v2_workers_test\\n WHERE worker_id='project-brain-live-v1-worker-v2' AND last_poll_at IS NOT NULL\\n),\\nworker_agg AS (\\n SELECT\\n COUNT(*) AS total_instances,\\n SUM(CASE WHEN poll_age_seconds_raw<0 THEN 1 ELSE 0 END) AS future_instances,\\n SUM(CASE WHEN poll_age_seconds_raw>=0 AND poll_age_seconds_raw<=90 THEN 1 ELSE 0 END) AS fresh_instances,\\n SUM(CASE WHEN poll_age_seconds_raw>90 AND poll_age_seconds_raw<=180 THEN 1 ELSE 0 END) AS degraded_instances\\n FROM worker_rows\\n),\\nlatest_worker AS (\\n SELECT * FROM worker_rows ORDER BY last_poll_at DESC, instance_id DESC LIMIT 1\\n),\\nqueue_stats AS (\\n 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'\\n AND (lease_owner IS NULL OR trim(lease_owner)='' OR lease_expires_at IS NULL OR julianday(lease_expires_at) IS NULL)\\n THEN 1 ELSE 0 END) AS malformed_lease_count,\\n SUM(CASE WHEN state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\\n SUM(CASE WHEN state='READY' AND priority>1000000000 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 n4x7_v2_jobs_test\\n),\\ndup_active AS (\\n SELECT COUNT(*) AS duplicate_worker_count FROM (\\n SELECT lease_owner\\n FROM n4x7_v2_jobs_test\\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),\\nready_order AS (\\n SELECT\\n id,\\n CASE\\n WHEN op='brain' AND json_valid(payload_json)=1 THEN\\n CASE\\n WHEN json_type(payload_json,'$.args')='array'\\n AND json_array_length(json_extract(payload_json,'$.args'))=1\\n AND json_extract(payload_json,'$.args[0]')='recover-stale'\\n AND json_type(payload_json,'$.timeout')='integer'\\n AND json_extract(payload_json,'$.timeout') BETWEEN 1 AND 120\\n AND (SELECT COUNT(*) FROM json_each(payload_json))=2\\n THEN 0 ELSE 1\\n END\\n ELSE 1\\n END AS recovery_class,\\n CASE WHEN priority>1000000000 THEN 1000000000 ELSE priority END AS effective_priority,\\n created_at\\n FROM n4x7_v2_jobs_test\\n WHERE state='READY'\\n),\\nranked_ready AS (\\n SELECT\\n id,\\n ROW_NUMBER() OVER (ORDER BY recovery_class ASC,effective_priority DESC,created_at ASC,id ASC)-1 AS transport_ready_ahead\\n FROM ready_order\\n),\\nselected AS (\\n SELECT\\n s.idx,s.job_id AS id,COALESCE(j.state,'MISSING') AS state,j.priority,\\n CASE WHEN j.priority>1000000000 THEN 1000000000 ELSE j.priority END AS effective_priority,\\n j.lease_owner,j.lease_expires_at,j.updated_at,\\n CASE WHEN j.result_json IS NOT NULL THEN 1 ELSE 0 END AS result_available,\\n CASE WHEN j.error_json IS NOT NULL THEN 1 ELSE 0 END AS error_available,\\n CASE WHEN j.id IS NOT NULL AND j.state IN ('COMPLETE','FAILED') THEN 1 ELSE 0 END AS terminal,\\n CASE WHEN j.state='READY' THEN rr.transport_ready_ahead ELSE NULL END AS transport_ready_ahead\\n FROM sel AS s\\n LEFT JOIN n4x7_v2_jobs_test AS j ON j.id=s.job_id\\n LEFT JOIN ranked_ready AS rr ON rr.id=j.id\\n WHERE (SELECT selector_error FROM validation) IS NULL\\n ORDER BY s.idx\\n),\\njobs_agg AS (\\n SELECT json_group_array(json_object(\\n 'id',id,\\n 'state',state,\\n 'priority',priority,\\n 'effective_priority',effective_priority,\\n 'lease_owner',lease_owner,\\n 'lease_expires_at',lease_expires_at,\\n 'updated_at',updated_at,\\n 'result_available',result_available,\\n 'error_available',error_available,\\n 'terminal',terminal,\\n 'transport_ready_ahead',transport_ready_ahead\\n )) AS jobs_json\\n FROM selected\\n)\\nSELECT json_object(\\n 'schema','BRAIN_CONTROL_READMUX_V2',\\n 'observed_at',(SELECT now_ts FROM clock),\\n 'selector_error',(SELECT selector_error FROM validation),\\n 'worker',json_object(\\n 'worker_id','project-brain-live-v1-worker-v2',\\n 'state',(\\n SELECT CASE\\n WHEN future_instances>0 THEN 'FUTURE_HEARTBEAT_FAIL_CLOSED'\\n WHEN total_instances=0 THEN 'UNKNOWN'\\n WHEN fresh_instances=1 THEN 'HEALTHY'\\n WHEN fresh_instances>1 THEN 'AMBIGUOUS_FAIL_CLOSED'\\n WHEN degraded_instances>0 THEN 'DEGRADED'\\n ELSE 'DOWN'\\n END FROM worker_agg\\n ),\\n 'latest_instance_id',(SELECT instance_id FROM latest_worker),\\n 'latest_poll_age_seconds',(SELECT poll_age_seconds FROM latest_worker),\\n 'future_instance_count',COALESCE((SELECT future_instances FROM worker_agg),0),\\n 'fresh_instance_count',COALESCE((SELECT fresh_instances FROM worker_agg),0),\\n 'degraded_instance_count',COALESCE((SELECT degraded_instances FROM worker_agg),0),\\n 'endpoint_scope_attested',0\\n ),\\n 'queue',json_object(\\n 'ready_count',COALESCE((SELECT ready_count FROM queue_stats),0),\\n 'leased_count',COALESCE((SELECT leased_count FROM queue_stats),0),\\n 'malformed_lease_count',COALESCE((SELECT malformed_lease_count FROM queue_stats),0),\\n 'expired_lease_count',COALESCE((SELECT expired_lease_count FROM queue_stats),0),\\n 'duplicate_active_worker_leases',COALESCE((SELECT duplicate_worker_count FROM dup_active),0),\\n 'gate',CASE\\n WHEN COALESCE((SELECT malformed_lease_count FROM queue_stats),0)>0 THEN 'MALFORMED_LEASE_METADATA'\\n WHEN COALESCE((SELECT expired_lease_count FROM queue_stats),0)>0 THEN 'EXPIRED_LEASE_PRESENT'\\n WHEN COALESCE((SELECT duplicate_worker_count FROM dup_active),0)>0 THEN 'DUPLICATE_ACTIVE_WORKER_LEASE'\\n ELSE 'PASS'\\n END,\\n 'overcap_ready_count',COALESCE((SELECT overcap_ready_count FROM queue_stats),0),\\n 'oldest_ready_at',(SELECT oldest_ready_at FROM queue_stats),\\n 'earliest_lease_expiry',(SELECT earliest_lease_expiry FROM queue_stats),\\n 'transport_priority_cap',1000000000,\\n 'selection_policy','RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT'\\n ),\\n 'jobs',json(COALESCE((SELECT jobs_json FROM jobs_agg),'[]'))\\n) AS snapshot_json\";\nconst JOBS=\"n4x7_v2_jobs_test\", WORKERS=\"n4x7_v2_workers_test\";\ntype C={name:string,pass:boolean,actual?:unknown,expected?:unknown};\nconst cases:C[]=[]; const add=(name:string,pass:boolean,actual?:unknown,expected?:unknown)=>cases.push({name,pass,actual,expected});\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\nasync function reset(){await ex(\"DELETE FROM \"+JOBS);await ex(\"DELETE FROM \"+WORKERS);}\nasync function snap(ids:any){const r:any=await ex(SQL,[typeof ids===\"string\"?ids:JSON.stringify(ids)]);return JSON.parse(String(r.rows?.[0]?.snapshot_json));}\ntry{\n await ex(\"CREATE TABLE IF NOT EXISTS \"+JOBS+\"(id TEXT PRIMARY KEY,priority REAL,op TEXT,payload_json TEXT,state TEXT,lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,created_at TEXT,updated_at TEXT)\");\n await ex(\"CREATE TABLE IF NOT EXISTS \"+WORKERS+\"(worker_id TEXT,instance_id TEXT,last_poll_at TEXT,last_result_at TEXT,lease_count INTEGER,result_count INTEGER)\");\n await reset();\n for(const [name,input,err] of [\n [\"malformed\",\"{\",\"JOBS_JSON_INVALID\"],[\"object\",\"{}\",\"JOBS_ARRAY_REQUIRED\"],\n [\"too-many\",JSON.stringify(Array.from({length:17},(_,i)=>\"j\"+i)),\"TOO_MANY_JOB_IDS\"],\n [\"non-string\",JSON.stringify([\"x\",1]),\"JOB_ID_STRING_REQUIRED\"],\n [\"duplicate\",JSON.stringify([\"x\",\"x\"]),\"DUPLICATE_JOB_ID\"],\n [\"id-too-long\",JSON.stringify([\"x\".repeat(257)]),\"JOB_ID_LENGTH_INVALID\"],\n [\"selector-too-large\",JSON.stringify([\"x\".repeat(4097)]),\"JOBS_SELECTOR_TOO_LARGE\"]\n ] as const){const s=await snap(input);add(\"selector \"+name,s.selector_error===err&&s.jobs.length===0,{error:s.selector_error,jobs:s.jobs.length},err);}\n await ex(\"INSERT INTO \"+WORKERS+\" VALUES('project-brain-live-v1-worker-v2','fresh-a',datetime('now','-5 seconds'),NULL,0,0)\");\n const normal=JSON.stringify({args:[\"status\"],timeout:60}),recover=JSON.stringify({args:[\"recover-stale\"],timeout:60});\n await ex(\"INSERT INTO \"+JOBS+\" VALUES(?,?,?,?,?,?,?,?,?,?,?)\",[\"z-recover\",-100,\"brain\",recover,\"READY\",null,null,null,null,\"2026-01-01 00:00:05\",\"2026-01-01 00:00:05\"]);\n await ex(\"INSERT INTO \"+JOBS+\" VALUES(?,?,?,?,?,?,?,?,?,?,?)\",[\"a-overcap\",2000000000,\"brain\",normal,\"READY\",null,null,null,null,\"2026-01-01 00:00:00\",\"2026-01-01 00:00:00\"]);\n await ex(\"INSERT INTO \"+JOBS+\" VALUES(?,?,?,?,?,?,?,?,?,?,?)\",[\"b-cap\",1000000000,\"brain\",normal,\"READY\",null,null,null,null,\"2026-01-01 00:00:00\",\"2026-01-01 00:00:00\"]);\n await ex(\"INSERT INTO \"+JOBS+\" VALUES(?,?,?,?,?,?,?,?,?,?,?)\",[\"c-low\",999,\"brain\",normal,\"READY\",null,null,null,null,\"2026-01-01 00:00:00\",\"2026-01-01 00:00:00\"]);\n let s=await snap([\"z-recover\",\"a-overcap\",\"b-cap\",\"c-low\"]);\n const ahead=Object.fromEntries(s.jobs.map((j:any)=>[j.id,j.transport_ready_ahead]));\n add(\"queue ordering exact\",JSON.stringify(ahead)===JSON.stringify({\"z-recover\":0,\"a-overcap\":1,\"b-cap\":2,\"c-low\":3}),ahead,{\"z-recover\":0,\"a-overcap\":1,\"b-cap\":2,\"c-low\":3});\n add(\"overcap clamped\",s.jobs.find((j:any)=>j.id===\"a-overcap\")?.effective_priority===1000000000,s.jobs.find((j:any)=>j.id===\"a-overcap\")?.effective_priority,1000000000);\n add(\"healthy single worker\",s.worker.state===\"HEALTHY\"&&s.worker.fresh_instance_count===1,s.worker,\"HEALTHY/1 fresh\");\n add(\"endpoint nonattested\",s.worker.endpoint_scope_attested===0,s.worker.endpoint_scope_attested,0);\n await reset();\n await ex(\"INSERT INTO \"+WORKERS+\" VALUES('project-brain-live-v1-worker-v2','f1',datetime('now','-5 seconds'),NULL,0,0),('project-brain-live-v1-worker-v2','f2',datetime('now','-6 seconds'),NULL,0,0)\");\n s=await snap([]);add(\"multiple fresh fail closed\",s.worker.state===\"AMBIGUOUS_FAIL_CLOSED\",s.worker.state,\"AMBIGUOUS_FAIL_CLOSED\");\n await reset();\n await ex(\"INSERT INTO \"+WORKERS+\" VALUES('project-brain-live-v1-worker-v2','d1',datetime('now','-120 seconds'),NULL,0,0)\");\n s=await snap([]);add(\"stale worker degraded\",s.worker.state===\"DEGRADED\",s.worker.state,\"DEGRADED\");\n await reset();\n await ex(\"INSERT INTO \"+WORKERS+\" VALUES('project-brain-live-v1-worker-v2','future1',datetime('now','+3600 seconds'),NULL,0,0)\");\n s=await snap([]);add(\"future heartbeat explicit fail closed\",s.worker.state===\"FUTURE_HEARTBEAT_FAIL_CLOSED\"&&s.worker.future_instance_count===1,s.worker,\"FUTURE_HEARTBEAT_FAIL_CLOSED/1\");\n await reset();\n await ex(\"INSERT INTO \"+WORKERS+\" VALUES('project-brain-live-v1-worker-v2','down1',datetime('now','-240 seconds'),NULL,0,0)\");\n s=await snap([]);add(\"old worker down\",s.worker.state===\"DOWN\",s.worker.state,\"DOWN\");\n await reset();\n await ex(\"INSERT INTO \"+JOBS+\" VALUES('expired',1,'brain','{}','LEASED','w',datetime('now','-1 seconds'),NULL,NULL,datetime('now'),datetime('now'))\");\n s=await snap([\"expired\"]);add(\"expired lease gate\",s.queue.gate===\"EXPIRED_LEASE_PRESENT\",s.queue,\"EXPIRED_LEASE_PRESENT\");\n await reset();\n await ex(\"INSERT INTO \"+JOBS+\" VALUES('dup1',1,'brain','{}','LEASED','w',datetime('now','+60 seconds'),NULL,NULL,datetime('now'),datetime('now')),('dup2',1,'brain','{}','LEASED','w',datetime('now','+60 seconds'),NULL,NULL,datetime('now'),datetime('now'))\");\n s=await snap([\"dup1\",\"dup2\"]);add(\"duplicate lease gate\",s.queue.gate===\"DUPLICATE_ACTIVE_WORKER_LEASE\"&&s.queue.duplicate_active_worker_leases===1,s.queue,\"DUPLICATE_ACTIVE_WORKER_LEASE/1\");\n await reset();\n await ex(\"INSERT INTO \"+JOBS+\" VALUES('null-expiry',1,'brain','{}','LEASED','w',NULL,NULL,NULL,datetime('now'),datetime('now'))\");\n s=await snap([\"null-expiry\"]);add(\"null expiry malformed gate\",s.queue.gate===\"MALFORMED_LEASE_METADATA\"&&s.queue.malformed_lease_count===1,s.queue,\"MALFORMED_LEASE_METADATA/1\");\n await reset();\n await ex(\"INSERT INTO \"+JOBS+\" VALUES('null-owner',1,'brain','{}','LEASED',NULL,datetime('now','+60 seconds'),NULL,NULL,datetime('now'),datetime('now'))\");\n s=await snap([\"null-owner\"]);add(\"null owner malformed gate\",s.queue.gate===\"MALFORMED_LEASE_METADATA\"&&s.queue.malformed_lease_count===1,s.queue,\"MALFORMED_LEASE_METADATA/1\");\n await reset();\n await ex(\"INSERT INTO \"+JOBS+\" VALUES('bad-expiry',1,'brain','{}','LEASED','w','not-a-date',NULL,NULL,datetime('now'),datetime('now'))\");\n s=await snap([\"bad-expiry\"]);add(\"invalid expiry malformed gate\",s.queue.gate===\"MALFORMED_LEASE_METADATA\"&&s.queue.malformed_lease_count===1,s.queue,\"MALFORMED_LEASE_METADATA/1\");\n await reset();\n await ex(\"INSERT INTO \"+JOBS+\" VALUES('term-complete',1,'brain','{}','COMPLETE',NULL,NULL,'{}',NULL,datetime('now'),datetime('now')),('term-failed',1,'brain','{}','FAILED',NULL,NULL,NULL,'{}',datetime('now'),datetime('now'))\");\n s=await snap([\"term-complete\",\"term-failed\",\"missing-id\"]);\n const missing=s.jobs.find((j:any)=>j.id===\"missing-id\");\n add(\"missing watched ID is explicit nonterminal row\",s.jobs.length===3&&missing?.state===\"MISSING\"&&missing?.terminal===0&&missing?.result_available===0&&missing?.error_available===0,{jobs:s.jobs},\"3 rows with explicit MISSING/nonterminal\");\n await reset();\n await ex(\"INSERT INTO \"+WORKERS+\" VALUES('project-brain-live-v1-worker-v2','fresh',datetime('now','-1 seconds'),NULL,0,0)\");\n await ex(\"WITH RECURSIVE n(x) AS (VALUES(0) UNION ALL SELECT x+1 FROM n WHERE x<9999) INSERT INTO \"+JOBS+\"(id,priority,op,payload_json,state,created_at,updated_at) SELECT printf('q%05d',x),1,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00' FROM n\",[normal]);\n const before:any=await ex(\"SELECT COUNT(*) AS n FROM \"+JOBS);s=await snap([\"q00000\",\"q05000\",\"q09999\"]);const after:any=await ex(\"SELECT COUNT(*) AS n FROM \"+JOBS);\n const pa=Object.fromEntries(s.jobs.map((j:any)=>[j.id,j.transport_ready_ahead]));\n add(\"large queue positions\",pa.q00000===0&&pa.q05000===5000&&pa.q09999===9999,pa,{q00000:0,q05000:5000,q09999:9999});\n add(\"candidate query no mutation\",Number(before.rows?.[0]?.n)===10000&&Number(after.rows?.[0]?.n)===10000,{before:before.rows?.[0]?.n,after:after.rows?.[0]?.n},\"10000/10000\");\n const mutation=/\\b(INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|ALTER|VACUUM|ATTACH|DETACH|PRAGMA)\\b/gi;\n add(\"static read-only tokens\",(SQL.match(mutation)||[]).length===0,(SQL.match(mutation)||[]),[]);\n add(\"one bound parameter\",(SQL.match(/\\?/g)||[]).length===1,(SQL.match(/\\?/g)||[]).length,1);\n add(\"single statement semicolon-free\",(SQL.match(/;/g)||[]).length===0,(SQL.match(/;/g)||[]).length,0);\n const failures=cases.filter(x=>!x.pass);\n console.log(JSON.stringify({schema:\"READMUX_V2_SQL_ADVERSARIAL\",ok:failures.length===0,total:cases.length,passed:cases.length-failures.length,failed:failures.length,failures,cases}));\n} finally {await ex(\"DROP TABLE IF EXISTS \"+JOBS);await ex(\"DROP TABLE IF EXISTS \"+WORKERS);}\n","label",[139],"a9c8d2ff-673f-40e8-9c45-3bc2ea3c101f","v2r1_rate_transition_test.ts","a72471d8-a998-11f1-8790-1607ee4eb77e",14,["D",1788660852929],"import { observationIdentity, nextPollDecision } from \"./candidate_v2r1_poll.ts\";\nconst obs={workerState:\"HEALTHY\" as const,workerInstanceId:\"i-rate\",queueGate:\"PASS\",jobs:[{id:\"j-rate\",state:\"READY\",updated_at:\"t\",transport_ready_ahead:0}]};\nconst identityNormal=observationIdentity({...obs,rateLimited:false});\nconst first429=nextPollDecision({previousIdentity:identityNormal,previousUnchangedReads:4,rateLimited:true,...obs});\nconst identity429=first429.identity;\nconst second429=nextPollDecision({previousIdentity:identity429,previousUnchangedReads:first429.unchangedReads,rateLimited:true,...obs});\nconst recovered=nextPollDecision({previousIdentity:second429.identity,previousUnchangedReads:second429.unchangedReads,rateLimited:false,...obs});\nconst cases=[\n {name:\"enter 429 resets identity/backoff\",actual:[first429.changed,first429.unchangedReads,first429.seconds],expected:[true,0,30]},\n {name:\"repeat 429 advances to 60\",actual:[second429.changed,second429.unchangedReads,second429.seconds],expected:[false,1,60]},\n {name:\"clear 429 resets normal base\",actual:[recovered.changed,recovered.unchangedReads,recovered.seconds],expected:[true,0,3]}\n].map(x=>({...x,pass:JSON.stringify(x.actual)===JSON.stringify(x.expected)}));\nconsole.log(JSON.stringify({schema:\"READMUX_V2R1_RATE_LIMIT_TRANSITION_TEST_V1\",ok:cases.every(x=>x.pass),cases}));",[150],"c5bf8080-34f5-414e-8e3d-c3858ef4c2ac","v2r1_poller_adv_test.ts","a654b5ce-a998-11f1-ab32-1607ee4eb77e",13,["D",1788660851578],"import {advanceObservationState,classifyWorker,nextPollDecision,observationIdentity,queueGate,nextPollSeconds,stableStaggerMs} from \"./candidate_v2r1_poll.ts\";\ntype Case={name:string,expected:unknown,actual:unknown,pass:boolean};\nconst cases:Case[]=[];\nfunction add(name:string,actual:unknown,expected:unknown){cases.push({name,actual,expected,pass:Object.is(actual,expected)});}\nadd(\"terminal healthy stops\",nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"COMPLETE\"},{state:\"FAILED\"}],unchangedReads:0}),null);\nadd(\"terminal degraded stops\",nextPollSeconds({workerState:\"DEGRADED\",jobs:[{state:\"COMPLETE\"}],unchangedReads:0}),null);\nadd(\"terminal rate-limited stops\",nextPollSeconds({rateLimited:true,workerState:\"HEALTHY\",jobs:[{state:\"COMPLETE\"}],unchangedReads:0}),null);\nadd(\"terminal degraded rate-limited stops\",nextPollSeconds({rateLimited:true,workerState:\"DOWN\",jobs:[{state:\"FAILED\"}],unchangedReads:4}),null);\nadd(\"429 first observation 30\",nextPollSeconds({rateLimited:true,workerState:\"HEALTHY\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:0}),30);\nadd(\"429 repeated 60\",nextPollSeconds({rateLimited:true,workerState:\"HEALTHY\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:1}),60);\nadd(\"ambiguous worker backs off\",nextPollSeconds({workerState:\"AMBIGUOUS_FAIL_CLOSED\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:0}),15);\nadd(\"future worker backs off\",nextPollSeconds({workerState:\"FUTURE_HEARTBEAT_FAIL_CLOSED\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:0}),15);\nadd(\"malformed queue backs off\",nextPollSeconds({workerState:\"HEALTHY\",queueGate:\"MALFORMED_LEASE_METADATA\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:0}),15);\nadd(\"duplicate queue backs off\",nextPollSeconds({workerState:\"HEALTHY\",queueGate:\"DUPLICATE_ACTIVE_WORKER_LEASE\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:2}),60);\nadd(\"one fresh is healthy\",classifyWorker(4,1,2,0),\"HEALTHY\");\nadd(\"two fresh fail closed\",classifyWorker(4,2,1,0),\"AMBIGUOUS_FAIL_CLOSED\");\nadd(\"future heartbeat fail closed\",classifyWorker(1,0,0,1),\"FUTURE_HEARTBEAT_FAIL_CLOSED\");\nadd(\"malformed beats expired duplicate\",queueGate(1,1,1),\"MALFORMED_LEASE_METADATA\");\nadd(\"expired beats duplicate\",queueGate(1,1,0),\"EXPIRED_LEASE_PRESENT\");\nconst obs1=observationIdentity({workerState:\"HEALTHY\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"1\",transport_ready_ahead:5}]});\nconst obs2=observationIdentity({workerState:\"HEALTHY\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"2\",transport_ready_ahead:5}]});\nadd(\"unchanged counter increments\",advanceObservationState(obs1,obs1,0).unchangedReads,1);\nadd(\"updated_at change resets\",advanceObservationState(obs1,obs2,4).unchangedReads,0);\nconst inst1=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"1\",transport_ready_ahead:5}]});\nconst inst2=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i2\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"1\",transport_ready_ahead:5}]});\nadd(\"instance change resets\",advanceObservationState(inst1,inst2,4).unchangedReads,0);\nconst d1=nextPollDecision({previousIdentity:null,previousUnchangedReads:4,workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"1\",transport_ready_ahead:0}]});\nconst d2=nextPollDecision({previousIdentity:d1.identity,previousUnchangedReads:d1.unchangedReads,workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"1\",transport_ready_ahead:0}]});\nadd(\"decision first interval\",d1.seconds,3);\nadd(\"decision repeated interval\",d2.seconds,6);\nconst st=stableStaggerMs(\"chat-bbn-20260906-0217-sol-n4x7\");\ncases.push({name:\"stagger bounded\",actual:st,expected:\"0..1999\",pass:Number.isInteger(st)&&st>=0&&st<2000});\nconst failures=cases.filter(x=>!x.pass);\nconsole.log(JSON.stringify({schema:\"READMUX_V2_POLLER_ADVERSARIAL\",ok:failures.length===0,total:cases.length,passed:cases.length-failures.length,failed:failures.length,failures,cases}));\n",[157],"674b1136-e48c-4334-b524-3a413fba7d34","v2r1_poll_unit_test.ts","a528c564-a998-11f1-b129-1607ee4eb77e",12,["D",1788660849612],"import {advanceObservationState,classifyWorker,nextPollDecision,observationIdentity,queueGate,nextPollSeconds,stableStaggerMs} from \"./candidate_v2r1_poll.ts\";\n\nfunction eq(actual:unknown,expected:unknown,name:string){\n if(actual!==expected)throw new Error(name+\": expected \"+String(expected)+\" got \"+String(actual));\n}\nlet n=0;\nfunction t(name:string,fn:()=>void){fn();n++;}\n\nt(\"unknown worker\",()=>eq(classifyWorker(0,0,0,0),\"UNKNOWN\",\"unknown\"));\nt(\"healthy worker\",()=>eq(classifyWorker(3,1,1,0),\"HEALTHY\",\"healthy\"));\nt(\"ambiguous worker\",()=>eq(classifyWorker(4,2,0,0),\"AMBIGUOUS_FAIL_CLOSED\",\"ambiguous\"));\nt(\"future worker fail closed\",()=>eq(classifyWorker(1,0,0,1),\"FUTURE_HEARTBEAT_FAIL_CLOSED\",\"future\"));\nt(\"future dominates fresh\",()=>eq(classifyWorker(2,1,0,1),\"FUTURE_HEARTBEAT_FAIL_CLOSED\",\"future dominates\"));\nt(\"degraded worker\",()=>eq(classifyWorker(3,0,1,0),\"DEGRADED\",\"degraded\"));\nt(\"down worker\",()=>eq(classifyWorker(3,0,0,0),\"DOWN\",\"down\"));\nt(\"malformed lease gate\",()=>eq(queueGate(0,0,1),\"MALFORMED_LEASE_METADATA\",\"malformed\"));\nt(\"expired lease gate\",()=>eq(queueGate(1,0,0),\"EXPIRED_LEASE_PRESENT\",\"expired\"));\nt(\"duplicate lease gate\",()=>eq(queueGate(0,1,0),\"DUPLICATE_ACTIVE_WORKER_LEASE\",\"duplicate\"));\nt(\"malformed gate precedence\",()=>eq(queueGate(1,1,1),\"MALFORMED_LEASE_METADATA\",\"malformed precedence\"));\nt(\"queue pass\",()=>eq(queueGate(0,0,0),\"PASS\",\"pass\"));\nt(\"rate limit base\",()=>eq(nextPollSeconds({rateLimited:true,workerState:\"HEALTHY\",jobs:[],unchangedReads:0}),30,\"429 base\"));\nt(\"rate limit backoff\",()=>eq(nextPollSeconds({rateLimited:true,workerState:\"HEALTHY\",jobs:[],unchangedReads:3}),60,\"429 backoff\"));\nt(\"stale health base\",()=>eq(nextPollSeconds({workerState:\"DEGRADED\",jobs:[],unchangedReads:0}),15,\"stale base\"));\nt(\"stale health backoff\",()=>eq(nextPollSeconds({workerState:\"DOWN\",jobs:[],unchangedReads:3}),60,\"stale backoff\"));\nt(\"future health backoff\",()=>eq(nextPollSeconds({workerState:\"FUTURE_HEARTBEAT_FAIL_CLOSED\",jobs:[],unchangedReads:0}),15,\"future backoff\"));\nt(\"malformed queue backoff\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",queueGate:\"MALFORMED_LEASE_METADATA\",jobs:[],unchangedReads:0}),15,\"malformed backoff\"));\nt(\"expired queue backoff\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",queueGate:\"EXPIRED_LEASE_PRESENT\",jobs:[],unchangedReads:2}),60,\"expired backoff\"));\nt(\"terminal healthy stops\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"COMPLETE\"}],unchangedReads:0}),null,\"terminal healthy\"));\nt(\"terminal degraded stops\",()=>eq(nextPollSeconds({workerState:\"DEGRADED\",jobs:[{state:\"COMPLETE\"}],unchangedReads:0}),null,\"terminal degraded\"));\nt(\"terminal 429 stops\",()=>eq(nextPollSeconds({rateLimited:true,workerState:\"HEALTHY\",jobs:[{state:\"FAILED\"}],unchangedReads:0}),null,\"terminal 429\"));\nt(\"leased near\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"LEASED\"}],unchangedReads:0}),5,\"leased\"));\nt(\"ready head\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:0}),3,\"head\"));\nt(\"ready head no progress\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:2}),12,\"head backoff\"));\nt(\"ready three\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"READY\",transport_ready_ahead:3}],unchangedReads:0}),5,\"three\"));\nt(\"ready ten\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"READY\",transport_ready_ahead:10}],unchangedReads:0}),10,\"ten\"));\nt(\"ready far\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[{state:\"READY\",transport_ready_ahead:99}],unchangedReads:0}),20,\"far\"));\nt(\"no jobs\",()=>eq(nextPollSeconds({workerState:\"HEALTHY\",jobs:[],unchangedReads:0}),15,\"no jobs\"));\nt(\"stagger deterministic\",()=>eq(stableStaggerMs(\"agent-a\"),stableStaggerMs(\"agent-a\"),\"stagger deterministic\"));\nt(\"stagger bounded\",()=>{const x=stableStaggerMs(\"agent-b\");if(x<0||x>=2000)throw new Error(\"stagger range\");});\nt(\"observation identity stable\",()=>{\n const a=observationIdentity({workerState:\"HEALTHY\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:2}]});\n const b=observationIdentity({workerState:\"HEALTHY\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:2}]});\n eq(a,b,\"identity stable\");\n});\nt(\"observation update increments\",()=>{\n const id=observationIdentity({workerState:\"HEALTHY\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:2}]});\n const x=advanceObservationState(id,id,2);eq(x.unchangedReads,3,\"unchanged increment\");eq(x.changed,false,\"unchanged changed flag\");\n});\nt(\"observation change resets\",()=>{\n const a=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:2}]});\n const b=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"LEASED\",updated_at:\"t2\",transport_ready_ahead:null}]});\n const x=advanceObservationState(a,b,4);eq(x.unchangedReads,0,\"change reset\");eq(x.changed,true,\"change flag\");\n});\nt(\"worker instance replacement resets\",()=>{\n const a=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:2}]});\n const b=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i2\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:2}]});\n eq(advanceObservationState(a,b,4).unchangedReads,0,\"instance reset\");\n});\nt(\"poll decision binds unchanged state\",()=>{\n const first=nextPollDecision({previousIdentity:null,previousUnchangedReads:4,workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:0}]});\n eq(first.unchangedReads,0,\"first reset\");eq(first.seconds,3,\"first interval\");\n const second=nextPollDecision({previousIdentity:first.identity,previousUnchangedReads:first.unchangedReads,workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j1\",state:\"READY\",updated_at:\"t1\",transport_ready_ahead:0}]});\n eq(second.unchangedReads,1,\"second increment\");eq(second.seconds,6,\"second interval\");\n});\nconsole.log(JSON.stringify({ok:true,tests:n}));\n",[164],"0875cae4-d5f5-423a-aa60-38b6c977527a",["D",1788661007901],4,[28],"a7a6dfc8-8357-483b-8804-08e9c26680d3","composition_test.ts","8c02d4ae-a997-11f1-bacc-1607ee4eb77e",10,["D",1788660810928],"import { nextPollSeconds, nextPollDecision, observationIdentity, advanceObservationState } from \"./candidate.ts\";\n\nfunction eq(name:string, actual:any, expected:any){\n const pass=JSON.stringify(actual)===JSON.stringify(expected);\n return {name,pass,actual,expected};\n}\n\nfunction main(){\n const cases:any[]=[];\n const returnedTerminal=[\n {state:\"COMPLETE\",transport_ready_ahead:null},\n {state:\"FAILED\",transport_ready_ahead:null},\n ];\n cases.push(eq(\n \"mixed requested set with one missing but all returned terminal stops\",\n nextPollSeconds({workerState:\"DEGRADED\",queueGate:\"PASS\",jobs:returnedTerminal,unchangedReads:0}),\n null\n ));\n cases.push(eq(\n \"empty returned set does not stop\",\n nextPollSeconds({workerState:\"HEALTHY\",queueGate:\"PASS\",jobs:[],unchangedReads:0}),\n 15\n ));\n cases.push(eq(\n \"explicit MISSING row prevents false terminal stop\",\n nextPollSeconds({workerState:\"DEGRADED\",queueGate:\"PASS\",jobs:[\n {state:\"COMPLETE\",transport_ready_ahead:null},\n {state:\"FAILED\",transport_ready_ahead:null},\n {state:\"MISSING\",transport_ready_ahead:null}\n ],unchangedReads:0}),\n 15\n ));\n cases.push(eq(\n \"mixed terminal and ready does not stop\",\n nextPollSeconds({workerState:\"HEALTHY\",queueGate:\"PASS\",jobs:[\n {state:\"COMPLETE\",transport_ready_ahead:null},\n {state:\"READY\",transport_ready_ahead:0}\n ],unchangedReads:0}),\n 3\n ));\n cases.push(eq(\n \"terminal stop outranks nonpass queue gate\",\n nextPollSeconds({workerState:\"DOWN\",queueGate:\"MALFORMED_LEASE_METADATA\",jobs:[{state:\"COMPLETE\"}],unchangedReads:4}),\n null\n ));\n cases.push(eq(\n \"429 outranks queue gate for nonterminal work\",\n nextPollSeconds({rateLimited:true,workerState:\"DOWN\",queueGate:\"MALFORMED_LEASE_METADATA\",jobs:[{state:\"READY\",transport_ready_ahead:0}],unchangedReads:4}),\n 60\n ));\n const rlObs={workerState:\"HEALTHY\" as const,workerInstanceId:\"i-rate\",queueGate:\"PASS\",jobs:[{id:\"j-rate\",state:\"READY\",updated_at:\"t\",transport_ready_ahead:0}]};\n const rlIdentity=observationIdentity(rlObs);\n const first429AfterStable=nextPollDecision({previousIdentity:rlIdentity,previousUnchangedReads:4,rateLimited:true,...rlObs});\n cases.push(eq(\"first 429 after stable snapshot inherits old unchanged counter\",first429AfterStable.seconds,60));\n const recoveredAfter429=nextPollDecision({previousIdentity:rlIdentity,previousUnchangedReads:4,rateLimited:false,...rlObs});\n cases.push(eq(\"429 clear is absent from identity and does not reset backoff\",recoveredAfter429.seconds,12));\n const a=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i1\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"t\",transport_ready_ahead:0}]});\n const b=observationIdentity({workerState:\"HEALTHY\",workerInstanceId:\"i2\",queueGate:\"PASS\",jobs:[{id:\"j\",state:\"READY\",updated_at:\"t\",transport_ready_ahead:0}]});\n cases.push(eq(\"worker instance is in observation identity\",a===b,false));\n cases.push(eq(\"counter caps at four\",advanceObservationState(a,a,99).unchangedReads,4));\n cases.push(eq(\"identity change resets counter\",advanceObservationState(a,b,4).unchangedReads,0));\n\n const composition={\n requested_count:3,\n returned_count:2,\n missing_count:1,\n returned_jobs_all_terminal:true,\n actual_next_poll_seconds:cases[0].actual,\n expected_fail_closed_behavior:\"MUST_NOT_STOP_UNTIL_ALL_REQUESTED_IDS_ARE_ACCOUNTED_FOR\"\n };\n const failed=cases.filter(x=>!x.pass);\n console.log(JSON.stringify({\n schema:\"READMUX_V2_A7C94F_INDEPENDENT_COMPOSITION_TEST_V1\",\n ok:failed.length===0,\n test_cases:cases.length,\n passed:cases.length-failed.length,\n failed:failed.length,\n cases,\n composition,\n finding: composition.actual_next_poll_seconds===null && composition.missing_count>0\n ? \"MISSING_WATCHED_ID_FALSE_TERMINAL_STOP_REPRODUCED\"\n : \"NOT_REPRODUCED\"\n }));\n}\n\nmain();",[175],"a682e957-f2c7-4a0d-8150-1effb2a1e44e","candidate_v2r1_poll.ts","9c86cc94-a998-11f1-9cc4-1607ee4eb77e",11,["D",1788660835129],"export type WorkerState=\"HEALTHY\"|\"DEGRADED\"|\"DOWN\"|\"UNKNOWN\"|\"AMBIGUOUS_FAIL_CLOSED\"|\"FUTURE_HEARTBEAT_FAIL_CLOSED\";\nexport type QueueGate=\"PASS\"|\"MALFORMED_LEASE_METADATA\"|\"EXPIRED_LEASE_PRESENT\"|\"DUPLICATE_ACTIVE_WORKER_LEASE\";\n\nexport function stableStaggerMs(agentId:string){\n let h=2166136261>>>0;\n for(const ch of agentId){\n h^=ch.codePointAt(0)??0;\n h=Math.imul(h,16777619)>>>0;\n }\n return h%2000;\n}\n\nexport function classifyWorker(total:number,fresh:number,degraded:number,future=0):WorkerState{\n if(future>0)return \"FUTURE_HEARTBEAT_FAIL_CLOSED\";\n if(total===0)return \"UNKNOWN\";\n if(fresh===1)return \"HEALTHY\";\n if(fresh>1)return \"AMBIGUOUS_FAIL_CLOSED\";\n if(degraded>0)return \"DEGRADED\";\n return \"DOWN\";\n}\n\nexport function queueGate(expired:number,duplicates:number,malformed=0):QueueGate{\n if(malformed>0)return \"MALFORMED_LEASE_METADATA\";\n if(expired>0)return \"EXPIRED_LEASE_PRESENT\";\n if(duplicates>0)return \"DUPLICATE_ACTIVE_WORKER_LEASE\";\n return \"PASS\";\n}\n\nexport type WatchedJobObservation={\n id?:string,\n state:string,\n updated_at?:string|null,\n transport_ready_ahead?:number|null\n};\n\nexport function observationIdentity(input:{\n rateLimited?:boolean,\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}):string{\n return JSON.stringify({\n rateLimited:input.rateLimited===true,\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId??null,\n queueGate:input.queueGate,\n jobs:input.jobs.map(j=>({\n id:j.id??null,\n state:j.state,\n updated_at:j.updated_at??null,\n transport_ready_ahead:Number.isInteger(j.transport_ready_ahead)?Number(j.transport_ready_ahead):null\n }))\n });\n}\n\nexport function advanceObservationState(\n previousIdentity:string|null,\n currentIdentity:string,\n previousUnchangedReads:number\n){\n const prev=Math.max(0,Math.min(4,Math.trunc(previousUnchangedReads||0)));\n const same=previousIdentity!==null&&previousIdentity===currentIdentity;\n return {\n identity:currentIdentity,\n unchangedReads:same?Math.min(4,prev+1):0,\n changed:previousIdentity===null||!same\n };\n}\n\nexport function nextPollSeconds(input:{\n rateLimited?:boolean,\n workerState:WorkerState,\n queueGate?:QueueGate|string,\n jobs:Array<{state:string,transport_ready_ahead?:number|null}>,\n unchangedReads:number\n}):number|null{\n const unchanged=Math.max(0,Math.min(4,Math.trunc(input.unchangedReads||0)));\n if(input.jobs.length>0&&input.jobs.every(j=>j.state===\"COMPLETE\"||j.state===\"FAILED\"))return null;\n if(input.rateLimited)return Math.min(60,30*(2**Math.min(unchanged,1)));\n if(input.queueGate&&input.queueGate!==\"PASS\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.workerState!==\"HEALTHY\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.jobs.some(j=>j.state===\"LEASED\"))return Math.min(30,5*(2**Math.min(unchanged,2)));\n const ahead=input.jobs\n .filter(j=>j.state===\"READY\"&&Number.isInteger(j.transport_ready_ahead))\n .map(j=>Number(j.transport_ready_ahead));\n let base=15;\n if(ahead.length){\n const n=Math.min(...ahead);\n base=n===0?3:n<=3?5:n<=10?10:20;\n }\n return Math.min(60,base*(2**Math.min(unchanged,2)));\n}\n\nexport function nextPollDecision(input:{\n previousIdentity:string|null,\n previousUnchangedReads:number,\n rateLimited?:boolean,\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}){\n const identity=observationIdentity({\n rateLimited:input.rateLimited,\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId,\n queueGate:input.queueGate,\n jobs:input.jobs\n });\n const state=advanceObservationState(input.previousIdentity,identity,input.previousUnchangedReads);\n return {\n ...state,\n seconds:nextPollSeconds({\n rateLimited:input.rateLimited,\n workerState:input.workerState,\n queueGate:input.queueGate,\n jobs:input.jobs,\n unchangedReads:state.unchangedReads\n })\n };\n}\n",[182],"27be5069-810c-45c2-bd22-70fc8a0983d8","candidate_v2r1.sql","b6d7fa1e-a998-11f1-b0e0-1607ee4eb77e",15,["D",1788660879281],"WITH\ninput(raw) AS (VALUES (?)),\nmeta AS (\n SELECT raw,\n json_valid(raw) AS is_json,\n CASE WHEN json_valid(raw) THEN json_type(raw) ELSE NULL END AS root_type,\n length(raw) AS raw_len\n FROM input\n),\nsel AS (\n SELECT CAST(je.key AS INTEGER) AS idx, je.value AS job_id, je.type AS value_type\n FROM meta,\n json_each(CASE WHEN is_json=1 AND root_type='array' THEN raw ELSE '[]' END) AS je\n),\nsel_stats AS (\n SELECT\n (SELECT is_json FROM meta) AS is_json,\n (SELECT root_type FROM meta) AS root_type,\n (SELECT raw_len FROM meta) AS raw_len,\n COUNT(*) AS item_count,\n SUM(CASE WHEN value_type!='text' THEN 1 ELSE 0 END) AS non_text_count,\n SUM(CASE WHEN value_type='text' AND (length(job_id)<1 OR length(job_id)>256) THEN 1 ELSE 0 END) AS bad_length_count,\n COUNT(DISTINCT CASE WHEN value_type='text' THEN job_id END) AS distinct_text_count\n FROM sel\n),\nvalidation AS (\n SELECT CASE\n WHEN is_json!=1 THEN 'JOBS_JSON_INVALID'\n WHEN root_type!='array' THEN 'JOBS_ARRAY_REQUIRED'\n WHEN raw_len>4096 THEN 'JOBS_SELECTOR_TOO_LARGE'\n WHEN item_count>16 THEN 'TOO_MANY_JOB_IDS'\n WHEN COALESCE(non_text_count,0)>0 THEN 'JOB_ID_STRING_REQUIRED'\n WHEN COALESCE(bad_length_count,0)>0 THEN 'JOB_ID_LENGTH_INVALID'\n WHEN item_count!=distinct_text_count THEN 'DUPLICATE_JOB_ID'\n ELSE NULL\n END AS selector_error\n FROM sel_stats\n),\nclock AS (SELECT datetime('now') AS now_ts),\nworker_rows AS (\n SELECT\n instance_id,last_poll_at,last_result_at,lease_count,result_count,\n ((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS poll_age_seconds_raw,\n CAST(((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS INTEGER) AS poll_age_seconds\n FROM brain_bridge_workers_v4\n WHERE worker_id='project-brain-live-v1-worker-v2' AND last_poll_at IS NOT NULL\n),\nworker_agg AS (\n SELECT\n COUNT(*) AS total_instances,\n SUM(CASE WHEN poll_age_seconds_raw<0 THEN 1 ELSE 0 END) AS future_instances,\n SUM(CASE WHEN poll_age_seconds_raw>=0 AND poll_age_seconds_raw<=90 THEN 1 ELSE 0 END) AS fresh_instances,\n SUM(CASE WHEN poll_age_seconds_raw>90 AND poll_age_seconds_raw<=180 THEN 1 ELSE 0 END) AS degraded_instances\n FROM worker_rows\n),\nlatest_worker AS (\n SELECT * FROM worker_rows ORDER BY last_poll_at DESC, instance_id DESC LIMIT 1\n),\nqueue_stats AS (\n 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'\n AND (lease_owner IS NULL OR trim(lease_owner)='' OR lease_expires_at IS NULL OR julianday(lease_expires_at) IS NULL)\n THEN 1 ELSE 0 END) AS malformed_lease_count,\n SUM(CASE WHEN state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\n SUM(CASE WHEN state='READY' AND priority>1000000000 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),\ndup_active AS (\n SELECT COUNT(*) AS duplicate_worker_count FROM (\n SELECT lease_owner\n 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),\nready_order AS (\n SELECT\n id,\n CASE\n WHEN op='brain' AND json_valid(payload_json)=1 THEN\n CASE\n WHEN json_type(payload_json,'$.args')='array'\n AND json_array_length(json_extract(payload_json,'$.args'))=1\n AND json_extract(payload_json,'$.args[0]')='recover-stale'\n AND json_type(payload_json,'$.timeout')='integer'\n AND json_extract(payload_json,'$.timeout') BETWEEN 1 AND 120\n AND (SELECT COUNT(*) FROM json_each(payload_json))=2\n THEN 0 ELSE 1\n END\n ELSE 1\n END AS recovery_class,\n CASE WHEN priority>1000000000 THEN 1000000000 ELSE priority END AS effective_priority,\n created_at\n FROM brain_bridge_jobs\n WHERE state='READY'\n),\nranked_ready AS (\n SELECT\n id,\n ROW_NUMBER() OVER (ORDER BY recovery_class ASC,effective_priority DESC,created_at ASC,id ASC)-1 AS transport_ready_ahead\n FROM ready_order\n),\nselected AS (\n SELECT\n s.idx,s.job_id AS id,COALESCE(j.state,'MISSING') AS state,j.priority,\n CASE WHEN j.priority>1000000000 THEN 1000000000 ELSE j.priority END AS effective_priority,\n j.lease_owner,j.lease_expires_at,j.updated_at,\n CASE WHEN j.result_json IS NOT NULL THEN 1 ELSE 0 END AS result_available,\n CASE WHEN j.error_json IS NOT NULL THEN 1 ELSE 0 END AS error_available,\n CASE WHEN j.id IS NOT NULL AND j.state IN ('COMPLETE','FAILED') THEN 1 ELSE 0 END AS terminal,\n CASE WHEN j.state='READY' THEN rr.transport_ready_ahead ELSE NULL END AS transport_ready_ahead\n FROM sel AS s\n LEFT JOIN brain_bridge_jobs AS j ON j.id=s.job_id\n LEFT JOIN ranked_ready AS rr ON rr.id=j.id\n WHERE (SELECT selector_error FROM validation) IS NULL\n ORDER BY s.idx\n),\njobs_agg AS (\n SELECT json_group_array(json_object(\n 'id',id,\n 'state',state,\n 'priority',priority,\n 'effective_priority',effective_priority,\n 'lease_owner',lease_owner,\n 'lease_expires_at',lease_expires_at,\n 'updated_at',updated_at,\n 'result_available',result_available,\n 'error_available',error_available,\n 'terminal',terminal,\n 'transport_ready_ahead',transport_ready_ahead\n )) AS jobs_json\n FROM selected\n)\nSELECT json_object(\n 'schema','BRAIN_CONTROL_READMUX_V2',\n 'observed_at',(SELECT now_ts FROM clock),\n 'selector_error',(SELECT selector_error FROM validation),\n 'worker',json_object(\n 'worker_id','project-brain-live-v1-worker-v2',\n 'state',(\n SELECT CASE\n WHEN future_instances>0 THEN 'FUTURE_HEARTBEAT_FAIL_CLOSED'\n WHEN total_instances=0 THEN 'UNKNOWN'\n WHEN fresh_instances=1 THEN 'HEALTHY'\n WHEN fresh_instances>1 THEN 'AMBIGUOUS_FAIL_CLOSED'\n WHEN degraded_instances>0 THEN 'DEGRADED'\n ELSE 'DOWN'\n END FROM worker_agg\n ),\n 'latest_instance_id',(SELECT instance_id FROM latest_worker),\n 'latest_poll_age_seconds',(SELECT poll_age_seconds FROM latest_worker),\n 'future_instance_count',COALESCE((SELECT future_instances FROM worker_agg),0),\n 'fresh_instance_count',COALESCE((SELECT fresh_instances FROM worker_agg),0),\n 'degraded_instance_count',COALESCE((SELECT degraded_instances FROM worker_agg),0),\n 'endpoint_scope_attested',0\n ),\n 'queue',json_object(\n 'ready_count',COALESCE((SELECT ready_count FROM queue_stats),0),\n 'leased_count',COALESCE((SELECT leased_count FROM queue_stats),0),\n 'malformed_lease_count',COALESCE((SELECT malformed_lease_count FROM queue_stats),0),\n 'expired_lease_count',COALESCE((SELECT expired_lease_count FROM queue_stats),0),\n 'duplicate_active_worker_leases',COALESCE((SELECT duplicate_worker_count FROM dup_active),0),\n 'gate',CASE\n WHEN COALESCE((SELECT malformed_lease_count FROM queue_stats),0)>0 THEN 'MALFORMED_LEASE_METADATA'\n WHEN COALESCE((SELECT expired_lease_count FROM queue_stats),0)>0 THEN 'EXPIRED_LEASE_PRESENT'\n WHEN COALESCE((SELECT duplicate_worker_count FROM dup_active),0)>0 THEN 'DUPLICATE_ACTIVE_WORKER_LEASE'\n ELSE 'PASS'\n END,\n 'overcap_ready_count',COALESCE((SELECT overcap_ready_count FROM queue_stats),0),\n 'oldest_ready_at',(SELECT oldest_ready_at FROM queue_stats),\n 'earliest_lease_expiry',(SELECT earliest_lease_expiry FROM queue_stats),\n 'transport_priority_cap',1000000000,\n 'selection_policy','RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT'\n ),\n 'jobs',json(COALESCE((SELECT jobs_json FROM jobs_agg),'[]'))\n) AS snapshot_json",[189],"668ed63e-863c-4151-a980-24a02873db51","candidate.ts","7e0cb9dc-a997-11f1-9700-1607ee4eb77e",1,["D",1788660354491],"export type WorkerState=\"HEALTHY\"|\"DEGRADED\"|\"DOWN\"|\"UNKNOWN\"|\"AMBIGUOUS_FAIL_CLOSED\"|\"FUTURE_HEARTBEAT_FAIL_CLOSED\";\nexport type QueueGate=\"PASS\"|\"MALFORMED_LEASE_METADATA\"|\"EXPIRED_LEASE_PRESENT\"|\"DUPLICATE_ACTIVE_WORKER_LEASE\";\n\nexport function stableStaggerMs(agentId:string){\n let h=2166136261>>>0;\n for(const ch of agentId){\n h^=ch.codePointAt(0)??0;\n h=Math.imul(h,16777619)>>>0;\n }\n return h%2000;\n}\n\nexport function classifyWorker(total:number,fresh:number,degraded:number,future=0):WorkerState{\n if(future>0)return \"FUTURE_HEARTBEAT_FAIL_CLOSED\";\n if(total===0)return \"UNKNOWN\";\n if(fresh===1)return \"HEALTHY\";\n if(fresh>1)return \"AMBIGUOUS_FAIL_CLOSED\";\n if(degraded>0)return \"DEGRADED\";\n return \"DOWN\";\n}\n\nexport function queueGate(expired:number,duplicates:number,malformed=0):QueueGate{\n if(malformed>0)return \"MALFORMED_LEASE_METADATA\";\n if(expired>0)return \"EXPIRED_LEASE_PRESENT\";\n if(duplicates>0)return \"DUPLICATE_ACTIVE_WORKER_LEASE\";\n return \"PASS\";\n}\n\nexport type WatchedJobObservation={\n id?:string,\n state:string,\n updated_at?:string|null,\n transport_ready_ahead?:number|null\n};\n\nexport function observationIdentity(input:{\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}):string{\n return JSON.stringify({\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId??null,\n queueGate:input.queueGate,\n jobs:input.jobs.map(j=>({\n id:j.id??null,\n state:j.state,\n updated_at:j.updated_at??null,\n transport_ready_ahead:Number.isInteger(j.transport_ready_ahead)?Number(j.transport_ready_ahead):null\n }))\n });\n}\n\nexport function advanceObservationState(\n previousIdentity:string|null,\n currentIdentity:string,\n previousUnchangedReads:number\n){\n const prev=Math.max(0,Math.min(4,Math.trunc(previousUnchangedReads||0)));\n const same=previousIdentity!==null&&previousIdentity===currentIdentity;\n return {\n identity:currentIdentity,\n unchangedReads:same?Math.min(4,prev+1):0,\n changed:previousIdentity===null||!same\n };\n}\n\nexport function nextPollSeconds(input:{\n rateLimited?:boolean,\n workerState:WorkerState,\n queueGate?:QueueGate|string,\n jobs:Array<{state:string,transport_ready_ahead?:number|null}>,\n unchangedReads:number\n}):number|null{\n const unchanged=Math.max(0,Math.min(4,Math.trunc(input.unchangedReads||0)));\n if(input.jobs.length>0&&input.jobs.every(j=>j.state===\"COMPLETE\"||j.state===\"FAILED\"))return null;\n if(input.rateLimited)return Math.min(60,30*(2**Math.min(unchanged,1)));\n if(input.queueGate&&input.queueGate!==\"PASS\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.workerState!==\"HEALTHY\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.jobs.some(j=>j.state===\"LEASED\"))return Math.min(30,5*(2**Math.min(unchanged,2)));\n const ahead=input.jobs\n .filter(j=>j.state===\"READY\"&&Number.isInteger(j.transport_ready_ahead))\n .map(j=>Number(j.transport_ready_ahead));\n let base=15;\n if(ahead.length){\n const n=Math.min(...ahead);\n base=n===0?3:n<=3?5:n<=10?10:20;\n }\n return Math.min(60,base*(2**Math.min(unchanged,2)));\n}\n\nexport function nextPollDecision(input:{\n previousIdentity:string|null,\n previousUnchangedReads:number,\n rateLimited?:boolean,\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}){\n const identity=observationIdentity({\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId,\n queueGate:input.queueGate,\n jobs:input.jobs\n });\n const state=advanceObservationState(input.previousIdentity,identity,input.previousUnchangedReads);\n return {\n ...state,\n seconds:nextPollSeconds({\n rateLimited:input.rateLimited,\n workerState:input.workerState,\n queueGate:input.queueGate,\n jobs:input.jobs,\n unchangedReads:state.unchangedReads\n })\n };\n}\n",[196],"pulls","branches","forks","envVars",{"_209":61,"_211":61},"connections",{"_209":61,"_210":61},"count","unfilledCount","emptyCount",{"_43":195,"_32":196,"_30":197,"_141":-5,"_41":42,"_40":198,"_143":144,"_38":246,"_13":61,"_33":34,"_35":200,"_24":25,"_147":-5,"_222":247,"_27":248},{"_43":188,"_32":189,"_30":190,"_141":-5,"_41":42,"_40":191,"_143":144,"_38":243,"_13":61,"_33":20,"_35":193,"_24":25,"_147":-5,"_222":244,"_27":245},{"_43":181,"_32":182,"_30":183,"_141":-5,"_41":42,"_40":184,"_143":144,"_38":240,"_13":61,"_33":34,"_35":186,"_24":25,"_147":-5,"_222":241,"_27":242},{"_43":174,"_32":175,"_30":176,"_141":-5,"_41":42,"_40":177,"_143":144,"_38":237,"_13":172,"_33":34,"_35":179,"_24":25,"_147":-5,"_222":238,"_27":239},{"_43":170,"_32":28,"_30":31,"_141":-5,"_41":42,"_40":14,"_143":25,"_38":234,"_13":172,"_33":34,"_35":37,"_24":25,"_147":-5,"_222":235,"_27":236},{"_43":163,"_32":164,"_30":165,"_141":-5,"_41":42,"_40":166,"_143":144,"_38":231,"_13":61,"_33":34,"_35":168,"_24":25,"_147":-5,"_222":232,"_27":233},{"_43":156,"_32":157,"_30":158,"_141":-5,"_41":42,"_40":159,"_143":144,"_38":228,"_13":61,"_33":34,"_35":161,"_24":25,"_147":-5,"_222":229,"_27":230},{"_43":149,"_32":150,"_30":151,"_141":-5,"_41":42,"_40":152,"_143":144,"_38":225,"_13":61,"_33":34,"_35":154,"_24":25,"_147":-5,"_222":226,"_27":227},{"_43":138,"_32":139,"_30":140,"_141":-5,"_41":42,"_40":142,"_143":144,"_38":221,"_13":61,"_33":34,"_35":146,"_24":25,"_147":-5,"_222":223,"_27":224},["D",1788660660293],"children",[],[139],["D",1788660852929],[],[150],["D",1788660851578],[],[157],["D",1788660849612],[],[164],["D",1788661007901],[],[28],["D",1788660810928],[],[175],["D",1788660835129],[],[182],["D",1788660879281],[],[189],["D",1788660354491],[],[196],["D",1788660354429],["D",1789533091345],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":287,"_288":289,"_290":291,"_292":25,"_293":25,"_294":25,"_295":144,"_296":-5,"_297":-7,"_298":-7,"_299":61,"_300":25,"_301":25,"_302":-5,"_303":25,"_304":25,"_305":25,"_306":-5},"ENV",{"_258":259,"_260":261,"_262":88,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v17