1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
/*
* ============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.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 = new URI('urn:cps:org.onap.cps:data-updated-event-schema:v1')
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 JSON String to CpsDataUpdatedEvent POJO.'() {
when: 'event JSON String is converted to CpsDataUpdatedEvent'
def notificationMessage = getEventAsJsonStringFromFile()
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
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 CpsDataUpdatedEvent POJO to JSON String.'() {
given: 'Event 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)
.withData(data)
and: 'CpsDataUpdatedEvent with the content'
def cpsDataUpdateEvent = new CpsDataUpdatedEvent()
cpsDataUpdateEvent
.withSchema(EVENT_SCHEMA)
.withId(EVENT_ID)
.withSource(EVENT_SOURCE)
.withType(EVENT_TYPE)
.withContent(content)
when: 'CpsDataUpdatedEvent is converted to JSON string'
def actualMessage = objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(cpsDataUpdateEvent)
then: 'the created JSON String is same as the expected JSON String'
def expectedMessage = getEventAsJsonStringFromFile()
assert actualMessage == expectedMessage
}
def getEventAsJsonStringFromFile() {
return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(
objectMapper.readValue(
this.class.getResource('/bookstore-chapters.json').getText('UTF-8'),
ObjectNode.class)
)
}
}
|
