opencrabs 0.3.75

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

//! 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());
}

/// #731: the session→JID map lets a finished background task resume the right
/// chat. Unknown sessions resolve to None; the latest registration wins.
#[tokio::test]
async fn session_jid_registers_and_resolves() {
    let state = WhatsAppState::new();
    let sid = uuid::Uuid::new_v4();
    assert!(
        state.session_jid(sid).await.is_none(),
        "an unregistered session has no jid"
    );
    state
        .register_session_jid(sid, "123@s.whatsapp.net".to_string())
        .await;
    assert_eq!(
        state.session_jid(sid).await.as_deref(),
        Some("123@s.whatsapp.net")
    );
    // The chat can move; the latest registration wins.
    state
        .register_session_jid(sid, "456@s.whatsapp.net".to_string())
        .await;
    assert_eq!(
        state.session_jid(sid).await.as_deref(),
        Some("456@s.whatsapp.net")
    );
}