summaryrefslogtreecommitdiffstats
path: root/cps-ncmp-service
diff options
context:
space:
mode:
authorraviteja.karumuri <raviteja.karumuri@est.tech>2023-06-30 13:23:33 +0100
committerraviteja.karumuri <raviteja.karumuri@est.tech>2023-07-03 09:58:26 +0100
commit5388f2299156f9a85202c746b790e8e2434eb2c1 (patch)
tree7af37a12e28cc0f24c6cffabd32af0df1e135a81 /cps-ncmp-service
parentabc251870a167f28f0e2c802828ecba9bf57e874 (diff)
Kafka (De)serializtion test case for legacy consumer
# Added test case to verify the legacy consumer able to forward the event to client topic Signed-off-by: raviteja.karumuri <raviteja.karumuri@est.tech> Change-Id: I9c88023028eaa2453e5578b5afb4951a41bf4999
Diffstat (limited to 'cps-ncmp-service')
-rw-r--r--cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy27
1 files changed, 23 insertions, 4 deletions
diff --git a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy
index 78a655b315..14ecd92824 100644
--- a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy
+++ b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/SerializationIntegrationSpec.groovy
@@ -25,6 +25,8 @@ import io.cloudevents.core.builder.CloudEventBuilder
import org.onap.cps.ncmp.api.impl.config.kafka.KafkaConfig
import org.onap.cps.ncmp.api.impl.events.EventsPublisher
import org.onap.cps.ncmp.api.kafka.ConsumerBaseSpec
+import org.onap.cps.ncmp.event.model.DmiAsyncRequestResponseEvent
+import org.onap.cps.ncmp.event.model.NcmpAsyncRequestResponseEvent
import org.onap.cps.ncmp.events.async1_0_0.Data
import org.onap.cps.ncmp.events.async1_0_0.DataOperationEvent
import org.onap.cps.ncmp.events.async1_0_0.Response
@@ -38,7 +40,7 @@ import org.testcontainers.spock.Testcontainers
import java.util.concurrent.TimeUnit
-@SpringBootTest(classes =[DataOperationEventConsumer, RecordFilterStrategies, KafkaConfig])
+@SpringBootTest(classes =[DataOperationEventConsumer, AsyncRestRequestResponseEventConsumer, RecordFilterStrategies, KafkaConfig])
@DirtiesContext
@Testcontainers
@EnableAutoConfiguration
@@ -47,6 +49,9 @@ class SerializationIntegrationSpec extends ConsumerBaseSpec {
@SpringBean
EventsPublisher mockEventsPublisher = Mock()
+ @SpringBean
+ NcmpAsyncRequestResponseEventMapper mapper = Stub() { toNcmpAsyncEvent(_) >> new NcmpAsyncRequestResponseEvent(eventId: 'my-event-id', eventTarget: 'some client topic')}
+
@Autowired
private ObjectMapper objectMapper
@@ -57,15 +62,29 @@ class SerializationIntegrationSpec extends ConsumerBaseSpec {
def 'Forwarding DataOperation Event Data.'() {
given: 'a data operation cloud event'
- def cloudEventSent = createCloudEvent()
+ def cloudEvent = createCloudEvent()
when: 'send the event'
- cloudEventKafkaTemplate.send(topic, cloudEventSent)
+ cloudEventKafkaTemplate.send(topic, cloudEvent)
and: 'wait a little for async processing of message'
TimeUnit.MILLISECONDS.sleep(300)
then: 'the event has been forwarded'
1 * mockEventsPublisher.publishCloudEvent('some client topic', 'my-event-id', _) >> { args -> { capturedForwardedEvent = args[2] } }
and: 'the forwarded event is identical to the event that was sent'
- assert capturedForwardedEvent == cloudEventSent
+ assert capturedForwardedEvent == cloudEvent
+ }
+
+ def 'Forwarding AsyncRestRequestResponse Event Data.'() {
+ given: 'async request response legacy event'
+ def dmiAsyncRequestResponseEvent = new DmiAsyncRequestResponseEvent(eventId: 'my-event-id',eventTarget: 'some client topic')
+ when: 'send the event'
+ legacyEventKafkaTemplate.send(topic, dmiAsyncRequestResponseEvent)
+ and: 'wait a little for async processing of message'
+ TimeUnit.MILLISECONDS.sleep(300)
+ then: 'the event has been forwarded'
+ 1 * mockEventsPublisher.publishEvent('some client topic', 'my-event-id', _) >> { args -> { capturedForwardedEvent = args[2] } }
+ and: 'the captured id and target of the forwarded event is same as the one that was sent'
+ assert capturedForwardedEvent.eventId == dmiAsyncRequestResponseEvent.eventId
+ assert capturedForwardedEvent.eventTarget == dmiAsyncRequestResponseEvent.eventTarget
}
def createCloudEvent() {