all files / src/socket.io/user/ ban.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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
 
 
1×
1×
1×
1×
 
1×
 
1×
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1×
 
 
 
1×
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1×
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
'use strict';
 
var async = require('async');
var user = require('../../user');
var websockets = require('../index');
var events = require('../../events');
 
module.exports = function(SocketUser) {
 
	SocketUser.banUsers = function(socket, uids, callback) {
		toggleBan(socket.uid, uids, SocketUser.banUser, function(err) {
			if (err) {
				return callback(err);
			}
			async.each(uids, function(uid, next) {
				events.log({
					type: 'user-ban',
					uid: socket.uid,
					targetUid: uid,
					ip: socket.ip
				}, next);
			}, callback);
		});
	};
 
	SocketUser.unbanUsers = function(socket, uids, callback) {
		toggleBan(socket.uid, uids, user.unban, callback);
	};
 
	function toggleBan(uid, uids, method, callback) {
		if (!Array.isArray(uids)) {
			return callback(new Error('[[error:invalid-data]]'));
		}
 
		async.waterfall([
			function (next) {
				user.isAdminOrGlobalMod(uid, next);
			},
			function (isAdminOrGlobalMod, next) {
				if (!isAdminOrGlobalMod) {
					return next(new Error('[[error:no-privileges]]'));
				}
				async.each(uids, method, next);
			}
		], callback);
	}
 
	SocketUser.banUser = function(uid, callback) {
		async.waterfall([
			function (next) {
				user.isAdministrator(uid, next);
			},
			function (isAdmin, next) {
				if (isAdmin) {
					return next(new Error('[[error:cant-ban-other-admins]]'));
				}
				user.ban(uid, next);
			},
			function (next) {
				websockets.in('uid_' + uid).emit('event:banned');
				next();
			}
		], callback);
	};
 
};