const fs = require("fs"); const https = require("https"); const dotenv = require('dotenv').config(); const express = require("express"); const socketio = require("socket.io"); const sanitizeHtml = require("sanitize-html"); const basicAuth = require("express-basic-auth"); function getCurrentTime() { function addZero(i) { if (i < 10) { i = "0" + i; } return i; } var d = new Date(); var day = addZero(d.getUTCDate()); var month = addZero(d.getUTCMonth() + 1); var year = d.getFullYear(); var h = addZero(d.getHours()); var m = addZero(d.getMinutes()); var s = addZero(d.getSeconds()); return "[" + day + "-"+ month + "-" + year + " " + h + ":" + m + ":" + s + "]"; } function log(message) { console.log(getCurrentTime() + " " + message); } const app = express(); //The base http server, use by socketio and https serveur const https_options = { key: fs.readFileSync("./privkey.pem"), cert: fs.readFileSync("./fullchain.pem"), requestCert: false, rejectUnauthorized: false } const socketHTTPSServer = https.createServer(https_options, app); const webHTTPSServer = https.createServer(https_options, app); const io = socketio(socketHTTPSServer, { cors: { origin: "https://danby.aniere.fr", }, secure: true }); usersConnected = 0; lastUsername = 0; messagesHistory = [] io.on("connection", (client) => { client.on("disconnect", () => { usersConnected--; io.sockets.emit("update-count", {value: usersConnected}); log(`${client.denisFanNumber} has disconnected`); }); client.on("message", (data) => { if(data.message.toLowerCase().includes("denis")) { message = sanitizeHtml(data.message, {allowedTags: [], allowedAttributes: {}}); io.sockets.emit("new-message", {author: client.denisFanNumber, message: message}); log(`${client.denisFanNumber} : ${message}`); messagesHistory.push([client.denisFanNumber, message]); if(messagesHistory.length > 20) { messagesHistory.shift(); } } else if(data.message === "/prout") { io.sockets.emit("fart"); log(`${client.denisFanNumber} : have farted`); } else { client.emit("warning"); log(`${client.denisFanNumber} : ${data.message} (INVALID)`); } }); lastUsername++; usersConnected++; io.sockets.emit("update-count", {value: usersConnected}); client.denisFanNumber = "DenisFan" + lastUsername; client.emit("username", {username: "DenisFan" + lastUsername}); client.emit("previous-messages", {messages: messagesHistory}); log(`${client.denisFanNumber} is now connected`); }); app.use(express.static("src")); app.get("/clear", basicAuth({users:{"quentin": process.env.ADMIN_PASSWORD}, challenge: true}), (req, res) => { messagesHistory = []; res.send("message history was cleared"); io.sockets.emit("refresh"); log("Admin cleared messages history"); }); app.listen(80, () => { log("Web server started on port 80") }); webHTTPSServer.listen(443, () => { log("Web HTTPS server started on port 443"); }); socketHTTPSServer.listen(3000, () => { log("Socket HTTPS server started on port 3000"); });