return Object.assign(new Error(message), { name: "AbortError" });

}

function timeoutError(message: string): Error {

return Object.assign(new Error(message), { name: "TimeoutError" });

}

describe("executeWithApiKeyRotation", () => {

it("keeps transient retry disabled by default for single-key 500", async () => {

const execute = vi.fn(async () => {

expect(execute).toHaveBeenCalledTimes(2);

});

it("retries generic AbortError when the caller signal is not aborted", async () => {

it("retries timeout-named provider errors", async () => {

const sleep = vi.fn(async () => undefined);

const execute = vi

.fn<(apiKey: string) => Promise<string>>()

.mockRejectedValueOnce(abortError("This operation was aborted"))

.mockRejectedValueOnce(timeoutError("The operation was aborted due to timeout"))

.mockResolvedValueOnce("ok");

await expect(

expect(execute).toHaveBeenCalledTimes(2);

});

it("does not retry generic AbortError without timeout evidence", async () => {

const sleep = vi.fn(async () => undefined);

const execute = vi

.fn<(apiKey: string) => Promise<string>>()

.mockRejectedValueOnce(abortError("This operation was aborted"))

.mockResolvedValueOnce("ok");

await expect(

executeWithApiKeyRotation({

provider: "openai",

apiKeys: ["key-1"],

transientRetry: { attempts: 2, baseDelayMs: 0, maxDelayMs: 0, sleep },

execute,

}),

).rejects.toThrow("This operation was aborted");

expect(execute).toHaveBeenCalledTimes(1);

expect(sleep).not.toHaveBeenCalled();

});

it.each([400, 401, 403, 404])("does not retry HTTP %i", async (status) => {

const sleep = vi.fn(async () => undefined);

const execute = vi.fn(async () => {