Video Store Ada Project

.gitignore

@@ -1,2 +1,4 @@
 .DS_Store
 node_modules/
+*.log
+coverage/

app.js

@@ -4,14 +4,20 @@ var favicon = require('serve-favicon');
 var logger = require('morgan');
 var cookieParser = require('cookie-parser');
 var bodyParser = require('body-parser');
+var massive = require('massive');
 
-var routes = require('./routes/index');
+var app = module.exports = express();
 
-var app = express();
+// database setup
+var connectionString = "postgres://localhost/videoStore";
+// the node module that is used to access the database
+var db = massive.connectSync({connectionString: connectionString});
+// this gives me a way to grab the database from the code, like in the model
+app.set('db', db);
 
 // view engine setup
 app.set('views', path.join(__dirname, 'views'));
-app.set('view engine', 'jade');
+app.set('view engine', 'ejs');
 
 // uncomment after placing your favicon in /public
 //app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
@@ -21,8 +27,18 @@ app.use(bodyParser.urlencoded({ extended: false }));
 app.use(cookieParser());
 app.use(express.static(path.join(__dirname, 'public')));
 
+var routes = require('./routes/index');
 app.use('/', routes);
 
+var moviesRoutes = require('./routes/movies');
+app.use('/movies', moviesRoutes);
+
+var customersRoutes = require('./routes/customers');
+app.use('/customers', customersRoutes);
+
+var rentalsRoutes = require('./routes/rentals');
+app.use('/rentals', rentalsRoutes);
+
 // catch 404 and forward to error handler
 app.use(function(req, res, next) {
   var err = new Error('Not Found');

controllers/customers_controller.js

@@ -0,0 +1,97 @@
+var Customers = require("../models/customers");
+var Rentals = require("../models/rentals");
+var History = require("../models/history");
+
+var CustomersController = {
+  index: function(req, res, next) {
+    Customers.all(function(error, customers) { // this is a callback
+      if(error) {
+        var err = new Error("Error retrieving customers list:\n" + error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        var obj = {};
+        if (customers.length === 0) {
+          obj["status"] = 204;
+        } else {
+          obj["status"] = 200;
+        }
+      }
+      obj["customers"] = customers;
+      res.json(obj);
+    });
+  },
+
+  // the word phone breaks the code:
+  sort: function(req, res, next) {
+    if(req.params.column === "name" || req.params.column === "registered_at" || req.params.column === "postal_code") {
+
+      //Send in an ORDER clause and a LIMIT with OFFSET
+      var options = {
+        limit : req.query.n,
+        order : req.params.column,
+        offset: req.query.p
+      };
+    // products ordered in descending fashion
+    // takes 2 parameters
+    // options and the callback fucntion
+      Customers.sort_by(options, function(error, customers) { // this will return and array of customers
+        if(error) {
+          var err = new Error("No such customer");
+          err.status = 404;
+          next(err);
+        } else {
+          var obj = {};
+          if (customers.length === 0) {
+            obj["status"] = 204;
+          } else {
+            obj["status"] = 200;
+        }
+        obj["customers"] = customers;
+        res.json(obj);
+        }
+      });
+    } else {
+      var obj = {};
+      obj["status"] = 400;
+      obj["message"] = "invalid request";
+      res.json(obj);
+    }
+  },
+  // this is a property whose value is a function (this is now a method)
+  // this is the response from node
+  current: function(req, res, next) {
+    //model has a find method that takes in 2 arguments (id, callback function)
+    Rentals.find_by_customer(req.params.id, function(error, rentals) {
+      if(error) {
+        var err = new Error("No such account");
+        err.status = 404;
+        next(err);
+      } else {
+        res.json(rentals); // write out the rentals as json
+      }
+    });
+  },
+
+  history: function(req, res, next) {
+    //model has a find method that takes in 2 arguments (id, callback function)
+    History.getPastRentalHistory(req.params.id, function(error, history) {
+      if(error) {
+        var err = new Error("No history at this store");
+        err.status = 404;
+        next(err);
+      } else {
+        var obj = {};
+        if (history.length === 0) {
+          obj["status"] = 204;
+        } else {
+          obj["status"] = 200;
+        }
+        obj["history"] = history;
+        res.json(obj); // write out the history as json
+      }
+    });
+  }
+};
+
+module.exports = CustomersController;

controllers/index_controller.js

@@ -0,0 +1,21 @@
+var doc = require ("../doc.json");
+
+
+var IndexController = {
+  locals: {
+    documentation: doc
+  },
+
+  getJSON: function (req, res, next) {
+    res.json(200, doc);
+  },
+
+  getHTML: function(req, res, next) {
+    // console.log(string_docs);
+    res.render('docs', IndexController.locals);
+  }
+};
+
+
+
+module.exports = IndexController;

controllers/movies_controller.js

@@ -0,0 +1,68 @@
+var Movies = require("../models/movies");
+var Rentals = require('../models/rentals');
+var Customers = require('../models/customers');
+
+var MoviesController = {
+  index: function(req, res, next) {
+    Movies.all(callback(res, "movies"));
+  },
+
+  sort: function(req, res, next) {
+    var order_by = req.params.column;
+    var options = {
+      limit : req.query.n,
+      offset: req.query.p
+    };
+
+    if (order_by === "release_date" || order_by === "release-date") {
+      options["order"] = "release_date";
+    } else if (order_by === "title") {
+      options["order"] = "title";
+    } else {
+      options["order"] = "id";
+    }
+
+    Movies.sort_by(options, callback(res, "movies"));
+  },
+
+  current: function(req, res, next) {
+    var movie = req.params.title;
+    Movies.find_customers_by_title(movie, callback(res, "customers"));
+  },
+
+  history: function(req, res, next) {
+    var movie = req.params.title;
+    var column = req.params.column;
+    var order_by;
+
+    if (column === 'name') {
+      order_by = 'name';
+    } else if (column === 'checkout_date') {
+      order_by = 'checkout_date';
+    }
+
+    Movies.find_customers_by_history(movie, order_by, callback(res, "customers"));
+  }
+};
+
+function callback(res, type) {
+  return function(error, result) { // this is a callback
+    if(error) {
+      var err = new Error("Error retrieving results:\n" + error.message);
+      err.status = 500;
+      res.render(err);
+    } else {
+      var obj = {};
+      if (result.length === 0) {
+        obj["status"] = 204;
+      } else {
+        obj["status"] = 200;
+      }
+      obj[type] = result;
+      res.json(obj);
+    }
+  }
+}
+
+module.exports = MoviesController;
+

controllers/rentals_controller.js

@@ -0,0 +1,123 @@
+var Rentals = require('../models/rentals');
+var Movies = require("../models/movies");
+var Customers = require("../models/customers");
+var History = require("../models/history");
+
+var RentalsController = {
+
+  find_movie: function(req, res, next) {
+    var movie = req.params.title;
+
+    Movies.find(movie, function(error, found_movie) {
+      if(error) {
+        var err = new Error("No such movie");
+        err.status = 404;
+        next(err);
+      } else {
+        obj = {}
+        obj['status'] = 200;
+        obj['Movie Info'] = {};
+        obj['Movie Info']['Synopsis'] = found_movie.overview;
+        obj['Movie Info']['Release Date'] = found_movie.release_date;
+        obj['Movie Info']['Total Inventory'] = found_movie.inventory;
+        Rentals.available(found_movie.id, function(err, number){
+          obj['Movie Info']['Available Inventory'] = number
+          res.json(obj);
+        });
+      }
+    });
+  },
+
+  current_customers: function(req, res, next) {
+    var movie = req.params.title;
+
+    Rentals.find_customers_by_title(movie, function(error, customers) {
+      if(error) {
+        var err = new Error("No such movie");
+        err.status = 404;
+        next(err);
+      } else {
+        var obj = {};
+        if (customers.length === 0) {
+          obj["status"] = 204;
+        } else {
+          obj["status"] = 200;
+        }
+        obj["customers"] = customers;
+        res.json(obj);
+      }
+    })
+  },
+
+  checkout: function(req, res, next) {
+    var customer_id = req.params.id;
+    var movie = req.params.title;
+
+
+    Rentals.mark_as_checkout (movie, customer_id, function(error, rental_array, customer_updated) {
+      if(error) {
+        var err = new Error(error.message);
+        err.status = 404;
+        next(err);
+      } else {
+        var rental_id = rental_array[0].id
+        History.create_record(rental_id, customer_id, function(error, history_result) {
+          if(error) {
+            var err = new Error(error.message);
+            err.status = 404;
+            next(err);
+          } else {
+            obj = {}
+            obj["Status"] = 200;
+            obj["Message"] = "Checkout has been processed succesfully"
+            obj["Return day"] = history_result["return_date"]
+            obj["Customer's Name"] = customer_updated[0]["name"]
+            obj["Customer's Credit"] = customer_updated[0]["account_credit"]
+
+            res.json(obj);
+          }
+        });
+      }
+    });
+  },
+
+  // include customer name, movie title, check-out date, and return date
+  overdue: function(req, res, next) {
+    Rentals.get_overdue(function(error, customers) {
+      if(error) {
+        var err = new Error(error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        obj = {};
+        if (customers.length === 0) {
+          obj["status"] = 204;
+        } else {
+          obj["status"] = 200;
+        }
+        obj["customers"] = customers
+        res.json(obj);
+      }
+    })
+  },
+
+  return_a_rental: function(req, res, next) {
+    var customer_id = req.params.id;
+    var movie = req.params.title;
+    Rentals.return_rental(customer_id, movie, function(error, updated_rental) {
+      if(error) {
+        var err = new Error(error.message);
+        err.status = 404;
+        next(err);
+      } else {
+        obj = {}
+        obj["Status"] = 200;
+        obj["Message"] = "Return has been processed succesfully"
+        obj["Rental info"] = updated_rental[0]
+        res.json(obj);
+      }
+    })
+  }
+};
+
+module.exports = RentalsController;