fix #379

askmike · Jul 10, 2016 · 1ac2013 · 1ac2013
1 parent 532e724
commit 1ac2013
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/importers/exchanges/poloniex.js b/importers/exchanges/poloniex.js
@@ -65,11 +65,15 @@ var fetch = () => {
 }
 
 var handleFetch = trades => {
-  var last = moment.unix(_.last(trades).date);
 
   iterator.from.add(batchSize, 'minutes').subtract(overlapSize, 'minutes');
   iterator.to.add(batchSize, 'minutes').subtract(overlapSize, 'minutes');
 
+  if(!_.size(trades))
+    return fetcher.emit('trades', []);
+
+  var last = moment.unix(_.last(trades).date);
+
   if(last > end) {
     fetcher.emit('done');
 

diff --git a/sample-config.js b/sample-config.js
@@ -15,6 +15,7 @@ config.debug = true; // for additional logging / debugging
 
 // Monitor the live market
 config.watch = {
+
   // see https://github.com/askmike/gekko#supported-exchanges
   exchange: 'Bitstamp',
   currency: 'USD',