opencrabs 0.3.20

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Install with: cargo install opencrabs
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

//! Tests for WhatsApp state broadcasting (QR, connected, error channels).

use crate::channels::whatsapp::WhatsAppState;

#[test]
fn broadcast_qr_received_by_subscriber() {
    let state = WhatsAppState::new();
    let mut rx = state.subscribe_qr();
    state.broadcast_qr("test-qr-code");
    let received = rx.try_recv().unwrap();
    assert_eq!(received, "test-qr-code");
}

#[test]
fn broadcast_connected_received_by_subscriber() {
    let state = WhatsAppState::new();
    let mut rx = state.subscribe_connected();
    state.broadcast_connected();
    assert!(rx.try_recv().is_ok());
}

#[test]
fn broadcast_error_received_by_subscriber() {
    let state = WhatsAppState::new();
    let mut rx = state.subscribe_error();
    state.broadcast_error("session store failed");
    let received = rx.try_recv().unwrap();
    assert_eq!(received, "session store failed");
}

#[test]
fn multiple_qr_codes_received_in_order() {
    let state = WhatsAppState::new();
    let mut rx = state.subscribe_qr();
    state.broadcast_qr("qr-1");
    state.broadcast_qr("qr-2");
    state.broadcast_qr("qr-3");
    assert_eq!(rx.try_recv().unwrap(), "qr-1");
    assert_eq!(rx.try_recv().unwrap(), "qr-2");
    assert_eq!(rx.try_recv().unwrap(), "qr-3");
}

#[test]
fn no_subscriber_does_not_panic() {
    // Broadcasting without any subscriber should not panic
    let state = WhatsAppState::new();
    state.broadcast_qr("no one listening");
    state.broadcast_connected();
    state.broadcast_error("no one listening");
}

#[test]
fn error_channel_independent_of_qr_channel() {
    let state = WhatsAppState::new();
    let mut qr_rx = state.subscribe_qr();
    let mut err_rx = state.subscribe_error();

    state.broadcast_error("something broke");

    // QR channel should be empty
    assert!(qr_rx.try_recv().is_err());
    // Error channel should have the message
    assert_eq!(err_rx.try_recv().unwrap(), "something broke");
}

#[test]
fn late_subscriber_misses_earlier_messages() {
    let state = WhatsAppState::new();
    state.broadcast_qr("before-subscribe");
    let mut rx = state.subscribe_qr();
    assert!(rx.try_recv().is_err());
}