gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-07-28 00:58:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(admin): cover tier, bucket metadata, and kms aliases (#2334)

Browse Source
This commit is contained in:
安正超
2026-03-30 21:48:42 +08:00
committed by GitHub
parent d5f05993a3
commit b256154f25
1 changed files with 29 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/admin/route_registration_test.rs
+29 -30
View File
@@ -38,24 +38,29 @@ fn assert_route(router: &S3Router<AdminOperation>, method: Method, path: &str) {
);
}
fn register_admin_routes(router: &mut S3Router<AdminOperation>) {
health::register_health_route(router).expect("register health route");
sts::register_admin_auth_route(router).expect("register sts route");
user::register_user_route(router).expect("register user route");
system::register_system_route(router).expect("register system route");
pools::register_pool_route(router).expect("register pool route");
rebalance::register_rebalance_route(router).expect("register rebalance route");
heal::register_heal_route(router).expect("register heal route");
tier::register_tier_route(router).expect("register tier route");
quota::register_quota_route(router).expect("register quota route");
bucket_meta::register_bucket_meta_route(router).expect("register bucket meta route");
replication::register_replication_route(router).expect("register replication route");
profile_admin::register_profiling_route(router).expect("register profile route");
kms::register_kms_route(router).expect("register kms route");
oidc::register_oidc_route(router).expect("register oidc route");
}
#[test]
fn test_register_routes_cover_representative_admin_paths() {
let mut router: S3Router<AdminOperation> = S3Router::new(false);
health::register_health_route(&mut router).expect("register health route");
sts::register_admin_auth_route(&mut router).expect("register sts route");
user::register_user_route(&mut router).expect("register user route");
system::register_system_route(&mut router).expect("register system route");
pools::register_pool_route(&mut router).expect("register pool route");
rebalance::register_rebalance_route(&mut router).expect("register rebalance route");
heal::register_heal_route(&mut router).expect("register heal route");
tier::register_tier_route(&mut router).expect("register tier route");
quota::register_quota_route(&mut router).expect("register quota route");
bucket_meta::register_bucket_meta_route(&mut router).expect("register bucket meta route");
replication::register_replication_route(&mut router).expect("register replication route");
profile_admin::register_profiling_route(&mut router).expect("register profile route");
kms::register_kms_route(&mut router).expect("register kms route");
oidc::register_oidc_route(&mut router).expect("register oidc route");
register_admin_routes(&mut router);
assert_route(&router, Method::GET, HEALTH_PREFIX);
assert_route(&router, Method::HEAD, HEALTH_PREFIX);
assert_route(&router, Method::GET, HEALTH_READY_PATH);
@@ -143,18 +148,7 @@ fn test_register_routes_cover_representative_admin_paths() {
fn test_admin_alias_paths_match_existing_admin_routes() {
let mut router: S3Router<AdminOperation> = S3Router::new(false);
health::register_health_route(&mut router).expect("register health route");
sts::register_admin_auth_route(&mut router).expect("register sts route");
user::register_user_route(&mut router).expect("register user route");
system::register_system_route(&mut router).expect("register system route");
pools::register_pool_route(&mut router).expect("register pool route");
rebalance::register_rebalance_route(&mut router).expect("register rebalance route");
heal::register_heal_route(&mut router).expect("register heal route");
tier::register_tier_route(&mut router).expect("register tier route");
bucket_meta::register_bucket_meta_route(&mut router).expect("register bucket meta route");
quota::register_quota_route(&mut router).expect("register quota route");
kms::register_kms_route(&mut router).expect("register kms route");
oidc::register_oidc_route(&mut router).expect("register oidc route");
register_admin_routes(&mut router);
for (method, path) in [
(Method::GET, compat_admin_alias_path("/v3/is-admin")),
@@ -179,15 +173,20 @@ fn test_admin_alias_paths_match_existing_admin_routes() {
(Method::POST, compat_admin_alias_path("/v3/idp/builtin/policy/detach")),
(Method::GET, compat_admin_alias_path("/v3/idp/builtin/policy-entities")),
(Method::POST, compat_admin_alias_path("/v3/rebalance/start")),
(Method::POST, compat_admin_alias_path("/v3/kms/key/create")),
(Method::GET, compat_admin_alias_path("/v3/kms/key/status")),
(Method::POST, compat_admin_alias_path("/v3/kms/status")),
(Method::GET, compat_admin_alias_path("/v3/kms/keys/test-key")),
(Method::GET, compat_admin_alias_path("/v3/oidc/providers")),
(Method::GET, compat_admin_alias_path("/v3/oidc/authorize/default")),
(Method::GET, compat_admin_alias_path("/v3/oidc/callback/default")),
(Method::GET, compat_admin_alias_path("/v3/oidc/config")),
(Method::PUT, compat_admin_alias_path("/v3/oidc/config/default")),
(Method::GET, compat_admin_alias_path("/export-bucket-metadata")),
(Method::GET, compat_admin_alias_path("/v3/export-bucket-metadata")),
(Method::PUT, compat_admin_alias_path("/import-bucket-metadata")),
(Method::PUT, compat_admin_alias_path("/v3/import-bucket-metadata")),
(Method::POST, compat_admin_alias_path("/v3/kms/key/create")),
(Method::GET, compat_admin_alias_path("/v3/kms/keys/test-key")),
(Method::GET, compat_admin_alias_path("/v3/kms/status")),
(Method::POST, compat_admin_alias_path("/v3/kms/status")),
(Method::GET, compat_admin_alias_path("/v3/kms/key/status")),
] {
assert!(
router.contains_compatible_route(method.clone(), &path),