[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","pb-r3r1-readcoalesce-20260912","path","qualification.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":36,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mosadek/pb-r3r1-readcoalesce-20260912/code/qualification.ts","extension","id","9afa6c8b-a4b1-4782-990a-14dec70bac60","fileId","01a0928e-7a2b-70bf-843e-ed49e6d5b620","parentId","branchId","a9932cbe-2418-481b-981e-aabcc7561c6a","branchVersion",1,"latest",true,"createdAt",["D",1789165205903],"version",0,"fileType","script","content","import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\nimport { acquireWithDurableReceipt,ensureShadowSchema,finalizeLeaderOptionalFollower,orderedReadySql,pureSelectorOrder,receiptBindingDecision,classifyValidCoalesceResult,sha256Text,PRIORITY_CAP } from \"./candidate.ts\";\nconst nativeFetch=globalThis.fetch.bind(globalThis);\nasync function compat(input:any,init?:any):Promise{let target:any=input,reqInit:any=init;if(typeof input!==\"string\"&&!(input instanceof URL)){const method=String(input?.method||init?.method||\"GET\"),headers=new Headers(),src=input?.headers||init?.headers;if(src?.forEach)src.forEach((v:string,k:string)=>headers.set(k,v));else if(src)for(const[k,v]of Object.entries(src))headers.set(k,String(v));let body:any=undefined;if(method!==\"GET\"&&method!==\"HEAD\")body=typeof input?.arrayBuffer===\"function\"?new Uint8Array(await input.arrayBuffer()):(input?.body??init?.body);target=String(input?.url||\"\");if(!target)throw new Error(\"URL_REQUIRED\");reqInit={method,headers,body,redirect:\"manual\"}}const r:any=await nativeFetch(target,reqInit);if(r?.body==null||typeof r.body.cancel===\"function\")return r;const b=new Uint8Array(await r.arrayBuffer());return new Response(b,{status:r.status,statusText:r.statusText,headers:r.headers})}\nconst db:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:Deno.env.get(\"VAL_TOWN_API_KEY\"),fetch:compat});\nconst Q=\"r8k2_queue\",R=\"r8k2_receipts\",W=\"worker-r8k2\",I=\"instance-r8k2\";\nawait ensureShadowSchema(db,Q,R);\nconst checks:any[]=[];function ok(name:string,pass:boolean,detail:any=null){checks.push({name,pass,detail});if(!pass)throw new Error(\"CHECK_FAILED:\"+name+\":\"+JSON.stringify(detail))}\nasync function reset(){await db.batch([{sql:`DELETE FROM ${R}`},{sql:`DELETE FROM ${Q}`}],\"write\")}\nfunction p(cmd:string,args:string[]=[cmd],timeout=60){return JSON.stringify({args,timeout})}\nasync function add(id:string,priority:number,payload:string,created:string){await db.execute({sql:`INSERT INTO ${Q}(id,priority,op,payload_json,state,created_at,updated_at) VALUES(?,?,'brain',?,'READY',?,?)`,args:[id,priority,payload,created,created]})}\nconst H=\"0\".repeat(64);const validChain=JSON.stringify({returncode:0,stdout:JSON.stringify({computed_head:H,events:7,ok:true,stored_head:H})+\"\\n\",stderr:\"\",stdout_truncated:false,stderr_truncated:false});\nconst validGraph=JSON.stringify({returncode:0,stdout:JSON.stringify({claims:8,ok:true,problems:[]})+\"\\n\",stderr:\"\",stdout_truncated:false,stderr_truncated:false});\n\n// Exact current classifier semantics.\nok(\"classifier-chain\",classifyValidCoalesceResult(validChain)===\"verify-chain\");ok(\"classifier-graph\",classifyValidCoalesceResult(validGraph)===\"verify-claim-graph\");ok(\"classifier-reject-status\",classifyValidCoalesceResult(JSON.stringify({returncode:0,stdout:'{\"ok\":true}',stderr:\"\",stdout_truncated:false,stderr_truncated:false}))===null);\n\n// Three load-bearing selector-shape assertions.\nconst sql=orderedReadySql(Q);ok(\"shape-recovery-first\",sql.includes(\"recover-stale\")&&sql.indexOf(\"recover-stale\")x.state===\"READY\"&&Number(x.transport_lease_generation)===0)&&Number(rbr.rows[0].n)===0,{rows:rbq.rows,receipts:rbr.rows[0]});\n\n// Rank0/rank1 capture and valid follower completion.\nconst acq:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-a\"});ok(\"remote-rank0-rank1\",acq.kind===\"leased\"&&acq.rank0===\"rb0\"&&acq.rank1===\"rb1\",acq);\nconst fin:any=await finalizeLeaderOptionalFollower(db,{qTable:Q,rTable:R,leaderId:acq.rank0,worker:W,instance:I,attempt:\"attempt-a\",generation:Number(acq.leader.transport_lease_generation),resultJson:validChain});ok(\"remote-valid-follower\",fin.ok&&fin.leader_completed&&fin.follower_completed&&fin.command===\"verify-chain\",fin);\n\n// Missing receipt never authorizes follower, but ordinary valid leader completion survives.\nawait reset();await add(\"m0\",100,p(\"verify-claim-graph\"),t0);await add(\"m1\",100,p(\"verify-claim-graph\"),\"2026-09-11 15:00:01\");const ma:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-m\"});await db.execute({sql:`DELETE FROM ${R} WHERE job_id=?`,args:[ma.rank0]});const mf:any=await finalizeLeaderOptionalFollower(db,{qTable:Q,rTable:R,leaderId:ma.rank0,worker:W,instance:I,attempt:\"attempt-m\",generation:Number(ma.leader.transport_lease_generation),resultJson:validGraph});const mstate:any=await db.execute(`SELECT id,state FROM ${Q} ORDER BY id`);ok(\"remote-missing-receipt-leader-only\",mf.ok&&mf.reason===\"PRELEASE_RECEIPT_MISSING\"&&mf.leader_completed&&!mf.follower_completed&&mstate.rows[0].state===\"COMPLETE\"&&mstate.rows[1].state===\"READY\",{mf,rows:mstate.rows});\n\n// Stale/ABA attempt fails before any terminalization.\nawait reset();await add(\"s0\",100,p(\"verify-chain\"),t0);const sa:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-old\"});await db.execute({sql:`UPDATE ${Q} SET lease_attempt_id='attempt-new',transport_lease_generation=transport_lease_generation+1 WHERE id=?`,args:[sa.rank0]});const sf:any=await finalizeLeaderOptionalFollower(db,{qTable:Q,rTable:R,leaderId:sa.rank0,worker:W,instance:I,attempt:\"attempt-old\",generation:Number(sa.leader.transport_lease_generation),resultJson:validChain});const sr:any=await db.execute({sql:`SELECT state FROM ${Q} WHERE id=?`,args:[sa.rank0]});ok(\"remote-stale-aba-reject\",sf.ok===false&&sr.rows[0].state===\"LEASED\",sf);\n\n// Concurrent contenders: one durable winner, all others fail closed/busy/error, never >1 lease or receipt.\nawait reset();for(let i=0;i<4;i++)await add(\"c\"+i,100-i,p(\"verify-chain\"),`2026-09-11 15:00:0${i}`);const contenders=await Promise.all(Array.from({length:6},async(_,i)=>{try{return await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"conc-\"+i})}catch(e){return {kind:\"error\",error:String(e)}}}));const cq:any=await db.execute(`SELECT COUNT(*) n FROM ${Q} WHERE state='LEASED'`),cr:any=await db.execute(`SELECT COUNT(*) n FROM ${R}`);ok(\"remote-concurrent-single-flight\",Number(cq.rows[0].n)===1&&Number(cr.rows[0].n)===1&&contenders.filter((x:any)=>x.kind===\"leased\").length===1,{contenders,leased:cq.rows[0].n,receipts:cr.rows[0].n});\nconst second:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"after-winner\"});ok(\"remote-same-worker-single-flight\",second.kind===\"busy\",second);\n\n// Twenty semantic binding vectors, inherited contract but independently rerun in Deno.\nconst baseLeader={id:\"L\",state:\"LEASED\",lease_owner:\"w\",lease_instance_id:\"i\",lease_attempt_id:\"a\",transport_lease_generation:3};const baseReceipt={job_id:\"L\",rank0_id:\"L\",rank1_id:\"F\",lease_owner:\"w\",lease_instance_id:\"i\",lease_attempt_id:\"a\",transport_lease_generation:3};const E={worker:\"w\",instance:\"i\",attempt:\"a\",generation:3};\nconst vectors:any[]=[\n [\"baseline\",baseLeader,baseReceipt,E,\"OK\"],[\"missing\",baseLeader,null,E,\"PRELEASE_RECEIPT_MISSING\"],[\"leader-terminal\",{...baseLeader,state:\"COMPLETE\"},baseReceipt,E,\"LEADER_NOT_CURRENTLY_LEASED\"],[\"wrong-owner\",{...baseLeader,lease_owner:\"x\"},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"wrong-instance\",{...baseLeader,lease_instance_id:\"x\"},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"wrong-attempt\",{...baseLeader,lease_attempt_id:\"x\"},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"wrong-generation\",{...baseLeader,transport_lease_generation:4},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"receipt-job\",baseLeader,{...baseReceipt,job_id:\"X\"},E,\"PRELEASE_RECEIPT_CORRUPT\"],[\"receipt-rank0\",baseLeader,{...baseReceipt,rank0_id:\"X\"},E,\"PRELEASE_RECEIPT_CORRUPT\"],[\"receipt-owner\",baseLeader,{...baseReceipt,lease_owner:\"x\"},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"receipt-instance\",baseLeader,{...baseReceipt,lease_instance_id:\"x\"},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"receipt-attempt\",baseLeader,{...baseReceipt,lease_attempt_id:\"x\"},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"receipt-generation\",baseLeader,{...baseReceipt,transport_lease_generation:4},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"expect-owner\",baseLeader,baseReceipt,{...E,worker:\"x\"},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"expect-instance\",baseLeader,baseReceipt,{...E,instance:\"x\"},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"expect-attempt\",baseLeader,baseReceipt,{...E,attempt:\"x\"},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"expect-generation\",baseLeader,baseReceipt,{...E,generation:4},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"rank1-null\",baseLeader,{...baseReceipt,rank1_id:null},E,\"OK\"],[\"extra-receipt-field\",baseLeader,{...baseReceipt,extra:\"ignored\"},E,\"OK\"],[\"extra-leader-field\",{...baseLeader,extra:\"ignored\"},baseReceipt,E,\"OK\"]];\nlet semPass=0;for(const [name,l,r,e,want] of vectors){const got=receiptBindingDecision(l,r,e);if(got===want)semPass++;else checks.push({name:\"semantic-\"+name,pass:false,detail:{got,want}})}ok(\"semantic-20\",semPass===20,{passed:semPass,total:20});\n\n// 5000 deterministic scheduler parity cases: independent comparator oracle vs candidate pure selector.\nfunction mulberry32(a:number){return()=>{a|=0;a=a+0x6D2B79F5|0;let t=Math.imul(a^a>>>15,1|a);t=t+Math.imul(t^t>>>7,61|t)^t;return((t^t>>>14)>>>0)/4294967296}}\nconst rnd=mulberry32(0x9e3779b9),commands=[\"status\",\"verify-chain\",\"verify-claim-graph\",\"register-agent\",\"claim\",\"commit\",\"ensure-task\",\"renew-lease\",\"recover-stale\",\"other\"];\nfunction desc(r:any,rows:any[],idx:number,nowMs:number){let q:any=null;try{q=JSON.parse(r.payload_json)}catch{}const c=q?.args?.[0]||\"\",closed=q&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120,read=closed&&q.args?.length===1&&[\"status\",\"verify-chain\",\"verify-claim-graph\"].includes(c),boot=read||[\"register-agent\",\"claim\"].includes(c),recover=closed&&q.args?.length===1&&c===\"recover-stale\",older=boot&&rows.some((x:any,j:number)=>{let z:any;try{z=JSON.parse(x.payload_json)}catch{return false}return x.state===\"READY\"&&x.op===\"brain\"&&z?.args?.[0]===\"commit\"&&Object.keys(z).sort().join(\",\")===\"args,timeout\"&&Number.isInteger(z.timeout)&&z.timeout>=1&&z.timeout<=120&&(x.created_at=15,pair=c===\"claim\"&&q?.args?.[1]===\"--agent\"&&rows.some((x:any)=>{try{const z=JSON.parse(x.payload_json);return x.state===\"READY\"&&z.args?.[0]===\"register-agent\"&&z.args?.[1]===q.args?.[2]&&x.created_at===r.created_at}catch{return false}}),co=c===\"status\"?0:c===\"verify-chain\"?1:c===\"verify-claim-graph\"?2:c===\"register-agent\"?3:c===\"claim\"?4:5;return [recover?0:1,older?1:0,mission?0:1,boot?0:1,pair?1:0,-Math.min(r.priority,1e9),r.created_at,co,idx+1,r.id]}\nfunction oracle(rows:any[],nowMs:number){const ready=rows.filter((r:any)=>r.state===\"READY\");const indexed=ready.map((r:any)=>({r,idx:rows.indexOf(r),k:desc(r,rows,rows.indexOf(r),nowMs)}));indexed.sort((a:any,b:any)=>{for(let i=0;ib.k[i])return 1}return 0});return indexed.map((x:any)=>x.r.id)}\nlet parity=0;for(let n=0;n<5000;n++){const nowMs=Date.UTC(2026,8,11,16,0,0),count=2+Math.floor(rnd()*7),rows:any[]=[];for(let i=0;ix.pass),schema:\"R8K2_DENO_LIBSQL_TRANSACTIONAL_ADAPTER_QUALIFICATION_V1\",runtime:{deno:Deno.version.deno,v8:Deno.version.v8,typescript:Deno.version.typescript},libsql:\"@libsql/client@0.17.2/web\",scoped_url:\"API_URL/v3/sqlite/scoped/\",checks,semantic:{passed:semPass,total:20},scheduler_parity:{passed:parity,total:5000},cross_invocation_seed:{job_id:pa.rank0,attempt:\"cross-invocation-attempt\",generation:Number(pa.leader.transport_lease_generation),rank1:pa.rank1,rank_snapshot_sha256:pa.rank_snapshot_sha256}};\nconsole.log(JSON.stringify(summary));if(!summary.ok)Deno.exit(2);\n","deleted",false,"label",[14],"4d625a42-bd31-472a-9c2e-3fa3d1061da9",["D",1789165205903],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Rev3 read-only coalescer rebind qualification","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a0928e-9e37-702a-9dd5-eff9bd500039","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":85,"_11":86,"_22":28,"_87":45,"_88":89,"_90":91,"_92":50,"_93":94,"_95":64,"_96":12,"_97":10},"isOwned",11,"main","projectId","forkedBranchId","135bdb83-a5ef-4663-8e8c-8e5cf123ceb2","forkedBranchVersion",20,"forkedProjectPrivacy","forkedProjectId","ef2de6a5-356a-4dd1-b3f2-03ea3ef80bac","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":36,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":86,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]