groups.js

var _ = require('lodash');
var nconf = require('nconf');
var async = require('async');
var algos = require('habitrpg-shared/script/algos');
var helpers = require('habitrpg-shared/script/helpers');
var items = require('habitrpg-shared/script/items');
var User = require('./../models/user').model;
var Group = require('./../models/group').model;
var api = module.exports;

/*
  ------------------------------------------------------------------------
  Groups
  ------------------------------------------------------------------------
*/

var usernameFields = 'auth.local.username auth.facebook.displayName auth.facebook.givenName auth.facebook.familyName auth.facebook.name';
var partyFields = 'profile preferences items stats achievements party backer flags.rest auth.timestamps ' + usernameFields;

function removeSelf(group, user){
  group.members = _.filter(group.members, function(m){return m._id != user._id});
}

api.getMember = function(req, res) {
  User.findById(req.params.uid).select(partyFields).exec(function(err, user){
    if (err) return res.json(500,{err:err});
    if (!user) return res.json(400,{err:'User not found'});
    res.json(user);
  })
}

/**
 * Get groups. If req.query.type privided, returned as an array (so ngResource can use). If not, returned as
 * object {guilds, public, party, tavern}. req.query.type can be comma-separated `type=guilds,party`
 * @param req
 * @param res
 * @param next
 */
api.getGroups = function(req, res, next) {
  var user = res.locals.user;

  var type = req.query.type && req.query.type.split(',');

  async.parallel({
    party: function(cb) {
      if (type && !~type.indexOf('party')) return cb(null, {});
      Group
        .findOne({type: 'party', members: {'$in': [user._id]}})
        .populate({
          path: 'members',

          select: partyFields
        })
        .exec(cb);
    },
    guilds: function(cb) {
      if (type && !~type.indexOf('guilds')) return cb(null, []);
      Group.find({type: 'guild', members: {'$in': [user._id]}}).populate('members', usernameFields).exec(cb);

    },
    tavern: function(cb) {
      if (type && !~type.indexOf('tavern')) return cb(null, {});
      Group.findOne({_id: 'habitrpg'}, cb);
    },
    "public": function(cb) {
      if (type && !~type.indexOf('public')) return cb(null, []);
      Group.find({privacy: 'public'}, {name:1, description:1, members:1}, cb);
    }
  }, function(err, results){
    if (err) return res.json(500, {err: err});

    if (results.party) {
      removeSelf(results.party, user);
    }

    results.public = _.sortBy(results.public, function(group){
      return -group.members.length;
    });

    if (type) {
      results = _.reduce(type, function(m,t){
        return m.concat(_.isArray(results[t]) ? results[t] : [results[t]]);
      }, []);
    }

    res.json(results);
  })
};

/**
 * Get group
 */
api.getGroup = function(req, res, next) {
  var user = res.locals.user;
  var gid = req.params.gid;

  Group.findById(gid).populate('members', partyFields).exec(function(err, group){
    if ( (group.type == 'guild' && group.privacy == 'private') || group.type == 'party') {
      return res.json(401, {err: "You don't have access to this group"});
    }

    if (group.type == 'party') {
      removeSelf(group, user);
    }
    res.json(group);

  })
};


api.createGroup = function(req, res, next) {
  var group = new Group(req.body);
  group.save(function(err, saved){
    if (err) return res.json(500,{err:err});
    res.json(saved);
  })
}

api.updateGroup = function(req, res, next) {
  var group = res.locals.group;
  'name description logo websites logo leaderMessage'.split(' ').forEach(function(attr){
    group[attr] = req.body[attr];
  });
  async.series([
    function(cb){group.save(cb);},
    function(cb){
      var fields = group.type == 'party' ? partyFields : usernameFields;
      Group.findById(group._id).populate('members', fields).exec(cb);
    }
  ], function(err, results){
    if (err) return res.json(500,{err:err});
    removeSelf(results[1], res.locals.user);
    res.json(results[1]);
  })
}

api.attachGroup = function(req, res, next) {
  Group.findById(req.params.gid, function(err, group){
    if(err) return res.json(500, {err:err});
    res.locals.group = group;
    next();
  })
}

