Crypto Price API

📊 Crypto Price API is a lightweight suite of API provided by Bitquery to fetch and stream live cryptocurrency prices, historical data, and token analytics across multiple blockchains, using its Trading API Endpoints.

---

What is Crypto Price API?

A Crypto Price API allows developers to access real-time and historical cryptocurrency prices programmatically. Bitquery’s Crypto Price API provides data for tokens across chains like Ethereum, Solana, BSC, Polygon, and Tron — all through simple GraphQL queries or WebSocket streams.

---

🚀 Crypto Price API Features

• Get the latest token price in USD
• Stream live token price updates
• Get price change percentage for ROI calculations
• Get token volume data with configurable time intervals
• Stream live token volume updates
• Get volume data for multiple tokens simultaneously
• Stream live volume updates for multiple tokens simultaneously
• Convert token addresses into currencyId for queries
• Extendable query SDK workflow for adding new APIs
• Open source & developer-friendly

List of Chains Supported by Crypto Price API

• Ethereum
• BSC
• Solana
• Tron
• Polygon
• Base

How Does

---

📦 Installation

npm install bitquery-crypto-price

---

Access Token

Get Your Bitquery Access Token here

---

⚡ Quick Start for Crypto Price API

1. Get the latest price for a token

const { getTokenPrice } = require("bitquery-crypto-price");

(async () => {
  const data = await getTokenPrice("<Access Token>", "TOKEN ADDRESS");
  console.log(data);
})();

---

2. Stream live token price updates

const { getTokenPriceStream } = require("bitquery-crypto-price");

const ws = getTokenPriceStream("<Access Token>", "TOKEN ADDRESS", {
  autoCloseMs: 15000, // optional: auto-close after 15 seconds
  onData: (data) => {
    console.log("Live BTC Price:", JSON.stringify(data, null, 2));
  },
  onError: (err) => {
    console.error("Stream error:", err);
  },
});

// ws.close() // manually close if needed

---

3. Get 5-min price change of a token

const { getPriceChange } = require("bitquery-crypto-price");

(async () => {
  const data = await getPriceChange("<Access Token>", "CURRENCY_ID");
  console.log( JSON.stringify(data, null, 2));
})();

---

4. Stream live price change updates

const { getPriceChangeStream } = require("bitquery-crypto-price");

const ws = getPriceChangeStream("<Access Token>", "CURRENCY_ID", {
  autoCloseMs: 30000, // optional: auto-close after 30 seconds
  onData: (data) => {
    console.log("Live price changes:", JSON.stringify(data, null, 2));
  },
  onError: (err) => {
    console.error("Stream error:", err);
  },
});

// ws.close() // manually close if needed

---

5. Get token volume data

const { getTokenVolume } = require("bitquery-crypto-price");

(async () => {
  const data = await getTokenVolume("<Access Token>", "TOKEN ADDRESS", 3600); // 3600 = 1 hour interval
  console.log(JSON.stringify(data, null, 2));
})();

---

6. Stream live token volume updates

const { getTokenVolumeStream } = require("bitquery-crypto-price");

const ws = getTokenVolumeStream("<Access Token>", "TOKEN ADDRESS", {
  interval: 3600, // optional: time interval in seconds (default: 3600)
  autoCloseMs: 30000, // optional: auto-close after 30 seconds
  onData: (data) => {
    console.log("Live token volume:", JSON.stringify(data, null, 2));
  },
  onError: (err) => {
    console.error("Stream error:", err);
  },
});

// ws.close() // manually close if needed

---

7. Get volume data for multiple tokens

const { getMultipleTokenVolume } = require("bitquery-crypto-price");

(async () => {
  const tokenAddresses = [
    "0x4d15a3a2286d883af0aa1b3f21367843fac63e07", // WETH
    "0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48", // USDC
    "0xdac17f958d2ee523a2206206994597c13d831ec7"  // USDT
  ];
  const data = await getMultipleTokenVolume("<Access Token>", tokenAddresses, 3600); // 3600 = 1 hour interval
  console.log(JSON.stringify(data, null, 2));
})();

