UNIFIED PIPELINE STATUS · CHAIN 137 · POLYGON POS

Live Execution Pipeline

Full pipeline status, data parity, discovery cycles, data lifespan, blockers, and identity wiring

LIVE

PARTIAL

SIMULATED

CRITICAL

GAPS CLOSED

6 Production Gaps Closed — All 4 Critical Blockers + Event-Driven Cache + 3-Tier Oracle Engine

✅ Blocker 1 — Real Signing

ethers.js v6 Wallet.signTransaction(). JIT hold unsigned. Signer recovery verified. SHADOW/LIVE gate. EIP-1559 type-2.

✅ Blocker 2 — Venue Registry

Canonical P0_VENUE_REGISTRY. QuickSwap V2/V3-Algebra, SushiSwap, Uniswap V3, Curve, Balancer V2, Aave V3. Bytecode provenance. Balancer reentrancy rule.

✅ Blocker 3 — ABI Calldata

ethers.Interface.encodeFunctionData() for execute(ExecutionPlan). ABI roundtrip test. Sealed payload. eth_call simulation. Selector + length verification.

✅ Blocker 4 — Flash Capital

Live Aave V3 + Balancer V2 liquidity query. Economics-aware source selection. Balancer reentrancy topology enforced. Premium in economics. Insufficient liquidity rejects route.

✅ Event-Driven Cache

WebSocket Sync/Swap/Mint/Burn → in-memory CPMM at 0ms. CLMM Multicall only on touched pools. WARM→HOT instant on 25 bps or 2% volume. 95% RPC reduction.

✅ 3-Tier Oracle Engine

Chainlink AggregatorV3 (8 feeds) + Curve/Balancer virtual price + Uniswap V3/Algebra TWAP. PASS/WARN/FAIL divergence gates. All 16 tokens live-priced. apexService auto-sync to token_registry.

Discovery Engine Cycle Frequency Summary

HOT POOLS

Every block (~2s)

State hydration, math, simulation, route enumeration

WARM POOLS

Every 20 blocks (~40s)

State refresh, re-scoring, promotion check

COLD POOLS

Every 300 blocks (~10min)

Periodic re-score, demotion/promotion check

FACTORY WATCHERS

Continuous (event-driven)

PairCreated/PoolCreated events, backfill on boot

Data Lifespan Reference

Data Type	TTL / Lifespan	Expiry Action	Phase
Block header / WSS event	1 block TTL	Discarded after factory watcher processes	Phase 1
Factory event log	Permanent	Written to pool registry, never expires	Phase 2
Pool registry entry	Permanent (until REJECT)	Demoted to REJECT tier, archived	Phase 3
Pool tier score	Per scan policy (1/20/300 blocks)	Re-scored on next scan cycle	Phase 3
Pool state cache (HOT)	Max 2 blocks	Stale state → re-hydration required before math	Phase 4
Staged route data	1 block	Discarded, re-staged next cycle	Phase 4
Invariant math quote	1 block	Stale quote → re-compute before simulation	Phase 5
Simulation result	1 block	Stale sim → re-simulate before relay	Phase 6
Holding Tank TX	Max 3 blocks	Forced flush or expiry on 3rd block	Phase 7
Nonce state	Per flush attempt	Refreshed via dual eth_getTransactionCount	Phase 7
Signed bundle	Target block + 1	Relay drops bundle after target block passes	Phase 8
Relay outcome / tx log	Permanent (Supabase)	Persisted to transaction_logs table	Phase 8