fix(discord): surface stalled transport health

clawsweeper[bot] · clawsweeper[bot] · commit 5b2e8ac15ff6 · 2026-05-03T03:15:18.000Z
diff --git a/src/gateway/protocol/channels.schema.test.ts b/src/gateway/protocol/channels.schema.test.ts
@@ -1,9 +1,10 @@
 import AjvPkg from "ajv";
 import { describe, expect, it } from "vitest";
-import { WebLoginWaitParamsSchema } from "./schema/channels.js";
+import { ChannelsStatusResultSchema, WebLoginWaitParamsSchema } from "./schema/channels.js";
+
+const Ajv = AjvPkg as unknown as new (opts?: object) => import("ajv").default;
 
 describe("WebLoginWaitParamsSchema", () => {
-  const Ajv = AjvPkg as unknown as new (opts?: object) => import("ajv").default;
   const validate = new Ajv().compile(WebLoginWaitParamsSchema);
 
   it("bounds caller-provided QR data URLs", () => {
@@ -25,3 +26,40 @@ describe("WebLoginWaitParamsSchema", () => {
     ).toBe(false);
   });
 });
+
+describe("ChannelsStatusResultSchema", () => {
+  const validate = new Ajv().compile(ChannelsStatusResultSchema);
+
+  it("accepts gateway event-loop diagnostics emitted by channels.status", () => {
+    expect(
+      validate({
+        ts: Date.now(),
+        channelOrder: ["discord"],
+        channelLabels: { discord: "Discord" },
+        channels: { discord: { configured: true } },
+        channelAccounts: {
+          discord: [
+            {
+              accountId: "default",
+              enabled: true,
+              configured: true,
+              running: true,
+              connected: false,
+              healthState: "stale-socket",
+            },
+          ],
+        },
+        channelDefaultAccountId: { discord: "default" },
+        eventLoop: {
+          degraded: true,
+          reasons: ["event_loop_delay", "cpu"],
+          intervalMs: 62_000,
+          delayP99Ms: 1_250.5,
+          delayMaxMs: 62_000,
+          utilization: 0.98,
+          cpuCoreRatio: 1.2,
+        },
+      }),
+    ).toBe(true);
+  });
+});
diff --git a/src/gateway/protocol/schema/channels.ts b/src/gateway/protocol/schema/channels.ts
@@ -287,6 +287,25 @@ export const ChannelUiMetaSchema = Type.Object(
   { additionalProperties: false },
 );
 
+export const ChannelEventLoopHealthSchema = Type.Object(
+  {
+    degraded: Type.Boolean(),
+    reasons: Type.Array(
+      Type.Union([
+        Type.Literal("event_loop_delay"),
+        Type.Literal("event_loop_utilization"),
+        Type.Literal("cpu"),
+      ]),
+    ),
+    intervalMs: Type.Integer({ minimum: 0 }),
+    delayP99Ms: Type.Number({ minimum: 0 }),
+    delayMaxMs: Type.Number({ minimum: 0 }),
+    utilization: Type.Number({ minimum: 0 }),
+    cpuCoreRatio: Type.Number({ minimum: 0 }),
+  },
+  { additionalProperties: false },
+);
+
 export const ChannelsStatusResultSchema = Type.Object(
   {
     ts: Type.Integer({ minimum: 0 }),
@@ -298,6 +317,7 @@ export const ChannelsStatusResultSchema = Type.Object(
     channels: Type.Record(NonEmptyString, Type.Unknown()),
     channelAccounts: Type.Record(NonEmptyString, Type.Array(ChannelAccountSnapshotSchema)),
     channelDefaultAccountId: Type.Record(NonEmptyString, NonEmptyString),
+    eventLoop: Type.Optional(ChannelEventLoopHealthSchema),
   },
   { additionalProperties: false },
 );
