Transmitir precios Solana y actualizar gráficos en vivo

Elige el pool principal, uno concreto, todos los pools o un precio agregado. Carga el historial desde la Data API y usa los ticks para actualizar la vela actual.

URL: wss://datastream.solanatracker.io/{apiKey}
Disponible en los planes Premium, Business y Enterprise.

Conectarse

Todos los canales de Datastream usan la misma conexión WebSocket. Envía mensajes JSON para unirte a salas y salir de ellas. Consulta el protocolo de Datastream para ver el latido (ping/pong), los fallos de autenticación y cómo funciona leave.

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
  }
};

Precio por token

Suscríbete a price-by-token:{tokenAddress} para obtener el precio del pool principal. El pool principal suele ser el de mayor liquidez.

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
  }
}

Precio agregado

Suscríbete a price:aggregated:{tokenAddress} para obtener un resumen del precio entre pools. El payload incluye mediana, media, mínimo, máximo y número de pools.

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": [...]
}

Precio por pool

Suscríbete a price:{poolId} para recibir actualizaciones de precio de un pool concreto. Úsalo cuando te interese un DEX o una fuente de liquidez en particular.

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

Precios de todos los pools

Suscríbete a price:{tokenAddress} (sin aggregated) para recibir actualizaciones de precio individuales de cada pool donde se opera un token.

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

Cambios del token (actualizaciones completas)

Suscríbete a token:{tokenAddress} cuando necesites más estado del pool que el precio, como liquidez, market cap, supply y campos de seguridad.

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}%`);
  }
};

Solo para el pool principal (menos ruido en tokens con varios pools):

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

Transacciones en vivo

Suscríbete a transaction:{tokenAddress} para ver cada swap en cuanto ocurre.

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}`);
    });
  }
};

Filtra por pool:

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

Crear un gráfico en vivo

Carga las velas históricas desde el endpoint OHLCV y usa los ticks de precio para actualizar el open, high, low y close de la vela actual. Los ticks de precio por sí solos no dan el volumen operado.

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
};

Ejemplos de gráficos de código abierto

Estos repositorios de ejemplo muestran cómo conectar el historial y los feeds en vivo:

Liveline Chart

Gráfico de líneas mínimo en tiempo real con el WebSocket de Datastream. Buen punto de partida para interfaces propias.

TradingView Advanced Chart

Integración completa de TradingView Advanced Charts con actualizaciones de velas en tiempo real desde Datastream.

Volumen y estadísticas

Volumen del token

Suscríbete a volume:token:{tokenAddress} para recibir actualizaciones de volumen agregado:

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

Estadísticas del token

Suscríbete a stats:token:{tokenAddress} para recibir estadísticas en varios intervalos (1m, 5m, 1h, 6h, 24h: compras y ventas, volumen, traders únicos):

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

Para un único snapshot total:

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

Referencia de salas

Patrón de sala	Qué recibes
`price-by-token:{token}`	Precio del pool principal
`price:aggregated:{token}`	Mediana, media, mínimo y máximo entre pools
`price:{pool}`	Precio de un pool
`price:{token}`	Precio de todos los pools
`token:{token}`	Estado completo del pool (precio, liquidez, mcap)
`token:{token}:primary`	Solo el estado del pool principal
`transaction:{token}`	Todos los swaps de un token
`transaction:{token}:{pool}`	Swaps en un pool concreto
`volume:token:{token}`	Volumen agregado
`stats:token:{token}`	Estadísticas en varios intervalos

Precios y gráficos

Endpoints REST para OHLCV histórico, snapshots de precio y datos de ATH.

Lanzamientos de tokens

Recibe en vivo tokens nuevos, tokens en graduación y eventos de mercado.

Primeros pasos

Datos de tokens

Wallets y PnL

Datos en vivo

Pump.fun

Mercados de predicción

Swaps y RPC

Transmitir precios Solana y actualizar gráficos en vivo

Conectarse

Precio por token

Precio agregado

Precio por pool

Precios de todos los pools

Cambios del token (actualizaciones completas)

Transacciones en vivo

Crear un gráfico en vivo

Ejemplos de gráficos de código abierto

Liveline Chart

TradingView Advanced Chart

Volumen y estadísticas

Volumen del token

Estadísticas del token

Referencia de salas

Precios y gráficos

Lanzamientos de tokens

​Conectarse

​Precio por token

​Precio agregado

​Precio por pool

​Precios de todos los pools

​Cambios del token (actualizaciones completas)

​Transacciones en vivo

​Crear un gráfico en vivo

​Ejemplos de gráficos de código abierto

Liveline Chart

TradingView Advanced Chart

​Volumen y estadísticas

​Volumen del token

​Estadísticas del token

​Referencia de salas

Precios y gráficos

Lanzamientos de tokens

Conectarse

Precio por token

Precio agregado

Precio por pool

Precios de todos los pools

Cambios del token (actualizaciones completas)

Transacciones en vivo

Crear un gráfico en vivo

Ejemplos de gráficos de código abierto

Volumen y estadísticas

Volumen del token

Estadísticas del token

Referencia de salas