Launch stream (WSS)

Receive an initial view of indexed Solana launches, followed by changes over one WebSocket connection. This is a changing launch view, not a stream of individual trades.

wss://api.dexra.dev/new_launches/stream

Access and authentication

Create an API key and use an active, non-trial subscription with launch_stream enabled. Access and limits are managed per plan; a plan name alone does not grant access. Delivery is included in the subscription and updates do not consume tool credits.

Check GET https://api.dexra.dev/billing/plans for launch_stream, stream_connections, stream_max_launches and stream_interval_seconds. The ready event reports the effective limits for this connection. Global service capacity can also limit connections.

Currently enabled plans: Scale, Business, Scale, Business. View plans.

Send the auth frame within five seconds of opening the connection. Server clients may instead send Authorization: Bearer dxr_… or X-Api-Key during the upgrade. Use an API key, not the cabinet session token. Keep keys out of URLs and public frontend bundles.

{"type":"auth","api_key":"dxr_YOUR_KEY","client":"my-bot/1.0"}

Connect from Node.js

Save as stream.mjs, set DEXRA_API_KEY in the server environment, then run node stream.mjs. Node.js 22 or later includes WebSocket; no package is needed.

// Node.js 22+. Set DEXRA_API_KEY in your server environment.
const apiKey = process.env.DEXRA_API_KEY;
if (!apiKey) throw new Error('Set DEXRA_API_KEY first');

const launches = new Map();
const ws = new WebSocket("wss://api.dexra.dev/new_launches/stream");

ws.onopen = () => ws.send(JSON.stringify({
  type: 'auth', api_key: apiKey, client: 'my-bot/1.0'
}));

ws.onmessage = ({ data }) => {
  const event = JSON.parse(data);
  switch (event.type) {
    case 'ready':
      console.log('Connected', event);
      break;
    case 'snapshot_start':
      launches.clear();
      break;
    case 'upsert':
      launches.set(event.launch.pool, event.launch);
      break;
    case 'remove':
      launches.delete(event.pool);
      break;
    case 'snapshot_end':
      console.log('Initial view ready', [...launches.values()]);
      break;
    case 'status':
    case 'error':
      console.log(event);
      break;
  }
};

ws.onerror = () => console.error('WebSocket connection failed');
ws.onclose = ({ code, reason }) => {
  console.log('Disconnected', code, reason);
  // Fix auth, access or filters before retrying 4401, 4403 or 4400.
  // For temporary failures, reconnect with capped exponential backoff.
  // Every reconnect sends a new snapshot; discard the previous view.
};

Events and reconnects

Every reconnect starts a new snapshot. There is no durable replay cursor or exactly-once delivery. Use capped exponential backoff with jitter for temporary failures and replace the old view. Standard WebSocket clients handle protocol ping/pong automatically; no JSON heartbeat is needed.

Optional filters

Add query parameters to the endpoint before connecting. Omit limit to use your plan's default. To change filters, reconnect.

The shared source covers the latest 200 indexed pools within a rolling 60-minute window. Filters operate inside that bounded source. Read source freshness and coverage from stream events; delivery frequency does not guarantee every on-chain launch has been indexed.

Connection failures

Header authentication can return HTTP 401 or 403 before upgrade; exhausted service capacity can return HTTP 429. Fix the cause before retrying.