opencrabs 0.5.1

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Recommended: the 40MB prebuilt binary for macOS, Linux and Windows: https://github.com/adolfousier/opencrabs/releases
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
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

//! #1189 — CDP event ring buffer: bounded retention, drain-once
//! surfacing, event-to-summary mapping, and the `recent_events:` line
//! format appended to browser tool results.

use crate::brain::tools::browser::events::{EventLog, RING_CAPACITY, append_line, map_cdp_event};
use chromiumoxide::cdp::CdpEvent;
use chromiumoxide::cdp::browser_protocol as bp;
use chromiumoxide::cdp::browser_protocol::page::DialogType;

fn dialog(message: &str, kind: DialogType) -> CdpEvent {
    CdpEvent::PageJavascriptDialogOpening(bp::page::EventJavascriptDialogOpening {
        url: "https://example.com".into(),
        frame_id: Default::default(),
        message: message.into(),
        r#type: kind,
        has_browser_handler: false,
        default_prompt: None,
    })
}

#[test]
fn ring_is_bounded_at_capacity() {
    let log = EventLog::default();
    for i in 0..(RING_CAPACITY + 7) {
        log.push(format!("event {i}"));
    }
    assert_eq!(log.len(), RING_CAPACITY);
    // Oldest evicted: first drained entry is event 7, not event 0.
    let drained = log.take();
    assert!(
        drained[0].summary.contains("event 7"),
        "oldest should be evicted"
    );
    assert!(
        drained
            .last()
            .unwrap()
            .summary
            .contains(&format!("event {}", RING_CAPACITY + 6))
    );
}

#[test]
fn drain_surfaces_exactly_once() {
    let log = EventLog::default();
    log.push("js-dialog opened (alert)".into());
    let first = log.take_formatted();
    assert!(first.is_some());
    assert!(first.unwrap().starts_with("recent_events: ["));
    // Second drain: nothing — cleared after reporting (spec).
    assert!(log.take_formatted().is_none());
}

#[test]
fn dialog_event_maps_with_kind_and_truncated_message() {
    let ev = dialog(
        "Are you sure you want to delete every single file?",
        DialogType::Confirm,
    );
    let s = map_cdp_event(&ev).expect("dialog should map");
    assert!(s.contains("js-dialog opened (confirm)"), "kind label: {s}");
    assert!(s.contains('…'), "long message truncated: {s}");
    assert!(
        !s.contains("every single file"),
        "full message must not survive: {s}"
    );
}

#[test]
fn download_event_maps_with_filename() {
    let ev = CdpEvent::BrowserDownloadWillBegin(bp::browser::EventDownloadWillBegin {
        frame_id: Default::default(),
        guid: "g".into(),
        url: "https://example.com/f/invoice.pdf".into(),
        suggested_filename: "invoice.pdf".into(),
    });
    let s = map_cdp_event(&ev).expect("download should map");
    assert_eq!(s, "download started: invoice.pdf");
}

#[test]
fn worker_target_creation_is_ignored_page_target_surfaces() {
    let worker = CdpEvent::TargetTargetCreated(Box::new(bp::target::EventTargetCreated {
        target_info: bp::target::TargetInfo::builder()
            .target_id("00000000000000000000000000000001".to_string())
            .r#type("worker")
            .title("sw")
            .attached(true)
            .can_access_opener(false)
            .url("https://example.com/sw.js")
            .build()
            .expect("builder"),
    }));
    assert!(map_cdp_event(&worker).is_none(), "worker targets are noise");

    let page = CdpEvent::TargetTargetCreated(Box::new(bp::target::EventTargetCreated {
        target_info: bp::target::TargetInfo::builder()
            .target_id("00000000000000000000000000000001".to_string())
            .r#type("page")
            .title("popup")
            .attached(true)
            .can_access_opener(false)
            .url("https://example.com/popup")
            .build()
            .expect("builder"),
    }));
    assert!(map_cdp_event(&page).is_some(), "page popups surface");
}

#[test]
fn append_line_attaches_and_passthrough() {
    assert_eq!(append_line("Clicked: #go".into(), None), "Clicked: #go");
    let with = append_line(
        "Clicked: #go".into(),
        Some("recent_events: [21:14:03 js-dialog opened (alert)]".into()),
    );
    assert!(with.starts_with("Clicked: #go\n\nrecent_events: ["));
}