Skip to content

Commit 9788bb2

Browse files
committed
Fixed provectus#4312 the issue where audit was not working
1 parent 53a6553 commit 9788bb2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/audit/AuditService.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import org.springframework.beans.factory.annotation.Autowired;
3131
import org.springframework.security.core.GrantedAuthority;
3232
import org.springframework.security.core.context.SecurityContext;
33-
import org.springframework.security.core.userdetails.UserDetails;
33+
import org.springframework.security.oauth2.core.oidc.user.OidcUser;
3434
import org.springframework.stereotype.Service;
3535
import reactor.core.publisher.Mono;
3636
import reactor.core.publisher.Signal;
@@ -197,10 +197,10 @@ private Mono<AuthenticatedUser> extractUser(Signal<?> sig) {
197197
if (sig.getContextView().hasKey(key)) {
198198
return sig.getContextView().<Mono<SecurityContext>>get(key)
199199
.map(context -> context.getAuthentication().getPrincipal())
200-
.cast(UserDetails.class)
200+
.cast(OidcUser.class)
201201
.map(user -> {
202202
var roles = user.getAuthorities().stream().map(GrantedAuthority::getAuthority).collect(Collectors.toSet());
203-
return new AuthenticatedUser(user.getUsername(), roles);
203+
return new AuthenticatedUser(user.getName(), roles);
204204
})
205205
.switchIfEmpty(NO_AUTH_USER);
206206
} else {

0 commit comments

Comments
 (0)