gerrit.onap Code Review - dcaegen2/collectors/hv-ves.git/blob

   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.adapters
  21
  22 import com.nhaarman.mockito_kotlin.mock
  23 import com.nhaarman.mockito_kotlin.whenever
  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.onap.ves.VesEventV5.VesEvent.CommonEventHeader.Domain
  28 import reactor.core.publisher.Mono
  29 import java.util.*
  30 import kotlin.test.assertEquals
  31
  32 /**
  33  * @author Jakub Dudycz <jakub.dudycz@nokia.com>
  34  * @since May 2018
  35  */
  36 internal object ConsulConfigurationProviderTest : Spek({
  37
  38     given("valid resource url") {
  39         val testUrl = "http://valid-url/"
  40         val httpAdapterMock: HttpAdapter = mock()
  41         val consulConfigProvider = ConsulConfigurationProvider(testUrl, httpAdapterMock)
  42
  43         whenever(httpAdapterMock.getResponse(testUrl)).thenReturn(Mono.just(constructConsulResponse()))
  44
  45
  46         it("should create valid collector configuration") {
  47             val response = consulConfigProvider().blockFirst()
  48             assertEquals("val1", response.kafkaBootstrapServers)
  49             val route = response.routing.routes[0]
  50             assertEquals(Domain.MEASUREMENTS_FOR_VF_SCALING, route.domain)
  51             assertEquals("val3", route.targetTopic)
  52         }
  53     }
  54 })
  55
  56 fun constructConsulResponse(): String {
  57
  58     val config = """{
  59         "kafkaBootstrapServers": "val1",
  60         "routing": {
  61             "fromDomain": 2,
  62             "toTopic": "val3"
  63         }
  64     }"""
  65
  66     val encodedValue = String(Base64.getEncoder().encode(config.toByteArray()))
  67
  68     return """[
  69         {
  70             "CreateIndex": 100,
  71             "ModifyIndex": 200,
  72             "LockIndex": 200,
  73             "Key": "zip",
  74             "Flags": 0,
  75             "Value": "$encodedValue",
  76             "Session": "adf4238a-882b-9ddc-4a9d-5b6758e4159e"
  77         }
  78     ]"""
  79 }