Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-02 12:05:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

socket.io admin/user

Browse Source
This commit is contained in:
psychobunny
2014-04-15 02:25:42 -04:00
parent 3f22027007
commit 2fc6bfaa72
2 changed files with 91 additions and 79 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
src/socket.io/admin.js
View File

@@ -17,7 +17,7 @@ var groups = require('../groups'),
SocketAdmin = {
topics: {},
user: {},
user: require('admin/user'),
categories: {},
themes: {},
plugins: {},
@@ -68,84 +68,6 @@ SocketAdmin.fireEvent = function(socket, data, callback) {
index.server.sockets.emit(data.name, data.payload || {});
};
/* User */
SocketAdmin.user.makeAdmin = function(socket, theirid, callback) {
groups.join('administrators', theirid, callback);
};
SocketAdmin.user.removeAdmin = function(socket, theirid, callback) {
groups.leave('administrators', theirid, callback);
};
SocketAdmin.user.createUser = function(socket, userData, callback) {
if (!userData) {
return callback(new Error('[[error:invalid-data]]'));
}
user.create(userData, callback);
};
SocketAdmin.user.banUser = function(socket, theirid, callback) {
user.isAdministrator(theirid, function(err, isAdmin) {
if (err || isAdmin) {
return callback(err || new Error('[[error:cant-ban-other-admins]]'));
}
user.ban(theirid, function(err) {
if (err) {
return callback(err);
}
var sockets = index.getUserSockets(theirid);
for(var i=0; i<sockets.length; ++i) {
sockets[i].emit('event:banned');
}
module.parent.exports.logoutUser(theirid);
callback();
});
});
};
SocketAdmin.user.unbanUser = function(socket, theirid, callback) {
user.unban(theirid, callback);
};
SocketAdmin.user.deleteUser = function(socket, theirid, callback) {
user.delete(theirid, function(err) {
if (err) {
return callback(err);
}
events.logAdminUserDelete(socket.uid, theirid);
module.parent.exports.logoutUser(theirid);
callback();
});
};
SocketAdmin.user.search = function(socket, username, callback) {
user.search(username, function(err, data) {
function isAdmin(userData, next) {
user.isAdministrator(userData.uid, function(err, isAdmin) {
if(err) {
return next(err);
}
userData.administrator = isAdmin?'1':'0';
next();
});
}
if (err) {
return callback(err);
}
async.each(data.users, isAdmin, function(err) {
callback(err, data);
});
});
};
/* Categories */
SocketAdmin.categories.create = function(socket, data, callback) {

90
src/socket.io/admin/user.js Normal file
View File

@@ -0,0 +1,90 @@
"use strict";
var groups = require('../../groups'),
user = require('../../user'),
events = require('../../events'),
index = require('../index'),
async = require('async'),
User = {};
User.makeAdmin = function(socket, theirid, callback) {
groups.join('administrators', theirid, callback);
};
User.removeAdmin = function(socket, theirid, callback) {
groups.leave('administrators', theirid, callback);
};
User.createUser = function(socket, userData, callback) {
if (!userData) {
return callback(new Error('[[error:invalid-data]]'));
}
user.create(userData, callback);
};
User.banUser = function(socket, theirid, callback) {
user.isAdministrator(theirid, function(err, isAdmin) {
if (err || isAdmin) {
return callback(err || new Error('[[error:cant-ban-other-admins]]'));
}
user.ban(theirid, function(err) {
if (err) {
return callback(err);
}
var sockets = index.getUserSockets(theirid);
for(var i=0; i<sockets.length; ++i) {
sockets[i].emit('event:banned');
}
module.parent.exports.logoutUser(theirid);
callback();
});
});
};
User.unbanUser = function(socket, theirid, callback) {
user.unban(theirid, callback);
};
User.deleteUser = function(socket, theirid, callback) {
user.delete(theirid, function(err) {
if (err) {
return callback(err);
}
events.logAdminUserDelete(socket.uid, theirid);
module.parent.exports.logoutUser(theirid);
callback();
});
};
User.search = function(socket, username, callback) {
user.search(username, function(err, data) {
function isAdmin(userData, next) {
user.isAdministrator(userData.uid, function(err, isAdmin) {
if(err) {
return next(err);
}
userData.administrator = isAdmin?'1':'0';
next();
});
}
if (err) {
return callback(err);
}
async.each(data.users, isAdmin, function(err) {
callback(err, data);
});
});
};
module.exports = User;