opencrabs 0.5.4

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
119
120
121
122
123

//! Broadcast safety rails (#1485).

use std::time::Duration;

use crate::channels::whatsapp::broadcast::{
    DEFAULT_DELAY_SECONDS, STATUS_BACKGROUND_ARGB, burst_floor, delay, is_allowed, normalize,
    partition, target_jid,
};

#[test]
fn normalise_strips_formatting_and_the_server() {
    assert_eq!(normalize("+1 (555) 123-4567"), "15551234567");
    assert_eq!(normalize("+15551234567"), "15551234567");
    assert_eq!(normalize("15551234567@s.whatsapp.net"), "15551234567");
}

#[test]
fn an_allowlist_matches_across_formatting() {
    // An allowlist that only matched one spelling would be an allowlist in
    // name only.
    let allow = vec!["+1 555 123 4567".to_string()];
    assert!(is_allowed("15551234567@s.whatsapp.net", &allow));
    assert!(is_allowed("+15551234567", &allow));
}

#[test]
fn an_empty_allowlist_allows_nobody() {
    // The opposite of the usual "empty means everyone", on purpose: an
    // unconfigured install must not be one tool call from messaging strangers.
    assert!(!is_allowed("+15551234567", &[]));
}

#[test]
fn a_number_not_on_the_list_is_refused() {
    let allow = vec!["+15551234567".to_string()];
    assert!(!is_allowed("+15559999999", &allow));
}

#[test]
fn a_target_with_no_digits_is_refused() {
    let allow = vec!["+15551234567".to_string()];
    assert!(!is_allowed("not-a-number", &allow));
    assert!(!is_allowed("", &allow));
}

#[test]
fn the_default_pacing_is_the_conservative_one() {
    assert_eq!(delay(None), Duration::from_secs(DEFAULT_DELAY_SECONDS));
}

#[test]
fn a_configured_delay_is_honoured() {
    assert_eq!(delay(Some(30)), Duration::from_secs(30));
}

#[test]
fn a_zero_delay_does_not_disable_pacing() {
    // Turning the rail off is not a knob this feature offers: a config typo
    // must not become a mass-send.
    assert_eq!(delay(Some(0)), Duration::from_secs(DEFAULT_DELAY_SECONDS));
}

#[test]
fn a_burst_costs_at_least_n_minus_one_delays() {
    let d = Duration::from_secs(5);
    assert_eq!(burst_floor(0, d), Duration::ZERO);
    assert_eq!(burst_floor(1, d), Duration::ZERO);
    assert_eq!(burst_floor(10, d), Duration::from_secs(45));
}

#[test]
fn partition_names_the_refused_numbers() {
    let allow = vec!["+15551234567".to_string()];
    let targets = vec![
        "+15551234567".to_string(),
        "+15559999999".to_string(),
        "15551234567@s.whatsapp.net".to_string(),
    ];
    let (ok, refused) = partition(&targets, &allow);
    assert_eq!(ok.len(), 2);
    assert_eq!(refused, vec![&"+15559999999".to_string()]);
}

#[test]
fn an_allowlist_entry_becomes_a_usable_jid() {
    let jid = target_jid("+1 (555) 123-4567").expect("parses");
    assert_eq!(jid.to_string(), "15551234567@s.whatsapp.net");
}

#[test]
fn a_jid_shaped_entry_round_trips() {
    let jid = target_jid("15551234567@s.whatsapp.net").expect("parses");
    assert_eq!(jid.to_string(), "15551234567@s.whatsapp.net");
}

#[test]
fn an_entry_with_no_digits_yields_no_jid() {
    // A config typo must surface as a refusal naming the entry, not as a
    // silently skipped recipient.
    assert!(target_jid("not-a-number").is_none());
    assert!(target_jid("").is_none());
}

#[test]
fn the_status_background_is_opaque() {
    // A status with a transparent background renders as a black card on some
    // clients. The alpha byte must be full.
    assert_eq!(STATUS_BACKGROUND_ARGB >> 24, 0xFF);
}

#[test]
fn the_shipped_config_default_broadcasts_to_nobody() {
    // The rail that matters most: an install that never touched the config
    // must not be one tool call away from messaging strangers.
    let cfg = crate::config::WaBroadcastConfig::default();
    assert!(cfg.allowed_targets.is_empty());
    assert!(!is_allowed("+15551234567", &cfg.allowed_targets));
    assert_eq!(
        delay(cfg.min_delay_seconds),
        Duration::from_secs(DEFAULT_DELAY_SECONDS),
        "an unset delay must still pace"
    );
}