[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_229":230,"_231":232},"routes/_app.x.$handle.$name",{"_96":95,"_31":43,"_105":86,"_26":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":24,"_120":121,"_122":24,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":24},"version",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","v2r1_poller_adv_test.ts","latestPath","fileId","a654b5ce-a998-11f1-ab32-1607ee4eb77e","name","fileType","script","content","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","createdAt",["D",1788660851578],"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",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},"branch",{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"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",{"_41":42,"_31":43,"_36":224,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":225,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":226,"_80":227,"_82":228,"_84":24},"tree",[195,196,197,198,199,200,201],"files",[195,196,197,198,199,200,201],"counts",{"_185":59,"_186":181,"_187":59,"_188":189,"_190":191},"contents",[127,128,129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":178,"_31":179,"_29":180,"_137":-5,"_39":40,"_38":181,"_139":140,"_36":182,"_13":59,"_32":33,"_34":183,"_23":24,"_143":-5,"_26":184},{"_41":171,"_31":172,"_29":173,"_137":-5,"_39":40,"_38":174,"_139":140,"_36":175,"_13":59,"_32":33,"_34":176,"_23":24,"_143":-5,"_26":177},{"_41":163,"_31":164,"_29":165,"_137":-5,"_39":40,"_38":166,"_139":140,"_36":167,"_13":168,"_32":33,"_34":169,"_23":24,"_143":-5,"_26":170},{"_41":155,"_31":156,"_29":157,"_137":-5,"_39":40,"_38":158,"_139":24,"_36":159,"_13":160,"_32":33,"_34":161,"_23":24,"_143":-5,"_26":162},{"_41":148,"_31":149,"_29":150,"_137":-5,"_39":40,"_38":151,"_139":140,"_36":152,"_13":59,"_32":33,"_34":153,"_23":24,"_143":-5,"_26":154},{"_41":145,"_31":27,"_29":30,"_137":-5,"_39":40,"_38":14,"_139":140,"_36":146,"_13":59,"_32":33,"_34":35,"_23":24,"_143":-5,"_26":147},{"_41":134,"_31":135,"_29":136,"_137":-5,"_39":40,"_38":138,"_139":140,"_36":141,"_13":59,"_32":33,"_34":142,"_23":24,"_143":-5,"_26":144},"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",[135],"c5bf8080-34f5-414e-8e3d-c3858ef4c2ac",["D",1788660851578],[27],"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",[149],"ee26265a-f31d-4b4e-b362-4a44405887c7","hash_evidence.ts","e1d74662-a997-11f1-b89a-1607ee4eb77e",9,["D",1788660759177],2,"const s=\"{\\n \\\"schema\\\": \\\"BRAIN_VAL_CONTROL_READMUX_V2_SECOND_PARTY_REPAIR_PROOF_V1\\\",\\n \\\"task_id\\\": \\\"BRAIN-VAL-CONTROL-PLANE-READMUX-V2-INDEPENDENT-VALIDATION-20260906\\\",\\n \\\"agent_id\\\": \\\"chat-bbn-20260906-0353-sol-a7c94f\\\",\\n \\\"parent_evidence\\\": {\\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 \\\"review_val\\\": \\\"mosadek/brain-readmux-v2-review-a7c94f\\\",\\n \\\"artifacts\\\": [\\n {\\n \\\"path\\\": \\\"candidate.ts\\\",\\n \\\"bytes\\\": 3948,\\n \\\"sha256\\\": \\\"97282abd4a0c5c858596b22fa24afc2681ecf6e5a2e98a6f68fee2e782d640ec\\\",\\n \\\"role\\\": \\\"exact frozen V2 poller copy\\\"\\n },\\n {\\n \\\"path\\\": \\\"composition_test.ts\\\",\\n \\\"bytes\\\": 3202,\\n \\\"sha256\\\": \\\"9a05608db8e677c43d4b4f439461e3bebee0eeee64db96737fc730a47d191d1a\\\",\\n \\\"role\\\": \\\"independent composition/counterexample test\\\"\\n },\\n {\\n \\\"path\\\": \\\"v2r1_sql_adv_test.ts\\\",\\n \\\"bytes\\\": 16701,\\n \\\"sha256\\\": \\\"adcbef7b20f12f7a1a30d01cca9c535441f343b249b0889acb52976b60efc6f0\\\",\\n \\\"role\\\": \\\"minimal LEFT-JOIN/MISSING-row repair proof\\\"\\n }\\n ],\\n \\\"counterexample\\\": {\\n \\\"live_requested_count\\\": 3,\\n \\\"live_returned_count\\\": 2,\\n \\\"missing_id\\\": \\\"__READMUX_A7C94F_MISSING_SENTINEL__\\\",\\n \\\"existing_returned_states\\\": [\\n \\\"COMPLETE\\\",\\n \\\"COMPLETE\\\"\\n ],\\n \\\"frozen_poller_result\\\": null,\\n \\\"classification\\\": \\\"MISSING_WATCHED_ID_FALSE_TERMINAL_STOP_REPRODUCED\\\"\\n },\\n \\\"minimal_repair\\\": {\\n \\\"sql_changes\\\": [\\n \\\"Preserve selector ordinal and selector job_id as returned id.\\\",\\n \\\"LEFT JOIN requested selector IDs to bridge jobs.\\\",\\n \\\"COALESCE missing job state to explicit MISSING.\\\",\\n \\\"MISSING terminal flag = 0.\\\"\\n ],\\n \\\"poller_changes\\\": \\\"NONE REQUIRED for bounded explicit-MISSING-row repair\\\",\\n \\\"result\\\": \\\"PASS\\\",\\n \\\"sql_adversarial\\\": \\\"26/26 PASS including mixed terminal+missing regression\\\",\\n \\\"composition\\\": \\\"9/9 PASS; explicit MISSING row causes continued polling (15s under DEGRADED worker)\\\"\\n },\\n \\\"scope\\\": \\\"NONAUTHORITY_REVIEW_PROOF_ONLY\\\",\\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(\"\")}));",[156],"a7a6dfc8-8357-483b-8804-08e9c26680d3","composition_test.ts","8c02d4ae-a997-11f1-bacc-1607ee4eb77e",10,["D",1788660810928],4,"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();",[164],"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",[172],"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",[179],"pulls","branches","forks","envVars",{"_192":59,"_194":59},"connections",{"_192":59,"_193":59},"count","unfilledCount","emptyCount",{"_41":178,"_31":179,"_29":180,"_137":-5,"_39":40,"_38":181,"_139":140,"_36":221,"_13":59,"_32":33,"_34":183,"_23":24,"_143":-5,"_203":222,"_26":223},{"_41":171,"_31":172,"_29":173,"_137":-5,"_39":40,"_38":174,"_139":140,"_36":218,"_13":59,"_32":33,"_34":176,"_23":24,"_143":-5,"_203":219,"_26":220},{"_41":163,"_31":164,"_29":165,"_137":-5,"_39":40,"_38":166,"_139":140,"_36":215,"_13":168,"_32":33,"_34":169,"_23":24,"_143":-5,"_203":216,"_26":217},{"_41":155,"_31":156,"_29":157,"_137":-5,"_39":40,"_38":158,"_139":24,"_36":212,"_13":160,"_32":33,"_34":161,"_23":24,"_143":-5,"_203":213,"_26":214},{"_41":148,"_31":149,"_29":150,"_137":-5,"_39":40,"_38":151,"_139":140,"_36":209,"_13":59,"_32":33,"_34":153,"_23":24,"_143":-5,"_203":210,"_26":211},{"_41":145,"_31":27,"_29":30,"_137":-5,"_39":40,"_38":14,"_139":140,"_36":206,"_13":59,"_32":33,"_34":35,"_23":24,"_143":-5,"_203":207,"_26":208},{"_41":134,"_31":135,"_29":136,"_137":-5,"_39":40,"_38":138,"_139":140,"_36":202,"_13":59,"_32":33,"_34":142,"_23":24,"_143":-5,"_203":204,"_26":205},["D",1788660660293],"children",[],[135],["D",1788660851578],[],[27],["D",1788660849612],[],[149],["D",1788660759177],[],[156],["D",1788660810928],[],[164],["D",1788660835129],[],[172],["D",1788660354491],[],[179],["D",1788660354429],["D",1789533091345],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"ctx",{"_78":-5,"_124":262,"_263":264,"_265":266,"_267":24,"_268":24,"_269":24,"_270":140,"_271":-5,"_272":-7,"_273":-7,"_274":59,"_275":24,"_276":24,"_277":-5,"_278":24,"_279":24,"_280":24,"_281":-5},"ENV",{"_233":234,"_235":236,"_237":86,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v13