first commit

README.md

@@ -1,4 +1,4 @@
-# Building an API using a Relational Database
+# Building an API using a Relational Database.
 
 ## Topics
 

index.js

@@ -0,0 +1,30 @@
+const express = require('express');
+const server = express();
+const requireAll = require('require-all');
+var _ = require('lodash');
+server.use(express.json());
+
+const helmet = require('helmet');
+server.use(helmet());
+
+/*
+// endpoints here
+
+const port = 3300;
+server.listen(port, function() {
+  console.log(`\n=== Web API Listening on http://localhost:${port} ===\n`);
+});
+*/
+
+// add your server code starting here
+server.listen(3300, () => console.log('server running'));
+
+process.setMaxListeners(0);
+
+const controllers = requireAll(__dirname + '/src/endpoints');
+_.each(controllers, (endpoints, controller) => {
+  _.each(endpoints, (definition, endpoint) => {
+  	console.log(`${endpoint}: /api/${controller}${definition.url}`);
+    server[definition.type.toLowerCase()](`/api/${controller}${definition.url}`, definition.handler);
+  });
+});

knexfile.js

@@ -0,0 +1,12 @@
+module.exports = {
+  development: {
+    client: 'sqlite3',
+    connection: { filename: './src/lambda.sqlite3' },
+    useNullAsDefault: true,
+    migrations: {
+      directory: './src/migrations',
+      tableName: 'dbmigrations',
+    },
+    seeds: { directory: './src/seeds' },
+  },
+};

package.json

@@ -0,0 +1,15 @@
+{
+  "scripts": {
+    "server": "nodemon index.js"
+  },
+  "dependencies": {
+    "express": "^4.16.4",
+    "helmet": "^3.15.0",
+    "knex": "^0.16.3",
+    "require-all": "^3.0.0",
+    "sqlite3": "^4.0.6"
+  },
+  "devDependencies": {
+    "nodemon": "^1.18.9"
+  }
+}

src/db/cohort.js

@@ -0,0 +1,46 @@
+const db = require('../dbConfig.js');
+const mappers = require('./mappers');
+
+module.exports = {
+  get: function(id) {
+    let query = db('cohorts as c');
+
+    if (id) {
+      query.where('c.id', id).first();
+
+      /*const promises = [query, this.getProjectActions(id)]; // [ projects, actions ]
+
+      return Promise.all(promises).then(function(results) {
+        let [project, actions] = results;
+        project.actions = actions;
+
+        return mappers.projectToBody(project);
+      });*/
+    }
+
+    return query/*.then(projects => {
+      return projects.map(project => mappers.projectToBody(project));
+    });*/
+  },/*
+  getProjectActions: function(projectId) {
+    return db('actions')
+      .where('project_id', projectId)
+      .then(actions => actions.map(action => mappers.actionToBody(action)));
+  },*/
+  insert: function(cohort) {
+    return db('cohorts')
+      .insert(cohort)
+      .then(([id]) => this.get(id));
+  },
+  update: function(id, changes) {
+    return db('cohorts')
+      .where('id', id)
+      .update(changes)
+      .then(count => (count > 0 ? this.get(id) : null));
+  },
+  remove: function(id) {
+    return db('cohorts')
+      .where('id', id)
+      .del();
+  },
+};

src/db/mappers.js

@@ -0,0 +1,37 @@
+module.exports = {
+  intToBoolean,
+  booleanToint,
+  projectToBody,
+  actionToBody,
+};
+
+function intToBoolean(int) {
+  return int === 1 ? true : false;
+}
+
+function booleanToint(bool) {
+  return bool === true ? 1 : 0;
+}
+
+function projectToBody(project) {
+  const result = {
+    ...project,
+    completed: intToBoolean(project.completed),
+  };
+
+  if (project.actions) {
+    result.actions = project.actions.map(action => ({
+      ...action,
+      completed: intToBoolean(action.completed),
+    }));
+  }
+
+  return result;
+}
+
+function actionToBody(action) {
+  return {
+    ...action,
+    completed: intToBoolean(action.completed),
+  };
+}

src/db/student.js

@@ -0,0 +1,35 @@
+const db = require('../dbConfig.js');
+const mappers = require('./mappers');
+
+module.exports = {
+  get: function(id) {
+    let query = db('students');
+
+    if (id) {
+      return query
+        .where('id', id)
+        .first()/*
+        .then(action => mappers.actionToBody(action));*/
+    }
+
+    return query/*.then(actions => {
+      return actions.map(action => mappers.actionToBody(action));
+    });*/
+  },
+  insert: function(student) {
+    return db('students')
+      .insert(student)
+      .then(([id]) => this.get(id));
+  },
+  update: function(id, changes) {
+    return db('students')
+      .where('id', id)
+      .update(changes)
+      .then(count => (count > 0 ? this.get(id) : null));
+  },
+  remove: function(id) {
+    return db('students')
+      .where('id', id)
+      .del();
+  },
+};

src/dbConfig.js

@@ -0,0 +1,4 @@
+const knex = require('knex');
+const knexConfig = require('../knexfile.js');
+
+module.exports = knex(knexConfig.development);

src/endpoints/cohort/create.js

