opencrabs 0.3.65

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

//! Newest-incoming-message tracking used by the flow-block re-stick (#451).
//!
//! The streaming edit loop relocates its open processing-log block to the
//! bottom when newer chatter has buried it. That decision reads the highest
//! incoming message id the handler has recorded for the chat. These tests pin
//! the per-chat max bookkeeping the re-stick relies on.

use crate::channels::telegram::TelegramState;

#[test]
fn newest_msg_id_starts_empty() {
    let state = TelegramState::new();
    assert_eq!(state.newest_incoming_msg_id(100), None);
}

#[test]
fn newest_msg_id_keeps_the_per_chat_maximum() {
    let state = TelegramState::new();
    state.note_incoming_msg(100, 10);
    state.note_incoming_msg(100, 25);
    state.note_incoming_msg(100, 25);
    assert_eq!(state.newest_incoming_msg_id(100), Some(25));

    // An out-of-order (lower) id must not lower the recorded max: Telegram ids
    // are monotonic per chat, so a smaller id is stale, never the newest.
    state.note_incoming_msg(100, 12);
    assert_eq!(state.newest_incoming_msg_id(100), Some(25));
}

#[test]
fn newest_msg_id_is_isolated_per_chat() {
    let state = TelegramState::new();
    state.note_incoming_msg(100, 50);
    state.note_incoming_msg(200, 7);
    assert_eq!(state.newest_incoming_msg_id(100), Some(50));
    assert_eq!(state.newest_incoming_msg_id(200), Some(7));
    assert_eq!(state.newest_incoming_msg_id(300), None);
}

#[test]
fn block_is_buried_only_when_a_newer_message_landed() {
    // Mirrors the restick gate: buried iff newest incoming id > block id.
    let state = TelegramState::new();
    let block_mid = 40;

    // Nothing newer than the block: not buried.
    state.note_incoming_msg(100, 40);
    assert!(state.newest_incoming_msg_id(100).unwrap() <= block_mid);

    // A message lands after the block: buried, re-stick fires.
    state.note_incoming_msg(100, 41);
    assert!(state.newest_incoming_msg_id(100).unwrap() > block_mid);
}