} from "./internal/test-builders.test-support.js";

import { createDiscordRequestClient, DISCORD_REST_TIMEOUT_MS } from "./proxy-request-client.js";

async function expectAbortError(promise: Promise<unknown>) {

let abortError: unknown;

try {

await promise;

} catch (error) {

abortError = error;

}

expect(abortError).toBeInstanceOf(DOMException);

if (!(abortError instanceof DOMException)) {

throw new Error("expected Discord request abort error");

}

expect(abortError.name).toBe("AbortError");

expect(abortError.message).toBe("The operation was aborted.");

}

describe("createDiscordRequestClient", () => {

it("preserves the REST client's abort signal for proxied fetch calls", async () => {

const fetchSpy = vi.fn(async (_input: string | URL | Request, init?: RequestInit) => {

timeout: 20,

});

await expect(client.get("/channels/123/messages")).rejects.toMatchObject({

message: "The operation was aborted.",

name: "AbortError",

});

await expectAbortError(client.get("/channels/123/messages"));

}, 1_000);

it("lets abortAllRequests cancel active proxied fetches", async () => {

client.abortAllRequests();

await expect(request).rejects.toMatchObject({

message: "The operation was aborted.",

name: "AbortError",

});

await expectAbortError(request);

if (!abortable.receivedSignal) {

throw new Error("Expected proxied fetch abort signal");

}