fix up consolidation

lib/plugins.js

@@ -586,8 +586,17 @@ function consolidateTrades (cryptoCode) {
 
   const t0 = Date.now()
 
-  const cryptoAtoms = tradesQueues[cryptoCode]
+  const filtered = tradesQueues[cryptoCode]
   .filter(trade => t0 - trade.timestamp < TRADE_TTL)
+
+  const filteredCount = tradesQueues[cryptoCode].length - filtered.length
+
+  if (filteredCount > 0) {
+    tradesQueues[cryptoCode] = filtered
+    logger.debug('[%s] expired %d trades', cryptoCode, filteredCount)
+  }
+
+  const cryptoAtoms = filtered
   .reduce((prev, current) => prev.plus(current.cryptoAtoms), new BigNumber(0))
 
   var consolidatedTrade = {