feat(engine): buffered stream anchored on CannonStateNotifications + defer trie root computation on dedicated thread

.github/workflows/rust-ci.yml

@@ -37,13 +37,21 @@ jobs:
   cargo-lint:
     runs-on: arc-public-8xlarge-amd64-runner
     timeout-minutes: 20
+    permissions:
+        contents: write
     name: lint
     steps:
       - uses: actions/checkout@v6
-      - uses: taiki-e/install-action@just
+        with:
+          ref: ${{ github.head_ref }}
+          persist-credentials: true
       - uses: dtolnay/rust-toolchain@nightly
         with:
           components: rustfmt, clippy
+
+      - uses: foundry-rs/foundry-toolchain@v1
+
+      - uses: taiki-e/install-action@just
       - name: Cache
         uses: actions/cache@v5
         continue-on-error: false
@@ -54,9 +62,17 @@ jobs:
             ~/.cargo/git/db/
           key: cargo-test-${{ hashFiles('**/Cargo.lock') }}
           restore-keys: cargo-test-
-      - name: fmt + lint
-        run: cargo +nightly fmt --all -- --check
+      - name: Run Formatter
+        run: just fmt
 
+      - name: Commit changes
+        run: |
+          git config user.name "github-actions[bot]"
+          git config user.email "github-actions[bot]@users.noreply.github.com"
+          git add -A
+          git diff --staged --quiet || git commit -m "chore: auto-format"
+          git push
+
   cargo-clippy:
     runs-on: arc-public-8xlarge-amd64-runner
     timeout-minutes: 20

.github/workflows/sync.yml

@@ -9,7 +9,7 @@ on:
   push:
     tags:
       - v*
-
+  pull_request:
 env:
   CARGO_TERM_COLOR: always
 

Cargo.toml

@@ -68,6 +68,7 @@ reth = { git = "https://github.com/worldcoin/reth", rev = "15d0a8f" }
 reth-cli-util = { git = "https://github.com/worldcoin/reth", rev = "15d0a8f" }
 reth-cli = { git = "https://github.com/worldcoin/reth", rev = "15d0a8f" }
 reth-engine-primitives = { git = "https://github.com/worldcoin/reth", rev = "15d0a8f" }
+reth-engine-tree = { git = "https://github.com/worldcoin/reth", rev = "15d0a8f" }
 reth-evm = { git = "https://github.com/worldcoin/reth", rev = "15d0a8f", features = [
     "op",
 ] }
@@ -144,6 +145,7 @@ op-alloy-rpc-types = { version = "0.23.1", default-features = false }
 op-alloy-rpc-types-engine = { version = "0.23.1", default-features = false }
 op-alloy-network = { version = "0.23.1", default-features = false }
 alloy-op-hardforks = { version = "0.4.4", default-features = false }
+op-alloy-provider = { version = "0.23.1", default-features = false }
 
 # alloy
 alloy = { version = "1.1.2" }
@@ -199,7 +201,6 @@ revm-inspectors = "0.34"
 
 alloy-op-evm = { version = "0.27", default-features = false }
 alloy-evm = { version = "0.27", default-features = false }
-
 # rpc
 jsonrpsee = { version = "0.26.0", features = ["server", "client", "macros"] }
 jsonrpsee-core = { version = "0.26.0" }
@@ -256,6 +257,7 @@ url = "2.5.7"
 brotli = "8.0.2"
 once_cell = "1.19"
 either = { version = "1.15.0", default-features = false }
+pin-project = "1.0.1"
 
 # Test
 testcontainers = "0.27"

Justfile

@@ -24,8 +24,10 @@ devnet-down:
 test *args='':
     RUST_LOG="info" cargo nextest run --workspace $@
 
+fmt: fmt-fix fmt-check contracts-fmt
+
 # Formats the whole workspace
-fmt: devnet-fmt contracts-fmt fmt-fix fmt-check
+fmt-all: devnet-fmt contracts-fmt fmt-fix fmt-check
 
 devnet-fmt:
     @just ./devnet/fmt

crates/flashblocks/builder/Cargo.toml

@@ -21,6 +21,7 @@ reth-payload-util.workspace = true
 reth-evm.workspace = true
 reth-node-api.workspace = true
 reth-node-builder.workspace = true
+reth-engine-tree.workspace = true
 
 # op-reth
 reth-optimism-forks.workspace = true
@@ -60,8 +61,8 @@ dashmap.workspace = true
 thiserror.workspace = true
 either.workspace = true
 metrics.workspace = true
+metrics-derive.workspace = true
 serde.workspace = true
-backon.workspace = true
 
 [dev-dependencies]
 serde.workspace = true
@@ -70,6 +71,7 @@ eyre.workspace = true
 lazy_static.workspace = true
 proptest.workspace = true
 reth-tracing.workspace = true
+tracing-subscriber.workspace = true
 alloy-genesis.workspace = true
 op-alloy-network.workspace = true
 alloy-signer-local.workspace = true