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
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160

//! Tests for rebuild outcome delivery (#304/#305): the background build's
//! completion and failure notices must reach whoever asked — a chat via the
//! cron `deliver_to` path, the TUI via the scheduler's session notifier.
//! Forum-topic origin rides the #1451 grammar (`telegram:chat:thread`),
//! captured automatically from the asking turn (#1457).

use crate::brain::tools::rebuild::rebuild_deliver_target;
use crate::db::Database;
use crate::db::repository::PendingRequestRepository;

// ── deliver_to mapping (#305) ────────────────────────────────────────────

#[test]
fn channel_chats_map_to_delivery_targets() {
    assert_eq!(
        rebuild_deliver_target("telegram", Some("123456789"), None).as_deref(),
        Some("telegram:123456789")
    );
    assert_eq!(
        rebuild_deliver_target("discord", Some("987654321"), None).as_deref(),
        Some("discord:987654321")
    );
    assert_eq!(
        rebuild_deliver_target("slack", Some("C0123ABC"), None).as_deref(),
        Some("slack:C0123ABC")
    );
}

#[test]
fn telegram_topic_origin_rides_the_1451_grammar() {
    // #1457: a rebuild fired from forum topic 249 must report back into
    // topic 249, not the chat default. Negative chat ids (supergroups) stay
    // intact — the scheduler's parse_telegram_target splits left-to-right.
    assert_eq!(
        rebuild_deliver_target("telegram", Some("-1004428873948"), Some("249")).as_deref(),
        Some("telegram:-1004428873948:249")
    );
    // Empty/whitespace thread degrades to the plain chat target, never to
    // "telegram:chat:" (which #1451's parser would reject loudly).
    assert_eq!(
        rebuild_deliver_target("telegram", Some("123"), Some("")).as_deref(),
        Some("telegram:123")
    );
    assert_eq!(
        rebuild_deliver_target("telegram", Some("123"), Some("  ")).as_deref(),
        Some("telegram:123")
    );
    // Discord/Slack ignore the thread component — no grammar for it there.
    assert_eq!(
        rebuild_deliver_target("discord", Some("987"), Some("249")).as_deref(),
        Some("discord:987")
    );
}

#[test]
fn tui_and_unsupported_channels_map_to_none() {
    // TUI has its own notifier; whatsapp has no cron delivery arm.
    assert!(rebuild_deliver_target("tui", None, None).is_none());
    assert!(rebuild_deliver_target("tui", Some("ignored"), None).is_none());
    assert!(rebuild_deliver_target("whatsapp", Some("15551234567"), None).is_none());
}

#[test]
fn missing_or_empty_chat_id_maps_to_none() {
    assert!(rebuild_deliver_target("telegram", None, None).is_none());
    assert!(rebuild_deliver_target("telegram", Some(""), None).is_none());
    assert!(rebuild_deliver_target("telegram", Some("   "), None).is_none());
}

// ── pending-request lookup (#305 source of channel/chat/thread) ─────────

#[tokio::test]
async fn find_latest_for_session_returns_the_current_turn_row() {
    let db = Database::connect_in_memory().await.unwrap();
    db.run_migrations().await.unwrap();
    let repo = PendingRequestRepository::new(db.pool().clone());

    let session_id = uuid::Uuid::new_v4();
    repo.insert(
        uuid::Uuid::new_v4(),
        session_id,
        "please rebuild yourself",
        "telegram",
        Some("123456789"),
        None,
        "user",
    )
    .await
    .unwrap();

    let row = repo
        .find_latest_for_session(session_id)
        .await
        .unwrap()
        .expect("in-flight row must be found");
    assert_eq!(row.channel, "telegram");
    assert_eq!(row.channel_chat_id.as_deref(), Some("123456789"));

    // End-to-end mapping: this is the deliver_to the tool will schedule.
    assert_eq!(
        rebuild_deliver_target(
            &row.channel,
            row.channel_chat_id.as_deref(),
            row.channel_thread_id.as_deref()
        )
        .as_deref(),
        Some("telegram:123456789")
    );
}

#[tokio::test]
async fn rebuild_from_a_topic_targets_that_topic_end_to_end() {
    // The #1457 occurrence: rebuild triggered in OC Dev (thread 249),
    // completion landed in General. The row now carries the topic and the
    // scheduled target names it — landing IN the topic is #1451's parser.
    let db = Database::connect_in_memory().await.unwrap();
    db.run_migrations().await.unwrap();
    let repo = PendingRequestRepository::new(db.pool().clone());

    let session_id = uuid::Uuid::new_v4();
    repo.insert(
        uuid::Uuid::new_v4(),
        session_id,
        "rebuild from OC Dev",
        "telegram",
        Some("-1004428873948"),
        Some("249"),
        "user",
    )
    .await
    .unwrap();

    let row = repo
        .find_latest_for_session(session_id)
        .await
        .unwrap()
        .expect("in-flight row must be found");
    assert_eq!(
        rebuild_deliver_target(
            &row.channel,
            row.channel_chat_id.as_deref(),
            row.channel_thread_id.as_deref()
        )
        .as_deref(),
        Some("telegram:-1004428873948:249")
    );
}

#[tokio::test]
async fn find_latest_for_session_none_when_no_row() {
    let db = Database::connect_in_memory().await.unwrap();
    db.run_migrations().await.unwrap();
    let repo = PendingRequestRepository::new(db.pool().clone());

    let row = repo
        .find_latest_for_session(uuid::Uuid::new_v4())
        .await
        .unwrap();
    assert!(row.is_none());
}