From 8aef9b9cc2cfdefb6cd442074e63ec9122563e97 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sun, 9 Jul 2023 19:26:45 +0800 Subject: [PATCH] 1 --- server/web3bcspider/tasks/bcrefresh.js | 20 ++++++++------------ 1 file changed, 8 insertions(+), 12 deletions(-) diff --git a/server/web3bcspider/tasks/bcrefresh.js b/server/web3bcspider/tasks/bcrefresh.js index 325d5c6..4c0e9ed 100644 --- a/server/web3bcspider/tasks/bcrefresh.js +++ b/server/web3bcspider/tasks/bcrefresh.js @@ -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); }