From 2698d3aa107a656eb2f9ad114e941aab33f41d21 Mon Sep 17 00:00:00 2001 From: houseme Date: Fri, 27 Jun 2025 09:41:29 +0800 Subject: [PATCH] fix/event (#514) * improve code for notify * fix * cargo fmt * improve code and create `DEFAULT_DELIMITER` * fix * fix * improve code for notify * fmt * Update crates/notify/src/registry.rs Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * Update crates/notify/src/factory.rs Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * fix cllipy * fix * fix --------- Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --- crates/utils/Cargo.toml | 2 +- rustfs/src/storage/ecfs.rs | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) 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), // 假设的辅助函数 }; // 异步调用，不会阻塞当前请求的响应