aigw-anthropic 0.5.0

Anthropic provider for AI Gateway
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

//! Error types for the Anthropic provider.

use crate::transport::TransportConfigError;
use crate::types::ApiError;

/// Errors that can occur when using the Anthropic API client.
#[derive(Debug, thiserror::Error)]
pub enum Error {
    /// HTTP transport error (connection, TLS, timeout via reqwest).
    #[error("HTTP error: {0}")]
    Http(#[from] reqwest::Error),

    /// JSON serialization or deserialization error.
    #[error("JSON error: {0}")]
    Json(#[from] serde_json::Error),

    /// Anthropic API returned a structured error response.
    #[error("Anthropic API error ({status}): [{error_type}] {message}")]
    Api {
        /// HTTP status code.
        status: u16,
        /// Error type (e.g. `"invalid_request_error"`, `"rate_limit_error"`).
        error_type: String,
        /// Human-readable error message.
        message: String,
    },

    /// Non-JSON error response from the server (e.g. 502 HTML page from a proxy).
    #[error("unexpected error response ({status}): {body}")]
    UnexpectedResponse {
        /// HTTP status code.
        status: u16,
        /// Raw response body.
        body: String,
    },

    /// Error from the SSE stream parser.
    #[error("SSE stream error: {source}")]
    Stream {
        /// The underlying stream error.
        #[source]
        source: Box<dyn std::error::Error + Send + Sync>,
    },

    /// Invalid transport configuration.
    #[error("transport config: {0}")]
    Transport(#[from] TransportConfigError),

    /// Invalid client configuration (non-transport).
    #[error("invalid configuration: {0}")]
    Config(String),
}

impl Error {
    pub(crate) fn from_api_error(status: u16, error: ApiError) -> Self {
        Self::Api {
            status,
            error_type: error.r#type,
            message: error.message,
        }
    }

    pub(crate) fn stream(err: impl std::error::Error + Send + Sync + 'static) -> Self {
        Self::Stream {
            source: Box::new(err),
        }
    }
}