[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_328":329,"_330":331},"routes/_app.x.$handle.$name",{"_100":99,"_31":43,"_109":88,"_26":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":123,"_124":24,"_125":126,"_127":57,"_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",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","r6_bootstrap_http_selftest.ts","latestPath","fileId","3bf415f6-a355-11f1-b028-1607ee4eb77e","name","fileType","script","content","const url=\"https://sebas1--01a04b6c896271ba8fca9e6b08c7e987.web.val.run/v1/bootstrap/codex-device.py\";\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(\"\");\nconsole.log(JSON.stringify({\n status:res.status,\n bytes:raw.length,\n sha256:sha,\n header_sha256:res.headers.get(\"x-sha256\"),\n content_type:res.headers.get(\"content-type\")\n},null,2));","createdAt",["D",1787972189852],"branchVersion","branchId","48591728-dca8-4658-b9a0-ce62b3456ce0","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",true,"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":53,"_105":106,"_107":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":91,"_92":93,"_94":48,"_95":42,"_96":63,"_97":43,"_98":99},"isOwned",40,"r6-device-bootstrap","projectId","forkedBranchId","cdbfe23c-d122-4f18-ad6e-34fdd0cb88da","forkedBranchVersion",51,"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sebas1","handle","displayName","sebas","avatar","https://lh3.googleusercontent.com/a/ACg8ocJaC6uiXPmN9dvgA2XcSlzBSkPJO0GN5zKzPm3a8cbjmXC9HYA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":323,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":324,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":325,"_82":326,"_84":327,"_86":24},"tree",[262,263,264,265,266,267,268,269,270,271,272,273,274,275,276],"files",[262,263,264,265,266,267,268,269,270,271,272,273,274,275,276],"counts",{"_250":61,"_251":252,"_253":61,"_254":255,"_256":257},"contents",[139,140,141,142,143,144,145,146,147,148,149,150,151,152,153],"upstreamProject","upstreamBranch",{"_41":91,"_36":132,"_133":134,"_31":135,"_89":42,"_13":136,"_90":-5,"_92":-5,"_137":138,"_45":-5,"_86":24,"_47":48,"_98":99,"_62":63,"_97":43},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1787964475423],"updatedAt",["D",1788191453959],"main",234,"lockfileKey","1788191454040-esm.town_v_sebas1_rumbo-continuity-relay@234-main",{"_41":244,"_31":245,"_29":246,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":247,"_13":61,"_32":248,"_34":-5,"_23":24,"_158":-5,"_26":249},{"_41":238,"_31":239,"_29":240,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":241,"_13":61,"_32":20,"_34":242,"_23":24,"_158":-5,"_26":243},{"_41":232,"_31":233,"_29":234,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":235,"_13":61,"_32":20,"_34":236,"_23":24,"_158":-5,"_26":237},{"_41":226,"_31":227,"_29":228,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":229,"_13":61,"_32":20,"_34":230,"_23":24,"_158":-5,"_26":231},{"_41":220,"_31":221,"_29":222,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":223,"_13":61,"_32":20,"_34":224,"_23":24,"_158":-5,"_26":225},{"_41":214,"_31":215,"_29":216,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":217,"_13":61,"_32":20,"_34":218,"_23":24,"_158":-5,"_26":219},{"_41":208,"_31":209,"_29":210,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":211,"_13":61,"_32":20,"_34":212,"_23":24,"_158":-5,"_26":213},{"_41":202,"_31":203,"_29":204,"_155":-5,"_39":40,"_38":163,"_156":24,"_36":205,"_13":61,"_32":20,"_34":206,"_23":24,"_158":-5,"_26":207},{"_41":195,"_31":196,"_29":197,"_155":-5,"_39":40,"_38":198,"_156":57,"_36":199,"_13":163,"_32":33,"_34":200,"_23":24,"_158":-5,"_26":201},{"_41":188,"_31":189,"_29":190,"_155":-5,"_39":40,"_38":191,"_156":24,"_36":192,"_13":61,"_32":33,"_34":193,"_23":24,"_158":-5,"_26":194},{"_41":179,"_31":180,"_29":181,"_155":-5,"_39":40,"_38":182,"_156":24,"_36":183,"_13":184,"_32":185,"_34":186,"_23":24,"_158":-5,"_26":187},{"_41":173,"_31":174,"_29":175,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":176,"_13":61,"_32":33,"_34":177,"_23":24,"_158":-5,"_26":178},{"_41":167,"_31":168,"_29":169,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":170,"_13":61,"_32":33,"_34":171,"_23":24,"_158":-5,"_26":172},{"_41":160,"_31":161,"_29":162,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":164,"_13":61,"_32":33,"_34":165,"_23":24,"_158":-5,"_26":166},{"_41":154,"_31":27,"_29":30,"_155":-5,"_39":40,"_38":14,"_156":24,"_36":157,"_13":61,"_32":33,"_34":35,"_23":24,"_158":-5,"_26":159},"2672f867-4270-4c71-9a0d-7e789e5412e5","parentId","latest",["D",1787972189852],"label",[27],"476e9b19-ac3a-4ec0-aad7-b281ef9d7481","r5_pairing_selftest.ts","01a04b6c-8962-71ba-8fca-aa745ede3df8",1,["D",1787971799396],"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",[161],"e86468a0-1085-43bf-b1d9-e5ec6070d8d7","r5_branch_regression.ts","01a04b6c-8962-71ba-8fca-a78a7ca46f75",["D",1787971799396],"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));",[168],"fa0f8bdb-c08e-40aa-886a-9787b96eef25","pairing_state.ts","01a04b6c-8962-71ba-8fca-a3e5c289b907",["D",1787971799396],"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",[174],"0e3bc522-214b-4b58-96ac-54d9b6fcd873","main.tsx","01a04b6c-8962-71ba-8fca-9e6b08c7e987",11,["D",1787972166078],9,"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\";\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_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 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 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\nfunction roleFrom(req: Request): \"gpt\" | \"codex\" | \"admin\" | null {\n const token = bearer(req);\n if (!token) return null;\n if (token === Deno.env.get(\"GPT_TOKEN_V4\")) return \"gpt\";\n if (token === Deno.env.get(\"CODEX_TOKEN_V4\")) return \"codex\";\n if (token === Deno.env.get(\"ADMIN_TOKEN_V4\")) return \"admin\";\n return null;\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\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]) => secretKeyRe.test(k) || hasSecret(x));\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:\"R6-DEVICE-BOOTSTRAP\",status:\"ok\",production_go:false}));\napp.get(\"/health\", (c) => c.json({\n ok:true,\n protocol:\"rumbo-continuity-relay/v1\",\n implementation_revision:\"R6-DEVICE-BOOTSTRAP\",\n capabilities:[\n \"atomic-stale-guard\",\"request-idempotency\",\"idempotent-ack\",\"audit-chain\",\n \"two-phase-pairing\",\"pairing-expiry-recovery\",\"pairing-constant-time-code-check\",\"device-code-pairing\",\"secretless-public-bootstrap\",\"canonical-plugin-reconstruction\",\"canonical-v1.6-skill-bootstrap\",\"codex-runtime-acceptance-verifier\",\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 role = roleFrom(c.req.raw); if (!role) 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 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 role = roleFrom(c.req.raw); if (role !== \"gpt\" && role !== \"codex\") return c.json({error:\"UNAUTHORIZED\"},401);\n const lane = c.req.query(\"lane\") || \"\"; if (!LANE_RE.test(lane)) return c.json({error:\"INVALID_LANE\"},400);\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.post(\"/v1/messages\", async (c) => {\n const actor = roleFrom(c.req.raw); if (actor !== \"gpt\" && actor !== \"codex\") return c.json({error:\"UNAUTHORIZED\"},401);\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 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 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 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 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 (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 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 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 actor = roleFrom(c.req.raw); if (actor !== \"gpt\" && actor !== \"codex\") return c.json({error:\"UNAUTHORIZED\"},401);\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 (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) return c.json({acked:true,idempotent:true,message_id:id});\n const ackId = crypto.randomUUID(), created_at = new Date().toISOString();\n const results:any = await sqlite.batch([\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 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 = 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 (lane !== \"CODEX_REAL_RUNTIME_ACCEPTANCE_V1\") return c.json({error:\"UNSUPPORTED_ACCEPTANCE_LANE\"},404,{\"Cache-Control\":\"no-store\"});\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 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 \"publish_reverse_response_with_same_challenge_nonce\",\"include_local_plugin_manifest_sha256\",\n \"include_local_runtime_receipt_sha256\",\"do_not_include_secrets\",\"preserve_fail_closed_project_gates\"\n ];\n const declared = Array.isArray(cp?.acceptance_requirements) ? cp.acceptance_requirements.map(String) : [];\n const contractOk = cp?.kind === \"runtime_acceptance_challenge\"\n && typeof cp?.challenge_nonce === \"string\" && cp.challenge_nonce.length >= 32\n && required.every(x => declared.includes(x));\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 };\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 id,created_at FROM acknowledgements\n WHERE actor='codex' AND target_message_id=? AND target_message_sha256=? LIMIT 1`,\n args:[String(challenge.id),String(challenge.message_sha256)]});\n if (!codexAck.rows.length) return c.json({lane,state:\"PENDING_CODEX_ACK\",mechanical_checks_passed:false,evidence,production_go:false},200,{\"Cache-Control\":\"no-store\"});\n\n const reverse = await sqlite.execute({sql:`SELECT id,revision,payload_json,message_sha256,created_at,acked_at\n FROM messages WHERE lane=? AND actor='codex' AND recipient='gpt' AND revision>? ORDER BY revision ASC`,\n args:[lane,Number(challenge.revision)]});\n if (!reverse.rows.length) return c.json({lane,state:\"PENDING_CODEX_RESPONSE\",mechanical_checks_passed:false,evidence:{...evidence,codex_ack_id:String((codexAck.rows[0] as any).id)},production_go:false},200,{\"Cache-Control\":\"no-store\"});\n if (reverse.rows.length !== 1) return c.json({lane,state:\"AMBIGUOUS_MULTIPLE_CODEX_RESPONSES\",response_count:reverse.rows.length,mechanical_checks_passed:false,evidence,production_go:false},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 checks = {\n challenge_nonce_exact:typeof rp?.challenge_nonce === \"string\" && rp.challenge_nonce === cp.challenge_nonce,\n local_plugin_manifest_sha256:validSha256(rp?.local_plugin_manifest_sha256),\n local_runtime_receipt_sha256:validSha256(rp?.local_runtime_receipt_sha256)\n };\n const responseEvidence = {\n ...evidence,codex_ack_id:String((codexAck.rows[0] as any).id),\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 checks\n };\n if (!Object.values(checks).every(Boolean)) return c.json({lane,state:\"INVALID_CODEX_RESPONSE\",mechanical_checks_passed:false,evidence:responseEvidence,production_go:false},200,{\"Cache-Control\":\"no-store\"});\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 transport/runtime 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 = 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 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.execute({\n sql:\"DELETE FROM device_pairing_sessions WHERE approved_at IS NULL AND expires_at<=?\",\n args:[nowIso]\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.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\n ) VALUES(?,?,?,?,?,?,?)`,\n args:[pairingId,deviceSha,userSha,fingerprint,clientLabel,nowIso,expiresAt]\n });\n return c.json({\n schema:\"rumbo-codex-device-pairing/v1\",\n pairing_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 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/approve\", async (c) => {\n const actor = 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 pairing_id,device_code_sha256,expires_at,approved_at,approved_by FROM device_pairing_sessions WHERE 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 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,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 await audit(\"CODEX_DEVICE_PAIRING_APPROVED\",actor,null,String(row.pairing_id),String(row.device_code_sha256));\n return c.json({\n approved:true,idempotent:false,pairing_id:row.pairing_id,expires_at:row.expires_at,\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/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)) {\n return c.json({error:\"INVALID_DEVICE_CODE\"},400,{\"Cache-Control\":\"no-store\"});\n }\n const deviceSha = await sha(deviceCode);\n const rs = await sqlite.execute({\n sql:\"SELECT pairing_id,device_code_sha256,expires_at,approved_at,approved_by,delivered_at,client_label FROM device_pairing_sessions WHERE 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 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) {\n return c.json({authorized:false,status:\"PENDING_APPROVAL\",retry_after_seconds:2,production_go:false},202,{\"Cache-Control\":\"no-store\"});\n }\n const codexToken = Deno.env.get(\"CODEX_TOKEN_V4\") || \"\";\n if (!codexToken) return c.json({error:\"CODEX_BEARER_NOT_CONFIGURED\"},503,{\"Cache-Control\":\"no-store\"});\n\n const pairingId = \"codex-v4\";\n const existing = await sqlite.execute({\n sql:\"SELECT pairing_id,pairing_code_sha256,issued_at,expires_at,confirmed_at,client_label FROM pairing_sessions WHERE pairing_id=?\",\n args:[pairingId]\n });\n const p:any = existing.rows[0] || null;\n let delivery = \"UNKNOWN\";\n let pairingExpiresAt = p?.expires_at ? String(p.expires_at) : null;\n let confirmed = !!p?.confirmed_at;\n\n if (p?.confirmed_at) {\n delivery = \"ALREADY_CONFIRMED_REDELIVERY\";\n } else {\n const decision = classifyPairing(\n p ? {expires_at:String(p.expires_at || \"\"),confirmed_at:null} : null,\n now.getTime()\n );\n if (decision === \"INVALID_EXISTING_SESSION\") {\n return c.json({error:\"PAIRING_STATE_INVALID\"},409,{\"Cache-Control\":\"no-store\"});\n }\n if (decision === \"REDELIVER_ACTIVE\") {\n if (!constantTimeEqual(String(p.pairing_code_sha256),deviceSha)) {\n return c.json({error:\"PAIRING_CHANNEL_CONFLICT_ACTIVE\",retry_after_expiry:p.expires_at,production_go:false},409,{\"Cache-Control\":\"no-store\"});\n }\n delivery = \"REDELIVERED_ACTIVE\";\n } else if (decision === \"REISSUE_EXPIRED\") {\n pairingExpiresAt = new Date(now.getTime()+10*60*1000).toISOString();\n const updated: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:[deviceSha,nowIso,pairingExpiresAt,String(d.client_label || \"device-bootstrap\"),pairingId,nowIso]\n });\n if (Number(updated?.rowsAffected ?? 0) !== 1) return c.json({error:\"PAIRING_REISSUE_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n await audit(\"CODEX_PAIRING_REISSUED_AFTER_EXPIRY\",\"codex\",null,pairingId,deviceSha);\n delivery = \"REISSUED_AFTER_EXPIRY\";\n } else if (decision === \"ISSUE_NEW\") {\n pairingExpiresAt = new Date(now.getTime()+10*60*1000).toISOString();\n const inserted:any = await sqlite.execute({\n sql:\"INSERT OR IGNORE INTO pairing_sessions(pairing_id,pairing_code_sha256,issued_at,expires_at,client_label) VALUES(?,?,?,?,?)\",\n args:[pairingId,deviceSha,nowIso,pairingExpiresAt,String(d.client_label || \"device-bootstrap\")]\n });\n if (Number(inserted?.rowsAffected ?? 0) !== 1) return c.json({error:\"PAIRING_ISSUE_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n await audit(\"CODEX_PAIRING_ISSUED\",\"codex\",null,pairingId,deviceSha);\n delivery = \"ISSUED_NEW\";\n } else {\n return c.json({error:\"PAIRING_DECISION_UNEXPECTED\",decision},409,{\"Cache-Control\":\"no-store\"});\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,String(d.pairing_id)]\n });\n if (Number(updated?.rowsAffected ?? 0) === 1) {\n await audit(\"CODEX_DEVICE_PAIRING_TOKEN_DELIVERED\",\"codex\",null,String(d.pairing_id),deviceSha);\n }\n }\n return c.json({\n schema:\"rumbo-codex-device-pairing/v1\",\n authorized:true,\n role:\"codex\",\n token_type:\"Bearer\",\n token:codexToken,\n pairing_id:pairingId,\n pairing_delivery:delivery,\n pairing_expires_at:pairingExpiresAt,\n confirmed,\n confirm_path:\"/v1/pair/codex/confirm\",\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 try {\n const b = await bodyJson(c);\n const code = String(b.code || \"\");\n const clientLabel = String(b.client_label || \"\").slice(0,128);\n const expected = Deno.env.get(\"CODEX_PAIRING_CODE_V4\") || \"\";\n if (!expected || !constantTimeEqual(code,expected)) return c.json({error:\"PAIRING_DENIED\"},403,{\"Cache-Control\":\"no-store\"});\n const pairingId = \"codex-v4\";\n const now = new Date();\n const codeSha = await sha(code);\n const existing = await sqlite.execute({\n sql:\"SELECT pairing_id,issued_at,expires_at,confirmed_at,pairing_code_sha256 FROM pairing_sessions WHERE pairing_id=?\",\n args:[pairingId]\n });\n const row:any = existing.rows[0] || null;\n const decision = classifyPairing(\n row ? {expires_at:String(row.expires_at || \"\"),confirmed_at:row.confirmed_at ? String(row.confirmed_at) : null} : null,\n now.getTime()\n );\n if (decision === \"ALREADY_CONFIRMED\") {\n return c.json({error:\"PAIRING_ALREADY_CONFIRMED\"},409,{\"Cache-Control\":\"no-store\"});\n }\n if (decision === \"INVALID_EXISTING_SESSION\") {\n return c.json({error:\"PAIRING_STATE_INVALID\"},409,{\"Cache-Control\":\"no-store\"});\n }\n if (decision === \"REDELIVER_ACTIVE\") {\n await audit(\"CODEX_PAIRING_REDELIVERED\",\"codex\",null,pairingId,String(row.pairing_code_sha256 || codeSha));\n return c.json({\n paired:\"ISSUED_UNCONFIRMED\",\n delivery:\"REDELIVERED_ACTIVE\",\n role:\"codex\",\n token_type:\"Bearer\",\n token:Deno.env.get(\"CODEX_TOKEN_V4\"),\n pairing_id:pairingId,\n expires_at:row.expires_at,\n confirm_path:\"/v1/pair/codex/confirm\",\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 },200,{\"Cache-Control\":\"no-store\"});\n }\n const issuedAt = now.toISOString();\n const expiresAt = new Date(now.getTime()+10*60*1000).toISOString();\n if (decision === \"REISSUE_EXPIRED\") {\n const updated: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:[codeSha,issuedAt,expiresAt,clientLabel,pairingId,issuedAt]\n });\n if (Number(updated?.rowsAffected ?? 0) !== 1) {\n return c.json({error:\"PAIRING_REISSUE_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n }\n await audit(\"CODEX_PAIRING_REISSUED_AFTER_EXPIRY\",\"codex\",null,pairingId,codeSha);\n return c.json({\n paired:\"ISSUED_UNCONFIRMED\",\n delivery:\"REISSUED_AFTER_EXPIRY\",\n role:\"codex\",\n token_type:\"Bearer\",\n token:Deno.env.get(\"CODEX_TOKEN_V4\"),\n pairing_id:pairingId,\n expires_at:expiresAt,\n confirm_path:\"/v1/pair/codex/confirm\",\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 },200,{\"Cache-Control\":\"no-store\"});\n }\n const inserted:any = await sqlite.execute({\n sql:\"INSERT OR IGNORE INTO pairing_sessions(pairing_id,pairing_code_sha256,issued_at,expires_at,client_label) VALUES(?,?,?,?,?)\",\n args:[pairingId,codeSha,issuedAt,expiresAt,clientLabel]\n });\n if (Number(inserted?.rowsAffected ?? 0) !== 1) {\n return c.json({error:\"PAIRING_ISSUE_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n }\n await audit(\"CODEX_PAIRING_ISSUED\",\"codex\",null,pairingId,codeSha);\n return c.json({\n paired:\"ISSUED_UNCONFIRMED\",\n delivery:\"ISSUED_NEW\",\n role:\"codex\",\n token_type:\"Bearer\",\n token:Deno.env.get(\"CODEX_TOKEN_V4\"),\n pairing_id:pairingId,\n expires_at:expiresAt,\n confirm_path:\"/v1/pair/codex/confirm\",\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 },200,{\"Cache-Control\":\"no-store\"});\n } catch (e) { return c.json({error:String(e?.message||e)},400,{\"Cache-Control\":\"no-store\"}); }\n});\n\napp.post(\"/v1/pair/codex/confirm\", async (c) => {\n const actor = roleFrom(c.req.raw);\n if (actor !== \"codex\") return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n try {\n const b = await bodyJson(c);\n const pairingId = String(b.pairing_id || \"\");\n if (pairingId !== \"codex-v4\") return c.json({error:\"INVALID_PAIRING_ID\"},400,{\"Cache-Control\":\"no-store\"});\n const rs = await sqlite.execute({sql:\"SELECT pairing_id,expires_at,confirmed_at,pairing_code_sha256 FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n if (!rs.rows.length) return c.json({error:\"PAIRING_NOT_ISSUED\"},404,{\"Cache-Control\":\"no-store\"});\n const row:any = rs.rows[0];\n if (row.confirmed_at) return c.json({confirmed:true,idempotent:true,pairing_id:pairingId},200,{\"Cache-Control\":\"no-store\"});\n const confirmedAt = new Date().toISOString();\n const expiresAt = String(row.expires_at || \"\");\n if (!expiresAt || !Number.isFinite(Date.parse(expiresAt))) {\n return c.json({error:\"PAIRING_STATE_INVALID\"},409,{\"Cache-Control\":\"no-store\"});\n }\n if (Date.parse(expiresAt) <= Date.parse(confirmedAt)) {\n return c.json({error:\"PAIRING_EXPIRED\",retryable:true},410,{\"Cache-Control\":\"no-store\"});\n }\n const updated: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 if (Number(updated?.rowsAffected ?? 0) !== 1) {\n const check = await sqlite.execute({sql:\"SELECT confirmed_at,expires_at FROM pairing_sessions WHERE pairing_id=?\",args:[pairingId]});\n const current:any = check.rows[0] || null;\n if (current?.confirmed_at) return c.json({confirmed:true,idempotent:true,pairing_id:pairingId},200,{\"Cache-Control\":\"no-store\"});\n if (current && Date.parse(String(current.expires_at)) <= Date.now()) {\n return c.json({error:\"PAIRING_EXPIRED\",retryable:true},410,{\"Cache-Control\":\"no-store\"});\n }\n return c.json({error:\"PAIRING_CONFIRM_RACE_LOST\"},409,{\"Cache-Control\":\"no-store\"});\n }\n await audit(\"CODEX_PAIRING_CONFIRMED\",\"codex\",null,pairingId,String(row.pairing_code_sha256));\n return c.json({confirmed:true,idempotent:false,pairing_id:pairingId,confirmed_at:confirmedAt},200,{\"Cache-Control\":\"no-store\"});\n } catch (e) { return c.json({error:String(e?.message||e)},400,{\"Cache-Control\":\"no-store\"}); }\n});\n\napp.get(\"/v1/bootstrap/codex-device/metadata\", (c) => {\n return c.json({\n schema:\"rumbo-codex-device-bootstrap/v1\",\n implementation_revision:\"R6-DEVICE-BOOTSTRAP\",\n launcher_path:\"/v1/bootstrap/codex-device.py\",\n launcher_sha256:\"a57995004d4ab6683fed3afaba0964fbe1799e9137809a916f28aa35b258c0f5\",\n launcher_bytes:9205,\n python_minimum:\"3.11\",\n canonical_skill_sha256:\"152dee3cf1bf86e81539e3f334f74d8bf630937d516b0a88a60463c9f0feb068\",\n plugin_name:\"rumbo-gpt-codex-continuity\",\n plugin_version:\"1.0.0\",\n acceptance_lane:\"CODEX_REAL_RUNTIME_ACCEPTANCE_V1\",\n challenge_message_id:\"f7ca12d8-226a-43b9-9fc0-bd9ede8548af\",\n challenge_message_sha256:\"70d6702195fca8666fd31d15084993c8ce4a7e191bd692984c0b1429c92f5979\",\n security_boundary:{\n embedded_credentials:false,\n device_code_secret_delivered_only_after_gpt_or_admin_approval:true,\n final_chatgpt_ack_required:true,\n plugin_listing_alone_not_sufficient:true,\n cache_skill_bytes_verified_by_launcher:true\n },\n production_go:false\n },200,{\"Cache-Control\":\"no-store\"});\n});\n\napp.get(\"/v1/bootstrap/codex-device.py\", async (c) => {\n const res = await blob.get(\"bootstrap/r6/codex_device_bootstrap.py\");\n const raw = await res.arrayBuffer();\n const bytes = new Uint8Array(raw);\n const observed = await sha(new TextDecoder().decode(bytes));\n if (observed !== \"a57995004d4ab6683fed3afaba0964fbe1799e9137809a916f28aa35b258c0f5\") {\n return c.json({error:\"BOOTSTRAP_BLOB_HASH_MISMATCH\",production_go:false},500,{\"Cache-Control\":\"no-store\"});\n }\n return new Response(bytes,{\n status:200,\n headers:{\n \"Content-Type\":\"text/x-python; charset=utf-8\",\n \"Content-Disposition\":\"attachment; filename=codex_device_bootstrap.py\",\n \"X-SHA256\":\"a57995004d4ab6683fed3afaba0964fbe1799e9137809a916f28aa35b258c0f5\",\n \"Cache-Control\":\"no-store\"\n }\n });\n});\n\napp.get(\"/v1/bootstrap/skill/metadata\", (c) => {\n const role = 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 = 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",[180],"1379250e-0093-49da-b6ba-3146d08f748f","inspect_skill_tmp.ts","56be9808-a354-11f1-af97-1607ee4eb77e",2,["D",1787971805302],"import JSZip from \"npm:jszip\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst res = await blob.get(\"bridge/v1.6/gpt-codex-context-bridge-skill.zip.b64\");\nconst b64 = await res.text();\nconst raw = Uint8Array.from(atob(b64), ch => ch.charCodeAt(0));\nconst zip = await JSZip.loadAsync(raw);\nconst out:any = {};\nfor (const [name, entry] of Object.entries(zip.files)) {\n if ((entry as any).dir) continue;\n out[name] = await (entry as any).async(\"string\");\n}\nconsole.log(JSON.stringify(out,null,2));",[189],"80bd7e4c-3c87-4294-b645-ad5e2a113623","acceptance_selftest.ts","01a04b6c-8962-71ba-8fca-99bf64f228c5",12,["D",1787972172176],"const 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(\"R4_REQUIRED_ENV_MISSING\");\n\nconst healthRes = await fetch(base + \"/health\");\nconst health = await healthRes.json();\nconst acceptedRuntimeRevisions = new Set([\"R4-ACCEPTANCE-GUARD\",\"R5-PAIRING-RECOVERY\",\"R6-DEVICE-BOOTSTRAP\"]);\nif (healthRes.status !== 200 || !acceptedRuntimeRevisions.has(health.implementation_revision)) {\n throw new Error(\"ACCEPTANCE_RUNTIME_REVISION_MISMATCH\");\n}\nif (health.production_go !== false) throw new Error(\"HEALTH_PRODUCTION_GO_INVARIANT_BROKEN\");\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 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\",\"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\");\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_CODEX_ACK\") {\n if (acceptance.evidence?.challenge_message_id !== \"f7ca12d8-226a-43b9-9fc0-bd9ede8548af\") {\n throw new Error(\"CHALLENGE_ID_DRIFT\");\n }\n if (acceptance.evidence?.challenge_message_sha256 !== \"70d6702195fca8666fd31d15084993c8ce4a7e191bd692984c0b1429c92f5979\") {\n throw new Error(\"CHALLENGE_SHA_DRIFT\");\n }\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 unauth_acceptance_status:unauthRes.status,\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));",[196],"770aa84a-b18c-49bd-aeb6-ca645d2cc0c8","README.md","01a04b6c-8962-71ba-8fca-960fe037e44d",["D",1787971799396],"# RUMBO Continuity Relay\n\nLive durable relay for material continuity between ChatGPT-side workflows and a Codex/local runtime.\n\n## Protocol\n\n`rumbo-continuity-relay/v1`\n\nCurrent implementation: `R5-PAIRING-RECOVERY` (R4 acceptance verifier and R3 external guard preserved).\n\n## Security model\n\n- bearer-role separation: GPT, Codex, admin;\n- no credentials in repository/code;\n- secret-bearing continuity payload rejection;\n- strict lane grammar;\n- optimistic revision control with SQLite trigger-enforced stale-write rejection;\n- exact message SHA-256 binding;\n- exact recipient ACK binding;\n- idempotent ACK replay handling;\n- append-only hash-chained audit events;\n- persistent val-scoped SQLite storage.\n\n## Pairing recovery hardening\n\nR5 removes a permanent-liveness failure in the real `codex-v4` bootstrap: an issued but unconfirmed pairing that expires can now be safely re-issued with the same fixed pairing id, instead of returning HTTP 410 forever. The pairing code check uses constant-time comparison, issue/reissue paths are race-checked, and confirmation is atomically conditioned on `expires_at`.\n\nAn active unconfirmed issuance is still redelivered without creating a second session; a confirmed session still fails closed against re-pairing. Expired confirmation responses are explicitly retryable and require a fresh pairing issuance. Synthetic regression fixtures never use `codex-v4` and are deleted in `finally`.\n\nThis changes bootstrap liveness only. It does not ACK the acceptance challenge, prove a real Codex runtime, grant merge authority, or change `production_go=false`.\n\n## Codex real-runtime acceptance verifier\n\nR4 adds a read-only, fail-closed verifier for the exact lane `CODEX_REAL_RUNTIME_ACCEPTANCE_V1`.\n\nProtected endpoint:\n\n- `GET /v1/acceptance/CODEX_REAL_RUNTIME_ACCEPTANCE_V1` — GPT/admin bearer only.\n\nThe verifier derives its contract from the stored acceptance challenge and never creates an ACK, message, pairing, authorization or production promotion. It reports only evidence-backed states:\n\n`CHALLENGE_NOT_PROVEN -> PENDING_CODEX_ACK -> PENDING_CODEX_RESPONSE -> PENDING_CHATGPT_ACK -> PASS_RUNTIME_ROUNDTRIP`\n\nAmbiguous, malformed or mechanically invalid evidence fails closed. `PENDING_CHATGPT_ACK` explicitly requires semantic review before the final GPT ACK. Even `PASS_RUNTIME_ROUNDTRIP` proves only continuity transport/runtime binding and always returns `production_go=false`.\n\nCurrent authenticated self-test observes `PENDING_CODEX_ACK`, which is consistent with the live ledger: the real Codex runtime has not yet ACKed the exact challenge.\n\n## R2 external authorization guard\n\nR3-GUARD adds an external, fail-closed authorization surface for the RUMBO Continuity R2 control package.\n\nProperties:\n\n- controller bearer is held only as an encrypted Val Town environment variable;\n- target repository is bound by an opaque immutable repository-identity SHA-256;\n- control package is pinned to one exact SHA-256;\n- authorization binds exactly to action, PR number, base SHA, head SHA, package SHA-256 and evidence SHA-256;\n- raw one-time authorization tokens are returned only at issuance;\n- only token SHA-256 values are persisted;\n- authorizations have a 60–900 second TTL;\n- exact request bindings cannot be re-issued because request SHA-256 is unique;\n- consumption is atomic and one-time;\n- replay, token mismatch, binding mismatch and stale/expired authorization fail closed;\n- ledger reads never expose token hashes;\n- guard lifecycle events are added to the existing audit hash chain;\n- `production_go` is always false on this surface.\n\n### Merge gate\n\n`MERGE_PR` issuance **and consumption** are disabled unless the runtime environment explicitly contains:\n\n`R2_ALLOW_MERGE_AUTHORIZATION=true`\n\nThat variable is intentionally absent. Therefore this runtime cannot presently authorize a PR merge.\n\nA green guard receipt is not product GO and cannot substitute for live GitHub-side observation of the exact PR state.\n\n## Guard endpoints\n\nAll guard endpoints require the dedicated R2 guard bearer except public health.\n\n- `POST /v1/guard/authorize`\n- `POST /v1/guard/consume`\n- `POST /v1/guard/revoke`\n- `GET /v1/guard/authorizations/:id`\n- `GET /v1/guard/ledger`\n\nThe temporary self-test route used during branch validation was removed before promotion.\n\n## Guard validation evidence\n\nThe branch implementation was exercised against the live Val Town runtime with an internal bearer self-test that did not expose the bearer or one-time token.\n\nFinal adversarial matrix:\n\n- unauthenticated ledger → 401;\n- merge issuance while disabled → 423;\n- invalid repository binding → 400;\n- TTL below policy → 400;\n- TEST_ONLY issuance → 201;\n- invalid consumer label → 400 with authorization still ISSUED;\n- exact TEST_ONLY consumption → 200;\n- consumed-token replay → 409;\n- duplicate exact authorization request → 409;\n- read of an expired fixture → effective status EXPIRED without mutating on read;\n- revoke of expired authorization → 410 and durable EXPIRED state;\n- pre-existing MERGE_PR fixture consumption while merge gate disabled → 423;\n- revoked merge fixture → 200;\n- ledger read → 200;\n- token-hash leakage check → false.\n\nValidated receipt SHA-256:\n\n`90d2e2fd1691b523e0a0ab182ad2f41dd9a6d8dd6ec2f06d8af19c24a58e82ab`\n\nThe live health endpoint remained 200 after removal of the temporary self-test route.\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/CODEX_REAL_RUNTIME_ACCEPTANCE_V1` (GPT/admin; read-only)\n- `GET /v1/audit` (admin only)\n\n## Boundary\n\nThe relay is a transport, evidence surface and external fail-closed authorization ledger. It does not replace lane-scoped CURRENT authority, the RUMBO continuity capsule, GitHub branch/ruleset enforcement, a dedicated GitHub App, an independent deployer, or project production authorization.\n\nA real Codex-runtime roundtrip remains a separate acceptance gate until the user's actual Codex/local runtime executes the client and produces a receipt.\n",[203],"ced28af5-67f8-48d8-af08-89fbd4560385","R5_POST_PROMOTION_RECEIPT.md","01a04b6c-8962-71ba-8fca-90494f1f8af1",["D",1787971799396],"# 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",[209],"01fdb244-10c2-44b8-9a21-ab61f601ffe6","R5_PAIRING_RECOVERY_RELEASE.md","01a04b6c-8962-71ba-8fca-8d0019f8479a",["D",1787971799396],"# 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",[215],"f1d6ef9f-3ee5-4373-ac11-7672eefd4793","R4_PR412_SUCCESSOR_BIND.md","01a04b6c-8962-71ba-8fca-89f4a2622fb1",["D",1787971799396],"# 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",[221],"d6c47eca-0c19-47e2-95a6-0dc1489ae46b","R4_PR392_FINAL_BIND.md","01a04b6c-8962-71ba-8fca-87b3dbc60ee7",["D",1787971799396],"# 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",[227],"f4f7f43c-5d52-4d13-9880-e962e6a3bcb1","R4_ACCEPTANCE_RELEASE.md","01a04b6c-8961-769d-8a18-8836f141444c",["D",1787971799396],"# 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",[233],"73c85198-6c30-4fa5-89cb-6ce7ecd60c0e","R3_GUARD_RELEASE.md","01a04b6c-8961-769d-8a18-870ec9f259ed",["D",1787971799396],"# 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",[239],"ca0f9d7a-851b-4227-8899-05000a25604b","components","01a04b6c-8961-769d-8a18-8292d7ece219",["D",1787971799396],"directory",[245],"pulls","branches",26,"forks","envVars",{"_258":260,"_261":61},"connections",{"_258":61,"_259":61},"count","unfilledCount",21,"emptyCount",{"_41":244,"_31":245,"_29":246,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":320,"_13":61,"_32":248,"_34":-5,"_23":24,"_158":-5,"_278":321,"_26":322},{"_41":238,"_31":239,"_29":240,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":317,"_13":61,"_32":20,"_34":242,"_23":24,"_158":-5,"_278":318,"_26":319},{"_41":232,"_31":233,"_29":234,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":314,"_13":61,"_32":20,"_34":236,"_23":24,"_158":-5,"_278":315,"_26":316},{"_41":226,"_31":227,"_29":228,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":311,"_13":61,"_32":20,"_34":230,"_23":24,"_158":-5,"_278":312,"_26":313},{"_41":220,"_31":221,"_29":222,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":308,"_13":61,"_32":20,"_34":224,"_23":24,"_158":-5,"_278":309,"_26":310},{"_41":214,"_31":215,"_29":216,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":305,"_13":61,"_32":20,"_34":218,"_23":24,"_158":-5,"_278":306,"_26":307},{"_41":208,"_31":209,"_29":210,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":302,"_13":61,"_32":20,"_34":212,"_23":24,"_158":-5,"_278":303,"_26":304},{"_41":202,"_31":203,"_29":204,"_155":-5,"_39":40,"_38":163,"_156":24,"_36":299,"_13":61,"_32":20,"_34":206,"_23":24,"_158":-5,"_278":300,"_26":301},{"_41":195,"_31":196,"_29":197,"_155":-5,"_39":40,"_38":198,"_156":57,"_36":296,"_13":163,"_32":33,"_34":200,"_23":24,"_158":-5,"_278":297,"_26":298},{"_41":188,"_31":189,"_29":190,"_155":-5,"_39":40,"_38":191,"_156":24,"_36":293,"_13":61,"_32":33,"_34":193,"_23":24,"_158":-5,"_278":294,"_26":295},{"_41":179,"_31":180,"_29":181,"_155":-5,"_39":40,"_38":182,"_156":24,"_36":290,"_13":184,"_32":185,"_34":186,"_23":24,"_158":-5,"_278":291,"_26":292},{"_41":173,"_31":174,"_29":175,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":287,"_13":61,"_32":33,"_34":177,"_23":24,"_158":-5,"_278":288,"_26":289},{"_41":167,"_31":168,"_29":169,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":284,"_13":61,"_32":33,"_34":171,"_23":24,"_158":-5,"_278":285,"_26":286},{"_41":160,"_31":161,"_29":162,"_155":-5,"_39":40,"_38":163,"_156":57,"_36":281,"_13":61,"_32":33,"_34":165,"_23":24,"_158":-5,"_278":282,"_26":283},{"_41":154,"_31":27,"_29":30,"_155":-5,"_39":40,"_38":14,"_156":24,"_36":277,"_13":61,"_32":33,"_34":35,"_23":24,"_158":-5,"_278":279,"_26":280},["D",1787972189852],"children",[],[27],["D",1787971799396],[],[161],["D",1787971799396],[],[168],["D",1787971799396],[],[174],["D",1787972166078],[],[180],["D",1787971805302],[],[189],["D",1787972172176],[],[196],["D",1787971799396],[],[203],["D",1787971799396],[],[209],["D",1787971799396],[],[215],["D",1787971799396],[],[221],["D",1787971799396],[],[227],["D",1787971799396],[],[233],["D",1787971799396],[],[239],["D",1787971799396],[],[245],["D",1787964475423],["D",1789531243171],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":53,"_105":106,"_107":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":91,"_92":93,"_94":48,"_95":42,"_96":63,"_97":43,"_98":99},"ctx",{"_80":-5,"_129":361,"_362":363,"_364":365,"_366":24,"_367":24,"_368":24,"_369":57,"_370":-5,"_371":-7,"_372":-7,"_373":61,"_374":24,"_375":24,"_376":-5,"_377":24,"_378":24,"_379":24,"_380":-5},"ENV",{"_332":333,"_334":335,"_336":135,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360},"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 · v13