51 lines
2.3 KiB
Java
51 lines
2.3 KiB
Java
package eu.eudat.configurations;
|
|
|
|
import eu.eudat.depositinterface.repository.RepositoryDeposit;
|
|
import eu.eudat.repository.DepositRepository;
|
|
import gr.cite.commons.web.oidc.apikey.ApiKeyCacheService;
|
|
import gr.cite.commons.web.oidc.apikey.webflux.ApiKeyExchangeFilterFunction;
|
|
import gr.cite.commons.web.oidc.apikey.webflux.ApiKeyWebfluxModel;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Qualifier;
|
|
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Configuration;
|
|
import org.springframework.web.reactive.function.client.WebClient;
|
|
|
|
import java.net.URI;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
@Configuration
|
|
@EnableConfigurationProperties({DepositProperties.class})
|
|
public class DepositConfiguration {
|
|
private static final Logger logger = LoggerFactory.getLogger(DepositConfiguration.class);
|
|
|
|
private final DepositProperties properties;
|
|
|
|
private final ApiKeyCacheService apiKeyCacheService;
|
|
|
|
@Autowired
|
|
public DepositConfiguration(DepositProperties properties, ApiKeyCacheService apiKeyCacheService) {
|
|
this.properties = properties;
|
|
this.apiKeyCacheService = apiKeyCacheService;
|
|
}
|
|
|
|
@Bean
|
|
@Qualifier("depositClients")
|
|
public List<RepositoryDeposit> depositClients() {
|
|
List<RepositoryDeposit> clients = new ArrayList<>();
|
|
for (DepositProperties.DepositSource source: properties.getSources()) {
|
|
|
|
String host = URI.create(source.getUrl()).getHost();
|
|
ApiKeyWebfluxModel apiKeyWebfluxModel = new ApiKeyWebfluxModel(host + "_" + source.getClientId(), source.getIssuerUrl(), source.getClientId(), source.getClientSecret(), source.getScope());
|
|
ApiKeyExchangeFilterFunction apiKeyExchangeFilterFunction = new ApiKeyExchangeFilterFunction(this.apiKeyCacheService, apiKeyWebfluxModel);
|
|
|
|
clients.add(new DepositRepository(WebClient.builder().baseUrl(source.getUrl() + "/api/deposit").filters(exchangeFilterFunctions -> exchangeFilterFunctions.add(apiKeyExchangeFilterFunction)).build()));
|
|
}
|
|
return clients;
|
|
}
|
|
}
|