malvin 0.2.5

Non-interactive research and coding agent
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
101
102
103
104
105
106
107
108
109
110
111
112

use crate::agent_backend::AgentBackend;

pub(crate) struct RouterInitialCoderPrompt<'a> {
    pub client: &'a mut AgentBackend,
    pub prompt: &'a str,
    pub log_path: &'a std::path::Path,
    pub stdout_bracket_label: &'a str,
    pub log_who: &'a str,
}

pub(crate) async fn run_router_initial_coder_prompt(
    input: RouterInitialCoderPrompt<'_>,
) -> Result<(), String> {
    input
        .client
        .run_coder_prompt(
            input.prompt,
            input.log_path,
            input.log_who,
            crate::acp::CoderPromptOptions {
                llm_phase: Some(crate::run_timing::TimingPhase::Implement),
                do_trace_split: None,
                stdout_bracket_label: Some(input.stdout_bracket_label),
                append_trace: true,
                ..Default::default()
            },
        )
        .await
        .map_err(|e| e.to_string())
}

pub(crate) async fn run_router_b_coder_prompt(
    client: &mut AgentBackend,
    prompt: &str,
    log_path: &std::path::Path,
    stdout_bracket_label: &str,
) -> Result<(), String> {
    client
        .run_coder_prompt(
            prompt,
            log_path,
            "router_b",
            crate::acp::CoderPromptOptions {
                llm_phase: Some(crate::run_timing::TimingPhase::Implement),
                do_trace_split: None,
                stdout_bracket_label: Some(stdout_bracket_label),
                append_trace: true,
                ..Default::default()
            },
        )
        .await
        .map_err(|e| e.to_string())
}

pub(crate) async fn run_router_summarize_coder_prompt(
    client: &mut AgentBackend,
    prompt: &str,
    log_path: &std::path::Path,
) -> Result<(), String> {
    client
        .run_coder_prompt(
            prompt,
            log_path,
            "router_summarize",
            crate::acp::CoderPromptOptions {
                llm_phase: Some(crate::run_timing::TimingPhase::Implement),
                do_trace_split: None,
                stdout_bracket_label: Some("router_summarize.md"),
                append_trace: true,
                ..Default::default()
            },
        )
        .await
        .map_err(|e| e.to_string())
}

#[cfg(test)]
mod kiss_cov_gate_refs {
    use super::*;
    use crate::prompts::{header_prompt_file, kpop_common_prompt_file, router_a_prompt_file};

    #[test]
    fn kiss_cov_unit_names() {
        let _ = run_router_initial_coder_prompt;
        let _: Option<RouterInitialCoderPrompt<'_>> = None;
        let _ = run_router_b_coder_prompt;
        let _ = run_router_summarize_coder_prompt;
        let _ = header_prompt_file;
        let _ = router_a_prompt_file;
        let _ = kpop_common_prompt_file;
        let _ = crate::agent_backend::header_prompt_options_for_test;
    }

    #[test]
    fn router_header_retries_use_fresh_agent() {
        let opts = crate::agent_backend::header_prompt_options_for_test();
        assert!(
            opts.fresh_agent_on_retry,
            "spawn header must not re-send header.md into the same agent on ACP retry"
        );
        assert_eq!(opts.stdout_bracket_label, Some("header.md"));
    }

    #[test]
    fn router_coder_stdout_labels_match_active_prompt_files() {
        assert_eq!(header_prompt_file(), "header.md");
        assert_eq!(router_a_prompt_file(false), "router_a.md");
        assert_eq!(router_a_prompt_file(true), "router_a_no_kpop.md");
        assert_eq!(kpop_common_prompt_file(false), "kpop_common.md");
        assert_eq!(kpop_common_prompt_file(true), "kpop_common_no_kpop.md");
    }
}