From d87dcd6ada1db5072e4932eb8beed7e7431f1b73 Mon Sep 17 00:00:00 2001
From: terakilobyte <terakilobyte@gmail.com>
Date: Mon, 15 Jun 2015 19:12:48 -0400
Subject: [PATCH] Remove excess debug statements from flattenUser.js

---
 flattenUser.js | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/flattenUser.js b/flattenUser.js
index fad529cea3..db107ade45 100644
--- a/flattenUser.js
+++ b/flattenUser.js
@@ -29,26 +29,21 @@ function createConnection(URI) {
 
 function createQuery(db, collection, options, batchSize) {
   return Rx.Observable.create(function (observer) {
-    console.log('Creating cursor...');
     var cursor = db.collection(collection).find({}, options);
     cursor.batchSize(batchSize || 20);
     // Cursor.each will yield all doc from a batch in the same tick,
     // or schedule getting next batch on nextTick
     cursor.each(function (err, doc) {
       if (err) {
-        console.log(err);
         return observer.onError(err);
       }
       if (!doc) {
-        console.log('hit complete');
         return observer.onCompleted();
       }
-      console.log('calling onnext');
       observer.onNext(doc);
     });
 
     return Rx.Disposable.create(function () {
-      console.log('Disposing cursor...');
       cursor.close();
     });
   });
@@ -101,7 +96,6 @@ var userSavesCount = users
   })
   .flatMap(function(dats) {
     // bulk insert into new collection for loopback
-    console.log(dats);
     return insertMany(dats.db, 'user', dats.users, { w: 1 });
   })
   // count how many times insert completes
@@ -147,7 +141,7 @@ Rx.Observable.merge(
       count += _count * 20;
     },
     function(err) {
-      console.log('an error occured', err, err.stack);
+      console.error('an error occured', err, err.stack);
     },
     function() {
       console.log('finished with %s documents processed', count);