Watch New Trades Only

'use strict';

import ccxt from '../../js/ccxt.js';

console.log ('CCXT Version:', ccxt.version); // eslint-disable-line import/no-named-as-default-member

async function watchExchange (exchangeId, symbol) {
   const exchange = new ccxt.pro[exchangeId] ({ // eslint-disable-line import/no-named-as-default-member
       'newUpdates': true,
   });

   await exchange.loadMarkets ();

   // exchange.verbose = true // uncomment for debugging purposes if necessary

   while (true) { // eslint-disable-line no-constant-condition
       try {
           const trades = await exchange.watchTrades (symbol);
           for (let i = 0; i < trades.length; i++) {
               const trade = trades[i];
               console.log (exchange.iso8601 (exchange.milliseconds ()), exchange.id, trade['symbol'], trade['id'], trade['datetime'], trade['price'], trade['amount']);
           }
       } catch (e) {
           console.log (symbol, e);
       }
   }
}

async function main () {
   const streams = {
       'binance': 'BTC/USDT',
       'okex': 'BTC/USDT',
       'kraken': 'BTC/USD',
   };

   const values = Object.entries (streams);
   const promises = values.map (([ exchangeId, symbol ]) => watchExchange (exchangeId, symbol));
   await Promise.all (promises);
}

main ();