stormchaser-cli 0.1.0

A robust, distributed workflow engine for event-driven and human-triggered workflows.
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

use crate::utils::{handle_run_response, parse_key_val_list, require_token};
use anyhow::Result;
use serde_json::json;
use std::fs;
use std::path::PathBuf;

pub async fn handle(
    url: &str,
    token: Option<&str>,
    http_client: &reqwest_middleware::ClientWithMiddleware,
    file: PathBuf,
    input: Vec<String>,
    tail: bool,
    watch: bool,
) -> Result<()> {
    let dsl = fs::read_to_string(file)?;
    let inputs = parse_key_val_list(input);
    let token = require_token(token)?;

    let res = http_client
        .post(format!("{}/api/v1/runs/direct", url))
        .header("Authorization", format!("Bearer {}", token))
        .json(&json!({ "dsl": dsl, "inputs": inputs }))
        .send()
        .await?;

    handle_run_response(http_client, url, token, res, tail, watch).await
}