fix(discord): bound JSON response reads via shared provider helpers

lsr911 · claude · lsr911 · commit 0acda0c2555d · 2026-06-27T09:22:53.000+08:00
- pluralkit: use readProviderJsonResponse for message info lookup
- send.webhook: use readProviderJsonResponse for webhook responses
- voice-message: use readProviderJsonResponse for upload URL responses

Co-Authored-By: Claude &lt;noreply@anthropic.com&gt;
Signed-off-by: lsr911 &lt;liao.shirong@xydigit.com&gt;
diff --git a/extensions/discord/src/pluralkit.ts b/extensions/discord/src/pluralkit.ts
@@ -1,6 +1,9 @@
 // Discord plugin module implements pluralkit behavior.
 import { resolveFetch } from "openclaw/plugin-sdk/fetch-runtime";
-import { readResponseTextLimited } from "openclaw/plugin-sdk/provider-http";
+import {
+  readProviderJsonResponse,
+  readResponseTextLimited,
+} from "openclaw/plugin-sdk/provider-http";
 
 const PLURALKIT_API_BASE = "https://api.pluralkit.me/v2";
 const PLURALKIT_ERROR_BODY_LIMIT_BYTES = 8 * 1024;
@@ -59,5 +62,5 @@ export async function fetchPluralKitMessageInfo(params: {
     const detail = text.trim() ? `: ${text.trim()}` : "";
     throw new Error(`PluralKit API failed (${res.status})${detail}`);
   }
-  return (await res.json()) as PluralKitMessageInfo;
+  return await readProviderJsonResponse<PluralKitMessageInfo>(res, "discord.pluralkit");
 }
diff --git a/extensions/discord/src/send.webhook.ts b/extensions/discord/src/send.webhook.ts
@@ -1,7 +1,10 @@
 // Discord plugin module implements send.webhook behavior.
 import { recordChannelActivity } from "openclaw/plugin-sdk/channel-activity-runtime";
 import type { OpenClawConfig } from "openclaw/plugin-sdk/config-contracts";
-import { readResponseTextLimited } from "openclaw/plugin-sdk/provider-http";
+import {
+  readProviderJsonResponse,
+  readResponseTextLimited,
+} from "openclaw/plugin-sdk/provider-http";
 import { normalizeOptionalString } from "openclaw/plugin-sdk/string-coerce-runtime";
 import { resolveDiscordClientAccountContext } from "./client.js";
 import {
@@ -120,7 +123,9 @@ export async function sendWebhookMessageDiscord(
     await throwWebhookResponseError(response);
   }
 
-  const payload = (await response.json().catch(() => ({}))) as {
+  const payload = (await readProviderJsonResponse(response, "discord.webhook").catch(
+    () => ({}),
+  )) as {
     id?: string;
     channel_id?: string;
   };
diff --git a/extensions/discord/src/voice-message.ts b/extensions/discord/src/voice-message.ts
@@ -22,7 +22,10 @@ import {
 import { MEDIA_FFMPEG_MAX_AUDIO_DURATION_SECS } from "openclaw/plugin-sdk/media-runtime";
 import { unlinkIfExists } from "openclaw/plugin-sdk/media-runtime";
 import { parseStrictFiniteNumber } from "openclaw/plugin-sdk/number-runtime";
-import { readResponseTextLimited } from "openclaw/plugin-sdk/provider-http";
+import {
+  readResponseTextLimited,
+  readProviderJsonResponse,
+} from "openclaw/plugin-sdk/provider-http";
 import type { RetryRunner } from "openclaw/plugin-sdk/retry-runtime";
 import { writeExternalFileWithinRoot } from "openclaw/plugin-sdk/security-runtime";
 import { fetchWithSsrFGuard, type SsrFPolicy } from "openclaw/plugin-sdk/ssrf-runtime";
@@ -351,7 +354,7 @@ async function requestVoiceUploadUrl(params: {
     if (!res.ok) {
       throw await createVoiceRequestError(res, "Upload URL request failed");
     }
-    return (await res.json()) as UploadUrlResponse;
+    return await readProviderJsonResponse<UploadUrlResponse>(res, "discord.voice-message");
   } finally {
     await release();
   }
