[{"_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_rebase_3056.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_rebase_3056.ts","extension","id","92989f3d-1f20-475d-b08f-d29c936a91d8","fileId","01a0928e-7a2b-70bf-843e-f3bedbfcfa2a","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 { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\nimport { acquireWithPreleaseRankReceiptV1,finalizeLeaderOptionalPreleaseFollowerV1,orderedReadyTop2SqlV1,classifyValNativeCoalesceResultV1,preleaseReceiptBindingReasonV1,ensurePreleaseRankReceiptTableV1 } from \"https://esm.town/v/mosadek/project-brain-live-v1-durable@3056-main/val_native_executor_prod.ts\";\nimport { orderedReadySql,pureSelectorOrder } 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=\"r8k2r_queue\",R=\"r8k2r_receipts\",W=\"worker-r8k2-rebase\",I=\"instance-r8k2-rebase\";\nawait db.execute(`CREATE TABLE IF NOT EXISTS ${Q}(id TEXT PRIMARY KEY,priority REAL NOT NULL,op TEXT NOT NULL,payload_json TEXT NOT NULL,state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL,transport_lease_generation INTEGER NOT NULL DEFAULT 0,lease_instance_id TEXT,lease_attempt_id TEXT)`);\nawait ensurePreleaseRankReceiptTableV1(db,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),t0=\"2026-09-11 15:00:00\";\nconst valChain=JSON.stringify({returncode:0,stderr:\"\",stdout:JSON.stringify({computed_head:H,events:7,ok:true,stored_head:H})+\"\\n\"});\nconst valGraph=JSON.stringify({returncode:0,stderr:\"\",stdout:JSON.stringify({claims:8,ok:true,problems:[]})+\"\\n\"});\nok(\"classifier-chain\",classifyValNativeCoalesceResultV1(valChain)===\"verify-chain\");\nok(\"classifier-graph\",classifyValNativeCoalesceResultV1(valGraph)===\"verify-claim-graph\");\nok(\"classifier-status-rejected\",classifyValNativeCoalesceResultV1(JSON.stringify({returncode:0,stderr:\"\",stdout:'{\"ok\":true}'}))===null);\nconst prodSql=orderedReadyTop2SqlV1(Q),candSql=orderedReadySql(Q),norm=(s:string)=>s.replace(/\\s+/g,\"\");\nok(\"selector-token-equivalence\",norm(prodSql)===norm(candSql),{prod:norm(prodSql),candidate:norm(candSql)});\nok(\"shape-recovery-first\",prodSql.includes(\"recover-stale\")&&prodSql.indexOf(\"recover-stale\")=1&&q.timeout<=120}\nfunction exactRecover(row:any){const q=parsePayload(row);return row.op===\"brain\"&&q&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Array.isArray(q.args)&&q.args.length===1&&q.args[0]===\"recover-stale\"&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120}\nfunction validMutationCommand(row:any,cmd:string){const q=parsePayload(row);return row.op===\"brain\"&&q&&Array.isArray(q.args)&&q.args[0]===cmd&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120&&Object.keys(q).sort().join(\",\")===\"args,timeout\"}\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.state===\"READY\"&&Number(x.transport_lease_generation)===0)&&Number(rbr.rows[0].n)===0,{rows:rbq.rows,receipts:rbr.rows[0]});\nconst acq:any=await acquireWithPreleaseRankReceiptV1(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);const fin:any=await finalizeLeaderOptionalPreleaseFollowerV1(db,{qTable:Q,rTable:R,job:{...acq.job,lease_owner:W},expected:{state:\"COMPLETE\",result_json:valChain,error_json:null}});ok(\"remote-valid-follower\",fin.ok&&fin.follower_completed&&fin.command===\"verify-chain\",fin);\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 acquireWithPreleaseRankReceiptV1(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 finalizeLeaderOptionalPreleaseFollowerV1(db,{qTable:Q,rTable:R,job:{...ma.job,lease_owner:W},expected:{state:\"COMPLETE\",result_json:valGraph,error_json:null}});const mstate:any=await db.execute(`SELECT id,state FROM ${Q} ORDER BY id`);ok(\"remote-missing-receipt-leader-only\",mf.ok&&mf.receipt_reason===\"PRELEASE_RECEIPT_MISSING\"&&!mf.follower_completed&&mstate.rows[0].state===\"COMPLETE\"&&mstate.rows[1].state===\"READY\",{mf,rows:mstate.rows});\nawait reset();await add(\"s0\",100,p(\"verify-chain\"),t0);const sa:any=await acquireWithPreleaseRankReceiptV1(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 finalizeLeaderOptionalPreleaseFollowerV1(db,{qTable:Q,rTable:R,job:{...sa.job,lease_owner:W},expected:{state:\"COMPLETE\",result_json:valChain,error_json:null}});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);\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 acquireWithPreleaseRankReceiptV1(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});const second:any=await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"after-winner\"});ok(\"remote-same-worker-single-flight\",second.kind===\"busy\",second);\nawait reset();await add(\"persist0\",100,p(\"verify-chain\"),t0);await add(\"persist1\",100,p(\"verify-chain\"),\"2026-09-11 15:00:01\");const pa:any=await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"cross-invocation-attempt\"});ok(\"cross-invocation-seed\",pa.kind===\"leased\"&&!!pa.rank_snapshot_sha256,pa);\nconst summary={ok:checks.every(x=>x.pass),schema:\"R8K2_REBASED_PRODUCTION_EXPORT_QUALIFICATION_V1\",production_version:3056,production_gate_expected_disabled:true,runtime:{deno:Deno.version.deno,v8:Deno.version.v8,typescript:Deno.version.typescript},libsql:\"@libsql/client@0.17.2/web\",checks,semantic:{passed:sem,total:20},scheduler_shape:{passed:3,total:3},scheduler_parity:{passed:parity,total:5000},selector_equivalent_to_prior_qualified_candidate:norm(prodSql)===norm(candSql),cross_invocation_seed:{job_id:pa.rank0,attempt:\"cross-invocation-attempt\",generation:Number(pa.job.transport_lease_generation),rank1:pa.rank1,rank_snapshot_sha256:pa.rank_snapshot_sha256}};\nawait blob.set(\"evidence/r8k2/rebase3056/REPORT_V1.json\",JSON.stringify(summary));\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"]