api.postChat = function(req, res, next) {
  var user = res.locals.user
  var group = res.locals.group;
  var message = {
    id: helpers.uuid(),
    uuid: user._id,
    contributor: user.backer && user.backer.contributor,
    npc: user.backer && user.backer.npc,
    text: req.query.message, // FIXME this should be body, but ngResource is funky
    user: helpers.username(user.auth, user.profile.name),
    timestamp: +(new Date)
  };

  group.chat.unshift(message);
  group.chat.splice(200);

  if (group.type === 'party') {
    user.party.lastMessageSeen = message.id;
    user.save();
  }

  async.series([
    function(cb){group.save(cb)},
    function(cb){
      Group.findById(group._id).populate('members', partyFields).exec(cb);
    }
  ], function(err, results){
    if (err) return res.json(500, {err:err});

    var saved = results[1];
    removeSelf(saved, user);

    res.json(saved);
  })
}

api.deleteChatMessage = function(req, res, next){
  var user = res.locals.user
  var group = res.locals.group;
  var message = _.find(group.chat, {id: req.params.messageId, uuid: user.id});

  if(message === undefined) return res.json(404, {err: "Message not found!"});

  if(user.id !== message.uuid){
    if(!user.backer || (user.backer && !user.backer.admin)){
      return res.json(401, {err: "Not authorized to delete this message!"})
    }
  }

  group.chat = _.without(group.chat, message);
  
  group.save(function(err, data){
    if(err) return res.json(500, {err: err});

    res.send(204);
  });
}

api.join = function(req, res, next) {
  var user = res.locals.user,
    group = res.locals.group;

  if (group.type == 'party' && group._id == (user.invitations && user.invitations.party && user.invitations.party.id)) {
    user.invitations.party = undefined;
    user.save();
  }
  else if (group.type == 'guild' && user.invitations && user.invitations.guilds) {
    var i = _.findIndex(user.invitations.guilds, {id:group._id});
    if (~i) user.invitations.guilds.splice(i,1);
    user.save();
  }

  group.members.push(user._id);
  async.series([
    function(cb){
      group.save(cb);
    },
    function(cb){
      Group.findById(group._id).populate('members', partyFields).exec(cb);
    }
  ], function(err, results){
    if (err) return res.json(500,{err:err});
    res.json(results[1]);
  });
}

api.leave = function(req, res, next) {
  var user = res.locals.user,
    group = res.locals.group;

  Group.update({_id:group._id},{$pull:{members:user._id}}, function(err, saved){
    if (err) return res.json(500,{err:err});
    res.send(200, {_id: saved._id});
  })
}

api.invite = function(req, res, next) {
  var group = res.locals.group;
  var uuid = req.query.uuid;

  User.findById(uuid, function(err,invite){
    if (err) return res.json(500,{err:err});
    if (!invite)
       return res.json(400,{err:'User with id '+req.query.uid+' not found'});
    if (group.type == 'guild') {
      if (_.contains(group.members,uuid))
        return res.json(400,{err: "User already in that group"});
      if (invite.invitations && invite.invitations.guilds && _.find(invite.invitations.guilds, {id:group._id}))
        return res.json(400, {err:"User already invited to that group"});
      sendInvite();
    } else if (group.type == 'party') {
      if (invite.invitations && !_.isEmpty(invite.invitations.party))
        return res.json(400,{err:"User already pending invitation."});
      Group.find({type:'party', members:{$in:[uuid]}}, function(err, groups){
        if (err) return res.json(500,{err:err});
        if (!_.isEmpty(groups))
          return res.json(400,{err:"User already in a party."})
        sendInvite();
      })
    }

    function sendInvite (){
      if(group.type === 'guild'){
        invite.invitations.guilds.push({id: group._id, name: group.name});
      }else{

        invite.invitations.party = {id: group._id, name: group.name}
      }

      invite.save();
      Group.findById(group._id)
        .populate('members', partyFields).exec(function(err, saved){
          res.json(saved);
        });

    }
  });
}