in src/main/java/com/epam/digital/data/platform/gateway/filter/ClientRegistrySetTokenGatewayFilter.java [64:79]
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
log.info("Replacing token in request");
var authInfoOpt = getAuthInfoFromVault(exchange);
if (authInfoOpt.isEmpty()) {
throw new VaultDataRetrievingException("Auth configs were not found in vault");
}
var token = getTokenFromKeycloak(authInfoOpt.get());
var request =
exchange
.getRequest()
.mutate()
.headers(httpHeaders -> httpHeaders.set(config.getHeader(), token))
.build();
return chain.filter(exchange.mutate().request(request).build());
}