Your Trade Updates

// To subscribe
const address = "0xbcc6D643e4159A75ED1dB4e13330230B82F2AEe5"; // checksummed
const sub = client.newSubscription(`account:trades_v3_#${address}`, { 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():
    address = "0xbcc6D643e4159A75ED1dB4e13330230B82F2AEe5"  # checksummed
    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"account:trades_v3_#{address}", handler)
    await sub.subscribe()
    await asyncio.Future()  # keep running

asyncio.run(main())