malvin 0.2.4

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

use crate::agent_backend::AgentBackend;
use crate::artifacts::RunArtifacts;
use crate::cli::one_shot_session::OneShotCoderGuard;
use crate::run_timing::TimingPhase;

use super::do_flow_prompt;

pub(super) async fn run_do_coder_prompt(
    client: &mut AgentBackend,
    artifacts: &RunArtifacts,
    coder: &do_flow_prompt::DoCoderRun,
) -> Result<(), String> {
    let (ref header, ref user) = coder.header_user_for_trace;
    client
        .run_coder_prompt(
            &coder.combined,
            &artifacts.log_path("do"),
            "do",
            crate::acp::CoderPromptOptions {
                llm_phase: Some(TimingPhase::Implement),
                do_trace_split: Some((header.as_str(), user.as_str())),
                stdout_bracket_label: None,
                ..Default::default()
            },
        )
        .await
        .map_err(|e| e.to_string())
}

pub(super) async fn run_do_acp(
    client: &mut AgentBackend,
    artifacts: &RunArtifacts,
    coder: do_flow_prompt::DoCoderRun,
) -> Result<(), String> {
    let guard = OneShotCoderGuard::begin(client, artifacts, "do").await?;
    let run_res = run_do_coder_prompt(client, artifacts, &coder).await;
    guard.finish(client, run_res).await
}