feat(twap-monitor): consume composable-cow batched contract surface

.dockerignore

@@ -0,0 +1,55 @@
+# Build context exclusion list for `docker build .`. Keeping the
+# context lean matters: every byte sent to the daemon is hashed for
+# the build's source-changed signal, and the production multi-stage
+# Dockerfile already invalidates the dependency layer cache on any
+# Cargo.lock / Cargo.toml change.
+
+# Cargo build artefacts — re-built inside the build stage anyway.
+/target/
+target/
+**/target/
+
+# Runtime state directory the engine writes the redb file into. Never
+# part of the image.
+/data/
+data/
+
+# Backtest tooling output: large JSON fixtures + Python venv state.
+# Re-collected on demand via `tools/backtest-collect/backtest_collect.py`.
+tools/backtest-collect/fixtures-*.json
+tools/baseline-latency/data/
+tools/**/__pycache__/
+tools/**/*.pyc
+
+# NOTE: `modules/fixtures/*-bomb` are listed in the workspace
+# `Cargo.toml`, so excluding them breaks `cargo build` ("failed to
+# load manifest for workspace member"). They're tiny crates and the
+# Dockerfile doesn't COPY them to the runtime stage, so the
+# image size impact is zero. Keep them in the build context.
+
+# Local-only configs. The production `engine.toml` is supplied at
+# runtime via a bind-mount (`/etc/shepherd/engine.toml`).
+engine.toml
+engine.e2e.toml
+engine.load.toml
+engine.m2.toml
+engine.m3.toml
+
+# Git + GitHub metadata.
+/.git/
+/.github/
+.gitignore
+
+# Editor / OS noise.
+.vscode/
+.idea/
+.DS_Store
+*.swp
+
+# Operator-side docs reports the image doesn't need. Source markdown
+# stays so it's discoverable inside the container if an operator
+# `docker exec`s in for a quick `cat docs/production.md`.
+docs/operations/load-reports/
+docs/operations/e2e-reports/
+docs/operations/backtest-reports/
+docs/operations/baselines/

.env.example

@@ -0,0 +1,25 @@
+# Operator template — copy to `.env` and fill in your paid RPC URLs.
+# `.env` is gitignored; never commit a populated copy.
+#
+# Workflow:
+#   cp .env.example .env
+#   $EDITOR .env
+#   docker compose up -d
+#
+# The engine reads these via `${VAR}` placeholders in
+# `engine.docker.toml` (substitution happens at config-load time,
+# before TOML parse, so a missing variable fails fast).
+#
+# Use `wss://` schemes — `eth_subscribe` is WebSocket-only and the
+# engine emits a boot-time ERROR on http(s):// URLs (see
+# docs/production.md §6 and engine_config::validate_transports).
+
+MAINNET_RPC_URL=wss://eth-mainnet.g.alchemy.com/v2/REPLACE_ME
+GNOSIS_RPC_URL=wss://gnosis-mainnet.g.alchemy.com/v2/REPLACE_ME
+SEPOLIA_RPC_URL=wss://eth-sepolia.g.alchemy.com/v2/REPLACE_ME
+ARBITRUM_RPC_URL=wss://arb-mainnet.g.alchemy.com/v2/REPLACE_ME
+BASE_RPC_URL=wss://base-mainnet.g.alchemy.com/v2/REPLACE_ME
+
+# Optional: override the published image with a locally-built or
+# pinned-by-SHA tag. Leave unset to pull `:latest` from ghcr.io.
+# SHEPHERD_IMAGE=ghcr.io/bleu/nullis-shepherd:sha-abc1234

.github/workflows/ci.yml

@@ -55,14 +55,46 @@ jobs:
       - uses: Swatinem/rust-cache@c19371144df3bb44fab255c43d04cbc2ab54d1c4 # v2.9.1
       - run: cargo test --workspace --all-features --no-fail-fast
 
+  docs:
+    name: rustdoc
+    runs-on: ubuntu-latest
+    env:
+      RUSTDOCFLAGS: "-D warnings"
+    steps:
+      - uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
+      - uses: dtolnay/rust-toolchain@3c5f7ea28cd621ae0bf5283f0e981fb97b8a7af9 # master 2026-03-27
+        with:
+          toolchain: nightly
+          targets: wasm32-wasip2
+      - uses: Swatinem/rust-cache@c19371144df3bb44fab255c43d04cbc2ab54d1c4 # v2.9.1
+      - run: cargo doc --workspace --no-deps
+
   build-module:
