💚 fix upgrade to opendal 0.46

cdviz-collector/Cargo.toml

@@ -14,6 +14,7 @@ publish = false
 [dependencies]
 axum = { version = "0.7", optional = true }
 axum-tracing-opentelemetry = { version = "0.18", optional = true }
+bytes = { version = "1.6", optional = true }
 cdevents-sdk = { git = "https://github.com/cdevents/sdk-rust" }
 chrono = "0.4"
 clap = { version = "4", features = ["derive", "env"] }
@@ -64,10 +65,15 @@ rustainers = "0.12"
 tracing-subscriber = "0.3"
 
 [features]
-default = ["source_http", "source_opendal", "sink_db", "reqwest/rustls"]
+default = [
+  "source_http",
+  "source_opendal",
+  "sink_db",
+  "reqwest/rustls",
+] #reqwest is also used as transitive dependencies
 sink_db = ["dep:sqlx"]
 source_http = ["dep:axum", "dep:axum-tracing-opentelemetry"]
-source_opendal = ["dep:opendal", "dep:globset"]
+source_opendal = ["dep:opendal", "dep:globset", "dep:bytes"]
 
 [package.metadata.release]
 pre-release-commit-message = "🚀 (cargo-release) version {{version}}"

cdviz-collector/src/sources/opendal/mod.rs

@@ -94,7 +94,8 @@ pub(crate) async fn run_once(
 }
 
 async fn process_entry(tx: &Sender<Message>, op: &Operator, entry: &Entry) -> Result<usize> {
-    let read = op.read(entry.path()).await?;
-    let cdevent: CDEvent = serde_json::from_slice::<CDEvent>(&read)?;
+    use bytes::Buf;
+    let buf = op.read(entry.path()).await?;
+    let cdevent: CDEvent = serde_json::from_reader(buf.reader())?;
     tx.send(cdevent.into()).map_err(Error::from)
 }