refactor rxify fieldguides

server/boot/fieldGuide.js

@@ -1,11 +1,16 @@
-var R = require('ramda'),
+var Rx = require('rx');
-// Rx = require('rx'),
+var debug = require('debug')('freecc:fieldguides');
-  debug = require('debug')('freecc:fieldguides'),
+var observeMethod = require('../utils/rx').observeMethod;
-  utils = require('../utils');
+var saveUser = require('../utils/rx').saveUser;
+var utils = require('../utils');
+
+var allFieldGuideNamesAndIds = utils.allFieldGuideNamesAndIds();
 
 module.exports = function(app) {
   var router = app.loopback.Router();
   var FieldGuide = app.models.FieldGuide;
+  var findFieldGuideById = observeMethod(FieldGuide, 'findById');
+  var findOneFieldGuide = observeMethod(FieldGuide, 'findOne');
 
   router.get('/field-guide/all-articles', showAllFieldGuides);
   router.get('/field-guide/:fieldGuideName', returnIndividualFieldGuide);
@@ -15,60 +20,66 @@ module.exports = function(app) {
   app.use(router);
 
   function returnIndividualFieldGuide(req, res, next) {
-    var dashedNameFromQuery = req.params.fieldGuideName;
+    var dashedName = req.params.fieldGuideName;
-    if (req.user) {
+    var userSave = Rx.Observable.just(req.user)
-      var completed = req.user.completedFieldGuides;
+      .filter(function(user) {
+        return !!user;
+      })
+      .map(function(user) {
+        var completed = user.completedFieldGuides;
 
         var uncompletedFieldGuides = utils.allFieldGuideIds()
-        .filter(function (elem) {
+          .filter(function(id) {
-          if (completed.indexOf(elem) === -1) {
+            if (completed.indexOf(id) === -1) {
-            return elem;
+              return id;
             }
           });
-      req.user.uncompletedFieldGuides = uncompletedFieldGuides;
+        user.uncompletedFieldGuides = uncompletedFieldGuides;
-      // TODO(berks): handle callback properly
+        return user;
-      req.user.save(function(err) {
+      })
-        if (err) { return next(err); }
+      .flatMap(function(user) {
+        return saveUser(user);
       });
-    }
 
-    FieldGuide.find({ where: {'dashedName': dashedNameFromQuery}},
+    var query = { where: { dashedName: { like: dashedName, options: 'i' } } };
-      function(err, fieldGuideFromMongo) {
-        if (err) {
-          return next(err);
-        }
 
-        if (fieldGuideFromMongo.length < 1) {
+    debug('find fieldGuide', query);
+    Rx.Observable.combineLatest(
+      // find that field guide
+      findOneFieldGuide(query),
+      userSave,
+      Rx.helpers.identity
+    )
+      .subscribe(
+        // don't care about return from userSave
+        function(fieldGuide) {
+          if (!fieldGuide) {
             req.flash('errors', {
-            msg: '404: We couldn\'t find a field guide entry with that name. ' +
+              msg: '404: We couldn\'t find a field guide entry with ' +
-            'Please double check the name.'
+                'that name. Please double check the name.'
             });
-
+            return res.redirect('/field-guide/all-articles');
-          return res.redirect('/');
           }
 
-        var fieldGuide = R.head(fieldGuideFromMongo);
+          if (fieldGuide.dashedName !== dashedName) {
-        fieldGuide.name.toLowerCase().replace(/\s/g, '-').replace(/\?/g, '');
+            return res.redirect('../field-guide/' + fieldGuide.dashedName);
-
+          }
-        // if (fieldGuide.dashedName !== dashedNameFromQuery) {
-        //   return res.redirect('../field-guide/' + fieldGuide.dashedName);
-        // }
           res.render('field-guide/show', {
             title: fieldGuide.name,
             fieldGuideId: fieldGuide.id,
             description: fieldGuide.description.join('')
           });
-      }
+        },
+        next
     );
   }
 
   function showAllFieldGuides(req, res) {
-    var allFieldGuideNamesAndIds = utils.allFieldGuideNamesAndIds();
-
     var completedFieldGuides = [];
     if (req.user && req.user.completedFieldGuides) {
       completedFieldGuides = req.user.completedFieldGuides;
     }
+
     res.render('field-guide/all-articles', {
       allFieldGuideNamesAndIds: allFieldGuideNamesAndIds,
       completedFieldGuides: completedFieldGuides
@@ -76,7 +87,9 @@ module.exports = function(app) {
   }
 
   function showCompletedFieldGuideFunction(req, res) {
-    req.flash('success', {
+    req.flash(
+      'success',
+      {
         msg: [
           'You\'ve read all our current Field Guide entries. ' +
           'If you have ideas for other Field Guide articles, ' +
@@ -85,7 +98,8 @@ module.exports = function(app) {
           'issues/new?&body=Please describe your idea for a Field Guide' +
           ' article and include links if possible.\'>GitHub</a>.'
         ].join('')
-            });
+      }
+    );
     return res.redirect('../field-guide/how-do-i-use-this-guide');
   }
 
@@ -95,24 +109,25 @@ module.exports = function(app) {
     }
 
     if (!req.user.uncompletedFieldGuides.length) {
-      return showCompletedFieldGuideFunction(req, res, next);
+      return showCompletedFieldGuideFunction(req, res);
     }
 
-    FieldGuide.findById(req.user.uncompletedFieldGuides[0],
+    findFieldGuideById(req.user.uncompletedFieldGuides[0]).subscribe(
-      function(err, fieldGuide) {
+      function(fieldGuide) {
-
-        if (err) { return next(err); }
         if (!fieldGuide) {
-          debug('bad juju in field guide %s',
+          debug(
-            req.user.uncompletedFieldGuides[0]);
+            'field guide %s not found',
+            req.user.uncompletedFieldGuides[0]
+          );
           return res.redirect('../field-guide/how-do-i-use-this-guide');
         }
         return res.redirect('../field-guide/' + fieldGuide.dashedName);
-      });
+      },
+      next
+    );
   }
-};
 
-function completedFieldGuide(req, res, next) {
+  function completedFieldGuide(req, res, next) {
     var fieldGuideId = req.body.fieldGuideInfo.fieldGuideId;
 
     req.user.completedFieldGuides.push(fieldGuideId);
@@ -123,10 +138,11 @@ function completedFieldGuide(req, res, next) {
       req.user.uncompletedFieldGuides.splice(index, 1);
     }
 
-  req.user.save(function (err) {
+    saveUser(req.user).subscribe(
-    if (err) {
+      function() {
-      return next(err);
-    }
         res.send(true);
-  });
+      },
-}
+      next
+    );
+  }
+};

server/utils/rx.js

@@ -1,6 +1,5 @@
 var Rx = require('rx');
 var debug = require('debug')('freecc:rxUtils');
-var slice = Array.prototype.slice;
 
 exports.saveUser = function saveUser(user) {
   return new Rx.Observable.create(function(observer) {