[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_453":454,"_455":456},"routes/_app.x.$handle.$name",{"_100":99,"_32":44,"_109":88,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":123,"_124":26,"_125":126,"_127":24,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":24,"_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":26},"version",35,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","tmp_r9_final_pairing_test.ts","latestPath","fileId","8e675e42-a369-11f1-bdc2-1607ee4eb77e","name","fileType","script","content","\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst BASE=\"https://sebas1--01a04be61b1e7309a9270b8b6ef9cc89.web.val.run\";\nconst GPT=Deno.env.get(\"GPT_TOKEN_V4\")||\"\"; if(!GPT)throw new Error(\"GPT_MISSING\");\nconst BOOT=\"2feb17809757ddf6d9fb192f9d4385d8e7a21d92182e1a4dd228c2fe94c4db37\";\nconst L=\"CODEX_REAL_RUNTIME_ACCEPTANCE_V4\", CID=\"5abe8d3e-d35f-411f-b1c7-a8f4dc3e4b89\", CS=\"d7fe64c4a5b4e3d27ef3c9e636610a2a67812c9b7234dccb86a1061f17b8ab50\";\nasync function req(m:string,p:string,b?:unknown,t?:string){const h:Record={\"User-Agent\":\"r9-final-candidate-regression\"};if(b!==undefined)h[\"Content-Type\"]=\"application/json\";if(t)h[\"Authorization\"]=\"Bearer \"+t;const r=await fetch(BASE+p,{method:m,headers:h,body:b===undefined?undefined:JSON.stringify(b)});const x=await r.text();let j:any={};try{j=x?JSON.parse(x):{}}catch{};return{status:r.status,json:j};}\nfunction ok(x:boolean,l:string){if(!x)throw new Error(\"ASSERT:\"+l);}\nlet pid=\"\";\ntry{\n const bad=await req(\"POST\",\"/v1/pair/codex/device/start\",{client_label:\"r9-final-candidate-regression\",bootstrap_script_sha256:\"0\".repeat(64),acceptance_lane:L,challenge_message_id:CID,challenge_message_sha256:CS});\n ok(bad.status===409,\"bad\");\n const s=await req(\"POST\",\"/v1/pair/codex/device/start\",{client_label:\"r9-final-candidate-regression\",bootstrap_script_sha256:BOOT,acceptance_lane:L,challenge_message_id:CID,challenge_message_sha256:CS});\n ok(s.status===201&&s.json.schema===\"rumbo-codex-device-pairing/v3\",\"start\"); pid=s.json.pairing_id;\n const i=await req(\"POST\",\"/v1/pair/codex/device/inspect\",{user_code:s.json.user_code},GPT);ok(i.status===200&&i.json.contract_ok===true,\"inspect\");\n const a=await req(\"POST\",\"/v1/pair/codex/device/approve\",{user_code:s.json.user_code,expected_pairing_id:pid},GPT);ok(a.status===200&&a.json.contract_ok===true,\"approve\");\n const p=await req(\"POST\",\"/v1/pair/codex/device/poll\",{device_code:s.json.device_code});ok(p.status===200&&p.json.schema===\"rumbo-codex-device-pairing/v3\"&&p.json.lane_scope===L,\"poll\");\n const dev=p.json.token;\n const c=await req(\"GET\",\"/v1/challenge/\"+L,undefined,dev);ok(c.status===200&&c.json.challenge?.id===CID,\"challenge\");\n const acc=await req(\"GET\",\"/v1/acceptance/\"+L,undefined,GPT);ok(acc.status===200&&acc.json.state===\"PENDING_CODEX_ACK\",\"acceptance\");\n const rv=await req(\"POST\",\"/v1/pair/codex/device/revoke\",{pairing_id:pid},dev);ok(rv.status===200,\"revoke\");\n const reuse=await req(\"GET\",\"/v1/state/\"+L,undefined,dev);ok(reuse.status===401,\"reuse\");\n console.log(JSON.stringify({result:\"PASS\",bad:bad.status,start:s.status,inspect:i.status,approve:a.status,poll:p.status,challenge:c.status,acceptance:acc.json.state,revoke:rv.status,post_revoke:reuse.status}));\n}finally{\n if(pid){await sqlite.execute({sql:\"DELETE FROM device_access_tokens WHERE pairing_id=?\",args:[pid]});await sqlite.execute({sql:\"DELETE FROM device_pairing_contracts WHERE pairing_id=?\",args:[pid]});await sqlite.execute({sql:\"DELETE FROM device_pairing_sessions WHERE pairing_id=?\",args:[pid]});}\n}\n","createdAt",["D",1787980918115],"branchVersion","branchId","274c486e-95f0-4b59-bb8a-e49918c713fc","id","ea8b2cee-9441-4610-a164-e736539c861b","rumbo-continuity-relay",["D",1787964475423],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Durable GPT-Codex continuity relay","imageUrl","d3788f19-13c5-4356-87e8-dce639626bb9","pinnedFileId","01a04afc-c88b-766f-9e89-3c0c81cf30bc","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04116-f28c-754c-9173-77bf5814fcd6","tursoName","ea8b2cee94414610a164e736539c861b","tursoHostname","ea8b2cee94414610a164e736539c861b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789531243171],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":54,"_105":106,"_107":26},"branch",{"_13":87,"_32":88,"_42":41,"_89":43,"_90":91,"_92":93,"_94":49,"_95":43,"_96":63,"_97":44,"_98":99},"isOwned",36,"r9-v15-reconciled-isolation","projectId","forkedBranchId","cdbfe23c-d122-4f18-ad6e-34fdd0cb88da","forkedBranchVersion",173,"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sebas1","handle","displayName","sebas","avatar","https://lh3.googleusercontent.com/a/ACg8ocJaC6uiXPmN9dvgA2XcSlzBSkPJO0GN5zKzPm3a8cbjmXC9HYA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":448,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":24,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":449,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":450,"_82":451,"_84":452,"_86":26},"tree",[327,328,332,333,334,335,336,337,338,339,340,341,342,343,344,345,346,347,348,349,350,351,352,353],"files",[327,328,329,330,331,332,333,334,335,336,337,338,339,340,341,342,343,344,345,346,347,348,349,350,351,352,353],"counts",{"_315":61,"_316":317,"_318":61,"_319":320,"_321":322},"contents",[139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162],"upstreamProject","upstreamBranch",{"_42":91,"_37":132,"_133":134,"_32":135,"_89":43,"_13":136,"_90":-5,"_92":-5,"_137":138,"_46":-5,"_86":26,"_48":49,"_98":99,"_62":63,"_97":44},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1787964475423],"updatedAt",["D",1788191453959],"main",234,"lockfileKey","1788191454040-esm.town_v_sebas1_rumbo-continuity-relay@234-main",{"_42":310,"_32":311,"_30":312,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":313,"_13":61,"_33":308,"_35":-5,"_23":26,"_167":-5,"_27":314},{"_42":304,"_32":305,"_30":306,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":307,"_13":61,"_33":308,"_35":-5,"_23":26,"_167":-5,"_27":309},{"_42":298,"_32":299,"_30":300,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":301,"_13":61,"_33":20,"_35":302,"_23":26,"_167":-5,"_27":303},{"_42":292,"_32":293,"_30":294,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":295,"_13":61,"_33":20,"_35":296,"_23":26,"_167":-5,"_27":297},{"_42":286,"_32":287,"_30":288,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":289,"_13":61,"_33":20,"_35":290,"_23":26,"_167":-5,"_27":291},{"_42":280,"_32":281,"_30":282,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":283,"_13":61,"_33":20,"_35":284,"_23":26,"_167":-5,"_27":285},{"_42":274,"_32":275,"_30":276,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":277,"_13":61,"_33":20,"_35":278,"_23":26,"_167":-5,"_27":279},{"_42":268,"_32":269,"_30":270,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":271,"_13":61,"_33":20,"_35":272,"_23":26,"_167":-5,"_27":273},{"_42":262,"_32":263,"_30":264,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":265,"_13":61,"_33":20,"_35":266,"_23":26,"_167":-5,"_27":267},{"_42":256,"_32":257,"_30":258,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":259,"_13":61,"_33":20,"_35":260,"_23":26,"_167":-5,"_27":261},{"_42":250,"_32":251,"_30":252,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":253,"_13":61,"_33":20,"_35":254,"_23":26,"_167":-5,"_27":255},{"_42":244,"_32":245,"_30":246,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":247,"_13":61,"_33":34,"_35":248,"_23":26,"_167":-5,"_27":249},{"_42":237,"_32":238,"_30":239,"_164":-5,"_40":41,"_39":240,"_165":24,"_37":241,"_13":174,"_33":20,"_35":242,"_23":26,"_167":-5,"_27":243},{"_42":229,"_32":230,"_30":231,"_164":-5,"_40":41,"_39":232,"_165":24,"_37":233,"_13":180,"_33":234,"_35":235,"_23":26,"_167":-5,"_27":236},{"_42":220,"_32":221,"_30":222,"_164":-5,"_40":41,"_39":223,"_165":24,"_37":224,"_13":225,"_33":226,"_35":227,"_23":26,"_167":-5,"_27":228},{"_42":214,"_32":215,"_30":216,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":217,"_13":61,"_33":34,"_35":218,"_23":26,"_167":-5,"_27":219},{"_42":208,"_32":209,"_30":210,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":211,"_13":61,"_33":34,"_35":212,"_23":26,"_167":-5,"_27":213},{"_42":202,"_32":203,"_30":204,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":205,"_13":61,"_33":34,"_35":206,"_23":26,"_167":-5,"_27":207},{"_42":196,"_32":197,"_30":198,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":199,"_13":61,"_33":34,"_35":200,"_23":26,"_167":-5,"_27":201},{"_42":190,"_32":191,"_30":192,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":193,"_13":61,"_33":34,"_35":194,"_23":26,"_167":-5,"_27":195},{"_42":184,"_32":185,"_30":186,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":187,"_13":61,"_33":34,"_35":188,"_23":26,"_167":-5,"_27":189},{"_42":177,"_32":178,"_30":179,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":181,"_13":61,"_33":34,"_35":182,"_23":26,"_167":-5,"_27":183},{"_42":169,"_32":170,"_30":171,"_164":-5,"_40":41,"_39":172,"_165":24,"_37":173,"_13":174,"_33":34,"_35":175,"_23":26,"_167":-5,"_27":176},{"_42":163,"_32":28,"_30":31,"_164":-5,"_40":41,"_39":14,"_165":26,"_37":166,"_13":61,"_33":34,"_35":36,"_23":26,"_167":-5,"_27":168},"a953bfdc-3d7f-48fe-811a-89923c2b87b4","parentId","latest",["D",1787980918115],"label",[28],"733ed865-3407-4101-88ee-528c0553cf85","r9_bootstrap_module.ts","e0705088-a367-11f1-ab25-1607ee4eb77e",30,["D",1787980873315],2,"export const R9_BOOTSTRAP_PY = \"#!/usr/bin/env python3\\nfrom __future__ import annotations\\nimport calendar,hashlib,io,json,os,platform,re,secrets,shutil,subprocess,sys,tempfile,time,urllib.error,urllib.parse,urllib.request,zipfile\\nfrom pathlib import Path\\n\\nBASE=\\\"https://sebas1--01a04afcc88b766f9e893c0c81cf30bc.web.val.run\\\"\\nLANE=\\\"CODEX_REAL_RUNTIME_ACCEPTANCE_V4\\\"\\nCID=\\\"5abe8d3e-d35f-411f-b1c7-a8f4dc3e4b89\\\"\\nCSHA=\\\"d7fe64c4a5b4e3d27ef3c9e636610a2a67812c9b7234dccb86a1061f17b8ab50\\\"\\nRELEASE=\\\"GPT_CODEX_CONTEXT_BRIDGE_V1_6\\\"\\nRELEASE_SHA=\\\"cdbbb59d96a4a45d943f6d14a610e3cdbf451cc9480ed9300a170f60bef39e0b\\\"\\nSKILL_SHA=\\\"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\\\"\\nPLUGIN=\\\"rumbo-gpt-codex-continuity\\\"\\nVERSION=\\\"1.2.0\\\"\\nMANIFEST_SHA=\\\"c0f12562dbee00f897b7f0d164b35845f7388ec996c19b371c0ccf6e0fb12d27\\\"\\nDEADLINE=\\\"2026-08-31T03:15:00Z\\\"\\nMANIFEST='{\\\"name\\\": \\\"rumbo-gpt-codex-continuity\\\", \\\"version\\\": \\\"1.2.0\\\", \\\"description\\\": \\\"RUMBO GPT-Codex continuity bridge with isolated real-runtime local-read attestation.\\\", \\\"author\\\": {\\\"name\\\": \\\"RUMBO\\\"}, \\\"skills\\\": \\\"./skills/\\\", \\\"interface\\\": {\\\"displayName\\\": \\\"RUMBO GPT-Codex Continuity\\\", \\\"shortDescription\\\": \\\"Durable evidence-bound GPT↔Codex continuity.\\\", \\\"longDescription\\\": \\\"Canonical GPT-Codex Context Bridge V1.6 plus isolated real-runtime local-read attestation.\\\", \\\"developerName\\\": \\\"RUMBO\\\", \\\"category\\\": \\\"Productivity\\\", \\\"capabilities\\\": [], \\\"defaultPrompt\\\": \\\"Use the GPT-Codex continuity bridge and preserve fail-closed project state.\\\"}}'\\nSTATE=Path.home()/\\\".agents\\\"/\\\"rumbo\\\"/\\\"gpt-codex-continuity-v3\\\"\\nRECEIPT=STATE/\\\"runtime-acceptance-receipt-v3.json\\\"\\n\\ndef H(b:bytes)->str: return hashlib.sha256(b).hexdigest()\\ndef A(path:Path,b:bytes):\\n path.parent.mkdir(parents=True,exist_ok=True)\\n t=path.with_suffix(path.suffix+\\\".tmp\\\")\\n t.write_bytes(b); os.replace(t,path)\\n try: os.chmod(path,0o600)\\n except OSError: pass\\n\\ndef R(cmd,**kw):\\n return subprocess.run([str(x) for x in cmd],text=True,capture_output=True,**kw)\\n\\ndef C(method,path,body=None,token=None,ok=(200,)):\\n headers={\\\"User-Agent\\\":\\\"rumbo-codex-bootstrap-r9/5.0\\\"}\\n data=None if body is None else json.dumps(body,separators=(\\\",\\\",\\\":\\\")).encode()\\n if data is not None: headers[\\\"Content-Type\\\"]=\\\"application/json\\\"\\n if token: headers[\\\"Authorization\\\"]=\\\"Bearer \\\"+token\\n req=urllib.request.Request(BASE+path,data=data,headers=headers,method=method)\\n try:\\n with urllib.request.urlopen(req,timeout=30) as x: status,raw=x.status,x.read()\\n except urllib.error.HTTPError as e:\\n status,raw=e.code,e.read()\\n if status not in ok:\\n raise RuntimeError(f\\\"{path} HTTP {status}: {raw[:600].decode(errors='replace')}\\\")\\n return status,raw\\n\\ndef J(method,path,body=None,token=None,ok=(200,)):\\n s,b=C(method,path,body,token,ok)\\n return s,json.loads(b.decode())\\n\\ndef metadata_self_check():\\n _,m=J(\\\"GET\\\",\\\"/v1/bootstrap/codex-device/metadata\\\")\\n own=H(Path(__file__).read_bytes())\\n if m.get(\\\"implementation_revision\\\")!=\\\"R9-ISOLATED-AUTH-PROVENANCE\\\":\\n raise RuntimeError(\\\"unexpected relay revision\\\")\\n if m.get(\\\"schema\\\")!=\\\"rumbo-codex-device-bootstrap/v3\\\":\\n raise RuntimeError(\\\"unexpected metadata schema\\\")\\n if m.get(\\\"acceptance_lane\\\")!=LANE or m.get(\\\"challenge_message_id\\\")!=CID or m.get(\\\"challenge_message_sha256\\\")!=CSHA:\\n raise RuntimeError(\\\"acceptance metadata mismatch\\\")\\n if m.get(\\\"launcher_sha256\\\")!=own:\\n raise RuntimeError(\\\"bootstrap self-hash mismatch\\\")\\n if m.get(\\\"plugin_manifest_sha256\\\")!=MANIFEST_SHA or m.get(\\\"plugin_version\\\")!=VERSION:\\n raise RuntimeError(\\\"plugin metadata mismatch\\\")\\n if m.get(\\\"acceptance_not_after_utc\\\")!=DEADLINE:\\n raise RuntimeError(\\\"deadline metadata mismatch\\\")\\n\\ndef isolated_codex_env():\\n codex=shutil.which(\\\"codex\\\")\\n if not codex: raise RuntimeError(\\\"Codex CLI not found on PATH\\\")\\n original=Path(os.environ.get(\\\"CODEX_HOME\\\") or (Path.home()/\\\".codex\\\")).expanduser()\\n td=tempfile.TemporaryDirectory(prefix=\\\"rumbo-codex-home-r9-\\\")\\n iso=Path(td.name)\\n auth=original/\\\"auth.json\\\"\\n if not auth.is_file() or auth.is_symlink():\\n td.cleanup(); raise RuntimeError(\\\"isolated Codex auth unavailable: regular auth.json not found; no pairing started\\\")\\n size=auth.stat().st_size\\n if size<=0 or size>1024*1024:\\n td.cleanup(); raise RuntimeError(\\\"isolated Codex auth file size invalid; no pairing started\\\")\\n shutil.copy2(auth,iso/\\\"auth.json\\\")\\n try: os.chmod(iso/\\\"auth.json\\\",0o600)\\n except OSError: pass\\n env=os.environ.copy()\\n for k in list(env):\\n if k.startswith(\\\"CODEX_\\\") or k in (\\\"OPENAI_API_KEY\\\",\\\"OPENAI_BASE_URL\\\"):\\n env.pop(k,None)\\n env[\\\"CODEX_HOME\\\"]=str(iso)\\n unexpected=[x.name for x in iso.iterdir() if x.name!=\\\"auth.json\\\"]\\n if unexpected:\\n td.cleanup(); raise RuntimeError(\\\"isolated Codex home contamination: \\\"+\\\",\\\".join(unexpected))\\n gh=R([codex,\\\"--help\\\"],env=env,timeout=30)\\n eh=R([codex,\\\"exec\\\",\\\"--help\\\"],env=env,timeout=30)\\n gtxt=(gh.stdout or \\\"\\\")+(gh.stderr or \\\"\\\"); etxt=(eh.stdout or \\\"\\\")+(eh.stderr or \\\"\\\")\\n if gh.returncode or eh.returncode or \\\"--ask-for-approval\\\" not in gtxt or \\\"--sandbox\\\" not in gtxt:\\n td.cleanup(); raise RuntimeError(\\\"Codex global safety flags unavailable; no pairing started\\\")\\n for flag in (\\\"--ignore-user-config\\\",\\\"--ignore-rules\\\",\\\"--ephemeral\\\",\\\"--output-schema\\\",\\\"--output-last-message\\\"):\\n if flag not in etxt:\\n td.cleanup(); raise RuntimeError(\\\"Codex exec safety capability missing: \\\"+flag)\\n status=R([codex,\\\"login\\\",\\\"status\\\"],env=env,timeout=30)\\n if status.returncode:\\n td.cleanup()\\n raise RuntimeError(\\\"isolated Codex auth unavailable; no pairing started\\\")\\n return td,codex,env\\n\\ndef pair():\\n _,s=J(\\\"POST\\\",\\\"/v1/pair/codex/device/start\\\",{\\\"client_label\\\":f\\\"codex-r9:{platform.node()[:48]}\\\",\\\"bootstrap_script_sha256\\\":H(Path(__file__).read_bytes()),\\\"acceptance_lane\\\":LANE,\\\"challenge_message_id\\\":CID,\\\"challenge_message_sha256\\\":CSHA},ok=(201,))\\n print(\\\"\\\\nRUMBO DEVICE PAIRING R9\\\\nCódigo:\\\",s[\\\"user_code\\\"],\\\"\\\\nPegá ese código en el chat RUMBO/ChatGPT. No compartas device_code.\\\\n\\\")\\n end=time.time()+int(s.get(\\\"expires_in_seconds\\\",900))\\n while time.time()=calendar.timegm(time.strptime(DEADLINE,\\\"%Y-%m-%dT%H:%M:%SZ\\\")):\\n raise RuntimeError(\\\"challenge expired\\\")\\n for k,v in {\\n \\\"canonical_release\\\":RELEASE,\\n \\\"canonical_release_sha256\\\":RELEASE_SHA,\\n \\\"canonical_skill_sha256\\\":SKILL_SHA,\\n \\\"expected_plugin_name\\\":PLUGIN,\\n \\\"expected_plugin_version\\\":VERSION\\n }.items():\\n if p.get(k)!=v: raise RuntimeError(\\\"challenge binding mismatch: \\\"+k)\\n ex=p.get(\\\"required_codex_execution\\\") or {}\\n must={\\n \\\"mode\\\":\\\"codex exec\\\",\\\"ephemeral\\\":True,\\\"sandbox\\\":\\\"read-only\\\",\\\"ask_for_approval\\\":\\\"never\\\",\\n \\\"skip_git_repo_check\\\":True,\\\"dangerous_bypass_forbidden\\\":True,\\\"model_override_forbidden\\\":True,\\n \\\"isolated_codex_home\\\":True,\\\"ignore_user_config\\\":True,\\\"ignore_rules\\\":True,\\n \\\"user_config_inherited\\\":False,\\\"project_config_inherited\\\":False,\\\"global_agents_md_inherited\\\":False,\\n \\\"local_read_challenge_required\\\":True,\\\"hidden_local_nonce_not_in_prompt\\\":True,\\\"auth_source\\\":\\\"regular_auth_json_copy\\\"\\n }\\n if any(ex.get(k)!=v for k,v in must.items()): raise RuntimeError(\\\"execution contract mismatch\\\")\\n return ch\\n\\ndef workdir(token):\\n _,raw=C(\\\"GET\\\",\\\"/v1/bootstrap/skill\\\",token=token)\\n if H(raw)!=SKILL_SHA: raise RuntimeError(\\\"skill hash mismatch\\\")\\n td=tempfile.TemporaryDirectory(prefix=\\\"rumbo-codex-r9-work-\\\"); root=Path(td.name)\\n with zipfile.ZipFile(io.BytesIO(raw)) as z:\\n pre=\\\"gpt-codex-context-bridge/\\\"\\n for n in z.namelist():\\n if n.endswith(\\\"/\\\"): continue\\n if not n.startswith(pre): raise RuntimeError(\\\"unexpected skill layout\\\")\\n rel=Path(n[len(pre):])\\n if rel.is_absolute() or \\\"..\\\" in rel.parts: raise RuntimeError(\\\"unsafe skill path\\\")\\n d=root/\\\"skills\\\"/\\\"gpt-codex-context-bridge\\\"/rel\\n d.parent.mkdir(parents=True,exist_ok=True); d.write_bytes(z.read(n))\\n mp=root/\\\".codex-plugin\\\"/\\\"plugin.json\\\"\\n A(mp,(json.dumps(json.loads(MANIFEST),ensure_ascii=False,indent=2)+\\\"\\\\n\\\").encode())\\n if H(mp.read_bytes())!=MANIFEST_SHA: raise RuntimeError(\\\"manifest hash mismatch\\\")\\n skill_md=root/\\\"skills\\\"/\\\"gpt-codex-context-bridge\\\"/\\\"SKILL.md\\\"\\n if not skill_md.is_file(): raise RuntimeError(\\\"SKILL.md missing\\\")\\n skill_md_sha=H(skill_md.read_bytes())\\n probe=secrets.token_hex(32)\\n probe_path=root/\\\"RUNTIME_PROBE.txt\\\"\\n A(probe_path,(\\\"probe_nonce=\\\"+probe+\\\"\\\\n\\\").encode())\\n return td,root,probe,H(probe_path.read_bytes()),skill_md_sha\\n\\ndef codex_run(codex,env,root,ch,probe,probe_file_sha,skill_md_sha):\\n version=R([codex,\\\"--version\\\"],env=env,timeout=30)\\n if version.returncode: raise RuntimeError(\\\"codex --version failed\\\")\\n with tempfile.TemporaryDirectory(prefix=\\\"rumbo-codex-r9-out-\\\") as od:\\n od=Path(od); schema_path=od/\\\"schema.json\\\"; last_path=od/\\\"last.json\\\"\\n schema={\\n \\\"type\\\":\\\"object\\\",\\\"additionalProperties\\\":False,\\n \\\"required\\\":[\\\"task_completed\\\",\\\"challenge_nonce\\\",\\\"challenge_message_id\\\",\\\"challenge_message_sha256\\\",\\n \\\"canonical_release\\\",\\\"canonical_release_sha256\\\",\\\"canonical_skill_sha256\\\",\\n \\\"plugin_name\\\",\\\"plugin_version\\\",\\\"plugin_manifest_sha256\\\",\\\"skill_md_sha256\\\",\\n \\\"probe_nonce\\\",\\\"runtime_nonce\\\",\\\"production_go\\\",\\\"secrets_exposed\\\"],\\n \\\"properties\\\":{\\n \\\"task_completed\\\":{\\\"type\\\":\\\"boolean\\\"},\\\"challenge_nonce\\\":{\\\"type\\\":\\\"string\\\"},\\n \\\"challenge_message_id\\\":{\\\"type\\\":\\\"string\\\"},\\\"challenge_message_sha256\\\":{\\\"type\\\":\\\"string\\\"},\\n \\\"canonical_release\\\":{\\\"type\\\":\\\"string\\\"},\\\"canonical_release_sha256\\\":{\\\"type\\\":\\\"string\\\"},\\n \\\"canonical_skill_sha256\\\":{\\\"type\\\":\\\"string\\\"},\\\"plugin_name\\\":{\\\"type\\\":\\\"string\\\"},\\n \\\"plugin_version\\\":{\\\"type\\\":\\\"string\\\"},\\\"plugin_manifest_sha256\\\":{\\\"type\\\":\\\"string\\\",\\\"pattern\\\":\\\"^[0-9a-f]{64}$\\\"},\\n \\\"skill_md_sha256\\\":{\\\"type\\\":\\\"string\\\",\\\"pattern\\\":\\\"^[0-9a-f]{64}$\\\"},\\n \\\"probe_nonce\\\":{\\\"type\\\":\\\"string\\\",\\\"pattern\\\":\\\"^[0-9a-f]{64}$\\\"},\\n \\\"runtime_nonce\\\":{\\\"type\\\":\\\"string\\\",\\\"pattern\\\":\\\"^[0-9a-f]{64}$\\\"},\\n \\\"production_go\\\":{\\\"type\\\":\\\"boolean\\\"},\\\"secrets_exposed\\\":{\\\"type\\\":\\\"boolean\\\"}\\n }\\n }\\n schema_path.write_text(json.dumps(schema),encoding=\\\"utf-8\\\")\\n cp=ch[\\\"payload\\\"]\\n prompt=f\\\"\\\"\\\"REAL CODEX RUNTIME ACCEPTANCE V3 ONLY.\\nDo not modify files, use web search, call MCP tools, or expose auth/secrets.\\nUse a read-only LOCAL SHELL COMMAND that reads RUNTIME_PROBE.txt and computes SHA-256 for BOTH:\\n- .codex-plugin/plugin.json\\n- skills/gpt-codex-context-bridge/SKILL.md\\nThe command must print the probe_nonce from RUNTIME_PROBE.txt plus both computed hashes.\\nThe probe nonce and expected local file hashes are intentionally NOT present in this prompt.\\nGenerate a separate fresh random 32-byte runtime nonce as 64 lowercase hex.\\nReturn only JSON matching the supplied schema.\\nRequired server bindings:\\nchallenge_nonce={cp['challenge_nonce']}\\nchallenge_message_id={CID}\\nchallenge_message_sha256={CSHA}\\ncanonical_release={RELEASE}\\ncanonical_release_sha256={RELEASE_SHA}\\ncanonical_skill_sha256={SKILL_SHA}\\nproduction_go=false\\nsecrets_exposed=false\\ntask_completed=true\\nIf any local read, command, or hash fails, set task_completed=false.\\n\\\"\\\"\\\"\\n cmd=[\\n codex,\\\"--ask-for-approval\\\",\\\"never\\\",\\\"--sandbox\\\",\\\"read-only\\\",\\n \\\"exec\\\",\\\"--ignore-user-config\\\",\\\"--ignore-rules\\\",\\\"--skip-git-repo-check\\\",\\n \\\"--ephemeral\\\",\\\"--json\\\",\\\"--output-schema\\\",str(schema_path),\\n \\\"--output-last-message\\\",str(last_path),\\\"-C\\\",str(root),prompt\\n ]\\n p=R(cmd,cwd=root,env=env,timeout=360)\\n if p.returncode or not last_path.is_file():\\n raise RuntimeError(\\\"codex exec failed: \\\"+(p.stderr or p.stdout)[-2000:])\\n last=last_path.read_bytes(); o=json.loads(last.decode())\\n checks=[\\n o.get(\\\"task_completed\\\") is True,o.get(\\\"challenge_nonce\\\")==cp[\\\"challenge_nonce\\\"],\\n o.get(\\\"challenge_message_id\\\")==CID,o.get(\\\"challenge_message_sha256\\\")==CSHA,\\n o.get(\\\"canonical_release\\\")==RELEASE,o.get(\\\"canonical_release_sha256\\\")==RELEASE_SHA,\\n o.get(\\\"canonical_skill_sha256\\\")==SKILL_SHA,o.get(\\\"plugin_name\\\")==PLUGIN,\\n o.get(\\\"plugin_version\\\")==VERSION,o.get(\\\"plugin_manifest_sha256\\\")==MANIFEST_SHA,\\n o.get(\\\"skill_md_sha256\\\")==skill_md_sha,o.get(\\\"probe_nonce\\\")==probe,\\n bool(re.fullmatch(r\\\"[0-9a-f]{64}\\\",str(o.get(\\\"runtime_nonce\\\",\\\"\\\")))),\\n o.get(\\\"production_go\\\") is False,o.get(\\\"secrets_exposed\\\") is False\\n ]\\n if not all(checks): raise RuntimeError(\\\"Codex structured output/local proof binding failed\\\")\\n tid=None; probe_command_verified=False; prohibited_items_seen=False; command_count=0\\n for line in (p.stdout or \\\"\\\").splitlines():\\n try: e=json.loads(line)\\n except Exception: continue\\n if e.get(\\\"type\\\")==\\\"thread.started\\\" and isinstance(e.get(\\\"thread_id\\\"),str): tid=e[\\\"thread_id\\\"]\\n if e.get(\\\"type\\\")==\\\"item.completed\\\":\\n item=e.get(\\\"item\\\") or {}; it=item.get(\\\"type\\\")\\n if it in {\\\"file_change\\\",\\\"web_search\\\",\\\"mcp_tool_call\\\"}: prohibited_items_seen=True\\n if it==\\\"command_execution\\\":\\n command_count+=1\\n output=str(item.get(\\\"aggregated_output\\\") or item.get(\\\"output\\\") or \\\"\\\")\\n if item.get(\\\"exit_code\\\")==0 and item.get(\\\"status\\\")==\\\"completed\\\" and probe in output and MANIFEST_SHA in output and skill_md_sha in output:\\n probe_command_verified=True\\n if not probe_command_verified or prohibited_items_seen or command_count < 1:\\n raise RuntimeError(\\\"Codex command-execution proof failed\\\")\\n return {\\n \\\"codex_cli_version\\\":(version.stdout or version.stderr).strip()[:300],\\n \\\"codex_thread_id\\\":tid,\\\"codex_runtime_nonce\\\":o[\\\"runtime_nonce\\\"],\\n \\\"codex_local_read_challenge_sha256\\\":probe_file_sha,\\n \\\"codex_last_message_sha256\\\":H(last),\\n \\\"codex_exec_events_sha256\\\":H((p.stdout or \\\"\\\").encode()),\\n \\\"codex_tool_probe_verified\\\":True,\\\"codex_tool_probe_sha256\\\":H(probe.encode()),\\n \\\"codex_skill_md_sha256\\\":skill_md_sha,\\\"codex_command_execution_count\\\":command_count,\\n \\\"codex_prohibited_items_seen\\\":False,\\\"codex_exec_exit_code\\\":0,\\n \\\"codex_cli_contract_preflight\\\":True,\\\"codex_output_bindings_exact\\\":True,\\n \\\"codex_local_read_proof_exact\\\":True,\\n \\\"codex_execution\\\":{\\n \\\"mode\\\":\\\"codex exec\\\",\\\"ephemeral\\\":True,\\\"sandbox\\\":\\\"read-only\\\",\\\"ask_for_approval\\\":\\\"never\\\",\\n \\\"dangerous_bypass_used\\\":False,\\\"model_override_used\\\":False,\\\"skip_git_repo_check\\\":True,\\n \\\"isolated_codex_home\\\":True,\\\"user_config_inherited\\\":False,\\\"project_config_inherited\\\":False,\\n \\\"global_agents_md_inherited\\\":False,\\\"auth_source\\\":\\\"regular_auth_json_copy\\\",\\n \\\"ignore_user_config\\\":True,\\\"ignore_rules\\\":True\\n }\\n }\\n\\ndef main():\\n if sys.version_info<(3,11): raise SystemExit(\\\"Python 3.11+ required\\\")\\n metadata_self_check()\\n codex_home,codex,env=isolated_codex_env()\\n if \\\"--preflight-only\\\" in sys.argv[1:]:\\n print(json.dumps({\\\"preflight\\\":\\\"PASS\\\",\\\"isolated_codex_home\\\":True,\\\"ignore_user_config\\\":True,\\\"ignore_rules\\\":True,\\\"approval_policy\\\":\\\"never\\\",\\\"pairing_started\\\":False,\\\"production_go\\\":False}))\\n codex_home.cleanup(); return 0\\n try:\\n token,pairing=pair()\\n ch=challenge(token)\\n work_tmp,root,probe,probe_file_sha,skill_md_sha=workdir(token)\\n try:\\n runtime=codex_run(codex,env,root,ch,probe,probe_file_sha,skill_md_sha)\\n finally:\\n work_tmp.cleanup()\\n if pairing.get(\\\"confirmed\\\") is not True:\\n raise RuntimeError(\\\"scoped device token was not confirmed\\\")\\n rec={\\n \\\"schema\\\":\\\"rumbo.codex-real-runtime-receipt/v4\\\",\\n \\\"device_pairing_session_id\\\":pairing.get(\\\"device_pairing_session_id\\\"),\\n \\\"challenge_message_id\\\":CID,\\\"challenge_message_sha256\\\":CSHA,\\n \\\"challenge_nonce\\\":ch[\\\"payload\\\"][\\\"challenge_nonce\\\"],\\\"acceptance_not_after_utc\\\":DEADLINE,\\n \\\"canonical_release\\\":RELEASE,\\\"canonical_release_sha256\\\":RELEASE_SHA,\\\"canonical_skill_sha256\\\":SKILL_SHA,\\n \\\"plugin_name\\\":PLUGIN,\\\"plugin_version\\\":VERSION,\\\"local_plugin_manifest_sha256\\\":MANIFEST_SHA,\\n **runtime,\\n \\\"fail_closed_project_gates_preserved\\\":True,\\\"secrets_exposed\\\":False,\\\"production_go\\\":False,\\n \\\"bootstrap_script_sha256\\\":H(Path(__file__).read_bytes()),\\n \\\"created_at_utc\\\":time.strftime(\\\"%Y-%m-%dT%H:%M:%SZ\\\",time.gmtime())\\n }\\n A(RECEIPT,(json.dumps(rec,ensure_ascii=False,indent=2)+\\\"\\\\n\\\").encode())\\n receipt_sha=H(RECEIPT.read_bytes())\\n _,ack=J(\\\"POST\\\",\\\"/v1/acks\\\",{\\\"message_id\\\":CID,\\\"message_sha256\\\":CSHA},token)\\n if not ack.get(\\\"acked\\\"): raise RuntimeError(\\\"challenge ACK failed\\\")\\n payload={\\n \\\"kind\\\":\\\"runtime_acceptance_response_v4\\\",\\n \\\"device_pairing_session_id\\\":rec[\\\"device_pairing_session_id\\\"],\\n \\\"challenge_nonce\\\":rec[\\\"challenge_nonce\\\"],\\\"challenge_message_id\\\":CID,\\\"challenge_message_sha256\\\":CSHA,\\n \\\"canonical_release\\\":RELEASE,\\\"canonical_release_sha256\\\":RELEASE_SHA,\\\"canonical_skill_sha256\\\":SKILL_SHA,\\n \\\"plugin_name\\\":PLUGIN,\\\"plugin_version\\\":VERSION,\\\"local_plugin_manifest_sha256\\\":MANIFEST_SHA,\\n \\\"local_runtime_receipt_sha256\\\":receipt_sha,\\\"bootstrap_script_sha256\\\":rec[\\\"bootstrap_script_sha256\\\"],\\n **runtime,\\n \\\"runtime_claim\\\":\\\"ACTUAL_CODEX_CLI_EXEC_ISOLATED_READ_ONLY_LOCAL_READ_PROVEN\\\",\\n \\\"fail_closed_project_gates_preserved\\\":True,\\\"secrets_exposed\\\":False,\\\"production_go\\\":False\\n }\\n _,res=J(\\\"POST\\\",\\\"/v1/messages\\\",{\\n \\\"lane\\\":LANE,\\\"base_revision\\\":1,\\n \\\"request_id\\\":\\\"runtime-acceptance-v4-\\\"+CID.replace(\\\"-\\\",\\\"\\\"),\\n \\\"payload\\\":payload\\n },token,ok=(200,201))\\n _,rv=J(\\\"POST\\\",\\\"/v1/pair/codex/device/revoke\\\",{\\\"pairing_id\\\":pairing.get(\\\"device_pairing_session_id\\\")},token)\\n if not rv.get(\\\"revoked\\\"): raise RuntimeError(\\\"device token self-revoke failed\\\")\\n st,raw=C(\\\"GET\\\",\\\"/v1/state/\\\"+urllib.parse.quote(LANE),token=token,ok=(401,))\\n if json.loads(raw.decode()).get(\\\"error\\\")!=\\\"UNAUTHORIZED\\\": raise RuntimeError(\\\"revoked device token remained usable\\\")\\n print(\\\"\\\\nRUNTIME_ACCEPTANCE_V4_RESPONSE=PUBLISHED\\\")\\n print(\\\"response_message_id=\\\",res.get(\\\"id\\\"))\\n print(\\\"response_message_sha256=\\\",res.get(\\\"message_sha256\\\"))\\n print(\\\"local_runtime_receipt_sha256=\\\",receipt_sha)\\n print(\\\"DEVICE_TOKEN_SELF_REVOKE=PASS\\\")\\n print(\\\"NEXT_GATE=PENDING_CHATGPT_SEMANTIC_REVIEW_AND_ACK\\\")\\n finally:\\n codex_home.cleanup()\\n\\nif __name__==\\\"__main__\\\": raise SystemExit(main())\\n\";\n",[170],"07423cc7-4975-412c-b19f-99002319079d","r6_main_postmerge_selftest.ts","01a04be6-1b1e-7309-a927-26e7f06664a5",1,["D",1787979766563],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst base=\"https://sebas1--01a04afcc88b766f9e893c0c81cf30bc.web.val.run\";\nconst lane=\"CODEX_REAL_RUNTIME_ACCEPTANCE_V1\";\nconst gpt=Deno.env.get(\"GPT_TOKEN_V4\");\nconst admin=Deno.env.get(\"ADMIN_TOKEN_V4\");\nif(!gpt||!admin) throw new Error(\"R6_MAIN_REQUIRED_ENV_MISSING\");\nlet fixture=\"\";\n\nasync function j(method:string,path:string,body?:unknown,token?:string,ok=[200]){\n const r=await fetch(base+path,{method,headers:{\n ...(body!==undefined?{\"content-type\":\"application/json\"}:{}),\n ...(token?{authorization:\"Bearer \"+token}:{}),\n \"user-agent\":\"r6-main-postmerge-selftest/1\"\n },body:body===undefined?undefined:JSON.stringify(body),cache:\"no-store\"});\n const x=await r.json();\n if(!ok.includes(r.status)) throw new Error(path+\"_HTTP_\"+r.status+\"_\"+JSON.stringify(x));\n return {status:r.status,body:x};\n}\n\ntry {\n const health=await j(\"GET\",\"/health\");\n if(health.body.implementation_revision!==\"R6-DEVICE-BOOTSTRAP\"||health.body.production_go!==false) throw new Error(\"HEALTH_INVARIANT\");\n\n const meta=await j(\"GET\",\"/v1/bootstrap/codex-device/metadata\");\n if(meta.body.launcher_sha256!==\"5bd101b674bcc4cc6f6e842d285c486857cb73b20211c375706067eba71fbcd6\"||meta.body.launcher_bytes!==13466||meta.body.launcher_version!==\"1.3\") throw new Error(\"META_DRIFT\");\n\n const launcher=await fetch(base+\"/v1/bootstrap/codex-device.py\",{cache:\"no-store\"});\n const raw=new Uint8Array(await launcher.arrayBuffer());\n const d=await crypto.subtle.digest(\"SHA-256\",raw);\n const sha=[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n if(launcher.status!==200||raw.length!==13466||sha!==meta.body.launcher_sha256||launcher.headers.get(\"x-sha256\")!==sha) throw new Error(\"LAUNCHER_DRIFT\");\n\n const acc=await j(\"GET\",\"/v1/acceptance/\"+lane,undefined,gpt);\n if(acc.body.state!==\"PENDING_CODEX_ACK\"||acc.body.production_go!==false) throw new Error(\"ACCEPTANCE_DRIFT\");\n\n const state=await j(\"GET\",\"/v1/state/\"+lane,undefined,gpt);\n if(Number(state.body.state?.revision)!==1||state.body.state?.checkpoint_sha256!==\"d97d464ac817879c733f26249518faf3833a48c8e00a14d7ebed389af9a70962\") throw new Error(\"STATE_DRIFT\");\n\n const start=await j(\"POST\",\"/v1/pair/codex/device/start\",{client_label:\"r6-main-postmerge-selftest\"},undefined,[201]);\n fixture=String(start.body.pairing_id||\"\");\n if(!/^[A-Za-z0-9_-]{43}$/.test(String(start.body.device_code||\"\"))||!/^[A-Z2-9]{4}-[A-Z2-9]{4}$/.test(String(start.body.user_code||\"\"))) throw new Error(\"DEVICE_CODES_INVALID\");\n\n const pending=await j(\"POST\",\"/v1/pair/codex/device/poll\",{device_code:start.body.device_code},undefined,[202]);\n if(pending.body.authorized!==false||pending.body.status!==\"PENDING_APPROVAL\") throw new Error(\"PENDING_NOT_CLOSED\");\n\n const unauth=await fetch(base+\"/v1/pair/codex/device/approve\",{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:JSON.stringify({user_code:start.body.user_code})});\n if(unauth.status!==401) throw new Error(\"UNAUTH_APPROVE_\"+unauth.status);\n\n const approved=await j(\"POST\",\"/v1/pair/codex/device/approve\",{user_code:start.body.user_code},gpt,[200]);\n if(approved.body.approved!==true||approved.body.idempotent!==false||approved.body.production_go!==false) throw new Error(\"APPROVE_FAIL\");\n\n const replay=await j(\"POST\",\"/v1/pair/codex/device/approve\",{user_code:start.body.user_code},gpt,[200]);\n if(replay.body.idempotent!==true) throw new Error(\"APPROVE_REPLAY_FAIL\");\n\n const deviceRow=await sqlite.execute({sql:\"SELECT approved_at,approved_by,delivered_at FROM device_pairing_sessions WHERE pairing_id=?\",args:[fixture]});\n const dr:any=deviceRow.rows[0];\n if(!dr?.approved_at||dr.approved_by!==\"gpt\"||dr.delivered_at) throw new Error(\"DEVICE_DB_DRIFT\");\n\n const real=await sqlite.execute({sql:\"SELECT COUNT(*) AS n FROM pairing_sessions WHERE pairing_id='codex-v4'\"});\n if(Number((real.rows[0] as any)?.n ?? -1)!==0) throw new Error(\"REAL_CODEX_PAIRING_TOUCHED\");\n\n const audit=await j(\"GET\",\"/v1/audit\",undefined,admin);\n if(audit.body.audit_chain_ok!==true) throw new Error(\"AUDIT_CHAIN_FAIL\");\n\n console.log(JSON.stringify({\n selftest:\"PASS\",implementation_revision:health.body.implementation_revision,\n launcher_sha256:sha,launcher_bytes:raw.length,launcher_version:meta.body.launcher_version,\n device_start_http:201,pending_poll_http:202,unauth_approve_http:401,\n gpt_approve_http:200,approval_replay:\"IDEMPOTENT_PASS\",token_delivered:false,\n acceptance_state:acc.body.state,lane_revision:state.body.state.revision,\n checkpoint_sha256:state.body.state.checkpoint_sha256,audit_chain_ok:true,\n audit_event_count:audit.body.count,real_codex_pairing_touched:false,\n real_codex_runtime:\"NOT_PROVEN_BY_THIS_TEST\",production_go:false\n },null,2));\n} finally {\n if(fixture) await sqlite.execute({sql:\"DELETE FROM device_pairing_sessions WHERE pairing_id=?\",args:[fixture]});\n if(fixture){\n const left=await sqlite.execute({sql:\"SELECT COUNT(*) AS n FROM device_pairing_sessions WHERE pairing_id=?\",args:[fixture]});\n if(Number((left.rows[0] as any)?.n ?? -1)!==0) throw new Error(\"POSTMERGE_FIXTURE_CLEANUP_FAIL\");\n }\n}",[178],"796178ee-ee00-4282-9d06-941f14226412","r6_device_pairing_selftest.ts","01a04be6-1b1e-7309-a927-231a2df4d078",["D",1787979766563],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst base=\"https://sebas1--01a04b6c896271ba8fca9e6b08c7e987.web.val.run\";\nconst gpt=Deno.env.get(\"GPT_TOKEN_V4\");\nif(!gpt) throw new Error(\"GPT_TOKEN_V4_MISSING\");\nlet pairingId=\"\";\ntry {\n const start=await fetch(base+\"/v1/pair/codex/device/start\",{\n method:\"POST\",headers:{\"content-type\":\"application/json\",\"user-agent\":\"r6-device-selftest/1\"},\n body:JSON.stringify({client_label:\"r6-device-selftest\"})\n });\n const s=await start.json();\n if(start.status!==201) throw new Error(\"START_\"+start.status+\"_\"+JSON.stringify(s));\n pairingId=String(s.pairing_id||\"\");\n if(!/^[0-9a-f-]{36}$/.test(pairingId)) throw new Error(\"PAIRING_ID_INVALID\");\n if(!/^[A-Za-z0-9_-]{43}$/.test(String(s.device_code||\"\"))) throw new Error(\"DEVICE_CODE_INVALID\");\n if(!/^[A-Z2-9]{4}-[A-Z2-9]{4}$/.test(String(s.user_code||\"\"))) throw new Error(\"USER_CODE_INVALID\");\n if(s.production_go!==false) throw new Error(\"START_PRODUCTION_GO\");\n\n const pending=await fetch(base+\"/v1/pair/codex/device/poll\",{\n method:\"POST\",headers:{\"content-type\":\"application/json\"},\n body:JSON.stringify({device_code:s.device_code})\n });\n const p=await pending.json();\n if(pending.status!==202||p.status!==\"PENDING_APPROVAL\"||p.authorized!==false) {\n throw new Error(\"PENDING_FAIL_\"+pending.status+\"_\"+JSON.stringify(p));\n }\n\n const denied=await fetch(base+\"/v1/pair/codex/device/approve\",{\n method:\"POST\",headers:{\"content-type\":\"application/json\"},\n body:JSON.stringify({user_code:s.user_code})\n });\n if(denied.status!==401) throw new Error(\"UNAUTH_APPROVAL_EXPECTED_401_\"+denied.status);\n\n const before=await sqlite.execute({\n sql:\"SELECT approved_at,delivered_at FROM device_pairing_sessions WHERE pairing_id=?\",args:[pairingId]\n });\n if(!before.rows.length||(before.rows[0] as any).approved_at||(before.rows[0] as any).delivered_at) throw new Error(\"PREAPPROVAL_DB_DRIFT\");\n\n const approved=await fetch(base+\"/v1/pair/codex/device/approve\",{\n method:\"POST\",headers:{\"content-type\":\"application/json\",\"authorization\":\"Bearer \"+gpt},\n body:JSON.stringify({user_code:s.user_code})\n });\n const a=await approved.json();\n if(approved.status!==200||a.approved!==true||a.idempotent!==false||a.production_go!==false) {\n throw new Error(\"APPROVAL_FAIL_\"+approved.status+\"_\"+JSON.stringify(a));\n }\n\n const replay=await fetch(base+\"/v1/pair/codex/device/approve\",{\n method:\"POST\",headers:{\"content-type\":\"application/json\",\"authorization\":\"Bearer \"+gpt},\n body:JSON.stringify({user_code:s.user_code})\n });\n const ar=await replay.json();\n if(replay.status!==200||ar.approved!==true||ar.idempotent!==true) throw new Error(\"APPROVAL_REPLAY_FAIL\");\n\n const after=await sqlite.execute({\n sql:\"SELECT approved_at,approved_by,delivered_at FROM device_pairing_sessions WHERE pairing_id=?\",args:[pairingId]\n });\n const row:any=after.rows[0];\n if(!row?.approved_at||row.approved_by!==\"gpt\"||row.delivered_at) throw new Error(\"POSTAPPROVAL_DB_DRIFT\");\n\n const real=await sqlite.execute({sql:\"SELECT COUNT(*) AS n FROM pairing_sessions WHERE pairing_id='codex-v4'\"});\n if(Number((real.rows[0] as any)?.n||0)!==0) throw new Error(\"REAL_PAIRING_TOUCHED\");\n\n console.log(JSON.stringify({\n selftest:\"PASS\",\n start_http:201,\n pending_poll_http:202,\n unauth_approve_http:401,\n authenticated_approve_http:200,\n approval_replay:\"IDEMPOTENT_PASS\",\n approved_by:\"gpt\",\n token_delivered:false,\n real_codex_pairing_touched:false,\n production_go:false\n },null,2));\n} finally {\n if(pairingId) await sqlite.execute({sql:\"DELETE FROM device_pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n const left=pairingId?await sqlite.execute({sql:\"SELECT COUNT(*) AS n FROM device_pairing_sessions WHERE pairing_id=?\",args:[pairingId]}):null;\n if(left&&Number((left.rows[0] as any)?.n ?? -1)!==0) throw new Error(\"DEVICE_FIXTURE_CLEANUP_FAILED\");\n}",[185],"08668438-9c8f-4e87-867c-f3a7960361dc","r6_branch_regression.ts","01a04be6-1b1e-7309-a927-1d2b5d6533f5",["D",1787979766563],"const base=\"https://sebas1--01a04b6c896271ba8fca9e6b08c7e987.web.val.run\";\nconst lane=\"CODEX_REAL_RUNTIME_ACCEPTANCE_V1\";\nconst gpt=Deno.env.get(\"GPT_TOKEN_V4\");\nconst admin=Deno.env.get(\"ADMIN_TOKEN_V4\");\nif(!gpt||!admin) throw new Error(\"R6_REQUIRED_ENV_MISSING\");\n\nconst healthRes=await fetch(base+\"/health\",{cache:\"no-store\"});\nconst health=await healthRes.json();\nif(healthRes.status!==200||health.implementation_revision!==\"R6-DEVICE-BOOTSTRAP\") throw new Error(\"R6_HEALTH\");\nif(health.production_go!==false) throw new Error(\"R6_HEALTH_PRODUCTION_GO\");\n\nconst metaRes=await fetch(base+\"/v1/bootstrap/codex-device/metadata\",{cache:\"no-store\"});\nconst meta=await metaRes.json();\nif(metaRes.status!==200||meta.launcher_sha256!==\"5bd101b674bcc4cc6f6e842d285c486857cb73b20211c375706067eba71fbcd6\"||meta.launcher_bytes!==13466||meta.launcher_version!==\"1.3\") throw new Error(\"R6_METADATA\");\nif(meta.security_boundary?.embedded_credentials!==false||meta.security_boundary?.final_chatgpt_ack_required!==true) throw new Error(\"R6_METADATA_BOUNDARY\");\n\nconst accRes=await fetch(base+\"/v1/acceptance/\"+lane,{headers:{authorization:\"Bearer \"+gpt},cache:\"no-store\"});\nconst acc=await accRes.json();\nif(accRes.status!==200||acc.state!==\"PENDING_CODEX_ACK\") throw new Error(\"R6_ACCEPTANCE_\"+acc.state);\nif(acc.production_go!==false) throw new Error(\"R6_ACCEPTANCE_GO\");\n\nconst stateRes=await fetch(base+\"/v1/state/\"+lane,{headers:{authorization:\"Bearer \"+gpt},cache:\"no-store\"});\nconst state=await stateRes.json();\nif(stateRes.status!==200||Number(state.state?.revision)!==1) throw new Error(\"R6_STATE_REVISION\");\nif(state.state?.checkpoint_sha256!==\"d97d464ac817879c733f26249518faf3833a48c8e00a14d7ebed389af9a70962\") throw new Error(\"R6_STATE_CHECKPOINT\");\n\nconst auditRes=await fetch(base+\"/v1/audit\",{headers:{authorization:\"Bearer \"+admin},cache:\"no-store\"});\nconst audit=await auditRes.json();\nif(auditRes.status!==200||audit.audit_chain_ok!==true) throw new Error(\"R6_AUDIT\");\n\nconsole.log(JSON.stringify({\n selftest:\"PASS\",implementation_revision:health.implementation_revision,\n acceptance_state:acc.state,lane_revision:state.state.revision,\n checkpoint_sha256:state.state.checkpoint_sha256,audit_chain_ok:audit.audit_chain_ok,\n audit_event_count:audit.count,launcher_sha256:meta.launcher_sha256,\n launcher_bytes:meta.launcher_bytes,launcher_version:meta.launcher_version,embedded_credentials:false,\n final_chatgpt_ack_required:true,production_go:false,\n real_codex_runtime:\"NOT_PROVEN_BY_THIS_TEST\"\n},null,2));",[191],"a590be87-5ef4-477d-9cb3-b7bd0b0e86dd","r6_bootstrap_http_selftest.ts","01a04be6-1b1e-7309-a927-1bde10fbed7f",["D",1787979766563],"const url=\"https://sebas1--01a04b6c896271ba8fca9e6b08c7e987.web.val.run/v1/bootstrap/codex-device.py\";\nconst expectedSha=\"5bd101b674bcc4cc6f6e842d285c486857cb73b20211c375706067eba71fbcd6\";\nconst expectedBytes=13466;\nconst res=await fetch(url,{cache:\"no-store\"});\nconst raw=new Uint8Array(await res.arrayBuffer());\nconst d=await crypto.subtle.digest(\"SHA-256\",raw);\nconst sha=[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nif(res.status!==200) throw new Error(\"BOOTSTRAP_HTTP_\"+res.status);\nif(raw.length!==expectedBytes) throw new Error(\"BOOTSTRAP_SIZE_\"+raw.length);\nif(sha!==expectedSha) throw new Error(\"BOOTSTRAP_SHA_\"+sha);\nif(res.headers.get(\"x-sha256\")!==expectedSha) throw new Error(\"BOOTSTRAP_HEADER_SHA\");\nconst text=new TextDecoder().decode(raw);\nif(!text.startsWith(\"#!/usr/bin/env python3\")) throw new Error(\"BOOTSTRAP_SHEBANG\");\nif(!text.includes('User-Agent\":\"rumbo-codex-device-bootstrap/1.3')) throw new Error(\"BOOTSTRAP_VERSION_MARKER\");\nif(!text.includes(\"receipt_sha=h(RECEIPT.read_bytes())\")) throw new Error(\"EXACT_RECEIPT_HASH_MISSING\");\nif(!text.includes(\"def verify_existing_receipt():\")) throw new Error(\"RESUME_VERIFIER_MISSING\");\nif(!text.includes('\"challenge_nonce\":nonce')) throw new Error(\"NONCE_RECEIPT_BINDING_MISSING\");\nif(!text.includes(\"local receipt belongs to a different bootstrap script\")) throw new Error(\"SCRIPT_RECEIPT_BINDING_MISSING\");\nif(!text.includes('market_backup=BACKUPS/f\"marketplace-{stamp}.json\"')) throw new Error(\"PERSISTENT_MARKET_BACKUP_MISSING\");\nif(!text.includes('cache_backup=BACKUPS/f\"{PLUGIN}-cache-{stamp}\"')) throw new Error(\"CACHE_BACKUP_MISSING\");\nif(!text.includes(\"write(MARKET,market_before)\")) throw new Error(\"MARKETPLACE_ROLLBACK_MISSING\");\nif(!text.includes(\"shutil.move(str(cache_backup),str(cache))\")) throw new Error(\"CACHE_ROLLBACK_MISSING\");\nconsole.log(JSON.stringify({\n selftest:\"PASS\",status:res.status,bytes:raw.length,sha256:sha,\n header_sha256:res.headers.get(\"x-sha256\"),launcher_version:\"1.3\",\n exact_receipt_bytes_hash:true,resume_verification:true,nonce_receipt_binding:true,\n plugin_backup_rollback:true,marketplace_backup_rollback:true,cache_backup_rollback:true\n},null,2));",[197],"c0729552-b1f8-44a1-8f13-490cb488d47c","r5_pairing_selftest.ts","01a04be6-1b1e-7309-a927-14476343d65c",["D",1787979766563],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { classifyPairing } from \"./pairing_state.ts\";\n\nfunction assert(cond: unknown, message: string): asserts cond {\n if (!cond) throw new Error(message);\n}\n\nconst now = Date.now();\nassert(classifyPairing(null, now) === \"ISSUE_NEW\", \"null must issue\");\nassert(\n classifyPairing({expires_at:new Date(now+60000).toISOString(),confirmed_at:null}, now) === \"REDELIVER_ACTIVE\",\n \"active unconfirmed must redeliver\"\n);\nassert(\n classifyPairing({expires_at:new Date(now).toISOString(),confirmed_at:null}, now) === \"REISSUE_EXPIRED\",\n \"expiry boundary must reissue\"\n);\nassert(\n classifyPairing({expires_at:new Date(now-1).toISOString(),confirmed_at:null}, now) === \"REISSUE_EXPIRED\",\n \"expired must reissue\"\n);\nassert(\n classifyPairing({expires_at:new Date(now+60000).toISOString(),confirmed_at:new Date(now-1).toISOString()}, now) === \"ALREADY_CONFIRMED\",\n \"confirmed must stop\"\n);\nassert(\n classifyPairing({expires_at:\"not-a-date\",confirmed_at:null}, now) === \"INVALID_EXISTING_SESSION\",\n \"invalid expiry must fail closed\"\n);\n\nconst pairingId = \"r5-selftest-expired\";\nconst dummySha = \"a\".repeat(64);\nlet cleanupOk = false;\ntry {\n await sqlite.execute({sql:\"DELETE FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n const expiredIssued = new Date(now-120000).toISOString();\n const expiredAt = new Date(now-60000).toISOString();\n await sqlite.execute({\n sql:\"INSERT INTO pairing_sessions(pairing_id,pairing_code_sha256,issued_at,expires_at,confirmed_at,client_label) VALUES(?,?,?,?,NULL,?)\",\n args:[pairingId,dummySha,expiredIssued,expiredAt,\"r5-selftest\"]\n });\n\n const before = await sqlite.execute({sql:\"SELECT expires_at,confirmed_at FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n const beforeRow:any = before.rows[0];\n assert(classifyPairing({expires_at:String(beforeRow.expires_at),confirmed_at:null}, Date.now()) === \"REISSUE_EXPIRED\", \"fixture must be expired\");\n\n const issuedAt = new Date().toISOString();\n const expiresAt = new Date(Date.parse(issuedAt)+10*60*1000).toISOString();\n const reissued:any = await sqlite.execute({\n sql:\"UPDATE pairing_sessions SET pairing_code_sha256=?,issued_at=?,expires_at=?,confirmed_at=NULL,client_label=? WHERE pairing_id=? AND confirmed_at IS NULL AND expires_at<=?\",\n args:[dummySha,issuedAt,expiresAt,\"r5-selftest-reissued\",pairingId,issuedAt]\n });\n assert(Number(reissued?.rowsAffected ?? 0) === 1, \"expired row must reissue atomically\");\n\n const active = await sqlite.execute({sql:\"SELECT expires_at,confirmed_at FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n const activeRow:any = active.rows[0];\n assert(classifyPairing({expires_at:String(activeRow.expires_at),confirmed_at:null}, Date.now()) === \"REDELIVER_ACTIVE\", \"reissued row must be active\");\n\n const confirmedAt = new Date().toISOString();\n const confirmed:any = await sqlite.execute({\n sql:\"UPDATE pairing_sessions SET confirmed_at=? WHERE pairing_id=? AND confirmed_at IS NULL AND expires_at>?\",\n args:[confirmedAt,pairingId,confirmedAt]\n });\n assert(Number(confirmed?.rowsAffected ?? 0) === 1, \"active row must confirm atomically\");\n\n const after = await sqlite.execute({sql:\"SELECT expires_at,confirmed_at FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n const afterRow:any = after.rows[0];\n assert(!!afterRow.confirmed_at, \"confirmed_at must be durable\");\n assert(\n classifyPairing({expires_at:String(afterRow.expires_at),confirmed_at:String(afterRow.confirmed_at)}, Date.now()) === \"ALREADY_CONFIRMED\",\n \"confirmed row must classify confirmed\"\n );\n\n console.log(JSON.stringify({\n selftest:\"PASS\",\n pure_state_cases:6,\n sqlite_expiry_reissue:\"PASS\",\n sqlite_atomic_confirm:\"PASS\",\n production_pairing_touched:false\n }, null, 2));\n} finally {\n await sqlite.execute({sql:\"DELETE FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n const left = await sqlite.execute({sql:\"SELECT COUNT(*) AS n FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n cleanupOk = Number((left.rows[0] as any)?.n ?? -1) === 0;\n if (!cleanupOk) throw new Error(\"SELFTEST_FIXTURE_CLEANUP_FAILED\");\n}\n",[203],"d9e269ae-3ba6-4141-a571-5e80d3ce60eb","r5_branch_regression.ts","01a04be6-1b1e-7309-a927-13a23ad39375",["D",1787979766563],"const base = \"https://sebas1--01a04b6631be7019bc45cebfd3460391.web.val.run\";\nconst lane = \"CODEX_REAL_RUNTIME_ACCEPTANCE_V1\";\nconst gpt = Deno.env.get(\"GPT_TOKEN_V4\");\nconst admin = Deno.env.get(\"ADMIN_TOKEN_V4\");\nif (!gpt || !admin) throw new Error(\"R5_REQUIRED_ENV_MISSING\");\n\nconst healthRes = await fetch(base + \"/health\");\nconst health = await healthRes.json();\nif (healthRes.status !== 200 || health.implementation_revision !== \"R5-PAIRING-RECOVERY\") {\n throw new Error(\"R5_HEALTH_MISMATCH\");\n}\nif (health.production_go !== false) throw new Error(\"R5_PRODUCTION_GO_INVARIANT_BROKEN\");\n\nconst acceptanceRes = await fetch(`${base}/v1/acceptance/${lane}`, {\n headers:{Authorization:`Bearer ${gpt}`}\n});\nconst acceptance = await acceptanceRes.json();\nif (acceptanceRes.status !== 200) throw new Error(\"R5_ACCEPTANCE_UNREADABLE\");\nif (acceptance.state !== \"PENDING_CODEX_ACK\") throw new Error(`R5_ACCEPTANCE_DRIFT_${acceptance.state}`);\nif (acceptance.production_go !== false) throw new Error(\"R5_ACCEPTANCE_PRODUCTION_GO\");\n\nconst stateRes = await fetch(`${base}/v1/state/${lane}`, {\n headers:{Authorization:`Bearer ${gpt}`}\n});\nconst state = await stateRes.json();\nif (stateRes.status !== 200 || Number(state.state?.revision) !== 1) throw new Error(\"R5_LANE_REVISION_DRIFT\");\nif (state.state?.checkpoint_sha256 !== \"d97d464ac817879c733f26249518faf3833a48c8e00a14d7ebed389af9a70962\") {\n throw new Error(\"R5_LANE_CHECKPOINT_DRIFT\");\n}\n\nconst auditRes = await fetch(base + \"/v1/audit\", {\n headers:{Authorization:`Bearer ${admin}`}\n});\nconst audit = await auditRes.json();\nif (auditRes.status !== 200 || audit.audit_chain_ok !== true) throw new Error(\"R5_AUDIT_CHAIN_FAIL\");\n\nconsole.log(JSON.stringify({\n selftest:\"PASS\",\n implementation_revision:health.implementation_revision,\n acceptance_state:acceptance.state,\n lane_revision:state.state.revision,\n checkpoint_sha256:state.state.checkpoint_sha256,\n audit_chain_ok:audit.audit_chain_ok,\n audit_event_count:audit.count,\n production_go:false,\n real_codex_runtime:\"NOT_PROVEN_BY_THIS_TEST\"\n},null,2));",[209],"5661a4ae-861d-4d58-a543-49856676641e","pairing_state.ts","01a04be6-1b1e-7309-a927-0f79e79f6a6b",["D",1787979766563],"export type PairingSnapshot = {\n expires_at: string | null;\n confirmed_at: string | null;\n} | null;\n\nexport type PairingDecision =\n | \"ISSUE_NEW\"\n | \"REDELIVER_ACTIVE\"\n | \"REISSUE_EXPIRED\"\n | \"ALREADY_CONFIRMED\"\n | \"INVALID_EXISTING_SESSION\";\n\nexport function classifyPairing(\n existing: PairingSnapshot,\n nowMs: number,\n): PairingDecision {\n if (!Number.isFinite(nowMs)) return \"INVALID_EXISTING_SESSION\";\n if (!existing) return \"ISSUE_NEW\";\n if (existing.confirmed_at) return \"ALREADY_CONFIRMED\";\n if (!existing.expires_at) return \"INVALID_EXISTING_SESSION\";\n const expiresMs = Date.parse(existing.expires_at);\n if (!Number.isFinite(expiresMs)) return \"INVALID_EXISTING_SESSION\";\n return expiresMs <= nowMs ? \"REISSUE_EXPIRED\" : \"REDELIVER_ACTIVE\";\n}\n",[215],"92821ac3-12fe-48fa-9d4f-233a0e3b594e","main.tsx","01a04be6-1b1e-7309-a927-0b8b6ef9cc89",34,["D",1787980891907],16,"http","import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { classifyPairing } from \"./pairing_state.ts\";\nimport { R9_BOOTSTRAP_PY } from \"./r9_bootstrap_module.ts\";\n\nconst app = new Hono();\nconst LANE_RE = /^[A-Z0-9][A-Z0-9_.:-]{0,95}$/;\nconst MAX_BODY = 256 * 1024;\nconst secretKeyRe = /(password|api[_-]?key|secret|access[_-]?token|refresh[_-]?token|private[_-]?key|authorization|session[_-]?cookie)/i;\nconst tokenPrefixRe = /(sk-[A-Za-z0-9_-]{16,}|gh[pousr]_[A-Za-z0-9_]{20,}|glpat-[A-Za-z0-9_-]{12,}|xox[baprs]-[A-Za-z0-9-]{10,})/;\nconst SHA256_RE = /^[a-f0-9]{64}$/;\nconst R2_TARGET_REPOSITORY_IDENTITY_SHA256 = \"59e28afe0dd67d61cdaaaa5d470a6470b6c1540f025d172f094fe3321857fc23\";\nconst R2_CONTROL_PACKAGE_SHA256 = \"afbdc77510286adc5721ada5a0ddfa75e10305cb5200d6fd37cd8438c9c6119f\";\nconst R2_GUARD_MAX_TTL_SECONDS = 900;\nconst DEVICE_PAIRING_TTL_MS = 15 * 60 * 1000;\nconst DEVICE_PAIRING_MAX_PENDING_PER_FINGERPRINT = 3;\nconst DEVICE_PAIRING_MAX_PENDING_GLOBAL = 100;\nconst DEVICE_ACCESS_TOKEN_TTL_MS = 60 * 60 * 1000;\nconst DEVICE_ACCESS_LANE = \"CODEX_REAL_RUNTIME_ACCEPTANCE_V4\";\nconst R9_BOOTSTRAP_SHA256 = \"2feb17809757ddf6d9fb192f9d4385d8e7a21d92182e1a4dd228c2fe94c4db37\";\nconst R9_BOOTSTRAP_BYTES = 20490;\nconst R9_CHALLENGE_ID = \"5abe8d3e-d35f-411f-b1c7-a8f4dc3e4b89\";\nconst R9_CHALLENGE_SHA256 = \"d7fe64c4a5b4e3d27ef3c9e636610a2a67812c9b7234dccb86a1061f17b8ab50\";\nconst R9_ACCEPTANCE_NOT_AFTER_UTC = \"2026-08-31T03:15:00Z\";\nconst R9_PLUGIN_VERSION = \"1.2.0\";\nconst R9_PLUGIN_MANIFEST_SHA256 = \"c0f12562dbee00f897b7f0d164b35845f7388ec996c19b371c0ccf6e0fb12d27\";\nconst DEVICE_USER_CODE_ALPHABET = \"ABCDEFGHJKLMNPQRSTUVWXYZ23456789\";\n\nasync function init() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS lane_state (\n lane TEXT PRIMARY KEY,\n revision INTEGER NOT NULL DEFAULT 0,\n checkpoint_sha256 TEXT NOT NULL DEFAULT '',\n updated_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS messages (\n id TEXT PRIMARY KEY,\n actor TEXT NOT NULL CHECK(actor IN ('gpt','codex')),\n recipient TEXT NOT NULL CHECK(recipient IN ('gpt','codex')),\n lane TEXT NOT NULL,\n base_revision INTEGER NOT NULL,\n revision INTEGER NOT NULL,\n payload_json TEXT NOT NULL,\n payload_sha256 TEXT NOT NULL,\n message_sha256 TEXT NOT NULL UNIQUE,\n created_at TEXT NOT NULL,\n acked_at TEXT\n )`,\n `CREATE INDEX IF NOT EXISTS idx_messages_inbox ON messages(recipient,lane,acked_at,revision)`,\n `CREATE TABLE IF NOT EXISTS acknowledgements (\n id TEXT PRIMARY KEY,\n actor TEXT NOT NULL CHECK(actor IN ('gpt','codex')),\n target_message_id TEXT NOT NULL UNIQUE,\n target_message_sha256 TEXT NOT NULL,\n created_at TEXT NOT NULL,\n FOREIGN KEY(target_message_id) REFERENCES messages(id)\n )`,\n `CREATE TABLE IF NOT EXISTS message_auth_provenance (\n message_id TEXT PRIMARY KEY,\n auth_kind TEXT NOT NULL CHECK(auth_kind IN ('device')),\n pairing_id TEXT NOT NULL,\n token_sha256 TEXT NOT NULL,\n created_at TEXT NOT NULL,\n FOREIGN KEY(message_id) REFERENCES messages(id),\n FOREIGN KEY(pairing_id) REFERENCES device_pairing_sessions(pairing_id)\n )`,\n `CREATE INDEX IF NOT EXISTS idx_message_auth_pairing ON message_auth_provenance(pairing_id,message_id)`,\n `CREATE TABLE IF NOT EXISTS ack_auth_provenance (\n target_message_id TEXT PRIMARY KEY,\n acknowledgement_id TEXT NOT NULL UNIQUE,\n auth_kind TEXT NOT NULL CHECK(auth_kind IN ('device')),\n pairing_id TEXT NOT NULL,\n token_sha256 TEXT NOT NULL,\n created_at TEXT NOT NULL,\n FOREIGN KEY(target_message_id) REFERENCES messages(id),\n FOREIGN KEY(acknowledgement_id) REFERENCES acknowledgements(id),\n FOREIGN KEY(pairing_id) REFERENCES device_pairing_sessions(pairing_id)\n )`,\n `CREATE INDEX IF NOT EXISTS idx_ack_auth_pairing ON ack_auth_provenance(pairing_id,target_message_id)`,\n `CREATE TABLE IF NOT EXISTS audit_events (\n seq INTEGER PRIMARY KEY AUTOINCREMENT,\n event_type TEXT NOT NULL,\n actor TEXT NOT NULL,\n lane TEXT,\n object_id TEXT,\n object_sha256 TEXT,\n prev_event_sha256 TEXT NOT NULL,\n event_sha256 TEXT NOT NULL UNIQUE,\n created_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS pairing_events (\n pairing_id TEXT PRIMARY KEY,\n pairing_code_sha256 TEXT NOT NULL,\n consumed_at TEXT NOT NULL,\n client_label TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS pairing_sessions (\n pairing_id TEXT PRIMARY KEY,\n pairing_code_sha256 TEXT NOT NULL,\n issued_at TEXT NOT NULL,\n expires_at TEXT NOT NULL,\n confirmed_at TEXT,\n client_label TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS device_pairing_sessions (\n pairing_id TEXT PRIMARY KEY,\n device_code_sha256 TEXT NOT NULL UNIQUE,\n user_code_sha256 TEXT NOT NULL UNIQUE,\n client_fingerprint_sha256 TEXT NOT NULL,\n client_label TEXT,\n issued_at TEXT NOT NULL,\n expires_at TEXT NOT NULL,\n approved_at TEXT,\n approved_by TEXT,\n delivered_at TEXT\n )`,\n `CREATE INDEX IF NOT EXISTS idx_device_pairing_pending ON device_pairing_sessions(client_fingerprint_sha256,expires_at,approved_at)`,\n `CREATE TABLE IF NOT EXISTS device_pairing_contracts (\\n pairing_id TEXT PRIMARY KEY,\\n bootstrap_script_sha256 TEXT NOT NULL,\\n acceptance_lane TEXT NOT NULL,\\n challenge_message_id TEXT NOT NULL,\\n challenge_message_sha256 TEXT NOT NULL,\\n created_at TEXT NOT NULL,\\n FOREIGN KEY(pairing_id) REFERENCES device_pairing_sessions(pairing_id)\\n )`,\n `CREATE TABLE IF NOT EXISTS device_access_tokens (\\n token_sha256 TEXT PRIMARY KEY,\\n pairing_id TEXT NOT NULL UNIQUE,\\n lane_scope TEXT NOT NULL,\\n issued_at TEXT NOT NULL,\\n expires_at TEXT NOT NULL,\\n revoked_at TEXT,\\n FOREIGN KEY(pairing_id) REFERENCES device_pairing_sessions(pairing_id)\\n )`,\n `CREATE INDEX IF NOT EXISTS idx_device_access_active ON device_access_tokens(expires_at,revoked_at,lane_scope)`,\n `CREATE TABLE IF NOT EXISTS request_dedup (\n actor TEXT NOT NULL,\n request_id TEXT NOT NULL,\n body_sha256 TEXT NOT NULL,\n message_id TEXT NOT NULL,\n created_at TEXT NOT NULL,\n PRIMARY KEY(actor,request_id),\n FOREIGN KEY(message_id) REFERENCES messages(id)\n )`,\n `CREATE TABLE IF NOT EXISTS guard_authorizations (\n authorization_id TEXT PRIMARY KEY,\n action TEXT NOT NULL CHECK(action IN ('TEST_ONLY','MERGE_PR')),\n repository_identity_sha256 TEXT NOT NULL,\n pr_number INTEGER NOT NULL,\n base_sha TEXT NOT NULL,\n head_sha TEXT NOT NULL,\n package_sha256 TEXT NOT NULL,\n evidence_sha256 TEXT NOT NULL,\n request_sha256 TEXT NOT NULL UNIQUE,\n token_sha256 TEXT NOT NULL UNIQUE,\n status TEXT NOT NULL CHECK(status IN ('ISSUED','CONSUMED','REVOKED','EXPIRED')),\n issued_at TEXT NOT NULL,\n expires_at TEXT NOT NULL,\n consumed_at TEXT,\n consumer TEXT\n )`,\n `CREATE INDEX IF NOT EXISTS idx_guard_status ON guard_authorizations(status,expires_at)`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_audit_prev_unique ON audit_events(prev_event_sha256)`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_audit_message_accepted_unique ON audit_events(object_id) WHERE event_type='MESSAGE_ACCEPTED'`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_audit_message_acked_unique ON audit_events(object_id) WHERE event_type='MESSAGE_ACKED'`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_audit_guard_event_unique ON audit_events(event_type,object_id) WHERE event_type LIKE 'GUARD_%'`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_audit_device_event_unique ON audit_events(event_type,object_id) WHERE event_type LIKE 'CODEX_DEVICE_%'`,\n `CREATE TRIGGER IF NOT EXISTS messages_revision_guard\n BEFORE INSERT ON messages\n BEGIN\n SELECT CASE\n WHEN COALESCE((SELECT revision FROM lane_state WHERE lane=NEW.lane), -1) != NEW.base_revision\n THEN RAISE(ABORT, 'STALE_REVISION')\n END;\n END`,\n `CREATE TRIGGER IF NOT EXISTS messages_revision_advance\n AFTER INSERT ON messages\n BEGIN\n UPDATE lane_state\n SET revision=NEW.revision, updated_at=NEW.created_at\n WHERE lane=NEW.lane AND revision=NEW.base_revision;\n END`\n ]);\n}\n\nfunction bearer(req: Request): string {\n const h = req.headers.get(\"authorization\") || \"\";\n return h.startsWith(\"Bearer \") ? h.slice(7) : \"\";\n}\n\ntype AuthContext = { role:\"gpt\"|\"codex\"|\"admin\"; kind:\"environment\"|\"device\"; lane_scope?:string; pairing_id?:string; token_sha256?:string; };\n\nasync function authFrom(req: Request): Promise {\n const token = bearer(req);\n if (!token) return null;\n const gpt = Deno.env.get(\"GPT_TOKEN_V4\") || \"\";\n const admin = Deno.env.get(\"ADMIN_TOKEN_V4\") || \"\";\n if (gpt && constantTimeEqual(token,gpt)) return {role:\"gpt\",kind:\"environment\"};\n if (admin && constantTimeEqual(token,admin)) return {role:\"admin\",kind:\"environment\"};\n const tokenSha = await sha(token);\n const nowIso = new Date().toISOString();\n const rs = await sqlite.execute({sql:\"SELECT pairing_id,lane_scope,expires_at,revoked_at FROM device_access_tokens WHERE token_sha256=? LIMIT 1\",args:[tokenSha]});\n if (!rs.rows.length) return null;\n const row:any = rs.rows[0];\n if (row.revoked_at || String(row.expires_at) <= nowIso) return null;\n return {role:\"codex\",kind:\"device\",lane_scope:String(row.lane_scope),pairing_id:String(row.pairing_id),token_sha256:tokenSha};\n}\n\nasync function roleFrom(req: Request): Promise<\"gpt\"|\"codex\"|\"admin\"|null> {\n return (await authFrom(req))?.role || null;\n}\n\nfunction laneAuthorized(auth: AuthContext, lane: string): boolean {\n return auth.kind !== \"device\" || auth.lane_scope === lane;\n}\n\nfunction constantTimeEqual(a: string, b: string): boolean {\n const aa = new TextEncoder().encode(a);\n const bb = new TextEncoder().encode(b);\n if (aa.length !== bb.length) return false;\n let diff = 0;\n for (let i = 0; i < aa.length; i++) diff |= aa[i] ^ bb[i];\n return diff === 0;\n}\n\nfunction guardAuthorized(req: Request): boolean {\n const expected = Deno.env.get(\"R2_GUARD_TOKEN_V1\") || \"\";\n const observed = bearer(req);\n return !!expected && !!observed && constantTimeEqual(expected, observed);\n}\n\nfunction validGitSha(v: unknown): boolean {\n return typeof v === \"string\" && /^[a-f0-9]{40}$/.test(v);\n}\n\nfunction validSha256(v: unknown): v is string {\n return typeof v === \"string\" && SHA256_RE.test(v);\n}\n\nfunction randomOneTimeToken(bytes = 32): string {\n const raw = new Uint8Array(bytes);\n crypto.getRandomValues(raw);\n const binary = Array.from(raw, b => String.fromCharCode(b)).join(\"\");\n return btoa(binary).replaceAll(\"+\", \"-\").replaceAll(\"/\", \"_\").replace(/=+$/g, \"\");\n}\n\nasync function deriveDeviceAccessToken(pairingId:string, deviceSha:string): Promise {\n const master = Deno.env.get(\"CODEX_DEVICE_TOKEN_MASTER_V1\") || \"\";\n if (!master) throw new Error(\"DEVICE_TOKEN_MASTER_NOT_CONFIGURED\");\n const enc = new TextEncoder();\n const key = await crypto.subtle.importKey(\"raw\",enc.encode(master),{name:\"HMAC\",hash:\"SHA-256\"},false,[\"sign\"]);\n const sig = await crypto.subtle.sign(\"HMAC\",key,enc.encode(\"rumbo-codex-device-token/v1|\"+pairingId+\"|\"+deviceSha));\n const binary = Array.from(new Uint8Array(sig), b => String.fromCharCode(b)).join(\"\");\n return \"cdxdev_\" + btoa(binary).replaceAll(\"+\",\"-\").replaceAll(\"/\",\"_\").replace(/=+$/g,\"\");\n}\n\nfunction randomUserCode(chars = 8): string {\n let out = \"\";\n while (out.length < chars) {\n const raw = new Uint8Array(16);\n crypto.getRandomValues(raw);\n for (const n of raw) {\n const limit = 256 - (256 % DEVICE_USER_CODE_ALPHABET.length);\n if (n >= limit) continue;\n out += DEVICE_USER_CODE_ALPHABET[n % DEVICE_USER_CODE_ALPHABET.length];\n if (out.length === chars) break;\n }\n }\n return out;\n}\n\nfunction normalizeUserCode(v: unknown): string {\n return String(v || \"\").toUpperCase().replace(/[^A-Z0-9]/g, \"\");\n}\n\ntype GuardAction = \"TEST_ONLY\" | \"MERGE_PR\";\ntype GuardBinding = {\n action: GuardAction;\n repository_identity_sha256: string;\n pr_number: number;\n base_sha: string;\n head_sha: string;\n package_sha256: string;\n evidence_sha256: string;\n};\n\nfunction parseGuardBinding(b: any): GuardBinding | null {\n const action = String(b?.action || \"\") as GuardAction;\n const repository_identity_sha256 = String(b?.repository_identity_sha256 || \"\");\n const pr_number = Number(b?.pr_number);\n const base_sha = String(b?.base_sha || \"\");\n const head_sha = String(b?.head_sha || \"\");\n const package_sha256 = String(b?.package_sha256 || \"\");\n const evidence_sha256 = String(b?.evidence_sha256 || \"\");\n if (action !== \"TEST_ONLY\" && action !== \"MERGE_PR\") return null;\n if (repository_identity_sha256 !== R2_TARGET_REPOSITORY_IDENTITY_SHA256) return null;\n if (!Number.isSafeInteger(pr_number) || pr_number <= 0) return null;\n if (!validGitSha(base_sha) || !validGitSha(head_sha)) return null;\n if (package_sha256 !== R2_CONTROL_PACKAGE_SHA256) return null;\n if (!validSha256(evidence_sha256)) return null;\n return {action,repository_identity_sha256,pr_number,base_sha,head_sha,package_sha256,evidence_sha256};\n}\n\nfunction canonical(v: unknown): string {\n if (v === null || typeof v !== \"object\") return JSON.stringify(v);\n if (Array.isArray(v)) return \"[\" + v.map(canonical).join(\",\") + \"]\";\n const o = v as Record;\n return \"{\" + Object.keys(o).sort().map(k => JSON.stringify(k)+\":\"+canonical(o[k])).join(\",\") + \"}\";\n}\nasync function sha(s: string): Promise {\n const b = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(s));\n return [...new Uint8Array(b)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nfunction hasSecret(v: unknown): boolean {\n if (typeof v === \"string\") return tokenPrefixRe.test(v);\n if (Array.isArray(v)) return v.some(hasSecret);\n if (v && typeof v === \"object\") {\n return Object.entries(v as Record).some(([k,x]) => {\n if (k === \"secrets_exposed\" && x === false) return false;\n return secretKeyRe.test(k) || hasSecret(x);\n });\n }\n return false;\n}\nasync function bodyJson(c: any) {\n const len = Number(c.req.header(\"content-length\") || \"0\");\n if (len > MAX_BODY) throw new Error(\"PAYLOAD_TOO_LARGE\");\n const txt = await c.req.text();\n if (new TextEncoder().encode(txt).length > MAX_BODY) throw new Error(\"PAYLOAD_TOO_LARGE\");\n return JSON.parse(txt || \"{}\");\n}\nasync function audit(event_type:string, actor:string, lane:string|null, object_id:string|null, object_sha256:string|null) {\n const idempotentEvent = event_type === \"MESSAGE_ACCEPTED\" || event_type === \"MESSAGE_ACKED\" || event_type.startsWith(\"GUARD_\") || event_type.startsWith(\"CODEX_DEVICE_\");\n if (idempotentEvent && object_id) {\n const existing = await sqlite.execute({sql:\"SELECT event_sha256 FROM audit_events WHERE event_type=? AND object_id=? LIMIT 1\",args:[event_type,object_id]});\n if (existing.rows.length) return String(existing.rows[0].event_sha256);\n }\n for (let attempt=0; attempt<8; attempt++) {\n const last = await sqlite.execute(\"SELECT event_sha256 FROM audit_events ORDER BY seq DESC LIMIT 1\");\n const prev = String(last.rows[0]?.event_sha256 || \"0\".repeat(64));\n const created_at = new Date().toISOString();\n const ev = {event_type,actor,lane,object_id,object_sha256,prev_event_sha256:prev,created_at};\n const event_sha256 = await sha(canonical(ev));\n try {\n await sqlite.execute({sql:`INSERT INTO audit_events(event_type,actor,lane,object_id,object_sha256,prev_event_sha256,event_sha256,created_at)\n VALUES(?,?,?,?,?,?,?,?)`,args:[event_type,actor,lane,object_id,object_sha256,prev,event_sha256,created_at]});\n return event_sha256;\n } catch (e) {\n if (idempotentEvent && object_id) {\n const existing = await sqlite.execute({sql:\"SELECT event_sha256 FROM audit_events WHERE event_type=? AND object_id=? LIMIT 1\",args:[event_type,object_id]});\n if (existing.rows.length) return String(existing.rows[0].event_sha256);\n }\n if (!String(e).includes(\"UNIQUE\")) throw e;\n }\n }\n throw new Error(\"AUDIT_APPEND_CONTENTION\");\n}\n\nawait init();\n\napp.get(\"/\", (c) => c.json({service:\"rumbo-continuity-relay\",protocol:\"rumbo-continuity-relay/v1\",implementation_revision:\"R9-ISOLATED-AUTH-PROVENANCE\",status:\"ok\",production_go:false}));\napp.get(\"/health\", (c) => c.json({\n ok:true,\n protocol:\"rumbo-continuity-relay/v1\",\n implementation_revision:\"R9-ISOLATED-AUTH-PROVENANCE\",\n capabilities:[\n \"atomic-stale-guard\",\"request-idempotency\",\"idempotent-ack\",\"audit-chain\",\n \"device-code-pairing\",\"device-pairing-expiry\",\"device-pairing-rate-limit\",\"preapproval-pairing-inspection\",\"approval-exact-pairing-id-binding\",\n \"scoped-per-device-bearer\",\"authenticated-device-provenance-binding\",\"device-idempotency-provenance-binding\",\"device-ack-provenance-binding\",\"idempotent-audit-recovery\",\"device-token-self-revoke\",\"stable-token-redelivery-expiry\",\"acked-challenge-resume\",\"bounded-response-network-retry\",\"expired-token-crash-recovery\",\"device-message-kind-restriction\",\"device-base-revision-restriction\",\"device-inbox-disabled\",\"device-ack-target-restriction\",\"legacy-static-pairing-deprecated\",\"legacy-shared-codex-bearer-revoked\",\"secretless-public-bootstrap\",\"canonical-plugin-reconstruction\",\"canonical-v1.6-skill-bootstrap\",\n \"codex-runtime-acceptance-verifier\",\"server-enforced-acceptance-deadline\",\"actual-codex-exec-evidence\",\n \"codex-local-random-file-probe\",\"completed-command-execution-evidence\",\"prohibited-item-event-rejection\",\n \"exact-bootstrap-hash-binding\",\"isolated-codex-home-attestation\",\"ignore-user-config-enforcement\",\"ignore-rules-enforcement\",\"approval-never-enforcement\",\"pairing-contract-binding\",\"regular-auth-json-isolation\",\"v1-v2-v3-superseded-v4-active\",\n \"external-r2-authorizer\",\"one-time-token-ledger\",\"exact-pr-binding\",\"fail-closed-merge-gate\"\n ],\n guard:{\n configured:!!Deno.env.get(\"R2_GUARD_TOKEN_V1\"),\n merge_authorization_enabled:Deno.env.get(\"R2_ALLOW_MERGE_AUTHORIZATION\") === \"true\",\n max_ttl_seconds:R2_GUARD_MAX_TTL_SECONDS\n },\n production_go:false\n}));\n\napp.get(\"/v1/state/:lane\", async (c) => {\n const auth = await authFrom(c.req.raw); if (!auth) return c.json({error:\"UNAUTHORIZED\"},401);\n const lane = c.req.param(\"lane\"); if (!LANE_RE.test(lane)) return c.json({error:\"INVALID_LANE\"},400);\n if (!laneAuthorized(auth,lane)) return c.json({error:\"DEVICE_TOKEN_SCOPE_VIOLATION\"},403);\n const st = await sqlite.execute({sql:\"SELECT lane,revision,checkpoint_sha256,updated_at FROM lane_state WHERE lane=?\",args:[lane]});\n const row = st.rows[0] || {lane,revision:0,checkpoint_sha256:\"0\".repeat(64),updated_at:null};\n const pending = await sqlite.execute({sql:\"SELECT recipient,COUNT(*) AS n FROM messages WHERE lane=? AND acked_at IS NULL GROUP BY recipient\",args:[lane]});\n return c.json({state:row,pending:pending.rows});\n});\n\napp.get(\"/v1/inbox\", async (c) => {\n const auth = await authFrom(c.req.raw); if (!auth || (auth.role !== \"gpt\" && auth.role !== \"codex\")) return c.json({error:\"UNAUTHORIZED\"},401);\n if (auth.kind === \"device\") return c.json({error:\"DEVICE_TOKEN_USE_CHALLENGE_ROUTE\"},403);\n const role = auth.role;\n const lane = c.req.query(\"lane\") || \"\"; if (!LANE_RE.test(lane)) return c.json({error:\"INVALID_LANE\"},400);\n if (!laneAuthorized(auth,lane)) return c.json({error:\"DEVICE_TOKEN_SCOPE_VIOLATION\"},403);\n const rs = await sqlite.execute({sql:`SELECT id,actor,recipient,lane,base_revision,revision,payload_json,payload_sha256,message_sha256,created_at\n FROM messages WHERE recipient=? AND lane=? AND acked_at IS NULL ORDER BY revision,id LIMIT 100`,args:[role,lane]});\n return c.json({messages:rs.rows.map((r:any)=>({...r,payload:JSON.parse(String(r.payload_json)),payload_json:undefined}))});\n});\n\napp.get(\"/v1/challenge/:lane\", async (c) => {\n const auth = await authFrom(c.req.raw);\n if (!auth || auth.kind !== \"device\" || auth.role !== \"codex\") return c.json({error:\"UNAUTHORIZED\"},401);\n const lane = c.req.param(\"lane\");\n if (!LANE_RE.test(lane)) return c.json({error:\"INVALID_LANE\"},400);\n if (!laneAuthorized(auth,lane)) return c.json({error:\"DEVICE_TOKEN_SCOPE_VIOLATION\"},403);\n const rs = await sqlite.execute({\n sql:\"SELECT id,actor,recipient,lane,base_revision,revision,payload_json,payload_sha256,message_sha256,created_at,acked_at FROM messages WHERE lane=? AND actor='gpt' AND recipient='codex' ORDER BY revision ASC\",\n args:[lane]\n });\n if (rs.rows.length !== 1) return c.json({error:\"CHALLENGE_SET_NOT_UNIQUE\",count:rs.rows.length},409);\n const row:any = rs.rows[0];\n return c.json({challenge:{...row,payload:JSON.parse(String(row.payload_json)),payload_json:undefined}});\n});\n\napp.post(\"/v1/messages\", async (c) => {\n const auth = await authFrom(c.req.raw); if (!auth || (auth.role !== \"gpt\" && auth.role !== \"codex\")) return c.json({error:\"UNAUTHORIZED\"},401);\n const actor = auth.role;\n try {\n const b = await bodyJson(c);\n const lane = String(b.lane||\"\"); if (!LANE_RE.test(lane)) return c.json({error:\"INVALID_LANE\"},400);\n if (!laneAuthorized(auth,lane)) return c.json({error:\"DEVICE_TOKEN_SCOPE_VIOLATION\"},403);\n const base = Number(b.base_revision); if (!Number.isSafeInteger(base) || base < 0) return c.json({error:\"INVALID_BASE_REVISION\"},400);\n const payload = b.payload ?? {}; if (hasSecret(payload)) return c.json({error:\"SECRET_REJECTED\"},400);\n if (auth.kind === \"device\" && payload?.kind !== \"runtime_acceptance_response_v4\") return c.json({error:\"DEVICE_TOKEN_MESSAGE_KIND_VIOLATION\"},403);\n if (auth.kind === \"device\" && base !== 1) return c.json({error:\"DEVICE_TOKEN_BASE_REVISION_VIOLATION\",expected:1,observed:base},403);\n const requestId = String(b.request_id || \"\").trim();\n if (requestId && !/^[A-Za-z0-9_.:-]{16,128}$/.test(requestId)) return c.json({error:\"INVALID_REQUEST_ID\"},400);\n const requestBodySha256 = await sha(canonical({lane,base_revision:base,payload}));\n if (requestId) {\n const prior = await sqlite.execute({sql:\"SELECT body_sha256,message_id FROM request_dedup WHERE actor=? AND request_id=?\",args:[actor,requestId]});\n if (prior.rows.length) {\n const d:any = prior.rows[0];\n if (String(d.body_sha256)!==requestBodySha256) return c.json({error:\"IDEMPOTENCY_KEY_REUSE_MISMATCH\"},409);\n const m = await sqlite.execute({sql:\"SELECT id,lane,revision,payload_sha256,message_sha256 FROM messages WHERE id=?\",args:[String(d.message_id)]});\n if (!m.rows.length) return c.json({error:\"DEDUP_MESSAGE_MISSING\"},500);\n if (auth.kind === \"device\") {\n const prov = await sqlite.execute({sql:\"SELECT pairing_id,token_sha256 FROM message_auth_provenance WHERE message_id=? LIMIT 1\",args:[String(d.message_id)]});\n const p:any = prov.rows[0];\n if (!p || String(p.pairing_id)!==String(auth.pairing_id) || String(p.token_sha256)!==String(auth.token_sha256)) {\n return c.json({error:\"DEVICE_IDEMPOTENCY_PROVENANCE_MISMATCH\"},403);\n }\n }\n const row:any = m.rows[0];\n const checkpoint_sha256 = await sha(canonical({lane:String(row.lane),revision:Number(row.revision),message_sha256:String(row.message_sha256)}));\n await audit(\"MESSAGE_ACCEPTED\",actor,String(row.lane),String(row.id),String(row.message_sha256));\n return c.json({accepted:true,idempotent:true,id:row.id,lane:row.lane,revision:row.revision,payload_sha256:row.payload_sha256,message_sha256:row.message_sha256,checkpoint_sha256},200);\n }\n }\n await sqlite.execute({sql:\"INSERT OR IGNORE INTO lane_state(lane,revision,checkpoint_sha256,updated_at) VALUES(?,0,?,?)\",args:[lane,\"0\".repeat(64),new Date().toISOString()]});\n const st = await sqlite.execute({sql:\"SELECT revision FROM lane_state WHERE lane=?\",args:[lane]});\n const cur = Number(st.rows[0]?.revision ?? 0); if (cur !== base) return c.json({error:\"STALE_REVISION\",expected:cur,observed:base},409);\n const recipient = actor === \"gpt\" ? \"codex\" : \"gpt\";\n const id = crypto.randomUUID(); const revision = base + 1; const created_at = new Date().toISOString();\n const payload_json = canonical(payload); const payload_sha256 = await sha(payload_json);\n const envelope = {protocol:\"rumbo-continuity-relay/v1\",id,actor,recipient,lane,base_revision:base,revision,payload_sha256,created_at};\n const message_sha256 = await sha(canonical(envelope));\n const checkpoint_sha256 = await sha(canonical({lane,revision,message_sha256}));\n const statements:any[] = [\n {sql:`INSERT INTO messages(id,actor,recipient,lane,base_revision,revision,payload_json,payload_sha256,message_sha256,created_at)\n VALUES(?,?,?,?,?,?,?,?,?,?)`,args:[id,actor,recipient,lane,base,revision,payload_json,payload_sha256,message_sha256,created_at]},\n {sql:\"UPDATE lane_state SET checkpoint_sha256=? WHERE lane=? AND revision=?\",args:[checkpoint_sha256,lane,revision]}\n ];\n if (auth.kind === \"device\") {\n if (!auth.pairing_id || !auth.token_sha256) return c.json({error:\"DEVICE_AUTH_PROVENANCE_MISSING\"},403);\n statements.push({sql:\"INSERT INTO message_auth_provenance(message_id,auth_kind,pairing_id,token_sha256,created_at) VALUES(?,?,?,?,?)\",args:[id,\"device\",auth.pairing_id,auth.token_sha256,created_at]});\n }\n if (requestId) statements.push({sql:\"INSERT INTO request_dedup(actor,request_id,body_sha256,message_id,created_at) VALUES(?,?,?,?,?)\",args:[actor,requestId,requestBodySha256,id,created_at]});\n try {\n await sqlite.batch(statements);\n } catch (e) {\n if (requestId) {\n const prior = await sqlite.execute({sql:\"SELECT body_sha256,message_id FROM request_dedup WHERE actor=? AND request_id=?\",args:[actor,requestId]});\n if (prior.rows.length) {\n const d:any = prior.rows[0];\n if (String(d.body_sha256)!==requestBodySha256) return c.json({error:\"IDEMPOTENCY_KEY_REUSE_MISMATCH\"},409);\n const m = await sqlite.execute({sql:\"SELECT id,lane,revision,payload_sha256,message_sha256 FROM messages WHERE id=?\",args:[String(d.message_id)]});\n if (m.rows.length) {\n if (auth.kind === \"device\") {\n const prov = await sqlite.execute({sql:\"SELECT pairing_id,token_sha256 FROM message_auth_provenance WHERE message_id=? LIMIT 1\",args:[String(d.message_id)]});\n const p:any = prov.rows[0];\n if (!p || String(p.pairing_id)!==String(auth.pairing_id) || String(p.token_sha256)!==String(auth.token_sha256)) {\n return c.json({error:\"DEVICE_IDEMPOTENCY_PROVENANCE_MISMATCH\"},403);\n }\n }\n const row:any=m.rows[0];\n const cp=await sha(canonical({lane:String(row.lane),revision:Number(row.revision),message_sha256:String(row.message_sha256)}));\n await audit(\"MESSAGE_ACCEPTED\",actor,String(row.lane),String(row.id),String(row.message_sha256));\n return c.json({accepted:true,idempotent:true,id:row.id,lane:row.lane,revision:row.revision,payload_sha256:row.payload_sha256,message_sha256:row.message_sha256,checkpoint_sha256:cp},200);\n }\n }\n }\n if (String(e).includes(\"STALE_REVISION\")) {\n const curState=await sqlite.execute({sql:\"SELECT revision FROM lane_state WHERE lane=?\",args:[lane]});\n return c.json({error:\"STALE_REVISION\",expected:Number(curState.rows[0]?.revision ?? 0),observed:base},409);\n }\n throw e;\n }\n const verify = await sqlite.execute({sql:\"SELECT revision,checkpoint_sha256 FROM lane_state WHERE lane=?\",args:[lane]});\n if (Number(verify.rows[0]?.revision) !== revision || String(verify.rows[0]?.checkpoint_sha256)!==checkpoint_sha256) return c.json({error:\"ATOMIC_ADVANCE_FAILED\"},409);\n await audit(\"MESSAGE_ACCEPTED\",actor,lane,id,message_sha256);\n return c.json({accepted:true,idempotent:false,id,lane,revision,payload_sha256,message_sha256,checkpoint_sha256},201);\n } catch (e) { return c.json({error:String(e?.message||e)},400); }\n});\n\napp.post(\"/v1/acks\", async (c) => {\n const auth = await authFrom(c.req.raw); if (!auth || (auth.role !== \"gpt\" && auth.role !== \"codex\")) return c.json({error:\"UNAUTHORIZED\"},401);\n const actor = auth.role;\n try {\n const b = await bodyJson(c); const id = String(b.message_id||\"\"); const msgSha = String(b.message_sha256||\"\");\n const rs = await sqlite.execute({sql:\"SELECT * FROM messages WHERE id=?\",args:[id]}); const m:any = rs.rows[0];\n if (!m) return c.json({error:\"NOT_FOUND\"},404);\n if (!laneAuthorized(auth,String(m.lane))) return c.json({error:\"DEVICE_TOKEN_SCOPE_VIOLATION\"},403);\n if (auth.kind === \"device\") {\n let mp:any = null;\n try { mp = JSON.parse(String(m.payload_json || \"{}\")); } catch {}\n if (String(m.actor)!==\"gpt\" || String(m.recipient)!==\"codex\" || Number(m.revision)!==1 || mp?.kind!==\"runtime_acceptance_challenge_v4\") {\n return c.json({error:\"DEVICE_TOKEN_ACK_TARGET_VIOLATION\"},403);\n }\n }\n if (String(m.recipient)!==actor) return c.json({error:\"WRONG_RECIPIENT\"},403);\n if (String(m.message_sha256)!==msgSha) return c.json({error:\"HASH_MISMATCH\"},409);\n const prior = await sqlite.execute({sql:\"SELECT id FROM acknowledgements WHERE target_message_id=?\",args:[id]});\n if (prior.rows.length) {\n if (auth.kind === \"device\") {\n const prov = await sqlite.execute({sql:\"SELECT pairing_id,token_sha256 FROM ack_auth_provenance WHERE target_message_id=? LIMIT 1\",args:[id]});\n const p:any = prov.rows[0];\n if (!p || String(p.pairing_id)!==String(auth.pairing_id) || String(p.token_sha256)!==String(auth.token_sha256)) {\n return c.json({error:\"DEVICE_ACK_PROVENANCE_MISMATCH\"},403);\n }\n }\n await audit(\"MESSAGE_ACKED\",actor,String(m.lane),id,msgSha);\n return c.json({acked:true,idempotent:true,message_id:id});\n }\n const ackId = crypto.randomUUID(), created_at = new Date().toISOString();\n const ackStatements:any[] = [\n {sql:\"INSERT OR IGNORE INTO acknowledgements(id,actor,target_message_id,target_message_sha256,created_at) VALUES(?,?,?,?,?)\",args:[ackId,actor,id,msgSha,created_at]},\n {sql:\"UPDATE messages SET acked_at=COALESCE(acked_at,?) WHERE id=?\",args:[created_at,id]}\n ];\n if (auth.kind === \"device\") {\n if (!auth.pairing_id || !auth.token_sha256) return c.json({error:\"DEVICE_AUTH_PROVENANCE_MISSING\"},403);\n ackStatements.push({sql:\"INSERT INTO ack_auth_provenance(target_message_id,acknowledgement_id,auth_kind,pairing_id,token_sha256,created_at) VALUES(?,?,?,?,?,?)\",args:[id,ackId,\"device\",auth.pairing_id,auth.token_sha256,created_at]});\n }\n const results:any = await sqlite.batch(ackStatements);\n const inserted = Number(results?.[0]?.rowsAffected ?? 0) > 0;\n if (inserted) await audit(\"MESSAGE_ACKED\",actor,String(m.lane),id,msgSha);\n return c.json({acked:true,idempotent:!inserted,message_id:id});\n } catch (e) { return c.json({error:String(e?.message||e)},400); }\n});\n\napp.get(\"/v1/acceptance/:lane\", async (c) => {\n const role = await roleFrom(c.req.raw);\n if (role !== \"gpt\" && role !== \"admin\") return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n const lane = c.req.param(\"lane\");\n if ([\"CODEX_REAL_RUNTIME_ACCEPTANCE_V1\",\"CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",\"CODEX_REAL_RUNTIME_ACCEPTANCE_V3\"].includes(lane)) {\n return c.json({\n lane,state:\"SUPERSEDED_BY_CODEX_REAL_RUNTIME_ACCEPTANCE_V4\",\n mechanical_checks_passed:false,production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n }\n if (lane !== DEVICE_ACCESS_LANE) return c.json({error:\"UNSUPPORTED_ACCEPTANCE_LANE\"},404,{\"Cache-Control\":\"no-store\"});\n\n const challenges = await sqlite.execute({sql:`SELECT id,revision,payload_json,message_sha256,created_at,acked_at\n FROM messages WHERE lane=? AND actor='gpt' AND recipient='codex' ORDER BY revision ASC`,args:[lane]});\n if (challenges.rows.length !== 1) return c.json({\n lane,state:challenges.rows.length ? \"AMBIGUOUS_CHALLENGE_SET\" : \"CHALLENGE_NOT_PROVEN\",\n challenge_count:challenges.rows.length,mechanical_checks_passed:false,production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n\n const challenge:any = challenges.rows[0];\n let cp:any;\n try { cp = JSON.parse(String(challenge.payload_json)); } catch { cp = null; }\n const required = [\n \"consume_this_exact_message\",\"ack_exact_message_id_and_message_sha256\",\n \"execute_actual_codex_cli_isolated_read_only_never_approve\",\n \"prove_fresh_local_read_challenge_not_present_in_prompt\",\n \"publish_reverse_response_with_same_challenge_nonce\",\n \"bind_ack_and_response_to_same_authenticated_device\",\n \"bind_device_pairing_contract_to_bootstrap_lane_and_challenge\",\n \"include_local_plugin_manifest_sha256\",\"include_local_runtime_receipt_sha256\",\n \"include_local_read_challenge_sha256\",\"include_codex_runtime_nonce\",\n \"include_codex_last_message_sha256\",\"include_codex_exec_events_sha256\",\n \"do_not_include_secrets\",\"preserve_fail_closed_project_gates\",\"production_go_false\"\n ];\n const declared = Array.isArray(cp?.acceptance_requirements) ? cp.acceptance_requirements.map(String) : [];\n const deadline = String(cp?.acceptance_not_after_utc || \"\");\n const deadlineMs = Date.parse(deadline);\n const challengeCreatedAt = Date.parse(String(challenge.created_at || \"\"));\n const execContract:any = cp?.required_codex_execution || {};\n const contractOk =\n String(challenge.id) === R9_CHALLENGE_ID &&\n String(challenge.message_sha256) === R9_CHALLENGE_SHA256 &&\n Number(challenge.revision) === 1 &&\n cp?.kind === \"runtime_acceptance_challenge_v4\" &&\n typeof cp?.challenge_nonce === \"string\" && cp.challenge_nonce.length >= 32 &&\n deadline === R9_ACCEPTANCE_NOT_AFTER_UTC && Number.isFinite(deadlineMs) &&\n cp?.canonical_release === \"GPT_CODEX_CONTEXT_BRIDGE_V1_6\" &&\n cp?.canonical_release_sha256 === \"cdbbb59d96a4a45d943f6d14a610e3cdbf451cc9480ed9300a170f60bef39e0b\" &&\n cp?.canonical_skill_sha256 === \"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\" &&\n cp?.expected_plugin_name === \"rumbo-gpt-codex-continuity\" &&\n cp?.expected_plugin_version === R9_PLUGIN_VERSION &&\n cp?.expected_plugin_manifest_sha256 === R9_PLUGIN_MANIFEST_SHA256 &&\n execContract?.mode === \"codex exec\" &&\n execContract?.ephemeral === true &&\n execContract?.sandbox === \"read-only\" &&\n execContract?.ask_for_approval === \"never\" &&\n execContract?.skip_git_repo_check === true &&\n execContract?.dangerous_bypass_forbidden === true &&\n execContract?.model_override_forbidden === true &&\n execContract?.isolated_codex_home === true &&\n execContract?.ignore_user_config === true &&\n execContract?.ignore_rules === true &&\n execContract?.user_config_inherited === false &&\n execContract?.project_config_inherited === false &&\n execContract?.global_agents_md_inherited === false &&\n execContract?.local_read_challenge_required === true &&\n execContract?.hidden_local_nonce_not_in_prompt === true &&\n execContract?.auth_source === \"regular_auth_json_copy\" &&\n required.every(x => declared.includes(x));\n\n const evidence:any = {\n challenge_message_id:String(challenge.id),\n challenge_message_sha256:String(challenge.message_sha256),\n challenge_revision:Number(challenge.revision),\n challenge_created_at:String(challenge.created_at || \"\"),\n acceptance_not_after_utc:deadline\n };\n if (!contractOk) return c.json({lane,state:\"CHALLENGE_CONTRACT_MISMATCH\",mechanical_checks_passed:false,evidence,production_go:false},200,{\"Cache-Control\":\"no-store\"});\n\n const codexAck = await sqlite.execute({sql:`SELECT a.id,a.created_at,p.auth_kind,p.pairing_id AS auth_pairing_id,p.token_sha256 AS auth_token_sha256\n FROM acknowledgements a\n LEFT JOIN ack_auth_provenance p ON p.target_message_id=a.target_message_id AND p.acknowledgement_id=a.id\n WHERE a.actor='codex' AND a.target_message_id=? AND a.target_message_sha256=? LIMIT 1`,\n args:[String(challenge.id),String(challenge.message_sha256)]});\n if (!codexAck.rows.length) {\n const expired = Date.now() > deadlineMs;\n return c.json({\n lane,state:expired ? \"CHALLENGE_EXPIRED_NO_CODEX_ACK\" : \"PENDING_CODEX_ACK\",\n mechanical_checks_passed:false,evidence,production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n }\n\n const ackRow:any = codexAck.rows[0];\n const codexAckAt = Date.parse(String(ackRow.created_at || \"\"));\n if (!Number.isFinite(codexAckAt) || codexAckAt > deadlineMs || codexAckAt < challengeCreatedAt) {\n return c.json({\n lane,state:\"INVALID_CODEX_ACK_TIME\",mechanical_checks_passed:false,\n evidence:{...evidence,codex_ack_id:String(ackRow.id),codex_ack_created_at:String(ackRow.created_at || \"\")},\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n }\n\n const reverse = await sqlite.execute({sql:`SELECT m.id,m.revision,m.payload_json,m.message_sha256,m.created_at,m.acked_at,\n p.auth_kind,p.pairing_id AS auth_pairing_id,p.token_sha256 AS auth_token_sha256\n FROM messages m\n LEFT JOIN message_auth_provenance p ON p.message_id=m.id\n WHERE m.lane=? AND m.actor='codex' AND m.recipient='gpt' AND m.revision>? ORDER BY m.revision ASC`,\n args:[lane,Number(challenge.revision)]});\n if (!reverse.rows.length) return c.json({\n lane,state:\"PENDING_CODEX_RESPONSE\",mechanical_checks_passed:false,\n evidence:{...evidence,codex_ack_id:String(ackRow.id)},production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n if (reverse.rows.length !== 1) return c.json({\n lane,state:\"AMBIGUOUS_MULTIPLE_CODEX_RESPONSES\",response_count:reverse.rows.length,\n mechanical_checks_passed:false,evidence,production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n\n const response:any = reverse.rows[0];\n let rp:any;\n try { rp = JSON.parse(String(response.payload_json)); } catch { rp = null; }\n const responseCreatedAt = Date.parse(String(response.created_at || \"\"));\n const codexExecution:any = rp?.codex_execution || {};\n const devicePairingId = String(rp?.device_pairing_session_id || \"\");\n\n const deviceRows = /^[0-9a-f-]{36}$/.test(devicePairingId)\n ? await sqlite.execute({sql:`SELECT t.token_sha256,t.lane_scope,t.issued_at,t.expires_at,t.revoked_at,\n s.approved_at,s.delivered_at,\n x.bootstrap_script_sha256,x.acceptance_lane,x.challenge_message_id,x.challenge_message_sha256\n FROM device_access_tokens t\n JOIN device_pairing_sessions s ON s.pairing_id=t.pairing_id\n LEFT JOIN device_pairing_contracts x ON x.pairing_id=t.pairing_id\n WHERE t.pairing_id=? LIMIT 1`,args:[devicePairingId]})\n : {rows:[]};\n const device:any = deviceRows.rows[0] || null;\n\n const responseAuthPairingId = String(response.auth_pairing_id || \"\");\n const responseAuthTokenSha256 = String(response.auth_token_sha256 || \"\");\n const ackAuthPairingId = String(ackRow.auth_pairing_id || \"\");\n const ackAuthTokenSha256 = String(ackRow.auth_token_sha256 || \"\");\n const tokenIssuedAt = Date.parse(String(device?.issued_at || \"\"));\n const tokenExpiresAt = Date.parse(String(device?.expires_at || \"\"));\n const tokenRevokedAt = device?.revoked_at ? Date.parse(String(device.revoked_at)) : null;\n const pairingApprovedAt = Date.parse(String(device?.approved_at || \"\"));\n const pairingDeliveredAt = Date.parse(String(device?.delivered_at || \"\"));\n\n const checks = {\n response_before_deadline:Number.isFinite(responseCreatedAt) && responseCreatedAt <= deadlineMs,\n response_after_codex_ack:Number.isFinite(responseCreatedAt) && responseCreatedAt >= codexAckAt,\n response_kind:rp?.kind === \"runtime_acceptance_response_v4\",\n challenge_nonce_exact:typeof rp?.challenge_nonce === \"string\" && rp.challenge_nonce === cp.challenge_nonce,\n challenge_message_id_exact:rp?.challenge_message_id === String(challenge.id),\n challenge_message_sha256_exact:rp?.challenge_message_sha256 === String(challenge.message_sha256),\n canonical_release_exact:rp?.canonical_release === \"GPT_CODEX_CONTEXT_BRIDGE_V1_6\",\n canonical_release_sha256_exact:rp?.canonical_release_sha256 === \"cdbbb59d96a4a45d943f6d14a610e3cdbf451cc9480ed9300a170f60bef39e0b\",\n canonical_skill_sha256_exact:rp?.canonical_skill_sha256 === \"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\",\n plugin_name_exact:rp?.plugin_name === \"rumbo-gpt-codex-continuity\",\n plugin_version_exact:rp?.plugin_version === R9_PLUGIN_VERSION,\n local_plugin_manifest_sha256_exact:rp?.local_plugin_manifest_sha256 === R9_PLUGIN_MANIFEST_SHA256,\n local_runtime_receipt_sha256:validSha256(rp?.local_runtime_receipt_sha256),\n device_pairing_session_id:/^[0-9a-f-]{36}$/.test(devicePairingId),\n device_binding_exists:!!device,\n device_lane_scope_exact:String(device?.lane_scope || \"\") === DEVICE_ACCESS_LANE,\n pairing_contract_bootstrap_exact:String(device?.bootstrap_script_sha256 || \"\") === R9_BOOTSTRAP_SHA256,\n pairing_contract_lane_exact:String(device?.acceptance_lane || \"\") === DEVICE_ACCESS_LANE,\n pairing_contract_challenge_id_exact:String(device?.challenge_message_id || \"\") === R9_CHALLENGE_ID,\n pairing_contract_challenge_sha_exact:String(device?.challenge_message_sha256 || \"\") === R9_CHALLENGE_SHA256,\n response_auth_kind_device:String(response.auth_kind || \"\") === \"device\",\n response_auth_pairing_exact:responseAuthPairingId === devicePairingId,\n response_auth_token_exact:validSha256(responseAuthTokenSha256) && responseAuthTokenSha256 === String(device?.token_sha256 || \"\"),\n ack_auth_kind_device:String(ackRow.auth_kind || \"\") === \"device\",\n ack_auth_pairing_exact:ackAuthPairingId === devicePairingId,\n ack_auth_token_exact:validSha256(ackAuthTokenSha256) && ackAuthTokenSha256 === String(device?.token_sha256 || \"\"),\n ack_response_same_authenticated_device:ackAuthPairingId === responseAuthPairingId && ackAuthTokenSha256 === responseAuthTokenSha256,\n pairing_approved_before_ack:Number.isFinite(pairingApprovedAt) && pairingApprovedAt <= codexAckAt,\n token_delivered_before_ack:Number.isFinite(pairingDeliveredAt) && pairingDeliveredAt <= codexAckAt,\n token_issued_before_ack:Number.isFinite(tokenIssuedAt) && tokenIssuedAt <= codexAckAt,\n token_active_at_response:Number.isFinite(tokenIssuedAt) && Number.isFinite(tokenExpiresAt) &&\n tokenIssuedAt <= responseCreatedAt && tokenExpiresAt > responseCreatedAt &&\n (tokenRevokedAt === null || (Number.isFinite(tokenRevokedAt) && tokenRevokedAt >= responseCreatedAt)),\n bootstrap_script_sha256_exact:rp?.bootstrap_script_sha256 === R9_BOOTSTRAP_SHA256,\n codex_cli_version:typeof rp?.codex_cli_version === \"string\" && rp.codex_cli_version.length > 0 && rp.codex_cli_version.length <= 300,\n codex_thread_id:typeof rp?.codex_thread_id === \"string\" && rp.codex_thread_id.length > 0 && rp.codex_thread_id.length <= 200,\n codex_runtime_nonce:typeof rp?.codex_runtime_nonce === \"string\" && /^[a-f0-9]{64}$/.test(rp.codex_runtime_nonce),\n codex_local_read_challenge_sha256:validSha256(rp?.codex_local_read_challenge_sha256),\n codex_last_message_sha256:validSha256(rp?.codex_last_message_sha256),\n codex_exec_events_sha256:validSha256(rp?.codex_exec_events_sha256),\n codex_tool_probe_verified:rp?.codex_tool_probe_verified === true,\n codex_tool_probe_sha256:validSha256(rp?.codex_tool_probe_sha256),\n codex_skill_md_sha256_exact:rp?.codex_skill_md_sha256 === \"224197fb56be75ae395fb2e4e2eb48f3bd64d1e187df5799fd6d661e4d1ec09f\",\n codex_command_execution_count:Number.isSafeInteger(rp?.codex_command_execution_count) && rp.codex_command_execution_count >= 1,\n codex_prohibited_items_seen:rp?.codex_prohibited_items_seen === false,\n codex_exec_exit_code:rp?.codex_exec_exit_code === 0,\n codex_cli_contract_preflight:rp?.codex_cli_contract_preflight === true,\n codex_output_bindings_exact:rp?.codex_output_bindings_exact === true,\n codex_local_read_proof_exact:rp?.codex_local_read_proof_exact === true,\n codex_exec_mode:codexExecution?.mode === \"codex exec\",\n codex_exec_ephemeral:codexExecution?.ephemeral === true,\n codex_exec_sandbox:codexExecution?.sandbox === \"read-only\",\n codex_exec_approval_never:codexExecution?.ask_for_approval === \"never\",\n codex_exec_dangerous_bypass:codexExecution?.dangerous_bypass_used === false,\n codex_exec_model_override:codexExecution?.model_override_used === false,\n codex_exec_skip_git_repo_check:codexExecution?.skip_git_repo_check === true,\n codex_exec_isolated_home:codexExecution?.isolated_codex_home === true,\n codex_exec_ignore_user_config:codexExecution?.ignore_user_config === true,\n codex_exec_ignore_rules:codexExecution?.ignore_rules === true,\n codex_exec_user_config_not_inherited:codexExecution?.user_config_inherited === false,\n codex_exec_project_config_not_inherited:codexExecution?.project_config_inherited === false,\n codex_exec_global_agents_not_inherited:codexExecution?.global_agents_md_inherited === false,\n codex_exec_auth_source:codexExecution?.auth_source === \"regular_auth_json_copy\",\n runtime_claim:rp?.runtime_claim === \"ACTUAL_CODEX_CLI_EXEC_ISOLATED_READ_ONLY_LOCAL_READ_PROVEN\",\n fail_closed_project_gates_preserved:rp?.fail_closed_project_gates_preserved === true,\n secrets_exposed:rp?.secrets_exposed === false,\n production_go:rp?.production_go === false\n };\n\n const responseEvidence:any = {\n ...evidence,\n codex_ack_id:String(ackRow.id),\n codex_ack_created_at:String(ackRow.created_at || \"\"),\n codex_response_message_id:String(response.id),\n codex_response_message_sha256:String(response.message_sha256),\n codex_response_revision:Number(response.revision),\n codex_response_created_at:String(response.created_at || \"\"),\n device_pairing_session_id:devicePairingId,\n checks\n };\n if (!Object.values(checks).every(Boolean)) return c.json({\n lane,state:\"INVALID_CODEX_RESPONSE\",mechanical_checks_passed:false,evidence:responseEvidence,production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n\n const deviceTokenExpired = Number.isFinite(tokenExpiresAt) && tokenExpiresAt <= Date.now();\n if (!device?.revoked_at && !deviceTokenExpired) return c.json({\n lane,state:\"PENDING_DEVICE_TOKEN_INACTIVATION\",mechanical_checks_passed:false,\n evidence:{...responseEvidence,device_token_revoked_at:null,device_token_expires_at:String(device?.expires_at || \"\")},\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n\n responseEvidence.device_token_revoked_at = device?.revoked_at ? String(device.revoked_at) : null;\n responseEvidence.device_token_expires_at = String(device?.expires_at || \"\");\n responseEvidence.device_token_inactive_reason = device?.revoked_at ? \"REVOKED\" : \"EXPIRED\";\n\n const gptAck = await sqlite.execute({sql:`SELECT id,created_at FROM acknowledgements\n WHERE actor='gpt' AND target_message_id=? AND target_message_sha256=? LIMIT 1`,\n args:[String(response.id),String(response.message_sha256)]});\n if (!gptAck.rows.length) return c.json({\n lane,state:\"PENDING_CHATGPT_ACK\",mechanical_checks_passed:true,\n evidence:responseEvidence,manual_semantic_review_required:true,production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n\n return c.json({\n lane,state:\"PASS_RUNTIME_ROUNDTRIP\",mechanical_checks_passed:true,\n evidence:{...responseEvidence,gpt_ack_id:String((gptAck.rows[0] as any).id)},\n claim_boundary:\"Continuity runtime/authenticated-device/local-read binding only; no project production authorization.\",\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n});\n\napp.post(\"/v1/guard/authorize\", async (c) => {\n if (!guardAuthorized(c.req.raw)) return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n try {\n const b = await bodyJson(c);\n const binding = parseGuardBinding(b);\n if (!binding) return c.json({error:\"INVALID_GUARD_BINDING\"},400,{\"Cache-Control\":\"no-store\"});\n if (binding.action === \"MERGE_PR\" && Deno.env.get(\"R2_ALLOW_MERGE_AUTHORIZATION\") !== \"true\") {\n return c.json({error:\"MERGE_AUTHORIZATION_DISABLED\",production_go:false},423,{\"Cache-Control\":\"no-store\"});\n }\n const ttl = b.ttl_seconds === undefined ? 300 : Number(b.ttl_seconds);\n if (!Number.isSafeInteger(ttl) || ttl < 60 || ttl > R2_GUARD_MAX_TTL_SECONDS) {\n return c.json({error:\"INVALID_TTL\",min_seconds:60,max_seconds:R2_GUARD_MAX_TTL_SECONDS},400,{\"Cache-Control\":\"no-store\"});\n }\n const requestSha256 = await sha(canonical(binding));\n const prior = await sqlite.execute({\n sql:\"SELECT authorization_id,status,expires_at FROM guard_authorizations WHERE request_sha256=? LIMIT 1\",\n args:[requestSha256]\n });\n if (prior.rows.length) {\n const row:any = prior.rows[0];\n return c.json({\n error:\"AUTHORIZATION_ALREADY_EXISTS\",\n authorization_id:row.authorization_id,\n status:row.status,\n expires_at:row.expires_at,\n request_sha256:requestSha256\n },409,{\"Cache-Control\":\"no-store\"});\n }\n\n const rawToken = randomOneTimeToken();\n const tokenSha256 = await sha(rawToken);\n const authorizationId = crypto.randomUUID();\n const issuedAt = new Date();\n const issuedAtIso = issuedAt.toISOString();\n const expiresAt = new Date(issuedAt.getTime() + ttl * 1000).toISOString();\n try {\n await sqlite.execute({\n sql:`INSERT INTO guard_authorizations(\n authorization_id,action,repository_identity_sha256,pr_number,base_sha,head_sha,\n package_sha256,evidence_sha256,request_sha256,token_sha256,status,issued_at,expires_at\n ) VALUES(?,?,?,?,?,?,?,?,?,?, 'ISSUED', ?,?)`,\n args:[\n authorizationId,binding.action,binding.repository_identity_sha256,binding.pr_number,\n binding.base_sha,binding.head_sha,binding.package_sha256,binding.evidence_sha256,\n requestSha256,tokenSha256,issuedAtIso,expiresAt\n ]\n });\n } catch (e) {\n if (String(e).includes(\"UNIQUE\")) return c.json({error:\"AUTHORIZATION_COLLISION\"},409,{\"Cache-Control\":\"no-store\"});\n throw e;\n }\n\n try {\n await audit(\"GUARD_AUTHORIZATION_ISSUED\",\"guard\",null,authorizationId,requestSha256);\n } catch (e) {\n await sqlite.execute({sql:\"UPDATE guard_authorizations SET status='REVOKED' WHERE authorization_id=? AND status='ISSUED'\",args:[authorizationId]});\n throw e;\n }\n\n return c.json({\n authorized:true,\n authorization_id:authorizationId,\n action:binding.action,\n request_sha256:requestSha256,\n token:rawToken,\n token_type:\"One-Time\",\n issued_at:issuedAtIso,\n expires_at:expiresAt,\n production_go:false,\n merge_authorized:binding.action === \"MERGE_PR\",\n note:\"The raw one-time token is returned only on issuance; only its SHA-256 is persisted.\"\n },201,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.post(\"/v1/guard/consume\", async (c) => {\n if (!guardAuthorized(c.req.raw)) return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n try {\n const b = await bodyJson(c);\n const binding = parseGuardBinding(b);\n if (!binding) return c.json({error:\"INVALID_GUARD_BINDING\"},400,{\"Cache-Control\":\"no-store\"});\n if (binding.action === \"MERGE_PR\" && Deno.env.get(\"R2_ALLOW_MERGE_AUTHORIZATION\") !== \"true\") {\n return c.json({error:\"MERGE_AUTHORIZATION_DISABLED\",production_go:false},423,{\"Cache-Control\":\"no-store\"});\n }\n const authorizationId = String(b.authorization_id || \"\");\n const rawToken = String(b.token || \"\");\n if (!authorizationId || !/^[A-Za-z0-9_-]{43,128}$/.test(rawToken)) {\n return c.json({error:\"INVALID_CONSUMPTION_REQUEST\"},400,{\"Cache-Control\":\"no-store\"});\n }\n const requestSha256 = await sha(canonical(binding));\n const rs = await sqlite.execute({sql:\"SELECT * FROM guard_authorizations WHERE authorization_id=? LIMIT 1\",args:[authorizationId]});\n if (!rs.rows.length) return c.json({error:\"AUTHORIZATION_NOT_FOUND\"},404,{\"Cache-Control\":\"no-store\"});\n const row:any = rs.rows[0];\n\n if (String(row.status) === \"ISSUED\" && Date.parse(String(row.expires_at)) <= Date.now()) {\n await sqlite.execute({sql:\"UPDATE guard_authorizations SET status='EXPIRED' WHERE authorization_id=? AND status='ISSUED'\",args:[authorizationId]});\n await audit(\"GUARD_AUTHORIZATION_EXPIRED\",\"guard\",null,authorizationId,String(row.request_sha256));\n return c.json({error:\"AUTHORIZATION_EXPIRED\",authorization_id:authorizationId},410,{\"Cache-Control\":\"no-store\"});\n }\n if (String(row.status) !== \"ISSUED\") {\n return c.json({error:\"AUTHORIZATION_NOT_ISSUED\",authorization_id:authorizationId,status:row.status},409,{\"Cache-Control\":\"no-store\"});\n }\n if (!constantTimeEqual(String(row.request_sha256), requestSha256)) {\n return c.json({error:\"BINDING_MISMATCH\"},409,{\"Cache-Control\":\"no-store\"});\n }\n const observedTokenSha256 = await sha(rawToken);\n if (!constantTimeEqual(String(row.token_sha256), observedTokenSha256)) {\n return c.json({error:\"TOKEN_MISMATCH\"},403,{\"Cache-Control\":\"no-store\"});\n }\n\n const consumedAt = new Date().toISOString();\n const consumer = String(b.consumer || \"unspecified\").slice(0,128);\n if (!/^[A-Za-z0-9_.:-]{1,128}$/.test(consumer)) {\n return c.json({error:\"INVALID_CONSUMER\"},400,{\"Cache-Control\":\"no-store\"});\n }\n const updated:any = await sqlite.execute({\n sql:\"UPDATE guard_authorizations SET status='CONSUMED',consumed_at=?,consumer=? WHERE authorization_id=? AND status='ISSUED' AND consumed_at IS NULL\",\n args:[consumedAt,consumer,authorizationId]\n });\n if (Number(updated?.rowsAffected ?? 0) !== 1) {\n return c.json({error:\"AUTHORIZATION_RACE_LOST\",authorization_id:authorizationId},409,{\"Cache-Control\":\"no-store\"});\n }\n\n const receipt = {\n schema:\"rumbo-r2-guard-consumption/v1\",\n authorization_id:authorizationId,\n action:binding.action,\n repository_identity_sha256:binding.repository_identity_sha256,\n pr_number:binding.pr_number,\n base_sha:binding.base_sha,\n head_sha:binding.head_sha,\n package_sha256:binding.package_sha256,\n evidence_sha256:binding.evidence_sha256,\n request_sha256:requestSha256,\n consumed_at:consumedAt,\n consumer,\n production_go:false,\n merge_authorized:binding.action === \"MERGE_PR\"\n };\n const receiptSha256 = await sha(canonical(receipt));\n await audit(\"GUARD_AUTHORIZATION_CONSUMED\",\"guard\",null,authorizationId,receiptSha256);\n return c.json({...receipt,consumed:true,receipt_sha256:receiptSha256},200,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.post(\"/v1/guard/revoke\", async (c) => {\n if (!guardAuthorized(c.req.raw)) return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n try {\n const b = await bodyJson(c);\n const authorizationId = String(b.authorization_id || \"\");\n if (!authorizationId) return c.json({error:\"INVALID_AUTHORIZATION_ID\"},400,{\"Cache-Control\":\"no-store\"});\n const rs = await sqlite.execute({sql:\"SELECT status,request_sha256,expires_at FROM guard_authorizations WHERE authorization_id=? LIMIT 1\",args:[authorizationId]});\n if (!rs.rows.length) return c.json({error:\"AUTHORIZATION_NOT_FOUND\"},404,{\"Cache-Control\":\"no-store\"});\n const row:any = rs.rows[0];\n if (String(row.status) === \"ISSUED\" && Date.parse(String(row.expires_at)) <= Date.now()) {\n const expired:any = await sqlite.execute({\n sql:\"UPDATE guard_authorizations SET status='EXPIRED' WHERE authorization_id=? AND status='ISSUED'\",\n args:[authorizationId]\n });\n if (Number(expired?.rowsAffected ?? 0) === 1) {\n await audit(\"GUARD_AUTHORIZATION_EXPIRED\",\"guard\",null,authorizationId,String(row.request_sha256));\n }\n return c.json({error:\"AUTHORIZATION_EXPIRED\",authorization_id:authorizationId},410,{\"Cache-Control\":\"no-store\"});\n }\n if (String(row.status) !== \"ISSUED\") {\n return c.json({error:\"AUTHORIZATION_NOT_ISSUED\",status:row.status},409,{\"Cache-Control\":\"no-store\"});\n }\n const updated:any = await sqlite.execute({\n sql:\"UPDATE guard_authorizations SET status='REVOKED' WHERE authorization_id=? AND status='ISSUED'\",\n args:[authorizationId]\n });\n if (Number(updated?.rowsAffected ?? 0) !== 1) return c.json({error:\"AUTHORIZATION_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n await audit(\"GUARD_AUTHORIZATION_REVOKED\",\"guard\",null,authorizationId,String(row.request_sha256));\n return c.json({revoked:true,authorization_id:authorizationId,production_go:false},200,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.get(\"/v1/guard/authorizations/:id\", async (c) => {\n if (!guardAuthorized(c.req.raw)) return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n const authorizationId = c.req.param(\"id\");\n const now = new Date().toISOString();\n const rs = await sqlite.execute({\n sql:`SELECT authorization_id,action,repository_identity_sha256,pr_number,base_sha,head_sha,\n package_sha256,evidence_sha256,request_sha256,status,\n CASE WHEN status='ISSUED' AND expires_at<=? THEN 'EXPIRED' ELSE status END AS effective_status,\n issued_at,expires_at,consumed_at,consumer\n FROM guard_authorizations WHERE authorization_id=? LIMIT 1`,\n args:[now,authorizationId]\n });\n if (!rs.rows.length) return c.json({error:\"AUTHORIZATION_NOT_FOUND\"},404,{\"Cache-Control\":\"no-store\"});\n return c.json({authorization:rs.rows[0],production_go:false},200,{\"Cache-Control\":\"no-store\"});\n});\n\napp.get(\"/v1/guard/ledger\", async (c) => {\n if (!guardAuthorized(c.req.raw)) return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n const rawLimit = Number(c.req.query(\"limit\") || \"50\");\n const limit = Number.isSafeInteger(rawLimit) ? Math.max(1,Math.min(100,rawLimit)) : 50;\n const now = new Date().toISOString();\n const rs = await sqlite.execute({\n sql:`SELECT authorization_id,action,repository_identity_sha256,pr_number,base_sha,head_sha,\n package_sha256,evidence_sha256,request_sha256,status,\n CASE WHEN status='ISSUED' AND expires_at<=? THEN 'EXPIRED' ELSE status END AS effective_status,\n issued_at,expires_at,consumed_at,consumer\n FROM guard_authorizations ORDER BY issued_at DESC LIMIT ?`,\n args:[now,limit]\n });\n return c.json({\n schema:\"rumbo-r2-guard-ledger/v1\",\n external_authorizer_live:true,\n durable_one_time_token_ledger:true,\n merge_authorization_enabled:Deno.env.get(\"R2_ALLOW_MERGE_AUTHORIZATION\") === \"true\",\n production_go:false,\n records:rs.rows\n },200,{\"Cache-Control\":\"no-store\"});\n});\n\napp.get(\"/v1/audit\", async (c) => {\n const role = await roleFrom(c.req.raw); if (role !== \"admin\") return c.json({error:\"UNAUTHORIZED\"},401);\n const rs = await sqlite.execute(\"SELECT * FROM audit_events ORDER BY seq ASC\");\n let prev=\"0\".repeat(64), ok=true;\n for (const r of rs.rows as any[]) {\n const ev={event_type:r.event_type,actor:r.actor,lane:r.lane,object_id:r.object_id,object_sha256:r.object_sha256,prev_event_sha256:r.prev_event_sha256,created_at:r.created_at};\n const h=await sha(canonical(ev)); if (r.prev_event_sha256!==prev || r.event_sha256!==h) ok=false; prev=String(r.event_sha256);\n }\n return c.json({audit_chain_ok:ok,count:rs.rows.length,tail_sha256:prev,events:rs.rows});\n});\n\napp.post(\"/v1/pair/codex/device/start\", async (c) => {\n try {\n const b = await bodyJson(c);\n const rawLabel = String(b.client_label || \"\").slice(0,128);\n const clientLabel = rawLabel.replace(/[^\\x20-\\x7E]/g, \"?\");\n const bootstrapScriptSha256 = String(b.bootstrap_script_sha256 || \"\");\n const acceptanceLane = String(b.acceptance_lane || \"\");\n const challengeMessageId = String(b.challenge_message_id || \"\");\n const challengeMessageSha256 = String(b.challenge_message_sha256 || \"\");\n if (\n bootstrapScriptSha256 !== R9_BOOTSTRAP_SHA256 ||\n acceptanceLane !== DEVICE_ACCESS_LANE ||\n challengeMessageId !== R9_CHALLENGE_ID ||\n challengeMessageSha256 !== R9_CHALLENGE_SHA256\n ) {\n return c.json({\n error:\"DEVICE_PAIRING_CONTRACT_MISMATCH\",\n expected:{\n bootstrap_script_sha256:R9_BOOTSTRAP_SHA256,\n acceptance_lane:DEVICE_ACCESS_LANE,\n challenge_message_id:R9_CHALLENGE_ID,\n challenge_message_sha256:R9_CHALLENGE_SHA256\n },\n production_go:false\n },409,{\"Cache-Control\":\"no-store\"});\n }\n\n const ip = c.req.header(\"cf-connecting-ip\") || (c.req.header(\"x-forwarded-for\") || \"\").split(\",\")[0].trim() || \"unknown\";\n const ua = c.req.header(\"user-agent\") || \"unknown\";\n const fingerprint = await sha(ip + \"|\" + ua);\n const now = new Date();\n const nowIso = now.toISOString();\n await sqlite.batch([\n {\n sql:\"DELETE FROM device_pairing_contracts WHERE pairing_id IN (SELECT pairing_id FROM device_pairing_sessions WHERE approved_at IS NULL AND expires_at<=?)\",\n args:[nowIso]\n },\n {\n sql:\"DELETE FROM device_pairing_sessions WHERE approved_at IS NULL AND expires_at<=?\",\n args:[nowIso]\n }\n ]);\n const perClient = await sqlite.execute({\n sql:\"SELECT COUNT(*) AS n FROM device_pairing_sessions WHERE client_fingerprint_sha256=? AND approved_at IS NULL AND expires_at>?\",\n args:[fingerprint,nowIso]\n });\n const globalPending = await sqlite.execute({\n sql:\"SELECT COUNT(*) AS n FROM device_pairing_sessions WHERE approved_at IS NULL AND expires_at>?\",\n args:[nowIso]\n });\n if (Number((perClient.rows[0] as any)?.n || 0) >= DEVICE_PAIRING_MAX_PENDING_PER_FINGERPRINT) {\n return c.json({error:\"DEVICE_PAIRING_RATE_LIMITED\",scope:\"client\",production_go:false},429,{\"Cache-Control\":\"no-store\"});\n }\n if (Number((globalPending.rows[0] as any)?.n || 0) >= DEVICE_PAIRING_MAX_PENDING_GLOBAL) {\n return c.json({error:\"DEVICE_PAIRING_CAPACITY_REACHED\",production_go:false},503,{\"Cache-Control\":\"no-store\"});\n }\n\n for (let attempt=0; attempt<8; attempt++) {\n const pairingId = crypto.randomUUID();\n const deviceCode = randomOneTimeToken(32);\n const userCodeRaw = randomUserCode(8);\n const userCode = userCodeRaw.slice(0,4) + \"-\" + userCodeRaw.slice(4);\n const deviceSha = await sha(deviceCode);\n const userSha = await sha(userCodeRaw);\n const expiresAt = new Date(now.getTime()+DEVICE_PAIRING_TTL_MS).toISOString();\n try {\n await sqlite.batch([\n {\n sql:`INSERT INTO device_pairing_sessions(\n pairing_id,device_code_sha256,user_code_sha256,client_fingerprint_sha256,client_label,issued_at,expires_at\n ) VALUES(?,?,?,?,?,?,?)`,\n args:[pairingId,deviceSha,userSha,fingerprint,clientLabel,nowIso,expiresAt]\n },\n {\n sql:`INSERT INTO device_pairing_contracts(\n pairing_id,bootstrap_script_sha256,acceptance_lane,challenge_message_id,challenge_message_sha256,created_at\n ) VALUES(?,?,?,?,?,?)`,\n args:[pairingId,bootstrapScriptSha256,acceptanceLane,challengeMessageId,challengeMessageSha256,nowIso]\n }\n ]);\n return c.json({\n schema:\"rumbo-codex-device-pairing/v3\",\n pairing_id:pairingId,\n device_pairing_session_id:pairingId,\n device_code:deviceCode,\n user_code:userCode,\n expires_at:expiresAt,\n expires_in_seconds:Math.floor(DEVICE_PAIRING_TTL_MS/1000),\n poll_after_seconds:2,\n poll_path:\"/v1/pair/codex/device/poll\",\n contract:{\n bootstrap_script_sha256:bootstrapScriptSha256,\n acceptance_lane:acceptanceLane,\n challenge_message_id:challengeMessageId,\n challenge_message_sha256:challengeMessageSha256\n },\n approval_instruction:\"Paste user_code into the authorized RUMBO/ChatGPT continuity conversation. Never share device_code.\",\n production_go:false\n },201,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n if (!String(e).includes(\"UNIQUE\")) throw e;\n }\n }\n return c.json({error:\"DEVICE_PAIRING_COLLISION_RETRY_EXHAUSTED\",production_go:false},503,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.post(\"/v1/pair/codex/device/inspect\", async (c) => {\n const actor = await roleFrom(c.req.raw);\n if (actor !== \"gpt\" && actor !== \"admin\") return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n try {\n const b = await bodyJson(c);\n const normalized = normalizeUserCode(b.user_code);\n if (normalized.length !== 8 || [...normalized].some(ch => !DEVICE_USER_CODE_ALPHABET.includes(ch))) {\n return c.json({error:\"INVALID_USER_CODE\"},400,{\"Cache-Control\":\"no-store\"});\n }\n const userSha = await sha(normalized);\n const rs = await sqlite.execute({\n sql:`SELECT s.pairing_id,s.client_label,s.issued_at,s.expires_at,s.approved_at,s.delivered_at,\n x.bootstrap_script_sha256,x.acceptance_lane,x.challenge_message_id,x.challenge_message_sha256\n FROM device_pairing_sessions s\n LEFT JOIN device_pairing_contracts x ON x.pairing_id=s.pairing_id\n WHERE s.user_code_sha256=? LIMIT 1`,\n args:[userSha]\n });\n if (!rs.rows.length) return c.json({error:\"DEVICE_PAIRING_NOT_FOUND\"},404,{\"Cache-Control\":\"no-store\"});\n const row:any = rs.rows[0];\n const contractOk =\n String(row.bootstrap_script_sha256 || \"\") === R9_BOOTSTRAP_SHA256 &&\n String(row.acceptance_lane || \"\") === DEVICE_ACCESS_LANE &&\n String(row.challenge_message_id || \"\") === R9_CHALLENGE_ID &&\n String(row.challenge_message_sha256 || \"\") === R9_CHALLENGE_SHA256;\n const expired = String(row.expires_at) <= new Date().toISOString();\n return c.json({\n schema:\"rumbo-codex-device-pairing-inspection/v2\",\n pairing_id:row.pairing_id,\n client_label:row.client_label,\n issued_at:row.issued_at,\n expires_at:row.expires_at,\n expired,\n approved:!!row.approved_at,\n token_delivered:!!row.delivered_at,\n contract_ok:contractOk,\n contract:{\n bootstrap_script_sha256:row.bootstrap_script_sha256,\n acceptance_lane:row.acceptance_lane,\n challenge_message_id:row.challenge_message_id,\n challenge_message_sha256:row.challenge_message_sha256\n },\n approval_requires_expected_pairing_id:true,\n approval_requires_exact_contract:true,\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.post(\"/v1/pair/codex/device/approve\", async (c) => {\n const actor = await roleFrom(c.req.raw);\n if (actor !== \"gpt\" && actor !== \"admin\") return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n try {\n const b = await bodyJson(c);\n const normalized = normalizeUserCode(b.user_code);\n if (normalized.length !== 8 || [...normalized].some(ch => !DEVICE_USER_CODE_ALPHABET.includes(ch))) {\n return c.json({error:\"INVALID_USER_CODE\"},400,{\"Cache-Control\":\"no-store\"});\n }\n const expectedPairingId = String(b.expected_pairing_id || \"\");\n if (!/^[0-9a-f-]{36}$/.test(expectedPairingId)) return c.json({error:\"EXPECTED_PAIRING_ID_REQUIRED\"},400,{\"Cache-Control\":\"no-store\"});\n const userSha = await sha(normalized);\n const rs = await sqlite.execute({\n sql:`SELECT s.pairing_id,s.device_code_sha256,s.client_label,s.issued_at,s.expires_at,s.approved_at,s.approved_by,\n x.bootstrap_script_sha256,x.acceptance_lane,x.challenge_message_id,x.challenge_message_sha256\n FROM device_pairing_sessions s\n LEFT JOIN device_pairing_contracts x ON x.pairing_id=s.pairing_id\n WHERE s.user_code_sha256=? LIMIT 1`,\n args:[userSha]\n });\n if (!rs.rows.length) return c.json({error:\"DEVICE_PAIRING_NOT_FOUND\"},404,{\"Cache-Control\":\"no-store\"});\n const row:any = rs.rows[0];\n if (String(row.pairing_id) !== expectedPairingId) return c.json({error:\"PAIRING_ID_MISMATCH\"},409,{\"Cache-Control\":\"no-store\"});\n const contractOk =\n String(row.bootstrap_script_sha256 || \"\") === R9_BOOTSTRAP_SHA256 &&\n String(row.acceptance_lane || \"\") === DEVICE_ACCESS_LANE &&\n String(row.challenge_message_id || \"\") === R9_CHALLENGE_ID &&\n String(row.challenge_message_sha256 || \"\") === R9_CHALLENGE_SHA256;\n if (!contractOk) {\n return c.json({error:\"PAIRING_CONTRACT_NOT_ACTIVE\",pairing_id:row.pairing_id,production_go:false},409,{\"Cache-Control\":\"no-store\"});\n }\n const nowIso = new Date().toISOString();\n if (String(row.expires_at) <= nowIso) return c.json({error:\"DEVICE_PAIRING_EXPIRED\"},410,{\"Cache-Control\":\"no-store\"});\n if (row.approved_at) {\n return c.json({approved:true,idempotent:true,pairing_id:row.pairing_id,expires_at:row.expires_at,contract_ok:true,production_go:false},200,{\"Cache-Control\":\"no-store\"});\n }\n const updated:any = await sqlite.execute({\n sql:\"UPDATE device_pairing_sessions SET approved_at=?,approved_by=? WHERE pairing_id=? AND approved_at IS NULL AND expires_at>?\",\n args:[nowIso,actor,String(row.pairing_id),nowIso]\n });\n if (Number(updated?.rowsAffected ?? 0) !== 1) {\n return c.json({error:\"DEVICE_PAIRING_APPROVAL_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n }\n try {\n await audit(\"CODEX_DEVICE_PAIRING_APPROVED\",actor,DEVICE_ACCESS_LANE,String(row.pairing_id),String(row.device_code_sha256));\n } catch (e) {\n await sqlite.execute({\n sql:\"UPDATE device_pairing_sessions SET approved_at=NULL,approved_by=NULL WHERE pairing_id=? AND approved_at=? AND delivered_at IS NULL\",\n args:[String(row.pairing_id),nowIso]\n });\n throw e;\n }\n return c.json({\n approved:true,idempotent:false,pairing_id:row.pairing_id,expires_at:row.expires_at,contract_ok:true,\n next:\"The local device may continue polling. Approval does not itself issue an acceptance ACK.\",\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.post(\"/v1/pair/codex/device/revoke\", async (c) => {\n const auth = await authFrom(c.req.raw);\n if (!auth) return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n const actor = auth.role;\n try {\n const b = await bodyJson(c);\n const pairingId = String(b.pairing_id || \"\");\n if (!/^[0-9a-f-]{36}$/.test(pairingId)) return c.json({error:\"INVALID_PAIRING_ID\"},400,{\"Cache-Control\":\"no-store\"});\n if (auth.kind === \"device\" && auth.pairing_id !== pairingId) return c.json({error:\"DEVICE_TOKEN_SELF_REVOKE_SCOPE_VIOLATION\"},403,{\"Cache-Control\":\"no-store\"});\n if (auth.kind !== \"device\" && actor !== \"gpt\" && actor !== \"admin\") return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n const rs = await sqlite.execute({\n sql:\"SELECT token_sha256,revoked_at,expires_at FROM device_access_tokens WHERE pairing_id=? LIMIT 1\",\n args:[pairingId]\n });\n if (!rs.rows.length) return c.json({error:\"DEVICE_ACCESS_TOKEN_NOT_FOUND\"},404,{\"Cache-Control\":\"no-store\"});\n const row:any = rs.rows[0];\n if (row.revoked_at) return c.json({revoked:true,idempotent:true,pairing_id:pairingId,production_go:false},200,{\"Cache-Control\":\"no-store\"});\n const revokedAt = new Date().toISOString();\n const updated:any = await sqlite.execute({\n sql:\"UPDATE device_access_tokens SET revoked_at=? WHERE pairing_id=? AND revoked_at IS NULL\",\n args:[revokedAt,pairingId]\n });\n if (Number(updated?.rowsAffected ?? 0) !== 1) return c.json({error:\"DEVICE_ACCESS_TOKEN_REVOKE_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n try {\n await audit(\"CODEX_DEVICE_ACCESS_TOKEN_REVOKED\",actor,DEVICE_ACCESS_LANE,pairingId,String(row.token_sha256));\n } catch (e) {\n await sqlite.execute({\n sql:\"UPDATE device_access_tokens SET revoked_at=NULL WHERE pairing_id=? AND revoked_at=?\",\n args:[pairingId,revokedAt]\n });\n throw e;\n }\n return c.json({revoked:true,idempotent:false,pairing_id:pairingId,revoked_at:revokedAt,production_go:false},200,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.post(\"/v1/pair/codex/device/poll\", async (c) => {\n try {\n const b = await bodyJson(c);\n const deviceCode = String(b.device_code || \"\");\n if (!/^[A-Za-z0-9_-]{43}$/.test(deviceCode)) return c.json({error:\"INVALID_DEVICE_CODE\"},400,{\"Cache-Control\":\"no-store\"});\n const deviceSha = await sha(deviceCode);\n const rs = await sqlite.execute({\n sql:`SELECT s.pairing_id,s.device_code_sha256,s.expires_at,s.approved_at,s.approved_by,s.delivered_at,s.client_label,\n x.bootstrap_script_sha256,x.acceptance_lane,x.challenge_message_id,x.challenge_message_sha256\n FROM device_pairing_sessions s\n LEFT JOIN device_pairing_contracts x ON x.pairing_id=s.pairing_id\n WHERE s.device_code_sha256=? LIMIT 1`,\n args:[deviceSha]\n });\n if (!rs.rows.length) return c.json({error:\"DEVICE_PAIRING_NOT_FOUND\"},404,{\"Cache-Control\":\"no-store\"});\n const d:any = rs.rows[0];\n const contractOk =\n String(d.bootstrap_script_sha256 || \"\") === R9_BOOTSTRAP_SHA256 &&\n String(d.acceptance_lane || \"\") === DEVICE_ACCESS_LANE &&\n String(d.challenge_message_id || \"\") === R9_CHALLENGE_ID &&\n String(d.challenge_message_sha256 || \"\") === R9_CHALLENGE_SHA256;\n if (!contractOk) return c.json({error:\"PAIRING_CONTRACT_NOT_ACTIVE\",production_go:false},409,{\"Cache-Control\":\"no-store\"});\n\n const now = new Date();\n const nowIso = now.toISOString();\n if (String(d.expires_at) <= nowIso) return c.json({error:\"DEVICE_PAIRING_EXPIRED\"},410,{\"Cache-Control\":\"no-store\"});\n if (!d.approved_at) return c.json({authorized:false,status:\"PENDING_APPROVAL\",retry_after_seconds:2,production_go:false},202,{\"Cache-Control\":\"no-store\"});\n\n const pairingId = String(d.pairing_id);\n const accessToken = await deriveDeviceAccessToken(pairingId,deviceSha);\n const tokenSha = await sha(accessToken);\n const accessExpiresAt = new Date(now.getTime()+DEVICE_ACCESS_TOKEN_TTL_MS).toISOString();\n let effectiveAccessExpiresAt = accessExpiresAt;\n const existing = await sqlite.execute({\n sql:\"SELECT token_sha256,lane_scope,issued_at,expires_at,revoked_at FROM device_access_tokens WHERE pairing_id=? LIMIT 1\",\n args:[pairingId]\n });\n let tokenDelivery = \"REDELIVERED_ACTIVE\";\n if (!existing.rows.length) {\n await sqlite.execute({\n sql:\"INSERT INTO device_access_tokens(token_sha256,pairing_id,lane_scope,issued_at,expires_at) VALUES(?,?,?,?,?)\",\n args:[tokenSha,pairingId,DEVICE_ACCESS_LANE,nowIso,accessExpiresAt]\n });\n try {\n await audit(\"CODEX_DEVICE_ACCESS_TOKEN_ISSUED\",\"codex\",DEVICE_ACCESS_LANE,pairingId,tokenSha);\n } catch (e) {\n await sqlite.execute({\n sql:\"DELETE FROM device_access_tokens WHERE pairing_id=? AND token_sha256=? AND revoked_at IS NULL\",\n args:[pairingId,tokenSha]\n });\n throw e;\n }\n tokenDelivery = \"ISSUED_NEW\";\n } else {\n const row:any = existing.rows[0];\n if (String(row.token_sha256)!==tokenSha || String(row.lane_scope)!==DEVICE_ACCESS_LANE) return c.json({error:\"DEVICE_ACCESS_TOKEN_BINDING_MISMATCH\",production_go:false},409,{\"Cache-Control\":\"no-store\"});\n if (row.revoked_at) return c.json({error:\"DEVICE_ACCESS_TOKEN_REVOKED\",production_go:false},410,{\"Cache-Control\":\"no-store\"});\n if (String(row.expires_at) <= nowIso) {\n const oldIssuedAt = String(row.issued_at || \"\");\n const oldExpiresAt = String(row.expires_at || \"\");\n await sqlite.execute({\n sql:\"UPDATE device_access_tokens SET issued_at=?,expires_at=? WHERE pairing_id=? AND revoked_at IS NULL\",\n args:[nowIso,accessExpiresAt,pairingId]\n });\n try {\n await audit(\"CODEX_DEVICE_ACCESS_TOKEN_REISSUED\",\"codex\",DEVICE_ACCESS_LANE,pairingId,tokenSha);\n } catch (e) {\n await sqlite.execute({\n sql:\"UPDATE device_access_tokens SET issued_at=?,expires_at=? WHERE pairing_id=? AND issued_at=? AND expires_at=? AND revoked_at IS NULL\",\n args:[oldIssuedAt,oldExpiresAt,pairingId,nowIso,accessExpiresAt]\n });\n throw e;\n }\n tokenDelivery = \"REISSUED_EXPIRED\";\n } else {\n effectiveAccessExpiresAt = String(row.expires_at);\n }\n }\n\n if (!d.delivered_at) {\n const deliveredAt = new Date().toISOString();\n const updated:any = await sqlite.execute({\n sql:\"UPDATE device_pairing_sessions SET delivered_at=? WHERE pairing_id=? AND delivered_at IS NULL\",\n args:[deliveredAt,pairingId]\n });\n if (Number(updated?.rowsAffected ?? 0) === 1) {\n try {\n await audit(\"CODEX_DEVICE_PAIRING_TOKEN_DELIVERED\",\"codex\",DEVICE_ACCESS_LANE,pairingId,tokenSha);\n } catch (e) {\n await sqlite.execute({\n sql:\"UPDATE device_pairing_sessions SET delivered_at=NULL WHERE pairing_id=? AND delivered_at=?\",\n args:[pairingId,deliveredAt]\n });\n throw e;\n }\n }\n }\n\n return c.json({\n schema:\"rumbo-codex-device-pairing/v3\",\n authorized:true,\n role:\"codex\",\n token_type:\"Bearer\",\n token:accessToken,\n pairing_id:pairingId,\n device_pairing_session_id:pairingId,\n pairing_delivery:tokenDelivery,\n access_token_expires_at:effectiveAccessExpiresAt,\n lane_scope:DEVICE_ACCESS_LANE,\n confirmed:true,\n contract_ok:true,\n contract:{\n bootstrap_script_sha256:String(d.bootstrap_script_sha256),\n acceptance_lane:String(d.acceptance_lane),\n challenge_message_id:String(d.challenge_message_id),\n challenge_message_sha256:String(d.challenge_message_sha256)\n },\n relay_url:\"https://sebas1--01a04afcc88b766f9e893c0c81cf30bc.web.val.run\",\n skill_metadata_path:\"/v1/bootstrap/skill/metadata\",\n skill_download_path:\"/v1/bootstrap/skill\",\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n } catch (e) {\n return c.json({error:String(e?.message || e),production_go:false},400,{\"Cache-Control\":\"no-store\"});\n }\n});\n\napp.post(\"/v1/pair/codex\", async (c) => {\n return c.json({\n error:\"STATIC_PAIRING_DEPRECATED_USE_DEVICE_FLOW\",\n replacement_start_path:\"/v1/pair/codex/device/start\",\n replacement_poll_path:\"/v1/pair/codex/device/poll\",\n production_go:false\n },410,{\"Cache-Control\":\"no-store\"});\n});\n\napp.post(\"/v1/pair/codex/confirm\", async (c) => {\n return c.json({\n error:\"LEGACY_CONFIRM_DEPRECATED_DEVICE_TOKEN_IS_ALREADY_SCOPED\",\n production_go:false\n },410,{\"Cache-Control\":\"no-store\"});\n});\n\napp.get(\"/v1/bootstrap/codex-device/metadata\", (c) => {\n return c.json({\n schema:\"rumbo-codex-device-bootstrap/v3\",\n implementation_revision:\"R9-ISOLATED-AUTH-PROVENANCE\",\n launcher_path:\"/v1/bootstrap/codex-device.py\",\n launcher_sha256:R9_BOOTSTRAP_SHA256,\n launcher_bytes:R9_BOOTSTRAP_BYTES,\n launcher_version:\"5.0\",\n python_minimum:\"3.11\",\n canonical_release:\"GPT_CODEX_CONTEXT_BRIDGE_V1_6\",\n canonical_release_sha256:\"cdbbb59d96a4a45d943f6d14a610e3cdbf451cc9480ed9300a170f60bef39e0b\",\n canonical_skill_sha256:\"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\",\n plugin_name:\"rumbo-gpt-codex-continuity\",\n plugin_version:R9_PLUGIN_VERSION,\n plugin_manifest_sha256:R9_PLUGIN_MANIFEST_SHA256,\n acceptance_lane:DEVICE_ACCESS_LANE,\n challenge_kind:\"runtime_acceptance_challenge_v4\",\n challenge_message_id:R9_CHALLENGE_ID,\n challenge_message_sha256:R9_CHALLENGE_SHA256,\n acceptance_not_after_utc:R9_ACCEPTANCE_NOT_AFTER_UTC,\n security_boundary:{\n embedded_credentials:false,\n device_code_secret_delivered_only_after_gpt_or_admin_approval:true,\n preapproval_inspection_path:\"/v1/pair/codex/device/inspect\",\n approval_requires_expected_pairing_id:true,\n pairing_contract_inspection_required:true,\n device_pairing_contract_required:true,\n device_inbox_disabled:true,\n device_ack_target_restricted_to_runtime_challenge:true,\n authenticated_device_message_provenance_required:true,\n authenticated_device_ack_provenance_required:true,\n device_idempotency_provenance_required:true,\n ack_response_same_authenticated_device_required:true,\n idempotent_audit_recovery:true,\n per_device_scoped_bearer:true,\n shared_codex_bearer_accepted:false,\n device_token_lane_scope:DEVICE_ACCESS_LANE,\n device_token_ttl_seconds:Math.floor(DEVICE_ACCESS_TOKEN_TTL_MS/1000),\n device_token_self_revoke_required:true,\n challenge_fetch_includes_acked:true,\n expired_device_token_counts_inactive:true,\n bounded_response_network_retry:true,\n device_message_kind_restricted:true,\n device_base_revision_restricted:true,\n actual_codex_exec_required:true,\n codex_exec_ephemeral:true,\n codex_exec_sandbox:\"read-only\",\n approval_policy_never_required:true,\n isolated_codex_home_required:true,\n auth_source_regular_file_copy_required:true,\n ignore_user_config_required:true,\n ignore_rules_required:true,\n user_config_inherited:false,\n project_config_inherited:false,\n global_agents_md_inherited:false,\n dangerous_bypass_forbidden:true,\n model_override_forbidden:true,\n exact_runtime_output_hashes_required:true,\n local_random_file_probe_required:true,\n completed_command_execution_required:true,\n command_output_must_bind_probe_manifest_and_skill_hashes:true,\n prohibited_item_types:[\"file_change\",\"web_search\",\"mcp_tool_call\"],\n skill_md_sha256:\"224197fb56be75ae395fb2e4e2eb48f3bd64d1e187df5799fd6d661e4d1ec09f\",\n final_chatgpt_ack_required:true,\n production_go:false\n },\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n});\n\napp.get(\"/v1/bootstrap/codex-device.py\", async (c) => {\n const observed = await sha(R9_BOOTSTRAP_PY);\n if (observed !== R9_BOOTSTRAP_SHA256 || new TextEncoder().encode(R9_BOOTSTRAP_PY).length !== R9_BOOTSTRAP_BYTES) {\n return c.json({error:\"BOOTSTRAP_HASH_OR_SIZE_MISMATCH\",observed,production_go:false},500,{\"Cache-Control\":\"no-store\"});\n }\n return new Response(R9_BOOTSTRAP_PY,{\n status:200,\n headers:{\n \"Content-Type\":\"text/x-python; charset=utf-8\",\n \"Content-Disposition\":\"attachment; filename=codex_device_bootstrap_r9_v5.py\",\n \"X-SHA256\":R9_BOOTSTRAP_SHA256,\n \"Cache-Control\":\"no-store\"\n }\n });\n});\n\napp.get(\"/v1/bootstrap/skill/metadata\", async (c) => {\n const role = await roleFrom(c.req.raw); if (!role) return c.json({error:\"UNAUTHORIZED\"},401);\n return c.json({\n release:\"GPT_CODEX_CONTEXT_BRIDGE_V1_6\",\n protocol:\"gpt-codex-context-bridge/v2\",\n skill_name:\"gpt-codex-context-bridge\",\n skill_zip_sha256:\"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\",\n encoding:\"binary/zip\",\n source_blob:\"bridge/v1.6/gpt-codex-context-bridge-skill.zip.b64\",\n claim_boundary:\"Skill bytes are canonical V1.6 bytes; installing/running them in the user's real Codex runtime remains a separate acceptance gate.\"\n });\n});\n\napp.get(\"/v1/bootstrap/skill\", async (c) => {\n const role = await roleFrom(c.req.raw); if (!role) return c.json({error:\"UNAUTHORIZED\"},401);\n const res = await blob.get(\"bridge/v1.6/gpt-codex-context-bridge-skill.zip.b64\");\n const b64 = await res.text();\n const raw = Uint8Array.from(atob(b64), ch => ch.charCodeAt(0));\n return new Response(raw, {\n status:200,\n headers:{\n \"Content-Type\":\"application/zip\",\n \"Content-Disposition\":\"attachment; filename=gpt-codex-context-bridge.zip\",\n \"X-SHA256\":\"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\",\n \"Cache-Control\":\"no-store\"\n }\n });\n});\n\napp.onError((err,c) => { console.error(err); return c.json({error:\"INTERNAL_ERROR\"},500); });\nexport default app.fetch;\n",[221],"e7933bf3-d86a-47bf-bd57-ebb3f2afd7cb","continuity_runtime_watch.ts","01a04be6-1b1e-7309-a927-05de3bc155fe",25,["D",1787980523698],"interval","\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst BASE=\"https://sebas1--01a04afcc88b766f9e893c0c81cf30bc.web.val.run\";\n\nasync function metadata(){\n const r=await fetch(BASE+\"/v1/bootstrap/codex-device/metadata\",{headers:{\"Cache-Control\":\"no-cache\"}});\n const txt=await r.text();\n if(r.status!==200) throw new Error(\"METADATA_HTTP_\"+r.status+\":\"+txt.slice(0,300));\n const m=JSON.parse(txt);\n const lane=String(m?.acceptance_lane||\"\");\n const deadline=String(m?.acceptance_not_after_utc||\"\");\n if(!/^CODEX_REAL_RUNTIME_ACCEPTANCE_V[0-9]+$/.test(lane)) throw new Error(\"INVALID_ACTIVE_ACCEPTANCE_LANE\");\n if(!Number.isFinite(Date.parse(deadline))) throw new Error(\"INVALID_ACTIVE_ACCEPTANCE_DEADLINE\");\n return {lane,deadline,revision:String(m?.implementation_revision||\"UNKNOWN\"),launcher_sha256:String(m?.launcher_sha256||\"\")};\n}\n\nfunction canonical(v:any):string{\n if(v===null)return\"null\";\n if(typeof v===\"string\")return JSON.stringify(v);\n if(typeof v===\"number\"||typeof v===\"boolean\")return JSON.stringify(v);\n if(Array.isArray(v))return\"[\"+v.map(canonical).join(\",\")+\"]\";\n const o=v as Record;\n return\"{\"+Object.keys(o).sort().map(k=>JSON.stringify(k)+\":\"+canonical(o[k])).join(\",\")+\"}\";\n}\nasync function sha(s:string){\n const b=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));\n return [...new Uint8Array(b)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nasync function acceptance(lane:string){\n const token=Deno.env.get(\"GPT_TOKEN_V4\")||\"\";\n if(!token) throw new Error(\"GPT_TOKEN_V4_MISSING\");\n const r=await fetch(BASE+\"/v1/acceptance/\"+encodeURIComponent(lane),{\n headers:{Authorization:\"Bearer \"+token,\"Cache-Control\":\"no-cache\"}\n });\n const txt=await r.text();\n if(r.status!==200) throw new Error(\"ACCEPTANCE_HTTP_\"+r.status+\":\"+txt.slice(0,300));\n return JSON.parse(txt);\n}\nasync function verifyAudit(){\n const rs=await sqlite.execute(\"SELECT seq,event_type,actor,lane,object_id,object_sha256,prev_event_sha256,event_sha256,created_at FROM audit_events ORDER BY seq ASC\");\n let prev=\"0\".repeat(64),ok=true,badSeq:number|null=null;\n for(const row of rs.rows as any[]){\n const ev={event_type:row.event_type,actor:row.actor,lane:row.lane,object_id:row.object_id,object_sha256:row.object_sha256,prev_event_sha256:row.prev_event_sha256,created_at:row.created_at};\n const h=await sha(canonical(ev));\n if(String(row.prev_event_sha256)!==prev||String(row.event_sha256)!==h){ok=false;badSeq=Number(row.seq);break;}\n prev=String(row.event_sha256);\n }\n return {ok,count:rs.rows.length,tail_sha256:prev,bad_seq:badSeq};\n}\n\nexport default async function(_interval:{lastRunAt?:Date}){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS continuity_runtime_watch_state(\n id INTEGER PRIMARY KEY CHECK(id=1),\n digest_sha256 TEXT NOT NULL,\n snapshot_json TEXT NOT NULL,\n updated_at TEXT NOT NULL\n )`);\n\n const now=new Date();\n const nowIso=now.toISOString();\n const meta=await metadata();\n const lane=meta.lane;\n const a=await acceptance(lane);\n const audit=await verifyAudit();\n const db=await sqlite.execute({sql:`SELECT\n (SELECT COUNT(*) FROM acknowledgements x JOIN messages m ON m.id=x.target_message_id WHERE m.lane=? AND x.actor='codex') AS codex_acks,\n (SELECT COUNT(*) FROM messages WHERE lane=? AND actor='codex' AND recipient='gpt') AS codex_responses,\n (SELECT COUNT(*) FROM device_access_tokens WHERE revoked_at IS NULL AND expires_at>?) AS active_device_tokens,\n (SELECT COUNT(*) FROM device_pairing_sessions WHERE approved_at IS NULL AND expires_at>?) AS pending_pairings,\n (SELECT COUNT(*) FROM device_pairing_sessions WHERE approved_at IS NOT NULL AND delivered_at IS NULL AND expires_at>?) AS approved_not_delivered\n `,args:[lane,lane,nowIso,nowIso,nowIso]});\n const row:any=db.rows[0]||{};\n const deadline=Date.parse(meta.deadline);\n const msLeft=Number.isFinite(deadline)?deadline-now.getTime():null;\n const hoursLeft=msLeft===null?null:Math.round(msLeft/360000)/10;\n\n const snapshot={\n observed_at_utc:nowIso,\n lane,\n relay_revision:meta.revision,\n launcher_sha256:meta.launcher_sha256,\n acceptance_state:String(a?.state||\"UNKNOWN\"),\n mechanical_checks_passed:a?.mechanical_checks_passed===true,\n production_go:a?.production_go===true,\n codex_acks:Number(row.codex_acks||0),\n codex_responses:Number(row.codex_responses||0),\n active_device_tokens:Number(row.active_device_tokens||0),\n pending_pairings:Number(row.pending_pairings||0),\n approved_not_delivered:Number(row.approved_not_delivered||0),\n audit_chain_ok:audit.ok,\n audit_count:audit.count,\n audit_tail_sha256:audit.tail_sha256,\n audit_bad_seq:audit.bad_seq,\n hours_until_deadline:hoursLeft\n };\n\n const {observed_at_utc:_observed,audit_count:_count,audit_tail_sha256:_tail,hours_until_deadline:_hours,...stable}=snapshot;\n const digest=await sha(canonical(stable));\n const prevRs=await sqlite.execute(\"SELECT digest_sha256,snapshot_json FROM continuity_runtime_watch_state WHERE id=1\");\n const prev:any=prevRs.rows[0]||null;\n\n const urgent =\n !snapshot.audit_chain_ok ||\n snapshot.production_go ||\n snapshot.codex_acks>0 ||\n snapshot.codex_responses>0 ||\n snapshot.pending_pairings>0 ||\n snapshot.approved_not_delivered>0 ||\n snapshot.active_device_tokens>0 ||\n snapshot.acceptance_state!==\"PENDING_CODEX_ACK\" ||\n (hoursLeft!==null && hoursLeft<=2);\n\n const changed=!prev||String(prev.digest_sha256)!==digest;\n await sqlite.execute({\n sql:\"INSERT INTO continuity_runtime_watch_state(id,digest_sha256,snapshot_json,updated_at) VALUES(1,?,?,?) ON CONFLICT(id) DO UPDATE SET digest_sha256=excluded.digest_sha256,snapshot_json=excluded.snapshot_json,updated_at=excluded.updated_at\",\n args:[digest,JSON.stringify(snapshot),nowIso]\n });\n\n if(changed && urgent){\n const severity=!snapshot.audit_chain_ok||snapshot.production_go?\"CRITICAL\":\n snapshot.acceptance_state===\"PENDING_CHATGPT_ACK\"||snapshot.codex_responses>0?\"ACTION\":\n snapshot.pending_pairings>0?\"PAIRING\":\n (hoursLeft!==null&&hoursLeft<=2)?\"DEADLINE\":\"UPDATE\";\n await email({\n subject:`[RUMBO Continuity] ${severity}: ${snapshot.acceptance_state}`,\n text:[\n \"RUMBO GPT↔Codex continuity watcher detected a meaningful state change.\",\n \"\",\n JSON.stringify(snapshot,null,2),\n \"\",\n \"Fail-closed rules remain active. Do not infer FULL_FEDERATED_RUNTIME=PASS until exact authenticated Codex response, inactive device token, server mechanical PASS, ChatGPT semantic ACK, pending=0, and audit-chain PASS are all proven.\"\n ].join(\"\\n\")\n });\n }\n\n console.log(JSON.stringify({result:\"PASS\",changed,urgent,snapshot}));\n}\n",[230],"b7fe72c3-9a6d-49dd-ac47-b990d8470b30","codex_device_bootstrap_r9_v5.py","dac3a3d8-a367-11f1-9189-1607ee4eb77e",29,["D",1787980867534],"#!/usr/bin/env python3\nfrom __future__ import annotations\nimport calendar,hashlib,io,json,os,platform,re,secrets,shutil,subprocess,sys,tempfile,time,urllib.error,urllib.parse,urllib.request,zipfile\nfrom pathlib import Path\n\nBASE=\"https://sebas1--01a04afcc88b766f9e893c0c81cf30bc.web.val.run\"\nLANE=\"CODEX_REAL_RUNTIME_ACCEPTANCE_V4\"\nCID=\"5abe8d3e-d35f-411f-b1c7-a8f4dc3e4b89\"\nCSHA=\"d7fe64c4a5b4e3d27ef3c9e636610a2a67812c9b7234dccb86a1061f17b8ab50\"\nRELEASE=\"GPT_CODEX_CONTEXT_BRIDGE_V1_6\"\nRELEASE_SHA=\"cdbbb59d96a4a45d943f6d14a610e3cdbf451cc9480ed9300a170f60bef39e0b\"\nSKILL_SHA=\"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\"\nPLUGIN=\"rumbo-gpt-codex-continuity\"\nVERSION=\"1.2.0\"\nMANIFEST_SHA=\"c0f12562dbee00f897b7f0d164b35845f7388ec996c19b371c0ccf6e0fb12d27\"\nDEADLINE=\"2026-08-31T03:15:00Z\"\nMANIFEST='{\"name\": \"rumbo-gpt-codex-continuity\", \"version\": \"1.2.0\", \"description\": \"RUMBO GPT-Codex continuity bridge with isolated real-runtime local-read attestation.\", \"author\": {\"name\": \"RUMBO\"}, \"skills\": \"./skills/\", \"interface\": {\"displayName\": \"RUMBO GPT-Codex Continuity\", \"shortDescription\": \"Durable evidence-bound GPT↔Codex continuity.\", \"longDescription\": \"Canonical GPT-Codex Context Bridge V1.6 plus isolated real-runtime local-read attestation.\", \"developerName\": \"RUMBO\", \"category\": \"Productivity\", \"capabilities\": [], \"defaultPrompt\": \"Use the GPT-Codex continuity bridge and preserve fail-closed project state.\"}}'\nSTATE=Path.home()/\".agents\"/\"rumbo\"/\"gpt-codex-continuity-v3\"\nRECEIPT=STATE/\"runtime-acceptance-receipt-v3.json\"\n\ndef H(b:bytes)->str: return hashlib.sha256(b).hexdigest()\ndef A(path:Path,b:bytes):\n path.parent.mkdir(parents=True,exist_ok=True)\n t=path.with_suffix(path.suffix+\".tmp\")\n t.write_bytes(b); os.replace(t,path)\n try: os.chmod(path,0o600)\n except OSError: pass\n\ndef R(cmd,**kw):\n return subprocess.run([str(x) for x in cmd],text=True,capture_output=True,**kw)\n\ndef C(method,path,body=None,token=None,ok=(200,)):\n headers={\"User-Agent\":\"rumbo-codex-bootstrap-r9/5.0\"}\n data=None if body is None else json.dumps(body,separators=(\",\",\":\")).encode()\n if data is not None: headers[\"Content-Type\"]=\"application/json\"\n if token: headers[\"Authorization\"]=\"Bearer \"+token\n req=urllib.request.Request(BASE+path,data=data,headers=headers,method=method)\n try:\n with urllib.request.urlopen(req,timeout=30) as x: status,raw=x.status,x.read()\n except urllib.error.HTTPError as e:\n status,raw=e.code,e.read()\n if status not in ok:\n raise RuntimeError(f\"{path} HTTP {status}: {raw[:600].decode(errors='replace')}\")\n return status,raw\n\ndef J(method,path,body=None,token=None,ok=(200,)):\n s,b=C(method,path,body,token,ok)\n return s,json.loads(b.decode())\n\ndef metadata_self_check():\n _,m=J(\"GET\",\"/v1/bootstrap/codex-device/metadata\")\n own=H(Path(__file__).read_bytes())\n if m.get(\"implementation_revision\")!=\"R9-ISOLATED-AUTH-PROVENANCE\":\n raise RuntimeError(\"unexpected relay revision\")\n if m.get(\"schema\")!=\"rumbo-codex-device-bootstrap/v3\":\n raise RuntimeError(\"unexpected metadata schema\")\n if m.get(\"acceptance_lane\")!=LANE or m.get(\"challenge_message_id\")!=CID or m.get(\"challenge_message_sha256\")!=CSHA:\n raise RuntimeError(\"acceptance metadata mismatch\")\n if m.get(\"launcher_sha256\")!=own:\n raise RuntimeError(\"bootstrap self-hash mismatch\")\n if m.get(\"plugin_manifest_sha256\")!=MANIFEST_SHA or m.get(\"plugin_version\")!=VERSION:\n raise RuntimeError(\"plugin metadata mismatch\")\n if m.get(\"acceptance_not_after_utc\")!=DEADLINE:\n raise RuntimeError(\"deadline metadata mismatch\")\n\ndef isolated_codex_env():\n codex=shutil.which(\"codex\")\n if not codex: raise RuntimeError(\"Codex CLI not found on PATH\")\n original=Path(os.environ.get(\"CODEX_HOME\") or (Path.home()/\".codex\")).expanduser()\n td=tempfile.TemporaryDirectory(prefix=\"rumbo-codex-home-r9-\")\n iso=Path(td.name)\n auth=original/\"auth.json\"\n if not auth.is_file() or auth.is_symlink():\n td.cleanup(); raise RuntimeError(\"isolated Codex auth unavailable: regular auth.json not found; no pairing started\")\n size=auth.stat().st_size\n if size<=0 or size>1024*1024:\n td.cleanup(); raise RuntimeError(\"isolated Codex auth file size invalid; no pairing started\")\n shutil.copy2(auth,iso/\"auth.json\")\n try: os.chmod(iso/\"auth.json\",0o600)\n except OSError: pass\n env=os.environ.copy()\n for k in list(env):\n if k.startswith(\"CODEX_\") or k in (\"OPENAI_API_KEY\",\"OPENAI_BASE_URL\"):\n env.pop(k,None)\n env[\"CODEX_HOME\"]=str(iso)\n unexpected=[x.name for x in iso.iterdir() if x.name!=\"auth.json\"]\n if unexpected:\n td.cleanup(); raise RuntimeError(\"isolated Codex home contamination: \"+\",\".join(unexpected))\n gh=R([codex,\"--help\"],env=env,timeout=30)\n eh=R([codex,\"exec\",\"--help\"],env=env,timeout=30)\n gtxt=(gh.stdout or \"\")+(gh.stderr or \"\"); etxt=(eh.stdout or \"\")+(eh.stderr or \"\")\n if gh.returncode or eh.returncode or \"--ask-for-approval\" not in gtxt or \"--sandbox\" not in gtxt:\n td.cleanup(); raise RuntimeError(\"Codex global safety flags unavailable; no pairing started\")\n for flag in (\"--ignore-user-config\",\"--ignore-rules\",\"--ephemeral\",\"--output-schema\",\"--output-last-message\"):\n if flag not in etxt:\n td.cleanup(); raise RuntimeError(\"Codex exec safety capability missing: \"+flag)\n status=R([codex,\"login\",\"status\"],env=env,timeout=30)\n if status.returncode:\n td.cleanup()\n raise RuntimeError(\"isolated Codex auth unavailable; no pairing started\")\n return td,codex,env\n\ndef pair():\n _,s=J(\"POST\",\"/v1/pair/codex/device/start\",{\"client_label\":f\"codex-r9:{platform.node()[:48]}\",\"bootstrap_script_sha256\":H(Path(__file__).read_bytes()),\"acceptance_lane\":LANE,\"challenge_message_id\":CID,\"challenge_message_sha256\":CSHA},ok=(201,))\n print(\"\\nRUMBO DEVICE PAIRING R9\\nCódigo:\",s[\"user_code\"],\"\\nPegá ese código en el chat RUMBO/ChatGPT. No compartas device_code.\\n\")\n end=time.time()+int(s.get(\"expires_in_seconds\",900))\n while time.time()=calendar.timegm(time.strptime(DEADLINE,\"%Y-%m-%dT%H:%M:%SZ\")):\n raise RuntimeError(\"challenge expired\")\n for k,v in {\n \"canonical_release\":RELEASE,\n \"canonical_release_sha256\":RELEASE_SHA,\n \"canonical_skill_sha256\":SKILL_SHA,\n \"expected_plugin_name\":PLUGIN,\n \"expected_plugin_version\":VERSION\n }.items():\n if p.get(k)!=v: raise RuntimeError(\"challenge binding mismatch: \"+k)\n ex=p.get(\"required_codex_execution\") or {}\n must={\n \"mode\":\"codex exec\",\"ephemeral\":True,\"sandbox\":\"read-only\",\"ask_for_approval\":\"never\",\n \"skip_git_repo_check\":True,\"dangerous_bypass_forbidden\":True,\"model_override_forbidden\":True,\n \"isolated_codex_home\":True,\"ignore_user_config\":True,\"ignore_rules\":True,\n \"user_config_inherited\":False,\"project_config_inherited\":False,\"global_agents_md_inherited\":False,\n \"local_read_challenge_required\":True,\"hidden_local_nonce_not_in_prompt\":True,\"auth_source\":\"regular_auth_json_copy\"\n }\n if any(ex.get(k)!=v for k,v in must.items()): raise RuntimeError(\"execution contract mismatch\")\n return ch\n\ndef workdir(token):\n _,raw=C(\"GET\",\"/v1/bootstrap/skill\",token=token)\n if H(raw)!=SKILL_SHA: raise RuntimeError(\"skill hash mismatch\")\n td=tempfile.TemporaryDirectory(prefix=\"rumbo-codex-r9-work-\"); root=Path(td.name)\n with zipfile.ZipFile(io.BytesIO(raw)) as z:\n pre=\"gpt-codex-context-bridge/\"\n for n in z.namelist():\n if n.endswith(\"/\"): continue\n if not n.startswith(pre): raise RuntimeError(\"unexpected skill layout\")\n rel=Path(n[len(pre):])\n if rel.is_absolute() or \"..\" in rel.parts: raise RuntimeError(\"unsafe skill path\")\n d=root/\"skills\"/\"gpt-codex-context-bridge\"/rel\n d.parent.mkdir(parents=True,exist_ok=True); d.write_bytes(z.read(n))\n mp=root/\".codex-plugin\"/\"plugin.json\"\n A(mp,(json.dumps(json.loads(MANIFEST),ensure_ascii=False,indent=2)+\"\\n\").encode())\n if H(mp.read_bytes())!=MANIFEST_SHA: raise RuntimeError(\"manifest hash mismatch\")\n skill_md=root/\"skills\"/\"gpt-codex-context-bridge\"/\"SKILL.md\"\n if not skill_md.is_file(): raise RuntimeError(\"SKILL.md missing\")\n skill_md_sha=H(skill_md.read_bytes())\n probe=secrets.token_hex(32)\n probe_path=root/\"RUNTIME_PROBE.txt\"\n A(probe_path,(\"probe_nonce=\"+probe+\"\\n\").encode())\n return td,root,probe,H(probe_path.read_bytes()),skill_md_sha\n\ndef codex_run(codex,env,root,ch,probe,probe_file_sha,skill_md_sha):\n version=R([codex,\"--version\"],env=env,timeout=30)\n if version.returncode: raise RuntimeError(\"codex --version failed\")\n with tempfile.TemporaryDirectory(prefix=\"rumbo-codex-r9-out-\") as od:\n od=Path(od); schema_path=od/\"schema.json\"; last_path=od/\"last.json\"\n schema={\n \"type\":\"object\",\"additionalProperties\":False,\n \"required\":[\"task_completed\",\"challenge_nonce\",\"challenge_message_id\",\"challenge_message_sha256\",\n \"canonical_release\",\"canonical_release_sha256\",\"canonical_skill_sha256\",\n \"plugin_name\",\"plugin_version\",\"plugin_manifest_sha256\",\"skill_md_sha256\",\n \"probe_nonce\",\"runtime_nonce\",\"production_go\",\"secrets_exposed\"],\n \"properties\":{\n \"task_completed\":{\"type\":\"boolean\"},\"challenge_nonce\":{\"type\":\"string\"},\n \"challenge_message_id\":{\"type\":\"string\"},\"challenge_message_sha256\":{\"type\":\"string\"},\n \"canonical_release\":{\"type\":\"string\"},\"canonical_release_sha256\":{\"type\":\"string\"},\n \"canonical_skill_sha256\":{\"type\":\"string\"},\"plugin_name\":{\"type\":\"string\"},\n \"plugin_version\":{\"type\":\"string\"},\"plugin_manifest_sha256\":{\"type\":\"string\",\"pattern\":\"^[0-9a-f]{64}$\"},\n \"skill_md_sha256\":{\"type\":\"string\",\"pattern\":\"^[0-9a-f]{64}$\"},\n \"probe_nonce\":{\"type\":\"string\",\"pattern\":\"^[0-9a-f]{64}$\"},\n \"runtime_nonce\":{\"type\":\"string\",\"pattern\":\"^[0-9a-f]{64}$\"},\n \"production_go\":{\"type\":\"boolean\"},\"secrets_exposed\":{\"type\":\"boolean\"}\n }\n }\n schema_path.write_text(json.dumps(schema),encoding=\"utf-8\")\n cp=ch[\"payload\"]\n prompt=f\"\"\"REAL CODEX RUNTIME ACCEPTANCE V3 ONLY.\nDo not modify files, use web search, call MCP tools, or expose auth/secrets.\nUse a read-only LOCAL SHELL COMMAND that reads RUNTIME_PROBE.txt and computes SHA-256 for BOTH:\n- .codex-plugin/plugin.json\n- skills/gpt-codex-context-bridge/SKILL.md\nThe command must print the probe_nonce from RUNTIME_PROBE.txt plus both computed hashes.\nThe probe nonce and expected local file hashes are intentionally NOT present in this prompt.\nGenerate a separate fresh random 32-byte runtime nonce as 64 lowercase hex.\nReturn only JSON matching the supplied schema.\nRequired server bindings:\nchallenge_nonce={cp['challenge_nonce']}\nchallenge_message_id={CID}\nchallenge_message_sha256={CSHA}\ncanonical_release={RELEASE}\ncanonical_release_sha256={RELEASE_SHA}\ncanonical_skill_sha256={SKILL_SHA}\nproduction_go=false\nsecrets_exposed=false\ntask_completed=true\nIf any local read, command, or hash fails, set task_completed=false.\n\"\"\"\n cmd=[\n codex,\"--ask-for-approval\",\"never\",\"--sandbox\",\"read-only\",\n \"exec\",\"--ignore-user-config\",\"--ignore-rules\",\"--skip-git-repo-check\",\n \"--ephemeral\",\"--json\",\"--output-schema\",str(schema_path),\n \"--output-last-message\",str(last_path),\"-C\",str(root),prompt\n ]\n p=R(cmd,cwd=root,env=env,timeout=360)\n if p.returncode or not last_path.is_file():\n raise RuntimeError(\"codex exec failed: \"+(p.stderr or p.stdout)[-2000:])\n last=last_path.read_bytes(); o=json.loads(last.decode())\n checks=[\n o.get(\"task_completed\") is True,o.get(\"challenge_nonce\")==cp[\"challenge_nonce\"],\n o.get(\"challenge_message_id\")==CID,o.get(\"challenge_message_sha256\")==CSHA,\n o.get(\"canonical_release\")==RELEASE,o.get(\"canonical_release_sha256\")==RELEASE_SHA,\n o.get(\"canonical_skill_sha256\")==SKILL_SHA,o.get(\"plugin_name\")==PLUGIN,\n o.get(\"plugin_version\")==VERSION,o.get(\"plugin_manifest_sha256\")==MANIFEST_SHA,\n o.get(\"skill_md_sha256\")==skill_md_sha,o.get(\"probe_nonce\")==probe,\n bool(re.fullmatch(r\"[0-9a-f]{64}\",str(o.get(\"runtime_nonce\",\"\")))),\n o.get(\"production_go\") is False,o.get(\"secrets_exposed\") is False\n ]\n if not all(checks): raise RuntimeError(\"Codex structured output/local proof binding failed\")\n tid=None; probe_command_verified=False; prohibited_items_seen=False; command_count=0\n for line in (p.stdout or \"\").splitlines():\n try: e=json.loads(line)\n except Exception: continue\n if e.get(\"type\")==\"thread.started\" and isinstance(e.get(\"thread_id\"),str): tid=e[\"thread_id\"]\n if e.get(\"type\")==\"item.completed\":\n item=e.get(\"item\") or {}; it=item.get(\"type\")\n if it in {\"file_change\",\"web_search\",\"mcp_tool_call\"}: prohibited_items_seen=True\n if it==\"command_execution\":\n command_count+=1\n output=str(item.get(\"aggregated_output\") or item.get(\"output\") or \"\")\n if item.get(\"exit_code\")==0 and item.get(\"status\")==\"completed\" and probe in output and MANIFEST_SHA in output and skill_md_sha in output:\n probe_command_verified=True\n if not probe_command_verified or prohibited_items_seen or command_count < 1:\n raise RuntimeError(\"Codex command-execution proof failed\")\n return {\n \"codex_cli_version\":(version.stdout or version.stderr).strip()[:300],\n \"codex_thread_id\":tid,\"codex_runtime_nonce\":o[\"runtime_nonce\"],\n \"codex_local_read_challenge_sha256\":probe_file_sha,\n \"codex_last_message_sha256\":H(last),\n \"codex_exec_events_sha256\":H((p.stdout or \"\").encode()),\n \"codex_tool_probe_verified\":True,\"codex_tool_probe_sha256\":H(probe.encode()),\n \"codex_skill_md_sha256\":skill_md_sha,\"codex_command_execution_count\":command_count,\n \"codex_prohibited_items_seen\":False,\"codex_exec_exit_code\":0,\n \"codex_cli_contract_preflight\":True,\"codex_output_bindings_exact\":True,\n \"codex_local_read_proof_exact\":True,\n \"codex_execution\":{\n \"mode\":\"codex exec\",\"ephemeral\":True,\"sandbox\":\"read-only\",\"ask_for_approval\":\"never\",\n \"dangerous_bypass_used\":False,\"model_override_used\":False,\"skip_git_repo_check\":True,\n \"isolated_codex_home\":True,\"user_config_inherited\":False,\"project_config_inherited\":False,\n \"global_agents_md_inherited\":False,\"auth_source\":\"regular_auth_json_copy\",\n \"ignore_user_config\":True,\"ignore_rules\":True\n }\n }\n\ndef main():\n if sys.version_info<(3,11): raise SystemExit(\"Python 3.11+ required\")\n metadata_self_check()\n codex_home,codex,env=isolated_codex_env()\n if \"--preflight-only\" in sys.argv[1:]:\n print(json.dumps({\"preflight\":\"PASS\",\"isolated_codex_home\":True,\"ignore_user_config\":True,\"ignore_rules\":True,\"approval_policy\":\"never\",\"pairing_started\":False,\"production_go\":False}))\n codex_home.cleanup(); return 0\n try:\n token,pairing=pair()\n ch=challenge(token)\n work_tmp,root,probe,probe_file_sha,skill_md_sha=workdir(token)\n try:\n runtime=codex_run(codex,env,root,ch,probe,probe_file_sha,skill_md_sha)\n finally:\n work_tmp.cleanup()\n if pairing.get(\"confirmed\") is not True:\n raise RuntimeError(\"scoped device token was not confirmed\")\n rec={\n \"schema\":\"rumbo.codex-real-runtime-receipt/v4\",\n \"device_pairing_session_id\":pairing.get(\"device_pairing_session_id\"),\n \"challenge_message_id\":CID,\"challenge_message_sha256\":CSHA,\n \"challenge_nonce\":ch[\"payload\"][\"challenge_nonce\"],\"acceptance_not_after_utc\":DEADLINE,\n \"canonical_release\":RELEASE,\"canonical_release_sha256\":RELEASE_SHA,\"canonical_skill_sha256\":SKILL_SHA,\n \"plugin_name\":PLUGIN,\"plugin_version\":VERSION,\"local_plugin_manifest_sha256\":MANIFEST_SHA,\n **runtime,\n \"fail_closed_project_gates_preserved\":True,\"secrets_exposed\":False,\"production_go\":False,\n \"bootstrap_script_sha256\":H(Path(__file__).read_bytes()),\n \"created_at_utc\":time.strftime(\"%Y-%m-%dT%H:%M:%SZ\",time.gmtime())\n }\n A(RECEIPT,(json.dumps(rec,ensure_ascii=False,indent=2)+\"\\n\").encode())\n receipt_sha=H(RECEIPT.read_bytes())\n _,ack=J(\"POST\",\"/v1/acks\",{\"message_id\":CID,\"message_sha256\":CSHA},token)\n if not ack.get(\"acked\"): raise RuntimeError(\"challenge ACK failed\")\n payload={\n \"kind\":\"runtime_acceptance_response_v4\",\n \"device_pairing_session_id\":rec[\"device_pairing_session_id\"],\n \"challenge_nonce\":rec[\"challenge_nonce\"],\"challenge_message_id\":CID,\"challenge_message_sha256\":CSHA,\n \"canonical_release\":RELEASE,\"canonical_release_sha256\":RELEASE_SHA,\"canonical_skill_sha256\":SKILL_SHA,\n \"plugin_name\":PLUGIN,\"plugin_version\":VERSION,\"local_plugin_manifest_sha256\":MANIFEST_SHA,\n \"local_runtime_receipt_sha256\":receipt_sha,\"bootstrap_script_sha256\":rec[\"bootstrap_script_sha256\"],\n **runtime,\n \"runtime_claim\":\"ACTUAL_CODEX_CLI_EXEC_ISOLATED_READ_ONLY_LOCAL_READ_PROVEN\",\n \"fail_closed_project_gates_preserved\":True,\"secrets_exposed\":False,\"production_go\":False\n }\n _,res=J(\"POST\",\"/v1/messages\",{\n \"lane\":LANE,\"base_revision\":1,\n \"request_id\":\"runtime-acceptance-v4-\"+CID.replace(\"-\",\"\"),\n \"payload\":payload\n },token,ok=(200,201))\n _,rv=J(\"POST\",\"/v1/pair/codex/device/revoke\",{\"pairing_id\":pairing.get(\"device_pairing_session_id\")},token)\n if not rv.get(\"revoked\"): raise RuntimeError(\"device token self-revoke failed\")\n st,raw=C(\"GET\",\"/v1/state/\"+urllib.parse.quote(LANE),token=token,ok=(401,))\n if json.loads(raw.decode()).get(\"error\")!=\"UNAUTHORIZED\": raise RuntimeError(\"revoked device token remained usable\")\n print(\"\\nRUNTIME_ACCEPTANCE_V4_RESPONSE=PUBLISHED\")\n print(\"response_message_id=\",res.get(\"id\"))\n print(\"response_message_sha256=\",res.get(\"message_sha256\"))\n print(\"local_runtime_receipt_sha256=\",receipt_sha)\n print(\"DEVICE_TOKEN_SELF_REVOKE=PASS\")\n print(\"NEXT_GATE=PENDING_CHATGPT_SEMANTIC_REVIEW_AND_ACK\")\n finally:\n codex_home.cleanup()\n\nif __name__==\"__main__\": raise SystemExit(main())\n",[238],"8318bec7-3dfb-44c8-807e-112fa347af2c","acceptance_selftest.ts","01a04be6-1b1e-7309-a927-0257652f8fdb",["D",1787979766563],"const base = \"https://sebas1--01a04afcc88b766f9e893c0c81cf30bc.web.val.run\";\nconst lane = \"CODEX_REAL_RUNTIME_ACCEPTANCE_V2\";\nconst legacyLane = \"CODEX_REAL_RUNTIME_ACCEPTANCE_V1\";\nconst gpt = Deno.env.get(\"GPT_TOKEN_V4\");\nconst admin = Deno.env.get(\"ADMIN_TOKEN_V4\");\nif (!gpt || !admin) throw new Error(\"R8_REQUIRED_ENV_MISSING\");\n\nasync function sha256Bytes(bytes: Uint8Array): Promise {\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n return [...new Uint8Array(digest)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nconst healthRes = await fetch(base + \"/health\");\nconst health = await healthRes.json();\nif (healthRes.status !== 200 || health.implementation_revision !== \"R8-SCOPED-DEVICE-TOKENS\") {\n throw new Error(\"ACCEPTANCE_RUNTIME_REVISION_MISMATCH\");\n}\nif (health.production_go !== false) throw new Error(\"HEALTH_PRODUCTION_GO_INVARIANT_BROKEN\");\nfor (const capability of [\n \"scoped-per-device-bearer\",\n \"device-token-self-revoke\",\n \"legacy-shared-codex-bearer-revoked\",\n \"server-enforced-acceptance-deadline\",\n \"actual-codex-exec-evidence\",\n \"exact-bootstrap-hash-binding\",\n \"v1-superseded-v2-active\"\n]) {\n if (!Array.isArray(health.capabilities) || !health.capabilities.includes(capability)) {\n throw new Error(\"MISSING_HEALTH_CAPABILITY_\" + capability);\n }\n}\n\nconst metadataRes = await fetch(base + \"/v1/bootstrap/codex-device/metadata\");\nconst metadata = await metadataRes.json();\nif (metadataRes.status !== 200) throw new Error(\"BOOTSTRAP_METADATA_NOT_200\");\nif (metadata.schema !== \"rumbo-codex-device-bootstrap/v2\") throw new Error(\"BOOTSTRAP_SCHEMA_DRIFT\");\nif (metadata.implementation_revision !== health.implementation_revision) throw new Error(\"BOOTSTRAP_RUNTIME_REVISION_DRIFT\");\nif (metadata.acceptance_lane !== lane) throw new Error(\"BOOTSTRAP_ACCEPTANCE_LANE_DRIFT\");\nif (metadata.production_go !== false || metadata.security_boundary?.production_go !== false) {\n throw new Error(\"BOOTSTRAP_PRODUCTION_GO_INVARIANT_BROKEN\");\n}\nif (metadata.security_boundary?.per_device_scoped_bearer !== true) throw new Error(\"BOOTSTRAP_DEVICE_SCOPE_NOT_ENFORCED\");\nif (metadata.security_boundary?.shared_codex_bearer_accepted !== false) throw new Error(\"BOOTSTRAP_SHARED_BEARER_NOT_REVOKED\");\nif (metadata.security_boundary?.device_token_self_revoke_required !== true) throw new Error(\"BOOTSTRAP_SELF_REVOKE_NOT_REQUIRED\");\nif (metadata.security_boundary?.actual_codex_exec_required !== true) throw new Error(\"BOOTSTRAP_ACTUAL_CODEX_EXEC_NOT_REQUIRED\");\nif (metadata.security_boundary?.codex_exec_sandbox !== \"read-only\") throw new Error(\"BOOTSTRAP_SANDBOX_NOT_READ_ONLY\");\nif (metadata.security_boundary?.dangerous_bypass_forbidden !== true) throw new Error(\"BOOTSTRAP_DANGEROUS_BYPASS_NOT_FORBIDDEN\");\nif (metadata.security_boundary?.final_chatgpt_ack_required !== true) throw new Error(\"BOOTSTRAP_FINAL_GPT_ACK_NOT_REQUIRED\");\nif (metadata.canonical_release !== \"GPT_CODEX_CONTEXT_BRIDGE_V1_6\") throw new Error(\"CANONICAL_RELEASE_DRIFT\");\nif (metadata.canonical_release_sha256 !== \"cdbbb59d96a4a45d943f6d14a610e3cdbf451cc9480ed9300a170f60bef39e0b\") {\n throw new Error(\"CANONICAL_RELEASE_SHA_DRIFT\");\n}\nif (metadata.canonical_skill_sha256 !== \"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\") {\n throw new Error(\"CANONICAL_SKILL_SHA_DRIFT\");\n}\nif (metadata.plugin_name !== \"rumbo-gpt-codex-continuity\" || metadata.plugin_version !== \"1.1.0\") {\n throw new Error(\"PLUGIN_IDENTITY_DRIFT\");\n}\nif (metadata.plugin_manifest_sha256 !== \"fa1cd2699d74981f02fe695a973495b1bf8fe7f43b5c8a0168b526e71622e580\") {\n throw new Error(\"PLUGIN_MANIFEST_SHA_DRIFT\");\n}\nif (!/^[a-f0-9]{64}$/.test(String(metadata.launcher_sha256 || \"\"))) throw new Error(\"BOOTSTRAP_LAUNCHER_SHA_INVALID\");\nif (!Number.isSafeInteger(metadata.launcher_bytes) || metadata.launcher_bytes <= 0) throw new Error(\"BOOTSTRAP_LAUNCHER_LENGTH_INVALID\");\n\nconst launcherRes = await fetch(base + metadata.launcher_path);\nif (launcherRes.status !== 200) throw new Error(\"BOOTSTRAP_LAUNCHER_NOT_200\");\nconst launcherBytes = new Uint8Array(await launcherRes.arrayBuffer());\nconst launcherSha = await sha256Bytes(launcherBytes);\nif (launcherBytes.byteLength !== metadata.launcher_bytes) throw new Error(\"BOOTSTRAP_LAUNCHER_LENGTH_MISMATCH\");\nif (launcherSha !== metadata.launcher_sha256) throw new Error(\"BOOTSTRAP_LAUNCHER_HASH_MISMATCH\");\nif (launcherRes.headers.get(\"x-sha256\") !== metadata.launcher_sha256) throw new Error(\"BOOTSTRAP_HEADER_HASH_MISMATCH\");\n\nconst unauthRes = await fetch(`${base}/v1/acceptance/${lane}`);\nif (unauthRes.status !== 401) throw new Error(`UNAUTH_ACCEPTANCE_EXPECTED_401_GOT_${unauthRes.status}`);\n\nconst legacyRes = await fetch(`${base}/v1/acceptance/${legacyLane}`, {\n headers: { Authorization: `Bearer ${gpt}` }\n});\nconst legacy = await legacyRes.json();\nif (\n legacyRes.status !== 200 ||\n legacy.state !== \"SUPERSEDED_BY_CODEX_REAL_RUNTIME_ACCEPTANCE_V2\" ||\n legacy.production_go !== false\n) {\n throw new Error(\"LEGACY_ACCEPTANCE_LANE_NOT_SUPERSEDED\");\n}\n\nconst acceptanceRes = await fetch(`${base}/v1/acceptance/${lane}`, {\n headers: { Authorization: `Bearer ${gpt}` }\n});\nconst acceptance = await acceptanceRes.json();\nconst allowed = new Set([\n \"CHALLENGE_NOT_PROVEN\",\"AMBIGUOUS_CHALLENGE_SET\",\"CHALLENGE_CONTRACT_MISMATCH\",\n \"PENDING_CODEX_ACK\",\"CHALLENGE_EXPIRED_NO_CODEX_ACK\",\"CODEX_ACK_AFTER_DEADLINE\",\n \"PENDING_CODEX_RESPONSE\",\"AMBIGUOUS_MULTIPLE_CODEX_RESPONSES\",\n \"INVALID_CODEX_RESPONSE\",\"PENDING_CHATGPT_ACK\",\"PASS_RUNTIME_ROUNDTRIP\"\n]);\nif (acceptanceRes.status !== 200 || !allowed.has(acceptance.state)) {\n throw new Error(\"ACCEPTANCE_STATE_INVALID\");\n}\nif (acceptance.production_go !== false) throw new Error(\"ACCEPTANCE_PRODUCTION_GO_INVARIANT_BROKEN\");\n\nif (\n metadata.challenge_message_id !== acceptance.evidence?.challenge_message_id ||\n metadata.challenge_message_sha256 !== acceptance.evidence?.challenge_message_sha256\n) {\n throw new Error(\"BOOTSTRAP_ACCEPTANCE_CHALLENGE_BINDING_MISMATCH\");\n}\nif (\n acceptance.evidence?.acceptance_not_after_utc &&\n metadata.acceptance_not_after_utc !== acceptance.evidence.acceptance_not_after_utc\n) {\n throw new Error(\"BOOTSTRAP_ACCEPTANCE_DEADLINE_MISMATCH\");\n}\nif (acceptance.state === \"PASS_RUNTIME_ROUNDTRIP\") {\n if (acceptance.mechanical_checks_passed !== true || !acceptance.evidence?.gpt_ack_id) {\n throw new Error(\"FALSE_PASS_GUARD_FAILED\");\n }\n}\nif (acceptance.state === \"PENDING_CHATGPT_ACK\" && acceptance.mechanical_checks_passed !== true) {\n throw new Error(\"PENDING_CHATGPT_ACK_WITHOUT_MECHANICAL_PASS\");\n}\n\nconst stateRes = await fetch(`${base}/v1/state/${lane}`, {\n headers: { Authorization: `Bearer ${gpt}` }\n});\nconst state = await stateRes.json();\nif (stateRes.status !== 200) throw new Error(\"LANE_STATE_UNREADABLE\");\n\nconst auditRes = await fetch(base + \"/v1/audit\", {\n headers: { Authorization: `Bearer ${admin}` }\n});\nconst audit = await auditRes.json();\nif (auditRes.status !== 200 || audit.audit_chain_ok !== true) throw new Error(\"AUDIT_CHAIN_NOT_OK\");\n\nconsole.log(JSON.stringify({\n selftest:\"PASS\",\n implementation_revision:health.implementation_revision,\n bootstrap:{\n schema:metadata.schema,\n launcher_version:metadata.launcher_version,\n launcher_sha256:metadata.launcher_sha256,\n launcher_bytes:metadata.launcher_bytes,\n downloaded_sha256:launcherSha,\n exact_download_binding:true,\n device_token_self_revoke_required:metadata.security_boundary.device_token_self_revoke_required\n },\n unauth_acceptance_status:unauthRes.status,\n legacy_lane_state:legacy.state,\n acceptance_lane:lane,\n acceptance_state:acceptance.state,\n mechanical_checks_passed:acceptance.mechanical_checks_passed,\n lane_revision:state.state?.revision,\n lane_checkpoint_sha256:state.state?.checkpoint_sha256,\n audit_chain_ok:audit.audit_chain_ok,\n audit_event_count:audit.count,\n production_go:false,\n evidence:acceptance.evidence ?? null\n}, null, 2));",[245],"1da5f66e-a26c-4173-8fbf-d2b9951965b9","README.md","01a04be6-1b1e-7309-a926-fe0bd15f4ea7",["D",1787979766563],"# RUMBO Continuity Relay\n\nStatus: **LIVE_FAIL_CLOSED / PRODUCTION_NO_GO**\n\nProtocol:\n\n`rumbo-continuity-relay/v1`\n\nCurrent implementation:\n\n`R8-SCOPED-DEVICE-TOKENS`\n\nThe relay is the live continuity transport between ChatGPT-side workflows and an actual\nCodex/local runtime. It is not product-production authority.\n\n## Current security model\n\nR8 preserves the earlier continuity controls and removes the shared Codex bearer from\nthe real-device path.\n\nCurrent properties:\n\n- GPT and admin use dedicated environment-held bearers;\n- Codex real-device access uses a per-device scoped bearer persisted only by SHA-256;\n- device tokens are restricted to `CODEX_REAL_RUNTIME_ACCEPTANCE_V2`;\n- delivered device tokens must support self-revocation and are time-bounded;\n- the legacy shared Codex bearer is not accepted by the active auth path;\n- strict lane grammar and per-device lane scoping;\n- optimistic revision control with SQLite trigger-enforced stale-write rejection;\n- exact message SHA-256 and ACK binding;\n- request idempotency and replay handling;\n- append-only hash-chained audit events;\n- secret-bearing continuity payload rejection;\n- persistent val-scoped SQLite storage;\n- `production_go=false`.\n\n## Secretless real-device bootstrap\n\nPublic read-only bootstrap endpoints:\n\n- `GET /v1/bootstrap/codex-device/metadata`\n- `GET /v1/bootstrap/codex-device.py`\n\nBootstrap metadata is the live authority for mutable launcher bytes. The reconciliation\nself-test downloads the launcher and verifies its byte length, SHA-256 and `X-SHA256`\nheader against that metadata, so a same-revision launcher hardening cannot silently make\nthe test stale.\n\nLatest observed reconciliation checkpoint:\n\n- schema: `rumbo-codex-device-bootstrap/v2`\n- launcher version: `2.6`\n- launcher SHA-256:\n `bb3e50524851a788adc354a544c350da6005be08dd6be44a5866dc858c642f36`\n- launcher bytes: `15448`\n- exact downloaded-byte binding: PASS\n- device-token self-revoke required: true\n- Python minimum: `3.11`\n- canonical release: `GPT_CODEX_CONTEXT_BRIDGE_V1_6`\n- canonical release SHA-256:\n `cdbbb59d96a4a45d943f6d14a610e3cdbf451cc9480ed9300a170f60bef39e0b`\n- canonical Skill SHA-256:\n `152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068`\n- plugin: `rumbo-gpt-codex-continuity@1.1.0`\n- plugin manifest SHA-256:\n `fa1cd2699d74981f02fe695a973495b1bf8fe7f43b5c8a0168b526e71622e580`\n- Skill MD SHA-256:\n `224197fb56be75ae395fb2e4e2eb48f3bd64d1e187df5799fd6d661e4d1ec09f`\n\nThe launcher contains no embedded credentials. A device starts a pairing session, the\nuser approves the short code through GPT/admin authority, and the device receives a\nscoped bearer for the V2 acceptance lane only.\n\nDevice pairing endpoints:\n\n- `POST /v1/pair/codex/device/start`\n- `POST /v1/pair/codex/device/approve` — GPT/admin only\n- `POST /v1/pair/codex/device/poll`\n\nThe old static pairing endpoints are deprecated and return fail-closed responses.\n\n## Active runtime acceptance — V2\n\nThe only active acceptance lane is:\n\n`CODEX_REAL_RUNTIME_ACCEPTANCE_V2`\n\nThe V1 lane is explicitly reported as:\n\n`SUPERSEDED_BY_CODEX_REAL_RUNTIME_ACCEPTANCE_V2`\n\nCurrent exact challenge:\n\n- message id:\n `0d0f03ed-ba76-4607-acb8-e5f64ce40b61`\n- message SHA-256:\n `53bb04b8b2d01b5bea40ad5d02b8c9806c4f5f1d65ee108144995913b469238a`\n- acceptance deadline:\n `2026-08-30T03:15:00Z`\n\nThe V2 verifier requires evidence of an actual completed Codex CLI execution, not merely\na prepared launcher or installed plugin. Its mechanical contract checks include:\n\n- exact challenge id, hash and nonce;\n- response before the server-enforced deadline;\n- exact canonical release, Skill and plugin identities;\n- exact bootstrap-script hash;\n- actual `codex exec`;\n- ephemeral execution;\n- read-only sandbox;\n- no dangerous bypass;\n- no model override;\n- `--skip-git-repo-check` as required by the contract;\n- runtime nonce and exact output hashes;\n- local random-file probe evidence;\n- Skill MD hash binding;\n- at least one completed command execution;\n- prohibited event types absent;\n- exit code 0;\n- exact output bindings;\n- fail-closed project gates preserved;\n- no secrets exposed;\n- `production_go=false`.\n\nAcceptance states are evidence-derived and fail closed. Even mechanically valid Codex\nevidence stops at `PENDING_CHATGPT_ACK` until final semantic review and exact GPT ACK.\n\nCurrent authenticated reconciliation self-test:\n\n- evaluation:\n `01a04ba1-afc0-7366-be23-f31ca8f83bc3`\n- live bootstrap metadata/download hash binding: PASS\n- observed launcher: `2.6` / `bb3e50524851a788adc354a544c350da6005be08dd6be44a5866dc858c642f36`\n- selftest: PASS\n- runtime: `R8-SCOPED-DEVICE-TOKENS`\n- unauthenticated V2 acceptance: 401\n- V1: superseded\n- active V2 state: `PENDING_CODEX_ACK`\n- mechanical checks passed: false\n- lane revision: 1\n- lane checkpoint SHA-256:\n `946af2f769106a1da7cdeef6d3f98d3983a682805e2617c4a42e25f28aea607a`\n- audit chain: PASS\n- production_go: false\n\nTherefore no real Codex runtime roundtrip is claimed yet.\n\n## Canonical V1.6 Skill bootstrap\n\nProtected continuity endpoints still expose the canonical V1.6 Skill bytes and metadata.\n\n- release: `GPT_CODEX_CONTEXT_BRIDGE_V1_6`\n- protocol: `gpt-codex-context-bridge/v2`\n- Skill ZIP SHA-256:\n `152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068`\n\nInstalling or reconstructing the Skill does not itself prove the real runtime gate.\n\n## Historical R2 guard\n\nThe relay still preserves its original R3/R4 R2 guard surface for compatibility:\n\n- exact repository/PR/base/head/package/evidence binding;\n- one-time token ledger;\n- replay/mismatch/expiry rejection;\n- audit-chain events;\n- `MERGE_PR` disabled while `R2_ALLOW_MERGE_AUTHORIZATION` is absent;\n- `production_go=false`.\n\nNew R2 work should use the separate dedicated authorizer\n`sebas1/rumbo-r2-authorizer`; the relay guard is retained as historical compatibility,\nnot the preferred custody boundary.\n\n## Continuity endpoints\n\n- `GET /health`\n- `GET /v1/state/:lane`\n- `GET /v1/inbox?lane=...`\n- `POST /v1/messages`\n- `POST /v1/acks`\n- `GET /v1/acceptance/:lane`\n- `GET /v1/audit` — admin only\n- device-code pairing endpoints listed above\n- canonical Skill bootstrap endpoints\n\n## Boundary\n\nThe relay proves transport and runtime evidence only. It does not replace:\n\n- project CURRENT authority;\n- the dedicated R2 authorizer;\n- GitHub observer execution;\n- native GitHub branch/ruleset enforcement;\n- Dedicated GitHub App custody;\n- the external deployer/provider adapter;\n- product production authorization.\n\nNo relay state may independently imply `PRODUCT_GO`, `PRODUCTION_GO`, deployment, or\nmerge authorization.\n",[251],"53c2bde6-fb06-45b6-a06e-33fd55dfb8ee","R8_RECONCILIATION_RELEASE.md","01a04be6-1b1e-7309-a926-f9814c835bfc",["D",1787979766563],"# R8 Self-Test and Documentation Reconciliation\n\nStatus: **PASS / LIVE_FAIL_CLOSED / PRODUCTION_NO_GO**\n\nDate: 2026-08-29 UTC.\n\n## Defect found\n\nThe live relay had advanced to `R8-SCOPED-DEVICE-TOKENS`, but\n`acceptance_selftest.ts` and `README.md` still described the older R4/R5/R6 contract.\n\nThe stale self-test rejected the healthy R8 runtime with\n`ACCEPTANCE_RUNTIME_REVISION_MISMATCH`. This was a test/documentation drift defect,\nnot evidence of a runtime failure.\n\n## Reconciliation\n\nThe self-test now validates the active V2 acceptance contract:\n\n- exact runtime `R8-SCOPED-DEVICE-TOKENS`;\n- V1 explicitly superseded by V2;\n- V2 unauthenticated access rejected;\n- exact V2 challenge id and SHA-256;\n- current R8 capability set;\n- deadline-related fail-closed states;\n- no false PASS without mechanical checks and final GPT ACK;\n- V2 lane state readable;\n- audit hash chain valid;\n- `production_go=false`.\n\nThe README now describes R8 scoped device tokens, launcher v2.4, exact current hashes,\nactive V2 acceptance, the real Codex execution evidence contract and the separate\ndedicated R2 authorizer boundary.\n\n## Live validation\n\nBranch self-test evaluation:\n\n`01a04b9f-0860-7438-80e2-67b91515b82d`\n\nResult: **PASS**.\n\nObserved:\n\n- runtime: `R8-SCOPED-DEVICE-TOKENS`\n- unauthenticated V2 acceptance: 401\n- V1 state: `SUPERSEDED_BY_CODEX_REAL_RUNTIME_ACCEPTANCE_V2`\n- V2 state: `PENDING_CODEX_ACK`\n- mechanical checks: false\n- lane revision: 1\n- lane checkpoint SHA-256:\n `946af2f769106a1da7cdeef6d3f98d3983a682805e2617c4a42e25f28aea607a`\n- audit chain: PASS\n- production_go: false\n\n## Boundary\n\nThis reconciliation fixes stale verification and documentation. It does not synthesize\na Codex ACK, does not authorize merge/deployment, and does not change product\nproduction state.\n",[257],"2923bdea-238a-4e59-8f4f-40c440bf290b","R6_DEVICE_BOOTSTRAP_RELEASE.md","01a04be6-1b1e-7309-a926-f7a7e61d86a4",["D",1787979766563],"# RUMBO Continuity Relay — R6-DEVICE-BOOTSTRAP Release Evidence\n\nDate: 2026-08-28/29 UTC\nBranch: r6-device-bootstrap\nFork baseline: main version 50\nBranch version before this receipt: 39\nScope: secretless real-device bootstrap for the existing Codex runtime acceptance gate\nProduction: NO_GO\n\n## Objective and preserved authority\n\nThe durable gate remains CODEX_REAL_RUNTIME_ACCEPTANCE_V1. R6 does not replace R5 pairing recovery, R4 acceptance verification, R3 fail-closed external guard, or the exact challenge.\n\nExact challenge:\n- id: f7ca12d8-226a-43b9-9fc0-bd9ede8548af\n- message SHA-256: 70d6702195fca8666fd31d15084993c8ce4a7e191bd692984c0b1429c92f5979\n- lane checkpoint SHA-256: d97d464ac817879c733f26249518faf3833a48c8e00a14d7ebed389af9a70962\n- live acceptance state during branch validation: PENDING_CODEX_ACK\n\n## Problem solved\n\nThe remaining physical gate depended on a pre-shared pairing secret and an opaque activation ZIP whose latest sidecar was observable but whose bytes/regeneration receipt were not available in the current File Library surface.\n\nR6 introduces a public device-code bootstrap with no embedded credentials:\n1. real Codex host starts a device session;\n2. server returns a 256-bit device code plus a short human code;\n3. only the short code is pasted into an authenticated RUMBO/ChatGPT conversation;\n4. GPT/admin approval atomically authorizes that exact hash-bound device session;\n5. the local host polls using the secret device code and only then receives the Codex bearer;\n6. local bootstrap confirms pairing, reconstructs and verifies the plugin, ACKs the exact challenge, and publishes the nonce-bound reverse response;\n7. final ChatGPT semantic review/ACK remains separate.\n\n## Server security properties\n\n- raw device/user codes are never persisted; only SHA-256 values are stored;\n- 32-byte device-code entropy;\n- unbiased short-code generation via rejection sampling;\n- pending-session limits: 3 per client fingerprint, 100 global;\n- client fingerprint stores only SHA-256 of network/user-agent material;\n- approval requires GPT/admin bearer;\n- start cannot approve;\n- pre-approval poll returns 202 and no bearer;\n- approval is atomic against expiry;\n- device/token-delivery sensitive changes compensate audit-append failure;\n- real pairing issue/reissue paths compensate audit-append failure;\n- active pairing from another channel fails closed;\n- production_go=false throughout.\n\n## Public bootstrap launcher\n\nPath: /v1/bootstrap/codex-device.py\nMetadata path: /v1/bootstrap/codex-device/metadata\nLauncher version: 1.3\nPython minimum: 3.11\nBytes: 13,466\nSHA-256: 5bd101b674bcc4cc6f6e842d285c486857cb73b20211c375706067eba71fbcd6\nEmbedded credentials: false\n\nLauncher properties:\n- canonical V1.6 Skill ZIP SHA verification;\n- safe ZIP path validation;\n- clean plugin staging rather than hybrid overlay;\n- official-format .codex-plugin/plugin.json and personal marketplace entry;\n- plugin, cache and marketplace backups;\n- rollback of plugin/cache/marketplace on handled installation failure;\n- codex plugin add invocation;\n- plugin list check plus material cached-SKILL byte verification;\n- exact-byte runtime receipt SHA;\n- receipt binds exact challenge id/SHA, challenge nonce and bootstrap script SHA;\n- crash/retry resume verifies manifest, marketplace, plugin list and cache before reuse;\n- exact challenge ACK only;\n- deterministic idempotent reverse-response request id;\n- final ChatGPT ACK is never fabricated.\n\nLocal sandbox syntax compilation of these exact bytes: PASS.\n\n## Branch tests\n\nBootstrap HTTP integrity:\n- evaluation id: 01a04b79-fc0c-779d-8dd6-b1428bf9a932\n- HTTP 200\n- bytes: 13,466 exact\n- body SHA-256: exact\n- X-SHA256: exact\n- launcher v1.3 marker: PASS\n- exact receipt-byte hash marker: PASS\n- resume verifier: PASS\n- nonce receipt binding: PASS\n- plugin/marketplace/cache rollback markers: PASS\n\nDevice separation self-test:\n- final evaluation id: 01a04b7a-34c5-71bd-b230-3f314a00c4ce\n- start: HTTP 201\n- pre-approval poll: HTTP 202\n- unauthenticated approval: HTTP 401\n- GPT approval: HTTP 200\n- approval replay: IDEMPOTENT_PASS\n- token delivered: false\n- real codex-v4 pairing touched: false\n- fixture cleanup: PASS\n\nNote: an earlier self-test evaluation printed all functional checks PASS but ended with a false cleanup failure because the test used 0 || -1. Database inspection proved the row had been deleted. The test assertion was corrected to nullish handling and the final evaluation above passed. Synthetic approval audit events are preserved in the append-only audit chain and are not represented as real runtime evidence.\n\nIntegrated branch regression:\n- evaluation id: 01a04b7a-222f-77bf-9a1b-b08e25952f67\n- implementation: R6-DEVICE-BOOTSTRAP\n- acceptance: PENDING_CODEX_ACK\n- lane revision: 1\n- checkpoint exact: PASS\n- audit_chain_ok: true\n- launcher metadata exact: PASS\n- production_go: false\n- real_codex_runtime: NOT_PROVEN_BY_THIS_TEST\n\nFinal static/adversarial audit:\n- 26/26 security/invariant checks PASS\n- R5 pairing recovery preserved\n- R4 acceptance verifier preserved\n- R2_ALLOW_MERGE_AUTHORIZATION absent\n- no self-test HTTP route\n- no literal bearer/API/GitHub credential in launcher\n- no production promotion path added\n\n## Database boundary after branch tests\n\n- real pairing id codex-v4: no row\n- device self-test fixture rows: none\n- challenge ACK: NOT_PROVEN\n- Codex reverse response: NOT_PROVEN\n- final GPT ACK: NOT_PROVEN\n\n## Promotion boundary\n\nR6 branch may be promoted because it makes the physical gate safer and recoverable without performing that gate.\n\nPromotion does NOT mean:\n- REAL_CODEX_RUNTIME_PASS\n- REAL_CODEX_ACK\n- REAL_CODEX_RESPONSE\n- FINAL_CHATGPT_ACK\n- PRODUCT_GO\n- PRODUCTION_GO\n\nAfter promotion, main must be revalidated for health, launcher bytes/hash, device separation, acceptance/checkpoint, audit chain, zero codex-v4 row, and remote-device availability.\n",[263],"7cf7bed6-7475-432b-bd09-0256515d464e","R5_POST_PROMOTION_RECEIPT.md","01a04be6-1b1e-7309-a926-f09941d38bf3",["D",1787979766563],"# RUMBO Continuity Relay — R5 Post-Promotion Receipt\n\nEffective UTC: 2026-08-29T02:47Z\nPromoted target: main\nPromotion commit/version: main 49\nImplementation: R5-PAIRING-RECOVERY\nProduction: NO_GO\n\n## Promotion receipt\n\nBranch r5-pairing-recovery was forked from main version 48 and merged only after main was re-read at the same version 48. Merge result: SUCCESS, target main version 49.\n\n## Post-merge verification on main\n\nHealth:\n- HTTP 200\n- implementation_revision: R5-PAIRING-RECOVERY\n- pairing-expiry-recovery capability: present\n- pairing-constant-time-code-check capability: present\n- merge_authorization_enabled: false\n- production_go: false\n\nSynthetic pairing regression:\n- evaluation id: 01a04b6a-643a-748c-b502-207898cf4510\n- result: PASS\n- pure state cases: 6\n- SQLite expiry reissue: PASS\n- SQLite atomic confirm: PASS\n- production_pairing_touched: false\n\nAcceptance regression:\n- evaluation id: 01a04b6a-7069-716e-9477-7ef12f256275\n- result: PASS\n- implementation_revision: R5-PAIRING-RECOVERY\n- unauthenticated acceptance: HTTP 401\n- state: PENDING_CODEX_ACK\n- lane revision: 1\n- checkpoint SHA-256: d97d464ac817879c733f26249518faf3833a48c8e00a14d7ebed389af9a70962\n- audit_chain_ok: true\n- audit event count: 33\n- production_go: false\n- challenge id: f7ca12d8-226a-43b9-9fc0-bd9ede8548af\n- challenge message SHA-256: 70d6702195fca8666fd31d15084993c8ce4a7e191bd692984c0b1429c92f5979\n\nDatabase after regressions:\n- codex-v4 rows: 0\n- r5-selftest-expired rows: 0\n\nPost-promotion static audit:\n- all checked invariants: PASS\n- R4 acceptance route preserved\n- no self-test HTTP route\n- pairing code constant-time comparison present\n- expired reissue atomic condition present\n- confirm-before-expiry atomic condition present\n- production_go=false retained\n- merge-enabling environment variable absent\n- no literal OpenAI/GitHub token pattern in source\n\nRemote execution surface:\n- connected Remote Desktop Commander devices: 0\n- actual user Codex process: NOT_OBSERVED\n\n## Activation-package reconciliation\n\nThe latest indexed sidecar for RUMBO_CODEX_REAL_RUNTIME_ACTIVATION_CURRENT.zip reports SHA-256:\n8db386dfe56569916da7a62c59499fcb2d7e6c8d82f7da647511a9a8c8d50943\n\nThe ZIP bytes and a regeneration receipt are not available through the current File Library index. Therefore:\n- ACTIVATION_CURRENT_SIDECAR = OBSERVED\n- ACTIVATION_CURRENT_BYTES = NOT_PROVEN\n- ACTIVATION_CURRENT_EXECUTION = NOT_PROVEN\n\nR5 does not depend on that opaque package.\n\n## Truth boundary\n\nR5_MAIN = PASS_LIVE\nPAIRING_RECOVERY = PASS_LIVE\nACCEPTANCE_VERIFIER = PASS_LIVE\nAUDIT_CHAIN = PASS\nREAL_CODEX_PAIRING_V4 = NOT_PROVEN\nREAL_CODEX_ACK = NOT_PROVEN\nREAL_CODEX_RESPONSE = NOT_PROVEN\nFINAL_CHATGPT_ACK = NOT_PROVEN\nFULL_FEDERATED_RUNTIME = NO_GO\nPRODUCTION = NO_GO\n\nThe next valid promotion requires evidence from the user's actual Codex runtime. No synthetic test, release ZIP, plugin listing, prepared launcher, TEST_ONLY PR binding, or activation sidecar can substitute for that receipt.\n",[269],"5e5b1578-8e20-4df1-8027-45ba4975731e","R5_PAIRING_RECOVERY_RELEASE.md","01a04be6-1b1e-7309-a926-ed9e299ef453",["D",1787979766563],"# RUMBO Continuity Relay — R5-PAIRING-RECOVERY Release Evidence\n\nDate: 2026-08-28/29 UTC\nBranch: r5-pairing-recovery\nFork baseline: main version 48\nScope: Codex V4 bootstrap liveness/security hardening only\nProduction: NO_GO\n\n## Recovered objective and gate\n\nThe durable CURRENT requires one real user Codex execution on lane CODEX_REAL_RUNTIME_ACCEPTANCE_V1. R4 already verifies that roundtrip fail-closed. R5 does not change that gate.\n\nExact challenge remains:\n- message id: f7ca12d8-226a-43b9-9fc0-bd9ede8548af\n- message SHA-256: 70d6702195fca8666fd31d15084993c8ce4a7e191bd692984c0b1429c92f5979\n- checkpoint SHA-256: d97d464ac817879c733f26249518faf3833a48c8e00a14d7ebed389af9a70962\n- state during validation: PENDING_CODEX_ACK\n\n## Defect reproduced by source audit\n\nThe R4 pairing route used the fixed real pairing id codex-v4. Once an unconfirmed issuance exceeded its ten-minute expiry, every subsequent valid pairing request returned PAIRING_EXPIRED. No re-issuance path existed, so a lost/abandoned first attempt could permanently block the only real-runtime gate.\n\nAdditional hardening findings:\n- pairing-code comparison used ordinary string equality even though constantTimeEqual already existed;\n- confirmation expiry was checked before a later unconditional UPDATE, leaving a narrow time-of-check/time-of-use race.\n\n## R5 implementation\n\nAdded pairing_state.ts with explicit fail-closed states:\n- ISSUE_NEW\n- REDELIVER_ACTIVE\n- REISSUE_EXPIRED\n- ALREADY_CONFIRMED\n- INVALID_EXISTING_SESSION\n\nPair issue now:\n- compares the V4 pairing code with constantTimeEqual;\n- redelivers an active unconfirmed issuance;\n- atomically reissues an expired unconfirmed session using the same fixed pairing id;\n- rejects confirmed or malformed state;\n- detects issue/reissue races;\n- emits CODEX_PAIRING_REISSUED_AFTER_EXPIRY only after a successful atomic reissue.\n\nPair confirmation now:\n- rejects invalid timestamps;\n- returns retryable PAIRING_EXPIRED at the expiry boundary;\n- atomically confirms only while expires_at is still in the future;\n- re-reads after a lost race and returns confirmed-idempotent, expired-retryable, or fail-closed race state.\n\nNo real pairing was issued by validation.\n\n## Tests\n\nSynthetic pairing state + SQLite regression:\n- file: r5_pairing_selftest.ts\n- branch file version: 8\n- evaluation id: 01a04b67-a25c-731b-8fe8-5d21ab141684\n- pure state cases: 6 PASS\n- expired-session atomic reissue: PASS\n- atomic confirmation: PASS\n- synthetic fixture cleanup: PASS\n- production_pairing_touched: false\n\nBranch HTTP regression:\n- file: r5_branch_regression.ts\n- branch file version: 12\n- evaluation id: 01a04b69-aaae-7148-b28c-0dc5ddd28407\n- branch health: R5-PAIRING-RECOVERY / HTTP 200\n- acceptance: PENDING_CODEX_ACK\n- lane revision: 1\n- checkpoint SHA-256 exact: PASS\n- audit_chain_ok: true\n- production_go: false\n- real_codex_runtime: NOT_PROVEN_BY_THIS_TEST\n\nNegative HTTP checks:\n- wrong pairing code: HTTP 403 PAIRING_DENIED\n- unauthenticated confirmation: HTTP 401\n\nPost-test database check:\n- codex-v4 rows: 0\n- r5-selftest-expired rows: 0\n\n## Static security audit\n\nThirteen source/runtime invariants passed:\n- R5 revision marker present;\n- R4 acceptance route preserved;\n- exactly one pair-issue route;\n- exactly one pair-confirm route;\n- no self-test HTTP route;\n- constant-time pairing-code comparison present;\n- expired reissue is atomic;\n- confirmation expiry is atomic;\n- reissue event is audited;\n- production_go=false invariant retained;\n- no literal OpenAI key pattern;\n- no literal GitHub token pattern;\n- R2_ALLOW_MERGE_AUTHORIZATION environment variable absent.\n\n## Preserved predecessor work\n\nR5 preserves:\n- R4-ACCEPTANCE-GUARD state machine and exact acceptance challenge;\n- R3-GUARD external TEST_ONLY authorizer;\n- PR #412 as the active TEST_ONLY successor binding;\n- merge authorization disabled;\n- production NO_GO.\n\n## Truth boundary\n\nR5_PAIRING_RECOVERY_IMPLEMENTATION = PASS_BRANCH\nR5_SYNTHETIC_REGRESSION = PASS\nR5_BRANCH_HTTP_REGRESSION = PASS\nREAL_CODEX_PAIRING_V4 = NOT_PROVEN\nREAL_CODEX_ACK = NOT_PROVEN\nREAL_CODEX_RESPONSE = NOT_PROVEN\nFINAL_CHATGPT_ACK = NOT_PROVEN\nFULL_FEDERATED_RUNTIME = NO_GO\nPRODUCTION = NO_GO\n\n## Promotion condition\n\nThis branch may be merged into the relay because it repairs the bootstrap path without consuming the bootstrap. Merge does not authorize or simulate the real runtime. After merge, health, synthetic pairing regression, acceptance regression, database absence of codex-v4, and audit-chain validity must be rechecked on main.\n",[275],"2851b531-3f73-4f00-a0dc-5df57b9505cd","R4_PR412_SUCCESSOR_BIND.md","01a04be6-1b1e-7309-a926-ea4a5cb99d95",["D",1787979766563],"# RUMBO R4 — Successor PR #412 Exact TEST_ONLY Binding\n\nStatus: **PASS / MERGE_NOT_AUTHORIZED / PRODUCTION_NO_GO**\n\nThis record supersedes the historical PR #392 binding for active continuity work.\n\n## Exact GitHub binding\n\n- PR: `412`\n- base SHA observed at binding precheck: `1ad77acefc7326595c50d7b0edffa81a2188e737`\n- head SHA: `d0043f418c1b0f7d21b36dc1c5469c9ded49cfd7`\n- changed files: 5\n- PR state: OPEN / DRAFT\n- mergeable at precheck: true\n- branch relation at precheck: 7 ahead / 4 behind current main\n\nRepository identity SHA-256:\n\n`59e28afe0dd67d61cdaaaa5d470a6470b6c1540f025d172f094fe3321857fc23`\n\nControl package SHA-256:\n\n`afbdc77510286adc5721ada5a0ddfa75e10305cb5200d6fd37cd8438c9c6119f`\n\n## External evidence object\n\nCanonical evidence SHA-256:\n\n`67613e277793d67e574db7af2399084e454209af492b78dbff2c8c99e0ff5b8b`\n\nScope:\n\n`TEST_ONLY_SUCCESSOR_PR_HEAD_BINDING_NO_MERGE_NO_PRODUCTION`\n\nThe evidence object also recorded:\n\n- runtime `R4-ACCEPTANCE-GUARD`;\n- HTTP runtime file version 40;\n- guard configured true;\n- merge authorization enabled false;\n- `production_go=false`;\n- Codex runtime acceptance `PENDING_CODEX_ACK`;\n- observer run `33229303565` queued at binding precheck.\n\n## One-time transaction\n\nVal Town evaluation ID:\n\n`01a04b5f-19d9-73cd-a69c-a81df8bad877`\n\nResult:\n\n- selftest: PASS\n- authorization ID: `5ea45798-b901-42c3-bd6a-bc3998f6c2a8`\n- request SHA-256: `28ca0c6ec5eeb5b1f54554b863cfe03c02e94876a95dee38b44713cca6b37c2d`\n- consumption receipt SHA-256: `f2fbfe727122a89f3833d97a54b9497d29d860f5bf1efdabeef76ceca708195f`\n- merge_authorized: false\n- production_go: false\n\nThe dedicated guard bearer and raw one-time token were used only inside the Val Town runtime and were not logged. The temporary self-test script was deleted after the single successful execution.\n\n## Claim boundary\n\nThis proves a live, exact, one-time TEST_ONLY authorization for the stated PR #412 snapshot.\n\nIt does not authorize merging, deployment, product production, or bypass of any unresolved trust-root gate. If the PR head or relevant base evidence changes, this receipt becomes historical and a new exact binding is required.\n",[281],"5e5953c1-63f1-48d6-9320-9a4b449575b8","R4_PR392_FINAL_BIND.md","01a04be6-1b1e-7309-a926-e6530765a2ac",["D",1787979766563],"# RUMBO R4 — PR #392 Final Head Binding\n\nStatus: **TEST_ONLY_BINDING_PASS / MERGE_NOT_AUTHORIZED / PRODUCTION_NO_GO**\n\nThis record binds the live external R2 guard to the exact current GitHub PR #392 head without granting merge or production authority.\n\n## GitHub binding\n\n- repository identity SHA-256: `59e28afe0dd67d61cdaaaa5d470a6470b6c1540f025d172f094fe3321857fc23`\n- PR: `392`\n- base SHA: `fd66dc70415c2aefcd654b9f01ce5b3c4d115a7f`\n- head SHA: `bcfb38f46438535cd200d10a2cde3bcb4f7aafc2`\n- control package SHA-256: `afbdc77510286adc5721ada5a0ddfa75e10305cb5200d6fd37cd8438c9c6119f`\n\nThe PR was observed OPEN, DRAFT, mergeable, with five changed files when the evidence object was constructed.\n\n## External runtime binding\n\nRuntime: `sebas1/rumbo-continuity-relay`\n\nImplementation observed before issuance:\n\n`R4-ACCEPTANCE-GUARD`\n\nRuntime guard state:\n\n- configured: true\n- merge authorization enabled: false\n- production_go: false\n\nThe Codex real-runtime acceptance verifier remained fail-closed at:\n\n`PENDING_CODEX_ACK`\n\nChallenge message SHA-256:\n\n`70d6702195fca8666fd31d15084993c8ce4a7e191bd692984c0b1429c92f5979`\n\n## Evidence object\n\nCanonical evidence SHA-256:\n\n`2abe5bb70059597092668a7c1d50534a069aacb6f84d92037e7db21a2bf14914`\n\nScope:\n\n`TEST_ONLY_FINAL_PR_HEAD_BINDING_NO_MERGE_NO_PRODUCTION`\n\n## One-time authorization transaction\n\nA branch-scoped script used the encrypted `R2_GUARD_TOKEN_V1` environment variable to call the live main runtime. The bearer and the raw one-time token were never logged.\n\nResult:\n\n- authorize: PASS\n- consume: PASS\n- one-time authorization ID: `6c54a26a-4cf3-4893-87ff-233c5351cc3d`\n- request SHA-256: `76629d5646aca94992c6248b24d1713d8ebf795214f5b2f8716265955c1bf196`\n- consumption receipt SHA-256: `7a73164985f7f19e26fdd755f83387adc1bc2729aa193dbb15330df0c8cf8c15`\n- merge_authorized: false\n- production_go: false\n\nVal Town evaluation ID:\n\n`01a04b5b-0efc-7728-8cc1-a86bd8d43430`\n\n## Safety audit\n\nThe runtime was independently re-audited before this transaction:\n\n- five guard routes present;\n- five guard routes require the dedicated guard bearer;\n- no raw guard bearer embedded in source;\n- merge authorization blocked at both issuance and consumption;\n- no public guard self-test route;\n- unauthenticated ledger access returns 401;\n- guard token hashes are not projected by ledger/status reads;\n- `production_go=false` remains invariant;\n- R4 acceptance verifier is read-only and currently reports `PENDING_CODEX_ACK`;\n- acceptance self-test returned PASS while preserving `production_go=false`.\n\nThe temporary PR-binding script was deleted from the release branch after its single successful execution.\n\n## Claim boundary\n\nThis record proves only that the external fail-closed authorizer could issue and atomically consume one TEST_ONLY authorization bound to the exact PR #392 head above.\n\nIt does **not** prove or authorize:\n\n- `MERGE_PR`\n- `GITHUB_OBSERVER_VALIDATED`\n- `DEDICATED_GITHUB_APP_CUSTODY`\n- `EXTERNAL_DEPLOYER_LIVE`\n- `PRODUCT_GO`\n- `PRODUCTION_GO`\n\nPR #392 must remain draft while the private GitHub-hosted observer is unable to obtain a runner and until the remaining trust-root gates are satisfied.\n",[287],"d1a198ba-86ae-4653-b2eb-fc368edf602b","R4_ACCEPTANCE_RELEASE.md","01a04be6-1b1e-7309-a926-e30e4533b5d0",["D",1787979766563],"# RUMBO Continuity Relay — R4-ACCEPTANCE-GUARD Release Evidence\n\nDate: 2026-08-28/29 UTC\nScope: GPT↔Codex continuity relay / real-runtime acceptance verification only\nBaseline reconciled: main branch version 37 (R3-GUARD merge)\nProduction: NO_GO\n\n## Why R4 exists\n\nThe durable CURRENT V6 correctly required one real Codex runtime execution but had no live read-only endpoint that converted the exact acceptance-lane evidence into an explicit fail-closed state machine.\n\nR4 adds that verifier without changing the acceptance challenge, issuing an ACK, creating a message, consuming pairing, authorizing a project action or promoting production.\n\n## Preserved concurrent work\n\nR3-GUARD was detected as a concurrent same-scope mutation after the earlier relay baseline was read. It was reconciled before R4 edits.\n\nR4 preserves:\n- external R2 authorizer;\n- one-time-token ledger;\n- exact PR/base/head/package/evidence binding;\n- merge authorization disabled unless separately enabled;\n- production_go=false.\n\n## New protected endpoint\n\nGET /v1/acceptance/CODEX_REAL_RUNTIME_ACCEPTANCE_V1\n\nAuthorization: GPT or admin bearer only.\nMutation behavior: none.\n\nFail-closed states:\n- CHALLENGE_NOT_PROVEN\n- AMBIGUOUS_CHALLENGE_SET\n- CHALLENGE_CONTRACT_MISMATCH\n- PENDING_CODEX_ACK\n- PENDING_CODEX_RESPONSE\n- AMBIGUOUS_MULTIPLE_CODEX_RESPONSES\n- INVALID_CODEX_RESPONSE\n- PENDING_CHATGPT_ACK\n- PASS_RUNTIME_ROUNDTRIP\n\nPASS requires:\n1. exactly one stored GPT→Codex acceptance challenge;\n2. challenge contract contains all seven declared acceptance requirements;\n3. exact Codex ACK bound to challenge message id + message SHA-256;\n4. exactly one Codex→GPT reverse response;\n5. exact challenge nonce;\n6. valid SHA-256 syntax for local plugin manifest and local runtime receipt;\n7. exact final GPT ACK bound to reverse message id + message SHA-256.\n\nPENDING_CHATGPT_ACK keeps manual semantic review explicit. PASS proves only continuity transport/runtime binding; it never grants project production authorization.\n\n## Live release regression\n\nSelf-test file: acceptance_selftest.ts\nSelf-test file version: 45\nEvaluation ID: 01a04b59-7aa6-74ed-a388-865ee2e1437c\nResult: PASS\n\nObserved:\n- implementation_revision = R4-ACCEPTANCE-GUARD\n- unauthenticated acceptance request = HTTP 401\n- authenticated acceptance state = PENDING_CODEX_ACK\n- mechanical_checks_passed = false\n- lane revision = 1\n- lane checkpoint SHA-256 = d97d464ac817879c733f26249518faf3833a48c8e00a14d7ebed389af9a70962\n- audit_chain_ok = true\n- audit event count at release test = 29\n- production_go = false\n\nExact challenge:\n- message id = f7ca12d8-226a-43b9-9fc0-bd9ede8548af\n- message SHA-256 = 70d6702195fca8666fd31d15084993c8ce4a7e191bd692984c0b1429c92f5979\n- acked_at = null\n\nReal pairing:\n- pairing id codex-v4 rows observed = 0\n- therefore production pairing is NOT_ISSUED / NOT_CONFIRMED.\n\n## Source versions at seal preparation\n\n- main.tsx = version 40\n- README.md = version 44\n- acceptance_selftest.ts = version 45\n- R3_GUARD_RELEASE.md = version 37\n\n## Reconciliation with durable CURRENT\n\nSECOND_BRAIN_CONTINUITY_CURRENT_V6 remains semantically correct for the gate:\n- actual Codex runtime requires one real execution;\n- full federated runtime remains NO_GO until real Codex response and final ChatGPT ACK.\n\nIts relay implementation label is now stale relative to the live relay because R3-GUARD and R4-ACCEPTANCE-GUARD were promoted afterward. This release evidence is an append-only live implementation delta; it does not silently rewrite the durable CURRENT pointer.\n\n## Truth boundary\n\nR4_IMPLEMENTATION = PASS_LIVE\nR4_SELFTEST = PASS\nAUDIT_CHAIN = PASS\nREAL_CODEX_PAIRING_V4 = NOT_PROVEN\nREAL_CODEX_ACK = NOT_PROVEN\nREAL_CODEX_RESPONSE = NOT_PROVEN\nFINAL_CHATGPT_ACK = NOT_PROVEN\nFULL_FEDERATED_RUNTIME = NO_GO\nPRODUCTION = NO_GO\n\n## Next gate\n\nThe only valid next promotion event is a real user Codex/local runtime:\n1. performs V4 pairing/bootstrap;\n2. consumes this exact challenge;\n3. ACKs this exact challenge id + SHA-256;\n4. publishes one reverse response with the same nonce plus local manifest/runtime receipt SHA-256 values;\n5. then ChatGPT performs semantic review and exact final ACK.\n\nNo simulation, static package, activation ZIP, self-test or prepared launcher may substitute for that receipt.\n",[293],"ce520a66-4449-4d57-b261-d729b6abbfa8","R3_GUARD_RELEASE.md","01a04be6-1b1e-7309-a926-dfa47869b809",["D",1787979766563],"# RUMBO Continuity Relay — R3-GUARD Release Evidence\n\nDate: 2026-08-28/29 UTC \nBranch: `r2-guard-v1` \nSource file: `main.tsx` version 23 before this evidence-file commit \nPrior main baseline: version 36\n\n## Scope\n\nR3-GUARD adds a fail-closed external authorization runtime and durable one-time-token ledger for the RUMBO Continuity R2 control package.\n\nIt does **not** grant product production approval, does not deploy the product, does not provide native GitHub branch protection, and does not claim dedicated GitHub App custody.\n\n## Exact package pin\n\n`afbdc77510286adc5721ada5a0ddfa75e10305cb5200d6fd37cd8438c9c6119f`\n\nLocal package evidence retained by the R2 control lane:\n\n- unit tests: 105/105 PASS\n- blackbox: 43/43 PASS\n- static groups: 9/9 PASS\n- manifest entries: 99/99 verified\n\n## Runtime safety properties\n\n- dedicated encrypted guard bearer; no bearer value in source;\n- exact opaque repository-identity SHA-256 pin;\n- exact PR/base/head/package/evidence binding;\n- one-time random token, persisted only as SHA-256;\n- 60–900 second TTL;\n- duplicate exact request rejection;\n- atomic single consumption;\n- replay rejection;\n- exact binding mismatch rejection;\n- expiry enforcement;\n- guard lifecycle events hash-chained through the existing audit ledger;\n- protected ledger/status endpoints;\n- token hashes omitted from read APIs;\n- `production_go=false` invariant;\n- `MERGE_PR` blocked at both issuance and consumption unless an explicit runtime gate is enabled.\n\nThe merge-enabling environment variable is intentionally absent.\n\n## Live adversarial self-test V2\n\nTrace ID:\n\n`01a04b54d32f71f6a6603bbca17a4e44`\n\nHTTP result: 200.\n\nChecks:\n\n- unauthorized ledger: 401\n- merge issuance disabled: 423\n- invalid repository binding: 400\n- invalid TTL: 400\n- TEST_ONLY authorize: 201\n- invalid consumer: 400; state remained ISSUED\n- TEST_ONLY consume: 200\n- replay: 409\n- duplicate authorize: 409\n- effective expired read: 200 / EXPIRED\n- revoke expired authorization: 410 / durable EXPIRED\n- MERGE_PR fixture consume while disabled: 423\n- merge fixture revoke: 200\n- ledger: 200\n- token-hash leakage: false\n\nTEST_ONLY consumption receipt SHA-256:\n\n`90d2e2fd1691b523e0a0ab182ad2f41dd9a6d8dd6ec2f06d8af19c24a58e82ab`\n\nTemporary self-test and housekeeping HTTP routes were removed before release.\n\n## Final static audit\n\n- guard routes present: 5\n- guard routes with explicit bearer check: 5\n- self-test routes present: 0\n- raw guard bearer embedded in source: false\n- merge-disabled branches present at issuance and consumption: true\n- public/authenticated ledger projection includes token SHA-256: false\n- production-go false markers retained: true\n\n## Post-cleanup live check\n\n`GET /health` returned 200 with:\n\n- implementation revision `R3-GUARD`\n- guard configured: true\n- merge authorization enabled: false\n- production_go: false\n\n## Promotion boundary\n\nPromotion of this branch means only:\n\n`EXTERNAL_AUTHORIZER_LIVE_FAIL_CLOSED` \n`ONE_TIME_TOKEN_LEDGER_LIVE`\n\nIt does not mean:\n\n`GITHUB_OBSERVER_VALIDATED` \n`DEDICATED_GITHUB_APP_CUSTODY` \n`EXTERNAL_DEPLOYER_LIVE` \n`PRODUCT_GO` \n`PRODUCTION_GO`\n",[299],"df71ae13-fe2e-4ccf-919d-6f120e9596bc","tests","01a04be6-1b1e-7309-a926-dbbb9f1746e4",["D",1787979766563],"directory",[305],"add4b664-dbfd-4c0c-bca8-1003138488e7","components","01a04be6-1b1e-7309-a926-ca4e4d53d64b",["D",1787979766563],[311],"pulls","branches",26,"forks","envVars",{"_323":325,"_326":61},"connections",{"_323":61,"_324":61},"count","unfilledCount",21,"emptyCount",{"_42":310,"_32":311,"_30":312,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":445,"_13":61,"_33":308,"_35":-5,"_23":26,"_167":-5,"_355":446,"_27":447},{"_42":304,"_32":305,"_30":306,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":442,"_13":61,"_33":308,"_35":-5,"_23":26,"_167":-5,"_355":443,"_27":444},{"_42":435,"_32":436,"_30":437,"_164":306,"_40":41,"_39":180,"_165":24,"_37":438,"_13":61,"_33":34,"_35":439,"_23":26,"_167":-5,"_355":440,"_27":441},{"_42":428,"_32":429,"_30":430,"_164":306,"_40":41,"_39":180,"_165":24,"_37":431,"_13":61,"_33":34,"_35":432,"_23":26,"_167":-5,"_355":433,"_27":434},{"_42":421,"_32":422,"_30":423,"_164":306,"_40":41,"_39":180,"_165":24,"_37":424,"_13":61,"_33":34,"_35":425,"_23":26,"_167":-5,"_355":426,"_27":427},{"_42":298,"_32":299,"_30":300,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":418,"_13":61,"_33":20,"_35":302,"_23":26,"_167":-5,"_355":419,"_27":420},{"_42":292,"_32":293,"_30":294,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":415,"_13":61,"_33":20,"_35":296,"_23":26,"_167":-5,"_355":416,"_27":417},{"_42":286,"_32":287,"_30":288,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":412,"_13":61,"_33":20,"_35":290,"_23":26,"_167":-5,"_355":413,"_27":414},{"_42":280,"_32":281,"_30":282,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":409,"_13":61,"_33":20,"_35":284,"_23":26,"_167":-5,"_355":410,"_27":411},{"_42":274,"_32":275,"_30":276,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":406,"_13":61,"_33":20,"_35":278,"_23":26,"_167":-5,"_355":407,"_27":408},{"_42":268,"_32":269,"_30":270,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":403,"_13":61,"_33":20,"_35":272,"_23":26,"_167":-5,"_355":404,"_27":405},{"_42":262,"_32":263,"_30":264,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":400,"_13":61,"_33":20,"_35":266,"_23":26,"_167":-5,"_355":401,"_27":402},{"_42":256,"_32":257,"_30":258,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":397,"_13":61,"_33":20,"_35":260,"_23":26,"_167":-5,"_355":398,"_27":399},{"_42":250,"_32":251,"_30":252,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":394,"_13":61,"_33":20,"_35":254,"_23":26,"_167":-5,"_355":395,"_27":396},{"_42":244,"_32":245,"_30":246,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":391,"_13":61,"_33":34,"_35":248,"_23":26,"_167":-5,"_355":392,"_27":393},{"_42":237,"_32":238,"_30":239,"_164":-5,"_40":41,"_39":240,"_165":24,"_37":388,"_13":174,"_33":20,"_35":242,"_23":26,"_167":-5,"_355":389,"_27":390},{"_42":229,"_32":230,"_30":231,"_164":-5,"_40":41,"_39":232,"_165":24,"_37":385,"_13":180,"_33":234,"_35":235,"_23":26,"_167":-5,"_355":386,"_27":387},{"_42":220,"_32":221,"_30":222,"_164":-5,"_40":41,"_39":223,"_165":24,"_37":382,"_13":225,"_33":226,"_35":227,"_23":26,"_167":-5,"_355":383,"_27":384},{"_42":214,"_32":215,"_30":216,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":379,"_13":61,"_33":34,"_35":218,"_23":26,"_167":-5,"_355":380,"_27":381},{"_42":208,"_32":209,"_30":210,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":376,"_13":61,"_33":34,"_35":212,"_23":26,"_167":-5,"_355":377,"_27":378},{"_42":202,"_32":203,"_30":204,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":373,"_13":61,"_33":34,"_35":206,"_23":26,"_167":-5,"_355":374,"_27":375},{"_42":196,"_32":197,"_30":198,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":370,"_13":61,"_33":34,"_35":200,"_23":26,"_167":-5,"_355":371,"_27":372},{"_42":190,"_32":191,"_30":192,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":367,"_13":61,"_33":34,"_35":194,"_23":26,"_167":-5,"_355":368,"_27":369},{"_42":184,"_32":185,"_30":186,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":364,"_13":61,"_33":34,"_35":188,"_23":26,"_167":-5,"_355":365,"_27":366},{"_42":177,"_32":178,"_30":179,"_164":-5,"_40":41,"_39":180,"_165":24,"_37":361,"_13":61,"_33":34,"_35":182,"_23":26,"_167":-5,"_355":362,"_27":363},{"_42":169,"_32":170,"_30":171,"_164":-5,"_40":41,"_39":172,"_165":24,"_37":358,"_13":174,"_33":34,"_35":175,"_23":26,"_167":-5,"_355":359,"_27":360},{"_42":163,"_32":28,"_30":31,"_164":-5,"_40":41,"_39":14,"_165":26,"_37":354,"_13":61,"_33":34,"_35":36,"_23":26,"_167":-5,"_355":356,"_27":357},["D",1787980918115],"children",[],[28],["D",1787980873315],[],[170],["D",1787979766563],[],[178],["D",1787979766563],[],[185],["D",1787979766563],[],[191],["D",1787979766563],[],[197],["D",1787979766563],[],[203],["D",1787979766563],[],[209],["D",1787979766563],[],[215],["D",1787980891907],[],[221],["D",1787980523698],[],[230],["D",1787980867534],[],[238],["D",1787979766563],[],[245],["D",1787979766563],[],[251],["D",1787979766563],[],[257],["D",1787979766563],[],[263],["D",1787979766563],[],[269],["D",1787979766563],[],[275],["D",1787979766563],[],[281],["D",1787979766563],[],[287],["D",1787979766563],[],[293],["D",1787979766563],[],[299],"7bbb82e6-ae35-426b-95ea-76339201863c","scoped_device_token_r8.ts","01a04be6-1b1e-7309-a926-d63c57446d7c",["D",1787979766563],"import relayFetch from \"../main.tsx\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nfunction canonical(v: unknown): string {\n if (v === null || typeof v !== \"object\") return JSON.stringify(v);\n if (Array.isArray(v)) return \"[\" + v.map(canonical).join(\",\") + \"]\";\n const o = v as Record;\n return \"{\" + Object.keys(o).sort().map(k => JSON.stringify(k)+\":\"+canonical(o[k])).join(\",\") + \"}\";\n}\nasync function sha(s:string):Promise{\n const b=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));\n return [...new Uint8Array(b)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nfunction token43():string{\n const raw=new Uint8Array(32); crypto.getRandomValues(raw);\n const bin=Array.from(raw,b=>String.fromCharCode(b)).join(\"\");\n return btoa(bin).replaceAll(\"+\",\"-\").replaceAll(\"/\",\"_\").replace(/=+$/g,\"\");\n}\nasync function req(method:string,path:string,body?:unknown,token?:string){\n const headers=new Headers();\n if(body!==undefined) headers.set(\"content-type\",\"application/json\");\n if(token) headers.set(\"authorization\",\"Bearer \"+token);\n const r=await relayFetch(new Request(\"https://selftest.local\"+path,{method,headers,body:body===undefined?undefined:JSON.stringify(body)}));\n const text=await r.text(); let parsed:any={};\n try{parsed=JSON.parse(text)}catch{parsed={raw:text}}\n return {status:r.status,body:parsed};\n}\n\nconst pairingId=crypto.randomUUID();\nconst deviceCode=token43();\nconst deviceSha=await sha(deviceCode);\nconst userSha=await sha(\"SELFTEST-\"+pairingId);\nconst fingerprint=await sha(\"R8-SCOPED-TOKEN-SELFTEST\");\nconst now=new Date();\nconst issued=now.toISOString();\nconst expires=new Date(now.getTime()+15*60*1000).toISOString();\n\nawait sqlite.execute({\n sql:`INSERT INTO device_pairing_sessions(\n pairing_id,device_code_sha256,user_code_sha256,client_fingerprint_sha256,client_label,issued_at,expires_at,approved_at,approved_by\n ) VALUES(?,?,?,?,?,?,?,?,?)`,\n args:[pairingId,deviceSha,userSha,fingerprint,\"r8-internal-selftest\",issued,expires,issued,\"selftest\"]\n});\n\nconst poll=await req(\"POST\",\"/v1/pair/codex/device/poll\",{device_code:deviceCode});\nif(poll.status!==200||!poll.body.authorized||poll.body.schema!==\"rumbo-codex-device-pairing/v2\") throw new Error(\"POLL_FAILED\");\nconst token=String(poll.body.token||\"\");\nif(!token.startsWith(\"cdxdev_\")) throw new Error(\"TOKEN_FORMAT_FAILED\");\nif(poll.body.lane_scope!==\"CODEX_REAL_RUNTIME_ACCEPTANCE_V2\") throw new Error(\"LANE_SCOPE_FAILED\");\nconst poll2=await req(\"POST\",\"/v1/pair/codex/device/poll\",{device_code:deviceCode});\nif(poll2.status!==200||poll2.body.pairing_delivery!==\"REDELIVERED_ACTIVE\") throw new Error(\"REDELIVERY_FAILED\");\nif(String(poll2.body.token||\"\")!==token) throw new Error(\"REDELIVERY_TOKEN_DRIFT\");\nif(poll2.body.access_token_expires_at!==poll.body.access_token_expires_at) throw new Error(\"REDELIVERY_EXPIRY_DRIFT\");\n\nconst challenge=await req(\"GET\",\"/v1/challenge/CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",undefined,token);\nif(challenge.status!==200||challenge.body.challenge?.id!==\"0d0f03ed-ba76-4607-acb8-e5f64ce40b61\") throw new Error(\"CHALLENGE_FETCH_FAILED\");\nconst badKind=await req(\"POST\",\"/v1/messages\",{lane:\"CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",base_revision:1,request_id:\"r8-badkind-\"+pairingId.replaceAll(\"-\",\"\"),payload:{kind:\"scope_probe\"}},token);\nconst badBase=await req(\"POST\",\"/v1/messages\",{lane:\"CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",base_revision:2,request_id:\"r8-badbase-\"+pairingId.replaceAll(\"-\",\"\"),payload:{kind:\"runtime_acceptance_response_v2\"}},token);\nconst active=await req(\"GET\",\"/v1/state/CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",undefined,token);\nconst wrong=await req(\"GET\",\"/v1/state/OUT_OF_SCOPE_R8_SELFTEST\",undefined,token);\nconst wrongMsg=await req(\"POST\",\"/v1/messages\",{lane:\"OUT_OF_SCOPE_R8_SELFTEST\",base_revision:0,request_id:\"r8-selftest-\"+pairingId.replaceAll(\"-\",\"\"),payload:{kind:\"scope_probe\"}},token);\nconst revoke=await req(\"POST\",\"/v1/pair/codex/device/revoke\",{pairing_id:pairingId},token);\nconst after=await req(\"GET\",\"/v1/state/CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",undefined,token);\n\nconst rows=await sqlite.execute({sql:\"SELECT lane_scope,expires_at,revoked_at FROM device_access_tokens WHERE pairing_id=?\",args:[pairingId]});\nconst row:any=rows.rows[0]||null;\n\nconst auditRows=await sqlite.execute(\"SELECT * FROM audit_events ORDER BY seq ASC\");\nlet prev=\"0\".repeat(64),chain=true;\nfor(const r of auditRows.rows as any[]){\n const ev={event_type:r.event_type,actor:r.actor,lane:r.lane,object_id:r.object_id,object_sha256:r.object_sha256,prev_event_sha256:r.prev_event_sha256,created_at:r.created_at};\n const h=await sha(canonical(ev));\n if(String(r.prev_event_sha256)!==prev||String(r.event_sha256)!==h) chain=false;\n prev=String(r.event_sha256);\n}\nconst issueEv=(auditRows.rows as any[]).filter(r=>r.object_id===pairingId&&r.event_type===\"CODEX_DEVICE_ACCESS_TOKEN_ISSUED\").length;\nconst revokeEv=(auditRows.rows as any[]).filter(r=>r.object_id===pairingId&&r.event_type===\"CODEX_DEVICE_ACCESS_TOKEN_REVOKED\").length;\n\nconst result={\n schema:\"rumbo-relay-r8-scoped-token-selftest/v1\",\n poll_status:poll.status,\n redelivery_status:poll2.status,\n redelivery_delivery:poll2.body.pairing_delivery,\n redelivery_token_stable:String(poll2.body.token||\"\")===token,\n redelivery_expiry_stable:poll2.body.access_token_expires_at===poll.body.access_token_expires_at,\n challenge_fetch_status:challenge.status,\n challenge_message_id:challenge.body.challenge?.id,\n bad_kind_status:badKind.status,\n bad_kind_error:badKind.body.error,\n bad_base_status:badBase.status,\n bad_base_error:badBase.body.error,\n active_lane_status:active.status,\n wrong_lane_status:wrong.status,\n wrong_lane_error:wrong.body.error,\n wrong_message_status:wrongMsg.status,\n wrong_message_error:wrongMsg.body.error,\n self_revoke_status:revoke.status,\n self_revoke_result:revoke.body.revoked===true,\n post_revoke_status:after.status,\n post_revoke_error:after.body.error,\n db_lane_scope:row?.lane_scope,\n db_revoked:!!row?.revoked_at,\n issued_audit_events:issueEv,\n revoked_audit_events:revokeEv,\n audit_chain_ok:chain,\n audit_count:auditRows.rows.length,\n audit_tail_sha256:prev,\n secrets_exposed:false,\n production_go:false\n};\nif(!(result.challenge_fetch_status===200&&result.bad_kind_status===403&&result.bad_kind_error===\"DEVICE_TOKEN_MESSAGE_KIND_VIOLATION\"&&result.bad_base_status===403&&result.bad_base_error===\"DEVICE_TOKEN_BASE_REVISION_VIOLATION\"&&result.active_lane_status===200&&result.wrong_lane_status===403&&result.wrong_message_status===403&&result.self_revoke_status===200&&result.post_revoke_status===401&&result.db_revoked&&issueEv===1&&revokeEv===1&&chain)) throw new Error(\"R8_SCOPED_TOKEN_SELFTEST_FAILED:\"+JSON.stringify(result));\nconsole.log(JSON.stringify(result));\n",[],[305,422],"15135a55-4605-466f-9ba3-1cb1611e8c6e","device_pairing_inspect_r8.ts","01a04be6-1b1e-7309-a926-d3ab429b46fb",["D",1787979766563],"import relayFetch from \"../main.tsx\";\n\nasync function req(method:string,path:string,body?:unknown,token?:string){\n const headers=new Headers();\n if(body!==undefined) headers.set(\"content-type\",\"application/json\");\n if(token) headers.set(\"authorization\",\"Bearer \"+token);\n const r=await relayFetch(new Request(\"https://selftest.local\"+path,{method,headers,body:body===undefined?undefined:JSON.stringify(body)}));\n const text=await r.text(); let parsed:any={};\n try{parsed=JSON.parse(text)}catch{parsed={raw:text}}\n return {status:r.status,body:parsed};\n}\nconst gpt=Deno.env.get(\"GPT_TOKEN_V4\")||\"\";\nif(!gpt) throw new Error(\"GPT_TOKEN_V4 missing\");\n\nconst start=await req(\"POST\",\"/v1/pair/codex/device/start\",{client_label:\"r8-inspect-approve-selftest\"});\nif(start.status!==201) throw new Error(\"START_FAILED\");\nconst userCode=String(start.body.user_code||\"\");\nconst deviceCode=String(start.body.device_code||\"\");\nconst inspect=await req(\"POST\",\"/v1/pair/codex/device/inspect\",{user_code:userCode},gpt);\nif(inspect.status!==200||inspect.body.schema!==\"rumbo-codex-device-pairing-inspection/v1\") throw new Error(\"INSPECT_FAILED\");\nif(inspect.body.client_label!==\"r8-inspect-approve-selftest\") throw new Error(\"INSPECT_LABEL_DRIFT\");\n\nconst missing=await req(\"POST\",\"/v1/pair/codex/device/approve\",{user_code:userCode},gpt);\nif(missing.status!==400||missing.body.error!==\"EXPECTED_PAIRING_ID_REQUIRED\") throw new Error(\"MISSING_EXPECTED_ID_NOT_REJECTED\");\n\nconst wrong=await req(\"POST\",\"/v1/pair/codex/device/approve\",{user_code:userCode,expected_pairing_id:\"00000000-0000-4000-8000-000000000000\"},gpt);\nif(wrong.status!==409||wrong.body.error!==\"PAIRING_ID_MISMATCH\") throw new Error(\"PAIRING_MISMATCH_NOT_REJECTED\");\n\nconst approve=await req(\"POST\",\"/v1/pair/codex/device/approve\",{user_code:userCode,expected_pairing_id:inspect.body.pairing_id},gpt);\nif(approve.status!==200||approve.body.approved!==true) throw new Error(\"APPROVE_FAILED\");\n\nconst poll=await req(\"POST\",\"/v1/pair/codex/device/poll\",{device_code:deviceCode});\nif(poll.status!==200||poll.body.schema!==\"rumbo-codex-device-pairing/v2\") throw new Error(\"POLL_FAILED\");\nconst token=String(poll.body.token||\"\");\nconst challenge=await req(\"GET\",\"/v1/challenge/CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",undefined,token);\nif(challenge.status!==200) throw new Error(\"CHALLENGE_FAILED\");\nconst inbox=await req(\"GET\",\"/v1/inbox?lane=CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",undefined,token);\nif(inbox.status!==403||inbox.body.error!==\"DEVICE_TOKEN_USE_CHALLENGE_ROUTE\") throw new Error(\"DEVICE_INBOX_NOT_RESTRICTED\");\n\nconst revoke=await req(\"POST\",\"/v1/pair/codex/device/revoke\",{pairing_id:inspect.body.pairing_id},token);\nif(revoke.status!==200||revoke.body.revoked!==true) throw new Error(\"REVOKE_FAILED\");\nconst after=await req(\"GET\",\"/v1/state/CODEX_REAL_RUNTIME_ACCEPTANCE_V2\",undefined,token);\nif(after.status!==401) throw new Error(\"POST_REVOKE_STILL_AUTHORIZED\");\n\nconsole.log(JSON.stringify({\n schema:\"rumbo-relay-r8-inspect-approve-selftest/v1\",\n inspect_status:inspect.status,\n inspect_pairing_id_bound:inspect.body.pairing_id===approve.body.pairing_id,\n missing_expected_id_status:missing.status,\n mismatch_status:wrong.status,\n exact_approve_status:approve.status,\n device_inbox_status:inbox.status,\n device_inbox_error:inbox.body.error,\n self_revoke_status:revoke.status,\n post_revoke_status:after.status,\n secrets_exposed:false,\n production_go:false\n}));\n",[],[305,429],"046120da-eea8-4b65-9c9f-6e2f438282a0","audit_chain.ts","01a04be6-1b1e-7309-a926-cf5fc45a0cef",["D",1787979766563],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nfunction canonical(v: unknown): string {\n if (v === null || typeof v !== \"object\") return JSON.stringify(v);\n if (Array.isArray(v)) return \"[\" + v.map(canonical).join(\",\") + \"]\";\n const o=v as Record;\n return \"{\" + Object.keys(o).sort().map(k=>JSON.stringify(k)+\":\"+canonical(o[k])).join(\",\") + \"}\";\n}\nasync function sha(s:string){\n const b=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));\n return [...new Uint8Array(b)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nconst rs=await sqlite.execute(\"SELECT * FROM audit_events ORDER BY seq ASC\");\nlet prev=\"0\".repeat(64),ok=true;\nfor(const r of rs.rows as any[]){\n const ev={event_type:r.event_type,actor:r.actor,lane:r.lane,object_id:r.object_id,object_sha256:r.object_sha256,prev_event_sha256:r.prev_event_sha256,created_at:r.created_at};\n const h=await sha(canonical(ev));\n if(String(r.prev_event_sha256)!==prev||String(r.event_sha256)!==h) ok=false;\n prev=String(r.event_sha256);\n}\nif(!ok) throw new Error(\"AUDIT_CHAIN_FAIL\");\nconsole.log(JSON.stringify({audit_chain_ok:true,count:rs.rows.length,tail_sha256:prev}));\n",[],[305,436],["D",1787979766563],[329,330,331],[305],["D",1787979766563],[],[311],["D",1787964475423],["D",1789531243171],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":54,"_105":106,"_107":26},{"_13":87,"_32":88,"_42":41,"_89":43,"_90":91,"_92":93,"_94":49,"_95":43,"_96":63,"_97":44,"_98":99},"ctx",{"_80":-5,"_129":486,"_487":488,"_489":490,"_491":26,"_492":26,"_493":26,"_494":24,"_495":-5,"_496":-7,"_497":-7,"_498":61,"_499":26,"_500":26,"_501":-5,"_502":26,"_503":26,"_504":26,"_505":-5},"ENV",{"_457":458,"_459":460,"_461":135,"_462":463,"_464":465,"_466":467,"_468":469,"_470":471,"_472":473,"_474":475,"_476":477,"_478":479,"_480":481,"_482":483,"_484":485},"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 · v35