Market Price Updates

ws.send() wss://api.synthetix.io/v1/ws/subscriptions

{
  "id": "sub-1",
  "method": "subscribe",
  "params": {
    "type": "marketPrices",
    "symbol": "BTC-USDT"
  }
}

{
  "id": "sub-all",
  "method": "subscribe",
  "params": {
    "type": "marketPrices",
    "symbol": "ALL"
  }
}

{
  "id": "sub-all",
  "method": "subscribe",
  "params": {
    "type": "marketPrices"
  }
}

{
  "method": "market_price_update",
  "data": {
    "symbol": "BTC-USDT",
    "markPrice": "50125.50",
    "indexPrice": "50123.75",
    "lastPrice": "50130.00",
    "bestBid": "50124.00",
    "bestAsk": "50127.00",
    "volume24h": "45678.25",
    "fundingRate": "0.0001",
    "openInterest": "12500.75",
    "timestamp": 1704067200000,
    // Additional fields may be included:
    "nextFundingTime": 1704096000000,
    "change24h": "2.5",
    "changePercent24h": "5.23",
    "high24h": "51000.00",
    "low24h": "49200.00",
    "vwap24h": "50234.67"
  }
}

{
  "method": "market_price_update",
  "data": {
    "symbol": "ETH-USDT",
    "fundingRate": "0.00015",
    "nextFundingRate": "0.00012",
    "nextFundingTime": 1704096000000,
    "fundingInterval": 28800000,
    "timestamp": 1704067300000
  }
}

{
  "method": "market_price_update",
  "data": {
    "symbol": "SOL-USDT",
    "markPrice": "125.50",
    "indexPrice": "125.48",
    "lastPrice": "125.55",
    "bestBid": "125.49",
    "bestAsk": "125.51",
    "prevDayPrice": "124.80",
    "volume24h": "8934.50",
    "quoteVolume24h": "1120345.25",
    "fundingRate": "0.00015",
    "openInterest": "234567.50",
    "timestamp": 1704067400000
  }
}

// Subscribe to market price updates
const subscription = {
  id: "sub-1",
  method: "subscribe",
  params: {
    type: "marketPrices",
    symbol: "BTC-USDT"
  }
};
 
ws.send(JSON.stringify(subscription));
 
// Handle market price update messages
ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
 
  if (message.method === "market_price_update") {
    const { symbol, markPrice, fundingRate, changePercent24h } = message.data;
    console.log(`${symbol}: ${markPrice} (${changePercent24h}%) FR: ${fundingRate}`);
 
    // Update UI with new price data
    updatePriceDisplay(message.data);
  }
};
 
function updatePriceDisplay(priceData) {
  const {
    symbol,
    markPrice,
    bestBid,
    bestAsk,
    changePercent24h,
    volume24h,
    fundingRate
  } = priceData;
 
  // Update price ticker
  document.getElementById(`price-${symbol}`).textContent = `${markPrice}`;
  document.getElementById(`change-${symbol}`).textContent = `${changePercent24h}%`;
  document.getElementById(`volume-${symbol}`).textContent = volume24h;
  document.getElementById(`funding-${symbol}`).textContent = `${fundingRate}%`;
 
  // Update bid/ask spread
  const spread = (parseFloat(bestAsk) - parseFloat(bestBid)).toFixed(2);
  document.getElementById(`spread-${symbol}`).textContent = `${spread}`;
}

// Subscribe to all markets
const allMarketsSubscription = {
  id: "sub-all",
  method: "subscribe",
  params: {
    type: "marketPrices",
    symbol: "ALL"
  }
};
 
ws.send(JSON.stringify(allMarketsSubscription));
 
// Handle updates for multiple markets
const marketPrices = new Map();
 
ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
 
  if (message.method === "market_price_update") {
    const { symbol } = message.data;
 
    // Store latest price data
    marketPrices.set(symbol, message.data);
 
    // Update specific market display
    updateMarketRow(symbol, message.data);
  }
};
 
function updateMarketRow(symbol, data) {
  const row = document.getElementById(`market-${symbol}`);
  if (row) {
    row.querySelector('.price').textContent = `${data.markPrice}`;
    row.querySelector('.change').textContent = `${data.changePercent24h}%`;
    row.querySelector('.volume').textContent = data.volume24h;
 
    // Update row styling based on price change
    const changePercent = parseFloat(data.changePercent24h);
    row.className = changePercent >= 0 ? 'positive' : 'negative';
  }
}

class PriceAlertManager {
  constructor() {
    this.alerts = new Map(); // symbol -> array of alerts
  }
 
  addAlert(symbol, targetPrice, direction, callback) {
    if (!this.alerts.has(symbol)) {
      this.alerts.set(symbol, []);
    }
 
    this.alerts.get(symbol).push({
      targetPrice,
      direction, // 'above' or 'below'
      callback,
      id: Date.now()
    });
  }
 
  checkAlerts(symbol, currentPrice) {
    const alerts = this.alerts.get(symbol);
    if (!alerts) return;
 
    const triggeredAlerts = [];
    const remainingAlerts = [];
 
    alerts.forEach(alert => {
      const price = parseFloat(currentPrice);
      const target = parseFloat(alert.targetPrice);
 
      const triggered =
        (alert.direction === 'above' && price >= target) ||
        (alert.direction === 'below' && price <= target);
 
      if (triggered) {
        triggeredAlerts.push(alert);
        alert.callback(symbol, price, alert);
      } else {
        remainingAlerts.push(alert);
      }
    });
 
    // Remove triggered alerts
    this.alerts.set(symbol, remainingAlerts);
  }
}
 
const alertManager = new PriceAlertManager();
 
// Add price alert
alertManager.addAlert('BTC-USDT', '52000.00', 'above', (symbol, price, alert) => {
  console.log(`🚨 ALERT: ${symbol} reached ${price} (target: ${alert.targetPrice})`);
  showNotification(`${symbol} price alert triggered at ${price}`);
});
 
// Check alerts on price updates
ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
 
  if (message.method === "market_price_update") {
    const { symbol, markPrice } = message.data;
    alertManager.checkAlerts(symbol, markPrice);
  }
};

{
  "id": "sub-1",
  "status": 400,
  "result": null,
  "error": {
    "code": 400,
    "message": "Invalid symbol: XYZ-USDT not supported"
  }
}