2 * ============LICENSE_START====================================
3 * DCAEGEN2-SERVICES-SDK
4 * =========================================================
5 * Copyright (C) 2019 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 org.jetbrains.annotations.NotNull;
25 import org.onap.dcaegen2.services.sdk.security.ssl.SecurityKeys;
26 import org.onap.dcaegen2.services.sdk.security.ssl.SslFactory;
27 import org.onap.dcaegen2.services.sdk.security.ssl.TrustStoreKeys;
28 import reactor.netty.http.client.HttpClient;
31 * @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
34 public final class RxHttpClientFactory {
36 private static final SslFactory SSL_FACTORY = new SslFactory();
38 private RxHttpClientFactory() {
41 public static RxHttpClient create() {
42 return new RxHttpClient(HttpClient.create());
46 public static RxHttpClient create(SecurityKeys securityKeys) {
47 final SslContext context = SSL_FACTORY.createSecureClientContext(securityKeys);
48 return create(context);
51 public static RxHttpClient create(TrustStoreKeys trustStoreKeys) {
52 final SslContext context = SSL_FACTORY.createSecureClientContext(trustStoreKeys);
53 return create(context);
56 public static RxHttpClient createInsecure() {
57 final SslContext context = SSL_FACTORY.createInsecureClientContext();
58 return create(context);
61 private static RxHttpClient create(@NotNull SslContext sslContext) {
62 return new RxHttpClient(HttpClient.create().secure(sslContextSpec -> sslContextSpec.sslContext(sslContext)));