|
|
|
|
@ -20,6 +20,7 @@ import java.util.HashMap;
@@ -20,6 +20,7 @@ import java.util.HashMap;
|
|
|
|
|
import java.util.List; |
|
|
|
|
import java.util.Map; |
|
|
|
|
|
|
|
|
|
import io.netty.handler.ssl.SslContextBuilder; |
|
|
|
|
import io.netty.handler.ssl.SslProvider; |
|
|
|
|
import io.netty.handler.ssl.util.InsecureTrustManagerFactory; |
|
|
|
|
import reactor.core.publisher.Mono; |
|
|
|
|
@ -65,13 +66,16 @@ class ReactiveCloudFoundrySecurityService {
@@ -65,13 +66,16 @@ class ReactiveCloudFoundrySecurityService {
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
protected ReactorClientHttpConnector buildTrustAllSslConnector() { |
|
|
|
|
HttpClient client = HttpClient.create() |
|
|
|
|
.secure((sslContextSpec) -> sslContextSpec.forClient() |
|
|
|
|
.sslContext((builder) -> builder.sslProvider(SslProvider.JDK) |
|
|
|
|
.trustManager(InsecureTrustManagerFactory.INSTANCE))); |
|
|
|
|
HttpClient client = HttpClient.create().secure((sslContextSpec) -> sslContextSpec |
|
|
|
|
.forClient().sslContext(this::configureSsl)); |
|
|
|
|
return new ReactorClientHttpConnector(client); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private SslContextBuilder configureSsl(SslContextBuilder builder) { |
|
|
|
|
return builder.sslProvider(SslProvider.JDK) |
|
|
|
|
.trustManager(InsecureTrustManagerFactory.INSTANCE); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* Return a Mono of the access level that should be granted to the given token. |
|
|
|
|
* @param token the token |
|
|
|
|
|