CE Refund Events

// To subscribe
const bettor = "0xaD6A65315Cb20dD0b9D0Af56213516727a20C66F";
const sub = client.newSubscription(`ce_refunds:${bettor}`, { positioned: true, recoverable: true });

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

sub.subscribe();

import asyncio
from centrifuge import Client, PublicationContext, SubscriptionEventHandler

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

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

asyncio.run(main())