diff --git a/server/web3bcspider/tasks/bcrefresh.js b/server/web3bcspider/tasks/bcrefresh.js index 0f70f89..325d5c6 100644 --- a/server/web3bcspider/tasks/bcrefresh.js +++ b/server/web3bcspider/tasks/bcrefresh.js @@ -20,34 +20,86 @@ class BcRefresh extends BaseTask { async initNet(net) { { - const events = []; + const refreshers = []; net['refresh_erc721'].forEach ( - (conf721) => { - const event = { - 'conf721': conf721, + (conf) => { + const refresher = { + 'conf': conf, 'progressInfo': { - 'confirmedCount': 0, + 'refreshedCount': 0, 'pendingCount': 0, } }; - events.push(event); - this.createPullBcEventService(net, event); + refreshers.push(refresher); + this.createErc721Refresher(net, refresher); }); - this.outputErc721ProgressInfo(net, events); + this.outputProgressInfo(net, refreshers); + } + { + const refreshers = []; + net['refresh_erc1155'].forEach + ( + (conf) => { + const refresher = { + 'conf': conf, + 'progressInfo': { + 'refreshedCount': 0, + 'pendingCount': 0, + } + }; + refreshers.push(refresher); + this.createErc1155Refresher(net, refresher); + }); + this.outputProgressInfo(net, refreshers); + } + { + const refreshers = []; + net['refresh_erc20'].forEach + ( + (conf) => { + const refresher = { + 'conf': conf, + 'progressInfo': { + 'refreshedCount': 0, + 'pendingCount': 0, + } + }; + refreshers.push(refresher); + this.createErc20Refresher(net, refresher); + }); + this.outputProgressInfo(net, refreshers); } } - createPullBcEventService(net, event) { + createErc721Refresher(net, refresher) { const bc = serviceFactory.create('BlockChain'); bc.init(net['net_id']); - const pullBcEventService = serviceFactory.create('PullBcEvent'); - event['pullBcEventService'] = pullBcEventService; - pullBcEventService.init(bc, net, event); - return pullBcEventService; + const refresherService = serviceFactory.create('Erc721Refresher'); + event['refresherService'] = refresherService; + refresherService.init(bc, net, event); + return refresherService; } - async outputErc721ProgressInfo(net, events) { + createErc1155Refresher(net, refresher) { + const bc = serviceFactory.create('BlockChain'); + bc.init(net['net_id']); + const refresherService = serviceFactory.create('Erc1155Refresher'); + event['refresherService'] = refresherService; + refresherService.init(bc, net, event); + return refresherService; + } + + createErc20Refresher(net, refresher) { + const bc = serviceFactory.create('BlockChain'); + bc.init(net['net_id']); + const refresherService = serviceFactory.create('Erc20Refresher'); + event['refresherService'] = refresherService; + refresherService.init(bc, net, event); + return refresherService; + } + + async outputProgressInfo(net, events) { let count = 0; while (true) { log.info('----------------------------------------------------------');