@effect/ai-anthropic

Provides a type-safe wrapper around the Anthropic API using Effect-TS's functional error handling and resource management primitives. Implements automatic retry logic, timeout handling, and structured error propagation through Effect's Either/Result types, eliminating callback hell and promise-based error chains. Integrates with Effect's Layer system for dependency injection and resource lifecycle management.

Implements streaming responses from Anthropic's API using Effect's Stream abstraction, providing built-in backpressure handling, cancellation tokens, and resource cleanup. Streams are lazily evaluated and can be composed with other Effect streams for token-level processing, filtering, and aggregation without buffering entire responses in memory.

Enables Anthropic's tool-use feature through a schema-based function registry that maps Anthropic tool definitions to TypeScript functions with automatic type extraction and validation. Uses Effect's type system to ensure tool inputs are validated against declared schemas before execution, and tool outputs are properly typed for downstream processing.

Provides a templating system for constructing prompts with variable placeholders that are type-checked at compile time. Variables are injected from a context object, and the system ensures all required variables are provided before the prompt is sent to Anthropic, preventing runtime template errors and enabling IDE autocomplete for available variables.

Manages conversation history as an immutable Effect-based data structure that supports appending messages, retrieving context windows, and composing multiple conversation threads. History is tracked through Effect's state management primitives, enabling deterministic replay, testing, and composition with other stateful operations without mutable arrays or class-based state.

Provides declarative retry policies that automatically retry failed Anthropic API calls with exponential backoff and jitter, respecting rate-limit headers and configurable max attempts. Policies are composed using Effect's policy combinators, allowing fine-grained control over retry behavior without imperative retry loops or setTimeout callbacks.

Enforces timeouts on Anthropic API calls using Effect's timeout primitives, allowing graceful degradation (fallback to cached responses or partial results) or cancellation of long-running requests. Timeouts are composable with other Effect operations and can be configured per-request or globally through the Layer system.

Uses Effect's Layer system to configure the Anthropic API client as a composable dependency that can be injected into services, enabling easy swapping of API keys, base URLs, and client configurations without modifying service code. Layers support environment-based configuration, secret management, and composition with other service layers.

Provides utilities for batch processing multiple prompts through Anthropic's API with configurable concurrency limits, using Effect's concurrency primitives (Semaphore, Queue) to prevent overwhelming the API or local resources. Batch results are collected with guaranteed ordering and error handling, allowing partial success scenarios where some requests fail.

Integrates with Effect's logging and metrics systems to provide structured logging of API calls, response times, token usage, and errors. Traces are automatically propagated through the Effect runtime, enabling correlation of logs across multiple API calls and service boundaries without manual trace ID threading.