Fetch Ohlcv Many Exchanges Continuosly

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

// AUTO-TRANSPILE //

// fetch and handle constinuosly
async function fetchOHLCVContinuously (exchange, symbol) {
   while (true) {
       try {
           const ohlcv = await exchange.fetchOHLCV (symbol);
           const ohlcvLength = ohlcv.length;
           console.log ('Fetched ', exchange.id, ' - ', symbol, ' candles. last candle: ', ohlcv[ohlcvLength - 1]);
       } catch (e) {
           console.log (e);
           break;
       }
   }
}

// start exchanges and fetch OHLCV loop
async function startExchange (exchangeName, symbols) {
   const ex = new ccxt[exchangeName] ({});
   const promises = [];
   for (let i = 0; i < symbols.length; i++) {
       const symbol = symbols[i];
       promises.push (fetchOHLCVContinuously (ex, symbol));
   }
   await Promise.all (promises);
   await ex.close ();
}

// main function
async function example () {
   const exchanges = [ 'binance', 'okx', 'kraken' ];
   const symbols = [ 'BTC/USDT', 'ETH/USDT' ];
   const promises = [];
   for (let i = 0; i < exchanges.length; i++) {
       const exchangeName = exchanges[i];
       promises.push (startExchange (exchangeName, symbols));
   }
   await Promise.all (promises);
}


await example ();