quelch 0.11.1

Ingest data from Jira, Confluence, and more directly into Azure AI Search
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

/// Wrapper around `az deployment group create` that applies a Bicep template.
///
/// Entry point: [`run`].
use std::path::Path;

// ---------------------------------------------------------------------------
// Public types
// ---------------------------------------------------------------------------

/// The outcome of a successful `az deployment group create` call.
#[derive(Debug)]
pub struct ApplyOutcome {
    /// The `provisioningState` field from the ARM response, e.g. `"Succeeded"`.
    pub provisioning_state: String,
    /// Raw JSON body returned by `az`.
    pub raw: serde_json::Value,
}

// ---------------------------------------------------------------------------
// Errors
// ---------------------------------------------------------------------------

/// Errors that can occur while running `az deployment group create`.
#[derive(Debug, thiserror::Error)]
pub enum ApplyError {
    #[error("az command failed (exit {code}): {stderr}")]
    AzFailed { code: i32, stderr: String },
    #[error("io: {0}")]
    Io(#[from] std::io::Error),
    #[error("json: {0}")]
    Json(#[from] serde_json::Error),
}

// ---------------------------------------------------------------------------
// Entry point
// ---------------------------------------------------------------------------

/// Run `az deployment group create` to apply a Bicep template.
///
/// This shells out to the `az` CLI, parses its JSON output, and returns the
/// provisioning state. It will fail if `az` is not installed or the user is
/// not logged in.
///
/// The `--no-prompt` flag prevents `az` from asking for parameter values
/// interactively; callers must supply all required parameters in the template
/// or via `--parameters`.
pub fn run(resource_group: &str, bicep_path: &Path) -> Result<ApplyOutcome, ApplyError> {
    let output = std::process::Command::new("az")
        .args([
            "deployment",
            "group",
            "create",
            "--resource-group",
            resource_group,
            "--template-file",
            bicep_path.to_str().unwrap_or(""),
            "--no-prompt",
            "true",
            "--output",
            "json",
        ])
        .output()?;

    if !output.status.success() {
        return Err(ApplyError::AzFailed {
            code: output.status.code().unwrap_or(-1),
            stderr: String::from_utf8_lossy(&output.stderr).into_owned(),
        });
    }

    let result: serde_json::Value = serde_json::from_slice(&output.stdout)?;

    let provisioning_state = result
        .pointer("/properties/provisioningState")
        .and_then(|v| v.as_str())
        .unwrap_or("Unknown")
        .to_string();

    Ok(ApplyOutcome {
        provisioning_state,
        raw: result,
    })
}

// ---------------------------------------------------------------------------
// Tests
// ---------------------------------------------------------------------------

#[cfg(test)]
mod tests {
    use super::*;

    /// Verify that `ApplyError::AzFailed` formats correctly.
    #[test]
    fn apply_error_formats_code_and_stderr() {
        let err = ApplyError::AzFailed {
            code: 1,
            stderr: "some error".to_string(),
        };
        let msg = err.to_string();
        assert!(msg.contains("exit 1"), "error must mention exit code");
        assert!(msg.contains("some error"), "error must include stderr");
    }
}