diff options
author | 2018-11-19 10:28:28 +0000 | |
---|---|---|
committer | 2018-11-19 10:28:28 +0000 | |
commit | e3e2a55c10f00c26a565cdf30a5ae2b49604344d (patch) | |
tree | ce39c7506bf63cb111a3e0a3d85b00faee20dc79 /hv-collector-core/src/test | |
parent | 4d15e5a578dc2c94af2b7f1c7ad02fb44d384501 (diff) | |
parent | 33ff28e3fab91baa36e954c4fd167b615e94993c (diff) |
Merge "Fix Common Event Header fields validation"
Diffstat (limited to 'hv-collector-core/src/test')
-rw-r--r-- | hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/MessageValidatorTest.kt | 23 |
1 files changed, 18 insertions, 5 deletions
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 443dfa2f..25bd4f67 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 @@ -29,10 +29,7 @@ import org.onap.dcae.collectors.veshv.domain.VesEventDomain import org.onap.dcae.collectors.veshv.model.VesMessage import org.onap.dcae.collectors.veshv.tests.utils.commonHeader import org.onap.dcae.collectors.veshv.tests.utils.vesEventBytes - -import org.onap.ves.VesEventOuterClass.CommonEventHeader.Priority -import org.onap.ves.VesEventOuterClass.CommonEventHeader.getDefaultInstance -import org.onap.ves.VesEventOuterClass.CommonEventHeader.newBuilder +import org.onap.ves.VesEventOuterClass.CommonEventHeader.* internal object MessageValidatorTest : Spek({ @@ -91,9 +88,25 @@ internal object MessageValidatorTest : Spek({ .build() val rawMessageBytes = vesEventBytes(commonHeader) - it("should not accept not fully initialized message header ") { + it("should not accept not fully initialized message header") { + val vesMessage = VesMessage(commonHeader, rawMessageBytes) + assertThat(cut.isValid(vesMessage)).describedAs("message validation result").isFalse() + } + } + + on("ves hv message including header with vesEventListenerVersion field not matching required pattern") { + val commonHeader = commonHeader(vesEventListenerVersion = "1.2.3") + val commonHeader2 = commonHeader(vesEventListenerVersion = "sample-version") + + val rawMessageBytes = vesEventBytes(commonHeader) + val rawMessageBytes2 = vesEventBytes(commonHeader2) + + it("should not accept message header") { val vesMessage = VesMessage(commonHeader, rawMessageBytes) assertThat(cut.isValid(vesMessage)).describedAs("message validation result").isFalse() + + val vesMessage2 = VesMessage(commonHeader2, rawMessageBytes2) + assertThat(cut.isValid(vesMessage2)).describedAs("second message validation result").isFalse() } } } |