Price Feed Stream

{
  "type": "feed",
  "authorization": "YOUR_API_KEY",
  "kind": "asset_ids",
  "asset_ids": [123, 456],
  "quote_id": 456
}

{
  "type": "feed",
  "authorization": "YOUR_API_KEY",
  "kind": "address",
  "tokens": [
    {
      "blockchain": "solana",
      "address": "So11111111111111111111111111111111111111112"
    },
    {
      "blockchain": "evm:1",
      "address": "0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2"
    }
  ],
  "quote": {
    "blockchain": "solana",
    "address": "So11111111111111111111111111111111111111112"
  }
}

{
  "type": "feed",
  "authorization": "YOUR_API_KEY"
}

{
  timestamp: number;           // Unix timestamp in milliseconds
  price: number;              // Current asset price
  marketDepthUSDUp: number;   // Market depth for upward price movement
  marketDepthUSDDown: number; // Market depth for downward price movement
  volume24h: number;          // 24-hour trading volume
  baseSymbol: string;         // Base asset symbol
  quoteSymbol: string;        // Quote asset symbol (e.g., "USD")
  extra: {
    priceUSD: number;         // Price in USD
    quoteAssetPrice: number;  // Quote asset price
    blockNumber: string;      // Latest block number
  }
}

{
  "timestamp": 1733173907000,
  "price": 3881.328639607063,
  "marketDepthUSDUp": 418639.4559697787,
  "marketDepthUSDDown": 623414.4447679224,
  "volume24h": 874713.342519723,
  "baseSymbol": "SWETH",
  "quoteSymbol": "USD",
  "extra": {
    "priceUSD": 3881.328639607063,
    "quoteAssetPrice": 1,
    "blockNumber": "21317425"
  }
}

curl --request GET \
  --url "https://api.mobula.io/api/1/feed/create?assetId=<assetId>&quoteId=<quoteId>" \
  --header "Authorization: YOUR_API_KEY" \
  --header "Content-Type: application/json"

const socket = new WebSocket("wss://production-feed.mobula.io");

socket.addEventListener("open", () => {
  // V2 subscription by asset IDs
  socket.send(JSON.stringify({
    type: "feed",
    authorization: "YOUR_API_KEY",
    kind: "asset_ids",
    asset_ids: [123, 456],
    quote_id: 456
  }));
});

socket.addEventListener("message", (event) => {
  const data = JSON.parse(event.data);
  
  // Process price update
  console.log(`${data.baseSymbol}/${data.quoteSymbol}: $${data.price}`);
  console.log(`24h Volume: $${data.volume24h}`);
});

socket.addEventListener("error", (error) => {
  console.error("WebSocket error:", error);
});

socket.addEventListener("close", () => {
  console.log("WebSocket connection closed");
});

{"event":"ping"}

{
  "type": "unsubscribe",
  "authorization": "YOUR_API_KEY",
  "payload": {
    "type": "feed",
    "asset_ids": [123, 456]
  }
}

{
  "type": "unsubscribe",
  "authorization": "YOUR_API_KEY",
  "payload": {
    "type": "feed",
    "tokens": [
      {
        "blockchain": "solana",
        "address": "So11111111111111111111111111111111111111112"
      }
    ]
  }
}