kumo 0.2.5

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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

use kumo::error::{KumoError, KumoErrorKind};

#[cfg(feature = "persistence")]
use kumo::frontier::FileFrontier;

#[test]
fn error_helpers_preserve_context_in_display() {
    let parse = KumoError::parse_msg("bad selector");
    assert_eq!(
        parse.to_string(),
        "parse error - bad selector: bad selector"
    );

    let store = KumoError::store_msg("queue is invalid");
    assert_eq!(
        store.to_string(),
        "store error - queue is invalid: queue is invalid"
    );
}

#[test]
fn error_helpers_preserve_source_chain() {
    let source = std::io::Error::other("disk full");
    let err = KumoError::store("write queue", source);

    assert_eq!(err.to_string(), "store error - write queue: disk full");
    assert_eq!(
        std::error::Error::source(&err).map(ToString::to_string),
        Some("disk full".to_string())
    );
}

#[test]
fn error_kind_classifies_every_variant() {
    assert_eq!(
        KumoError::parse_msg("bad selector").kind(),
        KumoErrorKind::Parse
    );
    assert_eq!(
        KumoError::store_msg("bad disk").kind(),
        KumoErrorKind::Store
    );
    assert_eq!(
        KumoError::invalid_url("not a url").kind(),
        KumoErrorKind::InvalidUrl
    );
    assert_eq!(
        KumoError::DepthExceeded.kind(),
        KumoErrorKind::DepthExceeded
    );
    assert_eq!(
        KumoError::DomainNotAllowed("example.com".into()).kind(),
        KumoErrorKind::DomainNotAllowed
    );
    assert_eq!(KumoError::llm("bad json").kind(), KumoErrorKind::Llm);
    assert_eq!(
        KumoError::browser("browser closed").kind(),
        KumoErrorKind::Browser
    );
    assert_eq!(
        KumoError::HttpStatus {
            status: 503,
            url: "https://example.com".into(),
        }
        .kind(),
        KumoErrorKind::HttpStatus
    );
}

#[test]
fn ergonomic_error_constructors_match_variants() {
    assert!(matches!(
        KumoError::invalid_url("not a url"),
        KumoError::InvalidUrl(value) if value == "not a url"
    ));
    assert!(matches!(
        KumoError::llm("model failed"),
        KumoError::Llm(value) if value == "model failed"
    ));
    assert!(matches!(
        KumoError::browser("page crashed"),
        KumoError::Browser(value) if value == "page crashed"
    ));
}

#[cfg(feature = "persistence")]
#[test]
fn file_frontier_reports_malformed_queue_as_store_error() {
    let dir = tempfile::tempdir().unwrap();
    std::fs::write(dir.path().join("queue.json"), r#"{"not":"a queue"}"#).unwrap();

    let err = FileFrontier::open(dir.path()).unwrap_err();
    assert!(matches!(err, KumoError::Store { .. }));
    assert!(
        err.to_string().contains("parse queue.json"),
        "unexpected error: {err}"
    );
}