Realtime Feed

curl "https://www.oceanx.trade/api/v1/tracker/realtime/session" \
  -H "Authorization: Bearer $OCEANX_API_KEY"

{
  "wsUrl": "wss://stream.oceanx.trade/wallet/track/ws?ticket=…&wallets=5Q54…e4j1,9aB…",
  "wallets": ["5Q54…e4j1", "9aB…"],
  "expiresInSeconds": 60
}

{
  "wsUrl": "",
  "wallets": [],
  "expiresInSeconds": 0,
  "message": "No tracked wallets in this view yet. Track a wallet first, then open a session."
}

{
  "type": "snapshot",
  "wallets": {
    "5Q54…e4j1": {
      "balances": {
        "<mint>": { "balance": "12345.67", "lastTradeTs": 1751385600000 }
      },
      "recent_trades": [ /* trade frames, see below (up to 200) */ ]
    }
  }
}

{
  "type": "balance_update",
  "wallet": "5Q54…e4j1",
  "mint": "EKpQ…zcjm",
  "balance_before": "10000.0",
  "balance_after": "12345.67",
  "slot": 301234567,
  "ts": 1751385600000,
  "signature": "3xY…"
}

{
  "type": "pnl_summary",
  "wallet": "5Q54…e4j1",
  "ts": 1751385600000,
  "data": { /* … */ }
}

import WebSocket from "ws";
import { decode } from "@msgpack/msgpack";

const API_KEY = process.env.OCEANX_API_KEY;
const BASE = "https://www.oceanx.trade/api/v1";

async function connect() {
  const res = await fetch(`${BASE}/tracker/realtime/session`, {
    headers: { Authorization: `Bearer ${API_KEY}` },
  });
  const { wsUrl } = await res.json();
  if (!wsUrl) return console.log("No tracked wallets yet.");

  const ws = new WebSocket(wsUrl);
  ws.binaryType = "arraybuffer";

  ws.on("message", (raw) => {
    const frame =
      typeof raw === "string"
        ? JSON.parse(raw)
        : decode(new Uint8Array(raw));

    if (frame.type === "trade") {
      console.log(
        `${frame.side.toUpperCase()} ${frame.symbol} $${frame.volume_usd} by ${frame.wallet}`
      );
    }
  });

  // Reconnect with a fresh session (tickets expire ~60s).
  ws.on("close", () => setTimeout(connect, 1000));
  ws.on("error", () => ws.close());
}

connect();