deps: Bump OpenDAL to 0.50 (#2888)

Signed-off-by: Xuanwo <github@xuanwo.io>
rooch-network · Nov 13, 2024 · 6d8e324 · 6d8e324
1 parent 0baac99
commit 6d8e324
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 14 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -331,7 +331,7 @@ ciborium = "0.2.1"
 pprof = { version = "0.13.0", features = ["flamegraph", "criterion", "cpp", "frame-pointer", "protobuf-codec"] }
 celestia-rpc = { git = "https://github.com/eigerco/celestia-node-rs.git", rev = "129272e8d926b4c7badf27a26dea915323dd6489" }
 celestia-types = { git = "https://github.com/eigerco/celestia-node-rs.git", rev = "129272e8d926b4c7badf27a26dea915323dd6489" }
-opendal = { version = "0.47.3", features = ["services-fs", "services-gcs"] }
+opendal = { version = "0.50.2", features = ["services-fs", "services-gcs"] }
 toml = "0.8.19"
 tabled = "0.16.0"
 csv = "1.3.1"

diff --git a/crates/rooch-da/src/backend/openda/operator.rs b/crates/rooch-da/src/backend/openda/operator.rs
@@ -52,7 +52,7 @@ pub(crate) async fn new_operator(
     let operator: Box<dyn Operator> = match scheme {
         OpenDAScheme::Avail => Box::new(AvailClient::new(&config["endpoint"])?),
         _ => {
-            let mut op = opendal::Operator::via_map(Scheme::from(scheme), config)?;
+            let mut op = opendal::Operator::via_iter(Scheme::from(scheme), config)?;
             let max_times = max_retry_times.unwrap_or(DEFAULT_MAX_RETRY_TIMES);
             op = op
                 .layer(RetryLayer::new().with_max_times(max_times))