src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avc/AvcEventExecutorIntegrationSpec.groovy

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * Copyright (C) 2023 Nordix Foundation
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the 'License');
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *       http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an 'AS IS' BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.cps.ncmp.dmi.notifications.avc
  22
  23 import com.fasterxml.jackson.databind.ObjectMapper
  24 import io.cloudevents.core.CloudEventUtils
  25 import io.cloudevents.jackson.PojoCloudEventDataMapper
  26 import org.onap.cps.ncmp.dmi.api.kafka.MessagingBaseSpec
  27 import org.onap.cps.ncmp.events.avc1_0_0.AvcEvent
  28 import org.spockframework.spring.SpringBean
  29 import org.springframework.boot.test.context.SpringBootTest
  30 import org.springframework.test.annotation.DirtiesContext
  31 import org.testcontainers.spock.Testcontainers
  32
  33 import java.time.Duration
  34
  35 @SpringBootTest(classes = [DmiDataAvcEventProducer])
  36 @Testcontainers
  37 @DirtiesContext
  38 class AvcEventExecutorIntegrationSpec extends MessagingBaseSpec {
  39
  40     @SpringBean
  41     DmiDataAvcEventProducer dmiDataAvcEventProducer = new DmiDataAvcEventProducer(cloudEventKafkaTemplate)
  42
  43     def dmiService = new DmiDataAvcEventSimulationController(dmiDataAvcEventProducer)
  44
  45     def objectMapper = new ObjectMapper()
  46
  47     def 'Publish Avc Event'() {
  48         given: 'a simulated event'
  49             dmiService.simulateEvents(1)
  50         and: 'a consumer subscribed to dmi-cm-events topic'
  51             cloudEventKafkaConsumer.subscribe(['dmi-cm-events'])
  52         when: 'the next event record is consumed'
  53             def record = cloudEventKafkaConsumer.poll(Duration.ofMillis(1500)).iterator().next()
  54         then: 'record has correct topic'
  55             assert record.topic == 'dmi-cm-events'
  56         and: 'the record value can be mapped to an avcEvent'
  57             def dmiDataAvcEvent = record.value()
  58             def convertedAvcEvent = CloudEventUtils.mapData(dmiDataAvcEvent, PojoCloudEventDataMapper.from(objectMapper, AvcEvent.class)).getValue()
  59             assert convertedAvcEvent != null
  60     }
  61 }