chrs 0.3.1

CLI ChRIS client
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

use super::prompt::{prompt_if_missing, prompt_if_missing_password};
use super::state::ChrsSessions;
use super::store;
use crate::credentials::Credentials;
use chris::{
    types::{CubeUrl, Username},
    Account, AnonChrisClient, ChrisClient,
};
use color_eyre::eyre::{bail, Context, Result};
use color_eyre::owo_colors::OwoColorize;

pub async fn login(
    Credentials {
        cube_url,
        username,
        password,
        token,
        ui,
        config_path,
        ..
    }: Credentials,
    backend: store::Backend,
    password_from_stdin: bool,
) -> Result<()> {
    if password.is_some() && password_from_stdin {
        bail!(
            "Options {} and {} may not be used together.",
            "--password".bold(),
            "--password-stdin".bold()
        );
    }

    let mut config = ChrsSessions::load(config_path.as_deref())?;
    let cube = prompt_if_missing(cube_url, "ChRIS API address")?;
    let username = prompt_if_missing(username, "username")?;

    let token = if username.as_str().is_empty() {
        login_anonymous(&cube).await
    } else if let Some(token) = token {
        login_with_token(&cube, &username, &token).await
    } else {
        let password = prompt_if_missing_password(password, "password", password_from_stdin)?;
        login_with_password(&cube, &username, &password).await
    }?;

    let login = store::CubeState {
        cube,
        token,
        username,
        current_plugin_instance_id: None,
        ui,
    };

    config.add(login, backend)?;
    config.save(config_path.as_deref())
}

/// Contact CUBE just to make sure CUBE is reachable.
async fn login_anonymous(cube_url: &CubeUrl) -> Result<Option<String>> {
    AnonChrisClient::build(cube_url.clone())?.connect().await?;
    Ok(None)
}

/// Login to CUBE by getting a token using a password.
async fn login_with_password(
    cube_url: &CubeUrl,
    username: &Username,
    password: &str,
) -> Result<Option<String>> {
    let account = Account {
        client: Default::default(),
        url: cube_url,
        username,
        password,
    };

    let token = account.get_token().await.wrap_err("Could not log in")?;
    Ok(Some(token))
}

/// Verify token works for the CUBE.
async fn login_with_token(
    cube_url: &CubeUrl,
    username: &Username,
    token: &str,
) -> Result<Option<String>> {
    ChrisClient::build(cube_url.clone(), username.clone(), token)?
        .connect()
        .await
        .wrap_err_with(|| format!("Invalid token for {cube_url}"))?;
    Ok(Some(token.to_string()))
}

pub fn logout(
    Credentials {
        cube_url,
        username,
        config_path,
        ..
    }: Credentials,
) -> Result<()> {
    let mut config = ChrsSessions::load(config_path.as_deref())?;
    if let Some(url) = cube_url {
        let removed = match username {
            Some(u) => config.remove(&url, Some(&u)),
            None => config.remove(&url, None),
        };
        if !removed {
            bail!("Not logged in.");
        }
    } else if !config.clear() {
        bail!("Not logged in.");
    }
    config.save(config_path.as_deref())
}