Build Ohlcv Many Symbols

'use strict';
import asTable from 'as-table';
import ccxt from '../../js/ccxt.js';
console.log('CCXT Version:', ccxt.version);
asTable.configure({ 'delimiter': ' | ' });
async function loop(exchange, symbol, timeframe, completeCandlesOnly = false) {
    const durationInSeconds = exchange.parseTimeframe(timeframe);
    const durationInMs = durationInSeconds * 1000;
    while (true) {
        try {
            const trades = await exchange.watchTrades(symbol);
            if (trades.length > 0) {
                const currentMinute = Math.floor(exchange.milliseconds() / durationInMs);
                let ohlcvc = exchange.buildOHLCVC(trades, timeframe);
                if (completeCandlesOnly) {
                    ohlcvc = ohlcvc.filter((candle) => Math.floor(candle[0] / durationInMs) < currentMinute);
                }
                if (ohlcvc.length > 0) {
                    console.log('Symbol:', symbol, 'timeframe:', timeframe);
                    console.log('-----------------------------------------------------------');
                    console.log(asTable(ohlcvc));
                    console.log('-----------------------------------------------------------');
                }
            }
        }
        catch (e) {
            console.log(symbol, e);
            // do nothing and retry on next loop iteration
            // throw e // uncomment to break all loops in case of an error in any one of them
            // break // you can also break just this one loop if it fails
        }
    }
}
async function main() {
    // select the exchange
    const exchange = new ccxt.pro.okx();
    if (exchange.has['watchTrades']) {
        await exchange.loadMarkets();
        // Change this value accordingly
        const timeframe = '1m';
        // arbitrary n symbols
        const selectedSymbols = ['BTC/USDT', 'LTC/USDT']; // or random 3 pairs: exchange.symbols.slice(0, 3);
        console.log(selectedSymbols);
        // Use this variable to choose if only complete candles ;
        // should be considered
        const completeCandlesOnly = true;
        await Promise.all(selectedSymbols.map((symbol) => loop(exchange, symbol, timeframe, completeCandlesOnly)));
    }
    else {
        console.log(exchange.id, 'does not support watchTrades yet');
    }
}
main();