diff --git a/server/web3bcspider/metadata/BlockChainDb.js b/server/web3bcspider/metadata/BcEventDb.js similarity index 50% rename from server/web3bcspider/metadata/BlockChainDb.js rename to server/web3bcspider/metadata/BcEventDb.js index f258b04..0f22c4a 100644 --- a/server/web3bcspider/metadata/BlockChainDb.js +++ b/server/web3bcspider/metadata/BcEventDb.js @@ -1,8 +1,8 @@ const utils = require('j7/utils'); const basewrap = require('./basewrap'); -class BlockChainDb extends basewrap.BaseWrap { +class BcEventDb extends basewrap.BaseWrap { } -module.exports = BlockChainDb; +module.exports = BcEventDb; diff --git a/server/web3bcspider/metadata/factory.js b/server/web3bcspider/metadata/factory.js index bff1636..fe6aef2 100644 --- a/server/web3bcspider/metadata/factory.js +++ b/server/web3bcspider/metadata/factory.js @@ -90,9 +90,9 @@ async function init() { '', 'Config' ); - registerMetaClass(configDir + 'blockchaindb_mysql.json', + registerMetaClass(configDir + 'bcevent_mysql.json', '', - 'BlockChainDb' + 'BcEventDb' ); registerMetaClass(configDir + 'web3bcspider.cluster.json', '', @@ -100,8 +100,8 @@ async function init() { ); load(); { - traverseMetaList('BlockChainDb', (dbConf, idx) => { - app.registerDb('BlockChainDb' + idx, dbConf); + traverseMetaList('BcEventDb', (dbConf, idx) => { + app.registerDb('BcEventDb' + idx, dbConf); }); traverseMetaList('Web3BcSpider', (item, idx) => { if (item['instance_id'] == app.getInstanceId()) { diff --git a/server/web3bcspider/services/pull_bcevent.js b/server/web3bcspider/services/pull_bcevent.js index 1e9e109..b3c74a0 100644 --- a/server/web3bcspider/services/pull_bcevent.js +++ b/server/web3bcspider/services/pull_bcevent.js @@ -7,6 +7,7 @@ const BaseService = require('./baseservice'); class PullBcEvent extends BaseService { async init(bc, net, event) { + const {err, conn} = await app.getDbConn('MarketDb0'); this.conn = conn; this.lastBlockNumber = 0; this.bc = bc;