diff --git a/server/web3dbspider/services/dbevent_process.js b/server/web3dbspider/services/dbevent_process.js index 980452c..1afd2df 100644 --- a/server/web3dbspider/services/dbevent_process.js +++ b/server/web3dbspider/services/dbevent_process.js @@ -219,9 +219,6 @@ class DbEventProcess extends BaseService { async process(row) { const logHead = this.getInstanceName() + ' process: '; - if (!this.eventHandle) { - return false; - } while (true) { try { const handle = eventsFactory.createEventHandle(this, this.conn, row); @@ -237,6 +234,10 @@ class DbEventProcess extends BaseService { await utils.sleep(5000 + utils.randRange(500, 1500)); } } + const idx = BigInt(row['idx']); + if (idx > this.lastIdx) { + this.lastIdx = idx; + } return true; }