0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add some logging

Browse source
This commit is contained in:
Roman Zabaluev 2023-05-02 16:51:21 +08:00
parent e0b910cb0a
commit 42e025eb3f
1 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/rbac/extractor/OauthAuthorityExtractor.java
View file

@ -66,11 +66,18 @@ public class OauthAuthorityExtractor implements ProviderAuthorityExtractor {
.stream() .stream()
.filter(s -> s.getProvider().equals(Provider.OAUTH)) .filter(s -> s.getProvider().equals(Provider.OAUTH))
.filter(s -> s.getType().equals("role")) .filter(s -> s.getType().equals("role"))
.anyMatch(subject .anyMatch(subject -> {
-> {
var principalRoles = convertRoles(principal.getAttribute(rolesFieldName));
var roleName = subject.getValue(); var roleName = subject.getValue();
return principalRoles.contains(roleName); var principalRoles = convertRoles(principal.getAttribute(rolesFieldName));
var roleMatched = principalRoles.contains(roleName);
if (roleMatched) {
log.debug("Assigning role [{}] to user [{}]", roleName, principal.getName());
} else {
log.trace("Role [{}] not found in user [{}] roles", roleName, principal.getName());
}
return roleMatched;
}) })
) )
.map(Role::getName) .map(Role::getName)