[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_210":211,"_212":213},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_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",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",31,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","core.ts","latestPath","fileId","36492a40-ad34-11f1-8d19-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ValTownOpenAI } from \"https://esm.town/v/std/openai/main.ts\";\n\nexport type AgentId = \"IMPERIAL-ADRIAN-WALKER-NCA-001\" | \"IMPERIAL-LUCAS-BENNETT-NCA-002\";\nexport type TaskKind = \"CODE\"|\"DEBUG\"|\"REFACTOR\"|\"TEST\"|\"ARCHITECTURE\"|\"SECURITY_REVIEW\"|\"DEVOPS\"|\"DATA\"|\"RESEARCH\";\n\nexport const AGENTS: Record = {\n \"IMPERIAL-ADRIAN-WALKER-NCA-001\": {\n name: \"Adrian Walker\",\n designation: \"Universal NCA\",\n role: \"Principal Autonomous Developer\",\n specialty: \"software architecture, implementation, debugging, refactoring, APIs, backend/frontend, automation\",\n skills: [\"requirements analysis\",\"repository comprehension\",\"software architecture\",\"TypeScript\",\"JavaScript\",\"Python\",\"SQL\",\"REST APIs\",\"JSON schemas\",\"backend engineering\",\"frontend fixes\",\"automation\",\"data processing\",\"debugging\",\"refactoring\",\"unit testing\",\"integration testing\",\"regression design\",\"Git patch planning\",\"CI/CD design\",\"performance analysis\",\"observability\",\"security-aware coding\",\"technical documentation\",\"delivery packaging\"],\n model: \"gpt-5.6-luna\",\n fallback: \"gpt-5.4-nano\",\n },\n \"IMPERIAL-LUCAS-BENNETT-NCA-002\": {\n name: \"Lucas Bennett\",\n designation: \"Universal NCA\",\n role: \"Autonomous Systems & Verification Developer\",\n specialty: \"systems engineering, testing, code review, security review, CI/CD, reliability, data and infrastructure\",\n model: \"gpt-5.6-luna\",\n fallback: \"gpt-5.4-nano\",\n },\n};\n\nconst now=()=>new Date().toISOString();\nasync function sha256(v:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(v));return [...new Uint8Array(d)].map(b=>b.toString(16).padStart(2,\"0\")).join(\"\");}\n\nexport async function ensureSchema(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_agents(\n agent_id TEXT PRIMARY KEY,\n human_name TEXT NOT NULL,\n designation TEXT NOT NULL,\n role TEXT NOT NULL,\n specialty TEXT NOT NULL,\n state TEXT NOT NULL,\n kill_switch INTEGER NOT NULL DEFAULT 0,\n deny_by_default INTEGER NOT NULL DEFAULT 1,\n authority_root TEXT NOT NULL DEFAULT 'ARCHITECT_ONLY',\n model TEXT NOT NULL,\n fallback_model TEXT NOT NULL,\n last_heartbeat TEXT,\n completed_tasks INTEGER NOT NULL DEFAULT 0,\n failed_tasks INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_tasks(\n task_id TEXT PRIMARY KEY,\n assigned_agent TEXT NOT NULL,\n task_kind TEXT NOT NULL,\n priority INTEGER NOT NULL DEFAULT 50,\n user_instruction TEXT NOT NULL,\n context_json TEXT NOT NULL DEFAULT '{}',\n status TEXT NOT NULL,\n require_peer_review INTEGER NOT NULL DEFAULT 1,\n attempt INTEGER NOT NULL DEFAULT 0,\n max_attempts INTEGER NOT NULL DEFAULT 3,\n implementation_json TEXT,\n review_json TEXT,\n final_json TEXT,\n blocker TEXT,\n created_at TEXT NOT NULL,\n started_at TEXT,\n completed_at TEXT,\n updated_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS dev_nca_tasks_pick ON dev_nca_tasks(status,priority,created_at)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_intake(\n command_id TEXT PRIMARY KEY,\n agent_id TEXT NOT NULL,\n task_kind TEXT NOT NULL,\n priority INTEGER NOT NULL DEFAULT 50,\n instruction TEXT NOT NULL,\n context_json TEXT NOT NULL DEFAULT '{}',\n require_peer_review INTEGER NOT NULL DEFAULT 1,\n status TEXT NOT NULL DEFAULT 'NEW',\n task_id TEXT,\n created_at TEXT NOT NULL,\n accepted_at TEXT\n )`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS dev_nca_intake_pick ON dev_nca_intake(status,priority,created_at)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_model_runs(\n run_id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n phase TEXT NOT NULL,\n model TEXT NOT NULL,\n status TEXT NOT NULL,\n response_sha256 TEXT,\n error_class TEXT,\n requested_at TEXT NOT NULL,\n completed_at TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_audit(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n event_id TEXT NOT NULL UNIQUE,\n occurred_at TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n task_id TEXT,\n event_type TEXT NOT NULL,\n status TEXT NOT NULL,\n evidence_json TEXT NOT NULL,\n prev_hash TEXT NOT NULL,\n event_hash TEXT NOT NULL UNIQUE\n )`);\n await sqlite.execute(`CREATE TRIGGER IF NOT EXISTS dev_nca_audit_no_update BEFORE UPDATE ON dev_nca_audit BEGIN SELECT RAISE(ABORT,'APPEND_ONLY_AUDIT'); END`);\n await sqlite.execute(`CREATE TRIGGER IF NOT EXISTS dev_nca_audit_no_delete BEFORE DELETE ON dev_nca_audit BEGIN SELECT RAISE(ABORT,'APPEND_ONLY_AUDIT'); END`);\n for(const [id,a] of Object.entries(AGENTS)){\n await sqlite.execute({sql:`INSERT INTO dev_nca_agents(agent_id,human_name,designation,role,specialty,state,kill_switch,deny_by_default,authority_root,model,fallback_model,last_heartbeat,updated_at)\n VALUES(?,?,?,?,?,'RUNNING_BOUNDED',0,1,'ARCHITECT_ONLY',?,?,?,?)\n ON CONFLICT(agent_id) DO UPDATE SET human_name=excluded.human_name,designation=excluded.designation,role=excluded.role,specialty=excluded.specialty,model=excluded.model,fallback_model=excluded.fallback_model,updated_at=excluded.updated_at`,\n args:[id,a.name,a.designation,a.role,a.specialty,a.model,a.fallback,now(),now()]});\n }\n}\n\nexport async function audit(agentId:string,taskId:string|null,type:string,status:string,evidence:any){\n const last=await sqlite.execute(`SELECT event_hash FROM dev_nca_audit ORDER BY id DESC LIMIT 1`);\n const prev=String(last.rows?.[0]?.event_hash??\"GENESIS\");\n const eventId=crypto.randomUUID(), at=now(), body=JSON.stringify(evidence??{});\n const hash=await sha256([eventId,at,agentId,taskId??\"\",type,status,body,prev].join(\"|\"));\n await sqlite.execute({sql:`INSERT INTO dev_nca_audit(event_id,occurred_at,agent_id,task_id,event_type,status,evidence_json,prev_hash,event_hash) VALUES(?,?,?,?,?,?,?,?,?)`,args:[eventId,at,agentId,taskId,type,status,body,prev,hash]});\n return {event_id:eventId,event_hash:hash};\n}\n\nexport async function enqueueTask(input:{agent_id:AgentId;task_kind:TaskKind;instruction:string;context?:any;priority?:number;require_peer_review?:boolean}){\n await ensureSchema();\n if(!AGENTS[input.agent_id]) throw new Error(\"UNKNOWN_AGENT\");\n const instruction=String(input.instruction??\"\").trim();\n if(instruction.length<5) throw new Error(\"TASK_INSTRUCTION_REQUIRED\");\n if(instruction.length>16000) throw new Error(\"TASK_TOO_LARGE\");\n const taskId=`DEV-${crypto.randomUUID()}`, t=now();\n await sqlite.execute({sql:`INSERT INTO dev_nca_tasks(task_id,assigned_agent,task_kind,priority,user_instruction,context_json,status,require_peer_review,created_at,updated_at) VALUES(?,?,?,?,?,?, 'QUEUED', ?,?,?)`,args:[taskId,input.agent_id,input.task_kind,Math.max(1,Math.min(100,input.priority??50)),instruction,JSON.stringify(input.context??{}),input.require_peer_review===false?0:1,t,t]});\n await audit(input.agent_id,taskId,\"TASK_ENQUEUED\",\"PASS\",{task_kind:input.task_kind,priority:input.priority??50,peer_review:input.require_peer_review!==false});\n return {task_id:taskId,status:\"QUEUED\",agent:AGENTS[input.agent_id].name,designation:\"Universal NCA\"};\n}\n\nexport async function ingestCommands(limit=4){\n await ensureSchema();\n const rows:any[]=(await sqlite.execute({sql:`SELECT * FROM dev_nca_intake WHERE status='NEW' ORDER BY priority DESC,created_at ASC LIMIT ?`,args:[Math.max(1,Math.min(20,limit))]})).rows as any[];\n const accepted=[] as any[];\n for(const row of rows){\n try{\n const agentId=String(row.agent_id) as AgentId;\n const taskKind=String(row.task_kind) as TaskKind;\n if(!AGENTS[agentId]) throw new Error(\"UNKNOWN_AGENT\");\n const queued=await enqueueTask({agent_id:agentId,task_kind:taskKind,instruction:String(row.instruction),context:JSON.parse(String(row.context_json||'{}')),priority:Number(row.priority),require_peer_review:Number(row.require_peer_review)!==0});\n await sqlite.execute({sql:`UPDATE dev_nca_intake SET status='ACCEPTED',task_id=?,accepted_at=? WHERE command_id=? AND status='NEW'`,args:[queued.task_id,now(),row.command_id]});\n accepted.push({command_id:row.command_id,task_id:queued.task_id,agent:queued.agent});\n }catch(e){\n await sqlite.execute({sql:`UPDATE dev_nca_intake SET status='REJECTED',accepted_at=? WHERE command_id=? AND status='NEW'`,args:[now(),row.command_id]});\n }\n }\n return {accepted,count:accepted.length};\n}\n\nfunction policyPrompt(agentId:AgentId,phase:string){\n const a=AGENTS[agentId];\n return `You are ${a.name}, ${a.designation}, ${a.role}, inside IMPERIAL Core.\\nSpecialty: ${a.specialty}.\\nYou operate as a Codex-style autonomous software engineering worker: analyze requirements, inspect supplied context, design minimal safe changes, produce implementation artifacts, tests, and evidence.\\nArchitecture Before Implementation. Evidence before claims. Deny by default for destructive, financial, credential, privilege-escalation, malware, evasion, or unauthorized actions. Never invent test results, repository state, deployment state, clients, payments, or evidence.\\nNo hidden chain-of-thought is requested or stored. Return concise observable engineering outputs only.\\nPhase: ${phase}.\\nReturn STRICT JSON only. No markdown fences.`;\n}\n\nconst implementationSchema=`{\n \"summary\":\"string\",\n \"requirements_understood\":[\"string\"],\n \"assumptions\":[\"string\"],\n \"plan\":[\"string\"],\n \"artifacts\":[{\"path\":\"string\",\"operation\":\"create|update|delete|none\",\"content\":\"string\"}],\n \"tests\":[{\"name\":\"string\",\"method\":\"string\",\"expected\":\"string\",\"status\":\"NOT_RUN|STATIC_PASS|BLOCKED\"}],\n \"risks\":[\"string\"],\n \"tool_requests\":[{\"tool\":\"string\",\"action\":\"string\",\"reason\":\"string\"}],\n \"completion\":\"READY_FOR_REVIEW|BLOCKED\"\n}`;\nconst reviewSchema=`{\n \"verdict\":\"PASS|CHANGES_REQUIRED|BLOCKED\",\n \"findings\":[{\"severity\":\"LOW|MEDIUM|HIGH\",\"issue\":\"string\",\"fix\":\"string\"}],\n \"test_gaps\":[\"string\"],\n \"security_notes\":[\"string\"],\n \"truth_check\":\"PASS|FAIL\",\n \"recommended_final\":\"string\"\n}`;\n\nasync function modelCall(taskId:string,agentId:AgentId,phase:string,prompt:string,maxTokens:number){\n const a=AGENTS[agentId];\n const candidates=[a.model,a.fallback].filter((v:string,i:number,x:string[])=>v&&x.indexOf(v)===i);\n let lastError=\"MODEL_UNAVAILABLE\";\n for(const model of candidates){\n const runId=crypto.randomUUID(), start=now();\n await sqlite.execute({sql:`INSERT INTO dev_nca_model_runs(run_id,task_id,agent_id,phase,model,status,requested_at) VALUES(?,?,?,?,?,'RUNNING',?)`,args:[runId,taskId,agentId,phase,model,start]});\n try{\n const openai=new ValTownOpenAI({});\n const c=await openai.chat.completions.create({model,messages:[{role:\"system\",content:policyPrompt(agentId,phase)},{role:\"user\",content:prompt.slice(0,30000)}],max_completion_tokens:maxTokens});\n const text=String(c.choices?.[0]?.message?.content??\"\").trim();\n if(!text) throw new Error(\"EMPTY_MODEL_RESPONSE\");\n const h=await sha256(text), done=now();\n await sqlite.execute({sql:`UPDATE dev_nca_model_runs SET status='PASS',response_sha256=?,completed_at=? WHERE run_id=?`,args:[h,done,runId]});\n if(model!==a.model) await audit(agentId,taskId,\"MODEL_FALLBACK\",\"PASS\",{phase,primary:a.model,fallback:model});\n return {status:\"PASS\",text,hash:h,model,run_id:runId};\n }catch(e){\n lastError=String((e as Error)?.message??e).slice(0,300); const done=now();\n await sqlite.execute({sql:`UPDATE dev_nca_model_runs SET status='FAIL',error_class=?,completed_at=? WHERE run_id=?`,args:[lastError,done,runId]});\n }\n }\n return {status:\"FAIL\",error:lastError,model:a.model,run_id:null};\n}\n\nfunction parseJson(text:string){\n const cleaned=text.replace(/^```(?:json)?\\s*/i,\"\").replace(/\\s*```$/,\"\");\n return JSON.parse(cleaned);\n}\nfunction isTransientModelError(message:string){return /(429|too many requests|rate.?limit|empty_model_response|timeout|timed out|502|503|temporar)/i.test(String(message));}\nfunction otherAgent(id:AgentId):AgentId{return id===\"IMPERIAL-ADRIAN-WALKER-NCA-001\"?\"IMPERIAL-LUCAS-BENNETT-NCA-002\":\"IMPERIAL-ADRIAN-WALKER-NCA-001\";}\n\nexport async function runAgentCycle(agentId:AgentId){\n await ensureSchema();\n const policy:any=(await sqlite.execute({sql:`SELECT * FROM dev_nca_agents WHERE agent_id=?`,args:[agentId]})).rows?.[0];\n if(!policy) return {status:\"BLOCKED\",reason:\"AGENT_NOT_REGISTERED\"};\n if(Number(policy.kill_switch)!==0 || String(policy.authority_root)!==\"ARCHITECT_ONLY\" || Number(policy.deny_by_default)!==1){\n await sqlite.execute({sql:`UPDATE dev_nca_agents SET state='HALTED_KILL_SWITCH',kill_switch=1,updated_at=? WHERE agent_id=?`,args:[now(),agentId]});\n await audit(agentId,null,\"WATCHDOG\",\"FAIL\",{reason:\"POLICY_INVARIANT_FAILED\"});\n return {status:\"KILL_SWITCH_ACTIVATED\"};\n }\n const pick=await sqlite.execute({sql:`SELECT * FROM dev_nca_tasks WHERE assigned_agent=? AND status IN ('QUEUED','RETRY') AND attempt0 THEN attempt-1 ELSE 0 END,blocker=?,updated_at=? WHERE task_id=?`,args:[`TRANSIENT_PROVIDER:${impl.error}`,now(),task.task_id]});\n await sqlite.execute({sql:`UPDATE dev_nca_agents SET state='WAITING_PROVIDER',last_heartbeat=?,updated_at=? WHERE agent_id=?`,args:[now(),now(),agentId]});\n await audit(agentId,task.task_id,\"MODEL_PROVIDER\",\"PARTIAL\",{error:impl.error,transient:true,retry_preserves_attempt_budget:true});\n return {status:\"WAITING_PROVIDER\",task_id:task.task_id,error:impl.error};\n }\n await sqlite.execute({sql:`UPDATE dev_nca_tasks SET status=CASE WHEN attempt{\n const reviewPrompt=`Review this engineering task independently.\\nORIGINAL TASK:\\n${task.user_instruction}\\n\\nIMPLEMENTATION JSON:\\n${JSON.stringify(implementation)}\\n\\nReturn exact JSON shape:\\n${reviewSchema}\\nReject unsupported claims, unsafe operations, incomplete tests, fabricated evidence, destructive changes without authorization, or obvious correctness defects.`;\n const rv=await modelCall(task.task_id,reviewer,label,reviewPrompt,900);\n if(rv.status!==\"PASS\") return {verdict:\"BLOCKED\",findings:[{severity:\"HIGH\",issue:\"PEER_REVIEW_MODEL_FAILED\",fix:\"Retry review\"}],test_gaps:[],security_notes:[],truth_check:\"FAIL\",recommended_final:\"BLOCKED\"};\n try{return parseJson(rv.text!);}catch{return {verdict:\"BLOCKED\",findings:[{severity:\"HIGH\",issue:\"PEER_REVIEW_JSON_INVALID\",fix:\"Retry review\"}],test_gaps:[],security_notes:[],truth_check:\"FAIL\",recommended_final:\"BLOCKED\"};}\n };\n review=await doReview(\"PEER_REVIEW\");\n\n }\n\n const verdict=String(review?.verdict??\"BLOCKED\");\n const truth=String(review?.truth_check??\"FAIL\");\n const currentAttempt=Number(task.attempt)+1;\n const passed=verdict===\"PASS\" && truth===\"PASS\" && String(implementation?.completion)!==\"BLOCKED\";\n const canRetry=!passed && currentAttempt = {\n \"IMPERIAL-ADRIAN-WALKER-NCA-001\": {\n name: \"Adrian Walker\",\n designation: \"Universal NCA\",\n role: \"Principal Autonomous Developer\",\n specialty: \"software architecture, implementation, debugging, refactoring, APIs, backend/frontend, automation\",\n skills: [\"requirements analysis\",\"repository comprehension\",\"software architecture\",\"TypeScript\",\"JavaScript\",\"Python\",\"SQL\",\"REST APIs\",\"JSON schemas\",\"backend engineering\",\"frontend fixes\",\"automation\",\"data processing\",\"debugging\",\"refactoring\",\"unit testing\",\"integration testing\",\"regression design\",\"Git patch planning\",\"CI/CD design\",\"performance analysis\",\"observability\",\"security-aware coding\",\"technical documentation\",\"delivery packaging\"],\n model: \"gpt-5.6-luna\",\n fallback: \"gpt-5.4-nano\",\n },\n \"IMPERIAL-LUCAS-BENNETT-NCA-002\": {\n name: \"Lucas Bennett\",\n designation: \"Universal NCA\",\n role: \"Autonomous Systems & Verification Developer\",\n specialty: \"systems engineering, testing, code review, security review, CI/CD, reliability, data and infrastructure\",\n skills: [\"requirements analysis\",\"systems architecture\",\"TypeScript\",\"JavaScript\",\"Python\",\"SQL\",\"API contracts\",\"code review\",\"static analysis\",\"unit testing\",\"integration testing\",\"end-to-end test design\",\"property testing\",\"regression analysis\",\"security review\",\"threat modeling\",\"CI/CD design\",\"release verification\",\"failure injection\",\"reliability engineering\",\"observability\",\"data validation\",\"performance testing\",\"incident analysis\",\"technical documentation\",\"evidence verification\"],\n model: \"gpt-5.6-luna\",\n fallback: \"gpt-5.4-nano\",\n },\n};\n\nconst now=()=>new Date().toISOString();\nasync function sha256(v:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(v));return [...new Uint8Array(d)].map(b=>b.toString(16).padStart(2,\"0\")).join(\"\");}\n\nexport async function ensureSchema(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_agents(\n agent_id TEXT PRIMARY KEY,\n human_name TEXT NOT NULL,\n designation TEXT NOT NULL,\n role TEXT NOT NULL,\n specialty TEXT NOT NULL,\n state TEXT NOT NULL,\n kill_switch INTEGER NOT NULL DEFAULT 0,\n deny_by_default INTEGER NOT NULL DEFAULT 1,\n authority_root TEXT NOT NULL DEFAULT 'ARCHITECT_ONLY',\n model TEXT NOT NULL,\n fallback_model TEXT NOT NULL,\n last_heartbeat TEXT,\n completed_tasks INTEGER NOT NULL DEFAULT 0,\n failed_tasks INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_tasks(\n task_id TEXT PRIMARY KEY,\n assigned_agent TEXT NOT NULL,\n task_kind TEXT NOT NULL,\n priority INTEGER NOT NULL DEFAULT 50,\n user_instruction TEXT NOT NULL,\n context_json TEXT NOT NULL DEFAULT '{}',\n status TEXT NOT NULL,\n require_peer_review INTEGER NOT NULL DEFAULT 1,\n attempt INTEGER NOT NULL DEFAULT 0,\n max_attempts INTEGER NOT NULL DEFAULT 3,\n implementation_json TEXT,\n review_json TEXT,\n final_json TEXT,\n blocker TEXT,\n created_at TEXT NOT NULL,\n started_at TEXT,\n completed_at TEXT,\n updated_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS dev_nca_tasks_pick ON dev_nca_tasks(status,priority,created_at)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_intake(\n command_id TEXT PRIMARY KEY,\n agent_id TEXT NOT NULL,\n task_kind TEXT NOT NULL,\n priority INTEGER NOT NULL DEFAULT 50,\n instruction TEXT NOT NULL,\n context_json TEXT NOT NULL DEFAULT '{}',\n require_peer_review INTEGER NOT NULL DEFAULT 1,\n status TEXT NOT NULL DEFAULT 'NEW',\n task_id TEXT,\n created_at TEXT NOT NULL,\n accepted_at TEXT\n )`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS dev_nca_intake_pick ON dev_nca_intake(status,priority,created_at)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_model_runs(\n run_id TEXT PRIMARY KEY,\n task_id TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n phase TEXT NOT NULL,\n model TEXT NOT NULL,\n status TEXT NOT NULL,\n response_sha256 TEXT,\n error_class TEXT,\n requested_at TEXT NOT NULL,\n completed_at TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dev_nca_audit(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n event_id TEXT NOT NULL UNIQUE,\n occurred_at TEXT NOT NULL,\n agent_id TEXT NOT NULL,\n task_id TEXT,\n event_type TEXT NOT NULL,\n status TEXT NOT NULL,\n evidence_json TEXT NOT NULL,\n prev_hash TEXT NOT NULL,\n event_hash TEXT NOT NULL UNIQUE\n )`);\n await sqlite.execute(`CREATE TRIGGER IF NOT EXISTS dev_nca_audit_no_update BEFORE UPDATE ON dev_nca_audit BEGIN SELECT RAISE(ABORT,'APPEND_ONLY_AUDIT'); END`);\n await sqlite.execute(`CREATE TRIGGER IF NOT EXISTS dev_nca_audit_no_delete BEFORE DELETE ON dev_nca_audit BEGIN SELECT RAISE(ABORT,'APPEND_ONLY_AUDIT'); END`);\n for(const [id,a] of Object.entries(AGENTS)){\n await sqlite.execute({sql:`INSERT INTO dev_nca_agents(agent_id,human_name,designation,role,specialty,state,kill_switch,deny_by_default,authority_root,model,fallback_model,last_heartbeat,updated_at)\n VALUES(?,?,?,?,?,'RUNNING_BOUNDED',0,1,'ARCHITECT_ONLY',?,?,?,?)\n ON CONFLICT(agent_id) DO UPDATE SET human_name=excluded.human_name,designation=excluded.designation,role=excluded.role,specialty=excluded.specialty,model=excluded.model,fallback_model=excluded.fallback_model,updated_at=excluded.updated_at`,\n args:[id,a.name,a.designation,a.role,a.specialty,a.model,a.fallback,now(),now()]});\n }\n}\n\nexport async function audit(agentId:string,taskId:string|null,type:string,status:string,evidence:any){\n const last=await sqlite.execute(`SELECT event_hash FROM dev_nca_audit ORDER BY id DESC LIMIT 1`);\n const prev=String(last.rows?.[0]?.event_hash??\"GENESIS\");\n const eventId=crypto.randomUUID(), at=now(), body=JSON.stringify(evidence??{});\n const hash=await sha256([eventId,at,agentId,taskId??\"\",type,status,body,prev].join(\"|\"));\n await sqlite.execute({sql:`INSERT INTO dev_nca_audit(event_id,occurred_at,agent_id,task_id,event_type,status,evidence_json,prev_hash,event_hash) VALUES(?,?,?,?,?,?,?,?,?)`,args:[eventId,at,agentId,taskId,type,status,body,prev,hash]});\n return {event_id:eventId,event_hash:hash};\n}\n\nexport async function enqueueTask(input:{agent_id:AgentId;task_kind:TaskKind;instruction:string;context?:any;priority?:number;require_peer_review?:boolean}){\n await ensureSchema();\n if(!AGENTS[input.agent_id]) throw new Error(\"UNKNOWN_AGENT\");\n const instruction=String(input.instruction??\"\").trim();\n if(instruction.length<5) throw new Error(\"TASK_INSTRUCTION_REQUIRED\");\n if(instruction.length>16000) throw new Error(\"TASK_TOO_LARGE\");\n const taskId=`DEV-${crypto.randomUUID()}`, t=now();\n await sqlite.execute({sql:`INSERT INTO dev_nca_tasks(task_id,assigned_agent,task_kind,priority,user_instruction,context_json,status,require_peer_review,created_at,updated_at) VALUES(?,?,?,?,?,?, 'QUEUED', ?,?,?)`,args:[taskId,input.agent_id,input.task_kind,Math.max(1,Math.min(100,input.priority??50)),instruction,JSON.stringify(input.context??{}),input.require_peer_review===false?0:1,t,t]});\n await audit(input.agent_id,taskId,\"TASK_ENQUEUED\",\"PASS\",{task_kind:input.task_kind,priority:input.priority??50,peer_review:input.require_peer_review!==false});\n return {task_id:taskId,status:\"QUEUED\",agent:AGENTS[input.agent_id].name,designation:\"Universal NCA\"};\n}\n\nexport async function ingestCommands(limit=4){\n await ensureSchema();\n const rows:any[]=(await sqlite.execute({sql:`SELECT * FROM dev_nca_intake WHERE status='NEW' ORDER BY priority DESC,created_at ASC LIMIT ?`,args:[Math.max(1,Math.min(20,limit))]})).rows as any[];\n const accepted=[] as any[];\n for(const row of rows){\n try{\n const agentId=String(row.agent_id) as AgentId;\n const taskKind=String(row.task_kind) as TaskKind;\n if(!AGENTS[agentId]) throw new Error(\"UNKNOWN_AGENT\");\n const queued=await enqueueTask({agent_id:agentId,task_kind:taskKind,instruction:String(row.instruction),context:JSON.parse(String(row.context_json||'{}')),priority:Number(row.priority),require_peer_review:Number(row.require_peer_review)!==0});\n await sqlite.execute({sql:`UPDATE dev_nca_intake SET status='ACCEPTED',task_id=?,accepted_at=? WHERE command_id=? AND status='NEW'`,args:[queued.task_id,now(),row.command_id]});\n accepted.push({command_id:row.command_id,task_id:queued.task_id,agent:queued.agent});\n }catch(e){\n await sqlite.execute({sql:`UPDATE dev_nca_intake SET status='REJECTED',accepted_at=? WHERE command_id=? AND status='NEW'`,args:[now(),row.command_id]});\n }\n }\n return {accepted,count:accepted.length};\n}\n\nfunction policyPrompt(agentId:AgentId,phase:string){\n const a=AGENTS[agentId];\n return `You are ${a.name}, ${a.designation}, ${a.role}, inside IMPERIAL Core.\\nSpecialty: ${a.specialty}.\\nYou operate as a Codex-style autonomous software engineering worker: analyze requirements, inspect supplied context, design minimal safe changes, produce implementation artifacts, tests, and evidence.\\nArchitecture Before Implementation. Evidence before claims. Deny by default for destructive, financial, credential, privilege-escalation, malware, evasion, or unauthorized actions. Never invent test results, repository state, deployment state, clients, payments, or evidence.\\nNo hidden chain-of-thought is requested or stored. Return concise observable engineering outputs only.\\nPhase: ${phase}.\\nReturn STRICT JSON only. No markdown fences.`;\n}\n\nconst implementationSchema=`{\n \"summary\":\"string\",\n \"requirements_understood\":[\"string\"],\n \"assumptions\":[\"string\"],\n \"plan\":[\"string\"],\n \"artifacts\":[{\"path\":\"string\",\"operation\":\"create|update|delete|none\",\"content\":\"string\"}],\n \"tests\":[{\"name\":\"string\",\"method\":\"string\",\"expected\":\"string\",\"status\":\"NOT_RUN|STATIC_PASS|BLOCKED\"}],\n \"risks\":[\"string\"],\n \"tool_requests\":[{\"tool\":\"string\",\"action\":\"string\",\"reason\":\"string\"}],\n \"completion\":\"READY_FOR_REVIEW|BLOCKED\"\n}`;\nconst reviewSchema=`{\n \"verdict\":\"PASS|CHANGES_REQUIRED|BLOCKED\",\n \"findings\":[{\"severity\":\"LOW|MEDIUM|HIGH\",\"issue\":\"string\",\"fix\":\"string\"}],\n \"test_gaps\":[\"string\"],\n \"security_notes\":[\"string\"],\n \"truth_check\":\"PASS|FAIL\",\n \"recommended_final\":\"string\"\n}`;\n\nasync function modelCall(taskId:string,agentId:AgentId,phase:string,prompt:string,maxTokens:number){\n const a=AGENTS[agentId];\n const candidates=[a.model,a.fallback].filter((v:string,i:number,x:string[])=>v&&x.indexOf(v)===i);\n let lastError=\"MODEL_UNAVAILABLE\";\n for(const model of candidates){\n const runId=crypto.randomUUID(), start=now();\n await sqlite.execute({sql:`INSERT INTO dev_nca_model_runs(run_id,task_id,agent_id,phase,model,status,requested_at) VALUES(?,?,?,?,?,'RUNNING',?)`,args:[runId,taskId,agentId,phase,model,start]});\n try{\n const openai=new ValTownOpenAI({});\n const c=await openai.chat.completions.create({model,messages:[{role:\"system\",content:policyPrompt(agentId,phase)},{role:\"user\",content:prompt.slice(0,30000)}],max_completion_tokens:maxTokens});\n const text=String(c.choices?.[0]?.message?.content??\"\").trim();\n if(!text) throw new Error(\"EMPTY_MODEL_RESPONSE\");\n const h=await sha256(text), done=now();\n await sqlite.execute({sql:`UPDATE dev_nca_model_runs SET status='PASS',response_sha256=?,completed_at=? WHERE run_id=?`,args:[h,done,runId]});\n if(model!==a.model) await audit(agentId,taskId,\"MODEL_FALLBACK\",\"PASS\",{phase,primary:a.model,fallback:model});\n return {status:\"PASS\",text,hash:h,model,run_id:runId};\n }catch(e){\n lastError=String((e as Error)?.message??e).slice(0,300); const done=now();\n await sqlite.execute({sql:`UPDATE dev_nca_model_runs SET status='FAIL',error_class=?,completed_at=? WHERE run_id=?`,args:[lastError,done,runId]});\n }\n }\n return {status:\"FAIL\",error:lastError,model:a.model,run_id:null};\n}\n\nfunction parseJson(text:string){\n const cleaned=text.replace(/^```(?:json)?\\s*/i,\"\").replace(/\\s*```$/,\"\");\n return JSON.parse(cleaned);\n}\nfunction isTransientModelError(message:string){return /(429|too many requests|rate.?limit|empty_model_response|timeout|timed out|502|503|temporar)/i.test(String(message));}\nfunction otherAgent(id:AgentId):AgentId{return id===\"IMPERIAL-ADRIAN-WALKER-NCA-001\"?\"IMPERIAL-LUCAS-BENNETT-NCA-002\":\"IMPERIAL-ADRIAN-WALKER-NCA-001\";}\n\nexport async function runAgentCycle(agentId:AgentId){\n await ensureSchema();\n const policy:any=(await sqlite.execute({sql:`SELECT * FROM dev_nca_agents WHERE agent_id=?`,args:[agentId]})).rows?.[0];\n if(!policy) return {status:\"BLOCKED\",reason:\"AGENT_NOT_REGISTERED\"};\n if(Number(policy.kill_switch)!==0 || String(policy.authority_root)!==\"ARCHITECT_ONLY\" || Number(policy.deny_by_default)!==1){\n await sqlite.execute({sql:`UPDATE dev_nca_agents SET state='HALTED_KILL_SWITCH',kill_switch=1,updated_at=? WHERE agent_id=?`,args:[now(),agentId]});\n await audit(agentId,null,\"WATCHDOG\",\"FAIL\",{reason:\"POLICY_INVARIANT_FAILED\"});\n return {status:\"KILL_SWITCH_ACTIVATED\"};\n }\n const pick=await sqlite.execute({sql:`SELECT * FROM dev_nca_tasks WHERE assigned_agent=? AND status IN ('QUEUED','RETRY') AND attempt0 THEN attempt-1 ELSE 0 END,blocker=?,updated_at=? WHERE task_id=?`,args:[`TRANSIENT_PROVIDER:${impl.error}`,now(),task.task_id]});\n await sqlite.execute({sql:`UPDATE dev_nca_agents SET state='WAITING_PROVIDER',last_heartbeat=?,updated_at=? WHERE agent_id=?`,args:[now(),now(),agentId]});\n await audit(agentId,task.task_id,\"MODEL_PROVIDER\",\"PARTIAL\",{error:impl.error,transient:true,retry_preserves_attempt_budget:true});\n return {status:\"WAITING_PROVIDER\",task_id:task.task_id,error:impl.error};\n }\n await sqlite.execute({sql:`UPDATE dev_nca_tasks SET status=CASE WHEN attempt{\n const reviewPrompt=`Review this engineering task independently.\\nORIGINAL TASK:\\n${task.user_instruction}\\n\\nIMPLEMENTATION JSON:\\n${JSON.stringify(implementation)}\\n\\nReturn exact JSON shape:\\n${reviewSchema}\\nReject unsupported claims, unsafe operations, incomplete tests, fabricated evidence, destructive changes without authorization, or obvious correctness defects.`;\n const rv=await modelCall(task.task_id,reviewer,label,reviewPrompt,900);\n if(rv.status!==\"PASS\") return {verdict:\"BLOCKED\",findings:[{severity:\"HIGH\",issue:\"PEER_REVIEW_MODEL_FAILED\",fix:\"Retry review\"}],test_gaps:[],security_notes:[],truth_check:\"FAIL\",recommended_final:\"BLOCKED\"};\n try{return parseJson(rv.text!);}catch{return {verdict:\"BLOCKED\",findings:[{severity:\"HIGH\",issue:\"PEER_REVIEW_JSON_INVALID\",fix:\"Retry review\"}],test_gaps:[],security_notes:[],truth_check:\"FAIL\",recommended_final:\"BLOCKED\"};}\n };\n review=await doReview(\"PEER_REVIEW\");\n\n }\n\n const verdict=String(review?.verdict??\"BLOCKED\");\n const truth=String(review?.truth_check??\"FAIL\");\n const currentAttempt=Number(task.attempt)+1;\n const passed=verdict===\"PASS\" && truth===\"PASS\" && String(implementation?.completion)!==\"BLOCKED\";\n const canRetry=!passed && currentAttemptb.toString(16).padStart(2,\"0\")).join(\"\");}\nawait ensureSchema();\nconst agents:any[]=(await sqlite.execute(`SELECT agent_id,human_name,designation,state,kill_switch,deny_by_default,authority_root,model,fallback_model FROM dev_nca_agents ORDER BY agent_id`)).rows as any[];\nconst modelRuns:any[]=(await sqlite.execute(`SELECT agent_id,status,COUNT(*) n FROM dev_nca_model_runs GROUP BY agent_id,status ORDER BY agent_id,status`)).rows as any[];\nconst auditRows:any[]=(await sqlite.execute(`SELECT event_id,occurred_at,agent_id,task_id,event_type,status,evidence_json,prev_hash,event_hash FROM dev_nca_audit ORDER BY id`)).rows as any[];\nlet prev=\"GENESIS\", auditChain=true;\nfor(const r of auditRows){const expected=await sha256([r.event_id,r.occurred_at,r.agent_id,r.task_id??\"\",r.event_type,r.status,r.evidence_json,r.prev_hash].join(\"|\"));if(r.prev_hash!==prev||r.event_hash!==expected){auditChain=false;break;}prev=r.event_hash;}\nconst successfulByAgent=Object.fromEntries(Object.keys(AGENTS).map(id=>[id,Number(modelRuns.find(r=>r.agent_id===id&&r.status===\"PASS\")?.n??0)]));\nconst policyPass=agents.length===2 && agents.every(a=>a.human_name&&a.designation===\"Universal NCA\"&&Number(a.kill_switch)===0&&Number(a.deny_by_default)===1&&a.authority_root===\"ARCHITECT_ONLY\");\nconst inferencePass=Object.values(successfulByAgent).every((n:any)=>Number(n)>=1);\nconst result={status:policyPass&&inferencePass&&auditChain?\"PASS\":\"PARTIAL\",agent_count:agents.length,human_names:agents.map(a=>a.human_name),designation_check:agents.every(a=>a.designation===\"Universal NCA\"),policy_invariants:policyPass,model_inference_observed_for_both:inferencePass,successful_model_runs:successfulByAgent,audit_chain_valid:auditChain,financial_authority:false,external_execution_authority:false,truth_boundary:\"Model inference and server runtime verified; external repo/shell/deployment execution remains connector/tool-gated.\"};\nconsole.log(JSON.stringify(result));\nexport default result;\n",[149],"d38f165a-9e98-422d-917b-42dcd749fe97","main.ts",4,["D",1789057560500],"http","import { getStatus } from \"./core.ts\";\n\nexport default async function(req: Request) {\n if (req.method !== \"GET\") {\n return new Response(JSON.stringify({error:\"METHOD_NOT_ALLOWED\"}), {status:405, headers:{\"content-type\":\"application/json\",\"cache-control\":\"no-store\"}});\n }\n const url = new URL(req.url);\n if (url.pathname !== \"/\" && url.pathname !== \"/health\" && url.pathname !== \"/status\") {\n return new Response(JSON.stringify({error:\"NOT_FOUND\"}), {status:404, headers:{\"content-type\":\"application/json\",\"cache-control\":\"no-store\"}});\n }\n const status = await getStatus();\n return new Response(JSON.stringify({...status, endpoint:\"STATUS_ONLY\", command_submission:\"CHATGPT/VAL_TOWN_TOOL_GATED\"}), {status:200, headers:{\"content-type\":\"application/json; charset=utf-8\",\"cache-control\":\"no-store\",\"x-content-type-options\":\"nosniff\"}});\n}\n","imperial-dev-nca",[156],"cba4b134-a0eb-418a-8d0e-371c2caeaf06",["D",1789058528745],13,[28],"709e4e25-16b9-49a7-8622-455ea777b061","AGENTS.md","547f6f86-ad36-11f1-9f5f-1607ee4eb77e",29,["D",1789058428255],"# IMPERIAL Core — Universal Developer NCA Pair\n\n## Adrian Walker — Universal NCA\n**Role:** Principal Autonomous Developer\n\nPrimary strengths: software architecture, implementation, debugging, refactoring, APIs, backend/frontend engineering, automation, data workflows, code generation, patch design, test design, technical documentation and delivery packaging.\n\n## Lucas Bennett — Universal NCA\n**Role:** Autonomous Systems & Verification Developer\n\nPrimary strengths: systems engineering, code review, testing, security review, CI/CD, reliability, infrastructure, data validation, failure analysis, regression design and independent verification.\n\n## Engineering Model\nThe pair uses a Codex-style workflow rather than claiming to be the Codex product/runtime:\n\n1. Architect command enters a private server-side intake queue.\n2. The assigned Universal NCA produces an implementation-grade structured result.\n3. The other Universal NCA acts as independent peer reviewer by default.\n4. Review findings cause a bounded retry/revision cycle.\n5. Evidence is recorded in an append-only hash-chained audit log.\n6. Transient model/provider failures (including rate limits) preserve task retry budget.\n7. The worker runs automatically every 15 minutes on the free Val Town tier and can also be triggered manually.\n\n## Server Topology\n- **Val Town:** live execution runtime, queue, SQLite state, LLM calls, worker, audit chain.\n- **Supabase:** IMPERIAL federation registry entries for Adrian Walker and Lucas Bennett.\n- **Netlify:** IMPERIAL Core runtime discovery/configuration pointers for the pair.\n\n## Security & Authority\n- Authority root: `ARCHITECT_ONLY`\n- Deny by default: enabled\n- Kill switch: enabled\n- Peer review: enabled by default\n- Financial authority: none\n- External execution authority: none by default\n- No private-key, wallet, payment or credential authority\n- External repository writes, shell execution and deployments require an actually connected execution tool and evidence.\n\n## Truth Boundary\nModel-backed engineering work is verified on the server runtime. Do not claim external repository modification, shell execution, CI execution, deployment, or production success unless the corresponding connected tool actually performed the action and evidence was retained.\n",[168],"pulls","branches","forks","envVars",{"_181":63,"_183":63},"connections",{"_181":63,"_182":63},"count","unfilledCount","emptyCount",{"_43":167,"_32":168,"_30":169,"_139":-5,"_41":42,"_40":170,"_141":59,"_38":202,"_13":63,"_33":20,"_35":172,"_24":25,"_146":-5,"_190":203,"_27":204},{"_43":163,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":25,"_38":199,"_13":165,"_33":34,"_35":37,"_24":25,"_146":-5,"_190":200,"_27":201},{"_43":155,"_32":156,"_30":57,"_139":-5,"_41":42,"_40":157,"_141":25,"_38":196,"_13":143,"_33":159,"_35":160,"_24":25,"_146":161,"_190":197,"_27":198},{"_43":148,"_32":149,"_30":150,"_139":-5,"_41":42,"_40":151,"_141":59,"_38":193,"_13":63,"_33":34,"_35":153,"_24":25,"_146":-5,"_190":194,"_27":195},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":25,"_38":189,"_13":143,"_33":144,"_35":145,"_24":25,"_146":-5,"_190":191,"_27":192},["D",1789058312875],"children",[],[137],["D",1789058158778],[],[149],["D",1789057560500],[],[156],["D",1789058528745],[],[28],["D",1789058428255],[],[168],["D",1789057363602],["D",1789492268774],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":243,"_244":245,"_246":247,"_248":25,"_249":25,"_250":25,"_251":59,"_252":-5,"_253":-7,"_254":-7,"_255":63,"_256":25,"_257":25,"_258":-5,"_259":25,"_260":25,"_261":25,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":90,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"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 · v31