Chat JSON and spam fix

server/index.js

@@ -577,8 +577,48 @@ chatWss.on('connection', (ws, request) => {
   };
   ws.send(JSON.stringify(ipMessage));
 
+  const userCommands = {};
+
   ws.on('message', function incoming(message) {
-    const messageData = JSON.parse(message);
+
+    // Anti-spam
+    const command = message.toString();
+    const now = Date.now();
+
+    // Update the last message time for general spam detection
+    lastMessageTime = now;
+  
+    // Initialize command history for rate-limiting checks
+    if (!userCommands[command]) {
+      userCommands[command] = [];
+    }
+  
+    // Record the current timestamp for this command
+    userCommands[command].push(now);
+  
+    // Remove timestamps older than 1 second
+    userCommands[command] = userCommands[command].filter(timestamp => now - timestamp <= 1000);
+  
+    // If command count exceeds limit, close connection
+    if (userCommands[command].length > 3) {
+      logWarn(`User \x1b[90m${clientIp}\x1b[0m is spamming command "${command}". Connection will be terminated.`);
+      ws.close(1008, 'Spamming detected');
+      return;
+    }
+
+
+
+    let messageData;
+
+    try {
+      messageData = JSON.parse(message);
+    } catch (error) {
+      // console.error("Failed to parse message:", error);
+      // Optionally, send an error response back to the client
+      ws.send(JSON.stringify({ error: "Invalid message format" }));
+      return; // Stop processing if JSON parsing fails
+    }
+
     messageData.ip = clientIp; // Adding IP address to the message object
     const currentTime = new Date();
     
@@ -617,15 +657,6 @@ chatWss.on('connection', (ws, request) => {
   });
 });
 
-rdsWss.on('connection', (ws, request) => {
-  ws.on('message', function incoming(message) {
-  
-  });
-
-  ws.on('close', function close() {
-  });
-});
-
 //additional web socket for using plugins
 pluginsWss.on('connection', (ws, request)  => { 
     ws.on('message', message => {