all files / src/groups/ delete.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
 
1×
 
 
 
 
1×
 
1×
2×
2×
 
 
2×
 
 
2×
2×
 
2×
 
 
 
 
 
 
 
 
 
 
 
2×
2×
 
 
2×
9×
 
 
 
 
 
 
 
 
'use strict';
 
var async = require('async'),
	plugins = require('../plugins'),
	utils = require('../../public/src/utils'),
	db = require('./../database');
 
module.exports = function(Groups) {
 
	Groups.destroy = function(groupName, callback) {
		Groups.getGroupsData([groupName], function(err, groupsData) {
			Iif (err) {
				return callback(err);
			}
			Iif (!Array.isArray(groupsData) || !groupsData[0]) {
				return callback();
			}
			var groupObj = groupsData[0];
			plugins.fireHook('action:group.destroy', groupObj);
 
			async.parallel([
				async.apply(db.delete, 'group:' + groupName),
				async.apply(db.sortedSetRemove, 'groups:createtime', groupName),
				async.apply(db.sortedSetRemove, 'groups:visible:createtime', groupName),
				async.apply(db.sortedSetRemove, 'groups:visible:memberCount', groupName),
				async.apply(db.sortedSetRemove, 'groups:visible:name', groupName.toLowerCase() + ':' + groupName),
				async.apply(db.delete, 'group:' + groupName + ':members'),
				async.apply(db.delete, 'group:' + groupName + ':pending'),
				async.apply(db.delete, 'group:' + groupName + ':invited'),
				async.apply(db.delete, 'group:' + groupName + ':owners'),
				async.apply(db.deleteObjectField, 'groupslug:groupname', utils.slugify(groupName)),
				function(next) {
					db.getSortedSetRange('groups:createtime', 0, -1, function(err, groups) {
						Iif (err) {
							return next(err);
						}
						async.each(groups, function(group, next) {
							db.sortedSetRemove('group:' + group + ':members', groupName, next);
						}, next);
					});
				}
			], callback);
		});
	};
};