requestHandlers.js

var persistency = require('./persistency'),
    date_utils = require('date-utils'),
    everyauth = require('everyauth'),
    config = require('./config'),
    util = require('util');

var realtime;


function setRealtimeEngine(engine) {
  realtime = engine;
}

function isUserAllowed(req, res, success) {
  if (!req.loggedIn) {
    res.redirect('/login'); 
  } else {
    persistency.isUserWhitelisted(req.session.auth.google.user.id, function(whitelisted) {
      if (whitelisted) success();
      else res.redirect('/access');
    });
  }
}

function login(req, res) {
  res.render('login');
}

function index(req, res) {
  isUserAllowed(req, res, function() {
    res.render('index', {
      calendar_web_link: config.app.calendar
    });
  });
}

function history(req, res) {
  isUserAllowed(req, res, function() {
    res.render('history');
  });
}

function getHistory(req, res) {
  isUserAllowed(req, res, function() {
    year = parseInt(req.params.year);
    month = parseInt(req.params.month);
    day = parseInt(req.params.day);
    if (isNaN(day) || isNaN(month) || isNaN(year)) {
      res.render('404');
      return;
    }

    if (!Date.validateDay(day, year, month)) {
      res.render('404');
      return;
    }

    lower_date = new Date(year, month, day, 0, 0, 0, 0);
    upper_date = lower_date.clone();
    upper_date.addDays(1);

    data = {};
    persistency.getMessages(lower_date, upper_date, function(err, messages) {
      if (err) {
        console.warn('Error getting messages: ' + err, err.stack);
        res.render('404');
      } else {
        persistency.getUsers(function(err, users) {
          if (err) {
            console.warn('Error getting users: ' + err, err.stack);
            res.render('404');
          } else {
            data.messages = messages;
            data.users = users;
            res.contentType('json');
            res.send(data);
          }
        });
      }
    });
  });
}

function beta(req, res) {
  isUserAllowed(req, res, function() {
    res.render('beta', {
      calendar_web_link: config.app.calendar
    });
  });
}

function whitelist(req, res) {
  isUserAllowed(req, res, function() {
    persistency.getUsers(function(err, users) {
      if (err) handleError(err);
      else {
        pending = [];
        accepted = [];
        banned = [];
        userMap = {};
        // exclude system user
        users = users.filter(function(user) {
          return user.id !== 'ServusTalk';
        });
        for (i in users) {
          if (users[i].acceptedBy && users[i].bannedBy) {
	    // TODO this will happen for first person to login after everyone has been blacklisted
            console.error('User ' + users[i].email + ' cannot be both banned and accepted at the same time');
          }
          if (users[i].acceptedBy) accepted.push(users[i]);
          else if (users[i].bannedBy) banned.push(users[i]);
          else pending.push(users[i]);
          userMap[users[i].id] = users[i];
        }
        res.render('whitelist', {
          accepted: accepted,
          pending: pending,
          banned: banned,
          userMap: userMap
        });
      }
    });
  });
}

function handleError(err) {
  console.warn('Error getting messages: ' + err, err.stack);
  res.render('404');
}

function acceptUser(req, res) {
  isUserAllowed(req, res, function() {
    userId = req.params.userid;
    persistency.getUser(userId, function(err, user) {
      if (err) handleError(err);
      else {
        if (!user.acceptedBy) {
          delete user.bannedBy;
          user.acceptedBy = req.session.auth.google.user.id;
          persistency.updateUser(user);
          if (realtime) {
            realtime.pushSystemMessage('99CC32', user.name + ' has been whitelisted by ' + req.session.auth.google.user.name);
          }
        }
        res.redirect('/whitelist');
      }
    });
  });
}

function banUser(req, res) {
  isUserAllowed(req, res, function() {
    userId = req.params.userid;
    persistency.getUser(userId, function(err, user) {
      if (err) handleError(err);
      else {
        if (!user.bannedBy) {
          delete user.acceptedBy;
          user.bannedBy = req.session.auth.google.user.id;
          persistency.updateUser(user);
          if (realtime) {
            realtime.disconnectUser(userId);
            realtime.pushSystemMessage('FF6A6A', user.name + ' has been blacklisted by ' + req.session.auth.google.user.name);
          }
        }
        res.redirect('/whitelist');
      }
    });
  });
}

function access(req, res) {
  if (!req.loggedIn) {
    res.redirect('/login');
  } else {
    persistency.isUserWhitelisted(req.session.auth.google.user.id, function(whitelisted) {
      if (whitelisted) {
        res.redirect('/');
      } else {
        res.render('access');
      }
    });
  }

}

function pay(req, res) {
  isUserAllowed(req, res, function() {
    res.render('pay');
  });
}

function vote(req, res) {
  user_id = req.session.auth.google.user.id;
  if (req.body.vote === undefined || req.body.message_ts === undefined ||
      !(req.body.vote <= 1 && req.body.vote >= -1)) {
    res.statusCode = 400;
    res.end('Invalid request');
    return;
  }

  message_ts = parseInt(req.body.message_ts);
  vote = parseInt(req.body.vote);
  persistency.saveVote(message_ts, user_id, vote, function(message) {
    realtime.broadcast('vote', message);
  });
  res.end('uptokes!');
}

function getMessages(req, res) {
  timestamp = parseInt(req.params.timestamp);
  if (isNaN(timestamp)) {
    res.render('404');
  } else {
    persistency.getMessagesChunk(timestamp, 100, function(err, messages) {
      persistency.mergeMessagesWithUsers(messages, null, function(messages) {
        res.contentType('json');
        res.send(messages);
      });
    });
  }
}

exports.index = index
exports.login = login
exports.access = access
exports.history = history
exports.getHistory = getHistory
exports.beta = beta
exports.whitelist = whitelist
exports.acceptUser = acceptUser
exports.banUser = banUser
exports.setRealtimeEngine = setRealtimeEngine
exports.pay = pay
exports.vote = vote
exports.getMessages = getMessages