magi-code 0.64.0

Repository-aware CLI coding agent for terminal work
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
101
102

use crate::{
    config::{EffectiveConfig, Settings},
    output::{OutputMode, output_mode},
    sessions::Session,
};
use anyhow::Result;
use std::{
    io::{self, Write},
    path::Path,
};

pub(super) fn run_print_mode(
    config: &EffectiveConfig,
    instructions: &[crate::instructions::InstructionFile],
    skills: &crate::skills::SkillDiscovery,
    settings: &Settings,
    prompt: &[String],
    session: Option<&Session>,
    cwd: &Path,
) -> Result<()> {
    let prompt = prompt.join(" ");
    if prompt.trim().is_empty() {
        anyhow::bail!("print mode requires a prompt");
    }
    if !config.auth_state().is_ready() {
        let error = config.missing_auth_error();
        super::diagnostics::record_error(session, cwd, &error.to_string())?;
        return Err(error.into());
    }
    let stdout = io::stdout();
    let mut writer = stdout.lock();
    let mode = output_mode(false, !config.no_color, false);
    run_print_mode_streaming_with_mode(&mut writer, mode, session, cwd, |session, cwd, sink| {
        crate::agent::runner::run_provider_once_streaming(
            config,
            instructions,
            skills,
            crate::agent::runner::ProviderRunOptions {
                settings: Some(settings.clone()),
                prompt: &prompt,
                session,
                cwd,
                output_sink: Some(sink),
                selected_primary_agent: None,
                cancellation: None,
                session_title_notifier: None,
                invocation_mode: crate::output::InvocationMode::Print,
                disabled_tools: None,
                disabled_subagent_profiles: None,
                subagent_profile_discovery: None,
                mcp: None,
            },
        )
    })
    .map(|_| ())
}

#[cfg(test)]
pub(super) fn run_print_mode_streaming_with_runner<W: Write>(
    writer: &mut W,
    session: Option<&Session>,
    cwd: &Path,
    runner: impl FnOnce(
        Option<&Session>,
        &Path,
        &mut dyn crate::agent::AgentOutputSink,
    ) -> Result<crate::agent::AgentRunOutput>,
) -> Result<crate::agent::AgentRunOutput> {
    run_print_mode_streaming_with_mode(writer, OutputMode::Plain, session, cwd, runner)
}

pub(super) fn run_print_mode_streaming_with_mode<W: Write>(
    writer: &mut W,
    mode: OutputMode,
    session: Option<&Session>,
    cwd: &Path,
    runner: impl FnOnce(
        Option<&Session>,
        &Path,
        &mut dyn crate::agent::AgentOutputSink,
    ) -> Result<crate::agent::AgentRunOutput>,
) -> Result<crate::agent::AgentRunOutput> {
    let mut sink = super::CliOutputSink::with_mode(writer, mode);
    let result =
        run_print_mode_with_runner(session, cwd, |session, cwd| runner(session, cwd, &mut sink));
    sink.finish_line()?;
    result
}

pub(super) fn run_print_mode_with_runner(
    session: Option<&Session>,
    cwd: &Path,
    runner: impl FnOnce(Option<&Session>, &Path) -> Result<crate::agent::AgentRunOutput>,
) -> Result<crate::agent::AgentRunOutput> {
    match runner(session, cwd) {
        Ok(output) => Ok(output),
        Err(error) => {
            super::diagnostics::record_error(session, cwd, &error.to_string())?;
            Err(error)
        }
    }
}