Skip to content
This repository was archived by the owner on Feb 3, 2025. It is now read-only.

Commit cc14c84

Browse files
Merge pull request #1144 from MutinyWallet/stop-nm-separate
Stop NodeManager separately
2 parents 9c1c4ac + 1d21aec commit cc14c84

File tree

2 files changed

+12
-10
lines changed

2 files changed

+12
-10
lines changed

mutiny-core/src/lib.rs

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -872,7 +872,6 @@ impl<S: MutinyStorage> MutinyWalletBuilder<S> {
872872

873873
let mut nm_builder = NodeManagerBuilder::new(self.xprivkey, self.storage.clone())
874874
.with_config(config.clone());
875-
nm_builder.with_stop(stop.clone());
876875
nm_builder.with_logger(logger.clone());
877876
let node_manager = Arc::new(nm_builder.build().await?);
878877

@@ -1182,7 +1181,6 @@ impl<S: MutinyStorage> MutinyWallet<S> {
11821181

11831182
let mut nm_builder = NodeManagerBuilder::new(self.xprivkey, self.storage.clone())
11841183
.with_config(self.config.clone());
1185-
nm_builder.with_stop(self.stop.clone());
11861184
nm_builder.with_logger(self.logger.clone());
11871185

11881186
// when we restart, gen a new session id
@@ -2347,7 +2345,18 @@ impl<S: MutinyStorage> MutinyWallet<S> {
23472345
/// Stops all of the nodes and background processes.
23482346
/// Returns after node has been stopped.
23492347
pub async fn stop(&self) -> Result<(), MutinyError> {
2350-
self.node_manager.stop().await
2348+
self.stop.store(true, Ordering::Relaxed);
2349+
2350+
self.node_manager.stop().await?;
2351+
2352+
// stop the indexeddb object to close db connection
2353+
if self.storage.connected().unwrap_or(false) {
2354+
log_debug!(self.logger, "stopping storage");
2355+
self.storage.stop();
2356+
log_debug!(self.logger, "stopped storage");
2357+
}
2358+
2359+
Ok(())
23512360
}
23522361

23532362
pub async fn change_password(

mutiny-core/src/nodemanager.rs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -571,13 +571,6 @@ impl<S: MutinyStorage> NodeManager<S> {
571571
nodes.clear();
572572
log_debug!(self.logger, "stopped all nodes");
573573

574-
// stop the indexeddb object to close db connection
575-
if self.storage.connected().unwrap_or(false) {
576-
log_debug!(self.logger, "stopping storage");
577-
self.storage.stop();
578-
log_debug!(self.logger, "stopped storage");
579-
}
580-
581574
Ok(())
582575
}
583576

0 commit comments

Comments
 (0)