Stream Solana token prices and update live charts

Choose a price room by scope: the primary pool, a specific pool, every pool, or an aggregate across pools. For charts, combine these ticks with historical candles from the Data API.

URL: wss://datastream.solanatracker.io/{apiKey}
Available on Premium, Business, and Enterprise plans.

Connect

All Datastream channels use the same WebSocket connection. Send JSON messages to join and leave rooms. See the Datastream protocol for heartbeat (ping/pong), auth failures, and leave semantics.

const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

ws.onopen = () => {
  console.log("Connected");
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "ping") {
    ws.send(JSON.stringify({ type: "pong" }));
    return;
  }
  if (msg.type === "message") {
    // Handle data
  }
};

Price by token

Subscribe to price-by-token:{tokenAddress} for the primary pool’s price. The primary pool is usually the one with the most liquidity.

const token = "9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump";

// Join
ws.send(JSON.stringify({ type: "join", room: `price-by-token:${token}` }));

// Receive
ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "joined") {
    console.log(`Subscribed to ${msg.room}`);
  }
  if (msg.type === "message") {
    const { price, price_quote, pool, time } = msg.data;
    console.log(`$${price} (${price_quote} SOL) at ${new Date(time).toISOString()}`);
  }
};

// Leave when done
ws.send(JSON.stringify({ type: "leave", room: `price-by-token:${token}` }));

Payload:

{
  "type": "message",
  "room": "price-by-token:9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump",
  "data": {
    "price": 0.008006,
    "price_quote": 0.00010064,
    "pool": "EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump",
    "token": "9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump",
    "time": 1723728065246
  }
}

Aggregated price

Subscribe to price:aggregated:{tokenAddress} for a cross-pool price summary. The payload includes median, average, minimum, maximum, and pool count.

const sol = "So11111111111111111111111111111111111111112";

ws.send(JSON.stringify({ type: "join", room: `price:aggregated:${sol}` }));

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "message") {
    const { price, aggregated } = msg.data;
    console.log(`Price: $${price}`);
    console.log(`Median: $${aggregated.median} (${aggregated.poolCount} pools)`);
    console.log(`Range: $${aggregated.min} — $${aggregated.max}`);
  }
};

Payload:

{
  "price": 153.70,
  "aggregated": {
    "median": 153.68,
    "average": 153.67,
    "min": 153.36,
    "max": 153.71,
    "poolCount": 10
  },
  "topPools": [...]
}

Price by pool

Subscribe to price:{poolId} for price updates from one specific pool. Use this when you care about a particular DEX or liquidity source.

ws.send(JSON.stringify({ type: "join", room: "price:EWiYmq3nWQpoTkcU4UfGYEoYvDHduDsXhpPvqmoqpump" }));

All pool prices

Subscribe to price:{tokenAddress} (without aggregated) to receive individual price updates from every pool a token trades on.

ws.send(JSON.stringify({ type: "join", room: `price:${token}` }));

Token changes (full updates)

Subscribe to token:{tokenAddress} when you need pool state beyond price, including liquidity, market cap, supply, and security fields.

ws.send(JSON.stringify({ type: "join", room: `token:${token}` }));

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "message") {
    const d = msg.data;
    console.log(`Price: $${d.price.usd}`);
    console.log(`Liquidity: $${d.liquidity.usd}`);
    console.log(`Market Cap: $${d.marketCap.usd}`);
    console.log(`LP Burn: ${d.lpBurn}%`);
  }
};

For primary pool only (less noise on multi-pool tokens):

ws.send(JSON.stringify({ type: "join", room: `token:${token}:primary` }));

Live transactions

Subscribe to transaction:{tokenAddress} to see every swap as it happens.

ws.send(JSON.stringify({ type: "join", room: `transaction:${token}` }));

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type === "message") {
    const trades = Array.isArray(msg.data) ? msg.data : [msg.data];
    trades.forEach(t => {
      const side = t.type === "buy" ? "BUY " : "SELL";
      console.log(`${side} $${t.volume.toFixed(2)} by ${t.wallet}`);
    });
  }
};

Filter by pool:

ws.send(JSON.stringify({
  type: "join",
  room: `transaction:${token}:${poolId}`
}));

