diff --git a/lib/trader.js b/lib/trader.js index d7698e93..d7c958c7 100644 --- a/lib/trader.js +++ b/lib/trader.js @@ -182,15 +182,19 @@ Trader.prototype.pollBalance = function (callback) { }); }; -Trader.prototype.pollRate = function () { +Trader.prototype.pollRate = function (callback) { var self = this; var currency = self.config.exchanges.settings.currency; self.logger.info('polling for rate...'); self.tickerExchange.ticker(currency, function(err, rate) { - if (err) return; + if (err) { + return callback && callback(err); + } + self.logger.info('Rate update:', rate); self.rates[currency] = {rate: rate, timestamp: new Date()}; + callback && callback(null, self.rates[currency]); }); };