import Config from "./objects/Config"; import SimpleProm from "simple-prom"; import Gauge from "simple-prom/lib/objects/Gauge"; import Counter from "simple-prom/lib/objects/Counter"; const metrics = SimpleProm.init({ selfHost: true, selfHostPort: Config.ports.metrics ?? 9100 }); const onlineUsers = metrics.addMetric(new Gauge("multiprobe_open_connections")); onlineUsers.setHelpText("Number of connections to the websocket"); const onlineUsersUnique = metrics.addMetric(new Gauge("multiprobe_unique_connections")); onlineUsersUnique.setHelpText("Number of unique user connections to the websocket"); const dataIn = metrics.addMetric(new Counter("multiprobe_data_in")); dataIn.setHelpText("Data received by the server in bytes"); const dataOut = metrics.addMetric(new Counter("multiprobe_data_out")); dataOut.setHelpText("Data sent by the server in bytes"); import { createReader, createWriter, Endian } from "bufferstuff"; import { WebSocketServer } from "ws"; import Fastify from "fastify"; import FastifyFormBody from "@fastify/formbody"; import FastifyCookie from "@fastify/cookie"; import FastifyView from "@fastify/view"; import EJS from "ejs"; import FunkyArray from "funky-array"; import RemoteUser from "./objects/RemoteUser"; import { MessageType } from "./enums/MessageType"; import Database from "./objects/Database"; import { Console } from "hsconsole"; import UserService from "./services/UserService"; import Party from "./entities/Party"; import Controller from "./controller/Controller"; import HomeController from "./controller/HomeController"; import AccountController from "./controller/AccountController"; import PartyController from "./controller/PartyController"; import ApiController from "./controller/ApiController"; Console.customHeader(`MultiProbe server started at ${new Date()}`); const users = new FunkyArray(); new Database(Config.database.address, Config.database.port, Config.database.username, Config.database.password, Config.database.name); // Web stuff const fastify = Fastify({ logger: false }); fastify.register(FastifyView, { engine: { ejs: EJS } }); fastify.register(FastifyFormBody); fastify.register(FastifyCookie, { secret: Config.session.secret, parseOptions: { path: "/", secure: true } }); fastify.setNotFoundHandler(async (req, res) => { return res.status(404).view("templates/404.ejs", { }); }); Controller.FastifyInstance = fastify; new HomeController(); new AccountController(); new PartyController(); new ApiController(); // Websocket stuff const websocketServer = new WebSocketServer({ port: Config.ports.ws }, () => { Console.printInfo(`WebsocketServer listening at ws://localhost:${Config.ports.ws}`); fastify.listen({ port: Config.ports.http, host: "0.0.0.0" }, (err, address) => { if (err) { Console.printError(`Error occured while spinning up fastify:\n${err}`); process.exit(1); } Console.printInfo(`Fastify listening at ${address.replace("0.0.0.0", "localhost")}`); Console.printInfo("MultiProbe is ready to go!"); }); }); function sendToAllButSelf(user:RemoteUser, data:Buffer) { users.forEach(otherUser => { if (otherUser.id !== user.id && otherUser.currentURL === user.currentURL) { otherUser.send(data); } }); } function sendToAll(user:RemoteUser, data:Buffer) { users.forEach(otherUser => { if (otherUser.currentURL === user.currentURL) { otherUser.send(data); } }); } function sendToAllInGroup(user:RemoteUser, data:Buffer) { users.forEach(otherUser => { if (otherUser.groupId === user.groupId && otherUser.userId !== user.userId) { otherUser.send(data); } }); } const afkInterval = setInterval(() => { users.forEach(otherUser => { if (Date.now() - otherUser.timeLastMovedCursor >= 30000 && !otherUser.isAfk) { otherUser.isAfk = true; const afkPacket = createWriter(Endian.LE, 6).writeByte(MessageType.HonkShoe).writeUInt(otherUser.id).writeBool(otherUser.isAfk).toBuffer(); sendToAllButSelf(otherUser, afkPacket); } }); }, 5000); async function updateConnectionMetrics() { onlineUsers.Value = users.length; let userCount = 0; const checkedUsers = new Array(); await users.forEach(user => { if (!checkedUsers.includes(user.username)) { userCount++; checkedUsers.push(user.username); } }); onlineUsersUnique.Value = userCount; } websocketServer.on("connection", (socket) => { const myUUID = crypto.randomUUID(); let user:RemoteUser; function closeOrError() { if (users.has(myUUID)) { users.remove(myUUID); const userLeftPacket = createWriter(Endian.LE, 5).writeByte(MessageType.ClientLeft).writeUInt(user.id).toBuffer(); users.forEach(otherUser => otherUser.send(userLeftPacket)); sendGroupUpdate(user); } updateConnectionMetrics(); } async function sendGroupUpdate(sendUser:RemoteUser, groupSend = false) { if (!sendUser || sendUser.groupId === Number.MIN_VALUE) { return; } const usersInGroup = new FunkyArray(); let totalUsernameLength = 0; await users.forEach(otherUser => { if (sendUser.groupId === otherUser.groupId && sendUser.userId !== otherUser.userId) { if (usersInGroup.has(otherUser.userId)) { totalUsernameLength += otherUser.username.length; } usersInGroup.set(otherUser.userId, otherUser); } if (!groupSend && sendUser.userId !== otherUser.userId) { sendGroupUpdate(otherUser, true); } }); const writer = createWriter(Endian.LE) .writeByte(MessageType.GroupData) .writeShortString(sendUser.groupName) .writeUShort(usersInGroup.length); await usersInGroup.forEach(otherUser => { writer.writeShortString(otherUser.username).writeString(otherUser.rawURL); }); const groupData = writer.toBuffer(); sendUser.send(groupData); } socket.on("close", closeOrError); socket.on("error", closeOrError); socket.on("message", async (data) => { const reader = createReader(Endian.LE, data as Buffer); dataIn.add(reader.length); if (reader.length > 0 && reader.length < 1024) { switch (reader.readUByte()) { case MessageType.KeepAlive: { if (user !== undefined) { user.lastKeepAliveTime = Date.now(); } break; } case MessageType.ClientDetails: { if (user !== undefined) { return; } const apiKey = reader.readShortString(); const rawURL = reader.readString(); const dbUser = await UserService.GetUserByAPIKey(apiKey); if (dbUser == null) { return; } const dbUserParty = await UserService.GetActiveParty(dbUser.Id); let dbParty: Party | null = null; if (dbUserParty) { dbParty = await UserService.GetParty(dbUserParty.PartyId); } let page = rawURL.toLowerCase().replace(".htm", "").replace(".html", ""); if (page === "index") { page = ""; } let lengthOfUsernames = 0; const usersOnPage = new Array(); await users.forEach(otherUser => { if (otherUser.currentURL === page) { usersOnPage.push(otherUser); lengthOfUsernames += otherUser.username.length + 1; // + 1 for length byte } }); const usersToSend = createWriter(Endian.LE, 3 + (usersOnPage.length * 13) + lengthOfUsernames).writeByte(MessageType.Clients).writeUShort(usersOnPage.length); for (const otherUser of usersOnPage) { usersToSend.writeUInt(otherUser.id).writeShortString(otherUser.username).writeFloat(otherUser.cursorX).writeInt(otherUser.cursorY).writeBool(otherUser.isAfk); } if (dbParty) { user = users.set(myUUID, new RemoteUser(socket, dataOut, myUUID, dbUser.Username, page, rawURL, dbUser.Id, dbParty.Id, dbParty.Name)); } else { user = users.set(myUUID, new RemoteUser(socket, dataOut, myUUID, dbUser.Username, page, rawURL, dbUser.Id, Number.MIN_VALUE, "")); } sendToAllButSelf(user, createWriter(Endian.LE, 6 + dbUser.Username.length).writeByte(MessageType.ClientJoined).writeUInt(user.id).writeShortString(dbUser.Username).toBuffer()); user.send(usersToSend.toBuffer()); sendGroupUpdate(user); updateConnectionMetrics(); break; } case MessageType.CursorPos: { if (user === undefined) { return; } user.cursorX = reader.readFloat(); user.cursorY = reader.readInt(); sendToAllButSelf(user, createWriter(Endian.LE, 13).writeByte(MessageType.CursorPos).writeUInt(user.id).writeFloat(user.cursorX).writeInt(user.cursorY).toBuffer()); user.timeLastMovedCursor = Date.now(); if (user.isAfk) { user.isAfk = false; const afkPacket = createWriter(Endian.LE, 6).writeByte(MessageType.HonkShoe).writeUInt(user.id).writeBool(user.isAfk).toBuffer(); sendToAllButSelf(user, afkPacket); } break; } case MessageType.Ping: { if (user === undefined) { return; } if ((Date.now() - user.lastPingReset) >= 1000) { user.allowedPings = 10; user.lastPingReset = Date.now(); } if (user.allowedPings > 0) { user.allowedPings--; const cursorX = reader.readFloat(); const cursorY = reader.readInt(); const packet = createWriter(Endian.LE, 9).writeByte(MessageType.Ping).writeFloat(cursorX).writeInt(cursorY).toBuffer(); sendToAll(user, packet); } break; } case MessageType.HonkShoe: { if (user === undefined) { return; } user.isAfk = reader.readBool(); const afkPacket = createWriter(Endian.LE, 6).writeByte(MessageType.HonkShoe).writeUInt(user.id).writeBool(user.isAfk).toBuffer(); sendToAllButSelf(user, afkPacket); break; } } } }); }); let isShuttingDown = false; function shutdown() { if (isShuttingDown) { return; } isShuttingDown = true; Console.printInfo("Shutting down..."); websocketServer.close(async () => { await fastify.close(); clearInterval(afkInterval); Console.cleanup(); console.log("Goodbye!"); }); } process.on("SIGQUIT", shutdown); process.on("SIGINT", shutdown); //process.on("SIGUSR2", shutdown);