ForecastEx WebSocket

wss://api.delphiterminal.co/ws/fex?api_key=YOUR_API_KEY

{
  "action": "subscribe",
  "market_ids": ["EMCAC_1226_24"],
  "message_types": ["prices", "trades"]
}

{
  "action": "unsubscribe",
  "market_ids": ["EMCAC_1226_24"]
}

{
  "type": "prices",
  "data": {
    "venue": "FEX",
    "market_id": "EMCAC_1226_24",
    "server_time": 1774762511552,
    "ingest_time": 1774762511553,
    "payload": {
      "type": "Ticker",
      "Ticker": {
        "price": 0.65,
        "yes_bid": 0.0,
        "yes_ask": 0.0,
        "volume": 0,
        "open_interest": 0
      }
    }
  }
}

{
  "type": "trades",
  "data": {
    "venue": "FEX",
    "market_id": "EMCAC_1226_24",
    "server_time": 1774762511552,
    "payload": {
      "type": "Trade",
      "Trade": {
        "yes_price": 0.65,
        "no_price": 0.35,
        "count": 1,
        "taker_side": "yes"
      }
    }
  }
}

const ws = new WebSocket("wss://api.delphiterminal.co/ws/fex?api_key=YOUR_API_KEY");

ws.onopen = () => {
  console.log("Connected to ForecastEx WebSocket");

  ws.send(JSON.stringify({
    action: "subscribe",
    market_ids: ["EMCAC_1226_24"],
    message_types: ["prices", "trades"]
  }));
};

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

  if (data.type === "prices") {
    console.log("Price update:", data.data);
  } else if (data.type === "trades") {
    console.log("Trade:", data.data);
  }
};

ws.onclose = () => console.log("Disconnected");
ws.onerror = (error) => console.error("WebSocket error:", error);