Установите аутентификацию вручную с помощью ReactiveSecurityContextHolder - PullRequest
Новая
       7

Установите аутентификацию вручную с помощью ReactiveSecurityContextHolder

1 голос
/ 03 апреля 2019

Я пытаюсь настроить Spring Security с помощью Spring Web Flux. Я не понимаю, как вручную установить SecurityContext с помощью ReactiveSecurityContextHolder. У вас есть какой-либо ресурс или подсказка? Возьмем, к примеру, этот фильтр, который я написал, который читает токен JWT и должен установить аутентификацию вручную: 

@Slf4j
public class JwtTokenAuthenticationFilter implements WebFilter {

    private final JwtAuthenticationConfig config;

    private final JwtParser jwtParser = Jwts.parser();

    public JwtTokenAuthenticationFilter(JwtAuthenticationConfig config) {
        this.config = config;
        jwtParser.setSigningKey(config.getSecret().getBytes());
    }

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {

        String token = exchange.getRequest().getHeaders().getFirst(config.getHeader());
        if (token != null && token.startsWith(config.getPrefix() + " ")) {
            token = token.replace(config.getPrefix() + " ", "");
            try {
                Claims claims = jwtParser.parseClaimsJws(token).getBody();
                String username = claims.getSubject();
                @SuppressWarnings("unchecked")
                List<String> authorities = claims.get("authorities", List.class);
                if (username != null) {
                    UsernamePasswordAuthenticationToken auth = new UsernamePasswordAuthenticationToken(username, null,
                            authorities.stream().map(SimpleGrantedAuthority::new).collect(Collectors.toList()));

                    // TODO set authentication into ReactiveSecurityContextHolder 
                }
            } catch (Exception ex) {
                log.warn(ex.toString(), ex);
                ReactiveSecurityContextHolder.clearContext();
            }
        }
        return chain.filter(exchange);
    }
}

1 Ответ

0 голосов
/ 04 апреля 2019

Мне удалось обновить SecurityContext, позвонив по номеру: 

return chain.filter(exchange).subscriberContext(ReactiveSecurityContextHolder.withAuthentication(auth));

Исправьте меня, если я ошибаюсь или есть лучший способ управлять им.

...