Merge 6483c49 into 67e1d43

mushuiyu886 · web-flow · commit 544851db2074 · 2026-07-11T01:47:53.000Z
diff --git a/src/agents/embedded-agent-helpers.ts b/src/agents/embedded-agent-helpers.ts
@@ -64,6 +64,7 @@ export { sanitizeSessionMessagesImages } from "./embedded-agent-helpers/images.j
 export {
   isMessagingToolDuplicate,
   isMessagingToolDuplicateNormalized,
+  isPostToolSendMetaAck,
   normalizeTextForComparison,
 } from "./embedded-agent-helpers/messaging-dedupe.js";
 
diff --git a/src/agents/embedded-agent-helpers/messaging-dedupe.ts b/src/agents/embedded-agent-helpers/messaging-dedupe.ts
@@ -5,6 +5,12 @@ import { normalizeLowercaseStringOrEmpty } from "@openclaw/normalization-core/st
 
 const MIN_DUPLICATE_TEXT_LENGTH = 10;
 const MIN_REVERSE_SUBSTRING_DUPLICATE_RATIO = 0.5;
+const MAX_POST_TOOL_SEND_META_ACK_LENGTH = 80;
+const POST_TOOL_SEND_META_ACK_PATTERNS: readonly RegExp[] = [
+  /^(?:已发(?:送|出|完毕)?|回复已发(?:送|出)?|主回复已发|消息已发(?:送|出)?)(?:[\s,，。.!！:：-]*(?:[#＃][\p{L}\p{N}_-]+|\d+|\((?:[#＃][\p{L}\p{N}_-]+|\d+)\)|不再追加(?:总结|内容|回复)?))?[\s。.!！]*$/iu,
+  /^(?:核心回答如下|总结如下|答案如下|不再追加(?:总结|内容|回复)?)[\s。.!！:：]*$/u,
+  /^(?:sent(?:\s+(?:above|already|[#＃][\p{L}\p{N}_-]+))?|posted|done|ok(?:ay)?|roger|got\s+it|ack(?:nowledged)?|replied\s+above)(?:[\s,，。.!！:：-]*(?:replied\s+(?:above|in\s+thread)|that's\s+the\s+fix|no\s+more\s+content))?[\s。.!！]*$/iu,
+];
 
 /**
  * Normalize text for duplicate comparison.
@@ -20,6 +26,14 @@ export function normalizeTextForComparison(text: string): string {
     .trim();
 }
 
+export function isPostToolSendMetaAck(text: string): boolean {
+  const normalized = normalizeTextForComparison(text);
+  if (!normalized || normalized.length > MAX_POST_TOOL_SEND_META_ACK_LENGTH) {
+    return false;
+  }
+  return POST_TOOL_SEND_META_ACK_PATTERNS.some((pattern) => pattern.test(normalized));
+}
+
 /** Compare already-normalized message text against prior sends. */
 export function isMessagingToolDuplicateNormalized(
   normalized: string,
diff --git a/src/auto-reply/reply/followup-delivery.test.ts b/src/auto-reply/reply/followup-delivery.test.ts
@@ -321,6 +321,54 @@ describe("resolveFollowupDeliveryPayloads", () => {
     ).toEqual([{ text: "hello world!" }]);
   });
 
+  it("drops short trailing meta acknowledgements after a same-route message tool send", () => {
+    expect(
+      resolveFollowupDeliveryPayloads({
+        cfg: baseConfig,
+        payloads: [
+          { text: "已发 #22141" },
+          { text: "Sent above" },
+          { text: "核心回答如下" },
+          { text: "OK" },
+        ],
+        messageProvider: "telegram",
+        originatingTo: "telegram:123",
+        sentTargets: [
+          {
+            tool: "message",
+            provider: "telegram",
+            to: "telegram:123",
+            text: "完整主回复内容已经通过 message tool 发出",
+          },
+        ],
+      }),
+    ).toStrictEqual([]);
+  });
+
+  it("drops compound meta acknowledgements without dropping substantive short replies", () => {
+    expect(
+      resolveFollowupDeliveryPayloads({
+        cfg: baseConfig,
+        payloads: [
+          { text: "已发, 不再追加总结" },
+          { text: "Sent. Replied in thread." },
+          { text: "OK, that's the fix." },
+          { text: "OK, here is the actual answer." },
+        ],
+        messageProvider: "telegram",
+        originatingTo: "telegram:123",
+        sentTargets: [
+          {
+            tool: "message",
+            provider: "telegram",
+            to: "telegram:123",
+            text: "完整主回复内容已经通过 message tool 发出",
+          },
+        ],
+      }),
+    ).toEqual([{ text: "OK, here is the actual answer." }]);
+  });
+
   it("dedupes duplicate replies when a messaging tool already sent to the same provider and target", () => {
     expect(
       resolveFollowupDeliveryPayloads({
diff --git a/src/auto-reply/reply/reply-payloads-dedupe.ts b/src/auto-reply/reply/reply-payloads-dedupe.ts
@@ -3,7 +3,10 @@ import {
   normalizeLowercaseStringOrEmpty,
   normalizeOptionalString,
 } from "@openclaw/normalization-core/string-coerce";
-import { isMessagingToolDuplicate } from "../../agents/embedded-agent-helpers.js";
+import {
+  isMessagingToolDuplicate,
+  isPostToolSendMetaAck,
+} from "../../agents/embedded-agent-helpers.js";
 import type { MessagingToolSend } from "../../agents/embedded-agent-messaging.types.js";
 import { getChannelPlugin } from "../../channels/plugins/index.js";
 import { getLoadedChannelPluginForRead } from "../../channels/plugins/registry-loaded-read.js";
@@ -31,7 +34,8 @@ export function filterMessagingToolDuplicates(params: {
     if (payload.mediaUrl || payload.mediaUrls?.length) {
       return true;
     }
-    return !isMessagingToolDuplicate(payload.text ?? "", sentTexts);
+    const text = payload.text ?? "";
+    return !isMessagingToolDuplicate(text, sentTexts) && !isPostToolSendMetaAck(text);
   });
 }
 
