chore: Bump poem to 3.0 (#15486)

* chore: Bump poem to 3.0

Signed-off-by: Xuanwo <github@xuanwo.io>

* remove not used crates

Signed-off-by: Xuanwo <github@xuanwo.io>

* remove the crate who have problem

Signed-off-by: Xuanwo <github@xuanwo.io>

* Fix test

Signed-off-by: Xuanwo <github@xuanwo.io>

---------

Signed-off-by: Xuanwo <github@xuanwo.io>

Author: Xuanwo

Cargo.lock

@@ -167,7 +167,7 @@ itertools = "0.10.5"
 match-template = "0.0.1"
 mysql_async = { version = "0.33", default-features = false, features = ["rustls-tls"] }
 ordered-float = { version = "4.1.0", default-features = false }
-poem = { version = "~1.3.57", features = ["rustls", "multipart", "compression"] }
+poem = { version = "3.0", features = ["rustls", "multipart", "compression"] }
 prometheus-client = "0.22"
 rand = { version = "0.8.5", features = ["small_rng"] }
 regex = "1.8.1"
@@ -247,7 +247,6 @@ opentelemetry = { version = "0.22", features = ["trace", "logs"] }
 opentelemetry-otlp = { version = "0.15", features = ["trace", "logs", "grpc-tonic"] }
 opentelemetry_sdk = { version = "0.22", features = ["trace", "logs", "rt-tokio"] }
 tracing = "0.1.40"
-opentelemetry-http = "0.11.0"
 tracing-appender = "0.2.3"
 console-subscriber = { version = "0.2.0" }
 tracing-subscriber = { version = "0.3.17", features = ["env-filter", "json", "valuable"] }

Cargo.toml

@@ -25,6 +25,7 @@ databend-common-exception = { path = "../exception" }
 # Crates.io dependencies
 anyerror = { workspace = true }
 futures = { workspace = true }
+http = { workspace = true }
 log = { workspace = true }
 poem = { workspace = true }
 serde = { workspace = true }

src/common/http/Cargo.toml

@@ -14,8 +14,8 @@
 
 use databend_common_base::mem_allocator::dump_profile;
 use databend_common_exception::ErrorCode;
+use http::StatusCode;
 use poem::error::InternalServerError;
-use poem::http::StatusCode;
 use poem::web::IntoResponse;
 use poem::web::Query;
 use poem::Error;

src/common/http/src/debug/jeprof.rs

@@ -14,10 +14,10 @@
 
 use databend_common_base::base::tokio;
 use databend_common_http::health_handler;
+use http::Method;
+use http::StatusCode;
+use http::Uri;
 use poem::get;
-use poem::http::Method;
-use poem::http::StatusCode;
-use poem::http::Uri;
 use poem::Endpoint;
 use poem::Request;
 use poem::Route;

src/common/http/tests/it/health.rs

@@ -51,6 +51,7 @@ derive_more = { workspace = true }
 feature-set = { workspace = true }
 futures = { workspace = true }
 futures-async-stream = { workspace = true }
+http = { workspace = true }
 itertools = { workspace = true }
 log = { workspace = true }
 logcall = { workspace = true }

src/meta/service/Cargo.toml

@@ -14,7 +14,7 @@
 
 use std::sync::Arc;
 
-use poem::http::StatusCode;
+use http::StatusCode;
 use poem::web::Data;
 use poem::web::IntoResponse;
 use poem::web::Json;

src/meta/service/src/api/http/v1/cluster_state.rs

@@ -15,7 +15,7 @@
 use std::sync::Arc;
 use std::time::Duration;
 
-use poem::http::StatusCode;
+use http::StatusCode;
 use poem::web::Data;
 use poem::web::IntoResponse;
 use poem::web::Json;

src/meta/service/src/api/http/v1/ctrl.rs

@@ -25,11 +25,11 @@ use databend_meta::api::http::v1::cluster_state::nodes_handler;
 use databend_meta::api::http::v1::cluster_state::status_handler;
 use databend_meta::api::HttpService;
 use databend_meta::meta_service::MetaNode;
+use http::Method;
+use http::StatusCode;
+use http::Uri;
 use log::info;
 use poem::get;
-use poem::http::Method;
-use poem::http::StatusCode;
-use poem::http::Uri;
 use poem::Endpoint;
 use poem::EndpointExt;
 use poem::Request;

src/meta/service/tests/it/api/http/cluster_state_test.rs

@@ -15,10 +15,10 @@
 use databend_common_base::base::tokio;
 use databend_meta::api::http::v1::config::config_handler;
 use databend_meta::configs::Config;
+use http::Method;
+use http::StatusCode;
+use http::Uri;
 use poem::get;
-use poem::http::Method;
-use poem::http::StatusCode;
-use poem::http::Uri;
 use poem::Endpoint;
 use poem::EndpointExt;
 use poem::Request;