563 lines
16 KiB
JavaScript
563 lines
16 KiB
JavaScript
var User = require("../user");
|
|
var XSS = require("../xss");
|
|
var ChannelModule = require("./module");
|
|
var util = require("../utilities");
|
|
var Flags = require("../flags");
|
|
var url = require("url");
|
|
|
|
const SHADOW_TAG = "[shadow]";
|
|
const LINK = /(\w+:\/\/(?:[^:\/\[\]\s]+|\[[0-9a-f:]+\])(?::\d+)?(?:\/[^\/\s]*)*)/ig;
|
|
const TYPE_CHAT = {
|
|
msg: "string",
|
|
meta: "object,optional"
|
|
};
|
|
|
|
const TYPE_PM = {
|
|
msg: "string",
|
|
to: "string",
|
|
meta: "object,optional"
|
|
};
|
|
|
|
function ChatModule(channel) {
|
|
ChannelModule.apply(this, arguments);
|
|
this.buffer = [];
|
|
this.muted = new util.Set();
|
|
this.commandHandlers = {};
|
|
|
|
/* Default commands */
|
|
this.registerCommand("/me", this.handleCmdMe.bind(this));
|
|
this.registerCommand("/sp", this.handleCmdSp.bind(this));
|
|
this.registerCommand("/say", this.handleCmdSay.bind(this));
|
|
this.registerCommand("/shout", this.handleCmdSay.bind(this));
|
|
this.registerCommand("/clear", this.handleCmdClear.bind(this));
|
|
this.registerCommand("/a", this.handleCmdAdminflair.bind(this));
|
|
this.registerCommand("/afk", this.handleCmdAfk.bind(this));
|
|
this.registerCommand("/mute", this.handleCmdMute.bind(this));
|
|
this.registerCommand("/smute", this.handleCmdSMute.bind(this));
|
|
this.registerCommand("/unmute", this.handleCmdUnmute.bind(this));
|
|
this.registerCommand("/unsmute", this.handleCmdUnmute.bind(this));
|
|
}
|
|
|
|
ChatModule.prototype = Object.create(ChannelModule.prototype);
|
|
|
|
ChatModule.prototype.load = function (data) {
|
|
this.buffer = [];
|
|
this.muted = new util.Set();
|
|
|
|
if ("chatbuffer" in data) {
|
|
for (var i = 0; i < data.chatbuffer.length; i++) {
|
|
this.buffer.push(data.chatbuffer[i]);
|
|
}
|
|
}
|
|
|
|
if ("chatmuted" in data) {
|
|
for (var i = 0; i < data.chatmuted.length; i++) {
|
|
this.muted.add(data.chatmuted[i]);
|
|
}
|
|
}
|
|
};
|
|
|
|
ChatModule.prototype.save = function (data) {
|
|
data.chatbuffer = this.buffer;
|
|
data.chatmuted = Array.prototype.slice.call(this.muted);
|
|
};
|
|
|
|
ChatModule.prototype.packInfo = function (data, isAdmin) {
|
|
data.chat = Array.prototype.slice.call(this.buffer);
|
|
};
|
|
|
|
ChatModule.prototype.onUserPostJoin = function (user) {
|
|
var self = this;
|
|
user.waitFlag(Flags.U_LOGGED_IN, function () {
|
|
var muteperm = self.channel.modules.permissions.permissions.mute;
|
|
if (self.isShadowMuted(user.getName())) {
|
|
user.setFlag(Flags.U_SMUTED | Flags.U_MUTED);
|
|
self.channel.sendUserMeta(self.channel.users, user, muteperm);
|
|
} else if (self.isMuted(user.getName())) {
|
|
user.setFlag(Flags.U_MUTED);
|
|
self.channel.sendUserMeta(self.channel.users, user, muteperm);
|
|
}
|
|
});
|
|
|
|
user.socket.typecheckedOn("chatMsg", TYPE_CHAT, this.handleChatMsg.bind(this, user));
|
|
user.socket.typecheckedOn("pm", TYPE_PM, this.handlePm.bind(this, user));
|
|
this.buffer.forEach(function (msg) {
|
|
user.socket.emit("chatMsg", msg);
|
|
});
|
|
};
|
|
|
|
ChatModule.prototype.isMuted = function (name) {
|
|
return this.muted.contains(name.toLowerCase()) ||
|
|
this.muted.contains(SHADOW_TAG + name.toLowerCase());
|
|
};
|
|
|
|
ChatModule.prototype.mutedUsers = function () {
|
|
var self = this;
|
|
return self.channel.users.filter(function (u) {
|
|
return self.isMuted(u.getName());
|
|
});
|
|
};
|
|
|
|
ChatModule.prototype.isShadowMuted = function (name) {
|
|
return this.muted.contains(SHADOW_TAG + name.toLowerCase());
|
|
};
|
|
|
|
ChatModule.prototype.shadowMutedUsers = function () {
|
|
var self = this;
|
|
return self.channel.users.filter(function (u) {
|
|
return self.isShadowMuted(u.getName());
|
|
});
|
|
};
|
|
|
|
ChatModule.prototype.handleChatMsg = function (user, data) {
|
|
var self = this;
|
|
|
|
if (!this.channel || !this.channel.modules.permissions.canChat(user)) {
|
|
return;
|
|
}
|
|
|
|
// Limit to 240 characters
|
|
data.msg = data.msg.substring(0, 240);
|
|
// If channel doesn't permit them, strip ASCII control characters
|
|
if (!this.channel.modules.options ||
|
|
!this.channel.modules.options.get("allow_ascii_control")) {
|
|
|
|
data.msg = data.msg.replace(/[\x00-\x1f]+/g, " ");
|
|
}
|
|
|
|
// Disallow blankposting
|
|
if (!data.msg.trim()) {
|
|
return;
|
|
}
|
|
|
|
if (!user.is(Flags.U_LOGGED_IN)) {
|
|
return;
|
|
}
|
|
|
|
var meta = {};
|
|
data.meta = data.meta || {};
|
|
if (user.account.effectiveRank >= 2) {
|
|
if ("modflair" in data.meta && data.meta.modflair === user.account.effectiveRank) {
|
|
meta.modflair = data.meta.modflair;
|
|
}
|
|
}
|
|
data.meta = meta;
|
|
|
|
this.channel.checkModules("onUserPreChat", [user, data], function (err, result) {
|
|
if (result === ChannelModule.PASSTHROUGH) {
|
|
self.processChatMsg(user, data);
|
|
}
|
|
});
|
|
};
|
|
|
|
ChatModule.prototype.handlePm = function (user, data) {
|
|
if (!this.channel) {
|
|
return;
|
|
}
|
|
|
|
if (!user.is(Flags.U_LOGGED_IN)) {
|
|
return user.socket.emit("errorMsg", {
|
|
msg: "You must be signed in to send PMs"
|
|
});
|
|
}
|
|
|
|
var reallyTo = data.to;
|
|
data.to = data.to.toLowerCase();
|
|
|
|
if (data.to === user.getLowerName()) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "You can't PM yourself!"
|
|
});
|
|
return;
|
|
}
|
|
|
|
if (!util.isValidUserName(data.to)) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "PM failed: " + data.to + " isn't a valid username."
|
|
});
|
|
return;
|
|
}
|
|
|
|
var msg = data.msg.substring(0, 240);
|
|
var to = null;
|
|
for (var i = 0; i < this.channel.users.length; i++) {
|
|
if (this.channel.users[i].getLowerName() === data.to) {
|
|
to = this.channel.users[i];
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!to) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "PM failed: " + data.to + " isn't connected to this channel."
|
|
});
|
|
return;
|
|
}
|
|
|
|
var meta = {};
|
|
data.meta = data.meta || {};
|
|
if (user.rank >= 2) {
|
|
if ("modflair" in data.meta && data.meta.modflair === user.rank) {
|
|
meta.modflair = data.meta.modflair;
|
|
}
|
|
}
|
|
|
|
if (msg.indexOf(">") === 0) {
|
|
meta.addClass = "greentext";
|
|
}
|
|
|
|
data.meta = meta;
|
|
var msgobj = this.formatMessage(user.getName(), data);
|
|
msgobj.to = to.getName();
|
|
|
|
to.socket.emit("pm", msgobj);
|
|
user.socket.emit("pm", msgobj);
|
|
};
|
|
|
|
ChatModule.prototype.processChatMsg = function (user, data) {
|
|
if (data.msg.indexOf("/afk") === -1) {
|
|
user.setAFK(false);
|
|
}
|
|
|
|
var msgobj = this.formatMessage(user.getName(), data);
|
|
if (this.channel.modules.options &&
|
|
this.channel.modules.options.get("chat_antiflood") &&
|
|
user.account.effectiveRank < 2) {
|
|
|
|
var antiflood = this.channel.modules.options.get("chat_antiflood_params");
|
|
if (user.chatLimiter.throttle(antiflood)) {
|
|
user.socket.emit("cooldown", 1000 / antiflood.sustained);
|
|
return;
|
|
}
|
|
}
|
|
|
|
if (user.is(Flags.U_SMUTED)) {
|
|
this.shadowMutedUsers().forEach(function (u) {
|
|
u.socket.emit("chatMsg", msgobj);
|
|
});
|
|
msgobj.meta.shadow = true;
|
|
this.channel.moderators().forEach(function (u) {
|
|
u.socket.emit("chatMsg", msgobj);
|
|
});
|
|
return;
|
|
} else if (user.is(Flags.U_MUTED)) {
|
|
user.socket.emit("noflood", {
|
|
action: "chat",
|
|
msg: "You have been muted on this channel."
|
|
});
|
|
return;
|
|
}
|
|
|
|
if (data.msg.indexOf("/") === 0) {
|
|
var space = data.msg.indexOf(" ");
|
|
var cmd;
|
|
if (space < 0) {
|
|
cmd = data.msg.substring(1);
|
|
} else {
|
|
cmd = data.msg.substring(1, space);
|
|
}
|
|
|
|
if (cmd in this.commandHandlers) {
|
|
this.commandHandlers[cmd](user, data.msg, data.meta);
|
|
} else {
|
|
this.sendMessage(msgobj);
|
|
}
|
|
} else {
|
|
if (data.msg.indexOf(">") === 0) {
|
|
msgobj.meta.addClass = "greentext";
|
|
}
|
|
this.sendMessage(msgobj);
|
|
}
|
|
};
|
|
|
|
ChatModule.prototype.formatMessage = function (username, data) {
|
|
var msg = XSS.sanitizeText(data.msg);
|
|
if (this.channel.modules.filters) {
|
|
msg = this.filterMessage(msg);
|
|
}
|
|
var obj = {
|
|
username: username,
|
|
msg: msg,
|
|
meta: data.meta,
|
|
time: Date.now()
|
|
};
|
|
|
|
return obj;
|
|
};
|
|
|
|
const link = /(\w+:\/\/(?:[^:\/\[\]\s]+|\[[0-9a-f:]+\])(?::\d+)?(?:\/[^\/\s]*)*)/ig;
|
|
ChatModule.prototype.filterMessage = function (msg) {
|
|
var filters = this.channel.modules.filters.filters;
|
|
var chan = this.channel;
|
|
var parts = msg.split(link);
|
|
var convertLinks = this.channel.modules.options.get("enable_link_regex");
|
|
|
|
for (var j = 0; j < parts.length; j++) {
|
|
/* substring is a URL */
|
|
if (convertLinks && parts[j].match(link)) {
|
|
var original = parts[j];
|
|
parts[j] = filters.exec(parts[j], { filterlinks: true });
|
|
|
|
/* no filters changed the URL, apply link filter */
|
|
if (parts[j] === original) {
|
|
parts[j] = url.format(url.parse(parts[j]));
|
|
parts[j] = parts[j].replace(link, "<a href=\"$1\" target=\"_blank\">$1</a>");
|
|
}
|
|
|
|
} else {
|
|
/* substring is not a URL */
|
|
parts[j] = filters.exec(parts[j], { filterlinks: false });
|
|
}
|
|
}
|
|
|
|
msg = parts.join("");
|
|
/* Anti-XSS */
|
|
return XSS.sanitizeHTML(msg);
|
|
};
|
|
|
|
ChatModule.prototype.sendModMessage = function (msg, minrank) {
|
|
if (isNaN(minrank)) {
|
|
minrank = 2;
|
|
}
|
|
|
|
var msgobj = {
|
|
username: "[server]",
|
|
msg: msg,
|
|
meta: {
|
|
addClass: "server-whisper",
|
|
addClassToNameAndTimestamp: true
|
|
},
|
|
time: Date.now()
|
|
};
|
|
|
|
this.channel.users.forEach(function (u) {
|
|
if (u.account.effectiveRank >= minrank) {
|
|
u.socket.emit("chatMsg", msgobj);
|
|
}
|
|
});
|
|
};
|
|
|
|
ChatModule.prototype.sendMessage = function (msgobj) {
|
|
this.channel.broadcastAll("chatMsg", msgobj);
|
|
|
|
this.buffer.push(msgobj);
|
|
if (this.buffer.length > 15) {
|
|
this.buffer.shift();
|
|
}
|
|
|
|
this.channel.logger.log("<" + msgobj.username + (msgobj.meta.addClass ?
|
|
"." + msgobj.meta.addClass : "") +
|
|
"> " + XSS.decodeText(msgobj.msg));
|
|
};
|
|
|
|
ChatModule.prototype.registerCommand = function (cmd, cb) {
|
|
cmd = cmd.replace(/^\//, "");
|
|
this.commandHandlers[cmd] = cb;
|
|
};
|
|
|
|
/**
|
|
* == Default commands ==
|
|
*/
|
|
|
|
ChatModule.prototype.handleCmdMe = function (user, msg, meta) {
|
|
meta.addClass = "action";
|
|
meta.action = true;
|
|
var args = msg.split(" ");
|
|
args.shift();
|
|
this.processChatMsg(user, { msg: args.join(" "), meta: meta });
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdSp = function (user, msg, meta) {
|
|
meta.addClass = "spoiler";
|
|
var args = msg.split(" ");
|
|
args.shift();
|
|
this.processChatMsg(user, { msg: args.join(" "), meta: meta });
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdSay = function (user, msg, meta) {
|
|
if (user.account.effectiveRank < 1.5) {
|
|
return;
|
|
}
|
|
meta.addClass = "shout";
|
|
meta.addClassToNameAndTimestamp = true;
|
|
meta.forceShowName = true;
|
|
var args = msg.split(" ");
|
|
args.shift();
|
|
this.processChatMsg(user, { msg: args.join(" "), meta: meta });
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdClear = function (user, msg, meta) {
|
|
if (!this.channel.modules.permissions.canClearChat(user)) {
|
|
return;
|
|
}
|
|
|
|
this.buffer = [];
|
|
this.channel.broadcastAll("clearchat");
|
|
this.channel.logger.log("[mod] " + user.getName() + " used /clear");
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdAdminflair = function (user, msg, meta) {
|
|
if (user.account.globalRank < 255) {
|
|
return;
|
|
}
|
|
var args = msg.split(" ");
|
|
args.shift();
|
|
|
|
var superadminflair = {
|
|
labelclass: "label-danger",
|
|
icon: "glyphicon-globe"
|
|
};
|
|
|
|
var cargs = [];
|
|
args.forEach(function (a) {
|
|
if (a.indexOf("!icon-") === 0) {
|
|
superadminflair.icon = "glyph" + a.substring(1);
|
|
} else if (a.indexOf("!label-") === 0) {
|
|
superadminflair.labelclass = a.substring(1);
|
|
} else {
|
|
cargs.push(a);
|
|
}
|
|
});
|
|
|
|
meta.superadminflair = superadminflair;
|
|
meta.forceShowName = true;
|
|
|
|
this.processChatMsg(user, { msg: cargs.join(" "), meta: meta });
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdAfk = function (user, msg, meta) {
|
|
user.setAFK(!user.is(Flags.U_AFK));
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdMute = function (user, msg, meta) {
|
|
if (!this.channel.modules.permissions.canMute(user)) {
|
|
return;
|
|
}
|
|
|
|
var muteperm = this.channel.modules.permissions.permissions.mute;
|
|
var args = msg.split(" ");
|
|
args.shift(); /* shift off /mute */
|
|
|
|
var name = args.shift();
|
|
if (typeof name !== "string") {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "/mute requires a target name"
|
|
});
|
|
return;
|
|
}
|
|
name = name.toLowerCase();
|
|
|
|
var target;
|
|
|
|
for (var i = 0; i < this.channel.users.length; i++) {
|
|
if (this.channel.users[i].getLowerName() === name) {
|
|
target = this.channel.users[i];
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!target) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "/mute target " + name + " not present in channel."
|
|
});
|
|
return;
|
|
}
|
|
|
|
if (target.account.effectiveRank >= user.account.effectiveRank) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "/mute failed - " + target.getName() + " has equal or higher rank " +
|
|
"than you."
|
|
});
|
|
return;
|
|
}
|
|
|
|
target.setFlag(Flags.U_MUTED);
|
|
this.muted.add(name);
|
|
this.channel.sendUserMeta(this.channel.users, target, -1);
|
|
this.channel.logger.log("[mod] " + user.getName() + " muted " + target.getName());
|
|
this.sendModMessage(user.getName() + " muted " + target.getName(), muteperm);
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdSMute = function (user, msg, meta) {
|
|
if (!this.channel.modules.permissions.canMute(user)) {
|
|
return;
|
|
}
|
|
|
|
var muteperm = this.channel.modules.permissions.permissions.mute;
|
|
var args = msg.split(" ");
|
|
args.shift(); /* shift off /smute */
|
|
|
|
var name = args.shift().toLowerCase();
|
|
var target;
|
|
|
|
for (var i = 0; i < this.channel.users.length; i++) {
|
|
if (this.channel.users[i].getLowerName() === name) {
|
|
target = this.channel.users[i];
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!target) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "/smute target " + name + " not present in channel."
|
|
});
|
|
return;
|
|
}
|
|
|
|
if (target.account.effectiveRank >= user.account.effectiveRank) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: "/smute failed - " + target.getName() + " has equal or higher rank " +
|
|
"than you."
|
|
});
|
|
return;
|
|
}
|
|
|
|
target.setFlag(Flags.U_MUTED | Flags.U_SMUTED);
|
|
this.muted.add(name);
|
|
this.muted.add(SHADOW_TAG + name);
|
|
this.channel.sendUserMeta(this.channel.users, target, muteperm);
|
|
this.channel.logger.log("[mod] " + user.getName() + " shadowmuted " + target.getName());
|
|
this.sendModMessage(user.getName() + " shadowmuted " + target.getName(), muteperm);
|
|
};
|
|
|
|
ChatModule.prototype.handleCmdUnmute = function (user, msg, meta) {
|
|
if (!this.channel.modules.permissions.canMute(user)) {
|
|
return;
|
|
}
|
|
|
|
var muteperm = this.channel.modules.permissions.permissions.mute;
|
|
var args = msg.split(" ");
|
|
args.shift(); /* shift off /mute */
|
|
|
|
var name = args.shift().toLowerCase();
|
|
|
|
if (!this.isMuted(name)) {
|
|
user.socket.emit("errorMsg", {
|
|
msg: name + " is not muted."
|
|
});
|
|
return;
|
|
}
|
|
|
|
this.muted.remove(name);
|
|
this.muted.remove(SHADOW_TAG + name);
|
|
|
|
var target;
|
|
for (var i = 0; i < this.channel.users.length; i++) {
|
|
if (this.channel.users[i].getLowerName() === name) {
|
|
target = this.channel.users[i];
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!target) {
|
|
return;
|
|
}
|
|
|
|
target.clearFlag(Flags.U_MUTED | Flags.U_SMUTED);
|
|
this.channel.sendUserMeta(this.channel.users, target, -1);
|
|
this.channel.logger.log("[mod] " + user.getName() + " unmuted " + target.getName());
|
|
this.sendModMessage(user.getName() + " unmuted " + target.getName(), muteperm);
|
|
};
|
|
|
|
module.exports = ChatModule;
|