Struct IdentitySession 

pub struct IdentitySession { /* private fields */ }

A rustenium browser session with an identity applied.

Implementations

impl IdentitySession

pub async fn launch( config: impl Into<IdentityConfig>, ) -> Result<Self, IdentityError>

Launch a new Chromium instance from the given config. Applies all CDP emulation overrides and registers the stealth bootstrap script before returning.

Examples found in repository

examples/launch.rs (line 32)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let identity = match std::env::args().nth(1) {
        Some(arg) => {
            let id: u64 = arg.parse()?;
            preset::get_by_id(id)?
        }
        None => preset::random(),
    };

    println!(
        "Launching preset #{:?}: {:?} {} / {:?} / {}",
        identity.id, identity.os, identity.os_version, identity.browser, identity.gpu.webgl_renderer
    );

    let _session = IdentitySession::launch(identity).await?;

    println!("Browser is up with the identity applied.");
    println!("Visit a detection site in the opened window (e.g. creepjs / bot.sannysoft.com).");
    println!("Press Ctrl-C to quit.");

    // Hold the process (and therefore the browser) open until interrupted.
    tokio::signal::ctrl_c().await?;
    println!("\nShutting down.");
    Ok(())
}

examples/verify.rs (line 23)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let identity = match std::env::args().nth(1) {
        Some(arg) => preset::get_by_id(arg.parse()?)?,
        None => preset::random(),
    };
    let url = std::env::args()
        .nth(2)
        .unwrap_or_else(|| "https://abrahamjuliot.github.io/creepjs/".to_string());

    println!("preset #{:?}: {:?} / {:?}", identity.id, identity.os, identity.browser);

    let mut session = IdentitySession::launch(identity).await?;
    println!("launched, navigating to {url} ...");

    // Collect page errors before anything else runs.
    session.browser().add_init_script(rustenium::cdp::target_manager::InitScript {
        page: Some(r#"window.__errs=[];
            addEventListener('error', e => __errs.push('ERR ' + (e.message||e)));
            addEventListener('unhandledrejection', e => __errs.push('REJ ' + (e.reason && (e.reason.message||e.reason))));
        "#.into()),
        worker: None,
    }).await;

    session.browser_mut().navigate(&url).await?;
    println!("navigated; waiting for CreepJS to finish computing");

    // CreepJS takes a while; poll for the widget rather than guessing a duration.
    let mut rendered = false;
    for _ in 0..40 {
        tokio::time::sleep(Duration::from_secs(2)).await;
        let probe = session
            .browser_mut()
            .evaluate_script("!!document.querySelector('.stealth-rating')", false)
            .await;
        if let Ok(v) = probe {
            if format!("{:?}", v).contains("true") {
                rendered = true;
                break;
            }
        }
        print!(".");
    }
    println!();
    if !rendered {
        println!("WARNING: stealth widget never rendered — page may be blocked or hung");
    }
    tokio::time::sleep(Duration::from_secs(3)).await;

    let expr = r#"(() => {
        const pct = (s) => { const e=document.querySelector(s); return e ? (e.textContent.match(/^\s*(\d+%)/)||['','?'])[1] : 'MISSING'; };
        const flagged = [...document.querySelectorAll('#fingerprint-data span.hash')]
            .map(e => [e.parentElement.textContent.trim().slice(0,12), e.className.replace('hash','').trim()])
            .filter(([,c]) => c).map(([n,c]) => n+'='+c);
        return 'stealth=' + pct('.stealth-rating') + ' headless=' + pct('.headless-rating')
             + ' hashes=' + document.querySelectorAll('span.hash').length
             + ' flagged=' + (flagged.join(',') || 'NONE');
    })()"#;

    match session.browser_mut().evaluate_script(expr, false).await {
        Ok(v) => println!("\n=== CreepJS ===\n{:?}", v.result.value),
        Err(e) => println!("\nevaluate failed: {e:?}"),
    }

    session.close().await;
    Ok(())
}

pub fn browser(&self) -> &ChromeBrowser

Access the underlying rustenium ChromeBrowser.

Examples found in repository

