chromey 2.49.1

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

//! Phase 3: target detach / lifecycle handling for 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::js_protocol::runtime::EvaluateParams;

#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
async fn parallel_handler_errors_on_detached_target() {
    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");
    let _h = tokio::spawn(handler.run_parallel());
    let browser = Arc::new(browser);

    let page = browser.new_page("about:blank").await.expect("new_page");
    let session_id = page.session_id().as_ref().to_string();
    let target_id: String = page.target_id().clone().into();

    // Sanity: a normal command works before detach.
    page.execute(EvaluateParams::new("'pre'"))
        .await
        .expect("pre");

    // Force-detach the session.
    mock.detach_session(&session_id, &target_id).await;

    // Allow the detach event to propagate to the Router and through to the
    // SessionTask. A short loop polls until subsequent commands start failing
    // — we don't care about the exact timing, only that the page is no longer
    // serviceable after detach.
    let mut last_err = None;
    for _ in 0..50 {
        match page.execute(EvaluateParams::new("'post'")).await {
            Ok(_) => tokio::time::sleep(Duration::from_millis(10)).await,
            Err(e) => {
                last_err = Some(e);
                break;
            }
        }
    }

    assert!(
        last_err.is_some(),
        "expected post-detach command to error within ~500 ms"
    );

    drop(browser);
}