交易代码更新、重构数据库结构

.vscode/launch.json

@@ -20,6 +20,9 @@
       "env": {
         "NODE_ENV": "test"
       },
+      "outFiles": [
+        "${workspaceFolder}/dist/**/*.js"
+      ],
       "internalConsoleOptions": "openOnSessionStart"
     },
     {

package.json

@@ -21,6 +21,7 @@
     "db:clie": "node dist/test/pouchdb/clie.js",
     "test": "cross-env NODE_ENV=test mocha dist/**/*.test.js --timeout 5000 --require intelli-espower-loader",
     "test:m": "cross-env NODE_ENV=test mocha dist/**/trading.test.js --timeout 5000 --require intelli-espower-loader",
+    "test:db": "cross-env NODE_ENV=test mocha dist/**/storage.test.js --timeout 5000 --require intelli-espower-loader",
     "prepare": "npm run rm && tsc -p tsconfig.json"
   },
   "dependencies": {

src/lib/arbitrage.ts

@@ -58,7 +58,7 @@ export class TriangularArbitrage extends Event {
     }
   }
 
-  private async initExchange(exchangeId: types.ExchangeId) {
+  public async initExchange(exchangeId: types.ExchangeId) {
     const timer = Helper.getTimer();
     logger.debug('初始化交易所[启动]');
     try {

src/lib/common/helper.ts

@@ -180,6 +180,7 @@ export class Helper {
     timer.start();
     return timer;
   }
+
   static endTimer(timer: any) {
     return timer.stop().words;
   }
@@ -199,9 +200,9 @@ export class Helper {
   }
 
   /**
-   * 获取交易额度
+   * 获取基础货币交易额度
    */
-  static getTradeAmount(tradeAmount: BigNumber, feeAmount: BigNumber) {
+  static getBaseTradeAmount(tradeAmount: BigNumber, feeAmount: BigNumber) {
     // 如果A点交易额 x 50% < 该资产可用额度
     if (tradeAmount.times(0.5).isLessThan(feeAmount)) {
       // 返回交易额 x 50% 

src/lib/event.ts

@@ -32,7 +32,7 @@ export class Event extends EventEmitter {
 
   async onUpdateArbitage(ranks: types.IRank[]) {
     if (ranks.length > 0) {
-      await this.storage.putRanks(ranks);
+      await this.storage.rank.putRanks(ranks);
     }
   }
 }