use anyhow::{Context, Result}; use clap::Parser; use is_terminal::IsTerminal; use std::io::{stdin, Read}; #[derive(Parser, Debug)] #[command(author, version, about, long_about = None)] pub struct Cli { /// Select a LLM model #[clap(short, long)] pub model: Option, /// Use the system prompt #[clap(long)] pub prompt: Option, /// Select a role #[clap(short, long)] pub role: Option, /// Start or join a session #[clap(short = 's', long)] pub session: Option>, /// Ensure the session is empty #[clap(long)] pub empty_session: bool, /// Ensure the new conversation is saved to the session #[clap(long)] pub save_session: bool, /// Start a agent #[clap(short = 'a', long)] pub agent: Option, /// Set agent variables #[clap(long, value_names = ["NAME", "VALUE"], num_args = 2)] pub agent_variable: Vec, /// Start a RAG #[clap(long)] pub rag: Option, /// Rebuild the RAG to sync document changes #[clap(long)] pub rebuild_rag: bool, /// Execute a macro #[clap(long = "macro", value_name = "MACRO")] pub macro_name: Option, /// Serve the LLM API and WebAPP #[clap(long, value_name = "ADDRESS")] pub serve: Option>, /// Execute commands in natural language #[clap(short = 'e', long)] pub execute: bool, /// Output code only #[clap(short = 'c', long)] pub code: bool, /// Include files, directories, or URLs #[clap(short = 'f', long, value_name = "FILE")] pub file: Vec, /// Turn off stream mode #[clap(short = 'S', long)] pub no_stream: bool, /// Display the message without sending it #[clap(long)] pub dry_run: bool, /// Display information #[clap(long)] pub info: bool, /// Sync models updates #[clap(long)] pub sync_models: bool, /// List all available chat models #[clap(long)] pub list_models: bool, /// List all roles #[clap(long)] pub list_roles: bool, /// List all sessions #[clap(long)] pub list_sessions: bool, /// List all agents #[clap(long)] pub list_agents: bool, /// List all RAGs #[clap(long)] pub list_rags: bool, /// List all macros #[clap(long)] pub list_macros: bool, /// Input text #[clap(trailing_var_arg = true)] text: Vec, } impl Cli { pub fn text(&self) -> Result> { let mut stdin_text = String::new(); if !stdin().is_terminal() { let _ = stdin() .read_to_string(&mut stdin_text) .context("Invalid stdin pipe")?; }; match self.text.is_empty() { true => { if stdin_text.is_empty() { Ok(None) } else { Ok(Some(stdin_text)) } } false => { if self.macro_name.is_some() { let text = self .text .iter() .map(|v| shell_words::quote(v)) .collect::>() .join(" "); if stdin_text.is_empty() { Ok(Some(text)) } else { Ok(Some(format!("{text} -- {stdin_text}"))) } } else { let text = self.text.join(" "); if stdin_text.is_empty() { Ok(Some(text)) } else { Ok(Some(format!("{text}\n{stdin_text}"))) } } } } } }