nodebb/src/groups.js

(function(Groups) {
	"use strict";

	var async = require('async'),
		User = require('./user'),
		RDB = RDB || require('./redis');

	Groups.list = function(options, callback) {
		RDB.hvals('group:gid', function (err, gids) {
			if (gids.length > 0) {
				async.map(gids, function (gid, next) {
					Groups.get(gid, {
						expand: options.expand
					}, next);
				}, function (err, groups) {
					callback(err, groups.filter(function (group) {
						if (group.deleted === '1') {
							return false;
						} else {
							return true;
						}
					}));
				});
			} else {
				callback(null, []);
			}
		});
	};

	Groups.get = function(gid, options, callback) {
		async.parallel({
			base: function (next) {
				RDB.hgetall('gid:' + gid, next);
			},
			users: function (next) {
				RDB.smembers('gid:' + gid + ':members', function (err, uids) {
					if (options.expand) {
						if (err) {
							return next(err);
						}

						async.map(uids, function (uid, next) {
							User.getUserData(uid, next);
						}, function (err, users) {
							next(err, users);
						});
					} else {
						next(err, uids);
					}
				});
			}
		}, function (err, results) {
			if (err) {
				return callback(err);
			}

			results.base.count = results.users.length;
			results.base.members = results.users;

			results.base.deletable = (results.base.gid !== '1');

			callback(err, results.base);
		});
	};

	Groups.getGidFromName = function(name, callback) {
		RDB.hget('group:gid', name, callback);
	};

	Groups.isMember = function(uid, gid, callback) {
		RDB.sismember('gid:' + gid + ':members', uid, callback);
	};

	Groups.isMemberByGroupName = function(uid, groupName, callback)
		this.getGidFromName(groupName, function(err, gid
			if (err || !gid) {
				callback(null, false);
			} else {
				Groups.isMember(uid, gid, callba
			}
		});
	};

	Groups.exists = function(name, callback) {
		RDB.hexists('group:gid', name, callback);
	};

	Groups.create = function(name, description, callback) {
		if (name.length === 0) {
			return callback(new Error('name-too-short'));
		}

		Groups.exists(name, function (err, exists) {
			if (!exists) {
				RDB.incr('next_gid', function (err, gid) {
					RDB.multi()
						.hset('group:gid', name, gid)
						.hmset('gid:' + gid, {
							gid: gid,
							name: name,
							description: description,
							deleted: '0'
						})
						.exec(function (err) {
							Groups.get(gid, {}, callback);
						});
				});
			} else {
				callback(new Error('group-exists'));
			}
		});
	};

	Groups.update = function(gid, values, callback) {
		RDB.exists('gid:' + gid, function (err, exists) {
			if (!err && exists) {
				RDB.hmset('gid:' + gid, values, callback);
			} else {
				callback(new Error('gid-not-found'));
			}
		});
	};

	Groups.destroy = function(gid, callback) {
		if (gid !== 1) {
			RDB.hset('gid:' + gid, 'deleted', '1', callback);
		}
	};

	Groups.join = function(gid, uid, callback) {
		RDB.sadd('gid:' + gid + ':members', uid, callback);
	};

	Groups.leave = function(gid, uid, callback) {
		RDB.srem('gid:' + gid + ':members', uid, callback);
	};
	
}(module.exports));