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

//! Configures the repo source required by [`crate::git_checkout_openvmm_repo`]

use flowey::node::prelude::*;

flowey_request! {
    #[derive(Clone)]
    pub struct Params {
        pub hvlite_repo_source: flowey_lib_common::git_checkout::RepoSource,
    }
}

new_simple_flow_node!(struct Node);

impl SimpleFlowNode for Node {
    type Request = Params;

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

    fn process_request(request: Self::Request, ctx: &mut NodeCtx<'_>) -> anyhow::Result<()> {
        let Params { hvlite_repo_source } = request;

        if matches!(ctx.backend(), FlowBackend::Local) {
            ctx.req(
                flowey_lib_common::git_checkout::Request::LocalOnlyRequireExistingClones(
                    !matches!(
                        hvlite_repo_source,
                        flowey_lib_common::git_checkout::RepoSource::LocalOnlyNewClone { .. }
                    ),
                ),
            );
        }

        ctx.req(flowey_lib_common::git_checkout::Request::RegisterRepo {
            repo_id: "openvmm".into(),
            repo_src: hvlite_repo_source,
            allow_persist_credentials: false,
            depth: Some(1),           // shallow fetch
            pre_run_deps: Vec::new(), // no special auth required
        });

        ctx.req(crate::git_checkout_openvmm_repo::req::SetRepoId(
            ReadVar::from_static("openvmm".into()),
        ));

        Ok(())
    }
}