Initialization

npm install centrifuge

pip install centrifuge-python requests

import { Centrifuge } from "centrifuge";

const RELAYER_URL = "https://api.sx.bet"; // Mainnet — use https://api.toronto.sx.bet for testnet
const WS_URL = "wss://realtime.sx.bet/connection/websocket"; // Mainnet — use wss://realtime.toronto.sx.bet/connection/websocket for testnet

async function fetchCentrifugoToken(apiKey) {
  const res = await fetch(`${RELAYER_URL}/user/realtime-token/api-key`, {
    headers: { "x-api-key": apiKey },
  });
  if (!res.ok) {
    const body = await res.text();
    throw new Error(`Token endpoint returned ${res.status}: ${body}`);
  }
  const { token } = await res.json();
  return token;
}

const client = new Centrifuge(WS_URL, {
  getToken: () => fetchCentrifugoToken(YOUR_API_KEY),
});

client.connect();

import asyncio
import os
import requests
from centrifuge import Client

RELAYER_URL = "https://api.sx.bet"  # Mainnet — use https://api.toronto.sx.bet for testnet
WS_URL = "wss://realtime.sx.bet/connection/websocket"  # Mainnet — use wss://realtime.toronto.sx.bet/connection/websocket for testnet

def fetch_token():
    res = requests.get(
        f"{RELAYER_URL}/user/realtime-token/api-key",
        headers={"x-api-key": os.environ["SX_API_KEY"]},
    )
    if not res.ok:
        body = res.text
        raise Exception(f"Token endpoint returned {res.status_code}: {body}")
    return res.json()["token"]

async def main():
    client = Client(WS_URL, get_token=fetch_token)
    await client.connect()
    await asyncio.Future()  # keep running

asyncio.run(main())

const sub = client.newSubscription("channel:name", { positioned: true, recoverable: true });

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

sub.subscribe();

import asyncio
from centrifuge import Client, PublicationContext, SubscriptionEventHandler

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

async def main():
    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("channel:name", handler)
    await sub.subscribe()
    await asyncio.Future()  # keep running

asyncio.run(main())

sub.unsubscribe();
sub.removeAllListeners();
client.removeSubscription(sub);

await sub.unsubscribe()
client.remove_subscription(sub)