1
This commit is contained in:
parent
963fd8a58a
commit
e105392a3c
0
server/web3bcspider/services/erc1155_refresher.js
Normal file
0
server/web3bcspider/services/erc1155_refresher.js
Normal file
0
server/web3bcspider/services/erc20_refresher.js
Normal file
0
server/web3bcspider/services/erc20_refresher.js
Normal file
0
server/web3bcspider/services/erc721_refresher.js
Normal file
0
server/web3bcspider/services/erc721_refresher.js
Normal file
@ -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('----------------------------------------------------------');
|
||||
|
Loading…
x
Reference in New Issue
Block a user