aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormarzavec <admin@marzavec.com>2018-06-04 09:07:24 +0200
committermarzavec <admin@marzavec.com>2018-06-04 09:07:24 +0200
commite35fff59ba30e78046c9212e74fce9aef56c6e93 (patch)
treec7d3e0cd75f5a6063d629d4295952488907e9562
parentCompleted protocol decoupling (diff)
downloadhackchat-e35fff59ba30e78046c9212e74fce9aef56c6e93.tar.gz
hackchat-e35fff59ba30e78046c9212e74fce9aef56c6e93.zip
cleaned up and commented modules
-rw-r--r--clientSource/package-lock.json2
-rw-r--r--package-lock.json2
-rw-r--r--server/package-lock.json2
-rw-r--r--server/src/commands/admin/addmod.js15
-rw-r--r--server/src/commands/admin/listusers.js27
-rw-r--r--server/src/commands/admin/reload.js9
-rw-r--r--server/src/commands/admin/saveconfig.js15
-rw-r--r--server/src/commands/admin/shout.js9
-rw-r--r--server/src/commands/core/changenick.js19
-rw-r--r--server/src/commands/core/chat.js8
-rw-r--r--server/src/commands/core/help.js6
-rw-r--r--server/src/commands/core/invite.js24
-rw-r--r--server/src/commands/core/join.js34
-rw-r--r--server/src/commands/core/morestats.js11
-rw-r--r--server/src/commands/core/move.js15
-rw-r--r--server/src/commands/core/stats.js5
-rw-r--r--server/src/commands/internal/disconnect.js2
-rw-r--r--server/src/commands/internal/socketreply.js1
-rw-r--r--server/src/commands/mod/ban.js19
-rw-r--r--server/src/commands/mod/dumb.js11
-rw-r--r--server/src/commands/mod/kick.js14
-rw-r--r--server/src/commands/mod/speak.js9
-rw-r--r--server/src/commands/mod/unban.js15
23 files changed, 185 insertions, 89 deletions
diff --git a/clientSource/package-lock.json b/clientSource/package-lock.json
index 25a29ca..f308f6b 100644
--- a/clientSource/package-lock.json
+++ b/clientSource/package-lock.json
@@ -1,6 +1,6 @@
{
"name": "hack.chat-v2",
- "version": "2.0.1",
+ "version": "2.0.3",
"lockfileVersion": 1,
"requires": true,
"dependencies": {
diff --git a/package-lock.json b/package-lock.json
index 6fd5471..8ddaa40 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,6 +1,6 @@
{
"name": "hack.chat-v2",
- "version": "2.0.2",
+ "version": "2.0.3",
"lockfileVersion": 1,
"requires": true,
"dependencies": {
diff --git a/server/package-lock.json b/server/package-lock.json
index aa8283d..b18faf3 100644
--- a/server/package-lock.json
+++ b/server/package-lock.json
@@ -1,6 +1,6 @@
{
"name": "hack.chat-v2",
- "version": "2.0.1",
+ "version": "2.0.3",
"lockfileVersion": 1,
"requires": true,
"dependencies": {
diff --git a/server/src/commands/admin/addmod.js b/server/src/commands/admin/addmod.js
index 4c13b22..bde54a1 100644
--- a/server/src/commands/admin/addmod.js
+++ b/server/src/commands/admin/addmod.js
@@ -3,19 +3,18 @@
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin
if (socket.uType != 'admin') {
- // ignore if not admin
- return;
- }
+ server._police.frisk(socket.remoteAddress, 20);
- let mod = {
- trip: data.trip
+ return;
}
- core.config.mods.push(mod); // purposely not using `config.set()` to avoid auto-save
+ // add new trip to config
+ core.config.mods.push({ trip: data.trip }); // purposely not using `config.set()` to avoid auto-save
+ // upgarde existing connections & notify user
let newMod = server.findSockets({ trip: data.trip });
-
if (newMod.length !== 0) {
for (let i = 0, l = newMod.length; i < l; i++) {
newMod[i].uType = 'mod';
@@ -27,11 +26,13 @@ exports.run = async (core, server, socket, data) => {
}
}
+ // return success message
server.reply({
cmd: 'info',
text: `Added mod trip: ${data.trip}`
}, socket);
+ // notify all mods
server.broadcast({
cmd: 'info',
text: `Added mod trip: ${data.trip}`
diff --git a/server/src/commands/admin/listusers.js b/server/src/commands/admin/listusers.js
index a539a3c..d3dddc2 100644
--- a/server/src/commands/admin/listusers.js
+++ b/server/src/commands/admin/listusers.js
@@ -3,32 +3,37 @@
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin
if (socket.uType != 'admin') {
- // ignore if not admin
+ server._police.frisk(socket.remoteAddress, 20);
+
return;
}
+ // find all users currently in a channel
+ let currentUsers = server.findSockets({
+ channel: (channel) => true
+ });
+
+ // compile channel and user list
let channels = {};
- for (var client of server.clients) {
- if (client.channel) {
- if (!channels[client.channel]) {
- channels[client.channel] = [];
- }
- channels[client.channel].push(client.nick);
+ for (let i = 0, j = currentUsers.length; i < j; i++) {
+ if (typeof channels[currentUsers[i].channel] === 'undefined') {
+ channels[currentUsers[i].channel] = [];
}
+ channels[currentUsers[i].channel].push(currentUsers[i].nick);
}
+ // build output
let lines = [];
for (let channel in channels) {
lines.push(`?${channel} ${channels[channel].join(", ")}`);
}
- let text = '';
- text += lines.join("\n");
-
+ // send reply
server.reply({
cmd: 'info',
- text: text
+ text: lines.join("\n")
}, socket);
};
diff --git a/server/src/commands/admin/reload.js b/server/src/commands/admin/reload.js
index e2cfbe6..7a0ffdc 100644
--- a/server/src/commands/admin/reload.js
+++ b/server/src/commands/admin/reload.js
@@ -3,25 +3,31 @@
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin
if (socket.uType != 'admin') {
- // ignore if not admin
+ server._police.frisk(socket.remoteAddress, 20);
+
return;
}
+ // do command reloads and store results
let loadResult = core.managers.dynamicImports.reloadDirCache('src/commands');
loadResult += core.commands.loadCommands();
+ // build reply based on reload results
if (loadResult == '') {
loadResult = `Loaded ${core.commands._commands.length} commands, 0 errors`;
} else {
loadResult = `Loaded ${core.commands._commands.length} commands, error(s): ${loadResult}`;
}
+ // reply with results
server.reply({
cmd: 'info',
text: loadResult
}, socket);
+ // notify mods of reload #transparency
server.broadcast({
cmd: 'info',
text: loadResult
@@ -32,4 +38,3 @@ exports.info = {
name: 'reload',
description: '(Re)loads any new commands into memory, outputs errors if any'
};
-
diff --git a/server/src/commands/admin/saveconfig.js b/server/src/commands/admin/saveconfig.js
index ed3a312..20927e7 100644
--- a/server/src/commands/admin/saveconfig.js
+++ b/server/src/commands/admin/saveconfig.js
@@ -1,16 +1,17 @@
/*
- Description: Writes any changes to the config to the disk
+ Description: Writes the current config to disk
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin
if (socket.uType != 'admin') {
- // ignore if not admin
+ server._police.frisk(socket.remoteAddress, 20);
+
return;
}
- let saveResult = core.managers.config.save();
-
- if (!saveResult) {
+ // attempt save, notify of failure
+ if (!core.managers.config.save()) {
server.reply({
cmd: 'warn',
text: 'Failed to save config, check logs.'
@@ -19,11 +20,13 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // return success message
server.reply({
cmd: 'info',
text: 'Config saved!'
}, socket);
+ // notify mods #transparency
server.broadcast({
cmd: 'info',
text: 'Config saved!'
@@ -32,5 +35,5 @@ exports.run = async (core, server, socket, data) => {
exports.info = {
name: 'saveconfig',
- description: 'Saves current config'
+ description: 'Writes the current config to disk'
};
diff --git a/server/src/commands/admin/shout.js b/server/src/commands/admin/shout.js
index 1358dd9..80a6470 100644
--- a/server/src/commands/admin/shout.js
+++ b/server/src/commands/admin/shout.js
@@ -3,12 +3,15 @@
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin
if (socket.uType != 'admin') {
- // ignore if not admin
+ server._police.frisk(socket.remoteAddress, 20);
+
return;
}
- server.broadcast( {
+ // send text to all channels
+ server.broadcast({
cmd: 'info',
text: `Server Notice: ${data.text}`
}, {});
@@ -20,4 +23,4 @@ exports.info = {
name: 'shout',
usage: 'shout {text}',
description: 'Displays passed text to every client connected'
-}; \ No newline at end of file
+};
diff --git a/server/src/commands/core/changenick.js b/server/src/commands/core/changenick.js
index 4041bb0..5a8b5c2 100644
--- a/server/src/commands/core/changenick.js
+++ b/server/src/commands/core/changenick.js
@@ -2,9 +2,7 @@
Description: Generates a semi-unique channel name then broadcasts it to each client
*/
-const verifyNickname = (nick) => {
- return /^[a-zA-Z0-9_]{1,24}$/.test(nick);
-};
+const verifyNickname = (nick) => /^[a-zA-Z0-9_]{1,24}$/.test(nick);
exports.run = async (core, server, socket, data) => {
if (server._police.frisk(socket.remoteAddress, 6)) {
@@ -16,12 +14,13 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // verify user data is string
if (typeof data.nick !== 'string') {
return;
}
+ // make sure requested nickname meets standards
let newNick = data.nick.trim();
-
if (!verifyNickname(newNick)) {
server.reply({
cmd: 'warn',
@@ -31,6 +30,8 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // prevent admin impersonation
+ // TODO: prevent mod impersonation
if (newNick.toLowerCase() == core.config.adminName.toLowerCase()) {
server._police.frisk(socket.remoteAddress, 4);
@@ -42,11 +43,13 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // find any sockets that have the same nickname
let userExists = server.findSockets({
channel: socket.channel,
nick: (targetNick) => targetNick.toLowerCase() === newNick.toLowerCase()
});
+ // return error if found
if (userExists.length > 0) {
// That nickname is already in that channel
server.reply({
@@ -57,7 +60,7 @@ exports.run = async (core, server, socket, data) => {
return;
}
- let peerList = server.findSockets({ channel: socket.channel });
+ // build join and leave notices
let leaveNotice = {
cmd: 'onlineRemove',
nick: socket.nick
@@ -66,16 +69,20 @@ exports.run = async (core, server, socket, data) => {
cmd: 'onlineAdd',
nick: newNick,
trip: socket.trip || 'null',
- hash: server.getSocketHash(socket)
+ hash: socket.hash
};
+ // broadcast remove event and join event with new name, this is to support legacy clients and bots
server.broadcast( leaveNotice, { channel: socket.channel });
server.broadcast( joinNotice, { channel: socket.channel });
+
+ // notify channel that the user has changed their name
server.broadcast( {
cmd: 'info',
text: `${socket.nick} is now ${newNick}`
}, { channel: socket.channel });
+ // commit change to nickname
socket.nick = newNick;
};
diff --git a/server/src/commands/core/chat.js b/server/src/commands/core/chat.js
index 168c0bb..89d497e 100644
--- a/server/src/commands/core/chat.js
+++ b/server/src/commands/core/chat.js
@@ -3,6 +3,7 @@
*/
const parseText = (text) => {
+ // verifies user input is text
if (typeof text !== 'string') {
return false;
}
@@ -16,12 +17,16 @@ const parseText = (text) => {
};
exports.run = async (core, server, socket, data) => {
+ // check user input
let text = parseText(data.text);
if (!text) {
// lets not send objects or empty text, yea?
+ server._police.frisk(socket.remoteAddress, 6);
+
return;
}
+ // check for spam
let score = text.length / 83 / 4;
if (server._police.frisk(socket.remoteAddress, score)) {
server.reply({
@@ -32,6 +37,7 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // build chat payload
let payload = {
cmd: 'chat',
nick: socket.nick,
@@ -48,6 +54,7 @@ exports.run = async (core, server, socket, data) => {
payload.trip = socket.trip;
}
+ // check if the users connection is muted
// TODO: Add a more contained way for modules to interact, event hooks or something?
if(core.muzzledHashes && core.muzzledHashes[socket.hash]){
server.broadcast( payload, { channel: socket.channel, hash: socket.hash });
@@ -59,6 +66,7 @@ exports.run = async (core, server, socket, data) => {
server.broadcast( payload, { channel: socket.channel});
}
+ // stats are fun
core.managers.stats.increment('messages-sent');
};
diff --git a/server/src/commands/core/help.js b/server/src/commands/core/help.js
index 7f63d3d..8fd02a1 100644
--- a/server/src/commands/core/help.js
+++ b/server/src/commands/core/help.js
@@ -5,6 +5,8 @@
const stripIndents = require('common-tags').stripIndents;
exports.run = async (core, server, socket, data) => {
+ // TODO: this module needs to be clean up badly :(
+
// verify passed arguments
let typeDt = typeof data.type;
let catDt = typeof data.category;
@@ -23,6 +25,7 @@ exports.run = async (core, server, socket, data) => {
Show all commands in category -> { cmd: 'help', category: '<category name>' }
Show specific command -> { cmd: 'help', command: '<command name>' }`;
+ // change reply based on query
if (typeDt !== 'undefined') {
let categories = core.commands.categories().sort();
reply = `Command Categories:\n${categories.map(c => `- ${c.replace('../src/commands/', '')}`).join('\n')}`;
@@ -36,6 +39,7 @@ exports.run = async (core, server, socket, data) => {
Description: ${command.info.description || '¯\_(ツ)_/¯'}`;
}
+ // output reply
server.reply({
cmd: 'info',
text: reply
@@ -46,4 +50,4 @@ exports.info = {
name: 'help',
usage: 'help ([ type:categories] | [category:<category name> | command:<command name> ])',
description: 'Outputs information about the servers current protocol'
-}; \ No newline at end of file
+};
diff --git a/server/src/commands/core/invite.js b/server/src/commands/core/invite.js
index bcf9097..d616193 100644
--- a/server/src/commands/core/invite.js
+++ b/server/src/commands/core/invite.js
@@ -2,11 +2,10 @@
Description: Generates a semi-unique channel name then broadcasts it to each client
*/
-const verifyNickname = (nick) => {
- return /^[a-zA-Z0-9_]{1,24}$/.test(nick);
-};
+const verifyNickname = (nick) => /^[a-zA-Z0-9_]{1,24}$/.test(nick);
exports.run = async (core, server, socket, data) => {
+ // check for spam
if (server._police.frisk(socket.remoteAddress, 2)) {
server.reply({
cmd: 'warn',
@@ -16,22 +15,20 @@ exports.run = async (core, server, socket, data) => {
return;
}
- if (typeof data.nick !== 'string') {
- return;
- }
-
- if (!verifyNickname(data.nick)) {
- // Not a valid nickname? Chances are we won't find them
+ // verify user input
+ if (typeof data.nick !== 'string' || !verifyNickname(data.nick)) {
return;
}
+ // why would you invite yourself?
if (data.nick == socket.nick) {
- // They invited themself
return;
}
-
+
+ // generate common channel
let channel = Math.random().toString(36).substr(2, 8);
+ // build and send invite
let payload = {
cmd: 'info',
invite: channel,
@@ -39,6 +36,7 @@ exports.run = async (core, server, socket, data) => {
};
let inviteSent = server.broadcast( payload, { channel: socket.channel, nick: data.nick });
+ // server indicates the user was not found
if (!inviteSent) {
server.reply({
cmd: 'warn',
@@ -48,11 +46,13 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // reply with common channel
server.reply({
cmd: 'info',
text: `You invited ${data.nick} to ?${channel}`
}, socket);
+ // stats are fun
core.managers.stats.increment('invites-sent');
};
@@ -62,4 +62,4 @@ exports.info = {
name: 'invite',
usage: 'invite {nick}',
description: 'Generates a unique (more or less) room name and passes it to two clients'
-}; \ No newline at end of file
+};
diff --git a/server/src/commands/core/join.js b/server/src/commands/core/join.js
index 4875b0e..31458a2 100644
--- a/server/src/commands/core/join.js
+++ b/server/src/commands/core/join.js
@@ -10,11 +10,10 @@ const hash = (password) => {
return sha.digest('base64').substr(0, 6);
};
-const verifyNickname = (nick) => {
- return /^[a-zA-Z0-9_]{1,24}$/.test(nick);
-};
+const verifyNickname = (nick) => /^[a-zA-Z0-9_]{1,24}$/.test(nick);
exports.run = async (core, server, socket, data) => {
+ // check for spam
if (server._police.frisk(socket.remoteAddress, 3)) {
server.reply({
cmd: 'warn',
@@ -24,22 +23,23 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // calling socket already in a channel
if (typeof socket.channel !== 'undefined') {
- // Calling socket already in a channel
return;
}
+ // check user input
if (typeof data.channel !== 'string' || typeof data.nick !== 'string') {
return;
}
let channel = data.channel.trim();
if (!channel) {
- // Must join a non-blank channel
+ // must join a non-blank channel
return;
}
- // Process nickname
+ // process nickname
let nick = data.nick;
let nickArray = nick.split('#', 2);
nick = nickArray[0].trim();
@@ -53,13 +53,14 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // check if the nickname already exists in the channel
let userExists = server.findSockets({
channel: data.channel,
nick: (targetNick) => targetNick.toLowerCase() === nick.toLowerCase()
});
if (userExists.length > 0) {
- // That nickname is already in that channel
+ // that nickname is already in that channel
server.reply({
cmd: 'warn',
text: 'Nickname taken'
@@ -68,7 +69,7 @@ exports.run = async (core, server, socket, data) => {
return;
}
- // TODO: Should we check for mod status first to prevent overwriting of admin status somehow? Meh, w/e, cba.
+ // TODO: should we check for mod status first to prevent overwriting of admin status somehow? Meh, w/e, cba.
let uType = 'user';
let trip = null;
let password = nickArray[1];
@@ -90,40 +91,47 @@ exports.run = async (core, server, socket, data) => {
trip = hash(password + core.config.tripSalt);
}
- // TODO: Disallow moderator impersonation
+ // TODO: disallow moderator impersonation
for (let mod of core.config.mods) {
if (trip === mod.trip) {
uType = 'mod';
}
}
- // Reply with online user list
+ // prepare to notify channel peers
let newPeerList = server.findSockets({ channel: data.channel });
+ let userHash = server.getSocketHash(socket);
+ let nicks = [];
+
let joinAnnouncement = {
cmd: 'onlineAdd',
nick: nick,
trip: trip || 'null',
- hash: server.getSocketHash(socket)
+ hash: userHash
};
- let nicks = [];
+ // send join announcement and prep online set
for (let i = 0, l = newPeerList.length; i < l; i++) {
server.reply(joinAnnouncement, newPeerList[i]);
nicks.push(newPeerList[i].nick);
}
+ // store user info
socket.uType = uType;
socket.nick = nick;
socket.channel = channel;
- socket.hash = server.getSocketHash(socket);
+ socket.hash = userHash;
if (trip !== null) socket.trip = trip;
+
nicks.push(socket.nick);
+ // reply with channel peer list
server.reply({
cmd: 'onlineSet',
nicks: nicks
}, socket);
+ // stats are fun
core.managers.stats.increment('users-joined');
};
diff --git a/server/src/commands/core/morestats.js b/server/src/commands/core/morestats.js
index 5510cb1..b64d478 100644
--- a/server/src/commands/core/morestats.js
+++ b/server/src/commands/core/morestats.js
@@ -12,10 +12,15 @@ const formatTime = (time) => {
let hours = Math.floor(minutes / 60);
minutes = minutes % 60;
- return `${hours.toFixed(0)}h ${minutes.toFixed(0)}m ${seconds.toFixed(0)}s`;
+
+ let days = Math.floor(hours / 24);
+ hours = hours % 24;
+
+ return `${days.toFixed(0)}d ${hours.toFixed(0)}h ${minutes.toFixed(0)}m ${seconds.toFixed(0)}s`;
};
exports.run = async (core, server, socket, data) => {
+ // gather connection and channel count
let ips = {};
let channels = {};
for (let client of server.clients) {
@@ -31,6 +36,7 @@ exports.run = async (core, server, socket, data) => {
ips = null;
channels = null;
+ // dispatch info
server.reply({
cmd: 'info',
text: stripIndents`current-connections: ${uniqueClientCount}
@@ -44,10 +50,11 @@ exports.run = async (core, server, socket, data) => {
server-uptime: ${formatTime(process.hrtime(core.managers.stats.get('start-time')))}`
}, socket);
+ // stats are fun
core.managers.stats.increment('stats-requested');
};
exports.info = {
name: 'morestats',
description: 'Sends back current server stats to the calling client'
-}; \ No newline at end of file
+};
diff --git a/server/src/commands/core/move.js b/server/src/commands/core/move.js
index c5efafd..284a38d 100644
--- a/server/src/commands/core/move.js
+++ b/server/src/commands/core/move.js
@@ -1,8 +1,9 @@
/*
- Description: Generates a semi-unique channel name then broadcasts it to each client
+ Description: Changes the current channel of the calling socket
*/
exports.run = async (core, server, socket, data) => {
+ // check for spam
if (server._police.frisk(socket.remoteAddress, 6)) {
server.reply({
cmd: 'warn',
@@ -12,15 +13,17 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // check user input
if (typeof data.channel !== 'string') {
return;
}
if (data.channel === socket.channel) {
- // They are trying to rejoin the channel
+ // they are trying to rejoin the channel
return;
}
+ // check that the nickname isn't already in target channel
const currentNick = socket.nick.toLowerCase();
let userExists = server.findSockets({
channel: data.channel,
@@ -32,6 +35,7 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // broadcast leave notice to peers
let peerList = server.findSockets({ channel: socket.channel });
if (peerList.length > 1) {
@@ -50,12 +54,13 @@ exports.run = async (core, server, socket, data) => {
}
}
+ // broadcast join notice to new peers
let newPeerList = server.findSockets({ channel: data.channel });
let moveAnnouncement = {
cmd: 'onlineAdd',
nick: socket.nick,
trip: socket.trip || 'null',
- hash: server.getSocketHash(socket)
+ hash: socket.hash
};
let nicks = [];
@@ -66,11 +71,13 @@ exports.run = async (core, server, socket, data) => {
nicks.push(socket.nick);
+ // reply with new user list
server.reply({
cmd: 'onlineSet',
nicks: nicks
}, socket);
+ // commit change
socket.channel = data.channel;
};
@@ -80,4 +87,4 @@ exports.info = {
name: 'move',
usage: 'move {channel}',
description: 'This will change the current channel to the new one provided'
-}; \ No newline at end of file
+};
diff --git a/server/src/commands/core/stats.js b/server/src/commands/core/stats.js
index b9dc002..74bd4a5 100644
--- a/server/src/commands/core/stats.js
+++ b/server/src/commands/core/stats.js
@@ -3,6 +3,7 @@
*/
exports.run = async (core, server, socket, data) => {
+ // gather connection and channel count
let ips = {};
let channels = {};
for (let client of server.clients) {
@@ -18,15 +19,17 @@ exports.run = async (core, server, socket, data) => {
ips = null;
channels = null;
+ // dispatch info
server.reply({
cmd: 'info',
text: `${uniqueClientCount} unique IPs in ${uniqueChannels} channels`
}, socket);
+ // stats are fun
core.managers.stats.increment('stats-requested');
};
exports.info = {
name: 'stats',
description: 'Sends back legacy server stats to the calling client'
-}; \ No newline at end of file
+};
diff --git a/server/src/commands/internal/disconnect.js b/server/src/commands/internal/disconnect.js
index bb3981b..7b9b299 100644
--- a/server/src/commands/internal/disconnect.js
+++ b/server/src/commands/internal/disconnect.js
@@ -11,6 +11,7 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // send leave notice to client peers
if (socket.channel) {
server.broadcast({
cmd: 'onlineRemove',
@@ -18,6 +19,7 @@ exports.run = async (core, server, socket, data) => {
}, { channel: socket.channel });
}
+ // commit close just in case
socket.terminate();
};
diff --git a/server/src/commands/internal/socketreply.js b/server/src/commands/internal/socketreply.js
index 82834b7..e77d080 100644
--- a/server/src/commands/internal/socketreply.js
+++ b/server/src/commands/internal/socketreply.js
@@ -10,6 +10,7 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // send warning to target socket
server.reply({ cmd: 'warn', text: data.text }, socket);
};
diff --git a/server/src/commands/mod/ban.js b/server/src/commands/mod/ban.js
index e19efc2..721ad27 100644
--- a/server/src/commands/mod/ban.js
+++ b/server/src/commands/mod/ban.js
@@ -3,15 +3,19 @@
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin or mod
if (socket.uType == 'user') {
- // ignore if not mod or admin
+ server._police.frisk(socket.remoteAddress, 10);
+
return;
}
+ // check user input
if (typeof data.nick !== 'string') {
return;
}
+ // find target user
let targetNick = data.nick;
let badClient = server.findSockets({ channel: socket.channel, nick: targetNick });
@@ -26,6 +30,7 @@ exports.run = async (core, server, socket, data) => {
badClient = badClient[0];
+ // i guess banning mods or admins isn't the best idea?
if (badClient.uType !== 'user') {
server.reply({
cmd: 'warn',
@@ -35,23 +40,27 @@ exports.run = async (core, server, socket, data) => {
return;
}
- let clientHash = server.getSocketHash(badClient);
- server._police.arrest(badClient.remoteAddress, clientHash);
+ // commit arrest record
+ server._police.arrest(badClient.remoteAddress, badClient.hash);
console.log(`${socket.nick} [${socket.trip}] banned ${targetNick} in ${socket.channel}`);
+ // notify normal users
server.broadcast({
cmd: 'info',
text: `Banned ${targetNick}`
}, { channel: socket.channel, uType: 'user' });
+ // notify mods
server.broadcast({
cmd: 'info',
- text: `${socket.nick} banned ${targetNick} in ${socket.channel}, userhash: ${clientHash}`
+ text: `${socket.nick} banned ${targetNick} in ${socket.channel}, userhash: ${badClient.hash}`
}, { uType: 'mod' });
- badClient.close();
+ // force connection closed
+ badClient.terminate();
+ // stats are fun
core.managers.stats.increment('users-banned');
};
diff --git a/server/src/commands/mod/dumb.js b/server/src/commands/mod/dumb.js
index 0708fb8..675ecd6 100644
--- a/server/src/commands/mod/dumb.js
+++ b/server/src/commands/mod/dumb.js
@@ -8,15 +8,19 @@ exports.init = (core) => {
}
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin or mod
if (socket.uType == 'user') {
- // ignore if not mod or admin
+ server._police.frisk(socket.remoteAddress, 10);
+
return;
}
+ // check user input
if (typeof data.nick !== 'string') {
return;
}
+ // find target user
let badClient = server.findSockets({ channel: socket.channel, nick: data.nick });
if (badClient.length === 0) {
@@ -30,6 +34,7 @@ exports.run = async (core, server, socket, data) => {
badClient = badClient[0];
+ // likely dont need this, muting mods and admins is fine
if (badClient.uType !== 'user') {
server.reply({
cmd: 'warn',
@@ -39,19 +44,21 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // store hash in mute list
let record = core.muzzledHashes[badClient.hash] = {
dumb:true
}
+ // store allies if needed
if(data.allies && Array.isArray(data.allies)){
record.allies = data.allies;
}
+ // notify mods
server.broadcast({
cmd: 'info',
text: `${socket.nick} muzzled ${data.nick} in ${socket.channel}, userhash: ${badClient.hash}`
}, { uType: 'mod' });
-
}
exports.requiredData = ['nick'];
diff --git a/server/src/commands/mod/kick.js b/server/src/commands/mod/kick.js
index 157592d..75c0d40 100644
--- a/server/src/commands/mod/kick.js
+++ b/server/src/commands/mod/kick.js
@@ -1,19 +1,23 @@
/*
- Description: Forces a change on the target socket's channel, then broadcasts event
+ Description: Forces a change on the target(s) socket's channel, then broadcasts event
*/
exports.run = async (core, server, socket, data) => {
- if (socket.uType === 'user') {
- // ignore if not mod or admin
+ // increase rate limit chance and ignore if not admin or mod
+ if (socket.uType == 'user') {
+ server._police.frisk(socket.remoteAddress, 10);
+
return;
}
+ // check user input
if (typeof data.nick !== 'string') {
if (typeof data.nick !== 'object' && !Array.isArray(data.nick)) {
return;
}
}
+ // find target user(s)
let badClients = server.findSockets({ channel: socket.channel, nick: data.nick });
if (badClients.length === 0) {
@@ -25,6 +29,7 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // check if found targets are kickable, commit kick
let newChannel = '';
let kicked = [];
for (let i = 0, j = badClients.length; i < j; i++) {
@@ -66,6 +71,7 @@ exports.run = async (core, server, socket, data) => {
text: `Kicked ${kicked.join(', ')}`
}, { channel: socket.channel, uType: 'user' });
+ // stats are fun
core.managers.stats.increment('users-kicked', kicked.length);
};
@@ -75,4 +81,4 @@ exports.info = {
name: 'kick',
usage: 'kick {nick}',
description: 'Silently forces target client(s) into another channel. `nick` may be string or array of strings'
-}; \ No newline at end of file
+};
diff --git a/server/src/commands/mod/speak.js b/server/src/commands/mod/speak.js
index 643280b..454ca94 100644
--- a/server/src/commands/mod/speak.js
+++ b/server/src/commands/mod/speak.js
@@ -4,11 +4,14 @@
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin or mod
if (socket.uType == 'user') {
- // ignore if not mod or admin
+ server._police.frisk(socket.remoteAddress, 10);
+
return;
}
+ // check user input
if (typeof data.ip !== 'string' && typeof data.hash !== 'string') {
server.reply({
cmd: 'warn',
@@ -18,8 +21,8 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // find target & remove mute status
let target;
-
if (typeof data.ip === 'string') {
target = getSocketHash(data.ip);
} else {
@@ -28,11 +31,11 @@ exports.run = async (core, server, socket, data) => {
delete core.muzzledHashes[target];
+ // notify mods
server.broadcast({
cmd: 'info',
text: `${socket.nick} unmuzzled : ${target}`
}, { uType: 'mod' });
-
}
exports.info = {
diff --git a/server/src/commands/mod/unban.js b/server/src/commands/mod/unban.js
index e82f0b9..9115dbd 100644
--- a/server/src/commands/mod/unban.js
+++ b/server/src/commands/mod/unban.js
@@ -3,11 +3,14 @@
*/
exports.run = async (core, server, socket, data) => {
+ // increase rate limit chance and ignore if not admin or mod
if (socket.uType == 'user') {
- // ignore if not mod or admin
+ server._police.frisk(socket.remoteAddress, 10);
+
return;
}
+ // check user input
if (typeof data.ip !== 'string' && typeof data.hash !== 'string') {
server.reply({
cmd: 'warn',
@@ -17,8 +20,8 @@ exports.run = async (core, server, socket, data) => {
return;
}
+ // find target
let mode, target;
-
if (typeof data.ip === 'string') {
mode = 'ip';
target = data.ip;
@@ -27,24 +30,28 @@ exports.run = async (core, server, socket, data) => {
target = data.hash;
}
+ // remove arrest record
server._police.pardon(target);
+ // mask ip if used
if (mode === 'ip') {
target = server.getSocketHash(target);
}
-
console.log(`${socket.nick} [${socket.trip}] unbanned ${target} in ${socket.channel}`);
+ // reply with success
server.reply({
cmd: 'info',
text: `Unbanned ${target}`
}, socket);
+ // notify mods
server.broadcast({
cmd: 'info',
text: `${socket.nick} unbanned: ${target}`
}, { uType: 'mod' });
+ // stats are fun
core.managers.stats.decrement('users-banned');
};
@@ -52,4 +59,4 @@ exports.info = {
name: 'unban',
usage: 'unban {[ip || hash]}',
description: 'Removes target ip from the ratelimiter'
-}; \ No newline at end of file
+};