For bot, scanner and agent developers

Real-time Solana DEX trades over one WebSocket

The MadeOnSol DEX firehose streams parsed Solana DEX trades from 14 programs across 8 venues, filtered on the server by token, wallet, venue, size and more.

Try it free

The REST API, live feeds 5 minutes delayed, or the demo without signing up
200 calls a day, no card needed

Get a free API key

Ultra

€131/month

Firehose: 3 connections, 10 subscriptions each
14 programs, 8 venues, one frame shape
500 trades replayed on subscribe, 100,000 REST calls a day

Start Ultra

Billed in euros by card. Checkout shows today's dollar estimate; your card issuer sets the exact amount. USDC or SOL at the day's rate. Cancel anytime.

Free, Pro and Ultra keys are for your own internal use, such as bots, backends and research. Showing MadeOnSol data to your own users, for example in a public terminal or dashboard, needs Business. Compare plans

Server-side filter keys: 13
Named subscriptions per connection: 10
Recent trades replayable on subscribe: 500
DEX stream connections on Ultra: 3

Normalized DEX trades from every supported Solana venue over one WebSocket, filtered on the server, for bots, terminals, scanners, analytics and AI agents.

Decoded venues

14 Solana programs across 8 venues, one trade model.

pump.fun
dex: "pumpfun" · 1 program
PumpSwap
dex: "pumpswap" · 1 program
Raydium
dex: "raydium" · 4 programs
Jupiter
dex: "jupiter" · 1 program
Orca
dex: "orca" · 1 program
Meteora
dex: "meteora" · 4 programs
LaunchLab
dex: "launchlab" · 1 program
Moonshot
dex: "moonshot" · 1 program

The problem

Raw Solana transactions are flexible, but a production market-data product needs consistency. Every additional venue creates parsing, schema and operational work. The MadeOnSol DEX firehose delivers parsed real-time DEX activity from every supported venue in one frame shape.

Show me

One subscribe, one frame shape

Name what you want and set a size floor; every venue arrives in the same frame. Values are illustrative, keys are the serializer's.

You send

At least one targeting filter is required. replay asks for recent matching trades from the server's buffer.

Subscribe message

// wss://madeonsol.com/ws/v1/dex-stream
{
  "type": "subscribe",
  "sub_id": "pumpswap-flow",
  "filters": { "dex": ["pumpswap"], "min_sol": 1 },
  "replay": 100
}

You receive

One dex:trades frame per matching trade, with the executed price, the pool and its post-swap reserves.

dex:trades frame you receive

{
  "channel": "dex:trades",
  "sub_id": "pumpswap-flow",
  "data": {
    "wallet": "7vfC...rXs2",
    "mint": "Cgxx...pump",
    "action": "buy",
    "sol_amount": 2.5,
    "token_amount": 1234567.89,
    "tx_signature": "5K7j...",
    "block_time": 1790157600,
    "slot": 449476673,
    "program": "pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA",
    "dex": "pumpswap",
    "executed_price_sol": 0.000002025,
    "pool_address": "Gf7h...2kLm",
    "pool_model": "constant_product",
    "pool_quote_mint": "So11111111111111111111111111111111111111112",
    "quote_reserve_raw": "112000000000",
    "quote_decimals": 9,
    "token_reserve_raw": "55308641975309",
    "token_decimals": 6,
    "dust": false
  },
  "ts": 1790157600412
}

Try it

Explore before you subscribe

The firehose itself needs Ultra and Business. A free key and the no-signup demo let you check the REST data and response shapes first.

Get a free API key Try the API without signing up

Filters

Filtered on the server, before trades reach you

Every subscription needs at least one targeting filter; refinements narrow it further. Up to 10 named subscriptions share one connection, each with its own filters. Included in Ultra and Business. Compare plans

Filter	Kind	Accepts
token_mint / token_mints	Targeting	One mint, or up to 50
wallet / wallets	Targeting	One trader wallet, or up to 50
dex	Targeting	One venue or a list`pumpfunpumpswapraydiumjupiterorcameteoralaunchlabmoonshot`
program	Targeting	One raw DEX program ID
deployer_tier	Targeting	One tier or a list`elitegoodmoderaterisingcoldunranked`
token_age_max_seconds	Targeting	Tokens first seen within N seconds
market_cap_min_sol / market_cap_max_sol	Targeting	Market cap bounds in SOL
min_sol	Refinement	Minimum trade size in SOL; 0.05 when unset
max_sol	Refinement	Maximum trade size in SOL
action	Refinement	One side`buysell`

Beyond trades

More than a trade tape

Opt-in views on the same connection. For measured delivery numbers, see the latency benchmarks.

Swap legs and routes

Subscribe with legs: true and each matching transaction also arrives as one dex:route plus one dex:leg per pool it touched. Since 2026-10-17 a multi-hop instruction (PumpSwap MultiHopSwap, including a hand-off to a pump.fun curve) arrives as one leg per proved pool, with ids ending #h1, #h2 and a hop_index. decoded_complete says whether every hop was decoded, and an incomplete route names its undecoded program.

legs
dex:route
dex:leg
hop_index
decoded_complete

