basemind 0.24.0

Full AI context layer over MCP — tree-sitter code-map, document RAG (PDF/Office/HTML/email + OCR + reranker), shared agent memory, on-demand web crawl, git history + blame + per-symbol diff. 300+ languages, 10+ coding-agent harnesses, content-addressed Fjall + LanceDB.
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

//! Lifecycle tests split from `daemon_tests.rs` to keep both source files under the line cap.

use super::*;

#[tokio::test]
async fn stop_refuses_to_disconnect_another_live_link() {
    let (_dir, broker) = temp_broker();
    let (tx, _rx) = mpsc::channel(8);
    let mut session = Session::default();
    let active_relay = broker
        .try_register_relay()
        .await
        .expect("active broker accepts a relay");
    let stop_client = broker.register_link();

    let refused = broker.handle(CommsRequest::Stop, &mut session, &tx).await;
    assert!(
        matches!(refused, CommsResponse::Error { ref code, .. } if code == "daemon_busy"),
        "a stop request must not tear down another agent's live relay: {refused:?}"
    );
    assert_eq!(broker.state().await, LifecycleState::Starting);

    drop(active_relay);
    let accepted = broker.handle(CommsRequest::Stop, &mut session, &tx).await;
    assert_eq!(accepted, CommsResponse::Ok);
    assert_eq!(broker.state().await, LifecycleState::Draining);
    drop(stop_client);
}

#[tokio::test]
async fn stop_refuses_to_disconnect_an_active_http_connection() {
    let (_dir, broker) = temp_broker();
    let (tx, _rx) = mpsc::channel(8);
    let mut session = Session::default();
    let active_http = broker
        .try_begin_http_connection()
        .await
        .expect("active broker accepts an HTTP connection");

    let refused = broker.handle(CommsRequest::Stop, &mut session, &tx).await;
    assert!(
        matches!(refused, CommsResponse::Error { ref code, .. } if code == "daemon_busy"),
        "a stop request must not tear down an active HTTP connection: {refused:?}"
    );
    assert_eq!(broker.state().await, LifecycleState::Starting);

    drop(active_http);
    let accepted = broker.handle(CommsRequest::Stop, &mut session, &tx).await;
    assert_eq!(accepted, CommsResponse::Ok);
    assert_eq!(broker.state().await, LifecycleState::Draining);
}