Brenna and Corinne's excellent node adventure!

.gitignore

@@ -1 +1,4 @@
 .DS_Store
+node_modules
+npm-debug.log
+db/

app.js

@@ -0,0 +1,68 @@
+var express = require('express');
+var path = require('path');
+var favicon = require('serve-favicon');
+var logger = require('morgan');
+var cookieParser = require('cookie-parser');
+var bodyParser = require('body-parser');
+
+// establish our routes based on route files
+var routes = require('./routes/index');
+var movies = require('./routes/movies');
+var customers = require('./routes/customers');
+var rentals = require('./routes/rentals');
+
+
+var app = express();
+
+// view engine setup
+app.set('views', path.join(__dirname, 'views'));
+app.set('view engine', 'jade');
+
+// uncomment after placing your favicon in /public
+//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
+app.use(logger('dev'));
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: false }));
+app.use(cookieParser());
+app.use(express.static(path.join(__dirname, 'public')));
+
+// Establishes our routes
+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) {
+  var err = new Error('Not Found');
+  err.status = 404;
+  next(err);
+});
+
+// error handlers
+
+// development error handler
+// will print stacktrace
+if (app.get('env') === 'development') {
+  app.use(function(err, req, res, next) {
+    res.status(err.status || 500);
+    res.render('error', {
+      message: err.message,
+      error: err
+    });
+  });
+}
+
+// production error handler
+// no stacktraces leaked to user
+app.use(function(err, req, res, next) {
+  res.status(err.status || 500);
+  res.render('error', {
+    message: err.message,
+    error: {}
+  });
+});
+
+
+module.exports = app;

bin/www

@@ -0,0 +1,90 @@
+#!/usr/bin/env node
+
+/**
+ * Module dependencies.
+ */
+
+var app = require('../app');
+var debug = require('debug')('C3Projects--VideoStoreAPI:server');
+var http = require('http');
+
+/**
+ * Get port from environment and store in Express.
+ */
+
+var port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+
+/**
+ * Create HTTP server.
+ */
+
+var server = http.createServer(app);
+
+/**
+ * Listen on provided port, on all network interfaces.
+ */
+
+server.listen(port);
+server.on('error', onError);
+server.on('listening', onListening);
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+  var port = parseInt(val, 10);
+
+  if (isNaN(port)) {
+    // named pipe
+    return val;
+  }
+
+  if (port >= 0) {
+    // port number
+    return port;
+  }
+
+  return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  var bind = typeof port === 'string'
+    ? 'Pipe ' + port
+    : 'Port ' + port;
+
+  // handle specific listen errors with friendly messages
+  switch (error.code) {
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
+      process.exit(1);
+      break;
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
+      process.exit(1);
+      break;
+    default:
+      throw error;
+  }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+  var addr = server.address();
+  var bind = typeof addr === 'string'
+    ? 'pipe ' + addr
+    : 'port ' + addr.port;
+  debug('Listening on ' + bind);
+}

controllers/customers.js

@@ -0,0 +1,52 @@
+"use strict";
+
+var Customer = require('../customers');
+var customer = new Customer();
+
+var sortCustomers = function(sort_type, params, res) {
+  var records_per_page = params.records_per_page;
+  var offset = params.offset;
+  var customers = customer.sort_by(sort_type, records_per_page, offset, function(customers) {
+    return res.status(200).json(customers);
+  });
+};
+
+exports.customersController = {
+
+  all: function all(req, res) {
+    var customers = customer.all(function(customers) {
+      return res.status(200).json(customers);
+    });
+  },
+
+  registered_at_sort: function registered_at_sort(req, res) {
+    var sort_type = "registered_at";
+    sortCustomers(sort_type, req.params, res);
+  },
+
+  name_sort: function name_sort(req, res) {
+    var sort_type = "name";
+    sortCustomers(sort_type, req.params, res);
+  },
+
+  postal_code_sort: function postal_code_sort(req, res) {
+    var sort_type = "postal_code";
+    sortCustomers(sort_type, req.params, res);
+  },
+
+  current_rentals: function current_rentals(req, res) {
+    var id = req.params.id;
+
+    customer.current_rentals(id, function(current_rentals) {
+      return res.status(200).json(current_rentals);
+    });
+  },
+
+  past_rentals: function past_rentals(req, res) {
+    var id = req.params.id;
+
+    customer.past_rentals(id, function(past_rentals) {
+      return res.status(200).json(past_rentals);
+    });
+  }
+}

controllers/movies.js

