From 06c3751e4769f8c9fa13e4188fb41a2e9c796188 Mon Sep 17 00:00:00 2001 From: Filip Krzywka Date: Mon, 10 Sep 2018 11:35:13 +0200 Subject: Enable ssl-disable option for xNF simulator Change-Id: I8d4459c4b612e6066ae0da9521333fc3083952d3 Issue-ID: DCAEGEN2-760 Signed-off-by: Filip Krzywka --- .../simulators/xnf/impl/adapters/VesHvClient.kt | 23 ++++++++++++++-------- 1 file changed, 15 insertions(+), 8 deletions(-) (limited to 'hv-collector-xnf-simulator') diff --git a/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt b/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt index 22e47d75..d1a5296a 100644 --- a/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt +++ b/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt @@ -19,6 +19,7 @@ */ package org.onap.dcae.collectors.veshv.simulators.xnf.impl.adapters +import arrow.core.Option import io.netty.handler.ssl.ClientAuth import io.netty.handler.ssl.SslContext import io.netty.handler.ssl.SslContextBuilder @@ -48,7 +49,7 @@ class VesHvClient(private val configuration: SimulatorConfiguration) { .options { opts -> opts.host(configuration.vesHost) .port(configuration.vesPort) - .sslContext(createSslContext(configuration.security)) + .sslContext(createSslContext(configuration.security).orNull()) } .build() @@ -92,13 +93,19 @@ class VesHvClient(private val configuration: SimulatorConfiguration) { .then() } - private fun createSslContext(config: SecurityConfiguration): SslContext = - SslContextBuilder.forClient() - .keyManager(config.cert.toFile(), config.privateKey.toFile()) - .trustManager(config.trustedCert.toFile()) - .sslProvider(SslProvider.OPENSSL) - .clientAuth(ClientAuth.REQUIRE) - .build() + private fun createSslContext(config: SecurityConfiguration): Option = + if (config.sslDisable) { + Option.empty() + } else { + Option.just( + SslContextBuilder.forClient() + .keyManager(config.cert.toFile(), config.privateKey.toFile()) + .trustManager(config.trustedCert.toFile()) + .sslProvider(SslProvider.OPENSSL) + .clientAuth(ClientAuth.REQUIRE) + .build() + ) + } private fun NettyOutbound.logConnectionClosed(): NettyOutbound { context().onClose { -- cgit 1.2.3-korg