gerrit.onap Code Review - cps.git/blob

   1 package org.onap.cps.ncmp.api.impl.events.cmsubscription
   2
   3 import com.fasterxml.jackson.databind.ObjectMapper
   4 import io.cloudevents.CloudEvent
   5 import org.onap.cps.events.EventsPublisher
   6 import org.onap.cps.ncmp.api.impl.events.mapper.CloudEventMapper
   7 import org.onap.cps.ncmp.events.cmsubscription_merge1_0_0.ncmp_to_client.CmNotificationSubscriptionNcmpOutEvent
   8 import org.onap.cps.ncmp.events.cmsubscription_merge1_0_0.ncmp_to_client.Data
   9 import org.onap.cps.utils.JsonObjectMapper
  10 import spock.lang.Specification
  11
  12 class CmNotificationSubscriptionNcmpOutEventProducerSpec extends Specification {
  13
  14     def mockEventsPublisher = Mock(EventsPublisher)
  15     def jsonObjectMapper = new JsonObjectMapper(new ObjectMapper())
  16
  17     def objectUnderTest = new CmNotificationSubscriptionNcmpOutEventProducer(mockEventsPublisher, jsonObjectMapper)
  18
  19     def 'Create and Publish Cm Notification Subscription DMI In Event'() {
  20         given: 'a cm subscription response for the client'
  21             def subscriptionId = 'test-subscription-id'
  22             def eventType = 'subscriptionCreateResponse'
  23             def cmNotificationSubscriptionNcmpOutEvent = new CmNotificationSubscriptionNcmpOutEvent(data: new Data(subscriptionId: 'sub-1', acceptedTargets: ['ch-1', 'ch-2']))
  24         and: 'also we have target topic for publishing to client'
  25             objectUnderTest.cmNotificationSubscriptionNcmpOutEventTopic = 'client-test-topic'
  26         when: 'the event is published'
  27             objectUnderTest.publishCmNotificationSubscriptionNcmpOutEvent(subscriptionId, eventType, cmNotificationSubscriptionNcmpOutEvent)
  28         then: 'the event contains the required attributes'
  29             1 * mockEventsPublisher.publishCloudEvent(_, _, _) >> {
  30                 args ->
  31                     {
  32                         assert args[0] == 'client-test-topic'
  33                         assert args[1] == subscriptionId
  34                         def cmNotificationSubscriptionNcmpOutEventAsCloudEvent = (args[2] as CloudEvent)
  35                         assert cmNotificationSubscriptionNcmpOutEventAsCloudEvent.getExtension('correlationid') == subscriptionId
  36                         assert cmNotificationSubscriptionNcmpOutEventAsCloudEvent.type == 'subscriptionCreateResponse'
  37                         assert cmNotificationSubscriptionNcmpOutEventAsCloudEvent.source.toString() == 'NCMP'
  38                         assert CloudEventMapper.toTargetEvent(cmNotificationSubscriptionNcmpOutEventAsCloudEvent, CmNotificationSubscriptionNcmpOutEvent) == cmNotificationSubscriptionNcmpOutEvent
  39                     }
  40             }
  41     }
  42
  43
  44 }