Add support for success_action_status and success_action_redirect in AWS S3 POST object uploads (#1606)

rustfs/src/init.rs

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use crate::storage::ecfs::{process_lambda_configurations, process_queue_configurations, process_topic_configurations};
+use crate::storage::{process_lambda_configurations, process_queue_configurations, process_topic_configurations};
 use crate::{admin, config, version};
 use rustfs_config::{DEFAULT_UPDATE_CHECK, ENV_UPDATE_CHECK};
 use rustfs_ecstore::bucket::metadata_sys;

rustfs/src/server/layer.rs

@@ -16,7 +16,7 @@ use crate::admin::console::is_console_path;
 use crate::server::cors;
 use crate::server::hybrid::HybridBody;
 use crate::server::{ADMIN_PREFIX, RPC_PREFIX};
-use crate::storage::ecfs;
+use crate::storage::apply_cors_headers;
 use http::{HeaderMap, HeaderValue, Method, Request as HttpRequest, Response, StatusCode};
 use hyper::body::Incoming;
 use std::future::Future;
@@ -229,7 +229,7 @@ where
                 if ConditionalCorsLayer::is_s3_path(&path)
                     && !bucket.is_empty()
                     && cors_origins.is_some()
-                    && let Some(cors_headers) = ecfs::apply_cors_headers(&bucket, &method_clone, &request_headers_clone).await
+                    && let Some(cors_headers) = apply_cors_headers(&bucket, &method_clone, &request_headers_clone).await
                 {
                     for (key, value) in cors_headers.iter() {
                         response.headers_mut().insert(key, value.clone());

rustfs/src/storage/mod.rs

@@ -22,3 +22,8 @@ pub mod tonic_service;
 
 #[cfg(test)]
 mod concurrent_get_object_test;
+mod ecfs_extend;
+#[cfg(test)]
+mod ecfs_test;
+
+pub(crate) use ecfs_extend::*;