WebSocket — /v1/stream

const ws = new WebSocket(
  "wss://api.pipdata.net/v1/stream?api_key=fxd_your_key_here"
);

class ForexWebSocket {
  constructor(apiKey) {
    this.apiKey      = apiKey;
    this.ws          = null;
    this.handlers    = {};
    this.pingTimer   = null;
    this.reconnectMs = 5000;
  }

  connect() {
    this.ws = new WebSocket(
      `wss://api.pipdata.net/v1/stream?api_key=${this.apiKey}`
    );

    this.ws.onopen = () => {
      console.log("WebSocket connected");
      this.reconnectMs = 5000;  // reset backoff

      this.pingTimer = setInterval(() => {
        if (this.ws.readyState === WebSocket.OPEN) {
          this.ws.send(JSON.stringify({ action: "ping" }));
        }
      }, 30_000);
    };

    this.ws.onmessage = (event) => {
      const msg = JSON.parse(event.data);

      switch (msg.type) {
        case "connected":
          console.log(`Session: ${msg.session_id} | Max symbols: ${msg.limits.max_symbols}`);
          break;

        case "subscribed":
          console.log(`Subscribed to ${msg.symbols.length} symbols`);
          if (msg.rejected.length) {
            console.warn("Rejected:", msg.rejected);
          }
          break;

        case "bar":
          this.handlers[msg.symbol]?.(msg.bar);
          break;

        case "error":
          console.error("Server error:", msg.code);
          if (["KEY_INVALID", "KEY_INACTIVE", "KEY_EXPIRED"].includes(msg.code)) {
            this.ws.close();  // don't reconnect on auth errors
          }
          break;
      }
    };

    this.ws.onclose = () => {
      clearInterval(this.pingTimer);
      console.log(`Disconnected — reconnecting in ${this.reconnectMs / 1000}s`);
      setTimeout(() => {
        this.reconnectMs = Math.min(this.reconnectMs * 2, 60_000);
        this.connect();
      }, this.reconnectMs);
    };
  }

  subscribe(symbols, onBar) {
    symbols.forEach(sym => { this.handlers[sym] = onBar; });
    if (this.ws?.readyState === WebSocket.OPEN) {
      this.ws.send(JSON.stringify({
        action: "subscribe",
        symbols,
        type: "bar"
      }));
    }
  }

  disconnect() {
    clearInterval(this.pingTimer);
    this.ws?.close();
  }
}

// Usage
const client = new ForexWebSocket("fxd_your_key_here");
client.connect();

client.subscribe(
  ["WMMARKETS:ZERO:EURUSD", "WMMARKETS:ZERO:XAUUSD"],
  (bar) => {
    const time = new Date(bar.time * 1000).toISOString();
    console.log(`close: ${bar.close} at ${time}`);
  }
);