2 * ============LICENSE_START=======================================================
3 * dcaegen2-collectors-veshv
4 * ================================================================================
5 * Copyright (C) 2019-2021 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 com.nhaarman.mockitokotlin2.mock
23 import com.nhaarman.mockitokotlin2.whenever
24 import org.onap.dcae.collectors.veshv.config.api.model.Route
25 import org.onap.dcae.collectors.veshv.utils.logging.LogLevel
26 import org.onap.dcaegen2.services.sdk.model.streams.dmaap.KafkaSink
27 import reactor.retry.Retry
28 import java.nio.file.Paths
29 import java.time.Duration
31 private fun resourcePathAsString(resource: String) =
32 Paths.get(ConfigurationValidatorTest::class.java.getResource(resource).toURI()).toString()
34 internal val DEFAULT_LOG_LEVEL = LogLevel.INFO
36 internal const val defaultListenPort = 1234
37 internal const val defaultRequestIntervalSec = 3L
38 internal const val defaultIdleTimeoutSec = 10L
39 internal const val defaultFirstReqDelaySec = 10L
41 internal const val KEYSTORE = "test.ks.pkcs12"
42 internal const val KEYSTORE_PASSWORD = "change.me"
43 internal const val TRUSTSTORE = "trust.ks.pkcs12"
44 internal const val TRUSTSTORE_PASSWORD = "change.me.too"
45 internal val KEYSTORE_PASS_FILE = resourcePathAsString("/test.ks.pass")
46 internal val TRUSTSTORE_PASS_FILE = resourcePathAsString("/trust.ks.pass")
48 internal const val DEFAULT_MAX_PAYLOAD_SIZE_BYTES = 1024 * 1024
50 private val sampleSink = mock<KafkaSink>().also {
51 whenever(it.name()).thenReturn("perf3gpp")
52 whenever(it.maxPayloadSizeBytes()).thenReturn(DEFAULT_MAX_PAYLOAD_SIZE_BYTES)
55 internal val sampleStreamsDefinition = listOf(sampleSink)
56 internal val sampleRouting = listOf(Route(sampleSink.name(), sampleSink))
58 internal val mdc = { mapOf("mdc_key" to "mdc_value") }
60 internal fun retry(iterationCount: Long = 1) = Retry
61 .onlyIf<Any> { it.iteration() <= iterationCount }
62 .fixedBackoff(Duration.ofMillis(10))