[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","project-brain-successor-20260915-v1","path","successor_kernel_v1.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":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":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/project-brain-successor-20260915-v1/code/successor_kernel_v1.ts","extension","id","bb6dad5f-aeb9-4c27-82af-545871806c62","fileId","4fd298bc-b0a3-11f1-8074-1607ee4eb77e","parentId","branchId","0b2522ef-5041-4256-a795-786066279094","branchVersion",1448,"latest",true,"createdAt",["D",1789578372853],"version",19,"fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { initLineage, sha256Text, prepareCurrentnessGuard } from \"./lineage_currentness_v2.ts\";\n\nconst TASKS=\"succ_tasks\";\nconst H64=/^[0-9a-f]{64}$/;\nconst enc=new TextEncoder();\nconst now=()=>new Date().toISOString();\nfunction canon(x:any):string{if(x===null||typeof x!==\"object\")return JSON.stringify(x);if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\"}\nfunction parse(s:any,f:any){try{return JSON.parse(String(s??\"\"))}catch{return f}}\nfunction uniq(xs:string[]){return [...new Set(xs.map(String))]}\nfunction exactKeys(o:any,keys:string[]){return !!o&&typeof o===\"object\"&&!Array.isArray(o)&&Object.keys(o).sort().join(\"\\0\")===keys.slice().sort().join(\"\\0\")}\nfunction assertEventToken(x:any){if(!exactKeys(x,[\"generation\",\"event_head_hash\"]))throw new Error(\"BAD_EVENT_TOKEN_SHAPE\");if(typeof x.generation!==\"number\"||!Number.isInteger(x.generation)||x.generation<0)throw new Error(\"BAD_EVENT_TOKEN_GENERATION\");if(typeof x.event_head_hash!==\"string\"||!H64.test(x.event_head_hash))throw new Error(\"BAD_EVENT_TOKEN_HEAD\");return x as {generation:number,event_head_hash:string}}\n\nexport async function initKernel(){\n await initLineage();\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TASKS}(\n id TEXT PRIMARY KEY,\n dedupe_key TEXT NOT NULL UNIQUE,\n priority REAL NOT NULL,\n state TEXT NOT NULL,\n payload_json TEXT NOT NULL,\n prerequisites_json TEXT NOT NULL,\n executor_requirements_json TEXT NOT NULL,\n resources_json TEXT NOT NULL,\n verifier_spec_json TEXT NOT NULL,\n member_instance_id TEXT NOT NULL UNIQUE,\n lease_owner TEXT,\n lease_token TEXT,\n lease_expires_at TEXT,\n result_json TEXT,\n result_sha256 TEXT,\n submitted_by TEXT,\n verified_by TEXT,\n verification_json TEXT,\n updated_at TEXT NOT NULL\n )`);\n const cols:any=await sqlite.execute(`PRAGMA table_info(lineage_members)`);if(!(cols.rows as any[]).some(r=>String(r.name)===\"runtime_sha256\"))await sqlite.execute(`ALTER TABLE lineage_members ADD COLUMN runtime_sha256 TEXT`);\n}\n\nasync function appendEventTx(tx:any,type:string,body:any){\n const m:any=(await tx.execute(`SELECT generation,event_head_hash FROM succ_event_meta WHERE id=1`)).rows[0];\n const token=assertEventToken({generation:m.generation,event_head_hash:m.event_head_hash});\n const n:any=(await tx.execute(`SELECT COALESCE(MAX(local_seq),0)+1 AS n FROM succ_events`)).rows[0];\n const local_seq=Number(n.n),generation=token.generation+1,event_uuid=crypto.randomUUID(),prev_hash=token.event_head_hash,body_json=canon(body),created_at=now();\n const event_hash=await sha256Text(canon({schema:\"SUCCESSOR_EVENT_V1\",local_seq,event_uuid,type,generation,prev_hash,body_json}));\n await tx.execute({sql:`INSERT INTO succ_events(local_seq,event_uuid,type,generation,prev_hash,event_hash,body_json,created_at) VALUES(?,?,?,?,?,?,?,?)`,args:[local_seq,event_uuid,type,generation,prev_hash,event_hash,body_json,created_at]});\n await tx.execute({sql:`UPDATE succ_event_meta SET generation=?,event_head_hash=? WHERE id=1`,args:[generation,event_hash]});\n return {local_seq,event_uuid,type,generation,prev_hash,event_hash,body_json,created_at};\n}\n\nasync function memberId(e:any){return \"m:\"+await sha256Text(canon({event_uuid:e.event_uuid,local_seq:e.local_seq,generation:e.generation,event_hash:e.event_hash}))}\nasync function edgeId(s:string,t:string,r:string){return \"e:\"+await sha256Text(canon({source:s,target:t,relation:r}))}\n\nasync function publishTx(tx:any){\n const tr:any=(await tx.execute(`SELECT generation,event_head_hash FROM succ_event_meta WHERE id=1`)).rows[0];const token=assertEventToken({generation:tr.generation,event_head_hash:tr.event_head_hash});\n const members:any[]=(await tx.execute(`SELECT * FROM lineage_members ORDER BY member_instance_id`)).rows as any[];\n const edges:any[]=(await tx.execute(`SELECT * FROM lineage_edges ORDER BY edge_id`)).rows as any[];\n const members_sha256=await sha256Text(canon(members)),edges_sha256=await sha256Text(canon(edges));\n const c:any=(await tx.execute(`SELECT version,head_sha256 FROM lineage_current_head WHERE id=1`)).rows[0];const version=Number(c.version)+1,previous_head_sha256=String(c.head_sha256),created_at=now();\n const sp={schema:\"LINEAGE_SNAPSHOT_V1\",version,members_sha256,edges_sha256,event_history_generation:token.generation,event_history_head_sha256:token.event_head_hash,previous_head_sha256};const snapshot_sha256=await sha256Text(canon(sp));\n const hp={schema:\"LINEAGE_HEAD_V1\",version,previous_head_sha256,snapshot_sha256,event_history_generation:token.generation,event_history_head_sha256:token.event_head_hash};const head_sha256=await sha256Text(canon(hp));\n await tx.execute({sql:`INSERT INTO lineage_snapshots(version,members_sha256,edges_sha256,event_history_generation,event_history_head_sha256,previous_head_sha256,snapshot_sha256,created_at) VALUES(?,?,?,?,?,?,?,?)`,args:[version,members_sha256,edges_sha256,token.generation,token.event_head_hash,previous_head_sha256,snapshot_sha256,created_at]});\n await tx.execute({sql:`INSERT INTO lineage_heads(version,previous_head_sha256,snapshot_sha256,event_history_generation,event_history_head_sha256,head_sha256,created_at) VALUES(?,?,?,?,?,?,?)`,args:[version,previous_head_sha256,snapshot_sha256,token.generation,token.event_head_hash,head_sha256,created_at]});\n await tx.execute({sql:`UPDATE lineage_current_head SET version=?,head_sha256=? WHERE id=1`,args:[version,head_sha256]});\n return {version,head_sha256,event_token:token};\n}\n\nfunction taskRuntimeProjection(r:any){return {id:String(r.id),dedupe_key:String(r.dedupe_key),priority:Number(r.priority),state:String(r.state),payload_json:String(r.payload_json),prerequisites_json:String(r.prerequisites_json),executor_requirements_json:String(r.executor_requirements_json),resources_json:String(r.resources_json),verifier_spec_json:String(r.verifier_spec_json),member_instance_id:String(r.member_instance_id),lease_owner:r.lease_owner??null,lease_token:r.lease_token??null,lease_expires_at:r.lease_expires_at??null,result_json:r.result_json??null,result_sha256:r.result_sha256??null,submitted_by:r.submitted_by??null,verified_by:r.verified_by??null,verification_json:r.verification_json??null}}\nasync function taskRuntimeSha(r:any){return await sha256Text(canon(taskRuntimeProjection(r)))}\nasync function syncTaskMemberTx(tx:any,taskId:string){const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];if(!r)throw new Error(\"TASK_NOT_FOUND\");const h=await taskRuntimeSha(r);const u:any=await tx.execute({sql:`UPDATE lineage_members SET state=?,runtime_sha256=?,updated_at=? WHERE member_instance_id=?`,args:[String(r.state),h,now(),String(r.member_instance_id)]});if(Number(u.rowsAffected)!==1)throw new Error(\"LINEAGE_MEMBER_NOT_FOUND\");return h}\nasync function assertTaskMemberParityTx(tx:any){const rows:any[]=(await tx.execute(`SELECT t.*,m.logical_task_id,m.creation_dedupe_key,m.state AS member_state,m.runtime_sha256 FROM ${TASKS} t LEFT JOIN lineage_members m ON m.member_instance_id=t.member_instance_id ORDER BY t.id`)).rows as any[];const mc:any=(await tx.execute(`SELECT COUNT(*) AS n FROM lineage_members`)).rows[0];if(Number(mc.n)!==rows.length)throw new Error(\"TASK_LINEAGE_CARDINALITY_MISMATCH\");for(const r of rows){if(r.logical_task_id!==r.id||r.creation_dedupe_key!==r.dedupe_key||r.member_state!==r.state)throw new Error(\"TASK_LINEAGE_PARITY_MISMATCH\");const h=await taskRuntimeSha(r);if(typeof r.runtime_sha256!==\"string\"||r.runtime_sha256!==h)throw new Error(\"TASK_RUNTIME_HASH_MISMATCH\")}return true}\n\nexport async function addTask(x:{id:string,dedupe_key:string,priority:number,payload:any,prerequisites?:string[],executor_requirements?:string[],resources?:string[],verifier_spec?:any}){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");\n try{\n await assertTaskMemberParityTx(tx);\n const pre=uniq(x.prerequisites??[]),req=uniq(x.executor_requirements??[]),res=uniq(x.resources??[]);const verifier=x.verifier_spec??{type:\"NO_POSITIVE_COMPLETION\"};\n if(typeof x.id!==\"string\"||!x.id||typeof x.dedupe_key!==\"string\"||!x.dedupe_key)throw new Error(\"BAD_TASK_IDENTITY\");\n if(verifier?.type===\"EXACT_JSON_SHA256\"&&(!H64.test(String(verifier.expected_sha256))||!exactKeys(verifier,[\"type\",\"expected_sha256\"])))throw new Error(\"BAD_VERIFIER_SPEC\");\n if(verifier?.type!==\"EXACT_JSON_SHA256\"&&verifier?.type!==\"NO_POSITIVE_COMPLETION\")throw new Error(\"UNSUPPORTED_VERIFIER_SPEC\");\n const existing:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=? OR dedupe_key=?`,args:[x.id,x.dedupe_key]})).rows[0];\n const fields={id:x.id,dedupe_key:x.dedupe_key,priority:Number(x.priority),payload_json:canon(x.payload),prerequisites_json:canon(pre),executor_requirements_json:canon(req),resources_json:canon(res),verifier_spec_json:canon(verifier)};\n if(existing){const same=existing.id===fields.id&&existing.dedupe_key===fields.dedupe_key&&Number(existing.priority)===fields.priority&&existing.payload_json===fields.payload_json&&existing.prerequisites_json===fields.prerequisites_json&&existing.executor_requirements_json===fields.executor_requirements_json&&existing.resources_json===fields.resources_json&&existing.verifier_spec_json===fields.verifier_spec_json;await tx.commit();if(!same)throw new Error(\"TASK_ID_OR_DEDUPE_CONFLICT\");return {ok:true,created:false,task_id:x.id,member_instance_id:existing.member_instance_id}}\n for(const dep of pre){const d:any=(await tx.execute({sql:`SELECT id FROM ${TASKS} WHERE id=?`,args:[dep]})).rows[0];if(!d)throw new Error(\"PREREQUISITE_NOT_FOUND\")}\n const payload_sha256=await sha256Text(fields.payload_json);const ev=await appendEventTx(tx,\"TASK_CREATED\",{task_id:x.id,dedupe_key:x.dedupe_key,payload_sha256});const member_instance_id=await memberId(ev),t=now();\n await tx.execute({sql:`INSERT INTO ${TASKS}(id,dedupe_key,priority,state,payload_json,prerequisites_json,executor_requirements_json,resources_json,verifier_spec_json,member_instance_id,updated_at) VALUES(?,?,?,'READY',?,?,?,?,?,?,?)`,args:[x.id,x.dedupe_key,fields.priority,fields.payload_json,fields.prerequisites_json,fields.executor_requirements_json,fields.resources_json,fields.verifier_spec_json,member_instance_id,t]});\n const taskRow:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[x.id]})).rows[0];const runtime_sha256=await taskRuntimeSha(taskRow);\n await tx.execute({sql:`INSERT INTO lineage_members(member_instance_id,logical_task_id,creation_dedupe_key,created_event_uuid,created_event_local_seq,created_event_generation,created_event_hash,payload_sha256,state,updated_at,runtime_sha256) VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[member_instance_id,x.id,x.dedupe_key,ev.event_uuid,ev.local_seq,ev.generation,ev.event_hash,payload_sha256,\"READY\",t,runtime_sha256]});\n for(const dep of pre){const dr:any=(await tx.execute({sql:`SELECT member_instance_id FROM ${TASKS} WHERE id=?`,args:[dep]})).rows[0];const eid=await edgeId(member_instance_id,String(dr.member_instance_id),\"DEPENDS_ON\");await tx.execute({sql:`INSERT INTO lineage_edges(edge_id,source_member_id,target_member_id,relation_type,updated_at) VALUES(?,?,?,?,?)`,args:[eid,member_instance_id,String(dr.member_instance_id),\"DEPENDS_ON\",t]})}\n const published=await publishTx(tx);await tx.commit();return {ok:true,created:true,task_id:x.id,member_instance_id,published};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\nexport async function claimOne(executor:{id:string,tokens:string[]},leaseSeconds=300){\n if(!Number.isInteger(leaseSeconds)||leaseSeconds<30||leaseSeconds>900)throw new Error(\"INVALID_LEASE_SECONDS\");await initKernel();const tx:any=await sqlite.transaction(\"write\");\n try{\n await assertTaskMemberParityTx(tx);\n const t=now(),expiry=new Date(Date.now()+leaseSeconds*1000).toISOString();let changed=false;\n const expired:any[]=(await tx.execute({sql:`SELECT id,member_instance_id FROM ${TASKS} WHERE state='LEASED' AND lease_expires_atString(r.id)));const locked=new Set();for(const r of (await tx.execute(`SELECT resources_json FROM ${TASKS} WHERE state IN ('LEASED','SUBMITTED')`)).rows as any[])for(const q of parse(r.resources_json,[]))locked.add(String(q));\n const have=new Set(executor.tokens.map(String));const cand:any[]=(await tx.execute(`SELECT * FROM ${TASKS} WHERE state='READY' ORDER BY priority DESC,id`)).rows as any[];let pick:any=null;\n for(const r of cand){const payload=parse(r.payload_json,{});if(payload?.objective_alignment?.schema!==\"ASTRA_CAPABILITY_OBJECTIVE_V1\"||payload?.objective_alignment?.local_improvement_only!==false)continue;const pre=parse(r.prerequisites_json,[]),req=parse(r.executor_requirements_json,[]),res=parse(r.resources_json,[]);if(pre.some((q:string)=>!done.has(q))||req.some((q:string)=>!have.has(q))||res.some((q:string)=>locked.has(q)))continue;pick=r;break}\n if(!pick){if(changed)await publishTx(tx);await tx.commit();return {ok:true,assignment:null}}\n const lease_token=crypto.randomUUID();await tx.execute({sql:`UPDATE ${TASKS} SET state='LEASED',lease_owner=?,lease_token=?,lease_expires_at=?,updated_at=? WHERE id=? AND state='READY'`,args:[executor.id,lease_token,expiry,t,pick.id]});await syncTaskMemberTx(tx,String(pick.id));await appendEventTx(tx,\"TASK_LEASED\",{task_id:pick.id,executor_id:executor.id,lease_token,lease_expires_at:expiry});const published=await publishTx(tx);await tx.commit();return {ok:true,assignment:{task_id:pick.id,lease_token,lease_expires_at:expiry,payload:parse(pick.payload_json,{})},published};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\nexport async function submitResult(executorId:string,taskId:string,leaseToken:string,result:any){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");try{await assertTaskMemberParityTx(tx);const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];if(!r||r.state!==\"LEASED\"||r.lease_owner!==executorId||r.lease_token!==leaseToken||String(r.lease_expires_at)<=now()){await tx.commit();return {ok:false,reason:\"NOT_CURRENT_LEASE_ATTEMPT\"}}const raw=canon(result),result_sha256=await sha256Text(raw),t=now();await tx.execute({sql:`UPDATE ${TASKS} SET state='SUBMITTED',lease_owner=NULL,lease_token=NULL,lease_expires_at=NULL,result_json=?,result_sha256=?,submitted_by=?,verified_by=NULL,verification_json=NULL,updated_at=? WHERE id=?`,args:[raw,result_sha256,executorId,t,taskId]});await syncTaskMemberTx(tx,String(r.id));await appendEventTx(tx,\"TASK_SUBMITTED\",{task_id:taskId,executor_id:executorId,result_sha256});const published=await publishTx(tx);await tx.commit();return {ok:true,task_id:taskId,result_sha256,published}}catch(e){try{await tx.rollback()}catch{};throw e}}\n\nexport async function rejectSubmission(verifierId:string,verifierTokens:string[],taskId:string,resultSha256:string,evidence:any){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");try{await assertTaskMemberParityTx(tx);const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];if(!r||r.state!==\"SUBMITTED\"){await tx.commit();return {ok:false,reason:\"TASK_NOT_SUBMITTED\"}}if(r.submitted_by===verifierId){await tx.commit();return {ok:false,reason:\"SELF_VERIFICATION_FORBIDDEN\"}}if(!new Set(verifierTokens.map(String)).has(\"cap:verify\")){await tx.commit();return {ok:false,reason:\"VERIFIER_CAPABILITY_REQUIRED\"}}if(r.result_sha256!==resultSha256){await tx.commit();return {ok:false,reason:\"STALE_VERIFICATION_RESULT\"}}const t=now();await tx.execute({sql:`UPDATE ${TASKS} SET state='READY',result_json=NULL,result_sha256=NULL,submitted_by=NULL,verified_by=?,verification_json=?,updated_at=? WHERE id=?`,args:[verifierId,canon({passed:false,evidence}),t,taskId]});await syncTaskMemberTx(tx,String(r.id));await appendEventTx(tx,\"TASK_VERIFICATION_REJECTED\",{task_id:taskId,verifier_id:verifierId,result_sha256:resultSha256});const published=await publishTx(tx);await tx.commit();return {ok:true,state:\"READY\",published}}catch(e){try{await tx.rollback()}catch{};throw e}}\n\nexport async function completeExactVerified(verifierId:string,verifierTokens:string[],taskId:string,resultSha256:string,evidence:any){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");try{await assertTaskMemberParityTx(tx);const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];if(!r||r.state!==\"SUBMITTED\"){await tx.commit();return {ok:false,reason:\"TASK_NOT_SUBMITTED\"}}if(r.submitted_by===verifierId){await tx.commit();return {ok:false,reason:\"SELF_VERIFICATION_FORBIDDEN\"}}if(!new Set(verifierTokens.map(String)).has(\"cap:verify\")){await tx.commit();return {ok:false,reason:\"VERIFIER_CAPABILITY_REQUIRED\"}}if(r.result_sha256!==resultSha256){await tx.commit();return {ok:false,reason:\"STALE_VERIFICATION_RESULT\"}}const spec=parse(r.verifier_spec_json,{});if(!exactKeys(spec,[\"type\",\"expected_sha256\"])||spec.type!==\"EXACT_JSON_SHA256\"||!H64.test(String(spec.expected_sha256))){await tx.commit();return {ok:false,reason:\"POSITIVE_VERIFICATION_NOT_ENFORCEABLE\"}}if(resultSha256!==spec.expected_sha256){await tx.commit();return {ok:false,reason:\"DETERMINISTIC_VERIFIER_REJECTED\"}}const t=now();await tx.execute({sql:`UPDATE ${TASKS} SET state='COMPLETE',verified_by=?,verification_json=?,updated_at=? WHERE id=?`,args:[verifierId,canon({passed:true,verifier:\"EXACT_JSON_SHA256\",evidence}),t,taskId]});await syncTaskMemberTx(tx,String(r.id));await appendEventTx(tx,\"TASK_RESULT_VERIFIED\",{task_id:taskId,verifier_id:verifierId,result_sha256:resultSha256,verifier:\"EXACT_JSON_SHA256\"});const published=await publishTx(tx);await tx.commit();return {ok:true,state:\"COMPLETE\",published}}catch(e){try{await tx.rollback()}catch{};throw e}}\n\nexport function __testEvidenceSupersedePolicyV1(row:any,verifierTokens:string[],evidence:any){\n if(!new Set((verifierTokens??[]).map(String)).has(\"cap:verify\"))return {ok:false,reason:\"VERIFIER_CAPABILITY_REQUIRED\"};\n if(!row||String(row.state)!==\"READY\")return {ok:false,reason:\"TASK_NOT_READY\"};\n if(row.result_json!==null&&row.result_json!==undefined||row.result_sha256!==null&&row.result_sha256!==undefined||row.submitted_by!==null&&row.submitted_by!==undefined||row.verified_by!==null&&row.verified_by!==undefined||row.verification_json!==null&&row.verification_json!==undefined)return {ok:false,reason:\"TASK_ALREADY_EXECUTED\"};\n if(!evidence||typeof evidence!==\"object\"||Array.isArray(evidence))return {ok:false,reason:\"CONCRETE_NEWER_EVIDENCE_REQUIRED\"};\n const source_url=String(evidence.source_url??\"\"),observed_at=String(evidence.observed_at??\"\"),finding=String(evidence.finding??\"\").trim(),observedMs=Date.parse(observed_at),taskMs=Date.parse(String(row.updated_at??\"\"));\n if(!/^https:\\/\\//.test(source_url)||finding.length<20||!Number.isFinite(observedMs))return {ok:false,reason:\"CONCRETE_NEWER_EVIDENCE_REQUIRED\"};\n if(Number.isFinite(taskMs)&&observedMs<=taskMs)return {ok:false,reason:\"EVIDENCE_NOT_NEWER_THAN_TASK\"};\n return {ok:true};\n}\n\nexport async function supersedeReadyTaskByEvidence(verifierId:string,verifierTokens:string[],taskId:string,evidence:any){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");\n try{\n await assertTaskMemberParityTx(tx);\n const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];\n const gate=__testEvidenceSupersedePolicyV1(r,verifierTokens,evidence);if(!gate.ok){await tx.commit();return gate}\n if(typeof verifierId!==\"string\"||!verifierId){await tx.commit();return {ok:false,reason:\"BAD_VERIFIER_ID\"}}\n const evidence_sha256=await sha256Text(canon(evidence)),t=now(),record={passed:false,classification:\"SUPERSEDED_BY_EVIDENCE\",evidence_sha256,evidence};\n const u:any=await tx.execute({sql:`UPDATE ${TASKS} SET state='SUPERSEDED_BY_EVIDENCE',lease_owner=NULL,lease_token=NULL,lease_expires_at=NULL,verified_by=?,verification_json=?,updated_at=? WHERE id=? AND state='READY'`,args:[verifierId,canon(record),t,taskId]});\n if(Number(u.rowsAffected)!==1){await tx.rollback();return {ok:false,reason:\"TASK_STATE_CHANGED\"}}\n await syncTaskMemberTx(tx,String(taskId));\n await appendEventTx(tx,\"TASK_SUPERSEDED_BY_EVIDENCE\",{task_id:taskId,verifier_id:verifierId,evidence_sha256,source_url:String(evidence.source_url),observed_at:String(evidence.observed_at)});\n const published=await publishTx(tx);await tx.commit();return {ok:true,state:\"SUPERSEDED_BY_EVIDENCE\",task_id:taskId,evidence_sha256,published};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\n\nexport async function retireDeterministicallyMalformedTask(executorId:string,taskId:string,leaseToken:string,evidence:any={}){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");\n try{\n await assertTaskMemberParityTx(tx);\n const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];\n if(!r||r.state!==\"LEASED\"||r.lease_owner!==executorId||r.lease_token!==leaseToken||String(r.lease_expires_at)<=now()){await tx.commit();return {ok:false,reason:\"NOT_CURRENT_LEASE_ATTEMPT\"}}\n const payload=parse(r.payload_json,{}),spec=parse(r.verifier_spec_json,{});\n if(!exactKeys(spec,[\"type\",\"expected_sha256\"])||spec.type!==\"EXACT_JSON_SHA256\"||!H64.test(String(spec.expected_sha256))){await tx.commit();return {ok:false,reason:\"EXACT_VERIFIER_REQUIRED\"}}\n if(!Object.prototype.hasOwnProperty.call(payload,\"required_result\")){await tx.commit();return {ok:false,reason:\"DECLARED_REQUIRED_RESULT_REQUIRED\"}}\n const declared_required_result_sha256=await sha256Text(canon(payload.required_result));\n if(declared_required_result_sha256===String(spec.expected_sha256)){await tx.commit();return {ok:false,reason:\"NO_DETERMINISTIC_VERIFIER_MISMATCH\"}}\n const t=now();\n const defect={classification:\"TASK_DEFINITION_DEFECT\",declared_required_result_sha256,frozen_expected_sha256:String(spec.expected_sha256),evidence};\n await tx.execute({sql:`UPDATE ${TASKS} SET state='RETIRED_DEFECTIVE',lease_owner=NULL,lease_token=NULL,lease_expires_at=NULL,verified_by=?,verification_json=?,updated_at=? WHERE id=?`,args:[executorId,canon({passed:false,defect}),t,taskId]});\n await syncTaskMemberTx(tx,String(r.id));\n await appendEventTx(tx,\"TASK_DEFINITION_DEFECT_RETIRED\",{task_id:taskId,executor_id:executorId,declared_required_result_sha256,frozen_expected_sha256:String(spec.expected_sha256),evidence});\n const published=await publishTx(tx);await tx.commit();\n return {ok:true,state:\"RETIRED_DEFECTIVE\",declared_required_result_sha256,frozen_expected_sha256:String(spec.expected_sha256),published};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\nexport async function auditKernelIntegrity(){await initKernel();const tx:any=await sqlite.transaction(\"read\");try{await assertTaskMemberParityTx(tx);await tx.commit()}catch(e){try{await tx.rollback()}catch{};return {ok:false,reason:String((e as any)?.message??e)}}const c:any=await prepareCurrentnessGuard();return c.ok?{ok:true,guard:c.guard,diagnostic:c.diagnostic}:{ok:false,reason:c.reason}}\n\n\nexport async function getTask(id:string){await initKernel();return (await sqlite.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[id]})).rows[0]??null}\n\nexport async function __testResetKernel(){await initKernel();await sqlite.batch([`DELETE FROM lineage_consumptions`,`DELETE FROM lineage_edges`,`DELETE FROM lineage_members`,`DELETE FROM lineage_snapshots`,`DELETE FROM lineage_heads`,`UPDATE lineage_current_head SET version=0,head_sha256='${\"0\".repeat(64)}' WHERE id=1`,`DELETE FROM succ_events`,`UPDATE succ_event_meta SET generation=0,event_head_hash='${\"0\".repeat(64)}' WHERE id=1`,`DELETE FROM ${TASKS}`]);}\n\n\nexport function __testEvidenceSupersedeSubmittedPolicyV1(row:any,verifierId:string,verifierTokens:string[],resultSha256:string,evidence:any){\n if(!new Set((verifierTokens??[]).map(String)).has(\"cap:verify\"))return {ok:false,reason:\"VERIFIER_CAPABILITY_REQUIRED\"};\n if(!row||String(row.state)!==\"SUBMITTED\")return {ok:false,reason:\"TASK_NOT_SUBMITTED\"};\n if(String(row.submitted_by??\"\")===String(verifierId??\"\"))return {ok:false,reason:\"SELF_VERIFICATION_FORBIDDEN\"};\n if(typeof row.result_sha256!==\"string\"||!H64.test(String(row.result_sha256))||String(row.result_sha256)!==String(resultSha256))return {ok:false,reason:\"STALE_VERIFICATION_RESULT\"};\n if(row.result_json===null||row.result_json===undefined||row.submitted_by===null||row.submitted_by===undefined)return {ok:false,reason:\"SUBMISSION_EVIDENCE_REQUIRED\"};\n if(!evidence||typeof evidence!==\"object\"||Array.isArray(evidence))return {ok:false,reason:\"CONCRETE_NEWER_EVIDENCE_REQUIRED\"};\n const source_url=String(evidence.source_url??\"\"),observed_at=String(evidence.observed_at??\"\"),finding=String(evidence.finding??\"\").trim(),observedMs=Date.parse(observed_at),taskMs=Date.parse(String(row.updated_at??\"\"));\n if(!/^https:\\/\\//.test(source_url)||finding.length<20||!Number.isFinite(observedMs))return {ok:false,reason:\"CONCRETE_NEWER_EVIDENCE_REQUIRED\"};\n if(Number.isFinite(taskMs)&&observedMs<=taskMs)return {ok:false,reason:\"EVIDENCE_NOT_NEWER_THAN_TASK\"};\n return {ok:true};\n}\n\nexport async function supersedeSubmittedTaskByEvidence(verifierId:string,verifierTokens:string[],taskId:string,resultSha256:string,evidence:any){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");\n try{\n await assertTaskMemberParityTx(tx);\n const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];\n const gate=__testEvidenceSupersedeSubmittedPolicyV1(r,verifierId,verifierTokens,resultSha256,evidence);if(!gate.ok){await tx.commit();return gate}\n if(typeof verifierId!==\"string\"||!verifierId){await tx.commit();return {ok:false,reason:\"BAD_VERIFIER_ID\"}}\n const evidence_sha256=await sha256Text(canon(evidence)),t=now(),record={passed:false,classification:\"SUPERSEDED_BY_EVIDENCE\",from_state:\"SUBMITTED\",superseded_result_sha256:String(resultSha256),evidence_sha256,evidence};\n const u:any=await tx.execute({sql:`UPDATE ${TASKS} SET state='SUPERSEDED_BY_EVIDENCE',lease_owner=NULL,lease_token=NULL,lease_expires_at=NULL,verified_by=?,verification_json=?,updated_at=? WHERE id=? AND state='SUBMITTED' AND result_sha256=?`,args:[verifierId,canon(record),t,taskId,resultSha256]});\n if(Number(u.rowsAffected)!==1){await tx.rollback();return {ok:false,reason:\"TASK_STATE_CHANGED\"}}\n await syncTaskMemberTx(tx,String(taskId));\n await appendEventTx(tx,\"TASK_SUBMISSION_SUPERSEDED_BY_EVIDENCE\",{task_id:taskId,verifier_id:verifierId,superseded_result_sha256:String(resultSha256),evidence_sha256,source_url:String(evidence.source_url),observed_at:String(evidence.observed_at)});\n const published=await publishTx(tx);await tx.commit();return {ok:true,state:\"SUPERSEDED_BY_EVIDENCE\",task_id:taskId,superseded_result_sha256:String(resultSha256),evidence_sha256,published};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\n\nexport function __testEvidenceSupersedeCompletedPolicyV1(row:any,verifierId:string,verifierTokens:string[],resultSha256:string,evidence:any){\n if(!new Set((verifierTokens??[]).map(String)).has(\"cap:verify\"))return {ok:false,reason:\"VERIFIER_CAPABILITY_REQUIRED\"};\n if(!row||String(row.state)!==\"COMPLETE\")return {ok:false,reason:\"TASK_NOT_COMPLETE\"};\n if(String(row.submitted_by??\"\")===String(verifierId??\"\")||String(row.verified_by??\"\")===String(verifierId??\"\"))return {ok:false,reason:\"SELF_CORRECTION_FORBIDDEN\"};\n if(typeof row.result_sha256!==\"string\"||!H64.test(String(row.result_sha256))||String(row.result_sha256)!==String(resultSha256))return {ok:false,reason:\"STALE_VERIFICATION_RESULT\"};\n if(row.result_json===null||row.result_json===undefined||row.submitted_by===null||row.submitted_by===undefined||row.verified_by===null||row.verified_by===undefined||row.verification_json===null||row.verification_json===undefined)return {ok:false,reason:\"COMPLETION_EVIDENCE_REQUIRED\"};\n if(!evidence||typeof evidence!==\"object\"||Array.isArray(evidence))return {ok:false,reason:\"CONCRETE_NEWER_EVIDENCE_REQUIRED\"};\n const source_url=String(evidence.source_url??\"\"),observed_at=String(evidence.observed_at??\"\"),finding=String(evidence.finding??\"\").trim(),observedMs=Date.parse(observed_at),taskMs=Date.parse(String(row.updated_at??\"\"));\n if(!/^https:\\/\\//.test(source_url)||finding.length<20||!Number.isFinite(observedMs))return {ok:false,reason:\"CONCRETE_NEWER_EVIDENCE_REQUIRED\"};\n if(Number.isFinite(taskMs)&&observedMs<=taskMs)return {ok:false,reason:\"EVIDENCE_NOT_NEWER_THAN_TASK\"};\n return {ok:true};\n}\n\nexport async function supersedeCompletedTaskByEvidence(verifierId:string,verifierTokens:string[],taskId:string,resultSha256:string,evidence:any){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");\n try{\n await assertTaskMemberParityTx(tx);\n const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];\n const gate=__testEvidenceSupersedeCompletedPolicyV1(r,verifierId,verifierTokens,resultSha256,evidence);if(!gate.ok){await tx.commit();return gate}\n if(typeof verifierId!==\"string\"||!verifierId){await tx.commit();return {ok:false,reason:\"BAD_VERIFIER_ID\"}}\n const evidence_sha256=await sha256Text(canon(evidence)),t=now(),prior_verification_json=String(r.verification_json),prior_verified_by=String(r.verified_by),record={passed:false,classification:\"SUPERSEDED_BY_EVIDENCE\",from_state:\"COMPLETE\",superseded_result_sha256:String(resultSha256),prior_verified_by,prior_verification_json,evidence_sha256,evidence};\n const u:any=await tx.execute({sql:`UPDATE ${TASKS} SET state='SUPERSEDED_BY_EVIDENCE',lease_owner=NULL,lease_token=NULL,lease_expires_at=NULL,verified_by=?,verification_json=?,updated_at=? WHERE id=? AND state='COMPLETE' AND result_sha256=?`,args:[verifierId,canon(record),t,taskId,resultSha256]});\n if(Number(u.rowsAffected)!==1){await tx.rollback();return {ok:false,reason:\"TASK_STATE_CHANGED\"}}\n await syncTaskMemberTx(tx,String(taskId));\n await appendEventTx(tx,\"TASK_COMPLETION_SUPERSEDED_BY_EVIDENCE\",{task_id:taskId,verifier_id:verifierId,prior_verified_by,superseded_result_sha256:String(resultSha256),evidence_sha256,source_url:String(evidence.source_url),observed_at:String(evidence.observed_at)});\n const published=await publishTx(tx);await tx.commit();return {ok:true,state:\"SUPERSEDED_BY_EVIDENCE\",task_id:taskId,superseded_result_sha256:String(resultSha256),evidence_sha256,published};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\n\nexport async function __testRejectedReadyVerifierDefectRetirementPolicyV1(row:any,verifierTokens:string[]){\n if(!new Set((verifierTokens??[]).map(String)).has(\"cap:verify\"))return {ok:false,reason:\"VERIFIER_CAPABILITY_REQUIRED\"};\n if(!row||String(row.state)!==\"READY\")return {ok:false,reason:\"TASK_NOT_READY\"};\n if(row.result_json!==null&&row.result_json!==undefined||row.result_sha256!==null&&row.result_sha256!==undefined||row.submitted_by!==null&&row.submitted_by!==undefined)return {ok:false,reason:\"LIVE_SUBMISSION_RESIDUE_FORBIDDEN\"};\n if(row.lease_owner!==null&&row.lease_owner!==undefined||row.lease_token!==null&&row.lease_token!==undefined||row.lease_expires_at!==null&&row.lease_expires_at!==undefined)return {ok:false,reason:\"LIVE_LEASE_RESIDUE_FORBIDDEN\"};\n const prior=parse(row.verification_json,{});if(typeof row.verified_by!==\"string\"||!row.verified_by||prior?.passed!==false)return {ok:false,reason:\"PRIOR_INDEPENDENT_REJECTION_REQUIRED\"};\n const payload=parse(row.payload_json,{}),hasRequired=Object.prototype.hasOwnProperty.call(payload,\"required_result\"),hasExpected=Object.prototype.hasOwnProperty.call(payload,\"expected_result\");\n if(Number(hasRequired)+Number(hasExpected)!==1)return {ok:false,reason:\"EXACTLY_ONE_DECLARED_RESULT_REQUIRED\"};\n const spec=parse(row.verifier_spec_json,{});if(!exactKeys(spec,[\"type\",\"expected_sha256\"])||spec.type!==\"EXACT_JSON_SHA256\"||!H64.test(String(spec.expected_sha256)))return {ok:false,reason:\"EXACT_VERIFIER_REQUIRED\"};\n const declared_result_field=hasRequired?\"required_result\":\"expected_result\",declared=hasRequired?payload.required_result:payload.expected_result,declared_result_sha256=await sha256Text(canon(declared)),frozen_expected_sha256=String(spec.expected_sha256);\n if(declared_result_sha256===frozen_expected_sha256)return {ok:false,reason:\"NO_DETERMINISTIC_VERIFIER_MISMATCH\"};\n return {ok:true,declared_result_field,declared_result_sha256,frozen_expected_sha256,prior_verified_by:String(row.verified_by),prior_verification_json:String(row.verification_json)};\n}\n\nexport async function retireRejectedReadyVerifierDefect(verifierId:string,verifierTokens:string[],taskId:string,evidence:any={}){\n await initKernel();const tx:any=await sqlite.transaction(\"write\");\n try{\n await assertTaskMemberParityTx(tx);\n const r:any=(await tx.execute({sql:`SELECT * FROM ${TASKS} WHERE id=?`,args:[taskId]})).rows[0];\n const gate:any=await __testRejectedReadyVerifierDefectRetirementPolicyV1(r,verifierTokens);if(!gate.ok){await tx.commit();return gate}\n if(typeof verifierId!==\"string\"||!verifierId){await tx.commit();return {ok:false,reason:\"BAD_VERIFIER_ID\"}}\n const t=now(),defect={classification:\"REJECTED_READY_VERIFIER_BINDING_DEFECT\",declared_result_field:gate.declared_result_field,declared_result_sha256:gate.declared_result_sha256,frozen_expected_sha256:gate.frozen_expected_sha256,prior_verified_by:gate.prior_verified_by,prior_verification_json:gate.prior_verification_json,evidence};\n const u:any=await tx.execute({sql:`UPDATE ${TASKS} SET state='RETIRED_DEFECTIVE',lease_owner=NULL,lease_token=NULL,lease_expires_at=NULL,verified_by=?,verification_json=?,updated_at=? WHERE id=? AND state='READY'`,args:[verifierId,canon({passed:false,defect}),t,taskId]});\n if(Number(u.rowsAffected)!==1){await tx.rollback();return {ok:false,reason:\"TASK_STATE_CHANGED\"}}\n await syncTaskMemberTx(tx,String(taskId));\n await appendEventTx(tx,\"TASK_REJECTED_READY_VERIFIER_DEFECT_RETIRED\",{task_id:taskId,verifier_id:verifierId,declared_result_field:gate.declared_result_field,declared_result_sha256:gate.declared_result_sha256,frozen_expected_sha256:gate.frozen_expected_sha256,prior_verified_by:gate.prior_verified_by});\n const published=await publishTx(tx);await tx.commit();return {ok:true,state:\"RETIRED_DEFECTIVE\",task_id:taskId,declared_result_field:gate.declared_result_field,declared_result_sha256:gate.declared_result_sha256,frozen_expected_sha256:gate.frozen_expected_sha256,published};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n","deleted",false,"label",[14],"f6e8c32f-bea0-4b8f-ad10-b41ce857754f",["D",1789434280321],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Clean successor focused on first real superhero","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a0a2ab-510a-711e-aa9d-429474e675c1","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","f6e8c32fbea04b8fad10b41ce857754f","tursoHostname","f6e8c32fbea04b8fad10b41ce857754f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522252250],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_55":56,"_103":104,"_105":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",1477,"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",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":42,"_147":42,"_148":42,"_149":32,"_150":-5,"_151":-7,"_152":-7,"_153":63,"_154":42,"_155":42,"_156":-5,"_157":42,"_158":42,"_159":42,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]