From 0d84a32b64ccb8bf7a1ac07b166b8fbc1337f1b9 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Sun, 2 Jul 2023 09:08:27 +0800 Subject: [PATCH] 1 --- server/web3bcspider/tasks/bcspider.js | 56 +-------------------------- 1 file changed, 2 insertions(+), 54 deletions(-) diff --git a/server/web3bcspider/tasks/bcspider.js b/server/web3bcspider/tasks/bcspider.js index 83a6305..9e81687 100644 --- a/server/web3bcspider/tasks/bcspider.js +++ b/server/web3bcspider/tasks/bcspider.js @@ -8,18 +8,7 @@ const C = require('../C'); const factory = require('./factory'); const serviceFactory = require('../services/factory'); -class EventCenter extends BaseTask { - - instances = [ - { - 'name': 'HERO', - 'eventName': 'Transfer', - }, - { - 'name': 'WEAPON', - 'eventName': 'Transfer', - }, - ]; +class BcSpider extends BaseTask { async init() { await this.initEventProcess(); @@ -33,49 +22,8 @@ class EventCenter extends BaseTask { instance['toBlock'] = 0; instance['currBlock'] = 0; }; - const allInstances = []; - { - this.instances.forEach((item) => { - allInstances.push(item); - }); - console.log(allInstances); - { - const instanceHash = {}; - allInstances.forEach((item) => { - const key = item['name'] + '.' + item['eventName']; - if (utils.hasKey(instanceHash, key)) { - console.log(key); - throw '!!!!duplicate instance'; - } - instanceHash[key] = item; - }); - } - allInstances.forEach((item) => { - initInstance(item); - }); - { - let count = 0; - const outputLog = async () => { - while (true) { - log.info(++count + '-------------------------------------------------------------'); - allInstances.forEach((item) => { - log.info(utils.jsonEncode(item)); - }); - await utils.sleep(1000 * 10); - } - }; - setTimeout(outputLog, 1000 * 3); - } - } - { - allInstances.forEach(async (item) => { - serviceFactory.create('EventProcess', null) - .init(this.conn, item, async (event) => { - }); - }); - } } } -module.exports = EventCenter; +module.exports = BcSpider;