bwx-cli 2.2.0

Unofficial Bitwarden CLI with first-class macOS support
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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

use crate::bin_error::{self, ContextExt as _};

pub(super) async fn respond_ack(
    sock: &mut crate::sock::Sock,
) -> bin_error::Result<()> {
    sock.send(&bwx::protocol::Response::Ack).await?;

    Ok(())
}

pub(super) async fn respond_decrypt(
    sock: &mut crate::sock::Sock,
    plaintext: String,
) -> bin_error::Result<()> {
    sock.send(&bwx::protocol::Response::Decrypt { plaintext })
        .await?;

    Ok(())
}

pub(super) async fn respond_encrypt(
    sock: &mut crate::sock::Sock,
    cipherstring: String,
) -> bin_error::Result<()> {
    sock.send(&bwx::protocol::Response::Encrypt { cipherstring })
        .await?;

    Ok(())
}

pub(super) async fn config_email() -> bin_error::Result<String> {
    let config = bwx::config::Config::load_async().await?;
    config.email.map_or_else(
        || {
            Err(bin_error::Error::msg(
                "failed to find email address in config",
            ))
        },
        Ok,
    )
}

pub(super) async fn load_db() -> bin_error::Result<bwx::db::Db> {
    let config = bwx::config::Config::load_async().await?;
    if let Some(email) = &config.email {
        Ok(bwx::db::Db::load_async(&config.server_name(), email).await?)
    } else {
        Err(bin_error::Error::msg(
            "failed to find email address in config",
        ))
    }
}

pub(super) async fn save_db(db: &bwx::db::Db) -> bin_error::Result<()> {
    let config = bwx::config::Config::load_async().await?;
    if let Some(email) = &config.email {
        db.save_async(&config.server_name(), email).await?;
        Ok(())
    } else {
        Err(bin_error::Error::msg(
            "failed to find email address in config",
        ))
    }
}

pub(super) async fn config_base_url() -> bin_error::Result<String> {
    let config = bwx::config::Config::load_async().await?;
    Ok(config.base_url())
}

pub(super) async fn config_pinentry() -> bin_error::Result<String> {
    let config = bwx::config::Config::load_async().await?;
    Ok(config.pinentry)
}

pub(super) async fn subscribe_to_notifications(
    state: std::sync::Arc<tokio::sync::Mutex<crate::state::State>>,
) -> bin_error::Result<()> {
    if state.lock().await.notifications_handler.is_connected() {
        return Ok(());
    }

    let config = bwx::config::Config::load_async()
        .await
        .context("Config is missing")?;
    let email = config.email.clone().context("Config is missing email")?;
    let db = bwx::db::Db::load_async(config.server_name().as_str(), &email)
        .await?;
    let access_token =
        db.access_token.context("Error getting access token")?;

    let websocket_url = format!(
        "{}/hub?access_token={}",
        config.notifications_url(),
        access_token
    )
    .replace("https://", "wss://");

    let mut state = state.lock().await;
    state
        .notifications_handler
        .connect(websocket_url)
        .await
        .err()
        .map_or_else(
            || Ok(()),
            |err| Err(bin_error::Error::msg(err.to_string())),
        )
}