tera-rand 0.2.2

use crate::common::parse_arg;
use crate::error::{empty_file, internal_error, missing_arg, read_file_error};
use dashmap::mapref::one::Ref;
use dashmap::DashMap;
use lazy_static::lazy_static;
use rand::{rng, Rng};
use std::collections::HashMap;
use std::fs::File;
use std::io::{BufRead, BufReader};
use tera::{to_value, Result, Value};

lazy_static! {
    static ref FILE_CACHE: DashMap<String, Vec<String>> = DashMap::new();
}

/// A Tera function to sample a random value from a line-delimited file of strings. The filepath
/// should be passed in as an argument to the `path` parameter.
///
/// Note that the contents of the filepath is read only once and cached.
///
/// # Example usage
///
/// ```edition2021
/// use tera::{Context, Tera};
/// use tera_rand::random_from_file;
///
/// let mut tera: Tera = Tera::default();
/// tera.register_function("random_from_file", random_from_file);
/// let context: Context = Context::new();
///
/// let rendered: String = tera
///     .render_str(r#"{{ random_from_file(path="resources/test/addresses.txt") }}"#, &context)
///     .unwrap();
/// ```
pub fn random_from_file(args: &HashMap<String, Value>) -> Result<Value> {
    let filepath: Option<String> = parse_arg(args, "path")?;
    let filepath: String = filepath.ok_or_else(|| missing_arg("path"))?;

    let possible_values_ref: Ref<String, Vec<String>> = read_all_file_lines(filepath)?;
    let possible_values: &Vec<String> = possible_values_ref.value();

    let index_to_sample: usize = rng().random_range(0usize..possible_values.len());
    convert_line_to_json_value(possible_values_ref.key(), possible_values, index_to_sample)
}

/// A Tera function to sample a specific value from a line-delimited file of strings. The filepath
/// should be passed in as an argument to the `path` parameter. The 0-indexed line number should
/// be passed in as an argument to the `line_num` parameter.
///
/// Note that the contents of the filepath is read only once and cached.
///
/// # Example usage
///
/// ```edition2021
/// use tera::{Context, Tera};
/// use tera_rand::line_from_file;
/// let mut tera: Tera = Tera::default();
/// tera.register_function("line_from_file", line_from_file);
/// let context: Context = Context::new();
/// let rendered: String = tera
///     .render_str(
///         r#"{{ line_from_file(path="resources/test/addresses.txt", line_num=2) }}"#,
///         &context
///     )
///     .unwrap();
/// ```
pub fn line_from_file(args: &HashMap<String, Value>) -> Result<Value> {
    let filepath_opt: Option<String> = parse_arg(args, "path")?;
    let filepath: String = filepath_opt.ok_or_else(|| missing_arg("path"))?;

    let line_num: Option<usize> = parse_arg(args, "line_num")?;
    let line_num: usize = line_num.ok_or_else(|| missing_arg("line_num"))?;

    let possible_values_ref = read_all_file_lines(filepath)?;
    let possible_values: &Vec<String> = possible_values_ref.value();

    convert_line_to_json_value(possible_values_ref.key(), possible_values, line_num)
}

fn convert_line_to_json_value(
    filename: &String,
    possible_values: &Vec<String>,
    line_num: usize
) -> Result<Value> {
    match possible_values.get(line_num) {
        Some(sampled_value) => {
            let json_value = to_value(sampled_value)?;
            Ok(json_value)
        }
        None => {
            Err(internal_error(format!(
                "Unable to sample value with line number {} for file at path {}",
                line_num, filename
            )))
        },
    }
}

// Read the entire file in and store the individual lines if we haven't seen it before.
// Otherwise, return the existing lines.
fn read_all_file_lines<'a>(filepath: String) -> Result<Ref<'a, String, Vec<String>>> {
    if !FILE_CACHE.contains_key(&filepath) {
        let input_file: File =
            File::open(&filepath).map_err(|source| read_file_error(filepath.clone(), source))?;
        let buf_reader: BufReader<File> = BufReader::new(input_file);

        let mut file_values: Vec<String> = Vec::new();
        for line_result in buf_reader.lines() {
            let line: String =
                line_result.map_err(|source| read_file_error(filepath.clone(), source))?;
            file_values.push(line);
        }

        if file_values.is_empty() {
            return Err(empty_file(filepath));
        }
        FILE_CACHE.insert(filepath.clone(), file_values);
    }
    FILE_CACHE.get(&filepath)
        .ok_or_else(|| internal_error(
            format!("File cache did not contain an entry for file {filepath}")
        ))
}

#[cfg(test)]
mod tests {
    use crate::common::tests::{test_tera_rand_function, test_tera_rand_function_returns_error};
    use crate::file::*;
    use tracing_test::traced_test;

    #[test]
    #[traced_test]
    fn test_random_from_file() {
        test_tera_rand_function(
            random_from_file,
            "random_from_file",
            r#"{ "some_field": "{{ random_from_file(path="resources/test/days.txt") }}" }"#,
            r#"\{ "some_field": "(Monday|Tuesday|Wednesday|Thursday|Friday|Saturday|Sunday)" }"#,
        )
    }

    #[test]
    #[traced_test]
    fn test_with_file_with_one_item() {
        test_tera_rand_function(
            random_from_file,
            "random_from_file",
            r#"{ "some_field": "{{ random_from_file(path="resources/test/file_with_one_item.txt") }}" }"#,
            r#"\{ "some_field": "item" }"#,
        )
    }

    #[test]
    #[traced_test]
    fn test_error_with_empty_file() {
        test_tera_rand_function_returns_error(
            random_from_file,
            "random_from_file",
            r#"{ "some_field": "{{ random_from_file(path="resources/test/empty_file.txt") }}" }"#,
        )
    }
}