brazen 0.0.14

A stateless, swiss-army-knife adapter for every LLM provider and protocol.
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

//! The loopback AuthCode flow (auth §7.4) and the token exchange that ends BOTH
//! non-refresh logins, driven by [`login`](super::login). The headless device-code
//! variants live beside it in [`device`](super::device); they finish through this
//! file's [`exchange_auth_code`] whenever their variant answers a code rather than
//! a token. The interactive impurities (`BrowserLauncher`/`CodeReceiver`/`Pacer`)
//! arrive injected via [`LoginIo`](super::login::LoginIo), so both run offline in
//! tests, and the pure builders they share live in [`wire`](super::wire).

use super::login::LoginIo;
use super::oauth::{parse_token_response, AuthError, Grant};
use super::refresh::collect_body;
use super::wire::{build_authorize_url, build_token_exchange_request, parse_callback, Pkce};
use super::{auth_error, OAuthConfig};
use crate::canonical::CanonicalError;
use crate::store::{Cred, Secret};

/// AuthCode + loopback flow (RFC 8252 / auth §7.4, §10.1): bind the loopback on the
/// row's redirect port (`None` ⇒ ephemeral), build the PKCE-S256 authorize URL
/// against the row's redirect host/port/path, launch the browser, await the
/// callback, CSRF-check it, exchange the code, and return the cred.
pub(super) fn browser_flow(cfg: &OAuthConfig, io: &mut LoginIo) -> Result<Cred, CanonicalError> {
    let port = io
        .receiver
        .bind(cfg.redirect.port)
        .map_err(|e| auth_error(&format!("could not bind loopback listener: {e}")))?;
    let redirect_uri = format!("http://{}:{}{}", cfg.redirect.host, port, cfg.redirect.path);
    let pkce = Pkce::derive(io.verifier);
    let url = build_authorize_url(cfg, &pkce, io.state, &redirect_uri);
    io.browser
        .open(&url)
        .map_err(|e| auth_error(&format!("could not launch browser: {e}")))?;
    let query = io
        .receiver
        .await_query()
        .map_err(|e| auth_error(&format!("loopback receiver failed: {e}")))?;
    let callback = parse_callback(&query, io.state).map_err(fatal)?;
    exchange_auth_code(cfg, io, &callback.code, &pkce.verifier, &redirect_uri)
}

/// The AuthCode half-step both code-answering logins end in (auth §7.5): `POST
/// {token_url}` with `Grant::AuthCode`, then the ONE token parser. The loopback flow
/// reaches it with the code the browser redirected back and its own `redirect_uri`;
/// the Codex device variant reaches it with the code its poll answered and the
/// vendor's `deviceauth/callback` — one exchange, two ways of obtaining the code.
pub(super) fn exchange_auth_code(
    cfg: &OAuthConfig,
    io: &mut LoginIo,
    code: &str,
    verifier: &str,
    redirect_uri: &str,
) -> Result<Cred, CanonicalError> {
    let req = build_token_exchange_request(
        cfg,
        Grant::AuthCode {
            code,
            verifier,
            redirect_uri,
        },
    );
    let tok = parse_token_response(&collect_body(io.transport.send(req)?)?, io.clock.now())
        .map_err(fatal)?;
    Ok(tok.as_cred(&Secret::new(""), &None, &None))
}

/// Any non-success token/callback outcome is fatal in the auth-code path (→77).
pub(super) fn fatal(err: AuthError) -> CanonicalError {
    let msg = match err {
        AuthError::Pending | AuthError::SlowDown => "unexpected poll signal".to_owned(),
        AuthError::Fatal(m) => m,
    };
    auth_error(&format!("login failed: {msg}"))
}