This commit is contained in:
aozhiwei 2023-07-09 19:26:45 +08:00
parent 89ce413a64
commit 8aef9b9cc2

View File

@ -99,23 +99,19 @@ class BcRefresh extends BaseTask {
return refresherService;
}
async outputProgressInfo(net, events) {
async outputProgressInfo(net, refreshers) {
let count = 0;
while (true) {
log.info('----------------------------------------------------------');
events.forEach
refreshers.forEach
(
(event) => {
const eventConf = event['eventConf'];
const progInfo = event['progressInfo'];
(refresher) => {
const conf = refresher['conf'];
const progInfo = refresher['progressInfo'];
const logObj = 'net_id: ' + net['net_id'] + ' ' +
eventConf['contract_name'] + '.' +
eventConf['event_name'] + ' ' +
' pullCount:' + progInfo['pullCount'] +
' eventCount:' + progInfo['eventCount'] +
' fromBlock:' + progInfo['fromBlock'] +
' toBlock:' + progInfo['toBlock'] +
' currBlock:' + progInfo['currBlock']
conf['contract_name'] + '.' +
' refreshedCount:' + progInfo['refreshedCount'] +
' pullCount:' + progInfo['pullCount']
;
log.info(logObj);
}