Merge branch 'release/1.6.1'

CHANGELOG.md

@@ -1,3 +1,13 @@
+<a name="1.6.1"></a>
+## [1.6.1](https://github.com/benmarten/CryptoETF/compare/1.6.0...1.6.1) (2018-01-09)
+
+
+### Features
+
+* **ui:** colorize output; allow to hide exchanges below certain holding treshold ([94a1ac1](https://github.com/benmarten/CryptoETF/commit/94a1ac1))
+
+
+
 <a name="1.6.0"></a>
 # [1.6.0](https://github.com/benmarten/CryptoETF/compare/1.5.1...1.6.0) (2018-01-06)
 

README.md

@@ -43,6 +43,7 @@ The tool expects your settings in settings.json. Take a look at settings.example
   - rebalanceDeltaTotalPct: Treshold in percent, that will show a Y in the rebalance column, once rebalancing of total portfolio is recommended.
   - rebalanceDeltaPct: Treshold in percent, that will show a Y in the rebalance column, once rebalancing of individual position is recommended.
   - minValueBtc: Ignore coins that only have a holdingsvalue under a certain bitcoin value.
+  - exchangeMinValueBtc: Don't list exchanges in the exchanges column, with less than the specified BTC value. The complete holding value will still be added in the total sum.
   - hideMissingCoins: By default CryptoETF will add all missing coins up to your last coin holding by rank of the coin (global market cap). This option disables that behaviour.
 - *outputFile*: Path to a file to forward the output to as json.
 

package.json

@@ -4,6 +4,7 @@
     "binance": "^1.1.0",
     "bitfinex": "^1.0.3",
     "coinbase": "^2.0.6",
+    "colors": "^1.1.2",
     "gdax": "^0.4.2",
     "kraken-api": "^1.0.0",
     "node-bittrex-api": "^0.8.1",
@@ -31,5 +32,5 @@
     "testLocal": "./node_modules/.bin/nyc mocha --require babel-core/register test/**/*.js test/**/**/*.js",
     "test": "NODE_ENV=test npm run testLocal"
   },
-  "version": "1.6.0"
+  "version": "1.6.1"
 }

settings.example.json

@@ -57,6 +57,7 @@
     "rebalanceDeltaPct": 1.0,
     "rebalanceDeltaTotalPct": 10.0,
     "minValueBtc": 0.0001,
+    "exchangeMinValueBtc": 0.0001,
     "hideMissingCoins": false
   },
   "outputFile": false

src/Utils.js

@@ -46,4 +46,12 @@ export default class Utils {
   static hasDriftedAboveTreshold(drift, treshold) {
     return (Math.abs(drift) * 100 > treshold) ? 'Y' : ''
   }
+
+  static colorize(string) {
+    if (string.startsWith('-')) {
+      return string.red
+    } else {
+      return string.green
+    }
+  }
 }

src/index.js

@@ -4,30 +4,34 @@ import Coin from './model/Coin'
 import Utils from './Utils'
 import fs from 'fs'
 import * as Settings from './Settings'
