opencrabs 0.5.0

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

//! #1368: `agent --session <prefix|uuid>` resumes a session instead of
//! silently discarding the flag, and every output format echoes the id so
//! scripts can close the loop without scraping `session list`.
//!
//! These tests pin the resolve-or-create seam shared by `cmd_run` and
//! `cmd_agent_interactive` (`resolve_or_create_session`). The pure prefix
//! rules (case-insensitivity, ambiguity candidates) are already pinned by
//! `cli_session_id_prefix_test` (#1340/#1366) and are not restated here.

use crate::cli::session_resolve::resolve_or_create_session;
use crate::db::Database;
use crate::services::{ServiceContext, SessionService};

async fn service() -> SessionService {
    let db = Database::connect_in_memory().await.unwrap();
    db.run_migrations().await.unwrap();
    SessionService::new(ServiceContext::new(db.pool().clone()))
}

#[tokio::test]
async fn none_creates_fresh_session_with_default_title() {
    let svc = service().await;
    let session = resolve_or_create_session(&svc, None, "CLI Run")
        .await
        .unwrap();
    assert_eq!(session.title.as_deref(), Some("CLI Run"));
}

#[tokio::test]
async fn eight_char_prefix_resumes_the_matching_session() {
    let svc = service().await;
    let target = svc
        .create_session(Some("orchestrator".to_string()))
        .await
        .unwrap();
    let _other = svc
        .create_session(Some("worker".to_string()))
        .await
        .unwrap();
    // Exactly what a user copies from `session list` or the json output.
    let prefix = &target.id.to_string()[..8];
    let resumed = resolve_or_create_session(&svc, Some(prefix), "CLI Run")
        .await
        .unwrap();
    assert_eq!(resumed.id, target.id, "prefix must resume, not create");
}

#[tokio::test]
async fn unknown_prefix_errors_without_guessing() {
    let svc = service().await;
    let err = resolve_or_create_session(&svc, Some("deadbeef"), "CLI Run")
        .await
        .unwrap_err()
        .to_string();
    assert!(
        err.contains("no session id starts with 'deadbeef'"),
        "got: {err}"
    );
}

#[tokio::test]
async fn full_uuid_absent_from_db_is_reported_not_found() {
    // Fast-path parity with `session get` (#1340): a well-formed UUID the
    // DB does not know surfaces "session not found" rather than a prefix
    // error — the caller learns the truth about the id they supplied.
    let svc = service().await;
    let stranger = uuid::Uuid::new_v4();
    let err = resolve_or_create_session(&svc, Some(&stranger.to_string()), "CLI Run")
        .await
        .unwrap_err()
        .to_string();
    assert!(err.contains("session not found"), "got: {err}");
}