#![forbid(unsafe_code)]

use clap::{crate_authors, crate_version, Parser};
use crossbeam::channel::unbounded;
use json5::from_str;
use notify::{RecommendedWatcher, RecursiveMode, Watcher};
use serde_json::Value;
use std::env;
use std::error::Error;
use std::fs::{create_dir_all, read_dir, read_to_string, write};
use std::path::{Path, PathBuf};
use std::process;
use tera::{Context, Error as TeraError, Tera};

const DEFAULT_TEMPLATE_DIR: &str = "templates";
const DEFAULT_OUTPUT_DIR: &str = "output";

fn main() -> Result<(), Box<dyn Error>> {
    process::exit(match run() {
        Ok(_) => 0,
        Err(e) => {
            eprintln!("{}", e);
            1
        }
    })
}

fn env_or_default(env_name: &str, default: &str) -> String {
    env::var(env_name).unwrap_or_else(|_| String::from(default))
}

/// Universal resume formatter
#[derive(Parser)]
#[clap(version = crate_version!(), author = crate_authors!())]
struct Args {
    /// Watch for changes
    #[clap(short)]
    watch: bool,
    /// Specifies which output format you want
    #[clap(short, long, multiple_occurrences = true)]
    output: Vec<String>,
}

fn run() -> Result<(), Box<dyn Error>> {
    let config: Value = from_str(&read_to_string("config.json5")?)?;
    let template_dir = env_or_default("PANRES_TEMPLATE_DIR", DEFAULT_TEMPLATE_DIR);
    let output_dir = env_or_default("PANRES_OUTPUT_DIR", DEFAULT_OUTPUT_DIR);

    let args = Args::parse();

    let tera = Tera::new(&format!("{template_dir}/**/*"))?;
    let mut context = Context::new();
    context.insert("config", &config);
    let template_dir = PathBuf::from(template_dir);

    output(&tera, &context, &output_dir, &args.output, &template_dir)?;

    if args.watch {
        watch_mode(tera, context, output_dir, args.output, &template_dir)?;
    }

    Ok(())
}

/// Usually never returns, unless there was an error initializing the watcher.
/// Handles watching for file changes, and reloads tera if there's a change.
fn watch_mode(
    mut engine: Tera,
    context: Context,
    dir: String,
    outputs: Vec<String>,
    template_dir: &Path,
) -> Result<(), Box<dyn Error>> {
    let (tx, rx) = unbounded();
    let mut watcher: RecommendedWatcher = Watcher::new(move |res| tx.send(res).unwrap())?;
    watcher.watch(template_dir, RecursiveMode::Recursive)?;

    for res in rx {
        match res {
            Err(e) => println!("{}", e),
            Ok(event) => {
                println!("got event {:?}", event);
                engine.full_reload().expect("Failed to perform full reload");
                output(&engine, &context, &dir, &outputs, template_dir)
                    .expect("Failed to call output");
            }
        }
    }

    Ok(())
}

/// Parses the output values and generates a file for each format specified or
/// found, if told to generate all outputs.
fn output(
    engine: &Tera,
    context: &Context,
    dir: &str,
    outputs: &[String],
    template_dir: &Path,
) -> Result<(), Box<dyn Error>> {
    if outputs.contains(&String::from("all")) {
        for output in read_dir(template_dir)? {
            write_file(engine, context, dir, &output?.file_name().to_str().unwrap())?;
        }
    } else {
        for output in outputs {
            write_file(engine, context, dir, &output)?;
        }
    }

    Ok(())
}

/// Write out the post-template file to the output dir.
fn write_file(engine: &Tera, context: &Context, dir: &str, format: &str) -> Result<(), TeraError> {
    create_dir_all(dir).expect("Could not create output dir");
    write(
        format!("{}/{}", dir, format),
        engine.render(format, context)?,
    )
    .expect("to be able to write to output folder");
    Ok(())
}