Trades Channel

// Dev endpoint — no API key required, but rate-limited.
// For production, use your production WS URL and add:
//   { headers: { "x-api-key": "YOUR_API_KEY" } }
// as the second argument to new WebSocket().
const WS_URL = "wss://dev-prediction-markets-api.dflow.net/api/v1/ws";

const ws = new WebSocket(WS_URL);

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

  // Subscribe to all trade updates
  ws.send(
    JSON.stringify({
      type: "subscribe",
      channel: "trades",
      all: true,
    })
  );
};

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

  if (message.channel === "trades") {
    console.log("Trade executed:", {
      ticker: message.market_ticker,
      tradeId: message.trade_id,
      side: message.taker_side,
      count: message.count,
      yesPrice: message.yes_price_dollars,
      noPrice: message.no_price_dollars,
      time: new Date(message.created_time).toISOString(),
    });
  }
};

ws.onerror = (error) => {
  console.error("WebSocket error:", error);
};

ws.onclose = () => {
  console.log("WebSocket connection closed");
};

// Dev endpoint — no API key required, but rate-limited.
// For production, use your production WS URL and add:
//   { headers: { "x-api-key": "YOUR_API_KEY" } }
// as the second argument to new WebSocket().
const WS_URL = "wss://dev-prediction-markets-api.dflow.net/api/v1/ws";

// Market tickers to subscribe to
const marketTickers = ["BTCD-25DEC0313-T92749.99", "SPX-25DEC0313-T5000"];

const ws = new WebSocket(WS_URL);

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

  // Subscribe to specific tickers for trades
  ws.send(
    JSON.stringify({
      type: "subscribe",
      channel: "trades",
      tickers: marketTickers,
    })
  );
};

ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
  console.log(`Trade on ${message.market_ticker}:`, message);
};

interface TradeUpdate {
  channel: "trades";
  type: "trade";
  market_ticker: string;
  trade_id: string;
  price: number;
  count: number;
  yes_price: number;
  no_price: number;
  yes_price_dollars: string;
  no_price_dollars: string;
  taker_side: "yes" | "no";
  created_time: number;
}

function handleTradeUpdate(update: TradeUpdate) {
  console.log(`Trade executed on ${update.market_ticker}:`, {
    tradeId: update.trade_id,
    side: update.taker_side,
    count: update.count,
    yesPrice: update.yes_price_dollars,
    noPrice: update.no_price_dollars,
    time: new Date(update.created_time).toISOString(),
  });
}