freedom-api 4.1.0

Freedom API for Rustaceans
Documentation 
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

use freedom_api::prelude::*;
use freedom_config::Config;
use futures::StreamExt;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let atlas_config = Config::from_env()?;
    let atlas_client = Client::from_config(atlas_config);

    let configurations = atlas_client
        .get_site_configurations()
        .collect::<Vec<_>>()
        .await;

    let mut edge = Vec::new();
    for item in configurations {
        let Ok(item) = item else {
            continue;
        };

        let item = item.into_inner();
        let hw = item.hardware.unwrap_or_default();
        for hw in hw {
            if let Some(ref model) = hw.model
                && model == "EDGE"
            {
                let ip = hw.ip.clone().unwrap_or_default();
                let port_comms = hw.port_comms.unwrap_or_default();
                let output = (item.name.clone(), ip, port_comms);
                edge.push(output);
            }
        }
    }

    edge.sort_by(|a, b| a.0.cmp(&b.0));

    println!("{edge:#?}");

    Ok(())
}