that's the last of it!! :D
Julian Lam
11 years ago
parent
a2329980c8
commit
a150691b5e
@ -0,0 +1,223 @@
|
||||
var groups = require('../groups'),
|
||||
meta = require('../meta'),
|
||||
plugins = require('../plugins'),
|
||||
user = require('../user'),
|
||||
topics = require('../topics'),
|
||||
CategoryTools = require('../categoryTools'),
|
||||
admin = {
|
||||
user: require('../admin/user'),
|
||||
categories: require('../admin/categories')
|
||||
},
|
||||
|
||||
async = require('async'),
|
||||
|
||||
SocketAdmin = {};
|
||||
|
||||
/* Topics */
|
||||
|
||||
SocketAdmin.topics = {};
|
||||
|
||||
SocketAdmin.topics.getMore = function(data, callback) {
|
||||
topics.getAllTopics(data.limit, data.after, function(err, topics) {
|
||||
callback(JSON.stringify(topics));
|
||||
});
|
||||
};
|
||||
|
||||
/* User */
|
||||
|
||||
SocketAdmin.user = {};
|
||||
|
||||
SocketAdmin.user.makeAdmin = function(theirid, sessionData) {
|
||||
if (sessionData.uid && sessionData.uid > 0) {
|
||||
admin.user.makeAdmin(sessionData.uid, theirid, sessionData.socket);
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.user.removeAdmin = function(theirid, sessionData) {
|
||||
if (sessionData.uid && sessionData.uid > 0) {
|
||||
admin.user.removeAdmin(sessionData.uid, theirid, sessionData.socket);
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.user.createUser = function(user, callback, sessionData) {
|
||||
if (sessionData.uid && sessionData.uid > 0) {
|
||||
admin.user.createUser(sessionData.uid, user, callback);
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.user.banUser = function(theirid, sessionData) {
|
||||
if (sessionData.uid && sessionData.uid > 0) {
|
||||
admin.user.banUser(sessionData.uid, theirid, sessionData.socket, function(isBanned) {
|
||||
if(isBanned) {
|
||||
if(sessionData.userSockets[theirid]) {
|
||||
for(var i=0; i<sessionData.userSockets[theirid].length; ++i) {
|
||||
sessionData.userSockets[theirid][i].emit('event:banned');
|
||||
}
|
||||
}
|
||||
module.parent.exports.logoutUser(theirid);
|
||||
}
|
||||
});
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.user.unbanUser = function(theirid, sessionData) {
|
||||
if (sessionData.uid && sessionData.uid > 0) {
|
||||
admin.user.unbanUser(sessionData.uid, theirid, sessionData.socket);
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.user.search = function(username, callback, sessionData) {
|
||||
if (!(sessionData.uid && sessionData.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);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
/* Categories */
|
||||
|
||||
SocketAdmin.categories = {};
|
||||
|
||||
SocketAdmin.categories.create = function(data, callback) {
|
||||
categories.create(data, function(err, data) {
|
||||
callback(err, data);
|
||||
});
|
||||
};
|
||||
|
||||
SocketAdmin.categories.update = function(data, sessionData) {
|
||||
admin.categories.update(data, sessionData.socket);
|
||||
};
|
||||
|
||||
SocketAdmin.categories.search = function(username, cid, callback, sessionData) {
|
||||
if (sessionData.uid && sessionData.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) sessionData.socket.emit('api:admin.categories.search', data);
|
||||
else callback(null, data);
|
||||
});
|
||||
});
|
||||
} else {
|
||||
if (!callback) sessionData.socket.emit('api:admin.user.search', null);
|
||||
else callback();
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.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);
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.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
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
SocketAdmin.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);
|
||||
}
|
||||
};
|
||||
|
||||
SocketAdmin.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);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
/* Themes & Plugins */
|
||||
|
||||
SocketAdmin.themes = {};
|
||||
SocketAdmin.plugins = {};
|
||||
|
||||
SocketAdmin.themes.getInstalled = function(callback) {
|
||||
meta.themes.get(function(err, themeArr) {
|
||||
callback(themeArr);
|
||||
});
|
||||
};
|
||||
|
||||
SocketAdmin.themes.set = meta.themes.set;
|
||||
|
||||
SocketAdmin.plugins.toggle = function(plugin_id, sessionData) {
|
||||
plugins.toggleActive(plugin_id, function(status) {
|
||||
sessionData.socket.emit('api:admin.plugins.toggle', status);
|
||||
});
|
||||
};
|
||||
|
||||
module.exports = SocketAdmin;
|
||||
@ -0,0 +1,39 @@
|
||||
var groups = require('../groups'),
|
||||
|
||||
SocketGroups = {};
|
||||
|
||||
SocketGroups.create = function(data, callback) {
|
||||
groups.create(data.name, data.description, function(err, groupObj) {
|
||||
callback(err ? err.message : null, groupObj || undefined);
|
||||
});
|
||||
};
|
||||
|
||||
SocketGroups.delete = function(gid, callback) {
|
||||
groups.destroy(gid, function(err) {
|
||||
callback(err ? err.message : null, err ? null : 'OK');
|
||||
});
|
||||
};
|
||||
|
||||
SocketGroups.get = function(gid, callback) {
|
||||
groups.get(gid, {
|
||||
expand: true
|
||||
}, function(err, groupObj) {
|
||||
callback(err ? err.message : null, groupObj || undefined);
|
||||
});
|
||||
};
|
||||
|
||||
SocketGroups.join = function(data, callback) {
|
||||
groups.join(data.gid, data.uid, callback);
|
||||
};
|
||||
|
||||
SocketGroups.leave = function(data, callback) {
|
||||
groups.leave(data.gid, data.uid, callback);
|
||||
};
|
||||
|
||||
SocketGroups.update = function(data, callback) {
|
||||
groups.update(data.gid, data.values, function(err) {
|
||||
callback(err ? err.message : null);
|
||||
});
|
||||
};
|
||||
|
||||
module.exports = SocketGroups;
|
||||
@ -0,0 +1,161 @@
|
||||
"use strict";
|
||||
|
||||
var posts = require('../posts'),
|
||||
postTools = require('../postTools'),
|
||||
topics = require('../topics'),
|
||||
meta = require('../meta'),
|
||||
Messaging = require('../messaging'),
|
||||
user = require('../user'),
|
||||
notifications = require('../notifications'),
|
||||
|
||||
async = require('async'),
|
||||
S = require('string'),
|
||||
winston = require('winston'),
|
||||
|
||||
SocketModules = {};
|
||||
|
||||
/* Posts Composer */
|
||||
|
||||
SocketModules.composer = {};
|
||||
|
||||
SocketModules.composer.push = function(data, callback, sessionData) {
|
||||
if (parseInt(sessionData.uid, 10) > 0 || parseInt(meta.config.allowGuestPosting, 10) === 1) {
|
||||
if (parseInt(data.pid, 10) > 0) {
|
||||
|
||||
async.parallel([
|
||||
function(next) {
|
||||
posts.getPostFields(data.pid, ['content'], next);
|
||||
},
|
||||
function(next) {
|
||||
topics.getTitleByPid(data.pid, function(title) {
|
||||
next(null, title);
|
||||
});
|
||||
}
|
||||
], function(err, results) {
|
||||
callback({
|
||||
title: results[1],
|
||||
pid: data.pid,
|
||||
body: results[0].content
|
||||
});
|
||||
});
|
||||
}
|
||||
} else {
|
||||
callback({
|
||||
error: 'no-uid'
|
||||
});
|
||||
}
|
||||
};
|
||||
|
||||
SocketModules.composer.editCheck = function(pid, callback) {
|
||||
posts.getPostField(pid, 'tid', function(err, tid) {
|
||||
postTools.isMain(pid, tid, function(err, isMain) {
|
||||
callback({
|
||||
titleEditable: isMain
|
||||
});
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
/* Chat */
|
||||
|
||||
SocketModules.chats = {};
|
||||
|
||||
SocketModules.chats.get = function(data, callback, sessionData) {
|
||||
var touid = data.touid;
|
||||
Messaging.getMessages(sessionData.uid, touid, function(err, messages) {
|
||||
if (err) {
|
||||
return callback(null);
|
||||
}
|
||||
|
||||
callback(messages);
|
||||
});
|
||||
};
|
||||
|
||||
SocketModules.chats.send = function(data, sessionData) {
|
||||
|
||||
var touid = data.touid;
|
||||
if (touid === sessionData.uid || sessionData.uid === 0) {
|
||||
return;
|
||||
}
|
||||
|
||||
var msg = S(data.message).stripTags().s;
|
||||
|
||||
user.getMultipleUserFields([sessionData.uid, touid], ['username'], function(err, usersData) {
|
||||
if(err) {
|
||||
return;
|
||||
}
|
||||
|
||||
var username = usersData[0].username,
|
||||
toUsername = usersData[1].username,
|
||||
finalMessage = username + ' : ' + msg,
|
||||
notifText = 'New message from <strong>' + username + '</strong>';
|
||||
|
||||
if (!module.parent.exports.isUserOnline(touid)) {
|
||||
notifications.create(notifText, 'javascript:app.openChat('' + username + '', ' + sessionData.uid + ');', 'notification_' + sessionData.uid + '_' + touid, function(nid) {
|
||||
notifications.push(nid, [touid], function(success) {
|
||||
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
Messaging.addMessage(sessionData.uid, touid, msg, function(err, message) {
|
||||
var numSockets = 0,
|
||||
x;
|
||||
|
||||
if (sessionData.userSockets[touid]) {
|
||||
numSockets = sessionData.userSockets[touid].length;
|
||||
|
||||
for (x = 0; x < numSockets; ++x) {
|
||||
sessionData.userSockets[touid][x].emit('event:chats.receive', {
|
||||
fromuid: sessionData.uid,
|
||||
username: username,
|
||||
message: finalMessage,
|
||||
timestamp: Date.now()
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
if (sessionData.userSockets[sessionData.uid]) {
|
||||
|
||||
numSockets = sessionData.userSockets[sessionData.uid].length;
|
||||
|
||||
for (x = 0; x < numSockets; ++x) {
|
||||
sessionData.userSockets[sessionData.uid][x].emit('event:chats.receive', {
|
||||
fromuid: touid,
|
||||
username: toUsername,
|
||||
message: 'You : ' + msg,
|
||||
timestamp: Date.now()
|
||||
});
|
||||
}
|
||||
}
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
SocketModules.chats.list = function(callback, sessionData) {
|
||||
Messaging.getRecentChats(sessionData.uid, function(err, uids) {
|
||||
if (err) {
|
||||
winston.warn('[(socket) api:chats.list] Problem retrieving chats: ' + err.message);
|
||||
}
|
||||
|
||||
callback(uids || []);
|
||||
});
|
||||
};
|
||||
|
||||
/* Notifications */
|
||||
|
||||
SocketModules.notifications = {};
|
||||
|
||||
SocketModules.notifications.mark_read = function(nid, sessionData) {
|
||||
notifications.mark_read(nid, sessionData.uid);
|
||||
};
|
||||
|
||||
SocketModules.notifications.mark_all_read = function(data, callback, sessionData) {
|
||||
notifications.mark_all_read(sessionData.uid, function(err) {
|
||||
if (!err) {
|
||||
callback();
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
module.exports = SocketModules;
|
||||
@ -0,0 +1,154 @@
|
||||
var posts = require('../posts'),
|
||||
meta = require('../meta'),
|
||||
topics = require('../topics'),
|
||||
favourites = require('../favourites'),
|
||||
postTools = require('../postTools'),
|
||||
|
||||
SocketPosts = {};
|
||||
|
||||
SocketPosts.reply = function(data, sessionData) {
|
||||
if (sessionData.uid < 1 && parseInt(meta.config.allowGuestPosting, 10) === 0) {
|
||||
sessionData.socket.emit('event:alert', {
|
||||
title: 'Reply Unsuccessful',
|
||||
message: 'You don't seem to be logged in, so you cannot reply.',
|
||||
type: 'danger',
|
||||
timeout: 2000
|
||||
});
|
||||
return;
|
||||
}
|
||||
|
||||
// FIXME: postDelay in sockets? I am disappoint.
|
||||
// if (Date.now() - lastPostTime < meta.config.postDelay * 1000) {
|
||||
// module.parent.exports.emitTooManyPostsAlert(sessionData.socket);
|
||||
// return;
|
||||
// }
|
||||
|
||||
topics.reply(data.topic_id, sessionData.uid, data.content, function(err, postData) {
|
||||
if(err) {
|
||||
if (err.message === 'content-too-short') {
|
||||
module.parent.exports.emitContentTooShortAlert(sessionData.socket);
|
||||
} else if (err.message === 'too-many-posts') {
|
||||
module.parent.exports.emitTooManyPostsAlert(sessionData.socket);
|
||||
} else if (err.message === 'reply-error') {
|
||||
sessionData.socket.emit('event:alert', {
|
||||
title: 'Reply Unsuccessful',
|
||||
message: 'Your reply could not be posted at this time. Please try again later.',
|
||||
type: 'warning',
|
||||
timeout: 2000
|
||||
});
|
||||
} else if (err.message === 'no-privileges') {
|
||||
sessionData.socket.emit('event:alert', {
|
||||
title: 'Unable to post',
|
||||
message: 'You do not have posting privileges in this category.',
|
||||
type: 'danger',
|
||||
timeout: 7500
|
||||
});
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
if (postData) {
|
||||
lastPostTime = Date.now();
|
||||
module.parent.exports.emitTopicPostStats();
|
||||
|
||||
sessionData.socket.emit('event:alert', {
|
||||
title: 'Reply Successful',
|
||||
message: 'You have successfully replied. Click here to view your reply.',
|
||||
type: 'success',
|
||||
timeout: 2000
|
||||
});
|
||||
var socketData = {
|
||||
posts: [postData]
|
||||
};
|
||||
sessionData.server.sockets.in('topic_' + postData.tid).emit('event:new_post', socketData);
|
||||
sessionData.server.sockets.in('recent_posts').emit('event:new_post', socketData);
|
||||
sessionData.server.sockets.in('user/' + postData.uid).emit('event:new_post', socketData);
|
||||
|
||||
}
|
||||
|
||||
});
|
||||
};
|
||||
|
||||
SocketPosts.favourite = function(data, sessionData) {
|
||||
favourites.favourite(data.pid, data.room_id, sessionData.uid, sessionData.socket);
|
||||
};
|
||||
|
||||
SocketPosts.unfavourite = function(data, sessionData) {
|
||||
favourites.unfavourite(data.pid, data.room_id, sessionData.uid, sessionData.socket);
|
||||
};
|
||||
|
||||
SocketPosts.uploadImage = function(data, callback) {
|
||||
posts.uploadPostImage(data, callback);
|
||||
};
|
||||
|
||||
SocketPosts.uploadFile = function(data, callback) {
|
||||
posts.uploadPostFile(data, callback);
|
||||
};
|
||||
|
||||
SocketPosts.getRawPost = function(data, callback) {
|
||||
posts.getPostField(data.pid, 'content', function(err, raw) {
|
||||
callback({
|
||||
post: raw
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
SocketPosts.edit = function(data, sessionData) {
|
||||
if(!sessionData.uid) {
|
||||
sessionData.socket.emit('event:alert', {
|
||||
title: 'Can't edit',
|
||||
message: 'Guests can't edit posts!',
|
||||
type: 'warning',
|
||||
timeout: 2000
|
||||
});
|
||||
return;
|
||||
} else if (!data.title || data.title.length < parseInt(meta.config.minimumTitleLength, 10)) {
|
||||
topics.emitTitleTooShortAlert(sessionData.socket);
|
||||
return;
|
||||
} else if (!data.content || data.content.length < parseInt(meta.config.minimumPostLength, 10)) {
|
||||
module.parent.exports.emitContentTooShortAlert(sessionData.socket);
|
||||
return;
|
||||
}
|
||||
|
||||
postTools.edit(sessionData.uid, data.pid, data.title, data.content, data.images);
|
||||
};
|
||||
|
||||
SocketPosts.delete = function(data, callback, sessionData) {
|
||||
postTools.delete(sessionData.uid, data.pid, function(err) {
|
||||
|
||||
if(err) {
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
module.parent.exports.emitTopicPostStats();
|
||||
|
||||
sessionData.server.sockets.in('topic_' + data.tid).emit('event:post_deleted', {
|
||||
pid: data.pid
|
||||
});
|
||||
callback(null);
|
||||
});
|
||||
};
|
||||
|
||||
SocketPosts.restore = function(data, callback, sessionData) {
|
||||
postTools.restore(sessionData.uid, data.pid, function(err) {
|
||||
if(err) {
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
module.parent.exports.emitTopicPostStats();
|
||||
|
||||
sessionData.server.sockets.in('topic_' + data.tid).emit('event:post_restored', {
|
||||
pid: data.pid
|
||||
});
|
||||
callback(null);
|
||||
});
|
||||
};
|
||||
|
||||
SocketPosts.getPrivileges = function(pid, callback, sessionData) {
|
||||
postTools.privileges(pid, sessionData.uid, function(privileges) {
|
||||
privileges.pid = parseInt(pid);
|
||||
callback(privileges);
|
||||
});
|
||||
};
|
||||
|
||||
module.exports = SocketPosts;
|
||||
Loading…
Reference in New Issue