flowey_lib_hvlite/_jobs/
cfg_gh_azure_login.rs1use flowey::node::prelude::*;
7
8flowey_request! {
9 #[derive(Clone)]
10 pub struct Params {
11 pub client_id: GhUserSecretVar,
12 pub tenant_id: GhUserSecretVar,
13 pub subscription_id: GhUserSecretVar,
14 }
15}
16
17new_simple_flow_node!(struct Node);
18
19impl SimpleFlowNode for Node {
20 type Request = Params;
21
22 fn imports(ctx: &mut ImportCtx<'_>) {
23 ctx.import::<flowey_lib_common::gh_task_azure_login::Node>();
24 }
25
26 fn process_request(request: Self::Request, ctx: &mut NodeCtx<'_>) -> anyhow::Result<()> {
27 let Params {
28 client_id,
29 tenant_id,
30 subscription_id,
31 } = request;
32
33 if !matches!(ctx.backend(), FlowBackend::Github) {
34 return Ok(());
35 }
36
37 let client_id = ctx.get_gh_context_var().secret(client_id);
38 let tenant_id = ctx.get_gh_context_var().secret(tenant_id);
39 let subscription_id = ctx.get_gh_context_var().secret(subscription_id);
40
41 let open_id_connect = ctx.emit_rust_stepv("Create OpenIDConnect Credentials", |ctx| {
42 let client_id = client_id.claim(ctx);
43 let tenant_id = tenant_id.claim(ctx);
44 let subscription_id = subscription_id.claim(ctx);
45 |rt| {
46 let client_id = rt.read(client_id);
47 let tenant_id = rt.read(tenant_id);
48 let subscription_id = rt.read(subscription_id);
49 Ok(flowey_lib_common::gh_task_azure_login::OpenIDConnect {
50 client_id,
51 tenant_id,
52 subscription_id,
53 })
54 }
55 });
56
57 ctx.req(flowey_lib_common::gh_task_azure_login::Request::Credentials(open_id_connect));
58 Ok(())
59 }
60}