🐋 Mempool Monitor

A Rust daemon that monitors Ethereum's pending transaction pool (mempool) via WebSockets to detect large-value transfers in real time.

Features

• Connects to an Ethereum node via WebSocket (WSS)
• Subscribes to the pendingTransactions stream
• Identifies and logs transactions with value > 1 ETH
• Async task spawning for non-blocking transaction inspection

Setup

cp .env.example .env
# Add your WebSocket RPC URL (Alchemy, Infura, etc.)

Note: Public WebSocket endpoints may be rate-limited or unstable. For best results, use a dedicated provider like Alchemy or Infura.

Usage

cargo run

Sample Output

Connecting to WebSocket: wss://eth-mainnet.g.alchemy.com/v2/YOUR_KEY ...
Connected successfully! Monitoring pending transactions...
Listening for transactions with value > 1.0 ETH...
🐋 Large Tx -> Hash: 0xabc...def | Value: 5.2 ETH | From: 0x123...456 | To: 0x789...012
🐋 Large Tx -> Hash: 0xfed...cba | Value: 100.0 ETH | From: 0x456...789 | To: 0xabc...def

Tech Stack

• ethers (with ws feature) — WebSocket provider, transaction parsing
• tokio — Async runtime with task spawning
• dotenv — Environment configuration
• serde_json — JSON handling