Liquidity events

Subscribe with liquidity: true for pool_created, add and remove events. material marks a removal of at least 25% of a pool's reserves.

liquidity
dex:liquidity
material

Dust on request

On the live stream, trades under 0.05 SOL are delivered only when you set min_sol yourself, and each one is marked dust: true. Stored trade history over REST has no size floor since 2026-10-22 19:53 UTC.

min_sol
dust

Graduations in-band

A subscription scoped to mints also receives dex:graduations frames when those tokens graduate, on the same connection.

dex:graduations
token_mints

Deployer-tier filter

Target trades by the reputation tier of the token's deployer: elite, good, moderate, rising, cold, unranked.

deployer_tier

Executed price and reserves

Each trade carries the price of that swap and, when available, the pool it hit, the pool model and post-swap reserves as integer strings (null when extraction fails).

executed_price_sol
pool_model
quote_reserve_raw
token_reserve_raw

Capabilities

How MadeOnSol fits

Multiple venues

Reduce venue-by-venue parsing with a normalized trade model across supported programs.

Server-side filtering

Filter by token, wallet, venue, deployer tier, token age, market cap, size or side before trades reach you.

Recovery

After a short disconnect, request a replay of recent trades from the server's in-memory buffer when you resubscribe, and deduplicate by transaction signature.

One market layer

Feed bots, alerts, discovery, terminals and analytics from the same live layer. AI agents get MadeOnSol data as tools through the MCP server mcp-server-madeonsol (108 tools).

Architecture

From DEX programs to your market product

1 · Source
Chain activity
Transactions and program events
2 · MadeOnSol
Data and intelligence layer
- Decoded DEX programs
- Normalized trade model
- Server-side filters
3 · Delivery
- WebSocket streams/ws/v1/dex-stream firehose
- REST API/api/v1 request-response
4 · Yours
Your ingestion service
Keys and business logic stay server-side
5 · Users
Your market product

Build outcomes

What teams can build

Live trade feeds
Trading terminals
DEX analytics
Token activity scanners
Signal engines

Displaying MadeOnSol data to your own users requires a Business plan. See pricing

Keep going

Solution

Trading Bots

Launch, KOL and copy-trade signals for bots.

Solution

Onchain Analytics

Load history over REST, then keep a dashboard live.

Solution

Trading Terminals

Prices, candles and the tape in one interface.

Solution

Token Scanners

From a surge to an enriched scanner result.

Guide

Connect, subscribe and parse trade frames

The firehose in code.

Guide

The firehose against other streaming stacks

A comparison guide.

FAQ

Questions market-data teams ask

Which filters does the DEX firehose support?

Targeting: token_mint(s), wallet(s), dex, program, deployer_tier, token_age_max_seconds and market_cap_min_sol / market_cap_max_sol; each subscription needs at least one. Refinements: min_sol, max_sol and action. The dex filter accepts pumpfun, pumpswap, raydium, jupiter, orca, meteora, launchlab, moonshot.

Can I recover trades after a disconnect?

Within limits. When you resubscribe, replay asks for up to 500 recent matching trades from the server's in-memory buffer, which holds a few minutes of trades; a replay_done frame always follows. The firehose has no resume cursor and no durable backfill, so deduplicate by tx_signature and read older history from the REST trade endpoints. The firehose reference documents replay and replay_done.

Does the firehose include trades below 0.05 SOL?

Only if you ask. min_sol defaults to 0.05 SOL on the live stream; set it to 0, or your own floor, and smaller trades arrive marked dust: true. Stored trade history over REST records every size since 2026-10-22 19:53 UTC.

What does Ultra include for the DEX stream, and can I cancel?

Ultra includes 3 DEX stream connections with up to 10 named subscriptions each; Business has 6. Pay by card, USDC or SOL, and cancel at any time: access continues until the end of the paid period. Pricing compares every plan.

Can this work alongside an existing RPC provider?

Yes. The DEX firehose replaces the work of decoding each venue's swaps yourself. It does not replace RPC access for sending transactions or reading raw accounts.

REST or live transport?

The DEX firehose is a WebSocket stream with server-side filters, and it is not offered as a webhook. For history, the REST trade endpoints return paginated trades per tracked token or per wallet, at every size since 2026-10-22 19:53 UTC.

Can teams prototype first?

You can explore the API with a free key from the developer page, but the DEX firehose itself is a paid-plan feature. Check pricing for the plans that include it, and the streaming docs for its filters and replay options.

Does MadeOnSol execute trades?

No. The firehose is a read-only feed of parsed trades. It does not route orders, quote swaps or submit transactions.

Next step

Subscribe to the venues your product trades on.

Check the measured numbers, explore the response shapes on a free key, then open the firehose.

Real-time Solana DEX trades over one WebSocket

The MadeOnSol DEX firehose streams parsed Solana DEX trades from 14 programs across 8 venues, filtered on the server by token, wallet, venue, size and more.

Try it free

The REST API, live feeds 5 minutes delayed, or the demo without signing up
200 calls a day, no card needed

Get a free API key

Ultra

€131/month

