From e105392a3cd8388ec3d41efadd90bce265701492 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sun, 9 Jul 2023 18:50:48 +0800 Subject: [PATCH] 1 --- .../services/erc1155_refresher.js | 0 .../web3bcspider/services/erc20_refresher.js | 0 .../web3bcspider/services/erc721_refresher.js | 0 server/web3bcspider/tasks/bcrefresh.js | 33 +++++++++---------- 4 files changed, 16 insertions(+), 17 deletions(-) create mode 100644 server/web3bcspider/services/erc1155_refresher.js create mode 100644 server/web3bcspider/services/erc20_refresher.js create mode 100644 server/web3bcspider/services/erc721_refresher.js diff --git a/server/web3bcspider/services/erc1155_refresher.js b/server/web3bcspider/services/erc1155_refresher.js new file mode 100644 index 0000000..e69de29 diff --git a/server/web3bcspider/services/erc20_refresher.js b/server/web3bcspider/services/erc20_refresher.js new file mode 100644 index 0000000..e69de29 diff --git a/server/web3bcspider/services/erc721_refresher.js b/server/web3bcspider/services/erc721_refresher.js new file mode 100644 index 0000000..e69de29 diff --git a/server/web3bcspider/tasks/bcrefresh.js b/server/web3bcspider/tasks/bcrefresh.js index 607bdf9..0f70f89 100644 --- a/server/web3bcspider/tasks/bcrefresh.js +++ b/server/web3bcspider/tasks/bcrefresh.js @@ -19,24 +19,23 @@ class BcRefresh extends BaseTask { } async initNet(net) { - const events = []; - net['Events'].forEach - ( - (eventConf) => { - const event = { - 'eventConf': eventConf, + { + const events = []; + net['refresh_erc721'].forEach + ( + (conf721) => { + const event = { + 'conf721': conf721, 'progressInfo': { - 'pullCount': 0, - 'eventCount': 0, - 'fromBlock': 0, - 'toBlock': 0, - 'currBlock': 0 + 'confirmedCount': 0, + 'pendingCount': 0, } - }; - events.push(event); - this.createPullBcEventService(net, event); - }); - this.outputProgressInfo(net, events); + }; + events.push(event); + this.createPullBcEventService(net, event); + }); + this.outputErc721ProgressInfo(net, events); + } } createPullBcEventService(net, event) { @@ -48,7 +47,7 @@ class BcRefresh extends BaseTask { return pullBcEventService; } - async outputProgressInfo(net, events) { + async outputErc721ProgressInfo(net, events) { let count = 0; while (true) { log.info('----------------------------------------------------------');