rngo-cli 0.22.0

Data simulation CLI using api.rngo.dev
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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

use crate::model::{Effect, SimulationRunData, System};
use anyhow::Result;
use reqwest::Client;

/// Downloads all simulation run data including effects and systems with pagination support.
///
/// This function handles pagination to ensure all effects and systems are downloaded,
/// regardless of the API's implicit limit.
pub async fn get_simulation_run_data(
    client: &Client,
    api_url: &str,
    api_key: &str,
    simulation_key: &str,
    run_index: u64,
) -> Result<SimulationRunData> {
    let effects = fetch_all_effects(client, api_url, api_key, simulation_key, run_index).await?;
    let systems = fetch_all_systems(client, api_url, api_key, simulation_key, run_index).await?;

    Ok(SimulationRunData {
        index: run_index,
        effects,
        systems,
    })
}

/// Fetches all effects with pagination
async fn fetch_all_effects(
    client: &Client,
    api_url: &str,
    api_key: &str,
    simulation_key: &str,
    run_index: u64,
) -> Result<Vec<Effect>> {
    let mut all_effects = Vec::new();
    let mut offset = 0;
    let limit = 10;

    loop {
        let response = client
            .get(format!(
                "{api_url}/simulations/{simulation_key}/runs/{run_index}/effects"
            ))
            .header("Authorization", format!("Bearer {}", api_key))
            .query(&[("offset", offset.to_string()), ("limit", limit.to_string())])
            .send()
            .await?;

        let effects = response.json::<Vec<Effect>>().await?;
        let count = effects.len();

        all_effects.extend(effects);

        // If we received fewer items than the limit, we've reached the end
        if count < limit {
            break;
        }

        offset += limit;
    }

    Ok(all_effects)
}

/// Fetches all systems with pagination
async fn fetch_all_systems(
    client: &Client,
    api_url: &str,
    api_key: &str,
    simulation_key: &str,
    run_index: u64,
) -> Result<Vec<System>> {
    let mut all_systems = Vec::new();
    let mut offset = 0;
    let limit = 10;

    loop {
        let response = client
            .get(format!(
                "{api_url}/simulations/{simulation_key}/runs/{run_index}/systems"
            ))
            .header("Authorization", format!("Bearer {}", api_key))
            .query(&[("offset", offset.to_string()), ("limit", limit.to_string())])
            .send()
            .await?;

        let systems = response.json::<Vec<System>>().await?;
        let count = systems.len();

        all_systems.extend(systems);

        // If we received fewer items than the limit, we've reached the end
        if count < limit {
            break;
        }

        offset += limit;
    }

    Ok(all_systems)
}