From a227c883e3360a9cca8dd3c2317d735e71dd6919 Mon Sep 17 00:00:00 2001
From: MythEclipse <asepharyanalm001@gmail.com>
Date: Tue, 2 Jun 2026 23:00:42 +0700
Subject: [PATCH] =?UTF-8?q?There=20are=20no=20staged=20changes=20to=20comm?=
 =?UTF-8?q?it.=20The=20staging=20area=20is=20empty=20=E2=80=94=20stage=20s?=
 =?UTF-8?q?ome=20files=20first=20with=20`git=20add`=20and=20I=20can=20help?=
 =?UTF-8?q?=20craft=20the=20message.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ai-moderation/llmModerationClient.ts      | 47 +++++++++++++++++--
 1 file changed, 44 insertions(+), 3 deletions(-)

diff --git a/services/discord-gateway/src/modules/ai-moderation/llmModerationClient.ts b/services/discord-gateway/src/modules/ai-moderation/llmModerationClient.ts
index b1ad72e..487a6d0 100644
--- a/services/discord-gateway/src/modules/ai-moderation/llmModerationClient.ts
+++ b/services/discord-gateway/src/modules/ai-moderation/llmModerationClient.ts
@@ -908,10 +908,51 @@ async function runTextOnlyBatch(
     }),
   );
 
-  // Split into sub-batches if needed (R6)
+  // ── Group identical short messages (< 20 chars) to reduce redundant analysis ──
+  // Messages with identical normalized content share a single representative.
+  // Results are fanned out to all group members after the LLM call.
+  const shortContentGroups = new Map<string, MessageRecord[]>();
+  const deduplicatedTargets: MessageRecord[] = [];
+  const groupMapping = new Map<string, string[]>(); // representativeId → [all memberIds]
+
+  for (const msg of targets) {
+    const rawContent = (msg.edited_content ?? msg.content).trim();
+    if (rawContent.length > 0 && rawContent.length < 20) {
+      const groupKey = rawContent.toLowerCase();
+      if (shortContentGroups.has(groupKey)) {
+        shortContentGroups.get(groupKey)!.push(msg);
+      } else {
+        shortContentGroups.set(groupKey, [msg]);
+        deduplicatedTargets.push(msg); // first occurrence = representative
+      }
+    } else {
+      deduplicatedTargets.push(msg);
+    }
+  }
+
+  // Build group mapping for results fan-out
+  for (const [, members] of shortContentGroups) {
+    if (members.length > 1) {
+      const rep = members[0];
+      groupMapping.set(rep.id, members.map((m) => m.id));
+    }
+  }
+
+  if (groupMapping.size > 0) {
+    log.info(
+      {
+        originalCount: targets.length,
+        deduplicatedCount: deduplicatedTargets.length,
+        groupsFormed: groupMapping.size,
+      },
+      "Grouped identical short messages for text batch",
+    );
+  }
+
+  // Split into sub-batches if needed (R6) — using deduplicated targets
   const subBatches: MessageRecord[][] = [];
-  for (let i = 0; i < targets.length; i += maxBatchSize) {
-    subBatches.push(targets.slice(i, i + maxBatchSize));
+  for (let i = 0; i < deduplicatedTargets.length; i += maxBatchSize) {
+    subBatches.push(deduplicatedTargets.slice(i, i + maxBatchSize));
   }
 
   if (subBatches.length > 1) {