-    name: build example module
+    name: build ${{ matrix.module }} (wasm32-wasip2)
     runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        module:
+          - example
+          - twap-monitor
+          - ethflow-watcher
+          - price-alert
+          - balance-tracker
+          - stop-loss
     steps:
       - uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
       - uses: dtolnay/rust-toolchain@3c5f7ea28cd621ae0bf5283f0e981fb97b8a7af9 # master 2026-03-27
         with:
           toolchain: nightly
           targets: wasm32-wasip2
       - uses: Swatinem/rust-cache@c19371144df3bb44fab255c43d04cbc2ab54d1c4 # v2.9.1
-      - run: cargo build -p example --target wasm32-wasip2 --release
+      - run: cargo build -p ${{ matrix.module }} --target wasm32-wasip2 --release
+      - name: report wasm size
+        run: |
+          artifact_name=$(echo "${{ matrix.module }}" | tr '-' '_')
+          wasm_path="target/wasm32-wasip2/release/${artifact_name}.wasm"
+          if [ -f "$wasm_path" ]; then
+            size=$(wc -c < "$wasm_path")
+            echo "${{ matrix.module }} .wasm size: ${size} bytes"
+          fi

.github/workflows/docker.yml

@@ -0,0 +1,88 @@
+# Docker image build + publish to ghcr.io.
+#
+# Triggers:
+#   - push to `main`               → publish `latest` + `sha-<sha>`
+#   - tag push `v*`                → publish `v<tag>` + `latest`
+#   - workflow_dispatch (manual)   → publish `manual-<run_id>`
+#   - pull_request to `main`       → build only, no push (CI smoke)
+#
+# Image: ghcr.io/<owner>/nullis-shepherd
+# Auth:  GITHUB_TOKEN (scoped to packages:write below).
+#
+# Pinned action SHAs match the style of `.github/workflows/ci.yml`.
+
+name: docker
+
+on:
+  push:
+    branches: [main]
+    tags: ["v*"]
+  pull_request:
+    branches: [main]
+  workflow_dispatch:
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
+permissions:
+  contents: read
+  packages: write
+
+env:
+  REGISTRY: ghcr.io
+  IMAGE_NAME: ${{ github.repository }}
+
+jobs:
+  build-and-push:
+    name: build + push (${{ github.event_name }})
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
+
+      - name: Set up Docker buildx
+        uses: docker/setup-buildx-action@e468171a9de216ec08956ac3ada2f0791b6bd435 # v3.11.1
+
+      - name: Log in to ghcr.io
+        if: github.event_name != 'pull_request'
+        uses: docker/login-action@74a5d142397b4f367a81961eba4e8cd7edddf772 # v3.4.0
+        with:
+          registry: ${{ env.REGISTRY }}
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Compute image metadata
+        id: meta
+        uses: docker/metadata-action@902fa8ec7d6ecbf8d84d538b9b233a880e428804 # v5.7.0
+        with:
+          images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
+          tags: |
+            # `latest` on push to main and on tag.
+            type=raw,value=latest,enable={{is_default_branch}}
+            type=ref,event=tag
+            # `sha-<short>` on every event so a soak run can pin an
+            # exact build.
+            type=sha,prefix=sha-,format=short
+            # manual-<run_id> for workflow_dispatch.
+            type=raw,value=manual-${{ github.run_id }},enable=${{ github.event_name == 'workflow_dispatch' }}
+            # `pr-<n>` on pull-request builds so the smoke artefact
+            # is identifiable. PR builds are NOT pushed (see `push:`).
+            type=ref,event=pr,prefix=pr-
+
+      - name: Build + push
+        uses: docker/build-push-action@263435318d21b8e681c14492fe198d362a7d2c83 # v6.18.0
+        with:
+          context: .
+          file: ./Dockerfile
+          # Push on every non-PR event; PR builds are local-only smoke.
+          push: ${{ github.event_name != 'pull_request' }}
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+          # Layer cache via the registry: the previous successful
+          # build's intermediate layers are reused so a Cargo.toml-only
+          # change re-compiles only the changed crate.
+          cache-from: type=registry,ref=${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:buildcache
+          cache-to: type=registry,ref=${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:buildcache,mode=max,ignore-error=true
+          # `amd64` is enough for the soak VM. Add `arm64` once an
+          # operator surfaces a real need; multi-arch ~2x the build.
+          platforms: linux/amd64

.gitignore

@@ -21,6 +21,9 @@ Thumbs.db
 # Environment
 .env
 .env.*
+# Exception: the committed template (operator copies it to `.env`,
+# which is then caught by the rule above).
+!.env.example
 
 # Agent skills / AI tooling — installed locally, never committed.
 .agents/
@@ -29,3 +32,19 @@ skills-lock.json
 
 # Engine runtime state (default state_dir from engine.toml).
 data/
+
+# E2E automation: rendered configs with embedded RPC keys + script state
+# never get committed.
+*.local.toml
+scripts/.state
+scripts/.env
+
+# Operator-supplied engine config (carries paid RPC URLs / API keys).
+# The committed siblings `engine.example.toml`, `engine.docker.toml`,
+# and `engine.{m2,m3,e2e,load}.toml` are placeholder templates.
+/engine.toml
+
+# Generated reports under e2e-reports/ (operator commits the filled-in ones
+# manually via `git add -f`).
+docs/operations/e2e-reports/engine-*.log
+docs/operations/e2e-reports/metrics-*.txt

Cargo.toml

@@ -1,7 +1,20 @@
 [workspace]
 members = [
     "crates/nexum-engine",
+    "crates/shepherd-backtest",
+    "crates/shepherd-sdk",
+    "crates/shepherd-sdk-test",
+    "modules/ethflow-watcher",
     "modules/example",
+    "modules/examples/balance-tracker",
+    "modules/examples/price-alert",
+    "modules/examples/stop-loss",
+    "modules/fixtures/flaky-bomb",
+    "modules/fixtures/fuel-bomb",
+    "modules/fixtures/memory-bomb",
+    "modules/twap-monitor",
+    "tools/load-gen",
+    "tools/orderbook-mock",
 ]
 resolver = "2"
 
@@ -99,18 +112,29 @@ dbg_macro = "deny"
 todo = "deny"
 
 # `cowprotocol` v1.0.0-alpha.3 (the crates.io release the engine
-# depends on) was cut from `cowdao-grants/cow-rs` PR #5 at commit
-# `1742ffa`. `bleu/cow-rs` main has diverged since with: the
-# `composable::Proof` width fix (relevant to the TWAP poll path),
-# `OrderCreation` zero-from-address fast-fail, the `order_book` /
-# `composable` submodule splits, `OrderPostErrorKind` + `retry_hint()`
-# (BLEU-822, the protocol-level retry contract M2 modules dispatch
-# on), and `OrderBookApi::with_base_url(chain, base_url)` for barn /
-# staging routing (BLEU-823). Patching to that commit picks the lot
-# up without waiting for an alpha.4 publish. Drop once
-# `cowprotocol >= 1.0.0-alpha.4` ships.
+# depends on) was cut from an earlier commit; bleu/cow-rs main has
+# diverged with the `composable::Proof` width fix, `OrderCreation`
+# zero-from-address fast-fail, the `order_book` / `composable`
+# submodule splits, `OrderPostErrorKind` + `retry_hint()` (the
+# protocol-level retry contract modules dispatch on), and
+# `OrderBookApi::with_base_url(chain, base_url)` for barn / staging
+# routing.
+#
+# Bumped to a head that additionally lands the composable-cow
+# bindings:
+#   - `ComposableCoW::ConditionalOrderRegistered` event (handler-indexed)
+#   - `BatchOrderRequest` / `BatchOrderResult` +
+#     `batchGetTradeableOrdersWithSignatureCall`
+#   - `OrderInfo` + `getOrderInfoCall`
+#   - `PollOutcome`, `BatchOrderOutcome`, `ComposableCoWError` enums
+#   - `decode_conditional_order_revert`, `decode_composable_cow_error`,
+#     `decode_batch_order_result(s)`,
+#     `registered_topic_filter_by_handler` helpers
+# Patching to that commit lets the twap-monitor consume the new
+# surface behind a runtime flag. Drop once bleu/cow-rs main absorbs
+# these changes and a tagged release ships.
 [patch.crates-io]
-cowprotocol = { git = "https://github.com/bleu/cow-rs", rev = "57f5f553ab28c9fff54089daf2d39b4282f3e4dd" }
+cowprotocol = { git = "https://github.com/bleu/cow-rs", rev = "3ba20753d91c71c1bd594e78b94b013052e963ba" }
 
 [profile.dev]
 panic = "abort"