use anyhow::{anyhow, Context, Result};
use rand::seq::SliceRandom;
use std::fs;
use std::path;
use std::process;
use std::str;
use std::thread;
use crate::config::Config;
use crate::find::find;
use crate::scheme::Scheme;
fn random(values: Vec<path::PathBuf>) -> Result<path::PathBuf> {
let chosen = values.choose(&mut rand::thread_rng()).ok_or_else(|| {
anyhow!(
"Scheme not found. Check if it exists, or run update schemes if you didn't already."
)
})?;
Ok(chosen.to_path_buf())
}
fn run_hook(command: &str, verbose: bool) -> Result<()> {
if verbose && command != "" {
println!("running {}", command);
}
let command_vec = shell_words::split(command)?;
if !command_vec.is_empty() {
if command_vec.len() == 1 {
process::Command::new(&command_vec[0])
.stdout(process::Stdio::null())
.stderr(process::Stdio::null())
.status()
.with_context(|| format!("Couldn't run hook '{}'", command))?;
} else {
process::Command::new(&command_vec[0])
.args(&command_vec[1..])
.stdout(process::Stdio::null())
.stderr(process::Stdio::null())
.status()
.with_context(|| format!("Couldn't run hook '{}'", command))?;
}
}
Ok(())
}
fn replace_delimiter(
file_content: &str,
start: &str,
end: &str,
built_template: &str,
) -> Result<String> {
let mut changed_content = String::new();
let mut found_start = false;
let mut found_end = false;
let mut appended = false;
for line in file_content.lines() {
if found_start && !found_end {
if !appended {
changed_content.push_str(&built_template);
appended = true;
}
if line.trim().to_lowercase().eq(&end) {
changed_content.push_str(&format!("{}\n", line));
found_end = true;
}
} else {
changed_content.push_str(&format!("{}\n", line));
if line.trim().to_lowercase().eq(&start) {
found_start = true
}
}
}
if !found_start {
Err(anyhow!("Couldn't find starting string."))
} else if !found_end {
Err(anyhow!("Couldn't find ending string."))
} else {
Ok(changed_content)
}
}
fn build_template(template_base: String, scheme: &Scheme) -> Result<String> {
let mut built_template = template_base;
built_template = built_template
.replace("{{scheme-name}}", &scheme.name)
.replace("{{scheme-author}}", &scheme.author)
.replace("{{scheme-slug}}", &scheme.slug);
for (name, color) in scheme.colors.iter().enumerate() {
let hex = String::from(color);
let rgb = hex::decode(&hex)?;
built_template = built_template
.replace(
&format!("{{{{base0{:X}-hex}}}}", name),
&hex,
)
.replace(
&format!("{{{{base0{:X}-hex-r}}}}", name),
&hex[0..2],
)
.replace(
&format!("{{{{base0{:X}-hex-g}}}}", name),
&hex[2..4],
)
.replace(
&format!("{{{{base0{:X}-hex-b}}}}", name),
&hex[4..6],
)
.replace(
&format!("{{{{base0{:X}-hex-bgr}}}}", name),
&format!("{}{}{}", &hex[4..6], &hex[2..4], &hex[0..2]),
)
.replace(
&format!("{{{{base0{:X}-rgb-r}}}}", name),
&format!("{}", rgb[0]),
)
.replace(
&format!("{{{{base0{:X}-rgb-g}}}}", name),
&format!("{}", rgb[1]),
)
.replace(
&format!("{{{{base0{:X}-rgb-b}}}}", name),
&format!("{}", rgb[2]),
)
.replace(
&format!("{{{{base0{:X}-dec-r}}}}", name),
&format!("{:.2}", (rgb[0] as f64) / (255_f64)),
)
.replace(
&format!("{{{{base0{:X}-dec-g}}}}", name),
&format!("{:.2}", (rgb[1] as f64) / (255_f64)),
)
.replace(
&format!("{{{{base0{:X}-dec-b}}}}", name),
&format!("{:.2}", (rgb[2] as f64) / (255_f64)),
)
}
Ok(built_template)
}
pub fn apply(
patterns: Vec<&str>,
base_dir: &path::Path,
config_path: &path::Path,
verbose: bool,
) -> Result<()> {
let mut schemes = Vec::new();
for pattern in patterns {
let found_schemes = find(pattern, &base_dir.join("base16").join("schemes"))?;
for found_scheme in found_schemes {
schemes.push(found_scheme);
}
}
schemes.sort();
schemes.dedup();
let scheme_file = random(schemes)?;
let scheme_slug = scheme_file
.file_stem()
.ok_or_else(|| anyhow!("Couldn't get scheme name."))?
.to_str()
.ok_or_else(|| anyhow!("Couldn't convert scheme file name."))?;
let scheme_contents = &fs::read_to_string(&scheme_file)
.with_context(|| format!("Couldn't read scheme file at {:?}.", scheme_file))?;
let scheme = Scheme::from_str(scheme_contents, scheme_slug)?;
if verbose {
println!(
"Using scheme: {} ({}), by {}",
scheme.name, scheme.slug, scheme.author
);
println!();
}
if !config_path.exists() {
eprintln!("Config {:?} doesn't exist, creating", config_path);
let default_content = match fs::read_to_string(path::Path::new("/etc/flavours.conf")) {
Ok(content) => content,
Err(_) => String::from(""),
};
let config_path_parent = config_path
.parent()
.with_context(|| format!("Couldn't get parent directory of {:?}", config_path))?;
fs::create_dir_all(config_path_parent).with_context(|| {
format!(
"Couldn't create configuration file parent directory {:?}",
config_path_parent
)
})?;
fs::write(config_path, default_content)
.with_context(|| format!("Couldn't create configuration file at {:?}", config_path))?;
}
let config_contents = fs::read_to_string(config_path)
.with_context(|| format!("Couldn't read configuration file {:?}.", config_path))?;
let config = Config::from_str(&config_contents)?;
let mut hooks = Vec::new();
let items = config.item.ok_or_else(|| anyhow!("Couldn't get items from config file. Check the default file or github for config examples."))?;
for item in items.iter() {
let template = &item.template;
let subtemplate = match &item.subtemplate {
Some(value) => String::from(value),
None => String::from("default"),
};
let hook = match &item.hook {
Some(value) => String::from(value),
None => String::from(""),
};
let rewrite = match &item.rewrite {
Some(value) => *value,
None => false,
};
let start = match &item.start {
Some(value) => String::from(value),
None => String::from("# Start flavours"),
}
.trim()
.to_lowercase();
let end = match &item.end {
Some(value) => String::from(value),
None => String::from("# End flavours"),
}
.trim()
.to_lowercase();
let subtemplate_file = &base_dir
.join("base16")
.join("templates")
.join(&template)
.join("templates")
.join(format!("{}.mustache", subtemplate));
let template_content = fs::read_to_string(subtemplate_file)
.with_context(||format!("Couldn't read template {}/{} at {:?}. Check if the correct template/subtemplate was specified, and run the update templates command if you didn't already.", template, subtemplate, subtemplate_file))?;
let built_template = build_template(template_content, &scheme)
.context("Couldn't replace placeholders. Check if all colors on the specified scheme file are valid (don't include a leading '#').")?;
let file = path::Path::new(&shellexpand::full(&item.file)?.to_string())
.canonicalize()
.with_context(|| format!("Invalid file to write: {}.", item.file))?;
if rewrite {
fs::write(&file, built_template)
.with_context(|| format!("Couldn't write to file {:?}.", file))?;
if verbose {
println!("Wrote {}/{} on: {:?}", template, subtemplate, file)
}
} else {
let file_content = fs::read_to_string(&file)?;
match replace_delimiter(&file_content, &start, &end, &built_template) {
Ok(content) => fs::write(&file, content)
.with_context(|| format!("Couldn't write to file {:?}", file))?,
Err(error) => eprintln!("Couldn't replace lines in {:?}: {}", file, error),
}
if verbose {
println!("Wrote {}/{} on {:?}", template, subtemplate, file);
}
}
hooks.push(thread::spawn(move || run_hook(&hook, verbose)));
}
let last_scheme_file = &base_dir.join("lastscheme");
fs::write(&last_scheme_file, &scheme.slug)
.with_context(|| "Couldn't update applied scheme name")?;
while !hooks.is_empty() {
hooks
.pop()
.ok_or_else(|| anyhow!("Couldn't pop hooks."))?
.join()
.unwrap()?;
}
if verbose {
println!("Successfully applied {}", &scheme.slug);
}
Ok(())
}