Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-01-30 03:09:53 +01:00
Code Issues Packages Projects Releases Wiki Activity

admin stuff, removed deprecated install templates, blah blah

Browse Source
This commit is contained in:
Julian Lam
2014-01-10 13:27:50 -05:00
parent c5d8a5a6b2
commit ea8aa3fff2
14 changed files with 69 additions and 696 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/admin/user.js
View File

@@ -72,6 +72,7 @@ var utils = require('../../public/src/utils'),
user.ban(theirid, function(err, result) {
callback(true);
socket.emit('event:alert', {
alert_id: 'ban_user',
title: 'User Banned',
message: 'This user is banned!',
type: 'success',
@@ -88,6 +89,7 @@ var utils = require('../../public/src/utils'),
if (amIAdmin) {
user.unban(theirid, function(err, result) {
socket.emit('event:alert', {
alert_id: 'ban_user',
title: 'User Unbanned',
message: 'This user is unbanned!',
type: 'success',

3
src/socket.io/index.js
View File

@@ -150,7 +150,8 @@ Sockets.init = function() {
uid: uid,
socket: socket,
rooms: rooms,
server: io
server: io,
userSockets: userSockets
},
socketArgs = [];

40
src/socket.io/meta.js
View File

@@ -1,6 +1,9 @@
var meta = require('../meta'),
user = require('../user'),
logger = require('../logger'),
plugins = require('../plugins'),
nconf = require('nconf'),
gravatar = require('gravatar'),
SocketMeta = {};
@@ -69,6 +72,43 @@ SocketMeta.rooms.enter = function(data, sessionData) {
}
};
SocketMeta.rooms.getAll = function(callback, sessionData) {
callback(sessionData.server.sockets.manager.rooms);
};
/* Config */
SocketMeta.config = {};
SocketMeta.config.get = function(callback, sessionData) {
meta.configs.list(function(err, config) {
if (!err) {
callback(config);
}
});
};
SocketMeta.config.set = function(data, callback, sessionData) {
meta.configs.set(data.key, data.value, function(err) {
if (!err) {
callback({
status: 'ok'
});
plugins.fireHook('action:config.set', {
key: data.key,
value: data.value
});
}
logger.monitorConfig({io: sessionData.server}, data);
});
};
SocketMeta.config.remove = function(key) {
meta.configs.remove(key);
};
/* Exports */
module.exports = SocketMeta;

215
src/websockets.js
View File

@@ -35,9 +35,7 @@ var cookie = require('cookie'),
websockets.init = function(io) {
socket.on('api:get_all_rooms', function(data) {
socket.emit('api:get_all_rooms', io.sockets.manager.rooms);
});
@@ -299,32 +297,7 @@ websockets.init = function(io) {
});
});
socket.on('api:config.get', function(data) {
meta.configs.list(function(err, config) {
if (!err) socket.emit('api:config.get', config);
});
});
socket.on('api:config.set', function(data) {
meta.configs.set(data.key, data.value, function(err) {
if (!err) {
socket.emit('api:config.set', {
status: 'ok'
});
plugins.fireHook('action:config.set', {
key: data.key,
value: data.value
});
}
logger.monitorConfig({io: io}, data);
});
});
socket.on('api:config.remove', function(key) {
meta.configs.remove(key);
});
socket.on('api:composer.push', function(data, callback) {
@@ -389,193 +362,7 @@ websockets.init = function(io) {
});
});
socket.on('api:admin.topics.getMore', function(data, callback) {
topics.getAllTopics(data.limit, data.after, function(err, topics) {
callback(JSON.stringify(topics));
});
});
socket.on('api:admin.categories.create', function(data, callback) {
categories.create(data, function(err, data) {
callback(err, data);
});
});
socket.on('api:admin.categories.update', function(data) {
admin.categories.update(data, socket);
});
socket.on('api:admin.user.makeAdmin', function(theirid) {
if (uid && uid > 0) {
admin.user.makeAdmin(uid, theirid, socket);
}
});
socket.on('api:admin.user.removeAdmin', function(theirid) {
if (uid && uid > 0) {
admin.user.removeAdmin(uid, theirid, socket);
}
});
socket.on('api:admin.user.createUser', function(user, callback) {
if (uid && uid > 0) {
admin.user.createUser(uid, user, callback);
}
});
socket.on('api:admin.user.banUser', function(theirid) {
if (uid && uid > 0) {
admin.user.banUser(uid, theirid, socket, function(isBanned) {
if(isBanned) {
if(userSockets[theirid]) {
for(var i=0; i<userSockets[theirid].length; ++i) {
userSockets[theirid][i].emit('event:banned');
}
}
websockets.logoutUser(theirid);
}
});
}
});
socket.on('api:admin.user.unbanUser', function(theirid) {
if (uid && uid > 0) {
admin.user.unbanUser(uid, theirid, socket);
}
});
socket.on('api:admin.user.search', function(username, callback) {
if (!(uid && uid > 0)) {
return callback();
}
user.search(username, function(data) {
function isAdmin(userData, next) {
user.isAdministrator(userData.uid, function(err, isAdmin) {
if(err) {
return next(err);
}
userData.administrator = isAdmin?'1':'0';
next();
});
}
async.each(data, isAdmin, function(err) {
if(err) {
return callback({message: err.message});
}
callback(null, data);
});
});
});
socket.on('api:admin.categories.search', function(username, cid, callback) {
if (uid && uid > 0) {
user.search(username, function(data) {
async.map(data, function(userObj, next) {
CategoryTools.privileges(cid, userObj.uid, function(err, privileges) {
if (!err) {
userObj.privileges = privileges;
} else {
winston.error('[socket api:admin.categories.search] Could not retrieve permissions');
}
next(null, userObj);
});
}, function(err, data) {
if (!callback) socket.emit('api:admin.categories.search', data);
else callback(null, data);
});
});
} else {
if (!callback) socket.emit('api:admin.user.search', null);
else callback();
}
});
socket.on('api:admin.categories.setPrivilege', function(cid, uid, privilege, set, callback) {
var cb = function(err) {
CategoryTools.privileges(cid, uid, callback);
};
if (set) {
groups.joinByGroupName('cid:' + cid + ':privileges:' + privilege, uid, cb);
} else {
groups.leaveByGroupName('cid:' + cid + ':privileges:' + privilege, uid, cb);
}
});
socket.on('api:admin.categories.getPrivilegeSettings', function(cid, callback) {
async.parallel({
"+r": function(next) {
groups.getByGroupName('cid:' + cid + ':privileges:+r', { expand: true }, function(err, groupObj) {
if (!err) {
next.apply(this, arguments);
} else {
next(null, {
members: []
});
}
});
},
"+w": function(next) {
groups.getByGroupName('cid:' + cid + ':privileges:+w', { expand: true }, function(err, groupObj) {
if (!err) {
next.apply(this, arguments);
} else {
next(null, {
members: []
});
}
});
}
}, function(err, data) {
callback(null, {
"+r": data['+r'].members,
"+w": data['+w'].members
});
});
});
socket.on('api:admin.categories.setGroupPrivilege', function(cid, gid, privilege, set, callback) {
if (set) {
groups.joinByGroupName('cid:' + cid + ':privileges:' + privilege, gid, callback);
} else {
groups.leaveByGroupName('cid:' + cid + ':privileges:' + privilege, gid, callback);
}
});
socket.on('api:admin.categories.groupsList', function(cid, callback) {
groups.list({expand:false}, function(err, data){
async.map(data, function(groupObj, next) {
CategoryTools.groupPrivileges(cid, groupObj.gid, function(err, privileges) {
if (!err) {
groupObj.privileges = privileges;
} else {
winston.error('[socket api:admin.categories.groupsList] Could not retrieve permissions');
}
next(null, groupObj);
});
}, function(err, data) {
callback(null, data);
});
});
});
socket.on('api:admin.themes.getInstalled', function(callback) {
meta.themes.get(function(err, themeArr) {
callback(themeArr);
});
});
socket.on('api:admin.plugins.toggle', function(plugin_id) {
plugins.toggleActive(plugin_id, function(status) {
socket.emit('api:admin.plugins.toggle', status);
});
});