Update seed directory to use loopback

2015-06-02 20:32:10 -07:00
parent e7d01424e9
commit 272d9b4ad5
26 changed files with 102 additions and 100 deletions
--- a/seed/userMigration.js
+++ b/seed/userMigration.js
@ -0,0 +1,137 @@
+/*eslint-disable block-scoped-var */
+require('dotenv').load();
+var User = require('../models/User.js'),
+    secrets = require('../config/secrets'),
+    mongoose = require('mongoose'),
+    R = require('ramda'),
+    ziplines = require('./challenges/ziplines.json'),
+    basejumps = require('./challenges/basejumps.json');
+
+mongoose.connect(secrets.db);
+
+var ziplineIds = ziplines.challenges.map(function(elem) {
+  return elem._id;
+});
+var basejumpIds = basejumps.challenges.map(function(elem) {
+  return elem._id;
+});
+var ziplineAndBaseJumpIds = R.concat(ziplineIds, basejumpIds);
+
+function userModelAssurity(cb) {
+  console.log('userModelAssurity');
+  var i = 1;
+  var stream = User.find({}).skip(0).limit(0).batchSize(20000).stream();
+
+  stream.on('data', function (user) {
+    console.log(i++);
+    this.pause();
+    user.needsMigration = true;
+    user.save(function (err) {
+      if (err) {
+        console.log('woops');
+      }
+      this.resume();
+    }.bind(this));
+  })
+    .on('error', function (err) {
+      console.log(err);
+    }).on('close', function () {
+      console.log('done with set');
+      stream.destroy();
+      cb();
+    });
+}
+
+function migrateIt() {
+  console.log('migrateIt');
+  var dones = 0;
+  var done = function() {
+    dones++;
+    if (dones === 2) {
+      process.exit(0);
+    }
+    if (dones === 1) {
+      userModelMigration(done);
+    }
+  };
+  console.log('calling userModelAssurity');
+  userModelAssurity(done);
+}
+
+function userModelMigration(cb) {
+
+  var i = 1;
+
+  var stream = User.find({needsMigration: true}).skip(0).limit(0)
+    .batchSize(20000).stream();
+
+  stream.on('data', function (user) {
+    console.log(i++);
+    /*
+    if (user.challengesHash) {
+      this.pause();
+      user.needsMigration = false;
+      var oldChallenges = Object.keys(user.challengesHash).filter(function (key) {
+        if (user.challengesHash[key]) {
+          user.progressTimestamps.push(user.challengesHash[key] * 1000);
+        }
+        return user.challengesHash[key];
+      });
+
+      newChallenges.forEach(function (challenge) {
+        if (oldChallenges.indexOf(challenge.oldNumber) !== -1 && challenge.newId) {
+          user.completedCoursewares.push({
+            _id: challenge.newId,
+            completedDate: user.challengesHash[challenge.oldNumber] * 1000
+          });
+        }
+      });
+
+      user.completedCoursewares.forEach(function (course) {
+        var indexOfCourse = user.uncompletedCoursewares.indexOf(course._id) !== -1;
+        if (indexOfCourse !== -1) {
+          user.uncompletedCoursewares.splice(indexOfCourse, 1);
+        }
+      });
+
+      user.completedBonfires.forEach(function (bonfire) {
+        bonfire.completedDate = bonfire.completedDate * 1000;
+        user.progressTimestamps.push(bonfire.completedDate);
+      });
+    }
+    */
+    user.needsMigration = false;
+    user.completedChallenges = user.completedChallenges.map(function(elem) {
+      if (ziplineAndBaseJumpIds.indexOf(elem._id) > 0) {
+        return ({
+          _id: elem._id,
+          name: elem.name,
+          completedWith: elem.completedWith,
+          completedDate: elem.completedDate,
+          solution: elem.solution,
+          githubLink: elem.githubLink,
+          verified: elem.verified,
+          challengeType: typeof elem.githubLink === 'boolean' ? 4 : 3
+        });
+      } else {
+        return elem;
+      }
+    });
+
+    var self = this;
+    user.save(function (err) {
+      if (err) {
+        console.log('woops');
+      }
+      self.resume();
+    });
+  }).on('error', function (err) {
+    console.log(err);
+  }).on('close', function () {
+    console.log('done with set');
+    stream.destroy();
+    cb();
+  });
+}
+
+migrateIt();