@@ -0,0 +1,82 @@
+"use strict";
+
+var Movie = require('../movies');
+var movie = new Movie();
+
+var sortMovies = function (sort_type, params, res) {
+  var records_per_page = params.records_per_page;
+  var offset = params.offset;
+  var movies = movie.sort_by(sort_type, records_per_page, offset, function(movies){
+    return res.status(200).json(movies);
+  });
+}
+
+exports.moviesController = {
+
+  all: function all(req, res) {
+    var movies = movie.all(function(movies) {
+      return res.status(200).json(movies);
+    });
+  },
+
+  release_date_sort: function release_date_sort(req, res) {
+    var sort_type = "release_date";
+    sortMovies(sort_type, req.params, res);
+  },
+
+  title_sort: function title_sort(req, res) {
+    var sort_type = "title";
+    sortMovies(sort_type, req.params, res);
+  },
+
+  movie_info: function movie_info(req, res) {
+    var movie_title = req.params.title;
+
+    movie.movie_info(movie_title, function(movie_info) {
+      return res.status(200).json(movie_info);
+    });
+  },
+
+  current_customers: function current_customers(req, res) {
+    var movie_title = req.params.title;
+
+    movie.current_customers(movie_title, function(current_customers) {
+      return res.status(200).json(current_customers);
+    });
+  },
+
+  past_customers: function past_customers(req, res) {
+    var movie_title = req.params.title;
+
+    movie.past_customers(movie_title, function(past_customers) {
+      return res.status(200).json(past_customers);
+    });
+  },
+
+  past_customers_id_sort: function past_customers_id_sort(req, res) {
+    var movie_title = req.params.title;
+    var sort_type = "customers.id";
+
+    movie.past_customers_sort(movie_title, sort_type, function(past_customers_sorted_by_id) {
+      return res.status(200).json(past_customers_sorted_by_id);
+    });
+  },
+
+  past_customers_name_sort: function past_customers_name_sort(req, res) {
+    var movie_title = req.params.title;
+    var sort_type = "customers.name";
+
+    movie.past_customers_sort(movie_title, sort_type, function(past_customers_sorted_by_name) {
+      return res.status(200).json(past_customers_sorted_by_name);
+    });
+  },
+
+  past_customers_checkout_date_sort: function past_customers_checkout_date_sort(req, res) {
+    var movie_title = req.params.title;
+    var sort_type = "rentals.check_out";
+
+    movie.past_customers_sort(movie_title, sort_type, function(past_customers_sorted_by_checkout_date) {
+      return res.status(200).json(past_customers_sorted_by_checkout_date);
+    });
+  }
+}

controllers/rentals.js

@@ -0,0 +1,46 @@
+"use strict";
+
+var Rental = require('../rentals');
+var rental = new Rental();
+
+exports.rentalsController = {
+  all_rentals: function all_rentals(req, res) {
+    var rentals = rental.all_rentals(function(rentals) {
+      return res.status(200).json(rentals);
+    });
+  },
+
+  current_customers: function current_customers(req, res) {
+    var movie_title = req.params.movie_title;
+
+    rental.current_customers(movie_title, function(current_customers){
+      return res.status(200).json(current_customers);
+    });
+  },
+
+  rental_log: function rental_log(req, res) {
+    var movie_title = req.params.movie_title;
+
+    rental.rental_log(movie_title, function(rental_log){
+      return res.status(200).json(rental_log);
+    });
+  },
+
+  overdue: function overdue(req, res) {
+    rental.overdue(function(overdue) {
+      return res.status(200).json(overdue);
+    });
+  },
+
+  check_out: function check_out(req, res) {
+    rental.check_out(req.body, function(check_out) {
+      return res.status(200).json(check_out);
+    });
+  },
+
+  check_in: function check_in(req, res) {
+    rental.check_in(req.body, function(check_in) {
+      return res.status(200).json(check_in);
+    });
+  }
+};

customers.js

@@ -0,0 +1,24 @@
+"use-strict";
+var sqlite3 = require('sqlite3').verbose();
+
+function Customer() {
+  this.table_name = "customers";
+}
+
+Customer.prototype = require('./database');
+
+Customer.prototype.current_rentals = function(id, callback) {
+  // list of current rentals out based on customer id
+  this.query("SELECT * FROM rentals WHERE customer_id=" + id + " AND check_in IS NULL;", function(res) {
+    callback(res);
+  });
+};
+
+Customer.prototype.past_rentals = function(id, callback) {
+  // list of past rentals based on customer id
+  this.query("SELECT * FROM rentals WHERE customer_id=" + id + " AND check_in IS NOT NULL ORDER BY check_out" + ";", function(res) {
+    callback(res);
+  });
+};
+
+module.exports = Customer;