fix: Telegram health-monitor stale-socket restart every ~35min on 2026.3.2 (post-#10795 fix)

root · root · commit 65dc78ffacf9 · 2026-03-07T07:48:55.000+08:00
diff --git a/src/gateway/channel-health-monitor.ts b/src/gateway/channel-health-monitor.ts
@@ -122,6 +122,7 @@ export function startChannelHealthMonitor(deps: ChannelHealthMonitorDeps): Chann
             continue;
           }
           const healthPolicy: ChannelHealthPolicy = {
+            channelId,
             now,
             staleEventThresholdMs: timing.staleEventThresholdMs,
             channelConnectGraceMs: timing.channelConnectGraceMs,
diff --git a/src/gateway/channel-health-policy.ts b/src/gateway/channel-health-policy.ts
@@ -28,6 +28,7 @@ export type ChannelHealthEvaluation = {
 };
 
 export type ChannelHealthPolicy = {
+  channelId?: string;
   now: number;
   staleEventThresholdMs: number;
   channelConnectGraceMs: number;
@@ -97,6 +98,11 @@ export function evaluateChannelHealth(
   if (snapshot.connected === false) {
     return { healthy: false, reason: "disconnected" };
   }
+  // Skip stale-socket check for Telegram (long-polling mode). Each polling request
+  // acts as a heartbeat, so the half-dead WebSocket scenario this check is designed
+  // to catch does not apply to Telegram's long-polling architecture.
+  if (policy.channelId !== "telegram") {
+
   if (snapshot.lastEventAt != null || snapshot.lastStartAt != null) {
     const upSince = snapshot.lastStartAt ?? 0;
     const upDuration = policy.now - upSince;
@@ -108,6 +114,7 @@ export function evaluateChannelHealth(
       }
     }
   }
+  }
   return { healthy: true, reason: "healthy" };
 }
 
diff --git a/src/gateway/server/readiness.ts b/src/gateway/server/readiness.ts
@@ -50,17 +50,18 @@ export function createReadinessChecker(deps: {
 
     const snapshot = channelManager.getRuntimeSnapshot();
     const failing: string[] = [];
-    const policy: ChannelHealthPolicy = {
-      now,
-      staleEventThresholdMs: DEFAULT_CHANNEL_STALE_EVENT_THRESHOLD_MS,
-      channelConnectGraceMs: DEFAULT_CHANNEL_CONNECT_GRACE_MS,
-    };
 
     for (const [channelId, accounts] of Object.entries(snapshot.channelAccounts)) {
       if (!accounts) {
         continue;
       }
       for (const accountSnapshot of Object.values(accounts)) {
+        const policy: ChannelHealthPolicy = {
+          now,
+          staleEventThresholdMs: DEFAULT_CHANNEL_STALE_EVENT_THRESHOLD_MS,
+          channelConnectGraceMs: DEFAULT_CHANNEL_CONNECT_GRACE_MS,
+          channelId,
+        };
         if (!accountSnapshot) {
           continue;
         }

Original file line number	Diff line number	Diff line change
`@@ -122,6 +122,7 @@ export function startChannelHealthMonitor(deps: ChannelHealthMonitorDeps): Chann`
`122`	`122`	`continue;`
`123`	`123`	`}`
`124`	`124`	`const healthPolicy: ChannelHealthPolicy = {`
	`125`	`+ channelId,`
`125`	`126`	`now,`
`126`	`127`	`staleEventThresholdMs: timing.staleEventThresholdMs,`
`127`	`128`	`channelConnectGraceMs: timing.channelConnectGraceMs,`
Original file line number	Diff line number	Diff line change
`@@ -28,6 +28,7 @@ export type ChannelHealthEvaluation = {`
`28`	`28`	`};`
`29`	`29`
`30`	`30`	`export type ChannelHealthPolicy = {`
	`31`	`+ channelId?: string;`
`31`	`32`	`now: number;`
`32`	`33`	`staleEventThresholdMs: number;`
`33`	`34`	`channelConnectGraceMs: number;`
`@@ -97,6 +98,11 @@ export function evaluateChannelHealth(`
`97`	`98`	`if (snapshot.connected === false) {`
`98`	`99`	`return { healthy: false, reason: "disconnected" };`
`99`	`100`	`}`
	`101`	`+ // Skip stale-socket check for Telegram (long-polling mode). Each polling request`
	`102`	`+ // acts as a heartbeat, so the half-dead WebSocket scenario this check is designed`
	`103`	`+ // to catch does not apply to Telegram's long-polling architecture.`
	`104`	`+ if (policy.channelId !== "telegram") {`
	`105`	`+`
`100`	`106`	`if (snapshot.lastEventAt != null \|\| snapshot.lastStartAt != null) {`
`101`	`107`	`const upSince = snapshot.lastStartAt ?? 0;`
`102`	`108`	`const upDuration = policy.now - upSince;`
`@@ -108,6 +114,7 @@ export function evaluateChannelHealth(`
`108`	`114`	`}`
`109`	`115`	`}`
`110`	`116`	`}`
	`117`	`+ }`
`111`	`118`	`return { healthy: true, reason: "healthy" };`
`112`	`119`	`}`
`113`	`120`