\\n

ℹ️ Recent review info

\\n\\n

\\n

⚙️ Run configuration

\\n\\n**Configuration used**: Path: .coderabbit.yaml\\n\\n**Review profile**: ASSERTIVE\\n\\n**Plan**: Pro\\n\\n**Run ID**: `17cea7fc-230b-4acd-b5a8-936e45cab518`\\n\\n

\\n\\n

\\n

📥 Commits

\\n\\nReviewing files that changed from the base of the PR and between 1ac17e70bb18fd835db4a09fd871a2bb0c4bb7b9 and 1b27c577cf5ae9e1049356044caf5284095f6aae.\\n\\n

\\n\\n

\\n

📒 Files selected for processing (3)

\\n\\n* `crates/warp-wasm/Cargo.toml`\\n* `crates/warp-wasm/src/lib.rs`\\n* `crates/warp-wasm/src/warp_kernel.rs`\\n\\n

\\n\\n

\\n\\n---\\n\\n\\n

\\n

📝 Walkthrough

\\n\\n## Walkthrough\\n\\nNative embedding support for WarpKernel introduces `init_embedded()` and `EmbeddedHandle` to expose kernel initialization from native code. Error handling improvements wrap underlying errors in boxes and implement the std::error::Error trait. Feature-gated G2b observer registration adds experimental head query observer infrastructure with tests validating both default and experimental behavior.\\n\\n## Changes\\n\\n**Native embedding and G2b observer feature**\\n\\n|Layer / File(s)|Summary|\\n|---|---|\\n|**Error handling trait implementation**
`crates/warp-wasm/src/warp_kernel.rs`|`KernelInitError` variants now wrap underlying errors in `Box<...>`; `std::error::Error::source()` implemented to expose boxed errors for all variants except `NonFreshEngine`; `From` conversions updated to construct boxed variants.|\\n|**Feature scaffolding and G2b query constants**
`crates/warp-wasm/Cargo.toml`, `crates/warp-wasm/src/lib.rs`|Feature `experimental-warp-drive-g2b` added under `engine` feature; `kernel_port` imports refactored; `experimental_warp_drive_g2b` module with `HEAD_QUERY_ID` and `HEAD_QUERY_VARS` constants added behind feature gate.|\\n|**Embedded kernel initialization and tests**
`crates/warp-wasm/src/lib.rs`|`EmbeddedHandle` struct added with `worldline_id` and `head` fields; `init_embedded()` function builds `WarpKernel`, reads default worldline and head info, installs as trusted kernel; tests validate G2b observer registration absent when feature disabled and G2b query validation present when enabled.|\\n|**G2b observer registration and kernel helper**
`crates/warp-wasm/src/warp_kernel.rs`|`WarpKernel::with_engine` conditionally registers contract query observer on experimental-warp-drive-g2b; `default_worldline_id()` method exposes default worldline identifier in ABI form for native embedders.|\\n\\n## Estimated code review effort\\n\\n🎯 3 (Moderate) | ⏱️ ~20 minutes\\n\\n## Possibly related PRs\\n\\n- [flyingrobots/echo#296](https://github.com/flyingrobots/echo/pull/296): Extends `WarpKernel`/`KernelPort` infrastructure from that PR by changing `KernelInitError` wrapping and adding experimental observer registration in `WarpKernel::with_engine`.\\n- [flyingrobots/echo#365](https://github.com/flyingrobots/echo/pull/365): Both PRs touch `warp-wasm`'s contract query observers—this PR feature-gates observer registration in `WarpKernel::with_engine`, while that PR adds query-observer generation and typed errors.\\n\\n## Suggested labels\\n\\n`tooling`\\n\\n## Poem\\n\\n> 🧬 A kernel wakes from native land,\\n> boxed errors hold their facts in hand,\\n> G2b observers quietly wait,\\n> querying heads through feature's gate—\\n> embedded now, prepared for launch.\\n\\n

\\n\\n\\n\\n\\n

\\n

🚥 Pre-merge checks | ✅ 5

\\n\\n

\\n

✅ Passed checks (5 passed)

\\n\\n_{✏️ Tip: You can configure your own custom pre-merge checks in the settings.}\\n\\n

\\n\\n\\n\\n\\n

\\n

✨ Finishing Touches

\\n\\n

\\n

📝 Generate docstrings

\\n\\n- [ ] Create stacked PR\\n- [ ] Commit on current branch\\n\\n

\\n

🧪 Generate unit tests (beta)

\\n\\n- [ ] Create PR with unit tests\\n- [ ] Commit unit tests in branch `feat/warp-drive-g1`\\n\\n

\\n\\n