Firehose: 3 connections, 10 subscriptions each
14 programs, 8 venues, one frame shape
500 trades replayed on subscribe, 100,000 REST calls a day

Start Ultra

Billed in euros by card. Checkout shows today's dollar estimate; your card issuer sets the exact amount. USDC or SOL at the day's rate. Cancel anytime.

Server-side filter keys

Named subscriptions per connection

Recent trades replayable on subscribe

500

DEX stream connections on Ultra

Normalized DEX trades from every supported Solana venue over one WebSocket, filtered on the server, for bots, terminals, scanners, analytics and AI agents.

One subscribe, one frame shape

Name what you want and set a size floor; every venue arrives in the same frame. Values are illustrative, keys are the serializer's.

You send

At least one targeting filter is required. replay asks for recent matching trades from the server's buffer.

Subscribe message

// wss://madeonsol.com/ws/v1/dex-stream
{
  "type": "subscribe",
  "sub_id": "pumpswap-flow",
  "filters": { "dex": ["pumpswap"], "min_sol": 1 },
  "replay": 100
}

You receive

One dex:trades frame per matching trade, with the executed price, the pool and its post-swap reserves.

dex:trades frame you receive

{
  "channel": "dex:trades",
  "sub_id": "pumpswap-flow",
  "data": {
    "wallet": "7vfC...rXs2",
    "mint": "Cgxx...pump",
    "action": "buy",
    "sol_amount": 2.5,
    "token_amount": 1234567.89,
    "tx_signature": "5K7j...",
    "block_time": 1790157600,
    "slot": 449476673,
    "program": "pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA",
    "dex": "pumpswap",
    "executed_price_sol": 0.000002025,
    "pool_address": "Gf7h...2kLm",
    "pool_model": "constant_product",
    "pool_quote_mint": "So11111111111111111111111111111111111111112",
    "quote_reserve_raw": "112000000000",
    "quote_decimals": 9,
    "token_reserve_raw": "55308641975309",
    "token_decimals": 6,
    "dust": false
  },
  "ts": 1790157600412
}

Filtered on the server, before trades reach you

Filter	Kind	Accepts
token_mint / token_mints	Targeting	One mint, or up to 50
wallet / wallets	Targeting	One trader wallet, or up to 50
dex	Targeting	One venue or a list`pumpfunpumpswapraydiumjupiterorcameteoralaunchlabmoonshot`
program	Targeting	One raw DEX program ID
deployer_tier	Targeting	One tier or a list`elitegoodmoderaterisingcoldunranked`
token_age_max_seconds	Targeting	Tokens first seen within N seconds
market_cap_min_sol / market_cap_max_sol	Targeting	Market cap bounds in SOL
min_sol	Refinement	Minimum trade size in SOL; 0.05 when unset
max_sol	Refinement	Maximum trade size in SOL
action	Refinement	One side`buysell`

More than a trade tape

Opt-in views on the same connection. For measured delivery numbers, see the latency benchmarks.

Swap legs and routes

legs
dex:route
dex:leg
hop_index
decoded_complete

Liquidity events

Subscribe with liquidity: true for pool_created, add and remove events. material marks a removal of at least 25% of a pool's reserves.

liquidity
dex:liquidity
material

Dust on request

min_sol
dust

Graduations in-band

A subscription scoped to mints also receives dex:graduations frames when those tokens graduate, on the same connection.

dex:graduations
token_mints

Deployer-tier filter

Target trades by the reputation tier of the token's deployer: elite, good, moderate, rising, cold, unranked.

deployer_tier

Executed price and reserves

Each trade carries the price of that swap and, when available, the pool it hit, the pool model and post-swap reserves as integer strings (null when extraction fails).

executed_price_sol
pool_model
quote_reserve_raw
token_reserve_raw

From DEX programs to your market product

1 · Source

Chain activity

Transactions and program events

2 · MadeOnSol

Data and intelligence layer

Decoded DEX programs
Normalized trade model
Server-side filters

3 · Delivery

WebSocket streams/ws/v1/dex-stream firehose
REST API/api/v1 request-response

4 · Yours

Your ingestion service

Keys and business logic stay server-side

5 · Users

Your market product

Real-time Solana DEX trades over one WebSocket

One subscribe, one frame shape

You send

You receive

Explore before you subscribe

Filtered on the server, before trades reach you

More than a trade tape

Swap legs and routes

Liquidity events

Dust on request

Graduations in-band

Deployer-tier filter

Executed price and reserves

How MadeOnSol fits

Multiple venues

Server-side filtering

Recovery

One market layer

From DEX programs to your market product

What teams can build

Related

Questions market-data teams ask

Subscribe to the venues your product trades on.

Real-time Solana DEX trades over one WebSocket

One subscribe, one frame shape

You send

You receive

Explore before you subscribe

Filtered on the server, before trades reach you

More than a trade tape

Swap legs and routes

Liquidity events

Dust on request

Graduations in-band

Deployer-tier filter

Executed price and reserves

How MadeOnSol fits

Multiple venues

Server-side filtering

Recovery

One market layer

From DEX programs to your market product

What teams can build

Related

Questions market-data teams ask

Subscribe to the venues your product trades on.