search

trasherdk / ccxws

WebSocket client for 38 cryptocurrency exchanges
MIT License
0 stars 0 forks source link

Snippet: Kraken Subscription #4

Open trasherdk opened 2 years ago

trasherdk commented 2 years ago 
import ccxt from 'ccxt';
import { KrakenClient } from 'ccxws';

async function processTradeData (trade) {
  console.log(trade)
}

async function main (exchange = new ccxt.kraken()) {
  const ws = new KrakenClient();
  ws.on('trade', (trade) => processTradeData(trade));
  const krakenMarkets = (await exchange.fetchMarkets()).map(x => ({ id: x.id, base: x.base, quote: x.quote }));
  for (const market of krakenMarkets) {
    ws.subscribeTrades(market)
  }
}

main();
trasherdk commented 2 years ago

Limit to a specific token:

import ccxt from 'ccxt'
import { KrakenClient } from 'ccxws'

async function processTradeData (trade) {
  console.log(trade)
}

async function main (ticker, exchange = new ccxt.kraken()) {
  const ws = new KrakenClient()
  ws.on('trade', (trade) => processTradeData(trade))
  const krakenMarkets = (await exchange.fetchMarkets())
    .filter(x => x.base === ticker)
    .map(x => ({ id: x.id, base: x.base, quote: x.quote }))
  for (const market of krakenMarkets) {
    ws.subscribeTrades(market)
  }
}

main('XMR')