@@ -0,0 +1,25 @@
+const express = require('express');
+const cohortDb = require('../../db/cohort.js');
+const validators = require('../../validators/cohort/create.js');
+
+module.exports = {
+	type: 'POST',
+	url: '/',
+	handler: (req, res) => {
+		const {name} = req.body;
+		let cohort = {
+	  		name: name,
+	  	}
+		const newKeys = Object.keys(cohort);
+		const validations = newKeys.map(key => validators[key](cohort));
+		Promise.all(validations).then(() => {
+			cohortDb.insert(cohort)
+			  .then(id => {
+			  	res.status(201).json(id);
+			  })
+			  .catch(err => {
+				res.status(500).json({ error: "There was an error while saving the new cohort to the database." });
+			  });
+		}).catch(err => res.status(err.statusCode || 500).json(err.stack));
+	}
+}

src/endpoints/cohort/delete.js

@@ -0,0 +1,30 @@
+const express = require('express');
+const cohortDb = require('../../db/cohort.js');
+
+module.exports = {
+	type: 'DELETE',
+	url: '/:id',
+	handler: (req, res) => {
+		cohortDb.get(req.params.id)
+		.then(cohort => {
+		  	if (cohort != undefined) {
+		  		cohortDb.remove(req.params.id)
+		  		.then(numRemoved => {
+		  			if(numRemoved === 1){
+						res.status(202).json({message: "Cohort successfully deleted."});
+					}else{
+						res.status(202).json({message: "Request accepted but no object deleted."});
+					}
+		  		})
+		  		.catch(err => {
+		  			res.status(500).json({ error: "The cohort could not be removed." });
+		  		});
+		  	}else{
+		  		res.status(404).json({ message: "The cohort with the specified ID does not exist." });
+		  	}
+		})
+		.catch(err => {
+			res.status(500).json({ error: "The cohort information could not be retrieved." });
+		})
+	}
+}

src/endpoints/cohort/list.js

@@ -0,0 +1,17 @@
+const express = require('express');
+const cohortDb = require('../../db/cohort.js');
+
+module.exports = {
+	type: 'GET',
+	url: 's/',
+	handler: (req, res) => {
+		cohortDb.get()
+		  .then(cohorts => {
+		  	res.status(200).json(cohorts);
+		  })
+		  .catch(err => {
+		  	console.log(err);
+			res.status(500).json({ error: "Could not retrieve cohorts." });
+		  })
+	}
+}

src/endpoints/cohort/retrieve.js

@@ -0,0 +1,22 @@
+const express = require('express');
+const cohortDb = require('../../db/cohort.js');
+
+module.exports = {
+	type: 'GET',
+	url: '/:id',
+	handler: (req, res) => {
+		const { id } = req.params;
+		cohortDb.get(id)
+		.then(cohort => {
+		  	if(cohort != undefined){
+		  		res.status(200).json(cohort);
+		  	}else{
+		  		res.status(404).json({ error: "Cohort not found."});
+		  	}
+		})
+		.catch(err => {
+		  	console.log(err);
+			res.status(500).json({ error: "Could not retrieve cohort." });
+		});
+	}
+}

src/endpoints/cohort/update.js

@@ -0,0 +1,31 @@
+const express = require('express');
+const cohortDb = require('../../db/cohort.js');
+const validators = require('../../validators/cohort/update.js');
+
+module.exports = {
+	type: 'PUT',
+	url: '/:id',
+	handler: (req, res) => {
+		const {name} = req.body;
+		const {id} = req.params;
+		let modifiedCohort = {
+	  		name: name,
+	  	}
+		const changedKeys = Object.keys(modifiedCohort);
+		const validations = changedKeys.map(key => validators[key](modifiedCohort));
+		Promise.all(validations).then(() => {
+			cohortDb.update(id, modifiedCohort)
+				.then(response => {
+					if(response === null){
+						res.status(404).json({message: "Cohort not found."});
+					}else{
+						res.status(200).json(response);
+					}
+				})
+				.catch(err => {
+					res.status(500).json({ error: "The cohort information could not be retrieved." });
+				})
+		}).catch(err => res.status(err.statusCode || 500).json(err.stack));
+
+	}
+}

src/endpoints/student/create.js

@@ -0,0 +1,43 @@
+const express = require('express');
+const studentDb = require('../../db/student.js');
+const cohortDb = require('../../db/cohort.js');
+const validators = require('../../validators/student/create.js');
+
+module.exports = {
+	type: 'POST',
+	url: '/',
+	handler: (req, res) => {
+		console.log(req.body);
+		const {cohort_id, name} = req.body;
+		let newStudent = {
+	  		cohort_id: cohort_id,
+	  		name: name,
+	  	}
+	  	console.log(newStudent);
+		const newKeys = Object.keys(newStudent);
+		console.log(newKeys);
+		const validations = newKeys.map(key => validators[key](newStudent));
+		Promise.all(validations).then(() => {
+			cohortDb.get(cohort_id)
+			.then(cohort => {
+				if(cohort != undefined){
+					studentDb.insert(newStudent)
+					  .then(id => {
+					  	res.status(201).json(id);
+					  })
+					  .catch(err => {
+						res.status(500).json({ error: "There was an error while saving the student to the database." });
+					  });
+				}else{
+					res.status(400).json({ error: "Please provide valid cohort ID." });
+				}
+			})
+			.catch(err => {
+				console.log(err);
+				res.status(500).json({ error: "The cohort information could not be retrieved." });
+			})
+		}).catch(err => {
+			res.status(err.statusCode || 500).json(err.message);
+		});
+	}
+}