thelounge/client/js/socket-events/msg.js

"use strict";

const $ = require("jquery");
const socket = require("../socket");
const utils = require("../utils");
const options = require("../options");
const cleanIrcMessage = require("../libs/handlebars/ircmessageparser/cleanIrcMessage");
const webpush = require("../webpush");
const {vueApp, findChannel} = require("../vue");

let pop;

try {
	pop = new Audio();
	pop.src = "audio/pop.wav";
} catch (e) {
	pop = {
		play: $.noop,
	};
}

socket.on("msg", function(data) {
	if (utils.lastMessageId < data.msg.id) {
		utils.lastMessageId = data.msg.id;
	}

	// We set a maximum timeout of 2 seconds so that messages don't take too long to appear.
	utils.requestIdleCallback(() => processReceivedMessage(data), 2000);
});

function processReceivedMessage(data) {
	let targetId = data.chan;
	let target = "#chan-" + targetId;
	let channelContainer = $("#chat").find(target);
	let channel = findChannel(data.chan);

	channel.channel.highlight = data.highlight;
	channel.channel.unread = data.unread;

	if (data.msg.self || data.msg.highlight) {
		utils.updateTitle();
	}

	// Display received notices and errors in currently active channel.
	// Reloading the page will put them back into the lobby window.
	// We only want to put errors/notices in active channel if they arrive on the same network
	if (data.msg.showInActive && vueApp.activeChannel && vueApp.activeChannel.network === channel.network) {
		channel = vueApp.activeChannel;

		targetId = data.chan = vueApp.activeChannel.channel.id;

		target = "#chan-" + targetId;
		channelContainer = $("#chat").find(target);
	}

	const scrollContainer = channelContainer.find(".chat");
	const container = channelContainer.find(".messages");

	if (data.msg.type === "channel_list" || data.msg.type === "ban_list" || data.msg.type === "ignore_list") {
		$(container).empty();
	}

	channel.channel.messages.push(data.msg);

	notifyMessage(targetId, channelContainer, data);

	if (data.msg.self) {
		channel.channel.firstUnread = 0;
	}

	let messageLimit = 0;

	if (!vueApp.activeChannel || vueApp.activeChannel.channel !== channel.channel) {
		// If message arrives in non active channel, keep only 100 messages
		messageLimit = 100;
	} else {
		const el = scrollContainer.get(0);

		// If message arrives in active channel, keep 500 messages if scroll is currently at the bottom
		if (el.scrollHeight - el.scrollTop - el.offsetHeight <= 30) {
			messageLimit = 500;
		}
	}

	if (messageLimit > 0) {
		channel.channel.messages.splice(0, channel.channel.messages.length - messageLimit);
	}

	if ((data.msg.type === "message" || data.msg.type === "action") && channel.channel.type === "channel") {
		const user = channel.channel.users.find((u) => u.nick === data.msg.from.nick);

		if (user) {
			user.lastMessage = (new Date(data.msg.time)).getTime() || Date.now();
		}
	}
}

function notifyMessage(targetId, channel, msg) {
	msg = msg.msg;

	if (msg.self) {
		return;
	}

	const button = $("#sidebar .chan[data-id='" + targetId + "']");

	if (msg.highlight || (options.settings.notifyAllMessages && msg.type === "message")) {
		if (!document.hasFocus() || !channel.hasClass("active")) {
			if (options.settings.notification) {
				try {
					pop.play();
				} catch (exception) {
					// On mobile, sounds can not be played without user interaction.
				}
			}

			utils.toggleNotificationMarkers(true);

			if (options.settings.desktopNotifications && ("Notification" in window) && Notification.permission === "granted") {
				let title;
				let body;

				if (msg.type === "invite") {
					title = "New channel invite:";
					body = msg.from.nick + " invited you to " + msg.channel;
				} else {
					title = msg.from.nick;

					if (!button.hasClass("query")) {
						title += " (" + button.attr("aria-label").trim() + ")";
					}

					if (msg.type === "message") {
						title += " says:";
					}

					body = cleanIrcMessage(msg.text);
				}

				const timestamp = Date.parse(msg.time);

				try {
					if (webpush.hasServiceWorker) {
						navigator.serviceWorker.ready.then((registration) => {
							registration.active.postMessage({
								type: "notification",
								chanId: targetId,
								timestamp: timestamp,
								title: title,
								body: body,
							});
						});
					} else {
						const notify = new Notification(title, {
							tag: `chan-${targetId}`,
							badge: "img/icon-alerted-black-transparent-bg-72x72px.png",
							icon: "img/icon-alerted-grey-bg-192x192px.png",
							body: body,
							timestamp: timestamp,
						});
						notify.addEventListener("click", function() {
							window.focus();
							button.trigger("click");
							this.close();
						});
					}
				} catch (exception) {
					// `new Notification(...)` is not supported and should be silenced.
				}
			}
		}
	}
}