Event Order Book Updates

// To subscribe
const eventId = "L12003787";
const sub = client.newSubscription(`orderbook_v3_event:${eventId}`, { recoverable: true });

sub.on("publication", (ctx) => {
  const data = ctx.data;
  // message handler logic — key state by data.marketHash
});

sub.subscribe();

import asyncio
from centrifuge import Client, PublicationContext, SubscriptionEventHandler

async def on_publication(ctx: PublicationContext) -> None:
    print(ctx.data)

async def main():
    event_id = "L12003787"
    client = Client(
        "wss://realtime.sx.bet/connection/websocket",
        token="YOUR_TOKEN",  # from /user/realtime-token-v3/api-key
    )
    await client.connect()
    handler = SubscriptionEventHandler(on_publication=on_publication)
    sub = client.new_subscription(f"orderbook_v3_event:{event_id}", handler)
    await sub.subscribe()
    await asyncio.Future()  # keep running

asyncio.run(main())