diff --git a/server/web3dbspider/services/dbevent_process.js b/server/web3dbspider/services/dbevent_process.js index b151b3e..8849147 100644 --- a/server/web3dbspider/services/dbevent_process.js +++ b/server/web3dbspider/services/dbevent_process.js @@ -216,7 +216,7 @@ class DbEventProcess extends BaseService { if (!this.eventHandle) { return false; } - const handle = eventsFactory.createEventHandle(this); + const handle = eventsFactory.createEventHandle(this, this.conn, row); await handle.start(); return true; } diff --git a/server/web3dbspider/services/events/factory.js b/server/web3dbspider/services/events/factory.js index 7fcd9ea..90734eb 100644 --- a/server/web3dbspider/services/events/factory.js +++ b/server/web3dbspider/services/events/factory.js @@ -33,9 +33,9 @@ function getEventHandle(eventProc) { return utils.hasKey(events, clsName) ? events[clsName] : null; } -function createEventHandle(eventProc) { +function createEventHandle(eventProc, conn, eventDb) { const clsName = eventProc.getContractName() + '.' + eventProc.getEventName(); - return new events[clsName]['class'](); + return new events[clsName]['class'](eventProc, conn, eventDb); } exports.init = init;