Build a live chart

Load historical candles from the OHLCV endpoint, then use price ticks to update the current candle’s open, high, low, and close. Price ticks alone do not provide traded volume.

const token = "9BB6NFEcjBCtnNLFko2FqVQBq8HHM13kCyYcdQbgpump";
const headers = { "x-api-key": "YOUR_API_KEY" };

// 1. Load historical candles via REST
const now = Math.floor(Date.now() / 1000);
const candles = await fetch(
  `https://data.solanatracker.io/chart/${token}?type=1m&time_from=${now - 3600}&time_to=${now}`,
  { headers }
).then(r => r.json());

let currentCandle = candles[candles.length - 1];

// 2. Stream live price updates
const ws = new WebSocket("wss://datastream.solanatracker.io/YOUR_API_KEY");

ws.onopen = () => {
  ws.send(JSON.stringify({ type: "join", room: `price-by-token:${token}` }));
};

ws.onmessage = (event) => {
  const msg = JSON.parse(event.data);
  if (msg.type !== "message") return;

  const { price, time } = msg.data;
  const candleStart = Math.floor(time / 60000) * 60;

  if (candleStart > currentCandle.time) {
    // New candle
    candles.push(currentCandle);
    currentCandle = { time: candleStart, open: price, high: price, low: price, close: price, volume: 0 };
  } else {
    // Update current candle
    currentCandle.close = price;
    currentCandle.high = Math.max(currentCandle.high, price);
    currentCandle.low = Math.min(currentCandle.low, price);
  }

  // Render candles + currentCandle to your chart library
};

Open-source chart examples

These example repositories show how to connect the history and live feeds:

Liveline Chart

Minimal real-time line chart using the Datastream WebSocket. Good starting point for custom UIs.

TradingView Advanced Chart

Full TradingView Advanced Charts integration with real-time candle updates from the Datastream.

Volume & statistics

Token volume

Subscribe to volume:token:{tokenAddress} for aggregated volume updates:

ws.send(JSON.stringify({ type: "join", room: `volume:token:${token}` }));

Token statistics

Subscribe to stats:token:{tokenAddress} for multi-timeframe stats (1m, 5m, 1h, 6h, 24h buy/sell counts, volume, unique traders):

ws.send(JSON.stringify({ type: "join", room: `stats:token:${token}` }));

For a single total snapshot:

ws.send(JSON.stringify({ type: "join", room: `stats:token:${token}:total` }));

Room reference

Room pattern	What you get
`price-by-token:{token}`	Price from primary pool
`price:aggregated:{token}`	Cross-pool median/avg/min/max
`price:{pool}`	Price from one pool
`price:{token}`	Price from all pools
`token:{token}`	Full pool state (price, liquidity, mcap)
`token:{token}:primary`	Primary pool state only
`transaction:{token}`	All swaps on a token
`transaction:{token}:{pool}`	Swaps in a specific pool
`volume:token:{token}`	Aggregated volume
`stats:token:{token}`	Multi-timeframe statistics

Prices and charts

REST endpoints for historical OHLCV, price snapshots, and ATH data.

Token launches

Stream new tokens, graduating tokens, and market events.

Start here

Token data

Wallets and PnL

Live data

Pump.fun

Prediction markets

Trading and RPC

Stream Solana token prices and update live charts

Connect

Price by token

Aggregated price

Price by pool

All pool prices

Token changes (full updates)

Live transactions

Build a live chart

Open-source chart examples

Liveline Chart

TradingView Advanced Chart

Volume & statistics

Token volume

Token statistics

Room reference

Prices and charts

Token launches

​Connect

​Price by token

​Aggregated price

​Price by pool

​All pool prices

​Token changes (full updates)

​Live transactions

​Build a live chart

​Open-source chart examples

Liveline Chart

TradingView Advanced Chart

​Volume & statistics

​Token volume

​Token statistics

​Room reference

Prices and charts

Token launches

Connect

Price by token

Aggregated price

Price by pool

All pool prices

Token changes (full updates)

Live transactions

Build a live chart

Open-source chart examples

Volume & statistics

Token volume

Token statistics

Room reference