fix(discord): keep gateway close reasons UTF-16 safe (#102246)

mushuiyu886 · steipete · web-flow · commit e90bf3182927 · 2026-07-09T04:28:06.000+01:00
* fix(discord): keep gateway close reasons UTF-16 safe

* test(discord): assert exact close reason truncation

---------

Co-authored-by: Peter Steinberger &lt;steipete@gmail.com&gt;
diff --git a/extensions/discord/src/monitor/gateway-plugin.test.ts b/extensions/discord/src/monitor/gateway-plugin.test.ts
@@ -355,4 +355,35 @@ describe("createDiscordGatewayPlugin", () => {
     expect(logs).toContain("lastErrorCode=WS_ERR_TOO_MANY_BUFFERED_PARTS");
     expect(logs).toContain("hint=possible ws receiver buffered-parts limit");
   });
+
+  it("keeps gateway close reason logs UTF-16 safe", () => {
+    const socket = new EventEmitter() as EventEmitter & { binaryType?: string };
+    const runtime = {
+      log: vi.fn(),
+      error: vi.fn(),
+      exit: vi.fn(),
+    };
+    const plugin = createPlugin(
+      {
+        webSocketCtor: function WebSocketCtor() {
+          return socket;
+        } as unknown as NonNullable<
+          Parameters<typeof createDiscordGatewayPlugin>[0]["testing"]
+        >["webSocketCtor"],
+      },
+      {},
+      runtime,
+    );
+    const createdSocket = (
+      plugin as unknown as { createWebSocket: (url: string) => typeof socket }
+    ).createWebSocket("wss://gateway.discord.gg");
+
+    createdSocket.emit("close", 1008, Buffer.from(`${"A".repeat(239)}🧪 tail`));
+
+    const log = String(runtime.log.mock.calls.at(-1)?.[0]);
+    expect(log).toContain("discord: gateway websocket closed");
+    expect(log).toContain("code=1008");
+    expect(log).toContain(`reason=${"A".repeat(239)}...`);
+    expect(log).toContain("hint=possible ws receiver buffered-parts limit");
+  });
 });
diff --git a/extensions/discord/src/monitor/gateway-plugin.ts b/extensions/discord/src/monitor/gateway-plugin.ts
@@ -11,6 +11,7 @@ import {
 } from "openclaw/plugin-sdk/proxy-capture";
 import { danger, warn } from "openclaw/plugin-sdk/runtime-env";
 import type { RuntimeEnv } from "openclaw/plugin-sdk/runtime-env";
+import { truncateUtf16Safe } from "openclaw/plugin-sdk/text-utility-runtime";
 import * as ws from "ws";
 import * as discordGateway from "../internal/gateway.js";
 import { createDiscordDnsLookup } from "../network-config.js";
@@ -110,7 +111,7 @@ function formatDiscordGatewayCloseReason(reason: Buffer): string {
   if (text.length <= DISCORD_GATEWAY_CLOSE_REASON_LOG_MAX_CHARS) {
     return text;
   }
-  return `${text.slice(0, DISCORD_GATEWAY_CLOSE_REASON_LOG_MAX_CHARS)}...`;
+  return `${truncateUtf16Safe(text, DISCORD_GATEWAY_CLOSE_REASON_LOG_MAX_CHARS)}...`;
 }
 
 function formatDiscordGatewayTransportErrorLog(params: {
