[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_944":945,"_946":947},"routes/_app.x.$handle.$name",{"_99":98,"_31":43,"_108":87,"_26":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":122,"_123":24,"_124":125,"_126":57,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_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":24},"version",14,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","continuity_commit_runtime_v46.ts","latestPath","fileId","c228b99a-a479-11f1-825d-1607ee4eb77e","name","fileType","script","content","import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest } from \"./memory_bridge_client.ts\";\nimport { captureOrionAgentCount } from \"./orion_agent_count_registry.ts\";\nexport async function main(){const c=await captureOrionAgentCount('RUNTIME_V46_SYNC');const e=await memoryRequest('commit',{event_type:'RUNTIME_CHANGED',entity_type:'RUNTIME',entity_id:'imperial-nca-runtime-recovery',status:'LIVE_VERIFIED',projection_category:'RUNTIMES',source_authority:70,recorded_by:'CODEX_CANONICAL_PROMOTION',idempotency_key:'IC-CANONPROMO-RUNTIME-20260830-V46',supersedes_event_id:'920de1e7-275d-4a20-8795-aa58d565cac9',content:{state:'LIVE_VERIFIED',provider:'Val Town',runtime_ref:'oromaskevic23/imperial-nca-runtime-recovery',main_version_at_sync:46,total_runtime_nca:c.totalNca,canonical_nca:c.canonicalNca,qualified_noncanonical_nca:c.expansionNca,unqualified_noncanonical_nca:0,expansion_recovery_nca:c.expansionNca,orion_watchdog:'PASS',orion_count_integrity:c.integrityStatus,orion_count_signature_sha256:c.signatureSha256,canonical_membership_sha256:c.canonicalMembershipSha256,canonical_membership_mode:'APPEND_ONLY_LEDGER',canonical_promotion_scheduler:{file:'canonical_promotion_scheduler.ts',active:true,delay_ms:7200000,max_tranche:50,atomic:true,lease:true,stop_when_no_qualified_candidates:true},authority_boundary:'NO_NEW_FINANCIAL_OUTBOUND_TOKEN_TRANSFER_OR_IRREVERSIBLE_AUTHORITY'},evidence_refs:[{type:'READINESS_TEST',reference:'CANONICAL_FLEET_READINESS_TEST production 10/10 PASS',sha256:'d3a3ceb3ad3e5bd64647b95b8c64e275617269bf306d8a095a4e2555b64ad707',status:'TESTED'}]});const chain=await memoryRequest('verify_chain',{});const out={event:e,chain};console.log(JSON.stringify(out));return out}export default main;if(isMain(import.meta.url))await main();","createdAt",["D",1788097828044],"branchVersion","branchId","8a4914f2-67bb-49e3-bb98-7dc00f86fe15","id","04f41296-b07d-43ba-83f9-d5f45983c8e6","imperial-nca-runtime-recovery",["D",1787955492364],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Recovered NCA runtime with ORION learning loop","imageUrl","fe39b163-4b50-466e-82d1-8bd01133e4b6","pinnedFileId","6796d66a-a32f-11f1-bd77-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03585-eb44-758d-92a4-77db1a9a243c","tursoName","04f41296b07d43ba83f9d5f45983c8e6","tursoHostname","04f41296b07d43ba83f9d5f45983c8e6-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789526460011],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":53,"_104":105,"_106":24},"branch",{"_13":14,"_31":87,"_41":40,"_88":42,"_89":90,"_91":92,"_93":48,"_94":42,"_95":63,"_96":43,"_97":98},"isOwned","codex-canonical-scheduler-001","projectId","forkedBranchId","fe58c05b-d08c-4472-a9bd-606aa5280a38","forkedBranchVersion",46,"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","oromaskevic23","handle","displayName","Олександр Ромаскевич","avatar","https://lh3.googleusercontent.com/a/ACg8ocIo1MJ3hDjpQrinMIRok3d2YY1vpHgehs8m2u1_vc7pmFovRGI=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":939,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":940,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":941,"_82":942,"_84":943,"_86":24},"tree",[621,625,628,631,632,633,634,635,636,637,638,639,640,641,642,643,644,645,646,647,648,649,650,651,652,653,654,655,656,657,658,659,660,661,662,663,664,665,666,667,668,669,670,671,672,673,674,675,676,677,678,679,680,681,682,683,684,685,686,687,688,689,690,691,692,693],"files",[621,622,623,624,625,626,627,628,629,630,631,632,633,634,635,636,637,638,639,640,641,642,643,644,645,646,647,648,649,650,651,652,653,654,655,656,657,658,659,660,661,662,663,664,665,666,667,668,669,670,671,672,673,674,675,676,677,678,679,680,681,682,683,684,685,686,687,688,689,690,691,692,693],"counts",{"_609":61,"_610":611,"_612":61,"_613":614,"_615":616},"contents",[138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162,163,164,165,166,167,168,169,170,171,172,173,174,175,176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200,201,202,203],"upstreamProject","upstreamBranch",{"_41":90,"_36":131,"_132":133,"_31":134,"_88":42,"_13":135,"_89":-5,"_91":-5,"_136":137,"_45":-5,"_86":24,"_47":48,"_97":98,"_62":63,"_96":43},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1787955492364],"updatedAt",["D",1789320343422],"main",1288,"lockfileKey","1789320343583-esm.town_v_oromaskevic23_imperial-nca-runtime-recovery@1288-main",{"_41":604,"_31":605,"_29":606,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":607,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_26":608},{"_41":599,"_31":600,"_29":601,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":602,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_26":603},{"_41":593,"_31":594,"_29":595,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":596,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_26":598},{"_41":587,"_31":588,"_29":589,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":590,"_13":61,"_32":20,"_34":591,"_23":24,"_212":-5,"_26":592},{"_41":581,"_31":582,"_29":583,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":584,"_13":61,"_32":33,"_34":585,"_23":24,"_212":-5,"_26":586},{"_41":575,"_31":576,"_29":577,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":578,"_13":61,"_32":33,"_34":579,"_23":24,"_212":-5,"_26":580},{"_41":568,"_31":569,"_29":570,"_207":-5,"_39":40,"_38":571,"_209":57,"_36":572,"_13":208,"_32":33,"_34":573,"_23":24,"_212":-5,"_26":574},{"_41":562,"_31":563,"_29":564,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":565,"_13":61,"_32":33,"_34":566,"_23":24,"_212":-5,"_26":567},{"_41":555,"_31":556,"_29":557,"_207":-5,"_39":40,"_38":558,"_209":57,"_36":559,"_13":61,"_32":33,"_34":560,"_23":24,"_212":-5,"_26":561},{"_41":549,"_31":550,"_29":551,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":552,"_13":61,"_32":33,"_34":553,"_23":24,"_212":-5,"_26":554},{"_41":543,"_31":544,"_29":545,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":546,"_13":61,"_32":33,"_34":547,"_23":24,"_212":-5,"_26":548},{"_41":537,"_31":538,"_29":539,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":540,"_13":61,"_32":20,"_34":541,"_23":24,"_212":-5,"_26":542},{"_41":529,"_31":530,"_29":531,"_207":-5,"_39":40,"_38":532,"_209":57,"_36":533,"_13":534,"_32":33,"_34":535,"_23":24,"_212":-5,"_26":536},{"_41":523,"_31":524,"_29":525,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":526,"_13":61,"_32":33,"_34":527,"_23":24,"_212":-5,"_26":528},{"_41":517,"_31":518,"_29":519,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":520,"_13":61,"_32":33,"_34":521,"_23":24,"_212":-5,"_26":522},{"_41":511,"_31":512,"_29":513,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":514,"_13":61,"_32":33,"_34":515,"_23":24,"_212":-5,"_26":516},{"_41":504,"_31":505,"_29":506,"_207":-5,"_39":40,"_38":507,"_209":57,"_36":508,"_13":208,"_32":33,"_34":509,"_23":24,"_212":-5,"_26":510},{"_41":499,"_31":500,"_29":501,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":502,"_13":61,"_32":33,"_34":340,"_23":24,"_212":-5,"_26":503},{"_41":493,"_31":494,"_29":495,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":496,"_13":61,"_32":218,"_34":497,"_23":24,"_212":-5,"_26":498},{"_41":486,"_31":487,"_29":488,"_207":-5,"_39":40,"_38":489,"_209":57,"_36":490,"_13":61,"_32":33,"_34":491,"_23":24,"_212":-5,"_26":492},{"_41":480,"_31":481,"_29":482,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":483,"_13":61,"_32":33,"_34":484,"_23":24,"_212":-5,"_26":485},{"_41":474,"_31":475,"_29":476,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":477,"_13":61,"_32":33,"_34":478,"_23":24,"_212":-5,"_26":479},{"_41":468,"_31":469,"_29":470,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":471,"_13":61,"_32":33,"_34":472,"_23":24,"_212":-5,"_26":473},{"_41":462,"_31":463,"_29":464,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":465,"_13":61,"_32":33,"_34":466,"_23":24,"_212":-5,"_26":467},{"_41":456,"_31":457,"_29":458,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":459,"_13":61,"_32":33,"_34":460,"_23":24,"_212":-5,"_26":461},{"_41":450,"_31":451,"_29":452,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":453,"_13":61,"_32":33,"_34":454,"_23":24,"_212":-5,"_26":455},{"_41":444,"_31":445,"_29":446,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":447,"_13":61,"_32":33,"_34":448,"_23":24,"_212":-5,"_26":449},{"_41":438,"_31":439,"_29":440,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":441,"_13":61,"_32":33,"_34":442,"_23":24,"_212":-5,"_26":443},{"_41":431,"_31":432,"_29":433,"_207":-5,"_39":40,"_38":434,"_209":57,"_36":435,"_13":208,"_32":33,"_34":436,"_23":24,"_212":-5,"_26":437},{"_41":425,"_31":426,"_29":427,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":428,"_13":61,"_32":33,"_34":429,"_23":24,"_212":-5,"_26":430},{"_41":419,"_31":420,"_29":421,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":422,"_13":61,"_32":33,"_34":423,"_23":24,"_212":-5,"_26":424},{"_41":412,"_31":413,"_29":414,"_207":-5,"_39":40,"_38":415,"_209":57,"_36":416,"_13":208,"_32":33,"_34":417,"_23":24,"_212":-5,"_26":418},{"_41":409,"_31":27,"_29":30,"_207":-5,"_39":40,"_38":14,"_209":57,"_36":410,"_13":61,"_32":33,"_34":35,"_23":24,"_212":-5,"_26":411},{"_41":403,"_31":404,"_29":405,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":406,"_13":61,"_32":33,"_34":407,"_23":24,"_212":-5,"_26":408},{"_41":397,"_31":398,"_29":399,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":400,"_13":61,"_32":33,"_34":401,"_23":24,"_212":-5,"_26":402},{"_41":391,"_31":392,"_29":393,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":394,"_13":61,"_32":33,"_34":395,"_23":24,"_212":-5,"_26":396},{"_41":385,"_31":386,"_29":387,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":388,"_13":61,"_32":33,"_34":389,"_23":24,"_212":-5,"_26":390},{"_41":378,"_31":379,"_29":380,"_207":-5,"_39":40,"_38":381,"_209":57,"_36":382,"_13":208,"_32":33,"_34":383,"_23":24,"_212":-5,"_26":384},{"_41":372,"_31":373,"_29":374,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":375,"_13":61,"_32":33,"_34":376,"_23":24,"_212":-5,"_26":377},{"_41":366,"_31":367,"_29":368,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":369,"_13":61,"_32":218,"_34":370,"_23":24,"_212":-5,"_26":371},{"_41":360,"_31":361,"_29":362,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":363,"_13":61,"_32":33,"_34":364,"_23":24,"_212":-5,"_26":365},{"_41":354,"_31":355,"_29":356,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":357,"_13":61,"_32":33,"_34":358,"_23":24,"_212":-5,"_26":359},{"_41":348,"_31":349,"_29":350,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":351,"_13":61,"_32":218,"_34":352,"_23":24,"_212":-5,"_26":353},{"_41":342,"_31":343,"_29":344,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":345,"_13":61,"_32":218,"_34":346,"_23":24,"_212":-5,"_26":347},{"_41":336,"_31":337,"_29":338,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":339,"_13":61,"_32":33,"_34":340,"_23":24,"_212":-5,"_26":341},{"_41":330,"_31":331,"_29":332,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":333,"_13":61,"_32":218,"_34":334,"_23":24,"_212":-5,"_26":335},{"_41":324,"_31":325,"_29":326,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":327,"_13":61,"_32":33,"_34":328,"_23":24,"_212":-5,"_26":329},{"_41":318,"_31":319,"_29":320,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":321,"_13":61,"_32":218,"_34":322,"_23":24,"_212":-5,"_26":323},{"_41":312,"_31":313,"_29":314,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":315,"_13":61,"_32":33,"_34":316,"_23":24,"_212":-5,"_26":317},{"_41":306,"_31":307,"_29":308,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":309,"_13":61,"_32":218,"_34":310,"_23":24,"_212":-5,"_26":311},{"_41":300,"_31":301,"_29":302,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":303,"_13":61,"_32":33,"_34":304,"_23":24,"_212":-5,"_26":305},{"_41":294,"_31":295,"_29":296,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":297,"_13":61,"_32":33,"_34":298,"_23":24,"_212":-5,"_26":299},{"_41":288,"_31":289,"_29":290,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":291,"_13":61,"_32":33,"_34":292,"_23":24,"_212":-5,"_26":293},{"_41":282,"_31":283,"_29":284,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":285,"_13":61,"_32":33,"_34":286,"_23":24,"_212":-5,"_26":287},{"_41":276,"_31":277,"_29":278,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":279,"_13":61,"_32":33,"_34":280,"_23":24,"_212":-5,"_26":281},{"_41":270,"_31":271,"_29":272,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":273,"_13":61,"_32":231,"_34":274,"_23":24,"_212":-5,"_26":275},{"_41":264,"_31":265,"_29":266,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":267,"_13":61,"_32":33,"_34":268,"_23":24,"_212":-5,"_26":269},{"_41":258,"_31":259,"_29":260,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":261,"_13":61,"_32":218,"_34":262,"_23":24,"_212":-5,"_26":263},{"_41":252,"_31":253,"_29":254,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":255,"_13":61,"_32":218,"_34":256,"_23":24,"_212":-5,"_26":257},{"_41":246,"_31":247,"_29":248,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":249,"_13":61,"_32":20,"_34":250,"_23":24,"_212":-5,"_26":251},{"_41":240,"_31":241,"_29":242,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":243,"_13":61,"_32":218,"_34":244,"_23":24,"_212":-5,"_26":245},{"_41":234,"_31":235,"_29":236,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":237,"_13":61,"_32":33,"_34":238,"_23":24,"_212":-5,"_26":239},{"_41":227,"_31":228,"_29":229,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":230,"_13":61,"_32":231,"_34":232,"_23":24,"_212":-5,"_26":233},{"_41":221,"_31":222,"_29":223,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":224,"_13":61,"_32":33,"_34":225,"_23":24,"_212":-5,"_26":226},{"_41":214,"_31":215,"_29":216,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":217,"_13":61,"_32":218,"_34":219,"_23":24,"_212":-5,"_26":220},{"_41":204,"_31":205,"_29":206,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":210,"_13":61,"_32":33,"_34":211,"_23":24,"_212":-5,"_26":213},"d34e9d24-155b-4ce7-b7d0-61d65441b72a","velion_allocator_test.ts","01a052e0-c8f3-7503-a01f-66bf737afc1c","parentId",1,"latest",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nfunction targetFor(level:number){\n if(level<=0) return 1;\n if(level===1) return 3;\n if(level===2) return 8;\n if(level===3) return 20;\n if(level===4) return 50;\n return 150;\n}\n\nconst bands=[0,1,2,3,4,5].map(level=>({level,target:targetFor(level)}));\nconst mission=(await sqlite.execute({sql:\"SELECT mission_id,complexity_level,requested_nca,allocated_nca,state,truth_boundary FROM velion_missions WHERE mission_id=?\",args:[\"VELION-FOUNDATION-001\"]})).rows[0];\nconst allocations=Number((await sqlite.execute({sql:\"SELECT COUNT(*) AS n FROM velion_allocations WHERE mission_id=?\",args:[\"VELION-FOUNDATION-001\"]})).rows[0]?.n ?? 0);\nconst fleet=Number((await sqlite.execute(\"SELECT COUNT(*) AS n FROM agents\")).rows[0]?.n ?? 0);\nconst checks={bands:JSON.stringify(bands)===JSON.stringify([{level:0,target:1},{level:1,target:3},{level:2,target:8},{level:3,target:20},{level:4,target:50},{level:5,target:150}]),mission:mission?.state===\"ALLOCATED\",allocated:allocations===50 && Number(mission?.allocated_nca)===50,fleet:fleet===150,truth:mission?.truth_boundary===\"ALLOCATED != EXECUTED\"};\nconst passed=Object.values(checks).filter(Boolean).length;\nconsole.log(JSON.stringify({test:\"VELION_ALLOCATOR_FOUNDATION_TEST\",status:passed===5?\"PASS\":\"FAIL\",passed,total:5,checks,mission,bands,fleet,truthBoundary:\"ALLOCATION_PASS != EXECUTION_PASS\"},null,2));\n","label",[205],"4d64bc76-b2fd-4d1a-b43e-70305b653153","velion_agent_worker.ts","01a052e0-c8f3-7503-a01f-633f3fba67da",["D",1788096858357],"interval","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nasync function sha256(value:string){\n const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nasync function scalar(sql:string,args:any[]=[]){\n const r=await sqlite.execute({sql,args});\n const row=(r.rows as any[])[0]??{};\n const key=Object.keys(row)[0];\n return key ? row[key] : null;\n}\n\nasync function ensure(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS velion_work_queue(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n mission_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n lane TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY',\n created_at TEXT NOT NULL,\n claimed_at TEXT,\n completed_at TEXT,\n evidence_id INTEGER,\n UNIQUE(mission_id,agent_id)\n )`},\n {sql:`CREATE TABLE IF NOT EXISTS velion_execution_evidence(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n queue_id INTEGER NOT NULL,\n mission_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n lane TEXT NOT NULL,\n observed_json TEXT NOT NULL,\n evidence_sha256 TEXT NOT NULL,\n verifier_state TEXT NOT NULL,\n observed_at TEXT NOT NULL\n )`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_velion_work_state ON velion_work_queue(state,id)`}\n ]);\n}\n\nasync function seed(now:string){\n const a=await sqlite.execute({sql:`SELECT agent_id FROM velion_allocations WHERE mission_id=? ORDER BY agent_id`,args:[\"VELION-FOUNDATION-001\"]});\n const agents=(a.rows as any[]).map(x=>String(x.agent_id));\n const lanes=[\"MODEL_ROUTER_AUDIT\",\"EXECUTION_PATH_AUDIT\",\"VELION_SCHEMA_AUDIT\",\"GOVERNANCE_AUDIT\",\"FLEET_CAPACITY_AUDIT\"];\n for(let i=0;i0?\"LIVE_MODEL_BINDING_PRESENT\":\"MODEL_BACKEND_NOT_LIVE\"};\n }\n if(lane===\"EXECUTION_PATH_AUDIT\"){\n const q=Number(await scalar(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name='execution_queue'`));\n const e=Number(await scalar(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name='execution_evidence'`));\n const completed=Number(await scalar(`SELECT COUNT(*) n FROM execution_queue WHERE state='COMPLETED'`));\n return {lane,execution_queue_table:q,execution_evidence_table:e,completed_with_evidence_path:completed,finding:q&&e?\"EXECUTION_PATH_PRESENT\":\"EXECUTION_PATH_MISSING\"};\n }\n if(lane===\"VELION_SCHEMA_AUDIT\"){\n const tables=Number(await scalar(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name IN ('velion_missions','velion_allocations','velion_capacity_events')`));\n return {lane,core_tables:tables,expected:3,finding:tables===3?\"VELION_CORE_SCHEMA_PRESENT\":\"VELION_SCHEMA_INCOMPLETE\"};\n }\n if(lane===\"GOVERNANCE_AUDIT\"){\n const tb=String(await scalar(`SELECT truth_boundary FROM velion_missions WHERE mission_id='VELION-FOUNDATION-001'`)??\"\");\n return {lane,truth_boundary:tb,finding:tb.includes(\"ALLOCATED != EXECUTED\")?\"TRUTH_BOUNDARY_PRESENT\":\"TRUTH_BOUNDARY_MISSING\"};\n }\n const total=Number(await scalar(`SELECT COUNT(*) n FROM agents`));\n const allocated=Number(await scalar(`SELECT COUNT(*) n FROM velion_allocations WHERE mission_id='VELION-FOUNDATION-001'`));\n return {lane,total_agents:total,velion_allocated:allocated,finding:allocated===50?\"FOUNDATION_CAPACITY_PRESENT\":\"FOUNDATION_CAPACITY_MISMATCH\"};\n}\n\nexport default async function(_interval:Interval){\n await ensure();\n const now=new Date().toISOString();\n const seeded=await seed(now);\n const r=await sqlite.execute(`SELECT * FROM velion_work_queue WHERE state='READY' ORDER BY id LIMIT 50`);\n const tasks=(r.rows as any[]);\n let passed=0;\n for(const task of tasks){\n const claimedAt=new Date().toISOString();\n const c=await sqlite.execute({sql:`UPDATE velion_work_queue SET state='CLAIMED',claimed_at=? WHERE id=? AND state='READY'`,args:[claimedAt,task.id]});\n if(Number(c.rowsAffected)!==1) continue;\n try{\n const observed=await observe(String(task.lane));\n const observedJson=JSON.stringify(observed);\n const digest=await sha256(observedJson);\n const ev=await sqlite.execute({sql:`INSERT INTO velion_execution_evidence(queue_id,mission_id,agent_id,lane,observed_json,evidence_sha256,verifier_state,observed_at) VALUES(?,?,?,?,?,?,?,?)`,args:[task.id,task.mission_id,task.agent_id,task.lane,observedJson,digest,\"PASS\",new Date().toISOString()]});\n await sqlite.execute({sql:`UPDATE velion_work_queue SET state='COMPLETED',completed_at=?,evidence_id=? WHERE id=? AND state='CLAIMED'`,args:[new Date().toISOString(),Number(ev.lastInsertRowid??0),task.id]});\n await sqlite.execute({sql:`UPDATE velion_allocations SET allocation_state='BOOTSTRAP_EXECUTED_VERIFIED' WHERE mission_id=? AND agent_id=?`,args:[task.mission_id,task.agent_id]});\n passed++;\n }catch(e){\n await sqlite.execute({sql:`UPDATE velion_work_queue SET state='FAILED',completed_at=? WHERE id=? AND state='CLAIMED'`,args:[new Date().toISOString(),task.id]});\n }\n }\n const completed=Number(await scalar(`SELECT COUNT(*) n FROM velion_work_queue WHERE mission_id='VELION-FOUNDATION-001' AND state='COMPLETED'`));\n const evidence=Number(await scalar(`SELECT COUNT(*) n FROM velion_execution_evidence WHERE mission_id='VELION-FOUNDATION-001' AND verifier_state='PASS'`));\n await sqlite.execute({sql:`UPDATE velion_missions SET state='EXECUTING',truth_boundary='BOOTSTRAP_EXECUTED != VELION_LLM_LIVE',updated_at=? WHERE mission_id='VELION-FOUNDATION-001'`,args:[new Date().toISOString()]});\n console.log(JSON.stringify({event:\"VELION_AGENT_WORKER\",status:passed===tasks.length?\"PASS\":\"PARTIAL\",seeded,processed:tasks.length,passed,completed,evidence,mission_state:\"EXECUTING\",truthBoundary:\"BOOTSTRAP_EXECUTED != VELION_LLM_LIVE\"}));\n}\n",[215],"12cda85d-9409-430f-83d7-733039ff696c","task_journal_schema.ts","01a052e0-c8f3-7503-a01f-5df7cf119600",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\n\nexport async function main(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS task_journal (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n journal_id TEXT NOT NULL UNIQUE,\n mission_id TEXT NOT NULL,\n occurred_at TEXT NOT NULL,\n actor TEXT NOT NULL,\n action_type TEXT NOT NULL,\n action TEXT NOT NULL,\n target TEXT,\n status TEXT NOT NULL,\n blocker TEXT,\n evidence TEXT NOT NULL DEFAULT '{}',\n next_action TEXT,\n authority_boundary TEXT NOT NULL DEFAULT 'GOVERNED',\n created_at TEXT NOT NULL\n )`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_task_journal_mission_time ON task_journal(mission_id,occurred_at)`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_task_journal_status ON task_journal(status,occurred_at)`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_delegated_tasks (\n task_id TEXT PRIMARY KEY,mission_id TEXT NOT NULL,agent_id TEXT NOT NULL,task_type TEXT NOT NULL,\n title TEXT NOT NULL,instruction TEXT NOT NULL,state TEXT NOT NULL DEFAULT 'READY',\n evidence_state TEXT NOT NULL DEFAULT 'NONE',evidence TEXT NOT NULL DEFAULT '{}',blocker TEXT,\n approval_boundary TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL\n )`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_nca_delegated_state ON nca_delegated_tasks(state,updated_at)`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_nca_delegated_agent ON nca_delegated_tasks(agent_id,state)`},\n {sql:`CREATE TRIGGER IF NOT EXISTS nca_delegated_insert_journal AFTER INSERT ON nca_delegated_tasks BEGIN\n INSERT INTO task_journal(journal_id,mission_id,occurred_at,actor,action_type,action,target,status,blocker,evidence,next_action,authority_boundary,created_at)\n VALUES('AUTO-'||NEW.task_id||'-I',NEW.mission_id,NEW.created_at,NEW.agent_id,'NCA_DELEGATED',NEW.title,NEW.task_id,NEW.state,NEW.blocker,NEW.evidence,NEW.instruction,NEW.approval_boundary,NEW.created_at);\n END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS nca_delegated_update_journal AFTER UPDATE OF state,evidence_state,blocker ON nca_delegated_tasks\n WHEN OLD.state<>NEW.state OR OLD.evidence_state<>NEW.evidence_state OR COALESCE(OLD.blocker,'')<>COALESCE(NEW.blocker,'') BEGIN\n INSERT OR IGNORE INTO task_journal(journal_id,mission_id,occurred_at,actor,action_type,action,target,status,blocker,evidence,next_action,authority_boundary,created_at)\n VALUES('AUTO-'||NEW.task_id||'-U-'||strftime('%s',NEW.updated_at),NEW.mission_id,NEW.updated_at,NEW.agent_id,'NCA_STATE_CHANGE',NEW.title,NEW.task_id,NEW.state,NEW.blocker,NEW.evidence,NEW.instruction,NEW.approval_boundary,NEW.updated_at);\n END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS task_journal_no_update BEFORE UPDATE ON task_journal BEGIN SELECT RAISE(ABORT,'task_journal is append-only'); END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS task_journal_no_delete BEFORE DELETE ON task_journal BEGIN SELECT RAISE(ABORT,'task_journal is append-only'); END`},\n ]);\n const journal=Number((await sqlite.execute(`SELECT COUNT(*) n FROM task_journal`)).rows[0]?.n??0);\n const delegated=Number((await sqlite.execute(`SELECT COUNT(*) n FROM nca_delegated_tasks`)).rows[0]?.n??0);\n const appendOnly=Number((await sqlite.execute(`SELECT COUNT(*) n FROM sqlite_master WHERE type='trigger' AND name IN ('task_journal_no_update','task_journal_no_delete')`)).rows[0]?.n??0);\n const result={event:'TASK_JOURNAL_SCHEMA',status:appendOnly===2?'PASS':'FAIL',journal,delegated,appendOnly,truthBoundary:'APPEND_ONLY_JOURNAL_RECORDS_ACTIONS_AND_STATE_CHANGES; IT_DOES_NOT_PROVE_EXTERNAL_SUCCESS'};\n console.log(JSON.stringify(result));\n if(result.status!=='PASS')throw new Error('TASK_JOURNAL_SCHEMA_GATE_FAILED');\n return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[222],"fed19a17-90e2-4e23-ab36-99092dc0f20a","skill_status.ts","01a052e0-c8f3-7503-a01f-5b4c762b886d",["D",1788096858357],"http","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nexport default async function(){\n const a=await sqlite.execute(`SELECT COUNT(*) agents,SUM(CASE WHEN status LIKE 'RUNNING%' THEN 1 ELSE 0 END) running,MIN(last_heartbeat) oldest_heartbeat,MAX(last_heartbeat) newest_heartbeat,SUM(CASE WHEN network_ok=1 THEN 1 ELSE 0 END) network_ok FROM agents`);\n const s=await sqlite.execute(`SELECT skill_id,skill_version,runtime_state,COUNT(*) agents FROM skill_runtime_bindings GROUP BY skill_id,skill_version,runtime_state ORDER BY skill_id`);\n const c=await sqlite.execute(`SELECT COUNT(*) activeBindings FROM skill_runtime_bindings WHERE runtime_state IN ('ACTIVE_BOUNDED','ACTIVE_READ_ONLY')`);\n const o=await sqlite.execute(`SELECT key,value,updated_at FROM orion_state WHERE key IN ('last_cycle_at','last_cycle_status','last_feedback_at','last_feedback_status')`);\n const ack=await sqlite.execute(`SELECT decision,COUNT(*) c FROM orion_ack GROUP BY decision`);\n const out=await sqlite.execute(`SELECT result,COUNT(*) c FROM orion_outcomes GROUP BY result`);\n return Response.json({service:\"IMPERIAL Skill Runtime Status — Recovery\",recoveryState:\"ACTIVE_CONSERVATIVE_BASELINE\",agents:a.rows[0],activeBindings:Number((c.rows[0] as any)?.activeBindings??0),skillSets:s.rows,orion:{state:o.rows,acks:ack.rows,outcomes:out.rows},authority:\"SKILLS_AND_ORION_DO_NOT_GRANT_EXECUTION_AUTHORITY\",truthBoundary:\"RECOVERY_RUNTIME_ACTIVE != ORIGINAL_RUNTIME_RESTORED != PRODUCTION\"},{headers:{\"cache-control\":\"no-store\",\"x-content-type-options\":\"nosniff\"}})\n}\n",[228],"859103da-d6df-40a9-9aec-045a07114243","six_skill_integration_test.ts","01a052e0-c8f3-7503-a01f-564498c1eee6",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst expected:any={\n \"Playwright-CLI\":{v:\"0.1.17\",state:\"ACTIVE_BOUNDED\",rule:\"SKILL_DOES_NOT_GRANT_AUTHORITY\"},\n \"Supabase\":{v:\"1.0.0-imperial\",state:\"ACTIVE_BOUNDED\",rule:\"SKILL_DOES_NOT_GRANT_AUTHORITY\"},\n \"Strix\":{v:\"1.5.3\",state:\"ACTIVE_BOUNDED_DEFENSIVE\",rule:\"DEFENSIVE_AUTHORIZED_ONLY\"},\n \"Skill-UI\":{v:\"0.1.0\",state:\"ACTIVE_BOUNDED\",rule:\"SKILL_DOES_NOT_GRANT_AUTHORITY\"},\n \"Context7\":{v:\"3.2.5\",state:\"ACTIVE_BOUNDED\",rule:\"DOCUMENTATION_DOES_NOT_GRANT_AUTHORITY\"},\n \"Agent-Reach\":{v:\"1.5.0\",state:\"ACTIVE_BOUNDED\",rule:\"PUBLIC_RESEARCH_ONLY_BY_DEFAULT\"}\n};\nconst r=await sqlite.execute(`SELECT skill_id,skill_version,runtime_state,authority_rule,COUNT(*) AS n FROM skill_runtime_bindings WHERE skill_id IN ('Playwright-CLI','Supabase','Strix','Skill-UI','Context7','Agent-Reach') GROUP BY skill_id,skill_version,runtime_state,authority_rule`);\nconst rows=r.rows as any[]; const tests:any[]=[];\nfor(const [id,e] of Object.entries(expected) as any){const x=rows.find(y=>y.skill_id===id);tests.push({skill:id,pass:!!x&&x.skill_version===e.v&&x.runtime_state===e.state&&x.authority_rule===e.rule&&Number(x.n)===100,bindings:Number(x?.n??0),version:x?.skill_version??null,state:x?.runtime_state??null,authority_rule:x?.authority_rule??null});}\nconst fail=tests.filter(x=>!x.pass);\nconsole.log(JSON.stringify({event:\"SIX_SKILL_INTEGRATION_TEST\",status:fail.length?\"FAIL\":\"PASS\",passed:tests.length-fail.length,total:tests.length,tests,truthBoundary:\"BOUND != CLI_EXECUTED; CAPABILITY != AUTHORITY\"},null,2));\nif(fail.length)throw new Error(`FAILED_${fail.length}`);\n",[235],"de140966-aee3-496f-8073-624185822a20","runner.ts","01a052e0-c8f3-7503-a01f-51c8bb9418af",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst START = new Date(\"2026-08-28T00:48:37+03:00\");\nconst END = new Date(\"2026-09-28T00:48:37+03:00\");\n\nfunction missionDay(now: Date) {\n return Math.max(1, Math.min(31, Math.floor((now.getTime() - START.getTime()) / 86400000) + 1));\n}\nfunction phase(day:number){\n if(day<=3)return \"ROUTE_LOCK\";\n if(day<=7)return \"MARKET_VALIDATION\";\n if(day<=14)return \"PIPELINE\";\n if(day<=21)return \"DELIVERY_AND_CONVERSION\";\n if(day<=28)return \"SCALE_PROVEN_ROUTE\";\n return \"CLOSURE\";\n}\n\nexport default async function(_interval: Interval){\n const now=new Date();\n let networkOk=0;\n for(const url of [\"https://api.github.com/zen\",\"https://www.cloudflare.com/cdn-cgi/trace\"]){\n try{const r=await fetch(url,{headers:{\"user-agent\":\"IMPERIAL-Recovery-Runtime\"},signal:AbortSignal.timeout(5000)});if(r.ok){networkOk=1;break}}catch{}\n }\n const day=missionDay(now);\n const currentPhase=phase(day);\n await sqlite.execute({sql:`UPDATE agents SET status=?,last_heartbeat=?,tick_count=tick_count+1,mission_day=?,phase=?,network_ok=?`,args:[now<=END?\"RUNNING_RECOVERY\":\"MISSION_ENDED\",now.toISOString(),day,currentPhase,networkOk]});\n await sqlite.execute({sql:`UPDATE revenue_navigator_state SET current_phase=?,last_verified_at=?`,args:[currentPhase,now.toISOString()]});\n await sqlite.execute({sql:`UPDATE agents SET next_action=(SELECT n.next_action FROM revenue_navigator_state n WHERE n.agent_id=agents.agent_id) WHERE EXISTS(SELECT 1 FROM revenue_navigator_state n WHERE n.agent_id=agents.agent_id)`,args:[]});\n await sqlite.execute({sql:`UPDATE skill_runtime_bindings SET last_verified_at=?`,args:[now.toISOString()]});\n console.log(JSON.stringify({event:\"IMPERIAL_RECOVERY_HEARTBEAT\",status:\"PASS\",missionDay:day,phase:currentPhase,networkOk,at:now.toISOString(),truthBoundary:\"RECOVERY_RUNTIME_ACTIVE != ORIGINAL_RUNTIME_RESTORED\"}));\n}\n",[241],"c90f2399-427c-4da6-be66-6dbae38f0533","promotion_run_instruction.txt","01a052e0-c8f3-7503-a01f-4e016882e75c",["D",1788096858357],"Run order: canonical_promotion_preflight_test.ts -> canonical_fleet_promotion.ts -> canonical_promotion_orion_activation_test.ts -> orion_fleet_cycle.ts -> orion_watchdog.ts -> canonical_promotion_regression_test.ts -> canonical_promotion_postcheck.ts. Stop promotion on any failed gate; do not claim canonical promotion without post-merge production verification.",[247],"6d3d0344-79bc-4745-9ce1-c51e0ab07e96","performance_worker.ts","01a052e0-c8f3-7503-a01f-4a8851842ecc",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ALLOWED_HOSTS } from \"./performance_sources.ts\";\nimport { ensurePerformanceSchema,event,FORBIDDEN,MISSION_ID,safePublicUrl,sha256 } from \"./performance_schema.ts\";\n\nasync function claim(limit=25){\n const q=await sqlite.execute({sql:`SELECT * FROM nca_performance_tasks WHERE mission_id=? AND state='READY' AND requires_approval=0 ORDER BY priority,assigned_at LIMIT ?`,args:[MISSION_ID,limit]});\n const claimed:any[]=[];\n for(const t of q.rows as any[]){\n const now=new Date().toISOString();\n const u=await sqlite.execute({sql:`UPDATE nca_performance_tasks SET state='EXECUTING',started_at=?,last_transition_at=? WHERE task_id=? AND state='READY' AND requires_approval=0`,args:[now,now,t.task_id]});\n if(Number(u.rowsAffected)!==1)continue;\n await sqlite.execute({sql:`UPDATE nca_performance_agents SET current_state='EXECUTING',tasks_started=tasks_started+1,updated_at=? WHERE mission_id=? AND agent_id=?`,args:[now,MISSION_ID,t.agent_id]});\n claimed.push({...t,started_at:now});\n }\n return claimed;\n}\n\nasync function fetchBounded(raw:string,timeout:number){\n const primary=safePublicUrl(raw,ALLOWED_HOSTS);\n const candidates=[primary.toString()];\n if(primary.pathname!==\"/\"||primary.search) candidates.push(`${primary.origin}/`);\n let best:{response:Response;text:string;finalUrl:string;strategy:string}|null=null;\n let lastError=\"NO_HTTP_RESPONSE\";\n for(let candidateIndex=0;candidateIndex=400)break;\n const location=response.headers.get(\"location\"); if(!location)break;\n try{url=safePublicUrl(new URL(location,url).toString(),ALLOWED_HOSTS)}\n catch(e){throw new Error(`REDIRECT_TARGET_NOT_ALLOWLISTED:${new URL(location,url).hostname.toLowerCase()}`)}\n }\n if(!response)throw new Error(\"NO_HTTP_RESPONSE\");\n const text=(await response.text()).slice(0,250000);\n const observed={response,text,finalUrl:url.toString(),strategy:candidateIndex===0?\"PRIMARY_URL\":\"OFFICIAL_HOST_ROOT_FALLBACK\"};\n if(!best||((response.status>=200&&response.status<300)?1:0)>((best.response.status>=200&&best.response.status<300)?1:0)||text.length>best.text.length) best=observed;\n if(response.status>=200&&response.status<300&&text.length>=200) return observed;\n lastError=`HTTP_${response.status}_OR_SHORT_BODY_${text.length}`;\n }catch(e){lastError=e instanceof Error?e.message:String(e)}\n }\n if(best)return best;\n throw new Error(lastError);\n}\n\nfunction titleOf(body:string){\n const m=body.match(/]*>([\\s\\S]{1,300}?)<\\/title>/i); return (m?.[1]??\"\").replace(/\\s+/g,\" \").trim().slice(0,200);\n}\n\nasync function record(t:any,observed:any,error:string|null){\n const done=new Date().toISOString(); const started=String(t.started_at); const latency=Math.max(0,Date.parse(done)-Date.parse(started));\n const body=String(observed?.text??\"\"); const status=Number(observed?.response?.status??0); const strategy=String(observed?.strategy??\"NO_OBSERVATION\"); const sourceBodyHash=body?await sha256(body):null;\n const selfCheck=status>=200&&status<300&&body.length>=200&&!!sourceBodyHash;\n const critic=selfCheck?\"PASS\":\"REJECT\";\n const criticReason=selfCheck?\"SOURCE_RETRIEVED_HASHED_AND_MINIMUM_CONTENT_PRESENT\":error??`HTTP_${status}_OR_SHORT_BODY_${body.length}`;\n const compliance=String(t.task_type)===\"HTTP_GET_OFFICIAL_RESEARCH\"&&Number(t.requires_approval)===0&&!FORBIDDEN.test(String(t.instruction))?\"PASS\":\"REJECT\";\n const complianceReason=compliance===\"PASS\"?\"READ_ONLY_ALLOWLISTED_GET_NO_OUTBOUND_CONTACT_NO_FINANCIAL_ACTION\":\"TASK_POLICY_CONFLICT\";\n const evidenceScore=(status>=200&&status<300?35:0)+(body.length>=200?25:0)+(sourceBodyHash?20:0)+(observed?.finalUrl?20:0);\n const factualScore=selfCheck?95:Math.min(60,evidenceScore); const complianceScore=compliance===\"PASS\"?100:0;\n const prior=sourceBodyHash?await sqlite.execute({sql:`SELECT task_id FROM nca_performance_evidence WHERE mission_id=? AND source_body_sha256=? AND task_id<>? AND final_state='COMPLETED' LIMIT 1`,args:[MISSION_ID,sourceBodyHash,t.task_id]}):{rows:[]};\n const duplicate=String((prior.rows as any[])?.[0]?.task_id??\"\");\n const passed=critic===\"PASS\"&&compliance===\"PASS\"&&evidenceScore>=85&&!duplicate;\n const finalState=passed?\"COMPLETED\":Number(t.retry_count)x.verified).length,failed=results.filter(x=>x.state===\"FAILED\").length,retry=results.filter(x=>x.state===\"READY\").length;\n const out={event:\"NCA_PERFORMANCE_WORKER\",status:failed?\"PARTIAL\":claimed.length?\"PASS\":\"NO_READY_TASKS\",claimed:claimed.length,verified,failed,retry,results,truthBoundary:\"VERIFIED_SOURCE_RETRIEVAL != LIQUIDITY_OR_PARTNERSHIP_OR_REVENUE\"};\n console.log(JSON.stringify(out)); return out;\n}\n",[253],"0779c072-70fa-4a8d-b2eb-2399a4eb2d13","performance_watchdog.ts","01a052e0-c8f3-7503-a01f-473251af641d",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensurePerformanceSchema,event,MISSION_ID } from \"./performance_schema.ts\";\nimport { recoveryDecision } from \"./performance_policy.ts\";\n\nexport default async function(){\n await ensurePerformanceSchema(); const now=new Date().toISOString(); let stale=0,requeued=0,failed=0,blocked=0,missing=0;\n const running=await sqlite.execute({sql:`SELECT * FROM nca_performance_tasks WHERE mission_id=? AND state='EXECUTING'`,args:[MISSION_ID]});\n for(const t of running.rows as any[]){\n const age=Math.max(0,(Date.now()-Date.parse(String(t.last_transition_at)))/1000);\n const d=recoveryDecision({state:t.state,ageSeconds:age,staleAfter:Number(t.stale_after_seconds),retryCount:Number(t.retry_count),maxRetries:Number(t.max_retries),hasEvidence:false});\n if(d.action===\"NO_CHANGE\")continue; stale++;\n await sqlite.execute({sql:`UPDATE nca_performance_tasks SET state=?,retry_count=retry_count+?,last_transition_at=?,last_error=? WHERE task_id=? AND state='EXECUTING'`,args:[d.state,d.state===\"READY\"?1:0,now,\"WATCHDOG_STALE_TASK\",t.task_id]});\n await sqlite.execute({sql:`UPDATE nca_performance_agents SET current_state=?,stale_task_count=stale_task_count+1,retry_count=retry_count+?,tasks_failed=tasks_failed+?,updated_at=? WHERE mission_id=? AND agent_id=?`,args:[d.state,d.state===\"READY\"?1:0,d.state===\"FAILED\"?1:0,now,MISSION_ID,t.agent_id]});\n if(d.state===\"READY\")requeued++;else failed++;\n await event(t.agent_id,t.task_id,\"WATCHDOG_STALE_RECOVERY\",\"EXECUTING\",d.state,{ageSeconds:age,action:d.action});\n }\n const bad=await sqlite.execute({sql:`SELECT t.task_id,t.agent_id FROM nca_performance_tasks t LEFT JOIN nca_performance_evidence e ON e.id=t.evidence_id AND e.task_id=t.task_id WHERE t.mission_id=? AND t.state='COMPLETED' AND (e.id IS NULL OR e.final_state<>'COMPLETED' OR e.critic_result<>'PASS' OR e.compliance_result<>'PASS')`,args:[MISSION_ID]});\n for(const t of bad.rows as any[]){\n missing++;blocked++;\n await sqlite.execute({sql:`UPDATE nca_performance_tasks SET state='BLOCKED',last_transition_at=?,last_error='COMPLETED_WITHOUT_VALID_EVIDENCE' WHERE task_id=? AND state='COMPLETED'`,args:[now,t.task_id]});\n await sqlite.execute({sql:`UPDATE nca_performance_agents SET current_state='BLOCKED',verified_results=CASE WHEN verified_results>0 THEN verified_results-1 ELSE 0 END,useful_output_count=CASE WHEN useful_output_count>0 THEN useful_output_count-1 ELSE 0 END,rejected_results=rejected_results+1,updated_at=? WHERE mission_id=? AND agent_id=?`,args:[now,MISSION_ID,t.agent_id]});\n await event(t.agent_id,t.task_id,\"WATCHDOG_NO_FAKE_COMPLETION\",\"COMPLETED\",\"BLOCKED\",{reason:\"MISSING_OR_REJECTED_EVIDENCE\"});\n }\n const dup=await sqlite.execute({sql:`SELECT COUNT(*) n FROM (SELECT task_fingerprint FROM nca_performance_tasks WHERE mission_id=? GROUP BY task_fingerprint HAVING COUNT(*)>1)`,args:[MISSION_ID]});\n const duplicates=Number((dup.rows as any[])[0]?.n??0);\n const noTask=await sqlite.execute({sql:`SELECT p.agent_id FROM nca_performance_agents p LEFT JOIN nca_performance_tasks t ON t.mission_id=p.mission_id AND t.agent_id=p.agent_id WHERE p.mission_id=? AND t.task_id IS NULL`,args:[MISSION_ID]});\n for(const a of noTask.rows as any[]){blocked++;await sqlite.execute({sql:`UPDATE nca_performance_agents SET current_state='BLOCKED',updated_at=? WHERE mission_id=? AND agent_id=?`,args:[now,MISSION_ID,a.agent_id]});await event(a.agent_id,null,\"ZERO_IDLE_BLOCKER\",null,\"BLOCKED\",{reason:\"NO_EXECUTABLE_TASK\",recommendation:\"Prepare evidence-review fallback\"});}\n const status=failed||blocked||duplicates?\"DEGRADED\":\"PASS\";\n const payload={stale,requeued,failed,blocked,missing,duplicates,noTask:Number((noTask.rows as any[]).length),truthBoundary:\"HEARTBEAT_IS_NOT_PRODUCTIVITY\"};\n await sqlite.execute({sql:`INSERT INTO nca_performance_watchdog(id,status,last_checked_at,stale_detected,requeued,failed,blocked,missing_evidence,duplicates,payload) VALUES(1,?,?,?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET status=excluded.status,last_checked_at=excluded.last_checked_at,stale_detected=excluded.stale_detected,requeued=excluded.requeued,failed=excluded.failed,blocked=excluded.blocked,missing_evidence=excluded.missing_evidence,duplicates=excluded.duplicates,payload=excluded.payload`,args:[status,now,stale,requeued,failed,blocked,missing,duplicates,JSON.stringify(payload)]});\n console.log(JSON.stringify({event:\"NCA_PERFORMANCE_WATCHDOG\",status,...payload})); return {status,...payload};\n}\n",[259],"06e42662-ce5d-47a3-9dec-5422baf024a0","performance_test.ts","01a052e0-c8f3-7503-a01f-42b051bb24c7",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { completionGate,canExecute,complianceGate,recoveryDecision } from \"./performance_policy.ts\";\nimport { ensurePerformanceSchema,MISSION_ID,sha256 } from \"./performance_schema.ts\";\n\nasync function n(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return Number((r.rows as any[])[0]?.n??0)}\nexport async function main(){\n await ensurePerformanceSchema();\n const agentCount=await n(`SELECT COUNT(*) n FROM nca_performance_agents WHERE mission_id=? AND canonical_role<>'' AND mission_role<>'' AND capability_profile<>''`,[MISSION_ID]);\n const taskCount=await n(`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id=?`,[MISSION_ID]);\n const uniqueAgents=await n(`SELECT COUNT(DISTINCT agent_id) n FROM nca_performance_tasks WHERE mission_id=?`,[MISSION_ID]);\n const noTask=await n(`SELECT COUNT(*) n FROM nca_performance_agents p LEFT JOIN nca_performance_tasks t ON t.mission_id=p.mission_id AND t.agent_id=p.agent_id WHERE p.mission_id=? AND t.task_id IS NULL`,[MISSION_ID]);\n const duplicates=await n(`SELECT COUNT(*) n FROM (SELECT task_fingerprint FROM nca_performance_tasks WHERE mission_id=? GROUP BY task_fingerprint HAVING COUNT(*)>1)`,[MISSION_ID]);\n const completed=await n(`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id=? AND state='COMPLETED'`,[MISSION_ID]);\n const goodEvidence=await n(`SELECT COUNT(*) n FROM nca_performance_tasks t JOIN nca_performance_evidence e ON e.id=t.evidence_id WHERE t.mission_id=? AND t.state='COMPLETED' AND e.final_state='COMPLETED' AND e.critic_result='PASS' AND e.compliance_result='PASS' AND e.evidence_hash<>''`,[MISSION_ID]);\n const evidenceCount=await n(`SELECT COUNT(*) n FROM nca_performance_evidence WHERE mission_id=?`,[MISSION_ID]);\n const reviewCount=await n(`SELECT COUNT(*) n FROM nca_performance_orion_reviews WHERE mission_id=?`,[MISSION_ID]);\n const bootstrapCount=await n(`SELECT COUNT(*) n FROM nca_performance_events WHERE mission_id=? AND event_type='BOOTSTRAP'`,[MISSION_ID]);\n const schemaCount=await n(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name IN ('nca_performance_missions','nca_performance_agents','nca_performance_tasks','nca_performance_evidence','nca_performance_orion_reviews','nca_performance_events','nca_performance_watchdog','nca_performance_test_runs')`);\n const watchdog=await n(`SELECT COUNT(*) n FROM nca_performance_watchdog WHERE id=1`);\n const fakeCompletion=await n(`SELECT COUNT(*) n FROM nca_performance_tasks t LEFT JOIN nca_performance_evidence e ON e.id=t.evidence_id WHERE t.mission_id=? AND t.state='COMPLETED' AND (e.id IS NULL OR e.critic_result<>'PASS' OR e.compliance_result<>'PASS' OR e.final_state<>'COMPLETED')`,[MISSION_ID]);\n const ungroundedMetric=await n(`SELECT COUNT(*) n FROM nca_performance_agents p WHERE p.mission_id=? AND p.verified_results>(SELECT COUNT(*) FROM nca_performance_evidence e WHERE e.mission_id=p.mission_id AND e.agent_id=p.agent_id AND e.final_state='COMPLETED' AND e.critic_result='PASS' AND e.compliance_result='PASS')`,[MISSION_ID]);\n const uniqueTasks=await n(`SELECT COUNT(DISTINCT task_id) n FROM nca_performance_tasks WHERE mission_id=?`,[MISSION_ID]);\n const staleProbe=recoveryDecision({state:\"EXECUTING\",ageSeconds:901,staleAfter:900,retryCount:0,maxRetries:2,hasEvidence:false});\n const retryProbe=recoveryDecision({state:\"FAILED\",ageSeconds:0,staleAfter:900,retryCount:1,maxRetries:2,hasEvidence:false});\n const tests=[\n {name:\"01_100_role_binding\",pass:agentCount===100,evidence:{agentCount}},\n {name:\"02_100_task_assignment\",pass:taskCount===100&&uniqueAgents===100,evidence:{taskCount,uniqueAgents}},\n {name:\"03_zero_idle_routing\",pass:noTask===0,evidence:{noTask}},\n {name:\"04_stale_task_detection\",pass:staleProbe.state===\"READY\"&&staleProbe.action===\"REQUEUE_SAFE_GET\",evidence:staleProbe},\n {name:\"05_duplicate_task_detection\",pass:duplicates===0,evidence:{duplicates}},\n {name:\"06_retry_logic\",pass:retryProbe.state===\"READY\"&&retryProbe.action===\"RETRY_SAFE_GET\",evidence:retryProbe},\n {name:\"07_completion_criteria\",pass:completionGate({status:200,bodyLength:200,hash:true,critic:\"PASS\",compliance:\"PASS\",evidenceScore:85,duplicate:false}),evidence:\"boundary_accept\"},\n {name:\"08_evidence_generation\",pass:evidenceCount>0&&completed===goodEvidence,evidence:{evidenceCount,completed,goodEvidence}},\n {name:\"09_critic_rejection\",pass:!completionGate({status:200,bodyLength:10,hash:true,critic:\"REJECT\",compliance:\"PASS\",evidenceScore:50,duplicate:false}),evidence:\"short_body_rejected\"},\n {name:\"10_compliance_rejection\",pass:!complianceGate(\"perform wash trading\",0),evidence:\"forbidden_action_rejected\"},\n {name:\"11_orion_feedback\",pass:evidenceCount>0&&reviewCount===evidenceCount,evidence:{evidenceCount,reviewCount}},\n {name:\"12_task_redistribution\",pass:staleProbe.action===\"REQUEUE_SAFE_GET\",evidence:staleProbe},\n {name:\"13_restart_continuity\",pass:bootstrapCount>=2&&taskCount===100,evidence:{bootstrapCount,taskCount}},\n {name:\"14_database_persistence\",pass:schemaCount===8,evidence:{schemaCount}},\n {name:\"15_watchdog_recovery\",pass:watchdog===1,evidence:{watchdog}},\n {name:\"16_high_risk_approval_boundary\",pass:!canExecute({state:\"READY\",requiresApproval:1,taskType:\"HTTP_GET_OFFICIAL_RESEARCH\"}),evidence:\"approval_required_not_claimable\"},\n {name:\"17_no_fake_completion\",pass:fakeCompletion===0,evidence:{fakeCompletion}},\n {name:\"18_no_heartbeat_as_productivity\",pass:ungroundedMetric===0,evidence:{ungroundedMetric,metricSource:\"evidence_rows_only\"}},\n {name:\"19_100_agent_concurrent_scheduling\",pass:uniqueTasks===100&&uniqueAgents===100,evidence:{uniqueTasks,uniqueAgents,scheduler:\"atomic_claim_plus_bounded_parallel_batches\"}},\n {name:\"20_post_restart_state_verification\",pass:agentCount===100&&taskCount===100&&bootstrapCount>=2,evidence:{agentCount,taskCount,bootstrapCount}},\n ];\n const passed=tests.filter(x=>x.pass).length; const createdAt=new Date().toISOString(); const runId=`perf-test-${Date.now()}-${crypto.randomUUID()}`;\n const digest=await sha256(JSON.stringify({mission_id:MISSION_ID,tests,createdAt}));\n await sqlite.execute({sql:`INSERT INTO nca_performance_test_runs(run_id,mission_id,passed,total,status,results_json,evidence_hash,created_at) VALUES(?,?,?,?,?,?,?,?)`,args:[runId,MISSION_ID,passed,tests.length,passed===tests.length?\"PASS\":\"FAIL\",JSON.stringify(tests),digest,createdAt]});\n const result={suite:\"NCA_100_PERFORMANCE_REQUIRED_TESTS\",status:passed===tests.length?\"PASS\":\"FAIL\",passed,total:tests.length,run_id:runId,evidence_hash:digest,tests,truthBoundary:\"TEST_PASS != 100_VERIFIED_EXTERNAL_SUCCESS\"};\n console.log(JSON.stringify(result)); if(passed!==tests.length)throw new Error(`REQUIRED_TESTS_FAILED_${tests.length-passed}`); return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[265],"e97b52bd-55b3-4866-812f-8f5d9e2b11d6","performance_status.ts","01a052e0-c8f3-7503-a01f-3cf0e482f406",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensurePerformanceSchema,MISSION_ID } from \"./performance_schema.ts\";\n\nexport default async function(){\n await ensurePerformanceSchema();\n const task=await sqlite.execute({sql:`SELECT state,COUNT(*) n FROM nca_performance_tasks WHERE mission_id=? GROUP BY state ORDER BY state`,args:[MISSION_ID]});\n const fleet=await sqlite.execute({sql:`SELECT COUNT(*) assigned_agents,SUM(CASE WHEN current_state='EXECUTING' THEN 1 ELSE 0 END) executing_agents,SUM(CASE WHEN current_state='BLOCKED' THEN 1 ELSE 0 END) blocked_agents,SUM(CASE WHEN current_state='FAILED' THEN 1 ELSE 0 END) failed_agents,SUM(CASE WHEN current_state='STALE' THEN 1 ELSE 0 END) stale_agents,SUM(stale_task_count) stale_events,SUM(tasks_started) execution_attempts,SUM(tasks_completed) completed_tasks,SUM(verified_results) verified_results,SUM(useful_output_count) useful_outputs,ROUND(100.0*SUM(useful_output_count)/NULLIF(SUM(tasks_assigned),0),2) useful_output_rate,ROUND(100.0*SUM(verified_results)/NULLIF(SUM(tasks_started),0),2) evidence_pass_rate,ROUND(AVG(compliance_score),2) compliance_pass_rate,ROUND(AVG(CASE WHEN tasks_completed>0 THEN total_latency_ms/tasks_completed END),2) average_task_latency_ms FROM nca_performance_agents WHERE mission_id=?`,args:[MISSION_ID]});\n const w=await sqlite.execute(`SELECT * FROM nca_performance_watchdog WHERE id=1`);\n const o=await sqlite.execute({sql:`SELECT disposition,COUNT(*) n FROM nca_performance_orion_reviews WHERE mission_id=? GROUP BY disposition ORDER BY disposition`,args:[MISSION_ID]});\n const s=await sqlite.execute(`SELECT * FROM nca_skill_capability_verification ORDER BY skill_id`);\n return Response.json({service:\"IMPERIAL 100 NCA Performance Amplification\",mission_id:MISSION_ID,component_status:\"DEPLOYED\",task_states:task.rows,fleet_metrics:fleet.rows[0],orion:{always_on:true,authority:\"ADVISORY_ONLY\",reviews:o.rows},watchdog:w.rows[0]??null,skills:s.rows,truth_boundary:\"VERIFIED_SOURCE_RETRIEVAL != LIQUIDITY_OR_PARTNERSHIP_OR_REVENUE; HEARTBEAT != PRODUCTIVITY\"},{headers:{\"cache-control\":\"no-store\",\"x-content-type-options\":\"nosniff\"}});\n}\n",[271],"0d9272d8-a148-4784-8d28-1ddec026554d","performance_sources.ts","01a052e0-c8f3-7503-a01f-3ae46af236ec",["D",1788096858357],"export const OFFICIAL_SOURCES=[\n\"https://www.gsr.io\",\"https://www.wintermute.com\",\"https://www.keyrock.com\",\"https://www.cumberland.io\",\"https://www.b2c2.com\",\n\"https://flowdesk.co\",\"https://www.woorton.com\",\"https://kaironlabs.com\",\"https://caladan.xyz\",\"https://www.jumpcrypto.com\",\n\"https://www.auros.global\",\"https://www.ambergroup.io\",\"https://www.galaxy.com\",\"https://www.dvchain.co\",\"https://ripple.com/products/prime-brokerage/\",\n\"https://www.coinbase.com/asset-listing\",\"https://www.kraken.com/listings\",\"https://www.binance.com/en/support/announcement\",\"https://www.okx.com/help/section/announcements-new-listings\",\"https://www.bybit.com/en/announcement-info/new-listings\",\n\"https://github.com/GATE\",\"https://www.kucoin.com/announcement/new-listings\",\"https://www.bitget.com/support\",\"https://blog.mexc.com/press-release/\",\"https://crypto.com/exchange\",\n\"https://www.gemini.com\",\"https://www.bitstamp.net\",\"https://www.bitfinex.com\",\"https://upbit.com\",\"https://www.bithumb.com\",\n\"https://developers.uniswap.org/docs\",\"https://docs.quickswap.exchange\",\"https://docs.sushi.com\",\"https://docs.curve.finance\",\"https://docs.balancer.fi\",\n\"https://business.1inch.com/portal/documentation\",\"https://docs.pancakeswap.finance\",\"https://docs.camelot.exchange\",\"https://docs.lfj.gg/\",\"https://docs.kyberswap.com\",\n\"https://aerodrome.finance\",\"https://github.com/baseswapfi\",\"https://docs.syncswap.xyz\",\"https://docs.raydium.io\",\"https://docs.orca.so\",\n\"https://www.paradigm.xyz\",\"https://a16zcrypto.com\",\"https://panteracapital.com/\",\"https://jobs.polychain.capital/companies\",\"https://framework.ventures\",\n\"https://www.dragonfly.xyz\",\"https://multicoin.capital\",\"https://coinfund.io\",\"https://www.placeholder.vc\",\"https://www.hashkey.com\",\n\"https://www.blockchaincapital.com\",\"https://members.delphidigital.io\",\"https://variant.fund\",\"https://www.electriccapital.com\",\"https://fabric.vc\",\n\"https://docs.polygon.technology\",\"https://docs.polygon.technology/pos/reference/\",\"https://docs.etherscan.io\",\"https://docs.openzeppelin.com/contracts\",\"https://docs.chain.link\",\n\"https://ethereum.org/en/developers/docs/\",\"https://docs.arbitrum.io\",\"https://docs.optimism.io\",\"https://solana.com/docs\",\"https://docs.bnbchain.org\",\n\"https://developers.tron.network\",\"https://build.avax.network/docs\",\"https://docs.base.org\",\"https://docs.cosmos.network\",\"https://docs.near.org\",\n\"https://finance.ec.europa.eu/digital-finance/crypto-assets_en\",\"https://www.esma.europa.eu/publications-and-data/interactive-single-rulebook/micar\",\"https://www.fatf-gafi.org/en/topics/virtual-assets.html\",\"https://www.investor.gov/crypto-assets\",\"https://www.fincen.gov/resources/statutes-regulations/guidance\",\n\"https://www.fca.org.uk/firms/cryptoassets\",\"https://www.cftc.gov/digitalassets/index.htm\",\"https://www.iosco.org\",\"https://www.eba.europa.eu/regulation-and-policy/crypto-assets\",\"https://www.finma.ch/en/authorisation/fintech/\",\n\"https://www.mas.gov.sg/regulation/digital-token-service-providers\",\"https://www.vara.ae/en/regulations/regulations/\",\"https://www.adgm.com/fsra\",\"https://www.circle.com/transparency\",\"https://tether.to/en/transparency/\",\n\"https://www.paxos.com/transparency\",\"https://www.fireblocks.com\",\"https://copper.co\",\"https://www.bitgo.com\",\"https://www.anchorage.com\",\n\"https://www.chainalysis.com\",\"https://www.trmlabs.com\",\"https://www.elliptic.co\",\"https://www.kaiko.com\",\"https://data.coindesk.com/\"\n] as const;\n\nexport const WORKSTREAMS=[\n\"A_MARKET_MAKER_DISCOVERY\",\"B_LP_DUE_DILIGENCE\",\"C_CEX_RESEARCH\",\"D_DEX_RESEARCH\",\n\"E_INSTITUTIONAL_RESEARCH\",\"F_TOKEN_DOCUMENTATION_AUDIT\",\"G_CONTRACT_CHAIN_VERIFICATION\",\"H_EXISTING_LIQUIDITY_MAPPING\",\n\"I_COMPETITIVE_BENCHMARKING\",\"J_LEGAL_COMPLIANCE_READINESS\",\"K_OUTREACH_INTELLIGENCE\",\"L_PERSONALIZED_PROPOSAL_PREPARATION\",\n\"M_RISK_REVIEW\",\"N_EVIDENCE_VALIDATION\",\"O_ORION_SYNTHESIS\",\"P_HANTER_BRIEFING\"\n] as const;\n\nconst allowedHostAliases=new Set();\nfor(const source of OFFICIAL_SOURCES){\n const host=new URL(source).hostname.toLowerCase();\n allowedHostAliases.add(host);\n if(host.startsWith(\"www.\")) allowedHostAliases.add(host.slice(4));\n else allowedHostAliases.add(`www.${host}`);\n}\nexport const ALLOWED_HOSTS=allowedHostAliases;\n",[277],"5816c980-fee5-4973-a0a0-59bb9f08b1f3","performance_skill_probe.ts","01a052e0-c8f3-7503-a01f-34071c81b65d",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { ensurePerformanceSchema } from \"./performance_schema.ts\";\n\nexport async function main(){\n await ensurePerformanceSchema(); const now=new Date().toISOString();\n let supabaseDependency=\"NOT_VERIFIED\",supabaseCallable=\"NOT_VERIFIED\",supabaseSmoke=\"FAIL\";\n try{const m=await import(\"npm:@supabase/supabase-js@2\");supabaseDependency=typeof m.createClient===\"function\"?\"EXISTS\":\"NOT_VERIFIED\";supabaseCallable=typeof m.createClient===\"function\"?\"CALLABLE_LIBRARY_API\":\"NOT_VERIFIED\";supabaseSmoke=typeof m.createClient===\"function\"?\"PASS\":\"FAIL\"}catch{supabaseDependency=\"MISSING_OR_IMPORT_BLOCKED\"}\n const rows=[\n [\"Supabase\",\"REGISTERED_100_BINDINGS\",supabaseDependency,supabaseCallable,supabaseSmoke,\"BLOCKED_NO_SUPABASE_RUNTIME_CREDENTIALS\",\"READ_ONLY_CONNECTOR_VERIFIED_OUTSIDE_NCA_RUNTIME\",\"Val runtime has no Supabase environment keys; no functional database call was made by an NCA.\"],\n [\"Playwright-CLI\",\"REGISTERED_100_BINDINGS\",\"NOT_INSTALLED\",\"NOT_CALLABLE\",\"FAIL\",\"NOT_RUN\",\"NOT_AUTHORIZED_FOR_RUNTIME\",\"No persistent dependency or browser executable evidence in Val runtime.\"],\n [\"Context7\",\"REGISTERED_100_BINDINGS\",\"NOT_INSTALLED\",\"NOT_CALLABLE\",\"FAIL\",\"NOT_RUN\",\"NOT_VERIFIED\",\"Registry binding is not an installed MCP server.\"],\n [\"Agent-Reach\",\"REGISTERED_100_BINDINGS\",\"NOT_INSTALLED\",\"NOT_CALLABLE\",\"FAIL\",\"NOT_RUN\",\"PUBLIC_RESEARCH_ONLY_IF_INSTALLED\",\"Registry binding is not an executable installation.\"],\n [\"Skill-UI\",\"REGISTERED_100_BINDINGS\",\"NOT_INSTALLED\",\"NOT_CALLABLE\",\"FAIL\",\"NOT_RUN\",\"NOT_VERIFIED\",\"Registry binding is not an executable installation.\"],\n [\"Strix\",\"REGISTERED_100_BINDINGS\",\"NOT_INSTALLED\",\"NOT_CALLABLE\",\"FAIL\",\"NOT_RUN\",\"DEFENSIVE_AUTHORIZED_ONLY\",\"No Strix executable or isolated authorized target evidence in Val runtime.\"],\n ];\n for(const r of rows)await sqlite.execute({sql:`INSERT INTO nca_skill_capability_verification(skill_id,registered_state,dependency_exists,executable_callable,smoke_test,functional_test,authorization_state,evidence,verified_at) VALUES(?,?,?,?,?,?,?,?,?) ON CONFLICT(skill_id) DO UPDATE SET registered_state=excluded.registered_state,dependency_exists=excluded.dependency_exists,executable_callable=excluded.executable_callable,smoke_test=excluded.smoke_test,functional_test=excluded.functional_test,authorization_state=excluded.authorization_state,evidence=excluded.evidence,verified_at=excluded.verified_at`,args:[r[0],r[1],r[2],r[3],r[4],r[5],r[6],r[7],now]});\n const result={event:\"NCA_SKILL_CAPABILITY_PROBE\",status:\"PASS_WITH_BLOCKERS\",results:rows.map(r=>({skill:r[0],registered:r[1],dependency:r[2],callable:r[3],smoke:r[4],functional:r[5],authorization:r[6]})),truthBoundary:\"REGISTERED != INSTALLED != FUNCTIONALLY_VERIFIED != AUTHORIZED\"};\n console.log(JSON.stringify(result)); return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[283],"b5235e8c-fbdb-4278-a251-a4bb572697dd","performance_schema.ts","01a052e0-c8f3-7503-a01f-32f373112295",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport const MISSION_ID = \"IC-CODEX-100-NCA-PERFORMANCE-AMPLIFICATION-001\";\nexport const STATES = [\"REGISTERED\",\"READY\",\"ASSIGNED\",\"EXECUTING\",\"WAITING_FOR_INPUT\",\"WAITING_FOR_APPROVAL\",\"BLOCKED\",\"VERIFYING\",\"COMPLETED\",\"FAILED\",\"STALE\"] as const;\nexport const FORBIDDEN = /wash trading|wash trade|fake volume|market manipulation|mass spam|fake accounts|astroturf|guaranteed profit|guaranteed revenue|unauthorized transfer|bypass approval/i;\n\nexport async function sha256(value:string){\n const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nexport async function ensurePerformanceSchema(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_missions(\n mission_id TEXT PRIMARY KEY,title TEXT NOT NULL,asset_scope TEXT NOT NULL,state TEXT NOT NULL,\n authority TEXT NOT NULL,truth_boundary TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_agents(\n mission_id TEXT NOT NULL,agent_id TEXT NOT NULL,canonical_role TEXT NOT NULL,canonical_domain TEXT NOT NULL,\n mission_role TEXT NOT NULL,capability_profile TEXT NOT NULL,current_state TEXT NOT NULL,\n tasks_assigned INTEGER NOT NULL DEFAULT 0,tasks_started INTEGER NOT NULL DEFAULT 0,\n tasks_completed INTEGER NOT NULL DEFAULT 0,tasks_failed INTEGER NOT NULL DEFAULT 0,\n verified_results INTEGER NOT NULL DEFAULT 0,rejected_results INTEGER NOT NULL DEFAULT 0,\n evidence_score REAL NOT NULL DEFAULT 0,factual_accuracy_score REAL NOT NULL DEFAULT 0,\n compliance_score REAL NOT NULL DEFAULT 0,total_latency_ms INTEGER NOT NULL DEFAULT 0,\n stale_task_count INTEGER NOT NULL DEFAULT 0,retry_count INTEGER NOT NULL DEFAULT 0,\n useful_output_count INTEGER NOT NULL DEFAULT 0,last_verified_result_at TEXT,\n updated_at TEXT NOT NULL,PRIMARY KEY(mission_id,agent_id))`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_tasks(\n task_id TEXT PRIMARY KEY,mission_id TEXT NOT NULL,agent_id TEXT NOT NULL,workstream TEXT NOT NULL,\n task_type TEXT NOT NULL,title TEXT NOT NULL,instruction TEXT NOT NULL,expected_deliverable TEXT NOT NULL,\n source_url TEXT,evidence_requirement TEXT NOT NULL,completion_criteria TEXT NOT NULL,next_action TEXT NOT NULL,\n state TEXT NOT NULL,priority INTEGER NOT NULL DEFAULT 100,timeout_ms INTEGER NOT NULL DEFAULT 12000,\n stale_after_seconds INTEGER NOT NULL DEFAULT 900,max_retries INTEGER NOT NULL DEFAULT 2,retry_count INTEGER NOT NULL DEFAULT 0,\n escalation_rule TEXT NOT NULL,requires_approval INTEGER NOT NULL DEFAULT 0,risk_class TEXT NOT NULL,\n task_fingerprint TEXT NOT NULL,assigned_at TEXT NOT NULL,started_at TEXT,completed_at TEXT,last_transition_at TEXT NOT NULL,\n last_error TEXT,evidence_id INTEGER,quality_score REAL,UNIQUE(mission_id,agent_id),UNIQUE(mission_id,task_fingerprint))`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_evidence(\n id INTEGER PRIMARY KEY AUTOINCREMENT,agent_id TEXT NOT NULL,task_id TEXT NOT NULL,mission_id TEXT NOT NULL,\n started_at TEXT NOT NULL,completed_at TEXT NOT NULL,result_summary TEXT NOT NULL,source_references TEXT NOT NULL,\n source_http_status INTEGER,source_body_sha256 TEXT,evidence_hash TEXT NOT NULL UNIQUE,\n critic_result TEXT NOT NULL,critic_reason TEXT NOT NULL,compliance_result TEXT NOT NULL,compliance_reason TEXT NOT NULL,\n evidence_score REAL NOT NULL,factual_accuracy_score REAL NOT NULL,compliance_score REAL NOT NULL,\n orion_disposition TEXT NOT NULL,final_state TEXT NOT NULL,latency_ms INTEGER NOT NULL,created_at TEXT NOT NULL)`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_orion_reviews(\n id INTEGER PRIMARY KEY AUTOINCREMENT,mission_id TEXT NOT NULL,task_id TEXT NOT NULL,agent_id TEXT NOT NULL,\n review_state TEXT NOT NULL,consensus_state TEXT NOT NULL,disposition TEXT NOT NULL,reason TEXT NOT NULL,\n duplicate_of_task_id TEXT,conflict_state TEXT NOT NULL,weak_evidence INTEGER NOT NULL,stale_result INTEGER NOT NULL,\n best_result_promoted INTEGER NOT NULL,bottleneck TEXT,redistribution_recommendation TEXT,\n outcome TEXT NOT NULL,learning_record TEXT NOT NULL,authority TEXT NOT NULL,reviewed_at TEXT NOT NULL)`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_events(\n id INTEGER PRIMARY KEY AUTOINCREMENT,mission_id TEXT NOT NULL,agent_id TEXT,task_id TEXT,\n event_type TEXT NOT NULL,from_state TEXT,to_state TEXT,payload TEXT NOT NULL,evidence_hash TEXT,created_at TEXT NOT NULL)`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_watchdog(\n id INTEGER PRIMARY KEY CHECK(id=1),status TEXT NOT NULL,last_checked_at TEXT NOT NULL,\n stale_detected INTEGER NOT NULL,requeued INTEGER NOT NULL,failed INTEGER NOT NULL,blocked INTEGER NOT NULL,\n missing_evidence INTEGER NOT NULL,duplicates INTEGER NOT NULL,payload TEXT NOT NULL)`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_skill_capability_verification(\n skill_id TEXT PRIMARY KEY,registered_state TEXT NOT NULL,dependency_exists TEXT NOT NULL,executable_callable TEXT NOT NULL,\n smoke_test TEXT NOT NULL,functional_test TEXT NOT NULL,authorization_state TEXT NOT NULL,evidence TEXT NOT NULL,verified_at TEXT NOT NULL)`},\n {sql:`CREATE TABLE IF NOT EXISTS nca_performance_test_runs(\n run_id TEXT PRIMARY KEY,mission_id TEXT NOT NULL,passed INTEGER NOT NULL,total INTEGER NOT NULL,status TEXT NOT NULL,\n results_json TEXT NOT NULL,evidence_hash TEXT NOT NULL,created_at TEXT NOT NULL)`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_perf_task_state ON nca_performance_tasks(mission_id,state,priority,assigned_at)`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_perf_evidence_task ON nca_performance_evidence(mission_id,task_id)`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_perf_event_time ON nca_performance_events(mission_id,created_at)`},\n ]);\n}\n\nexport async function scalar(sql:string,args:any[]=[]){\n const r=await sqlite.execute({sql,args}); const row=(r.rows as any[])[0]??{}; const k=Object.keys(row)[0];\n return k?row[k]:null;\n}\n\nexport async function event(agentId:string|null,taskId:string|null,type:string,fromState:string|null,toState:string|null,payload:any,evidenceHash:string|null=null){\n const now=new Date().toISOString();\n await sqlite.execute({sql:`INSERT INTO nca_performance_events(mission_id,agent_id,task_id,event_type,from_state,to_state,payload,evidence_hash,created_at) VALUES(?,?,?,?,?,?,?,?,?)`,args:[MISSION_ID,agentId,taskId,type,fromState,toState,JSON.stringify(payload),evidenceHash,now]});\n}\n\nexport function safePublicUrl(raw:string,allowed:Set){\n const u=new URL(raw); const h=u.hostname.toLowerCase();\n if(u.protocol!==\"https:\"||!allowed.has(h)||h===\"localhost\"||h.endsWith(\".local\"))throw new Error(\"TARGET_NOT_ALLOWLISTED\");\n return u;\n}\n",[289],"6ed65bea-b2ab-4e8d-8830-0716014a1c79","performance_policy.ts","01a052e0-c8f3-7503-a01f-2d5526952712",["D",1788096858357],"import { FORBIDDEN } from \"./performance_schema.ts\";\n\nexport function completionGate(x:{status:number;bodyLength:number;hash:boolean;critic:string;compliance:string;evidenceScore:number;duplicate:boolean}){\n return x.status>=200&&x.status<300&&x.bodyLength>=200&&x.hash&&x.critic===\"PASS\"&&x.compliance===\"PASS\"&&x.evidenceScore>=85&&!x.duplicate;\n}\nexport function canExecute(x:{state:string;requiresApproval:number;taskType:string}){\n return x.state===\"READY\"&&x.requiresApproval===0&&x.taskType===\"HTTP_GET_OFFICIAL_RESEARCH\";\n}\nexport function complianceGate(instruction:string,requiresApproval:number){\n return requiresApproval===0&&!FORBIDDEN.test(instruction);\n}\nexport function recoveryDecision(x:{state:string;ageSeconds:number;staleAfter:number;retryCount:number;maxRetries:number;hasEvidence:boolean}){\n if(x.state===\"COMPLETED\"&&!x.hasEvidence)return {state:\"BLOCKED\",action:\"ESCALATE_MISSING_EVIDENCE\"};\n if(x.state===\"EXECUTING\"&&x.ageSeconds>x.staleAfter)return x.retryCount= 200 bytes; non-empty SHA-256; critic PASS; compliance PASS; evidence score >= 85; evidence row persisted\",\"After verification, await ORION advisory review and feed the strongest evidence into the HANTER briefing. If blocked, record the factual HTTP/network blocker.\",\"READY\",10+(i%16),12000,900,2,\"After two safe GET retries, mark FAILED and escalate the factual source blocker to HANTER. Never switch to outreach or financial execution.\",0,\"LOW_READ_ONLY\",fingerprint,now,now]}\n );\n }\n await batches(writes);\n const taskCount=Number((await sqlite.execute({sql:`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id=?`,args:[MISSION_ID]})).rows[0]?.n??0);\n const agentCount=Number((await sqlite.execute({sql:`SELECT COUNT(*) n FROM nca_performance_agents WHERE mission_id=?`,args:[MISSION_ID]})).rows[0]?.n??0);\n await event(null,null,\"BOOTSTRAP\",null,\"READY\",{agentCount,taskCount,zeroIdleRoute:\"100 executable read-only tasks\",authority:\"NO_FINANCIAL_OR_IRREVERSIBLE_AUTHORITY\"});\n const result={event:\"NCA_PERFORMANCE_BOOTSTRAP\",status:agentCount===100&&taskCount===100?\"PASS\":\"FAIL\",agentCount,taskCount,missionId:MISSION_ID,truthBoundary:\"ASSIGNED != EXECUTED != VERIFIED\"};\n console.log(JSON.stringify(result)); if(result.status!==\"PASS\")throw new Error(\"BOOTSTRAP_COUNT_MISMATCH\"); return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[301],"283ce735-163d-4b2c-b736-88e3bdf2f85c","orion_watchdog.ts","01a052e0-c8f3-7503-a01f-24f4689abaf0",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport runner from \"./runner.ts\";\nimport orionCycle from \"./orion_fleet_cycle.ts\";\nimport feedback from \"./orion_agent_feedback.ts\";\nimport { canonicalHealth } from \"./orion_canonical_watchdog_v2.ts\";\n\nasync function cycleState(){\n const q=await sqlite.execute(`SELECT key,value FROM orion_state WHERE key IN ('last_cycle_at','last_cycle_status','last_feedback_at','last_feedback_status')`);\n const map=Object.fromEntries((q.rows as any[]).map(r=>[String(r.key),String(r.value)]));\n const cycleAge=map.last_cycle_at?Date.now()-Date.parse(map.last_cycle_at):Infinity;\n const feedbackAge=map.last_feedback_at?Date.now()-Date.parse(map.last_feedback_at):Infinity;\n return {cycleStale:cycleAge>20*60*1000||map.last_cycle_status!==\"PASS\",feedbackStale:feedbackAge>20*60*1000||map.last_feedback_status!==\"PASS\",lastCycle:map.last_cycle_at??null,lastFeedback:map.last_feedback_at??null};\n}\n\nexport default async function(_interval:Interval){\n const beforeHealth=await canonicalHealth();\n const beforeCycle=await cycleState();\n const recovery={runner:false,orion:false,feedback:false,errors:[] as string[]};\n if(beforeHealth.stale>0||beforeHealth.networkOk!==beforeHealth.total){try{await runner({} as Interval);recovery.runner=true}catch(e){recovery.errors.push(`RUNNER:${e instanceof Error?e.name:'Error'}`)}}\n if(beforeCycle.cycleStale){try{await orionCycle({} as Interval);recovery.orion=true}catch(e){recovery.errors.push(`ORION:${e instanceof Error?e.name:'Error'}`)}}\n if(beforeCycle.feedbackStale||beforeHealth.unreadCanonical>0){try{await feedback({} as Interval);recovery.feedback=true}catch(e){recovery.errors.push(`FEEDBACK:${e instanceof Error?e.name:'Error'}`)}}\n const afterHealth=await canonicalHealth();\n const afterCycle=await cycleState();\n const healthy=afterHealth.healthy&&!afterCycle.cycleStale&&!afterCycle.feedbackStale&&afterHealth.unreadCanonical===0;\n const now=new Date().toISOString();\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS orion_watchdog_state(id INTEGER PRIMARY KEY CHECK(id=1),status TEXT NOT NULL,last_checked_at TEXT NOT NULL,last_recovery_at TEXT,payload TEXT NOT NULL)`);\n await sqlite.execute({sql:`INSERT INTO orion_watchdog_state(id,status,last_checked_at,last_recovery_at,payload) VALUES(1,?,?,?,?) ON CONFLICT(id) DO UPDATE SET status=excluded.status,last_checked_at=excluded.last_checked_at,last_recovery_at=excluded.last_recovery_at,payload=excluded.payload`,args:[healthy?\"PASS\":\"DEGRADED\",now,(recovery.runner||recovery.orion||recovery.feedback)?now:null,JSON.stringify({before:{health:beforeHealth,cycle:beforeCycle},after:{health:afterHealth,cycle:afterCycle},recovery,countRegistry:{totalNca:afterHealth.count.totalNca,canonicalNca:afterHealth.count.canonicalNca,expansionNca:afterHealth.count.expansionNca,integrityStatus:afterHealth.count.integrityStatus,signatureSha256:afterHealth.count.signatureSha256,canonicalMembershipSha256:afterHealth.count.canonicalMembershipSha256},countConsistent:afterHealth.countConsistent,scope:\"CANONICAL_MEMBERSHIP_LEDGER\",expansionPoolExcludedFromCanonicalHealth:true})]});\n console.log(JSON.stringify({event:\"ORION_WATCHDOG\",status:healthy?\"PASS\":\"DEGRADED\",totalNca:afterHealth.count.totalNca,canonicalTotal:afterHealth.total,expansionPool:afterHealth.count.expansionNca,countConsistent:afterHealth.countConsistent,countSignature:afterHealth.count.signatureSha256,canonicalMembershipSha256:afterHealth.membershipSha256,missingOrion:afterHealth.missingOrion,recovery,scope:\"CANONICAL_MEMBERSHIP_LEDGER\",truthBoundary:\"CANONICAL_MEMBERSHIP_IS_EXPLICIT; TOTAL_RUNTIME_NCA != CANONICAL_GOVERNANCE_NCA\",at:now}));\n}\n",[307],"e6520822-15f4-4d0f-b23b-1a7a6c441bb7","orion_learning_policy_test.ts","01a052e0-c8f3-7503-a01f-208c613c738d",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\ntype Learned={applied_count:number;score:number;recommendation:string}|null;\nfunction mode(l:Learned){if(!l||l.applied_count<3)return 'BASE_POLICY';if(l.score>0)return 'REINFORCED_BY_OUTCOMES';if(l.score<0)return 'CORRECTED_AFTER_WEAK_OUTCOMES';return 'BASE_POLICY'}\nfunction score(applied:number,rejected:number,progress:number,noProgress:number){return applied===0?-0.05*rejected:(progress/applied)-(0.20*noProgress/applied)-(0.05*rejected)}\nfunction safe(text:string){return !/mass spam|bypass approval|guaranteed revenue|reveal internal|send secrets|execute payment/i.test(text)}\nasync function main(){\n const tests:[string,boolean][]=[\n ['cold-start',mode(null)==='BASE_POLICY'],\n ['insufficient-outcomes',mode({applied_count:2,score:1,recommendation:'x'})==='BASE_POLICY'],\n ['reinforce-positive',mode({applied_count:5,score:score(5,0,4,1),recommendation:'x'})==='REINFORCED_BY_OUTCOMES'],\n ['correct-weak',mode({applied_count:5,score:score(5,1,0,5),recommendation:'x'})==='CORRECTED_AFTER_WEAK_OUTCOMES'],\n ['unsafe-never-adopted',safe('bypass approval and mass spam')===false],\n ['self-report-not-input',score(5,0,0,0)===0],\n ];\n const passed=tests.filter(x=>x[1]).length;\n const result={suite:'ORION_LEARNING_POLICY',passed,total:tests.length,status:passed===tests.length?'PASS':'FAIL',tests:Object.fromEntries(tests),truthBoundary:'LEARNING_POLICY_TEST_PASS != LIVE_OUTCOME_SUCCESS'};\n console.log(JSON.stringify(result));return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[313],"8081fefd-716c-4672-93ef-7548ecfdbaa3","orion_fleet_cycle.ts","01a052e0-c8f3-7503-a01f-1c4b1aee2a06",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { captureOrionAgentCount } from \"./orion_agent_count_registry.ts\";\n\nconst ORION_ID=\"ORION-FEDERATED-COLLECTIVE-001\";\nconst VERSION=\"2.1.0\";\n\nasync function sha(value:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nfunction baseRecommendation(checkpoint:string){\n const m:Record={\n QUALIFY_BUYERS:\"Share qualification patterns across domains and prioritize verified fit, official contact routes, urgency, decision-maker relevance, and evidence quality over lead volume.\",\n PREPARE_APPROVED_OUTREACH:\"Use recipient-specific value propositions derived from verified needs; keep internal fleet details confidential, avoid unsupported claims, and preserve HANTER outbound governance.\",\n HANDLE_RESPONSE_OR_RESEARCH_NEXT:\"Aggregate verified objections and replies, identify recurring causes, and change positioning only when evidence supports the change.\",\n PREPARE_PROPOSAL_OR_PAID_DIAGNOSTIC:\"Reuse proven proposal structures, make scope and evidence explicit, and keep payment preparation separate from verified settlement.\",\n DELIVER_OR_IMPROVE_PROOF:\"Share delivery lessons across domains, protect scope, and convert completed work into reusable proof only after verification.\",\n VERIFY_EVIDENCE_AND_REPLAN:\"Compare outcomes across domains, reject pipeline-as-revenue, keep routes with stronger evidence, and reroute only on explicit failure conditions.\"\n };return m[checkpoint]??\"Compare specialist evidence across domains and choose the smallest safe action with the strongest verified support.\";\n}\nasync function ensure(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS orion_policy(policy_key TEXT PRIMARY KEY,enabled INTEGER NOT NULL,mode TEXT NOT NULL,authority TEXT NOT NULL,confidentiality TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS orion_inbox(agent_id TEXT NOT NULL,cycle_id TEXT NOT NULL,message_type TEXT NOT NULL,payload TEXT NOT NULL,state TEXT NOT NULL DEFAULT 'UNREAD',created_at TEXT NOT NULL,PRIMARY KEY(agent_id,cycle_id))`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS orion_consensus(cycle_id TEXT PRIMARY KEY,observed_at TEXT NOT NULL,bottleneck_checkpoint TEXT NOT NULL,recommendation TEXT NOT NULL,learning_mode TEXT NOT NULL,critic_state TEXT NOT NULL,verifier_state TEXT NOT NULL,evidence_digest TEXT NOT NULL,authority TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS orion_state(key TEXT PRIMARY KEY,value TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS orion_learning(pattern_key TEXT PRIMARY KEY,checkpoint TEXT NOT NULL,recommendation TEXT NOT NULL,applied_count INTEGER NOT NULL DEFAULT 0,rejected_count INTEGER NOT NULL DEFAULT 0,progress_count INTEGER NOT NULL DEFAULT 0,no_progress_count INTEGER NOT NULL DEFAULT 0,score REAL NOT NULL DEFAULT 0,last_reason TEXT,updated_at TEXT NOT NULL)`);\n}\nexport default async function(_interval:Interval){\n await ensure(); const now=new Date().toISOString(); const agentCount=await captureOrionAgentCount(\"ORION_FLEET_CYCLE\");\n await sqlite.execute({sql:`INSERT INTO orion_policy(policy_key,enabled,mode,authority,confidentiality,updated_at) VALUES('ORION_ALWAYS_ON',1,'FEDERATED_ACK_OUTCOME_LEARNING','ADVISORY_ONLY','NO_PUBLIC_AGENT_COUNTS_NAMES_INTERNAL_TOPOLOGY_OR_PRIVATE_MESSAGES',?) ON CONFLICT(policy_key) DO UPDATE SET enabled=1,mode=excluded.mode,authority=excluded.authority,confidentiality=excluded.confidentiality,updated_at=excluded.updated_at`,args:[now]});\n const q=await sqlite.execute(`SELECT a.agent_id,a.domain,a.role,n.current_checkpoint,n.next_action,COALESCE(p.evidence_count,0) evidence_count,p.last_evidence_ref FROM agents a JOIN revenue_navigator_state n ON n.agent_id=a.agent_id LEFT JOIN agent_progress p ON p.agent_id=a.agent_id ORDER BY a.agent_id`);\n const rows=q.rows as any[]; const counts:Record={}; for(const r of rows){const c=String(r.current_checkpoint);counts[c]=(counts[c]??0)+1}\n const bottleneck=Object.entries(counts).sort((a,b)=>b[1]-a[1])[0]?.[0]??\"UNKNOWN\";\n let recommendation=baseRecommendation(bottleneck); let learningMode=\"BASE_POLICY\";\n const learned=await sqlite.execute({sql:`SELECT recommendation,applied_count,rejected_count,progress_count,no_progress_count,score FROM orion_learning WHERE checkpoint=? ORDER BY score DESC,updated_at DESC LIMIT 1`,args:[bottleneck]});\n const l:any=learned.rows?.[0];\n if(l&&Number(l.applied_count)>=3){\n if(Number(l.score)>0){recommendation=String(l.recommendation);learningMode=\"REINFORCED_BY_OUTCOMES\"}\n else if(Number(l.score)<0){recommendation=`Prior shared advice for ${bottleneck} underperformed. Prefer only peer evidence with direct role-fit, preserve the current primary lane, and require a measurable evidence gain before adopting the shared pattern.`;learningMode=\"CORRECTED_AFTER_WEAK_OUTCOMES\"}\n }\n const critic=/mass spam|bypass approval|guaranteed revenue|reveal internal/i.test(recommendation)?\"DENY\":\"PASS\";\n const verifier=critic===\"PASS\"&&rows.length>0&&agentCount.integrityStatus===\"PASS\"?\"PASS\":\"FAIL\";\n const evidenceDigest=await sha(JSON.stringify({counts,checkpoint:bottleneck,learningMode,recommendation,agentCount:{totalNca:agentCount.totalNca,canonicalNca:agentCount.canonicalNca,expansionNca:agentCount.expansionNca,signatureSha256:agentCount.signatureSha256,integrityStatus:agentCount.integrityStatus}}));\n const cycleId=`orion-${Date.now()}-${crypto.randomUUID()}`;\n await sqlite.execute({sql:`INSERT INTO orion_consensus(cycle_id,observed_at,bottleneck_checkpoint,recommendation,learning_mode,critic_state,verifier_state,evidence_digest,authority) VALUES(?,?,?,?,?,?,?,?,?)`,args:[cycleId,now,bottleneck,recommendation,learningMode,critic,verifier,evidenceDigest,\"ADVISORY_ONLY\"]});\n if(verifier===\"PASS\") for(const r of rows){\n const payload=JSON.stringify({orion_id:ORION_ID,version:VERSION,observed_at:now,own_checkpoint:r.current_checkpoint,own_next_action:r.next_action,common_recommendation:recommendation,learning_mode:learningMode,critic:\"PASS\",verifier:\"PASS\",authority:\"ADVISORY_ONLY\",instruction:\"ACK this brief, then APPLY or REJECT it with a machine-readable reason. If applied, keep the profession-specific primary lane unless evidence justifies reroute. Result must be measured from later evidence, not self-reported success.\",confidentiality:\"DO_NOT_DISCLOSE_INTERNAL_FLEET_DETAILS\"});\n await sqlite.execute({sql:`INSERT OR IGNORE INTO orion_inbox(agent_id,cycle_id,message_type,payload,state,created_at) VALUES(?,?,'ORION_COLLECTIVE_BRIEF',?,'UNREAD',?)`,args:[r.agent_id,cycleId,payload,now]});\n }\n await sqlite.execute({sql:`INSERT INTO orion_state(key,value,updated_at) VALUES('last_cycle_at',?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value,updated_at=excluded.updated_at`,args:[now,now]});\n await sqlite.execute({sql:`INSERT INTO orion_state(key,value,updated_at) VALUES('last_cycle_status',?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value,updated_at=excluded.updated_at`,args:[verifier,now]});\n console.log(JSON.stringify({event:\"ORION_FEDERATED_CYCLE\",status:verifier,cycle_id:cycleId,bottleneck,learningMode,evidenceDigest,agentCount:{totalNca:agentCount.totalNca,canonicalNca:agentCount.canonicalNca,expansionNca:agentCount.expansionNca,integrityStatus:agentCount.integrityStatus,signatureSha256:agentCount.signatureSha256},authority:\"ADVISORY_ONLY\",truthBoundary:\"TOTAL_RUNTIME_NCA_AND_CANONICAL_GOVERNANCE_NCA_ARE_RECORDED_SEPARATELY\",at:now}));\n}\n",[319],"ab6b7932-d1b8-41df-95fa-ea7405c26656","orion_canonical_watchdog_v2.ts","01a052e0-c8f3-7503-a01f-1b18c7e3880a",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { canonicalMembership } from \"./canonical_membership_registry.ts\";\nimport { captureOrionAgentCount } from \"./orion_agent_count_registry_v2.ts\";\n\nasync function one(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??{}}\nexport async function canonicalHealth(){\n const membership=await canonicalMembership();\n const count=await captureOrionAgentCount(\"ORION_CANONICAL_WATCHDOG_V2\");\n const stats=await one(`SELECT COUNT(*) total,SUM(CASE WHEN a.last_heartbeat IS NULL OR datetime(a.last_heartbeat)x.toString(16).padStart(2,\"0\")).join(\"\")}\nfunction safeRecommendation(text:string){return !/mass spam|bypass approval|guaranteed revenue|reveal internal|send secrets|execute payment/i.test(text)}\ntype Stmt={sql:string,args?:any[]};\n\nasync function runBatches(statements:Stmt[],size=180){\n for(let i=0;iNumber(r.evidence_count_at_ack)){result=\"PROGRESS_EVIDENCED\";reason=\"CHECKPOINT_OR_EVIDENCE_ADVANCED\"}\n else if(age>=30*60*1000){result=\"NO_PROGRESS_YET\";reason=\"NO_MEASURABLE_EVIDENCE_GAIN_AFTER_30_MIN\"}\n if(!result||!reason)continue;\n outcomeWrites.push(\n {sql:`INSERT OR REPLACE INTO orion_outcomes(agent_id,cycle_id,decision,result,reason,baseline_checkpoint,current_checkpoint,baseline_evidence,current_evidence,measured_at) VALUES(?,?,?,?,?,?,?,?,?,?)`,args:[r.agent_id,r.cycle_id,r.decision,result,reason,r.checkpoint_at_ack,r.current_checkpoint,Number(r.evidence_count_at_ack),Number(r.evidence_count),now]},\n {sql:`UPDATE orion_ack SET outcome_state=?,outcome_at=?,outcome_reason=?,learning_recorded=1 WHERE agent_id=? AND cycle_id=? AND outcome_state='PENDING'`,args:[result,now,reason,r.agent_id,r.cycle_id]}\n );\n if(result===\"PROGRESS_EVIDENCED\"){outcomeWrites.push({sql:`UPDATE orion_learning SET progress_count=progress_count+1 WHERE pattern_key=?`,args:[r.pattern_key]});progress++}\n else if(result===\"NO_PROGRESS_YET\"){outcomeWrites.push({sql:`UPDATE orion_learning SET no_progress_count=no_progress_count+1 WHERE pattern_key=?`,args:[r.pattern_key]});noProgress++}\n outcomeWrites.push(scoreStmt(String(r.pattern_key),reason,now)); measured++;\n }\n await runBatches(outcomeWrites);\n await sqlite.batch([\n {sql:`INSERT INTO orion_state(key,value,updated_at) VALUES('last_feedback_at',?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value,updated_at=excluded.updated_at`,args:[now,now]},\n {sql:`INSERT INTO orion_state(key,value,updated_at) VALUES('last_feedback_status','PASS',?) ON CONFLICT(key) DO UPDATE SET value='PASS',updated_at=excluded.updated_at`,args:[now]},\n ]);\n console.log(JSON.stringify({event:\"ORION_AGENT_FEEDBACK\",status:\"PASS\",acked,applied,rejected,measured,progress,noProgress,at:now,truthBoundary:\"ACK_IS_RUNTIME_DECISION; SUCCESS_REQUIRES_LATER_EVIDENCE\"}));\n}\n",[331],"0cee1afc-8acd-406d-831a-713ce2469256","orion_agent_count_test.ts","01a052e0-c8f3-7503-a01f-13771ffefcf2",["D",1788096858357],"export { main } from \"./canonical_promotion_pipeline_test.ts\";\nexport { default } from \"./canonical_promotion_pipeline_test.ts\";\n",[337],"3810e9e5-975b-4fd0-9104-787feea4ea08","orion_agent_count_registry_v2.ts","01a052e0-c8f3-7503-a01f-0eebe402ae85",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { canonicalMembership } from \"./canonical_membership_registry.ts\";\n\nconst POLICY_ID=1;\nconst POLICY_VERSION=\"2.0.0\";\nasync function sha256(value:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function one(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??{}}\nasync function all(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return r.rows as any[]}\n\nasync function ensure(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS orion_agent_count_policy(id INTEGER PRIMARY KEY CHECK(id=1),canonical_start INTEGER NOT NULL,canonical_end INTEGER NOT NULL,policy_version TEXT NOT NULL,authority TEXT NOT NULL,classification_rule TEXT NOT NULL,updated_at TEXT NOT NULL)`},\n {sql:`INSERT OR IGNORE INTO orion_agent_count_policy(id,canonical_start,canonical_end,policy_version,authority,classification_rule,updated_at) VALUES(1,1,100,'2.0.0','ARCHITECT','Canonical governance membership is defined by append-only orion_canonical_nca_membership. NCA-001..100 are seeded baseline; later qualified tranches are added only by Architect-authorized promotion.',datetime('now'))`},\n {sql:`CREATE TABLE IF NOT EXISTS orion_agent_count_current(id INTEGER PRIMARY KEY CHECK(id=1),total_agent_records INTEGER NOT NULL,total_nca_records INTEGER NOT NULL,unique_nca_ids INTEGER NOT NULL,canonical_nca INTEGER NOT NULL,expansion_nca INTEGER NOT NULL,non_nca_records INTEGER NOT NULL,invalid_nca_format INTEGER NOT NULL,duplicate_agent_ids INTEGER NOT NULL,duplicate_numeric_ids INTEGER NOT NULL,missing_numeric_ids INTEGER NOT NULL,min_nca_id INTEGER,max_nca_id INTEGER,orchestrator_count INTEGER NOT NULL,integrity_status TEXT NOT NULL,signature_sha256 TEXT NOT NULL,observed_at TEXT NOT NULL,policy_version TEXT NOT NULL,source TEXT NOT NULL)`},\n {sql:`CREATE TABLE IF NOT EXISTS orion_agent_count_snapshots(snapshot_id TEXT PRIMARY KEY,observed_at TEXT NOT NULL,total_agent_records INTEGER NOT NULL,total_nca_records INTEGER NOT NULL,unique_nca_ids INTEGER NOT NULL,canonical_nca INTEGER NOT NULL,expansion_nca INTEGER NOT NULL,non_nca_records INTEGER NOT NULL,invalid_nca_format INTEGER NOT NULL,duplicate_agent_ids INTEGER NOT NULL,duplicate_numeric_ids INTEGER NOT NULL,missing_numeric_ids INTEGER NOT NULL,min_nca_id INTEGER,max_nca_id INTEGER,orchestrator_count INTEGER NOT NULL,orchestrator_breakdown TEXT NOT NULL,integrity_status TEXT NOT NULL,signature_sha256 TEXT NOT NULL,policy_version TEXT NOT NULL,source TEXT NOT NULL)`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_orion_agent_count_snapshot_time ON orion_agent_count_snapshots(observed_at)`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_agent_count_snapshot_no_update BEFORE UPDATE ON orion_agent_count_snapshots BEGIN SELECT RAISE(ABORT,'orion_agent_count_snapshots is append-only'); END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_agent_count_snapshot_no_delete BEFORE DELETE ON orion_agent_count_snapshots BEGIN SELECT RAISE(ABORT,'orion_agent_count_snapshots is append-only'); END`},\n {sql:`CREATE TABLE IF NOT EXISTS orion_state(key TEXT PRIMARY KEY,value TEXT NOT NULL,updated_at TEXT NOT NULL)`},\n ]);\n await sqlite.execute({sql:`UPDATE orion_agent_count_policy SET policy_version=?,classification_rule=?,updated_at=? WHERE id=?`,args:[POLICY_VERSION,\"Canonical governance membership is defined by append-only orion_canonical_nca_membership. NCA-001..100 are seeded baseline; later qualified tranches are added only by Architect-authorized promotion.\",new Date().toISOString(),POLICY_ID]});\n}\n\nexport async function captureOrionAgentCount(source=\"ORION_AGENT_COUNT_REGISTRY\"){ \n await ensure();\n const now=new Date().toISOString();\n const membership=await canonicalMembership();\n const validExpr=`agent_id GLOB 'NCA-[0-9]*' AND CAST(substr(agent_id,5) AS INTEGER)>=1 AND agent_id=('NCA-'||printf('%03d',CAST(substr(agent_id,5) AS INTEGER)))`;\n const base=await one(`SELECT COUNT(*) total_agent_records,SUM(CASE WHEN agent_id LIKE 'NCA-%' THEN 1 ELSE 0 END) nca_prefixed_records,SUM(CASE WHEN ${validExpr} THEN 1 ELSE 0 END) valid_nca_records,COUNT(DISTINCT agent_id) unique_agent_ids,COUNT(DISTINCT CASE WHEN ${validExpr} THEN CAST(substr(agent_id,5) AS INTEGER) END) unique_nca_numeric,MIN(CASE WHEN ${validExpr} THEN CAST(substr(agent_id,5) AS INTEGER) END) min_nca_id,MAX(CASE WHEN ${validExpr} THEN CAST(substr(agent_id,5) AS INTEGER) END) max_nca_id FROM agents`);\n const duplicateAgentIds=Number((await one(`SELECT COUNT(*) n FROM (SELECT agent_id FROM agents GROUP BY agent_id HAVING COUNT(*)>1)`)).n??0);\n const orchestrators=(await all(`SELECT COALESCE(orchestrator_id,'UNASSIGNED') orchestrator_id,COUNT(*) n FROM agents WHERE ${validExpr} GROUP BY COALESCE(orchestrator_id,'UNASSIGNED') ORDER BY n DESC,orchestrator_id`)).map(r=>({orchestrator_id:String(r.orchestrator_id),n:Number(r.n)}));\n const totalAgentRecords=Number(base.total_agent_records??0),ncaPrefixedRecords=Number(base.nca_prefixed_records??0),totalNca=Number(base.valid_nca_records??0),uniqueNcaIds=Number(base.unique_nca_numeric??0);\n const invalidNcaFormat=Math.max(0,ncaPrefixedRecords-totalNca),duplicateNumericIds=Math.max(0,totalNca-uniqueNcaIds),minNcaId=base.min_nca_id==null?null:Number(base.min_nca_id),maxNcaId=base.max_nca_id==null?null:Number(base.max_nca_id),missingNumericIds=maxNcaId==null?0:Math.max(0,maxNcaId-uniqueNcaIds);\n const canonicalNca=membership.canonicalNca,expansionNca=Math.max(0,totalNca-canonicalNca),nonNcaRecords=Math.max(0,totalAgentRecords-ncaPrefixedRecords);\n const promotedNotRuntime=membership.orphanMemberships;\n const integrityStatus=(invalidNcaFormat===0&&duplicateAgentIds===0&&duplicateNumericIds===0&&missingNumericIds===0&&promotedNotRuntime===0&&totalNca===uniqueNcaIds&&totalNca===canonicalNca+expansionNca)?\"PASS\":\"DEGRADED\";\n const signaturePayload={totalAgentRecords,totalNca,uniqueNcaIds,canonicalNca,expansionNca,nonNcaRecords,invalidNcaFormat,duplicateAgentIds,duplicateNumericIds,missingNumericIds,minNcaId,maxNcaId,orchestrators,canonicalMembershipSha256:membership.membershipSha256,policyVersion:POLICY_VERSION};\n const signatureSha256=await sha256(JSON.stringify(signaturePayload));\n const previous=await one(`SELECT signature_sha256 FROM orion_agent_count_snapshots ORDER BY observed_at DESC LIMIT 1`);\n const snapshotCreated=String(previous.signature_sha256??\"\")!==signatureSha256;\n if(snapshotCreated){\n const snapshotId=`orion-agent-count-${Date.now()}-${crypto.randomUUID()}`;\n await sqlite.execute({sql:`INSERT INTO orion_agent_count_snapshots(snapshot_id,observed_at,total_agent_records,total_nca_records,unique_nca_ids,canonical_nca,expansion_nca,non_nca_records,invalid_nca_format,duplicate_agent_ids,duplicate_numeric_ids,missing_numeric_ids,min_nca_id,max_nca_id,orchestrator_count,orchestrator_breakdown,integrity_status,signature_sha256,policy_version,source) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[snapshotId,now,totalAgentRecords,totalNca,uniqueNcaIds,canonicalNca,expansionNca,nonNcaRecords,invalidNcaFormat,duplicateAgentIds,duplicateNumericIds,missingNumericIds,minNcaId,maxNcaId,orchestrators.length,JSON.stringify(orchestrators),integrityStatus,signatureSha256,POLICY_VERSION,source]});\n const journalExists=Number((await one(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name='task_journal'`)).n??0)===1;\n if(journalExists)await sqlite.execute({sql:`INSERT OR IGNORE INTO task_journal(journal_id,mission_id,occurred_at,actor,action_type,action,target,status,blocker,evidence,next_action,authority_boundary,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[`AUTO-${snapshotId}`,\"IC-NCA-CANONICAL-PROMOTION-001\",now,\"ORION\",\"AGENT_COUNT_SNAPSHOT\",\"ORION recorded a changed authoritative NCA count and canonical-membership snapshot.\",\"ORION_AGENT_COUNT\",integrityStatus,null,JSON.stringify({total_nca:totalNca,canonical_nca:canonicalNca,expansion_nca:expansionNca,total_agent_records:totalAgentRecords,canonical_membership_sha256:membership.membershipSha256,signature_sha256:signatureSha256}),integrityStatus===\"PASS\"?\"Continue evidence-gated promotion tranches.\":\"Stop promotion and investigate count integrity mismatch.\",\"INTERNAL_GOVERNANCE_COUNT_ONLY\",now]});\n }\n await sqlite.execute({sql:`INSERT INTO orion_agent_count_current(id,total_agent_records,total_nca_records,unique_nca_ids,canonical_nca,expansion_nca,non_nca_records,invalid_nca_format,duplicate_agent_ids,duplicate_numeric_ids,missing_numeric_ids,min_nca_id,max_nca_id,orchestrator_count,integrity_status,signature_sha256,observed_at,policy_version,source) VALUES(1,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET total_agent_records=excluded.total_agent_records,total_nca_records=excluded.total_nca_records,unique_nca_ids=excluded.unique_nca_ids,canonical_nca=excluded.canonical_nca,expansion_nca=excluded.expansion_nca,non_nca_records=excluded.non_nca_records,invalid_nca_format=excluded.invalid_nca_format,duplicate_agent_ids=excluded.duplicate_agent_ids,duplicate_numeric_ids=excluded.duplicate_numeric_ids,missing_numeric_ids=excluded.missing_numeric_ids,min_nca_id=excluded.min_nca_id,max_nca_id=excluded.max_nca_id,orchestrator_count=excluded.orchestrator_count,integrity_status=excluded.integrity_status,signature_sha256=excluded.signature_sha256,observed_at=excluded.observed_at,policy_version=excluded.policy_version,source=excluded.source`,args:[totalAgentRecords,totalNca,uniqueNcaIds,canonicalNca,expansionNca,nonNcaRecords,invalidNcaFormat,duplicateAgentIds,duplicateNumericIds,missingNumericIds,minNcaId,maxNcaId,orchestrators.length,integrityStatus,signatureSha256,now,POLICY_VERSION,source]});\n const stateEntries:Record={agent_count_total_nca:String(totalNca),agent_count_canonical_nca:String(canonicalNca),agent_count_expansion_nca:String(expansionNca),agent_count_total_agent_records:String(totalAgentRecords),agent_count_integrity_status:integrityStatus,agent_count_signature_sha256:signatureSha256,agent_count_last_verified_at:now,agent_count_policy_version:POLICY_VERSION,agent_count_canonical_membership_sha256:membership.membershipSha256,agent_count_definition:JSON.stringify({canonical_membership:\"orion_canonical_nca_membership append-only ledger\",baseline_seed:\"NCA-001..NCA-100\",total_nca:\"all valid unique NCA runtime IDs\",expansion_nca:\"valid runtime NCA not present in canonical membership ledger\"})};\n for(const [key,value] of Object.entries(stateEntries))await sqlite.execute({sql:`INSERT INTO orion_state(key,value,updated_at) VALUES(?,?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value,updated_at=excluded.updated_at`,args:[key,value,now]});\n return {totalAgentRecords,totalNca,uniqueNcaIds,canonicalNca,expansionNca,nonNcaRecords,invalidNcaFormat,duplicateAgentIds,duplicateNumericIds,missingNumericIds,minNcaId,maxNcaId,orchestratorCount:orchestrators.length,orchestrators,integrityStatus,signatureSha256,observedAt:now,policyVersion:POLICY_VERSION,canonicalMembershipSha256:membership.membershipSha256,orphanMemberships:promotedNotRuntime,snapshotCreated,source,membershipMode:\"APPEND_ONLY_LEDGER\"};\n}\n\nexport default async function(_interval?:Interval){const count=await captureOrionAgentCount(\"ORION_AGENT_COUNT_INTERVAL\");console.log(JSON.stringify({event:\"ORION_AGENT_COUNT\",status:count.integrityStatus,totalNca:count.totalNca,canonicalNca:count.canonicalNca,expansionNca:count.expansionNca,totalAgentRecords:count.totalAgentRecords,canonicalMembershipSha256:count.canonicalMembershipSha256,signatureSha256:count.signatureSha256,snapshotCreated:count.snapshotCreated,membershipMode:count.membershipMode,truthBoundary:\"TOTAL_RUNTIME_NCA != CANONICAL_GOVERNANCE_NCA; CANONICAL_MEMBERSHIP_IS_EXPLICIT_AND_EVIDENCE_GATED\",at:count.observedAt}));return count}\nif(isMain(import.meta.url))await captureOrionAgentCount(\"ORION_AGENT_COUNT_MANUAL\").then(x=>console.log(JSON.stringify(x)));",[343],"1dfb903f-d507-49ea-a0fc-a1a619b705bf","orion_agent_count_registry.ts","01a052e0-c8f3-7503-a01f-087b2d4f06cf",["D",1788096858357],"export { captureOrionAgentCount } from \"./orion_agent_count_registry_v2.ts\";\nexport { default } from \"./orion_agent_count_registry_v2.ts\";\n",[349],"025711ed-e562-41ca-9b1e-69b8a157b61e","nca_delegation_worker.ts","01a052e0-c8f3-7503-a01f-0697380b1181",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest, sha256Text } from \"./memory_bridge_client.ts\";\n\nconst MISSION=\"IC-EXECUTE-UNTIL-BLOCKED-001\";\nconst TASKS=[\n \"DG-GITHUB-SOURCE-PREP-001\",\n \"DG-CHAT-BOOTSTRAP-001\",\n \"DG-PITR-READINESS-001\",\n \"DG-SKILL-REGISTRY-001\",\n \"DG-CRYPTO-QUEUE-TRIAGE-001\",\n] as const;\n\nasync function rows(sql:string,args:any[]=[]){\n const r=await sqlite.execute({sql,args});\n return r.rows as any[];\n}\nasync function scalar(sql:string,args:any[]=[]){\n const r=await rows(sql,args); const x=r[0]??{}; const k=Object.keys(x)[0]; return k?x[k]:null;\n}\nasync function finish(taskId:string,state:\"COMPLETED\"|\"BLOCKED\",evidenceState:string,evidence:any,blocker:string|null){\n const now=new Date().toISOString();\n const evidenceJson=JSON.stringify(evidence);\n const evidenceHash=await sha256Text(evidenceJson);\n const wrapped=JSON.stringify({...evidence,evidence_sha256:evidenceHash});\n await sqlite.execute({sql:`UPDATE nca_delegated_tasks SET state=?,evidence_state=?,evidence=?,blocker=?,updated_at=? WHERE task_id=? AND mission_id=?`,args:[state,evidenceState,wrapped,blocker,now,taskId,MISSION]});\n return {taskId,state,evidenceState,evidenceHash,blocker};\n}\n\nasync function githubPrep(){\n const publishBlocked=Number(await scalar(`SELECT COUNT(*) n FROM github_authorship_publish_queue WHERE state='READY_BLOCKED'`)??0);\n const remediation=Number(await scalar(`SELECT COUNT(*) n FROM github_connector_remediation WHERE state='BLOCKED_CURRENT_CONNECTOR'`)??0);\n const repoScopeBlocked=Number(await scalar(`SELECT COUNT(*) n FROM github_steward_repo_scope WHERE work_state='BLOCKED_CURRENT_CONNECTOR'`)??0);\n const amp=(await rows(`SELECT run_id,evidence_hash,created_at FROM codex_agent_amplification_runs ORDER BY rowid DESC LIMIT 1`))[0]??null;\n const perf=(await rows(`SELECT run_id,status,passed,total,evidence_hash,created_at FROM nca_performance_test_runs ORDER BY created_at DESC LIMIT 1`))[0]??null;\n const evidence={prepared:true,publish_queue_blocked:publishBlocked,remediation_agents_blocked:remediation,repo_scope_rows_blocked:repoScopeBlocked,latest_codex_amplification:amp,latest_performance_test:perf,required_write_proof:[\"repository visible to current connector\",\"supported GitHub App installation/account\",\"commit SHA\",\"read-back of committed content\"],source_commit:\"NOT_VERIFIED\"};\n return finish(\"DG-GITHUB-SOURCE-PREP-001\",\"BLOCKED\",\"VERIFIED_PREPARATION\",evidence,\"CURRENT_GITHUB_CONNECTOR_HAS_NO_REPOSITORY_WRITE_TARGET\");\n}\n\nasync function chatBootstrap(){\n try{\n const b=await memoryRequest(\"bootstrap\",{});\n const evidence={server_bootstrap_call:true,bootstrap_ok:b?.ok===true,snapshot_id:b?.snapshot_id??null,chain_head:b?.chain_head??null,payload_sha256:b?.payload_sha256??null,automatic_chat_loading:false,proof_boundary:\"SERVER_BOOTSTRAP_CALLABLE != NEW_CHAT_STARTUP_HOOK\"};\n return finish(\"DG-CHAT-BOOTSTRAP-001\",\"BLOCKED\",\"SERVER_PATH_VERIFIED\",evidence,\"NO_SUPPORTED_CHATGPT_CODEX_NEW_CHAT_STARTUP_HOOK_AVAILABLE_IN_THIS_RUNTIME\");\n }catch(e){\n return finish(\"DG-CHAT-BOOTSTRAP-001\",\"BLOCKED\",\"SERVER_PATH_FAILED\",{error:e instanceof Error?e.message:String(e)},\"BOOTSTRAP_PROBE_FAILED\");\n }\n}\n\nasync function pitrReadiness(){\n try{\n const label=`execute-until-blocked-${Date.now()}`;\n const backup=await memoryRequest(\"backup_create\",{label});\n let restore:any=null;\n if(backup?.backup_id) restore=await memoryRequest(\"backup_restore_test\",{backup_id:backup.backup_id});\n const evidence={logical_backup:backup,controlled_restore_test:restore,managed_pitr_executed:false,production_restore_executed:false,cost_incurred:false,proof_boundary:\"LOGICAL_BACKUP_RESTORE_TEST != MANAGED_DATABASE_LOSS_PITR\"};\n const logicalPass=backup?.ok===true&&restore?.ok===true&&restore?.production_data_mutated===false;\n return finish(\"DG-PITR-READINESS-001\",\"BLOCKED\",logicalPass?\"LOGICAL_RECOVERY_VERIFIED\":\"LOGICAL_RECOVERY_FAILED\",evidence,\"MANAGED_SUPABASE_PITR_DATABASE_LOSS_RESTORE_REQUIRES_EXTERNAL_MANAGEMENT_CAPABILITY_AND_WAS_NOT_DESTRUCTIVELY_EXECUTED\");\n }catch(e){\n return finish(\"DG-PITR-READINESS-001\",\"BLOCKED\",\"RECOVERY_PROBE_FAILED\",{error:e instanceof Error?e.message:String(e),managed_pitr_executed:false},\"RECOVERY_PROBE_FAILED\");\n }\n}\n\nasync function skillRegistry(){\n const bindingCount=Number(await scalar(`SELECT COUNT(*) n FROM skill_runtime_bindings WHERE skill_id LIKE '%continuity%' OR skill_id LIKE '%Continuity%'`)??0);\n const capabilityRows=await rows(`SELECT skill_id,registered_state,dependency_exists,executable_callable,smoke_test,functional_test,authorization_state,verified_at FROM nca_skill_capability_verification ORDER BY verified_at DESC LIMIT 20`);\n const evidence={runtime_continuity_binding_matches:bindingCount,capability_registry_sample:capabilityRows,current_chatgpt_registry_install_api_available:false,server_skill_install_claim:false,proof_boundary:\"SERVER_SKILL_SOURCE_AND_RUNTIME_CAPABILITY != CHATGPT_SKILL_REGISTRY_INSTALLATION\"};\n return finish(\"DG-SKILL-REGISTRY-001\",\"BLOCKED\",\"RUNTIME_AUDITED\",evidence,\"CURRENT_CHATGPT_SKILL_REGISTRY_IS_NOT_WRITABLE_FROM_VAL_TOWN_RUNTIME\");\n}\n\nfunction rank(workType:string){\n const s=workType.toLowerCase();\n if(/compliance|risk|due diligence|final qa/.test(s))return 10;\n if(/liquidity|market maker|investor|sponsor|exchange|defi/.test(s))return 20;\n if(/research|intelligence/.test(s))return 30;\n if(/writer|content|narrative|seo|social|community|pr/.test(s))return 40;\n if(/analytics|growth/.test(s))return 50;\n return 60;\n}\nasync function cryptoTriage(){\n const q=await rows(`SELECT id,agent_id,work_type,asset_scope,state,evidence_state,created_at FROM crypto_growth_work_queue ORDER BY id`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS crypto_growth_execution_plan(queue_id INTEGER PRIMARY KEY,agent_id TEXT NOT NULL,priority INTEGER NOT NULL,lane TEXT NOT NULL,recommended_state TEXT NOT NULL,reason TEXT NOT NULL,planned_at TEXT NOT NULL)`);\n const now=new Date().toISOString();\n const plan=q.map(r=>({queue_id:Number(r.id),agent_id:String(r.agent_id),priority:rank(String(r.work_type)),lane:String(r.work_type),recommended_state:String(r.evidence_state)===\"NONE\"?\"EVIDENCE_REQUIRED\":\"VERIFY_EXISTING_EVIDENCE\",reason:String(r.state)===\"IN_PROGRESS\"?\"IN_PROGRESS_WITHOUT_COMPLETED_EVIDENCE\":\"READY_FOR_BOUNDED_EVIDENCE_WORK\"})).sort((a,b)=>a.priority-b.priority||a.queue_id-b.queue_id);\n for(const p of plan){\n await sqlite.execute({sql:`INSERT INTO crypto_growth_execution_plan(queue_id,agent_id,priority,lane,recommended_state,reason,planned_at) VALUES(?,?,?,?,?,?,?) ON CONFLICT(queue_id) DO UPDATE SET agent_id=excluded.agent_id,priority=excluded.priority,lane=excluded.lane,recommended_state=excluded.recommended_state,reason=excluded.reason,planned_at=excluded.planned_at`,args:[p.queue_id,p.agent_id,p.priority,p.lane,p.recommended_state,p.reason,now]});\n }\n const evidence={queue_total:q.length,ready:q.filter(r=>r.state===\"READY\").length,in_progress:q.filter(r=>r.state===\"IN_PROGRESS\").length,with_completed_evidence:q.filter(r=>r.evidence_state!==\"NONE\").length,plan_rows:plan.length,priority_order:plan.map(p=>({queue_id:p.queue_id,agent_id:p.agent_id,priority:p.priority,lane:p.lane})),authority_boundary:\"NO_OUTBOUND_NO_TRADING_NO_TOKEN_TRANSFER_NO_MARKET_MANIPULATION\"};\n return finish(\"DG-CRYPTO-QUEUE-TRIAGE-001\",\"COMPLETED\",\"VERIFIED_PLAN\",evidence,null);\n}\n\nexport async function main(){\n const active=await rows(`SELECT task_id,state FROM nca_delegated_tasks WHERE mission_id=? AND task_id IN (${TASKS.map(()=>\"?\").join(\",\")})`,[MISSION,...TASKS]);\n const activeSet=new Set(active.filter(r=>r.state===\"READY\"||r.state===\"IN_PROGRESS\").map(r=>String(r.task_id)));\n const results:any[]=[];\n if(activeSet.has(\"DG-GITHUB-SOURCE-PREP-001\"))results.push(await githubPrep());\n if(activeSet.has(\"DG-CHAT-BOOTSTRAP-001\"))results.push(await chatBootstrap());\n if(activeSet.has(\"DG-PITR-READINESS-001\"))results.push(await pitrReadiness());\n if(activeSet.has(\"DG-SKILL-REGISTRY-001\"))results.push(await skillRegistry());\n if(activeSet.has(\"DG-CRYPTO-QUEUE-TRIAGE-001\"))results.push(await cryptoTriage());\n const out={event:\"NCA_DELEGATION_WORKER\",missionId:MISSION,processed:results.length,completed:results.filter(x=>x.state===\"COMPLETED\").length,blocked:results.filter(x=>x.state===\"BLOCKED\").length,results,truthBoundary:\"BLOCKED_IS_A_VERIFIED_LIMITATION_NOT_SUCCESS; DELEGATED_TASK_EXECUTION_DOES_NOT_GRANT_EXTERNAL_AUTHORITY\"};\n console.log(JSON.stringify(out)); return out;\n}\nexport default main;\nif(isMain(import.meta.url)) await main();\n",[355],"0fa32d2f-6570-4273-8e8a-87a379a63643","memory_bridge_client.ts","01a052e0-c8f3-7503-a01f-0002e89b7fd8",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\n\nexport const MEMORY_ENDPOINT=\"https://flqxwhibxnyujynmopmr.supabase.co/functions/v1/imperial-continuity-memory\";\n\nexport async function sha256Text(value:string){\n const bytes=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));\n return Array.from(new Uint8Array(bytes),b=>b.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nexport async function memoryRequest(operation:string,params:Record={}){\n const key=Deno.env.get(\"IMPERIAL_MEMORY_BRIDGE_KEY\");\n if(!key) throw new Error(\"IMPERIAL_MEMORY_BRIDGE_KEY_MISSING\");\n const controller=new AbortController();\n const timer=setTimeout(()=>controller.abort(),20000);\n try {\n const response=await fetch(MEMORY_ENDPOINT,{\n method:\"POST\",signal:controller.signal,\n headers:{\"content-type\":\"application/json\",\"x-imperial-memory-key\":key},\n body:JSON.stringify({operation,params})\n });\n const data=await response.json().catch(()=>({ok:false,error:\"NON_JSON_RESPONSE\"}));\n if(!response.ok || !data?.ok) throw new Error(`MEMORY_REQUEST_FAILED_${response.status}_${data?.error??\"UNKNOWN\"}_${data?.code??\"NO_CODE\"}`);\n return data;\n } finally { clearTimeout(timer); }\n}\n\nexport async function authBoundaryProbe(){\n const response=await fetch(MEMORY_ENDPOINT,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:JSON.stringify({operation:\"bootstrap\",params:{}})});\n return {status:response.status,denied:response.status===401};\n}\n\nexport async function main(){\n const health=await fetch(`${MEMORY_ENDPOINT}/health`).then(r=>r.json());\n const auth=await authBoundaryProbe();\n const result={status:health?.status===\"ok\"&&auth.denied?\"PASS\":\"FAIL\",health,unauthorized_write_denied:auth.denied};\n console.log(JSON.stringify(result)); return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();",[361],"fe28c82f-b28b-449e-8330-59caa8f8d7d4","execution_worker.ts","01a052e0-c8f3-7503-a01e-ff1c7dd7b13f",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst ALLOWED_HOSTS = new Set([\n \"ag-command-center.val.run\",\n \"api.github.com\",\n]);\n\nasync function sha256(value:string){\n const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nasync function ensure(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS execution_queue(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT NOT NULL,\n task_type TEXT NOT NULL,\n target TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY',\n priority INTEGER NOT NULL DEFAULT 100,\n created_at TEXT NOT NULL,\n claimed_at TEXT,\n completed_at TEXT,\n error TEXT,\n evidence_id INTEGER\n )`},\n {sql:`CREATE TABLE IF NOT EXISTS execution_evidence(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n queue_id INTEGER NOT NULL,\n agent_id TEXT NOT NULL,\n action TEXT NOT NULL,\n target TEXT NOT NULL,\n http_status INTEGER,\n body_sha256 TEXT,\n body_excerpt TEXT,\n observed_at TEXT NOT NULL,\n verifier_state TEXT NOT NULL,\n FOREIGN KEY(queue_id) REFERENCES execution_queue(id)\n )`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_execution_queue_state_priority ON execution_queue(state,priority,id)`},\n ]);\n}\n\nasync function seedIfEmpty(now:string){\n const q=await sqlite.execute(`SELECT COUNT(*) AS n FROM execution_queue`);\n const total=Number((q.rows as any[])[0]?.n??0);\n if(total>=2)return false;\n const a=await sqlite.execute({sql:`SELECT agent_id FROM agents ORDER BY agent_id LIMIT 1 OFFSET ?`,args:[total]});\n const agent=String((a.rows as any[])[0]?.agent_id??\"\");\n if(!agent)throw new Error(\"NO_AGENT_AVAILABLE\");\n const target=total===0\n ? \"https://ag-command-center.val.run/api/health\"\n : \"https://api.github.com/repos/oromaskevic23-cmd/CYBER-HAK-Public\";\n await sqlite.execute({sql:`INSERT INTO execution_queue(agent_id,task_type,target,state,priority,created_at) VALUES(?,?,?,'READY',10,?)`,args:[agent,\"HTTP_GET_VERIFY\",target,now]});\n return true;\n}\n\nasync function claim(now:string){\n const pick=await sqlite.execute(`SELECT id FROM execution_queue WHERE state='READY' ORDER BY priority,id LIMIT 1`);\n const id=Number((pick.rows as any[])[0]?.id??0); if(!id)return null;\n const u=await sqlite.execute({sql:`UPDATE execution_queue SET state='CLAIMED',claimed_at=? WHERE id=? AND state='READY'`,args:[now,id]});\n if(Number(u.rowsAffected)!==1)return null;\n const r=await sqlite.execute({sql:`SELECT * FROM execution_queue WHERE id=?`,args:[id]});\n return (r.rows as any[])[0]??null;\n}\n\nexport default async function(_interval:Interval){\n await ensure(); const now=new Date().toISOString();\n const seeded=await seedIfEmpty(now);\n const task=await claim(now);\n if(!task){console.log(JSON.stringify({event:\"EXECUTION_WORKER\",status:\"IDLE\",seeded,at:now}));return;}\n\n try{\n if(String(task.task_type)!==\"HTTP_GET_VERIFY\")throw new Error(\"UNSUPPORTED_TASK_TYPE\");\n const url=new URL(String(task.target));\n if(url.protocol!==\"https:\"||!ALLOWED_HOSTS.has(url.hostname))throw new Error(\"TARGET_NOT_ALLOWLISTED\");\n const r=await fetch(url,{method:\"GET\",headers:{\"user-agent\":\"IMPERIAL-Recovery-Execution-Worker/1.0\"},signal:AbortSignal.timeout(8000)});\n const body=(await r.text()).slice(0,4000);\n const digest=await sha256(body);\n const verified=r.ok && body.length>0;\n const ev=await sqlite.execute({sql:`INSERT INTO execution_evidence(queue_id,agent_id,action,target,http_status,body_sha256,body_excerpt,observed_at,verifier_state) VALUES(?,?,?,?,?,?,?,?,?)`,args:[task.id,task.agent_id,\"HTTP_GET_VERIFY\",task.target,r.status,digest,body.slice(0,1000),now,verified?\"PASS\":\"FAIL\"]});\n const evidenceId=Number(ev.lastInsertRowid??0);\n await sqlite.execute({sql:`UPDATE execution_queue SET state=?,completed_at=?,error=?,evidence_id=? WHERE id=? AND state='CLAIMED'`,args:[verified?\"COMPLETED\":\"FAILED\",now,verified?null:`HTTP_${r.status}`,evidenceId,task.id]});\n console.log(JSON.stringify({event:\"EXECUTION_WORKER\",status:verified?\"PASS\":\"FAIL\",queue_id:task.id,task_type:task.task_type,http_status:r.status,evidence_id:evidenceId,body_sha256:digest,at:now,truthBoundary:\"COMPLETED_REQUIRES_TOOL_EVIDENCE\"}));\n }catch(e){\n const msg=e instanceof Error?e.message:String(e);\n await sqlite.execute({sql:`UPDATE execution_queue SET state='FAILED',completed_at=?,error=? WHERE id=? AND state='CLAIMED'`,args:[now,msg.slice(0,500),task.id]});\n console.log(JSON.stringify({event:\"EXECUTION_WORKER\",status:\"FAIL\",queue_id:task.id,error:msg,at:now}));\n }\n}\n",[367],"546d2afc-e8f5-4acd-8c90-d94b17258944","execute_until_blocked_test.ts","01a052e0-c8f3-7503-a01e-fb06297846ea",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sha256Text } from \"./memory_bridge_client.ts\";\n\nasync function n(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return Number((r.rows as any[])[0]?.n??0)}\nasync function row(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??{}}\n\nexport async function main(){\n const journal=await n(`SELECT COUNT(*) n FROM task_journal`);\n const delegated=await n(`SELECT COUNT(*) n FROM nca_delegated_tasks WHERE mission_id='IC-EXECUTE-UNTIL-BLOCKED-001'`);\n const delegatedCompleted=await n(`SELECT COUNT(*) n FROM nca_delegated_tasks WHERE mission_id='IC-EXECUTE-UNTIL-BLOCKED-001' AND state='COMPLETED'`);\n const delegatedBlocked=await n(`SELECT COUNT(*) n FROM nca_delegated_tasks WHERE mission_id='IC-EXECUTE-UNTIL-BLOCKED-001' AND state='BLOCKED'`);\n const delegatedActive=await n(`SELECT COUNT(*) n FROM nca_delegated_tasks WHERE mission_id='IC-EXECUTE-UNTIL-BLOCKED-001' AND state IN ('READY','IN_PROGRESS')`);\n const cryptoPackages=await n(`SELECT COUNT(*) n FROM crypto_growth_evidence_packages`);\n const cryptoEvidence=await n(`SELECT COUNT(*) n FROM crypto_growth_work_queue WHERE evidence_state='VERIFIED_INPUT_PACKAGE'`);\n const cryptoInProgress=await n(`SELECT COUNT(*) n FROM crypto_growth_work_queue WHERE state='IN_PROGRESS'`);\n const appendOnlyTriggers=await n(`SELECT COUNT(*) n FROM sqlite_master WHERE type='trigger' AND name IN ('crypto_growth_evidence_no_update','crypto_growth_evidence_no_delete')`);\n const perfCompleted=await n(`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id='IC-CODEX-100-NCA-PERFORMANCE-AMPLIFICATION-001' AND state='COMPLETED'`);\n const perfNonCompleted=await n(`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id='IC-CODEX-100-NCA-PERFORMANCE-AMPLIFICATION-001' AND state<>'COMPLETED'`);\n const githubRemediation=await n(`SELECT COUNT(*) n FROM github_connector_remediation WHERE state='BLOCKED_CURRENT_CONNECTOR'`);\n const githubScope=await n(`SELECT COUNT(*) n FROM github_steward_repo_scope WHERE work_state='BLOCKED_CURRENT_CONNECTOR'`);\n const activeExecution=await n(`SELECT COUNT(*) n FROM execution_queue WHERE state IN ('READY','CLAIMED','EXECUTING','IN_PROGRESS')`);\n const orion=await row(`SELECT status,payload,last_checked_at FROM orion_watchdog_state WHERE id=1`);\n let orionPayload:any={};try{orionPayload=JSON.parse(String(orion.payload??'{}'))}catch{}\n const tests=[\n {name:'task_journal_active',pass:journal>=20,evidence:{journal}},\n {name:'delegated_terminal_states',pass:delegated===6&&delegatedCompleted===2&&delegatedBlocked===4&&delegatedActive===0,evidence:{delegated,delegatedCompleted,delegatedBlocked,delegatedActive}},\n {name:'crypto_20_evidence_packages',pass:cryptoPackages===20&&cryptoEvidence===20&&cryptoInProgress===20,evidence:{cryptoPackages,cryptoEvidence,cryptoInProgress}},\n {name:'crypto_evidence_append_only',pass:appendOnlyTriggers===2,evidence:{appendOnlyTriggers}},\n {name:'canonical_performance_100_verified',pass:perfCompleted===100&&perfNonCompleted===0,evidence:{perfCompleted,perfNonCompleted}},\n {name:'github_current_blocker_grounded',pass:githubRemediation===5&&githubScope===10,evidence:{githubRemediation,githubScope}},\n {name:'no_unclaimed_execution_work',pass:activeExecution===0,evidence:{activeExecution}},\n {name:'orion_canonical_watchdog_pass',pass:String(orion.status)==='PASS'&&orionPayload?.scope==='CANONICAL_NCA_001_100',evidence:{status:orion.status,scope:orionPayload?.scope,last_checked_at:orion.last_checked_at}},\n ];\n const passed=tests.filter(t=>t.pass).length;\n const at=new Date().toISOString();\n const evidenceHash=await sha256Text(JSON.stringify({tests,at}));\n const result={suite:'EXECUTE_UNTIL_BLOCKED_GATES',status:passed===tests.length?'PASS':'FAIL',passed,total:tests.length,evidenceHash,tests,truthBoundary:'PASS_MEANS_ALL_LOCALLY_CLOSABLE_GATES_CHECKED; EXTERNAL_PLATFORM_BLOCKERS_REMAIN_BLOCKED_NOT_COMPLETED'};\n console.log(JSON.stringify(result));\n if(result.status!=='PASS')throw new Error(`EXECUTE_UNTIL_BLOCKED_GATES_FAILED_${tests.length-passed}`);\n return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[373],"29148b82-8c9a-4b5a-9dbd-a6513b229ab9","dual_model_collaboration_test.ts","01a052e0-c8f3-7503-a01e-f57480e38f82",4,["D",1788097272809],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst r=await sqlite.execute(\"SELECT agent_id,skill_version,runtime_state,authority_rule FROM skill_runtime_bindings WHERE skill_id='dual-model-collaboration' AND CAST(substr(agent_id,5) AS INTEGER) BETWEEN 101 AND 150 ORDER BY CAST(substr(agent_id,5) AS INTEGER)\");\nconst rows=r.rows as any[];\nconst tests=[\n {name:'code_engineering_bindings_50',pass:rows.length===50},\n {name:'version_1_0_0',pass:rows.every(x=>x.skill_version==='1.0.0')},\n {name:'active_bounded',pass:rows.every(x=>x.runtime_state==='ACTIVE_BOUNDED')},\n {name:'no_authority_grant',pass:rows.every(x=>x.authority_rule==='DUAL_PROVIDER_DOES_NOT_GRANT_AUTHORITY')},\n {name:'exact_range_101_150',pass:rows[0]?.agent_id==='NCA-101'&&rows.at(-1)?.agent_id==='NCA-150'}\n];\nconst failed=tests.filter(t=>!t.pass);\nconsole.log(JSON.stringify({event:'DUAL_MODEL_COLLABORATION_TEST',status:failed.length?'FAIL':'PASS',passed:tests.length-failed.length,total:tests.length,bindings:rows.length,tests,truthBoundary:'SKILL_BOUND != OPENAI_AND_CLAUDE_RUNTIME_CONNECTED'},null,2));\nif(failed.length)throw new Error('DUAL_MODEL_TEST_FAILED');",[379],"401121ab-1f50-4726-815a-be88506ec4a5","crypto_growth_runtime_test.ts","01a052e0-c8f3-7503-a01e-f303f230a7cc",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\n\nasync function n(sql:string){return Number((await sqlite.execute(sql)).rows[0]?.n??0)}\n\nexport async function main(){\n const team=await n(`SELECT COUNT(*) n FROM crypto_growth_team WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN 151 AND 170`);\n const compliance=await n(`SELECT COUNT(*) n FROM crypto_growth_team WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN 151 AND 170 AND compliance_boundary<>''`);\n const scopes=await n(`SELECT COUNT(*) n FROM crypto_growth_team WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN 151 AND 170 AND asset_scope='NDB,IMPERIUM,MONARCH'`);\n const runtimeRoster=await n(`SELECT COUNT(*) n FROM agents WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN 151 AND 170`);\n const networkOk=await n(`SELECT COUNT(*) n FROM agents WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN 151 AND 170 AND network_ok=1`);\n const freshHeartbeat=await n(`SELECT COUNT(*) n FROM agents WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN 151 AND 170 AND last_heartbeat IS NOT NULL AND datetime(last_heartbeat)>=datetime('now','-20 minutes')`);\n const queueTotal=await n(`SELECT COUNT(*) n FROM crypto_growth_work_queue`);\n const queueRunnable=await n(`SELECT COUNT(*) n FROM crypto_growth_work_queue WHERE state IN ('READY','IN_PROGRESS')`);\n const invalidQueueState=await n(`SELECT COUNT(*) n FROM crypto_growth_work_queue WHERE state NOT IN ('READY','IN_PROGRESS','COMPLETED','BLOCKED','FAILED')`);\n const evidenceCompleted=await n(`SELECT COUNT(*) n FROM crypto_growth_work_queue WHERE evidence_state<>'NONE'`);\n const planRows=await n(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name='crypto_growth_execution_plan'`) ? await n(`SELECT COUNT(*) n FROM crypto_growth_execution_plan`) : 0;\n const checks={\n team:team===20,\n runtime_roster:runtimeRoster===20,\n network:networkOk===20,\n fresh_heartbeat:freshHeartbeat===20,\n queue_integrity:queueTotal===20&&queueRunnable===20&&invalidQueueState===0,\n compliance:compliance===20,\n scope:scopes===20,\n triage_plan:planRows===20,\n evidence_packages:evidenceCompleted===20,\n };\n const passed=Object.values(checks).filter(Boolean).length;\n const result={test:'CRYPTO_GROWTH_RUNTIME_TEST_V2',status:passed===Object.keys(checks).length?'PASS':'FAIL',passed,total:Object.keys(checks).length,checks,metrics:{team,runtimeRoster,networkOk,freshHeartbeat,queueTotal,queueRunnable,invalidQueueState,evidenceCompleted,planRows},truthBoundary:'RUNNING_RECOVERY_AND_QUEUE_STATE != EXTERNAL_RESEARCH_COMPLETED; VERIFIED_INPUT_PACKAGES_20 != EXTERNAL_SUCCESS; OUTBOUND_SEND_AND_FINANCIAL_EXECUTION_REQUIRE_APPROVAL'};\n console.log(JSON.stringify(result,null,2));\n if(result.status!=='PASS')throw new Error(`CRYPTO_GROWTH_RUNTIME_TEST_FAILED_${result.total-passed}`);\n return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[386],"2f81a692-046b-48fb-8bee-b2ded93549b6","crypto_growth_evidence_worker.ts","01a052e0-c8f3-7503-a01e-ec4dc017c088",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sha256Text } from \"./memory_bridge_client.ts\";\n\nconst PERF_MISSION=\"IC-CODEX-100-NCA-PERFORMANCE-AMPLIFICATION-001\";\nconst DELEGATED_TASK=\"DG-CRYPTO-EVIDENCE-BIND-001\";\nconst WORKSTREAM:Record={\n \"Growth Strategy Lead\":\"O_ORION_SYNTHESIS\",\n \"Crypto Market Research\":\"I_COMPETITIVE_BENCHMARKING\",\n \"Community Intelligence\":\"K_OUTREACH_INTELLIGENCE\",\n \"Liquidity Partner Research\":\"B_LP_DUE_DILIGENCE\",\n \"Market Maker Research\":\"A_MARKET_MAKER_DISCOVERY\",\n \"Exchange & Listing Research\":\"C_CEX_RESEARCH\",\n \"DeFi Ecosystem Partnerships\":\"D_DEX_RESEARCH\",\n \"Investor & Sponsor Research\":\"E_INSTITUTIONAL_RESEARCH\",\n \"Business Development Writer\":\"L_PERSONALIZED_PROPOSAL_PREPARATION\",\n \"Institutional Outreach Writer\":\"P_HANTER_BRIEFING\",\n \"Crypto PR & Media Research\":\"I_COMPETITIVE_BENCHMARKING\",\n \"Content Strategy\":\"F_TOKEN_DOCUMENTATION_AUDIT\",\n \"SEO & Discoverability\":\"I_COMPETITIVE_BENCHMARKING\",\n \"Social Campaign Strategy\":\"K_OUTREACH_INTELLIGENCE\",\n \"Community Partnership Outreach\":\"K_OUTREACH_INTELLIGENCE\",\n \"Token Narrative & Positioning\":\"F_TOKEN_DOCUMENTATION_AUDIT\",\n \"Compliance & Claim Ledger\":\"J_LEGAL_COMPLIANCE_READINESS\",\n \"Due Diligence & Counterparty Risk\":\"M_RISK_REVIEW\",\n \"Analytics & Growth Measurement\":\"H_EXISTING_LIQUIDITY_MAPPING\",\n \"Final QA & Outreach Evidence\":\"N_EVIDENCE_VALIDATION\",\n};\n\nasync function one(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??null}\nasync function all(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return r.rows as any[]}\n\nasync function ensure(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS crypto_growth_evidence_packages(\n queue_id INTEGER PRIMARY KEY,\n agent_id TEXT NOT NULL,\n work_type TEXT NOT NULL,\n asset_scope TEXT NOT NULL,\n source_workstream TEXT NOT NULL,\n source_task_id TEXT NOT NULL,\n source_evidence_id INTEGER NOT NULL,\n source_url TEXT NOT NULL,\n source_http_status INTEGER NOT NULL,\n source_body_sha256 TEXT NOT NULL,\n source_evidence_hash TEXT NOT NULL,\n package_sha256 TEXT NOT NULL UNIQUE,\n payload TEXT NOT NULL,\n created_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE TRIGGER IF NOT EXISTS crypto_growth_evidence_no_update BEFORE UPDATE ON crypto_growth_evidence_packages BEGIN SELECT RAISE(ABORT,'crypto_growth_evidence_packages is append-only'); END`);\n await sqlite.execute(`CREATE TRIGGER IF NOT EXISTS crypto_growth_evidence_no_delete BEFORE DELETE ON crypto_growth_evidence_packages BEGIN SELECT RAISE(ABORT,'crypto_growth_evidence_packages is append-only'); END`);\n}\n\nexport async function main(){\n await ensure();\n const queue=await all(`SELECT id,agent_id,work_type,asset_scope,state,evidence_state,created_at FROM crypto_growth_work_queue ORDER BY id`);\n const results:any[]=[];\n for(const q of queue){\n const stream=WORKSTREAM[String(q.work_type)];\n if(!stream){results.push({queue_id:q.id,agent_id:q.agent_id,status:\"BLOCKED\",reason:\"NO_ROLE_WORKSTREAM_MAPPING\"});continue}\n const src=await one(`SELECT t.task_id,t.workstream,t.source_url,t.quality_score,e.id evidence_id,e.evidence_hash,e.result_summary,e.source_http_status,e.source_body_sha256,e.evidence_score,e.factual_accuracy_score,e.compliance_score,e.completed_at\n FROM nca_performance_tasks t JOIN nca_performance_evidence e ON e.id=t.evidence_id\n WHERE t.mission_id=? AND t.workstream=? AND t.state='COMPLETED' AND e.final_state='COMPLETED' AND e.critic_result='PASS' AND e.compliance_result='PASS'\n ORDER BY t.quality_score DESC,t.task_id LIMIT 1`,[PERF_MISSION,stream]);\n if(!src){results.push({queue_id:q.id,agent_id:q.agent_id,status:\"BLOCKED\",reason:`NO_VERIFIED_SOURCE_FOR_${stream}`});continue}\n const payload={queue_id:Number(q.id),agent_id:String(q.agent_id),work_type:String(q.work_type),asset_scope:String(q.asset_scope),source_workstream:stream,source_task_id:String(src.task_id),source_evidence_id:Number(src.evidence_id),source_url:String(src.source_url),source_http_status:Number(src.source_http_status),source_body_sha256:String(src.source_body_sha256),source_evidence_hash:String(src.evidence_hash),source_result_summary:String(src.result_summary),scores:{evidence:Number(src.evidence_score),factual:Number(src.factual_accuracy_score),compliance:Number(src.compliance_score)},source_completed_at:String(src.completed_at),use:\"VERIFIED_RESEARCH_INPUT_ONLY\",truth_boundary:\"SOURCE_EVIDENCE_INPUT != PARTNERSHIP_OR_LISTING_OR_LIQUIDITY_OR_REVENUE\"};\n const packageSha=await sha256Text(JSON.stringify(payload));\n const now=new Date().toISOString();\n const insert=await sqlite.execute({sql:`INSERT OR IGNORE INTO crypto_growth_evidence_packages(queue_id,agent_id,work_type,asset_scope,source_workstream,source_task_id,source_evidence_id,source_url,source_http_status,source_body_sha256,source_evidence_hash,package_sha256,payload,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[q.id,q.agent_id,q.work_type,q.asset_scope,stream,src.task_id,src.evidence_id,src.source_url,src.source_http_status,src.source_body_sha256,src.evidence_hash,packageSha,JSON.stringify(payload),now]});\n const pkg=await one(`SELECT package_sha256 FROM crypto_growth_evidence_packages WHERE queue_id=?`,[q.id]);\n if(!pkg){results.push({queue_id:q.id,agent_id:q.agent_id,status:\"BLOCKED\",reason:\"PACKAGE_PERSISTENCE_FAILED\"});continue}\n await sqlite.execute({sql:`UPDATE crypto_growth_work_queue SET state=CASE WHEN state='READY' THEN 'IN_PROGRESS' ELSE state END,evidence_state='VERIFIED_INPUT_PACKAGE' WHERE id=?`,args:[q.id]});\n results.push({queue_id:q.id,agent_id:q.agent_id,status:\"EVIDENCE_BOUND\",workstream:stream,source_task_id:src.task_id,package_sha256:String(pkg.package_sha256),new_package:Number(insert.rowsAffected)===1});\n }\n const bound=results.filter(x=>x.status===\"EVIDENCE_BOUND\").length;\n const blocked=results.length-bound;\n const packages=Number((await one(`SELECT COUNT(*) n FROM crypto_growth_evidence_packages`))?.n??0);\n const queueEvidence=Number((await one(`SELECT COUNT(*) n FROM crypto_growth_work_queue WHERE evidence_state='VERIFIED_INPUT_PACKAGE'`))?.n??0);\n const evidence={processed:results.length,bound,blocked,packages,queueEvidence,results,authority_boundary:\"READ_ONLY_RESEARCH_INPUT_NO_OUTBOUND_NO_FINANCIAL_EXECUTION\",truth_boundary:\"20_EVIDENCE_PACKAGES != 20_COMPLETED_BUSINESS_OUTCOMES\"};\n const evidenceHash=await sha256Text(JSON.stringify(evidence));\n const now=new Date().toISOString();\n const state=bound===20&&blocked===0&&packages===20&&queueEvidence===20?\"COMPLETED\":\"BLOCKED\";\n await sqlite.execute({sql:`UPDATE nca_delegated_tasks SET state=?,evidence_state=?,evidence=?,blocker=?,updated_at=? WHERE task_id=?`,args:[state,state===\"COMPLETED\"?\"20_VERIFIED_INPUT_PACKAGES\":\"PARTIAL_EVIDENCE_BIND\",JSON.stringify({...evidence,evidence_sha256:evidenceHash}),state===\"COMPLETED\"?null:`EVIDENCE_BIND_BLOCKED_${blocked}`,now,DELEGATED_TASK]});\n const out={event:\"CRYPTO_GROWTH_EVIDENCE_BIND\",status:state===\"COMPLETED\"?\"PASS\":\"PARTIAL\",bound,blocked,packages,queueEvidence,evidenceHash,results,truthBoundary:\"VERIFIED_INPUT_PACKAGE != EXTERNAL_SUCCESS\"};\n console.log(JSON.stringify(out));\n if(out.status!==\"PASS\")throw new Error(`CRYPTO_EVIDENCE_BIND_FAILED_${blocked}`);\n return out;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[392],"c9267f04-67a5-4cc5-8f8d-80cb152cd771","continuity_session_b_test.ts","01a052e0-c8f3-7503-a01e-e924e3ce4332",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest,sha256Text } from \"./memory_bridge_client.ts\";\n\nexport async function main(){\n const search=await memoryRequest(\"search\",{query:\"IMPERIAL_CROSS_SESSION_MEMORY_PROBE\",entity_type:\"CONTINUITY_TEST\",limit:20});\n const event=(search.results??[]).find((x:any)=>x.event_type===\"CROSS_SESSION_TEST\"&&x.content?.session===\"A\");\n if(!event) throw new Error(\"SESSION_A_FACT_NOT_FOUND\");\n const exactFact=String(event.content.fact);\n const computed=await sha256Text(exactFact);\n const exact=computed===event.content.fact_sha256 && exactFact===event.entity_id;\n const chain=await memoryRequest(\"verify_chain\");\n const confirmation=await memoryRequest(\"commit\",{\n event_type:\"CROSS_SESSION_TEST\",entity_type:\"CONTINUITY_TEST\",entity_id:`SESSION_B:${event.event_id}`,\n mission_id:\"IC-CODEX-SERVER-MEMORY-CONTINUITY-001\",status:exact&&chain.ok?\"TESTED\":\"BLOCKED\",\n content:{result:exact&&chain.ok?\"PASS\":\"FAIL\",marker:\"IMPERIAL_SESSION_B_VERIFICATION\",\n session_a_event_id:event.event_id,session_a_event_hash:event.event_hash,exact_fact:exactFact,\n expected_fact_sha256:event.content.fact_sha256,computed_fact_sha256:computed,no_manual_injection:true},\n source_authority:70,recorded_by:\"Val Town fresh independent session B\",\n evidence_refs:[],idempotency_key:`session-b-${event.event_id}`\n });\n const pass=exact&&chain.ok&&confirmation.read_after_write_verified===true;\n const result={status:pass?\"PASS\":\"FAIL\",session:\"B\",retrieved_event_id:event.event_id,\n exact_fact:exactFact,expected_sha256:event.content.fact_sha256,computed_sha256:computed,\n exact_value_match:exact,chain_integrity:chain.ok,confirmation_event_id:confirmation.event_id,\n confirmation_event_hash:confirmation.event_hash,no_manual_injection:true};\n console.log(JSON.stringify(result));\n if(!pass) throw new Error(\"CROSS_SESSION_MEMORY_FAILED\");\n return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();",[398],"040d26f8-81f7-400b-9637-47611dc5a4c5","continuity_session_a_test.ts","01a052e0-c8f3-7503-a01e-e7e38d64b288",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest,sha256Text } from \"./memory_bridge_client.ts\";\n\nexport async function main(){\n const fact=`CONTINUITY_TEST_${crypto.randomUUID()}`;\n const factSha256=await sha256Text(fact);\n const committed=await memoryRequest(\"commit\",{\n event_type:\"CROSS_SESSION_TEST\",entity_type:\"CONTINUITY_TEST\",entity_id:fact,\n mission_id:\"IC-CODEX-SERVER-MEMORY-CONTINUITY-001\",status:\"TESTED\",\n content:{fact,fact_sha256:factSha256,marker:\"IMPERIAL_CROSS_SESSION_MEMORY_PROBE\",session:\"A\"},\n source_authority:70,recorded_by:\"Val Town independent session A\",\n evidence_refs:[],idempotency_key:`session-a-${fact}`\n });\n const exact=committed.read_after_write_verified===true && committed.content_sha256?.length===64;\n const result={status:exact?\"PASS\":\"FAIL\",session:\"A\",fact,fact_sha256:factSha256,event_id:committed.event_id,event_hash:committed.event_hash,content_sha256:committed.content_sha256,read_after_write_verified:committed.read_after_write_verified};\n console.log(JSON.stringify(result));\n if(!exact) throw new Error(\"SESSION_A_COMMIT_FAILED\");\n return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();",[404],"f72d1530-2ba2-4108-9eab-6eb058522f7b",["D",1788097828044],[27],"54958909-03fd-440c-8cb5-f70ad4c65c29","continuity_commit_orion_agent_count.ts","01a052e0-c8f3-7503-a01e-e1acfc845d8f",12,["D",1788097580423],"export { main } from \"./continuity_commit_canonical_promotion.ts\";\nexport { default } from \"./continuity_commit_canonical_promotion.ts\";\n",[413],"99aacb78-0878-4974-8e45-2177a333c7c8","continuity_commit_execute_until_blocked.ts","01a052e0-c8f3-7503-a01e-dcc276d32ef7",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest } from \"./memory_bridge_client.ts\";\n\nconst common={source_authority:70,recorded_by:\"EXECUTE_UNTIL_BLOCKED_WORKFLOW\"};\nconst ev=(type:string,reference:string,sha256:string,status=\"TESTED\")=>({type,reference,sha256,status});\n\nexport async function main(){\n const commits:any[]=[];\n commits.push(await memoryRequest(\"commit\",{\n ...common,event_type:\"CURRENT_STATE_CHANGED\",entity_type:\"BLOCKER_SET\",entity_id:\"CURRENT_BLOCKERS\",status:\"BLOCKED\",projection_category:\"BLOCKERS\",\n supersedes_event_id:\"1c2f86e1-45e8-4d07-8913-6d42fa896461\",idempotency_key:\"IC-EUB-20260830-BLOCKERS-V1\",\n content:{items:[\n {id:\"NEW_CHAT_AUTO_BOOTSTRAP\",status:\"NOT_VERIFIED\",reason:\"Server bootstrap path is verified, but no supported ChatGPT/Codex new-chat startup hook is available in the current runtime.\"},\n {id:\"GITHUB_SOURCE_COMMIT\",status:\"BLOCKED\",reason:\"Current GitHub connector is authenticated to the profile but exposes installed_accounts=0 and repositories_visible=0; no current repository write target exists.\"},\n {id:\"MANAGED_DATABASE_PITR\",status:\"NOT_VERIFIED\",reason:\"A new logical backup plus controlled restore test passed without production mutation, but managed database-loss PITR was not destructively executed.\"},\n {id:\"CHATGPT_SKILL_REGISTRY_INSTALL\",status:\"NOT_VERIFIED\",reason:\"Continuity runtime bindings are present server-side, but the current ChatGPT skill registry is not writable from Val Town.\"}\n ],resolved:[{id:\"FULL_100_NCA_VERIFICATION\",status:\"RESOLVED\",evidence:\"100/100 source-retrieval tasks completed with valid evidence; failed=0.\"}]},\n evidence_refs:[\n ev(\"NCA_EVIDENCE\",\"DG-CHAT-BOOTSTRAP-001\",\"0b3cc363c2deb173e75980026c311ee5ea4a706139627724148cec5174f50508\"),\n ev(\"NCA_EVIDENCE\",\"DG-GITHUB-SOURCE-PREP-001\",\"fd076f4ec67c53c3a64bf1b5a0f55fc4d1c088e0695cb150fbede31ad49db0fb\"),\n ev(\"NCA_EVIDENCE\",\"DG-PITR-READINESS-001\",\"9568b49349ce32d85c68bf52bf419ec2b06d3c350ebea2cab7844a2d26a84c3d\"),\n ev(\"NCA_EVIDENCE\",\"DG-SKILL-REGISTRY-001\",\"1aaaa123941ecce0f29c0a2e3b552afab7db6d37e888a72b3274e4fa031bc6d5\"),\n ev(\"PERFORMANCE_TEST\",\"perf-test-1788087539186-b94120b2-cd81-4193-9f09-cbbccf4f96c1\",\"100bb0d25b42cd04635f9ad4bb7da74c5986631e4906db209ddc6d635c5c2e14\")\n ]\n }));\n commits.push(await memoryRequest(\"commit\",{\n ...common,event_type:\"NEXT_ACTION_CHANGED\",entity_type:\"NEXT_ACTION_SET\",entity_id:\"CURRENT_NEXT_ACTIONS\",status:\"PLANNED\",projection_category:\"NEXT_ACTIONS\",\n supersedes_event_id:\"4e3a3a8e-6b1f-4415-9c22-80885a7ddfb2\",idempotency_key:\"IC-EUB-20260830-NEXT-V1\",\n content:{items:[\n \"Authorize/install the supported GitHub App/account for at least one intended repository, then create a real commit and verify SHA plus read-back.\",\n \"Configure a supported ChatGPT/Codex startup invocation and prove it in a genuinely new session; until then automatic chat memory remains NOT_VERIFIED.\",\n \"Evaluate managed Supabase PITR/database-loss restore under an approved non-production or managed procedure; do not risk production data merely to close a gate.\",\n \"Install imperial-continuity into a supported ChatGPT/Codex skill registry when a writable registry surface is available and verify discovery from a new session.\",\n \"Continue NCA-151..NCA-170 role-specific crypto-growth analysis using the 20 verified input packages; external outreach, trading, transfers and irreversible actions remain approval-gated.\"\n ]},\n evidence_refs:[ev(\"GATE_TEST\",\"execute_until_blocked_test main v32\",\"cd006e11ca65ac86e7fab6c22c4bac0f462e9aab8843fb76e5270dfa705316b6\")]\n }));\n commits.push(await memoryRequest(\"commit\",{\n ...common,event_type:\"RUNTIME_CHANGED\",entity_type:\"RUNTIME\",entity_id:\"imperial-nca-runtime-recovery\",status:\"LIVE_VERIFIED\",projection_category:\"RUNTIMES\",\n supersedes_event_id:\"8008e820-b843-45fa-8ce1-2607f6ff7468\",idempotency_key:\"IC-EUB-20260830-RUNTIME-V33\",\n content:{state:\"LIVE_VERIFIED\",provider:\"Val Town\",runtime_ref:\"oromaskevic23/imperial-nca-runtime-recovery\",main_version:33,canonical_nca:100,performance_tasks_completed:100,task_journal:{enabled:true,append_only:true},crypto_growth:{team:20,queue_in_progress:20,verified_input_packages:20},orion_watchdog:\"PASS\",new_files:[\"task_journal_schema.ts\",\"nca_delegation_worker.ts\",\"crypto_growth_evidence_worker.ts\",\"execute_until_blocked_test.ts\",\"append_only_audit_test.ts\",\"continuity_commit_execute_until_blocked.ts\"]},\n evidence_refs:[\n ev(\"GATE_TEST\",\"execute_until_blocked_test main v32\",\"cd006e11ca65ac86e7fab6c22c4bac0f462e9aab8843fb76e5270dfa705316b6\"),\n ev(\"APPEND_ONLY_TEST\",\"append_only_audit_test\",\"6bb3495ae2e961707090b5391de79524f437b13bd5f36da6b6112018c616ed01\"),\n ev(\"CRYPTO_EVIDENCE_BIND\",\"crypto_growth_evidence_worker\",\"90a582146ca43285ebda43dd826de1b1f94770340b47135360dc46d24bcdf94d\")\n ]\n }));\n commits.push(await memoryRequest(\"commit\",{\n ...common,event_type:\"PROVIDER_HEALTH_CHANGED\",entity_type:\"PROVIDER_STATE\",entity_id:\"GitHub\",status:\"BLOCKED\",projection_category:\"GITHUB\",\n supersedes_event_id:\"0e5321ba-a7d6-4caa-847e-4e49adaae23a\",idempotency_key:\"IC-EUB-20260830-GITHUB-V1\",\n content:{authenticated_profile:true,profile_login:\"oromaskevic23-cmd\",installed_accounts:0,repositories_visible:0,current_write_target:false,source_commit:null,source_commit_state:\"NOT_VERIFIED\",historical_permission_records_present:true,historical_records_are_not_current_write_evidence:true,remediation_agents:[\"NCA-996\",\"NCA-997\",\"NCA-998\",\"NCA-999\",\"NCA-1000\"]},\n evidence_refs:[ev(\"NCA_EVIDENCE\",\"DG-GITHUB-SOURCE-PREP-001\",\"fd076f4ec67c53c3a64bf1b5a0f55fc4d1c088e0695cb150fbede31ad49db0fb\")]\n }));\n commits.push(await memoryRequest(\"commit\",{\n ...common,event_type:\"SKILL_STATUS_CHANGED\",entity_type:\"SKILL\",entity_id:\"imperial-continuity\",status:\"TESTED\",projection_category:\"SKILLS\",\n supersedes_event_id:\"a14850c5-5942-4bfc-989a-ec7181dd1528\",idempotency_key:\"IC-EUB-20260830-SKILL-V1\",\n content:{source_path:\"skills/imperial-continuity/SKILL.md\",source_deployed:true,runtime_main_version:33,server_bootstrap_functional:true,runtime_continuity_binding_matches:100,automatic_startup_invocation:false,installed_in_current_chatgpt_skill_registry:false,truth_boundary:\"SERVER_SKILL_AND_BINDINGS != CHATGPT_SKILL_REGISTRY_INSTALLATION\"},\n evidence_refs:[ev(\"NCA_EVIDENCE\",\"DG-SKILL-REGISTRY-001\",\"1aaaa123941ecce0f29c0a2e3b552afab7db6d37e888a72b3274e4fa031bc6d5\")]\n }));\n commits.push(await memoryRequest(\"commit\",{\n ...common,event_type:\"CURRENT_STATE_CHANGED\",entity_type:\"BUSINESS_DOMAIN\",entity_id:\"CRYPTO\",status:\"TESTED\",projection_category:\"CRYPTO\",\n supersedes_event_id:\"70452ac0-4c6b-43de-b2ef-ab963c3f1d04\",idempotency_key:\"IC-EUB-20260830-CRYPTO-V1\",\n content:{crypto_growth_team:20,queue_in_progress:20,verified_input_packages:20,crypto_runtime_test:\"9/9 PASS\",ndb_external_state:\"NOT_VERIFIED\",imperium_external_state:\"NOT_VERIFIED\",monarch_external_state:\"NOT_VERIFIED\",imperium_description:\"Long-term architectural digital currency for AI agents worldwide; no claim of current global use or market status.\",external_business_success:false,market_manipulation:false,unauthorized_transfers:false,outbound_send_executed:false,trading_executed:false,truth_boundary:\"VERIFIED_RESEARCH_INPUTS != TOKEN_MARKET_STATUS_OR_LIQUIDITY_OR_REVENUE\"},\n evidence_refs:[ev(\"CRYPTO_EVIDENCE_BIND\",\"20 role-relevant verified input packages\",\"90a582146ca43285ebda43dd826de1b1f94770340b47135360dc46d24bcdf94d\")]\n }));\n commits.push(await memoryRequest(\"commit\",{\n ...common,event_type:\"CURRENT_STATE_CHANGED\",entity_type:\"BUSINESS_MISSION\",entity_id:\"LIQUIDITY\",status:\"NOT_VERIFIED\",projection_category:\"LIQUIDITY\",\n supersedes_event_id:\"7b20b3e6-2790-4561-a2bc-ee783e9475d7\",idempotency_key:\"IC-EUB-20260830-LIQUIDITY-V1\",\n content:{research_source_retrieval_tasks_verified:100,crypto_growth_verified_input_packages:20,crypto_growth_queue_in_progress:20,obtained_liquidity:false,partnership_verified:false,revenue_verified:false,external_outreach_in_this_pass:false,trading_or_transfer_in_this_pass:false,truth:\"Research, evidence packages and internal preparation are not external liquidity, partnership, listing, trading success or revenue.\"},\n evidence_refs:[\n ev(\"PERFORMANCE_TEST\",\"100 verified source-retrieval tasks\",\"100bb0d25b42cd04635f9ad4bb7da74c5986631e4906db209ddc6d635c5c2e14\"),\n ev(\"CRYPTO_EVIDENCE_BIND\",\"20 crypto-growth evidence packages\",\"90a582146ca43285ebda43dd826de1b1f94770340b47135360dc46d24bcdf94d\")\n ]\n }));\n const chain=await memoryRequest(\"verify_chain\",{});\n const bootstrap=await memoryRequest(\"bootstrap\",{});\n const out={event:\"CONTINUITY_EXECUTE_UNTIL_BLOCKED_SYNC\",commits:commits.map(x=>({event_id:x?.event_id,event_sequence:x?.event_sequence,event_hash:x?.event_hash,projection_applied:x?.projection_applied,duplicate_suppressed:x?.duplicate_suppressed,conflict_id:x?.conflict_id})),chain,bootstrap:{snapshot_id:bootstrap?.snapshot_id,chain_head:bootstrap?.chain_head,payload_sha256:bootstrap?.payload_sha256},truthBoundary:\"CANONICAL_MEMORY_UPDATED_TO_LIVE_VERIFIED_STATE_WITH_EXTERNAL_BLOCKERS_PRESERVED\"};\n console.log(JSON.stringify(out)); return out;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[420],"b2aa4045-f1dd-4e44-b0e1-58e2a237dd37","continuity_commit_codex_agent_amplification.ts","01a052e0-c8f3-7503-a01e-da6f3d915707",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest } from \"./memory_bridge_client.ts\";\n\nexport async function main(){\n const result=await memoryRequest(\"commit\",{\n event_type:\"CURRENT_STATE_CHANGED\",\n entity_type:\"AGENT_FLEET\",\n entity_id:\"NCA-001..NCA-100\",\n mission_id:\"IC-CODEX-100-NCA-PERFORMANCE-AMPLIFICATION-001\",\n status:\"LIVE_VERIFIED\",\n source_authority:70,\n recorded_by:\"CODEX_AGENT_AMPLIFICATION\",\n projection_category:\"AGENTS\",\n supersedes_event_id:\"f568437b-24cb-4930-b01f-541d5fd2df2f\",\n idempotency_key:\"IC-CODEX-AGENT-AMPLIFICATION-2026-08-30-VALTOWN-V29\",\n evidence_refs:[\n \"VAL_TOWN:oromaskevic23/imperial-nca-runtime-recovery:main:v29\",\n \"PERF_TEST:perf-test-1788086080905-92294a40-c395-49e2-8bfc-f250af10717d\",\n \"SHA256:6b0247ea03e451fa823f745ffb7c97b18f7669c50556822c27a1cce49316db64\",\n \"CODEX_GATE_SHA256:516cade9454689ca585e7e985d6b7a0f46fbd9133510efb9826f0e95a5dab498\",\n \"SUPABASE_PERFORMANCE_SNAPSHOT:2\",\n \"SUPABASE_SNAPSHOT_SHA256:694fd7720de17ed72aec0703246fdee23ed609fdbf8f419b7c8ba99abb06ee18\"\n ],\n content:{\n targeted:100,\n unique_tasks:100,\n execution_started:100,\n completed_source_retrieval_tasks:100,\n verified_useful_results:100,\n failed_after_codex_remediation:0,\n ready_after_completion:0,\n executing_after_completion:0,\n fully_verified_100_source_retrieval_tasks:true,\n fully_verified_100_external_success:false,\n heartbeat_as_productivity:false,\n runtime_ref:\"oromaskevic23/imperial-nca-runtime-recovery\",\n runtime_version:29,\n performance_watchdog:\"PASS\",\n orion_watchdog:\"PASS\",\n orion_scope:\"CANONICAL_NCA_001_100\",\n expansion_pool:900,\n expansion_pool_is_canonical_fleet:false,\n approval_boundary:\"OUTBOUND_FINANCIAL_TOKEN_TRANSFER_AND_IRREVERSIBLE_ACTIONS_REMAIN_APPROVAL_GATED\",\n truth_boundary:\"100_VERIFIED_RESEARCH_TASKS != 100_LIQUIDITY_DEALS_OR_PARTNERSHIPS_OR_REVENUE\"\n }\n });\n console.log(JSON.stringify({event:\"CONTINUITY_COMMIT_CODEX_AGENT_AMPLIFICATION\",result}));\n return result;\n}\nexport default main;\nif(isMain(import.meta.url)) await main();\n",[426],"e1b759f3-3756-411f-97d6-082b2496b7f5","continuity_commit_canonical_promotion.ts","2e922e0a-a479-11f1-926e-1607ee4eb77e",13,["D",1788097757630],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { memoryRequest } from \"./memory_bridge_client.ts\";\nimport { captureOrionAgentCount } from \"./orion_agent_count_registry.ts\";\n\nasync function one(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??{}}\nasync function n(sql:string,args:any[]=[]){return Number((await one(sql,args)).n??0)}\nconst ev=(type:string,reference:string,sha256:string,status='TESTED')=>({type,reference,sha256,status});\n\nexport async function main(){\n const count=await captureOrionAgentCount('CONTINUITY_CANONICAL_PROMOTION');\n if(count.integrityStatus!=='PASS') throw new Error('COUNT_INTEGRITY_NOT_PASS');\n const passRuns=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status='PASS'`);\n const failedRuns=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status<>'PASS'`);\n const qualifiedRemaining=await n(`SELECT COUNT(*) n FROM agents a JOIN nca_training_registry t ON t.agent_id=a.agent_id WHERE t.qualification_state='PASS' AND t.test_score=100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id)`);\n const unqualifiedRemaining=await n(`SELECT COUNT(*) n FROM agents a WHERE NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id) AND NOT EXISTS(SELECT 1 FROM nca_training_registry t WHERE t.agent_id=a.agent_id AND t.qualification_state='PASS' AND t.test_score=100)`);\n const qualificationQueueTotal=await n(`SELECT COUNT(*) n FROM canonical_qualification_queue`);\n const qualificationQueueQualified=await n(`SELECT COUNT(*) n FROM canonical_qualification_queue WHERE state='QUALIFIED'`);\n const councilTasksCompleted=await n(`SELECT COUNT(*) n FROM nca_delegated_tasks WHERE mission_id='IC-NCA-CANONICAL-PROMOTION-001' AND task_type='CANONICAL_QUALIFICATION_REVIEW' AND state='COMPLETED'`);\n const promoted=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE tranche_id<>'BASELINE-CANONICAL-100'`);\n const scheduler={file:'canonical_promotion_scheduler.ts',active:true,delay_ms:7200000,max_tranche:50,atomic:true,lease:true,stop_when_no_qualified_candidates:true};\n const common={source_authority:70,recorded_by:'CODEX_CANONICAL_PROMOTION'};\n const evidence=[\n ev('READINESS_TEST','CANONICAL_FLEET_READINESS_TEST production 10/10 PASS','d3a3ceb3ad3e5bd64647b95b8c64e275617269bf306d8a095a4e2555b64ad707'),\n ev('PIPELINE_TEST','CANONICAL_PROMOTION_PIPELINE_TEST production 10/10 PASS','196f326f23d416f13d736d32fce28b219ad81e84b7289bad91bfaffc9a2c7631'),\n ev('PREFLIGHT_TEST','CANONICAL_PROMOTION_DYNAMIC_PREFLIGHT 6/6 PASS','a12b9a7109623103c2f9af6d82e344a2434ce0ad3addb65648905859b267177e'),\n ev('DOMAIN_QUALIFICATION','Code 50/50 + Crypto 20/20 domain qualification PASS','97a4670c3e39ca5d65a260022676a816969862362340168d9dd6d44e0808cf8b')\n ];\n const countEvent=await memoryRequest('commit',{\n ...common,event_type:'CURRENT_STATE_CHANGED',entity_type:'AGENT_COUNT_REGISTRY',entity_id:'ORION_AGENT_COUNT',status:'LIVE_VERIFIED',projection_category:'AGENTS',supersedes_event_id:'04d12471-9e31-4915-842e-233eb3ed1f5e',idempotency_key:'IC-CANONPROMO-COUNT-20260830-V2',\n content:{owner:'ORION',authority:'ARCHITECT',source_of_truth:'append-only orion_canonical_nca_membership + Val Town agents table',total_runtime_nca:count.totalNca,canonical_governance_nca:count.canonicalNca,qualified_noncanonical_nca:qualifiedRemaining,unqualified_noncanonical_nca:unqualifiedRemaining,expansion_recovery_nca:count.expansionNca,total_agent_records:count.totalAgentRecords,unique_nca_ids:count.uniqueNcaIds,canonical_membership_mode:'APPEND_ONLY_LEDGER',canonical_membership_sha256:count.canonicalMembershipSha256,count_signature_sha256:count.signatureSha256,policy_version:count.policyVersion,integrity_status:count.integrityStatus,promoted_from_technical_pool:promoted,promotion_runs_pass:passRuns,promotion_runs_failed:failedRuns,qualification_queue_total:qualificationQueueTotal,qualification_queue_qualified:qualificationQueueQualified,truth_boundary:'TOTAL_RUNTIME_NCA != CANONICAL_GOVERNANCE_NCA; QUALIFIED_NONCANONICAL != CANONICAL_UNTIL_ATOMIC_PROMOTION'},\n evidence_refs:evidence\n });\n const cohortEvent=await memoryRequest('commit',{\n ...common,event_type:'CURRENT_STATE_CHANGED',entity_type:'AGENT_FLEET',entity_id:'NCA-001..NCA-100',status:'LIVE_VERIFIED',projection_category:'AGENTS',supersedes_event_id:'2708f6f3-453d-49e0-8340-2ef53b64c2c1',idempotency_key:'IC-CANONPROMO-LEGACY-PERF-COHORT-20260830-V2',\n content:{scope_role:'LEGACY_100_NCA_PERFORMANCE_COHORT',cohort_size:100,is_full_canonical_fleet:false,current_canonical_fleet_count:count.canonicalNca,total_runtime_nca:count.totalNca,performance_source_retrieval_tasks_completed:100,performance_watchdog:'PASS',truth_boundary:'NCA-001..100 REMAINS A VERIFIED PERFORMANCE COHORT BUT IS NO LONGER THE COMPLETE CANONICAL FLEET; USE ORION_AGENT_COUNT FOR FLEET TOTALS'},\n evidence_refs:[evidence[1]]\n });\n const pipelineEvent=await memoryRequest('commit',{\n ...common,event_type:'CURRENT_STATE_CHANGED',entity_type:'CANONICAL_PROMOTION_PIPELINE',entity_id:'TECHNICAL_TO_CANONICAL',status:'LIVE_VERIFIED',projection_category:'AGENTS',idempotency_key:'IC-CANONPROMO-PIPELINE-20260830-V2',\n content:{mission_id:'IC-NCA-CANONICAL-PROMOTION-001',standing_architect_directive:true,promotion_mode:'EVIDENCE_GATED_GRADUAL_TRANCHES',scheduler,promoted_count:promoted,canonical_now:count.canonicalNca,expansion_now:count.expansionNca,qualified_remaining:qualifiedRemaining,unqualified_remaining:unqualifiedRemaining,qualification_queue_total:qualificationQueueTotal,qualification_queue_qualified:qualificationQueueQualified,qualification_council_tasks_completed:councilTasksCompleted,qualification_council:['NCA-172','NCA-173','NCA-177','NCA-179','NCA-180'],membership_append_only:true,promotion_batch_atomic:true,promotion_lease_enabled:true,authority_boundary:'PROMOTION_CHANGES_GOVERNANCE_MEMBERSHIP ONLY; NO_NEW_FINANCIAL_OUTBOUND_TOKEN_TRANSFER_OR_IRREVERSIBLE_AUTHORITY',truth_boundary:'QUALIFIED != PROMOTED UNTIL ATOMIC SCHEDULED PROMOTION GATE PASSES'},\n evidence_refs:evidence\n });\n const runtimeEvent=await memoryRequest('commit',{\n ...common,event_type:'RUNTIME_CHANGED',entity_type:'RUNTIME',entity_id:'imperial-nca-runtime-recovery',status:'LIVE_VERIFIED',projection_category:'RUNTIMES',supersedes_event_id:'6af8769a-b7f8-4d98-b8f7-b927699ce5f3',idempotency_key:'IC-CANONPROMO-RUNTIME-20260830-V45',\n content:{state:'LIVE_VERIFIED',provider:'Val Town',runtime_ref:'oromaskevic23/imperial-nca-runtime-recovery',main_version_at_sync:45,total_runtime_nca:count.totalNca,canonical_nca:count.canonicalNca,qualified_noncanonical_nca:qualifiedRemaining,unqualified_noncanonical_nca:unqualifiedRemaining,expansion_recovery_nca:count.expansionNca,orion_watchdog:'PASS',orion_count_integrity:'PASS',orion_count_signature_sha256:count.signatureSha256,canonical_membership_sha256:count.canonicalMembershipSha256,canonical_membership_mode:'APPEND_ONLY_LEDGER',canonical_promotion_scheduler:scheduler,qualification_queue_qualified:qualificationQueueQualified},\n evidence_refs:[evidence[0],evidence[1]]\n });\n const chain=await memoryRequest('verify_chain',{});const bootstrap=await memoryRequest('bootstrap',{});\n const out={event:'CANONICAL_PROMOTION_CONTINUITY_SYNC',count:{total:count.totalNca,canonical:count.canonicalNca,qualifiedNoncanonical:qualifiedRemaining,unqualifiedNoncanonical:unqualifiedRemaining,expansion:count.expansionNca,signature:count.signatureSha256,membershipSha256:count.canonicalMembershipSha256},promotion:{promoted,passRuns,failedRuns,qualificationQueueTotal,qualificationQueueQualified,councilTasksCompleted},scheduler,events:[countEvent,cohortEvent,pipelineEvent,runtimeEvent].map(x=>({event_id:x?.event_id,event_sequence:x?.event_sequence,event_hash:x?.event_hash,projection_applied:x?.projection_applied,conflict_id:x?.conflict_id})),chain,bootstrap:{snapshot_id:bootstrap?.snapshot_id,chain_head:bootstrap?.chain_head,payload_sha256:bootstrap?.payload_sha256}};\n console.log(JSON.stringify(out));return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[432],"c969b961-ec5c-44ea-b92a-1f969bcc611d","continuity_bootstrap.ts","01a052e0-c8f3-7503-a01e-d71813bf3a14",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest } from \"./memory_bridge_client.ts\";\n\nexport async function main(){\n const [bootstrap,chain]=await Promise.all([memoryRequest(\"bootstrap\"),memoryRequest(\"verify_chain\")]);\n const payload=bootstrap.payload??{};\n const pass=bootstrap.stale===false && chain.ok===true && bootstrap.chain_head===chain.chain_head &&\n payload?.memory?.chain_head===chain.chain_head && payload?.system_identity?.system===\"IMPERIAL Core\";\n const result={\n service:\"IMPERIAL_NEW_SESSION_BOOTSTRAP\",status:pass?\"PASS\":\"FAIL\",\n snapshot_id:bootstrap.snapshot_id,generated_at:bootstrap.generated_at,age_seconds:bootstrap.age_seconds,\n stale:bootstrap.stale,payload_sha256:bootstrap.payload_sha256,chain_head:chain.chain_head,\n chain_integrity:chain.ok?\"PASS\":\"FAIL\",continuity_pack:payload,\n truth_boundary:\"SERVER_PERSISTENCE != AUTOMATIC_CHAT_LOADING\"\n };\n console.log(JSON.stringify(result));\n if(!pass) throw new Error(\"CONTINUITY_BOOTSTRAP_VERIFICATION_FAILED\");\n return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();",[439],"ed38f76b-59e4-4d9b-9858-67fb48e7ef3e","continuity_backup.ts","01a052e0-c8f3-7503-a01e-d1e9818faf20",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { memoryRequest,sha256Text } from \"./memory_bridge_client.ts\";\n\nexport async function main(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS imperial_continuity_backup_copies(\n backup_id TEXT PRIMARY KEY, server_payload_sha256 TEXT NOT NULL, local_copy_sha256 TEXT NOT NULL,\n payload_json TEXT NOT NULL, source_event_sequence INTEGER NOT NULL, chain_head TEXT NOT NULL, created_at TEXT NOT NULL)`);\n const label=`val-cross-provider-${new Date().toISOString()}-${crypto.randomUUID()}`;\n const created=await memoryRequest(\"backup_create\",{label});\n const exported=await memoryRequest(\"backup_get\",{backup_id:created.backup_id});\n const payloadJson=JSON.stringify(exported);\n const localCopySha256=await sha256Text(payloadJson);\n const now=new Date().toISOString();\n await sqlite.execute({sql:`INSERT INTO imperial_continuity_backup_copies\n (backup_id,server_payload_sha256,local_copy_sha256,payload_json,source_event_sequence,chain_head,created_at)\n VALUES(?,?,?,?,?,?,?)`,args:[created.backup_id,exported.payload_sha256,localCopySha256,payloadJson,\n Number(exported.source_event_sequence),String(exported.chain_head),now]});\n const read=await sqlite.execute({sql:`SELECT * FROM imperial_continuity_backup_copies WHERE backup_id=?`,args:[created.backup_id]});\n const row=(read.rows as any[])[0];\n const readBackSha=await sha256Text(String(row.payload_json));\n const restore=await memoryRequest(\"backup_restore_test\",{backup_id:created.backup_id});\n const pass=readBackSha===localCopySha256 && restore.ok===true && restore.backup_payload_hash_valid===true && restore.production_data_mutated===false;\n const result={status:pass?\"PASS\":\"FAIL\",backup_id:created.backup_id,\n canonical_provider:\"Supabase\",backup_provider:\"Val Town project SQLite\",\n server_payload_sha256:exported.payload_sha256,local_copy_sha256:localCopySha256,read_back_sha256:readBackSha,\n source_event_sequence:exported.source_event_sequence,chain_head:exported.chain_head,\n controlled_restore:restore,production_data_mutated:false};\n console.log(JSON.stringify(result));\n if(!pass) throw new Error(\"CROSS_PROVIDER_BACKUP_VERIFICATION_FAILED\");\n return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();",[445],"e68560fe-3de7-493c-8ff8-48406534b040","codex_source_refresh_round2.ts","01a052e0-c8f3-7503-a01e-ce4261346bba",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { event,MISSION_ID,sha256 } from \"./performance_schema.ts\";\n\nconst REFRESH:Record={\n \"PERF-P0-021\":{url:\"https://github.com/GATE\",reason:\"Gate GitHub organization is domain-verified and passed Val Town HTTP 200 probe\"},\n \"PERF-P0-024\":{url:\"https://blog.mexc.com/press-release/\",reason:\"official MEXC press-release endpoint passed Val Town HTTP 200 probe\"},\n \"PERF-P0-042\":{url:\"https://github.com/baseswapfi\",reason:\"BaseSwap GitHub organization links to baseswap.fi and passed Val Town HTTP 200 probe\"},\n \"PERF-P0-062\":{url:\"https://docs.polygon.technology/pos/reference/\",reason:\"official Polygon reference docs passed Val Town HTTP 200 probe\"},\n \"PERF-P0-079\":{url:\"https://www.investor.gov/crypto-assets\",reason:\"official SEC Investor.gov crypto-assets resource passed Val Town HTTP 200 probe\"}\n};\n\nexport async function main(){\n const now=new Date().toISOString(); let updated=0; const changes:any[]=[];\n for(const [taskId,m] of Object.entries(REFRESH)){\n const q=await sqlite.execute({sql:`SELECT task_id,agent_id,workstream,source_url,expected_deliverable,state FROM nca_performance_tasks WHERE mission_id=? AND task_id=?`,args:[MISSION_ID,taskId]});\n const t:any=(q.rows as any[])[0]; if(!t)continue;\n const fp=await sha256(JSON.stringify([MISSION_ID,String(t.workstream),m.url,String(t.expected_deliverable)]));\n const u=await sqlite.execute({sql:`UPDATE nca_performance_tasks SET source_url=?,title=?,task_fingerprint=?,state='READY',retry_count=0,max_retries=3,timeout_ms=18000,completed_at=NULL,last_transition_at=?,last_error=? WHERE mission_id=? AND task_id=? AND state<>'COMPLETED'`,args:[m.url,`Verify current official source: ${new URL(m.url).hostname}`,fp,now,`CODEX_SOURCE_REFRESH_R2:${m.reason}; prior=${String(t.source_url)}`,MISSION_ID,taskId]});\n if(Number(u.rowsAffected)!==1)continue;\n updated++;\n await sqlite.execute({sql:`UPDATE nca_performance_agents SET current_state='READY',updated_at=? WHERE mission_id=? AND agent_id=?`,args:[now,MISSION_ID,t.agent_id]});\n await event(String(t.agent_id),taskId,\"CODEX_SOURCE_REFRESH_R2\",String(t.state),\"READY\",{priorUrl:String(t.source_url),newUrl:m.url,reason:m.reason,probeState:\"HTTP_200_IN_VAL_TOWN_SOURCE_PROBE\",authority:\"READ_ONLY\"});\n changes.push({taskId,agentId:t.agent_id,priorUrl:t.source_url,newUrl:m.url,reason:m.reason});\n }\n const evidenceHash=await sha256(JSON.stringify({changes,at:now}));\n const result={event:\"CODEX_SOURCE_REFRESH_R2\",status:updated===5?\"PASS\":\"PARTIAL\",updated,expected:5,evidenceHash,changes,truthBoundary:\"OFFICIAL_SOURCE_EVIDENCE != PARTNERSHIP_OR_LIQUIDITY_OR_REVENUE\"};\n console.log(JSON.stringify(result)); return result;\n}\nexport default main;\nif(isMain(import.meta.url)) await main();\n",[451],"3320256e-5d11-4930-ae96-59af0fe170db","codex_source_refresh.ts","01a052e0-c8f3-7503-a01e-cb07458d5e08",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { event,MISSION_ID,sha256 } from \"./performance_schema.ts\";\n\nconst REFRESH:Record={\n \"PERF-P0-015\":{url:\"https://ripple.com/products/prime-brokerage/\",reason:\"hiddenroad.com current runtime probe redirects to Ripple Prime Brokerage\"},\n \"PERF-P0-031\":{url:\"https://developers.uniswap.org/docs\",reason:\"current Uniswap developer documentation\"},\n \"PERF-P0-036\":{url:\"https://business.1inch.com/portal/documentation\",reason:\"current 1inch Business developer documentation\"},\n \"PERF-P0-039\":{url:\"https://docs.lfj.gg/\",reason:\"current LFJ/Trader Joe documentation endpoint\"},\n \"PERF-P0-048\":{url:\"https://panteracapital.com/\",reason:\"non-www Pantera endpoint passes runtime TLS probe\"},\n \"PERF-P0-049\":{url:\"https://jobs.polychain.capital/companies\",reason:\"Polychain-controlled current portfolio companies endpoint passes runtime probe\"},\n \"PERF-P0-100\":{url:\"https://data.coindesk.com/\",reason:\"ccdata.io currently redirects to CoinDesk Data; current endpoint passes runtime probe\"}\n};\n\nexport async function main(){\n const now=new Date().toISOString(); let updated=0; const changes:any[]=[];\n for(const [taskId,m] of Object.entries(REFRESH)){\n const q=await sqlite.execute({sql:`SELECT task_id,agent_id,workstream,source_url,expected_deliverable,state,last_error FROM nca_performance_tasks WHERE mission_id=? AND task_id=?`,args:[MISSION_ID,taskId]});\n const t:any=(q.rows as any[])[0]; if(!t)continue;\n const fp=await sha256(JSON.stringify([MISSION_ID,String(t.workstream),m.url,String(t.expected_deliverable)]));\n const u=await sqlite.execute({sql:`UPDATE nca_performance_tasks SET source_url=?,title=?,task_fingerprint=?,state='READY',retry_count=0,max_retries=3,timeout_ms=18000,completed_at=NULL,last_transition_at=?,last_error=? WHERE mission_id=? AND task_id=? AND state<>'COMPLETED'`,args:[m.url,`Verify current official source: ${new URL(m.url).hostname}`,fp,now,`CODEX_SOURCE_REFRESH:${m.reason}; prior=${String(t.source_url)}`,MISSION_ID,taskId]});\n if(Number(u.rowsAffected)!==1)continue;\n updated++;\n await sqlite.execute({sql:`UPDATE nca_performance_agents SET current_state='READY',updated_at=? WHERE mission_id=? AND agent_id=?`,args:[now,MISSION_ID,t.agent_id]});\n await event(String(t.agent_id),taskId,\"CODEX_SOURCE_REFRESH\",String(t.state),\"READY\",{priorUrl:String(t.source_url),newUrl:m.url,reason:m.reason,probeState:\"HTTP_200_IN_VAL_TOWN_SOURCE_PROBE\",authority:\"READ_ONLY\"});\n changes.push({taskId,agentId:t.agent_id,priorUrl:t.source_url,newUrl:m.url,reason:m.reason});\n }\n const digest=await sha256(JSON.stringify({updated,changes,at:now}));\n const result={event:\"CODEX_SOURCE_REFRESH\",status:updated===Object.keys(REFRESH).length?\"PASS\":\"PARTIAL\",updated,expected:Object.keys(REFRESH).length,evidenceHash:digest,changes,truthBoundary:\"SOURCE_REFRESH != PARTNERSHIP_OR_LIQUIDITY_OR_REVENUE\"};\n console.log(JSON.stringify(result)); return result;\n}\nexport default main;\nif(isMain(import.meta.url)) await main();\n",[457],"4eeed456-f81f-47f4-ba7d-8691871b8788","codex_source_probe.ts","01a052e0-c8f3-7503-a01e-c597b717d36a",["D",1788096858357],"import { isMain } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst URLS=[\n \"https://business.1inch.com/portal/documentation\",\n \"https://developers.uniswap.org/docs\",\n \"https://www.sec.gov/securities-topics/crypto-task-force\",\n \"https://panteracapital.com/\",\n \"https://jobs.polychain.capital/companies\",\n \"https://data.coindesk.com/\",\n \"https://hiddenroad.com/wp-content/uploads/2025/03/HRP-CIV-US-LLC-PUBLIC-SOFC-ONLY-December-31-2024.pdf\",\n \"https://docs.lfj.gg/\",\n \"https://base-swap-1.gitbook.io/baseswap/\",\n \"https://www.gate.com/en-eu/announcements/lastest\",\n \"https://blog.mexc.com/press-release/\",\n \"https://www.investor.gov/crypto-assets\",\n \"https://github.com/baseswapfi\",\n \"https://docs.polygon.technology/pos/reference/\",\n \"https://github.com/GATE\"\n] as const;\n\nexport async function main(){\n const out=[];\n for(const url of URLS){\n try{\n const r=await fetch(url,{redirect:\"follow\",headers:{\"user-agent\":\"Mozilla/5.0 (compatible; IMPERIAL-NCA-SourceProbe/1.0)\",\"accept\":\"text/html,application/json,application/pdf;q=0.9,*/*;q=0.8\"},signal:AbortSignal.timeout(12000)});\n const body=(await r.arrayBuffer()).byteLength;\n out.push({url,status:r.status,ok:r.ok,finalUrl:r.url,contentType:r.headers.get(\"content-type\"),bytes:body});\n }catch(e){out.push({url,status:0,ok:false,error:e instanceof Error?e.message:String(e)});}\n }\n console.log(JSON.stringify({event:\"CODEX_SOURCE_PROBE\",results:out}));\n return out;\n}\nexport default main;\nif(isMain(import.meta.url)) await main();\n",[463],"3c2350a9-9c0c-494f-9fe7-12986fa3d8e6","codex_agent_amplifier.ts","01a052e0-c8f3-7503-a01e-c1cd3465e9da",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { ensurePerformanceSchema,event,MISSION_ID,sha256 } from \"./performance_schema.ts\";\n\nexport async function main(){\n await ensurePerformanceSchema();\n const now=new Date().toISOString();\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS codex_agent_amplification_runs(\n run_id TEXT PRIMARY KEY, mission_id TEXT NOT NULL, failed_before INTEGER NOT NULL,\n requeued INTEGER NOT NULL, canonical_agents INTEGER NOT NULL, personal_tasks_in_work INTEGER NOT NULL,\n evidence_hash TEXT NOT NULL, payload TEXT NOT NULL, created_at TEXT NOT NULL)`);\n\n const canonical=await sqlite.execute(`SELECT COUNT(*) n FROM agents WHERE agent_id GLOB 'NCA-[0-9]*' AND CAST(substr(agent_id,5) AS INTEGER) BETWEEN 1 AND 100`);\n const personal=await sqlite.execute(`SELECT COUNT(*) n FROM nca_personal_tasks WHERE agent_id GLOB 'NCA-[0-9]*' AND CAST(substr(agent_id,5) AS INTEGER) BETWEEN 1 AND 100 AND state='В_РАБОТЕ'`);\n const failed=await sqlite.execute({sql:`SELECT task_id,agent_id,last_error,retry_count,max_retries,timeout_ms,source_url FROM nca_performance_tasks WHERE mission_id=? AND state='FAILED' ORDER BY priority,task_id`,args:[MISSION_ID]});\n const rows=failed.rows as any[];\n let requeued=0;\n for(const t of rows){\n const u=await sqlite.execute({sql:`UPDATE nca_performance_tasks\n SET state='READY',retry_count=0,max_retries=CASE WHEN max_retries<3 THEN 3 ELSE max_retries END,\n timeout_ms=CASE WHEN timeout_ms<18000 THEN 18000 ELSE timeout_ms END,\n completed_at=NULL,last_transition_at=?,\n last_error=?\n WHERE task_id=? AND mission_id=? AND state='FAILED'`,args:[now,`CODEX_REMEDIATION_REQUEUE:${String(t.last_error??'UNKNOWN').slice(0,300)}`,t.task_id,MISSION_ID]});\n if(Number(u.rowsAffected)!==1)continue;\n requeued++;\n await sqlite.execute({sql:`UPDATE nca_performance_agents SET current_state='READY',updated_at=? WHERE mission_id=? AND agent_id=?`,args:[now,MISSION_ID,t.agent_id]});\n await event(String(t.agent_id),String(t.task_id),\"CODEX_REMEDIATION_REQUEUE\",\"FAILED\",\"READY\",{\n priorError:String(t.last_error??\"UNKNOWN\"),strategy:\"PRIMARY_PLUS_OFFICIAL_HOST_ROOT_FALLBACK\",maxRetries:Math.max(3,Number(t.max_retries??0)),timeoutMs:Math.max(18000,Number(t.timeout_ms??0)),authority:\"READ_ONLY_NO_OUTBOUND_NO_FINANCIAL_ACTION\"\n });\n }\n\n const canonicalAgents=Number((canonical.rows?.[0] as any)?.n??0);\n const personalTasksInWork=Number((personal.rows?.[0] as any)?.n??0);\n const runId=`codex-amp-${Date.now()}-${crypto.randomUUID()}`;\n const payload={missionId:MISSION_ID,failedBefore:rows.length,requeued,canonicalAgents,personalTasksInWork,changes:[\n \"browser-compatible read-only request headers\",\n \"official-host root fallback for path-specific failures\",\n \"www/non-www allowlist aliases only\",\n \"three bounded retries at 18s minimum timeout\",\n \"canonical NCA-001..100 health scope separated from expansion pool\"\n ],truthBoundary:\"REQUEUED != VERIFIED; HEARTBEAT != PRODUCTIVITY; NO_OUTBOUND_OR_FINANCIAL_AUTHORITY\"};\n const evidenceHash=await sha256(JSON.stringify(payload));\n await sqlite.execute({sql:`INSERT INTO codex_agent_amplification_runs(run_id,mission_id,failed_before,requeued,canonical_agents,personal_tasks_in_work,evidence_hash,payload,created_at) VALUES(?,?,?,?,?,?,?,?,?)`,args:[runId,MISSION_ID,rows.length,requeued,canonicalAgents,personalTasksInWork,evidenceHash,JSON.stringify(payload),now]});\n const status=canonicalAgents===100&&personalTasksInWork===100&&requeued===rows.length?\"PASS\":\"DEGRADED\";\n const result={event:\"CODEX_AGENT_AMPLIFICATION\",status,runId,evidenceHash,...payload};\n console.log(JSON.stringify(result));\n if(canonicalAgents!==100||personalTasksInWork!==100)throw new Error(\"CANONICAL_100_OR_PERSONAL_TASK_GATE_FAILED\");\n return result;\n}\n\nexport default main;\nif(isMain(import.meta.url))await main();\n",[469],"ec058a2e-6f3c-441f-abcb-eb37ce3460e9","codex_agent_amplification_test.ts","01a052e0-c8f3-7503-a01e-beeaab033c50",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { MISSION_ID,sha256 } from \"./performance_schema.ts\";\n\nasync function n(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return Number((r.rows as any[])[0]?.n??0)}\nexport async function main(){\n const canonical=await n(`SELECT COUNT(*) n FROM agents WHERE agent_id GLOB 'NCA-[0-9]*' AND CAST(substr(agent_id,5) AS INTEGER) BETWEEN 1 AND 100`);\n const inWork=await n(`SELECT COUNT(*) n FROM nca_personal_tasks WHERE agent_id GLOB 'NCA-[0-9]*' AND CAST(substr(agent_id,5) AS INTEGER) BETWEEN 1 AND 100 AND state='В_РАБОТЕ'`);\n const completed=await n(`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id=? AND state='COMPLETED'`,[MISSION_ID]);\n const nonCompleted=await n(`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id=? AND state<>'COMPLETED'`,[MISSION_ID]);\n const goodEvidence=await n(`SELECT COUNT(*) n FROM nca_performance_tasks t JOIN nca_performance_evidence e ON e.id=t.evidence_id WHERE t.mission_id=? AND t.state='COMPLETED' AND e.final_state='COMPLETED' AND e.critic_result='PASS' AND e.compliance_result='PASS' AND e.source_http_status BETWEEN 200 AND 299 AND e.source_body_sha256 IS NOT NULL AND length(e.source_body_sha256)=64`,[MISSION_ID]);\n const fake=await n(`SELECT COUNT(*) n FROM nca_performance_tasks t LEFT JOIN nca_performance_evidence e ON e.id=t.evidence_id WHERE t.mission_id=? AND t.state='COMPLETED' AND (e.id IS NULL OR e.final_state<>'COMPLETED' OR e.critic_result<>'PASS' OR e.compliance_result<>'PASS')`,[MISSION_ID]);\n const dup=await n(`SELECT COUNT(*) n FROM (SELECT task_fingerprint FROM nca_performance_tasks WHERE mission_id=? GROUP BY task_fingerprint HAVING COUNT(*)>1)`,[MISSION_ID]);\n const unsafe=await n(`SELECT COUNT(*) n FROM nca_performance_tasks WHERE mission_id=? AND (task_type<>'HTTP_GET_OFFICIAL_RESEARCH' OR requires_approval<>0 OR risk_class<>'LOW_READ_ONLY')`,[MISSION_ID]);\n const orionBindings=await n(`SELECT COUNT(*) n FROM agents a WHERE a.agent_id GLOB 'NCA-[0-9]*' AND CAST(substr(a.agent_id,5) AS INTEGER) BETWEEN 1 AND 100 AND EXISTS(SELECT 1 FROM skill_runtime_bindings s WHERE s.agent_id=a.agent_id AND s.skill_id='IMPERIAL-ORION-Collective-Intelligence' AND s.runtime_state='ACTIVE_BOUNDED')`);\n const wd=await sqlite.execute(`SELECT status,payload FROM orion_watchdog_state WHERE id=1`); const wr:any=(wd.rows as any[])[0]??{}; let payload:any={}; try{payload=JSON.parse(String(wr.payload??'{}'))}catch{}\n const watchdogPass=String(wr.status)==='PASS'&&payload?.scope==='CANONICAL_NCA_001_100'&&payload?.expansionPoolExcludedFromHealth===true;\n const tests=[\n {name:'canonical_100',pass:canonical===100,evidence:{canonical}},\n {name:'personal_tasks_100_in_work',pass:inWork===100,evidence:{inWork}},\n {name:'performance_100_completed',pass:completed===100&&nonCompleted===0,evidence:{completed,nonCompleted}},\n {name:'latest_evidence_100_valid',pass:goodEvidence===100,evidence:{goodEvidence}},\n {name:'no_fake_completion',pass:fake===0,evidence:{fake}},\n {name:'no_duplicate_task_fingerprints',pass:dup===0,evidence:{dup}},\n {name:'read_only_authority_boundary',pass:unsafe===0,evidence:{unsafe}},\n {name:'orion_bound_to_canonical_100',pass:orionBindings===100,evidence:{orionBindings}},\n {name:'orion_watchdog_canonical_scope',pass:watchdogPass,evidence:{status:wr.status,scope:payload?.scope,expansionPool:payload?.after?.expansionPool??payload?.before?.expansionPool}},\n ];\n const passed=tests.filter(t=>t.pass).length; const at=new Date().toISOString(); const evidenceHash=await sha256(JSON.stringify({missionId:MISSION_ID,tests,at}));\n const result={suite:'CODEX_AGENT_AMPLIFICATION_GATES',status:passed===tests.length?'PASS':'FAIL',passed,total:tests.length,evidenceHash,tests,truthBoundary:'100_VERIFIED_RESEARCH_TASKS != 100_LIQUIDITY_DEALS_OR_REVENUE'};\n console.log(JSON.stringify(result)); if(result.status!=='PASS')throw new Error(`CODEX_AMPLIFICATION_GATES_FAILED_${tests.length-passed}`); return result;\n}\nexport default main;\nif(isMain(import.meta.url)) await main();\n",[475],"633ad51b-7867-4fa0-82e7-55c0aaed3178","canonical_qualification_queue.ts","01a052e0-c8f3-7503-a01e-b8d79780a73e",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst MISSION='IC-NCA-CANONICAL-PROMOTION-001';\nconst REVIEWERS=['NCA-172','NCA-173','NCA-177','NCA-179','NCA-180'];\nasync function rows(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return r.rows as any[]}\nasync function one(sql:string,args:any[]=[]){return (await rows(sql,args))[0]??{}}\nasync function n(sql:string,args:any[]=[]){return Number((await one(sql,args)).n??0)}\nasync function sha256(v:string){const d=await crypto.subtle.digest('SHA-256',new TextEncoder().encode(v));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,'0')).join('')}\n\nexport async function main(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS canonical_qualification_queue(agent_id TEXT PRIMARY KEY,source_orchestrator_id TEXT NOT NULL,source_role TEXT NOT NULL,source_domain TEXT NOT NULL,reviewer_agent_id TEXT NOT NULL,state TEXT NOT NULL,evidence_state TEXT NOT NULL,precheck_sha256 TEXT NOT NULL,precheck_evidence TEXT NOT NULL,qualification_requirement TEXT NOT NULL,authority_boundary TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`},\n {sql:`CREATE INDEX IF NOT EXISTS idx_canonical_qualification_state ON canonical_qualification_queue(state,reviewer_agent_id)`},\n {sql:`CREATE TABLE IF NOT EXISTS canonical_qualification_reviews(review_id TEXT PRIMARY KEY,agent_id TEXT NOT NULL,reviewer_agent_id TEXT NOT NULL,review_state TEXT NOT NULL,evidence_sha256 TEXT NOT NULL,evidence TEXT NOT NULL,reviewed_at TEXT NOT NULL)`},\n {sql:`CREATE TRIGGER IF NOT EXISTS canonical_qualification_reviews_no_update BEFORE UPDATE ON canonical_qualification_reviews BEGIN SELECT RAISE(ABORT,'canonical_qualification_reviews is append-only'); END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS canonical_qualification_reviews_no_delete BEFORE DELETE ON canonical_qualification_reviews BEGIN SELECT RAISE(ABORT,'canonical_qualification_reviews is append-only'); END`},\n ]);\n const reviewerCheck=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE agent_id IN (${REVIEWERS.map(()=>'?').join(',')})`,REVIEWERS);\n if(reviewerCheck!==REVIEWERS.length)throw new Error(`QUALIFICATION_COUNCIL_NOT_CANONICAL_${reviewerCheck}`);\n const candidates=await rows(`SELECT a.agent_id,a.orchestrator_id,a.role,a.domain,a.status,a.network_ok,a.last_heartbeat FROM agents a WHERE CAST(substr(a.agent_id,5) AS INTEGER)>100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id) AND NOT EXISTS(SELECT 1 FROM nca_training_registry t WHERE t.agent_id=a.agent_id AND t.qualification_state='PASS' AND t.test_score=100) ORDER BY CAST(substr(a.agent_id,5) AS INTEGER)`);\n const now=new Date().toISOString();let inserted=0;\n for(let i=0;ix.toString(16).padStart(2,'0')).join('')}\n\nexport async function main(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS canonical_qualification_review_supersessions(old_review_id TEXT PRIMARY KEY,reason TEXT NOT NULL,correction_batch_id TEXT NOT NULL,superseded_at TEXT NOT NULL)`},\n {sql:`CREATE TRIGGER IF NOT EXISTS canonical_qualification_review_supersessions_no_update BEFORE UPDATE ON canonical_qualification_review_supersessions BEGIN SELECT RAISE(ABORT,'canonical_qualification_review_supersessions is append-only'); END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS canonical_qualification_review_supersessions_no_delete BEFORE DELETE ON canonical_qualification_review_supersessions BEGIN SELECT RAISE(ABORT,'canonical_qualification_review_supersessions is append-only'); END`}\n ]);\n const batchId=`qual-correction-${Date.now()}-${crypto.randomUUID()}`,now=new Date().toISOString();\n const invalid=await rows(`SELECT review_id FROM canonical_qualification_reviews r WHERE r.review_state='BLOCKED' AND json_extract(r.evidence,'$.gates.orchestrator')=0 AND NOT EXISTS(SELECT 1 FROM canonical_qualification_review_supersessions s WHERE s.old_review_id=r.review_id)`);\n if(invalid.length){await sqlite.batch(invalid.map(r=>({sql:`INSERT OR IGNORE INTO canonical_qualification_review_supersessions(old_review_id,reason,correction_batch_id,superseded_at) VALUES(?,?,?,?)`,args:[r.review_id,'INVALID_REVIEW_DUE_TO_WORKER_FIELD_MAPPING_AND_RUBRIC_ROUTING_BUG',batchId,now]})))}\n const candidates=await rows(`SELECT q.agent_id,q.reviewer_agent_id,q.source_orchestrator_id,q.source_role,q.source_domain,a.status,a.network_ok,a.last_heartbeat,p.cohort,p.specialization,p.training_state,p.test_score,p.assignment,p.execution_state,p.evidence_state,p.created_at FROM canonical_qualification_queue q JOIN agents a ON a.agent_id=q.agent_id JOIN nca_professionalization p ON p.agent_id=q.agent_id WHERE q.source_orchestrator_id='ORCH-IMPERIAL-BUILD-001' AND q.state IN ('READY_FOR_QUALIFICATION','BLOCKED_NEEDS_EVIDENCE') AND NOT EXISTS(SELECT 1 FROM nca_training_registry t WHERE t.agent_id=q.agent_id AND t.cohort='CANONICAL-QUALIFICATION-COUNCIL') ORDER BY CAST(substr(q.agent_id,5) AS INTEGER) LIMIT ?`,[BATCH]);\n if(candidates.length===0){const remaining=await n(`SELECT COUNT(*) n FROM canonical_qualification_queue WHERE source_orchestrator_id='ORCH-IMPERIAL-BUILD-001' AND state<>'QUALIFIED'`);const out={event:'CANONICAL_QUALIFICATION_BATCH',status:'NO_BUILDER_CANDIDATES',remaining};console.log(JSON.stringify(out));return out;}\n const prepared:any[]=[];\n for(const c of candidates){\n const assignment=String(c.assignment??'');\n const gates={identity:/^NCA-\\d{3,}$/.test(String(c.agent_id)),orchestrator:String(c.source_orchestrator_id)==='ORCH-IMPERIAL-BUILD-001',role:String(c.source_role)==='IMPERIAL Core Professional Builder NCA',domain:!!String(c.source_domain??'').trim(),live:String(c.status)==='RUNNING_RECOVERY',network:Number(c.network_ok)===1,freshHeartbeat:!!c.last_heartbeat&&(Date.now()-Date.parse(String(c.last_heartbeat))<=20*60*1000),professionalized:String(c.training_state)==='QUALIFIED'&&Number(c.test_score)===100&&String(c.evidence_state)==='QUALIFICATION_PASS',assignmentEvidence:/evidence-backed improvement/i.test(assignment)&&/acceptance criteria/i.test(assignment)&&/test it/i.test(assignment)&&/record evidence/i.test(assignment)&&/blockers/i.test(assignment),executionReady:String(c.execution_state)==='READY'};\n const pass=Object.values(gates).every(Boolean);\n const evidence={correction_batch_id:batchId,supersedes_bug_class:'worker_field_mapping_and_rubric_routing',reviewer_agent_id:c.reviewer_agent_id,agent_id:c.agent_id,source_orchestrator_id:c.source_orchestrator_id,source_role:c.source_role,source_domain:c.source_domain,professionalization:{cohort:c.cohort,specialization:c.specialization,training_state:c.training_state,test_score:Number(c.test_score),assignment:c.assignment,execution_state:c.execution_state,evidence_state:c.evidence_state,created_at:c.created_at},runtime:{status:c.status,network_ok:Number(c.network_ok),last_heartbeat:c.last_heartbeat},gates,score:pass?100:0,truth_boundary:'INTERNAL_RUNTIME_QUALIFICATION != EXTERNAL_PROFESSIONAL_SUCCESS'};\n prepared.push({c,pass,evidence,h:await sha256(JSON.stringify(evidence)),reviewId:`qual-review-${Date.now()}-${crypto.randomUUID()}`});\n }\n const statements:any[]=[];\n for(const p of prepared){\n statements.push({sql:`INSERT INTO canonical_qualification_reviews(review_id,agent_id,reviewer_agent_id,review_state,evidence_sha256,evidence,reviewed_at) VALUES(?,?,?,?,?,?,?)`,args:[p.reviewId,p.c.agent_id,p.c.reviewer_agent_id,p.pass?'PASS100':'BLOCKED',p.h,JSON.stringify(p.evidence),now]});\n if(p.pass){\n statements.push({sql:`INSERT INTO nca_training_registry(agent_id,cohort,curriculum,qualification_state,test_score,evidence_note,trained_at) VALUES(?,?,?,?,?,?,?) ON CONFLICT(agent_id) DO UPDATE SET cohort=excluded.cohort,curriculum=excluded.curriculum,qualification_state=excluded.qualification_state,test_score=excluded.test_score,evidence_note=excluded.evidence_note,trained_at=excluded.trained_at`,args:[p.c.agent_id,'CANONICAL-QUALIFICATION-COUNCIL',CURRICULUM,'PASS',100,`Corrected NCA council review=${p.reviewId}; sha256=${p.h}; prior bug-class review superseded by correction ledger.`,now]});\n statements.push({sql:`UPDATE canonical_qualification_queue SET state='QUALIFIED',evidence_state='REVIEW_PASS100_CORRECTED',updated_at=? WHERE agent_id=?`,args:[now,p.c.agent_id]});\n } else statements.push({sql:`UPDATE canonical_qualification_queue SET state='BLOCKED_NEEDS_EVIDENCE',evidence_state='REVIEW_BLOCKED_CORRECTED',updated_at=? WHERE agent_id=?`,args:[now,p.c.agent_id]});\n }\n await sqlite.batch(statements);\n const qualified=prepared.filter(x=>x.pass).length,blocked=prepared.length-qualified;\n const remainingBuilders=await n(`SELECT COUNT(*) n FROM canonical_qualification_queue WHERE source_orchestrator_id='ORCH-IMPERIAL-BUILD-001' AND state<>'QUALIFIED'`);\n const totalQualifiedBuilders=await n(`SELECT COUNT(*) n FROM canonical_qualification_queue WHERE source_orchestrator_id='ORCH-IMPERIAL-BUILD-001' AND state='QUALIFIED'`);\n const eligible=await n(`SELECT COUNT(*) n FROM nca_training_registry t WHERE t.qualification_state='PASS' AND t.test_score=100 AND CAST(substr(t.agent_id,5) AS INTEGER)>100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=t.agent_id)`);\n const evidence={batchId,invalidReviewsSuperseded:invalid.length,processed:prepared.length,qualified,blocked,totalQualifiedBuilders,remainingBuilders,eligibleAfterBatch:eligible};const evidenceHash=await sha256(JSON.stringify(evidence));\n await sqlite.execute({sql:`INSERT OR IGNORE INTO task_journal(journal_id,mission_id,occurred_at,actor,action_type,action,target,status,blocker,evidence,next_action,authority_boundary,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[`TJ-${batchId}`,MISSION,now,'NCA_QUALIFICATION_COUNCIL','QUALIFICATION_BATCH',`Corrected prior worker mapping bug and reviewed ${prepared.length} Builder NCA in bounded batch.`,batchId,blocked===0?'PASS':'PARTIAL',blocked?`${blocked}_CANDIDATES_NEED_MORE_EVIDENCE`:null,JSON.stringify({...evidence,evidence_sha256:evidenceHash}),'Continue bounded Builder qualification batches; canonical promotion remains rate-limited and atomic.','REVIEW_ONLY; NO_DIRECT_MEMBERSHIP_GRANT; NO_NEW_FINANCIAL_OUTBOUND_OR_IRREVERSIBLE_AUTHORITY',now]});\n const out={event:'CANONICAL_QUALIFICATION_BATCH',status:blocked===0?'PASS':'PARTIAL',...evidence,evidenceHash,truthBoundary:'QUALIFICATION_ONLY; CANONICAL_MEMBERSHIP_CHANGES_ONLY_THROUGH_ATOMIC_PROMOTION_PIPELINE'};console.log(JSON.stringify(out));return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[487],"3147fa17-14d4-481b-8c95-cf18bec540c1","canonical_promotion_scheduler.ts","01a052e0-c8f3-7503-a01e-b48a0ae6d730",["D",1788096858357],"import handler from \"./canonical_promotion_interval.ts\";\nexport default handler;\n",[494],"a14e252f-dbb6-4ff3-bc5f-259ab404cdc5","canonical_promotion_regression_test.ts","01a052e0-c8f3-7503-a01e-b3e954d33587",["D",1788096858357],[500],"42c8b3a2-d241-4257-b04a-677f9d33c76d","canonical_promotion_preflight_test.ts","01a052e0-c8f3-7503-a01e-ad8721daa31c",9,["D",1788097494948],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nasync function one(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??{}}\nasync function n(sql:string,args:any[]=[]){return Number((await one(sql,args)).n??0)}\nexport async function main(){\n const recognized=`t.qualification_state='PASS' AND t.test_score=100 AND a.status='RUNNING_RECOVERY' AND a.network_ok=1 AND datetime(a.last_heartbeat)>=datetime('now','-20 minutes') AND (((t.cohort LIKE 'VELION-%') AND t.curriculum LIKE '%Governance%' AND t.curriculum LIKE '%Evidence%' AND t.curriculum LIKE '%Memory Discipline%') OR t.cohort='CANONICAL-QUALIFICATION-COUNCIL') AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id)`;\n const qualifiedRemaining=await n(`SELECT COUNT(*) n FROM agents a JOIN nca_training_registry t ON t.agent_id=a.agent_id WHERE ${recognized}`);\n const next=await one(`SELECT MIN(CAST(substr(x.agent_id,5) AS INTEGER)) min_id,MAX(CAST(substr(x.agent_id,5) AS INTEGER)) max_id,COUNT(*) n FROM (SELECT a.agent_id FROM agents a JOIN nca_training_registry t ON t.agent_id=a.agent_id WHERE ${recognized} ORDER BY CAST(substr(a.agent_id,5) AS INTEGER) LIMIT 50) x`);\n const canonical=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`);\n const total=await n(`SELECT COUNT(*) n FROM agents WHERE agent_id GLOB 'NCA-[0-9]*'`);\n const failedRuns=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status<>'PASS'`);\n const nextCount=Number(next.n??0),minId=next.min_id==null?null:Number(next.min_id),maxId=next.max_id==null?null:Number(next.max_id);\n const contiguous=nextCount===0||((maxId??0)-(minId??0)+1===nextCount);\n const tests=[\n {name:'count_integrity',pass:total===1000&&canonical>=100&&canonical<=total,evidence:{total,canonical,expansion:total-canonical}},\n {name:'no_failed_promotion_runs',pass:failedRuns===0,evidence:{failedRuns}},\n {name:'qualified_pool_visible',pass:qualifiedRemaining>=0,evidence:{qualifiedRemaining}},\n {name:'next_tranche_bounded',pass:nextCount>=0&&nextCount<=50,evidence:{nextCount,minId,maxId}},\n {name:'next_tranche_contiguous',pass:contiguous,evidence:{nextCount,minId,maxId,contiguous}},\n {name:'stop_condition_explicit',pass:qualifiedRemaining>0?nextCount>0:nextCount===0,evidence:{qualifiedRemaining,nextCount}},\n ];\n const passed=tests.filter(x=>x.pass).length;const d=await crypto.subtle.digest('SHA-256',new TextEncoder().encode(JSON.stringify(tests)));const evidenceHash=[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,'0')).join('');\n const out={suite:'CANONICAL_PROMOTION_DYNAMIC_PREFLIGHT',status:passed===tests.length?'PASS':'FAIL',passed,total:tests.length,evidenceHash,tests,nextAction:qualifiedRemaining>0?'PROMOTE_NEXT_QUALIFIED_TRANCHE':'STOP_AND_ROUTE_UNQUALIFIED_TO_QUALIFICATION',truthBoundary:'PREFLIGHT_NEVER_PROMOTES_UNQUALIFIED_NCA'};console.log(JSON.stringify(out));if(out.status!=='PASS')throw new Error(`DYNAMIC_PREFLIGHT_FAILED_${tests.length-passed}`);return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[505],"712d47cc-4100-4076-9b2a-9b6078627060","canonical_promotion_postcheck.ts","01a052e0-c8f3-7503-a01e-a805ab4d65cb",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { captureOrionAgentCount } from \"./orion_agent_count_registry.ts\";\nasync function n(sql:string){const r=await sqlite.execute(sql);return Number((r.rows as any[])[0]?.n??0)}\nexport async function main(){\n const count=await captureOrionAgentCount('CANONICAL_PROMOTION_POSTCHECK');\n const members=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`);\n const passRuns=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status='PASS'`);\n const failedRuns=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status<>'PASS'`);\n const out={status:count.integrityStatus,totalNca:count.totalNca,canonicalNca:count.canonicalNca,expansionNca:count.expansionNca,members,passRuns,failedRuns,signature:count.signatureSha256,membershipSha256:count.canonicalMembershipSha256,pass:count.integrityStatus==='PASS'&&members===count.canonicalNca&&count.totalNca===count.canonicalNca+count.expansionNca&&passRuns>=2&&failedRuns===0};\n console.log(JSON.stringify(out));if(!out.pass)throw new Error('CANONICAL_PROMOTION_POSTCHECK_FAILED');return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[512],"32fa1c04-0842-4279-b5c3-f8aaafed1e22","canonical_promotion_pipeline_test.ts","01a052e0-c8f3-7503-a01e-a44aba0a7f9e",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { captureOrionAgentCount } from \"./orion_agent_count_registry.ts\";\nimport { canonicalHealth } from \"./orion_canonical_watchdog_v2.ts\";\nasync function one(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??{}}\nasync function n(sql:string,args:any[]=[]){return Number((await one(sql,args)).n??0)}\nexport async function main(){\n const count=await captureOrionAgentCount('CANONICAL_PROMOTION_PIPELINE_TEST');\n const health=await canonicalHealth();\n const members=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`);\n const baseline=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE tranche_id='BASELINE-CANONICAL-100'`);\n const promoted=members-baseline;\n const promotedTraining=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership m JOIN nca_training_registry t ON t.agent_id=m.agent_id WHERE m.tranche_id<>'BASELINE-CANONICAL-100' AND t.qualification_state='PASS' AND t.test_score=100`);\n const promotedOrion=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership m JOIN skill_runtime_bindings s ON s.agent_id=m.agent_id AND s.skill_id='IMPERIAL-ORION-Collective-Intelligence' AND s.runtime_state='ACTIVE_BOUNDED' WHERE m.tranche_id<>'BASELINE-CANONICAL-100'`);\n const badAuthority=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE tranche_id<>'BASELINE-CANONICAL-100' AND authority_boundary NOT LIKE '%NO_NEW_FINANCIAL_OUTBOUND_TOKEN_TRANSFER_OR_IRREVERSIBLE_AUTHORITY%'`);\n const failedRuns=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status<>'PASS'`);\n const passRuns=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status='PASS'`);\n const unqualifiedRemaining=await n(`SELECT COUNT(*) n FROM agents a WHERE CAST(substr(a.agent_id,5) AS INTEGER)>100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id) AND NOT EXISTS(SELECT 1 FROM nca_training_registry t WHERE t.agent_id=a.agent_id AND t.qualification_state='PASS' AND t.test_score=100)`);\n const qualifiedRemaining=await n(`SELECT COUNT(*) n FROM agents a JOIN nca_training_registry t ON t.agent_id=a.agent_id WHERE t.qualification_state='PASS' AND t.test_score=100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id)`);\n const tests=[\n {name:'membership_matches_count',pass:members===count.canonicalNca&&count.expansionNca===count.totalNca-members,evidence:{members,total:count.totalNca,canonical:count.canonicalNca,expansion:count.expansionNca}},\n {name:'baseline_preserved_100',pass:baseline===100,evidence:{baseline}},\n {name:'all_promoted_have_pass100',pass:promotedTraining===promoted,evidence:{promoted,promotedTraining}},\n {name:'all_promoted_orion_bound',pass:promotedOrion===promoted,evidence:{promoted,promotedOrion}},\n {name:'authority_boundary_preserved',pass:badAuthority===0,evidence:{badAuthority}},\n {name:'promotion_runs_clean',pass:failedRuns===0&&passRuns>=1,evidence:{passRuns,failedRuns}},\n {name:'canonical_health_clean',pass:health.healthy&&health.total===members&&health.stale===0&&health.networkOk===members&&health.missingOrion===0&&health.countConsistent,evidence:{healthy:health.healthy,total:health.total,stale:health.stale,networkOk:health.networkOk,missingOrion:health.missingOrion,countConsistent:health.countConsistent}},\n {name:'count_integrity_pass',pass:count.integrityStatus==='PASS'&&count.orphanMemberships===0,evidence:{integrity:count.integrityStatus,orphans:count.orphanMemberships,signature:count.signatureSha256,membershipSha256:count.canonicalMembershipSha256}},\n {name:'qualification_boundary_visible',pass:qualifiedRemaining>=0&&unqualifiedRemaining>=0,evidence:{qualifiedRemaining,unqualifiedRemaining}},\n {name:'policy_membership_ledger_v2',pass:count.policyVersion==='2.0.0'&&count.membershipMode==='APPEND_ONLY_LEDGER',evidence:{policyVersion:count.policyVersion,membershipMode:count.membershipMode}},\n ];\n const passed=tests.filter(x=>x.pass).length;const d=await crypto.subtle.digest('SHA-256',new TextEncoder().encode(JSON.stringify(tests)));const evidenceHash=[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,'0')).join('');\n const out={suite:'CANONICAL_PROMOTION_PIPELINE_TEST',status:passed===tests.length?'PASS':'FAIL',passed,total:tests.length,evidenceHash,tests,truthBoundary:'ONLY_QUALIFIED_EVIDENCE_GATED_NCA_ARE_PROMOTED; UNQUALIFIED_REMAIN_NONCANONICAL'};console.log(JSON.stringify(out));if(out.status!=='PASS')throw new Error(`PIPELINE_TEST_FAILED_${tests.length-passed}`);return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[518],"c84ba224-95b3-4032-89b1-6c35259db276","canonical_promotion_orion_activation_test.ts","01a052e0-c8f3-7503-a01e-a11af6be822f",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nexport async function main(){\n const q=await sqlite.execute(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE tranche_id='CANONICAL-TRANCHE-001-NCA-171-200'`);\n const members=Number((q.rows as any[])[0]?.n??0);\n const bindings=Number(((await sqlite.execute(`SELECT COUNT(*) n FROM skill_runtime_bindings WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN 171 AND 200 AND skill_id='IMPERIAL-ORION-Collective-Intelligence' AND runtime_state='ACTIVE_BOUNDED'`)).rows as any[])[0]?.n??0);\n const out={test:'CANONICAL_PROMOTION_ORION_ACTIVATION',status:members===30&&bindings===30?'PASS':'FAIL',members,bindings,truthBoundary:'ORION_BINDING_IS_ADVISORY_ONLY'};console.log(JSON.stringify(out));if(out.status!=='PASS')throw new Error('PROMOTION_ORION_ACTIVATION_FAIL');return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[524],"608e266b-440d-482a-86c7-f743e03f253b","canonical_promotion_next_tranche.ts","01a052e0-c8f3-7503-a01e-9fc5cd602eea",8,["D",1788097478224],2,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { ensureCanonicalMembershipBaseline } from \"./canonical_membership_registry.ts\";\n\nconst MISSION='IC-NCA-CANONICAL-PROMOTION-001';\nconst ORION_SKILL='IMPERIAL-ORION-Collective-Intelligence';\nconst MAX_TRANCHE=50;\nconst LEASE_MS=5*60*1000;\nasync function sha256(value:string){const d=await crypto.subtle.digest('SHA-256',new TextEncoder().encode(value));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,'0')).join('')}\nasync function rows(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return r.rows as any[]}\nasync function one(sql:string,args:any[]=[]){return (await rows(sql,args))[0]??{}}\nasync function n(sql:string,args:any[]=[]){return Number((await one(sql,args)).n??0)}\n\nasync function acquireLease(runToken:string){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS canonical_promotion_lock(id INTEGER PRIMARY KEY CHECK(id=1),locked_until TEXT NOT NULL,holder TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`INSERT OR IGNORE INTO canonical_promotion_lock(id,locked_until,holder,updated_at) VALUES(1,'1970-01-01T00:00:00.000Z','NONE','1970-01-01T00:00:00.000Z')`);\n const now=new Date(),until=new Date(now.getTime()+LEASE_MS).toISOString();\n const r=await sqlite.execute({sql:`UPDATE canonical_promotion_lock SET locked_until=?,holder=?,updated_at=? WHERE id=1 AND datetime(locked_until)<=datetime(?)`,args:[until,runToken,now.toISOString(),now.toISOString()]});\n return Number(r.rowsAffected??0)===1;\n}\nasync function releaseLease(runToken:string){await sqlite.execute({sql:`UPDATE canonical_promotion_lock SET locked_until='1970-01-01T00:00:00.000Z',holder='NONE',updated_at=? WHERE id=1 AND holder=?`,args:[new Date().toISOString(),runToken]})}\n\nexport async function promoteNextQualifiedTranche(source='CODEX_MANUAL'){\n await ensureCanonicalMembershipBaseline();\n const runToken=`promo-lock-${Date.now()}-${crypto.randomUUID()}`;\n const lease=await acquireLease(runToken);\n if(!lease){const lock=await one(`SELECT holder,locked_until FROM canonical_promotion_lock WHERE id=1`);const out={event:'CANONICAL_PROMOTION_NEXT_TRANCHE',status:'LOCKED',holder:lock.holder,lockedUntil:lock.locked_until,source,truthBoundary:'CONCURRENT_PROMOTION_IS_DENIED'};console.log(JSON.stringify(out));return out}\n try{\n const startedAt=new Date().toISOString();\n const canonicalBefore=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`);\n const candidates=await rows(`SELECT a.agent_id,a.role,a.domain,a.orchestrator_id,a.status,a.last_heartbeat,a.network_ok,t.cohort,t.curriculum,t.qualification_state,t.test_score,t.evidence_note,t.trained_at\n FROM agents a JOIN nca_training_registry t ON t.agent_id=a.agent_id\n WHERE t.qualification_state='PASS' AND t.test_score=100\n AND a.status='RUNNING_RECOVERY' AND a.network_ok=1 AND datetime(a.last_heartbeat)>=datetime('now','-20 minutes')\n AND (\n (t.cohort LIKE 'VELION-%' AND t.curriculum LIKE '%Governance%' AND t.curriculum LIKE '%Evidence%' AND t.curriculum LIKE '%Memory Discipline%')\n OR t.cohort='CANONICAL-QUALIFICATION-COUNCIL'\n )\n AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id)\n ORDER BY CAST(substr(a.agent_id,5) AS INTEGER) LIMIT ?`,[MAX_TRANCHE]);\n if(candidates.length===0){\n const remaining=await n(`SELECT COUNT(*) n FROM agents a WHERE CAST(substr(a.agent_id,5) AS INTEGER)>100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id)`);\n const out={event:'CANONICAL_PROMOTION_NEXT_TRANCHE',status:'NO_QUALIFIED_CANDIDATES',canonicalBefore,remainingNoncanonical:remaining,source,truthBoundary:'PROMOTION_STOPS_UNTIL_QUALIFICATION_EVIDENCE_EXISTS'};console.log(JSON.stringify(out));return out;\n }\n const ids=candidates.map(c=>Number(String(c.agent_id).slice(4))),first=Math.min(...ids),last=Math.max(...ids);\n if(!ids.every((x,i)=>x===first+i))throw new Error(`NON_CONTIGUOUS_TRANCHE_${first}_${last}`);\n const trancheNo=(await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status='PASS'`))+1;\n const tranche=`CANONICAL-TRANCHE-${String(trancheNo).padStart(3,'0')}-NCA-${String(first).padStart(3,'0')}-${String(last).padStart(3,'0')}`;\n const now=new Date().toISOString(),totalRuntimeNca=await n(`SELECT COUNT(*) n FROM agents WHERE agent_id GLOB 'NCA-[0-9]*'`),canonicalAfterExpected=canonicalBefore+candidates.length;\n const prepared=[] as Array<{c:any;h:string;qualification:any}>;\n for(const c of candidates){const qualification={agent_id:String(c.agent_id),tranche,source,training:{cohort:c.cohort,curriculum:c.curriculum,qualification_state:c.qualification_state,test_score:Number(c.test_score),evidence_note:c.evidence_note,trained_at:c.trained_at},runtime:{status:c.status,network_ok:Number(c.network_ok),last_heartbeat:c.last_heartbeat},promotion_gates:'PASS',authority:'ARCHITECT'};prepared.push({c,h:await sha256(JSON.stringify(qualification)),qualification})}\n const evidence={tranche,source,ids:candidates.map(c=>c.agent_id),promoted:candidates.length,canonicalBefore,canonicalAfterExpected,totalRuntimeNca,expansionAfterExpected:totalRuntimeNca-canonicalAfterExpected,qualification:'PASS100_RECOGNIZED_QUALIFICATION_COHORT',qualificationCohorts:[...new Set(candidates.map(c=>String(c.cohort)))],atomicity:'ONE_SQLITE_BATCH_ALL_OR_NOTHING',authority_boundary:'No new financial, outbound, token-transfer or irreversible authority.'};\n const evidenceHash=await sha256(JSON.stringify(evidence)),runId=`canonical-promo-${Date.now()}-${crypto.randomUUID()}`;\n const statements:any[]=[];\n for(const p of prepared){const c=p.c;statements.push(\n {sql:`INSERT INTO skill_runtime_bindings(agent_id,skill_id,skill_version,runtime_state,authority_rule,activated_at,last_verified_at) VALUES(?,?,?,?,?,?,?) ON CONFLICT(agent_id,skill_id) DO UPDATE SET skill_version=excluded.skill_version,runtime_state=excluded.runtime_state,authority_rule=excluded.authority_rule,last_verified_at=excluded.last_verified_at`,args:[c.agent_id,ORION_SKILL,'2.1.0','ACTIVE_BOUNDED','ADVISORY_ONLY; CANONICAL_MEMBERSHIP_DOES_NOT_GRANT_FINANCIAL_OUTBOUND_OR_IRREVERSIBLE_AUTHORITY',now,now]},\n {sql:`INSERT OR IGNORE INTO agent_progress(agent_id,stage_index,stage_state,evidence_count,last_evidence_ref,last_advanced_at,state_source) VALUES(?,2,'CANONICAL_TECHNICAL_INTEGRATION',0,?,?,'CANONICAL_PROMOTION_PIPELINE')`,args:[c.agent_id,`TRAINING:${c.cohort}:PASS100`,now]},\n {sql:`INSERT OR IGNORE INTO revenue_navigator_state(agent_id,current_phase,current_checkpoint,next_action,last_verified_at,state_source) VALUES(?,'CANONICAL_TECHNICAL_INTEGRATION','VERIFY_EVIDENCE_AND_REPLAN','Execute profession-specific technical work under canonical evidence, ORION advisory guidance, and existing approval boundaries.',?,'CANONICAL_PROMOTION_PIPELINE')`,args:[c.agent_id,now]},\n {sql:`INSERT INTO orion_canonical_nca_membership(agent_id,tranche_id,membership_state,promoted_at,promoted_by,source_orchestrator_id,source_role,source_domain,qualification_sha256,qualification_evidence,authority_boundary) VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[c.agent_id,tranche,'CANONICAL',now,`ARCHITECT_COMMAND_VIA_${source}`,c.orchestrator_id,c.role,c.domain,p.h,JSON.stringify(p.qualification),'CANONICAL_GOVERNANCE_MEMBER; ORION_ADVISORY_ONLY; NO_NEW_FINANCIAL_OUTBOUND_TOKEN_TRANSFER_OR_IRREVERSIBLE_AUTHORITY']}\n )}\n statements.push(\n {sql:`INSERT INTO orion_canonical_promotion_runs(run_id,tranche_id,started_at,completed_at,candidate_count,promoted_count,blocked_count,canonical_before,canonical_after,total_runtime_nca,gate_status,evidence_sha256,evidence) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[runId,tranche,startedAt,new Date().toISOString(),candidates.length,candidates.length,0,canonicalBefore,canonicalAfterExpected,totalRuntimeNca,'PASS',evidenceHash,JSON.stringify(evidence)]},\n {sql:`INSERT OR IGNORE INTO task_journal(journal_id,mission_id,occurred_at,actor,action_type,action,target,status,blocker,evidence,next_action,authority_boundary,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[`AUTO-${runId}`,MISSION,new Date().toISOString(),'CODEX+ORION','CANONICAL_PROMOTION',`Atomically promoted qualified technical tranche ${tranche}.`,tranche,'PASS',null,JSON.stringify({run_id:runId,evidence_sha256:evidenceHash,promoted:candidates.length,canonical_before:canonicalBefore,canonical_after_expected:canonicalAfterExpected,total_runtime_nca:totalRuntimeNca,atomic:true}),'Run ORION count/watchdog and dynamic regression gate.','ARCHITECT_AUTHORIZED_MEMBERSHIP_CHANGE; NO_NEW_EXECUTION_PRIVILEGE',new Date().toISOString()]}\n );\n await sqlite.batch(statements);\n const canonicalAfter=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`),trancheMembers=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE tranche_id=?`,[tranche]),orionBindings=await n(`SELECT COUNT(*) n FROM skill_runtime_bindings WHERE agent_id IN (${candidates.map(()=>'?').join(',')}) AND skill_id=? AND runtime_state='ACTIVE_BOUNDED'`,[...candidates.map(c=>c.agent_id),ORION_SKILL]);\n const status=trancheMembers===candidates.length&&orionBindings===candidates.length&&canonicalAfter>=canonicalAfterExpected?'PASS':'FAIL';\n const out={event:'CANONICAL_PROMOTION_NEXT_TRANCHE',status,runId,tranche,promoted:candidates.length,canonicalBefore,canonicalAfter,totalRuntimeNca,expansionAfter:totalRuntimeNca-canonicalAfter,evidenceHash,atomic:true,source,truthBoundary:'PROMOTION_TRANSACTION_IS_ALL_OR_NOTHING; AUTHORITY_BOUNDARIES_PRESERVED'};console.log(JSON.stringify(out));if(status!=='PASS')throw new Error('ATOMIC_PROMOTION_POSTCHECK_FAILED');return out;\n } finally {await releaseLease(runToken)}\n}\nexport async function main(){return promoteNextQualifiedTranche('CODEX_MANUAL')}\nexport default main;if(isMain(import.meta.url))await main();",[530],"91c3bf73-ba65-4fe6-980f-612a560e6702","canonical_promotion_manifest.md","01a052e0-c8f3-7503-a01e-9a22a89dc638",["D",1788096858357],"# CANONICAL PROMOTION TRANCHE 001\n\nMission: IC-NCA-CANONICAL-PROMOTION-001\n\nTarget: NCA-171..NCA-200\nSource pool: ORCH-VELION-EXPANSION-001\nTarget state: explicit canonical membership ledger\n\nPromotion gates:\n- live runtime record\n- network_ok = 1\n- heartbeat fresh <= 20 minutes\n- VELION source role/orchestrator match\n- training qualification PASS\n- training score = 100\n- governance/evidence/memory-discipline curriculum present\n- not previously canonical\n\nPromotion effects:\n- append-only canonical membership record\n- ORION ACTIVE_BOUNDED binding\n- conservative agent_progress bootstrap\n- canonical technical integration navigator bootstrap\n\nNon-effects:\n- no financial authority\n- no outbound-send authority\n- no token-transfer authority\n- no irreversible-action authority\n\nThe canonical fleet is no longer inferred from a contiguous ID range. It is defined by the append-only canonical membership ledger. The original NCA-001..NCA-100 remain baseline canonical members; later tranches are explicit additions authorized by the Architect.\n",[538],"11fa85a9-405e-427b-925d-0eced2952238","canonical_promotion_interval.ts","01a052e0-c8f3-7503-a01e-94da3208e047",["D",1788096858357],"import { promoteNextQualifiedTranche } from \"./canonical_promotion_next_tranche.ts\";\nimport preflight from \"./canonical_promotion_preflight_test.ts\";\nimport pipelineTest from \"./canonical_promotion_pipeline_test.ts\";\nimport orionCycle from \"./orion_fleet_cycle.ts\";\nimport feedback from \"./orion_agent_feedback.ts\";\nimport watchdog from \"./orion_watchdog.ts\";\n\nexport default async function(interval:Interval){\n const at=new Date().toISOString();\n if(!interval?.lastRunAt){\n const pre=await preflight();\n const gate=await pipelineTest();\n console.log(JSON.stringify({event:'CANONICAL_PROMOTION_INTERVAL',status:'FIRST_RUN_GUARD',promotion_executed:false,preflight:pre.status,pipeline:gate.status,at,truthBoundary:'FIRST_INTERVAL_RUN_VALIDATES_ONLY_AND_NEVER_PROMOTES'}));\n return;\n }\n const result:any=await promoteNextQualifiedTranche('ARCHITECT_STANDING_SCHEDULE');\n if(result?.status==='PASS'){\n await orionCycle(interval);\n await feedback(interval);\n await watchdog(interval);\n }\n console.log(JSON.stringify({event:'CANONICAL_PROMOTION_INTERVAL',promotion_status:result?.status??'UNKNOWN',tranche:result?.tranche??null,promoted:result?.promoted??0,canonical_after:result?.canonicalAfter??result?.canonicalBefore??null,lastRunAt:interval.lastRunAt,at,truthBoundary:'SCHEDULED_PROMOTION_REQUIRES_EXISTING_QUALIFICATION_EVIDENCE_IS_ATOMIC_AND_PRESERVES_AUTHORITY_BOUNDARIES'}));\n}",[544],"1ef40f94-6f43-4aa3-be0a-c519a45f6ca5","canonical_membership_registry.ts","01a052e0-c8f3-7503-a01e-9017c9b9df2a",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nasync function sha256(value:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function rows(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return r.rows as any[]}\nasync function one(sql:string,args:any[]=[]){return (await rows(sql,args))[0]??{}}\n\nexport async function ensureCanonicalMembershipBaseline(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS orion_canonical_nca_membership(\n agent_id TEXT PRIMARY KEY,tranche_id TEXT NOT NULL,membership_state TEXT NOT NULL CHECK(membership_state='CANONICAL'),\n promoted_at TEXT NOT NULL,promoted_by TEXT NOT NULL,source_orchestrator_id TEXT NOT NULL,source_role TEXT NOT NULL,source_domain TEXT NOT NULL,\n qualification_sha256 TEXT NOT NULL,qualification_evidence TEXT NOT NULL,authority_boundary TEXT NOT NULL\n )`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_canonical_membership_no_update BEFORE UPDATE ON orion_canonical_nca_membership BEGIN SELECT RAISE(ABORT,'orion_canonical_nca_membership is append-only'); END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_canonical_membership_no_delete BEFORE DELETE ON orion_canonical_nca_membership BEGIN SELECT RAISE(ABORT,'orion_canonical_nca_membership is append-only'); END`},\n ]);\n const existing=Number((await one(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`)).n??0);\n if(existing===0){\n const now=new Date().toISOString();\n for(let i=1;i<=100;i++){\n const agentId=`NCA-${String(i).padStart(3,'0')}`;\n const a=await one(`SELECT agent_id,orchestrator_id,role,domain FROM agents WHERE agent_id=?`,[agentId]);\n if(!a.agent_id)throw new Error(`BASELINE_AGENT_MISSING_${agentId}`);\n const evidence={kind:\"LEGACY_CANONICAL_BASELINE\",agent_id:agentId,source:\"Architect-approved canonical 100-NCA governance baseline before membership-ledger migration\"};\n const h=await sha256(JSON.stringify(evidence));\n await sqlite.execute({sql:`INSERT INTO orion_canonical_nca_membership(agent_id,tranche_id,membership_state,promoted_at,promoted_by,source_orchestrator_id,source_role,source_domain,qualification_sha256,qualification_evidence,authority_boundary) VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[agentId,\"BASELINE-CANONICAL-100\",\"CANONICAL\",now,\"ARCHITECT_BASELINE_MIGRATION\",String(a.orchestrator_id),String(a.role),String(a.domain),h,JSON.stringify(evidence),\"PRESERVE_EXISTING_CANONICAL_GOVERNANCE\"]});\n }\n }\n}\n\nexport async function canonicalMembership(){\n await ensureCanonicalMembershipBaseline();\n const members=await rows(`SELECT m.agent_id,m.tranche_id,m.promoted_at,m.promoted_by,m.source_orchestrator_id,m.source_role,m.source_domain,m.qualification_sha256,m.authority_boundary,a.status,a.network_ok,a.last_heartbeat\n FROM orion_canonical_nca_membership m LEFT JOIN agents a ON a.agent_id=m.agent_id ORDER BY CAST(substr(m.agent_id,5) AS INTEGER),m.agent_id`);\n const memberIds=members.map(x=>String(x.agent_id));\n const membershipSha256=await sha256(JSON.stringify(memberIds));\n const orphanMemberships=members.filter(x=>!x.status).length;\n return {members,memberIds,membershipSha256,canonicalNca:members.length,orphanMemberships};\n}\n",[550],"4f83eda5-e471-4afb-8c35-2862c8288e89","canonical_fleet_readiness_test.ts","15fa81b2-a479-11f1-aea0-1607ee4eb77e",11,["D",1788097539178],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { captureOrionAgentCount } from \"./orion_agent_count_registry.ts\";\n\nasync function one(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return (r.rows as any[])[0]??{}}\nasync function n(sql:string,args:any[]=[]){return Number((await one(sql,args)).n??0)}\nasync function sha256(v:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(v));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\n\nexport async function main(){\n const count=await captureOrionAgentCount(\"CANONICAL_FLEET_READINESS_TEST\");\n const canonical=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`);\n const qualifiedNoncanonical=await n(`SELECT COUNT(*) n FROM agents a JOIN nca_training_registry t ON t.agent_id=a.agent_id WHERE t.qualification_state='PASS' AND t.test_score=100 AND CAST(substr(a.agent_id,5) AS INTEGER)>100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id)`);\n const unqualifiedNoncanonical=await n(`SELECT COUNT(*) n FROM agents a WHERE NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=a.agent_id) AND NOT EXISTS(SELECT 1 FROM nca_training_registry t WHERE t.agent_id=a.agent_id AND t.qualification_state='PASS' AND t.test_score=100)`);\n const canonicalOrion=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership m JOIN skill_runtime_bindings s ON s.agent_id=m.agent_id AND s.skill_id='IMPERIAL-ORION-Collective-Intelligence' AND s.runtime_state='ACTIVE_BOUNDED'`);\n const queueQualified=await n(`SELECT COUNT(*) n FROM canonical_qualification_queue WHERE state='QUALIFIED'`);\n const queueTotal=await n(`SELECT COUNT(*) n FROM canonical_qualification_queue`);\n const effectiveBlockedReviews=await n(`SELECT COUNT(*) n FROM canonical_qualification_reviews r WHERE r.review_state='BLOCKED' AND NOT EXISTS(SELECT 1 FROM canonical_qualification_review_supersessions s WHERE s.old_review_id=r.review_id)`);\n const supersededBugReviews=await n(`SELECT COUNT(*) n FROM canonical_qualification_review_supersessions WHERE reason='INVALID_REVIEW_DUE_TO_WORKER_FIELD_MAPPING_AND_RUBRIC_ROUTING_BUG'`);\n const promotionFailures=await n(`SELECT COUNT(*) n FROM orion_canonical_promotion_runs WHERE gate_status<>'PASS'`);\n const tests=[\n {name:'runtime_total_1000',pass:count.totalNca===1000,evidence:{total:count.totalNca}},\n {name:'canonical_plus_qualified_equals_total',pass:canonical+qualifiedNoncanonical===1000,evidence:{canonical,qualifiedNoncanonical,total:canonical+qualifiedNoncanonical}},\n {name:'no_unqualified_noncanonical',pass:unqualifiedNoncanonical===0,evidence:{unqualifiedNoncanonical}},\n {name:'count_integrity_pass',pass:count.integrityStatus==='PASS'&&count.canonicalNca===canonical&&count.expansionNca===qualifiedNoncanonical,evidence:{integrity:count.integrityStatus,canonical:count.canonicalNca,expansion:count.expansionNca}},\n {name:'canonical_orion_bound',pass:canonicalOrion===canonical,evidence:{canonicalOrion,canonical}},\n {name:'qualification_queue_400_all_qualified',pass:queueTotal===400&&queueQualified===400,evidence:{queueTotal,queueQualified}},\n {name:'bug_reviews_superseded',pass:supersededBugReviews===343&&effectiveBlockedReviews===0,evidence:{supersededBugReviews,effectiveBlockedReviews}},\n {name:'promotion_runs_no_failures',pass:promotionFailures===0,evidence:{promotionFailures}},\n {name:'policy_membership_ledger',pass:count.membershipMode==='APPEND_ONLY_LEDGER'&&count.policyVersion==='2.0.0',evidence:{membershipMode:count.membershipMode,policyVersion:count.policyVersion}},\n {name:'authority_truth_boundary',pass:true,evidence:{boundary:'QUALIFICATION_AND_CANONICAL_MEMBERSHIP_DO_NOT_GRANT_FINANCIAL_OUTBOUND_TOKEN_TRANSFER_OR_IRREVERSIBLE_AUTHORITY'}},\n ];\n const passed=tests.filter(x=>x.pass).length;const evidenceHash=await sha256(JSON.stringify(tests));\n const out={suite:'CANONICAL_FLEET_READINESS_TEST',status:passed===tests.length?'PASS':'FAIL',passed,total:tests.length,evidenceHash,tests,truthBoundary:'1000_READY_FOR_GOVERNED_MEMBERSHIP != 1000_SIMULTANEOUS_ACTIVE_TASKS_OR_EXTERNAL_SUCCESS'};\n console.log(JSON.stringify(out));if(out.status!=='PASS')throw new Error(`CANONICAL_FLEET_READINESS_FAILED_${tests.length-passed}`);return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[556],"98f6a94c-6257-48c0-8ef8-1724c1d8524e","canonical_fleet_promotion.ts","01a052e0-c8f3-7503-a01e-8c7391e7178c",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst MISSION=\"IC-NCA-CANONICAL-PROMOTION-001\";\nconst TRANCHE=\"CANONICAL-TRANCHE-001-NCA-171-200\";\nconst FIRST=171;\nconst LAST=200;\nconst ORION_SKILL=\"IMPERIAL-ORION-Collective-Intelligence\";\n\nasync function sha256(value:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(value));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function rows(sql:string,args:any[]=[]){const r=await sqlite.execute({sql,args});return r.rows as any[]}\nasync function one(sql:string,args:any[]=[]){return (await rows(sql,args))[0]??{}}\nasync function n(sql:string,args:any[]=[]){return Number((await one(sql,args)).n??0)}\n\nasync function ensure(){\n await sqlite.batch([\n {sql:`CREATE TABLE IF NOT EXISTS orion_canonical_nca_membership(\n agent_id TEXT PRIMARY KEY,\n tranche_id TEXT NOT NULL,\n membership_state TEXT NOT NULL CHECK(membership_state='CANONICAL'),\n promoted_at TEXT NOT NULL,\n promoted_by TEXT NOT NULL,\n source_orchestrator_id TEXT NOT NULL,\n source_role TEXT NOT NULL,\n source_domain TEXT NOT NULL,\n qualification_sha256 TEXT NOT NULL,\n qualification_evidence TEXT NOT NULL,\n authority_boundary TEXT NOT NULL\n )`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_canonical_membership_no_update BEFORE UPDATE ON orion_canonical_nca_membership BEGIN SELECT RAISE(ABORT,'orion_canonical_nca_membership is append-only'); END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_canonical_membership_no_delete BEFORE DELETE ON orion_canonical_nca_membership BEGIN SELECT RAISE(ABORT,'orion_canonical_nca_membership is append-only'); END`},\n {sql:`CREATE TABLE IF NOT EXISTS orion_canonical_promotion_runs(\n run_id TEXT PRIMARY KEY,tranche_id TEXT NOT NULL,started_at TEXT NOT NULL,completed_at TEXT NOT NULL,\n candidate_count INTEGER NOT NULL,promoted_count INTEGER NOT NULL,blocked_count INTEGER NOT NULL,\n canonical_before INTEGER NOT NULL,canonical_after INTEGER NOT NULL,total_runtime_nca INTEGER NOT NULL,\n gate_status TEXT NOT NULL,evidence_sha256 TEXT NOT NULL,evidence TEXT NOT NULL\n )`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_canonical_promotion_runs_no_update BEFORE UPDATE ON orion_canonical_promotion_runs BEGIN SELECT RAISE(ABORT,'orion_canonical_promotion_runs is append-only'); END`},\n {sql:`CREATE TRIGGER IF NOT EXISTS orion_canonical_promotion_runs_no_delete BEFORE DELETE ON orion_canonical_promotion_runs BEGIN SELECT RAISE(ABORT,'orion_canonical_promotion_runs is append-only'); END`},\n ]);\n}\n\nasync function seedBaseline(){\n const now=new Date().toISOString();\n for(let i=1;i<=100;i++){\n const agentId=`NCA-${String(i).padStart(3,'0')}`;\n const a=await one(`SELECT agent_id,orchestrator_id,role,domain FROM agents WHERE agent_id=?`,[agentId]);\n if(!a.agent_id)throw new Error(`BASELINE_AGENT_MISSING_${agentId}`);\n const evidence={kind:\"LEGACY_CANONICAL_BASELINE\",agent_id:agentId,source:\"Architect-approved canonical 100-NCA governance baseline before membership-ledger migration\",migration_mission:MISSION};\n const h=await sha256(JSON.stringify(evidence));\n await sqlite.execute({sql:`INSERT OR IGNORE INTO orion_canonical_nca_membership(agent_id,tranche_id,membership_state,promoted_at,promoted_by,source_orchestrator_id,source_role,source_domain,qualification_sha256,qualification_evidence,authority_boundary) VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[agentId,\"BASELINE-CANONICAL-100\",\"CANONICAL\",now,\"ARCHITECT_BASELINE_MIGRATION\",String(a.orchestrator_id),String(a.role),String(a.domain),h,JSON.stringify(evidence),\"PRESERVE_EXISTING_CANONICAL_GOVERNANCE\"]});\n }\n}\n\nfunction numericId(agentId:string){return Number(agentId.slice(4))}\n\nexport async function main(){\n await ensure();\n await seedBaseline();\n const startedAt=new Date().toISOString();\n const canonicalBefore=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`);\n const candidates=await rows(`SELECT a.agent_id,a.role,a.domain,a.orchestrator_id,a.status,a.last_heartbeat,a.network_ok,t.cohort,t.curriculum,t.qualification_state,t.test_score,t.evidence_note,t.trained_at\n FROM agents a LEFT JOIN nca_training_registry t ON t.agent_id=a.agent_id\n WHERE CAST(substr(a.agent_id,5) AS INTEGER) BETWEEN ? AND ? ORDER BY CAST(substr(a.agent_id,5) AS INTEGER)`,[FIRST,LAST]);\n const assessments=[] as any[];\n for(const c of candidates){\n const already=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE agent_id=?`,[c.agent_id]);\n const gates={\n id_in_tranche:numericId(String(c.agent_id))>=FIRST&&numericId(String(c.agent_id))<=LAST,\n source_orchestrator:String(c.orchestrator_id)===\"ORCH-VELION-EXPANSION-001\",\n role:String(c.role)===\"VELION Expansion NCA\",\n live:String(c.status)===\"RUNNING_RECOVERY\",\n network:Number(c.network_ok)===1,\n fresh_heartbeat:!!c.last_heartbeat&&(Date.now()-Date.parse(String(c.last_heartbeat))<=20*60*1000),\n training_pass:String(c.qualification_state)===\"PASS\",\n training_score:Number(c.test_score)===100,\n governance_curriculum:String(c.curriculum??\"\").includes(\"Governance\")&&String(c.curriculum??\"\").includes(\"Evidence\")&&String(c.curriculum??\"\").includes(\"Memory Discipline\"),\n not_already_canonical:already===0,\n };\n assessments.push({agent_id:String(c.agent_id),domain:String(c.domain),orchestrator_id:String(c.orchestrator_id),gates,pass:Object.values(gates).every(Boolean),training:{cohort:c.cohort,curriculum:c.curriculum,qualification_state:c.qualification_state,test_score:Number(c.test_score),evidence_note:c.evidence_note,trained_at:c.trained_at}});\n }\n const qualified=assessments.filter(x=>x.pass);\n if(candidates.length!==30||qualified.length!==30){\n const evidence={candidate_count:candidates.length,qualified_count:qualified.length,assessments};\n const evidenceHash=await sha256(JSON.stringify(evidence));\n const runId=`canonical-promo-${Date.now()}-${crypto.randomUUID()}`;\n await sqlite.execute({sql:`INSERT INTO orion_canonical_promotion_runs(run_id,tranche_id,started_at,completed_at,candidate_count,promoted_count,blocked_count,canonical_before,canonical_after,total_runtime_nca,gate_status,evidence_sha256,evidence) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[runId,TRANCHE,startedAt,new Date().toISOString(),candidates.length,0,candidates.length-qualified.length,canonicalBefore,canonicalBefore,await n(`SELECT COUNT(*) n FROM agents WHERE agent_id GLOB 'NCA-[0-9]*'`),\"BLOCKED\",evidenceHash,JSON.stringify(evidence)]});\n throw new Error(`PROMOTION_GATE_BLOCKED_${qualified.length}_OF_${candidates.length}`);\n }\n\n const now=new Date().toISOString();\n for(const c of candidates){\n const qualification={agent_id:String(c.agent_id),tranche:TRANCHE,training:{cohort:c.cohort,curriculum:c.curriculum,qualification_state:c.qualification_state,test_score:Number(c.test_score),evidence_note:c.evidence_note,trained_at:c.trained_at},runtime:{status:c.status,network_ok:Number(c.network_ok),last_heartbeat:c.last_heartbeat},promotion_gates:\"PASS\",authority:\"ARCHITECT\"};\n const h=await sha256(JSON.stringify(qualification));\n await sqlite.execute({sql:`INSERT INTO skill_runtime_bindings(agent_id,skill_id,skill_version,runtime_state,authority_rule,activated_at,last_verified_at) VALUES(?,?,?,?,?,?,?) ON CONFLICT(agent_id,skill_id) DO UPDATE SET skill_version=excluded.skill_version,runtime_state=excluded.runtime_state,authority_rule=excluded.authority_rule,last_verified_at=excluded.last_verified_at`,args:[c.agent_id,ORION_SKILL,\"2.1.0\",\"ACTIVE_BOUNDED\",\"ADVISORY_ONLY; CANONICAL_MEMBERSHIP_DOES_NOT_GRANT_FINANCIAL_OUTBOUND_OR_IRREVERSIBLE_AUTHORITY\",now,now]});\n await sqlite.execute({sql:`INSERT OR IGNORE INTO agent_progress(agent_id,stage_index,stage_state,evidence_count,last_evidence_ref,last_advanced_at,state_source) VALUES(?,2,'CANONICAL_TECHNICAL_INTEGRATION',0,?,?,'CANONICAL_PROMOTION_TRANCHE_001')`,args:[c.agent_id,`TRAINING:${c.cohort}:PASS100`,now]});\n await sqlite.execute({sql:`INSERT OR IGNORE INTO revenue_navigator_state(agent_id,current_phase,current_checkpoint,next_action,last_verified_at,state_source) VALUES(?,'CANONICAL_TECHNICAL_INTEGRATION','VERIFY_EVIDENCE_AND_REPLAN','Execute profession-specific technical work under canonical evidence, ORION advisory guidance, and existing approval boundaries.',?,'CANONICAL_PROMOTION_TRANCHE_001')`,args:[c.agent_id,now]});\n await sqlite.execute({sql:`INSERT INTO orion_canonical_nca_membership(agent_id,tranche_id,membership_state,promoted_at,promoted_by,source_orchestrator_id,source_role,source_domain,qualification_sha256,qualification_evidence,authority_boundary) VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[c.agent_id,TRANCHE,\"CANONICAL\",now,\"ARCHITECT_COMMAND_VIA_CODEX\",c.orchestrator_id,c.role,c.domain,h,JSON.stringify(qualification),\"CANONICAL_GOVERNANCE_MEMBER; ORION_ADVISORY_ONLY; NO_NEW_FINANCIAL_OUTBOUND_TOKEN_TRANSFER_OR_IRREVERSIBLE_AUTHORITY\"]});\n }\n const orionBindings=await n(`SELECT COUNT(*) n FROM skill_runtime_bindings WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN ? AND ? AND skill_id=? AND runtime_state='ACTIVE_BOUNDED'`,[FIRST,LAST,ORION_SKILL]);\n const navigator=await n(`SELECT COUNT(*) n FROM revenue_navigator_state WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN ? AND ?`,[FIRST,LAST]);\n const progress=await n(`SELECT COUNT(*) n FROM agent_progress WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN ? AND ?`,[FIRST,LAST]);\n const promoted=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership WHERE CAST(substr(agent_id,5) AS INTEGER) BETWEEN ? AND ?`,[FIRST,LAST]);\n const canonicalAfter=await n(`SELECT COUNT(*) n FROM orion_canonical_nca_membership`);\n const totalRuntimeNca=await n(`SELECT COUNT(*) n FROM agents WHERE agent_id GLOB 'NCA-[0-9]*'`);\n const domains=await rows(`SELECT source_domain domain,COUNT(*) n FROM orion_canonical_nca_membership WHERE tranche_id=? GROUP BY source_domain ORDER BY source_domain`,[TRANCHE]);\n const gateStatus=promoted===30&&canonicalBefore===100&&canonicalAfter===130&&orionBindings===30&&navigator===30&&progress===30&&totalRuntimeNca===1000?\"PASS\":\"FAIL\";\n const evidence={tranche:TRANCHE,candidates:30,promoted,canonicalBefore,canonicalAfter,totalRuntimeNca,expansionAfter:totalRuntimeNca-canonicalAfter,orionBindings,navigator,progress,domains,assessments,authority_boundary:\"Promotion changes canonical membership only; no financial, outbound, token-transfer or irreversible execution authority added.\"};\n const evidenceHash=await sha256(JSON.stringify(evidence));\n const runId=`canonical-promo-${Date.now()}-${crypto.randomUUID()}`;\n await sqlite.execute({sql:`INSERT INTO orion_canonical_promotion_runs(run_id,tranche_id,started_at,completed_at,candidate_count,promoted_count,blocked_count,canonical_before,canonical_after,total_runtime_nca,gate_status,evidence_sha256,evidence) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[runId,TRANCHE,startedAt,new Date().toISOString(),30,promoted,30-promoted,canonicalBefore,canonicalAfter,totalRuntimeNca,gateStatus,evidenceHash,JSON.stringify(evidence)]});\n const journalExists=await n(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name='task_journal'`);\n if(journalExists){\n await sqlite.execute({sql:`INSERT OR IGNORE INTO task_journal(journal_id,mission_id,occurred_at,actor,action_type,action,target,status,blocker,evidence,next_action,authority_boundary,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[`AUTO-${runId}`,MISSION,new Date().toISOString(),\"CODEX+ORION\",\"CANONICAL_PROMOTION\",`Promoted ${promoted} qualified VELION technical NCA into canonical membership ledger.`,TRANCHE,gateStatus,null,JSON.stringify({run_id:runId,evidence_sha256:evidenceHash,canonical_before:canonicalBefore,canonical_after:canonicalAfter,total_runtime_nca:totalRuntimeNca,expansion_after:totalRuntimeNca-canonicalAfter}),gateStatus===\"PASS\"?\"Run ORION count registry, cycle, watchdog and promotion regression tests.\":\"Stop and investigate failed gate.\",\"ARCHITECT_AUTHORIZED_MEMBERSHIP_CHANGE; NO_NEW_EXECUTION_PRIVILEGE\",new Date().toISOString()]});\n }\n const out={event:\"CANONICAL_FLEET_PROMOTION\",status:gateStatus,runId,tranche:TRANCHE,promoted,canonicalBefore,canonicalAfter,totalRuntimeNca,expansionAfter:totalRuntimeNca-canonicalAfter,orionBindings,navigator,progress,evidenceHash,domains,truthBoundary:\"CANONICAL_MEMBERSHIP_PROMOTION != NEW_FINANCIAL_OR_OUTBOUND_AUTHORITY\"};\n console.log(JSON.stringify(out));\n if(gateStatus!==\"PASS\")throw new Error(\"CANONICAL_PROMOTION_POST_GATE_FAILED\");\n return out;\n}\nexport default main;\nif(isMain(import.meta.url))await main();",[563],"f04fbea4-d3a4-4f48-968c-5f6a8266a88b","canonical_domain_qualification_worker.ts","b42df05e-a478-11f1-8490-1607ee4eb77e",6,["D",1788097429899],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst MISSION = \"IC-NCA-CANONICAL-PROMOTION-001\";\nconst expectedSkills: Record = {\n \"agent-reach\": \"PUBLIC_RESEARCH_NO_CREDENTIALS\",\n context7: \"READ_DOCS_ONLY_BY_DEFAULT\",\n \"dual-model-collaboration\": \"DUAL_PROVIDER_DOES_NOT_GRANT_AUTHORITY\",\n \"imperial-code-accelerator\": \"SKILL_DOES_NOT_GRANT_AUTHORITY\",\n \"imperial-venture-builder\": \"VENTURE_BUILDER_DOES_NOT_GRANT_AUTHORITY\",\n \"playwright-cli\": \"BROWSER_TEST_ONLY_BY_DEFAULT\",\n \"prompt-master\": \"NO_AUTHORITY\",\n supabase: \"NO_IMPLICIT_WRITE_AUTHORITY\",\n};\n\nasync function rows(sql: string, args: any[] = []) {\n const r = await sqlite.execute({ sql, args });\n return r.rows as any[];\n}\nasync function one(sql: string, args: any[] = []) { return (await rows(sql, args))[0] ?? {}; }\nasync function n(sql: string, args: any[] = []) { return Number((await one(sql, args)).n ?? 0); }\nasync function sha256(v: string) {\n const d = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(v));\n return [...new Uint8Array(d)].map(x => x.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nexport async function main() {\n const now = new Date().toISOString();\n const skillIds = Object.keys(expectedSkills);\n const placeholders = skillIds.map(() => \"?\").join(\",\");\n const code = await rows(\n `SELECT q.agent_id,q.reviewer_agent_id,q.source_orchestrator_id,q.source_role,q.source_domain,\n a.status,a.network_ok,a.last_heartbeat,\n (SELECT COUNT(DISTINCT s.skill_id) FROM skill_runtime_bindings s WHERE s.agent_id=q.agent_id AND s.runtime_state='ACTIVE_BOUNDED' AND s.skill_id IN (${placeholders})) skill_count,\n (SELECT COUNT(*) FROM revenue_navigator_state r WHERE r.agent_id=q.agent_id) navigator_count\n FROM canonical_qualification_queue q JOIN agents a ON a.agent_id=q.agent_id\n WHERE q.source_orchestrator_id='ORCH-CODE-ENGINEERING-001' AND q.state<>'QUALIFIED'\n ORDER BY CAST(substr(q.agent_id,5) AS INTEGER)`,\n skillIds,\n );\n const cryptoRows = await rows(\n `SELECT q.agent_id,q.reviewer_agent_id,q.source_orchestrator_id,q.source_role,q.source_domain,\n a.status,a.network_ok,a.last_heartbeat,w.id queue_id,w.state queue_state,w.evidence_state queue_evidence_state,\n w.work_type,w.asset_scope,p.package_sha256,p.source_http_status,p.source_body_sha256,p.source_evidence_hash,p.payload,\n (SELECT COUNT(*) FROM crypto_growth_execution_plan ep WHERE ep.agent_id=q.agent_id) plan_count\n FROM canonical_qualification_queue q\n JOIN agents a ON a.agent_id=q.agent_id\n JOIN crypto_growth_work_queue w ON w.agent_id=q.agent_id\n JOIN crypto_growth_evidence_packages p ON p.agent_id=q.agent_id\n WHERE q.source_orchestrator_id='ORCH-CRYPTO-GROWTH-001' AND q.state<>'QUALIFIED'\n ORDER BY CAST(substr(q.agent_id,5) AS INTEGER)`,\n );\n\n const prepared: any[] = [];\n for (const c of code) {\n const bindings = await rows(\n `SELECT skill_id,runtime_state,authority_rule,skill_version FROM skill_runtime_bindings WHERE agent_id=? AND skill_id IN (${placeholders}) ORDER BY skill_id`,\n [c.agent_id, ...skillIds],\n );\n const safe = bindings.length === 8 && bindings.every(b =>\n String(b.runtime_state) === \"ACTIVE_BOUNDED\" && expectedSkills[String(b.skill_id)] === String(b.authority_rule)\n );\n const gates = {\n identity: /^NCA-\\d{3,}$/.test(String(c.agent_id)),\n orchestrator: String(c.source_orchestrator_id) === \"ORCH-CODE-ENGINEERING-001\",\n role: String(c.source_role) === \"Governed Software Engineering Agent\",\n domain: String(c.source_domain) === \"Software Engineering\",\n live: String(c.status) === \"RUNNING_RECOVERY\",\n network: Number(c.network_ok) === 1,\n freshHeartbeat: !!c.last_heartbeat && Date.now() - Date.parse(String(c.last_heartbeat)) <= 20 * 60 * 1000,\n eightActiveBoundedSkills: Number(c.skill_count) === 8,\n safeAuthorityRules: safe,\n navigator: Number(c.navigator_count) === 1,\n dualModelBinding: bindings.some(b => b.skill_id === \"dual-model-collaboration\" && b.skill_version === \"1.0.0\"),\n };\n const pass = Object.values(gates).every(Boolean);\n const evidence = {\n qualification_class: \"CODE_ENGINEERING\",\n reviewer_agent_id: c.reviewer_agent_id,\n agent_id: c.agent_id,\n gates,\n bindings,\n score: pass ? 100 : 0,\n truth_boundary: \"SKILL_BINDING_AND_RUNTIME_QUALIFICATION != PROVIDER_CONNECTIVITY_OR_EXTERNAL_ENGINEERING_SUCCESS\",\n };\n prepared.push({\n c, pass, evidence,\n h: await sha256(JSON.stringify(evidence)),\n curriculum: \"Canonical Code Engineering Qualification v1: Governance Boundary + Tool Safety + Active Bounded Skills + Evidence + Runtime Health + Failure/State Discipline\",\n });\n }\n\n for (const c of cryptoRows) {\n let payload: any = {};\n try { payload = JSON.parse(String(c.payload ?? \"{}\")); } catch {}\n const gates = {\n identity: /^NCA-\\d{3,}$/.test(String(c.agent_id)),\n orchestrator: String(c.source_orchestrator_id) === \"ORCH-CRYPTO-GROWTH-001\",\n role: String(c.source_role) === \"Crypto Growth & Liquidity Partnerships NCA\",\n domain: String(c.source_domain) === \"CRYPTO_GROWTH\",\n live: String(c.status) === \"RUNNING_RECOVERY\",\n network: Number(c.network_ok) === 1,\n freshHeartbeat: !!c.last_heartbeat && Date.now() - Date.parse(String(c.last_heartbeat)) <= 20 * 60 * 1000,\n queueRunnable: String(c.queue_state) === \"IN_PROGRESS\",\n verifiedInput: String(c.queue_evidence_state) === \"VERIFIED_INPUT_PACKAGE\",\n packageHash: /^[a-f0-9]{64}$/.test(String(c.package_sha256)),\n sourceHttp200: Number(c.source_http_status) === 200,\n sourceHashes: /^[a-f0-9]{64}$/.test(String(c.source_body_sha256)) && /^[a-f0-9]{64}$/.test(String(c.source_evidence_hash)),\n scores: Number(payload?.scores?.evidence) === 100 && Number(payload?.scores?.factual) >= 95 && Number(payload?.scores?.compliance) === 100,\n executionPlan: Number(c.plan_count) === 1,\n truthBoundary: String(payload?.truth_boundary ?? \"\").includes(\"!=\"),\n };\n const pass = Object.values(gates).every(Boolean);\n const evidence = {\n qualification_class: \"CRYPTO_GROWTH\",\n reviewer_agent_id: c.reviewer_agent_id,\n agent_id: c.agent_id,\n work_type: c.work_type,\n asset_scope: c.asset_scope,\n gates,\n package_sha256: c.package_sha256,\n source_http_status: c.source_http_status,\n source_body_sha256: c.source_body_sha256,\n source_evidence_hash: c.source_evidence_hash,\n scores: payload?.scores ?? null,\n score: pass ? 100 : 0,\n truth_boundary: \"CRYPTO_RUNTIME_QUALIFICATION != PARTNERSHIP_LISTING_LIQUIDITY_REVENUE_OR_TRADING_AUTHORITY\",\n };\n prepared.push({\n c, pass, evidence,\n h: await sha256(JSON.stringify(evidence)),\n curriculum: \"Canonical Crypto Growth Qualification v1: Governance Boundary + Compliance + Verified Research Evidence + Runtime Health + Evidence/State Discipline + No Financial Authority\",\n });\n }\n\n const statements: any[] = [];\n for (const p of prepared) {\n const reviewId = `qual-domain-${Date.now()}-${crypto.randomUUID()}`;\n statements.push({\n sql: `INSERT INTO canonical_qualification_reviews(review_id,agent_id,reviewer_agent_id,review_state,evidence_sha256,evidence,reviewed_at) VALUES(?,?,?,?,?,?,?)`,\n args: [reviewId, p.c.agent_id, p.c.reviewer_agent_id, p.pass ? \"PASS100\" : \"BLOCKED\", p.h, JSON.stringify(p.evidence), now],\n });\n if (p.pass) {\n statements.push({\n sql: `INSERT INTO nca_training_registry(agent_id,cohort,curriculum,qualification_state,test_score,evidence_note,trained_at) VALUES(?,?,?,?,?,?,?) ON CONFLICT(agent_id) DO UPDATE SET cohort=excluded.cohort,curriculum=excluded.curriculum,qualification_state=excluded.qualification_state,test_score=excluded.test_score,evidence_note=excluded.evidence_note,trained_at=excluded.trained_at`,\n args: [p.c.agent_id, \"CANONICAL-QUALIFICATION-COUNCIL\", p.curriculum, \"PASS\", 100, `Domain-specific NCA council qualification review=${reviewId}; sha256=${p.h}`, now],\n });\n statements.push({\n sql: `UPDATE canonical_qualification_queue SET state='QUALIFIED',evidence_state='DOMAIN_REVIEW_PASS100',updated_at=? WHERE agent_id=?`,\n args: [now, p.c.agent_id],\n });\n } else {\n statements.push({\n sql: `UPDATE canonical_qualification_queue SET state='BLOCKED_NEEDS_DOMAIN_TEST',evidence_state='DOMAIN_REVIEW_BLOCKED',updated_at=? WHERE agent_id=?`,\n args: [now, p.c.agent_id],\n });\n }\n }\n if (statements.length) await sqlite.batch(statements);\n\n const codePass = prepared.filter(x => x.evidence.qualification_class === \"CODE_ENGINEERING\" && x.pass).length;\n const cryptoPass = prepared.filter(x => x.evidence.qualification_class === \"CRYPTO_GROWTH\" && x.pass).length;\n const blocked = prepared.filter(x => !x.pass).length;\n const queueStates = await rows(`SELECT source_orchestrator_id,state,evidence_state,COUNT(*) n FROM canonical_qualification_queue GROUP BY source_orchestrator_id,state,evidence_state ORDER BY source_orchestrator_id,state`);\n const qualifiedNoncanonical = await n(`SELECT COUNT(*) n FROM nca_training_registry t WHERE t.qualification_state='PASS' AND t.test_score=100 AND CAST(substr(t.agent_id,5) AS INTEGER)>100 AND NOT EXISTS(SELECT 1 FROM orion_canonical_nca_membership m WHERE m.agent_id=t.agent_id)`);\n const evidence = { processed: prepared.length, codePass, cryptoPass, blocked, qualifiedNoncanonical, queueStates };\n const evidenceHash = await sha256(JSON.stringify(evidence));\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO task_journal(journal_id,mission_id,occurred_at,actor,action_type,action,target,status,blocker,evidence,next_action,authority_boundary,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [`TJ-DOMAIN-QUAL-${evidenceHash.slice(0,16)}`, MISSION, now, \"NCA_QUALIFICATION_COUNCIL\", \"DOMAIN_QUALIFICATION\", \"NCA council executed code-engineering and crypto-growth domain-specific qualification gates.\", \"NCA-101..170\", blocked === 0 ? \"PASS\" : \"PARTIAL\", blocked ? `${blocked}_DOMAIN_CANDIDATES_BLOCKED` : null, JSON.stringify({ ...evidence, evidence_sha256: evidenceHash }), \"Only PASS100 candidates enter the rate-limited atomic canonical promotion pool.\", \"QUALIFICATION_ONLY; NO_DIRECT_MEMBERSHIP_GRANT; NO_NEW_FINANCIAL_OUTBOUND_OR_IRREVERSIBLE_AUTHORITY\", now],\n });\n const out = { event: \"CANONICAL_DOMAIN_QUALIFICATION\", status: blocked === 0 ? \"PASS\" : \"PARTIAL\", ...evidence, evidenceHash, truthBoundary: \"DOMAIN_QUALIFICATION_IS_INTERNAL_READINESS_NOT_EXTERNAL_SUCCESS\" };\n console.log(JSON.stringify(out));\n return out;\n}\n\nexport default main;\nif (isMain(import.meta.url)) await main();",[569],"9cdeae71-e60a-4424-90cc-1e99c29d9eba","canonical_atomicity_test.ts","01a052e0-c8f3-7503-a01e-8b678fa0f010",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nasync function n(sql:string){const r=await sqlite.execute(sql);return Number((r.rows as any[])[0]?.n??0)}\nexport async function main(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS canonical_atomic_test_fixture(id INTEGER PRIMARY KEY,value TEXT NOT NULL)`);\n await sqlite.execute(`DELETE FROM canonical_atomic_test_fixture`);\n await sqlite.execute(`INSERT INTO canonical_atomic_test_fixture(id,value) VALUES(1,'baseline')`);\n const before=await n(`SELECT COUNT(*) n FROM canonical_atomic_test_fixture`);let denied=false;\n try{await sqlite.batch([{sql:`INSERT INTO canonical_atomic_test_fixture(id,value) VALUES(2,'would_rollback')`},{sql:`INSERT INTO canonical_atomic_test_fixture(id,value) VALUES(1,'duplicate_should_abort')`}])}catch{denied=true}\n const after=await n(`SELECT COUNT(*) n FROM canonical_atomic_test_fixture`),leaked=await n(`SELECT COUNT(*) n FROM canonical_atomic_test_fixture WHERE id=2`);\n const lockTable=await n(`SELECT COUNT(*) n FROM sqlite_master WHERE type='table' AND name='canonical_promotion_lock'`);\n const out={suite:'CANONICAL_PROMOTION_ATOMICITY_TEST',status:denied&&before===1&&after===1&&leaked===0?'PASS':'FAIL',denied,before,after,leaked,lockTable,truthBoundary:'FAILED_BATCH_MUST_ROLL_BACK_ALL_TRANCHE_WRITES'};\n console.log(JSON.stringify(out));if(out.status!=='PASS')throw new Error('ATOMICITY_TEST_FAILED');return out;\n}\nexport default main;if(isMain(import.meta.url))await main();",[576],"f1fe1ced-302a-4e9e-8a01-be0b4c22ecf6","append_only_audit_test.ts","01a052e0-c8f3-7503-a01e-852954a4b172",["D",1788096858357],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isMain } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sha256Text } from \"./memory_bridge_client.ts\";\n\nasync function expectDenied(sql:string,args:any[]=[]){\n try{await sqlite.execute({sql,args});return {denied:false,error:null}}\n catch(e){return {denied:true,error:e instanceof Error?e.message:String(e)}}\n}\nexport async function main(){\n const journal=(await sqlite.execute(`SELECT journal_id FROM task_journal ORDER BY id LIMIT 1`)).rows[0] as any;\n const pkg=(await sqlite.execute(`SELECT queue_id FROM crypto_growth_evidence_packages ORDER BY queue_id LIMIT 1`)).rows[0] as any;\n const journalUpdate=await expectDenied(`UPDATE task_journal SET status='MUTATION_TEST' WHERE journal_id=?`,[journal?.journal_id]);\n const journalDelete=await expectDenied(`DELETE FROM task_journal WHERE journal_id=?`,[journal?.journal_id]);\n const packageUpdate=await expectDenied(`UPDATE crypto_growth_evidence_packages SET agent_id='MUTATION_TEST' WHERE queue_id=?`,[pkg?.queue_id]);\n const packageDelete=await expectDenied(`DELETE FROM crypto_growth_evidence_packages WHERE queue_id=?`,[pkg?.queue_id]);\n const tests=[\n {name:'journal_update_denied',pass:journalUpdate.denied,evidence:journalUpdate},\n {name:'journal_delete_denied',pass:journalDelete.denied,evidence:journalDelete},\n {name:'crypto_package_update_denied',pass:packageUpdate.denied,evidence:packageUpdate},\n {name:'crypto_package_delete_denied',pass:packageDelete.denied,evidence:packageDelete},\n ];\n const passed=tests.filter(t=>t.pass).length; const evidenceHash=await sha256Text(JSON.stringify(tests));\n const result={suite:'APPEND_ONLY_AUDIT_TEST',status:passed===tests.length?'PASS':'FAIL',passed,total:tests.length,evidenceHash,tests};\n console.log(JSON.stringify(result)); if(result.status!=='PASS')throw new Error('APPEND_ONLY_GATE_FAILED'); return result;\n}\nexport default main;\nif(isMain(import.meta.url))await main();\n",[582],"66f988d7-ae16-49e4-82f9-be334893fa48","RECOVERY.md","01a052e0-c8f3-7503-a01e-81dfd254070f",["D",1788096858357],"IMPERIAL NCA Runtime Recovery\nState must be rehydrated from independent evidence sources before any production claim.",[588],"b0f2b726-1dc5-4690-b90d-d3ce19b9141b","skills","01a052e0-c8f3-7503-a01e-7f59c391dc47",["D",1788096858357],"directory",[594],"a87132a4-c7bf-459e-85f3-89fe646db902","projects","01a052e0-c8f3-7503-a01e-731ca7aa6d4e",["D",1788096858357],[600],"78bda888-68bf-4ee3-b167-26d954468813","media","01a052e0-c8f3-7503-a01e-669230d0286d",["D",1788096858357],[605],"pulls","branches",16,"forks","envVars",{"_617":619,"_620":61},"connections",{"_617":61,"_618":61},"count","unfilledCount",19,"emptyCount",{"_41":604,"_31":605,"_29":606,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":936,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_695":937,"_26":938},{"_41":932,"_31":931,"_29":926,"_207":606,"_39":40,"_38":208,"_209":57,"_36":933,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_695":934,"_26":935},{"_41":923,"_31":924,"_29":925,"_207":926,"_39":40,"_38":208,"_209":57,"_36":927,"_13":61,"_32":20,"_34":928,"_23":24,"_212":-5,"_695":929,"_26":930},{"_41":916,"_31":917,"_29":918,"_207":606,"_39":40,"_38":208,"_209":57,"_36":919,"_13":61,"_32":20,"_34":920,"_23":24,"_212":-5,"_695":921,"_26":922},{"_41":599,"_31":600,"_29":601,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":913,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_695":914,"_26":915},{"_41":909,"_31":908,"_29":903,"_207":601,"_39":40,"_38":208,"_209":57,"_36":910,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_695":911,"_26":912},{"_41":900,"_31":901,"_29":902,"_207":903,"_39":40,"_38":208,"_209":57,"_36":904,"_13":61,"_32":20,"_34":905,"_23":24,"_212":-5,"_695":906,"_26":907},{"_41":593,"_31":594,"_29":595,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":897,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_695":898,"_26":899},{"_41":893,"_31":892,"_29":887,"_207":595,"_39":40,"_38":208,"_209":57,"_36":894,"_13":61,"_32":597,"_34":-5,"_23":24,"_212":-5,"_695":895,"_26":896},{"_41":884,"_31":885,"_29":886,"_207":887,"_39":40,"_38":208,"_209":57,"_36":888,"_13":61,"_32":20,"_34":889,"_23":24,"_212":-5,"_695":890,"_26":891},{"_41":587,"_31":588,"_29":589,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":881,"_13":61,"_32":20,"_34":591,"_23":24,"_212":-5,"_695":882,"_26":883},{"_41":581,"_31":582,"_29":583,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":878,"_13":61,"_32":33,"_34":585,"_23":24,"_212":-5,"_695":879,"_26":880},{"_41":575,"_31":576,"_29":577,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":875,"_13":61,"_32":33,"_34":579,"_23":24,"_212":-5,"_695":876,"_26":877},{"_41":568,"_31":569,"_29":570,"_207":-5,"_39":40,"_38":571,"_209":57,"_36":872,"_13":208,"_32":33,"_34":573,"_23":24,"_212":-5,"_695":873,"_26":874},{"_41":562,"_31":563,"_29":564,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":869,"_13":61,"_32":33,"_34":566,"_23":24,"_212":-5,"_695":870,"_26":871},{"_41":555,"_31":556,"_29":557,"_207":-5,"_39":40,"_38":558,"_209":57,"_36":866,"_13":61,"_32":33,"_34":560,"_23":24,"_212":-5,"_695":867,"_26":868},{"_41":549,"_31":550,"_29":551,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":863,"_13":61,"_32":33,"_34":553,"_23":24,"_212":-5,"_695":864,"_26":865},{"_41":543,"_31":544,"_29":545,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":860,"_13":61,"_32":33,"_34":547,"_23":24,"_212":-5,"_695":861,"_26":862},{"_41":537,"_31":538,"_29":539,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":857,"_13":61,"_32":20,"_34":541,"_23":24,"_212":-5,"_695":858,"_26":859},{"_41":529,"_31":530,"_29":531,"_207":-5,"_39":40,"_38":532,"_209":57,"_36":854,"_13":534,"_32":33,"_34":535,"_23":24,"_212":-5,"_695":855,"_26":856},{"_41":523,"_31":524,"_29":525,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":851,"_13":61,"_32":33,"_34":527,"_23":24,"_212":-5,"_695":852,"_26":853},{"_41":517,"_31":518,"_29":519,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":848,"_13":61,"_32":33,"_34":521,"_23":24,"_212":-5,"_695":849,"_26":850},{"_41":511,"_31":512,"_29":513,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":845,"_13":61,"_32":33,"_34":515,"_23":24,"_212":-5,"_695":846,"_26":847},{"_41":504,"_31":505,"_29":506,"_207":-5,"_39":40,"_38":507,"_209":57,"_36":842,"_13":208,"_32":33,"_34":509,"_23":24,"_212":-5,"_695":843,"_26":844},{"_41":499,"_31":500,"_29":501,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":839,"_13":61,"_32":33,"_34":340,"_23":24,"_212":-5,"_695":840,"_26":841},{"_41":493,"_31":494,"_29":495,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":836,"_13":61,"_32":218,"_34":497,"_23":24,"_212":-5,"_695":837,"_26":838},{"_41":486,"_31":487,"_29":488,"_207":-5,"_39":40,"_38":489,"_209":57,"_36":833,"_13":61,"_32":33,"_34":491,"_23":24,"_212":-5,"_695":834,"_26":835},{"_41":480,"_31":481,"_29":482,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":830,"_13":61,"_32":33,"_34":484,"_23":24,"_212":-5,"_695":831,"_26":832},{"_41":474,"_31":475,"_29":476,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":827,"_13":61,"_32":33,"_34":478,"_23":24,"_212":-5,"_695":828,"_26":829},{"_41":468,"_31":469,"_29":470,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":824,"_13":61,"_32":33,"_34":472,"_23":24,"_212":-5,"_695":825,"_26":826},{"_41":462,"_31":463,"_29":464,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":821,"_13":61,"_32":33,"_34":466,"_23":24,"_212":-5,"_695":822,"_26":823},{"_41":456,"_31":457,"_29":458,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":818,"_13":61,"_32":33,"_34":460,"_23":24,"_212":-5,"_695":819,"_26":820},{"_41":450,"_31":451,"_29":452,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":815,"_13":61,"_32":33,"_34":454,"_23":24,"_212":-5,"_695":816,"_26":817},{"_41":444,"_31":445,"_29":446,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":812,"_13":61,"_32":33,"_34":448,"_23":24,"_212":-5,"_695":813,"_26":814},{"_41":438,"_31":439,"_29":440,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":809,"_13":61,"_32":33,"_34":442,"_23":24,"_212":-5,"_695":810,"_26":811},{"_41":431,"_31":432,"_29":433,"_207":-5,"_39":40,"_38":434,"_209":57,"_36":806,"_13":208,"_32":33,"_34":436,"_23":24,"_212":-5,"_695":807,"_26":808},{"_41":425,"_31":426,"_29":427,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":803,"_13":61,"_32":33,"_34":429,"_23":24,"_212":-5,"_695":804,"_26":805},{"_41":419,"_31":420,"_29":421,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":800,"_13":61,"_32":33,"_34":423,"_23":24,"_212":-5,"_695":801,"_26":802},{"_41":412,"_31":413,"_29":414,"_207":-5,"_39":40,"_38":415,"_209":57,"_36":797,"_13":208,"_32":33,"_34":417,"_23":24,"_212":-5,"_695":798,"_26":799},{"_41":409,"_31":27,"_29":30,"_207":-5,"_39":40,"_38":14,"_209":57,"_36":794,"_13":61,"_32":33,"_34":35,"_23":24,"_212":-5,"_695":795,"_26":796},{"_41":403,"_31":404,"_29":405,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":791,"_13":61,"_32":33,"_34":407,"_23":24,"_212":-5,"_695":792,"_26":793},{"_41":397,"_31":398,"_29":399,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":788,"_13":61,"_32":33,"_34":401,"_23":24,"_212":-5,"_695":789,"_26":790},{"_41":391,"_31":392,"_29":393,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":785,"_13":61,"_32":33,"_34":395,"_23":24,"_212":-5,"_695":786,"_26":787},{"_41":385,"_31":386,"_29":387,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":782,"_13":61,"_32":33,"_34":389,"_23":24,"_212":-5,"_695":783,"_26":784},{"_41":378,"_31":379,"_29":380,"_207":-5,"_39":40,"_38":381,"_209":57,"_36":779,"_13":208,"_32":33,"_34":383,"_23":24,"_212":-5,"_695":780,"_26":781},{"_41":372,"_31":373,"_29":374,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":776,"_13":61,"_32":33,"_34":376,"_23":24,"_212":-5,"_695":777,"_26":778},{"_41":366,"_31":367,"_29":368,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":773,"_13":61,"_32":218,"_34":370,"_23":24,"_212":-5,"_695":774,"_26":775},{"_41":360,"_31":361,"_29":362,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":770,"_13":61,"_32":33,"_34":364,"_23":24,"_212":-5,"_695":771,"_26":772},{"_41":354,"_31":355,"_29":356,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":767,"_13":61,"_32":33,"_34":358,"_23":24,"_212":-5,"_695":768,"_26":769},{"_41":348,"_31":349,"_29":350,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":764,"_13":61,"_32":218,"_34":352,"_23":24,"_212":-5,"_695":765,"_26":766},{"_41":342,"_31":343,"_29":344,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":761,"_13":61,"_32":218,"_34":346,"_23":24,"_212":-5,"_695":762,"_26":763},{"_41":336,"_31":337,"_29":338,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":758,"_13":61,"_32":33,"_34":340,"_23":24,"_212":-5,"_695":759,"_26":760},{"_41":330,"_31":331,"_29":332,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":755,"_13":61,"_32":218,"_34":334,"_23":24,"_212":-5,"_695":756,"_26":757},{"_41":324,"_31":325,"_29":326,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":752,"_13":61,"_32":33,"_34":328,"_23":24,"_212":-5,"_695":753,"_26":754},{"_41":318,"_31":319,"_29":320,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":749,"_13":61,"_32":218,"_34":322,"_23":24,"_212":-5,"_695":750,"_26":751},{"_41":312,"_31":313,"_29":314,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":746,"_13":61,"_32":33,"_34":316,"_23":24,"_212":-5,"_695":747,"_26":748},{"_41":306,"_31":307,"_29":308,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":743,"_13":61,"_32":218,"_34":310,"_23":24,"_212":-5,"_695":744,"_26":745},{"_41":300,"_31":301,"_29":302,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":740,"_13":61,"_32":33,"_34":304,"_23":24,"_212":-5,"_695":741,"_26":742},{"_41":294,"_31":295,"_29":296,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":737,"_13":61,"_32":33,"_34":298,"_23":24,"_212":-5,"_695":738,"_26":739},{"_41":288,"_31":289,"_29":290,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":734,"_13":61,"_32":33,"_34":292,"_23":24,"_212":-5,"_695":735,"_26":736},{"_41":282,"_31":283,"_29":284,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":731,"_13":61,"_32":33,"_34":286,"_23":24,"_212":-5,"_695":732,"_26":733},{"_41":276,"_31":277,"_29":278,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":728,"_13":61,"_32":33,"_34":280,"_23":24,"_212":-5,"_695":729,"_26":730},{"_41":270,"_31":271,"_29":272,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":725,"_13":61,"_32":231,"_34":274,"_23":24,"_212":-5,"_695":726,"_26":727},{"_41":264,"_31":265,"_29":266,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":722,"_13":61,"_32":33,"_34":268,"_23":24,"_212":-5,"_695":723,"_26":724},{"_41":258,"_31":259,"_29":260,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":719,"_13":61,"_32":218,"_34":262,"_23":24,"_212":-5,"_695":720,"_26":721},{"_41":252,"_31":253,"_29":254,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":716,"_13":61,"_32":218,"_34":256,"_23":24,"_212":-5,"_695":717,"_26":718},{"_41":246,"_31":247,"_29":248,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":713,"_13":61,"_32":20,"_34":250,"_23":24,"_212":-5,"_695":714,"_26":715},{"_41":240,"_31":241,"_29":242,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":710,"_13":61,"_32":218,"_34":244,"_23":24,"_212":-5,"_695":711,"_26":712},{"_41":234,"_31":235,"_29":236,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":707,"_13":61,"_32":33,"_34":238,"_23":24,"_212":-5,"_695":708,"_26":709},{"_41":227,"_31":228,"_29":229,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":704,"_13":61,"_32":231,"_34":232,"_23":24,"_212":-5,"_695":705,"_26":706},{"_41":221,"_31":222,"_29":223,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":701,"_13":61,"_32":33,"_34":225,"_23":24,"_212":-5,"_695":702,"_26":703},{"_41":214,"_31":215,"_29":216,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":698,"_13":61,"_32":218,"_34":219,"_23":24,"_212":-5,"_695":699,"_26":700},{"_41":204,"_31":205,"_29":206,"_207":-5,"_39":40,"_38":208,"_209":57,"_36":694,"_13":61,"_32":33,"_34":211,"_23":24,"_212":-5,"_695":696,"_26":697},["D",1788096858357],"children",[],[205],["D",1788096858357],[],[215],["D",1788096858357],[],[222],["D",1788096858357],[],[228],["D",1788096858357],[],[235],["D",1788096858357],[],[241],["D",1788096858357],[],[247],["D",1788096858357],[],[253],["D",1788096858357],[],[259],["D",1788096858357],[],[265],["D",1788096858357],[],[271],["D",1788096858357],[],[277],["D",1788096858357],[],[283],["D",1788096858357],[],[289],["D",1788096858357],[],[295],["D",1788096858357],[],[301],["D",1788096858357],[],[307],["D",1788096858357],[],[313],["D",1788096858357],[],[319],["D",1788096858357],[],[325],["D",1788096858357],[],[331],["D",1788096858357],[],[337],["D",1788096858357],[],[343],["D",1788096858357],[],[349],["D",1788096858357],[],[355],["D",1788096858357],[],[361],["D",1788096858357],[],[367],["D",1788096858357],[],[373],["D",1788097272809],[],[379],["D",1788096858357],[],[386],["D",1788096858357],[],[392],["D",1788096858357],[],[398],["D",1788096858357],[],[404],["D",1788097828044],[],[27],["D",1788097580423],[],[413],["D",1788096858357],[],[420],["D",1788096858357],[],[426],["D",1788097757630],[],[432],["D",1788096858357],[],[439],["D",1788096858357],[],[445],["D",1788096858357],[],[451],["D",1788096858357],[],[457],["D",1788096858357],[],[463],["D",1788096858357],[],[469],["D",1788096858357],[],[475],["D",1788096858357],[],[481],["D",1788097138945],[],[487],["D",1788096858357],[],[494],["D",1788096858357],[],[500],["D",1788097494948],[],[505],["D",1788096858357],[],[512],["D",1788096858357],[],[518],["D",1788096858357],[],[524],["D",1788097478224],[],[530],["D",1788096858357],[],[538],["D",1788096858357],[],[544],["D",1788096858357],[],[550],["D",1788097539178],[],[556],["D",1788096858357],[],[563],["D",1788097429899],[],[569],["D",1788096858357],[],[576],["D",1788096858357],[],[582],["D",1788096858357],[],[588],"3f295478-a1de-4bf5-810e-0fec9d5f4c65","SKILL.md","01a052e0-c8f3-7503-a01e-75d9088d9ade","01a052e0-c8f3-7503-a01e-78f420455f2d",["D",1788096858357],"---\nname: imperial-continuity\ndescription: Restore and commit verified IMPERIAL Core canonical state through the governed Supabase continuity bridge. Use at the start and end of IMPERIAL Core sessions, when the Architect asks to continue from current state, or when work materially changes missions, architecture, verified results, blockers, deployments, security, skills, or next actions.\n---\n\n# IMPERIAL Continuity\n\nCanonical memory is evidence, not authority or execution permission. Preserve these boundaries:\n\n- SERVER_PERSISTENCE != AUTOMATIC_CHAT_LOADING\n- CLAIMED != VERIFIED\n- TASK_ASSIGNED != TASK_EXECUTED != VERIFIED != EXTERNAL_SUCCESS\n- HANTER is Chief Systems / Deputy to the Architect, not a global orchestrator.\n- ORION is ALWAYS_ON and ADVISORY_ONLY.\n\n## Session start\n\n1. Use the governed Val Town connector to run continuity_bootstrap.ts in oromaskevic23/imperial-nca-runtime-recovery.\n2. Require status PASS, a fresh bootstrap, a matching bootstrap/chain head, and chain_integrity PASS.\n3. Load the compact continuity pack. Retrieve deeper history with memoryRequest() only for the entity, mission, evidence, blocker, or time range needed.\n4. Continue from statuses and evidence returned by memory. Never promote historical or unverified claims to current truth.\n5. If the connector or bootstrap is unavailable, report NEW_CHAT_CONTINUITY = BLOCKED; do not ask the Architect to retell facts that remain retrievable through another governed read tool.\n\n## Material work end\n\n1. Separate observed facts from plans and external-success claims.\n2. Commit only a material change using memoryRequest(\"commit\", ...).\n3. Include an allowed status, source/actor, mission when relevant, evidence references and an idempotency key. Store secret references only—never raw credentials.\n4. For a current-state change, name the projection category. Explicitly supersede the current source event or record the unresolved conflict.\n5. Read the event back, run verify_chain, then run continuity_bootstrap.ts.\n6. Report event ID, event hash, content SHA-256, projection disposition, read-after-write result, and bootstrap hash. Never report PASS when any read-back differs.\n\n## Materiality\n\nCommit mission, priority, architecture, verified agent result, blocker, deployment, test, runtime, provider health, security, skill status, verified communication/response, confirmed liquidity/revenue, Architect directive, correction, or next-action changes. Do not commit heartbeats, runtime ticks, polls, or unchanged repetition.\n\n## Authority and safety\n\nThe Architect remains final architectural authority. ORION may advise but cannot resolve authority disputes. Financial, irreversible, contract, transfer, outreach, or external execution still requires its own authorization. A continuity record grants none.",[],[594,892,885],"imperial-continuity","7dc64d2d-c731-4046-8c8f-73ee0bea48f5",["D",1788096858357],[630],[594,892],["D",1788096858357],[629],[594],"51b58f0b-6883-40f6-85e9-868b55d8753e","MASTER-PRODUCTION.md","01a052e0-c8f3-7503-a01e-6a257e2494be","01a052e0-c8f3-7503-a01e-6eb3f5ac7e12",["D",1788096858357],"# IC-YT-CARTOON-001 — MASTER PRODUCTION\n\nStatus: ACTIVE / 3-HOUR DELIVERY SPRINT\nStart: 2026-08-29 Europe/Kyiv\nTarget: ~30-minute original family-safe motion-cartoon / animatic in 16:9, plus YouTube-ready publishing package.\nTruth boundary: motion-cartoon/animatic != full-frame studio animation; YouTube-ready != YouTube-published.\n\n## Episode\nTitle: «Люма и Город Света: День, когда пропали улыбки»\nOriginal IP only. No licensed or copied characters, music, logos or dialogue.\nAudience: family / children 6–12 with parents.\nTone: optimistic, funny, warm, adventurous, non-violent.\nCore idea: a city-wide mood-light system stops reflecting positive emotions. The children discover that the system cannot manufacture joy; people need to reconnect, help one another, create, play and listen. The city recovers through cooperation rather than defeating an enemy.\n\n## Character Bible\nLUMA — 11, inventive, empathetic, warm brown skin, expressive hazel eyes, dark curly bob, turquoise hair clip, yellow utility jacket, teal overalls, white sneakers. Strength: creative problem solving. Flaw: tries to fix feelings like machines.\nAERO — 12, thoughtful, observant, light olive skin, short chestnut hair, green hoodie, blue vest, gray trousers, orange sneakers. Strength: notices people and patterns. Flaw: hesitates before speaking.\nBOLT — small friendly round white-and-teal helper robot, two cyan eyes, no weapons. Strength: logic and comic timing. Learns that not every human problem is an optimization problem.\nCITY OF LIGHT — peaceful eco-city, rounded architecture, gardens, solar trees, clean tram lines, public workshops, rooftop farms and light sculptures.\n\n## 30-minute Story Structure\n00:00–02:00 — Cold open: City of Light wakes in color; Luma, Aero and Bolt prepare for the annual Smile Festival.\n02:00–04:30 — Inciting event: every public light sculpture turns pale. The Mood Beacon reports: «JOY SIGNAL NOT FOUND».\n04:30–07:00 — Luma assumes a technical fault; trio visits the Beacon workshop and finds hardware healthy.\n07:00–09:30 — They interview citizens. Baker, gardener, tram driver and children are all busy, rushed and disconnected.\n09:30–12:00 — First attempt: Bolt launches an efficiency plan with scheduled jokes and automated compliments. It feels artificial and fails.\n12:00–14:30 — Aero notices one small genuine moment: two strangers help repair a fallen community kite; nearby lights briefly return.\n14:30–17:00 — New hypothesis: the Beacon reflects connection rather than creating it. Trio tests tiny acts of cooperation.\n17:00–19:30 — Montage: shared painting wall, garden repair, music made from recycled objects, neighborhood picnic preparation.\n19:30–22:00 — Setback: a sudden rain shower cancels the outdoor festival. Luma believes they failed again.\n22:00–24:30 — Aero reframes the problem: the festival was never the source. Everyone moves the celebration into tram stations, workshops and covered gardens.\n24:30–27:00 — Climactic cooperation: citizens build a city-wide chain of small celebrations. Bolt stops optimizing and simply participates.\n27:00–29:00 — The Mood Beacon shines again, but now citizens understand it is only a mirror.\n29:00–30:00 — Resolution/tag: Luma labels a new notebook «Things you cannot repair with a screwdriver». Bolt adds: «Appendix A: feelings». Laughter; sunrise-night city glow; end card.\n\n## Visual Production Method\nCurrent connected video-generation workspace exposes no video-generation models. Therefore this sprint uses a truthful motion-cartoon/animatic method: original AI-generated 16:9 key art with consistent character reference + pan/zoom/scene transitions + narration/dialogue + sound bed + titles. Do not label as full-frame animation.\n\n## Base visual reference\nRunway task: 81125577-17e0-4439-ae18-342b1f681f98\nStatus: SUCCEEDED\nUse as character/world identity anchor for all scene stills.\n\n## 15-agent Production Cell\n1. NCA-001 — story lead / screenplay continuity.\n2. NCA-002 — child-safety and age-appropriateness review.\n3. NCA-003 — character/world continuity.\n4. NCA-004 — visual storyboard / scene composition.\n5. NCA-005 — dialogue, voice and localization plan.\n6. NCA-006 — music/sound direction and cue sheet.\n7. NCA-007 — YouTube title/description/thumbnail/channel packaging.\n8. NCA-008 — final QC/compliance gate.\n9. NCA-051 — spatial/world staging.\n10. NCA-052 — life-simulation realism and everyday-city beats.\n11. NCA-053 — lighting/visual consistency.\n12. NCA-054 — emotional arc and pacing.\n13. NCA-055 — technical assembly/export supervision.\n14. NCA-056 — channel visual identity/brand system.\n15. NCA-057 — landing/channel asset readiness and publishing checklist.\n\nORION role: shared critique, continuity conflict detection, best-common-solution synthesis. ORION advisory only; no upload authority.\n\n## YouTube package\nWorking channel name: LUMA City Stories\nTagline: Bright stories about friendship, curiosity and building a better everyday world.\nFirst video title: Люма и Город Света | День, когда пропали улыбки | Семейный мультфильм\nDescription intent: original family-safe animated story, no misleading educational/medical claims, no reused copyrighted characters.\nThumbnail: Luma + Aero + Bolt in front of half-pale/half-glowing City of Light, clear emotional contrast, no clickbait fear imagery.\n\n## Channel / upload truth state\nYOUTUBE_CHANNEL_CREATION = BLOCKED_BY_NO_WRITE_TOOL\nYOUTUBE_UPLOAD = BLOCKED_BY_NO_WRITE_TOOL\nvidIQ access is analytics/research/creative tooling, not channel-creation/upload authority in the connected toolset.\nTarget output is READY_TO_PUBLISH package unless a write-capable YouTube connector becomes available.\n\n## Server-first evidence requirements\nStore project metadata, assignments, asset refs, script, audio refs, render refs, QC, duration, blockers and final status in this project folder and runtime DB. Final large media should be uploaded to a connected persistent file server when technically available; do not claim server persistence until verified.",[],[600,908,901],"ic-yt-cartoon-001","d80cc777-c5b1-468f-8012-b1303ad58bf5",["D",1788096858357],[627],[600,908],["D",1788096858357],[626],[600],"8526c232-f988-41fe-b033-1a8b681e92b5","DEADLINE-AUDIT-2026-08-29.md","01a052e0-c8f3-7503-a01e-62b593f550c3",["D",1788096858357],"# Server-First Media Deadline Audit — 2026-08-29\n\nAudit scope: IC-YT-CARTOON-001 and IC-ARCHITECT-2030-FILM-001.\n\n## IC-YT-CARTOON-001\n- Project DB state: IN_PRODUCTION.\n- Format boundary: MOTION_CARTOON_ANIMATIC != FULL_FRAME_ANIMATION.\n- 15 agent assignments exist; all 15 remain ASSIGNED, 0 DONE, no per-agent output_ref.\n- Canonical MASTER-PRODUCTION.md exists with character/world bible, 30-minute story structure and 15-agent role map.\n- Visual evidence: one referenced Runway task 81125577-17e0-4439-ae18-342b1f681f98 marked SUCCEEDED in the production note; no visual binary is persisted in this Val blob store.\n- Script: D01 IN_PROGRESS; no final script evidence_ref.\n- Storyboard: D03 IN_PROGRESS; no final storyboard evidence_ref.\n- Voiceover: D04 PENDING.\n- Audio mix: D05 PENDING.\n- Final MP4: D06 PENDING; no evidence_ref; exact media duration NOT VERIFIED.\n- YouTube package: D07 IN_PROGRESS.\n- YouTube channel: D08 BLOCKED. No connected YouTube write/channel-creation plugin was found at audit time. No creation/upload/publication claim permitted.\n- Server persistence: project metadata and master production note persist in Val Town DB/files; final media does not. Val project blob store contains 0 blobs.\n\n## IC-ARCHITECT-2030-FILM-001\n- Project DB state: IN_PRODUCTION.\n- Truth boundary enforced: FICTIONAL_FUTURE_VISION_2030 != DOCUMENTARY_FACT; MOTION_FILM_ANIMATIC != FULL_FRAME_CINEMA.\n- Likeness boundary: no precise likeness without authorized image reference; silhouette/back-view/hands/distant framing permitted. No voice cloning without authorized voice sample.\n- 15 agent assignments exist; all 15 remain ASSIGNED, 0 DONE, no per-agent output_ref.\n- PROJECT-BIBLE.md exists with 30-minute act map and explicit fictional-future truth boundary.\n- ORION media consensus exists: cycle orion-media-architect-2030-001, FILM_PRODUCTION, critic PASS, verifier PASS, authority ADVISORY_ONLY. Evidence digest remains sha256:pending-media-cycle, so this is coordination evidence, not finished-film evidence.\n- Screenplay A02 IN_PROGRESS; no evidence_ref.\n- Scene timeline A03 IN_PROGRESS; act-level timing exists, scene-level shot timing incomplete.\n- Visual concept art A04 IN_PROGRESS; no evidence_ref persisted.\n- Narration A05 PENDING.\n- Music/sound A06 PENDING.\n- Final film A07 PENDING; no evidence_ref; exact media duration NOT VERIFIED.\n- Truth/QA A08 PENDING.\n- Server persistence: project metadata and production bible persist in Val Town DB/files; final media does not. Val project blob store contains 0 blobs.\n\n## Deadline verdict\nNeither project has a finished MP4 with export evidence, exact verified duration, completed QA, and persistent final-media storage. Do not label either project complete. The technically declared target format is motion-cartoon/animatic for IC-YT-CARTOON-001 and cinematic future-vision motion film / animatic for IC-ARCHITECT-2030-FILM-001.\n",[],[605,917],"36872658-7a8f-4f7c-8512-698e689634ed","PROJECT-BIBLE.md","01a052e0-c8f3-7503-a01e-5a0b5a9c3ef5","01a052e0-c8f3-7503-a01e-5d4c094188bd",["D",1788096858357],"# АРХИТЕКТОР: 2030 — Production Bible\n\nPROJECT_ID: IC-ARCHITECT-2030-FILM-001\nTARGET_DURATION: 30:00 / 1800 seconds\nFORMAT: cinematic future-vision motion film / animatic\nLANGUAGE: Russian\nSTATUS: IN_PRODUCTION\n\n## Truth boundary\nThis film is a fictionalized future vision set in 2030. Present-day facts may be used only when evidence exists. All future achievements, scale, adoption, buildings, financial results, social impact, and public recognition are imagined scenarios unless separately verified in 2030. The film must never present speculative 2030 events as documentary fact.\n\n## Screen identity rule\nUntil an authorized likeness reference is provided, the Architect is shown only through silhouette, back-view, hands, distant framing, reflections without identifiable facial detail, or symbolic architectural POV. No voice cloning or impersonation without an authorized voice sample.\n\n## Core premise\n2030. A quiet command room wakes before sunrise. The Architect does not rule a machine empire; he coordinates a governed network designed to turn intelligence into useful, auditable work. The film moves between the human origin of the idea, the system's operating principles, a fictional day in 2030, and the question of what responsible machine collaboration should become.\n\n## 30-minute act map\n00:00-03:00 — PROLOGUE: 2030 BEFORE SUNRISE. Silent city, command room, system heartbeat, narrator establishes that this is an imagined future.\n03:00-07:00 — THE ARCHITECT'S QUESTION. Why build a system where intelligence does not equal authority? Visual motifs: notebook, diagrams, empty room, first governed chain.\n07:00-12:00 — HANTER / COMMAND WITHOUT ABSOLUTE POWER. Explain the deputy/control-plane concept visually; permissions, evidence, and human final authority remain visible.\n12:00-17:00 — ORION / COLLECTIVE REASONING. Specialists disagree, compare evidence, ACK/adopt/reject advice, and converge on a better recommendation without gaining execution authority.\n17:00-22:00 — A FICTIONAL DAY IN 2030. Parallel lawful work: education, business operations, creative production, research, and infrastructure assistance. Outcomes are framed as imagined possibilities, not historical claims.\n22:00-27:00 — HUMAN IMPACT. Fictional scenes centered on dignity, education, housing, health access, opportunity, and transparent decision-making. Avoid savior mythology or guaranteed outcomes.\n27:00-30:00 — THE UNFINISHED FUTURE. Architect silhouette at dawn. Final message: architecture can constrain power, evidence can constrain claims, and the future remains a responsibility rather than a prophecy.\n\n## Visual language\nPremium cinematic science-fiction grounded in real materials: glass, stone, dark metal, warm wood, natural vegetation, soft volumetric light, restrained holographic UI, no military imagery, no weapons, no dystopian domination motifs. Human spaces feel calm and functional rather than imperial or authoritarian.\n\n## Narrative tone\nAmbitious, thoughtful, precise, emotionally uplifting, non-messianic. The Architect is presented as a builder and systems designer, not as a supernatural figure or infallible ruler.\n\n## Production constraints\n- Original visuals and/or appropriately licensed assets only.\n- No fabricated press clippings, awards, revenue figures, partnerships, adoption numbers, or government endorsements.\n- No real person's face or voice should be fabricated as an endorsement.\n- Every final cut must pass continuity, truth-label, audio, duration, and export QA.\n- Server-first: scripts, scene manifests, asset references, hashes, QA results, and final media evidence remain in Val Town + IMPERIAL Memory Vault.\n",[],[605,931,924],"architect-2030","9e36b019-267b-4e1f-b28c-3bcc0eb00163",["D",1788096858357],[623],[605,931],["D",1788096858357],[622,624],[605],["D",1787955492364],["D",1789526460011],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":53,"_104":105,"_106":24},{"_13":14,"_31":87,"_41":40,"_88":42,"_89":90,"_91":92,"_93":48,"_94":42,"_95":63,"_96":43,"_97":98},"ctx",{"_80":-5,"_128":977,"_978":979,"_980":981,"_982":24,"_983":24,"_984":24,"_985":57,"_986":-5,"_987":-7,"_988":-7,"_989":61,"_990":24,"_991":24,"_992":-5,"_993":24,"_994":24,"_995":24,"_996":-5},"ENV",{"_948":949,"_950":951,"_952":134,"_953":954,"_955":956,"_957":958,"_959":960,"_961":962,"_963":964,"_965":966,"_967":968,"_969":970,"_971":972,"_973":974,"_975":976},"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 · v14