WebSocket disconnects mid-match: reconnect without losing state.

const KEY = process.env.CITO_API_KEY
const ROOMS = ["match:cs2-match-2398722"]          // or ["all"]
let delay = 1000

function connect() {
  const ws = new WebSocket(`wss://api.citoapi.com/api/v1/cs2/live/ws?apiKey=${KEY}`)
  let lastMessage = Date.now()

  ws.onopen = () => {
    delay = 1000
    ws.send(JSON.stringify({ action: "subscribe", rooms: ROOMS }))
  }
  ws.onmessage = (ev) => {
    lastMessage = Date.now()
    const msg = JSON.parse(ev.data)
    if (msg.type === "ping" || msg.type === "pong") return
    if (msg.type === "error") return console.error(msg.code, msg.message)
    render(msg) // the snapshot after subscribe, then every update
  }
  // No message for 45 s (three missed pings) means a dead connection.
  const watchdog = setInterval(() => {
    if (Date.now() - lastMessage > 45_000) ws.close()
  }, 5_000)

  ws.onclose = () => {
    clearInterval(watchdog)
    const wait = delay + Math.random() * 1000
    delay = Math.min(delay * 2, 30_000)
    setTimeout(connect, wait)
  }
}

function render(msg) { console.log(msg) }
connect()

import { EventSource } from "eventsource"

const es = new EventSource("https://api.citoapi.com/api/v1/cs2/live/stream?matchId=cs2-match-2398722", {
  fetch: (url, init) => fetch(url, { ...init, headers: { ...init.headers, "x-api-key": process.env.CITO_API_KEY } }),
})
es.onmessage = (ev) => console.log(JSON.parse(ev.data))