Fetching odds

curl "https://api.sx.bet/orderbook-v3/snapshot?marketHash=0x5be2a55e4b7dec1cec1b75af93b3fdef178ec1473866da95b3c68c1d4c99d4fd"

{
  "status": "success",
  "data": {
    "marketHash": "0x5be2a55e…d4fd",
    "outcomeOne": [{ "percentageOdds": "52000000000000000000", "size": "2000000" }],
    "outcomeTwo": [{ "percentageOdds": "46750000000000000000", "size": "1000000" }],
    "version": "00100000000000002210000"
  }
}

curl "https://api.sx.bet/orders-v3/odds/best?marketHashes=0x5be2a55e…d4fd,0xbf06c637…a2eb"

const sub = client.newSubscription("best_odds_v3:global");

sub.on("publication", (ctx) => {
  if (watchlist.has(ctx.data.marketHash)) applyBestOdds(ctx.data);
});

sub.on("subscribed", async () => {
  // Unconditional — this channel has no recovery, so seed on every connect.
  const { status, data } = await fetch(
    `${API}/orders-v3/odds/best?marketHashes=${marketHashes.join(",")}`
  ).then((r) => r.json());
  if (status !== "success") return; // keep prior state; retry next tick
  for (const row of data.bestOdds) applyBestOdds(row);
});

sub.subscribe();

const sub = client.newSubscription(`orderbook_v3:${marketHash}`);

// Every publication runs through the version rule; stale ones are discarded.
sub.on("publication", (ctx) => applyUpdate(ctx.data));

sub.on("subscribed", async (ctx) => {
  // recovered: true means the book was replayed — no REST seed needed.
  if (ctx.recovered) return;
  const { data } = await fetch(
    `${API}/orderbook-v3/snapshot?marketHash=${marketHash}`
  ).then((r) => r.json());
  // The snapshot goes through the same version rule, so a newer live update
  // that arrived during the fetch is not clobbered. `data` is flat — the level
  // arrays sit directly beside `marketHash` and `version`.
  applySnapshot(marketHash, data.version, data);
});

sub.subscribe();