cdk_common/database/mint/auth/
mod.rs

1//! Mint in memory database use std::collections::HashMap;
2
3use std::collections::HashMap;
4
5use async_trait::async_trait;
6use cashu::{AuthRequired, ProtectedEndpoint};
7
8use super::DbTransactionFinalizer;
9use crate::database::Error;
10use crate::mint::MintKeySetInfo;
11use crate::nuts::nut07::State;
12use crate::nuts::{AuthProof, BlindSignature, Id, PublicKey};
13
14/// Mint Database transaction
15#[async_trait]
16pub trait MintAuthTransaction<Error>: DbTransactionFinalizer<Err = Error> {
17    /// Add Active Keyset
18    async fn set_active_keyset(&mut self, id: Id) -> Result<(), Error>;
19
20    /// Add [`MintKeySetInfo`]
21    async fn add_keyset_info(&mut self, keyset: MintKeySetInfo) -> Result<(), Error>;
22
23    /// Add a spent [`AuthProof`]
24    ///
25    /// Returns [`Error::Duplicate`](crate::database::Error::Duplicate) if the proof has already
26    /// been added.
27    async fn add_proof(&mut self, proof: AuthProof) -> Result<(), Error>;
28
29    /// Update [`AuthProof`]s state
30    async fn update_proof_state(
31        &mut self,
32        y: &PublicKey,
33        proofs_state: State,
34    ) -> Result<Option<State>, Error>;
35
36    /// Add [`BlindSignature`]
37    async fn add_blind_signatures(
38        &mut self,
39        blinded_messages: &[PublicKey],
40        blind_signatures: &[BlindSignature],
41    ) -> Result<(), Error>;
42
43    /// Add protected endpoints
44    async fn add_protected_endpoints(
45        &mut self,
46        protected_endpoints: HashMap<ProtectedEndpoint, AuthRequired>,
47    ) -> Result<(), Error>;
48
49    /// Removed Protected endpoints
50    async fn remove_protected_endpoints(
51        &mut self,
52        protected_endpoints: Vec<ProtectedEndpoint>,
53    ) -> Result<(), Error>;
54}
55
56/// Mint Database trait
57#[async_trait]
58pub trait MintAuthDatabase {
59    /// Mint Database Error
60    type Err: Into<Error> + From<Error>;
61
62    /// Begins a transaction
63    async fn begin_transaction<'a>(
64        &'a self,
65    ) -> Result<Box<dyn MintAuthTransaction<Self::Err> + Send + Sync + 'a>, Self::Err>;
66
67    /// Get Active Keyset
68    async fn get_active_keyset_id(&self) -> Result<Option<Id>, Self::Err>;
69
70    /// Get [`MintKeySetInfo`]
71    async fn get_keyset_info(&self, id: &Id) -> Result<Option<MintKeySetInfo>, Self::Err>;
72    /// Get [`MintKeySetInfo`]s
73    async fn get_keyset_infos(&self) -> Result<Vec<MintKeySetInfo>, Self::Err>;
74
75    /// Get [`AuthProof`] state
76    async fn get_proofs_states(&self, ys: &[PublicKey]) -> Result<Vec<Option<State>>, Self::Err>;
77
78    /// Get [`BlindSignature`]s
79    async fn get_blind_signatures(
80        &self,
81        blinded_messages: &[PublicKey],
82    ) -> Result<Vec<Option<BlindSignature>>, Self::Err>;
83
84    /// Get auth for protected_endpoint
85    async fn get_auth_for_endpoint(
86        &self,
87        protected_endpoint: ProtectedEndpoint,
88    ) -> Result<Option<AuthRequired>, Self::Err>;
89    /// Get protected endpoints
90    async fn get_auth_for_endpoints(
91        &self,
92    ) -> Result<HashMap<ProtectedEndpoint, Option<AuthRequired>>, Self::Err>;
93}
94
95/// Type alias for trait objects
96pub type DynMintAuthDatabase =
97    std::sync::Arc<dyn MintAuthDatabase<Err = super::Error> + Send + Sync>;
cdk_common/database/mint/auth/mod.rs

cdk_common/database/mint/auth/
mod.rs
