fix: reuse shared heartbeat reasoning detection

harjothkhara · harjothkhara · commit 1d36bdf2ce87 · 2026-06-11T14:26:30.000-07:00
diff --git a/src/auto-reply/heartbeat-reply-payload.test.ts b/src/auto-reply/heartbeat-reply-payload.test.ts
@@ -21,6 +21,7 @@ describe("resolveHeartbeatReplyPayload", () => {
         finalPayload,
         { text: "Reasoning:\n_private details_" },
         { text: "Thinking\n\n_private details_" },
+        { text: "> reasoning:\n> _private details_" },
       ]),
     ).toBe(finalPayload);
   });
@@ -34,6 +35,9 @@ describe("resolveHeartbeatReplyPayload", () => {
     expect(resolveHeartbeatReplyPayload(reasoningPayload)).toBeUndefined();
     expect(resolveHeartbeatReplyPayload([reasoningPayload])).toBeUndefined();
     expect(resolveHeartbeatReplyPayload({ text: "Reasoning:\n_private details_" })).toBeUndefined();
+    expect(
+      resolveHeartbeatReplyPayload({ text: "> thinking\n> _private details_" }),
+    ).toBeUndefined();
   });
 
   it("continues scanning past empty and reasoning payloads", () => {
diff --git a/src/auto-reply/heartbeat-reply-payload.ts b/src/auto-reply/heartbeat-reply-payload.ts
@@ -1,18 +1,18 @@
 // Heartbeat reply payload selector for multi-payload auto-reply results.
-import { hasOutboundReplyContent } from "openclaw/plugin-sdk/reply-payload";
+import {
+  hasOutboundReplyContent,
+  isReasoningReplyPayload,
+} from "openclaw/plugin-sdk/reply-payload";
 import type { ReplyPayload } from "./types.js";
 
-const HEARTBEAT_REASONING_PREFIX_PATTERN = /^(?:Reasoning:|Thinking\.{0,3}(?=\s*_))/u;
-
 export function hasHeartbeatReasoningPrefix(text: string): boolean {
-  return HEARTBEAT_REASONING_PREFIX_PATTERN.test(text.trimStart());
+  return isReasoningReplyPayload({ text });
 }
 
 export function isHeartbeatReasoningPayload(
   payload: Pick<ReplyPayload, "isReasoning" | "text">,
 ): boolean {
-  const text = typeof payload.text === "string" ? payload.text : "";
-  return payload.isReasoning === true || hasHeartbeatReasoningPrefix(text);
+  return isReasoningReplyPayload(payload);
 }
 
 /** Pick the last non-reasoning outbound-capable reply payload for heartbeat delivery. */
diff --git a/src/infra/heartbeat-runner.returns-default-unset.test.ts b/src/infra/heartbeat-runner.returns-default-unset.test.ts
@@ -1363,6 +1363,10 @@ describe("runHeartbeatOnce", () => {
         name: "legacy-prefixed reasoning after HEARTBEAT_OK",
         replies: [{ text: "HEARTBEAT_OK" }, { text: "Reasoning:\n_Because it helps_" }],
       },
+      {
+        name: "blockquoted reasoning after HEARTBEAT_OK",
+        replies: [{ text: "HEARTBEAT_OK" }, { text: "> reasoning:\n> _Because it helps_" }],
+      },
     ]),
   )(
     "does not deliver late reasoning payloads when includeReasoning is unset: $name",
