xtask/tasks/fmt/
verify_flowey.rs

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
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

use crate::Xtask;
use anyhow::Context;
use clap::Parser;

#[derive(Parser)]
#[clap(about = "Ensure all flowey pipelines are up to date")]
pub struct VerifyFlowey {
    /// Fix any out-of-date pipelines
    #[clap(long)]
    pub fix: bool,
}

impl VerifyFlowey {
    pub fn new(fix: bool) -> Self {
        Self { fix }
    }
}

impl Xtask for VerifyFlowey {
    fn run(self, ctx: crate::XtaskCtx) -> anyhow::Result<()> {
        // need to go through all this rigamarole because `cargo --quiet
        // xflowey regen` doesn't do what you'd hope it'd do
        let cmd = {
            let data = fs_err::read_to_string(ctx.root.join(".cargo/config.toml"))?;
            let mut cmd = None;
            for ln in data.lines() {
                if let Some(ln) = ln.trim().strip_prefix(r#"xflowey = ""#) {
                    let alias = ln
                        .strip_suffix('"')
                        .context("invalid .cargo/config.toml")?
                        .split(' ')
                        .map(|s| s.to_owned())
                        .collect::<Vec<_>>();
                    cmd = Some(alias);
                }
            }
            cmd.context("could not find `xflowey` alias in .cargo/config.toml")?
        };

        let check = (!self.fix).then_some("--check");

        let sh = xshell::Shell::new()?;
        xshell::cmd!(sh, "cargo --quiet {cmd...} regen --quiet {check...}")
            .quiet()
            .run()?;

        Ok(())
    }
}