From 7001b3b0c79c747a4c66910f05d3ba6196360c50 Mon Sep 17 00:00:00 2001
From: John McLear <john@mclear.co.uk>
Date: Thu, 24 Mar 2016 14:29:55 +0000
Subject: [PATCH] whee

---
 bin/removeOldPadData.js | 38 +++++++++++++++++++++++++++-----------
 1 file changed, 27 insertions(+), 11 deletions(-)

diff --git a/bin/removeOldPadData.js b/bin/removeOldPadData.js
index 1f55eea0f..78659a4cb 100644
--- a/bin/removeOldPadData.js
+++ b/bin/removeOldPadData.js
@@ -10,6 +10,9 @@ var db, settings, keys, values;
 var npm = require("../src/node_modules/npm");
 var async = require("../src/node_modules/async");
 
+// Setup a removal count
+var removalCount = 0;
+
 async.series([
   //load npm
   function(callback) {
@@ -36,12 +39,17 @@ async.series([
   {
     values = {};
     async.eachSeries(keys, function(key, cb){
-      db.db.get(key, function(err, value){
-        // console.log("err", err);
-        // console.log("value", key, value);
-        values[key] = value;
+      // only get main pad data not any revisions
+      if(key.indexOf(":revs") === -1){
+        db.db.get(key, function(err, value){
+          // console.log("get value", key, value);
+          values[key] = value;
+          cb();
+        });
+      }else{
         cb();
-      });
+      }
+
     }, function(){
       callback();
     });
@@ -49,11 +57,16 @@ async.series([
   // Removing all old pad data record
   function (callback){
     async.each(keys, function(key, cb){
-      console.log("Removing", key);
+      if(key.indexOf(":revs") !== -1){
+        console.log("Removing", key);
         db.db.remove(key, function(err){
-        if(err) console.log("err", err);
+          removalCount++;
+          if(err) console.log("err", err);
+          cb();
+        });
+      }else{
         cb();
-      });
+      }
     }, function(){
       callback();
     });
@@ -61,8 +74,11 @@ async.series([
   // Add latest data back in for a pad
   function (callback){
     async.eachSeries(keys, function(key, cb){
-      console.log("Adding data back in for", key);
-      db.db.set(key, values[key]);
+      var sauce = values[key];
+      if(key.indexOf(":revs") === -1){
+        // console.log("Adding data back in for", key, sauce);
+        db.db.set(key, values[key]);
+      }
       cb();
     }, function(){
       callback();
@@ -72,7 +88,7 @@ async.series([
 {
   if(err) throw err;
   else{
-    console.log("finished");
+    console.log("finished, total database records removed "+removalCount);
     process.exit(0);
   }
 });