This commit is contained in:
aozhiwei 2023-07-03 15:35:33 +08:00
parent fbb9a28159
commit f79cf4ce50

View File

@ -2,7 +2,6 @@ const app = require('j7/app');
const utils = require('j7/utils');
const bcutils = require('j7/bcutils');
const log = require('j7/log');
const event = require('j7/event');
const BaseTask = require('./basetask');
const factory = require('./factory');
const serviceFactory = require('../services/factory');
@ -25,7 +24,7 @@ class BcSpider extends BaseTask {
(
(eventConf) => {
const event = {
'conf': eventConf,
'eventConf': eventConf,
'info': {
'pullCount': 0,
'eventCount': 0,
@ -34,14 +33,16 @@ class BcSpider extends BaseTask {
'currBlock': 0
}
};
const pullBcEventService = this.createPullBcEventService(event);
event['pullBcEventService'] = pullBcEventService;
events.push(event);
});
}
createPullEventService() {
createPullBcEventService(event) {
const bc = serviceFactory.create('BlockChain');
const pullEventService = service.create();
return pullEventService;
const pullBcEventService = serviceFactory.create('PullBcEvent');
return pullBcEventService;
}
}