[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_182":183,"_184":185},"routes/_app.x.$handle.$name",{"_97":96,"_31":42,"_106":87,"_26":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":24,"_121":122,"_123":56,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_40":41,"_31":42,"_35":43,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":54,"_55":56,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":24},"version",4,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":20,"_33":34,"_35":36,"_37":14,"_38":39,"_23":24},"previous","deleted",false,"deletedHere","path","RELEASE_V1.md","latestPath","fileId","7bb8e304-a361-11f1-8501-1607ee4eb77e","name","fileType","content","# RUMBO R2 GitHub Observer V1\n\nStatus: **IMPLEMENTED / SELFTEST_PASS / GITHUB_APP_CREDENTIAL_PENDING / PRODUCTION_NO_GO**\n\nRuntime:\n\n`sebas1/rumbo-r2-github-observer`\n\nImplementation:\n\n`R2_GITHUB_OBSERVER_V1`\n\n## Purpose\n\nThis observer removes the architectural requirement that a diagnostic R2 snapshot must\nexecute on a GitHub-hosted runner. Once a dedicated GitHub App installation token is\nbound, the observer can read the private repository directly through the GitHub REST API\nand independently verify the exact PR snapshot.\n\nIt does not weaken the historical GitHub Actions observer. The workflow remains pinned in\nthe candidate, but the external observer provides a second execution substrate that is not\ncoupled to the account's exhausted hosted-runner minutes.\n\n## Exact trust pins\n\nRepository:\n\n- full name: `fscfede-beep/rumbo-control-queue`\n- repository id: `1314199389`\n- owner id: `293577326`\n- default branch: `main`\n\nSealed package SHA-256:\n\n`afbdc77510286adc5721ada5a0ddfa75e10305cb5200d6fd37cd8438c9c6119f`\n\nStatic bootstrap Git blob pins:\n\n- observer workflow:\n `3d5dd465aad367cde5eabfff2ba7033865ceef8b`\n- expected package:\n `1260b3516219341c63107dca1cc1b21a1ecb9ba0`\n- snapshot guard:\n `752f12df05d0b6b1bc122cbe61a3145458fdd074`\n\n## Observation contract\n\nA live observation is bound to:\n\n- exact repository identity;\n- exact PR number;\n- exact base SHA;\n- exact head SHA;\n- open DRAFT PR state;\n- base branch `main`;\n- Git compare proof that head descends from base;\n- exact three static blob pins;\n- parseable `LIVE_STATE.json`;\n- `rumbo-continuity-live-state/v3` dynamic state invariants;\n- package SHA-256;\n- process prohibitions against direct main mutation and unreviewed merge;\n- product `NO_GO`;\n- README package and `PRODUCTION_NO_GO` markers;\n- observed native branch/ruleset enforcement.\n\nNative protection is measured independently from snapshot validity. A receipt may be\n`OBSERVATION_PASS` while `merge_ready=false` if native enforcement is not proven.\n\n## Signed receipts\n\nObserver receipts use ES256.\n\nSigning key id:\n\n`aaZsAh07RChcec-P6l_R-aGrMglZjIZP0xA0jZMClx8`\n\nThe private signing JWK is stored only as encrypted Val Town environment state. The public\nverification JWK is exposed in `/health`.\n\nReceipts are persisted in a dedicated SQLite ledger and lifecycle creation is anchored in\na separate audit hash chain.\n\n## Fail-closed credential state\n\nCurrent:\n\n- observer control bearer: configured;\n- observer receipt signing key: configured;\n- dedicated GitHub App token: **not configured**;\n- `observer_can_run=false`;\n- live observe request without GitHub App token: HTTP 424;\n- `production_go=false`.\n\nNo private GitHub credential is present in source.\n\n## Self-test\n\nEvaluation:\n\n`01a04bc2-7e75-7109-b401-e5af497fbc30`\n\nResult: **PASS**.\n\nChecks:\n\n- health → 200;\n- unauthenticated ledger → 401;\n- observe without GitHub App token → 424;\n- ES256 fixture signature → valid;\n- tampered fixture under same signature → invalid;\n- audit → 200;\n- audit chain → valid;\n- production_go → false.\n\nFixture receipt SHA-256:\n\n`3adf54a665f4bfa4e7975a3bc3a0754135ee3799506bc93619487cd6c5094fa5`\n\n## Claim boundary\n\nCode-level private GitHub observation is implemented.\n\nLive independent observation remains unavailable until a dedicated GitHub App installation\ncredential is placed in `R2_GITHUB_APP_TOKEN`. This service cannot itself create that\nGitHub App, change the user's GitHub plan, or bypass GitHub private-repository plan limits.\n\nNo merge or product-production authorization is implied.\n","createdAt",["D",1787977450786],"branchVersion","branchId","3b4d54a6-dc1b-448d-8db8-741c5fde7ed2","id","8438d584-50f8-4401-a0e3-85e0f7aa21f4","rumbo-r2-github-observer",["D",1787977337892],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Independent fail-closed GitHub observer for RUMBO R2","imageUrl","d3788f19-13c5-4356-87e8-dce639626bb9","pinnedFileId","3875e380-a361-11f1-aa59-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04116-f28c-754c-9173-77bf5814fcd6","tursoName","8438d58450f84401a0e385e0f7aa21f4","tursoHostname","8438d58450f84401a0e385e0f7aa21f4-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789539031988],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":52,"_102":103,"_104":24},"branch",{"_13":86,"_31":87,"_40":39,"_88":41,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":42,"_95":96},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sebas1","handle","displayName","sebas","avatar","https://lh3.googleusercontent.com/a/ACg8ocJaC6uiXPmN9dvgA2XcSlzBSkPJO0GN5zKzPm3a8cbjmXC9HYA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_40":41,"_31":42,"_35":177,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":54,"_55":56,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":178,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":179,"_81":180,"_83":181,"_85":24},"tree",[164,165,166],"files",[164,165,166],"counts",{"_153":60,"_154":155,"_156":60,"_157":158,"_159":160},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_40":150,"_31":27,"_29":30,"_134":-5,"_38":39,"_37":14,"_136":56,"_35":151,"_13":60,"_32":20,"_33":34,"_23":24,"_140":-5,"_26":152},{"_40":142,"_31":143,"_29":54,"_134":-5,"_38":39,"_37":144,"_136":24,"_35":145,"_13":146,"_32":147,"_33":148,"_23":24,"_140":-5,"_26":149},{"_40":131,"_31":132,"_29":133,"_134":-5,"_38":39,"_37":135,"_136":24,"_35":137,"_13":60,"_32":138,"_33":139,"_23":24,"_140":-5,"_26":141},"a84538e4-a5c7-4084-952d-0d3b8857cdee","selftest.ts","6e4efa8c-a361-11f1-bd76-1607ee4eb77e","parentId",3,"latest",["D",1787977428286],"script","const base=\"https://sebas1--3875e380a36111f1aa591607ee4eb77e.web.val.run\";\nconst root=Deno.env.get(\"R2_OBSERVER_ROOT_TOKEN\");\nconst signingRaw=Deno.env.get(\"R2_OBSERVER_SIGNING_JWK_V1\");\nif(!root||!signingRaw)throw new Error(\"REQUIRED_ENV_MISSING\");\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 sha256(s:string):Promise{\n const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nfunction b64url(bytes:Uint8Array):string{\n const raw=Array.from(bytes,b=>String.fromCharCode(b)).join(\"\");\n return btoa(raw).replaceAll(\"+\",\"-\").replaceAll(\"/\",\"_\").replace(/=+$/g,\"\");\n}\nfunction b64urlDecode(s:string):Uint8Array{\n const pad=\"=\".repeat((4-(s.length%4))%4);\n const raw=atob(s.replaceAll(\"-\",\"+\").replaceAll(\"_\",\"/\")+pad);\n return Uint8Array.from(raw,ch=>ch.charCodeAt(0));\n}\nasync function sign(s:string):Promise{\n const key=await crypto.subtle.importKey(\"jwk\",JSON.parse(signingRaw!),{name:\"ECDSA\",namedCurve:\"P-256\"},false,[\"sign\"]);\n const sig=await crypto.subtle.sign({name:\"ECDSA\",hash:\"SHA-256\"},key,new TextEncoder().encode(s));\n return b64url(new Uint8Array(sig));\n}\nasync function verify(s:string,sig:string,jwk:JsonWebKey):Promise{\n const key=await crypto.subtle.importKey(\"jwk\",jwk,{name:\"ECDSA\",namedCurve:\"P-256\"},false,[\"verify\"]);\n return await crypto.subtle.verify({name:\"ECDSA\",hash:\"SHA-256\"},key,b64urlDecode(sig),new TextEncoder().encode(s));\n}\n\nconst healthRes=await fetch(base+\"/health\");\nconst health:any=await healthRes.json();\nconst unauthLedger=await fetch(base+\"/v1/ledger\");\nconst authHeaders={Authorization:`Bearer ${root}`,\"Content-Type\":\"application/json\"};\nconst blockedObserve=await fetch(base+\"/v1/observe\",{\n method:\"POST\",headers:authHeaders,\n body:JSON.stringify({\n pr_number:999,\n expected_base_sha:\"1\".repeat(40),\n expected_head_sha:\"2\".repeat(40)\n })\n});\nconst blockedBody:any=await blockedObserve.json();\n\nconst fixtureUnsigned={\n schema:\"rumbo-r2-github-observer-receipt/v1\",\n authoritative_for:\"R2_GITHUB_PR_SNAPSHOT_ONLY\",\n production_go:false,\n repository:{full_name:\"fscfede-beep/rumbo-control-queue\",id:1314199389,owner_id:293577326},\n pr_number:999,\n base_sha:\"1\".repeat(40),\n head_sha:\"2\".repeat(40),\n head_branch:\"audit/selftest\",\n observed_at:new Date().toISOString(),\n package_sha256:\"afbdc77510286adc5721ada5a0ddfa75e10305cb5200d6fd37cd8438c9c6119f\",\n state_sha256:\"3\".repeat(64),\n readme_sha256:\"4\".repeat(64),\n static_file_evidence:{\n \".github/workflows/continuity-r2-observe.yml\":{status:200,git_blob_sha:\"3d5dd465aad367cde5eabfff2ba7033865ceef8b\"},\n \"tools/continuity-r2/EXPECTED_PACKAGE.json\":{status:200,git_blob_sha:\"1260b3516219341c63107dca1cc1b21a1ecb9ba0\"},\n \"tools/continuity-r2/snapshot_guard.py\":{status:200,git_blob_sha:\"752f12df05d0b6b1bc122cbe61a3145458fdd074\"}\n },\n native_enforcement:{\n proven:false,\n classic_branch_protection:false,\n active_main_ruleset:false,\n protection_api_status:403,\n rulesets_api_status:403\n },\n checks:[],\n blocking_count:0,\n observation_status:\"OBSERVATION_PASS\",\n merge_ready:false,\n note:\"Independent GitHub snapshot observation only. Receipt cannot authorize product production.\"\n};\nconst canon=canonical(fixtureUnsigned);\nconst fixtureSha=await sha256(canon);\nconst signature=await sign(canon);\nconst signatureValid=await verify(canon,signature,health.receipt_signature?.verify_jwk);\nconst tamperedValid=await verify(canonical({...fixtureUnsigned,head_sha:\"f\".repeat(40)}),signature,health.receipt_signature?.verify_jwk);\n\nconst auditRes=await fetch(base+\"/v1/audit\",{headers:{Authorization:`Bearer ${root}`}});\nconst audit:any=await auditRes.json();\n\nconst expectedPins={\n \".github/workflows/continuity-r2-observe.yml\":\"3d5dd465aad367cde5eabfff2ba7033865ceef8b\",\n \"tools/continuity-r2/EXPECTED_PACKAGE.json\":\"1260b3516219341c63107dca1cc1b21a1ecb9ba0\",\n \"tools/continuity-r2/snapshot_guard.py\":\"752f12df05d0b6b1bc122cbe61a3145458fdd074\"\n};\n\nconst pass=\n healthRes.status===200&&\n health.implementation===\"R2_GITHUB_OBSERVER_V1\"&&\n health.root_token_configured===true&&\n health.signing_key_configured===true&&\n health.github_app_token_configured===false&&\n health.observer_can_run===false&&\n health.production_go===false&&\n health.receipt_signature?.alg===\"ES256\"&&\n health.receipt_signature?.kid===\"aaZsAh07RChcec-P6l_R-aGrMglZjIZP0xA0jZMClx8\"&&\n JSON.stringify(health.static_git_blob_pins)===JSON.stringify(expectedPins)&&\n unauthLedger.status===401&&\n blockedObserve.status===424&&\n blockedBody.error===\"GITHUB_APP_TOKEN_NOT_CONFIGURED\"&&\n signatureValid===true&&\n tamperedValid===false&&\n auditRes.status===200&&\n audit.audit_chain_ok===true&&\n audit.production_go===false;\n\nconsole.log(JSON.stringify({\n selftest:pass?\"PASS\":\"FAIL\",\n implementation:health.implementation,\n checks:{\n health:healthRes.status,\n github_app_token_configured:health.github_app_token_configured,\n unauthenticated_ledger:unauthLedger.status,\n observe_without_github_app:blockedObserve.status,\n fixture_signature_valid:signatureValid,\n tampered_fixture_valid:tamperedValid,\n audit:auditRes.status,\n audit_chain_ok:audit.audit_chain_ok\n },\n fixture_receipt_sha256:fixtureSha,\n signing_kid:health.receipt_signature?.kid,\n observer_can_run:false,\n production_go:false\n},null,2));\nif(!pass)Deno.exit(1);\n","label",[132],"f70831a8-496c-42aa-8d39-b0772adb4c46","main.tsx",2,["D",1787977404111],1,"http","import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst app = new Hono();\n\nconst IMPLEMENTATION = \"R2_GITHUB_OBSERVER_V1\";\nconst REPO_OWNER = \"fscfede-beep\";\nconst REPO_NAME = \"rumbo-control-queue\";\nconst REPO_FULL = `${REPO_OWNER}/${REPO_NAME}`;\nconst REPOSITORY_ID = 1314199389;\nconst OWNER_ID = 293577326;\nconst DEFAULT_BRANCH = \"main\";\nconst PACKAGE_SHA256 = \"afbdc77510286adc5721ada5a0ddfa75e10305cb5200d6fd37cd8438c9c6119f\";\nconst SIGNING_KID = \"aaZsAh07RChcec-P6l_R-aGrMglZjIZP0xA0jZMClx8\";\nconst VERIFY_JWK: JsonWebKey = {\n kty:\"EC\",crv:\"P-256\",\n x:\"lYPzwJFKYb5YZsikYx57Wr6TfkwwNyog15s0BN_p8fA\",\n y:\"9bVfI4jPqeN-yt2KQjz9MgmsDjLpbqzs1pw1DcgPwHQ\",\n key_ops:[\"verify\"],ext:true\n};\nconst API_VERSION = \"2026-03-10\";\nconst MAX_BODY = 64 * 1024;\n\nconst STATIC_PINS: Record = {\n \".github/workflows/continuity-r2-observe.yml\":\n \"3d5dd465aad367cde5eabfff2ba7033865ceef8b\",\n \"tools/continuity-r2/EXPECTED_PACKAGE.json\":\n \"1260b3516219341c63107dca1cc1b21a1ecb9ba0\",\n \"tools/continuity-r2/snapshot_guard.py\":\n \"752f12df05d0b6b1bc122cbe61a3145458fdd074\"\n};\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS observer_receipts(\n receipt_sha256 TEXT PRIMARY KEY,\n pr_number INTEGER NOT NULL,\n base_sha TEXT NOT NULL,\n head_sha TEXT NOT NULL,\n observed_at TEXT NOT NULL,\n observation_status TEXT NOT NULL,\n blocking_count INTEGER NOT NULL,\n native_enforcement_proven INTEGER NOT NULL CHECK(native_enforcement_proven IN (0,1)),\n merge_ready INTEGER NOT NULL CHECK(merge_ready IN (0,1)),\n state_sha256 TEXT,\n readme_sha256 TEXT,\n signature_kid TEXT NOT NULL,\n signature_b64url TEXT NOT NULL\n )`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_observer_pr_head\n ON observer_receipts(pr_number,head_sha)`,\n `CREATE TABLE IF NOT EXISTS observer_audit(\n seq INTEGER PRIMARY KEY AUTOINCREMENT,\n event_type TEXT NOT NULL,\n receipt_sha256 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 UNIQUE INDEX IF NOT EXISTS idx_observer_audit_prev\n ON observer_audit(prev_event_sha256)`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_observer_audit_event_receipt\n ON observer_audit(event_type,receipt_sha256)\n WHERE receipt_sha256 IS NOT NULL`\n]);\n\nfunction bearer(req: Request): string {\n const h = req.headers.get(\"authorization\") || \"\";\n return h.startsWith(\"Bearer \") ? h.slice(7) : \"\";\n}\nfunction ct(a:string,b:string):boolean {\n const aa=new TextEncoder().encode(a),bb=new TextEncoder().encode(b);\n if(aa.length!==bb.length)return false;\n let d=0; for(let i=0;i;\n return \"{\"+Object.keys(o).sort().map(k=>JSON.stringify(k)+\":\"+canonical(o[k])).join(\",\")+\"}\";\n}\nasync function sha256Text(s:string):Promise {\n const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nfunction b64url(bytes:Uint8Array):string {\n const raw=Array.from(bytes,b=>String.fromCharCode(b)).join(\"\");\n return btoa(raw).replaceAll(\"+\",\"-\").replaceAll(\"/\",\"_\").replace(/=+$/g,\"\");\n}\nasync function signCanonical(s:string):Promise {\n const raw=Deno.env.get(\"R2_OBSERVER_SIGNING_JWK_V1\")||\"\";\n if(!raw)throw new Error(\"OBSERVER_SIGNING_KEY_NOT_CONFIGURED\");\n const jwk=JSON.parse(raw);\n const key=await crypto.subtle.importKey(\"jwk\",jwk,{name:\"ECDSA\",namedCurve:\"P-256\"},false,[\"sign\"]);\n const sig=await crypto.subtle.sign({name:\"ECDSA\",hash:\"SHA-256\"},key,new TextEncoder().encode(s));\n return b64url(new Uint8Array(sig));\n}\nfunction decodeBase64(s:string):string {\n const compact=s.replace(/\\s+/g,\"\");\n const raw=atob(compact);\n return new TextDecoder().decode(Uint8Array.from(raw,ch=>ch.charCodeAt(0)));\n}\nasync function bodyJson(c:any):Promise {\n const len=Number(c.req.header(\"content-length\")||\"0\");\n if(Number.isFinite(len)&&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}\nfunction add(checks:any[],name:string,ok:boolean,detail:any,blocking=true){\n checks.push({name,status:ok?\"PASS\":\"FAIL\",detail,blocking});\n}\nasync function github(path:string,method=\"GET\",body?:unknown){\n const token=Deno.env.get(\"R2_GITHUB_APP_TOKEN\")||\"\";\n if(!token)return {status:0,headers:new Headers(),json:null,text:\"GITHUB_APP_TOKEN_NOT_CONFIGURED\"};\n const res=await fetch(\"https://api.github.com\"+path,{\n method,\n headers:{\n Accept:\"application/vnd.github+json\",\n Authorization:`Bearer ${token}`,\n \"X-GitHub-Api-Version\":API_VERSION,\n \"User-Agent\":\"rumbo-r2-github-observer/1\"\n },\n body:body===undefined?undefined:JSON.stringify(body)\n });\n const text=await res.text();\n let json:any=null;\n try{json=text?JSON.parse(text):null;}catch{}\n return {status:res.status,headers:res.headers,json,text};\n}\nasync function fetchContent(path:string,ref:string){\n const encoded=path.split(\"/\").map(encodeURIComponent).join(\"/\");\n const r=await github(`/repos/${REPO_OWNER}/${REPO_NAME}/contents/${encoded}?ref=${encodeURIComponent(ref)}`);\n if(r.status!==200||!r.json||typeof r.json.content!==\"string\"){\n return {ok:false,status:r.status,sha:null,text:null,error:r.json?.message||r.text};\n }\n return {\n ok:true,status:r.status,sha:String(r.json.sha||\"\"),\n text:decodeBase64(r.json.content),error:null\n };\n}\nfunction validateState(state:any,ctx:{pr:number;base:string;head:string;branch:string}){\n const checks:any[]=[];\n add(checks,\"state_schema\",state?.schema===\"rumbo-continuity-live-state/v3\",state?.schema);\n add(checks,\"state_repo_full\",state?.repository?.full_name===REPO_FULL,state?.repository?.full_name);\n add(checks,\"state_repo_id\",Number(state?.repository?.repository_id)===REPOSITORY_ID,state?.repository?.repository_id);\n add(checks,\"state_owner_id\",Number(state?.repository?.owner_id)===OWNER_ID,state?.repository?.owner_id);\n add(checks,\"state_default_branch\",state?.repository?.default_branch===DEFAULT_BRANCH,state?.repository?.default_branch);\n add(checks,\"state_successor_base\",state?.repository?.successor_branch_base_sha===ctx.base,state?.repository?.successor_branch_base_sha);\n add(checks,\"state_successor_pr\",Number(state?.lineage?.successor_pr)===ctx.pr,state?.lineage?.successor_pr);\n add(checks,\"state_successor_branch\",state?.lineage?.successor_branch===ctx.branch,state?.lineage?.successor_branch);\n add(checks,\"state_control_package\",state?.control_package?.sha256===PACKAGE_SHA256,state?.control_package?.sha256);\n add(checks,\"state_direct_main_forbidden\",state?.safety?.direct_main_mutation===\"FORBIDDEN_BY_PROCESS\",state?.safety?.direct_main_mutation);\n add(checks,\"state_merge_without_review_forbidden\",state?.safety?.merge_without_reviewed_pr===\"FORBIDDEN_BY_PROCESS\",state?.safety?.merge_without_reviewed_pr);\n add(checks,\"state_production_false\",state?.safety?.production_go_from_this_file===false,state?.safety?.production_go_from_this_file);\n add(checks,\"state_product_no_go\",state?.authority?.product_production===\"NO_GO\",state?.authority?.product_production);\n return checks;\n}\nasync function nativeEnforcement(){\n const checks:any[]=[];\n const protection=await github(`/repos/${REPO_OWNER}/${REPO_NAME}/branches/${DEFAULT_BRANCH}/protection`);\n let classic=false;\n if(protection.status===200&&protection.json){\n const j=protection.json;\n const pr=!!j.required_pull_request_reviews;\n const force=j.allow_force_pushes?.enabled===false || j.allow_force_pushes===null;\n const del=j.allow_deletions?.enabled===false || j.allow_deletions===null;\n classic=pr&&force&&del;\n }\n add(checks,\"classic_branch_protection\",classic,{status:protection.status},false);\n\n const list=await github(`/repos/${REPO_OWNER}/${REPO_NAME}/rulesets`);\n let ruleset=false;\n const inspected:any[]=[];\n if(list.status===200&&Array.isArray(list.json)){\n for(const item of list.json){\n if(item?.enforcement!==\"active\"||item?.target!==\"branch\"||!item?.id)continue;\n const detail=await github(`/repos/${REPO_OWNER}/${REPO_NAME}/rulesets/${item.id}`);\n if(detail.status!==200||!detail.json)continue;\n const types=new Set((detail.json.rules||[]).map((r:any)=>String(r.type)));\n const include=(detail.json.conditions?.ref_name?.include||[]).map(String);\n const targetsMain=include.includes(\"~DEFAULT_BRANCH\")||include.includes(\"refs/heads/main\")||include.includes(\"main\");\n const protects=types.has(\"pull_request\")&&types.has(\"non_fast_forward\")&&targetsMain;\n inspected.push({id:item.id,types:[...types],include,protects});\n if(protects)ruleset=true;\n }\n }\n add(checks,\"active_main_ruleset\",ruleset,{status:list.status,inspected},false);\n return {\n proven:classic||ruleset,\n classic,\n ruleset,\n protection_status:protection.status,\n rulesets_status:list.status,\n checks\n };\n}\nasync function appendAudit(event_type:string,receipt_sha256:string|null,object_sha256:string|null){\n if(receipt_sha256){\n const ex=await sqlite.execute({sql:\"SELECT event_sha256 FROM observer_audit WHERE event_type=? AND receipt_sha256=? LIMIT 1\",args:[event_type,receipt_sha256]});\n if(ex.rows.length)return String(ex.rows[0].event_sha256);\n }\n for(let attempt=0;attempt<8;attempt++){\n const last=await sqlite.execute(\"SELECT event_sha256 FROM observer_audit 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,receipt_sha256,object_sha256,prev_event_sha256:prev,created_at};\n const event_sha256=await sha256Text(canonical(ev));\n try{\n await sqlite.execute({sql:`INSERT INTO observer_audit(event_type,receipt_sha256,object_sha256,prev_event_sha256,event_sha256,created_at)\n VALUES(?,?,?,?,?,?)`,args:[event_type,receipt_sha256,object_sha256,prev,event_sha256,created_at]});\n return event_sha256;\n }catch(e){\n if(!String(e).includes(\"UNIQUE\"))throw e;\n }\n }\n throw new Error(\"AUDIT_APPEND_CONTENTION\");\n}\n\napp.get(\"/\",c=>c.json({service:\"rumbo-r2-github-observer\",implementation:IMPLEMENTATION,status:\"ok\",production_go:false}));\napp.get(\"/health\",c=>c.json({\n ok:true,\n implementation:IMPLEMENTATION,\n root_token_configured:!!Deno.env.get(\"R2_OBSERVER_ROOT_TOKEN\"),\n signing_key_configured:!!Deno.env.get(\"R2_OBSERVER_SIGNING_JWK_V1\"),\n github_app_token_configured:!!Deno.env.get(\"R2_GITHUB_APP_TOKEN\"),\n repository:{full_name:REPO_FULL,id:REPOSITORY_ID,owner_id:OWNER_ID,default_branch:DEFAULT_BRANCH},\n package_sha256:PACKAGE_SHA256,\n static_git_blob_pins:STATIC_PINS,\n receipt_signature:{alg:\"ES256\",kid:SIGNING_KID,verify_jwk:VERIFY_JWK},\n capabilities:[\n \"private-github-independent-observation\",\n \"exact-repository-identity\",\n \"exact-pr-base-head-binding\",\n \"git-lineage-compare\",\n \"static-bootstrap-blob-pinning\",\n \"dynamic-state-invariant-validation\",\n \"native-enforcement-observation\",\n \"signed-observer-receipts\",\n \"durable-observer-ledger\",\n \"audit-hash-chain\"\n ],\n observer_can_run:!!Deno.env.get(\"R2_GITHUB_APP_TOKEN\"),\n production_go:false\n}),200,{\"Cache-Control\":\"no-store\"});\n\napp.post(\"/v1/observe\",async c=>{\n if(!authorized(c.req.raw))return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n if(!Deno.env.get(\"R2_GITHUB_APP_TOKEN\")){\n return c.json({error:\"GITHUB_APP_TOKEN_NOT_CONFIGURED\",observer_can_run:false,production_go:false},424,{\"Cache-Control\":\"no-store\"});\n }\n try{\n const b=await bodyJson(c);\n const prNumber=Number(b?.pr_number);\n const expectedBase=String(b?.expected_base_sha||\"\");\n const expectedHead=String(b?.expected_head_sha||\"\");\n if(!Number.isSafeInteger(prNumber)||prNumber<=0||!/^[a-f0-9]{40}$/.test(expectedBase)||!/^[a-f0-9]{40}$/.test(expectedHead)){\n return c.json({error:\"INVALID_EXACT_BINDING\"},400,{\"Cache-Control\":\"no-store\"});\n }\n\n const checks:any[]=[];\n const repo=await github(`/repos/${REPO_OWNER}/${REPO_NAME}`);\n add(checks,\"repo_api_read\",repo.status===200,repo.status);\n add(checks,\"repo_id\",Number(repo.json?.id)===REPOSITORY_ID,repo.json?.id);\n add(checks,\"owner_id\",Number(repo.json?.owner?.id)===OWNER_ID,repo.json?.owner?.id);\n add(checks,\"private_repo\",repo.json?.private===true,repo.json?.private);\n add(checks,\"default_branch\",repo.json?.default_branch===DEFAULT_BRANCH,repo.json?.default_branch);\n\n const pr=await github(`/repos/${REPO_OWNER}/${REPO_NAME}/pulls/${prNumber}`);\n add(checks,\"pr_api_read\",pr.status===200,pr.status);\n add(checks,\"pr_open\",pr.json?.state===\"open\",pr.json?.state);\n add(checks,\"pr_draft\",pr.json?.draft===true,pr.json?.draft);\n add(checks,\"pr_base_ref\",pr.json?.base?.ref===DEFAULT_BRANCH,pr.json?.base?.ref);\n add(checks,\"pr_base_sha_exact\",pr.json?.base?.sha===expectedBase,pr.json?.base?.sha);\n add(checks,\"pr_head_sha_exact\",pr.json?.head?.sha===expectedHead,pr.json?.head?.sha);\n const branch=String(pr.json?.head?.ref||\"\");\n add(checks,\"pr_branch_present\",!!branch,branch);\n\n const cmp=await github(`/repos/${REPO_OWNER}/${REPO_NAME}/compare/${expectedBase}...${expectedHead}`);\n add(checks,\"compare_api_read\",cmp.status===200,cmp.status);\n add(checks,\"head_descends_from_base\",cmp.json?.behind_by===0&&Number(cmp.json?.ahead_by)>=1,{status:cmp.json?.status,ahead_by:cmp.json?.ahead_by,behind_by:cmp.json?.behind_by});\n\n const fileEvidence:any={};\n for(const [path,pin] of Object.entries(STATIC_PINS)){\n const f=await fetchContent(path,expectedHead);\n fileEvidence[path]={status:f.status,git_blob_sha:f.sha};\n add(checks,`static_pin:${path}`,f.ok&&f.sha===pin,{observed:f.sha,expected:pin,status:f.status});\n }\n\n const liveFile=await fetchContent(\"tools/continuity-r2/LIVE_STATE.json\",expectedHead);\n add(checks,\"live_state_read\",liveFile.ok,{status:liveFile.status,error:liveFile.error});\n let state:any=null;\n if(liveFile.ok){\n try{state=JSON.parse(liveFile.text!);}catch{}\n }\n add(checks,\"live_state_json\",!!state,state?\"parsed\":\"invalid\");\n if(state){\n checks.push(...validateState(state,{pr:prNumber,base:expectedBase,head:expectedHead,branch}));\n }\n\n const readmeFile=await fetchContent(\"tools/continuity-r2/README.md\",expectedHead);\n add(checks,\"readme_read\",readmeFile.ok,{status:readmeFile.status,error:readmeFile.error});\n if(readmeFile.ok){\n add(checks,\"readme_package_pin\",readmeFile.text!.includes(PACKAGE_SHA256),PACKAGE_SHA256);\n add(checks,\"readme_production_no_go\",readmeFile.text!.includes(\"PRODUCTION_NO_GO\"),\"required marker\");\n }\n\n const native=await nativeEnforcement();\n checks.push(...native.checks);\n\n const blocking=checks.filter(x=>x.blocking&&x.status!==\"PASS\");\n const observationStatus=blocking.length===0?\"OBSERVATION_PASS\":\"NO_GO\";\n const stateSha=liveFile.ok?await sha256Text(liveFile.text!):null;\n const readmeSha=readmeFile.ok?await sha256Text(readmeFile.text!):null;\n const observedAt=new Date().toISOString();\n const unsigned={\n schema:\"rumbo-r2-github-observer-receipt/v1\",\n authoritative_for:\"R2_GITHUB_PR_SNAPSHOT_ONLY\",\n production_go:false,\n repository:{full_name:REPO_FULL,id:REPOSITORY_ID,owner_id:OWNER_ID},\n pr_number:prNumber,\n base_sha:expectedBase,\n head_sha:expectedHead,\n head_branch:branch||null,\n observed_at:observedAt,\n package_sha256:PACKAGE_SHA256,\n state_sha256:stateSha,\n readme_sha256:readmeSha,\n static_file_evidence:fileEvidence,\n native_enforcement:{\n proven:native.proven,\n classic_branch_protection:native.classic,\n active_main_ruleset:native.ruleset,\n protection_api_status:native.protection_status,\n rulesets_api_status:native.rulesets_status\n },\n checks,\n blocking_count:blocking.length,\n observation_status:observationStatus,\n merge_ready:observationStatus===\"OBSERVATION_PASS\"&&native.proven,\n note:\"Independent GitHub snapshot observation only. Receipt cannot authorize product production.\"\n };\n const canon=canonical(unsigned);\n const receiptSha=await sha256Text(canon);\n const signature=await signCanonical(canon);\n const receipt={\n ...unsigned,\n receipt_sha256:receiptSha,\n receipt_signature:{alg:\"ES256\",kid:SIGNING_KID,signature_b64url:signature}\n };\n\n const prior=await sqlite.execute({sql:\"SELECT receipt_sha256 FROM observer_receipts WHERE pr_number=? AND head_sha=? LIMIT 1\",args:[prNumber,expectedHead]});\n if(!prior.rows.length){\n await sqlite.execute({sql:`INSERT INTO observer_receipts(\n receipt_sha256,pr_number,base_sha,head_sha,observed_at,observation_status,blocking_count,\n native_enforcement_proven,merge_ready,state_sha256,readme_sha256,signature_kid,signature_b64url\n ) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[\n receiptSha,prNumber,expectedBase,expectedHead,observedAt,observationStatus,blocking.length,\n native.proven?1:0,receipt.merge_ready?1:0,stateSha,readmeSha,SIGNING_KID,signature\n ]});\n await appendAudit(\"OBSERVER_RECEIPT_CREATED\",receiptSha,receiptSha);\n }\n\n return c.json(receipt,observationStatus===\"OBSERVATION_PASS\"?200:409,{\"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/ledger\",async c=>{\n if(!authorized(c.req.raw))return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n const rs=await sqlite.execute(`SELECT receipt_sha256,pr_number,base_sha,head_sha,observed_at,\n observation_status,blocking_count,native_enforcement_proven,merge_ready,state_sha256,readme_sha256,\n signature_kid FROM observer_receipts ORDER BY observed_at DESC LIMIT 100`);\n return c.json({schema:\"rumbo-r2-github-observer-ledger/v1\",implementation:IMPLEMENTATION,production_go:false,records:rs.rows},200,{\"Cache-Control\":\"no-store\"});\n});\n\napp.get(\"/v1/audit\",async c=>{\n if(!authorized(c.req.raw))return c.json({error:\"UNAUTHORIZED\"},401,{\"Cache-Control\":\"no-store\"});\n const rs=await sqlite.execute(\"SELECT * FROM observer_audit 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,receipt_sha256:r.receipt_sha256,object_sha256:r.object_sha256,prev_event_sha256:r.prev_event_sha256,created_at:r.created_at};\n const h=await sha256Text(canonical(ev));\n if(String(r.prev_event_sha256)!==prev||String(r.event_sha256)!==h)ok=false;\n prev=String(r.event_sha256);\n }\n return c.json({schema:\"rumbo-r2-github-observer-audit/v1\",audit_chain_ok:ok,count:rs.rows.length,tail_sha256:prev,production_go:false},200,{\"Cache-Control\":\"no-store\"});\n});\n\napp.onError((err,c)=>{\n console.error(err);\n return c.json({error:\"INTERNAL_ERROR\",production_go:false},500,{\"Cache-Control\":\"no-store\"});\n});\nexport default app.fetch;\n",[143],"24d69fdc-91a7-4625-8b21-a551861917ce",["D",1787977450786],[27],"pulls","branches",5,"forks","envVars",{"_161":14,"_163":60},"connections",{"_161":60,"_162":60},"count","unfilledCount","emptyCount",{"_40":150,"_31":27,"_29":30,"_134":-5,"_38":39,"_37":14,"_136":56,"_35":174,"_13":60,"_32":20,"_33":34,"_23":24,"_140":-5,"_168":175,"_26":176},{"_40":142,"_31":143,"_29":54,"_134":-5,"_38":39,"_37":144,"_136":24,"_35":171,"_13":146,"_32":147,"_33":148,"_23":24,"_140":-5,"_168":172,"_26":173},{"_40":131,"_31":132,"_29":133,"_134":-5,"_38":39,"_37":135,"_136":24,"_35":167,"_13":60,"_32":138,"_33":139,"_23":24,"_140":-5,"_168":169,"_26":170},["D",1787977428286],"children",[],[132],["D",1787977404111],[],[143],["D",1787977450786],[],[27],["D",1787977337892],["D",1789539031988],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":52,"_102":103,"_104":24},{"_13":86,"_31":87,"_40":39,"_88":41,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":42,"_95":96},"ctx",{"_79":-5,"_125":215,"_216":217,"_218":219,"_220":24,"_221":24,"_222":24,"_223":56,"_224":-5,"_225":-7,"_226":-7,"_227":60,"_228":24,"_229":24,"_230":-5,"_231":24,"_232":24,"_233":24,"_234":-5},"ENV",{"_186":187,"_188":189,"_190":87,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v4