cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/events/cmsubscription/CmNotificationSubscriptionNcmpInEventConsumerSpec.groovy

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * Copyright (c) 2024 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.api.impl.events.cmsubscription
  22
  23 import ch.qos.logback.classic.Level
  24 import ch.qos.logback.classic.Logger
  25 import ch.qos.logback.classic.spi.ILoggingEvent
  26 import ch.qos.logback.core.read.ListAppender
  27 import com.fasterxml.jackson.databind.ObjectMapper
  28 import io.cloudevents.CloudEvent
  29 import io.cloudevents.core.builder.CloudEventBuilder
  30 import org.apache.kafka.clients.consumer.ConsumerRecord
  31 import org.onap.cps.ncmp.api.kafka.MessagingBaseSpec
  32 import org.onap.cps.ncmp.events.cmnotificationsubscription_merge1_0_0.client_to_ncmp.CmNotificationSubscriptionNcmpInEvent
  33 import org.onap.cps.ncmp.utils.TestUtils
  34 import org.onap.cps.utils.JsonObjectMapper
  35 import org.slf4j.LoggerFactory
  36 import org.springframework.beans.factory.annotation.Autowired
  37 import org.springframework.boot.test.context.SpringBootTest
  38
  39 @SpringBootTest(classes = [ObjectMapper, JsonObjectMapper])
  40 class CmNotificationSubscriptionNcmpInEventConsumerSpec extends MessagingBaseSpec {
  41
  42     def mockDmiCmNotificationSubscriptionCacheHandler = Mock(DmiCmNotificationSubscriptionCacheHandler)
  43     def objectUnderTest = new CmNotificationSubscriptionNcmpInEventConsumer(mockDmiCmNotificationSubscriptionCacheHandler)
  44     def logger = Spy(ListAppender<ILoggingEvent>)
  45
  46     @Autowired
  47     JsonObjectMapper jsonObjectMapper
  48
  49     @Autowired
  50     ObjectMapper objectMapper
  51
  52     void setup() {
  53         ((Logger) LoggerFactory.getLogger(CmNotificationSubscriptionNcmpInEventConsumer.class)).addAppender(logger)
  54         logger.start()
  55     }
  56
  57     void cleanup() {
  58         ((Logger) LoggerFactory.getLogger(CmNotificationSubscriptionNcmpInEventConsumer.class)).detachAndStopAllAppenders()
  59     }
  60
  61
  62     def 'Consume valid CMSubscription create message'() {
  63         given: 'a cmsubscription event'
  64             def jsonData = TestUtils.getResourceFileContent('cmSubscription/cmNotificationSubscriptionNcmpInEvent.json')
  65             def testEventSent = jsonObjectMapper.convertJsonString(jsonData, CmNotificationSubscriptionNcmpInEvent.class)
  66             def testCloudEventSent = CloudEventBuilder.v1()
  67                 .withData(objectMapper.writeValueAsBytes(testEventSent))
  68                 .withId('subscriptionCreated')
  69                 .withType('subscriptionCreated')
  70                 .withSource(URI.create('some-resource'))
  71                 .withExtension('correlationid', 'test-cmhandle1').build()
  72             def consumerRecord = new ConsumerRecord<String, CloudEvent>('topic-name', 0, 0, 'event-key', testCloudEventSent)
  73         and: 'notifications are enabled'
  74             objectUnderTest.notificationFeatureEnabled = true
  75         when: 'the valid event is consumed'
  76             objectUnderTest.consumeSubscriptionEvent(consumerRecord)
  77         then: 'an event is logged with level INFO'
  78             def loggingEvent = getLoggingEvent()
  79             assert loggingEvent.level == Level.INFO
  80         and: 'the log indicates the task completed successfully'
  81             assert loggingEvent.formattedMessage == 'Subscription with name cm-subscription-001 to be mapped to hazelcast object...'
  82         and: 'the cache handler method is called once'
  83             1 * mockDmiCmNotificationSubscriptionCacheHandler.add('cm-subscription-001',_)
  84     }
  85
  86     def getLoggingEvent() {
  87         return logger.list[0]
  88     }
  89
  90 }