[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","r3a4-82c51675-shadow","path","knowledge_kernel_r13_fault_certified.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":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":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/r3a4-82c51675-shadow/code/knowledge_kernel_r13_fault_certified.ts","extension","id","b2f46fd8-c683-44fb-8cbc-b5468f210349","fileId","01a09317-8b38-725b-99e6-1aac5c79a1be","parentId","branchId","667edb8b-aaf6-4374-bf1c-2397f495e068","branchVersion",1,"latest",true,"createdAt",["D",1789174188714],"version",0,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst REASONERS=[\"https://mosadek--83541b88aa4111f186de1607ee4eb77e.web.val.run\",\"https://mosadek--88f67324aa4111f1abc61607ee4eb77e.web.val.run\",\"https://mosadek--8a3f7a78aa4111f196531607ee4eb77e.web.val.run\"];\nconst VERIFIERS=[\"https://mosadek--00000000000000000000000000000000.web.val.run\",\"https://mosadek--11111111111111111111111111111111.web.val.run\",\"https://mosadek--812e6da8aa4211f19bfa1607ee4eb77e.web.val.run\",\"https://mosadek--828068c8aa4211f191911607ee4eb77e.web.val.run\"];\nconst WAKE_TTL_S=5;\nfunction nowS(){return Math.floor(Date.now()/1000);}\nasync function sleep(ms:number){await new Promise(r=>setTimeout(r,ms));}\nfunction norm(s:any){\n return String(s??\"\").normalize(\"NFKD\").replace(/[\\u0300-\\u036f]/g,\"\")\n .toLowerCase().replace(/[^a-z0-9]+/g,\" \").trim();\n}\nasync function getJson(url:string){\n const t0=performance.now();\n try{\n const res=await fetch(url);\n let body:any={};try{body=await res.json();}catch{}\n return {status:res.status,ok:res.ok,ms:performance.now()-t0,body};\n }catch(e){return {status:0,ok:false,ms:performance.now()-t0,body:{},error:String(e)};}\n}\nfunction reasonerKey(b:any){return JSON.stringify([b.relation,b.subject_id,b.property,b.answer_id,b.answer]);}\nasync function readCert(key:string,currentAnswer:string){\n const r=await sqlite.execute({\n sql:\"SELECT wikidata_answer,second_source,second_answer,second_source_id,agree,evidence_json,verified_at FROM knowledge_kernel_independent_verify_r11 WHERE cache_key=?\",\n args:[key]\n });\n if(!r.rows.length)return {certified:false,reason:\"NOT_CROSS_SOURCE_VERIFIED\"};\n const v:any=r.rows[0];\n const bound=norm(v.wikidata_answer)===norm(currentAnswer);\n const agree=Number(v.agree)===1;\n if(!bound)return {certified:false,reason:\"VERIFICATION_STALE_FOR_CURRENT_VALUE\",agree,bound,verified_at:v.verified_at};\n if(!agree)return {certified:false,reason:\"CROSS_SOURCE_DISAGREEMENT\",agree,bound,second_source:v.second_source,second_answer:v.second_answer,verified_at:v.verified_at,evidence:JSON.parse(String(v.evidence_json))};\n return {certified:true,reason:null,agree,bound,second_source:v.second_source,second_answer:v.second_answer,second_source_id:v.second_source_id,verified_at:v.verified_at,evidence:JSON.parse(String(v.evidence_json))};\n}\nasync function enqueueVerify(key:string,source1:string){\n await sqlite.execute({\n sql:`INSERT INTO knowledge_kernel_verify_jobs_r13\n (cache_key,source1_answer,state,attempts,last_error,lease_until,created_at,updated_at)\n VALUES (?,?,'READY',0,NULL,NULL,datetime('now'),datetime('now'))\n ON CONFLICT(cache_key) DO UPDATE SET\n source1_answer=excluded.source1_answer,\n state=CASE\n WHEN knowledge_kernel_verify_jobs_r13.source1_answer<>excluded.source1_answer THEN 'READY'\n WHEN knowledge_kernel_verify_jobs_r13.state IN ('FAILED','COMPLETE') THEN 'READY'\n ELSE knowledge_kernel_verify_jobs_r13.state\n END,\n attempts=CASE\n WHEN knowledge_kernel_verify_jobs_r13.source1_answer<>excluded.source1_answer THEN 0\n ELSE knowledge_kernel_verify_jobs_r13.attempts\n END,\n last_error=CASE\n WHEN knowledge_kernel_verify_jobs_r13.source1_answer<>excluded.source1_answer THEN NULL\n ELSE knowledge_kernel_verify_jobs_r13.last_error\n END,\n lease_until=CASE\n WHEN knowledge_kernel_verify_jobs_r13.source1_answer<>excluded.source1_answer THEN NULL\n ELSE knowledge_kernel_verify_jobs_r13.lease_until\n END,\n updated_at=datetime('now')`,\n args:[key,source1]\n });\n}\nasync function claimWake(key:string,source1:string){\n const n=nowS(),until=n+WAKE_TTL_S;\n const r=await sqlite.execute({\n sql:`INSERT INTO knowledge_kernel_verify_wake_r13(cache_key,source1_answer,wake_until,updated_at)\n VALUES (?,?,?,datetime('now'))\n ON CONFLICT(cache_key) DO UPDATE SET\n source1_answer=excluded.source1_answer,\n wake_until=excluded.wake_until,\n updated_at=excluded.updated_at\n WHERE knowledge_kernel_verify_wake_r13.source1_answer<>excluded.source1_answer\n OR knowledge_kernel_verify_wake_r13.wake_until0;\n}\nasync function wakeVerifier(endpoint:string,key:string){\n const u=new URL(endpoint);u.searchParams.set(\"cache_key\",key);\n return await getJson(u.toString());\n}\nexport default async function(req:Request):Promise{\n const u=new URL(req.url),q=(u.searchParams.get(\"q\")??\"\").trim();\n if(!q)return new Response(\"missing q\",{status:400});\n const t0=performance.now();\n\n const rr=await Promise.all(REASONERS.map(endpoint=>{\n const x=new URL(endpoint);x.searchParams.set(\"q\",q);return getJson(x.toString());\n }));\n const good=rr.filter((r:any)=>r.status===200&&r.body?.ok===true);\n const groups=new Map();\n for(const r of good as any[]){\n const k=reasonerKey(r.body),a=groups.get(k)??[];a.push(r);groups.set(k,a);\n }\n let winner:any[]=[];\n for(const a of groups.values())if(a.length>winner.length)winner=a;\n if(winner.length<2){\n return Response.json({\n ok:false,reason:\"INSUFFICIENT_SOURCE1_EXECUTION_AGREEMENT\",question:q,\n reasoners_attempted:REASONERS.length,reasoners_successful:good.length,best_agreement:winner.length,\n observations:rr.map((r:any)=>({status:r.status,ms:r.ms,answer:r.body?.answer,reason:r.body?.reason,error:r.error}))\n },{status:503});\n }\n\n const base=winner[0].body;\n const key=`${base.relation}|${base.property}|${String(base.subject_query??\"\").toLowerCase()}`;\n if(base.relation!==\"capital\"||base.property!==\"P36\"){\n return Response.json({ok:false,reason:\"CROSS_SOURCE_CERTIFICATION_NOT_IMPLEMENTED_FOR_RELATION\",question:q,candidate_answer:base.answer,relation:base.relation,property:base.property,source1_execution_agreement:winner.length,cache_key:key},{status:409});\n }\n\n let cert:any=await readCert(key,String(base.answer));\n if(cert.reason===\"CROSS_SOURCE_DISAGREEMENT\"){\n return Response.json({ok:false,reason:\"CROSS_SOURCE_DISAGREEMENT\",question:q,candidate_answer:base.answer,cache_key:key,source1_execution_agreement:winner.length,certification:cert},{status:409});\n }\n\n let wakeOwner=false;\n let workerResults:any[]=[];\n if(!cert.certified){\n await enqueueVerify(key,String(base.answer));\n wakeOwner=await claimWake(key,String(base.answer));\n if(wakeOwner){\n workerResults.push(...await Promise.all(VERIFIERS.slice(0,2).map(x=>wakeVerifier(x,key))));\n cert=await readCert(key,String(base.answer));\n if(!cert.certified&&cert.reason!==\"CROSS_SOURCE_DISAGREEMENT\"){\n workerResults.push(...await Promise.all(VERIFIERS.slice(2).map(x=>wakeVerifier(x,key))));\n cert=await readCert(key,String(base.answer));\n }\n }else{\n for(let i=0;i<30;i++){\n await sleep(100);\n cert=await readCert(key,String(base.answer));\n if(cert.certified||cert.reason===\"CROSS_SOURCE_DISAGREEMENT\")break;\n }\n }\n }\n\n if(cert.reason===\"CROSS_SOURCE_DISAGREEMENT\"){\n return Response.json({\n ok:false,reason:\"CROSS_SOURCE_DISAGREEMENT\",question:q,candidate_answer:base.answer,\n cache_key:key,source1_execution_agreement:winner.length,\n verification_wake_owner:wakeOwner,verification_workers_attempted:workerResults.length,\n certification:cert,cron_backstop_active:true\n },{status:409});\n }\n\n if(!cert.certified){\n const j=await sqlite.execute({sql:\"SELECT state,attempts,last_error,lease_until FROM knowledge_kernel_verify_jobs_r13 WHERE cache_key=?\",args:[key]});\n const jr:any=j.rows[0]??{};\n return Response.json({\n ok:false,reason:\"CROSS_SOURCE_VERIFICATION_PENDING\",question:q,candidate_answer:base.answer,\n cache_key:key,source1_execution_agreement:winner.length,\n verification_wake_owner:wakeOwner,verification_workers_attempted:workerResults.length,\n verification_workers_ok:workerResults.filter((x:any)=>x.status===200&&x.body?.ok===true).length,\n verification_job_state:String(jr.state??\"UNKNOWN\"),verification_attempts:Number(jr.attempts??0),\n last_error:jr.last_error??null,lease_until:jr.lease_until??null,cron_backstop_active:true\n },{status:202});\n }\n\n return Response.json({\n ok:true,question:q,answer:base.answer,answer_id:base.answer_id,\n relation:base.relation,subject:base.subject_label,subject_id:base.subject_id,property:base.property,\n cache_key:key,source1_execution_verified:true,source1_execution_agreement:winner.length,\n source1:\"Wikidata\",source2:cert.second_source,source2_answer:cert.second_answer,\n cross_source_certified:true,verification_bound_to_current_value:cert.bound===true,\n verified_at:cert.verified_at,verification_wake_owner:wakeOwner,\n verification_workers_attempted:workerResults.length,\n verification_workers_ok:workerResults.filter((x:any)=>x.status===200&&x.body?.ok===true).length,\n verifier_mode:\"R13_DURABLE_EVENT_WAKE_WITH_CRON_BACKSTOP\",\n model_calls:0,trained_parameters_in_reasoning_kernel:0,wall_ms:performance.now()-t0\n });\n}","deleted",false,"label",[14],"29a70aaf-cb5b-45b6-9fd3-d04be7430cbd",["D",1789174188714],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","R3A4 cohort repair isolated qualification","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a09317-8b36-757f-b18a-5477cfa017af","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","29a70aafcb5b45b69fd3d04be7430cbd","tursoHostname","29a70aafcb5b45b69fd3d04be7430cbd-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_104":100},"org",{"_9":10,"_97":98,"_99":100,"_55":56,"_101":102,"_103":42},"branch",{"_35":30,"_11":88,"_22":28,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":12,"_96":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":36,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":88,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"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"]