Refactor: Streamline the sync API

- Replace sync and sync_no_fail with sync_and_save
- Remove some redundant save_to_disk
- Update tests to use sync_and_save

Author: Godzilla-oss

src/bin/taker.rs

@@ -330,7 +330,7 @@ fn main() -> Result<(), TakerError> {
 
                     println!("{txid}");
 
-                    taker.get_wallet_mut().sync_no_fail();
+                    taker.get_wallet_mut().sync_and_save()?;
                 }
                 Commands::FetchOffers => {
                     let all_offers = {

src/maker/api2.rs

@@ -329,7 +329,7 @@ impl Maker {
         config.write_to_file(&data_dir.join("config.toml"))?;
 
         log::info!("Initializing wallet sync");
-        wallet.sync()?;
+        wallet.sync_and_save()?;
         log::info!("Completed wallet sync");
 
         let network_port = config.network_port;
@@ -483,7 +483,7 @@ impl Maker {
             let mut wallet = self.wallet.write()?;
 
             // Sync wallet to get latest UTXO state
-            wallet.sync()?;
+            wallet.sync_and_save()?;
 
             let balance = wallet.get_balances()?;
             if balance.spendable < connection_state.swap_amount {

src/maker/handlers.rs

@@ -303,7 +303,7 @@ impl Maker {
                 .get(funding_output_index as usize)
                 .expect("funding output expected at this index");
 
-            self.wallet.write()?.sync_no_fail();
+            self.wallet.write()?.sync_and_save()?;
 
             let receiver_contract_tx = create_receivers_contract_tx(
                 OutPoint {

src/maker/rpc/server.rs

@@ -105,7 +105,7 @@ fn handle_request<M: MakerRpc>(maker: &Arc<M>, socket: &mut TcpStream) -> Result
 
             let txid = maker.wallet().read()?.send_tx(&tx)?;
 
-            maker.wallet().write()?.sync_no_fail();
+            maker.wallet().write()?.sync_and_save()?;
 
             RpcMsgResp::SendToAddressResp(txid.to_string())
         }
@@ -136,11 +136,10 @@ fn handle_request<M: MakerRpc>(maker: &Arc<M>, socket: &mut TcpStream) -> Result
         RpcMsgReq::SyncWallet => {
             log::info!("Initializing wallet sync");
             let mut wallet = maker.wallet().write()?;
-            if let Err(e) = wallet.sync() {
+            if let Err(e) = wallet.sync_and_save() {
                 RpcMsgResp::ServerError(format!("{e:?}"))
             } else {
                 log::info!("Completed wallet sync");
-                wallet.save_to_disk()?;
                 RpcMsgResp::Pong
             }
         }

src/maker/server.rs

@@ -147,7 +147,7 @@ fn setup_fidelity_bond(maker: &Maker, maker_address: &str) -> Result<FidelityPro
         while !maker.shutdown.load(Relaxed) {
             sleep_multiplier += 1;
             // sync the wallet
-            maker.get_wallet().write()?.sync_no_fail();
+            maker.get_wallet().write()?.sync_and_save()?;
 
             let fidelity_result = maker.get_wallet().write()?.create_fidelity(
                 amount,
@@ -196,8 +196,7 @@ fn setup_fidelity_bond(maker: &Maker, maker_address: &str) -> Result<FidelityPro
                     *proof = Some(highest_proof);
 
                     // sync and save the wallet data to disk
-                    maker.get_wallet().write()?.sync_no_fail();
-                    maker.get_wallet().read()?.save_to_disk()?;
+                    maker.get_wallet().write()?.sync_and_save()?;
                     break;
                 }
             }
@@ -217,7 +216,7 @@ fn check_swap_liquidity(maker: &Maker) -> Result<(), MakerError> {
     let mut sleep_duration = 0;
     let addr = maker.get_wallet().write()?.get_next_external_address()?;
     while !maker.shutdown.load(Relaxed) {
-        maker.get_wallet().write()?.sync_no_fail();
+        maker.get_wallet().write()?.sync_and_save()?;
         let offer_max_size = maker.get_wallet().read()?.store.offer_maxsize;
 
         let min_required = maker.config.min_swap_amount;
@@ -501,9 +500,8 @@ pub fn start_maker_server(maker: Arc<Maker>) -> Result<(), MakerError> {
     maker.thread_pool.join_all_threads()?;
 
     log::info!("Shutdown wallet sync initiated.");
-    maker.get_wallet().write()?.sync_no_fail();
+    maker.get_wallet().write()?.sync_and_save()?;
     log::info!("Shutdown wallet syncing completed.");
-    maker.get_wallet().read()?.save_to_disk()?;
     log::info!("Wallet file saved to disk.");
     log::info!("Maker Server is shut down successfully.");
     Ok(())

src/maker/server2.rs

@@ -163,7 +163,7 @@ fn setup_fidelity_bond_taproot(
     while !maker.shutdown.load(Relaxed) {
         sleep_multiplier += 1;
         // sync the wallet
-        maker.wallet().write()?.sync_no_fail();
+        maker.wallet().write()?.sync_and_save()?;
 
         let fidelity_result = maker.wallet().write()?.create_fidelity(
             amount,
@@ -225,8 +225,7 @@ fn setup_fidelity_bond_taproot(
                 };
 
                 // sync and save the wallet data to disk
-                maker.wallet().write()?.sync_no_fail();
-                maker.wallet().read()?.save_to_disk()?;
+                maker.wallet().write()?.sync_and_save()?;
 
                 // Store the fidelity proof in maker
                 *maker.highest_fidelity_proof.write()? = Some(highest_proof.clone());

src/taker/api.rs

@@ -2163,9 +2163,7 @@ impl Taker {
             }
         }
 
-        self.wallet.sync_no_fail();
-
-        self.wallet.save_to_disk()?;
+        self.wallet.sync_and_save()?;
 
         self.clear_ongoing_swaps();
 

src/taker/api2.rs

@@ -407,7 +407,7 @@ impl Taker {
         };
 
         log::info!("Initializing wallet sync...");
-        wallet.sync()?;
+        wallet.sync_and_save()?;
         log::info!("Completed wallet sync");
 
         Ok(Self {

src/wallet/api.rs

@@ -2035,7 +2035,7 @@ impl Wallet {
             completed_swapcoins.len()
         );
 
-        self.sync_no_fail();
+        self.sync_and_save()?;
 
         for (multisig_redeemscript, _) in completed_swapcoins {
             let utxo_info = self
@@ -2128,7 +2128,7 @@ impl Wallet {
             }
             let reedem_script = incoming.get_multisig_redeemscript();
             let next_internal = &self.get_next_internal_addresses(1)?[0];
-            self.sync()?;
+            self.sync_and_save()?;
 
             let hashlock_spend =
                 self.create_hashlock_spend(&incoming, next_internal, MIN_FEE_RATE)?;
@@ -2159,7 +2159,7 @@ impl Wallet {
             let reedem_script = outgoing.get_multisig_redeemscript();
             let timelock = outgoing.get_timelock()?;
             let next_internal = &self.get_next_internal_addresses(1)?[0];
-            self.sync()?;
+            self.sync_and_save()?;
 
             let timelock_spend =
                 self.create_timelock_spend(&outgoing, next_internal, MIN_FEE_RATE)?;

src/wallet/backup.rs

@@ -125,8 +125,7 @@ impl Wallet {
             store,
             store_enc_material: restored_enc_material,
         };
-        tmp_wallet.sync()?;
-        tmp_wallet.save_to_disk()?;
+        tmp_wallet.sync_and_save()?;
 
         Ok(tmp_wallet)
     }