Align watchdog heartbeat logging with message timeout

oromeis · oromeis · commit 3d3c35670147 · 2026-04-09T22:41:37.000Z
diff --git a/docs/.generated/config-baseline.sha256 b/docs/.generated/config-baseline.sha256
@@ -1,4 +1,4 @@
-0a75b57f5dbb0bb1488eacb47111ee22ff42dd3747bfe07bb69c9445d5e55c3e  config-baseline.json
-ff15bb8b4231fc80174249ae89bcb61439d7adda5ee6be95e4d304680253a59f  config-baseline.core.json
+00e346178fc40bbfe864266dc694fdc080658c15aac6e3b5887d76925d1a8b2e  config-baseline.json
+60a021201aff8acf89c5d1d7496edc481ae88532e83303131bfbb1a2fbe1ff05  config-baseline.core.json
 7f42b22b46c487d64aaac46001ba9d9096cf7bf0b1c263a54d39946303ff5018  config-baseline.channel.json
-483d4f3c1d516719870ad6f2aba6779b9950f85471ee77b9994a077a7574a892  config-baseline.plugin.json
+3f6fccab66a9abe7e1dd412fb01b13b944ed24edbe09df55ada3323acc7f76fe  config-baseline.plugin.json
diff --git a/extensions/whatsapp/src/auto-reply/monitor.ts b/extensions/whatsapp/src/auto-reply/monitor.ts
@@ -123,6 +123,8 @@ export async function monitorWebChannel(
   const maxMediaBytes = resolveWhatsAppMediaMaxBytes(account);
   const heartbeatSeconds = resolveHeartbeatSeconds(cfg, tuning.heartbeatSeconds);
   const reconnectPolicy = resolveReconnectPolicy(cfg, tuning.reconnect);
+  const messageTimeoutMs = resolveMessageTimeoutMs(cfg, tuning.messageTimeoutMs);
+  const messageTimeoutMinutes = Math.floor(messageTimeoutMs / 60000);
   const baseMentionConfig = buildMentionConfig(cfg);
   const groupHistoryLimit =
     cfg.channels?.whatsapp?.accounts?.[tuning.accountId ?? ""]?.historyLimit ??
@@ -192,7 +194,7 @@ export async function monitorWebChannel(
 
     // Watchdog to detect stuck message processing (e.g., event emitter died).
     // Tuning overrides are test-oriented; production defaults remain unchanged.
-    const MESSAGE_TIMEOUT_MS = resolveMessageTimeoutMs(cfg, tuning.messageTimeoutMs);
+    const MESSAGE_TIMEOUT_MS = messageTimeoutMs;
     const WATCHDOG_CHECK_MS = tuning.watchdogCheckMs ?? 60 * 1000; // 1m default
 
     const onMessage = createWebOnMessageHandler({
@@ -329,13 +331,16 @@ export async function monitorWebChannel(
           lastInboundAt: active.lastInboundAt,
           authAgeMs,
           uptimeMs: Date.now() - active.startedAt,
-          ...(minutesSinceLastMessage !== null && minutesSinceLastMessage > 30
+          ...(minutesSinceLastMessage !== null && minutesSinceLastMessage > messageTimeoutMinutes
             ? { minutesSinceLastMessage }
             : {}),
         };
 
-        if (minutesSinceLastMessage && minutesSinceLastMessage > 30) {
-          heartbeatLogger.warn(logData, "⚠️ web gateway heartbeat - no messages in 30+ minutes");
+        if (minutesSinceLastMessage && minutesSinceLastMessage > messageTimeoutMinutes) {
+          heartbeatLogger.warn(
+            logData,
+            `⚠️ web gateway heartbeat - no messages in ${messageTimeoutMinutes}+ minutes`,
+          );
         } else {
           heartbeatLogger.info(logData, "web gateway heartbeat");
         }
