Roman Zabaluev 2 éve
szülő
commit
4da67e8b1b

+ 3 - 4
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/rbac/AccessControlService.java

@@ -51,6 +51,7 @@ import reactor.core.publisher.Mono;
 @Slf4j
 public class AccessControlService {
 
+  public static final String ACCESS_DENIED = "Access denied";
   @Nullable
   private final InMemoryReactiveClientRegistrationRepository clientRegistrationRepository;
   private final RoleBasedAccessControlProperties properties;
@@ -97,15 +98,13 @@ public class AccessControlService {
       return Mono.empty();
     }
 
-    var accessDeniedException = new AccessDeniedException("Access denied");
-
     if (CollectionUtils.isNotEmpty(context.getApplicationConfigActions())) {
       return getUser()
           .doOnNext(user -> {
             boolean accessGranted = isApplicationConfigAccessible(context, user);
 
             if (!accessGranted) {
-              throw accessDeniedException;
+              throw new AccessDeniedException(ACCESS_DENIED);
             }
           }).then();
     }
@@ -126,7 +125,7 @@ public class AccessControlService {
                   && isAuditAccessible(context, user);
 
           if (!accessGranted) {
-            throw accessDeniedException;
+            throw new AccessDeniedException(ACCESS_DENIED);
           }
         })
         .then();