Apex Watch

// AUTO-TRANSPILE //

'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 loop (exchange, symbol) {
   while (true) { // eslint-disable-line no-constant-condition
       try {
           const ticker = await exchange.watchTicker (symbol);
           console.log (new Date () + ' ' + exchange.id + ' ' + symbol);
           console.log (ticker);
           await exchange.sleep (1000);
       } catch (e) {
           console.log (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 () {
   const exchange = new ccxt.pro.apex ({ // eslint-disable-line import/no-named-as-default-member
       'apiKey': 'your api Key',
       'secret': 'your api secret',
       'walletAddress': 'your eth address',
       'options': {
           'accountId': 'your account id',
           'passphrase': 'your api passphrase',
           'seeds': 'your zklink omni seed',
           'brokerId': '',
       },
   });
   exchange.setSandboxMode (true);
   if (exchange.has['watchTicker']) {
       await exchange.loadMarkets ();
       const targetSymbols = [ 'BTC-USDT', 'ETH-USDT' ];
       for (let i = 0; i < targetSymbols.length; i++) {
           const symbol = targetSymbols[i];
           await loop (exchange, symbol);
       }
   } else {
       console.log (exchange.id + ' does not support watchTicker yet');
   }
}

main ();