Cleanup resume_from_database functions only used in tests

swap/src/alice/swap.rs

@@ -233,29 +233,6 @@ pub async fn swap(
     .await
 }
 
-pub async fn resume_from_database(
-    event_loop_handle: EventLoopHandle,
-    bitcoin_wallet: Arc<crate::bitcoin::Wallet>,
-    monero_wallet: Arc<crate::monero::Wallet>,
-    config: Config,
-    swap_id: Uuid,
-    db: Database,
-) -> Result<AliceState> {
-    let db_swap = db.get_state(swap_id)?;
-    let start_state = AliceState::try_from(db_swap)?;
-    let state = swap(
-        start_state,
-        event_loop_handle,
-        bitcoin_wallet,
-        monero_wallet,
-        config,
-        swap_id,
-        db,
-    )
-    .await?;
-    Ok(state)
-}
-
 pub fn is_complete(state: &AliceState) -> bool {
     matches!(
         state,

swap/src/bob/swap.rs

@@ -122,32 +122,6 @@ where
     .await
 }
 
-pub async fn resume_from_database<R>(
-    event_loop_handle: EventLoopHandle,
-    db: Database,
-    bitcoin_wallet: Arc<crate::bitcoin::Wallet>,
-    monero_wallet: Arc<crate::monero::Wallet>,
-    rng: R,
-    swap_id: Uuid,
-) -> Result<BobState>
-where
-    R: RngCore + CryptoRng + Send,
-{
-    let db_swap = db.get_state(swap_id)?;
-    let start_state = BobState::try_from(db_swap)?;
-    let state = swap(
-        start_state,
-        event_loop_handle,
-        db,
-        bitcoin_wallet,
-        monero_wallet,
-        rng,
-        swap_id,
-    )
-    .await?;
-    Ok(state)
-}
-
 pub fn is_complete(state: &BobState) -> bool {
     matches!(
         state,

swap/tests/happy_path_restart_alice.rs

@@ -9,6 +9,7 @@ use xmr_btc::config::Config;
 pub mod testutils;
 
 use crate::testutils::{init_alice, init_bob};
+use std::convert::TryFrom;
 use testutils::init_tracing;
 
 #[tokio::test]
@@ -114,7 +115,11 @@ async fn given_alice_restarts_after_encsig_is_learned_resume_swap() {
         testutils::init_alice_event_loop(alice_multiaddr);
     let _alice_swarm_fut = tokio::spawn(async move { event_loop_after_restart.run().await });
 
-    let alice_state = alice::swap::resume_from_database(
+    let db_swap = alice_db.get_state(alice_swap_id).unwrap();
+    let resume_state = AliceState::try_from(db_swap).unwrap();
+
+    let alice_state = alice::swap::swap(
+        resume_state,
         event_loop_handle_after_restart,
         alice_btc_wallet,
         alice_xmr_wallet,

swap/tests/happy_path_restart_bob.rs

@@ -9,6 +9,7 @@ use xmr_btc::config::Config;
 pub mod testutils;
 
 use crate::testutils::{init_alice, init_bob};
+use std::convert::TryFrom;
 use swap::bob::swap::BobState;
 use testutils::init_tracing;
 
@@ -112,9 +113,13 @@ async fn given_bob_restarts_after_encsig_is_sent_resume_swap() {
 
     let (event_loop_after_restart, event_loop_handle_after_restart) =
         testutils::init_bob_event_loop();
-    let _alice_swarm_fut = tokio::spawn(async move { event_loop_after_restart.run().await });
+    let _bob_swarm_fut = tokio::spawn(async move { event_loop_after_restart.run().await });
 
-    let alice_state = bob::swap::resume_from_database(
+    let db_swap = bob_db.get_state(bob_swap_id).unwrap();
+    let resume_state = BobState::try_from(db_swap).unwrap();
+
+    let bob_state = bob::swap::swap(
+        resume_state,
         event_loop_handle_after_restart,
         bob_db,
         bob_btc_wallet,
@@ -125,7 +130,7 @@ async fn given_bob_restarts_after_encsig_is_sent_resume_swap() {
     .await
     .unwrap();
 
-    assert!(matches!(alice_state, BobState::XmrRedeemed {..}));
+    assert!(matches!(bob_state, BobState::XmrRedeemed {..}));
 
     // TODO: Additionally assert balances
 }