cdk 0.8.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
82
83
84
85
86
87
88
89
90
91
92
93
94

//! On Subscription
//!
//! This module contains the code that is triggered when a new subscription is created.
use std::sync::Arc;

use cdk_common::database::{self, MintDatabase};
use cdk_common::nut17::Notification;
use cdk_common::pub_sub::OnNewSubscription;
use cdk_common::NotificationPayload;
use uuid::Uuid;

use crate::nuts::{MeltQuoteBolt11Response, MintQuoteBolt11Response, ProofState, PublicKey};

#[derive(Default)]
/// Subscription Init
///
/// This struct triggers code when a new subscription is created.
///
/// It is used to send the initial state of the subscription to the client.
pub struct OnSubscription(
    pub(crate) Option<Arc<dyn MintDatabase<Err = database::Error> + Send + Sync>>,
);

#[async_trait::async_trait]
impl OnNewSubscription for OnSubscription {
    type Event = NotificationPayload<Uuid>;
    type Index = Notification;

    async fn on_new_subscription(
        &self,
        request: &[&Self::Index],
    ) -> Result<Vec<Self::Event>, String> {
        let datastore = if let Some(localstore) = self.0.as_ref() {
            localstore
        } else {
            return Ok(vec![]);
        };

        let mut to_return = vec![];
        let mut public_keys: Vec<PublicKey> = Vec::new();
        let mut melt_queries = Vec::new();
        let mut mint_queries = Vec::new();

        for idx in request.iter() {
            match idx {
                Notification::ProofState(pk) => public_keys.push(*pk),
                Notification::MeltQuoteBolt11(uuid) => {
                    melt_queries.push(datastore.get_melt_quote(uuid))
                }
                Notification::MintQuoteBolt11(uuid) => {
                    mint_queries.push(datastore.get_mint_quote(uuid))
                }
            }
        }

        to_return.extend(
            futures::future::try_join_all(melt_queries)
                .await
                .map(|quotes| {
                    quotes
                        .into_iter()
                        .filter_map(|quote| quote.map(|x| x.into()))
                        .map(|x: MeltQuoteBolt11Response<Uuid>| x.into())
                        .collect::<Vec<_>>()
                })
                .map_err(|e| e.to_string())?,
        );
        to_return.extend(
            futures::future::try_join_all(mint_queries)
                .await
                .map(|quotes| {
                    quotes
                        .into_iter()
                        .filter_map(|quote| quote.map(|x| x.into()))
                        .map(|x: MintQuoteBolt11Response<Uuid>| x.into())
                        .collect::<Vec<_>>()
                })
                .map_err(|e| e.to_string())?,
        );

        to_return.extend(
            datastore
                .get_proofs_states(public_keys.as_slice())
                .await
                .map_err(|e| e.to_string())?
                .into_iter()
                .enumerate()
                .filter_map(|(idx, state)| state.map(|state| (public_keys[idx], state).into()))
                .map(|state: ProofState| state.into()),
        );

        Ok(to_return)
    }
}