codescout 0.14.0

High-performance coding agent toolkit MCP server
Documentation 
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

//! Rust-specific mux coherence test.
//!
//! Two Agents share one mux. A writes a new function; B must see it.
//! The bug being regression-tested: before mux, B's direct rust-analyzer
//! still saw the pre-write file because A's didChange only went to A's LSP.

use crate::lsp::manager::LspManager;

#[tokio::test]
#[ignore = "requires rust-analyzer on PATH; gated by CI job"]
async fn two_agents_coherent_after_edit() {
    let fixture =
        std::path::PathBuf::from(env!("CARGO_MANIFEST_DIR")).join("tests/fixtures/lsp-mux/rust");
    let (_td, root) = super::test_support::stage_fixture(&fixture);

    // Each agent has its own LspManager, but both point at the same workspace.
    // With mux=true, the first `get_or_start` spawns the mux process and both
    // connect to the same underlying rust-analyzer instance via a Unix socket.
    let mgr_a = LspManager::new();
    let mgr_b = LspManager::new();

    let ca = mgr_a
        .get_or_start("rust", &root, Some(true))
        .await
        .expect("A get_or_start");
    let cb = mgr_b
        .get_or_start("rust", &root, Some(true))
        .await
        .expect("B get_or_start");

    // 1. Both clients open the target file so the LSP tracks it.
    let target = root.join("src/lib.rs");
    ca.did_change(&target).await.expect("A did_change initial");
    cb.did_change(&target).await.expect("B did_change initial");

    // 2. Baseline: B sees original_symbol only (fresh_symbol does not exist yet).
    let syms_before = cb
        .document_symbols(&target, "rust")
        .await
        .expect("B document_symbols before");
    let names_before: Vec<_> = syms_before.iter().map(|s| s.name.clone()).collect();
    assert!(
        !names_before.iter().any(|n| n == "fresh_symbol"),
        "fresh_symbol should not exist yet: {:?}",
        names_before
    );

    // 3. A writes a new symbol to disk.
    let updated = "pub fn original_symbol() -> &'static str { \"original\" }\n\
                   pub fn fresh_symbol() -> &'static str { \"fresh\" }\n";
    std::fs::write(&target, updated).unwrap();

    // 4. Before notifying: B's view must still be stale (three-query sandwich —
    //    proves we are not observing eager re-indexing rather than mux coherence).
    let syms_stale = cb
        .document_symbols(&target, "rust")
        .await
        .expect("B document_symbols stale");
    let names_stale: Vec<_> = syms_stale.iter().map(|s| s.name.clone()).collect();
    assert!(
        !names_stale.iter().any(|n| n == "fresh_symbol"),
        "B should not see fresh_symbol before notification: {:?}",
        names_stale
    );

    // 5. A notifies the mux; B must now see fresh_symbol.
    //    A's didChange reaches the shared rust-analyzer, and B's documentSymbol
    //    request reflects the updated index.
    mgr_a.notify_file_changed(&target).await;

    let syms_after = cb
        .document_symbols(&target, "rust")
        .await
        .expect("B document_symbols after");
    let names_after: Vec<_> = syms_after.iter().map(|s| s.name.clone()).collect();
    assert!(
        names_after.iter().any(|n| n == "fresh_symbol"),
        "Agent B's view stale after notification: {:?}",
        names_after
    );

    mgr_a.shutdown_all().await;
    mgr_b.shutdown_all().await;
}