leyline-http 0.1.5

HTTP client that impersonates Chrome, Firefox, and Safari on the wire: TLS (JA3/JA4), HTTP/2, and HTTP/3 fingerprints
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

#![forbid(unsafe_code)]
mod builder;
pub(crate) mod decompress;
pub(crate) mod execute;
mod header_merge;
mod helpers;
mod identity;
mod proxy;
mod transport_policy;
#[cfg(feature = "websocket")]
mod websocket;

#[cfg(test)]
mod tests;

pub use builder::SessionBuilder;
pub use identity::{Identity, SessionIdentity};
#[cfg(feature = "websocket")]
pub use websocket::WebSocketBuilder;

use std::sync::{Arc, Mutex};

use url::Url;

use crate::cookie::Jar;
#[cfg(feature = "websocket")]
use crate::core::WebSocketConfig;
use crate::core::retry::RetryPolicy;
use crate::core::{CompressionConfig, ProxyConfig, RedirectPolicy, TimeoutConfig};
use crate::h2::H2Config;
use crate::pool::Pool;
use crate::profile::{Browser, ChromiumBrand, HeaderStyle, Platform};
use crate::tls::FingerprintConnector;
use crate::tls::TlsTrustConfig;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[non_exhaustive]
pub enum ProtocolPolicy {
    Auto,
    Http1,
    Http2,
    #[cfg(feature = "http3")]
    Http3,
    #[cfg(feature = "http3")]
    Race,
}

impl ProtocolPolicy {
    #[cfg(feature = "http3")]
    pub(crate) fn requires_h3(self) -> bool {
        matches!(self, Self::Http3 | Self::Race)
    }
}

#[derive(Clone)]
pub struct Session {
    inner: Arc<SessionInner>,
}

#[derive(Clone)]
pub(crate) struct SessionInner {
    browser: Option<Browser>,
    impersonates: bool,
    header_style: HeaderStyle,
    identity: Option<Identity>,
    platform: Platform,
    brand: ChromiumBrand,
    user_agent: String,
    sec_ch_ua: String,
    accept_language: String,
    header_order: Option<Vec<String>>,
    default_headers: Vec<(String, String)>,
    bearer: Option<builder::BearerToken>,
    proxy_config: ProxyConfig,
    timeouts: TimeoutConfig,
    redirect_policy: RedirectPolicy,
    compression: CompressionConfig,
    #[cfg(feature = "websocket")]
    websocket_config: WebSocketConfig,
    https_only: bool,
    cookie_jar: Jar,
    connector: FingerprintConnector,
    h2_config: H2Config,
    pool: Arc<Pool>,
    shutdown: tokio_util::sync::CancellationToken,
    audit_tls: Option<Arc<crate::audit::AuditTlsCache>>,
    protocol_policy: ProtocolPolicy,
    default_retry: RetryPolicy,
    #[cfg(feature = "http3")]
    h3_config: Option<crate::quic::H3Config>,
    tls_trust: TlsTrustConfig,
    profile: Arc<crate::profile::BrowserProfile>,
    base_url: Option<Url>,
    languages: Option<Vec<String>>,
    host_limits: crate::core::config::HostLimits,
    #[cfg(feature = "html")]
    crawl_limits: Arc<std::sync::OnceLock<crate::core::config::HostLimits>>,
    #[cfg(feature = "html")]
    crawl_pace: Option<crate::core::config::HostLimits>,
    proxy_pool: Option<crate::core::proxy_pool::ProxyPool>,
    trace: Option<Arc<dyn crate::trace::Trace>>,
    #[expect(
        clippy::type_complexity,
        reason = "The shared cache retains raw input and a parsed URL shared by active requests"
    )]
    url_cache: Arc<Mutex<Option<(String, Arc<Url>)>>>,
}