rai-sdk 0.1.1

Rust AI SDK — unified client for OpenAI, Anthropic, and OpenRouter with typed models, structured output, tool calling, and streaming
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

//! Provider implementations and the low-level streaming event they emit.
//!
//! Each provider module wraps one HTTP API and translates the crate's
//! provider-agnostic [`Prompt`](crate::Prompt)/[`Response`](crate::Response)
//! types to and from that API's wire format. Modules are gated behind the
//! matching Cargo feature (`openai`, `anthropic`, `openrouter`), all of which
//! are enabled by default.
//!
//! Most code should go through [`Client`](crate::Client) instead of using these
//! types directly; they are public so that advanced callers can drive a single
//! provider, and because streaming surfaces [`ProviderStreamEvent`].

#[cfg(feature = "openai")]
pub mod openai;

#[cfg(feature = "anthropic")]
pub mod anthropic;

#[cfg(feature = "openrouter")]
pub mod openrouter;

#[cfg(feature = "openai")]
pub use openai::OpenAIProvider;

#[cfg(feature = "anthropic")]
pub use anthropic::AnthropicProvider;

#[cfg(feature = "openrouter")]
pub use openrouter::OpenRouterProvider;

use crate::message::Usage;

/// Build the HTTP client with a deterministic TLS backend.
///
/// Cargo features are additive, so a downstream dependency can enable both
/// reqwest backends even when this crate requested only one. reqwest 0.13
/// otherwise prefers native-tls in that situation. rai-sdk keeps its documented
/// rustls default by selecting rustls explicitly whenever it is available.
#[cfg(any(feature = "openai", feature = "anthropic", feature = "openrouter"))]
pub(crate) fn http_client_builder() -> reqwest::ClientBuilder {
    let builder = reqwest::Client::builder();

    #[cfg(feature = "rustls-tls")]
    let builder = builder.tls_backend_rustls();

    #[cfg(all(not(feature = "rustls-tls"), feature = "native-tls"))]
    let builder = builder.tls_backend_native();

    builder
}

/// A low-level event decoded from a provider's server-sent event stream.
///
/// This is the raw shape yielded by
/// [`RequestBuilder::stream`](crate::RequestBuilder::stream). Providers differ
/// in how they chunk tool calls, so tool arguments arrive as a
/// [`ProviderStreamEvent::ToolCallStart`] followed by any number of
/// [`ProviderStreamEvent::ToolCallChunk`]s that must be concatenated. For a
/// pre-assembled view, use
/// [`RequestBuilder::generate_stream_events`](crate::RequestBuilder::generate_stream_events).
#[derive(Debug, Clone)]
pub enum ProviderStreamEvent {
    /// A fragment of assistant text to append to the output so far.
    Text(String),
    /// A tool call has begun; its arguments follow in later chunks.
    ToolCallStart {
        /// Provider-assigned call identifier.
        id: String,
        /// Name of the tool the model wants to run.
        name: String,
    },
    /// A fragment of the JSON argument string for a tool call.
    ToolCallChunk {
        /// Identifier of the call these arguments belong to.
        id: String,
        /// Partial JSON text to append to previously received fragments.
        arguments: String,
    },
    /// Generation finished.
    ///
    /// Depending on the provider, the finish reason and usage may arrive in
    /// separate `Done` events.
    Done {
        /// Why generation stopped, e.g. `"stop"` or `"tool_use"`.
        finish_reason: Option<String>,
        /// Token usage, when the provider reports it.
        usage: Option<Usage>,
    },
}