WebSocket stream

wscat -c wss://api.pegana.xyz/v1/ws

import WebSocket from "ws";

const ws = new WebSocket("wss://api.pegana.xyz/v1/ws");

ws.on("open", () => console.log("connected"));
ws.on("message", (data) => {
  const msg = JSON.parse(data.toString());
  console.log(msg);
});

{
  "op": "update",
  "asset": "jitoSOL",
  "payload": {
    "state": "DRIFT",
    "discount": "-0.0034",
    "intrinsic_usd": "213.42",
    "market_usd": "212.69",
    "updated_at": "2026-05-26T14:32:11Z"
  }
}

{
  "op": "heartbeat",
  "ts": "2026-05-26T14:32:16Z"
}

{
  "op": "error",
  "msg": "malformed subscribe message"
}

{ "op": "ping" }

{ "op": "subscribe", "assets": ["USDC", "jitoSOL"] }

function connect() {
  const ws = new WebSocket("wss://api.pegana.xyz/v1/ws");
  let lastFrame = Date.now();

  ws.on("message", (data) => {
    lastFrame = Date.now();
    // handle msg
  });

  // Hardstop if no frame in 15s
  const watchdog = setInterval(() => {
    if (Date.now() - lastFrame > 15_000) {
      ws.terminate();
    }
  }, 5_000);

  ws.on("close", () => {
    clearInterval(watchdog);
    setTimeout(connect, jitter(1_000, 5_000));   // backoff with jitter
  });
}

connect();