From b6d12c8129c3a0f302070f1a3e3612cc992aed24 Mon Sep 17 00:00:00 2001
From: Josh Harvey <josh@lamassu.is>
Date: Fri, 3 Jun 2016 12:34:10 +0300
Subject: [PATCH] fix up consolidation

---
 lib/plugins.js | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/lib/plugins.js b/lib/plugins.js
index 13289550..43883954 100644
--- a/lib/plugins.js
+++ b/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 = {