diff --git a/crates/utils/Cargo.toml b/crates/utils/Cargo.toml index 96f9b4758..882c2137b 100644 --- a/crates/utils/Cargo.toml +++ b/crates/utils/Cargo.toml @@ -66,7 +66,7 @@ path = [] notify = ["dep:hyper", "dep:s3s"] # file system notification features compress = ["dep:flate2", "dep:brotli", "dep:snap", "dep:lz4", "dep:zstd"] string = ["dep:regex", "dep:lazy_static", "dep:rand"] -crypto = ["dep:base64-simd", "dep:hex-simd", "dep:hmac", "dep:hyper"] +crypto = ["dep:base64-simd", "dep:hex-simd", "dep:hmac", "dep:hyper", "dep:sha1"] hash = ["dep:highway", "dep:md-5", "dep:sha2", "dep:blake3", "dep:serde", "dep:siphasher"] os = ["dep:nix", "dep:tempfile", "winapi"] # operating system utilities integration = [] # integration test features diff --git a/rustfs/src/storage/ecfs.rs b/rustfs/src/storage/ecfs.rs index 45d45a95e..36e70a46e 100644 --- a/rustfs/src/storage/ecfs.rs +++ b/rustfs/src/storage/ecfs.rs @@ -221,7 +221,7 @@ impl FS { .await .map_err(ApiError::from)?; - // let e_tag = obj_info.etag; + let e_tag = _obj_info.clone().etag; // // store.put_object(bucket, object, data, opts); @@ -235,9 +235,9 @@ impl FS { bucket_name: bucket.clone(), object: _obj_info.clone(), // clone() 或传递所需字段 req_params: rustfs_utils::extract_req_params_header(&req.headers), // 假设有一个辅助函数来提取请求参数 - resp_elements: rustfs_utils::extract_resp_elements(&output), // 假设有一个辅助函数来提取响应元素 - host: rustfs_utils::get_request_host(&req.headers), // 假设的辅助函数 - user_agent: rustfs_utils::get_request_user_agent(&req.headers), // 假设的辅助函数 + resp_elements: rustfs_utils::extract_resp_elements(&S3Response::new(output.clone())), // 假设有一个辅助函数来提取响应元素 + host: rustfs_utils::get_request_host(&req.headers), // 假设的辅助函数 + user_agent: rustfs_utils::get_request_user_agent(&req.headers), // 假设的辅助函数 }; // 异步调用,不会阻塞当前请求的响应