chromey 2.48.2

Concurrent chrome devtools protocol automation library for Rust
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

//! Phase 3: navigation flow round-trip on the parallel handler.

#![cfg(feature = "parallel-handler")]

#[path = "support/cdp_mock.rs"]
mod cdp_mock;

use std::sync::Arc;
use std::time::Duration;

use chromiumoxide::handler::HandlerConfig;
use chromiumoxide::Browser;
use chromiumoxide_cdp::cdp::browser_protocol::page::NavigateParams;

#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
async fn parallel_handler_completes_navigation() {
    let mock = cdp_mock::CdpMock::spawn().await;
    let cfg = HandlerConfig {
        request_timeout: Duration::from_secs(5),
        ..Default::default()
    };
    let (browser, handler) = Browser::connect_with_config(mock.ws_url(), cfg)
        .await
        .expect("connect to mock");
    let _h = tokio::spawn(handler.run_parallel());
    let browser = Arc::new(browser);

    let page = browser.new_page("about:blank").await.expect("new_page");

    // `Page.navigate` against the mock — completes when the lifecycle
    // events fire (`load` etc. emitted by the mock immediately after the
    // response).
    let resp = page
        .execute(NavigateParams::new("https://example.test/"))
        .await
        .expect("navigate");
    assert!(
        !resp.frame_id.as_ref().is_empty(),
        "navigate response should carry a frame_id"
    );

    drop(browser);
}

#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
async fn parallel_handler_supports_concurrent_navigations_across_pages() {
    let mock = cdp_mock::CdpMock::spawn().await;
    let cfg = HandlerConfig {
        request_timeout: Duration::from_secs(5),
        ..Default::default()
    };
    let (browser, handler) = Browser::connect_with_config(mock.ws_url(), cfg)
        .await
        .expect("connect to mock");
    let _h = tokio::spawn(handler.run_parallel());
    let browser = Arc::new(browser);

    const PAGES: usize = 4;
    let mut tasks = Vec::with_capacity(PAGES);
    for i in 0..PAGES {
        let b = browser.clone();
        tasks.push(tokio::spawn(async move {
            let page = b.new_page("about:blank").await.expect("new_page");
            page.execute(NavigateParams::new(format!("https://example.test/{i}")))
                .await
                .map(|_| ())
        }));
    }

    let results = futures_util::future::join_all(tasks).await;
    for r in results {
        r.expect("join").expect("navigate");
    }

    drop(browser);
}