github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-10 16:54:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: deliver reasoning alongside HEARTBEAT_OK

Browse Source
This commit is contained in:
Anton Sotkov
2026-01-11 00:53:52 +02:00
committed by Peter Steinberger
parent 7a518166bb
commit c7caa9a87d
2 changed files with 93 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/infra/heartbeat-runner.ts
View File

@@ -262,6 +262,11 @@ export async function runHeartbeatOnce(opts: {
const replyPayload = resolveHeartbeatReplyPayload(replyResult);
const includeReasoning =
cfg.agents?.defaults?.heartbeat?.includeReasoning === true;
const reasoningPayloads = includeReasoning
? resolveHeartbeatReasoningPayloads(replyResult).filter(
(payload) => payload !== replyPayload,
)
: [];
if (
!replyPayload ||
@@ -291,7 +296,8 @@ export async function runHeartbeatOnce(opts: {
).responsePrefix,
ackMaxChars,
);
if (normalized.shouldSkip && !normalized.hasMedia) {
const shouldSkipMain = normalized.shouldSkip && !normalized.hasMedia;
if (shouldSkipMain && reasoningPayloads.length === 0) {
await restoreHeartbeatUpdatedAt({
storePath,
sessionKey,
@@ -309,18 +315,18 @@ export async function runHeartbeatOnce(opts: {
const mediaUrls =
replyPayload.mediaUrls ??
(replyPayload.mediaUrl ? [replyPayload.mediaUrl] : []);
const reasoningPayloads = includeReasoning
? resolveHeartbeatReasoningPayloads(replyResult).filter(
(payload) => payload !== replyPayload,
)
: [];
const previewText = shouldSkipMain
? reasoningPayloads
.map((payload) => payload.text)
.filter((text): text is string => Boolean(text?.trim()))
.join("\n")
: normalized.text;
if (delivery.provider === "none" || !delivery.to) {
emitHeartbeatEvent({
status: "skipped",
reason: delivery.reason ?? "no-target",
preview: normalized.text?.slice(0, 200),
preview: previewText?.slice(0, 200),
durationMs: Date.now() - startedAt,
hasMedia: mediaUrls.length > 0,
});
@@ -333,7 +339,7 @@ export async function runHeartbeatOnce(opts: {
emitHeartbeatEvent({
status: "skipped",
reason: readiness.reason,
preview: normalized.text?.slice(0, 200),
preview: previewText?.slice(0, 200),
durationMs: Date.now() - startedAt,
hasMedia: mediaUrls.length > 0,
});
@@ -350,10 +356,14 @@ export async function runHeartbeatOnce(opts: {
to: delivery.to,
payloads: [
...reasoningPayloads,
{
text: normalized.text,
mediaUrls,
},
...(shouldSkipMain
? []
: [
{
text: normalized.text,
mediaUrls,
},
]),
],
deps: opts.deps,
});
@@ -361,7 +371,7 @@ export async function runHeartbeatOnce(opts: {
emitHeartbeatEvent({
status: "sent",
to: delivery.to,
preview: normalized.text?.slice(0, 200),
preview: previewText?.slice(0, 200),
durationMs: Date.now() - startedAt,
hasMedia: mediaUrls.length > 0,
});