WebSocket Overview

wss://api.orica.markets/ws

const ws = new WebSocket("wss://api.orica.markets/ws/markets/ABC123...");

ws.onopen = () => {
  console.log("Connected");
};

ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
  console.log("Received:", message.type);
};

ws.onerror = (error) => {
  console.error("WebSocket error:", error);
};

ws.onclose = (event) => {
  console.log("Disconnected:", event.code, event.reason);
};

// Keep alive
setInterval(() => {
  if (ws.readyState === WebSocket.OPEN) {
    ws.send(JSON.stringify({ action: "ping" }));
  }
}, 30000);

function createReconnectingWebSocket(url: string) {
  let ws: WebSocket;
  let reconnectAttempts = 0;
  const maxReconnectAttempts = 5;
  
  function connect() {
    ws = new WebSocket(url);
    
    ws.onopen = () => {
      reconnectAttempts = 0;
      console.log("Connected");
    };
    
    ws.onclose = (event) => {
      if (event.code !== 1000 && reconnectAttempts < maxReconnectAttempts) {
        const delay = Math.pow(2, reconnectAttempts) * 1000;
        reconnectAttempts++;
        console.log(`Reconnecting in ${delay}ms...`);
        setTimeout(connect, delay);
      }
    };
    
    ws.onerror = () => {
      ws.close();
    };
  }
  
  connect();
  return () => ws;
}