aljaz/cdk
1
0
Fork 0
mirror of https://github.com/aljazceru/cdk.git synced 2026-02-04 12:45:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: use Mint check payment status

Browse Source
This commit is contained in:
thesimplekid
2025-02-08 22:27:32 +00:00
parent 1abfd7f52b
commit 9697e602df
2 changed files with 7 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/cdk-integration-tests/tests/fake_wallet.rs
View File

@@ -867,7 +867,9 @@ async fn test_fake_mint_input_output_mismatch() -> Result<()> {
match response {
Err(err) => match err {
cdk::Error::UnsupportedUnit => (),
_ => {}
_ => {
bail!("Wrong error returned");
}
},
Ok(_) => {
bail!("Should not have allowed to mint with multiple units");

24
crates/cdk/src/mint/start_up_check.rs
View File

@@ -14,26 +14,10 @@ impl Mint {
pub async fn check_pending_mint_quotes(&self) -> Result<(), Error> {
let pending_quotes = self.get_pending_mint_quotes().await?;
tracing::info!("There are {} pending mint quotes.", pending_quotes.len());
for ln in self.ln.values() {
for quote in pending_quotes.iter() {
tracing::debug!("Checking status of mint quote: {}", quote.id);
let lookup_id = quote.request_lookup_id.as_str();
match ln.check_incoming_invoice_status(lookup_id).await {
Ok(state) => {
if state != quote.state {
tracing::trace!("Mint quote status changed: {}", quote.id);
self.localstore
.update_mint_quote_state(&quote.id, state)
.await?;
}
}
Err(err) => {
tracing::warn!("Could not check state of pending invoice: {}", lookup_id);
tracing::error!("{}", err);
}
}
for quote in pending_quotes.iter() {
tracing::debug!("Checking status of mint quote: {}", quote.id);
if let Err(err) = self.check_mint_quote_paid(&quote.id).await {
tracing::error!("Could not check status of {}, {}", quote.id, err);
}
}
Ok(())