[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_253":254,"_255":256},"routes/_app.x.$handle.$name",{"_95":94,"_31":42,"_104":85,"_26":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":24,"_119":120,"_121":24,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_40":41,"_31":42,"_35":43,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":62,"_63":64,"_65":66,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":24},"version",15,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":20,"_33":34,"_35":36,"_37":14,"_38":39,"_23":24},"previous","deleted",false,"deletedHere","path","candidate_v2r1.sql","latestPath","fileId","b6d7fa1e-a998-11f1-b0e0-1607ee4eb77e","name","fileType","content","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","createdAt",["D",1788660879281],"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",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":52,"_100":101,"_102":24},"branch",{"_13":84,"_31":85,"_40":39,"_86":41,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":42,"_93":94},"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",{"_40":41,"_31":42,"_35":248,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":62,"_63":64,"_65":249,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":250,"_79":251,"_81":252,"_83":24},"tree",[211,212,213,214,215,216,217,218,219],"files",[211,212,213,214,215,216,217,218,219],"counts",{"_201":58,"_202":197,"_203":58,"_204":205,"_206":207},"contents",[126,127,128,129,130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_40":194,"_31":195,"_29":196,"_138":-5,"_38":39,"_37":197,"_140":141,"_35":198,"_13":58,"_32":143,"_33":199,"_23":24,"_145":-5,"_26":200},{"_40":191,"_31":27,"_29":30,"_138":-5,"_38":39,"_37":14,"_140":141,"_35":192,"_13":58,"_32":20,"_33":34,"_23":24,"_145":-5,"_26":193},{"_40":184,"_31":185,"_29":186,"_138":-5,"_38":39,"_37":187,"_140":141,"_35":188,"_13":58,"_32":143,"_33":189,"_23":24,"_145":-5,"_26":190},{"_40":176,"_31":177,"_29":178,"_138":-5,"_38":39,"_37":179,"_140":141,"_35":180,"_13":181,"_32":143,"_33":182,"_23":24,"_145":-5,"_26":183},{"_40":168,"_31":169,"_29":170,"_138":-5,"_38":39,"_37":171,"_140":24,"_35":172,"_13":173,"_32":143,"_33":174,"_23":24,"_145":-5,"_26":175},{"_40":161,"_31":162,"_29":163,"_138":-5,"_38":39,"_37":164,"_140":141,"_35":165,"_13":58,"_32":143,"_33":166,"_23":24,"_145":-5,"_26":167},{"_40":154,"_31":155,"_29":156,"_138":-5,"_38":39,"_37":157,"_140":141,"_35":158,"_13":58,"_32":143,"_33":159,"_23":24,"_145":-5,"_26":160},{"_40":147,"_31":148,"_29":149,"_138":-5,"_38":39,"_37":150,"_140":141,"_35":151,"_13":58,"_32":143,"_33":152,"_23":24,"_145":-5,"_26":153},{"_40":135,"_31":136,"_29":137,"_138":-5,"_38":39,"_37":139,"_140":141,"_35":142,"_13":58,"_32":143,"_33":144,"_23":24,"_145":-5,"_26":146},"2b22ab5e-b00b-4bf4-82f5-a36f14734b63","v2r1_sql_adv_test.ts","34595588-a998-11f1-8704-1607ee4eb77e","parentId",7,"latest",true,["D",1788660660293],"script","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",[136],"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}));",[148],"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",[155],"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",[162],"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(\"\")}));",[169],"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();",[177],"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",[185],"27be5069-810c-45c2-bd22-70fc8a0983d8",["D",1788660879281],[27],"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",[195],"pulls","branches","forks","envVars",{"_208":58,"_210":58},"connections",{"_208":58,"_209":58},"count","unfilledCount","emptyCount",{"_40":194,"_31":195,"_29":196,"_138":-5,"_38":39,"_37":197,"_140":141,"_35":245,"_13":58,"_32":143,"_33":199,"_23":24,"_145":-5,"_221":246,"_26":247},{"_40":191,"_31":27,"_29":30,"_138":-5,"_38":39,"_37":14,"_140":141,"_35":242,"_13":58,"_32":20,"_33":34,"_23":24,"_145":-5,"_221":243,"_26":244},{"_40":184,"_31":185,"_29":186,"_138":-5,"_38":39,"_37":187,"_140":141,"_35":239,"_13":58,"_32":143,"_33":189,"_23":24,"_145":-5,"_221":240,"_26":241},{"_40":176,"_31":177,"_29":178,"_138":-5,"_38":39,"_37":179,"_140":141,"_35":236,"_13":181,"_32":143,"_33":182,"_23":24,"_145":-5,"_221":237,"_26":238},{"_40":168,"_31":169,"_29":170,"_138":-5,"_38":39,"_37":171,"_140":24,"_35":233,"_13":173,"_32":143,"_33":174,"_23":24,"_145":-5,"_221":234,"_26":235},{"_40":161,"_31":162,"_29":163,"_138":-5,"_38":39,"_37":164,"_140":141,"_35":230,"_13":58,"_32":143,"_33":166,"_23":24,"_145":-5,"_221":231,"_26":232},{"_40":154,"_31":155,"_29":156,"_138":-5,"_38":39,"_37":157,"_140":141,"_35":227,"_13":58,"_32":143,"_33":159,"_23":24,"_145":-5,"_221":228,"_26":229},{"_40":147,"_31":148,"_29":149,"_138":-5,"_38":39,"_37":150,"_140":141,"_35":224,"_13":58,"_32":143,"_33":152,"_23":24,"_145":-5,"_221":225,"_26":226},{"_40":135,"_31":136,"_29":137,"_138":-5,"_38":39,"_37":139,"_140":141,"_35":220,"_13":58,"_32":143,"_33":144,"_23":24,"_145":-5,"_221":222,"_26":223},["D",1788660660293],"children",[],[136],["D",1788660852929],[],[148],["D",1788660851578],[],[155],["D",1788660849612],[],[162],["D",1788660759177],[],[169],["D",1788660810928],[],[177],["D",1788660835129],[],[185],["D",1788660879281],[],[27],["D",1788660354491],[],[195],["D",1788660354429],["D",1789533091345],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":52,"_100":101,"_102":24},{"_13":84,"_31":85,"_40":39,"_86":41,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":42,"_93":94},"ctx",{"_77":-5,"_123":286,"_287":288,"_289":290,"_291":24,"_292":24,"_293":24,"_294":141,"_295":-5,"_296":-7,"_297":-7,"_298":58,"_299":24,"_300":24,"_301":-5,"_302":24,"_303":24,"_304":24,"_305":-5},"ENV",{"_257":258,"_259":260,"_261":85,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285},"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 · v15