From 0e01e0000e6751be09233b6206b6d41c277f230d Mon Sep 17 00:00:00 2001
From: Matias Alejo Garcia <ematiu@gmail.com>
Date: Wed, 22 Apr 2015 15:02:25 -0300
Subject: [PATCH] fix ending condition

---
 scripts/level2mongo.js | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/scripts/level2mongo.js b/scripts/level2mongo.js
index 125d484..4157fe6 100644
--- a/scripts/level2mongo.js
+++ b/scripts/level2mongo.js
@@ -5,7 +5,7 @@ var MongoStorage = require('../lib/storage');
 
 
 var level = new LevelStorage({
-  dbPath: './db/bws.db',
+  dbPath: './db',
 });
 
 var mongo = new MongoStorage();
@@ -29,17 +29,28 @@ mongo.connect({
 
 
 function run(cb) {
+  var pending = 0,
+    ended = false;
   level.db.readStream()
     .on('data', function(data) {
+      pending++;
       migrate(data.key, data.value, function(err) {
         if (err) throw err;
+        pending--;
+        if (pending==0 && ended) {
+          return cb();
+        }
       });
     })
     .on('error', function(err) {
       return cb(err);
     })
     .on('end', function() {
-      return cb();
+      console.log('All old data read')
+      ended = true;
+      if (!pending) {
+        return cb();
+      }
     });
 };