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

//! A replayed turn sees the follow-up the user queued before the restart
//! (#1401).
//!
//! The interrupted Slack turn had a mid-turn user message injected seconds
//! before the restart, persisted as a user row and followed by the empty
//! assistant placeholder the killed turn left behind. Replay rebuilds the
//! context from the database, so the follow-up must survive that rebuild
//! and the empty placeholder must not reach the provider.

use uuid::Uuid;

use crate::brain::agent::context::AgentContext;
use crate::brain::provider::{ContentBlock, Role};
use crate::db::models::Message as DbMessage;

fn row(session: Uuid, role: &str, content: &str, seq: i32) -> DbMessage {
    DbMessage::new(session, role.to_string(), content.to_string(), seq)
}

#[test]
fn queued_follow_up_survives_the_rebuild_and_the_empty_placeholder_does_not() {
    let session = Uuid::new_v4();
    let rows = vec![
        row(session, "user", "card 394 is still not fixed", 1),
        row(session, "assistant", "Checking the v2 docs now.", 2),
        row(
            session,
            "user",
            "dev server has the latest code by the way",
            3,
        ),
        // The killed turn's assistant row: created at turn start, never filled.
        row(session, "assistant", "", 4),
    ];
    let context = AgentContext::from_db_messages(session, rows, 100_000);
    let messages = &context.messages;
    assert_eq!(messages.len(), 3, "the empty placeholder must be dropped");
    let last = messages.last().expect("three messages");
    assert_eq!(last.role, Role::User);
    assert!(
        matches!(&last.content[..], [ContentBlock::Text { text }] if text == "dev server has the latest code by the way"),
        "the queued follow-up must be the last thing the replayed model reads: {:?}",
        last.content
    );
    assert!(
        messages.iter().all(|m| m
            .content
            .iter()
            .all(|b| !matches!(b, ContentBlock::Text { text } if text.is_empty()))),
        "no empty text block may reach the provider"
    );
}