rho_coding_agent/app/
bootstrap.rs

1use std::io::{self, IsTerminal};
2
3use crate::{
4    agent::Agent,
5    cli::{Cli, Command},
6    credentials::OsCredentialStore,
7    herdr::HerdrReporter,
8    model::{build_provider, models_dev::cached_model_metadata, ModelError, UnavailableProvider},
9    tool::{ToolContext, ToolRegistry},
10    tools, update,
11};
12
13use super::{automation, cli_config, config_repository::ConfigRepository, interactive, login};
14
15pub async fn run(cli: Cli) -> anyhow::Result<()> {
16    cli_config::validate(&cli)?;
17    if matches!(cli.command, Some(Command::Update)) {
18        return update::run_update(env!("CARGO_PKG_VERSION")).await;
19    }
20    if let Some(Command::Login {
21        provider,
22        device_auth,
23    }) = &cli.command
24    {
25        return login::run(provider, *device_auth).await;
26    }
27
28    let config_path = cli.config.clone();
29    let config_repository = ConfigRepository::new(config_path.clone());
30    let mut config = config_repository.load()?;
31    let store = OsCredentialStore;
32    cli_config::refresh_model_cache(&cli, &store).await?;
33    if cli_config::apply_overrides(&mut config, &cli)? {
34        config_repository.save(&config)?;
35    }
36
37    validate_terminal_mode(&cli)?;
38    let automation_prompt = automation::prompt_for_command(&cli.command)?;
39    let update_notice = if cli.command.is_none() && config.check_for_updates {
40        update::update_notice(env!("CARGO_PKG_VERSION")).await
41    } else {
42        None
43    };
44
45    if config.provider == "anthropic"
46        && cached_model_metadata(&config.provider, &config.model).is_none()
47    {
48        let _ =
49            crate::model::models_dev::fetch_model_metadata(&config.provider, &config.model).await;
50    }
51
52    let provider_result = build_provider(&config.provider, &config.model, config.reasoning);
53    let missing_auth_error = provider_result
54        .as_ref()
55        .err()
56        .filter(|error| is_interactive_startup_unavailable_error(error))
57        .map(ToString::to_string);
58    let provider = match provider_result {
59        Ok(provider) => provider,
60        Err(error)
61            if automation_prompt.is_none() && is_interactive_startup_unavailable_error(&error) =>
62        {
63            Box::new(UnavailableProvider::new(error))
64        }
65        Err(error) => return Err(error.into()),
66    };
67    let registry = if cli.no_tools {
68        ToolRegistry::new()
69    } else {
70        tools::registry(&config)
71    };
72    let cwd = std::env::current_dir()?;
73    let context = ToolContext {
74        cwd: cwd.clone(),
75        max_output_bytes: config.max_output_bytes,
76    };
77    let herdr = HerdrReporter::from_env();
78    let mut agent = Agent::new(provider, registry, context);
79    if cli.no_system_prompt {
80        agent = agent.without_system_prompt();
81    }
82    agent.set_compaction_config((&config).into());
83    agent.set_context_window(
84        cached_model_metadata(&config.provider, &config.model)
85            .and_then(|metadata| metadata.display_context_window()),
86    );
87
88    match automation_prompt {
89        Some(prompt) => automation::run(&mut agent, prompt, &herdr).await,
90        None => {
91            interactive::run(
92                agent,
93                interactive::Startup {
94                    cli: &cli,
95                    config,
96                    config_repository,
97                    cwd,
98                    missing_auth_error,
99                    update_notice,
100                    herdr,
101                },
102            )
103            .await
104        }
105    }
106}
107
108fn validate_terminal_mode(cli: &Cli) -> anyhow::Result<()> {
109    if cli.command.is_none() && (!io::stdin().is_terminal() || !io::stdout().is_terminal()) {
110        anyhow::bail!(
111            "rho's default mode is the interactive TUI; use `rho run` for non-interactive automation"
112        );
113    }
114    Ok(())
115}
116
117fn is_interactive_startup_unavailable_error(error: &ModelError) -> bool {
118    matches!(
119        error,
120        ModelError::MissingApiKey
121            | ModelError::MissingCodexAuth
122            | ModelError::MissingAnthropicApiKey
123            | ModelError::MissingGithubCopilotAuth
124            | ModelError::Credentials(_)
125            | ModelError::UnsupportedProvider(_)
126    )
127}
128
129#[cfg(test)]
130#[path = "bootstrap_tests.rs"]
131mod tests;
rho_coding_agent/app/bootstrap.rs

rho_coding_agent/app/
bootstrap.rs
