fix(discord): remove ETIMEDOUT from pre-dispatch allowlist

ZOOWH · ZOOWH · commit 5699be8a4d3c · 2026-07-07T06:51:20.000+08:00
ETIMEDOUT can occur both before and after the HTTP request reaches Discord (response timeout after acceptance), so returning not_sent would risk duplicate messages. Keep it unresolved to preserve duplicate-send safety. (#100979)
diff --git a/extensions/discord/src/channel.ts b/extensions/discord/src/channel.ts
@@ -114,7 +114,7 @@ const discordMessageAdapterBase = createChannelMessageAdapterFromOutbound({
  *  ENETUNREACH). Falls back to `unresolved` otherwise to avoid blindly
  *  duplicating messages that may have already been delivered. (#100979) */
 const PRE_DISPATCH_ERROR_RE =
-  /\b(UND_ERR_CONNECT_TIMEOUT|ECONNREFUSED|ENOTFOUND|EAI_AGAIN|ENETUNREACH|ERR_CONNECT_TIMEOUT|EADDRNOTAVAIL|ETIMEDOUT)\b/iu;
+  /\b(UND_ERR_CONNECT_TIMEOUT|ECONNREFUSED|ENOTFOUND|EAI_AGAIN|ENETUNREACH|ERR_CONNECT_TIMEOUT|EADDRNOTAVAIL)\b/iu;
 
 function reconcileDiscordUnknownSend(ctx: {
   lastError?: string | null;
diff --git a/extensions/discord/src/durable-delivery.test.ts b/extensions/discord/src/durable-delivery.test.ts
@@ -169,4 +169,24 @@ describe("durable Discord delivery", () => {
     expect(unresolved.status).toBe("unresolved");
     expect(unresolved.retryable).toBe(false);
   });
+
+  it("keeps ETIMEDOUT unresolved (can be post-dispatch response timeout)", async () => {
+    const durable = (discordPlugin.message as Record<string, unknown>).durableFinal as
+      | { reconcileUnknownSend?: Function }
+      | undefined;
+    expect(durable?.reconcileUnknownSend).toBeDefined();
+    const result = await durable!.reconcileUnknownSend!({
+      cfg: {},
+      queueId: "test-q",
+      channel: "discord",
+      to: "channel:1",
+      enqueuedAt: Date.now(),
+      retryCount: 0,
+      payloads: [{ text: "t" }],
+      lastError: "fetch failed | ETIMEDOUT",
+    });
+    const unresolved = result as { status: string; error: string; retryable: boolean };
+    expect(unresolved.status).toBe("unresolved");
+    expect(unresolved.retryable).toBe(false);
+  });
 });
