Examples

const ws = new WebSocket(
  "wss://api.tradara.com/v1/ws",
  ["bearer", accessToken],
);

ws.onopen = () => {
  ws.send(JSON.stringify({ op: "ping", ts: Date.now() }));
};

ws.onmessage = (evt) => {
  const msg = JSON.parse(evt.data);
  if (msg.schema === "ws.user.v1") {
    // route by (entity, event) — see /trading/realtime/event-catalog
    handleEvent(msg);
  } else if (msg.type === "pong") {
    // keepalive ack
  }
};

ws.onclose = () => scheduleReconnect();
ws.onerror = (err) => console.error("[ws]", err);

import WebSocket from "ws";

const ws = new WebSocket("wss://api.tradara.com/v1/ws", {
  headers: { Authorization: `Bearer ${process.env.TRADARA_ACCESS_TOKEN}` },
});

ws.on("open", () => console.log("[ws] open"));

ws.on("message", (raw) => {
  const msg = JSON.parse(raw.toString());
  if (msg.schema === "ws.user.v1") {
    console.log(`[event] ${msg.entity}.${msg.event} account=${msg.account_id}`);
  }
});

setInterval(() => {
  if (ws.readyState === WebSocket.OPEN) {
    ws.send(JSON.stringify({ op: "ping", ts: Date.now() }));
  }
}, 20_000);

async function syncAccount(accountId) {
  // 1. Parallel REST hydration
  const [orders, fills, positions, trades, balances, stats] = await Promise.all([
    api.get(`/v1/orders?account_id=${accountId}`),
    api.get(`/v1/fills?account_id=${accountId}`),
    api.get(`/v1/positions?account_id=${accountId}`),
    api.get(`/v1/trades?account_id=${accountId}`),
    api.get(`/v1/balances/${accountId}`),
    api.get(`/v1/stats/${accountId}`),
  ]);
  store.hydrate({ orders, fills, positions, trades, balances, stats });

  // 2. Open the WebSocket
  const ws = new WebSocket(
    "wss://api.tradara.com/v1/ws",
    ["bearer", await getAccessToken()],
  );

  ws.onmessage = (evt) => {
    const env = JSON.parse(evt.data);
    if (env.schema !== "ws.user.v1") return;
    if (env.account_id !== accountId) return; // UI is single-account-scoped

    switch (`${env.entity}.${env.event}`) {
      case "orders.state":     store.upsertOrder(env.data); break;
      case "fills.persisted":  store.appendFill(env.data); break;
      case "positions.updated":store.upsertPosition(env.data); break;
      case "positions.closed": store.closePosition(env.data); break;
      case "balances.updated": store.setBalance(env.data); break;
      case "stats.updated":    store.setStats(env.data); break;
      // …
    }
  };

  // 3. On close, re-run syncAccount(accountId) with backoff
  ws.onclose = () => scheduleReconnect(() => syncAccount(accountId));
}