app.js

var express = require('express');
var fs = require('fs');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var logger = require('morgan');
var mongo = require('./mongo');
var userModel = require('./schemas/user_schema');
var teamModel = require('./schemas/team_schema');
var eventModel = require('./schemas/event_schema');
var mongoose = require('mongoose');
var busboy = require('connect-busboy');

var HOST = '143.89.227.143';
var PORT = '5000';

var request  = require('request');

var mongoUrl = 'mongodb://generic01:generic01@ds041140.mongolab.com:41140/generic';

var app = express();

/**********************************************************************************/

// logger
app.use(logger('dev'));

// set the default view engine
app.set('views', __dirname + '/views');
app.set('view engine', 'ejs');

// Set the default rendering engine for normal html files
app.engine('html', require('ejs').renderFile);

// Use this so we can get access to `req.body` in login ad signup forms.
app.use(bodyParser.urlencoded({ extended: false}));

// We need to use cookies for sessions, so use the cookie parser middleware
app.use( require('cookie-parser')() );

// handles json parsing
app.use(bodyParser.json());

// parses cookies
app.use(cookieParser());

app.use(busboy());

// set the port number
app.set('port', (process.env.PORT || 5000));
app.use(express.static(__dirname + '/public'));


/**********************************************************************************/

// handle request to login page
app.get('/', function(req, res){
  res.send('hello world');
});

// logs the user out and renders the main page
app.get('/logout', function(req, res){
    delete req.session.username;
    res.redirect('/');
});

app.get('/index', function(req, res) {
  /**********************************************/
  res.render('index.html');
  /**********************************************/
});

app.get('/loggedIn', function(req, res) {
  /**********************************************/
  res.render('loggedIn.html');
  /**********************************************/
});

//create new user
app.get('/login', function(req, res) {
  getFacebookId(req.query.access_token, function(user_name, user_id, picture_url) {
    createUser(user_name, user_id, picture_url, function(success){
      if(success) res.json({userId: user_id});
    });
  });
});

app.post('/create/team', function(req, res) {
  var team_name;
  var user_id;
  var fstream;
  var imageUrl;
  console.log('here we go');
  req.pipe(req.busboy);
  req.busboy.on('field', function(fieldname, val, fieldnameTruncated, valTruncated) {
    if(fieldname == 'team_name')
      team_name = val;
    if(fieldname == 'user_id')
      user_id = val;
  });
  req.busboy.on('file', function (fieldname, file, filename) {
      console.log("Uploading: " + filename); 
      fstream = fs.createWriteStream(__dirname + '/public/images/' + filename);
      file.pipe(fstream);
      fstream.on('close', function () {
        imageUrl = 'http://' + HOST + ':' + PORT + '/images/' + filename;

        createTeam(team_name.toLowerCase(), user_id, imageUrl, function(team){
          res.json(team);
        });
      });
  });
});

//search existing user
app.get('/search/user', function(req, res) {
  var userName = req.query.user_name; 
  console.log(userName);
  var regex = new RegExp(userName, 'i');
  // get all the team names sorted alphabetically 
  userModel.find({name: { $regex: regex }}, function(err, user) {
    if (err) throw err;
    res.json(user);
  });
});

//search existing team
app.get('/search/team', function(req, res) {
  var teamName = req.query.team_name;
  console.log('search Team', teamName);
  if(teamName){
    // get the team specified
    var regex = new RegExp(teamName, 'i');
    teamModel.findOne({name: { $regex: regex }}, function(err, team) {
      if (err) throw err;
      res.json(team);
    });
  }
  else{
    // get all the team names sorted alphabetically 
    teamModel.find({}, function(err, teams) {
      if (err) throw err;
      res.json(teams);
    });
  }
});

//add user to team
app.get('/addUserToTeam', function(req, res) {
  var userId = req.query.user_id;
  var teamId = req.query.team_id;

  // get all the team names sorted alphabetically 
  teamModel.findOneAndUpdate({_id: teamId}, {$push: {userIds: userId}, $pull: {userRequestsIds: userId}}, function(err, team) {
    if (err) throw err;
    res.json({success: true});
  });
});

//ask to join a team
app.get('/joinTeam', function(req, res) {
 
  var userId = req.query.user_id;
  var teamId = req.query.team_id;

  // get all the team names sorted alphabetically 
  teamModel.findOneAndUpdate({_id: teamId}, {$push: {userRequestsIds: userId}}, function(err, team) {
    if (err) throw err;
    res.json({success: true});
  });
});

// handles request to create a new event
app.get('/create/event', function(req, res) {
  
  console.log(req.query.event_name);

  var eventName = req.query.event_name;
  var date = req.query.date;
  var teamId = req.query.team_id;
  var userId = req.query.user_id;

  createEvent(eventName, userId, teamId, date, function(newEvent){
    res.json(newEvent);
  });
});

// handles request to retrieve all events
app.get('/search/events', function(req, res) {
  
  eventModel.find({}, null, {sort: {date: -1}}, function(err, events) {
    if (err) throw err;
      res.json(events);
  });
});


/**********************************************************************************/


/**********************************************************************************/

function getFacebookId(access_token, callback) {
  request('https://graph.facebook.com/me?access_token=' + access_token, function (err, res, body) {
    if(!err && res.statusCode == 200) {
      var obj = JSON.parse(res.body);
      console.log('fb id: ', obj.id);
      callback(obj.name, obj.id, 'https://graph.facebook.com/v2.2/' + obj.id + '/picture');
    }
  });
};


/**
* Creates team and adds it to DB
*/
function createTeam(team_name, user_id, image_url, callback){

  var newTeam = new teamModel({
    name: team_name,
    imageUrl: image_url,
    userIds: [user_id],
    userRequestsIds: [],
    eventIds: [],
    messages: []
  });
  newTeam.save(function (err) {
    if (err) throw err;
    callback(newTeam);
  });
};

/**
* Creates events and adds it to DB
*/
function createEvent(eventName, user_id, team_id, date, callback){

  var newEvent = new eventModel({
    name: eventName,
    date: date,
    initiator_team_id: team_id,
    location: '',
    confirmed: false,
    participants: [user_id],
    participant_team_id: null,
  });

  newEvent.save(function (err) {
    if (err) throw err;
    callback(newEvent);
  });
};

/**
* Creates events and adds it to DB
*/
function createUser(user_name, user_id, picture_url, callback) {
  var newUser = new userModel({
    _id: user_id,
    name: user_name,
    imageUrl: picture_url,
    teamId: null
  });
  newUser.save(function (err) {
    if (err) throw err;
    console.log('user created');
    callback(true);
  });
};

/**********************************************************************************/

// catch 404 and forward to error handler
app.use(function(req, res, next) {
    var err = new Error('Not Found');
    err.status = 404;
    next(err);
});

// production error handler
// no stacktraces leaked to user
app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    console.log(err.message);
});

/**********************************************************************************/

// connect to the database
// and add a listening port to the applications
mongoose.connect(mongoUrl, function(){
  console.log('Connected to mongo at: ' + mongoUrl);
  app.listen(app.get('port'), function() {
    console.log('Server is listening on port: ' + app.get('port'));
  });  
});