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

//! Gets the merge commit of a PR to base branch

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

flowey_request! {
    pub struct Request {
        pub repo_path: ReadVar<PathBuf>,
        pub merge_commit: WriteVar<String>,
        pub base_branch: String,
    }
}

new_simple_flow_node!(struct Node);

impl SimpleFlowNode for Node {
    type Request = Request;

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

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

        ctx.emit_rust_step("get merge commit", move |ctx| {
            let merge_commit = merge_commit.claim(ctx);
            let repo_path = repo_path.claim(ctx);

            move |rt| {
                let sh = xshell::Shell::new()?;
                let repo_path = rt.read(repo_path);

                sh.change_dir(repo_path);

                xshell::cmd!(sh, "git fetch --unshallow").run()?;

                xshell::cmd!(sh, "git fetch origin {base_branch}").run()?;
                let commit = xshell::cmd!(sh, "git merge-base HEAD origin/{base_branch}").read()?;
                rt.write(merge_commit, &commit);

                Ok(())
            }
        });

        Ok(())
    }
}