From 30ab919bb33e8b68ec803ae0005913978fbfb4fe Mon Sep 17 00:00:00 2001 From: Zhengchao An Date: Sun, 6 Sep 2026 01:35:05 +0800 Subject: [PATCH 1/2] fix(ci): route v1 listing test types through application bridge (#7227) --- rustfs/src/app/bucket_list_through.rs | 7 ++++--- rustfs/src/app/storage_api.rs | 4 ++++ 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/rustfs/src/app/bucket_list_through.rs b/rustfs/src/app/bucket_list_through.rs index c385fdb9c..586f5b0ae 100644 --- a/rustfs/src/app/bucket_list_through.rs +++ b/rustfs/src/app/bucket_list_through.rs @@ -443,7 +443,9 @@ mod tests { use super::*; use crate::app::bucket_usecase::DefaultBucketUsecase; use crate::app::gating_test_env::{run_large_stack_test, shared_gating_ecstore}; - use crate::app::storage_api::bucket_usecase::s3::{ListObjectsV2Input, ListObjectsV2Output, S3Request, S3Response}; + use crate::app::storage_api::bucket_usecase::s3::{ + ListObjectsInput, ListObjectsV2Input, ListObjectsV2Output, S3Request, S3Response, XmlSerialize, XmlSerializer, + }; use crate::app::storage_api::test::StoragePutObjReader; use crate::app::storage_api::test::contract::bucket::{BucketOperations as _, MakeBucketOptions}; use crate::app::storage_api::test::contract::object::ObjectIO as _; @@ -451,7 +453,6 @@ mod tests { FilterConfig, MAX_LIST_NO_PROGRESS_PAGES, OnDemandMigrationConfig, PathStyle, PolicyConfig, Provider, SourceConfig, SourceCredentials, TlsConfig, }; - use s3s::dto::ListObjectsInput; use std::time::Duration; use tokio::io::{AsyncReadExt, AsyncWriteExt}; @@ -864,7 +865,7 @@ mod tests { assert_eq!(output.next_marker.as_deref(), (index == 0).then_some(expected_key)); let mut xml = Vec::new(); - s3s::xml::Serialize::serialize(&output, &mut s3s::xml::Serializer::new(&mut xml)) + XmlSerialize::serialize(&output, &mut XmlSerializer::new(&mut xml)) .expect("serialize the real v1 response"); assert!(!xml.contains(&0), "XML 1.0 forbids NUL in NextMarker"); let mut reader = quick_xml::Reader::from_reader(xml.as_slice()); diff --git a/rustfs/src/app/storage_api.rs b/rustfs/src/app/storage_api.rs index 6c810e213..da7af7c86 100644 --- a/rustfs/src/app/storage_api.rs +++ b/rustfs/src/app/storage_api.rs @@ -27,12 +27,16 @@ pub(crate) fn EndpointServerPools( /// S3 wire types for app-layer modules, funneled here so new files stay off /// the direct s3s surface (s3s footprint ratchet, `scripts/check_s3s_footprint.sh`). pub(crate) mod s3 { + #[cfg(test)] + pub(crate) use s3s::dto::ListObjectsInput; #[cfg(test)] pub(crate) use s3s::dto::{ BucketVersioningStatus, DeleteMarkerReplication, DeleteMarkerReplicationStatus, Destination, ListObjectsV2Input, ListObjectsV2Output, ReplicationConfiguration, ReplicationRule, ReplicationRuleFilter, ReplicationRuleStatus, ServerSideEncryptionByDefault, ServerSideEncryptionConfiguration, ServerSideEncryptionRule, Tag, VersioningConfiguration, }; + #[cfg(test)] + pub(crate) use s3s::xml::{Serialize as XmlSerialize, Serializer as XmlSerializer}; pub(crate) use s3s::{S3Error, S3ErrorCode, S3Result}; #[cfg(test)] pub(crate) use s3s::{S3Request, S3Response}; From 037354cec08180d6a5eb3390aac24534dc096ac6 Mon Sep 17 00:00:00 2001 From: Zhengchao An Date: Sun, 6 Sep 2026 01:37:02 +0800 Subject: [PATCH 2/2] fix(build): declare relocated migration service dependencies (#7229) --- Cargo.lock | 2 ++ rustfs/Cargo.toml | 2 ++ 2 files changed, 4 insertions(+) diff --git a/Cargo.lock b/Cargo.lock index c6d279229..aeadb7866 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -9527,6 +9527,7 @@ dependencies = [ "metrics", "metrics-util", "mime_guess", + "moka", "opentelemetry", "opentelemetry_sdk", "p256 0.14.0", @@ -9619,6 +9620,7 @@ dependencies = [ "urlencoding", "uuid", "x509-parser", + "xxhash-rust", "zeroize", "zip", "zstd 0.14.0", diff --git a/rustfs/Cargo.toml b/rustfs/Cargo.toml index 03b6b378e..aabf2d865 100644 --- a/rustfs/Cargo.toml +++ b/rustfs/Cargo.toml @@ -291,6 +291,8 @@ tokio-rustls = { workspace = true, default-features = false, features = ["loggin aws-smithy-runtime-api = { workspace = true, features = ["http-1x"] } aws-smithy-types = { workspace = true } google-cloud-auth = { workspace = true, optional = true } +moka = { workspace = true, features = ["sync"] } +xxhash-rust = { workspace = true, features = ["xxh3"] } aws-sdk-s3 = { workspace = true, default-features = false, features = ["sigv4a", "default-https-client", "rt-tokio"] } tokio-stream.workspace = true tokio-util = { workspace = true, features = ["io", "compat", "time"] }