Adding the ability to update items/categories through post requests.

lib/mongo/dbhelper.js

@@ -47,6 +47,10 @@ exports.remove = function(db,docType,id, callback){
   remove(db,docType,id, callback)
 }
 
+exports.updateByJSON = function(objJSON,changeJSON,db,docType,callback){
+  updateByJSON(objJSON,changeJSON,db,docType,callback);
+}
+
 getDatabase = function(){
   if(typeof dbinfo.DBURL() !== 'string') console.log("URL is bad");
   if(typeof dbinfo.DBPORT() !== 'number') console.log("PORT is bad");
@@ -129,9 +133,11 @@ findDocumentsMapped = function(db,docType,callback) {
 
 
 findByIdentifier = function(db,docType,id, callback) {
+    console.log(id)
     this.getCollection(db,docType,function(error, collection) {
       if( error ) callback(error,null)
       else {
+        console.log("ID is "+id)
         collection.findOne({_id: collection.db.bson_serializer.ObjectID.createFromHexString(id)}, function(error, result) {
           if( error ) callback(error)
           else {
@@ -155,6 +161,23 @@ save = function(db, docType, doc, callback) {
     });
 };
 
+/*
+ *Generic function to update
+ *objJSON: a JSON object that has the values to search for (similar to where in SQL)
+ *changeJSON: Update JSON (similar to set values)
+ */
+updateByJSON = function(objJSON,changeJSON,db,docType,callback){
+  var options = {safe:true,multi:true,};
+  getCollection(db, docType, function(error, collection) {
+    if(error != undefined){
+      callback(error,null)
+    }
+    else{
+      collection.update(objJSON,changeJSON,callback)
+    }
+  })
+}
+
 remove = function(db,docType,id, callback){
     var id = db.bson_serializer.ObjectID.createFromHexString(id);
     this.getCollection(db,docType,function(error, collection) {
@@ -166,4 +189,4 @@ remove = function(db,docType,id, callback){
          });
       }
     })
-};
+}

lib/mongo/document.js

@@ -57,6 +57,10 @@ DocumentProvider.prototype.save = function(item, callback) {
   dbhelper.save(this.db,this.TYPE,item,callback)
 };
 
+DocumentProvider.prototype.updateJSON = function(whereJSON, valuesJSON, callback){
+  dbhelper.updateByJSON(whereJSON, valuesJSON, this.db,this.TYPE, callback);
+}
+
 DocumentProvider.prototype.remove = function(id, callback){
   dbhelper.remove(this.db,this.TYPE,id,callback)
 };

lib/mongo/rest.js

@@ -50,6 +50,9 @@ exports.getImage = function(req, res){
   fileProvider.streamFile(res, fileid, 'image/jpg')
 }
 
+
+/* Catalog Entries */
+
 exports.getCatalogEntries= function (req, res, next){
   documentProvider.setType('items')
   documentProvider.findAllMapped(function (err, catalog) {
@@ -117,9 +120,7 @@ exports.getCategories= function (req, res, next){
   })
 }
 
-
-
-exports.getItemsForCategory = function(req,res,next){
+exports.getCategory = function(req,res,next){
   documentProvider.setType('categories')
   var objectId  
   try{
@@ -130,27 +131,69 @@ exports.getItemsForCategory = function(req,res,next){
     return next()
   }
   documentProvider.findByJSON({_id:objectId}, function(err,categories){
-    if(err != null){
-      req.err = err
+    checkCategoryFromJSON(categories, err, function(err, category){
+      if(err != undefined){
+        req.category = category
+      }
+      else{
+        req.err = err
+      }
       return next()
+    })
+  })
+}
+
+checkCategoryFromJSON = function(categories, err, callback){
+    var category;
+    var error;
+    if(err != null){
+      error = err
+      callback(error,category)
     }
     else if(categories == null || categories.length == 0){
-      req.err = "Category Undefined"
+      error = "Category Undefined"
       console.log("Error Set")
-      return next()
+      callback(error,category)
     }
     else if(categories.length != 1){
-      req.err = "Two Categories Share the same ID, Cannot retrieve"
+      req.error = "Two Categories Share the same ID, Cannot retrieve"
       console.log("Strange things are afoot: Two categories share the same ID")
-      return next()
+      callback(error,category)
     }
     else {
-      var category = categories[0]
+      category = categories[0]
       getExplodedItemsForCategory(category,function(err){
-        req.category = category
-        return next()
+        callback(err,category)
       })
     }
+
+}
+
+
+exports.getItemsForCategory = function(req,res,next){
+  documentProvider.setType('categories')
+  var objectId  
+  try{
+    objectId=new BSON.ObjectID(req.params.categoryId);
+  }
+  catch(exception){
+    req.err = exception
+    return next()
+  }
+  documentProvider.findByJSON({_id:objectId}, function(err,categories){
+    checkCategoryFromJSON(categories, err, function(err, category){
+      console.log("ERR is "+JSON.stringify(err))
+      if(err == undefined){
+        console.log("Category: "+category)
+        req.category = category
+      }
+      else{
+        console.log("else")
+        req.err = err
+      }
+      console.log("returning "+JSON.stringify(category))
+      return next()
+    })
   })
 }
 
@@ -171,7 +214,12 @@ getExplodedItemsForCategory = function (category,callback){
     documentProvider.setType('items')
     documentProvider.findByJSON({_id:{$in:itemIds}},function(err, items){
       //console.log("ITEMS: "+JSON.stringify(items))
+      if(items == undefined){
+        //console.log("making a new array")
+        items = []
+      }
       category.explodedItems = items
+      console.log("Category should have exploded " + JSON.stringify(category))
       finalCallback(null)
     })
   }
@@ -240,9 +288,61 @@ exports.postCategory = function (req, res, next){
   })
 }
 
+exports.putCategory = function(req, res){
+  //TODO: We should check the type to ensure JSON
+  res.set({
+    'Content-Type': 'application/json',
+    'type': 'get',
+    'dataType': 'json'
+  })
+  console.log(req.body)
+  var updateObj = req.body
+  console.log(JSON.stringify(updateObj))
+  documentProvider.setType('categories')
+  getIdFromString(updateObj.categoryId, function(err, id){
+    if(err != undefined){
+      console.log(err)
+      res.json(500, { error: err })
+    }
+    else{
+      documentProvider.findByJSON({_id:id}, function(err,categories){
+        if(err != undefined){
+           console.log(err)
+           res.json(500, { error: err })
+        }
+        else if(categories.length <= 0){
+          err = "There were no categories found"
+          console.log(err)
+          res.json(500, { error: err })
+        }
+        else{
+          documentProvider.updateJSON({_id:id},updateObj.updateValues,function(err){
+            if(err==undefined){
+              res.json({ message: "Category Updated" })
+            }
+            else{
+              res.json(500, { error: err })
+            }
+          })
+        }
+      })
+    }
+  })
+}
+
 exports.deleteCatalogEntry = function(req, res, next){
   documentProvider.setType('items')
   documentProvider.remove(req.params.itemid,function(){
     return next()
   })
 }
+
+getIdFromString = function(id, callback){
+  try{
+    var objectId=new BSON.ObjectID(id);
+    callback(null,objectId)    
+  }
+  catch(exception){
+    callback(exception,null)
+  }
+}

package.json

@@ -1,6 +1,6 @@
 {
   "name": "bullettrain",
-  "version": "1.0.6",
+  "version": "1.0.7",
   "description": "Simple Ecommerce",
   "keywords": [
     "OpenShift",