class CpsDataUpdateEventFactorySpec extends Specification {
def mockCpsDataService = Mock(CpsDataService)
- def mockCpsAdminService = Mock(CpsAdminService)
- def objectUnderTest = new CpsDataUpdatedEventFactory(mockCpsDataService, mockCpsAdminService)
+ def objectUnderTest = new CpsDataUpdatedEventFactory(mockCpsDataService)
- def myDataspaceName = 'my-dataspace'
- def myAnchorName = 'my-anchorname'
- def mySchemasetName = 'my-schemaset-name'
def dateTimeFormat = 'yyyy-MM-dd\'T\'HH:mm:ss.SSSZ'
def 'Create a CPS data updated event successfully: #scenario'() {
- given: 'cps admin service is able to return anchor details'
- mockCpsAdminService.getAnchor(myDataspaceName, myAnchorName) >>
- new Anchor(myAnchorName, myDataspaceName, mySchemasetName)
+ given: 'an anchor which has been updated'
+ def anchor = new Anchor('my-anchorname', 'my-dataspace', 'my-schemaset-name')
and: 'cps data service returns the data node details'
def xpath = '/'
def dataNode = new DataNodeBuilder().withXpath(xpath).withLeaves(['leafName': 'leafValue']).build()
mockCpsDataService.getDataNode(
- myDataspaceName, myAnchorName, xpath, FetchDescendantsOption.INCLUDE_ALL_DESCENDANTS) >> dataNode
+ 'my-dataspace', 'my-anchorname', xpath, FetchDescendantsOption.INCLUDE_ALL_DESCENDANTS) >> dataNode
when: 'CPS data updated event is created'
- def cpsDataUpdatedEvent = objectUnderTest.createCpsDataUpdatedEvent(myDataspaceName,
- myAnchorName, DateTimeUtility.toOffsetDateTime(inputObservedTimestamp), Operation.CREATE)
+ def cpsDataUpdatedEvent = objectUnderTest.createCpsDataUpdatedEvent(anchor,
+ DateTimeUtility.toOffsetDateTime(inputObservedTimestamp), Operation.CREATE)
then: 'CPS data updated event is created with correct envelope'
with(cpsDataUpdatedEvent) {
type == 'org.onap.cps.data-updated-event'
assert observedTimestamp == inputObservedTimestamp
else
assert OffsetDateTime.now().minusSeconds(20).isBefore(
- DateTimeUtility.toOffsetDateTime(observedTimestamp))
- assert anchorName == myAnchorName
- assert dataspaceName == myDataspaceName
- assert schemaSetName == mySchemasetName
+ DateTimeUtility.toOffsetDateTime(observedTimestamp))
+ assert anchorName == 'my-anchorname'
+ assert dataspaceName == 'my-dataspace'
+ assert schemaSetName == 'my-schemaset-name'
assert operation == Content.Operation.CREATE
assert data == new Data().withAdditionalProperty('leafName', 'leafValue')
}
'missing observed timestamp' | null
}
+ def 'Create a delete CPS data updated event successfully'() {
+ given: 'an anchor which has been deleted'
+ def anchor = new Anchor('my-anchorname', 'my-dataspace', 'my-schemaset-name')
+ def deletionTimestamp = '2021-01-01T23:00:00.345-0400'
+ when: 'a delete root data node event is created'
+ def cpsDataUpdatedEvent = objectUnderTest.createCpsDataUpdatedEvent(anchor,
+ DateTimeUtility.toOffsetDateTime(deletionTimestamp), Operation.DELETE)
+ then: 'CPS data updated event is created with correct envelope'
+ with(cpsDataUpdatedEvent) {
+ type == 'org.onap.cps.data-updated-event'
+ source == new URI('urn:cps:org.onap.cps')
+ schema == new URI('urn:cps:org.onap.cps:data-updated-event-schema:v1')
+ StringUtils.hasText(id)
+ content != null
+ }
+ and: 'correct content'
+ with(cpsDataUpdatedEvent.content) {
+ assert isExpectedDateTimeFormat(observedTimestamp): "$observedTimestamp is not in $dateTimeFormat format"
+ assert observedTimestamp == deletionTimestamp
+ assert anchorName == 'my-anchorname'
+ assert dataspaceName == 'my-dataspace'
+ assert schemaSetName == 'my-schemaset-name'
+ assert operation == Content.Operation.DELETE
+ assert data == null
+ }
+ }
+
def isExpectedDateTimeFormat(String observedTimestamp) {
try {
DateTimeFormatter.ofPattern(dateTimeFormat).parse(observedTimestamp)