Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-07 14:35:47 +01:00
Code Issues Packages Projects Releases Wiki Activity

hinting

Browse Source
This commit is contained in:
psychobunny
2013-09-18 10:50:02 -04:00
parent cf4ba9d1d3
commit 28704a6164
3 changed files with 130 additions and 106 deletions
Download Patch File Download Diff File Expand all files Collapse all files

204
src/groups.js
View File

@@ -1,95 +1,117 @@
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, []);
});
},
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);
(function () {
"use strict";
async.map(uids, function(uid, next) {
User.getUserData(uid, next);
}, function(err, users) {
next(err, users);
});
} else next(err, uids);
});
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, []);
}
});
},
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;
callback(err, results.base);
});
},
getGidFromName: function (name, callback) {
RDB.hget('group:gid', name, callback);
},
isMember: function (uid, gid, callback) {
RDB.sismember('gid:' + gid + ':members', uid, callback);
},
exists: function (name, callback) {
RDB.hexists('group:gid', name, callback);
},
create: function (name, description, callback) {
if (name.length === 0) {
return callback(new Error('name-too-short'));
}
}, function(err, results) {
if (err) return callback(err);
results.base.count = results.users.length;
results.base.members = results.users;
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'));
}
});
},
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'));
}
});
},
destroy: function (gid, callback) {
RDB.hset('gid:' + gid, 'deleted', '1', callback);
},
join: function (gid, uid, callback) {
RDB.sadd('gid:' + gid + ':members', uid, callback);
},
leave: function (gid, uid, callback) {
RDB.srem('gid:' + gid + ':members', uid, callback);
}
};
callback(err, results.base);
});
},
getGidFromName: function(name, callback) {
RDB.hget('group:gid', name, callback);
},
isMember: function(uid, gid, callback) {
RDB.sismember('gid:' + gid + ':members', uid, callback);
},
exists: function(name, callback) {
RDB.hexists('group:gid', name, callback);
},
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'))
});
},
update: function(gid, values, callback) {
RDB.exists('gid:' + gid, function(err, exists) {
if (!err && exists) RDB.hmset('gid:' + gid, values, callback);
else calback(new Error('gid-not-found'));
});
},
destroy: function(gid, callback) {
RDB.hset('gid:' + gid, 'deleted', '1', callback);
},
join: function(gid, uid, callback) {
RDB.sadd('gid:' + gid + ':members', uid, callback);
},
leave: function(gid, uid, callback) {
RDB.srem('gid:' + gid + ':members', uid, callback);
}
};
module.exports = Groups;
module.exports = Groups;
}());