update migrations for useAuth, access_token and grouptags (#563)

* update migrations for useAuth, access_token and grouptags

* rename files

* add migration to remove corrupted sensors, fix numbers

Co-authored-by: Umut Tas <[email protected]>

Author: mpfeil

packages/models/migrations/8-9_box_grouptag/8-node-update-grouptag.js renamed to packages/models/migrations/10-11_box_grouptag/10-node-update-grouptag.js

@@ -3,7 +3,6 @@
 
 const models = require("../../../models");
 const { mongoose, connect } = models.db;
-const moment = require("moment");
 
 const { Box } = models;
 
@@ -16,7 +15,7 @@ const migrate = function migrate() {
     .find({})
     .next()
     .then(function (latestVersion) {
-      if (latestVersion.schemaVersion !== 8) {
+      if (latestVersion.schemaVersion !== 10) {
         throw new Error("Unexpected schema version... Exiting!");
       }
 

packages/models/migrations/7-8_box_access_token/7-mongoshell-boxes-add-field.js

@@ -0,0 +1,55 @@
+/* eslint-disable */
+"use strict";
+
+const models = require("../../../models");
+const { mongoose, connect } = models.db;
+const { Box } = models;
+const crypto = require('crypto')
+
+const migrate = function migrate() {
+  const schemaVersion = mongoose.connection.db.collection("schemaVersion");
+
+  console.log('Starting "update access token" migration');
+
+  return schemaVersion
+    .find({})
+    .next()
+    .then(function (latestVersion) {
+      if (latestVersion.schemaVersion !== 7) {
+        throw new Error("Unexpected schema version... Exiting!");
+      }
+
+      return Box.find({access_token: {$exists: false}}).exec();
+    })
+    .then(function (boxes) {
+      const promises = [];
+      for (let index = 0; index < boxes.length; index++) {
+        const box = boxes[index];
+
+        box.set("access_token", crypto.randomBytes(32).toString('hex'));
+        promises.push(box.save());
+      }
+
+      return Promise.all(promises).then(function () {
+        console.log("Migration done!");
+
+        return schemaVersion.update({}, { $inc: { schemaVersion: 1 } });
+      });
+    });
+};
+
+// Connect to db and run migration
+connect()
+  .then(function () {
+    migrate()
+      .then(function () {
+        mongoose.disconnect();
+      })
+      .catch(function (err) {
+        console.log(err);
+        mongoose.disconnect();
+      });
+  })
+  .catch(function (err) {
+    console.log(err);
+  });

packages/models/migrations/7-9_box_access_token/7-node-boxes-add-field-access-token.js

@@ -0,0 +1,62 @@
+/* eslint-disable */
+"use strict";
+
+const models = require("../../../models");
+const { mongoose, connect } = models.db;
+const { Box } = models;
+
+const migrate = function migrate() {
+  const schemaVersion = mongoose.connection.db.collection("schemaVersion");
+
+  console.log('Starting "fix corrupt sensors" migration');
+
+  return schemaVersion
+    .find({})
+    .next()
+    .then(function (latestVersion) {
+      if (latestVersion.schemaVersion !== 8) {
+        throw new Error("Unexpected schema version... Exiting!");
+      }
+
+      return Box.find({ "sensors" : {$elemMatch: { title : { $exists: false }}}}).exec();
+    })
+    .then(function (boxes) {
+      console.log("Found boxes: ", boxes.length)
+      const promises = [];
+      for (let index = 0; index < boxes.length; index++) {
+        const box = boxes[index];
+
+        let sensors = box.sensors.filter(sensor => {
+          if(sensor.title && sensor.unit){
+            return true;
+          } else {
+            return false;
+          }
+        })
+        box.set("sensors", sensors);
+        promises.push(box.save());
+      }
+
+      return Promise.all(promises).then(function () {
+        console.log("Migration done!");
+
+        return schemaVersion.update({}, { $inc: { schemaVersion: 1 } });
+      });
+    });
+};
+
+// Connect to db and run migration
+connect()
+  .then(function () {
+    migrate()
+      .then(function () {
+        mongoose.disconnect();
+      })
+      .catch(function (err) {
+        console.log(err);
+        mongoose.disconnect();
+      });
+  })
+  .catch(function (err) {
+    console.log(err);
+  });

packages/models/migrations/7-9_box_access_token/8-node-boxes-fix-sensors.js

@@ -0,0 +1,54 @@
+/* eslint-disable */
+"use strict";
+
+const models = require("../../../models");
+const { mongoose, connect } = models.db;
+const { Box } = models;
+
+const migrate = function migrate() {
+  const schemaVersion = mongoose.connection.db.collection("schemaVersion");
+
+  console.log('Starting "update useAuth" migration');
+
+  return schemaVersion
+    .find({})
+    .next()
+    .then(function (latestVersion) {
+      if (latestVersion.schemaVersion !== 9) {
+        throw new Error("Unexpected schema version... Exiting!");
+      }
+
+      return Box.find({useAuth: {$exists: false}}).exec();
+    })
+    .then(function (boxes) {
+      const promises = [];
+      for (let index = 0; index < boxes.length; index++) {
+        const box = boxes[index];
+
+        box.set("useAuth", false);
+        promises.push(box.save());
+      }
+
+      return Promise.all(promises).then(function () {
+        console.log("Migration done!");
+
+        return schemaVersion.update({}, { $inc: { schemaVersion: 1 } });
+      });
+    });
+};
+
+// Connect to db and run migration
+connect()
+  .then(function () {
+    migrate()
+      .then(function () {
+        mongoose.disconnect();
+      })
+      .catch(function (err) {
+        console.log(err);
+        mongoose.disconnect();
+      });
+  })
+  .catch(function (err) {
+    console.log(err);
+  });