From 4b7a7309f099b16fa1a5113b95ee1337e1858cee Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 3 Jul 2023 21:07:00 +0800
Subject: [PATCH] 1

---
 .../metadata/{BlockChainDb.js => BcEventDb.js}            | 4 ++--
 server/web3bcspider/metadata/factory.js                   | 8 ++++----
 server/web3bcspider/services/pull_bcevent.js              | 1 +
 3 files changed, 7 insertions(+), 6 deletions(-)
 rename server/web3bcspider/metadata/{BlockChainDb.js => BcEventDb.js} (50%)

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;