Fix first start for new devs

also removes job seed

index.js

@@ -1,55 +1,34 @@
 /* eslint-disable no-process-exit */
 require('babel/register');
 require('dotenv').load();
+
 var fs = require('fs'),
+    Rx = require('rx'),
     _ = require('lodash'),
     path = require('path'),
-    app = require('../server/server'),
+    app = require('../server/server');
-    nonprofits = require('./nonprofits.json'),
-    jobs = require('./jobs.json');
 
 function getFilesFor(dir) {
   return fs.readdirSync(path.join(__dirname, '/' + dir));
 }
 
 var Challenge = app.models.Challenge;
-var Nonprofit = app.models.Nonprofit;
-var Job = app.models.Job;
-var counter = 0;
 var challenges = getFilesFor('challenges');
-// plus two accounts for nonprofits and jobs seed.
+var destroy = Rx.Observable.fromNodeCallback(Challenge.destroyAll, Challenge);
-var numberToSave = challenges.length + 1;
+var create = Rx.Observable.fromNodeCallback(Challenge.create, Challenge);
 
-function completionMonitor() {
+destroy()
-  // Increment counter
+  .flatMap(function() { return Rx.Observable.from(challenges); })
-  counter++;
+  .flatMap(function(file) {
-
-  // Exit if all challenges have been checked
-  if (counter >= numberToSave) {
-    process.exit(0);
-  }
-
-  // Log where in the seed order we're currently at
-  console.log('Call: ' + counter + '/' + numberToSave);
-}
-
-Challenge.destroyAll(function(err, info) {
-  if (err) {
-    throw err;
-  } else {
-    console.log('Deleted ', info);
-  }
-  challenges.forEach(function(file) {
     var challengeSpec = require('./challenges/' + file);
     var order = challengeSpec.order;
     var block = challengeSpec.name;
     var isBeta = !!challengeSpec.isBeta;
+    console.log('parsed %s successfully', file);
 
     // challenge file has no challenges...
     if (challengeSpec.challenges.length === 0) {
-      console.log('file %s has no challenges', file);
+      return Rx.Observable.just([{ block: 'empty ' + block }]);
-      completionMonitor();
-      return;
     }
 
     var challenges = challengeSpec.challenges
@@ -73,50 +52,15 @@ Challenge.destroyAll(function(err, info) {
         return challenge;
       });
 
-    Challenge.create(
+    return create(challenges);
-      challenges,
+  })
-      function(err) {
+  .subscribe(
-        if (err) {
+    function(challenges) {
-          throw err;
+      console.log('%s successfully saved', challenges[0].block);
-        } else {
+    },
-          console.log('Successfully parsed %s', file);
+    function(err) { throw err; },
-          completionMonitor(err);
+    function() {
-        }
+      console.log('challenge seed completed');
-      }
+      process.exit(0);
-    );
-  });
-});
-
-Nonprofit.destroyAll(function(err, info) {
-  if (err) {
-    console.error(err);
-  } else {
-    console.log('Deleted ', info);
-  }
-  Nonprofit.create(nonprofits, function(err, data) {
-    if (err) {
-      throw err;
-    } else {
-      console.log('Saved ', data);
     }
-    completionMonitor(err);
+  );
-    console.log('nonprofits');
-  });
-});
-
-Job.destroyAll(function(err, info) {
-  if (err) {
-    throw err;
-  } else {
-    console.log('Deleted ', info);
-  }
-  Job.create(jobs, function(err, data) {
-    if (err) {
-      console.log('error: ', err);
-    } else {
-      console.log('Saved ', data);
-    }
-    console.log('jobs');
-    completionMonitor(err);
-  });
-});

nonprofits.js

@@ -0,0 +1,29 @@
+/* eslint-disable no-process-exit */
+require('babel/register');
+require('dotenv').load();
+
+var Rx = require('rx');
+var app = require('../server/server');
+
+var Nonprofits = app.models.Challenge;
+var nonprofits = require('./nonprofits.json');
+var destroy = Rx.Observable.fromNodeCallback(Nonprofits.destroyAll, Nonprofits);
+var create = Rx.Observable.fromNodeCallback(Nonprofits.create, Nonprofits);
+
+destroy()
+  .flatMap(function() {
+    if (!nonprofits) {
+      return Rx.Observable.throw(new Error('No nonprofits found'));
+    }
+    return create(nonprofits);
+  })
+  .subscribe(
+    function(nonprofits) {
+      console.log('successfully saved %d nonprofits', nonprofits.length);
+    },
+    function(err) { throw err; },
+    function() {
+      console.log('nonprofit seed completed');
+      process.exit(0);
+    }
+  );