examples/verify.rs (line 27)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let identity = match std::env::args().nth(1) {
        Some(arg) => preset::get_by_id(arg.parse()?)?,
        None => preset::random(),
    };
    let url = std::env::args()
        .nth(2)
        .unwrap_or_else(|| "https://abrahamjuliot.github.io/creepjs/".to_string());

    println!("preset #{:?}: {:?} / {:?}", identity.id, identity.os, identity.browser);

    let mut session = IdentitySession::launch(identity).await?;
    println!("launched, navigating to {url} ...");

    // Collect page errors before anything else runs.
    session.browser().add_init_script(rustenium::cdp::target_manager::InitScript {
        page: Some(r#"window.__errs=[];
            addEventListener('error', e => __errs.push('ERR ' + (e.message||e)));
            addEventListener('unhandledrejection', e => __errs.push('REJ ' + (e.reason && (e.reason.message||e.reason))));
        "#.into()),
        worker: None,
    }).await;

    session.browser_mut().navigate(&url).await?;
    println!("navigated; waiting for CreepJS to finish computing");

    // CreepJS takes a while; poll for the widget rather than guessing a duration.
    let mut rendered = false;
    for _ in 0..40 {
        tokio::time::sleep(Duration::from_secs(2)).await;
        let probe = session
            .browser_mut()
            .evaluate_script("!!document.querySelector('.stealth-rating')", false)
            .await;
        if let Ok(v) = probe {
            if format!("{:?}", v).contains("true") {
                rendered = true;
                break;
            }
        }
        print!(".");
    }
    println!();
    if !rendered {
        println!("WARNING: stealth widget never rendered — page may be blocked or hung");
    }
    tokio::time::sleep(Duration::from_secs(3)).await;

    let expr = r#"(() => {
        const pct = (s) => { const e=document.querySelector(s); return e ? (e.textContent.match(/^\s*(\d+%)/)||['','?'])[1] : 'MISSING'; };
        const flagged = [...document.querySelectorAll('#fingerprint-data span.hash')]
            .map(e => [e.parentElement.textContent.trim().slice(0,12), e.className.replace('hash','').trim()])
            .filter(([,c]) => c).map(([n,c]) => n+'='+c);
        return 'stealth=' + pct('.stealth-rating') + ' headless=' + pct('.headless-rating')
             + ' hashes=' + document.querySelectorAll('span.hash').length
             + ' flagged=' + (flagged.join(',') || 'NONE');
    })()"#;

    match session.browser_mut().evaluate_script(expr, false).await {
        Ok(v) => println!("\n=== CreepJS ===\n{:?}", v.result.value),
        Err(e) => println!("\nevaluate failed: {e:?}"),
    }

    session.close().await;
    Ok(())
}

pub fn browser_mut(&mut self) -> &mut ChromeBrowser

Mutable access to the underlying rustenium ChromeBrowser.

Examples found in repository

examples/verify.rs (line 35)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let identity = match std::env::args().nth(1) {
        Some(arg) => preset::get_by_id(arg.parse()?)?,
        None => preset::random(),
    };
    let url = std::env::args()
        .nth(2)
        .unwrap_or_else(|| "https://abrahamjuliot.github.io/creepjs/".to_string());

    println!("preset #{:?}: {:?} / {:?}", identity.id, identity.os, identity.browser);

    let mut session = IdentitySession::launch(identity).await?;
    println!("launched, navigating to {url} ...");

    // Collect page errors before anything else runs.
    session.browser().add_init_script(rustenium::cdp::target_manager::InitScript {
        page: Some(r#"window.__errs=[];
            addEventListener('error', e => __errs.push('ERR ' + (e.message||e)));
            addEventListener('unhandledrejection', e => __errs.push('REJ ' + (e.reason && (e.reason.message||e.reason))));
        "#.into()),
        worker: None,
    }).await;

    session.browser_mut().navigate(&url).await?;
    println!("navigated; waiting for CreepJS to finish computing");

    // CreepJS takes a while; poll for the widget rather than guessing a duration.
    let mut rendered = false;
    for _ in 0..40 {
        tokio::time::sleep(Duration::from_secs(2)).await;
        let probe = session
            .browser_mut()
            .evaluate_script("!!document.querySelector('.stealth-rating')", false)
            .await;
        if let Ok(v) = probe {
            if format!("{:?}", v).contains("true") {
                rendered = true;
                break;
            }
        }
        print!(".");
    }
    println!();
    if !rendered {
        println!("WARNING: stealth widget never rendered — page may be blocked or hung");
    }
    tokio::time::sleep(Duration::from_secs(3)).await;

    let expr = r#"(() => {
        const pct = (s) => { const e=document.querySelector(s); return e ? (e.textContent.match(/^\s*(\d+%)/)||['','?'])[1] : 'MISSING'; };
        const flagged = [...document.querySelectorAll('#fingerprint-data span.hash')]
            .map(e => [e.parentElement.textContent.trim().slice(0,12), e.className.replace('hash','').trim()])
            .filter(([,c]) => c).map(([n,c]) => n+'='+c);
        return 'stealth=' + pct('.stealth-rating') + ' headless=' + pct('.headless-rating')
             + ' hashes=' + document.querySelectorAll('span.hash').length
             + ' flagged=' + (flagged.join(',') || 'NONE');
    })()"#;

    match session.browser_mut().evaluate_script(expr, false).await {
        Ok(v) => println!("\n=== CreepJS ===\n{:?}", v.result.value),
        Err(e) => println!("\nevaluate failed: {e:?}"),
    }

    session.close().await;
    Ok(())
}

