Co-authored-by: aider (openai/andrew/openrouter/deepseek/deepseek-chat-v3.1) <aider@aider.chat>
196 lines
6.3 KiB
Rust
196 lines
6.3 KiB
Rust
use crate::config;
|
|
use crate::compression_engine::CompressionType;
|
|
use crate::meta_plugin::MetaPluginType;
|
|
use clap::Command;
|
|
use clap::error::ErrorKind;
|
|
use log::debug;
|
|
use prettytable::format::TableFormat;
|
|
use regex::Regex;
|
|
use std::collections::HashMap;
|
|
use std::env;
|
|
use std::str::FromStr;
|
|
use strum::IntoEnumIterator;
|
|
#[derive(Debug, Clone, strum::EnumString, strum::Display, PartialEq)]
|
|
#[strum(ascii_case_insensitive)]
|
|
pub enum OutputFormat {
|
|
Table,
|
|
Json,
|
|
Yaml,
|
|
}
|
|
|
|
pub fn get_meta_from_env() -> HashMap<String, String> {
|
|
debug!("COMMON: Getting meta from KEEP_META_*");
|
|
let re = Regex::new(r"^KEEP_META_(.+)$").unwrap();
|
|
let mut meta_env: HashMap<String, String> = HashMap::new();
|
|
for (key, value) in env::vars() {
|
|
if let Some(meta_name_caps) = re.captures(key.as_str()) {
|
|
let name = String::from(meta_name_caps.get(1).unwrap().as_str());
|
|
// Ignore KEEP_META_PLUGINS
|
|
if name != "PLUGINS" {
|
|
debug!("COMMON: Found meta: {}={}", name.clone(), value.clone());
|
|
meta_env.insert(name, value.clone());
|
|
}
|
|
}
|
|
}
|
|
meta_env
|
|
}
|
|
|
|
pub fn format_size(size: u64, human_readable: bool) -> String {
|
|
match human_readable {
|
|
true => humansize::format_size(size, humansize::DECIMAL),
|
|
false => size.to_string(),
|
|
}
|
|
}
|
|
|
|
pub fn string_column(s: String, column_width: usize) -> String {
|
|
if column_width > 0 {
|
|
match s.char_indices().nth(column_width) {
|
|
None => s.to_string(),
|
|
Some((idx, _)) => {
|
|
if column_width > 1 {
|
|
// Find where to cut to fit the ellipsis
|
|
let mut cut_idx = idx;
|
|
// We need to make room for the ellipsis character
|
|
// Find the character boundary before the cut index
|
|
for i in (0..idx).rev() {
|
|
if s.is_char_boundary(i) {
|
|
if idx - i >= 3 { // Make sure we have enough room
|
|
cut_idx = i;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
// If we can't find a good place, just truncate without ellipsis
|
|
if cut_idx >= 3 {
|
|
format!("{}…", &s[..cut_idx - 1])
|
|
} else {
|
|
s[..idx].to_string()
|
|
}
|
|
} else {
|
|
s[..idx].to_string()
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
s.to_string()
|
|
}
|
|
}
|
|
|
|
pub fn size_column(size: u64, human_readable: bool, column_width: usize) -> String {
|
|
string_column(format_size(size, human_readable), column_width)
|
|
}
|
|
|
|
#[derive(Debug, Eq, PartialEq, Clone, strum::EnumIter, strum::Display, strum::EnumString)]
|
|
#[strum(ascii_case_insensitive)]
|
|
pub enum ColumnType {
|
|
Id,
|
|
Time,
|
|
Size,
|
|
Compression,
|
|
FileSize,
|
|
FilePath,
|
|
Tags,
|
|
Meta,
|
|
}
|
|
|
|
impl ColumnType {
|
|
/// Returns a Result with error message if the string is not a valid ColumnType
|
|
pub fn from_str(s: &str) -> anyhow::Result<Self> {
|
|
if s.starts_with("meta:") {
|
|
// Handle meta:<name> pattern - this is still a Meta column type
|
|
Ok(ColumnType::Meta)
|
|
} else {
|
|
// Handle regular column types
|
|
Ok(Self::try_from(s)?)
|
|
}
|
|
}
|
|
}
|
|
|
|
// impl TryFrom<&str> for ColumnType is already implemented by strum_macros
|
|
// so we remove this conflicting implementation
|
|
|
|
pub fn get_format_box_chars_no_border_line_separator() -> TableFormat {
|
|
prettytable::format::FormatBuilder::new()
|
|
.column_separator('│')
|
|
.borders('│')
|
|
.separators(
|
|
&[prettytable::format::LinePosition::Top],
|
|
prettytable::format::LineSeparator::new('─', '┬', '┌', '┐'),
|
|
)
|
|
.separators(
|
|
&[prettytable::format::LinePosition::Title],
|
|
prettytable::format::LineSeparator::new('─', '┼', '├', '┤'),
|
|
)
|
|
.separators(
|
|
&[prettytable::format::LinePosition::Bottom],
|
|
prettytable::format::LineSeparator::new('─', '┴', '└', '┘'),
|
|
)
|
|
.padding(1, 1)
|
|
.build()
|
|
}
|
|
|
|
|
|
|
|
|
|
pub fn settings_meta_plugin_types(cmd: &mut Command, settings: &config::Settings) -> Vec<MetaPluginType> {
|
|
let mut meta_plugin_types = Vec::new();
|
|
|
|
// Handle comma-separated values in each meta_plugins argument
|
|
for meta_plugin_names_str in &settings.meta_plugins_names() {
|
|
let meta_plugin_names: Vec<&str> = meta_plugin_names_str.split(',').collect();
|
|
|
|
for name in meta_plugin_names {
|
|
let trimmed_name = name.trim();
|
|
if trimmed_name.is_empty() {
|
|
continue;
|
|
}
|
|
|
|
// Try to find the MetaPluginType by meta name
|
|
let mut found = false;
|
|
for meta_plugin_type in MetaPluginType::iter() {
|
|
let meta_plugin = crate::meta_plugin::get_meta_plugin(meta_plugin_type.clone(), None, None);
|
|
if meta_plugin.meta_type().to_string() == trimmed_name {
|
|
meta_plugin_types.push(meta_plugin_type);
|
|
found = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if !found {
|
|
cmd.error(
|
|
ErrorKind::InvalidValue,
|
|
format!("Unknown meta plugin type: {}", trimmed_name),
|
|
)
|
|
.exit();
|
|
}
|
|
}
|
|
}
|
|
|
|
meta_plugin_types
|
|
}
|
|
|
|
|
|
pub fn settings_compression_type(cmd: &mut Command, settings: &config::Settings) -> CompressionType {
|
|
let compression_name = settings
|
|
.compression()
|
|
.unwrap_or(CompressionType::LZ4.to_string());
|
|
|
|
let compression_type_opt = CompressionType::from_str(&compression_name);
|
|
if compression_type_opt.is_err() {
|
|
cmd.error(
|
|
ErrorKind::InvalidValue,
|
|
format!("Invalid compression algorithm '{}'. Supported algorithms: lz4, gzip, xz, zstd", compression_name),
|
|
)
|
|
.exit();
|
|
}
|
|
|
|
compression_type_opt.unwrap()
|
|
}
|
|
|
|
pub fn settings_output_format(settings: &config::Settings) -> OutputFormat {
|
|
settings.output_format
|
|
.as_ref()
|
|
.and_then(|s| OutputFormat::from_str(s).ok())
|
|
.unwrap_or(OutputFormat::Table)
|
|
}
|