server/game2006web3
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2023-07-03 21:07:00 +08:00
parent 31d080ff28
commit 4b7a7309f0
3 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/web3bcspider/metadata/BlockChainDb.js → server/web3bcspider/metadata/BcEventDb.js
View File

@ -1,8 +1,8 @@
const utils = require('j7/utils'); const utils = require('j7/utils');
const basewrap = require('./basewrap'); const basewrap = require('./basewrap');
class BlockChainDb extends basewrap.BaseWrap { class BcEventDb extends basewrap.BaseWrap {
} }
module.exports = BlockChainDb; module.exports = BcEventDb;

8
server/web3bcspider/metadata/factory.js
View File

@ -90,9 +90,9 @@ async function init() {
'', '',
'Config' 'Config'
); );
registerMetaClass(configDir + 'blockchaindb_mysql.json', registerMetaClass(configDir + 'bcevent_mysql.json',
'', '',
'BlockChainDb' 'BcEventDb'
); );
registerMetaClass(configDir + 'web3bcspider.cluster.json', registerMetaClass(configDir + 'web3bcspider.cluster.json',
'', '',
@ -100,8 +100,8 @@ async function init() {
); );
load(); load();
{ {
traverseMetaList('BlockChainDb', (dbConf, idx) => { traverseMetaList('BcEventDb', (dbConf, idx) => {
app.registerDb('BlockChainDb' + idx, dbConf); app.registerDb('BcEventDb' + idx, dbConf);
}); });
traverseMetaList('Web3BcSpider', (item, idx) => { traverseMetaList('Web3BcSpider', (item, idx) => {
if (item['instance_id'] == app.getInstanceId()) { if (item['instance_id'] == app.getInstanceId()) {

1
server/web3bcspider/services/pull_bcevent.js
View File

@ -7,6 +7,7 @@ const BaseService = require('./baseservice');
class PullBcEvent extends BaseService { class PullBcEvent extends BaseService {
async init(bc, net, event) { async init(bc, net, event) {
const {err, conn} = await app.getDbConn('MarketDb0');
this.conn = conn; this.conn = conn;
this.lastBlockNumber = 0; this.lastBlockNumber = 0;
this.bc = bc; this.bc = bc;