flowey_lib_hvlite/
test_nextest_unit_tests_archive.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
53
54
55
56
57
58
59
60
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

//! Run cargo-nextest based unit tests from a pre-built archive.
//!
//! In the context of hvlite, we consider a "unit-test" to be any test which
//! doesn't require any special dependencies (e.g: additional binaries, disk
//! images, etc...), and can be run simply by invoking the test bin itself.

use crate::build_nextest_unit_tests::NextestUnitTestArchive;
use crate::run_cargo_nextest_run::NextestProfile;
use flowey::node::prelude::*;
use flowey_lib_common::run_cargo_nextest_run::TestResults;

flowey_request! {
    pub struct Request {
        /// Pre-built unit tests nextest archive
        pub nextest_archive_file: ReadVar<NextestUnitTestArchive>,
        /// Nextest profile to use when running the source code
        pub nextest_profile: NextestProfile,
        /// Results of running the tests
        pub results: WriteVar<TestResults>,
    }
}

new_flow_node!(struct Node);

impl FlowNode for Node {
    type Request = Request;

    fn imports(ctx: &mut ImportCtx<'_>) {
        ctx.import::<crate::run_cargo_nextest_run::Node>();
    }

    fn emit(requests: Vec<Self::Request>, ctx: &mut NodeCtx<'_>) -> anyhow::Result<()> {
        for Request {
            nextest_archive_file,
            nextest_profile,
            results,
        } in requests
        {
            let nextest_archive = nextest_archive_file.map(ctx, |x| x.0);

            ctx.req(crate::run_cargo_nextest_run::Request {
                friendly_name: "unit-tests".into(),
                run_kind: flowey_lib_common::run_cargo_nextest_run::NextestRunKind::RunFromArchive(
                    nextest_archive,
                ),
                nextest_profile,
                nextest_filter_expr: None,
                run_ignored: false,
                extra_env: None,
                pre_run_deps: Vec::new(), // FIXME: ensure all deps are installed
                results,
            })
        }

        Ok(())
    }
}