use std::{
fs,
io::{self},
path::{Path, PathBuf},
};
use serde::Serialize;
use toml::Table;
use crate::{config::Config, profile::Profile};
mod tests;
#[derive(Debug, Clone, Serialize)]
pub struct Context {
pub working_dir: PathBuf,
variables: Table,
user_variables: Table,
pub profile: Option<Profile>,
}
impl Context {
pub fn get_variable(&self, key: &str) -> Option<&toml::Value> {
self.variables.get(key)
}
pub fn get_user_variable(&self, key: &str) -> Option<&toml::Value> {
self.user_variables.get(key)
}
pub fn get_profile_variable(&self, key: &str) -> Option<&toml::Value> {
if let Some(profile) = &self.profile {
profile.variables.get(key)
} else {
None
}
}
pub fn get_context_variable(&self, key: &str) -> Option<&toml::Value> {
self.get_user_variable(key).or_else(|| {
self.get_profile_variable(key)
.or_else(|| self.get_variable(key))
})
}
pub fn set_profile(&mut self, profile: Option<Profile>) {
self.profile = profile;
}
pub fn get_prompted_variables(
&mut self,
conf: &Config,
packages: &Option<Vec<String>>,
) -> Result<Table, anyhow::Error> {
self.get_prompted_variables_with_io(
conf,
packages,
&mut std::io::stdin().lock(),
&mut std::io::stdout(),
)
}
pub(crate) fn get_prompted_variables_with_io<R: io::BufRead, W: io::Write>(
&mut self,
conf: &Config,
packages: &Option<Vec<String>>,
reader: &mut R,
writer: &mut W,
) -> Result<Table, anyhow::Error> {
let mut prompted_vars = self.user_variables.clone();
let mut prompts = conf.prompts.clone();
if let Some(profile) = &self.profile {
for (key, prompt) in profile.prompts.iter() {
prompts.insert(key.clone(), prompt.clone());
}
}
if let Ok(filtered_packages) = conf.filter_packages(self, packages) {
for (_, package) in filtered_packages.iter() {
for (key, prompt) in package.prompts.iter() {
prompts.insert(key.clone(), prompt.clone());
}
}
}
let mut dirty = false;
for (key, prompt) in prompts.iter() {
if !prompted_vars.contains_key(key) {
match get_prompted_variables(prompt, &mut *reader, &mut *writer) {
Ok(input) => {
prompted_vars.insert(key.clone(), toml::Value::String(input));
dirty = true;
}
Err(e) => {
eprintln!("Error getting prompted variable '{}': {}", key, e);
}
}
}
}
if !dirty {
return Ok(prompted_vars);
}
let path = self.working_dir.join(".uservariables.toml");
let toml_string = toml::to_string(&prompted_vars)?;
fs::write(&path, toml_string)?;
self.user_variables = prompted_vars.clone();
Ok(prompted_vars)
}
pub fn parse_uservariables(cwd: &Path) -> Result<Table, anyhow::Error> {
let path = cwd.join(".uservariables.toml");
if path.exists() {
let content = fs::read_to_string(&path)?;
let table: Table = toml::de::from_str(&content).map_err(|e| {
anyhow::anyhow!(
"Failed to parse .uservariables.toml at '{}': {}",
path.display(),
e
)
})?;
Ok(table)
} else {
Ok(Table::new())
}
}
pub fn new(working_dir: &Path) -> Result<Self, anyhow::Error> {
let mut variables = Table::new();
for (key, value) in std::env::vars() {
variables.insert(key, toml::Value::String(value));
}
let user_variables = Self::parse_uservariables(working_dir)?;
Ok(Self {
working_dir: working_dir.to_path_buf(),
variables,
user_variables,
profile: None,
})
}
pub fn get_variables(&self) -> &Table {
&self.variables
}
pub fn get_user_variables(&self) -> &Table {
&self.user_variables
}
pub fn get_context_variables(&self) -> Table {
let mut context_vars = self.variables.clone();
if let Some(profile) = &self.profile {
context_vars.extend(profile.variables.clone());
}
context_vars.extend(self.user_variables.clone());
context_vars
}
pub fn extend_variables(&mut self, new_vars: Table) {
self.variables.extend(new_vars);
}
pub fn print_variables(&self) {
let variables = &self.get_context_variables();
println!("User Variables:");
if variables.is_empty() {
println!(" (none)");
} else {
for (key, value) in variables.iter() {
print_variable(key, value, 1);
}
}
}
}
pub fn print_variable(key: &str, value: &toml::Value, level: usize) {
let indent = " ".repeat(level);
match value {
toml::Value::String(s) => {
println!("{}{} = {}", indent, key, s);
}
toml::Value::Integer(i) => {
println!("{}{} = {}", indent, key, i);
}
toml::Value::Float(f) => {
println!("{}{} = {}", indent, key, f);
}
toml::Value::Boolean(b) => {
println!("{}{} = {}", indent, key, b);
}
toml::Value::Table(t) => {
println!("{}{} =", indent, key);
for (k, v) in t.iter() {
print_variable(k, v, level + 1);
}
}
toml::Value::Array(arr) => {
println!("{}{} = [", indent, key);
for v in arr.iter() {
let item_indent = " ".repeat(level + 1);
match v {
toml::Value::String(s) => {
println!("{}- {}", item_indent, s);
}
toml::Value::Integer(i) => {
println!("{}- {}", item_indent, i);
}
toml::Value::Float(f) => {
println!("{}- {}", item_indent, f);
}
toml::Value::Boolean(b) => {
println!("{}- {}", item_indent, b);
}
toml::Value::Table(_) | toml::Value::Array(_) => {
println!("{}-", item_indent);
print_variable("", v, level + 2);
}
_ => {
println!("{}- {:?}", item_indent, v);
}
}
}
println!("{}]", indent);
}
_ => {
println!("{}{} = {:?}", indent, key, value);
}
}
}
fn get_prompted_variables<R: io::BufRead, W: io::Write>(
prompt: &str,
mut reader: R,
mut writer: W,
) -> anyhow::Result<String> {
writer.write_all(format!("{}\n>>> ", prompt).as_bytes())?;
writer.flush()?;
let mut input = String::new();
reader.read_line(&mut input)?;
Ok(input)
}