Connect your first market-data stream

import WebSocket from "ws";
import { createHash, createHmac } from "node:crypto";

const key = process.env.BRAVADO_API_KEY;
const secret = process.env.BRAVADO_API_SECRET;
if (!key || !secret) throw new Error("Set BRAVADO_API_KEY and BRAVADO_API_SECRET");

const path = "/stream/polymarket/partner/trades";
const timestamp = String(Date.now());
const bodyHash = createHash("sha256").update("").digest("hex");
const payload = [timestamp, "GET", path, bodyHash].join("\n");
const signature = createHmac("sha256", secret).update(payload).digest("hex");
const ws = new WebSocket(`wss://partner-api.bravadotrade.com${path}`, {
  headers: {
    "X-BRAVADO-API-KEY": key,
    "X-BRAVADO-TIMESTAMP": timestamp,
    "X-BRAVADO-SIGNATURE": signature,
  },
});

ws.on("message", data => {
  const frame = JSON.parse(data.toString());
  if (frame.type === "snapshot") {
    console.log("Recent trades:", frame.trades.length);
  } else if (frame.type === "trade") {
    const trade = frame.trade;
    console.log(trade.side, trade.size, trade.price, trade.assetId);
  } else if (frame.type === "error") {
    console.error(frame.code, frame.message);
  }
});
ws.on("error", error => console.error(error.message));
ws.on("close", (code, reason) => console.log("Closed:", code, reason.toString()));

// End this sample after 30 seconds to bound usage.
const stop = setTimeout(() => ws.close(), 30_000);
ws.once("close", () => clearTimeout(stop));