---

8. Stream live volume updates for multiple tokens

const { getMultipleTokenVolumeStream } = require("bitquery-crypto-price");

const tokenAddresses = [
  "0x4d15a3a2286d883af0aa1b3f21367843fac63e07", // WETH
  "0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48", // USDC
  "0xdac17f958d2ee523a2206206994597c13d831ec7"  // USDT
];

const ws = getMultipleTokenVolumeStream("<Access Token>", tokenAddresses, {
  interval: 3600, // optional: time interval in seconds (default: 3600)
  autoCloseMs: 30000, // optional: auto-close after 30 seconds
  onData: (data) => {
    console.log("Live multiple token volumes:", JSON.stringify(data, null, 2));
  },
  onError: (err) => {
    console.error("Stream error:", err);
  },
});

// ws.close() // manually close if needed

---

🛠️ Available Functions

Function	Description
getCurrencyId	Get currencyId from a token address (required for queries)
getTokenPrice	Fetch the latest token price (point-in-time query)
getTokenPriceStream	Subscribe to real-time token price updates (WebSocket stream)
getPriceChange	Get top tokens by price change percentage (point-in-time query)
getPriceChangeStream	Subscribe to real-time price change updates (WebSocket stream)
getTokenVolume	Fetch token volume data (point-in-time query)
getTokenVolumeStream	Subscribe to real-time token volume updates (WebSocket stream)
getMultipleTokenVolume	Fetch volume data for multiple tokens (point-in-time query)
getMultipleTokenVolumeStream	Subscribe to real-time volume updates for multiple tokens (WebSocket stream)

---

💰 Subscription/Stream Pricing

When using the stream functions (*Stream functions), you are charged based on simultaneous active streams. We don't count based on number of tokens monitored.

• Billing Model: Each active stream subscription is charged
• Separate Subscriptions: Each stream function call counts as a separate subscription:
  • getTokenPriceStream() = 1 subscription
  • getMultipleTokenVolume() = 1 subscription
  • getTokenVolumeStream() = 1 subscription
  • Running multiple streams simultaneously = multiple subscriptions

Important Notes:

• Billing is based on number of subscriptions and duration, not query complexity or data volume
• Check your points usage and manage subscriptions at your Bitquery Account Dashboard

For detailed pricing information, contact sales by filling the form on the Bitquery website

🧩 Extending the Crypto Price API (Adding New Queries and Streams)

To add support for more Trading APIs (e.g., OHLC candles, trades, liquidity pools):

Workflow

1. Create a new query file in queries/ with naming convention: <result-returned>-query.js Example: sample-query.js

   const sampleQuery = (currencyId) => {
     return `
     <Your GraphQL Query>
     `;
   };
   
   const sampleStream = (currencyId) => {
     return `
     <Your GraphQL Subscription>
     `;
   };
   
   module.exports = { sampleQuery, sampleStream };

2. Import into index.js:

   const { sampleQuery, sampleStream } = require("./queries/sample-query.js");

3. Wrap with a function for queries or streams in index.js:

   const getSample = async (token, tokenId) => {
     const query = sampleQuery(tokenId);
     const data = await queryRunner(query, token);
     return data;
   };
   
   const getSample = (token, tokenId, options = {}) => {
     const subscription = sampleStream(tokenId);
     return streamRunner(subscription, token, options);
   };

That’s it! Your new query is available to all SDK users after PR merge and release.

---

🤝 Contributing

1. Fork this repo https://github.com/bitquery/crypto-price-api
2. Create a feature branch
3. Follow the workflow for adding queries
4. Submit a PR 🎉
5. Make sure to follow the Contribution Guidelines

---

📜 License

MIT License. Free to use and modify.

---

Contact

Contact our team via Telegram for any support. Fill out this form, if you are interested in purchasing any product or service from Bitquery.