wiremux 0.11.3

Wiremux maps Chat Completions, Messages, Responses, Gemini, and Converse through one IR.
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

//! Dialect maps for Chat Completions, Messages, Responses, Gemini, and Converse.
//!
//! Decode a vendor JSON body into [`IrRequest`], then encode another wire.
//! Maps-only hosts set `default-features = false`.
//!
//! ```
//! use wiremux::{Wire, decode, parse_profile_str};
//!
//! let src = br#"{"model":"gpt-4o","messages":[{"role":"user","content":"ping"}]}"#;
//! let (ir, _loss) = decode(Wire::ChatCompletions, src).unwrap();
//! assert_eq!(ir.model, "gpt-4o");
//! let profile = parse_profile_str(
//!     "schema_version = 1\nid = \"example\"\nwire = \"messages\"\n",
//! )
//! .unwrap();
//! assert_eq!(profile.id, "example");
//! ```

#[cfg(any(feature = "proxy", feature = "client"))]
mod aws_creds;
#[cfg(any(feature = "proxy", feature = "client"))]
mod aws_sign;
#[cfg(any(feature = "cli", feature = "proxy", feature = "client"))]
mod capped_body;
#[cfg(feature = "cli")]
pub mod cli;
#[cfg(feature = "client")]
pub mod client;
mod completion;
#[cfg(any(feature = "proxy", feature = "client"))]
mod headers;
#[cfg(feature = "cli")]
pub mod ingest;
pub mod ir;
pub mod map;
#[cfg(any(feature = "cli", feature = "proxy", feature = "client"))]
mod profile_auth;
#[cfg(feature = "proxy")]
pub mod proxy;
pub mod stream;
#[cfg(any(feature = "cli", feature = "proxy", feature = "client"))]
mod upstream;

pub use ir::{
    IrCache, IrDocumentSource, IrItem, IrPart, IrRequest, IrSampling, IrStreamEvent, IrTool,
    IrToolChoice, LossAction, LossEvent, LossReport, estimate_prompt_tokens,
};
pub use map::{MapError, decode, encode};
pub use stream::{
    EventStreamReader, MAX_CONTENT_BLOCK_INDEX, MAX_EVENTSTREAM_PENDING, MAX_SSE_PENDING,
    MAX_TOOL_CALL_INDEX, RawSse, SseFrameReader, StreamDecoder, StreamEncoder, ToolCallAssembler,
    decode_response, decode_response_with_loss, decode_stream_event, decode_stream_events,
    encode_eventstream_message, encode_response, encode_response_with_model, encode_stream_event,
    frame_is_terminal, stream_has_terminal,
};
pub use wiremux_auth::{
    GROK_CHAT_PROXY_CLIENT_IDENTIFIER, GROK_CHAT_PROXY_CLIENT_VERSION, VERSION,
};
pub use wiremux_auth::{
    LoadOptions, ResolvedProfile, StreamUnknownPolicy, ToolTypePolicy, Wire, load_profile,
    load_profile_for_wire, parse_profile_str,
};

#[cfg(feature = "client")]
pub use client::{ClientError, ListedModel, TransientKind, WireClient};

#[cfg(test)]
mod tests {
    #[test]
    fn version_matches_package() {
        assert_eq!(super::VERSION, env!("CARGO_PKG_VERSION"));
    }
}