1#[cfg(test)]
7#[path = "./file_test.rs"]
8mod file_test;
9
10use crate::bulk;
11use crate::errors::EnvmntError;
12use crate::types::EnvmntResult;
13use fsio::error::FsIOError;
14use fsio::file::read_text_file;
15use indexmap::IndexMap;
16
17pub(crate) fn empty_evaluate_fn(key: String, value: String) -> Option<(String, String)> {
18 Some((key, value))
19}
20
21pub(crate) fn load_file(file: &str) -> EnvmntResult<()> {
22 evaluate_and_load_file(file, empty_evaluate_fn)
23}
24
25pub(crate) fn evaluate_and_load_file<F>(file: &str, evaluate: F) -> EnvmntResult<()>
26where
27 F: Fn(String, String) -> Option<(String, String)>,
28{
29 match parse_file(file) {
30 Ok(env) => {
31 bulk::evaluate_and_set_all(&env, evaluate);
32
33 Ok(())
34 }
35 Err(error) => Err(error),
36 }
37}
38
39pub(crate) fn parse_file(file: &str) -> EnvmntResult<IndexMap<String, String>> {
40 match read_text_file(file) {
41 Ok(env_content) => {
42 let env = parse_env_file_content(&env_content);
43
44 Ok(env)
45 }
46 Err(error) => Err(create_read_file_error(error)),
47 }
48}
49
50fn create_read_file_error(error: FsIOError) -> EnvmntError {
51 EnvmntError::ReadFile("Unable to read file.", error)
52}
53
54pub(crate) fn parse_env_file_content(env_content: &str) -> IndexMap<String, String> {
55 let mut env: IndexMap<String, String> = IndexMap::new();
56
57 let lines: Vec<&str> = env_content.split('\n').collect();
58
59 for mut line in lines {
60 line = line.trim();
61
62 if line.len() > 0 && !line.starts_with("#") {
63 let env_part: Vec<&str> = line.splitn(2, '=').collect();
64
65 if env_part.len() == 2 {
66 let key = env_part[0].trim().to_string();
67 let mut value = env_part[1].trim().to_string();
68
69 value = value
70 .replace("\\\"", "\"")
71 .replace("\\n", "\n")
72 .replace("\\r", "\r");
73
74 if value.starts_with('"') && value.ends_with('"') {
75 value.remove(0);
76 value.pop();
77 }
78
79 env.insert(key, value);
80 }
81 }
82 }
83
84 env
85}