High-performance WebSocket server for streaming Solana DEX events with microsecond-level latency

中文 | English | Website | Telegram | Discord

A WebSocket proxy server for Solana DEX events based on sol-parser-sdk. Real-time monitoring of DEX trading events from PumpFun, Raydium, Orca, and more, streamed to clients via WebSocket.

Parser Proxy WebSocket bridges Yellowstone gRPC DEX event parsing to browser, TypeScript, Python, and backend WebSocket clients. It is designed for dashboards, trading bots, copy-trading systems, stream processors, and parser pipelines that need filtered real-time Solana DEX events.

• 🔥 Ultra-low Latency - Built on sol-parser-sdk with 10-20μs parsing latency
• 🌐 Real-time WebSocket Push - Support multiple concurrent client connections
• 📊 Multi-protocol Support - PumpFun, Raydium AMM V4/CLMM/CPMM, Orca Whirlpool, Meteora, etc.
• 🎯 Event Filtering - Only push events you care about
• ⚙️ TOML Configuration - All parameters flexibly configurable via config file
• 🔄 Auto Reconnection - Automatic client cleanup on disconnect
• 📝 Multi-language Clients - Examples in HTML, TypeScript, Python

┌─────────────────┐
│ Yellowstone gRPC│
│   (Solana RPC)  │
└────────┬────────┘
         │
         ▼
┌─────────────────┐
│ sol-parser-sdk  │
│  (10-20μs parse)│
└────────┬────────┘
         │
         ▼
┌─────────────────┐
│  WebSocket Server│
│  (Broadcast)    │
└────────┬────────┘
         │
         ▼
┌─────────────────────────────────────┐
│  Clients (HTML/TS/Python/...)       │
│  (Real-time DEX Events)             │
└─────────────────────────────────────┘

git clone https://github.com/0xfnzero/parser-proxy-ws.git
cd parser-proxy-ws

cargo build --release

Edit config.toml:

[server]
host = "127.0.0.1"
port = 9001

[grpc]
endpoint = "https://solana-yellowstone-grpc.publicnode.com:443"
token = ""  # Optional: your gRPC token
enable_metrics = true
enable_tls = true
connection_timeout_ms = 10000
request_timeout_ms = 30000

[protocols]
pumpfun = true
raydium_amm_v4 = true
raydium_clmm = true
orca_whirlpool = true
# ... more protocols

[events]
pumpfun_trade = true
pumpfun_create = true
raydium_amm_v4_swap = true
# ... more event types

Method 1: Using Script (Recommended)

./start-server.sh

Method 2: Direct Run

cargo run --release

Server will start based on config file (default ws://127.0.0.1:9001)

Method 1: Using Script (Recommended)

./start-client.sh

The script will prompt you to choose client type:

• HTML Client (Browser visualization, auto-convert Pubkey/Signature)
• TypeScript Client (Terminal, auto-convert Pubkey/Signature)
• Python Client (Terminal, auto-convert Pubkey/Signature + latency display)

Method 2: Manual Start

open examples/client.html

✨ Features:

• Auto-convert Pubkey/Signature to base58 strings
• Real-time latency display (gRPC → Client)
• Color-coded latency (🟢 < 50ms, 🟡 < 100ms, 🔴 ≥ 100ms)
• ⏸️ Pause/Resume - Pause event updates to inspect details

cd examples
npm install
npm start

✨ Features:

• Auto-convert using @solana/web3.js and bs58
• Terminal real-time latency display (with colors)
• TypeScript type safety

pip3 install websockets base58
python3 examples/client.py

✨ Features:

• Auto-convert Pubkey/Signature using base58 library
• Terminal color latency display
• Microsecond precision latency calculation

Each protocol supports the following event types (enable in [events] config section):

• 📈 Trade/Swap - Trading/swapping events
• 💧 Deposit - Add liquidity
• 💸 Withdraw - Remove liquidity
• 🏊 Create/Initialize - Pool creation/initialization

See config.toml for complete event list.

[server]
host = "127.0.0.1"     # WebSocket listen address
port = 9001             # WebSocket listen port

[grpc]
endpoint = "https://solana-yellowstone-grpc.publicnode.com:443"
token = ""                    # gRPC auth token (optional)
enable_metrics = true         # Enable performance metrics
enable_tls = true             # Enable TLS
connection_timeout_ms = 10000 # Connection timeout (ms)
request_timeout_ms = 30000    # Request timeout (ms)

Enable/disable specific protocols and events via config:

[protocols]
pumpfun = true           # Enable PumpFun protocol
raydium_amm_v4 = false   # Disable Raydium AMM V4

[events]
pumpfun_trade = true     # Enable PumpFun trade events
pumpfun_create = false   # Disable PumpFun create events

Note: At least one protocol and one event type must be enabled, otherwise server will fail to start

Raw data from server:

• Pubkey: 32-byte array
• Signature: 64-byte array

{
  "signature": [188, 230, 16, ...],  // 64 bytes
  "mint": [208, 230, 16, ...],       // 32 bytes
  "user": [123, 45, 67, ...]         // 32 bytes
}

Client display format:

• ✅ HTML/TypeScript Client: Auto-convert to base58 strings

  {
    "signature": "5Jb7XqKGPj8XqKGPj8XqKGPj8XqKGPj...",
    "mint": "D0e610e3f14ed2960e95230e9d74e471...",
    "user": "7xKGPj8XqKGPj8XqKGPj8XqKGPj8Xq..."
  }

• ✅ Python Client: Auto-convert using base58 library

{
  "PumpFunTrade": {
    "metadata": {
      "signature": [byte array],
      "slot": 123456,
      "block_time": 1234567890,
      "grpc_recv_us": 1234567890123456
    },
    "mint": [byte array],
    "token_amount": 1000000,
    "sol_amount": 500000,
    "is_buy": true,
    "user": [byte array],
    "virtual_sol_reserves": 1000000000,
    "virtual_token_reserves": 1000000000
  }
}

Each event is wrapped in its corresponding type field:

• PumpFunTrade - PumpFun trade
• PumpFunCreate - PumpFun creation
• RaydiumAmmV4Swap - Raydium AMM swap
• RaydiumClmmSwap - Raydium CLMM swap
• OrcaWhirlpoolSwap - Orca swap

parser-proxy-ws/
├── src/
│   ├── main.rs           # Main entry point
│   ├── config.rs         # Config file loading and parsing
│   └── ws_server.rs      # WebSocket server implementation
├── examples/
│   ├── client.html       # HTML visualization client
│   ├── client.ts         # TypeScript client example
│   └── client.py         # Python client example
├── sol-parser-sdk/       # Solana parser SDK (submodule)
├── config.toml           # Configuration file
├── Cargo.toml            # Rust project config
└── README.md

cargo test

Performance metrics are displayed when server starts:

📊 gRPC receive time: 1234567890 μs
⚡ Event parsing took: 15 μs

1. Trading Bots - Real-time DEX monitoring for arbitrage strategies
2. Price Monitoring - Track trading prices of specific tokens
3. New Token Alerts - Monitor new token creation events
4. Liquidity Analysis - Analyze DEX liquidity changes
5. Data Analytics - Collect on-chain trading data for analysis

MIT License

• sol-parser-sdk - Solana DEX event parsing library
• Yellowstone gRPC - Solana gRPC interface

For issues or suggestions, please submit an Issue.