github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-09 08:47:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(web): dedupe heartbeat ok sender

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-15 05:33:51 +00:00
parent ca97c47a02
commit 4295ff785f
1 changed files with 24 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
src/web/auto-reply/heartbeat-runner.ts
View File

@@ -52,6 +52,28 @@ export async function runWebHeartbeatOnce(opts: {
const visibility = resolveHeartbeatVisibility({ cfg, channel: "whatsapp" }); const visibility = resolveHeartbeatVisibility({ cfg, channel: "whatsapp" });
const heartbeatOkText = HEARTBEAT_TOKEN; const heartbeatOkText = HEARTBEAT_TOKEN;
const maybeSendHeartbeatOk = async (): Promise<boolean> => {
if (!visibility.showOk) {
return false;
}
if (dryRun) {
whatsappHeartbeatLog.info(`[dry-run] heartbeat ok -> ${to}`);
return false;
}
const sendResult = await sender(to, heartbeatOkText, { verbose });
heartbeatLogger.info(
{
to,
messageId: sendResult.messageId,
chars: heartbeatOkText.length,
reason: "heartbeat-ok",
},
"heartbeat ok sent",
);
whatsappHeartbeatLog.info(`heartbeat ok sent to ${to} (id ${sendResult.messageId})`);
return true;
};
const sessionCfg = cfg.session; const sessionCfg = cfg.session;
const sessionScope = sessionCfg?.scope ?? "per-sender"; const sessionScope = sessionCfg?.scope ?? "per-sender";
const mainKey = normalizeMainKey(sessionCfg?.mainKey); const mainKey = normalizeMainKey(sessionCfg?.mainKey);
@@ -165,25 +187,7 @@ export async function runWebHeartbeatOnce(opts: {
}, },
"heartbeat skipped", "heartbeat skipped",
); );
let okSent = false; const okSent = await maybeSendHeartbeatOk();
if (visibility.showOk) {
if (dryRun) {
whatsappHeartbeatLog.info(`[dry-run] heartbeat ok -> ${to}`);
} else {
const sendResult = await sender(to, heartbeatOkText, { verbose });
okSent = true;
heartbeatLogger.info(
{
to,
messageId: sendResult.messageId,
chars: heartbeatOkText.length,
reason: "heartbeat-ok",
},
"heartbeat ok sent",
);
whatsappHeartbeatLog.info(`heartbeat ok sent to ${to} (id ${sendResult.messageId})`);
}
}
emitHeartbeatEvent({ emitHeartbeatEvent({
status: "ok-empty", status: "ok-empty",
to, to,
@@ -225,25 +229,7 @@ export async function runWebHeartbeatOnce(opts: {
{ to, reason: "heartbeat-token", rawLength: replyPayload.text?.length }, { to, reason: "heartbeat-token", rawLength: replyPayload.text?.length },
"heartbeat skipped", "heartbeat skipped",
); );
let okSent = false; const okSent = await maybeSendHeartbeatOk();
if (visibility.showOk) {
if (dryRun) {
whatsappHeartbeatLog.info(`[dry-run] heartbeat ok -> ${to}`);
} else {
const sendResult = await sender(to, heartbeatOkText, { verbose });
okSent = true;
heartbeatLogger.info(
{
to,
messageId: sendResult.messageId,
chars: heartbeatOkText.length,
reason: "heartbeat-ok",
},
"heartbeat ok sent",
);
whatsappHeartbeatLog.info(`heartbeat ok sent to ${to} (id ${sendResult.messageId})`);
}
}
emitHeartbeatEvent({ emitHeartbeatEvent({
status: "ok-token", status: "ok-token",
to, to,