56 lines
3.2 KiB
Java
56 lines
3.2 KiB
Java
package eu.eudat.configurations;
|
|
|
|
import eu.eudat.depositinterface.repository.RepositoryDeposit;
|
|
import eu.eudat.repository.DepositRepository;
|
|
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.security.oauth2.client.AuthorizedClientServiceReactiveOAuth2AuthorizedClientManager;
|
|
import org.springframework.security.oauth2.client.InMemoryReactiveOAuth2AuthorizedClientService;
|
|
import org.springframework.security.oauth2.client.ReactiveOAuth2AuthorizedClientService;
|
|
import org.springframework.security.oauth2.client.registration.ClientRegistration;
|
|
import org.springframework.security.oauth2.client.registration.InMemoryReactiveClientRegistrationRepository;
|
|
import org.springframework.security.oauth2.client.registration.ReactiveClientRegistrationRepository;
|
|
import org.springframework.security.oauth2.client.web.reactive.function.client.ServerOAuth2AuthorizedClientExchangeFilterFunction;
|
|
import org.springframework.security.oauth2.core.AuthorizationGrantType;
|
|
import org.springframework.web.reactive.function.client.WebClient;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
@Configuration
|
|
@EnableConfigurationProperties({DepositProperties.class})
|
|
public class DepositConfiguration {
|
|
|
|
private final DepositProperties properties;
|
|
|
|
@Autowired
|
|
public DepositConfiguration(DepositProperties properties) {
|
|
this.properties = properties;
|
|
}
|
|
|
|
@Bean
|
|
@Qualifier("depositClients")
|
|
public List<RepositoryDeposit> depositClients() {
|
|
List<RepositoryDeposit> clients = new ArrayList<>();
|
|
for (DepositProperties.DepositSource source: properties.getSources()) {
|
|
// ClientRegistration clientRegistration = ClientRegistration
|
|
// .withRegistrationId(source.getClientId())
|
|
// .clientId(source.getClientId())
|
|
// .clientSecret(source.getClientSecret())
|
|
// .scope(source.getScope())
|
|
// .issuerUri(source.getIssuerUrl())
|
|
// .authorizationGrantType(AuthorizationGrantType.JWT_BEARER)
|
|
// .build();
|
|
// ReactiveClientRegistrationRepository clientRegistrationRepository = new InMemoryReactiveClientRegistrationRepository(clientRegistration);
|
|
// ReactiveOAuth2AuthorizedClientService clientService = new InMemoryReactiveOAuth2AuthorizedClientService(clientRegistrationRepository);
|
|
// AuthorizedClientServiceReactiveOAuth2AuthorizedClientManager authorizedClientManager = new AuthorizedClientServiceReactiveOAuth2AuthorizedClientManager(clientRegistrationRepository, clientService);
|
|
// ServerOAuth2AuthorizedClientExchangeFilterFunction oauth = new ServerOAuth2AuthorizedClientExchangeFilterFunction(authorizedClientManager);
|
|
// clients.add(new DepositRepository(WebClient.builder().baseUrl(source.getUrl() + "/api/deposit").filters(exchangeFilterFunctions -> exchangeFilterFunctions.add(oauth)).build()));
|
|
}
|
|
return clients;
|
|
}
|
|
}
|