+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (c) 2021 Bell Canada.
- * ================================================================================
- * 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.
- * ============LICENSE_END=========================================================
-*/
-
-package org.onap.cps.event
-
-import com.fasterxml.jackson.databind.ObjectMapper
-import com.fasterxml.jackson.databind.node.ObjectNode
-import org.onap.cps.event.model.Content
-import org.onap.cps.event.model.CpsDataUpdatedEvent
-import org.onap.cps.event.model.Data
-import spock.lang.Shared
-import spock.lang.Specification
-
-/**
- * Test class for CpsDataUpdatedEvent.
- */
-class CpsDataUpdatedEventSpec extends Specification {
-
- def objectMapper = new ObjectMapper()
-
- final DATASPACE_NAME = 'my-dataspace'
- final BOOKSTORE_SCHEMA_SET = 'bookstore-schemaset'
- final ANCHOR_NAME = 'chapters'
- final EVENT_TIMESTAMP = '2020-12-01T00:00:00.000+0000'
- final EVENT_ID = '77b8f114-4562-4069-8234-6d059ff742ac'
- final EVENT_SOURCE = new URI('urn:cps:org.onap.cps')
- final EVENT_TYPE = 'org.onap.cps.data-updated-event'
- final EVENT_SCHEMA_V1 = new URI('urn:cps:org.onap.cps:data-updated-event-schema:v1')
- final EVENT_SCHEMA_V2 = new URI('urn:cps:org.onap.cps:data-updated-event-schema:v2')
-
- @Shared
- final DATA = [
- 'test:bookstore': [
- 'bookstore-name': 'Chapters',
- 'categories' : [
- ['code' : '01',
- 'name' : 'SciFi',
- 'books': [
- ['authors' : ['Iain M. Banks'],
- 'lang' : 'en',
- 'price' : 895,
- 'pub_year': '1994',
- 'title' : 'Feersum Endjinn'
- ]
- ]
- ]
- ]
- ]
- ]
-
- def 'Conversion from Event V1 JSON String to CpsDataUpdatedEvent POJO.'() {
- when: 'event V1 JSON String is converted to CpsDataUpdatedEvent'
- def notificationMessage = getEventAsJsonStringFromFile('/event-v1.json')
- def cpsDataUpdatedEvent = objectMapper.readValue(notificationMessage, CpsDataUpdatedEvent.class)
- then: 'CpsDataUpdatedEvent POJO has the excepted values'
- cpsDataUpdatedEvent.id == EVENT_ID
- cpsDataUpdatedEvent.source == EVENT_SOURCE
- cpsDataUpdatedEvent.schema == EVENT_SCHEMA_V1
- cpsDataUpdatedEvent.type == EVENT_TYPE
- def content = cpsDataUpdatedEvent.content
- content.observedTimestamp == EVENT_TIMESTAMP
- content.dataspaceName == DATASPACE_NAME
- content.schemaSetName == BOOKSTORE_SCHEMA_SET
- content.anchorName == ANCHOR_NAME
- content.data.getAdditionalProperties() == DATA
- }
-
- def 'Conversion from Event V2 JSON String to CpsDataUpdatedEvent POJO'() {
- when: 'event V2 JSON String is converted to CpsDataUpdatedEvent'
- def notificationMessage = getEventAsJsonStringFromFile(inputEventJson)
- def cpsDataUpdatedEvent = objectMapper.readValue(notificationMessage, CpsDataUpdatedEvent.class)
- then: 'CpsDataUpdatedEvent POJO has the excepted values'
- with(cpsDataUpdatedEvent) {
- id == EVENT_ID
- source == EVENT_SOURCE
- schema == EVENT_SCHEMA_V2
- type == EVENT_TYPE
- }
- with(cpsDataUpdatedEvent.content) {
- observedTimestamp == EVENT_TIMESTAMP
- dataspaceName == DATASPACE_NAME
- schemaSetName == BOOKSTORE_SCHEMA_SET
- anchorName == ANCHOR_NAME
- operation == expectedOperation
- if (expectedData != null)
- data.getAdditionalProperties() == expectedData
- else
- data == null
- }
- where:
- scenario | inputEventJson || expectedData | expectedOperation
- 'create operation' | '/event-v2-create-operation.json' || DATA | Content.Operation.CREATE
- 'delete operation' | '/event-v2-delete-operation.json' || null | Content.Operation.DELETE
- 'create with additional fields' | '/event-v2-with-additional-properties.json' || DATA | Content.Operation.CREATE
- }
-
- def 'Conversion from CpsDataUpdatedEvent POJO to Event V2 JSON String.'() {
- given: 'Event V2 content with the Data'
- def data = new Data()
- data.withAdditionalProperty('test:bookstore', DATA.'test:bookstore')
- def content = new Content()
- content.withAnchorName(ANCHOR_NAME)
- .withDataspaceName(DATASPACE_NAME)
- .withSchemaSetName(BOOKSTORE_SCHEMA_SET)
- .withObservedTimestamp(EVENT_TIMESTAMP)
- .withOperation(Content.Operation.CREATE)
- .withData(data)
- and: 'CpsDataUpdatedEvent with the content'
- def cpsDataUpdateEvent = new CpsDataUpdatedEvent()
- cpsDataUpdateEvent
- .withSchema(EVENT_SCHEMA_V2)
- .withId(EVENT_ID)
- .withSource(EVENT_SOURCE)
- .withType(EVENT_TYPE)
- .withContent(content)
- when: 'CpsDataUpdatedEvent is converted to Event V2 JSON string'
- def actualMessage = objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(cpsDataUpdateEvent)
- then: 'the created JSON String is same as the expected JSON String'
- def expectedMessage = getEventAsJsonStringFromFile('/event-v2-create-operation.json')
- assert actualMessage == expectedMessage
- }
-
- def getEventAsJsonStringFromFile(String fileName) {
- return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(
- objectMapper.readValue(
- this.class.getResource(fileName).getText('UTF-8'),
- ObjectNode.class)
- )
- }
-}
Code Review / cps.git / blobdiff