Completed VideoStore API

.gitignore

@@ -1 +1,6 @@
 .DS_Store
+
+# Let package.json handle dependencies
+/node_modules
+
+db/test.db

README.md

@@ -2,6 +2,14 @@ Alice & Anita
 
 # Project: VideoStoreAPI
 
+###How to run
+1. Clone the repo.
+2. Install all packages by running `npm install`.
+3. See tests by running `npm test`.
+4. See instructions for using our endpoints [here](./endpoint-readme.md).
+
+-------------
+
 The overall goal of this project is to create a system that a video store (remember those?) could use to track their inventory of rental videos and their collection of customers.
 
 We will use [NodeJS](https://nodejs.org/en/) to construct a RESTful API. The goal of this API is to quickly serve information about the store's video collection, customer information, and to update rental status. This repository provides two JSON datafiles to serve as the initial seeds for this system.

app.js

@@ -0,0 +1,71 @@
+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');
+
+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')));
+
+// Are we going to use this??
+// register root routes
+var routes = require('./routes/index');
+app.use('/', routes);
+
+// register movies routes
+var movie_routes = require('./routes/movies');
+app.use('/movies', movie_routes);
+
+// register customer routes
+var customer_routes = require('./routes/customers');
+app.use('/customers', customer_routes);
+
+// register rental routes
+var rental_routes = require('./routes/rentals');
+app.use('/rentals', rental_routes);
+
+// 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);
+}

database_adapter.js

@@ -0,0 +1,107 @@
+"use strict";
+
+var sqlite3 = require('sqlite3').verbose(),
+    db_env = process.env.DB || 'development';
+
+module.exports = {
+  find_all: function(callback) {
+    var db        = new sqlite3.Database('db/' + db_env + '.db');
+    var statement = "SELECT * FROM " + this.table_name;
+
+    db.all(statement, function(err, res) {
+      if (callback) { callback(err, res); }
+      db.close();
+    });
+  },
+
+  // get returns one record, making this emulate Active Record's find_by
+  find_by: function(column, value, callback) {
+    var db        = new sqlite3.Database('db/' + db_env + '.db');
+    var statement = "SELECT * FROM " + this.table_name + " WHERE " + column + " LIKE ?";
+
+    db.get(statement, value, function(err, res) {
+      if (callback) { callback(err, res); }
+      db.close();
+    });
+  },
+
+  // returns array of records
+  where: function(columns, values, callback) {
+    var db = new sqlite3.Database('db/' + db_env + '.db');
+    var where_statements = [];
+
+    // where_statements => ["city = ?", "state = ?"]
+    for (var i = 0; i < columns.length; i++) {
+      where_statements.push(columns[i] + " = ?");
+    }
+    // where_statement => "city = ? AND state = ?"
+    var where_statement = where_statements.join(" AND ");
+
+    var statement = "SELECT * FROM " + this.table_name + " WHERE " + where_statement;
+
+    db.all(statement, values, function(err, res) {
+      if (callback) { callback(err, res); }
+      db.close();
+    });
+  },
+
+  where_in: function(column, values, callback) {
+    var db = new sqlite3.Database('db/' + db_env + '.db');
+    var questionMarks = Array(values.length + 1).join('?').split('').join(', ');
+
+    var statement = "SELECT * FROM " + this.table_name + " WHERE " + column + " IN (" + questionMarks + ");";
+
+    db.all(statement, values, function(error, result) {
+      if (callback) { callback(error, result); }
+      db.close();
+    });
+  },
+
+  subset: function(column, queries, callback) {
+    var db = new sqlite3.Database('db/' + db_env + '.db');
+
+    var statement = "SELECT * FROM " + this.table_name + " ORDER BY " + column + " LIMIT ? OFFSET ?";
+
+    db.all(statement, queries, function(err, res) {
+      if (callback) { callback(err, res); }
+      db.close();
+    });
+  },
+
+  // Example route:
+  // customers/create/:name/:registered_at/:address/:city/:state/:postal_code/:phone
+  create: function(columns, values, callback) {
+    var db = new sqlite3.Database('db/' + db_env + '.db');
+    var column_names = columns.join(', ');
+    var question_marks =  Array(columns.length + 1).join('?').split('').join(', ');
+
+    var statement = "INSERT INTO " + this.table_name + " (" + column_names + ") \
+    VALUES (" + question_marks + ");";
+
+    db.run(statement, values, function(err, res) {
+      if (callback) { callback(err, { inserted_id: this.lastID }); }
+      db.close();
+    });
+  },
+
+  // Example route:
+  // customers/update/:id?name=name&city=city&state=state
+  update: function(id, columns, values, callback) {
+    var db = new sqlite3.Database('db/' + db_env + '.db');
+    // eg. "column1 = ?, column2 = ?, column3 = ?"
+    var columnsQueries = [];
+
+    for (var i = 0; i < columns.length; i++) {
+      columnsQueries.push(columns[i] + " = ?");
+    };
+
+    var update_statement = columnsQueries.join(', ');
+
+    var statement = "UPDATE " + this.table_name + " SET " + update_statement + "WHERE id = " + id + ";";
+
+    db.run(statement, values, function(err, res) {
+      if (callback) { callback(err, { changes: this.changes }); }
+      db.close();
+    });
+  }
+}