mirror of
https://github.com/aljazceru/cdk.git
synced 2025-12-19 13:44:55 +01:00
* Abstract the HTTP Transport This PR allows replacing the HTTP transport layer with another library, allowing wallet ffi to provide a better-suited HTTP library that would be used instead of Reqwest.
130 lines
3.6 KiB
Rust
130 lines
3.6 KiB
Rust
use std::str::FromStr;
|
|
use std::sync::Arc;
|
|
|
|
use bip39::Mnemonic;
|
|
use cashu::{Bolt11Invoice, ProofsMethods};
|
|
use cdk::amount::{Amount, SplitTarget};
|
|
use cdk::nuts::CurrencyUnit;
|
|
use cdk::wallet::{ReceiveOptions, SendKind, SendOptions, Wallet};
|
|
use cdk_integration_tests::init_regtest::get_temp_dir;
|
|
use cdk_integration_tests::{create_invoice_for_env, get_mint_url_from_env, pay_if_regtest};
|
|
use cdk_sqlite::wallet::memory;
|
|
|
|
#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
|
|
async fn test_swap() {
|
|
let seed = Mnemonic::generate(12).unwrap().to_seed_normalized("");
|
|
let wallet = Wallet::new(
|
|
&get_mint_url_from_env(),
|
|
CurrencyUnit::Sat,
|
|
Arc::new(memory::empty().await.unwrap()),
|
|
seed,
|
|
None,
|
|
)
|
|
.expect("failed to create new wallet");
|
|
|
|
let mint_quote = wallet.mint_quote(100.into(), None).await.unwrap();
|
|
|
|
let invoice = Bolt11Invoice::from_str(&mint_quote.request).unwrap();
|
|
pay_if_regtest(&get_temp_dir(), &invoice).await.unwrap();
|
|
|
|
let proofs = wallet
|
|
.wait_and_mint_quote(
|
|
mint_quote.clone(),
|
|
SplitTarget::default(),
|
|
None,
|
|
tokio::time::Duration::from_secs(60),
|
|
)
|
|
.await
|
|
.expect("payment");
|
|
|
|
println!("{:?}", proofs);
|
|
|
|
let send = wallet
|
|
.prepare_send(
|
|
4.into(),
|
|
SendOptions {
|
|
send_kind: SendKind::OfflineExact,
|
|
..Default::default()
|
|
},
|
|
)
|
|
.await
|
|
.unwrap();
|
|
|
|
let proofs = send.proofs();
|
|
|
|
let fee = wallet.get_proofs_fee(&proofs).await.unwrap();
|
|
|
|
assert_eq!(fee, 1.into());
|
|
|
|
let send = send.confirm(None).await.unwrap();
|
|
|
|
let rec_amount = wallet
|
|
.receive(&send.to_string(), ReceiveOptions::default())
|
|
.await
|
|
.unwrap();
|
|
|
|
assert_eq!(rec_amount, 3.into());
|
|
|
|
let wallet_balance = wallet.total_balance().await.unwrap();
|
|
|
|
assert_eq!(wallet_balance, 99.into());
|
|
}
|
|
|
|
#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
|
|
async fn test_fake_melt_change_in_quote() {
|
|
let wallet = Wallet::new(
|
|
&get_mint_url_from_env(),
|
|
CurrencyUnit::Sat,
|
|
Arc::new(memory::empty().await.unwrap()),
|
|
Mnemonic::generate(12).unwrap().to_seed_normalized(""),
|
|
None,
|
|
)
|
|
.expect("failed to create new wallet");
|
|
|
|
let mint_quote = wallet.mint_quote(100.into(), None).await.unwrap();
|
|
|
|
let bolt11 = Bolt11Invoice::from_str(&mint_quote.request).unwrap();
|
|
|
|
pay_if_regtest(&get_temp_dir(), &bolt11).await.unwrap();
|
|
|
|
let _proofs = wallet
|
|
.wait_and_mint_quote(
|
|
mint_quote.clone(),
|
|
SplitTarget::default(),
|
|
None,
|
|
tokio::time::Duration::from_secs(60),
|
|
)
|
|
.await
|
|
.expect("payment");
|
|
|
|
let invoice_amount = 9;
|
|
|
|
let invoice = create_invoice_for_env(Some(invoice_amount)).await.unwrap();
|
|
|
|
let melt_quote = wallet.melt_quote(invoice.to_string(), None).await.unwrap();
|
|
|
|
let proofs = wallet.get_unspent_proofs().await.unwrap();
|
|
|
|
let proofs_total = proofs.total_amount().unwrap();
|
|
|
|
let fee = wallet.get_proofs_fee(&proofs).await.unwrap();
|
|
let melt = wallet
|
|
.melt_proofs(&melt_quote.id, proofs.clone())
|
|
.await
|
|
.unwrap();
|
|
let change = melt.change.unwrap().total_amount().unwrap();
|
|
let idk = proofs.total_amount().unwrap() - Amount::from(invoice_amount) - change;
|
|
|
|
println!("{}", idk);
|
|
println!("{}", fee);
|
|
println!("{}", proofs_total);
|
|
println!("{}", change);
|
|
|
|
let ln_fee = 1;
|
|
|
|
assert_eq!(
|
|
wallet.total_balance().await.unwrap(),
|
|
Amount::from(100 - invoice_amount - u64::from(fee) - ln_fee)
|
|
);
|
|
}
|