chaser-oxide 0.2.2

Undetectable browser automation library
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

use std::panic;
use std::sync::OnceLock;

use chaser_oxide::{Browser, BrowserConfig};
use futures::{FutureExt, StreamExt};
use tokio::sync::Semaphore;

mod basic;
mod config;
mod page;
mod stealth;

static BROWSER_SEMAPHORE: OnceLock<Semaphore> = OnceLock::new();

fn browser_semaphore() -> &'static Semaphore {
    BROWSER_SEMAPHORE.get_or_init(|| Semaphore::new(1))
}

pub async fn test<T>(test: T)
where
    T: for<'a> AsyncFnOnce(&'a mut Browser),
{
    test_config(
        BrowserConfig::builder().new_headless_mode().build().unwrap(),
        test,
    )
    .await;
}

pub async fn test_config<T>(config: BrowserConfig, test: T)
where
    T: for<'a> AsyncFnOnce(&'a mut Browser),
{
    let _permit = browser_semaphore().acquire().await.unwrap();
    let (mut browser, mut handler) = Browser::launch(config).await.unwrap();

    let handle = tokio::spawn(async move {
        while let Some(h) = handler.next().await {
            match h {
                Ok(_) => continue,
                Err(_) => break,
            }
        }
    });

    let browser_ref = &mut browser;
    let result = async move {
        panic::AssertUnwindSafe(test(browser_ref))
            .catch_unwind()
            .await
    }
    .await;

    browser.close().await.unwrap();
    handle.await.unwrap();

    assert!(result.is_ok())
}