diff options
| author | Claude Sonnet 5 <noreply@anthropic.com> | 2026-07-03 09:03:01 +0000 |
|---|---|---|
| committer | Claude Sonnet 5 <noreply@anthropic.com> | 2026-07-03 09:03:13 +0000 |
| commit | e38f673edc7428c0c836c39f40707cb681defb14 (patch) | |
| tree | 97a704b2d83b9d572ae67d057315a6781ddf1470 /internal/retry/backoff_test.go | |
| parent | bbd58e8d77f7c996add29b69f600e835a922542e (diff) | |
feat(provider): add native Anthropic Messages API adapter (Phase 2)
Adds internal/provider/anthropic, the first genuinely new provider.Provider
implementation on top of Phase 1's provider-neutral tool-use loop, alongside
(not replacing) the existing Docker/CLI-subprocess ContainerRunner path for
the "claude" agent type:
- internal/provider/anthropic: translates the neutral ChatRequest/ChatResponse
shape to/from Anthropic's Messages API content-block format (system as a
top-level field, tool_use/tool_result blocks, no "tool" role -- tool
results become user-role messages), with a per-model-prefix pricing table
for CostUSD
- internal/retry: IsRateLimitError additively extended to recognize
Anthropic's rate_limit_error/overloaded_error/529 shapes
- internal/config: RunnersConfig.Anthropic/AnthropicEnabled() gate
- internal/cli/serve.go, run.go: register runners["anthropic"] as a
NativeRunner when [providers.anthropic].api_key is set and enabled --
tracked as a distinct executions.agent="anthropic" budget bucket, separate
from the CLI-subprocess "claude" runner even though both bill the same
Anthropic account
go build/vet/test -race all pass. No live Anthropic API key is available in
this environment, so verification is via fake-httptest-server adapter tests
(12 cases, incl. multi-turn tool_result round-trip and rate-limit error
matching) plus a Pool/NativeRunner routing test proving agent.type:
"anthropic" actually reaches the new provider. Live end-to-end verification
against the real API is a follow-up once a key is configured.
Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01V1moSNCJRcP6kykA4tyUSs
Diffstat (limited to 'internal/retry/backoff_test.go')
| -rw-r--r-- | internal/retry/backoff_test.go | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/internal/retry/backoff_test.go b/internal/retry/backoff_test.go index a963fc2..d605f29 100644 --- a/internal/retry/backoff_test.go +++ b/internal/retry/backoff_test.go @@ -38,6 +38,27 @@ func TestIsRateLimitError_Overloaded(t *testing.T) { } } +func TestIsRateLimitError_AnthropicRateLimitError(t *testing.T) { + err := errors.New(`anthropic: http 429 rate_limit_error: Number of requests has exceeded your rate limit.`) + if !IsRateLimitError(err) { + t.Error("want true for Anthropic 'rate_limit_error' shape, got false") + } +} + +func TestIsRateLimitError_AnthropicOverloadedError(t *testing.T) { + err := errors.New(`anthropic: http 529 overloaded_error: Overloaded`) + if !IsRateLimitError(err) { + t.Error("want true for Anthropic 'overloaded_error' shape (HTTP 529), got false") + } +} + +func TestIsRateLimitError_HTTP529(t *testing.T) { + err := errors.New("anthropic: http 529 unexpected_error: service unavailable") + if !IsRateLimitError(err) { + t.Error("want true for '529', got false") + } +} + func TestIsRateLimitError_NonRateLimitError(t *testing.T) { err := errors.New("claude exited with error: exit status 1") if IsRateLimitError(err) { |
