gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-09-03 18:55:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(multipart): include upload owner metadata (#3728)

Browse Source
This commit is contained in:
houseme
2026-06-22 13:54:37 +08:00
committed by GitHub
parent da5ff226ba
commit 6353f2093d
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/storage/s3_api/multipart.rs
+7
View File
@@ -153,6 +153,9 @@ pub(crate) fn build_list_multipart_uploads_output(
prefix: String, prefix: String,
result: ListMultipartsInfo, result: ListMultipartsInfo,
) -> ListMultipartUploadsOutput { ) -> ListMultipartUploadsOutput {
let owner = rustfs_owner();
let initiator = rustfs_initiator();
ListMultipartUploadsOutput { ListMultipartUploadsOutput {
bucket: Some(bucket), bucket: Some(bucket),
prefix: Some(prefix), prefix: Some(prefix),
@@ -169,6 +172,8 @@ pub(crate) fn build_list_multipart_uploads_output(
key: Some(u.object), key: Some(u.object),
upload_id: Some(u.upload_id), upload_id: Some(u.upload_id),
initiated: u.initiated.map(Timestamp::from), initiated: u.initiated.map(Timestamp::from),
owner: Some(owner.clone()),
initiator: Some(initiator.clone()),
..Default::default() ..Default::default()
}) })
.collect(), .collect(),
@@ -298,6 +303,8 @@ mod tests {
assert_eq!(uploads[0].key.as_deref(), Some("obj-a")); assert_eq!(uploads[0].key.as_deref(), Some("obj-a"));
assert_eq!(uploads[0].upload_id.as_deref(), Some("upload-a")); assert_eq!(uploads[0].upload_id.as_deref(), Some("upload-a"));
assert_eq!(uploads[0].initiated, Some(Timestamp::from(OffsetDateTime::UNIX_EPOCH))); assert_eq!(uploads[0].initiated, Some(Timestamp::from(OffsetDateTime::UNIX_EPOCH)));
assert_eq!(uploads[0].owner, Some(rustfs_owner()));
assert_eq!(uploads[0].initiator, Some(rustfs_initiator()));
assert_eq!(common_prefixes.len(), 2); assert_eq!(common_prefixes.len(), 2);
assert_eq!(common_prefixes[0].prefix.as_deref(), Some("prefix-a/")); assert_eq!(common_prefixes[0].prefix.as_deref(), Some("prefix-a/"));