WebSocket API

import WebSocket from "ws";

const apiKey = process.env.OXARCHIVE_API_KEY;
if (!apiKey) throw new Error("Set OXARCHIVE_API_KEY");

const ws = new WebSocket("wss://api.0xarchive.io/ws", {
  headers: { Authorization: `Bearer ${apiKey}` }
});

ws.onopen = () => {
  ws.send(JSON.stringify({ op: "subscribe", channel: "orderbook", symbol: "BTC" }));
};

ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
  if (message.type === "error") console.error(message.message);
  if (message.type === "subscribed") console.log("subscription accepted", message.channel, message.symbol);
  if (message.type === "data") console.log(message.channel, message.symbol, message.data);
};

ws.onerror = (error) => console.error("websocket error", error);
ws.onclose = (event) => console.log("websocket closed", event.code, event.reason);