Use better chat spam detection that works for multiple players spamming at once, instead of just one spammer in a row. Also fix issue with PlayerList/PlayerExtList opening the IOstream not being threadsafe.

Player/List/PlayerExtList.cs

@@ -26,7 +26,7 @@ namespace MCGalaxy {
         string path;
         List<string> players = new List<string>();
         List<string> lines = new List<string>();
-        readonly object locker = new object();
+        readonly object locker = new object(), saveLocker = new object();
         
         public void Add(string p, string data) {
         	p = p.ToLower();
@@ -68,16 +68,22 @@ namespace MCGalaxy {
         public int Count { get { lock (locker) return players.Count; } }
         
         
-        public void Save(bool console = false) {
+        public void Save() { Save(true); }
-            using (StreamWriter w = new StreamWriter(path)) {
+        public void Save(bool console) {
-                lock (locker) {
+            lock (saveLocker) {
-                    foreach (string line in lines)
+                using (StreamWriter w = new StreamWriter(path))
-                        w.WriteLine(line);
+                    SaveEntries(w);
-                }
             }
             if (console) Server.s.Log("SAVED: " + path, true);
         }
         
+        void SaveEntries(StreamWriter w) {
+            lock (locker) {
+                foreach (string p in players)
+                    w.WriteLine(p);
+            }
+        }
+        
         public static PlayerExtList Load(string path) {
             PlayerExtList list = new PlayerExtList();
             list.path = path;

Player/List/PlayerList.cs

@@ -24,7 +24,7 @@ namespace MCGalaxy {
     public sealed class PlayerList {
         string path;
         List<string> players = new List<string>();
-        readonly object locker = new object();
+        readonly object locker = new object(), saveLocker = new object();
         
         public PlayerList() { }
         public PlayerList(string path) { this.path = path; }
@@ -70,14 +70,19 @@ namespace MCGalaxy {
         
         public void Save() { Save(true); }
         public void Save(bool console) {
-            using (StreamWriter w = new StreamWriter(path)) {
+            lock (saveLocker) {
+                using (StreamWriter w = new StreamWriter(path))
+                    SaveEntries(w);
+            }
+            if (console) Server.s.Log("SAVED: " + path, true);
+        }
+        
+        void SaveEntries(StreamWriter w) {
             lock (locker) {
                 foreach (string p in players)
                     w.WriteLine(p);
             }
         }
-            if (console) Server.s.Log("SAVED: " + path, true);
-        }
         
         public static PlayerList Load(string file) {
             if (!Directory.Exists("ranks")) Directory.CreateDirectory("ranks");

Player/Player.Fields.cs

@@ -260,6 +260,8 @@ namespace MCGalaxy {
         Queue<DateTime> spamBlockLog = new Queue<DateTime>(spamBlockCount);
 
         public int consecutivemessages;
+        internal readonly object lastMessageLock = new object();
+        public List<DateTime> LastMessageTimes;
         //public static int spamChatCount = 3;
         //public static int spamChatTimer = 4;
         //Queue<DateTime> spamChatLog = new Queue<DateTime>(spamChatCount);

Player/Player.Handlers.cs

@@ -473,14 +473,9 @@ try { SendBlockchange(pos1.x, pos1.y, pos1.z, Block.waterstill); } catch { }
 });
 }
 } */
-        DateTime lastSpamReset;
         void HandleChat(byte[] packet) {
             try {
                 if (!loggedIn) return;
-                if ((DateTime.UtcNow - lastSpamReset).TotalSeconds > Server.spamcountreset) {
-                    lastSpamReset = DateTime.UtcNow;
-                    consecutivemessages = 0;
-                }
                 byte continued = packet[1];
                 string text = GetString(packet, 2);
 
@@ -660,26 +655,6 @@ return;
             catch ( Exception e ) { Server.ErrorLog(e); Player.GlobalMessage("An error occurred: " + e.Message); }
         }
         
-        public void CheckForMessageSpam() {
-            if (!Server.checkspam || ircNick != null) { Player.lastMSG = name; return; }
-            
-            if (Player.lastMSG == name) {
-                consecutivemessages++;
-            } else {
-                consecutivemessages--;
-            }
-
-            if (consecutivemessages >= Server.spamcounter) {
-                muteCooldown = Server.mutespamtime;
-                Command.all.Find("mute").Use(null, name);
-                Player.GlobalMessage(color + DisplayName + " %Shas been &0muted &efor spamming!");
-                muteTimer.Elapsed += MuteTimerElapsed;
-                muteTimer.Start();
-                return;
-            }
-            Player.lastMSG = name;
-        }
-        
         string HandleJoker(string text) {
             if (!joker) return text;
             if (!File.Exists("text/joker.txt")) {

Player/Player.cs

@@ -624,5 +624,37 @@ namespace MCGalaxy {
                     MakeSelection(selIndex, selState, selCallback);
             }
         }
+        
+        
+        public void CheckForMessageSpam() {
+            Player.lastMSG = name; 
+            if (!Server.checkspam || ircNick != null) return;
+            
+            lock (lastMessageLock) {
+                if (LastMessageTimes == null) 
+                    LastMessageTimes = new List<DateTime>(Server.spamcounter);
+                
+                DateTime now = DateTime.UtcNow;
+                int count = LastMessageTimes.Count, inThreshold = 0;
+                if (count > 0 && count >= Server.spamcounter)
+                    LastMessageTimes.RemoveAt(0);
+                LastMessageTimes.Add(now);
+                
+                // Count number of messages that are within the chat spam dection threshold
+                count = LastMessageTimes.Count;
+                for (int i = 0; i < count; i++) {
+                    TimeSpan delta = now - LastMessageTimes[i];
+                    if (delta.TotalSeconds <= Server.spamcountreset)
+                        inThreshold++;
+                }            
+                if (inThreshold < Server.spamcounter) return;
+                
+                muteCooldown = Server.mutespamtime;
+                Command.all.Find("mute").Use(null, name);
+                Player.GlobalMessage(color + DisplayName + " %Shas been &0muted &efor spamming!");
+                muteTimer.Elapsed += MuteTimerElapsed;
+                muteTimer.Start();
+            }
+        }        
     }
 }