fix(query): check storage request method with arg list-type (#16849)

* z

* fix(query): check storage request method with arg list-type

* z

Author: everpcpc

Cargo.lock

@@ -34,6 +34,7 @@ regex = { workspace = true }
 reqwest = { workspace = true }
 serde = { workspace = true }
 thiserror = { workspace = true }
+url = { workspace = true }
 
 [dev-dependencies]
 

src/common/storage/Cargo.toml

@@ -12,6 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+use std::collections::HashMap;
 use std::future;
 use std::mem;
 use std::str::FromStr;
@@ -26,6 +27,7 @@ use opendal::raw::parse_content_length;
 use opendal::raw::HttpBody;
 use opendal::raw::HttpFetch;
 use opendal::Buffer;
+use url::Url;
 
 pub struct StorageHttpClient {
     client: reqwest::Client,
@@ -46,13 +48,14 @@ impl HttpFetch for StorageHttpClient {
         let uri = req.uri().clone();
         let is_head = req.method() == http::Method::HEAD;
 
-        let host = uri.host().unwrap_or_default();
+        let url = Url::parse(uri.to_string().as_str()).expect("input request url must be valid");
+        let host = url.host_str().unwrap_or_default();
         let method = match req.method() {
             &http::Method::GET => {
-                if uri.path() == "/" {
-                    "LIST"
-                } else {
-                    "GET"
+                let query: HashMap<_, _> = url.query_pairs().collect();
+                match query.get("list-type") {
+                    Some(_) => "LIST",
+                    None => "GET",
                 }
             }
             m => m.as_str(),