fce506b3f9
Replace the LLMError { module, method, reason } wrapper with a flat
tagged union (LLM.BadRequest, LLM.Authentication, LLM.PermissionDenied,
LLM.NotFound, LLM.RateLimit, LLM.QuotaExceeded, LLM.ContentPolicy,
LLM.ContextOverflow, LLM.ServerError, LLM.APIError, LLM.ConnectionError,
LLM.TimeoutError, LLM.MalformedResponse, LLM.NoRoute) plus an isLLMError
guard. Add one shared classifyApiFailure classifier used by the HTTP
executor and the AI SDK adapter so both surfaces classify identically,
preserving status, headers, body, and retry-after.
Core policy moves onto tags: retry RateLimit | ServerError |
ConnectionError | TimeoutError; toSessionError adds
provider.context-overflow, provider.timeout, and provider.not-found.
The provider-error stream event and the runner's held-back overflow
handling are unchanged here; isContextOverflowFailure now bridges old
events and new tags until the event is removed.
52 lines
2 KiB
TypeScript
52 lines
2 KiB
TypeScript
import { describe, expect } from "bun:test"
|
|
import { Effect } from "effect"
|
|
import { isLLMError, LLM, Message, ToolCallPart } from "../../src"
|
|
import { LLMClient } from "../../src/route"
|
|
import * as Anthropic from "../../src/providers/anthropic"
|
|
import { weatherToolName } from "../recorded-scenarios"
|
|
import { recordedTests } from "../recorded-test"
|
|
|
|
const model = Anthropic.configure({
|
|
apiKey: process.env.ANTHROPIC_API_KEY ?? "fixture",
|
|
}).model("claude-haiku-4-5-20251001")
|
|
|
|
const malformedToolOrderRequest = LLM.request({
|
|
id: "recorded_anthropic_malformed_tool_order",
|
|
model,
|
|
messages: [
|
|
Message.assistant([
|
|
ToolCallPart.make({ id: "call_1", name: weatherToolName, input: { city: "Paris" } }),
|
|
{ type: "text", text: "I will check the weather." },
|
|
]),
|
|
Message.tool({ id: "call_1", name: weatherToolName, result: { temperature: "72F" } }),
|
|
Message.user("Use that result to answer briefly."),
|
|
],
|
|
tools: [{ name: weatherToolName, description: "Get weather", inputSchema: { type: "object", properties: {} } }],
|
|
// The cassette predates the `cache: "auto"` default; pin the policy off so
|
|
// the replayed request matches the recorded wire shape.
|
|
cache: "none",
|
|
})
|
|
|
|
const recorded = recordedTests({
|
|
prefix: "anthropic-messages",
|
|
provider: "anthropic",
|
|
protocol: "anthropic-messages",
|
|
requires: ["ANTHROPIC_API_KEY"],
|
|
options: { redact: { allowRequestHeaders: ["anthropic-version"] } },
|
|
})
|
|
|
|
describe("Anthropic Messages sad-path recorded", () => {
|
|
recorded.effect.with(
|
|
"rejects malformed assistant tool order",
|
|
// The cassette predates a test rename; keep replaying the existing recording.
|
|
{ id: "rejects-malformed-assistant-tool-order-without-patch", tags: ["tool", "sad-path"] },
|
|
() =>
|
|
Effect.gen(function* () {
|
|
const error = yield* LLMClient.generate(malformedToolOrderRequest).pipe(Effect.flip)
|
|
|
|
expect(isLLMError(error)).toBe(true)
|
|
expect(error).toMatchObject({ _tag: "LLM.BadRequest" })
|
|
expect(error.message).toContain("HTTP 400")
|
|
}),
|
|
)
|
|
})
|