diff --git a/server/web3dbspider/services/pull_dbevent.js b/server/web3dbspider/services/pull_dbevent.js index 38472f4..37d5625 100644 --- a/server/web3dbspider/services/pull_dbevent.js +++ b/server/web3dbspider/services/pull_dbevent.js @@ -19,6 +19,17 @@ class PullDbEvent extends BaseService { } PullDbEvent.#maxIdx = maxIdx; } + async () => { + while (true) { + const {err, maxIdx} = await conn.getMaxIdx(''); + if (!err) { + PullDbEvent.#maxIdx = maxIdx; + await utils.sleep(500 + utils.randRange(500, 1500)); + } else { + await utils.sleep(5000 + utils.randRange(500, 1500)); + } + } + }(); } async init(net, event) {