retryAsync,

type RetryConfig,

} from "openclaw/plugin-sdk/retry-runtime";

import { isDiscordHtmlResponseBody, summarizeDiscordResponseBody } from "./error-body.js";

const DISCORD_API_BASE = "https://discord.com/api/v10";

const DISCORD_API_RETRY_DEFAULTS = {

attempts: 3,

minDelayMs: 500,

maxDelayMs: 30_000,

maxDelayMs: 5 * 60_000,

jitter: 0.1,

};

const DISCORD_API_429_FALLBACK_RETRY_AFTER_SECONDS = 60;

type DiscordApiErrorPayload = {

message?: string;

return undefined;

}

const parsed = Number(header);

return Number.isFinite(parsed) ? parsed : undefined;

if (Number.isFinite(parsed) && parsed >= 0) {

return parsed;

}

const retryAt = Date.parse(header);

if (!Number.isFinite(retryAt)) {

return undefined;

}

return Math.max(0, (retryAt - Date.now()) / 1000);

}

function formatRetryAfterSeconds(value: number | undefined): string | undefined {

return `${rounded}s`;

}

function formatDiscordApiErrorText(text: string): string | undefined {

function formatDiscordApiErrorText(text: string, response: Response): string | undefined {

const trimmed = text.trim();

if (!trimmed) {

return undefined;

}

const payload = parseDiscordApiErrorPayload(trimmed);

if (!payload) {

const looksJson = trimmed.startsWith("{") && trimmed.endsWith("}");

return looksJson ? "unknown error" : trimmed;

if (looksJson) {

return "unknown error";

}

const summary = summarizeDiscordResponseBody(trimmed);

if (isDiscordHtmlResponseBody(trimmed, response.headers.get("content-type"))) {

if (!summary) {

return response.status === 429 ? "rate limited by Discord upstream" : undefined;

}

return response.status === 429 ? `rate limited by Discord upstream: ${summary}` : summary;

}

return summary;

}

const message =

typeof payload.message === "string" && payload.message.trim()

}

}

function getDiscordApiRetryAfterMs(

err: unknown,

retryConfig: Required<RetryConfig>,

): number | undefined {

if (!(err instanceof DiscordApiError) || typeof err.retryAfter !== "number") {

return undefined;

}

return Math.min(Math.max(0, err.retryAfter * 1000), retryConfig.maxDelayMs);

}

export type DiscordFetchOptions = {

retry?: RetryConfig;

label?: string;

});

if (!res.ok) {

const text = await res.text().catch(() => "");

const detail = formatDiscordApiErrorText(text);

const detail = formatDiscordApiErrorText(text, res);

const suffix = detail ? `: ${detail}` : "";

const retryAfter = res.status === 429 ? parseRetryAfterSeconds(text, res) : undefined;

const retryAfter =

res.status === 429

? (parseRetryAfterSeconds(text, res) ?? DISCORD_API_429_FALLBACK_RETRY_AFTER_SECONDS)

: undefined;

throw new DiscordApiError(

`Discord API ${path} failed (${res.status})${suffix}`,

res.status,

...retryConfig,

label: options?.label ?? path,

shouldRetry: (err) => err instanceof DiscordApiError && err.status === 429,

retryAfterMs: (err) =>

err instanceof DiscordApiError && typeof err.retryAfter === "number"

? err.retryAfter * 1000

: undefined,

retryAfterMs: (err) => getDiscordApiRetryAfterMs(err, retryConfig),

},

);

}