[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_289":290,"_291":292},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"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",23,"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","atomic_v3_a71_boundary_fixture.ts","latestPath","fileId","4d572c72-abbe-11f1-829e-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst past=new Date(Date.now()-1000).toISOString();\nconst exp=\"6d4e6034f2afa4827f8808feb3175b9650f497bebab8e96fe9b09fc08335a008\";\nconst unk=\"d2c1cb4021de683393d47a4fda80af31d023080219cf7d3e4bd5c4d9faefe6ac\";\nconst a=await sqlite.execute({sql:\"UPDATE atomic_precommits_v3_a71 SET expires_at=? WHERE challenge=? AND state='ISSUED'\",args:[past,exp]});\nconst b=await sqlite.execute({sql:\"UPDATE atomic_precommits_v3_a71 SET state='RESERVED',reserved_at=?,reservation_expires_at=? WHERE challenge=? AND state='ISSUED'\",args:[past,past,unk]});\nconsole.log(JSON.stringify({schema:\"ATOMIC_V3_A71_BOUNDARY_FIXTURE_V1\",past,expired_rows:a.rowsAffected,reserved_rows:b.rowsAffected,canonical_brain_mutation:false,human_authority_approval:false,direct_sprites_calls:0},null,2));\n","createdAt",["D",1788896925477],"branchVersion","branchId","bf3f4bf9-6775-417b-8b3b-0fbc443488fb","id","b4d20ed1-eb6f-490c-90dd-6aff6508c246","project-brain-exec-issuer-v1",["D",1788893645758],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Isolated execution-incarnation issuer canary","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","aa7fce52-abb6-11f1-b143-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","b4d20ed1eb6f490c90dd6aff6508c246","tursoHostname","b4d20ed1eb6f490c90dd6aff6508c246-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789502486629],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",96,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":284,"_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":285,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":286,"_82":287,"_84":288,"_86":24},"tree",[235,236,237,238,239,240,241,242,243,244,245,246],"files",[235,236,237,238,239,240,241,242,243,244,245,246],"counts",{"_224":61,"_225":226,"_227":61,"_228":229,"_230":231},"contents",[129,130,131,132,133,134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":217,"_31":218,"_29":219,"_144":-5,"_39":40,"_38":220,"_146":57,"_36":221,"_13":61,"_32":33,"_34":222,"_23":24,"_150":-5,"_26":223},{"_41":214,"_31":27,"_29":30,"_144":-5,"_39":40,"_38":14,"_146":57,"_36":215,"_13":61,"_32":33,"_34":35,"_23":24,"_150":-5,"_26":216},{"_41":207,"_31":208,"_29":209,"_144":-5,"_39":40,"_38":210,"_146":57,"_36":211,"_13":61,"_32":148,"_34":212,"_23":24,"_150":-5,"_26":213},{"_41":200,"_31":201,"_29":202,"_144":-5,"_39":40,"_38":203,"_146":57,"_36":204,"_13":61,"_32":148,"_34":205,"_23":24,"_150":-5,"_26":206},{"_41":193,"_31":194,"_29":195,"_144":-5,"_39":40,"_38":196,"_146":24,"_36":197,"_13":61,"_32":148,"_34":198,"_23":24,"_150":-5,"_26":199},{"_41":186,"_31":187,"_29":188,"_144":-5,"_39":40,"_38":189,"_146":57,"_36":190,"_13":61,"_32":148,"_34":191,"_23":24,"_150":-5,"_26":192},{"_41":180,"_31":181,"_29":182,"_144":-5,"_39":40,"_38":156,"_146":57,"_36":183,"_13":61,"_32":33,"_34":184,"_23":24,"_150":-5,"_26":185},{"_41":173,"_31":174,"_29":175,"_144":-5,"_39":40,"_38":176,"_146":57,"_36":177,"_13":61,"_32":148,"_34":178,"_23":24,"_150":-5,"_26":179},{"_41":166,"_31":167,"_29":168,"_144":-5,"_39":40,"_38":169,"_146":57,"_36":170,"_13":61,"_32":148,"_34":171,"_23":24,"_150":-5,"_26":172},{"_41":159,"_31":160,"_29":161,"_144":-5,"_39":40,"_38":162,"_146":57,"_36":163,"_13":61,"_32":33,"_34":164,"_23":24,"_150":-5,"_26":165},{"_41":152,"_31":153,"_29":55,"_144":-5,"_39":40,"_38":154,"_146":57,"_36":155,"_13":156,"_32":148,"_34":157,"_23":24,"_150":-5,"_26":158},{"_41":141,"_31":142,"_29":143,"_144":-5,"_39":40,"_38":145,"_146":57,"_36":147,"_13":61,"_32":148,"_34":149,"_23":24,"_150":-5,"_26":151},"d0e27730-f730-44a8-bc7d-a206fc4051b0","precommit_v3_candidate.ts","0d6c386e-abbe-11f1-9945-1607ee4eb77e","parentId",16,"latest",["D",1788896818243],"http","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SCHEMA=\"PROJECT_BRAIN_EXECUTION_PRECOMMIT_V3_CANDIDATE\";\nconst ISSUER=\"mosadek/project-brain-exec-issuer-v1/precommit_v3_candidate.ts\";\nconst PURPOSE=\"FIRST_REAL_SUPERHERO_EXECUTION_INCARCATION_CANARY_V3\";\nconst WORKSTREAM=\"global\";\nconst AUTHORITY_EPOCH=2;\nconst CREDENTIAL_GENERATION=1;\nconst ATTEMPT_GENERATION=1;\nconst TTL_MS=90_000;\nconst FIXED_CAPABILITIES=[\"deterministic_execution\",\"sha256\"] as const;\nconst FIXED_TASK={op:\"sha256_utf8\",input:\"FIRST_REAL_SUPERHERO_EXECUTION_INCARCATION_CANARY_V3\"};\n\nfunction hex(b:ArrayBuffer|Uint8Array){const a=b instanceof Uint8Array?b:new Uint8Array(b);return [...a].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function sha256Utf8(s:string){return hex(await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s)))}\nfunction randomHex(n=32){const b=new Uint8Array(n);crypto.getRandomValues(b);return hex(b)}\nfunction json(x:unknown,status=200){return new Response(JSON.stringify(x),{status,headers:{\"content-type\":\"application/json; charset=utf-8\",\"cache-control\":\"no-store\"}})}\nasync function init(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS execution_precommits_v3(\n incarnation_id TEXT PRIMARY KEY,\n bearer_digest TEXT NOT NULL UNIQUE,\n challenge TEXT NOT NULL UNIQUE,\n logical_agent_id TEXT NOT NULL UNIQUE,\n workstream TEXT NOT NULL,\n capabilities_json TEXT NOT NULL,\n task_json TEXT NOT NULL,\n task_sha256 TEXT NOT NULL,\n authority_epoch INTEGER NOT NULL,\n credential_generation INTEGER NOT NULL,\n attempt_generation INTEGER NOT NULL,\n state TEXT NOT NULL,\n issued_at_ms INTEGER NOT NULL,\n expires_at_ms INTEGER NOT NULL,\n reserved_at_ms INTEGER,\n completed_at_ms INTEGER,\n execution_id TEXT,\n result_json TEXT,\n receipt_json TEXT\n )`);\n}\nexport default async function(req:Request){\n await init();\n const u=new URL(req.url);\n if(req.method===\"GET\"&&u.pathname===\"/health\")return json({schema:SCHEMA,issuer:ISSUER,state:\"CANDIDATE_NONAUTHORITY\",production_admission_eligible:false});\n if(req.method===\"GET\"&&u.pathname===\"/precommit\"){\n const id=u.searchParams.get(\"incarnation_id\")||\"\";\n const q=await sqlite.execute({sql:`SELECT incarnation_id,challenge,logical_agent_id,workstream,capabilities_json,task_sha256,authority_epoch,credential_generation,attempt_generation,state,issued_at_ms,expires_at_ms,reserved_at_ms,completed_at_ms,execution_id,result_json,receipt_json FROM execution_precommits_v3 WHERE incarnation_id=?`,args:[id]});\n if(!q.rows.length)return json({error:\"NOT_FOUND\"},404);\n const r:any=q.rows[0];\n return json({...r,capabilities:JSON.parse(String(r.capabilities_json)),result:r.result_json?JSON.parse(String(r.result_json)):null,receipt:r.receipt_json?JSON.parse(String(r.receipt_json)):null,capabilities_json:undefined,result_json:undefined,receipt_json:undefined});\n }\n if(req.method===\"POST\"&&u.pathname===\"/reconcile\"){\n let body:any;try{body=await req.json()}catch{return json({error:\"INVALID_JSON\"},400)}\n if(!body||Object.keys(body).length!==1||typeof body.incarnation_id!==\"string\")return json({error:\"BODY_INVALID\"},400);\n const now=Date.now();\n await sqlite.execute({sql:`UPDATE execution_precommits_v3 SET state='EXPIRED_UNCONSUMED' WHERE incarnation_id=? AND state='ISSUED' AND expires_at_ms<=?`,args:[body.incarnation_id,now]});\n await sqlite.execute({sql:`UPDATE execution_precommits_v3 SET state='UNKNOWN_OUTCOME' WHERE incarnation_id=? AND state='RESERVED' AND expires_at_ms<=?`,args:[body.incarnation_id,now]});\n const q=await sqlite.execute({sql:\"SELECT state FROM execution_precommits_v3 WHERE incarnation_id=?\",args:[body.incarnation_id]});\n if(!q.rows.length)return json({error:\"NOT_FOUND\"},404);\n return json({incarnation_id:body.incarnation_id,state:String((q.rows[0] as any).state),replay_allowed:false});\n }\n if(req.method!==\"POST\"||u.pathname!==\"/issue\")return json({error:\"NOT_FOUND\"},404);\n let body:any;try{body=await req.json()}catch{return json({error:\"INVALID_JSON\"},400)}\n if(!body||typeof body!==\"object\"||Array.isArray(body)||JSON.stringify(Object.keys(body).sort())!==JSON.stringify([\"purpose\"]))return json({error:\"BODY_KEYS_INVALID\"},400);\n if(body.purpose!==PURPOSE)return json({error:\"PURPOSE_INVALID\"},400);\n const now=Date.now();\n const incarnationId=crypto.randomUUID();\n const logicalAgentId=\"extchat-\"+crypto.randomUUID();\n const challenge=randomHex(32);\n const bearer=randomHex(32);\n const bearerDigest=await sha256Utf8(\"PB_EXECUTION_BEARER_V3\\0\"+bearer);\n const taskJson=JSON.stringify(FIXED_TASK);\n const taskSha256=await sha256Utf8(taskJson);\n const expiresAt=now+TTL_MS;\n await sqlite.execute({sql:`INSERT INTO execution_precommits_v3(incarnation_id,bearer_digest,challenge,logical_agent_id,workstream,capabilities_json,task_json,task_sha256,authority_epoch,credential_generation,attempt_generation,state,issued_at_ms,expires_at_ms)\n VALUES(?,?,?,?,?,?,?,?,?,?,?,'ISSUED',?,?)`,args:[incarnationId,bearerDigest,challenge,logicalAgentId,WORKSTREAM,JSON.stringify(FIXED_CAPABILITIES),taskJson,taskSha256,AUTHORITY_EPOCH,CREDENTIAL_GENERATION,ATTEMPT_GENERATION,now,expiresAt]});\n return json({schema:SCHEMA,classification:\"CANDIDATE_NONAUTHORITY_ONE_TIME_EXECUTION_PRECOMMIT\",issuer:ISSUER,purpose:PURPOSE,incarnation_id:incarnationId,logical_agent_id:logicalAgentId,workstream:WORKSTREAM,capabilities:[...FIXED_CAPABILITIES],challenge,task_sha256:taskSha256,authority_epoch:AUTHORITY_EPOCH,credential_generation:CREDENTIAL_GENERATION,attempt_generation:ATTEMPT_GENERATION,issued_at_ms:now,expires_at_ms:expiresAt,bearer,raw_bearer_storage:\"RETURNED_ONCE_NOT_PERSISTED_BY_ISSUER\",production_admission_eligible:false,human_authority_approval:false,additional_out_of_pocket_spend_usd:0},201);\n}","label",[142],"da1f72d8-7c1b-4f0d-a554-0c9409750d7d","main.ts",4,["D",1788893872452],2,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst ISSUER = \"mosadek/project-brain-exec-issuer-v1\";\nconst SCHEMA = \"PROJECT_BRAIN_EXTERNAL_EXECUTION_RECEIPT_CANARY_V1\";\n\nfunction hex(b: Uint8Array) {\n return [...b].map(x => x.toString(16).padStart(2, \"0\")).join(\"\");\n}\nfunction randomHex(n = 32) {\n const b = new Uint8Array(n);\n crypto.getRandomValues(b);\n return hex(b);\n}\nfunction json(body: unknown, status = 200) {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"content-type\": \"application/json; charset=utf-8\", \"cache-control\": \"no-store\" },\n });\n}\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS execution_receipts(\n execution_id TEXT PRIMARY KEY,\n challenge TEXT NOT NULL,\n logical_agent_id TEXT NOT NULL,\n workstream TEXT NOT NULL,\n capabilities_json TEXT NOT NULL,\n runtime_nonce TEXT NOT NULL,\n issued_at TEXT NOT NULL,\n expires_at TEXT NOT NULL,\n receipt_json TEXT NOT NULL\n )`);\n}\nfunction validate(x: any) {\n if (!x || typeof x !== \"object\" || Array.isArray(x)) return \"BODY_NOT_OBJECT\";\n const keys = Object.keys(x).sort();\n const allowed = [\"capabilities\",\"challenge\",\"logical_agent_id\",\"ttl_seconds\",\"workstream\"].sort();\n if (JSON.stringify(keys) !== JSON.stringify(allowed)) return \"BODY_KEYS_INVALID\";\n if (typeof x.challenge !== \"string\" || !/^[0-9a-f]{64}$/.test(x.challenge)) return \"CHALLENGE_INVALID\";\n if (typeof x.logical_agent_id !== \"string\" || x.logical_agent_id.length < 3 || x.logical_agent_id.length > 128) return \"AGENT_ID_INVALID\";\n if (typeof x.workstream !== \"string\" || x.workstream.length < 1 || x.workstream.length > 96) return \"WORKSTREAM_INVALID\";\n if (!Array.isArray(x.capabilities) || x.capabilities.length > 64 || !x.capabilities.every((v: unknown) => typeof v === \"string\" && v.length >= 1 && v.length <= 96)) return \"CAPABILITIES_INVALID\";\n if (!Number.isInteger(x.ttl_seconds) || x.ttl_seconds < 30 || x.ttl_seconds > 300) return \"TTL_INVALID\";\n return null;\n}\n\nexport default async function(req: Request) {\n await init();\n const url = new URL(req.url);\n if (req.method === \"GET\" && url.pathname === \"/health\") {\n return json({ schema: SCHEMA, issuer: ISSUER, state: \"CANARY_NONAUTHORITY\", now: new Date().toISOString() });\n }\n if (req.method === \"GET\" && url.pathname === \"/receipt\") {\n const id = url.searchParams.get(\"id\") || \"\";\n const r = await sqlite.execute({ sql: \"SELECT receipt_json FROM execution_receipts WHERE execution_id=?\", args: [id] });\n if (!r.rows.length) return json({ error: \"NOT_FOUND\" }, 404);\n return json(JSON.parse(String((r.rows[0] as any).receipt_json)));\n }\n if (req.method !== \"POST\" || url.pathname !== \"/issue\") return json({ error: \"NOT_FOUND\" }, 404);\n\n let body: any;\n try { body = await req.json(); } catch { return json({ error: \"INVALID_JSON\" }, 400); }\n const err = validate(body);\n if (err) return json({ error: err }, 400);\n\n const issued = new Date();\n const expires = new Date(issued.getTime() + body.ttl_seconds * 1000);\n const receipt = {\n schema: SCHEMA,\n classification: \"CANDIDATE_NONAUTHORITY_EXECUTION_RECEIPT\",\n issuer: ISSUER,\n execution_id: crypto.randomUUID(),\n challenge: body.challenge,\n logical_agent_id: body.logical_agent_id,\n workstream: body.workstream,\n capabilities: [...new Set(body.capabilities)].sort(),\n runtime_nonce: randomHex(32),\n issued_at: issued.toISOString(),\n observed_at: issued.toISOString(),\n replay_valid_until: expires.toISOString(),\n execution_observation: \"HTTP_HANDLER_EXECUTED\",\n human_authority_approval: false,\n additional_out_of_pocket_spend_usd: 0\n };\n await sqlite.execute({\n sql: `INSERT INTO execution_receipts(execution_id,challenge,logical_agent_id,workstream,capabilities_json,runtime_nonce,issued_at,expires_at,receipt_json)\n VALUES(?,?,?,?,?,?,?,?,?)`,\n args: [receipt.execution_id, receipt.challenge, receipt.logical_agent_id, receipt.workstream, JSON.stringify(receipt.capabilities), receipt.runtime_nonce, receipt.issued_at, receipt.replay_valid_until, JSON.stringify(receipt)]\n });\n return json(receipt, 201);\n}",[153],"12028c77-c565-4180-bca6-1d9fb43b200d","incarnation_issuer_v3_candidate_test.ts","3d9ec92a-abbe-11f1-bfb4-1607ee4eb77e",22,["D",1788896899103],"import handler from \"./incarnation_issuer_v3_candidate.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ntype T = {name:string, pass:boolean, detail?:unknown};\nconst tests:T[]=[];\nfunction ok(name:string, pass:boolean, detail?:unknown){tests.push({name,pass,detail});}\nasync function call(path:string, method=\"GET\", body?:unknown){\n const req=new Request(\"https://candidate.test\"+path,{\n method,\n headers: body===undefined?undefined:{\"content-type\":\"application/json\"},\n body: body===undefined?undefined:JSON.stringify(body)\n });\n const res=await handler(req);\n let json:any=null; try{json=await res.json();}catch{}\n return {status:res.status,json};\n}\nconst slot=\"chatgpt_val_town_connector_v1\";\n\nconst h=await call(\"/health\");\nok(\"health candidate-only\",h.status===200&&h.json.production_admission_eligible===false&&h.json.raw_bearer_persisted===false,h);\n\nconst spoof=await call(\"/issue\",\"POST\",{slot_class:slot,logical_agent_id:\"evil\"});\nok(\"caller cannot choose identity/workstream/caps/task\",spoof.status===400&&spoof.json.error===\"SLOT_REQUEST_INVALID\",spoof);\n\nconst issued=await call(\"/issue\",\"POST\",{slot_class:slot});\nconst i=issued.json;\nok(\"issue returns project-fixed tuple and one-time bearer\",\n issued.status===201&&i.state===\"BOOTING\"&&/^[0-9a-f]{64}$/.test(i.bearer)&&\n i.workstream===\"global\"&&i.authority_epoch===2&&i.attempt_generation===1&&\n i.production_admission_eligible===false&&i.human_authority_approval===false&&\n !i.capabilities.includes(\"human_authority_approval\"),issued);\n\nconst pub0=await call(\"/receipt?id=\"+encodeURIComponent(i.incarnation_id));\nok(\"public state never exposes bearer or digest\",\n pub0.status===200&&pub0.json.bearer_present===false&&pub0.json.bearer_digest_exposed===false&&\n pub0.json.receipt===null,pub0);\n\nconst wrong=\"00\".repeat(32);\nconst bad=await call(\"/activate\",\"POST\",{incarnation_id:i.incarnation_id,bearer:wrong});\nok(\"wrong bearer fails closed\",bad.status===403&&bad.json.error===\"BEARER_MISMATCH\",bad);\n\nconst pub1=await call(\"/receipt?id=\"+encodeURIComponent(i.incarnation_id));\nok(\"wrong bearer leaves incarnation ISSUED\",pub1.status===200&&pub1.json.state===\"ISSUED\",pub1);\n\nconst [a1,a2]=await Promise.all([\n call(\"/activate\",\"POST\",{incarnation_id:i.incarnation_id,bearer:i.bearer}),\n call(\"/activate\",\"POST\",{incarnation_id:i.incarnation_id,bearer:i.bearer})\n]);\nconst transitions=[a1.json?.activation_transition,a2.json?.activation_transition].sort();\nok(\"concurrent same-bearer activation is one state transition plus idempotent readback\",\n a1.status===200&&a2.status===200&&\n transitions.includes(\"ISSUED_TO_ACTIVE\")&&transitions.includes(\"IDEMPOTENT_ACTIVE_READBACK\"),{a1,a2});\nok(\"activation receipt stays candidate-only and does not fake physical distinctness\",\n a1.json.production_admission_eligible===false&&a1.json.physical_chat_session_distinctness_proven===false&&\n a1.json.independent_review_eligible===false&&a1.json.p_real_delta===0,a1);\n\nconst pub2=await call(\"/receipt?id=\"+encodeURIComponent(i.incarnation_id));\nok(\"public readback is ACTIVE but not a bearer-possession proof\",\n pub2.status===200&&pub2.json.state===\"ACTIVE\"&&pub2.json.bearer_present===false&&\n pub2.json.production_admission_eligible===false,pub2);\n\nconst issued2=await call(\"/issue\",\"POST\",{slot_class:slot});\nconst j=issued2.json;\nawait sqlite.execute({sql:\"UPDATE execution_incarnations_v3_candidate SET expires_at='2000-01-01T00:00:00.000Z' WHERE incarnation_id=?\",args:[j.incarnation_id]});\nconst expired=await call(\"/activate\",\"POST\",{incarnation_id:j.incarnation_id,bearer:j.bearer});\nok(\"expired bearer cannot activate\",expired.status===410&&expired.json.error===\"INCARNATION_EXPIRED\",expired);\nconst pub3=await call(\"/receipt?id=\"+encodeURIComponent(j.incarnation_id));\nok(\"expired unactivated state terminalized\",pub3.status===200&&pub3.json.state===\"EXPIRED_UNACTIVATED\",pub3);\n\nconst issued3=await call(\"/issue\",\"POST\",{slot_class:slot});\nok(\"issuer creates distinct project-generated identities/challenges\",\n issued3.status===201&&issued3.json.incarnation_id!==i.incarnation_id&&\n issued3.json.logical_agent_id!==i.logical_agent_id&&issued3.json.challenge!==i.challenge,{first:i,second:issued3.json});\n\nconst failed=tests.filter(t=>!t.pass);\nconsole.log(JSON.stringify({\n schema:\"PROJECT_BRAIN_EXECUTION_INCARCINATION_ISSUER_V3_CANDIDATE_TEST_REPORT\",\n classification:\"CANDIDATE_NONAUTHORITY_SELF_TEST\",\n tests_total:tests.length,\n tests_passed:tests.length-failed.length,\n pass:failed.length===0,\n tests,\n known_unresolved:[\n \"No project/product primitive proves one physical ChatGPT execution can receive at most one incarnation.\",\n \"A connected caller with issuer access can mint multiple logical incarnations; therefore physical-session duplicate ambiguity remains.\",\n \"The raw bearer is returned only in the issue response and not persisted in project SQL, but provider/tool telemetry confidentiality is not independently attested.\",\n \"Authority epoch is pinned to candidate constant 2 rather than atomically read from canonical control-plane authority.\",\n \"This candidate does not establish production admission, independent-review eligibility, or P_real.\"\n ],\n human_authority_approval:false,\n p_real_delta:0\n},null,2));\nif(failed.length) throw new Error(\"TEST_FAILURE\");\n",[160],"ddd7fb1a-1237-435a-a94f-a6d16bf9c233","incarnation_issuer_v3_candidate.ts","24da0e9a-abbe-11f1-9eb2-1607ee4eb77e",20,["D",1788896857531],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SCHEMA = \"PROJECT_BRAIN_EXECUTION_INCARCINATION_ISSUER_V3_CANDIDATE\";\nconst ISSUER = \"mosadek/project-brain-exec-issuer-v1/incarnation_issuer_v3_candidate.ts\";\nconst AUTHORITY_EPOCH = 2;\nconst TTL_MS = 120_000;\nconst FIXED_SLOT = {\n slot_class: \"chatgpt_val_town_connector_v1\",\n workstream: \"global\",\n capabilities: [\n \"code_execution\",\n \"reasoning\",\n \"val_town_blob\",\n \"val_town_read\",\n \"val_town_sql\",\n \"val_town_write\",\n ],\n task_descriptor: \"PROJECT_BRAIN_CHATGPT_VAL_TOWN_BOOT_CANARY_V1\",\n} as const;\n\nfunction hex(b: ArrayBuffer | Uint8Array) {\n const a = b instanceof Uint8Array ? b : new Uint8Array(b);\n return [...a].map(x => x.toString(16).padStart(2, \"0\")).join(\"\");\n}\nfunction randomHex(n = 32) {\n const b = new Uint8Array(n);\n crypto.getRandomValues(b);\n return hex(b);\n}\nasync function sha256Utf8(s: string) {\n return hex(await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(s)));\n}\nasync function bearerDigest(bearer: string) {\n return sha256Utf8(\"PROJECT_BRAIN_EXECUTION_BEARER_V1\\0\" + bearer);\n}\nfunction json(body: unknown, status = 200) {\n return new Response(JSON.stringify(body), {\n status,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store, private\",\n \"pragma\": \"no-cache\",\n },\n });\n}\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS execution_incarnations_v3_candidate(\n incarnation_id TEXT PRIMARY KEY,\n challenge TEXT NOT NULL UNIQUE,\n bearer_digest TEXT NOT NULL UNIQUE,\n logical_agent_id TEXT NOT NULL UNIQUE,\n slot_class TEXT NOT NULL,\n workstream TEXT NOT NULL,\n capabilities_json TEXT NOT NULL,\n task_sha256 TEXT NOT NULL,\n authority_epoch INTEGER NOT NULL,\n attempt_generation INTEGER NOT NULL,\n state TEXT NOT NULL,\n issued_at TEXT NOT NULL,\n expires_at TEXT NOT NULL,\n activated_at TEXT,\n receipt_json TEXT\n )`);\n}\nfunction makeAgentId(now: Date) {\n const compact = now.toISOString().replace(/[-:.TZ]/g, \"\").slice(0, 14);\n return `chat-exec-${compact}-${randomHex(6)}`;\n}\nfunction publicTuple(row: any) {\n return {\n incarnation_id: String(row.incarnation_id),\n challenge: String(row.challenge),\n logical_agent_id: String(row.logical_agent_id),\n slot_class: String(row.slot_class),\n workstream: String(row.workstream),\n capabilities: JSON.parse(String(row.capabilities_json)),\n task_sha256: String(row.task_sha256),\n authority_epoch: Number(row.authority_epoch),\n attempt_generation: Number(row.attempt_generation),\n state: String(row.state),\n issued_at: String(row.issued_at),\n expires_at: String(row.expires_at),\n activated_at: row.activated_at ? String(row.activated_at) : null,\n };\n}\nasync function getRow(id: string) {\n const q = await sqlite.execute({\n sql: `SELECT * FROM execution_incarnations_v3_candidate WHERE incarnation_id=?`,\n args: [id],\n });\n return q.rows.length ? (q.rows[0] as any) : null;\n}\nasync function issue() {\n const now = new Date();\n const expires = new Date(now.getTime() + TTL_MS);\n const incarnationId = crypto.randomUUID();\n const challenge = randomHex(32);\n const bearer = randomHex(32);\n const digest = await bearerDigest(bearer);\n const logicalAgentId = makeAgentId(now);\n const taskSha = await sha256Utf8(FIXED_SLOT.task_descriptor);\n const capsJson = JSON.stringify([...FIXED_SLOT.capabilities].sort());\n\n await sqlite.execute({\n sql: `INSERT INTO execution_incarnations_v3_candidate(\n incarnation_id,challenge,bearer_digest,logical_agent_id,slot_class,workstream,\n capabilities_json,task_sha256,authority_epoch,attempt_generation,state,\n issued_at,expires_at\n ) VALUES(?,?,?,?,?,?,?,?,?,1,'ISSUED',?,?)`,\n args: [\n incarnationId, challenge, digest, logicalAgentId, FIXED_SLOT.slot_class,\n FIXED_SLOT.workstream, capsJson, taskSha, AUTHORITY_EPOCH,\n now.toISOString(), expires.toISOString(),\n ],\n });\n\n return json({\n schema: SCHEMA,\n classification: \"CANDIDATE_NONAUTHORITY_ONE_TIME_BEARER_ISSUE\",\n production_admission_eligible: false,\n state: \"BOOTING\",\n incarnation_id: incarnationId,\n challenge,\n bearer,\n logical_agent_id: logicalAgentId,\n workstream: FIXED_SLOT.workstream,\n capabilities: JSON.parse(capsJson),\n task_sha256: taskSha,\n authority_epoch: AUTHORITY_EPOCH,\n attempt_generation: 1,\n issued_at: now.toISOString(),\n liveness_expires_at: expires.toISOString(),\n bearer_storage: \"RETURNED_ONCE_RAW_PERSISTED_ONLY_AS_DOMAIN_SEPARATED_SHA256\",\n human_authority_approval: false,\n p_real_delta: 0,\n }, 201);\n}\nasync function activate(body: any) {\n if (!body || typeof body !== \"object\" || Array.isArray(body) ||\n JSON.stringify(Object.keys(body).sort()) !== JSON.stringify([\"bearer\",\"incarnation_id\"])) {\n return json({error:\"BODY_KEYS_INVALID\"}, 400);\n }\n if (typeof body.incarnation_id !== \"string\" || body.incarnation_id.length < 16 ||\n typeof body.bearer !== \"string\" || !/^[0-9a-f]{64}$/.test(body.bearer)) {\n return json({error:\"ACTIVATION_FIELDS_INVALID\"}, 400);\n }\n\n const digest = await bearerDigest(body.bearer);\n const now = new Date();\n const nowIso = now.toISOString();\n\n const changed = await sqlite.execute({\n sql: `UPDATE execution_incarnations_v3_candidate\n SET state='ACTIVE', activated_at=?\n WHERE incarnation_id=? AND bearer_digest=? AND state='ISSUED'\n AND expires_at>?`,\n args: [nowIso, body.incarnation_id, digest, nowIso],\n });\n\n const row = await getRow(body.incarnation_id);\n if (!row) return json({error:\"INCARNATION_NOT_FOUND\"}, 404);\n\n const expectedDigest = String(row.bearer_digest);\n if (expectedDigest !== digest) return json({error:\"BEARER_MISMATCH\"}, 403);\n if (new Date(String(row.expires_at)).getTime() <= now.getTime()) {\n if (String(row.state) === \"ISSUED\") {\n await sqlite.execute({\n sql: `UPDATE execution_incarnations_v3_candidate SET state='EXPIRED_UNACTIVATED'\n WHERE incarnation_id=? AND state='ISSUED'`,\n args: [body.incarnation_id],\n });\n }\n return json({error:\"INCARNATION_EXPIRED\"}, 410);\n }\n\n const current = await getRow(body.incarnation_id);\n if (!current) return json({error:\"INCARNATION_NOT_FOUND\"}, 404);\n if (String(current.state) !== \"ACTIVE\") {\n return json({error:\"INCARNATION_NOT_ACTIVE\", state:String(current.state)}, 409);\n }\n\n const tuple = publicTuple(current);\n const receipt = {\n schema: SCHEMA,\n classification: \"CANDIDATE_NONAUTHORITY_EXECUTION_INCARCINATION_RECEIPT\",\n production_admission_eligible: false,\n ...tuple,\n state: \"RUNNING\",\n liveness_signal: \"UNEXPIRED_ONE_TIME_BEARER_POSSESSION_PROVEN\",\n activation_transition: changed.rowsAffected === 1 ? \"ISSUED_TO_ACTIVE\" : \"IDEMPOTENT_ACTIVE_READBACK\",\n identity_binding: \"ISSUER_GENERATED_NOT_CALLER_SELECTED\",\n workstream_binding: \"ISSUER_FIXED_SLOT_NOT_CALLER_SELECTED\",\n capability_binding: \"ISSUER_FIXED_SLOT_NOT_CALLER_SELECTED\",\n challenge_binding: \"ISSUER_GENERATED_NOT_CALLER_SELECTED\",\n task_binding: \"ISSUER_FIXED_TASK_DESCRIPTOR_SHA256\",\n bearer_binding: \"DOMAIN_SEPARATED_SHA256_ONLY_PERSISTED\",\n physical_chat_session_distinctness_proven: false,\n independent_review_eligible: false,\n human_authority_approval: false,\n p_real_delta: 0,\n };\n await sqlite.execute({\n sql: `UPDATE execution_incarnations_v3_candidate\n SET receipt_json=? WHERE incarnation_id=? AND state='ACTIVE'`,\n args: [JSON.stringify(receipt), body.incarnation_id],\n });\n return json(receipt, 200);\n}\n\nexport default async function(req: Request) {\n await init();\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/health\") {\n return json({\n schema: SCHEMA,\n state: \"CANDIDATE_NONAUTHORITY\",\n production_admission_eligible: false,\n authority_epoch: AUTHORITY_EPOCH,\n slot_class: FIXED_SLOT.slot_class,\n fixed_workstream: FIXED_SLOT.workstream,\n fixed_capabilities: FIXED_SLOT.capabilities,\n raw_bearer_persisted: false,\n });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/issue\") {\n let body: any = null;\n try { body = await req.json(); } catch { return json({error:\"INVALID_JSON\"}, 400); }\n if (!body || typeof body !== \"object\" || Array.isArray(body) ||\n JSON.stringify(Object.keys(body)) !== JSON.stringify([\"slot_class\"]) ||\n body.slot_class !== FIXED_SLOT.slot_class) {\n return json({error:\"SLOT_REQUEST_INVALID\"}, 400);\n }\n return issue();\n }\n\n if (req.method === \"POST\" && url.pathname === \"/activate\") {\n let body: any;\n try { body = await req.json(); } catch { return json({error:\"INVALID_JSON\"}, 400); }\n return activate(body);\n }\n\n if (req.method === \"GET\" && url.pathname === \"/receipt\") {\n const id = url.searchParams.get(\"id\") || \"\";\n const row = await getRow(id);\n if (!row) return json({error:\"NOT_FOUND\"}, 404);\n const tuple = publicTuple(row);\n return json({\n schema: SCHEMA,\n classification: \"CANDIDATE_NONAUTHORITY_PUBLIC_INCARCINATION_STATE\",\n production_admission_eligible: false,\n ...tuple,\n bearer_present: false,\n bearer_digest_exposed: false,\n receipt: row.receipt_json ? JSON.parse(String(row.receipt_json)) : null,\n });\n }\n\n return json({error:\"NOT_FOUND\"}, 404);\n}\n",[167],"5320fbff-56ee-4673-874d-8b5a923fc2c0","challenge_issuer_v3_a71.ts","02308a54-abbe-11f1-bb88-1607ee4eb77e",14,["D",1788896799385],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SCHEMA = \"PROJECT_BRAIN_EXTERNAL_EXECUTION_PRECOMMIT_V3_CANDIDATE\";\nconst ISSUER_ID = \"mosadek/project-brain-exec-issuer-v1/challenge_issuer_v3_a71.ts\";\nconst WORKSTREAM = \"global\";\nconst FIXED_CAPABILITIES = [\"deterministic_execution\",\"sha256\"] as const;\n\nfunction hex(b: Uint8Array) { return [...b].map(x => x.toString(16).padStart(2,\"0\")).join(\"\"); }\nfunction randomHex(n=32){ const b=new Uint8Array(n); crypto.getRandomValues(b); return hex(b); }\nasync function sha256Utf8(s:string){ return hex(new Uint8Array(await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s)))); }\nfunction json(body:unknown,status=200){ return new Response(JSON.stringify(body),{status,headers:{\"content-type\":\"application/json; charset=utf-8\",\"cache-control\":\"no-store\"}}); }\n\nasync function init(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS atomic_precommits_v3_a71(\n challenge TEXT PRIMARY KEY,\n execution_incarnation_id TEXT NOT NULL UNIQUE,\n logical_agent_id TEXT NOT NULL UNIQUE,\n workstream TEXT NOT NULL,\n capabilities_json TEXT NOT NULL,\n task_json TEXT NOT NULL,\n task_sha256 TEXT NOT NULL,\n state TEXT NOT NULL,\n issued_at TEXT NOT NULL,\n expires_at TEXT NOT NULL,\n reserved_at TEXT,\n reservation_expires_at TEXT,\n completed_at TEXT,\n result_json TEXT,\n receipt_json TEXT,\n terminal_reason TEXT\n )`);\n}\nfunction validateIssue(body:any):string|null{\n if(!body||typeof body!==\"object\"||Array.isArray(body)) return \"BODY_NOT_OBJECT\";\n if(JSON.stringify(Object.keys(body).sort())!==JSON.stringify([\"task\",\"ttl_seconds\"])) return \"BODY_KEYS_INVALID\";\n if(!Number.isInteger(body.ttl_seconds)||body.ttl_seconds<30||body.ttl_seconds>300) return \"TTL_INVALID\";\n if(!body.task||typeof body.task!==\"object\"||Array.isArray(body.task)) return \"TASK_INVALID\";\n if(JSON.stringify(Object.keys(body.task).sort())!==JSON.stringify([\"input\",\"op\"])) return \"TASK_KEYS_INVALID\";\n if(body.task.op!==\"sha256_utf8\") return \"OP_NOT_ALLOWED\";\n if(typeof body.task.input!==\"string\"||body.task.input.length>65536) return \"TASK_INPUT_INVALID\";\n return null;\n}\n\nexport default async function(req:Request){\n await init();\n const url=new URL(req.url);\n if(req.method===\"GET\"&&url.pathname===\"/health\"){\n return json({schema:SCHEMA,issuer_id:ISSUER_ID,state:\"CANDIDATE_NONAUTHORITY\",workstream:WORKSTREAM,fixed_capabilities:FIXED_CAPABILITIES,production_admission_eligible:false});\n }\n if(req.method===\"GET\"&&url.pathname===\"/precommit\"){\n const challenge=url.searchParams.get(\"challenge\")||\"\";\n const q=await sqlite.execute({sql:`SELECT execution_incarnation_id,logical_agent_id,workstream,capabilities_json,task_sha256,state,issued_at,expires_at,reserved_at,reservation_expires_at,completed_at,terminal_reason FROM atomic_precommits_v3_a71 WHERE challenge=?`,args:[challenge]});\n if(!q.rows.length) return json({error:\"NOT_FOUND\"},404);\n const r:any=q.rows[0];\n return json({challenge,...r,capabilities:JSON.parse(String(r.capabilities_json)),capabilities_json:undefined});\n }\n if(req.method!==\"POST\"||url.pathname!==\"/issue\") return json({error:\"NOT_FOUND\"},404);\n let body:any; try{body=await req.json();}catch{return json({error:\"INVALID_JSON\"},400);}\n const invalid=validateIssue(body); if(invalid) return json({error:invalid},400);\n\n const issuedAt=new Date();\n const expiresAt=new Date(issuedAt.getTime()+body.ttl_seconds*1000);\n const executionIncarnationId=crypto.randomUUID();\n const logicalAgentId=\"ext-v3-\"+executionIncarnationId;\n const taskJson=JSON.stringify(body.task);\n const taskSha256=await sha256Utf8(taskJson);\n const capabilitiesJson=JSON.stringify([...FIXED_CAPABILITIES]);\n let challenge=\"\";\n let inserted=false;\n for(let i=0;i<3&&!inserted;i++){\n challenge=randomHex(32);\n const r=await sqlite.execute({sql:`INSERT INTO atomic_precommits_v3_a71\n (challenge,execution_incarnation_id,logical_agent_id,workstream,capabilities_json,task_json,task_sha256,state,issued_at,expires_at)\n VALUES(?,?,?,?,?,?,?,'ISSUED',?,?) ON CONFLICT(challenge) DO NOTHING`,\n args:[challenge,executionIncarnationId,logicalAgentId,WORKSTREAM,capabilitiesJson,taskJson,taskSha256,issuedAt.toISOString(),expiresAt.toISOString()]});\n inserted=r.rowsAffected===1;\n }\n if(!inserted) return json({error:\"CHALLENGE_COLLISION\"},500);\n return json({\n schema:SCHEMA,classification:\"CANDIDATE_NONAUTHORITY_PRECOMMIT\",\n issuer_id:ISSUER_ID,challenge,execution_incarnation_id:executionIncarnationId,\n logical_agent_id:logicalAgentId,workstream:WORKSTREAM,capabilities:[...FIXED_CAPABILITIES],\n task_sha256:taskSha256,issued_at:issuedAt.toISOString(),expires_at:expiresAt.toISOString(),\n binding:\"PROJECT_ISSUER_DERIVED_ID_WORKSTREAM_CAPABILITIES_AND_TASK_HASH\",\n production_admission_eligible:false,human_authority_approval:false,additional_out_of_pocket_spend_usd:0\n },201);\n}\n",[174],"8fdefd7f-f193-4f48-9ecb-468fe6939804","canary_call.ts","c713c500-abb6-11f1-bbc5-1607ee4eb77e",["D",1788893693732],"const endpoint = \"https://mosadek--aa7fce52abb611f1b1431607ee4eb77e.web.val.run/issue\";\nconst body = {\n capabilities: [\"reasoning\",\"val_town\",\"web_research\",\"file_analysis\"],\n challenge: \"cb9e0782bfd239ba4f2b4be86cc9a4c4c5e143f7541dcc83d79875845491533e\",\n logical_agent_id: \"external-val-canary-20260908-2054\",\n ttl_seconds: 180,\n workstream: \"global\"\n};\nconst res = await fetch(endpoint, {\n method: \"POST\",\n headers: {\"content-type\":\"application/json\"},\n body: JSON.stringify(body)\n});\nconst text = await res.text();\nif (res.status !== 201) throw new Error(\"ISSUER_HTTP_FAILED:\"+res.status+\":\"+text);\nconst receipt = JSON.parse(text);\nif (receipt.challenge !== body.challenge) throw new Error(\"CHALLENGE_MISMATCH\");\nif (receipt.logical_agent_id !== body.logical_agent_id) throw new Error(\"AGENT_MISMATCH\");\nif (receipt.workstream !== body.workstream) throw new Error(\"WORKSTREAM_MISMATCH\");\nif (receipt.execution_state !== \"RUNNING\") throw new Error(\"STATE_MISMATCH\");\nconsole.log(JSON.stringify({status:res.status,receipt}));\nexport default {status:res.status,receipt};",[181],"64e3d8d0-6bd7-42b6-93c3-636e7016eacf","atomic_worker_v3_candidate.ts","0e726b02-abbe-11f1-bc32-1607ee4eb77e",17,["D",1788896819917],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst SCHEMA=\"PROJECT_BRAIN_ATOMIC_EXTERNAL_WORKER_V3_PRECOMMIT_CANDIDATE\";\nconst WORKER_ID=\"mosadek/project-brain-exec-issuer-v1/atomic_worker_v3_candidate.ts\";\nconst AUTHORITY_EPOCH=2;\nconst FIXED_CAPABILITIES=[\"deterministic_execution\",\"sha256\"] as const;\nfunction hex(b:ArrayBuffer|Uint8Array){const a=b instanceof Uint8Array?b:new Uint8Array(b);return [...a].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function sha256Utf8(s:string){return hex(await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s)))}\nfunction json(x:unknown,status=200){return new Response(JSON.stringify(x),{status,headers:{\"content-type\":\"application/json; charset=utf-8\",\"cache-control\":\"no-store\"}})}\nasync function init(){await sqlite.execute(`CREATE TABLE IF NOT EXISTS execution_precommits_v3(\n incarnation_id TEXT PRIMARY KEY,bearer_digest TEXT NOT NULL UNIQUE,challenge TEXT NOT NULL UNIQUE,logical_agent_id TEXT NOT NULL UNIQUE,workstream TEXT NOT NULL,capabilities_json TEXT NOT NULL,task_json TEXT NOT NULL,task_sha256 TEXT NOT NULL,authority_epoch INTEGER NOT NULL,credential_generation INTEGER NOT NULL,attempt_generation INTEGER NOT NULL,state TEXT NOT NULL,issued_at_ms INTEGER NOT NULL,expires_at_ms INTEGER NOT NULL,reserved_at_ms INTEGER,completed_at_ms INTEGER,execution_id TEXT,result_json TEXT,receipt_json TEXT)`)}\nexport default async function(req:Request){\n await init(); const u=new URL(req.url);\n if(req.method===\"GET\"&&u.pathname===\"/health\")return json({schema:SCHEMA,worker_id:WORKER_ID,state:\"CANDIDATE_NONAUTHORITY\",fixed_capabilities:FIXED_CAPABILITIES,production_admission_eligible:false});\n if(req.method!==\"POST\"||u.pathname!==\"/execute\")return json({error:\"NOT_FOUND\"},404);\n let body:any;try{body=await req.json()}catch{return json({error:\"INVALID_JSON\"},400)}\n if(!body||typeof body!==\"object\"||Array.isArray(body)||JSON.stringify(Object.keys(body).sort())!==JSON.stringify([\"bearer\",\"incarnation_id\"]))return json({error:\"BODY_KEYS_INVALID\"},400);\n if(typeof body.incarnation_id!==\"string\"||body.incarnation_id.length<10||body.incarnation_id.length>128)return json({error:\"INCARCATION_ID_INVALID\"},400);\n if(typeof body.bearer!==\"string\"||!/^[0-9a-f]{64}$/.test(body.bearer))return json({error:\"BEARER_INVALID\"},400);\n const now=Date.now(); const executionId=crypto.randomUUID(); const digest=await sha256Utf8(\"PB_EXECUTION_BEARER_V3\\0\"+body.bearer);\n const reserve=await sqlite.execute({sql:`UPDATE execution_precommits_v3 SET state='RESERVED',reserved_at_ms=?,execution_id=? WHERE incarnation_id=? AND bearer_digest=? AND state='ISSUED' AND authority_epoch=? AND expires_at_ms>? AND attempt_generation=1`,args:[now,executionId,body.incarnation_id,digest,AUTHORITY_EPOCH,now]});\n if(reserve.rowsAffected!==1){\n const q=await sqlite.execute({sql:\"SELECT state,expires_at_ms,authority_epoch,attempt_generation FROM execution_precommits_v3 WHERE incarnation_id=?\",args:[body.incarnation_id]});\n if(!q.rows.length)return json({error:\"PRECOMMIT_NOT_FOUND\"},404);\n const r:any=q.rows[0]; if(Number(r.expires_at_ms)<=now)return json({error:\"PRECOMMIT_EXPIRED\",state:r.state},410);\n return json({error:\"PRECOMMIT_NOT_CONSUMABLE\",state:r.state,authority_epoch:r.authority_epoch,attempt_generation:r.attempt_generation},409);\n }\n const q=await sqlite.execute({sql:\"SELECT challenge,logical_agent_id,workstream,capabilities_json,task_json,task_sha256,authority_epoch,credential_generation,attempt_generation,issued_at_ms,expires_at_ms FROM execution_precommits_v3 WHERE incarnation_id=? AND execution_id=? AND state='RESERVED'\",args:[body.incarnation_id,executionId]});\n if(q.rows.length!==1)return json({error:\"RESERVATION_READBACK_FAILED\"},500);\n const r:any=q.rows[0];\n const caps=JSON.parse(String(r.capabilities_json)); const task=JSON.parse(String(r.task_json));\n if(String(r.workstream)!==\"global\"||JSON.stringify(caps)!==JSON.stringify(FIXED_CAPABILITIES)||Number(r.authority_epoch)!==AUTHORITY_EPOCH||Number(r.attempt_generation)!==1)return json({error:\"PROJECT_PRECOMMIT_TUPLE_INVALID\"},500);\n if(await sha256Utf8(String(r.task_json))!==String(r.task_sha256))return json({error:\"TASK_HASH_MISMATCH\"},500);\n if(task?.op!==\"sha256_utf8\"||typeof task?.input!==\"string\")return json({error:\"TASK_NOT_EXECUTABLE_FIXED_PROFILE\"},500);\n const result={op:\"sha256_utf8\",sha256:await sha256Utf8(task.input)}; const resultJson=JSON.stringify(result); const completed=Date.now();\n if(completed>Number(r.expires_at_ms)){\n await sqlite.execute({sql:\"UPDATE execution_precommits_v3 SET state='UNKNOWN_OUTCOME',completed_at_ms=?,result_json=? WHERE incarnation_id=? AND execution_id=? AND state='RESERVED'\",args:[completed,resultJson,body.incarnation_id,executionId]});\n return json({error:\"COMPLETED_AFTER_EXPIRY_UNKNOWN_OUTCOME\"},409);\n }\n const receipt={schema:SCHEMA,classification:\"CANDIDATE_NONAUTHORITY_ATOMIC_EXECUTION_RECEIPT\",worker_id:WORKER_ID,execution_id:executionId,incarnation_id:body.incarnation_id,challenge:String(r.challenge),logical_agent_id:String(r.logical_agent_id),workstream:String(r.workstream),capabilities:[...FIXED_CAPABILITIES],capability_source:\"PROJECT_PRECOMMITTED_EXECUTABLE_FIXED_SET\",identity_binding:\"PROJECT_ISSUER_PRECOMMITTED\",challenge_binding:\"PROJECT_ISSUER_PRECOMMITTED\",task_binding:\"PROJECT_ISSUER_PRECOMMITTED_HASH_MATCH\",bearer_binding:\"ONE_TIME_DOMAIN_SEPARATED_DIGEST_POSSESSION\",authority_epoch:Number(r.authority_epoch),credential_generation:Number(r.credential_generation),attempt_generation:Number(r.attempt_generation),task_sha256:String(r.task_sha256),result_sha256:await sha256Utf8(resultJson),issued_at_ms:Number(r.issued_at_ms),reserved_at_ms:now,completed_at_ms:completed,expires_at_ms:Number(r.expires_at_ms),execution_observation:\"PRECOMMITTED_ONE_TIME_HANDLER_EXECUTED_AND_RESULT_PERSISTED\",production_admission_eligible:false,human_authority_approval:false,additional_out_of_pocket_spend_usd:0};\n const done=await sqlite.execute({sql:\"UPDATE execution_precommits_v3 SET state='COMPLETE',completed_at_ms=?,result_json=?,receipt_json=? WHERE incarnation_id=? AND execution_id=? AND state='RESERVED'\",args:[completed,resultJson,JSON.stringify(receipt),body.incarnation_id,executionId]});\n if(done.rowsAffected!==1)return json({error:\"ATOMIC_COMPLETION_CAS_FAILED\"},500);\n return json({result,receipt},200);\n}",[187],"ecc48039-373d-4dad-b616-92df5dc0108a","atomic_worker_v3_a71.ts","032fbd1c-abbe-11f1-a3d6-1607ee4eb77e",15,["D",1788896801057],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SCHEMA=\"PROJECT_BRAIN_ATOMIC_EXTERNAL_WORKER_V3_CANDIDATE\";\nconst WORKER_ID=\"mosadek/project-brain-exec-issuer-v1/atomic_worker_v3_a71.ts\";\nconst FIXED_CAPABILITIES=[\"deterministic_execution\",\"sha256\"] as const;\nconst RESERVATION_TTL_MS=30000;\n\nfunction hex(b:Uint8Array){return [...b].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");}\nasync function sha256Utf8(s:string){return hex(new Uint8Array(await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s))));}\nfunction json(body:unknown,status=200){return new Response(JSON.stringify(body),{status,headers:{\"content-type\":\"application/json; charset=utf-8\",\"cache-control\":\"no-store\"}});}\nasync function init(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS atomic_precommits_v3_a71(\n challenge TEXT PRIMARY KEY, execution_incarnation_id TEXT NOT NULL UNIQUE, logical_agent_id TEXT NOT NULL UNIQUE,\n workstream TEXT NOT NULL, capabilities_json TEXT NOT NULL, task_json TEXT NOT NULL, task_sha256 TEXT NOT NULL,\n state TEXT NOT NULL, issued_at TEXT NOT NULL, expires_at TEXT NOT NULL, reserved_at TEXT, reservation_expires_at TEXT,\n completed_at TEXT, result_json TEXT, receipt_json TEXT, terminal_reason TEXT\n )`);\n}\nfunction validateExecute(body:any):string|null{\n if(!body||typeof body!==\"object\"||Array.isArray(body)) return \"BODY_NOT_OBJECT\";\n if(JSON.stringify(Object.keys(body).sort())!==JSON.stringify([\"challenge\",\"execution_incarnation_id\"])) return \"BODY_KEYS_INVALID\";\n if(typeof body.challenge!==\"string\"||!/^[0-9a-f]{64}$/.test(body.challenge)) return \"CHALLENGE_INVALID\";\n if(typeof body.execution_incarnation_id!==\"string\"||body.execution_incarnation_id.length<10||body.execution_incarnation_id.length>128) return \"EXECUTION_INCARNATION_INVALID\";\n return null;\n}\n\nexport default async function(req:Request){\n await init();\n const url=new URL(req.url);\n if(req.method===\"GET\"&&url.pathname===\"/health\") return json({schema:SCHEMA,worker_id:WORKER_ID,state:\"CANDIDATE_NONAUTHORITY\",fixed_capabilities:FIXED_CAPABILITIES,production_admission_eligible:false});\n if(req.method===\"GET\"&&url.pathname===\"/attempt\"){\n const challenge=url.searchParams.get(\"challenge\")||\"\";\n const q=await sqlite.execute({sql:\"SELECT state,reserved_at,reservation_expires_at,completed_at,result_json,receipt_json,terminal_reason FROM atomic_precommits_v3_a71 WHERE challenge=?\",args:[challenge]});\n if(!q.rows.length) return json({error:\"NOT_FOUND\"},404);\n const r:any=q.rows[0];\n return json({state:r.state,reserved_at:r.reserved_at,reservation_expires_at:r.reservation_expires_at,completed_at:r.completed_at,\n result:r.result_json?JSON.parse(String(r.result_json)):null,receipt:r.receipt_json?JSON.parse(String(r.receipt_json)):null,terminal_reason:r.terminal_reason});\n }\n if(req.method!==\"POST\"||url.pathname!==\"/execute\") return json({error:\"NOT_FOUND\"},404);\n let body:any; try{body=await req.json();}catch{return json({error:\"INVALID_JSON\"},400);}\n const invalid=validateExecute(body); if(invalid) return json({error:invalid},400);\n\n const q=await sqlite.execute({sql:\"SELECT * FROM atomic_precommits_v3_a71 WHERE challenge=?\",args:[body.challenge]});\n if(!q.rows.length) return json({error:\"PRECOMMIT_NOT_FOUND\"},404);\n const row:any=q.rows[0];\n if(String(row.execution_incarnation_id)!==body.execution_incarnation_id) return json({error:\"EXECUTION_INCARNATION_MISMATCH\"},409);\n const now=new Date();\n if(String(row.state)===\"RESERVED\"){\n const reservationExpiry=Date.parse(String(row.reservation_expires_at||\"\"));\n if(Number.isFinite(reservationExpiry)&&reservationExpiry<=now.getTime()){\n await sqlite.execute({sql:\"UPDATE atomic_precommits_v3_a71 SET state='UNKNOWN_OUTCOME',terminal_reason='RESERVATION_EXPIRED_OUTCOME_UNKNOWN' WHERE challenge=? AND execution_incarnation_id=? AND state='RESERVED' AND reservation_expires_at<=?\",\n args:[body.challenge,body.execution_incarnation_id,now.toISOString()]});\n return json({error:\"RESERVATION_EXPIRED_OUTCOME_UNKNOWN\"},409);\n }\n return json({error:\"ATTEMPT_ALREADY_RESERVED\"},409);\n }\n if(String(row.state)!==\"ISSUED\") return json({error:\"PRECOMMIT_STATE_NOT_ISSUED\",state:String(row.state)},409);\n if(Date.parse(String(row.expires_at))<=now.getTime()){\n await sqlite.execute({sql:\"UPDATE atomic_precommits_v3_a71 SET state='EXPIRED',terminal_reason='PRECOMMIT_EXPIRED' WHERE challenge=? AND execution_incarnation_id=? AND state='ISSUED'\",\n args:[body.challenge,body.execution_incarnation_id]});\n return json({error:\"PRECOMMIT_EXPIRED\"},410);\n }\n const expectedCaps=JSON.stringify([...FIXED_CAPABILITIES]);\n if(String(row.capabilities_json)!==expectedCaps) return json({error:\"PRECOMMIT_CAPABILITY_BINDING_INVALID\"},409);\n const taskJson=String(row.task_json);\n if(await sha256Utf8(taskJson)!==String(row.task_sha256)) return json({error:\"PRECOMMIT_TASK_HASH_MISMATCH\"},409);\n\n const reservedAt=now.toISOString();\n const reservationExpiresAt=new Date(now.getTime()+RESERVATION_TTL_MS).toISOString();\n const reserved=await sqlite.execute({sql:`UPDATE atomic_precommits_v3_a71 SET state='RESERVED',reserved_at=?,reservation_expires_at=?\n WHERE challenge=? AND execution_incarnation_id=? AND state='ISSUED' AND expires_at>?`,\n args:[reservedAt,reservationExpiresAt,body.challenge,body.execution_incarnation_id,reservedAt]});\n if(reserved.rowsAffected!==1) return json({error:\"ATOMIC_RESERVATION_CAS_FAILED\"},409);\n\n let task:any; try{task=JSON.parse(taskJson);}catch{return json({error:\"STORED_TASK_JSON_INVALID\"},500);}\n if(!task||task.op!==\"sha256_utf8\"||typeof task.input!==\"string\") return json({error:\"STORED_TASK_INVALID\"},500);\n const result={op:\"sha256_utf8\",sha256:await sha256Utf8(task.input)};\n const resultJson=JSON.stringify(result);\n const completedAt=new Date().toISOString();\n const receipt={\n schema:SCHEMA,classification:\"CANDIDATE_NONAUTHORITY_ATOMIC_EXECUTION_RECEIPT\",\n worker_id:WORKER_ID,execution_incarnation_id:String(row.execution_incarnation_id),challenge:body.challenge,\n logical_agent_id:String(row.logical_agent_id),workstream:String(row.workstream),capabilities:[...FIXED_CAPABILITIES],\n capability_source:\"EXECUTABLE_FIXED_SET_AND_ISSUER_PRECOMMIT\",identity_source:\"PROJECT_ISSUER_GENERATED\",\n task_sha256:String(row.task_sha256),result_sha256:await sha256Utf8(resultJson),\n issued_at:String(row.issued_at),reserved_at:reservedAt,reservation_expires_at:reservationExpiresAt,completed_at:completedAt,\n execution_observation:\"ATOMIC_HANDLER_EXECUTED_AND_RESULT_PERSISTED\",unknown_outcome_policy:\"EXPIRED_RESERVATION_TERMINATES_UNKNOWN_NO_RETRY_SAME_CHALLENGE\",\n production_admission_eligible:false,human_authority_approval:false,additional_out_of_pocket_spend_usd:0\n };\n const done=await sqlite.execute({sql:`UPDATE atomic_precommits_v3_a71 SET state='COMPLETE',completed_at=?,result_json=?,receipt_json=?\n WHERE challenge=? AND execution_incarnation_id=? AND state='RESERVED' AND reserved_at=?`,\n args:[completedAt,resultJson,JSON.stringify(receipt),body.challenge,body.execution_incarnation_id,reservedAt]});\n if(done.rowsAffected!==1) return json({error:\"ATOMIC_COMPLETION_CAS_FAILED\"},500);\n return json({result,receipt},200);\n}\n",[194],"0e2e039c-cc81-4cf2-9ded-d3184d17bf85","atomic_worker_v2_candidate.ts","097e09c2-abbd-11f1-b428-1607ee4eb77e",12,["D",1788896382138],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SCHEMA = \"PROJECT_BRAIN_ATOMIC_EXTERNAL_WORKER_V2_CANDIDATE\";\nconst WORKER_ID = \"mosadek/project-brain-exec-issuer-v1/atomic_worker_v2_candidate.ts\";\nconst FIXED_CAPABILITIES = [\"deterministic_execution\",\"sha256\"] as const;\nconst FORBIDDEN_CAPABILITY = \"human_authority_approval\";\n\nfunction hex(b: ArrayBuffer | Uint8Array) {\n const a = b instanceof Uint8Array ? b : new Uint8Array(b);\n return [...a].map(x => x.toString(16).padStart(2, \"0\")).join(\"\");\n}\nasync function sha256Utf8(s: string) {\n return hex(await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(s)));\n}\nfunction response(body: unknown, status = 200) {\n return new Response(JSON.stringify(body), {\n status,\n headers: {\"content-type\":\"application/json; charset=utf-8\",\"cache-control\":\"no-store\"}\n });\n}\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS atomic_attempts_v2(\n challenge TEXT PRIMARY KEY,\n execution_id TEXT NOT NULL UNIQUE,\n logical_agent_id TEXT NOT NULL,\n workstream TEXT NOT NULL,\n task_json TEXT NOT NULL,\n state TEXT NOT NULL,\n reserved_at TEXT NOT NULL,\n completed_at TEXT,\n result_json TEXT,\n receipt_json TEXT\n )`);\n}\nfunction canonicalCapabilities(xs: unknown[]): string[] {\n return [...new Set(xs as string[])].sort();\n}\nexport function validateV2(body: any): string | null {\n if (!body || typeof body !== \"object\" || Array.isArray(body)) return \"BODY_NOT_OBJECT\";\n const keys = Object.keys(body).sort();\n const allowed = [\"capabilities\",\"challenge\",\"logical_agent_id\",\"task\",\"workstream\"].sort();\n if (JSON.stringify(keys) !== JSON.stringify(allowed)) return \"BODY_KEYS_INVALID\";\n if (typeof body.challenge !== \"string\" || !/^[0-9a-f]{64}$/.test(body.challenge)) return \"CHALLENGE_INVALID\";\n if (typeof body.logical_agent_id !== \"string\" || body.logical_agent_id.length < 3 || body.logical_agent_id.length > 128) return \"AGENT_ID_INVALID\";\n if (typeof body.workstream !== \"string\" || body.workstream.length < 1 || body.workstream.length > 96) return \"WORKSTREAM_INVALID\";\n if (!Array.isArray(body.capabilities) || body.capabilities.length > 64 ||\n !body.capabilities.every((x: unknown) => typeof x === \"string\" && x.length >= 1 && x.length <= 96)) return \"CAPABILITIES_INVALID\";\n if (body.capabilities.includes(FORBIDDEN_CAPABILITY)) return \"HUMAN_AUTHORITY_CAPABILITY_FORBIDDEN\";\n if (body.capabilities.length !== new Set(body.capabilities).size) return \"DUPLICATE_CAPABILITY\";\n if (JSON.stringify(canonicalCapabilities(body.capabilities)) !== JSON.stringify([...FIXED_CAPABILITIES].sort())) return \"CAPABILITY_SET_NOT_EXECUTABLE_FIXED_SET\";\n if (!body.task || typeof body.task !== \"object\" || Array.isArray(body.task)) return \"TASK_INVALID\";\n if (JSON.stringify(Object.keys(body.task).sort()) !== JSON.stringify([\"input\",\"op\"])) return \"TASK_KEYS_INVALID\";\n if (body.task.op !== \"sha256_utf8\") return \"OP_NOT_ALLOWED\";\n if (typeof body.task.input !== \"string\" || body.task.input.length > 65536) return \"TASK_INPUT_INVALID\";\n return null;\n}\n\nexport default async function(req: Request) {\n await init();\n const url = new URL(req.url);\n if (req.method === \"GET\" && url.pathname === \"/health\") {\n return response({\n schema:SCHEMA,worker_id:WORKER_ID,state:\"CANDIDATE_NONAUTHORITY\",\n supported_ops:[\"sha256_utf8\"],fixed_capabilities:FIXED_CAPABILITIES,\n production_admission_eligible:false\n });\n }\n if (req.method === \"GET\" && url.pathname === \"/attempt\") {\n const challenge = url.searchParams.get(\"challenge\") || \"\";\n const q = await sqlite.execute({sql:\"SELECT state,reserved_at,completed_at,result_json,receipt_json FROM atomic_attempts_v2 WHERE challenge=?\",args:[challenge]});\n if (!q.rows.length) return response({error:\"NOT_FOUND\"},404);\n const row:any=q.rows[0];\n return response({\n state:row.state,reserved_at:row.reserved_at,completed_at:row.completed_at,\n result:row.result_json?JSON.parse(String(row.result_json)):null,\n receipt:row.receipt_json?JSON.parse(String(row.receipt_json)):null\n });\n }\n if (req.method !== \"POST\" || url.pathname !== \"/execute\") return response({error:\"NOT_FOUND\"},404);\n\n let body:any;\n try { body = await req.json(); } catch { return response({error:\"INVALID_JSON\"},400); }\n const invalid=validateV2(body);\n if (invalid) return response({error:invalid},400);\n\n const executionId=crypto.randomUUID();\n const reservedAt=new Date().toISOString();\n const taskJson=JSON.stringify(body.task);\n const reservation=await sqlite.execute({\n sql:`INSERT INTO atomic_attempts_v2(challenge,execution_id,logical_agent_id,workstream,task_json,state,reserved_at)\n VALUES(?,?,?,?,?,'RESERVED',?) ON CONFLICT(challenge) DO NOTHING`,\n args:[body.challenge,executionId,body.logical_agent_id,body.workstream,taskJson,reservedAt]\n });\n if (reservation.rowsAffected !== 1) return response({error:\"CHALLENGE_REPLAY_OR_CONCURRENT_ATTEMPT\"},409);\n\n const result={op:\"sha256_utf8\",sha256:await sha256Utf8(body.task.input)};\n const resultJson=JSON.stringify(result);\n const completedAt=new Date().toISOString();\n const receipt={\n schema:SCHEMA,\n classification:\"CANDIDATE_NONAUTHORITY_ATOMIC_EXECUTION_RECEIPT\",\n worker_id:WORKER_ID,\n execution_id:executionId,\n challenge:body.challenge,\n logical_agent_id:body.logical_agent_id,\n workstream:body.workstream,\n capabilities:[...FIXED_CAPABILITIES],\n capability_source:\"EXECUTABLE_FIXED_SET_NOT_CALLER_AUTHORITY\",\n identity_binding:\"CALLER_REQUESTED_NOT_PROJECT_ATTESTED\",\n challenge_binding:\"CALLER_SUPPLIED_NOT_PROJECT_PRECOMMITTED\",\n production_admission_eligible:false,\n task_sha256:await sha256Utf8(taskJson),\n result_sha256:await sha256Utf8(resultJson),\n reserved_at:reservedAt,\n completed_at:completedAt,\n execution_observation:\"ATOMIC_HANDLER_EXECUTED_AND_RESULT_PERSISTED\",\n human_authority_approval:false,\n additional_out_of_pocket_spend_usd:0\n };\n const done=await sqlite.execute({\n sql:`UPDATE atomic_attempts_v2\n SET state='COMPLETE',completed_at=?,result_json=?,receipt_json=?\n WHERE challenge=? AND execution_id=? AND state='RESERVED'`,\n args:[completedAt,resultJson,JSON.stringify(receipt),body.challenge,executionId]\n });\n if (done.rowsAffected !== 1) return response({error:\"ATOMIC_COMPLETION_CAS_FAILED\"},500);\n return response({result,receipt},200);\n}",[201],"2be2880c-b46c-4a90-bdd4-bc11023cb35d","atomic_worker.ts","464efc54-abb7-11f1-87fe-1607ee4eb77e",5,["D",1788893907200],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SCHEMA = \"PROJECT_BRAIN_ATOMIC_EXTERNAL_WORKER_V1\";\nconst WORKER_ID = \"mosadek/project-brain-exec-issuer-v1/atomic_worker.ts\";\n\nfunction hex(b: ArrayBuffer | Uint8Array) {\n const a = b instanceof Uint8Array ? b : new Uint8Array(b);\n return [...a].map(x => x.toString(16).padStart(2, \"0\")).join(\"\");\n}\nasync function sha256Utf8(s: string) {\n return hex(await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(s)));\n}\nfunction response(body: unknown, status = 200) {\n return new Response(JSON.stringify(body), {\n status,\n headers: {\"content-type\":\"application/json; charset=utf-8\",\"cache-control\":\"no-store\"}\n });\n}\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS atomic_attempts(\n challenge TEXT PRIMARY KEY,\n execution_id TEXT NOT NULL UNIQUE,\n logical_agent_id TEXT NOT NULL,\n workstream TEXT NOT NULL,\n task_json TEXT NOT NULL,\n state TEXT NOT NULL,\n reserved_at TEXT NOT NULL,\n completed_at TEXT,\n result_json TEXT,\n receipt_json TEXT\n )`);\n}\nfunction validate(body: any): string | null {\n if (!body || typeof body !== \"object\" || Array.isArray(body)) return \"BODY_NOT_OBJECT\";\n const keys = Object.keys(body).sort();\n const allowed = [\"capabilities\",\"challenge\",\"logical_agent_id\",\"task\",\"workstream\"].sort();\n if (JSON.stringify(keys) !== JSON.stringify(allowed)) return \"BODY_KEYS_INVALID\";\n if (typeof body.challenge !== \"string\" || !/^[0-9a-f]{64}$/.test(body.challenge)) return \"CHALLENGE_INVALID\";\n if (typeof body.logical_agent_id !== \"string\" || body.logical_agent_id.length < 3 || body.logical_agent_id.length > 128) return \"AGENT_ID_INVALID\";\n if (typeof body.workstream !== \"string\" || body.workstream.length < 1 || body.workstream.length > 96) return \"WORKSTREAM_INVALID\";\n if (!Array.isArray(body.capabilities) || body.capabilities.length > 64 ||\n !body.capabilities.every((x: unknown) => typeof x === \"string\" && x.length >= 1 && x.length <= 96)) return \"CAPABILITIES_INVALID\";\n if (!body.task || typeof body.task !== \"object\" || Array.isArray(body.task)) return \"TASK_INVALID\";\n if (JSON.stringify(Object.keys(body.task).sort()) !== JSON.stringify([\"input\",\"op\"])) return \"TASK_KEYS_INVALID\";\n if (body.task.op !== \"sha256_utf8\") return \"OP_NOT_ALLOWED\";\n if (typeof body.task.input !== \"string\" || body.task.input.length > 65536) return \"TASK_INPUT_INVALID\";\n return null;\n}\n\nexport default async function(req: Request) {\n await init();\n const url = new URL(req.url);\n if (req.method === \"GET\" && url.pathname === \"/health\") {\n return response({schema:SCHEMA,worker_id:WORKER_ID,state:\"CANARY_NONAUTHORITY\",supported_ops:[\"sha256_utf8\"]});\n }\n if (req.method === \"GET\" && url.pathname === \"/attempt\") {\n const challenge = url.searchParams.get(\"challenge\") || \"\";\n const q = await sqlite.execute({sql:\"SELECT state,reserved_at,completed_at,result_json,receipt_json FROM atomic_attempts WHERE challenge=?\",args:[challenge]});\n if (!q.rows.length) return response({error:\"NOT_FOUND\"},404);\n const row:any=q.rows[0];\n return response({\n state:row.state,reserved_at:row.reserved_at,completed_at:row.completed_at,\n result:row.result_json?JSON.parse(String(row.result_json)):null,\n receipt:row.receipt_json?JSON.parse(String(row.receipt_json)):null\n });\n }\n if (req.method !== \"POST\" || url.pathname !== \"/execute\") return response({error:\"NOT_FOUND\"},404);\n\n let body:any;\n try { body = await req.json(); } catch { return response({error:\"INVALID_JSON\"},400); }\n const invalid=validate(body);\n if (invalid) return response({error:invalid},400);\n\n const executionId=crypto.randomUUID();\n const reservedAt=new Date().toISOString();\n const taskJson=JSON.stringify(body.task);\n const reservation=await sqlite.execute({\n sql:`INSERT INTO atomic_attempts(challenge,execution_id,logical_agent_id,workstream,task_json,state,reserved_at)\n VALUES(?,?,?,?,?,'RESERVED',?) ON CONFLICT(challenge) DO NOTHING`,\n args:[body.challenge,executionId,body.logical_agent_id,body.workstream,taskJson,reservedAt]\n });\n if (reservation.rowsAffected !== 1) return response({error:\"CHALLENGE_REPLAY_OR_CONCURRENT_ATTEMPT\"},409);\n\n const inputSha256=await sha256Utf8(body.task.input);\n const result={op:\"sha256_utf8\",sha256:inputSha256};\n const resultJson=JSON.stringify(result);\n const resultSha256=await sha256Utf8(resultJson);\n const completedAt=new Date().toISOString();\n const receipt={\n schema:SCHEMA,\n classification:\"CANDIDATE_NONAUTHORITY_ATOMIC_EXECUTION_RECEIPT\",\n worker_id:WORKER_ID,\n execution_id:executionId,\n challenge:body.challenge,\n logical_agent_id:body.logical_agent_id,\n workstream:body.workstream,\n capabilities:[...new Set(body.capabilities)].sort(),\n task_sha256:await sha256Utf8(taskJson),\n result_sha256:resultSha256,\n reserved_at:reservedAt,\n completed_at:completedAt,\n execution_observation:\"ATOMIC_HANDLER_EXECUTED_AND_RESULT_PERSISTED\",\n human_authority_approval:false,\n additional_out_of_pocket_spend_usd:0\n };\n const done=await sqlite.execute({\n sql:`UPDATE atomic_attempts\n SET state='COMPLETE',completed_at=?,result_json=?,receipt_json=?\n WHERE challenge=? AND execution_id=? AND state='RESERVED'`,\n args:[completedAt,resultJson,JSON.stringify(receipt),body.challenge,executionId]\n });\n if (done.rowsAffected !== 1) return response({error:\"ATOMIC_COMPLETION_CAS_FAILED\"},500);\n return response({result,receipt},200);\n}",[208],"efd3fd7f-2d08-4c18-8dae-2ba4791d4cc6",["D",1788896925477],[27],"9d5d2044-e587-40a8-b2c2-e244a5e5cb40","atomic_admission_v3_a71_live_canary.ts","1c387b6e-abbe-11f1-a728-1607ee4eb77e",19,["D",1788896843049],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst ISSUER=\"https://mosadek--02308a54abbe11f1bb881607ee4eb77e.web.val.run\";\nconst WORKER=\"https://mosadek--032fbd1cabbe11f1a3d61607ee4eb77e.web.val.run\";\n\nasync function req(url:string,method=\"GET\",body?:unknown){\n const r=await fetch(url,{method,headers:body?{\"content-type\":\"application/json\"}:undefined,body:body?JSON.stringify(body):undefined});\n let j:any=null; try{j=await r.json();}catch{}\n return {status:r.status,body:j};\n}\nfunction must(cond:boolean,msg:string){ if(!cond) throw new Error(msg); }\nfunction hex(b:Uint8Array){return [...b].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");}\nasync function sha(s:string){return hex(new Uint8Array(await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s))));}\n\nconst report:any={schema:\"ATOMIC_EXTERNAL_ADMISSION_V3_A71_LIVE_FALSIFICATION_V1\",started_at:new Date().toISOString(),checks:[]};\nfunction check(name:string,cond:boolean,detail:any){report.checks.push({name,pass:cond,detail});must(cond,name);}\n\nconst injection=await req(ISSUER+\"/issue\",\"POST\",{task:{op:\"sha256_utf8\",input:\"x\"},ttl_seconds:60,capabilities:[\"human_authority_approval\"]});\ncheck(\"issuer_rejects_caller_capability_injection\",injection.status===400,injection);\n\nconst issue=await req(ISSUER+\"/issue\",\"POST\",{task:{op:\"sha256_utf8\",input:\"ATOMIC_V3_A71_CANARY\"},ttl_seconds:60});\ncheck(\"issue_created\",issue.status===201,issue);\ncheck(\"issuer_generated_identity\",typeof issue.body.logical_agent_id===\"string\"&&issue.body.logical_agent_id.startsWith(\"ext-v3-\"),issue.body);\ncheck(\"issuer_fixed_workstream\",issue.body.workstream===\"global\",issue.body);\ncheck(\"issuer_fixed_capabilities\",JSON.stringify(issue.body.capabilities)===JSON.stringify([\"deterministic_execution\",\"sha256\"]),issue.body);\ncheck(\"issuer_no_human_authority\",issue.body.human_authority_approval===false,issue.body);\n\nconst extra=await req(WORKER+\"/execute\",\"POST\",{challenge:issue.body.challenge,execution_incarnation_id:issue.body.execution_incarnation_id,capabilities:[\"human_authority_approval\"]});\ncheck(\"worker_rejects_extra_fields\",extra.status===400,extra);\n\nconst wrong=await req(WORKER+\"/execute\",\"POST\",{challenge:issue.body.challenge,execution_incarnation_id:crypto.randomUUID()});\ncheck(\"worker_rejects_wrong_incarnation\",wrong.status===409&&wrong.body.error===\"EXECUTION_INCARNATION_MISMATCH\",wrong);\n\nconst expected=await sha(\"ATOMIC_V3_A71_CANARY\");\nconst good=await req(WORKER+\"/execute\",\"POST\",{challenge:issue.body.challenge,execution_incarnation_id:issue.body.execution_incarnation_id});\ncheck(\"valid_execute\",good.status===200&&good.body.result?.sha256===expected,good);\ncheck(\"receipt_bound_identity\",good.body.receipt?.logical_agent_id===issue.body.logical_agent_id&&good.body.receipt?.execution_incarnation_id===issue.body.execution_incarnation_id,good.body.receipt);\ncheck(\"receipt_fixed_caps\",JSON.stringify(good.body.receipt?.capabilities)===JSON.stringify([\"deterministic_execution\",\"sha256\"]),good.body.receipt);\ncheck(\"receipt_no_human_authority\",good.body.receipt?.human_authority_approval===false,good.body.receipt);\n\nconst replay=await req(WORKER+\"/execute\",\"POST\",{challenge:issue.body.challenge,execution_incarnation_id:issue.body.execution_incarnation_id});\ncheck(\"replay_rejected\",replay.status===409,replay);\nconst attempt=await req(WORKER+\"/attempt?challenge=\"+issue.body.challenge);\ncheck(\"readback_complete\",attempt.status===200&&attempt.body.state===\"COMPLETE\",attempt);\n\nconst exp=await req(ISSUER+\"/issue\",\"POST\",{task:{op:\"sha256_utf8\",input:\"EXPIRE\"},ttl_seconds:60});\ncheck(\"expiry_issue\",exp.status===201,exp);\nawait sqlite.execute({sql:\"UPDATE atomic_precommits_v3_a71 SET expires_at=? WHERE challenge=?\",args:[new Date(Date.now()-1000).toISOString(),exp.body.challenge]});\nconst expRun=await req(WORKER+\"/execute\",\"POST\",{challenge:exp.body.challenge,execution_incarnation_id:exp.body.execution_incarnation_id});\ncheck(\"expired_precommit_fails_closed\",expRun.status===410&&expRun.body.error===\"PRECOMMIT_EXPIRED\",expRun);\n\nconst unk=await req(ISSUER+\"/issue\",\"POST\",{task:{op:\"sha256_utf8\",input:\"UNKNOWN\"},ttl_seconds:60});\ncheck(\"unknown_issue\",unk.status===201,unk);\nconst past=new Date(Date.now()-1000).toISOString();\nawait sqlite.execute({sql:\"UPDATE atomic_precommits_v3_a71 SET state='RESERVED',reserved_at=?,reservation_expires_at=? WHERE challenge=?\",args:[past,past,unk.body.challenge]});\nconst unkRun=await req(WORKER+\"/execute\",\"POST\",{challenge:unk.body.challenge,execution_incarnation_id:unk.body.execution_incarnation_id});\ncheck(\"expired_reservation_terminalizes_unknown\",unkRun.status===409&&unkRun.body.error===\"RESERVATION_EXPIRED_OUTCOME_UNKNOWN\",unkRun);\nconst unkRead=await req(WORKER+\"/attempt?challenge=\"+unk.body.challenge);\ncheck(\"unknown_readback_terminal\",unkRead.status===200&&unkRead.body.state===\"UNKNOWN_OUTCOME\"&&unkRead.body.terminal_reason===\"RESERVATION_EXPIRED_OUTCOME_UNKNOWN\",unkRead);\n\nreport.completed_at=new Date().toISOString();\nreport.pass=report.checks.every((x:any)=>x.pass);\nreport.brain_queue_traffic_submitted=false;\nreport.canonical_brain_mutation=false;\nreport.human_authority_approval=false;\nreport.direct_sprites_calls=0;\nreport.additional_out_of_pocket_spend_usd=0;\nconsole.log(JSON.stringify(report,null,2));\n",[218],"pulls","branches",1,"forks","envVars",{"_232":226,"_234":61},"connections",{"_232":61,"_233":61},"count","unfilledCount","emptyCount",{"_41":217,"_31":218,"_29":219,"_144":-5,"_39":40,"_38":220,"_146":57,"_36":281,"_13":61,"_32":33,"_34":222,"_23":24,"_150":-5,"_248":282,"_26":283},{"_41":214,"_31":27,"_29":30,"_144":-5,"_39":40,"_38":14,"_146":57,"_36":278,"_13":61,"_32":33,"_34":35,"_23":24,"_150":-5,"_248":279,"_26":280},{"_41":207,"_31":208,"_29":209,"_144":-5,"_39":40,"_38":210,"_146":57,"_36":275,"_13":61,"_32":148,"_34":212,"_23":24,"_150":-5,"_248":276,"_26":277},{"_41":200,"_31":201,"_29":202,"_144":-5,"_39":40,"_38":203,"_146":57,"_36":272,"_13":61,"_32":148,"_34":205,"_23":24,"_150":-5,"_248":273,"_26":274},{"_41":193,"_31":194,"_29":195,"_144":-5,"_39":40,"_38":196,"_146":24,"_36":269,"_13":61,"_32":148,"_34":198,"_23":24,"_150":-5,"_248":270,"_26":271},{"_41":186,"_31":187,"_29":188,"_144":-5,"_39":40,"_38":189,"_146":57,"_36":266,"_13":61,"_32":148,"_34":191,"_23":24,"_150":-5,"_248":267,"_26":268},{"_41":180,"_31":181,"_29":182,"_144":-5,"_39":40,"_38":156,"_146":57,"_36":263,"_13":61,"_32":33,"_34":184,"_23":24,"_150":-5,"_248":264,"_26":265},{"_41":173,"_31":174,"_29":175,"_144":-5,"_39":40,"_38":176,"_146":57,"_36":260,"_13":61,"_32":148,"_34":178,"_23":24,"_150":-5,"_248":261,"_26":262},{"_41":166,"_31":167,"_29":168,"_144":-5,"_39":40,"_38":169,"_146":57,"_36":257,"_13":61,"_32":148,"_34":171,"_23":24,"_150":-5,"_248":258,"_26":259},{"_41":159,"_31":160,"_29":161,"_144":-5,"_39":40,"_38":162,"_146":57,"_36":254,"_13":61,"_32":33,"_34":164,"_23":24,"_150":-5,"_248":255,"_26":256},{"_41":152,"_31":153,"_29":55,"_144":-5,"_39":40,"_38":154,"_146":57,"_36":251,"_13":156,"_32":148,"_34":157,"_23":24,"_150":-5,"_248":252,"_26":253},{"_41":141,"_31":142,"_29":143,"_144":-5,"_39":40,"_38":145,"_146":57,"_36":247,"_13":61,"_32":148,"_34":149,"_23":24,"_150":-5,"_248":249,"_26":250},["D",1788896818243],"children",[],[142],["D",1788893872452],[],[153],["D",1788896899103],[],[160],["D",1788896857531],[],[167],["D",1788896799385],[],[174],["D",1788893693732],[],[181],["D",1788896819917],[],[187],["D",1788896801057],[],[194],["D",1788896382138],[],[201],["D",1788893907200],[],[208],["D",1788896925477],[],[27],["D",1788896843049],[],[218],["D",1788893645758],["D",1789502486629],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":322,"_323":324,"_325":326,"_327":24,"_328":24,"_329":24,"_330":57,"_331":-5,"_332":-7,"_333":-7,"_334":61,"_335":24,"_336":24,"_337":-5,"_338":24,"_339":24,"_340":24,"_341":-5},"ENV",{"_293":294,"_295":296,"_297":88,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v23