Crea un Restful API con NodeJS y MongoDB en 10 minutos

Veremos que se nos ha creado un directorio llamado node_modules que contiene los módulos que hemos instalado como dependencias.

Ahora vamos a crear nuestro index.js y empecemos haciendo la referencia de los módulos.

 

var express = require("express");

var mongoskin = require("mongoskin");
var bodyParser = require(“body-parser");

 

A continuación crearemos una variable que será un objeto encargado de controlar el servidor. var app = express();

Vamos a hacer la conexión con MongoDB:

var db = mongoskin.db(“mongodb://@localhost:27017/testdatabase”, {safe:true});
var id = mongoskin.helper.toObjectID;

 

db es el objeto de conexión e id transformará una cadena en tipo idObject de MongoDB. Ahora es paso de empezar a configurar nuestro Middleware.

Primero haremos tres métodos, el primero para decir los métodos http que aceptamos y el segundo para asegurar con una contraseña nuestra Restful API. Vamos a poner una contraseña común para todos, esto en la práctica no es seguro y lo ideal sería una contraseña o token diferente por usuario con fecha de espiración pero para este ejemplo lo vamos a simplificar de esta forma. El tercer método es para que acepte los parámetros indicados en el header de la petición.

var allowMethods = function(req, res, next) {
    res.header('Access-Control-Allow-Methods', "GET, POST, PUT, DELETE, OPTIONS"); next();
}

var auth = function(req, res, next) {
    if (req.headers.token === "password123456") {
   	 return next();
	}else{
		return next(new Error('No autorizado'));
	}
};

var allowCrossTokenHeader = function(req, res, next) { 
	res.header('Access-Control-Allow-Headers', 'token'); 
	next();
}

Y ahora vamos con el middleware:

 

app.use(bodyParser.urlencoded({ extended: false })); 
app.use(bodyParser.json());
app.use(allowMethods); 
app.use(allowCrossTokenHeader);

Hemos añadido bodyParser para poder manejar los parámetros que nos lleguen y los métodos de allowMethods y allowCrossTokenHeader.

Ahora vamos a tratar independientemente el parámetro colección en cada petición para asignarlo a una colección de la base de datos.

app.param('coleccion', function(req, res, next, coleccion){ 
    req.collection = db.collection(coleccion);
    return next();
});

 

Lo que hacemos es usar el método param pasándole como primer valor el nombre del parámetro que debe obtener y hacemos la conexión a esa colección y lo pasamos como valor a req.collection para que esté disponible en las siguientes funciones para poder trabajar con ella.

La función get la usamos para recoger las peticiones GET así como post la usaremos para POST, etc. El primer valor es la ruta de la petición a la que tiene que responder, a partir de ahí son funciones que se le pasan como parámetros que se irán ejecutando una tras otras según vayan llamándose con next(). Como vemos la primera función es auth que la definimos antes y servía para asegurar la API y a siguiente función es la llamada a MongoDB en sí y con res.send() devolvemos los resultados.

app.get('/api/:coleccion', auth, function(req, res, next) { req.collection.find({},{
    limit:10, sort: [['_id',-1]] }).toArray(function(e, results){
        if (e) return next(e);
        res.send(results); 
    });
});

 

Ahora haremos definimos la misma ruta pero por POST para poder insertar los datos que llegan desde el cliente. En req.body están los datos que recibimos y tal cual nos llega los insertamos y devolvemos el resultado que son los mismo datos más el id generado al insertarse.

if (e) return next(e);
    res.send(results); });
});

Veamos como obtener un documento mediante el id que se le pasa por la url:

app.get('/api/:colecion/:id', auth, function(req, res, next) { req.collection.findOne({
_id: id(req.params.id) }, function(e, result){
if (e) return next(e);
res.send(result);
}); });

Actualizar
app.put('/api/:coleccion/:id', auth, function(req, res, next) {

app.put('/api/:coleccion/:id', auth, function(req, res, next) {
req.collection.update({ _id: id(req.params.id)
}, {$set:req.body}, {safe:true, multi:false}, function(e, result){
if (e) return next(e);
res.send((result === 1) ? {msg:'success'} : {msg:'error'});
}); });

Eliminar

app.delete('/api/:coleccion/:id', auth, function(req, res, next) { req.collection.remove({
_id: id(req.params.id) },
function(e, result){
if (e) return next(e);
res.send((result === 1) ? {msg:'success'} : {msg:'error'});
}); });

Finalmente le ejecutamos el servidor para que escuche en el puerto 8080

app.listen(80, function(){
console.log ('Servidor escuchando en puerto 8080');
});});

Ahora vamos al terminal, al directorio de nuestro proyecto y ejecutamos el siguiente comando node .
Probémoslo

 

Yo voy a usar Advanced Rest Client, es una aplicación para Chrome con la cual podemos hacer test de nuestro servicio.