Every race, every bookie's price, side by side.

// npm install centrifuge ws   (Node 22+ has a global WebSocket; ws is for older Node)
import { Centrifuge } from 'centrifuge';

const WS_URL = 'wss://api.oddsfather.com.au/connection/websocket'; // set at build time from PUBLIC_WS_URL
const API_KEY = process.env.ODDS_API_KEY; // opa_...
const races = new Map();
const apply = (payload) => { for (const race of payload.events ?? []) races.set(race.key, race); };

const client = new Centrifuge(WS_URL, {
  headers: { Authorization: `Bearer ${API_KEY}` }, // sent as emulated headers
  data: { key: API_KEY },
});

client.on('connected', async (ctx) => {
  console.log('connected', ctx.client);
  try {
    apply((await client.rpc('snapshot', {})).data);
  } catch {
    const hist = await client.history('odds:v2:snapshot', { limit: 1 });
    if (hist.publications.length) apply(hist.publications[0].data);
  }
  console.log(races.size, 'races loaded');
});
client.on('subscribed', (ctx) => console.log('granted', ctx.channel));
client.on('publication', (ctx) => apply(ctx.data)); // server-side subscriptions
client.on('disconnected', (ctx) => console.log('disconnected', ctx.code, ctx.reason));

client.connect();