Real time

import WebSocket from "ws";

const STOP = new Set(["SUBSCRIPTION_DENIED", "AUTHORIZATION_REVOKED", "INVALID_SUBSCRIPTION", "SUBPROTOCOL_REQUIRED"]);
let cursor = loadCursor(); // your last applied cursor, or undefined
let attempt = 0;

function connect() {
  const ws = new WebSocket("wss://hip4-api.totalis.trade/v1/stream", "totalis.realtime.v2", {
    headers: { Authorization: `Bearer ${process.env.TOTALIS_API_KEY}` },
  });
  let replaced = false;
  let stable;

  ws.on("open", () => {
    // A maker sends { type: "maker", maker_id: "7" }
    ws.send(JSON.stringify({ method: "subscribe", subscription: { type: "account", ...(cursor && { cursor }) } }));
  });

  ws.on("message", (raw) => {
    const { channel, data } = JSON.parse(raw);
    if (channel === "subscriptionResponse") stable = setTimeout(() => (attempt = 0), 60_000); // reset backoff once it holds
    if (channel === "snapshot") {
      replaceState(data.resources); // then page each class listed in data.truncated
      saveCursor((cursor = data.cursor));
      readBalancesAndPositions();
    }
    if (channel === "event") {
      if (cursor && BigInt(data.cursor.sequence) <= BigInt(cursor.sequence)) return; // already applied
      apply(data.event_type, data.payload); // ignore event types you do not know
      saveCursor((cursor = data.cursor));
    }
    if (channel === "reset") cursor = undefined;
    if (channel === "drain") {
      replaced = true;
      connect(); // the new socket resumes from cursor; the server closes this one
    }
  });

  ws.on("error", (error) => console.warn(`stream error: ${error.message}`)); // close follows

  ws.on("close", (_code, reason) => {
    clearTimeout(stable);
    const code = reason.toString();
    if (STOP.has(code)) return console.error(`stream stopped: ${code}`); // fix the key or the frame
    if (code === "CURSOR_RESET") cursor = undefined;
    if (replaced) return;
    setTimeout(connect, Math.min(30_000, 500 * 2 ** attempt++));
  });
}

connect();