Merge pull request #569 from XyLuoDYS/feat/AntiRepeat

[2.5.1] 完善消息拦截系统

Author: ItsFlicker

gradle.properties

@@ -1,5 +1,5 @@
 group=me.arasple.mc.trchat
-version=2.5.0
+version=2.5.1
 kotlin.incremental=true
 kotlin.incremental.java=true
 kotlin.caching.enabled=true

project/runtime-bukkit/src/main/kotlin/me/arasple/mc/trchat/module/conf/file/Settings.kt

@@ -36,10 +36,32 @@ object Settings {
     @ConfigNode("Chat.Cooldown", "settings.yml")
     val chatCooldown = ConfigNodeTransfer<String, Long> { parseMillis() }
 
-    @ConfigNode("Chat.Anti-Repeat", "settings.yml")
+    @ConfigNode("Chat.Interception.Anti-Repeat.Similarity", "settings.yml")
     var chatSimilarity = 0.85
         private set
 
+    @ConfigNode("Chat.Interception.Anti-Repeat.Max-Per-Period", "settings.yml")
+    var chatSimilarityMaxPerPeriod = 0
+        private set
+
+    @ConfigNode("Chat.Interception.Anti-Repeat.Period", "settings.yml")
+    val chatSimilarityPeriod = ConfigNodeTransfer<String, Long> { parseMillis() }
+
+    @ConfigNode("Chat.Interception.Anti-High-frequency.Max-Per-Period", "settings.yml")
+    var chatHighFrequencyMaxPerPeriod = 0
+        private set
+
+    @ConfigNode("Chat.Interception.Anti-High-frequency.Period", "settings.yml")
+    val chatHighFrequencyPeriod = ConfigNodeTransfer<String, Long> { parseMillis() }
+
+    @ConfigNode("Chat.Interception.Anti-Duplicate-Phrase.Max-Repeat", "settings.yml")
+    var chatDuplicatePhraseMaxRepeat = 0
+        private set
+
+    @ConfigNode("Chat.Interception.Anti-Duplicate-Phrase.Whitelist", "settings.yml")
+    var chatDuplicatePhraseWhitelist = emptyList<String>()
+        private set
+
     @ConfigNode("Chat.Length-Limit", "settings.yml")
     var chatLengthLimit = 100
         private set

project/runtime-bukkit/src/main/kotlin/me/arasple/mc/trchat/module/display/ChatSession.kt

@@ -26,6 +26,10 @@ class ChatSession(val player: Player) {
     var lastChannel: Channel? = null
     var lastPublicMessage = ""
     var lastPrivateMessage = ""
+    var similarCountInPeriod = 0
+    var similarPeriodStart = 0L
+    var totalCountInPeriod = 0
+    var totalPeriodStart = 0L
     var lastPrivateTo = ""
     var cancelChat = false
     @JvmField

project/runtime-bukkit/src/main/kotlin/me/arasple/mc/trchat/module/display/channel/Channel.kt

@@ -280,10 +280,30 @@ open class Channel(
             }
         }
         if (!player.hasPermission("trchat.bypass.repeat")) {
-            val lastMessage = player.session.lastPublicMessage
+            val session = player.session
+            val lastMessage = session.lastPublicMessage
             if (Settings.chatSimilarity > 0 && Settings.chatSimilarity <= 1 && Strings.similarDegree(lastMessage, message) >= Settings.chatSimilarity) {
-                player.sendLang("General-Too-Similar")
-                return false
+                val period = Settings.chatSimilarityPeriod.get()?.takeIf { it > 0 } ?: 60000L
+                val now = System.currentTimeMillis()
+                if (session.similarPeriodStart == 0L || now - session.similarPeriodStart >= period) {
+                    session.similarPeriodStart = now
+                    session.similarCountInPeriod = 0
+                }
+                if (session.similarCountInPeriod >= Settings.chatSimilarityMaxPerPeriod) {
+                    player.sendLang("General-Too-Similar")
+                    return false
+                }
+                session.similarCountInPeriod++
+            }
+        }
+        if (!player.hasPermission("trchat.bypass.duplicate")) {
+            val maxRepeat = Settings.chatDuplicatePhraseMaxRepeat
+            if (maxRepeat > 0 && message.length >= 2) {
+                val whitelist = Settings.chatDuplicatePhraseWhitelist.toSet()
+                if (maxConsecutiveRepeat(message, whitelist) > maxRepeat) {
+                    player.sendLang("General-Too-Duplicate")
+                    return false
+                }
             }
         }
         if (!player.hasPermission("trchat.bypass.chatcd")) {
@@ -296,6 +316,24 @@ open class Channel(
         if (Function.functions.any { !it.checkCooldown(player, message) }) {
             return false
         }
+        // 消息发送频率检查
+        if (!player.hasPermission("trchat.bypass.highfrequency")) {
+            val max = Settings.chatHighFrequencyMaxPerPeriod
+            if (max > 0) {
+                val session = player.session
+                val period = Settings.chatHighFrequencyPeriod.get()?.takeIf { it > 0 } ?: 60000L
+                val now = System.currentTimeMillis()
+                if (session.totalPeriodStart == 0L || now - session.totalPeriodStart >= period) {
+                    session.totalPeriodStart = now
+                    session.totalCountInPeriod = 0
+                }
+                if (session.totalCountInPeriod >= max) {
+                    player.sendLang("General-Too-Frequent")
+                    return false
+                }
+                session.totalCountInPeriod++
+            }
+        }
         player.updateCooldown(CooldownType.CHAT, Settings.chatCooldown.get())
         return true
     }
@@ -347,4 +385,53 @@ open class Channel(
             }
         }
     }
