Connection Guide

wss://exportcomments.com/connection/websocket

npm install centrifuge

import { Centrifuge } from 'centrifuge';

const API_KEY = 'your-api-key';

// Create client with automatic token management
const client = new Centrifuge('wss://exportcomments.com/connection/websocket', {
  getToken: async () => {
    const res = await fetch('https://exportcomments.com/api/public/auth/socket', {
      method: 'POST',
      headers: { 'X-AUTH-TOKEN': API_KEY },
    });
    const data = await res.json();
    return data.token;
  },
});

// Connection state changes
client.on('state', (ctx) => {
  console.log(`State: ${ctx.oldState} → ${ctx.newState}`);
});

// Receive events from auto-subscribed channels
client.on('publication', (ctx) => {
  const { event, guid, status } = ctx.data;

  switch (event) {
    case 'job.created':
      console.log(`Export ${guid} started`);
      break;
    case 'job.progress':
      console.log(`Export ${guid} progress: ${ctx.data.current}/${ctx.data.total}`);
      break;
    case 'job.finished':
      console.log(`Export ${guid} completed — download: ${ctx.data.url}`);
      break;
    case 'job.failed':
      console.log(`Export ${guid} failed`);
      break;
  }
});

// Handle errors
client.on('error', (err) => {
  console.error('Connection error:', err);
});

// Connect
client.connect();

// To disconnect later:
// client.disconnect();

const jobGuid = 'b4219d47-3138-5efd-9762-2ef9f9495084';
const sub = client.newSubscription(`export.${jobGuid}.job`);

sub.on('publication', (ctx) => {
  console.log('Job event:', ctx.data.event, ctx.data);
});

sub.subscribe();

pip install centrifuge-python

import asyncio
import aiohttp
from centrifuge import Client, PublicationEvent

API_KEY = "your-api-key"
WS_URL = "wss://exportcomments.com/connection/websocket"
AUTH_URL = "https://exportcomments.com/api/public/auth/socket"


async def get_token():
    async with aiohttp.ClientSession() as session:
        async with session.post(
            AUTH_URL, headers={"X-AUTH-TOKEN": API_KEY}
        ) as resp:
            data = await resp.json()
            return data["token"]


async def main():
    client = Client(WS_URL, token=await get_token())

    async def on_publication(event: PublicationEvent):
        data = event.data
        event_type = data.get("event")
        guid = data.get("guid")

        if event_type == "job.finished":
            print(f"Export {guid} completed!")
        elif event_type == "job.progress":
            print(f"Export {guid}: {data.get('current')}/{data.get('total')}")
        elif event_type == "job.failed":
            print(f"Export {guid} failed")

    client.on_publication = on_publication

    await client.connect()

    # Keep the connection alive
    try:
        while True:
            await asyncio.sleep(1)
    except KeyboardInterrupt:
        await client.disconnect()


asyncio.run(main())

<script src="https://unpkg.com/centrifuge@5/dist/centrifuge.js"></script>
<script>
  const client = new Centrifuge('wss://exportcomments.com/connection/websocket', {
    getToken: async () => {
      const res = await fetch('https://exportcomments.com/api/public/auth/socket', {
        method: 'POST',
        headers: { 'X-AUTH-TOKEN': 'your-api-key' },
      });
      const data = await res.json();
      return data.token;
    },
  });

  client.on('publication', (ctx) => {
    console.log('Event received:', ctx.data);
  });

  client.connect();
</script>

disconnected → connecting → connected
                    ↑            ↓
                    └── disconnected (auto-reconnect)