Connection and limits

// Most browser WebSocket implementations handle ping/pong automatically.
// For Node.js with the 'ws' library:
const WebSocket = require("ws");
const ws = new WebSocket("wss://relayer.xoxno.com/ws");

ws.on("ping", () => {
  ws.pong();
});

{
  "action": "subscribe",
  "status": "fail",
  "reason": "topic limit reached"
}

{
  "action": "subscribe",
  "status": "fail",
  "reason": "rate limit exceeded"
}

class RelayerClient {
  constructor() {
    this.topics = new Set();
    this.retryDelay = 1000;
    this.connect();
  }

  connect() {
    this.ws = new WebSocket("wss://relayer.xoxno.com/ws");

    this.ws.onopen = () => {
      this.retryDelay = 1000; // Reset on success

      // Re-subscribe to all tracked topics
      for (const topic of this.topics) {
        this.ws.send(JSON.stringify({
          action: "subscribe",
          topic
        }));
      }
    };

    this.ws.onclose = () => {
      console.log(`Reconnecting in ${this.retryDelay}ms`);
      setTimeout(() => this.connect(), this.retryDelay);
      this.retryDelay = Math.min(this.retryDelay * 2, 30000);
    };

    this.ws.onerror = () => this.ws.close();
  }

  subscribe(topic) {
    this.topics.add(topic);
    if (this.ws.readyState === WebSocket.OPEN) {
      this.ws.send(JSON.stringify({ action: "subscribe", topic }));
    }
  }

  unsubscribe(topic) {
    this.topics.delete(topic);
    if (this.ws.readyState === WebSocket.OPEN) {
      this.ws.send(JSON.stringify({ action: "unsubscribe", topic }));
    }
  }
}