+}
+
+// 检查重复的子字符串并统计
+private fun maxConsecutiveRepeat(message: String, whitelist: Set<String>): Int {
+    val n = message.length
+    if (n < 2) return 1
+    var max = 1
+    val checkWhitelist = whitelist.isNotEmpty()
+    var i = 0
+    while (i < n) {
+        val maxLen = (n - i) / 2
+        var len = 1
+        while (len <= maxLen) {
+            if (checkWhitelist && isWhitelistedUnit(message, i, len, whitelist)) {
+                len++
+                continue
+            }
+            var count = 1
+            var j = i + len
+            while (j + len <= n && message.regionMatches(j, message, j - len, len)) {
+                count++
+                j += len
+            }
+            if (count > max) max = count
+            len++
+        }
+        i++
+    }
+    return max
+}
+
+// 判断重复单元是否被白名单豁免
+private fun isWhitelistedUnit(message: String, start: Int, len: Int, whitelist: Set<String>): Boolean {
+    for (w in whitelist) {
+        val wl = w.length
+        if (wl == 0 || len < wl || len % wl != 0) continue
+        val repeat = len / wl
+        var ok = true
+        var k = 0
+        while (k < repeat) {
+            if (!message.regionMatches(start + k * wl, w, 0, wl)) {
+                ok = false
+                break
+            }
+            k++
+        }
+        if (ok) return true
+    }
+    return false
 }

project/runtime-bukkit/src/main/resources/lang/en_US.yml

@@ -42,6 +42,8 @@ Plugin-Failed: '&8[&3Tr&bChat&8] &cOperation failure.'
 
 General-Too-Long: '&8[&3Tr&bChat&8] &7Message is too long. &8[&6{0}&8/&2{1}&8]'
 General-Too-Similar: '&8[&3Tr&bChat&8] &7Please do not repeat your message.'
+General-Too-Frequent: '&8[&3Tr&bChat&8] &7You are sending messages too frequently, please slow down.'
+General-Too-Duplicate: '&8[&3Tr&bChat&8] &7Your message contains consecutively repeated phrases, please do not spam.'
 General-No-Permission: '&8[&3Tr&bChat&8] &7You do not have enough permission to do this.'
 General-Muted: '&8[&3Tr&bChat&8] &cYou have been muted until {0}!Reason: {1}'
 General-Cancel-Muted: '&8[&3Tr&bChat&8] &aYou can speak now.'

