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: any) {
           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 ();