tracing to logforth in test

Signed-off-by: tison <[email protected]>

Author: tisonkun

bin/oay/Cargo.lock

@@ -46,6 +46,8 @@ chrono = "0.4.31"
 dav-server = { version = "0.7", optional = true }
 dav-server-opendalfs = { version = "0.3.0", path = "../../integrations/dav-server", optional = true }
 futures-util = { version = "0.3.29", optional = true }
+log = { version = "0.4.22" }
+logforth = { version = "0.21.0", default-features = false }
 opendal = { version = "0.51.0", path = "../../core", features = [
   "services-fs",
 ] }
@@ -59,5 +61,3 @@ tokio = { version = "1.39", features = [
 ] }
 toml = "0.8.12"
 tower = { version = "0.4", features = ["util"] }
-tracing = "0.1"
-tracing-subscriber = { version = "0.3", features = ["env-filter"] }

bin/oay/Cargo.toml

@@ -26,9 +26,6 @@ use oay::Config;
 use opendal::services::Fs;
 use opendal::Operator;
 use opendal::Scheme;
-use tracing_subscriber::fmt;
-use tracing_subscriber::prelude::*;
-use tracing_subscriber::EnvFilter;
 
 #[tokio::main]
 async fn main() -> Result<()> {
@@ -37,10 +34,7 @@ async fn main() -> Result<()> {
 }
 
 async fn s3() -> Result<()> {
-    tracing_subscriber::registry()
-        .with(fmt::layer().pretty())
-        .with(EnvFilter::from_default_env())
-        .init();
+    logforth::stderr().apply();
 
     let cfg: Config =
         toml::from_str(&std::fs::read_to_string("oay.toml").context("failed to open oay.toml")?)?;

bin/oay/src/bin/oay.rs

@@ -22,16 +22,10 @@ use oay::services::WebdavService;
 use oay::Config;
 use opendal::services::Fs;
 use opendal::Operator;
-use tracing_subscriber::fmt;
-use tracing_subscriber::prelude::*;
-use tracing_subscriber::EnvFilter;
 
 #[tokio::main]
 async fn main() -> Result<()> {
-    tracing_subscriber::registry()
-        .with(fmt::layer().pretty())
-        .with(EnvFilter::from_default_env())
-        .init();
+    logforth::stderr().apply();
 
     let cfg: Config = Config {
         backend: oay::BackendConfig {

bin/oay/src/bin/webdav.rs

@@ -29,7 +29,6 @@ use futures_util::StreamExt;
 use opendal::Operator;
 use serde::Deserialize;
 use serde::Serialize;
-use tracing::debug;
 
 use crate::Config;
 
@@ -81,7 +80,7 @@ async fn handle_list_objects(
     state: State<S3State>,
     params: Query<ListObjectsV2Params>,
 ) -> Result<OkResponse, ErrorResponse> {
-    debug!("got params: {:?}", params);
+    log::debug!("got params: {:?}", params);
 
     if !state.op.info().full_capability().list_with_start_after {
         return Err(ErrorResponse {