Created
February 10, 2013 19:09
-
-
Save erichonorez/4750663 to your computer and use it in GitHub Desktop.
A simple REST API with Node.js and Express
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* TaskRepository class deals with task persistence | |
*/ | |
function TaskRepository() { | |
this.tasks = []; | |
this.nextId = 1; | |
} | |
/** | |
* Find a task by id | |
* Param: id of the task to find | |
* Returns: the task corresponding to the specified id | |
*/ | |
TaskRepository.prototype.find = function (id) { | |
var task = this.tasks.filter(function(item) { | |
return item.taskId == id; | |
})[0]; | |
if (null == task) { | |
throw new Error('task not found'); | |
} | |
return task; | |
} | |
/** | |
* Find the index of a task | |
* Param: id of the task to find | |
* Returns: the index of the task identified by id | |
*/ | |
TaskRepository.prototype.findIndex = function (id) { | |
var index = null; | |
this.tasks.forEach(function(item, key) { | |
if (item.taskId == id) { | |
index = key; | |
} | |
}); | |
if (null == index) { | |
throw new Error('task not found'); | |
} | |
return index; | |
} | |
/** | |
* Retrieve all tasks | |
* Returns: array of tasks | |
*/ | |
TaskRepository.prototype.findAll = function () { | |
return this.tasks; | |
} | |
/** | |
* Save a task (create or update) | |
* Param: task the task to save | |
*/ | |
TaskRepository.prototype.save = function (task) { | |
if (task.taskId == null || task.taskId == 0) { | |
task.taskId = this.nextId; | |
this.tasks.push(task); | |
this.nextId++; | |
} else { | |
var index = this.findIndex(task.taskId); | |
this.tasks[index] = task; | |
} | |
} | |
/** | |
* Remove a task | |
* Param: id the of the task to remove | |
*/ | |
TaskRepository.prototype.remove = function (id) { | |
var index = this.findIndex(id); | |
this.tasks.splice(index, 1); | |
} | |
/** | |
* API | |
*/ | |
var express = require('express'); | |
var app = express(); | |
var taskRepository = new TaskRepository(); | |
app.configure(function () { | |
// used to parse JSON object given in the body request | |
app.use(express.bodyParser()); | |
}); | |
/** | |
* HTTP GET /tasks | |
* Returns: the list of tasks in JSON format | |
*/ | |
app.get('/tasks', function (request, response) { | |
response.json({tasks: taskRepository.findAll()}); | |
}); | |
/** | |
* HTTP GET /tasks/:id | |
* Param: :id is the unique identifier of the task you want to retrieve | |
* Returns: the task with the specified :id in a JSON format | |
* Error: 404 HTTP code if the task doesn't exists | |
*/ | |
app.get('/tasks/:id', function (request, response) { | |
var taskId = request.params.id; | |
try { | |
response.json(taskRepository.find(taskId)); | |
} catch (exeception) { | |
response.send(404); | |
} | |
}); | |
/** | |
* HTTP POST /tasks/ | |
* Body Param: the JSON task you want to create | |
* Returns: 200 HTTP code | |
*/ | |
app.post('/tasks', function (request, response) { | |
var task = request.body; | |
taskRepository.save({ | |
title: task.title || 'Default title', | |
description: task.description || 'Default description', | |
dueDate: task.dueDate, | |
status: task.status || 'not completed' | |
}); | |
response.send(200); | |
}); | |
/** | |
* HTTP PUT /tasks/ | |
* Param: :id the unique identifier of the task you want to update | |
* Body Param: the JSON task you want to update | |
* Returns: 200 HTTP code | |
* Error: 404 HTTP code if the task doesn't exists | |
*/ | |
app.put('/tasks/:id', function (request, response) { | |
var task = request.body; | |
var taskId = request.params.id; | |
try { | |
var persistedTask = taskRepository.find(taskId); | |
taskRepository.save({ | |
taskId: persistedTask.taskId, | |
title: task.title || persistedTask.title, | |
description: task.description || persistedTask.description, | |
dueDate: task.dueDate || persistedTask.dueDate, | |
status: task.status || persistedTask.status | |
}); | |
response.send(200); | |
} catch (exception) { | |
response.send(404); | |
} | |
}); | |
/** | |
* HTTP PUT /tasks/ | |
* Param: :id the unique identifier of the task you want to update | |
* Body Param: the JSON task you want to update | |
* Returns: 200 HTTP code | |
* Error: 404 HTTP code if the task doesn't exists | |
*/ | |
app.delete('/tasks/:id', function (request, response) { | |
try { | |
taskRepository.remove(request.params.id); | |
response.send(200); | |
} catch (exeception) { | |
response.send(404); | |
} | |
}); | |
app.listen(8080); //to port on which the express server listen |
Sweet, thanks. nitpick: spelling error line 151: "exception"
Your get list of tasks route is wrong.
response.json({tasks: taskRepository.findAll()});
is not even a valid json object.
It should simply be
response.json( taskRepository.findAll() );
Return the array and let the parser worry about json-ifying it !
But thanks for the sample.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
how to use this code , where is JSON data