[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_254":255,"_256":257},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",18,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","hash_evidence.ts","latestPath","fileId","e1d74662-a997-11f1-b89a-1607ee4eb77e","name","fileType","script","content","const s=\"{\\n \\\"schema\\\": \\\"BRAIN_VAL_CONTROL_READMUX_V2R1_REPAIR_CANDIDATE_PROOF_V1\\\",\\n \\\"source_validation_task\\\": \\\"BRAIN-VAL-CONTROL-PLANE-READMUX-V2-INDEPENDENT-VALIDATION-20260906\\\",\\n \\\"agent_id\\\": \\\"chat-bbn-20260906-0353-sol-a7c94f\\\",\\n \\\"classification\\\": \\\"CANDIDATE_NONAUTHORITY_REPAIR_PASS_LOCAL_AND_LIVE_READ_ONLY\\\",\\n \\\"parent_falsification\\\": {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-v1.json\\\",\\n \\\"bytes\\\": 6756,\\n \\\"sha256\\\": \\\"bf98b3b5de13301318dd7ee4af80559f16c78f8cf2467a2a49a19fda3a13da0e\\\"\\n },\\n \\\"prior_repair_supplement\\\": {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-repair-proof-v1.json\\\",\\n \\\"bytes\\\": 2271,\\n \\\"sha256\\\": \\\"12507f14e8b5d466b0a84b70bddf67630736640ce78942d34b47faa762a71451\\\"\\n },\\n \\\"repair_val\\\": \\\"mosadek/brain-readmux-v2-review-a7c94f\\\",\\n \\\"candidate_artifacts\\\": [\\n {\\n \\\"path\\\": \\\"candidate_v2r1.sql\\\",\\n \\\"bytes\\\": 7835,\\n \\\"sha256\\\": \\\"c38cd379147874928fd796c959cfd3326b4c989e0c3489e3a930011737be5d3c\\\"\\n },\\n {\\n \\\"path\\\": \\\"candidate_v2r1_poll.ts\\\",\\n \\\"bytes\\\": 4049,\\n \\\"sha256\\\": \\\"ffb7bd495e82d9ec3cfb3fba0095d2b2336d4065c4ae5c8f6edc577f1614d850\\\"\\n },\\n {\\n \\\"path\\\": \\\"v2r1_sql_adv_test.ts\\\",\\n \\\"bytes\\\": 16701,\\n \\\"sha256\\\": \\\"adcbef7b20f12f7a1a30d01cca9c535441f343b249b0889acb52976b60efc6f0\\\"\\n },\\n {\\n \\\"path\\\": \\\"v2r1_rate_transition_test.ts\\\",\\n \\\"bytes\\\": 1349,\\n \\\"sha256\\\": \\\"a4851dbf0b9806fdfec30f962af703767a742d7f21e6e672cd98c45048d6874a\\\"\\n }\\n ],\\n \\\"repairs\\\": [\\n {\\n \\\"id\\\": \\\"D4_MISSING_WATCHED_ID_FALSE_TERMINAL_STOP\\\",\\n \\\"mechanism\\\": \\\"SQL preserves every requested selector ID via LEFT JOIN; unmatched IDs are explicit state=MISSING, terminal=0.\\\",\\n \\\"poller_change_required\\\": false\\n },\\n {\\n \\\"id\\\": \\\"D5_RATE_LIMIT_TRANSITION_NOT_IN_OBSERVATION_IDENTITY\\\",\\n \\\"mechanism\\\": \\\"rateLimited boolean is added to observationIdentity and nextPollDecision identity construction, resetting state on 429 enter/clear.\\\"\\n }\\n ],\\n \\\"verification\\\": {\\n \\\"patched_v2_unit\\\": \\\"36/36 PASS\\\",\\n \\\"patched_poller_adversarial\\\": \\\"21/21 PASS\\\",\\n \\\"patched_sql_adversarial\\\": \\\"26/26 PASS\\\",\\n \\\"patched_rate_limit_transition\\\": \\\"3/3 PASS\\\",\\n \\\"missing_id_composition_repair\\\": \\\"explicit MISSING row keeps polling active\\\",\\n \\\"one_bound_sql_parameter\\\": true,\\n \\\"static_sql_mutation_tokens\\\": 0,\\n \\\"sql_semicolons\\\": 0\\n },\\n \\\"live_repaired_read\\\": {\\n \\\"observed_at_utc\\\": \\\"2026-09-06T02:14:40Z\\\",\\n \\\"requested_count\\\": 3,\\n \\\"returned_count\\\": 3,\\n \\\"jobs\\\": [\\n {\\n \\\"id\\\": \\\"chat-sol-20260906-0353-a7c94f-status\\\",\\n \\\"state\\\": \\\"COMPLETE\\\",\\n \\\"terminal\\\": 1\\n },\\n {\\n \\\"id\\\": \\\"chat-sol-20260906-0353-a7c94f-claim\\\",\\n \\\"state\\\": \\\"COMPLETE\\\",\\n \\\"terminal\\\": 1\\n },\\n {\\n \\\"id\\\": \\\"__READMUX_A7C94F_MISSING_SENTINEL__\\\",\\n \\\"state\\\": \\\"MISSING\\\",\\n \\\"terminal\\\": 0\\n }\\n ],\\n \\\"worker_state\\\": \\\"AMBIGUOUS_FAIL_CLOSED\\\",\\n \\\"fresh_instance_count\\\": 2,\\n \\\"queue_gate\\\": \\\"PASS\\\",\\n \\\"rows_affected\\\": 0,\\n \\\"endpoint_scope_attested\\\": 0,\\n \\\"payload_result_error_bodies_returned\\\": false\\n },\\n \\\"promotion\\\": {\\n \\\"v2_unchanged\\\": \\\"REJECT\\\",\\n \\\"v2r1\\\": \\\"REQUIRES_DISTINCT_SECOND_PARTY_VALIDATION_BEFORE_PRODUCTION_ADOPTION\\\"\\n },\\n \\\"production_main_mutation\\\": false,\\n \\\"canonical_brain_py_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false\\n}\";\nconst b=new TextEncoder().encode(s);\nconst h=await crypto.subtle.digest(\"SHA-256\",b);\nconsole.log(JSON.stringify({bytes:b.length,sha256:[...new Uint8Array(h)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}));","const s=\"{\\n \\\"schema\\\": \\\"BRAIN_READMUX_V2_VALIDATION_CONTINUATION_V1\\\",\\n \\\"task_id\\\": \\\"BRAIN-VAL-CONTROL-PLANE-READMUX-V2-INDEPENDENT-VALIDATION-20260906\\\",\\n \\\"agent_id\\\": \\\"chat-bbn-20260906-0353-sol-a7c94f\\\",\\n \\\"status\\\": \\\"WORK_COMPLETE_PENDING_CANONICAL_BRAIN_COMMIT\\\",\\n \\\"original_lease_expires_at\\\": \\\"2026-09-06T02:29:39.176985+00:00\\\",\\n \\\"renewal_job\\\": \\\"chat-sol-20260906-0353-a7c94f-renew-1\\\",\\n \\\"verdict\\\": \\\"V2_UNCHANGED_REJECT\\\",\\n \\\"evidence\\\": [\\n {\\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 \\\"role\\\": \\\"independent validation/falsification\\\"\\n },\\n {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-repair-proof-v1.json\\\",\\n \\\"bytes\\\": 2271,\\n \\\"sha256\\\": \\\"12507f14e8b5d466b0a84b70bddf67630736640ce78942d34b47faa762a71451\\\",\\n \\\"role\\\": \\\"initial bounded D4 repair proof\\\"\\n },\\n {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-v2r1-proof-v1.json\\\",\\n \\\"bytes\\\": 3488,\\n \\\"sha256\\\": \\\"6351a46218125e968b6850087019c38d3627ecda0425b2ca02656b3e56acb7c3\\\",\\n \\\"role\\\": \\\"combined D4+D5 V2R1 candidate proof\\\"\\n }\\n ],\\n \\\"defects\\\": [\\n \\\"D4_MISSING_WATCHED_ID_FALSE_TERMINAL_STOP: promotion blocking\\\",\\n \\\"D5_RATE_LIMIT_TRANSITION_NOT_IN_OBSERVATION_IDENTITY: bounded sequencing/backoff defect\\\"\\n ],\\n \\\"v2r1_candidate\\\": {\\n \\\"val\\\": \\\"mosadek/brain-readmux-v2-review-a7c94f\\\",\\n \\\"sql\\\": {\\n \\\"path\\\": \\\"candidate_v2r1.sql\\\",\\n \\\"bytes\\\": 7835,\\n \\\"sha256\\\": \\\"c38cd379147874928fd796c959cfd3326b4c989e0c3489e3a930011737be5d3c\\\"\\n },\\n \\\"poll\\\": {\\n \\\"path\\\": \\\"candidate_v2r1_poll.ts\\\",\\n \\\"bytes\\\": 4049,\\n \\\"sha256\\\": \\\"ffb7bd495e82d9ec3cfb3fba0095d2b2336d4065c4ae5c8f6edc577f1614d850\\\"\\n },\\n \\\"tests\\\": [\\n \\\"36/36 V2 unit PASS\\\",\\n \\\"21/21 V2 poller adversarial PASS\\\",\\n \\\"26/26 SQL adversarial PASS\\\",\\n \\\"3/3 429 transition PASS\\\",\\n \\\"live read-only mixed missing selector PASS\\\"\\n ]\\n },\\n \\\"canonical_commit_template\\\": {\\n \\\"state\\\": \\\"COMPLETE\\\",\\n \\\"payload\\\": {\\n \\\"result\\\": \\\"FAIL\\\",\\n \\\"classification\\\": \\\"SECOND_PARTY_FAIL_PRODUCTION_ADOPTION_UNCHANGED\\\",\\n \\\"verdict\\\": \\\"V2_UNCHANGED_REJECT__V2R1_CANDIDATE_REQUIRES_DISTINCT_SECOND_PARTY_VALIDATION\\\",\\n \\\"evidence_uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-v1.json\\\",\\n \\\"evidence_sha256\\\": \\\"bf98b3b5de13301318dd7ee4af80559f16c78f8cf2467a2a49a19fda3a13da0e\\\",\\n \\\"repair_proof_uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_val_control_readmux_v2_secondparty/chat-bbn-20260906-0353-sol-a7c94f-v2r1-proof-v1.json\\\",\\n \\\"repair_proof_sha256\\\": \\\"6351a46218125e968b6850087019c38d3627ecda0425b2ca02656b3e56acb7c3\\\",\\n \\\"defects\\\": [\\n \\\"D4_MISSING_WATCHED_ID_FALSE_TERMINAL_STOP\\\",\\n \\\"D5_RATE_LIMIT_TRANSITION_NOT_IN_OBSERVATION_IDENTITY\\\"\\n ],\\n \\\"source_branch\\\": \\\"readmux-v2-repair-n4x7\\\",\\n \\\"repair_val\\\": \\\"mosadek/brain-readmux-v2-review-a7c94f\\\",\\n \\\"production_main_mutation\\\": false,\\n \\\"canonical_brain_py_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false\\n }\\n },\\n \\\"recovery_if_lease_expires\\\": [\\n \\\"Use the Val bridge only.\\\",\\n \\\"Run canonical recover-stale through brain_bridge_jobs after lease expiry if needed.\\\",\\n \\\"Reclaim this exact task as the same CHAT agent if still available, or let a successor claim it.\\\",\\n \\\"Do not rerun the scientific validation; verify the three evidence hashes instead.\\\",\\n \\\"Reconcile current global workstream generation and commit state COMPLETE with the stored FAIL payload.\\\",\\n \\\"Then create/claim only a distinct-agent V2R1 validation gate; this agent must not self-promote V2R1.\\\"\\n ],\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false\\n}\";\nconst b=new TextEncoder().encode(s);\nconst h=await crypto.subtle.digest(\"SHA-256\",b);\nconsole.log(JSON.stringify({bytes:b.length,sha256:[...new Uint8Array(h)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}));","createdAt",["D",1788661079915],"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",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":14,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":249,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":250,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":251,"_82":252,"_84":253,"_86":25},"tree",[212,213,214,215,216,217,218,219,220],"files",[212,213,214,215,216,217,218,219,220],"counts",{"_202":61,"_203":198,"_204":61,"_205":206,"_207":208},"contents",[128,129,130,131,132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":195,"_32":196,"_30":197,"_140":-5,"_41":42,"_40":198,"_142":143,"_38":199,"_13":61,"_33":34,"_35":200,"_24":25,"_146":-5,"_27":201},{"_43":188,"_32":189,"_30":190,"_140":-5,"_41":42,"_40":191,"_142":143,"_38":192,"_13":61,"_33":20,"_35":193,"_24":25,"_146":-5,"_27":194},{"_43":181,"_32":182,"_30":183,"_140":-5,"_41":42,"_40":184,"_142":143,"_38":185,"_13":61,"_33":34,"_35":186,"_24":25,"_146":-5,"_27":187},{"_43":173,"_32":174,"_30":175,"_140":-5,"_41":42,"_40":176,"_142":143,"_38":177,"_13":178,"_33":34,"_35":179,"_24":25,"_146":-5,"_27":180},{"_43":169,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":143,"_38":170,"_13":171,"_33":34,"_35":37,"_24":25,"_146":-5,"_27":172},{"_43":162,"_32":163,"_30":164,"_140":-5,"_41":42,"_40":165,"_142":143,"_38":166,"_13":61,"_33":34,"_35":167,"_24":25,"_146":-5,"_27":168},{"_43":155,"_32":156,"_30":157,"_140":-5,"_41":42,"_40":158,"_142":143,"_38":159,"_13":61,"_33":34,"_35":160,"_24":25,"_146":-5,"_27":161},{"_43":148,"_32":149,"_30":150,"_140":-5,"_41":42,"_40":151,"_142":143,"_38":152,"_13":61,"_33":34,"_35":153,"_24":25,"_146":-5,"_27":154},{"_43":137,"_32":138,"_30":139,"_140":-5,"_41":42,"_40":141,"_142":143,"_38":144,"_13":61,"_33":34,"_35":145,"_24":25,"_146":-5,"_27":147},"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",[138],"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}));",[149],"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",[156],"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",[163],"36ebd9e7-d935-4878-b7a9-32e26f2b08ed",["D",1788661079915],5,[28],"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();",[174],"a682e957-f2c7-4a0d-8150-1effb2a1e44e","candidate_v2r1_poll.ts","9c86cc94-a998-11f1-9cc4-1607ee4eb77e",11,["D",1788660835129],"export type WorkerState=\"HEALTHY\"|\"DEGRADED\"|\"DOWN\"|\"UNKNOWN\"|\"AMBIGUOUS_FAIL_CLOSED\"|\"FUTURE_HEARTBEAT_FAIL_CLOSED\";\nexport type QueueGate=\"PASS\"|\"MALFORMED_LEASE_METADATA\"|\"EXPIRED_LEASE_PRESENT\"|\"DUPLICATE_ACTIVE_WORKER_LEASE\";\n\nexport function stableStaggerMs(agentId:string){\n let h=2166136261>>>0;\n for(const ch of agentId){\n h^=ch.codePointAt(0)??0;\n h=Math.imul(h,16777619)>>>0;\n }\n return h%2000;\n}\n\nexport function classifyWorker(total:number,fresh:number,degraded:number,future=0):WorkerState{\n if(future>0)return \"FUTURE_HEARTBEAT_FAIL_CLOSED\";\n if(total===0)return \"UNKNOWN\";\n if(fresh===1)return \"HEALTHY\";\n if(fresh>1)return \"AMBIGUOUS_FAIL_CLOSED\";\n if(degraded>0)return \"DEGRADED\";\n return \"DOWN\";\n}\n\nexport function queueGate(expired:number,duplicates:number,malformed=0):QueueGate{\n if(malformed>0)return \"MALFORMED_LEASE_METADATA\";\n if(expired>0)return \"EXPIRED_LEASE_PRESENT\";\n if(duplicates>0)return \"DUPLICATE_ACTIVE_WORKER_LEASE\";\n return \"PASS\";\n}\n\nexport type WatchedJobObservation={\n id?:string,\n state:string,\n updated_at?:string|null,\n transport_ready_ahead?:number|null\n};\n\nexport function observationIdentity(input:{\n rateLimited?:boolean,\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}):string{\n return JSON.stringify({\n rateLimited:input.rateLimited===true,\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId??null,\n queueGate:input.queueGate,\n jobs:input.jobs.map(j=>({\n id:j.id??null,\n state:j.state,\n updated_at:j.updated_at??null,\n transport_ready_ahead:Number.isInteger(j.transport_ready_ahead)?Number(j.transport_ready_ahead):null\n }))\n });\n}\n\nexport function advanceObservationState(\n previousIdentity:string|null,\n currentIdentity:string,\n previousUnchangedReads:number\n){\n const prev=Math.max(0,Math.min(4,Math.trunc(previousUnchangedReads||0)));\n const same=previousIdentity!==null&&previousIdentity===currentIdentity;\n return {\n identity:currentIdentity,\n unchangedReads:same?Math.min(4,prev+1):0,\n changed:previousIdentity===null||!same\n };\n}\n\nexport function nextPollSeconds(input:{\n rateLimited?:boolean,\n workerState:WorkerState,\n queueGate?:QueueGate|string,\n jobs:Array<{state:string,transport_ready_ahead?:number|null}>,\n unchangedReads:number\n}):number|null{\n const unchanged=Math.max(0,Math.min(4,Math.trunc(input.unchangedReads||0)));\n if(input.jobs.length>0&&input.jobs.every(j=>j.state===\"COMPLETE\"||j.state===\"FAILED\"))return null;\n if(input.rateLimited)return Math.min(60,30*(2**Math.min(unchanged,1)));\n if(input.queueGate&&input.queueGate!==\"PASS\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.workerState!==\"HEALTHY\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.jobs.some(j=>j.state===\"LEASED\"))return Math.min(30,5*(2**Math.min(unchanged,2)));\n const ahead=input.jobs\n .filter(j=>j.state===\"READY\"&&Number.isInteger(j.transport_ready_ahead))\n .map(j=>Number(j.transport_ready_ahead));\n let base=15;\n if(ahead.length){\n const n=Math.min(...ahead);\n base=n===0?3:n<=3?5:n<=10?10:20;\n }\n return Math.min(60,base*(2**Math.min(unchanged,2)));\n}\n\nexport function nextPollDecision(input:{\n previousIdentity:string|null,\n previousUnchangedReads:number,\n rateLimited?:boolean,\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}){\n const identity=observationIdentity({\n rateLimited:input.rateLimited,\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId,\n queueGate:input.queueGate,\n jobs:input.jobs\n });\n const state=advanceObservationState(input.previousIdentity,identity,input.previousUnchangedReads);\n return {\n ...state,\n seconds:nextPollSeconds({\n rateLimited:input.rateLimited,\n workerState:input.workerState,\n queueGate:input.queueGate,\n jobs:input.jobs,\n unchangedReads:state.unchangedReads\n })\n };\n}\n",[182],"27be5069-810c-45c2-bd22-70fc8a0983d8","candidate_v2r1.sql","b6d7fa1e-a998-11f1-b0e0-1607ee4eb77e",15,["D",1788660879281],"WITH\ninput(raw) AS (VALUES (?)),\nmeta AS (\n SELECT raw,\n json_valid(raw) AS is_json,\n CASE WHEN json_valid(raw) THEN json_type(raw) ELSE NULL END AS root_type,\n length(raw) AS raw_len\n FROM input\n),\nsel AS (\n SELECT CAST(je.key AS INTEGER) AS idx, je.value AS job_id, je.type AS value_type\n FROM meta,\n json_each(CASE WHEN is_json=1 AND root_type='array' THEN raw ELSE '[]' END) AS je\n),\nsel_stats AS (\n SELECT\n (SELECT is_json FROM meta) AS is_json,\n (SELECT root_type FROM meta) AS root_type,\n (SELECT raw_len FROM meta) AS raw_len,\n COUNT(*) AS item_count,\n SUM(CASE WHEN value_type!='text' THEN 1 ELSE 0 END) AS non_text_count,\n SUM(CASE WHEN value_type='text' AND (length(job_id)<1 OR length(job_id)>256) THEN 1 ELSE 0 END) AS bad_length_count,\n COUNT(DISTINCT CASE WHEN value_type='text' THEN job_id END) AS distinct_text_count\n FROM sel\n),\nvalidation AS (\n SELECT CASE\n WHEN is_json!=1 THEN 'JOBS_JSON_INVALID'\n WHEN root_type!='array' THEN 'JOBS_ARRAY_REQUIRED'\n WHEN raw_len>4096 THEN 'JOBS_SELECTOR_TOO_LARGE'\n WHEN item_count>16 THEN 'TOO_MANY_JOB_IDS'\n WHEN COALESCE(non_text_count,0)>0 THEN 'JOB_ID_STRING_REQUIRED'\n WHEN COALESCE(bad_length_count,0)>0 THEN 'JOB_ID_LENGTH_INVALID'\n WHEN item_count!=distinct_text_count THEN 'DUPLICATE_JOB_ID'\n ELSE NULL\n END AS selector_error\n FROM sel_stats\n),\nclock AS (SELECT datetime('now') AS now_ts),\nworker_rows AS (\n SELECT\n instance_id,last_poll_at,last_result_at,lease_count,result_count,\n ((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS poll_age_seconds_raw,\n CAST(((julianday((SELECT now_ts FROM clock))-julianday(last_poll_at))*86400.0) AS INTEGER) AS poll_age_seconds\n FROM brain_bridge_workers_v4\n WHERE worker_id='project-brain-live-v1-worker-v2' AND last_poll_at IS NOT NULL\n),\nworker_agg AS (\n SELECT\n COUNT(*) AS total_instances,\n SUM(CASE WHEN poll_age_seconds_raw<0 THEN 1 ELSE 0 END) AS future_instances,\n SUM(CASE WHEN poll_age_seconds_raw>=0 AND poll_age_seconds_raw<=90 THEN 1 ELSE 0 END) AS fresh_instances,\n SUM(CASE WHEN poll_age_seconds_raw>90 AND poll_age_seconds_raw<=180 THEN 1 ELSE 0 END) AS degraded_instances\n FROM worker_rows\n),\nlatest_worker AS (\n SELECT * FROM worker_rows ORDER BY last_poll_at DESC, instance_id DESC LIMIT 1\n),\nqueue_stats AS (\n SELECT\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\n SUM(CASE WHEN state='LEASED' THEN 1 ELSE 0 END) AS leased_count,\n SUM(CASE WHEN state='LEASED'\n AND (lease_owner IS NULL OR trim(lease_owner)='' OR lease_expires_at IS NULL OR julianday(lease_expires_at) IS NULL)\n THEN 1 ELSE 0 END) AS malformed_lease_count,\n SUM(CASE WHEN state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\n SUM(CASE WHEN state='READY' AND priority>1000000000 THEN 1 ELSE 0 END) AS overcap_ready_count,\n MIN(CASE WHEN state='READY' THEN created_at END) AS oldest_ready_at,\n MIN(CASE WHEN state='LEASED' THEN lease_expires_at END) AS earliest_lease_expiry\n FROM brain_bridge_jobs\n),\ndup_active AS (\n SELECT COUNT(*) AS duplicate_worker_count FROM (\n SELECT lease_owner\n FROM brain_bridge_jobs\n WHERE state='LEASED' AND lease_expires_at>datetime('now') AND lease_owner IS NOT NULL\n GROUP BY lease_owner HAVING COUNT(*)>1\n )\n),\nready_order AS (\n SELECT\n id,\n CASE\n WHEN op='brain' AND json_valid(payload_json)=1 THEN\n CASE\n WHEN json_type(payload_json,'$.args')='array'\n AND json_array_length(json_extract(payload_json,'$.args'))=1\n AND json_extract(payload_json,'$.args[0]')='recover-stale'\n AND json_type(payload_json,'$.timeout')='integer'\n AND json_extract(payload_json,'$.timeout') BETWEEN 1 AND 120\n AND (SELECT COUNT(*) FROM json_each(payload_json))=2\n THEN 0 ELSE 1\n END\n ELSE 1\n END AS recovery_class,\n CASE WHEN priority>1000000000 THEN 1000000000 ELSE priority END AS effective_priority,\n created_at\n FROM brain_bridge_jobs\n WHERE state='READY'\n),\nranked_ready AS (\n SELECT\n id,\n ROW_NUMBER() OVER (ORDER BY recovery_class ASC,effective_priority DESC,created_at ASC,id ASC)-1 AS transport_ready_ahead\n FROM ready_order\n),\nselected AS (\n SELECT\n s.idx,s.job_id AS id,COALESCE(j.state,'MISSING') AS state,j.priority,\n CASE WHEN j.priority>1000000000 THEN 1000000000 ELSE j.priority END AS effective_priority,\n j.lease_owner,j.lease_expires_at,j.updated_at,\n CASE WHEN j.result_json IS NOT NULL THEN 1 ELSE 0 END AS result_available,\n CASE WHEN j.error_json IS NOT NULL THEN 1 ELSE 0 END AS error_available,\n CASE WHEN j.id IS NOT NULL AND j.state IN ('COMPLETE','FAILED') THEN 1 ELSE 0 END AS terminal,\n CASE WHEN j.state='READY' THEN rr.transport_ready_ahead ELSE NULL END AS transport_ready_ahead\n FROM sel AS s\n LEFT JOIN brain_bridge_jobs AS j ON j.id=s.job_id\n LEFT JOIN ranked_ready AS rr ON rr.id=j.id\n WHERE (SELECT selector_error FROM validation) IS NULL\n ORDER BY s.idx\n),\njobs_agg AS (\n SELECT json_group_array(json_object(\n 'id',id,\n 'state',state,\n 'priority',priority,\n 'effective_priority',effective_priority,\n 'lease_owner',lease_owner,\n 'lease_expires_at',lease_expires_at,\n 'updated_at',updated_at,\n 'result_available',result_available,\n 'error_available',error_available,\n 'terminal',terminal,\n 'transport_ready_ahead',transport_ready_ahead\n )) AS jobs_json\n FROM selected\n)\nSELECT json_object(\n 'schema','BRAIN_CONTROL_READMUX_V2',\n 'observed_at',(SELECT now_ts FROM clock),\n 'selector_error',(SELECT selector_error FROM validation),\n 'worker',json_object(\n 'worker_id','project-brain-live-v1-worker-v2',\n 'state',(\n SELECT CASE\n WHEN future_instances>0 THEN 'FUTURE_HEARTBEAT_FAIL_CLOSED'\n WHEN total_instances=0 THEN 'UNKNOWN'\n WHEN fresh_instances=1 THEN 'HEALTHY'\n WHEN fresh_instances>1 THEN 'AMBIGUOUS_FAIL_CLOSED'\n WHEN degraded_instances>0 THEN 'DEGRADED'\n ELSE 'DOWN'\n END FROM worker_agg\n ),\n 'latest_instance_id',(SELECT instance_id FROM latest_worker),\n 'latest_poll_age_seconds',(SELECT poll_age_seconds FROM latest_worker),\n 'future_instance_count',COALESCE((SELECT future_instances FROM worker_agg),0),\n 'fresh_instance_count',COALESCE((SELECT fresh_instances FROM worker_agg),0),\n 'degraded_instance_count',COALESCE((SELECT degraded_instances FROM worker_agg),0),\n 'endpoint_scope_attested',0\n ),\n 'queue',json_object(\n 'ready_count',COALESCE((SELECT ready_count FROM queue_stats),0),\n 'leased_count',COALESCE((SELECT leased_count FROM queue_stats),0),\n 'malformed_lease_count',COALESCE((SELECT malformed_lease_count FROM queue_stats),0),\n 'expired_lease_count',COALESCE((SELECT expired_lease_count FROM queue_stats),0),\n 'duplicate_active_worker_leases',COALESCE((SELECT duplicate_worker_count FROM dup_active),0),\n 'gate',CASE\n WHEN COALESCE((SELECT malformed_lease_count FROM queue_stats),0)>0 THEN 'MALFORMED_LEASE_METADATA'\n WHEN COALESCE((SELECT expired_lease_count FROM queue_stats),0)>0 THEN 'EXPIRED_LEASE_PRESENT'\n WHEN COALESCE((SELECT duplicate_worker_count FROM dup_active),0)>0 THEN 'DUPLICATE_ACTIVE_WORKER_LEASE'\n ELSE 'PASS'\n END,\n 'overcap_ready_count',COALESCE((SELECT overcap_ready_count FROM queue_stats),0),\n 'oldest_ready_at',(SELECT oldest_ready_at FROM queue_stats),\n 'earliest_lease_expiry',(SELECT earliest_lease_expiry FROM queue_stats),\n 'transport_priority_cap',1000000000,\n 'selection_policy','RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT'\n ),\n 'jobs',json(COALESCE((SELECT jobs_json FROM jobs_agg),'[]'))\n) AS snapshot_json",[189],"668ed63e-863c-4151-a980-24a02873db51","candidate.ts","7e0cb9dc-a997-11f1-9700-1607ee4eb77e",1,["D",1788660354491],"export type WorkerState=\"HEALTHY\"|\"DEGRADED\"|\"DOWN\"|\"UNKNOWN\"|\"AMBIGUOUS_FAIL_CLOSED\"|\"FUTURE_HEARTBEAT_FAIL_CLOSED\";\nexport type QueueGate=\"PASS\"|\"MALFORMED_LEASE_METADATA\"|\"EXPIRED_LEASE_PRESENT\"|\"DUPLICATE_ACTIVE_WORKER_LEASE\";\n\nexport function stableStaggerMs(agentId:string){\n let h=2166136261>>>0;\n for(const ch of agentId){\n h^=ch.codePointAt(0)??0;\n h=Math.imul(h,16777619)>>>0;\n }\n return h%2000;\n}\n\nexport function classifyWorker(total:number,fresh:number,degraded:number,future=0):WorkerState{\n if(future>0)return \"FUTURE_HEARTBEAT_FAIL_CLOSED\";\n if(total===0)return \"UNKNOWN\";\n if(fresh===1)return \"HEALTHY\";\n if(fresh>1)return \"AMBIGUOUS_FAIL_CLOSED\";\n if(degraded>0)return \"DEGRADED\";\n return \"DOWN\";\n}\n\nexport function queueGate(expired:number,duplicates:number,malformed=0):QueueGate{\n if(malformed>0)return \"MALFORMED_LEASE_METADATA\";\n if(expired>0)return \"EXPIRED_LEASE_PRESENT\";\n if(duplicates>0)return \"DUPLICATE_ACTIVE_WORKER_LEASE\";\n return \"PASS\";\n}\n\nexport type WatchedJobObservation={\n id?:string,\n state:string,\n updated_at?:string|null,\n transport_ready_ahead?:number|null\n};\n\nexport function observationIdentity(input:{\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}):string{\n return JSON.stringify({\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId??null,\n queueGate:input.queueGate,\n jobs:input.jobs.map(j=>({\n id:j.id??null,\n state:j.state,\n updated_at:j.updated_at??null,\n transport_ready_ahead:Number.isInteger(j.transport_ready_ahead)?Number(j.transport_ready_ahead):null\n }))\n });\n}\n\nexport function advanceObservationState(\n previousIdentity:string|null,\n currentIdentity:string,\n previousUnchangedReads:number\n){\n const prev=Math.max(0,Math.min(4,Math.trunc(previousUnchangedReads||0)));\n const same=previousIdentity!==null&&previousIdentity===currentIdentity;\n return {\n identity:currentIdentity,\n unchangedReads:same?Math.min(4,prev+1):0,\n changed:previousIdentity===null||!same\n };\n}\n\nexport function nextPollSeconds(input:{\n rateLimited?:boolean,\n workerState:WorkerState,\n queueGate?:QueueGate|string,\n jobs:Array<{state:string,transport_ready_ahead?:number|null}>,\n unchangedReads:number\n}):number|null{\n const unchanged=Math.max(0,Math.min(4,Math.trunc(input.unchangedReads||0)));\n if(input.jobs.length>0&&input.jobs.every(j=>j.state===\"COMPLETE\"||j.state===\"FAILED\"))return null;\n if(input.rateLimited)return Math.min(60,30*(2**Math.min(unchanged,1)));\n if(input.queueGate&&input.queueGate!==\"PASS\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.workerState!==\"HEALTHY\")return Math.min(60,15*(2**Math.min(unchanged,2)));\n if(input.jobs.some(j=>j.state===\"LEASED\"))return Math.min(30,5*(2**Math.min(unchanged,2)));\n const ahead=input.jobs\n .filter(j=>j.state===\"READY\"&&Number.isInteger(j.transport_ready_ahead))\n .map(j=>Number(j.transport_ready_ahead));\n let base=15;\n if(ahead.length){\n const n=Math.min(...ahead);\n base=n===0?3:n<=3?5:n<=10?10:20;\n }\n return Math.min(60,base*(2**Math.min(unchanged,2)));\n}\n\nexport function nextPollDecision(input:{\n previousIdentity:string|null,\n previousUnchangedReads:number,\n rateLimited?:boolean,\n workerState:WorkerState,\n workerInstanceId?:string|null,\n queueGate:QueueGate|string,\n jobs:WatchedJobObservation[]\n}){\n const identity=observationIdentity({\n workerState:input.workerState,\n workerInstanceId:input.workerInstanceId,\n queueGate:input.queueGate,\n jobs:input.jobs\n });\n const state=advanceObservationState(input.previousIdentity,identity,input.previousUnchangedReads);\n return {\n ...state,\n seconds:nextPollSeconds({\n rateLimited:input.rateLimited,\n workerState:input.workerState,\n queueGate:input.queueGate,\n jobs:input.jobs,\n unchangedReads:state.unchangedReads\n })\n };\n}\n",[196],"pulls","branches","forks","envVars",{"_209":61,"_211":61},"connections",{"_209":61,"_210":61},"count","unfilledCount","emptyCount",{"_43":195,"_32":196,"_30":197,"_140":-5,"_41":42,"_40":198,"_142":143,"_38":246,"_13":61,"_33":34,"_35":200,"_24":25,"_146":-5,"_222":247,"_27":248},{"_43":188,"_32":189,"_30":190,"_140":-5,"_41":42,"_40":191,"_142":143,"_38":243,"_13":61,"_33":20,"_35":193,"_24":25,"_146":-5,"_222":244,"_27":245},{"_43":181,"_32":182,"_30":183,"_140":-5,"_41":42,"_40":184,"_142":143,"_38":240,"_13":61,"_33":34,"_35":186,"_24":25,"_146":-5,"_222":241,"_27":242},{"_43":173,"_32":174,"_30":175,"_140":-5,"_41":42,"_40":176,"_142":143,"_38":237,"_13":178,"_33":34,"_35":179,"_24":25,"_146":-5,"_222":238,"_27":239},{"_43":169,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":143,"_38":234,"_13":171,"_33":34,"_35":37,"_24":25,"_146":-5,"_222":235,"_27":236},{"_43":162,"_32":163,"_30":164,"_140":-5,"_41":42,"_40":165,"_142":143,"_38":231,"_13":61,"_33":34,"_35":167,"_24":25,"_146":-5,"_222":232,"_27":233},{"_43":155,"_32":156,"_30":157,"_140":-5,"_41":42,"_40":158,"_142":143,"_38":228,"_13":61,"_33":34,"_35":160,"_24":25,"_146":-5,"_222":229,"_27":230},{"_43":148,"_32":149,"_30":150,"_140":-5,"_41":42,"_40":151,"_142":143,"_38":225,"_13":61,"_33":34,"_35":153,"_24":25,"_146":-5,"_222":226,"_27":227},{"_43":137,"_32":138,"_30":139,"_140":-5,"_41":42,"_40":141,"_142":143,"_38":221,"_13":61,"_33":34,"_35":145,"_24":25,"_146":-5,"_222":223,"_27":224},["D",1788660660293],"children",[],[138],["D",1788660852929],[],[149],["D",1788660851578],[],[156],["D",1788660849612],[],[163],["D",1788661079915],[],[28],["D",1788660810928],[],[174],["D",1788660835129],[],[182],["D",1788660879281],[],[189],["D",1788660354491],[],[196],["D",1788660354429],["D",1789533091345],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":14,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_80":-5,"_125":287,"_288":289,"_290":291,"_292":25,"_293":25,"_294":25,"_295":143,"_296":-5,"_297":-7,"_298":-7,"_299":61,"_300":25,"_301":25,"_302":-5,"_303":25,"_304":25,"_305":25,"_306":-5},"ENV",{"_258":259,"_260":261,"_262":87,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v18