+import Terminal from './model/Terminal'
 
 async function refreshPortfolio() {
   return new Promise(async (resolve) => {
         try {
           Portfolio.clear()
           await Coinmarket.init()
-          let integrations = {}
           let promises = []
 
           for (let account in Settings.accounts) {
             let name = Utils.capitalize(account)
+            let Wallet
             try {
-              integrations[name] = require(`./model/integrations/${name}Wallet`)
+              Wallet = require(`./model/integrations/${name}Wallet`).default
             } catch (ignored) {
               console.log(`Warning: Integration for Exchange: ${name} not found!`)
               continue
             }
-            try {
-              if (Settings.accounts[account] && Settings.accounts[account].length > 0) {
-                console.log(`Retrieving ${name} balance...`)
-                promises.push(integrations[name].default.getBalance().then(coins => Portfolio.addCoins(coins)))
+
+            for (let index in Settings.accounts[account]) {
+              let credentials = Settings.accounts[account][index]
+              let integration = new Wallet(credentials)
+              console.log(`Retrieving ${name} balance...`)
+              try {
+                promises.push(integration.getBalance().then(coins => Portfolio.addCoins(coins)))
+              } catch (e) {
+                console.log(`Error: An error occured while running integration: ${name}, ${e}`)
               }
-            } catch (e) {
-              console.log(`Error: An error occured while running integration: ${name}, ${e}`)
             }
           }
 
@@ -48,14 +52,14 @@ async function refreshPortfolio() {
           Portfolio.removeCoin('USDT')
 
           if (Settings.outputFile) {
-            fs.writeFile(Settings.outputFile, Portfolio.getJson(), 'utf8', function(err) {
+            fs.writeFile(Settings.outputFile, Portfolio.getPortfolioJson(), 'utf8', function(err) {
               if (err) throw err
               console.log(`Saved data to ${Settings.outputFile}...`)
             })
           }
 
-
-          console.log(Portfolio.getOutput())
+          let portfolio = Portfolio.getPortfolio()
+          Terminal.printOutput(portfolio)
         }
         catch
             (error) {

src/model/Coin.js

@@ -1,14 +1,14 @@
 import Coinmarket from './Coinmarket'
 import Portfolio from './Portfolio'
 import * as Settings from './../Settings'
+import _ from 'lodash'
 
 export default class Coin {
   symbol
   // noinspection JSCheckFunctionSignatures
   amount = parseFloat(0)
   rank
   exchanges = {}
-  exchangesPossible = {}
 
   constructor(symbol, amount, exchange, rank) {
     if (!symbol || (!amount && amount !== 0)) {
@@ -22,11 +22,7 @@ export default class Coin {
     this.amount = parseFloat(amount)
 
     if (exchange) {
-      if (this.amount > 0) {
-        this.addExchange(exchange)
-      } else {
-        this.addExchangePossible(exchange)
-      }
+      this.addExchange(exchange, amount)
     }
 
     if (rank) {
@@ -86,40 +82,36 @@ export default class Coin {
   /**
    * Records on which exchange the coin is traded and we hold it.
    * @param exchange The name of the exchange
+   * @param amount The amount held on the exchange
    */
-  addExchange(exchange) {
-    if (typeof exchange === 'object') {
-      for (let idx in exchange) {
-        this.exchanges[exchange[idx]] = 1
-      }
+  addExchange(exchange, amount) {
+    if (!exchange || exchange.length === 0) {
+      return
     }
-    this.exchanges[exchange] = 1
-  }
-
-  /**
-   * Records on which exchange the coin is traded.
-   * @param exchange The name of the exchange
-   */
-  addExchangePossible(exchange) {
     if (typeof exchange === 'object') {
       for (let idx in exchange) {
-        this.exchangesPossible[exchange[idx]] = 1
+        this.exchanges[exchange[idx]] = amount
       }
     }
-    this.exchangesPossible[exchange] = 1
+    this.exchanges[exchange] = amount
   }
 
   getExchanges() {
     return Object.keys(this.exchanges)
   }
 
   getExchangesString() {
-    let result
-    if (Object.keys(this.exchanges).length > 0) {
-      result = Object.keys(this.exchanges).toString()
+    let coin = this
+    let result = _.pickBy(this.exchanges, (value) => {
+      return (value * Coinmarket.getBtcForX(coin.symbol)) >
+          (Settings.options.exchangeMinValueBtc || 0)
+    })
+    if (Object.keys(result).length > 0) {
+      result = Object.keys(result).toString()
     } else {
-      result = Object.keys(this.exchangesPossible).toString()
+      result = Object.keys(this.exchanges).toString().blue.italic
     }
+
     return (result.charAt(result.length - 1) === ',') ? result.slice(0, -1) : result
   }
 }

src/model/Portfolio.js

@@ -1,8 +1,6 @@
 import Utils from './../Utils'
 import Coinmarket from './Coinmarket'
 // noinspection NpmUsedModulesInstalled
-import {table} from 'table'
-import Format from './../Format'
 import * as Settings from './../Settings'
 
 let portfolio = {}
@@ -21,11 +19,7 @@ export default class Portfolio {
     if (portfolio[coin.getSymbol()]) {
       let existingCoin = portfolio[coin.getSymbol()]
       existingCoin.addAmount(coin.getAmount())
-      if (coin.getAmount() > 0) {
-        existingCoin.addExchange(coin.getExchanges())
-      } else {
-        existingCoin.addExchangePossible(coin.getExchanges())
-      }
+      existingCoin.addExchange(coin.getExchanges(), coin.getAmount())
     } else {
       portfolio[coin.getSymbol()] = coin
       this.updateHighestRankWithBalance(coin)
@@ -121,123 +115,18 @@ export default class Portfolio {
   }
 
   /**
-   * Formats the output for the command line.
-   * @return {string} A string with the result.
+   * Returns the current portfolio.
+   * @return {{Object}} The portfolio.
    */
-  static getOutput() {
-    let stretchFactor = Portfolio.getStretchFactor()
-    let data = [
-      ['#', 'SYMBOL', 'AMOUNT', 'VALUE', 'VALUE', 'ALLOCATION', 'ALLOCATION', 'TARGET', 'TARGET', 'BUY/SELL', 'BUY/SELL', 'BUY/SELL', 'DRIFT', 'REBALANCE', 'EXCHANGES'],
-      ['', '', '', '฿', '$', 'actual %', 'target %', '฿', '$', '฿', 'ETH', '$', '%', '', '']
-    ]
-    let sortedKeys = Utils.getSortedKeys(portfolio, 'rank')
-    let targetSum = []
-    let targetValueUsd = this.getTargetValueUsd()
-    let targetValueBtc = this.getTargetValueUsd() / Coinmarket.getBtcUsd()
-    targetSum['allocationActualPct'] = 0
-    targetSum['allocationTargetPct'] = 0
-    targetSum['targetBtc'] = 0
-    targetSum['targetUsd'] = 0
-    for (let index in sortedKeys) {
-      if (!sortedKeys.hasOwnProperty(index)) {
-        continue
-      }
-      let coin = portfolio[sortedKeys[index]]
-      let allocationActualPct = coin.getRelativeMarketCap()
-      let allocationTargetPct = coin.getRelativeMarketCapRecommended() / stretchFactor
-      let targetBtc = coin.getRelativeMarketCapRecommended() / stretchFactor * targetValueBtc
-      let targetUsd = coin.getRelativeMarketCapRecommended() / stretchFactor * targetValueUsd
-      let drift = Math.abs((coin.getUsdValue() - targetUsd) / targetValueUsd)
-      data.push([
-        coin.getRank(),
-        coin.getSymbol(),
-        Utils.round(coin.getAmount(), 2),
-        Format.bitcoin(coin.getBtcValue()),
-        Format.money(coin.getUsdValue(), 0),
-        Format.percent(allocationActualPct),
-        Format.percent(allocationTargetPct),
-        Format.bitcoin(targetBtc),
-        Format.money(targetUsd),
-        Format.bitcoin(targetBtc - coin.getBtcValue(), 8),
-        Format.bitcoin((targetBtc - coin.getBtcValue()) / Coinmarket.getBtcEth(), 8),
-        Format.money(targetUsd - coin.getUsdValue()),
-        Format.percent(drift),
-        Utils.hasDriftedAboveTreshold(drift, Settings.options.rebalanceDeltaPct),
-        coin.getExchangesString()
-      ])
-      targetSum['allocationActualPct'] += allocationActualPct || 0
-      targetSum['allocationTargetPct'] += allocationTargetPct || 0
-      targetSum['targetBtc'] += targetBtc
-      targetSum['targetUsd'] += targetUsd
-    }
-
-    let drift = (targetSum['targetBtc'] - this.getSumBtc()) / targetSum['targetBtc']
-    data.push([
-      '',
-      '',
-      '',
-      Format.bitcoin(this.getSumBtc()),
-      Format.money(this.getSumUsd()),
-      Format.percent(targetSum['allocationActualPct']),
-      Format.percent(targetSum['allocationTargetPct']),
-      Format.bitcoin(targetSum['targetBtc']),
-      Format.money(targetSum['targetUsd']),
-      Format.bitcoin(targetSum['targetBtc'] - this.getSumBtc()),
-      '',
-      Format.money(targetSum['targetUsd'] - this.getSumUsd()),
-      Format.percent(drift),
-      Utils.hasDriftedAboveTreshold(drift, (Settings.options.rebalanceDeltaTotalPct ||
-          Settings.options.rebalanceDeltaPct)),
-      ''])
-
-    // noinspection JSUnusedGlobalSymbols
-    let config = {
-      columns: {
-        2: {
-          alignment: 'right'
-        },
-        3: {
-          alignment: 'right'
-        },
-        4: {
-          alignment: 'right'
-        },
-        5: {
-          alignment: 'right'
-        },
-        6: {
-          alignment: 'right'
-        },
-        7: {
-          alignment: 'right'
-        },
-        8: {
-          alignment: 'right'
-        },
-        9: {
-          alignment: 'right'
-        },
-        10: {
-          alignment: 'right'
-        },
-        11: {
-          alignment: 'right'
-        },
-        12: {
-          alignment: 'right'
-        },
-        13: {
-          alignment: 'right'
-        }
-      },
-      drawHorizontalLine: (index, size) => {
-        return index === 0 || index === 2 || index === size - 1 || index === size
-      }
-    }
-    return table(data, config)
+  static getPortfolio() {
+    return portfolio
   }
 
-  static getJson() {
+  /**
+   * Returns the portfolio as json string.
+   * @return {string} The portfolio as json string.
+   */
+  static getPortfolioJson() {
     return JSON.stringify(portfolio, null, 2)
   }
 }