WebSocket Streaming

const API_KEY = "YOUR_API_KEY";

const ws = new WebSocket(
  `wss://therundown.io/api/v2/ws/markets?key=${API_KEY}&sport_ids=4&market_ids=1,2,3`
);

ws.onopen = () => {
  console.log("Connected to V2 Markets WebSocket");
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);

  // Handle heartbeat
  if (data.meta?.type === "heartbeat") {
    console.log("Heartbeat received");
    return;
  }

  // Process market update
  console.log(
    `Update: event=${data.event_id} market=${data.market_name}`
  );

  for (const participant of data.participants || []) {
    for (const line of participant.lines || []) {
      for (const [affId, price] of Object.entries(line.prices || {})) {
        console.log(
          `  ${participant.name}: ${line.line} @ ${price.price} (${affId})`
        );
      }
    }
  }
};

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

ws.onclose = (event) => {
  console.log(`WebSocket closed: code=${event.code} reason=${event.reason}`);
};

const ws = new WebSocket(
  `wss://therundown.io/api/v2/ws/hedge?key=${API_KEY}&sport_ids=4`
);

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  if (data.meta?.type === "heartbeat") return;

  console.log(`Hedge opportunity: ${data.market_name} (${data.profit_pct}% profit)`);
  for (const bet of data.bets || []) {
    console.log(
      `  ${bet.affiliate_name}: ${bet.participant_name} @ ${bet.price} ($${bet.wager})`
    );
  }
};

let lastHeartbeat = Date.now();

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);

  if (data.meta?.type === "heartbeat") {
    lastHeartbeat = Date.now();
    return; // Do not process as data
  }

  // Process actual data update
  handleUpdate(data);
};

// Monitor heartbeat health
setInterval(() => {
  const elapsed = Date.now() - lastHeartbeat;
  if (elapsed > 60_000) {
    console.warn("No heartbeat in 60s, reconnecting...");
    ws.close();
    // Trigger reconnection logic
  }
}, 10_000);

function createReconnectingWebSocket(url, onMessage) {
  let ws;
  let reconnectDelay = 1000;
  const MAX_DELAY = 30000;

  function connect() {
    ws = new WebSocket(url);

    ws.onopen = () => {
      console.log("WebSocket connected");
      reconnectDelay = 1000; // Reset backoff
    };

    ws.onmessage = (event) => {
      const data = JSON.parse(event.data);
      if (data.meta?.type === "heartbeat") return;
      onMessage(data);
    };

    ws.onclose = () => {
      const jitter = Math.random() * 1000;
      const delay = Math.min(reconnectDelay + jitter, MAX_DELAY);
      console.log(`WebSocket closed. Reconnecting in ${Math.round(delay)}ms...`);

      setTimeout(() => {
        reconnectDelay = Math.min(reconnectDelay * 2, MAX_DELAY);
        connect();
      }, delay);
    };

    ws.onerror = (error) => {
      console.error("WebSocket error:", error);
      ws.close(); // Triggers onclose -> reconnect
    };
  }

  connect();

  return {
    close: () => {
      reconnectDelay = MAX_DELAY + 1; // Prevent reconnection
      ws.close();
    },
  };
}

// Usage
const connection = createReconnectingWebSocket(
  `wss://therundown.io/api/v2/ws/markets?key=${API_KEY}&sport_ids=4`,
  (data) => {
    console.log("Market update:", data.event_id, data.market_name);
  }
);