Quote Stream

// 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 arg to new WebSocket().
const WS_URL = "wss://dev-quote-api.dflow.net/quote-stream";

const SOL = "So11111111111111111111111111111111111111112";
const USDC = "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v";

const ws = new WebSocket(WS_URL);

ws.onopen = () => {
  ws.send(JSON.stringify({ op: "subscribe", base_mint: SOL, quote_mint: USDC }));
};

ws.onmessage = (event) => {
  const frame = JSON.parse(event.data);
  for (const u of frame.updates ?? []) {
    if (u.e) {
      console.log(`${u.sb} / ${u.sq}: ${u.e}`);
      continue;
    }
    console.log(`slot ${frame.u}  bid ${u.b}  ask ${u.a}`);
  }
};

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

interface QuoteUpdate {
  sb: string; // base mint
  sq: string; // quote mint
  b?: string; // bid, quote per base
  a?: string; // ask, quote per base
  B?: string; // bid size, quote-denominated
  A?: string; // ask size, quote-denominated
  e?: string; // per-pair error code
}

interface QuoteFrame {
  u: number; // slot
  ts: number; // unix seconds
  updates?: QuoteUpdate[];
  subscribe?: { sb: string; sq: string; auto: boolean }[];
  unsubscribe?: { sb: string; sq: string; auto: boolean }[];
}