diff --git a/lib/plugins.js b/lib/plugins.js index 426095a3..49a22471 100644 --- a/lib/plugins.js +++ b/lib/plugins.js @@ -370,6 +370,8 @@ function consolidateTrades() { }, 0) }; + tradesQueue = []; + logger.debug('consolidated: ', JSON.stringify(consolidatedTrade)); return consolidatedTrade; }; @@ -388,7 +390,10 @@ function executeTrades() { logger.trade.debug('making a trade: %d', trade.satoshis / SATOSHI_FACTOR); purchase(trade, function(err) { - if (err) logger.error(err); + if (err) { + tradesQueue.push(trade); + logger.error(err); + } }); };