drission 0.2.0

Rust 反检测浏览器自动化 + 内置验证码识别:ddddocr 离线 OCR 与图片滑块缺口距离(极验/顶象),默认 Camoufox/Firefox、自动过 Cloudflare 盾、高并发爬虫与 XHR 监听拦截,DrissionPage 风格 API。Anti-detect browser automation in Rust with built-in ddddocr captcha OCR + slider-gap (GeeTest) solving, Camoufox, Cloudflare bypass — a Rust DrissionPage.
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

//! 请求拦截示例:**伪造响应** / 中止 / 改写放行。
//!
//! 这里用 `fulfill` 伪造一个本不存在接口(`/api/profile`)的响应:页面里的 `fetch`
//! 实际拿到的就是我们伪造的 JSON,请求并不会真正发往服务器。
//! 只拦截匹配 `"/api/"` 的请求,其余请求由库自动放行,页面照常加载。
//!
//! 运行:`cargo run --example intercept`

use std::time::Duration;

use drission::prelude::*;

#[tokio::main]
async fn main() -> drission::Result<()> {
    tracing_subscriber::fmt()
        .with_env_filter(
            tracing_subscriber::EnvFilter::try_from_default_env().unwrap_or_else(|_| "warn".into()),
        )
        .init();

    let browser = Browser::launch(
        BrowserOptions::new()
            .headless(true)
            .bypass_csp(true)
            .ignore_https_errors(true),
    )
    .await?;
    let tab = browser.latest_tab().await?;
    tab.get("https://example.com/").await?;

    // 只拦截发往 /api/ 的 XHR/fetch,其余自动放行。
    tab.intercept_xhr(&["/api/"]).await?;

    // 页面里发起一个对不存在接口的 fetch,把结果写入全局变量便于稍后读取。
    tab.run_js(
        "window.__hijacked = null; \
         fetch('https://example.com/api/profile') \
           .then(r => r.json()).then(j => window.__hijacked = j) \
           .catch(e => window.__hijacked = { error: String(e) }); true",
    )
    .await?;

    // 取到被拦请求,用伪造 JSON 直接满足它(不真正发往服务器)。
    let req = tab.intercept_next().await?;
    println!("拦截到: {} {} [{}]", req.method, req.url, req.resource_type);
    req.fulfill(
        200,
        vec![("content-type".to_string(), "application/json".to_string())],
        r#"{"id":1,"name":"drission","hijacked":true}"#,
    )
    .await?;

    // 轮询读取页面拿到的(已被伪造的)响应。
    let mut got = serde_json::Value::Null;
    for _ in 0..30 {
        let v = tab.run_js("window.__hijacked").await?;
        if !v.is_null() {
            got = v;
            break;
        }
        tokio::time::sleep(Duration::from_millis(100)).await;
    }
    println!("页面 JS 实际拿到的响应(已被伪造): {got}");

    tab.intercept_stop().await?;

    // 其他决策方式(仅注释说明,本例未实跑):
    //   req.abort("blockedbyclient").await?;  // 直接中止,适合拦广告/统计/打点
    //   req.resume().await?;                   // 原样放行
    //   req.resume_with(                       // 改写后放行
    //       ResumeOptions::new().headers(vec![("X-Inject".into(), "1".into())]),
    //   ).await?;

    browser.quit().await?;
    println!("完成。");
    Ok(())
}