\\n\\n\\n\\n\\n---\\n\\nThanks for using [CodeRabbit](https://coderabbit.ai?utm_source=oss&utm_medium=github&utm_campaign=flyingrobots/echo&utm_content=389)! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.\\n\\n

\\n

❤️ Share

\\n\\n- [X](https://twitter.com/intent/tweet?text=I%20just%20used%20%40coderabbitai%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20the%20proprietary%20code.%20Check%20it%20out%3A&url=https%3A//coderabbit.ai)\\n- [Mastodon](https://mastodon.social/share?text=I%20just%20used%20%40coderabbitai%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20the%20proprietary%20code.%20Check%20it%20out%3A%20https%3A%2F%2Fcoderabbit.ai)\\n- [Reddit](https://www.reddit.com/submit?title=Great%20tool%20for%20code%20review%20-%20CodeRabbit&text=I%20just%20used%20CodeRabbit%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20proprietary%20code.%20Check%20it%20out%3A%20https%3A//coderabbit.ai)\\n- [LinkedIn](https://www.linkedin.com/sharing/share-offsite/?url=https%3A%2F%2Fcoderabbit.ai&mini=true&title=Great%20tool%20for%20code%20review%20-%20CodeRabbit&summary=I%20just%20used%20CodeRabbit%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20proprietary%20code)\\n\\n

\\n\\n\\n_{Comment `@coderabbitai help` to get the list of available commands and usage tips.}\\n\\n\\n\\n\\n\\n\\n\\n\",\"path\":null,\"side\":null,\"line\":null}{\"type\":\"pull_request_comment\",\"body\":\"@codex self-review findings after diffing `feat/warp-drive-g1` against `origin/main`.\\n\\n| Severity | File | Lines | Type | Finding | Recommended mitigation |\\n| --- | --- | ---: | --- | --- | --- |\\n| Medium | `crates/warp-wasm/src/lib.rs` | `426-439` | API documentation / side-effect contract | The new `init_embedded()` docs say failure “does not install a new kernel”, but the shared `build_kernel_head()` helper clears the module-scoped kernel on initialization or head-observation failure (`crates/warp-wasm/src/lib.rs:368-387`). If a native embedder already installed a kernel, a failed `init_embedded()` call removes it. The docs are therefore technically true only in the narrow “does not install the failed kernel” sense, but omit the destructive side effect on any previously installed kernel. | Prompt: “Update the `init_embedded()` documentation to explicitly say that success replaces any previously installed kernel and failure clears any previously installed kernel via the existing initialization failure behavior, or change the implementation if preserving an existing kernel is intended.” |\\n\\nIssue count: Critical 0, High 0, Medium 1, Low 0.\\n\\nAdditional review notes:\\n- `git diff --check origin/main...HEAD` is clean.\\n- The G2b observer is correctly feature-fenced behind `experimental-warp-drive-g2b` and hidden from generated docs.\\n- The default `engine` path is protected by a regression test that the WARP DRIVE query observer is not installed.\\n- The projected payload avoids POSIX path leakage and uses `projection_hash`, not `artifact_hash`.\\n\",\"path\":null,\"side\":null,\"line\":null}{\"type\":\"pull_request_comment\",\"body\":\"**Summary**\\n* Updated `init_embedded()` API documentation to state that successful initialization replaces any previously installed module-scoped trusted kernel. [crates/warp-wasm/src/lib.rsL428-L434](https://github.com/flyingrobots/echo/blob/1b27c577cf5ae9e1049356044caf5284095f6aae/crates/warp-wasm/src/lib.rs#L428-L434)\\n* Clarified the failure contract: kernel construction or initial head observation failure clears any previously installed module-scoped trusted kernel via the existing initialization failure behavior. [crates/warp-wasm/src/lib.rsL436-L440](https://github.com/flyingrobots/echo/blob/1b27c577cf5ae9e1049356044caf5284095f6aae/crates/warp-wasm/src/lib.rs#L436-L440)\\n* Committed the change as `b8cf382 docs(warp-wasm): clarify init_embedded kernel replacement`.\\n* Created a PR titled `docs(warp-wasm): clarify init_embedded kernel replacement`.\\n* Note: the pre-existing unstaged `pnpm-lock.yaml` modification was left untouched and uncommitted.\\n\\n**Testing**\\n* ✅ `cargo fmt --manifest-path crates/warp-wasm/Cargo.toml`\\n* ✅ `cargo check --manifest-path crates/warp-wasm/Cargo.toml --features engine`\\n* ✅ `git diff --check -- crates/warp-wasm/src/lib.rs`\\n* ✅ `cargo test --manifest-path crates/warp-wasm/Cargo.toml --features engine --lib default_engine_tests`\\n\\n [View task →](https://chatgpt.com/s/cd_6a1d5786ea5c8191809dbd52937b11e6)\",\"path\":null,\"side\":null,\"line\":null}","text_elements",[],{"_392":558,"_373":374,"_394":380},{"_395":559,"_397":-5,"_41":-5,"_398":-5,"_94":321,"_90":400},[560],{"_45":554,"_90":561},"input_text",{"_392":563,"_373":374,"_394":380},{"_395":564,"_397":-5,"_41":-5,"_398":-5,"_94":321,"_90":400},[565,566],{"_45":568,"_90":561},{"_45":567,"_90":561},"\n /workspace/echo\n bash\n 2026-06-01\n Etc/UTC\n","# AGENTS.md instructions for /workspace/echo\n\n\n\n\n\n# AGENTS\n\nThis guide is for AI agents and human operators recovering context in the Echo repository.\n\n## Architecture North Star\n\nEcho is not a graph database, app framework, sync daemon, or mutable state\nserver. Echo is a deterministic WARP runtime over witnessed causal history.\n\nThe durable territory is admitted causal history: transitions, frontiers, lane\nidentities, payload hashes, receipts, witnesses, checkpoints, suffixes, and\nretained boundary artifacts. Graphs, files, editor buffers, UI state, and debug\nviews are materialized readings emitted by observers or optics over that\nhistory. They may be cached, retained, transported, compared, or revealed, but\nthey are not the substrate ontology.\n\nPublic Echo surfaces should follow the WARP optic shape:\n\n```text\nexplicit causal basis/site\n+ bounded aperture\n+ law\n+ support, capability, budget, and evidence posture\n-> witnessed hologram\n```\n\nExternal callers propose explicit-base intents or observe through bounded\noptics. Echo admits, stages, pluralizes, conflicts, or obstructs those claims\nunder named law and emits receipts, reading envelopes, witnesses, or retained\nshells. Transport is witnessed suffix admission, not state sync. Application\nnouns belong in authored contracts and generated adapters, not in Echo core.\n\nKeep these sentences in view when changing architecture, docs, or APIs:\n\n```text\nThere is witnessed causal history.\nWARP optics chart it.\nHolograms witness those charts.\nMaterialized graphs are optional readings.\nContinuum is the protocol for lawful causal-history exchange.\n```\n\n## Git Rules\n\n- **NEVER** amend commits.\n- **NEVER** rebase or force-push.\n- **NEVER** push to `main` without explicit permission.\n- Always use standard commits and regular pushes.\n\n## Documentation & Planning Map\n\nDo not audit the repository by recursively walking the filesystem. Follow the authoritative manifests:\n\n### 1. The Entrance\n\n- **`README.md`**: Public front door, core value prop, and quick tour.\n- **`GUIDE.md`**: Orientation and productive-fast path.\n- **`docs/index.md`**: VitePress documentation map.\n\n### 2. The Bedrock\n\n- **`ARCHITECTURE.md`**: Authoritative structural reference (Hexagonal, Core, Memory).\n- **`VISION.md`**: Core tenets and the causal mission.\n- **`METHOD.md`**: Repo work doctrine (Backlog lanes, Cycle loop).\n\n### 3. The Direction\n\n- **`docs/BEARING.md`**: Current execution gravity and active tensions.\n- **`docs/design/ROADMAP.md`**: Broad strategic horizon and targets.\n- **`backlog/`**: The active source of truth for pending work.\n\n### 4. The Proof\n\n- **`CHANGELOG.md`**: Historical truth of merged behavior.\n- **`cargo xtask dind`**: Determinism convergence verification.\n\n## Context Recovery Protocol\n\nWhen starting a new session or recovering from context loss:\n\n1. **Read `docs/BEARING.md`** to find the current execution gravity.\n2. **Read `METHOD.md`** to understand the work doctrine.\n3. **Check `backlog/asap/`** for imminent work.\n4. **Check `git log -n 5` and `git status`** to verify the current branch state.\n\n## Executable Claim Protocol\n\nEngineering work must converge around executable evidence, not broad repository\ninterpretation. Before editing code, reduce the task to one executable claim:\n\n1. **Bound the Claim**: State the behavior, invariant, or artifact that must\n change.\n2. **Name the Witness**: Identify the smallest test, check, script, compile\n contract, golden vector, schema validation, or artifact inspection that can\n prove the claim.\n3. **Run the Witness When Feasible**: Prefer a failing witness before the fix.\n If the witness cannot execute because the repository is already broken,\n repair only the minimal compile/runtime blocker required to run it.\n4. **Do Not Expand from an Unblocker**: Do not turn a compile blocker into\n nearby architecture cleanup, docs cleanup, lint cleanup, migration sweep, or\n opportunistic refactor.\n5. **Green the Claim**: Implement the smallest fix, rerun the witness, and run\n only directly relevant surrounding checks unless broader validation is\n explicitly requested.\n6. **Stop on Green**: When the witness passes and the requested scope is\n satisfied, stop. Do not inspect more PR comments, audit more files, or clean\n unrelated residue without a new executable claim.\n\nIf unrelated failures remain, isolate them in the final report instead of\nabsorbing them into the task. Report files changed, symbols or behavior changed,\nwitness commands, pass/fail results, and intentional non-actions such as no\ncommit, no push, or no PR comment.\n\n## End of Turn Checklist\n\nAfter altering files:\n\n1. **Verify Truth**: Ensure documentation is updated if behavior or structure changed.\n2. **Log Debt**: Add follow-on backlog items to `bad-code/` or `cool-ideas/`.\n3. **Commit**: Use focused, conventional commit messages. Propose a draft before executing.\n4. **Validate**: Run `cargo check` and relevant tests.\n\n---\n\n**The goal is inevitability. Every feature is defined by its tests.**\n\n",{"_392":570,"_373":374,"_394":380},{"_395":571,"_397":-5,"_41":-5,"_398":-5,"_94":572,"_90":400},[573,574],"developer",{"_45":576,"_90":561},{"_45":575,"_90":561},"\n## Skills\nA skill is a set of local instructions to follow that is stored in a `SKILL.md` file. Below is the list of skills that can be used. Each entry includes a name, description, and file path so you can open the source for full instructions when using a specific skill.\n### Available skills\n- imagegen: Generate or edit raster images when the task benefits from AI-created bitmap visuals such as photos, illustrations, textures, sprites, mockups, or transparent-background cutouts. Use when Codex should create a brand-new image, transform an existing image, or derive visual variants from references, and the output should be a bitmap asset rather than repo-native code or vector. Do not use when the task is better handled by editing existing SVG/vector/code-native assets, extending an established icon or logo system, or building the visual directly in HTML/CSS/canvas. (file: /opt/codex/skills/.system/imagegen/SKILL.md)\n- openai-docs: Use when the user asks how to build with OpenAI products or APIs and needs up-to-date official documentation with citations, help choosing the latest model for a use case, or model upgrade and prompt-upgrade guidance; prioritize OpenAI docs MCP tools, use bundled references only as helper context, and restrict any fallback browsing to official OpenAI domains. (file: /opt/codex/skills/.system/openai-docs/SKILL.md)\n- plugin-creator: Create and scaffold plugin directories for Codex with a required `.codex-plugin/plugin.json`, optional plugin folders/files, and baseline placeholders you can edit before publishing or testing. Use when Codex needs to create a new local plugin, add optional plugin structure, or generate or update repo-root `.agents/plugins/marketplace.json` entries for plugin ordering and availability metadata. (file: /opt/codex/skills/.system/plugin-creator/SKILL.md)\n- skill-creator: Guide for creating effective skills. This skill should be used when users want to create a new skill (or update an existing skill) that extends Codex's capabilities with specialized knowledge, workflows, or tool integrations. (file: /opt/codex/skills/.system/skill-creator/SKILL.md)\n- skill-installer: Install Codex skills into $CODEX_HOME/skills from a curated list or a GitHub repo path. Use when a user asks to list installable skills, install a curated skill, or install a skill from another repo (including private repos). (file: /opt/codex/skills/.system/skill-installer/SKILL.md)\n### How to use skills\n- Discovery: The list above is the skills available in this session (name + description + file path). Skill bodies live on disk at the listed paths.\n- Trigger rules: If the user names a skill (with `$SkillName` or plain text) OR the task clearly matches a skill's description shown above, you must use that skill for that turn. Multiple mentions mean use them all. Do not carry skills across turns unless re-mentioned.\n- Missing/blocked: If a named skill isn't in the list or the path can't be read, say so briefly and continue with the best fallback.\n- How to use a skill (progressive disclosure):\n 1) After deciding to use a skill, open its `SKILL.md`. Read only enough to follow the workflow.\n 2) When `SKILL.md` references relative paths (e.g., `scripts/foo.py`), resolve them relative to the skill directory listed above first, and only consider other paths if needed.\n 3) If `SKILL.md` points to extra folders such as `references/`, load only the specific files needed for the request; don't bulk-load everything.\n 4) If `scripts/` exist, prefer running or patching them instead of retyping large code blocks.\n 5) If `assets/` or templates exist, reuse them instead of recreating from scratch.\n- Coordination and sequencing:\n - If multiple skills apply, choose the minimal set that covers the request and state the order you'll use them.\n - Announce which skill(s) you're using and why (one short line). If you skip an obvious skill, say why.\n- Context hygiene:\n - Keep context small: summarize long sections instead of pasting them; only load extra files when needed.\n - Avoid deep reference-chasing: prefer opening only files directly linked from `SKILL.md` unless you're blocked.\n - When variants exist (frameworks, providers, domains), pick only the relevant reference file(s) and note that choice.\n- Safety and fallback: If a skill can't be applied cleanly (missing files, unclear instructions), state the issue, pick the next-best approach, and continue.\n","\nFilesystem sandboxing defines which files can be read or written. `sandbox_mode` is `danger-full-access`: No filesystem sandboxing - all commands are permitted. Network access is enabled.\nApproval policy is currently never. Do not provide the `sandbox_permissions` for any reason, commands will be rejected.\n","turn/started",{"_373":374,"_85":579},{"_101":-5,"_41":380,"_381":580,"_383":384,"_385":581},[],"inProgress",{"_385":583,"_373":374},{"_584":585,"_90":586},"activeFlags",[],"active","thread/started",{"_589":590},"thread",{"_591":-5,"_592":-5,"_593":594,"_595":384,"_435":436,"_596":15,"_597":-5,"_598":-5,"_41":374,"_599":600,"_179":-5,"_159":601,"_602":207,"_440":603,"_385":604,"_75":605,"_606":384},"agentNickname","agentRole","cliVersion","0.124.0","createdAt","ephemeral","forkedFromId","gitInfo","modelProvider","openai","/opt/codex/sessions/2026/06/01/rollout-2026-06-01T10-32-53-019e82be-58e0-7830-b161-f826b4fa1f92.jsonl","preview","vscode",{"_90":389},[],"updatedAt",[],"messages",[610],{"_41":611,"_612":613,"_614":615,"_616":615,"_395":617,"_385":618,"_397":-5,"_619":31,"_620":621,"_622":623,"_624":-5},"00eaa520-3ccf-49bc-b4cb-715cbb45ce1f","author",{"_94":321,"_179":-5,"_620":633},"create_time",1780309971.608699,"update_time",{"_629":45,"_630":631},"finished_successfully","weight","metadata",{"_625":626},"recipient","all","channel","l1239dk1",{"_627":628},"inline_comments",[],"content_type","parts",[632],"@codex resolved the self-review finding in `875780b151e9`.\n\n`init_embedded()` docs now explicitly state both lifecycle side effects:\n- success replaces any previously installed module-scoped kernel\n- failure clears any previously installed module-scoped kernel through the same initialization failure behavior as `init`\n\nThis is documentation-only; no behavior changed.\nwarp-wasm: add WARP DRIVE G2b query projection\n\nAdds a temporary WARP DRIVE G2b query observer in `warp-wasm`'s native engine path.\n\nThis is not the final Echo filesystem contract. It exists to prove that WARP DRIVE can request normal regular-file bytes through Echo's existing `ObservationProjection::Query -> ObservationPayload::QueryBytes` path.\n\nArchitecture guardrails:\n- The observer is fenced behind the non-default `experimental-warp-drive-g2b` feature.\n- Plain `engine` builds do not register the WARP DRIVE observer.\n- WARP DRIVE-specific constants live under `experimental_warp_drive_g2b`, not the `warp_wasm` crate root.\n- The experimental module is hidden from generated docs with `#[doc(hidden)]`.\n- Query vars name a projection, not a POSIX path: `{\"projection\":\"g2b-head\",\"version\":1}`.\n- The payload uses `projection_hash`, not `artifact_hash`, because it is not the self-hash of the final `ObservationArtifact`.\n- Tests assert stable ABI error codes rather than human message substrings.\n- `CODEC_ERROR` for invalid query vars is documented as temporary until the ABI exposes a more precise invalid-vars code.\n\nValidated Echo commit: `d8da6d0478bb`\nCurrent branch head: `1b27c577cf5a` comment-only TODO after validation.\n\nValidation:\n```sh\ncargo fmt --manifest-path crates/warp-wasm/Cargo.toml\ncargo check --manifest-path crates/warp-wasm/Cargo.toml --features engine\ncargo clippy --manifest-path crates/warp-wasm/Cargo.toml --features engine -- -D warnings\ncargo test --manifest-path crates/warp-wasm/Cargo.toml --features engine --lib default_engine_tests\ncargo check --manifest-path crates/warp-wasm/Cargo.toml --features experimental-warp-drive-g2b\ncargo clippy --manifest-path crates/warp-wasm/Cargo.toml --features experimental-warp-drive-g2b -- -D warnings\ncargo test --manifest-path crates/warp-wasm/Cargo.toml --features experimental-warp-drive-g2b --lib experimental_warp_drive_g2b_tests\ncargo test --manifest-path crates/warp-wasm/Cargo.toml --all-features\n```\n\nDownstream WARP DRIVE gate:\n- PR: flyingrobots/warp-drive#2\n- Branch: `gate/g2b`\n- WARP DRIVE validated implementation commit: `82a9fdc24484`\n- WARP DRIVE gate record head after proof refresh: `77b5e4707c44`\n- Copy-in Docker acceptance: 58 / 58 assertions\n\nNote: the local pre-push hook failed in this worktree because `.git` is a file, not a directory, and the hook attempted `mkdir .git`. The push was made with `--no-verify` after the explicit validation matrix above passed. The failing hook behavior is worktree-specific and unrelated to this diff.\n\n\n\n\n## Summary by CodeRabbit\n\n* **New Features**\n * Added embedded engine initialization capability enabling direct kernel construction and registration, returning a handle with worldline identity and head state information\n * Introduced optional experimental G2b head projection query feature for advanced observer scenarios\n\n* **Improvements**\n * Enhanced error handling with improved error source chain visibility across initialization failures\n\n\n\n\n\n[![Review Change Stack](https://storage.googleapis.com/coderabbit_public_assets/review-stack-in-coderabbit-ui.svg)](https://app.coderabbit.ai/change-stack/flyingrobots/echo/pull/389?utm_source=github_walkthrough&utm_medium=github&utm_campaign=change_stack)\n\n\nNo actionable comments were generated in the recent review. 🎉\n\n

ℹ️ Recent review info

\n\n

⚙️ Run configuration

\n\n**Configuration used**: Path: .coderabbit.yaml\n\n**Review profile**: ASSERTIVE\n\n**Plan**: Pro\n\n**Run ID**: `17cea7fc-230b-4acd-b5a8-936e45cab518`\n\n

\n\n

📥 Commits

\n\nReviewing files that changed from the base of the PR and between 1ac17e70bb18fd835db4a09fd871a2bb0c4bb7b9 and 1b27c577cf5ae9e1049356044caf5284095f6aae.\n\n

\n\n

📒 Files selected for processing (3)

\n\n* `crates/warp-wasm/Cargo.toml`\n* `crates/warp-wasm/src/lib.rs`\n* `crates/warp-wasm/src/warp_kernel.rs`\n\n

\n\n

\n\n---\n\n\n

📝 Walkthrough

\n\n## Walkthrough\n\nNative embedding support for WarpKernel introduces `init_embedded()` and `EmbeddedHandle` to expose kernel initialization from native code. Error handling improvements wrap underlying errors in boxes and implement the std::error::Error trait. Feature-gated G2b observer registration adds experimental head query observer infrastructure with tests validating both default and experimental behavior.\n\n## Changes\n\n**Native embedding and G2b observer feature**\n\n|Layer / File(s)|Summary|\n|---|---|\n|**Error handling trait implementation**
`crates/warp-wasm/src/warp_kernel.rs`|`KernelInitError` variants now wrap underlying errors in `Box<...>`; `std::error::Error::source()` implemented to expose boxed errors for all variants except `NonFreshEngine`; `From` conversions updated to construct boxed variants.|\n|**Feature scaffolding and G2b query constants**
`crates/warp-wasm/Cargo.toml`, `crates/warp-wasm/src/lib.rs`|Feature `experimental-warp-drive-g2b` added under `engine` feature; `kernel_port` imports refactored; `experimental_warp_drive_g2b` module with `HEAD_QUERY_ID` and `HEAD_QUERY_VARS` constants added behind feature gate.|\n|**Embedded kernel initialization and tests**
`crates/warp-wasm/src/lib.rs`|`EmbeddedHandle` struct added with `worldline_id` and `head` fields; `init_embedded()` function builds `WarpKernel`, reads default worldline and head info, installs as trusted kernel; tests validate G2b observer registration absent when feature disabled and G2b query validation present when enabled.|\n|**G2b observer registration and kernel helper**
`crates/warp-wasm/src/warp_kernel.rs`|`WarpKernel::with_engine` conditionally registers contract query observer on experimental-warp-drive-g2b; `default_worldline_id()` method exposes default worldline identifier in ABI form for native embedders.|\n\n## Estimated code review effort\n\n🎯 3 (Moderate) | ⏱️ ~20 minutes\n\n## Possibly related PRs\n\n- [flyingrobots/echo#296](https://github.com/flyingrobots/echo/pull/296): Extends `WarpKernel`/`KernelPort` infrastructure from that PR by changing `KernelInitError` wrapping and adding experimental observer registration in `WarpKernel::with_engine`.\n- [flyingrobots/echo#365](https://github.com/flyingrobots/echo/pull/365): Both PRs touch `warp-wasm`'s contract query observers—this PR feature-gates observer registration in `WarpKernel::with_engine`, while that PR adds query-observer generation and typed errors.\n\n## Suggested labels\n\n`tooling`\n\n## Poem\n\n> 🧬 A kernel wakes from native land,\n> boxed errors hold their facts in hand,\n> G2b observers quietly wait,\n> querying heads through feature's gate—\n> embedded now, prepared for launch.\n\n

\n\n\n\n\n

🚥 Pre-merge checks | ✅ 5

\n\n

✅ Passed checks (5 passed)

\n\n_{✏️ Tip: You can configure your own custom pre-merge checks in the settings.}\n\n

\n\n\n\n\n

✨ Finishing Touches

\n\n

📝 Generate docstrings

\n\n- [ ] Create stacked PR\n- [ ] Commit on current branch\n\n

🧪 Generate unit tests (beta)

\n\n- [ ] Create PR with unit tests\n- [ ] Commit unit tests in branch `feat/warp-drive-g1`\n\n

\n\n

\n\n\n\n\n---\n\nThanks for using [CodeRabbit](https://coderabbit.ai?utm_source=oss&utm_medium=github&utm_campaign=flyingrobots/echo&utm_content=389)! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.\n\n

❤️ Share

\n\n- [X](https://twitter.com/intent/tweet?text=I%20just%20used%20%40coderabbitai%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20the%20proprietary%20code.%20Check%20it%20out%3A&url=https%3A//coderabbit.ai)\n- [Mastodon](https://mastodon.social/share?text=I%20just%20used%20%40coderabbitai%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20the%20proprietary%20code.%20Check%20it%20out%3A%20https%3A%2F%2Fcoderabbit.ai)\n- [Reddit](https://www.reddit.com/submit?title=Great%20tool%20for%20code%20review%20-%20CodeRabbit&text=I%20just%20used%20CodeRabbit%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20proprietary%20code.%20Check%20it%20out%3A%20https%3A//coderabbit.ai)\n- [LinkedIn](https://www.linkedin.com/sharing/share-offsite/?url=https%3A%2F%2Fcoderabbit.ai&mini=true&title=Great%20tool%20for%20code%20review%20-%20CodeRabbit&summary=I%20just%20used%20CodeRabbit%20for%20my%20code%20review%2C%20and%20it%27s%20fantastic%21%20It%27s%20free%20for%20OSS%20and%20offers%20a%20free%20trial%20for%20proprietary%20code)\n\n

\n\n\n_{Comment `@coderabbitai help` to get the list of available commands and usage tips.}\n\n\n\n\n\n\n\n\n@codex self-review findings after diffing `feat/warp-drive-g1` against `origin/main`.\n\n| Severity | File | Lines | Type | Finding | Recommended mitigation |\n| --- | --- | ---: | --- | --- | --- |\n| Medium | `crates/warp-wasm/src/lib.rs` | `426-439` | API documentation / side-effect contract | The new `init_embedded()` docs say failure “does not install a new kernel”, but the shared `build_kernel_head()` helper clears the module-scoped kernel on initialization or head-observation failure (`crates/warp-wasm/src/lib.rs:368-387`). If a native embedder already installed a kernel, a failed `init_embedded()` call removes it. The docs are therefore technically true only in the narrow “does not install the failed kernel” sense, but omit the destructive side effect on any previously installed kernel. | Prompt: “Update the `init_embedded()` documentation to explicitly say that success replaces any previously installed kernel and failure clears any previously installed kernel via the existing initialization failure behavior, or change the implementation if preserving an existing kernel is intended.” |\n\nIssue count: Critical 0, High 0, Medium 1, Low 0.\n\nAdditional review notes:\n- `git diff --check origin/main...HEAD` is clean.\n- The G2b observer is correctly feature-fenced behind `experimental-warp-drive-g2b` and hidden from generated docs.\n- The default `engine` path is protected by a regression test that the WARP DRIVE query observer is not installed.\n- The projected payload avoids POSIX path leakage and uses `projection_hash`, not `artifact_hash`.\n\n**Summary**\n* Updated `init_embedded()` API documentation to state that successful initialization replaces any previously installed module-scoped trusted kernel. [crates/warp-wasm/src/lib.rsL428-L434](https://github.com/flyingrobots/echo/blob/1b27c577cf5ae9e1049356044caf5284095f6aae/crates/warp-wasm/src/lib.rs#L428-L434)\n* Clarified the failure contract: kernel construction or initial head observation failure clears any previously installed module-scoped trusted kernel via the existing initialization failure behavior. [crates/warp-wasm/src/lib.rsL436-L440](https://github.com/flyingrobots/echo/blob/1b27c577cf5ae9e1049356044caf5284095f6aae/crates/warp-wasm/src/lib.rs#L436-L440)\n* Committed the change as `b8cf382 docs(warp-wasm): clarify init_embedded kernel replacement`.\n* Created a PR titled `docs(warp-wasm): clarify init_embedded kernel replacement`.\n* Note: the pre-existing unstaged `pnpm-lock.yaml` modification was left untouched and uncommitted.\n\n**Testing**\n* ✅ `cargo fmt --manifest-path crates/warp-wasm/Cargo.toml`\n* ✅ `cargo check --manifest-path crates/warp-wasm/Cargo.toml --features engine`\n* ✅ `git diff --check -- crates/warp-wasm/src/lib.rs`\n* ✅ `cargo test --manifest-path crates/warp-wasm/Cargo.toml --features engine --lib default_engine_tests`\n\n [View task →](https://chatgpt.com/s/cd_6a1d5786ea5c8191809dbd52937b11e6)",{},"created",1780310030.5048368,"Completing the task","event_type","info",{"_90":400,"_94":91,"_395":1525},{"_90":641,"_642":643},"partial_repo_snapshot","files",[644],{"_159":645,"_646":-5,"_647":648,"_649":-5},"crates/warp-wasm/src/lib.rs","contents","line_range_contents",[650],"missing_reason",{"_651":652,"_653":654,"_395":655,"_656":57},"line_range_start",1,"line_range_end",1560,[657,658,207,659,660,661,662,663,660,664,660,665,666,667,660,668,660,669,660,670,671,672,673,674,207,675,676,677,207,678,679,680,681,682,683,684,685,207,686,207,687,688,689,690,691,692,693,694,695,696,697,698,699,207,700,696,701,702,703,704,207,705,706,705,207,707,708,704,207,709,710,711,704,207,712,713,714,715,716,717,718,207,719,714,720,721,717,718,207,722,714,723,724,717,718,704,207,725,688,726,727,688,728,688,729,730,731,732,733,704,207,734,688,735,736,737,688,728,688,729,738,731,739,733,704,207,740,741,688,742,743,744,745,746,747,748,704,207,749,750,688,751,752,753,754,755,756,757,758,759,760,761,717,762,763,704,207,764,688,765,766,767,704,207,768,688,769,770,771,772,773,774,757,758,759,775,761,717,762,776,777,748,704,207,778,683,779,731,780,733,704,207,781,688,782,783,784,785,786,787,731,788,789,790,791,792,793,794,704,207,795,796,785,797,787,731,798,799,790,791,792,800,794,704,207,801,802,785,803,787,731,788,789,790,791,792,804,805,806,792,807,794,704,207,808,809,810,811,812,813,814,815,207,816,817,818,819,820,718,207,821,704,207,822,823,824,825,826,827,704,207,828,829,830,831,832,718,704,207,833,834,835,836,837,838,759,839,840,792,841,842,704,207,705,843,705,207,844,845,846,704,207,847,848,849,850,851,852,853,814,718,704,207,854,855,856,704,207,857,858,704,207,859,860,861,704,207,862,863,864,704,207,865,866,867,868,869,718,704,207,870,867,871,872,718,704,207,873,688,874,875,876,877,878,879,880,881,704,207,705,882,705,207,683,883,207,683,884,785,885,787,886,887,888,889,890,891,840,892,757,893,894,895,896,761,717,718,704,207,683,897,785,885,787,898,899,900,901,902,903,904,890,905,906,907,908,840,717,909,718,704,207,705,910,705,207,911,683,912,913,914,915,916,704,207,917,688,918,919,920,921,922,688,923,688,924,925,926,927,683,928,929,930,931,932,704,207,933,934,935,936,937,938,762,207,939,940,941,942,943,944,945,946,947,948,949,950,946,951,952,207,953,954,955,956,718,704,207,957,958,935,936,959,960,762,207,939,961,962,963,964,965,966,967,968,969,970,971,972,717,973,974,718,207,939,975,976,977,978,979,718,207,980,941,942,943,944,945,946,947,948,981,982,946,951,952,207,953,954,983,984,985,717,718,207,986,987,988,989,990,991,992,993,994,995,996,718,207,997,998,999,1000,1001,1002,1003,1004,999,1005,1006,1004,718,704,207,705,1007,705,207,1008,1009,1010,1011,1012,704,207,705,1013,705,207,1014,688,1015,1016,1017,1018,1019,1020,1021,1022,718,1023,1021,1024,1025,1026,951,718,704,207,1027,688,1028,1029,1018,1030,1031,747,748,704,207,1032,688,1033,1034,1035,1018,1036,773,774,757,1037,759,775,761,717,762,1038,777,748,704,207,1039,688,1040,1018,1041,1042,704,207,1043,688,1044,1018,1045,1046,756,757,1037,759,1047,761,717,762,1048,704,207,1049,688,1050,1018,1051,755,756,757,1037,759,760,761,717,762,1052,704,207,1053,688,1050,1018,1054,755,756,757,1037,759,760,761,717,762,1055,704,207,1056,688,1050,1018,1057,755,756,757,1037,759,760,761,717,762,1058,704,207,1059,688,1060,1018,1061,1062,756,757,1037,759,1063,761,717,762,1064,704,207,1065,688,1060,1018,1066,1062,756,757,1037,759,1063,761,717,762,1067,704,207,1068,688,1060,1018,1069,1062,756,757,1037,759,1063,761,717,762,1070,704,207,1071,688,1072,1018,1073,1074,704,207,1075,688,1076,1077,1078,1079,1080,688,1081,1082,1018,1083,1084,704,207,1085,1018,1086,1087,867,1088,1089,1090,892,1091,718,704,207,1092,1018,1093,1087,867,1094,1095,1090,892,1091,718,704,207,1096,1018,1097,1087,867,1098,1099,1090,892,1091,718,704,207,705,1100,705,207,1101,1102,1103,1104,1105,1106,1107,1108,1109,762,207,1110,1111,1112,1113,965,1114,1113,717,718,207,1115,1116,1117,1118,1119,1120,840,1121,965,1122,1123,1124,1125,1126,1127,1128,840,1129,1130,965,1131,1113,717,718,1132,704,207,1101,1133,1134,1135,1136,1137,1138,1139,1140,1141,1142,1143,1144,1145,1146,814,1147,1138,1148,1149,1150,1140,1141,1142,1143,1144,1145,1146,814,1151,1152,1153,1154,1155,1156,1157,1127,904,1158,840,717,718,704,207,1101,1159,935,1160,1161,1162,207,1163,1164,1165,1166,717,1167,718,207,1168,1169,1170,1171,1172,718,207,939,1173,1174,1175,1176,1177,1178,1179,1180,1181,1182,1183,1184,1185,1186,1187,1188,718,207,939,1189,1174,1175,1176,1177,1178,1179,1190,1184,1185,1186,1187,1188,718,207,939,1191,1174,1192,1193,1177,1178,1179,1194,1195,1196,1197,1184,1185,1186,1187,1188,718,207,939,1198,1174,1199,1200,1177,1178,1179,1194,1201,1202,1203,1204,1205,1197,1184,1185,1186,1187,1188,718,704,207,1206,1207,1208,935,936,1209,1210,1211,1212,1213,1214,1215,1216,1217,1218,1219,1220,1221,1222,1223,762,207,1224,207,1225,1226,1227,1228,1229,1230,1231,840,717,718,207,1232,1233,1234,1235,1236,1237,1238,1239,1240,1241,1242,1243,1244,1245,1246,1247,1248,1249,1250,761,717,207,1251,1252,1253,1254,1255,1256,1257,1258,1259,1260,1261,1262,1250,1263,1264,1265,1266,1267,1268,1269,1270,1271,1272,1273,1274,1275,1276,1277,1278,1279,1280,1250,1281,1282,1283,1284,1285,1286,1287,1288,1289,1266,1250,761,717,207,1290,1291,1292,1293,1294,1295,1296,1255,1256,1257,1297,1298,1260,1299,1300,1250,1301,1302,1256,1303,1304,1305,1306,1307,761,717,207,1308,1291,1292,1309,1310,1311,1312,1313,1314,1315,1316,1317,1318,1319,1303,1320,1321,1322,1307,1323,761,717,207,1324,1291,1325,1326,1327,1328,1329,1330,1331,1332,1256,1333,1300,1250,1334,1335,1336,1337,1338,1339,1340,1341,1342,1343,1344,1307,1345,1346,1347,1348,1349,1350,1273,1351,1352,1266,1353,1354,1355,1250,761,717,207,1356,1357,1358,1228,1330,1334,1359,1336,1360,1361,1345,1362,1363,1364,1352,1365,1366,1266,1347,1348,1349,1367,1353,1354,1355,1250,1368,1369,1370,1371,1372,1373,1374,1375,1376,1377,1378,1266,1307,761,717,207,1379,1380,1325,1381,1382,1383,1384,1385,1386,1256,1343,1387,1307,761,717,207,1388,1389,1390,1391,1392,1393,840,717,207,1394,1395,1396,1397,1398,1399,1400,1401,1402,1403,761,717,718,207,1404,1405,1380,1406,1407,1408,1409,1410,1411,1412,1413,1127,1414,1234,1235,1415,1416,1417,1239,1240,1418,1244,1419,1246,1247,1248,1249,1250,761,717,718,207,939,1420,1421,1422,1423,207,1421,1424,1425,1426,1427,965,1428,718,207,939,1429,1421,1422,1430,1431,1432,946,1433,952,207,1434,1435,207,1436,718,207,939,1437,1421,1438,1430,1431,1432,946,1433,952,207,1439,1440,207,1441,1442,1443,1444,1445,1004,718,207,939,1446,1421,1422,1430,1431,1432,946,1433,952,207,1439,1435,207,1447,718,207,939,1448,1421,1438,1449,207,1450,1435,207,1451,718,207,939,1452,1421,1422,1453,1454,1455,1456,207,1457,1435,207,1436,718,207,939,1458,1421,1422,207,1459,1460,1461,1462,1453,1454,1455,1456,207,1463,1464,1465,1466,1467,946,1468,1469,1470,1471,1472,1473,946,1474,1475,1471,1476,1477,1478,1479,1480,1481,1482,1483,1484,1485,1486,1250,946,1487,1488,965,953,207,1489,207,1436,718,207,939,1490,1421,1422,1491,1425,1426,1492,965,1493,207,1424,1425,1426,1494,965,1428,718,207,939,1495,1421,1422,942,1496,1358,945,946,1497,1498,951,952,1499,1500,1501,1502,718,207,939,1503,1421,1422,942,1496,1358,945,946,1497,1498,951,952,1504,1505,1506,1507,1443,1508,1509,1004,718,207,939,1510,1421,1422,1511,1512,965,207,1513,1514,1515,207,1516,1517,1518,1519,1520,1521,1188,207,1522,1523,1524,718,704],"contains_end_of_file","// SPDX-License-Identifier: Apache-2.0","// © James Ross Ω FLYING•ROBOTS ","//! WASM boundary for the Echo deterministic simulation engine.","//!","//! This crate provides `wasm-bindgen` exports that delegate to a [`KernelPort`]","//! implementation. The boundary is app-agnostic: any kernel that implements","//! the trait can be installed via [`install_kernel`].","//! # ABI Contract (v7)","//! All exports return CBOR-encoded bytes wrapped in a success/error envelope:","//! - Success: `{ \"ok\": true, ...response_fields }`","//! - Error: `{ \"ok\": false, \"code\": u32, \"message\": string }`","//! See [`echo_wasm_abi::kernel_port`] for the full type definitions.","//! # Initialization","//! The host must call [`init`] (or install a kernel via [`install_kernel`])","//! before using any other export. Calling exports before initialization","//! returns a structured error (no panics).","// wasm_bindgen generates unsafe glue code; allow unsafe in this crate.","#![allow(unsafe_code)]","use js_sys::Uint8Array;","use wasm_bindgen::prelude::*;","use wasm_bindgen::JsValue;","use echo_wasm_abi::kernel_port::{"," self, AbiError, DispatchOpticIntentRequest, ErrEnvelope, KernelPort, ObservationRequest,"," ObserveOpticRequest, OkEnvelope, OpticIntentPayload, SettlementRequest,"," TrustedKernelControlPort,","};","#[cfg(feature = \"engine\")]","use echo_wasm_abi::kernel_port::{HeadInfo, WorldlineId};","use echo_wasm_abi::{unpack_control_intent_v1, unpack_intent_v1, CONTROL_INTENT_V1_OP_ID};","use std::cell::RefCell;","/// Temporary downstream gate scaffold for WARP DRIVE G2b.","///","/// This module is not Echo's filesystem contract. It is an explicit,","/// non-default native-embedding fixture that lets WARP DRIVE prove that normal","/// file bytes can come back through Echo's existing query-observation ABI.","#[cfg(all(feature = \"engine\", feature = \"experimental-warp-drive-g2b\"))]","#[doc(hidden)]","pub mod experimental_warp_drive_g2b {"," /// Temporary query id for the G2b head projection."," ///"," /// The value is namespaced by this experimental feature and must not be"," /// treated as a stable Echo operation id."," pub const HEAD_QUERY_ID: u32 = 0x5744_4732;"," /// Temporary query vars for the G2b head projection."," /// This intentionally names a projection, not a POSIX path. Paths are"," /// WARP DRIVE membrane concerns; Echo observes projection identities."," pub const HEAD_QUERY_VARS: &[u8] = b\"{\\\"projection\\\":\\\"g2b-head\\\",\\\"version\\\":1}\";","}","// ---------------------------------------------------------------------------","// Kernel storage (module-scoped, single-threaded WASM)","thread_local! {"," static KERNEL: RefCell> = const { RefCell::new(None) };","enum InstalledKernel {"," App(Box),"," Trusted(Box),","impl InstalledKernel {"," fn kernel(&self) -> &dyn KernelPort {"," match self {"," Self::App(kernel) => kernel.as_ref(),"," Self::Trusted(kernel) => kernel.as_ref(),"," }"," }"," fn kernel_mut(&mut self) -> &mut dyn KernelPort {"," Self::App(kernel) => kernel.as_mut(),"," Self::Trusted(kernel) => kernel.as_mut(),"," fn trusted_mut(&mut self) -> Option<&mut dyn TrustedKernelControlPort> {"," Self::App(_) => None,"," Self::Trusted(kernel) => Some(kernel.as_mut()),","/// Install a kernel implementation into the WASM boundary.","/// This is the app-agnostic injection point. Call this from your app's","/// initialization code (or from [`init`] for the default engine kernel).","/// # Panics","/// Does not panic. Replaces any previously installed kernel.","pub fn install_kernel(kernel: Box) {"," KERNEL.with(|cell| {"," *cell.borrow_mut() = Some(InstalledKernel::App(kernel));"," });","/// Install a trusted runtime-owner kernel implementation into the WASM boundary.","/// Application adapters should use [`install_kernel`] or only receive app-safe","/// exports. Host/runtime-owner adapters that own scheduler lifecycle may install","/// this trusted boundary and call [`dispatch_control_intent_trusted`].","pub fn install_trusted_kernel(kernel: Box) {"," *cell.borrow_mut() = Some(InstalledKernel::Trusted(kernel));","/// Dispatch intent bytes through the installed kernel and return a CBOR","/// success/error envelope as raw bytes.","/// This is the native Rust equivalent of the `dispatch_intent` WASM export. It","/// keeps generated-contract smoke tests off `js_sys::Uint8Array` while","/// exercising the same installed-kernel envelope contract.","pub fn dispatch_intent_cbor(intent_bytes: &[u8]) -> Vec {"," encode_result_bytes(with_kernel(|k| {"," dispatch_application_intent(k, intent_bytes)"," }))","/// Observe through the installed kernel and return a CBOR success/error","/// envelope as raw bytes.","/// `request_bytes` must decode as canonical-CBOR [`ObservationRequest`]. This","/// mirrors the `observe` WASM export without requiring JavaScript bindings in","/// native tests.","pub fn observe_cbor(request_bytes: &[u8]) -> Vec {"," let request = match echo_wasm_abi::decode_cbor::(request_bytes) {"," Ok(request) => request,"," Err(err) => {"," return encode_err_bytes(&AbiError {"," code: kernel_port::error_codes::INVALID_PAYLOAD,"," message: format!(\"invalid observation request payload: {err}\"),"," })"," };"," encode_result_bytes(with_kernel_ref(|k| k.observe(request)))","/// Return installed registry metadata as a CBOR success/error envelope.","/// This is the native Rust equivalent of the `get_registry_info` WASM export.","pub fn get_registry_info_cbor() -> Vec {"," encode_result_bytes(with_kernel_ref(|k| Ok(k.registry_info())))","/// Dispatch a privileged control intent through the trusted runtime boundary.","/// `control_intent_bytes` must be a packed `ControlIntentV1` EINT envelope. This","/// is the native Rust equivalent of the `dispatch_control_intent_trusted` WASM","/// export and is intentionally separate from application `dispatch_intent`.","pub fn dispatch_control_intent_trusted_cbor(control_intent_bytes: &[u8]) -> Vec {"," let control = match unpack_control_intent_v1(control_intent_bytes) {"," Ok(control) => control,"," message: format!(\"invalid trusted control intent payload: {err}\"),"," encode_result_bytes(with_trusted_kernel(|k| {"," k.dispatch_control_intent_trusted(control)","/// Remove any installed kernel from the WASM boundary.","fn clear_kernel() {"," *cell.borrow_mut() = None;","/// Run a closure with a mutable reference to the installed kernel.","/// Returns an [`AbiError`] with code [`NOT_INITIALIZED`](kernel_port::error_codes::NOT_INITIALIZED)","/// if no kernel has been installed.","fn with_kernel(f: F) -> Result","where"," F: FnOnce(&mut dyn KernelPort) -> Result,","{"," let mut borrow = cell.borrow_mut();"," let kernel = borrow.as_mut().ok_or_else(|| AbiError {"," code: kernel_port::error_codes::NOT_INITIALIZED,"," message: \"kernel not initialized; call init() first\".into(),"," })?;"," f(kernel.kernel_mut())"," })","/// Run a closure with an immutable reference to the installed kernel.","fn with_kernel_ref(f: F) -> Result"," F: FnOnce(&dyn KernelPort) -> Result,"," let borrow = cell.borrow();"," let kernel = borrow.as_ref().ok_or_else(|| AbiError {"," f(kernel.kernel())","/// Run a closure with a mutable reference to the trusted runtime boundary.","fn with_trusted_kernel(f: F) -> Result"," F: FnOnce(&mut dyn TrustedKernelControlPort) -> Result,"," let trusted = kernel.trusted_mut().ok_or_else(|| AbiError {"," code: kernel_port::error_codes::NOT_SUPPORTED,"," message: \"trusted runtime control is not installed\".into(),"," f(trusted)","fn validate_application_intent_bytes(intent_bytes: &[u8]) -> Result<(), AbiError> {"," let (op_id, _) = unpack_intent_v1(intent_bytes).map_err(|error| AbiError {"," code: kernel_port::error_codes::INVALID_INTENT,"," message: format!("," \"malformed EINT envelope ({} bytes): {error}\","," intent_bytes.len()"," ),"," })?;"," if op_id == CONTROL_INTENT_V1_OP_ID {"," return Err(AbiError {"," code: kernel_port::error_codes::FORBIDDEN_CONTROL_INTENT,"," message: \"application dispatch cannot carry scheduler control intents\".into(),"," });"," Ok(())","fn dispatch_application_intent("," kernel: &mut dyn KernelPort,"," intent_bytes: &[u8],",") -> Result {"," validate_application_intent_bytes(intent_bytes)?;"," kernel.dispatch_intent(intent_bytes)","fn validate_application_optic_intent_request("," request: &DispatchOpticIntentRequest,",") -> Result<(), AbiError> {"," match &request.payload {"," OpticIntentPayload::EintV1 { bytes } => validate_application_intent_bytes(bytes),","fn dispatch_optic_intent_result("," request_bytes: &[u8],",") -> Result {"," let request ="," echo_wasm_abi::decode_cbor::(request_bytes).map_err(|err| {"," AbiError {"," message: format!(\"invalid optic dispatch request payload: {err}\"),"," }"," validate_application_optic_intent_request(&request)?;"," with_kernel(|k| k.dispatch_optic_intent(request))","// CBOR envelope encoding","/// Encode a successful result as a CBOR Uint8Array with `{ ok: true, ...data }`.","fn encode_ok(value: &T) -> Uint8Array {"," bytes_to_uint8array(&encode_ok_bytes(value))","fn encode_ok_bytes(value: &T) -> Vec {"," let envelope = OkEnvelope::new(value);"," match echo_wasm_abi::encode_cbor(&envelope) {"," Ok(bytes) => bytes,"," Err(_) => encode_err_raw_bytes("," kernel_port::error_codes::CODEC_ERROR,"," \"failed to encode response\",","/// Encode an error as a CBOR Uint8Array with `{ ok: false, code, message }`.","fn encode_err(err: &AbiError) -> Uint8Array {"," bytes_to_uint8array(&encode_err_bytes(err))","fn encode_err_bytes(err: &AbiError) -> Vec {"," encode_err_raw_bytes(err.code, &err.message)","/// Low-level error encoding that cannot itself fail (falls back to empty array).","fn encode_err_raw(code: u32, message: &str) -> Uint8Array {"," bytes_to_uint8array(&encode_err_raw_bytes(code, message))","fn encode_err_raw_bytes(code: u32, message: &str) -> Vec {"," let envelope = ErrEnvelope::new(code, message.into());"," echo_wasm_abi::encode_cbor(&envelope).unwrap_or_default()","/// Encode a `Result` into a CBOR Uint8Array envelope.","fn encode_result(result: Result) -> Uint8Array {"," match result {"," Ok(ref val) => encode_ok(val),"," Err(ref err) => encode_err(err),","fn encode_result_bytes(result: Result) -> Vec {"," Ok(ref val) => encode_ok_bytes(val),"," Err(ref err) => encode_err_bytes(err),","/// Helper to convert a byte slice into a JS `Uint8Array`.","/// WASM linear memory is 32-bit, so `bytes.len()` is guaranteed to fit in u32","/// on the target platform. On native (tests), we saturate to u32::MAX.","#[allow(clippy::cast_possible_truncation)]","fn bytes_to_uint8array(bytes: &[u8]) -> Uint8Array {"," let len = bytes.len().min(u32::MAX as usize) as u32;"," let arr = Uint8Array::new_with_length(len);"," arr.copy_from(bytes);"," arr","// WarpKernel: Engine-backed KernelPort (feature-gated)","mod warp_kernel;","fn build_kernel_head(make_kernel: F) -> Result<(warp_kernel::WarpKernel, HeadInfo), AbiError>"," F: FnOnce() -> Result,"," match make_kernel() {"," Ok(kernel) => match kernel.current_head() {"," Ok(head) => Ok((kernel, head)),"," Err(err) => {"," clear_kernel();"," Err(err)"," },"," clear_kernel();"," Err(AbiError {"," code: kernel_port::error_codes::ENGINE_ERROR,"," message: format!(\"kernel initialization failed: {err}\"),","fn init_with_factory(make_kernel: F) -> Uint8Array"," match build_kernel_head(make_kernel) {"," Ok((kernel, head)) => {"," let envelope = OkEnvelope::new(&head);"," if let Ok(bytes) = echo_wasm_abi::encode_cbor(&envelope) {"," install_trusted_kernel(Box::new(kernel));"," bytes_to_uint8array(&bytes)"," } else {"," encode_err_raw("," kernel_port::error_codes::CODEC_ERROR,"," \"failed to encode response\","," )"," Err(err) => encode_err(&err),","// Native embedding surface (non-wasm-bindgen, feature = \"engine\")","/// State returned by [`init_embedded`] describing the freshly initialized kernel.","pub struct EmbeddedHandle {"," /// The default worldline id to use when constructing observation requests."," pub worldline_id: WorldlineId,"," /// Head info as of kernel initialization (tick 0, real hashes)."," pub head: HeadInfo,","/// Initialize the default engine kernel for native (non-WASM) embedding.","/// Creates a [`warp_kernel::WarpKernel`] backed by `warp-core`, installs it as","/// the module-scoped trusted kernel, and returns an [`EmbeddedHandle`] with the","/// default worldline id and initial head. After this call, [`observe_cbor`],","/// [`dispatch_intent_cbor`], and [`dispatch_control_intent_trusted_cbor`] are","/// all ready to use without a JavaScript host.","/// # Errors","/// Returns [`AbiError`] if kernel construction or the initial head observation","/// fails. Success replaces any previously installed module-scoped kernel. Failure","/// clears any previously installed module-scoped kernel through the same","/// initialization failure behavior as [`init`].","pub fn init_embedded() -> Result {"," let (kernel, head) = build_kernel_head(warp_kernel::WarpKernel::new)?;"," let worldline_id = kernel.default_worldline_id();"," install_trusted_kernel(Box::new(kernel));"," Ok(EmbeddedHandle { worldline_id, head })","#[cfg(all(test, feature = \"engine\", not(feature = \"experimental-warp-drive-g2b\")))]","mod default_engine_tests {"," use super::*;"," use echo_wasm_abi::kernel_port::{"," error_codes, ObservationAt, ObservationCoordinate, ObservationFrame, ObservationProjection,"," ObservationRequest,"," #[test]"," fn default_init_embedded_does_not_register_warp_drive_g2b_observer() {"," let handle = init_embedded().unwrap();"," let request = ObservationRequest::builtin_one_shot("," ObservationCoordinate {"," worldline_id: handle.worldline_id,"," at: ObservationAt::Frontier,"," },"," ObservationFrame::QueryView,"," ObservationProjection::Query {"," query_id: 0x5744_4732,"," vars_bytes: b\"{\\\"projection\\\":\\\"g2b-head\\\",\\\"version\\\":1}\".to_vec(),"," )"," .unwrap();"," let request_bytes = echo_wasm_abi::encode_cbor(&request).unwrap();"," let response_bytes = observe_cbor(&request_bytes);"," let error = echo_wasm_abi::decode_cbor::(&response_bytes).unwrap();"," assert_eq!(error.code, error_codes::UNSUPPORTED_QUERY);","#[cfg(all(test, feature = \"engine\", feature = \"experimental-warp-drive-g2b\"))]","mod experimental_warp_drive_g2b_tests {"," error_codes, ObservationArtifact, ObservationAt, ObservationCoordinate, ObservationFrame,"," ObservationPayload, ObservationProjection, ObservationRequest,"," fn experimental_query_observer_returns_query_bytes() {"," let artifact = observe_g2b(experimental_warp_drive_g2b::HEAD_QUERY_VARS.to_vec()).unwrap();"," let ObservationPayload::QueryBytes { data } = artifact.payload else {"," panic!(\"expected QueryBytes payload\");"," };"," let json = String::from_utf8(data).unwrap();"," assert!(json.contains(\"\\\"kind\\\":\\\"echo-projected-file\\\"\"));"," assert!(json.contains(\"\\\"gate\\\":\\\"G2b\\\"\"));"," assert!(json.contains(\"\\\"source\\\":\\\"echo-observation-payload\\\"\"));"," assert!(json.contains(\"\\\"projection_hash\\\"\"));"," for field in [\"worldline\", \"frontier\", \"state_root\", \"projection_hash\"] {"," assert_nonzero_hex64(field, json_string_value(&json, field));"," assert!(!json.contains(\"/echo/head.json\"));"," assert!(!json.contains(\"\\\"artifact_hash\\\"\"));"," fn experimental_query_observer_rejects_invalid_vars() {"," let error = observe_g2b(b\"{\\\"path\\\":\\\"/echo/head.json\\\"}\".to_vec()).unwrap_err();"," // TODO: replace CODEC_ERROR with INVALID_QUERY_VARS once the ABI"," // exposes a more precise query-vars error code."," assert_eq!(error.code, error_codes::CODEC_ERROR);"," fn observe_g2b(vars_bytes: Vec) -> Result {"," query_id: experimental_warp_drive_g2b::HEAD_QUERY_ID,"," vars_bytes,"," match echo_wasm_abi::decode_cbor::>(&response_bytes) {"," Ok(envelope) => Ok(envelope.data),"," Err(_) => Err(echo_wasm_abi::decode_cbor::(&response_bytes).unwrap()),"," fn json_string_value<'a>(json: &'a str, key: &str) -> &'a str {"," let needle = format!(\"\\\"{key}\\\":\\\"\");"," let start = json"," .find(&needle)"," .unwrap_or_else(|| panic!(\"missing JSON string field `{key}`\"))"," + needle.len();"," let rest = &json[start..];"," let end = rest"," .find('\"')"," .unwrap_or_else(|| panic!(\"unterminated JSON string field `{key}`\"));"," &rest[..end]"," fn assert_nonzero_hex64(field: &str, value: &str) {"," assert_eq!(value.len(), 64, \"{field} should be 64 hex chars\");"," assert!("," value"," .bytes()"," .all(|byte| byte.is_ascii_digit() || (b'a'..=b'f').contains(&byte)),"," \"{field} should be lowercase hex: {value}\""," );"," value.bytes().any(|byte| byte != b'0'),"," \"{field} should not be all zeros\"","// Console panic hook","#[cfg(feature = \"console-panic\")]","#[wasm_bindgen(start)]","/// Initialize console panic hook for better error messages in browser.","pub fn init_console_panic_hook() {"," console_error_panic_hook::set_once();","// ABI exports (v3)","/// Initialize the default engine kernel.","/// When compiled with the `engine` feature, this creates a `WarpKernel`","/// backed by `warp-core::Engine`. Without the feature, this returns","/// a \"not supported\" error.","#[wasm_bindgen]","pub fn init() -> Uint8Array {"," #[cfg(feature = \"engine\")]"," {"," init_with_factory(warp_kernel::WarpKernel::new)"," #[cfg(not(feature = \"engine\"))]"," encode_err_raw("," kernel_port::error_codes::NOT_SUPPORTED,"," \"no engine feature enabled; install a kernel via install_kernel()\",","/// Enqueue a canonical intent payload.","/// Returns CBOR-encoded [`DispatchResponse`](kernel_port::DispatchResponse)","/// on success, or an error envelope.","pub fn dispatch_intent(intent_bytes: &[u8]) -> Uint8Array {"," encode_result(with_kernel(|k| {","/// Execute a privileged scheduler/runtime control intent.","/// This export is for trusted host/runtime-owner adapters. Application-facing","/// clients must use `dispatch_intent`, `observe`, and `scheduler_status` only.","/// The input bytes must be a packed `ControlIntentV1` EINT envelope.","pub fn dispatch_control_intent_trusted(control_intent_bytes: &[u8]) -> Uint8Array {"," return encode_err(&AbiError {"," encode_result(with_trusted_kernel(|k| {","/// Propose an intent through an explicit optic dispatch request.","/// The request bytes must decode as canonical-CBOR `DispatchOpticIntentRequest`.","pub fn dispatch_optic_intent(request_bytes: &[u8]) -> Uint8Array {"," encode_result(dispatch_optic_intent_result(request_bytes))","/// Observe through an explicit optic request.","/// The request bytes must decode as canonical-CBOR `ObserveOpticRequest`.","pub fn observe_optic(request_bytes: &[u8]) -> Uint8Array {"," let request = match echo_wasm_abi::decode_cbor::(request_bytes) {"," message: format!(\"invalid optic observe request payload: {err}\"),"," encode_result(with_kernel_ref(|k| k.observe_optic(request)))","/// Observe a worldline at an explicit coordinate, frame, and projection.","/// The request bytes must decode as canonical-CBOR `ObservationRequest`.","pub fn observe(request_bytes: &[u8]) -> Uint8Array {"," encode_result(with_kernel_ref(|k| k.observe(request)))","/// Publish the local neighborhood site for an explicit observation request.","pub fn observe_neighborhood_site(request_bytes: &[u8]) -> Uint8Array {"," encode_result(with_kernel_ref(|k| k.observe_neighborhood_site(request)))","/// Publish the shared neighborhood-core projection for an explicit observation request.","pub fn observe_neighborhood_core(request_bytes: &[u8]) -> Uint8Array {"," encode_result(with_kernel_ref(|k| k.observe_neighborhood_core(request)))","/// Compare a strand suffix against its recorded base coordinate.","/// The request bytes must decode as canonical-CBOR `SettlementRequest`.","pub fn compare_settlement(request_bytes: &[u8]) -> Uint8Array {"," let request = match echo_wasm_abi::decode_cbor::(request_bytes) {"," message: format!(\"invalid settlement request payload: {err}\"),"," encode_result(with_kernel_ref(|k| k.compare_settlement(request)))","/// Produce a deterministic settlement plan for one strand.","pub fn plan_settlement(request_bytes: &[u8]) -> Uint8Array {"," encode_result(with_kernel_ref(|k| k.plan_settlement(request)))","/// Execute the deterministic settlement plan for one strand.","pub fn settle_strand(request_bytes: &[u8]) -> Uint8Array {"," encode_result(with_kernel(|k| k.settle_strand(request)))","/// Return registry metadata (schema hash, codec id, registry version).","/// Returns CBOR-encoded [`RegistryInfo`](kernel_port::RegistryInfo).","pub fn get_registry_info() -> Uint8Array {"," encode_result(with_kernel_ref(|k| Ok(k.registry_info())))","/// Return the current read-only scheduler status envelope.","/// The returned bytes are canonical-CBOR encoded","/// [`SchedulerStatus`](kernel_port::SchedulerStatus) metadata. Callers should","/// decode the returned `Uint8Array` as `SchedulerStatus` and treat it as an","/// observation-only snapshot of scheduler lifecycle state; it does not advance","/// the runtime or mutate scheduler policy.","/// Returns a `NOT_INITIALIZED` ABI error envelope until a kernel has been","/// installed via [`init`].","pub fn scheduler_status() -> Uint8Array {"," encode_result(with_kernel_ref(|k| k.scheduler_status()))","/// Get the codec identifier from the installed registry.","pub fn get_codec_id() -> JsValue {"," let result = with_kernel_ref(|k| Ok(k.registry_info()));"," Ok(info) => match info.codec_id {"," Some(id) => JsValue::from_str(&id),"," None => JsValue::NULL,"," Err(_) => JsValue::NULL,","/// Get the registry version from the installed registry.","pub fn get_registry_version() -> JsValue {"," Ok(info) => match info.registry_version {"," Some(v) => JsValue::from_str(&v),","/// Get the schema hash (hex) from the installed registry.","pub fn get_schema_sha256_hex() -> JsValue {"," Ok(info) => match info.schema_sha256_hex {"," Some(h) => JsValue::from_str(&h),","// Schema validation helpers (test-only, retained from previous impl)","#[cfg(test)]","fn validate_object_against_args("," value: &serde_value::Value,"," args: &[echo_registry_api::ArgDef],"," enums: &[echo_registry_api::EnumDef],",") -> bool {"," let obj = match value {"," serde_value::Value::Map(map) => map,"," _ => return false,"," // Unknown keys?"," for key in obj.keys() {"," let serde_value::Value::String(s) = key else {"," return false;"," if !args.iter().any(|a| a.name == s.as_str()) {"," // Required + type checks"," for arg in args {"," let v = obj.get(&serde_value::Value::String(arg.name.to_string()));"," let Some(v) = v else {"," if arg.required {"," return false;"," continue;"," // Type check"," let ok = if arg.list {"," match v {"," serde_value::Value::Seq(items) => {"," items.iter().all(|item| scalar_type_ok(item, arg.ty, enums))"," }"," _ => false,"," } else {"," scalar_type_ok(v, arg.ty, enums)"," if !ok {"," true","fn scalar_type_ok(v: &serde_value::Value, ty: &str, enums: &[echo_registry_api::EnumDef]) -> bool {"," match ty {"," \"String\" | \"ID\" => matches!(v, serde_value::Value::String(_)),"," \"Boolean\" => matches!(v, serde_value::Value::Bool(_)),"," \"Int\" => matches!("," v,"," serde_value::Value::I8(_)"," | serde_value::Value::I16(_)"," | serde_value::Value::I32(_)"," | serde_value::Value::I64(_)"," | serde_value::Value::U8(_)"," | serde_value::Value::U16(_)"," | serde_value::Value::U32(_)"," | serde_value::Value::U64(_)"," \"Float\" => matches!("," serde_value::Value::F32(_)"," | serde_value::Value::F64(_)"," | serde_value::Value::I8(_)"," other => {"," // enum check"," if let Some(def) = enums.iter().find(|e| e.name == other) {"," if let serde_value::Value::String(s) = v {"," def.values.contains(&s.as_str())"," } else {"," false"," false // unknown type -> reject to prevent schema drift","mod schema_validation_tests {"," use echo_registry_api::{ArgDef, EnumDef};"," use serde_value::Value as SV;"," use std::collections::BTreeMap;"," fn sv_map(entries: Vec<(SV, SV)>) -> SV {"," let mut map = BTreeMap::new();"," for (k, v) in entries {"," map.insert(k, v);"," SV::Map(map)"," fn enums_theme() -> Vec {"," vec![EnumDef {"," name: \"Theme\","," values: &[\"LIGHT\", \"DARK\", \"SYSTEM\"],"," }]"," fn reject_unknown_keys() {"," let args = vec![ArgDef {"," name: \"path\","," ty: \"String\","," required: true,"," list: false,"," }];"," let val_sv = sv_map(vec!["," (SV::String(\"path\".into()), SV::String(\"ok\".into())),"," (SV::String(\"extra\".into()), SV::I64(1)),"," ]);"," assert!(!validate_object_against_args("," &val_sv,"," &args,"," &enums_theme(),"," ));"," fn reject_missing_required() {"," let val_sv = sv_map(vec![]);"," fn reject_enum_mismatch() {"," name: \"mode\","," ty: \"Theme\","," let val_sv = sv_map(vec![("," SV::String(\"mode\".into()),"," SV::String(\"WRONG\".into()),"," )]);"," fn reject_unknown_type() {"," name: \"obj\","," ty: \"AppState\","," SV::String(\"obj\".into()),"," sv_map(vec![("," SV::String(\"routePath\".into()),"," SV::String(\"/\".into()),"," )]),","#[cfg(all(test, feature = \"engine\"))]","#[allow(clippy::unwrap_used)]","mod init_tests {"," AdmissionLawId, AdmissionOutcomeKind, BaseRef, BuiltinObserverPlan, ConflictArtifactDraft,"," ConflictReason, ControlIntentV1, CoordinateAt, DispatchOpticIntentRequest,"," DispatchResponse, EchoCoordinate, GlobalTick, HeadInfo, HeadObservation, IntentFamilyId,"," NeighborhoodCore, NeighborhoodParticipant, NeighborhoodParticipantRole,"," NeighborhoodPlurality, NeighborhoodSite, NeighborhoodSiteId, ObservationArtifact,"," ObservationAt, ObservationBasisPosture, ObservationFrame, ObservationPayload,"," ObservationProjection, OpticActorId, OpticCapability, OpticCapabilityId, OpticCause,"," OpticFocus, OpticId, OpticIntentPayload, OpticReadBudget, ParticipantRole,"," ProjectionVersion, ProvenanceRef, ReadingBudgetPosture, ReadingEnvelope,"," ReadingObserverBasis, ReadingObserverPlan, ReadingResidualPosture, ReadingRightsPosture,"," ReadingWitnessRef, RegistryInfo, ResolvedObservationCoordinate, RunCompletion, RunId,"," SchedulerMode, SchedulerState, SchedulerStatus, SettlementBasisReport, SettlementDecision,"," SettlementDelta, SettlementParentRevalidation, SettlementPlan, SettlementRequest,"," SettlementResult, SiteParticipant, SitePlurality, WorkState, WorldlineId, WorldlineTick,"," ABI_VERSION,"," struct StubKernel;"," impl StubKernel {"," fn current_head() -> HeadInfo {"," HeadInfo {"," worldline_tick: WorldlineTick(0),"," commit_global_tick: None,"," state_root: vec![2; 32],"," commit_id: vec![3; 32],"," impl KernelPort for StubKernel {"," fn dispatch_intent(&mut self, _intent_bytes: &[u8]) -> Result {"," Ok(DispatchResponse {"," accepted: true,"," intent_id: vec![0; 32],"," submission_id: Some(vec![1; 32]),"," submission_generation: Some(1),"," scheduler_status: SchedulerStatus {"," state: SchedulerState::Inactive,"," active_mode: Some(SchedulerMode::UntilIdle {"," cycle_limit: Some(1),"," }),"," work_state: WorkState::Quiescent,"," run_id: Some(RunId(1)),"," latest_cycle_global_tick: Some(GlobalTick(1)),"," latest_commit_global_tick: Some(GlobalTick(1)),"," last_quiescent_global_tick: Some(GlobalTick(1)),"," last_run_completion: Some(RunCompletion::Quiesced),"," },"," fn observe(&self, _request: ObservationRequest) -> Result {"," let head = Self::current_head();"," Ok(ObservationArtifact {"," resolved: ResolvedObservationCoordinate {"," observation_version: 2,"," worldline_id: WorldlineId::from_bytes([9; 32]),"," requested_at: ObservationAt::Frontier,"," resolved_worldline_tick: head.worldline_tick,"," commit_global_tick: head.commit_global_tick,"," observed_after_global_tick: Some(GlobalTick(1)),"," state_root: head.state_root.clone(),"," commit_hash: head.commit_id.clone(),"," reading: ReadingEnvelope {"," observer_plan: ReadingObserverPlan::Builtin {"," plan: BuiltinObserverPlan::CommitBoundaryHead,"," },"," observer_instance: None,"," observer_basis: ReadingObserverBasis::CommitBoundary,"," contract: None,"," query_identity: None,"," retained_evidence: Vec::new(),"," witness_refs: vec![ReadingWitnessRef::EmptyFrontier {"," worldline_id: WorldlineId::from_bytes([9; 32]),"," state_root: head.state_root.clone(),"," commit_hash: head.commit_id.clone(),"," }],"," parent_basis_posture: ObservationBasisPosture::Worldline,"," budget_posture: ReadingBudgetPosture::UnboundedOneShot,"," rights_posture: ReadingRightsPosture::KernelPublic,"," residual_posture: ReadingResidualPosture::Complete,"," frame: ObservationFrame::CommitBoundary,"," projection: ObservationProjection::Head,"," artifact_hash: vec![4; 32],"," payload: ObservationPayload::Head {"," head: HeadObservation {"," worldline_tick: head.worldline_tick,"," commit_global_tick: head.commit_global_tick,"," state_root: head.state_root,"," commit_id: head.commit_id,"," fn observe_neighborhood_site("," &self,"," _request: ObservationRequest,"," ) -> Result {"," Ok(NeighborhoodSite {"," site_id: NeighborhoodSiteId::from_bytes([7; 32]),"," anchor: ResolvedObservationCoordinate {"," resolved_worldline_tick: WorldlineTick(0),"," commit_global_tick: None,"," state_root: vec![2; 32],"," commit_hash: vec![3; 32],"," plurality: SitePlurality::Singleton,"," participants: vec![SiteParticipant {"," strand_id: None,"," role: ParticipantRole::Primary,"," tick: WorldlineTick(0),"," state_hash: vec![2; 32],"," }],"," fn observe_neighborhood_core("," ) -> Result {"," Ok(NeighborhoodCore {"," site_id: \"site:stub\".into(),"," anchor_lane_id: \"wl:stub\".into(),"," anchor_frame_index: 0,"," anchor_head_id: None,"," outcome_kind: AdmissionOutcomeKind::Derived,"," plurality: NeighborhoodPlurality::Singleton,"," participants: vec![NeighborhoodParticipant {"," participant_id: \"participant:stub:primary:0\".into(),"," lane_id: \"wl:stub\".into(),"," role: NeighborhoodParticipantRole::Primary,"," frame_index: 0,"," state_hash: \"02\".repeat(32),"," summary: \"Stub neighborhood core\".into(),"," fn compare_settlement("," request: SettlementRequest,"," ) -> Result {"," let base_ref = BaseRef {"," source_worldline_id: WorldlineId::from_bytes([9; 32]),"," fork_tick: WorldlineTick(0),"," commit_hash: vec![3; 32],"," boundary_hash: vec![2; 32],"," provenance_ref: ProvenanceRef {"," worldline_tick: WorldlineTick(0),"," };"," Ok(SettlementDelta {"," strand_id: request.strand_id,"," base_ref: base_ref.clone(),"," source_worldline_id: WorldlineId::from_bytes([4; 32]),"," source_suffix_start_tick: WorldlineTick(1),"," source_suffix_end_tick: WorldlineTick(1),"," source_entries: vec![ProvenanceRef {"," worldline_id: WorldlineId::from_bytes([4; 32]),"," worldline_tick: WorldlineTick(1),"," commit_hash: vec![8; 32],"," basis_report: SettlementBasisReport {"," parent_anchor: base_ref,"," child_worldline_id: WorldlineId::from_bytes([4; 32]),"," source_suffix_start_tick: WorldlineTick(1),"," source_suffix_end_tick: Some(WorldlineTick(1)),"," realized_parent_ref: ProvenanceRef {"," worldline_tick: WorldlineTick(0),"," commit_hash: vec![3; 32],"," owned_closed_slot_count: 2,"," parent_written_slot_count: 0,"," parent_revalidation: SettlementParentRevalidation::AtAnchor,"," fn plan_settlement(&self, request: SettlementRequest) -> Result {"," let target_base_ref = ProvenanceRef {"," worldline_id: WorldlineId::from_bytes([9; 32]),"," Ok(SettlementPlan {"," target_worldline: WorldlineId::from_bytes([9; 32]),"," target_base_ref: target_base_ref.clone(),"," parent_anchor: BaseRef {"," source_worldline_id: WorldlineId::from_bytes([9; 32]),"," fork_tick: WorldlineTick(0),"," boundary_hash: vec![2; 32],"," provenance_ref: target_base_ref.clone(),"," realized_parent_ref: target_base_ref,"," decisions: vec![SettlementDecision::ConflictArtifact {"," artifact: ConflictArtifactDraft {"," artifact_id: vec![7; 32],"," source_ref: ProvenanceRef {"," worldline_id: WorldlineId::from_bytes([4; 32]),"," worldline_tick: WorldlineTick(1),"," commit_hash: vec![8; 32],"," },"," channel_ids: vec![vec![6; 32]],"," reason: ConflictReason::BaseDivergence,"," overlap_revalidation: None,"," fn settle_strand("," &mut self,"," ) -> Result {"," let plan = self.plan_settlement(request)?;"," Ok(SettlementResult {"," plan,"," appended_imports: Vec::new(),"," appended_conflicts: vec![ProvenanceRef {"," commit_hash: vec![5; 32],"," fn registry_info(&self) -> RegistryInfo {"," RegistryInfo {"," codec_id: Some(\"stub\".into()),"," registry_version: None,"," schema_sha256_hex: None,"," abi_version: ABI_VERSION,"," fn scheduler_status(&self) -> Result {"," Ok(SchedulerStatus {"," state: SchedulerState::Inactive,"," active_mode: None,"," work_state: WorkState::Quiescent,"," run_id: None,"," latest_cycle_global_tick: None,"," latest_commit_global_tick: None,"," last_quiescent_global_tick: None,"," last_run_completion: None,"," impl TrustedKernelControlPort for StubKernel {"," fn dispatch_control_intent_trusted("," intent: ControlIntentV1,"," ) -> Result {"," assert!(matches!("," intent,"," ControlIntentV1::Start {"," mode: SchedulerMode::UntilIdle {"," cycle_limit: Some(1)"," }"," ));"," intent_id: vec![42; 32],"," submission_id: None,"," submission_generation: None,"," active_mode: None,"," run_id: Some(RunId(7)),"," fn clear_kernel_removes_previously_installed_kernel() {"," clear_kernel();"," install_kernel(Box::new(StubKernel));"," assert!(with_kernel_ref(|k| Ok(k.registry_info())).is_ok());"," let result = with_kernel_ref(|k| Ok(k.registry_info()));"," assert!(result.is_err());"," let Err(err) = result else {"," unreachable!(\"registry_info should fail after clear_kernel\");"," assert_eq!(err.code, kernel_port::error_codes::NOT_INITIALIZED);"," fn public_dispatch_rejects_packed_control_intent_start() {"," let control = echo_wasm_abi::pack_control_intent_v1(&ControlIntentV1::Start {"," mode: SchedulerMode::UntilIdle {"," cycle_limit: Some(1),"," })"," let response = dispatch_intent_cbor(&control);"," let err: ErrEnvelope = echo_wasm_abi::decode_cbor(&response).unwrap();"," assert_eq!(err.code, kernel_port::error_codes::FORBIDDEN_CONTROL_INTENT);"," fn trusted_control_dispatches_packed_control_intent_start() {"," install_trusted_kernel(Box::new(StubKernel));"," let response = dispatch_control_intent_trusted_cbor(&control);"," let envelope: OkEnvelope = echo_wasm_abi::decode_cbor(&response).unwrap();"," assert!(envelope.data.accepted);"," assert_eq!(envelope.data.intent_id, vec![42; 32]);"," assert_eq!("," envelope.data.scheduler_status.last_run_completion,"," Some(RunCompletion::Quiesced)"," fn trusted_control_is_unavailable_for_app_only_installed_kernel() {"," assert_eq!(err.code, kernel_port::error_codes::NOT_SUPPORTED);"," fn trusted_control_rejects_non_control_intent_envelope() {"," let app_intent = echo_wasm_abi::pack_intent_v1(1, b\"not-control\").unwrap();"," let response = dispatch_control_intent_trusted_cbor(&app_intent);"," assert_eq!(err.code, kernel_port::error_codes::INVALID_PAYLOAD);"," fn public_dispatch_rejects_hand_built_reserved_control_op_id() {"," let mut bytes = Vec::new();"," bytes.extend_from_slice(b\"EINT\");"," bytes.extend_from_slice(&CONTROL_INTENT_V1_OP_ID.to_le_bytes());"," bytes.extend_from_slice(&0u32.to_le_bytes());"," let response = dispatch_intent_cbor(&bytes);"," fn public_optic_dispatch_rejects_hand_built_reserved_control_op_id() {"," let worldline_id = WorldlineId::from_bytes([3; 32]);"," let focus = OpticFocus::Worldline { worldline_id };"," let actor = OpticActorId::from_bytes([4; 32]);"," let intent_family = IntentFamilyId::from_bytes([5; 32]);"," let request = DispatchOpticIntentRequest {"," optic_id: OpticId::from_bytes([1; 32]),"," base_coordinate: EchoCoordinate::Worldline {"," worldline_id,"," at: CoordinateAt::Frontier,"," intent_family,"," focus: focus.clone(),"," cause: OpticCause {"," actor,"," cause_hash: vec![6; 32],"," label: Some(\"optic dispatch\".into()),"," capability: OpticCapability {"," capability_id: OpticCapabilityId::from_bytes([7; 32]),"," issuer_ref: None,"," policy_hash: vec![8; 32],"," allowed_focus: focus,"," projection_version: ProjectionVersion(1),"," reducer_version: None,"," allowed_intent_family: intent_family,"," max_budget: OpticReadBudget {"," max_bytes: Some(4096),"," max_nodes: Some(64),"," max_ticks: Some(8),"," max_attachments: Some(0),"," admission_law: AdmissionLawId::from_bytes([9; 32]),"," payload: OpticIntentPayload::EintV1 { bytes },"," let err = dispatch_optic_intent_result(&request_bytes).unwrap_err();"," fn init_failure_clears_preexisting_kernel() {"," let result = build_kernel_head(|| Err(warp_kernel::KernelInitError::NonFreshEngine));"," unreachable!(\"build_kernel_head unexpectedly succeeded\");"," assert_eq!(err.code, kernel_port::error_codes::ENGINE_ERROR);"," unreachable!(\"registry_info should fail after init failure\");"," fn neighborhood_observation_uses_installed_kernel() {"," kernel_port::ObservationCoordinate {"," ObservationFrame::CommitBoundary,"," ObservationProjection::Head,"," let site = with_kernel_ref(|k| k.observe_neighborhood_site(request)).unwrap();"," assert_eq!(site.plurality, SitePlurality::Singleton);"," assert_eq!(site.participants.len(), 1);"," assert_eq!(site.participants[0].role, ParticipantRole::Primary);"," fn neighborhood_core_publication_uses_installed_kernel() {"," let core = with_kernel_ref(|k| k.observe_neighborhood_core(request)).unwrap();"," assert_eq!(core.outcome_kind, AdmissionOutcomeKind::Derived);"," assert_eq!(core.plurality, NeighborhoodPlurality::Singleton);"," assert_eq!(core.participants.len(), 1);"," core.participants[0].role,"," NeighborhoodParticipantRole::Primary"," fn settlement_publication_uses_installed_kernel() {"," let request = SettlementRequest {"," strand_id: kernel_port::StrandId::from_bytes([4; 32]),"," let delta = with_kernel_ref(|k| k.compare_settlement(request.clone())).unwrap();"," assert_eq!(delta.strand_id, request.strand_id);"," assert_eq!(delta.source_entries.len(), 1);"," let plan = with_kernel_ref(|k| k.plan_settlement(request.clone())).unwrap();"," assert_eq!(plan.decisions.len(), 1);"," assert!(matches!("," &plan.decisions[0],"," SettlementDecision::ConflictArtifact { artifact }"," if artifact.reason == ConflictReason::BaseDivergence"," let result = with_kernel(|k| k.settle_strand(request)).unwrap();"," assert!(result.appended_imports.is_empty());"," assert_eq!(result.appended_conflicts.len(), 1);",[1526,1527,1528,1529,1530],{"_629":45,"_45":1538},{"_629":1532,"_159":645,"_651":1536,"_653":1537},{"_629":45,"_45":1535},{"_629":1532,"_159":645,"_651":1533,"_653":1534},{"_629":45,"_45":1531},"\n* I did not commit or create a PR because there were no new changes to make. The existing unstaged `pnpm-lock.yaml` modification was left untouched.\n\n**Testing**\n* ✅ `git diff --check -- crates/warp-wasm/src/lib.rs`\n* ✅ `git status --short --branch`\n* ⚠️ `git show --stat --oneline --decorate 875780b151e9` — the referenced SHA was not present in this local checkout, so I validated the effective docs in the current branch instead.","repo_file_citation",434,439,"\n* The `init_embedded()` error contract already states both lifecycle side effects requested in the self-review: success replaces any previously installed module-scoped kernel, and failure clears any previously installed module-scoped kernel via the same initialization failure behavior as `init`. ",426,432,"**Summary**\n* No new code or documentation changes were needed. The current checkout already documents that `init_embedded()` installs the module-scoped trusted kernel and makes the native observation/dispatch APIs ready for use. ",{"_90":321,"_41":82,"_94":321,"_1541":1542,"_1543":1544,"_1545":1546,"_130":-5,"_117":1547},[81],"input_items",[1565,1566,1567,1568,1569],"external_post_config",{"_1548":1549,"_260":194,"_1550":301,"_271":-5,"_1551":254,"_1552":-5,"_1553":1554,"_1555":1556,"_1557":-5,"_1558":-5,"_1559":1560,"_1561":15,"_1562":57,"_1563":52,"_1564":15},"user_model_slug","slug",1780309957.097451,"installation_id",89912914,"pr_number","repo_id","review_trigger","comment_id",4591751041,"comment_type","issue","pr_write_guard_token","pending_pr_reaction_id","pending_comment_reaction_id",364009506,"comment_if_no_findings","comment_on_error","share_url","is_parallel_review",{"_90":400,"_94":321,"_395":1580},{"_308":309,"_310":1576,"_1577":315,"_1578":127,"_317":-5,"_90":1579},{"_90":1570,"_310":1575,"_159":-5,"_1572":-5,"_1573":-5},{"_90":1570,"_310":1574,"_159":-5,"_1572":-5,"_1573":-5},{"_90":1570,"_310":1571,"_159":-5,"_1572":-5,"_1573":-5},"pull_request_comment","**Summary**\n* Updated `init_embedded()` API documentation to state that successful initialization replaces any previously installed module-scoped trusted kernel. [crates/warp-wasm/src/lib.rsL428-L434](https://github.com/flyingrobots/echo/blob/1b27c577cf5ae9e1049356044caf5284095f6aae/crates/warp-wasm/src/lib.rs#L428-L434)\n* Clarified the failure contract: kernel construction or initial head observation failure clears any previously installed module-scoped trusted kernel via the existing initialization failure behavior. [crates/warp-wasm/src/lib.rsL436-L440](https://github.com/flyingrobots/echo/blob/1b27c577cf5ae9e1049356044caf5284095f6aae/crates/warp-wasm/src/lib.rs#L436-L440)\n* Committed the change as `b8cf382 docs(warp-wasm): clarify init_embedded kernel replacement`.\n* Created a PR titled `docs(warp-wasm): clarify init_embedded kernel replacement`.\n* Note: the pre-existing unstaged `pnpm-lock.yaml` modification was left untouched and uncommitted.\n\n**Testing**\n* ✅ `cargo fmt --manifest-path crates/warp-wasm/Cargo.toml`\n* ✅ `cargo check --manifest-path crates/warp-wasm/Cargo.toml --features engine`\n* ✅ `git diff --check -- crates/warp-wasm/src/lib.rs`\n* ✅ `cargo test --manifest-path crates/warp-wasm/Cargo.toml --features engine --lib default_engine_tests`\n\n [View task →](https://chatgpt.com/s/cd_6a1d5786ea5c8191809dbd52937b11e6)","side","line","@codex self-review findings after diffing `feat/warp-drive-g1` against `origin/main`.\n\n| Severity | File | Lines | Type | Finding | Recommended mitigation |\n| --- | --- | ---: | --- | --- | --- |\n| Medium | `crates/warp-wasm/src/lib.rs` | `426-439` | API documentation / side-effect contract | The new `init_embedded()` docs say failure “does not install a new kernel”, but the shared `build_kernel_head()` helper clears the module-scoped kernel on initialization or head-observation failure (`crates/warp-wasm/src/lib.rs:368-387`). If a native embedder already installed a kernel, a failed `init_embedded()` call removes it. The docs are therefore technically true only in the narrow “does not install the failed kernel” sense, but omit the destructive side effect on any previously installed kernel. | Prompt: “Update the `init_embedded()` documentation to explicitly say that success replaces any previously installed kernel and failure clears any previously installed kernel via the existing initialization failure behavior, or change the implementation if preserving an existing kernel is intended.” |\n\nIssue count: Critical 0, High 0, Medium 1, Low 0.\n\nAdditional review notes:\n- `git diff --check origin/main...HEAD` is clean.\n- The G2b observer is correctly feature-fenced behind `experimental-warp-drive-g2b` and hidden from generated docs.\n- The default `engine` path is protected by a regression test that the WARP DRIVE query observer is not installed.\n- The projected payload avoids POSIX path leakage and uses `projection_hash`, not `artifact_hash`.\n","\n\n\n[![Review Change Stack](https://storage.googleapis.com/coderabbit_public_assets/review-stack-in-coderabbit-ui.svg)](https://app.coderabbit.ai/change-stack/flyingrobots/echo/pull/389?utm_source=github_walkthrough&utm_medium=github&utm_campaign=change_stack)\n\n\nNo actionable comments were generated in the recent review. 🎉\n\n

ℹ️ Recent review info

\n\n

⚙️ Run configuration

\n\n**Configuration used**: Path: .coderabbit.yaml\n\n**Review profile**: ASSERTIVE\n\n**Plan**: Pro\n\n**Run ID**: `17cea7fc-230b-4acd-b5a8-936e45cab518`\n\n

\n\n

📥 Commits

\n\nReviewing files that changed from the base of the PR and between 1ac17e70bb18fd835db4a09fd871a2bb0c4bb7b9 and 1b27c577cf5ae9e1049356044caf5284095f6aae.\n\n

\n\n

📒 Files selected for processing (3)

\n\n* `crates/warp-wasm/Cargo.toml`\n* `crates/warp-wasm/src/lib.rs`\n* `crates/warp-wasm/src/warp_kernel.rs`\n\n

\n\n

\n\n---\n\n\n

📝 Walkthrough

\n\n\n\n\n

🚥 Pre-merge checks | ✅ 5

\n\n

✅ Passed checks (5 passed)

\n\n_{✏️ Tip: You can configure your own custom pre-merge checks in the settings.}\n\n

\n\n\n\n\n

✨ Finishing Touches

\n\n

📝 Generate docstrings

\n\n- [ ] Create stacked PR\n- [ ] Commit on current branch\n\n

🧪 Generate unit tests (beta)

\n\n- [ ] Create PR with unit tests\n- [ ] Commit unit tests in branch `feat/warp-drive-g1`\n\n

\n\n

❤️ Share

\n\n\n_{Comment `@coderabbitai help` to get the list of available commands and usage tips.}\n\n\n\n\n\n\n\n","Adds a temporary WARP DRIVE G2b query observer in `warp-wasm`'s native engine path.\n\nThis is not the final Echo filesystem contract. It exists to prove that WARP DRIVE can request normal regular-file bytes through Echo's existing `ObservationProjection::Query -> ObservationPayload::QueryBytes` path.\n\nArchitecture guardrails:\n- The observer is fenced behind the non-default `experimental-warp-drive-g2b` feature.\n- Plain `engine` builds do not register the WARP DRIVE observer.\n- WARP DRIVE-specific constants live under `experimental_warp_drive_g2b`, not the `warp_wasm` crate root.\n- The experimental module is hidden from generated docs with `#[doc(hidden)]`.\n- Query vars name a projection, not a POSIX path: `{\"projection\":\"g2b-head\",\"version\":1}`.\n- The payload uses `projection_hash`, not `artifact_hash`, because it is not the self-hash of the final `ObservationArtifact`.\n- Tests assert stable ABI error codes rather than human message substrings.\n- `CODEC_ERROR` for invalid query vars is documented as temporary until the ABI exposes a more precise invalid-vars code.\n\nValidated Echo commit: `d8da6d0478bb`\nCurrent branch head: `1b27c577cf5a` comment-only TODO after validation.\n\nValidation:\n```sh\ncargo fmt --manifest-path crates/warp-wasm/Cargo.toml\ncargo check --manifest-path crates/warp-wasm/Cargo.toml --features engine\ncargo clippy --manifest-path crates/warp-wasm/Cargo.toml --features engine -- -D warnings\ncargo test --manifest-path crates/warp-wasm/Cargo.toml --features engine --lib default_engine_tests\ncargo check --manifest-path crates/warp-wasm/Cargo.toml --features experimental-warp-drive-g2b\ncargo clippy --manifest-path crates/warp-wasm/Cargo.toml --features experimental-warp-drive-g2b -- -D warnings\ncargo test --manifest-path crates/warp-wasm/Cargo.toml --features experimental-warp-drive-g2b --lib experimental_warp_drive_g2b_tests\ncargo test --manifest-path crates/warp-wasm/Cargo.toml --all-features\n```\n\nDownstream WARP DRIVE gate:\n- PR: flyingrobots/warp-drive#2\n- Branch: `gate/g2b`\n- WARP DRIVE validated implementation commit: `82a9fdc24484`\n- WARP DRIVE gate record head after proof refresh: `77b5e4707c44`\n- Copy-in Docker acceptance: 58 / 58 assertions\n\nNote: the local pre-push hook failed in this worktree because `.git` is a file, not a directory, and the hook attempted `mkdir .git`. The push was made with `--no-verify` after the explicit validation matrix above passed. The failing hook behavior is worktree-specific and unrelated to this diff.\n\n\n\n\n## Summary by CodeRabbit\n\n* **New Features**\n * Added embedded engine initialization capability enabling direct kernel construction and registration, returning a handle with worldline identity and head state information\n * Introduced optional experimental G2b head projection query feature for advanced observer scenarios\n\n* **Improvements**\n * Enhanced error handling with improved error source chain visibility across initialization failures\n\n","base_ref","head_ref","pull_request_info",[1581],{"_629":45,"_45":1582},"@codex resolved the self-review finding in `875780b151e9`.\n\n`init_embedded()` docs now explicitly state both lifecycle side effects:\n- success replaces any previously installed module-scoped kernel\n- failure clears any previously installed module-scoped kernel through the same initialization failure behavior as `init`\n\nThis is documentation-only; no behavior changed.\n",[1780,1781],[],{"_634":635,"_45":636,"_637":638},{"_608":1771},{"_332":1770},{"_332":1618},{"_300":301,"_292":302,"_303":304,"_305":57,"_306":15,"_307":15,"_308":309,"_310":311,"_312":264,"_313":125,"_314":315,"_316":127,"_317":318,"_319":-5,"_320":-5,"_321":1617,"_323":324,"_325":326,"_327":328,"_329":330},{"_41":121,"_191":192,"_193":194,"_195":15,"_196":197,"_198":199,"_200":1606,"_202":-5,"_203":-5,"_204":1607,"_206":207,"_208":207,"_209":1608,"_211":1609,"_213":1610,"_215":-5,"_216":217,"_218":219,"_220":221,"_222":1611,"_53":-5,"_117":224,"_225":1612,"_227":1613,"_229":230,"_231":15,"_232":15},{"_131":1599},[1593,1594,1595,1596,1597,1598],{"_146":169,"_148":163,"_150":164,"_152":161,"_154":170,"_156":157,"_158":31,"_159":-5},{"_146":168,"_148":163,"_150":164,"_152":161,"_154":165,"_156":157,"_158":31,"_159":-5},{"_146":166,"_148":163,"_150":164,"_152":161,"_154":167,"_156":157,"_158":31,"_159":-5},{"_146":162,"_148":163,"_150":164,"_152":161,"_154":165,"_156":157,"_158":31,"_159":-5},{"_146":160,"_148":149,"_150":151,"_152":161,"_154":155,"_156":157,"_158":31,"_159":-5},{"_146":147,"_148":149,"_150":151,"_152":153,"_154":155,"_156":157,"_158":31,"_159":-5},[1600,1601,1602],{"_175":1605,"_177":188},{"_175":1604,"_177":184},{"_175":1603,"_177":178},{"_179":180,"_90":181,"_117":182},{"_179":185,"_90":181,"_117":186},{"_179":189,"_90":181,"_117":190},{"_294":295,"_296":-5,"_297":-5,"_298":-5,"_299":-5},[254],{"_254":1614},{"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253},{},[],{"_235":57},{"_233":57,"_234":207},{"_41":256,"_179":257,"_258":1615,"_260":194,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":62,"_272":15,"_273":-5,"_274":-5,"_275":-5,"_276":-5,"_277":-5,"_278":-5,"_158":279,"_280":-5,"_53":1616},{"_286":287,"_41":288,"_90":289,"_290":291,"_292":293},{"_282":15,"_283":15,"_284":15,"_285":15},{"_286":287,"_179":287,"_331":-5,"_290":291,"_41":288},[1619,1620,1621,1622,1623,1624,1625,1626,1627,1628,1629,1630,1631,1632,1633,1634,1635,1636,1637,1638,1639,1640,1641,1642,1643,1644,1645,1646,1647,1648,1649,1650,1651,1652,1653,1654],{"_152":587,"_371":1766},{"_152":386,"_371":1763},{"_152":577,"_371":1760},{"_152":390,"_371":1755},{"_152":390,"_371":1750},{"_152":390,"_371":1746},{"_152":404,"_371":1741},{"_152":404,"_371":1737},{"_152":390,"_371":1734},{"_152":390,"_371":1732},{"_152":390,"_371":1730},{"_152":404,"_371":1726},{"_152":390,"_371":1724},{"_152":390,"_371":1722},{"_152":404,"_371":1718},{"_152":404,"_371":1714},{"_152":390,"_371":1711},{"_152":390,"_371":1709},{"_152":390,"_371":1707},{"_152":404,"_371":1703},{"_152":404,"_371":1699},{"_152":390,"_371":1696},{"_152":390,"_371":1694},{"_152":404,"_371":1690},{"_152":390,"_371":1688},{"_152":404,"_371":1684},{"_152":390,"_371":1681},{"_152":390,"_371":1679},{"_152":404,"_371":1675},{"_152":390,"_371":1673},{"_152":404,"_371":1669},{"_152":390,"_371":1666},{"_152":404,"_371":1664},{"_152":390,"_371":1660},{"_152":386,"_371":1658},{"_152":370,"_371":1655},{"_373":374,"_85":1656},{"_376":377,"_378":379,"_101":-5,"_41":380,"_381":1657,"_383":384,"_385":111},[],{"_385":1659,"_373":374},{"_90":389},{"_392":1661,"_373":374,"_394":380},{"_395":1662,"_397":-5,"_41":-5,"_398":399,"_94":91,"_90":400},[1663],{"_45":402,"_90":403},{"_392":1665,"_373":374,"_394":380},{"_41":407,"_398":399,"_45":402,"_90":408},{"_392":1667,"_373":374,"_394":380},{"_395":-5,"_411":-5,"_41":-5,"_412":1668,"_90":414},[],{"_392":1670,"_373":374,"_394":380},{"_395":1671,"_41":418,"_412":1672,"_90":414},[],[],{"_392":1674,"_373":374,"_394":380},{"_422":423,"_424":425,"_90":426},{"_392":1676,"_373":374,"_394":380},{"_429":430,"_431":432,"_433":1677,"_435":436,"_378":31,"_437":31,"_41":423,"_438":439,"_440":441,"_385":111,"_90":442},[1678],{"_431":444,"_90":445},{"_392":1680,"_373":374,"_394":380},{"_448":449,"_422":423,"_41":-5,"_179":450,"_451":-5,"_90":452},{"_392":1682,"_373":374,"_394":380},{"_395":-5,"_411":-5,"_41":-5,"_412":1683,"_90":414},[],{"_392":1685,"_373":374,"_394":380},{"_395":1686,"_41":459,"_412":1687,"_90":414},[],[],{"_392":1689,"_373":374,"_394":380},{"_422":463,"_424":464,"_90":426},{"_392":1691,"_373":374,"_394":380},{"_429":467,"_431":468,"_433":1692,"_435":436,"_378":31,"_437":31,"_41":463,"_438":470,"_440":441,"_385":111,"_90":442},[1693],{"_431":472,"_90":445},{"_392":1695,"_373":374,"_394":380},{"_448":475,"_422":463,"_41":-5,"_179":450,"_451":-5,"_90":452},{"_392":1697,"_373":374,"_394":380},{"_395":-5,"_411":-5,"_41":-5,"_412":1698,"_90":414},[],{"_392":1700,"_373":374,"_394":380},{"_395":1701,"_41":482,"_412":1702,"_90":414},[],[],{"_392":1704,"_373":374,"_394":380},{"_429":486,"_431":487,"_433":1705,"_435":436,"_378":489,"_437":31,"_41":490,"_438":491,"_440":441,"_385":111,"_90":442},[1706],{"_431":493,"_90":445},{"_392":1708,"_373":374,"_394":380},{"_422":490,"_424":496,"_90":426},{"_392":1710,"_373":374,"_394":380},{"_448":499,"_422":490,"_41":-5,"_179":450,"_451":-5,"_90":452},{"_392":1712,"_373":374,"_394":380},{"_395":-5,"_411":-5,"_41":-5,"_412":1713,"_90":414},[],{"_392":1715,"_373":374,"_394":380},{"_395":1716,"_41":506,"_412":1717,"_90":414},[],[],{"_392":1719,"_373":374,"_394":380},{"_429":510,"_431":511,"_433":1720,"_435":436,"_378":513,"_437":31,"_41":514,"_438":515,"_440":441,"_385":111,"_90":442},[1721],{"_431":517,"_90":445},{"_392":1723,"_373":374,"_394":380},{"_422":514,"_424":520,"_90":426},{"_392":1725,"_373":374,"_394":380},{"_448":523,"_422":514,"_41":-5,"_179":450,"_451":-5,"_90":452},{"_392":1727,"_373":374,"_394":380},{"_429":526,"_431":527,"_433":1728,"_435":436,"_378":529,"_437":31,"_41":530,"_438":531,"_440":441,"_385":111,"_90":442},[1729],{"_431":533,"_90":445},{"_392":1731,"_373":374,"_394":380},{"_422":530,"_424":536,"_90":426},{"_392":1733,"_373":374,"_394":380},{"_448":539,"_422":530,"_41":-5,"_179":450,"_451":-5,"_90":452},{"_392":1735,"_373":374,"_394":380},{"_395":-5,"_411":-5,"_41":-5,"_412":1736,"_90":414},[],{"_392":1738,"_373":374,"_394":380},{"_395":1739,"_41":546,"_412":1740,"_90":414},[],[],{"_392":1742,"_373":374,"_394":380},{"_395":1743,"_41":551,"_90":552},[1744],{"_45":554,"_555":1745,"_90":45},[],{"_392":1747,"_373":374,"_394":380},{"_395":1748,"_397":-5,"_41":-5,"_398":-5,"_94":321,"_90":400},[1749],{"_45":554,"_90":561},{"_392":1751,"_373":374,"_394":380},{"_395":1752,"_397":-5,"_41":-5,"_398":-5,"_94":321,"_90":400},[1753,1754],{"_45":568,"_90":561},{"_45":567,"_90":561},{"_392":1756,"_373":374,"_394":380},{"_395":1757,"_397":-5,"_41":-5,"_398":-5,"_94":572,"_90":400},[1758,1759],{"_45":576,"_90":561},{"_45":575,"_90":561},{"_373":374,"_85":1761},{"_101":-5,"_41":380,"_381":1762,"_383":384,"_385":581},[],{"_385":1764,"_373":374},{"_584":1765,"_90":586},[],{"_589":1767},{"_591":-5,"_592":-5,"_593":594,"_595":384,"_435":436,"_596":15,"_597":-5,"_598":-5,"_41":374,"_599":600,"_179":-5,"_159":601,"_602":207,"_440":603,"_385":1768,"_75":1769,"_606":384},{"_90":389},[],[],[1772],{"_41":611,"_612":1773,"_614":615,"_616":615,"_395":1774,"_385":618,"_397":-5,"_619":31,"_620":1775,"_622":623,"_624":-5},{"_94":321,"_179":-5,"_620":1779},{"_629":45,"_630":1778},{"_625":1776},{"_627":1777},[],[632],{},{"_90":400,"_94":91,"_395":1787},{"_90":641,"_642":1782},[1783],{"_159":645,"_646":-5,"_647":1784,"_649":-5},[1785],{"_651":652,"_653":654,"_395":1786,"_656":57},[657,658,207,659,660,661,662,663,660,664,660,665,666,667,660,668,660,669,660,670,671,672,673,674,207,675,676,677,207,678,679,680,681,682,683,684,685,207,686,207,687,688,689,690,691,692,693,694,695,696,697,698,699,207,700,696,701,702,703,704,207,705,706,705,207,707,708,704,207,709,710,711,704,207,712,713,714,715,716,717,718,207,719,714,720,721,717,718,207,722,714,723,724,717,718,704,207,725,688,726,727,688,728,688,729,730,731,732,733,704,207,734,688,735,736,737,688,728,688,729,738,731,739,733,704,207,740,741,688,742,743,744,745,746,747,748,704,207,749,750,688,751,752,753,754,755,756,757,758,759,760,761,717,762,763,704,207,764,688,765,766,767,704,207,768,688,769,770,771,772,773,774,757,758,759,775,761,717,762,776,777,748,704,207,778,683,779,731,780,733,704,207,781,688,782,783,784,785,786,787,731,788,789,790,791,792,793,794,704,207,795,796,785,797,787,731,798,799,790,791,792,800,794,704,207,801,802,785,803,787,731,788,789,790,791,792,804,805,806,792,807,794,704,207,808,809,810,811,812,813,814,815,207,816,817,818,819,820,718,207,821,704,207,822,823,824,825,826,827,704,207,828,829,830,831,832,718,704,207,833,834,835,836,837,838,759,839,840,792,841,842,704,207,705,843,705,207,844,845,846,704,207,847,848,849,850,851,852,853,814,718,704,207,854,855,856,704,207,857,858,704,207,859,860,861,704,207,862,863,864,704,207,865,866,867,868,869,718,704,207,870,867,871,872,718,704,207,873,688,874,875,876,877,878,879,880,881,704,207,705,882,705,207,683,883,207,683,884,785,885,787,886,887,888,889,890,891,840,892,757,893,894,895,896,761,717,718,704,207,683,897,785,885,787,898,899,900,901,902,903,904,890,905,906,907,908,840,717,909,718,704,207,705,910,705,207,911,683,912,913,914,915,916,704,207,917,688,918,919,920,921,922,688,923,688,924,925,926,927,683,928,929,930,931,932,704,207,933,934,935,936,937,938,762,207,939,940,941,942,943,944,945,946,947,948,949,950,946,951,952,207,953,954,955,956,718,704,207,957,958,935,936,959,960,762,207,939,961,962,963,964,965,966,967,968,969,970,971,972,717,973,974,718,207,939,975,976,977,978,979,718,207,980,941,942,943,944,945,946,947,948,981,982,946,951,952,207,953,954,983,984,985,717,718,207,986,987,988,989,990,991,992,993,994,995,996,718,207,997,998,999,1000,1001,1002,1003,1004,999,1005,1006,1004,718,704,207,705,1007,705,207,1008,1009,1010,1011,1012,704,207,705,1013,705,207,1014,688,1015,1016,1017,1018,1019,1020,1021,1022,718,1023,1021,1024,1025,1026,951,718,704,207,1027,688,1028,1029,1018,1030,1031,747,748,704,207,1032,688,1033,1034,1035,1018,1036,773,774,757,1037,759,775,761,717,762,1038,777,748,704,207,1039,688,1040,1018,1041,1042,704,207,1043,688,1044,1018,1045,1046,756,757,1037,759,1047,761,717,762,1048,704,207,1049,688,1050,1018,1051,755,756,757,1037,759,760,761,717,762,1052,704,207,1053,688,1050,1018,1054,755,756,757,1037,759,760,761,717,762,1055,704,207,1056,688,1050,1018,1057,755,756,757,1037,759,760,761,717,762,1058,704,207,1059,688,1060,1018,1061,1062,756,757,1037,759,1063,761,717,762,1064,704,207,1065,688,1060,1018,1066,1062,756,757,1037,759,1063,761,717,762,1067,704,207,1068,688,1060,1018,1069,1062,756,757,1037,759,1063,761,717,762,1070,704,207,1071,688,1072,1018,1073,1074,704,207,1075,688,1076,1077,1078,1079,1080,688,1081,1082,1018,1083,1084,704,207,1085,1018,1086,1087,867,1088,1089,1090,892,1091,718,704,207,1092,1018,1093,1087,867,1094,1095,1090,892,1091,718,704,207,1096,1018,1097,1087,867,1098,1099,1090,892,1091,718,704,207,705,1100,705,207,1101,1102,1103,1104,1105,1106,1107,1108,1109,762,207,1110,1111,1112,1113,965,1114,1113,717,718,207,1115,1116,1117,1118,1119,1120,840,1121,965,1122,1123,1124,1125,1126,1127,1128,840,1129,1130,965,1131,1113,717,718,1132,704,207,1101,1133,1134,1135,1136,1137,1138,1139,1140,1141,1142,1143,1144,1145,1146,814,1147,1138,1148,1149,1150,1140,1141,1142,1143,1144,1145,1146,814,1151,1152,1153,1154,1155,1156,1157,1127,904,1158,840,717,718,704,207,1101,1159,935,1160,1161,1162,207,1163,1164,1165,1166,717,1167,718,207,1168,1169,1170,1171,1172,718,207,939,1173,1174,1175,1176,1177,1178,1179,1180,1181,1182,1183,1184,1185,1186,1187,1188,718,207,939,1189,1174,1175,1176,1177,1178,1179,1190,1184,1185,1186,1187,1188,718,207,939,1191,1174,1192,1193,1177,1178,1179,1194,1195,1196,1197,1184,1185,1186,1187,1188,718,207,939,1198,1174,1199,1200,1177,1178,1179,1194,1201,1202,1203,1204,1205,1197,1184,1185,1186,1187,1188,718,704,207,1206,1207,1208,935,936,1209,1210,1211,1212,1213,1214,1215,1216,1217,1218,1219,1220,1221,1222,1223,762,207,1224,207,1225,1226,1227,1228,1229,1230,1231,840,717,718,207,1232,1233,1234,1235,1236,1237,1238,1239,1240,1241,1242,1243,1244,1245,1246,1247,1248,1249,1250,761,717,207,1251,1252,1253,1254,1255,1256,1257,1258,1259,1260,1261,1262,1250,1263,1264,1265,1266,1267,1268,1269,1270,1271,1272,1273,1274,1275,1276,1277,1278,1279,1280,1250,1281,1282,1283,1284,1285,1286,1287,1288,1289,1266,1250,761,717,207,1290,1291,1292,1293,1294,1295,1296,1255,1256,1257,1297,1298,1260,1299,1300,1250,1301,1302,1256,1303,1304,1305,1306,1307,761,717,207,1308,1291,1292,1309,1310,1311,1312,1313,1314,1315,1316,1317,1318,1319,1303,1320,1321,1322,1307,1323,761,717,207,1324,1291,1325,1326,1327,1328,1329,1330,1331,1332,1256,1333,1300,1250,1334,1335,1336,1337,1338,1339,1340,1341,1342,1343,1344,1307,1345,1346,1347,1348,1349,1350,1273,1351,1352,1266,1353,1354,1355,1250,761,717,207,1356,1357,1358,1228,1330,1334,1359,1336,1360,1361,1345,1362,1363,1364,1352,1365,1366,1266,1347,1348,1349,1367,1353,1354,1355,1250,1368,1369,1370,1371,1372,1373,1374,1375,1376,1377,1378,1266,1307,761,717,207,1379,1380,1325,1381,1382,1383,1384,1385,1386,1256,1343,1387,1307,761,717,207,1388,1389,1390,1391,1392,1393,840,717,207,1394,1395,1396,1397,1398,1399,1400,1401,1402,1403,761,717,718,207,1404,1405,1380,1406,1407,1408,1409,1410,1411,1412,1413,1127,1414,1234,1235,1415,1416,1417,1239,1240,1418,1244,1419,1246,1247,1248,1249,1250,761,717,718,207,939,1420,1421,1422,1423,207,1421,1424,1425,1426,1427,965,1428,718,207,939,1429,1421,1422,1430,1431,1432,946,1433,952,207,1434,1435,207,1436,718,207,939,1437,1421,1438,1430,1431,1432,946,1433,952,207,1439,1440,207,1441,1442,1443,1444,1445,1004,718,207,939,1446,1421,1422,1430,1431,1432,946,1433,952,207,1439,1435,207,1447,718,207,939,1448,1421,1438,1449,207,1450,1435,207,1451,718,207,939,1452,1421,1422,1453,1454,1455,1456,207,1457,1435,207,1436,718,207,939,1458,1421,1422,207,1459,1460,1461,1462,1453,1454,1455,1456,207,1463,1464,1465,1466,1467,946,1468,1469,1470,1471,1472,1473,946,1474,1475,1471,1476,1477,1478,1479,1480,1481,1482,1483,1484,1485,1486,1250,946,1487,1488,965,953,207,1489,207,1436,718,207,939,1490,1421,1422,1491,1425,1426,1492,965,1493,207,1424,1425,1426,1494,965,1428,718,207,939,1495,1421,1422,942,1496,1358,945,946,1497,1498,951,952,1499,1500,1501,1502,718,207,939,1503,1421,1422,942,1496,1358,945,946,1497,1498,951,952,1504,1505,1506,1507,1443,1508,1509,1004,718,207,939,1510,1421,1422,1511,1512,965,207,1513,1514,1515,207,1516,1517,1518,1519,1520,1521,1188,207,1522,1523,1524,718,704],[1788,1789,1790,1791,1792],{"_629":45,"_45":1538},{"_629":1532,"_159":645,"_651":1536,"_653":1537},{"_629":45,"_45":1535},{"_629":1532,"_159":645,"_651":1533,"_653":1534},{"_629":45,"_45":1531},[1795,1796,1797,1798,1799],{"_1548":1549,"_260":194,"_1550":301,"_271":-5,"_1551":254,"_1552":-5,"_1553":1554,"_1555":1556,"_1557":-5,"_1558":-5,"_1559":1560,"_1561":15,"_1562":57,"_1563":52,"_1564":15},{"_90":400,"_94":321,"_395":1800},{"_308":309,"_310":1576,"_1577":315,"_1578":127,"_317":-5,"_90":1579},{"_90":1570,"_310":1575,"_159":-5,"_1572":-5,"_1573":-5},{"_90":1570,"_310":1574,"_159":-5,"_1572":-5,"_1573":-5},{"_90":1570,"_310":1571,"_159":-5,"_1572":-5,"_1573":-5},[1801],{"_629":45,"_45":1582},"task_e_6a1d5fc39f84832a81f003164b321987",1780309955.623274,"Github Mention: warp-wasm: add WARP DRIVE G2b query projection","has_generated_title","has_unread_turn","denormalized_metadata",{"_1833":31,"_1834":1835,"_1836":-5,"_1837":-5,"_1828":1838,"_1839":-5,"_1840":-5,"_1841":-5,"_1842":-5},"task_status_display",{"_1821":1822,"_1823":194,"_128":125,"_1824":-5,"_1825":1826},"creator_workspace","external_pull_requests",[1814],{"_41":1815,"_1816":81,"_1817":1818,"_1819":127},"github-1082070703-389","assistant_turn_id","pull_request",{"_300":301,"_292":302,"_303":304,"_305":57,"_306":15,"_307":15,"_308":309,"_310":311,"_312":264,"_313":125,"_314":315,"_316":127,"_317":318,"_319":-5,"_320":-5,"_321":1820,"_323":324,"_325":326,"_327":328,"_329":330},"codex_updated_sha",{"_286":287,"_179":287,"_331":-5,"_290":291,"_41":288},"latest_turn_status_display",{"_1827":81,"_110":111,"_1828":-5,"_92":1829,"_1830":-5,"_1831":-5,"_1832":1826,"_112":-5},"environment_label","fix_task_id","initial_intent","pr","turn_id","diff_stats",[],"image_asset_pointer_citations","issue_counts","intent","num_follow_ups","repo_name_map",{},"last_user_turn_created_at","last_turn_status",{"_1843":-5,"_1844":-5,"_1845":-5},"last_pushed_turn_id","start_branch_name","pushed_branch_name","cached_pull_request_data","files_modified","lines_added","lines_removed","dd",{"_1857":1858,"_1859":1860},"disablePrefetch","shouldPrefetchAccount","shouldPrefetchUser","shouldPrefetchSystemHints","promoteCss","disableSSR","stripModulepreloadImports","statsigGateEvaluationsPromise",["P",1856],"traceId","14014528469325364448","traceTime",1780846541545]