"use strict"; const Chan = require("../../models/chan"); const Msg = require("../../models/msg"); const LinkPrefetch = require("./link"); const cleanIrcMessage = require("../../../client/js/libs/handlebars/ircmessageparser/cleanIrcMessage"); const nickRegExp = /[\w[\]\\`^{|}-]{4,}/gi; module.exports = function(irc, network) { const client = this; irc.on("notice", function(data) { // Some servers send notices without any nickname if (!data.nick) { data.from_server = true; data.nick = network.host; } data.type = Msg.Type.NOTICE; handleMessage(data); }); irc.on("action", function(data) { data.type = Msg.Type.ACTION; handleMessage(data); }); irc.on("privmsg", function(data) { data.type = Msg.Type.MESSAGE; handleMessage(data); }); irc.on("wallops", function(data) { data.from_server = true; data.type = Msg.Type.NOTICE; handleMessage(data); }); function handleMessage(data) { let chan; let user; let highlight = false; const self = data.nick === irc.user.nick; // Server messages go to server window, no questions asked if (data.from_server) { chan = network.channels[0]; user = chan.getUser(data.nick); } else { let target = data.target; // If the message is targeted at us, use sender as target instead if (target.toLowerCase() === irc.user.nick.toLowerCase()) { target = data.nick; } chan = network.getChannel(target); if (typeof chan === "undefined") { // Send notices that are not targeted at us into the server window if (data.type === Msg.Type.NOTICE) { chan = network.channels[0]; } else { chan = new Chan({ type: Chan.Type.QUERY, name: target, }); network.channels.push(chan); client.emit("join", { network: network.id, chan: chan, }); } } user = chan.getUser(data.nick); // Query messages (unless self) always highlight if (chan.type === Chan.Type.QUERY) { highlight = !self; } else if (chan.type === Chan.Type.CHANNEL) { user.lastMessage = data.time || Date.now(); } } // Self messages in channels are never highlighted // Non-self messages are highlighted as soon as the nick is detected if (!highlight && !self) { highlight = network.highlightRegex.test(data.message); } const users = []; let match; while ((match = nickRegExp.exec(data.message))) { if (chan.findUser(match[0])) { users.push(match[0]); } } const msg = new Msg({ type: data.type, time: data.time, from: user, text: data.message, self: self, highlight: highlight, users: users, }); // No prefetch URLs unless are simple MESSAGE or ACTION types if ([Msg.Type.MESSAGE, Msg.Type.ACTION].indexOf(data.type) !== -1) { LinkPrefetch(client, chan, msg); } chan.pushMessage(client, msg, !self); // Do not send notifications for messages older than 15 minutes (znc buffer for example) if (highlight && (!data.time || data.time > Date.now() - 900000)) { let title = chan.name; let body = cleanIrcMessage(data.message); // In channels, prepend sender nickname to the message if (chan.type !== Chan.Type.QUERY) { body = `${data.nick}: ${body}`; } // If a channel is active on any client, highlight won't increment and notification will say (0 mention) if (chan.highlight > 0) { title += ` (${chan.highlight} ${chan.type === Chan.Type.QUERY ? "new message" : "mention"}${chan.highlight > 1 ? "s" : ""})`; } if (chan.highlight > 1) { body += `\n\n… and ${chan.highlight - 1} other message${chan.highlight > 2 ? "s" : ""}`; } client.manager.webPush.push(client, { type: "notification", chanId: chan.id, timestamp: data.time || Date.now(), title: title, body: body, }, true); } } };