Exchange Close

'use strict';
import ccxt from '../../js/ccxt.js';
console.log('CCXT Version:', ccxt.version); // eslint-disable-line import/no-named-as-default-member
const orderbooks = {};
let run = true;
async function watchOrderBook(exchange, symbol) {
   while (run) {
       try {
           const orderbook = await exchange.watchOrderBook(symbol);
           orderbooks[symbol] = orderbook;
           console.log(exchange.iso8601(exchange.milliseconds()), orderbook['datetime'], orderbook['nonce'], symbol, orderbook['asks'][0], orderbook['bids'][0]);
       }
       catch (e) {
           console.log(e.constructor.name, e.message);
       }
   }
}
async function stop(exchange) {
   await exchange.sleep(10000);
   run = false;
   await exchange.close();
}
async function main() {
   const exchange = new ccxt.pro.binance();
   await exchange.loadMarkets();
   exchange.verbose = true;
   const symbols = [
       'BTC/USDT',
       'ETH/USDT',
   ];
   stop(exchange).then(() => { });
   await Promise.all(symbols.map((symbol) => watchOrderBook(exchange, symbol)));
   console.log('Sleeping for a moment...');
   await exchange.sleep(10000);
   console.log('Done');
}
main();