summaryrefslogtreecommitdiffstats
path: root/src/test
diff options
context:
space:
mode:
authormpriyank <priyank.maheshwari@est.tech>2023-08-24 14:20:51 +0100
committermpriyank <priyank.maheshwari@est.tech>2023-08-25 15:07:20 +0100
commitb86ef87781764606358ace875ef13f36e39502d0 (patch)
tree21cd8853c1e8186e8920250c083f06866f2a5955 /src/test
parent5272927ea8fd21487d640e22e62c087913e302f5 (diff)
Fix pojos and classes with new cps version
- incorporate changes done on pojos and schema rename in cps 3.3.6 which affects dmi plugin - refactor the test cases and naming - dmi plugin to use the upgraded cps version Issue-ID: CPS-1828 Change-Id: I98fbb15dac58caac584b9e267be0c1cdc3675b91 Signed-off-by: mpriyank <priyank.maheshwari@est.tech>
Diffstat (limited to 'src/test')
-rw-r--r--src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapperSpec.groovy107
-rw-r--r--src/test/groovy/org/onap/cps/ncmp/dmi/notifications/cmsubscription/CmSubscriptionDmiInEventConsumerSpec.groovy (renamed from src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy)52
-rw-r--r--src/test/groovy/org/onap/cps/ncmp/dmi/notifications/cmsubscription/CmSubscriptionDmiOutEventToCloudEventMapperSpec.groovy73
-rw-r--r--src/test/groovy/org/onap/cps/ncmp/dmi/notifications/mapper/CloudEventMapperSpec.groovy54
4 files changed, 153 insertions, 133 deletions
diff --git a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapperSpec.groovy b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapperSpec.groovy
deleted file mode 100644
index d7b43aac..00000000
--- a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventResponseMapperSpec.groovy
+++ /dev/null
@@ -1,107 +0,0 @@
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2023 Nordix Foundation
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- * SPDX-License-Identifier: Apache-2.0
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.cps.ncmp.dmi.notifications.avcsubscription
-
-import com.fasterxml.jackson.databind.ObjectMapper
-import io.cloudevents.core.builder.CloudEventBuilder
-import org.onap.cps.ncmp.dmi.TestUtils
-import org.onap.cps.ncmp.dmi.exception.CloudEventConstructionException
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.dmi_to_ncmp.Data
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.dmi_to_ncmp.SubscriptionEventResponse
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.dmi_to_ncmp.SubscriptionStatus
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.ncmp_to_dmi.CmHandle
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.ncmp_to_dmi.SubscriptionEvent
-import org.spockframework.spring.SpringBean
-import org.springframework.beans.factory.annotation.Autowired
-import org.springframework.boot.test.context.SpringBootTest
-import spock.lang.Specification
-
-@SpringBootTest(classes = [ObjectMapper])
-class SubscriptionEventResponseMapperSpec extends Specification {
-
- @Autowired
- def objectMapper = new ObjectMapper()
-
- @SpringBean
- SubscriptionEventResponseMapper objectUnderTest = new SubscriptionEventResponseMapper()
-
- def 'Convert a SubscriptionResponseEvent to CloudEvent successfully.'() {
- given: 'a SubscriptionResponseEvent and an event key'
- def dmiName = 'test-ncmp-dmi'
- def responseStatus = SubscriptionStatus.Status.ACCEPTED
- def subscriptionStatuses = [new SubscriptionStatus(id: 'CmHandle1', status: responseStatus),
- new SubscriptionStatus(id: 'CmHandle2', status: responseStatus)]
- def subscriptionEventResponseData = new Data(subscriptionName: 'cm-subscription-001',
- clientId: 'SCO-9989752', dmiName: 'ncmp-dmi-plugin', subscriptionStatus: subscriptionStatuses)
- def subscriptionEventResponse =
- new SubscriptionEventResponse().withData(subscriptionEventResponseData)
- when: 'a SubscriptionResponseEvent is converted'
- def result = objectUnderTest.toCloudEvent(subscriptionEventResponse,"subscriptionCreatedStatus", dmiName)
- then: 'SubscriptionResponseEvent is converted as expected'
- def expectedCloudEvent = CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create('test-ncmp-dmi'))
- .withType("subscriptionCreated")
- .withDataSchema(URI.create("urn:cps:" + SubscriptionEventResponse.class.getName() + ":1.0.0"))
- .withExtension("correlationid", subscriptionEventResponse.getData().getClientId() + ":"
- + subscriptionEventResponse.getData().getSubscriptionName())
- .withData(objectMapper.writeValueAsBytes(subscriptionEventResponse)).build()
- assert expectedCloudEvent.data == result.data
- }
-
- def 'Map the Cloud Event to data of the subscription event with incorrect content causes an exception'() {
- given: 'an empty subscription response event and event key'
- def dmiName = 'test-ncmp-dmi'
- def testSubscriptionEventResponse = new SubscriptionEventResponse()
- when: 'the subscription response event map to data of cloud event'
- objectUnderTest.toCloudEvent(testSubscriptionEventResponse, "subscriptionCreatedStatus", dmiName)
- then: 'a run time exception is thrown'
- thrown(CloudEventConstructionException)
- }
-
- def 'Convert a CloudEvent to SubscriptionEvent.'() {
- given: 'a CloudEvent'
- def eventKey = UUID.randomUUID().toString()
- def jsonData = TestUtils.getResourceFileContent('avcSubscriptionCreationEvent.json')
- def subscriptionEvent = objectMapper.readValue(jsonData, SubscriptionEvent.class)
- def cloudEvent = CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create('test-ncmp-dmi'))
- .withType("subscriptionCreated")
- .withDataSchema(URI.create("urn:cps:" + SubscriptionEvent.class.getName() + ":1.0.0"))
- .withExtension("correlationid", eventKey)
- .withData(objectMapper.writeValueAsBytes(subscriptionEvent)).build()
- when: 'a SubscriptionEvent is formed'
- def result = objectUnderTest.toSubscriptionEvent(cloudEvent)
- then: 'Confirm SubscriptionEvent was formed as expected'
- assert result == subscriptionEvent
- }
-
- def 'Convert a CloudEvent with Null data to SubscriptionEvent.'() {
- given: 'a CloudEvent with null data'
- def eventKey = UUID.randomUUID().toString()
- def cloudEvent = CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create('test-ncmp-dmi'))
- .withType("subscriptionCreated")
- .withDataSchema(URI.create("urn:cps:" + SubscriptionEvent.class.getName() + ":1.0.0"))
- .withExtension("correlationid", eventKey)
- .withData(null).build()
- when: 'a SubscriptionEvent is formed'
- def result = objectUnderTest.toSubscriptionEvent(cloudEvent)
- then: 'Confirm SubscriptionEventResponse was formed as expected'
- assert result == null
- }
-} \ No newline at end of file
diff --git a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/cmsubscription/CmSubscriptionDmiInEventConsumerSpec.groovy
index 8382f67f..bf15f00c 100644
--- a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/avcsubscription/SubscriptionEventConsumerSpec.groovy
+++ b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/cmsubscription/CmSubscriptionDmiInEventConsumerSpec.groovy
@@ -18,7 +18,7 @@
* ============LICENSE_END=========================================================
*/
-package org.onap.cps.ncmp.dmi.notifications.avcsubscription
+package org.onap.cps.ncmp.dmi.notifications.cmsubscription
import com.fasterxml.jackson.databind.ObjectMapper
import io.cloudevents.CloudEvent
@@ -26,11 +26,11 @@ import io.cloudevents.core.builder.CloudEventBuilder
import org.apache.kafka.clients.consumer.ConsumerRecord
import org.onap.cps.ncmp.dmi.TestUtils
import org.onap.cps.ncmp.dmi.api.kafka.MessagingBaseSpec
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.ncmp_to_dmi.CmHandle
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.ncmp_to_dmi.SubscriptionEvent
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.dmi_to_ncmp.Data
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.dmi_to_ncmp.SubscriptionEventResponse
-import org.onap.cps.ncmp.events.avcsubscription1_0_0.dmi_to_ncmp.SubscriptionStatus
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.CmSubscriptionDmiOutEvent
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.Data
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.SubscriptionStatus
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.ncmp_to_dmi.CmHandle
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.ncmp_to_dmi.CmSubscriptionDmiInEvent
import org.spockframework.spring.SpringBean
import org.springframework.boot.test.context.SpringBootTest
import org.springframework.test.annotation.DirtiesContext
@@ -41,16 +41,16 @@ import java.time.Duration
import java.time.OffsetDateTime
import java.time.ZoneId
-@SpringBootTest(classes = [SubscriptionEventConsumer])
+@SpringBootTest(classes = [CmSubscriptionDmiInEventConsumer])
@Testcontainers
@DirtiesContext
-class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
+class CmSubscriptionDmiInEventConsumerSpec extends MessagingBaseSpec {
def objectMapper = new ObjectMapper()
def testTopic = 'dmi-ncmp-cm-avc-subscription'
@SpringBean
- SubscriptionEventConsumer objectUnderTest = new SubscriptionEventConsumer(cloudEventKafkaTemplate)
+ CmSubscriptionDmiInEventConsumer objectUnderTest = new CmSubscriptionDmiInEventConsumer(cloudEventKafkaTemplate)
def 'Sends subscription cloud event response successfully.'() {
given: 'an subscription event response'
@@ -59,15 +59,15 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
def responseStatus = SubscriptionStatus.Status.ACCEPTED
def subscriptionStatuses = [new SubscriptionStatus(id: 'CmHandle1', status: responseStatus),
new SubscriptionStatus(id: 'CmHandle2', status: responseStatus)]
- def subscriptionEventResponseData = new Data(subscriptionName: 'cm-subscription-001',
+ def cmSubscriptionDmiOutEventData = new Data(subscriptionName: 'cm-subscription-001',
clientId: 'SCO-9989752', dmiName: 'ncmp-dmi-plugin', subscriptionStatus: subscriptionStatuses)
def subscriptionEventResponse =
- new SubscriptionEventResponse().withData(subscriptionEventResponseData)
+ new CmSubscriptionDmiOutEvent().withData(cmSubscriptionDmiOutEventData)
and: 'consumer has a subscription'
kafkaConsumer.subscribe([testTopic] as List<String>)
when: 'an event is published'
def eventKey = UUID.randomUUID().toString()
- objectUnderTest.sendSubscriptionResponseMessage(eventKey, "subscriptionCreatedStatus", subscriptionEventResponse)
+ objectUnderTest.sendCmSubscriptionDmiOutEvent(eventKey, "subscriptionCreatedStatus", subscriptionEventResponse)
and: 'topic is polled'
def records = kafkaConsumer.poll(Duration.ofMillis(1500))
then: 'poll returns one record'
@@ -85,17 +85,17 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
def eventKey = UUID.randomUUID().toString()
def timestamp = new Timestamp(1679521929511)
def jsonData = TestUtils.getResourceFileContent('avcSubscriptionCreationEvent.json')
- def subscriptionEvent = objectMapper.readValue(jsonData, SubscriptionEvent.class)
+ def subscriptionEvent = objectMapper.readValue(jsonData, CmSubscriptionDmiInEvent.class)
objectUnderTest.cmAvcSubscriptionResponseTopic = testTopic
def cloudEvent = CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create('test-ncmp-dmi'))
- .withType(subscriptionType)
- .withDataSchema(URI.create("urn:cps:" + SubscriptionEvent.class.getName() + ":1.0.0"))
- .withExtension("correlationid", eventKey)
- .withTime(OffsetDateTime.ofInstant(timestamp.toInstant(), ZoneId.of("UTC")))
- .withData(objectMapper.writeValueAsBytes(subscriptionEvent)).build()
+ .withType(subscriptionType)
+ .withDataSchema(URI.create("urn:cps:" + CmSubscriptionDmiInEvent.class.getName() + ":1.0.0"))
+ .withExtension("correlationid", eventKey)
+ .withTime(OffsetDateTime.ofInstant(timestamp.toInstant(), ZoneId.of("UTC")))
+ .withData(objectMapper.writeValueAsBytes(subscriptionEvent)).build()
def testEventSent = new ConsumerRecord<String, CloudEvent>('topic-name', 0, 0, eventKey, cloudEvent)
when: 'the valid event is consumed'
- objectUnderTest.consumeSubscriptionEvent(testEventSent)
+ objectUnderTest.consumeCmSubscriptionDmiInEvent(testEventSent)
then: 'no exception is thrown'
noExceptionThrown()
where: 'given #senario'
@@ -112,12 +112,12 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
objectUnderTest.cmAvcSubscriptionResponseTopic = testTopic
def cloudEvent = CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create('test-ncmp-dmi'))
.withType("subscriptionCreated")
- .withDataSchema(URI.create("urn:cps:" + SubscriptionEventResponse.class.getName() + ":1.0.0"))
+ .withDataSchema(URI.create("urn:cps:" + CmSubscriptionDmiOutEvent.class.getName() + ":1.0.0"))
.withTime(OffsetDateTime.ofInstant(timestamp.toInstant(), ZoneId.of("UTC")))
.withExtension("correlationid", eventKey).build()
def testEventSent = new ConsumerRecord<String, CloudEvent>('topic-name', 0, 0, eventKey, cloudEvent)
when: 'the invalid event is consumed'
- objectUnderTest.consumeSubscriptionEvent(testEventSent)
+ objectUnderTest.consumeCmSubscriptionDmiInEvent(testEventSent)
then: 'no exception is thrown and event is logged'
noExceptionThrown()
}
@@ -125,9 +125,9 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
def 'Form a SubscriptionEventResponse from a SubscriptionEvent.'() {
given: 'a SubscriptionEvent'
def jsonData = TestUtils.getResourceFileContent('avcSubscriptionCreationEvent.json')
- def subscriptionEvent = objectMapper.readValue(jsonData, SubscriptionEvent.class)
+ def subscriptionEvent = objectMapper.readValue(jsonData, CmSubscriptionDmiInEvent.class)
when: 'a SubscriptionResponseEvent is formed'
- def result = objectUnderTest.formSubscriptionEventResponse(subscriptionEvent)
+ def result = objectUnderTest.formCmSubscriptionDmiOutEvent(subscriptionEvent)
then: 'Confirm SubscriptionEventResponse was formed as expected'
assert result.data.clientId == "SCO-9989752"
assert result.data.subscriptionName == "cm-subscription-001"
@@ -136,8 +136,8 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
def 'Extract cm handle ids from cm handle successfully.'() {
given: 'a list of cm handles'
def cmHandleIds =
- [new CmHandle(id:'CmHandle1', additionalProperties: ['prop-x':'prop-valuex']),
- new CmHandle(id:'CmHandle2', additionalProperties: ['prop-y':'prop-valuey'])]
+ [new CmHandle(id: 'CmHandle1', additionalProperties: ['prop-x': 'prop-valuex']),
+ new CmHandle(id: 'CmHandle2', additionalProperties: ['prop-y': 'prop-valuey'])]
when: 'extract the cm handle ids'
def result = objectUnderTest.extractCmHandleIds(cmHandleIds)
then: 'cm handle ids are extracted as expected'
@@ -152,7 +152,7 @@ class SubscriptionEventConsumerSpec extends MessagingBaseSpec {
when: 'populate cm handle id to subscriptionStatus'
def result = objectUnderTest.populateSubscriptionStatus(cmHandleIds).status
then: 'cm handle id to subscriptionStatus populated as expected'
- def expectedStatus = [responseStatus,responseStatus]
+ def expectedStatus = [responseStatus, responseStatus]
expectedStatus == result
}
} \ No newline at end of file
diff --git a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/cmsubscription/CmSubscriptionDmiOutEventToCloudEventMapperSpec.groovy b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/cmsubscription/CmSubscriptionDmiOutEventToCloudEventMapperSpec.groovy
new file mode 100644
index 00000000..4d0363c7
--- /dev/null
+++ b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/cmsubscription/CmSubscriptionDmiOutEventToCloudEventMapperSpec.groovy
@@ -0,0 +1,73 @@
+/*
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2023 Nordix Foundation
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.cps.ncmp.dmi.notifications.cmsubscription
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import io.cloudevents.core.builder.CloudEventBuilder
+import org.onap.cps.ncmp.dmi.exception.CloudEventConstructionException
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.CmSubscriptionDmiOutEvent
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.Data
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.SubscriptionStatus
+import org.spockframework.spring.SpringBean
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootTest
+import spock.lang.Specification
+
+@SpringBootTest(classes = [ObjectMapper])
+class CmSubscriptionDmiOutEventToCloudEventMapperSpec extends Specification {
+
+ @Autowired
+ def objectMapper = new ObjectMapper()
+
+ @SpringBean
+ CmSubscriptionDmiOutEventToCloudEventMapper objectUnderTest = new CmSubscriptionDmiOutEventToCloudEventMapper()
+
+ def 'Convert a Cm Subscription DMI Out Event to CloudEvent successfully.'() {
+ given: 'a Cm Subscription DMI Out Event and an event key'
+ def dmiName = 'test-ncmp-dmi'
+ def responseStatus = SubscriptionStatus.Status.ACCEPTED
+ def subscriptionStatuses = [new SubscriptionStatus(id: 'CmHandle1', status: responseStatus),
+ new SubscriptionStatus(id: 'CmHandle2', status: responseStatus)]
+ def cmSubscriptionDmiOutEventData = new Data(subscriptionName: 'cm-subscription-001',
+ clientId: 'SCO-9989752', dmiName: 'ncmp-dmi-plugin', subscriptionStatus: subscriptionStatuses)
+ def cmSubscriptionDmiOutEvent =
+ new CmSubscriptionDmiOutEvent().withData(cmSubscriptionDmiOutEventData)
+ when: 'a Cm Subscription DMI Out Event is converted'
+ def result = objectUnderTest.toCloudEvent(cmSubscriptionDmiOutEvent, "subscriptionCreatedStatus", dmiName)
+ then: 'Cm Subscription DMI Out Event is converted as expected'
+ def expectedCloudEvent = CloudEventBuilder.v1().withId(UUID.randomUUID().toString()).withSource(URI.create('test-ncmp-dmi'))
+ .withType("subscriptionCreated")
+ .withDataSchema(URI.create("urn:cps:" + CmSubscriptionDmiOutEvent.class.getName() + ":1.0.0"))
+ .withExtension("correlationid", cmSubscriptionDmiOutEvent.getData().getClientId() + ":" + cmSubscriptionDmiOutEvent.getData().getSubscriptionName())
+ .withData(objectMapper.writeValueAsBytes(cmSubscriptionDmiOutEvent)).build()
+ assert expectedCloudEvent.data == result.data
+ }
+
+ def 'Map the Cloud Event to data of the subscription event with incorrect content causes an exception'() {
+ given: 'an empty subscription response event and event key'
+ def dmiName = 'test-ncmp-dmi'
+ def cmSubscriptionDmiOutEvent = new CmSubscriptionDmiOutEvent()
+ when: 'the cm subscription dmi out Event map to data of cloud event'
+ objectUnderTest.toCloudEvent(cmSubscriptionDmiOutEvent, "subscriptionCreatedStatus", dmiName)
+ then: 'a run time exception is thrown'
+ thrown(CloudEventConstructionException)
+ }
+} \ No newline at end of file
diff --git a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/mapper/CloudEventMapperSpec.groovy b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/mapper/CloudEventMapperSpec.groovy
new file mode 100644
index 00000000..4e1a7480
--- /dev/null
+++ b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/mapper/CloudEventMapperSpec.groovy
@@ -0,0 +1,54 @@
+/*
+ * ============LICENSE_START========================================================
+ * Copyright (c) 2023 Nordix Foundation.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an 'AS IS' BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.cps.ncmp.dmi.notifications.mapper
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import io.cloudevents.core.builder.CloudEventBuilder
+import org.onap.cps.ncmp.events.cmsubscription1_0_0.client_to_ncmp.CmSubscriptionNcmpInEvent
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootTest
+import spock.lang.Specification
+
+@SpringBootTest(classes = [ObjectMapper])
+class CloudEventMapperSpec extends Specification {
+
+ @Autowired
+ ObjectMapper objectMapper
+
+ def 'Cloud event to Target event type when it is #scenario'() {
+ expect: 'Events mapped correctly'
+ assert mappedCloudEvent == (CloudEventMapper.toTargetEvent(testCloudEvent(), targetClass) != null)
+ where: 'below are the scenarios'
+ scenario | targetClass || mappedCloudEvent
+ 'valid concrete type' | CmSubscriptionNcmpInEvent.class || true
+ 'invalid concrete type' | ArrayList.class || false
+ }
+
+ def testCloudEvent() {
+ return CloudEventBuilder.v1().withData(objectMapper.writeValueAsBytes(new CmSubscriptionNcmpInEvent()))
+ .withId("cmhandle1")
+ .withSource(URI.create('test-source'))
+ .withDataSchema(URI.create('test'))
+ .withType('org.onap.cm.events.cm-subscription')
+ .build()
+ }
+}
+