runmat 0.4.5

High-performance MATLAB/Octave syntax mathematical runtime
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
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

use anyhow::Result;
use runmat_server_client::auth::{
    build_public_client, map_public_error, resolve_auth_token, resolve_org_id, resolve_project_id,
    resolve_server_url, RemoteConfig,
};
use runmat_server_client::public_api;
use uuid::Uuid;

pub async fn list_projects(
    org: Option<Uuid>,
    limit: Option<u32>,
    cursor: Option<String>,
) -> Result<()> {
    let mut config = RemoteConfig::load()?;
    let org_id = resolve_org_id(&config, org)?;
    let server_url = resolve_server_url(&config, None)?;
    let token = resolve_auth_token(&mut config, &server_url).await?;
    let client = build_public_client(&server_url, &token)?;
    let org_id = org_id.to_string();
    let response = client
        .list_projects(&org_id, cursor.as_deref(), limit.map(|value| value as u64))
        .await
        .map_err(map_public_error)?
        .into_inner();
    for project in response.items {
        println!("{}\t{}", project.id, project.name);
    }
    if let Some(cursor) = response.next_cursor {
        println!("next_cursor\t{cursor}");
    }
    Ok(())
}

pub async fn create_project(org: Option<Uuid>, name: String) -> Result<()> {
    let mut config = RemoteConfig::load()?;
    let org_id = resolve_org_id(&config, org)?;
    let server_url = resolve_server_url(&config, None)?;
    let token = resolve_auth_token(&mut config, &server_url).await?;
    let client = build_public_client(&server_url, &token)?;
    let org_id = org_id.to_string();
    let response = client
        .create_project(&org_id, &public_api::types::ProjectCreateRequest { name })
        .await
        .map_err(map_public_error)?
        .into_inner();
    println!("{}\t{}", response.id, response.name);
    Ok(())
}

pub async fn list_project_members(
    project: Option<Uuid>,
    limit: Option<u32>,
    cursor: Option<String>,
) -> Result<()> {
    let mut config = RemoteConfig::load()?;
    let project_id = resolve_project_id(&config, project)?;
    let server_url = resolve_server_url(&config, None)?;
    let token = resolve_auth_token(&mut config, &server_url).await?;
    let client = build_public_client(&server_url, &token)?;
    let project_id = project_id.to_string();
    let response = client
        .list_project_memberships(
            &project_id,
            cursor.as_deref(),
            limit.map(|value| value as u64),
        )
        .await
        .map_err(map_public_error)?
        .into_inner();
    for member in response.items {
        println!("{}\t{}\t{}", member.id, member.user_id, member.role);
    }
    if let Some(cursor) = response.next_cursor {
        println!("next_cursor\t{cursor}");
    }
    Ok(())
}

pub async fn select_project(project_id: Uuid) -> Result<()> {
    let mut config = RemoteConfig::load()?;
    config.project_id = Some(project_id);
    config.save()?;
    println!("Default project set to {project_id}");
    Ok(())
}