mirror of
https://github.com/comit-network/xmr-btc-swap.git
synced 2024-07-01 00:51:23 +00:00
ea05c306e0
Instead of spawning the swap inside the event loop we send the swap back to the caller to be spawned. This means we no longer need the remote handle that was only used in the tests. This now properly logs the swap results in production. It also gives us more control over Alice's swap in the tests.
35 lines
1.1 KiB
Rust
35 lines
1.1 KiB
Rust
pub mod testutils;
|
|
|
|
use swap::protocol::bob::BobState;
|
|
use swap::protocol::{alice, bob};
|
|
use testutils::bob_run_until::is_xmr_locked;
|
|
use testutils::SlowCancelConfig;
|
|
|
|
#[tokio::test]
|
|
async fn given_bob_restarts_after_xmr_is_locked_resume_swap() {
|
|
testutils::setup_test(SlowCancelConfig, |mut ctx| async move {
|
|
let (bob_swap, bob_join_handle) = ctx.bob_swap().await;
|
|
let bob_swap = tokio::spawn(bob::run_until(bob_swap, is_xmr_locked));
|
|
|
|
let alice_swap = ctx.alice_next_swap().await;
|
|
let alice_swap = tokio::spawn(alice::run(alice_swap));
|
|
|
|
let bob_state = bob_swap.await??;
|
|
|
|
assert!(matches!(bob_state, BobState::XmrLocked { .. }));
|
|
|
|
let (bob_swap, _) = ctx.stop_and_resume_bob_from_db(bob_join_handle).await;
|
|
assert!(matches!(bob_swap.state, BobState::XmrLocked { .. }));
|
|
|
|
let bob_state = bob::run(bob_swap).await?;
|
|
|
|
ctx.assert_bob_redeemed(bob_state).await;
|
|
|
|
let alice_state = alice_swap.await??;
|
|
ctx.assert_alice_redeemed(alice_state).await;
|
|
|
|
Ok(())
|
|
})
|
|
.await;
|
|
}
|