project/runtime-bukkit/src/main/resources/lang/es_ES.yml

@@ -42,6 +42,8 @@ Plugin-Failed: '&8[&3Tr&bChat&8] &cOperación fallida.'
 
 General-Too-Long: '&8[&3Tr&bChat&8] &7El mensaje enviado es muy largo. &8[&6{0}&8/&2{1}&8]'
 General-Too-Similar: '&8[&3Tr&bChat&8] &7Porfavor no repitas el mismo mensaje.'
+General-Too-Frequent: '&8[&3Tr&bChat&8] &7Estás enviando mensajes con demasiada frecuencia, por favor espera.'
+General-Too-Duplicate: '&8[&3Tr&bChat&8] &7Tu mensaje contiene frases repetidas consecutivamente, por favor no hagas spam.'
 General-No-Permission: '&8[&3Tr&bChat&8] &7No tienes permisos para realizar esto.'
 General-Muted: '&8[&3Tr&bChat&8] &cFuiste silenciado por {0}! Razón: {1}'
 General-Cancel-Muted: '&8[&3Tr&bChat&8] &aYa puedes escribir.'

project/runtime-bukkit/src/main/resources/lang/zh_CN.yml

@@ -45,6 +45,8 @@ Plugin-Failed: '&8[&3Tr&bChat&8] &c操作失败.'
 
 General-Too-Long: '&8[&3Tr&bChat&8] &7你的聊天内容过长. &8[&6{0}&8/&2{1}&8]'
 General-Too-Similar: '&8[&3Tr&bChat&8] &7你的两次聊天内容过于相似, 请勿复读.'
+General-Too-Frequent: '&8[&3Tr&bChat&8] &7你发送消息的频率过高, 请稍后再试.'
+General-Too-Duplicate: '&8[&3Tr&bChat&8] &7你发送的内容中存在连续重复的词组, 请勿刷屏.'
 General-No-Permission: '&8[&3Tr&bChat&8] &7你没有足够的权限执行此操作.'
 General-Muted: '&8[&3Tr&bChat&8] &c你被禁言了!解除时间: {0} 原因: {1}'
 General-Cancel-Muted: '&8[&3Tr&bChat&8] &a你的禁言已被解除.'

project/runtime-bukkit/src/main/resources/settings.yml

@@ -36,7 +36,31 @@ Redis:
   timeout: 1000
 
 Chat:
-  Anti-Repeat: 0.85
+  Interception:
+    Anti-Repeat:
+      #内容相似度防刷屏
+      Similarity: 0.85
+      #每个周期内（下面的Period配置项）允许发送的相似消息最大条数，0表示任何时间完全禁止连续发送相似消息
+      Max-Per-Period: 0
+      #计数周期
+      Period: '1m'
+    Anti-High-frequency:
+      #每个周期内（下面的Period配置项）允许发送的消息最大条数，0表示无消息发送频率限制
+      Max-Per-Period: 0
+      #计数周期
+      Period: '1m'
+    Anti-Duplicate-Phrase:
+      #句内连续重复词组允许的最大次数，超过则拦截，0表示禁用此检测
+      #例如填2时，发送"加我微信加我微信"时放行, "加我微信加我微信加我微信"时拦截
+      Max-Repeat: 0
+      #词组白名单，其中的词组无论连续重复多少次都不拦截
+      Whitelist:
+        - '哈'
+        - '6'
+        - '?'
+        - '？'
+        - '!'
+        - '！'
   Cooldown: '2.0s'
   Length-Limit: 100
   Permission-Check:

project/runtime-bukkit/src/main/resources/special-chars.yml

@@ -1,4 +1,5 @@
 # 在频道配置文件启用special-char功能，玩家发出以下字符都会变成特定颜色
+# 注意更新频道配置文件的配置，如果不使用此功能可忽略
 
 SpecialChars: []