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
74
75
76
77
78
79
80
81
82
83
84
85
86
87

//! #1195 task 5 - worker purity via `allow_nested`.
//!
//! Pins the three manager-lookup semantics (restricted child denied,
//! unrestricted child allowed, unregistered session allowed) and the
//! plan-worker spawn JSON carrying `allow_nested: false` by default.

use crate::brain::tools::subagent::SubAgent;
use crate::brain::tools::subagent::SubAgentManager;
use tokio::sync::mpsc;
use uuid::Uuid;

fn make_agent(session_id: Uuid, allow_nested: bool) -> SubAgent {
    let (tx, _rx) = mpsc::unbounded_channel::<String>();
    SubAgent {
        allow_nested,
        input_tx: Some(tx),
        ..SubAgent::new(
            format!("agent-{}", Uuid::new_v4().simple()),
            "test".to_string(),
            session_id,
            Uuid::new_v4(),
        )
    }
}

#[test]
fn restricted_child_cannot_nest() {
    let mgr = SubAgentManager::default();
    let sid = Uuid::new_v4();
    mgr.insert(make_agent(sid, false));
    assert!(
        !mgr.nesting_allowed_for_session(sid),
        "a child spawned with allow_nested=false must be denied nesting"
    );
}

#[test]
fn unrestricted_child_may_nest() {
    let mgr = SubAgentManager::default();
    let sid = Uuid::new_v4();
    mgr.insert(make_agent(sid, true));
    assert!(
        mgr.nesting_allowed_for_session(sid),
        "allow_nested=true children keep nesting rights"
    );
}

#[test]
fn unknown_session_is_root_and_allowed() {
    let mgr = SubAgentManager::default();
    // No agents registered at all.
    assert!(mgr.nesting_allowed_for_session(Uuid::new_v4()));
    // Registered siblings do not affect an unrelated session id.
    let other = Uuid::new_v4();
    mgr.insert(make_agent(other, false));
    assert!(
        mgr.nesting_allowed_for_session(Uuid::new_v4()),
        "sessions without a manager entry are roots - always unrestricted"
    );
    assert!(!mgr.nesting_allowed_for_session(other));
}

#[test]
fn plan_worker_spawn_json_is_pure() {
    // The plan-worker spawn path must request a non-nesting child unless the
    // operator opted out via [agent] plan_worker_allow_nested (#1195). Pin
    // both halves of that wiring by their unique source strings.
    let src = include_str!("../brain/tools/plan_tool.rs");
    assert!(
        src.contains("\"allow_nested\": worker_nesting,"),
        "plan workers must pass allow_nested explicitly (worker purity, #1195)"
    );
    assert!(
        src.contains("c.agent.plan_worker_allow_nested"),
        "worker nesting must be gated on [agent] plan_worker_allow_nested"
    );
    // #1229 drift guard: plan workers are READ-ONLY by default (#1173 grant);
    // mutations stay with the parent unless [agent] plan_worker_allow_write.
    assert!(
        src.contains("\"read_only\": worker_read_only,"),
        "plan workers must pass read_only explicitly (drift guard)"
    );
    assert!(
        src.contains("c.agent.plan_worker_allow_write"),
        "worker read-only mode must be gated on [agent] plan_worker_allow_write"
    );
}