1use crate::environment::EnvironmentErrorMessage;
2use std::process::ExitStatus;
3
4#[cfg(not(any(test, feature = "test-support")))]
5use {collections::HashMap, std::path::Path, util::ResultExt};
6
7#[derive(Clone)]
8pub enum DirenvError {
9 NotFound,
10 FailedRun,
11 NonZeroExit(ExitStatus, Vec<u8>),
12 EmptyOutput,
13 InvalidJson,
14}
15
16impl From<DirenvError> for Option<EnvironmentErrorMessage> {
17 fn from(value: DirenvError) -> Self {
18 match value {
19 DirenvError::NotFound => None,
20 DirenvError::FailedRun | DirenvError::NonZeroExit(_, _) => {
21 Some(EnvironmentErrorMessage(String::from(
22 "Failed to run direnv. See logs for more info",
23 )))
24 }
25 DirenvError::EmptyOutput => None,
26 DirenvError::InvalidJson => Some(EnvironmentErrorMessage(String::from(
27 "Direnv returned invalid json. See logs for more info",
28 ))),
29 }
30 }
31}
32
33#[cfg(not(any(test, feature = "test-support")))]
34pub async fn load_direnv_environment(dir: &Path) -> Result<HashMap<String, String>, DirenvError> {
35 let Ok(direnv_path) = which::which("direnv") else {
36 return Err(DirenvError::NotFound);
37 };
38
39 let Some(direnv_output) = smol::process::Command::new(direnv_path)
40 .args(["export", "json"])
41 .env("TERM", "dumb")
42 .current_dir(dir)
43 .output()
44 .await
45 .log_err()
46 else {
47 return Err(DirenvError::FailedRun);
48 };
49
50 if !direnv_output.status.success() {
51 log::error!(
52 "Loading direnv environment failed ({}), stderr: {}",
53 direnv_output.status,
54 String::from_utf8_lossy(&direnv_output.stderr)
55 );
56 return Err(DirenvError::NonZeroExit(
57 direnv_output.status,
58 direnv_output.stderr,
59 ));
60 }
61
62 let output = String::from_utf8_lossy(&direnv_output.stdout);
63 if output.is_empty() {
64 return Err(DirenvError::EmptyOutput);
65 }
66
67 let Some(env) = serde_json::from_str(&output).log_err() else {
68 return Err(DirenvError::InvalidJson);
69 };
70
71 Ok(env)
72}