pub fn identity(&self) -> &Identity

Get the identity.

pub async fn close(self) -> bool

Examples found in repository

examples/verify.rs (line 75)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let identity = match std::env::args().nth(1) {
        Some(arg) => preset::get_by_id(arg.parse()?)?,
        None => preset::random(),
    };
    let url = std::env::args()
        .nth(2)
        .unwrap_or_else(|| "https://abrahamjuliot.github.io/creepjs/".to_string());

    println!("preset #{:?}: {:?} / {:?}", identity.id, identity.os, identity.browser);

    let mut session = IdentitySession::launch(identity).await?;
    println!("launched, navigating to {url} ...");

    // Collect page errors before anything else runs.
    session.browser().add_init_script(rustenium::cdp::target_manager::InitScript {
        page: Some(r#"window.__errs=[];
            addEventListener('error', e => __errs.push('ERR ' + (e.message||e)));
            addEventListener('unhandledrejection', e => __errs.push('REJ ' + (e.reason && (e.reason.message||e.reason))));
        "#.into()),
        worker: None,
    }).await;

    session.browser_mut().navigate(&url).await?;
    println!("navigated; waiting for CreepJS to finish computing");

    // CreepJS takes a while; poll for the widget rather than guessing a duration.
    let mut rendered = false;
    for _ in 0..40 {
        tokio::time::sleep(Duration::from_secs(2)).await;
        let probe = session
            .browser_mut()
            .evaluate_script("!!document.querySelector('.stealth-rating')", false)
            .await;
        if let Ok(v) = probe {
            if format!("{:?}", v).contains("true") {
                rendered = true;
                break;
            }
        }
        print!(".");
    }
    println!();
    if !rendered {
        println!("WARNING: stealth widget never rendered — page may be blocked or hung");
    }
    tokio::time::sleep(Duration::from_secs(3)).await;

    let expr = r#"(() => {
        const pct = (s) => { const e=document.querySelector(s); return e ? (e.textContent.match(/^\s*(\d+%)/)||['','?'])[1] : 'MISSING'; };
        const flagged = [...document.querySelectorAll('#fingerprint-data span.hash')]
            .map(e => [e.parentElement.textContent.trim().slice(0,12), e.className.replace('hash','').trim()])
            .filter(([,c]) => c).map(([n,c]) => n+'='+c);
        return 'stealth=' + pct('.stealth-rating') + ' headless=' + pct('.headless-rating')
             + ' hashes=' + document.querySelectorAll('span.hash').length
             + ' flagged=' + (flagged.join(',') || 'NONE');
    })()"#;

    match session.browser_mut().evaluate_script(expr, false).await {
        Ok(v) => println!("\n=== CreepJS ===\n{:?}", v.result.value),
        Err(e) => println!("\nevaluate failed: {e:?}"),
    }

    session.close().await;
    Ok(())
}