kumo 0.2.1

An async web crawling framework for Rust — Scrapy 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

//! Demonstrates the stealth HTTP fetcher with TLS fingerprint spoofing.
//!
//! Fetches https://tls.browserleaks.com/json and prints the JA3/JA4 fingerprint.
//! When stealth is working correctly, the fingerprint will match Chrome 131, not
//! the default reqwest fingerprint.
//!
//! Run with:
//!   cargo run --example stealth --features stealth
//!
//! NOTE: The `stealth` feature requires cmake and NASM build tools for BoringSSL.
//! On Ubuntu/Debian: apt install cmake nasm
//! On macOS: brew install cmake nasm
//! On Windows: install CMake and NASM manually, or use WSL.

use kumo::prelude::*;
use serde::{Deserialize, Serialize};

#[derive(Debug, Serialize, Deserialize)]
struct TlsInfo {
    ja3: Option<String>,
    ja3_hash: Option<String>,
    ja4: Option<String>,
    user_agent: Option<String>,
}

struct StealthSpider;

#[async_trait::async_trait]
impl Spider for StealthSpider {
    type Item = TlsInfo;

    fn name(&self) -> &str {
        "stealth-test"
    }

    fn start_urls(&self) -> Vec<String> {
        vec!["https://tls.browserleaks.com/json".into()]
    }

    async fn parse(&self, res: &Response) -> Result<Output<Self::Item>, KumoError> {
        let info: TlsInfo =
            serde_json::from_str(res.text().unwrap_or("{}")).unwrap_or_else(|_| TlsInfo {
                ja3: None,
                ja3_hash: None,
                ja4: None,
                user_agent: None,
            });

        println!("JA3 hash: {}", info.ja3_hash.as_deref().unwrap_or("(none)"));
        println!("JA4:      {}", info.ja4.as_deref().unwrap_or("(none)"));
        println!(
            "UA:       {}",
            info.user_agent.as_deref().unwrap_or("(none)")
        );

        Ok(Output::new().item(info))
    }
}

#[tokio::main]
async fn main() -> Result<(), KumoError> {
    tracing_subscriber::fmt()
        .with_env_filter("kumo=info")
        .init();

    CrawlEngine::builder()
        .stealth(StealthProfile::Chrome131)
        .concurrency(1)
        .store(StdoutStore)
        .run(StealthSpider)
        .await?;

    Ok(())
}