stygian-browser 0.9.2

Anti-detection browser automation library for Rust with CDP stealth features
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
108
109
110
111
112
113
114
115
116

//! Example 6: Proxy integration
//!
//! Demonstrates configuring an HTTP/SOCKS5 proxy with WebRTC leak protection
//! and verifying the apparent IP address changed.
//!
//! Set the `STYGIAN_PROXY` environment variable before running:
//!
//! ```sh
//! STYGIAN_PROXY=http://user:pass@proxy.example.com:8080 \
//!   cargo run --example proxy_integration -p stygian-browser
//! ```
//!
//! Without a proxy configured the example still runs but shows your real IP.

use std::time::Duration;

use stygian_browser::webrtc::{ProxyLocation, WebRtcConfig, WebRtcPolicy};
use stygian_browser::{BrowserConfig, BrowserPool, WaitUntil};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    tracing_subscriber::fmt::init();

    // ── Configuration ──────────────────────────────────────────────────────────
    let proxy_url = std::env::var("STYGIAN_PROXY").ok();
    let using_proxy = proxy_url.is_some();

    let mut builder = BrowserConfig::builder()
        .headless(true)
        // Block non-proxied WebRTC to prevent IP leaks
        .webrtc(WebRtcConfig {
            policy: WebRtcPolicy::DisableNonProxied,
            // Spoof geolocation to match the proxy's region
            location: Some(ProxyLocation::new_us_east()),
            ..Default::default()
        });

    if let Some(proxy) = proxy_url {
        println!("Using proxy: {proxy}");
        builder = builder.proxy(proxy);
    } else {
        println!("No STYGIAN_PROXY set — running without proxy");
    }

    let config = builder.build();

    // ── Launch ──────────────────────────────────────────────────────────────────
    let pool = BrowserPool::new(config).await?;
    let handle = pool.acquire().await?;
    let mut page = handle
        .browser()
        .ok_or("browser handle no longer valid")?
        .new_page()
        .await?;

    // ── Verify IP via ipify.org ────────────────────────────────────────────────
    println!("Checking IP via https://api.ipify.org ...");
    page.navigate(
        "https://api.ipify.org?format=json",
        WaitUntil::Selector("body".to_string()),
        Duration::from_secs(30),
    )
    .await?;

    let body = page.content().await?;
    // ipify returns {"ip":"1.2.3.4"}
    let ip_json: serde_json::Value = serde_json::from_str(
        // strip HTML wrapper if present
        body.trim()
            .trim_start_matches("<html><head></head><body>")
            .trim_end_matches("</body></html>")
            .trim(),
    )
    .unwrap_or_else(|_| serde_json::json!({"ip": "unknown"}));

    let ip = ip_json
        .get("ip")
        .and_then(|v| v.as_str())
        .unwrap_or("unknown");
    println!(
        "Apparent IP: {ip}{}",
        if using_proxy {
            " (via proxy)"
        } else {
            " (direct)"
        }
    );

    // ── Verify WebRTC policy prevents leaks ───────────────────────────────────
    page.navigate(
        "about:blank",
        WaitUntil::Selector("body".to_string()),
        Duration::from_secs(5),
    )
    .await?;

    let rtc_disabled: bool = page
        .eval(
            r"(function() {
                // DisableNonProxied mode prevents non-proxied ICE candidates
                // We verify no local IP candidates would be generated (best-effort check)
                return typeof RTCPeerConnection !== 'undefined';
            })()",
        )
        .await
        .unwrap_or(false);

    println!("RTCPeerConnection present: {rtc_disabled}  (WebRTC policy: DisableNonProxied)");
    println!("IP leak protection: enabled");

    page.close().await?;
    handle.release().await;

    println!("Done.");
    Ok(())
}