vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 12:20:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: satisfy Discord gateway fetch boundary (#70945)

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-24 23:53:23 +01:00
parent 21162233d5
commit 3a6d50deb3
1 changed files with 35 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
extensions/discord/src/monitor/gateway-plugin.ts
View File

@@ -406,6 +406,30 @@ function createGatewayPlugin(params: {
return new SafeGatewayPlugin();
}
async function fetchDiscordGatewayMetadataDirect(
input: string,
init?: DiscordGatewayFetchInit,
capture?: false | { flowId: string; meta: Record<string, unknown> },
): Promise<Response> {
const runtimeFetch = globalThis.fetch;
if (typeof runtimeFetch !== "function") {
throw new Error("fetch is not available");
}
const response = await runtimeFetch(input, init as RequestInit);
if (capture) {
captureHttpExchange({
url: input,
method: (init?.method as string | undefined) ?? "GET",
requestHeaders: init?.headers as Headers | Record<string, string> | undefined,
requestBody: (init as RequestInit & { body?: BodyInit | null })?.body ?? null,
response,
flowId: capture.flowId,
meta: capture.meta,
});
}
return response;
}
export function waitForDiscordGatewayPluginRegistration(
plugin: unknown,
): Promise<void> | undefined {
@@ -442,19 +466,16 @@ export function createDiscordGatewayPlugin(params: {
return createGatewayPlugin({
options,
fetchImpl: async (input, init) => {
const response = await fetch(input, init as RequestInit);
if (!debugProxySettings.enabled) {
captureHttpExchange({
url: input,
method: (init?.method as string | undefined) ?? "GET",
requestHeaders: init?.headers as Headers | Record<string, string> | undefined,
requestBody: (init as RequestInit & { body?: BodyInit | null })?.body ?? null,
response,
flowId: randomUUID(),
meta: { subsystem: "discord-gateway-metadata" },
});
}
return response;
return await fetchDiscordGatewayMetadataDirect(
input,
init,
debugProxySettings.enabled
? false
: {
flowId: randomUUID(),
meta: { subsystem: "discord-gateway-metadata" },
},
);
},
runtime: params.runtime,
testing: params.__testing
@@ -508,7 +529,7 @@ export function createDiscordGatewayPlugin(params: {
params.runtime.error?.(danger(`discord: invalid gateway proxy: ${String(err)}`));
return createGatewayPlugin({
options,
fetchImpl: (input, init) => fetch(input, init as RequestInit),
fetchImpl: (input, init) => fetchDiscordGatewayMetadataDirect(input, init, false),
runtime: params.runtime,
testing: params.__testing
? {