From afe3b4df8c83cdc78cad027dcf56ab1c2aaa95b1 Mon Sep 17 00:00:00 2001 From: Andrea Lepori Date: Sun, 19 Apr 2020 22:51:16 +0200 Subject: add bridge command to send messages with different nicks --- server/src/commands/core/bridge.js | 133 +++++++++++++++++++++++++++++++++++++ 1 file changed, 133 insertions(+) create mode 100644 server/src/commands/core/bridge.js diff --git a/server/src/commands/core/bridge.js b/server/src/commands/core/bridge.js new file mode 100644 index 0000000..89ed211 --- /dev/null +++ b/server/src/commands/core/bridge.js @@ -0,0 +1,133 @@ +/* + Description: Rebroadcasts any `text` to all clients in a `channel` with `nick` +*/ + +import * as UAC from "../utility/UAC/_info"; + +// module support functions +const parseText = (text) => { + // verifies user input is text + if (typeof text !== "string") { + return false; + } + + let sanitizedText = text; + + // strip newlines from beginning and end + sanitizedText = sanitizedText.replace(/^\s*\n|^\s+$|\n\s*$/g, ""); + // replace 3+ newlines with just 2 newlines + sanitizedText = sanitizedText.replace(/\n{3,}/g, "\n\n"); + + return sanitizedText; +}; + +// module main +export async function run(core, server, socket, data) { + // check user input + const text = parseText(data.text); + + if (!text) { + // lets not send objects or empty text, yea? + return server.police.frisk(socket.address, 13); + } + + // check for spam + const score = text.length / 83 / 4; + if (server.police.frisk(socket.address, score)) { + return server.reply( + { + cmd: "warn", + text: + "You are sending too much text. Wait a moment and try again.\nPress the up arrow key to restore your last message.", + }, + socket + ); + } + + // build chat payload + const payload = { + cmd: "chat", + nick: data.nick, + text, + level: socket.level, + }; + + if (UAC.isAdmin(socket.level)) { + payload.admin = true; + } else if (UAC.isModerator(socket.level)) { + payload.mod = true; + } + + if (socket.trip) { + payload.trip = socket.trip; + } + + // broadcast to channel peers + server.broadcast(payload, {channel: socket.channel}); + + // stats are fun + core.stats.increment("messages-sent"); + + return true; +} + +// module hook functions +export function initHooks(server) { + server.registerHook("in", "chat", this.commandCheckIn.bind(this), 20); + server.registerHook("in", "chat", this.finalCmdCheck.bind(this), 254); +} + +// checks for miscellaneous '/' based commands +export function commandCheckIn(core, server, socket, payload) { + if (typeof payload.text !== "string") { + return false; + } + + if (payload.text.startsWith("/myhash")) { + server.reply( + { + cmd: "info", + text: `Your hash: ${socket.hash}`, + }, + socket + ); + + return false; + } + + return payload; +} + +export function finalCmdCheck(core, server, socket, payload) { + if (typeof payload.text !== "string") { + return false; + } + + if (!payload.text.startsWith("/")) { + return payload; + } + + if (payload.text.startsWith("//")) { + payload.text = payload.text.substr(1); + + return payload; + } + + server.reply( + { + cmd: "warn", + text: `Unknown command: ${payload.text}`, + }, + socket + ); + + return false; +} + +export const requiredData = ["text", "nick"]; +export const info = { + name: "chat", + description: "Broadcasts passed `text` field to the calling users channel using `nick`", + usage: ` + API: { cmd: 'chat', text: '', nick: 'nick'} `, +}; -- cgit v1.2.1