cdk 0.16.0

Core Cashu Development Kit library implementing the Cashu protocol
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

mod auth_connector;
mod auth_wallet;

pub use auth_connector::AuthMintConnector;
pub use auth_wallet::AuthWallet;
use cdk_common::{Amount, AuthProof, AuthToken, Proofs};
use tracing::instrument;

use super::Wallet;
use crate::error::Error;

impl Wallet {
    /// Mint blind auth tokens
    #[instrument(skip_all)]
    pub async fn mint_blind_auth(&self, amount: Amount) -> Result<Proofs, Error> {
        self.auth_wallet
            .read()
            .await
            .as_ref()
            .ok_or(Error::AuthSettingsUndefined)?
            .mint_blind_auth(amount)
            .await
    }

    /// Get unspent auth proofs
    #[instrument(skip_all)]
    pub async fn get_unspent_auth_proofs(&self) -> Result<Vec<AuthProof>, Error> {
        self.auth_wallet
            .read()
            .await
            .as_ref()
            .ok_or(Error::AuthSettingsUndefined)?
            .get_unspent_auth_proofs()
            .await
    }

    /// Set Clear Auth Token (CAT) for authentication
    #[instrument(skip_all)]
    pub async fn set_cat(&self, cat: String) -> Result<(), Error> {
        let auth_wallet = self.auth_wallet.read().await;
        if let Some(auth_wallet) = auth_wallet.as_ref() {
            auth_wallet
                .set_auth_token(AuthToken::ClearAuth(cat))
                .await?;
        }
        Ok(())
    }

    /// Set refresh for authentication
    #[instrument(skip_all)]
    pub async fn set_refresh_token(&self, refresh_token: String) -> Result<(), Error> {
        let auth_wallet = self.auth_wallet.read().await;
        if let Some(auth_wallet) = auth_wallet.as_ref() {
            auth_wallet.set_refresh_token(Some(refresh_token)).await;
        }
        Ok(())
    }

    /// Refresh CAT token
    #[instrument(skip(self))]
    pub async fn refresh_access_token(&self) -> Result<(), Error> {
        let auth_wallet = self.auth_wallet.read().await;
        if let Some(auth_wallet) = auth_wallet.as_ref() {
            auth_wallet.refresh_access_token().await?;
        }
        Ok(())
    }

    /// Set the auth client (AuthWallet) for this wallet
    ///
    /// This allows updating the auth wallet without recreating the wallet.
    /// Also updates the client's auth wallet to keep them in sync.
    #[instrument(skip_all)]
    pub async fn set_auth_client(&self, auth_wallet: Option<AuthWallet>) {
        let mut auth_wallet_guard = self.auth_wallet.write().await;
        *auth_wallet_guard = auth_wallet.clone();

        // Also update the client's auth wallet to keep them in sync
        self.client.set_auth_wallet(auth_wallet).await;
    }
}