2026-03-11 17:05:13 +09:00
|
|
|
declare const require: (name: string) => any
|
2026-04-04 20:06:56 +09:00
|
|
|
const { describe, expect, test, beforeEach, afterEach, mock, spyOn } = require("bun:test")
|
|
|
|
|
import * as connectedProvidersCache from "./connected-providers-cache"
|
2026-02-19 04:41:00 +02:00
|
|
|
|
2026-04-04 20:06:56 +09:00
|
|
|
let readConnectedProvidersCacheSpy: ReturnType<typeof spyOn> | undefined
|
|
|
|
|
const { shouldRetryError, selectFallbackProvider } = await import("./model-error-classifier")
|
2026-02-19 04:41:00 +02:00
|
|
|
|
2026-03-11 17:05:13 +09:00
|
|
|
describe("model-error-classifier", () => {
|
2026-02-19 04:41:00 +02:00
|
|
|
beforeEach(() => {
|
2026-04-04 20:06:56 +09:00
|
|
|
readConnectedProvidersCacheSpy?.mockRestore()
|
|
|
|
|
readConnectedProvidersCacheSpy = spyOn(connectedProvidersCache, "readConnectedProvidersCache").mockReturnValue(null)
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
afterEach(() => {
|
|
|
|
|
readConnectedProvidersCacheSpy?.mockRestore()
|
|
|
|
|
readConnectedProvidersCacheSpy = undefined
|
2026-02-19 04:41:00 +02:00
|
|
|
})
|
|
|
|
|
|
|
|
|
|
test("treats overloaded retry messages as retryable", () => {
|
|
|
|
|
//#given
|
|
|
|
|
const error = { message: "Provider is overloaded" }
|
|
|
|
|
|
|
|
|
|
//#when
|
|
|
|
|
const result = shouldRetryError(error)
|
|
|
|
|
|
|
|
|
|
//#then
|
|
|
|
|
expect(result).toBe(true)
|
|
|
|
|
})
|
|
|
|
|
|
2026-03-04 18:35:09 +01:00
|
|
|
test("treats cooling-down auto-retry messages as retryable", () => {
|
|
|
|
|
//#given
|
|
|
|
|
const error = {
|
|
|
|
|
message:
|
|
|
|
|
"All credentials for model claude-opus-4-6-thinking are cooling down [retrying in ~5 days attempt #1]",
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//#when
|
|
|
|
|
const result = shouldRetryError(error)
|
|
|
|
|
|
|
|
|
|
//#then
|
|
|
|
|
expect(result).toBe(true)
|
|
|
|
|
})
|
|
|
|
|
|
2026-02-19 04:41:00 +02:00
|
|
|
test("selectFallbackProvider prefers first connected provider in preference order", () => {
|
|
|
|
|
//#given
|
2026-04-04 20:06:56 +09:00
|
|
|
readConnectedProvidersCacheSpy?.mockReturnValue(["anthropic", "nvidia"])
|
2026-02-19 04:41:00 +02:00
|
|
|
|
|
|
|
|
//#when
|
2026-02-21 03:03:57 +09:00
|
|
|
const provider = selectFallbackProvider(["anthropic", "nvidia"], "nvidia")
|
2026-02-19 04:41:00 +02:00
|
|
|
|
|
|
|
|
//#then
|
2026-02-21 03:03:57 +09:00
|
|
|
expect(provider).toBe("anthropic")
|
2026-02-19 04:41:00 +02:00
|
|
|
})
|
|
|
|
|
|
|
|
|
|
test("selectFallbackProvider falls back to next connected provider when first is disconnected", () => {
|
|
|
|
|
//#given
|
2026-04-04 20:06:56 +09:00
|
|
|
readConnectedProvidersCacheSpy?.mockReturnValue(["nvidia"])
|
2026-02-19 04:41:00 +02:00
|
|
|
|
|
|
|
|
//#when
|
2026-02-21 03:03:57 +09:00
|
|
|
const provider = selectFallbackProvider(["anthropic", "nvidia"])
|
2026-02-19 04:41:00 +02:00
|
|
|
|
|
|
|
|
//#then
|
|
|
|
|
expect(provider).toBe("nvidia")
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
test("selectFallbackProvider uses provider preference order when cache is missing", () => {
|
|
|
|
|
//#given - no cache file
|
|
|
|
|
|
|
|
|
|
//#when
|
2026-02-21 03:03:57 +09:00
|
|
|
const provider = selectFallbackProvider(["anthropic", "nvidia"], "nvidia")
|
2026-02-19 04:41:00 +02:00
|
|
|
|
|
|
|
|
//#then
|
2026-02-21 03:03:57 +09:00
|
|
|
expect(provider).toBe("anthropic")
|
2026-02-19 04:41:00 +02:00
|
|
|
})
|
2026-03-04 18:35:09 +01:00
|
|
|
|
2026-03-04 18:55:43 +01:00
|
|
|
test("selectFallbackProvider uses connected preferred provider when fallback providers are unavailable", () => {
|
2026-03-04 18:35:09 +01:00
|
|
|
//#given
|
2026-04-04 20:06:56 +09:00
|
|
|
readConnectedProvidersCacheSpy?.mockReturnValue(["provider-x"])
|
2026-03-04 18:35:09 +01:00
|
|
|
|
|
|
|
|
//#when
|
2026-03-04 18:55:43 +01:00
|
|
|
const provider = selectFallbackProvider(["provider-y"], "provider-x")
|
2026-03-04 18:35:09 +01:00
|
|
|
|
|
|
|
|
//#then
|
2026-03-04 18:55:43 +01:00
|
|
|
expect(provider).toBe("provider-x")
|
2026-03-04 18:35:09 +01:00
|
|
|
})
|
2026-03-12 01:40:24 +09:00
|
|
|
|
2026-03-12 11:05:26 +09:00
|
|
|
test("treats FreeUsageLimitError (PascalCase name) as retryable by name", () => {
|
2026-03-12 01:40:24 +09:00
|
|
|
//#given
|
|
|
|
|
const error = { name: "FreeUsageLimitError" }
|
|
|
|
|
|
|
|
|
|
//#when
|
|
|
|
|
const result = shouldRetryError(error)
|
|
|
|
|
|
|
|
|
|
//#then
|
|
|
|
|
expect(result).toBe(true)
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
test("treats freeusagelimiterror (lowercase name) as retryable by name", () => {
|
|
|
|
|
//#given
|
|
|
|
|
const error = { name: "freeusagelimiterror" }
|
|
|
|
|
|
|
|
|
|
//#when
|
|
|
|
|
const result = shouldRetryError(error)
|
|
|
|
|
|
|
|
|
|
//#then
|
|
|
|
|
expect(result).toBe(true)
|
|
|
|
|
})
|
2026-02-19 04:41:00 +02:00
|
|
|
})
|
2026-04-04 02:35:23 +09:00
|
|
|
|
|
|
|
|
export {}
|