diff --git a/server/web3dbspider/metadata/Events.js b/server/web3dbspider/metadata/Events.js new file mode 100644 index 0000000..704c50f --- /dev/null +++ b/server/web3dbspider/metadata/Events.js @@ -0,0 +1,8 @@ +const utils = require('j7/utils'); +const basewrap = require('./basewrap'); + +class Events extends basewrap.BaseWrap { + +} + +module.exports = Events; diff --git a/server/web3dbspider/metadata/factory.js b/server/web3dbspider/metadata/factory.js index a0684d3..fb7322f 100644 --- a/server/web3dbspider/metadata/factory.js +++ b/server/web3dbspider/metadata/factory.js @@ -103,6 +103,10 @@ async function init() { '', 'Web3DbSpider' ); + registerMetaClass(configDir + 'events.json', + 'net_id', + 'Events' + ); load(); { traverseMetaList('BcEventDb', (dbConf, idx) => { @@ -122,6 +126,7 @@ async function init() { 'netId': netId, 'Web3': utils.readJsonFromFile(netDir + 'web3.json'), 'Contract': utils.readJsonFromFile(netDir + 'contract.json'), + 'Events': getMetaByKey('Events', netId)['events'] }; netObj.getContractAddressByName = (name) => { let address = ''; diff --git a/server/web3dbspider/services/pull_dbevent.js b/server/web3dbspider/services/pull_dbevent.js index 37d5625..7d5a8f2 100644 --- a/server/web3dbspider/services/pull_dbevent.js +++ b/server/web3dbspider/services/pull_dbevent.js @@ -5,6 +5,7 @@ const log = require('j7/log'); const BaseService = require('./baseservice'); const LIMIT_COUNT = 100; +const BCEVENT_TABLE_NAME = 't_blockchain_event'; class PullDbEvent extends BaseService { @@ -13,15 +14,15 @@ class PullDbEvent extends BaseService { static async staticInit() { const {err, conn} = await app.getDbConn('BcEventDb0'); { - const {err, maxIdx} = await conn.getMaxIdx(''); + const {err, maxIdx} = await conn.getMaxIdx(BCEVENT_TABLE_NAME); if (err) { throw 'PullDbEvent error:' + err; } PullDbEvent.#maxIdx = maxIdx; } - async () => { + const updateMaxIdxFunc = async () => { while (true) { - const {err, maxIdx} = await conn.getMaxIdx(''); + const {err, maxIdx} = await conn.getMaxIdx('BCEVENT_TABLE_NAME'); if (!err) { PullDbEvent.#maxIdx = maxIdx; await utils.sleep(500 + utils.randRange(500, 1500)); @@ -29,7 +30,8 @@ class PullDbEvent extends BaseService { await utils.sleep(5000 + utils.randRange(500, 1500)); } } - }(); + }; + updateMaxIdxFunc(); } async init(net, event) {