Spring Webflux и Keycloak JWT остальные API - PullRequest
Новая
       47

Spring Webflux и Keycloak JWT остальные API

0 голосов
/ 05 июля 2018

Я создаю конечную точку userinfo на моем интерфейсе restflux, как получить доступ к access_token, переданному через заголовок Authorization в вызове rest. Также нужна аналогичная конечная точка для обновления пользователя.

Все примеры, которые я нашел в последней версии Spring 5 / boot 2, касаются защиты веб-приложения. 

@GetMapping("/api/user-info")
    public Map userInfo(OAuth2AuthenticationToken authentication) {
        OAuth2AuthorizedClient authorizedClient = this.getAuthorizedClient(authentication);
        Map userAttributes = Collections.emptyMap();

        String userInfoEndpointUri = authorizedClient
                                    .getClientRegistration()
                                    .getProviderDetails()
                                    .getUserInfoEndpoint()
                                    .getUri();

        if (!StringUtils.isEmpty(userInfoEndpointUri)) {
            // userInfoEndpointUri is optional for OIDC Clients
            userAttributes = WebClient.builder()
                    .filter(oauth2Credentials(authorizedClient))
                    .build()
                    .get()
                    .uri(userInfoEndpointUri)
                    .retrieve()
                    .bodyToMono(Map.class)
                    .block();
        }

        return userAttributes;
    }

    private OAuth2AuthorizedClient getAuthorizedClient(OAuth2AuthenticationToken authentication) {
        return this.authorizedClientService.loadAuthorizedClient(
                authentication.getAuthorizedClientRegistrationId(), authentication.getName());
    }

    private ExchangeFilterFunction oauth2Credentials(OAuth2AuthorizedClient authorizedClient) {
        return ExchangeFilterFunction.ofRequestProcessor(
                clientRequest -> {
                    ClientRequest authorizedRequest = ClientRequest.from(clientRequest)
                            .header(HttpHeaders.AUTHORIZATION, "Bearer " + authorizedClient.getAccessToken().getTokenValue())
                            .build();
                    return Mono.just(authorizedRequest);
                });
    }

Объект OAuth2AuthenticationToken, определенный в методе, имеет значение null, что понятно, но не уверен, что еще нужно настроить.

Спасибо за вашу помощь.

...