use std::collections::{BTreeMap, HashSet};
use std::path::{Path, PathBuf};
use serde::{Deserialize, Serialize};
use crate::anthropic::creds::CredsTarget;
use crate::cache::Cache;
use crate::error::{AppError, Result};
use crate::vendor::VendorId;
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(default, deny_unknown_fields)]
pub struct Config {
pub ui: UiConfig,
pub context: ContextConfig,
pub anthropic: AnthropicConfig,
pub anthropic_api: AnthropicApiConfig,
pub openai: OpenAiConfig,
pub zai: ZaiConfig,
pub openrouter: OpenRouterConfig,
pub deepseek: DeepseekConfig,
pub kimi: KimiConfig,
pub kilo: KiloConfig,
pub novita: NovitaConfig,
pub moonshot: MoonshotConfig,
pub grok: GrokConfig,
pub antigravity: AntigravityConfig,
pub cursor: CursorConfig,
pub minimax: MinimaxConfig,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(default)]
pub struct UiConfig {
pub primary: Option<VendorId>,
pub overview_vendors: Option<Vec<VendorId>>,
pub vendor_box: Option<VendorBoxStyle>,
}
impl UiConfig {
pub fn vendor_box(&self) -> VendorBoxStyle {
self.vendor_box.unwrap_or_default()
}
}
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Deserialize, Serialize)]
#[serde(rename_all = "lowercase")]
pub enum VendorBoxStyle {
#[default]
Sidebar,
Navbar,
None,
}
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Deserialize, Serialize)]
#[serde(rename_all = "lowercase")]
pub enum ContextLayout {
#[default]
Full,
Split,
Bottom,
}
impl ContextLayout {
pub fn next(self) -> Self {
match self {
ContextLayout::Full => ContextLayout::Split,
ContextLayout::Split => ContextLayout::Bottom,
ContextLayout::Bottom => ContextLayout::Full,
}
}
pub fn label(self) -> &'static str {
match self {
ContextLayout::Full => "full",
ContextLayout::Split => "split",
ContextLayout::Bottom => "bottom",
}
}
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(default)]
pub struct ContextConfig {
pub enabled: bool,
pub projects_path: Option<PathBuf>,
pub context_window_tokens: Option<u64>,
pub model_context_window_tokens: BTreeMap<String, u64>,
pub layout: ContextLayout,
}
impl ContextConfig {
pub fn window_tokens_for(&self, model: Option<&str>) -> Option<u64> {
model
.and_then(|model| self.model_context_window_tokens.get(model).copied())
.filter(|tokens| *tokens > 0)
.or_else(|| self.context_window_tokens.filter(|tokens| *tokens > 0))
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct AnthropicConfig {
pub enabled: bool,
pub credentials_path: Option<PathBuf>,
pub accounts: Vec<AnthropicAccount>,
pub accounts_dir: Option<PathBuf>,
pub show_default_account: bool,
pub desktop_profiles_dir: Option<PathBuf>,
}
impl Default for AnthropicConfig {
fn default() -> Self {
Self {
enabled: true,
credentials_path: None,
accounts: Vec::new(),
accounts_dir: None,
show_default_account: true,
desktop_profiles_dir: None,
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
pub struct AnthropicAccount {
pub label: String,
pub credentials_path: PathBuf,
}
impl AnthropicAccount {
pub fn config_dir(&self) -> PathBuf {
self.credentials_path
.parent()
.map_or_else(|| self.credentials_path.clone(), Path::to_path_buf)
}
}
impl AnthropicConfig {
pub fn all_accounts(&self) -> Vec<AnthropicAccount> {
let mut out = self.accounts.clone();
if let Some(dir) = &self.accounts_dir {
for acct in discover_accounts(dir) {
if !out.iter().any(|a| a.label == acct.label) {
out.push(acct);
}
}
}
out
}
pub fn account(&self, label: &str) -> Result<AnthropicAccount> {
validate_account_label(label)?;
let all = self.all_accounts();
all.iter().find(|a| a.label == label).cloned().ok_or_else(|| {
let known: Vec<&str> = all.iter().map(|a| a.label.as_str()).collect();
AppError::Credentials(format!(
"anthropic account {label:?} not found in [[anthropic.accounts]] or accounts_dir; \
known labels: {known:?}"
))
})
}
pub fn account_target(&self, label: &str) -> Result<(CredsTarget, Cache)> {
let active = crate::anthropic::cli_account::home_claude_json()
.ok()
.and_then(|path| {
crate::anthropic::cli_account::resolve_active_label(&path, &self.all_accounts())
});
self.account_target_with(label, active.as_deref())
}
pub fn account_target_with(
&self,
label: &str,
cli_active: Option<&str>,
) -> Result<(CredsTarget, Cache)> {
let account = self.account(label)?;
let cache = Cache::for_vendor_account("anthropic", label)?;
if cli_active == Some(label) {
return Ok((
CredsTarget::Default(crate::anthropic::creds::default_path()?),
cache,
));
}
Ok((
CredsTarget::Named {
config_dir: account.config_dir(),
path: account.credentials_path,
},
cache,
))
}
}
pub fn validate_account_label(label: &str) -> Result<()> {
const RESERVED: [&str; 4] = ["usage.json", ".stale", ".last_error", ".fetch.lock"];
let bad = label.is_empty()
|| label == "."
|| label == ".."
|| label.contains(['/', '\\'])
|| label.chars().any(char::is_control)
|| RESERVED.contains(&label);
if bad {
return Err(AppError::Credentials(format!(
"invalid anthropic account label {label:?}: must be a non-empty name \
without path separators, control characters, or reserved cache names"
)));
}
Ok(())
}
fn discover_accounts(accounts_dir: &std::path::Path) -> Vec<AnthropicAccount> {
let Ok(entries) = std::fs::read_dir(accounts_dir) else {
return Vec::new();
};
let mut found: Vec<AnthropicAccount> = entries
.flatten()
.filter_map(|entry| {
let path = entry.path();
if !path.is_dir() {
return None;
}
let label = path.file_name()?.to_str()?.to_string();
validate_account_label(&label).ok()?;
Some(AnthropicAccount {
label,
credentials_path: path.join(".credentials.json"),
})
})
.collect();
found.sort_by(|a, b| a.label.cmp(&b.label));
found
}
pub fn tildify(path: &Path, home: &Path) -> String {
path.strip_prefix(home)
.map(|rest| {
let rendered = rest.display().to_string();
#[cfg(windows)]
let rendered = rendered.replace('\\', "/");
format!("~/{rendered}")
})
.unwrap_or_else(|_| path.display().to_string())
}
pub fn default_account_credentials_path(config_path: &Path, label: &str) -> PathBuf {
let base = config_path.parent().unwrap_or_else(|| Path::new("."));
base.join("accounts").join(label).join(".credentials.json")
}
pub fn add_anthropic_account_to_doc(
doc: &mut toml_edit::DocumentMut,
label: &str,
credentials_path: &str,
) -> Result<()> {
use toml_edit::{Item, Table, value};
validate_account_label(label)?;
let anthropic = doc
.entry("anthropic")
.or_insert_with(|| Item::Table(Table::new()));
let anthropic = anthropic
.as_table_mut()
.ok_or_else(|| AppError::Other("[anthropic] in config.toml is not a table".into()))?;
let accounts = anthropic
.entry("accounts")
.or_insert_with(|| Item::ArrayOfTables(toml_edit::ArrayOfTables::new()));
let accounts = accounts.as_array_of_tables_mut().ok_or_else(|| {
AppError::Other("[[anthropic.accounts]] in config.toml is not an array of tables".into())
})?;
let exists = accounts
.iter()
.any(|t| t.get("label").and_then(Item::as_str) == Some(label));
if exists {
return Err(AppError::Credentials(format!(
"anthropic account {label:?} already exists in config.toml"
)));
}
let mut table = Table::new();
table["label"] = value(label);
table["credentials_path"] = value(credentials_path);
accounts.push(table);
Ok(())
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct OpenAiConfig {
pub enabled: bool,
pub codex_auth_path: Option<PathBuf>,
pub admin_key_env: String,
}
impl Default for OpenAiConfig {
fn default() -> Self {
Self {
enabled: true,
codex_auth_path: None,
admin_key_env: "OPENAI_ADMIN_KEY".to_string(),
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct ZaiConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
pub plan_tier: Option<String>,
}
impl Default for ZaiConfig {
fn default() -> Self {
Self {
enabled: true,
api_key_env: "ZAI_API_KEY".to_string(),
api_key: None,
plan_tier: None,
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct OpenRouterConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
}
impl Default for OpenRouterConfig {
fn default() -> Self {
Self {
enabled: true,
api_key_env: "OPENROUTER_API_KEY".to_string(),
api_key: None,
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct DeepseekConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
}
impl Default for DeepseekConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "DEEPSEEK_API_KEY".to_string(),
api_key: None,
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct KimiConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
}
impl Default for KimiConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "KIMI_API_KEY".to_string(),
api_key: None,
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct KiloConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
pub organization_id: Option<String>,
}
impl Default for KiloConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "KILO_API_KEY".to_string(),
api_key: None,
organization_id: None,
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct NovitaConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
}
impl Default for NovitaConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "NOVITA_API_KEY".to_string(),
api_key: None,
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct MinimaxConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
pub region: String,
}
impl Default for MinimaxConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "MINIMAX_API_KEY".to_string(),
api_key: None,
region: "global".to_string(),
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct MoonshotConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
pub region: String,
}
impl Default for MoonshotConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "MOONSHOT_API_KEY".to_string(),
api_key: None,
region: "global".to_string(),
}
}
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct GrokConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
pub team_id: Option<String>,
}
impl Default for GrokConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "XAI_MANAGEMENT_KEY".to_string(),
api_key: None,
team_id: None,
}
}
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(default)]
pub struct AntigravityConfig {
pub enabled: bool,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(default)]
pub struct CursorConfig {
pub enabled: bool,
pub db_path: Option<PathBuf>,
}
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(default)]
pub struct AnthropicApiConfig {
pub enabled: bool,
pub api_key_env: String,
pub api_key: Option<String>,
pub monthly_limit: Option<f64>,
}
impl Default for AnthropicApiConfig {
fn default() -> Self {
Self {
enabled: false,
api_key_env: "ANTHROPIC_ADMIN_KEY".to_string(),
api_key: None,
monthly_limit: None,
}
}
}
pub fn resolve_api_key(
vendor_label: &str,
env_var_name: &str,
inline: Option<&str>,
) -> crate::error::Result<String> {
let valid_env_name = is_valid_env_var_name(env_var_name);
if valid_env_name
&& let Ok(v) = std::env::var(env_var_name)
&& !v.is_empty()
{
return Ok(v);
}
if let Some(v) = inline
&& !v.is_empty()
{
return Ok(v.to_string());
}
let advice = if valid_env_name {
"set an API key in a valid environment variable or set `api_key`"
} else {
"fix the invalid `api_key_env` with a valid environment variable name or set `api_key`"
};
Err(crate::error::AppError::Credentials(format!(
"{vendor_label}: no API key. Either {advice} under [{}] in {}.",
vendor_label.to_lowercase(),
config_path_hint()
)))
}
fn is_valid_env_var_name(name: &str) -> bool {
let mut chars = name.chars();
let Some(first) = chars.next() else {
return false;
};
(first.is_ascii_alphabetic() || first == '_')
&& chars.all(|c| c.is_ascii_alphanumeric() || c == '_')
}
impl Config {
pub fn load() -> Result<Self> {
let Some(path) = resolved_path() else {
return Ok(Self::default());
};
Self::load_from(&path)
}
pub fn load_from(path: &std::path::Path) -> Result<Self> {
match std::fs::read_to_string(path) {
Ok(s) => {
let mut config: Self = toml::from_str(&s)?;
config.expand_paths();
config.validate()?;
Ok(config)
}
Err(e) if e.kind() == std::io::ErrorKind::NotFound => Ok(Self::default()),
Err(e) => Err(AppError::io_at(path, e)),
}
}
fn expand_paths(&mut self) {
expand_tilde_opt(&mut self.context.projects_path);
expand_tilde_opt(&mut self.anthropic.credentials_path);
expand_tilde_opt(&mut self.anthropic.accounts_dir);
expand_tilde_opt(&mut self.anthropic.desktop_profiles_dir);
expand_tilde_opt(&mut self.openai.codex_auth_path);
expand_tilde_opt(&mut self.cursor.db_path);
for account in &mut self.anthropic.accounts {
account.credentials_path = expand_tilde(&account.credentials_path);
}
}
pub fn is_enabled(&self, id: VendorId) -> bool {
match id {
VendorId::Anthropic => self.anthropic.enabled,
VendorId::AnthropicApi => self.anthropic_api.enabled,
VendorId::Openai => self.openai.enabled,
VendorId::Zai => self.zai.enabled,
VendorId::Openrouter => self.openrouter.enabled,
VendorId::Deepseek => self.deepseek.enabled,
VendorId::Kimi => self.kimi.enabled,
VendorId::Kilo => self.kilo.enabled,
VendorId::Novita => self.novita.enabled,
VendorId::Moonshot => self.moonshot.enabled,
VendorId::Grok => self.grok.enabled,
VendorId::Antigravity => self.antigravity.enabled,
VendorId::Cursor => self.cursor.enabled,
VendorId::Minimax => self.minimax.enabled,
}
}
pub fn enabled_vendors(&self) -> Vec<VendorId> {
VendorId::all()
.iter()
.copied()
.filter(|id| self.is_enabled(*id))
.collect()
}
pub fn validate(&self) -> Result<()> {
if self.context.context_window_tokens == Some(0) {
return Err(AppError::Other(
"[context] context_window_tokens must be greater than zero".into(),
));
}
for (model, tokens) in &self.context.model_context_window_tokens {
if model.trim().is_empty() {
return Err(AppError::Other(
"[context] model_context_window_tokens keys must not be empty".into(),
));
}
if *tokens == 0 {
return Err(AppError::Other(format!(
"[context] model_context_window_tokens entry {model:?} must be greater than zero"
)));
}
}
if let Some(limit) = self.anthropic_api.monthly_limit
&& (!limit.is_finite() || limit <= 0.0)
{
return Err(AppError::Other(
"[anthropic_api] monthly_limit must be finite and greater than zero; \
remove it to show spend without a limit"
.into(),
));
}
if !self.minimax.region.eq_ignore_ascii_case("global")
&& !self.minimax.region.eq_ignore_ascii_case("cn")
{
return Err(AppError::Other(format!(
"[minimax] region must be \"global\" or \"cn\", got {:?}",
self.minimax.region
)));
}
let mut labels = HashSet::new();
for account in &self.anthropic.accounts {
validate_account_label(&account.label)?;
if !labels.insert(&account.label) {
return Err(AppError::Credentials(format!(
"duplicate anthropic account label {:?}",
account.label
)));
}
}
Ok(())
}
}
pub fn default_path() -> Option<PathBuf> {
let proj = directories::ProjectDirs::from("", "", "ai-usagebar")?;
Some(proj.config_dir().join("config.toml"))
}
fn legacy_xdg_path() -> Option<PathBuf> {
let home = crate::cache::home_dir().ok()?;
Some(home.join(".config").join("ai-usagebar").join("config.toml"))
}
pub fn resolved_path() -> Option<PathBuf> {
let canonical = default_path();
if let Some(p) = &canonical
&& p.exists()
{
return canonical;
}
if let Some(legacy) = legacy_xdg_path()
&& legacy.exists()
{
return Some(legacy);
}
canonical
}
fn expand_tilde(p: &std::path::Path) -> PathBuf {
let Some(s) = p.to_str() else {
return p.to_path_buf();
};
let rest = if s == "~" {
""
} else if let Some(r) = s.strip_prefix("~/") {
r
} else {
return p.to_path_buf();
};
match crate::cache::home_dir() {
Ok(home) if rest.is_empty() => home,
Ok(home) => home.join(rest),
Err(_) => p.to_path_buf(),
}
}
fn expand_tilde_opt(p: &mut Option<PathBuf>) {
if let Some(inner) = p.as_ref() {
*p = Some(expand_tilde(inner));
}
}
pub fn config_path_hint() -> String {
resolved_path()
.map(|p| p.display().to_string())
.unwrap_or_else(|| "config.toml".to_string())
}
#[cfg(test)]
mod tests {
use super::*;
use std::io::Write;
use tempfile::NamedTempFile;
fn write_toml(s: &str) -> NamedTempFile {
let mut f = NamedTempFile::new().unwrap();
f.write_all(s.as_bytes()).unwrap();
f.flush().unwrap();
f
}
#[test]
fn defaults_enable_only_the_four_core_vendors() {
let c = Config::default();
assert!(c.is_enabled(VendorId::Anthropic));
assert!(c.is_enabled(VendorId::Openai));
assert!(c.is_enabled(VendorId::Zai));
assert!(c.is_enabled(VendorId::Openrouter));
for opt_in in [
VendorId::AnthropicApi,
VendorId::Deepseek,
VendorId::Kimi,
VendorId::Kilo,
VendorId::Novita,
VendorId::Moonshot,
VendorId::Grok,
VendorId::Cursor,
VendorId::Minimax,
] {
assert!(!c.is_enabled(opt_in), "{opt_in:?}");
}
assert_eq!(c.enabled_vendors().len(), 4);
}
#[test]
fn missing_file_uses_defaults() {
let path = std::path::Path::new("/tmp/does-not-exist-ai-usagebar-test");
let c = Config::load_from(path).unwrap();
assert!(c.is_enabled(VendorId::Anthropic));
}
#[test]
fn parses_full_config() {
let f = write_toml(
r#"
[anthropic]
enabled = true
[openai]
enabled = false
admin_key_env = "MY_ADMIN_KEY"
[zai]
enabled = true
api_key_env = "MY_ZAI"
plan_tier = "pro"
[openrouter]
enabled = false
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert!(c.is_enabled(VendorId::Anthropic));
assert!(!c.is_enabled(VendorId::Openai));
assert!(c.is_enabled(VendorId::Zai));
assert!(!c.is_enabled(VendorId::Openrouter));
assert_eq!(c.openai.admin_key_env, "MY_ADMIN_KEY");
assert_eq!(c.zai.api_key_env, "MY_ZAI");
assert_eq!(c.zai.plan_tier.as_deref(), Some("pro"));
}
#[test]
fn partial_config_falls_back_to_defaults() {
let f = write_toml(
r#"[openai]
enabled = false
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert!(!c.is_enabled(VendorId::Openai));
assert!(c.is_enabled(VendorId::Anthropic));
assert_eq!(c.openai.admin_key_env, "OPENAI_ADMIN_KEY");
}
#[test]
fn malformed_toml_returns_error() {
let f = write_toml("this is not = = valid");
assert!(Config::load_from(f.path()).is_err());
}
#[test]
fn anthropic_api_monthly_limit_must_be_positive_and_finite() {
for value in ["0", "-1", "inf", "nan"] {
let file = write_toml(&format!("[anthropic_api]\nmonthly_limit = {value}\n"));
let error = Config::load_from(file.path()).unwrap_err().to_string();
assert!(error.contains("monthly_limit"), "value {value}: {error}");
}
let file = write_toml("[anthropic_api]\nmonthly_limit = 1000\n");
assert_eq!(
Config::load_from(file.path())
.unwrap()
.anthropic_api
.monthly_limit,
Some(1000.0)
);
}
#[test]
fn minimax_region_accepts_only_known_instances() {
for region in ["global", "GLOBAL", "cn", "CN"] {
let file = write_toml(&format!("[minimax]\nregion = {region:?}\n"));
assert_eq!(
Config::load_from(file.path()).unwrap().minimax.region,
region
);
}
for region in ["", "china", "us"] {
let file = write_toml(&format!("[minimax]\nregion = {region:?}\n"));
let error = Config::load_from(file.path()).unwrap_err().to_string();
assert!(error.contains("[minimax] region"), "{error}");
}
}
#[test]
fn context_monitor_is_opt_in_and_window_sizes_are_explicit() {
let defaults = Config::default();
assert!(!defaults.context.enabled);
assert_eq!(
defaults.context.window_tokens_for(Some("claude-test")),
None
);
let file = write_toml(
r#"
[context]
enabled = true
context_window_tokens = 200000
[context.model_context_window_tokens]
claude-opus-1m = 1000000
"claude exact id" = 300000
"#,
);
let config = Config::load_from(file.path()).unwrap();
assert!(config.context.enabled);
assert_eq!(
config.context.window_tokens_for(Some("claude-opus-1m")),
Some(1_000_000)
);
assert_eq!(
config.context.window_tokens_for(Some("claude exact id")),
Some(300_000)
);
assert_eq!(
config.context.window_tokens_for(Some("another-model")),
Some(200_000)
);
}
#[test]
fn context_layout_defaults_to_full_and_parses_each_variant() {
assert_eq!(Config::default().context.layout, ContextLayout::Full);
for (text, want) in [
("full", ContextLayout::Full),
("split", ContextLayout::Split),
("bottom", ContextLayout::Bottom),
] {
let file = write_toml(&format!("[context]\nlayout = \"{text}\"\n"));
assert_eq!(Config::load_from(file.path()).unwrap().context.layout, want);
}
let file = write_toml("[context]\nlayout = \"floating\"\n");
assert!(
Config::load_from(file.path()).is_err(),
"an unknown layout must be rejected, not silently defaulted"
);
}
#[test]
fn vendor_box_defaults_to_sidebar_and_parses_each_variant() {
assert_eq!(Config::default().ui.vendor_box(), VendorBoxStyle::Sidebar);
for (text, want) in [
("sidebar", VendorBoxStyle::Sidebar),
("navbar", VendorBoxStyle::Navbar),
("none", VendorBoxStyle::None),
] {
let file = write_toml(&format!("[ui]\nvendor_box = \"{text}\"\n"));
assert_eq!(
Config::load_from(file.path()).unwrap().ui.vendor_box(),
want
);
}
let file = write_toml("[ui]\nvendor_box = \"floating\"\n");
assert!(
Config::load_from(file.path()).is_err(),
"an unknown vendor_box style must be rejected, not silently defaulted"
);
}
#[test]
fn context_window_sizes_must_be_nonzero_and_model_ids_nonempty() {
for source in [
"[context]\ncontext_window_tokens = 0\n",
"[context.model_context_window_tokens]\nclaude = 0\n",
"[context.model_context_window_tokens]\n\" \" = 200000\n",
] {
let file = write_toml(source);
let error = Config::load_from(file.path()).unwrap_err().to_string();
assert!(error.contains("context"), "{error}");
}
}
fn env_guard() -> std::sync::MutexGuard<'static, ()> {
static M: std::sync::Mutex<()> = std::sync::Mutex::new(());
M.lock().unwrap_or_else(|p| p.into_inner())
}
#[test]
fn resolve_api_key_prefers_env_over_inline() {
let _g = env_guard();
let var = "AI_USAGEBAR_TEST_ENV_WINS";
unsafe { std::env::set_var(var, "from-env") };
let got = resolve_api_key("Zai", var, Some("from-inline")).unwrap();
unsafe { std::env::remove_var(var) };
assert_eq!(got, "from-env");
}
#[test]
fn resolve_api_key_falls_back_to_inline() {
let _g = env_guard();
let var = "AI_USAGEBAR_TEST_INLINE_FALLBACK";
unsafe { std::env::remove_var(var) };
let got = resolve_api_key("Zai", var, Some("inline-key")).unwrap();
assert_eq!(got, "inline-key");
}
#[test]
fn resolve_api_key_errors_when_both_missing() {
let _g = env_guard();
let var = "AI_USAGEBAR_TEST_BOTH_MISSING";
unsafe { std::env::remove_var(var) };
let err = resolve_api_key("Zai", var, None).unwrap_err();
match err {
crate::error::AppError::Credentials(msg) => {
assert!(
msg.contains("api_key"),
"error should suggest config field: {msg}"
);
}
other => panic!("expected Credentials error, got {other:?}"),
}
}
#[test]
fn config_path_hint_ends_with_config_toml() {
assert!(config_path_hint().ends_with("config.toml"));
}
#[test]
fn resolve_api_key_treats_empty_env_as_unset() {
let _g = env_guard();
let var = "AI_USAGEBAR_TEST_EMPTY_ENV";
unsafe { std::env::set_var(var, "") };
let got = resolve_api_key("OpenRouter", var, Some("inline")).unwrap();
unsafe { std::env::remove_var(var) };
assert_eq!(got, "inline");
}
#[test]
fn resolve_api_key_rejects_invalid_env_var_name_without_leaking_it() {
let _g = env_guard();
let bad = "sk-kimi-very-real-looking-pasted-secret";
let err = resolve_api_key("Kimi", bad, None).unwrap_err();
let msg = err.to_string();
assert!(
msg.contains("invalid") && msg.contains("api_key_env"),
"error should explain misconfiguration: {msg}"
);
assert!(
!msg.contains(bad),
"error must not echo the misconfigured value: {msg}"
);
assert!(msg.contains("valid environment variable name"));
assert!(
msg.contains("[kimi]"),
"error should point at the lowercase TOML section: {msg}"
);
}
#[test]
fn resolve_api_key_invalid_env_name_falls_back_to_inline() {
let _g = env_guard();
let got = resolve_api_key("Kimi", "sk-pasted-secret", Some("inline-key")).unwrap();
assert_eq!(got, "inline-key");
}
#[test]
fn resolve_api_key_never_leaks_valid_looking_configured_env_name() {
let _g = env_guard();
let pasted_secret = "sk_pasted_secret";
unsafe { std::env::remove_var(pasted_secret) };
let err = resolve_api_key("Kimi", pasted_secret, None).unwrap_err();
assert!(
!err.to_string().contains(pasted_secret),
"error must not echo configured api_key_env values"
);
}
#[test]
fn is_valid_env_var_name_rules() {
for valid in ["KIMI_API_KEY", "_PRIVATE", "a", "Z9", "MY_ZAI_2"] {
assert!(is_valid_env_var_name(valid), "{valid} should be valid");
}
for invalid in ["", "9LIVES", "sk-kimi", "MY KEY", "A.B", "sk/k"] {
assert!(
!is_valid_env_var_name(invalid),
"{invalid} should be invalid"
);
}
}
#[test]
fn config_parses_with_inline_api_key_and_primary() {
let f = write_toml(
r#"
[ui]
primary = "openrouter"
[zai]
enabled = true
api_key_env = "MY_ZAI"
api_key = "sk-zai-inline"
[openrouter]
enabled = true
api_key = "sk-or-inline"
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert_eq!(c.ui.primary, Some(VendorId::Openrouter));
assert_eq!(c.zai.api_key.as_deref(), Some("sk-zai-inline"));
assert_eq!(c.openrouter.api_key.as_deref(), Some("sk-or-inline"));
}
#[test]
fn enabled_vendors_preserves_canonical_order() {
let c = Config::default();
assert_eq!(
c.enabled_vendors(),
vec![
VendorId::Anthropic,
VendorId::Openai,
VendorId::Zai,
VendorId::Openrouter,
]
);
}
#[test]
fn deepseek_appears_when_enabled() {
let f = write_toml(
r#"
[deepseek]
enabled = true
api_key = "sk-test"
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert!(c.is_enabled(VendorId::Deepseek));
assert!(c.enabled_vendors().contains(&VendorId::Deepseek));
assert_eq!(c.deepseek.api_key.as_deref(), Some("sk-test"));
}
#[test]
fn tilde_paths_are_expanded_on_load() {
let f = write_toml(
r#"
[context]
projects_path = "~/.claude/projects"
[anthropic]
credentials_path = "~/.claude/.credentials.json"
[[anthropic.accounts]]
label = "work"
credentials_path = "~/work.json"
"#,
);
let c = Config::load_from(f.path()).unwrap();
let home = crate::cache::home_dir().unwrap();
assert_eq!(c.context.projects_path, Some(home.join(".claude/projects")));
let got = c.anthropic.credentials_path.unwrap();
assert_eq!(got, home.join(".claude/.credentials.json"));
assert!(!got.to_string_lossy().contains('~'));
assert_eq!(
c.anthropic.accounts[0].credentials_path,
home.join("work.json")
);
}
#[test]
fn absolute_and_relative_paths_are_left_alone() {
let f = write_toml(
r#"
[anthropic]
credentials_path = "/etc/creds.json"
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert_eq!(
c.anthropic.credentials_path.unwrap(),
std::path::Path::new("/etc/creds.json")
);
let f2 = write_toml(
r#"
[anthropic]
credentials_path = "~someone/creds.json"
"#,
);
let c2 = Config::load_from(f2.path()).unwrap();
assert_eq!(
c2.anthropic.credentials_path.unwrap(),
std::path::Path::new("~someone/creds.json")
);
}
#[test]
fn resolved_path_is_the_canonical_one_and_names_the_config_file() {
let p = resolved_path().expect("a config path must resolve");
assert!(p.ends_with("config.toml"));
let canonical = default_path().unwrap();
let legacy = legacy_xdg_path().unwrap();
assert!(
p == canonical || p == legacy,
"resolved to an unexpected location: {}",
p.display()
);
}
#[test]
fn misspelled_section_is_rejected_not_ignored() {
let f = write_toml(
r#"
[openrouer]
enabled = true
api_key = "sk-or-v1-typo"
"#,
);
let err = Config::load_from(f.path()).unwrap_err().to_string();
assert!(
err.contains("openrouer"),
"error should name the typo: {err}"
);
}
#[test]
fn invalid_toml_is_an_error_not_silent_defaults() {
let f = write_toml("[zai\nenabled = true\n");
assert!(Config::load_from(f.path()).is_err());
}
#[test]
fn a_missing_file_is_still_just_defaults() {
let dir = tempfile::tempdir().unwrap();
let missing = dir.path().join("nope").join("config.toml");
let c = Config::load_from(&missing).unwrap();
assert!(c.is_enabled(VendorId::Anthropic));
}
#[test]
fn kimi_appears_when_enabled() {
let f = write_toml(
r#"
[kimi]
enabled = true
api_key = "sk-test"
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert!(c.is_enabled(VendorId::Kimi));
assert!(c.enabled_vendors().contains(&VendorId::Kimi));
assert_eq!(c.kimi.api_key.as_deref(), Some("sk-test"));
}
#[test]
fn enabled_deepseek_and_kimi_appear_in_canonical_order_ending_with_them() {
let f = write_toml(
r#"
[deepseek]
enabled = true
api_key = "sk-ds"
[kimi]
enabled = true
api_key = "sk-kimi"
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert_eq!(
c.enabled_vendors(),
vec![
VendorId::Anthropic,
VendorId::Openai,
VendorId::Zai,
VendorId::Openrouter,
VendorId::Deepseek,
VendorId::Kimi,
]
);
}
#[test]
fn parses_anthropic_accounts_and_looks_them_up() {
let f = write_toml(
r#"
[anthropic]
enabled = true
[[anthropic.accounts]]
label = "personal"
credentials_path = "/creds/personal.json"
[[anthropic.accounts]]
label = "work"
credentials_path = "/creds/work.json"
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert_eq!(c.anthropic.accounts.len(), 2);
let work = c.anthropic.account("work").unwrap();
assert_eq!(work.credentials_path, PathBuf::from("/creds/work.json"));
let err = format!("{:?}", c.anthropic.account("missing").unwrap_err());
assert!(err.contains("missing") && err.contains("work"), "{err}");
}
#[test]
fn duplicate_anthropic_account_labels_are_rejected_on_load() {
let f = write_toml(
r#"
[[anthropic.accounts]]
label = "work"
credentials_path = "/creds/work-one.json"
[[anthropic.accounts]]
label = "work"
credentials_path = "/creds/work-two.json"
"#,
);
let err = Config::load_from(f.path()).unwrap_err().to_string();
assert!(
err.contains("duplicate anthropic account label \"work\""),
"{err}"
);
}
#[test]
fn account_label_rejects_path_like_names() {
let cfg = AnthropicConfig::default();
for bad in [
"",
".",
"..",
"a/b",
r"a\b",
"line\nbreak",
"tab\tname",
"usage.json",
".stale",
".last_error",
".fetch.lock",
] {
let err = cfg.account(bad).unwrap_err();
assert!(
format!("{err:?}").contains("invalid anthropic account label"),
"{bad:?} should be rejected as a label"
);
}
}
#[test]
fn anthropic_accounts_default_to_empty() {
assert!(Config::default().anthropic.accounts.is_empty());
assert!(Config::default().anthropic.accounts_dir.is_none());
}
fn seed_account_dir(root: &std::path::Path, label: &str) {
let dir = root.join(label);
std::fs::create_dir_all(&dir).unwrap();
std::fs::write(dir.join(".credentials.json"), "{}").unwrap();
}
#[test]
fn discovers_account_dirs_in_claude_config_dir_layout() {
let td = tempfile::tempdir().unwrap();
seed_account_dir(td.path(), "work");
seed_account_dir(td.path(), "personal");
std::fs::create_dir_all(td.path().join("keychain-only")).unwrap();
std::fs::write(td.path().join("stray.json"), "{}").unwrap();
let cfg = AnthropicConfig {
accounts_dir: Some(td.path().to_path_buf()),
..Default::default()
};
let all = cfg.all_accounts();
let labels: Vec<&str> = all.iter().map(|a| a.label.as_str()).collect();
assert_eq!(labels, vec!["keychain-only", "personal", "work"]);
assert_eq!(
all[2].credentials_path,
td.path().join("work").join(".credentials.json")
);
}
#[test]
fn explicit_account_wins_over_a_discovered_one_with_the_same_label() {
let td = tempfile::tempdir().unwrap();
seed_account_dir(td.path(), "work");
let cfg = AnthropicConfig {
accounts: vec![AnthropicAccount {
label: "work".into(),
credentials_path: "/explicit/work.json".into(),
}],
accounts_dir: Some(td.path().to_path_buf()),
..Default::default()
};
let all = cfg.all_accounts();
assert_eq!(all.len(), 1, "no duplicate label");
assert_eq!(
all[0].credentials_path,
std::path::Path::new("/explicit/work.json"),
"explicit entry wins"
);
seed_account_dir(td.path(), "other");
assert_eq!(cfg.account("other").unwrap().label, "other");
}
#[test]
fn missing_accounts_dir_is_silently_empty_not_an_error() {
let cfg = AnthropicConfig {
accounts_dir: Some("/nonexistent/ai-usagebar-accounts".into()),
..Default::default()
};
assert!(cfg.all_accounts().is_empty());
}
#[test]
fn accounts_dir_is_tilde_expanded_on_load() {
let f = write_toml(
r#"
[anthropic]
accounts_dir = "~/.config/ai-usagebar/accounts"
"#,
);
let c = Config::load_from(f.path()).unwrap();
let home = crate::cache::home_dir().unwrap();
assert_eq!(
c.anthropic.accounts_dir,
Some(home.join(".config/ai-usagebar/accounts"))
);
}
#[test]
fn desktop_profiles_dir_is_tilde_expanded_on_load() {
let f = write_toml(
r#"
[anthropic]
desktop_profiles_dir = "~/.claude-acc/profiles"
"#,
);
let c = Config::load_from(f.path()).unwrap();
let home = crate::cache::home_dir().unwrap();
assert_eq!(
c.anthropic.desktop_profiles_dir,
Some(home.join(".claude-acc/profiles"))
);
}
#[test]
fn the_live_cli_account_is_read_from_the_default_credential_slot() {
let cfg = AnthropicConfig {
accounts: vec![
AnthropicAccount {
label: "work".into(),
credentials_path: "/tmp/accounts/work/.credentials.json".into(),
},
AnthropicAccount {
label: "personal".into(),
credentials_path: "/tmp/accounts/personal/.credentials.json".into(),
},
],
..Default::default()
};
let (idle, idle_cache) = cfg.account_target_with("work", Some("personal")).unwrap();
assert!(
matches!(&idle, CredsTarget::Named { config_dir, .. }
if config_dir == std::path::Path::new("/tmp/accounts/work")),
"{idle:?}"
);
let (live, live_cache) = cfg.account_target_with("work", Some("work")).unwrap();
assert!(matches!(live, CredsTarget::Default(_)), "{live:?}");
assert_eq!(idle_cache.dir(), live_cache.dir());
}
#[test]
fn no_live_cli_account_keeps_every_account_on_its_own_slot() {
let cfg = AnthropicConfig {
accounts: vec![AnthropicAccount {
label: "work".into(),
credentials_path: "/tmp/accounts/work/.credentials.json".into(),
}],
..Default::default()
};
let (target, _) = cfg.account_target_with("work", None).unwrap();
assert!(matches!(target, CredsTarget::Named { .. }), "{target:?}");
}
fn config_example() -> PathBuf {
PathBuf::from(env!("CARGO_MANIFEST_DIR")).join("config.example.toml")
}
#[test]
fn shipped_example_parses_as_a_real_config() {
let c = Config::load_from(&config_example()).unwrap();
assert!(!c.context.enabled);
assert!(c.is_enabled(VendorId::Anthropic));
assert!(c.is_enabled(VendorId::Openai));
assert!(!c.is_enabled(VendorId::AnthropicApi));
assert!(!c.is_enabled(VendorId::Deepseek));
assert!(!c.is_enabled(VendorId::Kimi));
assert!(!c.is_enabled(VendorId::Kilo));
assert!(!c.is_enabled(VendorId::Novita));
assert!(!c.is_enabled(VendorId::Moonshot));
assert!(!c.is_enabled(VendorId::Grok));
assert!(!c.is_enabled(VendorId::Cursor));
assert!(!c.is_enabled(VendorId::Minimax));
}
#[test]
fn shipped_example_does_not_advertise_admin_key_env_as_working() {
let text = std::fs::read_to_string(config_example()).unwrap();
let live: Vec<&str> = text
.lines()
.map(str::trim)
.filter(|l| l.contains("admin_key_env") && !l.starts_with('#'))
.collect();
assert!(
live.is_empty(),
"admin_key_env must stay commented out while it is inert: {live:?}"
);
assert!(
text.contains("admin_key_env") && text.contains("RESERVED"),
"the example should keep describing admin_key_env as reserved"
);
}
#[test]
fn admin_key_env_is_accepted_but_changes_nothing() {
let f = write_toml(
r#"
[openai]
admin_key_env = "SOME_ADMIN_KEY"
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert_eq!(c.openai.admin_key_env, "SOME_ADMIN_KEY");
let default = OpenAiConfig::default();
assert_eq!(c.openai.enabled, default.enabled);
assert_eq!(c.openai.codex_auth_path, default.codex_auth_path);
assert_eq!(c.enabled_vendors(), Config::default().enabled_vendors());
}
#[test]
fn config_example_documents_every_vendor_without_secrets() {
let raw = std::fs::read_to_string(config_example()).unwrap();
let cfg = Config::load_from(&config_example()).unwrap();
for id in VendorId::all() {
let section = id.slug();
assert!(
raw.contains(&format!("[{section}]")),
"config.example.toml has no [{section}] section"
);
}
assert!(!cfg.anthropic_api.enabled && cfg.anthropic_api.api_key.is_none());
assert!(!cfg.kilo.enabled && cfg.kilo.api_key.is_none());
assert!(!cfg.novita.enabled && cfg.novita.api_key.is_none());
assert!(!cfg.moonshot.enabled && cfg.moonshot.api_key.is_none());
assert!(!cfg.grok.enabled && cfg.grok.api_key.is_none());
assert!(!cfg.cursor.enabled && cfg.cursor.db_path.is_none());
}
#[test]
fn cursor_db_path_is_tilde_expanded() {
let f = write_toml(
r#"
[cursor]
db_path = "~/cursor-state.vscdb"
"#,
);
let c = Config::load_from(f.path()).unwrap();
let home = crate::cache::home_dir().unwrap();
assert_eq!(c.cursor.db_path, Some(home.join("cursor-state.vscdb")));
}
#[test]
fn cursor_appears_when_enabled() {
let f = write_toml(
r#"
[cursor]
enabled = true
"#,
);
let c = Config::load_from(f.path()).unwrap();
assert!(c.is_enabled(VendorId::Cursor));
assert!(c.enabled_vendors().contains(&VendorId::Cursor));
}
#[test]
fn add_account_appends_and_preserves_existing() {
let mut doc: toml_edit::DocumentMut = r#"
# keep me
[anthropic]
enabled = true
[[anthropic.accounts]]
label = "personal"
credentials_path = "~/.config/ai-usagebar/accounts/personal/.credentials.json"
"#
.parse()
.unwrap();
add_anthropic_account_to_doc(
&mut doc,
"work",
"~/.config/ai-usagebar/accounts/work/.credentials.json",
)
.unwrap();
let rendered = doc.to_string();
assert!(rendered.contains("# keep me"), "comment must survive");
let f = write_toml(&rendered);
let c = Config::load_from(f.path()).unwrap();
let labels: Vec<&str> = c
.anthropic
.accounts
.iter()
.map(|a| a.label.as_str())
.collect();
assert_eq!(labels, vec!["personal", "work"]);
}
#[test]
fn add_account_to_empty_doc_is_loadable() {
let mut doc = toml_edit::DocumentMut::new();
add_anthropic_account_to_doc(&mut doc, "solo", "~/x/.credentials.json").unwrap();
let f = write_toml(&doc.to_string());
let c = Config::load_from(f.path()).unwrap();
assert_eq!(c.anthropic.accounts.len(), 1);
assert_eq!(c.anthropic.accounts[0].label, "solo");
}
#[test]
fn add_account_rejects_duplicate_label() {
let mut doc: toml_edit::DocumentMut = r#"
[[anthropic.accounts]]
label = "work"
credentials_path = "~/w/.credentials.json"
"#
.parse()
.unwrap();
assert!(
add_anthropic_account_to_doc(&mut doc, "work", "~/other/.credentials.json").is_err(),
"a duplicate label must be rejected, not appended"
);
}
#[test]
fn add_account_rejects_bad_label() {
let mut doc = toml_edit::DocumentMut::new();
assert!(add_anthropic_account_to_doc(&mut doc, "a/b", "~/x/.credentials.json").is_err());
assert!(add_anthropic_account_to_doc(&mut doc, "", "~/x/.credentials.json").is_err());
}
#[test]
fn tildify_collapses_home_only() {
let home = Path::new("/Users/me");
assert_eq!(tildify(&home.join("a/b"), home), "~/a/b");
assert_eq!(tildify(Path::new("/etc/hosts"), home), "/etc/hosts");
}
#[test]
fn default_account_credentials_path_nests_under_config_dir() {
let cfg = Path::new("/home/u/.config/ai-usagebar/config.toml");
assert_eq!(
default_account_credentials_path(cfg, "work"),
Path::new("/home/u/.config/ai-usagebar/accounts/work/.credentials.json"),
);
}
}