Ania and Suze

app.js

@@ -4,10 +4,16 @@ 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 = express();
+module.exports = app;
+
+// database setup
+var connectionString = "postgres://localhost/video_store_api_" + app.get('env');
+var db = massive.connectSync({connectionString: connectionString});
+app.set('db', db);
 
 // view engine setup
 app.set('views', path.join(__dirname, 'views'));
@@ -23,6 +29,15 @@ app.use(express.static(path.join(__dirname, 'public')));
 
 app.use('/', routes);
 
+var customersRoutes = require('./routes/customers');
+app.use('/customers', customersRoutes);
+
+
+var moviesRoutes = require('./routes/movies');
+app.use('/movies', moviesRoutes);
+
+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');
@@ -53,6 +68,3 @@ app.use(function(err, req, res, next) {
     error: {}
   });
 });
-
-
-module.exports = app;

controllers/customers_controller.js

@@ -0,0 +1,63 @@
+var Customer = require("../models/customer");
+
+var CustomersController = {
+
+  getCustomers: function(req, res, next) {
+    // giving a callback function to handle error or render view
+    Customer.all(function(error, customers) {
+      if(error) {
+        var err = new Error("Error retrieving customer list:\n" + error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        res.json(customers)
+      }
+    });
+  },
+
+  sortBy: function(req, res, next) {
+    var n = req.query.n;
+    var p = req.query.p;
+    var field = String(req.params.field)
+
+    Customer.sortBy(field, n, p, function(error, customers) {
+      if(error) {
+        var err = new Error("Error retrieving customer list:\n" + error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        res.json(customers)
+      }
+    });
+
+  },
+
+  customerCurrent: function(req, res, next) {
+    var id = req.params.id
+
+    Customer.current([id], function(error, movies) {
+      if(error) {
+        var err = new Error("Error retrieving current movies for this customer:\n" + error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        res.json(movies)
+      }
+    })
+  },
+
+  customerHistory: function(req, res, next) {
+    var id = req.params.id
+
+    Customer.history([id], function(error, movies) {
+      if(error) {
+        var err = new Error("Error retrieving historic movies for this customer:\n" + error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        res.json(movies)
+      }
+    })
+  }
+}
+module.exports = CustomersController

controllers/movies_controller.js

@@ -0,0 +1,82 @@
+var Movie = require("../models/movie");
+var Customer = require("../models/customer");
+var Rental = require("../models/rental");
+
+var MoviesController = {
+  listMovies: function(req, res, next) {
+    // giving a callback function to handle error or render view
+    Movie.all(function(error, movies) {
+      if(error) {
+        var err = new Error("Error retrieving movie list:\n" + error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        res.json(movies)
+        // var locals = { movies: movies }
+        // res.render("movies/index", locals);
+      }
+    });
+  },
+
+  sortBy: function(req, res, next) {
+    var options = {
+      order: req.params.field,
+      limit: req.query.n,
+      offset: req.query.p
+    }
+
+    Movie.sortBy(options, function(error, movies) {
+      if(error) {
+        var err = new Error("Error retrieving sorted movie list:\n" + error.message);
+        err.status = 500;
+        next(err);
+      } else {
+        res.json(movies)
+      }
+    });
+ },
+
+ current: function(req, res, next) {
+   var movie = req.params.title;
+
+   Movie.find_customers_by_movie_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);
+     }
+   })
+ },
+
+  history: function(req, res, next) {
+    var movie = req.params.title;
+    var field = req.params.field;
+
+    Movie.find_customers_by_movie_title_history([movie, field], 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);
+      }
+    })
+   }
+}
+module.exports = MoviesController;

controllers/rentals_controller.js

