From efceaa86a2fc3eb22b9e30bafd08c0fb6ad2a783 Mon Sep 17 00:00:00 2001 From: kjaniak Date: Wed, 25 Jul 2018 14:02:27 +0200 Subject: Enable UNDEFINED option in commonHeader GPB schema Closes ONAP-655 Change-Id: I6fc830d2b8c7bdd726f306a6fbf7e979f39e03f0 Signed-off-by: kjaniak Issue-ID: DCAEGEN2-601 --- .../collectors/veshv/impl/MessageValidatorTest.kt | 73 +++++++++++++++++----- .../adapters/ConsulConfigurationProviderTest.kt | 4 +- 2 files changed, 59 insertions(+), 18 deletions(-) (limited to 'hv-collector-core/src/test') diff --git a/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/MessageValidatorTest.kt b/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/MessageValidatorTest.kt index a2a26b31..eb8971c3 100644 --- a/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/MessageValidatorTest.kt +++ b/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/MessageValidatorTest.kt @@ -49,18 +49,7 @@ internal object MessageValidatorTest : Spek({ val cut = MessageValidator on("ves hv message including header with fully initialized fields") { - val commonHeader = newBuilder() - .setVersion("1.9") - .setEventName("Sample event name") - .setDomain(Domain.HVRANMEAS) - .setEventId("Sample event Id") - .setSourceName("Sample Source") - .setReportingEntityName(ByteString.copyFromUtf8("Sample byte String")) - .setPriority(Priority.MEDIUM) - .setStartEpochMicrosec(120034455) - .setLastEpochMicrosec(120034459) - .setSequence(2) - .build() + val commonHeader = createInitializedHeaderBuilder().build() it("should accept message with fully initialized message header") { val vesMessage = VesMessage(commonHeader, vesMessageBytes(commonHeader)) @@ -68,9 +57,9 @@ internal object MessageValidatorTest : Spek({ } Domain.values() - .filter { it != Domain.UNRECOGNIZED } - .forEach {domain -> - it("should accept message with $domain domain"){ + .filter { (it != Domain.UNRECOGNIZED && it != Domain.DOMAIN_UNDEFINED) } + .forEach { domain -> + it("should accept message with $domain domain") { val header = newBuilder(commonHeader).setDomain(domain).build() val vesMessage = VesMessage(header, vesMessageBytes(header)) assertThat(cut.isValid(vesMessage)) @@ -87,6 +76,45 @@ internal object MessageValidatorTest : Spek({ } + val domainTestCases = mapOf( + Domain.DOMAIN_UNDEFINED to false, + Domain.FAULT to true + ) + + domainTestCases.forEach { value, expectedResult -> + on("ves hv message including header with domain $value") { + val commonEventHeader = createInitializedHeaderBuilder() + .setDomain(value) + .build() + val vesMessage = VesMessage(commonEventHeader, vesMessageBytes(commonEventHeader)) + + it("should resolve validation result") { + assertThat(cut.isValid(vesMessage)).describedAs("message validation results") + .isEqualTo(expectedResult) + } + } + } + + val priorityTestCases = mapOf( + Priority.PRIORITY_UNDEFINED to false, + Priority.HIGH to true + ) + + priorityTestCases.forEach { value, expectedResult -> + on("ves hv message including header with priority $value") { + val commonEventHeader = createInitializedHeaderBuilder() + .setPriority(value) + .build() + val vesMessage = VesMessage(commonEventHeader, vesMessageBytes(commonEventHeader)) + + it("should resolve validation result") { + assertThat(cut.isValid(vesMessage)).describedAs("message validation results") + .isEqualTo(expectedResult) + } + } + } + + on("ves hv message including header with not initialized fields") { val commonHeader = newBuilder() .setVersion("1.9") @@ -106,4 +134,17 @@ internal object MessageValidatorTest : Spek({ } } } -}) \ No newline at end of file +}) + +private fun createInitializedHeaderBuilder(): CommonEventHeader.Builder = + newBuilder() + .setVersion("1.9") + .setEventName("Sample event name") + .setDomain(Domain.HVRANMEAS) + .setEventId("Sample event Id") + .setSourceName("Sample Source") + .setReportingEntityName(ByteString.copyFromUtf8("Sample byte String")) + .setPriority(Priority.MEDIUM) + .setStartEpochMicrosec(120034455) + .setLastEpochMicrosec(120034459) + .setSequence(2) \ No newline at end of file diff --git a/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt b/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt index 808a6fcc..f4c527a4 100644 --- a/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt +++ b/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/adapters/ConsulConfigurationProviderTest.kt @@ -68,11 +68,11 @@ internal object ConsulConfigurationProviderTest : Spek({ assertEquals("kafka:9093", it.kafkaBootstrapServers) val route1 = it.routing.routes[0] - assertEquals(Domain.HEARTBEAT, route1.domain) + assertEquals(Domain.FAULT, route1.domain) assertEquals("test-topic-1", route1.targetTopic) val route2 = it.routing.routes[1] - assertEquals(Domain.MEASUREMENTS_FOR_VF_SCALING, route2.domain) + assertEquals(Domain.HEARTBEAT, route2.domain) assertEquals("test-topic-2", route2.targetTopic) }.verifyComplete() -- cgit 1.2.3-korg