use std::{
fs::File,
io::Read,
path::{Path, PathBuf},
};
use anyhow::{Context, Result};
use term_table::{Table, TableStyle};
use wash_lib::{
config::{cfg_dir, DEFAULT_NATS_TIMEOUT_MS},
plugin::{subcommand::SubcommandRunner, PLUGIN_DIR},
};
const MAX_TERMINAL_WIDTH: usize = 120;
pub fn format_optional(value: Option<String>) -> String {
value.unwrap_or_else(|| "N/A".into())
}
pub fn extract_arg_value(arg: &str) -> Result<String> {
match File::open(arg) {
Ok(mut f) => {
let mut value = String::new();
f.read_to_string(&mut value)
.with_context(|| format!("Failed to read file {}", &arg))?;
Ok(value)
}
Err(_) => Ok(arg.to_string()),
}
}
pub fn default_timeout_ms() -> u64 {
DEFAULT_NATS_TIMEOUT_MS
}
pub fn json_str_to_msgpack_bytes(payload: &str) -> Result<Vec<u8>> {
let json: serde_json::Value =
serde_json::from_str(payload).context("failed to encode string as JSON")?;
rmp_serde::to_vec_named(&json).context("failed to encode JSON as msgpack")
}
pub async fn ensure_plugin_dir(dir: Option<impl AsRef<Path>>) -> Result<PathBuf> {
let plugin_dir = match dir.map(|dir| dir.as_ref().to_path_buf()) {
Some(dir) => dir,
None => cfg_dir()?.join(PLUGIN_DIR),
};
if !tokio::fs::try_exists(&plugin_dir).await.unwrap_or(false) {
tokio::fs::create_dir(&plugin_dir).await?;
}
Ok(plugin_dir)
}
pub async fn load_plugins(plugin_dir: impl AsRef<Path>) -> anyhow::Result<SubcommandRunner> {
let mut readdir = tokio::fs::read_dir(&plugin_dir)
.await
.context("Unable to read plugin directory")?;
let mut plugins = SubcommandRunner::new().context("Could not inititalize plugin runner")?;
while let Some(entry) = readdir.next_entry().await.transpose() {
let entry = match entry {
Ok(entry) => entry,
Err(e) => {
eprintln!("WARN: Could not read plugin directory entry. Skipping: {e:?}");
continue;
}
};
if entry
.file_type()
.await
.map(|ft| ft.is_file())
.unwrap_or(false)
{
if let Err(e) = plugins.add_plugin(entry.path()).await {
eprintln!("WARN: Couldn't load plugin, skipping: {:?}", e);
}
}
}
Ok(plugins)
}
use once_cell::sync::OnceCell;
static BIN_STR: OnceCell<char> = OnceCell::new();
fn msgpack_to_json(mval: rmpv::Value) -> serde_json::Value {
use rmpv::Value as RV;
use serde_json::Value as JV;
match mval {
RV::String(s) => JV::String(s.to_string()),
RV::Boolean(b) => JV::Bool(b),
RV::Array(v) => JV::Array(v.into_iter().map(msgpack_to_json).collect::<Vec<_>>()),
RV::F64(f) => JV::from(f),
RV::F32(f) => JV::from(f),
RV::Integer(i) => match (i.is_u64(), i.is_i64()) {
(true, _) => JV::from(i.as_u64().unwrap()),
(_, true) => JV::from(i.as_i64().unwrap()),
_ => JV::from(0u64),
},
RV::Map(vkv) => JV::Object(
vkv.into_iter()
.map(|(k, v)| {
(
k.as_str().unwrap_or_default().to_string(),
msgpack_to_json(v),
)
})
.collect::<serde_json::Map<_, _>>(),
),
RV::Binary(v) => match BIN_STR.get().unwrap() {
's' => JV::String(String::from_utf8_lossy(&v).into_owned()),
'2' => serde_json::json!({
"str": String::from_utf8_lossy(&v),
"bin": v,
}),
_ => JV::Array(v.into_iter().map(JV::from).collect::<Vec<_>>()),
},
RV::Ext(i, v) => serde_json::json!({
"type": i,
"data": v
}),
RV::Nil => JV::Bool(false),
}
}
pub fn msgpack_to_json_val(msg: Vec<u8>, bin_str: char) -> serde_json::Value {
use bytes::Buf;
BIN_STR.set(bin_str).unwrap();
let bytes = bytes::Bytes::from(msg);
if let Ok(v) = rmpv::decode::value::read_value(&mut bytes.reader()) {
msgpack_to_json(v)
} else {
serde_json::json!({ "error": "Could not decode data" })
}
}
pub fn configure_table_style(table: &mut Table<'_>, num_rows: usize) {
table.style = empty_table_style();
table.separate_rows = false;
table.max_column_width = termsize::get()
.map(|size| size.cols.saturating_sub(4) as usize)
.unwrap_or(MAX_TERMINAL_WIDTH)
/ num_rows;
}
fn empty_table_style() -> TableStyle {
TableStyle {
top_left_corner: ' ',
top_right_corner: ' ',
bottom_left_corner: ' ',
bottom_right_corner: ' ',
outer_left_vertical: ' ',
outer_right_vertical: ' ',
outer_bottom_horizontal: ' ',
outer_top_horizontal: ' ',
intersection: ' ',
vertical: ' ',
horizontal: ' ',
}
}
mod test {
#[test]
fn test_safe_base64_parse_option() {
let base64_option = "config_b64=eyJhZGRyZXNzIjogIjAuMC4wLjA6ODA4MCJ9Cg==".to_string();
let mut expected = std::collections::HashMap::new();
expected.insert(
"config_b64".to_string(),
"eyJhZGRyZXNzIjogIjAuMC4wLjA6ODA4MCJ9Cg==".to_string(),
);
let output = wash_lib::cli::input_vec_to_hashmap(vec![base64_option]).unwrap();
assert_eq!(expected, output);
}
}