sources/hv-collector-core/src/test/kotlin/org/onap/dcae/collectors/veshv/impl/VesDecoderTest.kt

   1 /*
   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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20 package org.onap.dcae.collectors.veshv.impl
  21
  22 import arrow.core.Option
  23 import com.google.protobuf.ByteString
  24 import org.jetbrains.spek.api.Spek
  25 import org.jetbrains.spek.api.dsl.given
  26 import org.jetbrains.spek.api.dsl.it
  27 import org.jetbrains.spek.api.dsl.on
  28 import org.onap.dcae.collectors.veshv.domain.ByteData
  29 import org.onap.dcae.collectors.veshv.domain.VesEventDomain.HEARTBEAT
  30 import org.onap.dcae.collectors.veshv.model.VesMessage
  31 import org.onap.dcae.collectors.veshv.tests.utils.commonHeader
  32 import org.onap.dcae.collectors.veshv.tests.utils.vesEventBytes
  33 import java.nio.charset.Charset
  34 import kotlin.test.assertTrue
  35 import kotlin.test.fail
  36
  37
  38 internal object VesDecoderTest : Spek({
  39
  40     given("ves message decoder") {
  41         val cut = VesDecoder()
  42
  43         on("ves hv message bytes") {
  44             val commonHeader = commonHeader(HEARTBEAT)
  45             val rawMessageBytes = vesEventBytes(commonHeader, ByteString.copyFromUtf8("highvolume measurements"))
  46
  47             it("should decode only header and pass it on along with raw message") {
  48                 val expectedMessage = VesMessage(
  49                         commonHeader,
  50                         rawMessageBytes
  51                 )
  52
  53                 assertTrue {
  54                     cut.decode(rawMessageBytes).exists {
  55                         it == expectedMessage
  56                     }
  57                 }
  58             }
  59         }
  60
  61         on("invalid ves hv message bytes") {
  62             val rawMessageBytes = ByteData("ala ma kota".toByteArray(Charset.defaultCharset()))
  63
  64             it("should throw error") {
  65                 assertFailedWithError(cut.decode(rawMessageBytes))
  66             }
  67         }
  68     }
  69 })
  70
  71 private fun <A> assertFailedWithError(option: Option<A>) =
  72         option.exists {
  73             fail("Error expected")
  74         }