2 * ============LICENSE_START====================================
3 * DCAEGEN2-SERVICES-SDK
4 * =========================================================
5 * Copyright (C) 2019-2021 Nokia. All rights reserved.
6 * =========================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=====================================
21 package org.onap.dcaegen2.services.sdk.rest.services.adapters.http;
23 import io.netty.handler.ssl.SslContext;
24 import io.vavr.control.Option;
25 import org.jetbrains.annotations.NotNull;
26 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.config.RxHttpClientConfig;
27 import org.onap.dcaegen2.services.sdk.security.ssl.SecurityKeys;
28 import org.onap.dcaegen2.services.sdk.security.ssl.SslFactory;
29 import org.onap.dcaegen2.services.sdk.security.ssl.TrustStoreKeys;
30 import reactor.netty.http.client.HttpClient;
33 * @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
36 public final class RxHttpClientFactory {
38 private static final SslFactory SSL_FACTORY = new SslFactory();
40 private RxHttpClientFactory() {
43 public static RxHttpClient create() {
44 return new RxHttpClient(HttpClient.create());
47 public static RxHttpClient create(RxHttpClientConfig config) {
48 return createWithConfig(HttpClient.create(), config);
51 public static RxHttpClient create(SecurityKeys securityKeys) {
52 final SslContext context = SSL_FACTORY.createSecureClientContext(securityKeys);
53 return create(context);
56 public static RxHttpClient create(SecurityKeys securityKeys, RxHttpClientConfig config) {
57 final SslContext context = SSL_FACTORY.createSecureClientContext(securityKeys);
58 return create(context, config);
61 public static RxHttpClient create(TrustStoreKeys trustStoreKeys) {
62 final SslContext context = SSL_FACTORY.createSecureClientContext(trustStoreKeys);
63 return create(context);
66 public static RxHttpClient create(TrustStoreKeys trustStoreKeys, RxHttpClientConfig config) {
67 final SslContext context = SSL_FACTORY.createSecureClientContext(trustStoreKeys);
68 return create(context, config);
71 public static RxHttpClient createInsecure() {
72 final SslContext context = SSL_FACTORY.createInsecureClientContext();
73 return create(context);
76 public static RxHttpClient createInsecure(RxHttpClientConfig config) {
77 final SslContext context = SSL_FACTORY.createInsecureClientContext();
78 return create(context, config);
81 private static RxHttpClient create(@NotNull SslContext sslContext) {
82 HttpClient secure = HttpClient.create().secure(sslContextSpec -> sslContextSpec.sslContext(sslContext));
83 return new RxHttpClient(secure);
86 private static RxHttpClient create(@NotNull SslContext sslContext, RxHttpClientConfig config) {
87 HttpClient secure = HttpClient.create().secure(sslContextSpec -> sslContextSpec.sslContext(sslContext));
88 return createWithConfig(secure, config);
91 private static RxHttpClient createWithConfig(HttpClient httpClient, RxHttpClientConfig config) {
92 return Option.of(config.retryConfig())
93 .map(retryConfig -> new RxHttpClient(httpClient, retryConfig))
94 .getOrElse(() -> new RxHttpClient(httpClient));