|
|
|
@ -32,8 +32,7 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
(function(io) {
|
|
|
|
(function(io) {
|
|
|
|
var users = {},
|
|
|
|
var users = {},
|
|
|
|
userSockets = {},
|
|
|
|
userSockets = {},
|
|
|
|
rooms = {},
|
|
|
|
rooms = {};
|
|
|
|
chats = {};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
global.io = io;
|
|
|
|
global.io = io;
|
|
|
|
|
|
|
|
|
|
|
|
@ -57,13 +56,6 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
|
|
|
|
|
|
|
|
user.getUserField(uid, 'username', function(err, username) {
|
|
|
|
user.getUserField(uid, 'username', function(err, username) {
|
|
|
|
socket.emit('event:connect', {status: 1, username:username, uid:uid});
|
|
|
|
socket.emit('event:connect', {status: 1, username:username, uid:uid});
|
|
|
|
|
|
|
|
|
|
|
|
if(chats[uid]) {
|
|
|
|
|
|
|
|
for(var i=0; i<chats[uid].length; ++i) {
|
|
|
|
|
|
|
|
io.sockets.in(chats[uid][i]).emit('chatMessage', {fromuid:uid, username:username, message: username+' came online\n', timestamp: Date.now()});
|
|
|
|
|
|
|
|
socket.join(chats[uid][i]);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
@ -82,18 +74,6 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
delete users[sessionID];
|
|
|
|
delete users[sessionID];
|
|
|
|
if(uid) {
|
|
|
|
if(uid) {
|
|
|
|
io.sockets.in('global').emit('api:user.isOnline', isUserOnline(uid));
|
|
|
|
io.sockets.in('global').emit('api:user.isOnline', isUserOnline(uid));
|
|
|
|
|
|
|
|
|
|
|
|
user.getUserField(uid, 'username', function(err, username) {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if(chats[uid] && chats[uid].length) {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for(var i=0; i<chats[uid].length; ++i) {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
io.sockets.in(chats[uid][i]).emit('chatGoOffline', {uid:uid, username:username, timestamp:Date.now()});
|
|
|
|
|
|
|
|
socket.leave(chats[uid][i]);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@ -269,8 +249,8 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
socket.emit('api:user.get_online_users', returnData);
|
|
|
|
socket.emit('api:user.get_online_users', returnData);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
socket.on('api:user.isOnline', function(uid) {
|
|
|
|
socket.on('api:user.isOnline', function(uid, callback) {
|
|
|
|
socket.emit('api:user.isOnline', isUserOnline(uid));
|
|
|
|
callback({online:isUserOnline(uid), timestamp:Date.now()});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
socket.on('api:user.changePassword', function(data, callback) {
|
|
|
|
socket.on('api:user.changePassword', function(data, callback) {
|
|
|
|
@ -363,7 +343,7 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
socket.emit('event:alert', {
|
|
|
|
socket.emit('event:alert', {
|
|
|
|
title: 'Thank you for posting',
|
|
|
|
title: 'Thank you for posting',
|
|
|
|
message: 'You have successfully posted. Click here to view your post.',
|
|
|
|
message: 'You have successfully posted. Click here to view your post.',
|
|
|
|
type: 'warning',
|
|
|
|
type: 'success',
|
|
|
|
timeout: 2000
|
|
|
|
timeout: 2000
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -416,7 +396,7 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
socket.emit('event:alert', {
|
|
|
|
socket.emit('event:alert', {
|
|
|
|
title: 'Reply Successful',
|
|
|
|
title: 'Reply Successful',
|
|
|
|
message: 'You have successfully replied. Click here to view your reply.',
|
|
|
|
message: 'You have successfully replied. Click here to view your reply.',
|
|
|
|
type: 'warning',
|
|
|
|
type: 'success',
|
|
|
|
timeout: 2000
|
|
|
|
timeout: 2000
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
@ -496,7 +476,7 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
posts.emitContentTooShortAlert(socket);
|
|
|
|
posts.emitContentTooShortAlert(socket);
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
postTools.edit(uid, data.pid, data.title, data.content);
|
|
|
|
postTools.edit(uid, data.pid, data.title, data.content, data.images);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
socket.on('api:posts.delete', function(data) {
|
|
|
|
socket.on('api:posts.delete', function(data) {
|
|
|
|
@ -548,15 +528,12 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
|
|
|
|
|
|
|
|
var msg = utils.strip_tags(data.message);
|
|
|
|
var msg = utils.strip_tags(data.message);
|
|
|
|
|
|
|
|
|
|
|
|
var uids = [uid, touid].sort();
|
|
|
|
|
|
|
|
var chatroom = 'chatroom_'+uids[0]+'_'+uids[1];
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
user.getUserField(uid, 'username', function(err, username) {
|
|
|
|
user.getUserField(uid, 'username', function(err, username) {
|
|
|
|
var finalMessage = username + ': ' + msg,
|
|
|
|
var finalMessage = username + ' : ' + msg,
|
|
|
|
notifText = 'New message from <strong>' + username + '</strong>';
|
|
|
|
notifText = 'New message from <strong>' + username + '</strong>';
|
|
|
|
|
|
|
|
|
|
|
|
if(!isUserOnline(touid)) {
|
|
|
|
if(!isUserOnline(touid)) {
|
|
|
|
notifications.create(notifText, 5, '#', 'notification_' + uid + '_' + touid, function(nid) {
|
|
|
|
notifications.create(notifText, 5, 'javascript:app.openChat(''+username+'', '+uid+');', 'notification_' + uid + '_' + touid, function(nid) {
|
|
|
|
notifications.push(nid, [touid], function(success) {
|
|
|
|
notifications.push(nid, [touid], function(success) {
|
|
|
|
|
|
|
|
|
|
|
|
});
|
|
|
|
});
|
|
|
|
@ -570,13 +547,8 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
numSockets = userSockets[touid].length;
|
|
|
|
numSockets = userSockets[touid].length;
|
|
|
|
|
|
|
|
|
|
|
|
for(var x=0; x<numSockets; ++x) {
|
|
|
|
for(var x=0; x<numSockets; ++x) {
|
|
|
|
userSockets[touid][x].join(chatroom);
|
|
|
|
|
|
|
|
userSockets[touid][x].emit('chatMessage', {fromuid:uid, username:username, message: finalMessage, timestamp: Date.now()});
|
|
|
|
userSockets[touid][x].emit('chatMessage', {fromuid:uid, username:username, message: finalMessage, timestamp: Date.now()});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
chats[touid] = chats[touid] || [];
|
|
|
|
|
|
|
|
if(chats[touid].indexOf(chatroom) === -1)
|
|
|
|
|
|
|
|
chats[touid].push(chatroom);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if(userSockets[uid]) {
|
|
|
|
if(userSockets[uid]) {
|
|
|
|
@ -584,13 +556,8 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
numSockets = userSockets[uid].length;
|
|
|
|
numSockets = userSockets[uid].length;
|
|
|
|
|
|
|
|
|
|
|
|
for(var x=0; x<numSockets; ++x) {
|
|
|
|
for(var x=0; x<numSockets; ++x) {
|
|
|
|
userSockets[uid][x].join(chatroom);
|
|
|
|
|
|
|
|
userSockets[uid][x].emit('chatMessage', {fromuid:touid, username:username, message:'You : ' + msg, timestamp: Date.now()});
|
|
|
|
userSockets[uid][x].emit('chatMessage', {fromuid:touid, username:username, message:'You : ' + msg, timestamp: Date.now()});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
chats[uid] = chats[uid] || [];
|
|
|
|
|
|
|
|
if(chats[uid].indexOf(chatroom) === -1)
|
|
|
|
|
|
|
|
chats[uid].push(chatroom);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
@ -616,7 +583,6 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
if (uid > 0) {
|
|
|
|
if (uid > 0) {
|
|
|
|
if (parseInt(data.tid) > 0) {
|
|
|
|
if (parseInt(data.tid) > 0) {
|
|
|
|
topics.getTopicData(data.tid, function(topicData) {
|
|
|
|
topics.getTopicData(data.tid, function(topicData) {
|
|
|
|
|
|
|
|
|
|
|
|
if (data.body)
|
|
|
|
if (data.body)
|
|
|
|
topicData.body = data.body;
|
|
|
|
topicData.body = data.body;
|
|
|
|
|
|
|
|
|
|
|
|
@ -639,9 +605,17 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
} else if (parseInt(data.pid) > 0) {
|
|
|
|
} else if (parseInt(data.pid) > 0) {
|
|
|
|
|
|
|
|
|
|
|
|
async.parallel([
|
|
|
|
async.parallel([
|
|
|
|
function(next) {
|
|
|
|
function(next) {
|
|
|
|
posts.getPostField(data.pid, 'content', function(raw) {
|
|
|
|
posts.getPostFields(data.pid, ['content', 'uploadedImages'], function(raw) {
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
raw.uploadedImages = JSON.parse(raw.uploadedImages);
|
|
|
|
|
|
|
|
} catch(e) {
|
|
|
|
|
|
|
|
winston.err(e);
|
|
|
|
|
|
|
|
raw.uploadedImages = [];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
next(null, raw);
|
|
|
|
next(null, raw);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
},
|
|
|
|
},
|
|
|
|
@ -654,7 +628,8 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
|
|
|
|
socket.emit('api:composer.push', {
|
|
|
|
socket.emit('api:composer.push', {
|
|
|
|
title: results[1],
|
|
|
|
title: results[1],
|
|
|
|
pid: data.pid,
|
|
|
|
pid: data.pid,
|
|
|
|
body: results[0]
|
|
|
|
body: results[0].content,
|
|
|
|
|
|
|
|
uploadedImages: results[0].uploadedImages
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
Julian Lam
12 years ago