2 * ============LICENSE_START=======================================================
3 * dcaegen2-collectors-veshv
4 * ================================================================================
5 * Copyright (C) 2019 NOKIA
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=========================================================
20 package org.onap.dcae.collectors.veshv.config.impl
22 import arrow.core.None
23 import arrow.core.Option
24 import arrow.core.Some
25 import com.nhaarman.mockitokotlin2.mock
26 import org.assertj.core.api.Assertions.assertThat
27 import org.assertj.core.api.Assertions.fail
28 import org.jetbrains.spek.api.Spek
29 import org.jetbrains.spek.api.dsl.describe
30 import org.jetbrains.spek.api.dsl.it
31 import org.onap.dcae.collectors.veshv.config.api.model.routing
32 import org.onap.dcae.collectors.veshv.config.impl.ConfigurationValidator.Companion.DEFAULT_LOG_LEVEL
33 import org.onap.dcae.collectors.veshv.utils.logging.LogLevel
34 import org.onap.dcaegen2.services.sdk.security.ssl.SecurityKeys
35 import java.time.Duration
37 internal object ConfigurationValidatorTest : Spek({
38 describe("ConfigurationValidator") {
39 val cut = ConfigurationValidator()
41 describe("validating partial configuration with missing fields") {
42 val config = PartialConfiguration(
43 Some(PartialServerConfig(listenPort = Some(1)))
46 it("should return ValidationError") {
47 val result = cut.validate(config)
48 assertThat(result.isLeft()).isTrue()
52 describe("validating configuration with empty log level") {
53 val config = PartialConfiguration(
54 Some(PartialServerConfig(
59 Some(PartialCbsConfig(
63 Some(PartialSecurityConfig(
66 Some(PartialCollectorConfig(
69 Some(routing { }.build())
74 it("should use default log level") {
75 val result = cut.validate(config)
78 fail("Configuration should have been created successfully")
81 assertThat(it.logLevel).isEqualTo(DEFAULT_LOG_LEVEL)
87 describe("validating complete configuration") {
88 val idleTimeoutSec = 10
89 val firstReqDelaySec = 10
90 val securityKeys = Some(mock<SecurityKeys>())
91 val routing = routing { }.build()
93 val config = PartialConfiguration(
94 Some(PartialServerConfig(
99 Some(PartialCbsConfig(
100 Some(firstReqDelaySec),
103 Some(PartialSecurityConfig(
106 Some(PartialCollectorConfig(
114 it("should create valid configuration") {
115 val result = cut.validate(config)
118 fail("Configuration should have been created successfully")
121 assertThat(it.server.idleTimeout)
122 .isEqualTo(Duration.ofSeconds(idleTimeoutSec.toLong()))
124 assertThat(it.security.keys)
125 .isEqualTo(securityKeys)
127 assertThat(it.cbs.firstRequestDelay)
128 .isEqualTo(Duration.ofSeconds(firstReqDelaySec.toLong()))
130 assertThat(it.collector.routing)
137 describe("validating configuration with security disabled") {
138 val idleTimeoutSec = 10
139 val firstReqDelaySec = 10
140 val securityKeys: Option<SecurityKeys> = None
141 val routing = routing { }.build()
143 val config = PartialConfiguration(
144 Some(PartialServerConfig(
146 Some(idleTimeoutSec),
149 Some(PartialCbsConfig(
150 Some(firstReqDelaySec),
153 Some(PartialSecurityConfig(
156 Some(PartialCollectorConfig(
164 it("should create valid configuration") {
165 val result = cut.validate(config)
168 fail("Configuration should have been created successfully but was $it")
171 assertThat(it.server.idleTimeout)
172 .isEqualTo(Duration.ofSeconds(idleTimeoutSec.toLong()))
174 assertThat(it.security.keys)
175 .isEqualTo(securityKeys)
177 assertThat(it.cbs.firstRequestDelay)
178 .isEqualTo(Duration.ofSeconds(firstReqDelaySec.toLong()))
180 assertThat(it.collector.routing)