Done

.gitignore

@@ -1,2 +1,3 @@
 .DS_Store
+coverage/
 node_modules/

app.js

@@ -4,24 +4,51 @@ var favicon = require('serve-favicon');
 var logger = require('morgan');
 var cookieParser = require('cookie-parser');
 var bodyParser = require('body-parser');
+var massive = require("massive");
+var app = module.exports = express();
 
-var routes = require('./routes/index');
+// view engine setup
+// app.set('views', path.join(__dirname, 'views'));
+// app.set('view engine', 'ejs');
+
+// var connectionString = "postgres://localhost/video_store"
+var connectionString = "postgres://localhost/video_store_" + app.get('env');
+
+// connect to Massive and get the db instance. You can safely use the
+// convenience sync method here because its on app load
+// you can also use loadSync - it's an alias
+var massiveInstance = massive.connectSync({connectionString : connectionString})
+
+// Set a reference to the massive instance on Express' app:
+app.set('db', massiveInstance);
 
-var app = express();
 
 // 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')));
 app.use(logger('dev'));
+// this will terminate the request with an error 400 if the POST body
+// doesn't contain valid json
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({ extended: false }));
 app.use(cookieParser());
 app.use(express.static(path.join(__dirname, 'public')));
 
+var routes    = require('./routes/index');
+var customers = require('./routes/customers');
+var movies    = require('./routes/movies');
+var rentals   = require('./routes/rentals');
+
+
+
 app.use('/', routes);
