2 * ============LICENSE_START=======================================================
3 * dcaegen2-collectors-veshv
4 * ================================================================================
5 * Copyright (C) 2018 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.main.config
22 import arrow.core.identity
23 import org.assertj.core.api.Assertions.assertThat
24 import org.jetbrains.spek.api.Spek
25 import org.jetbrains.spek.api.dsl.describe
26 import org.jetbrains.spek.api.dsl.given
27 import org.jetbrains.spek.api.dsl.it
28 import org.jetbrains.spek.api.dsl.on
29 import org.onap.dcae.collectors.veshv.domain.SecurityConfiguration
30 import org.onap.dcae.collectors.veshv.simulators.xnf.config.ArgConfigurationProvider
31 import org.onap.dcae.collectors.veshv.simulators.xnf.config.ArgConfigurationProvider.*
32 import org.onap.dcae.collectors.veshv.simulators.xnf.config.SimulatorConfiguration
33 import java.nio.file.Paths
36 object ArgConfigurationProviderTest : Spek({
37 lateinit var cut: ArgConfigurationProvider
38 val messagesAmount = 3L
39 val vesHost = "localhosting"
40 val pk = Paths.get("/", "etc", "ves", "pk.pem")
41 val cert = Paths.get("/", "etc", "ssl", "certs", "ca-bundle.crt")
42 val trustCert = Paths.get("/", "etc", "ves", "trusted.crt")
45 cut = ArgConfigurationProvider()
48 fun parse(vararg cmdLine: String): SimulatorConfiguration =
49 cut.parse(cmdLine).fold(
50 {throw AssertionError("Parsing result should be present")},
54 describe("parsing arguments") {
55 lateinit var result: SimulatorConfiguration
57 given("all parameters are present in the long form") {
60 result = parse("--ves-port", "6969",
61 "--ves-host", vesHost,
62 "--messages", messagesAmount.toString(),
63 "--private-key-file", pk.toFile().absolutePath,
64 "--cert-file", cert.toFile().absolutePath,
65 "--trust-cert-file", trustCert.toFile().absolutePath)
68 it("should set proper port") {
69 assertThat(result.vesPort).isEqualTo(6969)
73 it("should set proper config url") {
74 assertThat(result.messagesAmount).isEqualTo(messagesAmount)
77 it("should set proper security configuration") {
78 assertThat(result.security).isEqualTo(
79 SecurityConfiguration(pk, cert, trustCert)
84 given("some parameters are present in the short form") {
87 result = parse("-h", "ves-hv", "--ves-port", "666", "-m", messagesAmount.toString())
90 it("should set proper port") {
91 assertThat(result.vesPort).isEqualTo(666)
94 it("should set proper messages amount") {
95 assertThat(result.messagesAmount).isEqualTo(messagesAmount)
99 given("all optional parameters are absent") {
102 result = parse("-h", "ves-hv", "-p", "666")
105 it("should set default messages amount") {
106 assertThat(result.messagesAmount).isEqualTo(DefaultValues.MESSAGES_AMOUNT)
109 on("security config") {
110 val securityConfiguration = result.security
112 it("should set default trust cert file") {
113 assertThat(securityConfiguration.trustedCert.toString()).isEqualTo(DefaultValues.TRUST_CERT_FILE)
116 it("should set default server cert file") {
117 assertThat(securityConfiguration.cert.toString()).isEqualTo(DefaultValues.CERT_FILE)
120 it("should set default private key file") {
121 assertThat(securityConfiguration.privateKey.toString()).isEqualTo(DefaultValues.PRIVATE_KEY_FILE)