Robosats/taptrade-core
1
0
Fork 0
mirror of https://github.com/RoboSats/taptrade-core.git synced 2025-07-21 10:13:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

update coordinator wallet tests

Browse Source
This commit is contained in:
f321x
2024-07-17 17:45:11 +02:00
parent 2dbeb55238
commit 08140d43b6
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
taptrade-cli-demo/coordinator/src/wallet/mod.rs
View File

@ -61,6 +61,8 @@ pub async fn init_coordinator_wallet() -> Result<CoordinatorWallet<sled::Tree>>
&rpc_config.url, &rpc_config.url,
rpc_config.auth.clone().into(), rpc_config.auth.clone().into(),
)?); )?);
let json_rpc_client_clone = Arc::clone(&json_rpc_client);
let mempool = MempoolHandler::new(json_rpc_client_clone).await;
let backend = RpcBlockchain::from_config(&rpc_config)?; let backend = RpcBlockchain::from_config(&rpc_config)?;
// let backend = EsploraBlockchain::new(&env::var("ESPLORA_BACKEND")?, 1000); // let backend = EsploraBlockchain::new(&env::var("ESPLORA_BACKEND")?, 1000);
let sled_db = sled::open(env::var("BDK_DB_PATH")?)?.open_tree("default_wallet")?; let sled_db = sled::open(env::var("BDK_DB_PATH")?)?.open_tree("default_wallet")?;
@ -71,9 +73,6 @@ pub async fn init_coordinator_wallet() -> Result<CoordinatorWallet<sled::Tree>>
sled_db, sled_db,
)?; )?;
let json_rpc_client_clone = Arc::clone(&json_rpc_client);
let mempool = MempoolHandler::new(json_rpc_client_clone).await;
wallet wallet
.sync(&backend, SyncOptions::default()) .sync(&backend, SyncOptions::default())
.context("Connection to blockchain server failed.")?; // we could also use Esplora to make this async .context("Connection to blockchain server failed.")?; // we could also use Esplora to make this async
@ -220,7 +219,6 @@ impl<D: bdk::database::BatchDatabase> CoordinatorWallet<D> {
} }
fn search_monitoring_bond_by_txid( fn search_monitoring_bond_by_txid(
// this should not happen often, so the inefficiency is acceptable
monitoring_bonds: &Vec<MonitoringBond>, monitoring_bonds: &Vec<MonitoringBond>,
txid: &str, txid: &str,
) -> Result<MonitoringBond> { ) -> Result<MonitoringBond> {
@ -304,7 +302,8 @@ mod tests {
wallet_name: env::var("BITCOIN_RPC_WALLET_NAME").unwrap(), wallet_name: env::var("BITCOIN_RPC_WALLET_NAME").unwrap(),
sync_params: None, sync_params: None,
}; };
let json_rpc_client = Client::new(&rpc_config.url, rpc_config.auth.clone().into()).unwrap(); let json_rpc_client =
Arc::new(Client::new(&rpc_config.url, rpc_config.auth.clone().into()).unwrap());
let backend = RpcBlockchain::from_config(&rpc_config).unwrap(); let backend = RpcBlockchain::from_config(&rpc_config).unwrap();
let wallet_xprv = ExtendedPrivKey::from_str(wallet_xprv).unwrap(); let wallet_xprv = ExtendedPrivKey::from_str(wallet_xprv).unwrap();
@ -320,7 +319,8 @@ mod tests {
CoordinatorWallet::<MemoryDatabase> { CoordinatorWallet::<MemoryDatabase> {
wallet: Arc::new(Mutex::new(wallet)), wallet: Arc::new(Mutex::new(wallet)),
backend: Arc::new(backend), backend: Arc::new(backend),
json_rpc_client: Arc::new(json_rpc_client), json_rpc_client: Arc::clone(&json_rpc_client),
mempool: Arc::new(MempoolHandler::new(json_rpc_client).await),
} }
} }