refactor(book-feeds)!: port the five venues onto the snapshot feed layer

Cargo.toml

@@ -47,6 +47,7 @@ tycho-execution        = { path = "crates/tycho-execution",        version = "0.
 # --- Serialization/Deserialization ---
 serde = { version = "1.0.204", features = ["rc", "derive"] }
 serde_json = "1.0.120"
+serde_with = "3.16.1"
 toml = "0.8"
 typetag = "0.2.21"
 uuid = { version = "1.4.1", features = ["serde", "macro-diagnostics"] }
@@ -57,7 +58,7 @@ futures = "0.3.31"
 futures03 = { package = "futures", version = "0.3.31", features = ["compat"] }
 async-trait = "0.1.88"
 async-stream = "0.3.6"
-# Pinned at 0.20 for tycho-client; simulation's rfq feature uses 0.28 directly (separate semver)
+# Pinned at 0.20 for tycho-client; simulation's book-feeds feature uses 0.28 directly (separate semver)
 tokio-tungstenite = { version = "0.20.0", features = ["native-tls"] }
 tokio-stream = { version = "0.1", features = ["sync"] }
 

crates/tycho-ethereum/Cargo.toml

@@ -24,7 +24,7 @@ unicode-segmentation.workspace = true
 futures = "0.3"
 backoff = { version = "0.4.0", features = ["tokio"], default-features = false }
 num-bigint = { version = "0.4", features = ["serde"] }
-serde_with = "3.16.1"
+serde_with = { workspace = true }
 
 # Required dependencies
 alloy = { workspace = true, default-features = false, features = [

crates/tycho-execution/CLAUDE.md

@@ -426,7 +426,8 @@ flags) into packed bytes. Each encoder holds its executor address.
 
 **SwapEncoderRegistry** (`swap_encoder_registry.rs`): Creates encoders by protocol system name. Reads executor addresses
 from `config/executor_addresses.json`. Protocol name prefixes: `vm:` (simulation-backed,
-e.g. `vm:balancer_v2`, `vm:curve`), `rfq:` (request-for-quote, e.g. `rfq:bebop`), bare (on-chain,
+e.g. `vm:balancer_v2`, `vm:curve`), `rfq:` (off-chain book feeds — the RFQ venues and Metric,
+e.g. `rfq:bebop`, `rfq:metric`), bare (on-chain,
 e.g. `uniswap_v2`, `fluid_v1`), and `pricelevelstream:` (Titan pAMM price level stream, suffixed
 with the protocol name or, for auto-detected pAMMs, the protocol address). Price-level-stream protocols
 resolve generically: a single `pricelevelstream` config entry serves the whole family via a

crates/tycho-integration-test/CLAUDE.md

@@ -26,7 +26,7 @@ cargo run -p tycho-integration-test -- \
   --tvl-threshold 100
 ```
 
-Key optional flags: `--no-tls`, `--disable-onchain`, `--disable-rfq`,
+Key optional flags: `--no-tls`, `--disable-onchain`, `--disable-rfq`, `--disable-pamm`,
 `--disable-price-level-stream`, `--disable-execution`, `--protocols uniswap_v2,curve`,
 `--max-blocks 100`, `--parallel-simulations 5`, `--always-test-components <id,...>`,
 `--price-level-stream-block-interval 1`, `--price-level-stream-stale-threshold-secs 10`,
@@ -51,8 +51,8 @@ shows up as a failure.
 - **`stream_processor/`**:
   - `protocol_stream_processor.rs`: Handles on-chain protocol updates — applies deltas to
     `ProtocolSim` instances, runs `get_amount_out` simulations, validates via RPC execution
-  - `rfq_stream_processor.rs`: Handles RFQ protocol updates — fetches live quotes, compares
-    against simulation
+  - `book_stream_processor.rs`: Handles the off-chain book feeds (the RFQ venues and Metric) —
+    fetches live quotes, compares against simulation
   - `price_level_stream_processor.rs`: Handles Titan pAMM price level stream updates (Ethereum
     only) — emits one sampled update per `--price-level-stream-block-interval` blocks, holding a
     chosen block's latest snapshot back until the stream moves to the next block (least drift to

crates/tycho-integration-test/Cargo.toml

@@ -18,6 +18,7 @@ num-bigint = { workspace = true }
 num-traits = { workspace = true }
 rand = "0.9.2"
 tokio = { workspace = true, features = ["signal"] }
+chrono = { workspace = true }
 tracing = { workspace = true }
 tracing-subscriber = { workspace = true }
 tycho-client = { workspace = true }

crates/tycho-integration-test/README.md

@@ -41,11 +41,12 @@ This test runs continuously in the cluster but it can also be run locally for de
 | `--tvl-threshold`          | `100.0`    | TVL threshold in native tokens for filtering                                                                     |
 | `--metrics-port`           | `9898`     | Port for Prometheus metrics server                                                                               |
 | `--disable-onchain`        | `false`    | Skip on-chain protocol testing                                                                                   |
-| `--disable-rfq`            | `false`    | Skip RFQ protocol testing                                                                                        |
+| `--disable-rfq`            | `false`    | Skip the RFQ book feeds (Bebop, Hashflow, Liquorice, Native)                                                     |
+| `--disable-pamm`           | `false`    | Skip the pAMM book feeds (Metric)                                                                                |
 | `--disable-price-level-stream` | `false` | Skip Titan pAMM price level stream testing (only active on Ethereum)                                            |
 | `--price-level-stream-block-interval` | `1` | Emit one sampled price level update per this many blocks                                                    |
 | `--price-level-stream-stale-threshold-secs` | `10` | Seconds without a Titan message before marking served pAMMs stale in metrics (0 disables)              |
-| `--skip-messages-duration` | `600`      | RFQ stream skip duration (seconds) after processing a message                                                    |
+| `--skip-messages-duration` | `600`      | Book stream skip duration (seconds) after processing a message                                                   |
 | `--block-wait-time`        | `12`       | Time to wait (seconds) for block N+1 before executing debug_traceCall                                            |
 | `--always-test-components` | -          | Comma-separated list of component IDs to test every block                                                        |
 | `--max-blocks`             | `0`        | Maximum number of blocks to process before exiting (0 = run indefinitely). When set, prints a summary at the end |
@@ -66,6 +67,7 @@ cargo run --package tycho-integration-test
 cargo run --package tycho-integration-test -- \
   --chain ethereum \
   --disable-rfq \
+  --disable-pamm \
   --protocols uniswap_v2 \
   --max-simulations 20 \
   --parallel-simulations 10