dk-protocol 0.3.0

dkod gRPC protocol definitions and server/client implementations
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

use dk_engine::workspace::session_manager::SessionInfo;
use uuid::Uuid;

#[test]
fn test_agent_name_auto_assigned_when_empty() {
    // When agent_name is empty, the connect handler auto-assigns "agent-N".
    // We test the logic branch directly:
    let provided = "";
    let agent_name = if provided.is_empty() {
        "agent-1".to_string()
    } else {
        provided.to_string()
    };
    assert_eq!(agent_name, "agent-1");
}

#[test]
fn test_agent_name_preserved_when_provided() {
    // When an agent provides a name, it should be used as-is.
    let provided = "feature-bot";
    let agent_name = if provided.is_empty() {
        "agent-1".to_string()
    } else {
        provided.to_string()
    };
    assert_eq!(agent_name, "feature-bot");
}

#[test]
fn test_agent_names_increment_per_repo() {
    // WorkspaceManager::next_agent_name uses per-repo AtomicU32 counters.
    // The unit test in session_manager.rs covers the full counter logic.
    // Here we verify the format convention.
    for n in 1..=5 {
        let name = format!("agent-{n}");
        assert!(name.starts_with("agent-"));
        assert_eq!(name, format!("agent-{}", n));
    }
}

#[test]
fn test_agent_name_in_session_info() {
    let info = SessionInfo {
        session_id: Uuid::new_v4(),
        agent_id: "claude-code".to_string(),
        agent_name: "agent-1".to_string(),
        intent: "refactor".to_string(),
        repo_id: Uuid::new_v4(),
        changeset_id: Uuid::new_v4(),
        state: "active".to_string(),
        elapsed_secs: 0,
    };

    assert_eq!(info.agent_name, "agent-1");

    let json = serde_json::to_value(&info).unwrap();
    assert_eq!(json["agent_name"], "agent-1");
    assert_eq!(json["agent_id"], "claude-code");
}

#[tokio::test]
async fn test_agent_name_on_session_workspace() {
    use dk_engine::workspace::session_workspace::{SessionWorkspace, WorkspaceMode};

    let ws = SessionWorkspace::new_test(
        Uuid::new_v4(),
        Uuid::new_v4(),
        "claude-code".to_string(),
        "fix bugs".to_string(),
        "abc123".to_string(),
        WorkspaceMode::Ephemeral,
    );

    // new_test defaults agent_name to empty string
    assert_eq!(ws.agent_name, "");
}

#[test]
fn test_source_branch_uses_intent_and_agent_name() {
    // Branch naming: {intent_slug}/{agent_name}
    fn slugify(intent: &str) -> String {
        let s: String = intent
            .to_lowercase()
            .chars()
            .map(|c| if c.is_alphanumeric() || c == '-' { c } else { '-' })
            .collect::<String>()
            .trim_matches('-')
            .to_string();
        if s.len() > 50 { s[..50].trim_end_matches('-').to_string() } else { s }
    }

    assert_eq!(
        format!("{}/{}", slugify("Fix UI bugs"), "feature-bot"),
        "fix-ui-bugs/feature-bot"
    );
    assert_eq!(
        format!("{}/{}", slugify("Add comments endpoint"), "agent-3"),
        "add-comments-endpoint/agent-3"
    );
}