deblan-mirror/thelounge
deblan-mirror/thelounge
1
0
Fork 0
mirror of https://github.com/thelounge/thelounge.git synced 2024-05-02 06:33:19 +02:00
Code Issues Projects Releases Wiki Activity

Merge pull request #3461 from thelounge/xpaw/reconnect-unread

Browse source 
Synchronize open channel on client on reconnection
This commit is contained in:
Pavel Djundik 2019-10-21 17:59:34 +03:00 committed by GitHub
parent c4a637ab49 1ca16816c2
commit d4198e4360
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 24 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
client/js/socket-events/auth.js
View file

@ -79,15 +79,19 @@ socket.on("auth", function(data) {
for (const network of vueApp.networks) {
for (const chan of network.channels) {
for (const msg of chan.messages) {
if (msg.id > lastMessage) {
lastMessage = msg.id;
if (chan.messages.length > 0) {
const id = chan.messages[chan.messages.length - 1].id;
if (lastMessage < id) {
lastMessage = id;
}
}
}
}
socket.emit("auth", {user, token, lastMessage});
const openChannel = (vueApp.activeChannel && vueApp.activeChannel.channel.id) || null;
socket.emit("auth", {user, token, lastMessage, openChannel});
}
}

20
src/server.js
View file

@ -331,11 +331,23 @@ function indexRequest(req, res) {
);
}
function initializeClient(socket, client, token, lastMessage) {
function initializeClient(socket, client, token, lastMessage, openChannel) {
socket.emit("authorized");
client.clientAttach(socket.id, token);
// Client sends currently active channel on reconnect,
// pass it into `open` directly so it is verified and updated if necessary
if (openChannel) {
client.open(socket.id, openChannel);
// If client provided channel passes checks, use it. if client has invalid
// channel open (or windows like settings) then use last known server active channel
openChannel = client.attachedClients[socket.id].openChannel || client.lastActiveChannel;
} else {
openChannel = client.lastActiveChannel;
}
if (Helper.config.fileUpload.enable) {
new Uploader(socket);
}
@ -624,9 +636,9 @@ function initializeClient(socket, client, token, lastMessage) {
socket.emit("init", {
applicationServerKey: manager.webPush.vapidKeys.publicKey,
pushSubscription: client.config.sessions[token],
active: client.lastActiveChannel,
active: openChannel,
networks: client.networks.map((network) =>
network.getFilteredClone(client.lastActiveChannel, lastMessage)
network.getFilteredClone(openChannel, lastMessage)
),
token: tokenToSend,
});
@ -705,7 +717,7 @@ function performAuthentication(data) {
let token = null;
const finalInit = () => {
initializeClient(socket, client, token, data.lastMessage || -1);
initializeClient(socket, client, token, data.lastMessage || -1, data.openChannel);
if (!Helper.config.public) {
client.manager.updateUser(client.name, {