indexers: make AnyResolver thread-safe

RGB-WG · Sep 25, 2024 · ba318f6 · ba318f6
1 parent a3b2e43
commit ba318f6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/indexers/any.rs b/src/indexers/any.rs
@@ -22,6 +22,7 @@
 // limitations under the License.
 
 use std::collections::HashMap;
+use std::sync::Arc;
 
 use bp::Tx;
 use bpstd::Network;
@@ -44,15 +45,15 @@ pub trait RgbResolver: Send {
 #[derive(From)]
 #[non_exhaustive]
 pub struct AnyResolver {
-    inner: Box<dyn RgbResolver>,
+    inner: Arc<dyn RgbResolver + Sync>,
     terminal_txes: HashMap<Txid, Tx>,
 }
 
 impl AnyResolver {
     #[cfg(feature = "electrum_blocking")]
     pub fn electrum_blocking(url: &str, config: Option<electrum::Config>) -> Result<Self, String> {
         Ok(AnyResolver {
-            inner: Box::new(
+            inner: Arc::new(
                 electrum::Client::from_config(url, config.unwrap_or_default())
                     .map_err(|e| e.to_string())?,
             ),
@@ -63,7 +64,7 @@ impl AnyResolver {
     #[cfg(feature = "esplora_blocking")]
     pub fn esplora_blocking(url: &str, config: Option<esplora::Config>) -> Result<Self, String> {
         Ok(AnyResolver {
-            inner: Box::new(
+            inner: Arc::new(
                 esplora::BlockingClient::from_config(url, config.unwrap_or_default())
                     .map_err(|e| e.to_string())?,
             ),
@@ -74,7 +75,7 @@ impl AnyResolver {
     #[cfg(feature = "mempool_blocking")]
     pub fn mempool_blocking(url: &str, config: Option<esplora::Config>) -> Result<Self, String> {
         Ok(AnyResolver {
-            inner: Box::new(super::mempool_blocking::MemPoolClient::new(
+            inner: Arc::new(super::mempool_blocking::MemPoolClient::new(
                 url,
                 config.unwrap_or_default(),
             )?),