@@ -0,0 +1,90 @@
+var Movie = require("../models/movie");
+var Customer = require("../models/customer");
+var Rental = require("../models/rental");
+
+var RentalsController = {
+
+  findMovie: function(req, res, next) {
+  var title = req.params.title;
+
+    Rental.all([title], function (error, rentals) {
+      if(error) {
+        var err = new Error("Error retrieving movie info:\n" + error.message);
+          err.status = 500;
+          next(err);
+      } else {
+        res.json(rentals)
+      }
+    })
+  },
+
+  sortBy: function(req, res, next) {
+    var movie = req.params.title;
+
+    Rental.customers_current_rentals(movie, function(error, 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);
+      }
+    })
+  },
+
+  checkout: function(req, res, next) {
+    var movie = req.params.title;
+    var customer_id = req.body.customer_id;
+    console.log(movie, customer_id);
+
+    Rental.createCheckOut(movie, customer_id, function(error) {
+      console.log("in createCheckOut method")
+      if(error) {
+        var err = new Error("Rental checkout failed");
+        err.status = 404;
+        next(err);
+      } else {
+        res.json("rental_checkout works");
+      }
+    })
+  },
+
+  return: function(req, res, next) {
+    var movie = req.params.title;
+    var customer_id = req.body.customer_id;
+
+    console.log(movie, customer_id);
+    Rental.returnRental(movie, customer_id, function(error) {
+      console.log("in RETURN method")
+      if(error) {
+        var err = new Error("Rental return failed");
+        err.status = 404;
+        next(err);
+      } else {
+        res.json({returnRental: "Rental was properly returned"});
+      }
+    })
+  },
+
+  overdue: function(req, res, next) {
+    console.log("1st stop");
+    Rental.findOverdue(function(error, customers) {
+      if (error) {
+        var err = new Error("Error in finding overdue ");
+        err.status = 404;
+        next(err);
+      } else {
+        console.log("Final")
+        res.json(customers)
+      }
+    })
+  }
+}
+module.exports = RentalsController;

db/movie/customers_by_movie_title.sql

@@ -0,0 +1,10 @@
+SELECT
+  customers.name,
+  customers.phone,
+  customers.account_credit
+FROM customers
+  INNER JOIN rentals ON customers.id = rentals.customer_id
+  INNER JOIN movies ON rentals.movie_id = movies.id
+WHERE
+  movies.title ILIKE $1 AND
+  rentals.return_date IS NULL;

db/rental/customers_current_rentals.sql

@@ -0,0 +1,10 @@
+SELECT
+  customers.name,
+  customers.phone,
+  customers.account_credit
+FROM customers
+  INNER JOIN rentals ON customers.id = rentals.customer_id
+  INNER JOIN movies ON rentals.movie_id = movies.id
+WHERE
+  movies.title ILIKE $1 AND
+  rentals.return_date IS NULL;

db/seeds/rentals.json

@@ -0,0 +1,54 @@
+[
+{
+"movie_id": 1,
+"customer_id": 6,
+"checkout_date": "2015-06-10",
+"due_date": "2015-06-20",
+"return_date": "2015-06-20"
+},
+
+{
+"movie_id": 2,
+"customer_id": 4,
+"checkout_date": "2014-03-10",
+"due_date": "2014-03-20",
+"return_date": "2014-03-20"
+},
+
+{
+"movie_id": 3,
+"customer_id": 9,
+"checkout_date": "2015-08-11",
+"due_date": "2015-08-21"
+},
+
+{
+"movie_id": 4,
+"customer_id": 6,
+"checkout_date": "2015-08-11",
+"due_date": "2015-08-21",
+"return_date": "2015-08-28"
+},
+
+{
+"movie_id": 5,
+"customer_id": 1,
+"checkout_date": "2016-02-10",
+"due_date": "2016-02-20"
+},
+
+{
+"movie_id": 6,
+"customer_id": 6,
+"checkout_date": "2016-06-16",
+"due_date": "2016-06-26"
+},
+
+{
+"movie_id": 7,
+"customer_id": 9,
+"checkout_date": "2015-08-11",
+"due_date": "2015-08-21",
+"return_date": "2015-08-28"
+}
+]

db/setup/schema.sql

@@ -0,0 +1,41 @@
+DROP TABLE IF EXISTS rentals;
+DROP TABLE IF EXISTS movies;
+DROP TABLE IF EXISTS customers;
+CREATE TABLE movies(
+  id serial PRIMARY KEY,
+  title text,
+  overview text,
+  release_date date,
+  inventory integer
+);
+
+CREATE INDEX movies_title ON movies (title);
+CREATE INDEX movies_release_date ON movies (release_date);
+
+/*customers */
+CREATE TABLE customers(
+  id serial PRIMARY KEY,
+  name text,
+  registered_at text,
+  address text,
+  city text,
+  state text,
+  postal_code integer,
+  phone text,
+  account_credit decimal
+);
+
+CREATE INDEX customers_name ON customers (name);
+
+/* rentals */
+CREATE TABLE rentals(
+  id serial PRIMARY KEY,
+  movie_id integer references movies(id),
+  customer_id integer references customers(id),
+  checkout_date date,
+  due_date date,
+  return_date date
+);
+
+CREATE INDEX rentals_customer_id ON rentals (customer_id);
+CREATE INDEX rentals_movie_id ON rentals (movie_id);