xmr-btc-swap/swap/tests/happy_path_restart_alice.rs

// use crate::testutils::{init_alice, init_bob};
// use get_port::get_port;
// use libp2p::Multiaddr;
// use rand::rngs::OsRng;
// use swap::{
//     bitcoin,
//     config::Config,
//     database::Database,
//     monero,
//     protocol::{alice, alice::AliceState, bob},
//     seed::Seed,
// };
// use tempfile::tempdir;
// use testcontainers::clients::Cli;
// use testutils::init_tracing;
// use uuid::Uuid;
//
// pub mod testutils;
//
// #[tokio::test]
// async fn given_alice_restarts_after_encsig_is_learned_resume_swap() {
//     let _guard = init_tracing();
//
//     let cli = Cli::default();
//     let (
//         monero,
//         testutils::Containers {
//             bitcoind,
//             monerods: _monerods,
//         },
//     ) = testutils::init_containers(&cli).await;
//
//     let btc_to_swap = bitcoin::Amount::from_sat(1_000_000);
//     let xmr_to_swap = monero::Amount::from_piconero(1_000_000_000_000);
//
//     let bob_btc_starting_balance = btc_to_swap * 10;
//     let alice_xmr_starting_balance = xmr_to_swap * 10;
//
//     let port = get_port().expect("Failed to find a free port");
//     let alice_multiaddr: Multiaddr = format!("/ip4/127.0.0.1/tcp/{}", port)
//         .parse()
//         .expect("failed to parse Alice's address");
//
//     let config = Config::regtest();
//
//     let alice_seed = Seed::random().unwrap();
//     let (
//         start_state,
//         mut alice_event_loop,
//         alice_event_loop_handle,
//         alice_btc_wallet,
//         alice_xmr_wallet,
//         _,
//     ) = init_alice(
//         &bitcoind,
//         &monero,
//         btc_to_swap,
//         xmr_to_swap,
//         alice_xmr_starting_balance,
//         alice_multiaddr.clone(),
//         config,
//         alice_seed,
//     )
//     .await;
//
//     let alice_peer_id = alice_event_loop.peer_id();
//
//     let (bob_state, bob_event_loop, bob_event_loop_handle, bob_btc_wallet,
// bob_xmr_wallet, bob_db) =         init_bob(
//             alice_multiaddr.clone(),
//             alice_peer_id.clone(),
//             &bitcoind,
//             &monero,
//             btc_to_swap,
//             bob_btc_starting_balance,
//             xmr_to_swap,
//             config,
//         )
//         .await;
//
//     // TODO: we are making a clone of Bob's wallets here to keep them in
// scope after     // Bob's wallets are moved into an async task.
//     let bob_btc_wallet_clone = bob_btc_wallet.clone();
//     let bob_xmr_wallet_clone = bob_xmr_wallet.clone();
//
//     let bob_fut = bob::swap::swap(
//         bob_state,
//         bob_event_loop_handle,
//         bob_db,
//         bob_btc_wallet.clone(),
//         bob_xmr_wallet.clone(),
//         OsRng,
//         Uuid::new_v4(),
//     );
//
//     let alice_db_datadir = tempdir().unwrap();
//     let alice_db = Database::open(alice_db_datadir.path()).unwrap();
//
//     tokio::spawn(async move { alice_event_loop.run().await });
//     let bob_swap_handle = tokio::spawn(bob_fut);
//     tokio::spawn(bob_event_loop.run());
//
//     let alice_swap_id = Uuid::new_v4();
//
//     let alice_state = alice::swap::run_until(
//         start_state,
//         alice::swap::is_encsig_learned,
//         alice_event_loop_handle,
//         alice_btc_wallet.clone(),
//         alice_xmr_wallet.clone(),
//         config,
//         alice_swap_id,
//         alice_db,
//     )
//     .await
//     .unwrap();
//
//     assert!(matches!(alice_state, AliceState::EncSigLearned {..}));
//
//     let alice_db = Database::open(alice_db_datadir.path()).unwrap();
//
//     let resume_state =
//         if let swap::database::Swap::Alice(state) =
// alice_db.get_state(alice_swap_id).unwrap() {
// assert!(matches!(state, swap::database::Alice::EncSigLearned {..}));
//             state.into()
//         } else {
//             unreachable!()
//         };
//
//     let (mut event_loop_after_restart, event_loop_handle_after_restart) =
//         testutils::init_alice_event_loop(alice_multiaddr, alice_seed);
//     tokio::spawn(async move { event_loop_after_restart.run().await });
//
//     let alice_state = alice::swap::swap(
//         resume_state,
//         event_loop_handle_after_restart,
//         alice_btc_wallet.clone(),
//         alice_xmr_wallet.clone(),
//         config,
//         alice_swap_id,
//         alice_db,
//     )
//     .await
//     .unwrap();
//
//     // Wait for Bob to finish
//     bob_swap_handle.await.unwrap().unwrap();
//
//     assert!(matches!(alice_state, AliceState::BtcRedeemed {..}));
//
//     let btc_alice_final = alice_btc_wallet.as_ref().balance().await.unwrap();
//     let btc_bob_final =
// bob_btc_wallet_clone.as_ref().balance().await.unwrap();
//
//     assert_eq!(
//         btc_alice_final,
//         btc_to_swap - bitcoin::Amount::from_sat(bitcoin::TX_FEE)
//     );
//     assert!(btc_bob_final <= bob_btc_starting_balance - btc_to_swap);
//
//     let xmr_alice_final =
// alice_xmr_wallet.as_ref().get_balance().await.unwrap();
//     bob_xmr_wallet_clone.as_ref().inner.refresh().await.unwrap();
//     let xmr_bob_final =
// bob_xmr_wallet_clone.as_ref().get_balance().await.unwrap();
//
//     assert!(xmr_alice_final <= alice_xmr_starting_balance - xmr_to_swap);
//     assert_eq!(xmr_bob_final, xmr_to_swap);
// }