supernets/hardlounge
supernets/hardlounge
4
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Only send messages newer than last seen id

Browse Source
This commit is contained in:
Pavel Djundik 2017-08-28 23:14:01 +03:00
parent 05fc00d9be
commit cffa957e34
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/server.js
View File

@ -236,7 +236,7 @@ function index(req, res, next) {
res.render("index", data); res.render("index", data);
} }
function initializeClient(socket, client, token) { function initializeClient(socket, client, token, lastMessage) {
socket.emit("authorized"); socket.emit("authorized");
socket.on("disconnect", function() { socket.on("disconnect", function() {
@ -400,11 +400,24 @@ function initializeClient(socket, client, token) {
socket.join(client.id); socket.join(client.id);
const sendInitEvent = (tokenToSend) => { const sendInitEvent = (tokenToSend) => {
let networks = client.networks;
if (lastMessage > -1) {
// We need a deep cloned object because we are going to remove unneeded messages
networks = _.cloneDeep(networks);
networks.forEach((network) => {
network.channels.forEach((channel) => {
channel.messages = channel.messages.filter((m) => m.id > lastMessage);
});
});
}
socket.emit("init", { socket.emit("init", {
applicationServerKey: manager.webPush.vapidKeys.publicKey, applicationServerKey: manager.webPush.vapidKeys.publicKey,
pushSubscription: client.config.sessions[token], pushSubscription: client.config.sessions[token],
active: client.lastActiveChannel, active: client.lastActiveChannel,
networks: client.networks, networks: networks,
token: tokenToSend token: tokenToSend
}); });
}; };
@ -434,7 +447,7 @@ function performAuthentication(data) {
const socket = this; const socket = this;
let client; let client;
const finalInit = () => initializeClient(socket, client, data.token || null); const finalInit = () => initializeClient(socket, client, data.token || null, data.lastMessage || -1);
const initClient = () => { const initClient = () => {
client.ip = getClientIp(socket.request); client.ip = getClientIp(socket.request);