app.js

//require dependencies
var express = require('express');
var models = require('./models');
var routes = require('./routes');
var userAPI = require('./routes/userAPI');
var videoAPI = require('./routes/videoAPI');
var http = require('http');
var request = require("request");
var path = require('path');
var dbUrl = process.env.MONGOHQ_URL || 'mongodb://localhost:27017/fleet';
//mongoose
var mongoose = require('mongoose');
mongoose.connect(dbUrl, {safe: true});
var db = mongoose.connection;
db.on('error', console.error.bind(console, 'connection error:'));
db.once('open', function (callback) {

});

//middleware
var logger = require('morgan'),
	errorHandler = require('errorhandler'),
	bodyParser = require('body-parser'),
	jwt = require('jsonwebtoken'),
	methodOverride = require('method-override');
	uuident = require('node-uuid');

var app = express();
app.locals.appTitle = 'Fleet';


//middleware that exposes Mongoose models in each Express.js route via a req object
app.use(function(req, res, next) {
	if (!models.User || !models.Video) return next(new Error('One or more models is missing.'));
	req.models = models;
	return next();
});

//configure settings
app.set('port', process.env.PORT || 3003);
app.set('secret', process.env.SECRET || 'supersecret');

//use middleware
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded());
app.use(methodOverride());
app.use(require('stylus').middleware(__dirname + 'public'));
app.use(express.static(path.join(__dirname, 'public')));

//error handling if environment is development
if ('development' == app.get('env')) {
	app.use(errorHandler({
		dumpExceptions: true,
		showStack: true
	}));
}
else if ('production' == app.get('env')) {
	app.use(errorHandler());
}

//signup route
app.post('/api/users', function(req, res) {
	models.User.findOne({
		email: req.body.email
	}, function(err, user) {
		if (err) throw err;
		if (user) {
			res.json({ success: false, message: 'Signup failed! User with given email already exists' });
		}
		else {
			var newUser = new models.User();
			newUser.email = req.body.email;
			newUser.username = req.body.username;
			newUser._id = uuident.v4();

			if (newUser.email && newUser._id && newUser.username) {
				newUser.save(function(err){
					if (err) throw err;
					res.json({
						success: true,
						message: 'User successfully created!',
					});
				});
			}
			else {
				res.json({
					success: false,
					message: 'Failed to generate new user. At least one field is missing',
				});
			}
		}
	});
});


//authenticate
app.post('/api/authenticate', function(req, res) {
	models.User.findOne({
		email: req.body.email
	}, function(err, user) {
		if (err) throw err;
		if (!user) {
			res.json({ success: false, exists: false, message: 'Authentication failed. User not found' });
		}
		else {
			var url = 'https://graph.facebook.com/me?access_token=' + req.body.fb_token;
			request(url, function(error, response, body) {
				if(!error){
					var token = jwt.sign(user, app.get('secret'), {
					expiresInMinutes: 1440 // expires in 24 hours
					});
					res.json({
						success: true,
						message: 'Token successfully generated!',
						uuid: user._id,
						email: user.email,
						username: user.username,
						token: token
					});
				}
				else{
					throw error;
				}
			});
		}
	});
});


//add authentication middleware middleware -- NEEDS TO BE AFTER api/authenticate
app.all('/api/*', function(req, res, next) {
	var token = req.body.token || req.query.token || req.headers['x-auth-token'];
	if (token) {
		jwt.verify(token, app.get('secret'), function(err, decoded) {
			if (err) {
				return res.json({ success: false, message: 'Failed to authenticate token.' });
			}
			else {
				req.decoded = decoded;
				next();
			}
		});
	}
	else {
		console.log('did not have token');
		return res.status(403).send({
			success: false,
			message: 'No token provided.'
		});
	}
});


//User API routes
app.get('/api/users/:uuid', userAPI.getUser);
app.put('/api/users/:uuid', userAPI.update);
app.delete('/api/users/:uuid', userAPI.delete);
app.get('/api/users/:uuid/videos/uploaded', userAPI.getUploadedVideos);
app.get('/api/users/:uuid/videos/upvoted', userAPI.getUpvotedVideos);


//Video API routes
app.get('/api/videos/:uuid', videoAPI.getVideo);
app.post('/api/videos', videoAPI.addVideo);
app.put('/api/videos/:uuid', videoAPI.updateVideo);
app.delete('/api/videos/:uuid', videoAPI.deleteVideo);
app.get('/api/videos/list/hot', videoAPI.getHotVideos);
app.get('/api/videos/list/new', videoAPI.getNewVideos);


//catch-all error 404 response
app.all('*', function(req, res) {
	res.sendStatus(404);
});

//start server
var server = http.createServer(app);
var boot = function() {
	server.listen(app.get('port'), function() {
		console.info('Express server listening on port ' + app.get('port'));
	});
	server.on('error', function(err) {
		console.error(err);
	});
}
var shutdown = function() {
	server.close();
}

if (require.main === module) {
	boot();
}
else {
	console.info('Running app as a module');
	exports.boot = boot;
	exports.shutdown = shutdown;
	exports.port = app.get('port');
}

//uncaught error handling
process.on('uncaughtException', function(err) {
	console.error('uncaughtException: ', err.message);
	console.error(err.stack);
	process.exit(1);
});