+app.use('/customers', customers);
+app.use('/movies', movies);
+app.use('/rentals', rentals);
+
 
 // catch 404 and forward to error handler
 app.use(function(req, res, next) {

controllers/customers.js

@@ -0,0 +1,59 @@
+var Customer = require("../models/customers_model");
+var Rental = require("../models/rentals_model");
+
+
+var CustomersController = {
+	getCustomers: function(req, res) {
+		Customer.all(function(error, customers) {
+			if(error=="Could not retrieve customers") {
+				res.status(404).send(error)
+			} else if (error) {
+				var err = "Please try again"
+				res.status(500).send(err)
+			} else {
+				res.json(customers)
+			}
+		})
+	},
+	// customer id, sort column, offest ?????
+	subsetCustomers: function(req, res) {
+		Customer.sort(req.params.column, req.query.p, req.query.n, function(error, data) {
+			if(error=="Could not retrieve customers") {
+				res.status(404).send(error)
+			} else if (error) {
+				var err = "Please try again"
+				res.status(500).send(err)
+			} else {
+				res.json(data)
+			}
+		})
+	},
+
+	// customer id, all rentals attached to customer id within data params
+	getCustomersCurrent: function(req, res) {
+		Rental.getCurrentRentals(req.params.customer_id, function(error, data) {
+			if(error=="No results from database") {
+				res.status(404).send(error)
+			} else if (error) {
+				var err = "Please try again"
+				res.status(500).send(err)
+			} else {
+				res.json(data)
+			}
+		})
+	},
+
+	getCustomersHistory: function(req, res) {
+		Rental.getPastRentals(req.params.customer_id, function(error, data) {
+			if(error=="No past rentals") {
+				res.status(404).send(error)
+			} else if (error) {
+				var err = "Please try again"
+				res.status(500).send(err)
+			} else {
+				res.json(data)
+			}
+		})
+	}
+}
+module.exports = CustomersController

controllers/docs.js

@@ -0,0 +1,16 @@
+var docs = require('../public/docs.json');
+
+var DocsController = {
+	getDocs: function(req, res) {
+		res.render('docs', { 
+			title: 'The Docs',
+			docs: docs
+		});
+	},
+
+	getJsonDocs: function(req, res) {
+		res.json(docs);
+	}
+}
+
+module.exports = DocsController

controllers/movies.js

@@ -0,0 +1,50 @@
+var Movie = require("../models/movies_model");
+var Rental = require("../models/rentals_model");
+
+
+MoviesController = {
+	getMovies: function(req, res) {
+		Movie.all(function(error, movies) {
+			if(error=="Could not retrieve movies") {
+				res.status(404).send(error)
+			} else if (error) {
+				var err = "Please try again"
+				res.status(500).send(err)
+			} else {
+				res.json(movies)
+			}
+		})
+	},
+
+	subsetMovies: function(req, res) {
+		Movie.sort(req.params.column, req.query.p, req.query.n, function(error, data) {
+			if(error=="Could not retrieve movies") {
+				res.status(404).send(error)
+			} else if (error) {
+				var err = "Please try again"
+				res.status(500).send(err)
+			} else {
+				res.json(data)
+			}
+		})
+	},
+
+	getRentalsCustomers: function(req, res) {
+			Rental.getCustomers(req.params.title, function(error, checked_out) {
+			if(error=="Could not retrieve movies") {
+				res.status(404).send(error)
+			} else if (error) {
+				var err = "Please try again"
+				res.status(500).send(err)
+			} else {
+					res.json(checked_out)
+			}
+		})
+	},
+
+	getMoviesHistory: function(req, res) {
+
+	}
+}
+
+module.exports = MoviesController

controllers/rentals.js

@@ -0,0 +1,72 @@
+var Rental = require("../models/rentals_model");
+var Movie = require("../models/movies_model");
+
+RentalsController = {
+	getRentals: function(req, res) {
+		Movie.findMovie(req.params.title, function(error, movie) {
+			if(error) {
+				var err = new Error("No such movie");
+				err.status = 404;
+			} else {
+				Rental.getCurrentlyCheckedOut(movie, function(error, checked_out) {
+					var return_data = {
+						title:movie.title,
+						overview:movie.overview,
+						release_date:movie.release_date,
+						total_inventory:movie.inventory,
+						available_copies:(parseInt(movie.inventory))-(parseInt(checked_out))
+					} 
+					res.json(return_data)
+				})
+			}
+
+		})
+	},
+
+	getRentalsCustomers: function(req, res) {
+			Rental.getCustomers(req.params.title, function(error, checked_out) {
+			if(error) {
+				var err = new Error("No one has that movie checked out");
+				err.status = 404;
+			} else {
+					res.json(checked_out)
+			}
+		})
+	},
+
+	getRentalsCheckOut: function(req, res, next) {
+		Rental.getCheckout(req.params.title, req.params.customerid, function(error, checked_out) {
+			if(error) {
+				var err = new Error("No one has that movie checked out");
+				err.status = 404;
+			} else {
+				res.json(checked_out)
+			}
+		});
+	},
+
+	getRentalsReturn: function(req, res) {
+		Rental.getReturn(req.params.id, function(error, returned) {
+			if(error) {
+				var err = new Error("No one has that movie checked out");
+				err.status = 404;
+			} else {
+				res.json(returned)
+			}
+		});
+
+	},
+
+	getRentalsOverdue: function(req, res) {
+		Rental.getOverdue(function(error, over_due) {
+			if(error) {
+				var err = new Error("Ooops");
+				err.status = 404;
+			} else {
+				res.json(over_due)
+			}
+		});
+	}
+}
+
+module.exports = RentalsController

db/seeds/rentals.json

@@ -0,0 +1,42 @@
+[
+{
+"movie_id": 2,
+"customer_id": 5,
+"created_date": "1980-06-16",
+"due_date": "1980-06-18",
+"returned": true,
+"returned_date": "1980-06-18T20:24:01.218Z"
+},
+{
+"movie_id": 2,
+"customer_id": 5,
+"created_date": "1960-06-16",
+"due_date": "2016-06-18T20:24:01.218Z",
+"returned": false
+},
+{
+"movie_id": 2,
+"customer_id": 5,
+"created_date": "1960-06-16",
+"due_date": "1960-06-18",
+"returned": true,
+"returned_date": "1960-06-18T20:24:01.218Z"
+},
+{
+"movie_id": 2,
+"customer_id": 5,
+"created_date": "1970-06-16",
+"due_date": "1970-06-18",
+"returned": true,
+"returned_date": "1967-06-18T20:24:01.218Z"
+},
+{
+"movie_id": 10,
+"customer_id": 4,
+"created_date": "1960-06-16",
+"due_date": "1960-06-17",
+"returned": false
+}
+
+
+]

db/setup/schema.sql

@@ -0,0 +1,32 @@
+DROP TABLE IF EXISTS movies;
+CREATE TABLE movies(
+  id serial PRIMARY KEY,
+  title text,
+  overview text,
+  release_date date,
+  inventory integer
+);
+
+DROP TABLE IF EXISTS rentals;
+CREATE TABLE rentals(
+  id serial PRIMARY KEY,
+  movie_id int,
+  customer_id int,
+  created_date date,
+  due_date date,
+  returned boolean,
+  returned_date date
+);
+
+DROP TABLE IF EXISTS customers;
+CREATE TABLE customers(
+  id serial PRIMARY KEY,
+  name text,
+  registered_at timestamp,
+  address text,
+  city text,
+  state text,
+  postal_code text,
+  phone text,
+  account_credit decimal 
+);

models/customers_model.js

@@ -0,0 +1,37 @@
+var app = require("../app");
+var db = app.get("db");
+
+var Customer = function(id) {
+  this.id = id;
+}
+
+Customer.all = function(callback) {
+  db.customers.find(function(error, customers) {
+    if (error|| !customers) {
+      callback(error || new Error("Could not retrieve customers"), undefined);
+    } else {
+      callback(null, customers.map(function(customer) {
+        return new Customer(customer.id);
+      }))
+    };
+  })
+};
+
+Customer.sort = function(column, p, n, callback) {
+  // sort by column, for n number of records starting at p
+ db.customers.find({}, {
+    order: column,
+    limit: n,
+    offset: p
+  }, function(error, customers) {
+    if (error || !customers) {
+      callback(error || new Error("Could not retrieve customers"), undefined)
+    } else {
+      callback(null, customers.map (function (customer) {
+        return customer
+      }))
+    }
+  })
+}
+
+module.exports = Customer;