RethinkDB Auto Connect: Express Middleware

r-auto-connect.js

module.exports = function(app){
	app.express.use(function(req, res, next){
		// initialise rethink connection
		if(!app.rethinkdb){
			return next();
		}
		app.rethinkdb.connect(function(err, r, conn, rethinkNext){
			if(err){
				return res.error('DB Error', err).end();
			}
			req.on('end', function(){
				rethinkNext();
			});
			req.rethinkdb = {
				r: r,
				conn: conn,
				next: rethinkNext
			};
			return next();
		});
	});
}